1、修改推送的bug

sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/Forwarder.java

@@ -121,15 +121,16 @@ public class Forwarder {
             calcDataQueryWrapper.orderByAsc("createtime");
             List<GnssCalcData> calcDataList = gnssDataMapper.selectList(calcDataQueryWrapper);
             // 推送记录
-            sendBatch(fwdRecord.getProject_id(),calcDataList);
+            if(sendBatch(fwdRecord.getProject_id(),calcDataList)>0) {
                 // 记录推送结果
                 fwdRecord.setState(FwdRecord.STATE_FWD_DONE);
                 fwdRecordsMapper.updateById(fwdRecord);
             }
         }
+    }
 
-    void sendBatch(String projectId, List<GnssCalcData> records){
+    int sendBatch(String projectId, List<GnssCalcData> records){
-        if(records.size() == 0) return;
+        if(records.size() == 0) return 0;
 
         LocalDateTime lastTime = records.get(0).getCreatetime();
 
@@ -144,8 +145,7 @@ public class Forwarder {
             }
         }
 
-        send(projectId, records);
+        return send(projectId, records);
-
     }
 
     int send(String projectId, List<GnssCalcData> records) {

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

@@ -43,13 +43,6 @@ public class GXXfzForwarder extends Forwarder{
         xfzTcpClient.start();
     }
 
-    @Scheduled(cron = "0 29,39,59 * * * ?") // 每29分/59分执行一次
-    private void checkTCP() {
-        if(!xfzTcpClient.isActive()) {
-            xfzTcpClient.connect();
-        }
-    }
-
     /**
      * 每半小时转发GNSS解算结果
      */
@@ -69,6 +62,16 @@ 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);
@@ -77,7 +80,7 @@ public class GXXfzForwarder extends Forwarder{
         xfzTcpMessage.setData(dataList);
 
         for(GnssCalcData locationRecord: records) {
-            if(!locationRecord.getEnabled()) continue;
+            if(!locationRecord.getEnabled() || locationRecord.getRb562e()==null) continue;
             XFZData.Data data = new XFZData.Data();
             dataList.add(data);
             data.setDataTime(locationRecord.getCreatetime().format(dateFormatter));

sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/GZYForwarder.java

@@ -61,7 +61,7 @@ public class GZYForwarder extends Forwarder{
 
 
         for(GnssCalcData locationRecord: records) {
-            if(!locationRecord.getEnabled()) continue;
+            if(!locationRecord.getEnabled() || locationRecord.getRb562e()==null) continue;
             GZYData.Data tranData = new GZYData.Data();
             tranData.setCollectTime(locationRecord.getCreatetime().format(formatter));
             double n = NumberUtils.scale(locationRecord.getRb562n(), 2);

sec-beidou-fwd/src/main/java/com/imdroid/beidou_fwd/task/KingMaForwarder.java

@@ -101,7 +101,7 @@ public class KingMaForwarder extends Forwarder{
         List<KingMaData> dataList = new ArrayList<>(records.size());
 
         for(GnssCalcData locationRecord: records) {
-            if(!locationRecord.getEnabled()) continue;
+            if(!locationRecord.getEnabled() || locationRecord.getRb562e()==null) continue;
             KingMaData data = new KingMaData();
             data.setDataTime(locationRecord.getCreatetime().toString());
             data.setProjectId(projectId);