拆分ETA定时服务

services/task.go

@@ -81,8 +81,8 @@ func Task() {
 	task.AddTask("存量客户数据统计", stackCompanyStatistic)
 
 	// 定时往同花顺推送报告
-	sendWaitReport := task.NewTask("sendWaitReport", "0 */1 * * * * ", SendWaitReport)
-	task.AddTask("定时往同花顺推送报告", sendWaitReport)
+	//sendWaitReport := task.NewTask("sendWaitReport", "0 */1 * * * * ", SendWaitReport)
+	//task.AddTask("定时往同花顺推送报告", sendWaitReport)
 
 	// 研报电话会提醒
 	ybTelRemind := task.NewTask("YbTelRemind", "0 */1 * * * * ", YbTelRemind)
@@ -92,11 +92,11 @@ func Task() {
 	ybSalonRemind := task.NewTask("ybSalonRemind", "0 */1 * * * * ", YbSalonRemind)
 	task.AddTask("研报沙龙提醒", ybSalonRemind)
 
-	// 定时新增手工指标数据提醒
-	addEdbTask := task.NewTask("sendWaitReport", "1 0 2 * * * ", AddEdbTask)
-	task.AddTask("定时新增手工指标数据提醒", addEdbTask)
-	//每次服务启动都需要执行一次的
-	_ = AddEdbTask(nil)
+	//// 定时新增手工指标数据提醒
+	//addEdbTask := task.NewTask("sendWaitReport", "1 0 2 * * * ", AddEdbTask)
+	//task.AddTask("定时新增手工指标数据提醒", addEdbTask)
+	////每次服务启动都需要执行一次的
+	//_ = AddEdbTask(nil)
 
 	//每日用户阅读数据统计
 	statisticsUserView := task.NewTask("statisticsUserView", "0 5 2 * * *", StatisticsUserView)
@@ -205,51 +205,51 @@ func releaseTask() {
 	task.AddTask("上周增量客户列表", incrementCompany)
 
 	// 刷新指标数据
-	refreshData := task.NewTask("refreshData", "0 1 0,19 * * *", RefreshData)
-	task.AddTask("refreshData", refreshData)
+	//refreshData := task.NewTask("refreshData", "0 1 0,19 * * *", RefreshData)
+	//task.AddTask("refreshData", refreshData)
 
 	// 刷新商品数据
-	refreshFutureGoodData := task.NewTask("refreshFutureGoodData", "0 30 0,19 * * *", RefreshFutureGoodData)
-	task.AddTask("refreshFutureGoodData", refreshFutureGoodData)
+	//refreshFutureGoodData := task.NewTask("refreshFutureGoodData", "0 30 0,19 * * *", RefreshFutureGoodData)
+	//task.AddTask("refreshFutureGoodData", refreshFutureGoodData)
 
 	//刷新交易所指标数据
-	refreshTradeData := task.NewTask("refreshData", "0 1 4 * * *", RefreshTradeData)
-	task.AddTask("refreshTradeData", refreshTradeData)
+	//refreshTradeData := task.NewTask("refreshData", "0 1 4 * * *", RefreshTradeData)
+	//task.AddTask("refreshTradeData", refreshTradeData)
 
 	//刷新欧洲天然气指标数据
-	refreshEicData := task.NewTask("refreshData", "0 1 3,7 * * *", RefreshEicData)
-	task.AddTask("refreshEicData", refreshEicData)
+	//refreshEicData := task.NewTask("refreshData", "0 1 3,7 * * *", RefreshEicData)
+	//task.AddTask("refreshEicData", refreshEicData)
 
 	//刷新指标基础数据
 	//refreshBaseData := task.NewTask("refreshBaseData", "0 */30 * * * * ", RefreshBaseData)
 	//task.AddTask("refreshBaseData", refreshBaseData)
 
-	//同步弘则数据库中来自，钢联，隆众，有色,人工等基础数据--每隔五分钟，同步一次最新数据
-	syncBaseData := task.NewTask("syncBaseData", "0 */5 * * * * ", SyncBaseData)
-	task.AddTask("syncBaseData", syncBaseData)
-
-	syncBaseDataExt := task.NewTask("syncBaseDataExt", "0 */30 * * * * ", SyncBaseDataExt)
-	task.AddTask("syncBaseDataExt", syncBaseDataExt)
+	////同步弘则数据库中来自，钢联，隆众，有色,人工等基础数据--每隔五分钟，同步一次最新数据
+	//syncBaseData := task.NewTask("syncBaseData", "0 */5 * * * * ", SyncBaseData)
+	//task.AddTask("syncBaseData", syncBaseData)
+	//
+	//syncBaseDataExt := task.NewTask("syncBaseDataExt", "0 */30 * * * * ", SyncBaseDataExt)
+	//task.AddTask("syncBaseDataExt", syncBaseDataExt)
 
 	// 定时往同花顺同步微信群的截止日期（凌晨4点）
-	syncThsWxGroupEveryDay := task.NewTask("syncThsWxGroupEveryDay", "0 1 4 * * * ", SyncWxGroupEveryDay)
-	task.AddTask("定时往同花顺同步微信群的截止日期", syncThsWxGroupEveryDay)
+	//syncThsWxGroupEveryDay := task.NewTask("syncThsWxGroupEveryDay", "0 1 4 * * * ", SyncWxGroupEveryDay)
+	//task.AddTask("定时往同花顺同步微信群的截止日期", syncThsWxGroupEveryDay)
 
 	//检测数据服务器
-	checkDataServer := task.NewTask("checkDataServer", "0 */2 * * * * ", checkDataServer)
-	task.AddTask("checkDataServer", checkDataServer)
+	//checkDataServer := task.NewTask("checkDataServer", "0 */2 * * * * ", checkDataServer)
+	//task.AddTask("checkDataServer", checkDataServer)
 
 	//初始化指标更新状态
-	resetEdbInfoIsUpdate := task.NewTask("resetEdbInfoIsUpdate", "0 0 0 * * *", data.ResetEdbInfoIsUpdate)
-	task.AddTask("resetEdbInfoIsUpdate", resetEdbInfoIsUpdate)
+	//resetEdbInfoIsUpdate := task.NewTask("resetEdbInfoIsUpdate", "0 0 0 * * *", data.ResetEdbInfoIsUpdate)
+	//task.AddTask("resetEdbInfoIsUpdate", resetEdbInfoIsUpdate)
 
 	// 定时检测同花顺客群推送消息状态
 	//checkThsReportList := task.NewTask("checkThsReportList", "0 */2 * * * * ", CheckThsReportList)
 	//task.AddTask("checkThsReportList", checkThsReportList)
 
-	// 定时统计交易所的持仓分析数据
-	initPositionTask := task.NewTask("initPositionTask", "0 15,45 16-23 * * *", data.InitPositionTask)
-	task.AddTask("initPositionTask", initPositionTask)
+	//// 定时统计交易所的持仓分析数据
+	//initPositionTask := task.NewTask("initPositionTask", "0 15,45 16-23 * * *", data.InitPositionTask)
+	//task.AddTask("initPositionTask", initPositionTask)
 
 	// 每日4:01更新每刻报销-客户档案
 	syncMaycurCompanyProfile := task.NewTask("syncMaycurCompanyProfile", "0 1 4 * * * ", maycur.DailyUpdateCompanyProfile)