86 lines
2.8 KiB
Go
86 lines
2.8 KiB
Go
package localjx
|
|
|
|
import (
|
|
"crypto/md5"
|
|
"crypto/rand"
|
|
"crypto/rsa"
|
|
"crypto/x509"
|
|
"encoding/json"
|
|
"io/ioutil"
|
|
"time"
|
|
|
|
"git.rosy.net.cn/jx-callback/globals"
|
|
|
|
"git.rosy.net.cn/baseapi/platformapi/tonglianpayapi"
|
|
"git.rosy.net.cn/baseapi/platformapi/wxpayapi"
|
|
"git.rosy.net.cn/baseapi/utils"
|
|
|
|
"git.rosy.net.cn/jx-callback/business/auth2/authprovider/weixin"
|
|
"git.rosy.net.cn/jx-callback/business/jxutils/jxcontext"
|
|
"git.rosy.net.cn/jx-callback/business/model"
|
|
"git.rosy.net.cn/jx-callback/globals/api"
|
|
)
|
|
|
|
func pay4OrderByTL(ctx *jxcontext.Context, order *model.GoodsOrder, vendorPayType string) (orderPay *model.OrderPay, err error) {
|
|
payCreatedAt := time.Now()
|
|
// param := &wxpayapi.CreateOrderParam{
|
|
// OutTradeNo: utils.Int64ToStr(GenPayOrderID(order)),
|
|
// Body: getOrderBrief(order),
|
|
// NotifyURL: globals.TLPayNotifyURL,
|
|
// SpbillCreateIP: ctx.GetRealRemoteIP(),
|
|
// TradeType: vendorPayType2WxpayType(vendorPayType),
|
|
// TotalFee: int(order.ActualPayPrice),
|
|
|
|
// TimeStart: wxpayapi.Time2PayTime(payCreatedAt),
|
|
// // TimeExpire: wxpayapi.Time2PayTime(payCreatedAt.Add(PayWaitingTime)),
|
|
// ProfitSharing: wxpayapi.OptYes,
|
|
// }
|
|
param := &tonglianpayapi.CreateUnitorderOrderParam{
|
|
Trxamt: int(order.ActualPayPrice),
|
|
NotifyUrl: globals.TLPayNotifyURL,
|
|
Reqsn: order.VendorOrderID,
|
|
}
|
|
|
|
if authInfo, err := ctx.GetV2AuthInfo(); err == nil && authInfo.GetAuthType() == weixin.AuthTypeMini {
|
|
param.Acct = authInfo.GetAuthID()
|
|
}
|
|
result, err := api.TLpayAPI.CreateUnitorderOrder(param)
|
|
result2 := &tonglianpayapi.PayInfo{}
|
|
json.Unmarshal([]byte(result.PayInfo), &result2)
|
|
file, err := ioutil.ReadFile("conf/rsa_key.pem")
|
|
prk, err := x509.ParsePKCS1PrivateKey(file)
|
|
paySign, err := rsa.DecryptOAEP(md5.New(), rand.Reader, prk, []byte(result2.PaySign), nil)
|
|
result2.PaySign = string(paySign)
|
|
str, err := json.Marshal(result2)
|
|
result.PayInfo = string(str)
|
|
if err == nil {
|
|
result2 := &wxpayapi.CreateOrderResult{}
|
|
json.Unmarshal([]byte(result.PayInfo), &result2)
|
|
orderPay = &model.OrderPay{
|
|
PayOrderID: param.Reqsn,
|
|
PayType: model.PayTypeTL,
|
|
VendorPayType: vendorPayType,
|
|
|
|
VendorOrderID: order.VendorOrderID,
|
|
VendorID: order.VendorID,
|
|
Status: 0,
|
|
PayCreatedAt: payCreatedAt,
|
|
PrepayID: result2.PrepayID,
|
|
CodeURL: utils.LimitUTF8StringLen(result.PayInfo, 3200),
|
|
TotalFee: int(order.ActualPayPrice),
|
|
}
|
|
}
|
|
return orderPay, err
|
|
}
|
|
|
|
func OnTLPayCallback(msg *wxpayapi.CallbackMsg) (err error) {
|
|
globals.SugarLogger.Debugf("OnTLPayCallback msg:%s", utils.Format4Output(msg, true))
|
|
switch msg.MsgType {
|
|
case wxpayapi.MsgTypePay:
|
|
err = onWxpayFinished(msg.Data.(*wxpayapi.PayResultMsg))
|
|
case wxpayapi.MsgTypeRefund:
|
|
err = onWxpayRefund(msg.Data.(*wxpayapi.RefundResultMsg))
|
|
}
|
|
return err
|
|
}
|