Skip to content

W
wecloud_im_server
Commit d87c12e7 by 罗长华
Options

Merge remote-tracking branch 'origin/xiaohudou_20220427' into xiaohudou_20220427

parents ced42ebe a615d63d
Showing with 8 additions and 0 deletions
core/src/main/java/com/wecloud/im/action/InboxAction.java
package com.wecloud.im.action; package com.wecloud.im.action;
import com.alibaba.fastjson.JSON;
import io.geekidea.springbootplus.framework.common.api.ApiCode; import io.geekidea.springbootplus.framework.common.api.ApiCode;
import io.swagger.annotations.Api; import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation; import io.swagger.annotations.ApiOperation;
...@@ -40,6 +41,7 @@ public class InboxAction { ...@@ -40,6 +41,7 @@ public class InboxAction {
@ActionMapping("/msgReceivedUpdate") @ActionMapping("/msgReceivedUpdate")
@ApiOperation(value = "消息修改为已接收状态") @ApiOperation(value = "消息修改为已接收状态")
public WsResponse<Map<String, Boolean>> updateImMsgReceived(@Validated ImMsgReceivedStatusUpdate data) throws Exception { public WsResponse<Map<String, Boolean>> updateImMsgReceived(@Validated ImMsgReceivedStatusUpdate data) throws Exception {
log.info("消息修改为已接收状态入参 {}", JSON.toJSONString(data));
imInboxService.updateImMsgReceived(data); imInboxService.updateImMsgReceived(data);
return WsResponse.ok(); return WsResponse.ok();
} }
...@@ -50,6 +52,7 @@ public class InboxAction { ...@@ -50,6 +52,7 @@ public class InboxAction {
@ActionMapping("/msgReadUpdate") @ActionMapping("/msgReadUpdate")
@ApiOperation(value = "消息修改为已读状态") @ApiOperation(value = "消息修改为已读状态")
public WsResponse<Map<String, Boolean>> updateInMsgReadUpdate(MsgReadStatusUpdateParam data) throws Exception { public WsResponse<Map<String, Boolean>> updateInMsgReadUpdate(MsgReadStatusUpdateParam data) throws Exception {
log.info("消息修改为已读状态入参 {}", JSON.toJSONString(data));
if (CollectionUtils.isEmpty(data.getMsgIds())) { if (CollectionUtils.isEmpty(data.getMsgIds())) {
return WsResponse.fail(ApiCode.PARAMETER_EXCEPTION); return WsResponse.fail(ApiCode.PARAMETER_EXCEPTION);
} }
...@@ -64,6 +67,7 @@ public class InboxAction { ...@@ -64,6 +67,7 @@ public class InboxAction {
@ActionMapping("/updateMsgReadStatusByConversation") @ActionMapping("/updateMsgReadStatusByConversation")
@ApiOperation(value = "会话消息修改为已读状态") @ApiOperation(value = "会话消息修改为已读状态")
public WsResponse<Map<String, Boolean>> updateMsgReadStatusByConversation(UpdateMsgReadStatusByConversationParam data) throws Exception { public WsResponse<Map<String, Boolean>> updateMsgReadStatusByConversation(UpdateMsgReadStatusByConversationParam data) throws Exception {
log.info("会话消息修改为已读状态入参 {}", JSON.toJSONString(data));
if (data.getConversationId() == null) { if (data.getConversationId() == null) {
return WsResponse.fail(ApiCode.PARAMETER_EXCEPTION); return WsResponse.fail(ApiCode.PARAMETER_EXCEPTION);
} }
......
core/src/main/java/com/wecloud/im/controller/ImInboxController.java
package com.wecloud.im.controller; package com.wecloud.im.controller;
import com.alibaba.fastjson.JSON;
import com.wecloud.im.param.ImMsgReceivedStatusUpdate; import com.wecloud.im.param.ImMsgReceivedStatusUpdate;
import com.wecloud.im.param.MsgReadStatusUpdateParam; import com.wecloud.im.param.MsgReadStatusUpdateParam;
import com.wecloud.im.param.UpdateMsgReadStatusByConversationParam; import com.wecloud.im.param.UpdateMsgReadStatusByConversationParam;
...@@ -39,6 +40,7 @@ public class ImInboxController extends BaseController { ...@@ -39,6 +40,7 @@ public class ImInboxController extends BaseController {
@PostMapping("/msgReceivedUpdate") @PostMapping("/msgReceivedUpdate")
@ApiOperation(value = "消息修改为已接收状态") @ApiOperation(value = "消息修改为已接收状态")
public ApiResult<Boolean> updateImMsgReceived(@RequestBody @Validated ImMsgReceivedStatusUpdate imMsgReceivedUpdate) throws Exception { public ApiResult<Boolean> updateImMsgReceived(@RequestBody @Validated ImMsgReceivedStatusUpdate imMsgReceivedUpdate) throws Exception {
log.info("消息修改为已接收状态入参 {}", JSON.toJSONString(imMsgReceivedUpdate));
imInboxService.updateImMsgReceived(imMsgReceivedUpdate); imInboxService.updateImMsgReceived(imMsgReceivedUpdate);
return ApiResult.ok(); return ApiResult.ok();
} }
...@@ -49,6 +51,7 @@ public class ImInboxController extends BaseController { ...@@ -49,6 +51,7 @@ public class ImInboxController extends BaseController {
@PostMapping("/msgReadUpdate") @PostMapping("/msgReadUpdate")
@ApiOperation(value = "消息修改为已读状态") @ApiOperation(value = "消息修改为已读状态")
public ApiResult<Boolean> updateInMsgReadUpdate(@RequestBody MsgReadStatusUpdateParam msgReadStatusUpdateParam) throws Exception { public ApiResult<Boolean> updateInMsgReadUpdate(@RequestBody MsgReadStatusUpdateParam msgReadStatusUpdateParam) throws Exception {
log.info("消息修改为已读状态 {}", JSON.toJSONString(msgReadStatusUpdateParam));
if (CollectionUtils.isEmpty(msgReadStatusUpdateParam.getMsgIds())) { if (CollectionUtils.isEmpty(msgReadStatusUpdateParam.getMsgIds())) {
return ApiResult.fail(ApiCode.PARAMETER_EXCEPTION); return ApiResult.fail(ApiCode.PARAMETER_EXCEPTION);
} }
...@@ -62,6 +65,7 @@ public class ImInboxController extends BaseController { ...@@ -62,6 +65,7 @@ public class ImInboxController extends BaseController {
@PostMapping("/updateMsgReadStatusByConversation") @PostMapping("/updateMsgReadStatusByConversation")
@ApiOperation(value = "会话消息修改为已读状态") @ApiOperation(value = "会话消息修改为已读状态")
public ApiResult<Boolean> updateMsgReadStatusByConversation(@RequestBody UpdateMsgReadStatusByConversationParam param) throws Exception { public ApiResult<Boolean> updateMsgReadStatusByConversation(@RequestBody UpdateMsgReadStatusByConversationParam param) throws Exception {
log.info("会话消息修改为已读状态入参 {}", JSON.toJSONString(param));
if (param.getConversationId() == null) { if (param.getConversationId() == null) {
return ApiResult.fail(ApiCode.PARAMETER_EXCEPTION); return ApiResult.fail(ApiCode.PARAMETER_EXCEPTION);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment