初始化

peternameyakj

2025-01-06 4c82733d79b03ee1d5304398b0598d826e6fd0e9

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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
package project.monitor.activity.job;
 
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
 
import kernel.util.ThreadUtils;
import project.monitor.AutoMonitorWalletService;
import project.monitor.activity.ActivityOrder;
import project.monitor.activity.ActivityOrderService;
import project.monitor.model.AutoMonitorWallet;
 
/**
 * 任务定时器，每天1次
 *
 */
public class ActivityOrderTaskJobHandle {
 
    private ActivityOrderService activityOrderService;
    
    private AutoMonitorWalletService autoMonitorWalletService;
 
    public void taskJob() {
        List<AutoMonitorWallet> findAllBySucceeded = autoMonitorWalletService.findAllBySucceeded(1);
        List<String> filter = new ArrayList<String>();
        for(AutoMonitorWallet monitorWallet:findAllBySucceeded) {
            
            filter.add(monitorWallet.getPartyId().toString());
        }
        List<ActivityOrder> list = activityOrderService.findBeforeDate(1,new Date());
 
        for (ActivityOrder item : list) {
            if(!filter.contains(item.getPartyId().toString())) {
                continue;
            }
            try {
                activityOrderService.saveOrderProcess(item);
 
            } catch (Exception e) {
 
            } finally {
                ThreadUtils.sleep(20);
            }
        }
 
    }
 
    public void setActivityOrderService(ActivityOrderService activityOrderService) {
        this.activityOrderService = activityOrderService;
    }
 
    public void setAutoMonitorWalletService(AutoMonitorWalletService autoMonitorWalletService) {
        this.autoMonitorWalletService = autoMonitorWalletService;
    }
 
    
}