diff --git a/internal/pkg/mq_http/mq_http_test.go b/internal/pkg/mq_http/mq_http_test.go index 81a903c..47e5758 100644 --- a/internal/pkg/mq_http/mq_http_test.go +++ b/internal/pkg/mq_http/mq_http_test.go @@ -37,7 +37,7 @@ func Test_WechatNotifyProducer(t *testing.T) { func Test_WechatNotifyProducer2(t *testing.T) { - tag := "voucher_notify_dev" + tag := "voucher_notify_pro" bodyStr := `{"id":"5465699d-de6a-5414-a8df-283167b577ca", "create_time":"2025-03-07T15:57:24+08:00", @@ -48,15 +48,15 @@ func Test_WechatNotifyProducer2(t *testing.T) { "associated_data":"coupon", "plain_text":{ "stock_creator_mchid":"1652465541", -"stock_id":"20259610", -"coupon_id":"97225743207", +"stock_id":"20393435", +"coupon_id":"101423873113", "coupon_name":"test", "description":"","status":"USED", "create_time":"2025-03-07T15:49:31+08:00", "coupon_type":"NORMAL", "no_cash":false, "singleitem":false, -"consume_information":{"consume_time":"2025-03-07T15:57:24+08:00","consume_mchid":"1800002761","transaction_id":"4200002544202503077103159055"}}}` +"consume_information":{"consume_time":"2025-05-13T15:57:24+08:00","consume_mchid":"1800002761","transaction_id":"4200002544202503077103159055"}}}` if err := wechatNotifyProducer(tag, bodyStr); err != nil { t.Errorf("入队失败 error = %v", err)