mirror of
https://github.com/xxjwxc/public.git
synced 2026-04-22 23:17:20 +08:00
xxj
94 lines
4.9 KiB
Go
94 lines
4.9 KiB
Go
package weixin
|
|
|
|
import (
|
|
"github.com/xxjwxc/public/message"
|
|
"github.com/xxjwxc/public/mycache"
|
|
"github.com/xxjwxc/public/mylog"
|
|
|
|
"github.com/xxjwxc/public/tools"
|
|
|
|
wxpay "gopkg.in/go-with/wxpay.v1"
|
|
)
|
|
|
|
// 微信支付商户平台证书路径
|
|
|
|
// CertFileLoc cert.pem
|
|
var CertFileLoc = "/conf/cert/apiclient_cert.pem"
|
|
|
|
// KeyFileLoc key.pem
|
|
var KeyFileLoc = "/conf/cert/apiclient_key.pem"
|
|
|
|
// RootcaFileLoc rootca.pem
|
|
var RootcaFileLoc = "/conf/cert/rootca.pem"
|
|
|
|
// WxTools 微信操作类型
|
|
type WxTools interface {
|
|
SetCache(cache mycache.CacheIFS) // 设置缓存
|
|
GetAccessToken() (accessToken string, err error) // 获取登录凭证
|
|
GetAPITicket() (ticket string, err error) // 获取微信卡券ticket
|
|
GetJsTicket() (ticket APITicket, err error) // 获取微信js ticket
|
|
SendTemplateMsg(msg TempMsg) bool // 发送订阅消息
|
|
SmallAppOauth(jscode string) string // 小程序授权
|
|
SmallAppUnifiedorder(openID string, price int64, priceBody, orderID, clientIP string) message.MessageBody // 小程序统一下单接口
|
|
SelectOrder(openID, orderID string) (int, message.MessageBody) // 统一查询接口
|
|
RefundPay(openID, orderID, refundNO string, totalFee, refundFee int64) (bool, message.MessageBody) // 申请退款
|
|
WxEnterprisePay(openID, tradeNO, desc, ipAddr string, amount int) bool // 企业付款
|
|
GetShareQrcode(path string, scene, page string) (ret QrcodeRet) // 获取小程序码
|
|
GetWxQrcode(path, page string, width int) (ret QrcodeRet) // 获取小程序二维码 （有限个）
|
|
GetAllOpenId() ([]string, error) // 获取所有用户id
|
|
GetFreepublish(max int64) ([]FreepublishiInfo, error) // 获取成功发布列表，最大条数
|
|
GetMaterial(mediaId string) (string, error) // 获取素材地址
|
|
GetBlacklist(openid string) ([]string, string, error) // 获取黑名单列表
|
|
Getuserphonenumber(code string) (string, error) // 手机号获取凭证
|
|
// --------------------h5------------------------------
|
|
GetWebOauth(code string) (*AccessToken, error) // 授权
|
|
GetWebUserinfo(openid, snaccessToken string) (*WxUserinfo, error) // 获取用户信息
|
|
SendWebTemplateMsg(msg TempWebMsg) error // 发送公众号模板消息
|
|
CreateMenu(menu WxMenu) error // 创建自定义菜单
|
|
DeleteMenu() error // 删除自定义菜单
|
|
SetGuideConfig(guideConfig GuideConfig) error // 快捷回复与关注自动回复
|
|
|
|
GetH5Qrcode(expireSeconds int, actionName string, aceneId int) (string, error) // h5获取临时二维码
|
|
SendCustomMsg(msg CustomMsg) error // 发送客服消息
|
|
UploadTmpFile(path, tp string) (string, error) //上传临时文件(tp:媒体文件类型，分别有图片（image）、语音（voice）、视频（video）和缩略图（thumb）)
|
|
// ----------------------------------------------------
|
|
|
|
GetJsSign(url string) (*WxJsSign, error) // js-sdk 授权
|
|
}
|
|
|
|
// New 新建及 初始化配置信息
|
|
func New(info WxInfo) (WxTools, error) {
|
|
t := &wxTools{
|
|
wxInfo: info,
|
|
certFile: tools.GetCurrentDirectory() + CertFileLoc,
|
|
keyFile: tools.GetCurrentDirectory() + KeyFileLoc,
|
|
rootcaFile: tools.GetCurrentDirectory() + RootcaFileLoc,
|
|
client: wxpay.NewClient(info.AppID, info.MchID, info.APIKey),
|
|
cache: mycache.NewCache(_cacheToken),
|
|
}
|
|
err := t.client.WithCert(t.certFile, t.keyFile, t.rootcaFile)
|
|
if err != nil {
|
|
mylog.Error(err)
|
|
return nil, err
|
|
}
|
|
return t, nil
|
|
}
|
|
|
|
// New 新建及 初始化配置信息
|
|
func NewWithCertFile(info WxInfo, certFileLoc, keyFileLoc, rootcaFileLoc string) (WxTools, error) {
|
|
t := &wxTools{
|
|
wxInfo: info,
|
|
certFile: certFileLoc,
|
|
keyFile: keyFileLoc,
|
|
rootcaFile: rootcaFileLoc,
|
|
client: wxpay.NewClient(info.AppID, info.MchID, info.APIKey),
|
|
cache: mycache.NewCache(_cacheToken),
|
|
}
|
|
err := t.client.WithCert(t.certFile, t.keyFile, t.rootcaFile)
|
|
if err != nil {
|
|
mylog.Error(err)
|
|
return nil, err
|
|
}
|
|
return t, nil
|
|
}
|