浏览代码

列表页异常任务逻辑修改

maxiaoshan 2 年之前
父节点
当前提交
73fca2e4e9
共有 2 个文件被更改,包括 4 次插入4 次删除
  1. 1 1
      src/luatask/task.go
  2. 3 3
      src/main.go

+ 1 - 1
src/luatask/task.go

@@ -2113,7 +2113,7 @@ func CreateTaskProcess() {
 							limitDayNum = -1
 						}
 						//if !spider.ListIsFilter || (spider.FindListHeart < util.GetTime(limitDayNum) && spider.ListIsFilter) { //列表页不含过滤代码或者有过滤无心跳
-						if spider.FindListHeart < util.GetTime(limitDayNum) { //最近心跳判断为异常
+						if spider.FindListHeart < util.GetTime(limitDayNum) || !spider.ListIsFilter { //最近心跳判断为异常
 							task.State = 1 //待处理
 							task.ErrType = TASK_LISTERR
 							task.DescribeMap[TASK_LISTERR] = "列表页异常:\n 列表页共采集" + fmt.Sprint(spider.ListDownloadAllTimes) + "轮,其中有" + fmt.Sprint(spider.ListNoDataTimes) + "轮无数据\n"

+ 3 - 3
src/main.go

@@ -48,9 +48,9 @@ func main() {
 	//
 	c.AddFunc(util.QyworkRemindModifyuserCron, timetask.SendInfoToWxWork_Tomodifyuser) //企业微信日常警告,爬虫开发人员告警信息
 	c.AddFunc(util.QyworkRemindAuditorCron, timetask.SendInfoToWxWork_ToAuditor)       //企业微信日常警告,审核人员告警信息
-	c.AddFunc(util.UpdateLuaUserCron, timetask.UpdateLuaUser)                          //更新外包爬虫所属人
-	c.AddFunc(util.MoveListDataCron, timetask.MoveListData)                            //列表页数据迁移
-	c.AddFunc(util.UpdateSiteCron, timetask.UpdateSiteInfo)                            //站点信息更新
+	//c.AddFunc(util.UpdateLuaUserCron, timetask.UpdateLuaUser)                          //更新外包爬虫所属人
+	c.AddFunc(util.MoveListDataCron, timetask.MoveListData) //列表页数据迁移
+	c.AddFunc(util.UpdateSiteCron, timetask.UpdateSiteInfo) //站点信息更新
 	//爬虫任务
 	c.AddFunc(util.ResetDataStateCron, luatask.ResetDataState) //重置数据
 	c.AddFunc(util.StartTaskCron, luatask.StartTask)           //爬虫维护任务