| | |
|---|
| | | |
|---|
| | | //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()); |
|---|
| | | |
|---|
| | |
|---|
| | | 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) { |
|---|
| | |
|---|
| | | 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; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 根据用户id从redis中获取cid |
|---|
| | | * |
|---|
| | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 对集合按指定数量进行分组 |
|---|
| | | * |
|---|
| | | * @param list 分组的集合 |
|---|
| | | * @param quantity 数量 |
|---|
| | | * @param <T> |
|---|
