wangli/msg-center-plat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add-unread-statistics api

Browse Source
This commit is contained in:
金海洋 2023-08-18 14:43:12 +08:00
parent 0dc96891c4
commit e17e57b687
4 changed files with 52 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
inside-notices/src/main/java/cn/axzo/msg/center/inside/notices/service/MessageRecordService.java
View File

@ -64,4 +64,6 @@ public interface MessageRecordService {
IPage<MessageRecordRes> querySent(QueryMessageRecordReq request);
Integer unReadStatistics(MessageStatisticsReq request);
}

11
inside-notices/src/main/java/cn/axzo/msg/center/inside/notices/service/impl/InsideMessageRecordApiImpl.java
View File

@ -2,12 +2,16 @@ package cn.axzo.msg.center.inside.notices.service.impl;
import cn.axzo.core.domain.PageResult;
import cn.axzo.msg.center.api.InsideMessageRecordApi;
import cn.axzo.msg.center.api.enums.MsgTypeEnum;
import cn.axzo.msg.center.api.request.*;
import cn.axzo.msg.center.api.response.MessageNewRes;
import cn.axzo.msg.center.api.response.MessageRecordRes;
import cn.axzo.msg.center.common.exception.ServiceException;
import cn.axzo.msg.center.common.utils.BeanConvertUtils;
import cn.axzo.msg.center.dal.MessageRecordDao;
import cn.axzo.msg.center.dal.MessageRouterDao;
import cn.axzo.msg.center.domain.dto.UpdateReadDTO;
import cn.axzo.msg.center.domain.entity.MessageRecord;
import cn.axzo.msg.center.inside.notices.service.MessageRecordService;
import cn.azxo.framework.common.model.CommonResponse;
import com.baomidou.mybatisplus.core.metadata.IPage;
@ -16,6 +20,7 @@ import org.springframework.beans.BeanUtils;
import org.springframework.web.bind.annotation.RestController;
import javax.annotation.Resource;
import java.util.Objects;
@Slf4j
@RestController
@ -24,6 +29,9 @@ public class InsideMessageRecordApiImpl implements InsideMessageRecordApi {
@Resource
private MessageRecordService messageRecordService;
@Resource
private MessageRecordDao messageRecordDao;
@Override
public CommonResponse<PageResult<MessageNewRes>> listMsgInfo4Trade(CmsMsgListReq req) {
CmsMsgQueryReq request=new CmsMsgQueryReq();
@ -63,8 +71,7 @@ public class InsideMessageRecordApiImpl implements InsideMessageRecordApi {
@Override
public CommonResponse<Integer> unReadStatistics(MessageStatisticsReq request) {
return null;
return CommonResponse.success(messageRecordService.unReadStatistics(request));
}

11
inside-notices/src/main/java/cn/axzo/msg/center/inside/notices/service/impl/MessageRecordServiceImpl.java
View File

@ -579,4 +579,15 @@ public class MessageRecordServiceImpl implements MessageRecordService {
public IPage<MessageRecordRes> querySent(QueryMessageRecordReq request) {
return messageRecordDao.querySent(request);
}
@Override
public Integer unReadStatistics(MessageStatisticsReq request) {
return messageRecordDao.lambdaQuery()
.eq(Objects.nonNull(request.getFromId()), MessageRecord::getFromId, request.getFromId())
.eq(Objects.nonNull(request.getModuleId()), MessageRecord::getModuleId, request.getFromId())
.eq(Objects.nonNull(request.getMsgType()), MessageRecord::getType, MsgTypeEnum.valueOf(request.getMsgType()))
.eq(Objects.nonNull(request.getToId()), MessageRecord::getToId, request.getToId())
.eq(Objects.nonNull(request.getTenantId()), MessageRecord::getTenantId, request.getTenantId()
).count();
}
}

30
integration-test/src/test/resources/message.http
View File

@ -28,3 +28,33 @@ Content-Type: application/json
> reponse-check.js
###
POST {{host}}/msg/record/unread/statistics
Accept: application/json
Content-Type: application/json
{
"msgType": 1
}
> reponse-check.js
###
POST {{host}}/webApi/wx/message/list
Accept: application/json
Content-Type: application/json
{
"msgType": 1,
"personId": 1,
"msgRouteType": 1,
"page": 1,
"pageSize": 10
}
> reponse-check.js