pcsg新增判断

models/pcsg/bloomberg.go

@@ -28,6 +28,7 @@ type PythonBloombergGeneralData struct {
 	OPEN_INT               *float64 `json:"OPEN_INT"`
 	OPEN_INT_DATE          string   `json:"OPEN_INT_DATE"`
 	DL_SNAPSHOT_START_TIME string   `json:"DL_SNAPSHOT_START_TIME" description:"数据日期"`
+	LAST_UPDATE            string   `json:"LAST_UPDATE" description:"IDpcsgDailySnap0000和IDpcsgDailySnap0330判断用的"`
 }
 
 // PythonBloombergGeneralResult API响应体
@@ -94,6 +95,12 @@ func FormatPythonBloombergGeneralData2Base(origin PythonBloombergGeneralData, fr
 		val = origin.OPEN_INT
 	}
 	if (taskKey == TaskKey0000 || taskKey == SubOneDayTaskKey) && origin.DL_SNAPSHOT_START_TIME != "" && origin.PX_LAST != nil {
+		// 根据LAST_UPDATE的格式进行判断, 仅加入格式为hh:mm:ss的
+		_, e := time.ParseInLocation("15:04:05", origin.LAST_UPDATE, time.Local)
+		if e != nil {
+			return
+		}
+
 		d, e := time.ParseInLocation("2006-01-02T15:04:05", origin.DL_SNAPSHOT_START_TIME, time.Local)
 		if e != nil {
 			global.LOG.Info(fmt.Sprintf("DL_SNAPSHOT_START_TIME日期解析失败, %s", origin.DL_SNAPSHOT_START_TIME))