/* * Copyright (c) 2018-2028, Chill Zhuang All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions are met: * * Redistributions of source code must retain the above copyright notice, * this list of conditions and the following disclaimer. * Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * Neither the name of the dreamlu.net developer nor the names of its * contributors may be used to endorse or promote products derived from * this software without specific prior written permission. * Author: Chill 庄骞 (smallchill@163.com) */ package org.springblade.modules.house.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import org.apache.commons.lang3.StringUtils; import org.apache.logging.log4j.util.Strings; import org.springblade.common.cache.SysCache; import org.springblade.common.param.CommonParamSet; import org.springblade.common.utils.IdUtils; import org.springblade.common.utils.NodeTreeUtil; import org.springblade.common.utils.SpringUtils; import org.springblade.core.mp.support.Condition; import org.springblade.core.secure.utils.AuthUtil; import org.springblade.core.tool.utils.BeanUtil; import org.springblade.modules.grid.entity.GridEntity; import org.springblade.modules.grid.entity.GridRangeEntity; import org.springblade.modules.grid.service.IGridRangeService; import org.springblade.modules.grid.service.IGridService; import org.springblade.modules.house.entity.HouseEntity; import org.springblade.modules.house.entity.HouseholdEntity; import org.springblade.modules.house.entity.UserHouseLabelEntity; import org.springblade.modules.house.excel.HouseAndHoldExcel; import org.springblade.modules.house.excel.HouseExcel; import org.springblade.modules.house.mapper.HouseMapper; import org.springblade.modules.house.service.IHouseService; import org.springblade.modules.house.service.IHouseholdService; import org.springblade.modules.house.service.IUserHouseLabelService; import org.springblade.modules.house.vo.HouseParam; import org.springblade.modules.house.vo.HouseTree; import org.springblade.modules.house.vo.HouseVO; import org.springblade.modules.label.entity.LabelEntity; import org.springblade.modules.label.service.ILabelService; import org.springblade.modules.label.vo.LabelVO; import org.springblade.modules.place.excel.PlaceExcel; import org.springblade.modules.place.vo.PlaceVO; import org.springblade.modules.police.entity.PoliceAffairsGridEntity; import org.springblade.modules.police.service.IPoliceAffairsGridService; import org.springblade.modules.system.entity.Region; import org.springblade.modules.system.entity.User; import org.springblade.modules.system.service.IRegionService; import org.springblade.modules.system.service.IUserService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import java.math.BigDecimal; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.*; /** * 房屋 服务实现类 * * @author BladeX * @since 2023-10-28 */ @Service public class HouseServiceImpl extends ServiceImpl implements IHouseService { @Autowired private IGridService gridService; @Autowired private IHouseholdService householdService; @Autowired private IGridRangeService gridRangeService; @Autowired private IUserService userService; @Autowired private IRegionService regionService; @Override public IPage selectHousePage(IPage page, HouseVO house) { // List regionChildCodesList = SysCache.getRegionChildCodesByDeptId(AuthUtil.getDeptId()); // Integer isAdministrator = AuthUtil.isAdministrator() == true ? 1 : 2; CommonParamSet commonParamSet = new CommonParamSet().invoke(HouseVO.class,house); List houseVOS = baseMapper.selectHousePage(page, house, commonParamSet.getRegionChildCodesList(),commonParamSet.getGridCodeList(), commonParamSet.getIsAdministrator() ); return page.setRecords(houseVOS); } /** * 房屋自定义详情查询 * * @param house * @return */ @Override public HouseVO getHouseDetail(HouseVO house) { return baseMapper.getHouseDetail(house); } /** * 房屋自定义新增或修改 * * @param house * @return */ @Override public boolean saveOrUpdateHouse(HouseEntity house) { boolean flag = false; // 如果没有房屋编号，自己生成 if (!Strings.isBlank(house.getHouseCode())) { // 查询是否已存在房屋数据 QueryWrapper wrapper = new QueryWrapper<>(); wrapper.eq("house_code", house.getHouseCode()); HouseEntity one = getOne(wrapper); if (null != one) { house.setId(one.getId()); // 更新数据 return updateById(house); } } else { //自己生成编号 // 设置来源( 1：地址总表 2：国控采集) house.setSource(2); // 并生成36位的houseCode house.setHouseCode(IdUtils.getIdBy36()); } //插入数据 flag = save(house); // 设置网格绑定数据 gridBind(house); // 返回 return flag; } /** * 网格绑定 * * @param house */ public void gridBind(HouseEntity house) { if (null != house.getGridId()) { // 判断关联关系表是否存在 QueryWrapper wrapper = new QueryWrapper<>(); wrapper.eq("grid_id", house.getGridId()).eq("house_code", house.getHouseCode()); GridRangeEntity one = gridRangeService.getOne(wrapper); if (null == one) { // 新增 GridRangeEntity gridRangeEntity = new GridRangeEntity(); gridRangeEntity.setHouseCode(house.getHouseCode()); gridRangeEntity.setGridId(house.getGridId()); // 插入 gridRangeService.save(gridRangeEntity); } } } /** * 导入房屋数据 * * @param data * @param isCovered */ @Override public void importUserHouse(List data, Boolean isCovered) { data.forEach(houseExcel -> { HouseEntity HouseEntity = Objects.requireNonNull(BeanUtil.copy(houseExcel, HouseEntity.class)); this.save(HouseEntity); }); } @Override public List export(HouseVO household) { List houseExcels = baseMapper.export(household); return houseExcels; } /** * 查询房屋树 * * @param houseParam * @return */ @Override public List getHouseTree(HouseParam houseParam) { List houseCodeList = getHouseCodeList(houseParam); return NodeTreeUtil.getHouseTree(baseMapper.getHouseTree(houseParam, houseCodeList)); } /** * 根据角色获取地址编号集合 * * @param houseParam * @return */ private List getHouseCodeList(HouseParam houseParam) { List stringList = new ArrayList<>(); if (null != houseParam.getRoleName() && !houseParam.getRoleName().equals("")) { if (houseParam.getRoleName().equals("网格员")) { // 查询对应的房屋地址code stringList = gridService.getAddressCodeListByUserId(AuthUtil.getUserId(),null); } } return stringList; } /** * 人房数据导入 * * @param data * @param isCovered */ @Override @Transactional(rollbackFor = Exception.class) public void importHouseAndHold(List data, Boolean isCovered) { for (HouseAndHoldExcel houseAndHoldExcel : data) { // System.out.println(houseAndHoldExcel); System.out.println("houseAndHoldExcel = " + houseAndHoldExcel); // 保存房屋数据--一个一个插入，防止一个表格中存在多个地址编号相同的数据 saveHouseData(houseAndHoldExcel); // 保存住户数据（包含标签）--一个一个插入，防止一个表格中存在多个地址编号相同的数据 saveHouseholdData(houseAndHoldExcel); // 保存租户数据 } } /** * 保存房屋数据 * * @param houseAndHoldExcel */ @Transactional(rollbackFor = Exception.class) public void saveHouseData(HouseAndHoldExcel houseAndHoldExcel) { // 查询库中是否已存在 QueryWrapper wrapper = new QueryWrapper<>(); wrapper.eq("house_code", houseAndHoldExcel.getHouseCode()) .eq("is_deleted", 0); HouseEntity one = getOne(wrapper); // 不存在则插入，存在则不操作 if (null == one) { HouseEntity houseEntity = new HouseEntity(); houseEntity.setHouseCode(houseAndHoldExcel.getHouseCode()); houseEntity.setHouseName(houseAndHoldExcel.getHouseName()); houseEntity.setDistrictName(houseAndHoldExcel.getDistrictName()); houseEntity.setUnit(houseAndHoldExcel.getUnit()); if (!Strings.isBlank(houseAndHoldExcel.getFloor())) { houseEntity.setFloor(houseAndHoldExcel.getFloor()); } houseEntity.setRoom(houseAndHoldExcel.getRoom()); houseEntity.setBuilding(houseAndHoldExcel.getBuilding()); houseEntity.setArea(houseAndHoldExcel.getArea()); houseEntity.setPropertyPrice(houseAndHoldExcel.getPropertyPrice()); if (!Strings.isBlank(houseAndHoldExcel.getServiceDue())) { try { Date date = new SimpleDateFormat("yyyy-MM-dd").parse(houseAndHoldExcel.getServiceDue()); houseEntity.setServiceDue(date); } catch (ParseException e) { e.printStackTrace(); } } houseEntity.setRemark(houseAndHoldExcel.getRemark()); houseEntity.setCreateTime(new Date()); houseEntity.setCreateUser(AuthUtil.getUserId().toString()); houseEntity.setUpdateTime(new Date()); houseEntity.setUpdateUser(AuthUtil.getUserId().toString()); if (!Strings.isBlank(houseAndHoldExcel.getHouseCode())) { houseEntity.setSource(1); } else { houseEntity.setHouseCode(IdUtils.getIdBy36()); houseEntity.setSource(2); } // 网格处理 importGridHandle(houseAndHoldExcel,houseEntity); // 新增 save(houseEntity); }else { // 更新 one.setHouseName(houseAndHoldExcel.getHouseName()); one.setAddress(houseAndHoldExcel.getHouseName()); one.setDistrictName(houseAndHoldExcel.getDistrictName()); one.setUnit(houseAndHoldExcel.getUnit()); if (!Strings.isBlank(houseAndHoldExcel.getFloor())) { one.setFloor(houseAndHoldExcel.getFloor()); } one.setRoom(houseAndHoldExcel.getRoom()); one.setBuilding(houseAndHoldExcel.getBuilding()); one.setArea(houseAndHoldExcel.getArea()); one.setPropertyPrice(houseAndHoldExcel.getPropertyPrice()); // 网格处理 importGridHandle(houseAndHoldExcel,one); // 更新 updateById(one); } } /** * 保存住户数据 * * @param houseAndHoldExcel */ @Transactional(rollbackFor = Exception.class) public void saveHouseholdData(HouseAndHoldExcel houseAndHoldExcel) { // 查询库中是否已存在 QueryWrapper wrapper = new QueryWrapper<>(); wrapper.eq("house_code", houseAndHoldExcel.getHouseCode()) .eq("is_deleted", 0) .eq("phone_number", houseAndHoldExcel.getPhoneNumber()) .eq("name", houseAndHoldExcel.getName()); HouseholdEntity one = householdService.getOne(wrapper); // 不存在则插入，存在则不操作 if (null == one) { HouseholdEntity householdEntity = new HouseholdEntity(); householdEntity.setHouseCode(houseAndHoldExcel.getHouseCode()); householdEntity.setName(houseAndHoldExcel.getName()); householdEntity.setPhoneNumber(houseAndHoldExcel.getPhoneNumber()); // 与角色关系 if (!Strings.isBlank(houseAndHoldExcel.getRelationship())) { householdEntity.setRelationship(Integer.parseInt(houseAndHoldExcel.getRelationship())); // 如果是业主，则需要往用户表插入用户 if (householdEntity.getRelationship() == 1) { saveOrUpdateUser(householdEntity); } } /// 是否主要联系人 if (!Strings.isBlank(houseAndHoldExcel.getIsPrimaryContact())) { householdEntity.setIsPrimaryContact(Integer.parseInt(houseAndHoldExcel.getIsPrimaryContact())); } // 居住状态 if (!Strings.isBlank(houseAndHoldExcel.getResidentialStatus())) { householdEntity.setResidentialStatus(Integer.parseInt(houseAndHoldExcel.getResidentialStatus())); } // 性别 if (!Strings.isBlank(houseAndHoldExcel.getGender())) { householdEntity.setGender(Short.parseShort(houseAndHoldExcel.getGender())); } // 居民身份证 if (!Strings.isBlank(houseAndHoldExcel.getIdCard())) { // 身份证类型为居民身份证 householdEntity.setCardType(111); householdEntity.setIdCard(houseAndHoldExcel.getIdCard()); } // 党员 if (!Strings.isBlank(houseAndHoldExcel.getPartyEmber())) { householdEntity.setPartyEmber(Integer.parseInt(houseAndHoldExcel.getPartyEmber())); } // householdEntity.setHkmtPass(houseAndHoldExcel.getHkmtPass()); // householdEntity.setPassport(houseAndHoldExcel.getPassport()); // 民族 if (!Strings.isBlank(houseAndHoldExcel.getEthnicity())) { householdEntity.setEthnicity(Integer.parseInt(houseAndHoldExcel.getEthnicity())); } // 学历 if (!Strings.isBlank(houseAndHoldExcel.getEducation())) { householdEntity.setEducation(Integer.parseInt(houseAndHoldExcel.getEducation())); } // 户籍类型 if (!Strings.isBlank(houseAndHoldExcel.getResidentType())) { householdEntity.setResidentType(Integer.parseInt(houseAndHoldExcel.getResidentType().trim())); } // 户籍地区县 if (!Strings.isBlank(houseAndHoldExcel.getResidentAdcode())) { String adCode = shiftResidentResidentAdCode(houseAndHoldExcel.getResidentProvinceAdcode(), houseAndHoldExcel.getResidentCityAdcode(), houseAndHoldExcel.getResidentAdcode()); // 转换行政区code houseAndHoldExcel.setResidentAdcode(adCode); } householdEntity.setHukouRegistration(houseAndHoldExcel.getHukouRegistration()); // 籍贯地区县 if (!Strings.isBlank(houseAndHoldExcel.getNativePlaceAdcode())) { String adCode = shiftResidentResidentAdCode(null, null, houseAndHoldExcel.getNativePlaceAdcode()); // 转换行政区code houseAndHoldExcel.setNativePlaceAdcode(adCode); } // 健康状况 if (!Strings.isBlank(houseAndHoldExcel.getHealthStatus())) { householdEntity.setHealthStatus(Integer.parseInt(houseAndHoldExcel.getHealthStatus())); } householdEntity.setDiseaseName(houseAndHoldExcel.getDiseaseName()); householdEntity.setReligiousBelief(houseAndHoldExcel.getReligiousBelief()); // 工作状态 if (!Strings.isBlank(houseAndHoldExcel.getWorkStatus())) { householdEntity.setWorkStatus(Integer.parseInt(houseAndHoldExcel.getWorkStatus())); } householdEntity.setEmployer(houseAndHoldExcel.getEmployer()); householdEntity.setOccupation(houseAndHoldExcel.getOccupation()); householdEntity.setCmpyRegAddr(houseAndHoldExcel.getCmpyRegAddr()); // 外出 householdEntity.setGoOutReason(houseAndHoldExcel.getGoOutReason()); if (!Strings.isBlank(houseAndHoldExcel.getGoOutTime())) { try { Date date = new SimpleDateFormat("yyyy-MM-dd").parse(houseAndHoldExcel.getGoOutTime()); householdEntity.setGoOutTime(date); } catch (ParseException e) { e.printStackTrace(); } } householdEntity.setGoOutWhere(houseAndHoldExcel.getGoOutWhere()); householdEntity.setGoOutAddr(houseAndHoldExcel.getGoOutAddr()); // 婚姻状态 if (!Strings.isBlank(houseAndHoldExcel.getMaritalStatus())) { householdEntity.setMaritalStatus(Integer.parseInt(houseAndHoldExcel.getMaritalStatus())); } // 车牌号 householdEntity.setCardNumber(houseAndHoldExcel.getCardNumber()); // 其他联系方式 householdEntity.setOtherContact(houseAndHoldExcel.getOtherContact()); if (!Strings.isBlank(householdEntity.getHomeAdcode())) { // 暂时不处理，导入数据目前都有house_code String adCode = shiftResidentHomeAdcode(houseAndHoldExcel.getHomeAdcode()); // 转换行政区code houseAndHoldExcel.setHomeAdcode(adCode); } householdEntity.setCurrentAddress(houseAndHoldExcel.getCurrentAddress()); householdEntity.setDisabilityCert(houseAndHoldExcel.getDisabilityCert()); householdEntity.setRemark(houseAndHoldExcel.getRemarks()); householdEntity.setCreateTime(new Date()); householdEntity.setCreateUser(AuthUtil.getUserId()); householdEntity.setUpdateTime(new Date()); householdEntity.setUpdateUser(AuthUtil.getUserId()); // 新增 boolean save = householdService.save(householdEntity); if (save) { householdLabelHandle(houseAndHoldExcel, householdEntity); } } else { // 更新 one.setHouseCode(houseAndHoldExcel.getHouseCode()); one.setName(houseAndHoldExcel.getName()); one.setPhoneNumber(houseAndHoldExcel.getPhoneNumber()); // 与角色关系 if (!Strings.isBlank(houseAndHoldExcel.getRelationship())) { one.setRelationship(Integer.parseInt(houseAndHoldExcel.getRelationship())); // 如果是业主，则需要往用户表插入用户 if (one.getRelationship() == 1) { saveOrUpdateUser(one); } } /// 是否主要联系人 if (!Strings.isBlank(houseAndHoldExcel.getIsPrimaryContact())) { one.setIsPrimaryContact(Integer.parseInt(houseAndHoldExcel.getIsPrimaryContact())); } // 居住状态 if (!Strings.isBlank(houseAndHoldExcel.getResidentialStatus())) { one.setResidentialStatus(Integer.parseInt(houseAndHoldExcel.getResidentialStatus())); } // 性别 if (!Strings.isBlank(houseAndHoldExcel.getGender())) { one.setGender(Short.parseShort(houseAndHoldExcel.getGender())); } // 居民身份证 if (!Strings.isBlank(houseAndHoldExcel.getIdCard())) { // 身份证类型为居民身份证 one.setCardType(111); one.setIdCard(houseAndHoldExcel.getIdCard()); } // 党员 if (!Strings.isBlank(houseAndHoldExcel.getPartyEmber())) { one.setPartyEmber(Integer.parseInt(houseAndHoldExcel.getPartyEmber())); } // 民族 if (!Strings.isBlank(houseAndHoldExcel.getEthnicity())) { one.setEthnicity(Integer.parseInt(houseAndHoldExcel.getEthnicity())); } // 学历 if (!Strings.isBlank(houseAndHoldExcel.getEducation())) { one.setEducation(Integer.parseInt(houseAndHoldExcel.getEducation())); } // 户籍类型 if (!Strings.isBlank(houseAndHoldExcel.getResidentType())) { one.setResidentType(Integer.parseInt(houseAndHoldExcel.getResidentType().trim())); } // 户籍地区县 if (!Strings.isBlank(houseAndHoldExcel.getResidentAdcode())) { String adCode = shiftResidentResidentAdCode(houseAndHoldExcel.getResidentProvinceAdcode(), houseAndHoldExcel.getResidentCityAdcode(), houseAndHoldExcel.getResidentAdcode()); // 转换行政区code houseAndHoldExcel.setResidentAdcode(adCode); } one.setHukouRegistration(houseAndHoldExcel.getHukouRegistration()); // 籍贯地区县 if (!Strings.isBlank(houseAndHoldExcel.getNativePlaceAdcode())) { String adCode = shiftResidentResidentAdCode(null, null, houseAndHoldExcel.getNativePlaceAdcode()); // 转换行政区code houseAndHoldExcel.setNativePlaceAdcode(adCode); } // 健康状况 if (!Strings.isBlank(houseAndHoldExcel.getHealthStatus())) { one.setHealthStatus(Integer.parseInt(houseAndHoldExcel.getHealthStatus())); } one.setDiseaseName(houseAndHoldExcel.getDiseaseName()); one.setReligiousBelief(houseAndHoldExcel.getReligiousBelief()); // 工作状态 if (!Strings.isBlank(houseAndHoldExcel.getWorkStatus())) { one.setWorkStatus(Integer.parseInt(houseAndHoldExcel.getWorkStatus())); } one.setEmployer(houseAndHoldExcel.getEmployer()); one.setOccupation(houseAndHoldExcel.getOccupation()); one.setCmpyRegAddr(houseAndHoldExcel.getCmpyRegAddr()); one.setGoOutReason(houseAndHoldExcel.getGoOutReason()); if (!Strings.isBlank(houseAndHoldExcel.getGoOutTime())) { try { Date date = new SimpleDateFormat("yyyy-MM-dd").parse(houseAndHoldExcel.getGoOutTime()); one.setGoOutTime(date); } catch (ParseException e) { e.printStackTrace(); } } one.setGoOutWhere(houseAndHoldExcel.getGoOutWhere()); one.setGoOutAddr(houseAndHoldExcel.getGoOutAddr()); // 婚姻状态 if (!Strings.isBlank(houseAndHoldExcel.getMaritalStatus())) { one.setMaritalStatus(Integer.parseInt(houseAndHoldExcel.getMaritalStatus())); } one.setCardNumber(houseAndHoldExcel.getCardNumber()); one.setOtherContact(houseAndHoldExcel.getOtherContact()); if (!Strings.isBlank(one.getHomeAdcode())) { // 暂时不处理，导入数据目前都有house_code String adCode = shiftResidentHomeAdcode(houseAndHoldExcel.getHomeAdcode()); // 转换行政区code houseAndHoldExcel.setHomeAdcode(adCode); } one.setCurrentAddress(houseAndHoldExcel.getCurrentAddress()); one.setDisabilityCert(houseAndHoldExcel.getDisabilityCert()); one.setRemark(houseAndHoldExcel.getRemarks()); one.setUpdateTime(new Date()); one.setUpdateUser(AuthUtil.getUserId()); // 新增 boolean update = householdService.updateById(one); if (update) { // 住户标签处理 householdLabelHandle(houseAndHoldExcel,one); } } } /** * 导入是网格数据绑定处理 * @param houseAndHoldExcel * @param houseEntity */ public void importGridHandle(HouseAndHoldExcel houseAndHoldExcel, HouseEntity houseEntity) { if (!Strings.isBlank(houseAndHoldExcel.getCommunityName()) && !Strings.isBlank(houseAndHoldExcel.getGridName())){ // 查询对应的网格信息 GridEntity gridEntity = gridService.getGridInfoByParam(houseAndHoldExcel.getCommunityName(),houseAndHoldExcel.getGridName()); if (null!=gridEntity){ // 设置场所范围 houseEntity.setGridId(gridEntity.getId()); houseEntity.setGridCode(gridEntity.getGridCode()); // 更新网格范围绑定 GridRangeEntity gridRangeEntity = new GridRangeEntity(); gridRangeEntity.setGridId(gridEntity.getId()); gridRangeEntity.setGridCode(gridEntity.getGridCode()); gridRangeEntity.setHouseCode(houseEntity.getHouseCode()); UpdateWrapper updateWrapper = new UpdateWrapper<>(); updateWrapper.eq("house_code",houseEntity.getHouseCode()); gridRangeService.update(gridRangeEntity,updateWrapper); } } } /** * 住户标签处理 * @param houseAndHoldExcel * @param householdEntity */ public void householdLabelHandle(HouseAndHoldExcel houseAndHoldExcel, HouseholdEntity householdEntity) { String labelId = houseAndHoldExcel.getLabelId(); if (!StringUtils.isBlank(labelId)) { String[] split = labelId.split(","); IUserHouseLabelService bean = SpringUtils.getBean(IUserHouseLabelService.class); ILabelService bean1 = SpringUtils.getBean(ILabelService.class); for (String s : split) { LabelEntity one1 = bean1.getOne(Wrappers.lambdaQuery().eq(LabelEntity::getLabelName, s)); if (one1 != null) { UserHouseLabelEntity userHouseLabelEntity = new UserHouseLabelEntity(); userHouseLabelEntity.setLabelId(BigDecimal.valueOf(one1.getId()).longValue()); userHouseLabelEntity.setHouseholdId(householdEntity.getId()); // 设置默认的绿色 userHouseLabelEntity.setColor("green"); userHouseLabelEntity.setLableType(1); userHouseLabelEntity.setLabelName(s); userHouseLabelEntity.setHouseCode(houseAndHoldExcel.getHouseCode()); bean.save(userHouseLabelEntity); } } } } /** * 住户业主信息处理，将业主人员插入到用户表 * * @return */ public void userHandle(HouseholdEntity householdEntity) { if (!Strings.isBlank(householdEntity.getPhoneNumber())) { // 根据手机号查询对应账号和手机号的用户信息 List userList = userService.getUserListByPhoneOrAccount(householdEntity.getPhoneNumber()); if (userList.size() > 0) { User user = userList.get(0); householdEntity.setAssociatedUserId(user.getId()); // 更新 householdService.updateById(householdEntity); // 判断用户是否包含了居民角色,不包含则需更新 if (!user.getRoleId().contains("1717429059648606209")) { user.setRoleId(user.getRoleId() + ",1717429059648606209"); //更新 userService.updateById(user); } } else { // 插入用户信息 //如果用户不存在，则新增一个用户 User newUser = new User(); newUser.setAccount(householdEntity.getPhoneNumber()); newUser.setPhone(householdEntity.getPhoneNumber()); newUser.setName(householdEntity.getName()); newUser.setRealName(householdEntity.getName()); // 社区群众部门 newUser.setDeptId("1727979636479037441"); // 目前暂定居民角色， newUser.setRoleId("1717429059648606209"); //默认密码为 123456 newUser.setPassword("123456"); // 用户新增 boolean submit = userService.submit(newUser); // 更新绑定用户信息 householdEntity.setAssociatedUserId(newUser.getId()); // 更新 householdService.updateById(householdEntity); } } } /** * 现居住地街道转换 * * @param homeAdcode * @return */ public String shiftResidentHomeAdcode(String homeAdcode) { // 只根据区县名称查询 QueryWrapper wrapper = new QueryWrapper<>(); wrapper.eq("town_name", homeAdcode); List list = regionService.list(wrapper); if (list.size() == 1) { return list.get(0).getTownCode(); } return ""; } /** * 根据名称转成code * * @param residentProvinceAdcode 省名称 * @param residentCityAdcode 市名称 * @param residentAdcode 区县名称 */ public String shiftResidentResidentAdCode(String residentProvinceAdcode, String residentCityAdcode, String residentAdcode) { if (!Strings.isBlank(residentProvinceAdcode) && !Strings.isBlank(residentCityAdcode)) { // 根据省市县三级查询对应的区县code QueryWrapper wrapper = new QueryWrapper<>(); wrapper.eq("province_name", residentProvinceAdcode) .eq("city_name", residentCityAdcode) .eq("district_name", residentAdcode); List list = regionService.list(wrapper); if (list.size() > 0) { return list.get(0).getDistrictCode(); } } else { // 只根据区县名称查询 QueryWrapper wrapper = new QueryWrapper<>(); wrapper.eq("district_name", residentAdcode); List list = regionService.list(wrapper); if (list.size() == 1) { return list.get(0).getDistrictCode(); } } return ""; } /** * 保存或更新用户（业主） * * @param householdEntity */ @Transactional(rollbackFor = Exception.class) public void saveOrUpdateUser(HouseholdEntity householdEntity) { if (null != householdEntity.getPhoneNumber() && !householdEntity.getPhoneNumber().equals("")) { //根据手机号查询库里的数据 List list = userService.getUserListByPhoneOrAccount(householdEntity.getPhoneNumber()); if (list.size()>0) { User user = list.get(0); //如果用户存在，则该用户id绑定住户 householdEntity.setAssociatedUserId(user.getId()); // 判断用户是否包含了居民角色,不包含则需更新 if (!user.getRoleId().contains("1717429059648606209")) { user.setRoleId(user.getRoleId() + ",1717429059648606209"); //更新 userService.updateById(user); } } else { User newUser = new User(); //如果用户不存在，则新增一个用户 newUser.setAccount(householdEntity.getPhoneNumber()); newUser.setPhone(householdEntity.getPhoneNumber()); newUser.setName(householdEntity.getName()); newUser.setRealName(householdEntity.getName()); // 社区群众部门 newUser.setDeptId("1727979636479037441"); // 目前暂定居民角色， newUser.setRoleId("1717429059648606209"); //默认密码为 123456 newUser.setPassword("123456"); // 设置机构 // 用户新增 boolean submit = userService.submit(newUser); //绑定id householdEntity.setAssociatedUserId(newUser.getId()); } } } @Override public Map getHouseStatistics(String code, String roleType, String aoiCode, String buildingCode, String unitCode) { Map objectObjectHashMap = new HashMap<>(); if (roleType.equals("2")) { // result1 查询楼栋数 result2 查询房屋套数 result3 查询住户数 result4 查询单元数 Integer result1 = baseMapper.getHouseStatisticsOne(code, null, aoiCode, buildingCode, unitCode, roleType); Integer result2 = baseMapper.getHouseStatisticsTwo(code, null, aoiCode, buildingCode, unitCode, roleType); Integer result3 = baseMapper.getHouseStatisticsThree(code, null, aoiCode, buildingCode, unitCode, roleType); Integer result4 = baseMapper.getHouseStatisticsFour(code, null, aoiCode, buildingCode, unitCode, roleType); objectObjectHashMap.put("result1", result1); objectObjectHashMap.put("result2", result2); objectObjectHashMap.put("result3", result3); objectObjectHashMap.put("result4", result4); } else { Integer result1 = baseMapper.getHouseStatisticsOne(code, AuthUtil.getUserId(), aoiCode, buildingCode, unitCode, roleType); Integer result2 = baseMapper.getHouseStatisticsTwo(code, AuthUtil.getUserId(), aoiCode, buildingCode, unitCode, roleType); Integer result3 = baseMapper.getHouseStatisticsThree(code, AuthUtil.getUserId(), aoiCode, buildingCode, unitCode, roleType); Integer result4 = baseMapper.getHouseStatisticsFour(code, AuthUtil.getUserId(), aoiCode, buildingCode, unitCode, roleType); objectObjectHashMap.put("result1", result1); objectObjectHashMap.put("result2", result2); objectObjectHashMap.put("result3", result3); objectObjectHashMap.put("result4", result4); } return objectObjectHashMap; } @Override public List getHouseBuilding(String districtCode) { return baseMapper.getHouseBuilding(districtCode); } @Override public List getHouseUnit(String districtCode, String building) { return baseMapper.getHouseUnit(districtCode, building); } @Override public List> labelStatistics(HouseVO house) { CommonParamSet commonParamSet = new CommonParamSet<>().invoke(HouseVO.class, house); return baseMapper.labelStatistics(house, commonParamSet.getRegionChildCodesList(), commonParamSet.getIsAdministrator()); } @Override public List> labelCommunityStatistics(HouseVO house) { CommonParamSet commonParamSet = new CommonParamSet<>().invoke(HouseVO.class, house); List> list = baseMapper.labelCommunityStatistics(house, commonParamSet.getRegionChildCodesList()); for (Map map : list) { List code = baseMapper.getlabelCount(house, commonParamSet.getRegionChildCodesList(), commonParamSet.getIsAdministrator(), map.get("code").toString()); map.put("child",code); } return list; } /** * 房屋网格处理 * @return */ @Override public Object houseGridHandle() { // 查询未处理的数据 List houseEntityList = baseMapper.getNotBindGridOrJwGridList(1); // 遍历 for (HouseEntity houseEntity : houseEntityList) { String point = "'POINT(" + houseEntity.getLng() + " " + houseEntity.getLat() + ")'"; List gridEntityList = SpringUtils.getBean(IGridService.class).spatialAnalysis(point); if (gridEntityList.size()>0){ houseEntity.setGridCode(gridEntityList.get(0).getGridCode()); houseEntity.setGridId(gridEntityList.get(0).getId()); // 更新 updateById(houseEntity); } } return null; } /** * 房屋警格处理 * @return */ @Override public Object houseJwGridHandle() { // 查询未处理的数据 List houseEntityList = baseMapper.getNotBindGridOrJwGridList(2); // 遍历 for (HouseEntity houseEntity : houseEntityList) { String point = "'POINT(" + houseEntity.getLng() + " " + houseEntity.getLat() + ")'"; List policeAffairsGridEntityList = SpringUtils.getBean(IPoliceAffairsGridService.class).spatialAnalysis(point); if (policeAffairsGridEntityList.size()>0){ houseEntity.setJwGridCode(policeAffairsGridEntityList.get(0).getJwGridCode()); // 更新 updateById(houseEntity); } } return null; } /** * 房屋画像统计-按房屋标签统计 * @param house * @return */ @Override public List> getHouseLabelStatistic(HouseVO house) { CommonParamSet commonParamSet = new CommonParamSet<>().invoke(HouseVO.class, house); // 按房屋标签统计 List> list = baseMapper.getHouseLabelStatistic(house, commonParamSet.getIsAdministrator(), commonParamSet.getRegionChildCodesList(), commonParamSet.getGridCodeList()); // 返回 return list; } /** * 查询对应的社区编号 * @param id * @return */ @Override public String getCommunityCode(Long id) { return baseMapper.getCommunityCode(id); } /** * 查询所有房屋总数 * @return */ @Override public int getAllListTotal() { return baseMapper.getAllListTotal(); } /** * 查询所有的房屋 * @param i * @param size * @return */ @Override public List getAllList(int i, int size) { return baseMapper.getAllList(i,size); } }