From 6e63019ccba5a0e2e56ffe0f589932a00cd0bcba Mon Sep 17 00:00:00 2001
From: zhanghua <314079846@qq.com>
Date: 星期一, 04 十二月 2023 11:25:12 +0800
Subject: [PATCH] 大华接口

---
 ycl-platform/src/main/java/com/ycl/controller/platformApi/TranspondDHController.java |   60 +++++++++++++++++++++++++++---
 ycl-platform/src/main/resources/application-dev.yml                                  |    6 +++
 ycl-platform/src/main/resources/application-prod.yml                                 |    9 ++++
 3 files changed, 68 insertions(+), 7 deletions(-)

diff --git a/ycl-platform/src/main/java/com/ycl/controller/platformApi/TranspondDHController.java b/ycl-platform/src/main/java/com/ycl/controller/platformApi/TranspondDHController.java
index b388b2b..35d099e 100644
--- a/ycl-platform/src/main/java/com/ycl/controller/platformApi/TranspondDHController.java
+++ b/ycl-platform/src/main/java/com/ycl/controller/platformApi/TranspondDHController.java
@@ -4,7 +4,9 @@
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.ycl.annotation.LogSave;
 import com.ycl.api.CommonResult;
+import com.ycl.dto.casePool.ViolationParam;
 import com.ycl.dto.v1.Req.FirstReq;
+import com.ycl.dto.v1.Req.GpsSubscribe;
 import com.ycl.dto.v1.Req.SecondReq;
 import com.ycl.dto.v1.Res.FirstRes;
 import com.ycl.dto.video.AlarmParam;
@@ -25,30 +27,54 @@
 
 @Api(tags = "绗笁鏂规帴鍙�-澶у崕")
 @RestController
-@RequestMapping("/API/videoService/eventCenter/messages")
+@RequestMapping("/API")
 public class TranspondDHController {
 
-    @Value("${videoPoint.web_url}")
+    @Value("${DH.web_url}")
     private String url;
 
-    @Value("${videoPoint.userName}")
+    @Value("${DH.userName}")
     private String userName;
 
-    @Value("${videoPoint.passWord}")
+    @Value("${DH.passWord}")
     private String passWord;
 
     @Value("${videoPoint.ip}")
     private String ip;
 
     @ApiOperation("娑堟伅璁㈤槄")
-    @GetMapping("/subscribeAddress")
+    @GetMapping("/videoService/eventCenter/messages/subscribeAddress")
     public CommonResult subscribeAddress() {
         String url = "/videoService/eventCenter/messages/subscribeAddress";
         return getResult(url, "");
     }
 
+    @ApiOperation("鐢ㄦ埛淇℃伅")
+    @GetMapping("/udu/user/infos")
+    public CommonResult infos() {
+        String url = "/udu/user/infos";
+        return getResult(url, "");
+    }
+
+    @ApiOperation("gps璁㈤槄")
+    @PostMapping("/dsu/gps/subscribe")
+    public CommonResult gps_subscribe(@RequestBody GpsSubscribe subscribe) {
+        String url = "/dsu/gps/subscribe";
+        postResult(url, subscribe);
+        return CommonResult.success("璁㈤槄鎴愬姛");
+    }
+
+    @ApiOperation("gps鐢ㄦ埛璁㈤槄")
+    @PostMapping("/dsu/gps/user/subscribe")
+    public CommonResult gps_user_subscribe(@RequestBody GpsSubscribe subscribe) {
+        String url = "/dsu/gps/user/subscribe";
+        postResult(url, subscribe);
+        return CommonResult.success("璁㈤槄鎴愬姛");
+    }
+
+
     @ApiOperation("闀胯疆璇㈣幏鍙栨秷鎭�")
-    @GetMapping("/subscribe")
+    @GetMapping("/videoService/eventCenter/messages/subscribe")
     public CommonResult subscribe(@RequestParam Integer type,
                                   @RequestParam Integer msgId,
                                   @RequestParam(required = false) Integer msgNum,
@@ -78,6 +104,28 @@
         }
     }
 
+    private void postResult(String reqUrl, GpsSubscribe subscribe) {
+        try {
+            String token = getToken();
+            System.out.println("瀹氫綅鎺ュ彛url:" + url + reqUrl + subscribe.toString());
+            HttpHeaders deviceHeaders = new HttpHeaders();
+            ObjectMapper objectMapper = new ObjectMapper();
+            deviceHeaders.add("X-Subject-Token", token);
+            HttpEntity<Object> deviceEntity = new HttpEntity<>(deviceHeaders);
+            //璇锋眰澶�
+            HttpHeaders httpHeaders = new HttpHeaders();
+            httpHeaders.setContentType(MediaType.APPLICATION_JSON);
+
+            RestTemplate restTemplate = new RestTemplate();
+            HttpEntity<String> secondEntity = new HttpEntity<>(objectMapper.writeValueAsString(subscribe), httpHeaders);
+            ResponseEntity<String> resEntity = restTemplate.postForEntity(url + reqUrl, secondEntity, String.class);
+
+            System.out.println(resEntity.toString());
+        } catch (Exception ex) {
+            System.out.println("瀹氫綅鎺ュ彛閿欒锛�" + ex.getMessage());
+        }
+    }
+
 
     private String getToken() throws JsonProcessingException {
 
diff --git a/ycl-platform/src/main/resources/application-dev.yml b/ycl-platform/src/main/resources/application-dev.yml
index 9469da4..aa51354 100644
--- a/ycl-platform/src/main/resources/application-dev.yml
+++ b/ycl-platform/src/main/resources/application-dev.yml
@@ -74,6 +74,12 @@
   passWord: a12345677
   ip: 10.10.10.10
 
+DH:
+  web_url: http://172.28.194.185:8281
+  port: 8281
+  userName: zfgy
+  passWord: zfj12345
+
 aliyun:
   oss:
     endpoint: https://oss-accelerate.aliyuncs.com
diff --git a/ycl-platform/src/main/resources/application-prod.yml b/ycl-platform/src/main/resources/application-prod.yml
index 550307c..d4060ba 100644
--- a/ycl-platform/src/main/resources/application-prod.yml
+++ b/ycl-platform/src/main/resources/application-prod.yml
@@ -67,12 +67,19 @@
 
 videoPoint:
   url: http://172.28.194.180:7901
-  web_url: http://172.28.194.185:8281
+  web_url: https://172.28.194.185:8282
+#  web_url: http://172.28.194.185:8281
   port: 7901
   userName: suichang
   passWord: a12345677
   ip: 10.10.10.10
 
+DH:
+  web_url: http://172.28.194.185:8281
+  port: 8281
+  userName: zfgy
+  passWord: zfj12345
+
 aliyun:
   oss:
     endpoint: http://oss-cn-zjls-lszwy-d01-a.ops.zjlscloud.com

--
Gitblit v1.8.0