package com.yeshi.makemoney.app.job;
|
|
import com.xxl.job.core.biz.model.ReturnT;
|
import com.xxl.job.core.handler.annotation.XxlJob;
|
import com.yeshi.makemoney.app.entity.SystemEnum;
|
import com.yeshi.makemoney.app.entity.money.Extract;
|
import com.yeshi.makemoney.app.exception.money.ExtractException;
|
import com.yeshi.makemoney.app.service.inter.goldcorn.GoldCornGetRecordService;
|
import com.yeshi.makemoney.app.service.inter.money.ExtractService;
|
import com.yeshi.makemoney.app.service.manager.PushManager;
|
import com.yeshi.makemoney.app.utils.goldcorn.GoldCornUtil;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Component;
|
import org.yeshi.utils.StringUtil;
|
|
import javax.annotation.Resource;
|
import java.math.BigDecimal;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @author hxh
|
* @title: PushJob
|
* @description: 提现任务
|
* @date 2022/5/7 17:44
|
*/
|
@Component
|
public class ExtractJob {
|
|
private Logger logger = LoggerFactory.getLogger(ExtractJob.class);
|
|
@Resource
|
private ExtractService extractService;
|
|
|
/**
|
* @return com.xxl.job.core.biz.model.ReturnT<java.lang.String>
|
* @author hxh
|
* @description 通过提现
|
* @date 14:30 2022/6/20
|
* @param: param
|
**/
|
@XxlJob("pass-extract")
|
public ReturnT<String> passExtract(String param) throws Exception {
|
if (StringUtil.isNullOrEmpty(param)) {
|
param = "1";
|
}
|
Date minDate = new Date(System.currentTimeMillis() - 1000 * 60 * 60 * 24L * 2);
|
long count = extractService.countNeedPassRecord(new BigDecimal(param), minDate);
|
int pageSize = 100;
|
int pageCount = (int) (count % 100 == 0 ? count / 100 : count / 100 + 1);
|
for (int p = 0; p < pageCount; p++) {
|
List<Extract> extractList = extractService.listNeedPassRecord(new BigDecimal(param), minDate, p + 1, pageSize);
|
for (Extract extract : extractList) {
|
try {
|
extractService.passExtract(extract.getId(), "auto_verify_extract");
|
} catch (ExtractException e) {
|
e.printStackTrace();
|
logger.error("机器通过提现出错：id-{}", extract.getId(), e);
|
}
|
}
|
}
|
return ReturnT.SUCCESS;
|
}
|
|
}
|
