acitvity.go 54 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472
  1. package cygx
  2. import (
  3. "errors"
  4. "fmt"
  5. "github.com/PuerkitoBio/goquery"
  6. "hongze/hz_crm_api/models"
  7. "hongze/hz_crm_api/models/company"
  8. "hongze/hz_crm_api/models/cygx"
  9. "hongze/hz_crm_api/models/system"
  10. "hongze/hz_crm_api/services"
  11. "hongze/hz_crm_api/services/alarm_msg"
  12. "hongze/hz_crm_api/utils"
  13. "html"
  14. "regexp"
  15. "strconv"
  16. "strings"
  17. "time"
  18. )
  19. // 线下活动处理用户爽约限制人数
  20. func AddCygxActivityRestrictSignupByAdmin(activityId int) (err error) {
  21. defer func() {
  22. if err != nil {
  23. fmt.Println("err:", err)
  24. go alarm_msg.SendAlarmMsg("查研观向处理活动用户限制报名失败,Err:"+err.Error(), 3)
  25. }
  26. }()
  27. activityInfo, e := cygx.GetAddActivityInfoById(activityId)
  28. if e != nil {
  29. err = errors.New("GetAddActivityInfoById" + e.Error())
  30. return
  31. }
  32. if activityInfo == nil {
  33. return
  34. }
  35. //不限制报名的不做爽约限制处理
  36. //if activityInfo.IsLimitPeople > 0 {
  37. //total, err := cygx.GetActivitySignupNomeetingCount(activityId)
  38. if err != nil {
  39. return
  40. }
  41. mobileList, _ := cygx.GetUserMeetingMobile(activityId)
  42. var userIdArr []int
  43. if len(mobileList) >= 0 {
  44. for _, v := range mobileList {
  45. userIdArr = append(userIdArr, v.UserId)
  46. }
  47. lenuserIdArr := len(userIdArr)
  48. var condition string
  49. var pars []interface{}
  50. condition = ` AND user_id IN (` + utils.GetOrmInReplace(lenuserIdArr) + `)`
  51. pars = append(pars, userIdArr)
  52. restrictSignupList, e := cygx.GetCygxActivityRestrictSignupList(condition, pars, 0, 9999)
  53. if e != nil {
  54. err = errors.New("GetCygxActivityRestrictSignupList" + e.Error())
  55. return
  56. }
  57. //获取这些用户是否被加入到限制报名了
  58. maptotalRestrict := make(map[int]bool)
  59. for _, v := range restrictSignupList {
  60. maptotalRestrict[v.UserId] = true
  61. }
  62. pars = make([]interface{}, 0)
  63. condition = ` AND a.is_limit_people = 1 AND v.is_meeting = 0 AND v.do_fail_type = 0 AND v.user_id IN (` + utils.GetOrmInReplace(lenuserIdArr) + `)`
  64. pars = append(pars, userIdArr)
  65. listSignup, e := cygx.GetActivitySignupInnerActivityList(condition, pars)
  66. if e != nil && e.Error() != utils.ErrNoRow() {
  67. err = errors.New("GetActivitySignupList" + e.Error())
  68. return
  69. }
  70. mapNomeet := make(map[int]int)
  71. if len(listSignup) > 0 {
  72. for _, v := range listSignup {
  73. mapNomeet[v.UserId]++
  74. }
  75. }
  76. var userIdDelArr []int
  77. for _, v := range mobileList {
  78. //如果加入了爽约限制但是爽约次数少于3条就删除爽约记录
  79. if maptotalRestrict[v.UserId] && mapNomeet[v.UserId] < 3 {
  80. userIdDelArr = append(userIdDelArr, v.UserId)
  81. }
  82. }
  83. if len(userIdDelArr) > 0 {
  84. e = cygx.DeleteCygxActivityRestrictSignupByUserIds(userIdDelArr)
  85. if e != nil {
  86. err = errors.New("DeleteCygxActivityRestrictSignupByUserIds" + e.Error())
  87. return
  88. }
  89. }
  90. }
  91. //if total == 0 {
  92. // return
  93. //}
  94. //}
  95. list, e := cygx.GetActivitySignupNomeetingCountList(activityId)
  96. if e != nil {
  97. err = errors.New("GetActivitySignupNomeetingCountList" + e.Error())
  98. return
  99. }
  100. var userIdSiginArr []int
  101. var items []*cygx.CygxActivitySignupBreak
  102. for _, v := range list {
  103. userIdSiginArr = append(userIdSiginArr, v.UserId)
  104. //添加爽约记录
  105. item := new(cygx.CygxActivitySignupBreak)
  106. item.UserId = v.UserId
  107. item.ActivityId = v.ActivityId
  108. item.CreateTime = time.Now()
  109. item.Mobile = v.Mobile
  110. item.Email = v.Email
  111. item.CompanyId = v.CompanyId
  112. item.CompanyName = v.CompanyName
  113. item.RealName = v.RealName
  114. item.SellerName = v.SellerName
  115. items = append(items, item)
  116. }
  117. if len(list) == 0 {
  118. return
  119. }
  120. var itemsRestrict []*cygx.CygxActivityRestrictSignup
  121. maptotalRestrict := make(map[int]bool)
  122. lenuserIdSiginArr := len(userIdSiginArr)
  123. var condition string
  124. var pars []interface{}
  125. condition = ` AND user_id IN (` + utils.GetOrmInReplace(lenuserIdSiginArr) + `)`
  126. pars = append(pars, userIdSiginArr)
  127. restrictSignupList, e := cygx.GetCygxActivityRestrictSignupList(condition, pars, 0, 9999)
  128. if e != nil {
  129. err = errors.New("GetCygxActivityRestrictSignupList" + e.Error())
  130. return
  131. }
  132. //获取这些用户是否被加入到限制报名了
  133. for _, v := range restrictSignupList {
  134. maptotalRestrict[v.UserId] = true
  135. }
  136. pars = make([]interface{}, 0)
  137. condition = ` AND a.is_limit_people = 1 AND v.is_meeting = 0 AND v.do_fail_type = 0 AND user_id IN (` + utils.GetOrmInReplace(lenuserIdSiginArr) + `)`
  138. pars = append(pars, userIdSiginArr)
  139. listSignup, e := cygx.GetActivitySignupInnerActivityList(condition, pars)
  140. if e != nil && e.Error() != utils.ErrNoRow() {
  141. err = errors.New("GetActivitySignupList" + e.Error())
  142. return
  143. }
  144. mapNomeet := make(map[int]int)
  145. if len(listSignup) > 0 {
  146. for _, v := range listSignup {
  147. mapNomeet[v.UserId]++
  148. }
  149. }
  150. for _, v := range mobileList {
  151. //如果加入了爽约限制但是爽约次数少于3条就删除爽约记录
  152. if !maptotalRestrict[v.UserId] && mapNomeet[v.UserId] >= 3 {
  153. itemRestrict := new(cygx.CygxActivityRestrictSignup)
  154. itemRestrict.UserId = v.UserId
  155. itemRestrict.CreateTime = time.Now()
  156. itemRestrict.Mobile = v.Mobile
  157. itemRestrict.Email = v.Email
  158. itemRestrict.CompanyId = v.CompanyId
  159. itemRestrict.CompanyName = v.CompanyName
  160. itemRestrict.IsRestrict = 1
  161. itemsRestrict = append(itemsRestrict, itemRestrict)
  162. }
  163. }
  164. err = cygx.DeleteCygxActivitySignupBreakById(activityId)
  165. if err != nil {
  166. err = errors.New("DeleteCygxActivitySignupBreakById" + err.Error())
  167. return
  168. }
  169. //添加爽约记录
  170. if len(items) > 0 {
  171. _, e = cygx.AddCygxActivitySignupBreakList(items)
  172. if e != nil {
  173. err = errors.New("AddCygxActivitySignupBreakList, Err: " + e.Error())
  174. return
  175. }
  176. }
  177. //添加报名限制
  178. if len(itemsRestrict) > 0 {
  179. _, e = cygx.AddCygxActivityRestrictSignupList(itemsRestrict)
  180. if e != nil {
  181. err = errors.New("AddCygxActivityRestrictSignupList, Err: " + e.Error())
  182. return
  183. }
  184. }
  185. return
  186. }
  187. func GetReportContentTextSub(content string) (contentSub string, err error) {
  188. content = html.UnescapeString(content)
  189. doc, err := goquery.NewDocumentFromReader(strings.NewReader(content))
  190. docText := doc.Text()
  191. bodyRune := []rune(docText)
  192. bodyRuneLen := len(bodyRune)
  193. if bodyRuneLen > 200 {
  194. bodyRuneLen = 200
  195. }
  196. body := string(bodyRune[:bodyRuneLen])
  197. contentSub = body
  198. return
  199. }
  200. // 富文本字段过滤处理
  201. func GetRichtext(content string) (contentSub string) {
  202. contentSub = strings.Replace(content, "<p data-f-id=\"pbf\" style=\"text-align: center; font-size: 14px; margin-top: 30px; opacity: 0.65; font-family: sans-serif;\">Powered by <a href=\"https://www.froala.com/wysiwyg-editor?pb=1\" title=\"Froala Editor\">Froala Editor</a></p>", "", -1)
  203. return
  204. }
  205. // 校验该用户是否有报名权限
  206. func CheckaddSignuUserPower(companyId, activityId int, activityInfo *cygx.ActivityDetail) (havePower bool) {
  207. havePower = true
  208. companyPermission, _ := cygx.GetCompanyPermission(companyId)
  209. if companyPermission == "" {
  210. havePower = false
  211. return
  212. }
  213. userType, _, permissionStr, companyStatus, _ := GetUserType(companyId)
  214. permissionStr += ",宏观"
  215. if activityInfo.IsLimitPeople > 0 {
  216. noPower, _ := GetShareNoPowe(activityInfo, permissionStr, userType)
  217. if noPower {
  218. havePower = false
  219. //获取用户的产业规模,判断是否允许可见
  220. companyProduct, _ := company.GetCompanyProductByCompanyIdAndProductId(companyId, 2)
  221. if companyProduct.Scale != "" {
  222. if strings.Count(activityInfo.Scale, companyProduct.Scale) > 0 {
  223. havePower = true
  224. }
  225. }
  226. return
  227. }
  228. }
  229. if userType == 1 && strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  230. havePower = false
  231. return
  232. }
  233. havePower = GetHavePower(activityInfo, permissionStr, companyStatus)
  234. return
  235. }
  236. // 校验用户报名的权限
  237. func GetHavePower(activityInfo *cygx.ActivityDetail, permissionStr, companyDetailStatus string) (havePower bool) {
  238. if (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 3) && strings.Contains(permissionStr, "专家") && activityInfo.LimitPeopleNum == "0" {
  239. havePower = true
  240. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "正式" && strings.Contains(activityInfo.CustomerTypeIds, "4") {
  241. havePower = true
  242. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "试用" && strings.Contains(activityInfo.CustomerTypeIds, "5") {
  243. havePower = true
  244. } else if (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 3 || activityInfo.ActivityTypeId == 4 || activityInfo.ActivityTypeId == 5) && strings.Contains(permissionStr, "专家") {
  245. havePower = true
  246. }
  247. if activityInfo.ActivityTypeId == 2 || activityInfo.ActivityTypeId == 6 || activityInfo.ActivityTypeId == 7 {
  248. if strings.Contains(permissionStr, activityInfo.ChartPermissionName+"(主观)") {
  249. havePower = true
  250. }
  251. } else {
  252. if strings.Contains(permissionStr, activityInfo.ChartPermissionName+"(客观)") {
  253. havePower = true
  254. }
  255. }
  256. if (strings.Contains(activityInfo.ChartPermissionName, "研选") || activityInfo.ChartPermissionName == "策略") && strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  257. havePower = true
  258. }
  259. //如果是易董的活动且属于研选类型,只要开通任何权限就可以查看详情
  260. if activityInfo.YidongActivityId != "" && permissionStr != "" && strings.Contains(activityInfo.ChartPermissionName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  261. havePower = true
  262. }
  263. if activityInfo.ChartPermissionName == "宏观" {
  264. havePower = true
  265. }
  266. return
  267. }
  268. // 获取 用户类型 //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //3、分行业套餐客户(开通对应行业的正式客户) //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户
  269. func GetUserType(companyId int) (userType, packageType int, permissionStrnew, companyStatus string, err error) {
  270. var permissionStr, permissionZhengShiStr string
  271. if companyId <= 1 {
  272. userType = 0
  273. } else {
  274. total, errs := cygx.GetCountCompanyDetailByIdGroup(companyId)
  275. if errs != nil {
  276. err = errs
  277. return
  278. }
  279. if total == 0 {
  280. userType = 0
  281. } else {
  282. companyDetail, errs := cygx.GetCompanyDetailByIdGroup(companyId)
  283. if errs != nil {
  284. err = errs
  285. return
  286. }
  287. companyStatus = companyDetail.Status
  288. permissionStr, errs = cygx.GetCompanyPermission(companyId)
  289. if errs != nil {
  290. err = errs
  291. return
  292. }
  293. permissionStrnew = permissionStr
  294. //大套餐客户,数据库添加标识,
  295. companyUserTypeDetail, errs := cygx.GetCygxCompanyUserType(companyId)
  296. if errs != nil && errs.Error() != utils.ErrNoRow() {
  297. err = errs
  298. return
  299. }
  300. if companyUserTypeDetail != nil {
  301. packageType = companyUserTypeDetail.PackageType
  302. if companyUserTypeDetail.CustomerTypeId != 0 {
  303. userType = companyUserTypeDetail.CustomerTypeId
  304. return
  305. }
  306. }
  307. permissionZhengShiStr, errs = cygx.GetCompanyPermissionByUserZhengShi(companyId)
  308. if errs != nil {
  309. err = errs
  310. return
  311. }
  312. //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //3、分行业套餐客户(开通对应行业的正式客户) //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户、 10: 30W套餐客户
  313. //大套餐客户定义:医药、消费、科技、智造、策略。5个行业中任意4个及以上是正式权限的,属于大套餐客户(医药、消费、科技、智造需要主客观都开)
  314. if companyDetail.Status == "永续" {
  315. userType = 1
  316. } else if companyDetail.Status == "试用" {
  317. userType = 5
  318. } else if companyDetail.Status == "冻结" {
  319. userType = 6
  320. } else if companyDetail.Status == "流失" {
  321. userType = 7
  322. }
  323. //大套餐客户定义:医药、消费、科技、智造、策略。5个行业中任意4个及以上是正式权限的,属于大套餐客户(医药、消费、科技、智造需要主客观都开)
  324. if userType == 0 && companyDetail.Status == "正式" {
  325. var permissionZhegnshiNum int
  326. if strings.Count(permissionZhengShiStr, "医药") == 2 {
  327. permissionZhegnshiNum++
  328. }
  329. if strings.Count(permissionZhengShiStr, "消费") == 2 {
  330. permissionZhegnshiNum++
  331. }
  332. if strings.Count(permissionZhengShiStr, "科技") == 2 {
  333. permissionZhegnshiNum++
  334. }
  335. if strings.Count(permissionZhengShiStr, "智造") == 2 {
  336. permissionZhegnshiNum++
  337. }
  338. if strings.Count(permissionZhengShiStr, "策略") == 1 {
  339. permissionZhegnshiNum++
  340. }
  341. if strings.Count(permissionZhengShiStr, "路演服务") == 1 {
  342. permissionZhegnshiNum++
  343. }
  344. //if permissionZhegnshiNum == 6 {
  345. // userType = 2
  346. //} else
  347. //大套餐客户,数据库添加标识,条件大于等于四的都是 30W套餐客户
  348. if permissionZhegnshiNum >= 4 {
  349. userType = 10
  350. } else {
  351. userType = 3
  352. }
  353. }
  354. }
  355. }
  356. permissionStrnew = permissionStr
  357. return
  358. }
  359. func GetUserTypeZhengShi(companyId int) (userType int, permissionStrnew, permissionStrZhengShinew, companyStatus string, err error) {
  360. var permissionStr, permissionZhengShiStr string
  361. if companyId <= 1 {
  362. userType = 0
  363. } else {
  364. total, errs := cygx.GetCountCompanyDetailByIdGroup(companyId)
  365. if errs != nil {
  366. err = errs
  367. return
  368. }
  369. if total == 0 {
  370. userType = 0
  371. } else {
  372. companyDetail, errs := cygx.GetCompanyDetailByIdGroup(companyId)
  373. if errs != nil {
  374. err = errs
  375. return
  376. }
  377. companyStatus = companyDetail.Status
  378. permissionStr, errs = cygx.GetCompanyPermission(companyId)
  379. if errs != nil {
  380. err = errs
  381. return
  382. }
  383. permissionStrnew = permissionStr
  384. permissionZhengShiStr, errs = cygx.GetCompanyPermissionByUserZhengShi(companyId)
  385. if errs != nil {
  386. err = errs
  387. return
  388. }
  389. permissionStrZhengShinew = permissionZhengShiStr
  390. //大套餐客户,数据库添加标识,
  391. companyUserTypeDetail, errs := cygx.GetCygxCompanyUserType(companyId)
  392. if errs != nil && errs.Error() != utils.ErrNoRow() {
  393. err = errs
  394. return
  395. }
  396. if companyUserTypeDetail != nil {
  397. if companyUserTypeDetail.CustomerTypeId != 0 {
  398. userType = companyUserTypeDetail.CustomerTypeId
  399. return
  400. }
  401. }
  402. //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //3、分行业套餐客户(开通对应行业的正式客户) //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户、 10: 30W套餐客户
  403. //大套餐客户定义:医药、消费、科技、智造、策略。5个行业中任意4个及以上是正式权限的,属于大套餐客户(医药、消费、科技、智造需要主客观都开)
  404. if companyDetail.Status == "永续" {
  405. userType = 1
  406. } else if companyDetail.Status == "试用" {
  407. userType = 5
  408. } else if companyDetail.Status == "冻结" {
  409. userType = 6
  410. } else if companyDetail.Status == "流失" {
  411. userType = 7
  412. }
  413. //大套餐客户定义:医药、消费、科技、智造、策略。5个行业中任意4个及以上是正式权限的,属于大套餐客户(医药、消费、科技、智造需要主客观都开)
  414. if userType == 0 && companyDetail.Status == "正式" {
  415. var permissionZhegnshiNum int
  416. if strings.Count(permissionZhengShiStr, "医药") == 2 {
  417. permissionZhegnshiNum++
  418. }
  419. if strings.Count(permissionZhengShiStr, "消费") == 2 {
  420. permissionZhegnshiNum++
  421. }
  422. if strings.Count(permissionZhengShiStr, "科技") == 2 {
  423. permissionZhegnshiNum++
  424. }
  425. if strings.Count(permissionZhengShiStr, "智造") == 2 {
  426. permissionZhegnshiNum++
  427. }
  428. if strings.Count(permissionZhengShiStr, "策略") == 1 {
  429. permissionZhegnshiNum++
  430. }
  431. if strings.Count(permissionZhengShiStr, "路演服务") == 1 {
  432. permissionZhegnshiNum++
  433. }
  434. //if permissionZhegnshiNum == 6 {
  435. // userType = 2
  436. //} else
  437. //大套餐客户,数据库添加标识,条件大于等于四的都是 30W套餐客户
  438. if permissionZhegnshiNum >= 4 {
  439. userType = 10
  440. } else {
  441. userType = 3
  442. }
  443. }
  444. }
  445. }
  446. permissionStrnew = permissionStr
  447. permissionStrZhengShinew = permissionZhengShiStr
  448. return
  449. }
  450. // 校验被分享的用户是否有查看详情的权限
  451. func GetShareNoPowe(activityInfo *cygx.ActivityDetail, permissionStr string, userType int) (noPower bool, err error) {
  452. //var noPower bool
  453. if (userType == 1 || userType == 4 || userType == 5) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(userType)) {
  454. noPower = true
  455. }
  456. //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //3、分行业套餐客户(开通对应行业的正式客户) //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户
  457. 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)) {
  458. noPower = true
  459. }
  460. if userType == 2 && !strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(2)) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) {
  461. noPower = true
  462. }
  463. if userType == 3 && strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(4)) {
  464. noPower = true
  465. }
  466. if userType == 3 && !strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) {
  467. noPower = true
  468. }
  469. return
  470. }
  471. // 校验活动是否可以新增纪要预约
  472. func CheckActivityAddAppointment(activityInfo *cygx.ActivityDetail) (isProhibit bool) {
  473. if (activityInfo.ActivityTypeId == 5 && activityInfo.ChartPermissionName != "医药") || activityInfo.ActivityTypeId == 6 {
  474. isProhibit = true
  475. }
  476. return
  477. }
  478. //// 处理活动取消报名截止时间类型展示
  479. //func ActivityCancelDeadlineType(activityInfo *cygx.ActivityDetail) (cancelDeadlineType int) {
  480. // //CancelDeadlineType int `description:"取消报名截止时间类型,0:不设置,1:24小时之前、2:48小时之前"`
  481. // //如果时间是初始值或者为空,就是默认为0 状态
  482. // if activityInfo.CancelDeadline == "" || activityInfo.CancelDeadline == utils.EmptyDateTimeStr {
  483. // cancelDeadlineType = 0
  484. // return
  485. // }
  486. // activityTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  487. // cancelDeadline := utils.StrTimeToTime(activityInfo.CancelDeadline) //时间字符串格式转时间格式
  488. // hourNum := activityTime.Sub(cancelDeadline).Hours()
  489. // if hourNum == 24 {
  490. // cancelDeadlineType = 1
  491. // }
  492. // if hourNum == 48 {
  493. // cancelDeadlineType = 2
  494. // }
  495. // return
  496. //}
  497. // 解析查研观向的模板内容
  498. func ActivityBodyAnalysis(body string, activeState int, req cygx.ActivityRep) (itemr *cygx.CygxActivity, errstr string) {
  499. item := new(cygx.CygxActivity)
  500. body = strings.Replace(body, "<p data-f-id=\"pbf\" style=\"text-align: center; font-size: 14px; margin-top: 30px; opacity: 0.65; font-family: sans-serif;\">Powered by <a href=\"https://www.froala.com/wysiwyg-editor?pb=1\" title=\"Froala Editor\">Froala Editor</a></p>", "", -1)
  501. //活动地址,活动地点,地点,地址,办会地点,办会地址。对地址字眼进行替换,对上述字段兼容做内容解析
  502. body = strings.Replace(body, "活动地点:", "活动地址:", -1)
  503. body = strings.Replace(body, "地点:", "活动地址:", -1)
  504. body = strings.Replace(body, "地址:", "活动地址:", -1)
  505. body = strings.Replace(body, "办会地点:", "活动地址:", -1)
  506. body = strings.Replace(body, "办会地址:", "活动地址:", -1)
  507. doc, _ := goquery.NewDocumentFromReader(strings.NewReader(body))
  508. doc.Find("p").Each(func(i int, s *goquery.Selection) {
  509. contentTxt := s.Text()
  510. contentTxt = strings.Replace(contentTxt, "\n", "", -1)
  511. //contentTxt = strings.Replace(contentTxt, " ", "", -1)
  512. if strings.Contains(contentTxt, "活动名称:") {
  513. item.ActivityName = strings.Replace(contentTxt, "活动名称:", "", -1)
  514. }
  515. if i == 0 {
  516. item.ActivityName = contentTxt
  517. }
  518. if strings.Contains(contentTxt, "时间:") || strings.Contains(contentTxt, "时间:") {
  519. strText := strings.Replace(contentTxt, "时间:", "", -1)
  520. strText = strings.Replace(strText, "时间:", "", -1)
  521. strText = strings.Replace(strText, "p", "", -1)
  522. strText = strings.Replace(strText, "P", "", -1)
  523. strText = strings.Replace(strText, "m", "", -1)
  524. strText = strings.Replace(strText, "M", "", -1)
  525. strText = strings.Replace(strText, "a", "", -1)
  526. strText = strings.Replace(strText, "A", "", -1)
  527. strText = strings.Replace(strText, " ", "", -1)
  528. item.ActivityTimeText = strText
  529. //var hrefRegexp = regexp.MustCompile("[^\\\\x00-\\\\xff]+")
  530. var hrefRegexp = regexp.MustCompile("[/\\d+/]+")
  531. match := hrefRegexp.FindAllString(strText, -1)
  532. if match != nil {
  533. activityTimeText := item.ActivityTimeText
  534. //timeStr := strings.Replace(strText, match[len(match)-1], " ", -1)
  535. //resultTime := utils.StrTimeToTime(timeStr + ":00") //时间字符串格式转时间格式
  536. if len(match) < 5 {
  537. errstr = "活动时间格式错误"
  538. }
  539. var timeStr string
  540. for k, v := range match {
  541. if k < 2 {
  542. timeStr += v + "-"
  543. } else if k == 2 {
  544. timeStr += v + " "
  545. } else if k <= 4 {
  546. timeStr += v + ":"
  547. }
  548. }
  549. timeStr += "00"
  550. resultTime := utils.StrTimeToTime(timeStr) //时间字符串格式转时间格式
  551. timeStrYmd := resultTime.Format(utils.FormatDate)
  552. timeYmd := utils.StrTimeToTime(timeStrYmd + " 11:59:59") //拼接当天中午12点的时间 处理AM、PM标签
  553. var amOrPm string
  554. if resultTime.After(timeYmd) {
  555. amOrPm = " PM"
  556. } else {
  557. amOrPm = " AM"
  558. }
  559. item.ActivityTimeText = activityTimeText + amOrPm
  560. item.ActivityTime = timeStr
  561. res := time.Now().After(resultTime)
  562. if res && activeState == 0 {
  563. errstr = "时间格式错误,请按照模板时间格式填写!"
  564. return
  565. }
  566. //如果报名时间不为空,而且是买方研选活动那么就做校验、
  567. if req.SiginupDeadline != "" && strings.Contains(req.PermissionName, utils.CHART_PERMISSION_NAME_MF_YANXUAN) {
  568. siginupDeadline := utils.StrTimeToTime(req.SiginupDeadline)
  569. if siginupDeadline.After(resultTime) && activeState == 0 {
  570. errstr = "截止时间需早于活动开始时间!"
  571. return
  572. }
  573. }
  574. //设置取消报名截止时间为会前一小时
  575. item.CancelDeadline = resultTime.Add(-time.Hour * 1).Format(utils.FormatDateTime)
  576. if req.IsResearchPoints == 1 {
  577. if req.PointsSet.CancelDeadlineType == "1" && req.SiginupDeadline != "" {
  578. item.CancelDeadline = req.SiginupDeadline
  579. }
  580. if req.PointsSet.CancelDeadlineType == "2" {
  581. item.CancelDeadline = resultTime.Add(-time.Hour * 24).Format(utils.FormatDateTime)
  582. }
  583. if req.PointsSet.CancelDeadlineType == "3" {
  584. item.CancelDeadline = resultTime.Add(-time.Hour * 48).Format(utils.FormatDateTime)
  585. }
  586. }
  587. }
  588. }
  589. if strings.Contains(contentTxt, "主讲人:") {
  590. item.Speaker = strings.Replace(contentTxt, "主讲人:", "", -1)
  591. }
  592. if strings.Contains(contentTxt, "嘉宾:") {
  593. item.DistinguishedGuest = strings.Replace(contentTxt, "嘉宾:", "", -1)
  594. }
  595. if strings.Contains(contentTxt, "主持人:") {
  596. item.Host = strings.Replace(contentTxt, "主持人:", "", -1)
  597. }
  598. if strings.Contains(contentTxt, "大陆拨入号:") {
  599. item.MainlandTell = strings.Replace(contentTxt, "大陆拨入号:", "", -1)
  600. }
  601. if strings.Contains(contentTxt, "香港拨入号:") {
  602. item.HongKongTell = strings.Replace(contentTxt, "香港拨入号:", "", -1)
  603. }
  604. if strings.Contains(contentTxt, "台湾拨入号:") {
  605. item.TaiwanTell = strings.Replace(contentTxt, "台湾拨入号:", "", -1)
  606. }
  607. if strings.Contains(contentTxt, "美国拨入号:") {
  608. item.AmericaTell = strings.Replace(contentTxt, "美国拨入号:", "", -1)
  609. }
  610. if strings.Contains(contentTxt, "拨入密码:") {
  611. item.ParticipationCode = strings.Replace(contentTxt, "拨入密码:", "", -1)
  612. }
  613. if strings.Contains(contentTxt, "参会人密码:") {
  614. item.ParticipationCode = strings.Replace(contentTxt, "参会人密码:", "", -1)
  615. }
  616. if strings.Contains(contentTxt, "参会密码:") {
  617. item.ParticipationCode = strings.Replace(contentTxt, "参会密码:", "", -1)
  618. }
  619. if strings.Contains(contentTxt, "主题:") {
  620. item.Theme = strings.Replace(contentTxt, "主题:", "", -1)
  621. }
  622. if strings.Contains(contentTxt, "专家:") {
  623. item.Expert = strings.Replace(contentTxt, "专家:", "", -1)
  624. }
  625. if strings.Contains(contentTxt, "网络参会:") {
  626. item.OnlineParticipation = strings.Replace(contentTxt, "网络参会:", "", -1)
  627. }
  628. if strings.Contains(contentTxt, "参会链接:") {
  629. item.OnlineParticipation = strings.Replace(contentTxt, "参会链接:", "", -1)
  630. }
  631. if strings.Contains(contentTxt, "报告链接:") {
  632. item.ReportLink = strings.Replace(contentTxt, "报告链接:", "", -1)
  633. }
  634. if strings.Contains(contentTxt, "城市:") {
  635. item.City = strings.Replace(contentTxt, "城市:", "", -1)
  636. }
  637. if strings.Contains(contentTxt, "活动地址:") {
  638. item.Address = strings.Replace(contentTxt, "活动地址:", "", -1)
  639. }
  640. if strings.Contains(contentTxt, "活动亮点:") {
  641. item.Highlights = strings.Replace(contentTxt, "活动亮点:", "", -1)
  642. }
  643. if strings.Contains(contentTxt, "备注:") {
  644. item.Remarks = strings.Replace(contentTxt, "备注:", "", -1)
  645. }
  646. if strings.Contains(contentTxt, "标签:") {
  647. item.Label = strings.Replace(contentTxt, "标签:", "", -1)
  648. }
  649. if strings.Contains(contentTxt, "链接参会:") {
  650. item.LinkParticipants = strings.Replace(contentTxt, "链接参会:", "", -1)
  651. }
  652. if strings.Contains(contentTxt, "App参会:") {
  653. item.AppAttendance = strings.Replace(contentTxt, "App参会:", "", -1)
  654. }
  655. if strings.Contains(contentTxt, "会议密码:") {
  656. item.ConferencePassword = strings.Replace(contentTxt, "会议密码:", "", -1)
  657. }
  658. if strings.Contains(contentTxt, "腾讯会议号:") {
  659. item.TencentConferenceNumber = strings.Replace(contentTxt, "腾讯会议号:", "", -1)
  660. }
  661. })
  662. strnum := strings.Index(body, "活动亮点:")
  663. if strnum > 0 {
  664. bodyHighlights := body[strnum:]
  665. bodyHighlightsNew, _ := ActivityHtmlAnalysis(bodyHighlights, "活动亮点:")
  666. if len(bodyHighlightsNew) > 0 {
  667. item.Highlights = strings.Replace(bodyHighlightsNew, "活动亮点:", "", -1)
  668. } else {
  669. item.Highlights = strings.Replace(bodyHighlights, "活动亮点:", "", -1)
  670. }
  671. }
  672. strnum2 := strings.Index(body, "备注:")
  673. if strnum2 > 0 {
  674. bodyRemarks := body[strnum2:]
  675. bodyRemarksNew, _ := ActivityHtmlAnalysis(bodyRemarks, "备注:")
  676. if len(bodyRemarksNew) > 0 {
  677. item.Remarks = strings.Replace(bodyRemarksNew, "备注:", "", -1)
  678. } else {
  679. item.Remarks = strings.Replace(bodyRemarks, "备注:", "", -1)
  680. }
  681. }
  682. strnum3 := strings.Index(body, "主题:")
  683. if strnum3 > 0 {
  684. bodyTheme := body[strnum3:]
  685. bodyThemeNew, _ := ActivityHtmlAnalysis(bodyTheme, "主题:")
  686. if len(bodyThemeNew) > 0 {
  687. item.Theme = strings.Replace(bodyThemeNew, "主题:", "", -1)
  688. } else {
  689. item.Theme = strings.Replace(bodyTheme, "主题:", "", -1)
  690. }
  691. }
  692. strnum4 := strings.Index(body, "专家:")
  693. if strnum4 > 0 {
  694. bodyExpert := body[strnum4:]
  695. //bodyExpert = strings.Replace(bodyExpert, "专家:", "", -1)
  696. bodyExpertNew, _ := ActivityHtmlAnalysis(bodyExpert, "专家:")
  697. //fmt.Println(bodyExpertNew)
  698. if len(bodyExpertNew) > 0 {
  699. item.Expert = strings.Replace(bodyExpertNew, "专家:", "", -1)
  700. } else {
  701. item.Expert = strings.Replace(bodyExpert, "专家:", "", -1)
  702. }
  703. }
  704. itemr = item
  705. return
  706. }
  707. // 解析查研观向的模板内容
  708. func ActivityHtmlAnalysis(body, srt string) (bodyNew, srts string) {
  709. var strarr = [...]string{"主讲人:", "嘉宾:", "主持人:", "大陆拨入号:", "香港拨入号:", "台湾拨入号:", "美国拨入号:", "拨入密码:", "参会人密码:", "参会密码:", "主题:", "专家:", "网络参会:", "参会链接:", "报告链接:", "城市:", "活动地址:", "活动亮点:", "备注:", "标签:", "链接参会:", "App参会:", "会议密码:", "腾讯会议号:"}
  710. var bodys string
  711. for _, v := range strarr {
  712. if v != srt {
  713. strnum := strings.Index(body, v)
  714. if strnum > 0 {
  715. strnum := strings.Index(body, v)
  716. bodys = body[0:strnum]
  717. bodys = strings.Replace(bodys, srt, "", -1)
  718. var isGoback bool //判断是否递归回调
  719. for _, v2 := range strarr {
  720. if strings.Index(bodys, v2) > 0 {
  721. isGoback = true
  722. }
  723. }
  724. if isGoback {
  725. ActivityHtmlAnalysis(bodys, srt)
  726. } else {
  727. bodyNew = bodys
  728. return
  729. }
  730. }
  731. }
  732. }
  733. bodyNew = bodys
  734. return
  735. }
  736. func ActivityReportLink(item *cygx.CygxActivity, industrialSubjectIdS string) (newReportLink string, err error) {
  737. var categoryIds string
  738. var reportLink string
  739. if item.ReportLink == "" {
  740. //ActivityTypeId = 2是分析师电话会
  741. if item.ActivityTypeId == 2 {
  742. //类型ID 医药(医享会:28 、药调研:301)、消费【渠道新声:32】、科技【科技前言:79】、智造【匠心智造:84】
  743. if item.ChartPermissionName == "医药" {
  744. categoryIds = "28,301"
  745. } else if item.ChartPermissionName == "消费" {
  746. categoryIds = "32"
  747. } else if item.ChartPermissionName == "科技" {
  748. categoryIds = "79"
  749. } else if item.ChartPermissionName == "智造" {
  750. categoryIds = "84"
  751. }
  752. if categoryIds != "" {
  753. articleList, errArt := cygx.GetArticleListByCategoryId(categoryIds, industrialSubjectIdS)
  754. if errArt != nil {
  755. err = errArt
  756. return
  757. }
  758. if len(articleList) > 0 {
  759. for _, v := range articleList {
  760. reportLink += utils.Hz_CeLue_Article_Url + strconv.Itoa(v.ArticleId) + "{|}"
  761. }
  762. }
  763. }
  764. }
  765. }
  766. reportLink = strings.TrimRight(reportLink, "{|}")
  767. fmt.Println(reportLink)
  768. newReportLink = reportLink
  769. return
  770. }
  771. // 判断预约纪要按钮是否显示
  772. func IsShowAppointment(activityTypeId int, chartPermissionName string) (isShowAppointment bool) {
  773. if activityTypeId == 1 || activityTypeId == 2 || activityTypeId == 3 || activityTypeId == 4 {
  774. isShowAppointment = true
  775. }
  776. if activityTypeId == 5 && chartPermissionName == "医药" {
  777. isShowAppointment = true
  778. }
  779. return
  780. }
  781. // 判断预约纪要按钮是否显示 管理员设置
  782. func IsShowAppointmentByadminSet(IsCanAppointmentMinutes int) (isShowAppointment bool) {
  783. if IsCanAppointmentMinutes == 1 {
  784. isShowAppointment = true
  785. }
  786. return
  787. }
  788. //func init() {
  789. // DoActivityOnenIdWxTemplateMsg(2100)
  790. //}
  791. // 处理活动是否进行模板消息推送
  792. func DoActivityOnenIdWxTemplateMsg(activityId int) (err error) {
  793. //10分钟之内的活动二次编辑不重复推送
  794. cacheKey := fmt.Sprint("Source:ADMIN", "_ActivityId:", activityId)
  795. isExist := utils.Rc.IsExist(cacheKey)
  796. if isExist {
  797. return err
  798. }
  799. setNX := utils.Rc.SetNX(cacheKey, activityId, time.Minute*10)
  800. if !setNX {
  801. go alarm_msg.SendAlarmMsg("发送模版消息失败,10分钟之内的活动二次编辑不重复推送,设置Redis Key 过期时间失败:key"+cacheKey, 3)
  802. return err
  803. }
  804. var weekday string
  805. weekday = time.Now().Weekday().String()
  806. if weekday == "Sunday" {
  807. //fmt.Println("今天是周日,不推送")
  808. return err
  809. }
  810. var msg string
  811. defer func() {
  812. //fmt.Println()
  813. if err != nil {
  814. fmt.Println("err:", err)
  815. go alarm_msg.SendAlarmMsg("查研观向处理活动是否进行模板消息推送,发送模版消息失败,Err:"+err.Error()+";msg:"+msg+"活动ID"+strconv.Itoa(activityId), 3)
  816. utils.FileLog.Info(fmt.Sprintf("发送模版消息失败,Err:%s,%s", err.Error(), msg))
  817. }
  818. if msg != "" {
  819. utils.FileLog.Info("发送模版消息失败,msg:%s", msg)
  820. }
  821. }()
  822. activityInfo, err := cygx.GetAddActivityInfoById(activityId)
  823. if err != nil {
  824. return
  825. }
  826. var chartPermissionIds string
  827. var chartPermissionName string
  828. //专家权限可以查看以参加以下活动的类型 1:专家电话会 、3:公司调研电话会、4:公司线下调研、5:专家线下沙龙
  829. chartPermissionName = `'` + activityInfo.ChartPermissionName + `'`
  830. if activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 3 || activityInfo.ActivityTypeId == 4 || activityInfo.ActivityTypeId == 5 {
  831. chartPermissionName += `'专家'` + `'` + activityInfo.ChartPermissionName + `'`
  832. }
  833. var activityChartPermissionName string
  834. activityChartPermissionName = activityInfo.ChartPermissionName
  835. //如果是四大行业的则做主客观区分处理
  836. if activityChartPermissionName == utils.YI_YAO_NAME || activityChartPermissionName == utils.XIAO_FEI_NAME || activityChartPermissionName == utils.KE_JI_NAME || activityChartPermissionName == utils.ZHI_ZAO_NAME {
  837. if activityInfo.PermissionType == 1 {
  838. activityChartPermissionName = activityInfo.ChartPermissionName + "(主观)"
  839. } else {
  840. activityChartPermissionName = activityInfo.ChartPermissionName + "(客观)"
  841. }
  842. }
  843. listPermissionByname, err := company.GetPermissionLookItemsSandOByName(`'` + activityChartPermissionName + `'`)
  844. if err != nil {
  845. return
  846. }
  847. var chartPermissionIdArr []int
  848. var chartPermissionStarus []string
  849. for _, v := range listPermissionByname {
  850. chartPermissionIds += strconv.Itoa(v.ChartPermissionId) + ","
  851. chartPermissionIdArr = append(chartPermissionIdArr, v.ChartPermissionId)
  852. }
  853. if strings.Contains(activityInfo.CustomerTypeIds, "1") {
  854. chartPermissionStarus = append(chartPermissionStarus, "永续")
  855. }
  856. if strings.Contains(activityInfo.CustomerTypeIds, "2") || strings.Contains(activityInfo.CustomerTypeIds, "3") || strings.Contains(activityInfo.CustomerTypeIds, "4") || strings.Contains(activityInfo.CustomerTypeIds, "9") {
  857. chartPermissionStarus = append(chartPermissionStarus, "正式")
  858. }
  859. if strings.Contains(activityInfo.CustomerTypeIds, "5") {
  860. chartPermissionStarus = append(chartPermissionStarus, "试用")
  861. }
  862. chartPermissionIds = strings.TrimRight(chartPermissionIds, ",")
  863. //var conditionPer string
  864. var parsPer []interface{}
  865. //conditionPer = ` AND p.chart_permission_id IN (` + utils.GetOrmInReplace(len(chartPermissionIdArr)) + `) `
  866. parsPer = append(parsPer, chartPermissionIdArr)
  867. //if len(chartPermissionStarus) > 0 {
  868. // conditionPer += ` AND p.STATUS IN (` + utils.GetOrmInReplace(len(chartPermissionStarus)) + `) `
  869. // parsPer = append(parsPer, chartPermissionStarus)
  870. //}
  871. //先获取有对应权限的所有用户
  872. //openidPowerList, e := cygx.GetCygxUserRecordPowerOpenid(conditionPer, parsPer)
  873. //if e != nil && e.Error() != utils.ErrNoRow() {
  874. // err = errors.New("GetCygxUserRecordPowerOpenid, Err: " + e.Error())
  875. // return
  876. //}
  877. //fmt.Println(len(openidPowerList))
  878. // 获取所有有权的用户的 openid
  879. //openidPowerList, err := cygx.GetCygxUserRecordPower(chartPermissionIds)
  880. //if err != nil {
  881. // return
  882. //}
  883. var havePowerCompanyid string
  884. //如果活动限制人数就做可见区分判断
  885. if activityInfo.IsLimitPeople > 0 {
  886. var companyIdsRecord []int
  887. var companyIdsYongxu []int
  888. companyIdsYongxuMap := make(map[int]int)
  889. var companyIdsDaTaoCan []int
  890. companyIdsDaTaoCanMap := make(map[int]int)
  891. //var companyIdsHangYe []int // 行业套餐客户
  892. companyIdsHangYeMap := make(map[int]int) // 行业套餐客户
  893. companyIds30WMap := make(map[int]int) // 30W套餐客户
  894. var companyIdsShiYong []int
  895. companyIdsShiYongMap := make(map[int]int) // 试用客户
  896. companyIdsShengJiMap := make(map[int]int) // 升级客户
  897. companyIdsZhuKeGuanMap := make(map[int]int) // 行业套餐客户区分主客观
  898. //获取关注了查研观向小助手的客户ID
  899. cygxUserRecordCompanyList, e := cygx.GetCygxUserRecordCompany()
  900. if e != nil && e.Error() != utils.ErrNoRow() {
  901. err = errors.New("GetCygxUserRecordCompany, Err: " + e.Error())
  902. return
  903. }
  904. for _, v := range cygxUserRecordCompanyList {
  905. companyIdsRecord = append(companyIdsRecord, v.CompanyId)
  906. }
  907. listYongXu, e := company.GetCompanyProductListByStatus("永续", 2)
  908. if e != nil && e.Error() != utils.ErrNoRow() {
  909. err = errors.New("GetCygxUserRecordCompany, Err: " + e.Error())
  910. return
  911. }
  912. //永续客户
  913. for _, v := range listYongXu {
  914. companyIdsYongxu = append(companyIdsYongxu, v.CompanyId)
  915. companyIdsYongxuMap[v.CompanyId] = v.CompanyId
  916. }
  917. listShiYong, e := company.GetCompanyProductListByStatus("试用", 2)
  918. if e != nil && e.Error() != utils.ErrNoRow() {
  919. err = errors.New("GetCygxUserRecordCompany, Err: " + e.Error())
  920. return
  921. }
  922. //试用客户
  923. for _, v := range listShiYong {
  924. companyIdsShiYong = append(companyIdsShiYong, v.CompanyId)
  925. companyIdsShiYongMap[v.CompanyId] = v.CompanyId
  926. }
  927. //自定义的大套餐客户
  928. listDaTaoCan, e := cygx.GetCygxCompanyUserTypeList()
  929. if e != nil && e.Error() != utils.ErrNoRow() {
  930. err = errors.New("GetCygxCompanyUserTypeList, Err: " + e.Error())
  931. return
  932. }
  933. for _, v := range listDaTaoCan {
  934. companyIdsDaTaoCan = append(companyIdsDaTaoCan, v.CompanyId)
  935. companyIdsDaTaoCanMap[v.CompanyId] = v.CompanyId
  936. }
  937. var conditionPer string
  938. var parsPer []interface{}
  939. conditionPer = ` AND r.company_id IN ( ` + utils.GetOrmInReplace(len(companyIdsRecord)) + `) `
  940. parsPer = append(parsPer, companyIdsRecord)
  941. companyReportPermissionItemList, e := cygx.GetCompanyReportPermissionItem(conditionPer, parsPer)
  942. if e != nil && e.Error() != utils.ErrNoRow() {
  943. err = errors.New("GetCompanyReportPermissionItem, Err: " + e.Error())
  944. return
  945. }
  946. permissionNameNumMap := make(map[string]int)
  947. permissionComapnyNumMap := make(map[int]int)
  948. //过滤这些客户中的30w套餐客户(四大行业+策略,有任意4个以上是正式状态的客户)
  949. for _, v := range companyReportPermissionItemList {
  950. if companyIdsYongxuMap[v.CompanyId] == 0 && companyIdsDaTaoCanMap[v.CompanyId] == 0 {
  951. permissionNameNumMap[fmt.Sprint(v.CompanyId, "_", v.PermissionName)]++
  952. if v.PermissionName == utils.YI_YAO_NAME || v.PermissionName == utils.XIAO_FEI_NAME || v.PermissionName == utils.KE_JI_NAME || v.PermissionName == utils.ZHI_ZAO_NAME || v.PermissionName == utils.CE_LUE_NAME {
  953. if permissionNameNumMap[fmt.Sprint(v.CompanyId, "_", v.PermissionName)] == 2 {
  954. permissionComapnyNumMap[v.CompanyId]++
  955. }
  956. }
  957. if v.PermissionName == utils.CE_LUE_NAME {
  958. permissionComapnyNumMap[v.CompanyId]++
  959. }
  960. }
  961. if v.IsUpgrade == 1 && v.PermissionName == activityInfo.ChartPermissionName {
  962. companyIdsShengJiMap[v.CompanyId] = v.CompanyId
  963. }
  964. if activityInfo.PermissionType == 1 {
  965. activityChartPermissionName = activityInfo.ChartPermissionName + "(主观)"
  966. } else {
  967. activityChartPermissionName = activityInfo.ChartPermissionName + "(客观)"
  968. }
  969. }
  970. for k, v := range permissionComapnyNumMap {
  971. if v >= 4 {
  972. companyIds30WMap[k] = v
  973. }
  974. }
  975. //如果一个客户不满足,永续客户,大套餐客户,30W套餐客户 就把他归为其他行业正式客户
  976. for _, v := range companyReportPermissionItemList {
  977. if companyIdsYongxuMap[v.CompanyId] == 0 && companyIdsDaTaoCanMap[v.CompanyId] == 0 && companyIds30WMap[v.CompanyId] == 0 {
  978. if v.Remark == activityChartPermissionName {
  979. companyIdsZhuKeGuanMap[v.CompanyId] = v.CompanyId
  980. }
  981. }
  982. }
  983. //listHangYe, e := company.GetCompanyProductListByStatus("正式", 2)
  984. //if e != nil && e.Error() != utils.ErrNoRow() {
  985. // err = errors.New("GetCygxUserRecordCompany, Err: " + e.Error())
  986. // return
  987. //}
  988. for _, v := range companyReportPermissionItemList {
  989. if companyIdsYongxuMap[v.CompanyId] == 0 && companyIdsDaTaoCanMap[v.CompanyId] == 0 && companyIds30WMap[v.CompanyId] == 0 {
  990. companyIdsHangYeMap[v.CompanyId] = v.CompanyId
  991. //var companyIdsHangYe []int // 行业套餐客户
  992. //companyIdsHangYeMap := make(map[int]int) // 行业套餐客户
  993. }
  994. }
  995. //处理活动针对可见的用户
  996. var companyIdsPower []int // 获取可见活动的公司ID
  997. //var companyIds []int
  998. //mapComapnyId := make(map[int]int)
  999. //mapCompanyProduct := make(map[int]int)
  1000. //mapComapnyPower := make(map[int]*cygx.CompanyPermissionPower)
  1001. if activityInfo.CustomerTypeIds != "" {
  1002. customerTypeIdMap, err := GetCustomerTypeIds(activityInfo.CustomerTypeIds)
  1003. if err != nil {
  1004. return err
  1005. }
  1006. if _, ok := customerTypeIdMap[1]; ok {
  1007. //永续客户
  1008. for _, v := range listYongXu {
  1009. companyIdsPower = append(companyIdsPower, v.CompanyId)
  1010. }
  1011. }
  1012. if _, ok := customerTypeIdMap[2]; ok {
  1013. //大套餐客户
  1014. for _, v := range listDaTaoCan {
  1015. companyIdsPower = append(companyIdsPower, v.CompanyId)
  1016. }
  1017. }
  1018. if _, ok := customerTypeIdMap[3]; ok {
  1019. //行业套餐客户
  1020. for _, v := range companyIdsHangYeMap {
  1021. companyIdsPower = append(companyIdsPower, v)
  1022. }
  1023. }
  1024. if _, ok := customerTypeIdMap[10]; ok {
  1025. //30万套餐客户
  1026. for k := range companyIds30WMap {
  1027. companyIdsPower = append(companyIdsPower, k)
  1028. }
  1029. }
  1030. if _, ok := customerTypeIdMap[5]; ok {
  1031. //试用客户
  1032. for _, v := range listShiYong {
  1033. companyIdsPower = append(companyIdsPower, v.CompanyId)
  1034. }
  1035. }
  1036. if _, ok := customerTypeIdMap[8]; ok {
  1037. //升级权限的客户
  1038. for k := range companyIdsShengJiMap {
  1039. companyIdsPower = append(companyIdsPower, k)
  1040. }
  1041. for _, v := range listYongXu {
  1042. companyIdsPower = append(companyIdsPower, v.CompanyId)
  1043. }
  1044. }
  1045. if _, ok := customerTypeIdMap[9]; ok {
  1046. //其他行业正式客户
  1047. for k := range companyIdsZhuKeGuanMap {
  1048. companyIdsPower = append(companyIdsPower, k)
  1049. }
  1050. }
  1051. }
  1052. //如果勾选了管理规模可见,则做以下处理
  1053. if activityInfo.Scale != "" {
  1054. listCompmayScale, e := company.GetCompanyProductListByScale(activityInfo.Scale, 2)
  1055. if e != nil && e.Error() != utils.ErrNoRow() {
  1056. err = errors.New("GetCompanyProductListByScale, Err: " + e.Error())
  1057. return
  1058. }
  1059. for _, v := range listCompmayScale {
  1060. companyIdsPower = append(companyIdsPower, v.CompanyId)
  1061. }
  1062. }
  1063. companyIdsPowerMap := make(map[int]int)
  1064. for _, v := range companyIdsPower {
  1065. companyIdsPowerMap[v] = v
  1066. }
  1067. //如果活动设置仅本组可见,那么则对公司ID做限制
  1068. if activityInfo.VisibleRange == 1 {
  1069. adminInfo, err := system.GetSysUserById(activityInfo.AdminId)
  1070. if err != nil {
  1071. return err
  1072. }
  1073. adminList, err := system.GetAdminListByGroupId(adminInfo.GroupId)
  1074. if err != nil {
  1075. return err
  1076. }
  1077. var adminIdGroup string
  1078. for _, v := range adminList {
  1079. adminIdGroup += strconv.Itoa(v.AdminId) + ","
  1080. }
  1081. adminIdGroup = strings.TrimRight(adminIdGroup, ",")
  1082. companyProductList, err := company.GetCompanyProductsBySellerId(adminIdGroup)
  1083. if err != nil && err.Error() != utils.ErrNoRow() {
  1084. return err
  1085. }
  1086. if len(companyProductList) == 0 {
  1087. return err
  1088. }
  1089. for _, v := range companyProductList {
  1090. if companyIdsPowerMap[v.CompanyId] > 0 {
  1091. havePowerCompanyid += strconv.Itoa(v.CompanyId) + ","
  1092. }
  1093. }
  1094. } else {
  1095. for _, v := range companyIdsPowerMap {
  1096. havePowerCompanyid += strconv.Itoa(v) + ","
  1097. }
  1098. }
  1099. //for _, v := range openidPowerList {
  1100. // //如果仅本组人可见,那么就对companyID做一下限制
  1101. // if activityInfo.VisibleRange == 1 {
  1102. // if mapCompanyProduct[v.CompanyId] > 0 {
  1103. // if _, ok := mapComapnyId[v.CompanyId]; !ok {
  1104. // mapComapnyId[v.CompanyId] = v.CompanyId
  1105. // companyIds = append(companyIds, v.CompanyId)
  1106. // }
  1107. // }
  1108. // } else {
  1109. // if _, ok := mapComapnyId[v.CompanyId]; !ok {
  1110. // mapComapnyId[v.CompanyId] = v.CompanyId
  1111. // companyIds = append(companyIds, v.CompanyId)
  1112. // }
  1113. // }
  1114. //}
  1115. //fmt.Println("companyIds", companyIds)
  1116. ////获取客户的状态,正式、试用、冻结。
  1117. //listCompany, err := cygx.GetCompanyDetailByIdGroupList(companyIds)
  1118. //if err != nil && err.Error() != utils.ErrNoRow() {
  1119. // return err
  1120. //}
  1121. //for _, v := range listCompany {
  1122. // itemCompanyPermissionPower := new(cygx.CompanyPermissionPower)
  1123. // itemCompanyPermissionPower.CompanyId = v.CompanyId
  1124. // itemCompanyPermissionPower.Status = v.Status
  1125. // mapComapnyPower[v.CompanyId] = itemCompanyPermissionPower
  1126. //}
  1127. //
  1128. ////获取公司权限非正式,用来区分大套餐客户
  1129. //listCompanyPermission, err := cygx.GetCompanyPermissionByCompanyIds(companyIds)
  1130. //if err != nil && err.Error() != utils.ErrNoRow() {
  1131. // return err
  1132. //}
  1133. //for _, v := range listCompanyPermission {
  1134. // mapComapnyPower[v.CompanyId].PermissionName = v.PermissionName
  1135. //}
  1136. //
  1137. ////获取公司权限 正式,用来区分大套餐客户
  1138. //listCompanyPermissionZhenShi, err := cygx.GetCompanyPermissionZhenShiByCompanyIds(companyIds)
  1139. //if err != nil && err.Error() != utils.ErrNoRow() {
  1140. // return err
  1141. //}
  1142. //for _, v := range listCompanyPermissionZhenShi {
  1143. // mapComapnyPower[v.CompanyId].PermissionNameZhengShi = v.PermissionName
  1144. //}
  1145. //
  1146. ////处理用户身份 userType
  1147. //for k, v := range mapComapnyPower {
  1148. // v.HavePower = true
  1149. // mapComapnyPower[k] = GetUserTypeByPermission(v)
  1150. //}
  1151. //for k, v := range mapComapnyPower {
  1152. // noPower, _ := GetShareNoPowe(activityInfo, v.PermissionName, v.UserType)
  1153. // if noPower {
  1154. // mapComapnyPower[k].HavePower = false
  1155. // }
  1156. //}
  1157. ////如果活动选了企业管理规模可见字段,则作以下处理
  1158. //if activityInfo.Scale != "" {
  1159. // listCompanyByScale, err := cygx.GetCygxUserRecordPowerByScale(chartPermissionIds, activityInfo.Scale)
  1160. // if err != nil && err.Error() != utils.ErrNoRow() {
  1161. // return err
  1162. // }
  1163. // for _, v := range listCompanyByScale {
  1164. // if mapComapnyPower[v.CompanyId] != nil {
  1165. // mapComapnyPower[v.CompanyId].HavePower = true
  1166. // }
  1167. // }
  1168. //}
  1169. //for _, v := range mapComapnyPower {
  1170. // if v.HavePower == true {
  1171. // havePowerCompanyid += strconv.Itoa(v.CompanyId) + ","
  1172. // }
  1173. //}
  1174. havePowerCompanyid = strings.TrimRight(havePowerCompanyid, ",")
  1175. if havePowerCompanyid == "" {
  1176. return err
  1177. }
  1178. }
  1179. //获取拒绝接收推送的的用户的 openid
  1180. //return
  1181. mapOpenidRefuset := make(map[int]string)
  1182. openidRefusetList, err := cygx.GetCygxUserRefusetOpenid()
  1183. if err != nil && err.Error() != utils.ErrNoRow() {
  1184. return err
  1185. }
  1186. for _, v := range openidRefusetList {
  1187. mapOpenidRefuset[v.UserId] = v.OpenId
  1188. }
  1189. var condition string
  1190. //如果活动选择了仅有决策人可见则做以下处理
  1191. if activityInfo.IsMakerShow == 1 {
  1192. condition += ` AND u.is_maker = 1 `
  1193. }
  1194. //fmt.Println(havePowerCompanyid)
  1195. if activityInfo.IsLimitPeople > 0 && havePowerCompanyid != "" {
  1196. condition += ` AND u.company_id IN (` + havePowerCompanyid + `) `
  1197. }
  1198. //根据活动的主客观,获取选择主客观规则的用户的 openid
  1199. mapUserIdChooseTypeSend := make(map[int]int)
  1200. //获取提交过推送规则的用户的 openid
  1201. mapUserIdChooseSend := make(map[int]int)
  1202. var conditionChoose string
  1203. if activityInfo.ChartPermissionName == utils.YI_YAO_NAME {
  1204. conditionChoose = ` AND all_in_yi_yao = 0 `
  1205. } else if activityInfo.ChartPermissionName == utils.XIAO_FEI_NAME {
  1206. conditionChoose = ` AND all_in_xiao_fei = 0 `
  1207. } else if activityInfo.ChartPermissionName == utils.KE_JI_NAME {
  1208. conditionChoose = ` AND all_in_ke_ji = 0 `
  1209. } else if activityInfo.ChartPermissionName == utils.ZHI_ZAO_NAME {
  1210. conditionChoose = ` AND all_in_zhi_zao = 0 `
  1211. } else if activityInfo.ChartPermissionName == utils.CHART_PERMISSION_NAME_MF_YANXUAN || activityInfo.ChartPermissionName == utils.CHART_PERMISSION_NAME_YANXUAN {
  1212. conditionChoose = ` AND all_in_yan_xuan = 0 `
  1213. }
  1214. chooseSendtList, err := cygx.GetCygxXzsChooseSend(conditionChoose)
  1215. if err != nil && err.Error() != utils.ErrNoRow() {
  1216. return err
  1217. }
  1218. for _, v := range chooseSendtList {
  1219. mapUserIdChooseSend[v.UserId] = v.UserId
  1220. //选择主观的客户
  1221. if activityInfo.PermissionType == 1 && v.IsSubjective == 1 {
  1222. mapUserIdChooseTypeSend[v.UserId] = v.UserId
  1223. }
  1224. //选择客观的客户
  1225. if activityInfo.PermissionType == 2 && v.IsObjective == 1 {
  1226. mapUserIdChooseTypeSend[v.UserId] = v.UserId
  1227. }
  1228. }
  1229. //fmt.Println(chooseSendtList)
  1230. //获取关注这个活动对应产业的用户的 openid
  1231. mapOpenidFllow := make(map[int]string)
  1232. openidFllowList, err := cygx.GetCygxActiviyUserFllowOpenid(activityId)
  1233. if err != nil && err.Error() != utils.ErrNoRow() {
  1234. return err
  1235. }
  1236. for _, v := range openidFllowList {
  1237. mapOpenidFllow[v.UserId] = v.OpenId
  1238. }
  1239. //fmt.Println(mapOpenidFllow)
  1240. openidPowerByActivitySetList, err := cygx.GetCygxUserRecordPowerByActivitySet(chartPermissionIds, condition)
  1241. if err != nil && err.Error() != utils.ErrNoRow() {
  1242. return err
  1243. }
  1244. //已经推送过的不做二次推送
  1245. listSendOpendId, err := models.GeUserTemplateRecordListBysendType(utils.TEMPLATE_MSG_CYGX_ACTIVITY_ADD, strconv.Itoa(activityId))
  1246. if err != nil && err.Error() != utils.ErrNoRow() {
  1247. return err
  1248. }
  1249. mapSendOpenid := make(map[string]int)
  1250. for _, v := range listSendOpendId {
  1251. mapSendOpenid[v.OpenId] = v.UserId
  1252. }
  1253. var OpenIdList []*models.OpenIdList
  1254. for _, v := range openidPowerByActivitySetList {
  1255. if mapSendOpenid[v.OpenId] > 0 {
  1256. //fmt.Println("已经推过了")
  1257. continue
  1258. }
  1259. item := new(models.OpenIdList)
  1260. item.UserId = v.UserId
  1261. item.OpenId = v.OpenId
  1262. if mapUserIdChooseSend[v.UserId] == 0 {
  1263. //如果小助手没有选择过权限信息,那么做消息推送
  1264. OpenIdList = append(OpenIdList, item)
  1265. } else {
  1266. //如果勾选了权限信息,则要满足 1选择产业,2没有选择不接受任何消息推送,3活动对应的主客观跟自己选择的一致。
  1267. if mapOpenidFllow[v.UserId] != "" && mapOpenidRefuset[v.UserId] == "" && mapUserIdChooseTypeSend[v.UserId] != 0 {
  1268. OpenIdList = append(OpenIdList, item)
  1269. }
  1270. }
  1271. }
  1272. if len(OpenIdList) == 0 {
  1273. return err
  1274. }
  1275. //
  1276. //for _, v := range OpenIdList {
  1277. // fmt.Println(v)
  1278. //}
  1279. //return err
  1280. activityInfo.ActivityTypeName = strings.Replace(activityInfo.ActivityTypeName, "(C类)", "", -1)
  1281. first := "您关注的赛道,有【" + activityInfo.ActivityTypeName + "】活动发布,欢迎参与"
  1282. keyword1 := "新活动:" + activityInfo.ActivityName
  1283. keyword2 := activityInfo.ActivityTimeText + ",【" + activityInfo.Label + "】"
  1284. keyword3 := ""
  1285. keyword4 := ""
  1286. services.SendActivityOnenIdWxTemplateMsg(first, keyword1, keyword2, keyword3, keyword4, OpenIdList, activityInfo.ActivityId)
  1287. return
  1288. }
  1289. // 获取 用户类型 //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //3、分行业套餐客户(开通对应行业的正式客户) //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户
  1290. func GetUserTypeByPermission(item *cygx.CompanyPermissionPower) (itemPower *cygx.CompanyPermissionPower) {
  1291. itemPower = item
  1292. var userType int
  1293. var permissionStr string
  1294. var permissionZhengShiStr string
  1295. permissionStr = item.PermissionName
  1296. permissionZhengShiStr = item.PermissionNameZhengShi
  1297. //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //3、分行业套餐客户(开通对应行业的正式客户) //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户 6、冻结客户;7、流失客户
  1298. if item.Status == "永续" {
  1299. userType = 1
  1300. } else if item.Status == "试用" {
  1301. userType = 5
  1302. } else if item.Status == "正式" {
  1303. if permissionStr == "专家" {
  1304. userType = 4
  1305. } else if strings.Contains(permissionZhengShiStr, "医药") && strings.Contains(permissionZhengShiStr, "消费") && strings.Contains(permissionZhengShiStr, "科技") && strings.Contains(permissionZhengShiStr, "智造") {
  1306. userType = 2
  1307. } else {
  1308. userType = 3
  1309. }
  1310. if userType == 3 {
  1311. if !strings.Contains(permissionStr, "医药") && !strings.Contains(permissionStr, "消费") && !strings.Contains(permissionStr, "科技") && !strings.Contains(permissionStr, "智造") {
  1312. userType = 4
  1313. }
  1314. }
  1315. //大套餐客户定义:医药、消费、科技、智造、策略。5个行业中任意4个及以上是正式权限的,属于大套餐客户(医药、消费、科技、智造需要主客观都开)
  1316. if userType == 3 {
  1317. var permissionZhegnshiNum int
  1318. if strings.Count(permissionZhengShiStr, "医药") == 2 {
  1319. permissionZhegnshiNum++
  1320. }
  1321. if strings.Count(permissionZhengShiStr, "消费") == 2 {
  1322. permissionZhegnshiNum++
  1323. }
  1324. if strings.Count(permissionZhengShiStr, "科技") == 2 {
  1325. permissionZhegnshiNum++
  1326. }
  1327. if strings.Count(permissionZhengShiStr, "智造") == 2 {
  1328. permissionZhegnshiNum++
  1329. }
  1330. if strings.Count(permissionZhengShiStr, "策略") == 1 {
  1331. permissionZhegnshiNum++
  1332. }
  1333. if permissionZhegnshiNum >= 4 {
  1334. userType = 2
  1335. }
  1336. }
  1337. } else if item.Status == "冻结" {
  1338. userType = 6
  1339. } else if item.Status == "流失" {
  1340. userType = 7
  1341. }
  1342. itemPower.UserType = userType
  1343. return
  1344. }
  1345. // GetActChartPermissionList 获取活动行业分类列表
  1346. func GetActChartPermissionList() []*cygx.ChartPermissionRepMore {
  1347. list := []*cygx.ChartPermissionRepMore{
  1348. {PermissionName: "医药"},
  1349. {PermissionName: "消费"},
  1350. {PermissionName: "科技"},
  1351. {PermissionName: "智造"},
  1352. {PermissionName: "策略"},
  1353. {PermissionName: "宏观"},
  1354. {PermissionName: utils.CHART_PERMISSION_NAME_MF_YANXUAN},
  1355. {PermissionName: utils.CHART_PERMISSION_NAME_MF_YANXUAN + "(医药)"},
  1356. {PermissionName: utils.CHART_PERMISSION_NAME_MF_YANXUAN + "(消费)"},
  1357. {PermissionName: utils.CHART_PERMISSION_NAME_MF_YANXUAN + "(科技)"},
  1358. {PermissionName: utils.CHART_PERMISSION_NAME_MF_YANXUAN + "(智造)"},
  1359. }
  1360. return list
  1361. }
  1362. // 同步活动到最新数据表
  1363. func UpdateResourceData(sourceId int, source, doType, publishDate string) (err error) {
  1364. defer func() {
  1365. if err != nil {
  1366. fmt.Println("err:", err)
  1367. go alarm_msg.SendAlarmMsg("同步到最新数据表失败,Err:"+err.Error()+"资源ID"+strconv.Itoa(sourceId)+"资源类型"+source+"操作方式"+doType, 3)
  1368. }
  1369. }()
  1370. if doType == "add" {
  1371. item := new(cygx.CygxResourceData)
  1372. item.SourceId = sourceId
  1373. item.Source = source
  1374. item.PublishDate = publishDate
  1375. item.CreateTime = time.Now()
  1376. _, err = cygx.AddCygxResourceData(item)
  1377. } else if doType == "delete" {
  1378. err = cygx.DeleteResourceData(sourceId, source)
  1379. } else if doType == "update" {
  1380. err = cygx.UpdateResourceData(sourceId, source, publishDate)
  1381. }
  1382. return
  1383. }
  1384. // CheckActivityUpdatePower 校验活动后台管理员、销售是否有修改权限
  1385. func CheckActivityUpdatePower(adminId int, activityInfo *cygx.ActivityDetail) (havePower bool, popupMsg string, err error) {
  1386. defer func() {
  1387. if err != nil {
  1388. fmt.Println("err:", err)
  1389. go alarm_msg.SendAlarmMsg("校验活动后台管理员、销售是否有修改权限失败,Err:"+err.Error(), 3)
  1390. }
  1391. }()
  1392. adminInfo, e := system.GetSysUserById(adminId)
  1393. if e != nil {
  1394. err = errors.New("获取管理员身份失败,GetSysUserById" + e.Error())
  1395. return
  1396. }
  1397. //如果这个活动不是自己建的会议,那么就对权益销售跟权益组长做身份限制判断
  1398. if activityInfo.AdminId > 0 && activityInfo.AdminId != adminId && (adminInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_SELLER || adminInfo.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_GROUP) {
  1399. popupMsg = "只有建会销售可修改。"
  1400. return
  1401. }
  1402. havePower = true
  1403. return
  1404. }