check_sysmodel_ied_func.go 5.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172
  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. "sync"
  10. "github.com/astaxie/beego/orm"
  11. )
  12. //系统内置模型-装置功能管理
  13. type T_data_model_func_def struct {
  14. Id int `orm:"pk"`
  15. ModelId int // '模型ID' ,
  16. IedType string // '装置类型;关联代码:device_type',
  17. FuncName string // '功能名称',
  18. FuncFcdaId int `orm:"-"`
  19. FcdaName string `orm:"-"` // 端子设计名称
  20. FcdaMatchExp string `orm:"-"` // 端子匹配表达式
  21. Cr int // '创建人' ,
  22. Ct string `orm:"-"` // '创建时间' ,
  23. Ur int // '更新人' ,
  24. Ut string `orm:"-"` // '更新时间'
  25. }
  26. //内置检测模型-装置功能管理对象
  27. type SysCheckModelIedFuncMgr struct {
  28. Model T_data_model_func_def
  29. DeviceBaseModel
  30. }
  31. var sysCheckModel_iedFuncDesc = "内置检测模型-装置功能管理"
  32. var SysModelFuncList = sync.Map{}
  33. func init() {
  34. orm.RegisterModel(new(T_data_model_func_def))
  35. }
  36. //保存检测模型装置功能信息
  37. func (c *SysCheckModelIedFuncMgr) Save() (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 err
  48. }
  49. if hasName {
  50. return errors.New("功能名称已存在")
  51. }
  52. db.Begin()
  53. if c.Model.Id > 0 {
  54. //编辑
  55. _, err = db.Update(&c.Model)
  56. } else {
  57. //新增
  58. _, err = db.Insert(&c.Model)
  59. }
  60. if err != nil {
  61. logger.Logger.Error(err)
  62. dblog.Description = fmt.Sprintf("保存%s信息失败:%s,操作数据:%+v", sysCheckModel_iedFuncDesc, err.Error(), c.Model)
  63. dblog.Fail2()
  64. } else {
  65. //保存功能-端子定义
  66. fcdaMgr := new(SysCheckModelIedFuncFcdaMgr)
  67. fcdaMgr.Model = T_data_model_func_fcda{ModelId: c.Model.ModelId}
  68. fcdaMgr.Model.Id = c.Model.FuncFcdaId
  69. fcdaMgr.Model.FcdaMatchExp = c.Model.FcdaMatchExp
  70. fcdaMgr.Model.FcdaName = c.Model.FcdaName
  71. err = fcdaMgr.Save()
  72. if err != nil {
  73. db.Rollback()
  74. logger.Logger.Error(err)
  75. dblog.Description = fmt.Sprintf("保存%s信息失败:%s,操作数据:%+v", sysCheckModel_iedFuncDesc, err.Error(), c.Model)
  76. dblog.Fail2()
  77. return
  78. }
  79. db.Commit()
  80. dblog.Description = fmt.Sprintf("保存%s信息成功,操作数据:%+v", sysCheckModel_iedFuncDesc, c.Model)
  81. dblog.Success2()
  82. }
  83. return err
  84. }
  85. func (c *SysCheckModelIedFuncMgr) Exist() (bool, error) {
  86. db := orm.NewOrm()
  87. if c.Model.FuncName == "" {
  88. return false, errors.New("功能名称不能为空")
  89. }
  90. rowset := []orm.Params{}
  91. _, err := db.Raw("select id from t_data_model_func_def where model_id=? and ied_type=? and func_name=?", c.Model.ModelId, c.Model.IedType, c.Model.FuncName).Values(&rowset)
  92. if len(rowset) > 0 {
  93. if tools.IsEmpty(c.Model.Id) != tools.IsEmpty(rowset[0]["id"]) {
  94. return false, nil
  95. } else {
  96. return true, nil
  97. }
  98. }
  99. return false, err
  100. }
  101. //根据model中指定的id删除
  102. func (c *SysCheckModelIedFuncMgr) Delete() (err error) {
  103. dblog := new(SystemLog)
  104. dblog.SetUserInfo(c.GetUserInfo())
  105. dblog.Audittype = enum.AuditType_check_model
  106. dblog.Logtype = enum.LogType_Delete
  107. dblog.Eventtype = enum.OptEventType_Bus
  108. dblog.Eventlevel = enum.OptEventLevel_Hight
  109. db := orm.NewOrm()
  110. funcLst := []orm.Params{}
  111. if c.Model.Id > 0 {
  112. _, err = db.Raw("delete from t_data_model_func_def where id=?", c.Model.Id).Exec()
  113. } else if c.Model.IedType != "" {
  114. //删除指定装置类型的数据
  115. db.Raw("select id from t_data_model_func_def where model_id=? and ied_type=?", c.Model.ModelId, c.Model.IedType).Values(&funcLst)
  116. _, err = db.Raw("delete from t_data_model_func_def where model_id=? and ied_type=?", c.Model.ModelId, c.Model.IedType).Exec()
  117. } else {
  118. _, err = db.Raw("delete from t_data_model_func_def where model_id=?", c.Model.ModelId).Exec()
  119. }
  120. if err != nil {
  121. logger.Logger.Error(err)
  122. dblog.Description = fmt.Sprintf("删除%s(%d)失败:%s", sysCheckModel_iedFuncDesc, c.Model.ModelId, err.Error())
  123. dblog.Fail2()
  124. } else {
  125. fcdaMgr := new(SysCheckModelIedFuncFcdaMgr)
  126. fcdaMgr.Model = T_data_model_func_fcda{ModelId: c.Model.ModelId}
  127. if c.Model.Id > 0 {
  128. fcdaMgr.Model.FuncId = c.Model.Id
  129. }
  130. if c.Model.IedType != "" {
  131. //删除所有功能的相关数据
  132. for _, row := range funcLst {
  133. fcdaMgr.Model.FuncId, _ = strconv.Atoi(tools.IsEmpty(row["id"]))
  134. fcdaMgr.Delete()
  135. }
  136. } else {
  137. fcdaMgr.Delete()
  138. }
  139. SysModelRelationList.Delete(c.Model.ModelId)
  140. dblog.Description = fmt.Sprintf("删除%s(%d)成功", sysCheckModel_iedFuncDesc, c.Model.ModelId)
  141. dblog.Success2()
  142. }
  143. return err
  144. }
  145. func (c *SysCheckModelIedFuncMgr) GetListByModelid(modelid int) ([]orm.Params, error) {
  146. if v, h := SysModelFuncList.Load(modelid); h {
  147. return v.([]orm.Params), nil
  148. }
  149. o := orm.NewOrm()
  150. sqlParamters := []interface{}{modelid}
  151. sql := "select t.* from t_data_model_func_def t where t.model_id=?"
  152. rowset := []orm.Params{}
  153. _, err := o.Raw(sql, sqlParamters).Values(&rowset)
  154. if err != nil {
  155. logger.Logger.Error(err)
  156. } else {
  157. SysModelFuncList.Store(modelid, rowset)
  158. }
  159. return rowset, err
  160. }