修改彭博数据同步

services/data/data_pb.go

@@ -54,29 +54,30 @@ func SyncEdbDataByPb(edbInfoId int64, edbCode, startDate, endDate string) (err e
 			val := item.Value[k]
 			field := item.Field[k]
 			ticker := item.Ticker[k]
-
-			count, err := data_manage.GetEdbDataPbCount(addEdbCode, dateTime)
-			if err != nil {
-				return err
-			}
-			if count > 0 {
-				err = data_manage.ModifyEdbDataPb(edbInfoId, addEdbCode, dateTime, val)
+			if field == "PX_LAST" {
+				count, err := data_manage.GetEdbDataPbCount(addEdbCode, dateTime)
 				if err != nil {
 					return err
 				}
-			} else {
-				item := new(data_manage.EdbDataPb)
-				item.EdbCode = addEdbCode
-				item.EdbInfoId = int(edbInfoId)
-				item.CreateTime = time.Now()
-				item.ModifyTime = time.Now()
-				item.DataTime = dateTime
-				item.Value = val
-				item.Status = 1
-				item.Field = field
-				item.Ticker = ticker
-				item.DataTimestamp = dataTimestamp
-				pbList = append(pbList, item)
+				if count > 0 {
+					err = data_manage.ModifyEdbDataPb(edbInfoId, addEdbCode, dateTime, val)
+					if err != nil {
+						return err
+					}
+				} else {
+					item := new(data_manage.EdbDataPb)
+					item.EdbCode = addEdbCode
+					item.EdbInfoId = int(edbInfoId)
+					item.CreateTime = time.Now()
+					item.ModifyTime = time.Now()
+					item.DataTime = dateTime
+					item.Value = val
+					item.Status = 1
+					item.Field = field
+					item.Ticker = ticker
+					item.DataTimestamp = dataTimestamp
+					pbList = append(pbList, item)
+				}
 			}
 		}
 	}