activity.go 32 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021
  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. // @Title 活动类型列表
  17. // @Description活动类型列表接口
  18. // @Success 200 {object} models.ActivityTypeListResp
  19. // @router /activityTypelist [get]
  20. func (this *ActivityCoAntroller) List() {
  21. br := new(models.BaseResponse).Init()
  22. defer func() {
  23. this.Data["json"] = br
  24. this.ServeJSON()
  25. }()
  26. user := this.User
  27. if user == nil {
  28. br.Msg = "请登录"
  29. br.ErrMsg = "请登录,SysUser Is Empty"
  30. br.Ret = 408
  31. return
  32. }
  33. resp := new(models.ActivityTypeListResp)
  34. list, err := models.GetActivityTypeList()
  35. if err != nil {
  36. br.Msg = "获取失败"
  37. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  38. return
  39. }
  40. resp.List = list
  41. br.Ret = 200
  42. br.Success = true
  43. br.Msg = "获取成功"
  44. br.Data = resp
  45. }
  46. // @Title 活动列表
  47. // @Description 获取活动列表接口
  48. // @Param PageSize query int true "每页数据条数"
  49. // @Param CurrentIndex query int true "当前页页码,从1开始"
  50. // @Param ChartPermissionIds query string false "行业id 多个用 , 隔开"
  51. // @Param ActivityTypeIds query string false "活动类型id 多个用 , 隔开"
  52. // @Param KeyWord query string false "搜索关键词"
  53. // @Param ActiveState query string false "活动进行状态 未开始:1、进行中2、已结束3"
  54. // @Param IsShowJurisdiction query int false "是否仅展示有权限的,1是,2否 默认为零"
  55. // @Success 200 {object} models.GetCygxActivityListRep
  56. // @router /list [get]
  57. func (this *ActivityCoAntroller) ActivityList() {
  58. br := new(models.BaseResponse).Init()
  59. defer func() {
  60. this.Data["json"] = br
  61. this.ServeJSON()
  62. }()
  63. user := this.User
  64. if user == nil {
  65. br.Msg = "请登录"
  66. br.ErrMsg = "请登录,SysUser Is Empty"
  67. return
  68. }
  69. uid := user.UserId
  70. pageSize, _ := this.GetInt("PageSize")
  71. currentIndex, _ := this.GetInt("CurrentIndex")
  72. chartPermissionIds := this.GetString("ChartPermissionIds")
  73. activityTypeIds := this.GetString("ActivityTypeIds")
  74. isShowJurisdiction, _ := this.GetInt("IsShowJurisdiction")
  75. keyWord := this.GetString("KeyWord")
  76. activeState := this.GetString("ActiveState")
  77. //if activeState == "" {
  78. // activeState = "1"
  79. //}
  80. //if isShowJurisdiction != 1 {
  81. // isShowJurisdiction = 0
  82. //}
  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. if isShowJurisdiction == 1 && chartPermissionIds == "" {
  102. resp := new(models.GetCygxActivityListRep)
  103. br.Ret = 200
  104. br.Success = true
  105. br.Msg = "获取成功"
  106. br.Data = resp
  107. return
  108. }
  109. var startSize int
  110. if pageSize <= 0 {
  111. pageSize = utils.PageSize20
  112. }
  113. if currentIndex <= 0 {
  114. currentIndex = 1
  115. }
  116. startSize = utils.StartIndex(currentIndex, pageSize)
  117. var condition string
  118. var pars []interface{}
  119. if keyWord != "" {
  120. condition += ` AND (art.activity_name LIKE '%` + keyWord + `%' ) `
  121. }
  122. //行业名称
  123. if len(chartPermissionIds) > 0 {
  124. condition += ` AND art.chart_permission_id IN (` + chartPermissionIds + `)`
  125. }
  126. if activityTypeIds != "" {
  127. condition += ` AND art.activity_type_id IN (` + activityTypeIds + `)`
  128. }
  129. condition += ` AND art.publish_status = 1 `
  130. if activeState != "" {
  131. condition += ` AND art.active_state IN (` + activeState + `) ORDER BY art.active_state ASC`
  132. }
  133. total, err := models.GetActivityCount(condition, pars)
  134. if err != nil {
  135. br.Msg = "获取失败"
  136. br.ErrMsg = "获取失败,Err:" + err.Error()
  137. return
  138. }
  139. condition += ` ORDER BY art.active_state ASC `
  140. //if activeState == "2" || activeState == "3" || activeState == "2,3" {
  141. // condition += ` ORDER BY art.activity_time DESC `
  142. //}
  143. list, errList := models.GetActivityListAll(condition, pars, uid, startSize, pageSize)
  144. if errList != nil {
  145. br.Msg = "获取失败"
  146. br.ErrMsg = "获取失败,Err:" + errList.Error()
  147. return
  148. }
  149. for k, v := range list {
  150. if strings.Contains(v.ActivityName, "【") {
  151. list[k].IsBrackets = 1
  152. }
  153. if v.SignupNum > v.LimitPeopleNum {
  154. list[k].SignupNum = v.LimitPeopleNum
  155. }
  156. }
  157. page := paging.GetPaging(currentIndex, pageSize, total)
  158. resp := new(models.GetCygxActivityListRep)
  159. resp.List = list
  160. resp.Paging = page
  161. br.Ret = 200
  162. br.Success = true
  163. br.Msg = "获取成功"
  164. br.Data = resp
  165. }
  166. // @Title 我的日程
  167. // @Description 我的日程列表接口
  168. // @Param PageSize query int true "每页数据条数"
  169. // @Param CurrentIndex query int true "当前页页码,从1开始"
  170. // @Success 200 {object} models.GetCygxActivityListRep
  171. // @router /scheduleList [get]
  172. func (this *ActivityCoAntroller) ScheduleList() {
  173. br := new(models.BaseResponse).Init()
  174. defer func() {
  175. this.Data["json"] = br
  176. this.ServeJSON()
  177. }()
  178. user := this.User
  179. if user == nil {
  180. br.Msg = "请登录"
  181. br.ErrMsg = "请登录,SysUser Is Empty"
  182. return
  183. }
  184. uid := user.UserId
  185. pageSize, _ := this.GetInt("PageSize")
  186. currentIndex, _ := this.GetInt("CurrentIndex")
  187. var startSize int
  188. if pageSize <= 0 {
  189. pageSize = utils.PageSize20
  190. }
  191. if currentIndex <= 0 {
  192. currentIndex = 1
  193. }
  194. startSize = utils.StartIndex(currentIndex, pageSize)
  195. var condition string
  196. var pars []interface{}
  197. //condition += ` AND art.publish_status = 1 AND art.active_state IN(1,2) AND s.is_cancel = 0 AND s.fail_type = 0 `
  198. condition += ` AND art.publish_status = 1 AND art.active_state IN(1,2) `
  199. total, err := models.GetScheduleCount(uid)
  200. if err != nil {
  201. br.Msg = "获取失败"
  202. br.ErrMsg = "获取失败,Err:" + err.Error()
  203. return
  204. }
  205. list, errList := models.GetScheduleList(condition, pars, uid, startSize, pageSize)
  206. if errList != nil {
  207. br.Msg = "获取失败"
  208. br.ErrMsg = "获取失败,Err:" + errList.Error()
  209. return
  210. }
  211. for k, v := range list {
  212. if strings.Contains(v.ActivityName, "【") {
  213. list[k].IsBrackets = 1
  214. }
  215. if v.SignupNum > v.LimitPeopleNum {
  216. list[k].SignupNum = v.LimitPeopleNum
  217. }
  218. }
  219. page := paging.GetPaging(currentIndex, pageSize, total)
  220. resp := new(models.GetCygxActivityListRep)
  221. resp.List = list
  222. resp.Paging = page
  223. br.Ret = 200
  224. br.Success = true
  225. br.Msg = "获取成功"
  226. br.Data = resp
  227. }
  228. // @Title 活动详情
  229. // @Description 获取活动详情接口
  230. // @Param ActivityId query int true "活动ID"
  231. // @Success Ret=200 {object} models.CygxActivityResp
  232. // @router /detail [get]
  233. func (this *ActivityCoAntroller) Detail() {
  234. br := new(models.BaseResponse).Init()
  235. defer func() {
  236. this.Data["json"] = br
  237. this.ServeJSON()
  238. }()
  239. user := this.User
  240. if user == nil {
  241. br.Msg = "请登录"
  242. br.ErrMsg = "请登录,用户信息为空"
  243. br.Ret = 408
  244. return
  245. }
  246. uid := user.UserId
  247. activityId, _ := this.GetInt("ActivityId")
  248. if activityId < 1 {
  249. br.Msg = "请输入活动ID"
  250. return
  251. }
  252. activityInfo, err := models.GetAddActivityInfoByIdShow(uid, activityId)
  253. if activityInfo == nil {
  254. br.Msg = "活动不存在"
  255. br.ErrMsg = "活动ID错误,Err:" + "activityId:" + strconv.Itoa(activityId)
  256. return
  257. }
  258. detail, errDetail := models.GetActivityTypeDetailById(activityInfo.ActivityTypeId)
  259. if errDetail != nil {
  260. br.Msg = "获取信息失败"
  261. br.ErrMsg = "获取信息失败,Err:" + errDetail.Error()
  262. return
  263. }
  264. if activityInfo.IsSignup > 0 {
  265. detail, errDetail := models.GetActivitySignupDetail(activityId, uid)
  266. if errDetail != nil {
  267. br.Msg = "获取信息失败"
  268. br.ErrMsg = "获取信息失败,Err:" + errDetail.Error()
  269. return
  270. }
  271. activityInfo.SignupType = detail.SignupType
  272. }
  273. activityInfo.ShowType = detail.ShowType
  274. resp := new(models.CygxActivityResp)
  275. hasPermission := 0
  276. //判断是否已经申请过
  277. applyCount, err := models.GetApplyRecordCount(uid)
  278. if err != nil && err.Error() != utils.ErrNoRow() {
  279. br.Msg = "获取信息失败"
  280. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  281. return
  282. }
  283. if user.CompanyId > 1 {
  284. permissionStr, err := models.GetCompanyPermission(user.CompanyId)
  285. if err != nil {
  286. br.Msg = "获取信息失败"
  287. br.ErrMsg = "获取客户权限信息失败,Err:" + err.Error()
  288. return
  289. }
  290. companyItem, err := models.GetCompanyDetailAllById(user.CompanyId)
  291. //冻结客户
  292. if err != nil {
  293. if err.Error() == utils.ErrNoRow() {
  294. resp.HasPermission = 4
  295. resp.OperationMode = "Apply"
  296. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  297. br.Ret = 200
  298. br.Success = true
  299. br.Msg = "获取成功"
  300. br.Data = resp
  301. return
  302. } else {
  303. br.Msg = "获取信息失败"
  304. br.ErrMsg = "获取客户公司信息失败,Err:" + err.Error()
  305. return
  306. }
  307. }
  308. //1专家电话会、2分析师电话会、3公司调研电话会、4公司线下调研、5专家线下沙龙、6分析师线下沙龙
  309. //OperationMode string `description:"操作方式 Apply:立即申请、Call:拨号 为空则为有权限"`
  310. if activityInfo.ActivityTypeId != 1 && activityInfo.ActivityTypeId != 4 && permissionStr == "专家" {
  311. resp.PopupMsg = "您暂无权限参加" + activityInfo.ActivityName + "类型活动,若想参加请联系对口销售--" + companyItem.SellerName + ":" + companyItem.Mobile
  312. resp.SellerMobile = companyItem.Mobile
  313. resp.OperationMode = "Call"
  314. hasPermission = 2
  315. } else {
  316. if strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  317. hasPermission = 1
  318. resp.HaqveJurisdiction = true
  319. } else {
  320. resp.PopupMsg = "您暂无权限参加【" + activityInfo.ChartPermissionName + "】行业活动,若想参加请联系对口销售--" + companyItem.SellerName + ":" + companyItem.Mobile
  321. resp.SellerMobile = companyItem.Mobile
  322. resp.OperationMode = "Call"
  323. hasPermission = 2
  324. }
  325. }
  326. } else { //潜在客户
  327. if applyCount > 0 {
  328. hasPermission = 4
  329. } else {
  330. hasPermission = 3
  331. }
  332. resp.OperationMode = "Apply"
  333. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  334. }
  335. if hasPermission == 1 {
  336. if activityInfo.SignupNum > activityInfo.LimitPeopleNum {
  337. activityInfo.SignupNum = activityInfo.LimitPeopleNum
  338. }
  339. resp.Detail = activityInfo
  340. }
  341. resp.HasPermission = hasPermission
  342. br.Ret = 200
  343. br.Success = true
  344. br.Msg = "获取成功"
  345. br.Data = resp
  346. }
  347. // @Title 活动报名
  348. // @Description 活动报名接口
  349. // @Param request body models.ActivitySingnupRep true "type json string"
  350. // @Success Ret=200 {object} models.SignupStatus
  351. // @router /signup/add [post]
  352. func (this *ActivityCoAntroller) SignupAdd() {
  353. br := new(models.BaseResponse).Init()
  354. defer func() {
  355. this.Data["json"] = br
  356. this.ServeJSON()
  357. }()
  358. user := this.User
  359. if user == nil {
  360. br.Msg = "请登录"
  361. br.ErrMsg = "请登录,用户信息为空"
  362. br.Ret = 408
  363. return
  364. }
  365. uid := user.UserId
  366. //var signupStatus string
  367. signupStatus := ""
  368. var req models.ActivitySingnupRep
  369. var total int
  370. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  371. if err != nil {
  372. br.Msg = "参数解析异常!"
  373. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  374. return
  375. }
  376. activityId := req.ActivityId
  377. signupType := req.SignupType
  378. //SignupStatus "报名状态:人数已满:FullStarffed、单机构超过两人:TwoPeople、爽约次数过多:BreakPromise、超时:Overtime 、成功:Success"`
  379. //HasPermission "1:有该行业权限,正常展示,2:无该行业权限,3:潜在客户,未提交过申请,4:潜在客户,已提交过申请"`
  380. item := new(models.CygxActivitySignup)
  381. resp := new(models.SignupStatus)
  382. hasPermission := 0
  383. //判断是否已经申请过
  384. applyCount, err := models.GetApplyRecordCount(uid)
  385. if err != nil && err.Error() != utils.ErrNoRow() {
  386. br.Msg = "获取信息失败"
  387. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  388. return
  389. }
  390. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  391. if activityInfo == nil {
  392. br.Msg = "操作失败"
  393. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  394. return
  395. }
  396. if errInfo != nil {
  397. br.Msg = "操作失败"
  398. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  399. return
  400. }
  401. if user.CompanyId > 1 {
  402. permissionStr, err := models.GetCompanyPermission(user.CompanyId)
  403. if err != nil {
  404. br.Msg = "获取信息失败"
  405. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  406. return
  407. }
  408. companyItem, err := models.GetCompanyDetailAllById(user.CompanyId)
  409. //if err != nil {
  410. // br.Msg = "获取信息失败"
  411. // br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  412. // return
  413. //}
  414. //冻结客户
  415. if err != nil {
  416. if err.Error() == utils.ErrNoRow() {
  417. resp.HasPermission = 4
  418. resp.OperationMode = "Apply"
  419. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  420. br.Ret = 200
  421. br.Success = true
  422. br.Msg = "获取成功"
  423. br.Data = resp
  424. return
  425. } else {
  426. br.Msg = "获取信息失败"
  427. br.ErrMsg = "获取客户公司信息失败,Err:" + err.Error()
  428. return
  429. }
  430. }
  431. //1专家电话会、2分析师电话会、3公司调研电话会、4公司线下调研、5专家线下沙龙、6分析师线下沙龙
  432. //OperationMode string `description:"操作方式 Apply:立即申请、Call:拨号 为空则为有权限"`
  433. if activityInfo.ActivityTypeId != 1 && activityInfo.ActivityTypeId != 4 && permissionStr == "专家" {
  434. resp.PopupMsg = "您暂无权限参加" + activityInfo.ActivityName + "类型活动,若想参加请联系对口销售--" + companyItem.SellerName + ":" + companyItem.Mobile
  435. resp.SellerMobile = companyItem.Mobile
  436. resp.OperationMode = "Call"
  437. hasPermission = 2
  438. } else {
  439. if strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  440. hasPermission = 1
  441. signupStatus = "Success"
  442. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  443. if time.Now().After(resultTime.Add(-time.Minute * 60)) {
  444. signupStatus = "Overtime"
  445. }
  446. //人数已满:FullStarffed、单机构超过两人:TwoPeople、爽约次数过多:BreakPromise、超时:Overtime 、成功:Success"`
  447. //如果是下面几种情况则对报名信息做判断限制 (公司调研电话会(限制人数)、公司线下调研、专家/分析师线下沙龙)
  448. if (activityInfo.ActivityTypeId == 3 && activityInfo.IsLimitPeople == 1) || activityInfo.ActivityTypeId > 3 {
  449. //判断优先级:总人数限制→单机构2人限制→爽约3次限制
  450. total, err = models.GetUserRestrictCount(user.UserId)
  451. if err != nil {
  452. br.Msg = "获取信息失败"
  453. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  454. return
  455. }
  456. if total >= 1 {
  457. signupStatus = "BreakPromise"
  458. item.FailType = 3
  459. }
  460. total, err = models.GetActivitySignupCompanyCount(activityId, user.CompanyId)
  461. if err != nil {
  462. br.Msg = "获取信息失败"
  463. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  464. return
  465. }
  466. if total >= 2 {
  467. signupStatus = "TwoPeople"
  468. item.FailType = 2
  469. }
  470. total, err = models.GetActivitySignupSuccessCount(activityId)
  471. if err != nil {
  472. br.Msg = "获取信息失败"
  473. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  474. return
  475. }
  476. if total >= activityInfo.LimitPeopleNum {
  477. signupStatus = "FullStarffed"
  478. item.FailType = 1
  479. }
  480. total, err = models.GetActivitySignupCount(uid, activityId)
  481. if err != nil {
  482. br.Msg = "获取失败"
  483. br.ErrMsg = "获取失败,Err:" + err.Error()
  484. return
  485. }
  486. if signupStatus != "Success" && total == 0 {
  487. item.UserId = uid
  488. item.ActivityId = activityId
  489. item.CreateTime = time.Now()
  490. item.Mobile = user.Mobile
  491. item.Email = user.Email
  492. item.CompanyId = user.CompanyId
  493. item.CompanyName = user.CompanyName
  494. item.SignupType = signupType
  495. //添加报名信息,但是不加入日程
  496. _, errSignup := models.AddActivitySignupNoSchedule(item)
  497. if errSignup != nil {
  498. br.Msg = "操作失败"
  499. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  500. return
  501. }
  502. }
  503. }
  504. if signupStatus == "Success" {
  505. total, err = models.GetActivitySignupCount(uid, activityId)
  506. if err != nil {
  507. br.Msg = "获取失败"
  508. br.ErrMsg = "获取失败,Err:" + err.Error()
  509. return
  510. }
  511. if total > 0 {
  512. br.Msg = "您已报名这个活动"
  513. return
  514. }
  515. item.UserId = uid
  516. item.ActivityId = activityId
  517. item.CreateTime = time.Now()
  518. item.Mobile = user.Mobile
  519. item.Email = user.Email
  520. item.CompanyId = user.CompanyId
  521. item.CompanyName = user.CompanyName
  522. item.SignupType = signupType
  523. item.FailType = 0
  524. _, errSignup := models.AddActivitySignup(item)
  525. if errSignup != nil {
  526. br.Msg = "操作失败"
  527. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  528. return
  529. }
  530. resp.HaqveJurisdiction = true
  531. }
  532. } else {
  533. resp.PopupMsg = "您暂无权限参加【" + activityInfo.ChartPermissionName + "】行业活动,若想参加请联系对口销售--" + companyItem.SellerName + ":" + companyItem.Mobile
  534. resp.SellerMobile = companyItem.Mobile
  535. resp.OperationMode = "Call"
  536. hasPermission = 2
  537. }
  538. }
  539. } else { //潜在客户
  540. if applyCount > 0 {
  541. hasPermission = 4
  542. } else {
  543. hasPermission = 3
  544. }
  545. resp.OperationMode = "Apply"
  546. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  547. }
  548. resp.SignupType = signupType
  549. resp.SignupStatus = signupStatus
  550. resp.HasPermission = hasPermission
  551. if signupStatus == "Success" {
  552. resp.ActivityId = activityId
  553. }
  554. total, err = models.GetUserMeetingReminderCount(user.UserId)
  555. if err != nil {
  556. br.Msg = "获取信息失败"
  557. br.ErrMsg = "获取日程数量信息失败,Err:" + err.Error()
  558. return
  559. }
  560. if total == 0 {
  561. resp.GoFollow = true
  562. }
  563. br.Ret = 200
  564. br.Success = true
  565. br.Msg = "操作成功"
  566. br.Data = resp
  567. }
  568. // @Title 活动取消报名
  569. // @Description 活动取消报名接口
  570. // @Param request body models.ActivitySingnupRep true "type json string"
  571. // @Success Ret=200 {object} models.SignupStatus
  572. // @router /signup/cancel [post]
  573. func (this *ActivityCoAntroller) SignupCancel() {
  574. br := new(models.BaseResponse).Init()
  575. defer func() {
  576. this.Data["json"] = br
  577. this.ServeJSON()
  578. }()
  579. user := this.User
  580. if user == nil {
  581. br.Msg = "请登录"
  582. br.ErrMsg = "请登录,用户信息为空"
  583. br.Ret = 408
  584. return
  585. }
  586. uid := user.UserId
  587. var req models.ActivitySingnupRep
  588. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  589. if err != nil {
  590. br.Msg = "参数解析异常!"
  591. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  592. return
  593. }
  594. activityId := req.ActivityId
  595. signupType := req.SignupType
  596. //if signupType != 1 && signupType != 2 {
  597. // br.Msg = "请选择正确的报名方式!"
  598. // return
  599. //}
  600. item := new(models.CygxActivitySignup)
  601. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  602. if activityInfo == nil {
  603. br.Msg = "操作失败"
  604. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  605. return
  606. }
  607. if errInfo != nil {
  608. br.Msg = "操作失败"
  609. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  610. return
  611. }
  612. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  613. if time.Now().After(resultTime.Add(-time.Minute * 60)) {
  614. if signupType == 1 {
  615. br.Msg = "活动开始前1小时内无法取消预约外呼,请联系对口销售处理"
  616. } else {
  617. br.Msg = "活动开始前1小时内无法取消报名,请联系对口销售处理"
  618. }
  619. return
  620. }
  621. total, err := models.GetActivitySignupCount(uid, activityId)
  622. if err != nil {
  623. br.Msg = "获取失败"
  624. br.ErrMsg = "获取失败,Err:" + err.Error()
  625. return
  626. }
  627. if total == 0 {
  628. br.Msg = "您暂未报名这个活动"
  629. return
  630. }
  631. item.UserId = uid
  632. item.ActivityId = activityId
  633. item.CreateTime = time.Now()
  634. item.Mobile = user.Mobile
  635. item.Email = user.Email
  636. item.CompanyId = user.CompanyId
  637. item.CompanyName = user.CompanyName
  638. resp := new(models.SignupStatus)
  639. resp.ActivityId = activityId
  640. _, errSignup := models.CancelActivitySignup(item)
  641. if errSignup != nil {
  642. br.Msg = "操作失败"
  643. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  644. return
  645. }
  646. br.Ret = 200
  647. br.Success = true
  648. br.Msg = "操作成功"
  649. br.Data = resp
  650. }
  651. // @Title 用户搜索详情
  652. // @Description 获取用户搜索详情接口
  653. // @Param IsShowJurisdiction query int true "是否仅展示有权限的,默认为0,1是,2否 "
  654. // @Success Ret=200 {object} models.ActivityUserSearchContentList
  655. // @router /getUserSearchContent [get]
  656. func (this *ActivityCoAntroller) GetUserSearchContent() {
  657. br := new(models.BaseResponse).Init()
  658. defer func() {
  659. this.Data["json"] = br
  660. this.ServeJSON()
  661. }()
  662. user := this.User
  663. if user == nil {
  664. br.Msg = "请登录"
  665. br.ErrMsg = "请登录,用户信息为空"
  666. br.Ret = 408
  667. return
  668. }
  669. uid := user.UserId
  670. detailSeearch := new(models.CygxActivityUserSearchContent)
  671. detailSeearch.IsShowJurisdiction = 0
  672. detailSeearch.ChartPermissionids = ""
  673. detailSeearch.ActiveState = ""
  674. detail, _ := models.GetUserSearchContentByUid(uid)
  675. if detail == nil {
  676. detail = detailSeearch
  677. }
  678. //if err != nil {
  679. // br.Msg = "获取信息失败"
  680. // br.ErrMsg = "获取信息失败,Err:" + err.Error()
  681. // return
  682. //}
  683. isShowJurisdiction, _ := this.GetInt("IsShowJurisdiction")
  684. //chartPermissionidsSlice := strings.Split(detail.ChartPermissionids, ",")
  685. //activityTypeidsSlice := strings.Split(detail.ActivityTypeids, ",")
  686. //activeStateSlice := strings.Split(detail.ActiveState, ",") //"活动进行状态 未开始:1、进行中2、已结束3"`
  687. listActivityType, errActivityType := models.GetActivityTypeList()
  688. if errActivityType != nil {
  689. br.Msg = "获取失败"
  690. br.ErrMsg = "获取数据失败,Err:" + errActivityType.Error()
  691. return
  692. }
  693. //for _, v := range activityTypeidsSlice {
  694. // for k2, v2 := range listActivityType {
  695. // if strconv.Itoa(v2.ActivityTypeId) == v {
  696. // listActivityType[k2].IsChoose = true
  697. // }
  698. // }
  699. //}
  700. var listChartPermissionid []*models.ActivityChartPermission
  701. var errChart error
  702. if isShowJurisdiction == 1 {
  703. listChartPermissionidAll, errChartAll := models.GetUserCompanyPermission(user.CompanyId)
  704. listChartPermissionid = listChartPermissionidAll
  705. errChart = errChartAll
  706. } else if isShowJurisdiction == 2 {
  707. listChartPermissionidAll, errChartAll := models.GetChartPermissionActivity()
  708. listChartPermissionid = listChartPermissionidAll
  709. errChart = errChartAll
  710. } else {
  711. if detail.IsShowJurisdiction == 1 {
  712. listChartPermissionidAll, errChartAll := models.GetUserCompanyPermission(user.CompanyId)
  713. listChartPermissionid = listChartPermissionidAll
  714. errChart = errChartAll
  715. } else {
  716. listChartPermissionidAll, errChartAll := models.GetChartPermissionActivity()
  717. listChartPermissionid = listChartPermissionidAll
  718. errChart = errChartAll
  719. }
  720. }
  721. if errChart != nil {
  722. br.Msg = "获取信息失败"
  723. br.ErrMsg = "获取品种信息失败,Err:" + errChart.Error()
  724. return
  725. }
  726. //for _, v := range chartPermissionidsSlice {
  727. // for k2, v2 := range listChartPermissionid {
  728. // if strconv.Itoa(v2.ChartPermissionId) == v {
  729. // listChartPermissionid[k2].IsChoose = true
  730. // }
  731. // }
  732. //}
  733. resp := new(models.ActivityUserSearchContentList)
  734. if detail.IsShowJurisdiction == 1 {
  735. resp.IsShowJurisdiction = true
  736. }
  737. fmt.Println(isShowJurisdiction)
  738. if isShowJurisdiction == 1 || detail.IsShowJurisdiction == 1 {
  739. resp.IsShowJurisdiction = true
  740. for k, _ := range listChartPermissionid {
  741. listChartPermissionid[k].IsChoose = true
  742. }
  743. }
  744. if isShowJurisdiction == 2 {
  745. resp.IsShowJurisdiction = false
  746. }
  747. activeStateList := []models.ActivityStaus{models.ActivityStaus{Id: 1, StatusName: "未开始", IsChoose: true}, models.ActivityStaus{Id: 2, StatusName: "进行中"}, models.ActivityStaus{Id: 3, StatusName: "已结束"}}
  748. //for _, v := range activeStateSlice {
  749. // for k2, v2 := range activeStateList {
  750. // if strconv.Itoa(v2.Id) == v {
  751. // //activeStateList[k2].IsChoose = true
  752. // }
  753. // }
  754. //}
  755. if activeStateList[1].IsChoose == activeStateList[2].IsChoose == false {
  756. activeStateList[0].IsChoose = true
  757. }
  758. resp.ListActivityType = listActivityType
  759. resp.ListChartPermission = listChartPermissionid
  760. resp.ListActivityStaus = activeStateList
  761. br.Ret = 200
  762. br.Success = true
  763. br.Msg = "获取成功"
  764. br.Data = resp
  765. }
  766. // @Title 添加会议提醒
  767. // @Description 添加会议提醒接口
  768. // @Param request body models.ActivityIdRep true "type json string"
  769. // @Success Ret=200 {object} models.SignupStatus
  770. // @router /meetingReminder/add [post]
  771. func (this *ActivityCoAntroller) MeetingReminderAdd() {
  772. br := new(models.BaseResponse).Init()
  773. defer func() {
  774. this.Data["json"] = br
  775. this.ServeJSON()
  776. }()
  777. user := this.User
  778. if user == nil {
  779. br.Msg = "请登录"
  780. br.ErrMsg = "请登录,用户信息为空"
  781. br.Ret = 408
  782. return
  783. }
  784. uid := user.UserId
  785. //var signupStatus string
  786. signupStatus := "Success"
  787. var req models.ActivityIdRep
  788. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  789. if err != nil {
  790. br.Msg = "参数解析异常!"
  791. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  792. return
  793. }
  794. activityId := req.ActivityId
  795. //SignupStatus string `description:"报名状态:人数已满:FullStarffed、单机构超过两人:TwoPeople、爽约次数过多:BreakPromise、超时:Overtime 、成功:Success"`
  796. item := new(models.CygxActivityMeetingReminder)
  797. resp := new(models.SignupStatus)
  798. hasPermission := 0
  799. //判断是否已经申请过
  800. applyCount, err := models.GetApplyRecordCount(uid)
  801. if err != nil && err.Error() != utils.ErrNoRow() {
  802. br.Msg = "获取信息失败"
  803. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  804. return
  805. }
  806. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  807. if activityInfo == nil {
  808. br.Msg = "操作失败"
  809. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  810. return
  811. }
  812. if errInfo != nil {
  813. br.Msg = "操作失败"
  814. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  815. return
  816. }
  817. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  818. if time.Now().After(resultTime.Add(-time.Minute * 15)) {
  819. br.Msg = "活动开始前15分钟无法设置会议提醒"
  820. return
  821. }
  822. if user.CompanyId > 1 {
  823. permissionStr, err := models.GetCompanyPermission(user.CompanyId)
  824. if err != nil {
  825. br.Msg = "获取信息失败"
  826. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  827. return
  828. }
  829. companyItem, err := models.GetCompanyDetailAllById(user.CompanyId)
  830. //if err != nil {
  831. // br.Msg = "获取信息失败"
  832. // br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  833. // return
  834. //}
  835. //冻结客户
  836. if err != nil {
  837. if err.Error() == utils.ErrNoRow() {
  838. resp.HasPermission = 4
  839. resp.OperationMode = "Apply"
  840. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  841. br.Ret = 200
  842. br.Success = true
  843. br.Msg = "获取成功"
  844. br.Data = resp
  845. return
  846. } else {
  847. br.Msg = "获取信息失败"
  848. br.ErrMsg = "获取客户公司信息失败,Err:" + err.Error()
  849. return
  850. }
  851. }
  852. if activityInfo.ActivityTypeId != 1 && activityInfo.ActivityTypeId != 4 && permissionStr == "专家" {
  853. resp.PopupMsg = "您暂无权限参加" + activityInfo.ActivityName + "类型活动,若想参加请联系对口销售--" + companyItem.SellerName + ":" + companyItem.Mobile
  854. resp.SellerMobile = companyItem.Mobile
  855. resp.OperationMode = "Call"
  856. hasPermission = 2
  857. } else {
  858. if strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  859. hasPermission = 1
  860. signupStatus = "Success"
  861. totalMeeting, errMeeting := models.GetActivityMeetingReminderCount(uid, activityId)
  862. if errMeeting != nil {
  863. br.Msg = "获取失败"
  864. br.ErrMsg = "获取失败,Err:" + errMeeting.Error()
  865. return
  866. }
  867. if totalMeeting > 0 {
  868. br.Msg = "您已预约,请勿重复预约"
  869. return
  870. }
  871. item.UserId = uid
  872. item.ActivityId = activityId
  873. item.CreateTime = time.Now()
  874. item.Mobile = user.Mobile
  875. item.Email = user.Email
  876. item.CompanyId = user.CompanyId
  877. item.CompanyName = user.CompanyName
  878. _, errSignup := models.AddActivityMeetingReminder(item)
  879. if errSignup != nil {
  880. br.Msg = "操作失败"
  881. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  882. return
  883. }
  884. resp.HaqveJurisdiction = true
  885. } else {
  886. resp.PopupMsg = "您暂无权限参加【" + activityInfo.ChartPermissionName + "】行业活动,若想参加请联系对口销售--" + companyItem.SellerName + ":" + companyItem.Mobile
  887. resp.SellerMobile = companyItem.Mobile
  888. resp.OperationMode = "Call"
  889. hasPermission = 2
  890. }
  891. }
  892. } else { //潜在客户
  893. if applyCount > 0 {
  894. hasPermission = 4
  895. } else {
  896. hasPermission = 3
  897. }
  898. resp.OperationMode = "Apply"
  899. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  900. }
  901. resp.HasPermission = hasPermission
  902. resp.SignupStatus = signupStatus
  903. resp.ActivityId = activityId
  904. var total int
  905. total, err = models.GetUserMeetingReminderCount(user.UserId)
  906. if err != nil {
  907. br.Msg = "获取信息失败"
  908. br.ErrMsg = "获取日程数量信息失败,Err:" + err.Error()
  909. return
  910. }
  911. if total == 0 {
  912. resp.GoFollow = true
  913. }
  914. br.Ret = 200
  915. br.Success = true
  916. if hasPermission == 1 {
  917. br.Msg = "设置成功,会前15分钟会为您推送微信消息提醒"
  918. }
  919. br.Data = resp
  920. }
  921. // @Title 取消会议提醒
  922. // @Description 取消会议提醒接口
  923. // @Param request body models.ActivityIdRep true "type json string"
  924. // @Success Ret=200 {object} models.SignupStatus
  925. // @router /meetingReminder/cancel [post]
  926. func (this *ActivityCoAntroller) MeetingReminderCancel() {
  927. br := new(models.BaseResponse).Init()
  928. defer func() {
  929. this.Data["json"] = br
  930. this.ServeJSON()
  931. }()
  932. user := this.User
  933. if user == nil {
  934. br.Msg = "请登录"
  935. br.ErrMsg = "请登录,用户信息为空"
  936. br.Ret = 408
  937. return
  938. }
  939. uid := user.UserId
  940. var req models.ActivityIdRep
  941. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  942. if err != nil {
  943. br.Msg = "参数解析异常!"
  944. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  945. return
  946. }
  947. activityId := req.ActivityId
  948. signupStatus := "Success"
  949. item := new(models.CygxActivityMeetingReminder)
  950. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  951. if activityInfo == nil {
  952. br.Msg = "操作失败"
  953. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  954. return
  955. }
  956. if errInfo != nil {
  957. br.Msg = "操作失败"
  958. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  959. return
  960. }
  961. //if signupStatus == "Success" {
  962. total, err := models.GetActivityMeetingReminderCount(uid, activityId)
  963. if err != nil {
  964. br.Msg = "获取失败"
  965. br.ErrMsg = "获取失败,Err:" + err.Error()
  966. return
  967. }
  968. if total == 0 {
  969. br.Msg = "您暂未添加该活动会议提醒"
  970. return
  971. }
  972. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  973. if time.Now().After(resultTime.Add(-time.Minute * 15)) {
  974. br.Msg = "活动开始前15分钟无法取消会议提醒"
  975. return
  976. }
  977. item.UserId = uid
  978. item.ActivityId = activityId
  979. item.CreateTime = time.Now()
  980. item.Mobile = user.Mobile
  981. item.Email = user.Email
  982. item.CompanyId = user.CompanyId
  983. item.CompanyName = user.CompanyName
  984. _, errSignup := models.CancelActivityMeetingReminder(item)
  985. if errSignup != nil {
  986. br.Msg = "操作失败"
  987. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  988. return
  989. }
  990. //}
  991. resp := new(models.SignupStatus)
  992. resp.SignupStatus = signupStatus
  993. resp.ActivityId = activityId
  994. br.Ret = 200
  995. br.Success = true
  996. br.Msg = "会议提醒已取消"
  997. br.Data = resp
  998. }