replace json to json-iterator

zhangmeng

2024-01-19 01dfd9dc8de7b19f9dfa4284722e01bbd5837801

 deviceCtlApi.go

@@ -2,14 +2,13 @@

import (
   "basic.com/valib/c_bhomebus.git/proto/source/bhome_msg"
   json "github.com/json-iterator/go"
   jsoniter "github.com/json-iterator/go"
)

type DeviceCtlApi struct {

}

func (api DeviceCtlApi) DevAuthApply(targetIp string, fromDevId string, fromIp string, key string) (bool,interface{}) {
func (api DeviceCtlApi) DevAuthApply(targetIp string, fromDevId string, fromIp string, key string) (bool, interface{}) {
   url := DATA_URL_PREFIX + "/devAuth/apply"
   dest := &bhome_msg.BHAddress{
      Ip: []byte(targetIp),
@@ -19,22 +18,23 @@
   })

   client := NewClient(WithNodes(netNode))
   paramBody := map[string]interface{} {
   paramBody := map[string]interface{}{
      "key":       key,
      "fromDevId": fromDevId,
      "fromIp":    fromIp,
   }
   body,err := client.DoPutRequest(url,CONTENT_TYPE_JSON, paramBody,nil)
   body, err := client.DoPutRequest(url, CONTENT_TYPE_JSON, paramBody, nil)
   if err != nil {
      return false,nil
      return false, nil
   }

   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false,nil
      return false, nil
   }

   return res.Success,res.Data
   return res.Success, res.Data
}

func (api DeviceCtlApi) DevDetail(targetIp string, devId string) (bool, interface{}) {
@@ -47,21 +47,22 @@
      Addr: dest,
   })

   paramQuery := map[string]string {
   paramQuery := map[string]string{
      "devId": devId,
   }
   client := NewClient(WithNodes(netNode))
   body,err := client.DoGetRequest(url,paramQuery,nil)
   body, err := client.DoGetRequest(url, paramQuery, nil)
   if err != nil {
      return false,nil
      return false, nil
   }

   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false,nil
      return false, nil
   }

   return res.Success,res.Data
   return res.Success, res.Data
}

//控制其他节点创建集群
@@ -76,17 +77,18 @@

   client := NewClient(WithNodes(netNode))

   body,err := client.DoPutRequest(url,CONTENT_TYPE_JSON, paramBody,nil)
   body, err := client.DoPutRequest(url, CONTENT_TYPE_JSON, paramBody, nil)
   if err != nil {
      return false,nil
      return false, nil
   }

   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false,nil
      return false, nil
   }

   return res.Success,res.Data
   return res.Success, res.Data
}

//控制其他节点搜索集群
@@ -101,17 +103,18 @@

   client := NewClient(WithNodes(netNode))

   body,err := client.DoPutRequest(url,CONTENT_TYPE_JSON, paramBody,nil)
   body, err := client.DoPutRequest(url, CONTENT_TYPE_JSON, paramBody, nil)
   if err != nil {
      return false,nil
      return false, nil
   }

   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false,nil
      return false, nil
   }

   return res.Success,res.Data
   return res.Success, res.Data
}

//获取远程设备搜索到集群节点列表
@@ -126,17 +129,18 @@

   client := NewClient(WithNodes(netNode))

   body,err := client.DoPutRequest(url,CONTENT_TYPE_JSON, paramBody,nil)
   body, err := client.DoPutRequest(url, CONTENT_TYPE_JSON, paramBody, nil)
   if err != nil {
      return false,nil
      return false, nil
   }

   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false,nil
      return false, nil
   }

   return res.Success,res.Data
   return res.Success, res.Data
}

//控制其他节点设备加入集群
@@ -151,17 +155,18 @@

   client := NewClient(WithNodes(netNode))

   body,err := client.DoPutRequest(url,CONTENT_TYPE_JSON, paramBody,nil)
   body, err := client.DoPutRequest(url, CONTENT_TYPE_JSON, paramBody, nil)
   if err != nil {
      return false,nil
      return false, nil
   }

   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false,nil
      return false, nil
   }

   return res.Success,res.Data
   return res.Success, res.Data
}

//远程控制设备重启
@@ -175,20 +180,19 @@
   })

   client := NewClient(WithNodes(netNode))
   paramBody := map[string]interface{} {

   }
   body,err := client.DoPutRequest(url,CONTENT_TYPE_JSON, paramBody,nil)
   paramBody := map[string]interface{}{}
   body, err := client.DoPutRequest(url, CONTENT_TYPE_JSON, paramBody, nil)
   if err != nil {
      return false,nil
      return false, nil
   }

   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false,nil
      return false, nil
   }

   return res.Success,res.Data
   return res.Success, res.Data
}

//远程控制算法或应用卸载
@@ -202,20 +206,21 @@
   })

   client := NewClient(WithNodes(netNode))
   paramBody := map[string]interface{} {
   paramBody := map[string]interface{}{
      "id": id,
   }
   body,err := client.DoPostRequest(url,CONTENT_TYPE_JSON, paramBody, nil,nil)
   body, err := client.DoPostRequest(url, CONTENT_TYPE_JSON, paramBody, nil, nil)
   if err != nil {
      return false,nil
      return false, nil
   }

   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false,nil
      return false, nil
   }

   return res.Success,res.Data
   return res.Success, res.Data
}

//远程控制设备系统更新
@@ -230,16 +235,16 @@

   client := NewClient(WithNodes(netNode))

   body,err := client.DoPutRequest(url,CONTENT_TYPE_JSON, nil,nil)
   body, err := client.DoPutRequest(url, CONTENT_TYPE_JSON, nil, nil)
   if err != nil {
      return false,nil
      return false, nil
   }

   var res Result
   var json = jsoniter.ConfigCompatibleWithStandardLibrary
   if err = json.Unmarshal(body, &res); err != nil {
      return false,nil
      return false, nil
   }

   return res.Success,res.Data
   return res.Success, res.Data
}