From a2299a6d4a6f99e9c11132138f5d3e9ec68f03ea Mon Sep 17 00:00:00 2001
From: jiangping <jp@doumee.com>
Date: 星期五, 06 六月 2025 19:19:34 +0800
Subject: [PATCH] 开发更新

---
 server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/YwContractServiceImpl.java |  411 ++++++++++++++++++++++++++++++++++++++++++++++++----------
 1 files changed, 337 insertions(+), 74 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 25b1402..383ca4c 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());
@@ -84,15 +84,14 @@
         model.setEditor(model.getCreator());
         if(model.getStartDate().getTime() > System.currentTimeMillis()){
             model.setStatus(Constants.ZERO);
-        }else if(model.getStartDate().getTime() <= System.currentTimeMillis() && model.getEndDate().getTime() > System.currentTimeMillis()){
+        }else if(model.getStartDate().getTime() <= System.currentTimeMillis() && Utils.Date.getEnd(model.getEndDate()).getTime() > System.currentTimeMillis()){
             model.setStatus(Constants.ONE);
         }else{
             model.setStatus(Constants.TWO);
         }
-        model.setStatus(Constants.ZERO);//寰呮墽琛�
         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("鍚堝悓鎽樿锛�","")+"銆�");//璁板綍鏂板缓鏃ュ織
@@ -113,6 +112,12 @@
             t.setEditor(model.getCreator());
             t.setType(Constants.ZERO);
             list.add(t);
+        }
+        if(Constants.equalsInteger(model.getStatus(),Constants.ONE)){
+            //鏇存柊鎴挎簮鏁版嵁涓虹璧佷腑
+            roomMapper.update(new UpdateWrapper<YwRoom>().lambda().set(YwRoom::getLeaseNowStatus,Constants.ONE)
+                    .in(YwRoom::getId,model.getRoomList().stream().map(i->i.getId()).collect(Collectors.toList()))
+            );
         }
         ywContractRoomMapper.insert(list);
     }
@@ -163,7 +168,7 @@
         isParamValidForBill(model);
         model.setCreateDate(new Date());
         model.setEditDate(model.getCreateDate());
-        dealDetailListBiz(model);//澶勭悊鏉℃淇℃伅
+        dealDetailListBiz(model,true);//澶勭悊鏉℃淇℃伅
         return model.getBillList();
     }
 
@@ -178,8 +183,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(),"瀵逛笉璧凤紝鍚堝悓鏈夋晥鏈熺粨鏉熸椂闂翠笉寰楁棭浜庡紑濮嬫椂闂达紒");
         }
 
@@ -212,7 +216,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(),"瀵逛笉璧凤紝绉熻祦鏉℃鏈夋晥鏈熺粨鏉熸椂闂翠笉寰楁棭浜庡紑濮嬫椂闂达紒");
                 }
@@ -343,6 +347,13 @@
     @Transactional(rollbackFor = {BusinessException.class,Exception.class})
     public  Integer backRent(YwContract param){
         isParamValidBackRent(param);
+        YwContract model = ywContractMapper.selectById(param.getId());
+        if(Objects.isNull(model)){
+            throw new BusinessException(ResponseStatus.DATA_EMPTY);
+        }
+        if(!(model.getStartDate().getTime()<=param.getBtDate().getTime()&&model.getEndDate().getTime()>=param.getBtDate().getTime())){
+            throw new BusinessException(ResponseStatus.NOT_ALLOWED.getCode(),"閫�绉熸棩鏈熼敊璇紝璇锋鏌ラ��绉熸棩鏈熼渶鍦ㄥ悎鍚屾棩鏈熷唴锛�");
+        }
         param.setEditDate(new Date());
         param.setEditor(param.getLoginUserInfo().getId());
         //澶勭悊
@@ -366,30 +377,47 @@
         update.setBtRemark(getbackRentRemarkByParam(param));
         ywContractMapper.updateById(update);
         dealLogBiz(param,Constants.YwLogType.CONTRACT_BACK, param.getLoginUserInfo().getRealname(),getbackRentLogByParam(param));
+        //濡傛灉閫�绉熸棩鏈熷皬浜庡綋鍓嶆棩鏈� 鍒欑洿鎺ラ噴鏀炬埧婧愪俊鎭� 鏈璧�
+        if(Utils.Date.getEnd(param.getBtDate()).getTime()<System.currentTimeMillis()){
+            List<YwContractRoom> contractRoomList = ywContractRoomMapper.selectList(new QueryWrapper<YwContractRoom>().lambda()
+                    .eq(YwContractRoom::getContractId, param.getId()));
+            if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(contractRoomList)){
+                //鏇存柊鎴挎簮鏁版嵁涓烘湭绉熻祦
+                roomMapper.update(new UpdateWrapper<YwRoom>().lambda().set(YwRoom::getLeaseNowStatus,Constants.ZERO)
+                        .in(YwRoom::getId,contractRoomList.stream().map(i->i.getRoomId()).collect(Collectors.toList()))
+                );
+            }
+        }
         return param.getId();
     }
 
 
     @Override
     public  void dealTimeOut(){
-        //瀹氭椂澶勭悊鍚堝悓鎵ц涓�
-        ywContractMapper.update(new UpdateWrapper<YwContract>()
-                .lambda()
-                .set(YwContract::getStatus,Constants.ONE)
-                .set(YwContract::getEditDate,DateUtil.getCurrDateTime())
+
+        List<YwContract> listA = ywContractMapper.selectList(new QueryWrapper<YwContract>().lambda()
                 .eq(YwContract::getIsdeleted,Constants.ZERO)
                 .in(YwContract::getStatus,Constants.ZERO)
                 .apply(" START_DATE < NOW()  AND END_DATE > NOW() ")
         );
-        //瀹氭椂澶勭悊鍚堝悓宸茶繃鏈�
-        ywContractMapper.update(new UpdateWrapper<YwContract>()
-                        .lambda()
-                .set(YwContract::getStatus,Constants.TWO)
-                .set(YwContract::getEditDate,DateUtil.getCurrDateTime())
-                .eq(YwContract::getIsdeleted,Constants.ZERO)
-                .in(YwContract::getStatus,Constants.ONE,Constants.ZERO)
-                .apply(" END_DATE < NOW() ")
-        );
+        if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(listA)){
+            //瀹氭椂澶勭悊鍚堝悓鎵ц涓�
+            ywContractMapper.update(new UpdateWrapper<YwContract>()
+                    .lambda()
+                    .set(YwContract::getStatus,Constants.ONE)
+                    .set(YwContract::getEditDate,DateUtil.getCurrDateTime())
+                    .in(YwContract::getId,listA.stream().map(i->i.getId()).collect(Collectors.toList()))
+            );
+
+            List<YwContractRoom> contractRoomList = ywContractRoomMapper.selectList(new QueryWrapper<YwContractRoom>().lambda().in(YwContractRoom::getContractId,
+                    listA.stream().map(i->i.getId()).collect(Collectors.toList())));
+            if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(contractRoomList)){
+                //鏇存柊鎴挎簮鏁版嵁涓虹璧佷腑
+                roomMapper.update(new UpdateWrapper<YwRoom>().lambda().set(YwRoom::getLeaseNowStatus,Constants.ONE)
+                        .in(YwRoom::getId,contractRoomList.stream().map(i->i.getRoomId()).collect(Collectors.toList()))
+                );
+            }
+        }
 
     }
 
@@ -400,6 +428,7 @@
         List<YwContractBill> noBills = new ArrayList<>();//涓嶉渶瑕佺粨绠楃殑璐﹀崟
         List<YwContractBill> yjBills = new ArrayList<>();//鎶奸噾璐﹀崟
         List<YwContractBill> canBills = new ArrayList<>();//鍙��绉熶慨鏀规暟鎹�
+        Integer canBillCount = Constants.ZERO;
         List<YwContractBill> allBills = ywContractBillMapper.selectList(new QueryWrapper<YwContractBill>().
                 select("*," +
                         "( select ifnull(sum(case when yw.REVENUE_TYPE = 0 then yw.ACT_RECEIVABLE_FEE  else  -yw.ACT_RECEIVABLE_FEE end),0) from  yw_contract_revenue yw where yw.bill_id = yw_contract_bill.id and yw.status = 0 and yw.isdeleted = 0 ) as  actReceivableFee " )
@@ -421,6 +450,7 @@
                         ||Constants.equalsInteger(bill.getPayStatus(),Constants.THREE)){
                     if(bill.getStartDate().getTime()<=param.getBtDate().getTime()){
                         canBills.add(bill);
+                        canBillCount = canBillCount + 1 ;
                     }else{
                         //濡傛灉杩樻病寮�濮嬶紝璐﹀崟鐩存帴鍏抽棴
                         closeBills.add(bill);
@@ -432,9 +462,11 @@
                         noBills.add(bill);
                     }else{
                         canBills.add(bill);
+                        canBillCount = canBillCount + 1 ;
                     }
                 }else  if(Constants.equalsInteger(bill.getPayStatus(),Constants.TWO) ){
                      canBills.add(bill);
+                    canBillCount = canBillCount + 1 ;
                 }
             }
         }
@@ -462,14 +494,20 @@
                     if(fee.compareTo(new BigDecimal(0))== 0){
                         //濡傛灉璐圭敤姝eソ锛屽垯淇敼璐﹀崟淇℃伅涓哄凡缁撴竻
                         b.setPayStatus(Constants.ONE);
-                    }else if(fee.compareTo(new BigDecimal(0))> 0){
+                        canBillCount = canBillCount - 1 ;
+                    }else if(fee.compareTo(new BigDecimal(0))< 0){
                         //濡傛灉闇�瑕佽繘琛岄��娆撅紝鏇存柊璐﹀崟淇℃伅涓哄緟閫�娆�
                         b.setPayStatus(Constants.FOUR);
-                    }else if(fee.compareTo(new BigDecimal(0)) < 0){
-                        //濡傛灉璐﹀崟杩樻湁娆惧緟鏀讹紝鍒欎繚鎸佺姸鎬佷笉鍙�
+                    }else if(fee.compareTo(new BigDecimal(0)) > 0){
+                        //濡傛灉璐﹀崟杩樻湁娆惧緟鏀讹紝鍒欐洿鏂拌处鍗曚负寰呮敹娆�
+                        if(b.getPayStatus()==Constants.ZERO){
+                            b.setPayStatus(Constants.ZERO);
+                        }else if(b.getPayStatus()!=Constants.TWO){
+                            b.setPayStatus(Constants.TWO);
+                        }
                     }
+                    b.setReceivableFee(editBill.getReceivableFee());
                 }
-                b.setReceivableFee(editBill.getReceivableFee());
                 b.setEditDate(param.getEditDate());
                 b.setEditor(param.getEditor());
                 b.setBtActDate(param.getBtActDate());
@@ -488,6 +526,8 @@
             for(YwContractBill addBill : param.getAddBillList()){
                 addBill.setIsdeleted(Constants.ZERO);
                 addBill.setContractId(param.getId());
+                addBill.setCreateDate(new Date());
+                addBill.setCreator(param.getEditor());
                 addBill.setType(Constants.TWO);
                 addBill.setStatus(Constants.ZERO);
                 addBill.setTotleFee(addBill.getReceivableFee());
@@ -549,7 +589,7 @@
                 }
             }
         }
-        param.setBtWaitBill(canBills.size() + newBills.size()+yjNoBills);//鏈竻绠楃殑璐﹀崟鏁伴噺
+        param.setBtWaitBill(canBillCount  + newBills.size()+yjNoBills);//鏈竻绠楃殑璐﹀崟鏁伴噺
         param.setBtCLoseBill(closeBills.size());
         param.setBtFee(totalBackFee);
     }
@@ -599,7 +639,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;
@@ -639,7 +683,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.ONE))&& 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);
+            }
+        }
+
     }
 
     /**
@@ -701,13 +828,19 @@
         }
         int num =1;
         for(int i=0;i<billList1.size();i++){
+            if(Constants.formatBigdecimal(billList1.get(i).getReceivableFee()).compareTo(new BigDecimal(0)) == 0){
+                billList1.get(i).setPayStatus(Constants.ONE);
+            }
             if(Constants.equalsInteger(billList1.get(i).getCostType(),Constants.ZERO)){
                 billList1.get(i).setSortnum(num);
                 num++;
             }
         }
         for(int i=0;i<billList2.size();i++){
-            if(Constants.equalsInteger(billList1.get(i).getCostType(),Constants.ONE)) {
+            if(Constants.formatBigdecimal(billList2.get(i).getReceivableFee()).compareTo(new BigDecimal(0)) == 0){
+                billList2.get(i).setPayStatus(Constants.ONE);
+            }
+            if(Constants.equalsInteger(billList2.get(i).getCostType(),Constants.ONE)) {
                 billList2.get(i).setSortnum(num);
                 num++;
             }
@@ -1031,8 +1164,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 )
@@ -1068,7 +1200,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()){
@@ -1176,7 +1308,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
@@ -1253,7 +1431,7 @@
                 .selectAs(YwCustomer::getName, YwContract::getRenterName)
                 .selectAs(YwProject::getName, YwContract::getProjectName)
                 .select("t3.realname", YwContract::getCreatorName)
-                .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)
                 .leftJoin(Company.class, Company::getId, YwContract::getCompanyId)
                 .leftJoin(SystemUser.class, SystemUser::getId, YwContract::getUserId)
                 .leftJoin(SystemUser.class, SystemUser::getId, YwContract::getCreator)
@@ -1264,38 +1442,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;
     }
@@ -1314,14 +1492,12 @@
         //鏌ヨ璐﹀崟闆嗗悎
         model.setBillList(ywContractBillMapper.selectJoinList(YwContractBill.class,new MPJLambdaWrapper<YwContractBill>()
                 .selectAll(YwContractBill.class )
-                //.select(" ( select ifnull(sum(case when yw.REVENUE_TYPE = 0 then yw.ACT_RECEIVABLE_FEE  else  -yw.ACT_RECEIVABLE_FEE end),0) from  yw_contract_revenue yw where yw.bill_id = t.id and yw.status = 0 and yw.isdeleted = 0 ) as  actReceivableFee  ")
                 .select(" ( select ifnull( sum( CASE WHEN t.bill_type = 0 and yw.REVENUE_TYPE = 0 THEN yw.ACT_RECEIVABLE_FEE when  t.bill_type = 0 and yw.REVENUE_TYPE = 1 then -yw.ACT_RECEIVABLE_FEE  when t.bill_type = 1 and yw.REVENUE_TYPE = 0 then -yw.ACT_RECEIVABLE_FEE else  yw.ACT_RECEIVABLE_FEE END),0) from  yw_contract_revenue yw where yw.bill_id = t.id and yw.status = 0 and yw.isdeleted = 0 ) as  actReceivableFee  ")
                 .eq(  YwContractBill::getContractId,model.getId())
                 .eq(YwContractBill::getIsdeleted,Constants.ZERO)
                 .orderByAsc(YwContractBill::getSortnum,YwContractBill::getCreateDate)));
         for (YwContractBill ywContractBill:model.getBillList()) {
             ywContractBill.setNeedReceivableFee(ywContractBill.getReceivableFee());
-//            ywContractBill.setNeedReceivableFee(ywContractBill.getReceivableFee().subtract(ywContractBill.getActReceivableFee()));
         }
         model.setCanBackRentBills(new ArrayList<>());
         long nowStart = Utils.Date.getStart(date).getTime();
@@ -1417,7 +1593,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());
@@ -1430,6 +1607,9 @@
         if (pageWrap.getModel().getCreateDate() != null) {
             queryWrapper.ge(YwContract::getCreateDate, Utils.Date.getStart(pageWrap.getModel().getCreateDate()));
             queryWrapper.le(YwContract::getCreateDate, Utils.Date.getEnd(pageWrap.getModel().getCreateDate()));
+        }
+        if (pageWrap.getModel().getStatusList() != null) {
+            queryWrapper.in(YwContract::getStatus, pageWrap.getModel().getStatusList());
         }
         if (pageWrap.getModel().getEditor() != null) {
             queryWrapper.eq(YwContract::getEditor, pageWrap.getModel().getEditor());
@@ -1513,10 +1693,6 @@
             queryWrapper.le(YwContract::getWyFreeEndDate, Utils.Date.getEnd(pageWrap.getModel().getWyFreeEndDate()));
         }
 
-
-
-
-
         if (pageWrap.getModel().getZlTotalFee() != null) {
             queryWrapper.eq(YwContract::getZlTotalFee, pageWrap.getModel().getZlTotalFee());
         }
@@ -1526,6 +1702,12 @@
         if (pageWrap.getModel().getCompanyName() != null) {
             queryWrapper.like(Company::getName, pageWrap.getModel().getCompanyName());
         }
+        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 );
@@ -1534,6 +1716,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;
@@ -1544,4 +1748,63 @@
         QueryWrapper<YwContract> wrapper = new QueryWrapper<>(ywContract);
         return ywContractMapper.selectCount(wrapper);
     }
+
+
+    /**
+     * 鍒版湡鍚堝悓 鏈彂璧烽��绉熺殑杩涜鏁版嵁璋冩暣 鎶婂悎鍚屼笅鐨勬埧婧愰噴鏀� 瀹氭椂鏃堕棿闇�瑕佸湪姣忓ぉ鏅氫笂12鐐瑰墠
+     */
+    @Override
+    public void updRoomLeaseNowStatus(){
+
+        //瀹氭椂澶勭悊鍚堝悓宸茶繃鏈�
+        List<YwContract> ywContractList = ywContractMapper.selectList(new QueryWrapper<YwContract>().lambda()
+                .eq(YwContract::getIsdeleted,Constants.ZERO)
+                .in(YwContract::getStatus,Constants.ONE,Constants.ZERO)
+                .apply(" DATE(END_DATE) = CURRENT_DATE ")
+        );
+
+        if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywContractList)){
+            ywContractMapper.update(new UpdateWrapper<YwContract>()
+                    .lambda()
+                    .set(YwContract::getStatus,Constants.TWO)
+                    .set(YwContract::getEditDate,DateUtil.getCurrDateTime())
+                    .in(YwContract::getId,ywContractList.stream().map(i->i.getId()).collect(Collectors.toList()))
+            );
+
+
+            List<YwContractRoom> contractRoomList = ywContractRoomMapper.selectList(new QueryWrapper<YwContractRoom>().lambda().in(YwContractRoom::getContractId,
+                    ywContractList.stream().map(i->i.getId()).collect(Collectors.toList())));
+            if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(contractRoomList)){
+                //鏇存柊鎴挎簮鏁版嵁涓虹璧佷腑
+                roomMapper.update(new UpdateWrapper<YwRoom>().lambda().set(YwRoom::getLeaseNowStatus,Constants.ZERO)
+                        .in(YwRoom::getId,contractRoomList.stream().map(i->i.getRoomId()).collect(Collectors.toList()))
+                );
+            }
+        }
+    }
+
+
+    /**
+     * 閫�绉熶腑/宸查��绉熷悎鍚� 鎶婂埌浜嗛��绉熸棩鏈熸椂闂寸殑鏁版嵁 杩涜鎴挎簮閲婃斁 瀹氭椂鏃堕棿闇�瑕佸湪姣忓ぉ鏅氫笂12鐐瑰墠
+     */
+    @Override
+    public void updRentContractStatus(){
+        List<YwContract> ywContractList = ywContractMapper.selectList(new QueryWrapper<YwContract>().lambda()
+                .eq(YwContract::getIsdeleted,Constants.ZERO)
+                .in(YwContract::getStatus,Constants.THREE,Constants.FOUR)
+                .eq(YwContract::getBtDate,DateUtil.getCurrDate())
+        );
+        if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(ywContractList)){
+            List<YwContractRoom> contractRoomList = ywContractRoomMapper.selectList(new QueryWrapper<YwContractRoom>().lambda().in(YwContractRoom::getContractId,
+                    ywContractList.stream().map(i->i.getId()).collect(Collectors.toList())));
+            if(com.github.xiaoymin.knife4j.core.util.CollectionUtils.isNotEmpty(contractRoomList)){
+                //鏇存柊鎴挎簮鏁版嵁涓哄緟绉熻祦
+                roomMapper.update(new UpdateWrapper<YwRoom>().lambda().set(YwRoom::getLeaseNowStatus,Constants.ZERO)
+                        .in(YwRoom::getId,contractRoomList.stream().map(i->i.getRoomId()).collect(Collectors.toList()))
+                );
+            }
+        }
+    }
+
+
 }

--
Gitblit v1.9.3