用户标签优化

clueSync/tag.go

@@ -23,13 +23,29 @@ func tagAllSync() {
 	log.Println("用户标签定时任务开始")
 	// TiDb.ExecBySql(`SET session max_execution_time=86400`)
 	count := 0
+	now := time.Now()
+	var allUser []map[string]interface{}
+	startOfDay := time.Date(now.Year(), now.Month(), now.Day()-1, 0, 0, 0, 0, now.Location())
 	TiDb.SelectByBath(100, func(l *[]map[string]interface{}) bool {
 		for _, v := range *l {
-			count++
-			FormatTag(v, count)
+			allUser = append(allUser, v)
 		}
 		return true
-	}, `select l_registedate,userid,uid,base_user_id from dwd_f_userbase_baseinfo order by updatetime desc`)
+	}, fmt.Sprintf(`select userid from dwd_f_userbase_visit_info where  createtime>"%s"   order by createtime asc`, startOfDay.Format(time.DateTime)))
+	TiDb.Update("dwd_f_crm_attribute_label", map[string]interface{}{}, map[string]interface{}{
+		"members_info": "昨日未浏览",
+		"updatetime":   time.Now().Format("2006-01-02 15:04:05"),
+	})
+	for _, v := range allUser {
+		count++
+		//查询用户信息
+		userId := common.ObjToString(v["userid"])
+		userData := TiDb.SelectBySql("select l_registedate,userid,uid,base_user_id from dwd_f_userbase_baseinfo where  userid=?", userId)
+		for _, vv := range *userData {
+			FormatTag(vv, count)
+		}
+		log.Println(count)
+	}
 	log.Println("用户标签定时任务结束")
 }
 
@@ -158,7 +174,7 @@ func FormatTag(data map[string]interface{}, count int) {
 	}
 	if len(keyMap) > 0 {
 		keyArr := []string{}
-		for k, _ := range keyMap {
+		for k := range keyMap {
 			keyArr = append(keyArr, k)
 		}
 		keyStr = strings.Join(keyArr, ",")