zhangzengfei
2024-10-20 5ddd4f4ba6aaf1fe52f93c0966315d0424bd2a5f
repository/captureRepo.go
@@ -8,9 +8,9 @@
   "gat1400Exchange/client"
   "gat1400Exchange/config"
   "gat1400Exchange/models"
   "gat1400Exchange/nvcs"
   "gat1400Exchange/pkg"
   "gat1400Exchange/pkg/logger"
   "gat1400Exchange/service"
   "gat1400Exchange/util"
   "gat1400Exchange/vo"
)
@@ -214,21 +214,17 @@
   // 判断是否需要匹配楼层
   if config.NVCSConf.Model != "" {
      // 匹配楼层
      var devPos models.Positions
      _ = devPos.FindDevicePosition(deviceId, faceAppearTime.Unix()+5) // 加5秒电梯关门的时间
      floor = devPos.Pos
      runState := nvcs.FindPositionByTime(faceAppearTime.Unix() + 3) // 加3秒电梯关门的时间
      floor = runState.Floor
      for i := 0; i < config.NVCSConf.WaitRunTime; i++ {
         var dbPos models.Positions
         if err := dbPos.FindMovePosition(faceAppearTime.Unix()+5, floor); err == nil {
            switch dbPos.RunDir {
            case service.RunUp:
         if runState = nvcs.FindMovePosition(faceAppearTime.Unix()+3, floor); runState.Floor != "" {
            switch runState.RunState {
            case nvcs.RunUp:
               runDir = "in"
            case service.RunDown:
            case nvcs.RunDown:
               runDir = "out"
            case service.RunStop:
            case nvcs.RunStop:
               runDir = ""
            }
@@ -268,6 +264,7 @@
func (c CaptureRepository) VIIDFaceMsgForward(msg *vo.RequestFaceList) {
   faceInfo := msg.FaceListObject.FaceObject[0]
   var floor, runDir string
   // 判断是否开启了梯控
   if config.NVCSConf.Model != "" {
@@ -278,25 +275,18 @@
         faceAppearTime = time.Now()
      }
      var floor, runDir string
      var devPos models.Positions
      _ = devPos.FindPositionByTime(faceAppearTime.Unix() + 5) // 加5秒电梯关门的时间
      if devPos.Pos == "" {
         devPos.Pos = "1F"
      }
      floor = devPos.Pos
      runState := nvcs.FindPositionByTime(faceAppearTime.Unix() + 3) // 加3秒电梯关门的时间
      floor = runState.Floor
      for i := 0; i < config.NVCSConf.WaitRunTime; i++ {
         var dbPos models.Positions
         if err := dbPos.FindMovePosition(faceAppearTime.Unix()+5, floor); err == nil {
            switch dbPos.RunDir {
            case service.RunUp:
               runDir = "1"
            case service.RunDown:
               runDir = "2"
            case service.RunStop:
               runDir = "0"
         if runState = nvcs.FindMovePosition(faceAppearTime.Unix()+3, floor); runState.Floor != "" {
            switch runState.RunState {
            case nvcs.RunUp:
               runDir = "in"
            case nvcs.RunDown:
               runDir = "out"
            case nvcs.RunStop:
               runDir = ""
            }
            break
@@ -311,7 +301,6 @@
         //   msg.FaceListObject.FaceObject[idx].FaceID = pkg.GenerateFaceIdContainFloor(face.FaceID, devPos.Pos)
         //}
      }
   }
   b, _ := json.Marshal(msg)
@@ -333,14 +322,10 @@
      appearTime = time.Now()
   }
   var devPos models.Positions
   _ = devPos.FindPositionByTime(appearTime.Unix() + 5) // 加5秒电梯关门的时间
   if devPos.Pos == "" {
      devPos.Pos = "1F"
   }
   runState := nvcs.FindPositionByTime(appearTime.Unix() + 3) // 加3秒电梯关门的时间
   for idx, v := range msg.PersonListObject.PersonObject {
      msg.PersonListObject.PersonObject[idx].BehaviorDescription = devPos.Pos
   for idx, _ := range msg.PersonListObject.PersonObject {
      msg.PersonListObject.PersonObject[idx].BehaviorDescription = runState.Floor
      //if config.ClientConf.AddFloorToFaceId {
      //   msg.PersonListObject.PersonObject[idx].PersonID = pkg.GenerateFaceIdContainFloor(v.PersonID, devPos.Pos)
      //}