diff --git a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetuser/impl/IcResiUserServiceImpl.java b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetuser/impl/IcResiUserServiceImpl.java index 6fa0ed8051..7c3e062649 100644 --- a/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetuser/impl/IcResiUserServiceImpl.java +++ b/epmet-module/data-aggregator/data-aggregator-server/src/main/java/com/epmet/dataaggre/service/epmetuser/impl/IcResiUserServiceImpl.java @@ -3,6 +3,7 @@ package com.epmet.dataaggre.service.epmetuser.impl; import com.alibaba.fastjson.JSON; import com.epmet.commons.dynamic.datasource.annotation.DataSource; import com.epmet.commons.tools.constant.NumConstant; +import com.epmet.commons.tools.constant.StrConstant; import com.epmet.commons.tools.page.PageData; import com.epmet.dataaggre.constant.DataSourceConstant; import com.epmet.dataaggre.dao.epmetuser.IcResiUserDao; @@ -111,19 +112,19 @@ public class IcResiUserServiceImpl implements IcResiUserService { } - public PageData> pageResiMap(IcResiUserPageFormDTO formDTO) { + public PageData> pageResiMap(IcResiUserPageFormDTO formDTO) { // 查询列表展示项,如果没有,直接返回 - List resultColumns=customerFootBarService.queryConditions(formDTO.getCustomerId(),formDTO.getFormCode()); - if(CollectionUtils.isEmpty(resultColumns)){ + List resultColumns = customerFootBarService.queryConditions(formDTO.getCustomerId(), formDTO.getFormCode()); + if (CollectionUtils.isEmpty(resultColumns)) { log.warn("没有配置列表展示列"); return new PageData(new ArrayList(), NumConstant.ZERO); } - log.warn("列表展示项:"+JSON.toJSONString(resultColumns)); + //log.warn("列表展示项:" + JSON.toJSONString(resultColumns)); // 查询列表展示项需要用到哪些子表 // 拼接好的left join table_name on (ic_resi_user.ID=table_name.IC_RESI_USER AND table_name.del_flag='0') - List subTables=customerFootBarService.querySubTables(formDTO.getCustomerId(),formDTO.getFormCode()); - log.info("子表:"+JSON.toJSONString(subTables)); - PageInfo> pageInfo = PageHelper.startPage(formDTO.getPageNo(), + List subTables = customerFootBarService.querySubTables(formDTO.getCustomerId(), formDTO.getFormCode()); + //log.info("子表:" + JSON.toJSONString(subTables)); + PageInfo> pageInfo = PageHelper.startPage(formDTO.getPageNo(), formDTO.getPageSize()).doSelectPageInfo(() -> icResiUserDao.selectListResiMap(formDTO.getCustomerId(), formDTO.getFormCode(), formDTO.getConditions(), @@ -132,75 +133,77 @@ public class IcResiUserServiceImpl implements IcResiUserService { List> list = pageInfo.getList(); //查询网格名称 - List gridIds=new ArrayList<>(); - Set houseIds=new HashSet<>(); - for(Map map:list){ + List gridIds = new ArrayList<>(); + Set houseIds = new HashSet<>(); + for (Map map : list) { log.warn(JSON.toJSONString(map)); - if(map.containsKey("GRID_ID")&& StringUtils.isNotBlank(map.get("GRID_ID").toString())){ + if (map.containsKey("GRID_ID") && null != map.get("GRID_ID") && StringUtils.isNotBlank(map.get("GRID_ID").toString())) { gridIds.add(map.get("GRID_ID").toString()); } - if(map.containsKey("HOME_ID")&& StringUtils.isNotBlank(map.get("HOME_ID").toString())){ + if (map.containsKey("HOME_ID") && null != map.get("HOME_ID") && StringUtils.isNotBlank(map.get("HOME_ID").toString())) { houseIds.add(map.get("HOME_ID").toString()); } } - log.warn("gridIds:"+JSON.toJSONString(gridIds)); + //log.warn("gridIds:" + JSON.toJSONString(gridIds)); - List gridInfoList=govOrgService.gridListByIds(gridIds); + List gridInfoList = govOrgService.gridListByIds(gridIds); //log.warn(JSON.toJSONString(gridInfoList)); Map gridInfoMap = gridInfoList.stream().collect(Collectors.toMap(GridsInfoListResultDTO::getGridId, Function.identity())); //查询房子名称 - List houseInfoDTOList=govOrgService.queryHouseInfo(houseIds); + List houseInfoDTOList = govOrgService.queryHouseInfo(houseIds); Map houseInfoMap = houseInfoDTOList.stream().collect(Collectors.toMap(HouseInfoDTO::getHomeId, Function.identity())); - for(Map resultMap:list){ - if (null != gridInfoMap && gridInfoMap.containsKey(resultMap.get("GRID_ID").toString())) { - resultMap.put("GRID_ID_VALUE",resultMap.get("GRID_ID").toString()); + for (Map resultMap : list) { + String gridIdValue = null != resultMap.get("GRID_ID") ? resultMap.get("GRID_ID").toString() : StrConstant.EPMETY_STR; + resultMap.put("GRID_ID_VALUE", gridIdValue); + if (null != gridInfoMap && gridInfoMap.containsKey(gridIdValue) && null != gridInfoMap.get(gridIdValue)) { //GRID_NAME - resultMap.put("GRID_ID",gridInfoMap.get(resultMap.get("GRID_ID")).getGridName()); + resultMap.put("GRID_ID", gridInfoMap.get(gridIdValue).getGridName()); } - if(null !=houseInfoMap &&houseInfoMap.containsKey(resultMap.get("HOME_ID"))){ - String homeId=resultMap.get("HOME_ID").toString(); - resultMap.put("HOME_ID_VALUE",homeId); - String buildName=houseInfoMap.get(resultMap.get("HOME_ID")).getBuildingName(); - resultMap.put("BUILD_NAME",buildName); + String homeId = null != resultMap.get("HOME_ID") ? resultMap.get("HOME_ID").toString() : StrConstant.EPMETY_STR; + resultMap.put("HOME_ID_VALUE", homeId); + if (null != houseInfoMap && houseInfoMap.containsKey(homeId) && null != houseInfoMap.get(homeId)) { + HouseInfoDTO houseInfoDTO = houseInfoMap.get(homeId); + String buildName = StringUtils.isNotBlank(houseInfoDTO.getBuildingName()) ? houseInfoDTO.getBuildingName() : StrConstant.EPMETY_STR; + resultMap.put("BUILD_NAME", buildName); - String neighBorName=houseInfoMap.get(resultMap.get("HOME_ID")).getNeighborHoodName(); - resultMap.put("VILLAGE_NAME",neighBorName); + String neighBorName = StringUtils.isNotBlank(houseInfoDTO.getNeighborHoodName()) ? houseInfoDTO.getNeighborHoodName() : StrConstant.EPMETY_STR; + resultMap.put("VILLAGE_NAME", neighBorName); - String unitName=houseInfoMap.get(resultMap.get("HOME_ID")).getUnitName(); - resultMap.put("UNIT_NAME",unitName); + String unitName = StringUtils.isNotBlank(houseInfoDTO.getUnitName()) ? houseInfoDTO.getUnitName() : StrConstant.EPMETY_STR; + resultMap.put("UNIT_NAME", unitName); - String doorName=houseInfoMap.get(resultMap.get("HOME_ID")).getDoorName(); - resultMap.put("DOOR_NAME",doorName); + String doorName = StringUtils.isNotBlank(houseInfoDTO.getDoorName()) ? houseInfoDTO.getDoorName() : StrConstant.EPMETY_STR; + resultMap.put("DOOR_NAME", doorName); - String houseType=houseInfoMap.get(resultMap.get("HOME_ID")).getHouseType(); + String houseType = StringUtils.isNotBlank(houseInfoDTO.getHouseType()) ? houseInfoDTO.getHouseType() : StrConstant.EPMETY_STR; //房屋类型,1楼房,2平房,3别墅 - resultMap.put("HOUSE_TYPE",""); - if("1".equals(houseType)){ - resultMap.put("HOUSE_TYPE","楼房"); - }else if("2".equals(houseType)){ - resultMap.put("HOUSE_TYPE","平房"); - }else if("3".equals(houseType)){ - resultMap.put("HOUSE_TYPE","别墅"); + resultMap.put("HOUSE_TYPE", ""); + if ("1".equals(houseType)) { + resultMap.put("HOUSE_TYPE", "楼房"); + } else if ("2".equals(houseType)) { + resultMap.put("HOUSE_TYPE", "平房"); + } else if ("3".equals(houseType)) { + resultMap.put("HOUSE_TYPE", "别墅"); } - resultMap.put("HOME_ID",neighBorName.concat(buildName).concat(unitName).concat(doorName)); + resultMap.put("HOME_ID", neighBorName.concat(buildName).concat(unitName).concat(doorName)); } - if(resultMap.containsKey("GENDER")){ - String genderValue=resultMap.get("GENDER").toString(); - if("1".equals(genderValue)){ - resultMap.put("GENDER","男"); - }else if("2".equals(genderValue)){ - resultMap.put("HOUSE_TYPE","女"); - }else if("0".equals(genderValue)){ - resultMap.put("HOUSE_TYPE","未知"); + if (resultMap.containsKey("GENDER")) { + String genderValue = null != resultMap.get("GENDER") ? resultMap.get("GENDER").toString() : StrConstant.EPMETY_STR; + if ("1".equals(genderValue)) { + resultMap.put("GENDER", "男"); + } else if ("2".equals(genderValue)) { + resultMap.put("HOUSE_TYPE", "女"); + } else if ("0".equals(genderValue)) { + resultMap.put("HOUSE_TYPE", "未知"); } } } pageInfo.setList(list); - return new PageData<>(pageInfo.getList(),pageInfo.getTotal()); + return new PageData<>(pageInfo.getList(), pageInfo.getTotal()); } /**