From 812d9ff257a89eebcd4bf038c16532c9dec90211 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期四, 14 十一月 2019 19:36:18 +0800
Subject: [PATCH] 业主表中加入 小区字段,方便后期处理

---
 HardwareAdapationService/src/main/java/com/java110/hardwareAdapation/thread/TranslateOwnerToMachine.java |   28 ++++++++++++++++++++++++----
 1 files changed, 24 insertions(+), 4 deletions(-)

diff --git a/HardwareAdapationService/src/main/java/com/java110/hardwareAdapation/thread/TranslateOwnerToMachine.java b/HardwareAdapationService/src/main/java/com/java110/hardwareAdapation/thread/TranslateOwnerToMachine.java
index ee3e4dc..0183035 100644
--- a/HardwareAdapationService/src/main/java/com/java110/hardwareAdapation/thread/TranslateOwnerToMachine.java
+++ b/HardwareAdapationService/src/main/java/com/java110/hardwareAdapation/thread/TranslateOwnerToMachine.java
@@ -1,6 +1,9 @@
 package com.java110.hardwareAdapation.thread;
 
 import com.java110.core.smo.order.IOrderInnerServiceSMO;
+import com.java110.core.smo.owner.IOwnerInnerServiceSMO;
+import com.java110.core.smo.user.IUserInnerServiceSMO;
+import com.java110.dto.OwnerDto;
 import com.java110.dto.order.OrderDto;
 import com.java110.utils.cache.MappingCache;
 import com.java110.utils.factory.ApplicationContextFactory;
@@ -9,6 +12,8 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.core.annotation.Order;
+
+import java.util.List;
 
 /**
  * 浠庤鍗曚腑鍚屾涓氫富淇℃伅鑷宠澶囦腑闂磋〃
@@ -20,9 +25,12 @@
     public static boolean TRANSLATE_STATE = false;
 
     private IOrderInnerServiceSMO orderInnerServiceSMOImpl;
+    private IOwnerInnerServiceSMO ownerInnerServiceSMOImpl;
 
     public TranslateOwnerToMachine() {
         orderInnerServiceSMOImpl = ApplicationContextFactory.getBean("orderInnerServiceSMOImpl", IOrderInnerServiceSMO.class);
+        ownerInnerServiceSMOImpl = ApplicationContextFactory.getBean("ownerInnerServiceSMOImpl", IOwnerInnerServiceSMO.class);
+
     }
 
     @Override
@@ -44,13 +52,25 @@
      * 鎵ц浠诲姟
      */
     private void executeTask() {
+        OwnerDto ownerDto = null;
         //鏌ヨ璁㈠崟淇℃伅
         OrderDto orderDto = new OrderDto();
-        orderInnerServiceSMOImpl.queryOwenrOrders(orderDto);
+        List<OrderDto> orderDtos = orderInnerServiceSMOImpl.queryOwenrOrders(orderDto);
+        for (OrderDto tmpOrderDto : orderDtos) {
+            try {
+                //鏍规嵁bId 鏌ヨ涓氫富淇℃伅
+                ownerDto = new OwnerDto();
+                ownerDto.setbId(tmpOrderDto.getbId());
+                List<OwnerDto> ownerDtos = ownerInnerServiceSMOImpl.queryOwners(ownerDto);
+                dealData(tmpOrderDto, ownerDtos);
+            } catch (Exception e) {
+                logger.error("鎵ц璁㈠崟浠诲姟澶辫触", e);
+            }
+        }
+    }
+
+    private void dealData(OrderDto tmpOrderDto, List<OwnerDto> ownerDtos) {
 
     }
 
-    private void getTask() {
-
-    }
 }

--
Gitblit v1.8.0