scd_tools_go/service/models/bo/check_sysmodel_ied_func_fcda.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_func_fcda struct {
	Id           int    `orm:"pk"`
	ModelId      int    // '模型ID' ,
	FuncId       int    // '功能ID',
	FcdaName     string // 端子设计名称
	FcdaMatchExp string // 端子匹配表达式
	Svorgoose    string
	Inorout      string
	Cr           int    // '创建人' ,
	Ct           string `orm:"-"` // '创建时间' ,
	Ur           int    // '更新人' ,
	Ut           string `orm:"-"` // '更新时间'
}

//内置检测模型-装置功能点端子管理
type SysCheckModelIedFuncFcdaMgr struct {
	Model T_data_model_func_fcda
	DeviceBaseModel
}

var sysCheckModel_iedFuncFcdaDesc = "内置检测模型-装置功能点端子管理"

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

//保存检测模型装置功能信息
func (c *SysCheckModelIedFuncFcdaMgr) 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
	db := orm.NewOrm()
	hasName, _, err := c.Exist()
	if err != nil {
		return err
	}
	if hasName {
		return errors.New("端子名称[" + c.Model.FcdaName + "]已存在")
	}
	if c.Model.Id > 0 {
		//编辑
		_, err = db.Update(&c.Model)
	} else {
		//新增
		_, err = db.Insert(&c.Model)
	}
	if err != nil {
		logger.Logger.Error(err)
		dblog.Description = fmt.Sprintf("保存%s信息失败：%s,操作数据：%+v", sysCheckModel_iedFuncFcdaDesc, err.Error(), c.Model)
		dblog.Fail2()
	} else {
		dblog.Description = fmt.Sprintf("保存%s信息成功,操作数据：%+v", sysCheckModel_iedFuncFcdaDesc, c.Model)
		dblog.Success2()
	}
	return err
}

func (c *SysCheckModelIedFuncFcdaMgr) Exist() (bool, int, error) {
	db := orm.NewOrm()
	if c.Model.FcdaName == "" {
		return false, 0, errors.New("端子设计名称不能为空")
	}
	rowset := []orm.Params{}
	_, err := db.Raw("select id from t_data_model_func_fcda where model_id=? and func_id=? and fcda_name=?", c.Model.ModelId, c.Model.FuncId, c.Model.FcdaName).Values(&rowset)
	if len(rowset) > 0 {
		findId := tools.IsEmpty(rowset[0]["id"])
		findIdint, _ := strconv.Atoi(findId)
		if tools.IsEmpty(c.Model.Id) != findId {
			//端子名称重复
			return true, c.Model.Id, nil
		} else {
			return false, findIdint, nil
		}
	}
	return false, 0, err
}
func (c *SysCheckModelIedFuncFcdaMgr) Copy(oldFuncId, newModelId, newFuncId int) error {
	db := orm.NewOrm()
	rowset := []orm.Params{}
	db.Raw("select * from t_data_model_func_fcda where model_id=? and func_id=?", c.Model.ModelId, oldFuncId).Values(&rowset)
	for _, row := range rowset {
		oldFcdaId, _ := strconv.Atoi(tools.IsEmpty(row["id"]))
		//复制端子数据
		newFcda := T_data_model_func_fcda{
			ModelId:      newModelId,
			FuncId:       newFuncId,
			FcdaName:     tools.IsEmpty(row["fcda_name"]),
			FcdaMatchExp: tools.IsEmpty(row["fcda_match_exp"]),
			Svorgoose:    tools.IsEmpty(row["svorgoose"]),
			Inorout:      tools.IsEmpty(row["inorout"]),
		}
		newid, err := db.Insert(&newFcda)
		if err != nil {
			logger.Logger.Error(err)
			return err
		}
		db.Raw("update t_data_model_fcda_ref set from_func_id=?,from_fcda_id=? where model_id=? and from_func_id=? and from_fcda_id=?", newFuncId, newid, newModelId, oldFuncId, oldFcdaId).Exec()
		db.Raw("update t_data_model_fcda_ref set to_func_id=?,to_fcda_id=? where model_id=? and to_func_id=? and to_fcda_id=?", newFuncId, newid, newModelId, oldFuncId, oldFcdaId).Exec()
	}
	return nil
}

//根据model中指定的id删除
func (c *SysCheckModelIedFuncFcdaMgr) 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()
	one := T_data_model_func_fcda{Id: c.Model.Id}
	if c.Model.Id > 0 {
		db.Read(&one)
		_, err = db.Raw("delete from t_data_model_func_fcda where id=?", c.Model.Id).Exec()
	} else if c.Model.FuncId > 0 {
		_, err = db.Raw("delete from t_data_model_func_fcda where model_id=? and func_id=?", c.Model.ModelId, c.Model.FuncId).Exec()
	} else {
		_, err = db.Raw("delete from t_data_model_func_fcda where model_id=? ", c.Model.ModelId).Exec()
	}
	if err != nil {
		logger.Logger.Error(err)
		dblog.Description = fmt.Sprintf("删除%s(%d)失败：%s", sysCheckModel_iedFuncFcdaDesc, c.Model.ModelId, err.Error())
		dblog.Fail2()
	} else {
		fcdaMgr := new(SysCheckModelFcdaRalationMgr)
		fcdaMgr.Model = T_data_model_fcda_ref{ModelId: c.Model.ModelId}
		if c.Model.Id > 0 {
			fcdaMgr.Model.FromFcdaId = c.Model.Id
		} else if c.Model.FuncId > 0 {
			fcdaMgr.Model.FromFuncId = c.Model.FuncId
		}
		fcdaMgr.Delete()
		dblog.Description = fmt.Sprintf("删除%s(%d)成功", sysCheckModel_iedFuncFcdaDesc, c.Model.ModelId)
		dblog.Success2()
		if c.Model.Id > 0 {
			//判断端子是否全部删除
			if one.FuncId > 0 {
				c.Model.ModelId = one.ModelId
				c.Model.FuncId = one.FuncId
				r, _ := c.GetList()
				if len(r) == 0 {
					//删除功能定义数据
					funcMgr := new(SysCheckModelIedFuncMgr)
					funcMgr.Model.Id = one.FuncId
					funcMgr.Delete(true)
				}
			}
		} else if c.Model.FuncId > 0 {
			funcMgr := new(SysCheckModelIedFuncMgr)
			funcMgr.Model.Id = c.Model.FuncId
			funcMgr.Delete(true)
		} else {
			funcMgr := new(SysCheckModelIedFuncMgr)
			funcMgr.Model.ModelId = c.Model.ModelId
			funcMgr.Delete(true)
		}
	}
	return err
}

func (c *SysCheckModelIedFuncFcdaMgr) One(id int) (T_data_model_func_fcda, error) {
	tmp := T_data_model_func_fcda{Id: id}
	db := orm.NewOrm()
	err := db.Read(&tmp)
	return tmp, err
}

//获取指定模型及装置功能下的端子信息列表
//funcids:指定的功能编码列表。可不传
func (c *SysCheckModelIedFuncFcdaMgr) GetList(funcids ...[]string) ([]orm.Params, error) {
	o := orm.NewOrm()
	sqlParamters := []interface{}{c.Model.ModelId}
	outsql := ""
	desc := ""
	if c.Model.Inorout == "接收" {
		outsql = ",(select from_fcda_id from t_data_model_fcda_ref where model_id=? and to_fcda_id=t.id) from_fcda_id"
		sqlParamters = append(sqlParamters, c.Model.ModelId)
		desc = " from_fcda_id," //已有关联关系的端子排在前面
	}
	if c.Model.Inorout == "输出" {
		outsql = ",(select to_fcda_id from t_data_model_fcda_ref where model_id=? and from_fcda_id=t.id) to_fcda_id"
		sqlParamters = append(sqlParamters, c.Model.ModelId)
	}
	sql := "select t.*,t1.func_name" + outsql + " from t_data_model_func_fcda t,t_data_model_func_def t1 where t1.id=t.func_id and t.model_id=? "
	if c.Model.FuncId > 0 {
		sql = sql + " and t.func_id=?"
		sqlParamters = append(sqlParamters, c.Model.FuncId)
	}
	if len(funcids) > 0 {
		sql = sql + " and t.func_id in(" + strings.Join(funcids[0], ",") + ")"
	}
	if c.Model.Svorgoose != "" {
		sql = sql + " and t.svorgoose=?"
		sqlParamters = append(sqlParamters, c.Model.Svorgoose)
	}
	if c.Model.Inorout != "" {
		sql = sql + " and t.inorout=?"
		sqlParamters = append(sqlParamters, c.Model.Inorout)
	}
	sql = sql + " order by " + desc + " t.id"
	if c.Model.Inorout == "输出" {
		sql = "select a.id,a.model_id,a.func_id,a.fcda_name,a.fcda_match_exp,a.svorgoose,a.inorout,ifnull(a.to_fcda_id,0) to_fcda_id,ifnull(ff1.fcda_name,'') to_fcda_name,ifnull(fd1.ied_type,'') to_ied_type from (" +
			sql + ") a left join t_data_model_func_fcda ff1 on a.to_fcda_id=ff1.id  LEFT JOIN t_data_model_func_def fd1 on ff1.func_id=fd1.id"
	} else if c.Model.Inorout == "接收" {
		sql = "select a.id,a.model_id,a.func_id,a.fcda_name,a.fcda_match_exp,a.svorgoose,a.inorout,ifnull(a.from_fcda_id,0) from_fcda_id,ifnull(ff1.fcda_name,'') from_fcda_name,ifnull(fd1.ied_type,'') from_ied_type from (" +
			sql + ") a left join t_data_model_func_fcda ff1 on a.from_fcda_id=ff1.id  LEFT JOIN t_data_model_func_def fd1 on ff1.func_id=fd1.id"
	}
	rowset := []orm.Params{}
	_, err := o.Raw(sql, sqlParamters).Values(&rowset)
	if err != nil {
		logger.Logger.Error(err)
	}
	return rowset, err
}