task.go 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442
  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. "sync"
  11. "github.com/astaxie/beego/orm"
  12. )
  13. //检测任务模型
  14. type T_data_task struct {
  15. Id int `orm:"pk"`
  16. Name string // '任务名称' ,
  17. Code string // '任务编号' ,
  18. StationId int // '所属变电站' ,
  19. ScdId int64 // 'SCD文件编号' ,
  20. ReportId int // '报告模板ID' ,
  21. Memo string // '任务说明' ,
  22. State int // '检测状态;0 未检查 1 检测中 2检测结束 3 异常中断' ,
  23. StartTime string // '开始检测时间' ,
  24. EndTime string // '检测结束时间' ,
  25. Cr int // '创建人' ,
  26. Ct string `orm:"-"` // '创建时间' ,
  27. Ur int // '更新人' ,
  28. Ut string `orm:"-"` // '更新时间'
  29. }
  30. //检测任务管理对象
  31. type TaskMgr struct {
  32. Model T_data_task
  33. DeviceBaseModel
  34. }
  35. var TaskSCD = sync.Map{}
  36. var modelDesc = "检测任务"
  37. func init() {
  38. orm.RegisterModel(new(T_data_task))
  39. }
  40. //重置检测异常中断的任务状态。一般在系统启动时处理
  41. func (c *TaskMgr) ChangeErr2Normal() {
  42. db := orm.NewOrm()
  43. db.Raw("update t_data_task set state=0 where state=1").Exec()
  44. }
  45. //设置指定任务的状态 flag:0 未检查 1 检测中 2检测结束 3 异常中断
  46. func (c *TaskMgr) SetActive(flag int) (err error) {
  47. dblog := new(SystemLog)
  48. dblog.SetUserInfo(c.GetUserInfo())
  49. dblog.Audittype = enum.AuditType_check_task
  50. dblog.Logtype = enum.LogType_Execute
  51. dblog.Eventtype = enum.OptEventType_Bus
  52. dblog.Eventlevel = enum.OptEventLevel_Hight
  53. db := orm.NewOrm()
  54. err = db.Read(&c.Model)
  55. if err != nil {
  56. logger.Logger.Error(err)
  57. return err
  58. }
  59. if flag == 0 {
  60. c.Model.StartTime = "1970-01-01 00:00:00"
  61. c.Model.EndTime = "1970-01-01 00:00:00"
  62. }
  63. if flag == 1 {
  64. if c.Model.State == 1 {
  65. return errors.New("当前任务正在检测中")
  66. }
  67. c.Model.StartTime = tools.NowTime()
  68. c.Model.EndTime = "1970-01-01 00:00:00"
  69. }
  70. if flag == 2 {
  71. c.Model.EndTime = tools.NowTime()
  72. }
  73. c.Model.State = flag
  74. _, err = db.Update(&c.Model)
  75. if err != nil {
  76. logger.Logger.Error(err)
  77. dblog.Description = fmt.Sprintf("更新%s%s状态失败:%s,操作数据:%+v", modelDesc, c.Model.Name, err.Error(), c.Model)
  78. dblog.Fail2()
  79. } else {
  80. dblog.Description = fmt.Sprintf("更新%s%s状态,操作数据:%+v", modelDesc, c.Model.Name, c.Model)
  81. dblog.Success2()
  82. if flag == 1 {
  83. return c.start(c.Model)
  84. }
  85. if flag == 2 {
  86. return c.finish(c.Model)
  87. }
  88. if flag == 3 {
  89. return c.stop(c.Model)
  90. }
  91. }
  92. return err
  93. }
  94. //开始检测
  95. func (c *TaskMgr) start(task T_data_task) error {
  96. scdParse := new(ScdParse)
  97. scdParse.SetUserInfo(c.GetUserInfo())
  98. scdMgr := new(ScdMgr)
  99. scdMgr.SetUserInfo(c.GetUserInfo())
  100. scdInfo, err := scdMgr.One(fmt.Sprintf("%d", task.ScdId))
  101. if err != nil {
  102. return err
  103. }
  104. c.Model.Id = task.Id
  105. _, cnt, _ := c.GetModels()
  106. if cnt == 0 {
  107. return errors.New("该检测任务还未配置检测模型")
  108. }
  109. TaskSCD.Store(task.ScdId, task)
  110. db := orm.NewOrm()
  111. //清除原步骤及状态
  112. db.Raw("delete from t_data_task_check_step where task_id=?", task.Id).Exec()
  113. db.Raw("delete from t_scd_node_rule_parse where scd_id=?", task.ScdId).Exec()
  114. //生成新的步骤
  115. db.Raw("insert into t_data_task_check_step(task_id,task_step_id,state) select ?,id,0 from global_const_code where parentcode='CHECK_STEP' order by id", task.Id).Exec()
  116. go func() {
  117. _, err = scdParse.XmlIEDParse(tools.IsEmpty(scdInfo["station_id"]), tools.IsEmpty(scdInfo["path"]), tools.IsEmpty(scdInfo["scd_name"]))
  118. if err == nil {
  119. scdParse.XmlCheckParse(task.ScdId)
  120. //模型分析
  121. c.SetStep(tools.IsEmpty(task.ScdId), enum.TaskStep_SCD_model_parse.Code(), 1)
  122. checkAreaMgr := new(CheckAreaMgr)
  123. checkAreaMgr.ScdId = task.ScdId
  124. err = checkAreaMgr.CheckAreaIedRelation()
  125. if err != nil {
  126. c.SetStep(tools.IsEmpty(task.ScdId), enum.TaskStep_SCD_model_parse.Code(), 3, err.Error())
  127. c.SetStep(tools.IsEmpty(task.ScdId), enum.TaskStep_SCD_func_parse.Code(), 3, "终止")
  128. c.SetStep(tools.IsEmpty(task.ScdId), enum.TaskStep_SCD_fcda_parse.Code(), 3, "终止")
  129. } else {
  130. c.SetStep(tools.IsEmpty(task.ScdId), enum.TaskStep_SCD_model_parse.Code(), 2)
  131. //功能分析
  132. err = checkAreaMgr.CheckAreaIedRelation()
  133. c.SetStep(tools.IsEmpty(task.ScdId), enum.TaskStep_SCD_func_parse.Code(), 1)
  134. if err != nil {
  135. c.SetStep(tools.IsEmpty(task.ScdId), enum.TaskStep_SCD_func_parse.Code(), 3, err.Error())
  136. c.SetStep(tools.IsEmpty(task.ScdId), enum.TaskStep_SCD_fcda_parse.Code(), 3, "终止")
  137. } else {
  138. c.SetStep(tools.IsEmpty(task.ScdId), enum.TaskStep_SCD_func_parse.Code(), 2)
  139. //端子分析
  140. c.SetStep(tools.IsEmpty(task.ScdId), enum.TaskStep_SCD_fcda_parse.Code(), 1)
  141. err = checkAreaMgr.CheckIedFcda()
  142. if err != nil {
  143. c.SetStep(tools.IsEmpty(task.ScdId), enum.TaskStep_SCD_fcda_parse.Code(), 3, err.Error())
  144. } else {
  145. c.SetStep(tools.IsEmpty(task.ScdId), enum.TaskStep_SCD_fcda_parse.Code(), 2)
  146. }
  147. }
  148. }
  149. }
  150. //检测结束
  151. c.SetActive(2)
  152. }()
  153. return err
  154. }
  155. //取消/终止检测
  156. func (c *TaskMgr) stop(task T_data_task) error {
  157. TaskSCD.Delete(task.ScdId)
  158. db := orm.NewOrm()
  159. _, err := db.Raw("update t_data_task_check_step set state=3,ut=now() where task_id=? and state=0", task.Id).Exec()
  160. return err
  161. }
  162. //完成检测
  163. func (c *TaskMgr) finish(task T_data_task) error {
  164. TaskSCD.Delete(task.ScdId)
  165. db := orm.NewOrm()
  166. _, err := db.Raw("update t_data_task_check_step set state=2,ut=now() where task_id=? and state=0", task.Id).Exec()
  167. return err
  168. }
  169. //更新检测步骤状态
  170. func (c *TaskMgr) SetStep(scdid string, stepcode string, state int, msg ...string) {
  171. db := orm.NewOrm()
  172. scdidint64, _ := strconv.ParseInt(scdid, 10, 64)
  173. taskid, has := TaskSCD.Load(scdidint64)
  174. if !has {
  175. return
  176. }
  177. errormsg := ""
  178. if len(msg) > 0 {
  179. errormsg = msg[0]
  180. }
  181. t1 := "ct" //步骤开始时间字段
  182. if state > 1 {
  183. t1 = "ut" //步骤结束时间字段
  184. }
  185. db.Raw("update t_data_task_check_step set state=?,state_msg=?,"+t1+"=now() where task_id=? and task_step_id=(select id from global_const_code where parentcode='CHECK_STEP' and code=?)", state, errormsg, taskid, stepcode).Exec()
  186. // 所有步骤都不为0和1了,则分析完成
  187. hasStep := []orm.Params{}
  188. _, err := db.Raw("select count(1) cnt from t_data_task_check_step where task_id=? and state in(0,1)", taskid).Values(&hasStep)
  189. if err != nil {
  190. logger.Logger.Error(err)
  191. return
  192. }
  193. if len(hasStep) == 0 {
  194. db.Raw("update t_data_task set state=2 where id=?", taskid).Exec()
  195. }
  196. }
  197. //保存任务信息
  198. func (c *TaskMgr) Save() (id int, err error) {
  199. dblog := new(SystemLog)
  200. dblog.SetUserInfo(c.GetUserInfo())
  201. dblog.Audittype = enum.AuditType_check_task
  202. dblog.Logtype = enum.LogType_Insert
  203. dblog.Eventtype = enum.OptEventType_Bus
  204. dblog.Eventlevel = enum.OptEventLevel_Hight
  205. db := orm.NewOrm()
  206. oldinfo := T_data_task{}
  207. oldid, _ := c.ExistName(c.Model.Name)
  208. if c.Model.Id == 0 {
  209. if oldid != "" {
  210. return 0, errors.New("任务名称(" + c.Model.Name + ")已存在")
  211. }
  212. c.Model.StartTime = "1970-01-01 00:00:00"
  213. c.Model.EndTime = "1970-01-01 00:00:00"
  214. c.Model.State = 0
  215. c.Model.Cr, _ = strconv.Atoi(c.GetUserId())
  216. id64 := int64(0)
  217. id64, err = db.Insert(&c.Model)
  218. id = int(id64)
  219. } else {
  220. if oldid != "" && oldid != tools.IsEmpty(c.Model.Id) {
  221. return 0, errors.New("任务名称(" + c.Model.Name + ")已存在")
  222. }
  223. id = c.Model.Id
  224. oldinfo, _ = c.One()
  225. if oldinfo.State == 1 {
  226. return 0, errors.New("任务正在检测中,不允许编辑")
  227. }
  228. if oldinfo.State == 2 {
  229. return 0, errors.New("任务已检测完成,不允许编辑")
  230. }
  231. c.Model.StartTime = oldinfo.StartTime
  232. c.Model.EndTime = oldinfo.EndTime
  233. c.Model.State = oldinfo.State
  234. c.Model.Ur, _ = strconv.Atoi(c.GetUserId())
  235. _, err = db.Update(&c.Model)
  236. }
  237. if err != nil {
  238. logger.Logger.Error(err)
  239. dblog.Description = fmt.Sprintf("保存%s信息失败:%s,操作数据:%+v", modelDesc, err.Error(), c.Model)
  240. dblog.Fail2()
  241. } else {
  242. dblog.Description = fmt.Sprintf("保存%s信息成功,操作数据:%+v", modelDesc, c.Model)
  243. dblog.Success2()
  244. if oldinfo.Id == 0 || oldinfo.ScdId != c.Model.ScdId {
  245. // 解析模型间隔及标准装置
  246. checkArea := new(CheckAreaMgr)
  247. checkArea.ScdId = c.Model.ScdId
  248. checkArea.Reset()
  249. }
  250. }
  251. return id, err
  252. }
  253. func (c *TaskMgr) One() (T_data_task, error) {
  254. if c.Model.Id == 0 {
  255. return c.Model, errors.New("未指定id")
  256. }
  257. o := orm.NewOrm()
  258. tmp := T_data_task{Id: c.Model.Id}
  259. err := o.Read(&tmp)
  260. if err != nil {
  261. logger.Logger.Error(err)
  262. }
  263. return tmp, err
  264. }
  265. func (c *TaskMgr) ExistName(name string) (string, error) {
  266. o := orm.NewOrm()
  267. rowset := []orm.Params{}
  268. _, err := o.Raw("select id from t_data_task where name=?", name).Values(&rowset)
  269. if err != nil {
  270. logger.Logger.Error(err)
  271. return "", err
  272. }
  273. if len(rowset) > 0 {
  274. return tools.IsEmpty(rowset[0]["id"]), nil
  275. }
  276. return "", nil
  277. }
  278. //根据model中指定的id删除检测任务
  279. func (c *TaskMgr) Delete() (err error) {
  280. dblog := new(SystemLog)
  281. u := c.GetUserInfo()
  282. dblog.SetUserInfo(u)
  283. dblog.Audittype = enum.AuditType_check_task
  284. dblog.Logtype = enum.LogType_Delete
  285. dblog.Eventtype = enum.OptEventType_Bus
  286. dblog.Eventlevel = enum.OptEventLevel_Hight
  287. db := orm.NewOrm()
  288. if c.Model.Id == 0 {
  289. return errors.New("无效的ID")
  290. } else {
  291. db.Read(&c.Model)
  292. if c.Model.State == 1 {
  293. return errors.New("任务正在检测中,不允许删除")
  294. }
  295. _, err = db.Delete(&c.Model)
  296. }
  297. if err != nil {
  298. logger.Logger.Error(err)
  299. dblog.Description = fmt.Sprintf("删除%s%s失败:%s", modelDesc, c.Model.Name, err.Error())
  300. dblog.Fail2()
  301. } else {
  302. TaskSCD.Delete(c.Model.ScdId)
  303. dblog.Description = fmt.Sprintf("删除%s%s成功", modelDesc, c.Model.Name)
  304. dblog.Success2()
  305. //同步删除关联数据
  306. db.Raw("delete from t_data_task_check_step where task_id=?", c.Model.Id).Exec()
  307. db.Raw("delete from t_data_check_area where scd_id=?", c.Model.ScdId).Exec()
  308. db.Raw("delete from t_data_check_area_ied where scd_id=?", c.Model.ScdId).Exec()
  309. scdmgr := new(ScdMgr)
  310. scdmgr.SetUserInfo(u)
  311. scdmgr.DeleteScd(strconv.FormatInt(c.Model.ScdId, 10), true)
  312. //删除关联模型
  313. m1 := new(TaskModelMgr)
  314. m1.SetUserInfo(u)
  315. m1.Model = T_data_task_model{TaskId: c.Model.Id}
  316. m1.Delete()
  317. //删除报告关联数据
  318. r1 := new(TaskReportMgr)
  319. r1.SetUserInfo(u)
  320. r1.Model = T_data_task_report{TaskId: c.Model.Id}
  321. r1.Delete()
  322. }
  323. return err
  324. }
  325. //根据model中的指定过滤属性条件查询任务列表
  326. func (c *TaskMgr) List(pageno, pagesize int) ([]orm.Params, int, error) {
  327. dblog := new(SystemLog)
  328. dblog.SetUserInfo(c.GetUserInfo())
  329. dblog.Audittype = enum.AuditType_check_task
  330. dblog.Logtype = enum.LogType_Query
  331. dblog.Eventtype = enum.OptEventType_Bus
  332. dblog.Eventlevel = enum.OptEventLevel_Low
  333. o := orm.NewOrm()
  334. sqlParamters := []interface{}{}
  335. sql := "select t.*,u.name username,s.scd_name,ts.area_name station_name,c1.id voltage_level,c1.name voltage_name from t_data_task t left join t_scd_scl s on t.scd_id=s.id left join t_data_user u on t.cr=u.id left join t_data_area ts on t.station_id=ts.ID left join global_const_code c1 on ts.AREA_LEVEL=c1.id and c1.parentcode='voltage_level' where 1=1 "
  336. if c.Model.Id > 0 {
  337. sql += " and t.id=?"
  338. sqlParamters = append(sqlParamters, c.Model.Id)
  339. }
  340. if c.Model.StationId > 0 {
  341. sql += " and t.station_id=?"
  342. sqlParamters = append(sqlParamters, c.Model.StationId)
  343. }
  344. if c.Model.Name != "" {
  345. sql += " and t.name like ?"
  346. sqlParamters = append(sqlParamters, "%"+c.Model.Name+"%")
  347. }
  348. if c.Model.ScdId > 0 {
  349. sql += " and t.scd_id=?"
  350. sqlParamters = append(sqlParamters, c.Model.ScdId)
  351. }
  352. if c.Model.State >= 0 {
  353. sql += " and t.state=?"
  354. sqlParamters = append(sqlParamters, c.Model.State)
  355. }
  356. if c.Model.StartTime != "" {
  357. sql += " and t.start_time>=?"
  358. sqlParamters = append(sqlParamters, c.Model.StartTime+" 00:00:00")
  359. }
  360. if c.Model.EndTime != "" {
  361. sql += " and t.end_time<=?"
  362. sqlParamters = append(sqlParamters, c.Model.EndTime+" 23:59:59")
  363. }
  364. limit := fmt.Sprintf(" order by t.ct desc limit %d,%d", (pageno-1)*pagesize, pagesize)
  365. r := []orm.Params{}
  366. _, err := o.Raw(sql+limit, sqlParamters).Values(&r)
  367. dblog.Description = fmt.Sprintf("SQL:%s 参数:%+v", sql+limit, sqlParamters)
  368. if err != nil {
  369. logger.Logger.Error(err, dblog.Description)
  370. dblog.Fail2()
  371. return nil, 0, err
  372. }
  373. dblog.Success2()
  374. total := []orm.Params{}
  375. _, err = o.Raw(strings.Replace(sql, "t.*,u.name username,s.scd_name,ts.area_name station_name", "count(1) cnt", 1), sqlParamters).Values(&total)
  376. if err != nil {
  377. logger.Logger.Error(err)
  378. return nil, 0, err
  379. }
  380. totalCnt := 0
  381. if len(total) > 0 {
  382. totalCnt, _ = strconv.Atoi(tools.IsEmpty(total[0]["cnt"]))
  383. }
  384. return r, totalCnt, err
  385. }
  386. //获取指定任务的已选择模型
  387. func (c *TaskMgr) GetModels() ([]orm.Params, int, error) {
  388. if c.Model.Id == 0 {
  389. return nil, 0, errors.New("任务ID不能为空")
  390. }
  391. db := orm.NewOrm()
  392. rowset := []orm.Params{}
  393. _, err := db.Raw("select t.*,t1.model_name,t1.vol_id,t1.line_link_style from t_data_task_model t,t_data_model_defualt t1 where t.model_id=t1.id and t.task_id=?", c.Model.Id).Values(&rowset)
  394. if err != nil {
  395. return rowset, 0, err
  396. }
  397. return rowset, len(rowset), nil
  398. }
  399. //根据SCD ID获取指定任务的已选择模型
  400. func (c *TaskMgr) GetModelsByScdID(scdid int64) ([]orm.Params, int, error) {
  401. if scdid == 0 {
  402. return nil, 0, errors.New("SCD ID不能为空")
  403. }
  404. db := orm.NewOrm()
  405. rowset := []orm.Params{}
  406. _, err := db.Raw("select t.*,t1.model_name,t1.vol_id,t1.line_link_style from t_data_task a, t_data_task_model t,t_data_model_defualt t1 where a.id=t.task_id and t.model_id=t1.id and a.scd_id=?", scdid).Values(&rowset)
  407. if err != nil {
  408. return rowset, 0, err
  409. }
  410. return rowset, len(rowset), nil
  411. }
  412. func (c *TaskMgr) GetCheckStepInfo() ([]orm.Params, int, error) {
  413. db := orm.NewOrm()
  414. rowset := []orm.Params{}
  415. _, err := db.Raw("select a.*,a1.name step_name,case a.state when 0 then '未开始' when 1 then '检测中' when 2 then '已完成' when 3 then '检测终止' else '检测异常' end state_name from t_data_task_check_step a left join global_const_code a1 on a.task_step_id=a1.id and a1.parentcode='CHECK_STEP' where a.task_id=? order by a1.id ", c.Model.Id).Values(&rowset)
  416. if err != nil {
  417. return rowset, 0, err
  418. }
  419. return rowset, len(rowset), nil
  420. }