report.go 59 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072
  1. package services
  2. import (
  3. "encoding/json"
  4. "errors"
  5. "eta/eta_api/models"
  6. "eta/eta_api/models/company"
  7. "eta/eta_api/models/report"
  8. "eta/eta_api/models/system"
  9. "eta/eta_api/services/alarm_msg"
  10. "eta/eta_api/services/public_api"
  11. "eta/eta_api/utils"
  12. "fmt"
  13. "github.com/PuerkitoBio/goquery"
  14. "html"
  15. "os"
  16. "regexp"
  17. "strconv"
  18. "strings"
  19. "time"
  20. )
  21. func GetReportContentSub(content string) (contentSub string, err error) {
  22. content = html.UnescapeString(content)
  23. doc, err := goquery.NewDocumentFromReader(strings.NewReader(content))
  24. if err != nil {
  25. fmt.Println("create doc err:", err.Error())
  26. return
  27. }
  28. n := 0
  29. doc.Find("p").Each(func(i int, s *goquery.Selection) {
  30. if n >= 5 {
  31. return
  32. }
  33. n++
  34. phtml, err := s.Html()
  35. if err != nil {
  36. fmt.Println("get html err", err.Error())
  37. return
  38. }
  39. if s.Text() != "" || strings.Contains(phtml, "src") {
  40. contentSub = contentSub + "<p>" + phtml + "</p>"
  41. }
  42. })
  43. return
  44. }
  45. // UpdateChaptersVideo 更新章节音频
  46. func UpdateChaptersVideo(ids []int) (err error) {
  47. defer func() {
  48. if err != nil {
  49. utils.FileLog.Error("UpdateChaptersVideo, chapterIds:%v, Err:%s", ids, err.Error())
  50. go alarm_msg.SendAlarmMsg(fmt.Sprintf("更新章节音频失败, 章节ID: %v; Err: "+err.Error(), ids), 3)
  51. }
  52. }()
  53. if len(ids) <= 0 {
  54. return
  55. }
  56. chapterList, err := models.GetChapterListByChapterIds(ids)
  57. if err != nil {
  58. return
  59. }
  60. // 生成video
  61. nowTime := time.Now()
  62. updateCols := make([]string, 0)
  63. updateCols = append(updateCols, "VideoUrl", "VideoName", "VideoSize", "VideoPlaySeconds")
  64. for i := 0; i < len(chapterList); i++ {
  65. item := chapterList[i]
  66. // 忽略已有音频的章节
  67. if item.VideoUrl != "" && item.VideoName != "" && item.VideoSize != "" && item.VideoPlaySeconds != "" {
  68. continue
  69. }
  70. videoUrl, videoName, videoSize, videoPlaySeconds, e := CreateReportVideo(item.Title, html.UnescapeString(item.Content), nowTime.Format(utils.FormatDateTime))
  71. if e != nil {
  72. err = e
  73. return
  74. }
  75. item.VideoUrl = videoUrl
  76. item.VideoName = videoName
  77. item.VideoSize = videoSize
  78. item.VideoPlaySeconds = fmt.Sprintf("%.2f", videoPlaySeconds)
  79. if e = item.UpdateChapter(updateCols); e != nil {
  80. err = e
  81. }
  82. }
  83. return
  84. }
  85. // PublishTodayDayReport 发布今日晨报
  86. func PublishTodayDayReport() (err error) {
  87. nowTime := time.Now()
  88. startTime := time.Date(nowTime.Year(), nowTime.Month(), nowTime.Day(), 0, 0, 0, 0, time.Local)
  89. endTime := time.Date(nowTime.Year(), nowTime.Month(), nowTime.Day(), 23, 59, 59, 0, time.Local)
  90. todayReport, err := models.GetUnPublishDayReport(startTime, endTime)
  91. if err != nil {
  92. if err.Error() == utils.ErrNoRow() { //如果是找不到待发送的晨报,那么需要将err置空
  93. err = nil
  94. }
  95. return
  96. }
  97. if todayReport != nil {
  98. if _, tmpErr, _ := PublishChapterReport(todayReport, ""); tmpErr != nil {
  99. err = tmpErr
  100. return
  101. }
  102. // 定时发布的晨报自动推送客群
  103. reportDetail, tmpErr := models.GetReportById(todayReport.Id)
  104. if tmpErr != nil {
  105. err = tmpErr
  106. return
  107. }
  108. // 推送模板消息
  109. if tmpErr = SendMiniProgramReportWxMsg(todayReport.Id); tmpErr != nil {
  110. err = tmpErr
  111. return
  112. }
  113. if tmpErr = models.ModifyReportThsMsgIsSend(reportDetail); tmpErr != nil {
  114. err = tmpErr
  115. return
  116. }
  117. }
  118. return
  119. }
  120. func initp2_838 (){
  121. var condition string
  122. var pars []interface{}
  123. condition = " AND state = 2 "
  124. list ,err:= models.GetReportByCondition(condition,pars,[]string{},"",false,0,0)
  125. if err != nil{
  126. fmt.Println(err)
  127. }
  128. fmt.Println(len(list))
  129. for _,v:= range list{
  130. fmt.Println(v.Id)
  131. UpdateReportEs(v.Id,2)
  132. }
  133. }
  134. // UpdateReportEs 更新报告/章节Es
  135. func UpdateReportEs(reportId int, publishState int) (err error) {
  136. if reportId <= 0 {
  137. return
  138. }
  139. reportInfo, err := models.GetReportByReportId(reportId)
  140. if err != nil {
  141. return
  142. }
  143. categories := ""
  144. if reportInfo.HasChapter == 1 {
  145. // 晨周报
  146. chapterList, tmpErr := models.GetPublishedChapterListByReportId(reportInfo.Id)
  147. if tmpErr != nil {
  148. return
  149. }
  150. if len(chapterList) > 0 {
  151. // 更新章节的es数据
  152. for _, chapterInfo := range chapterList {
  153. err = updateReportChapterEsByChapter(chapterInfo)
  154. if err != nil {
  155. return
  156. }
  157. }
  158. }
  159. } else {
  160. //if utils.BusinessCode == utils.BusinessCodeRelease || utils.BusinessCode == utils.BusinessCodeSandbox {
  161. permissionList, tmpErr := models.GetChartPermissionNameFromMappingByKeyword("rddp", reportInfo.ClassifyIdSecond)
  162. if tmpErr != nil {
  163. return
  164. }
  165. categoryArr := make([]string, 0)
  166. for i := 0; i < len(permissionList); i++ {
  167. categoryArr = append(categoryArr, permissionList[i].PermissionName)
  168. }
  169. aliasArr, _ := addCategoryAliasToArr(categoryArr)
  170. categories = strings.Join(aliasArr, ",")
  171. //}
  172. }
  173. // 最小单位的分类id
  174. minClassifyId, minClassifyName, err := getMinClassify(reportInfo)
  175. if err != nil {
  176. return
  177. }
  178. // 新增报告ES
  179. esReport := &models.ElasticReportDetail{
  180. ReportId: reportInfo.Id,
  181. ReportChapterId: 0,
  182. Title: reportInfo.Title,
  183. Abstract: reportInfo.Abstract,
  184. BodyContent: utils.TrimHtml(html.UnescapeString(reportInfo.Content)),
  185. PublishTime: reportInfo.PublishTime.Format(utils.FormatDateTime),
  186. PublishState: publishState,
  187. Author: reportInfo.Author,
  188. ClassifyIdFirst: reportInfo.ClassifyIdFirst,
  189. ClassifyNameFirst: reportInfo.ClassifyNameFirst,
  190. ClassifyIdSecond: reportInfo.ClassifyIdSecond,
  191. ClassifyNameSecond: reportInfo.ClassifyNameSecond,
  192. ClassifyId: minClassifyId,
  193. ClassifyName: minClassifyName,
  194. Categories: categories,
  195. StageStr: strconv.Itoa(reportInfo.Stage),
  196. }
  197. docId := fmt.Sprintf("%d-%d", reportInfo.Id, 0)
  198. if err = EsAddOrEditReport(utils.EsReportIndexName, docId, esReport); err != nil {
  199. return
  200. }
  201. return
  202. }
  203. // addCategoryAliasToArr 品种别名
  204. func addCategoryAliasToArr(categoryArr []string) (aliasArr []string, err error) {
  205. aliasArr = categoryArr
  206. if len(categoryArr) > 0 {
  207. for i := 0; i < len(categoryArr); i++ {
  208. if strings.Contains(categoryArr[i], "沥青") {
  209. aliasArr = append(aliasArr, "BU")
  210. }
  211. if strings.Contains(categoryArr[i], "MEG") {
  212. aliasArr = append(aliasArr, "EG", "乙二醇")
  213. }
  214. if strings.Contains(categoryArr[i], "聚酯") {
  215. aliasArr = append(aliasArr, "长丝", "短纤", "瓶片")
  216. }
  217. if strings.Contains(categoryArr[i], "纯苯+苯乙烯") {
  218. aliasArr = append(aliasArr, "EB")
  219. }
  220. if strings.Contains(categoryArr[i], "聚乙烯") {
  221. aliasArr = append(aliasArr, "PP", "PE")
  222. }
  223. if strings.Contains(categoryArr[i], "玻璃纯碱") {
  224. aliasArr = append(aliasArr, "玻璃", "纯碱", "FG", "SA")
  225. }
  226. if strings.Contains(categoryArr[i], "甲醇") {
  227. aliasArr = append(aliasArr, "甲醇", "MA")
  228. }
  229. if strings.Contains(categoryArr[i], "橡胶") {
  230. aliasArr = append(aliasArr, "橡胶", "RU")
  231. }
  232. }
  233. }
  234. return
  235. }
  236. // UpdateReportChapterEs
  237. // @Description: 通过章节id更新报告章节ES
  238. // @author: Roc
  239. // @datetime 2024-06-20 13:16:22
  240. // @param reportChapterId int
  241. // @return err error
  242. func UpdateReportChapterEs(reportChapterId int) (err error) {
  243. if reportChapterId <= 0 {
  244. return
  245. }
  246. chapterInfo, err := models.GetReportChapterInfoById(reportChapterId)
  247. if err != nil {
  248. return
  249. }
  250. err = updateReportChapterEsByChapter(chapterInfo)
  251. if err != nil {
  252. return
  253. }
  254. return
  255. }
  256. // updateReportChapterEsByChapter
  257. // @Description: 通过章节详情更新报告章节ES
  258. // @author: Roc
  259. // @datetime 2024-06-20 13:16:11
  260. // @param chapterInfo *models.ReportChapter
  261. // @return err error
  262. func updateReportChapterEsByChapter(chapterInfo *models.ReportChapter) (err error) {
  263. // 章节对应的品种
  264. obj := report.ReportChapterPermissionMapping{}
  265. permissionList, tmpErr := obj.GetPermissionItemListById(chapterInfo.ReportChapterId)
  266. if tmpErr != nil {
  267. return
  268. }
  269. categoryArr := make([]string, 0)
  270. if len(permissionList) > 0 {
  271. for ii := 0; ii < len(permissionList); ii++ {
  272. categoryArr = append(categoryArr, permissionList[ii].ChartPermissionName)
  273. }
  274. }
  275. aliasArr, _ := addCategoryAliasToArr(categoryArr)
  276. categories := strings.Join(aliasArr, ",")
  277. // 新增/编辑ES
  278. esChapter := &models.ElasticReportDetail{
  279. ReportId: chapterInfo.ReportId,
  280. ReportChapterId: chapterInfo.ReportChapterId,
  281. Title: chapterInfo.Title,
  282. Abstract: chapterInfo.Abstract,
  283. BodyContent: utils.TrimHtml(html.UnescapeString(chapterInfo.Content)),
  284. PublishTime: chapterInfo.PublishTime.Format(utils.FormatDateTime),
  285. PublishState: chapterInfo.PublishState,
  286. Author: chapterInfo.Author,
  287. ClassifyIdFirst: chapterInfo.ClassifyIdFirst,
  288. ClassifyNameFirst: chapterInfo.ClassifyNameFirst,
  289. ClassifyIdSecond: 0,
  290. ClassifyNameSecond: "",
  291. ClassifyId: chapterInfo.ClassifyIdFirst,
  292. ClassifyName: chapterInfo.ClassifyNameFirst,
  293. Categories: categories,
  294. StageStr: strconv.Itoa(chapterInfo.Stage),
  295. }
  296. chapterDocId := fmt.Sprintf("%d-%d", chapterInfo.ReportId, chapterInfo.ReportChapterId)
  297. if err = EsAddOrEditReport(utils.EsReportIndexName, chapterDocId, esChapter); err != nil {
  298. return
  299. }
  300. return
  301. }
  302. // DeleteReportAndChapter 删除报告及章节
  303. func DeleteReportAndChapter(reportId int) (err error) {
  304. reportInfo, err := models.GetReportByReportId(reportId)
  305. if err != nil {
  306. err = errors.New("报告信息有误, Err: " + err.Error())
  307. return
  308. }
  309. if reportInfo.State == 2 {
  310. err = errors.New("报告已发布,不可删除")
  311. return
  312. }
  313. // 更新ES
  314. _ = UpdateReportEs(reportId, 1)
  315. // 删除
  316. if reportInfo.HasChapter == 1 && (reportInfo.ChapterType == utils.REPORT_TYPE_DAY || reportInfo.ChapterType == utils.REPORT_TYPE_WEEK) {
  317. err = models.DeleteDayWeekReportAndChapter(reportId)
  318. } else {
  319. err = models.DeleteReport(reportId)
  320. }
  321. if err != nil {
  322. err = errors.New("删除失败, Err: " + err.Error())
  323. return
  324. }
  325. // 重置PPT关联报告
  326. go func() {
  327. _ = ResetPPTReport(reportId, false)
  328. }()
  329. return
  330. }
  331. // 替换报告内容中的base64图片
  332. func replaceReportBase64ToImg(content string) (newContent string, err error) {
  333. if content == "" {
  334. return
  335. }
  336. pattern := "data:([a-z]+\\/[a-z0-9-+.]+(;[a-z-]+=[a-z0-9-]+)?)?(;base64)?,([A-Za-z0-9+/]{4})*([A-Za-z0-9+/]{3}=|[A-Za-z0-9+/]{2}==)?"
  337. re, _ := regexp.Compile(pattern)
  338. matcher := re.FindAllString(content, 999)
  339. if len(matcher) > 0 {
  340. for _, v := range matcher {
  341. imgUrl, tmpErr := reportBase64ToImg(v)
  342. if tmpErr != nil {
  343. err = tmpErr
  344. return
  345. }
  346. content = strings.ReplaceAll(content, v, imgUrl)
  347. }
  348. }
  349. newContent = content
  350. return
  351. }
  352. // 转换base64图片为img并上传
  353. func reportBase64ToImg(imageBase64 string) (resourceUrl string, err error) {
  354. if imageBase64 == "" {
  355. err = errors.New("图片为空")
  356. return
  357. }
  358. ext := ".png"
  359. uploadDir := "./static"
  360. randStr := utils.GetRandStringNoSpecialChar(28)
  361. fileName := randStr + ext
  362. fpath := uploadDir + "/" + fileName
  363. b, _ := regexp.MatchString(`^data:\s*image\/(\w+);base64,`, imageBase64)
  364. if !b {
  365. err = errors.New("图片格式不正确")
  366. return
  367. }
  368. re, _ := regexp.Compile(`^data:\s*image\/(\w+);base64,`)
  369. base64Str := re.ReplaceAllString(imageBase64, "")
  370. base64Str = strings.Replace(base64Str, " ", "", -1)
  371. err = utils.SaveBase64ToFile(base64Str, fpath)
  372. if err != nil {
  373. err = errors.New("图片保存失败" + err.Error())
  374. return
  375. }
  376. defer os.Remove(fpath)
  377. hzUploadDir := utils.RESOURCE_DIR + "images/"
  378. savePath := hzUploadDir + time.Now().Format("200601/20060102/")
  379. savePath += fileName
  380. //上传到阿里云 和 minio
  381. //if utils.ObjectStorageClient == "minio" {
  382. // err = UploadFileToMinIo(fileName, fpath, savePath)
  383. // if err != nil {
  384. // err = errors.New("文件上传失败" + err.Error())
  385. // return
  386. // }
  387. // resourceUrl = utils.MinIoImghost + savePath
  388. //} else {
  389. // err = UploadFileToAliyun(fileName, fpath, savePath)
  390. // if err != nil {
  391. // err = errors.New("文件上传失败" + err.Error())
  392. // return
  393. // }
  394. // resourceUrl = utils.Imghost + savePath
  395. //}
  396. ossClient := NewOssClient()
  397. if ossClient == nil {
  398. err = fmt.Errorf("初始化OSS服务失败")
  399. return
  400. }
  401. resourceUrl, err = ossClient.UploadFile(fileName, fpath, savePath)
  402. if err != nil {
  403. err = fmt.Errorf("文件上传失败, Err: %s", err.Error())
  404. return
  405. }
  406. item := new(models.Resource)
  407. item.ResourceUrl = resourceUrl
  408. item.ResourceType = 1
  409. item.CreateTime = time.Now()
  410. _, err = models.AddResource(item)
  411. if err != nil {
  412. err = errors.New("资源上传失败" + err.Error())
  413. return
  414. }
  415. return
  416. }
  417. // UpdateReportVideo 更新报告及其章节音频
  418. func UpdateReportVideo(reportId int) (err error) {
  419. defer func() {
  420. if err != nil {
  421. utils.FileLog.Error("UpdateReportVideo, reportId:%s, Err:%s", strconv.Itoa(reportId), err.Error())
  422. go alarm_msg.SendAlarmMsg("更新报告音频失败, 报告ID: "+strconv.Itoa(reportId)+", Err: "+err.Error(), 3)
  423. //go utils.SendEmail(utils.APPNAME+"【"+utils.RunMode+"】"+"失败提醒", "更新报告音频失败, 报告ID: " + reportIdStr + ", Err: "+err.Error(), utils.EmailSendToUsers)
  424. }
  425. }()
  426. if reportId == 0 {
  427. return
  428. }
  429. reportInfo, err := models.GetReportByReportId(reportId)
  430. if err != nil {
  431. return
  432. }
  433. if reportInfo.HasChapter == 1 {
  434. // 更新章节音频
  435. chapterList, tmpErr := models.GetPublishedChapterListByReportId(reportInfo.Id)
  436. if tmpErr != nil {
  437. err = tmpErr
  438. return
  439. }
  440. chapterIdArr := make([]int, 0)
  441. for i := 0; i < len(chapterList); i++ {
  442. chapterIdArr = append(chapterIdArr, chapterList[i].ReportChapterId)
  443. }
  444. //go UpdateChaptersVideo(chapterIds)
  445. err = UpdateChaptersVideo(chapterIdArr)
  446. } else {
  447. // 更新报告音频
  448. if reportInfo.VideoUrl != "" {
  449. return
  450. }
  451. nowTime := time.Now()
  452. updateCols := make([]string, 0)
  453. updateCols = append(updateCols, "VideoUrl", "VideoName", "VideoSize", "VideoPlaySeconds")
  454. videoUrl, videoName, videoSize, videoPlaySeconds, tmpErr := CreateReportVideo(reportInfo.Title, html.UnescapeString(reportInfo.Content), nowTime.Format(utils.FormatDateTime))
  455. reportInfo.VideoUrl = videoUrl
  456. reportInfo.VideoName = videoName
  457. reportInfo.VideoSize = videoSize
  458. reportInfo.VideoPlaySeconds = fmt.Sprintf("%.2f", videoPlaySeconds)
  459. tmpErr = reportInfo.UpdateReport(updateCols)
  460. if tmpErr != nil {
  461. err = tmpErr
  462. return
  463. }
  464. }
  465. return
  466. }
  467. func UpdateEmptyVideoReportVideo() (err error) {
  468. list, err := models.GetSyncEmptyVideoReport()
  469. if err != nil {
  470. return
  471. }
  472. listLen := len(list)
  473. if listLen <= 0 {
  474. fmt.Println("无报告需要更新音频")
  475. return
  476. }
  477. fmt.Println("Start 待更新报告音频数: ", listLen)
  478. for i := 0; i < listLen; i++ {
  479. if err = UpdateReportVideo(list[i].Id); err != nil {
  480. fmt.Printf("更新音频失败")
  481. fmt.Println(err.Error())
  482. return
  483. }
  484. }
  485. fmt.Println("End 报告音频更新完毕")
  486. return
  487. }
  488. // checkDayWeekChapterWrite 校验晨周报已写章节与本期应写章节
  489. func checkDayWeekChapterWrite(chapters []*models.ReportChapter, reportType string) (publishReport bool, tips string, publishIdArr, unPublishIdArr []int, err error) {
  490. nowTime := time.Now().Local()
  491. updateTypeArr := make([]int, 0) // 需更新的章节类型IDs
  492. publishIdArr = make([]int, 0) // 需发布的章节IDs
  493. unPublishIdArr = make([]int, 0) // 需取消发布/未发布的章节IDs
  494. // 校验章节内容
  495. if reportType == utils.REPORT_TYPE_DAY {
  496. // 晨报章节不能都为空
  497. isEmpty := true
  498. for i := 0; i < len(chapters); i++ {
  499. if chapters[i].Content != "" && chapters[i].Title != "" {
  500. isEmpty = false
  501. break
  502. }
  503. }
  504. if isEmpty {
  505. err = errors.New("报告章节内容均为空或标题为空,不可发布")
  506. return
  507. }
  508. } else {
  509. // 周报章节需至少有一篇已编辑且有标题
  510. editNum := 0
  511. for i := 0; i < len(chapters); i++ {
  512. if chapters[i].IsEdit == 1 && chapters[i].Title != "" {
  513. editNum += 1
  514. }
  515. }
  516. if editNum == 0 {
  517. err = errors.New("报告均未编辑或标题为空,不可发布")
  518. return
  519. }
  520. }
  521. // 章节类型列表
  522. types, e := models.GetReportChapterTypeListByResearchType(reportType)
  523. if e != nil {
  524. err = errors.New("获取章节类型列表失败")
  525. return
  526. }
  527. // 本期需更新的章节IDs
  528. typeLen := len(types)
  529. for i := 0; i < typeLen; i++ {
  530. if types[i].IsSet != 1 && types[i].Enabled != 0 {
  531. // 正常更新
  532. updateTypeArr = append(updateTypeArr, types[i].ReportChapterTypeId)
  533. } else {
  534. // 被设置为零值的也算作正常更新
  535. if types[i].PauseStartTime == utils.EmptyDateStr && types[i].PauseEndTime == utils.EmptyDateStr {
  536. updateTypeArr = append(updateTypeArr, types[i].ReportChapterTypeId)
  537. continue
  538. }
  539. // 暂停更新需校验时间
  540. startTime, _ := time.Parse(utils.FormatDate, types[i].PauseStartTime)
  541. endTime, _ := time.Parse(utils.FormatDate, types[i].PauseEndTime)
  542. if nowTime.Before(startTime) || nowTime.After(endTime.AddDate(0, 0, 1)) {
  543. updateTypeArr = append(updateTypeArr, types[i].ReportChapterTypeId)
  544. }
  545. }
  546. }
  547. // 校验本期需更新的章节是否都已编辑
  548. chapterLen := len(chapters)
  549. updateTypeLen := len(updateTypeArr)
  550. tipsArr := make([]string, 0)
  551. for i := 0; i < chapterLen; i++ {
  552. isWrite := false
  553. for ii := 0; ii < updateTypeLen; ii++ {
  554. // 本期应发布的章节
  555. if chapters[i].TypeId == updateTypeArr[ii] {
  556. // 标题或者内容为空的情况下, 记录tips提示信息且不发布该章节
  557. if chapters[i].Title == "" || chapters[i].Content == "" {
  558. tipsArr = append(tipsArr, chapters[i].TypeName)
  559. break
  560. }
  561. isWrite = true
  562. break
  563. }
  564. }
  565. if isWrite {
  566. publishIdArr = append(publishIdArr, chapters[i].ReportChapterId)
  567. } else {
  568. unPublishIdArr = append(unPublishIdArr, chapters[i].ReportChapterId)
  569. }
  570. }
  571. if len(tipsArr) > 0 {
  572. tips = "部分章节未发布:" + strings.Join(tipsArr, "、") + "未填写标题/内容"
  573. }
  574. // 周报需发布的章节与需更新的章节数相等则表示可发布整期, 晨报无限制
  575. if reportType == utils.REPORT_TYPE_DAY {
  576. publishReport = true
  577. } else {
  578. if len(publishIdArr) == updateTypeLen {
  579. publishReport = true
  580. }
  581. }
  582. return
  583. }
  584. // PcCreateAndUploadSunCode 生成太阳码并上传OSS
  585. func PcCreateAndUploadSunCode(scene, page string) (imgUrl string, err error) {
  586. if page == "" {
  587. err = errors.New("page不能为空")
  588. return
  589. }
  590. // scene超过32位会生成失败,md5处理至32位
  591. sceneMD5 := "a=1"
  592. if scene != "" {
  593. sceneMD5 = utils.MD5(scene)
  594. }
  595. picByte, err := GetSunCode(page, sceneMD5)
  596. if err != nil {
  597. return
  598. }
  599. // 生成图片
  600. localPath := "./static/imgs"
  601. fileName := utils.GetRandStringNoSpecialChar(28) + ".png"
  602. fpath := fmt.Sprint(localPath, "/", fileName)
  603. f, err := os.Create(fpath)
  604. if err != nil {
  605. fmt.Println("11111")
  606. return
  607. }
  608. if _, err = f.Write(picByte); err != nil {
  609. return
  610. }
  611. defer func() {
  612. f.Close()
  613. os.Remove(fpath)
  614. }()
  615. // 上传OSS
  616. fileDir := "yb/suncode/"
  617. //上传到阿里云 和 minio
  618. //if utils.ObjectStorageClient == "minio" {
  619. // imgUrl, err = UploadMinIoToDir(fileName, fpath, "", fileDir)
  620. // if err != nil {
  621. // return
  622. // }
  623. //} else {
  624. // imgUrl, err = UploadAliyunToDir(fileName, fpath, "", fileDir)
  625. // if err != nil {
  626. // return
  627. // }
  628. //}
  629. savePath := fileDir + time.Now().Format("200601/20060102/") + fileName
  630. ossClient := NewOssClient()
  631. if ossClient == nil {
  632. err = fmt.Errorf("初始化OSS服务失败")
  633. return
  634. }
  635. imgUrl, err = ossClient.UploadFile(fileName, fpath, savePath)
  636. if err != nil {
  637. err = fmt.Errorf("文件上传失败, Err: %s", err.Error())
  638. return
  639. }
  640. if err != nil {
  641. return
  642. }
  643. // 记录参数
  644. if scene != "" {
  645. newSuncode := &models.YbPcSuncode{
  646. Scene: scene,
  647. SceneMd5: sceneMD5,
  648. CodePage: page,
  649. SuncodeUrl: imgUrl,
  650. CreateTime: time.Now(),
  651. }
  652. err = models.AddYbPcSunCode(newSuncode)
  653. }
  654. // 记录参数md5
  655. if scene != "" {
  656. newPars := &models.YbSuncodePars{
  657. Scene: scene,
  658. SceneKey: sceneMD5,
  659. CreateTime: time.Now(),
  660. }
  661. err = models.AddYbSuncodePars(newPars)
  662. }
  663. return
  664. }
  665. // CreateNewReport 创建新报告
  666. func CreateNewReport(req models.AddReq, adminInfo *system.Admin) (newReportId int64, reportCode, errMsg string, err error) {
  667. contentSub := ""
  668. if req.Content != "" {
  669. e := utils.ContentXssCheck(req.Content)
  670. if e != nil {
  671. errMsg = "存在非法标签"
  672. err = errors.New("存在非法标签, Err: " + e.Error())
  673. return
  674. }
  675. contentClean, e := FilterReportContentBr(req.Content)
  676. if e != nil {
  677. errMsg = "内容去除前后空格失败"
  678. err = errors.New("内容去除前后空格失败, Err: " + e.Error())
  679. return
  680. }
  681. req.Content = contentClean
  682. sub, e := GetReportContentSub(req.Content)
  683. if e != nil {
  684. go alarm_msg.SendAlarmMsg("ContentSub 失败,Err:"+e.Error(), 3)
  685. }
  686. contentSub = sub
  687. }
  688. maxStage, e := models.GetReportStage(req.ClassifyIdFirst, req.ClassifyIdSecond, req.ClassifyIdThird)
  689. if e != nil {
  690. errMsg = "期数获取失败!"
  691. err = errors.New("期数获取失败,Err:" + e.Error())
  692. return
  693. }
  694. item := new(models.Report)
  695. item.AddType = req.AddType
  696. item.ClassifyIdFirst = req.ClassifyIdFirst
  697. item.ClassifyNameFirst = req.ClassifyNameFirst
  698. item.ClassifyIdSecond = req.ClassifyIdSecond
  699. item.ClassifyNameSecond = req.ClassifyNameSecond
  700. item.Title = req.Title
  701. item.Abstract = req.Abstract
  702. item.Author = req.Author
  703. item.Frequency = req.Frequency
  704. item.State = req.State
  705. item.Content = html.EscapeString(req.Content)
  706. item.Stage = maxStage + 1
  707. item.ContentSub = html.EscapeString(contentSub)
  708. item.CreateTime = req.CreateTime
  709. item.ModifyTime = time.Now()
  710. item.ReportVersion = req.ReportVersion
  711. item.AdminId = adminInfo.AdminId
  712. item.AdminRealName = adminInfo.RealName
  713. item.ClassifyIdThird = req.ClassifyIdThird
  714. item.ClassifyNameThird = req.ClassifyNameThird
  715. // 产品要求,如果是多人协作,那么就是章节类型的报告
  716. if req.CollaborateType == 2 {
  717. item.HasChapter = 1
  718. item.ChapterType = ""
  719. }
  720. item.LastModifyAdminId = adminInfo.AdminId
  721. item.LastModifyAdminName = adminInfo.RealName
  722. item.ContentModifyTime = time.Now()
  723. item.NeedSplice = 1
  724. item.ContentStruct = html.EscapeString(req.ContentStruct)
  725. item.HeadImg = req.HeadImg
  726. item.EndImg = req.EndImg
  727. item.CanvasColor = req.CanvasColor
  728. item.HeadResourceId = req.HeadResourceId
  729. item.EndResourceId = req.EndResourceId
  730. item.CollaborateType = req.CollaborateType
  731. item.ReportLayout = req.ReportLayout
  732. item.IsPublicPublish = req.IsPublicPublish
  733. item.ReportCreateTime = time.Now()
  734. err, errMsg = AddReportAndChapter(item, 0, req.GrantAdminIdList)
  735. return
  736. }
  737. // FilterReportContentBr 过滤报告正文前后换行符
  738. func FilterReportContentBr(content string) (res string, err error) {
  739. newContent := content
  740. //content = `<p style=\"font-size: 16px;\"><br></p><p style=\"font-size: 16px;\"><br></p><p style=\"font-size: 16px;\"><br></p><p style=\"font-size: 16px;\"><br></p><p style=\"font-size: 16px;\"><br></p><p style=\"font-size: 16px;\"><br></p><p style=\"font-size: 16px;\"><br></p><p style=\"font-size: 16px;\"><br></p><p style=\"font-size: 16px;\"><br></p><p style=\"font-size: 16px;\"><strong>四季度验证投产预期</strong></p><p style=\"font-size: 16px;\"><strong>&nbsp;</strong></p><p style=\"font-size: 16px;\"><strong>PTA:<strong><strong>近端短缺的格局出现缓解的迹象,表现在:PX进口回升;国内重整及常减压提负;PTA、PX投产在即</strong></strong><strong>。正套部分或全部止盈。</strong></strong></p><p style=\"font-size: 16px;\"><strong>&nbsp;</strong></p><p style=\"font-size: 16px;\"><strong>乙二醇:</strong><strong style=\"font-weight: 700; color: rgb(0, 0, 0); font-family: ;\">到港预报集中的情况下仍在去库,4200-4600区间震荡操作,节前没有明显方向,不建议在节前备货的时间段布局空单</strong><strong>。</strong></p><p style=\"font-size: 16px;\"><strong>&nbsp;</strong></p><p style=\"font-size: 16px;\"><strong>1、PX国内供应本周回落,PTA工厂负荷变动滞后于PX装置。</strong></p><p style=\"font-size: 16px;\">PX装置变动:</p><p style=\"font-size: 16px;\">海南炼化一期66万吨PX装置因故障停车检修,重启时间待跟踪,其二期100万吨PX装置预计在此装置重启后停车检修。</p><p style=\"font-size: 16px;\">天津石化一套100万吨重整已于20日重启中,其39万吨PX预计下周初出产品。</p><p style=\"font-size: 16px;\">韩国SK 位于仁川的130万吨PX装置按计划在23日停车检修,计划检修时长45天左右。</p><p style=\"font-size: 16px;\">截至周五,中国国内PX负荷小幅回落至73.4%(前值<span style=\"color: rgb(65, 65, 65); font-family: sans-serif; font-size: 16px; font-style: normal; font-variant-ligatures: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; orphans: 2; text-align: left; text-indent: 0px; text-transform: none; white-space: normal; widows: 2; word-spacing: 0px; -webkit-text-stroke-width: 0px; background-color: rgb(255, 255, 255); text-decoration-thickness: initial; text-decoration-style: initial; text-decoration-color: initial; display: inline !important; float: none;\">76.8</span>%),亚洲PX负荷小幅回落至68.7%(<span style=\"color: rgb(65, 65, 65); font-family: sans-serif; font-size: 16px; font-style: normal; font-variant-ligatures: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; orphans: 2; text-align: left; text-indent: 0px; text-transform: none; white-space: normal; widows: 2; word-spacing: 0px; -webkit-text-stroke-width: 0px; background-color: rgb(255, 255, 255); text-decoration-thickness: initial; text-decoration-style: initial; text-decoration-color: initial; display: inline !important; float: none;\">72</span>%)。</p><p style=\"font-size: 16px;\"><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220925/4VcA2eUE1Sgkx0KQ0NjchM0ajIis.png\" class=\"fr-fic fr-dib fr-draggable\"></p><p style=\"font-size: 16px;\"><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220925/vi3laEb3qejWISetD0SjGTwuAxUg.png\" class=\"fr-fic fr-dib fr-draggable\"></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=760c86a78c35ab9286903e9ce52a6682\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=1e36d11158bf146313f3f65a65dbc5f3\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=7a69494b1a84520b2cdf1dccb3c78bda\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=0a2e374c0689d5fba4a9dc40474a33b0\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></p><p style=\"font-size: 16px;\">PXN本周延续回落至380美金附近。</p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=ad1b869f60ab31060730e8bd58260d8c\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=d1c87cb3adff22aea0fc37dfb1870626\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=bac98256b0b86e92ed4084fbbd223f5b\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><span style=\"font-size: 16px; font-family: Arial, Helvetica, sans-serif;\">PX平衡表</span></p><p style=\"margin: 0px; padding: 0px; font-size: 16px; color: rgb(0, 0, 0); font-family: ;\">海关统计,国内8月PX进口总量在78.8万吨,环比增加17.3万吨,增幅28%;同比减少30.8万吨,降幅28.1%;8月PX出口量0.47万吨,环比下降5万吨。</p><p style=\"margin: 0px; padding: 0px; font-size: 16px; color: rgb(0, 0, 0); font-family: ;\"><span style=\"color: rgb(0, 0, 0); font-family: ;\">PX 8月进口量大幅回升至79万吨附近,其中8月从韩国进口的PX量达到33.65万吨。9月目前公布的1-20号从韩国进口PX的量已经接近8月全月的水平,即环比8月仍是大幅增加的情况:</span><span style=\"font-size: 16px;\">据悉,9月1-20日韩国PX出口总量在30.9万吨,其中出口至中国27.9万吨。</span></p><p style=\"margin: 0px; padding: 0px; font-size: 16px; color: rgb(0, 0, 0); font-family: ;\"><span style=\"font-size: 16px;\">预计9月进口量环比8月进一步增加。</span></p><p style=\"margin: 0px; padding: 0px; font-size: 16px; color: rgb(0, 0, 0); font-family: ;\"><span style=\"font-size: 16px;\"><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220925/TD59rptBDNwJ7J2qpxd8HXi4X5cQ.png\" class=\"fr-fic fr-dib fr-draggable\"></span></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><strong><span style=\"color: rgb(0, 0, 0); font-family: ;\">原油本周偏弱,欧美汽油利润本周均出现了明显回升。</span></strong></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><strong><span style=\"color: rgb(0, 0, 0); font-family: ;\"><span style=\"color: rgb(34, 34, 34); font-family: system-ui, -apple-system, BlinkMacSystemFont, ;\">美国飓风将在下周登陆墨西哥湾,届时或将影响海上钻机的运行以及炼厂开工。</span>&nbsp;</span></strong></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=ef172d65e20b986351ed50545f3d36d1\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=4930c0981fc33ab125e6ef346c9cbd5b\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=f0cae34883508273d482d4cf8c577410\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><strong>2、</strong><strong>乙烯连续跌价至900美金,PX投产压力临近PXN延续压缩。石脑油亏损本周延续修复。</strong></p><p style=\"font-size: 16px;\">PTA:按照PX11-12月上1054美金(石脑油672美金,Brent86.15美金)计算,醋酸3075元,目前含醋酸的原料成本在5670元附近。可以发现虽然Brent和PX环比上周都出现了明显的下跌,但石脑油相对上周环比上涨,石脑油亏损本周延续修复,目前石脑油-Brent价差回升至0以上。</p><p style=\"font-size: 16px;\">给到200-300的最低加工成本,PTA的估值在5870-5970元。周五日盘收盘后TA11合约5742,11月及之后的PTA合约均亏损。</p><p style=\"font-size: 16px;\">PTA基差再度回升至1000附近,周五小幅走弱至970。</p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=3e743a3907292d9ad2dce6033ae7d8a4\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220925/Csak38HlAbt8XsbBsPeSWlaUKJiO.png\" class=\"fr-fic fr-dib fr-draggable\"></p><p style=\"font-size: 16px;\"><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220925/LOPKDaDnRnbJauWqlvbhQ5VNxa03.png\" class=\"fr-fic fr-dib fr-draggable\"></p><p style=\"font-size: 16px;\"><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220925/Ocdq2m3bMDqZnM8PTXVyj8XILt7Z.png\" class=\"fr-fic fr-dib fr-draggable\"></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=268b3f7204aa21accb8d292154cf4e3c\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></p><p style=\"font-size: 16px;\">乙二醇:静态来看,按照盘面(煤价按照900元),锚定石脑油672美金,乙烯900美金,甲醇2640元,北美乙烷价格38美分/加仑计算,乙二醇的综合成本仍在5050元附近。周五日盘收盘01合约按照综合成本亏损700元附近。</p><p style=\"font-size: 16px;\">国内外采乙烷制乙二醇目前扭亏为盈。</p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=f1e3ba1df230353571d00af2dfb7e92a\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=0d17c186dda211dab039f2ccd39a8d76\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=3a93cb16f02731bc5c74b560f9590456\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=e1a38d9058b719d8dd5bf746bc9739be\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220925/drjYJ468Tpnr3Bno52CQZXRuayow.png\" class=\"fr-fic fr-dib fr-draggable\"></p><p style=\"font-size: 16px;\"><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220925/bv4JvZN7OxhXFnx0xL0EW6yGFlX8.png\" class=\"fr-fic fr-dib fr-draggable\"></p><p style=\"font-size: 16px;\"><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220918/54TYCFo1ulvOhbJpk9jQPJcnDyan.png\" class=\"fr-fic fr-dib fr-draggable\"></p><p style=\"font-size: 16px;\"><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220925/fZayI9g8kS2ILeVu799dBnAdugNB.png\" class=\"fr-fic fr-dib fr-draggable\"></p><ol style=\"margin: 0px; padding: 0px; list-style: none; color: rgb(0, 0, 0); font-family: ;\"><li style=\"margin: 0px; padding: 0px; font-size: 16px;\"><strong>3、</strong><span style=\"font-size: 16px; color: rgb(0, 0, 0); font-family: ;\"><strong>需求端本周仍偏弱:继上周加弹负荷下滑后,本周织造负荷下滑。延续坯布库存回升同时原料库存下降,聚酯连续累库(瓶片低库存优势也明显减弱),两家大厂减产执行过程和节前备货中和,因此减产去库成效甚微</strong><strong>。</strong></span><span style=\"font-size: 16px;\">&nbsp;</span></li><li style=\"margin: 0px; padding: 0px; font-size: 16px;\"><span style=\"font-size: 18px !important; color: rgb(0, 0, 0); font-family: Tahoma, ;\">终端:江浙加弹综合开工微幅回升至77%(前值</span><span style=\"font-size: 16px; color: rgb(0, 0, 0); font-family: Tahoma, ;\">76</span><span style=\"font-size: 18px !important; color: rgb(0, 0, 0); font-family: Tahoma, ;\">%);江浙织机综合开工回落至69%(前值</span><span style=\"font-size: 16px; color: rgb(0, 0, 0); font-family: Tahoma, ;\">71</span><span style=\"font-size: 18px !important; color: rgb(0, 0, 0); font-family: Tahoma, ;\">%);</span><span style=\"font-size: 18px !important; color: rgb(0, 0, 0); font-family: Tahoma, ;\">江浙印染综合开工维持在77%</span><span style=\"font-size: 18px !important; color: rgb(0, 0, 0); font-family: Tahoma, ;\">&nbsp;。</span></li><li style=\"margin: 0px; padding: 0px; font-size: 16px;\"><span style=\"font-size: 18px !important; color: rgb(0, 0, 0); font-family: Tahoma, ;\">本周,涤丝仅周三稍有放量,整体涤丝销售氛围偏弱为主。终端在新订单氛围走弱和成本端偏弱氛围下,原料不再进一步跟进,消化前期备货为主,综合原料备货有所下降。截至目前,原料备货集中在10-15天,偏高备货至10月底。</span></li><li style=\"margin: 0px; padding: 0px; font-size: 16px;\"><span style=\"font-size: 18px !important; color: rgb(0, 0, 0); font-family: Tahoma, ;\">订单情况:近期的织造端新单氛围整体走弱明显,前期较好的圆机和经编工厂尤为明显,出货量也有所放缓,部分工厂生产前期订单为主。</span><br><span style=\"font-size: 18px !important; color: rgb(0, 0, 0); font-family: Tahoma, ;\">直接需求:</span>近期装置轮动检修与重启,长丝大厂陆续执行减产动作,但也有几套切片装置恢复,整体而言聚酯负荷仍以区间波动为主。截至本周五,初步核算聚酯负荷在83.9%(前值84.3%)。</li></ol><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=9c163c32bf7fca689c0067e285eb1a30\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></p><p style=\"font-size: 16px;\">轻纺城成交量节前震荡回升但仍在偏低水平。</p><p style=\"font-size: 16px;\"><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220925/sHBC03ZwLXP1jUK1mDdd0hUjEtQo.png\" class=\"fr-fic fr-dib fr-draggable\"></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=5e2a381802d34c5cf33502d8a9649bd6\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></p><p style=\"text-align: left; margin-top: 10px; font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=e47bcc409b9b7e9178805ac6c4a00bc1\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe><br></p><p style=\"font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=12be062cbc0c61819f99648cef6e2740\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe><br></p><p style=\"font-size: 16px;\"><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=fea70f6d5bf7f1899394be0619cc2da1\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe><br><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=8a50b210b7ebb4fbb890d8ad58a817f6\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe><br><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=800bf3710951ca96c2e5a3693c94a20d\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe><br><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=fd1bff8836af41d0c32d0ed168c8b748\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe><br><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=baf493ba32b3c39e070e24ac5546fd6b\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></p><ul style=\"margin: 0px; padding: 0px; list-style: none; color: rgb(0, 0, 0); font-family: ;\"><li style=\"margin: 0px; padding: 0px; font-size: 16px;\"><strong>4、PTA行情沙盘推演<strong>2022.9.23:</strong><strong>PTA近端短缺的格局出现缓解的迹象,表现在:PX进口回升;国内重整及常减压提负;PTA、PX投产在即</strong></strong><strong>。正套部分或全部止盈。</strong></li></ul><p style=\"font-size: 16px;\"><img style=\"width: 100%;\" src=\"https://hzstatic.hzinsights.com/static/images/202209/20220922/d1HYjIFoBG9L2bGuWrXq7sBPpnT7.png\" class=\"fr-fic fr-dii fr-draggable\"><br></p><p style=\"font-size: 16px;\">PTA库存结构变化跟踪:本期PTA库存大幅去化17.9万吨附近(本周仓单集中注销,仓单库存大幅下降至0附近),聚酯成品折算PTA库存大幅累库9.3万吨,叠加PTA库存在聚酯成品库存累库的情况下去库8.6万吨。</p><p style=\"font-size: 16px;\"><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220925/qYivQYoLkxJrmWGI5kNOy8i05q8P.png\" class=\"fr-fic fr-dib fr-draggable\"><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220925/cvLkXlLwczkvzktkN4R2SKCoHFby.png\" class=\"fr-fic fr-dib fr-draggable\" style=\"width: 572px;\"></p><p style=\"font-size: 16px;\"><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220925/EzRc4yuCqVcbdw2lb5FS2MCWvHd1.png\" class=\"fr-fic fr-dib fr-draggable\" style=\"width: 595px;\"></p><p style=\"font-size: 16px;\">PTA平衡表——按照Q4有500万吨新装置投产(东营威联化学250万吨及嘉通能源250万吨分别在11、12月计入产能基数)计算,按照9-10月聚酯月均负荷84%(下调1%)、87%(下调1%)预估,8-12月出口预计25万吨附近。8-10月目前预估均为去库格局。</p><p style=\"font-size: 16px;\">PX折算PTA与PTA合计9月去库幅度修正后大幅收窄。</p><p style=\"font-size: 16px;\"><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220925/6VzQkr5nkbeqlCakRzTvZgl1PeFE.png\" class=\"fr-fic fr-dib fr-draggable\"></p><p style=\"margin: 0px; padding: 0px; font-size: 16px;\"><br></p><p style=\"margin: 0px; padding: 0px; font-size: 16px;\"><strong style=\"color: rgb(0, 0, 0); font-family: ;\">5、</strong><strong style=\"color: rgb(0, 0, 0); font-family: ;\">乙二醇行情沙盘推演2022.9.23:到港预报集中的情况下仍在去库,4200-4600区间震荡操作,节前没有明显方向,不建议在节前备货的时间段布局空单。</strong></p><p style=\"margin: 0px; padding: 0px; font-size: 16px;\"><strong style=\"color: rgb(0, 0, 0); font-family: ;\"><img style=\"width: 100%;\" src=\"https://hzstatic.hzinsights.com/static/images/202209/20220916/e5XTMMmx04X6wpKITZ2NgjUyz8sI.png\" class=\"fr-fic fr-dii fr-draggable\"></strong><br></p><p style=\"margin: 0px; padding: 0px; font-size: 16px;\">乙二醇国内供需:</p><ul style=\"margin: 0px; padding: 0px; list-style: none; color: rgb(0, 0, 0); font-family: ;\"><li style=\"margin: 0px; padding: 0px; font-size: 16px;\"><span style=\"color: rgb(0, 0, 0); font-family: Arial, Helvetica, sans-serif; font-style: normal; font-variant-ligatures: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; orphans: 2; text-align: start; text-indent: 28px; text-transform: none; white-space: normal; widows: 2; word-spacing: 0px; -webkit-text-stroke-width: 0px; background-color: rgb(255, 255, 255); text-decoration-thickness: initial; text-decoration-style: initial; text-decoration-color: initial; float: none; display: inline !important;\">乙二醇负荷低位仍在下降:截至9月22日,中国大陆地区乙二醇整体开工负荷在43.98%(较上期下降2.44%),其中煤制乙二醇开工负荷在28.67%(较上期下降2.08%)。</span><span style=\"font-family: Arial, Helvetica, sans-serif;\">&nbsp;</span></li><li style=\"margin: 0px; padding: 0px; font-size: 16px;\"><span style=\"font-family: Arial, Helvetica, sans-serif;\">后续供应存增加预期:</span></li><li style=\"margin: 0px; padding: 0px; font-size: 16px;\"><span style=\"font-family: Arial, Helvetica, sans-serif;\">上周意外停车的大连大型装置预计本周末或下周初开车。</span></li><li style=\"margin: 0px; padding: 0px; font-size: 16px;\"><span style=\"font-family: Arial, Helvetica, sans-serif;\">内蒙古40万吨装置装置周内正常出料,负荷回升中。</span></li><li style=\"margin: 0px; padding: 0px; font-size: 16px;\"><span style=\"font-family: Arial, Helvetica, sans-serif;\">陕西30万吨装置将于近日重启,预计9月底前后出料;内蒙古26万吨装置计划本月底前后投料重启。</span></li><li style=\"margin: 0px; padding: 0px; font-size: 16px;\"><span style=\"font-family: Arial, Helvetica, sans-serif;\"><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220925/Yy4lTK54zBA3ifN4DFdpAhE1TQ4w.png\" class=\"fr-fic fr-dib fr-draggable\"></span><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220925/eXC4GZApxmJQLQSZZ15HV6J1nGdK.png\" class=\"fr-fic fr-dib fr-draggable\"></li></ul><p style=\"font-size: 16px;\">乙二醇到港预报与实际到港:</p><p style=\"font-size: 16px;\"><span style=\"font-size: 16px; color: rgb(0, 0, 0); font-style: normal; font-variant-ligatures: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; orphans: 2; text-align: start; text-transform: none; white-space: normal; widows: 2; word-spacing: 0px; -webkit-text-stroke-width: 0px; background-color: rgb(255, 255, 255); text-decoration-thickness: initial; text-decoration-style: initial; text-decoration-color: initial; font-family: Arial, Helvetica, sans-serif; text-indent: 32px; float: none; display: inline !important;\"><span style=\"color: rgb(0, 0, 0); font-style: normal; font-variant-ligatures: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; orphans: 2; text-align: left; text-indent: 32px; text-transform: none; white-space: normal; widows: 2; word-spacing: 0px; -webkit-text-stroke-width: 0px; text-decoration-thickness: initial; text-decoration-style: initial; text-decoration-color: initial; float: none; display: inline !important;\">隆众口径:截至9月29日,国内乙二醇华东总到港量预计在19.21万吨,较上一期增加3.45万吨,提升21.93个百分点。</span>&nbsp;</span></p><p style=\"font-size: 16px;\"><span style=\"font-size: 16px; color: rgb(0, 0, 0); font-style: normal; font-variant-ligatures: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; orphans: 2; text-align: start; text-transform: none; white-space: normal; widows: 2; word-spacing: 0px; -webkit-text-stroke-width: 0px; background-color: rgb(255, 255, 255); text-decoration-thickness: initial; text-decoration-style: initial; text-decoration-color: initial; font-family: Arial, Helvetica, sans-serif; text-indent: 32px; float: none; display: inline !important;\">港口发货节前回升。</span></p><p style=\"font-size: 16px;\"><br></p><p style=\"font-size: 16px;\"><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220925/WXVwl3NV0U68hnEjeNX5RFPGowq3.png\" class=\"fr-fic fr-dib fr-draggable\"></p><p style=\"font-size: 16px;\"><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220925/2FuGYgp5dpx6XbCNXLdSzdh4uzvp.png\" class=\"fr-fic fr-dib fr-draggable\"></p><p style=\"font-size: 16px;\">海外装置:</p><p style=\"font-size: 16px;\">印度IOC 32.5万吨装置将于近期停车技改,预计停车将持续至12月份。</p><p style=\"font-size: 16px;\">伊朗 Marun 44.5万吨装置目前处于停车状态,该装置此前货源供应印度市场为主。</p><p style=\"font-size: 16px;\">美国Sasol 28万吨装置计划于10月上旬停车检修,预计检修时长在一个月附近。</p><p style=\"font-size: 16px;\"><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220925/CRzzaHscEcvhW8KXdajvLqABw11g.png\" class=\"fr-fic fr-dib fr-draggable\"></p><ul style=\"margin: 0px; padding: 0px; list-style: none; color: rgb(0, 0, 0); font-family: ;\"><li style=\"margin: 0px; padding: 0px; font-size: 16px;\">库存:</li><li style=\"margin: 0px; padding: 0px; font-size: 16px;\">隆众口径:<span style=\"font-size: 16px; color: rgb(0, 0, 0); font-style: normal; font-variant-ligatures: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; orphans: 2; text-align: start; text-transform: none; white-space: normal; widows: 2; word-spacing: 0px; -webkit-text-stroke-width: 0px; background-color: rgb(255, 255, 255); text-decoration-thickness: initial; text-decoration-style: initial; text-decoration-color: initial; font-family: Arial, Helvetica, sans-serif; text-indent: 32px; float: none; display: inline !important;\">截至9月22日,华东主港地区MEG港口库存总量81.6万吨,较上一统计周期减少3.64万吨,降低4.27%。受周末台风天气影响,主港本周到货延迟且整体出货尚可,本周港口库存延续去库走势。</span></li></ul><ul style=\"margin: 0px; padding: 0px; list-style: none;\"><li style=\"margin: 0px; padding: 0px; color: rgb(0, 0, 0); font-family: ;\">节前备货,聚酯工厂的乙二醇备货量本周小幅回升至84万吨附近。</li><li><br></li><li><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=c13c3e669ae5940893d1fd0e669754a5\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></li><li><iframe src=\"https://chartlib.hzinsights.com/chartshow?code=0fac897a91cbfcdb67958ae9e5d039a7\" width=\"100%\" height=\"350\" style=\"border-width:0px; min-height:350px;\"></iframe></li><li style=\"margin: 0px; padding: 0px;\"><span style=\"font-size: 16px; font-family: Arial, Helvetica, sans-serif;\">乙二醇平衡表:</span></li><li style=\"margin: 0px; padding: 0px; font-size: 16px;\"><span style=\"color: rgb(0, 0, 0); font-style: normal; font-variant-ligatures: normal; font-variant-caps: normal; font-weight: 400; letter-spacing: normal; orphans: 2; text-align: left; text-indent: 0px; text-transform: none; white-space: normal; widows: 2; word-spacing: 0px; -webkit-text-stroke-width: 0px; background-color: rgb(255, 255, 255); text-decoration-thickness: initial; text-decoration-style: initial; text-decoration-color: initial; float: none; display: inline !important;\">2022年8月我国乙二醇当月进口量为598134.40吨,累计进口量为5189987.09吨,进口量环比升4.83%,进口量同比下跌23.97%,累计进口量比去年同期降9.28%。&nbsp;</span></li><li style=\"margin: 0px; padding: 0px; font-size: 16px;\"><span style=\"font-family: Arial, Helvetica, sans-serif;\">按照9-10月聚酯月均负荷84%、87%,8月进口量比预估略多,9月因受到台风影响到港持续延迟,压力预计在9月下旬至9月底显现,因此预计也只有55万吨附近,Q4进口预计仍有差别,10-12月目前预计进口60-65万吨(其中10月或偏多)。</span></li><li style=\"margin: 0px; padding: 0px; font-size: 16px; font-family: Arial, Helvetica, sans-serif;\">进口量调整后,8月去库收窄至16万吨偏下,9月目前预计去库14万吨附近,10月累库压力来自于到港集中及新装置开始贡献产量,11月累库压力来自于需求回落+新装置产量提升。</li><li style=\"margin: 0px; padding: 0px; font-size: 16px; font-family: Arial, Helvetica, sans-serif;\">11-12月警惕供应端的超预期缩量。</li><li style=\"margin: 0px; padding: 0px; font-size: 16px; font-family: Arial, Helvetica, sans-serif;\"><img src=\"https://hongze.oss-accelerate.aliyuncs.com/static/images/202209/20220925/VEW93DsD4vrzXuNUfTMCFiJSU8Y3.png\" class=\"fr-fic fr-dib fr-draggable\"></li></ul><p style=\"font-size: 16px;\"><br></p><p style=\"font-size: 16px;\"><br></p><p style=\"font-size: 16px;\"><br></p><p style=\"font-size: 16px;\"><br></p><p style=\"font-size: 16px;\"><br></p><p style=\"font-size: 16px;\"><br></p><p style=\"font-size: 16px;\"><br></p><p style=\"font-size: 16px;\"><br></p>`
  741. content = html.UnescapeString(content)
  742. if content == "" {
  743. return
  744. }
  745. // 过滤编辑器版权html
  746. content = strings.Replace(content, "<p data-f-id=\"pbf\" style=\"text-align: center; font-size: 14px; margin-top: 30px; opacity: 0.65; font-family: sans-serif;\">Powered by <a href=\"https://www.froala.com/wysiwyg-editor?pb=1\" title=\"Froala Editor\">Froala Editor</a></p>", "", -1)
  747. defer func() {
  748. if err != nil {
  749. go alarm_msg.SendAlarmMsg("过滤报告正文前后换行符及空格失败, ErrMsg: "+err.Error(), 3)
  750. }
  751. }()
  752. // 做一个配置,有问题的时候随时关闭
  753. configKey := "report_filter_br"
  754. conf, e := company.GetConfigDetailByCode(configKey)
  755. if e != nil {
  756. err = errors.New("获取报告过滤配置失败, Err: " + e.Error())
  757. return
  758. }
  759. if conf.ConfigValue != "1" {
  760. return content, nil
  761. }
  762. // 找出所有<p>标签, <p>标签的索引
  763. re := regexp.MustCompile(`(?is:<p(.*?)</p>)`)
  764. arr := re.FindAllString(content, -1)
  765. indexArr := re.FindAllIndex([]byte(content), -1)
  766. // 空<p>正则
  767. emptyRe := `<p[^>]*>(<br>|<br/>)+</p>`
  768. startIsBr := false
  769. countEmptyBr := 0 // 需要连续替换的空<p>总数
  770. lastBrRange := 0 // 最后一个空<p>右侧index, 用来判断是否为连续的空<p>
  771. // 注:以下逻辑只适用于去除前面的空行, 由于编辑器始终会在文章最后面跟上自己的html标签, 此处不再进行后面空行的去除=_=!
  772. for i := range arr {
  773. byteRange := indexArr[i]
  774. if len(byteRange) == 2 {
  775. // 内容开头不为<p>直接跳出遍历, 否则才进行空<p>的判断
  776. if i == 0 && byteRange[0] == 0 {
  777. startIsBr = true
  778. }
  779. if !startIsBr {
  780. break
  781. }
  782. if lastBrRange != 0 {
  783. // 说明不是连续的空<p>, 中间出现了其他标签, 那么结束遍历, 进行最终的文本替换
  784. if lastBrRange != byteRange[0] {
  785. break
  786. }
  787. }
  788. // 正则匹配为空<p>则计数, 记录该空<p>右侧index
  789. m, e := regexp.Match(emptyRe, []byte(arr[i]))
  790. if e != nil {
  791. err = e
  792. return
  793. }
  794. if m {
  795. countEmptyBr += 1
  796. lastBrRange = byteRange[1]
  797. continue
  798. }
  799. // 遍历到该<p>标签不为空了, 结束遍历
  800. break
  801. }
  802. }
  803. if countEmptyBr > 0 {
  804. reg, e := regexp.Compile(emptyRe)
  805. if e != nil {
  806. err = errors.New("正则解析失败, Err: " + e.Error())
  807. return
  808. }
  809. counted := 0 // 已替换数
  810. res = reg.ReplaceAllStringFunc(content, func(s string) string {
  811. counted += 1
  812. if counted <= countEmptyBr {
  813. return ""
  814. } else {
  815. return s
  816. }
  817. })
  818. if res == "" {
  819. res = newContent
  820. }
  821. } else {
  822. res = content
  823. if res == "" {
  824. res = newContent
  825. }
  826. }
  827. return
  828. }
  829. // GetEnglishReportOverview 获取英文研报overview部分
  830. func GetEnglishReportOverview(content string) (res string, err error) {
  831. content = html.UnescapeString(content)
  832. doc, e := goquery.NewDocumentFromReader(strings.NewReader(content))
  833. if e != nil {
  834. err = errors.New("Create Doc Err: " + e.Error())
  835. return
  836. }
  837. target := "overview"
  838. label := "</strong>"
  839. start := -1
  840. end := -1
  841. doc.Find("p").Each(func(i int, s *goquery.Selection) {
  842. h, e := s.Html()
  843. if e != nil {
  844. err = errors.New("Get Html1 Err: " + e.Error())
  845. return
  846. }
  847. h = strings.ToLower(h)
  848. t := s.Text()
  849. t = strings.ToLower(t)
  850. if strings.Contains(h, label) && t != "" && strings.Contains(t, target) {
  851. start = i
  852. }
  853. if start != -1 && end == -1 && i > start && strings.Contains(h, label) {
  854. end = i
  855. }
  856. })
  857. if start != -1 && end != -1 {
  858. doc.Find("p").Each(func(i int, s *goquery.Selection) {
  859. if i > start && i < end {
  860. h, e := s.Html()
  861. if e != nil {
  862. err = errors.New("Get Html2 Err: " + e.Error())
  863. return
  864. }
  865. // 包含iframe则过滤掉
  866. if strings.Contains(h, "iframe") {
  867. return
  868. }
  869. res += `<p>` + h + `</p>`
  870. }
  871. })
  872. }
  873. return
  874. }
  875. // GetReportContentSubWithoutIframe 获取报告正文前几段,过滤iframe
  876. func GetReportContentSubWithoutIframe(content string) (contentSub string, err error) {
  877. content = html.UnescapeString(content)
  878. doc, err := goquery.NewDocumentFromReader(strings.NewReader(content))
  879. if err != nil {
  880. fmt.Println("create doc err:", err.Error())
  881. return
  882. }
  883. label := "iframe"
  884. n := 0
  885. doc.Find("p").Each(func(i int, s *goquery.Selection) {
  886. if n >= 5 {
  887. return
  888. }
  889. n++
  890. h, err := s.Html()
  891. if err != nil {
  892. fmt.Println("get html err", err.Error())
  893. return
  894. }
  895. // 包含iframe则过滤掉
  896. if strings.Contains(h, label) {
  897. return
  898. }
  899. if s.Text() != "" || strings.Contains(h, "src") {
  900. contentSub = contentSub + "<p>" + h + "</p>"
  901. }
  902. })
  903. return
  904. }
  905. // UpdateReportEditMark 更新研报当前更新状态
  906. // status 枚举值 1:编辑中, 2:只做查询,3:完成编辑
  907. func UpdateReportEditMark(reportId, reportChapterId, nowUserId, status int, nowUserName, lang string) (ret models.MarkReportResp, err error) {
  908. //更新标记key
  909. key := fmt.Sprint(`crm:report:edit:`, reportId)
  910. // 章节id不为0则加上章节id
  911. if reportChapterId > 0 {
  912. key = fmt.Sprint(key, ":", reportChapterId)
  913. }
  914. ret.Status = 0
  915. ret.Msg = "无人编辑"
  916. opUserId, e := utils.Rc.RedisInt(key)
  917. var opUser models.MarkReportItem
  918. var classifyNameFirst string
  919. if e != nil {
  920. opUserInfoStr, tErr := utils.Rc.RedisString(key)
  921. if tErr == nil {
  922. tErr = json.Unmarshal([]byte(opUserInfoStr), &opUser)
  923. if tErr == nil {
  924. opUserId = opUser.AdminId
  925. }
  926. }
  927. }
  928. //判断是否是晨报或者周报,如果是则跳过
  929. var reportInfo *models.ReportDetail
  930. classifyNameFirst = opUser.ReportClassifyNameFirst
  931. if reportId > 0 && status != 2 && classifyNameFirst == "" {
  932. //查询报告ID信息
  933. reportInfo, err = models.GetReportById(reportId)
  934. if err != nil {
  935. err = fmt.Errorf("报告不存在")
  936. return
  937. }
  938. classifyNameFirst = reportInfo.ClassifyNameFirst
  939. }
  940. if opUserId > 0 && opUserId != nowUserId {
  941. editor := opUser.Editor
  942. if editor == "" {
  943. //查询账号的用户姓名
  944. otherInfo, e := system.GetSysAdminById(opUserId)
  945. if e != nil {
  946. err = fmt.Errorf("查询其他编辑者信息失败")
  947. return
  948. }
  949. editor = otherInfo.RealName
  950. }
  951. ret.Status = 1
  952. if lang == utils.EnLangVersion {
  953. ret.Msg = fmt.Sprintf("%s is currently editing the report", editor)
  954. } else {
  955. ret.Msg = fmt.Sprintf("当前%s正在编辑报告", editor)
  956. }
  957. ret.Editor = editor
  958. return
  959. }
  960. if status == 1 {
  961. nowUser := &models.MarkReportItem{AdminId: nowUserId, Editor: nowUserName, ReportClassifyNameFirst: classifyNameFirst}
  962. bt, e := json.Marshal(nowUser)
  963. if e != nil {
  964. err = fmt.Errorf("格式化编辑者信息失败")
  965. return
  966. }
  967. if opUserId > 0 {
  968. utils.Rc.Do("SETEX", key, int64(60), string(bt)) //3分钟缓存
  969. } else {
  970. utils.Rc.SetNX(key, string(bt), time.Second*60*1) //3分钟缓存
  971. }
  972. } else if status == 3 {
  973. //完成编辑,开始清除编辑缓存
  974. _ = utils.Rc.Delete(key)
  975. }
  976. return
  977. }
  978. // HandleVideoDecibel 处理报告中的音频文件
  979. func HandleVideoDecibel(chapterInfo *models.ReportChapter) {
  980. public_api.HandleVideoDecibel(chapterInfo.ReportChapterId)
  981. return
  982. }
  983. // SaveReportLogs 记录报告日志
  984. func SaveReportLogs(item *models.Report, chapters []*models.ReportChapter, adminId int, adminRealName string) {
  985. if item == nil && len(chapters) == 0 {
  986. return
  987. }
  988. var err error
  989. defer func() {
  990. if err != nil {
  991. tips := fmt.Sprintf("报告日志记录, SaveReportLogs error: %s", err.Error())
  992. go alarm_msg.SendAlarmMsg(tips, 2)
  993. }
  994. }()
  995. if item != nil {
  996. e := models.AddReportSaveLog(item.Id, item.AdminId, item.Content, item.ContentSub, item.ContentStruct, item.CanvasColor, item.AdminRealName, item.HeadResourceId, item.EndResourceId)
  997. if e != nil {
  998. err = fmt.Errorf("AddReportSaveLog: %s", e.Error())
  999. return
  1000. }
  1001. }
  1002. if len(chapters) > 0 {
  1003. e := models.MultiAddReportChaptersSaveLog(chapters, adminId, adminRealName)
  1004. if e != nil {
  1005. err = fmt.Errorf("MultiAddReportChaptersSaveLog: %s", e.Error())
  1006. return
  1007. }
  1008. }
  1009. return
  1010. }