|
|
@ -997,6 +997,10 @@ public class EpmetUserServiceImpl implements EpmetUserService { |
|
|
|
String customerId = tokenDto.getCustomerId(); |
|
|
|
String userId = tokenDto.getUserId(); |
|
|
|
CheckMQMsg msg = new CheckMQMsg(); |
|
|
|
IcResiUserInfoCache icResiUserInfo = CustomerResiUserRedis.getIcResiUserInfo(formDTO.getId()); |
|
|
|
if (null == icResiUserInfo){ |
|
|
|
throw new EpmetException("查询icResiUser失败:"+formDTO.getId()); |
|
|
|
} |
|
|
|
if (formDTO.getType().equals(NeighborhoodConstant.HOUSE)){ |
|
|
|
HouseInfoCache houseInfo = CustomerIcHouseRedis.getHouseInfo(customerId, formDTO.getId()); |
|
|
|
if (null == houseInfo){ |
|
|
@ -1005,22 +1009,76 @@ public class EpmetUserServiceImpl implements EpmetUserService { |
|
|
|
result.setMobile(houseInfo.getOwnerPhone()); |
|
|
|
result.setIdCard(houseInfo.getOwnerIdCard()); |
|
|
|
msg.setContent("查看"+houseInfo.getAllName()+"房屋的敏感信息"); |
|
|
|
msg.setType("checkHouse"); |
|
|
|
msg.setTypeDisplay("查看"+houseInfo.getAllName()+"房屋的敏感信息"); |
|
|
|
}else if (formDTO.getType().equals(NeighborhoodConstant.IC_RESI_USER)){ |
|
|
|
IcResiUserInfoCache icResiUserInfo = CustomerResiUserRedis.getIcResiUserInfo(formDTO.getId()); |
|
|
|
if (null == icResiUserInfo){ |
|
|
|
throw new EpmetException("查询icResiUser失败:"+formDTO.getId()); |
|
|
|
} |
|
|
|
result.setIdCard(icResiUserInfo.getIdCard()); |
|
|
|
result.setMobile(icResiUserInfo.getMobile()); |
|
|
|
msg.setContent("查看"+icResiUserInfo.getName()+"的敏感信息"); |
|
|
|
msg.setType("checkIcResiUser"); |
|
|
|
msg.setTypeDisplay("查看"+icResiUserInfo.getName()+"的敏感信息"); |
|
|
|
}else if (formDTO.getType().equals(NeighborhoodConstant.JMFYXX)){ |
|
|
|
result.setIdCard(icResiUserInfo.getIdCard()); |
|
|
|
result.setMobile(icResiUserInfo.getMobile()); |
|
|
|
msg.setContent("查看"+icResiUserInfo.getName()+"的敏感信息(居民防疫信息)"); |
|
|
|
}else if (formDTO.getType().equals(NeighborhoodConstant.ROUTE_FOLLOW)){ |
|
|
|
Map<String, String> info = icResiUserDao.getTripReportRecordInfo(formDTO.getId()); |
|
|
|
if (null == info){ |
|
|
|
throw new EpmetException("未查询到行程随访信息:"+formDTO.getId()); |
|
|
|
} |
|
|
|
result.setIdCard(info.get(NeighborhoodConstant.ID_CARD)); |
|
|
|
result.setMobile(info.get(NeighborhoodConstant.MOBILE)); |
|
|
|
msg.setContent("查看"+info.get(NeighborhoodConstant.NAME)+"的敏感信息(行程随访)"); |
|
|
|
}else if (formDTO.getType().equals(NeighborhoodConstant.VACCINATION_RECORD)){ |
|
|
|
Map<String, String> info = icResiUserDao.getVaccineRecordInfo(formDTO.getId()); |
|
|
|
if (null == info){ |
|
|
|
throw new EpmetException("未查询到疫苗接种信息:"+formDTO.getId()); |
|
|
|
} |
|
|
|
result.setIdCard(info.get(NeighborhoodConstant.ID_CARD)); |
|
|
|
result.setMobile(info.get(NeighborhoodConstant.MOBILE)); |
|
|
|
msg.setContent("查看"+info.get(NeighborhoodConstant.NAME)+"的敏感信息(疫苗接种记录)"); |
|
|
|
}else if (formDTO.getType().equals(NeighborhoodConstant.VACCINE_SPECIAL_ATTENTION) |
|
|
|
|| formDTO.getType().equals(NeighborhoodConstant.FOCUS_GROUP_SPECIAL_ATTENTION_QUARANTINE) |
|
|
|
|| formDTO.getType().equals(NeighborhoodConstant.FOCUS_GROUP_SPECIAL_ATTENTION_HISTORY)){ |
|
|
|
Map<String, String> info = icResiUserDao.getSpecialAttentionInfo(formDTO.getId()); |
|
|
|
if (null == info){ |
|
|
|
throw new EpmetException("未查询到特别关注名单信息:"+formDTO.getId()); |
|
|
|
} |
|
|
|
result.setIdCard(info.get(NeighborhoodConstant.ID_CARD)); |
|
|
|
result.setMobile(info.get(NeighborhoodConstant.MOBILE)); |
|
|
|
String cMsg = ""; |
|
|
|
switch (formDTO.getType()){ |
|
|
|
case NeighborhoodConstant.VACCINE_SPECIAL_ATTENTION: |
|
|
|
cMsg = "疫苗接种关注名单"; |
|
|
|
break; |
|
|
|
case NeighborhoodConstant.FOCUS_GROUP_SPECIAL_ATTENTION_QUARANTINE: |
|
|
|
cMsg = "重点人群关注名单(防疫隔离)"; |
|
|
|
break; |
|
|
|
case NeighborhoodConstant.FOCUS_GROUP_SPECIAL_ATTENTION_HISTORY: |
|
|
|
cMsg = "重点人群关注名单(历史记录)"; |
|
|
|
break; |
|
|
|
default: |
|
|
|
} |
|
|
|
msg.setContent("查看"+info.get(NeighborhoodConstant.NAME)+"的敏感信息("+cMsg+")"); |
|
|
|
|
|
|
|
}else if (formDTO.getType().equals(NeighborhoodConstant.NO_NAT_COMPARE)){ |
|
|
|
Map<String, String> info = icResiUserDao.getNoNatCompareInfo(formDTO.getId()); |
|
|
|
if (null == info){ |
|
|
|
throw new EpmetException("未查询到未做核酸比对信息:"+formDTO.getId()); |
|
|
|
} |
|
|
|
result.setIdCard(info.get(NeighborhoodConstant.ID_CARD)); |
|
|
|
result.setMobile(info.get(NeighborhoodConstant.MOBILE)); |
|
|
|
msg.setContent("查看"+info.get(NeighborhoodConstant.NAME)+"的敏感信息(未做核酸比对)"); |
|
|
|
}else if (formDTO.getType().equals(NeighborhoodConstant.NAT_RECORD)){ |
|
|
|
Map<String, String> info = icResiUserDao.getNatInfo(formDTO.getId()); |
|
|
|
if (null == info){ |
|
|
|
throw new EpmetException("未查询到核酸检测信息:"+formDTO.getId()); |
|
|
|
} |
|
|
|
result.setIdCard(info.get(NeighborhoodConstant.ID_CARD)); |
|
|
|
result.setMobile(info.get(NeighborhoodConstant.MOBILE)); |
|
|
|
msg.setContent("查看"+info.get(NeighborhoodConstant.NAME)+"的敏感信息(核酸检测信息)"); |
|
|
|
} |
|
|
|
// 发送mq消息
|
|
|
|
HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest(); |
|
|
|
msg.setOperateTime(new Date()); |
|
|
|
msg.setType(formDTO.getType()); |
|
|
|
msg.setTypeDisplay(msg.getContent()); |
|
|
|
msg.setUserId(userId); |
|
|
|
msg.setFromApp(tokenDto.getApp()); |
|
|
|
msg.setIp(IpUtils.getIpAddr(request)); |
|
|
|