From 9f8d7e3f8eb1e81e6eab411a415030085ff64da5 Mon Sep 17 00:00:00 2001
From: zhongrj <646384940@qq.com>
Date: Tue, 07 Mar 2023 14:09:09 +0800
Subject: [PATCH] 对讲设备读取数据修改
---
src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java | 21 +++++++++++++++++++--
1 files changed, 19 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java b/src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java
index 0c5bb60..0139bbb 100644
--- a/src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java
+++ b/src/main/java/com/genersoft/iot/vmp/storager/impl/VideoManagerStoragerImpl.java
@@ -10,6 +10,7 @@
import com.genersoft.iot.vmp.media.zlm.dto.StreamProxyItem;
import com.genersoft.iot.vmp.media.zlm.dto.StreamPushItem;
import com.genersoft.iot.vmp.policeBodyCamera.entity.DeviceChannelPoliceCamera;
+import com.genersoft.iot.vmp.policeBodyCamera.mapper.DeviceChannelPoliceCameraMapper;
import com.genersoft.iot.vmp.policeBodyCamera.service.DeviceChannelPoliceCameraService;
import com.genersoft.iot.vmp.service.IGbStreamService;
import com.genersoft.iot.vmp.service.bean.GPSMsgInfo;
@@ -107,6 +108,9 @@
@Autowired
private DeviceChannelPoliceCameraService deviceChannelPoliceCameraService;
+ @Autowired
+ private DeviceChannelPoliceCameraMapper deviceChannelPoliceCameraMapper;
+
private SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@@ -179,11 +183,12 @@
deviceChannelMapper.update(channel);
}
deviceChannelMapper.updateChannelSubCount(deviceId,channel.getParentId());
+ System.out.println("设备名称 = " + channel.getName());
//如果是是执法记录仪
- if (null!=channel.getName() && channel.getName().contains("执法记录仪")){
+// if (null!=channel.getName() && channel.getName().contains("执法记录仪")){
//更新执法记录仪信息
deviceChannelPoliceCameraService.updateChannelPoliceCamera(channel);
- }
+// }
}
@Override
@@ -234,9 +239,15 @@
toIndex = addChannels.size();
}
deviceChannelMapper.batchAdd(addChannels.subList(i, toIndex));
+ //执法记录仪数据新增
+ System.out.println("执法记录仪批量新增 ================= ");
+ deviceChannelPoliceCameraMapper.batchAdd(addChannels.subList(i, toIndex));
}
}else {
deviceChannelMapper.batchAdd(addChannels);
+ //执法记录仪数据新增
+ System.out.println("执法记录仪批量新增 ================= ");
+ deviceChannelPoliceCameraMapper.batchAdd(addChannels);
}
}
if (updateChannels.size() > 0) {
@@ -247,9 +258,15 @@
toIndex = updateChannels.size();
}
deviceChannelMapper.batchUpdate(updateChannels.subList(i, toIndex));
+ //执法记录仪数据修改
+ System.out.println("执法记录仪批量修改 ================= ");
+ deviceChannelPoliceCameraMapper.batchUpdate(updateChannels.subList(i, toIndex));
}
}else {
deviceChannelMapper.batchUpdate(updateChannels);
+ //执法记录仪数据修改
+ System.out.println("执法记录仪批量修改 ================= ");
+ deviceChannelPoliceCameraMapper.batchUpdate(updateChannels);
}
}
}
--
Gitblit v1.9.3