|
@@ -21,7 +21,7 @@ const (
|
|
|
customDataCacheTimeLong = 60 * 60 * 24 * 31
|
|
|
)
|
|
|
|
|
|
-//CustomManager 定制化报告管理
|
|
|
+// CustomManager 定制化报告管理
|
|
|
type CustomManager struct {
|
|
|
Conf vars.CustomConfig
|
|
|
UserGroup map[string]int // 月活用户
|
|
@@ -79,7 +79,7 @@ func (this *CustomManager) GetData(userId, keyWords string, isNew bool) map[stri
|
|
|
return nil
|
|
|
}
|
|
|
|
|
|
-//ScheduledTasks 定时任务
|
|
|
+// ScheduledTasks 定时任务
|
|
|
func (this *CustomManager) ScheduledTasks() {
|
|
|
if this.Conf.UpdateCron != "" {
|
|
|
// 给对象增加定时任务
|
|
@@ -91,7 +91,7 @@ func (this *CustomManager) ScheduledTasks() {
|
|
|
this.UpdateUserGroupJob()
|
|
|
}
|
|
|
|
|
|
-//UpdateUserGroupJob 更新用户群组
|
|
|
+// UpdateUserGroupJob 更新用户群组
|
|
|
func (this *CustomManager) UpdateUserGroupJob() {
|
|
|
//查询月活用户
|
|
|
userMap := activeUsers.GetMonthActiveFreeUsers()
|
|
@@ -110,7 +110,7 @@ func (this *CustomManager) UpdateUserGroupJob() {
|
|
|
go this.activityUserQueue(batchFlag, []string{})
|
|
|
}
|
|
|
|
|
|
-//activityUserQueue 活跃用户查询队列
|
|
|
+// activityUserQueue 活跃用户查询队列
|
|
|
func (this *CustomManager) activityUserQueue(batchFlag string, userIds []string) {
|
|
|
for i, userId := range userIds {
|
|
|
if i%100 == 0 {
|
|
@@ -128,7 +128,7 @@ func (this *CustomManager) activityUserQueue(batchFlag string, userIds []string)
|
|
|
log.Printf("[INFO]CustomManager Batch %s Is Finished !!!\n", batchFlag)
|
|
|
}
|
|
|
|
|
|
-//DoSearch 定制化分析报告查询队列
|
|
|
+// DoSearch 定制化分析报告查询队列
|
|
|
func (this *CustomManager) DoSearch() {
|
|
|
for {
|
|
|
var obj *SearchEntity
|
|
@@ -141,7 +141,7 @@ func (this *CustomManager) DoSearch() {
|
|
|
}
|
|
|
}
|
|
|
//查询结果处理
|
|
|
- data, err := search.PotentialCustomizeAnalysis(obj.UserId, obj.Value)
|
|
|
+ data, err := search.PotentialCustomizeAnalysis(obj.UserId)
|
|
|
if err != nil {
|
|
|
log.Printf("[ERROR]CustomManager %s DoSearch %s Error %v\n", obj.UserId, obj.Value, err)
|
|
|
}
|
|
@@ -156,7 +156,7 @@ func (this *CustomManager) DoSearch() {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-//checkActivityUser 校验用户是否是活跃用户
|
|
|
+// checkActivityUser 校验用户是否是活跃用户
|
|
|
func (this *CustomManager) checkActivityUser(userId string) (exists bool) {
|
|
|
this.RLock()
|
|
|
defer this.RUnlock()
|