自动化立体仓库 - WMS系统
pang.jiabao
昨天 3cb50aaf224b6a2afb98dc0bac0bb4ab10843b75
定时任务循环未执行完放弃当次任务
1个文件已修改
11 ■■■■■ 已修改文件
src/main/java/com/zy/asrs/task/OrderSyncScheduler.java 11 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/zy/asrs/task/OrderSyncScheduler.java
@@ -15,6 +15,7 @@
import javax.annotation.Resource;
import java.util.List;
import java.util.Map;
import java.util.concurrent.locks.ReentrantLock;
import java.util.stream.Collectors;
/**
@@ -43,10 +44,17 @@
    @Resource
    private ThreadPoolTaskExecutor orderThreadPool;
    private final ReentrantLock lock = new ReentrantLock();
//    @Scheduled(cron = "0/5 * * * * ? ")
    // 10分钟执行一次
    @Scheduled(cron = "0 0/10 * * * ?")
    public void completeAndReport() {
        if (!lock.tryLock()) {
            log.info("上一次任务未执行完,跳过本次");
            return;
        }
        try {
        String erpReport = Parameter.get().getErpReport();
        if (!Cools.isEmpty(erpReport) && erpReport.equals("true")) {
            List<Order> orders = orderService.selectComplete();
@@ -82,6 +90,9 @@
                });
            }
        }
        } finally {
            lock.unlock();
        }
    }
}