v2.0

app/user/cmd/api/internal/queue/cleanQueryData.go

@@ -27,7 +27,7 @@ func (l *CleanQueryDataHandler) ProcessTask(ctx context.Context, t *asynq.Task)
 	logx.Infof("%s - 开始执行查询数据清理任务", now)
 
 	// 计算3天前的时间
-	threeDaysAgo := time.Now().AddDate(0, 0, -3)
+	threeDaysAgo := time.Now().AddDate(0, 0, -30)
 
 	// 调用QueryModel删除3天前的数据
 	result, err := l.svcCtx.QueryModel.DeleteBefore(ctx, threeDaysAgo)

app/user/cmd/api/internal/queue/paySuccessNotify.go

@@ -52,7 +52,7 @@ func (l *PaySuccessNotifyUserHandler) ProcessTask(ctx context.Context, t *asynq.
 	if err != nil {
 		return fmt.Errorf("找不到相关产品: orderID: %d, productID: %d", payload.OrderID, order.ProductId)
 	}
-	redisKey := fmt.Sprintf("%d:%s", order.UserId, order.OrderNo)
+	redisKey := fmt.Sprintf(types.QueryCacheKey, order.UserId, order.OrderNo)
 	cache, cacheErr := l.svcCtx.Redis.GetCtx(ctx, redisKey)
 	if cacheErr != nil {
 		return fmt.Errorf("获取缓存内容失败: %+v", cacheErr)
@@ -149,7 +149,7 @@ func (l *PaySuccessNotifyUserHandler) ProcessTask(ctx context.Context, t *asynq.
 func (l *PaySuccessNotifyUserHandler) handleError(ctx context.Context, err error, order *model.Order, query *model.Query) error {
 	logx.Errorf("处理任务失败，原因: %v", err)
 
-	redisKey := fmt.Sprintf("%d:%s", order.UserId, order.OrderNo)
+	redisKey := fmt.Sprintf(types.QueryCacheKey, order.UserId, order.OrderNo)
 	_, delErr := l.svcCtx.Redis.DelCtx(ctx, redisKey)
 	if delErr != nil {
 		logx.Errorf("删除Redis缓存失败，订单ID: %d, 错误: %v", order.Id, delErr)

app/user/cmd/api/internal/queue/routes.go

@@ -3,9 +3,10 @@ package queue
 import (
 	"context"
 	"fmt"
-	"github.com/hibiken/asynq"
 	"tydata-server/app/user/cmd/api/internal/svc"
 	"tydata-server/app/user/cmd/api/internal/types"
+
+	"github.com/hibiken/asynq"
 )
 
 type CronJob struct {