package service

import (
	"encoding/json"
	"os/exec"
	"reflect"
	"strconv"
	"strings"
	"time"
	"vamicro/config"
	"vamicro/extend/util"
	"vamicro/system-service/models"
	"vamicro/system-service/sys"
	"vamicro/system-service/vo"

	"basic.com/valib/bhomedbapi.git"
	"basic.com/valib/licence.git"
	"basic.com/valib/logger.git"
	uuid "github.com/satori/go.uuid"
	"github.com/shirou/gopsutil/cpu"
	"github.com/shirou/gopsutil/host"
	"github.com/shirou/gopsutil/mem"
)

func StartSyncDev() {
	tk := time.NewTicker(30 * time.Second)
	for {
		select {
		case <-tk.C:
			syncDevToCloud()
		default:
			time.Sleep(2 * time.Second)
		}
	}
}

const (
	token        = "Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJleHAiOjQ3NDUwMjU5MjMsInVzZXIiOiJ7XCJpZFwiOlwiZTZjY2QzNmQtNGYxNi00NmZjLTg4ZDUtMDczNjU4NjZkMjA1XCIsXCJwZXJtaXNzaW9uc1wiOltcInByb2R1Y3RNYW5nZTpwdWJsaXNoXCIsXCJjb2RlTWFuZ2U6dmlld1wiLFwiZGV2aWNlTWFuYWdlOmFkZFwiLFwiYWRtaW5NYW5hZ2VcIixcIm9yZGVyTWFuZ2VcIixcImRldmljZU1hbmFnZTp2aWV3XCIsXCJwcm9kdWN0TWFuZ2U6YWRkXCIsXCJhZG1pbk1hbmFnZTp2aWV3XCIsXCJjb2RlTWFuZ2U6YWRkXCIsXCJwcm9kdWN0TWFuZ2U6b2ZmU2FsZVwiLFwib3JkZXJNYW5nZTpjYW5jZWxcIixcInByb2R1Y3RDZW50ZXI6ZG93bmxvYWRcIixcInByb2R1Y3RDZW50ZXI6YnV5XCIsXCJwcm9kdWN0TWFuZ2U6dmlld1wiLFwiYXBpXCIsXCJob21lXCIsXCJvcmRlck1hbmdlOnBheVwiLFwiYWRtaW5NYW5hZ2U6YWRkXCIsXCJvcmRlck1hbmdlOmRvd25sb2FkXCIsXCJwcm9kdWN0Q2VudGVyXCIsXCJkZXZpY2VNYW5hZ2U6dW5iaW5kXCIsXCJvcmRlck1hbmdlOnZpZXdcIixcImFkbWluTWFuYWdlOmVkaXRcIixcImRldmljZU1hbmFnZVwiLFwidmlwTWFuYWdlOmFkZFwiLFwidmlwTWFuYWdlOnZpZXdcIixcInByb2R1Y3RDZW50ZXI6dmlld1wiLFwidmlwTWFuYWdlOmVkaXRcIixcInZpcE1hbmFnZVwiLFwicHJvZHVjdE1hbmdlOmVkaXRcIixcImNvZGVNYW5nZVwiLFwicHJvZHVjdE1hbmdlXCJdLFwidXNlcm5hbWVcIjpcImJhc2ljXCJ9In0.vwjAFkWuEyadRLvIOGK8LFE3MjpY3SQ7j6AlTXnQDG8"
	tokenForSaas = "Bearer eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJleHAiOjQ3NDUwMjU5MjMsInVzZXIiOiJ7XCJpZFwiOlwiZTZjY2QzNmQtNGYxNi00NmZjLTg4ZDUtMDczNjU4NjZkMjA1XCIsXCJwZXJtaXNzaW9uc1wiOltcInByb2R1Y3RNYW5nZTpwdWJsaXNoXCIsXCJjb2RlTWFuZ2U6dmlld1wiLFwiZGV2aWNlTWFuYWdlOmFkZFwiLFwiYWRtaW5NYW5hZ2VcIixcIm9yZGVyTWFuZ2VcIixcImRldmljZU1hbmFnZTp2aWV3XCIsXCJwcm9kdWN0TWFuZ2U6YWRkXCIsXCJhZG1pbk1hbmFnZTp2aWV3XCIsXCJjb2RlTWFuZ2U6YWRkXCIsXCJwcm9kdWN0TWFuZ2U6b2ZmU2FsZVwiLFwib3JkZXJNYW5nZTpjYW5jZWxcIixcInByb2R1Y3RDZW50ZXI6ZG93bmxvYWRcIixcInByb2R1Y3RDZW50ZXI6YnV5XCIsXCJwcm9kdWN0TWFuZ2U6dmlld1wiLFwiYXBpXCIsXCJob21lXCIsXCJvcmRlck1hbmdlOnBheVwiLFwiYWRtaW5NYW5hZ2U6YWRkXCIsXCJvcmRlck1hbmdlOmRvd25sb2FkXCIsXCJwcm9kdWN0Q2VudGVyXCIsXCJkZXZpY2VNYW5hZ2U6dW5iaW5kXCIsXCJvcmRlck1hbmdlOnZpZXdcIixcImFkbWluTWFuYWdlOmVkaXRcIixcImRldmljZU1hbmFnZVwiLFwidmlwTWFuYWdlOmFkZFwiLFwidmlwTWFuYWdlOnZpZXdcIixcInByb2R1Y3RDZW50ZXI6dmlld1wiLFwidmlwTWFuYWdlOmVkaXRcIixcInZpcE1hbmFnZVwiLFwicHJvZHVjdE1hbmdlOmVkaXRcIixcImNvZGVNYW5nZVwiLFwicHJvZHVjdE1hbmdlXCJdLFwidXNlcm5hbWVcIjpcImJhc2ljXCJ9In0.vwjAFkWuEyadRLvIOGK8LFE3MjpY3SQ7j6AlTXnQDG8"
)

var lstSync *vo.SyncDevInfo

/*
设备信息同步到商城云端
*/
func syncDevToCloud() {
	var sysconf models.LocalConfig
	err := sysconf.Select()
	if err != nil { // 查询是否存在
		return
	}
	i := vo.SyncDevInfo{}
	ipv4, mask, _ := sys.GetLocalIP(config.Server.NetworkAdapter)
	gateway, _ := sys.GetDefaultRoute(config.Server.NetworkAdapter)
	dns, _ := sys.GetDnsServer()
	machineCode := licence.GetMachineCode()
	//1.收集设备基本信息
	i.Detail = vo.DevDetail{
		ServerId:        config.Server.AnalyServerId,
		MachineCode:     machineCode,
		ServerName:      sysconf.ServerName,
		ServerPort:      sys.GetNginxListenPort(),
		Ip:              ipv4,
		SubMask:         mask,
		Gateway:         gateway,
		Dns:             dns,
		DeviceNum:       config.Server.DeviceNum,
		DeviceType:      config.Server.DeviceType,
		DeviceModel:     config.Server.DeviceModel,
		DeviceSerialNum: config.Server.DeviceSerialNum,
		MasterVersion:   config.Server.MasterVersion,
		WebVersion:      "1.0.0",
		DeviceDesc:      config.Server.DeviceDesc,
		ChannelCount:    int(sysconf.RealMax),
		NeedAuthPwd:     sysconf.NeedAuthPwd,
		AuthPwd:         sysconf.AuthPwd,
	}
	if strings.HasPrefix(util.GetPlatform(), "X86") {
		vg, _ := util.NvidiaVGpu()
		i.Detail.VGpu = vg
	}
	cmd := exec.Command("/bin/sh", "-c", "lsblk -d | grep -v part | grep -v SWAP | grep -v M | grep disk | awk '{printf $4\" \"}'")
	disks, _ := cmd.Output()
	cpu, _ := cpu.Info()
	mem, _ := mem.VirtualMemory()
	hi, _ := host.Info()
	i.Detail.Disk = string(disks)
	i.Detail.Runtime = util.TimeSpan(time.Unix(int64(hi.BootTime), 0))
	if cpu != nil && len(cpu) > 0 {
		i.Detail.Cpu = cpu[0].ModelName
	}
	if mem != nil {
		i.Detail.Mem = mem.Total
	}

	var initE models.SysInit
	if i2, _ := initE.Select(); i2 > 0 {
		i.Detail.FirstUseTime = initE.InitTime
		i.Detail.ProvinceId = initE.ProvinceId
		i.Detail.CityId = initE.CityId
		i.Detail.CountyId = initE.CountyId
	}
	bSn, e := HttpRCT("POST", "http://127.0.0.1:8888/data/api-v/version/snBus", nil, 3*time.Second)
	if e == nil {
		var dRet bhomedbapi.Result
		if e := json.Unmarshal(bSn, &dRet); e == nil && dRet.Success {
			type tis struct {
				InstallTime string `json:"installTime"`
			}
			var is tis
			if bts, e := json.Marshal(dRet.Data); e == nil {
				if e = json.Unmarshal(bts, &is); e == nil {
					i.Detail.InstallTime = is.InstallTime
				}
			}
		}
	}

	//2.收集已安装算法
	var sdkApi bhomedbapi.SdkApi
	sdks := sdkApi.FindAll("")
	//3.收集已安装应用
	var appApi bhomedbapi.AppApi
	aps := appApi.FindAll("")

	i.Sdks = sdks
	i.Apps = aps

	diff := true
	if lstSync != nil {
		if reflect.DeepEqual(i, *lstSync) {
			diff = false
		}
	}

	// 同步设备数据到saas 已迁移至saas-service
	//if config.SaasConf.Url != "" {
	//	body := util.Struct2Map(i)
	//	url := "http://" + config.SaasConf.Url + "/data/api-d/device/syncDevToCloud"
	//
	//	header := map[string]string{
	//		"Authorization": tokenForSaas,
	//	}
	//	data, err := util.DoPostRequest(url, util.CONTENT_TYPE_JSON, body, nil, header, 10*time.Second)
	//	if err != nil {
	//		logger.Error("send devInfo to saas cloud err:", err, string(data))
	//	} else {
	//		logger.Debug("syncDevToCloud to saas result:", string(data))
	//		var result bhomedbapi.Result
	//		err = json.Unmarshal(data, &result)
	//		if err != nil {
	//			logger.Error("unmarshal err:", err)
	//		}
	//	}
	//}

	if diff {
		// 同步设备信息到商城
		if util.GetShopUrl() != "" {
			body := util.Struct2Map(i)
			url := "http://" + util.GetShopUrl() + "/data/api-d/device/syncDevToCloud"
			header := map[string]string{
				"Authorization": token,
			}
			data, err := util.DoPostRequest(url, util.CONTENT_TYPE_JSON, body, nil, header, 10*time.Second)
			if err != nil {
				logger.Error("send devInfo to cloud err:", err)
				return
			}
			logger.Debug("syncDevToCloud result:", string(data))
			var result bhomedbapi.Result
			err = json.Unmarshal(data, &result)
			if err != nil {
				logger.Error("unmarshal err:", err)
				return
			}
			if result.Success {
				lstSync = &i
			} else {
				logger.Error("syncDevToCloud result:", result)
			}
		}

		//查看是否有管理节点管理着此台设备
		syncToDevManager(i)

		//需要主动通知serf1更新数据，设备管理app的数据从serf1中获取的

	}
}

func syncToDevManager(info vo.SyncDevInfo) error {
	var ad models.AuthDevice
	managers := ad.FindByStatus(models.AuthStatus_Agreed) //获取已授权的设备列表
	if len(managers) > 0 {
		//写入device,deviceApp及deviceSdk表中通过serf同步到其它节点
		tx := models.GetDB().Begin()
		var err error
		defer func() {
			if err != nil && tx != nil {
				logger.Debug("syncToDevManager err:", err)
				tx.Rollback()
			}
		}()
		var dE models.Device
		dc, e := dE.FindByDevId(info.Detail.ServerId)
		if e == nil && dc > 0 { //已存在则更新
			cd := vo.Copy2DeviceModel(info.Detail)
			cd.Id = dE.Id
			cd.ActivateCode = dE.ActivateCode
			cd.ProductId = dE.ProductId
			cd.UserId = dE.UserId
			cd.Address = dE.Address
			cd.DevGpu = dE.DevGpu
			cd.InstallTime = dE.InstallTime
			cd.FirstUseTime = dE.FirstUseTime
			cd.ClusterId = dE.ClusterId
			cd.ClusterName = dE.ClusterName
			cd.Status = dE.Status
			cd.CreateTime = dE.CreateTime
			cd.UpdateTime = dE.UpdateTime
			if err = tx.Table(cd.TableName()).Save(&cd).Error; err != nil {
				return err
			}
		} else { //创建
			cd := vo.Copy2DeviceModel(info.Detail)
			cd.Id = uuid.NewV4().String()
			if err = tx.Table(cd.TableName()).Create(&cd).Error; err != nil {
				return err
			}
		}
		if len(info.Apps) > 0 {
			for _, a := range info.Apps {
				var da models.DeviceApp
				if row, _ := da.Exist(config.Server.AnalyServerId, a.Id); row > 0 {
					da.MachineCode = info.Detail.MachineCode
					da.ExpireTime = ""
					da.ActivateCode = ""
					da.InstallTime = ""
					if err = tx.Table(da.TableName()).Where("id=?", da.Id).Update(&da).Error; err != nil {
						return err
					}
				} else {
					tmp := models.DeviceApp{
						Id:           uuid.NewV4().String(),
						DevId:        config.Server.AnalyServerId,
						MachineCode:  info.Detail.MachineCode,
						ActivateCode: "",
						AppId:        a.Id,
						ExpireTime:   "",
						InstallTime:  "",
					}
					if err = tx.Table(tmp.TableName()).Create(&tmp).Error; err != nil {
						return err
					}
				}
			}
		}
		if len(info.Sdks) > 0 {
			for _, s := range info.Sdks {
				var ds models.DeviceSdk
				if row, _ := ds.Exist(config.Server.AnalyServerId, s.Id); row > 0 {
					ds.MachineCode = info.Detail.MachineCode
					ds.ExpireTime = ""
					ds.ActivateCode = ""
					ds.InstallTime = ""
					if err = tx.Table(ds.TableName()).Where("id=?", ds.Id).Update(&ds).Error; err != nil {
						return err
					}
				} else {
					tmp := models.DeviceSdk{
						Id:           uuid.NewV4().String(),
						DevId:        config.Server.AnalyServerId,
						MachineCode:  info.Detail.MachineCode,
						ActivateCode: "",
						SdkId:        s.Id,
						ExpireTime:   "",
						InstallTime:  "",
					}
					if err = tx.Table(tmp.TableName()).Create(&tmp).Error; err != nil {
						return err
					}
				}
			}
		}

		tx.Commit()
		return nil
	}
	return nil
}

//计算持续时长
func timeSpan(startTime time.Time) string {
	sp := time.Since(startTime)
	day := strconv.Itoa(int(sp.Hours() / 24))      //天数
	hour := strconv.Itoa(int(sp.Hours()) % 24)     //小时数
	minute := strconv.Itoa(int(sp.Minutes()) % 60) //分钟数
	sec := strconv.Itoa(int(sp.Seconds()) % 60)    //秒数
	return day + "天" + hour + "时" + minute + "分" + sec + "秒"
}