team/qnc-server-tob
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
liangzai 2025-04-26 15:39:44 +08:00
parent 7c0ec23b68
commit e1e76fa57b
2 changed files with 14 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
app/user/cmd/api/internal/queue/cleanQueryData.go
View File

@ -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
}

2
app/user/cmd/api/internal/service/wechatpayService.go
View File

@ -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)