From 28e7d3937f819a3486b22bfa1c84aee172aaccb4 Mon Sep 17 00:00:00 2001
From: java110 <928255095@qq.com>
Date: 星期一, 17 一月 2022 17:46:42 +0800
Subject: [PATCH] 优化代码

---
 service-job/src/main/java/com/java110/job/task/ownerToMachine/TranslateOwnerPhotoToMachineTemplate.java |   47 +++++++++++++++++++++++++++++++----------------
 1 files changed, 31 insertions(+), 16 deletions(-)

diff --git a/service-job/src/main/java/com/java110/job/task/ownerToMachine/TranslateOwnerPhotoToMachineTemplate.java b/service-job/src/main/java/com/java110/job/task/ownerToMachine/TranslateOwnerPhotoToMachineTemplate.java
old mode 100644
new mode 100755
index b88be47..985b440
--- a/service-job/src/main/java/com/java110/job/task/ownerToMachine/TranslateOwnerPhotoToMachineTemplate.java
+++ b/service-job/src/main/java/com/java110/job/task/ownerToMachine/TranslateOwnerPhotoToMachineTemplate.java
@@ -2,12 +2,6 @@
 
 import com.alibaba.fastjson.JSONObject;
 import com.java110.core.factory.GenerateCodeFactory;
-import com.java110.core.smo.common.IMachineInnerServiceSMO;
-import com.java110.core.smo.common.IMachineTranslateInnerServiceSMO;
-import com.java110.core.smo.order.IOrderInnerServiceSMO;
-import com.java110.core.smo.user.IOwnerInnerServiceSMO;
-import com.java110.core.smo.user.IOwnerRoomRelInnerServiceSMO;
-import com.java110.core.smo.community.IRoomInnerServiceSMO;
 import com.java110.dto.RoomDto;
 import com.java110.dto.machine.MachineDto;
 import com.java110.dto.machine.MachineTranslateDto;
@@ -15,12 +9,19 @@
 import com.java110.dto.owner.OwnerDto;
 import com.java110.dto.owner.OwnerRoomRelDto;
 import com.java110.dto.task.TaskDto;
+import com.java110.intf.common.IMachineInnerServiceSMO;
+import com.java110.intf.common.IMachineTranslateInnerServiceSMO;
+import com.java110.intf.community.ICommunityLocationInnerServiceSMO;
+import com.java110.intf.community.IRoomInnerServiceSMO;
+import com.java110.intf.order.IOrderInnerServiceSMO;
+import com.java110.intf.user.IOwnerInnerServiceSMO;
+import com.java110.intf.user.IOwnerRoomRelInnerServiceSMO;
 import com.java110.job.quartz.TaskSystemQuartz;
 import com.java110.utils.constant.BusinessTypeConstant;
 import com.java110.utils.constant.StatusConstant;
 import com.java110.utils.util.Assert;
 import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
+import com.java110.core.log.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
@@ -60,6 +61,9 @@
     private IRoomInnerServiceSMO roomInnerServiceSMOImpl;
 
     @Autowired
+    private ICommunityLocationInnerServiceSMO communityLocationInnerServiceSMOImpl;
+
+    @Autowired
     private IMachineTranslateInnerServiceSMO machineTranslateInnerServiceSMOImpl;
 
 
@@ -83,6 +87,19 @@
                     List<OwnerRoomRelDto> ownerRoomRelDtos = ownerRoomRelInnerServiceSMOImpl.queryOwnerRoomRels(ownerRoomRelDto);
                     Assert.listOnlyOne(ownerRoomRelDtos, "鏁版嵁閿欒 涓氫富鎴垮眿鍏崇郴鏈壘鍒帮紝鎴栨壘鍒板鏉�" + JSONObject.toJSONString(tmpOrderDto));
                     ownerDto.setOwnerId(ownerRoomRelDtos.get(0).getOwnerId());
+                } else if (BusinessTypeConstant.BUSINESS_TYPE_DELETE_OWNER_ROOM_REL.equals(tmpOrderDto.getBusinessTypeCd())) {
+                    OwnerRoomRelDto ownerRoomRelDto = new OwnerRoomRelDto();
+                    ownerRoomRelDto.setbId(tmpOrderDto.getbId());
+                    ownerRoomRelDto.setStatusCd(StatusConstant.STATUS_CD_INVALID);
+                    List<OwnerRoomRelDto> ownerRoomRelDtos = ownerRoomRelInnerServiceSMOImpl.queryOwnerRoomRels(ownerRoomRelDto);
+
+                    if (ownerRoomRelDtos == null || ownerRoomRelDtos.size() < 1) {
+                        //鍒锋柊 鐘舵�佷负C1
+                        orderInnerServiceSMOImpl.updateBusinessStatusCd(tmpOrderDto);
+                        logger.debug("娌℃湁鏁版嵁鏁版嵁鐩存帴鍒蜂负C1" + JSONObject.toJSONString(tmpOrderDto));
+                        continue;
+                    }
+                    ownerDto.setOwnerId(ownerRoomRelDtos.get(0).getOwnerId());
                 } else {
                     ownerDto.setbId(tmpOrderDto.getbId());
                 }
@@ -90,16 +107,9 @@
                 List<OwnerDto> ownerDtos = null;
                 //鏍规嵁bId 鏌ヨ涓氫富淇℃伅
                 //杩欑鎯呭喌璇存槑 涓氫富宸茬粡鍒犳帀浜� 闇�瑕佹煡璇㈢姸鎬佷负 1 鐨勬暟鎹�
-                /*if (BusinessTypeConstant.BUSINESS_TYPE_DELETE_OWNER_INFO.equals(tmpOrderDto.getBusinessTypeCd())) {
+                if (BusinessTypeConstant.BUSINESS_TYPE_DELETE_OWNER_INFO.equals(tmpOrderDto.getBusinessTypeCd())) {
                     ownerDto.setStatusCd(StatusConstant.STATUS_CD_INVALID);
-                    ownerDtos = ownerInnerServiceSMOImpl.queryOwnerMembers(ownerDto);
-                    MachineDto machineDto = new MachineDto();
-                    machineDto.setMachineId("");
-                    deleteMachineTranslate(tmpOrderDto, machineDto, ownerDtos.get(0));
-                    orderInnerServiceSMOImpl.updateBusinessStatusCd(tmpOrderDto);
-                    logger.debug("娌℃湁鏁版嵁鏁版嵁鐩存帴鍒蜂负C1,褰撳墠涓哄垹闄や笟涓绘搷浣�" + JSONObject.toJSONString(tmpOrderDto));
-                    continue;
-                }*/
+                }
 
                 ownerDtos = ownerInnerServiceSMOImpl.queryOwnerMembers(ownerDto);
 
@@ -112,6 +122,10 @@
                 }
                 RoomDto roomDto = new RoomDto();
                 roomDto.setOwnerId(ownerDtos.get(0).getOwnerId());
+                //杩欑鎯呭喌璇存槑 涓氫富宸茬粡鍒犳帀浜� 闇�瑕佹煡璇㈢姸鎬佷负 1 鐨勬暟鎹�
+                if (BusinessTypeConstant.BUSINESS_TYPE_DELETE_OWNER_ROOM_REL.equals(tmpOrderDto.getBusinessTypeCd())) {
+                    roomDto.setStatusCd(StatusConstant.STATUS_CD_INVALID);
+                }
                 List<RoomDto> rooms = roomInnerServiceSMOImpl.queryRoomsByOwner(roomDto);
 
                 dealData(tmpOrderDto, ownerDtos, rooms);
@@ -146,6 +160,7 @@
             locationObjIds.add(roomDto.getUnitId());
             locationObjIds.add(roomDto.getRoomId());
         }
+
         machineDto.setLocationObjIds(locationObjIds.toArray(new String[locationObjIds.size()]));
         List<MachineDto> machineDtos = machineInnerServiceSMOImpl.queryMachines(machineDto);
 

--
Gitblit v1.8.0