|
@@ -3,10 +3,10 @@ package utils
|
|
import (
|
|
import (
|
|
"context"
|
|
"context"
|
|
"fmt"
|
|
"fmt"
|
|
|
|
+ "github.com/beego/beego/v2/core/utils"
|
|
"github.com/wechatpay-apiv3/wechatpay-go/core"
|
|
"github.com/wechatpay-apiv3/wechatpay-go/core"
|
|
"github.com/wechatpay-apiv3/wechatpay-go/core/option"
|
|
"github.com/wechatpay-apiv3/wechatpay-go/core/option"
|
|
payUtils "github.com/wechatpay-apiv3/wechatpay-go/utils"
|
|
payUtils "github.com/wechatpay-apiv3/wechatpay-go/utils"
|
|
- "os"
|
|
|
|
)
|
|
)
|
|
|
|
|
|
var WechatCertClient *core.Client
|
|
var WechatCertClient *core.Client
|
|
@@ -21,16 +21,11 @@ const (
|
|
|
|
|
|
// 微信商户建立连接
|
|
// 微信商户建立连接
|
|
func init() {
|
|
func init() {
|
|
- if RunMode != "release" {
|
|
|
|
- _, err := os.Stat(MchPKFileName) // 判断证书路径是否存在,非生产环境不做判断。
|
|
|
|
- if err != nil {
|
|
|
|
- go SendAlarmMsg("微信商户链接失败 os.Stat"+err.Error(), 2)
|
|
|
|
- FileLog.Info("WechatCertClient err:" + err.Error())
|
|
|
|
- err = nil
|
|
|
|
- return
|
|
|
|
- }
|
|
|
|
|
|
+ if !utils.FileExists(MchPKFileName) {
|
|
|
|
+ //fmt.Println("商户私钥文件不存在")
|
|
|
|
+ go SendAlarmMsg("微信商户链接失败 商户私钥文件不存在", 2)
|
|
|
|
+ return
|
|
}
|
|
}
|
|
-
|
|
|
|
// 使用 utils 提供的函数从本地文件中加载商户私钥,商户私钥会用来生成请求的签名
|
|
// 使用 utils 提供的函数从本地文件中加载商户私钥,商户私钥会用来生成请求的签名
|
|
mchPrivateKey, err := payUtils.LoadPrivateKeyWithPath(MchPKFileName)
|
|
mchPrivateKey, err := payUtils.LoadPrivateKeyWithPath(MchPKFileName)
|
|
if err != nil {
|
|
if err != nil {
|