Browse Source

改了个名

dev_shibei_match
jianjun 4 years ago
parent
commit
e68ca8a448
  1. 5
      epmet-user/epmet-user-server/src/main/java/com/epmet/controller/IcResiUserController.java
  2. 30
      epmet-user/epmet-user-server/src/main/java/com/epmet/service/impl/IcResiUserServiceImpl.java

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

@ -385,12 +385,9 @@ public class IcResiUserController {
try { try {
excelWriter = EasyExcel.write(getOutputStream("居民基本信息.xlsx", response)).withTemplate(file).build(); excelWriter = EasyExcel.write(getOutputStream("居民基本信息.xlsx", response)).withTemplate(file).build();
pageFormDTO.setPageSize(NumConstant.FIVE_HUNDRED);
pageFormDTO.setPageNo(NumConstant.ONE);
//子表是否停止查询 //子表是否停止查询
Set<String> stopSearchSet = new HashSet<>(); Set<String> stopSearchSet = new HashSet<>();
//获取表单项 //获取表单项
List<FormItemResult> resiFormAllItems = icResiUserService.listFormItems(customerId, IC_RESI_FORM_CODE); List<FormItemResult> resiFormAllItems = icResiUserService.listFormItems(customerId, IC_RESI_FORM_CODE);
Map<String, FormItemResult> allItemMap = resiFormAllItems.stream().collect(Collectors.toMap(FormItemResult::getItemId, o -> o)); Map<String, FormItemResult> allItemMap = resiFormAllItems.stream().collect(Collectors.toMap(FormItemResult::getItemId, o -> o));
@ -424,6 +421,8 @@ public class IcResiUserController {
.sorted(Comparator.comparing(IcResiUserTableEnum::getSheetNo)) .sorted(Comparator.comparing(IcResiUserTableEnum::getSheetNo))
.collect(Collectors.toList()); .collect(Collectors.toList());
List<Map<String, Object>> resiResultList = null; List<Map<String, Object>> resiResultList = null;
pageFormDTO.setPageSize(NumConstant.FIVE_HUNDRED);
for (IcResiUserTableEnum tableEnum : resiTableList) { for (IcResiUserTableEnum tableEnum : resiTableList) {
String tableName = tableEnum.getTableName(); String tableName = tableEnum.getTableName();
pageFormDTO.setPageNo(NumConstant.ONE); pageFormDTO.setPageNo(NumConstant.ONE);

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

@ -650,56 +650,52 @@ public class IcResiUserServiceImpl extends BaseServiceImpl<IcResiUserDao, IcResi
Page<Map<String, Object>> mapListPage = PageHelper.startPage(pageFormDTO.getPageNo(), pageFormDTO.getPageSize(), pageFormDTO.getPageFlag()).doSelectPage(() -> { Page<Map<String, Object>> mapListPage = PageHelper.startPage(pageFormDTO.getPageNo(), pageFormDTO.getPageSize(), pageFormDTO.getPageFlag()).doSelectPage(() -> {
this.dynamicQuery(pageFormDTO.getCustomerId(), pageFormDTO.getFormCode(), baseTableName, pageFormDTO.getConditions(), currentStaffAgencyId, staffOrgPath); this.dynamicQuery(pageFormDTO.getCustomerId(), pageFormDTO.getFormCode(), baseTableName, pageFormDTO.getConditions(), currentStaffAgencyId, staffOrgPath);
}); });
mapListPage.getResult().stream().filter(Objects::nonNull).forEach(map -> { mapListPage.getResult().stream().filter(Objects::nonNull).forEach(resiUser -> {
String resiId = null; String resiId = null;
//获取用户Id //获取用户Id
if (IcResiUserConstant.IC_RESI_USER.equals(baseTableName)) { if (IcResiUserConstant.IC_RESI_USER.equals(baseTableName)) {
resiId = (String) map.get("ID"); resiId = (String) resiUser.get("ID");
}else { }else {
resiId = (String) map.get(UserConstant.IC_RESI_USER); resiId = (String) resiUser.get(UserConstant.IC_RESI_USER);
} }
if (StringUtils.isBlank(resiId)){ if (StringUtils.isBlank(resiId)){
log.error("getDataForExport error,resiId is net exist:{}",map); log.error("getDataForExport error,resiId is net exist:{}",resiUser);
return; return;
} }
//遍历所有字段 格式化时间字段 //遍历所有字段 格式化时间字段
map.forEach((k,o) -> { resiUser.forEach((k,o) -> {
if (o instanceof java.sql.Date){ if (o instanceof java.sql.Date){
o = DateUtils.format(((Date) o),DateUtils.DATE_PATTERN); o = DateUtils.format(((Date) o),DateUtils.DATE_PATTERN);
}else if (o instanceof java.sql.Timestamp){ }else if (o instanceof java.sql.Timestamp){
o = DateUtils.format(new Date(((Timestamp) o).getTime()),DateUtils.DATE_TIME_PATTERN); o = DateUtils.format(new Date(((Timestamp) o).getTime()),DateUtils.DATE_TIME_PATTERN);
} }
map.put(k,o); resiUser.put(k,o);
FormItemResult itemResult = formItemMap.getItemMap().get(k);
if (itemResult == null){
return;
}
}); });
//当前条数据原始的id值 map //当前条数据原始的id值 resiUser
Map<String,Object> originalConditionMap = new HashMap<>(); Map<String,Object> originalConditionMap = new HashMap<>();
for (FormItemResult e : formItemMap.getItemMap().values()) { for (FormItemResult e : formItemMap.getItemMap().values()) {
String columnName = getColumnName(e); String columnName = getColumnName(e);
Object temp = map.get(columnName); Object temp = resiUser.get(columnName);
String vauleStr = temp == null ? StrConstant.EPMETY_STR : temp.toString(); String vauleStr = temp == null ? StrConstant.EPMETY_STR : temp.toString();
originalConditionMap.putIfAbsent(columnName,vauleStr); originalConditionMap.putIfAbsent(columnName,vauleStr);
if ("remote".equals(e.getOptionSourceType()) && StringUtils.isNotBlank(vauleStr)) { if ("remote".equals(e.getOptionSourceType()) && StringUtils.isNotBlank(vauleStr)) {
putRemoteValue(formItemMap.getRemoteItemConditionMap().get(e.getItemId()), currentStaffAgencyId, map,originalConditionMap, e, columnName, vauleStr); putRemoteValue(formItemMap.getRemoteItemConditionMap().get(e.getItemId()), currentStaffAgencyId, resiUser,originalConditionMap, e, columnName, vauleStr);
} else { } else {
putOptionValue(map, e, columnName, vauleStr); putOptionValue(resiUser, e, columnName, vauleStr);
} }
} }
if (!IcResiUserConstant.IC_RESI_USER.equals(baseTableName)) { if (!IcResiUserConstant.IC_RESI_USER.equals(baseTableName)) {
Map<String,Object> o = redisUtils.hGetAll(RedisKeys.getExportResiBaseInfoKey(resiId)); Map<String,Object> o = redisUtils.hGetAll(RedisKeys.getExportResiBaseInfoKey(resiId));
if (o != null){ if (o != null){
map.putAll(o); resiUser.putAll(o);
} }
return; return;
} }
//把人放入redis缓存 便于后面的sheet使用基础信息 //把人放入redis缓存 便于后面的sheet使用基础信息
redisUtils.hMSet(RedisKeys.getExportResiBaseInfoKey(resiId),map,RedisUtils.MINUTE_THIRTY_EXPIRE); redisUtils.hMSet(RedisKeys.getExportResiBaseInfoKey(resiId),resiUser,RedisUtils.MINUTE_THIRTY_EXPIRE);
}); });
remoteOptionCacheMap.clear(); remoteOptionCacheMap.clear();
return mapListPage.getResult(); return mapListPage.getResult();
@ -730,7 +726,7 @@ public class IcResiUserServiceImpl extends BaseServiceImpl<IcResiUserDao, IcResi
continue; continue;
}*/ }*/
Cache<String, String> cache = remoteOptionCacheMap.getOrDefault(e.getItemId(), CacheBuilder.newBuilder().maximumSize(NumConstant.FIVE_HUNDRED).build()); Cache<String, String> cache = remoteOptionCacheMap.getOrDefault(e.getItemId(), CacheBuilder.newBuilder().maximumSize(NumConstant.FIVE_HUNDRED).build());
remoteOptionCacheMap.put(e.getItemId(),cache); remoteOptionCacheMap.putIfAbsent(e.getItemId(),cache);
String cacheValue = cache.getIfPresent(vauleStr); String cacheValue = cache.getIfPresent(vauleStr);
if (StringUtils.isNotBlank(cacheValue)){ if (StringUtils.isNotBlank(cacheValue)){
map.put(columnName,cacheValue); map.put(columnName,cacheValue);

Loading…
Cancel
Save