wyh
/
gan
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

~

main
linhw 2024-07-04 11:03:59 +08:00
parent 52a429704b
commit ab10cb5e78
1 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
gan-modules/ruoyi-gan/src/main/java/com/ruoyi/app/service/impl/AppMessageServiceImpl.java
View File

@ -5,6 +5,7 @@ import java.util.List;
import com.ruoyi.app.domain.AppUser; import com.ruoyi.app.domain.AppUser;
import com.ruoyi.app.mapper.AppUserMapper; import com.ruoyi.app.mapper.AppUserMapper;
import com.ruoyi.common.core.utils.DateUtils; import com.ruoyi.common.core.utils.DateUtils;
import lombok.extern.slf4j.Slf4j;
import org.apache.http.HttpResponse; import org.apache.http.HttpResponse;
import org.apache.http.client.HttpClient; import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpGet; import org.apache.http.client.methods.HttpGet;
@ -23,6 +24,7 @@ import com.ruoyi.app.service.IAppMessageService;
* @date 2024-05-29 * @date 2024-05-29
*/ */
@Service @Service
@Slf4j
public class AppMessageServiceImpl implements IAppMessageService public class AppMessageServiceImpl implements IAppMessageService
{ {
@Autowired @Autowired
@ -65,7 +67,7 @@ public class AppMessageServiceImpl implements IAppMessageService
public int insertAppMessage(AppMessage appMessage) public int insertAppMessage(AppMessage appMessage)
{ {
appMessage.setCreateTime(DateUtils.getNowDate()); appMessage.setCreateTime(DateUtils.getNowDate());
List<AppUser> appUsers = appUserMapper.selectAppUserList(new AppUser()); /*List<AppUser> appUsers = appUserMapper.selectAppUserList(new AppUser());
for (AppUser appUser : appUsers) { for (AppUser appUser : appUsers) {
if (appUser.getPushId() == null) { if (appUser.getPushId() == null) {
continue; continue;
@ -81,6 +83,22 @@ public class AppMessageServiceImpl implements IAppMessageService
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); 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); return appMessageMapper.insertAppMessage(appMessage);
} }