Merge branches 'dev_ic_data' and 'dev_ic_v2' of http://121.42.41.42:7070/r/epmet-cloud into dev_ic_data

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/dto/result/CustomerStaffInfoCacheResult.java

@@ -93,4 +93,20 @@ public class CustomerStaffInfoCacheResult implements Serializable {
      */
     private List<IdAndNameDTO> deptList;
 
+    /**
+     * 组织级别
+     */
+    private String level;
+
+    /**
+     * 中心位置经度
+     */
+    private String longitude;
+
+    /**
+     * 中心位置纬度
+     */
+    private String latitude;
+
+
 }

epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/epmetuser/result/CustomerStaffResultDTO.java

@@ -93,4 +93,24 @@ public class CustomerStaffResultDTO implements Serializable {
      */
     private String twoOrgName;
 
+    /**
+     * 【社区】名称0409
+     */
+    private String community;
+
+    /**
+     * 组织级别
+     */
+    private String level;
+
+    /**
+     * 中心位置经度
+     */
+    private String longitude;
+
+    /**
+     * 中心位置纬度
+     */
+    private String latitude;
+
 }

epmet-module/data-aggregator/data-aggregator-client/src/main/java/com/epmet/dataaggre/dto/govorg/CustomerAgencyDTO.java

@@ -142,4 +142,19 @@ public class CustomerAgencyDTO implements Serializable {
      * 社区
      */
     private String community;
+
+    /**
+     * 坐标
+     */
+    private String coordinates;
+
+    /**
+     * 中心位置经度
+     */
+    private String longitude;
+
+    /**
+     * 中心位置纬度
+     */
+    private String latitude;
 }

epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetuser/impl/EpmetUserServiceImpl.java

@@ -602,6 +602,9 @@ public class EpmetUserServiceImpl implements EpmetUserService {
         result.setAgencyId(agencyDTO.getId());
         result.setAgencyName(agencyDTO.getOrganizationName());
         result.setAgencyPIds(agencyDTO.getPids());
+        result.setLevel(agencyDTO.getLevel());
+        result.setLongitude(agencyDTO.getLongitude());
+        result.setLatitude(agencyDTO.getLatitude());
         StaffOrgRelationResultDTO fromOrgTypeDto = govOrgService.getStaffFromOrgType(staffId);
         String fromOrgType = OrgTypeEnum.AGENCY.getCode();
         if (fromOrgTypeDto != null){

epmet-module/data-aggregator/data-aggregator-server/src/main/resources/mapper/govorg/CustomerStaffAgencyDao.xml

@@ -26,7 +26,23 @@
             ca.organization_name,
             ca.level,
             ca.area_code,
-            ca.parent_area_code
+            ca.parent_area_code,
+            ( CASE WHEN ca.longitude is  THEN
+                ( SELECT longitude FROM customer_agency
+                    WHERE del_flag = '0' AND customer_id = (SELECT customer_id FROM customer_agency WHERE id = ca.id)
+                    ORDER BY pid ASC LIMIT 1
+                )
+                ELSE ca.longitude
+                END
+            ) longitude,
+            ( CASE WHEN ca.latitude is null THEN
+                ( SELECT latitude FROM customer_agency
+                    WHERE del_flag = '0' AND customer_id = (SELECT customer_id FROM customer_agency WHERE id = ca.id)
+                    ORDER BY pid ASC LIMIT 1
+                )
+                ELSE ca.latitude
+                END
+            ) latitude
         FROM
             customer_staff_agency csa
         INNER JOIN customer_agency ca ON csa.agency_id = ca.id

epmet-module/resi-mine/resi-mine-server/src/main/java/com/epmet/modules/mine/service/impl/PersonalCenterServiceImpl.java

@@ -47,6 +47,7 @@ public class PersonalCenterServiceImpl implements PersonalCenterService {
 	@Override
 	public void editInfo(TokenDto tokenDto, EditInfoFormDTO formDTO) {
 		formDTO.setUserId(tokenDto.getUserId());
+		formDTO.setCustomerId(tokenDto.getCustomerId());
 		Result result = epmetUserOpenFeignClient.editUserInfo(formDTO);
 		if (!result.success()) {
 			throw new RenException(result.getCode(), result.getMsg());

epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/EditInfoFormDTO.java

@@ -60,4 +60,10 @@ public class EditInfoFormDTO implements Serializable {
 	 */
 	@NotBlank(message = "昵称不能为空")
 	private String nickname;
+
+	/**
+	 * 当前客户id
+	 */
+	@NotBlank(message = "customerId不能为空")
+	private String customerId;
 }

epmet-user/epmet-user-client/src/main/java/com/epmet/dto/form/ResiUserFormDTO.java

@@ -6,7 +6,7 @@ import javax.validation.constraints.NotBlank;
 import java.io.Serializable;
 
 /**
- * 根据身份证号找人，也可根据epmetUserId查询，或者icResiUserId
+ * 根据身份证号||ic_resi_user.id找居民端小程序里的人
  */
 @Data
 public class ResiUserFormDTO implements Serializable {
@@ -18,11 +18,6 @@ public class ResiUserFormDTO implements Serializable {
      */
     private String idNum;
 
-    /**
-     * epemt_user.user.id
-     */
-    private String epmetUserId;
-
     /**
      * ic_resi_user.id
      */
@@ -30,7 +25,4 @@ public class ResiUserFormDTO implements Serializable {
 
     @NotBlank(message = "客户id不能为空", groups = AddUserInternalGroup.class)
     private String customerId;
-
-    //@NotBlank(message = "findType不能为空;根据身份证号：byIdNum;根据ic居民：byIc;根据小程序里的居民：byEpmetUser", groups = AddUserInternalGroup.class)
-    //private String findType;
 }

epmet-user/epmet-user-client/src/main/java/com/epmet/dto/result/StaffBasicInfoResultDTO.java

@@ -77,4 +77,20 @@ public class StaffBasicInfoResultDTO implements Serializable {
 	 */
 	private String agencyName;
 
+	/**
+	 * 组织级别
+	 */
+	private String level;
+
+	/**
+	 * 中心位置经度
+	 */
+	private String longitude;
+
+	/**
+	 * 中心位置纬度
+	 */
+	private String latitude;
+
+
 }

epmet-user/epmet-user-client/src/main/java/com/epmet/feign/EpmetUserOpenFeignClient.java

@@ -662,11 +662,11 @@ public interface EpmetUserOpenFeignClient {
     Result<List<CustomerStaffDTO>> getByRealNames(@RequestBody GetByRealNamesFormDTO formDTO);
 
     /**
-     * 根据身份证号找人，也可根据epmetUserId查询，或者icResiUserId
+     * 根据身份证号||ic_resi_user.id找居民端小程序里的人
      *
      * @param formDTO
      * @return
      */
-    @PostMapping(value = "/epmetuser/user/finduser")
+    @PostMapping(value = "/epmetuser/user/findepmetuser")
-    Result<ResiUserResDTO> findUser(@RequestBody ResiUserFormDTO formDTO);
+    Result<ResiUserResDTO> findEpmetUser(@RequestBody ResiUserFormDTO formDTO);
 }

epmet-user/epmet-user-client/src/main/java/com/epmet/feign/fallback/EpmetUserOpenFeignClientFallback.java

@@ -481,13 +481,13 @@ public class EpmetUserOpenFeignClientFallback implements EpmetUserOpenFeignClien
     }
 
     /**
-     * 根据身份证号找人
+     * 根据身份证号||ic_resi_user.id找居民端小程序里的人
      *
      * @param formDTO
      * @return
      */
     @Override
-    public Result<ResiUserResDTO> findUser(ResiUserFormDTO formDTO) {
+    public Result<ResiUserResDTO> findEpmetUser(ResiUserFormDTO formDTO) {
-        return ModuleUtils.feignConError(ServiceConstant.EPMET_USER_SERVER, "findUser", formDTO);
+        return ModuleUtils.feignConError(ServiceConstant.EPMET_USER_SERVER, "findEpmetUser", formDTO);
     }
 }

epmet-user/epmet-user-server/src/main/java/com/epmet/controller/UserController.java

@@ -187,15 +187,15 @@ public class UserController {
 	}
 
 	/**
-	 * 根据身份证号找人，也可根据epmetUserId查询，或者icResiUserId
+	 * 根据身份证号||ic_resi_user.id找居民端小程序里的人
 	 *
 	 *
 	 * @param formDTO
 	 * @return
 	 */
-	@PostMapping("finduser")
+	@PostMapping("findepmetuser")
-	public Result<ResiUserResDTO> findUser(@RequestBody ResiUserFormDTO formDTO){
+	public Result<ResiUserResDTO> findEpmetUser(@RequestBody ResiUserFormDTO formDTO){
 		ValidatorUtils.validateEntity(formDTO,ResiUserFormDTO.AddUserInternalGroup.class);
-		return new Result<ResiUserResDTO>().ok(userService.findUser(formDTO));
+		return new Result<ResiUserResDTO>().ok(userService.findEpmetUser(formDTO));
 	}
 }

epmet-user/epmet-user-server/src/main/java/com/epmet/dao/UserResiInfoDao.java

@@ -102,7 +102,9 @@ public interface UserResiInfoDao extends BaseDao<UserResiInfoEntity> {
 	 * @param idNum
 	 * @return
 	 */
-    Integer selectCountByIdNum(@Param("idNum") String idNum,@Param("customerId") String customerId);
+    Integer selectCountByIdNum(@Param("idNum") String idNum,
+							   @Param("customerId") String customerId,
+							   @Param("excludeUserId")String excludeUserId);
 
 	UserResiInfoDTO selectByIdNum(@Param("customerId") String customerId,
 								  @Param("idNum")String idNum,

epmet-user/epmet-user-server/src/main/java/com/epmet/service/UserService.java

@@ -106,11 +106,11 @@ public interface UserService extends BaseService<UserEntity> {
     UserDTO queryUserClient(String userId);
 
     /**
-     * 根据身份证号找人
+     * 根据身份证号||ic_resi_user.id找居民端小程序里的人
      *
      *
      * @param formDTO
      * @return
      */
-    ResiUserResDTO findUser(ResiUserFormDTO formDTO);
+    ResiUserResDTO findEpmetUser(ResiUserFormDTO formDTO);
 }

epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/CustomerStaffServiceImpl.java

@@ -717,6 +717,9 @@ public class CustomerStaffServiceImpl extends BaseServiceImpl<CustomerStaffDao,
 			if (null != staffInfo){
 				resultDTO.setAgencyId(staffInfo.getAgencyId());
 				resultDTO.setAgencyName(staffInfo.getAgencyName());
+				resultDTO.setLevel(staffInfo.getLevel());
+				resultDTO.setLongitude(staffInfo.getLongitude());
+				resultDTO.setLatitude(staffInfo.getLatitude());
 			}
 		}
         return new Result<StaffBasicInfoResultDTO>().ok(resultDTO);

epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java

@@ -534,8 +534,10 @@ public class IcResiUserServiceImpl extends BaseServiceImpl<IcResiUserDao, IcResi
         //新增以下2个返参
         ResiUserFormDTO resiUserFormDTO = new ResiUserFormDTO();
         resiUserFormDTO.setIcResiUserId(formDTO.getUserId());
+        resiUserFormDTO.setIdNum(personData.getIdCard());
         resiUserFormDTO.setCustomerId(formDTO.getCustomerId());
-        ResiUserResDTO resiUserResDTO = userService.findUser(resiUserFormDTO);
+        //根据身份证号+ic_resi_user.id找epmetUserId
+        ResiUserResDTO resiUserResDTO = userService.findEpmetUser(resiUserFormDTO);
         personData.setEpmetUserId(null != resiUserResDTO ? resiUserResDTO.getEpmetUserId() : StrConstant.EPMETY_STR);
         personData.setIcResiUserId(formDTO.getUserId());
 

epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserResiInfoServiceImpl.java

@@ -220,7 +220,7 @@ public class UserResiInfoServiceImpl extends BaseServiceImpl<UserResiInfoDao, Us
 		}
 		//3、身份证号不为空时，判断当前客户下身份证号是否呀已经被使用
 		if (StringUtils.isNotBlank(userResiInfoDTO.getIdNum())) {
-			if (baseDao.selectCountByIdNum(userResiInfoDTO.getIdNum(), userResiInfoDTO.getCustomerId()) > NumConstant.ZERO) {
+			if (baseDao.selectCountByIdNum(userResiInfoDTO.getIdNum(), userResiInfoDTO.getCustomerId(),null) > NumConstant.ZERO) {
 				throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "user_resi_info已存在该身份证号", "身份证号已被使用");
 			}
 		}
@@ -307,7 +307,7 @@ public class UserResiInfoServiceImpl extends BaseServiceImpl<UserResiInfoDao, Us
 			log.warn("手机号客户内不可用，没有更新用户信息，param:{}", JSON.toJSONString(userResiInfoDTO));
 			throw new RenException(EpmetErrorCode.THE_MOBILE_HAS_BEEN_USED.getCode(), EpmetErrorCode.THE_MOBILE_HAS_BEEN_USED.getMsg());
 		}
-		if (baseDao.selectCountByIdNum(userResiInfoDTO.getIdNum(), userResiInfoDTO.getCustomerId()) > 0) {
+		if (baseDao.selectCountByIdNum(userResiInfoDTO.getIdNum(), userResiInfoDTO.getCustomerId(),userResiInfoDTO.getUserId()) > 0) {
 			throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "user_resi_info已存在该身份证号", "身份证号已被使用");
 		}
 		//居民注册关系表新增数据 首次注册数加一 注册数加一 参与数加一
@@ -384,6 +384,12 @@ public class UserResiInfoServiceImpl extends BaseServiceImpl<UserResiInfoDao, Us
 	 */
 	@Override
 	public void editUserInfo(EditInfoFormDTO formDTO) {
+		if(StringUtils.isNotBlank(formDTO.getIdNum())){
+			//判断身份证号唯一，除了当前用户外没有人用过这个身份证号吧？？？
+			if(baseDao.selectCountByIdNum(formDTO.getIdNum(),formDTO.getCustomerId(),formDTO.getUserId())>0){
+				throw new EpmetException(EpmetErrorCode.EPMET_COMMON_OPERATION_FAIL.getCode(), "user_resi_info已存在该身份证号", "身份证号已被使用");
+			}
+		}
 		//更新居民注册信息表
 		baseDao.updateByUserId(ConvertUtils.sourceToTarget(formDTO, UserResiInfoEntity.class));
 		//更新baseInfo

epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserServiceImpl.java

@@ -350,33 +350,32 @@ public class UserServiceImpl extends BaseServiceImpl<UserDao, UserEntity> implem
     }
 
     /**
-     * 根据身份证号找人，也可根据epmetUserId查询，或者icResiUserId
+     * 根据身份证号||ic_resi_user.id找居民端小程序里的人
      *
      * @param formDTO
      * @return
      */
     @Override
-    public ResiUserResDTO findUser(ResiUserFormDTO formDTO) {
+    public ResiUserResDTO findEpmetUser(ResiUserFormDTO formDTO) {
-        if (StringUtils.isBlank(formDTO.getIdNum()) && StringUtils.isBlank(formDTO.getEpmetUserId()) && StringUtils.isBlank(formDTO.getIcResiUserId())) {
+        if (StringUtils.isBlank(formDTO.getIdNum()) && StringUtils.isBlank(formDTO.getIcResiUserId())) {
-            throw new EpmetException(EpmetErrorCode.SERVER_ERROR.getCode(),"身份证号、epmetuserId、icResiUserId至少输入一个","至少选择一种查询方式");
+            throw new EpmetException(EpmetErrorCode.SERVER_ERROR.getCode(), "身份证号、icResiUserId至少输入一个", "至少选择一种查询方式");
-        }
-        ResiUserResDTO resiUserResDTO = ConvertUtils.sourceToTarget(formDTO, ResiUserResDTO.class);
-        //可以根据身份证号查询，也可以根据ic_resi_user.id查询
-        if (StringUtils.isBlank(formDTO.getIcResiUserId())) {
-            IcResiUserDTO icResiUser = icResiUserService.getByIdCard(formDTO.getCustomerId(), formDTO.getIdNum(), formDTO.getIcResiUserId());
-            resiUserResDTO.setIcResiUserId(null != icResiUser ? icResiUser.getId() : StrConstant.EPMETY_STR);
-            resiUserResDTO.setIdNum(null != icResiUser ? icResiUser.getIdCard() : StrConstant.EPMETY_STR);
         }
         //可以根据身份证号查询，也可以根据epmet_user.user.id查询
-        if (StringUtils.isBlank(formDTO.getEpmetUserId())) {
+        if (StringUtils.isNotBlank(formDTO.getIcResiUserId()) && StringUtils.isBlank(formDTO.getIdNum())) {
+            IcResiUserDTO icResiUserDTO = icResiUserService.getByIdCard(formDTO.getCustomerId(), null, formDTO.getIcResiUserId());
+            if (null == icResiUserDTO) {
+                throw new EpmetException(EpmetErrorCode.SERVER_ERROR.getCode(), "根据ic_resi_user.id没有找到记录id=" + formDTO.getIcResiUserId(), "至少选择一种查询方式");
+            }
+            formDTO.setIdNum(icResiUserDTO.getIdCard());
+        }
+        ResiUserResDTO resiUserResDTO = ConvertUtils.sourceToTarget(formDTO, ResiUserResDTO.class);
+        if (StringUtils.isNotBlank(formDTO.getIdNum())) {
             UserBaseInfoDTO userBaseInfoDTO = userBaseInfoService.getUserIdByIdNum(formDTO.getCustomerId(),
-                    formDTO.getIdNum(),
+                    formDTO.getIdNum(), null);
-                    formDTO.getEpmetUserId());
             if (null == userBaseInfoDTO || StringUtils.isBlank(userBaseInfoDTO.getUserId())) {
                 log.info("user_base_info没有找到,去查下user_resi_info表吧");
                 UserResiInfoDTO userResiInfoDTO = userResiInfoDao.selectByIdNum(formDTO.getCustomerId(),
-                        formDTO.getIdNum(),
+                        formDTO.getIdNum(), null);
-                        formDTO.getEpmetUserId());
                 resiUserResDTO.setEpmetUserId(null != userResiInfoDTO ? userResiInfoDTO.getId() : StrConstant.EPMETY_STR);
             } else {
                 resiUserResDTO.setEpmetUserId(userBaseInfoDTO.getUserId());

epmet-user/epmet-user-server/src/main/resources/mapper/UserBaseInfoDao.xml

@@ -126,7 +126,7 @@
           *
         FROM user_base_info
         WHERE DEL_FLAG = '0'
-        AND customer_id = #{=customerId}
+        AND customer_id = #{customerId}
         <if test="idNum != null and idNum != ''">
             and id_num=#{idNum}
         </if>

epmet-user/epmet-user-server/src/main/resources/mapper/UserResiInfoDao.xml

@@ -185,6 +185,9 @@
             uri.DEL_FLAG = '0'
             AND uri.id_num = #{idNum}
             and uri.customer_id=#{customerId}
+            <if test="excludeUserId != null and excludeUserId != ''">
+                AND uri.user_id != #{excludeUserId}
+            </if>
     </select>
 
     <select id="selectByIdNum" parameterType="map" resultType="com.epmet.dto.UserResiInfoDTO">