From ccf217b3214bb65c6d622c40ecf7685c5dba297f Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwei@kingsome.cn>
Date: Fri, 14 Jun 2024 15:17:00 +0800
Subject: [PATCH] 1

---
 server/marketserver/task/taskmgr.go | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/server/marketserver/task/taskmgr.go b/server/marketserver/task/taskmgr.go
index 28ae5d96..a1dd893c 100644
--- a/server/marketserver/task/taskmgr.go
+++ b/server/marketserver/task/taskmgr.go
@@ -12,14 +12,14 @@ type taskMgr struct {
 }
 
 func (this* taskMgr) Init() {
-	go this.syncOrderUpdatedEvent(constant.ORDER_UPDATE_EVENT)
+	go this.loadWebHookEvent(constant.ORDER_UPDATE_EVENT)
 }
 
 func (this* taskMgr) UnInit() {
 
 }
 
-func (this* taskMgr) syncOrderUpdatedEvent(eventName string) {
+func (this* taskMgr) loadWebHookEvent(eventName string) {
 	var lastSyncIdx = this.getLastIdx(eventName)
 	for true {
 		if lastSyncIdx < 0 {
@@ -28,7 +28,15 @@ func (this* taskMgr) syncOrderUpdatedEvent(eventName string) {
 				continue
 			}
 		} else {
+			f5.GetGoStyleDb().RawQuery(
+				constant.BCEVENT_DB,
+				"SELECT * FROM t_webhook_process_last_idx WHERE idx > ?",
+				[]string{
+					q5.ToString(lastSyncIdx),
+				},
+				func (err error, ds *f5.DataSet) {
 
+				})
 		}
 		time.Sleep(time.Second * 3)
 	}