调整通过哨卡登记信息完善用户信息的代码

esua-epdc/epdc-module/epdc-api/epdc-api-server/src/main/java/com/elink/esua/epdc/listener/SentryPostUserInfoRedisListener.java

@@ -1,7 +1,6 @@
 package com.elink.esua.epdc.listener;
 
 import com.alibaba.fastjson.JSONObject;
-import com.elink.esua.epdc.commons.tools.exception.RenException;
 import com.elink.esua.epdc.commons.tools.utils.Result;
 import com.elink.esua.epdc.dto.EpidemicSentryPostDTO;
 import com.elink.esua.epdc.dto.epdc.form.EpdcAppPidemicCompleteInfoFromDTO;
@@ -40,7 +39,9 @@ public class SentryPostUserInfoRedisListener implements MessageListener {
             EpdcAppPidemicCompleteInfoFromDTO completeInfoDto = JSONObject.parseObject(message.toString(), EpdcAppPidemicCompleteInfoFromDTO.class);
 
             EpidemicSentryPostDTO sentryPostInfoByThirdId = getEpidemicSentryPostInfoByThirdId(completeInfoDto.getPostId());
-            completeInfoDto.setGridId(sentryPostInfoByThirdId.getGridId());
+            if (null != sentryPostInfoByThirdId) {
+                completeInfoDto.setGridId(sentryPostInfoByThirdId.getGridId());
+            }
 
             userFeignClient.createPidemicInfo(completeInfoDto);
         } catch (Exception e) {
@@ -59,7 +60,8 @@ public class SentryPostUserInfoRedisListener implements MessageListener {
     private EpidemicSentryPostDTO getEpidemicSentryPostInfoByThirdId(String thirdId) {
         Result<EpidemicSentryPostDTO> epidemicSentryResult = customFeignClient.getEpidemicSentryByThirdSentryPostid(thirdId);
         if (!epidemicSentryResult.success() || null == epidemicSentryResult.getData()) {
-            throw new RenException("查询哨卡信息失败");
+            log.error("根据第三方哨卡id：{}查询哨卡信息失败", thirdId);
+            return null;
         }
         return epidemicSentryResult.getData();
     }

esua-epdc/epdc-module/epdc-user/epdc-user-server/src/main/java/com/elink/esua/epdc/service/impl/UserServiceImpl.java

@@ -897,33 +897,38 @@ public class UserServiceImpl extends BaseServiceImpl<UserDao, UserEntity> implem
     @Override
     public Result createPidemicInfo(EpdcAppPidemicCompleteInfoFromDTO completeInfoFromDto) {
 
+        String userId = completeInfoFromDto.getUserId();
+
         // 更新用户信息
-        UserEntity userEntity = selectById(completeInfoFromDto.getUserId());
+        UserEntity userEntity = selectById(userId);
         if (null == userEntity) {
             return new Result().error("查询用户信息失败");
         }
 
-        Result<ParentAndAllDeptDTO> parentAndAllDeptDTOResult = adminFeignClient.getParentAndAllDept(String.valueOf(completeInfoFromDto.getGridId()));
-        if (!parentAndAllDeptDTOResult.success()) {
-            return new Result().error("查询机构信息失败");
+        UserEntity updateUser = new UserEntity();
+        updateUser.setId(userId);
+        updateUser.setRealName(completeInfoFromDto.getName());
+        updateUser.setIdentityNo(completeInfoFromDto.getIdcard());
+        updateUser.setMobile(completeInfoFromDto.getPhone());
+        updateUser.setAddress(completeInfoFromDto.getHabitationDetail());
+        updateUser.setRentFlag(completeInfoFromDto.getIsRent());
+        updateUser.setDriverFlag(completeInfoFromDto.getIsDriver());
+
+        Long gridId = completeInfoFromDto.getGridId();
+        if (null != gridId) {
+            Result<ParentAndAllDeptDTO> parentAndAllDeptDTOResult = adminFeignClient.getParentAndAllDept(String.valueOf(gridId));
+            if (!parentAndAllDeptDTOResult.success()) {
+                return new Result().error("查询机构信息失败");
+            }
+            ParentAndAllDeptDTO deptInfo = parentAndAllDeptDTOResult.getData();
+            updateUser.setDeptId(gridId);
+            updateUser.setAllDeptIds(deptInfo.getAllDeptIds());
+            updateUser.setAllDeptNames(deptInfo.getAllDeptNames());
+            updateUser.setParentDeptIds(deptInfo.getParentDeptIds());
+            updateUser.setParentDeptNames(deptInfo.getParentDeptNames());
         }
-        ParentAndAllDeptDTO deptInfo = parentAndAllDeptDTOResult.getData();
-
-
-        UserEntity userDTO = new UserEntity();
-        userDTO.setId(completeInfoFromDto.getUserId());
-        userDTO.setRealName(completeInfoFromDto.getName());
-        userDTO.setIdentityNo(completeInfoFromDto.getIdcard());
-        userDTO.setMobile(completeInfoFromDto.getPhone());
-        userDTO.setAddress(completeInfoFromDto.getHabitationDetail());
-        userDTO.setRentFlag(completeInfoFromDto.getIsRent());
-        userDTO.setDriverFlag(completeInfoFromDto.getIsDriver());
-        userDTO.setAllDeptIds(deptInfo.getAllDeptIds());
-        userDTO.setAllDeptNames(deptInfo.getAllDeptNames());
-        userDTO.setParentDeptIds(deptInfo.getParentDeptIds());
-        userDTO.setParentDeptNames(deptInfo.getParentDeptNames());
 
-        this.updateById(userDTO);
+        this.updateById(updateUser);
 
         String carNum = completeInfoFromDto.getCarNum();
 
@@ -933,12 +938,12 @@ public class UserServiceImpl extends BaseServiceImpl<UserDao, UserEntity> implem
             UserCarInfoDTO userCarInfoDTO = userCarInfoService.selectOneByCarNumber(carNum);
             if (userCarInfoDTO == null) {
                 UserCarInfoDTO dto = new UserCarInfoDTO();
-                dto.setUserId(userDTO.getId());
+                dto.setUserId(userId);
                 dto.setCarNumber(carNum);
                 userCarInfoService.save(dto);
             } else {
                 // 库里存的车牌号与该用户不相符
-                if (!userCarInfoDTO.getUserId().equals(userDTO.getId())) {
+                if (!userCarInfoDTO.getUserId().equals(userId)) {
                     throw new RenException("保存失败，此车牌已被注册");
                 }
             }