base_edb_lib.go 4.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161
  1. package data
  2. import (
  3. "encoding/json"
  4. "eta/eta_task/models"
  5. "eta/eta_task/models/data_manage"
  6. "eta/eta_task/utils"
  7. "fmt"
  8. "io/ioutil"
  9. "net/http"
  10. "strings"
  11. )
  12. // RefreshEdbData 刷新指标数据
  13. func RefreshEdbData(edbInfoId, source, subSource int, edbCode, startDate string) (resp *models.BaseResponse, err error) {
  14. param := make(map[string]interface{})
  15. param["EdbCode"] = edbCode
  16. param["EdbInfoId"] = edbInfoId
  17. param["StartDate"] = startDate
  18. param["Source"] = source
  19. urlStr := ``
  20. switch source {
  21. case utils.DATA_SOURCE_THS:
  22. urlStr = "ths/refresh"
  23. case utils.DATA_SOURCE_WIND:
  24. if subSource == 0 {
  25. urlStr = "wind/refresh"
  26. } else {
  27. urlStr = "wind/wsd/refresh"
  28. }
  29. case utils.DATA_SOURCE_PB:
  30. urlStr = "pb/refresh"
  31. case utils.DATA_SOURCE_PB_FINANCE:
  32. urlStr = "pb_finance/refresh"
  33. case utils.DATA_SOURCE_MANUAL:
  34. urlStr = "manual/refresh"
  35. case utils.DATA_SOURCE_LZ:
  36. urlStr = "lz/refresh"
  37. case utils.DATA_SOURCE_YS:
  38. urlStr = "smm/refresh"
  39. case utils.DATA_SOURCE_GL:
  40. urlStr = "mysteel/refresh"
  41. case utils.DATA_SOURCE_ZZ:
  42. urlStr = "zz/refresh"
  43. case utils.DATA_SOURCE_DL:
  44. urlStr = "dl/refresh"
  45. case utils.DATA_SOURCE_SH:
  46. urlStr = "sh/refresh"
  47. case utils.DATA_SOURCE_CFFEX:
  48. urlStr = "cffex/refresh"
  49. case utils.DATA_SOURCE_SHFE:
  50. urlStr = "shfe/refresh"
  51. case utils.DATA_SOURCE_GIE:
  52. urlStr = "gie/refresh"
  53. case utils.DATA_SOURCE_LT:
  54. urlStr = "lt/refresh"
  55. case utils.DATA_SOURCE_COAL:
  56. urlStr = "coal/refresh"
  57. case utils.DATA_SOURCE_GOOGLE_TRAVEL:
  58. urlStr = "google_travel/refresh"
  59. case utils.DATA_SOURCE_MYSTEEL_CHEMICAL:
  60. urlStr = "mysteel_chemical/refresh"
  61. case utils.DATA_SOURCE_EIA_STEO:
  62. urlStr = "eia_steo/refresh"
  63. case utils.DATA_SOURCE_PREDICT:
  64. urlStr = "predict/refresh"
  65. case utils.DATA_SOURCE_COM_TRADE:
  66. urlStr = "com_trade/refresh"
  67. case utils.DATA_SOURCE_SCI:
  68. urlStr = "sci/refresh"
  69. case utils.DATA_SOURCE_BAIINFO:
  70. urlStr = "baiinfo/refresh"
  71. case utils.DATA_SOURCE_NATIONAL_STATISTICS:
  72. urlStr = "national_statistics/refresh"
  73. case utils.DATA_SOURCE_FUBAO:
  74. urlStr = "fubao/refresh"
  75. default:
  76. urlStr = data_manage.EdbDataRefreshMethodMap[source] // 没有对应的从edb_source中取
  77. }
  78. if urlStr == "" {
  79. err = fmt.Errorf(fmt.Sprint("source:", source, ";未实现该指标的刷新接口,请联系管理员"))
  80. return
  81. }
  82. resp, err = postRefreshEdbData(param, urlStr)
  83. return
  84. }
  85. // RefreshEdbCalculateData 刷新计算指标数据请求
  86. func RefreshEdbCalculateData(edbInfoId int, edbCode, startDate string) (resp *models.BaseResponse, err error) {
  87. param := make(map[string]interface{})
  88. param["EdbCode"] = edbCode
  89. param["EdbInfoId"] = edbInfoId
  90. param["StartDate"] = startDate
  91. resp, err = postRefreshEdbData(param, "calculate/refresh")
  92. return
  93. }
  94. // RefreshPredictEdbCalculateData 刷新 预测计算指标 数据请求
  95. func RefreshPredictEdbCalculateData(edbInfoId int, edbCode, startDate string) (resp *models.BaseResponse, err error) {
  96. param := make(map[string]interface{})
  97. param["EdbCode"] = edbCode
  98. param["EdbInfoId"] = edbInfoId
  99. param["StartDate"] = startDate
  100. resp, err = postRefreshEdbData(param, "predict_calculate/refresh")
  101. return
  102. }
  103. // postRefreshEdbData 刷新指标数据
  104. func postRefreshEdbData(param map[string]interface{}, urlStr string) (resp *models.BaseResponse, err error) {
  105. postUrl := utils.EDB_LIB_URL + urlStr
  106. postData, err := json.Marshal(param)
  107. if err != nil {
  108. return
  109. }
  110. result, err := HttpPost(postUrl, string(postData), "application/json")
  111. if err != nil {
  112. return
  113. }
  114. err = json.Unmarshal(result, &resp)
  115. if err != nil {
  116. return
  117. }
  118. return resp, nil
  119. }
  120. // SetEdbSourceStat 指标终端更新情况定时汇总
  121. func SetEdbSourceStat() (resp *models.BaseResponse, err error) {
  122. postUrl := utils.EDB_LIB_URL + "edb_stat/source_update"
  123. result, err := HttpPost(postUrl, "", "application/json")
  124. if err != nil {
  125. return
  126. }
  127. err = json.Unmarshal(result, &resp)
  128. if err != nil {
  129. return
  130. }
  131. return resp, nil
  132. }
  133. func HttpPost(url, postData string, params ...string) ([]byte, error) {
  134. body := ioutil.NopCloser(strings.NewReader(postData))
  135. client := &http.Client{}
  136. req, err := http.NewRequest("POST", url, body)
  137. if err != nil {
  138. return nil, err
  139. }
  140. contentType := "application/x-www-form-urlencoded;charset=utf-8"
  141. if len(params) > 0 && params[0] != "" {
  142. contentType = params[0]
  143. }
  144. req.Header.Set("Content-Type", contentType)
  145. req.Header.Set("authorization", utils.MD5(utils.APP_EDB_LIB_NAME_EN+utils.EDB_LIB_Md5_KEY))
  146. resp, err := client.Do(req)
  147. if err != nil {
  148. return nil, err
  149. }
  150. defer resp.Body.Close()
  151. b, err := ioutil.ReadAll(resp.Body)
  152. fmt.Println("HttpPost:" + string(b))
  153. return b, err
  154. }