崇州自主安置
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
yanghb
3 天以前 ea3092eec19e10072aeed5569a464e0ea45fe52f 
 cz-bussiness/src/main/java/com/ruoyi/bussiness/service/impl/PlacementBatchServiceImpl.java


@@ -3,6 +3,7 @@


import cn.hutool.core.bean.BeanUtil;


import cn.hutool.core.util.NumberUtil;


import cn.hutool.core.util.ObjUtil;


import cn.hutool.core.util.ObjectUtil;


import cn.hutool.core.util.StrUtil;


import com.alibaba.excel.EasyExcelFactory;


import com.alibaba.excel.write.builder.ExcelWriterBuilder;


@@ -687,25 +688,33 @@


            placementApplyRecordLambdaQueryWrapper.eq(PlacementBatchHousehold::getPlacementBatchId, placementBatch.getId());


            //家庭成员


            List<PlacementBatchHousehold> households = placementBatchHouseholdService.list(placementApplyRecordLambdaQueryWrapper);


            //户主


            List<String> houseHead = households.stream().map(PlacementBatchHousehold::getHouseholdHead).collect(Collectors.toList());


            if (ObjUtil.isNotEmpty(households)) {


                List<String> familyNames = households.stream().map(PlacementBatchHousehold::getWaitFamilyNames).collect(Collectors.toList());


                List<String> allFamilyNames = new ArrayList<>();


                for(String familyName : familyNames) {


                    List<String> names = Arrays.asList(familyName.split("、"));


                    allFamilyNames.addAll(names);


                }


                LambdaUpdateWrapper<Placement> placementLambdaUpdateWrapper = new LambdaUpdateWrapper<>();


                placementLambdaUpdateWrapper.set(Placement::getStatus, 1);


                placementLambdaUpdateWrapper.and(query -> query.in(Placement::getFamilyName, allFamilyNames));


                placementService.update(placementLambdaUpdateWrapper);




            if(ObjectUtil.isEmpty(households)){


                return;


            }


            //修改户主安置状态


            List<String> houseHead = households.stream().map(PlacementBatchHousehold::getHouseholdHead).collect(Collectors.toList());


            if (ObjUtil.isNotEmpty(houseHead)) {


                LambdaUpdateWrapper<Placement> placementHouseHeadUpdateWrapper = new LambdaUpdateWrapper<>();


                placementHouseHeadUpdateWrapper.set(Placement::getStatus, 1);


                placementHouseHeadUpdateWrapper.and(query -> query.in(Placement::getHouseholdHead, houseHead));


                placementService.update(placementHouseHeadUpdateWrapper);


            }


            //修改家庭成员安置状态


            for(PlacementBatchHousehold household : households){


                if(ObjUtil.isEmpty(household.getWaitFamilyNames())){


                    continue;


                }


                //购房表家庭成员姓名


                List<String> names = Arrays.asList(household.getWaitFamilyNames().split("、"));


                //购房表户主身份证


                String headIdCard = household.getIdCard();


                LambdaUpdateWrapper<Placement> placementLambdaUpdateWrapper = new LambdaUpdateWrapper<>();


                placementLambdaUpdateWrapper.set(Placement::getStatus, 1);


                placementLambdaUpdateWrapper.eq(Placement::getIdCard,headIdCard);


                placementLambdaUpdateWrapper.and(query -> query.in(Placement::getFamilyName, names));


                placementService.update(placementLambdaUpdateWrapper);


            }


        }




        //同步待处理消息