From d3767d594de66cb5f9d1294931acefea1866f783 Mon Sep 17 00:00:00 2001 From: renkang <8417338+k94314517@user.noreply.gitee.com> Date: 星期五, 24 一月 2025 18:24:25 +0800 Subject: [PATCH] 客户资料 巡检任务业务 --- server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwContractServiceImpl.java | 249 ++++++++++++++++++++++++++++++++++++++++--------- 1 files changed, 203 insertions(+), 46 deletions(-) diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwContractServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwContractServiceImpl.java index ad8f044..49ecb0b 100644 --- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwContractServiceImpl.java +++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwContractServiceImpl.java @@ -12,6 +12,7 @@ import com.doumee.core.utils.Utils; import com.doumee.dao.business.*; import com.doumee.dao.business.dao.CompanyMapper; +import com.doumee.dao.business.dto.YwContractBillDTO; import com.doumee.dao.business.model.*; import com.doumee.dao.system.MultifileMapper; import com.doumee.dao.system.SystemUserMapper; @@ -25,6 +26,7 @@ import com.github.yulichang.wrapper.MPJLambdaWrapper; import org.apache.commons.lang3.StringUtils; import org.checkerframework.checker.units.qual.C; +import org.springframework.beans.BeanUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; @@ -75,8 +77,6 @@ @Transactional(rollbackFor = {BusinessException.class,Exception.class}) public Integer create(YwContract model) { isParamValidCreated(model); - - model.setCreator(model.getLoginUserInfo().getId()); model.setIsdeleted(Constants.ZERO); model.setCreateDate(new Date()); @@ -91,7 +91,7 @@ } model.setRemark(getRemarlByParam(model)); ywContractMapper.insert(model); - dealDetailListBiz(model);//澶勭悊鏉℃淇℃伅 + dealDetailListBiz(model,false);//澶勭悊鏉℃淇℃伅 dealMultifileBiz(model);//澶勭悊闄勪欢淇℃伅 dealRoomsForContract(model);//澶勭悊鎴挎簮鍏宠仈琛� dealLogBiz(model,Constants.YwLogType.CONTRACT_CREATE,model.getLoginUserInfo().getRealname(),"銆�"+model.getRemark().replace("鍚堝悓鎽樿锛�","")+"銆�");//璁板綍鏂板缓鏃ュ織 @@ -162,7 +162,7 @@ isParamValidForBill(model); model.setCreateDate(new Date()); model.setEditDate(model.getCreateDate()); - dealDetailListBiz(model);//澶勭悊鏉℃淇℃伅 + dealDetailListBiz(model,true);//澶勭悊鏉℃淇℃伅 return model.getBillList(); } @@ -177,8 +177,7 @@ ){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝璇锋寜椤甸潰瑕佹眰濉啓鍚堝悓淇℃伅"); } - if(model.getEndDate().getTime()<= model.getStartDate().getTime()){ - + if(model.getEndDate().getTime()< model.getStartDate().getTime()){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝鍚堝悓鏈夋晥鏈熺粨鏉熸椂闂翠笉寰楁棭浜庡紑濮嬫椂闂达紒"); } @@ -211,7 +210,7 @@ ){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝璇锋寜椤甸潰瑕佹眰濉啓绉熻祦鏉℃淇℃伅!"); } - if(d.getEndDate().getTime()<= d.getStartDate().getTime()){ + if(d.getEndDate().getTime()< d.getStartDate().getTime()){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝绉熻祦鏉℃鏈夋晥鏈熺粨鏉熸椂闂翠笉寰楁棭浜庡紑濮嬫椂闂达紒"); } @@ -387,7 +386,7 @@ .set(YwContract::getEditDate,DateUtil.getCurrDateTime()) .eq(YwContract::getIsdeleted,Constants.ZERO) .in(YwContract::getStatus,Constants.ONE,Constants.ZERO) - .apply(" END_DATE < NOW() ") + .apply(" END_DATE < CURRENT_DATE ") ); } @@ -605,7 +604,11 @@ } } - private void dealDetailListBiz(YwContract model) { + /** + * @param model + * @param createBill 鏍规嵁鏉℃鐢熸垚璐﹀崟 false 鍒欐牴鎹墠绔紪杈戝悗鐨勬暟鎹敓鎴� + */ + private void dealDetailListBiz(YwContract model,boolean createBill) { List<YwContractDetail> details1 = new ArrayList<>(); List<YwContractDetail> details2 = new ArrayList<>(); int num = 0; @@ -645,7 +648,90 @@ } } //澶勭悊璐﹀崟淇℃伅 - dealBillListBiz(model,details1,details2); + if(createBill){ + dealBillListBiz(model,details1,details2); + }else{ + //2025-1-23 13:56:53 鍔犲叆 鍓嶇鍏ュ弬璋冩暣鍚庣殑璐﹀崟淇℃伅 + List<YwContractBill> ywContractBillList = new ArrayList<>(); + //鏌ヨ绉熻祦鏉℃ + if(Constants.equalsInteger(model.getType(),Constants.ZERO ) + || Constants.equalsInteger(model.getType(),Constants.TWO)&& com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(details1)){ + YwContractDetail ywContractDetail = details1.get(Constants.ZERO); + YwContractBill zlBill = new YwContractBill(); + BeanUtils.copyProperties(model.getZlBillDTO(),zlBill); + zlBill.setCreator(model.getCreator()); + zlBill.setCreateDate(model.getCreateDate()); + zlBill.setIsdeleted(Constants.ZERO); + zlBill.setStatus(Constants.ZERO); + zlBill.setReceivableFee(zlBill.getTotleFee()); + zlBill.setType(Constants.ZERO); + zlBill.setCompanyId(model.getCompanyId()); + zlBill.setContractId(model.getId()); + zlBill.setBillType(Constants.ZERO); + zlBill.setPayStatus(Constants.ZERO); + ywContractBillList.add(zlBill); + Integer sortnum = Constants.ONE; + for (YwContractBillDTO zlBillDTO:model.getZlBillDTOList()) { + YwContractBill zl = new YwContractBill(); + BeanUtils.copyProperties(zlBillDTO,zl); + zl.setCreator(model.getCreator()); + zl.setCreateDate(model.getCreateDate()); + zl.setIsdeleted(Constants.ZERO); + zl.setStatus(Constants.ZERO); + zl.setReceivableFee(zl.getTotleFee()); + zl.setType(Constants.ZERO); + zl.setCompanyId(model.getCompanyId()); + zl.setContractId(model.getId()); + zl.setBillType(Constants.ZERO); + zl.setPayStatus(Constants.ZERO); + zl.setSortnum(sortnum); + zl.setDetailId(ywContractDetail.getId()); + ywContractBillList.add(zl); + sortnum++; + } + } + //鏌ヨ鐗╀笟璐﹀崟 + if(Constants.equalsInteger(model.getType(),Constants.ZERO ) + || Constants.equalsInteger(model.getType(),Constants.TWO)&& com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(details2)){ + YwContractDetail ywContractDetail = details2.get(Constants.ZERO); + YwContractBill wyBill = new YwContractBill(); + BeanUtils.copyProperties(model.getWyBillDTO(),wyBill); + wyBill.setCreator(model.getCreator()); + wyBill.setCreateDate(model.getCreateDate()); + wyBill.setIsdeleted(Constants.ZERO); + wyBill.setStatus(Constants.ZERO); + wyBill.setReceivableFee(wyBill.getTotleFee()); + wyBill.setType(Constants.ZERO); + wyBill.setCompanyId(model.getCompanyId()); + wyBill.setContractId(model.getId()); + wyBill.setBillType(Constants.ZERO); + wyBill.setPayStatus(Constants.ZERO); + ywContractBillList.add(wyBill); + Integer sortnum = Constants.ONE; + for (YwContractBillDTO wyBillDTO:model.getWyBillDTOList()) { + YwContractBill wy = new YwContractBill(); + BeanUtils.copyProperties(wyBillDTO,wy); + wy.setCreator(model.getCreator()); + wy.setCreateDate(model.getCreateDate()); + wy.setIsdeleted(Constants.ZERO); + wy.setStatus(Constants.ZERO); + wy.setReceivableFee(wy.getTotleFee()); + wy.setType(Constants.ZERO); + wy.setCompanyId(model.getCompanyId()); + wy.setContractId(model.getId()); + wy.setBillType(Constants.ZERO); + wy.setPayStatus(Constants.ZERO); + wy.setSortnum(sortnum); + wy.setDetailId(ywContractDetail.getId()); + ywContractBillList.add(wy); + sortnum++; + } + } + if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywContractBillList)){ + ywContractBillMapper.insert(ywContractBillList); + } + } + } /** @@ -1043,8 +1129,7 @@ ){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝璇锋寜椤甸潰瑕佹眰濉啓鍚堝悓淇℃伅"); } - if(model.getEndDate().getTime()<= model.getStartDate().getTime()){ - + if(model.getEndDate().getTime()< model.getStartDate().getTime()){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝鍚堝悓鏈夋晥鏈熺粨鏉熸椂闂翠笉寰楁棭浜庡紑濮嬫椂闂达紒"); } if(Constants.equalsInteger(model.getType(),Constants.ZERO ) @@ -1080,7 +1165,7 @@ ){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝璇锋寜椤甸潰瑕佹眰濉啓绉熻祦鏉℃淇℃伅!"); } - if(d.getEndDate().getTime()<= d.getStartDate().getTime()){ + if(d.getEndDate().getTime()< d.getStartDate().getTime()){ throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"瀵逛笉璧凤紝绉熻祦鏉℃鏈夋晥鏈熺粨鏉熸椂闂翠笉寰楁棭浜庡紑濮嬫椂闂达紒"); } if(d.getEndDate().getTime()>model.getEndDate().getTime() ||d.getStartDate().getTime()<model.getStartDate().getTime()){ @@ -1188,7 +1273,53 @@ if(user ==null || (user.getDeleted()!=null && user.getDeleted()) ){ throw new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"瀵逛笉璧凤紝缁忓姙浜轰俊鎭笉瀛樺湪锛岃灏濊瘯鍒锋柊椤甸潰閲嶈瘯锛�"); } + if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isEmpty(model.getYwContractBillDTOList())){ + throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"鏃犺处鍗曚俊鎭紝璇峰埛鏂伴噸璇�"); + } + for (YwContractBillDTO billDTO:model.getYwContractBillDTOList()) { + if( + Objects.isNull(billDTO.getStartDate()) + ||Objects.isNull(billDTO.getEndDate()) + ||Objects.isNull(billDTO.getPlanPayDate()) + ||Objects.isNull(billDTO.getTotleFee()) + ||Objects.isNull(billDTO.getCostType()) + ){ + throw new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"璐﹀崟鏄庣粏鍙傛暟閿欒"); + } + } + List<YwContractBillDTO> ywContractBillDTOList = model.getYwContractBillDTOList(); + //鏌ヨ绉熻祦鏉℃ + if(Constants.equalsInteger(model.getType(),Constants.ZERO ) + || Constants.equalsInteger(model.getType(),Constants.TWO)){ + List<YwContractBillDTO> leaseBillDTOList = ywContractBillDTOList.stream() + .filter(i->Constants.equalsInteger(i.getCostType(),Constants.ZERO)).collect(Collectors.toList()); + if(CollectionUtils.isEmpty(leaseBillDTOList)){ + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鏃犵璧佽垂璐﹀崟锛�"); + } + model.setZlBillDTOList(leaseBillDTOList); + Optional<YwContractBillDTO> leaseBillOptional = ywContractBillDTOList.stream() + .filter(i->Constants.equalsInteger(i.getCostType(),Constants.TWO)).findAny(); + if(!leaseBillOptional.isPresent()){ + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鏃犵璧佹娂閲戣处鍗曪紒"); + } + model.setZlBillDTO(leaseBillOptional.get()); + } + if(Constants.equalsInteger(model.getType(),Constants.ZERO ) + || Constants.equalsInteger(model.getType(),Constants.ONE)){ + List<YwContractBillDTO> wyBillDTOList = ywContractBillDTOList.stream() + .filter(i->Constants.equalsInteger(i.getCostType(),Constants.ONE)).collect(Collectors.toList()); + if(CollectionUtils.isEmpty(wyBillDTOList)){ + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鏃犵墿涓氳垂璐﹀崟锛�"); + } + model.setWyBillDTOList(wyBillDTOList); + Optional<YwContractBillDTO> wyBillOptional = ywContractBillDTOList.stream() + .filter(i->Constants.equalsInteger(i.getCostType(),Constants.THREE)).findAny(); + if(!wyBillOptional.isPresent()){ + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鏃犵墿涓氭娂閲戣处鍗曪紒"); + } + model.setWyBillDTO(wyBillOptional.get()); + } } @Override @@ -1276,38 +1407,38 @@ if (model == null) { throw new BusinessException(ResponseStatus.DATA_EMPTY); } - //鍚堝悓闄勪欢 - initFiles(model); - //鏌ヨ鎴挎簮淇℃伅鏁版嵁 - MPJLambdaWrapper<YwRoom> rw = new MPJLambdaWrapper<>(); - rw.selectAll(YwRoom.class) - .selectAs(YwProject::getName, YwRoom::getProjectName) - .selectAs(YwFloor::getName, YwRoom::getFloorName) - .selectAs(YwBuilding::getName, YwRoom::getBuildingName) - .leftJoin(YwProject.class, YwProject::getId, YwRoom::getProjectId) - .leftJoin(YwBuilding.class, YwBuilding::getId, YwRoom::getBuildingId) - .leftJoin(YwFloor.class, YwFloor::getId, YwRoom::getFloor) - .eq(YwRoom::getIsdeleted, Constants.ZERO) - .exists("(select a.id from yw_contract_room a where a.isdeleted=0 and a.type=0 and a.room_id=t.id and a.contract_id=" + model.getId() + ")"); - model.setRoomList(roomMapper.selectJoinList(YwRoom.class, rw)); - model.setWyFirstCircleStr(Constants.getUnitTypeByNum(model.getWyFirstCircle())); - model.setZlFirstCircleStr(Constants.getUnitTypeByNum(model.getZlFirstCircle())); - //鏌ヨ绉熻硟鏉℃淇℃伅 - MPJLambdaWrapper<YwContractDetail> dw = new MPJLambdaWrapper<>(); - dw.selectAll(YwContractDetail.class) - .eq(YwContractDetail::getIsdeleted, Constants.ZERO) - .eq(YwContractDetail::getContractId, model.getId()) - .in(YwContractDetail::getType, Constants.ZERO, Constants.TWO) - .orderByAsc(YwContractDetail::getSortnum); - model.setZlDetailList(ywContractDetailMapper.selectJoinList(YwContractDetail.class, dw)); - //鏌ヨ鐗╂キ鏉℃淇℃伅 - dw = new MPJLambdaWrapper<>(); - dw.selectAll(YwContractDetail.class) - .eq(YwContractDetail::getIsdeleted, Constants.ZERO) - .eq(YwContractDetail::getContractId, model.getId()) - .in(YwContractDetail::getType, Constants.ONE, Constants.THREE) - .orderByAsc(YwContractDetail::getSortnum); - model.setWyDetailList(ywContractDetailMapper.selectJoinList(YwContractDetail.class, dw)); + //鍚堝悓闄勪欢 + initFiles(model); + //鏌ヨ鎴挎簮淇℃伅鏁版嵁 + MPJLambdaWrapper<YwRoom> rw = new MPJLambdaWrapper<>(); + rw.selectAll(YwRoom.class) + .selectAs(YwProject::getName, YwRoom::getProjectName) + .selectAs(YwFloor::getName, YwRoom::getFloorName) + .selectAs(YwBuilding::getName, YwRoom::getBuildingName) + .leftJoin(YwProject.class, YwProject::getId, YwRoom::getProjectId) + .leftJoin(YwBuilding.class, YwBuilding::getId, YwRoom::getBuildingId) + .leftJoin(YwFloor.class, YwFloor::getId, YwRoom::getFloor) + .eq(YwRoom::getIsdeleted, Constants.ZERO) + .exists("(select a.id from yw_contract_room a where a.isdeleted=0 and a.type=0 and a.room_id=t.id and a.contract_id=" + model.getId() + ")"); + model.setRoomList(roomMapper.selectJoinList(YwRoom.class, rw)); + model.setWyFirstCircleStr(Constants.getUnitTypeByNum(model.getWyFirstCircle())); + model.setZlFirstCircleStr(Constants.getUnitTypeByNum(model.getZlFirstCircle())); + //鏌ヨ绉熻硟鏉℃淇℃伅 + MPJLambdaWrapper<YwContractDetail> dw = new MPJLambdaWrapper<>(); + dw.selectAll(YwContractDetail.class) + .eq(YwContractDetail::getIsdeleted, Constants.ZERO) + .eq(YwContractDetail::getContractId, model.getId()) + .in(YwContractDetail::getType, Constants.ZERO, Constants.TWO) + .orderByAsc(YwContractDetail::getSortnum); + model.setZlDetailList(ywContractDetailMapper.selectJoinList(YwContractDetail.class, dw)); + //鏌ヨ鐗╂キ鏉℃淇℃伅 + dw = new MPJLambdaWrapper<>(); + dw.selectAll(YwContractDetail.class) + .eq(YwContractDetail::getIsdeleted, Constants.ZERO) + .eq(YwContractDetail::getContractId, model.getId()) + .in(YwContractDetail::getType, Constants.ONE, Constants.THREE) + .orderByAsc(YwContractDetail::getSortnum); + model.setWyDetailList(ywContractDetailMapper.selectJoinList(YwContractDetail.class, dw)); return model; } @@ -1429,7 +1560,8 @@ queryWrapper.selectAll(YwContract.class ) .selectAs(Company::getName,YwContract::getCompanyName ) .selectAs(YwCustomer::getName,YwContract::getRenterName ) - .select("(select sum(r.area) from yw_contract_room cr left join yw_room r on r.id = cr.room_id where r.isdeleted=0 and cr.contract_id =t.id)",YwContract::getTotalArea ) + .select("(select sum(r.RENT_AREA) from yw_contract_room cr left join yw_room r on r.id = cr.room_id where r.isdeleted=0 and cr.contract_id =t.id)",YwContract::getTotalArea ) + .select(" ( select ifnull(sum(y.TOTLE_FEE),0) from yw_contract_bill y where y.CONTRACT_ID = t.id and y.type = 0 and y.COST_TYPE=0 and y.BILL_TYPE = 0 ) " , YwContract::getTotalFee) .leftJoin(Company.class,Company::getId,YwContract::getCompanyId) .leftJoin(YwCustomer.class,YwCustomer::getId,YwContract::getRenterId); Utils.MP.blankToNull(pageWrap.getModel()); @@ -1537,6 +1669,9 @@ if (pageWrap.getModel().getRoomId() != null) { queryWrapper.apply(" t.id in ( select ycr.CONTRACT_ID from yw_contract_room ycr where ycr.type = 0 and ycr.ROOM_ID = "+pageWrap.getModel().getRoomId()+" ) "); } + if (pageWrap.getModel().getBuildingId() != null) { + queryWrapper.apply(" t.id in ( select ycr.CONTRACT_ID from yw_contract_room ycr left join yw_room yr on ycr.ROOM_ID = yr.id where ycr.type = 0 and yr.BUILDING_ID = "+pageWrap.getModel().getBuildingId()+" ) "); + } queryWrapper.ge(Objects.nonNull(pageWrap.getModel().getQueryStartTime()), YwContract::getStartDate, pageWrap.getModel().getQueryStartTime()) .le(Objects.nonNull(pageWrap.getModel().getQueryEndTime()), YwContract::getEndDate, pageWrap.getModel().getQueryEndTime()); queryWrapper.orderByDesc(YwContract::getCreateDate ); @@ -1545,6 +1680,28 @@ for(YwContract model : data.getRecords()){ model.setWyFirstCircleStr(Constants.getUnitTypeByNum(model.getWyFirstCircle())); model.setZlFirstCircleStr(Constants.getUnitTypeByNum(model.getZlFirstCircle())); + //鏌ヨ鎴挎簮淇℃伅鏁版嵁 + MPJLambdaWrapper<YwRoom> rw = new MPJLambdaWrapper<>(); + rw.selectAll(YwRoom.class) + .selectAs(YwProject::getName, YwRoom::getProjectName) + .selectAs(YwFloor::getName, YwRoom::getFloorName) + .selectAs(YwBuilding::getName, YwRoom::getBuildingName) + .leftJoin(YwProject.class, YwProject::getId, YwRoom::getProjectId) + .leftJoin(YwBuilding.class, YwBuilding::getId, YwRoom::getBuildingId) + .leftJoin(YwFloor.class, YwFloor::getId, YwRoom::getFloor) + .eq(YwRoom::getIsdeleted, Constants.ZERO) + .exists("(select a.id from yw_contract_room a where a.isdeleted=0 and a.type=0 and a.room_id=t.id and a.contract_id=" + model.getId() + ")"); + model.setRoomList(roomMapper.selectJoinList(YwRoom.class, rw)); + model.setLeaseDays( + DateUtil.daysBetweenDates(model.getEndDate(),model.getStartDate()) + 1 + ); + if(Objects.nonNull(model.getLeaseDays())&&Objects.nonNull(model.getTotalArea())&&Objects.nonNull(model.getTotalFee())){ + model.setLeasePrice(model.getTotalFee().divide((model.getTotalArea().multiply(new BigDecimal(model.getLeaseDays()))),2,BigDecimal.ROUND_HALF_UP)); + }else{ + model.setLeasePrice(BigDecimal.ZERO); + } + + } } return data; -- Gitblit v1.9.3