天然气定时任务

services/task.go

@@ -18,8 +18,10 @@ func Task() {
 	//time.Sleep(20 * time.Second)
 	//SyncRankingFromDalianDo()
 	//SyncStorageFromEic()
-	refreshData := task.NewTask("refreshData", "0 */30 16-20 * * *", RefreshData)
+	refreshData := task.NewTask("refreshData", "0 0,30 16-20 * * *", RefreshData)
+	refreshEic := task.NewTask("refreshData", "0 0 1,6 * * *", RefreshEic)
 	task.AddTask("数据爬取", refreshData)
+	task.AddTask("欧洲天然气爬取", refreshEic)
 	task.StartTask()
 	fmt.Println("end crawler")
 }
@@ -35,3 +37,8 @@ func RefreshData(cont context.Context) (err error) {
 	
 	return
 }
+
+func RefreshEic(cont context.Context) (err error) {
+	SyncStorageFromEic()
+	return
+}