Explorar o código

fix:eiaSteo数据同步bug

zqbao hai 6 meses
pai
achega
e5103a91bf
Modificáronse 2 ficheiros con 4 adicións e 0 borrados
  1. 1 0
      models/db.go
  2. 3 0
      services/eia_steo.go

+ 1 - 0
models/db.go

@@ -115,6 +115,7 @@ func initEdbDataTable() {
 		new(data_manage.BaseFromTradeIneIndex),
 		new(data_manage.BaseFromChangesVisitorsCovid),
 		new(data_manage.BaseFromEiaSteoIndex),
+		new(data_manage.BaseFromEiaSteoClassify),
 		new(data_manage.BaseFromEiaSteoData),
 		new(data_manage.ComTradeIndex),           // 联合国指标表
 		new(data_manage.ComTradeCodeMapping),     // 联合国指标关系表

+ 3 - 0
services/eia_steo.go

@@ -52,6 +52,9 @@ func SyncEiaSteoIndex() (err error) {
 
 	for _, zv := range respObj.Data {
 		//if _, ok := existIndexMap[zv.IndexCode]; !ok {
+		if zv.BaseFromEiaSteoIndexId <= 0 {
+			continue
+		}
 		newID, err := data_manage.InsertOrUpdateBaseFromEiaSteoIndex(zv)
 		if err != nil {
 			fmt.Println("InsertOrUpdateBaseFromEiaSteoIndex error:", err)