|
@@ -35,17 +35,8 @@ func (l *GetMessageRecordsListLogic) GetMessageRecordsList(req *types.MessageRec
|
|
|
if req.BotWxid != nil {
|
|
|
predicates = append(predicates, messagerecords.BotWxidContains(*req.BotWxid))
|
|
|
}
|
|
|
- if req.ContactWxid != nil {
|
|
|
- predicates = append(predicates, messagerecords.ContactWxidContains(*req.ContactWxid))
|
|
|
- }
|
|
|
- if req.Content != nil {
|
|
|
- predicates = append(predicates, messagerecords.ContentContains(*req.Content))
|
|
|
- }
|
|
|
- if req.SourceType != nil {
|
|
|
- predicates = append(predicates, messagerecords.SourceTypeEQ(*req.SourceType))
|
|
|
- }
|
|
|
- if req.SourceId != nil {
|
|
|
- predicates = append(predicates, messagerecords.SourceIDEQ(*req.SourceId))
|
|
|
+ if req.Status != nil {
|
|
|
+ predicates = append(predicates, messagerecords.StatusEQ(*req.Status))
|
|
|
}
|
|
|
data, err := l.svcCtx.DB.MessageRecords.Query().Where(predicates...).Page(l.ctx, req.Page, req.PageSize)
|
|
|
|