eta_task/services/sync_hz_data.go

package services

import (
	"context"
	"eta/eta_task/utils"
	"fmt"
	"time"
)

// 同步指标
func SyncHzDataIndex(cont context.Context) (err error) {
	fmt.Println("SyncHzDataIndex start:", time.Now().Format(utils.FormatDateTime))
	//郑州交易所
	err = SyncRankingFromZhengzhou()
	if err != nil {
		fmt.Println("SyncRankingFromZhengzhou Err:" + err.Error())
		return
	}

	//大商所
	err = SyncRankingFromDalian()
	if err != nil {
		fmt.Println("SyncRankingFromDalian Err:" + err.Error())
		return
	}

	//上期所
	err = SyncRankingFromShanghai()
	if err != nil {
		fmt.Println("SyncRankingFromDalian Err:" + err.Error())
		return
	}

	//中金所
	err = SyncRankingFromCffex()
	if err != nil {
		fmt.Println("SyncRankingFromCffex Err:" + err.Error())
		return
	}

	//上期能源
	err = SyncRankingFromIne()
	if err != nil {
		fmt.Println("SyncRankingFromIne Err:" + err.Error())
		return
	}

	//谷歌出行数据
	err = SyncChangesVisitorsCovid()
	if err != nil {
		fmt.Println("SyncChangesVisitorsCovid Err:" + err.Error())
		return
	}

	// EiaSteo
	err = SyncEiaSteoIndex()
	if err != nil {
		fmt.Println("SyncEiaSteoIndex Err:" + err.Error())
		return
	}

	// UN联合国数据
	err = SyncComTradeIndex()
	if err != nil {
		fmt.Println("SyncComTradeIndexAndData Err:" + err.Error())
		return
	}

	// 同步指标数据
	SyncHzDataIndexData()
	fmt.Println("SyncHzDataIndex end:", time.Now().Format(utils.FormatDateTime))
	return err
}

// SyncHzDataIndexData 同步指标数据
func SyncHzDataIndexData() {
	var err error
	//EiaSteo
	err = SyncEiaSteoIndexData()
	if err != nil {
		fmt.Println("SyncEiaSteoIndexData Err:" + err.Error())
		return
	}

	// 同步un数据
	err = SyncComTradeData()
	if err != nil {
		fmt.Println("SyncComTradeData Err:" + err.Error())
		return
	}

	fmt.Println(err)
}