activity.go 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962
  1. package services
  2. import (
  3. "errors"
  4. "fmt"
  5. "hongze/hongze_clpt/models"
  6. "hongze/hongze_clpt/utils"
  7. "strconv"
  8. "strings"
  9. "time"
  10. "unicode/utf8"
  11. )
  12. // 获取活动列表查询权限的SQL
  13. // @Param ChartPermissionIds query string false "行业id 多个用 , 隔开"
  14. // @Param ActivityTypeIds query string false "活动类型id 多个用 , 隔开"
  15. // @Param ActiveState query string false "活动进行状态 未开始:1、进行中2、已结束3"
  16. // @Param WhichDay query string false "哪一天 今天:1、明天:2,多个用 , 隔开"
  17. // @Param WhichTime query string false "已结束的时间筛选项 本周:1、上周:2 、本月:3、上月:4"
  18. // @Param Label query string false "搜索主题 多个用 , 隔开"
  19. // @Param PlayBack query int false "是否仅展示回放 1:是、0:否 默认0"
  20. // @Param KeyWord query string false "搜索关键词"
  21. // @Param ikType query int false "联想词类型 , 1不做联想,2,做除初始词的联想,3所有联想"
  22. func GetActivityonditionList(user *models.WxUserItem, activityTypeId, chartPermissionIds, whichDay, activeState, label string, isPower, source int, keyWord string, playBack, ikType int) (conditionActivity string, err error) {
  23. keyWordNoIk := keyWord
  24. adminIds, err := models.GetSelleridWhichGroup(user.CompanyId, 2)
  25. if err != nil {
  26. return
  27. }
  28. userType, permissionStr, err := GetUserType(user.CompanyId)
  29. if err != nil {
  30. return
  31. }
  32. //判断客户规模是否属于可见范围的活动
  33. companyProduct, err := models.GetCompanyProductDetail(user.CompanyId, 2)
  34. if err != nil && err.Error() != utils.ErrNoRow() {
  35. return
  36. }
  37. isMaker := user.IsMaker
  38. slicePer := strings.Split(permissionStr, ",")
  39. var permissionSqlStr string
  40. var permissionNameStr string
  41. for _, v := range slicePer {
  42. if userType == 1 {
  43. //研选权限处理
  44. if !strings.Contains(v, utils.CHART_PERMISSION_NAME_YANXUAN) {
  45. permissionNameStr += "'" + v + "',"
  46. }
  47. } else {
  48. permissionNameStr += "'" + v + "',"
  49. }
  50. }
  51. permissionNameStr = strings.Replace(permissionNameStr, "(主观)", "", -1)
  52. permissionNameStr = strings.Replace(permissionNameStr, "(客观)", "", -1)
  53. permissionNameStr = strings.TrimRight(permissionNameStr, ",")
  54. // 查研观向7.4-始终查询宏观的权限(无论是否有权限)
  55. if permissionNameStr == `` {
  56. permissionNameStr = `'宏观'`
  57. } else {
  58. permissionNameStr += `, '宏观'`
  59. }
  60. var condition string
  61. var conditionAdmin string
  62. var conditionHz string // 弘则权限处理
  63. var sqlExport string // 专家权限处理
  64. permissionSqlStr = ` AND art.chart_permission_name IN (` + permissionNameStr + `)`
  65. sqlExport = ` AND (art.customer_type_ids LIKE '%` + strconv.Itoa(userType) + `%' `
  66. if userType == 2 {
  67. sqlExport += ` OR art.customer_type_ids LIKE '%3%' `
  68. }
  69. if (userType == 2 || userType == 3) && strings.Contains(permissionStr, "专家") {
  70. sqlExport += ` OR art.customer_type_ids LIKE '%4%' `
  71. }
  72. sqlExport += `) `
  73. // 如果是C类电话会就不展示内容,且合并到分析师电话会
  74. if activityTypeId != "" {
  75. if activityTypeId == strconv.Itoa(utils.ANALYST_TELL_ACTIVITY_TYPE_ID) {
  76. condition = ` AND art.publish_status = 1 AND art.label != '' AND art.activity_type_id IN (` + activityTypeId + "," + strconv.Itoa(utils.C_CLASS_ACTIVITY_TYPE_ID) + `)`
  77. } else {
  78. condition = ` AND art.publish_status = 1 AND art.label != '' AND art.activity_type_id IN (` + activityTypeId + `)`
  79. }
  80. }
  81. //主题
  82. if label != "" {
  83. condition = ` AND art.label LIKE '%` + label + `%' `
  84. }
  85. if isPower == 1 {
  86. condition += permissionSqlStr
  87. }
  88. //行业名称
  89. if len(chartPermissionIds) > 0 {
  90. condition += ` AND art.chart_permission_id IN (` + chartPermissionIds + `)`
  91. }
  92. //如果是PC的,则不看易董的
  93. if source == 1 {
  94. condition += ` AND art.yidong_activity_id = '' `
  95. }
  96. var conditionOr string
  97. if whichDay != "" {
  98. var startDate string
  99. var endDate string
  100. if whichDay == "1" {
  101. startDate = time.Now().Format(utils.FormatDate)
  102. endDate = startDate
  103. } else if whichDay == "2" {
  104. startDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  105. endDate = startDate
  106. } else if whichDay == "3" {
  107. startDate = utils.GetNowWeekMonday().Format(utils.FormatDate)
  108. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  109. } else if whichDay == "4" {
  110. startDate = utils.GetLastWeekMonday().Format(utils.FormatDate)
  111. endDate = utils.GetLastWeekSunday().Format(utils.FormatDate)
  112. } else if whichDay == "5" {
  113. startDate = utils.GetNowMonthFirstDay().Format(utils.FormatDate)
  114. endDate = utils.GetNowMonthLastDay().Format(utils.FormatDate)
  115. } else if whichDay == "6" {
  116. startDate = utils.GetLastMonthFirstDay().Format(utils.FormatDate)
  117. endDate = utils.GetLastMonthLastDay().Format(utils.FormatDate)
  118. } else if whichDay == "1,2" {
  119. startDate = time.Now().Format(utils.FormatDate)
  120. endDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  121. } else if whichDay == "3,4" {
  122. startDate = utils.GetLastWeekMonday().Format(utils.FormatDate)
  123. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  124. } else if whichDay == "5,6" {
  125. startDate = utils.GetLastMonthFirstDay().Format(utils.FormatDate)
  126. endDate = utils.GetNowMonthLastDay().Format(utils.FormatDate)
  127. } else {
  128. startDate = time.Now().Format(utils.FormatDate)
  129. endDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  130. }
  131. condition += ` AND art.activity_time >= ` + "'" + startDate + " 00:00:00'"
  132. condition += ` AND art.activity_time <= ` + "'" + endDate + " 23:59:59'"
  133. }
  134. //有搜索条件传过来时,不判进行状态条件
  135. if keyWord != "" {
  136. if ikType == 2 || ikType == 3 {
  137. keyWordArr, e := GetIndustryMapNameSliceV3(keyWord)
  138. if e != nil {
  139. err = errors.New("获取分词失败,GetIndustryMapNameSliceV3, Err: " + keyWord + e.Error())
  140. return
  141. }
  142. keyWordArr = RemoveDuplicatesAndEmpty(keyWordArr)
  143. //var keywords string
  144. if len(keyWordArr) > 1 {
  145. if ikType == 2 {
  146. keyWord = KeyWordArrSqlRegexp(keyWordArr)
  147. condition += ` AND (art.label NOT LIKE '%` + keyWordNoIk + `%' AND art.activity_name NOT LIKE '%` + keyWordNoIk + `%' ) `
  148. } else if ikType == 3 {
  149. keyWord = KeyWordArrSqlRegexpAll(keyWordArr)
  150. }
  151. }
  152. }
  153. condition += ` AND (art.label REGEXP '` + keyWord + `' OR art.activity_name REGEXP '` + keyWord + `' ) `
  154. } else {
  155. if activeState != "" {
  156. // 默认查看未开始跟进行中
  157. if activeState == "1" {
  158. condition += ` AND art.active_state IN (1,2)`
  159. } else {
  160. condition += ` AND art.active_state IN (` + activeState + `)`
  161. }
  162. } else {
  163. condition += ` AND art.active_state IN (1,2)`
  164. }
  165. }
  166. if playBack == 1 {
  167. var pars []interface{}
  168. ativityVIdArry := make([]string, 0)
  169. voiceList, e := models.GetActivityVoiceListAll("", pars, 0, 1000)
  170. if e != nil && e.Error() != utils.ErrNoRow() {
  171. err = e
  172. return
  173. }
  174. for _, v := range voiceList {
  175. ativityVIdArry = append(ativityVIdArry, strconv.Itoa(v.ActivityId))
  176. }
  177. videoList, e := models.GetActivityVideoListAll("", pars, 0, 1000)
  178. if e != nil && e.Error() != utils.ErrNoRow() {
  179. err = e
  180. return
  181. }
  182. for _, v := range videoList {
  183. ativityVIdArry = append(ativityVIdArry, strconv.Itoa(v.ActivityId))
  184. }
  185. //活动音频,设置有效时间为30天,失效后该活动就不再支持音频回放。有效期起始时间为活动的开始时间
  186. //endTime := time.Now().AddDate(0, 0, -30).Format("2006-01-02 15:04:05")
  187. //condition += ` AND art.activity_time > '` + endTime + `' `
  188. if len(ativityVIdArry) > 0 {
  189. ativityVIdstr := strings.Join(ativityVIdArry, ",")
  190. condition += ` AND art.activity_id IN (` + ativityVIdstr + `) `
  191. }
  192. }
  193. //查询全部可见的数据(是否全部客户可见)
  194. //condition += ` AND art.visible_range != 1 AND art.publish_status = 1 `
  195. condition += ` AND art.publish_status = 1 `
  196. conditionHz = condition
  197. //活动仅决策人可见
  198. if isMaker == 0 {
  199. condition += ` AND art.is_maker_show = 0 `
  200. }
  201. conditionAdmin = condition + ` AND art.visible_range = 1 `
  202. condition += ` AND art.visible_range != 1 `
  203. if (userType == 2 || userType == 3 || userType == 4) && strings.Contains(permissionStr, "专家") {
  204. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%4%' ` + condition + `) `
  205. }
  206. if (userType == 5) && strings.Contains(permissionStr, "专家") {
  207. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%5%' ` + condition + `) `
  208. }
  209. if userType == 1 {
  210. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + permissionSqlStr + `) `
  211. } else {
  212. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + `) `
  213. }
  214. if userType == 6 || userType == 7 {
  215. conditionOr += ` OR ( art.customer_type_ids LIKE '%` + strconv.Itoa(userType) + `%' ` + condition + `) `
  216. }
  217. if companyProduct != nil {
  218. if companyProduct.Scale != "" {
  219. conditionOr += ` OR ( art.scale LIKE '%` + companyProduct.Scale + `%' ` + condition + `) `
  220. }
  221. }
  222. if adminIds != "" {
  223. conditionOr += ` OR ( art.customer_type_ids LIKE '%` + strconv.Itoa(userType) + `%' ` + ` AND art.admin_id IN (` + adminIds + `) ` + conditionAdmin + `) `
  224. if companyProduct != nil {
  225. if companyProduct.Scale != "" {
  226. conditionOr += ` OR ( art.scale LIKE '%` + companyProduct.Scale + `%'` + ` AND art.admin_id IN (` + adminIds + `) ` + conditionAdmin + `) `
  227. }
  228. }
  229. }
  230. //弘则研究下的客户不做权限,限制,C类电话会,仅本组销售、部门管理员、admin、权益研究员账号能看到
  231. if user.CompanyId == 16 {
  232. mapMobile, e := GetAdminMobileMap()
  233. if e != nil {
  234. err = e
  235. return
  236. }
  237. if _, ok := mapMobile[user.Mobile]; ok {
  238. conditionOr += ` OR ( art.publish_status = 1 ` + conditionHz + `) `
  239. }
  240. }
  241. conditionActivity = condition + permissionSqlStr + sqlExport + conditionOr
  242. return
  243. }
  244. // 获取可见的活动
  245. func HandleActivityPowerList(listActivity []*models.CygxActivity, user *models.WxUserItem) (items []*models.CygxActivity, err error) {
  246. return
  247. }
  248. // 5.3版本活动标签字符串处理
  249. func LabelStr(label string, isShowSubjectName int, temporaryLabel string) (labelNew string) {
  250. slicebr := strings.Split(label, "-")
  251. if len(slicebr) > 1 {
  252. if isShowSubjectName == 1 {
  253. labelNew = slicebr[1]
  254. } else {
  255. labelNew = slicebr[0]
  256. }
  257. } else {
  258. labelNew = label
  259. }
  260. if temporaryLabel != "" {
  261. labelNew = temporaryLabel
  262. }
  263. return labelNew
  264. }
  265. // 列表
  266. func HandleActivityTypeHomeList(listType []*models.ActivityTypeHome, listActivity []*models.CygxActivity, user *models.WxUserItem) (items []*models.ActivityTypeHome, err error) {
  267. mapActivity := make(map[int][]*models.CygxActivityLabelList)
  268. activityIds := make([]int, 0) // 用于查询活动【新】标签Map
  269. for _, v := range listActivity {
  270. // 如果是C类电话会就不展示内容,且合并到分析师电话会
  271. if v.ActivityTypeId == 7 {
  272. v.ActivityTypeId = 2
  273. }
  274. if v.ActivityTypeId == 1 {
  275. activityIds = append(activityIds, v.ActivityId)
  276. }
  277. }
  278. // 活动【新】标签Map
  279. newLabelMap, _, e := GetActivityNewLabelMap(activityIds)
  280. if e != nil {
  281. err = errors.New("获取产业新标签Map失败,GetActivityNewLabelMap Err: " + e.Error())
  282. return
  283. }
  284. mapkeyWord := make(map[string]string)
  285. for _, v := range listActivity {
  286. if v.Label == "" {
  287. continue
  288. }
  289. // 如果是C类电话会就不展示内容,且合并到分析师电话会
  290. if v.ActivityTypeId == 7 {
  291. v.ActivityTypeId = 2
  292. }
  293. item := new(models.CygxActivityLabelList)
  294. item.KeyWord = LabelStr(v.Label, v.IsShowSubjectName, v.TemporaryLabel)
  295. if _, ok := mapkeyWord[fmt.Sprint(v.ActivityTypeId, "-", item.KeyWord)]; ok {
  296. continue
  297. }
  298. item.Resource = 1
  299. item.ActivityId = v.ActivityId
  300. if v.YidongActivityId != "" {
  301. item.IsExternalLabel = true
  302. }
  303. item.City = v.City
  304. if utf8.RuneCountInString(v.City) != 2 {
  305. item.City = ""
  306. }
  307. item.IsNew = newLabelMap[v.ActivityId]
  308. mapActivity[v.ActivityTypeId] = append(mapActivity[v.ActivityTypeId], item)
  309. mapkeyWord[fmt.Sprint(v.ActivityTypeId, "-", item.KeyWord)] = item.KeyWord
  310. }
  311. for _, v := range listType {
  312. v.Resource = 1
  313. if len(mapActivity[v.ActivityTypeId]) > 0 {
  314. v.List = mapActivity[v.ActivityTypeId]
  315. } else {
  316. v.List = make([]*models.CygxActivityLabelList, 0)
  317. }
  318. }
  319. items = listType
  320. return
  321. }
  322. // GetActivityVoiceResp 处理活动音频回放
  323. func GetActivityVoiceResp(mapActivityId []int) (mapItem map[int]*models.CygxActivityVoiceReq, err error) {
  324. activityVoiceList, err := models.GetCygxActivityVoiceReqList(mapActivityId)
  325. if err != nil && err.Error() != utils.ErrNoRow() {
  326. return
  327. }
  328. mapActivityVoice := make(map[int]*models.CygxActivityVoiceReq)
  329. if len(activityVoiceList) > 0 {
  330. for _, v := range activityVoiceList {
  331. mapActivityVoice[v.ActivityId] = v
  332. }
  333. }
  334. mapItem = mapActivityVoice
  335. return
  336. }
  337. // GetActivityVideoResp 处理活动视频频回放
  338. func GetActivityVideoResp(mapActivityId []int) (mapItem map[int]*models.CygxActivityVideoListResp, err error) {
  339. var condition string
  340. var ativityVIdstr string
  341. for _, v := range mapActivityId {
  342. ativityVIdstr += strconv.Itoa(v) + ","
  343. }
  344. if ativityVIdstr == "" {
  345. return
  346. }
  347. ativityVIdstr = strings.TrimRight(ativityVIdstr, ",")
  348. condition += ` AND art.activity_id IN (` + ativityVIdstr + `) `
  349. var pars []interface{}
  350. //endTime := time.Now().AddDate(0, 0, -30).Format("2006-01-02 15:04:05")
  351. //condition += ` AND art.activity_time > ? `
  352. //pars = append(pars, endTime)
  353. videoList, e := models.GetActivityVideoListAll(condition, pars, 0, 1000)
  354. if e != nil && e.Error() != utils.ErrNoRow() {
  355. err = e
  356. return
  357. }
  358. mapActivityVideo := make(map[int]*models.CygxActivityVideoListResp)
  359. if len(videoList) > 0 {
  360. for _, v := range videoList {
  361. mapActivityVideo[v.ActivityId] = v
  362. }
  363. }
  364. mapItem = mapActivityVideo
  365. return
  366. }
  367. func ActivityButtonShow(item *models.ActivityDetail, user *models.WxUserItem) (itemActivity *models.ActivityListResp) {
  368. articleDetail := item
  369. //IsShowAppointment bool `description:"是否展示预约纪要"`
  370. //IsShowOutboundCall bool `description:"是否展示预约外呼"`
  371. //IsShowMeetingReminder bool `description:"是否展示会议提醒"`
  372. //IsShowHelpSsk bool `description:"是否展示帮我带问"`
  373. //IsShowSignup bool `description:"是否展示我要报名"`
  374. activityTimeText := articleDetail.ActivityTimeText
  375. activityTimeText = strings.Replace(activityTimeText, "(", "(", -1)
  376. activityTimeText = strings.Replace(activityTimeText, ")", ")", -1)
  377. articleDetail.ActivityTimeText = activityTimeText
  378. var yidongActivityUrl string
  379. articleDetail.IsShowAppointment = false
  380. //易董的操作按钮都隐藏
  381. if articleDetail.YidongActivityId != "" {
  382. articleDetail.IsShowSignup = false
  383. articleDetail.IsShowDetails = true
  384. if articleDetail.YidongActivityId != "" {
  385. ydTgc, _ := GetYiDongCreateUserInfo(user)
  386. yidongLongLink, _ := GetYiDongOriginalLink(articleDetail)
  387. if yidongLongLink != "" {
  388. yidongActivityUrl = yidongLongLink + "%26source=11%26fromHz=true%26tgc=" + ydTgc
  389. }
  390. }
  391. } else {
  392. //专家电话会 1
  393. if articleDetail.ActivityTypeId == 1 && articleDetail.IsLimitPeople == 0 && (articleDetail.ActiveState == "1" || articleDetail.ActiveState == "2") {
  394. articleDetail.IsShowHelpSsk = true
  395. }
  396. if articleDetail.ActiveState == "1" {
  397. //新的是否展示规则
  398. if articleDetail.IsCanAppointmentMinutes == 1 {
  399. articleDetail.IsShowAppointment = true
  400. }
  401. //专家电话会 1
  402. if articleDetail.ActivityTypeId == 1 {
  403. if articleDetail.LimitPeopleNum == 0 {
  404. articleDetail.IsShowOutboundCall = true
  405. } else {
  406. articleDetail.IsShowSignup = true
  407. }
  408. articleDetail.IsShowMeetingReminder = true
  409. articleDetail.IsShowHelpSsk = true
  410. }
  411. //分析师电话会 2
  412. if articleDetail.ActivityTypeId == 2 {
  413. if articleDetail.LimitPeopleNum == 0 {
  414. articleDetail.IsShowOutboundCall = true
  415. } else {
  416. articleDetail.IsShowSignup = true
  417. }
  418. articleDetail.IsShowMeetingReminder = true
  419. }
  420. //公司调研电话会 3
  421. if articleDetail.ActivityTypeId == 3 {
  422. if articleDetail.LimitPeopleNum == 0 {
  423. articleDetail.IsShowMeetingReminder = true
  424. articleDetail.IsShowOutboundCall = true
  425. } else {
  426. articleDetail.IsShowSignup = true
  427. }
  428. }
  429. //公司线下调研 4
  430. if articleDetail.ActivityTypeId == 4 {
  431. articleDetail.IsShowSignup = true
  432. }
  433. //专家线下沙龙 5
  434. if articleDetail.ActivityTypeId == 5 {
  435. articleDetail.IsShowSignup = true
  436. }
  437. //分析师线下沙龙 6
  438. if articleDetail.ActivityTypeId == 6 {
  439. articleDetail.IsShowSignup = true
  440. }
  441. //分析师电话会(C类) 7
  442. if articleDetail.ActivityTypeId == 7 {
  443. articleDetail.IsShowSignup = true
  444. articleDetail.IsShowMeetingReminder = true
  445. }
  446. //如果是易董创建的活动,展示我要报名,不展示预约外呼
  447. if articleDetail.IsYidongConduct {
  448. articleDetail.IsShowSignup = true
  449. articleDetail.IsShowOutboundCall = false
  450. }
  451. }
  452. }
  453. authInfo, permissionArr, e := GetUserRaiPermissionInfo(user.UserId, user.CompanyId)
  454. if e != nil {
  455. e = errors.New("获取用户权限失败, Err: " + e.Error())
  456. return
  457. }
  458. v := articleDetail
  459. itemActivity = &models.ActivityListResp{
  460. ActivityId: v.ActivityId,
  461. ActivityTypeId: v.ActivityTypeId,
  462. ActivityTypeName: v.ActivityTypeName,
  463. ChartPermissionId: v.ChartPermissionId,
  464. ChartPermissionName: v.ChartPermissionName,
  465. IsLimitPeople: v.IsLimitPeople,
  466. LimitPeopleNum: v.LimitPeopleNum,
  467. LastUpdatedTime: v.LastUpdatedTime,
  468. ActivityTime: v.ActivityTime,
  469. ActivityTimeText: v.ActivityTimeText,
  470. DistinguishedGuest: v.DistinguishedGuest,
  471. Host: v.Host,
  472. Speaker: v.Speaker,
  473. MainlandTell: v.MainlandTell,
  474. HongKongTell: v.HongKongTell,
  475. TaiwanTell: v.TaiwanTell,
  476. AmericaTell: v.AmericaTell,
  477. ParticipationCode: v.ParticipationCode,
  478. Theme: v.Theme,
  479. Expert: v.Expert,
  480. ActivityName: v.ActivityName,
  481. OnlineParticipation: v.OnlineParticipation,
  482. ReportLink: v.ReportLink,
  483. City: v.City,
  484. Address: v.Address,
  485. Highlights: v.Highlights,
  486. Remarks: v.Remarks,
  487. IsSignup: v.IsSignup,
  488. IsCancelMeetingReminder: v.IsCancelMeetingReminder,
  489. IsAppointment: v.IsAppointment,
  490. ActiveState: v.ActiveState,
  491. IsShowSustainable: v.IsShowSustainable,
  492. Description: v.Description,
  493. IsResearch: v.IsResearch,
  494. IsHideAppointment: v.IsHideAppointment,
  495. IsCClassMeeting: v.IsCClassMeeting,
  496. Label: v.Label,
  497. ImgUrl: v.ImgUrl,
  498. ImgUrlText: v.ImgUrlText,
  499. ActivityType: v.ActivityType,
  500. IsShowOutboundCall: v.IsShowOutboundCall,
  501. IsShowMeetingReminder: v.IsShowMeetingReminder,
  502. IsShowHelpSsk: v.IsShowHelpSsk,
  503. IsShowSignup: v.IsShowSignup,
  504. IsShowAppointment: v.IsShowAppointment,
  505. IsShowDetails: v.IsShowDetails,
  506. AudioLink: v.AudioLink,
  507. VoiceDetail: v.VoiceList,
  508. VideoDetail: v.VideoDetail,
  509. FileType: v.FileType,
  510. SourceType: v.SourceType,
  511. SignupNum: v.SignupNum,
  512. YidongActivityUrl: yidongActivityUrl,
  513. Explain: utils.ACtIVITY_SPECIAL_EXPLAIN,
  514. TripImgLink: v.TripImgLink,
  515. Days: v.Days,
  516. SignupType: v.SignupType,
  517. IsYidongConduct: v.IsYidongConduct,
  518. TencentConferenceNumber: v.TencentConferenceNumber,
  519. }
  520. au := new(models.UserPermissionAuthInfo)
  521. au.SellerName = authInfo.SellerName
  522. au.SellerMobile = authInfo.SellerMobile
  523. au.HasPermission = authInfo.HasPermission
  524. au.OperationMode = authInfo.OperationMode
  525. if au.HasPermission == 1 {
  526. // 非宏观权限进一步判断是否有权限
  527. if v.ChartPermissionId != utils.HONG_GUAN_ID && !utils.InArrayByStr(permissionArr, v.ChartPermissionName) {
  528. au.HasPermission = 2
  529. }
  530. }
  531. // 无权限的弹框提示
  532. if au.HasPermission != 1 {
  533. if au.OperationMode == UserPermissionOperationModeCall {
  534. if v.FileType == 1 {
  535. au.PopupMsg = UserPermissionPopupMsgCallMicroVoice
  536. } else {
  537. au.PopupMsg = UserPermissionPopupMsgCallMicroVideo
  538. }
  539. } else {
  540. if v.FileType == 1 {
  541. au.PopupMsg = UserPermissionPopupMsgApplyMicroVoice
  542. } else {
  543. au.PopupMsg = UserPermissionPopupMsgApplyMicroVideo
  544. }
  545. }
  546. }
  547. itemActivity.AuthInfo = au
  548. //处理用户已经报名了的行程
  549. var activityIds []int
  550. activityIds = append(activityIds, v.ActivityId)
  551. UserMap, e := GetSpecialTripUserMap(activityIds, user.UserId)
  552. if e != nil {
  553. e = errors.New("GetSpecialTripUserMap, Err: " + e.Error())
  554. return
  555. }
  556. if _, ok := UserMap[v.ActivityId]; ok {
  557. itemActivity.IsTrip = 1
  558. }
  559. if itemActivity.Days == 0 {
  560. itemActivity.TripStatus = 1
  561. //activityDetail.Explain = utils.ACtIVITY_SPECIAL_EXPLAIN
  562. } else {
  563. itemActivity.TripStatus = 2
  564. //itemActivity.TripImgLink = itemActivity.TripImgLinkFix
  565. //activityDetail.Explain = utils.ACtIVITY_SPECIAL_TRIP_EXPLAIN
  566. }
  567. return
  568. }
  569. func ActivityDetaailShow(activityInfo *models.ActivityListResp) (itemActivity *models.ActivityListResp, err error) {
  570. itemActivity = activityInfo
  571. if GetShowSustainable() && strings.Contains(itemActivity.ChartPermissionName, "研选") {
  572. itemActivity.IsShowSustainable = true
  573. }
  574. if activityInfo.SignupNum > activityInfo.LimitPeopleNum {
  575. activityInfo.SignupNum = activityInfo.LimitPeopleNum
  576. }
  577. //if activityInfo.ReportLink != "" {
  578. // artList := strings.Split(activityInfo.ReportLink, "{|}")
  579. // if len(artList) > 0 {
  580. // for _, v := range artList {
  581. // artitem := new(models.ActivityArticleResp)
  582. // artitem.ReportLink = v
  583. // artIdSlice := strings.Split(v, "/")
  584. // if len(artIdSlice) > 0 {
  585. // articleId, _ := strconv.Atoi(artIdSlice[len(artIdSlice)-1])
  586. // artitem.ArticleId = articleId
  587. // }
  588. // activityInfo.ArticleList = append(activityInfo.ArticleList, artitem)
  589. // }
  590. // }
  591. //} else {
  592. // activityInfo.ArticleList = make([]*models.ActivityArticleResp, 0)
  593. //}
  594. if activityInfo.ReportLink != "" {
  595. artList, e := GetActivityReportLinkToArticleList(activityInfo)
  596. if e != nil && e.Error() != utils.ErrNoRow() {
  597. err = e
  598. return
  599. }
  600. if len(artList) == 0 {
  601. activityInfo.ArticleList = make([]*models.ActivityArticleResp, 0)
  602. } else {
  603. activityInfo.ArticleList = artList
  604. }
  605. } else {
  606. activityInfo.ArticleList = make([]*models.ActivityArticleResp, 0)
  607. }
  608. activityInfo.ActivityTypeName = strings.Replace(activityInfo.ActivityTypeName, "(C类)", "", -1)
  609. return
  610. }
  611. // GetActivityNewLabelMap 获取活动【新】标签Map
  612. func GetActivityNewLabelMap(activityIds []int) (labelMap map[int]bool, industryNewMap map[int]bool, err error) {
  613. labelMap = make(map[int]bool, 0)
  614. industryNewMap = make(map[int]bool, 0)
  615. if len(activityIds) == 0 {
  616. return
  617. }
  618. // 获取活动关联的产业
  619. var groupCond string
  620. var groupPars []interface{}
  621. groupCond += ` AND a.activity_id IN (` + utils.GetOrmInReplace(len(activityIds)) + `) AND b.source = 1 AND a.active_state != 3 `
  622. groupPars = append(groupPars, activityIds)
  623. groups, e := models.GetActivityIndustryRelationList(groupCond, groupPars)
  624. if e != nil {
  625. err = errors.New("获取活动产业关联列表失败, Err: " + e.Error())
  626. return
  627. }
  628. activityIndustryMap := make(map[int][]int, 0)
  629. industryIds := make([]int, 0)
  630. for i := range groups {
  631. industryIds = append(industryIds, groups[i].IndustrialManagementId)
  632. activityIndustryMap[groups[i].ActivityId] = append(activityIndustryMap[groups[i].ActivityId], groups[i].IndustrialManagementId)
  633. }
  634. // 获取新产业Map
  635. industryLabelMap, e := GetIndustryNewLabelMap(industryIds)
  636. if e != nil {
  637. err = errors.New("获取产业新标签Map失败, Err: " + e.Error())
  638. return
  639. }
  640. // 判断活动是否为新
  641. for k := range industryLabelMap {
  642. for k2, v2 := range activityIndustryMap {
  643. if labelMap[k2] {
  644. continue
  645. }
  646. // 活动的产业ID中存在一个新产业即为新活动
  647. if utils.InArrayByInt(v2, k) {
  648. labelMap[k2] = true
  649. }
  650. }
  651. }
  652. //for _, v := range activityIds {
  653. // labelMap[v] = true
  654. //}
  655. //fmt.Println(labelMap)
  656. ////产业关联的弘则报告发布日期在三个月以内的活动、产业显示 NEW标签
  657. articNewLabel, e := GetArticNewLabelWhithActivity3Month()
  658. if e != nil {
  659. err = errors.New("获取产业新标签Map失败, Err: " + e.Error())
  660. return
  661. }
  662. for k := range articNewLabel {
  663. labelMap[k] = false
  664. }
  665. return
  666. }
  667. // GetIndustryNewLabelMap 获取产业【新】标签Map
  668. func GetIndustryNewLabelMap(industryIds []int) (labelMap map[int]bool, err error) {
  669. labelMap = make(map[int]bool, 0)
  670. industryIdLen := len(industryIds)
  671. if industryIdLen == 0 {
  672. return
  673. }
  674. // 获取产业关联的报告最早发布时间及最近的发布时间
  675. var timeCond string
  676. var timePars []interface{}
  677. timeCond += ` AND b.publish_status = 1`
  678. if industryIdLen > 0 {
  679. timeCond += ` AND a.industrial_management_id IN (` + utils.GetOrmInReplace(industryIdLen) + `)`
  680. timePars = append(timePars, industryIds)
  681. }
  682. industryTimeList, e := models.GetIndustryArticleMinMaxPublishTime(timeCond, timePars)
  683. if e != nil {
  684. err = errors.New("获取产业文章最大最小发布时间失败, Err: " + e.Error())
  685. return
  686. }
  687. // 判断产业是否为新
  688. nowTime := time.Now().Local()
  689. threeMonthBefore := nowTime.AddDate(0, -3, 0)
  690. nullTime, _ := time.ParseInLocation(utils.FormatDateTime, "0001-01-01 00:00:00", time.Local)
  691. industryMap := make(map[int]*models.IndustryArticleMinMaxPublishTime, 0)
  692. for i := range industryTimeList {
  693. industryMap[industryTimeList[i].IndustrialManagementId] = industryTimeList[i]
  694. }
  695. for i := range industryIds {
  696. iid := industryIds[i]
  697. item := industryMap[iid]
  698. if item != nil {
  699. // 最早发布时间为空 / 最早发布时间在三个月前之后
  700. if item.MinPublishTime.Equal(nullTime) || (item.MinPublishTime.After(threeMonthBefore)) {
  701. labelMap[iid] = true
  702. }
  703. } else {
  704. // 产业无报告, 则为新产业
  705. labelMap[iid] = true
  706. }
  707. }
  708. return
  709. }
  710. // GetSpecialDetailUserPower 处理用户查看专项调研详情的权限
  711. func GetActivityDetailUserPower(user *models.WxUserItem, activityInfo *models.ActivityDetail) (havePower bool, err error) {
  712. var companyDetailStatus string
  713. userType, permissionStr, e := GetUserType(user.CompanyId)
  714. if e != nil {
  715. err = errors.New("GetCompanyPermissionUpgrade, Err: " + e.Error())
  716. return
  717. }
  718. if user.CompanyId <= 1 {
  719. return
  720. } else {
  721. if permissionStr == "" {
  722. return
  723. } else {
  724. companyDetail, e := models.GetCompanyDetailById(user.CompanyId)
  725. if e != nil {
  726. err = errors.New("GetCompanyPermissionUpgrade, Err: " + e.Error())
  727. return
  728. }
  729. if companyDetail == nil {
  730. err = errors.New("客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId))
  731. return
  732. }
  733. companyDetailStatus = companyDetail.Status
  734. }
  735. }
  736. if activityInfo.ChartPermissionId == 1 {
  737. havePower = true
  738. return
  739. }
  740. if (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 3) && strings.Contains(permissionStr, "专家") && activityInfo.LimitPeopleNum == 0 {
  741. havePower = true
  742. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "正式" && strings.Contains(activityInfo.CustomerTypeIds, "4") {
  743. havePower = true
  744. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "试用" && strings.Contains(activityInfo.CustomerTypeIds, "5") {
  745. havePower = true
  746. } else if (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 3 || activityInfo.ActivityTypeId == 4 || activityInfo.ActivityTypeId == 5) && strings.Contains(permissionStr, "专家") {
  747. havePower = true
  748. }
  749. if activityInfo.ActivityTypeId == 2 || activityInfo.ActivityTypeId == 6 || activityInfo.ActivityTypeId == 7 {
  750. if strings.Contains(permissionStr, activityInfo.ChartPermissionName+"(主观)") {
  751. havePower = true
  752. }
  753. } else {
  754. if strings.Contains(permissionStr, activityInfo.ChartPermissionName+"(客观)") {
  755. havePower = true
  756. }
  757. }
  758. if (strings.Contains(activityInfo.ChartPermissionName, "研选") || activityInfo.ChartPermissionName == "策略") && strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  759. havePower = true
  760. }
  761. //如果是易董的活动且属于研选类型,只要开通任何权限就可以查看详情
  762. if activityInfo.YidongActivityId != "" && permissionStr != "" && strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  763. havePower = true
  764. }
  765. if havePower && activityInfo.LimitPeopleNum > 0 {
  766. //对于一些特殊的活动,即使权限满足也不给产看
  767. noPower, e := GetShareNoPowe(activityInfo, permissionStr, userType, user)
  768. if e != nil {
  769. err = errors.New("GetShareNoPowe, Err: " + e.Error())
  770. return
  771. }
  772. if noPower {
  773. havePower = false
  774. }
  775. }
  776. return
  777. }
  778. // 校验被分享的用户是否有查看详情的权限
  779. func GetShareNoPowe(activityInfo *models.ActivityDetail, permissionStr string, userType int, user *models.WxUserItem) (noPower bool, err error) {
  780. //如果是弘则的就不进行可见权限校验
  781. if user.CompanyId == utils.HZ_COMPANY_ID {
  782. return
  783. }
  784. if (userType == 1 || userType == 4 || userType == 5) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(userType)) {
  785. noPower = true
  786. }
  787. //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //3、分行业套餐客户(开通对应行业的正式客户) //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户
  788. if userType == 2 && strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(2)) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(4)) {
  789. noPower = true
  790. }
  791. if userType == 2 && !strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(2)) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) {
  792. noPower = true
  793. }
  794. if userType == 3 && strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(4)) {
  795. noPower = true
  796. }
  797. if userType == 3 && !strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) {
  798. noPower = true
  799. }
  800. if !noPower {
  801. noPower, err = CheckUserPowerByActivityChoose(user, activityInfo)
  802. }
  803. return
  804. }
  805. // 处理活动本组们是否决策人权限
  806. func CheckUserPowerByActivityChoose(user *models.WxUserItem, activityInfo *models.ActivityDetail) (noPower bool, err error) {
  807. //处理 见范围 1,仅本组可见 、2,全部客户可见
  808. if activityInfo.VisibleRange == 1 {
  809. adminIds, errAdmin := models.GetSelleridWhichGroup(user.CompanyId, 2)
  810. if errAdmin != nil {
  811. err = errAdmin
  812. return
  813. }
  814. sliceAdminIds := strings.Split(adminIds, ",")
  815. var haveAdminId bool
  816. for _, v := range sliceAdminIds {
  817. if v == strconv.Itoa(activityInfo.AdminId) {
  818. haveAdminId = true
  819. }
  820. }
  821. if !haveAdminId {
  822. noPower = true
  823. }
  824. }
  825. //处理 是否仅决策人可见 0,否 、1,是
  826. if activityInfo.IsMakerShow == 1 {
  827. if user.IsMaker == 0 {
  828. noPower = true
  829. }
  830. }
  831. return
  832. }
  833. // 判断预约纪要按钮是否显示
  834. func IsShowAppointment(activityTypeId int, chartPermissionName string) (isShowAppointment bool) {
  835. if activityTypeId == 1 || activityTypeId == 2 || activityTypeId == 3 || activityTypeId == 4 {
  836. isShowAppointment = true
  837. }
  838. if activityTypeId == 5 && chartPermissionName == "医药" {
  839. isShowAppointment = true
  840. }
  841. return
  842. }
  843. // GetindustryVideoDetailById 通过视频ID获取视频详情
  844. func GetActivityVideoDetailById(user *models.WxUserItem, videoId int) (industryVideo *models.CygxActivityVideoDetailResp, AuthInfo *models.UserPermissionAuthInfo, err error) {
  845. total, e := models.GetActivityVideoByVideoIdCount(videoId)
  846. if e != nil {
  847. err = errors.New("获取活动的视频失败,GetActivityVideoByVideoIdCount " + e.Error())
  848. return
  849. }
  850. if total == 0 {
  851. err = errors.New("视频不存在,或已取消发布")
  852. return
  853. }
  854. // 用户权限
  855. authInfo, permissionArr, e := GetUserRaiPermissionInfo(user.UserId, user.CompanyId)
  856. if e != nil {
  857. err = errors.New("获取用户权限失败,GetUserRaiPermissionInfo " + e.Error())
  858. return
  859. }
  860. videoSimple := new(models.CygxActivityVideoDetailResp)
  861. // 权限
  862. var au *models.UserPermissionAuthInfo
  863. videoSimple, e = models.GetCygxActivityVideoById(videoId)
  864. if e != nil {
  865. err = errors.New("获取产业关联的视频失败,GetMicroRoadshowVideoByIndustryId " + e.Error())
  866. return
  867. } else {
  868. //videoSimple.Id = video.Id
  869. //videoSimple.Title = video.Title
  870. //videoSimple.ResourceUrl = video.ResourceUrl
  871. //videoSimple.PlaySeconds = video.PlaySeconds
  872. //videoSimple.ActivityId = video.ActivityId
  873. //videoSimple.ChartPermissionId = video.ChartPermissionId
  874. if videoSimple.BackgroundImg == "" {
  875. // 获取默认图配置
  876. _, videoMap, _, _, e := GetMicroRoadShowDefaultImgConfig()
  877. if e != nil {
  878. err = errors.New("获取视频默认配置图失败,GetMicroRoadshowVideoByIndustryId " + e.Error())
  879. return
  880. }
  881. videoSimple.BackgroundImg = videoMap[videoSimple.ChartPermissionId]
  882. }
  883. au = new(models.UserPermissionAuthInfo)
  884. au.SellerName = authInfo.SellerName
  885. au.SellerMobile = authInfo.SellerMobile
  886. au.HasPermission = authInfo.HasPermission
  887. au.OperationMode = authInfo.OperationMode
  888. if au.HasPermission == 1 {
  889. // 非宏观权限进一步判断是否有权限
  890. if videoSimple.ChartPermissionId != utils.HONG_GUAN_ID && !utils.InArrayByStr(permissionArr, videoSimple.ChartPermissionName) {
  891. au.HasPermission = 2
  892. }
  893. }
  894. // 无权限的弹框提示
  895. if au.HasPermission != 1 {
  896. if au.OperationMode == UserPermissionOperationModeCall {
  897. au.PopupMsg = UserPermissionPopupMsgCallMicroVideo
  898. } else {
  899. au.PopupMsg = UserPermissionPopupMsgApplyMicroVideo
  900. }
  901. videoSimple.ResourceUrl = ""
  902. }
  903. }
  904. industryVideo = videoSimple
  905. AuthInfo = au
  906. return
  907. }