From a541cdec15ce70b8eb49d4af42e828af5c01e846 Mon Sep 17 00:00:00 2001
From: liuzhihang1 <liuzhihang1@ruijie.com.cn>
Date: Sat, 15 Feb 2025 21:54:45 +0800
Subject: [PATCH] optimal http wait

---
 internal/app/logic/process_base.go | 1 -
 internal/app/middle/wait.go        | 4 ++--
 utils/utils.go                     | 2 +-
 3 files changed, 3 insertions(+), 4 deletions(-)

diff --git a/internal/app/logic/process_base.go b/internal/app/logic/process_base.go
index 1322b91..bce7d24 100644
--- a/internal/app/logic/process_base.go
+++ b/internal/app/logic/process_base.go
@@ -136,7 +136,6 @@ func (p *ProcessBase) pInit() {
 	go p.watchDog()
 	go p.readInit()
 	go p.monitorHanler()
-	middle.ProcessWaitCond.Trigger()
 }
 
 // fn 函数执行成功的情况下对state赋值
diff --git a/internal/app/middle/wait.go b/internal/app/middle/wait.go
index e586b88..d7c2041 100644
--- a/internal/app/middle/wait.go
+++ b/internal/app/middle/wait.go
@@ -47,8 +47,8 @@ func (p *waitCond) Trigger() {
 
 func (p *waitCond) WaitGetMiddel(c *gin.Context) {
 	reqUser := c.GetHeader("token")
-	if ts, ok := p.timeMap.Load(reqUser); !ok || ts.(int64) < p.ts {
-		p.timeMap.Store(reqUser, p.ts)
+	defer p.timeMap.Store(reqUser, p.ts)
+	if ts, ok := p.timeMap.Load(reqUser); !ok || ts.(int64) > p.ts {
 		c.Next()
 		return
 	}
diff --git a/utils/utils.go b/utils/utils.go
index 02f54df..b85f1e4 100644
--- a/utils/utils.go
+++ b/utils/utils.go
@@ -9,7 +9,7 @@ func Unwarp[T any](result T, err error) T {
 	return result
 }
 
-func UnwarpIgnore[T any](result T, _ error) T {
+func UnwarpIgnore[T any](result T, _ any) T {
 	return result
 }