From 25cd6d73b6a760f0d80cb05c62364175fe8d5180 Mon Sep 17 00:00:00 2001 From: chuzhongzai Date: Tue, 20 Aug 2024 17:09:24 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E5=8F=91=E9=80=81=E6=B6=88?= =?UTF-8?q?=E6=81=AF=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pom.xml | 1 - .../lionwebsite/Controller/PersonalController.java | 5 +++++ .../lion/lionwebsite/Service/PersonalServiceImpl.java | 11 ++++++++++- 3 files changed, 15 insertions(+), 2 deletions(-) diff --git a/pom.xml b/pom.xml index 49bc6c9..f0cfafd 100644 --- a/pom.xml +++ b/pom.xml @@ -101,7 +101,6 @@ io.netty netty-all - 4.1.105.Final diff --git a/src/main/java/com/lion/lionwebsite/Controller/PersonalController.java b/src/main/java/com/lion/lionwebsite/Controller/PersonalController.java index 31fe3e3..3976f3f 100644 --- a/src/main/java/com/lion/lionwebsite/Controller/PersonalController.java +++ b/src/main/java/com/lion/lionwebsite/Controller/PersonalController.java @@ -94,4 +94,9 @@ public class PersonalController { public String ip() throws JsonProcessingException { return personalService.getIp(); } + + @PostMapping("/message2me") + public String message2me(String message) { + return personalService.message2me(message); + } } diff --git a/src/main/java/com/lion/lionwebsite/Service/PersonalServiceImpl.java b/src/main/java/com/lion/lionwebsite/Service/PersonalServiceImpl.java index 049587a..c96aa7f 100644 --- a/src/main/java/com/lion/lionwebsite/Service/PersonalServiceImpl.java +++ b/src/main/java/com/lion/lionwebsite/Service/PersonalServiceImpl.java @@ -61,11 +61,14 @@ public class PersonalServiceImpl{ ExecutorService compressThreadPool; - public PersonalServiceImpl(CustomConfigurationMapper configurationMapper, UserMapper userMapper, ShareFileMapper shareFileMapper, TaskHandlerInterceptor taskHandlerInterceptor){ + PushService pushService; + + public PersonalServiceImpl(CustomConfigurationMapper configurationMapper, UserMapper userMapper, ShareFileMapper shareFileMapper, TaskHandlerInterceptor taskHandlerInterceptor, PushService pushService){ this.configurationMapper = configurationMapper; this.userMapper = userMapper; this.shareFileMapper = shareFileMapper; this.taskHandlerInterceptor = taskHandlerInterceptor; + this.pushService = pushService; compressThreadPool = Executors.newFixedThreadPool(1); } @@ -363,4 +366,10 @@ public class PersonalServiceImpl{ return response.toJSONString(); } + + public String message2me(String message){ + Response response = Response.generateResponse(); + pushService.sendToMe(message); + return response.success().toJSONString(); + } }