activity.go 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745
  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. )
  11. //获取活动列表查询权限的SQL
  12. // @Param ChartPermissionIds query string false "行业id 多个用 , 隔开"
  13. // @Param ActivityTypeIds query string false "活动类型id 多个用 , 隔开"
  14. // @Param ActiveState query string false "活动进行状态 未开始:1、进行中2、已结束3"
  15. // @Param WhichDay query string false "哪一天 今天:1、明天:2,多个用 , 隔开"
  16. // @Param WhichTime query string false "已结束的时间筛选项 本周:1、上周:2 、本月:3、上月:4"
  17. // @Param Label query string false "搜索主题 多个用 , 隔开"
  18. // @Param PlayBack query int false "是否仅展示回放 1:是、0:否 默认0"
  19. // @Param KeyWord query string false "搜索关键词"
  20. func GetActivityonditionList(user *models.WxUserItem, activityTypeId, chartPermissionIds, whichDay, activeState, label string, isPower, source int, keyWord string, playBack int) (conditionActivity string, err error) {
  21. adminIds, err := models.GetSelleridWhichGroup(user.CompanyId, 2)
  22. if err != nil {
  23. return
  24. }
  25. userType, permissionStr, err := GetUserType(user.CompanyId)
  26. if err != nil {
  27. return
  28. }
  29. //判断客户规模是否属于可见范围的活动
  30. companyProduct, err := models.GetCompanyProductDetail(user.CompanyId, 2)
  31. if err != nil && err.Error() != utils.ErrNoRow() {
  32. return
  33. }
  34. isMaker := user.IsMaker
  35. slicePer := strings.Split(permissionStr, ",")
  36. var permissionSqlStr string
  37. var permissionNameStr string
  38. for _, v := range slicePer {
  39. if userType == 1 {
  40. //研选权限处理
  41. if !strings.Contains(v, utils.CHART_PERMISSION_NAME_YANXUAN) {
  42. permissionNameStr += "'" + v + "',"
  43. }
  44. } else {
  45. permissionNameStr += "'" + v + "',"
  46. }
  47. }
  48. permissionNameStr = strings.Replace(permissionNameStr, "(主观)", "", -1)
  49. permissionNameStr = strings.Replace(permissionNameStr, "(客观)", "", -1)
  50. permissionNameStr = strings.TrimRight(permissionNameStr, ",")
  51. // 查研观向7.4-始终查询宏观的权限(无论是否有权限)
  52. if permissionNameStr == `` {
  53. permissionNameStr = `'宏观'`
  54. } else {
  55. permissionNameStr += `, '宏观'`
  56. }
  57. var condition string
  58. var conditionAdmin string
  59. var conditionHz string // 弘则权限处理
  60. var sqlExport string // 专家权限处理
  61. permissionSqlStr = ` AND art.chart_permission_name IN (` + permissionNameStr + `)`
  62. sqlExport = ` AND (art.customer_type_ids LIKE '%` + strconv.Itoa(userType) + `%' `
  63. if userType == 2 {
  64. sqlExport += ` OR art.customer_type_ids LIKE '%3%' `
  65. }
  66. if (userType == 2 || userType == 3) && strings.Contains(permissionStr, "专家") {
  67. sqlExport += ` OR art.customer_type_ids LIKE '%4%' `
  68. }
  69. sqlExport += `) `
  70. // 如果是C类电话会就不展示内容,且合并到分析师电话会
  71. if activityTypeId != "" {
  72. if activityTypeId == strconv.Itoa(utils.ANALYST_TELL_ACTIVITY_TYPE_ID) {
  73. condition = ` AND art.publish_status = 1 AND art.label != '' AND art.activity_type_id IN (` + activityTypeId + "," + strconv.Itoa(utils.C_CLASS_ACTIVITY_TYPE_ID) + `)`
  74. } else {
  75. condition = ` AND art.publish_status = 1 AND art.label != '' AND art.activity_type_id = ` + activityTypeId
  76. }
  77. }
  78. //主题
  79. if label != "" {
  80. condition = ` AND art.label LIKE '%` + label + `%' `
  81. }
  82. if isPower == 1 {
  83. condition += permissionSqlStr
  84. }
  85. //行业名称
  86. if len(chartPermissionIds) > 0 {
  87. condition += ` AND art.chart_permission_id IN (` + chartPermissionIds + `)`
  88. }
  89. //如果是PC的,则不看易董的
  90. if source == 1 {
  91. condition += ` AND art.yidong_activity_id = '' `
  92. }
  93. var conditionOr string
  94. if whichDay != "" {
  95. var startDate string
  96. var endDate string
  97. if whichDay == "1" {
  98. startDate = time.Now().Format(utils.FormatDate)
  99. endDate = startDate
  100. } else if whichDay == "2" {
  101. startDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  102. endDate = startDate
  103. } else {
  104. startDate = time.Now().Format(utils.FormatDate)
  105. endDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  106. }
  107. if whichDay == "3" {
  108. startDate = utils.GetNowWeekMonday().Format(utils.FormatDate)
  109. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  110. } else if whichDay == "4" {
  111. startDate = utils.GetLastWeekMonday().Format(utils.FormatDate)
  112. endDate = utils.GetLastWeekSunday().Format(utils.FormatDate)
  113. } else if whichDay == "5" {
  114. startDate = utils.GetNowMonthFirstDay().Format(utils.FormatDate)
  115. endDate = utils.GetNowMonthLastDay().Format(utils.FormatDate)
  116. } else if whichDay == "6" {
  117. startDate = utils.GetLastMonthFirstDay().Format(utils.FormatDate)
  118. endDate = utils.GetLastMonthLastDay().Format(utils.FormatDate)
  119. } else if whichDay == "3,4" {
  120. startDate = utils.GetLastWeekMonday().Format(utils.FormatDate)
  121. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  122. } else if whichDay == "5,6" {
  123. startDate = utils.GetLastMonthFirstDay().Format(utils.FormatDate)
  124. endDate = utils.GetNowMonthLastDay().Format(utils.FormatDate)
  125. } else {
  126. startDate = utils.GetNowWeekMonday().Format(utils.FormatDate)
  127. endDate = utils.GetNowWeekSunday().Format(utils.FormatDate)
  128. }
  129. condition += ` AND art.activity_time >= ` + "'" + startDate + " 00:00:00'"
  130. condition += ` AND art.activity_time <= ` + "'" + endDate + " 23:59:59'"
  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. condition += ` AND (art.label LIKE '%` + keyWord + `%' OR art.activity_name LIKE '%` + keyWord + `%' ) `
  137. } else {
  138. if activeState != "" {
  139. // 默认查看未开始跟进行中
  140. if activeState == "1" {
  141. condition += ` AND art.active_state IN (1,2)`
  142. } else {
  143. condition += ` AND art.active_state IN (` + activeState + `)`
  144. }
  145. } else {
  146. condition += ` AND art.active_state IN (1,2)`
  147. }
  148. }
  149. if playBack == 1 {
  150. var pars []interface{}
  151. ativityVIdArry := make([]string, 0)
  152. voiceList, e := models.GetActivityVoiceListAll("", pars, 0, 1000)
  153. if e != nil && e.Error() != utils.ErrNoRow() {
  154. err = e
  155. return
  156. }
  157. for _, v := range voiceList {
  158. ativityVIdArry = append(ativityVIdArry, strconv.Itoa(v.ActivityId))
  159. }
  160. videoList, e := models.GetActivityVideoListAll("", pars, 0, 1000)
  161. if e != nil && e.Error() != utils.ErrNoRow() {
  162. err = e
  163. return
  164. }
  165. for _, v := range videoList {
  166. ativityVIdArry = append(ativityVIdArry, strconv.Itoa(v.ActivityId))
  167. }
  168. //活动音频,设置有效时间为30天,失效后该活动就不再支持音频回放。有效期起始时间为活动的开始时间
  169. //endTime := time.Now().AddDate(0, 0, -30).Format("2006-01-02 15:04:05")
  170. //condition += ` AND art.activity_time > '` + endTime + `' `
  171. if len(ativityVIdArry) > 0 {
  172. ativityVIdstr := strings.Join(ativityVIdArry, ",")
  173. condition += ` AND art.activity_id IN (` + ativityVIdstr + `) `
  174. }
  175. }
  176. //查询全部可见的数据(是否全部客户可见)
  177. condition += ` AND art.publish_status = 1 `
  178. conditionHz = condition
  179. //活动仅决策人可见
  180. if isMaker == 0 {
  181. condition += ` AND art.is_maker_show = 0 `
  182. }
  183. conditionAdmin = condition + ` AND art.visible_range = 1 `
  184. condition += ` AND art.visible_range != 1 `
  185. if (userType == 2 || userType == 3 || userType == 4) && strings.Contains(permissionStr, "专家") {
  186. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%4%' ` + condition + `) `
  187. }
  188. if (userType == 5) && strings.Contains(permissionStr, "专家") {
  189. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%5%' ` + condition + `) `
  190. }
  191. if userType == 1 {
  192. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + permissionSqlStr + `) `
  193. } else {
  194. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + `) `
  195. }
  196. if userType == 6 || userType == 7 {
  197. conditionOr += ` OR ( art.customer_type_ids LIKE '%` + strconv.Itoa(userType) + `%' ` + condition + `) `
  198. }
  199. if companyProduct != nil {
  200. if companyProduct.Scale != "" {
  201. conditionOr += ` OR ( art.scale LIKE '%` + companyProduct.Scale + `%' ` + condition + `) `
  202. }
  203. }
  204. if adminIds != "" {
  205. conditionOr += ` OR ( art.customer_type_ids LIKE '%` + strconv.Itoa(userType) + `%' ` + ` AND art.admin_id IN (` + adminIds + `) ` + conditionAdmin + `) `
  206. if companyProduct != nil {
  207. if companyProduct.Scale != "" {
  208. conditionOr += ` OR ( art.scale LIKE '%` + companyProduct.Scale + `%'` + ` AND art.admin_id IN (` + adminIds + `) ` + conditionAdmin + `) `
  209. }
  210. }
  211. }
  212. //弘则研究下的客户不做权限,限制,C类电话会,仅本组销售、部门管理员、admin、权益研究员账号能看到
  213. if user.CompanyId == 16 {
  214. mapMobile, e := GetAdminMobileMap()
  215. if e != nil {
  216. err = e
  217. return
  218. }
  219. if _, ok := mapMobile[user.Mobile]; ok {
  220. conditionOr += ` OR ( art.publish_status = 1 ` + conditionHz + `) `
  221. }
  222. }
  223. conditionActivity = condition + permissionSqlStr + sqlExport + conditionOr
  224. return
  225. }
  226. //获取可见的活动
  227. func HandleActivityPowerList(listActivity []*models.CygxActivity, user *models.WxUserItem) (items []*models.CygxActivity, err error) {
  228. return
  229. }
  230. //5.3版本活动标签字符串处理
  231. func LabelStr(label string, isShowSubjectName int, temporaryLabel string) (labelNew string) {
  232. slicebr := strings.Split(label, "-")
  233. if len(slicebr) > 1 {
  234. if isShowSubjectName == 1 {
  235. labelNew = slicebr[1]
  236. } else {
  237. labelNew = slicebr[0]
  238. }
  239. } else {
  240. labelNew = label
  241. }
  242. if temporaryLabel != "" {
  243. labelNew = temporaryLabel
  244. }
  245. return labelNew
  246. }
  247. //列表
  248. func HandleActivityTypeHomeList(listType []*models.ActivityTypeHome, listActivity []*models.CygxActivity, user *models.WxUserItem) (items []*models.ActivityTypeHome, err error) {
  249. mapActivity := make(map[int][]*models.CygxActivityLabelList)
  250. for _, v := range listActivity {
  251. if v.Label == "" {
  252. continue
  253. }
  254. // 如果是C类电话会就不展示内容,且合并到分析师电话会
  255. if v.ActivityTypeId == 7 {
  256. v.ActivityTypeId = 1
  257. }
  258. item := new(models.CygxActivityLabelList)
  259. item.KeyWord = LabelStr(v.Label, v.IsShowSubjectName, v.TemporaryLabel)
  260. item.Resource = 1
  261. if v.YidongActivityId != "" {
  262. item.IsExternalLabel = true
  263. }
  264. if len(mapActivity[v.ActivityTypeId]) > 10 {
  265. continue
  266. }
  267. mapActivity[v.ActivityTypeId] = append(mapActivity[v.ActivityTypeId], item)
  268. }
  269. for _, v := range listType {
  270. v.Resource = 1
  271. if len(mapActivity[v.ActivityTypeId]) > 0 {
  272. v.List = mapActivity[v.ActivityTypeId]
  273. } else {
  274. v.List = make([]*models.CygxActivityLabelList, 0)
  275. }
  276. }
  277. items = listType
  278. fmt.Println(len(mapActivity))
  279. return
  280. }
  281. //GetActivityVoiceResp 处理活动音频回放
  282. func GetActivityVoiceResp(mapActivityId []int) (mapItem map[int]*models.CygxActivityVoiceReq, err error) {
  283. activityVoiceList, err := models.GetCygxActivityVoiceReqList(mapActivityId)
  284. if err != nil && err.Error() != utils.ErrNoRow() {
  285. return
  286. }
  287. mapActivityVoice := make(map[int]*models.CygxActivityVoiceReq)
  288. if len(activityVoiceList) > 0 {
  289. for _, v := range activityVoiceList {
  290. mapActivityVoice[v.ActivityId] = v
  291. }
  292. }
  293. mapItem = mapActivityVoice
  294. return
  295. }
  296. //GetActivityVideoResp 处理活动视频频回放
  297. func GetActivityVideoResp(mapActivityId []int) (mapItem map[int]*models.CygxActivityVideoListResp, err error) {
  298. var condition string
  299. var ativityVIdstr string
  300. for _, v := range mapActivityId {
  301. ativityVIdstr += strconv.Itoa(v) + ","
  302. }
  303. if ativityVIdstr == "" {
  304. return
  305. }
  306. ativityVIdstr = strings.TrimRight(ativityVIdstr, ",")
  307. condition += ` AND art.activity_id IN (` + ativityVIdstr + `) `
  308. var pars []interface{}
  309. //endTime := time.Now().AddDate(0, 0, -30).Format("2006-01-02 15:04:05")
  310. //condition += ` AND art.activity_time > ? `
  311. //pars = append(pars, endTime)
  312. videoList, e := models.GetActivityVideoListAll(condition, pars, 0, 1000)
  313. if e != nil && e.Error() != utils.ErrNoRow() {
  314. err = e
  315. return
  316. }
  317. mapActivityVideo := make(map[int]*models.CygxActivityVideoListResp)
  318. if len(videoList) > 0 {
  319. for _, v := range videoList {
  320. mapActivityVideo[v.ActivityId] = v
  321. }
  322. }
  323. mapItem = mapActivityVideo
  324. return
  325. }
  326. func ActivityButtonShow(item *models.ActivityDetail) (itemActivity *models.ActivityListResp) {
  327. articleDetail := item
  328. //IsShowAppointment bool `description:"是否展示预约纪要"`
  329. //IsShowOutboundCall bool `description:"是否展示预约外呼"`
  330. //IsShowMeetingReminder bool `description:"是否展示会议提醒"`
  331. //IsShowHelpSsk bool `description:"是否展示帮我带问"`
  332. //IsShowSignup bool `description:"是否展示我要报名"`
  333. activityTimeText := articleDetail.ActivityTimeText
  334. activityTimeText = strings.Replace(activityTimeText, "(", "(", -1)
  335. activityTimeText = strings.Replace(activityTimeText, ")", ")", -1)
  336. articleDetail.ActivityTimeText = activityTimeText
  337. articleDetail.IsShowAppointment = false
  338. //易董的操作按钮都隐藏
  339. if articleDetail.YidongActivityId != "" {
  340. articleDetail.IsShowSignup = false
  341. articleDetail.IsShowDetails = true
  342. } else {
  343. //专家电话会 1
  344. if articleDetail.ActivityTypeId == 1 {
  345. articleDetail.IsShowHelpSsk = true
  346. }
  347. if articleDetail.ActiveState == "1" {
  348. //新的是否展示规则
  349. if articleDetail.IsCanAppointmentMinutes == 1 {
  350. articleDetail.IsShowAppointment = true
  351. }
  352. //专家电话会 1
  353. if articleDetail.ActivityTypeId == 1 {
  354. articleDetail.IsShowOutboundCall = true
  355. articleDetail.IsShowMeetingReminder = true
  356. articleDetail.IsShowHelpSsk = true
  357. }
  358. //分析师电话会 2
  359. if articleDetail.ActivityTypeId == 2 {
  360. articleDetail.IsShowOutboundCall = true
  361. if articleDetail.LimitPeopleNum == 0 {
  362. articleDetail.IsShowMeetingReminder = true
  363. }
  364. }
  365. //公司调研电话会 3
  366. if articleDetail.ActivityTypeId == 3 {
  367. if articleDetail.LimitPeopleNum == 0 {
  368. articleDetail.IsShowMeetingReminder = true
  369. articleDetail.IsShowOutboundCall = true
  370. } else {
  371. articleDetail.IsShowSignup = true
  372. }
  373. }
  374. //公司线下调研 4
  375. if articleDetail.ActivityTypeId == 4 {
  376. articleDetail.IsShowSignup = true
  377. }
  378. //专家线下沙龙 5
  379. if articleDetail.ActivityTypeId == 5 {
  380. articleDetail.IsShowSignup = true
  381. }
  382. //分析师线下沙龙 6
  383. if articleDetail.ActivityTypeId == 6 {
  384. articleDetail.IsShowSignup = true
  385. }
  386. //分析师电话会(C类) 7
  387. if articleDetail.ActivityTypeId == 7 {
  388. articleDetail.IsShowSignup = true
  389. }
  390. }
  391. }
  392. v := articleDetail
  393. itemActivity = &models.ActivityListResp{
  394. ActivityId: v.ActivityId,
  395. ActivityTypeId: v.ActivityTypeId,
  396. ActivityTypeName: v.ActivityTypeName,
  397. ChartPermissionId: v.ChartPermissionId,
  398. ChartPermissionName: v.ChartPermissionName,
  399. IsLimitPeople: v.IsLimitPeople,
  400. LimitPeopleNum: v.LimitPeopleNum,
  401. LastUpdatedTime: v.LastUpdatedTime,
  402. ActivityTime: v.ActivityTime,
  403. ActivityTimeText: v.ActivityTimeText,
  404. DistinguishedGuest: v.DistinguishedGuest,
  405. Host: v.Host,
  406. Speaker: v.Speaker,
  407. MainlandTell: v.MainlandTell,
  408. HongKongTell: v.HongKongTell,
  409. TaiwanTell: v.TaiwanTell,
  410. AmericaTell: v.AmericaTell,
  411. ParticipationCode: v.ParticipationCode,
  412. Theme: v.Theme,
  413. Expert: v.Expert,
  414. ActivityName: v.ActivityName,
  415. OnlineParticipation: v.OnlineParticipation,
  416. ReportLink: v.ReportLink,
  417. City: v.City,
  418. Address: v.Address,
  419. Highlights: v.Highlights,
  420. Remarks: v.Remarks,
  421. IsSignup: v.IsSignup,
  422. IsCancelMeetingReminder: v.IsCancelMeetingReminder,
  423. IsAppointment: v.IsAppointment,
  424. ActiveState: v.ActiveState,
  425. IsShowSustainable: v.IsShowSustainable,
  426. Description: v.Description,
  427. IsResearch: v.IsResearch,
  428. IsHideAppointment: v.IsHideAppointment,
  429. IsCClassMeeting: v.IsCClassMeeting,
  430. Label: v.Label,
  431. ImgUrl: v.ImgUrl,
  432. ImgUrlText: v.ImgUrlText,
  433. ActivityType: v.ActivityType,
  434. IsShowOutboundCall: v.IsShowOutboundCall,
  435. IsShowMeetingReminder: v.IsShowMeetingReminder,
  436. IsShowHelpSsk: v.IsShowHelpSsk,
  437. IsShowSignup: v.IsShowSignup,
  438. IsShowAppointment: v.IsShowAppointment,
  439. IsShowDetails: v.IsShowDetails,
  440. AudioLink: v.AudioLink,
  441. VoiceDetail: v.VoiceList,
  442. VideoDetail: v.VideoDetail,
  443. FileType: v.FileType,
  444. SourceType: v.SourceType,
  445. }
  446. return
  447. }
  448. func ActivityDetaailShow(activityInfo *models.ActivityListResp) (itemActivity *models.ActivityListResp, err error) {
  449. itemActivity = activityInfo
  450. if GetShowSustainable() && strings.Contains(itemActivity.ChartPermissionName, "研选") {
  451. itemActivity.IsShowSustainable = true
  452. }
  453. if activityInfo.SignupNum > activityInfo.LimitPeopleNum {
  454. activityInfo.SignupNum = activityInfo.LimitPeopleNum
  455. }
  456. if activityInfo.ReportLink != "" {
  457. artList := strings.Split(activityInfo.ReportLink, "{|}")
  458. if len(artList) > 0 {
  459. for _, v := range artList {
  460. artitem := new(models.ActivityArticleResp)
  461. artitem.ReportLink = v
  462. artIdSlice := strings.Split(v, "/")
  463. if len(artIdSlice) > 0 {
  464. articleId, _ := strconv.Atoi(artIdSlice[len(artIdSlice)-1])
  465. artitem.ArticleId = articleId
  466. }
  467. activityInfo.ArticleList = append(activityInfo.ArticleList, artitem)
  468. }
  469. }
  470. } else {
  471. activityInfo.ArticleList = make([]*models.ActivityArticleResp, 0)
  472. }
  473. activityInfo.ActivityTypeName = strings.Replace(activityInfo.ActivityTypeName, "(C类)", "", -1)
  474. return
  475. }
  476. // GetActivityNewLabelMap 获取活动【新】标签Map
  477. func GetActivityNewLabelMap(activityIds []int) (labelMap map[int]bool, industryNewMap map[int]bool, err error) {
  478. labelMap = make(map[int]bool, 0)
  479. industryNewMap = make(map[int]bool, 0)
  480. if len(activityIds) == 0 {
  481. return
  482. }
  483. // 获取活动关联的产业
  484. var groupCond string
  485. var groupPars []interface{}
  486. groupCond += ` AND a.activity_id IN (` + utils.GetOrmInReplace(len(activityIds)) + `)`
  487. groupPars = append(groupPars, activityIds)
  488. groups, e := models.GetActivityIndustryRelationList(groupCond, groupPars)
  489. if e != nil {
  490. err = errors.New("获取活动产业关联列表失败, Err: " + e.Error())
  491. return
  492. }
  493. activityIndustryMap := make(map[int][]int, 0)
  494. industryIds := make([]int, 0)
  495. for i := range groups {
  496. industryIds = append(industryIds, groups[i].IndustrialManagementId)
  497. activityIndustryMap[groups[i].ActivityId] = append(activityIndustryMap[groups[i].ActivityId], groups[i].IndustrialManagementId)
  498. }
  499. // 获取新产业Map
  500. industryLabelMap, e := GetIndustryNewLabelMap(industryIds)
  501. if e != nil {
  502. err = errors.New("获取产业新标签Map失败, Err: " + e.Error())
  503. return
  504. }
  505. // 判断活动是否为新
  506. for k := range industryLabelMap {
  507. for k2, v2 := range activityIndustryMap {
  508. if labelMap[k2] {
  509. continue
  510. }
  511. // 活动的产业ID中存在一个新产业即为新活动
  512. if utils.InArrayByInt(v2, k) {
  513. labelMap[k2] = true
  514. }
  515. }
  516. }
  517. return
  518. }
  519. // GetIndustryNewLabelMap 获取产业【新】标签Map
  520. func GetIndustryNewLabelMap(industryIds []int) (labelMap map[int]bool, err error) {
  521. labelMap = make(map[int]bool, 0)
  522. industryIdLen := len(industryIds)
  523. if industryIdLen == 0 {
  524. return
  525. }
  526. // 获取产业关联的报告最早发布时间及最近的发布时间
  527. var timeCond string
  528. var timePars []interface{}
  529. timeCond += ` AND b.publish_status = 1`
  530. if industryIdLen > 0 {
  531. timeCond += ` AND a.industrial_management_id IN (` + utils.GetOrmInReplace(industryIdLen) + `)`
  532. timePars = append(timePars, industryIds)
  533. }
  534. industryTimeList, e := models.GetIndustryArticleMinMaxPublishTime(timeCond, timePars)
  535. if e != nil {
  536. err = errors.New("获取产业文章最大最小发布时间失败, Err: " + e.Error())
  537. return
  538. }
  539. // 判断产业是否为新
  540. nowTime := time.Now().Local()
  541. threeMonthBefore := nowTime.AddDate(0, -3, 0)
  542. nullTime, _ := time.ParseInLocation(utils.FormatDateTime, "0001-01-01 00:00:00", time.Local)
  543. industryMap := make(map[int]*models.IndustryArticleMinMaxPublishTime, 0)
  544. for i := range industryTimeList {
  545. industryMap[industryTimeList[i].IndustrialManagementId] = industryTimeList[i]
  546. }
  547. for i := range industryIds {
  548. iid := industryIds[i]
  549. item := industryMap[iid]
  550. if item != nil {
  551. // 最早发布时间为空 / 最早发布时间在三个月前之后
  552. if item.MinPublishTime.Equal(nullTime) || (item.MinPublishTime.After(threeMonthBefore)) {
  553. labelMap[iid] = true
  554. }
  555. } else {
  556. // 产业无报告, 则为新产业
  557. labelMap[iid] = true
  558. }
  559. }
  560. return
  561. }
  562. //GetSpecialDetailUserPower 处理用户查看专项调研详情的权限
  563. func GetActivityDetailUserPower(user *models.WxUserItem, activityInfo *models.ActivityDetail) (havePower bool, err error) {
  564. var companyDetailStatus string
  565. userType, permissionStr, e := GetUserType(user.CompanyId)
  566. if e != nil {
  567. err = errors.New("GetCompanyPermissionUpgrade, Err: " + e.Error())
  568. return
  569. }
  570. if user.CompanyId <= 1 {
  571. return
  572. } else {
  573. if permissionStr == "" {
  574. return
  575. } else {
  576. companyDetail, e := models.GetCompanyDetailById(user.CompanyId)
  577. if e != nil {
  578. err = errors.New("GetCompanyPermissionUpgrade, Err: " + e.Error())
  579. return
  580. }
  581. if companyDetail == nil {
  582. err = errors.New("客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId))
  583. return
  584. }
  585. companyDetailStatus = companyDetail.Status
  586. }
  587. }
  588. if activityInfo.ChartPermissionId == 1 {
  589. havePower = true
  590. return
  591. }
  592. if (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 3) && strings.Contains(permissionStr, "专家") && activityInfo.LimitPeopleNum == 0 {
  593. havePower = true
  594. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "正式" && strings.Contains(activityInfo.CustomerTypeIds, "4") {
  595. havePower = true
  596. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "试用" && strings.Contains(activityInfo.CustomerTypeIds, "5") {
  597. havePower = true
  598. } else if (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 3 || activityInfo.ActivityTypeId == 4 || activityInfo.ActivityTypeId == 5) && strings.Contains(permissionStr, "专家") {
  599. havePower = true
  600. }
  601. if activityInfo.ActivityTypeId == 2 || activityInfo.ActivityTypeId == 6 || activityInfo.ActivityTypeId == 7 {
  602. if strings.Contains(permissionStr, activityInfo.ChartPermissionName+"(主观)") {
  603. havePower = true
  604. }
  605. } else {
  606. if strings.Contains(permissionStr, activityInfo.ChartPermissionName+"(客观)") {
  607. havePower = true
  608. }
  609. }
  610. if (strings.Contains(activityInfo.ChartPermissionName, "研选") || activityInfo.ChartPermissionName == "策略") && strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  611. havePower = true
  612. }
  613. //如果是易董的活动且属于研选类型,只要开通任何权限就可以查看详情
  614. if activityInfo.YidongActivityId != "" && permissionStr != "" && strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  615. havePower = true
  616. }
  617. if havePower && activityInfo.LimitPeopleNum > 0 {
  618. //对于一些特殊的活动,即使权限满足也不给产看
  619. noPower, e := GetShareNoPowe(activityInfo, permissionStr, userType, user)
  620. if e != nil {
  621. err = errors.New("GetShareNoPowe, Err: " + e.Error())
  622. return
  623. }
  624. if noPower {
  625. havePower = false
  626. }
  627. }
  628. return
  629. }
  630. // 校验被分享的用户是否有查看详情的权限
  631. func GetShareNoPowe(activityInfo *models.ActivityDetail, permissionStr string, userType int, user *models.WxUserItem) (noPower bool, err error) {
  632. //如果是弘则的就不进行可见权限校验
  633. if user.CompanyId == utils.HZ_COMPANY_ID {
  634. return
  635. }
  636. if (userType == 1 || userType == 4 || userType == 5) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(userType)) {
  637. noPower = true
  638. }
  639. //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //3、分行业套餐客户(开通对应行业的正式客户) //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户
  640. 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)) {
  641. noPower = true
  642. }
  643. if userType == 2 && !strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(2)) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) {
  644. noPower = true
  645. }
  646. if userType == 3 && strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(4)) {
  647. noPower = true
  648. }
  649. if userType == 3 && !strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) {
  650. noPower = true
  651. }
  652. if !noPower {
  653. noPower, err = CheckUserPowerByActivityChoose(user, activityInfo)
  654. }
  655. return
  656. }
  657. //处理活动本组们是否决策人权限
  658. func CheckUserPowerByActivityChoose(user *models.WxUserItem, activityInfo *models.ActivityDetail) (noPower bool, err error) {
  659. //处理 见范围 1,仅本组可见 、2,全部客户可见
  660. if activityInfo.VisibleRange == 1 {
  661. adminIds, errAdmin := models.GetSelleridWhichGroup(user.CompanyId, 2)
  662. if errAdmin != nil {
  663. err = errAdmin
  664. return
  665. }
  666. sliceAdminIds := strings.Split(adminIds, ",")
  667. var haveAdminId bool
  668. for _, v := range sliceAdminIds {
  669. if v == strconv.Itoa(activityInfo.AdminId) {
  670. haveAdminId = true
  671. }
  672. }
  673. if !haveAdminId {
  674. noPower = true
  675. }
  676. }
  677. //处理 是否仅决策人可见 0,否 、1,是
  678. if activityInfo.IsMakerShow == 1 {
  679. if user.IsMaker == 0 {
  680. noPower = true
  681. }
  682. }
  683. return
  684. }
  685. //判断预约纪要按钮是否显示
  686. func IsShowAppointment(activityTypeId int, chartPermissionName string) (isShowAppointment bool) {
  687. if activityTypeId == 1 || activityTypeId == 2 || activityTypeId == 3 || activityTypeId == 4 {
  688. isShowAppointment = true
  689. }
  690. if activityTypeId == 5 && chartPermissionName == "医药" {
  691. isShowAppointment = true
  692. }
  693. return
  694. }