classify.go 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742
  1. package services
  2. import (
  3. "errors"
  4. "eta_gn/eta_api/models"
  5. "eta_gn/eta_api/models/report_approve"
  6. "eta_gn/eta_api/utils"
  7. "fmt"
  8. "sort"
  9. "time"
  10. )
  11. // MoveReportClassify 移动分类
  12. func MoveReportClassify(req models.ClassifyMoveReq) (err error, errMsg string) {
  13. classifyId := req.ClassifyId
  14. prevClassifyId := req.PrevClassifyId
  15. nextClassifyId := req.NextClassifyId
  16. //如果有传入 上一个兄弟节点分类id
  17. var (
  18. classifyInfo *models.Classify
  19. prevClassify *models.Classify
  20. nextClassify *models.Classify
  21. prevSort int
  22. nextSort int
  23. )
  24. // 移动对象为分类, 判断权限
  25. classifyInfo, err = models.GetClassifyById(classifyId)
  26. if err != nil {
  27. if utils.IsErrNoRow(err) {
  28. errMsg = "分类不存在, 请刷新页面"
  29. err = fmt.Errorf("获取分类信息失败,Err:" + err.Error())
  30. return
  31. }
  32. errMsg = "移动失败"
  33. err = fmt.Errorf("获取分类信息失败,Err:" + err.Error())
  34. return
  35. } else if classifyInfo.Id == 0 {
  36. errMsg = "分类不存在, 请刷新页面"
  37. err = fmt.Errorf("获取分类信息失败,Err:" + err.Error())
  38. return
  39. }
  40. parentClassifyId := classifyInfo.ParentId
  41. if prevClassifyId > 0 {
  42. prevClassify, err = models.GetClassifyById(prevClassifyId)
  43. if err != nil {
  44. if utils.IsErrNoRow(err) {
  45. errMsg = "上一个分类不存在, 请刷新页面"
  46. err = fmt.Errorf("获取分类信息失败,Err:" + err.Error())
  47. return
  48. }
  49. errMsg = "移动失败"
  50. err = fmt.Errorf("获取上一个兄弟节点分类信息失败,Err:" + err.Error())
  51. return
  52. }
  53. if prevClassify.ParentId != parentClassifyId {
  54. errMsg = "禁止拖动到其他节点"
  55. err = fmt.Errorf(errMsg)
  56. return
  57. }
  58. prevSort = prevClassify.Sort
  59. }
  60. if nextClassifyId > 0 {
  61. //下一个兄弟节点
  62. nextClassify, err = models.GetClassifyById(nextClassifyId)
  63. if err != nil {
  64. if utils.IsErrNoRow(err) {
  65. errMsg = "下一个分类不存在, 请刷新页面"
  66. err = fmt.Errorf("获取分类信息失败,Err:" + err.Error())
  67. return
  68. }
  69. errMsg = "移动失败"
  70. err = fmt.Errorf("获取下一个兄弟节点分类信息失败,Err:" + err.Error())
  71. return
  72. }
  73. if nextClassify.ParentId != parentClassifyId {
  74. errMsg = "禁止拖动到其他节点"
  75. err = fmt.Errorf(errMsg)
  76. return
  77. }
  78. nextSort = nextClassify.Sort
  79. }
  80. err, errMsg = moveReportClassify(classifyInfo, prevClassify, nextClassify, parentClassifyId, prevSort, nextSort)
  81. return
  82. }
  83. // moveReportClassify 移动分类
  84. func moveReportClassify(classifyInfo, prevClassify, nextClassify *models.Classify, parentId, prevSort, nextSort int) (err error, errMsg string) {
  85. ob := new(models.Classify)
  86. updateCol := make([]string, 0)
  87. //判断上级id是否一致,如果不一致的话,那么需要移动该分类层级
  88. if classifyInfo.ParentId != parentId {
  89. errMsg = "移动失败"
  90. err = fmt.Errorf("不支持目录层级变更")
  91. return
  92. }
  93. if prevSort > 0 {
  94. //如果是移动在两个兄弟节点之间
  95. if nextSort > 0 {
  96. //下一个兄弟节点
  97. //如果上一个兄弟与下一个兄弟的排序权重是一致的,那么需要将下一个兄弟(以及下个兄弟的同样排序权重)的排序权重+2,自己变成上一个兄弟的排序权重+1
  98. if prevSort == nextSort || prevSort == classifyInfo.Sort {
  99. //变更兄弟节点的排序
  100. updateSortStr := `sort + 2`
  101. //变更分类
  102. if prevClassify != nil {
  103. _ = models.UpdateClassifySortByParentId(parentId, prevClassify.Id, prevClassify.Sort, updateSortStr)
  104. } else {
  105. _ = models.UpdateClassifySortByParentId(parentId, 0, prevSort, updateSortStr)
  106. }
  107. } else {
  108. //如果下一个兄弟的排序权重正好是上个兄弟节点的下一层,那么需要再加一层了
  109. if nextSort-prevSort == 1 {
  110. //变更兄弟节点的排序
  111. updateSortStr := `sort + 1`
  112. //变更分类
  113. if prevClassify != nil {
  114. _ = models.UpdateClassifySortByParentId(parentId, prevClassify.Id, prevSort, updateSortStr)
  115. } else {
  116. _ = models.UpdateClassifySortByParentId(parentId, 0, prevSort, updateSortStr)
  117. }
  118. }
  119. }
  120. }
  121. classifyInfo.Sort = prevSort + 1
  122. classifyInfo.ModifyTime = time.Now()
  123. updateCol = append(updateCol, "Sort", "ModifyTime")
  124. } else if prevClassify == nil && nextClassify == nil && parentId > 0 {
  125. //处理只拖动到目录里,默认放到目录底部的情况
  126. var maxSort int
  127. maxSort, err = ob.GetMaxSortByParentId(parentId)
  128. if err != nil {
  129. errMsg = "移动失败"
  130. err = fmt.Errorf("查询组内排序信息失败,Err:" + err.Error())
  131. return
  132. }
  133. classifyInfo.Sort = maxSort + 1 //那就是排在组内最后一位
  134. classifyInfo.ModifyTime = time.Now()
  135. updateCol = append(updateCol, "Sort", "ModifyTime")
  136. } else {
  137. // 拖动到父级分类的第一位
  138. firstPermission, tmpErr := ob.GetFirstClassifyByParentId(parentId)
  139. if tmpErr != nil && !utils.IsErrNoRow(tmpErr) {
  140. errMsg = "移动失败"
  141. err = fmt.Errorf("获取获取当前父级分类下的排序第一条的分类信息失败,Err:" + tmpErr.Error())
  142. return
  143. }
  144. //如果该分类下存在其他分类,且第一个其他分类的排序等于0,那么需要调整排序
  145. if firstPermission != nil && firstPermission.Id != 0 && firstPermission.Sort == 0 {
  146. updateSortStr := ` sort + 1 `
  147. _ = models.UpdateClassifySortByParentId(parentId, firstPermission.Id-1, 0, updateSortStr)
  148. }
  149. classifyInfo.Sort = 0 //那就是排在第一位
  150. classifyInfo.ModifyTime = time.Now()
  151. updateCol = append(updateCol, "Sort", "ModifyTime")
  152. }
  153. //更新
  154. if len(updateCol) > 0 {
  155. err = classifyInfo.UpdateClassify(updateCol)
  156. if err != nil {
  157. errMsg = "移动失败"
  158. err = fmt.Errorf("修改失败,Err:" + err.Error())
  159. return
  160. }
  161. }
  162. return
  163. }
  164. // AddReportClassify
  165. // @Description: 添加报告分类
  166. // @author: Roc
  167. // @datetime 2024-06-17 11:01:21
  168. // @param classifyName string
  169. // @param parentId int
  170. // @param chartPermissionIdList []int
  171. // @return err error
  172. // @return errMsg string
  173. // @return isSendEmail bool
  174. func AddReportClassify(classifyName string, parentId int, chartPermissionIdList []int) (err error, errMsg string, isSendEmail bool) {
  175. isSendEmail = true
  176. errMsg = `添加失败`
  177. item, err := models.GetClassifyByName(classifyName, parentId)
  178. if err != nil && !utils.IsErrNoRow(err) {
  179. errMsg = "获取分类信息失败"
  180. if utils.IsErrNoRow(err) {
  181. errMsg = "分类名称:" + classifyName + "已存在"
  182. isSendEmail = false
  183. }
  184. return
  185. }
  186. if item != nil && item.Id > 0 {
  187. errMsg = "分类名称:" + classifyName + "已存在"
  188. isSendEmail = false
  189. err = errors.New(errMsg)
  190. return
  191. }
  192. level := 1
  193. // 父级分类
  194. var parentClassifyItem *models.Classify
  195. // 父级分类下的子分类数量
  196. var childClassifyCount int
  197. if parentId > 0 {
  198. // 获取父级分类信息
  199. parentClassifyItem, err = models.GetClassifyById(parentId)
  200. if err != nil {
  201. errMsg = "获取父级分类信息失败"
  202. if utils.IsErrNoRow(err) {
  203. errMsg = "父级分类不存在"
  204. }
  205. return
  206. }
  207. level = parentClassifyItem.Level + 1
  208. if level > 3 {
  209. errMsg = "分类层级不可超过三级"
  210. isSendEmail = false
  211. return
  212. }
  213. // 判断是否分类存在待操作的审批单
  214. err, errMsg = checkClassifyApprove(parentClassifyItem)
  215. if err != nil {
  216. return
  217. }
  218. // 获取父级分类下的子分类数量
  219. childClassifyCount, err = models.GetCountClassifyChildByParentId(parentId)
  220. if err != nil {
  221. errMsg = "获取父级分类的子分类信息失败"
  222. return
  223. }
  224. }
  225. nowTime := time.Now().Local()
  226. classify := new(models.Classify)
  227. maxSort, err := classify.GetMaxSort()
  228. if err != nil {
  229. errMsg = "操作失败"
  230. err = errors.New("查询品种排序失败, Err: " + err.Error())
  231. return
  232. }
  233. classify.ClassifyName = classifyName
  234. classify.ParentId = parentId
  235. classify.CreateTime = nowTime
  236. classify.ModifyTime = nowTime
  237. classify.Sort = maxSort + 1
  238. classify.Enabled = 1
  239. classify.ShowType = 1 //默认列表格式
  240. classify.ReportDetailShowType = 1 //默认列表格式
  241. classify.IsShow = 1
  242. classify.Level = level
  243. err = models.AddClassify(classify)
  244. if err != nil {
  245. return
  246. }
  247. // 如果父级分类不为空的话,那么就标记有子级分类,同时
  248. if parentClassifyItem != nil {
  249. parentClassifyItem.HasChild = 1
  250. parentClassifyItem.UpdateClassify([]string{"HasChild"})
  251. // 如果以前没有子级分类,那么就继承父级分类下的章节类型(创建新的章节与分类的关系)
  252. if childClassifyCount <= 0 {
  253. // 继承父级分类下的章节类型(创建新的章节与分类的关系)
  254. tmpErr := inheritReportChapterType(parentId, classify.Id)
  255. if tmpErr != nil {
  256. return
  257. }
  258. // 继承父级分类审批流
  259. go inheritReportApproveFlow(parentClassifyItem, classify)
  260. moveReportByAddClassify(parentClassifyItem, classify)
  261. }
  262. }
  263. return
  264. }
  265. // checkClassifyApprove
  266. // @Description: 判断分类是否存在待操作的审批单
  267. // @author: Roc
  268. // @datetime 2024-06-27 13:19:15
  269. // @param currClassify *models.Classify
  270. // @return err error
  271. // @return errMsg string
  272. func checkClassifyApprove(currClassify *models.Classify) (err error, errMsg string) {
  273. errMsg = `判断是否有审批流关联失败`
  274. var firstClassifyId, secondClassifyId int
  275. if currClassify.ParentId > 0 {
  276. parentClassifyItem, tmpErr := models.GetClassifyById(currClassify.ParentId)
  277. if tmpErr != nil {
  278. err = tmpErr
  279. errMsg = "获取父级分类信息失败"
  280. if utils.IsErrNoRow(tmpErr) {
  281. errMsg = "父级分类不存在"
  282. }
  283. return
  284. }
  285. firstClassifyId = parentClassifyItem.Id
  286. secondClassifyId = currClassify.Id
  287. } else {
  288. firstClassifyId = currClassify.Id
  289. }
  290. // 校验审批流是否关联了进行中的审批
  291. {
  292. flowOb := new(report_approve.ReportApproveFlow)
  293. existCond := fmt.Sprintf(` AND %s = ? AND %s = ? AND %s = ? AND %s = ?`, report_approve.ReportApproveFlowCols.ReportType, report_approve.ReportApproveFlowCols.ClassifyFirstId, report_approve.ReportApproveFlowCols.ClassifySecondId, report_approve.ReportApproveFlowCols.ClassifyThirdId)
  294. existPars := make([]interface{}, 0)
  295. existPars = append(existPars, report_approve.FlowReportTypeChinese, firstClassifyId, secondClassifyId, 0)
  296. flowItem, e := flowOb.GetItemByCondition(existCond, existPars, "")
  297. if e != nil {
  298. // 父级分类如果没有审批流,那么就正常进行就好了
  299. if !utils.IsErrNoRow(e) {
  300. err = errors.New("获取审批流是否已存在失败, Err: " + e.Error())
  301. return
  302. }
  303. err = nil
  304. return
  305. }
  306. if flowItem == nil {
  307. return
  308. }
  309. approvingOb := new(report_approve.ReportApprove)
  310. approvingCond := fmt.Sprintf(` AND %s = ? AND %s = ? AND %s = ?`, report_approve.ReportApproveCols.FlowId, report_approve.ReportApproveCols.FlowVersion, report_approve.ReportApproveCols.State)
  311. approvingPars := make([]interface{}, 0)
  312. approvingPars = append(approvingPars, flowItem.ReportApproveFlowId, flowItem.CurrVersion, report_approve.ReportApproveStateApproving)
  313. count, e := approvingOb.GetCountByCondition(approvingCond, approvingPars)
  314. if e != nil {
  315. err = errors.New("获取审批流关联进行中的审批数失败. Err: " + e.Error())
  316. return
  317. }
  318. if count > 0 {
  319. errMsg = "当前有未走完流程的报告,请走完流程后再做变更"
  320. err = errors.New(errMsg)
  321. return
  322. }
  323. }
  324. return
  325. }
  326. // 关于研报分类,因只允许报告或品种关联在最小分类下,所以当某个父分类(非三级分类)已关联报告或品种,需要在该父分类下增加子分类,则第一个子分类添加成功时,默认把该父分类关联的品种和报告转移至新创建的子分类(第一个子分类)下
  327. // moveReportByAddClassify
  328. // @Description: 报告和章节的转移
  329. // @author: Roc
  330. // @datetime 2024-06-17 16:29:56
  331. // @param parentClassifyInfo *models.Classify
  332. // @param currClassifyInfo *models.Classify
  333. // @return err error
  334. func moveReportByAddClassify(parentClassifyInfo, currClassifyInfo *models.Classify) (err error) {
  335. defer func() {
  336. if err != nil {
  337. utils.FileLog.Error(fmt.Sprint("历史报告更改分类失败,父级分类ID:", parentClassifyInfo.Id, ";当前分类ID:", currClassifyInfo.Id, ";错误信息:", err.Error()))
  338. }
  339. }()
  340. if currClassifyInfo.Level > 3 {
  341. err = errors.New("父级分类不支持三级分类以上")
  342. return
  343. }
  344. // 报告的分类归属调整,转为下一级的分类
  345. var condition, updateStr string
  346. pars := make([]interface{}, 0)
  347. switch currClassifyInfo.Level {
  348. case 3: // 当前分类是3级分类
  349. updateStr += ` classify_id_third = ?,classify_name_third = ?`
  350. condition += ` AND classify_id_second = ? `
  351. case 2: // 当前分类是2级分类
  352. updateStr += ` classify_id_second = ?,classify_name_second = ?`
  353. condition += ` AND classify_id_first = ? `
  354. default:
  355. err = errors.New("错误的分类层级")
  356. return
  357. }
  358. pars = append(pars, currClassifyInfo.Id, currClassifyInfo.ClassifyName, parentClassifyInfo.Id)
  359. // 获取当前分类下的所有章节类型
  360. currReportChapterTypeList, err := models.GetAllReportChapterTypeListByClassifyId(currClassifyInfo.Id)
  361. if err != nil {
  362. return
  363. }
  364. // 当前的章节类型ID ---> 继承的章节类型ID
  365. chapterTypeIdMap := make(map[int]int)
  366. for _, v := range currReportChapterTypeList {
  367. chapterTypeIdMap[v.ReportChapterTypeId] = v.InheritReportChapterTypeId
  368. }
  369. // 报告转移后,历史章节报告中的type_id也要修复成最新的type_id
  370. err = models.ModifyReportClassifyAndReportChapterTypeByCondition(condition, pars, updateStr, chapterTypeIdMap, parentClassifyInfo.Id, currClassifyInfo.Id, currClassifyInfo.ClassifyName)
  371. if err != nil {
  372. return
  373. }
  374. return
  375. }
  376. // inheritReportChapterType
  377. // @Description: 继承父级分类下的章节类型
  378. // @author: Roc
  379. // @datetime 2024-06-17 14:41:04
  380. // @param parentClassifyId int
  381. // @param currClassifyId int
  382. // @return err error
  383. func inheritReportChapterType(parentClassifyId, currClassifyId int) (err error) {
  384. defer func() {
  385. if err != nil {
  386. utils.FileLog.Error(fmt.Sprint("继承父级分类下的章节类型失败,父级分类ID:", parentClassifyId, ";当前分类ID:", currClassifyId, ";错误信息:", err.Error()))
  387. }
  388. }()
  389. parentReportChapterTypeList, err := models.GetAllReportChapterTypeListByClassifyId(parentClassifyId)
  390. if err != nil {
  391. return
  392. }
  393. // 如果没有章节类型,那么就直接返回
  394. if len(parentReportChapterTypeList) <= 0 {
  395. return
  396. }
  397. addList := make([]*models.ReportChapterType, 0)
  398. for _, v := range parentReportChapterTypeList {
  399. addList = append(addList, &models.ReportChapterType{
  400. //ReportChapterTypeId: 0,
  401. ReportChapterTypeKey: v.ReportChapterTypeKey,
  402. ReportChapterTypeThumb: v.ReportChapterTypeThumb,
  403. BannerUrl: v.BannerUrl,
  404. ReportChapterTypeName: v.ReportChapterTypeName,
  405. Sort: v.Sort,
  406. Enabled: v.Enabled,
  407. CreatedTime: time.Now(),
  408. LastUpdatedTime: time.Now(),
  409. ResearchType: v.ResearchType,
  410. SelectedImage: v.SelectedImage,
  411. UnselectedImage: v.UnselectedImage,
  412. PcSelectedImage: v.PcSelectedImage,
  413. PcUnselectedImage: v.PcUnselectedImage,
  414. EditImgUrl: v.EditImgUrl,
  415. TickerTitle: v.TickerTitle,
  416. IsShow: v.IsShow,
  417. PauseStartTime: v.PauseStartTime,
  418. PauseEndTime: v.PauseEndTime,
  419. IsSet: v.IsSet,
  420. YbIconUrl: v.YbIconUrl,
  421. YbBottomIcon: v.YbBottomIcon,
  422. ReportClassifyId: currClassifyId,
  423. InheritReportChapterTypeId: v.ReportChapterTypeId,
  424. })
  425. }
  426. obj := models.ReportChapterType{}
  427. err = obj.MultiCreate(addList)
  428. // 修改CRM权限
  429. go func() {
  430. var syncReq ChapterTypeSyncReq
  431. _, _ = ReportChapterTypeSync(&syncReq)
  432. }()
  433. return
  434. }
  435. // inheritReportApproveFlow
  436. // @Description: 继承父级分类下的审批流
  437. // @author: Roc
  438. // @datetime 2024-06-17 14:41:04
  439. // @param parentClassifyId int
  440. // @param currClassifyId int
  441. // @return err error
  442. func inheritReportApproveFlow(parentClassifyItem, currClassifyItem *models.Classify) (err error) {
  443. defer func() {
  444. if err != nil {
  445. utils.FileLog.Error(fmt.Sprint("继承父级分类下的审批流失败,父级分类ID:", parentClassifyItem.Id, ";当前分类ID:", currClassifyItem.Id, ";错误信息:", err.Error()))
  446. }
  447. }()
  448. var firstClassify, secondClassify, thirdClassify *models.Classify
  449. if parentClassifyItem.ParentId > 0 {
  450. // 获取父级分类信息
  451. firstClassify, err = models.GetClassifyById(parentClassifyItem.ParentId)
  452. if err != nil {
  453. return
  454. }
  455. secondClassify = parentClassifyItem
  456. thirdClassify = currClassifyItem
  457. } else {
  458. firstClassify = parentClassifyItem
  459. secondClassify = currClassifyItem
  460. }
  461. flowObj := report_approve.ReportApproveFlow{}
  462. // 获取父级的审批流
  463. existCond := fmt.Sprintf(` AND %s = ? AND %s = ? `, report_approve.ReportApproveFlowCols.ReportType, report_approve.ReportApproveFlowCols.ClassifyFirstId)
  464. existPars := make([]interface{}, 0)
  465. existPars = append(existPars, report_approve.FlowReportTypeChinese, firstClassify.Id)
  466. // 如果这是第三级,那么说明只需要查找第二级的审批配置就好了
  467. if thirdClassify != nil {
  468. existCond = fmt.Sprintf(`%s AND %s = ?`, existCond, report_approve.ReportApproveFlowCols.ClassifySecondId)
  469. existPars = append(existPars, secondClassify.Id)
  470. }
  471. parentFlow, err := flowObj.GetItemByCondition(existCond, existPars, "")
  472. if err != nil {
  473. // 如果没有配置审批流,那么就直接返回
  474. if utils.IsErrNoRow(err) {
  475. err = nil
  476. }
  477. return
  478. }
  479. // 获取父级的审批节点
  480. nodeObj := report_approve.ReportApproveNode{}
  481. nodeCond := fmt.Sprintf(` AND %s = ? AND %s = ?`, report_approve.ReportApproveNodeCols.ReportApproveFlowId, report_approve.ReportApproveNodeCols.CurrVersion)
  482. nodePars := make([]interface{}, 0)
  483. nodePars = append(nodePars, parentFlow.ReportApproveFlowId, parentFlow.CurrVersion)
  484. parentNodeList, err := nodeObj.GetItemsByCondition(nodeCond, nodePars, []string{}, "")
  485. if err != nil {
  486. return
  487. }
  488. // 新审批流
  489. currFlow := &report_approve.ReportApproveFlow{
  490. ReportApproveFlowId: 0,
  491. FlowName: currClassifyItem.ClassifyName,
  492. ReportType: parentFlow.ReportType,
  493. ClassifyFirstId: firstClassify.Id,
  494. ClassifySecondId: secondClassify.Id,
  495. //ClassifyThirdId: 0,
  496. CurrVersion: 1,
  497. Enabled: 1,
  498. CreateTime: time.Now().Local(),
  499. ModifyTime: time.Now().Local(),
  500. }
  501. if thirdClassify != nil {
  502. currFlow.ClassifyThirdId = thirdClassify.Id
  503. }
  504. // 新审批流的节点
  505. nodeItems := make([]*report_approve.ReportApproveNode, 0)
  506. for _, v := range parentNodeList {
  507. n := &report_approve.ReportApproveNode{
  508. //ReportApproveNodeId: 0,
  509. //ReportApproveFlowId: 0,
  510. PrevNodeId: 0,
  511. NextNodeId: 0,
  512. NodeType: v.NodeType,
  513. ApproveType: v.ApproveType,
  514. Users: v.Users,
  515. CurrVersion: 1,
  516. CreateTime: time.Now().Local(),
  517. }
  518. nodeItems = append(nodeItems, n)
  519. }
  520. // 新增审批流和节点
  521. err = flowObj.CreateFlowAndNodes(currFlow, nodeItems)
  522. if err != nil {
  523. return
  524. }
  525. parentFlow.Enabled = 0
  526. err = parentFlow.Update([]string{"Enabled"})
  527. return
  528. }
  529. // EditReportClassify
  530. // @Description: 编辑报告分类
  531. // @author: Roc
  532. // @datetime 2024-06-17 13:31:33
  533. // @param classifyId int
  534. // @param classifyName string
  535. // @param chartPermissionIdList []int
  536. // @return err error
  537. // @return errMsg string
  538. // @return isSendEmail bool
  539. func EditReportClassify(classifyId int, classifyName string, chartPermissionIdList []int) (err error, errMsg string, isSendEmail bool) {
  540. isSendEmail = true
  541. errMsg = `修改失败`
  542. item, err := models.GetClassifyById(classifyId)
  543. if err != nil {
  544. errMsg = "获取分类信息失败"
  545. if utils.IsErrNoRow(err) {
  546. errMsg = "分类不存在, 或已被删除"
  547. isSendEmail = false
  548. }
  549. return
  550. }
  551. //originName := item.ClassifyName
  552. // 重名校验
  553. existName, e := models.GetClassifyByName(classifyName, item.ParentId)
  554. if e != nil && !utils.IsErrNoRow(e) {
  555. errMsg = "获取信息失败"
  556. err = errors.New("获取重名分类失败, Err: " + err.Error())
  557. return
  558. }
  559. if existName != nil && existName.Id > 0 && existName.Id != item.Id {
  560. errMsg = "分类名称:" + classifyName + "已存在"
  561. err = errors.New(errMsg)
  562. isSendEmail = false
  563. return
  564. }
  565. item.ClassifyName = classifyName
  566. // ETA1.8.3:不允许修改上级分类 2024-6-17 13:21:01
  567. //item.ParentId = req.ParentId
  568. item.ModifyTime = time.Now().Local()
  569. cols := make([]string, 0)
  570. cols = append(cols, "ClassifyName", "ModifyTime")
  571. err = item.UpdateClassify(cols)
  572. if err != nil {
  573. return
  574. }
  575. return
  576. }
  577. // GetClassifyTreeRecursive 递归获取分类树形结构
  578. func GetClassifyTreeRecursive(list []*models.ClassifyItem, parentId int) []*models.ClassifyItem {
  579. res := make([]*models.ClassifyItem, 0)
  580. for _, v := range list {
  581. if v.ParentId == parentId {
  582. v.Child = GetClassifyTreeRecursive(list, v.Id)
  583. res = append(res, v)
  584. }
  585. }
  586. return res
  587. }
  588. // GetParentClassifyListByParentIdList
  589. // @Description: 递归获取父级分类信息,正常来讲只有三次
  590. // @author: Roc
  591. // @datetime 2024-06-19 13:23:33
  592. // @param parentClassifyIdList []int
  593. // @return list []*models.ClassifyList
  594. // @return err error
  595. func GetParentClassifyListByParentIdList(parentClassifyIdList []int) (list []*models.ClassifyList, err error) {
  596. num := len(parentClassifyIdList)
  597. if num <= 0 {
  598. return
  599. }
  600. list, err = models.GetClassifyListByParentIdList(parentClassifyIdList)
  601. if err != nil {
  602. return
  603. }
  604. // 是否还有上级
  605. {
  606. currParentClassifyIdList := make([]int, 0)
  607. for _, v := range list {
  608. if v.ParentId > 0 {
  609. currParentClassifyIdList = append(currParentClassifyIdList, v.ParentId)
  610. }
  611. }
  612. if len(currParentClassifyIdList) > 0 {
  613. tmpList, tmpErr := GetParentClassifyListByParentIdList(currParentClassifyIdList)
  614. if tmpErr != nil {
  615. err = tmpErr
  616. return
  617. }
  618. list = append(tmpList, list...)
  619. }
  620. }
  621. return
  622. }
  623. // GetClassifyListTreeRecursive
  624. // @Description: 递归获取分类树形结构
  625. // @author: Roc
  626. // @datetime 2024-06-19 13:23:28
  627. // @param list []*models.ClassifyList
  628. // @param parentId int
  629. // @return []*models.ClassifyList
  630. func GetClassifyListTreeRecursive(list []*models.ClassifyList, parentId int) []*models.ClassifyList {
  631. res := make([]*models.ClassifyList, 0)
  632. for _, v := range list {
  633. if v.ParentId == parentId {
  634. v.Child = GetClassifyListTreeRecursive(list, v.Id)
  635. res = append(res, v)
  636. }
  637. }
  638. // 前端的JP需要我这么返回
  639. if len(res) <= 0 {
  640. res = nil
  641. }
  642. return res
  643. }
  644. // BySortAndCreateTime 用来排序,先按Sort字段升序排序,若Sort相同,则按照CreateTime字段升序排序。
  645. type BySortAndCreateTime []*models.ClassifyList
  646. func (a BySortAndCreateTime) Len() int {
  647. return len(a)
  648. }
  649. func (a BySortAndCreateTime) Swap(i, j int) {
  650. a[i], a[j] = a[j], a[i]
  651. }
  652. func (a BySortAndCreateTime) Less(i, j int) bool {
  653. if a[i].Sort == a[j].Sort {
  654. return a[i].CreateTime.Before(a[j].CreateTime)
  655. }
  656. return a[i].Sort < a[j].Sort
  657. }
  658. // SortClassifyListBySortAndCreateTime sorts the ClassifyList slice by Sort and then CreateTime in ascending order.
  659. func SortClassifyListBySortAndCreateTime(classifyList []*models.ClassifyList) {
  660. sort.Sort(BySortAndCreateTime(classifyList))
  661. }