mqtt引入

qixiaoning

2025-08-26 7799d5acb4a25526625b3e99c2f7fd71d1be39ff

 system-service/service/devInfoSync.go

@@ -155,30 +155,30 @@

   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)
         }
      }
      // 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)
@@ -289,7 +289,7 @@
   return nil
}

//计算持续时长
// 计算持续时长
func timeSpan(startTime time.Time) string {
   sp := time.Since(startTime)
   day := strconv.Itoa(int(sp.Hours() / 24))      //天数