CCF配置优化

services/task.go

@@ -65,16 +65,28 @@ func Task() {
 
 	// CCF化纤信息
 	if utils.CCFOpen == "1" {
-		// 原油石化早报-每日9:00
-		taskCCFOilDailyEdb := task.NewTask("taskCCFOilDailyEdb", "0 30 17 * * *", ccfService.TaskOilDailyEdb)
+		// 原油石化早报-默认每日9:00
+		ccfDailyTime := utils.CCFDailyTaskTime
+		if ccfDailyTime == "" {
+			ccfDailyTime = "0 0 9 * * *"
+		}
+		taskCCFOilDailyEdb := task.NewTask("taskCCFOilDailyEdb", ccfDailyTime, ccfService.TaskOilDailyEdb)
 		task.AddTask("CCF原油石化早报", taskCCFOilDailyEdb)
 
-		// 各品种周报-每周五17-19点每隔半小时
-		taskCCFWeeklyEdb := task.NewTask("taskCCFWeeklyEdb", "0 */30 17 * * 5", ccfService.TaskWeeklyEdb)
+		// 各品种周报-默认每周五17-19点每隔半小时
+		ccfWeeklyTime := utils.CCFWeeklyTaskTime
+		if ccfWeeklyTime == "" {
+			ccfWeeklyTime = "0 */30 17-19 * * 5"
+		}
+		taskCCFWeeklyEdb := task.NewTask("taskCCFWeeklyEdb", ccfWeeklyTime, ccfService.TaskWeeklyEdb)
 		task.AddTask("CCF周度指标", taskCCFWeeklyEdb)
 
-		// 各品种装置-每周四15-18点每隔半小时
-		taskCCFStockTable := task.NewTask("taskCCFStockTable", "0 */30 15-18 * * 4", ccfService.TaskStockTable)
+		// 各品种装置-默认每周四15-18点每隔半小时
+		ccfStockTime := utils.CCFStockTaskTime
+		if ccfStockTime == "" {
+			ccfStockTime = "0 */30 15-18 * * 4"
+		}
+		taskCCFStockTable := task.NewTask("taskCCFStockTable", ccfStockTime, ccfService.TaskStockTable)
 		task.AddTask("CCF装置检修", taskCCFStockTable)
 	}
 

utils/config.go

@@ -69,9 +69,12 @@ var (
 
 // CCF化纤信息
 var (
-	CCFOpen         string // 是否配置CCF
-	CCFCookieFile   string // CCF登录Cookie
-	CCFDataRuleFile string // CCF数据爬取规则
+	CCFOpen           string // 是否配置CCF
+	CCFCookieFile     string // CCF登录Cookie
+	CCFDataRuleFile   string // CCF数据爬取规则
+	CCFDailyTaskTime  string // CCF数据日度任务时间
+	CCFWeeklyTaskTime string // CCF数据周度任务时间
+	CCFStockTaskTime  string // CCF数据装置任务时间
 )
 
 var TerminalCode string
@@ -154,6 +157,9 @@ func init() {
 		CCFOpen = config["ccf_open"]
 		CCFCookieFile = config["ccf_cookie_file"]
 		CCFDataRuleFile = config["ccf_data_rule_file"]
+		CCFDailyTaskTime = config["ccf_daily_task_time"]
+		CCFWeeklyTaskTime = config["ccf_weekly_task_time"]
+		CCFStockTaskTime = config["ccf_stock_task_time"]
 	}
 }