增加发送模板消息跳转小程序

common.go

@@ -0,0 +1,51 @@
+package wechat
+
+import (
+	"crypto/md5"
+	"encoding/hex"
+	"net"
+	"strings"
+)
+
+// 密码加密
+func Md5Str(str ...string) string {
+
+	var build strings.Builder
+	if len(str) > 0 {
+		for _, v := range str {
+			build.WriteString(v)
+		}
+	} else {
+		return ""
+	}
+
+	h := md5.New()
+	h.Write([]byte(build.String())) // 需要加密的字符串
+	cipher2Str := h.Sum(nil)
+	sMd5 := hex.EncodeToString(cipher2Str) // 输出加密结果
+	return sMd5
+}
+
+/**
+ * 取本地IP
+ */
+func GetLocalIp() string {
+
+	addrs, err := net.InterfaceAddrs()
+
+	if err != nil {
+		return ""
+	}
+
+	for _, address := range addrs {
+
+		// 检查ip地址判断是否回环地址
+		if ipnet, ok := address.(*net.IPNet); ok && !ipnet.IP.IsLoopback() {
+			if ipnet.IP.To4() != nil && !ipnet.IP.IsLinkLocalUnicast() {
+				return ipnet.IP.String()
+			}
+		}
+	}
+
+	return ""
+}

http.go

@@ -24,8 +24,6 @@ func SendHttp(method, url string, param map[string]string, header ...map[string]
 		paramStr = paramStr[0 : len(paramStr)-1]
 	}
 
-	log.Println("param",strings.NewReader(paramStr))
-
 	req, err := http.NewRequest(method, url, strings.NewReader(paramStr))
 	if err != nil {
 		return []byte(""), err
@@ -100,6 +98,7 @@ func SendXml(method, url string, requestxml interface{}, header ...map[string]st
  */
 func PostJson(url string, param []byte, header ...map[string]string) ([]byte, error) {
 	httpClient := &http.Client{}
+	log.Println("param_code", bytes.NewBuffer(param))
 
 	req, err := http.NewRequest("POST", url, bytes.NewBuffer(param))
 	if err != nil {

micropay.go

@@ -0,0 +1,334 @@
+package wechat
+
+import (
+	"encoding/xml"
+	"errors"
+	"fmt"
+	"log"
+	"reflect"
+	"strings"
+
+	"git.tetele.net/tgo/helper"
+)
+
+// 请求支付
+type PayXml struct {
+	XMLName        xml.Name `xml:"xml"`
+	Appid          string   `xml:"appid"`
+	MchId          string   `xml:"mch_id"`
+	DeviceInfo     string   `xml:"device_info"`
+	NonceStr       string   `xml:"nonce_str"`
+	Sign           string   `xml:"sign"`
+	Body           string   `xml:"body"`
+	OutTradeNo     string   `xml:"out_trade_no"`
+	TotalFee       int      `xml:"total_fee"`
+	SpbillCreateIp string   `xml:"spbill_create_ip"`
+	AuthCode       string   `xml:"auth_code"`
+}
+
+// 支付结果
+type PayReturnXml struct {
+	ReturnCode         string `xml:"return_code"`
+	ReturnMsg          string `xml:"return_msg"`
+	Appid              string `xml:"appid"`
+	MchId              string `xml:"mch_id"`
+	DeviceInfo         string `xml:"device_info"`
+	NonceStr           string `xml:"nonce_str"`
+	Sign               string `xml:"sign"`
+	ResultCode         string `xml:"result_code"`
+	ErrCode            string `xml:"err_code"`
+	ErrCodeDes         string `xml:"err_code_des"`
+	Openid             string `xml:"openid"`
+	IsSubscribe        string `xml:"is_subscribe"`
+	TradeType          string `xml:"trade_type"`
+	BankType           string `xml:"bank_type"`
+	FeeType            string `xml:"fee_type"`
+	TotalFee           string `xml:"total_fee"`
+	SettlementTotalFee string `xml:"settlement_total_fee"`
+	CouponFee          string `xml:"coupon_fee"`
+	CashFeeType        string `xml:"cash_fee_type"`
+	CashFee            string `xml:"cash_fee"`
+	TransactionId      string `xml:"transaction_id"`
+	OutTradeNo         string `xml:"out_trade_no"`
+	Attach             string `xml:"attach"`
+	TimeEnd            string `xml:"time_end"`
+	PromotionDetail    string `xml:"promotion_detail"`
+}
+
+// 查询支付
+type QueryXml struct {
+	XMLName    xml.Name `xml:"xml"`
+	Appid      string   `xml:"appid"`
+	MchId      string   `xml:"mch_id"`
+	OutTradeNo string   `xml:"out_trade_no"`
+	NonceStr   string   `xml:"nonce_str"`
+	Sign       string   `xml:"sign"`
+}
+
+// 查询结果
+type QueryReturnXml struct {
+	ReturnCode         string `xml:"return_code"`
+	ReturnMsg          string `xml:"return_msg"`
+	Appid              string `xml:"appid"`
+	MchId              string `xml:"mch_id"`
+	NonceStr           string `xml:"nonce_str"`
+	Sign               string `xml:"sign"`
+	ResultCode         string `xml:"result_code"`
+	ErrCode            string `xml:"err_code"`
+	ErrCodeDes         string `xml:"err_code_des"`
+	DeviceInfo         string `xml:"device_info"`
+	Openid             string `xml:"openid"`
+	IsSubscribe        string `xml:"is_subscribe"`
+	TradeType          string `xml:"trade_type"`
+	TradeState         string `xml:"trade_state"`
+	BankType           string `xml:"bank_type"`
+	TotalFee           string `xml:"total_fee"`
+	SettlementTotalFee string `xml:"settlement_total_fee"`
+	FeeType            string `xml:"fee_type"`
+	CashFee            string `xml:"cash_fee"`
+	CashFeeType        string `xml:"cash_fee_type"`
+	CouponFee          string `xml:"coupon_fee"`
+	CouponCount        string `xml:"coupon_count"`
+	TransactionId      string `xml:"transaction_id"`
+	OutTradeNo         string `xml:"out_trade_no"`
+	Attach             string `xml:"attach"`
+	TimeEnd            string `xml:"time_end"`
+	TradeStateDesc     string `xml:"trade_state_desc"`
+}
+
+// 撤消
+type ReverseXml struct {
+	XMLName    xml.Name `xml:"xml"`
+	Appid      string   `xml:"appid"`
+	MchId      string   `xml:"mch_id"`
+	OutTradeNo string   `xml:"out_trade_no"`
+	NonceStr   string   `xml:"nonce_str"`
+	Sign       string   `xml:"sign"`
+}
+
+// 撤消结果
+type ReverseReturnXml struct {
+	ReturnCode string `xml:"return_code"`
+	ReturnMsg  string `xml:"return_msg"`
+	Appid      string `xml:"appid"`
+	MchId      string `xml:"mch_id"`
+	NonceStr   string `xml:"nonce_str"`
+	Sign       string `xml:"sign"`
+	ResultCode string `xml:"result_code"`
+	ErrCode    string `xml:"err_code"`
+	ErrCodeDes string `xml:"err_code_des"`
+	Recall     string `xml:"recall"`
+}
+
+/**
+ * 微信二维码支付
+ * 2022/02/07
+ * @param device_info 设备号
+ * @param body 商品描述
+ * @param out_trade_no 商户订单号
+ * @param total_fee 订单金额
+ * @param auth_code 付款码
+ */
+
+func MicroPay(appid, mchid, mch_key, device_info, body, out_trade_no, auth_code, total_fee string) (PayReturnXml, error) {
+
+	log.Println("wechat micropay")
+
+	var requestxml PayXml
+
+	var retXml PayReturnXml
+
+	requestxml.Appid = appid
+	requestxml.MchId = mchid
+	requestxml.DeviceInfo = device_info
+	requestxml.NonceStr = helper.GetRandomString(30)
+	requestxml.Body = body
+	requestxml.OutTradeNo = out_trade_no
+	requestxml.TotalFee = helper.ToInt(helper.FloatMul(total_fee, 100))
+	requestxml.SpbillCreateIp = GetLocalIp()
+	requestxml.AuthCode = auth_code
+
+	signStr := helper.StringJoin("appid=", requestxml.Appid, "&auth_code=", requestxml.AuthCode,
+		"&body=", requestxml.Body, "&device_info=", requestxml.DeviceInfo,
+		"&mch_id=", requestxml.MchId, "&nonce_str=", requestxml.NonceStr,
+		"&out_trade_no=", requestxml.OutTradeNo, "&spbill_create_ip=", requestxml.SpbillCreateIp,
+		"&total_fee=", helper.ToString(requestxml.TotalFee), "&key=", mch_key)
+
+	signMd5 := Md5Str(signStr)
+
+	requestxml.Sign = strings.ToUpper(signMd5)
+
+	reqXmlJson, err := xml.Marshal(requestxml)
+
+	log.Println(requestxml, string(reqXmlJson), err)
+
+	url := "https://api.mch.weixin.qq.com/pay/micropay"
+	ret, err := SendXml("POST", url, requestxml)
+
+	log.Println("wechat micropay pay result:", string(ret), err)
+
+	if err != nil {
+		log.Println("Err:", err)
+		return retXml, errors.New("微信支付失败，请检查网络")
+	}
+
+	err = xml.Unmarshal(ret, &retXml)
+	if err != nil {
+		log.Println("xml Unmarshal Err:", retXml, err)
+		return retXml, errors.New("未知的支付结果")
+	}
+
+	if retXml.ResultCode == "SUCCESS" {
+
+		retMap := XmlStructToMap(retXml)
+
+		//验证sign
+		signStr = helper.HttpBuildQuery(retMap) + "&key=" + mch_key
+
+		sign := strings.ToUpper(Md5Str(signStr))
+
+		if sign != retXml.Sign {
+			log.Println("Err:签名错误", string(ret), sign)
+			return retXml, errors.New("支付结果签名错误")
+		}
+	} else {
+		return retXml, errors.New(retXml.ReturnMsg)
+	}
+
+	return retXml, nil
+}
+
+func MicroPayQuery(appid, mchid, out_trade_no, mch_key string) (QueryReturnXml, error) {
+
+	log.Println("wechat micropay query", out_trade_no)
+
+	var requestxml QueryXml
+
+	var retXml QueryReturnXml
+
+	requestxml.Appid = appid
+	requestxml.MchId = mchid
+	requestxml.NonceStr = helper.GetRandomString(30)
+	requestxml.OutTradeNo = out_trade_no
+
+	signStr := helper.StringJoin("appid=", requestxml.Appid,
+		"&mch_id=", requestxml.MchId, "&nonce_str=", requestxml.NonceStr,
+		"&out_trade_no=", requestxml.OutTradeNo, "&key=", mch_key)
+
+	signMd5 := Md5Str(signStr)
+
+	requestxml.Sign = strings.ToUpper(signMd5)
+
+	url := "https://api.mch.weixin.qq.com/pay/orderquery"
+	ret, err := SendXml("POST", url, requestxml)
+
+	if err != nil {
+		log.Println("Err:", err)
+		return retXml, errors.New("微信支付失败，请检查网络")
+	}
+
+	err = xml.Unmarshal(ret, &retXml)
+	if err != nil {
+		log.Println("xml Unmarshal Err:", retXml, err)
+		return retXml, errors.New("未知的支付结果")
+	}
+
+	if retXml.ReturnCode == "SUCCESS" {
+
+		retMap := XmlStructToMap(retXml)
+
+		//验证sign
+		signStr = helper.HttpBuildQuery(retMap) + "&key=" + mch_key
+
+		sign := strings.ToUpper(Md5Str(signStr))
+
+		if sign != retXml.Sign {
+			log.Println("Err:签名错误", string(ret), sign)
+			return retXml, errors.New("查询支付结果签名错误")
+		}
+	} else {
+		return retXml, errors.New(retXml.ReturnMsg)
+	}
+	return retXml, nil
+}
+
+/**
+ * 撤消订单
+ * 2023/06/13
+ */
+func MicroPayReverse(appid, mchid, out_trade_no, mch_key string) (ReverseReturnXml, error) {
+
+	log.Println("wechat micropay reverse", out_trade_no)
+
+	var requestxml ReverseXml
+
+	var retXml ReverseReturnXml
+
+	requestxml.Appid = appid
+	requestxml.MchId = mchid
+	requestxml.NonceStr = helper.GetRandomString(30)
+	requestxml.OutTradeNo = out_trade_no
+
+	signStr := helper.StringJoin("appid=", requestxml.Appid,
+		"&mch_id=", requestxml.MchId, "&nonce_str=", requestxml.NonceStr,
+		"&out_trade_no=", requestxml.OutTradeNo, "&key=", mch_key)
+
+	signMd5 := Md5Str(signStr)
+
+	requestxml.Sign = strings.ToUpper(signMd5)
+
+	url := "https://api.mch.weixin.qq.com/secapi/pay/reverse"
+	ret, err := SendXml("POST", url, requestxml)
+
+	if err != nil {
+		log.Println("Err:", err)
+		return retXml, errors.New("撤消微信支付失败，请检查网络")
+	}
+
+	err = xml.Unmarshal(ret, &retXml)
+	if err != nil {
+		log.Println("xml Unmarshal Err:", retXml, err)
+		return retXml, errors.New("未知的撤消结果")
+	}
+
+	if retXml.ReturnCode == "SUCCESS" {
+
+		retMap := XmlStructToMap(retXml)
+
+		//验证sign
+		signStr = helper.HttpBuildQuery(retMap) + "&key=" + mch_key
+
+		sign := strings.ToUpper(Md5Str(signStr))
+
+		if sign != retXml.Sign {
+			log.Println("Err:签名错误", string(ret), sign)
+			return retXml, errors.New("查询支付结果签名错误")
+		}
+
+	} else {
+		return retXml, errors.New(retXml.ReturnMsg)
+	}
+	return retXml, nil
+}
+
+func XmlStructToMap(retXml interface{}) map[string]string {
+
+	t := reflect.TypeOf(retXml)
+	v := reflect.ValueOf(retXml)
+
+	//转为map，验签
+	retMap := make(map[string]string)
+	var retValue string
+	var tag string
+	for k := 0; k < t.NumField(); k++ {
+		if t.Field(k).Name != "Sign" {
+			retValue = helper.ToString(v.Field(k).Interface())
+			tag = fmt.Sprintf("%s", t.Field(k).Tag)
+			tag = strings.ReplaceAll(tag, "xml:", "")
+			tag = strings.ReplaceAll(tag, "\"", "")
+			retMap[tag] = retValue
+		}
+	}
+
+	return retMap
+}

mp.go

@@ -0,0 +1,109 @@
+package wechat
+
+import (
+	"errors"
+	"fmt"
+)
+
+type wx_template_msg_res struct {
+	Errcode int    `json:"errcode"`
+	Errmsg  string `json:"errmsg"`
+	msgid   int    `json:"msgid"`
+}
+
+func SendTemplateMessage(access_token string, touser, template_id, url string, data map[string]interface{}, client_msg_id, miniapp_appid, miniapp_pagepath string) (wx_template_msg_res, error) {
+
+	var res wx_template_msg_res
+
+	if touser == "" {
+		return res, errors.New("缺少用户openid")
+	}
+	if template_id == "" {
+		return res, errors.New("缺少消息模板")
+	}
+	if access_token == "" {
+		return res, errors.New("缺少access token")
+	}
+	api_url := fmt.Sprintf(MP_TEMPLATE_MESSAGE_API, access_token)
+
+	msg := map[string]interface{}{
+		"touser":      touser,
+		"template_id": template_id,
+		"url":         url,
+		"data":        data,
+	}
+
+	if client_msg_id != "" {
+		msg["client_msg_id"] = client_msg_id
+	}
+
+	if miniapp_appid != "" {
+		msg["miniprogram"] = map[string]string{
+			"appid":    miniapp_appid,
+			"pagepath": miniapp_pagepath,
+		}
+	}
+
+	msg_json, err := json.Marshal(msg)
+
+	if err != nil {
+		return res, err
+	}
+
+	data_byte, err := PostJson(api_url, msg_json)
+
+	if err == nil {
+		err = json.Unmarshal(data_byte, &res)
+	}
+
+	return res, err
+}
+func SendTemplateMessageApplet(access_token string, touser, template_id string, miniprogram map[string]string, data map[string]interface{}, client_msg_id, miniapp_appid, miniapp_pagepath string) (wx_template_msg_res, error) {
+
+	var res wx_template_msg_res
+
+	if touser == "" {
+		return res, errors.New("缺少用户openid")
+	}
+	if template_id == "" {
+		return res, errors.New("缺少消息模板")
+	}
+	if access_token == "" {
+		return res, errors.New("缺少access token")
+	}
+	api_url := fmt.Sprintf(MP_TEMPLATE_MESSAGE_API, access_token)
+
+	msg := map[string]interface{}{
+		"touser":      touser,
+		"template_id": template_id,
+		"data":        data,
+	}
+
+	if len(miniprogram) > 0 {
+		msg["miniprogram"] = miniprogram
+	}
+	if client_msg_id != "" {
+		msg["client_msg_id"] = client_msg_id
+	}
+
+	if miniapp_appid != "" {
+		msg["miniprogram"] = map[string]string{
+			"appid":    miniapp_appid,
+			"pagepath": miniapp_pagepath,
+		}
+	}
+
+	msg_json, err := json.Marshal(msg)
+
+	if err != nil {
+		return res, err
+	}
+
+	data_byte, err := PostJson(api_url, msg_json)
+
+	if err == nil {
+		err = json.Unmarshal(data_byte, &res)
+	}
+
+	return res, err
+}

mp_test.go

@@ -0,0 +1,46 @@
+package wechat
+
+import (
+	"testing"
+)
+
+func Test_SendTemplateMessage(t *testing.T) {
+	// appid := "wxedaca3ab498ec6c0"
+	// appsecret := "6c7e567181dba2fe23692339d19ee16a"
+
+	touser := "o4AH1jm_rnjDV4-4nsFhGhk4wIEQ"
+	template_id := "avBk4QTEoA17c4G72XHet9gpGQtonW0ck2ewQWSsUwU"
+	url := "https://shopv2.tetele.net"
+	data := map[string]interface{}{
+		"first": map[string]interface{}{
+			"value": "已预约成功",
+		},
+		"keyword1": map[string]interface{}{
+			"value": "巧克力",
+		},
+		"keyword2": map[string]interface{}{
+			"value": "2014年9月22日",
+		},
+		"remark": map[string]interface{}{
+			"value": "请点击详情",
+		},
+	}
+	client_msg_id := ""
+	miniapp_appid := ""
+	miniapp_pagepath := ""
+
+	// mpAT, err := GetAccessToken(appid, appsecret)
+	// t.Log("access token:", mpAT)
+	// if err==nil{
+	// 	access_token = mpAT..AccessToken
+	// }
+	// if err != nil {
+	// 	t.Error("access token error:", err)
+	// }
+
+	access_token := "71_sgGezbuBtu94tgRuhzSJHiDvgoOI2mS5kpYyeaynnvILmpPPHEclUmhKq74fj0M3HRjZk7hcNfB54tAJvNZPOrZleXQX2dyWZm_8tyu5m1YpAb8qLrwRnUNRdowMJXhAIAVSG"
+
+	ret, err := SendTemplateMessage(access_token, touser, template_id, url, data, client_msg_id, miniapp_appid, miniapp_pagepath)
+	t.Log(ret)
+	t.Log(err)
+}

qrcode.go

@@ -1,6 +1,7 @@
 package wechat
 
 import (
+	"bytes"
 	"encoding/base64"
 	"errors"
 	"fmt"
@@ -49,13 +50,21 @@ func GetMiniappQrcode(access_token string, qrcodeParamsMap map[string]interface{
 		"auto_color":  autoColor,
 		"is_hyaline":  isHyaline,
 	}
-	requestDataJson, err := json.Marshal(requestData)
+	// json.marshal 会转义&字符
+	/*requestDataJson, err := json.Marshal(requestData)
 
 	if err != nil {
 		return "", err
-	}
+	}*/
+
+	bf := bytes.NewBuffer([]byte{})
+	jsonEncoder := json.NewEncoder(bf)
+	jsonEncoder.SetEscapeHTML(false)
+	jsonEncoder.Encode(requestData)
+
+	response, err := PostJson(getCodeUrl, bf.Bytes())
 
-	response, err := PostJson(getCodeUrl, requestDataJson)
+	log.Println("get mp qrcode response:", string(response), err)
 
 	if err != nil {
 		return "", err

url.go

@@ -6,28 +6,31 @@ import (
 
 var json = jsoniter.ConfigCompatibleWithStandardLibrary
 
-//获取access token
+// 获取access token
 const ACCESS_TOKEN_API string = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s"
 
-//小程序发送统一服务消息
+// 小程序发送统一服务消息
 const MINIAPP_UNIFORM_MESSAGE_API string = "https://api.weixin.qq.com/cgi-bin/message/wxopen/template/uniform_send?access_token=%s"
 
-//小程序获取openid
+// 小程序获取openid
 const GET_MINIAPP_OPENID_API string = "https://api.weixin.qq.com/sns/jscode2session?appid=%s&secret=%s&js_code=%s&grant_type=authorization_code"
 
-//公众号获取openid
+// 公众号获取openid
 const GET_MP_OPENID_API string = "https://api.weixin.qq.com/sns/oauth2/access_token?appid=%s&secret=%s&code=%s&grant_type=authorization_code"
 
-//小程序发送订阅消息
+// 小程序发送订阅消息
 const MINIAPP_SUBSCRIBE_MESSAGE_SEND_API string = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=%s"
 
-//app获取openid
+// app获取openid
 const GET_APP_OPENID string = "https://api.weixin.qq.com/sns/oauth2/access_token?appid=%s&secret=%s&code=%s&grant_type=authorization_code"
 
 const GET_MINIAPP_QRCODE string = "https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token=%s"
 
-//公众号授权
+// 公众号授权
 const OFFICAL_ACCOUNT_AUTHORIZATION_URL string = "https://open.weixin.qq.com/connect/oauth2/authorize?appid=%s&redirect_uri=%s&response_type=code&scope=snsapi_userinfo&state=%s#wechat_redirect"
 
-//公众号获取用户信息
+// 公众号获取用户信息
 const MP_USERINFO_API string = "https://api.weixin.qq.com/cgi-bin/user/info?access_token=%s&openid=%s&lang=%s"
+
+// 公众号模板消息
+const MP_TEMPLATE_MESSAGE_API string = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=%s"