diff --git a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GXXfzForwarder.java b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GXXfzForwarder.java index 7fe788a4..72a14d6b 100644 --- a/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GXXfzForwarder.java +++ b/sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GXXfzForwarder.java @@ -62,16 +62,6 @@ public class GXXfzForwarder extends Forwarder{ int sendNum = 0; if(records.size() == 0) return 0; - if(!xfzTcpClient.isActive()) { - xfzTcpClient.connect(); - try { - Thread.sleep(5000); - } - catch (Exception e){ - - } - } - XFZData xfzTcpMessage = new XFZData(); xfzTcpMessage.setProjectID(projectId); xfzTcpMessage.setWorkPointID(projectId); @@ -95,6 +85,15 @@ public class GXXfzForwarder extends Forwarder{ String json = GsonUtil.toJson(xfzTcpMessage); logger.info("project " + projectId + ": push calculation result to XFZ"); logger.info(json); + if(!xfzTcpClient.isActive()) { + xfzTcpClient.connect(); + try { + Thread.sleep(5000); + } + catch (Exception e){ + + } + } if(xfzTcpClient.isActive()) { xfzTcpClient.writeAndFlush(json); return sendNum;