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
2024-12-20 16:36:41 +08:00
parent bc33f78d0c
commit 8f0b923744
1 changed files with 21 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
detection/src/main/java/com/njcn/gather/detection/util/socket/service/NettyServerHandler.java
View File

@@ -43,10 +43,27 @@ public class NettyServerHandler extends SimpleChannelInboundHandler<String> {
}else{ }else{
channel.writeAndFlush("socket指令结果：成功指令"); channel.writeAndFlush("socket指令结果：成功指令");
}*/ }*/
JSONObject jsonObject = new JSONObject(); if(!msg.contains("HeartBeat")){
jsonObject.put("requestId","yjc_ytxjy"); JSONObject jsonObject1 = new JSONObject();
jsonObject.put("code","10200"); jsonObject1.put("requestId","yjc_ytxjy");
channel.writeAndFlush(jsonObject.toJSONString()+'\n'); jsonObject1.put("operateCode","INIT_GATHER");
jsonObject1.put("code","10201");
channel.writeAndFlush(jsonObject1.toJSONString()+'\n');
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
JSONObject jsonObject = new JSONObject();
jsonObject.put("requestId","yjc_ytxjy");
jsonObject.put("operateCode","INIT_GATHER");
jsonObject.put("code","10200");
channel.writeAndFlush(jsonObject.toJSONString()+'\n');
}
} }
@Override @Override