From 4ee8924bd9dbd36046d922d9480de310ee16b6ac Mon Sep 17 00:00:00 2001 From: zx <zuoxue@qq.com> Date: 星期五, 19 八月 2022 21:55:59 +0800 Subject: [PATCH] fix PlatformKeepaliveExpireEvent typo --- src/main/java/com/genersoft/iot/vmp/vmanager/server/ServerController.java | 104 +++++++++++++++++++++++----------------------------- 1 files changed, 46 insertions(+), 58 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/vmanager/server/ServerController.java b/src/main/java/com/genersoft/iot/vmp/vmanager/server/ServerController.java index 2311d4b..95995b8 100644 --- a/src/main/java/com/genersoft/iot/vmp/vmanager/server/ServerController.java +++ b/src/main/java/com/genersoft/iot/vmp/vmanager/server/ServerController.java @@ -15,10 +15,10 @@ import com.genersoft.iot.vmp.utils.SpringBeanFactory; import com.genersoft.iot.vmp.vmanager.bean.WVPResult; import gov.nist.javax.sip.SipStackImpl; -import io.swagger.annotations.Api; -import io.swagger.annotations.ApiImplicitParam; -import io.swagger.annotations.ApiImplicitParams; -import io.swagger.annotations.ApiOperation; + +import io.swagger.v3.oas.annotations.Operation; +import io.swagger.v3.oas.annotations.Parameter; +import io.swagger.v3.oas.annotations.tags.Tag; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.ConfigurableApplicationContext; @@ -33,7 +33,7 @@ import java.util.Set; @SuppressWarnings("rawtypes") -@Api(tags = "鏈嶅姟鎺у埗") +@Tag(name = "鏈嶅姟鎺у埗") @CrossOrigin @RestController @RequestMapping("/api/server") @@ -61,10 +61,10 @@ private int serverPort; - @ApiOperation("娴佸獟浣撴湇鍔″垪琛�") @GetMapping(value = "/media_server/list") @ResponseBody - public WVPResult<List<MediaServerItem>> getMediaServerList(boolean detail){ + @Operation(summary = "娴佸獟浣撴湇鍔″垪琛�") + public WVPResult<List<MediaServerItem>> getMediaServerList() { WVPResult<List<MediaServerItem>> result = new WVPResult<>(); result.setCode(0); result.setMsg("success"); @@ -72,10 +72,10 @@ return result; } - @ApiOperation("鍦ㄧ嚎娴佸獟浣撴湇鍔″垪琛�") @GetMapping(value = "/media_server/online/list") @ResponseBody - public WVPResult<List<MediaServerItem>> getOnlineMediaServerList(){ + @Operation(summary = "鍦ㄧ嚎娴佸獟浣撴湇鍔″垪琛�") + public WVPResult<List<MediaServerItem>> getOnlineMediaServerList() { WVPResult<List<MediaServerItem>> result = new WVPResult<>(); result.setCode(0); result.setMsg("success"); @@ -83,10 +83,11 @@ return result; } - @ApiOperation("鑾峰彇娴佸獟浣撴湇鍔�") @GetMapping(value = "/media_server/one/{id}") @ResponseBody - public WVPResult<MediaServerItem> getMediaServer(@PathVariable String id){ + @Operation(summary = "鍋滄瑙嗛鍥炴斁") + @Parameter(name = "id", description = "娴佸獟浣撴湇鍔D", required = true) + public WVPResult<MediaServerItem> getMediaServer(@PathVariable String id) { WVPResult<MediaServerItem> result = new WVPResult<>(); result.setCode(0); result.setMsg("success"); @@ -94,57 +95,49 @@ return result; } - @ApiOperation("娴嬭瘯娴佸獟浣撴湇鍔�") - @ApiImplicitParams({ - @ApiImplicitParam(name="ip", value = "娴佸獟浣撴湇鍔P", dataTypeClass = String.class), - @ApiImplicitParam(name="port", value = "娴佸獟浣撴湇鍔TT绔彛", dataTypeClass = Integer.class), - @ApiImplicitParam(name="secret", value = "娴佸獟浣撴湇鍔ecret", dataTypeClass = String.class), - }) + @Operation(summary = "娴嬭瘯娴佸獟浣撴湇鍔�") + @Parameter(name = "ip", description = "娴佸獟浣撴湇鍔P", required = true) + @Parameter(name = "port", description = "娴佸獟浣撴湇鍔TT绔彛", required = true) + @Parameter(name = "secret", description = "娴佸獟浣撴湇鍔ecret", required = true) @GetMapping(value = "/media_server/check") @ResponseBody - public WVPResult<MediaServerItem> checkMediaServer(@RequestParam String ip, @RequestParam int port, @RequestParam String secret){ + public WVPResult<MediaServerItem> checkMediaServer(@RequestParam String ip, @RequestParam int port, @RequestParam String secret) { return mediaServerService.checkMediaServer(ip, port, secret); } - @ApiOperation("娴嬭瘯娴佸獟浣撳綍鍍忕鐞嗘湇鍔�") - @ApiImplicitParams({ - @ApiImplicitParam(name="ip", value = "娴佸獟浣撴湇鍔P", dataTypeClass = String.class), - @ApiImplicitParam(name="port", value = "娴佸獟浣撴湇鍔TT绔彛", dataTypeClass = Integer.class), - @ApiImplicitParam(name="secret", value = "娴佸獟浣撴湇鍔ecret", dataTypeClass = String.class), - }) + @Operation(summary = "娴嬭瘯娴佸獟浣撳綍鍍忕鐞嗘湇鍔�") + @Parameter(name = "ip", description = "娴佸獟浣撴湇鍔P", required = true) + @Parameter(name = "port", description = "娴佸獟浣撴湇鍔TT绔彛", required = true) @GetMapping(value = "/media_server/record/check") @ResponseBody - public WVPResult<String> checkMediaRecordServer(@RequestParam String ip, @RequestParam int port){ + public WVPResult<String> checkMediaRecordServer(@RequestParam String ip, @RequestParam int port) { boolean checkResult = mediaServerService.checkMediaRecordServer(ip, port); WVPResult<String> result = new WVPResult<>(); if (checkResult) { result.setCode(0); result.setMsg("success"); - }else { + } else { result.setCode(-1); result.setMsg("杩炴帴澶辫触"); } return result; } - @ApiOperation("淇濆瓨娴佸獟浣撴湇鍔�") - @ApiImplicitParams({ - @ApiImplicitParam(name="mediaServerItem", value = "娴佸獟浣撲俊鎭�", dataTypeClass = MediaServerItem.class) - }) + @Operation(summary = "淇濆瓨娴佸獟浣撴湇鍔�") + @Parameter(name = "mediaServerItem", description = "娴佸獟浣撲俊鎭�", required = true) @PostMapping(value = "/media_server/save") @ResponseBody - public WVPResult<String> saveMediaServer(@RequestBody MediaServerItem mediaServerItem){ + public WVPResult<String> saveMediaServer(@RequestBody MediaServerItem mediaServerItem) { MediaServerItem mediaServerItemInDatabase = mediaServerService.getOne(mediaServerItem.getId()); if (mediaServerItemInDatabase != null) { - if (StringUtils.isEmpty(mediaServerItemInDatabase.getSendRtpPortRange()) - && StringUtils.isEmpty(mediaServerItem.getSendRtpPortRange())){ + if (StringUtils.isEmpty(mediaServerItemInDatabase.getSendRtpPortRange()) && StringUtils.isEmpty(mediaServerItem.getSendRtpPortRange())) { mediaServerItem.setSendRtpPortRange("30000,30500"); } - mediaServerService.update(mediaServerItem); - }else { - if (StringUtils.isEmpty(mediaServerItem.getSendRtpPortRange())){ + mediaServerService.update(mediaServerItem); + } else { + if (StringUtils.isEmpty(mediaServerItem.getSendRtpPortRange())) { mediaServerItem.setSendRtpPortRange("30000,30500"); } return mediaServerService.add(mediaServerItem); @@ -156,17 +149,15 @@ return result; } - @ApiOperation("绉婚櫎娴佸獟浣撴湇鍔�") - @ApiImplicitParams({ - @ApiImplicitParam(name="id", value = "娴佸獟浣揑D", dataTypeClass = String.class) - }) + @Operation(summary = "绉婚櫎娴佸獟浣撴湇鍔�") + @Parameter(name = "id", description = "娴佸獟浣揑D", required = true) @DeleteMapping(value = "/media_server/delete") @ResponseBody - public WVPResult<String> deleteMediaServer(@RequestParam String id){ + public WVPResult<String> deleteMediaServer(@RequestParam String id) { if (mediaServerService.getOne(id) != null) { mediaServerService.delete(id); mediaServerService.deleteDb(id); - }else { + } else { WVPResult<String> result = new WVPResult<>(); result.setCode(-1); result.setMsg("鏈壘鍒版鑺傜偣"); @@ -179,18 +170,17 @@ } - - @ApiOperation("閲嶅惎鏈嶅姟") + @Operation(summary = "閲嶅惎鏈嶅姟") @GetMapping(value = "/restart") @ResponseBody - public Object restart(){ + public Object restart() { Thread restartThread = new Thread(new Runnable() { @Override public void run() { try { Thread.sleep(3000); SipProvider up = (SipProvider) SpringBeanFactory.getBean("udpSipProvider"); - SipStackImpl stack = (SipStackImpl)up.getSipStack(); + SipStackImpl stack = (SipStackImpl) up.getSipStack(); stack.stop(); Iterator listener = stack.getListeningPoints(); while (listener.hasNext()) { @@ -213,10 +203,10 @@ return "success"; } - @ApiOperation("鐗堟湰淇℃伅") + @Operation(summary = "鑾峰彇鐗堟湰淇℃伅") @GetMapping(value = "/version") @ResponseBody - public WVPResult<VersionPo> getVersion(){ + public WVPResult<VersionPo> getVersion() { WVPResult<VersionPo> result = new WVPResult<>(); result.setCode(0); result.setMsg("success"); @@ -224,13 +214,11 @@ return result; } - @ApiOperation("閰嶇疆淇℃伅") @GetMapping(value = "/config") - @ApiImplicitParams({ - @ApiImplicitParam(name="type", value = "閰嶇疆绫诲瀷锛坰ip, base锛�", dataTypeClass = String.class), - }) + @Operation(summary = "鑾峰彇閰嶇疆淇℃伅") + @Parameter(name = "type", description = "閰嶇疆绫诲瀷锛坰ip, base锛�", required = true) @ResponseBody - public WVPResult<JSONObject> getVersion(String type){ + public WVPResult<JSONObject> getVersion(String type) { WVPResult<JSONObject> result = new WVPResult<>(); result.setCode(0); result.setMsg("success"); @@ -240,8 +228,8 @@ if (StringUtils.isEmpty(type)) { jsonObject.put("sip", JSON.toJSON(sipConfig)); jsonObject.put("base", JSON.toJSON(userSetting)); - }else { - switch (type){ + } else { + switch (type) { case "sip": jsonObject.put("sip", sipConfig); break; @@ -256,10 +244,10 @@ return result; } - @ApiOperation("鑾峰彇褰撳墠鎵�鏈塰ook") @GetMapping(value = "/hooks") @ResponseBody - public WVPResult<List<IHookSubscribe>> getHooks(){ + @Operation(summary = "鑾峰彇褰撳墠鎵�鏈塰ook") + public WVPResult<List<IHookSubscribe>> getHooks() { WVPResult<List<IHookSubscribe>> result = new WVPResult<>(); result.setCode(0); result.setMsg("success"); @@ -268,7 +256,7 @@ return result; } -// @ApiOperation("褰撳墠杩涜涓殑鍔ㄦ�佷换鍔�") +// //@ApiOperation("褰撳墠杩涜涓殑鍔ㄦ�佷换鍔�") // @GetMapping(value = "/dynamicTask") // @ResponseBody // public WVPResult<JSONObject> getDynamicTask(){ -- Gitblit v1.8.0