zyy
2025-08-07 ea4dda9def8d75d5ca8796771cf22b37fcd251d1
bug修改
6 files modified
20 ■■■■ changed files
src/main/java/com/nq/controller/StockInkApiController.java 2 ●●● patch | view | raw | blame | history
src/main/java/com/nq/utils/task/stock/StockTask.java 2 ●●● patch | view | raw | blame | history
src/main/java/com/nq/ws/TWWebsocketRunClient.java 2 ●●● patch | view | raw | blame | history
src/main/java/com/nq/ws/WebsocketRunClient.java 2 ●●● patch | view | raw | blame | history
src/main/resources/application.properties 4 ●●●● patch | view | raw | blame | history
src/main/resources/application.yml 8 ●●●● patch | view | raw | blame | history
src/main/java/com/nq/controller/StockInkApiController.java
@@ -34,7 +34,7 @@
    @ResponseBody
    public ServerResponse getStockAiList(@RequestParam(value = "pageNum", defaultValue = "1") int pageNum,
                                         @RequestParam(value = "pageSize", defaultValue = "5") int pageSize,
                                         @RequestParam(value = "stockName") String stockName)   {
                                         @RequestParam(value = "stockName", required = false) String stockName)   {
        return stockAiService.getStockAiList(pageNum, pageSize, stockName);
    }
src/main/java/com/nq/utils/task/stock/StockTask.java
@@ -85,7 +85,7 @@
    /**
     * 同步系统所需要的股票
     */
    @Scheduled(cron = "0 0/1 * * * ?")
    @Scheduled(cron = "0 0/3 * * * ?")
    public void syncINStockData() {
        if (syncINStockData.get()) { // 判断任务是否在处理中
src/main/java/com/nq/ws/TWWebsocketRunClient.java
@@ -65,7 +65,7 @@
            System.out.println("tw" + message);
            return;
        }
        System.out.println("tw2" + message);
        //System.out.println("tw2" + message);
        Map<String, String> stringObjectMap = jsonToMap(message);
        StockRealTimeBean stockRealTimeBean = new StockRealTimeBean();
        stockRealTimeBean.setPid(stringObjectMap.get("Id").toString());
src/main/java/com/nq/ws/WebsocketRunClient.java
@@ -67,7 +67,7 @@
            System.out.println("hk" + message);
            return;
        }
        System.out.println("hk2" + message);
        //System.out.println("hk2" + message);
        Map<String, String> stringObjectMap = jsonToMap(message);
        StockRealTimeBean stockRealTimeBean = new StockRealTimeBean();
        stockRealTimeBean.setPid(stringObjectMap.get("Id").toString());
src/main/resources/application.properties
@@ -17,10 +17,10 @@
ftp.user=ftp_stock
ftp.pass=123456
ftp.address =/www/wwwroot/ftp_stock/
ftp.server.http.prefix=https://img.kuspitai.com/
ftp.server.http.prefix=https://img.yanshiz.com/
redis1.ip=localhost
redis1.port=6379
redis1.port=6380
redis1.pwd=
redis1.timeout=10000
redis.max.total=50
src/main/resources/application.yml
@@ -2,7 +2,7 @@
# 开发环境配置
server:
  # 服务器的HTTP端口,默认为8090
  port: 8091
  port: 8219
  tomcat:
    # tomcat的URI编码
    uri-encoding: UTF-8
@@ -104,7 +104,7 @@
    # 地址
    host: localhost
    # 端口,默认为6379
    port: 6379
    port: 6380
    # 数据库索引
    database: 0
    # 密码
@@ -124,9 +124,9 @@
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driverClassName: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://127.0.0.1:3306/stock_ci?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
    url: jdbc:mysql://127.0.0.1:6306/stock_ci?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
#    url: jdbc:mysql://127.0.0.1:3306/cgstock?useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=convertToNull&useSSL=true&serverTimezone=GMT%2B8
    username: root
    username: stock_ci
    password: 123456
    druid:
      # 初始连接数