nhanvubk/ger-market-java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/develop' into develop

Browse Source 
# Conflicts:
#	src/main/java/cn/stock/market/web/StockApiController.java
This commit is contained in:
dengli
2023-12-04 14:20:08 +08:00
parent cffba8202d 93fc03bfa9
commit e350a14ccd
11 changed files with 604 additions and 192 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/generated/cn/stock/market/infrastructure/db/po/QSiteSettingPO.java
View File

@@ -15,7 +15,7 @@ import com.querydsl.core.types.Path;
@Generated("com.querydsl.codegen.EntitySerializer")
public class QSiteSettingPO extends EntityPathBase<SiteSettingPO> {
private static final long serialVersionUID = -51441337L;
private static final long serialVersionUID = 926298165L;
public static final QSiteSettingPO siteSettingPO = new QSiteSettingPO("siteSettingPO");

6
src/main/generated/cn/stock/market/infrastructure/db/po/QStockPO.java
View File

@@ -15,7 +15,7 @@ import com.querydsl.core.types.Path;
@Generated("com.querydsl.codegen.EntitySerializer")
public class QStockPO extends EntityPathBase<StockPO> {
private static final long serialVersionUID = -1246401708L;
private static final long serialVersionUID = 2143409346L;
public static final QStockPO stockPO = new QStockPO("stockPO");
@@ -33,6 +33,8 @@ public class QStockPO extends EntityPathBase<StockPO> {
public final StringPath stockCode = createString("stockCode");
public final NumberPath<Integer> stockExchangeId = createNumber("stockExchangeId", Integer.class);
public final StringPath stockGid = createString("stockGid");
public final StringPath stockName = createString("stockName");
@@ -43,6 +45,8 @@ public class QStockPO extends EntityPathBase<StockPO> {
public final NumberPath<Integer> stockState = createNumber("stockState", Integer.class);
public final NumberPath<Integer> stockSymbol = createNumber("stockSymbol", Integer.class);
public final StringPath stockType = createString("stockType");
public QStockPO(String variable) {

2
src/main/java/cn/stock/market/application/CommonApis.java
View File

@@ -47,7 +47,7 @@ public class CommonApis {
public Map<String, StockVO> stockDetailMap(List<StockCode> code) {
Function<StockSource, List<StockCode>> func = (source) -> {
return code.stream()
.filter(val -> val != null && source == val.getSource())
// .filter(val -> val != null && source == val.getSource())
.collect(Collectors.collectingAndThen(Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(StockCode::getCode))), ArrayList::new));
};

179
src/main/java/cn/stock/market/domain/basic/service/StockService.java
View File

@@ -1,5 +1,6 @@
package cn.stock.market.domain.basic.service;
import java.io.IOException;
import java.math.BigDecimal;
import java.text.SimpleDateFormat;
import java.util.*;
@@ -74,41 +75,6 @@ public class StockService {
String apikey = "VF7SHRYOFIYHCIKE";
public static final String API_HEADER = ":method: GET\n"
+ ":scheme: https\n"
+ ":path: /get_screen.php?screen_ID=22&skinID=1&overview_table_order=1&time_utc_offset=28800&pair_ID=1156730&additionalTimeframes=Yes&lang_ID=6&include_pair_attr=true&v2=1\n"
+ ":authority: cnappapi.investing.com\n"
+ "cache-control: no-cache\n"
+ "user-agent: Investing.China/64 CFNetwork/1390 Darwin/22.0.0\n"
+ "x-os: ios\n"
+ "x-idfa-perm: 0\n"
+ "x-os-ver: 16.0\n"
+ "x-app-ver: 156\n"
+ "apf_src: no\n"
+ "x-meta-ver: 14\n"
+ "accept-language: zh-CN,zh-Hans;q=0.9\n"
+ "accept: */*\n"
+ "ccode: CN\n"
+ "";
static OkHttpClient httpClient;
public static OkHttpClient httpClient() {
if(httpClient == null) {
X509TrustManager manager = SSLSocketClientUtil.getX509TrustManager();
httpClient = new OkHttpClient.Builder()
.followRedirects(true) // 为了制造非200状态码，禁止302跳转
.protocols(Collections.unmodifiableList(Arrays.asList(Protocol.HTTP_1_1, Protocol.HTTP_2)))// 启用http2.0协议 //, Protocol.HTTP_2
.sslSocketFactory(SSLSocketClientUtil.getSocketFactory(manager), manager)
.hostnameVerifier(SSLSocketClientUtil.getHostnameVerifier())//忽略校验
.retryOnConnectionFailure(true)
.connectTimeout(60, TimeUnit.SECONDS)
.readTimeout(60, TimeUnit.SECONDS)
.build();
}
return httpClient;
}
public ServerResponse getMarket() {
String market_url = "https://hq.sinajs.cn/rn=1520407404627&list=s_sh000001,s_sz399001,s_sz399006,s_sz399300,s_sz399005,s_sz399673,s_sz399106,s_sz399004,s_sz399100";
String result = null;
@@ -569,22 +535,6 @@ public class StockService {
return SpringUtils.getBean(StockService.class);
}
public ServerResponse getIndiaK(String code, Integer type) {
if (type == 0) {
return getYCTimeK(code);
}
if (type == 1) {
return getYQDayK(code);
}
if (type == 2) {
return getYQWeekK(code);
}
if (type == 3) {
return getYQMonthK(code);
}
return null;
}
/* 指数日线-K线 */
public ServerResponse getIndexDayK(String code) {
return getIndexK(code, "day");
@@ -678,73 +628,6 @@ public class StockService {
return null;
}
//印度股票个股详情 英财
public ServerResponse getYCStockInfo(String codeId) {
log.info("开始查询个股行情");
String sina_result = "";
try {
INDStockInfo indStockInfo = new INDStockInfo();
String tmpl = "https://cnappapi.investing.com/get_screen.php?v2=1&additionalTimeframes=Yes&time_utc_offset=28800&overview_table_order=0&skinID=1&lang_ID=6&include_pair_attr=true&screen_ID=22&pair_ID={}";
String url = StrFormatter.format(tmpl, codeId);
log.info("url: {}", url);
Builder builder = new Request.Builder().url(url).method("GET", null);
addHeader(builder, API_HEADER);
sina_result = httpClient().newCall(builder.build()).execute().body().string();
JSONArray pairs_data = JSON.parseObject(sina_result)
.getJSONArray("data").getJSONObject(0)
.getJSONObject("screen_data").getJSONArray("pairs_data");
JSONArray overview_table = pairs_data.getJSONObject(0).getJSONArray("overview_table");
JSONObject info_header = pairs_data.getJSONObject(0).getJSONObject("info_header");
indStockInfo.setClose(find_overview_table_value_with_key(overview_table, "昨收"));
indStockInfo.setVolume(find_overview_table_value_with_key(overview_table, "成交量"));
indStockInfo.setOpen(find_overview_table_value_with_key(overview_table, "开盘"));
String range = find_overview_table_value_with_key(overview_table, "当日幅度"); //6.91 - 7.89
if(StringUtils.isNotBlank(range)) {
String[] split = range.trim().split("-");
indStockInfo.setLow(numberToString(split[0]));
indStockInfo.setHigh(numberToString(split[1]));
}
String last = info_header.getString("last"); //当前价
indStockInfo.setPrice(numberToString(last));
String percent_tooltip_value = info_header.getString("percent_tooltip_value"); //涨幅
indStockInfo.setPrice(percent_tooltip_value);
String change = info_header.getString("change"); //涨幅值 ("+0.65")
if(change.startsWith("+")) {
indStockInfo.setChange(numberToString(change.substring(1)));
} else {
indStockInfo.setChange(numberToString(change));
}
return ServerResponse.createBySuccess(indStockInfo);
} catch (Exception e) {
log.error("获取出错，错误信息 = {}", e);
}
return null;
}
//印度股票列表 英财
public ServerResponse getINDStockList(Integer pageSize, Integer pageNum) {
String sina_result = "";
try {
String tmpl = "https://api.investing.com/api/financialdata/assets/equitiesByCountry/default?fields-list=id,name,symbol,high,low,last,lastPairDecimal,change,changePercent,volume,time,isOpen,url,flag,countryNameTranslated,exchangeId,performanceDay,performanceWeek,performanceMonth,performanceYtd,performanceYear,performance3Year,technicalHour,technicalDay,technicalWeek,technicalMonth,avgVolume,fundamentalMarketCap,fundamentalRevenue,fundamentalRatio,fundamentalBeta,pairType&country-id=14&page={}&page-size={}&include-major-indices=false&include-additional-indices=false&include-primary-sectors=false&include-other-indices=false&limit=0";
String url = StrFormatter.format(tmpl, pageNum, pageSize);
Stopwatch stopwatch = Stopwatch.createStarted();
log.info("url: {}", url);
Builder builder = new Request.Builder().url(url).method("GET", null);
String body = httpClient().newCall(builder.build()).execute().body().string();
sina_result = JSON.parseObject(body).toString();
return ServerResponse.createBySuccess(sina_result);
} catch (Exception e) {
log.error("获取出错，错误信息 = {}", e);
}
return null;
}
//印度股票时线-K线
public ServerResponse getTimeK(String stockCode) {
String sina_result = "";
@@ -760,21 +643,6 @@ public class StockService {
return null;
}
//印度股票时线-K线 英情
public ServerResponse getYCTimeK(String codeId) {
String sina_result = "";
try {
sina_result = HttpClientRequest.http2Get("https://api.investing.com/api/financialdata/"+codeId+"/historical/chart/?interval=PT5M&pointscount=160");
JSONObject json = JSONObject.parseObject(sina_result).getJSONObject("Time Series (Daily)");
return ServerResponse.createBySuccess(json);
} catch (Exception e) {
log.error("获取出错，错误信息 = {}", e);
}
return null;
}
//印度股票日线-K线
public ServerResponse getDayK(String stockCode) {
String sina_result = "";
@@ -790,21 +658,6 @@ public class StockService {
return null;
}
//印度股票日线-K线
public ServerResponse getYQDayK(String codeId) {
String sina_result = "";
try {
sina_result = HttpClientRequest.http2Get("https://api.investing.com/api/financialdata/"+codeId+"/historical/chart/?interval=P1D&pointscount=160");
JSONObject json = JSONObject.parseObject(sina_result).getJSONObject("Time Series (Daily)");
return ServerResponse.createBySuccess(json);
} catch (Exception e) {
log.error("获取出错，错误信息 = {}", e);
}
return null;
}
//印度股票周线-K线
public ServerResponse getWeekK(String stockCode) {
String sina_result = "";
@@ -821,21 +674,6 @@ public class StockService {
}
//印度股票周线-K线 英情
public ServerResponse getYQWeekK(String codeId) {
String sina_result = "";
try {
sina_result = HttpClientRequest.http2Get("https://api.investing.com/api/financialdata/"+codeId+"/historical/chart/?interval=P1W&pointscount=160");
JSONObject json = JSONObject.parseObject(sina_result).getJSONObject("Time Series (Daily)");
return ServerResponse.createBySuccess(json);
} catch (Exception e) {
log.error("获取出错，错误信息 = {}", e);
}
return null;
}
//印度股票月线-K线
public ServerResponse getMonthK(String stockCode) {
String sina_result = "";
@@ -851,21 +689,6 @@ public class StockService {
return null;
}
//印度股票月线-K线 英情
public ServerResponse getYQMonthK(String codeId) {
String sina_result = "";
try {
sina_result = HttpClientRequest.http2Get("https://api.investing.com/api/financialdata/"+codeId+"/historical/chart/?interval=P1M&pointscount=160");
JSONObject json = JSONObject.parseObject(sina_result).getJSONObject("Time Series (Daily)");
return ServerResponse.createBySuccess(json);
} catch (Exception e) {
log.error("获取出错，错误信息 = {}", e);
}
return null;
}
public ServerResponse getNewStockList() {
try {
JSONObject jsonParam = new JSONObject();

15
src/main/java/cn/stock/market/dto/model/StockCode.java
View File

@@ -14,17 +14,20 @@ import lombok.experimental.SuperBuilder;
@ApiModel
public class StockCode {
String code;
StockSource source;
// StockSource source;
public static StockCode a(String code) {
return of(code, StockSource.A);
return StockCode.builder().code(code)
.build();
}
public static StockCode of(String code, String source) {
return of(code, StockSource.of(source));
public static StockCode of(String code) {
return StockCode.builder().code(code)
.build();
}
public static StockCode of(String code, StockSource source) {
return StockCode.builder().code(code).source(source).build();
return StockCode.builder().code(code)
// .source(source)
.build();
}
}

81
src/main/java/cn/stock/market/infrastructure/api/investing/IndiaStockVO.java Normal file
View File

@@ -0,0 +1,81 @@
package cn.stock.market.infrastructure.api.investing;
import cn.qutaojing.common.utils.BigDecimals;
import cn.stock.market.dto.model.StockVO;
import lombok.Data;
@Data
public class IndiaStockVO {
private Integer id;
/**
* 股票名称
*/
private String name;
/**
* 股票中文名称
*/
private String cname;
/**
* 股票代码
*/
private String code;
private Integer isLock;
private Integer isShow;
/**
* 股票价格
*/
private String nowPrice;
private String open;
private String high;
private String low;
private String close;
/**
* 成交额(暂未获取到)
*/
private String turnover;
/**
* 成交量
*/
private String volume;
private String marketValue;
/**
* 股票涨跌幅
*/
private String number;
/**
* 股票涨跌幅百分比
*/
private String rate;
/*是否添加自选：1、添加自选，0、未添加自选*/
private String isOption;
private String time;
private String type; //股票类型
String url;
String targetId;
public StockVO toStockVo() {
StockVO vo = new StockVO();
vo.setName(name);
vo.setCode(code);
vo.setNowPrice(nowPrice);
vo.setHcrate(BigDecimals.divide(BigDecimals.p(rate), 100));
vo.setToday_max(high);
vo.setToday_min(low);
vo.setOpen_px(open);
vo.setPreclose_px(close);
return vo;
}
}

268
src/main/java/cn/stock/market/infrastructure/api/investing/InvestingApis.java Normal file
View File

@@ -0,0 +1,268 @@
package cn.stock.market.infrastructure.api.investing;
import java.io.IOException;
import java.util.Date;
import java.util.List;
import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors;
import org.apache.commons.lang.StringUtils;
import com.ag.utils.CollectionUtils;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.github.pagehelper.PageInfo;
import com.google.common.base.Stopwatch;
import com.google.common.collect.Lists;
import cn.hutool.core.date.DateUtil;
import cn.qutaojing.common.utils.BigDecimals;
import cn.stock.market.dto.model.StockCode;
import cn.stock.market.utils.RequestCacheUtils;
import cn.stock.market.utils.ServerResponse;
import lombok.extern.slf4j.Slf4j;
@Slf4j
public class InvestingApis {
public IndiaStockVO market(StockCode code) {
List<IndiaStockVO> list = batchMarket(Lists.newArrayList(code));
return CollectionUtils.isNotEmpty(list) ? list.get(0) : null;
}
public List<IndiaStockVO> batchMarket(List<StockCode> list) {
List<IndiaStockVO> retList = Lists.newArrayList();
for (StockCode code : list) {
ServerResponse<IndiaStockVO> response = RequestCacheUtils.cache("_INDIA_", "targetId_" + code.getCode(), (string) -> {
IndiaStockVO vo = _market(code);
return ServerResponse.createBySuccess(vo);
});
if(response.getData() != null) {
retList.add(response.getData());
}
}
return retList;
}
public IndiaStockVO _market(StockCode code) {
try {
JSONObject json = InvestingInvokerApis.of().__market(code);
JSONArray pairs_data = json
.getJSONArray("data").getJSONObject(0)
.getJSONObject("screen_data").getJSONArray("pairs_data");
IndiaStockVO vo = new IndiaStockVO();
JSONArray overview_table = pairs_data.getJSONObject(0).getJSONArray("overview_table");
JSONObject info_header = pairs_data.getJSONObject(0).getJSONObject("info_header");
String pair_name_base = info_header.getString("pair_name_base");
String pair_ID = info_header.getString("pair_ID");
vo.setName(pair_name_base);
vo.setCname(pair_name_base);
vo.setCode(pair_ID);
String 昨收 = find_overview_table_value_with_key(overview_table, "昨收");
vo.setClose(numberToString(昨收));
String 开盘 = find_overview_table_value_with_key(overview_table, "开盘");
String 成交量 = find_overview_table_value_with_key(overview_table, "成交量"); //658,477,949
vo.setVolume(numberToString(成交量));
if(StringUtils.isNotBlank(开盘)) {
vo.setOpen(numberToString(开盘));
}
String 当日幅度 = find_overview_table_value_with_key(overview_table, "当日幅度"); //6.91 - 7.89
if(StringUtils.isNotBlank(当日幅度)) {
String[] split = 当日幅度.trim().split("-");
vo.setLow(numberToString(split[0]));
vo.setHigh(numberToString(split[1]));
} else {
}
String last = info_header.getString("last"); //当前价
vo.setNowPrice(numberToString(last));
String percent_tooltip_value = info_header.getString("percent_tooltip_value"); //涨幅
vo.setRate(percent_tooltip_value);
String change = info_header.getString("change"); //涨幅值 ("+0.65")
if(change.startsWith("+")) {
vo.setNumber(numberToString(change.substring(1)));
} else {
vo.setNumber(numberToString(change));
}
if(BigDecimals.loeZero(vo.getNowPrice())) {
log.warn("{} 当前价非法, 将忽略.", JSON.toJSONString(vo));
return null;
} else {
return vo;
}
} catch (IOException e) {
log.error("batchIndiaStockMarketData>>code:{}, 失败. 跳过", code, e);
}
return null;
}
public static String numberToString(String string) {
return StringUtils.replace(string, ",", "");
}
public static String find_overview_table_value_with_key(JSONArray overview_table_value, String key) {
for (Object obj : overview_table_value) {
JSONObject item = (JSONObject) obj;
if(StringUtils.equals(item.getString("key"), key)) {
return item.getString("val");
}
}
return null;
}
/**
* "AvgVolume": 3741486,
"Chg": -9.55,
"ChgPct": -5.25,
"CountryNameTranslated": "India",
"ExchangeId": "46",
"Flag": "IN",
"FundamentalBeta": 0.916,
"FundamentalMarketCap": 448530000000,
"FundamentalRatio": 8.41,
"FundamentalRevenue": "250.56B",
"High": 183,
"Id": "7310",
"IsOpen": "0",
"Last": 172.35,
"LastPairDecimal": 2,
"Low": 171.45,
"Name": "Aditya Birla Capital",
"PairType": "Equities",
"Performance3Year": 150.69,
"PerformanceDay": -5.25,
"PerformanceMonth": -2.38,
"PerformanceWeek": -5.67,
"PerformanceYear": 48.71,
"PerformanceYtd": 14.75,
"Symbol": "ADTB",
"TechnicalDay": "strong_sell",
"TechnicalHour": "strong_sell",
"TechnicalMonth": "strong_buy",
"TechnicalWeek": "sell",
"Time": "1698055197",
"Url": "/equities/aditya-birla",
"Volume": 3693615
* @param httpClient
* @param currPage
* @param pageSize
* @return
* @throws IOException
*/
public PageInfo<IndiaStockVO> page(int currPage, int pageSize) throws IOException {
JSONObject json = InvestingInvokerApis.of().__page(currPage, pageSize);
int totalPages = (json.getIntValue("total") / json.getIntValue("pageSize")) + 1;
log.info("总页码数: {}", totalPages);
List<IndiaStockVO> items = json.getJSONArray("data").stream().map(val -> {
JSONObject j = (JSONObject) val;
IndiaStockVO vo = new IndiaStockVO();
vo.setName(j.getString("Name"));
vo.setCname(j.getString("Name"));
vo.setCode(j.getString("Symbol"));
vo.setIsLock(0);
vo.setIsShow(0);
vo.setNowPrice(numberToString(j.getString("Last")));
vo.setOpen("--");
vo.setClose("--");
vo.setNumber(numberToString(j.getString("Chg")));
vo.setRate(numberToString(j.getString("ChgPct")));
vo.setHigh(numberToString(j.getString("High")));
vo.setLow(numberToString(j.getString("Low")));
vo.setUrl(numberToString(j.getString("Url")));
vo.setTargetId(j.getString("Id"));
vo.setType("印度");
return vo;
}).collect(Collectors.toList());
PageInfo<IndiaStockVO> page = new PageInfo<>();
page.setPageNum(currPage);
page.setPageSize(pageSize);
page.setTotal(json.getIntValue("total"));
page.setPages(totalPages);
page.setList(items);
return page;
}
public List<IndiaStockVO> thirdIndiaList() throws IOException {
List<IndiaStockVO> list = Lists.newArrayList();
Stopwatch stopwatch = Stopwatch.createStarted();
int totalPages = 0;
int currPage = 0;
do {
try {
PageInfo<IndiaStockVO> page = page(currPage, 100);
totalPages = page.getPages();
currPage ++;
list.addAll(page.getList());
} catch(Exception e) {
log.error("发送错误, 跳过", e);
continue;
}
} while(currPage < totalPages);
log.info("获取印度股票列表执行完毕, 查询到数据 {} 条, 耗时: {} 毫秒", list.size(), stopwatch.elapsed(TimeUnit.MILLISECONDS));
return list;
}
/**
*
* @param code
* @param string min/day/week/month
* @return
* @throws IOException
*/
public List<JSONObject> kline(StockCode code, String string) throws IOException {
if(code == null) {
throw new RuntimeException("找不到股票信息");
}
String interval = null;
if("min".equalsIgnoreCase(string)) {
interval = "PT5M";
} else if("day".equalsIgnoreCase(string)) {
interval = "P1D";
} else if("week".equalsIgnoreCase(string)) {
interval = "P1W";
} else if("month".equalsIgnoreCase(string)) {
interval = "P1M";
}
Date nowDate = new Date();
JSONObject json = InvestingInvokerApis.of().__kline(code, interval);
return json
.getJSONArray("data")
.stream()
.map(val -> {
JSONArray _ar = (JSONArray) val;
JSONObject item = new JSONObject();
item.put("date", _ar.get(0));
item.put("open", _ar.get(1));
item.put("high", _ar.get(2));
item.put("low", _ar.get(3));
item.put("close", _ar.get(4));
item.put("volume", _ar.get(5));
return item;
}).filter(val -> {
// if("min".equalsIgnoreCase(string)) {
// return DateUtil.isSameDay(nowDate, new Date(val.getLong("date")));
// }
return true;
})
.collect(Collectors.toList())
;
}
public static InvestingApis of() {
return new InvestingApis();
}
}

170
src/main/java/cn/stock/market/infrastructure/api/investing/InvestingInvokerApis.java Normal file
View File

@@ -0,0 +1,170 @@
package cn.stock.market.infrastructure.api.investing;
import java.io.IOException;
import java.util.Arrays;
import java.util.Collections;
import java.util.concurrent.TimeUnit;
import javax.net.ssl.X509TrustManager;
import org.apache.commons.lang.StringUtils;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.google.common.base.Stopwatch;
import cn.hutool.core.text.StrFormatter;
import cn.stock.market.dto.model.StockCode;
import lombok.extern.slf4j.Slf4j;
import okhttp3.OkHttpClient;
import okhttp3.Protocol;
import okhttp3.Request;
import okhttp3.Request.Builder;
@Slf4j
public class InvestingInvokerApis {
public static final int COUNTRY_ID = 14; // INDIA
public static final String API_HEADER = ":method: GET\n"
+ ":scheme: https\n"
+ ":path: /get_screen.php?screen_ID=22&skinID=1&overview_table_order=1&time_utc_offset=28800&pair_ID=1156730&additionalTimeframes=Yes&lang_ID=6&include_pair_attr=true&v2=1\n"
+ ":authority: cnappapi.investing.com\n"
+ "cache-control: no-cache\n"
+ "user-agent: Investing.China/64 CFNetwork/1390 Darwin/22.0.0\n"
+ "x-os: ios\n"
+ "x-idfa-perm: 0\n"
+ "x-os-ver: 16.0\n"
+ "x-app-ver: 156\n"
+ "apf_src: no\n"
+ "x-meta-ver: 14\n"
+ "accept-language: zh-CN,zh-Hans;q=0.9\n"
+ "accept: */*\n"
+ "ccode: CN\n"
+ "";
public static final String API_HEADER_LIST = "Host: api.investing.com\n"
+ "User-Agent: Mozilla/5.0 (Macintosh; Intel Mac OS X 10.15; rv:109.0) Gecko/20100101 Firefox/119.0\n"
+ "Accept: application/json, text/plain, */*\n"
+ "Accept-Language: zh-CN,zh;q=0.8,zh-TW;q=0.7,zh-HK;q=0.5,en-US;q=0.3,en;q=0.2\n"
+ "domain-id: cn\n"
+ "Origin: https://cn.investing.com\n"
+ "Connection: keep-alive\n"
+ "Referer: https://cn.investing.com/\n"
+ "Sec-Fetch-Dest: empty\n"
+ "Sec-Fetch-Mode: cors\n"
+ "Sec-Fetch-Site: same-site\n"
+ "Pragma: no-cache\n"
+ "Cache-Control: no-cache\n"
+ "TE: trailers";
static OkHttpClient httpClient;
public static OkHttpClient httpClient() {
if(httpClient == null) {
X509TrustManager manager = SSLSocketClientUtil.getX509TrustManager();
httpClient = new OkHttpClient.Builder()
.followRedirects(true) // 为了制造非200状态码，禁止302跳转
.protocols(Collections.unmodifiableList(Arrays.asList(Protocol.HTTP_1_1, Protocol.HTTP_2)))// 启用http2.0协议 //, Protocol.HTTP_2
.sslSocketFactory(SSLSocketClientUtil.getSocketFactory(manager), manager)
.hostnameVerifier(SSLSocketClientUtil.getHostnameVerifier())//忽略校验
.retryOnConnectionFailure(true)
.connectTimeout(60, TimeUnit.SECONDS)
.readTimeout(60, TimeUnit.SECONDS)
.build();
}
return httpClient;
}
public static void addHeader(Builder builder,String headerLines) {
String[] headers = StringUtils.split(headerLines, "\n");
for (String header : headers) {
String[] split2 = StringUtils.split(header, ": ");
String key = split2[0];
String value = StringUtils.substring(header, key.length() + 2);
builder.header(key, value);
}
}
public static Builder builderGet(String url) {
return new Request.Builder().url(url).method("GET", null);
}
public JSONObject __market(StockCode code) throws IOException {
Stopwatch stopwatch = Stopwatch.createStarted();
String tmpl = "https://cnappapi.investing.com/get_screen.php?v2=1&additionalTimeframes=Yes&time_utc_offset=28800&overview_table_order=0&skinID=1&lang_ID=6&include_pair_attr=true&screen_ID=22&pair_ID={}";
String url = StrFormatter.format(tmpl, code.getCode());
log.info("url: {}", url);
Builder builder = builderGet(url);
addHeader(builder, API_HEADER);
String body = httpClient().newCall(builder.build()).execute().body().string();
log.info("india market cost: {} ms, url: {}, body: {}", stopwatch.elapsed(TimeUnit.MILLISECONDS), url, body);
return JSON.parseObject(body);
}
public static String numberToString(String string) {
return StringUtils.replace(string, ",", "");
}
public static String find_overview_table_value_with_key(JSONArray overview_table_value, String key) {
for (Object obj : overview_table_value) {
JSONObject item = (JSONObject) obj;
if(StringUtils.equals(item.getString("key"), key)) {
return item.getString("val");
}
}
return null;
}
public JSONObject __page(int pageNum, int pageSize) throws IOException {
String tmpl = "https://api.investing.com/api/financialdata/assets/equitiesByCountry/default?fields-list=id,name,symbol,high,low,last,lastPairDecimal,change,changePercent,volume,time,isOpen,url,flag,countryNameTranslated,exchangeId,performanceDay,performanceWeek,performanceMonth,performanceYtd,performanceYear,performance3Year,technicalHour,technicalDay,technicalWeek,technicalMonth,avgVolume,fundamentalMarketCap,fundamentalRevenue,fundamentalRatio,fundamentalBeta,pairType&country-id=14&page={}&page-size={}&include-major-indices=false&include-additional-indices=false&include-primary-sectors=false&include-other-indices=false&limit=0";
String url = StrFormatter.format(tmpl, pageNum, pageSize);
Stopwatch stopwatch = Stopwatch.createStarted();
log.info("url: {}", url);
Builder builder = builderGet(url);
String body = httpClient().newCall(builder.build()).execute().body().string();
log.info("第{}页码, 耗时: {} 毫秒, 返回原始值: {}, 准备解析中.", pageNum, stopwatch.elapsed(TimeUnit.MILLISECONDS), body);
return JSON.parseObject(body);
}
/**
*
* @param code
* @param string min/day/week/month
* @return
* @throws IOException
*/
public JSONObject __kline(StockCode code, String string) throws IOException {
if(code == null) {
throw new RuntimeException("找不到股票信息");
}
String interval = null;
if("min".equalsIgnoreCase(string)) {
interval = "PT5M";
} else if("day".equalsIgnoreCase(string)) {
interval = "P1D";
} else if("week".equalsIgnoreCase(string)) {
interval = "P1W";
} else if("month".equalsIgnoreCase(string)) {
interval = "P1M";
}
if(StringUtils.isBlank(interval)) {
interval = string;
}
String tmpl = "https://api.investing.com/api/financialdata/{}/historical/chart/?interval={}&pointscount=160";
String url = StrFormatter.format(tmpl, code.getCode(), interval);
Builder builder = builderGet(url);
String body = httpClient().newCall(builder.build()).execute().body().string();
return JSON.parseObject(body);
}
public static InvestingInvokerApis of() {
return new InvestingInvokerApis();
}
public static void main(String[] args) throws IOException {
JSONObject __market = of().__market(StockCode.of("17988"));
System.out.println(__market);
}
}

60
src/main/java/cn/stock/market/infrastructure/api/investing/SSLSocketClientUtil.java Normal file
View File

@@ -0,0 +1,60 @@
package cn.stock.market.infrastructure.api.investing;
import java.security.KeyManagementException;
import java.security.NoSuchAlgorithmException;
import java.security.SecureRandom;
import java.security.cert.CertificateException;
import java.security.cert.X509Certificate;
import javax.net.ssl.HostnameVerifier;
import javax.net.ssl.SSLContext;
import javax.net.ssl.SSLSession;
import javax.net.ssl.SSLSocketFactory;
import javax.net.ssl.TrustManager;
import javax.net.ssl.X509TrustManager;
public class SSLSocketClientUtil {
public static SSLSocketFactory getSocketFactory(TrustManager manager) {
SSLSocketFactory socketFactory = null;
try {
SSLContext sslContext = SSLContext.getInstance("SSL");
sslContext.init(null, new TrustManager[]{manager}, new SecureRandom());
socketFactory = sslContext.getSocketFactory();
} catch (NoSuchAlgorithmException e) {
e.printStackTrace();
} catch (KeyManagementException e) {
e.printStackTrace();
}
return socketFactory;
}
public static X509TrustManager getX509TrustManager() {
return new X509TrustManager() {
@Override
public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException {
}
@Override
public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException {
}
@Override
public X509Certificate[] getAcceptedIssuers() {
return new X509Certificate[0];
}
};
}
public static HostnameVerifier getHostnameVerifier() {
HostnameVerifier hostnameVerifier = new HostnameVerifier() {
@Override
public boolean verify(String s, SSLSession sslSession) {
return true;
}
};
return hostnameVerifier;
}
}

11
src/main/java/cn/stock/market/web/StockApiController.java
View File

@@ -1,5 +1,6 @@
package cn.stock.market.web;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.List;
@@ -119,16 +120,18 @@ public class StockApiController {
@ApiOperation(value = "印度股票个股详情", httpMethod = "GET")
@ResponseBody
public ServerResponse getINDStockInfo(@RequestParam("stockCode") String stockCode) {
log.info("进入印度股票个股详情方法");
return this.stockService.getYCStockInfo(stockCode);
ParamUtils.verify("股票代码", stockCode, ParamUtils.STRING_NOT_EMPTY_VERIFY_AND_CONVERT_VALUE);
IndiaStockVO market = InvestingApis.of().market(StockCode.of(stockCode));
return ServerResponse.createBySuccess(market.toStockVo());
}
//印度股票列表 英情
@RequestMapping({"getINDStockList.do"})
@ApiOperation(value = "印度股票列表", httpMethod = "GET")
@ResponseBody
public ServerResponse getINDStockList(@RequestParam("pageSize") Integer pageSize, @RequestParam("pageNum") Integer pageNum) {
return this.stockService.getINDStockList(pageSize, pageNum);
public ServerResponse getINDStockList(@RequestParam("pageSize") Integer pageSize, @RequestParam("pageNum") Integer pageNum) throws IOException {
return ServerResponse.createBySuccess(InvestingInvokerApis.of().__page(pageNum, pageSize));
}
//印度股票时线-K线

2
src/main/java/cn/stock/market/web/config/ControlSchedulingConfiguration.java
View File

@@ -6,7 +6,7 @@ import org.springframework.scheduling.annotation.EnableScheduling;
@Configuration
@EnableScheduling
@ConditionalOnProperty(prefix = "enable", name = "scheduled", havingValue = "true")
@ConditionalOnProperty(prefix = "enable", name = "scheduled", havingValue = "true", matchIfMissing = true)
public class ControlSchedulingConfiguration {
}