新增发送消息接口

pom.xml

@@ -101,7 +101,6 @@
         <dependency>
             <groupId>io.netty</groupId>
             <artifactId>netty-all</artifactId>
-            <version>4.1.105.Final</version>
         </dependency>
 
         <dependency>

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

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