uni-push多人推送

guoshilong

2023-10-11 721a3a12cd1d77c79f9d0f28862a0acedbfcd1b0

uni-push多人推送

 skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/push/controller/PushController.java

@@ -37,6 +37,19 @@
    }

    /**
     * 通过用户id推送消息，用于2.0测试（多人）
     * @param pushVO
     * @return
     */
    @PostMapping("/pushMessageByUserList")
    public R pushMessageByUserList(PushVO pushVO){
        return R.data(pushService.pushMessageByUserList(pushVO));
    }




    /**
     * 清空redis中的缓存
     * @param userId
     * @return

 skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/push/service/IPushService.java

@@ -56,4 +56,6 @@
     * @return
     */
    Boolean geTuiPushMessage(PushVO pushVO);

    Boolean pushMessageByUserList(PushVO pushVO);
}

 skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/push/service/impl/PushServiceImpl.java

@@ -46,26 +46,28 @@

        //uni-push 一次推送最多500名用户，所以分批推送
        List<List<String>> groupList = groupListByQuantity(cIdList, 400);
        groupList.forEach(item->{
        Boolean push = false;
        for(List<String> cids :groupList){
            PushVO pushVO = new PushVO();

            pushVO.setCIds(cIdList);
            pushVO.setCIds(cids);
            pushVO.setTitle(messageRecordList.get(0).getTheme());
            pushVO.setContent(messageRecordList.get(0).getContent());

            HashMap<String,Object> payload = new HashMap<>();
            payload.put("title",messageRecordList.get(0).getTheme());
            payload.put("content",messageRecordList.get(0).getContent());
            payload.put("payload","test");
            HashMap<String, Object> payload = new HashMap<>();
            payload.put("title", messageRecordList.get(0).getTheme());
            payload.put("content", messageRecordList.get(0).getContent());
            payload.put("payload", "test");
            pushVO.setPayload(payload);
             pushMessage(pushVO);
            push = pushMessage(pushVO);
        }

        });
        return true;
        return push;
    }

    /**
     * 新增测试信息
     *
     * @param messageRecordList
     */
    private void addSendMsgTest(List<MessageRecord> messageRecordList) {
@@ -120,10 +122,10 @@
        cIdList.add(clientIdByUserId);
        pushVO.setCIds(cIdList);

        HashMap<String,Object> payload = new HashMap<>();
        payload.put("title",pushVO.getTitle());
        payload.put("content",pushVO.getContent());
        payload.put("payload","test");
        HashMap<String, Object> payload = new HashMap<>();
        payload.put("title", pushVO.getTitle());
        payload.put("content", pushVO.getContent());
        payload.put("payload", "test");
        pushVO.setPayload(payload);


@@ -136,6 +138,32 @@
        cIdList.add(getClientIdByUserId(pushVO.getUserId()));
//        return geTuiUtils.pushMsg(cIdList, pushVO.getTitle(), pushVO.getContent());
        return geTuiUtils.myPushMessage(cIdList, pushVO.getTitle(), pushVO.getContent());
    }

    @Override
    public Boolean pushMessageByUserList(PushVO pushVO) {

        if (Func.isEmpty(pushVO.getUserId())) {
            throw new ServiceException("请填写用户id!");
        }

        //获取userIdList
        List<String> userIdList = Arrays.asList(pushVO.getUserId().split(","));
        List<MessageRecord> messageRecordList = new ArrayList<>();

        userIdList.forEach(userId->{
            MessageRecord messageRecord = new MessageRecord();

            messageRecord.setContent(pushVO.getContent());
            messageRecord.setTheme(pushVO.getTitle());
            messageRecord.setRecipient(userId);

            messageRecordList.add(messageRecord);
        });

        Boolean aBoolean = pushMessageList(messageRecordList);

        return aBoolean;
    }

    /**
@@ -169,7 +197,7 @@

        params.put("requestId", UUID.randomUUID());

        params.put("payload",pushVO.getPayload());
        params.put("payload", pushVO.getPayload());
        UniCloudReturnRes uniCloudReturnRes = template.postForObject(UNI_CLOUD_PUSH_URL, params, UniCloudReturnRes.class);
        return uniCloudReturnRes.getErrCode().equals("0") ? true : false;

@@ -177,12 +205,13 @@

    /**
     * 对集合按指定数量进行分组
     * @param list 分组的集合
     *
     * @param list     分组的集合
     * @param quantity 数量
     * @param <T>
     * @return
     */
    public  <T> List<List<T>> groupListByQuantity(List list, int quantity) {
    public <T> List<List<T>> groupListByQuantity(List list, int quantity) {
        if (list == null || list.size() == 0) {
            return list;
        }

 skjcmanager/skjcmanager-service/skjcmanager-alerts/src/main/java/cn/gistack/alerts/push/vo/PushVO.java

@@ -17,4 +17,5 @@
    private String userId;

    private HashMap<String,Object> payload;

}