闸阀详情；视频预览

src/main/java/com/gunshi/project/xyt/controller/AttCctvBaseController.java

@@ -3,21 +3,29 @@ package com.gunshi.project.xyt.controller;
 import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
 import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.fasterxml.jackson.databind.ObjectMapper;
 import com.gunshi.core.result.R;
 import com.gunshi.project.xyt.entity.so.AttCctvBasePage;
 import com.gunshi.project.xyt.model.AttCctvBase;
 import com.gunshi.project.xyt.service.AttCctvBaseService;
+import com.gunshi.project.xyt.util.OkHttpUtil;
 import com.gunshi.project.xyt.validate.markers.Insert;
 import com.gunshi.project.xyt.validate.markers.Update;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.media.Schema;
 import io.swagger.v3.oas.annotations.tags.Tag;
+import okhttp3.OkHttpClient;
+import okhttp3.Request;
+import okhttp3.Response;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
 
+import java.io.IOException;
 import java.io.Serializable;
 import java.util.List;
+import java.util.Map;
+
 /**
  * 描述: 视频基本信息表
  * author: xusan
@@ -77,4 +85,22 @@ public class AttCctvBaseController {
         return R.ok(service.page(page.getPageSo().toPage(), query));
     }
 
+    @Operation(summary = "获取预览地址")
+    @GetMapping("/preview/{indexCode}")
+    public R<String> preview(@PathVariable("indexCode") String indexCode) {
+        String api = "http://223.75.53.141:81/isc/liveAddressLimited?cameraIndexCode=%s&protocol=ws&token=111";
+        OkHttpClient client = OkHttpUtil.build();
+        String ret = null;
+        try {
+            Response resp = client.newCall(new Request.Builder().url(String.format(api, indexCode)).build()).execute();
+            String respStr = resp.body().string();
+            ObjectMapper om = new ObjectMapper();
+            Map map = om.readValue(respStr, Map.class);
+            ret = map.get("data").toString();
+        } catch (IOException e) {
+            throw new RuntimeException(e);
+        }
+        return R.ok(ret);
+    }
+
 }

src/main/java/com/gunshi/project/xyt/controller/AttGateValveController.java

@@ -79,4 +79,10 @@ public class AttGateValveController {
         return R.ok(service.page(page.getPageSo().toPage(),query));
     }
 
+    @Operation(summary = "详情")
+    @GetMapping("/detail")
+    public R<AttGateValve> detail(@Schema(name = "valveCode",description = "闸阀编码") @RequestParam("valveCode") String valveCode) {
+        return R.ok(service.getById(valveCode));
+    }
+
 }