task.go 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421
  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. } else {
  128. c.SetStep(tools.IsEmpty(task.ScdId), enum.TaskStep_SCD_model_parse.Code(), 2)
  129. }
  130. }
  131. }()
  132. return err
  133. }
  134. //取消/终止检测
  135. func (c *TaskMgr) stop(task T_data_task) error {
  136. TaskSCD.Delete(task.ScdId)
  137. db := orm.NewOrm()
  138. _, err := db.Raw("update t_data_task_check_step set state=3,ut=now() where task_id=? and state=0", task.Id).Exec()
  139. return err
  140. }
  141. //完成检测
  142. func (c *TaskMgr) finish(task T_data_task) error {
  143. TaskSCD.Delete(task.ScdId)
  144. db := orm.NewOrm()
  145. _, err := db.Raw("update t_data_task_check_step set state=2,ut=now() where task_id=? and state=0", task.Id).Exec()
  146. return err
  147. }
  148. //更新检测步骤状态
  149. func (c *TaskMgr) SetStep(scdid string, stepcode string, state int, msg ...string) {
  150. db := orm.NewOrm()
  151. scdidint64, _ := strconv.ParseInt(scdid, 10, 64)
  152. taskid, has := TaskSCD.Load(scdidint64)
  153. if !has {
  154. return
  155. }
  156. errormsg := ""
  157. if len(msg) > 0 {
  158. errormsg = msg[0]
  159. }
  160. t1 := "ct" //步骤开始时间字段
  161. if state > 1 {
  162. t1 = "ut" //步骤结束时间字段
  163. }
  164. 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()
  165. // 所有步骤都不为0和1了,则分析完成
  166. hasStep := []orm.Params{}
  167. _, err := db.Raw("select count(1) cnt from t_data_task_check_step where task_id=? and state in(0,1)", taskid).Values(&hasStep)
  168. if err != nil {
  169. logger.Logger.Error(err)
  170. return
  171. }
  172. if len(hasStep) == 0 {
  173. db.Raw("update t_data_task set state=2 where id=?", taskid).Exec()
  174. }
  175. }
  176. //保存任务信息
  177. func (c *TaskMgr) Save() (id int, err error) {
  178. dblog := new(SystemLog)
  179. dblog.SetUserInfo(c.GetUserInfo())
  180. dblog.Audittype = enum.AuditType_check_task
  181. dblog.Logtype = enum.LogType_Insert
  182. dblog.Eventtype = enum.OptEventType_Bus
  183. dblog.Eventlevel = enum.OptEventLevel_Hight
  184. db := orm.NewOrm()
  185. oldinfo := T_data_task{}
  186. oldid, _ := c.ExistName(c.Model.Name)
  187. if c.Model.Id == 0 {
  188. if oldid != "" {
  189. return 0, errors.New("任务名称(" + c.Model.Name + ")已存在")
  190. }
  191. c.Model.StartTime = "1970-01-01 00:00:00"
  192. c.Model.EndTime = "1970-01-01 00:00:00"
  193. c.Model.State = 0
  194. c.Model.Cr, _ = strconv.Atoi(c.GetUserId())
  195. id64 := int64(0)
  196. id64, err = db.Insert(&c.Model)
  197. id = int(id64)
  198. } else {
  199. if oldid != "" && oldid != tools.IsEmpty(c.Model.Id) {
  200. return 0, errors.New("任务名称(" + c.Model.Name + ")已存在")
  201. }
  202. id = c.Model.Id
  203. oldinfo, _ = c.One()
  204. if oldinfo.State == 1 {
  205. return 0, errors.New("任务正在检测中,不允许编辑")
  206. }
  207. if oldinfo.State == 2 {
  208. return 0, errors.New("任务已检测完成,不允许编辑")
  209. }
  210. c.Model.StartTime = oldinfo.StartTime
  211. c.Model.EndTime = oldinfo.EndTime
  212. c.Model.State = oldinfo.State
  213. c.Model.Ur, _ = strconv.Atoi(c.GetUserId())
  214. _, err = db.Update(&c.Model)
  215. }
  216. if err != nil {
  217. logger.Logger.Error(err)
  218. dblog.Description = fmt.Sprintf("保存%s信息失败:%s,操作数据:%+v", modelDesc, err.Error(), c.Model)
  219. dblog.Fail2()
  220. } else {
  221. dblog.Description = fmt.Sprintf("保存%s信息成功,操作数据:%+v", modelDesc, c.Model)
  222. dblog.Success2()
  223. if oldinfo.Id == 0 || oldinfo.ScdId != c.Model.ScdId {
  224. // 解析模型间隔及标准装置
  225. checkArea := new(CheckAreaMgr)
  226. checkArea.ScdId = c.Model.ScdId
  227. checkArea.Reset()
  228. }
  229. }
  230. return id, err
  231. }
  232. func (c *TaskMgr) One() (T_data_task, error) {
  233. if c.Model.Id == 0 {
  234. return c.Model, errors.New("未指定id")
  235. }
  236. o := orm.NewOrm()
  237. tmp := T_data_task{Id: c.Model.Id}
  238. err := o.Read(&tmp)
  239. if err != nil {
  240. logger.Logger.Error(err)
  241. }
  242. return tmp, err
  243. }
  244. func (c *TaskMgr) ExistName(name string) (string, error) {
  245. o := orm.NewOrm()
  246. rowset := []orm.Params{}
  247. _, err := o.Raw("select id from t_data_task where name=?", name).Values(&rowset)
  248. if err != nil {
  249. logger.Logger.Error(err)
  250. return "", err
  251. }
  252. if len(rowset) > 0 {
  253. return tools.IsEmpty(rowset[0]["id"]), nil
  254. }
  255. return "", nil
  256. }
  257. //根据model中指定的id删除检测任务
  258. func (c *TaskMgr) Delete() (err error) {
  259. dblog := new(SystemLog)
  260. u := c.GetUserInfo()
  261. dblog.SetUserInfo(u)
  262. dblog.Audittype = enum.AuditType_check_task
  263. dblog.Logtype = enum.LogType_Delete
  264. dblog.Eventtype = enum.OptEventType_Bus
  265. dblog.Eventlevel = enum.OptEventLevel_Hight
  266. db := orm.NewOrm()
  267. if c.Model.Id == 0 {
  268. return errors.New("无效的ID")
  269. } else {
  270. db.Read(&c.Model)
  271. if c.Model.State == 1 {
  272. return errors.New("任务正在检测中,不允许删除")
  273. }
  274. _, err = db.Delete(&c.Model)
  275. }
  276. if err != nil {
  277. logger.Logger.Error(err)
  278. dblog.Description = fmt.Sprintf("删除%s%s失败:%s", modelDesc, c.Model.Name, err.Error())
  279. dblog.Fail2()
  280. } else {
  281. TaskSCD.Delete(c.Model.ScdId)
  282. dblog.Description = fmt.Sprintf("删除%s%s成功", modelDesc, c.Model.Name)
  283. dblog.Success2()
  284. //同步删除关联数据
  285. db.Raw("delete from t_data_task_check_step where task_id=?", c.Model.Id).Exec()
  286. db.Raw("delete from t_data_check_area where scd_id=?", c.Model.ScdId).Exec()
  287. db.Raw("delete from t_data_check_area_ied where scd_id=?", c.Model.ScdId).Exec()
  288. scdmgr := new(ScdMgr)
  289. scdmgr.SetUserInfo(u)
  290. scdmgr.DeleteScd(strconv.FormatInt(c.Model.ScdId, 10), true)
  291. //删除关联模型
  292. m1 := new(TaskModelMgr)
  293. m1.SetUserInfo(u)
  294. m1.Model = T_data_task_model{TaskId: c.Model.Id}
  295. m1.Delete()
  296. //删除报告关联数据
  297. r1 := new(TaskReportMgr)
  298. r1.SetUserInfo(u)
  299. r1.Model = T_data_task_report{TaskId: c.Model.Id}
  300. r1.Delete()
  301. }
  302. return err
  303. }
  304. //根据model中的指定过滤属性条件查询任务列表
  305. func (c *TaskMgr) List(pageno, pagesize int) ([]orm.Params, int, error) {
  306. dblog := new(SystemLog)
  307. dblog.SetUserInfo(c.GetUserInfo())
  308. dblog.Audittype = enum.AuditType_check_task
  309. dblog.Logtype = enum.LogType_Query
  310. dblog.Eventtype = enum.OptEventType_Bus
  311. dblog.Eventlevel = enum.OptEventLevel_Low
  312. o := orm.NewOrm()
  313. sqlParamters := []interface{}{}
  314. 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 "
  315. if c.Model.Id > 0 {
  316. sql += " and t.id=?"
  317. sqlParamters = append(sqlParamters, c.Model.Id)
  318. }
  319. if c.Model.StationId > 0 {
  320. sql += " and t.station_id=?"
  321. sqlParamters = append(sqlParamters, c.Model.StationId)
  322. }
  323. if c.Model.Name != "" {
  324. sql += " and t.name like ?"
  325. sqlParamters = append(sqlParamters, "%"+c.Model.Name+"%")
  326. }
  327. if c.Model.ScdId > 0 {
  328. sql += " and t.scd_id=?"
  329. sqlParamters = append(sqlParamters, c.Model.ScdId)
  330. }
  331. if c.Model.State >= 0 {
  332. sql += " and t.state=?"
  333. sqlParamters = append(sqlParamters, c.Model.State)
  334. }
  335. if c.Model.StartTime != "" {
  336. sql += " and t.start_time>=?"
  337. sqlParamters = append(sqlParamters, c.Model.StartTime+" 00:00:00")
  338. }
  339. if c.Model.EndTime != "" {
  340. sql += " and t.end_time<=?"
  341. sqlParamters = append(sqlParamters, c.Model.EndTime+" 23:59:59")
  342. }
  343. limit := fmt.Sprintf(" order by t.ct desc limit %d,%d", (pageno-1)*pagesize, pagesize)
  344. r := []orm.Params{}
  345. _, err := o.Raw(sql+limit, sqlParamters).Values(&r)
  346. dblog.Description = fmt.Sprintf("SQL:%s 参数:%+v", sql+limit, sqlParamters)
  347. if err != nil {
  348. logger.Logger.Error(err, dblog.Description)
  349. dblog.Fail2()
  350. return nil, 0, err
  351. }
  352. dblog.Success2()
  353. total := []orm.Params{}
  354. _, 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)
  355. if err != nil {
  356. logger.Logger.Error(err)
  357. return nil, 0, err
  358. }
  359. totalCnt := 0
  360. if len(total) > 0 {
  361. totalCnt, _ = strconv.Atoi(tools.IsEmpty(total[0]["cnt"]))
  362. }
  363. return r, totalCnt, err
  364. }
  365. //获取指定任务的已选择模型
  366. func (c *TaskMgr) GetModels() ([]orm.Params, int, error) {
  367. if c.Model.Id == 0 {
  368. return nil, 0, errors.New("任务ID不能为空")
  369. }
  370. db := orm.NewOrm()
  371. rowset := []orm.Params{}
  372. _, 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)
  373. if err != nil {
  374. return rowset, 0, err
  375. }
  376. return rowset, len(rowset), nil
  377. }
  378. //根据SCD ID获取指定任务的已选择模型
  379. func (c *TaskMgr) GetModelsByScdID(scdid int64) ([]orm.Params, int, error) {
  380. if scdid == 0 {
  381. return nil, 0, errors.New("SCD ID不能为空")
  382. }
  383. db := orm.NewOrm()
  384. rowset := []orm.Params{}
  385. _, 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)
  386. if err != nil {
  387. return rowset, 0, err
  388. }
  389. return rowset, len(rowset), nil
  390. }
  391. func (c *TaskMgr) GetCheckStepInfo() ([]orm.Params, int, error) {
  392. db := orm.NewOrm()
  393. rowset := []orm.Params{}
  394. _, 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)
  395. if err != nil {
  396. return rowset, 0, err
  397. }
  398. return rowset, len(rowset), nil
  399. }