report.go 42 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500
  1. package english_report
  2. import (
  3. "encoding/json"
  4. "eta/eta_api/controllers"
  5. "eta/eta_api/models"
  6. "eta/eta_api/models/company"
  7. "eta/eta_api/models/report_approve"
  8. "eta/eta_api/models/system"
  9. "eta/eta_api/services"
  10. "eta/eta_api/services/alarm_msg"
  11. "eta/eta_api/services/data"
  12. "eta/eta_api/utils"
  13. "fmt"
  14. "html"
  15. "strconv"
  16. "strings"
  17. "time"
  18. "github.com/rdlucklib/rdluck_tools/paging"
  19. )
  20. // EnglishReportController 研报活动模块
  21. type EnglishReportController struct {
  22. controllers.BaseAuthController
  23. }
  24. // @Title 新增报告接口
  25. // @Description 新增报告
  26. // @Param request body models.AddEnglishReportReq true "type json string"
  27. // @Success 200 {object} models.AddEnglishReportResp
  28. // @router /add [post]
  29. func (this *EnglishReportController) Add() {
  30. br := new(models.BaseResponse).Init()
  31. defer func() {
  32. this.Data["json"] = br
  33. this.ServeJSON()
  34. }()
  35. sysUser := this.SysUser
  36. if sysUser == nil {
  37. br.Msg = "请登录"
  38. br.ErrMsg = "请登录,SysUser Is Empty"
  39. br.Ret = 408
  40. return
  41. }
  42. var req models.AddEnglishReportReq
  43. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  44. if err != nil {
  45. br.Msg = "参数解析异常!"
  46. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  47. return
  48. }
  49. if req.Content == "" {
  50. br.Msg = "请输入内容"
  51. return
  52. }
  53. if req.Overview == "" {
  54. br.Msg = "请输入overview"
  55. return
  56. }
  57. if req.Abstract == "" {
  58. br.Msg = "请输入摘要"
  59. return
  60. }
  61. var contentSub string
  62. if req.Content != "" {
  63. req.Content = services.HandleReportContent(req.Content, "del", nil)
  64. e := utils.ContentXssCheck(req.Content)
  65. if e != nil {
  66. br.Msg = "存在非法标签"
  67. br.ErrMsg = "存在非法标签, Err: " + e.Error()
  68. return
  69. }
  70. content, e := services.FilterReportContentBr(req.Content)
  71. if e != nil {
  72. br.Msg = "内容去除前后空格失败"
  73. br.ErrMsg = "内容去除前后空格失败, Err: " + e.Error()
  74. return
  75. }
  76. req.Content = content
  77. contentSub, err = services.GetReportContentSub(req.Content)
  78. if err != nil {
  79. go alarm_msg.SendAlarmMsg("ContentSub 失败,Err:"+err.Error(), 3)
  80. //utils.SendEmail(utils.APPNAME+"失败提醒", "解析 ContentSub 失败,Err:"+err.Error(), utils.EmailSendToUsers)
  81. }
  82. }
  83. maxStage, err := models.GetEnglishReportStage(req.ClassifyIdFirst, req.ClassifyIdSecond)
  84. if err != nil {
  85. br.Msg = "期数获取失败!"
  86. br.ErrMsg = "期数获取失败,Err:" + err.Error()
  87. return
  88. }
  89. reportClassify, e := models.GetEnglishReportClassifyById(req.ClassifyIdFirst)
  90. if e != nil {
  91. if e.Error() == utils.ErrNoRow() {
  92. br.Msg = "报告所在分类异常"
  93. return
  94. }
  95. br.Msg = "操作失败"
  96. br.ErrMsg = "获取分类失败, Err: " + e.Error()
  97. return
  98. }
  99. // 根据审批开关及审批流判断当前报告状态
  100. state, e := services.CheckReportCurrState(report_approve.FlowReportTypeEnglish, reportClassify.RootId, req.ClassifyIdFirst, req.ClassifyIdSecond, models.ReportOperateAdd)
  101. if e != nil {
  102. br.Msg = "操作失败"
  103. br.ErrMsg = "校验报告当前状态失败, Err: " + e.Error()
  104. return
  105. }
  106. item := new(models.EnglishReport)
  107. item.AddType = req.AddType
  108. item.ClassifyIdFirst = req.ClassifyIdFirst
  109. item.ClassifyNameFirst = req.ClassifyNameFirst
  110. item.ClassifyIdSecond = req.ClassifyIdSecond
  111. item.ClassifyNameSecond = req.ClassifyNameSecond
  112. item.Title = req.Title
  113. item.Abstract = req.Abstract
  114. item.Author = req.Author
  115. item.Frequency = req.Frequency
  116. item.State = state
  117. item.Content = html.EscapeString(req.Content)
  118. item.Stage = maxStage + 1
  119. item.ContentSub = html.EscapeString(contentSub)
  120. item.CreateTime = req.CreateTime
  121. item.ModifyTime = time.Now()
  122. item.Overview = req.Overview
  123. item.AdminId = sysUser.AdminId
  124. item.AdminRealName = sysUser.RealName
  125. newReportId, err := models.AddEnglishReport(item)
  126. if err != nil {
  127. br.Msg = "保存失败"
  128. br.ErrMsg = "保存失败,Err:" + err.Error()
  129. return
  130. }
  131. reportCode := utils.MD5(strconv.Itoa(int(newReportId)))
  132. //修改唯一编码
  133. {
  134. go models.ModifyEnglishReportCode(newReportId, reportCode)
  135. }
  136. resp := new(models.AddEnglishReportResp)
  137. resp.ReportId = newReportId
  138. resp.ReportCode = reportCode
  139. br.Ret = 200
  140. br.Success = true
  141. br.Msg = "保存成功"
  142. br.Data = resp
  143. }
  144. // @Title 编辑报告接口
  145. // @Description 编辑报告
  146. // @Param request body models.EditEnglishReportReq true "type json string"
  147. // @Success 200 {object} models.EditEnglishReportResp
  148. // @router /edit [post]
  149. func (this *EnglishReportController) Edit() {
  150. br := new(models.BaseResponse).Init()
  151. defer func() {
  152. this.Data["json"] = br
  153. this.ServeJSON()
  154. }()
  155. sysUser := this.SysUser
  156. if sysUser == nil {
  157. br.Msg = "请登录"
  158. br.ErrMsg = "请登录,SysUser Is Empty"
  159. br.Ret = 408
  160. return
  161. }
  162. var req models.EditEnglishReportReq
  163. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  164. if err != nil {
  165. br.Msg = "参数解析异常!"
  166. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  167. return
  168. }
  169. if req.Content == "" {
  170. br.Msg = "请输入内容"
  171. return
  172. }
  173. if req.Overview == "" {
  174. br.Msg = "请输入overview"
  175. return
  176. }
  177. if req.Abstract == "" {
  178. br.Msg = "请输入摘要"
  179. return
  180. }
  181. markStatus, err := services.UpdateEnReportEditMark(int(req.ReportId), sysUser.AdminId, 1, sysUser.RealName, this.Lang)
  182. if err != nil {
  183. br.Msg = err.Error()
  184. return
  185. }
  186. if markStatus.Status == 1 {
  187. br.Msg = markStatus.Msg
  188. return
  189. }
  190. var contentSub string
  191. if req.Content != "" {
  192. req.Content = services.HandleReportContent(req.Content, "del", nil)
  193. e := utils.ContentXssCheck(req.Content)
  194. if e != nil {
  195. br.Msg = "存在非法标签"
  196. br.ErrMsg = "存在非法标签, Err: " + e.Error()
  197. return
  198. }
  199. content, e := services.FilterReportContentBr(req.Content)
  200. if e != nil {
  201. br.Msg = "内容去除前后空格失败"
  202. br.ErrMsg = "内容去除前后空格失败, Err: " + e.Error()
  203. return
  204. }
  205. req.Content = content
  206. contentSub, err = services.GetReportContentSub(req.Content)
  207. if err != nil {
  208. go alarm_msg.SendAlarmMsg("解析 ContentSub 失败,Err:"+err.Error(), 3)
  209. //utils.SendEmail(utils.APPNAME+"失败提醒", "解析 ContentSub 失败,Err:"+err.Error(), utils.EmailSendToUsers)
  210. }
  211. }
  212. var stage int
  213. report, e := models.GetEnglishReportById(int(req.ReportId))
  214. if e != nil {
  215. if e.Error() == utils.ErrNoRow() {
  216. br.Msg = "报告已被删除, 请刷新页面"
  217. return
  218. }
  219. br.Msg = "操作失败"
  220. br.ErrMsg = "获取报告失败, Err: " + e.Error()
  221. return
  222. }
  223. if report.State == models.ReportStatePublished || report.State == models.ReportStatePass {
  224. br.Msg = "该报告已发布,不允许编辑"
  225. br.ErrMsg = "该报告已发布,不允许编辑"
  226. return
  227. }
  228. if report.ClassifyNameFirst != req.ClassifyNameFirst || report.ClassifyNameSecond != req.ClassifyNameSecond {
  229. maxStage, _ := models.GetEnglishReportStageEdit(req.ClassifyIdFirst, req.ClassifyIdSecond, int(req.ReportId))
  230. maxStage = maxStage + 1
  231. stage = maxStage
  232. } else {
  233. stage = report.Stage
  234. }
  235. item := new(models.EnglishReport)
  236. item.ClassifyIdFirst = req.ClassifyIdFirst
  237. item.ClassifyNameFirst = req.ClassifyNameFirst
  238. item.ClassifyIdSecond = req.ClassifyIdSecond
  239. item.ClassifyNameSecond = req.ClassifyNameSecond
  240. item.Title = req.Title
  241. item.Abstract = req.Abstract
  242. item.Author = req.Author
  243. item.Frequency = req.Frequency
  244. item.State = report.State // 编辑不变更状态
  245. item.Stage = stage
  246. item.Content = html.EscapeString(req.Content)
  247. item.ContentSub = html.EscapeString(contentSub)
  248. item.CreateTime = req.CreateTime
  249. item.Overview = req.Overview
  250. err = models.EditEnglishReport(item, req.ReportId)
  251. if err != nil {
  252. br.Msg = "保存失败"
  253. br.ErrMsg = "保存失败,Err:" + err.Error()
  254. return
  255. }
  256. reportCode := utils.MD5(strconv.Itoa(int(req.ReportId)))
  257. resp := new(models.EditEnglishReportResp)
  258. resp.ReportId = req.ReportId
  259. resp.ReportCode = reportCode
  260. br.Ret = 200
  261. br.Success = true
  262. br.Msg = "保存成功"
  263. br.Data = resp
  264. }
  265. // @Title 获取报告详情接口
  266. // @Description 获取报告详情
  267. // @Param request body models.ReportDetailReq true "type json string"
  268. // @Success 200 {object} models.EnglishReportDetailView
  269. // @router /detail [get]
  270. func (this *EnglishReportController) Detail() {
  271. br := new(models.BaseResponse).Init()
  272. defer func() {
  273. this.Data["json"] = br
  274. this.ServeJSON()
  275. }()
  276. /*var req models.ReportDetailReq
  277. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  278. if err != nil {
  279. br.Msg = "参数解析异常!"
  280. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  281. return
  282. }
  283. if req.ReportId <= 0 {
  284. br.Msg = "参数错误"
  285. return
  286. }*/
  287. reportId, err := this.GetInt("ReportId")
  288. if err != nil {
  289. br.Msg = "获取参数失败!"
  290. br.ErrMsg = "获取参数失败,Err:" + err.Error()
  291. return
  292. }
  293. if reportId <= 0 {
  294. br.Msg = "参数错误"
  295. return
  296. }
  297. item, err := models.GetEnglishReportById(reportId)
  298. if err != nil {
  299. if err.Error() == utils.ErrNoRow() {
  300. br.Msg = "报告已被删除"
  301. return
  302. }
  303. br.Msg = "获取失败"
  304. br.ErrMsg = "获取失败,Err:" + err.Error()
  305. return
  306. }
  307. item.Content = html.UnescapeString(item.Content)
  308. item.ContentSub = html.UnescapeString(item.ContentSub)
  309. businessConf, err := models.GetBusinessConfByKey(models.BusinessConfIsOpenChartExpired)
  310. if err != nil {
  311. br.Msg = "获取失败"
  312. br.ErrMsg = "获取配置失败,Err:" + err.Error()
  313. return
  314. }
  315. if businessConf.ConfVal == `true` {
  316. tokenMap := make(map[string]string)
  317. item.Content = services.HandleReportContent(item.Content, "add", tokenMap)
  318. }
  319. classifyNameMap := make(map[int]*models.EnglishClassifyFullName)
  320. if item.ClassifyIdSecond > 0 {
  321. nameList, tErr := models.GetEnglishClassifyFullNameByIds([]int{item.ClassifyIdSecond})
  322. if tErr != nil {
  323. br.Msg = "获取分类名称失败"
  324. br.ErrMsg = "获取分类名称失败, ERR:" + tErr.Error()
  325. return
  326. }
  327. for _, v := range nameList {
  328. classifyNameMap[v.Id] = v
  329. }
  330. //处理分类名
  331. if n, ok := classifyNameMap[item.ClassifyIdSecond]; ok {
  332. item.ClassifyNameRoot = n.RootName
  333. item.ClassifyIdRoot = n.RootId
  334. }
  335. }
  336. br.Ret = 200
  337. br.Success = true
  338. br.Msg = "获取成功"
  339. br.Data = item
  340. }
  341. // ListReport
  342. // @Title 获取报告列表接口
  343. // @Description 获取报告列表
  344. // @Param PageSize query int true "每页数据条数"
  345. // @Param CurrentIndex query int true "当前页页码,从1开始"
  346. // @Param TimeType query string true "筛选的时间类别:publish_time(发布时间),modify_time(更新时间);approve_time(审批时间)"
  347. // @Param StartDate query string true "开始时间"
  348. // @Param EndDate query string true "结束时间"
  349. // @Param Frequency query string true "频度"
  350. // @Param ClassifyIdFirst query string true "一级分类id"
  351. // @Param ClassifyIdSecond query string true "二级分类id"
  352. // @Param State query int true "状态"
  353. // @Param KeyWord query string true "搜索关键词"
  354. // @Param PublishSort query string true "desc:降序,asc 升序(预留)"
  355. // @Param CompanyType query string false "产品类型,枚举值:'ficc','权益';不传默认返回全部"
  356. // @Success 200 {object} models.ReportListResp
  357. // @router /list [get]
  358. func (this *EnglishReportController) ListReport() {
  359. br := new(models.BaseResponse).Init()
  360. defer func() {
  361. this.Data["json"] = br
  362. this.ServeJSON()
  363. }()
  364. sysUser := this.SysUser
  365. if sysUser == nil {
  366. br.Msg = "请登录"
  367. br.ErrMsg = "请登录,SysUser Is Empty"
  368. br.Ret = 408
  369. return
  370. }
  371. pageSize, _ := this.GetInt("PageSize")
  372. currentIndex, _ := this.GetInt("CurrentIndex")
  373. timeType := this.GetString("TimeType")
  374. startDate := this.GetString("StartDate")
  375. endDate := this.GetString("EndDate")
  376. frequency := this.GetString("Frequency")
  377. classifyIdFirst, _ := this.GetInt("ClassifyIdFirst")
  378. classifyIdSecond, _ := this.GetInt("ClassifyIdSecond")
  379. classifyIdRoot, _ := this.GetInt("ClassifyIdRoot")
  380. state, _ := this.GetInt("State")
  381. keyWord := this.GetString("KeyWord")
  382. companyType := this.GetString("CompanyType")
  383. // 群发邮件状态筛选
  384. emailState, _ := this.GetInt("EmailState")
  385. var startSize int
  386. if pageSize <= 0 {
  387. pageSize = utils.PageSize20
  388. }
  389. if currentIndex <= 0 {
  390. currentIndex = 1
  391. }
  392. startSize = utils.StartIndex(currentIndex, pageSize)
  393. var condition string
  394. var pars []interface{}
  395. if keyWord != "" {
  396. condition += ` AND (title LIKE ? OR admin_real_name LIKE ? ) `
  397. pars = utils.GetLikeKeywordPars(pars, keyWord, 2)
  398. }
  399. if timeType == "" {
  400. timeType = "publish_time"
  401. }
  402. if timeType != "publish_time" && timeType != "modify_time" && timeType != "approve_time" {
  403. br.Msg = "请选择正确的时间"
  404. br.ErrMsg = "请选择正确的时间"
  405. return
  406. }
  407. if startDate != "" {
  408. condition += ` AND ` + timeType + ` >= ? `
  409. pars = append(pars, startDate)
  410. }
  411. if endDate != "" {
  412. condition += ` AND ` + timeType + ` <= ? `
  413. pars = append(pars, endDate)
  414. }
  415. if frequency != "" {
  416. condition += ` AND frequency = ? `
  417. pars = append(pars, frequency)
  418. }
  419. if classifyIdFirst != 0 {
  420. condition += ` AND classify_id_first = ? `
  421. pars = append(pars, classifyIdFirst)
  422. }
  423. if classifyIdSecond != 0 {
  424. condition += ` AND classify_id_second = ? `
  425. pars = append(pars, classifyIdSecond)
  426. }
  427. if state > 0 {
  428. condition += ` AND state = ? `
  429. pars = append(pars, state)
  430. }
  431. if classifyIdRoot > 0 && classifyIdFirst == 0 && classifyIdSecond == 0 {
  432. //查询顶级分类下的所有二级分类ID
  433. childClassify, err := models.GetEnglishSecondClassifyList([]int{classifyIdRoot})
  434. if err != nil {
  435. br.Msg = "查询子分类出错"
  436. br.ErrMsg = "查询子分类出错, Err:" + err.Error()
  437. return
  438. }
  439. var childClassifyIds []int
  440. if len(childClassify) > 0 {
  441. for _, v := range childClassify {
  442. childClassifyIds = append(childClassifyIds, v.Id)
  443. }
  444. condition += ` AND classify_id_first IN (` + utils.GetOrmInReplace(len(childClassifyIds)) + `)`
  445. pars = append(pars, childClassifyIds)
  446. } else {
  447. //一级分类下没有子分类,直接返回空列表
  448. page := paging.GetPaging(currentIndex, pageSize, 0)
  449. resp := new(models.EnglishReportListResp)
  450. resp.Paging = page
  451. resp.List = make([]*models.EnglishReportList, 0)
  452. br.Ret = 200
  453. br.Success = true
  454. br.Msg = "获取成功"
  455. br.Data = resp
  456. return
  457. }
  458. }
  459. // 群发邮件状态筛选
  460. {
  461. // 未群发邮件(包含推送邮件失败的)
  462. if emailState == 1 {
  463. condition += ` AND (email_state = 0 OR email_has_fail = 1) `
  464. }
  465. // 已群发邮件
  466. if emailState == 2 {
  467. condition += ` AND email_state = 1 AND email_has_fail = 0 `
  468. }
  469. }
  470. var authOk bool
  471. adminMap := make(map[int]string, 0) // 编辑中的研究员姓名
  472. total, e := models.GetEnglishReportListCount(condition, pars, companyType)
  473. if e != nil {
  474. br.Msg = "获取失败"
  475. br.ErrMsg = "获取英文研报Count失败, Err: " + e.Error()
  476. return
  477. }
  478. list, e := models.GetEnglishReportList(condition, pars, companyType, startSize, pageSize, []string{})
  479. if e != nil {
  480. br.Msg = "获取失败"
  481. br.ErrMsg = "获取英文研报列表失败, Err: " + e.Error()
  482. return
  483. }
  484. // 获取邮件配置-是否有权限群发
  485. conf := new(models.EnglishReportEmailConf)
  486. authKey := "english_report_email_conf"
  487. confAuth, e := company.GetConfigDetailByCode(authKey)
  488. if e != nil {
  489. br.Msg = "获取失败"
  490. br.ErrMsg = "获取群发邮件权限失败, Err: " + e.Error()
  491. return
  492. }
  493. if confAuth.ConfigValue == "" {
  494. br.Msg = "获取失败"
  495. br.ErrMsg = "群发邮件配置为空"
  496. return
  497. }
  498. if e = json.Unmarshal([]byte(confAuth.ConfigValue), &conf); e != nil {
  499. br.Msg = "获取失败"
  500. br.ErrMsg = "群发邮件配置有误, Err: " + e.Error()
  501. return
  502. }
  503. authArr := strings.Split(conf.SendAuthGroup, ",")
  504. if utils.InArrayByStr(authArr, sysUser.RoleTypeCode) {
  505. authOk = true
  506. }
  507. // 获取admin, 用于匹配编辑中的研究员姓名
  508. admins, e := system.GetSysAdminList("", make([]interface{}, 0), []string{"admin_id", "real_name"}, "")
  509. if e != nil {
  510. br.Msg = "获取失败"
  511. br.ErrMsg = "获取系统用户列表失败, Err: " + e.Error()
  512. return
  513. }
  514. for _, a := range admins {
  515. adminMap[a.AdminId] = a.RealName
  516. }
  517. // 查询分类信息
  518. var classifyIdSecondSlice []int
  519. for _, item := range list {
  520. classifyIdSecondSlice = append(classifyIdSecondSlice, item.ClassifyIdSecond)
  521. }
  522. classifyNameMap := make(map[int]*models.EnglishClassifyFullName)
  523. if len(classifyIdSecondSlice) > 0 {
  524. nameList, err := models.GetEnglishClassifyFullNameByIds(classifyIdSecondSlice)
  525. if err != nil {
  526. br.Msg = "获取分类名称失败"
  527. br.ErrMsg = "获取分类名称失败, ERR:" + err.Error()
  528. return
  529. }
  530. for _, v := range nameList {
  531. classifyNameMap[v.Id] = v
  532. }
  533. }
  534. respList := make([]*models.EnglishReportList, 0)
  535. for _, v := range list {
  536. t := models.FormatEnglishReport2ListItem(v)
  537. if v.State == 2 {
  538. t.ShareUrl = "https://share.hzinsights.com/reportEn?code=" + v.ReportCode
  539. }
  540. t.EmailAuth = authOk
  541. // 报告是否正在编辑中
  542. var opUser models.MarkReportItem
  543. key := fmt.Sprint(`crm:enReport:edit:`, v.Id)
  544. opUserId, e := utils.Rc.RedisInt(key)
  545. if e != nil {
  546. str, te := utils.Rc.RedisString(key)
  547. if te == nil {
  548. te = json.Unmarshal([]byte(str), &opUser)
  549. if te == nil {
  550. opUserId = opUser.AdminId
  551. }
  552. }
  553. }
  554. var ret models.MarkReportResp
  555. if opUserId > 0 && opUserId != sysUser.AdminId {
  556. editor := opUser.Editor
  557. if editor == "" {
  558. editor = adminMap[opUserId]
  559. }
  560. ret.Status = 1
  561. if this.Lang == utils.EnLangVersion {
  562. ret.Msg = fmt.Sprintf("%s is currently editing the report", editor)
  563. } else {
  564. ret.Msg = fmt.Sprintf("当前%s正在编辑报告", editor)
  565. }
  566. ret.Editor = editor
  567. }
  568. if ret.Status == 0 {
  569. t.CanEdit = true
  570. } else {
  571. t.Editor = ret.Editor
  572. }
  573. //处理分类名
  574. if n, ok := classifyNameMap[v.ClassifyIdSecond]; ok {
  575. if n.RootId == 0 {
  576. t.FullClassifyName = strings.Join([]string{n.ParentName, n.ClassifyName}, "/")
  577. } else {
  578. t.FullClassifyName = strings.Join([]string{n.RootName, n.ParentName, n.ClassifyName}, "/")
  579. }
  580. t.ClassifyIdRoot = n.RootId
  581. t.ClassifyNameRoot = n.RootName
  582. }
  583. respList = append(respList, t)
  584. }
  585. page := paging.GetPaging(currentIndex, pageSize, total)
  586. resp := new(models.EnglishReportListResp)
  587. resp.Paging = page
  588. resp.List = respList
  589. br.Ret = 200
  590. br.Success = true
  591. br.Msg = "获取成功"
  592. br.Data = resp
  593. }
  594. // PublishReport
  595. // @Title 发布报告接口
  596. // @Description 发布报告
  597. // @Param request body models.PublishReq true "type json string"
  598. // @Success 200 Ret=200 发布成功
  599. // @router /publish [post]
  600. func (this *EnglishReportController) PublishReport() {
  601. br := new(models.BaseResponse).Init()
  602. defer func() {
  603. this.Data["json"] = br
  604. this.ServeJSON()
  605. }()
  606. var req models.PublishReq
  607. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  608. if err != nil {
  609. br.Msg = "参数解析异常!"
  610. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  611. return
  612. }
  613. reportIds := req.ReportIds
  614. if reportIds == "" {
  615. br.Msg = "参数错误"
  616. br.ErrMsg = "参数错误,报告id不可为空"
  617. return
  618. }
  619. reportArr := strings.Split(reportIds, ",")
  620. for _, v := range reportArr {
  621. vint, err := strconv.Atoi(v)
  622. if err != nil {
  623. br.Msg = "参数错误"
  624. br.ErrMsg = "参数错误,Err:" + err.Error()
  625. return
  626. }
  627. report, err := models.GetEnglishReportById(vint)
  628. if err != nil {
  629. br.Msg = "获取报告信息失败"
  630. br.ErrMsg = "获取报告信息失败,Err:" + err.Error()
  631. return
  632. }
  633. if report == nil {
  634. br.Msg = "报告不存在"
  635. return
  636. }
  637. // 图表刷新状态
  638. refreshResult := data.CheckBatchChartRefreshResult("report", vint, 0)
  639. if !refreshResult {
  640. br.Msg = "图表刷新未完成,请稍后操作"
  641. br.ErrMsg = "图表刷新未完成,请稍后操作"
  642. br.IsSendEmail = false
  643. return
  644. }
  645. var tmpErr error
  646. if report.Content == "" {
  647. br.Msg = "报告内容为空,不可发布"
  648. br.ErrMsg = "报告内容为空,不需要生成,report_id:" + strconv.Itoa(report.Id)
  649. return
  650. }
  651. var publishTime string
  652. if report.PublishTime != "" {
  653. // 发布时间固定为首次发布时间
  654. publishTime = report.PublishTime
  655. } else {
  656. publishTime = time.Now().Format(utils.FormatDateTime)
  657. }
  658. // 根据审批开关及审批流判断当前报告状态
  659. state, e := services.CheckReportCurrState(report_approve.FlowReportTypeEnglish, report.ClassifyIdFirst, report.ClassifyIdSecond, 0, models.ReportOperatePublish)
  660. if e != nil {
  661. br.Msg = "操作失败"
  662. br.ErrMsg = "校验报告当前状态失败, Err: " + e.Error()
  663. return
  664. }
  665. if state == models.ReportStatePublished {
  666. // 发布报告
  667. if tmpErr = models.PublishEnglishReportById(report.Id, publishTime); tmpErr != nil {
  668. br.Msg = "报告发布失败"
  669. br.ErrMsg = "报告发布失败, Err:" + tmpErr.Error() + ", report_id:" + strconv.Itoa(report.Id)
  670. return
  671. }
  672. go func() {
  673. _ = services.UpdateEnglishReportEs(report.Id, 2)
  674. }()
  675. // 生成报告pdf和长图
  676. if req.ReportUrl != "" {
  677. go services.Report2pdfAndJpeg(req.ReportUrl, report.Id, 2)
  678. }
  679. } else {
  680. // 从无审批切换为有审批, 状态重置
  681. if e = models.ResetEnglishReportById(report.Id, state); tmpErr != nil {
  682. br.Msg = "操作失败"
  683. br.ErrMsg = fmt.Sprintf("重置英文报告状态失败, Err: %s, ReportId: %d", e.Error(), report.Id)
  684. return
  685. }
  686. }
  687. }
  688. br.Ret = 200
  689. br.Success = true
  690. br.Msg = "发布成功"
  691. }
  692. // PrePublishReport
  693. // @Title 设置定时发布接口
  694. // @Description 设置定时发布接口
  695. // @Param request body models.PrePublishReq true "type json string"
  696. // @Success 200 Ret=200 发布成功
  697. // @router /pre_publish [post]
  698. func (this *EnglishReportController) PrePublishReport() {
  699. br := new(models.BaseResponse).Init()
  700. defer func() {
  701. this.Data["json"] = br
  702. this.ServeJSON()
  703. }()
  704. var req models.PrePublishReq
  705. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  706. if err != nil {
  707. br.Msg = "参数解析异常!"
  708. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  709. return
  710. }
  711. reportId := req.ReportId
  712. if reportId == 0 {
  713. br.Msg = "参数错误"
  714. br.ErrMsg = "参数错误,报告id不可为空"
  715. return
  716. }
  717. if req.PrePublishTime == "" {
  718. br.Msg = "发布时间不能为空"
  719. return
  720. }
  721. prePublishTime, err := time.ParseInLocation(utils.FormatDateTime, req.PrePublishTime, time.Local)
  722. if err != nil {
  723. br.Msg = "发布时间格式错误"
  724. br.ErrMsg = "发布时间格式错误,Err:" + err.Error()
  725. return
  726. }
  727. if prePublishTime.Before(time.Now()) {
  728. br.Msg = "发布时间不允许选择过去时间"
  729. return
  730. }
  731. if prePublishTime.Before(time.Now().Add(2 * time.Minute)) {
  732. br.Msg = "发布时间距离当前时间太近了"
  733. return
  734. }
  735. report, err := models.GetEnglishReportById(reportId)
  736. if err != nil {
  737. br.Msg = "获取报告信息失败"
  738. br.ErrMsg = "获取报告信息失败,Err:" + err.Error()
  739. return
  740. }
  741. if report == nil {
  742. br.Msg = "报告不存在"
  743. return
  744. }
  745. if report.Content == "" {
  746. br.Msg = "报告内容为空,不可发布"
  747. br.ErrMsg = "报告内容为空,不需要生成,report_id:" + strconv.Itoa(report.Id)
  748. return
  749. }
  750. if report.State == 2 {
  751. br.Msg = "报告已发布,不可设置定时发布"
  752. return
  753. }
  754. // 校验是否开启了审批流
  755. opening, e := services.CheckReportOpenApprove(report_approve.FlowReportTypeEnglish, report.ClassifyIdFirst, report.ClassifyIdSecond, 0)
  756. if e != nil {
  757. br.Msg = "操作失败"
  758. br.ErrMsg = "校验报告是否开启审批流失败, Err: " + e.Error()
  759. return
  760. }
  761. if opening {
  762. br.Msg = "报告已开启审批流, 不可设置定时发布"
  763. return
  764. }
  765. var tmpErr error
  766. if tmpErr = models.SetPrePublishEnglishReportById(report.Id, req.PrePublishTime); tmpErr != nil {
  767. br.Msg = "设置定时发布失败"
  768. br.ErrMsg = "设置定时发布失败, Err:" + tmpErr.Error() + ", report_id:" + strconv.Itoa(report.Id)
  769. return
  770. }
  771. // 生成报告pdf和长图
  772. if req.ReportUrl != "" {
  773. go services.Report2pdfAndJpeg(req.ReportUrl, report.Id, 2)
  774. }
  775. br.Ret = 200
  776. br.Success = true
  777. br.Msg = "定时发布成功"
  778. }
  779. // @Title 取消发布报告接口
  780. // @Description 取消发布报告
  781. // @Param request body models.PublishCancelReq true "type json string"
  782. // @Success 200 Ret=200 取消发布成功
  783. // @router /publish/cancel [post]
  784. func (this *EnglishReportController) PublishCancleReport() {
  785. br := new(models.BaseResponse).Init()
  786. defer func() {
  787. this.Data["json"] = br
  788. this.ServeJSON()
  789. }()
  790. var req models.PublishCancelReq
  791. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  792. if err != nil {
  793. br.Msg = "参数解析异常!"
  794. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  795. return
  796. }
  797. if req.ReportIds <= 0 {
  798. br.Msg = "参数错误"
  799. br.ErrMsg = "参数错误,报告id不可为空"
  800. return
  801. }
  802. reportInfo, err := models.GetEnglishReportById(req.ReportIds)
  803. if err != nil {
  804. br.Msg = "获取报告信息失败"
  805. br.ErrMsg = "获取报告信息失败,Err:" + err.Error()
  806. return
  807. }
  808. // 根据审批开关及审批流判断当前报告状态
  809. state, e := services.CheckReportCurrState(report_approve.FlowReportTypeEnglish, reportInfo.ClassifyIdFirst, reportInfo.ClassifyIdSecond, 0, models.ReportOperateCancelPublish)
  810. if e != nil {
  811. br.Msg = "操作失败"
  812. br.ErrMsg = "校验报告当前状态失败, Err: " + e.Error()
  813. return
  814. }
  815. err = models.PublishCancelEnglishReport(req.ReportIds, state)
  816. if err != nil {
  817. br.Msg = "取消发布失败"
  818. br.ErrMsg = "取消发布失败,Err:" + err.Error()
  819. return
  820. }
  821. // 更新es里的报告状态
  822. go func() {
  823. _ = services.UpdateEnglishReportEs(req.ReportIds, 1)
  824. }()
  825. br.Ret = 200
  826. br.Success = true
  827. br.Msg = "取消发布成功"
  828. }
  829. // @Title 删除报告接口
  830. // @Description 删除报告
  831. // @Param request body models.DeleteReq true "type json string"
  832. // @Success 200 Ret=200 删除成功
  833. // @router /delete [post]
  834. func (this *EnglishReportController) Delete() {
  835. br := new(models.BaseResponse).Init()
  836. defer func() {
  837. this.Data["json"] = br
  838. this.ServeJSON()
  839. }()
  840. var req models.DeleteReq
  841. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  842. if err != nil {
  843. br.Msg = "参数解析异常!"
  844. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  845. return
  846. }
  847. if req.ReportIds <= 0 {
  848. br.Msg = "参数错误"
  849. br.ErrMsg = "参数错误,报告id不可为空"
  850. return
  851. }
  852. reportInfo, err := models.GetEnglishReportById(req.ReportIds)
  853. if err != nil {
  854. if err.Error() == utils.ErrNoRow() {
  855. br.Msg = "报告不存在"
  856. return
  857. }
  858. br.Msg = "查询报告信息失败"
  859. br.ErrMsg = "查询报告信息失败, Err" + err.Error()
  860. return
  861. }
  862. // 更新es里的报告状态
  863. _ = services.UpdateEnglishReportEs(req.ReportIds, 1)
  864. if err = models.DeleteEnglishReportAndChapter(reportInfo); err != nil {
  865. br.Msg = "删除失败"
  866. br.ErrMsg = "删除报告失败, Err: " + err.Error()
  867. return
  868. }
  869. // 重置PPT关联报告
  870. go func() {
  871. _ = services.ResetPPTReport(req.ReportIds, true)
  872. }()
  873. br.Ret = 200
  874. br.Success = true
  875. br.Msg = "删除成功"
  876. }
  877. // @Title 保存草稿
  878. // @Description 保存草稿
  879. // @Param request body models.SaveReportContent true "type json string"
  880. // @Success 200 {object} models.ReportAuthorResp
  881. // @router /saveReportContent [post]
  882. func (this *EnglishReportController) SaveReportContent() {
  883. br := new(models.BaseResponse).Init()
  884. br.IsSendEmail = false
  885. defer func() {
  886. this.Data["json"] = br
  887. this.ServeJSON()
  888. }()
  889. var req models.SaveReportContent
  890. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  891. if err != nil {
  892. br.Msg = "参数解析异常!"
  893. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  894. return
  895. }
  896. sysUser := this.SysUser
  897. if sysUser == nil {
  898. br.Msg = "请登录"
  899. br.ErrMsg = "请登录,SysUser Is Empty"
  900. br.Ret = 408
  901. return
  902. }
  903. reportId := req.ReportId
  904. noChangeFlag := req.NoChange
  905. fmt.Println("reportId:", reportId)
  906. if reportId <= 0 {
  907. br.Msg = "请输入报告ID"
  908. return
  909. }
  910. markStatus, err := services.UpdateEnReportEditMark(int(req.ReportId), sysUser.AdminId, 1, sysUser.RealName, this.Lang)
  911. if err != nil {
  912. br.Msg = err.Error()
  913. return
  914. }
  915. if markStatus.Status == 1 {
  916. br.Msg = markStatus.Msg
  917. return
  918. }
  919. if noChangeFlag != 1 {
  920. req.Content = services.HandleReportContent(req.Content, "del", nil)
  921. content := req.Content
  922. if content == "" {
  923. content = this.GetString("Content")
  924. }
  925. if content != "" {
  926. e := utils.ContentXssCheck(req.Content)
  927. if e != nil {
  928. br.Msg = "存在非法标签"
  929. br.ErrMsg = "存在非法标签, Err: " + e.Error()
  930. return
  931. }
  932. contentClean, e := services.FilterReportContentBr(req.Content)
  933. if e != nil {
  934. br.Msg = "内容去除前后空格失败"
  935. br.ErrMsg = "内容去除前后空格失败, Err: " + e.Error()
  936. return
  937. }
  938. content = contentClean
  939. contentSub, err := services.GetReportContentSub(content)
  940. if err != nil {
  941. go alarm_msg.SendAlarmMsg("解析 ContentSub 失败,Err:"+err.Error(), 3)
  942. //utils.SendEmail(utils.APPNAME+"失败提醒", "解析 ContentSub 失败,Err:"+err.Error(), utils.EmailSendToUsers)
  943. }
  944. content = html.EscapeString(content)
  945. contentSub = html.EscapeString(contentSub)
  946. err = models.EditEnglishReportContent(reportId, content, contentSub)
  947. if err != nil {
  948. br.Msg = "保存失败"
  949. br.ErrMsg = "保存失败,Err:" + err.Error()
  950. return
  951. }
  952. go models.AddEnglishReportSaveLog(reportId, this.SysUser.AdminId, content, contentSub, this.SysUser.AdminName)
  953. }
  954. }
  955. resp := new(models.SaveReportContentResp)
  956. resp.ReportId = reportId
  957. br.Ret = 200
  958. br.Success = true
  959. br.Msg = "保存成功成功"
  960. br.Data = resp
  961. }
  962. // @Title 根据分类获取最近一次报告详情接口
  963. // @Description 根据分类获取最近一次报告详情
  964. // @Param request body models.ClassifyIdDetailReq true "type json string"
  965. // @Success 200 {object} models.Report
  966. // @router /classifyIdDetail [get]
  967. func (this *EnglishReportController) ClassifyIdDetail() {
  968. br := new(models.BaseResponse).Init()
  969. defer func() {
  970. this.Data["json"] = br
  971. this.ServeJSON()
  972. }()
  973. //classify_id_first=34&classify_id_second=36
  974. /*var req models.ClassifyIdDetailReq
  975. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  976. if err != nil {
  977. br.Msg = "参数解析异常!"
  978. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  979. return
  980. }*/
  981. classifyIdFirst, _ := this.GetInt("classify_id_first")
  982. if classifyIdFirst <= 0 {
  983. classifyIdFirst, _ = this.GetInt("ClassifyIdFirst")
  984. }
  985. classifyIdSecond, _ := this.GetInt("classify_id_second")
  986. if classifyIdSecond <= 0 {
  987. classifyIdSecond, _ = this.GetInt("ClassifyIdSecond")
  988. }
  989. item, err := models.GetEnglishReportDetailByClassifyId(classifyIdFirst, classifyIdSecond)
  990. if err != nil && err.Error() != utils.ErrNoRow() {
  991. br.Msg = "获取失败!"
  992. br.ErrMsg = "获取失败,Err:" + err.Error()
  993. return
  994. }
  995. if item != nil {
  996. item.Content = html.UnescapeString(item.Content)
  997. item.ContentSub = html.UnescapeString(item.ContentSub)
  998. businessConf, err := models.GetBusinessConfByKey(models.BusinessConfIsOpenChartExpired)
  999. if err != nil {
  1000. br.Msg = "获取失败"
  1001. br.ErrMsg = "获取配置失败,Err:" + err.Error()
  1002. return
  1003. }
  1004. if businessConf.ConfVal == `true` {
  1005. tokenMap := make(map[string]string)
  1006. item.Content = services.HandleReportContent(item.Content, "add", tokenMap)
  1007. }
  1008. classifyNameMap := make(map[int]*models.EnglishClassifyFullName)
  1009. if item.ClassifyIdSecond > 0 {
  1010. nameList, tErr := models.GetEnglishClassifyFullNameByIds([]int{item.ClassifyIdSecond})
  1011. if tErr != nil {
  1012. br.Msg = "获取分类名称失败"
  1013. br.ErrMsg = "获取分类名称失败, ERR:" + tErr.Error()
  1014. return
  1015. }
  1016. for _, v := range nameList {
  1017. classifyNameMap[v.Id] = v
  1018. }
  1019. //处理分类名
  1020. if n, ok := classifyNameMap[item.ClassifyIdSecond]; ok {
  1021. item.ClassifyNameRoot = n.RootName
  1022. item.ClassifyIdRoot = n.RootId
  1023. }
  1024. }
  1025. }
  1026. br.Ret = 200
  1027. br.Success = true
  1028. br.Msg = "获取成功"
  1029. br.Data = item
  1030. }
  1031. // Author
  1032. // @Title 获取报告作者接口
  1033. // @Description 获取报告作者
  1034. // @Param AuthorType query int true "来源类型,1:中文,2:英文"
  1035. // @Param Keyword query string true "搜索关键词"
  1036. // @Param CurrentIndex query int true "当前页页码,从1开始"
  1037. // @Param StartDate query string true "开始时间"
  1038. // @Success 200 {object} models.ReportAuthorResp
  1039. // @router /author [get]
  1040. func (this *EnglishReportController) Author() {
  1041. br := new(models.BaseResponse).Init()
  1042. defer func() {
  1043. this.Data["json"] = br
  1044. this.ServeJSON()
  1045. }()
  1046. keyword := this.GetString("Keyword")
  1047. var condition string
  1048. var pars []interface{}
  1049. condition += ` AND author_type = 2 AND enable = 1`
  1050. if keyword != `` {
  1051. condition += ` AND report_author like ? `
  1052. pars = append(pars, utils.GetLikeKeyword(keyword))
  1053. }
  1054. _, items, err := models.GetReportAuthorList(condition, pars, 0, 10000)
  1055. if err != nil {
  1056. br.Msg = "获取失败!"
  1057. br.ErrMsg = "获取失败,Err:" + err.Error()
  1058. return
  1059. }
  1060. resp := models.ReportAuthorResp{
  1061. List: items,
  1062. }
  1063. br.Ret = 200
  1064. br.Success = true
  1065. br.Msg = "获取成功"
  1066. br.Data = resp
  1067. }
  1068. // MarkEditStatus
  1069. // @Title 标记报告编辑状态
  1070. // @Description 标记报告编辑状态接口
  1071. // @Param request body request.MarkEditEnReport true "type json string"
  1072. // @Success 200 标记成功 ;202 标记成功
  1073. // @router /mark [post]
  1074. func (this *EnglishReportController) MarkEditStatus() {
  1075. br := new(models.BaseResponse).Init()
  1076. defer func() {
  1077. this.Data["json"] = br
  1078. this.ServeJSON()
  1079. }()
  1080. sysUser := this.SysUser
  1081. if sysUser == nil {
  1082. br.Msg = "请登录"
  1083. br.ErrMsg = "请登录,SysUser Is Empty"
  1084. br.Ret = 408
  1085. return
  1086. }
  1087. var req models.MarkEditEnReport
  1088. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1089. if err != nil {
  1090. br.Msg = "参数解析异常!"
  1091. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1092. return
  1093. }
  1094. if req.ReportId <= 0 {
  1095. br.Msg = "缺少报告Id"
  1096. return
  1097. }
  1098. if req.Status <= 0 {
  1099. br.Msg = "标记状态异常"
  1100. return
  1101. }
  1102. //更新标记key
  1103. data, err := services.UpdateEnReportEditMark(req.ReportId, sysUser.AdminId, req.Status, sysUser.RealName, this.Lang)
  1104. if err != nil {
  1105. br.Msg = err.Error()
  1106. return
  1107. }
  1108. msg := "标记成功"
  1109. br.Ret = 200
  1110. br.Success = true
  1111. br.Msg = msg
  1112. br.Data = data
  1113. }
  1114. // @Title 编辑来自策略报告的报告
  1115. // @Description 编辑来自策略报告的报告
  1116. // @Param request body models.EditEnglishReportFromPolicyReq true "type json string"
  1117. // @Success 200 {object} models.EditEnglishReportResp
  1118. // @router /edit_policy [post]
  1119. func (this *EnglishReportController) EditPolicy() {
  1120. br := new(models.BaseResponse).Init()
  1121. defer func() {
  1122. this.Data["json"] = br
  1123. this.ServeJSON()
  1124. }()
  1125. sysUser := this.SysUser
  1126. if sysUser == nil {
  1127. br.Msg = "请登录"
  1128. br.ErrMsg = "请登录,SysUser Is Empty"
  1129. br.Ret = 408
  1130. return
  1131. }
  1132. var req models.EditEnglishReportFromPolicyReq
  1133. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1134. if err != nil {
  1135. br.Msg = "参数解析异常!"
  1136. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1137. return
  1138. }
  1139. if req.ReportId <= 0 {
  1140. br.Msg = "请选择报告ID"
  1141. return
  1142. }
  1143. if req.Title == "" {
  1144. br.Msg = "请输入标题"
  1145. return
  1146. }
  1147. if req.Abstract == "" {
  1148. br.Msg = "请输入摘要"
  1149. return
  1150. }
  1151. if req.Frequency == "" {
  1152. br.Msg = "请输入频度"
  1153. return
  1154. }
  1155. if req.Author == "" {
  1156. br.Msg = "请输入作者"
  1157. return
  1158. }
  1159. if req.CreateTime == "" {
  1160. br.Msg = "请输入创建时间"
  1161. return
  1162. }
  1163. //查询报告是否存在
  1164. reportInfo, err := models.GetEnglishReportItemById(int(req.ReportId))
  1165. if err != nil {
  1166. if err.Error() == utils.ErrNoRow() {
  1167. br.Msg = "报告不存在"
  1168. return
  1169. }
  1170. br.Msg = "查询报告信息失败"
  1171. br.ErrMsg = "查询报告信息失败, Err" + err.Error()
  1172. return
  1173. }
  1174. if reportInfo.State == 2 {
  1175. br.Msg = "报告已发布不允许编辑"
  1176. return
  1177. }
  1178. markStatus, err := services.UpdateEnReportEditMark(int(req.ReportId), sysUser.AdminId, 1, sysUser.RealName, this.Lang)
  1179. if err != nil {
  1180. br.Msg = err.Error()
  1181. return
  1182. }
  1183. if markStatus.Status == 1 {
  1184. br.Msg = markStatus.Msg
  1185. return
  1186. }
  1187. item := reportInfo
  1188. item.Title = req.Title
  1189. item.Abstract = req.Abstract
  1190. item.Author = req.Author
  1191. item.Frequency = req.Frequency
  1192. item.CreateTime = req.CreateTime
  1193. item.ModifyTime = time.Now()
  1194. err = item.Update([]string{"Title", "Abstract", "Author", "Frequency", "CreateTime", "ModifyTime"})
  1195. if err != nil {
  1196. br.Msg = "保存失败"
  1197. br.ErrMsg = "保存失败,Err:" + err.Error()
  1198. return
  1199. }
  1200. reportCode := reportInfo.ReportCode
  1201. resp := new(models.EditEnglishReportResp)
  1202. resp.ReportId = req.ReportId
  1203. resp.ReportCode = reportCode
  1204. br.Ret = 200
  1205. br.Success = true
  1206. br.Msg = "保存成功"
  1207. br.Data = resp
  1208. }
  1209. // SubmitApprove
  1210. // @Title 提交审批
  1211. // @Description 提交审批接口
  1212. // @Param request body models.ReportSubmitApproveReq true "type json string"
  1213. // @Success 200 Ret=200 操作成功
  1214. // @router /approve/submit [post]
  1215. func (this *EnglishReportController) SubmitApprove() {
  1216. br := new(models.BaseResponse).Init()
  1217. defer func() {
  1218. if br.ErrMsg == "" {
  1219. br.IsSendEmail = false
  1220. }
  1221. this.Data["json"] = br
  1222. this.ServeJSON()
  1223. }()
  1224. sysUser := this.SysUser
  1225. if sysUser == nil {
  1226. br.Msg = "请登录"
  1227. br.ErrMsg = "请登录,SysUser Is Empty"
  1228. return
  1229. }
  1230. var req models.ReportSubmitApproveReq
  1231. if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
  1232. br.Msg = "参数有误"
  1233. br.ErrMsg = "参数解析失败, Err: " + e.Error()
  1234. return
  1235. }
  1236. reportId := req.ReportId
  1237. if reportId <= 0 {
  1238. br.Msg = "参数有误"
  1239. br.ErrMsg = fmt.Sprintf("参数有误, ReportId: %d", req.ReportId)
  1240. return
  1241. }
  1242. reportOb := new(models.EnglishReport)
  1243. reportItem, e := reportOb.GetItemById(reportId)
  1244. if e != nil {
  1245. if e.Error() == utils.ErrNoRow() {
  1246. br.Msg = "报告已被删除, 请刷新页面"
  1247. return
  1248. }
  1249. br.Msg = "操作失败"
  1250. br.ErrMsg = "获取报告失败, Err: " + e.Error()
  1251. return
  1252. }
  1253. reportClassify, e := models.GetEnglishReportClassifyById(reportItem.ClassifyIdFirst)
  1254. if e != nil {
  1255. if e.Error() == utils.ErrNoRow() {
  1256. br.Msg = "报告所在分类异常"
  1257. return
  1258. }
  1259. br.Msg = "操作失败"
  1260. br.ErrMsg = "获取分类失败, Err: " + e.Error()
  1261. return
  1262. }
  1263. // 校验当前审批配置, 返回下一个状态
  1264. state, e := services.CheckReportCurrState(report_approve.FlowReportTypeEnglish, reportClassify.RootId, reportItem.ClassifyIdFirst, reportItem.ClassifyIdSecond, models.ReportOperateSubmitApprove)
  1265. if e != nil {
  1266. br.Msg = "操作失败"
  1267. br.ErrMsg = "校验报告状态失败, Err: " + e.Error()
  1268. return
  1269. }
  1270. // 下一个状态不为待审批时, 仅更新状态
  1271. if state != models.ReportStateWaitApprove {
  1272. reportItem.State = state
  1273. e = reportItem.UpdateReport([]string{"State"})
  1274. if e != nil {
  1275. br.Msg = "操作失败"
  1276. br.ErrMsg = "更新报告状态失败, Err: " + e.Error()
  1277. return
  1278. }
  1279. br.Ret = 200
  1280. br.Success = true
  1281. br.Msg = "操作成功"
  1282. return
  1283. }
  1284. // 提交审批
  1285. approveId, e := services.SubmitReportApprove(report_approve.FlowReportTypeEnglish, reportItem.Id, reportItem.Title, reportClassify.RootId, reportItem.ClassifyIdFirst, reportItem.ClassifyIdSecond, sysUser.AdminId, sysUser.RealName)
  1286. if e != nil {
  1287. br.Msg = "操作失败"
  1288. br.ErrMsg = "提交审批失败, Err: " + e.Error()
  1289. return
  1290. }
  1291. reportItem.ApproveId = approveId
  1292. reportItem.State = models.ReportStateWaitApprove
  1293. reportItem.ModifyTime = time.Now().Local()
  1294. e = reportItem.UpdateReport([]string{"ApproveId", "State", "ModifyTime"})
  1295. if e != nil {
  1296. br.Msg = "操作失败"
  1297. br.ErrMsg = "更新报告状态失败, Err: " + e.Error()
  1298. return
  1299. }
  1300. br.Ret = 200
  1301. br.Success = true
  1302. br.Msg = "操作成功"
  1303. }
  1304. // CancelApprove
  1305. // @Title 撤销审批
  1306. // @Description 撤销审批
  1307. // @Param request body models.ReportCancelApproveReq true "type json string"
  1308. // @Success 200 Ret=200 操作成功
  1309. // @router /approve/cancel [post]
  1310. func (this *EnglishReportController) CancelApprove() {
  1311. br := new(models.BaseResponse).Init()
  1312. defer func() {
  1313. if br.ErrMsg == "" {
  1314. br.IsSendEmail = false
  1315. }
  1316. this.Data["json"] = br
  1317. this.ServeJSON()
  1318. }()
  1319. sysUser := this.SysUser
  1320. if sysUser == nil {
  1321. br.Msg = "请登录"
  1322. br.ErrMsg = "请登录,SysUser Is Empty"
  1323. return
  1324. }
  1325. var req models.ReportCancelApproveReq
  1326. if e := json.Unmarshal(this.Ctx.Input.RequestBody, &req); e != nil {
  1327. br.Msg = "参数有误"
  1328. br.ErrMsg = "参数解析失败, Err: " + e.Error()
  1329. return
  1330. }
  1331. reportId := req.ReportId
  1332. if reportId <= 0 {
  1333. br.Msg = "参数有误"
  1334. br.ErrMsg = fmt.Sprintf("参数有误, ReportId: %d", req.ReportId)
  1335. return
  1336. }
  1337. reportOb := new(models.EnglishReport)
  1338. reportItem, e := reportOb.GetItemById(reportId)
  1339. if e != nil {
  1340. if e.Error() == utils.ErrNoRow() {
  1341. br.Msg = "报告已被删除, 请刷新页面"
  1342. return
  1343. }
  1344. br.Msg = "操作失败"
  1345. br.ErrMsg = "获取报告失败, Err: " + e.Error()
  1346. return
  1347. }
  1348. reportClassify, e := models.GetEnglishReportClassifyById(reportItem.ClassifyIdFirst)
  1349. if e != nil {
  1350. if e.Error() == utils.ErrNoRow() {
  1351. br.Msg = "报告所在分类异常"
  1352. return
  1353. }
  1354. br.Msg = "操作失败"
  1355. br.ErrMsg = "获取分类失败, Err: " + e.Error()
  1356. return
  1357. }
  1358. // 校验当前审批配置, 返回下一个状态
  1359. state, e := services.CheckReportCurrState(report_approve.FlowReportTypeEnglish, reportClassify.RootId, reportItem.ClassifyIdFirst, reportItem.ClassifyIdSecond, models.ReportOperateCancelApprove)
  1360. if e != nil {
  1361. br.Msg = "操作失败"
  1362. br.ErrMsg = "校验报告状态失败, Err: " + e.Error()
  1363. return
  1364. }
  1365. // 下一个状态不为待提交时, 仅更新状态
  1366. if state != models.ReportStateWaitSubmit {
  1367. reportItem.State = state
  1368. e = reportItem.UpdateReport([]string{"State"})
  1369. if e != nil {
  1370. br.Msg = "操作失败"
  1371. br.ErrMsg = "更新报告状态失败, Err: " + e.Error()
  1372. return
  1373. }
  1374. br.Ret = 200
  1375. br.Success = true
  1376. br.Msg = "操作成功"
  1377. return
  1378. }
  1379. //if reportItem.ApproveId <= 0 {
  1380. // br.Msg = "报告审批不存在"
  1381. // br.ErrMsg = fmt.Sprintf("报告审批不存在, ApproveId: %d", reportItem.ApproveId)
  1382. // return
  1383. //}
  1384. // 撤销审批
  1385. e = services.CancelReportApprove(report_approve.FlowReportTypeEnglish, reportItem.Id, reportItem.ApproveId, sysUser.AdminId, sysUser.RealName)
  1386. if e != nil {
  1387. br.Msg = "操作失败"
  1388. br.ErrMsg = "撤销审批失败, Err: " + e.Error()
  1389. return
  1390. }
  1391. //reportItem.ApproveId = 0
  1392. //reportItem.State = models.ReportStateWaitSubmit
  1393. //reportItem.ModifyTime = time.Now().Local()
  1394. //e = reportItem.UpdateReport([]string{"ApproveId", "State", "ModifyTime"})
  1395. //if e != nil {
  1396. // br.Msg = "操作失败"
  1397. // br.ErrMsg = "更新报告状态失败, Err: " + e.Error()
  1398. // return
  1399. //}
  1400. br.Ret = 200
  1401. br.Success = true
  1402. br.Msg = "操作成功"
  1403. }