From ab10cb5e784c1cc9b3ada0497f9820854f74a308 Mon Sep 17 00:00:00 2001
From: linhw <5331581+linhw11@user.noreply.gitee.com>
Date: Thu, 4 Jul 2024 11:03:59 +0800
Subject: [PATCH] ~

---
 .../service/impl/AppMessageServiceImpl.java   | 20 ++++++++++++++++++-
 1 file changed, 19 insertions(+), 1 deletion(-)

diff --git a/gan-modules/ruoyi-gan/src/main/java/com/ruoyi/app/service/impl/AppMessageServiceImpl.java b/gan-modules/ruoyi-gan/src/main/java/com/ruoyi/app/service/impl/AppMessageServiceImpl.java
index bdb3d14..6e09347 100644
--- a/gan-modules/ruoyi-gan/src/main/java/com/ruoyi/app/service/impl/AppMessageServiceImpl.java
+++ b/gan-modules/ruoyi-gan/src/main/java/com/ruoyi/app/service/impl/AppMessageServiceImpl.java
@@ -5,6 +5,7 @@ import java.util.List;
 import com.ruoyi.app.domain.AppUser;
 import com.ruoyi.app.mapper.AppUserMapper;
 import com.ruoyi.common.core.utils.DateUtils;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.http.HttpResponse;
 import org.apache.http.client.HttpClient;
 import org.apache.http.client.methods.HttpGet;
@@ -23,6 +24,7 @@ import com.ruoyi.app.service.IAppMessageService;
  * @date 2024-05-29
  */
 @Service
+@Slf4j
 public class AppMessageServiceImpl implements IAppMessageService 
 {
     @Autowired
@@ -65,7 +67,7 @@ public class AppMessageServiceImpl implements IAppMessageService
     public int insertAppMessage(AppMessage appMessage)
     {
         appMessage.setCreateTime(DateUtils.getNowDate());
-        List<AppUser> appUsers = appUserMapper.selectAppUserList(new AppUser());
+        /*List<AppUser> appUsers = appUserMapper.selectAppUserList(new AppUser());
         for (AppUser appUser : appUsers) {
             if (appUser.getPushId() == null) {
                 continue;
@@ -81,6 +83,22 @@ public class AppMessageServiceImpl implements IAppMessageService
             } catch (Exception e) {
                 e.printStackTrace();
             }
+        }*/
+
+        if (appMessage.getType() == 0) {
+            log.info("马上通知啦----------");
+            HttpClient httpClient = HttpClients.createDefault();
+            String url = "https://fc-mp-7a162b82-1b95-423b-bbba-424378aedca1.next.bspapp.com/urlPush/chatId?userId=&title="+ appMessage.getTitle() + "&content=" + appMessage.getContent() + "&payload=%7B%22type%22:%223%22,%22userId%22:%22%22%7D";
+            try {
+                HttpGet request = new HttpGet(url);
+                HttpResponse response = httpClient.execute(request);
+                // Get the response entity as a String
+                String jsonResponse = EntityUtils.toString(response.getEntity());
+                log.info("通知啦----------" + jsonResponse);
+                System.out.println("通知啦----------" + jsonResponse);
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
         }
         return appMessageMapper.insertAppMessage(appMessage);
     }