package cc.mrbird.febs.mall.quartz;
|
|
import cc.mrbird.febs.mall.controller.dependentStation.TokenviewWebhookService;
|
import cc.mrbird.febs.mall.controller.dependentStation.utils.OkHttpUtil2;
|
import cc.mrbird.febs.mall.controller.dependentStation.utils.Trc20TokenviewContentModel;
|
import cc.mrbird.febs.mall.controller.dependentStation.utils.Trc20TokenviewModel;
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import com.alibaba.fastjson.JSONObject;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.nio.charset.StandardCharsets;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
@Slf4j
|
@Component
|
@ConditionalOnProperty(prefix = "system", name = "job", havingValue = "true")
|
public class ChatTrc20ChargeOkLinkTask {
|
|
@Resource
|
private TokenviewWebhookService tokenviewWebhookService;
|
|
/**
|
* 30分钟（毫秒）
|
*/
|
private final static long TIME_INTERVAL = 300000 * 6;
|
|
private final static String TRON_API_KEY = "X8Np5zbDuhmG6cntbhLu";
|
|
private static Map<String, String> REQUEST_HEADER = new HashMap<>();
|
static {
|
REQUEST_HEADER.put("TRON-PRO-API-KEY", TRON_API_KEY);
|
}
|
|
/**
|
* 每分钟轮询 Tokenview API，查询 TRC20-USDT 充值记录
|
* 充值匹配逻辑委托给 {@link TokenviewWebhookService}
|
*/
|
@Scheduled(cron = "0 0/1 * * * ? ")
|
public void recharge() {
|
String receiveAddress = tokenviewWebhookService.getReceiveAddress();
|
if (receiveAddress == null) {
|
log.error("请先配置系统地址");
|
return;
|
}
|
|
String url = "https://services.tokenview.io/vipapi/trx/address/tokentrans/"
|
+ receiveAddress + "/TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t/1/10";
|
|
long endTime = System.currentTimeMillis();
|
long startTime = endTime - TIME_INTERVAL;
|
|
log.info("自动充值定时任务 startTime={}, endTime={}", startTime, endTime);
|
|
Map<String, String> param = new HashMap<>();
|
param.put("timestampStart", startTime + "");
|
param.put("timestampEnd", endTime + "");
|
param.put("toAddress", receiveAddress);
|
param.put("apikey", TRON_API_KEY);
|
|
long start = System.currentTimeMillis();
|
byte[] bytes = OkHttpUtil2.doGetSingle(url, REQUEST_HEADER, param, "application/json");
|
|
if (ObjectUtil.isEmpty(bytes)) {
|
log.error("查询链上数据返回为空, param={}", param);
|
return;
|
}
|
|
String response = new String(bytes, StandardCharsets.UTF_8);
|
log.info("查询到的充值记录：{}", response);
|
|
Trc20TokenviewModel model = JSONObject.parseObject(response, Trc20TokenviewModel.class);
|
List<Trc20TokenviewContentModel> tokenTransfers = model.getData();
|
if (CollUtil.isEmpty(tokenTransfers)) {
|
return;
|
}
|
|
log.info("查询耗时：{}ms, 记录数：{}, 时间区间 [{}, {}]",
|
System.currentTimeMillis() - start, tokenTransfers.size(), startTime, endTime);
|
|
for (Trc20TokenviewContentModel transfer : tokenTransfers) {
|
log.info("链上时间: {}", transfer.getTime());
|
String result = tokenviewWebhookService.processPollTransaction(
|
transfer.getTxid(),
|
transfer.getValue(),
|
receiveAddress
|
);
|
log.info("轮询处理结果: {}", result);
|
}
|
}
|
|
public static void main(String[] args) {
|
String receiveAddress = "TExto1UjtFcXKw5QdJDRqtx7wTQ15D37GD";
|
String url = "https://services.tokenview.io/vipapi/trx/address/tokentrans/"
|
+ receiveAddress + "/TR7NHqjeKQxGTCi8q8ZY4pL8otSzgjLj6t/1/10";
|
|
long endTime = System.currentTimeMillis();
|
long startTime = endTime - TIME_INTERVAL;
|
|
System.out.println(new Date() + " 自动充值定时任务 " + startTime + " " + endTime);
|
|
Map<String, String> param = new HashMap<>();
|
param.put("timestampStart", startTime + "");
|
param.put("timestampEnd", endTime + "");
|
param.put("toAddress", receiveAddress);
|
param.put("apikey", TRON_API_KEY);
|
|
byte[] bytes = OkHttpUtil2.doGetSingle(url, REQUEST_HEADER, param, "application/json");
|
|
if (bytes == null) {
|
System.out.println("查询链上数据返回为空, param=" + param);
|
return;
|
}
|
|
String s = new String(bytes, StandardCharsets.UTF_8);
|
System.out.println(s);
|
System.exit(0);
|
}
|
}
|
