Browse Source

yinruoxi

sonar:
    1.Either re-interrupt this method or rethrow the "InterruptedException" that can be caught here.
    2.Use a thread-safe type; adding "volatile" is not enough to make this field thread-safe.
    3.Remove the boxing to "Long"; The argument is already of the same type.
tags/B.2.7.0_20240201_base
kira 1 year ago
parent
commit
9b0f1f516f
3 changed files with 4 additions and 3 deletions
  1. +1
    -0
      xueyi-modules/xueyi-nlt/src/main/java/com/xueyi/nlt/netty/client/listener/LlmWebSocketListener.java
  2. +2
    -2
      xueyi-modules/xueyi-nlt/src/main/java/com/xueyi/nlt/netty/server/config/ServerConfig.java
  3. +1
    -1
      xueyi-modules/xueyi-nlt/src/main/java/com/xueyi/nlt/nlt/controller/DmIntentController.java

+ 1
- 0
xueyi-modules/xueyi-nlt/src/main/java/com/xueyi/nlt/netty/client/listener/LlmWebSocketListener.java View File

@@ -111,6 +111,7 @@ public class LlmWebSocketListener extends WebSocketListener {
webSocket.close(1000, "");
} catch (InterruptedException e) {
logger.error("websocket发送消息异常:{}",e.getMessage());
Thread.currentThread().interrupt();
}

}


+ 2
- 2
xueyi-modules/xueyi-nlt/src/main/java/com/xueyi/nlt/netty/server/config/ServerConfig.java View File

@@ -6,8 +6,8 @@ import java.util.concurrent.ConcurrentHashMap;

public class ServerConfig {

public static volatile ConcurrentHashMap<String, Channel> sessionMap = new ConcurrentHashMap<>();
public static final ConcurrentHashMap<String, Channel> sessionMap = new ConcurrentHashMap<>();

public static volatile ConcurrentHashMap<String,Long> currentTraceMap = new ConcurrentHashMap<>();
public static final ConcurrentHashMap<String,Long> currentTraceMap = new ConcurrentHashMap<>();

}

+ 1
- 1
xueyi-modules/xueyi-nlt/src/main/java/com/xueyi/nlt/nlt/controller/DmIntentController.java View File

@@ -346,7 +346,7 @@ public class DmIntentController extends BaseController<DmIntentQuery, DmIntentDt
}
Source source = SourceUtil.getSourceCache(manDeviceDtoR.getData().getStrategyId());
String enterpriseName = "";
R<SysEnterpriseDto> enterpriseDtoR = remoteEnterpriseService.getInfo(Long.valueOf(manDeviceDtoR.getData().getTId()));
R<SysEnterpriseDto> enterpriseDtoR = remoteEnterpriseService.getInfo(manDeviceDtoR.getData().getTId());
if (enterpriseDtoR.isOk()) {
enterpriseName = enterpriseDtoR.getData().getName();
}


Loading…
Cancel
Save