From c50803b4bdec8da65c115161d2e7671f5fdca4de Mon Sep 17 00:00:00 2001 From: "HUOJIN\\92525" <925258474@qq.com> Date: Thu, 22 Aug 2024 15:46:46 +0800 Subject: [PATCH] no message --- .../youchain/basicdata/rest/StockController.java | 7 +++++++ .../youchain/basicdata/service/StockService.java | 2 ++ .../basicdata/service/impl/StockServiceImpl.java | 13 +++++++++++++ 3 files changed, 22 insertions(+) diff --git a/youchain-system/src/main/java/com/youchain/basicdata/rest/StockController.java b/youchain-system/src/main/java/com/youchain/basicdata/rest/StockController.java index e0a1bf2..5bd682f 100644 --- a/youchain-system/src/main/java/com/youchain/basicdata/rest/StockController.java +++ b/youchain-system/src/main/java/com/youchain/basicdata/rest/StockController.java @@ -211,6 +211,13 @@ public class StockController { return new ResponseEntity<>(stockService.getItemCode(stockCode), HttpStatus.OK); } + @PostMapping(value = "/stockMsg") + @AnonymousAccess + public ResponseEntity stockMsg() { + String stockMsg = stockService.stockMsg(); + return new ResponseEntity<>(stockMsg, HttpStatus.OK); + } + private ResponseEntity badRequest(String message) { return new ResponseEntity<>(ApiResult.fail(BAD_REQUEST.value(), message, ""), HttpStatus.BAD_REQUEST); } diff --git a/youchain-system/src/main/java/com/youchain/basicdata/service/StockService.java b/youchain-system/src/main/java/com/youchain/basicdata/service/StockService.java index a6552e8..7389f75 100644 --- a/youchain-system/src/main/java/com/youchain/basicdata/service/StockService.java +++ b/youchain-system/src/main/java/com/youchain/basicdata/service/StockService.java @@ -207,4 +207,6 @@ public interface StockService { */ void callJlTask(Pick pick); + String stockMsg(); + } diff --git a/youchain-system/src/main/java/com/youchain/basicdata/service/impl/StockServiceImpl.java b/youchain-system/src/main/java/com/youchain/basicdata/service/impl/StockServiceImpl.java index 53ce283..554b6e2 100644 --- a/youchain-system/src/main/java/com/youchain/basicdata/service/impl/StockServiceImpl.java +++ b/youchain-system/src/main/java/com/youchain/basicdata/service/impl/StockServiceImpl.java @@ -32,6 +32,9 @@ import com.youchain.businessdata.domain.*; import com.youchain.businessdata.repository.*; import com.youchain.businessdata.service.*; import com.youchain.businessdata.service.dto.TaskDto; +import com.youchain.modules.mnt.websocket.MsgType; +import com.youchain.modules.mnt.websocket.SocketMsg; +import com.youchain.modules.mnt.websocket.WebSocketServer; import com.youchain.utils.*; import lombok.RequiredArgsConstructor; import com.youchain.basicdata.repository.StockRepository; @@ -661,6 +664,16 @@ public class StockServiceImpl implements StockService { pointRepository.save(endPoint); } + @Override + public String stockMsg() { + try { + WebSocketServer.sendInfo(new SocketMsg("容器未解绑,请及时处理!", MsgType.INFO), "stock"); + }catch (Exception e){ + e.printStackTrace(); + } + return "ok"; + } + /** * 验证任务 *