123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992 |
- package controllers
- import (
- "encoding/json"
- "eta/eta_api/models"
- "eta/eta_api/services"
- "eta/eta_api/services/alarm_msg"
- "eta/eta_api/services/data"
- "eta/eta_api/utils"
- "fmt"
- "github.com/beego/beego/v2/server/web"
- "github.com/h2non/filetype"
- "github.com/tealeg/xlsx"
- "html"
- "io"
- "os"
- "path"
- "path/filepath"
- "strconv"
- "strings"
- "time"
- )
- type ReportController struct {
- BaseAuthController
- }
- type ReportCommonController struct {
- BaseCommonController
- }
- type ReportUploadCommonController struct {
- web.Controller
- }
- func (this *ReportController) Delete() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- var req models.DeleteReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- if req.ReportIds <= 0 {
- br.Msg = "参数错误"
- br.ErrMsg = "参数错误,报告id不可为空"
- return
- }
- if err := services.DeleteReportAndChapter(req.ReportIds); err != nil {
- br.Msg = "删除失败"
- br.ErrMsg = "删除报告失败, Err: " + err.Error()
- return
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "删除成功"
- }
- func (this *ReportController) Upload() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- f, h, err := this.GetFile("file")
- if err != nil {
- br.Msg = "获取资源信息失败"
- br.ErrMsg = "获取资源信息失败,Err:" + err.Error()
- return
- }
- fileData, e := io.ReadAll(f)
- if e != nil {
- br.Msg = "上传失败"
- br.ErrMsg = "读取文件失败, Err: " + e.Error()
- return
- }
- pass := filetype.IsImage(fileData)
- if !pass {
- br.Msg = "文件格式有误"
- br.ErrMsg = "文件格式有误"
- return
- }
- ext := path.Ext(h.Filename)
- dateDir := time.Now().Format("20060102")
- uploadDir := utils.STATIC_DIR + "hongze/" + dateDir
- err = os.MkdirAll(uploadDir, utils.DIR_MOD)
- if err != nil {
- br.Msg = "存储目录创建失败"
- br.ErrMsg = "存储目录创建失败,Err:" + err.Error()
- return
- }
- randStr := utils.GetRandStringNoSpecialChar(28)
- fileName := randStr + ext
- fpath := uploadDir + "/" + fileName
- defer f.Close()
- err = this.SaveToFile("file", fpath)
- if err != nil {
- br.Msg = "文件上传失败"
- br.ErrMsg = "文件上传失败,Err:" + err.Error()
- return
- }
- resourceUrl := ``
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
- ossClient := services.NewOssClient()
- if ossClient == nil {
- br.Msg = "上传失败"
- br.ErrMsg = "初始化OSS服务失败"
- return
- }
- resourceUrl, err = ossClient.UploadFile(fileName, fpath, "")
- if err != nil {
- br.Msg = "文件上传失败"
- br.ErrMsg = "文件上传失败,Err:" + err.Error()
- return
- }
- defer func() {
- os.Remove(fpath)
- }()
- item := new(models.Resource)
- item.ResourceUrl = resourceUrl
- item.ResourceType = 1
- item.CreateTime = time.Now()
- newId, err := models.AddResource(item)
- if err != nil {
- br.Msg = "资源上传失败"
- br.ErrMsg = "资源上传失败,Err:" + err.Error()
- return
- }
- resp := new(models.ResourceResp)
- resp.Id = newId
- resp.ResourceUrl = resourceUrl
- br.Msg = "上传成功"
- br.Ret = 200
- br.Success = true
- br.Data = resp
- return
- }
- func (this *ReportController) ClassifyIdDetail() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
-
-
- classifyIdFirst, _ := this.GetInt("classify_id_first")
- if classifyIdFirst <= 0 {
- classifyIdFirst, _ = this.GetInt("ClassifyIdFirst")
- }
- classifyIdSecond, _ := this.GetInt("classify_id_second")
- if classifyIdSecond <= 0 {
- classifyIdSecond, _ = this.GetInt("ClassifyIdSecond")
- }
- item, err := models.GetReportDetailByClassifyId(classifyIdFirst, classifyIdSecond)
- if err != nil && err.Error() != utils.ErrNoRow() {
- br.Msg = "获取失败!"
- br.ErrMsg = "获取失败,Err:" + err.Error()
- return
- }
- if item != nil {
- item.Content = html.UnescapeString(item.Content)
- item.ContentSub = html.UnescapeString(item.ContentSub)
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- br.Data = item
- }
- func (this *ReportController) SendTemplateMsg() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- if utils.BusinessCode != utils.BusinessCodeRelease && utils.BusinessCode != utils.BusinessCodeSandbox && utils.BusinessCode != utils.BusinessCodeDebug {
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- return
- }
- var req models.SendTemplateMsgReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- if req.ReportId <= 0 {
- br.Msg = "参数错误"
- br.ErrMsg = "参数错误"
- return
- }
- report, _ := models.GetReportById(req.ReportId)
- if report.MsgIsSend == 1 {
- br.Msg = "消息已推送,请勿重复操作"
- br.ErrMsg = "模板消息已推送,请勿重复操作"
- return
- }
- videoNameDate := `(` + time.Now().Format("0102") + `)`
- err = models.UpdateReportPublishTime(req.ReportId, videoNameDate)
- if err != nil {
- br.Msg = "修改报告发布时间失败"
- br.ErrMsg = "修改发布时间失败,Err:" + err.Error()
- return
- }
- err = models.UpdateReportChapterPublishTime(req.ReportId, videoNameDate)
- if err != nil {
- br.Msg = "修改章节发布时间失败"
- br.ErrMsg = "修改发布时间失败,Err:" + err.Error()
- return
- }
- services.SendMiniProgramReportWxMsg(req.ReportId)
- err = models.ModifyReportMsgIsSend(req.ReportId)
- if err != nil {
- br.Msg = "发送失败"
- br.ErrMsg = "发送失败,Err:" + err.Error()
- return
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "发送成功"
- br.IsAddLog = true
- }
- func (this *ReportController) Author() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- keyword := this.GetString("Keyword")
- var condition string
- var pars []interface{}
- condition += ` AND author_type = 1 AND enable = 1`
- if keyword != `` {
- condition += ` AND report_author like ? `
- pars = append(pars, utils.GetLikeKeyword(keyword))
- }
- _, items, err := models.GetReportAuthorList(condition, pars, 0, 10000)
- if err != nil {
- br.Msg = "获取失败!"
- br.ErrMsg = "获取失败,Err:" + err.Error()
- return
- }
- resp := models.ReportAuthorResp{
- List: items,
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- br.Data = resp
- }
- func (this *ReportUploadCommonController) UploadImg() {
- var err error
- defer func() {
- if err != nil {
- fmt.Println("文件上传失败:", err.Error())
- go alarm_msg.SendAlarmMsg("URI:"+this.Ctx.Input.URI()+" 文件上传失败:"+err.Error(), 3)
-
- }
- }()
- f, h, err := this.GetFile("file")
- if err != nil {
- return
- }
- defer f.Close()
-
- fileData, e := io.ReadAll(f)
- if e != nil {
- err = fmt.Errorf("读取文件失败, Err: %s", e.Error())
- return
- }
- pass := filetype.IsImage(fileData)
- if !pass {
- kind, _ := filetype.Match(fileData)
- if kind.Extension != "pdf" {
- err = fmt.Errorf("文件格式有误")
- return
- }
- fmt.Printf("File type: %s. MIME: %s\n", kind.Extension, kind.MIME.Value)
- }
- ext := path.Ext(h.Filename)
- dateDir := time.Now().Format("20060102")
- uploadDir := utils.STATIC_DIR + "hongze/" + dateDir
- err = os.MkdirAll(uploadDir, utils.DIR_MOD)
- if err != nil {
- return
- }
- randStr := utils.GetRandStringNoSpecialChar(28)
- fileName := randStr + ext
- fpath := uploadDir + "/" + fileName
- err = this.SaveToFile("file", fpath)
- if err != nil {
- return
- }
- defer func() {
- os.Remove(fpath)
- }()
-
- resourceUrl := ``
- ossClient := services.NewOssClient()
- if ossClient == nil {
- err = fmt.Errorf("初始化OSS服务失败")
- return
- }
- resourceUrl, err = ossClient.UploadFile(fileName, fpath, "")
- if err != nil {
- err = fmt.Errorf("文件上传失败, Err: %s", err.Error())
- return
- }
- item := new(models.Resource)
- item.ResourceUrl = resourceUrl
- item.ResourceType = 1
- item.CreateTime = time.Now()
- newId, err := models.AddResource(item)
- if err != nil {
- return
- }
- resp := new(models.ResourceResp)
- resp.Id = newId
- resp.ResourceUrl = resourceUrl
- this.Data["json"] = map[string]string{"link": resourceUrl}
- this.ServeJSON()
- }
- func (this *ReportController) Export() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- reportIds := this.GetString("ReportIds")
- if reportIds == "" {
- br.Msg = "请选择需要下载的报告"
- br.ErrMsg = "请选择需要下载的报告"
- return
- }
-
- dir, err := os.Executable()
- exPath := filepath.Dir(dir)
- downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
- xlsxFile := xlsx.NewFile()
- if err != nil {
- br.Msg = "生成文件失败"
- br.ErrMsg = "生成文件失败"
- return
- }
-
- if sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_RAI_RESEARCHR && sysUser.RoleTypeCode != utils.ROLE_TYPE_CODE_ADMIN {
- br.Msg = "没有下载权限"
- br.ErrMsg = "没有下载权限"
- return
- }
-
- style := xlsx.NewStyle()
- alignment := xlsx.Alignment{
- Horizontal: "center",
- Vertical: "center",
- WrapText: true,
- }
-
- xlsx.SetDefaultFont(12, "宋体")
- style.Alignment = alignment
- style.ApplyAlignment = true
-
- titleStyle := xlsx.NewStyle()
- titleFont := xlsx.NewFont(20, "宋体")
- titleFont.Bold = true
- titleStyle.Font = *titleFont
- titleStyle.Alignment = alignment
-
-
- headerStyle := xlsx.NewStyle()
- headerFont := xlsx.NewFont(12, "宋体")
- headerFont.Bold = true
- headerStyle.Font = *headerFont
- headerStyle.Alignment = alignment
- headerStyle.ApplyAlignment = true
- defer func() {
- os.Remove(downLoadnFilePath)
- }()
-
- sheetNameMap := make(map[string]int)
- reportSlice := strings.Split(reportIds, ",")
- for _, reportIdStr := range reportSlice {
- reportId, convErr := strconv.Atoi(reportIdStr)
- if convErr != nil {
- br.Msg = "报告传参异常"
- br.ErrMsg = "报告传参异常"
- return
- }
- report, reportErr := models.GetReportById(reportId)
- if reportErr != nil {
- br.Msg = "查询报告异常"
- br.ErrMsg = "查询报告异常:" + reportErr.Error()
- return
- }
-
- _, viewList, err := models.GetViewListByReportId(reportId)
-
-
-
- if err != nil {
- br.Msg = "查询报告浏览记录异常"
- br.ErrMsg = "查询报告浏览记录异常:" + err.Error()
- return
- }
-
-
- createTime, _ := time.Parse(utils.FormatDateTime, report.CreateTime)
- timeStr := createTime.Format("0102")
- reportName := report.Title + "(" + timeStr + ")"
-
- sheetName := reportName
-
- if n, ok := sheetNameMap[sheetName]; ok == true {
- n++
- sheetName = sheetName + "_" + strconv.Itoa(n)
- sheetNameMap[sheetName] = n
- } else {
- sheetNameMap[sheetName] = 1
- }
- sheel, err := xlsxFile.AddSheet(sheetName)
- if err != nil {
- br.Msg = "新增Sheet失败"
- br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
- return
- }
-
- sheel.SetColWidth(0, 0, 28)
- sheel.SetColWidth(1, 1, 18)
- sheel.SetColWidth(2, 2, 18)
- sheel.SetColWidth(3, 3, 18)
- sheel.SetColWidth(4, 4, 40)
-
- titleRow := sheel.AddRow()
- titleRow.SetHeight(40)
-
- titleCell := titleRow.AddCell()
- titleCell.HMerge = 4
-
- titleCell.SetValue(reportName)
- titleCell.SetStyle(titleStyle)
-
- headerRow := sheel.AddRow()
- headerRow.SetHeight(18)
- timeHeaderCell := headerRow.AddCell()
- timeHeaderCell.SetValue("浏览时间")
- timeHeaderCell.SetStyle(headerStyle)
- nameHeaderCell := headerRow.AddCell()
- nameHeaderCell.SetValue("用户名称")
- nameHeaderCell.SetStyle(headerStyle)
- mobileHeaderCell := headerRow.AddCell()
- mobileHeaderCell.SetValue("手机号")
- mobileHeaderCell.SetStyle(headerStyle)
- emailHeaderCell := headerRow.AddCell()
- emailHeaderCell.SetValue("邮箱")
- emailHeaderCell.SetStyle(headerStyle)
- companyHeaderCell := headerRow.AddCell()
- companyHeaderCell.SetValue("所属企业客户名称")
- companyHeaderCell.SetStyle(headerStyle)
- for _, v := range viewList {
- dataRow := sheel.AddRow()
- dataRow.SetHeight(18)
- timeCell := dataRow.AddCell()
- timeCell.SetString(v.CreateTime.Format(utils.FormatDateTime))
- timeCell.SetStyle(style)
- nameCell := dataRow.AddCell()
- nameCell.SetString(v.RealName)
- nameCell.SetStyle(style)
- mobileCell := dataRow.AddCell()
- mobileCell.SetString(v.Mobile)
- mobileCell.SetStyle(style)
- emailCell := dataRow.AddCell()
- emailCell.SetString(v.Email)
- emailCell.SetStyle(style)
- companyCell := dataRow.AddCell()
- companyCell.SetString(v.CompanyName)
- companyCell.SetStyle(style)
- }
- }
- err = xlsxFile.Save(downLoadnFilePath)
- if err != nil {
- br.Msg = "保存文件失败"
- br.ErrMsg = "保存文件失败"
- return
- }
- randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
- downloadFileName := "研报浏览记录" + randStr + ".xlsx"
- this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
- br.Ret = 200
- br.Success = true
- br.Msg = "导出成功"
- }
- func (this *ReportController) ThsSendTemplateMsg() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- var req models.ThsSendTemplateMsgReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- for _, v := range req.ReportId {
- if v <= 0 {
- br.Msg = "参数错误"
- br.ErrMsg = "参数错误"
- return
- }
-
- {
- redisKey := fmt.Sprint("report:send:ths:", v)
- ok := utils.Rc.SetNX(redisKey, 1, time.Second*300)
- if !ok {
- br.Msg = "报告已推送客群,请勿重复推送"
- return
- }
- defer func() {
- utils.Rc.Delete(redisKey)
- }()
- }
- report, err := models.GetReportById(v)
- if err != nil {
- if err.Error() == utils.ErrNoRow() {
- br.Msg = "报告已经被删除,请刷新页面"
- br.ErrMsg = "报告已经被删除,请刷新页面,req:" + string(this.Ctx.Input.RequestBody)
- return
- }
- br.Msg = "获取报告信息失败"
- br.ErrMsg = "获取报告信息失败,req:" + string(this.Ctx.Input.RequestBody)
- return
- }
- if report.ThsMsgIsSend == 1 {
- br.Msg = "消息已推送,请勿重复操作"
- br.ErrMsg = "模板消息已推送,请勿重复操作1"
- return
- }
- err = models.ModifyReportThsMsgIsSend(report)
- if err != nil {
- br.Msg = "发送失败"
- br.ErrMsg = "发送失败,Err:" + err.Error()
- return
- }
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "发送成功"
- }
- func (this *ReportController) GetDayWeekReportChapterTypeList() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- if utils.BusinessCode != utils.BusinessCodeRelease && utils.BusinessCode != utils.BusinessCodeSandbox && utils.BusinessCode != utils.BusinessCodeDebug {
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- return
- }
- var condition string
- var pars []interface{}
-
- stopType := this.GetString("StopType")
- switch stopType {
- case "", "stop":
- condition += ` AND enabled = ? `
- pars = append(pars, 1)
- case "disable":
- default:
- br.Msg = "停更类型异常"
- br.IsSendEmail = false
- return
- }
- dayList := make([]*models.ReportChapterType, 0)
- weekList := make([]*models.ReportChapterType, 0)
-
- {
- tmpCondition := condition
- tmpPars := pars
-
- tmpCondition += ` AND research_type = ? `
- tmpPars = append(tmpPars, "day")
- list, err := models.GetAllReportChapterTypeList(tmpCondition, tmpPars)
- if err != nil {
- br.Msg = "获取报告章节类型列表失败"
- br.ErrMsg = "获取报告章节类型列表失败, Err: " + err.Error()
- return
- }
- nowTime := time.Now()
- for _, v := range list {
- if v.IsSet == 1 {
- endTime, _ := time.Parse(utils.FormatDate, v.PauseEndTime)
- if nowTime.After(endTime.AddDate(0, 0, 1)) {
- v.IsSet = 0
- v.PauseStartTime = ``
- v.PauseEndTime = ``
- }
- }
- dayList = append(dayList, v)
- }
- }
-
- {
- tmpCondition := condition
- tmpPars := pars
-
- tmpCondition += ` AND research_type = ? `
- tmpPars = append(tmpPars, "week")
- list, err := models.GetAllReportChapterTypeList(tmpCondition, tmpPars)
- if err != nil {
- br.Msg = "获取报告章节类型列表失败"
- br.ErrMsg = "获取报告章节类型列表失败, Err: " + err.Error()
- return
- }
- nowTime := time.Now()
- for _, v := range list {
- if v.IsSet == 1 {
- endTime, _ := time.Parse(utils.FormatDate, v.PauseEndTime)
- if nowTime.After(endTime.AddDate(0, 0, 1)) {
- v.IsSet = 0
- v.PauseStartTime = ``
- v.PauseEndTime = ``
- }
- }
- weekList = append(weekList, v)
- }
- }
- resp := models.UpdateReportChapterTypeResp{
- Day: dayList,
- Week: weekList,
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- br.Data = resp
- }
- func (this *ReportController) GetDayWeekReportPauseTime() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- if utils.BusinessCode != utils.BusinessCodeRelease && utils.BusinessCode != utils.BusinessCodeSandbox && utils.BusinessCode != utils.BusinessCodeDebug {
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- return
- }
- list, err := models.GetDayWeekReportPauseTimeList()
- if err != nil {
- br.Msg = "获取晨报周报的更新暂停时间失败"
- br.ErrMsg = "获取晨报周报的更新暂停时间失败, Err: " + err.Error()
- return
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- br.Data = list
- }
- func (this *ReportController) SetDayWeekReportUpdateRule() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- if utils.BusinessCode != utils.BusinessCodeRelease && utils.BusinessCode != utils.BusinessCodeSandbox && utils.BusinessCode != utils.BusinessCodeDebug {
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- return
- }
- var req models.SetDayWeekReportUpdateRuleReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- researchType := req.ResearchType
- if researchType == "" {
- br.Msg = "报告类型不能为空"
- return
- }
-
- if err := models.SetDayWeekReportUpdateRule(researchType, req.List); err != nil {
- br.Msg = "设置暂停时间失败"
- br.ErrMsg = "设置暂停时间失败, Err: " + err.Error()
- return
- }
-
- go func() {
- var syncReq services.ChapterTypeSyncReq
- _, _ = services.ReportChapterTypeSync(&syncReq)
- }()
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- }
- func (this *ReportController) SetDayWeekReportEnableRule() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- if utils.BusinessCode != utils.BusinessCodeRelease && utils.BusinessCode != utils.BusinessCodeSandbox && utils.BusinessCode != utils.BusinessCodeDebug {
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- return
- }
- var req models.SetDayWeekReportEnableUpdateRuleReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- dayReportChapterTypeIdList := strings.Split(req.DayReportChapterTypeId, ",")
- weekReportChapterTypeIdList := strings.Split(req.WeekReportChapterTypeId, ",")
-
-
-
-
-
-
- if err := models.SetDayWeekReportEnableUpdateRule(dayReportChapterTypeIdList, weekReportChapterTypeIdList); err != nil {
- br.Msg = "设置永久停更失败"
- br.ErrMsg = "设置永久停更失败, Err: " + err.Error()
- return
- }
- go func() {
- var syncReq services.ChapterTypeSyncReq
- _, _ = services.ReportChapterTypeSync(&syncReq)
- }()
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- }
- func (this *ReportController) EditDayWeekReport() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- if utils.BusinessCode != utils.BusinessCodeRelease && utils.BusinessCode != utils.BusinessCodeSandbox && utils.BusinessCode != utils.BusinessCodeDebug {
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- return
- }
- var req models.SaveDayWeekReportReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- if req.ReportId == 0 {
- br.Msg = "报告ID有误"
- return
- }
- if req.ReportType == "" {
- br.Msg = "请选择报告类型"
- return
- }
- if req.ReportType != utils.REPORT_TYPE_DAY && req.ReportType != utils.REPORT_TYPE_WEEK {
- br.Msg = "报告类型有误"
- return
- }
- if req.Title == "" {
- br.Msg = "请输入报告标题"
- return
- }
- if req.CreateTime == "" {
- br.Msg = "请选择发布时间"
- return
- }
- reportInfo, err := models.GetReportByReportId(req.ReportId)
- if err != nil {
- br.Msg = "获取报告信息失败"
- br.ErrMsg = "获取报告信息失败, Err: " + err.Error()
- return
- }
- if req.ReportType != reportInfo.ChapterType {
- br.Msg = "暂不允许修改晨周报类型"
- return
- }
- reportInfo.Title = req.Title
- reportInfo.CreateTime = req.CreateTime
- reportInfo.Author = req.Author
- err = models.EditReport(reportInfo, int64(req.ReportId))
- br.Ret = 200
- br.Success = true
- br.Msg = "保存成功"
- }
- func (this *ReportController) GetLastDayWeekReportChapter() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- if utils.BusinessCode != utils.BusinessCodeRelease && utils.BusinessCode != utils.BusinessCodeSandbox && utils.BusinessCode != utils.BusinessCodeDebug {
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- return
- }
- typeId, _ := this.GetInt("TypeId")
- reportType := this.GetString("ReportType")
- item, err := models.GetLastPublishedReportChapter(typeId, reportType)
- if err != nil && err.Error() != utils.ErrNoRow() {
- br.Msg = "获取失败"
- br.ErrMsg = "获取上一篇晨周报失败, Err: " + err.Error()
- return
- }
- if item != nil {
- item.Content = html.UnescapeString(item.Content)
- item.ContentSub = html.UnescapeString(item.ContentSub)
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- br.Data = item
- }
- func (this *ReportController) GetChapterTrendTag() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- list, err := models.GetKeyWordListByFrom("trend")
- if err != nil {
- br.Msg = "获取章节趋势标签列表失败"
- br.ErrMsg = "获取章节趋势标签列表失败, Err: " + err.Error()
- return
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- br.Data = list
- }
- func (this *ReportController) GetDayReportTickerList() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- if utils.BusinessCode != utils.BusinessCodeRelease && utils.BusinessCode != utils.BusinessCodeSandbox && utils.BusinessCode != utils.BusinessCodeDebug {
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- return
- }
- reportChapterId, _ := this.GetInt("ReportChapterId")
- if reportChapterId <= 0 {
- br.Msg = "章节ID有误"
- return
- }
- chapterInfo, err := models.GetReportChapterInfoById(reportChapterId)
- if err != nil {
- br.Msg = "获取章节信息失败"
- br.ErrMsg = "获取章节信息失败, Err: " + err.Error()
- return
- }
-
- tickerList, err := models.GetDailyBaseColumnList("", chapterInfo.TypeId)
- if err != nil {
- br.Msg = "获取指标列表失败"
- br.ErrMsg = "获取指标列表失败, Err: " + err.Error()
- return
- }
-
- reportTicker, err := models.GetTickerListByReportChapterId(reportChapterId)
- if err != nil {
- br.Msg = "获取章节Ticker失败"
- br.ErrMsg = "获取章节Ticker失败, Err: " + err.Error()
- return
- }
- selectMap := make(map[string]int, 0)
- for i := 0; i < len(reportTicker); i++ {
- selectMap[reportTicker[i].Ticker] = 1
- }
-
- for _, item := range tickerList {
- if _, in := selectMap[item.BaseColumnTicker]; in {
- item.Selected = 1
- }
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- br.Data = tickerList
- }
- func (this *ReportController) GetDayWeekReportVideoList() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- reportId, _ := this.GetInt("ReportId")
- if reportId <= 0 {
- br.Msg = "参数有误"
- return
- }
- list, err := models.GetReportChapterVideoList(reportId)
- if err != nil {
- br.Msg = "获取失败"
- br.ErrMsg = "获取报告音频列表失败, Err: " + err.Error()
- return
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- br.Data = list
- }
- func (this *ReportController) IsLastDayWeekReportChapter() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- if utils.BusinessCode != utils.BusinessCodeRelease && utils.BusinessCode != utils.BusinessCodeSandbox && utils.BusinessCode != utils.BusinessCodeDebug {
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- return
- }
- reportChapterId, _ := this.GetInt("ReportChapterId")
- if reportChapterId <= 0 {
- br.Msg = "参数有误"
- return
- }
- chapterInfo, err := models.GetReportChapterInfoById(reportChapterId)
- if err != nil {
- br.Msg = "章节信息有误"
- br.ErrMsg = "章节信息有误, Err: " + err.Error()
- return
- }
-
- publishedNum, err := models.CountPublishedChapterNum(chapterInfo.ReportId)
- if err != nil {
- br.Msg = "获取已发布章节数失败"
- br.ErrMsg = "获取已发布章节数失败, Err: " + err.Error()
- return
- }
- enableTypeList, err := models.GetEnableReportChapterTypeList(chapterInfo.ReportType)
- if err != nil {
- br.Msg = "获取章节类型列表失败"
- br.ErrMsg = "获取章节类型列表失败, Err: " + err.Error()
- return
- }
- var isLast bool
- enableNum := len(enableTypeList)
- publishedNum += 1
- if publishedNum == enableNum {
- isLast = true
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- br.Data = isLast
- }
- func (this *ReportController) PublishDayWeekReport() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- if utils.BusinessCode != utils.BusinessCodeRelease && utils.BusinessCode != utils.BusinessCodeSandbox && utils.BusinessCode != utils.BusinessCodeDebug {
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- return
- }
- var req models.PublishDayWeekReportReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- reportId := req.ReportId
- if reportId <= 0 {
- br.Msg = "参数有误"
- return
- }
- reportInfo, err := models.GetReportByReportId(reportId)
- if err != nil {
- br.Msg = "报告信息有误"
- br.ErrMsg = "报告信息有误, Err: " + err.Error()
- return
- }
- if reportInfo.State == 2 {
- br.Msg = "该报告已发布"
- return
- }
-
- refreshResult := data.CheckBatchChartRefreshResult("report", reportId, 0)
- if !refreshResult {
- br.Msg = "图表刷新未完成,请稍后操作"
- br.ErrMsg = "图表刷新未完成,请稍后操作"
- br.IsSendEmail = false
- return
- }
- tips, err, errMsg := services.PublishChapterReport(reportInfo, "", sysUser)
- if err != nil {
- br.Msg = errMsg
- br.ErrMsg = "发布晨/周报失败, Err: " + err.Error()
- return
- }
-
- if tips != "" {
- br.Data = tips
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "操作成功"
- }
- func (this *ReportController) GetStopDayWeekReportChapterTypeList() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- if utils.BusinessCode != utils.BusinessCodeRelease && utils.BusinessCode != utils.BusinessCodeSandbox && utils.BusinessCode != utils.BusinessCodeDebug {
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- return
- }
- stopDay := make([]*models.ReportChapterType, 0)
- stopWeek := make([]*models.ReportChapterType, 0)
- disableDay := make([]*models.ReportChapterType, 0)
- disableWeek := make([]*models.ReportChapterType, 0)
- stopList, err := models.GetStopUpdateReportChapterTypeListByResearchType()
- if err != nil {
- br.Msg = "获取暂停更新报告章节类型列表失败"
- br.ErrMsg = "获取暂停更新报告章节类型列表失败, Err: " + err.Error()
- return
- }
- for _, v := range stopList {
- if v.ResearchType == "day" {
- stopDay = append(stopDay, v)
- } else {
- stopWeek = append(stopWeek, v)
- }
- }
- disableList, err := models.GetDisableUpdateReportChapterTypeListByResearchType()
- if err != nil {
- br.Msg = "获取停止更新报告章节类型列表失败"
- br.ErrMsg = "获取停止更新报告章节类型列表失败, Err: " + err.Error()
- return
- }
- for _, v := range disableList {
- if v.ResearchType == "day" {
- disableDay = append(disableDay, v)
- } else {
- disableWeek = append(disableWeek, v)
- }
- }
- resp := models.StopUpdateReportChapterTypeResp{
- StopDay: stopDay,
- StopWeek: stopWeek,
- DisableDay: disableDay,
- DisableWeek: disableWeek,
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "获取成功"
- br.Data = resp
- }
- func (this *ReportController) MarkEditStatus() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- var req models.MarkEditReport
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- if req.ReportId <= 0 {
- br.Msg = "缺少报告Id"
- return
- }
- if req.Status < 0 {
- br.Msg = "标记状态异常"
- return
- }
-
- data, err := services.UpdateReportEditMark(req.ReportId, req.ReportChapterId, sysUser.AdminId, req.Status, sysUser.RealName, this.Lang)
- if err != nil {
- br.Msg = err.Error()
- return
- }
- msg := "标记成功"
- br.Ret = 200
- br.Success = true
- br.Msg = msg
- br.Data = data
- }
- func (this *ReportController) SendMsg() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- var req models.SendTemplateMsgReq
- err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
- if err != nil {
- br.Msg = "参数解析异常!"
- br.ErrMsg = "参数解析失败,Err:" + err.Error()
- return
- }
- if req.ReportId <= 0 {
- br.Msg = "参数错误"
- br.ErrMsg = "参数错误"
- return
- }
-
- {
- redisKey := fmt.Sprint("report:send:ths:", req.ReportId)
- ok := utils.Rc.SetNX(redisKey, 1, time.Second*300)
- if !ok {
- br.Msg = "报告已推送, 请勿重复推送"
- return
- }
- defer func() {
- _ = utils.Rc.Delete(redisKey)
- }()
- }
- reportInfo, e := models.GetReportByReportId(req.ReportId)
- if e != nil {
- br.Msg = "报告不存在或已被删除, 请刷新页面"
- br.ErrMsg = "获取报告失败, Err: " + e.Error()
- return
- }
- if reportInfo.MsgIsSend == 1 && reportInfo.ThsMsgIsSend == 1 {
- br.Msg = "消息已推送,请勿重复操作"
- br.ErrMsg = "消息已推送,请勿重复操作"
- return
- }
-
- if reportInfo.IsPublicPublish != 1 {
- br.Msg = "报告未公开"
- return
- }
-
- videoNameDate := `(` + time.Now().Format("0102") + `)`
- if err = models.UpdateReportPublishTime(req.ReportId, videoNameDate); err != nil {
- br.Msg = "修改报告发布时间失败"
- br.ErrMsg = "修改发布时间失败,Err:" + err.Error()
- return
- }
- if err = models.UpdateReportChapterPublishTime(req.ReportId, videoNameDate); err != nil {
- br.Msg = "修改章节发布时间失败"
- br.ErrMsg = "修改发布时间失败,Err:" + err.Error()
- return
- }
-
-
- if reportInfo.MsgIsSend == 0 {
- go services.SendMiniProgramReportWxMsg(reportInfo.Id)
- }
-
- reportInfo.MsgIsSend = 1
- reportInfo.ThsMsgIsSend = 1
- reportInfo.MsgSendTime = time.Now()
- reportInfo.ModifyTime = time.Now()
- err = reportInfo.UpdateReport([]string{"MsgIsSend", "ThsMsgIsSend", "MsgSendTime", "ModifyTime"})
- if err != nil {
- br.Msg = "推送失败"
- br.ErrMsg = "更新报告消息状态失败, Err:" + err.Error()
- return
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "推送成功"
- br.IsAddLog = true
- br.Data = models.SendTemplateMsgResp{
- ReportId: reportInfo.Id,
- MsgSendTime: reportInfo.MsgSendTime.Format(utils.FormatDateTime),
- }
- }
- func (this *ReportController) CheckDayWeekReportChapterVideo() {
- br := new(models.BaseResponse).Init()
- defer func() {
- this.Data["json"] = br
- this.ServeJSON()
- }()
- sysUser := this.SysUser
- if sysUser == nil {
- br.Msg = "请登录"
- br.ErrMsg = "请登录,SysUser Is Empty"
- br.Ret = 408
- return
- }
- reqReportId := this.GetString("ReportId")
- reportId, _ := strconv.Atoi(reqReportId)
- if reportId <= 0 {
- br.Msg = "报告ID有误"
- return
- }
-
- chapterList, err := models.GetChapterListByReportId(reportId)
- if err != nil {
- br.Msg = "获取章节列表失败"
- br.ErrMsg = "获取章节列表失败, Err: " + err.Error()
- return
- }
- typeNameArr := make([]string, 0)
- for _, v := range chapterList {
- if v.VideoUrl == "" || (v.VideoUrl != "" && v.VideoKind == 2) {
- typeNameArr = append(typeNameArr, v.TypeName)
- }
- }
- br.Ret = 200
- br.Success = true
- br.Msg = "保存成功"
- br.Data = typeNameArr
- }
|