diff --git a/internal/logic/admin/marketing/createQuotaTaskLogic.go b/internal/logic/admin/marketing/createQuotaTaskLogic.go index 99d9778..606435f 100644 --- a/internal/logic/admin/marketing/createQuotaTaskLogic.go +++ b/internal/logic/admin/marketing/createQuotaTaskLogic.go @@ -43,11 +43,11 @@ func (l *CreateQuotaTaskLogic) CreateQuotaTask(req *types.CreateQuotaTaskRequest } if req.StartTime != 0 { start := time.UnixMilli(req.StartTime) - query = query.Where("`start_time` >= ?", start) + query = query.Where("`start_time` <= ?", start) } if req.EndTime != 0 { end := time.UnixMilli(req.EndTime) - query = query.Where("`expire_time` <= ?", end) + query = query.Where("`expire_time` >= ?", end) } if err := query.Find(&subs).Error; err != nil { diff --git a/internal/logic/admin/marketing/queryQuotaTaskPreCountLogic.go b/internal/logic/admin/marketing/queryQuotaTaskPreCountLogic.go index dde1b8e..21b0cb4 100644 --- a/internal/logic/admin/marketing/queryQuotaTaskPreCountLogic.go +++ b/internal/logic/admin/marketing/queryQuotaTaskPreCountLogic.go @@ -38,11 +38,11 @@ func (l *QueryQuotaTaskPreCountLogic) QueryQuotaTaskPreCount(req *types.QueryQuo } if req.StartTime != 0 { start := time.UnixMilli(req.StartTime) - tx = tx.Where("`start_time` >= ?", start) + tx = tx.Where("`start_time` <= ?", start) } if req.EndTime != 0 { end := time.UnixMilli(req.EndTime) - tx = tx.Where("`expire_time` <= ?", end) + tx = tx.Where("`expire_time` >= ?", end) } if err = tx.Count(&count).Error; err != nil { l.Errorf("[QueryQuotaTaskPreCount] count error: %v", err.Error())