From c6bc9682699d3e10dc06a3d6641a70179e64f9a1 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@63.com>
Date: 星期二, 14 九月 2021 08:32:11 +0800
Subject: [PATCH] Merge branch 'xgmasrs' of https://gitee.com/luxiaotao1123/zy-asrs into xgmasrs

---
 src/main/java/com/zy/ints/task/WaitMatoutLogScheduler.java |   47 +++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 47 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/zy/ints/task/WaitMatoutLogScheduler.java b/src/main/java/com/zy/ints/task/WaitMatoutLogScheduler.java
new file mode 100644
index 0000000..ff778c9
--- /dev/null
+++ b/src/main/java/com/zy/ints/task/WaitMatoutLogScheduler.java
@@ -0,0 +1,47 @@
+package com.zy.ints.task;
+
+import com.zy.asrs.task.core.ReturnT;
+import com.zy.ints.entity.WaitMatout;
+import com.zy.ints.service.WaitMatoutService;
+import com.zy.ints.task.handler.WaitMatoutLogHandler;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * 鍑哄簱閫氱煡妗h浆鍘嗗彶妗�
+ * Created by TQS on 2021/8/31
+ */
+@Component
+public class WaitMatoutLogScheduler {
+    private static final Logger log = LoggerFactory.getLogger(WaitMatoutLogScheduler.class);
+
+    @Autowired
+    private WaitMatoutService waitMatoutService;
+    @Autowired
+    private WaitMatoutLogHandler waitMatOutLogHandler;
+
+    /**
+     * ERP鎺ュ彛鏄惁鍚敤
+     */
+    @Value("${erp.enabled}")
+    private Boolean erpEnabled;
+
+    @Scheduled(cron = "0/4 * * * * ? ")
+    private void execute(){
+        if(!erpEnabled) return;
+        List<WaitMatout> waitMatouts = waitMatoutService.selectWaitMatOutBySts();
+        for (WaitMatout waitMatout : waitMatouts) {
+            ReturnT<String> result = waitMatOutLogHandler.start(waitMatout);
+            if (!result.isSuccess()) {
+                log.error("鍑哄簱閫氱煡妗billNo={},seqNo={}]鍘嗗彶妗e鐞嗗け璐�", waitMatout.getBillNo(),waitMatout.getSeqNo());
+            }
+        }
+    }
+
+}

--
Gitblit v1.9.1