yinzuomei
4 years ago
21 changed files with 943 additions and 52 deletions
@ -0,0 +1,118 @@ |
|||||
|
package com.epmet.dto; |
||||
|
|
||||
|
import com.epmet.commons.tools.constant.NumConstant; |
||||
|
import lombok.Data; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
|
||||
|
/** |
||||
|
* @Author zxc |
||||
|
* @DateTime 2022/2/13 4:32 下午 |
||||
|
* @DESC |
||||
|
*/ |
||||
|
@Data |
||||
|
public class ImportHouseGeneralDTO implements Serializable { |
||||
|
|
||||
|
private static final long serialVersionUID = -345610717773879687L; |
||||
|
|
||||
|
/** |
||||
|
* 组织名、ID |
||||
|
*/ |
||||
|
private String agencyName; |
||||
|
private String agencyId; |
||||
|
|
||||
|
/** |
||||
|
* agencyId的pid |
||||
|
*/ |
||||
|
private String pid; |
||||
|
private String pids; |
||||
|
|
||||
|
/** |
||||
|
* 网格名、ID |
||||
|
*/ |
||||
|
private String gridName; |
||||
|
private String gridId; |
||||
|
|
||||
|
/** |
||||
|
* 小区名、ID |
||||
|
*/ |
||||
|
private String neighborHoodName; |
||||
|
private String neighborHoodId; |
||||
|
|
||||
|
/** |
||||
|
* 所属楼栋、ID |
||||
|
*/ |
||||
|
private String buildingName; |
||||
|
private String buildingId; |
||||
|
|
||||
|
/** |
||||
|
* 房屋类型 |
||||
|
*/ |
||||
|
private String type; |
||||
|
|
||||
|
/** |
||||
|
* 单元数 |
||||
|
*/ |
||||
|
private Integer totalUnitNum = NumConstant.ONE; |
||||
|
|
||||
|
/** |
||||
|
* 层数 |
||||
|
*/ |
||||
|
private Integer totalFloorNum; |
||||
|
|
||||
|
/** |
||||
|
* 户数 |
||||
|
*/ |
||||
|
private Integer totalHouseNum; |
||||
|
|
||||
|
/** |
||||
|
* 单元号、ID |
||||
|
*/ |
||||
|
private Integer buildingUnit; |
||||
|
private String buildingUnitId; |
||||
|
|
||||
|
/** |
||||
|
* 门牌号 |
||||
|
*/ |
||||
|
private String doorName; |
||||
|
|
||||
|
/** |
||||
|
* 房屋类型 |
||||
|
*/ |
||||
|
private String houseType; |
||||
|
|
||||
|
/** |
||||
|
* 房屋用途 |
||||
|
*/ |
||||
|
private String purpose; |
||||
|
|
||||
|
/** |
||||
|
* 是否出租 |
||||
|
*/ |
||||
|
private String rentFlag; |
||||
|
|
||||
|
/** |
||||
|
* 姓名 |
||||
|
*/ |
||||
|
private String ownerName; |
||||
|
|
||||
|
/** |
||||
|
* 电话 |
||||
|
*/ |
||||
|
private String ownerPhone; |
||||
|
|
||||
|
/** |
||||
|
* 身份证 |
||||
|
*/ |
||||
|
private String ownerIdCard; |
||||
|
|
||||
|
/** |
||||
|
* 行号 |
||||
|
*/ |
||||
|
private Integer num; |
||||
|
|
||||
|
/** |
||||
|
* 房屋ID |
||||
|
*/ |
||||
|
private String houseId; |
||||
|
} |
||||
@ -0,0 +1,52 @@ |
|||||
|
package com.epmet.model; |
||||
|
|
||||
|
import com.alibaba.excel.annotation.ExcelProperty; |
||||
|
import lombok.Data; |
||||
|
import org.hibernate.validator.constraints.Length; |
||||
|
|
||||
|
/** |
||||
|
* @Author zxc |
||||
|
* @DateTime 2022/2/13 1:26 下午 |
||||
|
* @DESC |
||||
|
*/ |
||||
|
@Data |
||||
|
public class HouseInfoModel { |
||||
|
|
||||
|
@ExcelProperty(value = "所属组织") |
||||
|
private String agencyName; |
||||
|
|
||||
|
@ExcelProperty(value = "所属网格") |
||||
|
private String gridName; |
||||
|
|
||||
|
@ExcelProperty(value = "所属小区") |
||||
|
@Length(max=50,message = "不能超过50个字") |
||||
|
private String neighborHoodName; |
||||
|
|
||||
|
@ExcelProperty(value = "所属楼栋") |
||||
|
private String buildingName; |
||||
|
|
||||
|
@ExcelProperty(value = "单元号") |
||||
|
private Integer buildingUnit; |
||||
|
|
||||
|
@ExcelProperty(value = "门牌号") |
||||
|
private String doorName; |
||||
|
|
||||
|
@ExcelProperty(value = "房屋类型") |
||||
|
private String houseType; |
||||
|
|
||||
|
@ExcelProperty(value = "房屋用途") |
||||
|
private String purpose; |
||||
|
|
||||
|
@ExcelProperty(value = "出租") |
||||
|
private String rentFlag; |
||||
|
|
||||
|
@ExcelProperty(value = "房主姓名") |
||||
|
private String ownerName; |
||||
|
|
||||
|
@ExcelProperty(value = "房主电话") |
||||
|
private String ownerPhone; |
||||
|
|
||||
|
@ExcelProperty(value = "房主身份证") |
||||
|
private String ownerIdCard; |
||||
|
|
||||
|
} |
||||
@ -0,0 +1,41 @@ |
|||||
|
package com.epmet.model; |
||||
|
|
||||
|
import com.alibaba.excel.annotation.ExcelProperty; |
||||
|
import lombok.Data; |
||||
|
import org.hibernate.validator.constraints.Length; |
||||
|
|
||||
|
/** |
||||
|
* @Author zxc |
||||
|
* @DateTime 2022/2/13 1:26 下午 |
||||
|
* @DESC |
||||
|
*/ |
||||
|
@Data |
||||
|
public class HouseInfoModelDTO { |
||||
|
|
||||
|
private String agencyName; |
||||
|
|
||||
|
private String gridName; |
||||
|
|
||||
|
private String neighborHoodName; |
||||
|
|
||||
|
private String buildingName; |
||||
|
|
||||
|
private Integer buildingUnit; |
||||
|
|
||||
|
private String doorName; |
||||
|
|
||||
|
private String houseType; |
||||
|
|
||||
|
private String purpose; |
||||
|
|
||||
|
private String rentFlag; |
||||
|
|
||||
|
private String ownerName; |
||||
|
|
||||
|
private String ownerPhone; |
||||
|
|
||||
|
private String ownerIdCard; |
||||
|
|
||||
|
private Integer num; |
||||
|
|
||||
|
} |
||||
@ -0,0 +1,253 @@ |
|||||
|
package com.epmet.model; |
||||
|
|
||||
|
import com.alibaba.excel.context.AnalysisContext; |
||||
|
import com.alibaba.excel.event.AnalysisEventListener; |
||||
|
import com.alibaba.fastjson.JSON; |
||||
|
import com.epmet.commons.tools.constant.NumConstant; |
||||
|
import com.epmet.commons.tools.exception.EpmetException; |
||||
|
import com.epmet.commons.tools.redis.common.CustomerOrgRedis; |
||||
|
import com.epmet.commons.tools.redis.common.bean.GridInfoCache; |
||||
|
import com.epmet.commons.tools.utils.ConvertUtils; |
||||
|
import com.epmet.dao.IcBuildingDao; |
||||
|
import com.epmet.dto.ImportHouseGeneralDTO; |
||||
|
import com.epmet.dto.form.ImportInfoFormDTO; |
||||
|
import com.epmet.redis.IcHouseRedis; |
||||
|
import org.apache.commons.lang3.StringUtils; |
||||
|
import org.springframework.util.CollectionUtils; |
||||
|
|
||||
|
import java.util.*; |
||||
|
import java.util.stream.Collectors; |
||||
|
|
||||
|
/** |
||||
|
* @Author zxc |
||||
|
* @DateTime 2022/2/13 1:25 下午 |
||||
|
* @DESC |
||||
|
*/ |
||||
|
public class ImportHouseInfoListener extends AnalysisEventListener<HouseInfoModel> { |
||||
|
|
||||
|
List<Integer> nums = new ArrayList<>(); |
||||
|
Integer num = NumConstant.ZERO; |
||||
|
|
||||
|
List<ImportHouseGeneralDTO> needDisposeList = new ArrayList<>(); |
||||
|
List<ImportHouseGeneralDTO> needInsertList = new ArrayList<>(); |
||||
|
|
||||
|
String buildingName = null; |
||||
|
String neighborHoodName = null; |
||||
|
String gridName = null; |
||||
|
String agencyName = null; |
||||
|
|
||||
|
Map<String, Object> gridInfos = null; |
||||
|
List<ImportHouseGeneralDTO> gridInfoDTOs = null; |
||||
|
Map<String, Object> neighborHoodInfos = null; |
||||
|
List<ImportHouseGeneralDTO> neighborHoodInfoDTOs = null; |
||||
|
Map<String, Object> buildingInfos = null; |
||||
|
List<ImportHouseGeneralDTO> buildingInfoDTOs = null; |
||||
|
Map<String, Object> buildingUnitInfos = null; |
||||
|
List<ImportHouseGeneralDTO> buildingUnitInfoDTOs = null; |
||||
|
|
||||
|
private ImportInfoFormDTO formDTO; |
||||
|
private IcBuildingDao icBuildingDao; |
||||
|
private IcHouseRedis icHouseRedis; |
||||
|
|
||||
|
public ImportHouseInfoListener(ImportInfoFormDTO formDTO,IcBuildingDao icBuildingDao, IcHouseRedis icHouseRedis){ |
||||
|
this.formDTO = formDTO; |
||||
|
this.icBuildingDao = icBuildingDao; |
||||
|
this.icHouseRedis = icHouseRedis; |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public void invoke(HouseInfoModel data, AnalysisContext context) { |
||||
|
if (null == data){ |
||||
|
return; |
||||
|
} |
||||
|
num = num + NumConstant.ONE; |
||||
|
ImportHouseGeneralDTO dto = ConvertUtils.sourceToTarget(data, ImportHouseGeneralDTO.class); |
||||
|
dto.setNum(num); |
||||
|
if (formDTO.getOrgType().equals("building")){ |
||||
|
buildingName = null == buildingName ? icBuildingDao.selectBuildingNameById(formDTO.getOrgId()) : buildingName; |
||||
|
// 不是本楼的
|
||||
|
if (!data.getBuildingName().equals(buildingName)){ |
||||
|
nums.add(num); |
||||
|
}else { |
||||
|
/** |
||||
|
* 1。根据楼宇查询 |
||||
|
*/ |
||||
|
needDisposeList.add(dto); |
||||
|
Map<String, Object> collect = needDisposeList.stream().collect(Collectors.toMap(n -> n.getBuildingId() + "_" + n.getBuildingUnitId() + "_" + n.getDoorName(), n -> StringUtils.isNotBlank(n.getHouseId()) ? n.getHouseId() : "")); |
||||
|
icHouseRedis.setTemporaryCacheHouse(formDTO.getCustomerId(), collect, formDTO.getUserId()); |
||||
|
// Map<String, Object> temporaryCacheHouses = icHouseRedis.getTemporaryCacheHouses(formDTO.getCustomerId(), formDTO.getUserId());
|
||||
|
// TODO 等待方法
|
||||
|
List<ImportHouseGeneralDTO> result = new ArrayList<>(); |
||||
|
//把房屋ID不为空的行号加入nums，说明已存在
|
||||
|
result.forEach(r -> { |
||||
|
if (StringUtils.isNotBlank(r.getHouseId())){ |
||||
|
nums.add(r.getNum()); |
||||
|
} |
||||
|
}); |
||||
|
} |
||||
|
}else if (formDTO.getOrgType().equals("neighborHood")){ |
||||
|
disposeNeighborHoodHouse(dto); |
||||
|
}else if (formDTO.getOrgType().equals("grid")){ |
||||
|
disposeGridHouse(dto); |
||||
|
}else if (formDTO.getOrgType().equals("agency")){ |
||||
|
disposeAgencyHouse(dto); |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
public void disposeNeighborHoodHouse(ImportHouseGeneralDTO dto){ |
||||
|
neighborHoodName = null == neighborHoodName ? icBuildingDao.selectNeighborHoodNameById(formDTO.getOrgId()) : neighborHoodName; |
||||
|
//不是本小区的
|
||||
|
if (!dto.getNeighborHoodName().equals(neighborHoodName)){ |
||||
|
nums.add(num); |
||||
|
}else { |
||||
|
|
||||
|
} |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* @Description 左侧树点击网格时调用 |
||||
|
* @param dto |
||||
|
* @author zxc |
||||
|
* @date 2022/2/14 2:14 下午 |
||||
|
*/ |
||||
|
public void disposeGridHouse(ImportHouseGeneralDTO dto){ |
||||
|
gridName = null == gridName ? icBuildingDao.selectGridNameById(formDTO.getOrgId()) : gridName; |
||||
|
GridInfoCache gridInfo = CustomerOrgRedis.getGridInfo(formDTO.getOrgId()); |
||||
|
if (null == gridInfo){ |
||||
|
throw new EpmetException("查询网格失败..."); |
||||
|
} |
||||
|
//排除不是本网格的 gridName不一样排除，gridName一样但是agencyName不一样也得排除
|
||||
|
if (!dto.getGridName().equals(gridName) || (!dto.getAgencyName().equals(gridInfo.getAgencyName()) && dto.getGridName().equals(gridName))){ |
||||
|
nums.add(num); |
||||
|
}else { |
||||
|
//
|
||||
|
dto.setGridId(formDTO.getOrgId()); |
||||
|
dto.setAgencyId(gridInfo.getPid()); |
||||
|
fillData(dto); |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* @Description 左侧树点击组织时调用 |
||||
|
* @param dto |
||||
|
* @author zxc |
||||
|
* @date 2022/2/14 1:35 下午 |
||||
|
*/ |
||||
|
public void disposeAgencyHouse(ImportHouseGeneralDTO dto){ |
||||
|
agencyName = null == agencyName ? icBuildingDao.selectAgencyNameById(formDTO.getOrgId()) : agencyName; |
||||
|
//排除不是本组织的
|
||||
|
if (!dto.getAgencyName().equals(agencyName)){ |
||||
|
nums.add(num); |
||||
|
}else { |
||||
|
// 根据组织查询出所有网格，甩出不是本组织下的网格
|
||||
|
gridInfos = null == gridInfos ? getGridInfos(formDTO.getOrgId()) : gridInfos; |
||||
|
if (null == gridInfos){ |
||||
|
// 组织下确实不存在网格
|
||||
|
nums.add(num); |
||||
|
return; |
||||
|
} |
||||
|
// 根据网格名对比，没有找到的就把行号加入到未执行成功队列中
|
||||
|
Object cacheGridName = icHouseRedis.getTemporaryCacheGrid(formDTO.getCustomerId(), formDTO.getUserId(), dto.getGridName()); |
||||
|
if (null == cacheGridName){ |
||||
|
nums.add(num); |
||||
|
return; |
||||
|
} |
||||
|
dto.setGridId(cacheGridName.toString()); |
||||
|
dto.setAgencyId(formDTO.getOrgId()); |
||||
|
fillData(dto); |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
public void fillData(ImportHouseGeneralDTO dto){ |
||||
|
neighborHoodInfos = null == neighborHoodInfos ? getNeighborHoodInfos(Arrays.asList(formDTO.getOrgId())) : neighborHoodInfos; |
||||
|
Object cacheNeighBorHood = icHouseRedis.getTemporaryCacheNeighBorHood(formDTO.getCustomerId(), formDTO.getUserId(), formDTO.getOrgId() + "_" + dto.getNeighborHoodName()); |
||||
|
// 赋值小区ID
|
||||
|
dto.setNeighborHoodId(null == cacheNeighBorHood ? "" : cacheNeighBorHood.toString()); |
||||
|
if (StringUtils.isNotBlank(dto.getNeighborHoodId())){ |
||||
|
//小区ID不为空赋值楼栋ID
|
||||
|
buildingInfos = null == buildingInfos ? getBuildingInfos(dto.getNeighborHoodId()) : buildingInfos; |
||||
|
Object cacheBuilding = icHouseRedis.getTemporaryCacheBuilding(formDTO.getCustomerId(), formDTO.getUserId(), dto.getNeighborHoodId() + "_" + dto.getBuildingName()); |
||||
|
dto.setBuildingId(null == cacheBuilding ? "" : cacheBuilding.toString()); |
||||
|
if (StringUtils.isNotBlank(dto.getBuildingId())){ |
||||
|
// 楼栋ID不为空赋值单元ID
|
||||
|
buildingUnitInfos = null == buildingUnitInfos ? getBuildingUnitInfos(dto.getBuildingId()) : buildingUnitInfos; |
||||
|
Object cacheBuildingUnit = icHouseRedis.getTemporaryCacheBuildingUnit(formDTO.getCustomerId(), formDTO.getUserId(), dto.getBuildingId() + "_" + dto.getBuildingUnit()); |
||||
|
dto.setBuildingUnitId(null == cacheBuildingUnit ? "" : cacheBuildingUnit.toString()); |
||||
|
if (StringUtils.isNotBlank(dto.getBuildingUnitId())){ |
||||
|
// 所有ID补充完毕，不需调用补用方法
|
||||
|
needInsertList.add(dto); |
||||
|
}else { |
||||
|
needDisposeList.add(dto); |
||||
|
} |
||||
|
}else { |
||||
|
needDisposeList.add(dto); |
||||
|
} |
||||
|
}else { |
||||
|
needDisposeList.add(dto); |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* @Description 获取网格信息 |
||||
|
* @param orgId |
||||
|
* @author zxc |
||||
|
* @date 2022/2/14 9:57 上午 |
||||
|
*/ |
||||
|
public Map<String,Object> getGridInfos(String orgId){ |
||||
|
gridInfoDTOs = icBuildingDao.selectAllGridByOrgId(orgId); |
||||
|
gridInfos = gridInfoDTOs.stream().collect(Collectors.toMap(n -> n.getGridName(), n -> n.getGridId())); |
||||
|
icHouseRedis.setTemporaryCacheGrid(formDTO.getCustomerId(), gridInfos, formDTO.getUserId()); |
||||
|
return gridInfos; |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* @Description 获取网格下的小区 |
||||
|
* @param gridIds |
||||
|
* @author zxc |
||||
|
* @date 2022/2/14 10:16 上午 |
||||
|
*/ |
||||
|
public Map<String,Object> getNeighborHoodInfos(List<String> gridIds){ |
||||
|
neighborHoodInfoDTOs = icBuildingDao.selectAllNeighborHoodByGridIds(gridIds); |
||||
|
neighborHoodInfos = neighborHoodInfoDTOs.stream().collect(Collectors.toMap(n -> n.getGridId() + "_" + n.getNeighborHoodName(), n -> n.getNeighborHoodId())); |
||||
|
icHouseRedis.setTemporaryCacheNeighBorHood(formDTO.getCustomerId(), neighborHoodInfos, formDTO.getUserId()); |
||||
|
return neighborHoodInfos; |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* @Description 获取小区下的楼栋 |
||||
|
* @param neighborHoodId |
||||
|
* @author zxc |
||||
|
* @date 2022/2/14 1:32 下午 |
||||
|
*/ |
||||
|
public Map<String,Object> getBuildingInfos(String neighborHoodId){ |
||||
|
buildingInfoDTOs = icBuildingDao.selectAllBuildingByNeighborHoodId(neighborHoodId); |
||||
|
buildingInfos = buildingInfoDTOs.stream().collect(Collectors.toMap(n -> n.getNeighborHoodId() + "_" + n.getBuildingName(), n -> n.getBuildingId())); |
||||
|
icHouseRedis.setTemporaryCacheBuilding(formDTO.getCustomerId(), buildingInfos, formDTO.getUserId()); |
||||
|
return buildingInfos; |
||||
|
} |
||||
|
|
||||
|
/** |
||||
|
* @Description 获取楼栋下的单元 |
||||
|
* @param buildingId |
||||
|
* @author zxc |
||||
|
* @date 2022/2/14 2:04 下午 |
||||
|
*/ |
||||
|
public Map<String,Object> getBuildingUnitInfos(String buildingId){ |
||||
|
buildingUnitInfoDTOs = icBuildingDao.selectAllBuildingUnitByBuildingId(buildingId); |
||||
|
buildingUnitInfos = buildingInfoDTOs.stream().collect(Collectors.toMap(n -> n.getBuildingId() + "_" + n.getBuildingUnit(), n -> n.getBuildingUnitId())); |
||||
|
icHouseRedis.setTemporaryCacheBuildingUnit(formDTO.getCustomerId(), buildingUnitInfos, formDTO.getUserId()); |
||||
|
return buildingInfos; |
||||
|
} |
||||
|
|
||||
|
@Override |
||||
|
public void doAfterAllAnalysed(AnalysisContext context) { |
||||
|
|
||||
|
// 删除缓存
|
||||
|
icHouseRedis.delTemporaryCacheGrids(formDTO.getCustomerId(), formDTO.getUserId()); |
||||
|
icHouseRedis.delTemporaryCacheNeighBorHood(formDTO.getCustomerId(), formDTO.getUserId()); |
||||
|
icHouseRedis.delTemporaryCacheBuilding(formDTO.getCustomerId(), formDTO.getUserId()); |
||||
|
icHouseRedis.delTemporaryCacheBuildingUnit(formDTO.getCustomerId(), formDTO.getUserId()); |
||||
|
icHouseRedis.delTemporaryCacheHouses(formDTO.getCustomerId(), formDTO.getUserId()); |
||||
|
} |
||||
|
|
||||
|
} |
||||
Loading…
Reference in new issue