Forráskód Böngészése

调整更新发数时间和发数的顺序

lixing 3 éve
szülő
commit
64a7b5b5a6

+ 5 - 2
src/main/java/com/persagy/apm/diagnose/indicatorrecord/service/impl/MonitorIndicatorRecordServiceImpl.java

@@ -462,11 +462,14 @@ public class MonitorIndicatorRecordServiceImpl implements IMonitorIndicatorRecor
                 endTime = DateUtils.str2Date(dateListEntry.getKey(), DateUtils.SDFSECOND);
             }
             JSONArray sendArray = CollectDataUtil.batchBuildSendJsonParam(sendTimeKeyAndDataList, alarmItemCode);
-            rabbitConfig.sendMsg(sendArray);
-            log.error("指标发送报表服务数据:" + projectDTO.getProjectId() + ";" + sendArray);
+            /* 先更新发数时间再发数,避免已经发数但更新发数时间异常导致重复发数的问题 */
+            // 更新发数时间
             configItemSendTimeDTO.setLastSendTime(endTime);
             configItemSendTimeDTO.setUpdateTime(new Date());
             updateRedisConfigItemSendTimeDTO(projectDTO.getProjectId(), objIdAndAlarmItemCode, configItemSendTimeDTO);
+            // 发数
+            rabbitConfig.sendMsg(sendArray);
+            log.error("指标发送报表服务数据:" + projectDTO.getProjectId() + ";" + sendArray);
         }
     }