package com.nq.utils.task.stock;
|
|
import com.alibaba.fastjson2.JSONObject;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.nq.dao.StockMapper;
|
import com.nq.pojo.Stock;
|
import com.nq.service.IStockService;
|
import com.nq.utils.HttpClientRequest;
|
import com.nq.utils.PropertiesUtil;
|
import com.nq.utils.redis.RedisShardedPoolUtils;
|
import com.nq.utils.stock.BuyAndSellUtils;
|
import com.nq.utils.stock.pinyin.GetPyByChinese;
|
import lombok.extern.slf4j.Slf4j;
|
import org.junit.Test;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.PostConstruct;
|
import java.io.UnsupportedEncodingException;
|
import java.net.URLDecoder;
|
import java.util.ArrayList;
|
import java.util.Date;
|
|
import static com.nq.utils.DateTimeUtil.*;
|
|
|
@Component
|
public class StockOthersTask {
|
@Autowired
|
IStockService stockService;
|
@Autowired
|
StockMapper stockMapper;
|
private static final Logger log = LoggerFactory.getLogger(StockOthersTask.class);
|
|
/* //9点到15点每隔10s执行一次
|
// @Scheduled(cron = "0 0/1 9-15 * * MON-FRI")
|
//redis存股票信息
|
@Scheduled(cron = "0/30 0/1 9-16 * * MON-FRI")
|
public void HkStockTask() throws UnsupportedEncodingException {
|
|
//当前毫秒时间戳
|
long now = System.currentTimeMillis();
|
ArrayList diff = null;
|
|
String url = PropertiesUtil.getProperty("hk.stock.url") + now;
|
String result = null;
|
try {
|
result = HttpClientRequest.doGet(url);
|
} catch (Exception e) {
|
log.error("获取港股信息失败，重新获取", e);
|
result = HttpClientRequest.doGet(url);
|
}
|
if (result == null) {
|
log.error("获取港股信息失败");
|
return;
|
}
|
JSONObject json = JSONObject.parseObject(result);
|
//取出data里的diff数组
|
diff = (ArrayList) json.getJSONObject("data").get("diff");
|
|
|
for (Object o : diff) {
|
//取第一条数据存入redisDB1
|
JSONObject data = (JSONObject) o;
|
String stockCode = data.getString("f12");
|
//存入redis
|
RedisShardedPoolUtils.set("hk" + stockCode, String.valueOf(data), 1);
|
}
|
log.info("港股信息存入redis成功");
|
|
}*/
|
|
/**
|
* 美股存redis 22:00-05:00
|
|
// @Scheduled(cron = "0/20 0/1 22-23 * * ?")
|
@Scheduled(cron = "0/25 0/1 * * * ?")
|
|
|
public void UsStockTask() {
|
boolean am = false;
|
boolean pm = false;
|
try {
|
am = BuyAndSellUtils.isTransTime("21:00", "0:00");
|
pm = BuyAndSellUtils.isTransTime("0:00", "5:00");
|
} catch (Exception e) {
|
log.error("= {}", e);
|
}
|
// log.info("美股UsStock-am = {} pm = {}", Boolean.valueOf(am), Boolean.valueOf(pm));
|
if (am || pm) {
|
//当前毫秒时间戳
|
this.usStockTask2();
|
}
|
} */
|
|
/**
|
* 美股信息启动加载
|
*
|
|
public void usStockTask2(){
|
long now = System.currentTimeMillis();
|
ArrayList diff = null;
|
String result = null;
|
String url = PropertiesUtil.getProperty("us.stock.url") + now;
|
try {
|
result = HttpClientRequest.doGet(url);
|
} catch (Exception e) {
|
log.error("获取美股信息失败,尝试重新获取", e);
|
result = HttpClientRequest.doGet(url);
|
}
|
if (result == null) {
|
log.error("获取美股信息失败");
|
return;
|
}
|
//取第一个（后到最后的数据
|
String da = null;
|
try {
|
da = result.substring(result.indexOf("(") + 1, result.indexOf(");"));
|
} catch (Exception e) {
|
log.error("此次美股信息获取失败", e);
|
return;
|
}
|
JSONObject json = JSONObject.parseObject(da);
|
//取出data里的diff数组
|
diff = (ArrayList) json.getJSONObject("data").get("diff");
|
|
for (Object o : diff) {
|
//取第一条数据存入redisDB1
|
JSONObject data = (JSONObject) o;
|
String stockCode = data.getString("f12");
|
//存入redis
|
|
RedisShardedPoolUtils.set("us" + stockCode, String.valueOf(data), 2);
|
}
|
log.info("美股信息存入redis成功");
|
}
|
*/
|
/**
|
* 美股港股指数
|
|
@Scheduled(cron = "0/30 0/1 * * * ?")
|
public void HkIndexTask() throws UnsupportedEncodingException {
|
boolean am = false;
|
boolean pm = false;
|
try {
|
am = BuyAndSellUtils.isTransTime("9:00", "0:00");
|
pm = BuyAndSellUtils.isTransTime("0:00", "5:00");
|
} catch (Exception e) {
|
log.error("= {}", e);
|
}
|
// log.info("HkIndex-am = {} pm = {}", Boolean.valueOf(am), Boolean.valueOf(pm));
|
if (am || pm) {
|
String[] keys = {"hk", "us"};
|
//当前毫秒时间戳
|
long now = System.currentTimeMillis();
|
for (String key : keys) {
|
String url = null;
|
if ("hk".equals(key)) {
|
url = PropertiesUtil.getProperty("hk.index.url") + now;
|
} else {
|
url = PropertiesUtil.getProperty("us.index.url") + now;
|
}
|
|
String result = null;
|
try {
|
result = HttpClientRequest.doGet(url);
|
} catch (Exception e) {
|
log.error("获取指数信息失败,尝试重新获取", e);
|
result = HttpClientRequest.doGet(url);
|
}
|
|
JSONObject json = JSONObject.parseObject(result);
|
|
//取出data里的diff数组
|
ArrayList diff = null;
|
try {
|
diff = (ArrayList) json.getJSONObject("data").get("diff");
|
} catch (Exception e) {
|
log.error("获取指数信息失败", e);
|
return;
|
}
|
|
for (int i = 0; i < diff.size(); i++) {
|
JSONObject data = (JSONObject) diff.get(i);
|
String stockCode = data.getString("f12");
|
//存入redis
|
RedisShardedPoolUtils.set(key + stockCode, String.valueOf(data), 3);
|
}
|
}
|
|
log.info("美股港股指数信息存入redis成功");
|
}
|
}
|
*/
|
/**
|
* @Description: 股票数据启动后初始化
|
* @param
|
* @throws Exception
|
|
@PostConstruct
|
public void init() {
|
try {
|
this.HkStockTask();
|
} catch (UnsupportedEncodingException e) {
|
log.error("初始化港股数据加载失败"+e);
|
}
|
this.usStockTask2();
|
try {
|
this.HkIndexTask();
|
} catch (UnsupportedEncodingException e) {
|
log.error("初始化美港指数数据加载失败"+e);
|
}
|
log.info("=======================数据加载完毕============================");
|
}
|
*/
|
@Test
|
public void test() throws UnsupportedEncodingException {
|
//当前系统分钟时间戳
|
|
String date = getCurrentTimeMiaoZero();
|
//?cat_time=1669089660&stock_gid=sz000001&price=10
|
log.info("date = {}", date);
|
String result = HttpClientRequest.doGet("http://116.124.132.181/stock/base/cx_gp?cat_time="+date+"&stock_gid=sz000001&price=10");
|
log.info("result = {}", result);
|
// net.sf.json.JSONObject jsonObject = net.sf.json.JSONObject.fromObject(result);
|
// String nowPrice = jsonObject.getJSONObject("data").getString("new_price");
|
System.out.println(result);
|
}
|
}
|
