雨量设备在线离线

This commit is contained in:
guoshengxiong 2024-07-11 10:26:50 +08:00
parent 0ec791e703
commit 369143d68b

View File

@ -130,21 +130,20 @@ public class RainTask {
record.setDevSn(deviceAddr); record.setDevSn(deviceAddr);
record.setProjectSn(dev.getProjectSn()); record.setProjectSn(dev.getProjectSn());
records.add(record); records.add(record);
dev.setLastUploadTime(new Date());
} }
//更新在线离线 //更新在线离线
String offline = "offline"; String offline = "offline";
if (offline.equals(deviceStatus)) { if (offline.equals(deviceStatus)) {
if (dev != null) { if (dev != null) {
if (DateUtil.compare(dev.getLastUploadTime(), DateUtil.offsetMinute(new Date(), -30)) >= 0) { if (dev.getLastUploadTime() != null && DateUtil.compare(dev.getLastUploadTime(), DateUtil.offsetMinute(new Date(), -30)) >= 0) {
dev.setLastUploadTime(DateUtil.offsetMinute(new Date(), -60)); dev.setLastUploadTime(DateUtil.offsetMinute(new Date(), -60));
rainDevMapper.updateById(dev); rainDevMapper.updateById(dev);
} }
} }
} else { } else {
if (dev != null) { if (dev != null) {
if (DateUtil.compare(dev.getLastUploadTime(), DateUtil.offsetMinute(new Date(), -30)) < 0) { if (dev.getLastUploadTime() == null || DateUtil.compare(dev.getLastUploadTime(), DateUtil.offsetMinute(new Date(), -20)) < 0) {
dev.setLastUploadTime(new Date()); dev.setLastUploadTime(new Date());
rainDevMapper.updateById(dev); rainDevMapper.updateById(dev);
} }