From 3698d82e83cdb9c687c0e932093e712bda729b42 Mon Sep 17 00:00:00 2001
From: jack <zengjieli93@163.com>
Date: Thu, 28 Mar 2024 12:50:09 +0800
Subject: [PATCH] 韩国股票
---
src/main/java/com/nq/ws/WebsocketRunClient.java | 15 ++++++++++-----
1 files changed, 10 insertions(+), 5 deletions(-)
diff --git a/src/main/java/com/nq/ws/WebsocketRunClient.java b/src/main/java/com/nq/ws/WebsocketRunClient.java
index f6fe1c9..f8da7b5 100644
--- a/src/main/java/com/nq/ws/WebsocketRunClient.java
+++ b/src/main/java/com/nq/ws/WebsocketRunClient.java
@@ -1,14 +1,16 @@
package com.nq.ws;
import com.google.gson.Gson;
-import com.nq.constant.StockConstant;
import com.nq.enums.EStockType;
import com.nq.pojo.StockRealTimeBean;
+import com.nq.service.IMandatoryLiquidationService;
+import com.nq.service.impl.MandatoryLiquidationService;
+import com.nq.utils.ApplicationContextRegisterUtil;
import com.nq.utils.redis.RedisKeyUtil;
-import com.nq.utils.redis.RedisShardedPoolUtils;
import lombok.extern.slf4j.Slf4j;
import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;
+import org.springframework.context.ApplicationContext;
import java.net.URI;
@@ -21,15 +23,18 @@
@Override
public void onOpen(ServerHandshake serverHandshake) {
- log.info("webSocket 客服端链接成功");
- send(("key:"+ StockConstant.KEY+":"+EStockType.IN.getContryId()).getBytes());
+ send(("key:"+ EStockType.MAS.getStockKey()+":"+EStockType.MAS.getContryId()).getBytes());
}
@Override
public void onMessage(String s) {
try {
+
+
+ ApplicationContext act = ApplicationContextRegisterUtil.getApplicationContext();
+ MandatoryLiquidationService liquidationService = (MandatoryLiquidationService) act.getBean(IMandatoryLiquidationService.class);
StockRealTimeBean stockDetailBean = new Gson().fromJson(s, StockRealTimeBean.class);
- RedisKeyUtil.setCacheRealTimeStock(EStockType.IN,stockDetailBean);
+ liquidationService.RealTimeDataProcess(EStockType.MAS,stockDetailBean);
}catch (Exception e){
}
--
Gitblit v1.9.3