package controller

import (
	"encoding/json"
	"fmt"
	"github.com/gin-gonic/gin"
	"github.com/tidwall/gjson"
	"kefu/common"
	"kefu/lib"
	"kefu/models"
	"kefu/tools"
	"kefu/types"
	"log"
	"sort"
	"strconv"
	"strings"
	"time"
)

// 易支付下单
func PostYiApiPay(c *gin.Context) {
	entId := c.PostForm("entId")
	kefuName := c.PostForm("kefuName")
	amount := c.PostForm("amount")
	openId := c.PostForm("openId")
	email := c.PostForm("email")
	product := c.PostForm("product")
	tel := c.PostForm("tel")
	contact := c.PostForm("contact")

	virtualProduct := models.FindVirtualProduct("ent_id = ? and id = ?", entId, product)
	description := fmt.Sprintf("%s，支付金额：%s (分)", tools.SubStr(virtualProduct.ProductName, 0, 20), amount)
	snow, _ := tools.NewSnowflake(1)
	orderId := fmt.Sprintf("%s%d", time.Now().Format("0601021504"), snow.Generate())
	log.Println(tools.Str2Int(amount)/100, tools.Str2Int(amount))
	config := models.GetEntConfigsMap(entId, "Nan66Api", "Nan66Shopid", "Nan66ShopSecret")

	currentHost := tools.GetHost(c.Request)
	params := map[string]interface{}{
		"pid":          config["Nan66Shopid"],
		"type":         "wxpay",
		"out_trade_no": orderId,
		"notify_url":   currentHost + "/2/" + entId + "/yiApiPayNotifyUrl",
		"return_url":   currentHost + "/2/" + entId + "/yiApiPayNotifyUrl",
		"name":         description,
		"money":        float64(tools.Str2Int64(amount)) / 100,
		"clientip":     c.ClientIP(),
	}
	var keys []string
	// 筛选、排序参数
	for key := range params {
		keys = append(keys, key)
	}
	sort.Strings(keys)
	sortedParams := make([]string, len(keys))
	for i, key := range keys {
		sortedParams[i] = fmt.Sprintf("%s=%v", key, params[key])
	}
	waitSign := strings.Join(sortedParams, "&")
	sign := tools.Md5(waitSign + config["Nan66ShopSecret"])
	body := fmt.Sprintf("%s&sign=%s&sign_type=MD5", waitSign, sign)
	log.Println("请求易支付", config["Nan66Api"], body)
	resp, err := tools.Post(config["Nan66Api"], "", []byte(body))
	log.Println("请求易支付", resp, err)
	productOrder := &models.ProductOrder{
		KefuName:        kefuName,
		OrderSn:         orderId,
		UserId:          openId,
		EntID:           entId,
		OrderStatus:     "processing",
		TotalAmount:     tools.Str2Int64(amount),
		PaymentMethod:   "nan66",
		PaymentStatus:   "unpaid",
		ShippingAddress: virtualProduct.ResourceLink,
		OrderDesc:       description,
		Contact:         contact,
		Email:           email,
		Tel:             tel,
	}
	productOrder.AddProductOrder()
	c.Writer.Write([]byte(resp))
}

// 易支付回调
func GetYiApiPayNotifyUrl(c *gin.Context) {
	entId := c.Param("entId")
	config := models.GetEntConfigsMap(entId, "Nan66Api", "Nan66Shopid", "Nan66ShopSecret")
	out_trade_no := c.Query("out_trade_no")
	trade_status := c.Query("trade_status")
	money := c.Query("money")
	name := c.Query("name")
	pid := c.Query("pid")
	trade_no := c.Query("trade_no")
	types := c.Query("type")
	sign := c.Query("sign")
	param := c.Query("param")

	params := map[string]interface{}{
		"pid":          pid,
		"type":         types,
		"out_trade_no": out_trade_no,
		"trade_no":     trade_no,
		"name":         name,
		"money":        money,
		"param":        param,
		"trade_status": trade_status,
	}
	var keys []string
	// 筛选、排序参数
	for key := range params {
		if params[key] == "" {
			continue
		}
		keys = append(keys, key)
	}
	sort.Strings(keys)
	sortedParams := make([]string, len(keys))
	for i, key := range keys {
		sortedParams[i] = fmt.Sprintf("%s=%v", key, params[key])
	}
	waitSign := strings.Join(sortedParams, "&")
	newSign := tools.Md5(waitSign + config["Nan66ShopSecret"])
	if sign != newSign {
		log.Println("易支付验证签名失败", params, sign, newSign)
		c.Writer.Write([]byte("success"))
		return
	}

	order := models.FindProductOrder("order_sn = ?", out_trade_no)
	if trade_status == "TRADE_SUCCESS" && order.PaymentStatus == "unpaid" {
		newOrder := &models.ProductOrder{
			PaymentStatus: "paid",
		}
		newOrder.SaveProductOrder("order_sn = ?", out_trade_no)
	}
	c.Writer.Write([]byte("success"))
}

// jsapi支付下单
func PostJsApiCreateOrder(c *gin.Context) {
	entId := c.PostForm("entId")
	kefuName := c.PostForm("kefuName")
	amount := c.PostForm("amount")
	openId := c.PostForm("openId")
	email := c.PostForm("email")
	product := c.PostForm("product")
	tel := c.PostForm("tel")
	contact := c.PostForm("contact")

	virtualProduct := models.FindVirtualProduct("ent_id = ? and id = ?", entId, product)
	description := fmt.Sprintf("%s,支付金额：%s(分)", tools.SubStr(virtualProduct.ProductName, 0, 20), amount)
	snow, _ := tools.NewSnowflake(1)
	orderId := fmt.Sprintf("%s%d", time.Now().Format("0601021504"), snow.Generate())

	appId := models.FindConfig("WechatPayAppId")                                           //公众号APPID
	mchID := models.FindConfig("WechatPayMchID")                                           //商户号
	mchCertificateSerialNumber := models.FindConfig("WechatPayMchCertificateSerialNumber") //商户证书序列号
	//商户API V3密钥
	mchAPIv3Key := models.FindConfig("WechatPayMchAPIv3Key")
	//商户私钥
	mchPrivateKey := models.FindConfig("WechatPayMchPrivateKey")
	notifyUrl := models.FindConfig("WechatJsApiNotifyUrl")
	if appId == "" || mchID == "" || mchCertificateSerialNumber == "" || mchAPIv3Key == "" || mchPrivateKey == "" || notifyUrl == "" {
		c.JSON(200, gin.H{
			"code": types.ApiCode.FAILED,
			"msg":  "微信支付配置为空",
		})
		return
	}

	wechatpay, err := lib.NewWechatPay(appId, mchID, mchCertificateSerialNumber, mchAPIv3Key, mchPrivateKey, notifyUrl)
	resp, err := wechatpay.JsApiPreOrder(openId, tools.Str2Int64(amount), description, orderId)
	log.Println("微信支付JSAPI下单：", resp, err)
	if err != nil {
		c.JSON(200, gin.H{
			"code": types.ApiCode.FAILED,
			"msg":  err.Error(),
		})
		return
	}

	productOrder := &models.ProductOrder{
		KefuName:        kefuName,
		OrderSn:         orderId,
		UserId:          openId,
		EntID:           entId,
		OrderStatus:     "processing",
		TotalAmount:     tools.Str2Int64(amount),
		PaymentMethod:   "wechat",
		PaymentStatus:   "unpaid",
		ShippingAddress: virtualProduct.ResourceLink,
		OrderDesc:       description,
		Contact:         contact,
		Email:           email,
		Tel:             tel,
	}
	productOrder.AddProductOrder()

	c.JSON(200, gin.H{
		"code":          types.ApiCode.SUCCESS,
		"msg":           "下单成功！",
		"resource_link": virtualProduct.ResourceLink,
		"result":        resp,
	})
}

// JSAPI支付回调
func PostjsApiPayNotifyUrl(c *gin.Context) {
	appId := models.FindConfig("WechatPayAppId")                                           //公众号APPID
	mchID := models.FindConfig("WechatPayMchID")                                           //商户号
	mchCertificateSerialNumber := models.FindConfig("WechatPayMchCertificateSerialNumber") //商户证书序列号
	//商户API V3密钥
	mchAPIv3Key := models.FindConfig("WechatPayMchAPIv3Key")
	//商户私钥
	mchPrivateKey := models.FindConfig("WechatPayMchPrivateKey")
	notifyUrl := models.FindConfig("WechatJsApiNotifyUrl")

	wechatpay, _ := lib.NewWechatPay(appId, mchID, mchCertificateSerialNumber, mchAPIv3Key, mchPrivateKey, notifyUrl)
	result, err := wechatpay.ParseNotifyRequest(c.Request)
	resultStr, err := json.Marshal(result)
	log.Println("微信支付回调：", string(resultStr), err)

	//增加时间
	trade_state := gjson.Get(string(resultStr), "trade_state").String()
	out_trade_no := gjson.Get(string(resultStr), "out_trade_no").String()
	amount := gjson.Get(string(resultStr), "amount.total").Int()
	order := models.FindProductOrder("order_sn = ?", out_trade_no)
	if trade_state == "SUCCESS" && order.PaymentStatus == "unpaid" {

		newOrder := &models.ProductOrder{
			PaymentStatus: "paid",
		}
		newOrder.SaveProductOrder("order_sn = ?", out_trade_no)

		//增加余额
		userAttr := models.FindUserAttrRow("ent_id = ? and kefu_name = ?", order.EntID, order.KefuName)
		if userAttr.ID == 0 {
			userAttr.Money = amount
			userAttr.EntId = order.EntID
			userAttr.KefuName = order.KefuName
			userAttr.AddUserAttr()
		} else {
			userAttr.Money = userAttr.Money + amount
			userAttr.EntId = order.EntID
			userAttr.KefuName = order.KefuName
			userAttr.SaveUserAttr("ent_id = ? and kefu_name = ?", order.EntID, order.KefuName)
		}
	}
}

// native支付下单在线支付
func PostCreateOrder(c *gin.Context) {
	kefuName, _ := c.Get("kefu_name")
	entId, _ := c.Get("ent_id")
	payMonth := c.PostForm("pay_month")
	months := tools.Str2Int64(payMonth)

	//计算到期时间
	incSecond := months * 30 * 24 * 60 * 60
	kefuInfo := models.FindUser(kefuName.(string))
	nowTime := time.Now().Unix()
	expireTime := kefuInfo.ExpiredAt.Unix()
	newExpireInt := expireTime + incSecond
	//如果早就过期，当前时间增加
	if expireTime < nowTime {
		newExpireInt = nowTime + incSecond
	}
	newExpireStr := tools.IntToTimeStr(newExpireInt, "2006-01-02")

	amount := months * 60 * (int64(kefuInfo.AgentNum) + 1) * 100
	description := fmt.Sprintf("客服系统充值服务%s个月,到期时间：%s", payMonth, newExpireStr)
	snow, _ := tools.NewSnowflake(1)
	orderId := fmt.Sprintf("%s%d", time.Now().Format("0601021504"), snow.Generate())

	appId := models.FindConfig("WechatPayAppId")                                           //公众号APPID
	mchID := models.FindConfig("WechatPayMchID")                                           //商户号
	mchCertificateSerialNumber := models.FindConfig("WechatPayMchCertificateSerialNumber") //商户证书序列号
	//商户API V3密钥
	mchAPIv3Key := models.FindConfig("WechatPayMchAPIv3Key")
	//商户私钥
	mchPrivateKey := models.FindConfig("WechatPayMchPrivateKey")
	notifyUrl := models.FindConfig("WechatPayNotifyUrl")

	wechatpay, err := lib.NewWechatPay(appId, mchID, mchCertificateSerialNumber, mchAPIv3Key, mchPrivateKey, notifyUrl)
	if err != nil {
		log.Println(err)
		c.JSON(200, gin.H{
			"code": types.ApiCode.FAILED,
			"msg":  err.Error(),
		})
		return
	}
	codeUrl, err := wechatpay.NativePayPreOrder(amount, description, orderId)
	if err != nil {
		log.Println(err)
		c.JSON(200, gin.H{
			"code": types.ApiCode.FAILED,
			"msg":  err.Error(),
		})
		return
	}
	orderModels := &models.User_order{
		OrderSn:       orderId,
		Money:         uint(amount),
		NewExpireTime: newExpireStr,
		Payment:       "wechat",
		Type:          1,
		Comment:       description,
		CreatedAt:     types.Time{time.Now()},
		Operator:      kefuName.(string),
		KefuName:      kefuName.(string),
		EntId:         entId.(string),
	}
	orderModels.AddUserOrder()
	c.JSON(200, gin.H{
		"code": types.ApiCode.SUCCESS,
		"msg":  types.ApiCode.GetMessage(types.ApiCode.SUCCESS),
		"result": gin.H{
			"code_url": codeUrl,
			"order_id": orderId,
			"ammount":  amount,
		},
	})
}

// 在线支付回调
func PostWechatPayNotifyUrl(c *gin.Context) {
	appId := models.FindConfig("WechatPayAppId")                                           //公众号APPID
	mchID := models.FindConfig("WechatPayMchID")                                           //商户号
	mchCertificateSerialNumber := models.FindConfig("WechatPayMchCertificateSerialNumber") //商户证书序列号
	//商户API V3密钥
	mchAPIv3Key := models.FindConfig("WechatPayMchAPIv3Key")
	//商户私钥
	mchPrivateKey := models.FindConfig("WechatPayMchPrivateKey")
	notifyUrl := models.FindConfig("WechatPayNotifyUrl")

	wechatpay, _ := lib.NewWechatPay(appId, mchID, mchCertificateSerialNumber, mchAPIv3Key, mchPrivateKey, notifyUrl)
	result, err := wechatpay.ParseNotifyRequest(c.Request)
	log.Println("微信支付回调：", result, err)

	//增加时间
	trade_state := result["trade_state"].(string)
	out_trade_no := result["out_trade_no"].(string)
	order := models.FindUserOrder("order_sn = ?", out_trade_no)
	if trade_state == "SUCCESS" && order.Type != 2 {
		models.UpdateUserOrderTypedWhere(2, "order_sn = ?", out_trade_no)
		models.UpdateUserExpiredWhere(order.NewExpireTime, " name = ? ", order.KefuName)
	}
}

// 查询订单
func PostQueryWechatOrder(c *gin.Context) {
	orderId := c.PostForm("order_id")
	entId, _ := c.Get("ent_id")
	kefuName, _ := c.Get("kefu_name")

	appId := models.FindConfig("WechatPayAppId")                                           //公众号APPID
	mchID := models.FindConfig("WechatPayMchID")                                           //商户号
	mchCertificateSerialNumber := models.FindConfig("WechatPayMchCertificateSerialNumber") //商户证书序列号
	//商户API V3密钥
	mchAPIv3Key := models.FindConfig("WechatPayMchAPIv3Key")
	//商户私钥
	mchPrivateKey := models.FindConfig("WechatPayMchPrivateKey")
	notifyUrl := models.FindConfig("WechatPayNotifyUrl")

	wechatpay, _ := lib.NewWechatPay(appId, mchID, mchCertificateSerialNumber, mchAPIv3Key, mchPrivateKey, notifyUrl)

	body, res, err := wechatpay.NativePayQueryOrder(orderId)
	if err != nil {
		log.Println(body, err)
		c.JSON(200, gin.H{
			"code": types.ApiCode.FAILED,
			"msg":  err.Error(),
		})
		return
	}
	if res != "SUCCESS" {
		log.Println("微信支付订单查询：", body)
		c.JSON(200, gin.H{
			"code": types.ApiCode.FAILED,
			"msg":  "订单未成功支付",
		})
		return
	}
	//查询订单状态
	order := models.FindUserOrder("ent_id = ? and order_sn = ?", entId, orderId)
	if order.Type == 2 {
		c.JSON(200, gin.H{
			"code": types.ApiCode.SUCCESS,
			"msg":  "订单成功支付",
		})
		return
	}
	models.UpdateUserOrderTypedWhere(2, "ent_id = ? and order_sn = ?", entId, orderId)
	models.UpdateUserExpiredWhere(order.NewExpireTime, " name = ? ", kefuName)
	c.JSON(200, gin.H{
		"code": types.ApiCode.SUCCESS,
		"msg":  "订单成功支付",
	})
}
func GetSystemConfig(c *gin.Context) {
	alipayImageUrl := models.FindConfig("AlipayImageUrl")
	wechatImageUrl := models.FindConfig("WechatImageUrl")
	bankInfo := models.FindConfig("BankInfo")
	version := models.FindConfig("SystemVersion")
	versionName := models.FindConfig("SystemVersionName")
	kefuExpired := models.FindConfig("KefuExpired")
	KefuBindTel := models.FindConfig("KefuBindTel")
	c.JSON(200, gin.H{
		"code": 200,
		"msg":  "ok",
		"result": gin.H{
			"alipayImageUrl": alipayImageUrl,
			"wechatImageUrl": wechatImageUrl,
			"bankInfo":       bankInfo,
			"version":        version,
			"versionName":    versionName,
			"kefuExpired":    kefuExpired,
			"KefuBindTel":    KefuBindTel,
		},
	})
}

// 管理员充值
func PostAdminUserCharge(c *gin.Context) {
	entId, _ := c.Get("ent_id")
	myName, _ := c.Get("kefu_name")
	username := c.PostForm("kefu_name")
	money := c.PostForm("money")
	payment := c.PostForm("payment")
	var user *models.User
	if tools.IsPhoneNumber(username) {
		user = &models.User{
			Tel: username,
		}
	} else if tools.IsEmail(username) {
		user = &models.User{
			Email: username,
		}
	} else {
		user = &models.User{
			Name: username,
		}
	}

	kefuInfo := user.GetOneUser("*")
	if kefuInfo.ID == 0 {
		c.JSON(200, gin.H{
			"code": 400,
			"msg":  "账号不存在",
		})
		return
	}
	//充值天数
	moneyInt, _ := strconv.Atoi(money)
	dayInt := int64(moneyInt * 24 * 3600)

	nowTime := time.Now().Unix()
	expireTime := kefuInfo.ExpiredAt.Unix()
	newExpireInt := expireTime + dayInt
	//如果早就过期，当前时间增加天数
	if expireTime < nowTime {
		newExpireInt = nowTime + dayInt
	}
	newExpireStr := tools.IntToTimeStr(newExpireInt, "2006-01-02 15:04:05")

	query := " name = ? "
	arg := []interface{}{
		kefuInfo.Name,
	}
	models.UpdateUserExpiredWhere(newExpireStr, query, arg...)

	//记录订单
	snow, _ := tools.NewSnowflake(1)
	orderModels := &models.User_order{
		OrderSn:   fmt.Sprintf("SN%d", snow.Generate()),
		Money:     uint(moneyInt) * uint(common.EveryDayYuan) * 100,
		Payment:   payment,
		Type:      2,
		Comment:   "管理员充值 , 到期 " + newExpireStr,
		CreatedAt: types.Time{time.Now()},
		Operator:  myName.(string),
		KefuName:  kefuInfo.Name,
		EntId:     fmt.Sprintf("%d", kefuInfo.ID),
	}
	orderModels.AddUserOrder()
	logContent := fmt.Sprintf("'%s'为'%s'充值%s天,方式 %s,到期 %s", myName, kefuInfo.Name, money, payment, newExpireStr)
	go models.CreateFlyLog(entId.(string), c.ClientIP(), logContent, "user")
	c.JSON(200, gin.H{
		"code": 200,
		"msg":  "充值成功",
	})
}