中石油彭博

services/data/base_from_pcsg.go

@@ -7,8 +7,8 @@ import (
 	"fmt"
 )
 
-// RefreshPCSGBloombergDaily 中石油新加坡-刷新彭博日度指标
-func RefreshPCSGBloombergDaily(cont context.Context) (err error) {
+// RefreshPCSGBloomberg 中石油新加坡-每日指标刷新
+func RefreshPCSGBloomberg(cont context.Context) (err error) {
 	defer func() {
 		if err != nil {
 			tips := "RefreshPCSGBloombergDaily-中石油新加坡-刷新彭博日度指标失败, ErrMsg:\n" + err.Error()
@@ -18,79 +18,7 @@ func RefreshPCSGBloombergDaily(cont context.Context) (err error) {
 	}()
 
 	param := make(map[string]interface{})
-	uri := "bloomberg/pcsg/refresh_daily"
-	res, e := postRefreshEdbData(param, uri)
-	if e != nil {
-		err = fmt.Errorf("postRefreshEdbData err: %s", e.Error())
-		return
-	}
-	if res != nil && res.Ret != 200 {
-		err = fmt.Errorf("postRefreshEdbData fail")
-		return
-	}
-	return
-}
-
-// RefreshPCSGBloombergWeekly 中石油新加坡-刷新彭博周度指标
-func RefreshPCSGBloombergWeekly(cont context.Context) (err error) {
-	defer func() {
-		if err != nil {
-			tips := "RefreshPCSGBloombergWeekly-中石油新加坡-刷新彭博周度指标失败, ErrMsg:\n" + err.Error()
-			utils.FileLog.Info(tips)
-			go alarm_msg.SendAlarmMsg(tips, 3)
-		}
-	}()
-
-	param := make(map[string]interface{})
-	uri := "bloomberg/pcsg/refresh_weekly"
-	res, e := postRefreshEdbData(param, uri)
-	if e != nil {
-		err = fmt.Errorf("postRefreshEdbData err: %s", e.Error())
-		return
-	}
-	if res != nil && res.Ret != 200 {
-		err = fmt.Errorf("postRefreshEdbData fail")
-		return
-	}
-	return
-}
-
-// RefreshPCSGBloombergMonthly 中石油新加坡-刷新彭博月度指标
-func RefreshPCSGBloombergMonthly(cont context.Context) (err error) {
-	defer func() {
-		if err != nil {
-			tips := "RefreshPCSGBloombergMonthly-中石油新加坡-刷新彭博月度指标失败, ErrMsg:\n" + err.Error()
-			utils.FileLog.Info(tips)
-			go alarm_msg.SendAlarmMsg(tips, 3)
-		}
-	}()
-
-	param := make(map[string]interface{})
-	uri := "bloomberg/pcsg/refresh_monthly"
-	res, e := postRefreshEdbData(param, uri)
-	if e != nil {
-		err = fmt.Errorf("postRefreshEdbData err: %s", e.Error())
-		return
-	}
-	if res != nil && res.Ret != 200 {
-		err = fmt.Errorf("postRefreshEdbData fail")
-		return
-	}
-	return
-}
-
-// RefreshPCSGBloombergDailyRun3 中石油新加坡-刷新彭博日度指标Run3
-func RefreshPCSGBloombergDailyRun3(cont context.Context) (err error) {
-	defer func() {
-		if err != nil {
-			tips := "RefreshPCSGBloombergDailyRun3-中石油新加坡-刷新彭博日度指标V2失败, ErrMsg:\n" + err.Error()
-			utils.FileLog.Info(tips)
-			go alarm_msg.SendAlarmMsg(tips, 3)
-		}
-	}()
-
-	param := make(map[string]interface{})
-	uri := "bloomberg/pcsg/refresh_daily_run3"
+	uri := "bloomberg/pcsg/refresh_task"
 	res, e := postRefreshEdbData(param, uri)
 	if e != nil {
 		err = fmt.Errorf("postRefreshEdbData err: %s", e.Error())

services/task.go

@@ -119,17 +119,8 @@ func releaseTask() {
 
 	// 中石油新加坡
 	if utils.IsPCSG == "1" {
-		refreshPCSGBloombergDaily := task.NewTask("refreshPCSGBloombergDaily", "0 30 9 * * *", data.RefreshPCSGBloombergDaily)
-		task.AddTask("刷新中石油新加坡-Bloomberg日度指标", refreshPCSGBloombergDaily)
-
-		refreshPCSGBloombergDailyRun3 := task.NewTask("refreshPCSGBloombergDailyRun3", "0 32 9 * * *", data.RefreshPCSGBloombergDailyRun3)
-		task.AddTask("刷新中石油新加坡-Bloomberg日度指标Run3", refreshPCSGBloombergDailyRun3)
-
-		//refreshPCSGBloombergWeekly := task.NewTask("refreshPCSGBloombergWeekly", "0 30 9 * * *", data.RefreshPCSGBloombergWeekly)
-		//task.AddTask("刷新中石油新加坡-Bloomberg周度指标", refreshPCSGBloombergWeekly)
-
-		refreshPCSGBloombergMonthly := task.NewTask("refreshPCSGBloombergMonthly", "0 34 9 * * *", data.RefreshPCSGBloombergMonthly)
-		task.AddTask("刷新中石油新加坡-Bloomberg月度指标", refreshPCSGBloombergMonthly)
+		refreshPCSGBloomberg := task.NewTask("refreshPCSGBloombergDaily", "0 30 9 * * *", data.RefreshPCSGBloomberg)
+		task.AddTask("中石油新加坡-每日Bloomberg指标刷新", refreshPCSGBloomberg)
 	}
 }