内陆地区可用天数单位fix

services/commodity_coal_inland.go

@@ -18,21 +18,21 @@ func FileCoalInland() () {
 			go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "RefreshDataFromCoalInland ErrMsg:"+err.Error(), utils.EmailSendToUsers)
 		}
 	}()
-	//path := "static/file/内陆17省动力煤终端用户供耗存20220322.xlsx"
-	path := "/home/code/python/coal_mail/emailFile/内陆17省动力煤终端用户供耗存%s.xlsx"
-	for i := 0;i < 7;i++{
-		npath := fmt.Sprintf(path,time.Now().AddDate(0,0,-i).Format(utils.FormatDateUnSpace))
-		fmt.Println(npath)
-		exist,err := PathExists(npath)
-		if err != nil {
-			fmt.Println(err)
-			return
-		}
-		if exist{
-			path = npath
-			break
-		}
-	}
+	path := "static/file/内陆17省动力煤终端用户供耗存20220408.xlsx"
+	//path := "/home/code/python/coal_mail/emailFile/内陆17省动力煤终端用户供耗存%s.xlsx"
+	//for i := 0;i < 7;i++{
+	//	npath := fmt.Sprintf(path,time.Now().AddDate(0,0,-i).Format(utils.FormatDateUnSpace))
+	//	fmt.Println(npath)
+	//	exist,err := PathExists(npath)
+	//	if err != nil {
+	//		fmt.Println(err)
+	//		return
+	//	}
+	//	if exist{
+	//		path = npath
+	//		break
+	//	}
+	//}
 	xlFile, err := xlsx.OpenFile(path)
 	if err != nil {
 		fmt.Println(err)
@@ -70,6 +70,13 @@ func FileCoalInland() () {
 
 	for s, sheet := range xlFile.Sheets {
 		sheetName = sheet.Name
+		fmt.Println("sheetName:",sheetName)
+		var unit string
+		if sheetName == "可用天数" {
+			unit = "天"
+		}else {
+			unit = "万吨"
+		}
 		//遍历行读取
 		maxCol := sheet.MaxCol
 		for i := 0; i < maxCol; i++ {
@@ -144,7 +151,7 @@ func FileCoalInland() () {
 							item.GroupName = groupMap[k]
 							item.Source = "内陆十七省"
 							item.DataTime = dataTime
-							item.Unit = "万吨"
+							item.Unit = unit
 							item.Frequency = "日度"
 							item.ModifyTime = time.Now()
 							item.CreateTime = time.Now()

services/task.go

@@ -8,17 +8,17 @@ import (
 
 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 16 17 * * *", RefreshCoal)
-	task.AddTask("数据爬取", refreshData)
-	task.AddTask("欧洲天然气爬取", refreshEic)
-	task.AddTask("中国煤炭网爬取", refreshCoal)
+	//refreshData := task.NewTask("refreshData", "0 0,30 16-20 * * *", RefreshData)
+	//refreshEic := task.NewTask("refreshData", "0 0 1,6 * * *", RefreshEic)
+	//refreshCoal := task.NewTask("refreshData", "0 0 18-23 * * *", RefreshCoal)
+	//task.AddTask("数据爬取", refreshData)
+	//task.AddTask("欧洲天然气爬取", refreshEic)
+	//task.AddTask("中国煤炭网爬取", refreshCoal)
 	task.StartTask()
 	//FileCoalJsm()
 	//FileCoalFirm()
 	//FileCoalCoastal()
-	//FileCoalInland()
+	FileCoalInland()
 	fmt.Println("end crawler")
 }