activity.go 46 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312
  1. package services
  2. import (
  3. "errors"
  4. "fmt"
  5. "hongze/hongze_mfyx/models"
  6. "hongze/hongze_mfyx/utils"
  7. "strconv"
  8. "strings"
  9. "time"
  10. )
  11. // 获取 用户类型 //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //3、分行业套餐客户(开通对应行业的正式客户) //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户;6、冻结客户;7、流失客户
  12. func GetUserType(companyId int) (userType int, permissionStrnew string, err error) {
  13. var permissionStr, permissionZhengShiStr string
  14. if companyId <= 1 {
  15. userType = 0
  16. } else {
  17. total, errs := models.GetCountCompanyDetailByIdGroup(companyId)
  18. if errs != nil {
  19. err = errs
  20. return
  21. }
  22. if total == 0 {
  23. userType = 0
  24. } else {
  25. companyDetail, errs := models.GetCompanyDetailByIdGroup(companyId)
  26. if errs != nil {
  27. err = errs
  28. return
  29. }
  30. permissionStr, errs = models.GetCompanyPermission(companyId)
  31. if errs != nil {
  32. err = errs
  33. return
  34. }
  35. permissionStrnew = permissionStr
  36. //大套餐客户,数据库添加标识,
  37. companyUserTypeDetail, errs := models.GetCygxCompanyUserType(companyId)
  38. if errs != nil && errs.Error() != utils.ErrNoRow() {
  39. err = errs
  40. return
  41. }
  42. if companyUserTypeDetail != nil {
  43. if companyUserTypeDetail.CustomerTypeId != 0 {
  44. userType = companyUserTypeDetail.CustomerTypeId
  45. return
  46. }
  47. }
  48. permissionZhengShiStr, errs = models.GetCompanyPermissionByUserZhengShi(companyId)
  49. if errs != nil {
  50. err = errs
  51. return
  52. }
  53. //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //3、分行业套餐客户(开通对应行业的正式客户) //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户、 10: 30W套餐客户
  54. //大套餐客户定义:医药、消费、科技、智造、策略。5个行业中任意4个及以上是正式权限的,属于大套餐客户(医药、消费、科技、智造需要主客观都开)
  55. if companyDetail.Status == "永续" {
  56. userType = 1
  57. } else if companyDetail.Status == "试用" {
  58. userType = 5
  59. } else if companyDetail.Status == "冻结" {
  60. userType = 6
  61. } else if companyDetail.Status == "流失" {
  62. userType = 7
  63. }
  64. //大套餐客户定义:医药、消费、科技、智造、策略。5个行业中任意4个及以上是正式权限的,属于大套餐客户(医药、消费、科技、智造需要主客观都开)
  65. if userType == 0 && companyDetail.Status == "正式" {
  66. var permissionZhegnshiNum int
  67. if strings.Count(permissionZhengShiStr, "医药") == 2 {
  68. permissionZhegnshiNum++
  69. }
  70. if strings.Count(permissionZhengShiStr, "消费") == 2 {
  71. permissionZhegnshiNum++
  72. }
  73. if strings.Count(permissionZhengShiStr, "科技") == 2 {
  74. permissionZhegnshiNum++
  75. }
  76. if strings.Count(permissionZhengShiStr, "智造") == 2 {
  77. permissionZhegnshiNum++
  78. }
  79. if strings.Count(permissionZhengShiStr, "策略") == 1 {
  80. permissionZhegnshiNum++
  81. }
  82. if strings.Count(permissionZhengShiStr, "路演服务") == 1 {
  83. permissionZhegnshiNum++
  84. }
  85. //if permissionZhegnshiNum == 6 {
  86. // userType = 2
  87. //} else
  88. //大套餐客户,数据库添加标识,条件大于等于四的都是 30W套餐客户
  89. if permissionZhegnshiNum >= 4 {
  90. userType = 10
  91. } else {
  92. userType = 3
  93. }
  94. }
  95. }
  96. }
  97. permissionStrnew = permissionStr
  98. return
  99. }
  100. func GetUserTypeZhengShi(companyId int) (userType int, permissionStrnew, permissionStrZhengShinew string, err error) {
  101. var permissionStr, permissionZhengShiStr string
  102. if companyId <= 1 {
  103. userType = 0
  104. } else {
  105. total, errs := models.GetCountCompanyDetailByIdGroup(companyId)
  106. if errs != nil {
  107. err = errs
  108. return
  109. }
  110. if total == 0 {
  111. userType = 0
  112. } else {
  113. companyDetail, errs := models.GetCompanyDetailByIdGroup(companyId)
  114. if errs != nil {
  115. err = errs
  116. return
  117. }
  118. permissionStr, errs = models.GetCompanyPermission(companyId)
  119. if errs != nil {
  120. err = errs
  121. return
  122. }
  123. permissionStrnew = permissionStr
  124. permissionZhengShiStr, errs = models.GetCompanyPermissionByUserZhengShi(companyId)
  125. if errs != nil {
  126. err = errs
  127. return
  128. }
  129. permissionStrZhengShinew = permissionZhengShiStr
  130. //大套餐客户,数据库添加标识,
  131. companyUserTypeDetail, errs := models.GetCygxCompanyUserType(companyId)
  132. if errs != nil && errs.Error() != utils.ErrNoRow() {
  133. err = errs
  134. return
  135. }
  136. if companyUserTypeDetail != nil {
  137. if companyUserTypeDetail.CustomerTypeId != 0 {
  138. userType = companyUserTypeDetail.CustomerTypeId
  139. return
  140. }
  141. }
  142. //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //3、分行业套餐客户(开通对应行业的正式客户) //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户、 10: 30W套餐客户
  143. //大套餐客户定义:医药、消费、科技、智造、策略。5个行业中任意4个及以上是正式权限的,属于大套餐客户(医药、消费、科技、智造需要主客观都开)
  144. if companyDetail.Status == "永续" {
  145. userType = 1
  146. } else if companyDetail.Status == "试用" {
  147. userType = 5
  148. } else if companyDetail.Status == "冻结" {
  149. userType = 6
  150. } else if companyDetail.Status == "流失" {
  151. userType = 7
  152. }
  153. //大套餐客户定义:医药、消费、科技、智造、策略。5个行业中任意4个及以上是正式权限的,属于大套餐客户(医药、消费、科技、智造需要主客观都开)
  154. if userType == 0 && companyDetail.Status == "正式" {
  155. var permissionZhegnshiNum int
  156. if strings.Count(permissionZhengShiStr, "医药") == 2 {
  157. permissionZhegnshiNum++
  158. }
  159. if strings.Count(permissionZhengShiStr, "消费") == 2 {
  160. permissionZhegnshiNum++
  161. }
  162. if strings.Count(permissionZhengShiStr, "科技") == 2 {
  163. permissionZhegnshiNum++
  164. }
  165. if strings.Count(permissionZhengShiStr, "智造") == 2 {
  166. permissionZhegnshiNum++
  167. }
  168. if strings.Count(permissionZhengShiStr, "策略") == 1 {
  169. permissionZhegnshiNum++
  170. }
  171. if strings.Count(permissionZhengShiStr, "路演服务") == 1 {
  172. permissionZhegnshiNum++
  173. }
  174. //if permissionZhegnshiNum == 6 {
  175. // userType = 2
  176. //} else
  177. //大套餐客户,数据库添加标识,条件大于等于四的都是 30W套餐客户
  178. if permissionZhegnshiNum >= 4 {
  179. userType = 10
  180. } else {
  181. userType = 3
  182. }
  183. }
  184. }
  185. }
  186. permissionStrnew = permissionStr
  187. permissionStrZhengShinew = permissionZhengShiStr
  188. return
  189. }
  190. // GetSpecialDetailUserPower 处理用户查看详情的权限
  191. func GetActivityDetailUserPower(user *models.WxUserItem, activityInfo *models.ActivityDetail) (havePower, isResearchSpecial bool, err error) {
  192. var companyDetailStatus string
  193. var userTypeStr string
  194. userId := user.UserId
  195. activityId := activityInfo.ActivityId
  196. activityPointsByUserAllMap := GetActivityPointsByUserAllMap() // 获取对用户进行研选扣点的活动
  197. //勾选【研选扣点】且扣点对象为参会人的活动,需要有买方研选的正式权限
  198. if strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) && activityPointsByUserAllMap[activityInfo.ActivityId] {
  199. isResearchSpecial = true
  200. }
  201. //如果是弘则的用户或者宏观的权限不做校验
  202. //if (GetBelongingRai(user.Mobile) && user.CompanyId == utils.HZ_COMPANY_ID) || activityInfo.ChartPermissionName == utils.HONG_GUAN_NAME {
  203. if GetBelongingRai(user.Mobile) && user.CompanyId == utils.HZ_COMPANY_ID {
  204. havePower = true
  205. return
  206. }
  207. if (!activityInfo.IsResearchPoints && activityInfo.IsLimitPeople == 0) || activityInfo.YidongActivityId != "" { //易董的活动 或者(不扣点且不限制人数)走月卡日卡逻辑
  208. //用户是否持有有效卡片
  209. userCardTotal := GetCygxOrderUserCardTotal(user.Mobile)
  210. if userCardTotal == 1 {
  211. havePower = true
  212. return
  213. }
  214. } else {
  215. activtyPayTotal := GetCygxOrderVirtualAssetdCountTotal(user.Mobile, activityId)
  216. if activtyPayTotal == 1 {
  217. havePower = true
  218. return
  219. }
  220. }
  221. userType, permissionStr, permissionStrZhengShi, e := GetUserTypeZhengShi(user.CompanyId)
  222. if e != nil {
  223. err = errors.New("GetCompanyPermissionUpgrade, Err: " + e.Error())
  224. return
  225. }
  226. //判断用户是否开通了个人研选权限,如果有权限后缀拼接权限名称
  227. //判断用户是否开通了个人研选权限,如果有权限后缀拼接权限名称
  228. mfyxUserPermissionTotal := GetMfyxUserPermissionTotal(userId)
  229. if mfyxUserPermissionTotal == 1 {
  230. permissionStr += "," + utils.CHART_PERMISSION_NAME_MF_YANXUAN
  231. }
  232. //如果正式权限有开通 研选扣点包 ,那么就拼接一个 研选订阅的权限
  233. if strings.Contains(permissionStrZhengShi, utils.YAN_XUAN_KOU_DIAN_BAO_NAME) {
  234. permissionStr += "," + utils.CHART_PERMISSION_NAME_MF_YANXUAN
  235. permissionStrZhengShi += "," + utils.CHART_PERMISSION_NAME_MF_YANXUAN
  236. }
  237. //如果测试权限有开通 研选扣点包 ,那么就拼接一个 研选订阅的权限
  238. if strings.Contains(permissionStr, utils.YAN_XUAN_KOU_DIAN_BAO_NAME) {
  239. permissionStr += "," + utils.CHART_PERMISSION_NAME_MF_YANXUAN
  240. }
  241. //如果一个权限都没有就返回无权限
  242. if permissionStr == "" {
  243. return
  244. }
  245. //永续客户,无法查看研选权限,但是下面的联系人,单独开通研选后,也可以查看研选内容
  246. if userType == 1 && strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) && mfyxUserPermissionTotal == 0 {
  247. havePower = false
  248. return
  249. }
  250. permissionStr += "," + utils.HONG_GUAN_NAME // 添加一个宏观权限
  251. if permissionStrZhengShi == "" {
  252. permissionStrZhengShi = utils.HONG_GUAN_NAME // 添加一个宏观权限
  253. } else {
  254. permissionStrZhengShi += "," + utils.HONG_GUAN_NAME // 添加一个宏观权限
  255. }
  256. //如果是易董的活动,主、副权限有一个满足即可
  257. if activityInfo.YidongActivityId != "" {
  258. if strings.Contains(permissionStr, activityInfo.ChartPermissionName) || strings.Contains(permissionStr, activityInfo.ChartPermissionNameDeputy) {
  259. havePower = true
  260. return
  261. }
  262. }
  263. //如果权限不包含那么直接返回
  264. if !strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  265. return
  266. }
  267. //如果是 对用户的研选扣点的必须要有研选的正式权限
  268. if activityInfo.IsResearchPoints {
  269. //获取活动对用户要扣的点
  270. userPointsNum, e := models.GetCygxActivityPointsSetUserNum(activityInfo.ActivityId)
  271. if e != nil {
  272. err = errors.New("GetActivitySignupSuccessByUserCountNoHz, Err: " + e.Error())
  273. return
  274. }
  275. if userPointsNum > 0 {
  276. //if !strings.Contains(permissionStr, utils.CHART_PERMISSION_NAME_YANXUAN) {
  277. // //如果连试用权限都没有,那么久按照普通的研选样式展示
  278. // isResearchSpecial = false
  279. //}
  280. if !strings.Contains(permissionStrZhengShi, activityInfo.ChartPermissionName) {
  281. havePower = false
  282. return
  283. }
  284. }
  285. }
  286. //处理决策人可见权限
  287. if user.IsMaker == 0 && activityInfo.IsMakerShow == 1 {
  288. havePower = false
  289. return
  290. }
  291. // 处理本组可见权限
  292. if activityInfo.VisibleRange == 1 {
  293. adminIds, e := models.GetSelleridWhichGroup(user.CompanyId, 2)
  294. if e != nil {
  295. err = errors.New("GetSelleridWhichGroup, Err: " + e.Error())
  296. return
  297. }
  298. haveVisibleRange := false
  299. adminIdSlice := strings.Split(adminIds, ",")
  300. for _, v := range adminIdSlice {
  301. if v == strconv.Itoa(activityInfo.AdminId) {
  302. haveVisibleRange = true
  303. }
  304. }
  305. if !haveVisibleRange {
  306. havePower = false
  307. return
  308. }
  309. }
  310. if permissionStr == "" {
  311. return
  312. }
  313. //如果是易董的活动且属于研选类型,只要开通任何权限就可以查看详情
  314. if activityInfo.YidongActivityId != "" && permissionStr != "" && strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  315. havePower = true
  316. return
  317. }
  318. //医药消费,科技,智造四大行业,验证主客观。如果主客观校验不通过,那么直接返回
  319. if strings.Contains(utils.YI_YAO_NAME+utils.XIAO_FEI_NAME+utils.KE_JI_NAME+utils.ZHI_ZAO_NAME, activityInfo.ChartPermissionName) {
  320. if activityInfo.ActivityTypeId == 2 || activityInfo.ActivityTypeId == 6 || activityInfo.ActivityTypeId == 7 {
  321. if strings.Contains(permissionStr, activityInfo.ChartPermissionName+"(主观)") {
  322. havePower = true
  323. } else {
  324. havePower = false
  325. }
  326. } else {
  327. if strings.Contains(permissionStr, activityInfo.ChartPermissionName+"(客观)") {
  328. havePower = true
  329. } else {
  330. havePower = false
  331. }
  332. }
  333. if !havePower {
  334. return
  335. }
  336. }
  337. if activityInfo.LimitPeopleNum > 0 {
  338. mapUserType, e := GetActivityCcustomerTypeList()
  339. if e != nil {
  340. err = e
  341. return
  342. }
  343. userTypeStr = mapUserType[userType]
  344. // 永续客户、大套餐客户、30W套餐客户可以查看行业升级套餐客户 权限
  345. if userTypeStr == "1" || userTypeStr == "2" || userTypeStr == "AA" {
  346. if strings.Contains(activityInfo.CustomerTypeIds, userTypeStr) && strings.Contains(activityInfo.CustomerTypeIds, "8") {
  347. havePower = true
  348. //return
  349. }
  350. }
  351. } else {
  352. if strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  353. havePower = true
  354. return
  355. }
  356. }
  357. //判断管理规模是否满足
  358. companyProduct, e := models.GetCompanyProductDetail(user.CompanyId, 2)
  359. if e != nil {
  360. err = e
  361. return
  362. }
  363. if companyProduct != nil && activityInfo.Scale != "" {
  364. if strings.Contains(activityInfo.Scale, companyProduct.Scale) {
  365. havePower = true
  366. }
  367. }
  368. if user.CompanyId <= 1 {
  369. return
  370. } else {
  371. if permissionStr == "" {
  372. return
  373. } else {
  374. companyDetail, e := models.GetCompanyDetailById(user.CompanyId)
  375. if e != nil {
  376. err = errors.New("GetCompanyPermissionUpgrade, Err: " + e.Error())
  377. return
  378. }
  379. if companyDetail == nil {
  380. err = errors.New("客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId))
  381. return
  382. }
  383. companyDetailStatus = companyDetail.Status
  384. }
  385. }
  386. //宏观满足用户可见身份验证权限既满足 2023-9-18
  387. if activityInfo.ChartPermissionId == 1 {
  388. if activityInfo.LimitPeopleNum > 0 {
  389. if strings.Contains(activityInfo.CustomerTypeIds, userTypeStr) {
  390. havePower = true
  391. return
  392. }
  393. } else {
  394. havePower = true
  395. return
  396. }
  397. }
  398. if (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 3) && strings.Contains(permissionStr, "专家") && activityInfo.LimitPeopleNum == 0 {
  399. havePower = true
  400. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "正式" && strings.Contains(activityInfo.CustomerTypeIds, "4") {
  401. havePower = true
  402. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "试用" && strings.Contains(activityInfo.CustomerTypeIds, "5") {
  403. havePower = true
  404. } else if (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 3 || activityInfo.ActivityTypeId == 4 || activityInfo.ActivityTypeId == 5) && strings.Contains(permissionStr, "专家") {
  405. havePower = true
  406. }
  407. fmt.Println(permissionStrZhengShi)
  408. //if (strings.Contains(activityInfo.ChartPermissionName, "研选") || activityInfo.ChartPermissionName == "策略") && strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  409. // havePower = true
  410. // return
  411. //}
  412. if strings.Contains(activityInfo.ChartPermissionName, "研选") || activityInfo.ChartPermissionName == "策略" {
  413. if strings.Contains(activityInfo.CustomerTypeIds, "5") {
  414. if strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  415. havePower = true
  416. return
  417. }
  418. } else {
  419. if strings.Contains(permissionStrZhengShi, activityInfo.ChartPermissionName) {
  420. havePower = true
  421. return
  422. }
  423. }
  424. }
  425. permissionShengji, errs := models.GetCompanyPermissionByUserTrip(user.CompanyId)
  426. if errs != nil {
  427. err = errs
  428. return
  429. }
  430. //fmt.Println("主客观2", havePower)
  431. //if strings.Contains(permissionStr, activityInfo.ChartPermissionName) && strings.Contains(activityInfo.CustomerTypeIds, userTypeStr) {
  432. // havePower = true
  433. //}
  434. //fmt.Println("主客观3", havePower)
  435. //处理升级权限以及用户身份的 双重判断
  436. if activityInfo.CustomerTypeIds != "" {
  437. if !strings.Contains(activityInfo.CustomerTypeIds, userTypeStr) && userTypeStr != "8" {
  438. havePower = false
  439. if strings.Contains(permissionShengji, activityInfo.ChartPermissionName) && strings.Contains(activityInfo.CustomerTypeIds, "8") {
  440. havePower = true
  441. }
  442. }
  443. }
  444. if havePower && activityInfo.LimitPeopleNum > 0 {
  445. //对于一些特殊的活动,即使权限满足也不给产看
  446. noPower, e := GetShareNoPowe(activityInfo, permissionStr, userType, user)
  447. if e != nil {
  448. err = errors.New("GetShareNoPowe, Err: " + e.Error())
  449. return
  450. }
  451. if noPower {
  452. havePower = false
  453. }
  454. }
  455. return
  456. }
  457. // 校验被分享的用户是否有查看详情的权限
  458. func GetShareNoPowe(activityInfo *models.ActivityDetail, permissionStr string, userType int, user *models.WxUserItem) (noPower bool, err error) {
  459. //如果是弘则的就不进行可见权限校验
  460. if user.CompanyId == utils.HZ_COMPANY_ID {
  461. return
  462. }
  463. //var noPower bool
  464. //if !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(userType)) {
  465. // noPower = true
  466. //}
  467. //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //3、分行业套餐客户(开通对应行业的正式客户) //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户
  468. //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)) {
  469. // noPower = true
  470. //}
  471. //if userType == 2 && !strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(2)) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) {
  472. // noPower = true
  473. //}
  474. //if userType == 3 && strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(4)) {
  475. // noPower = true
  476. //}
  477. //if userType == 3 && !strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) {
  478. // noPower = true
  479. //}
  480. fmt.Println(userType)
  481. if userType == 8 {
  482. permissionShengji, errs := models.GetCompanyPermissionByUserZhengShiTrip(user.CompanyId)
  483. if errs != nil {
  484. err = errs
  485. return
  486. }
  487. if !strings.Contains(permissionShengji, activityInfo.ChartPermissionName) {
  488. noPower = true
  489. return
  490. }
  491. }
  492. if !noPower {
  493. noPower, err = CheckUserPowerByActivityChoose(user, activityInfo)
  494. }
  495. return
  496. }
  497. // 处理活动本组们是否决策人权限
  498. func CheckUserPowerByActivityChoose(user *models.WxUserItem, activityInfo *models.ActivityDetail) (noPower bool, err error) {
  499. //处理 见范围 1,仅本组可见 、2,全部客户可见
  500. if activityInfo.VisibleRange == 1 {
  501. adminIds, errAdmin := models.GetSelleridWhichGroup(user.CompanyId, 2)
  502. if errAdmin != nil {
  503. err = errAdmin
  504. return
  505. }
  506. sliceAdminIds := strings.Split(adminIds, ",")
  507. var haveAdminId bool
  508. for _, v := range sliceAdminIds {
  509. if v == strconv.Itoa(activityInfo.AdminId) {
  510. haveAdminId = true
  511. }
  512. }
  513. if !haveAdminId {
  514. noPower = true
  515. }
  516. }
  517. //处理 是否仅决策人可见 0,否 、1,是
  518. if activityInfo.IsMakerShow == 1 {
  519. if user.IsMaker == 0 {
  520. noPower = true
  521. }
  522. }
  523. return
  524. }
  525. // 根据用户身份处理活动可见
  526. func ActivityConditioninitSql(user *models.WxUserItem, condition string, isPower int) (conditionActivity string, err error) {
  527. condition += " AND IF ( art.is_limit_people = 1 , art.customer_type_ids != '' ,1=1 ) "
  528. //未登录的用户也可以查看所有活动v12.2.1
  529. if user.UserId == 0 {
  530. conditionActivity = ` AND art.publish_status = 1 AND art.yidong_activity_id = '' ` + condition
  531. return
  532. }
  533. // cygx_10.9 未绑定联系方式的客户可以看到部分活动
  534. if user.UserId == 0 || user.CompanyId == 1 {
  535. conditionActivity = ` AND art.publish_status = 1 AND art.visible_range != 1 AND (art.is_limit_people = 0 OR (art.is_limit_people=1 AND art.is_all_customer_type=1)) ` + condition
  536. return
  537. }
  538. condition += ` AND art.publish_status = 1 `
  539. conditionActivity = condition
  540. //弘则可以查看所有活动
  541. if (GetBelongingRai(user.Mobile) && user.CompanyId == utils.HZ_COMPANY_ID) || user.UserId == 0 {
  542. return
  543. }
  544. adminIds, err := models.GetSelleridWhichGroup(user.CompanyId, 2)
  545. if err != nil {
  546. return
  547. }
  548. userType, permissionStr, permissionStrZhengShi, err := GetUserTypeZhengShi(user.CompanyId)
  549. if err != nil {
  550. return
  551. }
  552. //判断客户规模是否属于可见范围的活动
  553. companyProduct, err := models.GetCompanyProductDetail(user.CompanyId, 2)
  554. if err != nil && err.Error() != utils.ErrNoRow() {
  555. return
  556. }
  557. isMaker := user.IsMaker
  558. slicePer := strings.Split(permissionStr, ",")
  559. var permissionSqlStr string
  560. var permissionNameStr string
  561. for _, v := range slicePer {
  562. if userType == 1 {
  563. //研选权限处理
  564. if !strings.Contains(v, utils.CHART_PERMISSION_NAME_YANXUAN) {
  565. permissionNameStr += "'" + v + "',"
  566. }
  567. } else {
  568. permissionNameStr += "'" + v + "',"
  569. }
  570. }
  571. permissionNameStr = strings.Replace(permissionNameStr, "(主观)", "", -1)
  572. permissionNameStr = strings.Replace(permissionNameStr, "(客观)", "", -1)
  573. permissionNameStr = strings.TrimRight(permissionNameStr, ",")
  574. slicePerZhengShi := strings.Split(permissionStrZhengShi, ",")
  575. var permissionNameStrZhengShi string
  576. for _, v := range slicePerZhengShi {
  577. if userType == 1 {
  578. //研选权限处理
  579. if !strings.Contains(v, utils.CHART_PERMISSION_NAME_YANXUAN) {
  580. permissionNameStrZhengShi += "'" + v + "',"
  581. }
  582. } else {
  583. permissionNameStrZhengShi += "'" + v + "',"
  584. }
  585. }
  586. permissionNameStrZhengShi = strings.Replace(permissionNameStrZhengShi, "(主观)", "", -1)
  587. permissionNameStrZhengShi = strings.Replace(permissionNameStrZhengShi, "(客观)", "", -1)
  588. permissionNameStrZhengShi = strings.TrimRight(permissionNameStrZhengShi, ",")
  589. mapUserType, e := GetActivityCcustomerTypeList()
  590. if e != nil {
  591. err = e
  592. return
  593. }
  594. var userTypeStr string
  595. userTypeStr = mapUserType[userType]
  596. // 查研观向7.4-始终查询宏观的权限(无论是否有权限)
  597. if permissionNameStr == `` {
  598. permissionNameStr = `'宏观'`
  599. } else {
  600. permissionNameStr += `, '宏观'`
  601. }
  602. var sqlExport string // 专家权限处理
  603. sqlExport = ` AND (art.customer_type_ids LIKE '%` + userTypeStr + `%' `
  604. if (userType == 2 || userType == 3) && strings.Contains(permissionStr, "专家") {
  605. sqlExport += ` OR art.customer_type_ids LIKE '%4%' `
  606. }
  607. sqlExport += `) `
  608. if isPower == 1 {
  609. //permissionSqlStr = ` AND art.chart_permission_name IN (` + permissionNameStr + `)`
  610. //condition += permissionSqlStr
  611. }
  612. var conditionOr string
  613. //查询全部可见的数据(是否全部客户可见)
  614. if adminIds != "" {
  615. condition += ` AND ( art.visible_range != 1 OR ( art.admin_id IN ( ` + adminIds + ` ) AND art.visible_range = 1 )) `
  616. }
  617. //活动仅决策人可见
  618. if isMaker == 0 {
  619. condition += ` AND art.is_maker_show = 0 `
  620. }
  621. //condition += ` AND art.visible_range != 1 `
  622. if (userType == 2 || userType == 3 || userType == 4) && strings.Contains(permissionStr, "专家") {
  623. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%4%' ` + condition + `) `
  624. }
  625. if (userType == 5) && strings.Contains(permissionStr, "专家") {
  626. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%5%' ` + condition + `) `
  627. }
  628. if userType == 1 {
  629. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + permissionSqlStr + `) `
  630. } else {
  631. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + `) `
  632. }
  633. if userType == 6 || userType == 7 {
  634. conditionOr += ` OR ( art.customer_type_ids LIKE '%` + strconv.Itoa(userType) + `%' ` + condition + `) `
  635. }
  636. if companyProduct != nil {
  637. if companyProduct.Scale != "" {
  638. conditionOr += ` OR ( art.scale LIKE '%` + companyProduct.Scale + `%' ` + condition + `) `
  639. }
  640. }
  641. //if userType == 3 {
  642. // condition += ` AND art.chart_permission_name IN (` + permissionNameStrZhengShi + `) `
  643. //}
  644. condition += ` AND art.is_limit_people = 1 `
  645. conditionActivity = condition + permissionSqlStr + sqlExport + conditionOr
  646. return
  647. }
  648. // 活动标签字符串处理
  649. func LabelStr(label string) (labelNew string) {
  650. slicebr := strings.Split(label, "-")
  651. if len(slicebr) < 2 {
  652. labelNew = label
  653. } else {
  654. labelNew = slicebr[1]
  655. }
  656. return labelNew
  657. }
  658. // 判断预约纪要按钮是否显示
  659. func IsShowAppointment(activityTypeId int, chartPermissionName string) (isShowAppointment bool) {
  660. if activityTypeId == 1 || activityTypeId == 2 || activityTypeId == 3 || activityTypeId == 4 {
  661. isShowAppointment = true
  662. }
  663. if activityTypeId == 5 && chartPermissionName == "医药" {
  664. isShowAppointment = true
  665. }
  666. return
  667. }
  668. // 用户报告操作行为,模板消息推送 (先放在活动模块下,避免代码冲突)
  669. func ArticleUserRemind(user *models.WxUserItem, articleDetail *models.ArticleDetail, source int) (err error) {
  670. defer func() {
  671. if err != nil {
  672. go utils.SendAlarmMsg(" 用户报告操作行为,模板消息推送失败"+fmt.Sprint("UserId:", user.UserId, "ArticleId:", articleDetail.ArticleId), 2)
  673. }
  674. }()
  675. countUser, err := models.GetUserRemind(user.UserId)
  676. if err != nil {
  677. return err
  678. }
  679. if countUser == 0 {
  680. return err
  681. }
  682. var sourceMsg string
  683. if source == 1 {
  684. sourceMsg = "阅读报告"
  685. } else {
  686. sourceMsg = "收藏报告"
  687. }
  688. //获取销售手机号
  689. sellerItemQy, err := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
  690. if err != nil && err.Error() != utils.ErrNoRow() {
  691. return err
  692. }
  693. if sellerItemQy != nil {
  694. articleId := articleDetail.ArticleId
  695. openIdList, e := models.GetWxOpenIdByMobileList(sellerItemQy.Mobile)
  696. if err != nil {
  697. err = errors.New("GetWxOpenIdByMobileList, Err: " + e.Error())
  698. return err
  699. }
  700. var keyword1 string
  701. var keyword2 string
  702. keyword1 = articleDetail.Title
  703. keyword2 = fmt.Sprint("互动:", sourceMsg, ",", user.RealName, "--", user.CompanyName)
  704. SendWxMsgWithArticleUserRemind(keyword1, keyword2, openIdList, articleDetail.ArticleId)
  705. if articleDetail.ArticleTypeId > 0 {
  706. // 类目模版买方研选
  707. openIdListMfyx, e := models.GetMfyxWxOpenIdByMobileList(sellerItemQy.Mobile)
  708. if e != nil {
  709. err = errors.New("GetMfyxWxOpenIdByMobileList, Err: " + e.Error())
  710. return err
  711. }
  712. var redirectUrl string
  713. keyword1 = utils.TruncateActivityNameString(user.RealName + "-" + user.CompanyName)
  714. keyword2 = fmt.Sprint("互动提醒:", sourceMsg)
  715. keyword3 := utils.TruncateActivityNameString(articleDetail.Title)
  716. keyword4 := time.Now().Format(utils.FormatDateTimeMinute2)
  717. redirectUrl = utils.WX_MSG_PATH_YX_ARTICLE_DETAIL + strconv.Itoa(articleId)
  718. SendWxCategoryMsgWithActivityUserRemind(keyword1, keyword2, keyword3, keyword4, redirectUrl, openIdListMfyx, articleId)
  719. }
  720. }
  721. return
  722. }
  723. // 用户活动操作行为,模板消息推送
  724. func ActivityUserRemind(user *models.WxUserItem, activityDetail *models.ActivityDetail, source int) (err error) {
  725. defer func() {
  726. if err != nil {
  727. go utils.SendAlarmMsg(" 用户活动操作行为,模板消息推送失败"+fmt.Sprint("UserId:", user.UserId, "ActivityId:", activityDetail.ActivityId), 2)
  728. }
  729. }()
  730. //获取销售手机号
  731. countUser, e := models.GetUserRemind(user.UserId)
  732. if e != nil {
  733. err = errors.New("GetUserRemind, Err: " + e.Error())
  734. return
  735. }
  736. //获取销售手机号
  737. sellerItemQy, e := models.GetSellerByCompanyIdCheckFicc(user.CompanyId, 2)
  738. if e != nil && e.Error() != utils.ErrNoRow() {
  739. err = errors.New("GetSellerByCompanyIdCheckFicc, Err: " + e.Error())
  740. return
  741. }
  742. if sellerItemQy == nil {
  743. err = nil
  744. return
  745. }
  746. //某销售下的所有客户活动报名/预约外呼时,模板消息提醒该销售(可设置销售范围,随时增减销售)
  747. conf, e := models.GetConfigByCode("tpl_msg_seller_mobile")
  748. if e != nil {
  749. err = errors.New("GetConfigByCode, Err: " + e.Error())
  750. return
  751. }
  752. //如果用户没有设置消息提醒,而且销售的手机号也没有添加到配置中,那么就不推送模版消息
  753. if countUser == 0 && !strings.Contains(conf.ConfigValue, sellerItemQy.Mobile) {
  754. err = nil
  755. return
  756. }
  757. var sourceMsg string
  758. var redirectUrl string
  759. if source == 1 {
  760. sourceMsg = "预约外呼"
  761. } else if source == 2 {
  762. sourceMsg = "设置会议提醒"
  763. } else if source == 3 {
  764. sourceMsg = "预约纪要"
  765. } else if source == 4 {
  766. sourceMsg = "活动报名"
  767. }
  768. openIdList, e := models.GetWxOpenIdByMobileList(sellerItemQy.Mobile)
  769. if e != nil {
  770. err = errors.New("GetUserRecordListByMobile, Err: " + e.Error())
  771. return err
  772. }
  773. var keyword1 string
  774. var keyword2 string
  775. keyword1 = activityDetail.ActivityName
  776. keyword2 = fmt.Sprint("互动:", sourceMsg, ",", user.RealName, "--", user.CompanyName)
  777. SendWxMsgWithActivityUserRemind(keyword1, keyword2, openIdList, activityDetail.ActivityId)
  778. // 买方研选类目模版
  779. openIdListMfyx, e := models.GetMfyxWxOpenIdByMobileList(sellerItemQy.Mobile)
  780. keyword1 = utils.TruncateActivityNameString(user.RealName + "-" + user.CompanyName)
  781. keyword2 = fmt.Sprint("互动提醒:", sourceMsg)
  782. keyword3 := utils.TruncateActivityNameString(activityDetail.ActivityName)
  783. keyword4 := time.Now().Format(utils.FormatDateTimeMinute2)
  784. redirectUrl = utils.WX_MSG_PATH_YX_ACTIVITY_DETAIL + strconv.Itoa(activityDetail.ActivityId)
  785. SendWxCategoryMsgWithActivityUserRemind(keyword1, keyword2, keyword3, keyword4, redirectUrl, openIdListMfyx, activityDetail.ActivityId)
  786. return
  787. }
  788. func ActivityButtonShow(item *models.ActivityDetail) (activityDetail *models.ActivityDetail) {
  789. if item.ChartPermissionId == utils.CHART_PERMISSION_ID_YANXUAN {
  790. item.IsResearch = true
  791. }
  792. activityDetail = item
  793. //IsShowAppointment bool `description:"是否展示预约纪要"`
  794. //IsShowOutboundCall bool `description:"是否展示预约外呼"`
  795. //IsShowMeetingReminder bool `description:"是否展示会议提醒"`
  796. //IsShowHelpSsk bool `description:"是否展示帮我带问"`
  797. //IsShowSignup bool `description:"是否展示我要报名"`
  798. activityTypeIdMap := GetActivityTypeIdMap()
  799. activityDetail.ActivityType = activityTypeIdMap[activityDetail.ActivityTypeId] // 线上还是线下
  800. activityPointsByUserAllMap := GetActivityPointsByUserAllMap() // 获取对用户进行研选扣点的活动
  801. activityDetail.IsResearchPoints = activityPointsByUserAllMap[activityDetail.ActivityId]
  802. if activityDetail.SiginupDeadline == utils.FormatDateTimeInit { //报名截止时间处理
  803. activityDetail.SiginupDeadline = ""
  804. }
  805. //如果报名截止时间不规范,或者是非研选扣点活动就把截止时间设置为空
  806. if activityDetail.CancelDeadline == utils.FormatDateTimeInit || !activityDetail.IsResearchPoints {
  807. activityDetail.CancelDeadline = ""
  808. }
  809. activityTimeText := activityDetail.ActivityTimeText
  810. activityTimeText = strings.Replace(activityTimeText, "(", "(", -1)
  811. activityTimeText = strings.Replace(activityTimeText, ")", ")", -1)
  812. activityDetail.ActivityTimeText = activityTimeText
  813. if activityDetail.SourceType != 2 {
  814. activityDetail.SourceType = 1
  815. }
  816. activityDetail.IsShowAppointment = false
  817. //易董的操作按钮都隐藏
  818. if activityDetail.YidongActivityId != "" {
  819. activityDetail.SourceType = 1
  820. activityDetail.IsShowSignup = false
  821. activityDetail.IsShowDetails = true
  822. activityDetail.IsExternalLabel = true
  823. activityDetail.IsResearch = false
  824. activityDetail.IsResearchSpecial = false
  825. return
  826. }
  827. //专家电话会 1
  828. if activityDetail.ActivityTypeId == 1 && activityDetail.IsLimitPeople == 0 && (activityDetail.ActiveState == "1" || activityDetail.ActiveState == "2") {
  829. activityDetail.IsShowHelpSsk = true
  830. }
  831. //新的是否展示规则
  832. if activityDetail.IsCanAppointmentMinutes == 1 {
  833. activityDetail.IsShowAppointment = true
  834. } else {
  835. activityDetail.IsShowAppointment = false
  836. }
  837. if activityDetail.ActiveState == "1" {
  838. //专家电话会 1
  839. //专家电话会限制人数的展示我要报名,不限制的展示预约外外呼
  840. if activityDetail.ActivityTypeId == 1 {
  841. //articleDetail.IsShowOutboundCall = true
  842. if activityDetail.LimitPeopleNum == 0 {
  843. activityDetail.IsShowOutboundCall = true
  844. //articleDetail.IsShowHelpSsk = true
  845. } else {
  846. activityDetail.IsShowSignup = true
  847. }
  848. activityDetail.IsShowMeetingReminder = true
  849. activityDetail.IsShowHelpSsk = true
  850. }
  851. //分析师电话会 2
  852. if activityDetail.ActivityTypeId == 2 {
  853. if activityDetail.LimitPeopleNum == 0 {
  854. activityDetail.IsShowOutboundCall = true
  855. //articleDetail.IsShowHelpSsk = true
  856. } else {
  857. activityDetail.IsShowSignup = true
  858. }
  859. activityDetail.IsShowMeetingReminder = true
  860. }
  861. //公司调研电话会 3
  862. if activityDetail.ActivityTypeId == 3 {
  863. if activityDetail.IsResearchPoints || activityDetail.LimitPeopleNum > 0 {
  864. activityDetail.IsShowSignup = true
  865. } else {
  866. activityDetail.IsShowMeetingReminder = true
  867. activityDetail.IsShowOutboundCall = true
  868. }
  869. }
  870. //公司线下调研 4
  871. if activityDetail.ActivityTypeId == 4 {
  872. activityDetail.IsShowSignup = true
  873. }
  874. //专家线下沙龙 5
  875. if activityDetail.ActivityTypeId == 5 {
  876. activityDetail.IsShowSignup = true
  877. }
  878. //分析师线下沙龙 6
  879. if activityDetail.ActivityTypeId == 6 {
  880. activityDetail.IsShowSignup = true
  881. }
  882. //分析师电话会(C类) 7
  883. if activityDetail.ActivityTypeId == 7 {
  884. activityDetail.IsShowSignup = true
  885. activityDetail.IsShowMeetingReminder = true
  886. activityDetail.ActivityTypeName = "分析师电话会"
  887. }
  888. //买方线下交流 8 // 查研观向 11.0
  889. if activityDetail.ActivityTypeId == 8 {
  890. activityDetail.IsShowSignup = true
  891. }
  892. }
  893. //如果是易董创建的活动,展示我要报名,不展示预约外呼
  894. if activityDetail.IsYidongConduct {
  895. activityDetail.IsShowSignup = true
  896. activityDetail.IsShowOutboundCall = false
  897. }
  898. return
  899. }
  900. func ActivityArrButtonShow(items []*models.ActivityDetail) (activityDetails []*models.ActivityDetail) {
  901. activityPointsByUserAllMap := GetActivityPointsByUserAllMap() // 获取对用户进行研选扣点的活动
  902. activityTypeIdMap := GetActivityTypeIdMap()
  903. for _, activityDetail := range items {
  904. activityDetail.ActivityType = activityTypeIdMap[activityDetail.ActivityTypeId] // 线上还是线下
  905. if activityDetail.ChartPermissionId == utils.CHART_PERMISSION_ID_YANXUAN {
  906. activityDetail.IsResearch = true
  907. }
  908. //勾选【研选扣点】且扣点对象为参会人的活动,需要有买方研选的正式权限
  909. if strings.Contains(activityDetail.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) && activityPointsByUserAllMap[activityDetail.ActivityId] {
  910. activityDetail.IsResearchSpecial = true
  911. }
  912. //IsShowAppointment bool `description:"是否展示预约纪要"`
  913. //IsShowOutboundCall bool `description:"是否展示预约外呼"`
  914. //IsShowMeetingReminder bool `description:"是否展示会议提醒"`
  915. //IsShowHelpSsk bool `description:"是否展示帮我带问"`
  916. //IsShowSignup bool `description:"是否展示我要报名"`
  917. activityDetail.IsResearchPoints = activityPointsByUserAllMap[activityDetail.ActivityId]
  918. if activityDetail.SiginupDeadline == utils.FormatDateTimeInit { //报名截止时间处理
  919. activityDetail.SiginupDeadline = ""
  920. }
  921. //如果报名截止时间不规范,或者是非研选扣点活动就把截止时间设置为空
  922. if activityDetail.CancelDeadline == utils.FormatDateTimeInit || !activityDetail.IsResearchPoints {
  923. activityDetail.CancelDeadline = ""
  924. }
  925. activityTimeText := activityDetail.ActivityTimeText
  926. activityTimeText = strings.Replace(activityTimeText, "(", "(", -1)
  927. activityTimeText = strings.Replace(activityTimeText, ")", ")", -1)
  928. activityDetail.ActivityTimeText = activityTimeText
  929. if activityDetail.SourceType != 2 {
  930. activityDetail.SourceType = 1
  931. }
  932. activityDetail.IsShowAppointment = false
  933. //易董的操作按钮都隐藏
  934. if activityDetail.YidongActivityId != "" {
  935. activityDetail.SourceType = 1
  936. activityDetail.IsShowSignup = false
  937. activityDetail.IsShowDetails = true
  938. } else {
  939. //专家电话会 1
  940. if activityDetail.ActivityTypeId == 1 && activityDetail.IsLimitPeople == 0 && (activityDetail.ActiveState == "1" || activityDetail.ActiveState == "2") {
  941. activityDetail.IsShowHelpSsk = true
  942. }
  943. //新的是否展示规则
  944. if activityDetail.IsCanAppointmentMinutes == 1 {
  945. activityDetail.IsShowAppointment = true
  946. } else {
  947. activityDetail.IsShowAppointment = false
  948. }
  949. if activityDetail.ActiveState == "1" {
  950. //专家电话会 1
  951. //专家电话会限制人数的展示我要报名,不限制的展示预约外外呼
  952. if activityDetail.ActivityTypeId == 1 {
  953. //articleDetail.IsShowOutboundCall = true
  954. if activityDetail.LimitPeopleNum == 0 {
  955. activityDetail.IsShowOutboundCall = true
  956. //articleDetail.IsShowHelpSsk = true
  957. } else {
  958. activityDetail.IsShowSignup = true
  959. }
  960. activityDetail.IsShowMeetingReminder = true
  961. activityDetail.IsShowHelpSsk = true
  962. }
  963. //分析师电话会 2
  964. if activityDetail.ActivityTypeId == 2 {
  965. if activityDetail.LimitPeopleNum == 0 {
  966. activityDetail.IsShowOutboundCall = true
  967. //articleDetail.IsShowHelpSsk = true
  968. } else {
  969. activityDetail.IsShowSignup = true
  970. }
  971. activityDetail.IsShowMeetingReminder = true
  972. }
  973. //公司调研电话会 3
  974. if activityDetail.ActivityTypeId == 3 {
  975. if activityDetail.IsResearchPoints || activityDetail.LimitPeopleNum > 0 {
  976. activityDetail.IsShowSignup = true
  977. } else {
  978. activityDetail.IsShowMeetingReminder = true
  979. activityDetail.IsShowOutboundCall = true
  980. }
  981. }
  982. //公司线下调研 4
  983. if activityDetail.ActivityTypeId == 4 {
  984. activityDetail.IsShowSignup = true
  985. }
  986. //专家线下沙龙 5
  987. if activityDetail.ActivityTypeId == 5 {
  988. activityDetail.IsShowSignup = true
  989. }
  990. //分析师线下沙龙 6
  991. if activityDetail.ActivityTypeId == 6 {
  992. activityDetail.IsShowSignup = true
  993. }
  994. //分析师电话会(C类) 7
  995. if activityDetail.ActivityTypeId == 7 {
  996. activityDetail.IsShowSignup = true
  997. activityDetail.IsShowMeetingReminder = true
  998. activityDetail.ActivityTypeName = "分析师电话会"
  999. }
  1000. //买方线下交流 8 // 查研观向 11.0
  1001. if activityDetail.ActivityTypeId == 8 {
  1002. activityDetail.IsShowSignup = true
  1003. }
  1004. }
  1005. //如果是易董创建的活动,展示我要报名,不展示预约外呼
  1006. if activityDetail.IsYidongConduct {
  1007. activityDetail.IsShowSignup = true
  1008. activityDetail.IsShowOutboundCall = false
  1009. }
  1010. }
  1011. //如果是易董同步过来的,只展示外部资源标签
  1012. if activityDetail.YidongActivityId != "" {
  1013. activityDetail.IsExternalLabel = true
  1014. activityDetail.IsResearch = false
  1015. activityDetail.IsResearchSpecial = false
  1016. }
  1017. if activityDetail.ActivityTypeName == "买方线下交流" {
  1018. activityDetail.LabelKeyword = utils.LABEL_L1_2
  1019. activityDetail.LabelKeywordImgLink = utils.LABEL_ICO_1
  1020. }
  1021. if activityDetail.ActivityTypeName == "专家电话会" || activityDetail.ActivityTypeName == "专家线下沙龙" {
  1022. activityDetail.LabelKeyword = utils.LABEL_L1_3
  1023. activityDetail.LabelKeywordImgLink = utils.LABEL_ICO_2
  1024. }
  1025. if activityDetail.ActivityTypeName == "公司调研电话会" {
  1026. activityDetail.LabelKeyword = utils.LABEL_L1_4
  1027. activityDetail.LabelKeywordImgLink = utils.LABEL_ICO_3
  1028. }
  1029. activityDetails = append(activityDetails, activityDetail)
  1030. }
  1031. return
  1032. }
  1033. // GetActivityNewLabelMap 获取活动【新】标签Map
  1034. func GetActivityNewLabelMap(activityIds []int) (labelMap map[int]bool, industryNewMap map[int]bool, err error) {
  1035. labelMap = make(map[int]bool, 0)
  1036. industryNewMap = make(map[int]bool, 0)
  1037. if len(activityIds) == 0 {
  1038. return
  1039. }
  1040. // 获取活动关联的产业
  1041. var groupCond string
  1042. var groupPars []interface{}
  1043. groupCond += ` AND a.activity_id IN (` + utils.GetOrmInReplace(len(activityIds)) + `) AND b.source = 1 `
  1044. groupPars = append(groupPars, activityIds)
  1045. groups, e := models.GetActivityIndustryRelationList(groupCond, groupPars)
  1046. if e != nil {
  1047. err = errors.New("获取活动产业关联列表失败, Err: " + e.Error())
  1048. return
  1049. }
  1050. activityIndustryMap := make(map[int][]int, 0)
  1051. industryIds := make([]int, 0)
  1052. for i := range groups {
  1053. industryIds = append(industryIds, groups[i].IndustrialManagementId)
  1054. activityIndustryMap[groups[i].ActivityId] = append(activityIndustryMap[groups[i].ActivityId], groups[i].IndustrialManagementId)
  1055. }
  1056. // 获取新产业Map
  1057. industryLabelMap, e := GetIndustryNewLabelMap(industryIds)
  1058. if e != nil {
  1059. err = errors.New("获取产业新标签Map失败, Err: " + e.Error())
  1060. return
  1061. }
  1062. // 判断活动是否为新
  1063. for k := range industryLabelMap {
  1064. for k2, v2 := range activityIndustryMap {
  1065. if labelMap[k2] {
  1066. continue
  1067. }
  1068. // 活动的产业ID中存在一个新产业即为新活动
  1069. if utils.InArrayByInt(v2, k) {
  1070. labelMap[k2] = true
  1071. }
  1072. }
  1073. }
  1074. ////产业关联的弘则报告发布日期在三个月以内的活动、产业显示 NEW标签
  1075. //articNewLabel, e := GetArticNewLabelWhithActivity3Month()
  1076. //if e != nil {
  1077. // err = errors.New("获取产业新标签Map失败, Err: " + e.Error())
  1078. // return
  1079. //}
  1080. //for k := range articNewLabel {
  1081. // labelMap[k] = true
  1082. //}
  1083. return
  1084. }
  1085. // GetActivityVoiceResp 处理活动音频回放
  1086. func GetActivityVoiceResp(mapActivityId []int) (mapItem map[int]*models.CygxActivityVoiceReq, err error) {
  1087. activityVoiceList, err := models.GetCygxActivityVoiceReqList(mapActivityId)
  1088. if err != nil && err.Error() != utils.ErrNoRow() {
  1089. return
  1090. }
  1091. mapActivityVoice := make(map[int]*models.CygxActivityVoiceReq)
  1092. if len(activityVoiceList) > 0 {
  1093. for _, v := range activityVoiceList {
  1094. mapActivityVoice[v.ActivityId] = v
  1095. }
  1096. }
  1097. mapItem = mapActivityVoice
  1098. return
  1099. }
  1100. // GetActivityVideoResp 处理活动视频频回放
  1101. func GetActivityVideoResp(mapActivityId []int) (mapItem map[int]*models.CygxActivityVideoListResp, err error) {
  1102. var condition string
  1103. var ativityVIdstr string
  1104. for _, v := range mapActivityId {
  1105. ativityVIdstr += strconv.Itoa(v) + ","
  1106. }
  1107. if ativityVIdstr == "" {
  1108. return
  1109. }
  1110. ativityVIdstr = strings.TrimRight(ativityVIdstr, ",")
  1111. condition += ` AND art.activity_id IN (` + ativityVIdstr + `) `
  1112. var pars []interface{}
  1113. //endTime := time.Now().AddDate(0, 0, -30).Format("2006-01-02 15:04:05")
  1114. //condition += ` AND art.activity_time > ? `
  1115. //pars = append(pars, endTime)
  1116. videoList, e := models.GetActivityVideoListAll(condition, pars, 0, 1000)
  1117. if e != nil && e.Error() != utils.ErrNoRow() {
  1118. err = e
  1119. return
  1120. }
  1121. mapActivityVideo := make(map[int]*models.CygxActivityVideoListResp)
  1122. if len(videoList) > 0 {
  1123. for _, v := range videoList {
  1124. mapActivityVideo[v.ActivityId] = v
  1125. }
  1126. }
  1127. mapItem = mapActivityVideo
  1128. return
  1129. }
  1130. // 解析活动填写的报告链接
  1131. func GetActivityReportLinkToArticleList(item *models.ActivityDetail) (items []*models.ActivityArticleResp, err error) {
  1132. reportLink := item.ReportLink
  1133. //处理活动的
  1134. var articleIds []int
  1135. var articleList []string
  1136. if strings.Contains(reportLink, ";") {
  1137. articleList = strings.Split(reportLink, ";")
  1138. } else {
  1139. articleList = strings.Split(reportLink, ";")
  1140. }
  1141. for _, v := range articleList {
  1142. linkList := strings.Split(v, "/")
  1143. if linkList[len(linkList)-1] != "" {
  1144. linkArticleId, _ := strconv.Atoi(linkList[len(linkList)-1])
  1145. articleIds = append(articleIds, linkArticleId)
  1146. }
  1147. }
  1148. lenarticleIds := len(articleIds)
  1149. if lenarticleIds == 0 {
  1150. return
  1151. }
  1152. var condition string
  1153. var pars []interface{}
  1154. pars = make([]interface{}, 0)
  1155. condition = ` AND a.article_id IN (` + utils.GetOrmInReplace(lenarticleIds) + `)`
  1156. pars = append(pars, articleIds)
  1157. listArticle, e := models.GetHomeList(condition, pars, 0, len(articleIds))
  1158. if e != nil {
  1159. err = errors.New("GetResourceDataList, Err: " + e.Error())
  1160. return
  1161. }
  1162. if len(listArticle) > 0 {
  1163. for _, v := range listArticle {
  1164. artItem := new(models.ActivityArticleResp)
  1165. artItem.ArticleId = v.ArticleId
  1166. artItem.Title = v.Title
  1167. items = append(items, artItem)
  1168. }
  1169. }
  1170. return
  1171. }
  1172. // 获取活动线上还是线下的类型
  1173. func GetActivityTypeIdMap() (mapResp map[int]int) {
  1174. var err error
  1175. defer func() {
  1176. if err != nil {
  1177. fmt.Println(err)
  1178. go utils.SendAlarmMsg("获取活动线上还是线下的类型,失败,GetActivityTypeIdMap:Err "+err.Error(), 2)
  1179. }
  1180. }()
  1181. list, e := models.GetActivityTypeList("")
  1182. if e != nil {
  1183. err = errors.New("GetActivityTypeList, Err: " + e.Error())
  1184. return
  1185. }
  1186. mapResp = make(map[int]int, 0)
  1187. for _, v := range list {
  1188. mapResp[v.ActivityTypeId] = v.ActivityType
  1189. }
  1190. return
  1191. }
  1192. // GetYanxuanActivityIds 获取研选活动ID
  1193. func GetYanxuanActivityIds(user *models.WxUserItem, activeState string) (activityIds []int) {
  1194. var err error
  1195. defer func() {
  1196. if err != nil {
  1197. fmt.Println(err)
  1198. go utils.SendAlarmMsg("获取研选活动ID GetYanxuanActivityIds,失败:"+err.Error(), 2)
  1199. }
  1200. }()
  1201. var condition string
  1202. var pars []interface{}
  1203. condition = ` AND chart_permission_id = 31 AND art.publish_status = 1 `
  1204. if activeState != "" {
  1205. condition += ` AND active_state IN (` + activeState + `) `
  1206. }
  1207. //pars = append(pars, utils.CHART_PERMISSION_ID_YANXUAN)
  1208. if user.CompanyId > 1 {
  1209. conditionActivity, e := ActivityConditioninitSql(user, condition, 0)
  1210. if e != nil && e.Error() != utils.ErrNoRow() {
  1211. err = errors.New("ActivityConditioninitSql, Err: " + e.Error())
  1212. return
  1213. }
  1214. condition += conditionActivity
  1215. }
  1216. condition += ` ORDER BY art.activity_time DESC , art.active_state ASC `
  1217. list, e := models.GetCygxActivityList(condition, pars, 0, 2000)
  1218. if e != nil {
  1219. err = errors.New("GetCygxActivityIdList, Err: " + e.Error())
  1220. return
  1221. }
  1222. for _, v := range list {
  1223. activityIds = append(activityIds, v.ActivityId)
  1224. }
  1225. return
  1226. }