package service

import (
	"encoding/json"
	"vamicro/saas-service/service/nodeService"

	"basic.com/valib/bhomeclient.git"
	"basic.com/valib/go-aiot.git/aiotProto/aiot"
	"basic.com/valib/go-aiot.git/client"
	"basic.com/valib/logger.git"
)

// 同步设备信息
func syncDeviceInfo(cli *client.Client) {
	// 获取设备详情信息
	deviceList := nodeService.Node.NodeLists
	logger.Debugf("syncDeviceInfo len(deviceList)=%v", len(deviceList))
	if deviceList == nil {
		return
	}
	for _, node := range deviceList {
		// 获取设备信息
		topic := "/data/api-v/sysset/getDeviceInfo"
		param := make(map[string]interface{})
		data, err := DoBusReq(topic, node.Id, aiot.RequestMethod_Post, aiot.RequestContentType_ApplicationJson, param)
		if err != nil {
			logger.Errorf("fail to do bus request topic=%v, err=%v", topic, err)
			// 查询错误
			continue
		}
		dataResp := bhomeclient.Reply{}
		err = json.Unmarshal(data, &dataResp)
		if err != nil {
			logger.Errorf("fail to Unmarshal topic=%v, err=%v", topic, err)
			return
		}
		if dataResp.Data == nil {
			logger.Errorf("fail to do bus request topic=%v, data=%v", topic, dataResp)
			return
		}
		if !dataResp.Success {
			logger.Errorf("getDeviceInfo dataResp.Success is false, data=%v", string(data))
			return
		}
		dataRes := dataResp.Data.(map[string]interface{})
		if dataResp.Success != true {
			logger.Errorf("topic error topic=%v, dataResp=%v", topic, dataResp)
			return
		}
		// 整理数据
		deviceDataReport := make(map[string]interface{})
		deviceDataReport["detail"] = dataRes["detail"]

		// 解码sdk信息
		type sdkStruct struct {
			Id         string `json:"id"`
			UpdateTime string `json:"update_time"`
			Version    string `json:"version"`
		}
		sdkJson, _ := json.Marshal(dataRes["sdks"])
		sdkList := make([]sdkStruct, 0)
		err = json.Unmarshal(sdkJson, &sdkList)
		deviceDataReport["sdks"] = sdkList

		// 整理APP信息
		type appStruct struct {
			Id      string `json:"id"`
			Version string `json:"version"`
		}
		appJson, _ := json.Marshal(dataRes["apps"])
		appList := make([]appStruct, 0)
		err = json.Unmarshal(appJson, &appList)
		deviceDataReport["apps"] = appList

		deviceData, _ := json.Marshal(deviceDataReport)
		report := aiot.DataReport{
			DataKey: DeviceSdkAppDataReport,
			Data:    deviceData,
		}
		logger.Debugf("syncDeviceInfo data=%v, dataKey=%v", string(deviceData), report.DataKey)
		reportData, _ := json.Marshal(report)
		syncData := &aiot.Protocol{
			Receiver: aiot.RECEIVER_TO_SAAS,
			SenderId: node.Id,
			MsgType:  aiot.MSG_TYPE_DATA_REPORT,
			ReqType:  aiot.REQ_TYPE_REQUEST,
			MsgProto: client.GetMsgProto(""),
			Data:     reportData,
		}

		//logger.Warn("sync device", syncData)
		// 上报集群数据
		_ = cli.WriteBody(syncData)
	}
}