fix:eiaSteo数据同步

models/data_manage/base_from_eia_steo.go

@@ -179,10 +179,10 @@ func GetBaseFromEiaSteoIndexDataAll(dateStr string) (list []*BaseFromEiaSteoData
 	return
 }
 
-func GetBaseFromEiaSteoIndexDataByIndexCode(indexCode string) (list []*BaseFromEiaSteoData, err error) {
+func GetBaseFromEiaSteoIndexDataByIndexCode(indexCode, dateStr string) (list []*BaseFromEiaSteoData, err error) {
 	o := orm.NewOrm()
-	sql := `SELECT * FROM base_from_eia_steo_data WHERE index_code=?`
-	_, err = o.Raw(sql, indexCode).QueryRows(&list)
+	sql := `SELECT * FROM base_from_eia_steo_data WHERE index_code=? AND modify_time>=?`
+	_, err = o.Raw(sql, indexCode, dateStr).QueryRows(&list)
 	return
 }
 

services/eia_steo.go

@@ -234,7 +234,7 @@ func SyncEiaSteoIndexDataV2() (err error) {
 		}
 
 		existDataMap := make(map[int]*data_manage.BaseFromEiaSteoData)
-		allData, err1 := data_manage.GetBaseFromEiaSteoIndexDataByIndexCode(indexCode)
+		allData, err1 := data_manage.GetBaseFromEiaSteoIndexDataByIndexCode(indexCode, startDate)
 		if err1 != nil {
 			utils.FileLog.Error("get GetBaseFromEiaSteoIndexDataByDate err:", err1.Error())
 			return