scd_tools_go/service/models/bo/check_sysmodel_ied_fcda_relation.go

package bo

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

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

//系统内置模型-装置功能点端子关系管理
type T_data_model_fcda_ref struct {
	Id          int    `orm:"pk"`
	ModelId     int    // '模型ID' ,
	RelationRef int    //
	FromIedCode string //
	ToIedCode   string //
	FromFuncId  int
	FromFcdaId  int
	ToFuncId    int
	ToFcdaId    int
	Goosesv     string
	Cr          int    // '创建人' ,
	Ct          string `orm:"-"` // '创建时间' ,
	Ur          int    // '更新人' ,
	Ut          string `orm:"-"` // '更新时间'
}

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

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

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

//保存检测模型装置功能信息
func (c *SysCheckModelFcdaRalationMgr) 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()
	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_iedFcdaRelationDesc, err.Error(), c.Model)
		dblog.Fail2()
	} else {
		dblog.Description = fmt.Sprintf("保存%s信息成功,操作数据：%+v", sysCheckModel_iedFcdaRelationDesc, c.Model)
		dblog.Success2()
	}
	return err
}

//根据model中指定的id删除
func (c *SysCheckModelFcdaRalationMgr) 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.FromFcdaId > 0 {
		_, err = db.Raw("delete from t_data_model_fcda_ref where model_id=? and (from_fcda_id=? or to_fcda_id=?) and to_ied_code=? and goosesv=?", c.Model.ModelId, c.Model.FromFcdaId, c.Model.FromFcdaId, c.Model.ToIedCode, c.Model.Goosesv).Exec()
	} else if c.Model.ToFcdaId > 0 {
		_, err = db.Raw("delete from t_data_model_fcda_ref where model_id=? and (from_fcda_id=? or to_fcda_id=?)", c.Model.ModelId, c.Model.ToFcdaId, c.Model.ToFcdaId).Exec()
	} else if c.Model.FromFuncId > 0 {
		_, err = db.Raw("delete from t_data_model_fcda_ref where model_id=? and from_func_id=?", c.Model.ModelId, c.Model.FromFuncId).Exec()
	} else if c.Model.FromIedCode != "" {
		_, err = db.Raw("delete from t_data_model_fcda_ref where model_id=? and (from_ied_code=? or to_ied_code=?)", c.Model.ModelId, c.Model.FromIedCode, c.Model.FromIedCode).Exec()
	} else if c.Model.ToIedCode != "" {
		_, err = db.Raw("delete from t_data_model_fcda_ref where model_id=? and (from_ied_code=? or to_ied_code=?)", c.Model.ModelId, c.Model.ToIedCode, c.Model.ToIedCode).Exec()
	} else if c.Model.FromFuncId > 0 {
		_, err = db.Raw("delete from t_data_model_fcda_ref where model_id=? and (from_func_id=? or to_func_id=?)", c.Model.ModelId, c.Model.FromFuncId, c.Model.FromFuncId).Exec()
	} else if c.Model.ToFuncId > 0 {
		_, err = db.Raw("delete from t_data_model_fcda_ref where model_id=? and (from_func_id=? or to_func_id=?)", c.Model.ModelId, c.Model.ToFuncId, c.Model.ToFuncId).Exec()
	} else {
		_, err = db.Raw("delete from t_data_model_fcda_ref where model_id=? ", c.Model.ModelId).Exec()
	}
	if err != nil {
		logger.Logger.Error(err)
		dblog.Description = fmt.Sprintf("删除%s(%d)失败：%s", sysCheckModel_iedFcdaRelationDesc, c.Model.ModelId, err.Error())
		dblog.Fail2()
	} else {
		dblog.Description = fmt.Sprintf("删除%s(%d)成功", sysCheckModel_iedFcdaRelationDesc, c.Model.ModelId)
		dblog.Success2()
	}
	return err
}

func (c *SysCheckModelFcdaRalationMgr) GetList() ([]orm.Params, error) {
	o := orm.NewOrm()
	sqlParamters := []interface{}{c.Model.ModelId, c.Model.FromFcdaId}
	sql := "select t.* from t_data_model_fcda_ref t where t.model_id=? and t.from_fcda_id=?"
	if c.Model.ToIedCode != "" {
		sql = sql + " and t.to_ied_code=?"
		sqlParamters = append(sqlParamters, c.Model.ToIedCode)
	}
	if c.Model.Goosesv != "" {
		sql = sql + " and t.goosesv=?"
		sqlParamters = append(sqlParamters, c.Model.Goosesv)
	}
	rowset := []orm.Params{}
	_, err := o.Raw(sql, sqlParamters).Values(&rowset)
	if err != nil {
		logger.Logger.Error(err)
	}
	return rowset, err
}

func (c *SysCheckModelFcdaRalationMgr) GetModelAllFcdaRef() (map[string][]orm.Params, error) {
	db := orm.NewOrm()
	sql := "select r1.*,f1.fcda_name from_fcda_name,f1.fcda_match_exp from_fcda_match_exp,f2.fcda_name to_fcda_name,f2.fcda_match_exp to_fcda_match_exp from t_data_model_fcda_ref r1 left join t_data_model_func_fcda f1 on r1.from_fcda_id=f1.id left join t_data_model_func_fcda f2 on r1.to_fcda_id=f2.id where r1.model_id=? "
	rowset := []orm.Params{}
	sqlParamters := []interface{}{c.Model.ModelId}
	_, err := db.Raw(sql, sqlParamters).Values(&rowset)
	if err != nil {
		logger.Logger.Error(err)
		return nil, err
	}
	result := map[string][]orm.Params{}
	for _, row := range rowset {
		toiedcode := tools.IsEmpty(row["to_ied_code"])
		extref_name_exp := strings.ReplaceAll(tools.IsEmpty(row["to_fcda_match_exp"]), "/", "|")
		if extref_name_exp == "" {
			extref_name_exp = tools.IsEmpty(row["to_fcda_name"])
		}
		row["to_fcda_match_exp"] = extref_name_exp
		fcda_name_exp := strings.ReplaceAll(tools.IsEmpty(row["from_fcda_match_exp"]), "/", "|")
		if fcda_name_exp == "" {
			fcda_name_exp = tools.IsEmpty(row["from_fcda_name"])
		}
		row["from_fcda_match_exp"] = fcda_name_exp
		if result[toiedcode] == nil {
			result[toiedcode] = []orm.Params{}
		}
		result[toiedcode] = append(result[toiedcode], row)
	}
	logger.Logger.Debug(fmt.Sprintf("=====模型%d所有的端子关联关系=====\n%+v", c.Model.ModelId, result))
	return result, err
}