From 44d216100b45c3337c593ee82ee68e7e0f35d24b Mon Sep 17 00:00:00 2001
From: Lawrence <1934378145@qq.com>
Date: 星期三, 16 十二月 2020 20:29:19 +0800
Subject: [PATCH] 与master分支同步

---
 src/main/java/com/genersoft/iot/vmp/vmanager/platform/PlatformController.java |   65 ++++++++++++++++++++++++++++++--
 1 files changed, 61 insertions(+), 4 deletions(-)

diff --git a/src/main/java/com/genersoft/iot/vmp/vmanager/platform/PlatformController.java b/src/main/java/com/genersoft/iot/vmp/vmanager/platform/PlatformController.java
index 9f35dd8..8af7cbf 100644
--- a/src/main/java/com/genersoft/iot/vmp/vmanager/platform/PlatformController.java
+++ b/src/main/java/com/genersoft/iot/vmp/vmanager/platform/PlatformController.java
@@ -3,6 +3,8 @@
 import com.genersoft.iot.vmp.common.PageResult;
 import com.genersoft.iot.vmp.gb28181.bean.Device;
 import com.genersoft.iot.vmp.gb28181.bean.ParentPlatform;
+import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommanderForPlatform;
+import com.genersoft.iot.vmp.gb28181.transmit.cmd.impl.SIPCommander;
 import com.genersoft.iot.vmp.storager.IVideoManagerStorager;
 import com.genersoft.iot.vmp.vmanager.device.DeviceController;
 import org.slf4j.Logger;
@@ -11,6 +13,7 @@
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Controller;
+import org.springframework.util.StringUtils;
 import org.springframework.web.bind.annotation.*;
 
 @CrossOrigin
@@ -23,8 +26,11 @@
     @Autowired
     private IVideoManagerStorager storager;
 
-    @GetMapping("/platforms")
-    public PageResult<ParentPlatform> platforms(int page, int count){
+    @Autowired
+    private ISIPCommanderForPlatform commanderForPlatform;
+
+    @GetMapping("/platforms/{count}/{page}")
+    public PageResult<ParentPlatform> platforms(@PathVariable int page, @PathVariable int count){
 
         if (logger.isDebugEnabled()) {
             logger.debug("鏌ヨ鎵�鏈変笂绾ц澶嘇PI璋冪敤");
@@ -32,17 +38,68 @@
         return storager.queryParentPlatformList(page, count);
     }
 
-    @PostMapping("/platforms/add")
-    public ResponseEntity<String> addPlatform(ParentPlatform parentPlatform){
+    @RequestMapping("/platforms/save")
+    @ResponseBody
+    public ResponseEntity<String> savePlatform(@RequestBody ParentPlatform parentPlatform){
 
         if (logger.isDebugEnabled()) {
             logger.debug("鏌ヨ鎵�鏈変笂绾ц澶嘇PI璋冪敤");
         }
+        if (StringUtils.isEmpty(parentPlatform.getName())
+                ||StringUtils.isEmpty(parentPlatform.getServerGBId())
+                ||StringUtils.isEmpty(parentPlatform.getServerGBDomain())
+                ||StringUtils.isEmpty(parentPlatform.getServerIP())
+                ||StringUtils.isEmpty(parentPlatform.getServerPort())
+                ||StringUtils.isEmpty(parentPlatform.getDeviceGBId())
+                ||StringUtils.isEmpty(parentPlatform.getExpires())
+                ||StringUtils.isEmpty(parentPlatform.getKeepTimeout())
+                ||StringUtils.isEmpty(parentPlatform.getTransport())
+                ||StringUtils.isEmpty(parentPlatform.getCharacterSet())
+        ){
+            return new ResponseEntity<>("missing parameters", HttpStatus.BAD_REQUEST);
+        }
+        // TODO 妫�鏌ユ槸鍚﹀凡缁忓瓨鍦�,涓旀敞鍐屾垚鍔�, 濡傛灉娉ㄥ唽鎴愬姛,闇�瑕佸厛娉ㄩ攢涔嬪墠鍐�,淇敼骞舵敞鍐�
+
         boolean updateResult = storager.updateParentPlatform(parentPlatform);
+
         if (updateResult) {
+            commanderForPlatform.register(parentPlatform, null, null, null, null);
+
             return new ResponseEntity<>("success", HttpStatus.OK);
         }else {
             return new ResponseEntity<>("fail", HttpStatus.OK);
         }
     }
+
+    @RequestMapping("/platforms/delete")
+    @ResponseBody
+    public ResponseEntity<String> deletePlatform(@RequestBody ParentPlatform parentPlatform){
+
+        if (logger.isDebugEnabled()) {
+            logger.debug("鏌ヨ鎵�鏈変笂绾ц澶嘇PI璋冪敤");
+        }
+        if (StringUtils.isEmpty(parentPlatform.getDeviceGBId())
+        ){
+            return new ResponseEntity<>("missing parameters", HttpStatus.BAD_REQUEST);
+        }
+        boolean deleteResult = storager.deleteParentPlatform(parentPlatform);
+        if (deleteResult) {
+            return new ResponseEntity<>("success", HttpStatus.OK);
+        }else {
+            return new ResponseEntity<>("fail", HttpStatus.OK);
+        }
+    }
+
+    @RequestMapping("/platforms/exit/{deviceGbId}")
+    @ResponseBody
+    public ResponseEntity<String> exitPlatform(@PathVariable String deviceGbId){
+
+        if (logger.isDebugEnabled()) {
+            logger.debug("鏌ヨ鎵�鏈変笂绾ц澶嘇PI璋冪敤");
+        }
+        ParentPlatform parentPlatform = storager.queryParentPlatById(deviceGbId);
+        return new ResponseEntity<>(String.valueOf(parentPlatform != null), HttpStatus.OK);
+    }
+
+
 }

--
Gitblit v1.8.0