maxiaoshan 3 éve
szülő
commit
1032243f6a
4 módosított fájl, 6 hozzáadás és 3 törlés
  1. 2 1
      src/config.json
  2. 1 2
      src/luatask/task.go
  3. 1 0
      src/main.go
  4. 2 0
      src/util/config.go

+ 2 - 1
src/config.json

@@ -81,7 +81,8 @@
 			"work": 1
 		}
 	},
-    "startaskcron": "0 0 1 ? * MON-FRI",
+	"resetdatastatecron": "0 0 1 ? * MON-FRI",
+    "startaskcron": "0 0 8 ? * MON-FRI",
 	"codesummarycron": "0 30 8 ? * *",
 	"randomdatapushcron": "0 50 8 ? * MON-FRI",
 	"qyworkremindcron": "0 0 9 ? * MON-FRI",

+ 1 - 2
src/luatask/task.go

@@ -144,8 +144,7 @@ var (
 )
 
 func StartTask() {
-	ResetDataState() //更新数据状态
-	InitInfo()       //初始化时间
+	InitInfo() //初始化时间
 	logger.Debug(StartTime, EndTime)
 	GetCodeBaseInfo()              //初始化爬虫基本信息
 	GetSpiderHighListDownloadNum() //统计spider_highlistdata爬虫列表页下载量、下载失败量、未下载量

+ 1 - 0
src/main.go

@@ -41,6 +41,7 @@ func main() {
 	c.Start()
 	c.AddFunc(util.RandomDataPushCron, timetask.GetSpiderWarnData) //数据维护平台-爬虫数据维护数据数据统计
 	c.AddFunc(util.QyworkRemindCron, timetask.SendInfoToWxWork)    //企业微信日常警告
+	c.AddFunc(util.ResetDataStateCron, luatask.ResetDataState)     //重置数据
 	c.AddFunc(util.StartTaskCron, luatask.StartTask)               //开始任务
 	//c.AddFunc(CodeSummaryCron, SummaryCode)    //上架爬虫信息汇总
 	ch := make(chan bool, 1)

+ 2 - 0
src/util/config.go

@@ -18,6 +18,7 @@ var (
 	QyworkRemindCron   string
 	StartTaskCron      string      //任务开始
 	CodeSummaryCron    string      //每天统计爬虫信息
+	ResetDataStateCron string      //重置数据状态
 	CloseNum           int         //关闭几天的任务
 	DayNum             int         //更新数据天数
 	CodeEventModel     map[int]int //节点对应的采集模式0:老模式;1:新模式
@@ -53,6 +54,7 @@ func InitMgo() {
 func InitOther() {
 	StartTaskCron = qu.ObjToString(Config["startaskcron"])
 	CodeSummaryCron = qu.ObjToString(Config["codesummarycron"])
+	ResetDataStateCron = qu.ObjToString(Config["resetdatastatecron"])
 	RandomDataPushCron = qu.ObjToString(Config["randomdatapushcron"])
 	QyworkRemindCron = qu.ObjToString(Config["qyworkremindcron"])
 	CloseNum = qu.IntAll(Config["closenum"])