|
@@ -449,7 +449,7 @@ public class MonitorIndicatorRecordServiceImpl implements IMonitorIndicatorRecor
|
|
|
String alarmItemCode = objIdAndAlarmItemCode.substring(indexOf + 1);
|
|
|
String lockKey = AlarmConstants.alarmDataLockPrefix + objId + "-" + alarmItemCode;
|
|
|
Object isLock = redisUtil.get(lockKey);
|
|
|
- log.error("是否获取到锁:" + isLock);
|
|
|
+// log.error("是否获取到锁:" + isLock);
|
|
|
if (null != isLock) {
|
|
|
continue;
|
|
|
}
|
|
@@ -479,14 +479,14 @@ public class MonitorIndicatorRecordServiceImpl implements IMonitorIndicatorRecor
|
|
|
endTime = DateUtils.str2Date(dateListEntry.getKey(), DateUtils.SDFSECOND);
|
|
|
}
|
|
|
JSONArray sendArray = CollectDataUtil.batchBuildSendJsonParam(sendTimeKeyAndDataList, alarmItemCode);
|
|
|
- /* 先更新发数时间再发数,避免已经发数但更新发数时间异常导致重复发数的问题 */
|
|
|
- // 更新发数时间
|
|
|
- configItemSendTimeDTO.setLastSendTime(endTime);
|
|
|
- configItemSendTimeDTO.setUpdateTime(new Date());
|
|
|
- updateRedisConfigItemSendTimeDTO(projectDTO.getProjectId(), objIdAndAlarmItemCode, configItemSendTimeDTO);
|
|
|
- // 发数
|
|
|
|
|
|
try {
|
|
|
+ /* 先更新发数时间再发数,避免已经发数但更新发数时间异常导致重复发数的问题 */
|
|
|
+ // 更新发数时间
|
|
|
+ configItemSendTimeDTO.setLastSendTime(endTime);
|
|
|
+ configItemSendTimeDTO.setUpdateTime(new Date());
|
|
|
+ updateRedisConfigItemSendTimeDTO(projectDTO.getProjectId(), objIdAndAlarmItemCode, configItemSendTimeDTO);
|
|
|
+ // 发数
|
|
|
rabbitConfig.sendMsg(sendArray);
|
|
|
} catch (Exception e) {
|
|
|
e.printStackTrace();
|