other_project/mallplus
7
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

消息通知

Browse Source
This commit is contained in:
lzh
2023-03-18 00:12:16 +08:00
parent cd96921473
commit 3ef558939b
1 changed files with 33 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
mallplus-admin/src/main/java/com/zscat/mallplus/unipush/UniPushService.java
View File

@@ -12,6 +12,8 @@ import com.getui.push.v2.sdk.dto.req.message.PushMessage;
import com.getui.push.v2.sdk.dto.req.message.android.GTNotification; import com.getui.push.v2.sdk.dto.req.message.android.GTNotification;
import com.getui.push.v2.sdk.dto.res.TaskIdDTO; import com.getui.push.v2.sdk.dto.res.TaskIdDTO;
import com.zscat.mallplus.ums.entity.SysMessage; import com.zscat.mallplus.ums.entity.SysMessage;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
@@ -22,6 +24,8 @@ import java.util.Map;
@Component @Component
public class UniPushService { public class UniPushService {
private static final Logger L = LoggerFactory.getLogger(UniPushService.class);
// @Value("${unipush.appid:UBUIDJ8NQm50rGJsB6LYx1}") // @Value("${unipush.appid:UBUIDJ8NQm50rGJsB6LYx1}")
// private String appid; // private String appid;
@@ -206,15 +210,39 @@ public class UniPushService {
private static String imgUrlwl = "http://mall.yyundong.com/wl.png"; private static String imgUrlwl = "http://mall.yyundong.com/wl.png";
public void sendPush(SysMessage mess, List<String> cids) { public void sendPush(SysMessage mess, List<String> cids) {
String code = mess.getCode(); // String code = mess.getCode();
if ("系统消息".equals(code)) { // if ("系统消息".equals(code)) {
sendTzMsg(mess); // sendTzMsg(mess);
} else { // } else {
sendUserMsg(mess, cids); // sendUserMsg(mess, cids);
// }
if (cids == null || cids.isEmpty())
return;
PushMessage pushMessage = createPushMessage(mess);
int size = cids.size();
for (int i = 0; i < size; i++) {
sendSingleMsg(pushMessage, cids.get(i), i);
} }
} }
private void sendSingleMsg(PushMessage pushMessage, String cid, int index) {
PushDTO<Audience> pushDTO = new PushDTO<Audience>();
pushDTO.setRequestId("" + System.currentTimeMillis() + index);
pushDTO.setPushMessage(pushMessage);
Audience audience = new Audience();
audience.addCid(cid);
pushDTO.setAudience(audience);
ApiResult<Map<String, Map<String, String>>> apiResult = pushApi.pushToSingleByCid(pushDTO);
if (apiResult.isSuccess()) {
System.out.println(apiResult.getData());
} else {
L.warn("推送信息失败：code:{}, msg: {}", apiResult.getCode(), apiResult.getMsg());
}
}
private void sendUserMsg(SysMessage mess, List<String> cids) { private void sendUserMsg(SysMessage mess, List<String> cids) {
if (cids == null || cids.isEmpty()) if (cids == null || cids.isEmpty())