修改定时任务触发方式，不是以固定时间执行，以执行完成任务，间隔多少时间在此执行

zhangchao

2024-11-22 611a816801c58abcc81d511a7dfc368f8d8fb24e

修改定时任务触发方式，不是以固定时间执行，以执行完成任务，间隔多少时间在此执行

 src/main/java/com/zy/asrs/task/AgvWrkMastScheduler.java

@@ -43,7 +43,8 @@
    /*
    定时处理AGV工作档中工作状态为205.工作完成 且 （1.入库 || 53，拣料入库 || 57.盘点入库 || 10.空板入库 || 11.单层移库 || 12.跨层移库 || 108.自动调拨 || 109.手动调拨)的数据
     */
    @Scheduled(cron = "0/1 * * * * ? ")
    //@Scheduled(cron = "0/1 * * * * ? ")
    @Scheduled(fixedDelay = 2000)
    public void excutePutwayWrk(){
        List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>()
                .eq("wrk_sts", 205)
@@ -76,7 +77,8 @@
    /*
    定时处理AGV工作档中工作状态为206.出库完成 且 (101.出库 || 110.空板出库)
     */
    @Scheduled(cron = "0/1 * * * * ? ")
    //@Scheduled(cron = "0/1 * * * * ? ")
    @Scheduled(fixedDelay = 2000)
    public void excuteCarryWrk(){
        List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>()
                .eq("wrk_sts", 206)
@@ -98,7 +100,8 @@
    /*
    定时处理AGV工作档中工作状态为206.出库完成 且 (101.出库 || 110.空板出库)
     */
    @Scheduled(cron = "0/1 * * * * ? ")
    //@Scheduled(cron = "0/1 * * * * ? ")
    @Scheduled(fixedDelay = 2000)
    public void excuteCarryWrk2(){
        List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>()
                .eq("wrk_sts", 208)
@@ -120,7 +123,8 @@
    putaway：上架
    定时处理AGV工作档中工作状态为201.生成入库任务ID 且(出库类型为 53.拣料再入库 || 1.入库 || 10.空板入库栽 || 57.盘点再入库)的数据
     */
    @Scheduled(cron = "0/1 * * * * ? ")
    //@Scheduled(cron = "0/1 * * * * ? ")
    @Scheduled(fixedDelay = 2000)
    public void startPutwayWrk(){
        List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectPage(new Page<>(1, 50)
                ,new EntityWrapper<AgvWrkMast>()
@@ -154,7 +158,8 @@
    putaway：上架
    定时处理AGV工作档中工作状态为201.生成入库任务ID 且(出库类型为 53.拣料再入库 || 1.入库 || 10.空板入库栽 || 57.盘点再入库)的数据
     */
    @Scheduled(cron = "0/1 * * * * ? ")
    //@Scheduled(cron = "0/1 * * * * ? ")
    @Scheduled(fixedDelay = 2000)
    public void startAllcationIn(){
        List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectPage(new Page<>(1, 50)
                ,new EntityWrapper<AgvWrkMast>()
@@ -176,7 +181,8 @@
    carry：搬运，统指出库、移库、点到点搬运等
    定时处理AGV工作档中工作状态为21.生成出库任务 且(出库类型为 101.出库 || 103.拣料出库 || 11.库格移栽 || 110.空板出库 || 107.盘点出库)的数据
     */
    @Scheduled(cron = "0/1 * * * * ? ")
    //@Scheduled(cron = "0/1 * * * * ? ")
    @Scheduled(fixedDelay = 2000)
    public void startCarryWrk(){
        List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectPage(new Page<>(1, 50)
                ,new EntityWrapper<AgvWrkMast>()
@@ -243,7 +249,8 @@
    /*
    自动生成空板出库任务
     */
    @Scheduled(cron = "0/1 * * * * ? ")
    //@Scheduled(cron = "0/1 * * * * ? ")
    @Scheduled(fixedDelay = 2000)
    public void autoEmptyOut(){
        boolean packageEmptyAutoOUt = Cools.eq("Y",Parameter.get().getPackageEmptyAutoOUt());
        boolean mateEmptyAutoOut = Cools.eq("Y",Parameter.get().getMateEmptyAutoOut());

 src/main/java/com/zy/asrs/task/OrderLogScheduler.java

@@ -22,7 +22,8 @@
//    @Value("${erp.enable}")
//    private boolean isERP;
//
    @Scheduled(cron = "0/10 * * * * ? ")
    //@Scheduled(cron = "0/10 * * * * ? ")
    @Scheduled(fixedDelay = 10000)
    private void execute(){
        List<Order> orders = orderService.selectToBeHistoryOrder();
        if (orders.isEmpty()) {

 src/main/java/com/zy/asrs/task/OrderSyncScheduler.java

@@ -49,7 +49,8 @@
        }
    }

    @Scheduled(cron = "0/5 * * * * ? ")
    //@Scheduled(cron = "0/5 * * * * ? ")
    @Scheduled(fixedDelay = 5000)
    //@Async("orderThreadPool")
    public void completeAndReport() {
        String erpReport = Parameter.get().getErpReport();
@@ -81,7 +82,8 @@
    }

    //@Scheduled(cron = "* 0/5 * * * ? ")
    @Scheduled(cron = "0/30 * * * * ? ")
    //@Scheduled(cron = "0/30 * * * * ? ")
    @Scheduled(fixedDelay = 30000)
    //@Async("orderThreadPool")
    public synchronized void  reportOrder() {
        List<Order> orderList = orderService.selectList(new EntityWrapper<Order>().in("settle", 2, 4));
@@ -94,7 +96,8 @@
    /*
    定时查询状态为2.作业中的单据，检查是否完成
     */
    @Scheduled(cron = "0 */1 * * * ? ")
    //@Scheduled(cron = "0 */1 * * * ? ")
    @Scheduled(fixedDelay = 60000)
    public void completeOrder() {
        List<Order> orderList = orderService.selectList(new EntityWrapper<Order>().eq("settle", 2));
        orderList.forEach(order -> {

 src/main/java/com/zy/asrs/task/WorkLogScheduler.java

@@ -23,7 +23,8 @@
    @Autowired
    private WrkMastService wrkMastService;

    @Scheduled(cron = "0/1 * * * * ? ")
    //@Scheduled(cron = "0/1 * * * * ? ")
    @Scheduled(fixedDelay = 60000)
    private void execute(){
        List<WrkMast> wrkMasts = wrkMastService.selectToBeHistoryData();
        if (wrkMasts.isEmpty()) {

 src/main/java/com/zy/asrs/task/WorkMastScheduler.java

@@ -26,7 +26,8 @@
    @Autowired
    private WorkMastHandler workMastHandler;

    @Scheduled(cron = "0/1 * * * * ? ")
    @Scheduled(fixedDelay = 60000)
    //@Scheduled(cron = "0/1 * * * * ? ")
    private void execute(){
        List<WrkMast> wrkMasts = wrkMastService.selectToBeCompleteData();
        if (wrkMasts.isEmpty()) {

 src/main/resources/application.yml

@@ -1,4 +1,4 @@
spring:
  profiles:
    #dev loc prod
    active: prod
    active: loc