TdCPushMsgDao.java
2.11 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
package com.zteits.pay.dao;
import java.util.List;
import com.github.pagehelper.PageInfo;
import com.zteits.clouds.api.dto.owner.param.QueryMessageRequest;
import com.zteits.clouds.api.dto.pay.JPushMessageDTO;
import com.zteits.clouds.api.dto.pay.JPushMsgQueryRequest;
import com.zteits.clouds.api.dto.pay.NewMessagePushDTO;
import com.zteits.clouds.api.dto.pay.param.JPushMessageRequest;
import com.zteits.pay.domain.JPushMessageDO;
import com.zteits.pay.domain.TdCPushMsg;
public interface TdCPushMsgDao {
/**
* 消息中心首页，查询各消息类型的最新一条
* @param request
* @return
*/
public List<JPushMessageDO> getLatestPushedMessages(JPushMessageRequest request);
/**
* 消息中心-消息详情，查询某一消息的详情
* @param request
* @return
*/
public List<JPushMessageDO> getPushedMessageDetails(JPushMessageRequest request);
/**
* 分页查询
* @param request
* @return
* 2018年5月15日 zhaowg
*/
public PageInfo<JPushMessageDO> getPushedMessageDetailsForPage(JPushMessageRequest request);
/**
* 消息中心-删除消息，删除某一指定类型消息的详情
* @param request
*/
void deletePushedMessageDetails(JPushMessageRequest request);
int insertSelective(TdCPushMsg record);
/**
* 根据消息类型和外部编号判断消息是否已经存在
* @param msgType
* @param outMsgNo
* @return
*/
Boolean isExistsByOutMsgNo(Integer msgType,String outMsgNo);
PageInfo<TdCPushMsg> queryPageJPushMsgByCondition(JPushMsgQueryRequest request);
/**
* 根据用户id和消息类型查询推送消息
* @param req
* @return
*/
PageInfo<TdCPushMsg> selectMessageByMessageType(QueryMessageRequest req);
/**
* 查询未读消息条数
* @param req
* @return
*/
NewMessagePushDTO countUnreadMessage(QueryMessageRequest req);
/**
* 新版消息中心-更新消息未读状态
* @param messageRequest
* @return
*/
int updateUnreadMessage(QueryMessageRequest messageRequest);
/**
* 查询未读消息总数
* @param messageRequest
* @return
*/
Long countUnreadTotal(QueryMessageRequest messageRequest);
}