|
@@ -618,7 +618,6 @@ func RefreshDataFromMysteelChemical(edbCode, startDate, endDate string) (err err
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
- alarm_msg.SendAlarmMsg(fmt.Sprintf("开始刷新钢联化工接口数据, %s", edbCode), 1)
|
|
|
|
|
|
terminal, err := GetTerminal(utils.DATA_SOURCE_MYSTEEL_CHEMICAL, tmpIndex.TerminalCode)
|
|
|
if err != nil {
|
|
@@ -643,7 +642,6 @@ func RefreshDataFromMysteelChemical(edbCode, startDate, endDate string) (err err
|
|
|
err = errors.New(resp.Message)
|
|
|
return
|
|
|
}
|
|
|
- alarm_msg.SendAlarmMsg("获取钢联化工接口数据", 1)
|
|
|
|
|
|
dataObj := new(models.BaseFromMysteelChemicalData)
|
|
|
exitDataList, er := dataObj.GetIndexDataList(edbCode)
|
|
@@ -675,7 +673,6 @@ func RefreshDataFromMysteelChemical(edbCode, startDate, endDate string) (err err
|
|
|
}
|
|
|
// 因为只有一个指标,所以取第一个就可以了
|
|
|
items := mysteelChemicalDatas[0]
|
|
|
- alarm_msg.SendAlarmMsg("钢联化工接口数据转化成功", 1)
|
|
|
for _, v := range items {
|
|
|
dateStr := v.DataTime.Format(utils.FormatDate)
|
|
|
if findData, ok := existDataMap[dateStr]; !ok {
|
|
@@ -694,7 +691,6 @@ func RefreshDataFromMysteelChemical(edbCode, startDate, endDate string) (err err
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
- alarm_msg.SendAlarmMsg("开始添加数据", 1)
|
|
|
err = dataObj.AddV2(addItems)
|
|
|
if err != nil {
|
|
|
return
|