scd_tools_go/service/models/bo/checktools_area.go

package bo

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

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

//检测时间隔管理
type CheckAreaMgr struct {
	DeviceBaseModel
	//SCD文件ID
	ScdId int64
	//电压等级定义
	VoltageLevelDef map[string]int
	//设备类型定义
	DeviceTypeDef          map[string]int
	CacheAreaID            map[string]int64
	CacheAreaIDByIedNameNo map[string]int
	//检测模型列表
	CheckModelList []orm.Params
	//模型内装置关系定义
	CheckModelDef sync.Map
	CacheLock     sync.RWMutex
}

type T_data_check_area struct {
	Id           int64 `orm:"pk"`
	AreaName     string
	ScdId        int64
	VoltageLevel int
	AreaType     string
	ModelId      int
	Cr           int    // '创建人' ,
	Ct           string `orm:"-"` // '创建时间' ,
	Ur           int    // '更新人' ,
	Ut           string `orm:"-"` // '更新时间'
}

type t_data_check_area_ied struct {
	Id      int64 `orm:"pk"`
	AreaId  int64
	IedName string
	IedType string
	ScdId   int64
	PType   string
	Cr      int    // '创建人' ,
	Ct      string `orm:"-"` // '创建时间' ,
	Ur      int    // '更新人' ,
	Ut      string `orm:"-"` // '更新时间'
}

func init() {
	orm.RegisterModel(new(T_data_check_area))
	orm.RegisterModel(new(t_data_check_area_ied))
}

func (c *CheckAreaMgr) Init(scdid int64) {
	c.VoltageLevelDef = map[string]int{}
	c.DeviceTypeDef = map[string]int{}
	c.CacheAreaIDByIedNameNo = map[string]int{}
	c.CacheAreaID = map[string]int64{}
	c.CacheLock = sync.RWMutex{}
	c.ScdId = scdid
	db := orm.NewOrm()
	rowset := []orm.Params{}
	db.Raw("select * from global_const_code where parentcode=?", "voltage_level").Values(&rowset)
	for _, row := range rowset {
		vl := strings.ToLower(tools.IsEmpty(row["code"]))
		id, _ := strconv.ParseInt(tools.IsEmpty(row["id"]), 10, 32)
		c.VoltageLevelDef[strings.ReplaceAll(vl, "v_level_", "")] = int(id)
	}
	db.Raw("select * from global_const_code where parentcode=?", "device_type").Values(&rowset)
	for _, row := range rowset {
		vl := tools.IsEmpty(row["code"])
		c.DeviceTypeDef[vl] = 1
	}
	v, _ := GetSysParamValue("OtherIedNameList", "")
	otherIedNameList = map[string]bool{}
	if v != "" {
		vs := strings.Split(v, ",")
		for _, vv := range vs {
			otherIedNameList[vv] = true
		}
	}
	//先清除ied与间隔关联关系
	clearSql := "delete from t_data_check_area_ied where area_id in(select id from t_data_check_area where  scd_id=?)"
	_, err := db.Raw(clearSql, c.ScdId).Exec()
	if err != nil {
		logger.Logger.Error(err, fmt.Sprintf("SQL:%s 参数：%+v", clearSql, []interface{}{c.ScdId}))
	}
	clearSql = "delete from t_data_check_area where scd_id=?"
	_, err = db.Raw(clearSql, c.ScdId).Exec()
	if err != nil {
		logger.Logger.Error(err, fmt.Sprintf("SQL:%s 参数：%+v", clearSql, []interface{}{c.ScdId}))
	}
	//获取当前scd信息中获取到对应的电压等级id
	/*
		scdMgr := new(ScdMgr)
		scdinfo, _ := scdMgr.One(fmt.Sprintf("%d", c.ScdId))
		stationid := tools.IsEmpty(scdinfo["station_id"])
		volid := 0
		if stationid != "" {
			basearea := new(BasicArea)
			stationonof, _ := basearea.One(stationid)
			volid = stationonof.AreaLevel
		}
	*/
	tmplist, _ := new(SysCheckModelMgr).GetModelsByVolid(2)
	scdModels, _, _ := new(TaskMgr).GetModelsByScdID(c.ScdId)
	ms := map[string]interface{}{}
	for _, row := range scdModels {
		ms[tools.IsEmpty(row["model_id"])] = row
	}
	for _, row := range tmplist {
		modelid := tools.IsEmpty(row["id"])
		if ms[modelid] != nil {
			c.CheckModelList = append(c.CheckModelList, row)
		}
	}
	logger.Logger.Debug(fmt.Sprintf("任务的模型列表：%+v", c.CheckModelList))
	ms = nil
	tmplist = nil
}

//保存指定间隔所属的电压等级
func (c *CheckAreaMgr) SetVoltageLevel(id string, voltagelevel int) error {
	db := orm.NewOrm()
	_, err := db.Raw("update t_data_check_area set voltage_level=? where id=?", voltagelevel, id).Exec()
	return err
}

//修改指定间隔的名称
func (c *CheckAreaMgr) UpdateName(scdid int64, area_id int, name string) error {
	db := orm.NewOrm()
	areaM := T_data_check_area{Id: int64(area_id), ScdId: scdid}
	err := db.Read(&areaM)
	if err != nil {
		logger.Logger.Error(err)
		return err
	}
	areaM.AreaName = name
	_, err = db.Update(&areaM)
	if err != nil {
		logger.Logger.Error(err)
	}
	return err
}

//修改指定IED的所属间隔
func (c *CheckAreaMgr) UpdateIedArea(scdid int64, iedname string, area_id int) error {
	db := orm.NewOrm()
	_, err := db.Raw("update t_data_check_area_ied set area_id=? where scd_id=? and ied_name=?", area_id, scdid, iedname).Exec()
	return err
}

//获取指定scd的间隔信息
func (c *CheckAreaMgr) GetAreaList(scdid int64) ([]orm.Params, error) {
	db := orm.NewOrm()
	sql := "select t.*,(select count(1) from t_data_check_area_ied where area_id=t.id) iedcount from t_data_check_area t where t.scd_id=? order by t.name"
	rowset := []orm.Params{}
	_, err := db.Raw(sql, scdid).Values(&rowset)
	sqllog := fmt.Sprintf("SQL：%s 参数：%+v", sql, []interface{}{scdid})
	if err != nil {
		logger.Logger.Error(err, sqllog)
		new(SystemLog).Fail(enum.AuditType_scd_show, enum.LogType_Query, enum.OptEventType_Bus, enum.OptEventLevel_Low, sqllog, c.GetUserInfo())
	} else {
		new(SystemLog).Success(enum.AuditType_scd_show, enum.LogType_Query, enum.OptEventType_Bus, enum.OptEventLevel_Low, sqllog, c.GetUserInfo())
	}
	return rowset, nil
}

//获取指定scd和电压等级的间隔信息
func (c *CheckAreaMgr) GetAreaListByVol(scdid int64, vl, linkstyleid int) ([]orm.Params, error) {
	db := orm.NewOrm()
	sql := "select t1.id model_id, t1.model_name,t1.vol_id,g1.name vol_name,t1.line_link_style,ls.name,t.id area_id, t.area_name,t.ut,t.ur from t_data_check_area t right join t_data_model_defualt t1 on t.model_id=t1.id left join t_data_link_style ls on t1.line_link_style=ls.id left join global_const_code g1 on t1.vol_id=g1.id and g1.parentcode='voltage_level' where t.scd_id=? "
	params := []interface{}{scdid}
	if vl > 0 {
		sql = sql + " and t1.vol_id=? "
		params = append(params, vl)
	}
	if linkstyleid > 0 {
		sql = sql + " and t1.line_link_style=? "
		params = append(params, linkstyleid)
	}
	rowset := []orm.Params{}
	_, err := db.Raw(sql+" order by t1.vol_id,t1.line_link_style,t1.id", params).Values(&rowset)
	sqllog := fmt.Sprintf("SQL：%s 参数：%+v", sql, []interface{}{scdid, vl})
	if err != nil {
		logger.Logger.Error(err, sqllog)
		new(SystemLog).Fail(enum.AuditType_scd_show, enum.LogType_Query, enum.OptEventType_Bus, enum.OptEventLevel_Low, sqllog, c.GetUserInfo())
	} else {
		new(SystemLog).Success(enum.AuditType_scd_show, enum.LogType_Query, enum.OptEventType_Bus, enum.OptEventLevel_Low, sqllog, c.GetUserInfo())
	}
	return rowset, nil
}

//获取指定间隔下的IED列表
func (c *CheckAreaMgr) GetIedList(scdid int64, areaid int) ([]orm.Params, error) {
	db := orm.NewOrm()
	sql := "select t1.* from t_data_check_area t,t_data_check_area_ied t1 where t.scd_id=? and t.id=t1.area_id "
	sqlParamters := []interface{}{}
	sqlParamters = append(sqlParamters, scdid)
	if areaid > 0 {
		sql = sql + " and t1.area_id=?"
		sqlParamters = append(sqlParamters, areaid)
	}
	scdXmlObj, serr := new(ScdParse).GetScdXmlObjectBySCDID(tools.IsEmpty(scdid))
	if serr != nil {
		return nil, serr
	}
	if scdXmlObj == nil {
		return nil, errors.New("无效的SCD")
	}
	rowset := []orm.Params{}
	_, err := db.Raw(sql, sqlParamters).Values(&rowset)
	sqllog := fmt.Sprintf("SQL：%s 参数：%+v", sql, sqlParamters)
	if err != nil {
		logger.Logger.Error(err, sqllog)
		new(SystemLog).Fail(enum.AuditType_scd_show, enum.LogType_Query, enum.OptEventType_Bus, enum.OptEventLevel_Low, sqllog, c.GetUserInfo())
	} else {
		scdNode := new(ScdNode)

		for i, row := range rowset {
			iedObj := scdNode.GetIed(scdXmlObj, tools.IsEmpty(scdid), tools.IsEmpty(row["ied_name"]))
			if iedObj == nil {
				continue
			}
			rowset[i]["attr_name"] = iedObj.Name
			rowset[i]["attr_desc"] = iedObj.Desc
			rowset[i]["attr_config_version"] = iedObj.ConfigVersion
			rowset[i]["attr_type"] = iedObj.Type
			rowset[i]["attr_manufacturer"] = iedObj.Manufacturer
			rowset[i]["ied_id"] = iedObj.NodeId
		}
		new(SystemLog).Success(enum.AuditType_scd_show, enum.LogType_Query, enum.OptEventType_Bus, enum.OptEventLevel_Low, sqllog, c.GetUserInfo())
	}
	return rowset, nil
}

//更新指定间隔下的装置定义
func (c *CheckAreaMgr) UpdateIeds(scdid int64, areaid int, ieds string) error {
	db := orm.NewOrm()
	iedlist := strings.Split(ieds, ",")
	_, err := db.Raw("delete from t_data_check_area_ied where scd_id=? and area_id=?", scdid, areaid).Exec()
	if err != nil {
		logger.Logger.Error(err)
		return err
	}
	for _, row := range iedlist {
		_, err = db.Raw("insert into t_data_check_area_ied(scd_id,area_id,ied_name)values(?,?,?)", scdid, areaid, row).Exec()
		if err != nil {
			logger.Logger.Error(err)
			break
		}
	}
	return err
}

//获取指定SCD的IED类型列表
func (c *CheckAreaMgr) GetIedTypeList(scdid int64) ([]orm.Params, error) {
	db := orm.NewOrm()
	sql := "select t2.* from t_data_check_area_ied t1,global_const_code t2 where t1.scd_id=? and t1.ied_type=t2.code and t2.parentcode='device_type'  group by t1.ied_type "
	sqlParamters := []interface{}{}
	rowset := []orm.Params{}
	sqlParamters = append(sqlParamters, scdid)
	_, err := db.Raw(sql, sqlParamters).Values(&rowset)
	sqllog := fmt.Sprintf("SQL：%s 参数：%+v", sql, sqlParamters)
	if err != nil {
		logger.Logger.Error(err, sqllog)
		new(SystemLog).Fail(enum.AuditType_scd_show, enum.LogType_Query, enum.OptEventType_Bus, enum.OptEventLevel_Low, sqllog, c.GetUserInfo())
	}
	return rowset, nil
}

func (c *CheckAreaMgr) One(id string) (interface{}, error) {
	db := orm.NewOrm()
	idInt, err := strconv.ParseInt(id, 10, 64)
	if err != nil {
		return nil, err
	}
	areaM := T_data_check_area{Id: idInt}
	err = db.Read(&areaM)
	if err == nil {
		return areaM, nil
	}
	return nil, err
}

//重置scd的间隔信息
func (c *CheckAreaMgr) Reset() error {
	dbo := orm.NewOrm()
	dbo.Raw("delete from t_data_check_area where scd_id=?", c.ScdId).Exec()
	dbo.Raw("delete from t_data_check_area_ied where scd_id=?", c.ScdId).Exec()
	c.ParseModelArea()

	logdesc := fmt.Sprintf("重置SCD[%d]检测模型间隔成功", c.ScdId)
	new(SystemLog).Success(enum.AuditType_check_task, enum.LogType_bind, enum.OptEventType_Bus, enum.OptEventLevel_Mid, logdesc, c.GetUserInfo())
	return nil
}

var areaCheckInfo = sync.Map{}

//获取解析模型需要的基础数据信息
func (c *CheckAreaMgr) getAreaCheckInfo() (*node_attr.SCL, []orm.Params, string, error) {
	key := fmt.Sprintf("%d-checkinfo", c.ScdId)
	if v, h := areaCheckInfo.Load(key); h {
		v1 := v.([]interface{})
		return v1[0].(*node_attr.SCL), v1[1].([]orm.Params), v1[2].(string), nil
	}
	arealist := []orm.Params{}
	db := orm.NewOrm()
	_, err := db.Raw("select id,area_name,area_type,model_id from t_data_check_area where scd_id=?", c.ScdId).Values(&arealist)
	if err != nil {
		logger.Logger.Error(err)
		return nil, nil, "", err
	}
	scdNodeRule := new(ScdNodeRule)
	area_ruleid := ""
	area_ruleList, _, _ := scdNodeRule.GetDefList(map[string]interface{}{"check_name": "间隔装置与检查模型不符"}, 1, 1)
	if len(area_ruleList) > 0 {
		area_ruleid = tools.IsEmpty(area_ruleList[0]["id"])
	}
	if area_ruleid == "" {
		return nil, nil, "", errors.New(fmt.Sprintf("未定义间隔装置的检查规则“间隔装置与检查模型不符”"))
	}
	scdParseMgr := new(ScdParse)
	scdXmlObj, serr := scdParseMgr.GetScdXmlObjectBySCDID(tools.IsEmpty(c.ScdId))
	if serr != nil {
		return nil, nil, "", serr
	}
	if scdXmlObj == nil {
		return nil, nil, "", errors.New("无效的SCD")
	}
	areaCheckInfo.Store(key, []interface{}{scdXmlObj, arealist, area_ruleid})
	return scdXmlObj, arealist, area_ruleid, nil
}

//检测装置端子分析：检测间隔装置关系正确性（已废弃）
func (c *CheckAreaMgr) CheckAreaIedRelation() error {
	// 获取当前scd中需要检查的间隔
	scdXmlObj, arealist, area_ruleid, err := c.getAreaCheckInfo()
	db := orm.NewOrm()
	if err != nil {
		logger.Logger.Error(err)
		return err
	}
	if area_ruleid == "" {
		return errors.New(fmt.Sprintf("未定义间隔装置的检查规则“间隔装置与检查模型不符”"))
	}
	if scdXmlObj == nil {
		return errors.New("无效的SCD")
	}
	scdNodeRule := new(ScdNodeRule)
	scdNode := new(ScdNode)
	model_refs := map[string][]orm.Params{} //模型定义的装置关系定义
	area_ieds := map[string][]orm.Params{}  //间隔下的装置列表
	iedRelationMgr := new(SysCheckModelIedRelationMgr)
	for _, row := range arealist {
		//获取间隔标准装置及关系
		modelid, _ := strconv.Atoi(tools.IsEmpty(row["model_id"]))
		//area_name := tools.IsEmpty(row["area_name"])
		//area_type := tools.IsEmpty(row["area_type"]) //间隔模型类型
		area_id := tools.IsEmpty(row["id"])
		s, err := iedRelationMgr.GetListByModelid(modelid)
		if err != nil {
			logger.Logger.Error(err)
			return err
		}
		if len(s) == 0 {
			return errors.New(fmt.Sprintf("模型%d还未配置装置关系", modelid))
		}
		model_refs[fmt.Sprintf("%d", modelid)] = s
		/*
			hasIeds := map[string]bool{}
			for _, row1 := range s {
				iedname := tools.IsEmpty(row1["from_ied_code"])
				if !hasIeds[iedname] {
					hasIeds[iedname] = true
				}
				iedname = tools.IsEmpty(row1["to_ied_code"])
				if !hasIeds[iedname] {
					hasIeds[iedname] = true
				}
			}
		*/
		s1 := []orm.Params{}
		_, err = db.Raw("select ied_name from t_data_check_area_ied where area_id=?", area_id).Values(&s1)
		if err != nil {
			logger.Logger.Error(err)
			return err
		}
		if len(s) == 0 {
			return errors.New(fmt.Sprintf("间隔%s未发现任何装置", tools.IsEmpty(row["area_name"])))
		}
		area_ieds[area_id] = s1
	}
	//装置关联关系分析
	//先分析母联间隔，如果没有选择母联间隔时，主变间隔中不包含母联终端装置
	HasAreaJ := false
	for _, row := range arealist {
		area_name := tools.IsEmpty(row["area_name"])
		areaCode := tools.IsEmpty(row["area_type"]) //间隔模型类型
		area_id := tools.IsEmpty(row["id"])
		if areaCode == "J" {
			HasAreaJ = true
			modelid := tools.IsEmpty(row["model_id"])
			c.cJ(modelid, scdXmlObj, scdNode, scdNodeRule, area_name, model_refs[modelid], area_ieds[area_id], "PE", area_ruleid)
			c.cJ(modelid, scdXmlObj, scdNode, scdNodeRule, area_name, model_refs[modelid], area_ieds[area_id], "PJ", area_ruleid)
			c.cJ(modelid, scdXmlObj, scdNode, scdNodeRule, area_name, model_refs[modelid], area_ieds[area_id], "PK", area_ruleid)
			c.cJ(modelid, scdXmlObj, scdNode, scdNodeRule, area_name, model_refs[modelid], area_ieds[area_id], "PF", area_ruleid)
		}
	}
	for _, row := range arealist {
		area_name := tools.IsEmpty(row["area_name"])
		areaCode := tools.IsEmpty(row["area_type"]) //间隔模型类型
		area_id := tools.IsEmpty(row["id"])
		modelid := tools.IsEmpty(row["model_id"])
		if areaCode == "J" {
			continue
		}
		if areaCode == "L" {
			//线路间隔
			c.cL(modelid, scdXmlObj, scdNode, scdNodeRule, area_name, model_refs[modelid], area_ieds[area_id], area_ruleid)
		}
		if areaCode == "T" {
			//变压器齐间隔
			c.cT(modelid, scdXmlObj, scdNode, scdNodeRule, area_name, model_refs[modelid], area_ieds[area_id], area_ruleid, HasAreaJ)
		}
	}
	scdNodeRule.CheckFinish()
	scdNodeRule.Flush()
	return nil
}

//检测装置功能分析
func (c *CheckAreaMgr) CheckIedFunc() error {

	return nil
}

//检测装置端子分析
func (c *CheckAreaMgr) CheckIedFcda() error {
	scdXmlObj, arealist, area_ruleid, err := c.getAreaCheckInfo()
	if err != nil {
		logger.Logger.Error(err)
		return err
	}
	if area_ruleid == "" {
		return errors.New(fmt.Sprintf("未定义间隔装置的检查规则“间隔装置与检查模型不符”"))
	}
	if scdXmlObj == nil {
		return errors.New("无效的SCD")
	}
	scdidStr := fmt.Sprintf("%d", c.ScdId)
	db := orm.NewOrm()
	//获取当前站的各电压等级
	volRows := []orm.Params{}
	_, err = db.Raw("select t.vol, CAST(REPLACE(UPPER(g.name),'KV','') as SIGNED) volname from t_area_ied_relation t,global_const_code g  where g.code=CONCAT('v_level_',t.vol) and g.parentcode='voltage_level' and  t.vol!=999 and t.scd_id=? GROUP BY t.vol ORDER BY volname desc", c.ScdId).Values(&volRows)
	if err != nil {
		logger.Logger.Error(err)
		return err
	}
	if len(volRows) == 0 {
		logger.Logger.Error(errors.New("该scd未发现任何电压等级的装置"))
		return errors.New("该scd未发现任何电压等级的装置")
	}
	volMap := map[string]string{}
	volMap["hight"] = tools.IsEmpty(volRows[0]["vol"]) //高压电压
	if len(volRows) == 2 {
		volMap["middle"] = ""
		volMap["low"] = volRows[1]["vol"].(string) //低压电压等级
	} else {
		volMap["middle"] = volRows[1]["vol"].(string)           //中压电压等级
		volMap["low"] = volRows[len(volRows)-1]["vol"].(string) //低压电压等级
	}
	scdNodeRule := new(ScdNodeRule)
	scdNodeRule.SetScdXmlObject(scdXmlObj)
	scdNodeMgr := new(ScdNode)
	//当前装置的所有信号接收端子列表
	var getIedExtRefs = func(iedname string) map[string]*node_attr.NExtRef {
		iedObj := scdNodeMgr.GetIed(scdXmlObj, tools.IsEmpty(c.ScdId), iedname)
		if iedObj == nil {
			logger.Logger.Debug(fmt.Sprintf("在scd：%d中未发现装置%s", c.ScdId, iedname))
			return nil
		}
		fcdaObjList := map[string]*node_attr.NExtRef{}
		for _, t1 := range iedObj.AccessPoint {
			if t1.Server == nil || len(t1.Server.LDevice) == 0 {
				continue
			}
			for _, ld := range t1.Server.LDevice {
				if ld.LN0 != nil && ld.LN0.Inputs != nil {
					for _, t2 := range ld.LN0.Inputs.ExtRef {
						doi := scdNodeRule.IedIntAddrExist(iedname, t2.IntAddr)
						if doi == nil {
							continue
						}
						fcdaObjList[doi.(*node_attr.NDOI).Desc] = t2
					}
				}
				for _, ln := range ld.LN {
					if ln.Inputs == nil {
						continue
					}
					for _, t2 := range ln.Inputs.ExtRef {
						doi := scdNodeRule.IedIntAddrExist(iedname, t2.IntAddr)
						if doi == nil {
							continue
						}
						fcdaObjList[doi.(*node_attr.NDOI).Desc] = t2
					}
				}
			}
		}
		return fcdaObjList
	}
	//当前装置的所有信号发送端子列表
	var getIedFcdas = func(iedname string) map[string]*node_attr.NFCDA {
		iedObj := scdNodeMgr.GetIed(scdXmlObj, tools.IsEmpty(c.ScdId), iedname)
		if iedObj == nil {
			return nil
		}
		fcdaObjList := map[string]*node_attr.NFCDA{}
		for _, t1 := range iedObj.AccessPoint {
			if t1.Server == nil || len(t1.Server.LDevice) == 0 {
				continue
			}
			for _, ld := range t1.Server.LDevice {
				if ld.LN0 != nil && len(ld.LN0.DataSet) > 0 {
					for _, t2 := range ld.LN0.DataSet {
						for _, t3 := range t2.FCDA {
							re, _ := scdNodeRule.IedFcdaExist(iedname, t3.LdInst, t3.LnClass, t3.LnInst, t3.Prefix, t3.DoName, t3.DaName)
							if re == nil {
								continue
							}
							doi := re.(*node_attr.NDOI)
							fcdaObjList[doi.Desc] = t3
						}
					}
				}
			}
		}
		return fcdaObjList
	}
	//从装置类型code中解析出类型代码和电压等级
	var getIedTypeAndVolCode = func(ied_type string) (string, string) {
		tmp := strings.Split(ied_type, "#")
		ied_type = tmp[0]
		vol := ""
		if len(tmp) == 2 {
			vol = tmp[1] //电压级别
		}
		return ied_type, vol
	}
	//从间隔装置中过滤出指定类型的IED
	var filterAreaIeds = func(ied_type, volLevelCode string, s1 []orm.Params, abCode string, isPm ...bool) []orm.Params {
		iedlst := []orm.Params{}
		if volLevelCode == "" || (volLevelCode != "H" && volLevelCode != "M" && volLevelCode != "L") {
			for _, r := range s1 {
				iedname := tools.IsEmpty(r["ied_name"])
				if strings.HasPrefix(iedname, ied_type) || (abCode != "" && strings.HasSuffix(iedname, abCode)) {
					iedlst = append(iedlst, r)
				}
			}
		} else {
			tmpLst := map[string]orm.Params{}
			for _, r := range s1 {
				iedname := tools.IsEmpty(r["ied_name"])
				if strings.HasPrefix(iedname, ied_type) || (abCode != "" && strings.HasSuffix(iedname, abCode)) {
					tmpLst[iedname] = r
				}
			}
			//PM类型的装置需要单独处理
			if len(isPm) > 0 {
				//只有1台PM装置时，不用区分电压等级直接返回
				if len(tmpLst) == 1 {
					for _, r1 := range tmpLst {
						return []orm.Params{r1}
					}
				}
			}
			h, m, l := c.getIedListByVol(ied_type, tmpLst, volMap, abCode)
			if volLevelCode == "H" {
				iedlst = h
			}
			if volLevelCode == "M" {
				iedlst = m
			}
			if volLevelCode == "L" {
				iedlst = l
			}
		}
		return iedlst
	}
	//iedRelationMgr := new(SysCheckModelIedRelationMgr)
	modelFcda := sync.Map{}
	//已经加载过遥信的装置
	isLoadYxIed := map[string]map[*node_attr.NExtRef][]string{}
	//已经处理过遥信端子的装置
	isDealYxIed := map[string]int{}
	//已获取端子的装置
	isLoadExtref := map[string]map[string]*node_attr.NExtRef{}
	for _, row := range arealist {
		//获取间隔标准装置及关系
		modelid, _ := strconv.Atoi(tools.IsEmpty(row["model_id"]))
		area_name := tools.IsEmpty(row["area_name"])
		//area_type := tools.IsEmpty(row["area_type"]) //间隔模型类型
		area_id := tools.IsEmpty(row["id"])
		logger.Logger.Debug(fmt.Sprintf("开始检查模型%d的间隔%s", modelid, area_name))
		//获取装置分组信息
		bgm := new(SysCheckModelIedtypeGroupMgr)
		bgm.Model = T_data_model_iedtype_group{ModelId: modelid}
		groupList := bgm.List()
		//获取该间隔模型配置的所有端子关系列表
		tmpMgr := new(SysCheckModelFcdaRalationMgr)
		tmpMgr.Model.ModelId = modelid
		funclist := map[string][]orm.Params{}
		key := fmt.Sprintf("%d-%d", modelid, area_id)
		v, h := modelFcda.Load(key)
		if h {
			funclist = v.(map[string][]orm.Params)
		} else {
			funclist, _ = tmpMgr.GetModelAllFcdaRef()
			if funclist == nil || len(funclist) == 0 {
				logger.Logger.Error(errors.New(fmt.Sprintf("模型%d下的间隔%s还未配置装置端子关联关系", modelid, area_name)))
				continue
			}
			modelFcda.Store(key, funclist)
		}
		//获取该间隔下该类型的装置
		s1 := []orm.Params{}
		_, err = db.Raw("select ied_name from t_data_check_area_ied where area_id=?", area_id).Values(&s1)
		typeMappingMgr := new(SysCheckModelIedtypeMappingMgr)
		pmCode := c.getIedTypeCode(modelid, "PM")
		//循环处理关联关系
		for to_ied_type2, refrow := range funclist {
			logger.Logger.Debug(fmt.Sprintf("================正在检查类型%s关系===============", to_ied_type2))
			ts := strings.Split(to_ied_type2, ",")
			//从间隔中获取当前同类型的信号接收装置
			ied_type := c.getIedTypeCode(modelid, ts[0])
			if v, h := groupList[ied_type]; h {
				ied_type = typeMappingMgr.GetMappingType(modelid, v)
			}
			abCode := c.getIedTypeABCode(ied_type)
			ied_type, vol := getIedTypeAndVolCode(ied_type)
			isReceivePm := strings.HasPrefix(ied_type, pmCode) //接收装置是Pm装置
			iedlst := filterAreaIeds(ied_type, vol, s1, abCode, isReceivePm)
			logger.Logger.Debug(fmt.Sprintf("装置类型%s#%s与%s的装置(%+v)端子关系", ied_type, vol, ts[1], iedlst))
			//从间隔中获取当前信号输出装置
			outiedlist := map[string]orm.Params{}
			fromiedcode := c.getIedTypeCode(modelid, ts[1])
			if v, h := groupList[fromiedcode]; h {
				fromiedcode = typeMappingMgr.GetMappingType(modelid, v)
			}
			fromAbCode := c.getIedTypeABCode(fromiedcode)
			from_ied_type, vol2 := getIedTypeAndVolCode(fromiedcode)
			isOutPm := strings.HasPrefix(from_ied_type, pmCode) //输出装置是PM装置
			outiedlist2 := filterAreaIeds(from_ied_type, vol2, s1, fromAbCode, isOutPm)
			for _, iedrow := range outiedlist2 {
				iedname := tools.IsEmpty(iedrow["ied_name"])
				outiedlist[iedname] = iedrow
			}
			if len(outiedlist) == 0 {
				logger.Logger.Debug(fmt.Sprintf("装置类型%s#%s%s未从类型%s%s的任何电压等级%s装置接收信号", ied_type, vol, abCode, from_ied_type, fromAbCode, vol2))
				continue
			}
			logger.Logger.Debug(fmt.Sprintf("当前装置类型：%s%s的装置(%+v)与类型%s#%s%s存在以下信号输出装置：%+v", ied_type, abCode, iedlst, from_ied_type, fromAbCode, vol2, outiedlist))
			//logger.Logger.Debug(fmt.Sprintf("设计端子关联关系:%+v", refrow))
			for _, ied := range iedlst {
				iedname := tools.IsEmpty(ied["ied_name"])
				iedObj := scdNodeMgr.GetIed(scdXmlObj, scdidStr, iedname)
				iedObjDesc := ""
				if iedObj != nil {
					iedObjDesc = iedObj.Desc
				} else {
					logger.Logger.Error(fmt.Sprintf("信号接收装置%s未找到！", iedname))
					continue
				}
				//遥信端子列表：仅根据scd实际配置检查其双方端子的doi名称是否相同
				scdMgr := new(ScdMgr)
				yx, h := isLoadYxIed[iedname]
				if !h {
					yx = scdMgr.GetYxExtref(scdXmlObj, c.ScdId, iedname)
					isLoadYxIed[iedname] = yx
				}
				yxAddrMap := map[string]int{}
				for sg, _ := range yx {
					key := fmt.Sprintf("%s%s%s%s%s%s%s", sg.IedName, sg.IntAddr, sg.LdInst, sg.Prefix, sg.LnClass, sg.LnInst, sg.DoName)
					yxAddrMap[key] = 1
				}
				//所有端子列表
				extreflist := isLoadExtref[iedname]
				if extreflist == nil {
					extreflist = getIedExtRefs(iedname)
				}
				for outiedname, _ := range outiedlist {
					if iedname == outiedname {
						continue
					}
					logger.Logger.Debug(fmt.Sprintf("正在匹配装置%s与%s的端子关联关系", iedname, outiedname))
					outIedObj := scdNodeMgr.GetIed(scdXmlObj, scdidStr, outiedname)
					outIedObjDesc := ""
					if outIedObj == nil {
						logger.Logger.Error(fmt.Sprintf("信号输出装置%s未找到！", outiedname))
					} else {
						outIedObjDesc = outIedObj.Desc
					}
					if iedObj == nil && outIedObj == nil {
						continue
					}
					outiedFcdaList := getIedFcdas(outiedname) //输入装置的信号输出端子
					//检查是否有错误和缺失的端子
					for _, r := range refrow {
						extref_name := tools.IsEmpty(r["to_fcda_name"])
						fcda_name := tools.IsEmpty(r["from_fcda_name"])
						extref_name_exp := tools.IsEmpty(r["to_fcda_match_exp"])
						fcda_name_exp := tools.IsEmpty(r["from_fcda_match_exp"])
						funcExist := false //判断接收端设计的端子是否存在
						extrefObj := new(node_attr.NExtRef)
						fcda2Exist := false
						fcdaObj := new(node_attr.NFCDA)
						isYx := false
						for desc, item := range extreflist {
							//logger.Logger.Debug(fmt.Sprintf("接收装置%s的设计端子%s匹配SCD ExtRef DO端子%s", iedname, extref_name_exp, desc))
							if tools.RexGroupTestMatch(extref_name_exp, desc) {
								//判断是否是遥信端子
								if yxAddrMap[fmt.Sprintf("%s%s%s%s%s%s%s", item.IedName, item.IntAddr, item.LdInst, item.Prefix, item.LnClass, item.LnInst, item.DoName)] == 1 {
									isYx = true
									break
								}
								funcExist = true
								extrefObj = item
								break
							}
						}
						if isYx {
							//遥信端子不处理
							continue
						}
						if funcExist {
							//判断输出端端子是否存在
							for desc, item := range outiedFcdaList {
								//logger.Logger.Debug(fmt.Sprintf("输出装置%s的设计端子%s匹配SCD FCDA DO端子%s", outiedname, fcda_name_exp, desc))
								if tools.RexGroupTestMatch(fcda_name_exp, desc) {
									fcda2Exist = true
									fcdaObj = item
									break
								}
							}
						}
						if !funcExist {
							parse_result := fmt.Sprintf("间隔%s的装置%s缺失端子%s", area_name, iedname, extref_name)
							re := map[string]interface{}{"scdid": c.ScdId, "lineno": 0, "ruleid": area_ruleid, "nodeid": 0, "parse_result": parse_result,
								"ied_name":      iedname,
								"ied_desc":      iedObjDesc,
								"out_ied_name":  "",
								"out_ied_desc":  "",
								"fcda_desc":     extref_name,
								"fcda_addr":     "",
								"out_fcda_desc": "",
								"out_fcda_addr": "",
								"error_type":    "3",
							}
							//检查未通过
							scdNodeRule.AppendFcdaCheckResult(re)
						} else {
							//检查端子是否关联正确
							//fcda2Exist为false表示实际的端子from ied不是当前设计的ied
							//fcda2Exist为true时，进一步判断端子地址是否与设计相符
							if !fcda2Exist || (extrefObj.LdInst != fcdaObj.LdInst ||
								extrefObj.LnInst != fcdaObj.LnInst ||
								extrefObj.LnClass != fcdaObj.LnClass ||
								extrefObj.Prefix != fcdaObj.Prefix ||
								extrefObj.DoName != fcdaObj.DoName) {
								//不正确
								//logger.Logger.Debug(fmt.Sprintf("extref_name:%s extref_name_exp:%s extrefObj:%+v", extref_name, extref_name_exp, extrefObj))
								//logger.Logger.Debug(fmt.Sprintf("fcda_name:%s fcda_name_exp:%s fcdaObj:%+v", fcda_name, fcda_name_exp, fcdaObj))
								parse_result := fmt.Sprintf("间隔%s的装置%s端子%s与装置%s端子%s关联错误", area_name, iedname, extref_name, outiedname, fcda_name)
								daname := ""
								if fcdaObj.DaName != "" {
									daname = "." + fcdaObj.DaName
								}
								re := map[string]interface{}{"scdid": c.ScdId, "lineno": 0, "ruleid": area_ruleid, "nodeid": 0, "parse_result": parse_result,
									"ied_name":      iedname,
									"ied_desc":      iedObj.Desc,
									"out_ied_name":  outiedname,
									"out_ied_desc":  outIedObjDesc,
									"fcda_desc":     extref_name,
									"fcda_addr":     extrefObj.IntAddr,
									"out_fcda_desc": fcda_name,
									"out_fcda_addr": fmt.Sprintf("%s/%s%s%s.%s%s", fcdaObj.LdInst, fcdaObj.Prefix, fcdaObj.LnClass, fcdaObj.LnInst, fcdaObj.DoName, daname),
									"error_type":    "2",
								}
								//检查未通过
								scdNodeRule.AppendFcdaCheckResult(re)
							}
						}
					}
					//检查是否有多余（SCD中有不存在于设计中）的端子
					for extrefdesc, r := range extreflist { //scd中的端子关系
						//判断是否是遥信端子
						if yxAddrMap[fmt.Sprintf("%s%s%s%s%s%s%s", r.IedName, r.IntAddr, r.LdInst, r.Prefix, r.LnClass, r.LnInst, r.DoName)] == 1 {
							continue
						}
						extref_name := ""
						fcda_name := ""
						isHave := false
						for _, r1 := range refrow { //设计的端子关系
							extref_name_exp := tools.IsEmpty(r1["to_fcda_match_exp"])
							if extrefdesc == extref_name_exp || tools.RexGroupTestMatch(extref_name_exp, extrefdesc) {
								//端子存在
								isHave = true
								break
							}
						}
						if !isHave {
							daname := ""
							if r.DaName != "" {
								daname = "." + r.DaName
							}
							doi := scdNodeRule.IedIntAddrExist(iedname, r.IntAddr)
							if doi != nil {
								extref_name = doi.(*node_attr.NDOI).Desc
							}
							doi, _ = scdNodeRule.IedFcdaExist(r.IedName, r.LdInst, r.LnClass, r.LnInst, r.Prefix, r.DoName, "")
							if doi != nil {
								fcda_name = doi.(*node_attr.NDOI).Desc
							}
							tmpIedObj := scdNodeMgr.GetIed(scdXmlObj, scdidStr, r.IedName)
							parse_result := fmt.Sprintf("间隔%s下装置(%s)的端子%s在设计中不存在", area_name, iedname, extref_name)
							re := map[string]interface{}{"scdid": c.ScdId, "lineno": 0, "ruleid": area_ruleid, "nodeid": 0, "parse_result": parse_result,
								"ied_name":      iedname,
								"ied_desc":      iedObj.Desc,
								"out_ied_name":  r.IedName,
								"out_ied_desc":  tmpIedObj.Desc,
								"fcda_desc":     extref_name,
								"fcda_addr":     r.IntAddr,
								"out_fcda_desc": fcda_name,
								"out_fcda_addr": fmt.Sprintf("%s/%s%s%s.%s%s", r.LdInst, r.Prefix, r.LnClass, r.LnInst, r.DoName, daname),
								"error_type":    "1",
							}
							//检查未通过
							scdNodeRule.AppendFcdaCheckResult(re)
						}
					}
				}
				//判断装置是否具备遥信功能，具备时需要单独处理遥信类端子
				//遥信类端子处理规则：以scd中实际配置为准，通过检查装置双方的端子名称是否完全一致以及单双点类型是否相同，以及是否有缺失和多余的遥信端子
				if len(yx) > 0 && isDealYxIed[iedname] == 0 {
					//logger.Logger.Debug(fmt.Sprintf("=============正在处理装置%s遥信端子数:%d  %+v", iedname, len(yx), isDealYxIed))
					isDealYxIed[iedname] = 1
					for extref, doiinfo := range yx {
						doiDesc := doiinfo[0]
						doiCdc := doiinfo[1]
						daname := ""
						if extref.DaName != "" {
							daname = "." + extref.DaName
						}
						//获取输出端端子名称
						outFcdaDoi, _ := scdNodeRule.IedFcdaExist(extref.IedName, extref.LdInst, extref.LnClass, extref.LnInst, extref.Prefix, extref.DoName, extref.DaName)
						tmpIedObj := scdNodeMgr.GetIed(scdXmlObj, scdidStr, extref.IedName)
						if tmpIedObj == nil || outFcdaDoi == nil {
							//端子缺失
							parse_result := fmt.Sprintf("间隔%s的装置%s遥信端子%s的关联端子不存在", area_name, iedname, doiDesc)
							re := map[string]interface{}{"scdid": c.ScdId, "lineno": 0, "ruleid": area_ruleid, "nodeid": 0, "parse_result": parse_result,
								"ied_name":      iedname,
								"ied_desc":      iedObj.Desc,
								"out_ied_name":  tmpIedObj.Name,
								"out_ied_desc":  tmpIedObj.Desc,
								"fcda_desc":     doiDesc,
								"fcda_addr":     extref.IntAddr,
								"out_fcda_desc": "",
								"out_fcda_addr": fmt.Sprintf("%s/%s%s%s.%s%s", extref.LdInst, extref.Prefix, extref.LnClass, extref.LnInst, extref.DoName, daname),
								"error_type":    "3",
							}
							//检查未通过
							scdNodeRule.AppendFcdaCheckResult(re)
							continue
						}
						if doiCdc != "" && (!YaoXinDBType[doiCdc] || !YaoXinSiType[doiCdc]) {
							//判断是否是双点或单点遥信端子
							fcdaCdcCode := new(ScdMgr).GetDoiCdcInfo(scdXmlObj, c.ScdId, outFcdaDoi.(*node_attr.NDOI))
							if doiCdc != fcdaCdcCode {
								//错误：cdc类型不一致
								parse_result := fmt.Sprintf("间隔%s的接收装置%s遥信端子%s与输出装置%s端子%s的CDC类型不一致(%s,%s)", area_name, iedname, doiDesc, tmpIedObj.Name, outFcdaDoi.(*node_attr.NDOI).Desc, doiCdc, fcdaCdcCode)
								re := map[string]interface{}{"scdid": c.ScdId, "lineno": 0, "ruleid": area_ruleid, "nodeid": 0, "parse_result": parse_result,
									"ied_name":      iedname,
									"ied_desc":      iedObj.Desc,
									"out_ied_name":  tmpIedObj.Name,
									"out_ied_desc":  tmpIedObj.Desc,
									"fcda_desc":     doiDesc,
									"fcda_addr":     extref.IntAddr,
									"out_fcda_desc": outFcdaDoi.(*node_attr.NDOI).Desc,
									"out_fcda_addr": fmt.Sprintf("%s/%s%s%s.%s%s", extref.LdInst, extref.Prefix, extref.LnClass, extref.LnInst, extref.DoName, daname),
									"error_type":    "2",
								}
								//检查未通过
								scdNodeRule.AppendFcdaCheckResult(re)
								continue
							}
						}
						if outFcdaDoi.(*node_attr.NDOI).Desc != doiDesc {
							//关联错误
							parse_result := fmt.Sprintf("间隔%s的装置%s遥信端子%s与装置%s端子%s名称不匹配", area_name, iedname, doiDesc, tmpIedObj.Name, outFcdaDoi.(*node_attr.NDOI).Desc)
							re := map[string]interface{}{"scdid": c.ScdId, "lineno": 0, "ruleid": area_ruleid, "nodeid": 0, "parse_result": parse_result,
								"ied_name":      iedname,
								"ied_desc":      iedObj.Desc,
								"out_ied_name":  tmpIedObj.Name,
								"out_ied_desc":  tmpIedObj.Desc,
								"fcda_desc":     doiDesc,
								"fcda_addr":     extref.IntAddr,
								"out_fcda_desc": outFcdaDoi.(*node_attr.NDOI).Desc,
								"out_fcda_addr": fmt.Sprintf("%s/%s%s%s.%s%s", extref.LdInst, extref.Prefix, extref.LnClass, extref.LnInst, extref.DoName, daname),
								"error_type":    "2",
							}
							//检查未通过
							scdNodeRule.AppendFcdaCheckResult(re)
						}
					}
				}
				yxAddrMap = nil
				extreflist = nil
			}
		}
	}
	isLoadYxIed = nil
	isDealYxIed = nil
	scdNodeRule.CheckFinish()
	scdNodeRule.Flush()
	return nil
}

//解析模型间隔。根据模型定义解析出间隔中的装置
func (c *CheckAreaMgr) ParseModelArea() {
	c.Init(c.ScdId)
	key := fmt.Sprintf("%d-checkinfo", c.ScdId)
	areaCheckInfo.Delete(key)
	// 取得当前scd所有ied及名称解析结果
	dbo := orm.NewOrm()
	sql := "select t.*,t1.name area_name from t_area_ied_relation t,t_substation_area t1 where t.area_id=t1.id and t.scd_id=? order by t.p_type"
	iedlst := []orm.Params{}
	_, err := dbo.Raw(sql, c.ScdId).Values(&iedlst)
	if err != nil {
		logger.Logger.Error(err)
		return
	}
	logger.Logger.Debug(fmt.Sprintf("=====总装置数：%d", len(iedlst)))
	iedMap := map[string]orm.Params{}
	for _, r := range iedlst {
		iedMap[tools.IsEmpty(r["ied_name"])] = r
	}
	//先分析母联间隔，如果没有选择母联间隔时，主变间隔中不包含母联终端装置
	HasAreaJ := false
	for _, row := range c.CheckModelList {
		areaCode := tools.IsEmpty(row["area_type_code"])
		if areaCode == "J" {
			HasAreaJ = true
			modelid, _ := strconv.Atoi(tools.IsEmpty(row["id"]))
			//modelname := tools.IsEmpty(row["model_name"])
			iedtypes := tools.IsEmpty(row["ied_types"])
			mapptype := new(SysCheckModelIedtypeMappingMgr)
			mapptype.Model = T_data_model_iedtype_mapping{ModelId: modelid}
			mappresult := mapptype.List()
			if len(mappresult) > 0 {
				tmp := []string{}
				for _, r := range strings.Split(iedtypes, ",") {
					if mappresult[r] != "" {
						tmp = append(tmp, mappresult[r])
					} else {
						tmp = append(tmp, r)
					}
				}
				iedtypes = strings.Join(tmp, ",")
			}
			volcode := strings.ReplaceAll(tools.IsEmpty(row["vol_code"]), "v_level_", "")
			c.pJ(modelid, volcode, iedtypes, iedMap, "PE")
			c.pJ(modelid, volcode, iedtypes, iedMap, "PJ")
			c.pJ(modelid, volcode, iedtypes, iedMap, "PK")
			c.pJ(modelid, volcode, iedtypes, iedMap, "PF")
		}
	}
	for _, row := range c.CheckModelList {
		//逐一分析模型定义
		modelid, _ := strconv.Atoi(tools.IsEmpty(row["id"]))
		modelname := tools.IsEmpty(row["model_name"])
		iedtypes := tools.IsEmpty(row["ied_types"])
		//模型对应的间隔代码
		/*
			S	站用变压器
			C	电容器
			B	断路器
			K	母分
			J	母联
			M	母线
			X	电抗器
			L	线路
			T	主变压器
		*/
		areaCode := tools.IsEmpty(row["area_type_code"])
		//模型对应的电压等级
		//10:10KV 35:35KV 66:66KV 11:110KV 22:220KV 50:500KV 75:750KV 33:330KV T0:1000KV
		volcode := strings.ReplaceAll(tools.IsEmpty(row["vol_code"]), "v_level_", "")
		if modelname == "" || iedtypes == "" {
			continue
		}
		//母联间隔已经提前分析，如果没有母联间隔时，主变间隔中不包含母联终端装置
		if areaCode == "J" {
			continue
		}
		//获取模型中的自定义装置类型编码
		mapptype := new(SysCheckModelIedtypeMappingMgr)
		mapptype.Model = T_data_model_iedtype_mapping{ModelId: modelid}
		mappresult := mapptype.List()
		if len(mappresult) > 0 {
			tmp := []string{}
			for _, r := range strings.Split(iedtypes, ",") {
				if mappresult[r] != "" {
					tmp = append(tmp, mappresult[r])
				} else {
					tmp = append(tmp, r)
				}
			}
			iedtypes = strings.Join(tmp, ",")
		}
		//获取模型内中装备关系定义
		//主变间隔分析：需要查站内该电压等级下的高中低压侧装置或者高低压装置组成一个间隔，以主变保护装置(PT)为起始
		if areaCode == "T" {
			c.pT(modelid, iedtypes, iedMap, HasAreaJ)
		}
		//线路保护间隔分析：以线路保护测控装置（PL）为开始分析
		if areaCode == "L" {
			c.pL(modelid, volcode, iedtypes, iedMap)
		}
	}
}

//根据默认装置类型获取其类型编码。如果没有自定义编码，则返回默认编码。返回编码时已自动去除套别标识
func (c *CheckAreaMgr) getIedTypeCode(modelid int, iedtype string) string {
	mapptype := new(SysCheckModelIedtypeMappingMgr)
	mappresult := mapptype.GetMappingType(modelid, iedtype)
	ptCode := iedtype
	if mappresult != "" {
		ptCode = mappresult //自定义主变保护编码
	}
	return strings.Split(ptCode, "-")[0]
}

//变压器间隔分析
func (c *CheckAreaMgr) pT(modelid int, iedtypes string, ieds map[string]orm.Params, HasAreaJ bool) {
	scdParseMgr := new(ScdParse)
	scdNodeMgr := new(ScdNode)
	db := orm.NewOrm()
	//获取装置分组信息
	bgm := new(SysCheckModelIedtypeGroupMgr)
	bgm.Model = T_data_model_iedtype_group{ModelId: modelid}
	groupList := bgm.List()
	scdXmlObj, _ := scdParseMgr.GetScdXmlObjectBySCDID(tools.IsEmpty(c.ScdId))
	//获取当前站的各电压等级
	volRows := []orm.Params{}
	_, err := db.Raw("select t.vol, CAST(REPLACE(UPPER(g.name),'KV','') as SIGNED) volname from t_area_ied_relation t,global_const_code g  where g.code=CONCAT('v_level_',t.vol) and g.parentcode='voltage_level' and  t.vol!=999 and t.scd_id=? GROUP BY t.vol ORDER BY volname desc", c.ScdId).Values(&volRows)
	if err != nil {
		logger.Logger.Error(err)
		return
	}
	if len(volRows) == 0 {
		logger.Logger.Error(errors.New("该scd未发现任何电压等级的装置"))
		return
	}
	volMap := map[string]string{}
	volMap["hight"] = tools.IsEmpty(volRows[0]["vol"]) //高压电压
	if len(volRows) == 2 {
		volMap["middle"] = ""
		volMap["low"] = volRows[1]["vol"].(string) //低压电压等级
	} else {
		volMap["middle"] = volRows[1]["vol"].(string)           //中压电压等级
		volMap["low"] = volRows[len(volRows)-1]["vol"].(string) //低压电压等级
	}

	var getIedByDesc = func(iedinfo map[string]orm.Params, iedtpye string, desc string) ([]string, []string) {
		scdParseMgr := new(ScdParse)
		scdXmlObj, _ := scdParseMgr.GetScdXmlObjectBySCDID(tools.IsEmpty(c.ScdId))
		r1 := []string{}
		r2 := []string{}
		for vn, row := range iedinfo {
			if strings.HasPrefix(vn, iedtpye) {
				v := tools.IsEmpty(row["ied_desc"])
				if v == "" {
					if scdXmlObj == nil {
						continue
					}
					scdNode := new(ScdNode)
					ied := scdNode.GetIed(scdXmlObj, "", vn)
					if ied == nil {
						continue
					}
					v = ied.Desc
				}
				if strings.Contains(v, desc) {
					r1 = append(r1, v)
					r2 = append(r2, vn)
				}
			}
		}
		return r1, r2
	}
	//判断是否将各电压等级的保护装置合并还是分开的间隔
	//如果存在高中低压的保护装置，则说明是分开的主变间隔
	ptCode := c.getIedTypeCode(modelid, "PT")
	volValue := "" //电压等级值
	if strings.Index(","+iedtypes+",", ","+ptCode+",") == -1 {
		//判断主变保护是否是按电压等级分开配置的模型
		h, m, l := c.getIedListByVol(ptCode, ieds, volMap)
		if strings.Contains(iedtypes, ptCode+"#H") && len(h) > 0 {
			//高压侧装置
			volValue = "H"
		} else if strings.Contains(iedtypes, ptCode+"#M") && len(m) > 0 {
			volValue = "M"
		} else if strings.Contains(iedtypes, ptCode+"#L") && len(l) > 0 {
			volValue = "L"
		}
	}
	pmCode := c.getIedTypeCode(modelid, "PM")
	mmCode := c.getIedTypeCode(modelid, "MM")
	ctCode := c.getIedTypeCode(modelid, "CT")
	delPm := false
	delMm := false
	for _, row := range ieds {
		if tools.IsEmpty(row["ied_type"]) != ptCode[0:1] || tools.IsEmpty(row["p_type"]) != ptCode[1:] {
			continue
		}
		if _, h := groupList[ptCode]; h {
			//装置如果是分组成员装置，则不用检测
			continue
		}
		pl_iedname := tools.IsEmpty(row["ied_name"])
		iednameParts := scdParseMgr.ParseIedName(pl_iedname)
		areadesc := tools.IsEmpty(row["ied_desc"])
		if areadesc == "" {
			iedobj := scdNodeMgr.GetIed(scdXmlObj, "", pl_iedname)
			if iedobj != nil {
				areadesc = iedobj.Desc
			} else {
				areadesc = tools.IsEmpty(row["area_name"])
			}
		}
		areadesc = strings.ReplaceAll(areadesc, "装置", "")
		//添加间隔数据
		dbdata := T_data_check_area{
			ModelId:  modelid,
			ScdId:    c.ScdId,
			AreaType: "T",
			AreaName: areadesc + iednameParts[7],
		}
		newid, err := db.Insert(&dbdata)
		if err != nil {
			logger.Logger.Error(err)
			return
		}
		ins1 := "insert into t_data_check_area_ied(scd_id,area_id,ied_name,ied_type,p_type)values"
		insvalues := []string{}
		inAreaIedName := ""
		//insvalues = append(insvalues, fmt.Sprintf("(%d,%d,'%s','%s','%s')", c.ScdId, newid, inAreaIedName, "P", "T"))
		for _, ty := range strings.Split(iedtypes, ",") {
			inAreaIedName = ""
			if _, h := groupList[ty]; h {
				//装置如果是分组成员装置，则不用检测
				continue
			}
			tyCode := c.getIedTypeCode(modelid, ty)
			if _, h := groupList[tyCode]; h {
				//装置如果是分组成员装置，则不用检测
				continue
			}
			if tyCode[0:len(pmCode)] == pmCode {
				//PM和MM最后处理
				delPm = true
				continue
			}
			if tyCode[0:len(mmCode)] == mmCode {
				//PM和MM最后处理
				delMm = true
				continue
			}
			//判断是否指定的套别标识
			abCode := c.getIedTypeABCode(tyCode)
			if abCode != "" {
				iednameParts[7] = abCode
			}
			//判断间隔是否需要包含差动装置
			if strings.Contains(tyCode, "#C") {
				_, iedname := getIedByDesc(ieds, tyCode, "差动")
				if len(iedname) > 0 {
					for _, in := range iedname {
						tmpIednameParts := scdParseMgr.ParseIedName(in)
						if tmpIednameParts[6] == iednameParts[6] && tmpIednameParts[7] == iednameParts[7] {
							insvalues = append(insvalues, fmt.Sprintf("(%d,%d,'%s','%s','%s')", c.ScdId, newid, in, tyCode[0:1], tyCode[1:]))
							break
						}
					}
				}
			}
			//判断间隔是否需要包含本体保护装置
			if strings.Contains(tyCode, "#0") {
				_, iedname := getIedByDesc(ieds, tyCode, "本体")
				if len(iedname) > 0 {
					for _, in := range iedname {
						tmpIednameParts := scdParseMgr.ParseIedName(in)
						if tmpIednameParts[6] == iednameParts[6] && tmpIednameParts[7] == iednameParts[7] {
							insvalues = append(insvalues, fmt.Sprintf("(%d,%d,'%s','%s','%s')", c.ScdId, newid, in, tyCode[0:1], tyCode[1:]))
							break
						}
					}
				}
			}
			dlIeds := []orm.Params{}
			imtcode := c.getIedTypeCode(modelid, tyCode)
			h, m, l := c.getIedListByVol(imtcode, ieds, volMap, abCode)
			//logger.Logger.Debug(fmt.Sprintf("tyCode:%s H：%+v，M：%+v，L：%+v", tyCode, h, m, l))
			if volValue == "" || volValue == "H" {
				dlIeds = append(dlIeds, h...)
			}
			if volValue == "" || volValue == "M" {
				dlIeds = append(dlIeds, m...)
			}
			if volValue == "" || volValue == "L" {
				dlIeds = append(dlIeds, l...)
			}
			for _, r := range dlIeds {
				inAreaIedName = tools.IsEmpty(r["ied_name"])
				tmpIednameParts := scdParseMgr.ParseIedName(inAreaIedName)
				if tyCode[0:len(ctCode)] == ctCode {
					//CT单独处理。它可能不分AB套
					lastChar := tmpIednameParts[7]
					if tmpIednameParts[6] == iednameParts[6] && (lastChar == "" || lastChar == iednameParts[7]) {
						insvalues = append(insvalues, fmt.Sprintf("(%d,%d,'%s','%s','%s')", c.ScdId, newid, inAreaIedName, tyCode[0:1], tyCode[1:]))
					}
				} else {
					if tmpIednameParts[6] == iednameParts[6] && tmpIednameParts[7] == iednameParts[7] {
						insvalues = append(insvalues, fmt.Sprintf("(%d,%d,'%s','%s','%s')", c.ScdId, newid, inAreaIedName, tyCode[0:1], tyCode[1:]))
					}
				}
			}
		}
		//最后处理PM和MM
		inAreaIedName = c.getPMName(iednameParts, ieds)
		if delPm && inAreaIedName != "" {
			insvalues = append(insvalues, fmt.Sprintf("(%d,%d,'%s','%s','%s')", c.ScdId, newid, inAreaIedName, "P", "M"))
			//pmIedNameParts := scdParseMgr.ParseIedName(pmIedName)
			//使用PM装置的名称去定义MM的名称
			inAreaIedName = c.getMMName(iednameParts, ieds, iednameParts[7])
			if delMm && inAreaIedName != "" {
				insvalues = append(insvalues, fmt.Sprintf("(%d,%d,'%s','%s','%s')", c.ScdId, newid, inAreaIedName, "M", "M"))
			}
		}
		//写数据库
		if len(insvalues) > 0 {
			_, err = db.Raw(ins1 + strings.Join(insvalues, ",")).Exec()
		}
		if err != nil {
			logger.Logger.Error(err)
			return
		}
	}
}

//线路间隔分析
//vol：电压等级
func (c *CheckAreaMgr) pL(modelid int, vol, iedtypes string, ieds map[string]orm.Params) {
	scdParseMgr := new(ScdParse)
	scdNodeMgr := new(ScdNode)
	db := orm.NewOrm()
	//获取装置分组信息
	bgm := new(SysCheckModelIedtypeGroupMgr)
	bgm.Model = T_data_model_iedtype_group{ModelId: modelid}
	groupList := bgm.List()
	scdXmlObj, _ := scdParseMgr.GetScdXmlObjectBySCDID(tools.IsEmpty(c.ScdId))
	iedCode := c.getIedTypeCode(modelid, "PL")
	for _, row := range ieds {
		if tools.IsEmpty(row["vol"]) != vol || tools.IsEmpty(row["ied_type"]) != iedCode[0:1] || tools.IsEmpty(row["p_type"]) != iedCode[1:] {
			continue
		}
		pmIedName := ""
		mmIedName := ""
		pl_iedname := tools.IsEmpty(row["ied_name"])
		if _, h := groupList[pl_iedname]; h {
			//装置如果是分组成员装置，则不用检测
			continue
		}
		iednameParts := scdParseMgr.ParseIedName(pl_iedname)
		areadesc := tools.IsEmpty(row["ied_desc"])
		if areadesc == "" {
			iedobj := scdNodeMgr.GetIed(scdXmlObj, "", pl_iedname)
			if iedobj != nil {
				areadesc = iedobj.Desc
			} else {
				areadesc = tools.IsEmpty(row["area_name"])
			}
		}
		areadesc = strings.ReplaceAll(areadesc, "装置", "")
		//添加间隔数据
		dbdata := T_data_check_area{
			ModelId:  modelid,
			ScdId:    c.ScdId,
			AreaType: "L",
			AreaName: areadesc + iednameParts[7],
		}
		newid, err := db.Insert(&dbdata)
		if err != nil {
			logger.Logger.Error(err)
			return
		}
		ins1 := "insert into t_data_check_area_ied(scd_id,area_id,ied_name,ied_type,p_type)values"
		insvalues := []string{}
		pmCode := c.getIedTypeCode(modelid, "PM")
		mmCode := c.getIedTypeCode(modelid, "MM")
		clCode := c.getIedTypeCode(modelid, "CL")
		for _, ty := range strings.Split(iedtypes, ",") {
			inAreaIedName := ""
			if _, h := groupList[ty]; h {
				//装置如果是分组成员装置，则不用检测
				continue
			}
			tyCode := c.getIedTypeCode(modelid, ty)
			if _, h := groupList[tyCode]; h {
				//装置如果是分组成员装置，则不用检测
				continue
			}
			abCode := c.getIedTypeABCode(tyCode)
			if abCode != "" {
				iednameParts[7] = abCode
			}
			if tyCode == pmCode {
				//母线保护和母线合并单元装置编号跟随变压器
				//查找变压器编号
				//1号变压器->2号变压器->3号
				inAreaIedName = c.getPMName(iednameParts, ieds)
				pmIedName = inAreaIedName
				if mmIedName == "" {
					insvalues = append(insvalues, fmt.Sprintf("(%d,%d,'%s','%s','%s')", c.ScdId, newid, inAreaIedName, ty[0:1], ty[1:2]))
					//pmIedNameParts := scdParseMgr.ParseIedName(pmIedName)
					//使用PM装置的名称去定义MM的名称
					tyCode = mmCode
					inAreaIedName = c.getMMName(iednameParts, ieds, iednameParts[7])
					mmIedName = inAreaIedName
				}
			} else if tyCode == mmCode {
				if pmIedName != "" && mmIedName == "" {
					//pmIedNameParts := scdParseMgr.ParseIedName(pmIedName)
					//使用PM装置的名称去定义MM的名称
					inAreaIedName = c.getMMName(iednameParts, ieds, iednameParts[7])
					mmIedName = inAreaIedName
				} else {
					continue
				}
			} else {
				inAreaIedName = tyCode + iednameParts[3] + iednameParts[4] + iednameParts[5] + iednameParts[6] + iednameParts[7]
			}
			if strings.Index("ABCDE", iednameParts[7]) > -1 {
				//最后一位是字母则说明是AB套
				switch tyCode {
				case clCode:
					if strings.Contains(iedtypes, "PLC") || strings.Contains(iedtypes, "PCL") {
						//不处理CL装置
					} else {
						//测控装置，先判断是否分了AB套，没有标识（ied名称的最后一位是否是字母）则说明是多套共用装置
						clIedname := inAreaIedName + iednameParts[7]
						iedObj := ieds[inAreaIedName]
						if iedObj != nil {
							//当前测控装置也分了AB套
							inAreaIedName = clIedname
						}
					}
					break
				default:
					break
				}
			}
			insvalues = append(insvalues, fmt.Sprintf("(%d,%d,'%s','%s','%s')", c.ScdId, newid, inAreaIedName, tyCode[0:1], tyCode[1:]))
		}
		_, err = db.Raw(ins1 + strings.Join(insvalues, ",")).Exec()
		if err != nil {
			logger.Logger.Error(err)
			return
		}
		//如果mm装置还未确定
		if mmIedName == "" {
			//pmIedNameParts := scdParseMgr.ParseIedName(pmIedName)
			inAreaIedName := c.getMMName(iednameParts, ieds, iednameParts[7])
			_, err = db.Raw(ins1 + fmt.Sprintf("(%d,%d,'%s','%s','%s')", c.ScdId, newid, inAreaIedName, "M", "M")).Exec()
			if err != nil {
				logger.Logger.Error(err)
				return
			}
		}
	}
}

//母联间隔分析
func (c *CheckAreaMgr) pJ(modelid int, vol, iedtypes string, ieds map[string]orm.Params, pjIed string) {
	scdParseMgr := new(ScdParse)
	scdNodeMgr := new(ScdNode)
	db := orm.NewOrm()
	pjIed = c.getIedTypeCode(modelid, pjIed)
	scdXmlObject, _ := scdParseMgr.GetScdXmlObjectBySCDID(tools.IsEmpty(c.ScdId))
	for _, row := range ieds {
		if tools.IsEmpty(row["vol"]) != vol || tools.IsEmpty(row["ied_type"]) != pjIed[0:1] || tools.IsEmpty(row["p_type"]) != pjIed[1:2] {
			continue
		}
		pmIedName := ""
		mmIedName := ""
		pl_iedname := tools.IsEmpty(row["ied_name"])
		iednameParts := scdParseMgr.ParseIedName(pl_iedname)
		areadesc := tools.IsEmpty(row["ied_desc"])
		if areadesc == "" {
			iedobj := scdNodeMgr.GetIed(scdXmlObject, "", pl_iedname)
			if iedobj != nil {
				areadesc = iedobj.Desc
			} else {
				areadesc = tools.IsEmpty(row["area_name"])
			}
		}
		areadesc = strings.ReplaceAll(areadesc, "装置", "")
		//添加间隔数据
		dbdata := T_data_check_area{
			ModelId:  modelid,
			ScdId:    c.ScdId,
			AreaType: "J",
			AreaName: areadesc + iednameParts[7],
		}
		newid, err := db.Insert(&dbdata)
		if err != nil {
			logger.Logger.Error(err)
			return
		}
		ins1 := "insert into t_data_check_area_ied(scd_id,area_id,ied_name,ied_type,p_type)values"
		insvalues := []string{}
		pmCode := c.getIedTypeCode(modelid, "PM")
		mmCode := c.getIedTypeCode(modelid, "MM")
		for _, ty := range strings.Split(iedtypes, ",") {
			tyCode := c.getIedTypeCode(modelid, ty)
			inAreaIedName := ""
			if tyCode == pmCode {
				//母线保护和母线合并单元装置编号跟随变压器
				//查找变压器编号
				//1号变压器->2号变压器->3号
				inAreaIedName = c.getPMName(iednameParts, ieds)
				pmIedName = inAreaIedName
				if mmIedName == "" {
					insvalues = append(insvalues, fmt.Sprintf("(%d,%d,'%s','%s','%s')", c.ScdId, newid, inAreaIedName, tyCode[0:1], tyCode[1:2]))
					pmIedNameParts := scdParseMgr.ParseIedName(pmIedName)
					//使用PM装置的名称去定义MM的名称
					tyCode = "MM"
					inAreaIedName = c.getMMName(pmIedNameParts, ieds, iednameParts[7])
					mmIedName = inAreaIedName
				}
			} else if tyCode == mmCode {
				if pmIedName != "" && mmIedName == "" {
					pmIedNameParts := scdParseMgr.ParseIedName(pmIedName)
					//使用PM装置的名称去定义MM的名称
					inAreaIedName = c.getMMName(pmIedNameParts, ieds, iednameParts[7])
					mmIedName = inAreaIedName
				} else {
					continue
				}
			} else {
				tyCode = tyCode[0:1] + pjIed[1:2]
				inAreaIedName = tyCode + iednameParts[3] + iednameParts[4] + iednameParts[5] + iednameParts[6] + iednameParts[7]
				//判断与基准保护装置相同套号的装置是否存在
				if ieds[inAreaIedName] == nil {
					//尝试去除套号
					inAreaIedName = tyCode + iednameParts[3] + iednameParts[4] + iednameParts[5] + iednameParts[6]
				}
			}
			insvalues = append(insvalues, fmt.Sprintf("(%d,%d,'%s','%s','%s')", c.ScdId, newid, inAreaIedName, tyCode[0:1], tyCode[1:2]))
		}
		_, err = db.Raw(ins1 + strings.Join(insvalues, ",")).Exec()
		if err != nil {
			logger.Logger.Error(err)
			return
		}

	}

}

//母联间隔装置关系检查
func (c *CheckAreaMgr) cJ(modelid string, scdXmlObj *node_attr.SCL, scdNodeMgr *ScdNode, scdNodeRule *ScdNodeRule, area_name string, ied_refs []orm.Params, area_ieds []orm.Params, pjIed, area_ruleid string) {
	modelidInt, _ := strconv.Atoi(modelid)
	pjIed = c.getIedTypeCode(modelidInt, pjIed)
	masterIed := new(node_attr.NIED)
	findIedName := ""
	for _, row2 := range area_ieds {
		findIedName = tools.IsEmpty(row2["ied_name"])
		if strings.HasPrefix(findIedName, pjIed) {
			masterIed = scdNodeMgr.GetIed(scdXmlObj, "", findIedName)
			break
		}
	}
	if masterIed == nil {
		return
	}
	dealFromIed := map[string]int{}
	for _, row := range ied_refs {
		fromiedtype := c.getIedTypeCode(modelidInt, tools.IsEmpty(row["from_ied_code"]))
		toiedtype := c.getIedTypeCode(modelidInt, tools.IsEmpty(row["to_ied_code"]))
		reftype := tools.IsEmpty(row["in_type"])
		tmpFromAreaIeds := []orm.Params{}
		tmpToAreaIeds := []orm.Params{}
		for _, row2 := range area_ieds {
			findIedName = tools.IsEmpty(row2["ied_name"])
			if strings.HasPrefix(findIedName, fromiedtype) {
				masterIed = scdNodeMgr.GetIed(scdXmlObj, "", findIedName)
				if masterIed != nil {
					tmpFromAreaIeds = append(tmpFromAreaIeds, row2)
				} else {
					if dealFromIed[findIedName] == 0 {
						parse_result := fmt.Sprintf("间隔%s的装置%s缺失", area_name, findIedName)
						r := map[string]interface{}{"scdid": c.ScdId, "lineno": 0, "ruleid": area_ruleid, "nodeid": 0, "parse_result": parse_result}
						//检查未通过
						scdNodeRule.AppendFcdaCheckResult(r)
					}
					dealFromIed[findIedName] = 1
				}
			}
			if strings.HasPrefix(findIedName, toiedtype) {
				tmpToAreaIeds = append(tmpToAreaIeds, row2)
			}
		}
		if len(tmpFromAreaIeds) == 0 {
			continue
		}
		if len(tmpToAreaIeds) == 0 {
			parse_result := fmt.Sprintf("间隔%s缺失类型为%s的装置", area_name, toiedtype)
			r := map[string]interface{}{"scdid": c.ScdId, "lineno": 0, "ruleid": area_ruleid, "nodeid": 0, "parse_result": parse_result}
			//检查未通过
			scdNodeRule.AppendFcdaCheckResult(r)
			continue
		}
		toIedname := ""
		for _, row2 := range tmpFromAreaIeds {
			findIedName = tools.IsEmpty(row2["ied_name"])
			hasToIedRef := false
			hasToIed := false
			for _, row3 := range tmpToAreaIeds {
				toIedname = tools.IsEmpty(row3["ied_name"])
				masterIed = scdNodeMgr.GetIed(scdXmlObj, "", toIedname)
				if masterIed != nil {
					hasToIed = true
					// 获取该ied的输出(ref_type为0)装置，并从中检测是否存在toiedtype类型的装置
					inout, _ := scdNodeMgr.GetIedRelations(map[string]interface{}{"scd_id": c.ScdId, "ied_name": findIedName})
					logger.Logger.Debug(fmt.Sprintf("ied:%s refs:%+v", findIedName, inout))
					if inout != nil {
						outiedlist := inout[findIedName].(orm.Params)["list"].([]orm.Params)
						for _, ieditem := range outiedlist {
							outiedname := ieditem["ref_ied_name"].(string)
							if outiedname == toIedname && ieditem["ref_type"].(string) == "0" {
								hasToIedRef = true
								break
							}
						}
					}
					if !hasToIedRef {
						parse_result := fmt.Sprintf("间隔%s的装置%s缺失与装置%s的%s信号关联", area_name, findIedName, toIedname, reftype)
						r := map[string]interface{}{"scdid": c.ScdId, "lineno": 0, "ruleid": area_ruleid, "nodeid": 0, "parse_result": parse_result}
						//检查未通过
						scdNodeRule.AppendFcdaCheckResult(r)
					}
				}
			}
			if !hasToIed {
				parse_result := fmt.Sprintf("间隔%s的装置%s缺失关联装置%s", area_name, findIedName, toIedname)
				r := map[string]interface{}{"scdid": c.ScdId, "lineno": 0, "ruleid": area_ruleid, "nodeid": 0, "parse_result": parse_result}
				//检查未通过
				scdNodeRule.AppendFcdaCheckResult(r)
			}
		}
	}

}

//线路间隔装置关系检查
func (c *CheckAreaMgr) cL(modelid string, scdXmlObj *node_attr.SCL, scdNodeMgr *ScdNode, scdNodeRule *ScdNodeRule, area_name string, ied_refs []orm.Params, area_ieds []orm.Params, area_ruleid string) {
	modelidInt, _ := strconv.Atoi(modelid)
	//获取装置分组信息
	bgm := new(SysCheckModelIedtypeGroupMgr)
	bgm.Model = T_data_model_iedtype_group{ModelId: modelidInt}
	groupList := bgm.List()
	plIed := c.getIedTypeCode(modelidInt, "PL")
	if v, h := groupList[plIed]; h {
		//装置如果是分组成员装置
		plIed = v
	}
	masterIed := new(node_attr.NIED)
	findIedName := ""
	for _, row2 := range area_ieds {
		findIedName = tools.IsEmpty(row2["ied_name"])
		if strings.HasPrefix(findIedName, plIed) {
			masterIed = scdNodeMgr.GetIed(scdXmlObj, "", findIedName)
			break
		}
	}
	if masterIed == nil {
		return
	}
	logger.Logger.Debug(fmt.Sprintf("开始分析模型%d的线路间隔关系", modelidInt))
	dealFromIed := map[string]int{}
	for _, row := range ied_refs {
		fromiedtype := c.getIedTypeCode(modelidInt, tools.IsEmpty(row["from_ied_code"]))
		toiedtype := c.getIedTypeCode(modelidInt, tools.IsEmpty(row["to_ied_code"]))
		reftype := tools.IsEmpty(row["in_type"])
		tmpFromAreaIeds := []orm.Params{}
		tmpToAreaIeds := []orm.Params{}
		for _, row2 := range area_ieds {
			findIedName = tools.IsEmpty(row2["ied_name"])
			if strings.HasPrefix(findIedName, fromiedtype) {
				masterIed = scdNodeMgr.GetIed(scdXmlObj, "", findIedName)
				if masterIed != nil {
					tmpFromAreaIeds = append(tmpFromAreaIeds, row2)
				} else {
					if dealFromIed[findIedName] == 0 {
						parse_result := fmt.Sprintf("间隔%s的装置%s缺失", area_name, findIedName)
						r := map[string]interface{}{"scdid": c.ScdId, "lineno": 0, "ruleid": area_ruleid, "nodeid": 0, "parse_result": parse_result,
							"ied_name":      findIedName,
							"ied_desc":      "",
							"out_ied_name":  "",
							"out_ied_desc":  "",
							"fcda_desc":     "",
							"fcda_addr":     "",
							"out_fcda_desc": "",
							"out_fcda_addr": "",
							"error_type":    "9",
						}
						//检查未通过
						scdNodeRule.AppendFcdaCheckResult(r)
					}
					dealFromIed[findIedName] = 1
				}
			}
			if strings.HasPrefix(findIedName, toiedtype) {
				tmpToAreaIeds = append(tmpToAreaIeds, row2)
			}
		}
		if len(tmpFromAreaIeds) == 0 {
			continue
		}
		if len(tmpToAreaIeds) == 0 {
			parse_result := fmt.Sprintf("间隔%s缺失类型为%s的装置", area_name, toiedtype)
			r := map[string]interface{}{"scdid": c.ScdId, "lineno": 0, "ruleid": area_ruleid, "nodeid": 0, "parse_result": parse_result}
			//检查未通过
			scdNodeRule.AppendFcdaCheckResult(r)
			continue
		}
		toIedname := ""
		for _, row2 := range tmpFromAreaIeds {
			findIedName = tools.IsEmpty(row2["ied_name"])
			hasToIedRef := false
			hasToIed := false
			for _, row3 := range tmpToAreaIeds {
				toIedname = tools.IsEmpty(row3["ied_name"])
				masterIed = scdNodeMgr.GetIed(scdXmlObj, "", toIedname)
				if masterIed != nil {
					hasToIed = true
					// 获取该ied的输出(ref_type为0)装置，并从中检测是否存在toiedtype类型的装置
					inout, _ := scdNodeMgr.GetIedRelations(map[string]interface{}{"scd_id": c.ScdId, "ied_name": findIedName})
					//logger.Logger.Debug(fmt.Sprintf("ied:%s refs:%+v", findIedName, inout))
					if inout != nil {
						outiedlist := inout[findIedName].(orm.Params)["list"].([]orm.Params)
						for _, ieditem := range outiedlist {
							outiedname := ieditem["ref_ied_name"].(string)
							if outiedname == toIedname && ieditem["ref_type"].(string) == "0" {
								hasToIedRef = true
								break
							}
						}
					}
					if !hasToIedRef {
						parse_result := fmt.Sprintf("间隔%s的装置%s缺失与装置%s的%s信号关联", area_name, findIedName, toIedname, reftype)
						r := map[string]interface{}{"scdid": c.ScdId, "lineno": 0, "ruleid": area_ruleid, "nodeid": 0, "parse_result": parse_result,
							"ied_name":      findIedName,
							"ied_desc":      "",
							"out_ied_name":  toIedname,
							"out_ied_desc":  "",
							"fcda_desc":     "",
							"fcda_addr":     "",
							"out_fcda_desc": "",
							"out_fcda_addr": "",
							"error_type":    "9",
						}
						//检查未通过
						scdNodeRule.AppendFcdaCheckResult(r)
					}
				}
			}
			if !hasToIed {
				parse_result := fmt.Sprintf("间隔%s的装置%s缺失关联装置%s", area_name, findIedName, toIedname)
				r := map[string]interface{}{"scdid": c.ScdId, "lineno": 0, "ruleid": area_ruleid, "nodeid": 0, "parse_result": parse_result,
					"ied_name":      findIedName,
					"ied_desc":      "",
					"out_ied_name":  toIedname,
					"out_ied_desc":  "",
					"fcda_desc":     "",
					"fcda_addr":     "",
					"out_fcda_desc": "",
					"out_fcda_addr": "",
					"error_type":    "9",
				}
				//检查未通过
				scdNodeRule.AppendFcdaCheckResult(r)
			}
		}
	}

}

//变压器间隔装置关系检查
func (c *CheckAreaMgr) cT(modelid string, scdXmlObj *node_attr.SCL, scdNodeMgr *ScdNode, scdNodeRule *ScdNodeRule, area_name string, ied_refs []orm.Params, area_ieds []orm.Params, area_ruleid string, HasAreaJ bool) {
	masterIed := new(node_attr.NIED)
	findIedName := ""
	modelidInt, _ := strconv.Atoi(modelid)
	ptIed := c.getIedTypeCode(modelidInt, "PT")
	for _, row2 := range area_ieds {
		findIedName = tools.IsEmpty(row2["ied_name"])
		if strings.HasPrefix(findIedName, ptIed) {
			masterIed = scdNodeMgr.GetIed(scdXmlObj, "", findIedName)
			break
		}
	}
	if masterIed == nil {
		return
	}
	scdParseMgr := new(ScdParse)
	dealFromIed := map[string]int{}
	for _, row := range ied_refs {
		fromiedtype := c.getIedTypeCode(modelidInt, tools.IsEmpty(row["from_ied_code"]))
		fromiedtype = strings.Split(fromiedtype, "#")[0]                                                    //去除后面的电压级别标识
		toiedtype := strings.Split(c.getIedTypeCode(modelidInt, tools.IsEmpty(row["to_ied_code"])), "#")[0] //去除后面的电压级别标识
		reftype := tools.IsEmpty(row["in_type"])
		tmpFromAreaIeds := []orm.Params{}
		tmpToAreaIeds := []orm.Params{}
		for _, row2 := range area_ieds {
			findIedName = tools.IsEmpty(row2["ied_name"])
			if strings.HasPrefix(findIedName, fromiedtype) {
				masterIed = scdNodeMgr.GetIed(scdXmlObj, "", findIedName)
				if masterIed != nil {
					tmpFromAreaIeds = append(tmpFromAreaIeds, row2)
				} else {
					if dealFromIed[findIedName] == 0 {
						parse_result := fmt.Sprintf("间隔%s的装置%s缺失", area_name, findIedName)
						r := map[string]interface{}{"scdid": c.ScdId, "lineno": 0, "ruleid": area_ruleid, "nodeid": 0, "parse_result": parse_result,
							"ied_name":      findIedName,
							"ied_desc":      "",
							"out_ied_name":  "",
							"out_ied_desc":  "",
							"fcda_desc":     "",
							"fcda_addr":     "",
							"out_fcda_desc": "",
							"out_fcda_addr": "",
							"error_type":    "9",
						}
						//检查未通过
						scdNodeRule.AppendFcdaCheckResult(r)
					}
					dealFromIed[findIedName] = 1
				}
			}
			if strings.HasPrefix(findIedName, toiedtype) {
				tmpToAreaIeds = append(tmpToAreaIeds, row2)
			}
		}
		if len(tmpFromAreaIeds) == 0 {
			continue
		}
		if len(tmpToAreaIeds) == 0 {
			logger.Logger.Debug(fmt.Sprintf("缺失类型关联装置 :%+v", row))
			parse_result := fmt.Sprintf("间隔%s缺失类型为%s的%s信号装置", area_name, toiedtype, reftype)
			r := map[string]interface{}{"scdid": c.ScdId, "lineno": 0, "ruleid": area_ruleid, "nodeid": 0, "parse_result": parse_result,
				"ied_name":      findIedName,
				"ied_desc":      "",
				"out_ied_name":  "",
				"out_ied_desc":  "",
				"fcda_desc":     "",
				"fcda_addr":     "",
				"out_fcda_desc": "",
				"out_fcda_addr": "",
				"error_type":    "9",
			}
			//检查未通过
			scdNodeRule.AppendFcdaCheckResult(r)
			continue
		}
		toIedname := ""
		for _, row2 := range tmpFromAreaIeds {
			findIedName = tools.IsEmpty(row2["ied_name"])
			hasToIedRef := false
			hasToIed := false
			t1 := fromiedtype + "->" + toiedtype
			volLevel := "" //电压等级
			if t1 == "CT->IT" || t1 == "IT->CT" || t1 == "CT->IB" || t1 == "IB->CT" || t1 == "MM->MT" || t1 == "PM->IB" || t1 == "IB->PM" || t1 == "PM->IT" || t1 == "IT->PM" {
				ps := scdParseMgr.ParseIedName(findIedName)
				volLevel = ps[3] + ps[4]
			}
			hasSameVolIed := false
			for _, row3 := range tmpToAreaIeds {
				toIedname = tools.IsEmpty(row3["ied_name"])
				if volLevel != "" {
					ps := scdParseMgr.ParseIedName(toIedname)
					if volLevel != ps[3]+ps[4] {
						//排除不是同一电压等级的装置
						continue
					}
					hasSameVolIed = true
				}
				if scdNodeMgr.GetIed(scdXmlObj, "", toIedname) != nil {
					hasToIed = true
					// 获取该ied的输出(ref_type为0)装置，并从中检测是否存在toiedtype类型的装置
					inout, _ := scdNodeMgr.GetIedRelations(map[string]interface{}{"scd_id": c.ScdId, "ied_name": findIedName})
					//logger.Logger.Debug(fmt.Sprintf("ied:%s refs:%+v", findIedName, inout))
					if inout != nil {
						outiedlist := inout[findIedName].(orm.Params)["list"].([]orm.Params)
						for _, ieditem := range outiedlist {
							outiedname := ieditem["ref_ied_name"].(string)
							if outiedname == toIedname && ieditem["ref_type"].(string) == "0" {
								hasToIedRef = true
								break
							}
						}
					}
					if !hasToIedRef {
						parse_result := fmt.Sprintf("间隔%s的装置%s缺失与装置%s的%s信号关联", area_name, findIedName, toIedname, reftype)
						r := map[string]interface{}{"scdid": c.ScdId, "lineno": 0, "ruleid": area_ruleid, "nodeid": 0, "parse_result": parse_result,
							"ied_name":      findIedName,
							"ied_desc":      "",
							"out_ied_name":  toIedname,
							"out_ied_desc":  "",
							"fcda_desc":     "",
							"fcda_addr":     "",
							"out_fcda_desc": "",
							"out_fcda_addr": "",
							"error_type":    "9",
						}
						//检查未通过
						scdNodeRule.AppendFcdaCheckResult(r)
					}
				}
				if hasSameVolIed {
					break
				}
			}
			if toiedtype != ptIed {
				if volLevel != "" && !hasSameVolIed {
					parse_result := fmt.Sprintf("间隔%s的装置%s缺失同电压等级的关联类型%s装置", area_name, findIedName, toiedtype)
					r := map[string]interface{}{"scdid": c.ScdId, "lineno": 0, "ruleid": area_ruleid, "nodeid": 0, "parse_result": parse_result,
						"ied_name":      findIedName,
						"ied_desc":      "",
						"out_ied_name":  "",
						"out_ied_desc":  "",
						"fcda_desc":     "",
						"fcda_addr":     "",
						"out_fcda_desc": "",
						"out_fcda_addr": "",
						"error_type":    "9",
					}
					//检查未通过
					scdNodeRule.AppendFcdaCheckResult(r)
				} else if !hasToIed {
					parse_result := fmt.Sprintf("间隔%s的装置%s缺失关联装置%s", area_name, findIedName, toIedname)
					r := map[string]interface{}{"scdid": c.ScdId, "lineno": 0, "ruleid": area_ruleid, "nodeid": 0, "parse_result": parse_result,
						"ied_name":      findIedName,
						"ied_desc":      "",
						"out_ied_name":  toIedname,
						"out_ied_desc":  "",
						"fcda_desc":     "",
						"fcda_addr":     "",
						"out_fcda_desc": "",
						"out_fcda_addr": "",
						"error_type":    "9",
					}
					//检查未通过
					scdNodeRule.AppendFcdaCheckResult(r)
				}
			}
		}

	}

}

//根据参考ied name找出应该关联PM装置
//abcode:套别标识代码。可选。不指定时将自动从iedtype识别
func (c *CheckAreaMgr) getPMName(iednameParts []string, ieds map[string]orm.Params, abcode ...string) string {
	//如果只有一个PM装置，则直接返回该 装置
	pmLst := []string{}
	for n, _ := range ieds {
		if strings.HasPrefix(n, "PM"+iednameParts[3]+iednameParts[4]) {
			pmLst = append(pmLst, n)
		}
	}
	if len(pmLst) == 1 {
		return pmLst[0]
	}
	ab := ""
	if len(abcode) > 0 {
		ab = abcode[0]
	}
	//暴力匹配
	for _, n := range pmLst {
		if ab != "" {
			//优先完全匹配指定套别
			if strings.HasSuffix(n, ab) {
				return n
			}
			continue
		}
		if strings.HasSuffix(n, iednameParts[7]) {
			return n
		}
	}
	return ""
}

//根据参考ied name找出应该关联MM装置
func (c *CheckAreaMgr) getMMName(iednameParts []string, ieds map[string]orm.Params, ab string) string {
	mmLst := []string{}
	for n, _ := range ieds {
		if strings.HasPrefix(n, "MM"+iednameParts[3]+iednameParts[4]) {
			mmLst = append(mmLst, n)
		}
	}
	if len(mmLst) == 1 {
		return mmLst[0]
	}
	for _, n := range mmLst {
		if strings.HasSuffix(n, ab) {
			return n
		}
	}
	return ""
}

//获取装置编码中的套别代码（A、B..）
func (c *CheckAreaMgr) getIedTypeABCode(iedtype string) string {
	if strings.Index(iedtype, "-") > 0 {
		return strings.Split(iedtype, "-")[1]
	}
	return iedtype
}

//根据当前设备列表，分析出电压等级（高、中、低）的设备列表
// CT测控、IT智能终端、MT合并单元需要判断是否是本体装置，是则将其归为主变高压侧
//iedtype:装置编码
//ieds:装置筛选范围列表
//vollevel:电压等级代码。H:高压 M:中压 L:低压
//abcode:套别标识代码。可选。不指定时将自动从iedtype识别
func (c *CheckAreaMgr) getIedListByVol(iedtype string, ieds map[string]orm.Params, vollevel map[string]string, abcode ...string) (hightLst, middleLst, lowLst []orm.Params) {
	tmpLst := map[string][]orm.Params{}
	for _, v := range vollevel {
		tmpLst[v] = []orm.Params{}
	}
	ab := ""
	if len(abcode) > 0 {
		ab = abcode[0]
	}
	if strings.Index(iedtype, "-") > 0 {
		//去除套别标识
		iedtype = strings.Split(iedtype, "-")[0]
		if ab == "" {
			ab = strings.Split(iedtype, "-")[1]
		}
	}
	it := strings.Split(iedtype, "#")
	scdParseMgr := new(ScdParse)
	for _, row := range ieds {
		pl_iedname := tools.IsEmpty(row["ied_name"])
		if pl_iedname[0:len(it[0])] != it[0] {
			continue
		}
		iednameParts := scdParseMgr.ParseIedName(pl_iedname)
		if ab != "" && iednameParts[7] != ab {
			//指定了套别时，装置套别必须与指定套别完全相同
			continue
		}
		volvalue := iednameParts[3] + iednameParts[4]
		if tmpLst[volvalue] == nil {
			tmpLst[volvalue] = []orm.Params{row}
		} else {
			tmpLst[volvalue] = append(tmpLst[volvalue], row)
		}
	}
	if len(it) > 1 {
		if it[1] == "H" {
			return tmpLst[vollevel["hight"]], []orm.Params{}, []orm.Params{}
		}
		if it[1] == "M" {
			return []orm.Params{}, tmpLst[vollevel["middle"]], []orm.Params{}
		}
		if it[1] == "L" {
			return []orm.Params{}, []orm.Params{}, tmpLst[vollevel["low"]]
		}
	}
	return tmpLst[vollevel["hight"]], tmpLst[vollevel["middle"]], tmpLst[vollevel["low"]]
}

func (c *CheckAreaMgr) GetCheckResult(scdid int64) ([]orm.Params, error) {
	db := orm.NewOrm()
	rowset := []orm.Params{}
	sql := "select *,case error_type when 1 then '多余' when 2 then '错误' when 3 then '缺失' else '其他' end error_type_desc from t_scd_fcda_check_result where scd_id=? order by ied_name,out_ied_name,error_type"
	_, err := db.Raw(sql, scdid).Values(&rowset)
	return rowset, err
}