Ma/origin
1
0
Fork 0
mirror of https://github.com/duanhf2012/origin.git synced 2026-02-04 06:54:45 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

优化持久化存储模块

Browse Source
This commit is contained in:
orgin
2022-11-25 11:45:35 +08:00
parent afb04cac7f
commit ca23925796
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
sysservice/messagequeueservice/MongoPersist.go
View File

@@ -123,7 +123,6 @@ func (mp *MongoPersist) OnReceiveTopicData(topic string, topicData []TopicData)
// OnPushTopicDataToCustomer 当推送数据到Customer时回调 // OnPushTopicDataToCustomer 当推送数据到Customer时回调
func (mp *MongoPersist) OnPushTopicDataToCustomer(topic string, topicData []TopicData) { func (mp *MongoPersist) OnPushTopicDataToCustomer(topic string, topicData []TopicData) {
} }
// PersistTopicData 持久化数据 // PersistTopicData 持久化数据
@@ -148,10 +147,15 @@ func (mp *MongoPersist) persistTopicData(collectionName string, topicData []Topi
return retryCount >= mp.retryCount return retryCount >= mp.retryCount
} }
//log.SRelease("+++++++++====", time.Now().UnixNano())
return true 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 持久化数据 // PersistTopicData 持久化数据
func (mp *MongoPersist) PersistTopicData(topic string, topicData []TopicData, retryCount int) ([]TopicData, bool) { func (mp *MongoPersist) PersistTopicData(topic string, topicData []TopicData, retryCount int) ([]TopicData, bool) {
if len(topicData) == 0 { if len(topicData) == 0 {
@@ -163,7 +167,7 @@ func (mp *MongoPersist) PersistTopicData(topic string, topicData []TopicData, re
for findPos = 1; findPos < len(topicData); findPos++ { for findPos = 1; findPos < len(topicData); findPos++ {
newDate := topicData[findPos].Seq >> 32 newDate := topicData[findPos].Seq >> 32
//说明换天了 //说明换天了
if preDate != newDate { if mp.IsSameDay(int64(preDate),int64(newDate)) == false {
break break
} }
} }