activity_video.go 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714
  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. // @Success 200 {object} cygx.CygxActivityVideoListRep
  419. // @router /activity_voice_and_video/list [get]
  420. func (this *ActivityVideoCoAntroller) ActivityVoiceAndVideoList() {
  421. br := new(models.BaseResponse).Init()
  422. defer func() {
  423. this.Data["json"] = br
  424. this.ServeJSON()
  425. }()
  426. sysUser := this.SysUser
  427. if sysUser == nil {
  428. br.Msg = "请登录"
  429. br.ErrMsg = "请登录,SysUser Is Empty"
  430. return
  431. }
  432. pageSize, _ := this.GetInt("PageSize")
  433. currentIndex, _ := this.GetInt("CurrentIndex")
  434. chartPermissionId, _ := this.GetInt("ChartPermissionId")
  435. ActivityTypeId, _ := this.GetInt("ActivityTypeId")
  436. searchType, _ := this.GetInt("SearchType", 1)
  437. startDate := this.GetString("StartDate")
  438. endDate := this.GetString("EndDate")
  439. keyWord := this.GetString("KeyWord")
  440. sortType := this.GetString("SortType")
  441. var startSize int
  442. if pageSize <= 0 {
  443. pageSize = utils.PageSize20
  444. }
  445. if currentIndex <= 0 {
  446. currentIndex = 1
  447. }
  448. startSize = utils.StartIndex(currentIndex, pageSize)
  449. var condition string
  450. var conditionVideo string
  451. var conditionVoice string
  452. var pars []interface{}
  453. if keyWord != "" {
  454. conditionVideo += ` AND (v.video_name LIKE '%` + keyWord + `%' ) `
  455. conditionVoice += ` AND (v.voice_name LIKE '%` + keyWord + `%' ) `
  456. }
  457. //行业名称
  458. if chartPermissionId > 0 {
  459. condition += ` AND art.chart_permission_id = ? `
  460. pars = append(pars, chartPermissionId)
  461. }
  462. if startDate != "" {
  463. condition += ` AND art.activity_time >= ` + "'" + startDate + " 00:00:00'"
  464. }
  465. if endDate != "" {
  466. condition += ` AND art.activity_time <= ` + "'" + endDate + " 23:59:59'"
  467. }
  468. if ActivityTypeId > 0 {
  469. condition += ` AND art.activity_type_id = ? `
  470. pars = append(pars, ActivityTypeId)
  471. }
  472. //类型 1 路演反馈 ,2:调研反馈
  473. if searchType == 1 {
  474. condition += ` AND v.file_type = 1 `
  475. } else if searchType == 2 {
  476. condition += ` AND v.file_type = 2 `
  477. }
  478. var conditionOrder string
  479. if sortType == "asc" || sortType == "desc" {
  480. conditionOrder += ` ORDER BY video_counts ` + sortType
  481. } else {
  482. conditionOrder += ` ORDER BY activity_time DESC `
  483. }
  484. list, total, err := cygx.GetActivityVoiceAndVideoList(condition, conditionVoice, conditionVideo, conditionOrder, pars, startSize, pageSize)
  485. if err != nil {
  486. br.Msg = "获取失败"
  487. br.ErrMsg = "获取失败,Err:" + err.Error()
  488. return
  489. }
  490. var activityIds string
  491. for k, v := range list {
  492. if v.ChartPermissionNames != "" {
  493. list[k].ChartPermissionName = v.ChartPermissionNames
  494. }
  495. activityIds += strconv.Itoa(v.ActivityId) + ","
  496. }
  497. activityIds = strings.TrimRight(activityIds, ",")
  498. mapIndustrial := make(map[int]string)
  499. mapSubject := make(map[string]string)
  500. if activityIds != "" {
  501. industrialList, err := cygx.GetIndustrialActivityGroupListByactivityIds(activityIds)
  502. if err != nil {
  503. br.Msg = "获取失败"
  504. br.ErrMsg = "获取失败,GetIndustrialActivityGroupListByactivityIds Err:" + err.Error()
  505. return
  506. }
  507. subjectList, err := cygx.GetSubjectActivityGroupListByactivityIds(activityIds)
  508. if err != nil {
  509. br.Msg = "获取失败"
  510. br.ErrMsg = "获取失败,GetSubjectActivityGroupListByactivityIds Err:" + err.Error()
  511. return
  512. }
  513. //合并活动对应的多个标的
  514. for _, v := range subjectList {
  515. mapSubject[fmt.Sprint(v.ActivityId, "_", v.IndustrialManagementId)] += v.SubjectName + "/"
  516. }
  517. //活动对应的产业
  518. for _, v := range industrialList {
  519. var labelSubject string
  520. labelSubject = mapSubject[fmt.Sprint(v.ActivityId, "_", v.IndustrialManagementId)]
  521. if labelSubject != "" {
  522. mapIndustrial[v.ActivityId] += v.IndustryName + "--" + strings.TrimRight(labelSubject, "/") + ","
  523. } else {
  524. mapIndustrial[v.ActivityId] += v.IndustryName + ","
  525. }
  526. }
  527. //处理音视文件标识
  528. mapVoice := make(map[int]bool)
  529. var conditionVoice string
  530. var parsVoice []interface{}
  531. conditionVoice = " AND activity_id IN (" + activityIds + ") "
  532. listVoice, err := cygx.GetActivityVoiceList(conditionVoice, parsVoice)
  533. if err != nil && err.Error() != utils.ErrNoRow() {
  534. br.Msg = "获取失败"
  535. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  536. return
  537. }
  538. if len(listVoice) > 0 {
  539. for _, v := range listVoice {
  540. mapVoice[v.ActivityId] = true
  541. }
  542. }
  543. for k, v := range list {
  544. if mapIndustrial[v.ActivityId] != "" && v.TemporaryLabel == "" {
  545. list[k].Label = strings.TrimRight(mapIndustrial[v.ActivityId], ",")
  546. }
  547. if mapVoice[v.ActivityId] {
  548. v.FileName = "音频"
  549. } else {
  550. v.FileName = "视频"
  551. }
  552. }
  553. if len(list) == 0 {
  554. list = make([]*cygx.CygxActivityVideoListResp, 0)
  555. }
  556. }
  557. page := paging.GetPaging(currentIndex, pageSize, total)
  558. resp := new(cygx.CygxActivityVideoListRep)
  559. resp.List = list
  560. resp.Paging = page
  561. br.Ret = 200
  562. br.Success = true
  563. br.Msg = "获取成功"
  564. br.Data = resp
  565. }
  566. // @Title 留言列表详情
  567. // @Description 获取留言列表详情接口
  568. // @Param ActivityId query int true "活动ID"
  569. // @Param IsExport query bool false "是否导出excel,默认是false"
  570. // @Success 200 {object} cygx.ArticleCommentListResp
  571. // @router /activity_voice_and_video/commentList [get]
  572. func (this *ActivityVideoCoAntroller) VoiceAndVideoCommentList() {
  573. br := new(models.BaseResponse).Init()
  574. defer func() {
  575. this.Data["json"] = br
  576. this.ServeJSON()
  577. }()
  578. sysUser := this.SysUser
  579. if sysUser == nil {
  580. br.Msg = "请登录"
  581. br.ErrMsg = "请登录,SysUser Is Empty"
  582. return
  583. }
  584. activityId, _ := this.GetInt("ActivityId")
  585. //是否导出报表
  586. isExport, _ := this.GetBool("IsExport")
  587. var condition string
  588. var pars []interface{}
  589. videoInfo, _ := cygx.GetCygxActivityVideoReqDetail(activityId)
  590. if videoInfo != nil {
  591. condition += ` AND activity_id = ? AND video_id = ? `
  592. pars = append(pars, videoInfo.ActivityId, videoInfo.VideoId)
  593. } else {
  594. videoInfo, _ := cygx.GetMicroRoadshowVoiceById(activityId)
  595. if videoInfo == nil {
  596. br.Msg = "操作失败"
  597. br.ErrMsg = "音频ID错误"
  598. return
  599. }
  600. condition += ` AND activity_voice_id = ? `
  601. pars = append(pars, videoInfo.ActivityVoiceId)
  602. }
  603. list, err := cygx.GetArticleCommentListSearch(condition, pars)
  604. if err != nil {
  605. br.Msg = "获取失败"
  606. br.ErrMsg = "获取失败,Err:" + err.Error()
  607. return
  608. }
  609. resp := new(cygx.ArticleCommentListResp)
  610. resp.List = list
  611. //导出excel
  612. if isExport {
  613. VoiceAndVideoCommentListExport(this, resp, br)
  614. return
  615. }
  616. br.Ret = 200
  617. br.Success = true
  618. br.Msg = "获取成功"
  619. br.Data = resp
  620. }
  621. // VoiceAndVideoCommentListExport 导出Excel
  622. func VoiceAndVideoCommentListExport(this *ActivityVideoCoAntroller, resp *cygx.ArticleCommentListResp, br *models.BaseResponse) {
  623. //创建excel
  624. dir, err := os.Executable()
  625. exPath := filepath.Dir(dir)
  626. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  627. xlsxFile := xlsx.NewFile()
  628. if err != nil {
  629. br.Msg = "生成文件失败"
  630. br.ErrMsg = "生成文件失败"
  631. return
  632. }
  633. style := xlsx.NewStyle()
  634. alignment := xlsx.Alignment{
  635. Horizontal: "center",
  636. Vertical: "center",
  637. WrapText: true,
  638. }
  639. style.Alignment = alignment
  640. style.ApplyAlignment = true
  641. sheet, err := xlsxFile.AddSheet("阅读明细")
  642. if err != nil {
  643. br.Msg = "新增Sheet失败"
  644. br.ErrMsg = "新增Sheet失败,Err:" + err.Error()
  645. return
  646. }
  647. //标头
  648. rowTitle := sheet.AddRow()
  649. cellA := rowTitle.AddCell()
  650. cellA.Value = "姓名"
  651. cellB := rowTitle.AddCell()
  652. cellB.Value = "公司名称"
  653. cellC := rowTitle.AddCell()
  654. cellC.Value = "留言"
  655. cellD := rowTitle.AddCell()
  656. cellD.Value = "提交时间"
  657. for _, item := range resp.List {
  658. row := sheet.AddRow()
  659. cellA := row.AddCell()
  660. cellA.Value = item.RealName
  661. cellB := row.AddCell()
  662. cellB.Value = item.CompanyName
  663. cellC := row.AddCell()
  664. cellC.Value = item.Content
  665. cellD := row.AddCell()
  666. cellD.Value = item.CreateTime
  667. }
  668. err = xlsxFile.Save(downLoadnFilePath)
  669. if err != nil {
  670. br.Msg = "保存文件失败"
  671. br.ErrMsg = "保存文件失败"
  672. return
  673. }
  674. downloadFileName := time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  675. this.Ctx.Output.Download(downLoadnFilePath, downloadFileName)
  676. defer func() {
  677. os.Remove(downLoadnFilePath)
  678. }()
  679. br.Ret = 200
  680. br.Success = true
  681. br.Msg = "导出成功"
  682. }