对讲设备读取数据修改

zhongrj

2023-03-07 9f8d7e3f8eb1e81e6eab411a415030085ff64da5

 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);
            }
         }
      }