From dd6687b118561100e1677e88a9c2f5842a54c531 Mon Sep 17 00:00:00 2001
From: jialh <1972868360@qq.com>
Date: 星期四, 16 四月 2026 18:14:14 +0800
Subject: [PATCH] 水电话费
---
service-store/src/main/java/com/java110/store/bmo/contract/impl/UpdateContractBMOImpl.java | 553 +++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 550 insertions(+), 3 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 b7a7e66..b30ca51
--- 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
@@ -1,13 +1,54 @@
package com.java110.store.bmo.contract.impl;
+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.room.RoomDto;
+import com.java110.dto.contract.ContractDto;
+import com.java110.dto.contract.ContractAttrDto;
+import com.java110.dto.contract.ContractChangePlanDto;
+import com.java110.dto.contract.ContractChangePlanDetailDto;
+import com.java110.dto.contract.ContractChangePlanRoomDto;
+import com.java110.dto.contract.ContractRoomDto;
+import com.java110.dto.fee.FeeDto;
+import com.java110.dto.owner.OwnerRoomRelDto;
+import com.java110.dto.renting.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.contract.ContractAttrPo;
+import com.java110.po.contract.ContractChangePlanPo;
+import com.java110.po.contract.ContractFilePo;
+import com.java110.po.contract.ContractRoomPo;
+import com.java110.po.owner.OwnerRoomRelPo;
+import com.java110.po.renting.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.DateUtil;
+import com.java110.utils.util.StringUtil;
import com.java110.vo.ResultVo;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Service;
+
+import java.util.Date;
+import java.util.List;
@Service("updateContractBMOImpl")
public class UpdateContractBMOImpl implements IUpdateContractBMO {
@@ -15,20 +56,526 @@
@Autowired
private IContractInnerServiceSMO contractInnerServiceSMOImpl;
+ @Autowired
+ private IContractAttrInnerServiceSMO contractAttrInnerServiceSMOImpl;
+
+ @Autowired
+ private IRentingPoolInnerServiceSMO rentingPoolInnerServiceSMOImpl;
+
+ @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 璁㈠崟鏈嶅姟鑳藉鎺ュ彈鐨勬姤鏂�
*/
@Java110Transactional
- public ResponseEntity<String> update(ContractPo contractPo) {
+ public ResponseEntity<String> update(ContractPo contractPo, JSONObject reqJson) {
int flag = contractInnerServiceSMOImpl.updateContract(contractPo);
- if (flag > 0) {
+ if (flag < 1) {
+ 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);
+
+ if (!reqJson.containsKey("contractTypeSpecs")) {
return ResultVo.createResponseEntity(ResultVo.CODE_OK, "淇濆瓨鎴愬姛");
}
- return ResultVo.createResponseEntity(ResultVo.CODE_ERROR, "淇濆瓨澶辫触");
+
+ JSONArray contractTypeSpecs = reqJson.getJSONArray("contractTypeSpecs");
+
+ if (contractTypeSpecs.size() < 1) {
+ return ResultVo.createResponseEntity(ResultVo.CODE_OK, "淇濆瓨鎴愬姛");
+ }
+
+ for (int typeSpecIndex = 0; typeSpecIndex < contractTypeSpecs.size(); typeSpecIndex++) {
+ updateContractAttr(contractTypeSpecs.getJSONObject(typeSpecIndex), contractPo);
+ }
+
+ return ResultVo.createResponseEntity(ResultVo.CODE_OK, "淇濆瓨鎴愬姛");
+
+ }
+
+ @Java110Transactional
+ public ResponseEntity<String> update(ContractDto contractPo, JSONObject reqJson) {
+
+ int flag = contractInnerServiceSMOImpl.updateContract(contractPo);
+
+ if (flag < 1) {
+ 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);
+
+ if (!reqJson.containsKey("contractTypeSpecs")) {
+ return ResultVo.createResponseEntity(ResultVo.CODE_OK, "淇濆瓨鎴愬姛");
+ }
+
+
+ JSONArray contractTypeSpecs = reqJson.getJSONArray("contractTypeSpecs");
+
+ if (contractTypeSpecs.size() < 1) {
+ return ResultVo.createResponseEntity(ResultVo.CODE_OK, "淇濆瓨鎴愬姛");
+ }
+
+ for (int typeSpecIndex = 0; typeSpecIndex < contractTypeSpecs.size(); typeSpecIndex++) {
+ updateContractAttr(contractTypeSpecs.getJSONObject(typeSpecIndex), contractPo);
+ }
+
+ return ResultVo.createResponseEntity(ResultVo.CODE_OK, "淇濆瓨鎴愬姛");
+
+ }
+ @Override
+ public ResponseEntity<String> needAuditContract(ContractDto contractDto, JSONObject reqJson) {
+
+ ContractDto tmpContractDto = new ContractDto();
+ tmpContractDto.setContractId(contractDto.getContractId());
+ tmpContractDto.setStoreId(contractDto.getStoreId());
+ 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) {
+ ContractPo contractPo = new ContractPo();
+ contractPo.setContractId(contractDto.getContractId());
+ contractPo.setState(ContractDto.STATE_AUDIT_FINISH);
+ contractPo.setStatusCd(StatusConstant.STATUS_CD_VALID);
+ contractInnerServiceSMOImpl.updateContract(contractPo);
+ } 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);
+ //todo 瑙ｅ喅鍚堝悓bug 鍙湁 璧勪骇鍙樻洿鏃� 鎿嶄綔 鍚堝悓鎴垮眿
+ if (ContractChangePlanDto.PLAN_TYPE_CHANGE_ROOM.equals(contractChangePlanDtos.get(0).getPlanType())) {
+ dealContractChangePlanRoom(contractChangePlanDto, contractDtos.get(0));
+ }
+
+ //todo 濡傛灉鏄鏈熷彉鏇存椂 灏嗘埧灞嬬殑鏃堕棿淇敼涓哄彉鏇村悗鐨勬椂闂�
+ if (ContractChangePlanDto.PLAN_TYPE_CHANGE_RENT_DATE.equals(contractChangePlanDtos.get(0).getPlanType())) {
+ changeRoomEndTime(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();
+ }
+
+ /**
+ * 淇敼鎴垮眿鐨勭鏈�
+ *
+ * @param contractChangePlanDto
+ * @param contractDto
+ */
+ private void changeRoomEndTime(ContractChangePlanDto contractChangePlanDto, ContractDto contractDto) {
+
+ //鏌ヨ鍚堝悓鎴垮眿
+ ContractRoomDto contractRoomDto = new ContractRoomDto();
+ contractRoomDto.setStoreId(contractChangePlanDto.getStoreId());
+ contractRoomDto.setContractId(contractDto.getContractId());
+ List<ContractRoomDto> oldContractRoomDtos = contractRoomInnerServiceSMOImpl.queryContractRooms(contractRoomDto);
+ if (oldContractRoomDtos == null || oldContractRoomDtos.size() < 1) {
+ return;
+ }
+ Date contractEndDate = DateUtil.getDateFromStringA(contractDto.getEndTime());
+ for (ContractRoomDto oldContractRoomDto : oldContractRoomDtos) {
+ OwnerRoomRelDto ownerRoomRelDto = new OwnerRoomRelDto();
+ ownerRoomRelDto.setRoomId(oldContractRoomDto.getRoomId());
+ ownerRoomRelDto.setOwnerId(contractDto.getObjId());
+ List<OwnerRoomRelDto> ownerRoomRelDtos = ownerRoomRelInnerServiceSMOImpl.queryOwnerRoomRels(ownerRoomRelDto);
+
+ if (ownerRoomRelDtos == null || ownerRoomRelDtos.size() < 1) { // 璇存槑涓氫富娌℃湁鍙戠敓鍙樺寲锛屽悗缁伐浣滀笉鍋氬鐞�
+ continue;
+ }
+
+ // todo 濡傛灉鍚堝悓鐨勫皬浜庢埧灞嬬殑鍒� 涓嶄慨鏀�
+ // todo 杩欏潡鍙互鏍规嵁瀹為檯鐨勪竴涓娇鐢ㄦ儏鍐电湅鐪嬭涓嶈闄愬埗
+ Date roomEndDate = ownerRoomRelDtos.get(0).getEndTime();
+ if(contractEndDate.getTime() < roomEndDate.getTime()){
+ continue;
+ }
+
+ //todo 淇敼鏃堕棿
+ OwnerRoomRelPo ownerRoomRelPo = new OwnerRoomRelPo();
+ ownerRoomRelPo.setEndTime(contractDto.getEndTime());
+ ownerRoomRelPo.setStartTime(contractDto.getStartTime());
+ ownerRoomRelPo.setRelId(ownerRoomRelDtos.get(0).getRelId());
+ ownerRoomRelInnerServiceSMOImpl.updateOwnerRoomRels(ownerRoomRelPo);
+ }
+ }
+
+ 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());
+ contractAttrDto.setSpecCd(jsonObject.getString("specCd"));
+ List<ContractAttrDto> contractAttrDtos = contractAttrInnerServiceSMOImpl.queryContractAttrs(contractAttrDto);
+
+ Assert.listOnlyOne(contractAttrDtos, "鏈壘鍒伴渶瑕佷慨鏀圭殑鍚堝悓灞炴��");
+ ContractAttrPo contractAttrPo = new ContractAttrPo();
+ contractAttrPo.setAttrId(contractAttrDtos.get(0).getAttrId());
+ contractAttrPo.setContractId(contractPo.getContractId());
+ contractAttrPo.setSpecCd(jsonObject.getString("specCd"));
+ contractAttrPo.setValue(jsonObject.getString("value"));
+ contractAttrPo.setStoreId(contractPo.getStoreId());
+ int count = contractAttrInnerServiceSMOImpl.updateContractAttr(contractAttrPo);
+
+ if (count < 1) {
+ throw new IllegalArgumentException("淇濆瓨灞炴�уけ璐�");
+ }
+ }
+
+ private void updateContractAttr(JSONObject jsonObject, ContractDto contractPo) {
+ ContractAttrDto contractAttrDto = new ContractAttrDto();
+ contractAttrDto.setContractId(contractPo.getContractId());
+ contractAttrDto.setSpecCd(jsonObject.getString("specCd"));
+ List<ContractAttrDto> contractAttrDtos = contractAttrInnerServiceSMOImpl.queryContractAttrs(contractAttrDto);
+
+ Assert.listOnlyOne(contractAttrDtos, "鏈壘鍒伴渶瑕佷慨鏀圭殑鍚堝悓灞炴��");
+ ContractAttrPo contractAttrPo = new ContractAttrPo();
+ contractAttrPo.setAttrId(contractAttrDtos.get(0).getAttrId());
+ contractAttrPo.setContractId(contractPo.getContractId());
+ contractAttrPo.setSpecCd(jsonObject.getString("specCd"));
+ contractAttrPo.setValue(jsonObject.getString("value"));
+ contractAttrPo.setStoreId(contractPo.getStoreId());
+ int count = contractAttrInnerServiceSMOImpl.updateContractAttr(contractAttrPo);
+
+ if (count < 1) {
+ throw new IllegalArgumentException("淇濆瓨灞炴�уけ璐�");
+ }
+ }
+
+ /**
+ * 淇敼 鎴垮眿绉熻祦鐘舵��
+ *
+ * @param contractPo
+ */
+ private void noticeRentUpdateState(ContractPo contractPo) {
+
+ ContractDto contractDto = new ContractDto();
+ contractDto.setContractId(contractPo.getContractId());
+ List<ContractDto> contractDtos = contractInnerServiceSMOImpl.queryContracts(contractDto);
+
+ Assert.listOnlyOne(contractDtos, "鏈壘鍒伴渶瑕佸鏍稿悎鍚�");
+
+ if (!contractDtos.get(0).getObjType().equals(FeeDto.PAYER_OBJ_TYPE_ROOM)
+ || StringUtil.isEmpty(contractDtos.get(0).getObjId())
+ || contractDtos.get(0).getObjId().startsWith("-")) {
+ return;
+ }
+
+ if (!StoreDto.STORE_ADMIN.equals(contractDtos.get(0).getStoreId())) {
+ return;
+ }
+ RentingPoolDto rentingPoolDto = new RentingPoolDto();
+ rentingPoolDto.setRoomId(contractDtos.get(0).getObjId());
+ rentingPoolDto.setState(RentingPoolDto.STATE_ADMIN_AUDIT);
+ List<RentingPoolDto> rentingPoolDtos = rentingPoolInnerServiceSMOImpl.queryRentingPools(rentingPoolDto);
+
+ if (rentingPoolDtos == null || rentingPoolDtos.size() < 1) {
+ return;
+ }
+
+ RentingPoolPo rentingPoolPo = new RentingPoolPo();
+ rentingPoolPo.setCommunityId(rentingPoolDtos.get(0).getCommunityId());
+ rentingPoolPo.setRentingId(rentingPoolDtos.get(0).getRentingId());
+
+ rentingPoolPo.setState(RentingPoolDto.STATE_FINISH);
+
+ rentingPoolInnerServiceSMOImpl.updateRentingPool(rentingPoolPo);
}
}
--
Gitblit v1.8.0