Imdroid/security-monitor
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

1、修改推送的bug

Browse Source
This commit is contained in:
weidong 2024-01-15 13:48:47 +08:00
parent 9f4f5ad5c9
commit 6fe9c14d67
1 changed files with 9 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GXXfzForwarder.java
View File

@ -62,16 +62,6 @@ public class GXXfzForwarder extends Forwarder{
int sendNum = 0; int sendNum = 0;
if(records.size() == 0) return 0; if(records.size() == 0) return 0;
if(!xfzTcpClient.isActive()) {
xfzTcpClient.connect();
try {
Thread.sleep(5000);
}
catch (Exception e){
}
}
XFZData xfzTcpMessage = new XFZData(); XFZData xfzTcpMessage = new XFZData();
xfzTcpMessage.setProjectID(projectId); xfzTcpMessage.setProjectID(projectId);
xfzTcpMessage.setWorkPointID(projectId); xfzTcpMessage.setWorkPointID(projectId);
@ -95,6 +85,15 @@ public class GXXfzForwarder extends Forwarder{
String json = GsonUtil.toJson(xfzTcpMessage); String json = GsonUtil.toJson(xfzTcpMessage);
logger.info("project " + projectId + ": push calculation result to XFZ"); logger.info("project " + projectId + ": push calculation result to XFZ");
logger.info(json); logger.info(json);
if(!xfzTcpClient.isActive()) {
xfzTcpClient.connect();
try {
Thread.sleep(5000);
}
catch (Exception e){
}
}
if(xfzTcpClient.isActive()) { if(xfzTcpClient.isActive()) {
xfzTcpClient.writeAndFlush(json); xfzTcpClient.writeAndFlush(json);
return sendNum; return sendNum;