|
@@ -1,6 +1,7 @@
|
|
|
package models
|
|
|
|
|
|
import (
|
|
|
+ "eta/eta_task/global"
|
|
|
"eta/eta_task/utils"
|
|
|
"fmt"
|
|
|
"github.com/beego/beego/v2/client/orm"
|
|
@@ -50,6 +51,8 @@ func (m *BusinessConf) Create() (err error) {
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|
|
|
+
|
|
|
+ err = global.DbMap[utils.DbNameMaster].Create(m).Error
|
|
|
m.Id = int(id)
|
|
|
return
|
|
|
}
|
|
@@ -58,47 +61,40 @@ func (m *BusinessConf) CreateMulti(items []*BusinessConf) (err error) {
|
|
|
if len(items) == 0 {
|
|
|
return
|
|
|
}
|
|
|
- o := orm.NewOrmUsingDB("eta")
|
|
|
- _, err = o.InsertMulti(len(items), items)
|
|
|
+ err = global.DbMap[utils.DbNameMaster].CreateInBatches(items, utils.MultiAddNum).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func (m *BusinessConf) Update(cols []string) (err error) {
|
|
|
- o := orm.NewOrmUsingDB("eta")
|
|
|
- _, err = o.Update(m, cols...)
|
|
|
+ err = global.DbMap[utils.DbNameMaster].Select(cols).Updates(m).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func (m *BusinessConf) Del() (err error) {
|
|
|
- o := orm.NewOrmUsingDB("eta")
|
|
|
sql := fmt.Sprintf(`DELETE FROM %s WHERE %s = ? LIMIT 1`, m.TableName(), m.PrimaryId())
|
|
|
- _, err = o.Raw(sql, m.Id).Exec()
|
|
|
+ err = global.DbMap[utils.DbNameMaster].Exec(sql, m.Id).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func (m *BusinessConf) GetItemById(id int) (item *BusinessConf, err error) {
|
|
|
- o := orm.NewOrmUsingDB("eta")
|
|
|
sql := fmt.Sprintf(`SELECT * FROM %s WHERE %s = ? LIMIT 1`, m.TableName(), m.PrimaryId())
|
|
|
- err = o.Raw(sql, id).QueryRow(&item)
|
|
|
+ err = global.DbMap[utils.DbNameMaster].Raw(sql, id).First(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func (m *BusinessConf) GetItemByCondition(condition string, pars []interface{}) (item *BusinessConf, err error) {
|
|
|
- o := orm.NewOrmUsingDB("eta")
|
|
|
sql := fmt.Sprintf(`SELECT * FROM %s WHERE 1=1 %s LIMIT 1`, m.TableName(), condition)
|
|
|
- err = o.Raw(sql, pars).QueryRow(&item)
|
|
|
+ err = global.DbMap[utils.DbNameMaster].Raw(sql, pars...).First(&item).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func (m *BusinessConf) GetCountByCondition(condition string, pars []interface{}) (count int, err error) {
|
|
|
- o := orm.NewOrmUsingDB("eta")
|
|
|
sql := fmt.Sprintf(`SELECT COUNT(1) FROM %s WHERE 1=1 %s`, m.TableName(), condition)
|
|
|
- err = o.Raw(sql, pars).QueryRow(&count)
|
|
|
+ err = global.DbMap[utils.DbNameMaster].Raw(sql, pars...).Scan(&count).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func (m *BusinessConf) GetItemsByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string) (items []*BusinessConf, err error) {
|
|
|
- o := orm.NewOrmUsingDB("eta")
|
|
|
fields := strings.Join(fieldArr, ",")
|
|
|
if len(fieldArr) == 0 {
|
|
|
fields = `*`
|
|
@@ -108,12 +104,11 @@ func (m *BusinessConf) GetItemsByCondition(condition string, pars []interface{},
|
|
|
order = ` ORDER BY ` + orderRule
|
|
|
}
|
|
|
sql := fmt.Sprintf(`SELECT %s FROM %s WHERE 1=1 %s %s`, fields, m.TableName(), condition, order)
|
|
|
- _, err = o.Raw(sql, pars).QueryRows(&items)
|
|
|
+ err = global.DbMap[utils.DbNameMaster].Raw(sql, pars...).Find(&items).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
func (m *BusinessConf) GetPageItemsByCondition(condition string, pars []interface{}, fieldArr []string, orderRule string, startSize, pageSize int) (items []*BusinessConf, err error) {
|
|
|
- o := orm.NewOrmUsingDB("eta")
|
|
|
fields := strings.Join(fieldArr, ",")
|
|
|
if len(fieldArr) == 0 {
|
|
|
fields = `*`
|
|
@@ -123,7 +118,8 @@ func (m *BusinessConf) GetPageItemsByCondition(condition string, pars []interfac
|
|
|
order = ` ORDER BY ` + orderRule
|
|
|
}
|
|
|
sql := fmt.Sprintf(`SELECT %s FROM %s WHERE 1=1 %s %s LIMIT ?,?`, fields, m.TableName(), condition, order)
|
|
|
- _, err = o.Raw(sql, pars, startSize, pageSize).QueryRows(&items)
|
|
|
+ err = global.DbMap[utils.DbNameMaster].Raw(sql, pars...).Find(&items).Error
|
|
|
+
|
|
|
return
|
|
|
}
|
|
|
|
|
@@ -132,9 +128,8 @@ func GetBusinessConf() (list map[string]string, err error) {
|
|
|
list = make(map[string]string)
|
|
|
|
|
|
var items []*BusinessConf
|
|
|
- o := orm.NewOrmUsingDB("eta")
|
|
|
sql := `SELECT * FROM business_conf`
|
|
|
- _, err = o.Raw(sql).QueryRows(&items)
|
|
|
+ err = global.DbMap[utils.DbNameMaster].Raw(sql).Find(&items).Error
|
|
|
if err != nil {
|
|
|
return
|
|
|
}
|