package controller

import (
	"basic.com/valib/bhomedbapi.git"
	"basic.com/valib/licence.git"
	"basic.com/valib/logger.git"
	"encoding/json"
	"errors"
	"github.com/gin-gonic/gin"
	"io/ioutil"
	"net/http"
	"os"
	"strings"
	"time"
	"vamicro/config"
	"vamicro/extend/code"
	"vamicro/extend/util"
	"vamicro/version-control/service"
)

/*
  	在线激活smartai
	1.登录商城
	2.展示商城订单
	3.选择订单进行激活
*/

func pRet(b []byte, err error, c *gin.Context, cb func(data interface{}) (interface{}, error)) {
	if err != nil {
		logger.Error("pRet err:", err)
		util.ResponseFormat(c, code.ComError, err.Error())
		return
	}
	var ret bhomedbapi.Result
	err = json.Unmarshal(b, &ret)
	if err != nil {
		logger.Error("pRet err:", err)
		util.ResponseFormat(c, code.ComError, err.Error())
		return
	}
	if !ret.Success {
		logger.Error("!ret.Success ret:", ret)
		c.JSON(http.StatusInternalServerError, ret)
		return
	}
	if cb != nil {
		var rd interface{}
		rd, err = cb(ret.Data)
		if err != nil {
			util.ResponseFormat(c, code.ComError, err.Error())
			return
		} else {
			util.ResponseFormat(c, code.Success, rd)
			return
		}
	}
	c.JSON(http.StatusOK, ret)
}

//请求商城端发送短信验证码
func shopMakSmsHandle(c *gin.Context) {
	phoneNum := c.Query("phoneNum")
	if phoneNum == "" {
		util.ResponseFormat(c, code.RequestParamError, "")
		return
	}
	url := util.GetShopUrl() + "/data/api-u/user/makeVerifyCode"
	if !strings.HasPrefix(url, "http://") {
		url = "http://" + url
	}
	m := map[string]string{
		"phoneNum": phoneNum,
	}
	b, err := util.DoGetRequest(url, m, nil)
	pRet(b, err, c, nil)
}

//调用商城端登录，获取token
func shopCenterLoginHandle(c *gin.Context) {
	phoneNum := c.PostForm("phoneNum")
	verifyCode := c.PostForm("verifyCode")

	if phoneNum == "" || verifyCode == "" {
		util.ResponseFormat(c, code.RequestParamError, "")
		return
	}

	url := util.GetShopUrl() + "/data/api-u/user/login"
	if !strings.HasPrefix(url, "http://") {
		url = "http://" + url
	}
	m := map[string]interface{}{
		"phoneNum":   phoneNum,
		"verifyCode": verifyCode,
	}

	b, err := util.DoPostRequest(url, util.CONTENT_TYPE_FORM, m, nil, nil, time.Second*5)
	pRet(b, err, c, func(data interface{}) (interface{}, error) {
		d, e := json.Marshal(data)
		if e != nil {
			return nil, e
		}
		type sld struct {
			AccessToken string `json:"access_token"`
		}
		var u sld
		e = json.Unmarshal(d, &u)
		if e != nil {
			return nil, e
		}
		if !strings.HasPrefix(u.AccessToken, "Bearer ") {
			u.AccessToken = "Bearer " + u.AccessToken
		}
		return u, nil
	})
}

//获取可用于激活的订单列表
func shopCenterGetOrderListHandle(c *gin.Context) {
	token := c.PostForm("token")
	if token == "" {
		util.ResponseFormat(c, code.RequestParamError, "")
		return
	}
	if !strings.HasPrefix(token, "Bearer ") {
		token = "Bearer " + token
	}
	url := util.GetShopUrl() + "/data/api-s/order/getActiveOrder"
	if !strings.HasPrefix(url, "http://") {
		url = "http://" + url
	}
	header := map[string]string{
		"Authorization": token,
	}
	m := map[string]interface{}{
		"page": 1,
		"size": 100,
	}
	b, err := util.DoPostRequest(url, util.CONTENT_TYPE_JSON, m, nil, header, time.Second*5)
	pRet(b, err, c, nil)
}

//请求商城使用订单进行激活,返回内容：
//请求码  通道数量  摄像机数量  设备数量  服务时长   产品密钥
func authActiveByOrderHandle(c *gin.Context) {
	token := c.PostForm("token")
	orderId := c.PostForm("orderId")
	productId := c.PostForm("productId")
	activateCode := c.PostForm("activateCode") //25位激活码
	if token == "" || activateCode == "" {
		util.ResponseFormat(c, code.RequestParamError, "")
		return
	}
	if !strings.HasPrefix(token, "Bearer ") {
		token = "Bearer " + token
	}
	url := util.GetShopUrl() + "/data/api-s/q_authorization"
	if !strings.HasPrefix(url, "http://") {
		url = "http://" + url
	}
	header := map[string]string{
		"Authorization": token,
	}

	var rd = util.AuthorizationInfo{
		DevId:        config.Server.AnalyServerId,
		MachineCode:  licence.GetMachineCode(),
		DeviceType:   config.Server.DeviceType,
		DeviceMode:   config.Server.DeviceModel,
		ActivateCode: activateCode,
	}

	var sysInitApi bhomedbapi.SysInitApi
	b, rInfo := sysInitApi.GetRegInfo()
	if b {
		rbd, e := json.Marshal(rInfo)
		if e == nil {
			var sysRI service.RegUserInfo
			if e = json.Unmarshal(rbd, &sysRI); e == nil {
				rd.UserType = sysRI.UserType
				rd.PhoneNum = sysRI.PhoneNum
				rd.Name = sysRI.Name
				rd.ProvinceId = sysRI.ProvinceId
				rd.CityId = sysRI.CityId
				rd.CountyId = sysRI.CountyId
				rd.Email = sysRI.Email
			}
		}
	}

	q, err := service.HackAuthorizationInfo(rd)
	if err != nil {
		logger.Error("Haq err:", err)
		util.ResponseFormat(c, code.ComError, err.Error())
		return
	}

	body := map[string]interface{}{
		"sn":           q,
		"orderId":      orderId,
		"productId":    productId,
		"activateCode": activateCode,
	}

	rb, err := util.DoPostRequest(url, util.CONTENT_TYPE_JSON, body, nil, header, time.Second*5)
	cb := func(data interface{}) (interface{}, error) {
		rb, err := json.Marshal(data)
		if err != nil {
			logger.Error("json.Marshal err:", err)
			return nil, err
		}
		type rs struct {
			AuthInfo string `json:"authInfo"`
		}
		var rai rs
		err = json.Unmarshal(rb, &rai)
		if err != nil {
			logger.Error("json.Unmarshal err:", err)
			return nil, err
		}
		authInfo, e := util.GetAuthorizationInfo(rai.AuthInfo)
		if e != nil {
			logger.Error("GetAuthorizationInfo e:", e)
			return nil, e
		}
		machineCode := licence.GetMachineCode()
		if machineCode != authInfo.MachineCode {
			logger.Error("GetAuthorization machineCode not match, local:", machineCode, " remote:", authInfo.MachineCode)
			return nil, errors.New("机器码不匹配")
		}

		sn := util.GetVamicroPath() + "/sn.txt"
		pathAuth := util.GetVamicroPath() + "/auth.txt"
		ioutil.WriteFile(sn, []byte(""), os.ModePerm)
		ioutil.WriteFile(pathAuth, []byte(rai.AuthInfo), os.ModePerm)
		rm := map[string]interface{}{
			"sn":          authInfo.ActivateCode,
			"edition":     authInfo.Edition,
			"chCount":     authInfo.ChCount,
			"cameraCount": authInfo.CameraCount,
			"devCount":    authInfo.DevCount,
			"serveYear":   authInfo.ServeYear,
			"authInfo":    rai.AuthInfo,
		}
		return rm, nil
	}
	pRet(rb, err, c, cb)
}