ClientApps/CN_Product
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

修改时间同步频次为10分钟

Browse Source
This commit is contained in:
hzj
2025-11-19 15:41:14 +08:00
parent 35cd056870
commit 27841f0f4e
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
event_smart/src/main/java/com/njcn/product/event/dataTransmit/DataSynchronization.java
View File

@@ -241,14 +241,14 @@ public class DataSynchronization {
Map<String, PqsEventDetailStatusPO> pqsEventDetailStatusPOMap = hasList.stream().collect(Collectors.toMap(PqsEventDetailStatusPO::getEventDetailId, Function.identity())); Map<String, PqsEventDetailStatusPO> pqsEventDetailStatusPOMap = hasList.stream().collect(Collectors.toMap(PqsEventDetailStatusPO::getEventDetailId, Function.identity()));
// 查询事件 // 查询事件
LambdaQueryWrapper<PqsEventdetail> pqsEventdetailLambdaQueryWrapper = new LambdaQueryWrapper<>(); LambdaQueryWrapper<PqsEventdetail> pqsEventdetailLambdaQueryWrapper = new LambdaQueryWrapper<>();
pqsEventdetailLambdaQueryWrapper.between(PqsEventdetail::getCreateTime,start.minusMinutes(3*10),end); pqsEventdetailLambdaQueryWrapper.between(PqsEventdetail::getCreateTime,start.minusMinutes(6*10),end);
List<PqsEventdetail> unsyncedEvents = pqsEventdetailMapper.selectList(pqsEventdetailLambdaQueryWrapper); List<PqsEventdetail> unsyncedEvents = pqsEventdetailMapper.selectList(pqsEventdetailLambdaQueryWrapper);
List<String> tempEvetIds = unsyncedEvents.stream().map(PqsEventdetail::getEventdetailIndex).collect(Collectors.toList()); List<String> tempEvetIds = unsyncedEvents.stream().map(PqsEventdetail::getEventdetailIndex).collect(Collectors.toList());
//查询日志 //查询日志
List<String> allEventIds = hasList.stream().map(PqsEventDetailStatusPO::getEventDetailId).collect(Collectors.toList()); List<String> allEventIds = hasList.stream().map(PqsEventDetailStatusPO::getEventDetailId).collect(Collectors.toList());
List<String> unSyncIds = tempEvetIds.stream().filter(temp -> !allEventIds.contains(temp)).collect(Collectors.toList()); List<String> unSyncIds = tempEvetIds.stream().filter(temp -> !allEventIds.contains(temp)).collect(Collectors.toList());
List<String> failIds = hasList.stream().filter(temp -> temp.getRetryCount() <= 2 && temp.getSyncStatus() == 0).map(PqsEventDetailStatusPO::getEventDetailId).collect(Collectors.toList()); List<String> failIds = hasList.stream().filter(temp -> temp.getRetryCount() <= 5 && temp.getSyncStatus() == 0).map(PqsEventDetailStatusPO::getEventDetailId).collect(Collectors.toList());
unSyncIds.addAll(failIds); unSyncIds.addAll(failIds);
List<UpLoadEvent> result = new ArrayList<>(); List<UpLoadEvent> result = new ArrayList<>();
@@ -286,7 +286,7 @@ public class DataSynchronization {
if(pqsEventDetailStatusPOMap.containsKey(temp)){ if(pqsEventDetailStatusPOMap.containsKey(temp)){
PqsEventDetailStatusPO pqsEventDetailStatusPO = pqsEventDetailStatusPOMap.get(temp); PqsEventDetailStatusPO pqsEventDetailStatusPO = pqsEventDetailStatusPOMap.get(temp);
pqsEventDetailStatusPO.setRetryCount(pqsEventDetailStatusPO.getRetryCount()+1); pqsEventDetailStatusPO.setRetryCount(pqsEventDetailStatusPO.getRetryCount()+1);
if(Objects.nonNull(pqsEventdetail.getWavename())||pqsEventDetailStatusPO.getRetryCount()>2){ if(Objects.nonNull(pqsEventdetail.getWavename())||pqsEventDetailStatusPO.getRetryCount()>5){
pqsEventDetailStatusPO.setSyncStatus(1); pqsEventDetailStatusPO.setSyncStatus(1);
pqsEventDetailStatusPO.setWaveFlag(0); pqsEventDetailStatusPO.setWaveFlag(0);
UpLoadEvent upLoadEvent = new UpLoadEvent(); UpLoadEvent upLoadEvent = new UpLoadEvent();

6
event_smart/src/main/resources/application.yml
View File

@@ -40,10 +40,10 @@ business:
wavePath: D://Comtrade wavePath: D://Comtrade
targetPath: /pqmonitor targetPath: /pqmonitor
exportBaseDir: D://exportComtrade exportBaseDir: D://exportComtrade
eventCronExpression: 0 9 0/1 * * ? eventCronExpression: 0 0/10 * * * ?
failCronExpression: 0 16 0/1 * * ? failCronExpression: 0 5/10 * * * ?
userCronExpression: 0 5 1 * * ? userCronExpression: 0 5 1 * * ?
syncinterval: 60 syncinterval: 10
failsyncinterval: 1440 failsyncinterval: 1440
#wavePath: /usr/local/comtrade #wavePath: /usr/local/comtrade
#处理临时数据 #处理临时数据