12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252 |
- package services
- import (
- "archive/zip"
- "encoding/json"
- "errors"
- "eta/eta_api/models"
- "eta/eta_api/models/company"
- "eta/eta_api/models/data_manage/excel"
- "eta/eta_api/models/report"
- "eta/eta_api/models/report_approve"
- "eta/eta_api/models/system"
- "eta/eta_api/models/yb"
- "eta/eta_api/services/alarm_msg"
- "eta/eta_api/utils"
- "fmt"
- "github.com/rdlucklib/rdluck_tools/file"
- "github.com/rdlucklib/rdluck_tools/http"
- html2 "golang.org/x/net/html"
- "html"
- "net/url"
- "os"
- "path"
- "strconv"
- "strings"
- "time"
- "github.com/beego/beego/v2/server/web"
- "github.com/beego/beego/v2/server/web/context"
- "github.com/go-redis/redis/v8"
- )
- func AddReportAndChapter(reportInfo *models.Report, inheritReportId int, grantAdminIdList []int, reportDate time.Time) (err error, errMsg string) {
-
- state, e := CheckReportCurrState(report_approve.FlowReportTypeChinese, reportInfo.ClassifyIdFirst, reportInfo.ClassifyIdSecond, reportInfo.ClassifyIdThird, models.ReportOperateAdd)
- if e != nil {
-
- err = errors.New("校验报告当前状态失败, Err: " + e.Error())
- return
- }
-
- reportInfo.State = state
-
- minClassifyId := reportInfo.ClassifyIdThird
- if minClassifyId <= 0 {
- minClassifyId = reportInfo.ClassifyIdSecond
- }
- if minClassifyId <= 0 {
- minClassifyId = reportInfo.ClassifyIdFirst
- }
- if minClassifyId <= 0 {
- errMsg = "分类异常"
- err = errors.New(errMsg)
- return
- }
- errMsg = "生成报告失败"
-
- if inheritReportId > 0 {
- inheritReport, tmpErr := models.GetReportByReportId(inheritReportId)
- if tmpErr != nil && tmpErr.Error() != utils.ErrNoRow() {
- errMsg = "获取待继承的报告失败"
- err = tmpErr
- return
- }
- if inheritReport != nil {
-
- if inheritReport.ClassifyIdFirst != reportInfo.ClassifyIdFirst || inheritReport.ClassifyIdSecond != reportInfo.ClassifyIdSecond || inheritReport.ClassifyIdThird != reportInfo.ClassifyIdThird {
- errMsg = "分类异常,与继承的报告分类不一致"
- err = errors.New(errMsg)
- return
- }
- reportInfo.ChapterType = inheritReport.ChapterType
- reportInfo.Content = inheritReport.Content
- reportInfo.ContentSub = inheritReport.ContentSub
- reportInfo.ContentStruct = inheritReport.ContentStruct
- reportInfo.CanvasColor = inheritReport.CanvasColor
-
- reportInfo.NeedSplice = 1
- reportInfo.HeadResourceId = inheritReport.HeadResourceId
-
-
- reportInfo.HeadImg = ``
- reportInfo.EndImg = ``
- reportInfo.EndResourceId = inheritReport.EndResourceId
- if inheritReport.HeadResourceId > 0 {
- reportInfo.HeadImg = inheritReport.HeadImg
- }
- if inheritReport.EndResourceId > 0 {
- reportInfo.EndImg = inheritReport.EndImg
- }
- reportInfo.InheritReportId = inheritReport.Id
- }
- }
-
- addChapterList, allGrantUserList, err, errMsg := getAddChapter(reportInfo, minClassifyId, inheritReportId, grantAdminIdList, reportDate)
-
- var reportId int64
- reportId, err = models.AddReportAndChapter(reportInfo, allGrantUserList, addChapterList)
- if err != nil {
- err = errors.New("新增报告及章节失败, Err: " + err.Error())
- return
- }
- reportCode := utils.MD5(strconv.Itoa(reportInfo.Id))
- reportInfo.ReportCode = reportCode
-
- {
- go models.ModifyReportCode(reportId, reportCode)
- }
-
- if reportInfo.InheritReportId > 0 {
- handlerReportTableReferenced(reportInfo)
- }
-
- go handleReportPermission(reportId, minClassifyId)
- return
- }
- func EditReport(reportInfo *models.Report, req models.EditReq, sysUser *system.Admin) (err error, errMsg string) {
- errMsg = `保存失败`
- oldIsPublicPublish := reportInfo.IsPublicPublish
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- reportInfo.Title = req.Title
- reportInfo.Abstract = req.Abstract
- reportInfo.Author = req.Author
- reportInfo.Frequency = req.Frequency
-
-
-
-
- reportInfo.CreateTime = req.CreateTime
-
-
- if req.IsPublicPublish <= 0 {
- req.IsPublicPublish = 1
- }
- reportInfo.IsPublicPublish = req.IsPublicPublish
- reportInfo.LastModifyAdminId = sysUser.AdminId
- reportInfo.LastModifyAdminName = sysUser.RealName
- reportInfo.ModifyTime = time.Now()
- state, e := CheckReportCurrState(report_approve.FlowReportTypeChinese, reportInfo.ClassifyIdFirst, reportInfo.ClassifyIdSecond, reportInfo.ClassifyIdThird, models.ReportOperateEdit)
- if e != nil {
-
- err = errors.New("校验报告当前状态失败, Err: " + e.Error())
- return
- }
-
- reportInfo.State = state
-
- updateCols := []string{"Title", "Abstract", "Author", "Frequency", "CreateTime", "IsPublicPublish", "LastModifyAdminId", "LastModifyAdminName", "ModifyTime", "State"}
- if req.HeadResourceId > 0 {
- reportInfo.HeadResourceId = req.HeadResourceId
- updateCols = append(updateCols, "HeadResourceId")
- }
- if req.EndResourceId > 0 {
- reportInfo.EndResourceId = req.EndResourceId
- updateCols = append(updateCols, "EndResourceId")
- }
-
- addReportAdminList := make([]*report.ReportGrant, 0)
-
- delReportGrantIdList := make([]int, 0)
-
- {
- reportGrantObj := report.ReportGrant{}
-
- reportGrantList, tmpErr := reportGrantObj.GetGrantListById(reportInfo.Id)
- if tmpErr != nil {
- err = tmpErr
- return
- }
-
- currReportAdminMap := make(map[int]*report.ReportGrant)
-
- delReportAdminMap := make(map[int]*report.ReportGrant)
- for _, v := range reportGrantList {
- currReportAdminMap[v.AdminId] = v
- delReportAdminMap[v.AdminId] = v
- }
-
- for _, tmpAdminId := range req.GrantAdminIdList {
- _, ok := currReportAdminMap[tmpAdminId]
-
- if ok {
- delete(delReportAdminMap, tmpAdminId)
- continue
- }
-
- addReportAdminList = append(addReportAdminList, &report.ReportGrant{
-
- ReportId: reportInfo.Id,
- AdminId: tmpAdminId,
- CreateTime: time.Now(),
- })
- }
-
- for _, v := range delReportAdminMap {
- delReportGrantIdList = append(delReportGrantIdList, v.GrantId)
- }
- }
-
- err = models.EditReportAndPermission(reportInfo, updateCols, addReportAdminList, delReportGrantIdList)
- if err != nil {
- return
- }
-
- {
- minClassifyId, _, tmpErr := getMinClassify(reportInfo)
- if tmpErr != nil {
- return
- }
- go handleReportPermission(int64(reportInfo.Id), minClassifyId)
- }
-
- if oldIsPublicPublish != reportInfo.IsPublicPublish {
- if reportInfo.HasChapter == 1 {
-
- chapterList, tmpErr := models.GetPublishedChapterListByReportId(reportInfo.Id)
- if tmpErr != nil {
- return
- }
- if len(chapterList) > 0 {
-
- for _, chapterInfo := range chapterList {
- err = updateReportChapterEsByChapter(chapterInfo, reportInfo.IsPublicPublish)
- if err != nil {
- return
- }
- }
- }
- }
- }
- return
- }
- func getAddChapter(reportInfo *models.Report, minClassifyId, inheritReportId int, grantAdminIdList []int, reportDate time.Time) (chapterList []models.AddReportChapter, allGrantUserList []*report.ReportGrant, err error, errMsg string) {
-
- chapterList = make([]models.AddReportChapter, 0)
-
- allGrantUserList = make([]*report.ReportGrant, 0)
-
- needAdminIdMap := make(map[int]bool)
- for _, adminId := range grantAdminIdList {
- needAdminIdMap[adminId] = true
- allGrantUserList = append(allGrantUserList, &report.ReportGrant{
-
-
- AdminId: adminId,
- CreateTime: time.Now(),
- })
- }
- if reportInfo.HasChapter != 1 {
- return
- }
-
- var minClassifyName string
- if reportInfo.ClassifyIdThird == minClassifyId {
- minClassifyName = reportInfo.ClassifyNameThird
- } else if reportInfo.ClassifyIdSecond == minClassifyId {
- minClassifyName = reportInfo.ClassifyNameSecond
- } else {
- minClassifyName = reportInfo.ClassifyNameFirst
- }
- errMsg = "生成报告章节失败"
-
- allTypeList, err := models.GetReportChapterTypeListByClassifyId(minClassifyId)
- if err != nil {
- err = errors.New(errMsg)
- return
- }
-
- chapterTypeList := make([]*models.ReportChapterType, 0)
-
- chapterTypeIdList := make([]int, 0)
-
- for _, chapterType := range allTypeList {
-
- if chapterType.Enabled == 0 {
- continue
- }
- if chapterType.PauseStartTime != "" && chapterType.PauseEndTime != "" && chapterType.PauseStartTime != utils.EmptyDateStr && chapterType.PauseEndTime != utils.EmptyDateStr {
- startTime, timeErr := time.ParseInLocation(utils.FormatDate, chapterType.PauseStartTime, time.Local)
- if timeErr != nil {
- utils.FileLog.Error("更新规则时间转换失败4001, Err: " + timeErr.Error())
- continue
- }
- endTime, timeErr := time.ParseInLocation(utils.FormatDate, chapterType.PauseEndTime, time.Local)
- if timeErr != nil {
- utils.FileLog.Error("更新规则时间转换失败4002, Err: " + timeErr.Error())
- continue
- }
-
- if !reportDate.Before(startTime) && !reportDate.After(endTime) {
- continue
- }
- }
-
- chapterTypeList = append(chapterTypeList, chapterType)
- chapterTypeIdList = append(chapterTypeIdList, chapterType.ReportChapterTypeId)
- }
-
- oldChapterIdGrantListMap := make(map[int][]*report.ReportChapterGrant)
-
- oldChapterPermissionListMap := make(map[int][]*report.ReportChapterPermissionMapping)
-
- customAddChapterList := make([]models.AddReportChapter, 0)
-
- inheritChapterMap := make(map[int]*models.ReportChapter)
-
- currChapterTypePermissionListMap := make(map[int][]*report.ReportChapterPermissionMapping)
- if len(chapterTypeIdList) > 0 {
- mappingList, e := models.GetChapterTypePermissionByChapterTypeIdList(chapterTypeIdList)
- if e != nil {
- err = fmt.Errorf("获取章节类型权限列表失败, Err: " + e.Error())
- return
- }
- hasPermissionMap := make(map[string]bool)
- for _, v := range mappingList {
- tmpChapterTypePermissionList, ok := currChapterTypePermissionListMap[v.ReportChapterTypeId]
- if !ok {
- tmpChapterTypePermissionList = make([]*report.ReportChapterPermissionMapping, 0)
- }
- key := fmt.Sprint(v.ReportChapterTypeId, "-", v.ChartPermissionId)
- if _, has := hasPermissionMap[key]; !has {
- hasPermissionMap[key] = true
- currChapterTypePermissionListMap[v.ReportChapterTypeId] = append(tmpChapterTypePermissionList, &report.ReportChapterPermissionMapping{
- ReportChapterPermissionMappingId: 0,
- ReportChapterId: 0,
- ChartPermissionId: v.ChartPermissionId,
- CreateTime: time.Now(),
- })
- }
- }
- }
- if inheritReportId > 0 {
-
- inheritReportChapters, tmpErr := models.GetChapterListByReportId(inheritReportId)
- if tmpErr != nil {
- errMsg = "获取待继承的报告章节失败"
- err = tmpErr
- return
- }
- reportChaptersIdList := make([]int, 0)
- for _, v := range inheritReportChapters {
- reportChaptersIdList = append(reportChaptersIdList, v.ReportChapterId)
- }
-
- grantListMap := make(map[int][]*report.ReportChapterGrant)
-
- chapterPermissionListMap := make(map[int][]*report.ReportChapterPermissionMapping)
-
- if len(reportChaptersIdList) > 0 {
-
- obj := report.ReportChapterGrant{}
- grantList, tmpErr := obj.GetGrantListByIdList(reportChaptersIdList)
- if tmpErr != nil {
- errMsg = "获取待继承的报告章节的授权用户列表失败"
- err = tmpErr
- return
- }
- for _, v := range grantList {
-
- if _, ok := needAdminIdMap[v.AdminId]; !ok {
- continue
- }
- currReportChapterId := v.ReportChapterId
- tmpGrantList, ok := grantListMap[currReportChapterId]
- if !ok {
- tmpGrantList = make([]*report.ReportChapterGrant, 0)
- }
- v.ReportChapterId = 0
- v.GrantId = 0
- tmpGrantList = append(tmpGrantList, v)
- grantListMap[currReportChapterId] = tmpGrantList
- }
-
- permissionObj := report.ReportChapterPermissionMapping{}
- permissionList, tmpErr := permissionObj.GetPermissionListByIdList(reportChaptersIdList)
- if tmpErr != nil {
- errMsg = "获取待继承的报告章节的授权用户列表失败"
- err = tmpErr
- return
- }
- for _, v := range permissionList {
- currReportChapterId := v.ReportChapterId
- tmpPermissionList, ok := chapterPermissionListMap[currReportChapterId]
- if !ok {
- tmpPermissionList = make([]*report.ReportChapterPermissionMapping, 0)
- }
- v.ReportChapterId = 0
- v.ReportChapterPermissionMappingId = 0
- tmpPermissionList = append(tmpPermissionList, v)
- chapterPermissionListMap[currReportChapterId] = tmpPermissionList
- }
- }
-
- for i := 0; i < len(inheritReportChapters); i++ {
- customChapter := inheritReportChapters[i]
-
- tmpGrantList, ok := grantListMap[customChapter.ReportChapterId]
- if !ok {
- tmpGrantList = make([]*report.ReportChapterGrant, 0)
- }
- oldChapterIdGrantListMap[customChapter.ReportChapterId] = tmpGrantList
-
- chapterPermissionList, ok := chapterPermissionListMap[customChapter.ReportChapterId]
- if !ok {
- chapterPermissionList = make([]*report.ReportChapterPermissionMapping, 0)
- }
- oldChapterPermissionListMap[customChapter.ReportChapterId] = chapterPermissionList
-
- if customChapter.TypeId > 0 {
- inheritChapterMap[customChapter.TypeId] = customChapter
- continue
- }
-
- customChapter.ReportId = reportInfo.Id
- customChapter.ReportChapterId = 0
- customChapter.ClassifyIdFirst = minClassifyId
- customChapter.ClassifyNameFirst = minClassifyName
- customChapter.Stage = reportInfo.Stage
- customChapter.PublishState = 1
- customChapter.CreateTime = reportInfo.CreateTime
- customChapter.ModifyTime = time.Now()
- customChapter.LastModifyAdminId = reportInfo.LastModifyAdminId
- customChapter.LastModifyAdminName = reportInfo.LastModifyAdminName
- customChapter.ContentModifyTime = time.Now()
- customAddChapter := models.AddReportChapter{
- ReportChapter: customChapter,
- GrantList: tmpGrantList,
- GrantPermissionList: chapterPermissionList,
- }
- customAddChapterList = append(customAddChapterList, customAddChapter)
- }
- }
-
- var maxSort int
- for _, typeItem := range chapterTypeList {
- v, ok := inheritChapterMap[typeItem.ReportChapterTypeId]
-
- var tmpGrantList []*report.ReportChapterGrant
-
- var tmpChapterPermissionList []*report.ReportChapterPermissionMapping
- chapterItem := new(models.ReportChapter)
- if ok && v != nil {
-
- chapterItem.AddType = 2
- chapterItem.Title = v.Title
- chapterItem.ReportType = v.ReportType
- chapterItem.ClassifyIdFirst = minClassifyId
- chapterItem.ClassifyNameFirst = minClassifyName
- chapterItem.TypeId = typeItem.ReportChapterTypeId
- chapterItem.TypeName = typeItem.ReportChapterTypeName
- chapterItem.Content = v.Content
- chapterItem.ContentSub = v.ContentSub
- chapterItem.Stage = reportInfo.Stage
- chapterItem.PublishState = 1
- chapterItem.Sort = typeItem.Sort
- chapterItem.CreateTime = reportInfo.CreateTime
- chapterItem.ModifyTime = time.Now()
- chapterItem.LastModifyAdminId = reportInfo.LastModifyAdminId
- chapterItem.LastModifyAdminName = reportInfo.LastModifyAdminName
- chapterItem.ContentModifyTime = time.Now()
- chapterItem.ContentStruct = v.ContentStruct
- chapterItem.ReportLayout = v.ReportLayout
- chapterItem.ReportCreateTime = time.Now()
-
- tmpGrantList, ok = oldChapterIdGrantListMap[v.ReportChapterId]
- if !ok {
- tmpGrantList = make([]*report.ReportChapterGrant, 0)
- }
-
- tmpChapterPermissionList, ok = oldChapterPermissionListMap[v.ReportChapterId]
- if !ok {
- tmpChapterPermissionList = make([]*report.ReportChapterPermissionMapping, 0)
- }
- } else {
-
- var findChapter bool
- if inheritReportId > 0 {
- chapterNewest, e := models.GetNewestPreReportChapterByClassifyIdAndTypeId(minClassifyId, typeItem.ReportChapterTypeId)
- if e != nil && e.Error() == utils.ErrNoRow() {
- errMsg = "继承最新内容的章节失败"
- err = fmt.Errorf("获取最新内容的章节失败, %v", e)
- return
- }
- if chapterNewest != nil {
- chapterItem.AddType = 2
- chapterItem.Title = chapterNewest.Title
- chapterItem.ReportType = chapterNewest.ReportType
- chapterItem.ClassifyIdFirst = minClassifyId
- chapterItem.ClassifyNameFirst = minClassifyName
- chapterItem.TypeId = typeItem.ReportChapterTypeId
- chapterItem.TypeName = typeItem.ReportChapterTypeName
- chapterItem.Content = chapterNewest.Content
- chapterItem.ContentSub = chapterNewest.ContentSub
- chapterItem.Stage = reportInfo.Stage
- chapterItem.PublishState = 1
- chapterItem.Sort = typeItem.Sort
- chapterItem.CreateTime = reportInfo.CreateTime
- chapterItem.ModifyTime = time.Now()
- chapterItem.LastModifyAdminId = reportInfo.LastModifyAdminId
- chapterItem.LastModifyAdminName = reportInfo.LastModifyAdminName
- chapterItem.ContentModifyTime = time.Now()
- chapterItem.ContentStruct = chapterNewest.ContentStruct
- chapterItem.ReportLayout = chapterNewest.ReportLayout
- chapterItem.ReportCreateTime = time.Now()
-
- tmpGrantList = make([]*report.ReportChapterGrant, 0)
- tmpChapterPermissionList = make([]*report.ReportChapterPermissionMapping, 0)
- {
- grantOb := report.ReportChapterGrant{}
- chapterGrant, e := grantOb.GetGrantListById(chapterNewest.ReportChapterId)
- if e != nil {
- errMsg = "获取待继承的报告章节的授权用户列表失败"
- err = fmt.Errorf("获取待继承的报告章节的授权用户列表失败, ChapterId: %d, Err: %v", chapterNewest.ReportChapterId, e)
- return
- }
- for _, cg := range chapterGrant {
-
- if _, ok := needAdminIdMap[cg.AdminId]; !ok {
- continue
- }
- cg.ReportChapterId = 0
- cg.GrantId = 0
- tmpGrantList = append(tmpGrantList, cg)
- }
- permissionOb := report.ReportChapterPermissionMapping{}
- permissions, e := permissionOb.GetPermissionListById(chapterNewest.ReportChapterId)
- if e != nil {
- errMsg = "获取待继承的报告章节的品种权限失败"
- err = fmt.Errorf("获取待继承的报告章节的品种权限失败, ChapterId: %d, Err: %v", chapterNewest.ReportChapterId, e)
- return
- }
- for _, ps := range permissions {
- ps.ReportChapterId = 0
- ps.ReportChapterPermissionMappingId = 0
- tmpChapterPermissionList = append(tmpChapterPermissionList, ps)
- }
- }
- findChapter = true
- }
- }
-
- if !findChapter {
- chapterItem.AddType = 1
- chapterItem.Title = typeItem.ReportChapterTypeName
- chapterItem.ReportType = typeItem.ResearchType
- chapterItem.ClassifyIdFirst = minClassifyId
- chapterItem.ClassifyNameFirst = minClassifyName
- chapterItem.TypeId = typeItem.ReportChapterTypeId
- chapterItem.TypeName = typeItem.ReportChapterTypeName
- chapterItem.Stage = reportInfo.Stage
- chapterItem.PublishState = 1
- chapterItem.Sort = typeItem.Sort
- chapterItem.CreateTime = reportInfo.CreateTime
- chapterItem.ModifyTime = time.Now()
- chapterItem.LastModifyAdminId = reportInfo.LastModifyAdminId
- chapterItem.LastModifyAdminName = reportInfo.LastModifyAdminName
- chapterItem.ContentModifyTime = time.Now()
-
- chapterItem.ReportLayout = reportInfo.ReportLayout
- chapterItem.ReportCreateTime = time.Now()
-
- tmpChapterPermissionList, ok = currChapterTypePermissionListMap[typeItem.ReportChapterTypeId]
- if !ok {
- tmpChapterPermissionList = make([]*report.ReportChapterPermissionMapping, 0)
- }
- }
- }
- if typeItem.Sort > maxSort {
- maxSort = typeItem.Sort
- }
- addChapter := models.AddReportChapter{
- ReportChapter: chapterItem,
- GrantList: tmpGrantList,
- GrantPermissionList: tmpChapterPermissionList,
- }
- chapterList = append(chapterList, addChapter)
- }
-
- for _, addChapterItem := range customAddChapterList {
- maxSort++
- addChapterItem.ReportChapter.Sort = maxSort
- chapterList = append(chapterList, addChapterItem)
- }
-
-
-
-
-
-
-
-
-
-
-
-
-
- return
- }
- func AddChapterBaseInfoAndPermission(reportInfo *models.Report, reportChapterInfo *models.ReportChapter, permissionIdList []int, adminIdList []int) (err error, errMsg string) {
- errMsg = "新增失败"
- if reportInfo.State == 2 {
- errMsg = "该报告已发布,不允许编辑"
- err = errors.New(errMsg)
- return
- }
-
- addChapterAdminList := make([]*report.ReportChapterGrant, 0)
- for _, adminId := range adminIdList {
-
- addChapterAdminList = append(addChapterAdminList, &report.ReportChapterGrant{
-
-
- AdminId: adminId,
- CreateTime: time.Now(),
- })
- }
-
- addChapterPermissionList := make([]*report.ReportChapterPermissionMapping, 0)
-
- for _, permissionId := range permissionIdList {
-
- addChapterPermissionList = append(addChapterPermissionList, &report.ReportChapterPermissionMapping{
-
-
- ChartPermissionId: permissionId,
- CreateTime: time.Now(),
- })
- }
- err = models.AddChapterBaseInfoAndPermission(reportChapterInfo, addChapterAdminList, addChapterPermissionList)
- return
- }
- func EditChapterBaseInfoAndPermission(reportInfo *models.Report, reportChapterInfo *models.ReportChapter, title string, permissionIdList []int, adminIdList []int) (err error, errMsg string) {
- errMsg = "修改失败"
- if reportInfo.State == 2 {
- errMsg = "该报告已发布,不允许编辑"
- err = errors.New(errMsg)
- return
- }
- updateCols := make([]string, 0)
-
- if title != `` {
- reportChapterInfo.Title = title
- reportChapterInfo.ModifyTime = time.Now()
- updateCols = append(updateCols, "Title", "ModifyTime")
- reportChapterInfo.UpdateChapter(updateCols)
- }
- reportGrantObj := report.ReportGrant{}
- chapterGrantObj := report.ReportChapterGrant{}
- chapterPermissionObj := report.ReportChapterPermissionMapping{}
-
- reportGrantAdminIdMap := make(map[int]bool)
-
- {
-
- reportGrantList, tmpErr := reportGrantObj.GetGrantListById(reportInfo.Id)
- if tmpErr != nil {
- err = tmpErr
- return
- }
- for _, v := range reportGrantList {
- reportGrantAdminIdMap[v.AdminId] = true
- }
- }
-
- addChapterAdminList := make([]*report.ReportChapterGrant, 0)
-
- delReportChapterGrantIdList := make([]int, 0)
-
- {
-
- chapterGrantList, tmpErr := chapterGrantObj.GetGrantListById(reportChapterInfo.ReportChapterId)
- if tmpErr != nil {
- err = tmpErr
- return
- }
-
- currChapterAdminMap := make(map[int]*report.ReportChapterGrant)
-
- delChapterAdminMap := make(map[int]*report.ReportChapterGrant)
- for _, v := range chapterGrantList {
- currChapterAdminMap[v.AdminId] = v
- delChapterAdminMap[v.AdminId] = v
- }
- for _, adminId := range adminIdList {
-
- if _, ok := reportGrantAdminIdMap[adminId]; !ok {
- continue
- }
- _, ok := currChapterAdminMap[adminId]
-
- if ok {
- delete(delChapterAdminMap, adminId)
- continue
- }
-
- addChapterAdminList = append(addChapterAdminList, &report.ReportChapterGrant{
-
- ReportChapterId: reportChapterInfo.ReportChapterId,
- AdminId: adminId,
- CreateTime: time.Now(),
- })
- }
-
- for _, v := range delChapterAdminMap {
- delReportChapterGrantIdList = append(delReportChapterGrantIdList, v.GrantId)
- }
- }
-
- otherChapterAdminMap := make(map[int]bool)
- {
-
- reportChapterIdList, tmpErr := models.GetReportChapterIdList(reportInfo.Id)
- if tmpErr != nil {
- err = tmpErr
- return
- }
- if len(reportChapterIdList) > 0 {
- list, tmpErr := chapterGrantObj.GetGrantListByIdList(reportChapterIdList)
- if tmpErr != nil {
- err = tmpErr
- return
- }
- for _, v := range list {
-
- if v.ReportChapterId == reportChapterInfo.ReportChapterId {
- continue
- }
- otherChapterAdminMap[v.AdminId] = true
- }
- }
- }
-
- addChapterPermissionList := make([]*report.ReportChapterPermissionMapping, 0)
-
- delChapterPermissionMappingIdList := make([]int, 0)
-
- {
-
- chapterPermissionList, tmpErr := chapterPermissionObj.GetPermissionListById(reportChapterInfo.ReportChapterId)
- if tmpErr != nil {
- err = tmpErr
- return
- }
-
- currChapterPermissionMap := make(map[int]*report.ReportChapterPermissionMapping)
-
- delChapterPermissionMap := make(map[int]*report.ReportChapterPermissionMapping)
- for _, v := range chapterPermissionList {
- currChapterPermissionMap[v.ChartPermissionId] = v
- delChapterPermissionMap[v.ChartPermissionId] = v
- }
- for _, permissionId := range permissionIdList {
- _, ok := currChapterPermissionMap[permissionId]
-
- if ok {
- delete(delChapterPermissionMap, permissionId)
- continue
- }
-
- addChapterPermissionList = append(addChapterPermissionList, &report.ReportChapterPermissionMapping{
-
- ReportChapterId: reportChapterInfo.ReportChapterId,
- ChartPermissionId: permissionId,
- CreateTime: time.Now(),
- })
- }
-
- for _, v := range delChapterPermissionMap {
- delChapterPermissionMappingIdList = append(delChapterPermissionMappingIdList, v.ReportChapterPermissionMappingId)
- }
- }
- err = models.EditChapterBaseInfoAndPermission(reportInfo, reportChapterInfo, updateCols, addChapterAdminList, addChapterPermissionList, delReportChapterGrantIdList, delChapterPermissionMappingIdList)
- return
- }
- func DelChapter(reportInfo *models.Report, reportChapterInfo *models.ReportChapter, sysUser *system.Admin) (err error, errMsg string) {
- errMsg = "删除失败"
- if reportInfo.State == 2 {
- errMsg = "该报告已发布,不允许删除"
- err = errors.New(errMsg)
- return
- }
- reportInfo.LastModifyAdminId = sysUser.AdminId
- reportInfo.LastModifyAdminName = sysUser.RealName
- reportInfo.ModifyTime = time.Now()
- updateReportCols := []string{"LastModifyAdminId", "LastModifyAdminName", "ModifyTime"}
- err = models.DelChapterAndPermission(reportInfo, updateReportCols, reportChapterInfo)
- return
- }
- func DownloadVoice(reportInfo *models.ReportDetail) (savePath, fileName string, err error, errMsg string) {
- errMsg = `下载失败`
-
- if reportInfo.VideoUrl != `` {
- savePath = time.Now().Format(utils.FormatDateTimeUnSpace) + utils.GetRandString(5) + ".mp3"
- fileName = reportInfo.VideoName + ".mp3"
- fileBody, tmpErr := http.Get(reportInfo.VideoUrl)
- if tmpErr != nil {
- err = tmpErr
- errMsg = "音频下载失败"
- return
- }
- err = file.SaveFile(fileBody, savePath)
- if err != nil {
- errMsg = "音频保存失败"
- return
- }
- }
-
- if reportInfo.HasChapter == 1 {
- videoList, tmpErr := models.GetReportChapterVideoList(reportInfo.Id)
- if tmpErr != nil {
- err = tmpErr
- errMsg = "获取音频列表失败"
- return
- }
- if len(videoList) > 0 {
-
- savePath = time.Now().Format(utils.FormatDateTimeUnSpace) + utils.GetRandString(5) + ".zip"
- fileName = reportInfo.VideoName + ".zip"
- zipFile, tmpErr := os.Create(savePath)
- if tmpErr != nil {
- err = tmpErr
- return
- }
- zipWriter := zip.NewWriter(zipFile)
-
- defer func() {
- if err != nil {
- zipWriter.Close()
- zipFile.Close()
- }
- }()
-
- for i := 0; i < len(videoList); i++ {
- item := videoList[i]
- if item.VideoName == "" || item.VideoUrl == "" {
- continue
- }
-
- ext := path.Ext(item.VideoUrl)
- ioWriter, tmpErr := zipWriter.Create(fmt.Sprintf("%s%s", item.VideoName, ext))
- if tmpErr != nil {
- err = tmpErr
- if os.IsPermission(err) {
- fmt.Println("权限不足: ", err)
- return
- }
- return
- }
- var content []byte
- content, err = http.Get(item.VideoUrl)
- if err != nil {
- content = []byte("")
- }
- ioWriter.Write(content)
- }
-
- zipWriter.Close()
- zipFile.Close()
- }
- }
- return
- }
- func CheckReportAuthByAdminIdList(adminId, createAdminId int, grantAdminIdList []int) (isAuth bool) {
-
- if adminId == createAdminId {
- isAuth = true
- return
- }
-
- if utils.IsCheckInList(grantAdminIdList, adminId) {
- isAuth = true
- return
- }
- return
- }
- func CheckReportAuthByReportId(sysUser *system.Admin, createAdminId int, reportInfoId int) (isAuth bool, err error) {
-
- if sysUser.AdminId == createAdminId {
- isAuth = true
- return
- }
-
- if utils.IsAdminRole(sysUser.RoleTypeCode) {
- isAuth = true
- return
- }
- obj := report.ReportGrant{}
- item, err := obj.GetGrantByIdAndAdmin(reportInfoId, sysUser.AdminId)
- if err != nil {
-
- if err.Error() == utils.ErrNoRow() {
- err = nil
- return
- }
-
- return
- }
-
- if item.AdminId == sysUser.AdminId {
- isAuth = true
- }
- return
- }
- func EditReportLayoutImg(reportInfo *models.Report, req models.EditLayoutImgReq, sysUser *system.Admin) (err error, errMsg string) {
- errMsg = `保存失败`
- reportInfo.HeadResourceId = req.HeadResourceId
- reportInfo.HeadImg = req.HeadImg
- reportInfo.EndResourceId = req.EndResourceId
- reportInfo.EndImg = req.EndImg
- reportInfo.CanvasColor = req.CanvasColor
- reportInfo.LastModifyAdminId = sysUser.AdminId
- reportInfo.LastModifyAdminName = sysUser.RealName
- reportInfo.ModifyTime = time.Now()
- updateCols := []string{"HeadResourceId", "HeadImg", "EndResourceId", "EndImg", "CanvasColor", "LastModifyAdminId", "LastModifyAdminName", "ModifyTime"}
- err = reportInfo.UpdateReport(updateCols)
- if err != nil {
- return
- }
- return
- }
- func PublishReport(reportId int, reportUrl string, sysUser *system.Admin) (tips string, err error, errMsg string) {
- errMsg = `报告发布失败`
- reportInfo, err := models.GetReportByReportId(reportId)
- if err != nil {
- errMsg = "获取报告信息失败"
- return
- }
- if reportInfo == nil {
- errMsg = "获取报告信息失败"
- err = errors.New(errMsg)
- return
- }
- var publishTime time.Time
- if reportInfo.MsgIsSend == 1 && !reportInfo.PublishTime.IsZero() {
- publishTime = reportInfo.PublishTime
- } else {
- publishTime = time.Now()
- }
- var tmpErr error
-
- if reportInfo.HasChapter == 1 {
- tips, tmpErr, errMsg = PublishChapterReport(reportInfo, reportUrl, sysUser)
- if tmpErr != nil {
- err = errors.New("晨周报发布失败, Err:" + tmpErr.Error() + ", report_id:" + strconv.Itoa(reportId))
- }
- return
- }
-
- if reportInfo.Content == "" {
- errMsg = `报告内容为空,不可发布`
- err = errors.New("报告内容为空,不需要生成,report_id:" + strconv.Itoa(reportId))
- return
- }
-
- state, e := CheckReportCurrState(report_approve.FlowReportTypeChinese, reportInfo.ClassifyIdFirst, reportInfo.ClassifyIdSecond, reportInfo.ClassifyIdThird, models.ReportOperatePublish)
- if e != nil {
- errMsg = "操作失败"
- err = errors.New("校验报告当前状态失败, Err: " + e.Error())
- return
- }
- if state == models.ReportStatePublished {
-
- if tmpErr = models.PublishReportById(reportId, publishTime, sysUser.AdminId, sysUser.RealName); tmpErr != nil {
- err = errors.New("报告发布失败, Err:" + tmpErr.Error() + ", report_id:" + strconv.Itoa(reportId))
- return
- }
- go func() {
-
- if reportInfo.VideoUrl == "" {
- go UpdateReportVideo(reportInfo)
- }
-
- _ = UpdateReportEs(reportId, 2)
- }()
- } else {
-
- if e = models.ResetReportById(reportId, state, sysUser.AdminId, sysUser.RealName); e != nil {
- errMsg = "操作失败"
- err = fmt.Errorf("重置报告状态失败, Err: %s, ReportId: %d", e.Error(), reportId)
- return
- }
- }
- recordItem := &models.ReportStateRecord{
- ReportId: reportId,
- ReportType: 1,
- State: state,
- AdminId: sysUser.AdminId,
- AdminName: sysUser.AdminName,
- CreateTime: time.Now(),
- }
- go func() {
- _, _ = models.AddReportStateRecord(recordItem)
- }()
-
- {
- reportPdfUrl := GetGeneralPdfUrl(reportInfo.ReportCode, reportInfo.ClassifyNameFirst, reportInfo.ReportLayout)
- go Report2pdfAndJpeg(reportPdfUrl, reportId, 1)
- }
-
- {
- minClassifyId, _, tmpErr := getMinClassify(reportInfo)
- if tmpErr != nil {
- return
- }
- go handleReportPermission(int64(reportInfo.Id), minClassifyId)
- }
- return
- }
- func PublishChapterReport(reportInfo *models.Report, reportUrl string, sysUser *system.Admin) (tips string, err error, errMsg string) {
- reportId := reportInfo.Id
- if reportInfo.State == 2 {
- return
- }
-
- chapters, err := models.GetChapterListByReportId(reportId)
- if err != nil {
- return
- }
- chapterLen := len(chapters)
- if chapterLen <= 0 {
- tips = "报告章节为空,不可发布"
- errMsg = tips
- err = errors.New(tips)
- return
- }
-
- chapterList, err := models.GetChapterListByReportId(reportId)
- if err != nil {
- return
- }
- for _, chapter := range chapterList {
- if chapter.PublishState == 1 {
- tips = "还存在未发布的章节"
- errMsg = tips
- err = errors.New(tips)
- return
- }
- }
-
- state, e := CheckReportCurrState(report_approve.FlowReportTypeChinese, reportInfo.ClassifyIdFirst, reportInfo.ClassifyIdSecond, reportInfo.ClassifyIdThird, models.ReportOperatePublish)
- if e != nil {
-
- err = errors.New("校验报告当前状态失败, Err: " + e.Error())
- return
- }
-
- if state != models.ReportStatePublished {
-
- if e = models.ResetReportById(reportId, state, sysUser.AdminId, sysUser.RealName); e != nil {
-
- err = fmt.Errorf("重置报告状态失败, Err: %s, ReportId: %d", e.Error(), reportId)
- return
- }
- return
- }
-
- updateCols := make([]string, 0)
- reportInfo.LastModifyAdminId = sysUser.AdminId
- reportInfo.LastModifyAdminName = sysUser.RealName
- updateCols = append(updateCols, "LastModifyAdminId", "LastModifyAdminName", "Title", "State", "ModifyTime")
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- reportInfo.State = state
-
- if reportInfo.MsgIsSend == 0 || reportInfo.PublishTime.IsZero() {
- reportInfo.PublishTime = time.Now().Local()
- updateCols = append(updateCols, "PublishTime")
- }
- reportInfo.ModifyTime = time.Now().Local()
- if e := models.PublishReportAndChapter(reportInfo, true, updateCols); e != nil {
- err = errors.New("发布报告及章节失败")
- return
- }
-
- go UpdateReportVideo(reportInfo)
-
- go func() {
- _ = UpdateReportEs(reportInfo.Id, 2)
- }()
-
- go SaveReportLogs(reportInfo, chapters, reportInfo.AdminId, reportInfo.AdminRealName)
-
- {
- reportPdfUrl := GetGeneralPdfUrl(reportInfo.ReportCode, reportInfo.ClassifyNameFirst, reportInfo.ReportLayout)
- go Report2pdfAndJpeg(reportPdfUrl, reportId, 1)
- }
- return
- }
- func DeleteReportAndChapter(reportId int) (err error) {
- reportInfo, err := models.GetReportByReportId(reportId)
- if err != nil {
- err = errors.New("报告信息有误, Err: " + err.Error())
- return
- }
- if reportInfo.State == 2 {
- err = errors.New("报告已发布,不可删除")
- return
- }
-
- _ = UpdateReportEs(reportId, 1)
-
- if reportInfo.HasChapter == 1 {
- err = models.DeleteDayWeekReportAndChapter(reportId)
- } else {
- err = models.DeleteReport(reportId)
- }
- if err != nil {
- err = errors.New("删除失败, Err: " + err.Error())
- return
- }
-
- go func() {
- _ = ResetPPTReport(reportId, false)
- }()
- return
- }
- func getMinClassify(reportInfo *models.Report) (minClassifyId int, minClassifyName string, err error) {
- defer func() {
- if err != nil {
- utils.FileLog.Error("获取最小分类ID失败,报告ID:%d,Err:%s", reportInfo.Id, err.Error())
- }
- }()
- minClassifyId = reportInfo.ClassifyIdThird
- minClassifyName = reportInfo.ClassifyNameThird
- if minClassifyId <= 0 {
- minClassifyId = reportInfo.ClassifyIdSecond
- minClassifyName = reportInfo.ClassifyNameSecond
- }
- if minClassifyId <= 0 {
- minClassifyId = reportInfo.ClassifyIdFirst
- minClassifyName = reportInfo.ClassifyNameFirst
- }
- if minClassifyId <= 0 {
- err = errors.New("分类异常")
- }
- return
- }
- func handleReportPermission(reportId int64, minClassifyId int) {
-
- var err error
- defer func() {
- if err != nil {
- utils.FileLog.Error("报告权限处理失败,报告ID:%d,分类ID:%d,Err:%s", reportId, minClassifyId, err.Error())
-
- }
- }()
- err = models.RemoveChartPermissionChapterMapping(reportId)
- if err != nil {
- err = errors.New("修改删除报告权限失败,Err:" + err.Error())
- return
- }
- permissionItems, err := models.GetPermission(minClassifyId)
- if err != nil {
- err = errors.New("获取权限失败,Err:" + err.Error())
- return
- }
- for _, v := range permissionItems {
- err = models.AddChartPermissionChapterMapping(v.ChartPermissionId, reportId)
- if err != nil {
- err = errors.New("新增权限失败,Err:" + err.Error())
- return
- }
- }
-
- _ = EditReportPermissionSync(reportId, minClassifyId)
- return
- }
- func handlerReportTableReferenced(reportInfo *models.Report) {
- var err error
- defer func() {
- if err != nil {
- utils.FileLog.Error("报告表关联处理失败,旧报告ID:%d,新报告ID:%d,Err:%s", reportInfo.InheritReportId, reportInfo.Id, err.Error())
- }
- }()
- addList, err := excel.CopyReferencedExcelConfigByReferencedIdAndFromScene(reportInfo.InheritReportId, utils.TableReferencedByReport, reportInfo.Id, utils.TableReferencedByReport, reportInfo.AdminId, reportInfo.AdminRealName)
- if err != nil {
- return
- }
- if len(addList) > 0 {
-
- reportInfo.Content = HandleReportContentTable(reportInfo.Id, reportInfo.Content)
- reportInfo.ContentStruct = HandleReportContentStructTable(reportInfo.Id, reportInfo.ContentStruct)
- err = reportInfo.Update([]string{"Content", "ContentStruct"})
- if err != nil {
- return
- }
- if reportInfo.HasChapter == 1 {
- chapterList, tmpErr := models.GetChapterListByReportId(reportInfo.Id)
- if tmpErr != nil {
- err = tmpErr
- return
- }
- for _, v := range chapterList {
- v.Content = HandleReportContentTable(reportInfo.Id, v.Content)
- v.ContentStruct = HandleReportContentStructTable(reportInfo.Id, v.ContentStruct)
- err = v.Update([]string{"Content", "ContentStruct"})
- if err != nil {
- return
- }
- }
- }
- }
- }
- func HandleReportPermission(reportInfo *models.Report) {
- minClassifyId, _, tmpErr := getMinClassify(reportInfo)
- if tmpErr != nil {
- return
- }
- handleReportPermission(int64(reportInfo.Id), minClassifyId)
- }
- func UpdateReportVideo(reportInfo *models.Report) {
- if reportInfo.HasChapter == 1 {
- reportChapterIdList := make([]int, 0)
-
- chapterList, err := models.GetChapterListByReportId(reportInfo.Id)
- if err != nil {
- return
- }
- reportContent := ""
- for _, chapter := range chapterList {
- if chapter.PublishState == 2 {
- reportChapterIdList = append(reportChapterIdList, chapter.ReportChapterId)
- reportContent += chapter.Title + `。`
- reportContent += chapter.Content + `。`
- }
- }
- if len(reportChapterIdList) > 0 {
- err = UpdateChaptersVideo(reportChapterIdList)
- if err != nil {
- utils.FileLog.Info(fmt.Sprintf("%d报告音频生产失败:%s", reportInfo.Id, err.Error()))
- }
- }
-
- {
- if reportInfo.VideoUrl != "" && reportInfo.VideoName != "" && reportInfo.VideoSize != "" && reportInfo.VideoPlaySeconds != "" {
- return
- }
- weekClassifyId, err := company.GetReportClassifyIdByConfigKey("report_week_classify_id")
- if err != nil && err.Error() != utils.ErrNoRow() {
- msg := "获取周报ID配置失败:" + err.Error()
- utils.FileLog.Info(msg)
- return
- }
- if reportInfo.ClassifyIdFirst == weekClassifyId {
- return
- }
- videoUrl, videoName, videoSize, videoPlaySeconds, e := CreateReportVideo(reportInfo.Title, html.UnescapeString(reportContent), time.Now().Format(utils.FormatDateTime))
- if e != nil {
- err = e
- return
- }
-
- err = models.ModifyReportVideoByNoVideo(reportInfo.Id, videoUrl, videoName, videoSize, videoPlaySeconds)
- }
- } else {
- err := CreateVideo(reportInfo)
- if err != nil {
- utils.FileLog.Info(fmt.Sprintf("%d报告音频生产失败:%s", reportInfo.Id, err.Error()))
- }
- }
- }
- func GetGeneralPdfUrl(reportCode, classifyFirstName string, reportLayout int8) (pdfUrl string) {
-
- if utils.InArrayByStr([]string{utils.BusinessCodeRelease, utils.BusinessCodeSandbox, utils.BusinessCodeDebug}, utils.BusinessCode) && utils.InArrayByStr([]string{"晨报", "周报"}, classifyFirstName) {
- return
- }
-
- var reportUrl string
- conf, _ := models.GetBusinessConfByKey(models.BusinessConfReport2ImgUrl)
- if conf != nil && conf.ConfVal != "" {
- reportUrl = conf.ConfVal
- }
- if reportUrl == "" {
- conf, e := models.GetBusinessConfByKey(models.BusinessConfReportViewUrl)
- if e != nil {
- return
- }
- reportUrl = conf.ConfVal
- }
- switch reportLayout {
- case 1:
-
- pdfUrl = fmt.Sprintf("%s/reportshare_pdf?code=%s", reportUrl, reportCode)
- case 2:
-
- pdfUrl = fmt.Sprintf("%s/reportshare_smart_pdf?code=%s", reportUrl, reportCode)
- }
- return
- }
- func GetReportWaterMarkPdf(reportInfo *models.Report, sysUser *system.Admin) {
- dateDir := time.Now().Format("20060102")
- uploadDir := utils.STATIC_DIR + "pdf/" + dateDir
- filePath, err := utils.DownloadFile(reportInfo.DetailPdfUrl, uploadDir)
- if err != nil {
- return
- }
-
- defer func() {
- _ = os.Remove(filePath)
- }()
- waterMarkStr := fmt.Sprintf("%s - %s", sysUser.RealName, sysUser.Mobile)
- GeneralWaterMarkPdf(filePath, waterMarkStr)
- }
- func GetReportShareUrlToken(req models.ReportShartUrlReq, adminId int) (linkToken string, err error) {
- cacheLinkKey := utils.CACHE_REPORT_SHARE_SHORT_Url + strconv.Itoa(req.ReportId) + "userId:" + strconv.Itoa(adminId)
- linkToken, _ = utils.Rc.RedisString(cacheLinkKey)
- if linkToken != "" && utils.Rc.IsExist(utils.CACHE_REPORT_SHARE_ORIGIN_Url+linkToken) {
- return
- }
- var ok bool
-
- for i := 0; i < 3; i++ {
- linkToken = req.Url
- if i > 0 {
- linkToken += "_" + utils.GetRandDigit(3)
- }
- hashUrl := utils.MurmurHash64([]byte(linkToken))
- linkToken = utils.ConvertNumToBase62(hashUrl)
- ok = utils.Rc.IsExist(utils.CACHE_REPORT_SHARE_ORIGIN_Url + linkToken)
- if !ok {
- break
- }
- }
- if !ok {
- after := time.Now().AddDate(0, 0, 7)
- err = utils.Rc.Put(cacheLinkKey, linkToken, time.Until(after))
- if err != nil {
- return
- }
- err = utils.Rc.Put(utils.CACHE_REPORT_SHARE_ORIGIN_Url+linkToken, req.Url, time.Until(after))
- if err != nil {
- return
- }
- } else {
- linkToken = ""
- err = errors.New("生成链接失败")
- }
- return
- }
- func TransfromToOriginUrl(linkToken string) (originLink string, msg string, err error) {
- cacheLinkKey := utils.CACHE_REPORT_SHARE_ORIGIN_Url + linkToken
- originLink, err = utils.Rc.RedisString(cacheLinkKey)
- if err != nil {
- if err == redis.Nil {
- msg = "链接已失效, 请重新获取"
- return
- }
- msg = "获取链接失败"
- return
- }
- if originLink == "" {
- msg = "链接已失效, 请重新获取"
- return
- }
- return
- }
- func FilterShareUrl() web.FilterFunc {
- return func(c *context.Context) {
- path := c.Input.Context.Request.URL.Path
- tokenArr := strings.Split(path, "/")
- token := tokenArr[len(tokenArr)-1]
- newPath := "/adminapi/report/share/link"
- q := c.Input.Context.Request.URL.Query()
- q.Add("Token", token)
- c.Input.Context.Request.URL.Path = newPath
- c.Input.Context.Request.URL.RawQuery = q.Encode()
- utils.ApiLog.Info(fmt.Sprintf("原始请求为:%s, 已修改请求路径为:%s?%s", path, newPath, q.Encode()))
- }
- }
- func ResetMiniProgramReportDetailCover(reportId int) (err error) {
- if utils.MYSQL_WEEKLY_URL == `` {
- return
- }
- defer func() {
- if err != nil {
- tips := fmt.Sprintf("ResetMiniProgramReportDetailCover-重置小程序报告封面失败, %v", err)
- utils.FileLog.Info(tips)
- alarm_msg.SendAlarmMsg(tips, 2)
- }
- }()
- ob := new(yb.YbPosterResource)
- cond := fmt.Sprintf(` AND path LIKE 'reportDetailCover?ReportId=%d&%%'`, reportId)
- pars := make([]interface{}, 0)
- list, e := ob.GetItemsByCondition(cond, pars, []string{"id"}, "")
- if e != nil {
- err = fmt.Errorf("获取报告海报失败, %v", e)
- return
- }
- if len(list) == 0 {
- return
- }
- var removeIds []int
- for _, v := range list {
- removeIds = append(removeIds, v.Id)
- }
- if e = ob.RemovePosters(removeIds); e != nil {
- err = fmt.Errorf("清除报告海报失败, %v", e)
- }
- return
- }
- func HandleReportContentTable(reportId int, body string) (newBody string) {
- if body == `` {
- return
- }
- newBody = body
-
- doc, err := html2.Parse(strings.NewReader(body))
- if err != nil {
- fmt.Println("Error parsing HTML:", err)
- return
- }
- replaceIframeSrcTable(doc, reportId, 0)
-
- var modifiedHtml strings.Builder
- err = html2.Render(&modifiedHtml, doc)
- if err != nil {
- fmt.Println("Error rendering HTML:", err)
- return
- }
- newBody = modifiedHtml.String()
- fmt.Println(newBody)
- return
- }
- func HandleReportContentTableAndScene(reportId, fromScene int, body string) (newBody string) {
- if body == `` {
- return
- }
- newBody = body
-
- doc, err := html2.Parse(strings.NewReader(body))
- if err != nil {
- fmt.Println("Error parsing HTML:", err)
- return
- }
- replaceIframeSrcTable(doc, reportId, fromScene)
-
- var modifiedHtml strings.Builder
- err = html2.Render(&modifiedHtml, doc)
- if err != nil {
- fmt.Println("Error rendering HTML:", err)
- return
- }
- newBody = modifiedHtml.String()
- return
- }
- func replaceIframeSrcTable(n *html2.Node, reportId, fromScene int) {
- if n.Type == html2.ElementNode && n.Data == "iframe" {
- for i, attr := range n.Attr {
- if attr.Key == "src" {
- newLink := handleTableLinkReportId(attr.Val, reportId, fromScene)
-
- n.Attr[i].Val = newLink
- break
- }
- }
- }
-
- for c := n.FirstChild; c != nil; c = c.NextSibling {
- replaceIframeSrcTable(c, reportId, fromScene)
- }
- }
- func handleTableLinkReportId(link string, reportId, fromScene int) string {
- var err error
- defer func() {
- if err != nil {
- utils.FileLog.Info("处理链接失败,ERR:" + err.Error())
- }
- }()
- if link == `` {
- return link
- }
- parsedURL, err := url.Parse(link)
- if err != nil {
- return link
- }
-
- queryParams := parsedURL.Query()
-
- queryParams.Del("sourceId")
- queryParams.Add("sourceId", fmt.Sprint(reportId))
- if fromScene > 0 {
- queryParams.Del("fromScene")
- queryParams.Add("fromScene", fmt.Sprint(fromScene))
- }
-
- parsedURL.RawQuery = queryParams.Encode()
-
- return parsedURL.String()
- }
- func HandleReportContentStructTable(reportId int, body string) (newBody string) {
- if body == `` {
- return
- }
- newBody = body
-
- var jsonData []map[string]interface{}
- if err := json.Unmarshal([]byte(body), &jsonData); err != nil {
- fmt.Println("Error parsing JSON:", err)
- return
- }
-
- for i := range jsonData {
- if err := processMapTable(jsonData[i], reportId, 0); err != nil {
- fmt.Println("Error processing component:", err)
- return
- }
- }
-
-
- modifiedJSON, err := json.Marshal(jsonData)
- if err != nil {
- fmt.Println("Error marshaling JSON:", err)
- return
- }
- newBody = string(modifiedJSON)
- return
- }
- func HandleReportContentStructTableAndScene(reportId, fromScene int, body string) (newBody string) {
- if body == `` {
- return
- }
- newBody = body
-
- var jsonData []map[string]interface{}
- if err := json.Unmarshal([]byte(body), &jsonData); err != nil {
- fmt.Println("Error parsing JSON:", err)
- return
- }
-
- for i := range jsonData {
- if err := processMapTable(jsonData[i], reportId, 0); err != nil {
- fmt.Println("Error processing component:", err)
- return
- }
- }
-
- modifiedJSON, err := json.MarshalIndent(jsonData, "", " ")
- if err != nil {
- fmt.Println("Error marshaling JSON:", err)
- return
- }
- newBody = string(modifiedJSON)
- return
- }
- func processMapTable(data map[string]interface{}, reportId, fromScene int) error {
- for key, value := range data {
- switch v := value.(type) {
- case string:
- if key == "content" {
- contentSource, ok := data["compType"]
- if !ok {
- continue
- }
- contentSourceType, ok := contentSource.(string)
- if !ok {
- continue
- }
- if !utils.InArrayByStr([]string{`sheet`, `chart`}, contentSourceType) {
- continue
- }
- newContent := handleTableLinkReportId(v, reportId, fromScene)
- data[key] = newContent
- }
- case map[string]interface{}:
- if err := processMapTable(v, reportId, fromScene); err != nil {
- return err
- }
- case []interface{}:
- for i := range v {
- if m, ok := v[i].(map[string]interface{}); ok {
- if err := processMapTable(m, reportId, fromScene); err != nil {
- return err
- }
- }
- }
- }
- }
- return nil
- }
- func HandleReportContent(body string, opType string, tokenMap map[string]string) (newBody string) {
- if body == `` {
- return
- }
- newBody = body
-
- doc, err := html2.Parse(strings.NewReader(body))
- if err != nil {
- fmt.Println("Error parsing HTML:", err)
- return
- }
- replaceIframeSrc(doc, opType, tokenMap)
-
- var modifiedHtml strings.Builder
- err = html2.Render(&modifiedHtml, doc)
- if err != nil {
- fmt.Println("Error rendering HTML:", err)
- return
- }
- newBody = modifiedHtml.String()
- fmt.Println(newBody)
- return
- }
- func replaceIframeSrc(n *html2.Node, opType string, tokenMap map[string]string) {
- if n.Type == html2.ElementNode && n.Data == "iframe" {
- for i, attr := range n.Attr {
- if attr.Key == "src" {
- newLink := attr.Val
-
- switch opType {
- case `add`:
- newLink = linkAddToken(attr.Val, tokenMap)
- case `del`:
- newLink = linkDelToken(attr.Val)
- }
-
- n.Attr[i].Val = newLink
- break
- }
- }
- }
-
- for c := n.FirstChild; c != nil; c = c.NextSibling {
- replaceIframeSrc(c, opType, tokenMap)
- }
- }
- func linkAddToken(link string, tokenMap map[string]string) string {
- var err error
- defer func() {
- if err != nil {
- utils.FileLog.Info("处理链接失败,ERR:" + err.Error())
- }
- }()
- if link == `` {
- return link
- }
- parsedURL, err := url.Parse(link)
- if err != nil {
- return link
- }
-
- queryParams := parsedURL.Query()
-
- queryParams.Del("authToken")
-
- code := queryParams.Get("code")
- if code == "" {
- return link
- }
- showType := `chart`
- if strings.Contains(parsedURL.Path, "sheetshow") {
- showType = `excel`
- }
-
- key := fmt.Sprint(showType, `:`, code)
- if tokenMap != nil {
- if token, ok := tokenMap[key]; ok {
-
- return link + "&authToken=" + token
- }
- }
- token, err := GeneralChartToken(showType, code, 30*time.Minute)
- if err != nil {
- return link
- }
- if tokenMap != nil {
- tokenMap[key] = token
- }
-
- return link + "&authToken=" + token
- }
- func linkDelToken(link string) string {
- var err error
- defer func() {
- if err != nil {
- utils.FileLog.Info("处理链接失败,ERR:" + err.Error())
- }
- }()
- parsedURL, err := url.Parse(link)
- if err != nil {
- return link
- }
-
- queryParams := parsedURL.Query()
-
- queryParams.Del("authToken")
-
- parsedURL.RawQuery = queryParams.Encode()
- return parsedURL.String()
- }
- func GeneralChartToken(showType, uniqueCode string, expireTime time.Duration) (token string, err error) {
-
- token = utils.MD5(fmt.Sprint(showType+`:`, uniqueCode, time.Now().UnixNano()/1e6))
- key := fmt.Sprint(utils.CACHE_CHART_AUTH, token)
- err = utils.Rc.Put(key, uniqueCode, expireTime)
- return
- }
- func HandleReportContentStruct(body string, opType string, tokenMap map[string]string) (newBody string) {
- if body == `` {
- return
- }
- newBody = body
-
- var jsonData []map[string]interface{}
- if err := json.Unmarshal([]byte(body), &jsonData); err != nil {
- fmt.Println("Error parsing JSON:", err)
- return
- }
-
- for i := range jsonData {
- if err := processMap(jsonData[i], opType, tokenMap); err != nil {
- fmt.Println("Error processing component:", err)
- return
- }
- }
-
- modifiedJSON, err := json.MarshalIndent(jsonData, "", " ")
- if err != nil {
- fmt.Println("Error marshaling JSON:", err)
- return
- }
- newBody = string(modifiedJSON)
- return
- }
- func processMap(data map[string]interface{}, opType string, tokenMap map[string]string) error {
- for key, value := range data {
- switch v := value.(type) {
- case string:
- if key == "content" {
- contentSource, ok := data["compType"]
- if !ok {
- continue
- }
- contentSourceType, ok := contentSource.(string)
- if !ok {
- continue
- }
- if !utils.InArrayByStr([]string{`sheet`, `chart`}, contentSourceType) {
- continue
- }
- newContent := v
-
- switch opType {
- case `add`:
- newContent = linkAddToken(v, tokenMap)
- case `del`:
- newContent = linkDelToken(v)
- }
- data[key] = newContent
- }
- case map[string]interface{}:
- if err := processMap(v, opType, tokenMap); err != nil {
- return err
- }
- case []interface{}:
- for i := range v {
- if m, ok := v[i].(map[string]interface{}); ok {
- if err := processMap(m, opType, tokenMap); err != nil {
- return err
- }
- }
- }
- }
- }
- return nil
- }
|