|
@@ -10,7 +10,7 @@ func Task() {
|
|
|
fmt.Println("start crawler")
|
|
|
refreshData := task.NewTask("refreshData", "0 0,30 16-20 * * *", RefreshData)
|
|
|
refreshEic := task.NewTask("refreshData", "0 0 1,6 * * *", RefreshEic)
|
|
|
- refreshCoal := task.NewTask("refreshData", "0 41 15 * * *", RefreshCoal)
|
|
|
+ refreshCoal := task.NewTask("refreshData", "0 0 16 * * *", RefreshCoal)
|
|
|
task.AddTask("数据爬取", refreshData)
|
|
|
task.AddTask("欧洲天然气爬取", refreshEic)
|
|
|
task.AddTask("中国煤炭网爬取", refreshCoal)
|
|
@@ -41,7 +41,7 @@ func RefreshEic(cont context.Context) (err error) {
|
|
|
|
|
|
func RefreshCoal(cont context.Context) (err error) {
|
|
|
FileCoalJsm()
|
|
|
- //FileCoalFirm()
|
|
|
+ FileCoalFirm()
|
|
|
FileCoalCoastal()
|
|
|
FileCoalInland()
|
|
|
return
|