管理员过滤文章

lin

2024-04-16 2b1a74f4faa5a00a294bdc6a6d956c2e009cf467

 src/main/java/org/springblade/modules/house/service/impl/HouseServiceImpl.java

@@ -16,7 +16,9 @@
 */
package org.springblade.modules.house.service.impl;

import cn.hutool.core.util.IdcardUtil;
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;
@@ -30,6 +32,8 @@
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.doorplateAddress.entity.DoorplateAddressEntity;
import org.springblade.modules.doorplateAddress.service.IDoorplateAddressService;
import org.springblade.modules.grid.entity.GridEntity;
import org.springblade.modules.grid.entity.GridRangeEntity;
import org.springblade.modules.grid.service.IGridRangeService;
@@ -49,6 +53,8 @@
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;
@@ -214,7 +220,7 @@
      if (null != houseParam.getRoleName() && !houseParam.getRoleName().equals("")) {
         if (houseParam.getRoleName().equals("网格员")) {
            // 查询对应的房屋地址code
            stringList = gridService.getAddressCodeListByUserId(AuthUtil.getUserId());
            stringList = gridService.getAddressCodeListByUserId(AuthUtil.getUserId(),null);
         }
      }
      return stringList;
@@ -247,6 +253,7 @@
    */
   @Transactional(rollbackFor = Exception.class)
   public void saveHouseData(HouseAndHoldExcel houseAndHoldExcel) {
      IDoorplateAddressService doorplateAddressService = SpringUtils.getBean(IDoorplateAddressService.class);
      // 查询库中是否已存在
      QueryWrapper<HouseEntity> wrapper = new QueryWrapper<>();
      wrapper.eq("house_code", houseAndHoldExcel.getHouseCode())
@@ -256,9 +263,29 @@
      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.getHouseName())) {
            // 查询地址总表对应的数据
            QueryWrapper<DoorplateAddressEntity> queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("address_code",houseAndHoldExcel.getHouseCode());
            DoorplateAddressEntity addressEntity = doorplateAddressService.getOne(queryWrapper);
            if (null!=addressEntity){
               houseEntity.setHouseName(addressEntity.getAddressName());
               houseEntity.setAddress(addressEntity.getAddressName());
               houseEntity.setDistrictCode(addressEntity.getAoiCode());
               houseEntity.setDistrictName(addressEntity.getAoiName());
               houseEntity.setLng(addressEntity.getX());
               houseEntity.setLat(addressEntity.getY());
            }
         }else {
            houseEntity.setHouseName(houseAndHoldExcel.getHouseName());
            houseEntity.setAddress(houseAndHoldExcel.getHouseName());
         }
         if (!Strings.isBlank(houseAndHoldExcel.getDistrictName())) {
            houseEntity.setDistrictName(houseAndHoldExcel.getDistrictName());
         }
         if (!Strings.isBlank(houseAndHoldExcel.getUnit())) {
            houseEntity.setUnit(houseAndHoldExcel.getUnit());
         }
         if (!Strings.isBlank(houseAndHoldExcel.getFloor())) {
            houseEntity.setFloor(houseAndHoldExcel.getFloor());
         }
@@ -285,8 +312,46 @@
            houseEntity.setHouseCode(IdUtils.getIdBy36());
            houseEntity.setSource(2);
         }
         // 网格处理
         importGridHandle(houseAndHoldExcel,houseEntity);
         // 新增
         save(houseEntity);
      }else {
         // 更新
         if (Strings.isBlank(houseAndHoldExcel.getHouseName())) {
            // 查询地址总表对应的数据
            QueryWrapper<DoorplateAddressEntity> queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("address_code",houseAndHoldExcel.getHouseCode());
            DoorplateAddressEntity addressEntity = doorplateAddressService.getOne(queryWrapper);
            if (null!=addressEntity){
               one.setHouseName(addressEntity.getAddressName());
               one.setAddress(addressEntity.getAddressName());
               one.setDistrictCode(addressEntity.getAoiCode());
               one.setDistrictName(addressEntity.getAoiName());
               one.setLng(addressEntity.getX());
               one.setLat(addressEntity.getY());
            }
         }else {
            one.setHouseName(houseAndHoldExcel.getHouseName());
            one.setAddress(houseAndHoldExcel.getHouseName());
         }
         if (!Strings.isBlank(houseAndHoldExcel.getDistrictName())) {
            one.setDistrictName(houseAndHoldExcel.getDistrictName());
         }
         if (!Strings.isBlank(houseAndHoldExcel.getUnit())) {
            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);
      }
   }

@@ -301,7 +366,7 @@
      QueryWrapper<HouseholdEntity> wrapper = new QueryWrapper<>();
      wrapper.eq("house_code", houseAndHoldExcel.getHouseCode())
         .eq("is_deleted", 0)
         .eq("id_card", houseAndHoldExcel.getIdCard())
         .eq("phone_number", houseAndHoldExcel.getPhoneNumber())
         .eq("name", houseAndHoldExcel.getName());
      HouseholdEntity one = householdService.getOne(wrapper);
      // 不存在则插入，存在则不操作
@@ -332,9 +397,13 @@
         }
         // 居民身份证
         if (!Strings.isBlank(houseAndHoldExcel.getIdCard())) {
            // 身份证类型为居民身份证
            householdEntity.setCardType(111);
            householdEntity.setIdCard(houseAndHoldExcel.getIdCard());
            if (IdcardUtil.isValidCard(houseAndHoldExcel.getIdCard())) {
               // 身份证类型为居民身份证
               householdEntity.setCardType(111);
               householdEntity.setIdCard(houseAndHoldExcel.getIdCard());
            }else {
               householdEntity.setIdCard(houseAndHoldExcel.getIdCard());
            }
         }
         // 党员
         if (!Strings.isBlank(houseAndHoldExcel.getPartyEmber())) {
@@ -420,27 +489,7 @@
         // 新增
         boolean save = householdService.save(householdEntity);
         if (save) {
            String labelId = houseAndHoldExcel.getLabelId();
            if (StringUtils.isBlank(labelId)) {
               return;
            }
            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.<LabelEntity>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);
               }
            }
            householdLabelHandle(houseAndHoldExcel, householdEntity);
         }
      } else {
         // 更新
@@ -469,9 +518,13 @@
         }
         // 居民身份证
         if (!Strings.isBlank(houseAndHoldExcel.getIdCard())) {
            // 身份证类型为居民身份证
            one.setCardType(111);
            one.setIdCard(houseAndHoldExcel.getIdCard());
            if (IdcardUtil.isValidCard(houseAndHoldExcel.getIdCard())) {
               // 身份证类型为居民身份证
               one.setCardType(111);
               one.setIdCard(houseAndHoldExcel.getIdCard());
            }else {
               one.setIdCard(houseAndHoldExcel.getIdCard());
            }
         }
         // 党员
         if (!Strings.isBlank(houseAndHoldExcel.getPartyEmber())) {
@@ -550,27 +603,116 @@
         // 新增
         boolean update = householdService.updateById(one);
         if (update) {
            String labelId = houseAndHoldExcel.getLabelId();
            if (StringUtils.isBlank(labelId)) {
               return;
            }
            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.<LabelEntity>lambdaQuery().eq(LabelEntity::getLabelName, s));
               if (one1 != null) {
            // 住户标签处理
            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<GridRangeEntity> 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.<LabelEntity>lambdaQuery().eq(LabelEntity::getLabelName, s));
            if (one1 != null) {
               // 判断是否已存在关联关系，没有则新增
               QueryWrapper<UserHouseLabelEntity> wrapper = new QueryWrapper<>();
               wrapper.eq("label_id",one1.getId())
                  .eq("house_code",householdEntity.getHouseCode())
                  .eq("household_id",householdEntity.getId());
               UserHouseLabelEntity houseLabelEntity = bean.getOne(wrapper);
               if (null==houseLabelEntity) {
                  UserHouseLabelEntity userHouseLabelEntity = new UserHouseLabelEntity();
                  userHouseLabelEntity.setLabelId(BigDecimal.valueOf(one1.getId()).longValue());
                  userHouseLabelEntity.setHouseholdId(one.getId());
                  userHouseLabelEntity.setLableType(1);
                  userHouseLabelEntity.setLabelName(s);
                  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<User> 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);
         }
      }
   }
@@ -628,13 +770,13 @@
    *
    * @param householdEntity
    */
   @Transactional(rollbackFor = Exception.class)
   public void saveOrUpdateUser(HouseholdEntity householdEntity) {
      if (null != householdEntity.getPhoneNumber() && !householdEntity.getPhoneNumber().equals("")) {
         //根据手机号查询库里的数据
         User userParams = new User();
         userParams.setPhone(householdEntity.getPhoneNumber());
         User user = userService.getOne(Condition.getQueryWrapper(userParams));
         if (null != user) {
         List<User> list = userService.getUserListByPhoneOrAccount(householdEntity.getPhoneNumber());
         if (list.size()>0) {
            User user = list.get(0);
            //如果用户存在，则该用户id绑定住户
            householdEntity.setAssociatedUserId(user.getId());
            // 判断用户是否包含了居民角色,不包含则需更新
@@ -704,18 +846,19 @@

   @Override
   public List<Map<String, Object>> labelStatistics(HouseVO house) {
      List<String> regionChildCodesList = SysCache.getRegionChildCodesByDeptId(AuthUtil.getDeptId());
      Integer isAdministrator = AuthUtil.isAdministrator() == true ? 1 : 2;
      return baseMapper.labelStatistics(house, regionChildCodesList, isAdministrator);
      CommonParamSet commonParamSet = new CommonParamSet<>().invoke(HouseVO.class, house);
      return baseMapper.labelStatistics(house, commonParamSet.getRegionChildCodesList(), commonParamSet.getIsAdministrator());
   }

   @Override
   public List<Map<String, Object>> labelCommunityStatistics(HouseVO house) {
      List<String> regionChildCodesList = SysCache.getRegionChildCodesByDeptId(AuthUtil.getDeptId());
      Integer isAdministrator = AuthUtil.isAdministrator() == true ? 1 : 2;
      List<Map<String, Object>> list = baseMapper.labelCommunityStatistics(house, regionChildCodesList);
      CommonParamSet commonParamSet = new CommonParamSet<>().invoke(HouseVO.class, house);
      List<Map<String, Object>> list = baseMapper.labelCommunityStatistics(house, commonParamSet.getRegionChildCodesList());
      for (Map<String, Object> map : list) {
         List<LabelVO> code = baseMapper.getlabelCount(house, regionChildCodesList, isAdministrator, map.get("code").toString());
         List<LabelVO> code = baseMapper.getlabelCount(house,
            commonParamSet.getRegionChildCodesList(),
            commonParamSet.getIsAdministrator(),
            map.get("code").toString());
         map.put("child",code);
      }
      return list;
@@ -781,4 +924,34 @@
      // 返回
      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<HouseVO> getAllList(int i, int size) {
      return baseMapper.getAllList(i,size);
   }
}