|
@@ -6,6 +6,7 @@ import (
|
|
|
"github.com/beego/beego/v2/client/orm"
|
|
|
"github.com/shopspring/decimal"
|
|
|
"hongze/hongze_edb_lib/services"
|
|
|
+ "hongze/hongze_edb_lib/services/alarm_msg"
|
|
|
"hongze/hongze_edb_lib/utils"
|
|
|
"strings"
|
|
|
"time"
|
|
@@ -29,7 +30,7 @@ func AddPythonEdb(edbInfoId int, edbCode string, item services.EdbDataFromPython
|
|
|
o := orm.NewOrm()
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
|
- go utils.SendEmail(utils.APP_NAME_CN+"【"+utils.RunMode+"】"+"失败提醒", " python代码运算数据获取失败:err:"+errMsg, utils.EmailSendToUsers)
|
|
|
+ go alarm_msg.SendAlarmMsg(" python代码运算数据添加失败:err:"+errMsg, 3)
|
|
|
}
|
|
|
}()
|
|
|
|
|
@@ -91,7 +92,7 @@ func EditPythonEdb(edbInfoId int, edbCode string, item services.EdbDataFromPytho
|
|
|
o := orm.NewOrm()
|
|
|
defer func() {
|
|
|
if err != nil {
|
|
|
- go utils.SendEmail(utils.APP_NAME_CN+"【"+utils.RunMode+"】"+"失败提醒", " 同花顺数据获取失败:err:"+errMsg, utils.EmailSendToUsers)
|
|
|
+ go alarm_msg.SendAlarmMsg(" 编辑python运算指标:err:"+errMsg, 3)
|
|
|
}
|
|
|
}()
|
|
|
|
|
@@ -380,7 +381,7 @@ func AnalysisPythonCode(pythonCode, edbName string) (edbInfoList []*EdbInfo) {
|
|
|
}
|
|
|
if len(edbInfoList) != edbCodeLen {
|
|
|
//code匹配失败,需要短信提醒
|
|
|
- go utils.SendEmail(utils.APP_NAME_CN+"%s【"+utils.RunMode+"】"+"失败提醒", fmt.Sprintf("python代码关联指标匹配失败,指标名称:%s;实际关联%d个,匹配上%d个", edbName, edbCodeLen, len(edbInfoList)), utils.EmailSendToUsers)
|
|
|
+ go alarm_msg.SendAlarmMsg(fmt.Sprintf("python代码关联指标匹配失败,指标名称:%s;实际关联%d个,匹配上%d个", edbName, edbCodeLen, len(edbInfoList)), 3)
|
|
|
}
|
|
|
return
|
|
|
}
|