|
@@ -31,7 +31,11 @@ func NewGetMessageRecordsListLogic(ctx context.Context, svcCtx *svc.ServiceConte
|
|
func (l *GetMessageRecordsListLogic) GetMessageRecordsList(req *types.MessageRecordsListReq) (*types.MessageRecordsListResp, error) {
|
|
func (l *GetMessageRecordsListLogic) GetMessageRecordsList(req *types.MessageRecordsListReq) (*types.MessageRecordsListResp, error) {
|
|
organizationId := l.ctx.Value("organizationId").(uint64)
|
|
organizationId := l.ctx.Value("organizationId").(uint64)
|
|
var predicates []predicate.MessageRecords
|
|
var predicates []predicate.MessageRecords
|
|
|
|
+ // 按机构ID搜
|
|
predicates = append(predicates, messagerecords.OrganizationIDEQ(organizationId))
|
|
predicates = append(predicates, messagerecords.OrganizationIDEQ(organizationId))
|
|
|
|
+ // 按群发ID搜
|
|
|
|
+ predicates = append(predicates, messagerecords.SourceIDEQ(*req.BatchMsgId))
|
|
|
|
+
|
|
if req.BotWxid != nil {
|
|
if req.BotWxid != nil {
|
|
predicates = append(predicates, messagerecords.BotWxidContains(*req.BotWxid))
|
|
predicates = append(predicates, messagerecords.BotWxidContains(*req.BotWxid))
|
|
}
|
|
}
|