From f2f7354ad14b2081e0923b2c002ecb70bfd41208 Mon Sep 17 00:00:00 2001
From: shoopea <shoopea@siteop.biz>
Date: Sat, 27 Jun 2020 14:06:21 +0200
Subject: [PATCH] test

---
 job.go     | 4 ----
 workers.go | 9 +++++++++
 2 files changed, 9 insertions(+), 4 deletions(-)

diff --git a/job.go b/job.go
index 7a9219e..c86feca 100644
--- a/job.go
+++ b/job.go
@@ -692,10 +692,6 @@ func jobMsgRefresh(j Job) {
 		err = setJobDone(j.ID64)
 		logOnError(err, "joMsgClient : setJobDone")
 		return
-	} else {
-		err = setJobDone(j.ID64)
-		logOnError(err, "joMsgClient : setJobDone")
-		return
 	}
 
 	err = delObj(p.ObjID64)
diff --git a/workers.go b/workers.go
index 2ee9e63..653466e 100644
--- a/workers.go
+++ b/workers.go
@@ -500,6 +500,15 @@ func SQLIdentifyMsgWorker(id int, objIds <-chan int64) {
 						cwm, err := parseSubTypeMessageTimeAck(m, rule.re)
 						logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_time_ack`]")
 						err = insertMsgTimeAck(cwm)
+						logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : insertMsgTimeAck")
+						if cwm.RealTime.After(m.Date.Add(5*time.Minute)) || cwm.RealTime.Before(m.Date.Add(5*time.Minute)) {
+							w := TGCommand{
+								Type:       commandSendMsg,
+								Text:       fmt.Sprintf("Date drifting %v => %v\n", m.Date, cwm.RealTime-m.Date),
+								ToUserID64: cfg.Bot.Admin,
+							}
+							TGCmdQueue <- w
+						}
 					case cacheObjSubType[`msg_orderbook_acl`]:
 						_, err := parseSubTypeMessageOrderbookAck(m, rule.re)
 						logOnError(err, "SQLIdentifyMsgWorker["+strconv.Itoa(id)+"] : Parsing cacheObjSubType[`msg_orderbook_acl`]")