..

models/data_manage/edb_config.go

@@ -8,7 +8,7 @@ type EdbConfig struct {
 
 // EdbConfigUpdate 修改配置
 func EdbConfigUpdate(newValue, configCode string) (err error) {
-	o := orm.NewOrm()
+	o := orm.NewOrmUsingDB("data")
 	sql := `UPDATE edb_config SET  config_value=?   WHERE config_code=  ?`
 	_, err = o.Raw(sql, newValue, configCode).Exec()
 	return
@@ -16,7 +16,7 @@ func EdbConfigUpdate(newValue, configCode string) (err error) {
 
 // GetConfigDetailByCode 根据配置编码获取配置的值
 func GetConfigDetailByCode(configCode string) (item *EdbConfig, err error) {
-	o := orm.NewOrm()
+	o := orm.NewOrmUsingDB("data")
 	sql := ` SELECT config_value FROM edb_config WHERE config_code=? `
 	err = o.Raw(sql, configCode).QueryRow(&item)
 	return

models/data_manage/edb_terminal.go

@@ -130,7 +130,7 @@ func (item *EdbTerminal) Update(cols []string) (err error) {
 
 // GetEdbTerminalByCode 根据终端编码获取终端信息
 func GetEdbTerminalByCode(terminalCode string) (item *EdbTerminal, err error) {
-	o := orm.NewOrm()
+	o := orm.NewOrmUsingDB("data")
 	sql := ` SELECT *  FROM edb_terminal WHERE terminal_code = ? `
 	err = o.Raw(sql, terminalCode).QueryRow(&item)
 	return
@@ -143,7 +143,7 @@ type TerminalCodeCountGroup struct {
 
 // GetEdbCountGroupByTerminal 获取终端code分组总数
 func GetEdbCountGroupByTerminal(source int) (list []TerminalCodeCountGroup, err error) {
-	o := orm.NewOrm()
+	o := orm.NewOrmUsingDB("data")
 	sql := `select terminal_code,count(1) total from edb_info where source = ? AND no_update=0 AND terminal_code != "" group by terminal_code; `
 	_, err = o.Raw(sql, source).QueryRows(&list)
 	return