lizixuan
/
coinbus
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

update 稳定币流通量定时任务修改完成

This commit is contained in:
yyb 2025-05-16 17:08:54 +08:00
parent 9c93dc1e10
commit 6e5a63784f
2 changed files with 33 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
jxy-common/common-core/src/main/java/com/jxy/common/core/utils/DateUtils.java
View File

@ -307,4 +307,22 @@ public class DateUtils extends org.apache.commons.lang3.time.DateUtils
return DateUtils.parseDate(format);
}
/**
* 获取当天零点零时零分 时间
* @return Date
*/
public static Date getZeroTimeOfToday() {
// 获取 Calendar 实例
Calendar calendar = Calendar.getInstance();
// 将小时、分钟、秒和毫秒都设置为 0
calendar.set(Calendar.HOUR_OF_DAY, 0);
calendar.set(Calendar.MINUTE, 0);
calendar.set(Calendar.SECOND, 0);
calendar.set(Calendar.MILLISECOND, 0);
// 返回 Date 对象
return calendar.getTime();
}
}

24
jxy-modules/jxy-marketall/src/main/java/com/jxy/marketall/task/CSupplyTask.java
View File

@ -20,8 +20,11 @@ import java.math.BigDecimal;
import java.net.InetSocketAddress;
import java.net.Proxy;
import java.net.URI;
import java.time.Instant;
import java.util.*;
import static com.jxy.common.core.utils.DateUtils.getZeroTimeOfToday;
/**
* @Description 稳定币流通量
@ -105,20 +108,23 @@ public class CSupplyTask {
JSONObject jsonObject = JSONObject.parseObject(s);
//币种流通量字段
JSONObject marketData = jsonObject.getJSONObject("market_data");
Date date;
try {
//币种流通量最后更新时间
date = (Date) marketData.get("last_updated");
}catch (Exception e){
return null;
}
//String dateString;
//try {
// //币种流通量最后更新时间
// dateString = (String) marketData.get("last_updated");
//}catch (Exception e){
// return null;
//}
//Instant instant = Instant.parse(dateString);
//Date date = Date.from(instant);
Date zeroTimeOfToday = getZeroTimeOfToday();
double doubleValue = marketData.getDoubleValue("circulating_supply");
List<CirculatingSupplyDataDto> circulatingSupplyDataDtos = new ArrayList<>();
CirculatingSupplyDataDto circulatingSupplyDataDto = new CirculatingSupplyDataDto();
circulatingSupplyDataDto.setValue(BigDecimal.valueOf(doubleValue));
circulatingSupplyDataDto.setDate(date);
circulatingSupplyDataDto.setDate(zeroTimeOfToday);
circulatingSupplyDataDtos.add(circulatingSupplyDataDto);
log.info("获取{}币流通量数据成功,最新时间{},流通量{}", coinId, date, doubleValue);
log.info("获取{}币流通量数据成功,最新时间{},流通量{}", coinId, zeroTimeOfToday, doubleValue);
return circulatingSupplyDataDtos;
}