ソースを参照

修改定时任务

tuoling805 1 年間 前
コミット
996a9cc5df
2 ファイル変更4 行追加3 行削除
  1. 2 2
      init_serve/task.go
  2. 2 1
      services/index_merge_v2.go

+ 2 - 2
init_serve/task.go

@@ -30,7 +30,7 @@ func InitTask() {
 	//	panic("DownloadCvTask err" + err.Error())
 	//}
 
-	_, err = c.AddFunc("0 0 17 * * *", services.MergeV2)
+	_, err = c.AddFunc("0 47 17 * * *", services.MergeV2)
 	//_, err = c.AddFunc("0 */10 * * * *", services.IndexRefreshAll)
 	if err != nil {
 		global.LOG.Info("DownloadCvTask err" + err.Error())
@@ -78,7 +78,7 @@ func InitTask() {
 	go watch.ListenFolderNewMerge()
 
 	//redis 队列刷新指标
-	go services.AutoRefresh()
+	//go services.AutoRefresh()
 
 	//CheckIndexCreate()
 	fmt.Println("start services.Merge")

+ 2 - 1
services/index_merge_v2.go

@@ -32,7 +32,7 @@ func MergeV2() {
 	//日度
 	IndexDayMergeV2()
 	//周度
-	IndexWeekMergeV2()
+	//IndexWeekMergeV2()
 	fmt.Println("MergeV2 end")
 }
 
@@ -158,5 +158,6 @@ func indexMergeV2(frequency, startDate, endDate, filePre string, pageSize int) (
 	}
 	templateFile.Close()
 	time.Sleep(1 * time.Second)
+	MysteelChemicalRefresh(mergeIndexFilePath)
 	return
 }