micro_roadshow.go 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742
  1. package services
  2. import (
  3. "encoding/json"
  4. "errors"
  5. "fmt"
  6. "hongze/hongze_cygx/models"
  7. "hongze/hongze_cygx/utils"
  8. "strconv"
  9. "strings"
  10. )
  11. // GetMicroRoadShowDefaultImgConfig 获取微路演默认图/分享图配置
  12. func GetMicroRoadShowDefaultImgConfig() (audioMap, videoMap, audioShareMap, videoShareMap map[int]string, err error) {
  13. audioMap = make(map[int]string, 0)
  14. videoMap = make(map[int]string, 0)
  15. audioShareMap = make(map[int]string, 0)
  16. videoShareMap = make(map[int]string, 0)
  17. key := models.MicroRoadshowDefaultImgKey
  18. conf, e := models.GetConfigByCode(key)
  19. if e != nil {
  20. err = errors.New("获取微路演默认图配置失败, Err: " + e.Error())
  21. return
  22. }
  23. if conf.ConfigValue == "" {
  24. err = errors.New("获取微路演默认图配置有误")
  25. return
  26. }
  27. list := new(models.MicroRoadShowDefaultImgList)
  28. if e = json.Unmarshal([]byte(conf.ConfigValue), &list); e != nil {
  29. err = errors.New("微路演默认图配置配置值解析失败, Err: " + e.Error())
  30. return
  31. }
  32. audioList := list.Audio
  33. for i := range audioList {
  34. audioMap[audioList[i].ChartPermissionId] = audioList[i].ImgUrl
  35. audioShareMap[audioList[i].ChartPermissionId] = audioList[i].ShareImg
  36. }
  37. videoList := list.Video
  38. for i := range videoList {
  39. videoMap[videoList[i].ChartPermissionId] = videoList[i].ImgUrl
  40. videoShareMap[videoList[i].ChartPermissionId] = videoList[i].ShareImg
  41. }
  42. return
  43. }
  44. // GetHomeNewestList 获取首页最新列表
  45. func GetHomeNewestList(userId, companyId, startSize, pageSize int, condition string, pars []interface{}) (resp []*models.HomeArticle, total int, err error) {
  46. resp = make([]*models.HomeArticle, 0)
  47. unionList, e := models.GetHomeNewestListUnionList(condition, pars, startSize, pageSize)
  48. if e != nil {
  49. err = errors.New("获取首页最新列表失败")
  50. return
  51. }
  52. unionTotal, e := models.GetHomeNewestListUnionCount(condition, pars)
  53. if e != nil {
  54. err = errors.New("获取首页最新列表总数失败")
  55. return
  56. }
  57. total = unionTotal
  58. // 用户权限
  59. authInfo, permissionArr, e := GetUserRaiPermissionInfo(userId, companyId)
  60. if e != nil {
  61. err = errors.New("获取用户权限失败, Err: " + e.Error())
  62. return
  63. }
  64. // 获取默认图配置
  65. audioMap, videoMap, audioShareMap, videoShareMap, e := GetMicroRoadShowDefaultImgConfig()
  66. if e != nil {
  67. err = errors.New("获取微路演默认图配置失败, Err: " + e.Error())
  68. return
  69. }
  70. // 此处没有直接使用HomeArticle结构体而是多加了一层, 纯粹是为了方便前端区分纪要和微路演音频=_=!
  71. for _, v := range unionList {
  72. item := new(models.HomeArticle)
  73. item.HomeType = v.HomeType
  74. // 纪要
  75. if item.HomeType == 0 {
  76. item.ArticleId = v.ArticleId
  77. item.Title = v.Title
  78. item.TitleEn = v.TitleEn
  79. item.UpdateFrequency = v.UpdateFrequency
  80. item.CreateDate = v.CreateDate
  81. item.PublishDate = v.PublishDate
  82. item.Body = v.Body
  83. item.BodyHtml = v.BodyHtml
  84. item.Abstract = v.Abstract
  85. item.CategoryName = v.CategoryName
  86. item.SubCategoryName = v.SubCategoryName
  87. item.ExpertBackground = v.ExpertBackground
  88. item.IsResearch = v.IsResearch
  89. item.Pv = v.Pv
  90. item.ImgUrlPc = v.ImgUrlPc
  91. item.CategoryId = v.CategoryId
  92. item.HttpUrl = v.HttpUrl
  93. item.IsNeedJump = v.IsNeedJump
  94. item.Source = v.Source
  95. item.Annotation = v.Annotation
  96. }
  97. // 音频
  98. if v.HomeType == 1 {
  99. ad := new(models.MicroAudioUnionList)
  100. ad.Id = v.Id
  101. ad.AudioTitle = v.AudioTitle
  102. ad.AudioResourceUrl = v.AudioResourceUrl
  103. ad.AudioType = v.AudioType
  104. ad.AudioPublishTime = utils.StrTimeToTime(v.AudioPublishTime).Format(utils.FormatDate)
  105. ad.AudioImgUrl = v.AudioImgUrl
  106. ad.AudioChartPermissionId = v.AudioChartPermissionId
  107. ad.AudioChartPermissionName = v.AudioChartPermissionName
  108. ad.AudioPlaySeconds = v.AudioPlaySeconds
  109. ad.AudioPlaySeconds = v.AudioPlaySeconds
  110. ad.AudioActivityId = v.AudioActivityId
  111. item.MicroAudio = ad
  112. // 默认图
  113. if ad.AudioImgUrl == "" {
  114. if ad.AudioType == 1 {
  115. ad.AudioImgUrl = audioMap[ad.AudioChartPermissionId]
  116. } else {
  117. ad.AudioImgUrl = videoMap[ad.AudioChartPermissionId]
  118. }
  119. }
  120. // 分享图
  121. if ad.AudioType == 1 {
  122. ad.AudioShareImg = audioShareMap[ad.AudioChartPermissionId]
  123. } else {
  124. ad.AudioShareImg = videoShareMap[ad.AudioChartPermissionId]
  125. }
  126. // 权限
  127. au := new(models.UserPermissionAuthInfo)
  128. au.SellerName = authInfo.SellerName
  129. au.SellerMobile = authInfo.SellerMobile
  130. au.HasPermission = authInfo.HasPermission
  131. au.OperationMode = authInfo.OperationMode
  132. if au.HasPermission == 1 {
  133. // 非宏观权限进一步判断是否有权限
  134. if ad.AudioChartPermissionId != utils.HONG_GUAN_ID && !utils.InArrayByStr(permissionArr, ad.AudioChartPermissionName) {
  135. au.HasPermission = 2
  136. }
  137. }
  138. // 无权限的弹框提示
  139. if au.HasPermission != 1 {
  140. if au.OperationMode == UserPermissionOperationModeCall {
  141. if ad.AudioType == 1 {
  142. au.PopupMsg = UserPermissionPopupMsgCallActivity
  143. } else {
  144. au.PopupMsg = UserPermissionPopupMsgCallMicroVideo
  145. }
  146. } else {
  147. if ad.AudioType == 1 {
  148. au.PopupMsg = UserPermissionPopupMsgApplyActivity
  149. } else {
  150. au.PopupMsg = UserPermissionPopupMsgApplyMicroVideo
  151. }
  152. }
  153. }
  154. ad.AuthInfo = au
  155. }
  156. resp = append(resp, item)
  157. }
  158. return
  159. }
  160. // GetMicroRoadShowPageList 获取微路演列表添加活动视频 更新与8.1版本
  161. func GetMicroRoadShowPageListV8(pageSize, currentIndex, audioId, videoId, activityVideoId int, filter, keywords, audioIds, videoIds, activityVideoIds, chartPermissionIds string) (respList []*models.MicroRoadShowPageList, total int, err error) {
  162. var e error
  163. // 根据每页数据量获取音视频配比
  164. startSize := utils.StartIndex(currentIndex, pageSize)
  165. videoList := make([]*models.MicroRoadShowPageList, 0)
  166. if keywords != "" {
  167. keywords = "%" + keywords + "%"
  168. }
  169. //音频的查询
  170. var audioCond string
  171. var audioPars []interface{}
  172. // 如果筛选条件为指定视频ID或只看视频则不做音频查询
  173. //if videoId > 0 || activityVideoId > 0 || filter == 1 {
  174. // audioCond = ""
  175. //} else {
  176. // 活动已发布且已结束
  177. audioCond += ` AND b.publish_status = 1 AND b.active_state = 3`
  178. //活动音频,设置有效时间为30天,失效后该活动就不再支持音频回放。有效期起始时间为活动的开始时间
  179. //endTime := time.Now().AddDate(0, 0, -30).Format("2006-01-02 15:04:05")
  180. //audioCond += ` AND b.activity_time > ? `
  181. //audioPars = append(audioPars, endTime)
  182. if keywords != "" {
  183. audioCond += ` AND ( a.voice_name LIKE ? OR b.label LIKE ? )`
  184. audioPars = append(audioPars, keywords, keywords)
  185. }
  186. if audioId > 0 {
  187. audioCond += ` AND a.activity_voice_id = ?`
  188. audioPars = append(audioPars, audioId)
  189. }
  190. if audioIds != "" {
  191. sliceId := strings.Split(audioIds, ",")
  192. var idSqlStr string
  193. for _, v := range sliceId {
  194. idSqlStr += "'" + v + "',"
  195. }
  196. idSqlStr = strings.TrimRight(idSqlStr, ",")
  197. audioCond += ` AND a.activity_voice_id IN (` + idSqlStr + `)`
  198. }
  199. //}
  200. //视频的处理
  201. var videoCond string
  202. var videoCondAct string
  203. var videoPars []interface{}
  204. var videoParsAct []interface{}
  205. //if audioId > 0 || filter == 2 {
  206. // videoCond = ""
  207. //} else {
  208. if keywords != "" {
  209. videoCond += ` AND video_name LIKE ?`
  210. videoPars = append(videoPars, keywords)
  211. videoCondAct += ` AND (video_name LIKE ? OR art.label LIKE ?)`
  212. videoParsAct = append(videoParsAct, keywords, keywords)
  213. }
  214. if videoId > 0 {
  215. videoCond += ` AND video_id = ?`
  216. videoPars = append(videoPars, videoId)
  217. }
  218. if activityVideoId > 0 {
  219. videoCondAct += ` AND video_id = ?`
  220. videoParsAct = append(videoParsAct, activityVideoId)
  221. }
  222. if activityVideoIds != "" {
  223. sliceId := strings.Split(activityVideoIds, ",")
  224. var idSqlStr string
  225. for _, v := range sliceId {
  226. idSqlStr += "'" + v + "',"
  227. }
  228. idSqlStr = strings.TrimRight(idSqlStr, ",")
  229. videoCondAct += ` AND v.video_id IN (` + idSqlStr + `)`
  230. }
  231. //如果传了路演的或者活动的视频ID只查询一个
  232. if videoId > 0 {
  233. videoCondAct += ` AND video_id = 0 `
  234. audioCond += ` AND a.activity_voice_id = 0 `
  235. }
  236. if activityVideoId > 0 {
  237. videoCond += ` AND video_id = 0 `
  238. audioCond += ` AND a.activity_voice_id = 0 `
  239. }
  240. if audioId > 0 {
  241. videoCondAct += ` AND video_id = 0 `
  242. videoCond += ` AND video_id = 0 `
  243. }
  244. if strings.Contains(filter, "1") && !strings.Contains(filter, "2") {
  245. audioCond += ` AND a.activity_voice_id = 0 `
  246. } else if !strings.Contains(filter, "1") && strings.Contains(filter, "2") {
  247. videoCondAct += ` AND video_id = 0 `
  248. videoCond += ` AND video_id = 0 `
  249. }
  250. if strings.Contains(filter, "3") && !strings.Contains(filter, "4") {
  251. audioCond += ` AND a.activity_voice_id = 0 `
  252. videoCondAct += ` AND video_id = 0 `
  253. } else if strings.Contains(filter, "3") && !strings.Contains(filter, "4") {
  254. videoCond += ` AND video_id = 0 `
  255. }
  256. if videoIds != "" {
  257. sliceId := strings.Split(videoIds, ",")
  258. var idSqlStr string
  259. for _, v := range sliceId {
  260. idSqlStr += "'" + v + "',"
  261. }
  262. idSqlStr = strings.TrimRight(idSqlStr, ",")
  263. videoCond += ` AND video_id IN (` + idSqlStr + `)`
  264. }
  265. videoCond += ` AND publish_status = 1`
  266. if chartPermissionIds != "" {
  267. videoCond += ` AND chart_permission_id IN (` + chartPermissionIds + `)`
  268. audioCond += ` AND b.chart_permission_id IN (` + chartPermissionIds + `)`
  269. videoCondAct += ` AND art.chart_permission_id IN (` + chartPermissionIds + `)`
  270. }
  271. //}
  272. total, videoList, e = models.GetMicroRoadShowVideoPageListV8(startSize, pageSize, videoCond, videoPars, videoCondAct, videoParsAct, audioCond, audioPars)
  273. if e != nil {
  274. err = errors.New("获取微路演音视频列表失败, Err: " + e.Error())
  275. return
  276. }
  277. respList = videoList
  278. return
  279. }
  280. // GetMicroRoadShowPageListIkWord 添加IK分词联想词 获取微路演列表添加活动视频 更新与8.1版本
  281. func CountMicroRoadShowPageListIkWord(audioId, videoId, activityVideoId int, keywordArr []string, filter, audioIds, videoIds, activityVideoIds string) (total int, err error) {
  282. var e error
  283. var keywords string
  284. if len(keywordArr) > 0 {
  285. keywords = KeyWordArrSqlRegexpAll(keywordArr)
  286. }
  287. //if keywords == "" {
  288. // return
  289. //}
  290. //音频的查询
  291. var audioCond string
  292. var audioPars []interface{}
  293. // 如果筛选条件为指定视频ID或只看视频则不做音频查询
  294. //if videoId > 0 || activityVideoId > 0 || filter == 1 {
  295. // audioCond += ` AND a.activity_voice_id = 0 `
  296. //} else {
  297. // 活动已发布且已结束
  298. audioCond += ` AND b.publish_status = 1 AND b.active_state = 3`
  299. if keywords != "" {
  300. audioCond += ` AND (a.voice_name REGEXP ? OR b.label REGEXP ? ) `
  301. audioPars = append(audioPars, keywords, keywords)
  302. }
  303. if audioId > 0 {
  304. audioCond += ` AND a.activity_voice_id = ?`
  305. audioPars = append(audioPars, audioId)
  306. }
  307. if audioIds != "" {
  308. sliceId := strings.Split(audioIds, ",")
  309. var idSqlStr string
  310. for _, v := range sliceId {
  311. idSqlStr += "'" + v + "',"
  312. }
  313. idSqlStr = strings.TrimRight(idSqlStr, ",")
  314. audioCond += ` AND a.activity_voice_id IN (` + idSqlStr + `)`
  315. }
  316. //}
  317. //视频的处理
  318. var videoCond string
  319. var videoCondAct string
  320. var videoPars []interface{}
  321. var videoParsAct []interface{}
  322. //if audioId > 0 || filter == 2 {
  323. // videoCond = ""
  324. //} else {
  325. if keywords != "" {
  326. videoCond += ` AND video_name REGEXP ? `
  327. videoPars = append(videoPars, keywords)
  328. videoCondAct += ` AND (video_name REGEXP ? OR art.label REGEXP ? )`
  329. videoParsAct = append(videoParsAct, keywords, keywords)
  330. }
  331. if videoId > 0 {
  332. videoCond += ` AND video_id = ? `
  333. videoPars = append(videoPars, videoId)
  334. }
  335. if activityVideoId > 0 {
  336. videoCondAct += ` AND video_id = ?`
  337. videoParsAct = append(videoParsAct, activityVideoId)
  338. }
  339. if activityVideoIds != "" {
  340. sliceId := strings.Split(activityVideoIds, ",")
  341. var idSqlStr string
  342. for _, v := range sliceId {
  343. idSqlStr += "'" + v + "',"
  344. }
  345. idSqlStr = strings.TrimRight(idSqlStr, ",")
  346. videoCondAct += ` AND v.video_id IN (` + idSqlStr + `)`
  347. }
  348. //如果传了路演的或者活动的视频ID只查询一个
  349. if videoId > 0 {
  350. videoCondAct += ` AND video_id = 0 `
  351. audioCond += ` AND a.activity_voice_id = 0 `
  352. }
  353. if activityVideoId > 0 {
  354. videoCond += ` AND video_id = 0 `
  355. audioCond += ` AND a.activity_voice_id = 0 `
  356. }
  357. if audioId > 0 {
  358. videoCondAct += ` AND video_id = 0 `
  359. videoCond += ` AND video_id = 0 `
  360. }
  361. if strings.Contains(filter, "1") && !strings.Contains(filter, "2") {
  362. audioCond += ` AND a.activity_voice_id = 0 `
  363. } else if !strings.Contains(filter, "1") && strings.Contains(filter, "2") {
  364. videoCondAct += ` AND video_id = 0 `
  365. videoCond += ` AND video_id = 0 `
  366. }
  367. if strings.Contains(filter, "3") && !strings.Contains(filter, "4") {
  368. audioCond += ` AND a.activity_voice_id = 0 `
  369. videoCondAct += ` AND video_id = 0 `
  370. } else if strings.Contains(filter, "3") && !strings.Contains(filter, "4") {
  371. videoCond += ` AND video_id = 0 `
  372. }
  373. if videoIds != "" {
  374. sliceId := strings.Split(videoIds, ",")
  375. var idSqlStr string
  376. for _, v := range sliceId {
  377. idSqlStr += "'" + v + "',"
  378. }
  379. idSqlStr = strings.TrimRight(idSqlStr, ",")
  380. videoCond += ` AND video_id IN (` + idSqlStr + `)`
  381. }
  382. videoCond += ` AND publish_status = 1`
  383. //}
  384. total, e = models.CountMicroRoadShowVideoPageList(videoCond, videoPars, videoCondAct, videoParsAct, audioCond, audioPars)
  385. if e != nil {
  386. err = errors.New("获取微路演音视频列表失败, Err: " + e.Error())
  387. return
  388. }
  389. return
  390. }
  391. // GetMicroRoadShowPageListIkWord 添加IK分词联想词 获取微路演列表添加活动视频 更新与8.1版本
  392. func GetMicroRoadShowPageListIkWord(startSize, pageSize, audioId, videoId, activityVideoId int, keywordArr []string, filter, audioIds, videoIds, activityVideoIds, keywords string) (respList []*models.MicroRoadShowPageList, err error) {
  393. videoList := make([]*models.MicroRoadShowPageList, 0)
  394. var e error
  395. var keywordsIk string
  396. if len(keywordArr) > 1 {
  397. keywordsIk = KeyWordArrSqlRegexp(keywordArr)
  398. }
  399. if keywords != "" {
  400. keywords = "%" + keywords + "%"
  401. }
  402. //音频的查询
  403. var audioCond string
  404. var audioPars []interface{}
  405. // 如果筛选条件为指定视频ID或只看视频则不做音频查询
  406. //if videoId > 0 || activityVideoId > 0 || filter == 1 {
  407. // audioCond += ` AND a.activity_voice_id = 0 `
  408. //} else {
  409. // 活动已发布且已结束
  410. audioCond += ` AND b.publish_status = 1 AND b.active_state = 3`
  411. if keywordsIk != "" {
  412. audioCond += ` AND ( a.voice_name REGEXP ? OR b.label REGEXP ? )`
  413. audioCond += ` AND ( a.voice_name NOT LIKE ? AND b.label NOT LIKE ? )`
  414. audioPars = append(audioPars, keywordsIk, keywordsIk, keywords, keywords)
  415. }
  416. if audioId > 0 {
  417. audioCond += ` AND a.activity_voice_id = ?`
  418. audioPars = append(audioPars, audioId)
  419. }
  420. if audioIds != "" {
  421. sliceId := strings.Split(audioIds, ",")
  422. var idSqlStr string
  423. for _, v := range sliceId {
  424. idSqlStr += "'" + v + "',"
  425. }
  426. idSqlStr = strings.TrimRight(idSqlStr, ",")
  427. audioCond += ` AND a.activity_voice_id IN (` + idSqlStr + `)`
  428. }
  429. //}
  430. //视频的处理
  431. var videoCond string
  432. var videoCondAct string
  433. var videoPars []interface{}
  434. var videoParsAct []interface{}
  435. //if audioId > 0 || filter == 2 {
  436. // videoCond = ""
  437. //} else {
  438. if keywordsIk != "" {
  439. videoCond += ` AND video_name REGEXP ?`
  440. videoPars = append(videoPars, keywordsIk)
  441. videoCondAct += ` AND ( v.video_name REGEXP ? OR art.label REGEXP ? )`
  442. videoCondAct += ` AND ( v.video_name NOT LIKE ? AND art.label NOT LIKE ? )`
  443. //videoCondAct += ` AND video_name REGEXP ?`
  444. videoParsAct = append(videoParsAct, keywordsIk, keywordsIk, keywords, keywords)
  445. }
  446. if videoId > 0 {
  447. videoCond += ` AND video_id = ?`
  448. videoPars = append(videoPars, videoId)
  449. }
  450. if activityVideoId > 0 {
  451. videoCondAct += ` AND video_id = ?`
  452. videoParsAct = append(videoParsAct, activityVideoId)
  453. }
  454. if activityVideoIds != "" {
  455. sliceId := strings.Split(activityVideoIds, ",")
  456. var idSqlStr string
  457. for _, v := range sliceId {
  458. idSqlStr += "'" + v + "',"
  459. }
  460. idSqlStr = strings.TrimRight(idSqlStr, ",")
  461. videoCondAct += ` AND v.video_id IN (` + idSqlStr + `)`
  462. }
  463. //如果传了路演的或者活动的视频ID只查询一个
  464. if videoId > 0 {
  465. videoCondAct += ` AND video_id = 0 `
  466. audioCond += ` AND a.activity_voice_id = 0 `
  467. }
  468. if activityVideoId > 0 {
  469. videoCond += ` AND video_id = 0 `
  470. audioCond += ` AND a.activity_voice_id = 0 `
  471. }
  472. if audioId > 0 {
  473. videoCondAct += ` AND video_id = 0 `
  474. videoCond += ` AND video_id = 0 `
  475. }
  476. if strings.Contains(filter, "1") && !strings.Contains(filter, "2") {
  477. audioCond += ` AND a.activity_voice_id = 0 `
  478. } else if !strings.Contains(filter, "1") && strings.Contains(filter, "2") {
  479. videoCondAct += ` AND video_id = 0 `
  480. videoCond += ` AND video_id = 0 `
  481. }
  482. if strings.Contains(filter, "3") && !strings.Contains(filter, "4") {
  483. audioCond += ` AND a.activity_voice_id = 0 `
  484. videoCondAct += ` AND video_id = 0 `
  485. } else if strings.Contains(filter, "3") && !strings.Contains(filter, "4") {
  486. videoCond += ` AND video_id = 0 `
  487. }
  488. if videoIds != "" {
  489. sliceId := strings.Split(videoIds, ",")
  490. var idSqlStr string
  491. for _, v := range sliceId {
  492. idSqlStr += "'" + v + "',"
  493. }
  494. idSqlStr = strings.TrimRight(idSqlStr, ",")
  495. videoCond += ` AND video_id IN (` + idSqlStr + `)`
  496. }
  497. videoCond += ` AND publish_status = 1`
  498. //}
  499. videoList, e = models.GetMicroRoadShowVideoPageListIkWord(startSize, pageSize, videoCond, videoPars, videoCondAct, videoParsAct, audioCond, audioPars)
  500. if e != nil {
  501. err = errors.New("获取微路演音视频列表失败分词, Err: " + e.Error())
  502. return
  503. }
  504. respList = videoList
  505. return
  506. }
  507. // 我的收藏
  508. func GetMicroRoadShowMycollect(pageSize, currentIndex int, audioIds, videoIds, activityVideoIds string) (respList []*models.MicroRoadShowPageList, total int, err error) {
  509. var e error
  510. // 根据每页数据量获取音视频配比
  511. startSize := utils.StartIndex(currentIndex, pageSize)
  512. videoList := make([]*models.MicroRoadShowPageList, 0)
  513. //音频的查询
  514. var audioCond string
  515. var audioPars []interface{}
  516. // 如果筛选条件为指定视频ID或只看视频则不做音频查询
  517. // 活动已发布且已结束
  518. audioCond += ` AND b.publish_status = 1 AND b.active_state = 3`
  519. if audioIds != "" {
  520. sliceId := strings.Split(audioIds, ",")
  521. var idSqlStr string
  522. for _, v := range sliceId {
  523. idSqlStr += "'" + v + "',"
  524. }
  525. idSqlStr = strings.TrimRight(idSqlStr, ",")
  526. audioCond += ` AND a.activity_voice_id IN (` + idSqlStr + `)`
  527. } else {
  528. audioCond += ` AND a.activity_voice_id = 0 `
  529. }
  530. //视频的处理
  531. var videoCond string
  532. var videoCondAct string
  533. if activityVideoIds != "" {
  534. sliceId := strings.Split(activityVideoIds, ",")
  535. var idSqlStr string
  536. for _, v := range sliceId {
  537. idSqlStr += "'" + v + "',"
  538. }
  539. idSqlStr = strings.TrimRight(idSqlStr, ",")
  540. videoCondAct += ` AND v.video_id IN (` + idSqlStr + `)`
  541. } else {
  542. videoCondAct += ` AND v.video_id = 0 `
  543. }
  544. var videoPars []interface{}
  545. var videoParsAct []interface{}
  546. if videoIds != "" {
  547. sliceId := strings.Split(videoIds, ",")
  548. var idSqlStr string
  549. for _, v := range sliceId {
  550. idSqlStr += "'" + v + "',"
  551. }
  552. idSqlStr = strings.TrimRight(idSqlStr, ",")
  553. videoCond += ` AND video_id IN (` + idSqlStr + `)`
  554. } else {
  555. videoCond += ` AND video_id = 0 `
  556. }
  557. videoCond += ` AND publish_status = 1`
  558. total, videoList, e = models.GetMicroRoadShowVideoPageListV8(startSize, pageSize, videoCond, videoPars, videoCondAct, videoParsAct, audioCond, audioPars)
  559. if e != nil {
  560. err = errors.New("获取微路演音视频列表失败, Err: " + e.Error())
  561. return
  562. }
  563. respList = videoList
  564. return
  565. }
  566. // GetMicroRoadshowVideoMap 获取已经发布的微路演的产业ID
  567. func GetMicroRoadshowVideoMap() (items map[int]int, err error) {
  568. list, e := models.GetMicroRoadshowVideoList()
  569. if e != nil && e.Error() != utils.ErrNoRow() {
  570. err = errors.New("获取已经发布的微路演的产业失败,GetMicroRoadshowVideoList " + e.Error())
  571. return
  572. }
  573. mapindustrialId := make(map[int]int)
  574. for _, v := range list {
  575. mapindustrialId[v.IndustryId] = v.IndustryId
  576. }
  577. items = mapindustrialId
  578. return
  579. }
  580. func GetindustryVideo(user *models.WxUserItem, industrialManagementId int) (industryVideo *models.MicroVideoSimpleInfo, AuthInfo *models.UserPermissionAuthInfo, err error) {
  581. total, e := models.GetMicroRoadshowVideoByIndustryIdCount(industrialManagementId)
  582. if e != nil {
  583. err = errors.New("获取产业关联的视频失败,GetMicroRoadshowVideoByIndustryIdCount " + e.Error())
  584. return
  585. }
  586. if total == 0 {
  587. return
  588. }
  589. // 用户权限
  590. authInfo, permissionArr, e := GetUserRaiPermissionInfo(user.UserId, user.CompanyId)
  591. if e != nil {
  592. err = errors.New("获取用户权限失败,GetUserRaiPermissionInfo " + e.Error())
  593. return
  594. }
  595. videoSimple := new(models.MicroVideoSimpleInfo)
  596. // 权限
  597. var au *models.UserPermissionAuthInfo
  598. video, e := models.GetMicroRoadshowVideoByIndustryId(industrialManagementId)
  599. if e != nil {
  600. err = errors.New("获取产业关联的视频失败,GetMicroRoadshowVideoByIndustryId " + e.Error())
  601. return
  602. } else {
  603. videoSimple.Id = video.VideoId
  604. videoSimple.Title = "5min【" + video.IndustryName + "】逻辑解析"
  605. videoSimple.BackgroundImg = video.ImgUrl
  606. videoSimple.DetailImgUrl = video.DetailImgUrl
  607. if videoSimple.BackgroundImg == "" {
  608. // 获取默认图配置
  609. _, videoMap, _, _, e := GetMicroRoadShowDefaultImgConfig()
  610. if e != nil {
  611. err = errors.New("获取视频默认配置图失败,GetMicroRoadshowVideoByIndustryId " + e.Error())
  612. return
  613. }
  614. videoSimple.BackgroundImg = videoMap[video.ChartPermissionId]
  615. }
  616. videoSimple.PlaySeconds = video.VideoDuration
  617. videoSimple.ResourceUrl = video.VideoUrl
  618. au = new(models.UserPermissionAuthInfo)
  619. au.SellerName = authInfo.SellerName
  620. au.SellerMobile = authInfo.SellerMobile
  621. au.HasPermission = authInfo.HasPermission
  622. au.OperationMode = authInfo.OperationMode
  623. if au.HasPermission == 1 {
  624. // 非宏观权限进一步判断是否有权限
  625. if video.ChartPermissionId != utils.HONG_GUAN_ID && !utils.InArrayByStr(permissionArr, video.ChartPermissionName) {
  626. au.HasPermission = 2
  627. }
  628. }
  629. // 无权限的弹框提示
  630. if au.HasPermission != 1 {
  631. if au.OperationMode == UserPermissionOperationModeCall {
  632. au.PopupMsg = UserPermissionPopupMsgCallMicroVideo
  633. } else {
  634. au.PopupMsg = UserPermissionPopupMsgApplyMicroVideo
  635. }
  636. videoSimple.ResourceUrl = ""
  637. }
  638. }
  639. industryVideo = videoSimple
  640. AuthInfo = au
  641. return
  642. }
  643. // 用户微路演视频回放操作操作行为,模板消息推送
  644. func MicroRoadshowVideoUserRmind(user *models.WxUserItem, videoId int) (err error) {
  645. defer func() {
  646. if err != nil {
  647. go utils.SendAlarmMsg("用户音视频回放操作操作行为,模板消息推送失败"+err.Error(), 2)
  648. }
  649. }()
  650. countUser, err := models.GetUserRemind(user.UserId)
  651. if err != nil {
  652. return err
  653. }
  654. if countUser == 0 {
  655. return err
  656. }
  657. var first string
  658. var keyword1 string
  659. var keyword2 string
  660. var keyword3 string
  661. var keyword4 string
  662. var remark string
  663. //获取销售手机号
  664. sellerItemQy, err := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
  665. if err != nil && err.Error() != utils.ErrNoRow() {
  666. return err
  667. }
  668. if sellerItemQy != nil {
  669. openIdList, e := models.GetWxOpenIdByMobileList(sellerItemQy.Mobile)
  670. if e != nil {
  671. err = errors.New("GetSellerByAdminId, Err: " + e.Error())
  672. return
  673. }
  674. videoInfo, e := models.GetMicroRoadshowVideoByVideoId(videoId)
  675. if e != nil {
  676. err = errors.New("GetCygxActivitySpecialDetailById, Err: " + e.Error())
  677. return
  678. }
  679. if videoInfo == nil {
  680. return
  681. }
  682. first = fmt.Sprint(user.RealName, "--", user.CompanyName, ",有新的互动:播放微路演详视频")
  683. keyword1 = videoInfo.VideoName
  684. keyword2 = fmt.Sprint("互动:播放微路演详视频,", user.RealName, "--", user.CompanyName)
  685. remark = "点击查看微路演详情"
  686. openIdArr := make([]string, 0)
  687. for _, v := range openIdList {
  688. openIdArr = append(openIdArr, v.OpenId)
  689. }
  690. redirectUrl := utils.WX_MSG_PATH_ACTIVITY_INDUSTRYR_EPORT + strconv.Itoa(videoInfo.IndustryId)
  691. sendInfo := new(SendWxTemplate)
  692. sendInfo.First = first
  693. sendInfo.Keyword1 = keyword1
  694. sendInfo.Keyword2 = keyword2
  695. sendInfo.Keyword3 = keyword3
  696. sendInfo.Keyword4 = keyword4
  697. sendInfo.Remark = remark
  698. sendInfo.TemplateId = utils.WxMsgTemplateIdArticleUserRemind
  699. sendInfo.RedirectUrl = redirectUrl
  700. sendInfo.RedirectTarget = 3
  701. sendInfo.Resource = strconv.Itoa(videoId)
  702. sendInfo.SendType = utils.TEMPLATE_MSG_CYGX_ARTICLE_ADD
  703. sendInfo.OpenIdArr = openIdArr
  704. err = PublicSendTemplateMsg(sendInfo)
  705. if err != nil {
  706. return
  707. }
  708. }
  709. return
  710. }