qdintc/fishery-back
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: 电流上报值为0的时候，没有更新，bug修复。

Browse Source
This commit is contained in:
tianyongbao
2026-03-30 15:31:05 +08:00
parent d911f232e2
commit 831bbd810a
2 changed files with 43 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
intc-modules/intc-iot/src/main/java/com/intc/iot/handler/DeviceDataHandler.java
View File

@@ -1647,6 +1647,30 @@ public class DeviceDataHandler {
return;
}
// 对应 C# CreateNoticeCall：同一设备已有活跃通知批次时，只追加消息关联，不重复创建新批次
// 活跃批次窗口 = 重试次数 * 手机号数量 * 间隔分钟 * 2（留余量）
int maxBatchMinutes = CALL_NOTICE_RETRY_COUNT * CALL_NOTICE_MINUTE_INTERVAL * 2;
LocalDateTime activeBatchStart = LocalDateTime.now().minusMinutes(maxBatchMinutes);
long activeCount = warnCallNoticeMapper.countActiveByDeviceAfter(device.getId(), activeBatchStart);
if (activeCount > 0) {
log.debug("[故障码] 设备={} 已有活跃通知批次，追加消息关联后跳过重复创建", device.getSerialNum());
// 查找当前批次中最早的一条通知记录，追加关联
AquWarnCallNotice existNotice = warnCallNoticeMapper.selectOne(
new com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper<AquWarnCallNotice>()
.eq(AquWarnCallNotice::getDeviceId, device.getId())
.ge(AquWarnCallNotice::getCallTime, activeBatchStart)
.orderByAsc(AquWarnCallNotice::getCallTime)
.last("LIMIT 1")
);
if (existNotice != null && warn.getId() != null) {
AquMapMessageWarnCallNotice mapRecord = new AquMapMessageWarnCallNotice();
mapRecord.setMessageWarnId(warn.getId());
mapRecord.setCallNoticeId(existNotice.getId());
mapMessageWarnCallNoticeMapper.insert(mapRecord);
}
return;
}
LocalDateTime baseTime = LocalDateTime.now();
int index = 0;
AquWarnCallNotice firstCallNotice = null;
@@ -1995,7 +2019,8 @@ public class DeviceDataHandler {
if (phaseVolt != null && phaseVolt > 0 && voltage == null) {
voltage = phaseVolt;
}
if (phaseCur != null && phaseCur > 0 && current == null) {
// 电流允许为 0（设备空载时上报 0.00 是合法值，不可用 > 0 过滤）
if (phaseCur != null && current == null) {
current = phaseCur;
}
if (voltage != null && current != null) break;
@@ -2008,7 +2033,7 @@ public class DeviceDataHandler {
com.intc.fishery.domain.DeviceSwitch updateVoltCur = new com.intc.fishery.domain.DeviceSwitch();
updateVoltCur.setId(sw.getId());
if (voltage != null) updateVoltCur.setDetectVoltageValue(voltage);
if (current != null) updateVoltCur.setDetectElectricValue(current);
if (current != null) updateVoltCur.setDetectElectricValue(current); // current=0 也需写入
deviceSwitchMapper.updateById(updateVoltCur);
log.debug("更新开关电压电流: 设备={}, 开关索引={}, 电压={}V, 电流={}A",
deviceName, switchIndex, voltage, current);