From c677cabebadd44cb554b9555b42ca39ca05e14b2 Mon Sep 17 00:00:00 2001
From: zxc <1272811460@qq.com>
Date: Tue, 16 Mar 2021 15:21:09 +0800
Subject: [PATCH] =?UTF-8?q?=E5=BE=BD=E7=AB=A0bug=E6=B5=8B=E8=AF=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/epmet/dao/RegisterRelationDao.java    |  8 +++++++
 .../service/RegisterRelationService.java      |  2 ++
 .../epmet/service/UserBaseInfoService.java    |  8 +++++++
 .../impl/RegisterRelationServiceImpl.java     |  5 ++++
 .../service/impl/UserBadgeServiceImpl.java    |  2 +-
 .../service/impl/UserBaseInfoServiceImpl.java | 24 +++++++++++++++++++
 .../resources/mapper/RegisterRelationDao.xml  |  5 ++++
 7 files changed, 53 insertions(+), 1 deletion(-)

diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/RegisterRelationDao.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/RegisterRelationDao.java
index a19881ce9a..160e1a4afc 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/RegisterRelationDao.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/dao/RegisterRelationDao.java
@@ -47,4 +47,12 @@ public interface RegisterRelationDao extends BaseDao<RegisterRelationEntity> {
 
 
     RegisterRelationEntity selectRegisteredGridIdByUserIdAndCustomerId(@Param("userId") String userId, @Param("customerId")String customerId);
+
+    /**
+     * @Description  根据userId查询注册网格ID
+     * @Param userId
+     * @author zxc
+     * @date 2021/3/16 下午3:05
+     */
+    String selectRegisterGridIdByUserId(@Param("userId")String userId);
 }
\ No newline at end of file
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/RegisterRelationService.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/RegisterRelationService.java
index e40e9ea607..96814c5fce 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/RegisterRelationService.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/RegisterRelationService.java
@@ -112,4 +112,6 @@ public interface RegisterRelationService extends BaseService<RegisterRelationEnt
      * @Author sun
      **/
     Result saveRegisterRelation(UserResiInfoDTO userResiInfoDTO);
+
+    String selectRegisterGridIdByUserId(String userId);
 }
\ No newline at end of file
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/UserBaseInfoService.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/UserBaseInfoService.java
index 07acf1138b..531213863d 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/UserBaseInfoService.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/UserBaseInfoService.java
@@ -118,6 +118,14 @@ public interface UserBaseInfoService extends BaseService<UserBaseInfoEntity> {
      **/
     List<UserBaseInfoResultDTO> queryUserBaseInfo(List<String> userIdList);
 
+    /**
+     * @Description  查询用户信息
+     * @Param userIdList
+     * @author zxc
+     * @date 2021/3/16 下午2:52
+     */
+    List<UserBaseInfoResultDTO> queryUserBaseInfoPlus(List<String> userIdList);
+
     /**
      * @return void
      * @param
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/RegisterRelationServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/RegisterRelationServiceImpl.java
index f8a78f8c14..ca7b3db589 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/RegisterRelationServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/RegisterRelationServiceImpl.java
@@ -339,4 +339,9 @@ public class RegisterRelationServiceImpl extends BaseServiceImpl<RegisterRelatio
         return new Result();
     }
 
+    @Override
+    public String selectRegisterGridIdByUserId(String userId) {
+        return baseDao.selectRegisterGridIdByUserId(userId);
+    }
+
 }
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBadgeServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBadgeServiceImpl.java
index b076c7eaff..a2b08568e7 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBadgeServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBadgeServiceImpl.java
@@ -194,7 +194,7 @@ public class UserBadgeServiceImpl implements UserBadgeService {
         }else {
             List<String> oneUserIds = new ArrayList<>();
             oneUserIds.add(userId);
-            List<UserBaseInfoResultDTO> userBaseInfoResultDTOS = userBaseInfoService.queryUserBaseInfo(oneUserIds);
+            List<UserBaseInfoResultDTO> userBaseInfoResultDTOS = userBaseInfoService.queryUserBaseInfoPlus(oneUserIds);
             log.info("user【"+userId+"】基本信息："+userBaseInfoResultDTOS.toString());
             if (!CollectionUtils.isEmpty(userIds)) {
                 AtomicReference<Boolean> status = new AtomicReference<>(true);
diff --git a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBaseInfoServiceImpl.java b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBaseInfoServiceImpl.java
index f76628b60d..852ca55843 100644
--- a/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBaseInfoServiceImpl.java
+++ b/epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/UserBaseInfoServiceImpl.java
@@ -40,6 +40,7 @@ import com.epmet.feign.GovOrgOpenFeignClient;
 import com.epmet.redis.UserBaseInfoRedis;
 import com.epmet.resi.partymember.dto.partymember.PartymemberInfoDTO;
 import com.epmet.resi.partymember.feign.ResiPartyMemberOpenFeignClient;
+import com.epmet.service.RegisterRelationService;
 import com.epmet.service.UserBaseInfoService;
 import com.epmet.util.ModuleConstant;
 import org.apache.commons.lang3.StringUtils;
@@ -77,6 +78,8 @@ public class UserBaseInfoServiceImpl extends BaseServiceImpl<UserBaseInfoDao, Us
     private GridLatestDao gridLatestDao;
     @Autowired
     private GovOrgOpenFeignClient govOrgOpenFeignClient;
+    @Autowired
+    private RegisterRelationService registerRelationService;
 
     @Override
     public PageData<UserBaseInfoDTO> page(Map<String, Object> params) {
@@ -181,6 +184,27 @@ public class UserBaseInfoServiceImpl extends BaseServiceImpl<UserBaseInfoDao, Us
         return userBaseInfoList;
     }
 
+    @Override
+    public List<UserBaseInfoResultDTO> queryUserBaseInfoPlus(List<String> userIdList) {
+        if (CollectionUtils.isEmpty(userIdList)){
+            return new ArrayList<>();
+        }
+        List<UserBaseInfoResultDTO> result = new ArrayList<>();
+        userIdList.forEach(id -> {
+            UserBaseInfoResultDTO baseInfo = userBaseInfoRedis.getUserInfo(id);
+            if (null != baseInfo && StringUtils.isEmpty(baseInfo.getRegisteredGridId())){
+                String gridId = registerRelationService.selectRegisterGridIdByUserId(id);
+                if (StringUtils.isNotEmpty(gridId)){
+                    baseInfo.setRegisteredGridId(gridId);
+                }else {
+                    throw new RenException("查询用户【"+id+"】所属网格失败");
+                }
+            }
+            result.add(baseInfo);
+        });
+        return result;
+    }
+
     /**
      * @return void
      * @author yinzuomei
diff --git a/epmet-user/epmet-user-server/src/main/resources/mapper/RegisterRelationDao.xml b/epmet-user/epmet-user-server/src/main/resources/mapper/RegisterRelationDao.xml
index 403e3fcc8e..c3f7bf7682 100644
--- a/epmet-user/epmet-user-server/src/main/resources/mapper/RegisterRelationDao.xml
+++ b/epmet-user/epmet-user-server/src/main/resources/mapper/RegisterRelationDao.xml
@@ -72,5 +72,10 @@
             LIMIT 1
     </select>
 
+    <!-- 根据userId查询注册网格ID -->
+    <select id="selectRegisterGridIdByUserId" resultType="java.lang.String">
+        SELECT GRID_ID FROM register_relation WHERE DEL_FLAG = 0 and USER_ID = #{userId}
+    </select>
+
 
 </mapper>
\ No newline at end of file