zhangzengfei
2024-09-13 dbc038d5318d53ac7c14e26386588c48c621a591
service/nvcs.go
@@ -98,9 +98,9 @@
      address := "192.168.10.253:50000"
      err := A1SendFrame(frame, address)
      if err != nil {
         logger.Debug("The floor has been calibrated.")
      } else {
         logger.Warn(err.Error())
      } else {
         logger.Debug("The floor has been calibrated.")
      }
   }
}
@@ -185,6 +185,7 @@
   logger.Info("UDP server listening on port %s...", port)
   var lastFloor int
   // 无限循环等待接收数据
   for {
      // 创建一个缓冲区来存储接收的数据
@@ -216,9 +217,6 @@
      elevator := data.Elevator[0]
      // 记录电梯运行状态
      ElevatorRunState = elevator.Status.RunDir
      var runStateStr string
      if config.NVCSConf.RunState {
         if elevator.Status.RunDir == RunUp {
@@ -241,10 +239,13 @@
      }
      // correct floor when elevator stopped.
      if ElevatorRunState == 0 {
         A1CorrectFloor()
      if elevator.Status.RunDir == 0 {
         go A1CorrectFloor()
      } else {
         RunningCorrectTaskId = ""
         if lastFloor == elevator.Status.Floor {
            continue
         }
      }
      // 程序部署在设备端, 字符叠加器上报的名称允许为空. 在云端, 名称必须与摄像机相同
@@ -252,18 +253,22 @@
         elevator.Name = "1"
      }
      var d = models.Positions{
         DeviceId:   elevator.Name,
         Pos:        elevator.Status.FloorName,
         RunDir:     elevator.Status.RunDir,
         CreateTime: time.Now().Unix(),
         TimeString: time.Now().Format("2006-01-02 15:04:05"),
      }
      lastFloor = elevator.Status.Floor
      err = d.Save()
      if err != nil {
         logger.Warn("Device position update error:%s", err.Error())
      }
      go func() {
         var d = models.Positions{
            DeviceId:   elevator.Name,
            Pos:        elevator.Status.FloorName,
            RunDir:     elevator.Status.RunDir,
            CreateTime: time.Now().Unix(),
            TimeString: time.Now().Format("2006-01-02 15:04:05"),
         }
         err = d.Save()
         if err != nil {
            logger.Warn("Device position update error:%s", err.Error())
         }
      }()
   }
}