|
@@ -58,12 +58,12 @@ func SyncEdbDataByPb(edbInfoId int64, edbCode, startDate, endDate string) (err e
|
|
field := item.Field[k]
|
|
field := item.Field[k]
|
|
ticker := item.Ticker[k]
|
|
ticker := item.Ticker[k]
|
|
|
|
|
|
- count, err := data_manage.GetEdbDataPbCount(edbCode, dateTime)
|
|
|
|
|
|
+ count, err := data_manage.GetEdbDataPbCount(addEdbCode, dateTime)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|
|
if count > 0 {
|
|
if count > 0 {
|
|
- err = data_manage.ModifyEdbDataPb(edbInfoId, edbCode, dateTime, val)
|
|
|
|
|
|
+ err = data_manage.ModifyEdbDataPb(edbInfoId, addEdbCode, dateTime, val)
|
|
if err != nil {
|
|
if err != nil {
|
|
return err
|
|
return err
|
|
}
|
|
}
|