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(); + } }