ClientApps/CN_Gather
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

代码调整

Browse Source
This commit is contained in:
chendaofei
2025-01-08 14:42:17 +08:00
parent b24b282cbb
commit 6de6c0955d
3 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
detection/src/main/java/com/njcn/gather/detection/controller/PreDetectionController.java
View File

@@ -61,14 +61,14 @@ public class PreDetectionController extends BaseController {
} }
/** /**
* 开始预检测 * 开始检测
*/ */
@PostMapping("/startPreTest") @PostMapping("/startPreTest")
@OperateInfo @OperateInfo
@ApiOperation("开始预检测") @ApiOperation("开始检测")
@ApiImplicitParam(name = "param", value = "查询参数", required = true) @ApiImplicitParam(name = "param", value = "查询参数", required = true)
public HttpResult<String> startPreTest(@RequestBody PreDetectionParam param){ public HttpResult<String> startPreTest(@RequestBody PreDetectionParam param){
System.out.println("系数校验controller进入================================22"); System.out.println("开始检测controller进入================================22");
String methodDescribe = getMethodDescribe("startPreTest"); String methodDescribe = getMethodDescribe("startPreTest");
preDetectionService.sourceCommunicationCheck(param); preDetectionService.sourceCommunicationCheck(param);
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe); return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, null, methodDescribe);

2
detection/src/main/java/com/njcn/gather/detection/util/socket/cilent/NettyDevClientHandler.java
View File

@@ -48,7 +48,7 @@ public class NettyDevClientHandler extends SimpleChannelInboundHandler<String> {
* @param ctx * @param ctx
*/ */
@Override @Override
public void channelActive(ChannelHandlerContext ctx) { public void channelActive(ChannelHandlerContext ctx)throws Exception {
System.out.println("客户端通道已建立" + ctx.channel().id()); System.out.println("客户端通道已建立" + ctx.channel().id());
Channel channel = SocketManager.getChannelByUserId(param.getUserPageId()+dev); Channel channel = SocketManager.getChannelByUserId(param.getUserPageId()+dev);
if(Objects.nonNull(channel)){ if(Objects.nonNull(channel)){

2
detection/src/main/java/com/njcn/gather/detection/util/socket/cilent/NettySourceClientHandler.java
View File

@@ -69,7 +69,7 @@ public class NettySourceClientHandler extends SimpleChannelInboundHandler<String
* @param ctx * @param ctx
*/ */
@Override @Override
public void channelInactive(ChannelHandlerContext ctx) { public void channelInactive(ChannelHandlerContext ctx) throws Exception{
System.out.println("源通讯客户端断线"); System.out.println("源通讯客户端断线");
Channel channel = SocketManager.getChannelByUserId(webUser.getUserPageId()+sourceTag); Channel channel = SocketManager.getChannelByUserId(webUser.getUserPageId()+sourceTag);