1

zj

2024-08-14 a949bf71283aeabbf4ac26adb7f183b67c02dfc7

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
package project.loan.job;
 
import java.util.Date;
import java.util.List;
 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.util.CollectionUtils;
 
import kernel.web.Page;
import project.loan.LoanOrder;
import project.loan.LoanOrderService;
 
/**
 * 质押借币 利息JOB
 *
 */
public class LoanInterestJob {
    
    private Logger logger = LoggerFactory.getLogger(LoanInterestJob.class);
    
    private LoanOrderService loanOrderService;
    
    public void taskJob() {
 
        try {
            int pageNo = 1;
            int pageSize = 300;
            // 小于当前时间，新增的订单都不查
            Date date = new Date();
            while (true) {
                
                Page page = loanOrderService.pagedQueryInterestOrder(pageNo, pageSize, date);
                List<LoanOrder> orders = page.getElements();
                // 分页没数据时表示已经计算结束
                if (CollectionUtils.isEmpty(orders)) {
                    break;
                }
                try {
                    loanOrderService.updateInterest(orders);
                } catch (Throwable e) {
                    logger.error("error:", e);
                }
                logger.info("loan interest finished, count:" + orders.size());
                pageNo++;
            }
        } catch (Throwable e) {
            logger.error("PledgeGalaxyOrderProfit run fail", e);
        }
    }
 
    public void setLoanOrderService(LoanOrderService loanOrderService) {
        this.loanOrderService = loanOrderService;
    }
    
}