From 7bd6e380475d1f4ec7a030dffcf0c217b879b0a5 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期五, 13 十月 2023 09:39:14 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/tzskasrs' into tzskasrs

---
 src/main/java/com/zy/asrs/task/AutoReplenishmentScheduler.java |   42 ++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 42 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/zy/asrs/task/AutoReplenishmentScheduler.java b/src/main/java/com/zy/asrs/task/AutoReplenishmentScheduler.java
new file mode 100644
index 0000000..55df580
--- /dev/null
+++ b/src/main/java/com/zy/asrs/task/AutoReplenishmentScheduler.java
@@ -0,0 +1,42 @@
+package com.zy.asrs.task;
+
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
+import com.core.common.Cools;
+import com.zy.asrs.entity.DocType;
+import com.zy.asrs.entity.Order;
+import com.zy.asrs.service.DocTypeService;
+import com.zy.asrs.service.OrderService;
+import com.zy.asrs.task.handler.AutoReplenishmentHandler;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Slf4j
+@Component
+public class AutoReplenishmentScheduler {
+
+    @Autowired
+    private OrderService orderService;
+    @Autowired
+    private DocTypeService docTypeService;
+    @Autowired
+    private AutoReplenishmentHandler autoReplenishmentHandler;
+
+    /*
+    瀹氭椂澶勭悊鑷姩琛ヨ揣鍗曟嵁
+     */
+    //@Scheduled(cron = "0/5 * * * * ? ")
+    public void excute(){
+        DocType docType = docTypeService.selectOne(new EntityWrapper<DocType>().eq("doc_name", "鑷姩琛ヨ揣鍗�"));
+        List<Order> orderList = orderService.selectList(new EntityWrapper<Order>()
+                .eq("doc_type", docType.getDocId())
+                .eq("settle",1));
+        if(!Cools.isEmpty(orderList)){
+            orderList.forEach(order -> {
+                autoReplenishmentHandler.start(order);
+            });
+        }
+    }
+}

--
Gitblit v1.9.1