base_from_pcsg.go 2.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980
  1. package data
  2. import (
  3. "context"
  4. "eta/eta_task/services/alarm_msg"
  5. "eta/eta_task/utils"
  6. "fmt"
  7. )
  8. // RefreshPCSGBloombergDaily 中石油新加坡-刷新彭博日度指标
  9. func RefreshPCSGBloombergDaily(cont context.Context) (err error) {
  10. defer func() {
  11. if err != nil {
  12. tips := "RefreshPCSGBloombergDaily-中石油新加坡-刷新彭博日度指标失败, ErrMsg:\n" + err.Error()
  13. utils.FileLog.Info(tips)
  14. go alarm_msg.SendAlarmMsg(tips, 3)
  15. }
  16. }()
  17. param := make(map[string]interface{})
  18. uri := "bloomberg/pcsg/refresh_daily"
  19. res, e := postRefreshEdbData(param, uri)
  20. if e != nil {
  21. err = fmt.Errorf("postRefreshEdbData err: %s", e.Error())
  22. return
  23. }
  24. if res != nil && res.Ret != 200 {
  25. err = fmt.Errorf("postRefreshEdbData fail")
  26. return
  27. }
  28. return
  29. }
  30. // RefreshPCSGBloombergWeekly 中石油新加坡-刷新彭博周度指标
  31. func RefreshPCSGBloombergWeekly(cont context.Context) (err error) {
  32. defer func() {
  33. if err != nil {
  34. tips := "RefreshPCSGBloombergWeekly-中石油新加坡-刷新彭博周度指标失败, ErrMsg:\n" + err.Error()
  35. utils.FileLog.Info(tips)
  36. go alarm_msg.SendAlarmMsg(tips, 3)
  37. }
  38. }()
  39. param := make(map[string]interface{})
  40. uri := "bloomberg/pcsg/refresh_weekly"
  41. res, e := postRefreshEdbData(param, uri)
  42. if e != nil {
  43. err = fmt.Errorf("postRefreshEdbData err: %s", e.Error())
  44. return
  45. }
  46. if res != nil && res.Ret != 200 {
  47. err = fmt.Errorf("postRefreshEdbData fail")
  48. return
  49. }
  50. return
  51. }
  52. // RefreshPCSGBloombergMonthly 中石油新加坡-刷新彭博月度指标
  53. func RefreshPCSGBloombergMonthly(cont context.Context) (err error) {
  54. defer func() {
  55. if err != nil {
  56. tips := "RefreshPCSGBloombergMonthly-中石油新加坡-刷新彭博月度指标失败, ErrMsg:\n" + err.Error()
  57. utils.FileLog.Info(tips)
  58. go alarm_msg.SendAlarmMsg(tips, 3)
  59. }
  60. }()
  61. param := make(map[string]interface{})
  62. uri := "bloomberg/pcsg/refresh_monthly"
  63. res, e := postRefreshEdbData(param, uri)
  64. if e != nil {
  65. err = fmt.Errorf("postRefreshEdbData err: %s", e.Error())
  66. return
  67. }
  68. if res != nil && res.Ret != 200 {
  69. err = fmt.Errorf("postRefreshEdbData fail")
  70. return
  71. }
  72. return
  73. }