BaseSystem
/
plugins
12
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

test

This commit is contained in:
李子铭 2024-10-31 16:25:45 +08:00
parent 9131c0b7a6
commit 41071798b9
8 changed files with 39 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cmd/main.go
View File

@ -3,7 +3,7 @@ package main
// main 这只是一个演示
func main() {
//alipayOrderRedPack()
wechatRedPackOrder()
wechatOrderCpn()
//wechatRedPackQuery()
//alipayNotifyRedPack()
}

27
cmd/wechat_cpn.go
View File

@ -27,7 +27,32 @@ func getWechatCpnConf() []byte {
return marshal
}
func wechatCpn() {
func wechatOrderCpn() {
err := manage.Add(wechatCpnConf)
if err != nil {
log.Fatalln(err)
}
defer manage.Close()
request := &proto.OrderRequest{
Config: getWechatCpnConf(),
Order: &proto.OrderRequest_Order{
OrderNo: "240403164049635931",
Account: "oO3vO5AxRWgTjmMD38FTvnB5Rq6o",
Extra: []byte(`{"app_id":"13100720242","stock_creator_mchid":"1605446142"}`),
},
Product: &proto.OrderRequest_Product{
ProductNo: "3102024032977191_11",
Extra: []byte(`{}`),
},
}
res, err := instance.Order(context.Background(), alpayRedConf.Tag, request)
if err != nil {
log.Fatalln(err)
}
log.Printf("Order res:%+v", res)
}
func wechatQueryCpn() {
err := manage.Add(wechatCpnConf)
if err != nil {
log.Fatalln(err)

8
plugins/alipay_cpn/internal/alipay_cpn.go
View File

@ -47,11 +47,13 @@ func (s *AlipayCpnService) Order(ctx context.Context, request *proto.OrderReques
var sp string
err = requests.URL(baseUri).Post().BodyForm(uv).ToString(&sp).Fetch(ctx)
if err != nil {
return nil, fmt.Errorf("请求异常，msg:" + err.Error())
}
var response *po.OrderResp
sp = helper.ToChinese(sp)
if err = json.Unmarshal([]byte(sp), &response); err != nil {
return nil, fmt.Errorf("请求异常，msg:" + err.Error())
return nil, fmt.Errorf("请求解析异常，msg:" + err.Error())
}
return orderResp(request, response), nil
@ -84,7 +86,7 @@ func (s *AlipayCpnService) Query(ctx context.Context, request *proto.QueryReques
var response po.QueryResp
sp = helper.ToChinese(sp)
if err = json.Unmarshal([]byte(sp), &response); err != nil {
return nil, fmt.Errorf("请求异常，msg:" + err.Error())
return nil, fmt.Errorf("请求解析异常，msg:" + err.Error())
}
return queryResp(request, response), nil

2
plugins/alipay_cpn/internal/alipay_test.go
View File

@ -38,7 +38,7 @@ func TestOrder(t *testing.T) {
Extra: []byte(`{"logon_id":"13100720242"}`),
},
Product: &proto.OrderRequest_Product{
ProductNo: "3102024032977191",
ProductNo: "3102024032977191_11",
Extra: []byte(`{}`),
},
}

6
plugins/alipay_cpn/internal/po/order.go
View File

@ -1,7 +1,6 @@
package po
import (
"fmt"
"gitea.cdlsxd.cn/sdk/plugin/proto"
"plugins/alipay_cpn/internal/vo"
)
@ -38,10 +37,7 @@ func (o *OrderResp) GetMsg() string {
if o.Response.Code.IsSuccess() {
return o.Response.Msg
}
return fmt.Sprintf(
"code:[%s],msg:[%s],subCode:[%s],subMsg[%s]",
o.Response.Code, o.Response.Msg, o.Response.SubCode, o.Response.SubMsg,
)
return o.Response.SubMsg
}
func (o *OrderResp) GetOrderStatus() proto.Status {

4
plugins/alipay_redpack/internal/alipay_redpack.go
View File

@ -53,7 +53,7 @@ func (s *AlipayRedPackService) Order(ctx context.Context, request *proto.OrderRe
var response *po.OrderResp
sp = helper.ToChinese(sp)
if err = json.Unmarshal([]byte(sp), &response); err != nil {
return nil, fmt.Errorf("请求异常，msg:" + err.Error())
return nil, fmt.Errorf("请求解析异常，msg:" + err.Error())
}
return orderResp(request, response), nil
@ -86,7 +86,7 @@ func (s *AlipayRedPackService) Query(ctx context.Context, request *proto.QueryRe
var response po.QueryResp
sp = helper.ToChinese(sp)
if err = json.Unmarshal([]byte(sp), &response); err != nil {
return nil, fmt.Errorf("请求异常，msg:" + err.Error())
return nil, fmt.Errorf("请求解析异常，msg:" + err.Error())
}
return queryResp(request, response), nil

3
plugins/wechat_cpn/internal/transform.go
View File

@ -27,8 +27,7 @@ func orderReq(order *proto.OrderRequest_Order, product *proto.OrderRequest_Produ
}
var extra Extra
if order.Extra != nil {
err := json.Unmarshal(order.Extra, &extra)
if err != nil {
if err := json.Unmarshal(order.Extra, &extra); err != nil {
return cashcoupons.SendCouponRequest{}, fmt.Errorf("order拓展参数 json unmarshal error: %v", err)
}
}

4
plugins/wechat_cpn/internal/wechat_cpn_test.go
View File

@ -35,10 +35,10 @@ func TestOrder(t *testing.T) {
Order: &proto.OrderRequest_Order{
OrderNo: "240403164049635931",
Account: "oO3vO5AxRWgTjmMD38FTvnB5Rq6o",
Extra: []byte(`{"app_id":"13100720242","stock_creator_mchid":"1605446142"`),
Extra: []byte(`{"app_id":"13100720242","stock_creator_mchid":"1605446142"}`),
},
Product: &proto.OrderRequest_Product{
ProductNo: "3102024032977191",
ProductNo: "3102024032977191_11",
Extra: []byte(`{}`),
},
}