payCenter/entity/config.go

package entity

import (
	"app.yhyue.com/moapp/jybase/mysql"
	"github.com/zeromicro/go-zero/core/logx"
)

const (
	Pay = "base_pay"
)

var (
	Mysql   *mysql.Mysql
	JyMysql *mysql.Mysql
)

//支付配置
var PayConf map[string]interface{}
var AliPayConf map[string]interface{}
var WxPayConf map[string]interface{}

type CallBackParam struct {
	TotalFee      int    //订单价格
	CashFee       int    //支付金额
	OutTradeno    string //订单号(微信支付宝支付使用)
	TimeEnd       string //支付时间
	TransactionId string //商户单号(微信支付宝支付)
	Openid        string //位置用户标识（仅微信有）
	OrderCode     string //线下支付使用
}

func init() {
	//qutil.ReadConfig("./pay_config.json", &PayConf)
	//AliPayConf = PayConf["aliPay"].(map[string]interface{})
	//WxPayConf = PayConf["wxPay"].(map[string]interface{})
}

func InitMysql(m, n *mysql.Mysql) {
	Mysql = &mysql.Mysql{
		Address:      m.Address,
		UserName:     m.UserName,
		PassWord:     m.PassWord,
		DBName:       m.DBName,
		MaxOpenConns: m.MaxOpenConns,
		MaxIdleConns: m.MaxIdleConns,
	}
	Mysql.Init()
	JyMysql = &mysql.Mysql{
		Address:      n.Address,
		UserName:     n.UserName,
		PassWord:     n.PassWord,
		DBName:       n.DBName,
		MaxOpenConns: n.MaxOpenConns,
		MaxIdleConns: n.MaxIdleConns,
	}
	JyMysql.Init()
	logx.Info("初始化mysql")
}

// func (param *CallBackParam) SaveWxPayRecord() (insert bool) {
// 	pay_count := util.Mysql.Count("weixin_pay", map[string]interface{}{
// 		"transaction_id": param.TransactionId,
// 		"out_trade_no":   param.OutTradeno,
// 		"user_openid":    param.Openid,
// 	})
// 	if pay_count == 0 {
// 		now := time.Now()
// 		insert = util.Mysql.Insert("weixin_pay", map[string]interface{}{
// 			"transaction_id": param.TransactionId,
// 			"out_trade_no":   param.OutTradeno,
// 			"user_openid":    param.Openid,
// 			"create_time":    qutil.FormatDate(&now, qutil.Date_Full_Layout),
// 			"total_fee":      param.TotalFee,
// 			"cash_fee":       param.CashFee,
// 			"time_end":       param.TimeEnd,
// 		}) > 0
// 	} else if pay_count > 0 {
// 		insert = true
// 	}
// 	return
// }

// func (param *CallBackParam) SaveAliPayRecord() (insert bool) {
// 	//支付完成插入
// 	pay_count := util.Mysql.Count("ali_pay", map[string]interface{}{
// 		"transaction_id": param.TransactionId,
// 		"out_trade_no":   param.OutTradeno,
// 	})
// 	if pay_count == 0 {
// 		now := time.Now()
// 		insert = util.Mysql.Insert("ali_pay", map[string]interface{}{
// 			"transaction_id": param.TransactionId,
// 			"out_trade_no":   param.OutTradeno,
// 			"create_time":    qutil.FormatDate(&now, qutil.Date_Full_Layout),
// 			"total_fee":      param.TotalFee,
// 			"cash_fee":       param.CashFee,
// 			"time_end":       param.TimeEnd,
// 		}) > 0
// 	} else {
// 		insert = true
// 	}
// 	return
// }