Commit 81a94a05 authored by 贷前—徐菲's avatar 贷前—徐菲

review代码

parent 934bedb3
...@@ -43,6 +43,6 @@ public class Bootstrap { ...@@ -43,6 +43,6 @@ public class Bootstrap {
springApplication.setRegisterShutdownHook(true); springApplication.setRegisterShutdownHook(true);
springApplication.run(args); springApplication.run(args);
log.info("server start..."); log.info("server start...");
//Sentry.init("http://13ef5642903a414c910f8d0e0a2c56ee:8b351ad1abf44de3b4c25f39105fb927@172.16.4.89:9000/6"); Sentry.init("http://13ef5642903a414c910f8d0e0a2c56ee:8b351ad1abf44de3b4c25f39105fb927@172.16.4.89:9000/6");
} }
} }
package cn.quantgroup.xyqb.controller.internal.user; package cn.quantgroup.xyqb.controller.internal.user;
import cn.quantgroup.xyqb.aspect.logcaller.LogHttpCaller; import cn.quantgroup.xyqb.aspect.logcaller.LogHttpCaller;
import cn.quantgroup.xyqb.controller.IBaseController;
import cn.quantgroup.xyqb.model.JsonResult; import cn.quantgroup.xyqb.model.JsonResult;
import cn.quantgroup.xyqb.model.UserAuthorizedParam;
import cn.quantgroup.xyqb.service.auth.IUserAuthorizedService; import cn.quantgroup.xyqb.service.auth.IUserAuthorizedService;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController; import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource; import javax.annotation.Resource;
import java.util.Map;
/** /**
* @author xufei on 2018/1/5. * @author xufei on 2018/1/5.
...@@ -30,20 +27,20 @@ public class UserAuthorizedController { ...@@ -30,20 +27,20 @@ public class UserAuthorizedController {
@RequestMapping(value = "/hasUserAuthorized") @RequestMapping(value = "/hasUserAuthorized")
public JsonResult hasUserAuthorized(String idNo) { public JsonResult hasUserAuthorized(String idNo) {
LOGGER.info("[hasUserAuthorized]需要校验的用户的身份证号为idNo:{}", idNo); LOGGER.info("[hasUserAuthorized]需要校验的用户的身份证号为idNo:{}", idNo);
return userAuthorizedService.hasUserAuthorized(idNo); return JsonResult.buildSuccessResult(null, userAuthorizedService.hasUserAuthorized(idNo));
} }
@LogHttpCaller @LogHttpCaller
@RequestMapping(value = "/createUserAuthorized") @RequestMapping(value = "/createUserAuthorized")
public JsonResult createUserAuthorized(String name, String idNo, Long userId, String authPattern) { public JsonResult createUserAuthorized(UserAuthorizedParam userAuthorizedParam) {
LOGGER.info("[createUserAuthorized]创建实名账户,name:{},idNo:{},", name, idNo, userId, authPattern); LOGGER.info("[createUserAuthorized]创建实名账户,userAuthorizedParam:{},", userAuthorizedParam);
return userAuthorizedService.createUserAuthorized(name, idNo, userId, authPattern); return JsonResult.buildSuccessResult(null, userAuthorizedService.createUserAuthorized(userAuthorizedParam));
} }
@LogHttpCaller @LogHttpCaller
@RequestMapping(value = "/getUserAuthorizedId") @RequestMapping(value = "/getUserAuthorizedId")
public JsonResult getUserAuthorizedId(Long userId) { public JsonResult getUserAuthorizedId(Long userId) {
LOGGER.info("[getUserAuthorizedId]获取实名账户的id,userId:{}", userId); LOGGER.info("[getUserAuthorizedId]获取实名账户的id,userId:{}", userId);
return userAuthorizedService.getUserAuthorizedId(userId); return JsonResult.buildSuccessResult(null, userAuthorizedService.getUserAuthorizedId(userId));
} }
} }
package cn.quantgroup.xyqb.model;
import lombok.Data;
import lombok.Getter;
/**
* @author xufei on 2018/1/10.
*/
@Getter
@Data
public class UserAuthorizedParam {
private String name;
private String idNo;
private Long userId;
private String authPattern;
}
package cn.quantgroup.xyqb.service.auth; package cn.quantgroup.xyqb.service.auth;
import cn.quantgroup.xyqb.model.JsonResult; import cn.quantgroup.xyqb.model.JsonResult;
import cn.quantgroup.xyqb.model.UserAuthorizedParam;
import java.util.Map; import java.util.Map;
...@@ -14,18 +15,15 @@ public interface IUserAuthorizedService { ...@@ -14,18 +15,15 @@ public interface IUserAuthorizedService {
* @param idNo 身份证号 * @param idNo 身份证号
* @return * @return
*/ */
JsonResult hasUserAuthorized(String idNo); Boolean hasUserAuthorized(String idNo);
/** /**
* 创建实名账户 * 创建实名账户
* *
* @param name 用户姓名 * @param userAuthorizedParam
* @param idNo 身份证号
* @param userId userId
* @param authPattern 认证方式
* @return * @return
*/ */
JsonResult createUserAuthorized(String name, String idNo, Long userId, String authPattern); String createUserAuthorized(UserAuthorizedParam userAuthorizedParam);
/** /**
* 通过userId获取实名账户表的id * 通过userId获取实名账户表的id
...@@ -33,5 +31,5 @@ public interface IUserAuthorizedService { ...@@ -33,5 +31,5 @@ public interface IUserAuthorizedService {
* @param userId userId * @param userId userId
* @return * @return
*/ */
JsonResult getUserAuthorizedId(Long userId); Long getUserAuthorizedId(Long userId);
} }
...@@ -3,7 +3,7 @@ package cn.quantgroup.xyqb.service.auth.impl; ...@@ -3,7 +3,7 @@ package cn.quantgroup.xyqb.service.auth.impl;
import cn.quantgroup.xyqb.Constants; import cn.quantgroup.xyqb.Constants;
import cn.quantgroup.xyqb.entity.UserAuthorized; import cn.quantgroup.xyqb.entity.UserAuthorized;
import cn.quantgroup.xyqb.model.AuthPattern; import cn.quantgroup.xyqb.model.AuthPattern;
import cn.quantgroup.xyqb.model.JsonResult; import cn.quantgroup.xyqb.model.UserAuthorizedParam;
import cn.quantgroup.xyqb.repository.IUserAuthorizedRepository; import cn.quantgroup.xyqb.repository.IUserAuthorizedRepository;
import cn.quantgroup.xyqb.service.auth.IIdCardService; import cn.quantgroup.xyqb.service.auth.IIdCardService;
import cn.quantgroup.xyqb.service.auth.IUserAuthorizedService; import cn.quantgroup.xyqb.service.auth.IUserAuthorizedService;
...@@ -13,6 +13,7 @@ import org.slf4j.LoggerFactory; ...@@ -13,6 +13,7 @@ import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
import javax.annotation.Resource; import javax.annotation.Resource;
import javax.naming.Name;
import java.sql.Timestamp; import java.sql.Timestamp;
import java.text.ParseException; import java.text.ParseException;
...@@ -29,7 +30,7 @@ public class UserAuthorizedServiceImpl implements IUserAuthorizedService { ...@@ -29,7 +30,7 @@ public class UserAuthorizedServiceImpl implements IUserAuthorizedService {
private IUserAuthorizedRepository userAuthorizedRepository; private IUserAuthorizedRepository userAuthorizedRepository;
@Override @Override
public JsonResult hasUserAuthorized(String idNo) { public Boolean hasUserAuthorized(String idNo) {
try { try {
if (StringUtils.isBlank(idNo) || !iIdCardService.isIdCardValid(idNo)) { if (StringUtils.isBlank(idNo) || !iIdCardService.isIdCardValid(idNo)) {
return null; return null;
...@@ -40,18 +41,26 @@ public class UserAuthorizedServiceImpl implements IUserAuthorizedService { ...@@ -40,18 +41,26 @@ public class UserAuthorizedServiceImpl implements IUserAuthorizedService {
UserAuthorized userAuthorized = userAuthorizedRepository.findByIdNo(idNo); UserAuthorized userAuthorized = userAuthorizedRepository.findByIdNo(idNo);
LOGGER.info("[hasUserAuthorized]查询实名账户userAuthorized:{}", userAuthorized); LOGGER.info("[hasUserAuthorized]查询实名账户userAuthorized:{}", userAuthorized);
return JsonResult.buildSuccessResult(null, null != userAuthorized); return null != userAuthorized;
} }
@Override @Override
public JsonResult createUserAuthorized(String name, String idNo, Long userId, String authPattern) { public String createUserAuthorized(UserAuthorizedParam userAuthorizedParam) {
if (null == userAuthorizedParam) {
return Constants.CREATE_USER_AUTHORIZED_FAIL;
}
String name = userAuthorizedParam.getName();
Long userId = userAuthorizedParam.getUserId();
String authPattern = userAuthorizedParam.getAuthPattern();
String idNo = userAuthorizedParam.getIdNo();
try { try {
if (StringUtils.isBlank(name) || StringUtils.isBlank(idNo) || StringUtils.isBlank(authPattern) if (StringUtils.isBlank(name) || userId == null || userId == 0L
|| !iIdCardService.isIdCardValid(idNo)) { || StringUtils.isBlank(authPattern) || !iIdCardService.isIdCardValid(idNo)) {
return JsonResult.buildErrorStateResult(null, Constants.CREATE_USER_AUTHORIZED_FAIL); return Constants.CREATE_USER_AUTHORIZED_FAIL;
} }
} catch (ParseException e) { } catch (Exception e) {
LOGGER.error("[createUserAuthorized]参数异常e:{}", e); LOGGER.error("[createUserAuthorized]参数有误:{}", e);
return Constants.CREATE_USER_AUTHORIZED_FAIL;
} }
AuthPattern authPatternEnum = AuthPattern.valueOf(authPattern); AuthPattern authPatternEnum = AuthPattern.valueOf(authPattern);
...@@ -64,28 +73,29 @@ public class UserAuthorizedServiceImpl implements IUserAuthorizedService { ...@@ -64,28 +73,29 @@ public class UserAuthorizedServiceImpl implements IUserAuthorizedService {
Timestamp now = new Timestamp(System.currentTimeMillis()); Timestamp now = new Timestamp(System.currentTimeMillis());
userAuthorized.setCreatedAt(now); userAuthorized.setCreatedAt(now);
userAuthorized.setUpdatedAt(now); userAuthorized.setUpdatedAt(now);
try { try {
userAuthorized = userAuthorizedRepository.save(userAuthorized); userAuthorized = userAuthorizedRepository.save(userAuthorized);
LOGGER.info("[createUserAuthorized]创建实名账户成功,userAuthorized:{}", userAuthorized); LOGGER.info("[createUserAuthorized]创建实名账户成功,userAuthorized:{}", userAuthorized);
return JsonResult.buildSuccessResult(null, Constants.CREATE_USER_AUTHORIZED_SUCCESS); return Constants.CREATE_USER_AUTHORIZED_SUCCESS;
} catch (Exception e) { } catch (Exception e) {
LOGGER.error("[createUserAuthorized]创建实名账户异常e:{}", e); LOGGER.error("[createUserAuthorized]创建实名账户异常e:{}", e);
return JsonResult.buildErrorStateResult(null, Constants.CREATE_USER_AUTHORIZED_FAIL); return Constants.CREATE_USER_AUTHORIZED_FAIL;
} }
} }
@Override @Override
public JsonResult getUserAuthorizedId(Long userId) { public Long getUserAuthorizedId(Long userId) {
if (null == userId || userId == 0) { if (null == userId || userId == 0) {
return JsonResult.buildErrorStateResult(null, null); return null;
} }
UserAuthorized userAuthorized = userAuthorizedRepository.findByUserId(userId); UserAuthorized userAuthorized = userAuthorizedRepository.findByUserId(userId);
if (null == userAuthorized) { if (null == userAuthorized) {
LOGGER.info("[getUserAuthorizedId]该实名账户不存在userId:{}", userId); LOGGER.info("[getUserAuthorizedId]该实名账户不存在userId:{}", userId);
return JsonResult.buildErrorStateResult(null, null); return null;
} }
LOGGER.info("[getUserAuthorizedId]获取实名账户的id,userAuthorized:{}", userAuthorized); LOGGER.info("[getUserAuthorizedId]获取实名账户的id,userAuthorized:{}", userAuthorized);
return JsonResult.buildSuccessResult(null, userAuthorized.getId()); return userAuthorized.getId();
} }
} }
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment