huanghongfa
2021-01-15 ada9d2e3f734582a0d9ae8c00a936d8c8ed669d7
springcloud_k8s_panzhihuazhihuishequ/service_community/src/main/java/com/panzhihua/service_community/service/impl/ComMngStructHouseServiceImpl.java
@@ -83,7 +83,8 @@
     * 批量添加地址功能提取出一个公共方法
     * @param batchhouseVO 批量添加小区、同级(楼栋、单元、楼层、房间)
     */
    private void batchSaveHouse(BatchhouseVO batchhouseVO) {
    @Transactional(rollbackFor = Exception.class)
    void batchSaveHouse(BatchhouseVO batchhouseVO) {
        String areaCode = batchhouseVO.getAreaCode();
        ComMngStructHouseDO comMngStructHouseDO = comMngStructHouseDAO.selectOne(new QueryWrapper<ComMngStructHouseDO>().lambda().eq(ComMngStructHouseDO::getHouseCode, areaCode));
        String areaName = comMngStructHouseDO.getHouseName();//小区地址
@@ -118,6 +119,7 @@
                comMngStructHouseDO1.setType(2);
                comMngStructHouseDOList.add(comMngStructHouseDO1);
            }
            for (int m = unitBegin; m <= unitEnd; m++) {//单元
                ComMngStructHouseDO comMngStructHouseDO2 = new ComMngStructHouseDO();
                if (unitBegin==unitEnd&&null!=type&&type==4) {
@@ -130,6 +132,7 @@
                    comMngStructHouseDOList.add(comMngStructHouseDO2);
                }
                int num = 0;//门牌累加时使用
                for (int k = floorBegin; k <= floorEnd; k++) {//楼层
                    ComMngStructHouseDO comMngStructHouseDO3 = new ComMngStructHouseDO();
                    if (floorBegin==floorEnd&&null!=type&&type==5) {
@@ -137,10 +140,11 @@
                    } else {
                        comMngStructHouseDO3.setType(4);
                        comMngStructHouseDO3.setParentCode(comMngStructHouseDO2.getHouseCode());
                        comMngStructHouseDO3.setHouseName(comMngStructHouseDO2.getHouseName() + "层");
                        comMngStructHouseDO3.setHouseName(comMngStructHouseDO2.getHouseName() +k+ "层");
                        comMngStructHouseDO3.setHouseCode(comMngStructHouseDO2.getHouseCode() + (floorCode + k));
                        comMngStructHouseDOList.add(comMngStructHouseDO3);
                    }
                    for (int h = doorBegin; h <= doorEnd; h++) {//门牌
                        num++;
                        ComMngStructHouseDO comMngStructHouseDO4 = new ComMngStructHouseDO();
@@ -215,12 +219,17 @@
                        comMngStructHouseDO4.setParentCode(comMngStructHouseDO3.getHouseCode());
                        comMngStructHouseDOList.add(comMngStructHouseDO4);
                    }
                }
            }
        }
        boolean b = this.saveBatch(comMngStructHouseDOList);
        if (b) {
            log.info("批量新增房屋地址数量【{}】", comMngStructHouseDOList.size());
            log.info("batchhouse----楼栋数一共【{}】",buildingEnd-buildingBegin+1);
            log.info("batchhouse----单元数一共【{}】",(unitEnd-unitBegin+1)*(buildingEnd-buildingBegin+1));
            log.info("batchhouse----楼层数一共【{}】",(unitEnd-unitBegin+1)*(buildingEnd-buildingBegin+1)*(floorEnd-floorBegin+1));
            log.info("batchhouse----房间数量一共【{}】",(unitEnd-unitBegin+1)*(buildingEnd-buildingBegin+1)*(floorEnd-floorBegin+1)*(doorEnd-doorBegin+1));
            log.info("batchhouse----批量新增房屋地址数量【{}】", comMngStructHouseDOList.size());
        }
    }
@@ -233,10 +242,18 @@
    public R addHouseArea(ComMngStructAreaVO comMngStructAreaVO) {
        ComMngStructHouseDO comMngStructHouseDO = new ComMngStructHouseDO();
        comMngStructHouseDO.setHouseCode(comMngStructAreaVO.getAreaCode());
        comMngStructHouseDO.setHouseName(comMngStructAreaVO.getAreaName());
        comMngStructHouseDO.setHouseName(comMngStructAreaVO.getAddressDetail());
        comMngStructHouseDO.setType(1);
        comMngStructHouseDO.setParentCode("0");
        int insert = comMngStructHouseDAO.insert(comMngStructHouseDO);
        int insert = 0;
        try {
            insert = comMngStructHouseDAO.insert(comMngStructHouseDO);
        } catch (Exception e) {
            log.error("新增地址错误【{}】",e.getMessage());
            if (e.getMessage().contains("unique_house_name")) {
                return R.fail("小区已经存在");
            }
        }
        if (insert > 0) {
            return R.ok();
        }
@@ -273,8 +290,8 @@
        List<ComMngStructHouseVO> comMngStructHouseVOS = new ArrayList<>();
        List<ComMngStructHouseDO> comMngStructHouseDOList = comMngStructHouseDAO.selectList(new QueryWrapper<ComMngStructHouseDO>().lambda().eq(ComMngStructHouseDO::getParentCode, houseCode));
        if (!ObjectUtils.isEmpty(comMngStructHouseDOList)) {
            ComMngStructHouseVO comMngStructHouseVO = new ComMngStructHouseVO();
            comMngStructHouseDOList.forEach(comMngStructHouseDO -> {
                ComMngStructHouseVO comMngStructHouseVO = new ComMngStructHouseVO();
                int type = comMngStructHouseDO.getType().intValue();
                String houseCode1 = comMngStructHouseDO.getHouseCode();
                BeanUtils.copyProperties(comMngStructHouseDO, comMngStructHouseVO);
@@ -402,11 +419,14 @@
    @Override
    public R putVolunteerPhone(String parentCode) {
        List<ComMngStructHouseVO> comMngStructHouseVOS = new ArrayList<>();
        ComMngStructHouseDO comMngStructHouseDO1 = comMngStructHouseDAO.selectOne(new QueryWrapper<ComMngStructHouseDO>().lambda().eq(ComMngStructHouseDO::getHouseCode, parentCode));
        String houseName = comMngStructHouseDO1.getHouseName();
        List<ComMngStructHouseDO> comMngStructHouseDOList = comMngStructHouseDAO.selectList(new QueryWrapper<ComMngStructHouseDO>().lambda().eq(ComMngStructHouseDO::getParentCode, parentCode));
        if (!ObjectUtils.isEmpty(comMngStructHouseDOList)) {
            ComMngStructHouseVO comMngStructHouseVO = new ComMngStructHouseVO();
            comMngStructHouseDOList.forEach(comMngStructHouseDO -> {
                ComMngStructHouseVO comMngStructHouseVO = new ComMngStructHouseVO();
                BeanUtils.copyProperties(comMngStructHouseDO, comMngStructHouseVO);
                comMngStructHouseVO.setHouseShortName(comMngStructHouseVO.getHouseName().replaceAll(houseName,""));
                comMngStructHouseVOS.add(comMngStructHouseVO);
            });
        }
@@ -423,12 +443,12 @@
    @Transactional(rollbackFor = Exception.class)
    public R addHouses(ComMngStructHouseVO comMngStructHouseVO) {
        String houseCode = comMngStructHouseVO.getHouseCode();
        Integer states1 = comMngStructHouseVO.getStates();
        Integer states1 = comMngStructHouseVO.getState();
        ComMngStructHouseDO comMngStructHouseDO1 = comMngStructHouseDAO.selectOne(new QueryWrapper<ComMngStructHouseDO>().lambda().eq(ComMngStructHouseDO::getHouseCode, houseCode));
        if (ObjectUtils.isEmpty(comMngStructHouseDO1)) {
            return R.fail("房屋不存在");
        }
        Integer states = comMngStructHouseDO1.getStates();
        Integer states = comMngStructHouseDO1.getState();
        if (null != states && 0 != states.intValue()) {
            if (states1.intValue() != states.intValue()) {
                return R.fail("房屋已经被绑定了,请通过意见反馈联系后台处理");
@@ -436,17 +456,21 @@
        }
        ComMngStructHouseDO comMngStructHouseDO = new ComMngStructHouseDO();
        comMngStructHouseDO.setSquare(comMngStructHouseVO.getSquare());
        comMngStructHouseDO.setStates(states1);
        comMngStructHouseDO.setState(states1);
        comMngStructHouseDO.setId(comMngStructHouseDO1.getId());
        int update = comMngStructHouseDAO.updateById(comMngStructHouseDO);
        if (update == 0) {
            return R.fail("修改房屋面积、状态失败");
        }
        ComMngStructHouseUserDO comMngStructHouseUserDO1 = comMngStructHouseUserDAO.selectOne(new QueryWrapper<ComMngStructHouseUserDO>().lambda().eq(ComMngStructHouseUserDO::getUserId, comMngStructHouseVO.getUserId()).eq(ComMngStructHouseUserDO::getHouseCode, comMngStructHouseVO.getHouseCode()));
        if (!ObjectUtils.isEmpty(comMngStructHouseUserDO1)) {
            return R.ok();
        }
        ComMngStructHouseUserDO comMngStructHouseUserDO = new ComMngStructHouseUserDO();
        comMngStructHouseUserDO.setUserId(comMngStructHouseVO.getUserId());
        comMngStructHouseUserDO.setIdentity(comMngStructHouseVO.getIdentity());
        ComMngStructHouseDO comMngStructHouseDO2 = comMngStructHouseDAO.selectById(comMngStructHouseVO.getAreaId());
        comMngStructHouseUserDO.setAreaCode(comMngStructHouseDO2.getHouseCode());
        comMngStructHouseUserDO.setAreaCode(comMngStructHouseVO.getAreaCode());
        comMngStructHouseUserDO.setHouseCode(comMngStructHouseVO.getHouseCode());
        int insert = comMngStructHouseUserDAO.insert(comMngStructHouseUserDO);
        if (insert > 0) {
            return R.ok();