|
|
@ -116,7 +116,7 @@ public class MessageClient extends BladeController implements IMessageClient{ |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
@Override |
|
|
|
@PostMapping(SEND_APP_AND_WS_MSG) |
|
|
|
@PostMapping(value = SEND_APP_AND_WS_MSG , produces="application/json; charset=UTF-8") |
|
|
|
public R<Boolean> sendAppAndWsMsgByUsers(@RequestBody BusinessMessageDTO request) { |
|
|
|
public R<Boolean> sendAppAndWsMsgByUsers(@RequestBody BusinessMessageDTO request) { |
|
|
|
// 保存消息记录
|
|
|
|
// 保存消息记录
|
|
|
|
List<MessagePushRecordEntity> pushRecords = Func.toLongList(request.getUserIds()).stream().flatMap(userId -> { |
|
|
|
List<MessagePushRecordEntity> pushRecords = Func.toLongList(request.getUserIds()).stream().flatMap(userId -> { |
|
|
|