From e6b7d6af8f9acf79f32fd386a9cead2d24ae2f9a Mon Sep 17 00:00:00 2001
From: wl <173@qq.com>
Date: 星期五, 30 十二月 2022 15:04:55 +0800
Subject: [PATCH] fix: 栏目订阅

---
 ycl-platform/src/main/java/com/ycl/controller/cockpit/aiIot/AIIotController.java |   71 ++++++++++++++++++++++-------------
 1 files changed, 44 insertions(+), 27 deletions(-)

diff --git a/ycl-platform/src/main/java/com/ycl/controller/cockpit/aiIot/AIIotController.java b/ycl-platform/src/main/java/com/ycl/controller/cockpit/aiIot/AIIotController.java
index 1393455..307a6fe 100644
--- a/ycl-platform/src/main/java/com/ycl/controller/cockpit/aiIot/AIIotController.java
+++ b/ycl-platform/src/main/java/com/ycl/controller/cockpit/aiIot/AIIotController.java
@@ -1,16 +1,24 @@
 package com.ycl.controller.cockpit.aiIot;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.ycl.api.CommonResult;
+import com.ycl.entity.video.VideoPoint;
+import com.ycl.service.carManage.ICarSlagcarService;
+import com.ycl.service.equipment.IHandheldTerminalService;
+import com.ycl.service.equipment.ILoudspeakerService;
+import com.ycl.service.video.impl.IVideoPointService;
 import com.ycl.util.CheckApiUtil;
+import com.ycl.util.VideoUtil;
 import com.ycl.vo.cockpit.CockpitVO;
 import com.ycl.vo.cockpit.aiIot.AIIotVO;
+import com.ycl.vo.cockpit.aiIot.EfficiencyVO;
+import com.ycl.vo.cockpit.aiIot.VideoVO;
 import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
 
 import javax.annotation.Resource;
@@ -18,6 +26,7 @@
 import java.math.RoundingMode;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.stream.Collectors;
 
 /**
  * @author Lyq
@@ -32,48 +41,56 @@
     @Resource
     private CheckApiUtil checkApiUtil;
 
+    @Autowired
+    private IVideoPointService iVideoPointService;
+    @Autowired
+    private VideoUtil videoUtil;
+    @Autowired
+    IHandheldTerminalService iHandheldTerminalService;
+    @Autowired
+    ILoudspeakerService loudspeakerService;
+    @Autowired
+    ICarSlagcarService iCarSlagcarService;
+
     @ApiOperation(value = "鐩戞祴鏁版嵁")
     @GetMapping("/detection")
     public CommonResult<AIIotVO.DetectionVO> detection(@Validated CockpitVO params) {
         checkApiUtil.cockpit(params);
         AIIotVO.DetectionVO detectionVO = new AIIotVO.DetectionVO();
-        detectionVO.setVideo(121);
-        detectionVO.setIndividual(20);
-        detectionVO.setLampblack(154);
-        detectionVO.setLoudspeaker(30);
-        detectionVO.setSlagCar(33);
+        detectionVO.setVideo(iVideoPointService.count());
+        detectionVO.setIndividual(iHandheldTerminalService.count());
+        detectionVO.setLampblack(154L);
+        /// TODO: 2022/12/13 缂哄皯娌圭儫鏈虹洃鎺ц〃
+        detectionVO.setLoudspeaker(loudspeakerService.count());
+        detectionVO.setSlagCar(iCarSlagcarService.count());
         return CommonResult.success(detectionVO);
     }
 
     @ApiOperation(value = "瀹炴椂瑙嗛鐩戞帶")
     @GetMapping("/video")
-    public CommonResult<List<AIIotVO.VideoVO>> video(@Validated CockpitVO params) {
+    public CommonResult video(@Validated CockpitVO params) {
         checkApiUtil.cockpit(params);
-        List<AIIotVO.VideoVO> videoVOS = new ArrayList<>();
-        AIIotVO.VideoVO a = null;
-        for (int i = 0; i < 4; i++) {
-            a = new AIIotVO.VideoVO();
-            a.setLongitude("32.11");
-            a.setLatitude("106.111");
-            a.setName("璁惧涓�");
-            a.setResourceId("012");
-            a.setBrand("澶у崕");
-            a.setModel("鐞冩満");
-            a.setIp("10.23.14.2");
-            a.setUrl("http://10.23.14.2:12001");
-            videoVOS.add(a);
-        }
-        return CommonResult.success(videoVOS);
+        /// TODO: 2022/12/13  瑙嗛鐐逛綅璁惧涓虹┖ 娌℃暟鎹�
+        return CommonResult.success(iVideoPointService.list(new LambdaQueryWrapper<VideoPoint>().eq(params.getStreetId() != null, VideoPoint::getStreetId, params.getStreetId()).isNotNull(VideoPoint::getPlatResourceId)).stream().map(item -> {
+            VideoVO videoVO = new VideoVO();
+            videoVO.setName(item.getName());
+            videoVO.setBrand(item.getEquipmentBrand());
+            videoVO.setModel(item.getEquipmentModel());
+            videoVO.setIp(item.getEquipmentIp());
+            videoVO.setLatitude(item.getLatitude().toString());
+            videoVO.setLongitude(item.getLongitude().toString());
+            videoVO.setResourceId(item.getPlatResourceId());
+            return videoVO;
+        }).collect(Collectors.toList()));
     }
 
     @ApiOperation(value = "AI绠楁硶鏁堣兘")
     @GetMapping("/efficiency")
-    public CommonResult<List<AIIotVO.EfficiencyVO>> efficiency(@Validated CockpitVO params) {
+    public CommonResult efficiency(@Validated CockpitVO params) {
         checkApiUtil.cockpit(params);
-        List<AIIotVO.EfficiencyVO> efficiencyVOS = new ArrayList<>();
-        AIIotVO.EfficiencyVO a = null;
+        List<EfficiencyVO> efficiencyVOS = new ArrayList<>();
         for (int i = 0; i < 4; i++) {
-            a = new AIIotVO.EfficiencyVO();
+            EfficiencyVO a = new EfficiencyVO();
             a.setType("閬撹矾鐮存崯");
             a.setCount(12);
             a.setRatio(new BigDecimal("0.63").setScale(2, RoundingMode.HALF_UP));

--
Gitblit v1.8.0