将容易存在写操作的从库查询服务copy一份

src/main/java/cn/quantgroup/xyqb/controller/external/UserController.java

@@ -443,7 +443,7 @@ public class UserController implements IBaseController {
             result.put("avatar", userAttached.getAvatar());
             result.put("nick", userAttached.getNick());
         }
-        UserDetail userDetail = userDetailService.findByUserId(userId);
+        UserDetail userDetail = userDetailService.findSlaveByUserId(userId);
         if (userDetail != null) {
             result.put("name", userDetail.getName());
             result.put("sex", Optional.ofNullable(userDetail.getGender()).orElse(cn.quantgroup.xyqb.model.Gender.UNKNOWN).ordinal() + "");

src/main/java/cn/quantgroup/xyqb/controller/internal/user/InnerController.java

@@ -408,7 +408,7 @@ public class InnerController implements IBaseController {
     @RequestMapping("/user_detail/search/phone")
     @ApiOperation(httpMethod = "POST", value = "查询用户详情")
     public JsonResult findUserDetailByPhone(String phoneNo) {
-        UserDetail userDetail = userDetailService.findByPhoneNo(phoneNo);
+        UserDetail userDetail = userDetailService.findSlaveByPhoneNo(phoneNo);
         if (userDetail != null) {
             return JsonResult.buildSuccessResult(null, UserDetailRet.getUserDetail(userDetail));
         }

src/main/java/cn/quantgroup/xyqb/service/user/IUserDetailService.java

@@ -12,11 +12,14 @@ import java.util.List;
  */
 public interface IUserDetailService {
     UserDetail findByUserId(Long userId);
+    UserDetail findSlaveByUserId(Long userId);
 
     UserDetail saveUserDetail(UserDetail userDetail) throws DataIntegrityViolationException;
 
     UserDetail findByPhoneNo(String phoneNo);
 
+	UserDetail findSlaveByPhoneNo(String phoneNo);
+
     void updateUserQq(Long userId, String qq);
 
     void updateUserEmail(Long userId, String email);

src/main/java/cn/quantgroup/xyqb/service/user/impl/UserDetailServiceImpl.java

@@ -53,7 +53,6 @@ public class UserDetailServiceImpl implements IUserDetailService {
     private JdbcTemplate jdbcTemplate;
 
     @Override
-    @TargetDataSource(type = DSType.SLAVE)//查询从库
     public UserDetail findByUserId(Long userId) {
         UserDetail userDetail = userDetailRepository.findByUserId(userId);
         if (null == userDetail) {
@@ -62,6 +61,17 @@ public class UserDetailServiceImpl implements IUserDetailService {
         userDetail.setEmail(AddressFilter.getEmail(userDetail.getPhoneNo(), userDetail.getEmail()));
         return userDetail;
     }
+    
+    @Override
+    @TargetDataSource(type = DSType.SLAVE)//查询从库
+    public UserDetail findSlaveByUserId(Long userId) {
+    	UserDetail userDetail = userDetailRepository.findByUserId(userId);
+    	if (null == userDetail) {
+    		return userDetail;
+    	}
+    	userDetail.setEmail(AddressFilter.getEmail(userDetail.getPhoneNo(), userDetail.getEmail()));
+    	return userDetail;
+    }
 
     @Override
     public UserDetail saveUserDetail(UserDetail userDetail) throws DataIntegrityViolationException {
@@ -76,11 +86,16 @@ public class UserDetailServiceImpl implements IUserDetailService {
     }
 
     @Override
-    @TargetDataSource(type = DSType.SLAVE)//查询从库
     public UserDetail findByPhoneNo(String phoneNo) {
         return userDetailRepository.findByPhoneNo(phoneNo);
     }
 
+    @Override
+    @TargetDataSource(type = DSType.SLAVE)//查询从库
+    public UserDetail findSlaveByPhoneNo(String phoneNo) {
+        return userDetailRepository.findByPhoneNo(phoneNo);
+    }
+
     @Override
     public void updateUserQq(Long userId, String qq) {
         userDetailRepository.updateUserQq(qq, userId);