check_sysmodel_ied_func_fcda.go 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330
  1. package bo
  2. import (
  3. "errors"
  4. "fmt"
  5. "scd_check_tools/logger"
  6. "scd_check_tools/models/enum"
  7. "scd_check_tools/tools"
  8. "strconv"
  9. "strings"
  10. "github.com/astaxie/beego/orm"
  11. )
  12. //系统内置模型-装置功能点端子管理
  13. type T_data_model_func_fcda struct {
  14. Id int `orm:"pk"`
  15. ModelId int // '模型ID' ,
  16. FuncId int // '功能ID',
  17. FcdaName string // 端子设计名称
  18. FcdaMatchExp string // 端子匹配表达式
  19. Svorgoose string
  20. Inorout string
  21. ReceiveIedType string
  22. Cr int // '创建人' ,
  23. Ct string `orm:"-"` // '创建时间' ,
  24. Ur int // '更新人' ,
  25. Ut string `orm:"-"` // '更新时间'
  26. }
  27. //内置检测模型-装置功能点端子管理
  28. type SysCheckModelIedFuncFcdaMgr struct {
  29. Model T_data_model_func_fcda
  30. DeviceBaseModel
  31. }
  32. var sysCheckModel_iedFuncFcdaDesc = "内置检测模型-装置功能点端子管理"
  33. func init() {
  34. orm.RegisterModel(new(T_data_model_func_fcda))
  35. }
  36. //保存检测模型装置功能信息
  37. func (c *SysCheckModelIedFuncFcdaMgr) Save() (id int, err error) {
  38. dblog := new(SystemLog)
  39. dblog.SetUserInfo(c.GetUserInfo())
  40. dblog.Audittype = enum.AuditType_check_model
  41. dblog.Logtype = enum.LogType_Insert
  42. dblog.Eventtype = enum.OptEventType_Bus
  43. dblog.Eventlevel = enum.OptEventLevel_Hight
  44. db := orm.NewOrm()
  45. hasName, _, err := c.Exist()
  46. if err != nil {
  47. return 0, err
  48. }
  49. if hasName {
  50. return 0, errors.New("端子名称[" + c.Model.FcdaName + "]已存在")
  51. }
  52. newid := int64(0)
  53. if c.Model.Id > 0 {
  54. //编辑
  55. _, err = db.Update(&c.Model)
  56. } else {
  57. //新增
  58. newid, err = db.Insert(&c.Model)
  59. c.Model.Id = int(newid)
  60. }
  61. if err != nil {
  62. logger.Logger.Error(err)
  63. dblog.Description = fmt.Sprintf("保存%s信息失败:%s,操作数据:%+v", sysCheckModel_iedFuncFcdaDesc, err.Error(), c.Model)
  64. dblog.Fail2()
  65. return 0, err
  66. } else {
  67. dblog.Description = fmt.Sprintf("保存%s信息成功,操作数据:%+v", sysCheckModel_iedFuncFcdaDesc, c.Model)
  68. dblog.Success2()
  69. }
  70. return c.Model.Id, nil
  71. }
  72. func (c *SysCheckModelIedFuncFcdaMgr) Exist() (bool, int, error) {
  73. db := orm.NewOrm()
  74. if c.Model.FcdaName == "" {
  75. return false, 0, errors.New("端子设计名称不能为空")
  76. }
  77. rowset := []orm.Params{}
  78. _, 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)
  79. if len(rowset) > 0 {
  80. findId := tools.IsEmpty(rowset[0]["id"])
  81. findIdint, _ := strconv.Atoi(findId)
  82. if tools.IsEmpty(c.Model.Id) != findId {
  83. //端子名称重复
  84. return true, c.Model.Id, nil
  85. } else {
  86. return false, findIdint, nil
  87. }
  88. }
  89. return false, 0, err
  90. }
  91. func (c *SysCheckModelIedFuncFcdaMgr) Copy(oldFuncId, newModelId, newFuncId int) error {
  92. db := orm.NewOrm()
  93. rowset := []orm.Params{}
  94. db.Raw("select * from t_data_model_func_fcda where model_id=? and func_id=?", c.Model.ModelId, oldFuncId).Values(&rowset)
  95. for _, row := range rowset {
  96. oldFcdaId, _ := strconv.Atoi(tools.IsEmpty(row["id"]))
  97. //复制端子数据
  98. newFcda := T_data_model_func_fcda{
  99. ModelId: newModelId,
  100. FuncId: newFuncId,
  101. FcdaName: tools.IsEmpty(row["fcda_name"]),
  102. FcdaMatchExp: tools.IsEmpty(row["fcda_match_exp"]),
  103. Svorgoose: tools.IsEmpty(row["svorgoose"]),
  104. Inorout: tools.IsEmpty(row["inorout"]),
  105. }
  106. newid, err := db.Insert(&newFcda)
  107. if err != nil {
  108. logger.Logger.Error(err)
  109. return err
  110. }
  111. 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()
  112. 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()
  113. }
  114. return nil
  115. }
  116. //自动建立端子关系
  117. func (c *SysCheckModelIedFuncFcdaMgr) AutoRelation(modelid int, relationrow []T_data_model_func_def) {
  118. if len(relationrow) == 0 {
  119. return
  120. }
  121. fcdaMap := map[string]T_data_model_func_def{}
  122. for _, row := range relationrow {
  123. key := fmt.Sprintf("%s%s", row.IedType, row.FcdaName)
  124. if row.FuncName == "额定延时" {
  125. if strings.Index(row.FcdaName, "额定") > -1 || strings.Index(row.FcdaName, "延迟") > -1 || strings.Index(row.FcdaName, "延时") > -1 {
  126. key = fmt.Sprintf("%s%s", row.IedType, "额定延时")
  127. }
  128. }
  129. fcdaMap[key] = row
  130. }
  131. //获取装置分组信息
  132. bgm := new(SysCheckModelIedtypeGroupMgr)
  133. bgm.Model = T_data_model_iedtype_group{ModelId: modelid}
  134. groupList := bgm.List()
  135. var getRealIedCode = func(ied_type string, groupList map[string]string) string {
  136. if groupList != nil && groupList[ied_type] != "" {
  137. ied_type = groupList[ied_type]
  138. }
  139. return ied_type
  140. }
  141. fr := new(SysCheckModelFcdaRalationMgr)
  142. fr.Model = T_data_model_fcda_ref{ModelId: modelid}
  143. noMatchList := map[string][]interface{}{} //未完全匹配的列表
  144. for i, row := range relationrow {
  145. if row.ReceiveIedType != "" {
  146. tmplst := strings.Split(row.ReceiveIedType, ",")
  147. for _, item := range tmplst {
  148. key := fmt.Sprintf("%s%s", item, row.FcdaName)
  149. if row.FuncName == "额定延时" {
  150. if strings.Index(row.FcdaName, "额定") > -1 || strings.Index(row.FcdaName, "延迟") > -1 || strings.Index(row.FcdaName, "延时") > -1 {
  151. key = fmt.Sprintf("%s%s", item, "额定延时")
  152. }
  153. }
  154. if r, h := fcdaMap[key]; h {
  155. fr.Model.FromFcdaId = row.FuncFcdaId
  156. fr.Model.ToFcdaId = r.FuncFcdaId
  157. fr.Model.FromFuncId = row.Id
  158. fr.Model.ToFuncId = r.Id
  159. fr.Model.FromIedCode = getRealIedCode(row.IedType, groupList)
  160. fr.Model.ToIedCode = getRealIedCode(r.IedType, groupList)
  161. fr.Model.Goosesv = row.Svorgoose
  162. fr.Save()
  163. } else {
  164. //未完全匹配到端子时,查找其接收端的对侧装置为当前装置的端子
  165. k := row.IedType + "," + item
  166. if _, h := noMatchList[k]; !h {
  167. tmp := map[string]interface{}{"no": i, "fromrow": row}
  168. noMatchList[k] = []interface{}{tmp}
  169. } else {
  170. noMatchList[k] = append(noMatchList[k], map[string]interface{}{"no": i, "fromrow": row})
  171. }
  172. }
  173. }
  174. }
  175. }
  176. //未完全匹配到端子时,查找其接收端的对侧装置为当前装置的端子
  177. for iedtype, obj := range noMatchList {
  178. ks := strings.Split(iedtype, ",")
  179. subNo := 0 //相差的行数
  180. fromrow := T_data_model_func_def{}
  181. for i, row := range relationrow {
  182. if row.IedType == ks[1] && strings.Index(row.ReceiveIedType, ks[0]) > -1 {
  183. tmp := obj[0].(map[string]interface{})
  184. no, _ := tmp["no"].(int)
  185. subNo = no - i //相差的行数
  186. break
  187. }
  188. }
  189. for _, item := range obj {
  190. item2 := item.(map[string]interface{})
  191. rowno := item2["no"].(int) - subNo
  192. if rowno < 0 || rowno > len(relationrow) {
  193. return
  194. }
  195. fromrow = item2["fromrow"].(T_data_model_func_def)
  196. r := relationrow[rowno]
  197. fr.Model.FromFcdaId = fromrow.FuncFcdaId
  198. fr.Model.ToFcdaId = r.FuncFcdaId
  199. fr.Model.FromFuncId = fromrow.Id
  200. fr.Model.ToFuncId = r.Id
  201. fr.Model.FromIedCode = getRealIedCode(fromrow.IedType, groupList)
  202. fr.Model.ToIedCode = getRealIedCode(r.IedType, groupList)
  203. fr.Model.Goosesv = fromrow.Svorgoose
  204. fr.Save()
  205. }
  206. }
  207. }
  208. //根据model中指定的id删除
  209. func (c *SysCheckModelIedFuncFcdaMgr) Delete() (err error) {
  210. dblog := new(SystemLog)
  211. dblog.SetUserInfo(c.GetUserInfo())
  212. dblog.Audittype = enum.AuditType_check_model
  213. dblog.Logtype = enum.LogType_Delete
  214. dblog.Eventtype = enum.OptEventType_Bus
  215. dblog.Eventlevel = enum.OptEventLevel_Hight
  216. db := orm.NewOrm()
  217. one := T_data_model_func_fcda{Id: c.Model.Id}
  218. if c.Model.Id > 0 {
  219. db.Read(&one)
  220. _, err = db.Raw("delete from t_data_model_func_fcda where id=?", c.Model.Id).Exec()
  221. } else if c.Model.FuncId > 0 {
  222. _, err = db.Raw("delete from t_data_model_func_fcda where model_id=? and func_id=?", c.Model.ModelId, c.Model.FuncId).Exec()
  223. } else {
  224. _, err = db.Raw("delete from t_data_model_func_fcda where model_id=? ", c.Model.ModelId).Exec()
  225. }
  226. if err != nil {
  227. logger.Logger.Error(err)
  228. dblog.Description = fmt.Sprintf("删除%s(%d)失败:%s", sysCheckModel_iedFuncFcdaDesc, c.Model.ModelId, err.Error())
  229. dblog.Fail2()
  230. } else {
  231. fcdaMgr := new(SysCheckModelFcdaRalationMgr)
  232. fcdaMgr.Model = T_data_model_fcda_ref{ModelId: c.Model.ModelId}
  233. if c.Model.Id > 0 {
  234. fcdaMgr.Model.FromFcdaId = c.Model.Id
  235. } else if c.Model.FuncId > 0 {
  236. fcdaMgr.Model.FromFuncId = c.Model.FuncId
  237. }
  238. fcdaMgr.Delete()
  239. dblog.Description = fmt.Sprintf("删除%s(%d)成功", sysCheckModel_iedFuncFcdaDesc, c.Model.ModelId)
  240. dblog.Success2()
  241. if c.Model.Id > 0 {
  242. //判断端子是否全部删除
  243. if one.FuncId > 0 {
  244. c.Model.ModelId = one.ModelId
  245. c.Model.FuncId = one.FuncId
  246. r, _ := c.GetList("")
  247. if len(r) == 0 {
  248. //删除功能定义数据
  249. funcMgr := new(SysCheckModelIedFuncMgr)
  250. funcMgr.Model.Id = one.FuncId
  251. funcMgr.Delete(true)
  252. }
  253. }
  254. } else if c.Model.FuncId > 0 {
  255. funcMgr := new(SysCheckModelIedFuncMgr)
  256. funcMgr.Model.Id = c.Model.FuncId
  257. funcMgr.Delete(true)
  258. } else {
  259. funcMgr := new(SysCheckModelIedFuncMgr)
  260. funcMgr.Model.ModelId = c.Model.ModelId
  261. funcMgr.Delete(true)
  262. }
  263. }
  264. return err
  265. }
  266. func (c *SysCheckModelIedFuncFcdaMgr) One(id int) (T_data_model_func_fcda, error) {
  267. tmp := T_data_model_func_fcda{Id: id}
  268. db := orm.NewOrm()
  269. err := db.Read(&tmp)
  270. return tmp, err
  271. }
  272. //获取指定模型及装置功能下的端子信息列表
  273. //funcids:指定的功能编码列表。可不传
  274. func (c *SysCheckModelIedFuncFcdaMgr) GetList(refIedtype string, funcids ...[]string) ([]orm.Params, error) {
  275. o := orm.NewOrm()
  276. sqlParamters := []interface{}{c.Model.ModelId}
  277. outsql := ""
  278. desc := ""
  279. if c.Model.Inorout == "接收" {
  280. outsql = ",(select from_fcda_id from t_data_model_fcda_ref where model_id=? and to_fcda_id=t.id and to_func_id=t1.id and from_ied_code=?) from_fcda_id"
  281. sqlParamters = append(sqlParamters, refIedtype, c.Model.ModelId)
  282. desc = " from_fcda_id," //已有关联关系的端子排在前面
  283. }
  284. if c.Model.Inorout == "输出" {
  285. outsql = ",(select to_fcda_id from t_data_model_fcda_ref where model_id=? and from_fcda_id=t.id and from_func_id=t1.id and to_ied_code=?) to_fcda_id"
  286. sqlParamters = append(sqlParamters, refIedtype, c.Model.ModelId)
  287. }
  288. 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=? "
  289. if c.Model.FuncId > 0 {
  290. sql = sql + " and t.func_id=?"
  291. sqlParamters = append(sqlParamters, c.Model.FuncId)
  292. }
  293. if len(funcids) > 0 {
  294. sql = sql + " and t.func_id in(" + strings.Join(funcids[0], ",") + ")"
  295. }
  296. if c.Model.Svorgoose != "" {
  297. sql = sql + " and t.svorgoose=?"
  298. sqlParamters = append(sqlParamters, c.Model.Svorgoose)
  299. }
  300. if c.Model.Inorout != "" {
  301. sql = sql + " and t.inorout like ?"
  302. sqlParamters = append(sqlParamters, "%"+c.Model.Inorout+"%")
  303. }
  304. sql = sql + " order by " + desc + " t.id"
  305. if c.Model.Inorout == "输出" {
  306. 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 (" +
  307. 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"
  308. } else if c.Model.Inorout == "接收" {
  309. 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 (" +
  310. 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"
  311. }
  312. rowset := []orm.Params{}
  313. _, err := o.Raw(sql, sqlParamters).Values(&rowset)
  314. if err != nil {
  315. logger.Logger.Error(err)
  316. }
  317. return rowset, err
  318. }