@@ -198,7 +198,7 @@ func (l *CreateBatchMsgLogic) CreateBatchMsg(req *types.BatchMsgInfo) (*types.Ba
SetOrganizationID(organizationId),
)
}
- err = l.svcCtx.DB.MessageRecords.CreateBulk(bulkCreate...).Exec(l.ctx)
+ err = tx.MessageRecords.CreateBulk(bulkCreate...).Exec(l.ctx)
if err != nil {
_ = tx.Rollback()
return nil, dberrorhandler.DefaultEntError(l.Logger, err, req)