From e1e76fa57b9711f7a9a81effaeeb61911f326381 Mon Sep 17 00:00:00 2001
From: liangzai <2440983361@qq.com>
Date: Sat, 26 Apr 2025 15:39:44 +0800
Subject: [PATCH] fix

---
 .../cmd/api/internal/queue/cleanQueryData.go  | 24 ++++++++++---------
 .../api/internal/service/wechatpayService.go  |  2 +-
 2 files changed, 14 insertions(+), 12 deletions(-)

diff --git a/app/user/cmd/api/internal/queue/cleanQueryData.go b/app/user/cmd/api/internal/queue/cleanQueryData.go
index e4d1333..a572a00 100644
--- a/app/user/cmd/api/internal/queue/cleanQueryData.go
+++ b/app/user/cmd/api/internal/queue/cleanQueryData.go
@@ -3,8 +3,10 @@ package queue
 import (
 	"context"
 	"qnc-server/app/user/cmd/api/internal/svc"
+	"time"
 
 	"github.com/hibiken/asynq"
+	"github.com/zeromicro/go-zero/core/logx"
 )
 
 // TASKTIME 定义为每天凌晨3点执行
@@ -21,19 +23,19 @@ func NewCleanQueryDataHandler(svcCtx *svc.ServiceContext) *CleanQueryDataHandler
 }
 
 func (l *CleanQueryDataHandler) ProcessTask(ctx context.Context, t *asynq.Task) error {
-	// now := time.Now().Format("2006-01-02 15:04:05")
-	// logx.Infof("%s - 开始执行查询数据清理任务", now)
+	now := time.Now().Format("2006-01-02 15:04:05")
+	logx.Infof("%s - 开始执行查询数据清理任务", now)
 
-	// // 计算3天前的时间
-	// threeDaysAgo := time.Now().AddDate(0, 0, -3)
+	// 计算3天前的时间
+	threeDaysAgo := time.Now().AddDate(0, 0, -30)
 
-	// // 调用QueryModel删除3天前的数据
-	// result, err := l.svcCtx.QueryModel.DeleteBefore(ctx, threeDaysAgo)
-	// if err != nil {
-	// 	logx.Errorf("%s - 清理查询数据失败: %v", time.Now().Format("2006-01-02 15:04:05"), err)
-	// 	return err
-	// }
+	// 调用QueryModel删除3天前的数据
+	result, err := l.svcCtx.QueryModel.DeleteBefore(ctx, threeDaysAgo)
+	if err != nil {
+		logx.Errorf("%s - 清理查询数据失败: %v", time.Now().Format("2006-01-02 15:04:05"), err)
+		return err
+	}
 
-	// logx.Infof("%s - 查询数据清理完成，共删除 %d 条记录", time.Now().Format("2006-01-02 15:04:05"), result)
+	logx.Infof("%s - 查询数据清理完成，共删除 %d 条记录", time.Now().Format("2006-01-02 15:04:05"), result)
 	return nil
 }
diff --git a/app/user/cmd/api/internal/service/wechatpayService.go b/app/user/cmd/api/internal/service/wechatpayService.go
index 20a6128..76aa07f 100644
--- a/app/user/cmd/api/internal/service/wechatpayService.go
+++ b/app/user/cmd/api/internal/service/wechatpayService.go
@@ -163,7 +163,7 @@ func (w *WechatPayService) CreateWechatOrder(ctx context.Context, amount float64
 		}
 	case "h5-weixin":
 		userID, getUidErr := ctxdata.GetUidFromCtx(ctx)
-		if getUidErr != nil || userID != 2743 {
+		if getUidErr != nil {
 			return "", getUidErr
 		}
 		userAuthModel, findAuthModelErr := w.userAuthModel.FindOneByUserIdAuthType(ctx, userID, model.UserAuthTypeWxh5)