|
@@ -7,26 +7,6 @@ import (
|
|
|
"time"
|
|
|
)
|
|
|
|
|
|
-func SyncEiaSteo() (err error) {
|
|
|
- // EiaSteo
|
|
|
- err = SyncEiaSteoClassify()
|
|
|
- if err != nil {
|
|
|
- fmt.Println("SyncEiaSteoClassify Err:" + err.Error())
|
|
|
- return
|
|
|
- }
|
|
|
- err = SyncEiaSteoIndex()
|
|
|
- if err != nil {
|
|
|
- fmt.Println("SyncEiaSteoIndex Err:" + err.Error())
|
|
|
- return
|
|
|
- }
|
|
|
- err = SyncEiaSteoIndexData()
|
|
|
- if err != nil {
|
|
|
- fmt.Println("SyncEiaSteoIndexData Err:" + err.Error())
|
|
|
- return
|
|
|
- }
|
|
|
- return
|
|
|
-}
|
|
|
-
|
|
|
// 同步指标
|
|
|
func SyncHzDataIndex(cont context.Context) (err error) {
|
|
|
fmt.Println("SyncHzDataIndex start:", time.Now().Format(utils.FormatDateTime))
|
|
@@ -165,7 +145,7 @@ func SyncHzDataIndex(cont context.Context) (err error) {
|
|
|
func SyncHzDataIndexData() {
|
|
|
var err error
|
|
|
//EiaSteo
|
|
|
- err = SyncEiaSteoIndexData()
|
|
|
+ err = SyncEiaSteoIndexDataV2()
|
|
|
if err != nil {
|
|
|
fmt.Println("SyncEiaSteoIndexData Err:" + err.Error())
|
|
|
return
|