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