From 58462e5cb223672fd5bf3ca463341c12397dae0b Mon Sep 17 00:00:00 2001
From: eric <465889110@qq.com>
Date: Mon, 29 Sep 2025 13:01:34 +0800
Subject: [PATCH] no message

---
 .../java/com/sczx/sync/Task/DataResendTask.java   | 15 ++++++---------
 .../sync/service/impl/SendDataServiceImpl.java    |  1 +
 2 files changed, 7 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/sczx/sync/Task/DataResendTask.java b/src/main/java/com/sczx/sync/Task/DataResendTask.java
index fd46447..3ceea81 100644
--- a/src/main/java/com/sczx/sync/Task/DataResendTask.java
+++ b/src/main/java/com/sczx/sync/Task/DataResendTask.java
@@ -23,18 +23,15 @@ public class DataResendTask {
 
     @Autowired
     private OrderBatteryInfoMapper orderBatteryInfoMapper;
-    
-    @Scheduled(fixedRate = 10000)
+
+    @Scheduled(fixedRate = 15000)
     public void resendFailedData() {
         // 查询所有发送失败的记录
-        List<DataReceivePo> failedRecords = dataReceiveRecordMapper.selectList(new QueryWrapper<DataReceivePo>().eq("status", 3));
-
+        List<DataReceivePo> failedRecords = dataReceiveRecordMapper.selectList(new QueryWrapper<DataReceivePo>().eq("status", 3).eq("data_type", "batteryorder"));
         for (DataReceivePo record : failedRecords) {
-            if (record.getDataType().equals("batteryorder")){
-                String status = orderBatteryInfoMapper.selectOrderStatus(record.getCid());
-                if (status.equals("RENT_ING")){
-                    sendDataService.retryForward(record.getId());
-                }
+            String status = orderBatteryInfoMapper.selectOrderStatus(record.getCid());
+            if (status.equals("RENT_ING")) {
+                sendDataService.retryForward(record.getId());
             }
         }
     }
diff --git a/src/main/java/com/sczx/sync/service/impl/SendDataServiceImpl.java b/src/main/java/com/sczx/sync/service/impl/SendDataServiceImpl.java
index b2ba4cd..029d1c7 100644
--- a/src/main/java/com/sczx/sync/service/impl/SendDataServiceImpl.java
+++ b/src/main/java/com/sczx/sync/service/impl/SendDataServiceImpl.java
@@ -412,6 +412,7 @@ public class SendDataServiceImpl implements SendDataService {
             // 重新转发
             forwardToThirdParty(recordId,URL+"/"+record.getDataType());
         } catch (Exception e) {
+
             log.error("重试转发失败，记录ID: {}", recordId, e);
         }
     }