更新设备操作

zhangzengfei

2024-05-18 3771d5551480964ab17f4c23a152df2482bf6470

 service/nvcs.go

@@ -7,6 +7,7 @@
   "io/ioutil"
   "net"
   "strings"
   "time"

   "gat1400Exchange/config"
   "gat1400Exchange/models"
@@ -75,12 +76,12 @@
      decodedBytes, err := ioutil.ReadAll(reader)

      var data ElevatorData
      // Unmarshal JSON into the struct
      err = json.Unmarshal(decodedBytes, &data)
      if err != nil {
         logger.Warn("ElevatorData unmarshal error:%s", err.Error())
         continue
      }
      logger.Debug("Received %d bytes from %s, %+v", numBytes, clientAddr, data)

      if len(data.Elevator) == 0 {
         continue
@@ -100,20 +101,17 @@
         }
      }

      var d = models.Device{
         Id:    elevator.Name,
         Floor: elevator.Status.FloorName,
         Ip:    elevator.IP,
      var d = models.Positions{
         DeviceId:   elevator.Name,
         Pos:        elevator.Status.FloorName,
         CreateTime: time.Now().Unix(),
         TimeString: time.Now().Format("2006-01-02 15:04:05"),
      }

      err = d.Upsert()
      err = d.Save()
      if err != nil {
         logger.Warn("Device db update error:%s", err.Error())
         logger.Warn("Device position update error:%s", err.Error())
      }

      deviceAliveCache.Add(elevator.Name, true)

      logger.Debug("Received %d bytes from %s, %+v", numBytes, clientAddr, data)
   }
}