query

2025-06-10 09:39:05 +08:00 · 2025-06-10 09:39:05 +08:00 · 5ce7dfbb88
parent 7ee72814bd
commit 5ce7dfbb88
1 changed files with 1 additions and 0 deletions
--- a/internal/biz/wechat_query.go
+++ b/internal/biz/wechat_query.go
@ -38,6 +38,7 @@ func (v *VoucherBiz) PushWechatQuery(ctx http.Context, req *do.WechatQuery) erro

 	_, err = v.rdb.Rdb.RPush(ctx, queue.Name, msg).Result()
 	if err != nil {
+		v.Remove("CMB_WECHAT_QUERY")
 		return fmt.Errorf("添加到队列失败:%v", err)
 	}