debug osd

zhangzengfei

2024-10-20 4f04056f8b70a467fe17cd989f284b5d23d34ed4

debug osd

 nvcs/a1.go

@@ -223,6 +223,6 @@
        //    RunningCorrectTaskId = ""
        //}

        queue.enqueue(runState)
        queue.put(runState)
    }
}

 nvcs/a2.go

@@ -110,7 +110,7 @@
            RunState:  iRunState,
        }

        queue.enqueue(runState)
        queue.put(runState)

        c.JSON(http.StatusOK, "ok")
    })

 nvcs/a3.go

@@ -45,7 +45,7 @@
            RunState:  req.Status,
        }

        queue.enqueue(runState)
        queue.put(runState)

        c.JSON(http.StatusOK, "ok")
    })

 nvcs/cache.go

@@ -41,8 +41,6 @@
        }
    }

    c.data.PushBack(data)

    // 数据库保存一份
    go func() {
        var d = models.Positions{

 nvcs/nvcs.go

@@ -55,7 +55,7 @@

func listenQueue() {
    for {
        data := queue.dequeue()
        data := queue.get()
        cache.store(data)

        // 清理过期数据

 nvcs/queue.go

@@ -10,11 +10,11 @@
    }
}

func (q *chQueue) enqueue(data elevatorRunData) {
func (q *chQueue) put(data elevatorRunData) {
    q.data <- data
}

func (q *chQueue) dequeue() elevatorRunData {
func (q *chQueue) get() elevatorRunData {
    data := <-q.data
    return data
}