activity_video.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723
  1. package cygx
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "github.com/rdlucklib/rdluck_tools/paging"
  6. "github.com/tealeg/xlsx"
  7. "hongze/hz_crm_api/controllers"
  8. "hongze/hz_crm_api/models"
  9. "hongze/hz_crm_api/models/cygx"
  10. "hongze/hz_crm_api/utils"
  11. "os"
  12. "path/filepath"
  13. "strconv"
  14. "strings"
  15. "time"
  16. )
  17. // 活动
  18. type ActivityVideoCoAntroller struct {
  19. controllers.BaseAuthController
  20. }
  21. // @Title 活动列表
  22. // @Description 获取活动列表接口
  23. // @Param PageSize query int true "每页数据条数"
  24. // @Param CurrentIndex query int true "当前页页码,从1开始"
  25. // @Param ChartPermissionId query string false "行业id"
  26. // @Param ActivityTypeId query string false "活动类型id"
  27. // @Param StartDate query string false "开始时间 ,列如2021-03-06 "
  28. // @Param EndDate query string false "结束时间,列如2021-03-06 "
  29. // @Param KeyWord query string false "搜索关键词"
  30. // @Param SortType query string false "排序顺序:asc、desc"
  31. // @Success 200 {object} cygx.CygxActivityVideoListRep
  32. // @router /activityVideo/list [get]
  33. func (this *ActivityVideoCoAntroller) ActivityVideoList() {
  34. br := new(models.BaseResponse).Init()
  35. defer func() {
  36. this.Data["json"] = br
  37. this.ServeJSON()
  38. }()
  39. sysUser := this.SysUser
  40. if sysUser == nil {
  41. br.Msg = "请登录"
  42. br.ErrMsg = "请登录,SysUser Is Empty"
  43. return
  44. }
  45. pageSize, _ := this.GetInt("PageSize")
  46. currentIndex, _ := this.GetInt("CurrentIndex")
  47. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  48. ActivityTypeId, _ := this.GetInt("ActivityTypeId")
  49. startDate := this.GetString("StartDate")
  50. endDate := this.GetString("EndDate")
  51. keyWord := this.GetString("KeyWord")
  52. sortType := this.GetString("SortType")
  53. var startSize int
  54. if pageSize <= 0 {
  55. pageSize = utils.PageSize20
  56. }
  57. if currentIndex <= 0 {
  58. currentIndex = 1
  59. }
  60. startSize = utils.StartIndex(currentIndex, pageSize)
  61. var condition string
  62. var pars []interface{}
  63. if keyWord != "" {
  64. condition += ` AND (v.video_name LIKE '%` + keyWord + `%' ) `
  65. }
  66. //行业名称
  67. if chartPermissionId > 0 {
  68. condition += ` AND art.chart_permission_id = ? `
  69. pars = append(pars, chartPermissionId)
  70. }
  71. if startDate != "" {
  72. condition += ` AND art.activity_time >= ` + "'" + startDate + " 00:00:00'"
  73. }
  74. if endDate != "" {
  75. condition += ` AND art.activity_time <= ` + "'" + endDate + " 23:59:59'"
  76. }
  77. if ActivityTypeId > 0 {
  78. condition += ` AND art.activity_type_id = ? `
  79. pars = append(pars, ActivityTypeId)
  80. }
  81. total, err := cygx.GetActivityVideoCount(condition, pars)
  82. if err != nil {
  83. br.Msg = "获取失败"
  84. br.ErrMsg = "获取失败,Err:" + err.Error()
  85. return
  86. }
  87. if sortType == "asc" || sortType == "desc" {
  88. condition += ` ORDER BY v.video_counts ` + sortType
  89. } else {
  90. condition += ` ORDER BY art.activity_time DESC `
  91. }
  92. list, errList := cygx.GetActivityVideoListAll(condition, pars, startSize, pageSize)
  93. if errList != nil {
  94. br.Msg = "获取失败"
  95. br.ErrMsg = "获取失败,Err:" + errList.Error()
  96. return
  97. }
  98. var activityIds string
  99. for k, v := range list {
  100. if v.ChartPermissionNames != "" {
  101. list[k].ChartPermissionName = v.ChartPermissionNames
  102. }
  103. activityIds += strconv.Itoa(v.ActivityId) + ","
  104. }
  105. activityIds = strings.TrimRight(activityIds, ",")
  106. mapIndustrial := make(map[int]string)
  107. mapSubject := make(map[string]string)
  108. if activityIds != "" {
  109. industrialList, err := cygx.GetIndustrialActivityGroupListByactivityIds(activityIds)
  110. if err != nil {
  111. br.Msg = "获取失败"
  112. br.ErrMsg = "获取失败,GetIndustrialActivityGroupListByactivityIds Err:" + err.Error()
  113. return
  114. }
  115. subjectList, err := cygx.GetSubjectActivityGroupListByactivityIds(activityIds)
  116. if err != nil {
  117. br.Msg = "获取失败"
  118. br.ErrMsg = "获取失败,GetSubjectActivityGroupListByactivityIds Err:" + err.Error()
  119. return
  120. }
  121. //合并活动对应的多个标的
  122. for _, v := range subjectList {
  123. mapSubject[fmt.Sprint(v.ActivityId, "_", v.IndustrialManagementId)] += v.SubjectName + "/"
  124. }
  125. //活动对应的产业
  126. for _, v := range industrialList {
  127. var labelSubject string
  128. labelSubject = mapSubject[fmt.Sprint(v.ActivityId, "_", v.IndustrialManagementId)]
  129. if labelSubject != "" {
  130. mapIndustrial[v.ActivityId] += v.IndustryName + "--" + strings.TrimRight(labelSubject, "/") + ","
  131. } else {
  132. mapIndustrial[v.ActivityId] += v.IndustryName + ","
  133. }
  134. }
  135. }
  136. for k, v := range list {
  137. if mapIndustrial[v.ActivityId] != "" && v.TemporaryLabel == "" {
  138. list[k].Label = strings.TrimRight(mapIndustrial[v.ActivityId], ",")
  139. }
  140. }
  141. if len(list) == 0 {
  142. list = make([]*cygx.CygxActivityVideoListResp, 0)
  143. }
  144. page := paging.GetPaging(currentIndex, pageSize, total)
  145. resp := new(cygx.CygxActivityVideoListRep)
  146. resp.List = list
  147. resp.Paging = page
  148. br.Ret = 200
  149. br.Success = true
  150. br.Msg = "获取成功"
  151. br.Data = resp
  152. }
  153. // @Title 音频播放详情
  154. // @Description 音频播放详情接口
  155. // @Param VideoId query int true "视频Id"
  156. // @Success Ret=200 发布成功
  157. // @router /activityVideo/deatil [get]
  158. func (this *ActivityVideoCoAntroller) VideoDeatil() {
  159. br := new(models.BaseResponse).Init()
  160. defer func() {
  161. this.Data["json"] = br
  162. this.ServeJSON()
  163. }()
  164. sysUser := this.SysUser
  165. if sysUser == nil {
  166. br.Msg = "请登录"
  167. br.ErrMsg = "请登录,SysUser Is Empty"
  168. br.Ret = 408
  169. return
  170. }
  171. videoId, _ := this.GetInt("VideoId")
  172. if videoId <= 0 {
  173. br.Msg = "参数错误"
  174. return
  175. }
  176. var condition string
  177. var pars []interface{}
  178. condition += `AND v.video_id= ? `
  179. pars = append(pars, videoId)
  180. list, err := cygx.GetActivityVideoHistoryById(condition, pars)
  181. if err != nil {
  182. br.Msg = "获取失败"
  183. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  184. return
  185. }
  186. for _, v := range list {
  187. v.RegisterPlatform = utils.CYGX_REGISTER_PLATFORM_MAP[v.RegisterPlatform]
  188. }
  189. br.Ret = 200
  190. br.Success = true
  191. br.Msg = "获取成功"
  192. br.Data = list
  193. }
  194. // @Title 留言详情excel表格下载
  195. // @Description 留言详情excel表格下载接口
  196. // @Param VideoId query int true "视频ID"
  197. // @Success 200 导出成功
  198. // @router /activityVideo/commnetListExport [get]
  199. func (this *ActivityVideoCoAntroller) CommentListExport() {
  200. br := new(models.BaseResponse).Init()
  201. defer func() {
  202. this.Data["json"] = br
  203. this.ServeJSON()
  204. }()
  205. sysUser := this.SysUser
  206. if sysUser == nil {
  207. br.Msg = "请登录"
  208. br.ErrMsg = "请登录,SysUser Is Empty"
  209. return
  210. }
  211. videoId, _ := this.GetInt("VideoId")
  212. videoInfo, _ := cygx.GetCygxActivityVideoReqDetailByVideoId(videoId)
  213. if videoInfo == nil {
  214. br.Msg = "操作失败"
  215. br.ErrMsg = "报告ID错误"
  216. return
  217. }
  218. var condition string
  219. var pars []interface{}
  220. condition += ` AND activity_id = ? AND video_id = ? `
  221. pars = append(pars, videoInfo.ActivityId, videoInfo.VideoId)
  222. list, err := cygx.GetArticleCommentListSearch(condition, pars)
  223. if err != nil {
  224. br.Msg = "获取失败"
  225. br.ErrMsg = "获取失败,Err:" + err.Error()
  226. return
  227. }
  228. //创建excel
  229. dir, err := os.Executable()
  230. exPath := filepath.Dir(dir)
  231. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  232. xlsxFile := xlsx.NewFile()
  233. if err != nil {
  234. br.Msg = "生成文件失败"
  235. br.ErrMsg = "生成文件失败"
  236. return
  237. }
  238. style := xlsx.NewStyle()
  239. alignment := xlsx.Alignment{
  240. Horizontal: "center",
  241. Vertical: "center",
  242. WrapText: true,
  243. }
  244. style.Alignment = alignment
  245. style.ApplyAlignment = true
  246. sheet, err := xlsxFile.AddSheet("名单")
  247. if err != nil {
  248. br.Msg = "新增Sheet失败"
  249. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  250. return
  251. }
  252. //标头
  253. rowTitle := sheet.AddRow()
  254. cellA := rowTitle.AddCell()
  255. cellA.Value = "姓名"
  256. cellB := rowTitle.AddCell()
  257. cellB.Value = "公司名称"
  258. cellC := rowTitle.AddCell()
  259. cellC.Value = "留言"
  260. cellD := rowTitle.AddCell()
  261. cellD.Value = "提交时间"
  262. for _, item := range list {
  263. row := sheet.AddRow()
  264. cellA := row.AddCell()
  265. cellA.Value = item.RealName
  266. cellB := row.AddCell()
  267. cellB.Value = item.CompanyName
  268. cellC := row.AddCell()
  269. cellC.Value = item.Content
  270. cellD := row.AddCell()
  271. cellD.Value = item.CreateTime
  272. }
  273. err = xlsxFile.Save(downLoadnFilePath)
  274. if err != nil {
  275. br.Msg = "保存文件失败"
  276. br.ErrMsg = "保存文件失败"
  277. return
  278. }
  279. randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  280. downloadFileName := "留言列表" + randStr + ".xlsx"
  281. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  282. defer func() {
  283. os.Remove(downLoadnFilePath)
  284. }()
  285. br.Success = true
  286. br.Ret = 200
  287. br.Msg = "导出成功"
  288. }
  289. // @Title 留言列表详情
  290. // @Description 获取留言列表详情接口
  291. // @Param VideoId query int true "视频ID"
  292. // @Success 200 {object} cygx.ArticleCommentListResp
  293. // @router /activityVideo/commentList [get]
  294. func (this *ActivityVideoCoAntroller) CommentList() {
  295. br := new(models.BaseResponse).Init()
  296. defer func() {
  297. this.Data["json"] = br
  298. this.ServeJSON()
  299. }()
  300. sysUser := this.SysUser
  301. if sysUser == nil {
  302. br.Msg = "请登录"
  303. br.ErrMsg = "请登录,SysUser Is Empty"
  304. return
  305. }
  306. videoId, _ := this.GetInt("VideoId")
  307. videoInfo, _ := cygx.GetCygxActivityVideoReqDetailByVideoId(videoId)
  308. if videoInfo == nil {
  309. br.Msg = "操作失败"
  310. br.ErrMsg = "报告ID错误"
  311. return
  312. }
  313. var condition string
  314. var pars []interface{}
  315. condition += ` AND activity_id = ? AND video_id = ? `
  316. pars = append(pars, videoInfo.ActivityId, videoInfo.VideoId)
  317. list, err := cygx.GetArticleCommentListSearch(condition, pars)
  318. if err != nil {
  319. br.Msg = "获取失败"
  320. br.ErrMsg = "获取失败,Err:" + err.Error()
  321. return
  322. }
  323. //list, err := cygx.GetArticleCommentListByActivityVideoId(videoId)
  324. //if err != nil {
  325. // br.Msg = "获取失败"
  326. // br.ErrMsg = "获取失败,Err:" + err.Error()
  327. // return
  328. //}
  329. resp := new(cygx.ArticleCommentListResp)
  330. resp.List = list
  331. br.Ret = 200
  332. br.Success = true
  333. br.Msg = "获取成功"
  334. br.Data = resp
  335. }
  336. // @Title 获取音视频上传之后的封面图
  337. // @Description 获取音视频上传之后的封面图
  338. // @Param ActivityId query int true "活动ID"
  339. // @Param FileType query int true "音视频文件类型 。1:音频。2:视频"
  340. // @Param ChartPermissionId query int true "行业ID"
  341. // @Success 200 {object} cygx.ChartPermissionRepMoreList
  342. // @router /activityVideo/video_and_voice/img [get]
  343. func (this *ActivityVideoCoAntroller) VideoAndVoice() {
  344. br := new(models.BaseResponse).Init()
  345. defer func() {
  346. this.Data["json"] = br
  347. this.ServeJSON()
  348. }()
  349. AdminUser := this.SysUser
  350. if AdminUser == nil {
  351. br.Msg = "请登录"
  352. br.ErrMsg = "请登录,用户信息为空"
  353. br.Ret = 408
  354. return
  355. }
  356. conf, err := cygx.GetCygxConfigDetailByCode("activity_video_default_img")
  357. if err != nil {
  358. br.Msg = "获取微路演默认图配置失败" + err.Error()
  359. return
  360. }
  361. list := new(cygx.ActivityVideoDefaultImgList)
  362. if err = json.Unmarshal([]byte(conf.ConfigValue), &list); err != nil {
  363. br.Msg = "微路演默认图配置配置值解析失败" + err.Error()
  364. return
  365. }
  366. resp := new(cygx.ActivityVideoDefaultImgListResp)
  367. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  368. activityId, _ := this.GetInt("ActivityId")
  369. fileType, _ := this.GetInt("FileType")
  370. if chartPermissionId > 0 {
  371. for _, v := range list.Audio {
  372. if v.ChartPermissionId == chartPermissionId {
  373. resp.List = v.List
  374. }
  375. }
  376. } else {
  377. if activityId < 1 {
  378. br.Msg = "请输入活动ID"
  379. return
  380. }
  381. activityInfo, err := cygx.GetAddActivityInfoById(activityId)
  382. if err != nil {
  383. br.Msg = "活动不存在"
  384. br.ErrMsg = "活动ID错误,Err:" + err.Error() + "activityId:" + strconv.Itoa(activityId)
  385. return
  386. }
  387. //key := utils.MicroRoadshowDefaultImgKey
  388. if fileType == 1 {
  389. for _, v := range list.Audio {
  390. if v.ChartPermissionId == activityInfo.ChartPermissionId {
  391. resp.List = v.List
  392. }
  393. }
  394. } else {
  395. for _, v := range list.Video {
  396. if v.ChartPermissionId == activityInfo.ChartPermissionId {
  397. resp.List = v.List
  398. }
  399. }
  400. }
  401. }
  402. br.Ret = 200
  403. br.Success = true
  404. br.Msg = "获取成功"
  405. br.Data = resp
  406. }
  407. // @Title 路演反馈、调研反馈列表
  408. // @Description 路演反馈、调研反馈列表接口
  409. // @Param PageSize query int true "每页数据条数"
  410. // @Param CurrentIndex query int true "当前页页码,从1开始"
  411. // @Param ChartPermissionId query string false "行业id"
  412. // @Param ActivityTypeId query string false "活动类型id"
  413. // @Param StartDate query string false "开始时间 ,列如2021-03-06 "
  414. // @Param EndDate query string false "结束时间,列如2021-03-06 "
  415. // @Param KeyWord query string false "搜索关键词"
  416. // @Param SortType query string false "排序顺序:asc、desc"
  417. // @Param SearchType query int false "类型 1 路演回放 ,2:调研反馈"
  418. // @Param IsResearch query bool true "是否为研选"
  419. // @Success 200 {object} cygx.CygxActivityVideoListRep
  420. // @router /activity_voice_and_video/list [get]
  421. func (this *ActivityVideoCoAntroller) ActivityVoiceAndVideoList() {
  422. br := new(models.BaseResponse).Init()
  423. defer func() {
  424. this.Data["json"] = br
  425. this.ServeJSON()
  426. }()
  427. sysUser := this.SysUser
  428. if sysUser == nil {
  429. br.Msg = "请登录"
  430. br.ErrMsg = "请登录,SysUser Is Empty"
  431. return
  432. }
  433. pageSize, _ := this.GetInt("PageSize")
  434. currentIndex, _ := this.GetInt("CurrentIndex")
  435. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  436. ActivityTypeId, _ := this.GetInt("ActivityTypeId")
  437. searchType, _ := this.GetInt("SearchType", 1)
  438. startDate := this.GetString("StartDate")
  439. endDate := this.GetString("EndDate")
  440. keyWord := this.GetString("KeyWord")
  441. sortType := this.GetString("SortType")
  442. isResearch, _ := this.GetBool("IsResearch")
  443. var startSize int
  444. if pageSize <= 0 {
  445. pageSize = utils.PageSize20
  446. }
  447. if currentIndex <= 0 {
  448. currentIndex = 1
  449. }
  450. startSize = utils.StartIndex(currentIndex, pageSize)
  451. var condition string
  452. var conditionVideo string
  453. var conditionVoice string
  454. var pars []interface{}
  455. if keyWord != "" {
  456. conditionVideo += ` AND (v.video_name LIKE '%` + keyWord + `%' ) `
  457. conditionVoice += ` AND (v.voice_name LIKE '%` + keyWord + `%' ) `
  458. }
  459. if isResearch {
  460. chartPermissionId = utils.CHART_PERMISSION_ID_YANXUAN //如果是研选添加一个研选行业的筛选
  461. } else {
  462. condition += ` AND art.chart_permission_id != ? `
  463. pars = append(pars, utils.CHART_PERMISSION_ID_YANXUAN)
  464. }
  465. //行业名称
  466. if chartPermissionId > 0 {
  467. condition += ` AND art.chart_permission_id = ? `
  468. pars = append(pars, chartPermissionId)
  469. }
  470. if startDate != "" {
  471. condition += ` AND art.activity_time >= ` + "'" + startDate + " 00:00:00'"
  472. }
  473. if endDate != "" {
  474. condition += ` AND art.activity_time <= ` + "'" + endDate + " 23:59:59'"
  475. }
  476. if ActivityTypeId > 0 {
  477. condition += ` AND art.activity_type_id = ? `
  478. pars = append(pars, ActivityTypeId)
  479. }
  480. //类型 1 路演反馈 ,2:调研反馈
  481. if searchType == 1 {
  482. condition += ` AND v.file_type = 1 `
  483. } else if searchType == 2 {
  484. condition += ` AND v.file_type = 2 `
  485. }
  486. var conditionOrder string
  487. if sortType == "asc" || sortType == "desc" {
  488. conditionOrder += ` ORDER BY video_counts ` + sortType
  489. } else {
  490. conditionOrder += ` ORDER BY activity_time DESC `
  491. }
  492. list, total, err := cygx.GetActivityVoiceAndVideoList(condition, conditionVoice, conditionVideo, conditionOrder, pars, startSize, pageSize)
  493. if err != nil {
  494. br.Msg = "获取失败"
  495. br.ErrMsg = "获取失败,Err:" + err.Error()
  496. return
  497. }
  498. var activityIds string
  499. for k, v := range list {
  500. if v.ChartPermissionNames != "" {
  501. list[k].ChartPermissionName = v.ChartPermissionNames
  502. }
  503. activityIds += strconv.Itoa(v.ActivityId) + ","
  504. }
  505. activityIds = strings.TrimRight(activityIds, ",")
  506. mapIndustrial := make(map[int]string)
  507. mapSubject := make(map[string]string)
  508. if activityIds != "" {
  509. industrialList, err := cygx.GetIndustrialActivityGroupListByactivityIds(activityIds)
  510. if err != nil {
  511. br.Msg = "获取失败"
  512. br.ErrMsg = "获取失败,GetIndustrialActivityGroupListByactivityIds Err:" + err.Error()
  513. return
  514. }
  515. subjectList, err := cygx.GetSubjectActivityGroupListByactivityIds(activityIds)
  516. if err != nil {
  517. br.Msg = "获取失败"
  518. br.ErrMsg = "获取失败,GetSubjectActivityGroupListByactivityIds Err:" + err.Error()
  519. return
  520. }
  521. //合并活动对应的多个标的
  522. for _, v := range subjectList {
  523. mapSubject[fmt.Sprint(v.ActivityId, "_", v.IndustrialManagementId)] += v.SubjectName + "/"
  524. }
  525. //活动对应的产业
  526. for _, v := range industrialList {
  527. var labelSubject string
  528. labelSubject = mapSubject[fmt.Sprint(v.ActivityId, "_", v.IndustrialManagementId)]
  529. if labelSubject != "" {
  530. mapIndustrial[v.ActivityId] += v.IndustryName + "--" + strings.TrimRight(labelSubject, "/") + ","
  531. } else {
  532. mapIndustrial[v.ActivityId] += v.IndustryName + ","
  533. }
  534. }
  535. //处理音视文件标识
  536. mapVoice := make(map[int]bool)
  537. //var conditionVoice string
  538. var parsVoice []interface{}
  539. conditionVoice = " AND activity_id IN (" + activityIds + ") "
  540. listVoice, err := cygx.GetActivityVoiceList(conditionVoice, parsVoice)
  541. if err != nil && err.Error() != utils.ErrNoRow() {
  542. br.Msg = "获取失败"
  543. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  544. return
  545. }
  546. if len(listVoice) > 0 {
  547. for _, v := range listVoice {
  548. mapVoice[v.ActivityId] = true
  549. }
  550. }
  551. for k, v := range list {
  552. if mapIndustrial[v.ActivityId] != "" && v.TemporaryLabel == "" {
  553. list[k].Label = strings.TrimRight(mapIndustrial[v.ActivityId], ",")
  554. }
  555. if mapVoice[v.ActivityId] {
  556. v.FileName = "音频"
  557. } else {
  558. v.FileName = "视频"
  559. }
  560. }
  561. if len(list) == 0 {
  562. list = make([]*cygx.CygxActivityVideoListResp, 0)
  563. }
  564. }
  565. page := paging.GetPaging(currentIndex, pageSize, total)
  566. resp := new(cygx.CygxActivityVideoListRep)
  567. resp.List = list
  568. resp.Paging = page
  569. br.Ret = 200
  570. br.Success = true
  571. br.Msg = "获取成功"
  572. br.Data = resp
  573. }
  574. // @Title 留言列表详情
  575. // @Description 获取留言列表详情接口
  576. // @Param ActivityId query int true "活动ID"
  577. // @Param IsExport query bool false "是否导出excel,默认是false"
  578. // @Success 200 {object} cygx.ArticleCommentListResp
  579. // @router /activity_voice_and_video/commentList [get]
  580. func (this *ActivityVideoCoAntroller) VoiceAndVideoCommentList() {
  581. br := new(models.BaseResponse).Init()
  582. defer func() {
  583. this.Data["json"] = br
  584. this.ServeJSON()
  585. }()
  586. sysUser := this.SysUser
  587. if sysUser == nil {
  588. br.Msg = "请登录"
  589. br.ErrMsg = "请登录,SysUser Is Empty"
  590. return
  591. }
  592. activityId, _ := this.GetInt("ActivityId")
  593. //是否导出报表
  594. isExport, _ := this.GetBool("IsExport")
  595. var condition string
  596. var pars []interface{}
  597. videoInfo, _ := cygx.GetCygxActivityVideoReqDetail(activityId)
  598. if videoInfo != nil {
  599. condition += ` AND activity_id = ? AND video_id = ? `
  600. pars = append(pars, videoInfo.ActivityId, videoInfo.VideoId)
  601. } else {
  602. videoInfo, _ := cygx.GetMicroRoadshowVoiceById(activityId)
  603. if videoInfo == nil {
  604. br.Msg = "操作失败"
  605. br.ErrMsg = "音频ID错误"
  606. return
  607. }
  608. condition += ` AND activity_voice_id = ? `
  609. pars = append(pars, videoInfo.ActivityVoiceId)
  610. }
  611. list, err := cygx.GetArticleCommentListSearch(condition, pars)
  612. if err != nil {
  613. br.Msg = "获取失败"
  614. br.ErrMsg = "获取失败,Err:" + err.Error()
  615. return
  616. }
  617. resp := new(cygx.ArticleCommentListResp)
  618. resp.List = list
  619. //导出excel
  620. if isExport {
  621. VoiceAndVideoCommentListExport(this, resp, br)
  622. return
  623. }
  624. br.Ret = 200
  625. br.Success = true
  626. br.Msg = "获取成功"
  627. br.Data = resp
  628. }
  629. // VoiceAndVideoCommentListExport 导出Excel
  630. func VoiceAndVideoCommentListExport(this *ActivityVideoCoAntroller, resp *cygx.ArticleCommentListResp, br *models.BaseResponse) {
  631. //创建excel
  632. dir, err := os.Executable()
  633. exPath := filepath.Dir(dir)
  634. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  635. xlsxFile := xlsx.NewFile()
  636. if err != nil {
  637. br.Msg = "生成文件失败"
  638. br.ErrMsg = "生成文件失败"
  639. return
  640. }
  641. style := xlsx.NewStyle()
  642. alignment := xlsx.Alignment{
  643. Horizontal: "center",
  644. Vertical: "center",
  645. WrapText: true,
  646. }
  647. style.Alignment = alignment
  648. style.ApplyAlignment = true
  649. sheet, err := xlsxFile.AddSheet("阅读明细")
  650. if err != nil {
  651. br.Msg = "新增Sheet失败"
  652. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  653. return
  654. }
  655. //标头
  656. rowTitle := sheet.AddRow()
  657. cellA := rowTitle.AddCell()
  658. cellA.Value = "姓名"
  659. cellB := rowTitle.AddCell()
  660. cellB.Value = "公司名称"
  661. cellC := rowTitle.AddCell()
  662. cellC.Value = "留言"
  663. cellD := rowTitle.AddCell()
  664. cellD.Value = "提交时间"
  665. for _, item := range resp.List {
  666. row := sheet.AddRow()
  667. cellA := row.AddCell()
  668. cellA.Value = item.RealName
  669. cellB := row.AddCell()
  670. cellB.Value = item.CompanyName
  671. cellC := row.AddCell()
  672. cellC.Value = item.Content
  673. cellD := row.AddCell()
  674. cellD.Value = item.CreateTime
  675. }
  676. err = xlsxFile.Save(downLoadnFilePath)
  677. if err != nil {
  678. br.Msg = "保存文件失败"
  679. br.ErrMsg = "保存文件失败"
  680. return
  681. }
  682. downloadFileName := time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  683. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  684. defer func() {
  685. os.Remove(downLoadnFilePath)
  686. }()
  687. br.Ret = 200
  688. br.Success = true
  689. br.Msg = "导出成功"
  690. }