diff --git a/src/main/java/com/gunshi/project/xyt/controller/AttCctvBaseController.java b/src/main/java/com/gunshi/project/xyt/controller/AttCctvBaseController.java index c148e41..d50b8a8 100644 --- a/src/main/java/com/gunshi/project/xyt/controller/AttCctvBaseController.java +++ b/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 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); + } + } \ No newline at end of file diff --git a/src/main/java/com/gunshi/project/xyt/controller/AttGateValveController.java b/src/main/java/com/gunshi/project/xyt/controller/AttGateValveController.java index 820cb3e..8a6a891 100644 --- a/src/main/java/com/gunshi/project/xyt/controller/AttGateValveController.java +++ b/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 detail(@Schema(name = "valveCode",description = "闸阀编码") @RequestParam("valveCode") String valveCode) { + return R.ok(service.getById(valveCode)); + } + } \ No newline at end of file