|
@@ -82,12 +82,10 @@ func RefreshEdbDataByYs(edbInfoId int, edbCode, startDate, endDate string) (err
|
|
|
|
|
|
existMap := make(map[string]float64)
|
|
|
for _, ev := range existDataList {
|
|
|
- fmt.Println(ev.DataTime, ev.Value)
|
|
|
existMap[ev.DataTime] = ev.Value
|
|
|
}
|
|
|
ysList := make([]*EdbDataYs, 0)
|
|
|
for _, dv := range ysBaseDataAll {
|
|
|
- fmt.Println("baseDataAll:", dv.DataTime, dv.Value)
|
|
|
if existItem, ok := existMap[dv.DataTime]; !ok { //新增
|
|
|
dataDate, _ := time.Parse(utils.FormatDate, dv.DataTime)
|
|
|
timestamp := dataDate.UnixNano() / 1e6
|
|
@@ -109,7 +107,6 @@ func RefreshEdbDataByYs(edbInfoId int, edbCode, startDate, endDate string) (err
|
|
|
}
|
|
|
}
|
|
|
if len(ysList) > 0 {
|
|
|
- fmt.Println("AddEdbDataSmm")
|
|
|
err = AddEdbDataSmm(ysList)
|
|
|
if err != nil {
|
|
|
return
|