report.go 51 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763
  1. package services
  2. import (
  3. "encoding/json"
  4. "errors"
  5. "eta/eta_mobile/models"
  6. "eta/eta_mobile/models/company"
  7. "eta/eta_mobile/models/system"
  8. "eta/eta_mobile/services/alarm_msg"
  9. "eta/eta_mobile/services/public_api"
  10. "eta/eta_mobile/utils"
  11. "fmt"
  12. "github.com/PuerkitoBio/goquery"
  13. "html"
  14. "os"
  15. "regexp"
  16. "strconv"
  17. "strings"
  18. "time"
  19. )
  20. func GetReportContentSub(content string) (contentSub string, err error) {
  21. content = html.UnescapeString(content)
  22. doc, err := goquery.NewDocumentFromReader(strings.NewReader(content))
  23. if err != nil {
  24. fmt.Println("create doc err:", err.Error())
  25. return
  26. }
  27. n := 0
  28. doc.Find("p").Each(func(i int, s *goquery.Selection) {
  29. if n >= 5 {
  30. return
  31. }
  32. n++
  33. phtml, err := s.Html()
  34. if err != nil {
  35. fmt.Println("get html err", err.Error())
  36. return
  37. }
  38. if s.Text() != "" || strings.Contains(phtml, "src") {
  39. contentSub = contentSub + "<p>" + phtml + "</p>"
  40. }
  41. })
  42. return
  43. }
  44. // PublishDayWeekReport 发布晨周报
  45. func PublishDayWeekReport(reportId int) (tips string, err error) {
  46. if utils.BusinessCode != utils.BusinessCodeRelease && utils.BusinessCode != utils.BusinessCodeSandbox {
  47. return
  48. }
  49. report, err := models.GetReportByReportId(reportId)
  50. if err != nil {
  51. return
  52. }
  53. if report.State == 2 {
  54. return
  55. }
  56. chapters, err := models.GetChapterListByReportId(reportId)
  57. if err != nil {
  58. return
  59. }
  60. chapterLen := len(chapters)
  61. if chapterLen <= 0 {
  62. err = errors.New("报告章节为空,不可发布")
  63. return
  64. }
  65. reportType := chapters[0].ReportType
  66. // 校验章节
  67. publishReport, tips, publishIdArr, unPublishIdArr, err := checkDayWeekChapterWrite(chapters, reportType)
  68. if err != nil {
  69. return
  70. }
  71. publishLen := len(publishIdArr)
  72. if publishLen <= 0 {
  73. err = errors.New("报告章节均不可发布")
  74. return
  75. }
  76. // 需发布整期
  77. updateCols := make([]string, 0)
  78. if publishReport {
  79. updateCols = append(updateCols, "Title", "State", "ModifyTime")
  80. // 发布后标题调整
  81. title := report.Title
  82. title = strings.ReplaceAll(title, "【弘则FICC晨报】", "")
  83. title = strings.ReplaceAll(title, "【弘则FICC周报】", "")
  84. if title == "" {
  85. // 取第一个需发布章节的标题
  86. firstId := publishIdArr[0]
  87. firstTitle := ""
  88. for i := 0; i < chapterLen; i++ {
  89. if chapters[i].ReportChapterId == firstId {
  90. firstTitle = chapters[i].Title
  91. break
  92. }
  93. }
  94. title = firstTitle
  95. }
  96. report.Title = title
  97. report.State = 2
  98. // 研报后台4.4 只在没有发布过时更新发布时间,其余均按模版消息发送时间当作发布时间
  99. if report.MsgIsSend == 0 || report.PublishTime.IsZero() {
  100. report.PublishTime = time.Now().Local()
  101. updateCols = append(updateCols, "PublishTime")
  102. }
  103. report.ModifyTime = time.Now().Local()
  104. }
  105. publishIdStr := utils.IntArr2joinString(publishIdArr, ",")
  106. unPublishIdStr := utils.IntArr2joinString(unPublishIdArr, ",")
  107. if e := models.PublishReportAndChapter(report, publishIdStr, unPublishIdStr, publishReport, updateCols); e != nil {
  108. err = errors.New("发布报告及章节失败")
  109. return
  110. }
  111. // 生成章节音频
  112. go func() {
  113. _ = UpdateChaptersVideo(publishIdStr)
  114. }()
  115. // 更新报告ES
  116. go func() {
  117. _ = UpdateReportEs(report.Id, 2)
  118. }()
  119. // 发布时备份内容
  120. go SaveReportLogs(report, chapters, report.AdminId, report.AdminRealName)
  121. return
  122. }
  123. // UpdateChaptersVideo 更新章节音频
  124. func UpdateChaptersVideo(chapterIds string) (err error) {
  125. defer func() {
  126. if err != nil {
  127. utils.FileLog.Error("UpdateChaptersVideo, chapterIds:%s, Err:%s", chapterIds, err.Error())
  128. go alarm_msg.SendAlarmMsg("更新章节音频失败, 章节ID: "+chapterIds+", Err: "+err.Error(), 3)
  129. }
  130. }()
  131. if chapterIds == "" {
  132. return
  133. }
  134. chapterList, err := models.GetChapterListByChapterIds(chapterIds)
  135. if err != nil {
  136. return
  137. }
  138. // 生成video
  139. nowTime := time.Now()
  140. updateCols := make([]string, 0)
  141. updateCols = append(updateCols, "VideoUrl", "VideoName", "VideoSize", "VideoPlaySeconds")
  142. for i := 0; i < len(chapterList); i++ {
  143. item := chapterList[i]
  144. // 忽略已有音频的章节
  145. if item.VideoUrl != "" && item.VideoName != "" && item.VideoSize != "" && item.VideoPlaySeconds != "" {
  146. continue
  147. }
  148. videoUrl, videoName, videoSize, videoPlaySeconds, e := CreateReportVideo(item.Title, html.UnescapeString(item.Content), nowTime.Format(utils.FormatDateTime))
  149. if e != nil {
  150. err = e
  151. return
  152. }
  153. item.VideoUrl = videoUrl
  154. item.VideoName = videoName
  155. item.VideoSize = videoSize
  156. item.VideoPlaySeconds = fmt.Sprintf("%.2f", videoPlaySeconds)
  157. if e = item.UpdateChapter(updateCols); e != nil {
  158. err = e
  159. }
  160. }
  161. return
  162. }
  163. // UpdateReportEs 更新报告/章节Es
  164. func UpdateReportEs(reportId int, publishState int) (err error) {
  165. if reportId <= 0 {
  166. return
  167. }
  168. reportInfo, err := models.GetReportByReportId(reportId)
  169. if err != nil {
  170. return
  171. }
  172. categories := ""
  173. if reportInfo.HasChapter == 1 {
  174. // 晨周报
  175. chapterList, tmpErr := models.GetPublishedChapterListByReportId(reportInfo.Id)
  176. if tmpErr != nil {
  177. return
  178. }
  179. if len(chapterList) > 0 {
  180. for i := 0; i < len(chapterList); i++ {
  181. // 章节对应的品种
  182. permissionList := make([]*models.ReportChapterTypePermission, 0)
  183. if utils.BusinessCode == utils.BusinessCodeRelease || utils.BusinessCode == utils.BusinessCodeSandbox {
  184. permissionList, tmpErr = models.GetChapterTypePermissionByTypeIdAndResearchType(chapterList[i].TypeId, chapterList[i].ReportType)
  185. if tmpErr != nil {
  186. return
  187. }
  188. }
  189. categoryArr := make([]string, 0)
  190. if len(permissionList) > 0 {
  191. for ii := 0; ii < len(permissionList); ii++ {
  192. categoryArr = append(categoryArr, permissionList[ii].PermissionName)
  193. }
  194. }
  195. aliasArr, _ := addCategoryAliasToArr(categoryArr)
  196. chapterCategories := strings.Join(aliasArr, ",")
  197. esChapter := &models.ElasticReportDetail{
  198. ReportId: chapterList[i].ReportId,
  199. ReportChapterId: chapterList[i].ReportChapterId,
  200. Title: chapterList[i].Title,
  201. Abstract: chapterList[i].Abstract,
  202. BodyContent: utils.TrimHtml(html.UnescapeString(chapterList[i].Content)),
  203. PublishTime: chapterList[i].PublishTime.Format(utils.FormatDateTime),
  204. PublishState: chapterList[i].PublishState,
  205. Author: chapterList[i].Author,
  206. ClassifyIdFirst: chapterList[i].ClassifyIdFirst,
  207. ClassifyNameFirst: chapterList[i].ClassifyNameFirst,
  208. ClassifyIdSecond: 0,
  209. ClassifyNameSecond: "",
  210. Categories: chapterCategories,
  211. StageStr: strconv.Itoa(chapterList[i].Stage),
  212. }
  213. chapterDocId := fmt.Sprintf("%d-%d", reportInfo.Id, chapterList[i].ReportChapterId)
  214. if err = EsAddOrEditReport(utils.EsReportIndexName, chapterDocId, esChapter); err != nil {
  215. return
  216. }
  217. }
  218. }
  219. } else {
  220. if utils.BusinessCode == utils.BusinessCodeRelease || utils.BusinessCode == utils.BusinessCodeSandbox {
  221. permissionList, tmpErr := models.GetChartPermissionNameFromMappingByKeyword(reportInfo.ClassifyNameSecond, "rddp")
  222. if tmpErr != nil {
  223. return
  224. }
  225. categoryArr := make([]string, 0)
  226. for i := 0; i < len(permissionList); i++ {
  227. categoryArr = append(categoryArr, permissionList[i].PermissionName)
  228. }
  229. aliasArr, _ := addCategoryAliasToArr(categoryArr)
  230. categories = strings.Join(aliasArr, ",")
  231. }
  232. }
  233. // 新增报告ES
  234. esReport := &models.ElasticReportDetail{
  235. ReportId: reportInfo.Id,
  236. ReportChapterId: 0,
  237. Title: reportInfo.Title,
  238. Abstract: reportInfo.Abstract,
  239. BodyContent: utils.TrimHtml(html.UnescapeString(reportInfo.Content)),
  240. PublishTime: reportInfo.PublishTime.Format(utils.FormatDateTime),
  241. PublishState: publishState,
  242. Author: reportInfo.Author,
  243. ClassifyIdFirst: reportInfo.ClassifyIdFirst,
  244. ClassifyNameFirst: reportInfo.ClassifyNameFirst,
  245. ClassifyIdSecond: reportInfo.ClassifyIdSecond,
  246. ClassifyNameSecond: reportInfo.ClassifyNameSecond,
  247. Categories: categories,
  248. StageStr: strconv.Itoa(reportInfo.Stage),
  249. }
  250. docId := fmt.Sprintf("%d-%d", reportInfo.Id, 0)
  251. if err = EsAddOrEditReport(utils.EsReportIndexName, docId, esReport); err != nil {
  252. return
  253. }
  254. return
  255. }
  256. // addCategoryAliasToArr 品种别名
  257. func addCategoryAliasToArr(categoryArr []string) (aliasArr []string, err error) {
  258. aliasArr = categoryArr
  259. if len(categoryArr) > 0 {
  260. for i := 0; i < len(categoryArr); i++ {
  261. if strings.Contains(categoryArr[i], "沥青") {
  262. aliasArr = append(aliasArr, "BU")
  263. }
  264. if strings.Contains(categoryArr[i], "MEG") {
  265. aliasArr = append(aliasArr, "EG", "乙二醇")
  266. }
  267. if strings.Contains(categoryArr[i], "聚酯") {
  268. aliasArr = append(aliasArr, "长丝", "短纤", "瓶片")
  269. }
  270. if strings.Contains(categoryArr[i], "纯苯+苯乙烯") {
  271. aliasArr = append(aliasArr, "EB")
  272. }
  273. if strings.Contains(categoryArr[i], "聚乙烯") {
  274. aliasArr = append(aliasArr, "PP", "PE")
  275. }
  276. if strings.Contains(categoryArr[i], "玻璃纯碱") {
  277. aliasArr = append(aliasArr, "玻璃", "纯碱", "FG", "SA")
  278. }
  279. if strings.Contains(categoryArr[i], "甲醇") {
  280. aliasArr = append(aliasArr, "甲醇", "MA")
  281. }
  282. if strings.Contains(categoryArr[i], "橡胶") {
  283. aliasArr = append(aliasArr, "橡胶", "RU")
  284. }
  285. }
  286. }
  287. return
  288. }
  289. // UpdateReportChapterEs 更新报告章节ES
  290. func UpdateReportChapterEs(reportChapterId int) (err error) {
  291. if reportChapterId <= 0 {
  292. return
  293. }
  294. chapterInfo, err := models.GetReportChapterInfoById(reportChapterId)
  295. if err != nil {
  296. return
  297. }
  298. // 章节对应的品种
  299. permissionList := make([]*models.ReportChapterTypePermission, 0)
  300. if utils.BusinessCode == utils.BusinessCodeRelease || utils.BusinessCode == utils.BusinessCodeSandbox {
  301. permissionList, err = models.GetChapterTypePermissionByTypeIdAndResearchType(chapterInfo.TypeId, chapterInfo.ReportType)
  302. if err != nil {
  303. return
  304. }
  305. }
  306. categoryArr := make([]string, 0)
  307. if len(permissionList) > 0 {
  308. for ii := 0; ii < len(permissionList); ii++ {
  309. categoryArr = append(categoryArr, permissionList[ii].PermissionName)
  310. }
  311. }
  312. aliasArr, _ := addCategoryAliasToArr(categoryArr)
  313. categories := strings.Join(aliasArr, ",")
  314. // 新增/编辑ES
  315. esChapter := &models.ElasticReportDetail{
  316. ReportId: chapterInfo.ReportId,
  317. ReportChapterId: chapterInfo.ReportChapterId,
  318. Title: chapterInfo.Title,
  319. Abstract: chapterInfo.Abstract,
  320. BodyContent: utils.TrimHtml(html.EscapeString(chapterInfo.Content)),
  321. PublishTime: chapterInfo.PublishTime.Format(utils.FormatDateTime),
  322. PublishState: chapterInfo.PublishState,
  323. Author: chapterInfo.Author,
  324. ClassifyIdFirst: chapterInfo.ClassifyIdFirst,
  325. ClassifyNameFirst: chapterInfo.ClassifyNameFirst,
  326. ClassifyIdSecond: 0,
  327. ClassifyNameSecond: "",
  328. Categories: categories,
  329. StageStr: strconv.Itoa(chapterInfo.Stage),
  330. }
  331. chapterDocId := fmt.Sprintf("%d-%d", chapterInfo.ReportId, chapterInfo.ReportChapterId)
  332. if err = EsAddOrEditReport(utils.EsReportIndexName, chapterDocId, esChapter); err != nil {
  333. return
  334. }
  335. return
  336. }
  337. // DeleteReportAndChapter 删除报告及章节
  338. func DeleteReportAndChapter(reportId int) (err error) {
  339. reportInfo, err := models.GetReportByReportId(reportId)
  340. if err != nil {
  341. err = errors.New("报告信息有误, Err: " + err.Error())
  342. return
  343. }
  344. if reportInfo.State == 2 {
  345. err = errors.New("报告已发布,不可删除")
  346. return
  347. }
  348. // 更新ES
  349. _ = UpdateReportEs(reportId, 1)
  350. // 删除
  351. if reportInfo.HasChapter == 1 && (reportInfo.ChapterType == utils.REPORT_TYPE_DAY || reportInfo.ChapterType == utils.REPORT_TYPE_WEEK) {
  352. err = models.DeleteDayWeekReportAndChapter(reportId)
  353. } else {
  354. err = models.DeleteReport(reportId)
  355. }
  356. if err != nil {
  357. err = errors.New("删除失败, Err: " + err.Error())
  358. return
  359. }
  360. // 重置PPT关联报告
  361. go func() {
  362. _ = ResetPPTReport(reportId, false)
  363. }()
  364. return
  365. }
  366. // checkDayWeekChapterWrite 校验晨周报已写章节与本期应写章节
  367. func checkDayWeekChapterWrite(chapters []*models.ReportChapter, reportType string) (publishReport bool, tips string, publishIdArr, unPublishIdArr []int, err error) {
  368. nowTime := time.Now().Local()
  369. updateTypeArr := make([]int, 0) // 需更新的章节类型IDs
  370. publishIdArr = make([]int, 0) // 需发布的章节IDs
  371. unPublishIdArr = make([]int, 0) // 需取消发布/未发布的章节IDs
  372. // 校验章节内容
  373. if reportType == utils.REPORT_TYPE_DAY {
  374. // 晨报章节不能都为空
  375. isEmpty := true
  376. for i := 0; i < len(chapters); i++ {
  377. if chapters[i].Content != "" && chapters[i].Title != "" {
  378. isEmpty = false
  379. break
  380. }
  381. }
  382. if isEmpty {
  383. err = errors.New("报告章节内容均为空或标题为空,不可发布")
  384. return
  385. }
  386. } else {
  387. // 周报章节需至少有一篇已编辑且有标题
  388. editNum := 0
  389. for i := 0; i < len(chapters); i++ {
  390. if chapters[i].IsEdit == 1 && chapters[i].Title != "" {
  391. editNum += 1
  392. }
  393. }
  394. if editNum == 0 {
  395. err = errors.New("报告均未编辑或标题为空,不可发布")
  396. return
  397. }
  398. }
  399. // 章节类型列表
  400. types, e := models.GetReportChapterTypeListByResearchType(reportType)
  401. if e != nil {
  402. err = errors.New("获取章节类型列表失败")
  403. return
  404. }
  405. // 本期需更新的章节IDs
  406. typeLen := len(types)
  407. for i := 0; i < typeLen; i++ {
  408. if types[i].IsSet != 1 && types[i].Enabled != 0 {
  409. // 正常更新
  410. updateTypeArr = append(updateTypeArr, types[i].ReportChapterTypeId)
  411. } else {
  412. // 被设置为零值的也算作正常更新
  413. if types[i].PauseStartTime == utils.EmptyDateStr && types[i].PauseEndTime == utils.EmptyDateStr {
  414. updateTypeArr = append(updateTypeArr, types[i].ReportChapterTypeId)
  415. continue
  416. }
  417. // 暂停更新需校验时间
  418. startTime, _ := time.Parse(utils.FormatDate, types[i].PauseStartTime)
  419. endTime, _ := time.Parse(utils.FormatDate, types[i].PauseEndTime)
  420. if nowTime.Before(startTime) || nowTime.After(endTime.AddDate(0, 0, 1)) {
  421. updateTypeArr = append(updateTypeArr, types[i].ReportChapterTypeId)
  422. }
  423. }
  424. }
  425. // 校验本期需更新的章节是否都已编辑
  426. chapterLen := len(chapters)
  427. updateTypeLen := len(updateTypeArr)
  428. tipsArr := make([]string, 0)
  429. for i := 0; i < chapterLen; i++ {
  430. isWrite := false
  431. for ii := 0; ii < updateTypeLen; ii++ {
  432. // 本期应发布的章节
  433. if chapters[i].TypeId == updateTypeArr[ii] {
  434. // 标题或者内容为空的情况下, 记录tips提示信息且不发布该章节
  435. if chapters[i].Title == "" || chapters[i].Content == "" {
  436. tipsArr = append(tipsArr, chapters[i].TypeName)
  437. break
  438. }
  439. isWrite = true
  440. break
  441. }
  442. }
  443. if isWrite {
  444. publishIdArr = append(publishIdArr, chapters[i].ReportChapterId)
  445. } else {
  446. unPublishIdArr = append(unPublishIdArr, chapters[i].ReportChapterId)
  447. }
  448. }
  449. if len(tipsArr) > 0 {
  450. tips = "部分章节未发布:" + strings.Join(tipsArr, "、") + "未填写标题/内容"
  451. }
  452. // 周报需发布的章节与需更新的章节数相等则表示可发布整期, 晨报无限制
  453. if reportType == utils.REPORT_TYPE_DAY {
  454. publishReport = true
  455. } else {
  456. if len(publishIdArr) == updateTypeLen {
  457. publishReport = true
  458. }
  459. }
  460. return
  461. }
  462. // PcCreateAndUploadSunCode 生成太阳码并上传OSS
  463. func PcCreateAndUploadSunCode(scene, page string) (imgUrl string, err error) {
  464. if page == "" {
  465. err = errors.New("page不能为空")
  466. return
  467. }
  468. // scene超过32位会生成失败,md5处理至32位
  469. sceneMD5 := "a=1"
  470. if scene != "" {
  471. sceneMD5 = utils.MD5(scene)
  472. }
  473. picByte, err := GetSunCode(page, sceneMD5)
  474. if err != nil {
  475. return
  476. }
  477. // 生成图片
  478. localPath := "./static/imgs"
  479. fileName := utils.GetRandStringNoSpecialChar(28) + ".png"
  480. fpath := fmt.Sprint(localPath, "/", fileName)
  481. f, err := os.Create(fpath)
  482. if err != nil {
  483. fmt.Println("11111")
  484. return
  485. }
  486. if _, err = f.Write(picByte); err != nil {
  487. return
  488. }
  489. defer func() {
  490. f.Close()
  491. os.Remove(fpath)
  492. }()
  493. // 上传OSS
  494. fileDir := "yb/suncode/"
  495. //上传到阿里云 和 minio
  496. if utils.ObjectStorageClient == "minio" {
  497. imgUrl, err = UploadMinIoToDir(fileName, fpath, "", fileDir)
  498. if err != nil {
  499. return
  500. }
  501. } else {
  502. imgUrl, err = UploadAliyunToDir(fileName, fpath, "", fileDir)
  503. if err != nil {
  504. return
  505. }
  506. }
  507. if err != nil {
  508. return
  509. }
  510. // 记录参数
  511. if scene != "" {
  512. newSuncode := &models.YbPcSuncode{
  513. Scene: scene,
  514. SceneMd5: sceneMD5,
  515. CodePage: page,
  516. SuncodeURL: imgUrl,
  517. CreateTime: time.Now(),
  518. }
  519. err = models.AddYbPcSunCode(newSuncode)
  520. }
  521. // 记录参数md5
  522. if scene != "" {
  523. newPars := &models.YbSuncodePars{
  524. Scene: scene,
  525. SceneKey: sceneMD5,
  526. CreateTime: time.Now(),
  527. }
  528. err = models.AddYbSuncodePars(newPars)
  529. }
  530. return
  531. }
  532. // FilterReportContentBr 过滤报告正文前后换行符
  533. func FilterReportContentBr(content string) (res string, err error) {
  534. newContent := content
  535. //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>`
  536. content = html.UnescapeString(content)
  537. if content == "" {
  538. return
  539. }
  540. // 过滤编辑器版权html
  541. 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)
  542. defer func() {
  543. if err != nil {
  544. go alarm_msg.SendAlarmMsg("过滤报告正文前后换行符及空格失败, ErrMsg: "+err.Error(), 3)
  545. }
  546. }()
  547. // 做一个配置,有问题的时候随时关闭
  548. configKey := "report_filter_br"
  549. conf, e := company.GetConfigDetailByCode(configKey)
  550. if e != nil {
  551. err = errors.New("获取报告过滤配置失败, Err: " + e.Error())
  552. return
  553. }
  554. if conf.ConfigValue != "1" {
  555. return content, nil
  556. }
  557. // 找出所有<p>标签, <p>标签的索引
  558. re := regexp.MustCompile(`(?is:<p(.*?)</p>)`)
  559. arr := re.FindAllString(content, -1)
  560. indexArr := re.FindAllIndex([]byte(content), -1)
  561. // 空<p>正则
  562. emptyRe := `<p[^>]*>(<br>|<br/>)+</p>`
  563. startIsBr := false
  564. countEmptyBr := 0 // 需要连续替换的空<p>总数
  565. lastBrRange := 0 // 最后一个空<p>右侧index, 用来判断是否为连续的空<p>
  566. // 注:以下逻辑只适用于去除前面的空行, 由于编辑器始终会在文章最后面跟上自己的html标签, 此处不再进行后面空行的去除=_=!
  567. for i := range arr {
  568. byteRange := indexArr[i]
  569. if len(byteRange) == 2 {
  570. // 内容开头不为<p>直接跳出遍历, 否则才进行空<p>的判断
  571. if i == 0 && byteRange[0] == 0 {
  572. startIsBr = true
  573. }
  574. if !startIsBr {
  575. break
  576. }
  577. if lastBrRange != 0 {
  578. // 说明不是连续的空<p>, 中间出现了其他标签, 那么结束遍历, 进行最终的文本替换
  579. if lastBrRange != byteRange[0] {
  580. break
  581. }
  582. }
  583. // 正则匹配为空<p>则计数, 记录该空<p>右侧index
  584. m, e := regexp.Match(emptyRe, []byte(arr[i]))
  585. if e != nil {
  586. err = e
  587. return
  588. }
  589. if m {
  590. countEmptyBr += 1
  591. lastBrRange = byteRange[1]
  592. continue
  593. }
  594. // 遍历到该<p>标签不为空了, 结束遍历
  595. break
  596. }
  597. }
  598. if countEmptyBr > 0 {
  599. reg, e := regexp.Compile(emptyRe)
  600. if e != nil {
  601. err = errors.New("正则解析失败, Err: " + e.Error())
  602. return
  603. }
  604. counted := 0 // 已替换数
  605. res = reg.ReplaceAllStringFunc(content, func(s string) string {
  606. counted += 1
  607. if counted <= countEmptyBr {
  608. return ""
  609. } else {
  610. return s
  611. }
  612. })
  613. if res == "" {
  614. res = newContent
  615. }
  616. } else {
  617. res = content
  618. if res == "" {
  619. res = newContent
  620. }
  621. }
  622. return
  623. }
  624. // UpdateReportEditMark 更新研报当前更新状态
  625. // status 枚举值 1:编辑中,0:完成编辑, 2:只做查询
  626. func UpdateReportEditMark(reportId, nowUserId, status int, nowUserName string) (ret models.MarkReportResp, err error) {
  627. //更新标记key
  628. key := fmt.Sprint(`crm:report:edit:`, reportId)
  629. ret.Status = 0
  630. ret.Msg = "无人编辑"
  631. opUserId, e := utils.Rc.RedisInt(key)
  632. var opUser models.MarkReportItem
  633. var classifyNameFirst string
  634. if e != nil {
  635. opUserInfoStr, tErr := utils.Rc.RedisString(key)
  636. if tErr == nil {
  637. tErr = json.Unmarshal([]byte(opUserInfoStr), &opUser)
  638. if tErr == nil {
  639. opUserId = opUser.AdminId
  640. }
  641. }
  642. }
  643. //判断是否是晨报或者周报,如果是则跳过
  644. var reportInfo *models.ReportDetail
  645. classifyNameFirst = opUser.ReportClassifyNameFirst
  646. if reportId > 0 && status != 2 && classifyNameFirst == "" {
  647. //查询报告ID信息
  648. reportInfo, err = models.GetReportById(reportId)
  649. if err != nil {
  650. err = fmt.Errorf("报告不存在")
  651. return
  652. }
  653. classifyNameFirst = reportInfo.ClassifyNameFirst
  654. }
  655. if classifyNameFirst == "晨报" || classifyNameFirst == "周报" {
  656. return
  657. }
  658. if opUserId > 0 && opUserId != nowUserId {
  659. editor := opUser.Editor
  660. if editor == "" {
  661. //查询账号的用户姓名
  662. otherInfo, e := system.GetSysAdminById(opUserId)
  663. if e != nil {
  664. err = fmt.Errorf("查询其他编辑者信息失败")
  665. return
  666. }
  667. editor = otherInfo.RealName
  668. }
  669. ret.Status = 1
  670. ret.Msg = fmt.Sprintf("当前%s正在编辑报告", editor)
  671. ret.Editor = editor
  672. return
  673. }
  674. if status == 1 {
  675. nowUser := &models.MarkReportItem{AdminId: nowUserId, Editor: nowUserName, ReportClassifyNameFirst: classifyNameFirst}
  676. bt, e := json.Marshal(nowUser)
  677. if e != nil {
  678. err = fmt.Errorf("格式化编辑者信息失败")
  679. return
  680. }
  681. if opUserId > 0 {
  682. utils.Rc.Do("SETEX", key, int64(180), string(bt)) //3分钟缓存
  683. } else {
  684. utils.Rc.SetNX(key, string(bt), time.Second*60*3) //3分钟缓存
  685. }
  686. } else if status == 0 {
  687. //清除编辑缓存
  688. _ = utils.Rc.Delete(key)
  689. }
  690. return
  691. }
  692. // SaveReportLogs 记录报告日志
  693. func SaveReportLogs(item *models.Report, chapters []*models.ReportChapter, adminId int, adminRealName string) {
  694. if item == nil && len(chapters) == 0 {
  695. return
  696. }
  697. var err error
  698. defer func() {
  699. if err != nil {
  700. tips := fmt.Sprintf("报告日志记录, SaveReportLogs error: %s", err.Error())
  701. go alarm_msg.SendAlarmMsg(tips, 2)
  702. }
  703. }()
  704. if item != nil {
  705. e := models.AddReportSaveLog(item.Id, item.AdminId, item.Content, item.ContentSub, item.AdminRealName)
  706. if e != nil {
  707. err = fmt.Errorf("AddReportSaveLog: %s", e.Error())
  708. return
  709. }
  710. }
  711. if len(chapters) > 0 {
  712. e := models.MultiAddReportChaptersSaveLog(chapters, adminId, adminRealName)
  713. if e != nil {
  714. err = fmt.Errorf("MultiAddReportChaptersSaveLog: %s", e.Error())
  715. return
  716. }
  717. }
  718. return
  719. }
  720. // HandleVideoDecibel 处理报告中的音频文件
  721. func HandleVideoDecibel(chapterInfo *models.ReportChapter) {
  722. public_api.HandleVideoDecibel(chapterInfo.ReportChapterId)
  723. return
  724. }