接口编写

zhang

2025-05-16 09fd9dc04b21a7d1a495a753b8efbb4820dd3720

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
package com.zy.asrs.task;

 

import com.zy.asrs.entity.WrkMast;

import com.zy.asrs.service.WrkMastService;

import com.zy.asrs.task.core.ReturnT;

import com.zy.asrs.task.handler.WorkLogHandler;

import lombok.extern.slf4j.Slf4j;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Component;

 

import java.util.List;

 

/**

 * Created by vincent on 2020/7/7

 */

@Slf4j

@Component

public class WorkLogScheduler {

 

    @Autowired

    private WorkLogHandler workLogHandler;

    @Autowired

    private WrkMastService wrkMastService;

 

    //@Scheduled(cron = "0/1 * * * * ? ")

    @Scheduled(fixedDelay = 60000)

    private void execute(){

        List<WrkMast> wrkMasts = wrkMastService.selectToBeHistoryData();

        if (wrkMasts.isEmpty()) {

            return;

        }

        for (WrkMast wrkMast : wrkMasts) {

            ReturnT<String> result = workLogHandler.start(wrkMast);

            if (!result.isSuccess()) {

                log.error("工作档[workNo={}]历史档处理失败", wrkMast.getWrkNo());

            }

        }

    }

 

}