package com.nq.utils.stock.lide;
|
|
import com.alibaba.fastjson.JSON;
|
import com.nq.common.StockIndexConst;
|
import com.nq.utils.HttpClientRequest;
|
import com.nq.utils.HttpRequest;
|
import com.nq.utils.redis.RedisShardedPoolUtils;
|
import com.nq.utils.stock.SerializeUtil;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.util.ObjectUtils;
|
import org.springframework.util.StringUtils;
|
import redis.clients.jedis.ShardedJedis;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
|
public class LiDeDataUtils {
|
|
public static final String URL="http://139.196.211.109/stock_rank.action";
|
|
//全量股票数据接口
|
public static final String QL_URL="http://139.196.211.109/stock_currPlus.action";
|
//新三板股票接口
|
public static final String XSBURL="http://139.196.211.109/new3_currPlus.action";
|
private static final Logger log = LoggerFactory.getLogger(LiDeDataUtils.class);
|
|
/**
|
* 拉取沪深全量数据
|
*/
|
public static void pullData(){
|
String password = null;
|
int size=0;
|
try {
|
password = "52d582b7580d0c019cc05950d3c88829";//Md5Utils.getMD5("jzy123456");
|
String params="?username=mry520&password="+password+"&zs=0&column=mc,open,high,low,pre,price,vol,e,zdf,zde,s1,s2,s3,s4,s5,b1,b2,b3,b4,b5";
|
System.out.println(QL_URL+params);
|
String s = HttpClientRequest.doGet(QL_URL+params);
|
//s=s.replaceFirst("品种代码,开盘价,最高价,最低价,昨收,现价,名称,成交量,成交额,涨跌幅,涨跌额,卖一价,卖二价,卖三价,卖四价,卖五价,买一价,买二价,买三价,买四价,买五价","");
|
String[] split = s.trim().split("\r\n");
|
ArrayList<LideDataVo> lideDataVos = new ArrayList<>();
|
for(int i=1;i<split.length;i++){
|
String stock= split[i];
|
String[] stockSplite = stock.split(",");
|
LideDataVo lideDataVo = new LideDataVo(stockSplite[0], stockSplite[1], stockSplite[2], stockSplite[3], stockSplite[4], stockSplite[5], stockSplite[6],
|
stockSplite[7], stockSplite[8], stockSplite[9], stockSplite[10], stockSplite[11], stockSplite[12], stockSplite[13]
|
, stockSplite[14], stockSplite[15], stockSplite[16], stockSplite[17], stockSplite[18], stockSplite[19], stockSplite[20]);
|
lideDataVos.add(lideDataVo);
|
//System.out.println(lideDataVo);
|
}
|
size=split.length;
|
RedisShardedPoolUtils.stockPipSet(lideDataVos);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
log.info("-------------------全量同步股票结束 {}个--------------",size);
|
}
|
|
/**
|
* 拉取排行榜数据
|
* @return
|
*/
|
public static ArrayList<LideRankDataVo> pullRankData(){
|
String password = null;
|
int size=0;
|
ArrayList<LideRankDataVo> lideDataVos = new ArrayList<>();
|
try {
|
password = "52d582b7580d0c019cc05950d3c88829";//Md5Utils.getMD5("jzy123456");
|
String params="?username=mry520&password="+password+"&zs=0&num=20&order=desc&type=zf&column=mc,price,e,zdf,ltsz,zsz,hsl";
|
System.out.println(URL+params);
|
String s = HttpRequest.doGetZip(URL,params);
|
//System.out.println(s);
|
//s=s.replaceFirst("品种代码,开盘价,最高价,最低价,昨收,现价,名称,成交量,成交额,涨跌幅,涨跌额,卖一价,卖二价,卖三价,卖四价,卖五价,买一价,买二价,买三价,买四价,买五价","");
|
String[] split = s.trim().split("\r\n");
|
for(int i=1;i<split.length;i++){
|
String stock= split[i];
|
String[] stockSplite = stock.split(",");
|
LideRankDataVo lideDataVo = new LideRankDataVo(stockSplite[0],
|
stockSplite[8],
|
Float.valueOf(stockSplite[7]),
|
Long.valueOf(stockSplite[4]),
|
Long.valueOf(stockSplite[5]),
|
Float.valueOf(stockSplite[6]),
|
Long.valueOf(stockSplite[10]),
|
Float.valueOf(stockSplite[3]));
|
lideDataVos.add(lideDataVo);
|
}
|
size=split.length;
|
if(lideDataVos.size()>1){
|
RedisShardedPoolUtils.set("ZDFB_STOCK", JSON.toJSONString(lideDataVos));
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
log.info("-------------------全量同步涨跌榜股票结束 {}个--------------",size);
|
return lideDataVos;
|
|
}
|
|
/**
|
* 拉取新三板数据
|
*/
|
public static void pullXSBData(){
|
String password = null;
|
int size=0;
|
try {
|
password = "52d582b7580d0c019cc05950d3c88829";//Md5Utils.getMD5("jzy123456");
|
String params="?username=mry520&password="+password+"&zs=0&column=mc,open,high,low,pre,price,vol,e,zdf,zde,s1,s2,s3,s4,s5,b1,b2,b3,b4,b5";
|
System.out.println(XSBURL+params);
|
String s = HttpClientRequest.doGet(XSBURL+params);
|
//s=s.replaceFirst("品种代码,开盘价,最高价,最低价,昨收,现价,名称,成交量,成交额,涨跌幅,涨跌额,卖一价,卖二价,卖三价,卖四价,卖五价,买一价,买二价,买三价,买四价,买五价","");
|
String[] split = s.trim().split("\r\n");
|
ArrayList<LideDataVo> lideDataVos = new ArrayList<>();
|
for(int i=1;i<split.length;i++){
|
String stock= split[i];
|
String[] stockSplite = stock.split(",");
|
LideDataVo lideDataVo = new LideDataVo(stockSplite[0], stockSplite[1], stockSplite[2], stockSplite[3], stockSplite[4], stockSplite[5], stockSplite[6],
|
stockSplite[7], stockSplite[8], stockSplite[9], stockSplite[10], stockSplite[11], stockSplite[12], stockSplite[13]
|
, stockSplite[14], stockSplite[15], stockSplite[16], stockSplite[17], stockSplite[18], stockSplite[19], stockSplite[20]);
|
lideDataVos.add(lideDataVo);
|
}
|
size=split.length;
|
RedisShardedPoolUtils.stockPipSet(lideDataVos);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
log.info("-------------------全量同步新三板股票结束 {}个--------------",size);
|
}
|
|
|
public static LideDataVo getStock(String code){
|
String key="STOCK:" + code;
|
LideDataVo lideDataVo = StockIndexConst.STOCKMap.get(key);
|
if(!ObjectUtils.isEmpty(lideDataVo)){
|
return lideDataVo;
|
}
|
byte[] bytearr = RedisShardedPoolUtils.get((key).getBytes());
|
if(!StringUtils.isEmpty(bytearr)){
|
lideDataVo = (LideDataVo) SerializeUtil.unserialize(bytearr,LideDataVo.class);
|
return lideDataVo;
|
}
|
return null;
|
}
|
|
|
|
|
public static void main(String[] args) throws Exception {
|
// String password = Md5Utils.getMD5("password");
|
//// System.out.println(password);
|
// // pullData();
|
//
|
//// LideDataVo lideDataVo = new LideDataVo();
|
//// lideDataVo.setAmount("1111");
|
// ShardedJedis jedis = RedisShardedPool.getJedis();
|
//// String set =jedis.set("STOCK:111".getBytes(), SerializeUtil.serialize(lideDataVo));
|
//// byte[] bytes = jedis.get("STOCK:111".getBytes());
|
//// LideDataVo unserialize = SerializeUtil.unserialize(bytes, LideDataVo.class);
|
//
|
// LideDataVo stock = getStock("688221");
|
// System.out.println(stock);
|
// String s="688077,54.44,11.375,11.375,2452331500,4397554300,8.495,54.44,大地熊,54.44,202496520";
|
// String[] stockSplite = s.split(",");
|
// System.out.println(Float.valueOf("2452331500"));
|
|
pullRankData();
|
|
}
|
}
|
