report_v2.go 43 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376
  1. package services
  2. import (
  3. "archive/zip"
  4. "errors"
  5. "eta/eta_api/models"
  6. "eta/eta_api/models/report"
  7. "eta/eta_api/models/report_approve"
  8. "eta/eta_api/models/system"
  9. "eta/eta_api/utils"
  10. "fmt"
  11. "github.com/rdlucklib/rdluck_tools/file"
  12. "github.com/rdlucklib/rdluck_tools/http"
  13. "os"
  14. "path"
  15. "strconv"
  16. "time"
  17. )
  18. // AddReportAndChapter
  19. // @Description: 新增报告(包含章节)
  20. // @author: Roc
  21. // @datetime 2024-06-04 11:23:20
  22. // @param reportInfo *models.Report
  23. // @param inheritReportId int
  24. // @return err error
  25. // @return errMsg string
  26. func AddReportAndChapter(reportInfo *models.Report, inheritReportId int, grantAdminIdList []int) (err error, errMsg string) {
  27. // 根据审批开关及审批流判断当前报告状态
  28. state, e := CheckReportCurrState(report_approve.FlowReportTypeChinese, reportInfo.ClassifyIdFirst, reportInfo.ClassifyIdSecond, reportInfo.ClassifyIdThird, models.ReportOperateAdd)
  29. if e != nil {
  30. //errMsg = "操作失败"
  31. err = errors.New("校验报告当前状态失败, Err: " + e.Error())
  32. return
  33. }
  34. // 报告状态
  35. reportInfo.State = state
  36. // 获取最小分类id
  37. minClassifyId := reportInfo.ClassifyIdThird
  38. if minClassifyId <= 0 {
  39. minClassifyId = reportInfo.ClassifyIdSecond
  40. }
  41. if minClassifyId <= 0 {
  42. minClassifyId = reportInfo.ClassifyIdFirst
  43. }
  44. if minClassifyId <= 0 {
  45. errMsg = "分类异常"
  46. err = errors.New(errMsg)
  47. return
  48. }
  49. errMsg = "生成报告失败"
  50. // 报告继承
  51. if inheritReportId > 0 {
  52. inheritReport, tmpErr := models.GetReportByReportId(inheritReportId)
  53. if tmpErr != nil && tmpErr.Error() != utils.ErrNoRow() {
  54. errMsg = "获取待继承的报告失败"
  55. err = tmpErr
  56. return
  57. }
  58. if inheritReport != nil {
  59. // 判断当前的报告分类与继承的报告分类是否一致
  60. if inheritReport.ClassifyIdFirst != reportInfo.ClassifyIdFirst || inheritReport.ClassifyIdSecond != reportInfo.ClassifyIdSecond || inheritReport.ClassifyIdThird != reportInfo.ClassifyIdThird {
  61. errMsg = "分类异常,与继承的报告分类不一致"
  62. err = errors.New(errMsg)
  63. return
  64. }
  65. reportInfo.ChapterType = inheritReport.ChapterType
  66. reportInfo.Content = inheritReport.Content
  67. reportInfo.ContentSub = inheritReport.ContentSub
  68. reportInfo.ContentStruct = inheritReport.ContentStruct
  69. reportInfo.HeadImg = inheritReport.HeadImg
  70. reportInfo.EndImg = inheritReport.EndImg
  71. reportInfo.CanvasColor = inheritReport.CanvasColor
  72. reportInfo.NeedSplice = inheritReport.NeedSplice
  73. reportInfo.HeadResourceId = inheritReport.HeadResourceId
  74. reportInfo.EndResourceId = inheritReport.EndResourceId
  75. reportInfo.InheritReportId = inheritReport.Id
  76. }
  77. }
  78. // 获取待生成的报告章节
  79. addChapterList, allGrantUserList, err, errMsg := getAddChapter(reportInfo, minClassifyId, inheritReportId, grantAdminIdList)
  80. // 新增报告及章节
  81. var reportId int64
  82. reportId, err = models.AddReportAndChapter(reportInfo, allGrantUserList, addChapterList)
  83. if err != nil {
  84. err = errors.New("新增报告及章节失败, Err: " + err.Error())
  85. return
  86. }
  87. reportCode := utils.MD5(strconv.Itoa(reportInfo.Id))
  88. reportInfo.ReportCode = reportCode
  89. // 修改唯一编码
  90. {
  91. go models.ModifyReportCode(reportId, reportCode)
  92. }
  93. // 报告权限处理
  94. go handleReportPermission(reportId, minClassifyId)
  95. return
  96. }
  97. // EditReport
  98. // @Description: 修改报告的基础信息、授权用户权限
  99. // @author: Roc
  100. // @datetime 2024-06-06 17:16:58
  101. // @param reportInfo *models.Report
  102. // @param req models.EditReq
  103. // @param sysUser *system.Admin
  104. // @return err error
  105. // @return errMsg string
  106. func EditReport(reportInfo *models.Report, req models.EditReq, sysUser *system.Admin) (err error, errMsg string) {
  107. errMsg = `保存失败`
  108. //var stage int
  109. //if reportInfo.ClassifyNameFirst != req.ClassifyNameFirst || reportInfo.ClassifyNameSecond != req.ClassifyNameSecond {
  110. // // 报告期数
  111. // maxStage, _ := models.GetReportStageEdit(req.ClassifyIdFirst, req.ClassifyIdSecond, req.ClassifyIdThird, int(req.ReportId))
  112. // maxStage = maxStage + 1
  113. // stage = maxStage
  114. //} else {
  115. // stage = reportInfo.Stage
  116. //}
  117. //if req.State != reportInfo.State {
  118. // recordItem := &models.ReportStateRecord{
  119. // ReportId: int(req.ReportId),
  120. // ReportType: 1,
  121. // State: req.State,
  122. // AdminId: this.SysUser.AdminId,
  123. // AdminName: this.SysUser.AdminName,
  124. // CreateTime: time.Now(),
  125. // }
  126. // go func() {
  127. // _, _ = models.AddReportStateRecord(recordItem)
  128. // }()
  129. //}
  130. //item := new(models.Report)
  131. //reportInfo.ClassifyIdFirst = req.ClassifyIdFirst
  132. //reportInfo.ClassifyNameFirst = req.ClassifyNameFirst
  133. //reportInfo.ClassifyIdSecond = req.ClassifyIdSecond
  134. //reportInfo.ClassifyNameSecond = req.ClassifyNameSecond
  135. //reportInfo.ClassifyIdThird = req.ClassifyIdThird
  136. //reportInfo.ClassifyNameThird = req.ClassifyNameThird
  137. reportInfo.Title = req.Title
  138. reportInfo.Abstract = req.Abstract
  139. reportInfo.Author = req.Author
  140. reportInfo.Frequency = req.Frequency
  141. //reportInfo.State = reportInfo.State // 编辑不变更状态
  142. //reportInfo.Stage = stage // 编辑不变更期数
  143. //reportInfo.Content = html.EscapeString(req.Content) // 编辑不变更具体内容
  144. //reportInfo.ContentSub = html.EscapeString(contentSub) // 编辑不变更具体内容
  145. reportInfo.CreateTime = req.CreateTime
  146. //reportInfo.CollaborateType = req.CollaborateType
  147. //reportInfo.ReportLayout = req.ReportLayout
  148. if req.IsPublicPublish <= 0 {
  149. req.IsPublicPublish = 1
  150. }
  151. reportInfo.IsPublicPublish = req.IsPublicPublish
  152. reportInfo.LastModifyAdminId = sysUser.AdminId
  153. reportInfo.LastModifyAdminName = sysUser.RealName
  154. reportInfo.ModifyTime = time.Now()
  155. state, e := CheckReportCurrState(report_approve.FlowReportTypeChinese, reportInfo.ClassifyIdFirst, reportInfo.ClassifyIdSecond, reportInfo.ClassifyIdThird, models.ReportOperateEdit)
  156. if e != nil {
  157. //errMsg = "操作失败"
  158. err = errors.New("校验报告当前状态失败, Err: " + e.Error())
  159. return
  160. }
  161. // 报告状态
  162. reportInfo.State = state
  163. //updateCols := []string{"ClassifyIdFirst", "ClassifyNameFirst", "ClassifyIdSecond", "ClassifyNameSecond", "ClassifyIdThird", "ClassifyNameThird", "Title", "Abstract", "Author", "Frequency", "Stage", "CreateTime", "IsPublicPublish", "LastModifyAdminId", "LastModifyAdminName", "ModifyTime"}
  164. updateCols := []string{"Title", "Abstract", "Author", "Frequency", "CreateTime", "IsPublicPublish", "LastModifyAdminId", "LastModifyAdminName", "ModifyTime", "State"}
  165. if req.HeadResourceId > 0 {
  166. reportInfo.HeadResourceId = req.HeadResourceId
  167. updateCols = append(updateCols, "HeadResourceId")
  168. }
  169. if req.EndResourceId > 0 {
  170. reportInfo.EndResourceId = req.EndResourceId
  171. updateCols = append(updateCols, "EndResourceId")
  172. }
  173. // 需要添加的报告授权数据
  174. addReportAdminList := make([]*report.ReportGrant, 0)
  175. // 待移除的报告授权数据id
  176. delReportGrantIdList := make([]int, 0)
  177. // 处理当前报告需要新增/移除的授权信息
  178. {
  179. reportGrantObj := report.ReportGrant{}
  180. // 获取当前报告已经授权的用户信息
  181. reportGrantList, tmpErr := reportGrantObj.GetGrantListById(reportInfo.Id)
  182. if tmpErr != nil {
  183. err = tmpErr
  184. return
  185. }
  186. // 当前报告已经授权的用户信息
  187. currReportAdminMap := make(map[int]*report.ReportGrant)
  188. // 需要删除的报告授权数据
  189. delReportAdminMap := make(map[int]*report.ReportGrant)
  190. for _, v := range reportGrantList {
  191. currReportAdminMap[v.AdminId] = v
  192. delReportAdminMap[v.AdminId] = v
  193. }
  194. // 先看需要新增哪些用户
  195. for _, tmpAdminId := range req.GrantAdminIdList {
  196. _, ok := currReportAdminMap[tmpAdminId]
  197. // 如果章节中需要新增的用户 已经在 报告授权用户里面,那么就忽略,可以不用新增了
  198. if ok {
  199. delete(delReportAdminMap, tmpAdminId)
  200. continue
  201. }
  202. // 如果不存在,那么就新增授权
  203. addReportAdminList = append(addReportAdminList, &report.ReportGrant{
  204. //GrantId: 0,
  205. ReportId: reportInfo.Id,
  206. AdminId: tmpAdminId,
  207. CreateTime: time.Now(),
  208. })
  209. }
  210. // 查出需要移除的授权id
  211. for _, v := range delReportAdminMap {
  212. delReportGrantIdList = append(delReportGrantIdList, v.GrantId)
  213. }
  214. }
  215. // 修改报告的基本信息,以及报告的授权用户
  216. err = models.EditReportAndPermission(reportInfo, updateCols, addReportAdminList, delReportGrantIdList)
  217. if err != nil {
  218. return
  219. }
  220. // 报告权限处理
  221. {
  222. minClassifyId, _, tmpErr := getMinClassify(reportInfo)
  223. if tmpErr != nil {
  224. return
  225. }
  226. go handleReportPermission(int64(reportInfo.Id), minClassifyId)
  227. }
  228. return
  229. }
  230. // getAddChapter
  231. // @Description: 获取待新增的报告章节列表
  232. // @author: Roc
  233. // @datetime 2024-06-04 13:10:58
  234. // @param reportInfo *models.Report
  235. // @param minClassifyId int
  236. // @param inheritReportId int
  237. // @param grantAdminIdList []int
  238. // @return chapterList []*models.ReportChapter
  239. // @return err error
  240. // @return errMsg string
  241. func getAddChapter(reportInfo *models.Report, minClassifyId, inheritReportId int, grantAdminIdList []int) (chapterList []models.AddReportChapter, allGrantUserList []*report.ReportGrant, err error, errMsg string) {
  242. // 待生成的报告章节内容
  243. chapterList = make([]models.AddReportChapter, 0)
  244. // 所有的授权用户
  245. allGrantUserList = make([]*report.ReportGrant, 0)
  246. // 报告授权的用户ID
  247. needAdminIdMap := make(map[int]bool)
  248. for _, adminId := range grantAdminIdList {
  249. needAdminIdMap[adminId] = true
  250. allGrantUserList = append(allGrantUserList, &report.ReportGrant{
  251. //GrantId: 0,
  252. //ReportId: 0,
  253. AdminId: adminId,
  254. CreateTime: time.Now(),
  255. })
  256. }
  257. if reportInfo.HasChapter != 1 {
  258. return
  259. }
  260. // 最小单元的分类
  261. var minClassifyName string
  262. if reportInfo.ClassifyIdThird == minClassifyId {
  263. minClassifyName = reportInfo.ClassifyNameThird
  264. } else if reportInfo.ClassifyIdSecond == minClassifyId {
  265. minClassifyName = reportInfo.ClassifyNameSecond
  266. } else {
  267. minClassifyName = reportInfo.ClassifyNameFirst
  268. }
  269. errMsg = "生成报告章节失败"
  270. // 章节类型列表
  271. allTypeList, err := models.GetReportChapterTypeListByClassifyId(minClassifyId)
  272. if err != nil {
  273. err = errors.New(errMsg)
  274. return
  275. }
  276. // 待添加的章节
  277. chapterTypeList := make([]*models.ReportChapterType, 0)
  278. // 待添加的章节类型id列表
  279. chapterTypeIdList := make([]int, 0)
  280. nowTime := time.Now().Local()
  281. for _, chapterType := range allTypeList {
  282. // 如果被永久暂停更新了
  283. if chapterType.Enabled == 0 { //该章节已被永久禁用,那么就不允许继承或者新增该章节
  284. continue
  285. }
  286. if chapterType.PauseStartTime != "" && chapterType.PauseEndTime != "" && chapterType.PauseStartTime != utils.EmptyDateStr && chapterType.PauseEndTime != utils.EmptyDateStr {
  287. startTime, timeErr := time.ParseInLocation(utils.FormatDate, chapterType.PauseStartTime, time.Local)
  288. if timeErr != nil {
  289. utils.FileLog.Error("更新规则时间转换失败4001, Err: " + timeErr.Error())
  290. continue
  291. }
  292. endTime, timeErr := time.ParseInLocation(utils.FormatDate, chapterType.PauseEndTime, time.Local)
  293. if timeErr != nil {
  294. utils.FileLog.Error("更新规则时间转换失败4002, Err: " + timeErr.Error())
  295. continue
  296. }
  297. // 暂停更新
  298. if nowTime.After(startTime) && nowTime.Before(endTime.AddDate(0, 0, 1)) {
  299. continue
  300. }
  301. }
  302. // 正常的章节类型状态,那么应该自动创建该章节
  303. chapterTypeList = append(chapterTypeList, chapterType)
  304. chapterTypeIdList = append(chapterTypeIdList, chapterType.ReportChapterTypeId)
  305. }
  306. // 待继承的章节类id的授权用户
  307. oldChapterIdGrantListMap := make(map[int][]*report.ReportChapterGrant)
  308. // 待继承的章节类id关联的品种列表
  309. oldChapterPermissionListMap := make(map[int][]*report.ReportChapterPermissionMapping)
  310. // 自定义章节列表
  311. customAddChapterList := make([]models.AddReportChapter, 0)
  312. // 报告继承
  313. inheritChapterMap := make(map[int]*models.ReportChapter)
  314. // 当前分类下配置的章节类型id所关联的品种列表(默认配置,不是从继承报告里面获取的,如果有继承章节,那么需要从继承报告里面获取)
  315. currChapterTypePermissionListMap := make(map[int][]*report.ReportChapterPermissionMapping)
  316. if len(chapterTypeIdList) > 0 {
  317. mappingList, e := models.GetChapterTypePermissionByChapterTypeIdList(chapterTypeIdList)
  318. if e != nil {
  319. err = fmt.Errorf("获取章节类型权限列表失败, Err: " + e.Error())
  320. return
  321. }
  322. hasPermissionMap := make(map[string]bool)
  323. for _, v := range mappingList {
  324. tmpChapterTypePermissionList, ok := currChapterTypePermissionListMap[v.ReportChapterTypeId]
  325. if !ok {
  326. tmpChapterTypePermissionList = make([]*report.ReportChapterPermissionMapping, 0)
  327. }
  328. key := fmt.Sprint(v.ReportChapterTypeId, "-", v.ChartPermissionId)
  329. if _, has := hasPermissionMap[key]; !has {
  330. hasPermissionMap[key] = true
  331. currChapterTypePermissionListMap[v.ReportChapterTypeId] = append(tmpChapterTypePermissionList, &report.ReportChapterPermissionMapping{
  332. ReportChapterPermissionMappingId: 0,
  333. ReportChapterId: 0,
  334. ChartPermissionId: v.ChartPermissionId,
  335. CreateTime: time.Now(),
  336. })
  337. }
  338. }
  339. }
  340. if inheritReportId > 0 {
  341. // 继承待继承的报告章节内容
  342. inheritReportChapters, tmpErr := models.GetChapterListByReportId(inheritReportId)
  343. if tmpErr != nil {
  344. errMsg = "获取待继承的报告章节失败"
  345. err = tmpErr
  346. return
  347. }
  348. reportChaptersIdList := make([]int, 0)
  349. for _, v := range inheritReportChapters {
  350. reportChaptersIdList = append(reportChaptersIdList, v.ReportChapterId)
  351. }
  352. // 继承的报告章节用户map
  353. grantListMap := make(map[int][]*report.ReportChapterGrant)
  354. // 继承的报告章节的关联品种map
  355. chapterPermissionListMap := make(map[int][]*report.ReportChapterPermissionMapping)
  356. // 授权数据列表
  357. if len(reportChaptersIdList) > 0 {
  358. // 授权用户数据
  359. obj := report.ReportChapterGrant{}
  360. grantList, tmpErr := obj.GetGrantListByIdList(reportChaptersIdList)
  361. if tmpErr != nil {
  362. errMsg = "获取待继承的报告章节的授权用户列表失败"
  363. err = tmpErr
  364. return
  365. }
  366. for _, v := range grantList {
  367. // 如果不在报告授权的用户ID里面,那么该章节就不继承该授权用户
  368. if _, ok := needAdminIdMap[v.AdminId]; !ok {
  369. continue
  370. }
  371. currReportChapterId := v.ReportChapterId
  372. tmpGrantList, ok := grantListMap[currReportChapterId]
  373. if !ok {
  374. tmpGrantList = make([]*report.ReportChapterGrant, 0)
  375. }
  376. v.ReportChapterId = 0
  377. v.GrantId = 0
  378. tmpGrantList = append(tmpGrantList, v)
  379. grantListMap[currReportChapterId] = tmpGrantList
  380. }
  381. // 授权关联品种数据
  382. permissionObj := report.ReportChapterPermissionMapping{}
  383. permissionList, tmpErr := permissionObj.GetPermissionListByIdList(reportChaptersIdList)
  384. if tmpErr != nil {
  385. errMsg = "获取待继承的报告章节的授权用户列表失败"
  386. err = tmpErr
  387. return
  388. }
  389. for _, v := range permissionList {
  390. currReportChapterId := v.ReportChapterId
  391. tmpPermissionList, ok := chapterPermissionListMap[currReportChapterId]
  392. if !ok {
  393. tmpPermissionList = make([]*report.ReportChapterPermissionMapping, 0)
  394. }
  395. v.ReportChapterId = 0
  396. v.ReportChapterPermissionMappingId = 0
  397. tmpPermissionList = append(tmpPermissionList, v)
  398. chapterPermissionListMap[currReportChapterId] = tmpPermissionList
  399. }
  400. }
  401. // 继承的报告章节内容
  402. for i := 0; i < len(inheritReportChapters); i++ {
  403. customChapter := inheritReportChapters[i]
  404. // 授权用户列表
  405. tmpGrantList, ok := grantListMap[customChapter.ReportChapterId]
  406. if !ok {
  407. tmpGrantList = make([]*report.ReportChapterGrant, 0)
  408. }
  409. oldChapterIdGrantListMap[customChapter.ReportChapterId] = tmpGrantList
  410. // 关联品种列表
  411. chapterPermissionList, ok := chapterPermissionListMap[customChapter.ReportChapterId]
  412. if !ok {
  413. chapterPermissionList = make([]*report.ReportChapterPermissionMapping, 0)
  414. }
  415. oldChapterPermissionListMap[customChapter.ReportChapterId] = chapterPermissionList
  416. // 判断该章节是否是系统章节,如果是的话,那就是需要额外创建的
  417. if customChapter.TypeId > 0 {
  418. inheritChapterMap[customChapter.TypeId] = customChapter
  419. continue
  420. }
  421. // 自定义的报告内容
  422. customChapter.ReportId = reportInfo.Id
  423. customChapter.ReportChapterId = 0
  424. customChapter.ClassifyIdFirst = minClassifyId
  425. customChapter.ClassifyNameFirst = minClassifyName
  426. customChapter.Stage = reportInfo.Stage
  427. customChapter.PublishState = 1
  428. customChapter.CreateTime = reportInfo.CreateTime
  429. customChapter.ModifyTime = time.Now()
  430. customChapter.LastModifyAdminId = reportInfo.LastModifyAdminId
  431. customChapter.LastModifyAdminName = reportInfo.LastModifyAdminName
  432. customChapter.ContentModifyTime = time.Now()
  433. customAddChapter := models.AddReportChapter{
  434. ReportChapter: customChapter,
  435. GrantList: tmpGrantList,
  436. GrantPermissionList: chapterPermissionList,
  437. }
  438. customAddChapterList = append(customAddChapterList, customAddChapter)
  439. }
  440. }
  441. // 最大排序
  442. var maxSort int
  443. for _, typeItem := range chapterTypeList {
  444. v, ok := inheritChapterMap[typeItem.ReportChapterTypeId]
  445. // 章节授权用户
  446. var tmpGrantList []*report.ReportChapterGrant
  447. // 章节关联品种
  448. var tmpChapterPermissionList []*report.ReportChapterPermissionMapping
  449. chapterItem := new(models.ReportChapter)
  450. if ok && v != nil {
  451. // 如果存在继承的章节,那么就从继承的章节内容中获取
  452. chapterItem.AddType = 2
  453. chapterItem.Title = v.Title
  454. chapterItem.ReportType = v.ReportType
  455. chapterItem.ClassifyIdFirst = minClassifyId
  456. chapterItem.ClassifyNameFirst = minClassifyName
  457. chapterItem.TypeId = typeItem.ReportChapterTypeId
  458. chapterItem.TypeName = typeItem.ReportChapterTypeName
  459. chapterItem.Content = v.Content
  460. chapterItem.ContentSub = v.ContentSub
  461. chapterItem.Stage = reportInfo.Stage
  462. chapterItem.PublishState = 1
  463. chapterItem.Sort = typeItem.Sort
  464. chapterItem.CreateTime = reportInfo.CreateTime
  465. chapterItem.ModifyTime = time.Now()
  466. chapterItem.LastModifyAdminId = reportInfo.LastModifyAdminId
  467. chapterItem.LastModifyAdminName = reportInfo.LastModifyAdminName
  468. chapterItem.ContentModifyTime = time.Now()
  469. chapterItem.ContentStruct = v.ContentStruct
  470. chapterItem.ReportLayout = v.ReportLayout
  471. chapterItem.ReportCreateTime = time.Now()
  472. // 继承历史章节中的授权用户列表
  473. tmpGrantList, ok = oldChapterIdGrantListMap[v.ReportChapterId]
  474. if !ok {
  475. tmpGrantList = make([]*report.ReportChapterGrant, 0)
  476. }
  477. // 继承历史章节中的关联品种列表
  478. tmpChapterPermissionList, ok = oldChapterPermissionListMap[v.ReportChapterId]
  479. if !ok {
  480. tmpChapterPermissionList = make([]*report.ReportChapterPermissionMapping, 0)
  481. }
  482. } else {
  483. chapterItem.AddType = 1
  484. chapterItem.Title = typeItem.ReportChapterTypeName
  485. chapterItem.ReportType = typeItem.ResearchType
  486. chapterItem.ClassifyIdFirst = minClassifyId
  487. chapterItem.ClassifyNameFirst = minClassifyName
  488. chapterItem.TypeId = typeItem.ReportChapterTypeId
  489. chapterItem.TypeName = typeItem.ReportChapterTypeName
  490. chapterItem.Stage = reportInfo.Stage
  491. chapterItem.PublishState = 1
  492. chapterItem.Sort = typeItem.Sort
  493. chapterItem.CreateTime = reportInfo.CreateTime
  494. chapterItem.ModifyTime = time.Now()
  495. chapterItem.LastModifyAdminId = reportInfo.LastModifyAdminId
  496. chapterItem.LastModifyAdminName = reportInfo.LastModifyAdminName
  497. chapterItem.ContentModifyTime = time.Now()
  498. //chapterItem.ContentStruct = v.ContentStruct
  499. chapterItem.ReportLayout = reportInfo.ReportLayout
  500. chapterItem.ReportCreateTime = time.Now()
  501. // 默认配置:从当前分类下配置的章节类型id所关联的品种列表
  502. tmpChapterPermissionList, ok = currChapterTypePermissionListMap[typeItem.ReportChapterTypeId]
  503. if !ok {
  504. tmpChapterPermissionList = make([]*report.ReportChapterPermissionMapping, 0)
  505. }
  506. }
  507. if typeItem.Sort > maxSort {
  508. maxSort = typeItem.Sort
  509. }
  510. addChapter := models.AddReportChapter{
  511. ReportChapter: chapterItem,
  512. GrantList: tmpGrantList,
  513. GrantPermissionList: tmpChapterPermissionList,
  514. }
  515. chapterList = append(chapterList, addChapter)
  516. }
  517. // 将自定义的章节内容添加到待生成的章节内容中
  518. for _, addChapterItem := range customAddChapterList {
  519. maxSort++
  520. addChapterItem.ReportChapter.Sort = maxSort
  521. chapterList = append(chapterList, addChapterItem)
  522. }
  523. //hasGrantUserMap := make(map[int]bool)
  524. //for _, grantList := range typeGrantListMap {
  525. // for _, grant := range grantList {
  526. // if _, ok := hasGrantUserMap[grant.AdminId]; !ok {
  527. // allGrantUserList = append(allGrantUserList, &report.ReportGrant{
  528. // //GrantId: 0,
  529. // //ReportId: 0,
  530. // AdminId: grant.AdminId,
  531. // CreateTime: time.Now(),
  532. // })
  533. // }
  534. // }
  535. //}
  536. return
  537. }
  538. // AddChapterBaseInfoAndPermission
  539. // @Description: 添加章节基本信息及权限
  540. // @author: Roc
  541. // @datetime 2024-06-11 15:35:23
  542. // @param reportInfo *models.Report
  543. // @param reportChapterInfo *models.ReportChapter
  544. // @param permissionIdList []int
  545. // @param adminIdList []int
  546. // @return err error
  547. // @return errMsg string
  548. func AddChapterBaseInfoAndPermission(reportInfo *models.Report, reportChapterInfo *models.ReportChapter, permissionIdList []int, adminIdList []int) (err error, errMsg string) {
  549. errMsg = "新增失败"
  550. if reportInfo.State == 2 {
  551. errMsg = "该报告已发布,不允许编辑"
  552. err = errors.New(errMsg)
  553. return
  554. }
  555. // 需要添加的报告章节授权数据
  556. addChapterAdminList := make([]*report.ReportChapterGrant, 0)
  557. for _, adminId := range adminIdList {
  558. //新增授权
  559. addChapterAdminList = append(addChapterAdminList, &report.ReportChapterGrant{
  560. //GrantId: 0,
  561. //ReportChapterId: reportChapterInfo.ReportChapterId,
  562. AdminId: adminId,
  563. CreateTime: time.Now(),
  564. })
  565. }
  566. // 需要添加的报告章节品种权限数据
  567. addChapterPermissionList := make([]*report.ReportChapterPermissionMapping, 0)
  568. // 品种权限
  569. for _, permissionId := range permissionIdList {
  570. // 如果不存在,那么就新增品种权限配置
  571. addChapterPermissionList = append(addChapterPermissionList, &report.ReportChapterPermissionMapping{
  572. //ReportChapterPermissionMappingId: 0,
  573. //ReportChapterId: reportChapterInfo.ReportChapterId,
  574. ChartPermissionId: permissionId,
  575. CreateTime: time.Now(),
  576. })
  577. }
  578. err = models.AddChapterBaseInfoAndPermission(reportChapterInfo, addChapterAdminList, addChapterPermissionList)
  579. return
  580. }
  581. // EditChapterBaseInfoAndPermission
  582. // @Description: 修改报告章节的基础信息、授权用户权限、品种权限
  583. // @author: Roc
  584. // @datetime 2024-06-05 11:49:11
  585. // @param reportInfo *models.Report
  586. // @param reportChapterInfo *models.ReportChapter
  587. // @param title string
  588. // @param permissionIdList []int
  589. // @param adminIdList []int
  590. // @return err error
  591. // @return errMsg string
  592. func EditChapterBaseInfoAndPermission(reportInfo *models.Report, reportChapterInfo *models.ReportChapter, title string, permissionIdList []int, adminIdList []int) (err error, errMsg string) {
  593. errMsg = "修改失败"
  594. if reportInfo.State == 2 {
  595. errMsg = "该报告已发布,不允许编辑"
  596. err = errors.New(errMsg)
  597. return
  598. }
  599. updateCols := make([]string, 0)
  600. // 如果标题内容,那么就修改
  601. if title != `` {
  602. reportChapterInfo.Title = title
  603. reportChapterInfo.ModifyTime = time.Now()
  604. updateCols = append(updateCols, "Title", "ModifyTime")
  605. reportChapterInfo.UpdateChapter(updateCols)
  606. }
  607. reportGrantObj := report.ReportGrant{}
  608. chapterGrantObj := report.ReportChapterGrant{}
  609. chapterPermissionObj := report.ReportChapterPermissionMapping{}
  610. // 报告授权的用户map
  611. reportGrantAdminIdMap := make(map[int]bool)
  612. // 获取报告授权的用户信息
  613. {
  614. // 获取当前报告已经授权的用户信息
  615. reportGrantList, tmpErr := reportGrantObj.GetGrantListById(reportInfo.Id)
  616. if tmpErr != nil {
  617. err = tmpErr
  618. return
  619. }
  620. for _, v := range reportGrantList {
  621. reportGrantAdminIdMap[v.AdminId] = true
  622. }
  623. }
  624. // 需要添加的报告章节授权数据
  625. addChapterAdminList := make([]*report.ReportChapterGrant, 0)
  626. // 待移除的报告章节授权数据id
  627. delReportChapterGrantIdList := make([]int, 0)
  628. // 处理当前报告章节需要新增/移除的授权信息
  629. {
  630. // 获取当前章节已经授权的用户信息
  631. chapterGrantList, tmpErr := chapterGrantObj.GetGrantListById(reportChapterInfo.ReportChapterId)
  632. if tmpErr != nil {
  633. err = tmpErr
  634. return
  635. }
  636. // 当前章节已经授权的用户信息
  637. currChapterAdminMap := make(map[int]*report.ReportChapterGrant)
  638. // 需要删除的报告章节授权数据
  639. delChapterAdminMap := make(map[int]*report.ReportChapterGrant)
  640. for _, v := range chapterGrantList {
  641. currChapterAdminMap[v.AdminId] = v
  642. delChapterAdminMap[v.AdminId] = v
  643. }
  644. for _, adminId := range adminIdList {
  645. // 如果该用户 不在 报告授权的用户map 里面,说明这个用户是要移除的
  646. if _, ok := reportGrantAdminIdMap[adminId]; !ok {
  647. continue
  648. }
  649. _, ok := currChapterAdminMap[adminId]
  650. // 如果存在,那么从 “需要删除的报告章节授权数据” 的map中移除
  651. if ok {
  652. delete(delChapterAdminMap, adminId)
  653. continue
  654. }
  655. // 如果不存在,那么就新增授权
  656. addChapterAdminList = append(addChapterAdminList, &report.ReportChapterGrant{
  657. //GrantId: 0,
  658. ReportChapterId: reportChapterInfo.ReportChapterId,
  659. AdminId: adminId,
  660. CreateTime: time.Now(),
  661. })
  662. }
  663. // 查出需要移除的授权id
  664. for _, v := range delChapterAdminMap {
  665. delReportChapterGrantIdList = append(delReportChapterGrantIdList, v.GrantId)
  666. }
  667. }
  668. // 其他章节授权的用户
  669. otherChapterAdminMap := make(map[int]bool)
  670. {
  671. // 获取报告所有的章节id
  672. reportChapterIdList, tmpErr := models.GetReportChapterIdList(reportInfo.Id)
  673. if tmpErr != nil {
  674. err = tmpErr
  675. return
  676. }
  677. if len(reportChapterIdList) > 0 {
  678. list, tmpErr := chapterGrantObj.GetGrantListByIdList(reportChapterIdList)
  679. if tmpErr != nil {
  680. err = tmpErr
  681. return
  682. }
  683. for _, v := range list {
  684. // 如果是当前章节,因为涉及到重新授权,所以得过滤
  685. if v.ReportChapterId == reportChapterInfo.ReportChapterId {
  686. continue
  687. }
  688. otherChapterAdminMap[v.AdminId] = true
  689. }
  690. }
  691. }
  692. // 需要添加的报告章节品种权限数据
  693. addChapterPermissionList := make([]*report.ReportChapterPermissionMapping, 0)
  694. // 待移除的报告章节品种权限数据id
  695. delChapterPermissionMappingIdList := make([]int, 0)
  696. // 处理当前报告章节需要新增/移除的品种权限信息
  697. {
  698. // 获取当前章节已经配置的品种权限信息
  699. chapterPermissionList, tmpErr := chapterPermissionObj.GetPermissionListById(reportChapterInfo.ReportChapterId)
  700. if tmpErr != nil {
  701. err = tmpErr
  702. return
  703. }
  704. // 当前章节已经配置的品种权限信息
  705. currChapterPermissionMap := make(map[int]*report.ReportChapterPermissionMapping)
  706. // 需要删除的报告章节品种权限配置
  707. delChapterPermissionMap := make(map[int]*report.ReportChapterPermissionMapping)
  708. for _, v := range chapterPermissionList {
  709. currChapterPermissionMap[v.ChartPermissionId] = v
  710. delChapterPermissionMap[v.ChartPermissionId] = v
  711. }
  712. for _, permissionId := range permissionIdList {
  713. _, ok := currChapterPermissionMap[permissionId]
  714. // 如果存在,那么从 “需要删除的报告章节品种权限配置” 的map中移除
  715. if ok {
  716. delete(delChapterPermissionMap, permissionId)
  717. continue
  718. }
  719. // 如果不存在,那么就新增品种权限配置
  720. addChapterPermissionList = append(addChapterPermissionList, &report.ReportChapterPermissionMapping{
  721. //ReportChapterPermissionMappingId: 0,
  722. ReportChapterId: reportChapterInfo.ReportChapterId,
  723. ChartPermissionId: permissionId,
  724. CreateTime: time.Now(),
  725. })
  726. }
  727. // 查出需要移除的品种权限配置
  728. for _, v := range delChapterPermissionMap {
  729. delChapterPermissionMappingIdList = append(delChapterPermissionMappingIdList, v.ReportChapterPermissionMappingId)
  730. }
  731. }
  732. err = models.EditChapterBaseInfoAndPermission(reportInfo, reportChapterInfo, updateCols, addChapterAdminList, addChapterPermissionList, delReportChapterGrantIdList, delChapterPermissionMappingIdList)
  733. return
  734. }
  735. // DelChapter
  736. // @Description: 删除报告章节、授权用户权限、品种权限
  737. // @author: Roc
  738. // @datetime 2024-06-06 17:28:37
  739. // @param reportInfo *models.Report
  740. // @param reportChapterInfo *models.ReportChapter
  741. // @param sysUser *system.Admin
  742. // @return err error
  743. // @return errMsg string
  744. func DelChapter(reportInfo *models.Report, reportChapterInfo *models.ReportChapter, sysUser *system.Admin) (err error, errMsg string) {
  745. errMsg = "删除失败"
  746. if reportInfo.State == 2 {
  747. errMsg = "该报告已发布,不允许删除"
  748. err = errors.New(errMsg)
  749. return
  750. }
  751. reportInfo.LastModifyAdminId = sysUser.AdminId
  752. reportInfo.LastModifyAdminName = sysUser.RealName
  753. reportInfo.ModifyTime = time.Now()
  754. updateReportCols := []string{"LastModifyAdminId", "LastModifyAdminName", "ModifyTime"}
  755. err = models.DelChapterAndPermission(reportInfo, updateReportCols, reportChapterInfo)
  756. return
  757. }
  758. // DownloadVoice
  759. // @Description: 下载报告音频文件
  760. // @author: Roc
  761. // @datetime 2024-06-13 15:36:46
  762. // @param reportInfo *models.ReportDetail
  763. // @return savePath string
  764. // @return fileName string
  765. // @return err error
  766. // @return errMsg string
  767. func DownloadVoice(reportInfo *models.ReportDetail) (savePath, fileName string, err error, errMsg string) {
  768. errMsg = `下载失败`
  769. // 如果报告有音频,那么下载音频
  770. if reportInfo.VideoUrl != `` {
  771. savePath = time.Now().Format(utils.FormatDateTimeUnSpace) + utils.GetRandString(5) + ".mp3"
  772. fileName = reportInfo.VideoName + ".mp3"
  773. fileBody, tmpErr := http.Get(reportInfo.VideoUrl)
  774. if tmpErr != nil {
  775. err = tmpErr
  776. errMsg = "音频下载失败"
  777. return
  778. }
  779. err = file.SaveFile(fileBody, savePath)
  780. if err != nil {
  781. errMsg = "音频保存失败"
  782. return
  783. }
  784. }
  785. // 如果是章节报告,那么就下载压缩包
  786. if reportInfo.HasChapter == 1 {
  787. videoList, tmpErr := models.GetReportChapterVideoList(reportInfo.Id)
  788. if tmpErr != nil {
  789. err = tmpErr
  790. errMsg = "获取音频列表失败"
  791. return
  792. }
  793. if len(videoList) > 0 {
  794. // 创建zip
  795. savePath = time.Now().Format(utils.FormatDateTimeUnSpace) + utils.GetRandString(5) + ".zip"
  796. fileName = reportInfo.VideoName + ".zip"
  797. zipFile, tmpErr := os.Create(savePath)
  798. if tmpErr != nil {
  799. err = tmpErr
  800. return
  801. }
  802. zipWriter := zip.NewWriter(zipFile)
  803. // 生成zip过程中报错关闭
  804. defer func() {
  805. if err != nil {
  806. zipWriter.Close()
  807. zipFile.Close()
  808. }
  809. }()
  810. // 获取音频,写入zip
  811. for i := 0; i < len(videoList); i++ {
  812. item := videoList[i]
  813. if item.VideoName == "" || item.VideoUrl == "" {
  814. continue
  815. }
  816. // 音频文件后缀
  817. ext := path.Ext(item.VideoUrl)
  818. ioWriter, tmpErr := zipWriter.Create(fmt.Sprintf("%s%s", item.VideoName, ext))
  819. if tmpErr != nil {
  820. err = tmpErr
  821. if os.IsPermission(err) {
  822. fmt.Println("权限不足: ", err)
  823. return
  824. }
  825. return
  826. }
  827. var content []byte
  828. content, err = http.Get(item.VideoUrl)
  829. if err != nil {
  830. content = []byte("")
  831. }
  832. ioWriter.Write(content)
  833. }
  834. // 生成zip后关闭,否则下载文件会损坏
  835. zipWriter.Close()
  836. zipFile.Close()
  837. }
  838. }
  839. return
  840. }
  841. // CheckReportAuthByAdminIdList
  842. // @Description: 根据管理员id列表,判断当前用户是否有报告权限
  843. // @author: Roc
  844. // @datetime 2024-06-13 11:03:10
  845. // @param adminId int
  846. // @param createAdminId int
  847. // @param grantAdminIdList []int
  848. // @return isAuth bool
  849. func CheckReportAuthByAdminIdList(adminId, createAdminId int, grantAdminIdList []int) (isAuth bool) {
  850. // 如果是自己创建的报告,那么就有权限
  851. if adminId == createAdminId {
  852. isAuth = true
  853. return
  854. }
  855. // 如果是授权用户,那么就有权限
  856. if utils.IsCheckInList(grantAdminIdList, adminId) {
  857. isAuth = true
  858. return
  859. }
  860. return
  861. }
  862. // CheckReportAuthByReportChapterInfo
  863. // @Description: 根据报告ID,判断当前用户是否有报告权限
  864. // @author: Roc
  865. // @datetime 2024-06-13 16:21:28
  866. // @param adminId int
  867. // @param reportInfoId int
  868. // @return isAuth bool
  869. // @return err error
  870. func CheckReportAuthByReportChapterInfo(adminId, createAdminId int, reportInfoId int) (isAuth bool, err error) {
  871. // 如果是自己创建的报告,那么就有权限
  872. if adminId == createAdminId {
  873. isAuth = true
  874. return
  875. }
  876. obj := report.ReportGrant{}
  877. chapterGrantList, err := obj.GetGrantListById(reportInfoId)
  878. if err != nil {
  879. return
  880. }
  881. for _, v := range chapterGrantList {
  882. if v.AdminId == adminId {
  883. isAuth = true
  884. return
  885. }
  886. }
  887. return
  888. }
  889. // EditReportLayoutImg
  890. // @Description: 修改报告的版图信息
  891. // @author: Roc
  892. // @datetime 2024-06-18 11:35:00
  893. // @param reportInfo *models.Report
  894. // @param req models.EditLayoutImgReq
  895. // @param sysUser *system.Admin
  896. // @return err error
  897. // @return errMsg string
  898. func EditReportLayoutImg(reportInfo *models.Report, req models.EditLayoutImgReq, sysUser *system.Admin) (err error, errMsg string) {
  899. errMsg = `保存失败`
  900. reportInfo.HeadResourceId = req.HeadResourceId
  901. reportInfo.HeadImg = req.HeadImg
  902. reportInfo.EndResourceId = req.EndResourceId
  903. reportInfo.EndImg = req.EndImg
  904. reportInfo.CanvasColor = req.CanvasColor
  905. reportInfo.LastModifyAdminId = sysUser.AdminId
  906. reportInfo.LastModifyAdminName = sysUser.RealName
  907. reportInfo.ModifyTime = time.Now()
  908. updateCols := []string{"HeadResourceId", "HeadImg", "EndResourceId", "EndImg", "CanvasColor", "LastModifyAdminId", "LastModifyAdminName", "ModifyTime"}
  909. err = reportInfo.UpdateReport(updateCols)
  910. if err != nil {
  911. return
  912. }
  913. return
  914. }
  915. // PublishReport
  916. // @Description: 报告发布
  917. // @author: Roc
  918. // @datetime 2024-06-20 09:44:13
  919. // @param reportId int
  920. // @param reportUrl string
  921. // @param sysUser *system.Admin
  922. // @return tips string
  923. // @return err error
  924. // @return errMsg string
  925. func PublishReport(reportId int, reportUrl string, sysUser *system.Admin) (tips string, err error, errMsg string) {
  926. errMsg = `报告发布失败`
  927. reportInfo, err := models.GetReportByReportId(reportId)
  928. if err != nil {
  929. errMsg = "获取报告信息失败"
  930. return
  931. }
  932. if reportInfo == nil {
  933. errMsg = "获取报告信息失败"
  934. err = errors.New(errMsg)
  935. return
  936. }
  937. var publishTime time.Time
  938. if reportInfo.MsgIsSend == 1 && reportInfo.PublishTime.IsZero() { //如果报告曾经发布过,并且已经发送过模版消息,则章节的发布时间为报告的发布时间
  939. publishTime = reportInfo.PublishTime
  940. } else {
  941. publishTime = time.Now()
  942. }
  943. var tmpErr error
  944. // 章节类型的报告(原来的晨周报)
  945. if reportInfo.HasChapter == 1 {
  946. tips, tmpErr, errMsg = PublishChapterReport(reportInfo, reportUrl, sysUser)
  947. if tmpErr != nil {
  948. err = errors.New("晨周报发布失败, Err:" + tmpErr.Error() + ", report_id:" + strconv.Itoa(reportId))
  949. }
  950. return
  951. }
  952. // 普通报告
  953. if reportInfo.Content == "" {
  954. errMsg = `报告内容为空,不可发布`
  955. err = errors.New("报告内容为空,不需要生成,report_id:" + strconv.Itoa(reportId))
  956. return
  957. }
  958. // 根据审批开关及审批流判断当前报告状态
  959. state, e := CheckReportCurrState(report_approve.FlowReportTypeChinese, reportInfo.ClassifyIdFirst, reportInfo.ClassifyIdSecond, reportInfo.ClassifyIdThird, models.ReportOperatePublish)
  960. if e != nil {
  961. errMsg = "操作失败"
  962. err = errors.New("校验报告当前状态失败, Err: " + e.Error())
  963. return
  964. }
  965. if state == models.ReportStatePublished {
  966. // 发布报告
  967. if tmpErr = models.PublishReportById(reportId, publishTime, sysUser.AdminId, sysUser.RealName); tmpErr != nil {
  968. err = errors.New("报告发布失败, Err:" + tmpErr.Error() + ", report_id:" + strconv.Itoa(reportId))
  969. return
  970. }
  971. go func() {
  972. // 生成音频
  973. if reportInfo.VideoUrl == "" {
  974. _ = CreateVideo(reportInfo)
  975. }
  976. // 更新报告Es
  977. _ = UpdateReportEs(reportId, 2)
  978. }()
  979. } else {
  980. // 从无审批切换为有审批, 状态重置
  981. if e = models.ResetReportById(reportId, state, sysUser.AdminId, sysUser.RealName); e != nil {
  982. errMsg = "操作失败"
  983. err = fmt.Errorf("重置报告状态失败, Err: %s, ReportId: %d", e.Error(), reportId)
  984. return
  985. }
  986. }
  987. recordItem := &models.ReportStateRecord{
  988. ReportId: reportId,
  989. ReportType: 1,
  990. State: state,
  991. AdminId: sysUser.AdminId,
  992. AdminName: sysUser.AdminName,
  993. CreateTime: time.Now(),
  994. }
  995. go func() {
  996. _, _ = models.AddReportStateRecord(recordItem)
  997. }()
  998. // 生成报告pdf和长图
  999. if reportUrl != "" {
  1000. go Report2pdfAndJpeg(reportUrl, reportId, 1)
  1001. }
  1002. // 报告权限处理
  1003. {
  1004. minClassifyId, _, tmpErr := getMinClassify(reportInfo)
  1005. if tmpErr != nil {
  1006. return
  1007. }
  1008. go handleReportPermission(int64(reportInfo.Id), minClassifyId)
  1009. }
  1010. return
  1011. }
  1012. // PublishChapterReport
  1013. // @Description: 发布章节类型的报告
  1014. // @author: Roc
  1015. // @datetime 2024-06-28 10:38:50
  1016. // @param reportInfo *models.Report
  1017. // @param reportUrl string
  1018. // @return tips string
  1019. // @return err error
  1020. // @return errMsg string
  1021. func PublishChapterReport(reportInfo *models.Report, reportUrl string, sysUser *system.Admin) (tips string, err error, errMsg string) {
  1022. reportId := reportInfo.Id
  1023. if reportInfo.State == 2 {
  1024. return
  1025. }
  1026. // 获取所有章节列表
  1027. chapters, err := models.GetChapterListByReportId(reportId)
  1028. if err != nil {
  1029. return
  1030. }
  1031. chapterLen := len(chapters)
  1032. if chapterLen <= 0 {
  1033. tips = "报告章节为空,不可发布"
  1034. errMsg = tips
  1035. err = errors.New(tips)
  1036. return
  1037. }
  1038. reportChapterIdList := make([]int, 0)
  1039. // 获取报告中的所有章节列表
  1040. chapterList, err := models.GetChapterListByReportId(reportId)
  1041. if err != nil {
  1042. return
  1043. }
  1044. for _, chapter := range chapterList {
  1045. if chapter.PublishState == 1 {
  1046. tips = "还存在未发布的章节"
  1047. errMsg = tips
  1048. err = errors.New(tips)
  1049. return
  1050. }
  1051. reportChapterIdList = append(reportChapterIdList, chapter.ReportChapterId)
  1052. }
  1053. // 根据审批开关及审批流判断当前报告状态
  1054. state, e := CheckReportCurrState(report_approve.FlowReportTypeChinese, reportInfo.ClassifyIdFirst, reportInfo.ClassifyIdSecond, reportInfo.ClassifyIdThird, models.ReportOperatePublish)
  1055. if e != nil {
  1056. //errMsg = "操作失败"
  1057. err = errors.New("校验报告当前状态失败, Err: " + e.Error())
  1058. return
  1059. }
  1060. // 如果状态不是已发布,那么就重置状态
  1061. if state != models.ReportStatePublished {
  1062. // 从无审批切换为有审批, 状态重置
  1063. if e = models.ResetReportById(reportId, state, sysUser.AdminId, sysUser.RealName); e != nil {
  1064. //errMsg = "操作失败"
  1065. err = fmt.Errorf("重置报告状态失败, Err: %s, ReportId: %d", e.Error(), reportId)
  1066. return
  1067. }
  1068. return
  1069. }
  1070. // 需发布整期
  1071. updateCols := make([]string, 0)
  1072. reportInfo.LastModifyAdminId = sysUser.AdminId
  1073. reportInfo.LastModifyAdminName = sysUser.RealName
  1074. updateCols = append(updateCols, "LastModifyAdminId", "LastModifyAdminName", "Title", "State", "ModifyTime")
  1075. // 发布后标题调整
  1076. //title := reportInfo.Title
  1077. //title = strings.ReplaceAll(title, "【弘则FICC晨报】", "")
  1078. //title = strings.ReplaceAll(title, "【弘则FICC周报】", "")
  1079. //if title == "" {
  1080. // // 取第一个需发布章节的标题
  1081. // firstId := publishIdArr[0]
  1082. // firstTitle := ""
  1083. // for i := 0; i < chapterLen; i++ {
  1084. // if chapters[i].ReportChapterId == firstId {
  1085. // firstTitle = chapters[i].Title
  1086. // break
  1087. // }
  1088. // }
  1089. // title = firstTitle
  1090. //}
  1091. //report.Title = title
  1092. reportInfo.State = state
  1093. // 研报后台4.4 只在没有发布过时更新发布时间,其余均按模版消息发送时间当作发布时间
  1094. if reportInfo.MsgIsSend == 0 || reportInfo.PublishTime.IsZero() {
  1095. reportInfo.PublishTime = time.Now().Local()
  1096. updateCols = append(updateCols, "PublishTime")
  1097. }
  1098. reportInfo.ModifyTime = time.Now().Local()
  1099. if e := models.PublishReportAndChapter(reportInfo, true, updateCols); e != nil {
  1100. err = errors.New("发布报告及章节失败")
  1101. return
  1102. }
  1103. // 生成章节音频
  1104. if len(reportChapterIdList) > 0 {
  1105. go func() {
  1106. _ = UpdateChaptersVideo(reportChapterIdList)
  1107. }()
  1108. }
  1109. // 更新报告ES
  1110. go func() {
  1111. _ = UpdateReportEs(reportInfo.Id, 2)
  1112. }()
  1113. // 发布时备份内容
  1114. go SaveReportLogs(reportInfo, chapters, reportInfo.AdminId, reportInfo.AdminRealName)
  1115. // 生成报告pdf和长图
  1116. if reportUrl != "" {
  1117. go Report2pdfAndJpeg(reportUrl, reportId, 1)
  1118. }
  1119. return
  1120. }
  1121. // getMinClassify
  1122. // @Description: 获取最小分类ID
  1123. // @author: Roc
  1124. // @datetime 2024-06-20 09:23:19
  1125. // @param reportInfo *models.Report
  1126. // @return minClassifyId int
  1127. // @return minClassifyName string
  1128. // @return err error
  1129. func getMinClassify(reportInfo *models.Report) (minClassifyId int, minClassifyName string, err error) {
  1130. defer func() {
  1131. if err != nil {
  1132. utils.FileLog.Error("获取最小分类ID失败,报告ID:%d,Err:%s", reportInfo.Id, err.Error())
  1133. }
  1134. }()
  1135. minClassifyId = reportInfo.ClassifyIdThird
  1136. minClassifyName = reportInfo.ClassifyNameThird
  1137. if minClassifyId <= 0 {
  1138. minClassifyId = reportInfo.ClassifyIdSecond
  1139. minClassifyName = reportInfo.ClassifyNameSecond
  1140. }
  1141. if minClassifyId <= 0 {
  1142. minClassifyId = reportInfo.ClassifyIdFirst
  1143. minClassifyName = reportInfo.ClassifyNameFirst
  1144. }
  1145. if minClassifyId <= 0 {
  1146. err = errors.New("分类异常")
  1147. }
  1148. return
  1149. }
  1150. // handleReportPermission
  1151. // @Description: 报告权限处理
  1152. // @author: Roc
  1153. // @datetime 2024-06-19 18:00:51
  1154. // @param reportId int64
  1155. // @param minClassifyId int
  1156. func handleReportPermission(reportId int64, minClassifyId int) {
  1157. // TODO 报告权限处理
  1158. var err error
  1159. defer func() {
  1160. if err != nil {
  1161. utils.FileLog.Error("报告权限处理失败,报告ID:%d,分类ID:%d,Err:%s", reportId, minClassifyId, err.Error())
  1162. //alarm_msg.SendAlarmMsg("修改删除报告权限失败,Err:"+err.Error(), 3)
  1163. }
  1164. }()
  1165. err = models.RemoveChartPermissionChapterMapping(reportId)
  1166. if err != nil {
  1167. err = errors.New("修改删除报告权限失败,Err:" + err.Error())
  1168. return
  1169. }
  1170. permissionItems, err := models.GetPermission(minClassifyId)
  1171. if err != nil {
  1172. err = errors.New("获取权限失败,Err:" + err.Error())
  1173. return
  1174. }
  1175. for _, v := range permissionItems {
  1176. err = models.AddChartPermissionChapterMapping(v.ChartPermissionId, reportId)
  1177. if err != nil {
  1178. err = errors.New("新增权限失败,Err:" + err.Error())
  1179. return
  1180. }
  1181. }
  1182. // 同步crm权限
  1183. _ = EditReportPermissionSync(reportId, minClassifyId)
  1184. return
  1185. }
  1186. // HandleReportPermission
  1187. // @Description: 报告权限处理
  1188. // @author: Roc
  1189. // @datetime 2024-07-12 11:17:49
  1190. // @param reportInfo *models.Report
  1191. func HandleReportPermission(reportInfo *models.Report) {
  1192. minClassifyId, _, tmpErr := getMinClassify(reportInfo)
  1193. if tmpErr != nil {
  1194. return
  1195. }
  1196. handleReportPermission(int64(reportInfo.Id), minClassifyId)
  1197. }
  1198. // UpdateReportVideo
  1199. // @Description: 更新报告音频
  1200. // @author: Roc
  1201. // @datetime 2024-07-17 18:11:10
  1202. // @param reportInfo *models.Report
  1203. func UpdateReportVideo(reportInfo *models.Report) {
  1204. if reportInfo.HasChapter == 1 {
  1205. reportChapterIdList := make([]int, 0)
  1206. // 获取报告中的所有章节列表
  1207. chapterList, err := models.GetChapterListByReportId(reportInfo.Id)
  1208. if err != nil {
  1209. return
  1210. }
  1211. for _, chapter := range chapterList {
  1212. if chapter.PublishState == 2 {
  1213. reportChapterIdList = append(reportChapterIdList, chapter.ReportChapterId)
  1214. }
  1215. }
  1216. if len(reportChapterIdList) > 0 {
  1217. err = UpdateChaptersVideo(reportChapterIdList)
  1218. if err != nil {
  1219. utils.FileLog.Info(fmt.Sprintf("%d报告音频生产失败:%s", reportInfo.Id, err.Error()))
  1220. }
  1221. }
  1222. } else {
  1223. err := CreateVideo(reportInfo)
  1224. if err != nil {
  1225. utils.FileLog.Info(fmt.Sprintf("%d报告音频生产失败:%s", reportInfo.Id, err.Error()))
  1226. }
  1227. }
  1228. }
  1229. func GeneralPdfUrl(reportCode string, adminInfo *system.Admin) {
  1230. }