From 14a20df4699cf3d933e2bdbe1ba2aba15ade1059 Mon Sep 17 00:00:00 2001 From: MrShi <1878285526@qq.com> Date: 星期二, 26 十一月 2024 09:20:02 +0800 Subject: [PATCH] 解决冲突 --- server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwContractBillServiceImpl.java | 240 +++++++++++++++++++++++++++++++++++++++++++++++++++++++----- 1 files changed, 220 insertions(+), 20 deletions(-) diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwContractBillServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwContractBillServiceImpl.java index b8cff6b..cd31b01 100644 --- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwContractBillServiceImpl.java +++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwContractBillServiceImpl.java @@ -1,5 +1,6 @@ package com.doumee.service.business.impl; +import com.doumee.biz.system.SystemDictDataBiz; import com.doumee.core.constants.ResponseStatus; import com.doumee.core.exception.BusinessException; import com.doumee.core.model.LoginUserInfo; @@ -7,12 +8,8 @@ import com.doumee.core.model.PageWrap; import com.doumee.core.utils.Constants; import com.doumee.core.utils.Utils; -import com.doumee.dao.business.YwContractBillMapper; -import com.doumee.dao.business.YwContractRoomMapper; -import com.doumee.dao.business.model.YwContract; -import com.doumee.dao.business.model.YwContractBill; -import com.doumee.dao.business.model.YwContractRoom; -import com.doumee.dao.business.model.YwCustomer; +import com.doumee.dao.business.*; +import com.doumee.dao.business.model.*; import com.doumee.dao.system.MultifileMapper; import com.doumee.dao.system.model.Multifile; import com.doumee.service.business.YwContractBillService; @@ -27,9 +24,8 @@ import org.springframework.util.CollectionUtils; import java.math.BigDecimal; -import java.util.Date; -import java.util.List; -import java.util.Objects; +import java.util.*; +import java.util.stream.Collectors; /** * 杩愮淮鍚堝悓璐﹀崟淇℃伅琛⊿ervice瀹炵幇 @@ -48,27 +44,51 @@ @Autowired private MultifileMapper multifileMapper; + @Autowired + private YwContractRevenueMapper ywContractRevenueMapper; + + @Autowired + private SystemDictDataBiz systemDictDataBiz; + + @Autowired + private YwContractMapper ywContractMapper; + + + @Override public Integer create(YwContractBill ywContractBill) { if(Objects.isNull(ywContractBill) - || Objects.isNull(ywContractBill.getContractId()) - || Objects.isNull(ywContractBill.getTotleFee()) - || Objects.isNull(ywContractBill.getPlanPayData()) + || Objects.isNull(ywContractBill.getContractId()) + || Objects.isNull(ywContractBill.getTotleFee()) + || Objects.isNull(ywContractBill.getPlanPayDate()) || Objects.isNull(ywContractBill.getCostType()) || Objects.isNull(ywContractBill.getBillType()) || Objects.isNull(ywContractBill.getCompanyId()) - || Objects.isNull(ywContractBill.getStartDate()) - || Objects.isNull(ywContractBill.getEndDate()) + || com.github.xiaoymin.knife4j.core.util.CollectionUtils.isEmpty(ywContractBill.getYwContractRoomList()) + || Objects.nonNull(ywContractBill.getFeeType()) + || (Constants.equalsInteger(ywContractBill.getFeeType(),Constants.ZERO)&& (Objects.isNull(ywContractBill.getStartDate()) + || Objects.isNull(ywContractBill.getEndDate()))) ){ throw new BusinessException(ResponseStatus.BAD_REQUEST); } + YwContract ywContract = ywContractMapper.selectById(ywContractBill.getContractId()); + if(Objects.isNull(ywContract)){ + throw new BusinessException(ResponseStatus.DATA_EMPTY); + } + if(Constants.equalsInteger(ywContract.getStatus(),Constants.THREE)){ + throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"鍚堝悓鐘舵�佸凡娴佽浆,鏃犳硶杩涜璇ユ搷浣�"); + } + LoginUserInfo loginUserInfo = ywContractBill.getLoginUserInfo(); + ywContractBill.setReceivableFee(ywContractBill.getTotleFee()); ywContractBill.setCreateDate(new Date()); ywContractBill.setCreator(loginUserInfo.getId()); ywContractBill.setIsdeleted(Constants.ZERO); + ywContractBill.setType(Constants.ONE); ywContractBill.setStatus(Constants.ZERO); ywContractBillMapper.insert(ywContractBill); + //鎴挎簮鏁版嵁 if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywContractBill.getYwContractRoomList())){ for (YwContractRoom ywContractRoom:ywContractBill.getYwContractRoomList()) { if(Objects.isNull(ywContractRoom) @@ -80,11 +100,11 @@ ywContractRoom.setIsdeleted(Constants.ZERO); ywContractRoom.setContractId(ywContractBill.getId()); ywContractRoom.setType(Constants.ONE); - } ywContractRoomMapper.insert(ywContractBill.getYwContractRoomList()); } + //闄勪欢鏁版嵁 if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywContractBill.getMultifileList())){ for (Multifile multifile:ywContractBill.getMultifileList()) { if(Objects.isNull(multifile) @@ -95,7 +115,7 @@ multifile.setCreator(loginUserInfo.getId()); multifile.setCreateDate(new Date()); multifile.setIsdeleted(Constants.ZERO); - multifile.setObjType(Constants.MultiFile.FN_PATROL_POINT_FILE.getKey()); + multifile.setObjType(Constants.MultiFile.FN_CONTRACT_BILL_FILE.getKey()); multifile.setObjId(ywContractBill.getId()); } multifileMapper.insert(ywContractBill.getMultifileList()); @@ -143,6 +163,53 @@ return ywContractBillMapper.selectById(id); } + + @Override + public YwContractBill getDetail(Integer id) { + YwContractBill ywContractBill = ywContractBillMapper.selectJoinOne(YwContractBill.class, + new MPJLambdaWrapper<YwContractBill>().selectAll(YwContractBill.class) + .select(" ( select ifnull(sum(yw.ACT_RECEIVABLE_FEE),0) from yw_contract_revenue yw where yw.bill_id = t.id and yw.status = 0 and yw.isdeleted = 0 ) as actReceivableFee ") + .selectAs(YwContract::getCode,YwContractBill::getContractCode) + .selectAs(YwCustomer::getName,YwContractBill::getCustomerName) + .leftJoin(YwContract.class,YwContract::getId,YwContractBill::getContractId) + .leftJoin(YwCustomer.class,YwCustomer::getId,YwContract::getRenterId) + .eq(YwContractBill::getIsdeleted,Constants.ZERO) + .eq(YwContractBill::getId,id)); + if(Objects.isNull(ywContractBill)){ + throw new BusinessException(ResponseStatus.DATA_EMPTY); + } + + //鎴挎簮鏁版嵁 + ywContractBill.setYwContractRoomList(ywContractRoomMapper.selectJoinList(YwContractRoom.class,new MPJLambdaWrapper<YwContractRoom>() + .selectAll(YwContractRoom.class) + .selectAs(YwProject::getName,YwRoom::getProjectName) + .selectAs(YwFloor::getName,YwRoom::getFloorName) + .selectAs(YwBuilding::getName,YwRoom::getBuildingName) + .leftJoin(YwRoom.class,YwRoom::getId,YwContractRoom::getRoomId) + .leftJoin(YwFloor.class,YwFloor::getId,YwRoom::getFloor) + .leftJoin(YwProject.class,YwProject::getId,YwRoom::getProjectId) + .leftJoin(YwBuilding.class,YwBuilding::getId,YwRoom::getBuildingId) + .eq(YwContractRoom::getContractId,id) + .eq(YwContractRoom::getType,Constants.ONE) + )); + + //闄勪欢鏁版嵁 + List<Multifile> multifileList = multifileMapper.selectList(new QueryWrapper<Multifile>().lambda() + .eq(Multifile::getObjId,id) + .eq(Multifile::getObjType,Constants.MultiFile.FN_CONTRACT_BILL_FILE.getKey())); + if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(multifileList)){ + String path = systemDictDataBiz.queryByCode(Constants.FTP,Constants.FTP_RESOURCE_PATH).getCode() + +systemDictDataBiz.queryByCode(Constants.FTP,Constants.YW_CONTRACT_BILL).getCode(); + for (Multifile multifile:multifileList) { + if(StringUtils.isNotBlank(multifile.getFileurl())){ + multifile.setFileurlFull(path + multifile.getFileurl()); + } + } + ywContractBill.setMultifileList(multifileList); + } + return ywContractBill; + } + @Override public YwContractBill findOne(YwContractBill ywContractBill) { QueryWrapper<YwContractBill> wrapper = new QueryWrapper<>(ywContractBill); @@ -160,17 +227,150 @@ IPage<YwContractBill> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity()); MPJLambdaWrapper<YwContractBill> queryWrapper = new MPJLambdaWrapper<>(); Utils.MP.blankToNull(pageWrap.getModel()); - queryWrapper.selectAll(YwContractBill.class) - .leftJoin(YwContract.class,YwContract::getId,YwContractBill::getContractId) - .leftJoin(YwCustomer.class,YwCustomer::getId,YwContract::getRenterId) + YwContractBill model = pageWrap.getModel(); + IPage<YwContractBill> iPage = ywContractBillMapper.selectJoinPage(page,YwContractBill.class, + queryWrapper.selectAll(YwContractBill.class) + .select(" ( select ifnull(sum(yw.ACT_RECEIVABLE_FEE),0) from yw_contract_revenue yw where yw.bill_id = t.id and yw.status = 0 and yw.isdeleted = 0 ) as actReceivableFee ") + .selectAs(YwContract::getCode,YwContractBill::getContractCode) + .selectAs(YwCustomer::getName,YwContractBill::getCustomerName) + .leftJoin(YwContract.class,YwContract::getId,YwContractBill::getContractId) + .leftJoin(YwCustomer.class,YwCustomer::getId,YwContract::getRenterId) + .eq(YwContractBill::getIsdeleted,Constants.ZERO) + .like(Objects.nonNull(model)&&StringUtils.isNotBlank(model.getCustomerName()), + YwCustomer::getName,model.getCustomerName()) + .eq(Objects.nonNull(model)&&Objects.nonNull(model.getStatus()), + YwContractBill::getStatus,model.getStatus()) + .eq(Objects.nonNull(model)&&Objects.nonNull(model.getPayStatus()), + YwContractBill::getPayStatus,model.getPayStatus()) + .eq(Objects.nonNull(model)&&Objects.nonNull(model.getType()), + YwContractBill::getType,model.getType()) + .eq(Objects.nonNull(model)&&Objects.nonNull(model.getContractId()), + YwContractBill::getContractId,model.getContractId()) + .ge(Objects.nonNull(model)&&Objects.nonNull(model.getPlanPayDateStart()),YwContractBill::getPlanPayDate, Utils.Date.getStart(model.getPlanPayDateStart())) + .le(Objects.nonNull(model)&&Objects.nonNull(model.getPlanPayDateEnd()),YwContractBill::getPlanPayDate, Utils.Date.getEnd(model.getPlanPayDateEnd())) ) ; + this.dealRoomDetail(iPage.getRecords()); + for (YwContractBill ywContractBill:iPage.getRecords()) { + //闇�鏀堕噾棰� + ywContractBill.setNeedReceivableFee( + ywContractBill.getReceivableFee().subtract(ywContractBill.getActReceivableFee()) + ); + //鏄惁閫炬湡 + if(Constants.equalsInteger(ywContractBill.getStatus(),Constants.ZERO) && (Constants.equalsInteger(ywContractBill.getPayStatus(),Constants.ZERO) + || Constants.equalsInteger(ywContractBill.getPayStatus(),Constants.TWO) + || Constants.equalsInteger(ywContractBill.getPayStatus(),Constants.THREE) + || Constants.equalsInteger(ywContractBill.getPayStatus(),Constants.FOUR)) + && ywContractBill.getEndDate().getTime() < System.currentTimeMillis()){ + ywContractBill.setIsOverdue(Constants.ONE); + }else{ + ywContractBill.setIsOverdue(Constants.ZERO); + } + //妤煎畤鍚嶇О + List<YwContractRoom> ywContractRoomList = ywContractBill.getYwContractRoomList(); + StringBuilder roomPathName = new StringBuilder(); + for (YwContractRoom ywContractRoom:ywContractRoomList) { + if(StringUtils.isNotBlank(ywContractRoom.getProjectName())){ + roomPathName.append(ywContractRoom.getProjectName()); + } + if(StringUtils.isNotBlank(ywContractRoom.getBuildingName())){ + roomPathName.append(ywContractRoom.getBuildingName()); + } + if(StringUtils.isNotBlank(ywContractRoom.getFloorName())){ + roomPathName.append(ywContractRoom.getFloorName()); + } + if(StringUtils.isNotBlank(ywContractRoom.getRoomName())){ + roomPathName.append(ywContractRoom.getRoomName()); + } + if(StringUtils.isNotBlank(roomPathName)){ + roomPathName.append(";"); + } + } + ywContractBill.setRoomPathName(roomPathName.toString()); + } - return PageData.from(ywContractBillMapper.selectPage(page, queryWrapper)); + return PageData.from(iPage); } + + public void dealRoomDetail(List<YwContractBill> ywContractBillList){ + //鏌ヨ璐﹀崟涓嬬殑妤煎畤鏁版嵁 + if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywContractBillList)){ + //鑾峰彇鎵�鏈夋暟鎹� + List<Integer> billIdList = ywContractBillList.stream().map(i->i.getId()).collect(Collectors.toList()); + if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(billIdList)){ + List<YwContractRoom> ywContractRoomList = ywContractRoomMapper.selectJoinList(YwContractRoom.class,new MPJLambdaWrapper<YwContractRoom>() + .selectAll(YwContractRoom.class) + .selectAs(YwProject::getName,YwRoom::getProjectName) + .selectAs(YwFloor::getName,YwRoom::getFloorName) + .selectAs(YwBuilding::getName,YwRoom::getBuildingName) + .selectAs(YwRoom::getName,YwContractRoom::getRoomName) + .leftJoin(YwRoom.class,YwRoom::getId,YwContractRoom::getRoomId) + .leftJoin(YwFloor.class,YwFloor::getId,YwRoom::getFloor) + .leftJoin(YwProject.class,YwProject::getId,YwRoom::getProjectId) + .leftJoin(YwBuilding.class,YwBuilding::getId,YwRoom::getBuildingId) + .in(YwContractRoom::getContractId,billIdList) + .eq(YwContractRoom::getType,Constants.ONE) + ); + if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywContractRoomList)){ + for (YwContractBill ywContractBill:ywContractBillList) { + ywContractBill.setYwContractRoomList( + ywContractRoomList.stream().filter(i->Constants.equalsInteger(i.getContractId(),ywContractBill.getId())).collect(Collectors.toList()) + ); + } + } + } + } + } + @Override public long count(YwContractBill ywContractBill) { QueryWrapper<YwContractBill> wrapper = new QueryWrapper<>(ywContractBill); return ywContractBillMapper.selectCount(wrapper); } + + + + @Override + public void dealDayBillCode(){ + List<YwContractBill> ywContractBillList = ywContractBillMapper.selectJoinList(YwContractBill.class, + new MPJLambdaWrapper<YwContractBill>() + .selectAll(YwContractBill.class) + .select(" DATE(CREATE_DATE) as codeDate") + .isNull(YwContractBill::getCode) + .orderByAsc(YwContractBill::getId) + ); + if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywContractBillList)){ + List<String> codeDateList = ywContractBillList.stream().map(i->i.getCodeDate()).collect(Collectors.toList()); + if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(codeDateList)){ + Set<String> codeDateSet = new HashSet<String>(codeDateList); + for (String codeDate:codeDateSet) { + //鑾峰彇褰撳墠鏃ユ湡鐨勬暟鎹� + List<YwContractBill> codeDateBillList = + ywContractBillList.stream().filter(i->i.getCodeDate().equals(codeDate)).collect(Collectors.toList()); + if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isEmpty(codeDateBillList)){ + continue; + } + //鏌ヨ鏈�澶х殑鍗曞彿 + YwContractBill ywContractBill = ywContractBillMapper.selectOne(new QueryWrapper<YwContractBill>().lambda() + .isNotNull(YwContractBill::getCode) + .apply(" CREATE_DATE like '"+codeDate+"%' ") + .orderByDesc(YwContractBill::getId) + ); + Integer maxCode = Constants.ONE; + if(Objects.nonNull(ywContractBill)){ + maxCode = Integer.valueOf(ywContractBill.getCode().replace("ZD"+codeDate,"")); + } + for (YwContractBill contractBill:codeDateBillList) { + maxCode = maxCode + 1; + contractBill.setCode("ZD" + codeDate + "-" + StringUtils.leftPad(maxCode.toString() , 4,"0")); + ywContractBillMapper.update(null, new UpdateWrapper<YwContractBill>().lambda().set(YwContractBill::getCode,contractBill.getCode()) + .eq(YwContractBill::getId,ywContractBill.getId())); + } + } + } + } + } + + + } -- Gitblit v1.9.3