需求

mall-server-api/src/main/java/com/gree/mall/manager/bean/workorder/WorkerOrderSyncBean.java

@@ -0,0 +1,29 @@
+package com.gree.mall.manager.bean.workorder;
+
+import lombok.Data;
+
+@Data
+public class WorkerOrderSyncBean {
+
+
+    private String inDownloadBatchNo;
+    private String inSynReqId;
+    private String inWorkOrderId;
+
+    /*
+ 执行结果
+  */
+    private boolean outSynStatus;
+    /*
+    错误信息
+     */
+    private String outSynErrMsg;
+
+    public static WorkerOrderSyncBean instance(String inDownloadBatchNo, String inSynReqId,String inWorkOrderId) {
+        WorkerOrderSyncBean bean = new WorkerOrderSyncBean();
+        bean.setInDownloadBatchNo(inDownloadBatchNo);
+        bean.setInSynReqId(inSynReqId);
+        bean.setInWorkOrderId(inWorkOrderId);
+        return bean;
+    }
+}

mall-server-api/src/main/java/com/gree/mall/manager/commonmapper/workorder/SyncMapper.java

@@ -0,0 +1,22 @@
+package com.gree.mall.manager.commonmapper.workorder;
+
+import com.gree.mall.manager.bean.workorder.WorkerOrderSyncBean;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Options;
+import org.apache.ibatis.annotations.Select;
+import org.apache.ibatis.mapping.StatementType;
+
+@Mapper
+public interface SyncMapper {
+
+
+    @Select({ "call TL_SynDataFrom_tbl_work_order_package("
+            + "#{sheetId,mode=IN,jdbcType=VARCHAR},"
+            + "#{flag,mode=IN,jdbcType=INTEGER},"
+            + "#{flag,mode=IN,jdbcType=INTEGER},"
+            + "#{status,mode=OUT,jdbcType=BOOLEAN},"
+            + "#{msg,mode=OUT,jdbcType=VARCHAR})"
+    })
+    @Options(statementType = StatementType.CALLABLE)
+    WorkerOrderSyncBean orderExecute(WorkerOrderSyncBean workerOrderSyncBean);
+}

mall-server-api/src/main/java/com/gree/mall/manager/enums/workorder/OrderFlagEnum.java

@@ -29,7 +29,7 @@ public enum OrderFlagEnum implements BaseEnum {
     PARTS_END("PARTS_END","配件已到货",11),
     PARTS_CANCEL("PARTS_CANCEL","配件已取消",12),
     ORDER4("ORDER4","4.0工单",13),
-    ORDER("ORDER4","自建工单",14),
+    ORDER("ORDER","自建工单",14),
     ;
 
     @EnumValue

mall-server-api/src/main/java/com/gree/mall/manager/logic/SyncOrderInfoLogic.java

@@ -19,6 +19,7 @@ import com.gree.mall.manager.bean.WorkOrderRelationBean;
 import com.gree.mall.manager.bean.WorkOrderSearchReq;
 
 import com.gree.mall.manager.bean.policy.ItfGreeSynDownloadRecBean;
+import com.gree.mall.manager.commonmapper.workorder.SyncMapper;
 import com.gree.mall.manager.constant.Constant;
 import com.gree.mall.manager.exception.RemoteServiceException;
 import com.gree.mall.manager.plus.entity.*;
@@ -188,6 +189,9 @@ public class SyncOrderInfoLogic {
     @Autowired
     ItfTblWorkOrderStatusService itfTblWorkOrderStatusService;
 
+    @Autowired
+    SyncMapper syncMapper;
+
 
     public void syncGuang() {
         List<ItfGreeSynRule> itfGreeSynRules = itfGreeSynRuleService.lambdaQuery().list();
@@ -521,4 +525,10 @@ public class SyncOrderInfoLogic {
         }
 
     }
+
+    public void task3() {
+
+
+
+    }
 }

mall-server-api/src/main/java/com/gree/mall/manager/schedule/SyncSchedule.java

@@ -25,14 +25,14 @@ public class SyncSchedule {
 
 
 
-    //每小时执行1次
+    //同步工单数据
     @Scheduled(fixedDelay =10* 1000)
     public void task() throws IOException {
         syncOrderInfoLogic.syncGuang();
     }
 
 
-    //监测今天是否有回执邮件，如果有则表示今天买保险的回执成功
+    //同步工单数据
     @Scheduled(fixedDelay = 10* 1000)
     public void task2() throws IOException, MessagingException {
         syncOrderInfoLogic.syncDetail();
@@ -40,4 +40,10 @@ public class SyncSchedule {
 
 
 
+    //同步工单数据
+    @Scheduled(fixedDelay = 5* 1000)
+    public void task3() throws IOException, MessagingException {
+        syncOrderInfoLogic.task3();
+    }
+
 }