同步业主信息未完成

HardwareAdapationService/src/main/java/com/java110/hardwareAdapation/thread/TranslateOwnerToMachine.java

@@ -0,0 +1,56 @@
+package com.java110.hardwareAdapation.thread;
+
+import com.java110.core.smo.order.IOrderInnerServiceSMO;
+import com.java110.dto.order.OrderDto;
+import com.java110.utils.cache.MappingCache;
+import com.java110.utils.factory.ApplicationContextFactory;
+import com.java110.utils.util.CacheUtil;
+import com.java110.utils.util.StringUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.core.annotation.Order;
+
+/**
+ * 从订单中同步业主信息至设备中间表
+ * add by wuxw 2019-11-14
+ */
+public class TranslateOwnerToMachine implements Runnable {
+    Logger logger = LoggerFactory.getLogger(TranslateOwnerToMachine.class);
+    public static final long DEFAULT_WAIT_SECOND = 5000 * 6; // 默认30秒执行一次
+    public static boolean TRANSLATE_STATE = false;
+
+    private IOrderInnerServiceSMO orderInnerServiceSMOImpl;
+
+    public TranslateOwnerToMachine() {
+        orderInnerServiceSMOImpl = ApplicationContextFactory.getBean("orderInnerServiceSMOImpl", IOrderInnerServiceSMO.class);
+    }
+
+    @Override
+    public void run() {
+        long waitTime = DEFAULT_WAIT_SECOND;
+        while (TRANSLATE_STATE) {
+            try {
+                executeTask();
+                waitTime = StringUtil.isNumber(MappingCache.getValue("DEFAULT_WAIT_SECOND")) ?
+                        Long.parseLong(MappingCache.getValue("DEFAULT_WAIT_SECOND")) : DEFAULT_WAIT_SECOND;
+                Thread.sleep(waitTime);
+            } catch (Throwable e) {
+                logger.error("执行订单中同步业主信息至设备中失败", e);
+            }
+        }
+    }
+
+    /**
+     * 执行任务
+     */
+    private void executeTask() {
+        //查询订单信息
+        OrderDto orderDto = new OrderDto();
+        orderInnerServiceSMOImpl.queryOwenrOrders(orderDto);
+
+    }
+
+    private void getTask() {
+
+    }
+}

OrderService/src/main/java/com/java110/order/smo/impl/OrderInnerServiceSMOImpl.java

@@ -0,0 +1,70 @@
+package com.java110.order.smo.impl;
+
+
+import com.java110.core.base.smo.BaseServiceSMO;
+import com.java110.core.smo.order.IOrderInnerServiceSMO;
+import com.java110.core.smo.user.IUserInnerServiceSMO;
+import com.java110.dto.order.OrderDto;
+import com.java110.order.dao.ICenterServiceDAO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+/**
+ * @ClassName FloorInnerServiceSMOImpl
+ * @Description 组织内部服务实现类
+ * @Author wuxw
+ * @Date 2019/4/24 9:20
+ * @Version 1.0
+ * add by wuxw 2019/4/24
+ **/
+@RestController
+public class OrderInnerServiceSMOImpl extends BaseServiceSMO implements IOrderInnerServiceSMO {
+
+    @Autowired
+    private ICenterServiceDAO centerServiceDAOImpl;
+
+    @Autowired
+    private IUserInnerServiceSMO userInnerServiceSMOImpl;
+
+    @Override
+    public List<OrderDto> queryOrders(@RequestBody OrderDto orderDto) {
+
+        //校验是否传了 分页信息
+
+        /*int page = orderDto.getPage();
+
+        if (page != PageDto.DEFAULT_PAGE) {
+            orderDto.setPage((page - 1) * orderDto.getRow());
+        }
+
+        List<OrderDto> orders = BeanConvertUtil.covertBeanList(centerServiceDAOImpl.(BeanConvertUtil.beanCovertMap(orderDto)), OrderDto.class);
+
+
+        return orders;*/
+        return null;
+    }
+
+
+    @Override
+    public int queryOrdersCount(@RequestBody OrderDto orderDto) {
+        //return orderServiceDaoImpl.queryOrdersCount(BeanConvertUtil.beanCovertMap(orderDto));
+        return 0;
+    }
+
+    @Override
+    public List<OrderDto> queryOwenrOrders(@RequestBody OrderDto orderDto) {
+        return null;
+    }
+
+
+    public IUserInnerServiceSMO getUserInnerServiceSMOImpl() {
+        return userInnerServiceSMOImpl;
+    }
+
+    public void setUserInnerServiceSMOImpl(IUserInnerServiceSMO userInnerServiceSMOImpl) {
+        this.userInnerServiceSMOImpl = userInnerServiceSMOImpl;
+    }
+}

java110-bean/src/main/java/com/java110/dto/order/OrderDto.java

@@ -0,0 +1,8 @@
+package com.java110.dto.order;
+
+import com.java110.dto.PageDto;
+
+import java.io.Serializable;
+
+public class OrderDto extends PageDto implements Serializable {
+}

java110-core/src/main/java/com/java110/core/smo/order/IOrderInnerServiceSMO.java

@@ -0,0 +1,51 @@
+package com.java110.core.smo.order;
+
+import com.java110.core.feign.FeignConfiguration;
+import com.java110.dto.order.OrderDto;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+
+import java.util.List;
+
+/**
+ * @ClassName IOrderInnerServiceSMO
+ * @Description 组织接口类
+ * @Author wuxw
+ * @Date 2019/4/24 9:04
+ * @Version 1.0
+ * add by wuxw 2019/4/24
+ **/
+@FeignClient(name = "order-service", configuration = {FeignConfiguration.class})
+@RequestMapping("/orderApi")
+public interface IOrderInnerServiceSMO {
+
+    /**
+     * <p>查询小区楼信息</p>
+     *
+     * @param orderDto 数据对象分享
+     * @return OrderDto 对象数据
+     */
+    @RequestMapping(value = "/queryOrders", method = RequestMethod.POST)
+    List<OrderDto> queryOrders(@RequestBody OrderDto orderDto);
+
+    /**
+     * 查询<p>小区楼</p>总记录数
+     *
+     * @param orderDto 数据对象分享
+     * @return 小区下的小区楼记录数
+     */
+    @RequestMapping(value = "/queryOrdersCount", method = RequestMethod.POST)
+    int queryOrdersCount(@RequestBody OrderDto orderDto);
+
+
+    /**
+     * <p>查询上级组织信息</p>
+     *
+     * @param orderDto 数据对象分享
+     * @return OrderDto 对象数据
+     */
+    @RequestMapping(value = "/queryOwenrOrders", method = RequestMethod.POST)
+    List<OrderDto> queryOwenrOrders(@RequestBody OrderDto orderDto);
+}