From 3b634a6134f94eb01d9abd0a6c770890abdc4a66 Mon Sep 17 00:00:00 2001
From: dengli <dengli@juyou88.com>
Date: Tue, 19 Dec 2023 14:23:20 +0800
Subject: [PATCH] =?UTF-8?q?=E7=88=AC=E5=8F=96=E6=96=B0=E8=82=A1=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E6=B5=8B=E8=AF=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../domain/basic/service/StockService.java    | 34 +++++++++++++++++++
 .../api/investing/InvestingInvokerApis.java   |  4 +++
 .../stock/market/web/StockApiController.java  |  7 ++++
 3 files changed, 45 insertions(+)

diff --git a/src/main/java/cn/stock/market/domain/basic/service/StockService.java b/src/main/java/cn/stock/market/domain/basic/service/StockService.java
index 4059817..5e5830f 100644
--- a/src/main/java/cn/stock/market/domain/basic/service/StockService.java
+++ b/src/main/java/cn/stock/market/domain/basic/service/StockService.java
@@ -1,7 +1,11 @@
 package cn.stock.market.domain.basic.service;
 
+import java.io.BufferedReader;
 import java.io.IOException;
+import java.io.InputStreamReader;
 import java.math.BigDecimal;
+import java.net.URL;
+import java.net.URLConnection;
 import java.text.SimpleDateFormat;
 import java.util.*;
 import java.util.concurrent.TimeUnit;
@@ -243,6 +247,36 @@ public class StockService {
 		return ServerResponse.createBySuccess(marketVO);
 	}
 
+	public ServerResponse getNews() {
+		String result = "";
+		try {
+			// 创建URL对象
+			URL url = new URL("https://www.business-standard.com/markets/news");
+
+			// 打开URL连接
+			URLConnection connection = url.openConnection();
+
+			// 获取输入流
+			BufferedReader reader = new BufferedReader(new InputStreamReader(connection.getInputStream()));
+
+			// 读取数据
+			StringBuilder data = new StringBuilder();
+			String line;
+			while ((line = reader.readLine()) != null) {
+				data.append(line);
+			}
+
+			// 关闭输入流
+			reader.close();
+
+			// 输出抓取到的数据
+			result = data.toString();
+		} catch (IOException e) {
+			e.printStackTrace();
+		}
+		return ServerResponse.createBySuccessMsg(result);
+	}
+
 	public ServerResponse getStock(int pageNum, int pageSize, String keyWords, String stockPlate, String stockType,
 								   HttpServletRequest request) {
 		Page<Stock> page = repository.findStockListByKeyWords(keyWords, stockPlate, stockType, 0, PageParam.of(pageNum, pageSize));
diff --git a/src/main/java/cn/stock/market/infrastructure/api/investing/InvestingInvokerApis.java b/src/main/java/cn/stock/market/infrastructure/api/investing/InvestingInvokerApis.java
index bb6457a..2417de0 100644
--- a/src/main/java/cn/stock/market/infrastructure/api/investing/InvestingInvokerApis.java
+++ b/src/main/java/cn/stock/market/infrastructure/api/investing/InvestingInvokerApis.java
@@ -1,6 +1,10 @@
 package cn.stock.market.infrastructure.api.investing;
 
+import java.io.BufferedReader;
 import java.io.IOException;
+import java.io.InputStreamReader;
+import java.net.URL;
+import java.net.URLConnection;
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.concurrent.TimeUnit;
diff --git a/src/main/java/cn/stock/market/web/StockApiController.java b/src/main/java/cn/stock/market/web/StockApiController.java
index a0462d7..de438ae 100644
--- a/src/main/java/cn/stock/market/web/StockApiController.java
+++ b/src/main/java/cn/stock/market/web/StockApiController.java
@@ -146,6 +146,13 @@ public class StockApiController {
 		return ServerResponse.createBySuccess(InvestingInvokerApis.of().__page_nifty100(pageNum, pageSize));
 	}
 
+	@RequestMapping({"getINDNews.do"})
+	@ApiOperation(value = "印度热门股票列表", httpMethod = "GET")
+	@ResponseBody
+	public ServerResponse getINDNews() {
+		return ServerResponse.createBySuccess(stockService.getNews());
+	}
+
 	//印度股票时线-K线
 	@RequestMapping({"getINDTimeK.do"})
 	@ApiOperation(value = "印度股票K线", httpMethod = "GET")