地址

zj

2025-06-30 414555cfbb72c02ebc07ca164a7ff0d0f592de13

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
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
package project.monitor.job.pooldata;
 
import org.apache.commons.lang3.ObjectUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import kernel.util.Arith;
import kernel.util.JsonUtils;
import project.monitor.AutoMonitorPoolDataService;
import project.monitor.model.AutoMonitorPoolData;
import project.syspara.Syspara;
import project.syspara.SysparaService;
import util.RandomUtil;
 
/**
 * 矿池产出数据更新定时器
 *
 */
public class AutoMonitorPoolDataUpdateJob {
    
    private static final Logger logger = LoggerFactory.getLogger(AutoMonitorPoolDataUpdateJob.class);
    
    private AutoMonitorPoolDataService autoMonitorPoolDataService;
    
    private SysparaService sysparaService;
    
    public void taskJob() {    
        Syspara syspara = sysparaService.find("project_type");    
        logger.info("矿池产出收益开始执行");
        if(ObjectUtils.isEmpty(syspara)) {
            return;
        }
        if (!syspara.getValue().contains("DAPP_EXCHANGE")) {
            return;
        }
        logger.info("矿池产出收益开始执行项目类型"+syspara.getValue());
        int randomVerifier = RandomUtil.random(35, 65); 
        int randomAmount = RandomUtil.random(1500, 2500);        
        int randomNode = RandomUtil.random(10, 50);  
        AutoMonitorPoolData data = autoMonitorPoolDataService.findDefault();
        Syspara mining_pool_config = sysparaService.find("mining_pool_config");
        if(ObjectUtils.isNotEmpty(mining_pool_config)) {
            try {
                String miningPoolConfig = mining_pool_config.getValue();
                if(!"0".equals(miningPoolConfig)) {
                    String[] arr1 = miningPoolConfig.split(",");
                    String random[] = arr1[0].split("-");
                    randomVerifier = RandomUtil.random(Integer.parseInt(random[0]), Integer.parseInt(random[1]));            
                    String random2[] = arr1[1].split("-");
                    int user_revenue = RandomUtil.random(Integer.parseInt(random2[0]), Integer.parseInt(random2[1]));
                    data.setUser_revenue(Arith.add(data.getUser_revenue(), user_revenue));
                    String random3[] = arr1[2].split("-");
                    randomAmount = RandomUtil.random(Integer.parseInt(random3[0]), Integer.parseInt(random3[1]));
                    String random4[] = arr1[3].split("-");
                    randomNode =  RandomUtil.random(Integer.parseInt(random4[0]), Integer.parseInt(random4[1]));
                }
            } catch (Exception e) {
                logger.error("taskJob解析异常",e.getMessage());
            }            
        }        
        data.setTradingSum(Arith.add(data.getTradingSum(), randomAmount));
        data.setVerifier(Arith.add(data.getVerifier(), randomVerifier));
        data.setNode_num(Arith.add(data.getNode_num(), randomNode));
        data.setMining_total(Arith.add(data.getMining_total(), randomAmount));
        
        String noticeRate = sysparaService.find("notice_rate").getValue();
        data.setNotice_logs(JsonUtils.bean2Json(autoMonitorPoolDataService.createNotice(noticeRate)));
        autoMonitorPoolDataService.update(data);
    }
 
    public AutoMonitorPoolDataService getAutoMonitorPoolDataService() {
        return autoMonitorPoolDataService;
    }
 
    public void setAutoMonitorPoolDataService(AutoMonitorPoolDataService autoMonitorPoolDataService) {
        this.autoMonitorPoolDataService = autoMonitorPoolDataService;
    }
 
    public void setSysparaService(SysparaService sysparaService) {
        this.sysparaService = sysparaService;
    }
    
}