加了个icresiuser缓存

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/feign/CommonUserFeignClient.java

@@ -2,6 +2,7 @@ package com.epmet.commons.tools.feign;
 
 import com.epmet.commons.tools.constant.ServiceConstant;
 import com.epmet.commons.tools.feign.fallback.CommonUserFeignClientFallBackFactory;
+import com.epmet.commons.tools.redis.common.bean.IcResiUserInfoCache;
 import com.epmet.commons.tools.redis.common.bean.ResiUserInfoCache;
 import com.epmet.commons.tools.utils.Result;
 import org.springframework.cloud.openfeign.FeignClient;
@@ -17,4 +18,7 @@ import org.springframework.web.bind.annotation.PostMapping;
 public interface CommonUserFeignClient {
     @PostMapping("/epmetuser/userbaseinfo/getUserInfo/{userId}")
     Result<ResiUserInfoCache> getUserInfo(@PathVariable("userId") String userId);
+
+    @PostMapping("/epmetuser/icresiuser/getIcResiUserInfo/{userId}")
+    Result<IcResiUserInfoCache> getIcResiUserInfo(@PathVariable("userId") String userId);
 }

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/feign/fallback/CommonUserFeignClientFallback.java

@@ -2,6 +2,7 @@ package com.epmet.commons.tools.feign.fallback;
 
 import com.epmet.commons.tools.constant.ServiceConstant;
 import com.epmet.commons.tools.feign.CommonUserFeignClient;
+import com.epmet.commons.tools.redis.common.bean.IcResiUserInfoCache;
 import com.epmet.commons.tools.redis.common.bean.ResiUserInfoCache;
 import com.epmet.commons.tools.utils.ModuleUtils;
 import com.epmet.commons.tools.utils.Result;
@@ -20,4 +21,9 @@ public class CommonUserFeignClientFallback implements CommonUserFeignClient {
     public Result<ResiUserInfoCache> getUserInfo(String userId) {
         return ModuleUtils.feignConError(ServiceConstant.EPMET_USER_SERVER, "getUserInfo", userId);
     }
+
+    @Override
+    public Result<IcResiUserInfoCache> getIcResiUserInfo(String userId) {
+        return ModuleUtils.feignConError(ServiceConstant.EPMET_USER_SERVER, "getIcResiUserInfo", userId);
+    }
 }

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/redis/RedisKeys.java

@@ -393,6 +393,10 @@ public class RedisKeys {
 		return rootPrefix.concat("resi:user:").concat(userId);
 	}
 
+	public static String getIcResiUserKey(String userId) {
+		return rootPrefix.concat("resi:icResiUser:").concat(userId);
+	}
+
 	/**
 	 * @param userId
 	 * @return epmet:badge:user:[customerId]:[userId]

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/redis/common/CustomerResiUserRedis.java

@@ -1,10 +1,12 @@
 package com.epmet.commons.tools.redis.common;
 
 import cn.hutool.core.bean.BeanUtil;
+import com.epmet.commons.tools.exception.EpmetException;
 import com.epmet.commons.tools.exception.RenException;
 import com.epmet.commons.tools.feign.CommonUserFeignClient;
 import com.epmet.commons.tools.redis.RedisKeys;
 import com.epmet.commons.tools.redis.RedisUtils;
+import com.epmet.commons.tools.redis.common.bean.IcResiUserInfoCache;
 import com.epmet.commons.tools.redis.common.bean.ResiUserInfoCache;
 import com.epmet.commons.tools.utils.ConvertUtils;
 import com.epmet.commons.tools.utils.Result;
@@ -70,6 +72,31 @@ public class CustomerResiUserRedis {
         return resultData;
     }
 
+    public static IcResiUserInfoCache getIcResiUserInfo(String icResiUserId){
+        if (StringUtils.isBlank(icResiUserId)){
+            log.warn("getIcResiUserInfo param is blank,userId:{}",icResiUserId);
+            return null;
+        }
+        String key = RedisKeys.getIcResiUserKey(icResiUserId);
+        Map<String, Object> map = customerResiUserRedis.redisUtils.hGetAll(key);
+        if (!CollectionUtils.isEmpty(map)) {
+            return ConvertUtils.mapToEntity(map, IcResiUserInfoCache.class);
+        }
+        Result<IcResiUserInfoCache> result = customerResiUserRedis.commonUserFeignClient.getIcResiUserInfo(icResiUserId);
+        if (result == null || !result.success()) {
+            throw new EpmetException("获取居民信息失败");
+        }
+        IcResiUserInfoCache data = result.getData();
+        if (null == data) {
+            log.warn("居民信息为空,userId:{}", icResiUserId);
+            return null;
+        }
+
+        Map<String, Object> cacheMap = BeanUtil.beanToMap(data, false, true);
+        customerResiUserRedis.redisUtils.hMSet(key, cacheMap);
+        return data;
+    }
+
     @Nullable
     private static ResiUserInfoCache reloadStaffCache(String userId, String key) {
         Result<ResiUserInfoCache> result = customerResiUserRedis.commonUserFeignClient.getUserInfo(userId);

epmet-commons/epmet-commons-tools/src/main/java/com/epmet/commons/tools/redis/common/bean/IcResiUserInfoCache.java

@@ -0,0 +1,539 @@
+package com.epmet.commons.tools.redis.common.bean;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.Date;
+
+/**
+ * @Author zxc
+ * @DateTime 2022/10/17 15:40
+ * @DESC
+ */
+@Data
+public class IcResiUserInfoCache implements Serializable {
+
+    private static final long serialVersionUID = -3644143706074015380L;
+
+
+    /**
+     * 主键
+     */
+    private String id;
+
+    /**
+     * 客户Id customer.id
+     */
+    private String customerId;
+
+    /**
+     *
+     */
+    private String agencyId;
+
+    /**
+     *
+     */
+    private String pids;
+
+    /**
+     * 网格ID
+     */
+    private String gridId;
+
+    /**
+     * 所属小区ID
+     */
+    private String villageId;
+
+    /**
+     * 所属楼宇Id
+     */
+    private String buildId;
+
+    /**
+     * 单元id
+     */
+    private String unitId;
+
+    /**
+     * 所属家庭Id
+     */
+    private String homeId;
+
+    /**
+     * 是否本地户籍
+     */
+    private String isBdhj;
+
+    /**
+     * 姓名
+     */
+    private String name;
+
+    /**
+     * 手机号
+     */
+    private String mobile;
+
+    /**
+     * 性别
+     */
+    private String gender;
+
+    /**
+     * 身份证号
+     */
+    private String idCard;
+
+    /**
+     * 出生日期
+     */
+    private String birthday;
+
+    /**
+     * 备注
+     */
+    private String remarks;
+
+    /**
+     * 联系人
+     */
+    private String contacts;
+
+    /**
+     * 联系人电话
+     */
+    private String contactsMobile;
+
+    /**
+     * 九小场所url
+     */
+    private String ninePlace;
+
+    /**
+     * 是否党员
+     */
+    private String isParty;
+
+    /**
+     * 是否低保户
+     */
+    private String isDbh;
+
+    /**
+     * 是否保障房
+     */
+    private String isEnsureHouse;
+
+    /**
+     * 是否失业
+     */
+    private String isUnemployed;
+
+    /**
+     * 是否育龄妇女
+     */
+    private String isYlfn;
+
+    /**
+     * 是否退役军人
+     */
+    private String isVeterans;
+
+    /**
+     * 是否统战人员
+     */
+    private String isUnitedFront;
+
+    /**
+     * 是否信访人员
+     */
+    private String isXfry;
+
+    /**
+     * 是否志愿者
+     */
+    private String isVolunteer;
+
+    /**
+     * 是否老年人
+     */
+    private String isOldPeople;
+
+    /**
+     * 是否空巢
+     */
+    private String isKc;
+
+    /**
+     * 是否失独
+     */
+    private String isSd;
+
+    /**
+     * 是否失能
+     */
+    private String isSn;
+
+    /**
+     * 是否失智
+     */
+    private String isSz;
+
+    /**
+     * 是否残疾
+     */
+    private String isCj;
+
+    /**
+     * 是否大病
+     */
+    private String isDb;
+
+    /**
+     * 是否慢病
+     */
+    private String isMb;
+
+    /**
+     * 是否特殊人群
+     */
+    private String isSpecial;
+
+    /**
+     * 是否租户【是:1 否:0】
+     */
+    private String isTenant;
+
+    /**
+     * 是否是流动人口【是:1 否:0】
+     */
+    private String isFloating;
+
+    /**
+     * 是否新阶层人士【是:1 否:0】
+     */
+    private String isXjc;
+
+    /**
+     * 文化程度【字典表】
+     */
+    private String culture;
+
+    /**
+     * 文化程度备注
+     */
+    private String cultureRemakes;
+
+    /**
+     * 特长【字典表】
+     */
+    private String specialSkill;
+
+    /**
+     * 兴趣爱好
+     */
+    private String hobby;
+
+    /**
+     * 兴趣爱好备注
+     */
+    private String hobbyRemakes;
+
+    /**
+     * 宗教信仰
+     */
+    private String faith;
+
+    /**
+     * 宗教信仰备注
+     */
+    private String faithRemakes;
+
+    /**
+     * 残疾类别【字典表】
+     */
+    private String cjlb;
+
+    /**
+     * 残疾登记(状况)【字典表】
+     */
+    private String cjzk;
+
+    /**
+     * 残疾证号
+     */
+    private String cjzh;
+
+    /**
+     * 残疾说明
+     */
+    private String cjsm;
+
+    /**
+     * 有无监护人【yes no】
+     */
+    private String ynJdr;
+
+    /**
+     * 有无技能特长【yes no】
+     */
+    private String ynJntc;
+
+    /**
+     * 有无劳动能力
+     */
+    private String ynLdnl;
+
+    /**
+     * 有无非义务教育阶段助学【yes no】
+     */
+    private String ynFywjyjdzx;
+
+    /**
+     * 所患大病
+     */
+    private String shdb;
+
+    /**
+     * 患大病时间
+     */
+    private String dbsj;
+
+    /**
+     * 所患慢性病
+     */
+    private String shmxb;
+
+    /**
+     * 患慢性病时间
+     */
+    private String mxbsj;
+
+    /**
+     * 是否参保
+     */
+    private String isCb;
+
+    /**
+     * 自付金额
+     */
+    private String zfje;
+
+    /**
+     * 救助金额
+     */
+    private String jzje;
+
+    /**
+     * 救助时间[yyyy-MM-dd]
+     */
+    private String jzsj;
+
+    /**
+     * 享受救助明细序号
+     */
+    private String jzmxxh;
+
+    /**
+     * 健康信息备注
+     */
+    private String healthRemakes;
+
+    /**
+     * 工作单位
+     */
+    private String gzdw;
+
+    /**
+     * 职业
+     */
+    private String zy;
+
+    /**
+     * 离退休时间
+     */
+    private String ltxsj;
+
+    /**
+     * 工作信息备注
+     */
+    private String workRemake;
+
+    /**
+     * 退休金额
+     */
+    private String txje;
+
+    /**
+     * 月收入
+     */
+    private String ysr;
+
+    /**
+     * 是否经济低保
+     */
+    private String isJjdb;
+
+    /**
+     * 籍贯
+     */
+    private String jg;
+
+    /**
+     * 户籍所在地
+     */
+    private String hjszd;
+
+    /**
+     * 现居住地
+     */
+    private String xjzd;
+
+    /**
+     * 人户情况
+     */
+    private String rhzk;
+
+    /**
+     * 居住信息备注
+     */
+    private String jzxxRemakes;
+
+    /**
+     * 民族【字典表】
+     */
+    private String mz;
+
+    /**
+     * 与户主关系【字典表】
+     */
+    private String yhzgx;
+
+    /**
+     * 居住情况【字典表】
+     */
+    private String jzqk;
+
+    /**
+     * 婚姻状况【字典表】
+     */
+    private String hyzk;
+
+    /**
+     * 配偶情况【字典表】
+     */
+    private String poqk;
+
+    /**
+     * 有无赡养人
+     */
+    private String ynSyr;
+
+    /**
+     * 与赡养人关系【字典表】
+     */
+    private String ysyrgx;
+
+    /**
+     * 赡养人电话
+     */
+    private String syrMobile;
+
+    /**
+     * 家庭信息备注
+     */
+    private String jtxxRemakes;
+
+    /**
+     * 用户状态【0:正常;1:迁出;2:注销】
+     */
+    private String status;
+
+    /**
+     * 用户详细状态：01：新增、02：导入、03：迁入、04：新生、11：迁出、21死亡
+     */
+    private String subStatus;
+
+
+    /**
+     * 删除标识 0.未删除 1.已删除
+     */
+    private Integer delFlag;
+
+    /**
+     * 乐观锁
+     */
+    private Integer revision;
+
+    /**
+     * 创建人
+     */
+    private String createdBy;
+
+    /**
+     * 创建时间
+     */
+    private Date createdTime;
+
+    /**
+     * 更新人
+     */
+    private String updatedBy;
+
+    /**
+     * 更新时间
+     */
+    private Date updatedTime;
+
+    /**
+     * 预留字段1
+     */
+    private String field1;
+
+    /**
+     * 预留字段2
+     */
+    private String field2;
+
+    /**
+     * 预留字段3
+     */
+    private String field3;
+
+    /**
+     * 预留字段4
+     */
+    private String field4;
+
+    /**
+     * 预留字段5
+     */
+    private String field5;
+
+    /**
+     * 预留字段6
+     */
+    private String field6;
+
+    /**
+     * 预留字段7
+     */
+    private String field7;
+
+    /**
+     * 预留字段8
+     */
+    private String field8;
+
+    /**
+     * 预留字段9
+     */
+    private String field9;
+
+    /**
+     * 预留字段10
+     */
+    private String field10;
+}

epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/IcHouseServiceImpl.java

@@ -15,6 +15,7 @@ import com.epmet.commons.tools.exception.RenException;
 import com.epmet.commons.tools.redis.common.CustomerIcHouseRedis;
 import com.epmet.commons.tools.redis.common.CustomerResiUserRedis;
 import com.epmet.commons.tools.redis.common.bean.HouseInfoCache;
+import com.epmet.commons.tools.redis.common.bean.IcResiUserInfoCache;
 import com.epmet.commons.tools.redis.common.bean.ResiUserInfoCache;
 import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.commons.tools.utils.ConvertUtils;
@@ -437,12 +438,12 @@ public class IcHouseServiceImpl extends BaseServiceImpl<IcHouseDao, IcHouseEntit
             result.setIdCard(houseInfo.getOwnerIdCard());
             msg.setContent("查看房屋信息明文");
         }else if (formDTO.getType().equals(NeighborhoodConstant.IC_RESI_USER)){
-            ResiUserInfoCache userBaseInfo = CustomerResiUserRedis.getUserBaseInfo(formDTO.getId());
-            if (null == userBaseInfo){
+            IcResiUserInfoCache icResiUserInfo = CustomerResiUserRedis.getIcResiUserInfo(formDTO.getId());
+            if (null == icResiUserInfo){
                 throw new EpmetException("查询icResiUser失败："+formDTO.getId());
             }
-            result.setIdCard(userBaseInfo.getIdNum());
-            result.setMobile(userBaseInfo.getMobile());
+            result.setIdCard(icResiUserInfo.getIdCard());
+            result.setMobile(icResiUserInfo.getMobile());
             msg.setContent("查看居民信息明文");
         }
         // 发送mq消息

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

@@ -46,6 +46,7 @@ import com.epmet.commons.tools.page.PageData;
 import com.epmet.commons.tools.redis.RedisKeys;
 import com.epmet.commons.tools.redis.RedisUtils;
 import com.epmet.commons.tools.redis.common.CustomerStaffRedis;
+import com.epmet.commons.tools.redis.common.bean.IcResiUserInfoCache;
 import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.commons.tools.security.user.LoginUserUtil;
 import com.epmet.commons.tools.utils.*;
@@ -1436,4 +1437,9 @@ public class IcResiUserController implements ResultDataResolver {
         return new Result();
     }
 
+    @PostMapping("getIcResiUserInfo/{userId}")
+    public Result<IcResiUserInfoCache> getIcResiUserInfo(@PathVariable("userId") String userId){
+        return new Result<IcResiUserInfoCache>().ok(icResiUserService.getIcResiUserInfo(userId));
+    }
+
 }

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

@@ -20,6 +20,7 @@ package com.epmet.service;
 import com.epmet.commons.mybatis.service.BaseService;
 import com.epmet.commons.tools.dto.result.OptionDataResultDTO;
 import com.epmet.commons.tools.page.PageData;
+import com.epmet.commons.tools.redis.common.bean.IcResiUserInfoCache;
 import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.commons.tools.utils.Result;
 import com.epmet.dto.IcResiUserDTO;
@@ -518,4 +519,6 @@ public interface IcResiUserService extends BaseService<IcResiUserEntity> {
      * @Date 2022/9/8 15:45
      */
     void updateYlfn();
+
+    IcResiUserInfoCache getIcResiUserInfo(String userId);
 }

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

@@ -44,10 +44,7 @@ import com.epmet.commons.tools.redis.common.CustomerIcHouseRedis;
 import com.epmet.commons.tools.redis.common.CustomerOrgRedis;
 import com.epmet.commons.tools.redis.common.CustomerResiUserRedis;
 import com.epmet.commons.tools.redis.common.CustomerStaffRedis;
-import com.epmet.commons.tools.redis.common.bean.AgencyInfoCache;
-import com.epmet.commons.tools.redis.common.bean.GridInfoCache;
-import com.epmet.commons.tools.redis.common.bean.HouseInfoCache;
-import com.epmet.commons.tools.redis.common.bean.ResiUserInfoCache;
+import com.epmet.commons.tools.redis.common.bean.*;
 import com.epmet.commons.tools.security.dto.TokenDto;
 import com.epmet.commons.tools.utils.*;
 import com.epmet.constant.IcPlatformConstant;
@@ -3540,4 +3537,10 @@ public class IcResiUserServiceImpl extends BaseServiceImpl<IcResiUserDao, IcResi
             }
         });
     }
+
+    @Override
+    public IcResiUserInfoCache getIcResiUserInfo(String userId) {
+        IcResiUserEntity icResiUserEntity = baseDao.selectById(userId);
+        return ConvertUtils.sourceToTarget(icResiUserEntity,IcResiUserInfoCache.class);
+    }
 }