This commit is contained in:
ziming 2025-05-27 16:54:50 +08:00
parent c3901c7f94
commit 993e567eca
1 changed files with 13 additions and 6 deletions

View File

@ -3,6 +3,7 @@ package mq_http
import ( import (
"encoding/json" "encoding/json"
"testing" "testing"
"time"
"voucher/internal/biz/bo" "voucher/internal/biz/bo"
) )
@ -67,14 +68,20 @@ func Test_WechatNotifyProducer2(t *testing.T) {
func Test_WechatNotifyProducer3(t *testing.T) { func Test_WechatNotifyProducer3(t *testing.T) {
tag := "voucher_notify_dev" useTime := time.Now().Format(time.RFC3339)
t.Log(useTime)
bodyStr := `{"id":"8804b1d0-74e8-5975-815d-e567a761a213","create_time":"2025-03-18T09:20:50+08:00","resource_type":"encrypt-resource","event_type":"COUPON.USE","summary":"代金券核销通知","original_type":"coupon","associated_data":"coupon","plain_text":{"stock_creator_mchid":"1652465541","stock_id":"20255099","coupon_id":"97046583699","coupon_name":"招行测试滚动有效期","description":"","status":"USED","create_time":"2025-03-17T19:38:52+08:00","coupon_type":"NORMAL","no_cash":false,"singleitem":false,"consume_information":{"consume_time":"2025-03-18T09:20:50+08:00","consume_mchid":"1532524971","transaction_id":"4200002702202503180978933760"}}}` x, _ := time.Parse(time.RFC3339, useTime)
t.Log(x.Format(time.DateTime))
if err := wechatNotifyProducer(tag, bodyStr); err != nil { //tag := "voucher_notify_dev"
t.Errorf("入队失败 error = %v", err) //
return //bodyStr := `{"id":"8804b1d0-74e8-5975-815d-e567a761a213","create_time":"2025-03-18T09:20:50+08:00","resource_type":"encrypt-resource","event_type":"COUPON.USE","summary":"代金券核销通知","original_type":"coupon","associated_data":"coupon","plain_text":{"stock_creator_mchid":"1652465541","stock_id":"20255099","coupon_id":"97046583699","coupon_name":"招行测试滚动有效期","description":"","status":"USED","create_time":"2025-03-17T19:38:52+08:00","coupon_type":"NORMAL","no_cash":false,"singleitem":false,"consume_information":{"consume_time":"2025-03-18T09:20:50+08:00","consume_mchid":"1532524971","transaction_id":"4200002702202503180978933760"}}}`
} //
//if err := wechatNotifyProducer(tag, bodyStr); err != nil {
// t.Errorf("入队失败 error = %v", err)
// return
//}
} }
func Test_WechatVoucherNotifyData(t *testing.T) { func Test_WechatVoucherNotifyData(t *testing.T) {