定时禁用指标刷新状态

services/edb_refresh.go

@@ -586,7 +586,7 @@ func getPreviousHalfHour(now time.Time) string {
 }
 
 // 根据配置把钢联化工和wind指标设置成禁止刷新
-func DisableEdbRefresh() (err error) {
+func DisableEdbRefresh(cont context.Context) (err error) {
 	//设置刷新key，如果没有执行完 报错提示
 	cacheKey := "eta_task:DisableEdbRefresh"
 	deleteCache := true

services/task.go

@@ -53,6 +53,10 @@ func releaseTask() {
 	configRefreshData := task.NewTask("syncBaseDataExt", "0 */30 * * * * ", ConfigRefreshData)
 	task.AddTask("configRefreshData", configRefreshData)
 
+	// 定时禁用钢联化工和wind指标的刷新状态
+	disableEdbRefresh := task.NewTask("disableEdbRefresh", "0 0 10 * * *", DisableEdbRefresh)
+	task.AddTask("disableEdbRefresh", disableEdbRefresh)
+
 	//同步弘则数据库中来自，钢联，隆众，有色,人工等基础数据--每隔五分钟，同步一次最新数据
 	syncBaseData := task.NewTask("syncBaseData", "0 */5 * * * * ", SyncBaseData)
 	task.AddTask("syncBaseData", syncBaseData)