Merge branch 'edb_data'

models/db.go

@@ -35,6 +35,13 @@ func init() {
 	edb_db, _ := orm.GetDB("edb")
 	edb_db.SetConnMaxLifetime(10 * time.Minute)
 
+	_ = orm.RegisterDataBase("data", "mysql", utils.MYSQL_URL_DATA)
+	orm.SetMaxIdleConns("data", 50)
+	orm.SetMaxOpenConns("data", 100)
+
+	data_db, _ := orm.GetDB("data")
+	data_db.SetConnMaxLifetime(10 * time.Minute)
+
 	//注册对象
 	orm.RegisterModel(
 		new(EdbinfoSendMsgRecord),

services/data_manage/edb_info.go

@@ -11,7 +11,8 @@ import (
 func RefreshDataFromThs() (err error) {
 	defer func() {
 		if err != nil {
-			fmt.Println("RefreshDataFromWind Err:" + err.Error())
+			fmt.Println("RefreshDataFromThs Err:" + err.Error())
+			go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "RefreshDataFromThs ErrMsg:"+err.Error(), utils.EmailSendToUsers)
 		}
 	}()
 	var condition string
@@ -49,6 +50,7 @@ func RefreshDataFromWind() (err error) {
 	defer func() {
 		if err != nil {
 			fmt.Println("RefreshDataFromWind Err:" + err.Error())
+			go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "RefreshDataFromWind ErrMsg:"+err.Error(), utils.EmailSendToUsers)
 		}
 	}()
 	var condition string

utils/config.go

@@ -9,6 +9,7 @@ var (
 	MYSQL_URL      string //数据库连接
 	MYSQL_URL_RDDP string //数据库连接
 	MYSQL_URL_EDB  string
+	MYSQL_URL_DATA string
 )
 
 var (
@@ -51,6 +52,7 @@ func init() {
 	MYSQL_URL = config["mysql_url"]
 	MYSQL_URL_RDDP = config["mysql_url_rddp"]
 	MYSQL_URL_EDB = config["mysql_url_edb"]
+	MYSQL_URL_DATA = config["mysql_url_data"]
 
 	if RunMode == "release" {
 		CompanyId = 16