fix bug

models/data_manage/base_from_changes_visitors_covid.go

@@ -61,3 +61,10 @@ func GetChangesVisitorsCovidAll(dateTime string) (items []*BaseFromChangesVisito
 	_, err = o.Raw(sql, dateTime).QueryRows(&items)
 	return
 }
+
+func GetChangesVisitorsCovidMaxDate() (max_date time.Time, err error) {
+	o := orm.NewOrm()
+	sql := ` SELECT max(a.day)as max_date FROM base_from_changes_visitors_covid as a `
+	err = o.Raw(sql).QueryRow(&max_date)
+	return
+}

models/data_manage/base_from_eia_steo.go

@@ -124,3 +124,10 @@ func GetBaseFromEiaSteoIndexDataAll(dateStr string) (list []*BaseFromEiaSteoData
 	_, err = o.Raw(sql, dateStr).QueryRows(&list)
 	return
 }
+
+func GetBaseFromEiaSteoIndexMaxDate() (max_date time.Time, err error) {
+	o := orm.NewOrm()
+	sql := ` SELECT max(a.data_time)as max_date FROM base_from_eia_steo_data as a `
+	err = o.Raw(sql).QueryRow(&max_date)
+	return
+}

models/data_manage/base_from_trade_cffex.go

@@ -60,3 +60,10 @@ type CffexIndexResp struct {
 	ErrCode string
 	Data    []*BaseFromTradeCffexIndex
 }
+
+func GetBaseFromTradeCffexIndexMaxDate() (max_date time.Time, err error) {
+	o := orm.NewOrm()
+	sql := ` SELECT max(a.data_time)as max_date FROM base_from_trade_cffex_index as a `
+	err = o.Raw(sql).QueryRow(&max_date)
+	return
+}

models/data_manage/base_from_trade_dalian.go

@@ -81,3 +81,10 @@ type DalianIndexResp struct {
 	ErrCode string
 	Data    []*BaseFromTradeDalianIndex
 }
+
+func GetBaseFromTradeDalianIndexMaxDate() (max_date time.Time, err error) {
+	o := orm.NewOrm()
+	sql := ` SELECT max(a.data_time)as max_date FROM base_from_trade_dalian_index as a `
+	err = o.Raw(sql).QueryRow(&max_date)
+	return
+}

models/data_manage/base_from_trade_ine.go

@@ -58,3 +58,10 @@ type IneIndexResp struct {
 	ErrCode string
 	Data    []*BaseFromTradeIneIndex
 }
+
+func GetBaseFromTradeIneIndexMaxDate() (max_date time.Time, err error) {
+	o := orm.NewOrm()
+	sql := ` SELECT max(a.data_time)as max_date FROM base_from_trade_ine_index as a `
+	err = o.Raw(sql).QueryRow(&max_date)
+	return
+}

models/data_manage/base_from_trade_shanghai.go

@@ -58,3 +58,10 @@ type ShanghaiIndexResp struct {
 	ErrCode string
 	Data    []*BaseFromTradeShanghaiIndex
 }
+
+func GetBaseFromTradeShangHaiIndexMaxDate() (max_date time.Time, err error) {
+	o := orm.NewOrm()
+	sql := ` SELECT max(a.data_time)as max_date FROM base_from_trade_shanghai_index as a `
+	err = o.Raw(sql).QueryRow(&max_date)
+	return
+}

models/data_manage/base_from_trade_zhengzhou.go

@@ -58,3 +58,10 @@ type ZhengzhouIndexResp struct {
 	ErrCode string
 	Data    []*BaseFromTradeZhengzhouIndex
 }
+
+func GetBaseFromTradeZhengzhouIndexMaxDate() (max_date time.Time, err error) {
+	o := orm.NewOrm()
+	sql := ` SELECT max(a.data_time)as max_date FROM base_from_trade_zhengzhou_index as a `
+	err = o.Raw(sql).QueryRow(&max_date)
+	return
+}

services/changes_visitors_covid.go

@@ -10,7 +10,13 @@ import (
 
 // 谷歌出现数据
 func SyncChangesVisitorsCovid() (err error) {
-	startDate := time.Now().Format(utils.FormatDate) + " 00:00:00"
+	var startDate string
+	maxDate, err := data_manage.GetChangesVisitorsCovidMaxDate()
+	if err != nil || maxDate.IsZero() {
+		startDate = time.Now().AddDate(0, 0, -1).Format(utils.FormatDate) + " 00:00:00"
+	} else {
+		startDate = maxDate.AddDate(0, 0, 1).Format(utils.FormatDate) + " 00:00:00"
+	}
 
 	method := `index/list`
 	data := make(map[string]interface{})

services/eia_steo.go

@@ -10,7 +10,13 @@ import (
 
 // EIA STEO报告 指标
 func SyncEiaSteoIndex() (err error) {
-	startDate := time.Now().Format(utils.FormatDate) + " 00:00:00"
+	var startDate string
+	maxDate, err := data_manage.GetBaseFromEiaSteoIndexMaxDate()
+	if err != nil || maxDate.IsZero() {
+		startDate = time.Now().AddDate(0, 0, -1).Format(utils.FormatDate) + " 00:00:00"
+	} else {
+		startDate = maxDate.AddDate(0, 0, 1).Format(utils.FormatDate) + " 00:00:00"
+	}
 
 	method := `index/list`
 	data := make(map[string]interface{})

services/sync_hz_data.go

@@ -49,13 +49,13 @@ func SyncHzDataIndex(cont context.Context) (err error) {
 		return
 	}
 
-	////EiaSteo
-	err = SyncEiaSteoIndex()
-	if err != nil {
-		fmt.Println("SyncEiaSteoIndex Err:" + err.Error())
-		return
-	}
-	SyncHzDataIndexData()
+	//////EiaSteo
+	//err = SyncEiaSteoIndex()
+	//if err != nil {
+	//	fmt.Println("SyncEiaSteoIndex Err:" + err.Error())
+	//	return
+	//}
+	//SyncHzDataIndexData()
 	return err
 }
 

services/trade_cffex.go

@@ -10,7 +10,13 @@ import (
 
 // 中金交易所持单排名
 func SyncRankingFromCffex() (err error) {
-	startDate := time.Now().Format(utils.FormatDate) + " 00:00:00"
+	var startDate string
+	maxDate, err := data_manage.GetBaseFromTradeCffexIndexMaxDate()
+	if err != nil || maxDate.IsZero() {
+		startDate = time.Now().AddDate(0, 0, -1).Format(utils.FormatDate) + " 00:00:00"
+	} else {
+		startDate = maxDate.AddDate(0, 0, 1).Format(utils.FormatDate) + " 00:00:00"
+	}
 
 	method := `index/list`
 	data := make(map[string]interface{})

services/trade_dalian.go

@@ -10,7 +10,13 @@ import (
 
 // 大连商品交易所持单排名
 func SyncRankingFromDalian() (err error) {
-	startDate := time.Now().Format(utils.FormatDate) + " 00:00:00"
+	var startDate string
+	maxDate, err := data_manage.GetBaseFromTradeDalianIndexMaxDate()
+	if err != nil || maxDate.IsZero() {
+		startDate = time.Now().AddDate(0, 0, -1).Format(utils.FormatDate) + " 00:00:00"
+	} else {
+		startDate = maxDate.AddDate(0, 0, 1).Format(utils.FormatDate) + " 00:00:00"
+	}
 
 	method := `index/list`
 	data := make(map[string]interface{})

services/trade_ine.go

@@ -10,7 +10,13 @@ import (
 
 // 上期能源所持单排名
 func SyncRankingFromIne() (err error) {
-	startDate := time.Now().Format(utils.FormatDate) + " 00:00:00"
+	var startDate string
+	maxDate, err := data_manage.GetBaseFromTradeIneIndexMaxDate()
+	if err != nil || maxDate.IsZero() {
+		startDate = time.Now().AddDate(0, 0, -1).Format(utils.FormatDate) + " 00:00:00"
+	} else {
+		startDate = maxDate.AddDate(0, 0, 1).Format(utils.FormatDate) + " 00:00:00"
+	}
 
 	method := `index/list`
 	data := make(map[string]interface{})

services/trade_shanghai.go

@@ -10,7 +10,13 @@ import (
 
 // 上海商品交易所持单排名
 func SyncRankingFromShanghai() (err error) {
-	startDate := time.Now().Format(utils.FormatDate) + " 00:00:00"
+	var startDate string
+	maxDate, err := data_manage.GetBaseFromTradeShangHaiIndexMaxDate()
+	if err != nil || maxDate.IsZero() {
+		startDate = time.Now().AddDate(0, 0, -1).Format(utils.FormatDate) + " 00:00:00"
+	} else {
+		startDate = maxDate.AddDate(0, 0, 1).Format(utils.FormatDate) + " 00:00:00"
+	}
 
 	method := `index/list`
 	data := make(map[string]interface{})

services/trade_zhengzhou.go

@@ -11,7 +11,13 @@ import (
 // 郑州商品交易所持单排名
 func SyncRankingFromZhengzhou() (err error) {
 
-	startDate := time.Now().Format(utils.FormatDate) + " 00:00:00"
+	var startDate string
+	maxDate, err := data_manage.GetBaseFromTradeZhengzhouIndexMaxDate()
+	if err != nil || maxDate.IsZero() {
+		startDate = time.Now().AddDate(0, 0, -1).Format(utils.FormatDate) + " 00:00:00"
+	} else {
+		startDate = maxDate.AddDate(0, 0, 1).Format(utils.FormatDate) + " 00:00:00"
+	}
 
 	method := `index/list`
 	data := make(map[string]interface{})