Browse Source

添加日志排查

master
jianjun 3 years ago
parent
commit
e169fc1c33
  1. 6
      epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/HouseController.java
  2. 9
      epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/service/impl/HouseServiceImpl.java

6
epmet-module/gov-org/gov-org-server/src/main/java/com/epmet/controller/HouseController.java

@ -335,6 +335,7 @@ public class HouseController implements ResultDataResolver {
@NoRepeatSubmit
@RequestMapping(value = "/exportHouseUser")
public void exportHouseUser(@LoginUser TokenDto tokenDto, @RequestBody IcHouseListFormDTO formDTO, HttpServletResponse response) throws Exception {
long startTime = System.currentTimeMillis();
formDTO.setIsPage(false);
formDTO.setPageSize(NumConstant.TEN_THOUSAND);
//效验数据
@ -371,15 +372,19 @@ public class HouseController implements ResultDataResolver {
.build();
PageData<HouseMemberResultDTO> dataList = null;
Cache<String,Boolean> haveSearchCache = CacheBuilder.newBuilder().maximumSize(NumConstant.ONE_HUNDRED).expireAfterWrite(NumConstant.THIRTY, TimeUnit.MINUTES).build();
do {
dataList = houseService.getHouseUser(tokenDto,formDTO,haveSearchCache);
formDTO.setPageNo(formDTO.getPageNo() + NumConstant.ONE);
long start = System.currentTimeMillis();
excelWriter.write(dataList.getList(), writeSheet);
log.info("getHouseUser doWrite cost:{}ms",System.currentTimeMillis() - start);
if (CollectionUtils.isEmpty(dataList.getList())){
break;
}
}while (dataList.getTotal() == formDTO.getPageSize());
//获取导出配置
haveSearchCache.invalidateAll();
} catch (EpmetException e) {
@ -394,6 +399,7 @@ public class HouseController implements ResultDataResolver {
if (excelWriter != null){
excelWriter.finish();
}
log.info("getHouseUser final cost:{}ms",System.currentTimeMillis() - startTime);
}
}

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

@ -615,8 +615,9 @@ public class HouseServiceImpl implements HouseService, ResultDataResolver {
if (StringUtils.isNotEmpty(formDTO.getOwnerName()) || StringUtils.isNotEmpty(formDTO.getOwnerPhone()) || StringUtils.isNotEmpty(formDTO.getRentFlag())){
searchLevel = 3;
}
long start = System.currentTimeMillis();
PageData<IcHouseListResultDTO> houseData = this.getHouseList(formDTO);
log.info("getHouseUser getHoseList cost:{}ms",System.currentTimeMillis() - start);
List<HouseMemberResultDTO> resultList = new ArrayList<>();
PageData<HouseMemberResultDTO> result = new PageData<>(resultList,houseData.getList().size());
@ -634,6 +635,7 @@ public class HouseServiceImpl implements HouseService, ResultDataResolver {
if (finalSearchLevel == 3){
resiParam.setHouseId(o.getHouseId());
}
this.getHouseMembers(resiParam, memberCacheMap,haveSearchCache);
List<HouseIcResiUserResultDTO.HouseMemberResultDTO> members = memberCacheMap.getIfPresent(o.getHouseId());
@ -676,11 +678,13 @@ public class HouseServiceImpl implements HouseService, ResultDataResolver {
* @param haveSearchCache
*/
public void getHouseMembers(RentTenantDataFormDTO resiParam, Cache<String, List<HouseIcResiUserResultDTO.HouseMemberResultDTO>> memberMap, Cache<String, Boolean> haveSearchCache) {
String searchKey = resiParam.getHouseId()+resiParam.getBuildingId()+resiParam.getNeighborHoodId()+resiParam.getAgencyId();
String searchKey = resiParam.getHouseId()+resiParam.getBuildingId()+resiParam.getNeighborHoodId()+resiParam.getGridId()+resiParam.getAgencyId();
Boolean haveSearch = haveSearchCache.getIfPresent(searchKey);
//log.info("getHouseUser getHouseMembers searchKey:"+searchKey);
if (haveSearch!= null && haveSearch){
return;
}
long startT = System.currentTimeMillis();
haveSearchCache.put(searchKey,true);
List<HouseIcResiUserResultDTO> memberListTemp = null;
resiParam.setPageNo(NumConstant.ONE);
@ -699,6 +703,7 @@ public class HouseServiceImpl implements HouseService, ResultDataResolver {
memberListTemp.parallelStream().forEach(h -> memberMap.put(h.getHomeId(), h.getHouseMemberList()));
} while (memberListTemp.size() == resiParam.getPageSize());
log.info("getHouseUser getHouseMembers cost:{}ms,param:{}",System.currentTimeMillis() - startT,JSON.toJSONString(resiParam));
}
/**

Loading…
Cancel
Save