预警6

internal/biz/vo/cache.go

@@ -30,7 +30,7 @@ const (
 )
 
 var (
-	WarningBudgetSendIncr CacheKey = "warning_budget_send_incr"
+	WarningBudgetSendIncr CacheKey = "warning_budget_incr"
 )
 
 var CacheKeyMap = map[CacheKey]time.Duration{
@@ -48,7 +48,7 @@ var CacheKeyMap = map[CacheKey]time.Duration{
 	ProductQueryKey:     30 * 86400 * time.Second, // 30天
 	ProductQueryLockKey: 30 * time.Second,
 
-	WarningBudgetSendIncr: 1 * time.Hour,
+	WarningBudgetSendIncr: 2 * time.Hour,
 }
 
 type Cache struct {

internal/biz/warning_budget.go

@@ -30,7 +30,7 @@ func (s *VoucherBiz) WarningBudgetIncr(ctx context.Context, uid string) (int64,
 	}
 
 	// 如果发送次数超过 “指定” 条，清除再来
-	if count > 12 {
+	if count > 24 { // 大约2小时
 		return 0, s.WarningBudgetIncrDel(ctx, v.Key)
 	}
 
@@ -122,7 +122,10 @@ func (v *VoucherBiz) Calculate(ctx context.Context, product *bo.ProductBo, wxRes
 		}
 
 		if w.AllBudget > product.AllBudget {
-
+			cv := vo.WarningBudgetSendIncr.BuildCache([]string{product.BatchNo})
+			if err := v.WarningBudgetIncrDel(ctx, cv.Key); err != nil {
+				return err
+			}
 		}
 	}
 

internal/pkg/sms/sms_test.go

@@ -68,7 +68,7 @@ func TestWarningSend(t *testing.T) {
 		return
 	}
 
-	err = smsService.SendSMS(context.Background(), []string{"18666173766"}, "SMS_489705720", params)
+	err = smsService.SendSMS(context.Background(), []string{"18666173766"}, "SMS_489660721", params)
 	if err != nil {
 		t.Errorf("发送短信失败: %v", err)
 		return