sczx_group/sczx_sync
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

no message

Browse Source
This commit is contained in:
eric
2025-09-29 13:01:34 +08:00
parent b4ad435945
commit 58462e5cb2
2 changed files with 7 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/com/sczx/sync/Task/DataResendTask.java
View File

@ -24,18 +24,15 @@ public class DataResendTask {
@Autowired @Autowired
private OrderBatteryInfoMapper orderBatteryInfoMapper; private OrderBatteryInfoMapper orderBatteryInfoMapper;
@Scheduled(fixedRate = 10000) @Scheduled(fixedRate = 15000)
public void resendFailedData() { 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) { for (DataReceivePo record : failedRecords) {
if (record.getDataType().equals("batteryorder")){
String status = orderBatteryInfoMapper.selectOrderStatus(record.getCid()); String status = orderBatteryInfoMapper.selectOrderStatus(record.getCid());
if (status.equals("RENT_ING")){ if (status.equals("RENT_ING")) {
sendDataService.retryForward(record.getId()); sendDataService.retryForward(record.getId());
} }
} }
} }
}
} }

1
src/main/java/com/sczx/sync/service/impl/SendDataServiceImpl.java
View File

@ -412,6 +412,7 @@ public class SendDataServiceImpl implements SendDataService {
// 重新转发 // 重新转发
forwardToThirdParty(recordId,URL+"/"+record.getDataType()); forwardToThirdParty(recordId,URL+"/"+record.getDataType());
} catch (Exception e) { } catch (Exception e) {
log.error("重试转发失败，记录ID: {}", recordId, e); log.error("重试转发失败，记录ID: {}", recordId, e);
} }
} }