|
@@ -1,9 +1,11 @@
|
|
|
package com.uas.platform.b2c.common.account.controller;
|
|
package com.uas.platform.b2c.common.account.controller;
|
|
|
|
|
|
|
|
|
|
+import com.uas.message.mail.service.MailService;
|
|
|
import com.uas.platform.b2c.common.account.model.Enterprise;
|
|
import com.uas.platform.b2c.common.account.model.Enterprise;
|
|
|
import com.uas.platform.b2c.common.account.model.User;
|
|
import com.uas.platform.b2c.common.account.model.User;
|
|
|
import com.uas.platform.b2c.common.account.model.UserInfo;
|
|
import com.uas.platform.b2c.common.account.model.UserInfo;
|
|
|
import com.uas.platform.b2c.common.account.service.UserService;
|
|
import com.uas.platform.b2c.common.account.service.UserService;
|
|
|
|
|
+import com.uas.platform.b2c.core.config.MessageConf;
|
|
|
import com.uas.platform.b2c.core.support.SystemSession;
|
|
import com.uas.platform.b2c.core.support.SystemSession;
|
|
|
import com.uas.platform.b2c.core.support.log.UsageBufferedLogger;
|
|
import com.uas.platform.b2c.core.support.log.UsageBufferedLogger;
|
|
|
import com.uas.platform.b2c.trade.inquiry.model.TradeCharge;
|
|
import com.uas.platform.b2c.trade.inquiry.model.TradeCharge;
|
|
@@ -19,6 +21,7 @@ import org.springframework.data.jpa.domain.Specification;
|
|
|
import org.springframework.http.HttpHeaders;
|
|
import org.springframework.http.HttpHeaders;
|
|
|
import org.springframework.http.HttpStatus;
|
|
import org.springframework.http.HttpStatus;
|
|
|
import org.springframework.http.ResponseEntity;
|
|
import org.springframework.http.ResponseEntity;
|
|
|
|
|
+import org.springframework.ui.ModelMap;
|
|
|
import org.springframework.util.StringUtils;
|
|
import org.springframework.util.StringUtils;
|
|
|
import org.springframework.web.bind.annotation.*;
|
|
import org.springframework.web.bind.annotation.*;
|
|
|
|
|
|
|
@@ -28,9 +31,7 @@ import javax.persistence.criteria.Predicate;
|
|
|
import javax.persistence.criteria.Root;
|
|
import javax.persistence.criteria.Root;
|
|
|
import javax.servlet.http.HttpServletRequest;
|
|
import javax.servlet.http.HttpServletRequest;
|
|
|
import javax.servlet.http.HttpSession;
|
|
import javax.servlet.http.HttpSession;
|
|
|
-import java.util.List;
|
|
|
|
|
-import java.util.Timer;
|
|
|
|
|
-import java.util.TimerTask;
|
|
|
|
|
|
|
+import java.util.*;
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
|
* 用户信息的请求
|
|
* 用户信息的请求
|
|
@@ -45,6 +46,12 @@ public class UserController {
|
|
|
@Autowired
|
|
@Autowired
|
|
|
private UserService userService;
|
|
private UserService userService;
|
|
|
|
|
|
|
|
|
|
+ @Autowired
|
|
|
|
|
+ private MailService mailService;
|
|
|
|
|
+
|
|
|
|
|
+ @Autowired
|
|
|
|
|
+ private MessageConf messageConf;
|
|
|
|
|
+
|
|
|
private final static UsageBufferedLogger logger = BufferedLoggerManager.getLogger(UsageBufferedLogger.class);
|
|
private final static UsageBufferedLogger logger = BufferedLoggerManager.getLogger(UsageBufferedLogger.class);
|
|
|
|
|
|
|
|
/**
|
|
/**
|
|
@@ -131,7 +138,6 @@ public class UserController {
|
|
|
User sysUser = SystemSession.getUser();
|
|
User sysUser = SystemSession.getUser();
|
|
|
User user = userService.findUserPwdByUserUU(sysUser.getUserUU());
|
|
User user = userService.findUserPwdByUserUU(sysUser.getUserUU());
|
|
|
if (!StringUtils.isEmpty(userEmail)) {
|
|
if (!StringUtils.isEmpty(userEmail)) {
|
|
|
-
|
|
|
|
|
boolean result = user.getUserEmail().equals(userEmail);
|
|
boolean result = user.getUserEmail().equals(userEmail);
|
|
|
if (result) {
|
|
if (result) {
|
|
|
return new ResponseEntity<>(HttpStatus.OK);
|
|
return new ResponseEntity<>(HttpStatus.OK);
|
|
@@ -148,30 +154,22 @@ public class UserController {
|
|
|
* @param newUserEmail 用户输入新邮箱地址
|
|
* @param newUserEmail 用户输入新邮箱地址
|
|
|
*/
|
|
*/
|
|
|
@RequestMapping(value = "/sendCheckCode", method = RequestMethod.GET)
|
|
@RequestMapping(value = "/sendCheckCode", method = RequestMethod.GET)
|
|
|
- public ResponseEntity<String> sendCheckCode(String newUserEmail,final HttpServletRequest request) {
|
|
|
|
|
|
|
+ public ResponseEntity<String> sendCheckCode(String newUserEmail,HttpServletRequest request) {
|
|
|
User sysUser = SystemSession.getUser();
|
|
User sysUser = SystemSession.getUser();
|
|
|
User user = userService.findUserPwdByUserUU(sysUser.getUserUU());
|
|
User user = userService.findUserPwdByUserUU(sysUser.getUserUU());
|
|
|
if (!StringUtils.isEmpty(newUserEmail)) {
|
|
if (!StringUtils.isEmpty(newUserEmail)) {
|
|
|
- //检查是否已经发送
|
|
|
|
|
- final HttpSession session = request.getSession();
|
|
|
|
|
- if(session.getAttribute(String.valueOf(user.getUserUU()))!=null){
|
|
|
|
|
- return new ResponseEntity<>(HttpStatus.EXPECTATION_FAILED);
|
|
|
|
|
- }
|
|
|
|
|
|
|
+ HttpSession session = request.getSession();
|
|
|
//发送邮件
|
|
//发送邮件
|
|
|
- String result = userService.sendCheckCode(newUserEmail);
|
|
|
|
|
- System.out.println(result);
|
|
|
|
|
- if (result!=null && !result.equals("")){
|
|
|
|
|
- /*
|
|
|
|
|
- final Timer timer=new Timer();
|
|
|
|
|
- timer.schedule(new TimerTask() {
|
|
|
|
|
- @Override
|
|
|
|
|
- public void run() {
|
|
|
|
|
- session.removeAttribute(String.valueOf(user.getUserUU()));
|
|
|
|
|
- timer.cancel();
|
|
|
|
|
- }
|
|
|
|
|
- },10*60*1000);
|
|
|
|
|
- */
|
|
|
|
|
|
|
+ ModelMap data = new ModelMap();
|
|
|
|
|
+ String checkCode = String.valueOf((int)((Math.random()*9+1)*100000));
|
|
|
|
|
+ data.put("checkcode", checkCode);
|
|
|
|
|
+ try {
|
|
|
|
|
+ //mailService.send("a4c45a22-436a-430c-9667-4edfd7d04a27", newUserEmail, data);
|
|
|
|
|
+ session.setAttribute("checkCode",checkCode);
|
|
|
|
|
+ session.setAttribute("checkTime",new Date().getTime());
|
|
|
return new ResponseEntity<>(HttpStatus.OK);
|
|
return new ResponseEntity<>(HttpStatus.OK);
|
|
|
|
|
+ } catch (Exception e) {
|
|
|
|
|
+ e.printStackTrace();
|
|
|
}
|
|
}
|
|
|
assert logger != null;
|
|
assert logger != null;
|
|
|
logger.log("用户信息", "验证用户邮箱地址,UU:" + user.getUserUU());
|
|
logger.log("用户信息", "验证用户邮箱地址,UU:" + user.getUserUU());
|
|
@@ -179,6 +177,73 @@ public class UserController {
|
|
|
return new ResponseEntity<>(HttpStatus.EXPECTATION_FAILED);
|
|
return new ResponseEntity<>(HttpStatus.EXPECTATION_FAILED);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ /**
|
|
|
|
|
+ * 校验验证码是否正确
|
|
|
|
|
+ * @param checkCode 用户输入验证码
|
|
|
|
|
+ * @param request
|
|
|
|
|
+ * @return
|
|
|
|
|
+ */
|
|
|
|
|
+ @RequestMapping(value = "/validCheckCode", method = RequestMethod.GET)
|
|
|
|
|
+ public Map<String,Object> validCheckCode(String checkCode, HttpServletRequest request) {
|
|
|
|
|
+ HttpSession session = request.getSession();
|
|
|
|
|
+ Map<String,Object> result = new HashMap<String,Object>();
|
|
|
|
|
+ if(checkCode!=null){
|
|
|
|
|
+ Long checkTime = (Long)session.getAttribute("checkTime");
|
|
|
|
|
+ Long nowTime = new Date().getTime();
|
|
|
|
|
+ String _checkCode = (String)session.getAttribute("checkCode");
|
|
|
|
|
+ //验证码失效
|
|
|
|
|
+ if((nowTime-checkTime)>10*60*1000 || _checkCode==null){
|
|
|
|
|
+ result.put("status",2);
|
|
|
|
|
+ result.put("message","验证码失效");
|
|
|
|
|
+ return result;
|
|
|
|
|
+ }
|
|
|
|
|
+ //验证码错误
|
|
|
|
|
+ if(!_checkCode.equals(checkCode)) {
|
|
|
|
|
+ result.put("status",0);
|
|
|
|
|
+ result.put("message","验证码错误");
|
|
|
|
|
+ return result;
|
|
|
|
|
+ }
|
|
|
|
|
+ //验证码正确
|
|
|
|
|
+ if(_checkCode.equals(checkCode)) {
|
|
|
|
|
+ result.put("status",1);
|
|
|
|
|
+ result.put("message","验证码正确");
|
|
|
|
|
+ return result;
|
|
|
|
|
+ }
|
|
|
|
|
+ }
|
|
|
|
|
+ result.put("status",0);
|
|
|
|
|
+ result.put("message","验证码错误");
|
|
|
|
|
+ return result;
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
|
|
+ /**
|
|
|
|
|
+ * 修改用户邮箱
|
|
|
|
|
+ * @param session
|
|
|
|
|
+ * @param userEmail
|
|
|
|
|
+ * @param newUserEmail
|
|
|
|
|
+ * @return
|
|
|
|
|
+ */
|
|
|
|
|
+ @RequestMapping(value = "/updateUserEmail", method = RequestMethod.POST)
|
|
|
|
|
+ public ResponseEntity<String> updateUserEmail(HttpSession session, String userEmail, String newUserEmail) {
|
|
|
|
|
+ if (userEmail.equals(newUserEmail)){
|
|
|
|
|
+ throw new IllegalOperatorException("新邮箱地址与旧邮箱地址相同");
|
|
|
|
|
+ }
|
|
|
|
|
+ User sysUser = SystemSession.getUser();
|
|
|
|
|
+ User user = userService.findUserPwdByUserUU(sysUser.getUserUU());
|
|
|
|
|
+ if (!StringUtils.isEmpty(newUserEmail)) {
|
|
|
|
|
+ if(!userService.isEmailUseable(newUserEmail)){
|
|
|
|
|
+ throw new IllegalOperatorException("邮箱已被注册...");
|
|
|
|
|
+ }
|
|
|
|
|
+ user.setUserEmail(newUserEmail);
|
|
|
|
|
+ user = userService.save(user);
|
|
|
|
|
+ session.setAttribute("user", user);
|
|
|
|
|
+ SystemSession.setUser(user);
|
|
|
|
|
+ assert logger != null;
|
|
|
|
|
+ logger.log("用户信息", "修改用户邮箱地址,UU:" + user.getUserUU());
|
|
|
|
|
+ return new ResponseEntity<>(HttpStatus.OK);
|
|
|
|
|
+ } else
|
|
|
|
|
+ throw new IllegalOperatorException("新邮箱地址不能为空");
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
/**
|
|
/**
|
|
|
* 根据UU获取该企业所有人员信息
|
|
* 根据UU获取该企业所有人员信息
|
|
|
* @param enuu 企业uu号
|
|
* @param enuu 企业uu号
|
|
@@ -216,32 +281,6 @@ public class UserController {
|
|
|
return new ResponseEntity<String>(HttpStatus.OK);
|
|
return new ResponseEntity<String>(HttpStatus.OK);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
- /**
|
|
|
|
|
- * 修改用户邮箱
|
|
|
|
|
- * @param session
|
|
|
|
|
- * @param userEmail
|
|
|
|
|
- * @param newUserEmail
|
|
|
|
|
- * @return
|
|
|
|
|
- */
|
|
|
|
|
- @RequestMapping(value = "/updateUserEmail", method = RequestMethod.POST)
|
|
|
|
|
- public ResponseEntity<String> updateUserEmail(HttpSession session, String userEmail, String newUserEmail) {
|
|
|
|
|
- if (userEmail.equals(newUserEmail)){
|
|
|
|
|
- throw new IllegalOperatorException("新邮箱地址与旧邮箱地址相同");
|
|
|
|
|
- }
|
|
|
|
|
- User sysUser = SystemSession.getUser();
|
|
|
|
|
- User user = userService.findUserPwdByUserUU(sysUser.getUserUU());
|
|
|
|
|
- Enterprise enterprise = user.getEnterprise();
|
|
|
|
|
- if (!StringUtils.isEmpty(newUserEmail)) {
|
|
|
|
|
- user = userService.updatePassword(user, userEmail, newUserEmail);
|
|
|
|
|
- user.setEnterprise(enterprise);
|
|
|
|
|
- session.setAttribute("user", user);
|
|
|
|
|
- SystemSession.setUser(user);
|
|
|
|
|
- assert logger != null;
|
|
|
|
|
- logger.log("用户信息", "修改用户邮箱地址,UU:" + user.getUserUU());
|
|
|
|
|
- return new ResponseEntity<>(HttpStatus.OK);
|
|
|
|
|
- } else
|
|
|
|
|
- throw new IllegalOperatorException("新邮箱地址不能为空");
|
|
|
|
|
- }
|
|
|
|
|
/**
|
|
/**
|
|
|
* 删除用户
|
|
* 删除用户
|
|
|
*
|
|
*
|