소스 검색

首页实时流接口--返回相机信息

buzhanyi 1 년 전
부모
커밋
b53fb727b9
1개의 변경된 파일13개의 추가작업 그리고 0개의 파일을 삭제
  1. 13 0
      vehicle-admin/src/main/java/com/ozs/web/controller/accountmanagment/BaseVehicleController.java

+ 13 - 0
vehicle-admin/src/main/java/com/ozs/web/controller/accountmanagment/BaseVehicleController.java

@@ -12,6 +12,7 @@ import com.ozs.common.utils.ChineseToPingyin;
 import com.ozs.common.utils.StringUtils;
 import com.ozs.common.utils.file.FileUtils;
 import com.ozs.common.utils.poi.ExcelUtil;
+import com.ozs.entity.BaseCameraManagement;
 import com.ozs.entity.BaseRailwayManagement;
 import com.ozs.entity.BaseTerminal;
 import com.ozs.entity.BaseVehicle;
@@ -20,6 +21,7 @@ import com.ozs.entity.vo.BaseRailwayManagementVo;
 import com.ozs.entity.vo.BaseVehicleTerminalVo;
 import com.ozs.entity.vo.BaseVehicleVo;
 import com.ozs.entity.vo.VehicleTreeVo;
+import com.ozs.service.BaseCameraManagementService;
 import com.ozs.service.BaseDeviceDynamicManagementService;
 import com.ozs.service.BaseRailwayManagementService;
 import com.ozs.service.BaseVehicleService;
@@ -54,6 +56,8 @@ import java.util.stream.Collectors;
 public class BaseVehicleController extends BaseController {
     @Resource
     BaseRailwayManagementService baseRailwayManagementService;
+    @Resource
+    BaseCameraManagementService cameraManagementService;
     @Autowired
     private DataScoreUtil dataScoreUtil;
     @Autowired
@@ -345,8 +349,17 @@ public class BaseVehicleController extends BaseController {
             Object cameraCode = cacheMap.get("cameraCode");
             Object stream = cacheMap.get("currentStream");
             if (!ObjectUtils.isEmpty(cameraCode)) {
+                LambdaQueryWrapper<BaseCameraManagement> bcWrapper = new LambdaQueryWrapper<>();
+                bcWrapper.eq(BaseCameraManagement::getCameraCode, cameraCode.toString());
+                BaseCameraManagement one = cameraManagementService.getOne(bcWrapper);
+                //相机编码和实时流
                 ccMap.put("cameraCode", cameraCode.toString());
                 ccMap.put("currentStream", stream.toString());
+                //行别
+                String lineDirStr = one.getLineDir() == 1 ? "上行" : "下行";
+                ccMap.put("lineDir", lineDirStr);
+                //安装里程位置
+                ccMap.put("installMile", one.getInstallMiles());
                 return AjaxResult.success(ccMap);
             }
         }