摄像头同步

zc-business/src/main/java/com/zc/business/controller/VideoController.java

@@ -99,8 +99,8 @@ public class VideoController extends BaseController {
     public AjaxResult synchronizeIotIds() {
         // 查询未同步物联ID的摄像头设备信息
         LambdaQueryWrapper<DcDevice> query = new LambdaQueryWrapper<>();
-        query.eq(DcDevice::getDeviceType, DeviceTypeConstants.CAMERA)
-                .isNull(DcDevice::getIotDeviceId);
+        query.eq(DcDevice::getDeviceType, DeviceTypeConstants.CAMERA);
+//                .isNull(DcDevice::getIotDeviceId);
 
         List<DcDevice> uninitializedCameras = iDcDeviceService.list(query);
 
@@ -164,23 +164,23 @@ public class VideoController extends BaseController {
             // 遍历并更新具备匹配IP的摄像头设备物联ID
             List<DcDevice> devicesToUpdate = new ArrayList<>();
             camType1Array.forEach(item -> {
-                JSONObject cameraInfo = (JSONObject) item;
-                // 桩号
-                String pileNum = cameraInfo.getString("pileNum");
-                // 方向
-                Integer camOrientation = cameraInfo.getInteger("camOrientation");
-                LaneDirectionEnum laneDirectionEnum = CameraDirectionEnum.fromCode(camOrientation).toLaneDirection();
-
-                // 是否有云台控制 0 有（球机） 1 ⽆（枪机）
-                String ptzCtrl = cameraInfo.getString("ptzCtrl");
-
-                String key = pileNum + UniversalEnum.VERTICAL_LINE.getValue() + laneDirectionEnum.getValue() + UniversalEnum.VERTICAL_LINE.getValue() + ptzCtrl;
-
-                if (cameraMap.containsKey(key)) {
-                    DcDevice dcDevice = cameraMap.get(key);
-                    dcDevice.setIotDeviceId(cameraInfo.getString("camId"));
-                    devicesToUpdate.add(dcDevice);
-                }
+                    JSONObject cameraInfo = (JSONObject) item;
+                    // 桩号
+                    String pileNum = cameraInfo.getString("pileNum");
+                    // 方向
+                    int camOrientation = Integer.valueOf(cameraInfo.getString("camOrientation"));
+                    LaneDirectionEnum laneDirectionEnum = CameraDirectionEnum.fromCode(camOrientation).toLaneDirection();
+
+                    // 是否有云台控制 0 有（球机） 1 ⽆（枪机）
+                    String ptzCtrl = cameraInfo.getString("ptzCtrl");
+
+                    String key = pileNum + UniversalEnum.VERTICAL_LINE.getValue() + laneDirectionEnum.getValue() + UniversalEnum.VERTICAL_LINE.getValue() + ptzCtrl;
+
+                    if (cameraMap.containsKey(key)) {
+                        DcDevice dcDevice = cameraMap.get(key);
+                        dcDevice.setIotDeviceId(cameraInfo.getString("camId"));
+                        devicesToUpdate.add(dcDevice);
+                    }
             });
 
             // 批量更新摄像头设备的物联ID
@@ -235,7 +235,7 @@ public class VideoController extends BaseController {
     /***
      * 根据相机中的设备状态，修改数据平台设备的设备状态
      */
-    @Scheduled(cron = "0 0/5 * * * ?")
+    //@Scheduled(cron = "0 0/5 * * * ?")
     @PostMapping("/updateDeviceState")
     public void updateDeviceState() throws HttpException, IOException {
         logger.debug("开始执行：同步数据平台视频设备设备的设备状态！！");
@@ -246,6 +246,7 @@ public class VideoController extends BaseController {
 //            JSONObject qiLuGaoSu = JSONObject.parseObject(JSONArray.parseArray(dataChildren.get("children").toString()).get(UniversalEnum.ZERO.getNumber()).toString());
 //            JSONObject jiHeYunGuan = JSONObject.parseObject(JSONArray.parseArray(qiLuGaoSu.get("children").toString()).get(UniversalEnum.ZERO.getNumber()).toString());
 //            JSONArray jiHeYunGuanG35 = JSONArray.parseArray(jiHeYunGuan.get("children").toString());
+
             JSONArray data = cameraData.getJSONArray("data");
             JSONObject children = data.getJSONObject(0);
             JSONArray jsonObject = children.getJSONArray("children");
@@ -292,6 +293,7 @@ public class VideoController extends BaseController {
 //                device.setIotDeviceId(item.get("camId").toString());
 //                list.add(device);
 //            }
+
             iDcDeviceService.batchUpdate(list);
 
             //更新中间库的设备状态
@@ -526,7 +528,21 @@ public class VideoController extends BaseController {
 
         return AjaxResult.success(result);
     }
+    /**
+     * 根据桩号查询附近收费站摄像机
+     */
+    @ApiOperation("根据桩号查询附近收费站摄像机")
+    @GetMapping(value = "/tollStationList")
+    public Object selectTollStationCamPile(@ApiParam(value = "桩号", name = "pileNum", required = true) String pileNum) throws HttpException, IOException {
+        Map<String,Object> result = new HashMap<>();
+        Integer pileNumDistance = pileNumTransformMetre(pileNum);
+        String startMileage = String.valueOf(pileNumDistance - UniversalEnum.TWO_THOUSAND.getNumber());
+        String endMileage = String.valueOf(pileNumDistance + UniversalEnum.TWO_THOUSAND.getNumber());
+        List<DcDevice> tollStationList = iDcDeviceService.selectTollStationCamPile(UniversalEnum.THREE.getValue(),startMileage,endMileage);
+        result.put("tollStationList",tollStationList);
 
+        return AjaxResult.success(result);
+    }
     /**
      * 获取视频流信息
      */

zc-business/src/main/java/com/zc/business/mapper/DcDeviceMapper.java

@@ -39,4 +39,7 @@ public interface DcDeviceMapper extends BaseMapper<DcDevice> {
     List<DcDevice> selectDeviceTollStationCamera();
     //同步收费站摄像头状态
     Integer updateTollStationCameraStatus(DcDevice dcDevice);
+
+    //获取收费站摄像头
+    List<DcDevice> selectTollStationCamPile(@Param("direction") String direction,@Param("startMileage") String startMileage,@Param("endMileage") String endMileage);
 }

zc-business/src/main/java/com/zc/business/service/IDcDeviceService.java

@@ -127,5 +127,6 @@ public interface IDcDeviceService extends IService<DcDevice> {
     List<DcDevice> selectDeviceTollStationCamera();
     //同步收费站摄像头状态
     Integer updateTollStationCameraStatus(DcDevice dcDevice);
-
+    //获取附近收费站摄像头
+    List<DcDevice> selectTollStationCamPile(String direction, String startMileage, String endMileage);
 }

zc-business/src/main/java/com/zc/business/service/impl/DcDeviceServiceImpl.java

@@ -654,5 +654,10 @@ public class DcDeviceServiceImpl extends ServiceImpl<DcDeviceMapper, DcDevice> i
     public Integer updateTollStationCameraStatus(DcDevice dcDevice) {
         return dcDeviceMapper.updateTollStationCameraStatus(dcDevice);
     }
+    //获取附近收费站摄像头
+    @Override
+    public List<DcDevice> selectTollStationCamPile(String direction, String startMileage, String endMileage) {
+        return dcDeviceMapper.selectTollStationCamPile(direction, startMileage, endMileage);
+    }
 }
 

zc-business/src/main/resources/mapper/business/DcDeviceMapper.xml

@@ -185,7 +185,18 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
     <select id="selectDeviceTollStationCamera" resultType="com.zc.business.domain.DcDevice">
         select id,iot_device_id from dc_device where facilities_type=5
     </select>
+
     <update id="updateTollStationCameraStatus">
         update dc_device set device_state=#{deviceState} where id=#{id}
     </update>
+    <select id="selectTollStationCamPile" resultType="com.zc.business.domain.DcDevice">
+        select t1.id, t1.iot_device_id, t1.group_id, t1.product_id, t1.stake_mark, t1.direction, t1.device_name,
+               t1.device_code, t1.device_type,t1.installation_Date,t1.production_date,t1.durable_years,t1.installation_site,
+               t1.use_state,t1.device_state,t1.other_config,t1.remark,t1.create_time,t1.update_time,t1.facilities_type,
+               t1.device_ip,t1.stake_mark_range,t1.network_segment,t1.device_img,t1.child_type,t1.facilities_type,t1.longitude,t1.latitude
+        from dc_device t1
+                 left join (select * from dc_stake_mark GROUP BY stake_mark) t2 on t1.stake_mark = t2.stake_mark
+        where  !ISNULL(t1.iot_device_id) and t1.device_type = '1' and (t1.facilities_type = '5'|| t1.facilities_type = '4')
+          and t2.mileage >= #{startMileage} and t2.mileage &lt;= #{endMileage}
+    </select>
 </mapper>