activity.go 49 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "hongze/hongze_cygx/models"
  6. "hongze/hongze_cygx/utils"
  7. "rdluck_tools/paging"
  8. "strconv"
  9. "strings"
  10. "time"
  11. )
  12. //活动
  13. type ActivityCoAntroller struct {
  14. BaseAuthController
  15. }
  16. type ActivityABaseController struct {
  17. BaseCommonController
  18. }
  19. // @Title 活动类型列表
  20. // @Description活动类型列表接口
  21. // @Success 200 {object} models.ActivityTypeListResp
  22. // @router /activityTypelist [get]
  23. func (this *ActivityCoAntroller) List() {
  24. br := new(models.BaseResponse).Init()
  25. defer func() {
  26. this.Data["json"] = br
  27. this.ServeJSON()
  28. }()
  29. user := this.User
  30. if user == nil {
  31. br.Msg = "请登录"
  32. br.ErrMsg = "请登录,SysUser Is Empty"
  33. br.Ret = 408
  34. return
  35. }
  36. resp := new(models.ActivityTypeListResp)
  37. list, err := models.GetActivityTypeList()
  38. if err != nil {
  39. br.Msg = "获取失败"
  40. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  41. return
  42. }
  43. resp.List = list
  44. br.Ret = 200
  45. br.Success = true
  46. br.Msg = "获取成功"
  47. br.Data = resp
  48. }
  49. // @Title 活动列表
  50. // @Description 获取活动列表接口
  51. // @Param PageSize query int true "每页数据条数"
  52. // @Param CurrentIndex query int true "当前页页码,从1开始"
  53. // @Param ChartPermissionIds query string false "行业id 多个用 , 隔开"
  54. // @Param ActivityTypeIds query string false "活动类型id 多个用 , 隔开"
  55. // @Param KeyWord query string false "搜索关键词 多个用 , 隔开"
  56. // @Param ActiveState query string false "活动进行状态 未开始:1、进行中2、已结束3"
  57. // @Param WhichDay query string false "哪一天 今天:1、明天:2,多个用 , 隔开"
  58. // @Param IsShowJurisdiction query int false "是否仅展示有权限的,1是,2否 默认为零"
  59. // @Success 200 {object} models.GetCygxActivityListRep
  60. // @router /list [get]
  61. func (this *ActivityCoAntroller) ActivityList() {
  62. br := new(models.BaseResponse).Init()
  63. defer func() {
  64. this.Data["json"] = br
  65. this.ServeJSON()
  66. }()
  67. user := this.User
  68. if user == nil {
  69. br.Msg = "请登录"
  70. br.ErrMsg = "请登录,SysUser Is Empty"
  71. return
  72. }
  73. fmt.Println(user.Mobile)
  74. uid := user.UserId
  75. pageSize, _ := this.GetInt("PageSize")
  76. currentIndex, _ := this.GetInt("CurrentIndex")
  77. chartPermissionIds := this.GetString("ChartPermissionIds")
  78. activityTypeIds := this.GetString("ActivityTypeIds")
  79. whichDay := this.GetString("WhichDay")
  80. isShowJurisdiction, _ := this.GetInt("IsShowJurisdiction")
  81. keyWord := this.GetString("KeyWord")
  82. activeState := this.GetString("ActiveState")
  83. itemSearch := new(models.CygxActivityUserSearchContent)
  84. itemSearch.UserId = uid
  85. itemSearch.CreateTime = time.Now()
  86. itemSearch.Mobile = user.Mobile
  87. itemSearch.Email = user.Email
  88. itemSearch.CompanyId = user.CompanyId
  89. itemSearch.CompanyName = user.CompanyName
  90. itemSearch.ModifyTime = time.Now()
  91. itemSearch.ChartPermissionids = chartPermissionIds
  92. itemSearch.ActivityTypeids = activityTypeIds
  93. itemSearch.ActiveState = activeState
  94. itemSearch.IsShowJurisdiction = isShowJurisdiction
  95. _, errSearch := models.AddUserSearchContent(itemSearch)
  96. if errSearch != nil {
  97. br.Msg = "操作失败"
  98. br.ErrMsg = "操作失败,Err:" + errSearch.Error()
  99. return
  100. }
  101. var userType int
  102. var permissionStr string
  103. if user.CompanyId <= 1 {
  104. userType = 0
  105. } else {
  106. total, err := models.GetCountCompanyDetailByIdGroup(user.CompanyId)
  107. if err != nil {
  108. br.Msg = "获取失败"
  109. br.ErrMsg = "获取失败,Err:" + err.Error()
  110. return
  111. }
  112. if total == 0 {
  113. userType = 0
  114. } else {
  115. companyDetail, err := models.GetCompanyDetailByIdGroup(user.CompanyId)
  116. if err != nil {
  117. br.Msg = "获取信息失败!"
  118. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  119. return
  120. }
  121. if companyDetail == nil {
  122. br.Msg = "获取信息失败!"
  123. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId)
  124. return
  125. }
  126. permissionStr, err = models.GetCompanyPermission(user.CompanyId)
  127. if err != nil {
  128. br.Msg = "获取信息失败"
  129. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  130. return
  131. }
  132. //1、永续客户
  133. //2、大套餐客户(4个行业全开通的正式客户)
  134. //3、分行业套餐客户(开通对应行业的正式客户)
  135. //4、仅开通专家套餐的正式客户
  136. //5、开通对应行业套餐或专家套餐的试用客户
  137. if companyDetail.Status == "永续" {
  138. userType = 1
  139. } else if companyDetail.Status == "试用" {
  140. userType = 5
  141. } else if companyDetail.Status == "正式" {
  142. if permissionStr == "专家" {
  143. userType = 4
  144. } else if strings.Contains(permissionStr, "医药") && strings.Contains(permissionStr, "消费") && strings.Contains(permissionStr, "科技") && strings.Contains(permissionStr, "智造") {
  145. userType = 2
  146. } else {
  147. userType = 3
  148. }
  149. if userType == 3 {
  150. if !strings.Contains(permissionStr, "医药") && !strings.Contains(permissionStr, "消费") && !strings.Contains(permissionStr, "科技") && !strings.Contains(permissionStr, "智造") {
  151. userType = 4
  152. }
  153. }
  154. }
  155. }
  156. }
  157. if isShowJurisdiction == 1 && chartPermissionIds == "" && userType == 4 {
  158. activityTypeIds = "1,3"
  159. }
  160. var startSize int
  161. if pageSize <= 0 {
  162. pageSize = utils.PageSize20
  163. }
  164. if currentIndex <= 0 {
  165. currentIndex = 1
  166. }
  167. startSize = utils.StartIndex(currentIndex, pageSize)
  168. var condition string
  169. var pars []interface{}
  170. //活动可见限制
  171. var sqlExport string
  172. slicePer := strings.Split(permissionStr, ",")
  173. var permissionSqlStr string
  174. for _, v := range slicePer {
  175. permissionSqlStr += "'" + v + "',"
  176. }
  177. permissionSqlStr = strings.TrimRight(permissionSqlStr, ",")
  178. permissionSqlStr = ` AND art.chart_permission_name IN (` + permissionSqlStr + `)`
  179. sqlExport = ` AND (art.customer_type_ids LIKE '%` + strconv.Itoa(userType) + `%' `
  180. if userType == 2 {
  181. sqlExport += ` OR art.customer_type_ids LIKE '%3%' `
  182. }
  183. if (userType == 2 || userType == 3) && strings.Contains(permissionStr, "专家") {
  184. sqlExport += ` OR art.customer_type_ids LIKE '%4%' `
  185. }
  186. sqlExport += `) `
  187. if keyWord != "" {
  188. var mirrorword string
  189. var mirrorwordSql string
  190. slicemirrorword := strings.Split(keyWord, ",")
  191. for _, v := range slicemirrorword {
  192. mirrorwordSql += "'" + v + "'" + ","
  193. }
  194. mirrorwordSql = strings.TrimRight(mirrorwordSql, ",")
  195. total, err := models.GetActivityMirrorWordCount(mirrorwordSql)
  196. if err != nil {
  197. br.Msg = "获取失败"
  198. br.ErrMsg = "获取失败,Err:" + err.Error()
  199. return
  200. }
  201. if total > 0 {
  202. mirrorword, err = models.GetMirrorWord(mirrorwordSql)
  203. if err != nil {
  204. br.Msg = "获取信息失败"
  205. br.ErrMsg = "关系词映射获取失败,Err:" + err.Error()
  206. return
  207. }
  208. }
  209. keyWord = keyWord + "," + mirrorword
  210. slicekeyWord := strings.Split(keyWord, ",")
  211. var sqlKeyOr string
  212. if len(slicekeyWord) >= 2 {
  213. for _, v := range slicekeyWord {
  214. if v != "" {
  215. sqlKeyOr += ` OR art.activity_name LIKE '%` + v + `%' `
  216. }
  217. }
  218. condition += ` AND (art.activity_name LIKE '%` + keyWord + `%' ` + sqlKeyOr + ` )`
  219. } else {
  220. condition += ` AND (art.activity_name LIKE '%` + keyWord + `%' )`
  221. }
  222. }
  223. //行业名称
  224. if len(chartPermissionIds) > 0 {
  225. condition += ` AND art.chart_permission_id IN (` + chartPermissionIds + `)`
  226. }
  227. if activityTypeIds != "" {
  228. condition += ` AND art.activity_type_id IN (` + activityTypeIds + `)`
  229. }
  230. if whichDay != "" {
  231. var startDate string
  232. var endDate string
  233. if whichDay == "1" {
  234. startDate = time.Now().Format(utils.FormatDate)
  235. endDate = startDate
  236. } else if whichDay == "2" {
  237. startDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  238. endDate = startDate
  239. } else {
  240. startDate = time.Now().Format(utils.FormatDate)
  241. endDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  242. }
  243. condition += ` AND art.activity_time >= ` + "'" + startDate + " 00:00:00'"
  244. condition += ` AND art.activity_time <= ` + "'" + endDate + " 23:59:59'"
  245. }
  246. if activeState != "" {
  247. condition += ` AND art.active_state IN (` + activeState + `)`
  248. }
  249. condition += ` AND art.publish_status = 1 `
  250. var conditionOr string
  251. //if strings.Contains(permissionStr, "专家") && (userType == 2 || userType == 3 || userType == 4) {
  252. //conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%4%' ` + permissionSqlStr + condition + `) `
  253. //conditionOr += ` OR ( art.is_limit_people = 1 AND art.activity_type_id = 3 AND art.customer_type_ids LIKE '%4%' ` + condition + `) `
  254. //}
  255. // 有专家权限的这几种用户,不做行业权限校验
  256. if (userType == 2 || userType == 3 || userType == 4) && strings.Contains(permissionStr, "专家") {
  257. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%4%' ` + condition + `) `
  258. }
  259. if (userType == 5) && strings.Contains(permissionStr, "专家") {
  260. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%5%' ` + condition + `) `
  261. }
  262. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + `) `
  263. condition += ` AND art.is_limit_people = 1 ` + permissionSqlStr + sqlExport + conditionOr
  264. total, err := models.GetActivityCount(condition, pars)
  265. if err != nil {
  266. br.Msg = "获取失败"
  267. br.ErrMsg = "获取失败,Err:" + err.Error()
  268. return
  269. }
  270. condition += ` ORDER BY art.active_state ASC, art.activity_time ASC `
  271. list, errList := models.GetActivityListAll(condition, pars, uid, startSize, pageSize)
  272. if errList != nil {
  273. br.Msg = "获取失败"
  274. br.ErrMsg = "获取失败,Err:" + errList.Error()
  275. return
  276. }
  277. for k, v := range list {
  278. if strings.Contains(v.ActivityName, "【") {
  279. list[k].IsBrackets = 1
  280. }
  281. if v.SignupNum > v.LimitPeopleNum {
  282. list[k].SignupNum = v.LimitPeopleNum
  283. }
  284. }
  285. page := paging.GetPaging(currentIndex, pageSize, total)
  286. resp := new(models.GetCygxActivityListRep)
  287. resp.List = list
  288. resp.Paging = page
  289. br.Ret = 200
  290. br.Success = true
  291. br.Msg = "获取成功"
  292. br.Data = resp
  293. }
  294. // @Title 我的日程
  295. // @Description 我的日程列表接口
  296. // @Param PageSize query int true "每页数据条数"
  297. // @Param CurrentIndex query int true "当前页页码,从1开始"
  298. // @Success 200 {object} models.GetCygxActivityListRep
  299. // @router /scheduleList [get]
  300. func (this *ActivityCoAntroller) ScheduleList() {
  301. br := new(models.BaseResponse).Init()
  302. defer func() {
  303. this.Data["json"] = br
  304. this.ServeJSON()
  305. }()
  306. user := this.User
  307. if user == nil {
  308. br.Msg = "请登录"
  309. br.ErrMsg = "请登录,SysUser Is Empty"
  310. return
  311. }
  312. uid := user.UserId
  313. pageSize, _ := this.GetInt("PageSize")
  314. currentIndex, _ := this.GetInt("CurrentIndex")
  315. var startSize int
  316. if pageSize <= 0 {
  317. pageSize = utils.PageSize20
  318. }
  319. if currentIndex <= 0 {
  320. currentIndex = 1
  321. }
  322. startSize = utils.StartIndex(currentIndex, pageSize)
  323. var condition string
  324. var pars []interface{}
  325. //condition += ` AND art.publish_status = 1 AND art.active_state IN(1,2) AND s.is_cancel = 0 AND s.fail_type = 0 `
  326. condition += ` AND art.publish_status = 1 AND art.active_state IN(1,2) `
  327. total, err := models.GetScheduleCount(uid)
  328. if err != nil {
  329. br.Msg = "获取失败"
  330. br.ErrMsg = "获取失败,Err:" + err.Error()
  331. return
  332. }
  333. list, errList := models.GetScheduleList(condition, pars, uid, startSize, pageSize)
  334. if errList != nil {
  335. br.Msg = "获取失败"
  336. br.ErrMsg = "获取失败,Err:" + errList.Error()
  337. return
  338. }
  339. for k, v := range list {
  340. if strings.Contains(v.ActivityName, "【") {
  341. list[k].IsBrackets = 1
  342. }
  343. if v.SignupNum > v.LimitPeopleNum {
  344. list[k].SignupNum = v.LimitPeopleNum
  345. }
  346. }
  347. page := paging.GetPaging(currentIndex, pageSize, total)
  348. resp := new(models.GetCygxActivityListRep)
  349. resp.List = list
  350. resp.Paging = page
  351. br.Ret = 200
  352. br.Success = true
  353. br.Msg = "获取成功"
  354. br.Data = resp
  355. }
  356. // @Title 活动详情
  357. // @Description 获取活动详情接口
  358. // @Param ActivityId query int true "活动ID"
  359. // @Success Ret=200 {object} models.CygxActivityResp
  360. // @router /detail [get]
  361. func (this *ActivityCoAntroller) Detail() {
  362. br := new(models.BaseResponse).Init()
  363. defer func() {
  364. this.Data["json"] = br
  365. this.ServeJSON()
  366. }()
  367. user := this.User
  368. if user == nil {
  369. br.Msg = "请登录"
  370. br.ErrMsg = "请登录,用户信息为空"
  371. br.Ret = 408
  372. return
  373. }
  374. uid := user.UserId
  375. activityId, _ := this.GetInt("ActivityId")
  376. if activityId < 1 {
  377. br.Msg = "请输入活动ID"
  378. return
  379. }
  380. resp := new(models.CygxActivityResp)
  381. hasPermission := 0
  382. var companyDetailStatus string
  383. activityInfo, err := models.GetAddActivityInfoByIdShow(uid, activityId)
  384. if err != nil && err.Error() != utils.ErrNoRow() {
  385. br.Msg = "获取信息失败"
  386. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  387. return
  388. }
  389. if activityInfo == nil {
  390. br.Msg = "活动不存在"
  391. br.ErrMsg = "活动ID错误,Err:" + "activityId:" + strconv.Itoa(activityId)
  392. return
  393. }
  394. applyCount, err := models.GetApplyRecordCount(uid)
  395. if err != nil && err.Error() != utils.ErrNoRow() {
  396. br.Msg = "获取信息失败"
  397. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  398. return
  399. }
  400. if user.CompanyId <= 1 {
  401. companyDetailStatus = ""
  402. } else {
  403. companyPermission, err := models.GetCompanyPermission(user.CompanyId)
  404. if err != nil {
  405. br.Msg = "获取信息失败"
  406. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  407. return
  408. }
  409. if companyPermission == "" {
  410. if applyCount > 0 {
  411. hasPermission = 4
  412. } else {
  413. hasPermission = 3
  414. }
  415. resp.HasPermission = hasPermission
  416. resp.OperationMode = "Apply"
  417. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  418. br.Ret = 200
  419. br.Success = true
  420. br.Msg = "获取成功"
  421. br.Data = resp
  422. return
  423. }
  424. companyDetail, err := models.GetCompanyDetailById(user.CompanyId)
  425. if err != nil {
  426. br.Msg = "获取信息失败!"
  427. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  428. return
  429. }
  430. if companyDetail == nil {
  431. br.Msg = "获取信息失败!"
  432. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId)
  433. return
  434. }
  435. companyDetailStatus = companyDetail.Status
  436. }
  437. var userType int
  438. var permissionStr string
  439. if user.CompanyId <= 1 {
  440. userType = 0
  441. } else {
  442. companyDetail, err := models.GetCompanyDetailById(user.CompanyId)
  443. if err != nil {
  444. br.Msg = "获取信息失败!"
  445. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  446. return
  447. }
  448. if companyDetail == nil {
  449. br.Msg = "获取信息失败!"
  450. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId)
  451. return
  452. }
  453. //1、永续客户
  454. //2、大套餐客户(4个行业全开通的正式客户)
  455. //3、分行业套餐客户(开通对应行业的正式客户)
  456. //4、仅开通专家套餐的正式客户
  457. //5、开通对应行业套餐或专家套餐的试用客户
  458. if companyDetail.Status == "永续" {
  459. userType = 1
  460. } else if companyDetail.Status == "试用" {
  461. userType = 5
  462. } else if companyDetail.Status == "正式" {
  463. permissionStr, err = models.GetCompanyPermission(user.CompanyId)
  464. if err != nil {
  465. br.Msg = "获取信息失败"
  466. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  467. return
  468. }
  469. if permissionStr == "专家" {
  470. userType = 4
  471. } else if strings.Contains(permissionStr, "医药") && strings.Contains(permissionStr, "消费") && strings.Contains(permissionStr, "科技") && strings.Contains(permissionStr, "智造") {
  472. userType = 2
  473. } else {
  474. userType = 3
  475. }
  476. }
  477. }
  478. if activityInfo.IsLimitPeople > 0 {
  479. var noPower bool
  480. if (userType == 1 || userType == 4 || userType == 5) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(userType)) {
  481. noPower = true
  482. }
  483. //带有专家权限的 2、大套餐客户(4个行业全开通的正式客户) 3、分行业套餐客户(开通对应行业的正式客户)
  484. 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)) {
  485. noPower = true
  486. }
  487. if userType == 2 && !strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(2)) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) {
  488. noPower = true
  489. }
  490. if userType == 3 && strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(4)) {
  491. noPower = true
  492. }
  493. if userType == 3 && !strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) {
  494. noPower = true
  495. }
  496. if noPower {
  497. br.Msg = "您暂无查看该活动权限"
  498. br.ErrMsg = "被分享客户不可见,获取信息失败,Err:"
  499. return
  500. }
  501. }
  502. fmt.Println("权限可见校验")
  503. detail, errDetail := models.GetActivityTypeDetailById(activityInfo.ActivityTypeId)
  504. if errDetail != nil {
  505. br.Msg = "获取信息失败"
  506. br.ErrMsg = "获取信息失败,Err:" + errDetail.Error()
  507. return
  508. }
  509. if activityInfo.IsSignup > 0 {
  510. detail, errDetail := models.GetActivitySignupDetail(activityId, uid)
  511. if errDetail != nil {
  512. br.Msg = "获取信息失败"
  513. br.ErrMsg = "获取信息失败,Err:" + errDetail.Error()
  514. return
  515. }
  516. activityInfo.SignupType = detail.SignupType
  517. }
  518. activityInfo.ShowType = detail.ShowType
  519. //判断是否已经申请过
  520. if user.CompanyId > 1 {
  521. permissionStr, err := models.GetCompanyPermission(user.CompanyId)
  522. if err != nil {
  523. br.Msg = "获取信息失败"
  524. br.ErrMsg = "获取客户权限信息失败,Err:" + err.Error()
  525. return
  526. }
  527. companyItem, err := models.GetCompanyDetailAllById(user.CompanyId)
  528. //冻结客户
  529. if err != nil {
  530. if err.Error() == utils.ErrNoRow() {
  531. resp.HasPermission = 4
  532. resp.OperationMode = "Apply"
  533. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动"
  534. br.Ret = 200
  535. br.Success = true
  536. br.Msg = "获取成功"
  537. br.Data = resp
  538. return
  539. } else {
  540. br.Msg = "获取信息失败"
  541. br.ErrMsg = "获取客户公司信息失败,Err:" + err.Error()
  542. return
  543. }
  544. }
  545. //1专家电话会、2分析师电话会、3公司调研电话会、4公司线下调研、5专家线下沙龙、6分析师线下沙龙
  546. //OperationMode string `description:"操作方式 Apply:立即申请、Call:拨号 为空则为有权限"`
  547. var havePower bool
  548. if (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 3) && strings.Contains(permissionStr, "专家") && activityInfo.LimitPeopleNum == 0 {
  549. havePower = true
  550. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "正式" && strings.Contains(activityInfo.CustomerTypeIds, "4") {
  551. havePower = true
  552. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "试用" && strings.Contains(activityInfo.CustomerTypeIds, "5") {
  553. havePower = true
  554. } else if strings.Contains(permissionStr, activityInfo.ChartPermissionName) && strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(userType)) {
  555. havePower = true
  556. } else if strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  557. havePower = true
  558. }
  559. if havePower {
  560. hasPermission = 1
  561. resp.HaqveJurisdiction = true
  562. } else {
  563. if permissionStr == "专家" {
  564. resp.PopupMsg = "您暂无权限参加【" + activityInfo.ActivityTypeName + "】类型活动"
  565. resp.MsgType = "Type"
  566. } else {
  567. resp.PopupMsg = "您暂无权限参加【" + activityInfo.ChartPermissionName + "】行业活动"
  568. resp.MsgType = "Industry"
  569. }
  570. resp.SellerMobile = companyItem.Mobile
  571. resp.SellerName = companyItem.SellerName
  572. resp.OperationMode = "Call"
  573. hasPermission = 2
  574. }
  575. } else { //潜在客户
  576. if applyCount > 0 {
  577. hasPermission = 4
  578. } else {
  579. hasPermission = 3
  580. }
  581. resp.OperationMode = "Apply"
  582. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  583. }
  584. if hasPermission == 1 {
  585. if activityInfo.SignupNum > activityInfo.LimitPeopleNum {
  586. activityInfo.SignupNum = activityInfo.LimitPeopleNum
  587. }
  588. resp.Detail = activityInfo
  589. }
  590. resp.HasPermission = hasPermission
  591. br.Ret = 200
  592. br.Success = true
  593. br.Msg = "获取成功"
  594. br.Data = resp
  595. }
  596. // @Title 活动报名
  597. // @Description 活动报名接口
  598. // @Param request body models.ActivitySingnupRep true "type json string"
  599. // @Success Ret=200 {object} models.SignupStatus
  600. // @router /signup/add [post]
  601. func (this *ActivityCoAntroller) SignupAdd() {
  602. br := new(models.BaseResponse).Init()
  603. defer func() {
  604. this.Data["json"] = br
  605. this.ServeJSON()
  606. }()
  607. user := this.User
  608. if user == nil {
  609. br.Msg = "请登录"
  610. br.ErrMsg = "请登录,用户信息为空"
  611. br.Ret = 408
  612. return
  613. }
  614. fmt.Println(user.Mobile)
  615. uid := user.UserId
  616. //var signupStatus string
  617. signupStatus := ""
  618. var req models.ActivitySingnupRep
  619. resp := new(models.SignupStatus)
  620. var total int
  621. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  622. if err != nil {
  623. br.Msg = "参数解析异常!"
  624. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  625. return
  626. }
  627. activityId := req.ActivityId
  628. signupType := req.SignupType
  629. hasPermission := 0
  630. //判断是否已经申请过
  631. applyCount, err := models.GetApplyRecordCount(uid)
  632. if err != nil && err.Error() != utils.ErrNoRow() {
  633. br.Msg = "获取信息失败"
  634. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  635. return
  636. }
  637. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  638. if activityInfo == nil {
  639. br.Msg = "操作失败"
  640. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  641. return
  642. }
  643. if errInfo != nil {
  644. br.Msg = "操作失败"
  645. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  646. return
  647. }
  648. //SignupStatus "报名状态:人数已满:FullStarffed、单机构超过两人:TwoPeople、爽约次数过多:BreakPromise、超时:Overtime 、成功:Success"`
  649. //HasPermission "1:有该行业权限,正常展示,2:无该行业权限,3:潜在客户,未提交过申请,4:潜在客户,已提交过申请"`
  650. var companyDetailStatus string
  651. if user.CompanyId <= 1 {
  652. companyDetailStatus = ""
  653. } else {
  654. companyPermission, err := models.GetCompanyPermission(user.CompanyId)
  655. if err != nil {
  656. br.Msg = "获取信息失败"
  657. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  658. return
  659. }
  660. if companyPermission == "" {
  661. if applyCount > 0 {
  662. hasPermission = 4
  663. } else {
  664. hasPermission = 3
  665. }
  666. resp.HasPermission = hasPermission
  667. resp.OperationMode = "Apply"
  668. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  669. br.Ret = 200
  670. br.Success = true
  671. br.Msg = "获取成功"
  672. br.Data = resp
  673. return
  674. }
  675. companyDetail, err := models.GetCompanyDetailById(user.CompanyId)
  676. if err != nil {
  677. br.Msg = "获取信息失败!"
  678. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  679. return
  680. }
  681. if companyDetail == nil {
  682. br.Msg = "获取信息失败!"
  683. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId)
  684. return
  685. }
  686. companyDetailStatus = companyDetail.Status
  687. }
  688. var userType int
  689. var permissionStr string
  690. if user.CompanyId <= 1 {
  691. userType = 0
  692. } else {
  693. companyDetail, err := models.GetCompanyDetailById(user.CompanyId)
  694. if err != nil {
  695. br.Msg = "获取信息失败!"
  696. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  697. return
  698. }
  699. if companyDetail == nil {
  700. br.Msg = "获取信息失败!"
  701. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId)
  702. return
  703. }
  704. if companyDetail.Status == "永续" {
  705. userType = 1
  706. } else if companyDetail.Status == "试用" {
  707. userType = 5
  708. } else if companyDetail.Status == "正式" {
  709. permissionStr, err = models.GetCompanyPermission(user.CompanyId)
  710. if err != nil {
  711. br.Msg = "获取信息失败"
  712. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  713. return
  714. }
  715. if permissionStr == "专家" {
  716. userType = 4
  717. } else if strings.Contains(permissionStr, "医药") && strings.Contains(permissionStr, "消费") && strings.Contains(permissionStr, "科技") && strings.Contains(permissionStr, "智造") {
  718. userType = 2
  719. } else {
  720. userType = 3
  721. }
  722. }
  723. }
  724. item := new(models.CygxActivitySignup)
  725. if user.CompanyId > 1 {
  726. permissionStr, err := models.GetCompanyPermission(user.CompanyId)
  727. if err != nil {
  728. br.Msg = "获取信息失败"
  729. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  730. return
  731. }
  732. companyItem, err := models.GetCompanyDetailAllById(user.CompanyId)
  733. //冻结客户
  734. if err != nil {
  735. if err.Error() == utils.ErrNoRow() {
  736. resp.HasPermission = 4
  737. resp.OperationMode = "Apply"
  738. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  739. br.Ret = 200
  740. br.Success = true
  741. br.Msg = "获取成功"
  742. br.Data = resp
  743. return
  744. } else {
  745. br.Msg = "获取信息失败"
  746. br.ErrMsg = "获取客户公司信息失败,Err:" + err.Error()
  747. return
  748. }
  749. }
  750. //1专家电话会、2分析师电话会、3公司调研电话会、4公司线下调研、5专家线下沙龙、6分析师线下沙龙
  751. //OperationMode string `description:"操作方式 Apply:立即申请、Call:拨号 为空则为有权限"`
  752. var havePower bool
  753. if (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 3) && strings.Contains(permissionStr, "专家") && activityInfo.LimitPeopleNum == 0 {
  754. havePower = true
  755. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "正式" && strings.Contains(activityInfo.CustomerTypeIds, "4") {
  756. havePower = true
  757. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "试用" && strings.Contains(activityInfo.CustomerTypeIds, "5") {
  758. havePower = true
  759. } else if strings.Contains(permissionStr, activityInfo.ChartPermissionName) && strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(userType)) {
  760. havePower = true
  761. } else if strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  762. havePower = true
  763. }
  764. if havePower {
  765. hasPermission = 1
  766. signupStatus = "Success"
  767. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  768. if time.Now().After(resultTime.Add(-time.Minute * 60)) {
  769. signupStatus = "Overtime"
  770. resp.SignupType = signupType
  771. resp.SignupStatus = signupStatus
  772. resp.HasPermission = hasPermission
  773. br.Ret = 200
  774. br.Success = true
  775. br.Msg = ""
  776. br.Data = resp
  777. return
  778. }
  779. //人数已满:FullStarffed、单机构超过两人:TwoPeople、爽约次数过多:BreakPromise、超时:Overtime 、成功:Success"`
  780. //如果是下面几种情况则对报名信息做判断限制 (公司调研电话会(限制人数)、公司线下调研、专家/分析师线下沙龙)
  781. if (activityInfo.ActivityTypeId == 3 && activityInfo.IsLimitPeople == 1) || activityInfo.ActivityTypeId > 3 {
  782. //判断优先级:总人数限制→单机构2人限制→爽约3次限制
  783. totalRestrict, err := models.GetUserRestrictCount(user.Mobile)
  784. if err != nil {
  785. br.Msg = "获取信息失败"
  786. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  787. return
  788. }
  789. if totalRestrict >= 1 {
  790. signupStatus = "BreakPromise"
  791. item.FailType = 3
  792. }
  793. totalSignupCompany, err := models.GetActivitySignupCompanyCount(activityId, user.CompanyId)
  794. if err != nil {
  795. br.Msg = "获取信息失败"
  796. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  797. return
  798. }
  799. if totalSignupCompany >= 2 {
  800. signupStatus = "TwoPeople"
  801. item.FailType = 2
  802. }
  803. totaSignupPeopleNum, err := models.GetActivitySignupSuccessCount(activityId)
  804. if err != nil {
  805. br.Msg = "获取信息失败"
  806. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  807. return
  808. }
  809. if totaSignupPeopleNum >= activityInfo.LimitPeopleNum {
  810. signupStatus = "FullStarffed"
  811. item.FailType = 1
  812. }
  813. totalUserRestrictCount, err := models.GetActivitySignupByUserRestrictCount(uid, activityId)
  814. if err != nil {
  815. br.Msg = "获取失败"
  816. br.ErrMsg = "获取失败,Err:" + err.Error()
  817. return
  818. }
  819. //解除报名限制之后二次报名相同活动
  820. if totalUserRestrictCount > 0 && totalRestrict == 0 {
  821. item.UserId = uid
  822. item.ActivityId = activityId
  823. item.CreateTime = time.Now()
  824. item.Mobile = user.Mobile
  825. item.Email = user.Email
  826. item.CompanyId = user.CompanyId
  827. item.CompanyName = user.CompanyName
  828. item.SignupType = signupType
  829. item.FailType = 0
  830. item.DoFailType = 0
  831. _, errSignup := models.AddActivitySignupByRestrict(item)
  832. if errSignup != nil {
  833. br.Msg = "操作失败"
  834. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  835. return
  836. }
  837. resp.HaqveJurisdiction = true
  838. resp.SignupType = signupType
  839. resp.SignupStatus = "Success"
  840. resp.HasPermission = hasPermission
  841. resp.ActivityId = activityId
  842. total, err = models.GetUserMeetingReminderCount(user.UserId)
  843. if err != nil {
  844. br.Msg = "获取信息失败"
  845. br.ErrMsg = "获取日程数量信息失败,Err:" + err.Error()
  846. return
  847. }
  848. if total == 0 {
  849. resp.GoFollow = true
  850. }
  851. br.Ret = 200
  852. br.Success = true
  853. br.Msg = "操作成功"
  854. br.Data = resp
  855. return
  856. }
  857. totalMy, err := models.GetActivitySignupByUserCount(uid, activityId)
  858. if err != nil {
  859. br.Msg = "获取失败"
  860. br.ErrMsg = "获取失败,Err:" + err.Error()
  861. return
  862. }
  863. if signupStatus != "Success" && totalMy == 0 {
  864. item.UserId = uid
  865. item.ActivityId = activityId
  866. item.CreateTime = time.Now()
  867. item.Mobile = user.Mobile
  868. item.Email = user.Email
  869. item.CompanyId = user.CompanyId
  870. item.CompanyName = user.CompanyName
  871. item.SignupType = signupType
  872. item.DoFailType = item.FailType
  873. //添加报名信息,但是不加入日程
  874. _, errSignup := models.AddActivitySignupNoSchedule(item)
  875. if errSignup != nil {
  876. br.Msg = "操作失败"
  877. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  878. return
  879. }
  880. }
  881. }
  882. totalMySuccess, err := models.GetActivitySignupCount(uid, activityId)
  883. fmt.Println(totalMySuccess)
  884. fmt.Println(signupStatus)
  885. if err != nil {
  886. br.Msg = "获取失败"
  887. br.ErrMsg = "获取失败,Err:" + err.Error()
  888. return
  889. }
  890. if totalMySuccess > 0 {
  891. br.Msg = "您已报名这个活动"
  892. return
  893. }
  894. if signupStatus == "Success" {
  895. item.UserId = uid
  896. item.ActivityId = activityId
  897. item.CreateTime = time.Now()
  898. item.Mobile = user.Mobile
  899. item.Email = user.Email
  900. item.CompanyId = user.CompanyId
  901. item.CompanyName = user.CompanyName
  902. item.SignupType = signupType
  903. item.FailType = 0
  904. item.DoFailType = 0
  905. _, errSignup := models.AddActivitySignup(item)
  906. if errSignup != nil {
  907. br.Msg = "操作失败"
  908. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  909. return
  910. }
  911. resp.HaqveJurisdiction = true
  912. }
  913. } else {
  914. hasPermission = 2
  915. resp.SellerMobile = companyItem.Mobile
  916. resp.SellerName = companyItem.SellerName
  917. resp.MsgType = "Type"
  918. resp.OperationMode = "Call"
  919. if permissionStr == "专家" {
  920. resp.PopupMsg = "您暂无权限参加【" + activityInfo.ActivityTypeName + "】类型活动,若想参加请联系对口销售--" + companyItem.SellerName + ":" + companyItem.Mobile
  921. resp.MsgType = "Type"
  922. } else {
  923. resp.PopupMsg = "您暂无权限参加【" + activityInfo.ChartPermissionName + "】行业活动,若想参加请联系对口销售--" + companyItem.SellerName + ":" + companyItem.Mobile
  924. resp.MsgType = "Industry"
  925. }
  926. }
  927. } else { //潜在客户
  928. if applyCount > 0 {
  929. hasPermission = 4
  930. } else {
  931. hasPermission = 3
  932. }
  933. resp.OperationMode = "Apply"
  934. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  935. }
  936. resp.SignupType = signupType
  937. resp.SignupStatus = signupStatus
  938. resp.HasPermission = hasPermission
  939. if signupStatus == "Success" {
  940. resp.ActivityId = activityId
  941. }
  942. total, err = models.GetUserSignupCount(user.UserId)
  943. if err != nil {
  944. br.Msg = "获取信息失败"
  945. br.ErrMsg = "获取日程数量信息失败,Err:" + err.Error()
  946. return
  947. }
  948. if total <= 1 {
  949. resp.GoFollow = true
  950. }
  951. br.Ret = 200
  952. br.Success = true
  953. br.Msg = "操作成功"
  954. br.Data = resp
  955. }
  956. // @Title 活动取消报名
  957. // @Description 活动取消报名接口
  958. // @Param request body models.ActivitySingnupRep true "type json string"
  959. // @Success Ret=200 {object} models.SignupStatus
  960. // @router /signup/cancel [post]
  961. func (this *ActivityCoAntroller) SignupCancel() {
  962. br := new(models.BaseResponse).Init()
  963. defer func() {
  964. this.Data["json"] = br
  965. this.ServeJSON()
  966. }()
  967. user := this.User
  968. if user == nil {
  969. br.Msg = "请登录"
  970. br.ErrMsg = "请登录,用户信息为空"
  971. br.Ret = 408
  972. return
  973. }
  974. uid := user.UserId
  975. var req models.ActivitySingnupRep
  976. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  977. if err != nil {
  978. br.Msg = "参数解析异常!"
  979. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  980. return
  981. }
  982. activityId := req.ActivityId
  983. signupType := req.SignupType
  984. item := new(models.CygxActivitySignup)
  985. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  986. if activityInfo == nil {
  987. br.Msg = "操作失败"
  988. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  989. return
  990. }
  991. if errInfo != nil {
  992. br.Msg = "操作失败"
  993. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  994. return
  995. }
  996. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  997. if time.Now().After(resultTime.Add(-time.Minute * 60)) {
  998. if signupType == 1 {
  999. br.Msg = "活动开始前1小时内无法取消预约外呼,请联系对口销售处理"
  1000. } else {
  1001. br.Msg = "活动开始前1小时内无法取消报名,请联系对口销售处理"
  1002. }
  1003. return
  1004. }
  1005. total, err := models.GetActivitySignupCount(uid, activityId)
  1006. if err != nil {
  1007. br.Msg = "获取失败"
  1008. br.ErrMsg = "获取失败,Err:" + err.Error()
  1009. return
  1010. }
  1011. if total == 0 {
  1012. br.Msg = "您暂未报名这个活动"
  1013. return
  1014. }
  1015. item.UserId = uid
  1016. item.ActivityId = activityId
  1017. item.CreateTime = time.Now()
  1018. item.Mobile = user.Mobile
  1019. item.Email = user.Email
  1020. item.CompanyId = user.CompanyId
  1021. item.CompanyName = user.CompanyName
  1022. resp := new(models.SignupStatus)
  1023. resp.ActivityId = activityId
  1024. _, errSignup := models.CancelActivitySignup(item)
  1025. if errSignup != nil {
  1026. br.Msg = "操作失败"
  1027. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  1028. return
  1029. }
  1030. br.Ret = 200
  1031. br.Success = true
  1032. br.Msg = "操作成功"
  1033. br.Data = resp
  1034. }
  1035. // @Title 用户搜索详情
  1036. // @Description 获取用户搜索详情接口
  1037. // @Param IsShowJurisdiction query int true "是否仅展示有权限的,默认为0,1是,2否 "
  1038. // @Success Ret=200 {object} models.ActivityUserSearchContentList
  1039. // @router /getUserSearchContent [get]
  1040. func (this *ActivityCoAntroller) GetUserSearchContent() {
  1041. br := new(models.BaseResponse).Init()
  1042. defer func() {
  1043. this.Data["json"] = br
  1044. this.ServeJSON()
  1045. }()
  1046. user := this.User
  1047. if user == nil {
  1048. br.Msg = "请登录"
  1049. br.ErrMsg = "请登录,用户信息为空"
  1050. br.Ret = 408
  1051. return
  1052. }
  1053. uid := user.UserId
  1054. detailSeearch := new(models.CygxActivityUserSearchContent)
  1055. detailSeearch.IsShowJurisdiction = 0
  1056. detailSeearch.ChartPermissionids = ""
  1057. detailSeearch.ActiveState = ""
  1058. resp := new(models.ActivityUserSearchContentList)
  1059. detail, _ := models.GetUserSearchContentByUid(uid)
  1060. if detail == nil {
  1061. detail = detailSeearch
  1062. }
  1063. isShowJurisdiction, _ := this.GetInt("IsShowJurisdiction")
  1064. listActivityType, errActivityType := models.GetActivityTypeList()
  1065. if errActivityType != nil {
  1066. br.Msg = "获取失败"
  1067. br.ErrMsg = "获取数据失败,Err:" + errActivityType.Error()
  1068. return
  1069. }
  1070. var listChartPermissionid []*models.ActivityChartPermission
  1071. var errChart error
  1072. if isShowJurisdiction == 1 {
  1073. listChartPermissionidAll, errChartAll := models.GetUserCompanyPermission(user.CompanyId)
  1074. listChartPermissionid = listChartPermissionidAll
  1075. errChart = errChartAll
  1076. } else if isShowJurisdiction == 2 {
  1077. listChartPermissionidAll, errChartAll := models.GetChartPermissionActivity()
  1078. listChartPermissionid = listChartPermissionidAll
  1079. errChart = errChartAll
  1080. } else {
  1081. if detail.IsShowJurisdiction == 1 {
  1082. listChartPermissionidAll, errChartAll := models.GetUserCompanyPermission(user.CompanyId)
  1083. listChartPermissionid = listChartPermissionidAll
  1084. errChart = errChartAll
  1085. } else {
  1086. listChartPermissionidAll, errChartAll := models.GetChartPermissionActivity()
  1087. listChartPermissionid = listChartPermissionidAll
  1088. errChart = errChartAll
  1089. }
  1090. }
  1091. if errChart != nil {
  1092. br.Msg = "获取信息失败"
  1093. br.ErrMsg = "获取品种信息失败,Err:" + errChart.Error()
  1094. return
  1095. }
  1096. if detail.IsShowJurisdiction == 1 {
  1097. resp.IsShowJurisdiction = true
  1098. }
  1099. fmt.Println(isShowJurisdiction)
  1100. if isShowJurisdiction == 1 || detail.IsShowJurisdiction == 1 {
  1101. resp.IsShowJurisdiction = true
  1102. for k, _ := range listChartPermissionid {
  1103. listChartPermissionid[k].IsChoose = true
  1104. }
  1105. }
  1106. if isShowJurisdiction == 2 {
  1107. resp.IsShowJurisdiction = false
  1108. }
  1109. activeStateList := []models.ActivityStaus{models.ActivityStaus{Id: 1, StatusName: "未开始", IsChoose: true}, models.ActivityStaus{Id: 2, StatusName: "进行中"}, models.ActivityStaus{Id: 3, StatusName: "已结束"}}
  1110. list2, err := models.GetChartPermissionActivity()
  1111. if err != nil {
  1112. br.Msg = "获取信息失败"
  1113. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  1114. return
  1115. }
  1116. resp.ListChartPermission2 = list2
  1117. if activeStateList[1].IsChoose == activeStateList[2].IsChoose == false {
  1118. activeStateList[0].IsChoose = true
  1119. }
  1120. resp.ListActivityType = listActivityType
  1121. resp.ListChartPermission = listChartPermissionid
  1122. resp.ListActivityStaus = activeStateList
  1123. br.Ret = 200
  1124. br.Success = true
  1125. br.Msg = "获取成功"
  1126. br.Data = resp
  1127. }
  1128. // @Title 添加会议提醒
  1129. // @Description 添加会议提醒接口
  1130. // @Param request body models.ActivityIdRep true "type json string"
  1131. // @Success Ret=200 {object} models.SignupStatus
  1132. // @router /meetingReminder/add [post]
  1133. func (this *ActivityCoAntroller) MeetingReminderAdd() {
  1134. br := new(models.BaseResponse).Init()
  1135. defer func() {
  1136. this.Data["json"] = br
  1137. this.ServeJSON()
  1138. }()
  1139. user := this.User
  1140. if user == nil {
  1141. br.Msg = "请登录"
  1142. br.ErrMsg = "请登录,用户信息为空"
  1143. br.Ret = 408
  1144. return
  1145. }
  1146. uid := user.UserId
  1147. //var signupStatus string
  1148. signupStatus := "Success"
  1149. var req models.ActivityIdRep
  1150. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1151. if err != nil {
  1152. br.Msg = "参数解析异常!"
  1153. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1154. return
  1155. }
  1156. activityId := req.ActivityId
  1157. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  1158. if activityInfo == nil {
  1159. br.Msg = "操作失败"
  1160. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  1161. return
  1162. }
  1163. if errInfo != nil {
  1164. br.Msg = "操作失败"
  1165. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  1166. return
  1167. }
  1168. //判断是否已经申请过
  1169. applyCount, err := models.GetApplyRecordCount(uid)
  1170. if err != nil && err.Error() != utils.ErrNoRow() {
  1171. br.Msg = "获取信息失败"
  1172. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  1173. return
  1174. }
  1175. //SignupStatus string `description:"报名状态:人数已满:FullStarffed、单机构超过两人:TwoPeople、爽约次数过多:BreakPromise、超时:Overtime 、成功:Success"`
  1176. item := new(models.CygxActivityMeetingReminder)
  1177. resp := new(models.SignupStatus)
  1178. hasPermission := 0
  1179. var companyDetailStatus string
  1180. if user.CompanyId <= 1 {
  1181. companyDetailStatus = ""
  1182. } else {
  1183. companyPermission, err := models.GetCompanyPermission(user.CompanyId)
  1184. if err != nil {
  1185. br.Msg = "获取信息失败"
  1186. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  1187. return
  1188. }
  1189. if companyPermission == "" {
  1190. if applyCount > 0 {
  1191. hasPermission = 4
  1192. } else {
  1193. hasPermission = 3
  1194. }
  1195. resp.HasPermission = hasPermission
  1196. resp.OperationMode = "Apply"
  1197. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  1198. br.Ret = 200
  1199. br.Success = true
  1200. br.Msg = "获取成功"
  1201. br.Data = resp
  1202. return
  1203. }
  1204. companyDetail, err := models.GetCompanyDetailById(user.CompanyId)
  1205. if err != nil {
  1206. br.Msg = "获取信息失败!"
  1207. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  1208. return
  1209. }
  1210. if companyDetail == nil {
  1211. br.Msg = "获取信息失败!"
  1212. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId)
  1213. return
  1214. }
  1215. companyDetailStatus = companyDetail.Status
  1216. }
  1217. var userType int
  1218. var permissionStr string
  1219. if user.CompanyId <= 1 {
  1220. userType = 0
  1221. } else {
  1222. companyDetail, err := models.GetCompanyDetailById(user.CompanyId)
  1223. if err != nil {
  1224. br.Msg = "获取信息失败!"
  1225. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  1226. return
  1227. }
  1228. if companyDetail == nil {
  1229. br.Msg = "获取信息失败!"
  1230. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId)
  1231. return
  1232. }
  1233. if companyDetail.Status == "永续" {
  1234. userType = 1
  1235. } else if companyDetail.Status == "试用" {
  1236. userType = 5
  1237. } else if companyDetail.Status == "正式" {
  1238. permissionStr, err = models.GetCompanyPermission(user.CompanyId)
  1239. if err != nil {
  1240. br.Msg = "获取信息失败"
  1241. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  1242. return
  1243. }
  1244. if permissionStr == "专家" {
  1245. userType = 4
  1246. } else if strings.Contains(permissionStr, "医药") && strings.Contains(permissionStr, "消费") && strings.Contains(permissionStr, "科技") && strings.Contains(permissionStr, "智造") {
  1247. userType = 2
  1248. } else {
  1249. userType = 3
  1250. }
  1251. }
  1252. }
  1253. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  1254. if time.Now().After(resultTime.Add(-time.Minute * 15)) {
  1255. br.Msg = "活动开始前15分钟无法设置会议提醒"
  1256. return
  1257. }
  1258. if user.CompanyId > 1 {
  1259. permissionStr, err := models.GetCompanyPermission(user.CompanyId)
  1260. if err != nil {
  1261. br.Msg = "获取信息失败"
  1262. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  1263. return
  1264. }
  1265. companyItem, err := models.GetCompanyDetailAllById(user.CompanyId)
  1266. //冻结客户
  1267. if err != nil {
  1268. if err.Error() == utils.ErrNoRow() {
  1269. resp.HasPermission = 4
  1270. resp.OperationMode = "Apply"
  1271. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  1272. br.Ret = 200
  1273. br.Success = true
  1274. br.Msg = "获取成功"
  1275. br.Data = resp
  1276. return
  1277. } else {
  1278. br.Msg = "获取信息失败"
  1279. br.ErrMsg = "获取客户公司信息失败,Err:" + err.Error()
  1280. return
  1281. }
  1282. }
  1283. var havePower bool
  1284. if (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 3) && strings.Contains(permissionStr, "专家") && activityInfo.LimitPeopleNum == 0 {
  1285. havePower = true
  1286. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "正式" && strings.Contains(activityInfo.CustomerTypeIds, "4") {
  1287. havePower = true
  1288. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "试用" && strings.Contains(activityInfo.CustomerTypeIds, "5") {
  1289. havePower = true
  1290. } else if strings.Contains(permissionStr, activityInfo.ChartPermissionName) && strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(userType)) {
  1291. havePower = true
  1292. } else if strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  1293. havePower = true
  1294. }
  1295. if havePower {
  1296. hasPermission = 1
  1297. signupStatus = "Success"
  1298. totalMeeting, errMeeting := models.GetActivityMeetingReminderCount(uid, activityId)
  1299. if errMeeting != nil {
  1300. br.Msg = "获取失败"
  1301. br.ErrMsg = "获取失败,Err:" + errMeeting.Error()
  1302. return
  1303. }
  1304. if totalMeeting > 0 {
  1305. br.Msg = "您已预约,请勿重复预约"
  1306. return
  1307. }
  1308. item.UserId = uid
  1309. item.ActivityId = activityId
  1310. item.CreateTime = time.Now()
  1311. item.Mobile = user.Mobile
  1312. item.Email = user.Email
  1313. item.CompanyId = user.CompanyId
  1314. item.CompanyName = user.CompanyName
  1315. _, errSignup := models.AddActivityMeetingReminder(item)
  1316. if errSignup != nil {
  1317. br.Msg = "操作失败"
  1318. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  1319. return
  1320. }
  1321. resp.HaqveJurisdiction = true
  1322. } else {
  1323. hasPermission = 2
  1324. resp.SellerMobile = companyItem.Mobile
  1325. resp.SellerName = companyItem.SellerName
  1326. resp.MsgType = "Type"
  1327. resp.OperationMode = "Call"
  1328. if permissionStr == "专家" {
  1329. resp.PopupMsg = "您暂无权限参加【" + activityInfo.ActivityTypeName + "】类型活动,若想参加请联系对口销售--" + companyItem.SellerName + ":" + companyItem.Mobile
  1330. resp.MsgType = "Type"
  1331. } else {
  1332. resp.PopupMsg = "您暂无权限参加【" + activityInfo.ChartPermissionName + "】行业活动,若想参加请联系对口销售--" + companyItem.SellerName + ":" + companyItem.Mobile
  1333. resp.MsgType = "Industry"
  1334. }
  1335. }
  1336. } else { //潜在客户
  1337. if applyCount > 0 {
  1338. hasPermission = 4
  1339. } else {
  1340. hasPermission = 3
  1341. }
  1342. resp.OperationMode = "Apply"
  1343. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  1344. }
  1345. resp.HasPermission = hasPermission
  1346. resp.SignupStatus = signupStatus
  1347. resp.ActivityId = activityId
  1348. var total int
  1349. total, err = models.GetUserActivityMeetingReminderCount(user.UserId)
  1350. if err != nil {
  1351. br.Msg = "获取信息失败"
  1352. br.ErrMsg = "获取日程数量信息失败,Err:" + err.Error()
  1353. return
  1354. }
  1355. if total <= 1 {
  1356. resp.GoFollow = true
  1357. }
  1358. br.Ret = 200
  1359. br.Success = true
  1360. if hasPermission == 1 {
  1361. br.Msg = "设置成功,会前15分钟会为您推送微信消息提醒"
  1362. }
  1363. br.Data = resp
  1364. }
  1365. // @Title 取消会议提醒
  1366. // @Description 取消会议提醒接口
  1367. // @Param request body models.ActivityIdRep true "type json string"
  1368. // @Success Ret=200 {object} models.SignupStatus
  1369. // @router /meetingReminder/cancel [post]
  1370. func (this *ActivityCoAntroller) MeetingReminderCancel() {
  1371. br := new(models.BaseResponse).Init()
  1372. defer func() {
  1373. this.Data["json"] = br
  1374. this.ServeJSON()
  1375. }()
  1376. user := this.User
  1377. if user == nil {
  1378. br.Msg = "请登录"
  1379. br.ErrMsg = "请登录,用户信息为空"
  1380. br.Ret = 408
  1381. return
  1382. }
  1383. uid := user.UserId
  1384. var req models.ActivityIdRep
  1385. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1386. if err != nil {
  1387. br.Msg = "参数解析异常!"
  1388. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1389. return
  1390. }
  1391. activityId := req.ActivityId
  1392. signupStatus := "Success"
  1393. item := new(models.CygxActivityMeetingReminder)
  1394. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  1395. if activityInfo == nil {
  1396. br.Msg = "操作失败"
  1397. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  1398. return
  1399. }
  1400. if errInfo != nil {
  1401. br.Msg = "操作失败"
  1402. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  1403. return
  1404. }
  1405. //if signupStatus == "Success" {
  1406. total, err := models.GetActivityMeetingReminderCount(uid, activityId)
  1407. if err != nil {
  1408. br.Msg = "获取失败"
  1409. br.ErrMsg = "获取失败,Err:" + err.Error()
  1410. return
  1411. }
  1412. if total == 0 {
  1413. br.Msg = "您暂未添加该活动会议提醒"
  1414. return
  1415. }
  1416. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  1417. if time.Now().After(resultTime.Add(-time.Minute * 15)) {
  1418. br.Msg = "活动开始前15分钟无法取消会议提醒"
  1419. return
  1420. }
  1421. item.UserId = uid
  1422. item.ActivityId = activityId
  1423. item.CreateTime = time.Now()
  1424. item.Mobile = user.Mobile
  1425. item.Email = user.Email
  1426. item.CompanyId = user.CompanyId
  1427. item.CompanyName = user.CompanyName
  1428. _, errSignup := models.CancelActivityMeetingReminder(item)
  1429. if errSignup != nil {
  1430. br.Msg = "操作失败"
  1431. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  1432. return
  1433. }
  1434. //}
  1435. resp := new(models.SignupStatus)
  1436. resp.SignupStatus = signupStatus
  1437. resp.ActivityId = activityId
  1438. br.Ret = 200
  1439. br.Success = true
  1440. br.Msg = "会议提醒已取消"
  1441. br.Data = resp
  1442. }
  1443. // @Title 敏捷搜索关键词的列表
  1444. // @Description 获取敏捷搜索关键词的列表接口
  1445. // @Success 200 {object} models.ActivityFastsearchKeywordsListResp
  1446. // @router /fastSearchKeWord [get]
  1447. func (this *ActivityABaseController) FastSearch() {
  1448. br := new(models.BaseResponse).Init()
  1449. defer func() {
  1450. this.Data["json"] = br
  1451. this.ServeJSON()
  1452. }()
  1453. resp := new(models.ActivityFastsearchKeywordsListResp)
  1454. list, err := models.GetActivityFastsearchKeywordsList()
  1455. if err != nil {
  1456. br.Msg = "获取失败"
  1457. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  1458. return
  1459. }
  1460. resp.List = list
  1461. br.Ret = 200
  1462. br.Success = true
  1463. br.Msg = "获取成功"
  1464. br.Data = resp
  1465. }