Merge branch 'feature/pcsg_0619'

services/data/base_from_pcsg.go

@@ -78,3 +78,27 @@ func RefreshPCSGBloombergMonthly(cont context.Context) (err error) {
 	}
 	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"
+	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
+}

services/task.go

@@ -122,10 +122,13 @@ func releaseTask() {
 		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 32 9 * * *", data.RefreshPCSGBloombergMonthly)
+		refreshPCSGBloombergMonthly := task.NewTask("refreshPCSGBloombergMonthly", "0 34 9 * * *", data.RefreshPCSGBloombergMonthly)
 		task.AddTask("刷新中石油新加坡-Bloomberg月度指标", refreshPCSGBloombergMonthly)
 	}
 }