|
@@ -55,7 +55,7 @@ func AddEdbDataFromPbFinance(edbCode string, item *services.EdbDataFromPb) (err
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-//刷新彭博指标数据
|
|
|
+// 刷新彭博指标数据
|
|
|
func RefreshEdbDataFromPbFinance(edbInfoId int, edbCode, startDate string, item *services.EdbDataFromPb) (err error) {
|
|
|
o := orm.NewOrm()
|
|
|
source := utils.DATA_SOURCE_PB_FINANCE
|
|
@@ -74,6 +74,10 @@ func RefreshEdbDataFromPbFinance(edbInfoId int, edbCode, startDate string, item
|
|
|
existMap[v.DataTime] = v
|
|
|
}
|
|
|
|
|
|
+ // 彭博财务编码
|
|
|
+ edbCodeArr := strings.Split(edbCode, "&&")
|
|
|
+ fieldCode := edbCodeArr[1]
|
|
|
+
|
|
|
edbInfoIdStr := strconv.Itoa(edbInfoId)
|
|
|
addMap := make(map[string]string)
|
|
|
if len(item.Date) > 0 {
|
|
@@ -90,7 +94,7 @@ func RefreshEdbDataFromPbFinance(edbInfoId int, edbCode, startDate string, item
|
|
|
field := item.Field[k]
|
|
|
ticker := item.Ticker[k]
|
|
|
saveValue := utils.SubFloatToString(val, 30)
|
|
|
- if field == "PX_LAST" {
|
|
|
+ if field == fieldCode {
|
|
|
if findItem, ok := existMap[dateTime]; !ok {
|
|
|
if _, addOk := addMap[dateTime]; !addOk {
|
|
|
addSql += "("
|