no message

services/task.go

@@ -117,7 +117,7 @@ func Task() {
 		task.AddTask("getArticleListByApi", getArticleListByApi)
 	}
 
-	//go UserLabelLogReduce() // 处理用户标签的队列消息
+	go UserLabelLogReduce() // 处理用户标签的队列消息
 	//GetCygxActivityAttendanceDetail()
 	//CreateIndexNameArticleHistory()
 	//AddAllArticleHistory()

services/user_label.go

@@ -348,6 +348,7 @@ func ArticleHistoryUserLabelLogReduce(log models.CygxUserLabelLogRedis) (err err
 	if len(items) > 0 {
 		go AddArticleHistoryUserLabelLog(items, articleId)
 	}
+	updateUserLabelByUserId(userId)
 	return
 }
 
@@ -450,6 +451,7 @@ func IndustryFllowUserLabelLogReduce(log models.CygxUserLabelLogRedis) (err erro
 			}
 		}
 	}
+	updateUserLabelByUserId(userId)
 	return
 }
 
@@ -541,6 +543,7 @@ func ActivityUserLabelLogReduce(log models.CygxUserLabelLogRedis) (err error) {
 			}
 		}
 	}
+	updateUserLabelByUserId(userId)
 	return
 }
 
@@ -610,6 +613,7 @@ func CategoryFllowUserLabelLogReduce(log models.CygxUserLabelLogRedis) (err erro
 			}
 		}
 	}
+	updateUserLabelByUserId(userId)
 	return
 }
 
@@ -701,13 +705,10 @@ func ActivitySpecialUserLabelLogReduce(log models.CygxUserLabelLogRedis) (err er
 			}
 		}
 	}
+	updateUserLabelByUserId(userId)
 	return
 }
 
-//	func init() {
-//		updateUserLabelByUserId(53095)
-//	}
-
 // 更新用户标签
 func updateUserLabelByUserId(userId int) (err error) {
 	defer func() {