Merge branch 'feat-cjy-tag' into dev

pkg/cron/task.go

@@ -44,7 +44,7 @@ func InitTasks() error {
 	}
 
 	// 每2分钟执行一次标签观看次数更新任务
-	// err = cm.AddTask("updateCastTagWatchCount", "0 */2 * * * *", UpdateCastTagWatchCountTask)
+	err = cm.AddTask("updateCastTagWatchCount", "0 */2 * * * *", UpdateCastTagWatchCountTask)
 	cm.Start()
 
 	// 启动队列消费者
@@ -584,12 +584,6 @@ func UpdateCastTagWatchCountTask() {
 				zap.String("hashTag", tag.HashTag),
 				zap.String("uuid", tag.Uuid),
 				zap.Error(err))
-			// 调用失败时，将WatchCount更新为1，IsWatchCountCalled更新为1
-			updateData = append(updateData, &cast.CastTagInfo{
-				Uuid:               tag.Uuid,
-				WatchCount:         1,
-				IsWatchCountCalled: 1,
-			})
 			continue
 		}