check_sys_model.go 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531
  1. package bo
  2. import (
  3. "encoding/json"
  4. "encoding/xml"
  5. "errors"
  6. "fmt"
  7. "scd_check_tools/arrayex"
  8. "scd_check_tools/logger"
  9. "scd_check_tools/models/enum"
  10. "scd_check_tools/tools"
  11. "strconv"
  12. "strings"
  13. "sync"
  14. "github.com/astaxie/beego/orm"
  15. )
  16. //系统内置模型
  17. type T_data_model_defualt struct {
  18. Id int `orm:"pk"`
  19. ModelName string // '模型名称' ,
  20. AreaType int // '所属间隔类型ID' ,
  21. VolId int // '所属电压等级ID' ,
  22. LineLinkStyle int // '接线方式' ,
  23. IedTypes string // '包含的装置类型' ,
  24. RelationJson string // '关系定义内容' ,
  25. IsSys int //是否内置模型。1 系统内置模型 2 任务检测模型
  26. FromModelId int //非系统内置模型时的参照模型ID。is_sys为2时有效
  27. Cr int // '创建人' ,
  28. Ct string `orm:"-"` // '创建时间' ,
  29. Ur int // '更新人' ,
  30. Ut string `orm:"-"` // '更新时间'
  31. }
  32. type ModelNodeStruct struct {
  33. XMLName xml.Name `xml:"flow"`
  34. Nodes []*INodeStruct `xml:"nodes"`
  35. Edges []*IEdges `xml:"edges"`
  36. }
  37. type INodeStruct struct {
  38. Id string `xml:"id"`
  39. Type string `xml:"type"`
  40. X string `xml:"x"`
  41. Y string `xml:"y"`
  42. Text *IText `xml:"text"`
  43. Properties *Iproperties `xml:"properties"`
  44. }
  45. type IText struct {
  46. X string `xml:"x"`
  47. Y string `xml:"y"`
  48. Value string `xml:"value"`
  49. }
  50. type Iproperties struct {
  51. IedType string `xml:"ied_type"`
  52. }
  53. type IEdges struct {
  54. Id string `xml:"id"`
  55. Type string `xml:"type"`
  56. SourceNodeId string `xml:"sourceNodeId"`
  57. TargetNodeId string `xml:"targetNodeId"`
  58. Properties *ILineProperties `xml:"properties"`
  59. }
  60. type ILineProperties struct {
  61. Issv string `xml:"issv"` // SV|GOOSE
  62. }
  63. //内置检测模型管理对象
  64. type SysCheckModelMgr struct {
  65. Model T_data_model_defualt
  66. DeviceBaseModel
  67. }
  68. var sysCheckModelDesc = "内置检测模型"
  69. var SysModelList = sync.Map{}
  70. func init() {
  71. orm.RegisterModel(new(T_data_model_defualt))
  72. }
  73. //判断名称是否已存在
  74. func (c *SysCheckModelMgr) ExistName(name string) (has bool, id int) {
  75. db := orm.NewOrm()
  76. rows := []orm.Params{}
  77. _, err := db.Raw("select id from t_data_model_defualt where model_name=?", name).Values(&rows)
  78. if err != nil {
  79. logger.Logger.Error(err)
  80. return true, 0
  81. }
  82. if len(rows) > 0 {
  83. id, _ = strconv.Atoi(tools.IsEmpty(rows[0]["id"]))
  84. return true, id
  85. }
  86. return false, 0
  87. }
  88. //保存检测模型信息
  89. func (c *SysCheckModelMgr) Save() (err error) {
  90. dblog := new(SystemLog)
  91. dblog.SetUserInfo(c.GetUserInfo())
  92. dblog.Audittype = enum.AuditType_check_model
  93. dblog.Logtype = enum.LogType_Insert
  94. dblog.Eventtype = enum.OptEventType_Bus
  95. dblog.Eventlevel = enum.OptEventLevel_Hight
  96. db := orm.NewOrm()
  97. if c.Model.Id == 0 {
  98. h, _ := c.ExistName(c.Model.ModelName)
  99. if h {
  100. return errors.New("模型名称已存在")
  101. }
  102. c.Model.Cr, _ = strconv.Atoi(c.GetUserId())
  103. //处理组合装置
  104. if c.Model.RelationJson != "" {
  105. modelJson := map[string]interface{}{}
  106. err = json.Unmarshal([]byte(c.Model.RelationJson), &modelJson)
  107. if err != nil {
  108. logger.Logger.Error(err)
  109. dblog.Description = fmt.Sprintf("保存%s信息失败:%s,操作数据:%+v", sysCheckModelDesc, err.Error(), c.Model)
  110. dblog.Fail2()
  111. return err
  112. }
  113. if modelJson["nodes"] != nil {
  114. nodes := modelJson["nodes"].([]interface{})
  115. iedtypes := []string{}
  116. for _, ritem := range nodes {
  117. ritem2 := ritem.(map[string]interface{})
  118. nodetype := tools.IsEmpty(ritem2["type"])
  119. if nodetype == "group" {
  120. properties := ritem2["properties"].(map[string]interface{})
  121. iedtypes = append(iedtypes, tools.IsEmpty(properties["ied_type"]))
  122. continue
  123. }
  124. properties := ritem2["properties"].(map[string]interface{})
  125. tmp := tools.IsEmpty(properties["ied_type"])
  126. if arrayex.IndexOf(iedtypes, tmp) > 0 {
  127. //装置类型重复了
  128. return errors.New("装置类型" + tmp + "不能重复引用")
  129. }
  130. iedtypes = append(iedtypes, tmp)
  131. }
  132. c.Model.IedTypes = strings.Join(iedtypes, ",")
  133. }
  134. }
  135. newid, err2 := db.Insert(&c.Model)
  136. if err2 == nil {
  137. //添加接线方式与模型关系
  138. lm := new(LinkStyleModelMgr)
  139. lm.Model.LinkstyleId = c.Model.LineLinkStyle
  140. lm.Model.ModelId = int(newid)
  141. lm.SetUserInfo(c.GetUserInfo())
  142. lm.Save()
  143. //保存装置分组
  144. bgm := new(SysCheckModelIedtypeGroupMgr)
  145. bgm.Model = T_data_model_iedtype_group{ModelId: int(newid)}
  146. bgm.Save(c.Model.RelationJson)
  147. if c.Model.RelationJson != "" {
  148. m2 := new(SysCheckModelIedRelationMgr)
  149. m2.SetUserInfo(c.GetUserInfo())
  150. m2.Model.ModelId = int(newid)
  151. //err = m2.Save(c.Model.RelationJson)
  152. }
  153. }
  154. if err2 != nil {
  155. err = err2
  156. }
  157. } else {
  158. tmpObj, err := c.One()
  159. if err != nil {
  160. return err
  161. }
  162. if c.Model.ModelName != "" {
  163. h, oldid := c.ExistName(c.Model.ModelName)
  164. if h && c.Model.Id != oldid {
  165. return errors.New("模型名称已存在")
  166. }
  167. } else {
  168. c.Model.ModelName = tmpObj.ModelName
  169. }
  170. if c.Model.AreaType == 0 {
  171. c.Model.AreaType = tmpObj.AreaType
  172. }
  173. if c.Model.IedTypes == "" {
  174. c.Model.IedTypes = tmpObj.IedTypes
  175. }
  176. if c.Model.LineLinkStyle == 0 {
  177. c.Model.LineLinkStyle = tmpObj.LineLinkStyle
  178. } else if c.Model.LineLinkStyle != tmpObj.LineLinkStyle {
  179. //更新接线方式与模型关系
  180. lm := new(LinkStyleModelMgr)
  181. lm.Model.LinkstyleId = tmpObj.LineLinkStyle
  182. lm.Model.ModelId = c.Model.Id
  183. lm.SetUserInfo(c.GetUserInfo())
  184. lm.Delete() //清除原来的关系
  185. lm.Model.LinkstyleId = c.Model.LineLinkStyle
  186. lm.Save()
  187. }
  188. if c.Model.VolId == 0 {
  189. c.Model.VolId = tmpObj.VolId
  190. }
  191. if c.Model.IsSys == 0 {
  192. c.Model.IsSys = tmpObj.IsSys
  193. }
  194. if c.Model.FromModelId == 0 {
  195. c.Model.FromModelId = tmpObj.FromModelId
  196. }
  197. if c.Model.RelationJson != "" {
  198. // 解析出模型需要的装置类型
  199. modelJson := map[string]interface{}{}
  200. err = json.Unmarshal([]byte(c.Model.RelationJson), &modelJson)
  201. /* <nodes>
  202. <id>5d787390-ebbb-4e97-93d2-87f6a63f7c44</id>
  203. <type>rect</type>
  204. <x>417</x>
  205. <y>202</y>
  206. <properties>
  207. <ied_type>PM</ied_type>
  208. </properties>
  209. <text>
  210. <x>417</x>
  211. <y>202</y>
  212. <value>母线保护</value>
  213. </text>
  214. </nodes>*/
  215. /*nodes := new(ModelNodeStruct)
  216. err = xml.Unmarshal([]byte(`<flow>`+c.Model.RelationJson+`</flow>`), &nodes)
  217. */
  218. if err != nil {
  219. logger.Logger.Error(err)
  220. dblog.Description = fmt.Sprintf("保存%s信息失败:%s,操作数据:%+v", sysCheckModelDesc, err.Error(), c.Model)
  221. dblog.Fail2()
  222. return err
  223. }
  224. if modelJson["nodes"] != nil {
  225. nodes := modelJson["nodes"].([]interface{})
  226. iedtypes := []string{}
  227. //groupIedTypes := map[string]int{}
  228. for _, ritem := range nodes {
  229. ritem2 := ritem.(map[string]interface{})
  230. nodetype := tools.IsEmpty(ritem2["type"])
  231. if nodetype == "group" {
  232. //装置分组
  233. properties := ritem2["properties"].(map[string]interface{})
  234. tmp := tools.IsEmpty(properties["ied_type"])
  235. iedtypes = append(iedtypes, tmp)
  236. continue
  237. }
  238. properties := ritem2["properties"].(map[string]interface{})
  239. tmp := tools.IsEmpty(properties["ied_type"])
  240. if arrayex.IndexOf(iedtypes, tmp) > 0 {
  241. //装置类型重复了
  242. return errors.New("装置类型" + tmp + "不能重复引用")
  243. }
  244. iedtypes = append(iedtypes, tmp)
  245. }
  246. c.Model.IedTypes = strings.Join(iedtypes, ",")
  247. }
  248. m2 := new(SysCheckModelIedRelationMgr)
  249. m2.SetUserInfo(c.GetUserInfo())
  250. m2.Model.ModelId = c.Model.Id
  251. err = m2.Save(modelJson) //先执行这
  252. } else {
  253. c.Model.RelationJson = tmpObj.RelationJson
  254. }
  255. if err == nil {
  256. c.Model.Cr = tmpObj.Cr
  257. c.Model.Ur, _ = strconv.Atoi(c.GetUserId())
  258. _, err = db.Update(&c.Model)
  259. if err != nil {
  260. //对比装置类型是否有变动.如果有减少则,需要同步删除减少装置类型的相关数据
  261. oldTypes := strings.Split(tmpObj.IedTypes, ",")
  262. newTypes := "," + c.Model.IedTypes + ","
  263. for _, item := range oldTypes {
  264. if strings.Index(newTypes, ","+item+",") == -1 {
  265. //当前装置类型item被删除:删除该装置类型原来的功能定义等
  266. m1 := new(SysCheckModelIedFuncMgr)
  267. m1.Model = T_data_model_func_def{ModelId: c.Model.Id, IedType: item}
  268. m1.Delete()
  269. bgm := new(SysCheckModelIedtypeGroupMgr)
  270. bgm.Model = T_data_model_iedtype_group{ModelId: c.Model.Id}
  271. bgm.Delete(item)
  272. }
  273. }
  274. }
  275. }
  276. }
  277. if err != nil {
  278. logger.Logger.Error(err)
  279. dblog.Description = fmt.Sprintf("保存%s信息失败:%s,操作数据:%+v", sysCheckModelDesc, err.Error(), c.Model)
  280. dblog.Fail2()
  281. } else {
  282. dblog.Description = fmt.Sprintf("保存%s信息成功,操作数据:%+v", sysCheckModelDesc, c.Model)
  283. dblog.Success2()
  284. }
  285. return err
  286. }
  287. func (c *SysCheckModelMgr) One() (T_data_model_defualt, error) {
  288. if c.Model.Id == 0 {
  289. return c.Model, errors.New("未指定id")
  290. }
  291. o := orm.NewOrm()
  292. tmpMod := T_data_model_defualt{Id: c.Model.Id}
  293. err := o.Read(&tmpMod)
  294. if err != nil {
  295. logger.Logger.Error(err)
  296. }
  297. return tmpMod, err
  298. }
  299. //更新指定模型中的指定装置类型编码
  300. func (c *SysCheckModelMgr) UpdateIedType(oldiedtype, newiedtype string) error {
  301. dblog := new(SystemLog)
  302. dblog.SetUserInfo(c.GetUserInfo())
  303. dblog.Audittype = enum.AuditType_check_model
  304. dblog.Logtype = enum.LogType_Delete
  305. dblog.Eventtype = enum.OptEventType_Bus
  306. dblog.Eventlevel = enum.OptEventLevel_Hight
  307. mapping := new(SysCheckModelIedtypeMappingMgr)
  308. mapping.Model = T_data_model_iedtype_maping{ModelId: c.Model.Id}
  309. mapping.Model.IedType = oldiedtype
  310. mapping.Model.MappingIedType = newiedtype
  311. err := mapping.Save()
  312. if err != nil {
  313. dblog.Description = fmt.Sprintf("设置%s%s装置类型编码(%s->%s)失败:%s", sysCheckModelDesc, c.Model.ModelName, oldiedtype, newiedtype, err.Error())
  314. dblog.Fail2()
  315. } else {
  316. dblog.Description = fmt.Sprintf("设置%s%s装置类型编码(%s->%s)成功", sysCheckModelDesc, c.Model.ModelName, oldiedtype, newiedtype)
  317. dblog.Success2()
  318. }
  319. return err
  320. }
  321. //获取指定装置类型的自定义类型编码
  322. func (c *SysCheckModelMgr) GetIedtypeMapping(iedtype string) string {
  323. mapping := new(SysCheckModelIedtypeMappingMgr)
  324. mapping.Model = T_data_model_iedtype_maping{ModelId: c.Model.Id}
  325. mapping.Model.IedType = iedtype
  326. re := mapping.List()
  327. if len(re) == 0 {
  328. return ""
  329. }
  330. return re[iedtype]
  331. }
  332. //根据model中指定的id删除
  333. func (c *SysCheckModelMgr) Delete() (err error) {
  334. dblog := new(SystemLog)
  335. dblog.SetUserInfo(c.GetUserInfo())
  336. dblog.Audittype = enum.AuditType_check_model
  337. dblog.Logtype = enum.LogType_Delete
  338. dblog.Eventtype = enum.OptEventType_Bus
  339. dblog.Eventlevel = enum.OptEventLevel_Hight
  340. db := orm.NewOrm()
  341. if c.Model.Id > 0 {
  342. db.Read(&c.Model)
  343. _, err = db.Delete(&c.Model)
  344. }
  345. if err != nil {
  346. logger.Logger.Error(err)
  347. dblog.Description = fmt.Sprintf("删除%s%s失败:%s", sysCheckModelDesc, c.Model.ModelName, err.Error())
  348. dblog.Fail2()
  349. } else {
  350. SysModelList.Delete(c.Model.Id)
  351. lsm := new(LinkStyleModelMgr)
  352. lsm.SetUserInfo(c.GetUserInfo())
  353. lsm.Model.ModelId = c.Model.Id
  354. lsm.Delete()
  355. m2 := new(SysCheckModelIedRelationMgr)
  356. m2.SetUserInfo(c.GetUserInfo())
  357. m2.Model.ModelId = c.Model.Id
  358. m2.Delete()
  359. m3 := new(SysCheckModelIedFuncMgr)
  360. m3.Model = T_data_model_func_def{ModelId: c.Model.Id}
  361. m3.Delete()
  362. bgm := new(SysCheckModelIedtypeGroupMgr)
  363. bgm.Model = T_data_model_iedtype_group{ModelId: c.Model.Id}
  364. bgm.Delete()
  365. obj1 := new(SysCheckModelIedtypeMappingMgr)
  366. obj1.Model = T_data_model_iedtype_maping{ModelId: c.Model.Id}
  367. obj1.Delete()
  368. dblog.Description = fmt.Sprintf("删除%s%s成功", sysCheckModelDesc, c.Model.ModelName)
  369. dblog.Success2()
  370. }
  371. return err
  372. }
  373. //复制模型
  374. func (c *SysCheckModelMgr) Copy(modelid int) (error, int) {
  375. dblog := new(SystemLog)
  376. dblog.SetUserInfo(c.GetUserInfo())
  377. dblog.Audittype = enum.AuditType_check_model
  378. dblog.Logtype = enum.LogType_Query
  379. dblog.Eventtype = enum.OptEventType_Bus
  380. dblog.Eventlevel = enum.OptEventLevel_Low
  381. o := orm.NewOrm()
  382. tmpM := T_data_model_defualt{Id: modelid}
  383. err := o.Read(&tmpM)
  384. if err != nil {
  385. logger.Logger.Error(err)
  386. return err, 0
  387. }
  388. if c.Model.ModelName != "" {
  389. tmpM.ModelName = c.Model.ModelName + tmpM.ModelName
  390. } else {
  391. tmpM.ModelName = "[检测模型]" + tmpM.ModelName
  392. }
  393. sql := "insert into t_data_model_defualt(model_name,area_type,vol_id,line_link_style,ied_types,relation_json,is_sys,from_model_id)values(?,?,?,?,?,?,?,?)"
  394. r, err := o.Raw(sql, []interface{}{tmpM.ModelName, tmpM.AreaType, tmpM.VolId, tmpM.LineLinkStyle, tmpM.IedTypes, tmpM.RelationJson, 2, modelid}).Exec()
  395. if err != nil {
  396. logger.Logger.Error(err)
  397. dblog.Description = fmt.Sprintf("复制%s%s失败:%s", sysCheckModelDesc, c.Model.ModelName, err.Error())
  398. dblog.Fail2()
  399. return err, 0
  400. } else {
  401. m2 := new(SysCheckModelIedRelationMgr)
  402. m2.SetUserInfo(c.GetUserInfo())
  403. m2.Model = T_data_model_relation_def{ModelId: modelid}
  404. newid, _ := r.LastInsertId()
  405. err, _ = m2.Copy(int(newid))
  406. if err != nil {
  407. c.Model.Id = int(newid)
  408. c.Delete()
  409. dblog.Description = fmt.Sprintf("复制%s%s失败:%s", sysCheckModelDesc, c.Model.ModelName, err.Error())
  410. dblog.Fail2()
  411. return err, 0
  412. }
  413. //复制装置类型分组数据
  414. bgm := new(SysCheckModelIedtypeGroupMgr)
  415. bgm.Model = T_data_model_iedtype_group{ModelId: modelid}
  416. bgm.Copy(int(newid))
  417. //复制装置类型自定义信息
  418. obj1 := new(SysCheckModelIedtypeMappingMgr)
  419. obj1.Model = T_data_model_iedtype_maping{ModelId: c.Model.Id}
  420. obj1.Copy(int(newid))
  421. //复制功能及端子信息
  422. m3 := new(SysCheckModelIedFuncMgr)
  423. m3.SetUserInfo(c.GetUserInfo())
  424. err = m3.Copy(tmpM.Id, int(newid))
  425. if err != nil {
  426. c.Model.Id = int(newid)
  427. c.Delete()
  428. m2.Model.ModelId = int(newid)
  429. m2.Delete()
  430. dblog.Description = fmt.Sprintf("复制%s%s失败:%s", sysCheckModelDesc, c.Model.ModelName, err.Error())
  431. dblog.Fail2()
  432. return err, 0
  433. }
  434. dblog.Description = fmt.Sprintf("复制%s%s成功", sysCheckModelDesc, c.Model.ModelName)
  435. dblog.Success2()
  436. return nil, int(newid)
  437. }
  438. }
  439. //获取指定电压等级下的所有模型
  440. func (c *SysCheckModelMgr) GetModelsByVolid(is_sys ...int) ([]orm.Params, error) {
  441. o := orm.NewOrm()
  442. s := 1
  443. if len(is_sys) > 0 {
  444. s = is_sys[0]
  445. }
  446. sqlParamters := []interface{}{s}
  447. sql := "select t.id, t.model_name,t.area_type,c.code area_type_code,c.name area_type_name ,t.ied_types,t.is_sys ,c1.`code` vol_code,c1.`name` vol_name from t_data_model_defualt t INNER JOIN global_const_code c on c.id=t.area_type and c.parentcode='area_type' INNER JOIN global_const_code c1 on t.vol_id=c1.id and c1.parentcode='voltage_level' where t.is_sys=? "
  448. rowset := []orm.Params{}
  449. _, err := o.Raw(sql, sqlParamters).Values(&rowset)
  450. if err != nil {
  451. logger.Logger.Error(err)
  452. }
  453. return rowset, err
  454. }
  455. //根据model中的指定过滤属性条件查询列表
  456. func (c *SysCheckModelMgr) List(pageno, pagesize int) ([]orm.Params, int, error) {
  457. dblog := new(SystemLog)
  458. dblog.SetUserInfo(c.GetUserInfo())
  459. dblog.Audittype = enum.AuditType_check_model
  460. dblog.Logtype = enum.LogType_Query
  461. dblog.Eventtype = enum.OptEventType_Bus
  462. dblog.Eventlevel = enum.OptEventLevel_Low
  463. o := orm.NewOrm()
  464. sqlParamters := []interface{}{}
  465. sql := "select t.*,t1.name area_type_name,s1.name line_link_style_name,v1.name voltage_level_name from t_data_model_defualt t left join global_const_code t1 on t.area_type=t1.id and t1.parentcode='area_type' left join global_const_code v1 on t.vol_id=v1.id and v1.parentcode='voltage_level' left join t_data_link_style s1 on t.line_link_style=s1.id where 1=1 "
  466. if c.Model.Id > 0 {
  467. sql += " and t.id=?"
  468. sqlParamters = append(sqlParamters, c.Model.Id)
  469. }
  470. if c.Model.VolId > 0 {
  471. sql += " and t.vol_id=?"
  472. sqlParamters = append(sqlParamters, c.Model.VolId)
  473. }
  474. if c.Model.LineLinkStyle > 0 {
  475. sql += " and t.line_link_style=?"
  476. sqlParamters = append(sqlParamters, c.Model.LineLinkStyle)
  477. }
  478. if c.Model.AreaType > 0 {
  479. sql += " and t.area_type=?"
  480. sqlParamters = append(sqlParamters, c.Model.AreaType)
  481. }
  482. if c.Model.ModelName != "" {
  483. sql += " and t.model_name like ?"
  484. sqlParamters = append(sqlParamters, "%"+c.Model.ModelName+"%")
  485. }
  486. if c.Model.IsSys > 0 {
  487. sql += " and t.is_sys = ?"
  488. sqlParamters = append(sqlParamters, c.Model.IsSys)
  489. }
  490. limit := fmt.Sprintf(" order by t.ct desc limit %d,%d", (pageno-1)*pagesize, pagesize)
  491. r := []orm.Params{}
  492. _, err := o.Raw(sql+limit, sqlParamters).Values(&r)
  493. dblog.Description = fmt.Sprintf("SQL:%s 参数:%+v", sql+limit, sqlParamters)
  494. if err != nil {
  495. logger.Logger.Error(err, dblog.Description)
  496. dblog.Fail2()
  497. return nil, 0, err
  498. }
  499. dblog.Success2()
  500. total := []orm.Params{}
  501. _, err = o.Raw(strings.Replace(sql, "t.*,t1.name area_type_name,s1.name line_link_style_name,v1.name voltage_level_name", "count(1) cnt", 1), sqlParamters).Values(&total)
  502. if err != nil {
  503. logger.Logger.Error(err)
  504. return nil, 0, err
  505. }
  506. totalCnt := 0
  507. if len(total) > 0 {
  508. totalCnt, _ = strconv.Atoi(tools.IsEmpty(total[0]["cnt"]))
  509. }
  510. return r, totalCnt, err
  511. }