From ca23925796e7ecd50cab2cf12b8ed827d2185f24 Mon Sep 17 00:00:00 2001 From: orgin Date: Fri, 25 Nov 2022 11:45:35 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=8C=81=E4=B9=85=E5=8C=96?= =?UTF-8?q?=E5=AD=98=E5=82=A8=E6=A8=A1=E5=9D=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sysservice/messagequeueservice/MongoPersist.go | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/sysservice/messagequeueservice/MongoPersist.go b/sysservice/messagequeueservice/MongoPersist.go index 93f0419..f2f5933 100644 --- a/sysservice/messagequeueservice/MongoPersist.go +++ b/sysservice/messagequeueservice/MongoPersist.go @@ -123,7 +123,6 @@ func (mp *MongoPersist) OnReceiveTopicData(topic string, topicData []TopicData) // OnPushTopicDataToCustomer 当推送数据到Customer时回调 func (mp *MongoPersist) OnPushTopicDataToCustomer(topic string, topicData []TopicData) { - } // PersistTopicData 持久化数据 @@ -148,10 +147,15 @@ func (mp *MongoPersist) persistTopicData(collectionName string, topicData []Topi return retryCount >= mp.retryCount } - //log.SRelease("+++++++++====", time.Now().UnixNano()) return true } +func (mp *MongoPersist) IsSameDay(timestamp1 int64,timestamp2 int64) bool{ + t1 := time.Unix(timestamp1, 0) + t2 := time.Unix(timestamp2, 0) + return t1.Year() == t2.Year() && t1.Month() == t2.Month()&&t1.Day() == t2.Day() +} + // PersistTopicData 持久化数据 func (mp *MongoPersist) PersistTopicData(topic string, topicData []TopicData, retryCount int) ([]TopicData, bool) { if len(topicData) == 0 { @@ -163,7 +167,7 @@ func (mp *MongoPersist) PersistTopicData(topic string, topicData []TopicData, re for findPos = 1; findPos < len(topicData); findPos++ { newDate := topicData[findPos].Seq >> 32 //说明换天了 - if preDate != newDate { + if mp.IsSameDay(int64(preDate),int64(newDate)) == false { break } }