From 688be4ce73ddf710a0acb4769e8fdb7394116434 Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期一, 16 五月 2022 19:07:47 +0800
Subject: [PATCH] 优化合同功能

---
 service-store/src/main/java/com/java110/store/bmo/contract/impl/UpdateContractBMOImpl.java |  303 ++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 302 insertions(+), 1 deletions(-)

diff --git a/service-store/src/main/java/com/java110/store/bmo/contract/impl/UpdateContractBMOImpl.java b/service-store/src/main/java/com/java110/store/bmo/contract/impl/UpdateContractBMOImpl.java
old mode 100644
new mode 100755
index 6a87730..149a5e9
--- a/service-store/src/main/java/com/java110/store/bmo/contract/impl/UpdateContractBMOImpl.java
+++ b/service-store/src/main/java/com/java110/store/bmo/contract/impl/UpdateContractBMOImpl.java
@@ -3,21 +3,43 @@
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.java110.core.annotation.Java110Transactional;
+import com.java110.core.factory.GenerateCodeFactory;
+import com.java110.dto.RoomDto;
 import com.java110.dto.contract.ContractDto;
 import com.java110.dto.contractAttr.ContractAttrDto;
+import com.java110.dto.contractChangePlan.ContractChangePlanDto;
+import com.java110.dto.contractChangePlanDetail.ContractChangePlanDetailDto;
+import com.java110.dto.contractChangePlanRoom.ContractChangePlanRoomDto;
+import com.java110.dto.contractRoom.ContractRoomDto;
 import com.java110.dto.fee.FeeDto;
+import com.java110.dto.owner.OwnerRoomRelDto;
 import com.java110.dto.rentingPool.RentingPoolDto;
 import com.java110.dto.store.StoreDto;
 import com.java110.intf.common.IContractApplyUserInnerServiceSMO;
+import com.java110.intf.common.IContractChangeUserInnerServiceSMO;
+import com.java110.intf.community.IRoomInnerServiceSMO;
 import com.java110.intf.store.IContractAttrInnerServiceSMO;
+import com.java110.intf.store.IContractChangePlanDetailInnerServiceSMO;
+import com.java110.intf.store.IContractChangePlanInnerServiceSMO;
+import com.java110.intf.store.IContractChangePlanRoomInnerServiceSMO;
+import com.java110.intf.store.IContractFileInnerServiceSMO;
 import com.java110.intf.store.IContractInnerServiceSMO;
+import com.java110.intf.store.IContractRoomInnerServiceSMO;
+import com.java110.intf.user.IOwnerRoomRelInnerServiceSMO;
 import com.java110.intf.user.IRentingPoolInnerServiceSMO;
 import com.java110.po.contract.ContractPo;
 import com.java110.po.contractAttr.ContractAttrPo;
+import com.java110.po.contractChangePlan.ContractChangePlanPo;
+import com.java110.po.contractFile.ContractFilePo;
+import com.java110.po.contractRoom.ContractRoomPo;
+import com.java110.po.owner.OwnerRoomRelPo;
 import com.java110.po.rentingPool.RentingPoolPo;
+import com.java110.po.room.RoomPo;
 import com.java110.store.bmo.contract.IUpdateContractBMO;
+import com.java110.store.bmo.contractFile.IDeleteContractFileBMO;
 import com.java110.utils.constant.StatusConstant;
 import com.java110.utils.util.Assert;
+import com.java110.utils.util.BeanConvertUtil;
 import com.java110.utils.util.StringUtil;
 import com.java110.vo.ResultVo;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -41,6 +63,35 @@
     @Autowired
     private IContractApplyUserInnerServiceSMO contractApplyUserInnerServiceSMOImpl;
 
+    @Autowired
+    private IContractChangeUserInnerServiceSMO contractChangeUserInnerServiceSMOImpl;
+
+    @Autowired
+    private IContractChangePlanInnerServiceSMO contractChangePlanInnerServiceSMOImpl;
+
+    @Autowired
+    private IContractChangePlanDetailInnerServiceSMO contractChangePlanDetailInnerServiceSMOImpl;
+
+    @Autowired
+    private IContractChangePlanRoomInnerServiceSMO contractChangePlanRoomInnerServiceSMOImpl;
+
+    @Autowired
+    private IContractRoomInnerServiceSMO contractRoomInnerServiceSMOImpl;
+
+
+    @Autowired
+    private IContractFileInnerServiceSMO contractFileInnerServiceSMOImpl;
+
+    @Autowired
+    private IDeleteContractFileBMO deleteContractFileBMOImpl;
+
+
+    @Autowired
+    private IOwnerRoomRelInnerServiceSMO ownerRoomRelInnerServiceSMOImpl;
+
+    @Autowired
+    private IRoomInnerServiceSMO roomInnerServiceSMOImpl;
+
     /**
      * @param contractPo
      * @return 璁㈠崟鏈嶅姟鑳藉鎺ュ彈鐨勬姤鏂�
@@ -54,6 +105,22 @@
             return ResultVo.createResponseEntity(ResultVo.CODE_ERROR, "淇濆瓨澶辫触");
 
         }
+
+        //闄勪欢淇濆瓨--鍏堝垹闄ゅ師鏉ユ墍鏈夌殑闄勪欢鍐嶈繘琛屼繚瀛�
+        ContractFilePo contractFilePo = new ContractFilePo();
+        contractFilePo.setContractId(contractPo.getContractId());
+        deleteContractFileBMOImpl.delete(contractFilePo);
+
+        List<ContractFilePo> filePos = contractPo.getContractFilePo();
+        if (filePos != null) {
+            for (ContractFilePo file : filePos) {
+                if (file.getFileRealName().length() > 0 && file.getFileSaveName().length() > 0) {
+                    file.setContractId(contractPo.getContractId());
+                    contractFileInnerServiceSMOImpl.saveContractFile(file);
+                }
+            }
+        }
+
 
         noticeRentUpdateState(contractPo);
 
@@ -85,6 +152,7 @@
         List<ContractDto> contractDtos = contractInnerServiceSMOImpl.queryContracts(tmpContractDto);
         Assert.listOnlyOne(contractDtos, "鍚堝悓涓嶅瓨鍦�");
         contractDto.setStartUserId(contractDtos.get(0).getStartUserId());
+        contractDto.setNextUserId(reqJson.getString("nextUserId"));
 
         boolean isLastTask = contractApplyUserInnerServiceSMOImpl.completeTask(contractDto);
         if (isLastTask) {
@@ -93,16 +161,249 @@
             contractPo.setState(ContractDto.STATE_AUDIT_FINISH);
             contractPo.setStatusCd(StatusConstant.STATUS_CD_VALID);
             contractInnerServiceSMOImpl.updateContract(contractPo);
-        }else{ //淇敼涓哄鏍镐腑
+        } else { //淇敼涓哄鏍镐腑
             ContractPo contractPo = new ContractPo();
             contractPo.setContractId(contractDto.getContractId());
             contractPo.setState(ContractDto.STATE_AUDIT_DOING);
+            if ("1200".equals(reqJson.getString("state"))) {
+                contractPo.setState(ContractDto.STATE_FAIL);
+            }
             contractPo.setStatusCd(StatusConstant.STATUS_CD_VALID);
             contractInnerServiceSMOImpl.updateContract(contractPo);
         }
         return ResultVo.success();
     }
 
+    @Override
+    public ResponseEntity<String> needAuditContractPlan(ContractChangePlanDto contractChangePlanDto, JSONObject reqJson) {
+
+        //鏌ヨ鑰佺殑鍚堝悓淇℃伅
+        ContractDto contractDto = new ContractDto();
+        contractDto.setContractId(contractChangePlanDto.getContractId());
+        contractDto.setStoreId(contractChangePlanDto.getStoreId());
+        List<ContractDto> contractDtos = contractInnerServiceSMOImpl.queryContracts(contractDto);
+
+        Assert.listOnlyOne(contractDtos, "鍚堝悓涓嶅瓨鍦�");
+
+        ContractChangePlanDto tmpContractChangePlanDto = new ContractChangePlanDto();
+        tmpContractChangePlanDto.setPlanId(contractChangePlanDto.getPlanId());
+        tmpContractChangePlanDto.setStoreId(contractChangePlanDto.getStoreId());
+        List<ContractChangePlanDto> contractChangePlanDtos = contractChangePlanInnerServiceSMOImpl.queryContractChangePlans(tmpContractChangePlanDto);
+        Assert.listOnlyOne(contractChangePlanDtos, "鍚堝悓璁″垝涓嶅瓨鍦�");
+        contractChangePlanDto.setStartUserId(contractChangePlanDtos.get(0).getChangePerson());
+        contractChangePlanDto.setNextUserId(reqJson.getString("nextUserId"));
+
+        boolean isLastTask = contractChangeUserInnerServiceSMOImpl.completeTask(contractChangePlanDto);
+        if (isLastTask) {
+            ContractChangePlanPo contractChangePlanPo = new ContractChangePlanPo();
+            contractChangePlanPo.setPlanId(contractChangePlanDto.getPlanId());
+            contractChangePlanPo.setState(ContractDto.STATE_AUDIT_FINISH);
+            contractChangePlanPo.setStatusCd(StatusConstant.STATUS_CD_VALID);
+            contractChangePlanInnerServiceSMOImpl.updateContractChangePlan(contractChangePlanPo);
+            //淇敼鍚堝悓淇℃伅
+            ContractChangePlanDetailDto contractChangePlanDetailDto = new ContractChangePlanDetailDto();
+            contractChangePlanDetailDto.setPlanId(contractChangePlanDto.getPlanId());
+            contractChangePlanDetailDto.setStoreId(contractChangePlanDto.getStoreId());
+            contractChangePlanDetailDto.setOperate("ADD");
+            List<ContractChangePlanDetailDto> contractChangePlanDetailDtos =
+                    contractChangePlanDetailInnerServiceSMOImpl.queryContractChangePlanDetails(contractChangePlanDetailDto);
+
+            Assert.listOnlyOne(contractChangePlanDetailDtos, "鏁版嵁閿欒");
+            ContractPo contractPo = BeanConvertUtil.covertBean(contractChangePlanDetailDtos.get(0), ContractPo.class);
+
+            contractInnerServiceSMOImpl.updateContract(contractPo);
+            //瑙e喅鍚堝悓bug 鍙湁 璧勪骇鍙樻洿鏃� 鎿嶄綔 鍚堝悓鎴垮眿
+            if (ContractChangePlanDto.PLAN_TYPE_CHANGE_ROOM.equals(contractChangePlanDtos.get(0).getPlanType())) {
+                dealContractChangePlanRoom(contractChangePlanDto, contractDtos.get(0));
+            }
+
+        } else { //淇敼涓哄鏍镐腑
+            ContractChangePlanPo contractChangePlanPo = new ContractChangePlanPo();
+            contractChangePlanPo.setPlanId(contractChangePlanDto.getPlanId());
+            contractChangePlanPo.setState(ContractDto.STATE_AUDIT_DOING);
+            contractChangePlanPo.setStatusCd(StatusConstant.STATUS_CD_VALID);
+            contractChangePlanInnerServiceSMOImpl.updateContractChangePlan(contractChangePlanPo);
+        }
+        return ResultVo.success();
+    }
+
+    private void dealContractChangePlanRoom(ContractChangePlanDto contractChangePlanDto, ContractDto contractDto) {
+
+        //鏌ヨ鍚堝悓鎴垮眿
+        ContractRoomDto contractRoomDto = new ContractRoomDto();
+        contractRoomDto.setStoreId(contractChangePlanDto.getStoreId());
+        contractRoomDto.setContractId(contractDto.getContractId());
+        List<ContractRoomDto> oldContractRoomDtos = contractRoomInnerServiceSMOImpl.queryContractRooms(contractRoomDto);
+        // 鏌ヨ 鏄惁鏈夎祫浜у彉鏇�
+
+        ContractChangePlanRoomDto contractChangePlanRoomDto = new ContractChangePlanRoomDto();
+        contractChangePlanRoomDto.setPlanId(contractChangePlanDto.getPlanId());
+        contractChangePlanRoomDto.setStoreId(contractChangePlanDto.getStoreId());
+        contractChangePlanRoomDto.setOperate("ADD");
+
+        List<ContractChangePlanRoomDto> contractChangePlanRoomDtos
+                = contractChangePlanRoomInnerServiceSMOImpl.queryContractChangePlanRooms(contractChangePlanRoomDto);
+
+        if (contractChangePlanRoomDtos == null || contractChangePlanRoomDtos.size() < 1) {
+            //鍒犻櫎鑰佺殑鍏崇郴鍊�
+            doDelOldRoomRel(contractChangePlanRoomDtos, oldContractRoomDtos);
+            return;
+        }
+        //鍒犻櫎鑰佺殑鍏崇郴鍊�
+        doDelOldRoomRel(contractChangePlanRoomDtos, oldContractRoomDtos);
+        //澧炲姞
+        doAddRoomRel(contractDto, oldContractRoomDtos, contractChangePlanRoomDtos);
+
+
+
+
+    }
+
+    private void doAddRoomRel(ContractDto contractDto, List<ContractRoomDto> oldContractRoomDtos, List<ContractChangePlanRoomDto> contractChangePlanRoomDtos) {
+        //鍒犻櫎涔嬪墠鏁版嵁 鎻掑叆鏂版暟鎹�
+        ContractRoomPo contractRoomPo = null;
+        //鎻掑叆鏂扮殑鍏崇郴鍊�
+        for (ContractChangePlanRoomDto tmpContractChangePlanRoomDto : contractChangePlanRoomDtos) {
+            if (isOldRoom(tmpContractChangePlanRoomDto, oldContractRoomDtos)) {
+                continue;
+            }
+            contractRoomPo = new ContractRoomPo();
+            contractRoomPo.setContractId(contractChangePlanRoomDtos.get(0).getContractId());
+            contractRoomPo.setStoreId(contractChangePlanRoomDtos.get(0).getStoreId());
+            contractRoomPo.setCrId(GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_crId));
+            contractRoomPo.setOwnerId(tmpContractChangePlanRoomDto.getOwnerId());
+            contractRoomPo.setOwnerName(tmpContractChangePlanRoomDto.getOwnerName());
+            contractRoomPo.setRoomId(tmpContractChangePlanRoomDto.getRoomId());
+            contractRoomPo.setRoomName(tmpContractChangePlanRoomDto.getRoomName());
+            contractRoomInnerServiceSMOImpl.saveContractRoom(contractRoomPo);
+
+            //鍒蜂笟涓�
+            OwnerRoomRelDto ownerRoomRelDto = new OwnerRoomRelDto();
+            ownerRoomRelDto.setRoomId(contractRoomPo.getRoomId());
+            List<OwnerRoomRelDto> ownerRoomRelDtos = ownerRoomRelInnerServiceSMOImpl.queryOwnerRoomRels(ownerRoomRelDto);
+
+            if (ownerRoomRelDtos != null && ownerRoomRelDtos.size() > 0) { // 璇存槑涓氫富娌℃湁鍙戠敓鍙樺寲锛屽悗缁伐浣滀笉鍋氬鐞�
+                if (contractDto.getObjId().equals(ownerRoomRelDtos.get(0).getOwnerId())) {
+                    continue;
+                }
+            }
+
+            //缁戝畾鍏崇郴
+            String relId = GenerateCodeFactory.getGeneratorId(GenerateCodeFactory.CODE_PREFIX_relId);
+            OwnerRoomRelPo ownerRoomRelPo = new OwnerRoomRelPo();
+            ownerRoomRelPo.setEndTime(contractDto.getEndTime());
+            ownerRoomRelPo.setStartTime(contractDto.getStartTime());
+            ownerRoomRelPo.setOwnerId(contractDto.getObjId());
+            ownerRoomRelPo.setRelId(relId);
+            ownerRoomRelPo.setRemark("绛捐鍚堝悓鑷姩缁戝畾");
+            ownerRoomRelPo.setRoomId(contractRoomPo.getRoomId());
+            ownerRoomRelPo.setState("2001");
+            ownerRoomRelPo.setUserId("-1");
+            ownerRoomRelPo.setOperate("ADD");
+            ownerRoomRelPo.setbId("-1");
+            ownerRoomRelInnerServiceSMOImpl.saveBusinessOwnerRoomRels(ownerRoomRelPo);
+
+            ownerRoomRelPo = new OwnerRoomRelPo();
+            ownerRoomRelPo.setEndTime(contractDto.getEndTime());
+            ownerRoomRelPo.setStartTime(contractDto.getStartTime());
+            ownerRoomRelPo.setOwnerId(contractDto.getObjId());
+            ownerRoomRelPo.setRelId(relId);
+            ownerRoomRelPo.setRemark("绛捐鍚堝悓鑷姩缁戝畾");
+            ownerRoomRelPo.setRoomId(contractRoomPo.getRoomId());
+            ownerRoomRelPo.setState("2001");
+            ownerRoomRelPo.setUserId("-1");
+            ownerRoomRelInnerServiceSMOImpl.saveOwnerRoomRels(ownerRoomRelPo);
+
+            //淇敼鎴垮眿鐘舵��
+            RoomPo roomPo = new RoomPo();
+            roomPo.setRoomId(contractRoomPo.getRoomId());
+            roomPo.setState(RoomDto.STATE_SELL);
+            roomPo.setStatusCd(StatusConstant.STATUS_CD_VALID);
+            roomInnerServiceSMOImpl.updateRooms(roomPo);
+            //鍒犻櫎鑰佺殑
+            if (ownerRoomRelDtos != null && ownerRoomRelDtos.size() > 0) {
+                ownerRoomRelPo = new OwnerRoomRelPo();
+                ownerRoomRelPo.setStatusCd(StatusConstant.STATUS_CD_INVALID);
+                ownerRoomRelPo.setRelId(ownerRoomRelDtos.get(0).getRelId());
+                ownerRoomRelInnerServiceSMOImpl.updateOwnerRoomRels(ownerRoomRelPo);
+                ownerRoomRelPo = BeanConvertUtil.covertBean(ownerRoomRelDtos.get(0), OwnerRoomRelPo.class);
+                ownerRoomRelPo.setbId("-1");
+                ownerRoomRelPo.setOperate("DEL");
+                ownerRoomRelInnerServiceSMOImpl.saveBusinessOwnerRoomRels(ownerRoomRelPo);
+            }
+        }
+    }
+
+    private void doDelOldRoomRel(List<ContractChangePlanRoomDto> contractChangePlanRoomDtos, List<ContractRoomDto> oldContractRoomDtos) {
+        ContractRoomPo contractRoomPo;
+        OwnerRoomRelPo ownerRoomRelPo = null;
+        for (ContractRoomDto oldContractRoomDto : oldContractRoomDtos) {
+            if (isDelOldRoom(oldContractRoomDto, contractChangePlanRoomDtos)) {
+                continue;
+            }
+            contractRoomPo = new ContractRoomPo();
+            contractRoomPo.setContractId(oldContractRoomDtos.get(0).getContractId());
+            contractRoomPo.setStoreId(oldContractRoomDtos.get(0).getStoreId());
+            contractRoomPo.setCrId(oldContractRoomDto.getCrId());
+            contractRoomInnerServiceSMOImpl.deleteContractRoom(contractRoomPo);
+
+            //鍒蜂笟涓�
+            OwnerRoomRelDto ownerRoomRelDto = new OwnerRoomRelDto();
+            ownerRoomRelDto.setRoomId(oldContractRoomDto.getRoomId());
+            List<OwnerRoomRelDto> ownerRoomRelDtos = ownerRoomRelInnerServiceSMOImpl.queryOwnerRoomRels(ownerRoomRelDto);
+
+            if (ownerRoomRelDtos == null || ownerRoomRelDtos.size() < 1) { // 璇存槑鎴垮眿娌℃湁涓氫富
+                continue;
+            }
+            //鍒犻櫎鍏崇郴
+            ownerRoomRelPo = new OwnerRoomRelPo();
+            ownerRoomRelPo.setStatusCd(StatusConstant.STATUS_CD_INVALID);
+            ownerRoomRelPo.setRelId(ownerRoomRelDtos.get(0).getRelId());
+            ownerRoomRelInnerServiceSMOImpl.updateOwnerRoomRels(ownerRoomRelPo);
+
+            //鎻掑叆鍒犻櫎鍏崇郴
+            ownerRoomRelPo = BeanConvertUtil.covertBean(ownerRoomRelDtos.get(0), OwnerRoomRelPo.class);
+            ownerRoomRelPo.setbId("-1");
+            ownerRoomRelPo.setOperate("DEL");
+            ownerRoomRelInnerServiceSMOImpl.saveBusinessOwnerRoomRels(ownerRoomRelPo);
+
+            //淇敼鎴垮眿鐘舵��
+            RoomPo roomPo = new RoomPo();
+            roomPo.setRoomId(oldContractRoomDto.getRoomId());
+            roomPo.setState(RoomDto.STATE_FREE);
+            roomPo.setStatusCd(StatusConstant.STATUS_CD_VALID);
+            roomInnerServiceSMOImpl.updateRooms(roomPo);
+        }
+    }
+
+    private boolean isDelOldRoom(ContractRoomDto oldContractRoomDto, List<ContractChangePlanRoomDto> contractChangePlanRoomDtos) {
+        if (contractChangePlanRoomDtos == null || contractChangePlanRoomDtos.size() < 1) {
+            return false;
+        }
+
+        for (ContractChangePlanRoomDto contractChangePlanRoomDto : contractChangePlanRoomDtos) {
+            if (contractChangePlanRoomDto.getRoomId().equals(oldContractRoomDto.getRoomId())) {
+                return true;
+            }
+        }
+
+        return false;
+    }
+
+    private boolean isOldRoom(ContractChangePlanRoomDto tmpContractChangePlanRoomDto, List<ContractRoomDto> oldContractRoomDtos) {
+        if (oldContractRoomDtos == null || oldContractRoomDtos.size() < 1) {
+            return false;
+        }
+
+        for (ContractRoomDto contractRoomDto : oldContractRoomDtos) {
+            if (tmpContractChangePlanRoomDto.getRoomId().equals(contractRoomDto.getRoomId())) {
+                return true;
+            }
+        }
+
+        return false;
+    }
+
     private void updateContractAttr(JSONObject jsonObject, ContractPo contractPo) {
         ContractAttrDto contractAttrDto = new ContractAttrDto();
         contractAttrDto.setContractId(contractPo.getContractId());

--
Gitblit v1.8.0