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

指定股票更换详情测试代码

Browse Source
This commit is contained in:
gavin
2024-09-10 13:11:01 +08:00
parent 5ae9762d45
commit 94d9aea2c8
1 changed files with 137 additions and 142 deletions
Download Patch File Download Diff File Expand all files Collapse all files

245
src/main/java/cn/stock/market/web/MoneyApiController.java
View File

@@ -60,11 +60,11 @@ public class MoneyApiController {
private static final String EXTERNAL_API_URL = "https://priceapi.moneycontrol.com/techCharts/indianMarket/stock/history"; private static final String EXTERNAL_API_URL = "https://priceapi.moneycontrol.com/techCharts/indianMarket/stock/history";
@ApiOperation(value = "股票详情信息",httpMethod = "GET") @ApiOperation(value = "股票详情信息", httpMethod = "GET")
@ApiImplicitParams({ @ApiImplicitParams({
@ApiImplicitParam(name="stockType",value = "BSE或者NSE"), @ApiImplicitParam(name = "stockType", value = "BSE或者NSE"),
@ApiImplicitParam(name="symbol",value = "scId值"), @ApiImplicitParam(name = "symbol", value = "scId值"),
@ApiImplicitParam(name="id",value = "id值"), @ApiImplicitParam(name = "id", value = "id值"),
}) })
@ApiResponses(value = { @ApiResponses(value = {
@ApiResponse(code = 200, message = "" + @ApiResponse(code = 200, message = "" +
@@ -163,11 +163,11 @@ public class MoneyApiController {
"priceprevclose: 前一交易日的收盘价\n" + "priceprevclose: 前一交易日的收盘价\n" +
"30DayAvg: 过去30天的平均", response = JSONObject.class), "30DayAvg: 过去30天的平均", response = JSONObject.class),
}) })
@GetMapping({"/market/api/market/money/getStockDetail","/api/market/money/getStockDetail"}) @GetMapping({"/market/api/market/money/getStockDetail", "/api/market/money/getStockDetail"})
@ResponseBody @ResponseBody
@EncryptFilter(decryptRequest = false) @EncryptFilter(decryptRequest = false)
public ServerResponse getStockDetail(@RequestParam String stockType, @RequestParam String symbol ) { public ServerResponse getStockDetail(@RequestParam String stockType, @RequestParam String symbol) {
MoneyStock moneyStock = moneyStockRepository.findOne(QMoneyStockPO.moneyStockPO.stockType.eq(stockType) MoneyStock moneyStock = moneyStockRepository.findOne(QMoneyStockPO.moneyStockPO.stockType.eq(stockType)
.and(QMoneyStockPO.moneyStockPO.moneyScId.eq(symbol)) .and(QMoneyStockPO.moneyStockPO.moneyScId.eq(symbol))
.and(QMoneyStockPO.moneyStockPO.isLock.eq(0)) .and(QMoneyStockPO.moneyStockPO.isLock.eq(0))
@@ -177,51 +177,52 @@ public class MoneyApiController {
return ServerResponse.createByErrorMsg("没有找到该股票"); return ServerResponse.createByErrorMsg("没有找到该股票");
}*/ }*/
// 设置重试次数 // 设置重试次数
if("ANI".equals(symbol)){ if ("ANI".equals(symbol)) {
JSONObject json1 = new JSONObject(); JSONObject json1 = new JSONObject();
json1.put("company","Archit Nuwood Industries Ltd"); json1.put("company", "Archit Nuwood Industries Ltd");
json1.put("pricepercentchange","Archit Nuwood Industries Ltd"); json1.put("pricepercentchange", "Archit Nuwood Industries Ltd");
json1.put("stockType",stockType); json1.put("stockType", stockType);
json1.put("pricecurrent","386"); json1.put("pricecurrent", "386");
json1.put("dataSourceType","3"); json1.put("dataSourceType", "3");
json1.put("symbol","ANI"); json1.put("symbol", "ANI");
json1.put("BSEID","ANI"); json1.put("BSEID", "ANI");
json1.put("NSEID","ANI"); json1.put("NSEID", "ANI");
return ServerResponse.createBySuccess(json1); return ServerResponse.createBySuccess(json1);
} }
String url = String.format("https://priceapi.moneycontrol.com/pricefeed/%s/equitycash/%s",stockType,symbol); String url = String.format("https://priceapi.moneycontrol.com/pricefeed/%s/equitycash/%s", stockType, symbol);
int maxRetries = 3; int maxRetries = 3;
for (int retry = 1; retry <= maxRetries; retry++) { for (int retry = 1; retry <= maxRetries; retry++) {
try { try {
ResponseEntity<String> responseEntity = restTemplate.exchange(url, HttpMethod.GET, null, String.class); ResponseEntity<String> responseEntity = restTemplate.exchange(url, HttpMethod.GET, null, String.class);
JSONObject json1 = new JSONObject(); JSONObject json1 = new JSONObject();
if (responseEntity.getStatusCode().value() == 200 && responseEntity.getBody() != null ) { if (responseEntity.getStatusCode().value() == 200 && responseEntity.getBody() != null) {
JSONObject data = JSONObject.parseObject(responseEntity.getBody()).getJSONObject("data"); JSONObject data = JSONObject.parseObject(responseEntity.getBody()).getJSONObject("data");
if(data!=null){ if (data != null) {
json1.put("company",data.getString("SC_FULLNM")); json1.put("company", data.getString("SC_FULLNM"));
json1.put("pricepercentchange",data.getString("pricepercentchange")); json1.put("pricepercentchange", data.getString("pricepercentchange"));
json1.put("stockType",stockType); json1.put("stockType", stockType);
json1.put("pricechange",data.getString("pricechange")); json1.put("pricechange", data.getString("pricechange"));
json1.put("pricecurrent",data.getString("pricecurrent")); json1.put("pricecurrent", data.getString("pricecurrent"));
json1.put("priceprevclose",data.getString("priceprevclose")); json1.put("priceprevclose", data.getString("priceprevclose"));
json1.put("PREVDATE",data.getString("PREVDATE")); json1.put("PREVDATE", data.getString("PREVDATE"));
json1.put("VOL",data.getString("VOL")); json1.put("VOL", data.getString("VOL"));
json1.put("dataSourceType","3"); json1.put("dataSourceType", "3");
json1.put("symbol",data.getString("symbol")); json1.put("symbol", data.getString("symbol"));
json1.put("BSEID",data.getString("BSEID")); json1.put("BSEID", data.getString("BSEID"));
json1.put("NSEID",data.getString("NSEID")); json1.put("NSEID", data.getString("NSEID"));
json1.put("LTH",data.getString("HP")); json1.put("LTH", data.getString("HP"));
json1.put("LTL",data.getString("LP")); json1.put("LTL", data.getString("LP"));
json1.put("OPN",data.getString("OPN")); json1.put("OPN", data.getString("OPN"));
if(null!=moneyStock){ if (null != moneyStock) {
json1.put("id",moneyStock.getId()); json1.put("id", moneyStock.getId());
} }
if(StringUtils.equals(data.getString("pricecurrent"),"0.00") if (StringUtils.equals(data.getString("pricecurrent"), "0.00")
&& (!StringUtils.equals(data.getString("priceprevclose"),"0.00"))){ && (!StringUtils.equals(data.getString("priceprevclose"), "0.00"))) {
json1.put("pricecurrent",data.getString("priceprevclose")); json1.put("pricecurrent", data.getString("priceprevclose"));
} }
} }
if (json1.size() > 0)
return ServerResponse.createBySuccess(json1); return ServerResponse.createBySuccess(json1);
} }
} catch (Exception e) { } catch (Exception e) {
@@ -240,7 +241,7 @@ public class MoneyApiController {
try { try {
// Get data from nseindia // Get data from nseindia
JSONObject json = NseIndiaRequest.stockByJYSFromHttp(stockType, symbol, moneyStock.getNseIndiaId()); JSONObject json = NseIndiaRequest.stockByJYSFromHttp(stockType, symbol, moneyStock.getNseIndiaId());
json.put("id",moneyStock.getId()); json.put("id", moneyStock.getId());
return ServerResponse.createBySuccess(json); return ServerResponse.createBySuccess(json);
@@ -252,16 +253,15 @@ public class MoneyApiController {
} }
private static List<MoneyStockSuggestDTO> nseActives() { private static List<MoneyStockSuggestDTO> nseActives() {
List<MoneyStockSuggestDTO> list = new ArrayList<>(); List<MoneyStockSuggestDTO> list = new ArrayList<>();
String url = "https://www.moneycontrol.com/stocks/marketstats/nse-mostactive-stocks/nifty-50-9/"; String url = "https://www.moneycontrol.com/stocks/marketstats/nse-mostactive-stocks/nifty-50-9/";
try { try {
Document doc = Jsoup.connect(url).get(); Document doc = Jsoup.connect(url).get();
int size = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div.bsr_table.hist_tbl_hm > table > tbody > tr").size(); int size = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div.bsr_table.hist_tbl_hm > table > tbody > tr").size();
for (int i =1;i<=size;i++){ for (int i = 1; i <= size; i++) {
MoneyStockSuggestDTO dto = new MoneyStockSuggestDTO(); MoneyStockSuggestDTO dto = new MoneyStockSuggestDTO();
Element company_a = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div.bsr_table.hist_tbl_hm > table > tbody > tr:nth-child("+i+") > td.PR > span > a").first(); Element company_a = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div.bsr_table.hist_tbl_hm > table > tbody > tr:nth-child(" + i + ") > td.PR > span > a").first();
if (company_a != null) { if (company_a != null) {
String stockUrl = company_a.attr("href"); String stockUrl = company_a.attr("href");
String stockName = company_a.text(); String stockName = company_a.text();
@@ -269,7 +269,7 @@ public class MoneyApiController {
dto.setStockUrl(stockUrl); dto.setStockUrl(stockUrl);
} }
String highPrice = getTextOrEmpty(doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div.bsr_table.hist_tbl_hm > table > tbody > tr:nth-child("+i+") > td:nth-child(2)").first()); String highPrice = getTextOrEmpty(doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div.bsr_table.hist_tbl_hm > table > tbody > tr:nth-child(" + i + ") > td:nth-child(2)").first());
dto.setHighPrice(highPrice); dto.setHighPrice(highPrice);
String lowPrice = getTextOrEmpty(doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div.bsr_table.hist_tbl_hm > table > tbody > tr:nth-child(" + i + ") > td:nth-child(3)").first()); String lowPrice = getTextOrEmpty(doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div.bsr_table.hist_tbl_hm > table > tbody > tr:nth-child(" + i + ") > td:nth-child(3)").first());
@@ -302,9 +302,9 @@ public class MoneyApiController {
Document doc = Jsoup.connect(url).get(); Document doc = Jsoup.connect(url).get();
int size = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div > div.bsr_table.hist_tbl_hm > table > tbody > tr").size(); int size = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div > div.bsr_table.hist_tbl_hm > table > tbody > tr").size();
System.err.println(size); System.err.println(size);
for (int i =1;i<=size;i++){ for (int i = 1; i <= size; i++) {
MoneyStockSuggestDTO dto = new MoneyStockSuggestDTO(); MoneyStockSuggestDTO dto = new MoneyStockSuggestDTO();
Element company_a = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div > div.bsr_table.hist_tbl_hm > table > tbody > tr:nth-child("+i+") > td.PR > span > a").first(); Element company_a = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div > div.bsr_table.hist_tbl_hm > table > tbody > tr:nth-child(" + i + ") > td.PR > span > a").first();
if (company_a != null) { if (company_a != null) {
String stockUrl = company_a.attr("href"); String stockUrl = company_a.attr("href");
String stockName = company_a.text(); String stockName = company_a.text();
@@ -333,7 +333,7 @@ public class MoneyApiController {
} }
} catch (IOException e) { } catch (IOException e) {
log.error("occur Exception",e); log.error("occur Exception", e);
} }
return list; return list;
} }
@@ -344,8 +344,8 @@ public class MoneyApiController {
try { try {
Document doc = Jsoup.connect(url).get(); Document doc = Jsoup.connect(url).get();
int size = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div > div.bsr_table.hist_tbl_hm > table > tbody > tr").size(); int size = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div > div.bsr_table.hist_tbl_hm > table > tbody > tr").size();
for (int i =1;i<=size;i++){ for (int i = 1; i <= size; i++) {
Element company_a = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div > div.bsr_table.hist_tbl_hm > table > tbody > tr:nth-child("+i+") > td.PR > span > a").first(); Element company_a = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div > div.bsr_table.hist_tbl_hm > table > tbody > tr:nth-child(" + i + ") > td.PR > span > a").first();
MoneyStockSuggestDTO dto = new MoneyStockSuggestDTO(); MoneyStockSuggestDTO dto = new MoneyStockSuggestDTO();
if (company_a != null) { if (company_a != null) {
String stockUrl = company_a.attr("href"); String stockUrl = company_a.attr("href");
@@ -389,9 +389,9 @@ public class MoneyApiController {
try { try {
Document doc = Jsoup.connect(url).get(); Document doc = Jsoup.connect(url).get();
int size = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div > div.bsr_table.hist_tbl_hm > table > tbody > tr").size(); int size = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div > div.bsr_table.hist_tbl_hm > table > tbody > tr").size();
for (int i =1;i<=size;i++){ for (int i = 1; i <= size; i++) {
MoneyStockSuggestDTO dto = new MoneyStockSuggestDTO(); MoneyStockSuggestDTO dto = new MoneyStockSuggestDTO();
Element company_a = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div > div.bsr_table.hist_tbl_hm > table > tbody > tr:nth-child("+i+") > td.PR > span > h3 > a").first(); Element company_a = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div > div.bsr_table.hist_tbl_hm > table > tbody > tr:nth-child(" + i + ") > td.PR > span > h3 > a").first();
if (company_a != null) { if (company_a != null) {
String stockUrl = company_a.attr("href"); String stockUrl = company_a.attr("href");
String stockName = company_a.text(); String stockName = company_a.text();
@@ -433,9 +433,9 @@ public class MoneyApiController {
try { try {
Document doc = Jsoup.connect(url).get(); Document doc = Jsoup.connect(url).get();
int size = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div > div.bsr_table.hist_tbl_hm > table > tbody > tr").size(); int size = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div > div.bsr_table.hist_tbl_hm > table > tbody > tr").size();
for (int i =1;i<=size;i++){ for (int i = 1; i <= size; i++) {
MoneyStockSuggestDTO dto = new MoneyStockSuggestDTO(); MoneyStockSuggestDTO dto = new MoneyStockSuggestDTO();
Element company_a = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div > div.bsr_table.hist_tbl_hm > table > tbody > tr:nth-child("+i+") > td.PR > span > h3 > a").first(); Element company_a = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div > div.bsr_table.hist_tbl_hm > table > tbody > tr:nth-child(" + i + ") > td.PR > span > h3 > a").first();
if (company_a != null) { if (company_a != null) {
String stockUrl = company_a.attr("href"); String stockUrl = company_a.attr("href");
String stockName = company_a.text(); String stockName = company_a.text();
@@ -476,7 +476,7 @@ public class MoneyApiController {
try { try {
Document doc = Jsoup.connect(url).get(); Document doc = Jsoup.connect(url).get();
int size = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div > div.bsr_table.hist_tbl_hm > table > tbody > tr").size(); int size = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div > div.bsr_table.hist_tbl_hm > table > tbody > tr").size();
for (int i =1;i<=size;i++){ for (int i = 1; i <= size; i++) {
Element company_a = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div > div.bsr_table.hist_tbl_hm > table > tbody > tr:nth-child(" + i + ") > td.PR > span > a").first(); Element company_a = doc.select("#mc_content > section > section > div.clearfix.stat_container > div.columnst.FR.wbg.brdwht > div > div > div.bsr_table.hist_tbl_hm > table > tbody > tr:nth-child(" + i + ") > td.PR > span > a").first();
MoneyStockSuggestDTO dto = new MoneyStockSuggestDTO(); MoneyStockSuggestDTO dto = new MoneyStockSuggestDTO();
if (company_a != null) { if (company_a != null) {
@@ -521,17 +521,15 @@ public class MoneyApiController {
} }
@ApiOperation(value = "股票推荐TopGainer", httpMethod = "GET")
@ApiOperation(value = "股票推荐TopGainer",httpMethod = "GET")
@ApiImplicitParams({ @ApiImplicitParams({
@ApiImplicitParam(name="stockType",value = "BSE或者NSE"), @ApiImplicitParam(name = "stockType", value = "BSE或者NSE"),
}) })
@ApiResponses(value = { @ApiResponses(value = {
@ApiResponse(code = 200, message = "" + @ApiResponse(code = 200, message = "" +
"股票推荐相关: top gainer", response = JSONObject.class), "股票推荐相关: top gainer", response = JSONObject.class),
}) })
@GetMapping({"/market/api/market/money/getTopGainer","/api/market/money/getTopGainer"}) @GetMapping({"/market/api/market/money/getTopGainer", "/api/market/money/getTopGainer"})
@ResponseBody @ResponseBody
@EncryptFilter(decryptRequest = false) @EncryptFilter(decryptRequest = false)
@@ -549,15 +547,15 @@ public class MoneyApiController {
} }
Map<Object, Boolean> map = new HashMap<>(); Map<Object, Boolean> map = new HashMap<>();
moneyStockSuggestDTOS = moneyStockSuggestDTOS.stream() moneyStockSuggestDTOS = moneyStockSuggestDTOS.stream()
.filter(f->StringUtils.isNotBlank(f.getStockName())) .filter(f -> StringUtils.isNotBlank(f.getStockName()))
.filter(i -> map.putIfAbsent(i.getStockName(), Boolean.TRUE) == null).collect(Collectors.toList()); .filter(i -> map.putIfAbsent(i.getStockName(), Boolean.TRUE) == null).collect(Collectors.toList());
if(CollectionUtils.isNotEmpty(moneyStockSuggestDTOS)){ if (CollectionUtils.isNotEmpty(moneyStockSuggestDTOS)) {
List<String> selfUlrList = moneyStockSuggestDTOS.stream().map(MoneyStockSuggestDTO::getStockName).collect(Collectors.toList()); List<String> selfUlrList = moneyStockSuggestDTOS.stream().map(MoneyStockSuggestDTO::getStockName).collect(Collectors.toList());
if(CollectionUtils.isNotEmpty(selfUlrList)){ if (CollectionUtils.isNotEmpty(selfUlrList)) {
List<MoneyStock> all = moneyStockRepository.findAll(QMoneyStockPO.moneyStockPO.stockName.in(selfUlrList)); List<MoneyStock> all = moneyStockRepository.findAll(QMoneyStockPO.moneyStockPO.stockName.in(selfUlrList));
if(CollectionUtils.isNotEmpty(all)){ if (CollectionUtils.isNotEmpty(all)) {
moneyStockSuggestDTOS.stream().filter(f->all.stream().anyMatch(s->s.getStockName().equals(f.getStockName()))) moneyStockSuggestDTOS.stream().filter(f -> all.stream().anyMatch(s -> s.getStockName().equals(f.getStockName())))
.forEach(f->f.setScId(all.stream().filter(s->s.getStockName().equals(f.getStockName())).findFirst().orElse(null).getMoneyScId())); .forEach(f -> f.setScId(all.stream().filter(s -> s.getStockName().equals(f.getStockName())).findFirst().orElse(null).getMoneyScId()));
} }
} }
gainerStockSuggestCache.put(stockType, moneyStockSuggestDTOS); gainerStockSuggestCache.put(stockType, moneyStockSuggestDTOS);
@@ -568,47 +566,47 @@ public class MoneyApiController {
} }
@ApiOperation(value = "股票推荐TopLoser",httpMethod = "GET") @ApiOperation(value = "股票推荐TopLoser", httpMethod = "GET")
@ApiImplicitParams({ @ApiImplicitParams({
@ApiImplicitParam(name="stockType",value = "BSE或者NSE"), @ApiImplicitParam(name = "stockType", value = "BSE或者NSE"),
}) })
@ApiResponses(value = { @ApiResponses(value = {
@ApiResponse(code = 200, message = "" + @ApiResponse(code = 200, message = "" +
"股票推荐相关: TopLoser", response = JSONObject.class), "股票推荐相关: TopLoser", response = JSONObject.class),
}) })
@GetMapping({"/market/api/market/money/getTopLoser","/api/market/money/getTopLoser"}) @GetMapping({"/market/api/market/money/getTopLoser", "/api/market/money/getTopLoser"})
@ResponseBody @ResponseBody
@EncryptFilter(decryptRequest = false) @EncryptFilter(decryptRequest = false)
public List<MoneyStockSuggestDTO> getTopLoser(@RequestParam String stockType) { public List<MoneyStockSuggestDTO> getTopLoser(@RequestParam String stockType) {
List<MoneyStockSuggestDTO> moneyStockSuggestDTOS = null; List<MoneyStockSuggestDTO> moneyStockSuggestDTOS = null;
moneyStockSuggestDTOS = loserStockSuggestCache.getIfPresent(stockType); moneyStockSuggestDTOS = loserStockSuggestCache.getIfPresent(stockType);
if(null==moneyStockSuggestDTOS){ if (null == moneyStockSuggestDTOS) {
if(StringUtils.equals(stockType,"nse")){ if (StringUtils.equals(stockType, "nse")) {
moneyStockSuggestDTOS = nseTopLoser(); moneyStockSuggestDTOS = nseTopLoser();
}else if(StringUtils.equals(stockType,"bse")){ } else if (StringUtils.equals(stockType, "bse")) {
moneyStockSuggestDTOS = bseTopLoser(); moneyStockSuggestDTOS = bseTopLoser();
} }
Map<Object, Boolean> map = new HashMap<>(); Map<Object, Boolean> map = new HashMap<>();
moneyStockSuggestDTOS = moneyStockSuggestDTOS.stream() moneyStockSuggestDTOS = moneyStockSuggestDTOS.stream()
.filter(f->StringUtils.isNotBlank(f.getStockName())) .filter(f -> StringUtils.isNotBlank(f.getStockName()))
.filter(i -> map.putIfAbsent(i.getStockName(), Boolean.TRUE) == null).collect(Collectors.toList()); .filter(i -> map.putIfAbsent(i.getStockName(), Boolean.TRUE) == null).collect(Collectors.toList());
if(CollectionUtils.isNotEmpty(moneyStockSuggestDTOS)){ if (CollectionUtils.isNotEmpty(moneyStockSuggestDTOS)) {
moneyStockSuggestDTOS.stream().forEach(f->f.setDispId(extractLastSegment(f.getStockUrl()))); moneyStockSuggestDTOS.stream().forEach(f -> f.setDispId(extractLastSegment(f.getStockUrl())));
List<String> selfUlrList = moneyStockSuggestDTOS.stream().map(MoneyStockSuggestDTO::getStockName).collect(Collectors.toList()); List<String> selfUlrList = moneyStockSuggestDTOS.stream().map(MoneyStockSuggestDTO::getStockName).collect(Collectors.toList());
if(CollectionUtils.isNotEmpty(selfUlrList)){ if (CollectionUtils.isNotEmpty(selfUlrList)) {
List<MoneyStock> all = moneyStockRepository.findAll(QMoneyStockPO.moneyStockPO.stockName.in(selfUlrList)); List<MoneyStock> all = moneyStockRepository.findAll(QMoneyStockPO.moneyStockPO.stockName.in(selfUlrList));
if(CollectionUtils.isNotEmpty(all)){ if (CollectionUtils.isNotEmpty(all)) {
moneyStockSuggestDTOS.stream().filter(f->all.stream().anyMatch(s->s.getStockName().equals(f.getStockName()))) moneyStockSuggestDTOS.stream().filter(f -> all.stream().anyMatch(s -> s.getStockName().equals(f.getStockName())))
.forEach(f->f.setScId(all.stream().filter(s->s.getStockName().equals(f.getStockName())).findFirst().orElse(null).getMoneyScId())); .forEach(f -> f.setScId(all.stream().filter(s -> s.getStockName().equals(f.getStockName())).findFirst().orElse(null).getMoneyScId()));
} }
List<MoneyStockSuggestDTO> noScIdList = moneyStockSuggestDTOS.stream().filter(f->StringUtils.isBlank(f.getScId())).collect(Collectors.toList()); List<MoneyStockSuggestDTO> noScIdList = moneyStockSuggestDTOS.stream().filter(f -> StringUtils.isBlank(f.getScId())).collect(Collectors.toList());
if(CollectionUtils.isNotEmpty(noScIdList)){ if (CollectionUtils.isNotEmpty(noScIdList)) {
List<String> dispIdList = noScIdList.stream().map(MoneyStockSuggestDTO::getDispId).collect(Collectors.toList()); List<String> dispIdList = noScIdList.stream().map(MoneyStockSuggestDTO::getDispId).collect(Collectors.toList());
List<MoneyStock> all1 = moneyStockRepository.findAll(QMoneyStockPO.moneyStockPO.selfDispId.in(dispIdList)); List<MoneyStock> all1 = moneyStockRepository.findAll(QMoneyStockPO.moneyStockPO.selfDispId.in(dispIdList));
if(CollectionUtils.isNotEmpty(all1)){ if (CollectionUtils.isNotEmpty(all1)) {
moneyStockSuggestDTOS.stream().filter(f->all1.stream().anyMatch(s->s.getSelfDispId().equals(f.getDispId()))) moneyStockSuggestDTOS.stream().filter(f -> all1.stream().anyMatch(s -> s.getSelfDispId().equals(f.getDispId())))
.forEach(f->f.setScId(all.stream().filter(s->s.getSelfDispId().equals(f.getDispId())).findFirst().orElse(null).getMoneyScId())); .forEach(f -> f.setScId(all.stream().filter(s -> s.getSelfDispId().equals(f.getDispId())).findFirst().orElse(null).getMoneyScId()));
} }
} }
} }
@@ -619,49 +617,47 @@ public class MoneyApiController {
} }
@ApiOperation(value = "股票推荐TopActive", httpMethod = "GET")
@ApiOperation(value = "股票推荐TopActive",httpMethod = "GET")
@ApiImplicitParams({ @ApiImplicitParams({
@ApiImplicitParam(name="stockType",value = "BSE或者NSE"), @ApiImplicitParam(name = "stockType", value = "BSE或者NSE"),
}) })
@ApiResponses(value = { @ApiResponses(value = {
@ApiResponse(code = 200, message = "" + @ApiResponse(code = 200, message = "" +
"股票推荐相关: top active", response = JSONObject.class), "股票推荐相关: top active", response = JSONObject.class),
}) })
@GetMapping({"/market/api/market/money/getTopActives","/api/market/money/getTopActives"}) @GetMapping({"/market/api/market/money/getTopActives", "/api/market/money/getTopActives"})
@ResponseBody @ResponseBody
@EncryptFilter(decryptRequest = false) @EncryptFilter(decryptRequest = false)
public List<MoneyStockSuggestDTO> getTopActive(@RequestParam String stockType) { public List<MoneyStockSuggestDTO> getTopActive(@RequestParam String stockType) {
List<MoneyStockSuggestDTO> moneyStockSuggestDTOS = null; List<MoneyStockSuggestDTO> moneyStockSuggestDTOS = null;
moneyStockSuggestDTOS = activesStockSuggestCache.getIfPresent(stockType); moneyStockSuggestDTOS = activesStockSuggestCache.getIfPresent(stockType);
if(moneyStockSuggestDTOS ==null){ if (moneyStockSuggestDTOS == null) {
if(StringUtils.equals(stockType,"nse")){ if (StringUtils.equals(stockType, "nse")) {
moneyStockSuggestDTOS = nseActives(); moneyStockSuggestDTOS = nseActives();
}else if(StringUtils.equals(stockType,"bse")){ } else if (StringUtils.equals(stockType, "bse")) {
moneyStockSuggestDTOS = bseActives(); moneyStockSuggestDTOS = bseActives();
} }
Map<Object, Boolean> map = new HashMap<>(); Map<Object, Boolean> map = new HashMap<>();
moneyStockSuggestDTOS = moneyStockSuggestDTOS.stream() moneyStockSuggestDTOS = moneyStockSuggestDTOS.stream()
.filter(f->StringUtils.isNotBlank(f.getStockName())) .filter(f -> StringUtils.isNotBlank(f.getStockName()))
.filter(i -> map.putIfAbsent(i.getStockName(), Boolean.TRUE) == null).collect(Collectors.toList()); .filter(i -> map.putIfAbsent(i.getStockName(), Boolean.TRUE) == null).collect(Collectors.toList());
if(CollectionUtils.isNotEmpty(moneyStockSuggestDTOS)){ if (CollectionUtils.isNotEmpty(moneyStockSuggestDTOS)) {
moneyStockSuggestDTOS.stream().forEach(f->f.setDispId(extractLastSegment(f.getStockUrl()))); moneyStockSuggestDTOS.stream().forEach(f -> f.setDispId(extractLastSegment(f.getStockUrl())));
List<String> selfUlrList = moneyStockSuggestDTOS.stream().map(MoneyStockSuggestDTO::getStockName).collect(Collectors.toList()); List<String> selfUlrList = moneyStockSuggestDTOS.stream().map(MoneyStockSuggestDTO::getStockName).collect(Collectors.toList());
if(CollectionUtils.isNotEmpty(selfUlrList)){ if (CollectionUtils.isNotEmpty(selfUlrList)) {
List<MoneyStock> all = moneyStockRepository.findAll(QMoneyStockPO.moneyStockPO.stockName.in(selfUlrList)); List<MoneyStock> all = moneyStockRepository.findAll(QMoneyStockPO.moneyStockPO.stockName.in(selfUlrList));
if(CollectionUtils.isNotEmpty(all)){ if (CollectionUtils.isNotEmpty(all)) {
moneyStockSuggestDTOS.stream().filter(f->all.stream().anyMatch(s->s.getStockName().equals(f.getStockName()))) moneyStockSuggestDTOS.stream().filter(f -> all.stream().anyMatch(s -> s.getStockName().equals(f.getStockName())))
.forEach(f->f.setScId(all.stream().filter(s->s.getStockName().equals(f.getStockName())).findFirst().orElse(null).getMoneyScId())); .forEach(f -> f.setScId(all.stream().filter(s -> s.getStockName().equals(f.getStockName())).findFirst().orElse(null).getMoneyScId()));
} }
List<MoneyStockSuggestDTO> noScIdList = moneyStockSuggestDTOS.stream().filter(f->StringUtils.isBlank(f.getScId())).collect(Collectors.toList()); List<MoneyStockSuggestDTO> noScIdList = moneyStockSuggestDTOS.stream().filter(f -> StringUtils.isBlank(f.getScId())).collect(Collectors.toList());
if(CollectionUtils.isNotEmpty(noScIdList)){ if (CollectionUtils.isNotEmpty(noScIdList)) {
List<String> dispIdList = noScIdList.stream().map(MoneyStockSuggestDTO::getDispId).collect(Collectors.toList()); List<String> dispIdList = noScIdList.stream().map(MoneyStockSuggestDTO::getDispId).collect(Collectors.toList());
List<MoneyStock> all1 = moneyStockRepository.findAll(QMoneyStockPO.moneyStockPO.selfDispId.in(dispIdList)); List<MoneyStock> all1 = moneyStockRepository.findAll(QMoneyStockPO.moneyStockPO.selfDispId.in(dispIdList));
if(CollectionUtils.isNotEmpty(all1)){ if (CollectionUtils.isNotEmpty(all1)) {
moneyStockSuggestDTOS.stream().filter(f->all1.stream().anyMatch(s->s.getSelfDispId().equals(f.getDispId()))) moneyStockSuggestDTOS.stream().filter(f -> all1.stream().anyMatch(s -> s.getSelfDispId().equals(f.getDispId())))
.forEach(f->f.setScId(all.stream().filter(s->s.getSelfDispId().equals(f.getDispId())).findFirst().orElse(null).getMoneyScId())); .forEach(f -> f.setScId(all.stream().filter(s -> s.getSelfDispId().equals(f.getDispId())).findFirst().orElse(null).getMoneyScId()));
} }
} }
} }
@@ -673,9 +669,8 @@ public class MoneyApiController {
} }
@GetMapping({"/market/api/market/money/history/kLine", "/api/market/money/history/kLine"})
@GetMapping({"/market/api/market/money/history/kLine","/api/market/money/history/kLine"}) @ApiOperation(value = "获取kline的money数据源", notes = "获取kline的money数据源", response = StockHistoryResponse.class)
@ApiOperation(value = "获取kline的money数据源", notes = "获取kline的money数据源",response = StockHistoryResponse.class)
@ApiImplicitParams({ @ApiImplicitParams({
@ApiImplicitParam(name = "symbol", value = "Stock symbol 对应的是NSEID 或者是BSEID", required = true, dataType = "String", paramType = "query"), @ApiImplicitParam(name = "symbol", value = "Stock symbol 对应的是NSEID 或者是BSEID", required = true, dataType = "String", paramType = "query"),
@ApiImplicitParam(name = "resolution", value = "单位:60 1D 1W 1D 对应H,D,W,Y", required = true, dataType = "String", paramType = "query"), @ApiImplicitParam(name = "resolution", value = "单位:60 1D 1W 1D 对应H,D,W,Y", required = true, dataType = "String", paramType = "query"),
@@ -686,7 +681,7 @@ public class MoneyApiController {
}) })
@ResponseBody @ResponseBody
@EncryptFilter(decryptRequest = false) @EncryptFilter(decryptRequest = false)
public ResponseEntity<StockHistoryResponse> getStockHistory( @RequestParam String symbol, public ResponseEntity<StockHistoryResponse> getStockHistory(@RequestParam String symbol,
@RequestParam String resolution @RequestParam String resolution
) { ) {
// 向外部API发起请求，并获取响应 // 向外部API发起请求，并获取响应
@@ -695,24 +690,24 @@ public class MoneyApiController {
Long to = null; Long to = null;
Long from = null; Long from = null;
int countback = 5; int countback = 5;
if(StringUtils.equals("H",resolution)){ if (StringUtils.equals("H", resolution)) {
to = (long) (System.currentTimeMillis() / 1000); to = (long) (System.currentTimeMillis() / 1000);
from = to - ( 60 * 60 ); from = to - (60 * 60);
countback = 60; countback = 60;
request.setResolution("1"); request.setResolution("1");
}else if(StringUtils.equals("D",resolution)){ } else if (StringUtils.equals("D", resolution)) {
to = (long) (System.currentTimeMillis() / 1000); to = (long) (System.currentTimeMillis() / 1000);
from = to - (24 * 60 * 60 ); from = to - (24 * 60 * 60);
countback = 390; countback = 390;
request.setResolution("1"); request.setResolution("1");
}else if(StringUtils.equals("W",resolution)){ } else if (StringUtils.equals("W", resolution)) {
to = (long) (System.currentTimeMillis() / 1000); to = (long) (System.currentTimeMillis() / 1000);
from = to - (7 * 24 * 60 * 60 ); from = to - (7 * 24 * 60 * 60);
countback = 471; countback = 471;
request.setResolution("5"); request.setResolution("5");
}else if(StringUtils.equals("M",resolution)){ } else if (StringUtils.equals("M", resolution)) {
to = (long) (System.currentTimeMillis() / 1000); to = (long) (System.currentTimeMillis() / 1000);
from = to - (35 * 24 * 60 * 60 ); from = to - (35 * 24 * 60 * 60);
countback = 328; countback = 328;
request.setResolution("30"); request.setResolution("30");
} }
@@ -722,7 +717,7 @@ public class MoneyApiController {
request.setCountback(countback); request.setCountback(countback);
request.setCurrencyCode("INR"); request.setCurrencyCode("INR");
String apiUrl = buildApiUrl(request); String apiUrl = buildApiUrl(request);
log.info("request url:"+apiUrl); log.info("request url:" + apiUrl);
StockHistoryResponse response = null; StockHistoryResponse response = null;
int maxRetries = 3; int maxRetries = 3;
int retryCount = 0; int retryCount = 0;
@@ -746,7 +741,7 @@ public class MoneyApiController {
} }
if (response != null) { if (response != null) {
setResponse(response,resolution); setResponse(response, resolution);
// API request successful, return the response // API request successful, return the response
return ResponseEntity.ok(response); return ResponseEntity.ok(response);
} else { } else {
@@ -757,14 +752,14 @@ public class MoneyApiController {
// 返回响应 // 返回响应
} }
private void setResponse(StockHistoryResponse response,String resolution){ private void setResponse(StockHistoryResponse response, String resolution) {
if(!"ok".equals(response.getS())){ if (!"ok".equals(response.getS())) {
return; return;
} }
if(Objects.isNull(response.getT())){ if (Objects.isNull(response.getT())) {
return; return;
} }
if(StringUtils.equals("H",resolution) || StringUtils.equals("D",resolution)) { if (StringUtils.equals("H", resolution) || StringUtils.equals("D", resolution)) {
List<Long> t = new ArrayList<>(); List<Long> t = new ArrayList<>();
List<Double> o = new ArrayList<>(); List<Double> o = new ArrayList<>();
List<Double> h = new ArrayList<>(); List<Double> h = new ArrayList<>();
@@ -776,7 +771,7 @@ public class MoneyApiController {
Date currentTime = new Date(); Date currentTime = new Date();
//判断最后一条是不是当天的数据，如果不是，把最后一条的时间作为当天的时间 //判断最后一条是不是当天的数据，如果不是，把最后一条的时间作为当天的时间
long getTime = response.getT().get(response.getT().size() - 1) * 1000L; long getTime = response.getT().get(response.getT().size() - 1) * 1000L;
if(!DateUtil.isSameDay(currentTime, new Date(getTime))){ if (!DateUtil.isSameDay(currentTime, new Date(getTime))) {
currentTime = new Date(getTime); currentTime = new Date(getTime);
} }
int i = 0; int i = 0;
@@ -802,14 +797,14 @@ public class MoneyApiController {
} }
private String buildApiUrl(StockHistoryRequest request) { private String buildApiUrl(StockHistoryRequest request) {
// 构建外部API的URL // 构建外部API的URL
return String.format("%s?symbol=%s&resolution=%s&from=%d&to=%d&countback=%d&currencyCode=%s", return String.format("%s?symbol=%s&resolution=%s&from=%d&to=%d&countback=%d&currencyCode=%s",
EXTERNAL_API_URL, request.getSymbol(), request.getResolution(), request.getFrom(), EXTERNAL_API_URL, request.getSymbol(), request.getResolution(), request.getFrom(),
request.getTo(), request.getCountback(), request.getCurrencyCode()); request.getTo(), request.getCountback(), request.getCurrencyCode());
}; }
;
private static String extractLastSegment(String url) { private static String extractLastSegment(String url) {
@@ -834,7 +829,7 @@ public class MoneyApiController {
//// bseTopLoser(); //// bseTopLoser();
System.out.println(new Date()); System.out.println(new Date());
System.out.println(new Date(1713949200000L)); System.out.println(new Date(1713949200000L));
System.out.println(DateUtil.isSameDay(new Date(),new Date(1713949200000L))); System.out.println(DateUtil.isSameDay(new Date(), new Date(1713949200000L)));
} }
private Cache<String, List<MoneyStockSuggestDTO>> gainerStockSuggestCache = CacheBuilder.newBuilder() private Cache<String, List<MoneyStockSuggestDTO>> gainerStockSuggestCache = CacheBuilder.newBuilder()