scd_tools_go/service/models/bo/check_sys_model.go

package bo

import (
	"errors"
	"fmt"
	"scd_check_tools/logger"
	"scd_check_tools/models/enum"
	"scd_check_tools/tools"
	"strconv"
	"strings"

	"github.com/astaxie/beego/orm"
)

//系统内置模型
type T_data_model_defualt struct {
	Id            int    `orm:"pk"`
	ModelName     string // '模型名称' ,
	AreaType      int    // '所属间隔类型ID' ,
	VolId         int    // '所属电压等级ID' ,
	LineLinkStyle int    // '接线方式' ,
	IedTypes      string // '包含的装置类型' ,
	RelationJson  string // '关系定义内容' ,
	Cr            int    // '创建人' ,
	Ct            string `orm:"-"` // '创建时间' ,
	Ur            int    // '更新人' ,
	Ut            string `orm:"-"` // '更新时间'
}

//内置检测模型管理对象
type SysCheckModelMgr struct {
	Model T_data_model_defualt
	DeviceBaseModel
}

var sysCheckModelDesc = "内置检测模型"

func init() {
	orm.RegisterModel(new(T_data_model_defualt))
}

//保存检测模型信息
func (c *SysCheckModelMgr) Save() (err error) {
	dblog := new(SystemLog)
	dblog.SetUserInfo(c.GetUserInfo())
	dblog.Audittype = enum.AuditType_check_model
	dblog.Logtype = enum.LogType_Insert
	dblog.Eventtype = enum.OptEventType_Bus
	dblog.Eventlevel = enum.OptEventLevel_Hight
	err = c.Delete()
	if err != nil {
		return err
	}
	db := orm.NewOrm()
	if c.Model.Id == 0 {
		c.Model.Cr, _ = strconv.Atoi(c.GetUserId())
		_, err = db.Insert(&c.Model)
	} else {
		tmpObj, err := c.One()
		if err != nil {
			return err
		}
		c.Model.Cr = tmpObj.Cr
		c.Model.Ur, _ = strconv.Atoi(c.GetUserId())
		_, err = db.Update(&c.Model)
	}
	if err != nil {
		logger.Logger.Error(err)
		dblog.Description = fmt.Sprintf("保存%s信息失败：%s,操作数据：%+v", sysCheckModelDesc, err.Error(), c.Model)
		dblog.Fail2()
	} else {
		dblog.Description = fmt.Sprintf("保存%s信息成功,操作数据：%+v", sysCheckModelDesc, c.Model)
		dblog.Success2()
	}
	return err
}

func (c *SysCheckModelMgr) One() (T_data_model_defualt, error) {
	if c.Model.Id == 0 {
		return c.Model, errors.New("未指定id")
	}
	o := orm.NewOrm()
	err := o.Read(&c.Model)
	if err != nil {
		logger.Logger.Error(err)
	}
	return c.Model, err
}

//根据model中指定的id删除
func (c *SysCheckModelMgr) Delete() (err error) {
	dblog := new(SystemLog)
	dblog.SetUserInfo(c.GetUserInfo())
	dblog.Audittype = enum.AuditType_check_model
	dblog.Logtype = enum.LogType_Delete
	dblog.Eventtype = enum.OptEventType_Bus
	dblog.Eventlevel = enum.OptEventLevel_Hight
	db := orm.NewOrm()
	if c.Model.Id > 0 {
		db.Read(&c.Model)
		_, err = db.Delete(&c.Model)
	}
	if err != nil {
		logger.Logger.Error(err)
		dblog.Description = fmt.Sprintf("删除%s%s失败：%s", sysCheckModelDesc, c.Model.ModelName, err.Error())
		dblog.Fail2()
	} else {
		lsm := new(LinkStyleModelMgr)
		lsm.Model.ModelId = c.Model.Id
		lsm.Delete()
		dblog.Description = fmt.Sprintf("删除%s%s成功", sysCheckModelDesc, c.Model.ModelName)
		dblog.Success2()
	}
	return err
}

//根据model中的指定过滤属性条件查询列表
func (c *SysCheckModelMgr) List(pageno, pagesize int) ([]orm.Params, int, error) {
	dblog := new(SystemLog)
	dblog.SetUserInfo(c.GetUserInfo())
	dblog.Audittype = enum.AuditType_check_model
	dblog.Logtype = enum.LogType_Query
	dblog.Eventtype = enum.OptEventType_Bus
	dblog.Eventlevel = enum.OptEventLevel_Low
	o := orm.NewOrm()
	sqlParamters := []interface{}{}
	sql := "select t.*,t1.name area_type_name,s1.name line_link_style_name,v1.name voltage_level_name from t_data_model_defualt t left join global_const_code t1 on t.area_type=t1.id and t1.parentcode='area_type' left join global_const_code v1 on t.voltage_level=v1.id and v1.parentcode='voltage_level' left join t_data_link_style s1 on t.line_link_style=s1.id  where 1=1 "

	if c.Model.Id > 0 {
		sql += " and t.id=?"
		sqlParamters = append(sqlParamters, c.Model.Id)
	}
	if c.Model.VolId > 0 {
		sql += " and t.vol_id=?"
		sqlParamters = append(sqlParamters, c.Model.VolId)
	}
	if c.Model.LineLinkStyle > 0 {
		sql += " and t.line_link_style=?"
		sqlParamters = append(sqlParamters, c.Model.LineLinkStyle)
	}
	if c.Model.AreaType > 0 {
		sql += " and t.area_type=?"
		sqlParamters = append(sqlParamters, c.Model.AreaType)
	}
	if c.Model.ModelName != "" {
		sql += " and t.model_name like ?"
		sqlParamters = append(sqlParamters, "%"+c.Model.ModelName+"%")
	}
	limit := fmt.Sprintf(" order by t.ct desc limit %d,%d", (pageno-1)*pagesize, pagesize)
	r := []orm.Params{}
	_, err := o.Raw(sql+limit, sqlParamters).Values(&r)
	dblog.Description = fmt.Sprintf("SQL：%s 参数：%+v", sql+limit, sqlParamters)
	if err != nil {
		logger.Logger.Error(err, dblog.Description)
		dblog.Fail2()
		return nil, 0, err
	}
	dblog.Success2()
	total := []orm.Params{}
	_, err = o.Raw(strings.Replace(sql, "t.*,t1.name area_type_name,s1.name line_link_style_name,v1.name voltage_level_name", "count(1) cnt", 1), sqlParamters).Values(&total)
	if err != nil {
		logger.Logger.Error(err)
		return nil, 0, err
	}
	totalCnt := 0
	if len(total) > 0 {
		totalCnt, _ = strconv.Atoi(tools.IsEmpty(total[0]["cnt"]))
	}
	return r, totalCnt, err
}