package services import ( "encoding/json" "errors" "eta/eta_mobile/models" "eta/eta_mobile/models/company" "eta/eta_mobile/models/system" "eta/eta_mobile/services/alarm_msg" "eta/eta_mobile/services/public_api" "eta/eta_mobile/utils" "fmt" "github.com/PuerkitoBio/goquery" "html" "os" "regexp" "strconv" "strings" "time" ) func GetReportContentSub(content string) (contentSub string, err error) { content = html.UnescapeString(content) doc, err := goquery.NewDocumentFromReader(strings.NewReader(content)) if err != nil { fmt.Println("create doc err:", err.Error()) return } n := 0 doc.Find("p").Each(func(i int, s *goquery.Selection) { if n >= 5 { return } n++ phtml, err := s.Html() if err != nil { fmt.Println("get html err", err.Error()) return } if s.Text() != "" || strings.Contains(phtml, "src") { contentSub = contentSub + "
" + phtml + "
" } }) return } // PublishDayWeekReport 发布晨周报 func PublishDayWeekReport(reportId int) (tips string, err error) { if utils.BusinessCode != utils.BusinessCodeRelease && utils.BusinessCode != utils.BusinessCodeSandbox { return } report, err := models.GetReportByReportId(reportId) if err != nil { return } if report.State == 2 { return } chapters, err := models.GetChapterListByReportId(reportId) if err != nil { return } chapterLen := len(chapters) if chapterLen <= 0 { err = errors.New("报告章节为空,不可发布") return } reportType := chapters[0].ReportType // 校验章节 publishReport, tips, publishIdArr, unPublishIdArr, err := checkDayWeekChapterWrite(chapters, reportType) if err != nil { return } publishLen := len(publishIdArr) if publishLen <= 0 { err = errors.New("报告章节均不可发布") return } // 需发布整期 updateCols := make([]string, 0) if publishReport { updateCols = append(updateCols, "Title", "State", "ModifyTime") // 发布后标题调整 title := report.Title title = strings.ReplaceAll(title, "【弘则FICC晨报】", "") title = strings.ReplaceAll(title, "【弘则FICC周报】", "") if title == "" { // 取第一个需发布章节的标题 firstId := publishIdArr[0] firstTitle := "" for i := 0; i < chapterLen; i++ { if chapters[i].ReportChapterId == firstId { firstTitle = chapters[i].Title break } } title = firstTitle } report.Title = title report.State = 2 // 研报后台4.4 只在没有发布过时更新发布时间,其余均按模版消息发送时间当作发布时间 if report.MsgIsSend == 0 || report.PublishTime.IsZero() { report.PublishTime = time.Now().Local() updateCols = append(updateCols, "PublishTime") } report.ModifyTime = time.Now().Local() } publishIdStr := utils.IntArr2joinString(publishIdArr, ",") unPublishIdStr := utils.IntArr2joinString(unPublishIdArr, ",") if e := models.PublishReportAndChapter(report, publishIdStr, unPublishIdStr, publishReport, updateCols); e != nil { err = errors.New("发布报告及章节失败") return } // 生成章节音频 go func() { _ = UpdateChaptersVideo(publishIdStr) }() // 更新报告ES go func() { _ = UpdateReportEs(report.Id, 2) }() // 发布时备份内容 go SaveReportLogs(report, chapters, report.AdminId, report.AdminRealName) return } // UpdateChaptersVideo 更新章节音频 func UpdateChaptersVideo(chapterIds string) (err error) { defer func() { if err != nil { utils.FileLog.Error("UpdateChaptersVideo, chapterIds:%s, Err:%s", chapterIds, err.Error()) go alarm_msg.SendAlarmMsg("更新章节音频失败, 章节ID: "+chapterIds+", Err: "+err.Error(), 3) } }() if chapterIds == "" { return } chapterList, err := models.GetChapterListByChapterIds(chapterIds) if err != nil { return } // 生成video nowTime := time.Now() updateCols := make([]string, 0) updateCols = append(updateCols, "VideoUrl", "VideoName", "VideoSize", "VideoPlaySeconds") for i := 0; i < len(chapterList); i++ { item := chapterList[i] // 忽略已有音频的章节 if item.VideoUrl != "" && item.VideoName != "" && item.VideoSize != "" && item.VideoPlaySeconds != "" { continue } videoUrl, videoName, videoSize, videoPlaySeconds, e := CreateReportVideo(item.Title, html.UnescapeString(item.Content), nowTime.Format(utils.FormatDateTime)) if e != nil { err = e return } item.VideoUrl = videoUrl item.VideoName = videoName item.VideoSize = videoSize item.VideoPlaySeconds = fmt.Sprintf("%.2f", videoPlaySeconds) if e = item.UpdateChapter(updateCols); e != nil { err = e } } return } // UpdateReportEs 更新报告/章节Es func UpdateReportEs(reportId int, publishState int) (err error) { if reportId <= 0 { return } reportInfo, err := models.GetReportByReportId(reportId) if err != nil { return } categories := "" if reportInfo.HasChapter == 1 { // 晨周报 chapterList, tmpErr := models.GetPublishedChapterListByReportId(reportInfo.Id) if tmpErr != nil { return } if len(chapterList) > 0 { for i := 0; i < len(chapterList); i++ { // 章节对应的品种 permissionList := make([]*models.ReportChapterTypePermission, 0) if utils.BusinessCode == utils.BusinessCodeRelease || utils.BusinessCode == utils.BusinessCodeSandbox { permissionList, tmpErr = models.GetChapterTypePermissionByTypeIdAndResearchType(chapterList[i].TypeId, chapterList[i].ReportType) if tmpErr != nil { return } } categoryArr := make([]string, 0) if len(permissionList) > 0 { for ii := 0; ii < len(permissionList); ii++ { categoryArr = append(categoryArr, permissionList[ii].PermissionName) } } aliasArr, _ := addCategoryAliasToArr(categoryArr) chapterCategories := strings.Join(aliasArr, ",") esChapter := &models.ElasticReportDetail{ ReportId: chapterList[i].ReportId, ReportChapterId: chapterList[i].ReportChapterId, Title: chapterList[i].Title, Abstract: chapterList[i].Abstract, BodyContent: utils.TrimHtml(html.UnescapeString(chapterList[i].Content)), PublishTime: chapterList[i].PublishTime.Format(utils.FormatDateTime), PublishState: chapterList[i].PublishState, Author: chapterList[i].Author, ClassifyIdFirst: chapterList[i].ClassifyIdFirst, ClassifyNameFirst: chapterList[i].ClassifyNameFirst, ClassifyIdSecond: 0, ClassifyNameSecond: "", Categories: chapterCategories, StageStr: strconv.Itoa(chapterList[i].Stage), } chapterDocId := fmt.Sprintf("%d-%d", reportInfo.Id, chapterList[i].ReportChapterId) if err = EsAddOrEditReport(utils.EsReportIndexName, chapterDocId, esChapter); err != nil { return } } } } else { if utils.BusinessCode == utils.BusinessCodeRelease || utils.BusinessCode == utils.BusinessCodeSandbox { permissionList, tmpErr := models.GetChartPermissionNameFromMappingByKeyword(reportInfo.ClassifyNameSecond, "rddp") if tmpErr != nil { return } categoryArr := make([]string, 0) for i := 0; i < len(permissionList); i++ { categoryArr = append(categoryArr, permissionList[i].PermissionName) } aliasArr, _ := addCategoryAliasToArr(categoryArr) categories = strings.Join(aliasArr, ",") } } // 新增报告ES esReport := &models.ElasticReportDetail{ ReportId: reportInfo.Id, ReportChapterId: 0, Title: reportInfo.Title, Abstract: reportInfo.Abstract, BodyContent: utils.TrimHtml(html.UnescapeString(reportInfo.Content)), PublishTime: reportInfo.PublishTime.Format(utils.FormatDateTime), PublishState: publishState, Author: reportInfo.Author, ClassifyIdFirst: reportInfo.ClassifyIdFirst, ClassifyNameFirst: reportInfo.ClassifyNameFirst, ClassifyIdSecond: reportInfo.ClassifyIdSecond, ClassifyNameSecond: reportInfo.ClassifyNameSecond, Categories: categories, StageStr: strconv.Itoa(reportInfo.Stage), } docId := fmt.Sprintf("%d-%d", reportInfo.Id, 0) if err = EsAddOrEditReport(utils.EsReportIndexName, docId, esReport); err != nil { return } return } // addCategoryAliasToArr 品种别名 func addCategoryAliasToArr(categoryArr []string) (aliasArr []string, err error) { aliasArr = categoryArr if len(categoryArr) > 0 { for i := 0; i < len(categoryArr); i++ { if strings.Contains(categoryArr[i], "沥青") { aliasArr = append(aliasArr, "BU") } if strings.Contains(categoryArr[i], "MEG") { aliasArr = append(aliasArr, "EG", "乙二醇") } if strings.Contains(categoryArr[i], "聚酯") { aliasArr = append(aliasArr, "长丝", "短纤", "瓶片") } if strings.Contains(categoryArr[i], "纯苯+苯乙烯") { aliasArr = append(aliasArr, "EB") } if strings.Contains(categoryArr[i], "聚乙烯") { aliasArr = append(aliasArr, "PP", "PE") } if strings.Contains(categoryArr[i], "玻璃纯碱") { aliasArr = append(aliasArr, "玻璃", "纯碱", "FG", "SA") } if strings.Contains(categoryArr[i], "甲醇") { aliasArr = append(aliasArr, "甲醇", "MA") } if strings.Contains(categoryArr[i], "橡胶") { aliasArr = append(aliasArr, "橡胶", "RU") } } } return } // UpdateReportChapterEs 更新报告章节ES func UpdateReportChapterEs(reportChapterId int) (err error) { if reportChapterId <= 0 { return } chapterInfo, err := models.GetReportChapterInfoById(reportChapterId) if err != nil { return } // 章节对应的品种 permissionList := make([]*models.ReportChapterTypePermission, 0) if utils.BusinessCode == utils.BusinessCodeRelease || utils.BusinessCode == utils.BusinessCodeSandbox { permissionList, err = models.GetChapterTypePermissionByTypeIdAndResearchType(chapterInfo.TypeId, chapterInfo.ReportType) if err != nil { return } } categoryArr := make([]string, 0) if len(permissionList) > 0 { for ii := 0; ii < len(permissionList); ii++ { categoryArr = append(categoryArr, permissionList[ii].PermissionName) } } aliasArr, _ := addCategoryAliasToArr(categoryArr) categories := strings.Join(aliasArr, ",") // 新增/编辑ES esChapter := &models.ElasticReportDetail{ ReportId: chapterInfo.ReportId, ReportChapterId: chapterInfo.ReportChapterId, Title: chapterInfo.Title, Abstract: chapterInfo.Abstract, BodyContent: utils.TrimHtml(html.EscapeString(chapterInfo.Content)), PublishTime: chapterInfo.PublishTime.Format(utils.FormatDateTime), PublishState: chapterInfo.PublishState, Author: chapterInfo.Author, ClassifyIdFirst: chapterInfo.ClassifyIdFirst, ClassifyNameFirst: chapterInfo.ClassifyNameFirst, ClassifyIdSecond: 0, ClassifyNameSecond: "", Categories: categories, StageStr: strconv.Itoa(chapterInfo.Stage), } chapterDocId := fmt.Sprintf("%d-%d", chapterInfo.ReportId, chapterInfo.ReportChapterId) if err = EsAddOrEditReport(utils.EsReportIndexName, chapterDocId, esChapter); err != nil { return } return } // DeleteReportAndChapter 删除报告及章节 func DeleteReportAndChapter(reportId int) (err error) { reportInfo, err := models.GetReportByReportId(reportId) if err != nil { err = errors.New("报告信息有误, Err: " + err.Error()) return } if reportInfo.State == 2 { err = errors.New("报告已发布,不可删除") return } // 更新ES _ = UpdateReportEs(reportId, 1) // 删除 if reportInfo.HasChapter == 1 && (reportInfo.ChapterType == utils.REPORT_TYPE_DAY || reportInfo.ChapterType == utils.REPORT_TYPE_WEEK) { err = models.DeleteDayWeekReportAndChapter(reportId) } else { err = models.DeleteReport(reportId) } if err != nil { err = errors.New("删除失败, Err: " + err.Error()) return } // 重置PPT关联报告 go func() { _ = ResetPPTReport(reportId, false) }() return } // checkDayWeekChapterWrite 校验晨周报已写章节与本期应写章节 func checkDayWeekChapterWrite(chapters []*models.ReportChapter, reportType string) (publishReport bool, tips string, publishIdArr, unPublishIdArr []int, err error) { nowTime := time.Now().Local() updateTypeArr := make([]int, 0) // 需更新的章节类型IDs publishIdArr = make([]int, 0) // 需发布的章节IDs unPublishIdArr = make([]int, 0) // 需取消发布/未发布的章节IDs // 校验章节内容 if reportType == utils.REPORT_TYPE_DAY { // 晨报章节不能都为空 isEmpty := true for i := 0; i < len(chapters); i++ { if chapters[i].Content != "" && chapters[i].Title != "" { isEmpty = false break } } if isEmpty { err = errors.New("报告章节内容均为空或标题为空,不可发布") return } } else { // 周报章节需至少有一篇已编辑且有标题 editNum := 0 for i := 0; i < len(chapters); i++ { if chapters[i].IsEdit == 1 && chapters[i].Title != "" { editNum += 1 } } if editNum == 0 { err = errors.New("报告均未编辑或标题为空,不可发布") return } } // 章节类型列表 types, e := models.GetReportChapterTypeListByResearchType(reportType) if e != nil { err = errors.New("获取章节类型列表失败") return } // 本期需更新的章节IDs typeLen := len(types) for i := 0; i < typeLen; i++ { if types[i].IsSet != 1 && types[i].Enabled != 0 { // 正常更新 updateTypeArr = append(updateTypeArr, types[i].ReportChapterTypeId) } else { // 被设置为零值的也算作正常更新 if types[i].PauseStartTime == utils.EmptyDateStr && types[i].PauseEndTime == utils.EmptyDateStr { updateTypeArr = append(updateTypeArr, types[i].ReportChapterTypeId) continue } // 暂停更新需校验时间 startTime, _ := time.Parse(utils.FormatDate, types[i].PauseStartTime) endTime, _ := time.Parse(utils.FormatDate, types[i].PauseEndTime) if nowTime.Before(startTime) || nowTime.After(endTime.AddDate(0, 0, 1)) { updateTypeArr = append(updateTypeArr, types[i].ReportChapterTypeId) } } } // 校验本期需更新的章节是否都已编辑 chapterLen := len(chapters) updateTypeLen := len(updateTypeArr) tipsArr := make([]string, 0) for i := 0; i < chapterLen; i++ { isWrite := false for ii := 0; ii < updateTypeLen; ii++ { // 本期应发布的章节 if chapters[i].TypeId == updateTypeArr[ii] { // 标题或者内容为空的情况下, 记录tips提示信息且不发布该章节 if chapters[i].Title == "" || chapters[i].Content == "" { tipsArr = append(tipsArr, chapters[i].TypeName) break } isWrite = true break } } if isWrite { publishIdArr = append(publishIdArr, chapters[i].ReportChapterId) } else { unPublishIdArr = append(unPublishIdArr, chapters[i].ReportChapterId) } } if len(tipsArr) > 0 { tips = "部分章节未发布:" + strings.Join(tipsArr, "、") + "未填写标题/内容" } // 周报需发布的章节与需更新的章节数相等则表示可发布整期, 晨报无限制 if reportType == utils.REPORT_TYPE_DAY { publishReport = true } else { if len(publishIdArr) == updateTypeLen { publishReport = true } } return } // PcCreateAndUploadSunCode 生成太阳码并上传OSS func PcCreateAndUploadSunCode(scene, page string) (imgUrl string, err error) { if page == "" { err = errors.New("page不能为空") return } // scene超过32位会生成失败,md5处理至32位 sceneMD5 := "a=1" if scene != "" { sceneMD5 = utils.MD5(scene) } picByte, err := GetSunCode(page, sceneMD5) if err != nil { return } // 生成图片 localPath := "./static/imgs" fileName := utils.GetRandStringNoSpecialChar(28) + ".png" fpath := fmt.Sprint(localPath, "/", fileName) f, err := os.Create(fpath) if err != nil { fmt.Println("11111") return } if _, err = f.Write(picByte); err != nil { return } defer func() { f.Close() os.Remove(fpath) }() // 上传OSS fileDir := "yb/suncode/" //上传到阿里云 和 minio if utils.ObjectStorageClient == "minio" { imgUrl, err = UploadMinIoToDir(fileName, fpath, "", fileDir) if err != nil { return } } else { imgUrl, err = UploadAliyunToDir(fileName, fpath, "", fileDir) if err != nil { return } } if err != nil { return } // 记录参数 if scene != "" { newSuncode := &models.YbPcSuncode{ Scene: scene, SceneMd5: sceneMD5, CodePage: page, SuncodeURL: imgUrl, CreateTime: time.Now(), } err = models.AddYbPcSunCode(newSuncode) } // 记录参数md5 if scene != "" { newPars := &models.YbSuncodePars{ Scene: scene, SceneKey: sceneMD5, CreateTime: time.Now(), } err = models.AddYbSuncodePars(newPars) } return } // FilterReportContentBr 过滤报告正文前后换行符 func FilterReportContentBr(content string) (res string, err error) { newContent := content //content = `四季度验证投产预期
PTA:近端短缺的格局出现缓解的迹象,表现在:PX进口回升;国内重整及常减压提负;PTA、PX投产在即。正套部分或全部止盈。
乙二醇:到港预报集中的情况下仍在去库,4200-4600区间震荡操作,节前没有明显方向,不建议在节前备货的时间段布局空单。
1、PX国内供应本周回落,PTA工厂负荷变动滞后于PX装置。
PX装置变动:
海南炼化一期66万吨PX装置因故障停车检修,重启时间待跟踪,其二期100万吨PX装置预计在此装置重启后停车检修。
天津石化一套100万吨重整已于20日重启中,其39万吨PX预计下周初出产品。
韩国SK 位于仁川的130万吨PX装置按计划在23日停车检修,计划检修时长45天左右。
截至周五,中国国内PX负荷小幅回落至73.4%(前值76.8%),亚洲PX负荷小幅回落至68.7%(72%)。
PXN本周延续回落至380美金附近。
PX平衡表
海关统计,国内8月PX进口总量在78.8万吨,环比增加17.3万吨,增幅28%;同比减少30.8万吨,降幅28.1%;8月PX出口量0.47万吨,环比下降5万吨。
PX 8月进口量大幅回升至79万吨附近,其中8月从韩国进口的PX量达到33.65万吨。9月目前公布的1-20号从韩国进口PX的量已经接近8月全月的水平,即环比8月仍是大幅增加的情况:据悉,9月1-20日韩国PX出口总量在30.9万吨,其中出口至中国27.9万吨。
预计9月进口量环比8月进一步增加。
原油本周偏弱,欧美汽油利润本周均出现了明显回升。
美国飓风将在下周登陆墨西哥湾,届时或将影响海上钻机的运行以及炼厂开工。
2、乙烯连续跌价至900美金,PX投产压力临近PXN延续压缩。石脑油亏损本周延续修复。
PTA:按照PX11-12月上1054美金(石脑油672美金,Brent86.15美金)计算,醋酸3075元,目前含醋酸的原料成本在5670元附近。可以发现虽然Brent和PX环比上周都出现了明显的下跌,但石脑油相对上周环比上涨,石脑油亏损本周延续修复,目前石脑油-Brent价差回升至0以上。
给到200-300的最低加工成本,PTA的估值在5870-5970元。周五日盘收盘后TA11合约5742,11月及之后的PTA合约均亏损。
PTA基差再度回升至1000附近,周五小幅走弱至970。
乙二醇:静态来看,按照盘面(煤价按照900元),锚定石脑油672美金,乙烯900美金,甲醇2640元,北美乙烷价格38美分/加仑计算,乙二醇的综合成本仍在5050元附近。周五日盘收盘01合约按照综合成本亏损700元附近。
国内外采乙烷制乙二醇目前扭亏为盈。
轻纺城成交量节前震荡回升但仍在偏低水平。
PTA库存结构变化跟踪:本期PTA库存大幅去化17.9万吨附近(本周仓单集中注销,仓单库存大幅下降至0附近),聚酯成品折算PTA库存大幅累库9.3万吨,叠加PTA库存在聚酯成品库存累库的情况下去库8.6万吨。
PTA平衡表——按照Q4有500万吨新装置投产(东营威联化学250万吨及嘉通能源250万吨分别在11、12月计入产能基数)计算,按照9-10月聚酯月均负荷84%(下调1%)、87%(下调1%)预估,8-12月出口预计25万吨附近。8-10月目前预估均为去库格局。
PX折算PTA与PTA合计9月去库幅度修正后大幅收窄。
5、乙二醇行情沙盘推演2022.9.23:到港预报集中的情况下仍在去库,4200-4600区间震荡操作,节前没有明显方向,不建议在节前备货的时间段布局空单。
乙二醇国内供需:
乙二醇到港预报与实际到港:
隆众口径:截至9月29日,国内乙二醇华东总到港量预计在19.21万吨,较上一期增加3.45万吨,提升21.93个百分点。
港口发货节前回升。
海外装置:
印度IOC 32.5万吨装置将于近期停车技改,预计停车将持续至12月份。
伊朗 Marun 44.5万吨装置目前处于停车状态,该装置此前货源供应印度市场为主。
美国Sasol 28万吨装置计划于10月上旬停车检修,预计检修时长在一个月附近。
Powered by Froala Editor
", "", -1) defer func() { if err != nil { go alarm_msg.SendAlarmMsg("过滤报告正文前后换行符及空格失败, ErrMsg: "+err.Error(), 3) } }() // 做一个配置,有问题的时候随时关闭 configKey := "report_filter_br" conf, e := company.GetConfigDetailByCode(configKey) if e != nil { err = errors.New("获取报告过滤配置失败, Err: " + e.Error()) return } if conf.ConfigValue != "1" { return content, nil } // 找出所有标签,
标签的索引 re := regexp.MustCompile(`(?is:
)`) arr := re.FindAllString(content, -1) indexArr := re.FindAllIndex([]byte(content), -1) // 空
正则 emptyRe := `
]*>(
|
)+
总数 lastBrRange := 0 // 最后一个空
右侧index, 用来判断是否为连续的空
// 注:以下逻辑只适用于去除前面的空行, 由于编辑器始终会在文章最后面跟上自己的html标签, 此处不再进行后面空行的去除=_=! for i := range arr { byteRange := indexArr[i] if len(byteRange) == 2 { // 内容开头不为
直接跳出遍历, 否则才进行空
的判断 if i == 0 && byteRange[0] == 0 { startIsBr = true } if !startIsBr { break } if lastBrRange != 0 { // 说明不是连续的空
, 中间出现了其他标签, 那么结束遍历, 进行最终的文本替换 if lastBrRange != byteRange[0] { break } } // 正则匹配为空
则计数, 记录该空
右侧index m, e := regexp.Match(emptyRe, []byte(arr[i])) if e != nil { err = e return } if m { countEmptyBr += 1 lastBrRange = byteRange[1] continue } // 遍历到该
标签不为空了, 结束遍历 break } } if countEmptyBr > 0 { reg, e := regexp.Compile(emptyRe) if e != nil { err = errors.New("正则解析失败, Err: " + e.Error()) return } counted := 0 // 已替换数 res = reg.ReplaceAllStringFunc(content, func(s string) string { counted += 1 if counted <= countEmptyBr { return "" } else { return s } }) if res == "" { res = newContent } } else { res = content if res == "" { res = newContent } } return } // UpdateReportEditMark 更新研报当前更新状态 // status 枚举值 1:编辑中,0:完成编辑, 2:只做查询 func UpdateReportEditMark(reportId, nowUserId, status int, nowUserName string) (ret models.MarkReportResp, err error) { //更新标记key key := fmt.Sprint(`crm:report:edit:`, reportId) ret.Status = 0 ret.Msg = "无人编辑" opUserId, e := utils.Rc.RedisInt(key) var opUser models.MarkReportItem var classifyNameFirst string if e != nil { opUserInfoStr, tErr := utils.Rc.RedisString(key) if tErr == nil { tErr = json.Unmarshal([]byte(opUserInfoStr), &opUser) if tErr == nil { opUserId = opUser.AdminId } } } //判断是否是晨报或者周报,如果是则跳过 var reportInfo *models.ReportDetail classifyNameFirst = opUser.ReportClassifyNameFirst if reportId > 0 && status != 2 && classifyNameFirst == "" { //查询报告ID信息 reportInfo, err = models.GetReportById(reportId) if err != nil { err = fmt.Errorf("报告不存在") return } classifyNameFirst = reportInfo.ClassifyNameFirst } if classifyNameFirst == "晨报" || classifyNameFirst == "周报" { return } if opUserId > 0 && opUserId != nowUserId { editor := opUser.Editor if editor == "" { //查询账号的用户姓名 otherInfo, e := system.GetSysAdminById(opUserId) if e != nil { err = fmt.Errorf("查询其他编辑者信息失败") return } editor = otherInfo.RealName } ret.Status = 1 ret.Msg = fmt.Sprintf("当前%s正在编辑报告", editor) ret.Editor = editor return } if status == 1 { nowUser := &models.MarkReportItem{AdminId: nowUserId, Editor: nowUserName, ReportClassifyNameFirst: classifyNameFirst} bt, e := json.Marshal(nowUser) if e != nil { err = fmt.Errorf("格式化编辑者信息失败") return } if opUserId > 0 { utils.Rc.Do("SETEX", key, int64(180), string(bt)) //3分钟缓存 } else { utils.Rc.SetNX(key, string(bt), time.Second*60*3) //3分钟缓存 } } else if status == 0 { //清除编辑缓存 _ = utils.Rc.Delete(key) } return } // SaveReportLogs 记录报告日志 func SaveReportLogs(item *models.Report, chapters []*models.ReportChapter, adminId int, adminRealName string) { if item == nil && len(chapters) == 0 { return } var err error defer func() { if err != nil { tips := fmt.Sprintf("报告日志记录, SaveReportLogs error: %s", err.Error()) go alarm_msg.SendAlarmMsg(tips, 2) } }() if item != nil { e := models.AddReportSaveLog(item.Id, item.AdminId, item.Content, item.ContentSub, item.AdminRealName) if e != nil { err = fmt.Errorf("AddReportSaveLog: %s", e.Error()) return } } if len(chapters) > 0 { e := models.MultiAddReportChaptersSaveLog(chapters, adminId, adminRealName) if e != nil { err = fmt.Errorf("MultiAddReportChaptersSaveLog: %s", e.Error()) return } } return } // HandleVideoDecibel 处理报告中的音频文件 func HandleVideoDecibel(chapterInfo *models.ReportChapter) { public_api.HandleVideoDecibel(chapterInfo.ReportChapterId) return }