package test import ( "context" "encoding/json" "fmt" "github.com/wechatpay-apiv3/wechatpay-go/core" "github.com/wechatpay-apiv3/wechatpay-go/services/cashcoupons" "io" "os" "path/filepath" "time" "voucher/internal/biz/do" "voucher/internal/conf" "voucher/internal/data" ) var bc = &conf.Bootstrap{ Wechat: &conf.Wechat{ MchID: "1710953361", MchCertificateSerialNumber: "6006B8208815DB5EAC5BF2E783CB9D34082C3772", WechatPayPublicKeyID: "PUB_KEY_ID_0117109533612025031800326400002563", Name: "蓝色兄弟-new", }, } // bcFJXW Callback{NotifyUrl:https://nsall.86698.cn/wechatPay/coupon_notify/fjxingwang, Mchid:1652465541} var bcFJXW = &conf.Bootstrap{ Wechat: &conf.Wechat{ MchID: "1652465541", // notifyUrl https://nsall.86698.cn/wechatPay/coupon_notify/fjxingwang MchCertificateSerialNumber: "1E3F2CE013203BA9C3DEFC5782FCD3329C3DAC1C", WechatPayPublicKeyID: "PUB_KEY_ID_0116524655412025070900181741001803", Name: "福建兴旺", }, } // bcFJLF Callback{NotifyUrl:https://gateway.dev.cdlsxd.cn/voucher/v1/notify/1100040695, Mchid:1100040695} // /voucher/v1/notify/1100040695 var bcFJLF = &conf.Bootstrap{ Wechat: &conf.Wechat{ MchID: "1100040695", MchCertificateSerialNumber: "46712853869DB0EDAA9B4DF97DADEECD4CCDC85B", WechatPayPublicKeyID: "PUB_KEY_ID_0111000406952026032500382251001000", Name: "福建峦峰", }, } func SendCoupon() { ctx := context.Background() dir, err := os.Getwd() if err != nil { fmt.Printf("os.Getwd() error = %v", err) return } parentDir := filepath.Dir(dir) server := data.Server{ MchID: bc.Wechat.MchID, MchCertificateSerialNumber: bc.Wechat.MchCertificateSerialNumber, WechatPayPublicKeyID: bc.Wechat.WechatPayPublicKeyID, Dir: parentDir, } client, err := data.GetClient(ctx, server) if err != nil { fmt.Println(err) return } req := cashcoupons.SendCouponRequest{ OutRequestNo: core.String("LQ2011991700944699394"), // {CouponId:129623470711} // 微信为发券方商户分配的公众账号ID，接口传入的所有appid应该为公众号的appid（在mp.weixin.qq.com申请的），不能为APP的appid（在open.weixin.qq.com申请的）。 Appid: core.String("wxd27e255810842ba8"), Openid: core.String("o3dEt5b_1lFtKc-aAT3tiYjJIGwk"), StockId: core.String("21502886"), StockCreatorMchid: core.String("1652465541"), } fmt.Printf("\nreq:%+v", req) svc := cashcoupons.CouponApiService{Client: client} resp, result, err := svc.SendCoupon(ctx, req) if err != nil { fmt.Println(err) return } fmt.Printf("\nresp:%+v\n result:%+v", resp, result) return } func QueryCoupon() { ctx := context.Background() dir, err := os.Getwd() if err != nil { fmt.Printf("os.Getwd() error = %v", err) return } parentDir := filepath.Dir(dir) server := data.Server{ MchID: bc.Wechat.MchID, MchCertificateSerialNumber: bc.Wechat.MchCertificateSerialNumber, WechatPayPublicKeyID: bc.Wechat.WechatPayPublicKeyID, Dir: parentDir, } client, err := data.GetClient(ctx, server) if err != nil { fmt.Println(err) return } appId := "wx619991cc795028f5" openId := "oSNb4fnWoktz7YVNIXE5bvoB3-1w" couponId := "106048490308" req := cashcoupons.QueryCouponRequest{ CouponId: core.String(couponId), Appid: core.String(appId), Openid: core.String(openId), } svc := cashcoupons.CouponApiService{Client: client} resp, result, err := svc.QueryCoupon(ctx, req) if err != nil { fmt.Println(err) return } fmt.Printf("\nresp:%+v\n", resp) bodyBytes, err := io.ReadAll(result.Response.Body) if err != nil { fmt.Println(err) return } fmt.Printf("\nresult:%s\n", bodyBytes) return } func QueryProduct() { ctx := context.Background() dir, err := os.Getwd() if err != nil { fmt.Printf("os.Getwd() error = %v", err) return } parentDir := filepath.Dir(dir) server := data.Server{ MchID: bc.Wechat.MchID, MchCertificateSerialNumber: bc.Wechat.MchCertificateSerialNumber, WechatPayPublicKeyID: bc.Wechat.WechatPayPublicKeyID, Dir: parentDir, } client, err := data.GetClient(ctx, server) if err != nil { fmt.Println(err) return } req := cashcoupons.QueryStockRequest{ StockId: core.String("21923564"), StockCreatorMchid: core.String("1100040695"), } svc := cashcoupons.StockApiService{Client: client} resp, _, err := svc.QueryStock(ctx, req) if err != nil { fmt.Println(err) return } j, _ := json.Marshal(resp) fmt.Printf("\nresp:%s\n", string(j)) availableStock := *resp.StockUseRule.MaxCoupons - *resp.DistributedCoupons couponAmount := *resp.StockUseRule.FixedNormalCoupon.CouponAmount / 100 fmt.Printf("\n批次号:%s", *req.StockId) fmt.Printf("\n面额:%d", couponAmount) fmt.Printf("\n总预算:%d", *resp.StockUseRule.MaxAmount/100) fmt.Printf("\n总库存:%d", *resp.StockUseRule.MaxCoupons) fmt.Printf("\n已发券数:%d", *resp.DistributedCoupons) fmt.Printf("\n已发券金额:%d", *resp.DistributedCoupons*couponAmount) fmt.Printf("\n剩余库存:%d", availableStock) fmt.Printf("\n剩余预算:%d", availableStock*couponAmount) str, _ := json.Marshal(WxResp(resp)) fmt.Printf("\nWxResp:%+v", string(str)) return } func WxResp(wxResp *cashcoupons.Stock) (reps *do.WxResp) { availableStock := *wxResp.StockUseRule.MaxCoupons - *wxResp.DistributedCoupons couponAmount := *wxResp.StockUseRule.FixedNormalCoupon.CouponAmount / 100 remainingBudget := availableStock * couponAmount stockUsageRate := float64(*wxResp.DistributedCoupons) / float64(*wxResp.StockUseRule.MaxCoupons) * 100 req := &do.WxResp{ Amount: couponAmount, AllBudget: *wxResp.StockUseRule.MaxAmount / 100, AllStock: *wxResp.StockUseRule.MaxCoupons, UsedStock: *wxResp.DistributedCoupons, UsedBudget: *wxResp.DistributedCoupons * couponAmount, AvailableStock: availableStock, AvailableBudget: remainingBudget, StockUsageRate: stockUsageRate, } inputFormat := time.RFC3339 if wxResp.AvailableBeginTime != nil { availableBeginTime, _ := time.Parse(inputFormat, *wxResp.AvailableBeginTime) req.StartTime = &availableBeginTime } if wxResp.AvailableEndTime != nil { availableEndTime, _ := time.Parse(inputFormat, *wxResp.AvailableEndTime) req.EndTime = &availableEndTime } return req } func QueryCallback(bc *conf.Bootstrap) { ctx := context.Background() dir, err := os.Getwd() if err != nil { fmt.Printf("os.Getwd() error = %v", err) return } parentDir := filepath.Dir(dir) server := data.Server{ MchID: bc.Wechat.MchID, MchCertificateSerialNumber: bc.Wechat.MchCertificateSerialNumber, WechatPayPublicKeyID: bc.Wechat.WechatPayPublicKeyID, Dir: parentDir, } client, err := data.GetClient(ctx, server) if err != nil { fmt.Println(err) return } svc := cashcoupons.CallBackUrlApiService{Client: client} response, _, err := svc.QueryCallback(ctx, cashcoupons.QueryCallbackRequest{ Mchid: core.String(bc.Wechat.MchID), }) if err != nil { fmt.Println(err) return } fmt.Printf("\nresp:%+v\n", response) return } func SetCallback(bc *conf.Bootstrap) { ctx := context.Background() dir, err := os.Getwd() if err != nil { fmt.Printf("os.Getwd() error = %v", err) return } parentDir := filepath.Dir(dir) server := data.Server{ MchID: bc.Wechat.MchID, MchCertificateSerialNumber: bc.Wechat.MchCertificateSerialNumber, WechatPayPublicKeyID: bc.Wechat.WechatPayPublicKeyID, Dir: parentDir, } client, err := data.GetClient(ctx, server) if err != nil { fmt.Println(err) return } svc := cashcoupons.CallBackUrlApiService{Client: client} response, _, err := svc.SetCallback(ctx, cashcoupons.SetCallbackRequest{ Mchid: core.String(bc.Wechat.MchID), NotifyUrl: core.String("https://gateway.dev.cdlsxd.cn/voucher/v1/notify/" + bc.Wechat.MchID), Switch: core.Bool(true), }) if err != nil { fmt.Println(err) return } fmt.Printf("\nresp:%+v\n", response) return }