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