qdintc/intc-cloud
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: 智聪记账管理，期货同步功能,5秒同步一条数据。

Browse Source
This commit is contained in:
tianyongbao
2025-04-03 18:18:25 +08:00
parent 6cb4672a39
commit 97a2eb69e7
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
intc-modules/intc-invest/src/main/java/com/intc/invest/service/impl/FuturesDailyHistoryServiceImpl.java
View File

@@ -228,6 +228,7 @@ public class FuturesDailyHistoryServiceImpl implements IFuturesDailyHistoryServi
List<FutureBaseInforVo> futureBaseInforVos=futureBaseInforMapper.selectFutureBaseInforList(new FutureBaseInforDto()); List<FutureBaseInforVo> futureBaseInforVos=futureBaseInforMapper.selectFutureBaseInforList(new FutureBaseInforDto());
// //
for (FutureBaseInforVo base : futureBaseInforVos) { for (FutureBaseInforVo base : futureBaseInforVos) {
TuShare tuShare = new TuShare(); TuShare tuShare = new TuShare();
tuShare.setToken(tushareToken); tuShare.setToken(tushareToken);
tuShare.setApi_name("fut_daily"); tuShare.setApi_name("fut_daily");
@@ -242,6 +243,12 @@ public class FuturesDailyHistoryServiceImpl implements IFuturesDailyHistoryServi
JsonObject json = gson.toJsonTree(tuShare).getAsJsonObject(); JsonObject json = gson.toJsonTree(tuShare).getAsJsonObject();
Map<String, String> headers = new HashMap<String, String>(); Map<String, String> headers = new HashMap<String, String>();
headers.put("X-Ca-Signature-Headers", "x-ca-key,x-ca-timestamp"); headers.put("X-Ca-Signature-Headers", "x-ca-key,x-ca-timestamp");
//休眠4秒
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
String returnString = HttpUtils.sendSSLPost(tushareUrl, null, JSONObject.parseObject(json.toString()), headers); String returnString = HttpUtils.sendSSLPost(tushareUrl, null, JSONObject.parseObject(json.toString()), headers);
com.alibaba.fastjson.JSONObject jsonObject = com.alibaba.fastjson.JSONObject.parseObject(returnString); com.alibaba.fastjson.JSONObject jsonObject = com.alibaba.fastjson.JSONObject.parseObject(returnString);
TuShareData data = JSON.parseObject(jsonObject.getString("data"), TuShareData.class); TuShareData data = JSON.parseObject(jsonObject.getString("data"), TuShareData.class);