activity.go 69 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "github.com/tealeg/xlsx"
  6. "hongze/hongze_cygx/models"
  7. "hongze/hongze_cygx/services"
  8. "hongze/hongze_cygx/utils"
  9. "os"
  10. "path/filepath"
  11. "rdluck_tools/paging"
  12. "strconv"
  13. "strings"
  14. "time"
  15. )
  16. //活动
  17. type ActivityCoAntroller struct {
  18. BaseAuthController
  19. }
  20. type ActivityABaseController struct {
  21. BaseCommonController
  22. }
  23. // @Title 活动类型列表
  24. // @Description活动类型列表接口
  25. // @Success 200 {object} models.ActivityTypeListResp
  26. // @router /activityTypelist [get]
  27. func (this *ActivityCoAntroller) List() {
  28. br := new(models.BaseResponse).Init()
  29. defer func() {
  30. this.Data["json"] = br
  31. this.ServeJSON()
  32. }()
  33. user := this.User
  34. if user == nil {
  35. br.Msg = "请登录"
  36. br.ErrMsg = "请登录,SysUser Is Empty"
  37. br.Ret = 408
  38. return
  39. }
  40. resp := new(models.ActivityTypeListResp)
  41. list, err := models.GetActivityTypeList()
  42. if err != nil {
  43. br.Msg = "获取失败"
  44. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  45. return
  46. }
  47. resp.List = list
  48. br.Ret = 200
  49. br.Success = true
  50. br.Msg = "获取成功"
  51. br.Data = resp
  52. }
  53. // @Title 活动列表
  54. // @Description 获取活动列表接口
  55. // @Param PageSize query int true "每页数据条数"
  56. // @Param CurrentIndex query int true "当前页页码,从1开始"
  57. // @Param ChartPermissionIds query string false "行业id 多个用 , 隔开"
  58. // @Param ActivityTypeIds query string false "活动类型id 多个用 , 隔开"
  59. // @Param KeyWord query string false "搜索关键词 多个用 , 隔开"
  60. // @Param ActiveState query string false "活动进行状态 未开始:1、进行中2、已结束3"
  61. // @Param WhichDay query string false "哪一天 今天:1、明天:2,多个用 , 隔开"
  62. // @Param IsShowJurisdiction query int false "是否仅展示有权限的,1是,2否 默认为零"
  63. // @Param Label query string false "搜索主题 多个用 , 隔开"
  64. // @Success 200 {object} models.GetCygxActivityListRep
  65. // @router /list [get]
  66. func (this *ActivityCoAntroller) ActivityList() {
  67. br := new(models.BaseResponse).Init()
  68. defer func() {
  69. this.Data["json"] = br
  70. this.ServeJSON()
  71. }()
  72. user := this.User
  73. if user == nil {
  74. br.Msg = "请登录"
  75. br.ErrMsg = "请登录,SysUser Is Empty"
  76. return
  77. }
  78. uid := user.UserId
  79. pageSize, _ := this.GetInt("PageSize")
  80. currentIndex, _ := this.GetInt("CurrentIndex")
  81. chartPermissionIds := this.GetString("ChartPermissionIds")
  82. activityTypeIds := this.GetString("ActivityTypeIds")
  83. whichDay := this.GetString("WhichDay")
  84. isShowJurisdiction, _ := this.GetInt("IsShowJurisdiction")
  85. keyWord := this.GetString("KeyWord")
  86. activeState := this.GetString("ActiveState")
  87. label := this.GetString("Label")
  88. //更新用户的搜索信息
  89. itemSearch := new(models.CygxActivityUserSearchContent)
  90. itemSearch.UserId = uid
  91. itemSearch.CreateTime = time.Now()
  92. itemSearch.Mobile = user.Mobile
  93. itemSearch.Email = user.Email
  94. itemSearch.CompanyId = user.CompanyId
  95. itemSearch.CompanyName = user.CompanyName
  96. itemSearch.ModifyTime = time.Now()
  97. itemSearch.ChartPermissionids = chartPermissionIds
  98. itemSearch.ActivityTypeids = activityTypeIds
  99. itemSearch.ActiveState = activeState
  100. itemSearch.IsShowJurisdiction = isShowJurisdiction
  101. _, errSearch := models.AddUserSearchContent(itemSearch)
  102. if errSearch != nil {
  103. br.Msg = "操作失败"
  104. br.ErrMsg = "操作失败,Err:" + errSearch.Error()
  105. return
  106. }
  107. var userType int
  108. var permissionStr string
  109. if user.CompanyId <= 1 {
  110. userType = 0
  111. } else {
  112. total, err := models.GetCountCompanyDetailByIdGroup(user.CompanyId)
  113. if err != nil {
  114. br.Msg = "获取失败"
  115. br.ErrMsg = "获取失败,Err:" + err.Error()
  116. return
  117. }
  118. if total == 0 {
  119. userType = 0
  120. } else {
  121. companyDetail, err := models.GetCompanyDetailByIdGroup(user.CompanyId)
  122. if err != nil {
  123. br.Msg = "获取信息失败!"
  124. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  125. return
  126. }
  127. if companyDetail == nil {
  128. br.Msg = "获取信息失败!"
  129. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId)
  130. return
  131. }
  132. permissionStr, err = models.GetCompanyPermission(user.CompanyId)
  133. if err != nil {
  134. br.Msg = "获取信息失败"
  135. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  136. return
  137. }
  138. //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //3、分行业套餐客户(开通对应行业的正式客户) //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户
  139. if companyDetail.Status == "永续" {
  140. userType = 1
  141. } else if companyDetail.Status == "试用" {
  142. userType = 5
  143. } else if companyDetail.Status == "正式" {
  144. if permissionStr == "专家" {
  145. userType = 4
  146. } else if strings.Contains(permissionStr, "医药") && strings.Contains(permissionStr, "消费") && strings.Contains(permissionStr, "科技") && strings.Contains(permissionStr, "智造") {
  147. userType = 2
  148. } else {
  149. userType = 3
  150. }
  151. if userType == 3 {
  152. if !strings.Contains(permissionStr, "医药") && !strings.Contains(permissionStr, "消费") && !strings.Contains(permissionStr, "科技") && !strings.Contains(permissionStr, "智造") {
  153. userType = 4
  154. }
  155. }
  156. }
  157. }
  158. }
  159. if isShowJurisdiction == 1 && chartPermissionIds == "" && userType == 4 {
  160. activityTypeIds = "1,3"
  161. }
  162. var startSize int
  163. if pageSize <= 0 {
  164. pageSize = utils.PageSize20
  165. }
  166. if currentIndex <= 0 {
  167. currentIndex = 1
  168. }
  169. startSize = utils.StartIndex(currentIndex, pageSize)
  170. var condition string
  171. var pars []interface{}
  172. //活动可见限制
  173. var sqlExport string
  174. slicePer := strings.Split(permissionStr, ",")
  175. var permissionSqlStr string
  176. for _, v := range slicePer {
  177. if userType == 1 {
  178. if v != "研选" {
  179. permissionSqlStr += "'" + v + "',"
  180. }
  181. } else {
  182. permissionSqlStr += "'" + v + "',"
  183. }
  184. }
  185. permissionSqlStr = strings.TrimRight(permissionSqlStr, ",")
  186. permissionSqlStr = ` AND art.chart_permission_name IN (` + permissionSqlStr + `)`
  187. sqlExport = ` AND (art.customer_type_ids LIKE '%` + strconv.Itoa(userType) + `%' `
  188. if userType == 2 {
  189. sqlExport += ` OR art.customer_type_ids LIKE '%3%' `
  190. }
  191. if (userType == 2 || userType == 3) && strings.Contains(permissionStr, "专家") {
  192. sqlExport += ` OR art.customer_type_ids LIKE '%4%' `
  193. }
  194. sqlExport += `) `
  195. if keyWord != "" {
  196. var mirrorword string
  197. var mirrorwordSql string
  198. slicemirrorword := strings.Split(keyWord, ",")
  199. for _, v := range slicemirrorword {
  200. mirrorwordSql += "'" + v + "'" + ","
  201. }
  202. mirrorwordSql = strings.TrimRight(mirrorwordSql, ",")
  203. total, err := models.GetActivityMirrorWordCount(mirrorwordSql)
  204. if err != nil {
  205. br.Msg = "获取失败"
  206. br.ErrMsg = "获取失败,Err:" + err.Error()
  207. return
  208. }
  209. if total > 0 {
  210. mirrorword, err = models.GetMirrorWord(mirrorwordSql)
  211. if err != nil {
  212. br.Msg = "获取信息失败"
  213. br.ErrMsg = "关系词映射获取失败,Err:" + err.Error()
  214. return
  215. }
  216. }
  217. keyWord = keyWord + "," + mirrorword
  218. slicekeyWord := strings.Split(keyWord, ",")
  219. var sqlKeyOr string
  220. if len(slicekeyWord) >= 2 {
  221. for _, v := range slicekeyWord {
  222. if v != "" {
  223. sqlKeyOr += ` OR art.activity_name LIKE '%` + v + `%' `
  224. }
  225. }
  226. condition += ` AND (art.activity_name LIKE '%` + keyWord + `%' ` + sqlKeyOr + ` )`
  227. } else {
  228. condition += ` AND (art.activity_name LIKE '%` + keyWord + `%' )`
  229. }
  230. }
  231. //主题
  232. if label != "" {
  233. sliceLabel := strings.Split(label, ",")
  234. var labelSqlStr string
  235. for _, v := range sliceLabel {
  236. labelSqlStr += "'" + v + "',"
  237. }
  238. labelSqlStr = strings.TrimRight(labelSqlStr, ",")
  239. condition = ` AND art.label IN (` + labelSqlStr + `)`
  240. }
  241. //行业名称
  242. if len(chartPermissionIds) > 0 {
  243. condition += ` AND art.chart_permission_id IN (` + chartPermissionIds + `)`
  244. }
  245. if activityTypeIds != "" {
  246. condition += ` AND art.activity_type_id IN (` + activityTypeIds + `)`
  247. }
  248. if whichDay != "" {
  249. var startDate string
  250. var endDate string
  251. if whichDay == "1" {
  252. startDate = time.Now().Format(utils.FormatDate)
  253. endDate = startDate
  254. } else if whichDay == "2" {
  255. startDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  256. endDate = startDate
  257. } else {
  258. startDate = time.Now().Format(utils.FormatDate)
  259. endDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  260. }
  261. condition += ` AND art.activity_time >= ` + "'" + startDate + " 00:00:00'"
  262. condition += ` AND art.activity_time <= ` + "'" + endDate + " 23:59:59'"
  263. }
  264. if activeState != "" {
  265. condition += ` AND art.active_state IN (` + activeState + `)`
  266. }
  267. condition += ` AND art.publish_status = 1 `
  268. var conditionOr string
  269. // 有专家权限的这几种用户,不做行业权限校验
  270. if (userType == 2 || userType == 3 || userType == 4) && strings.Contains(permissionStr, "专家") {
  271. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%4%' ` + condition + `) `
  272. }
  273. if (userType == 5) && strings.Contains(permissionStr, "专家") {
  274. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%5%' ` + condition + `) `
  275. }
  276. if userType == 1 {
  277. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + permissionSqlStr + `) `
  278. } else {
  279. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + `) `
  280. }
  281. condition += ` AND art.is_limit_people = 1 ` + permissionSqlStr + sqlExport + conditionOr
  282. total, err := models.GetActivityCount(condition, pars)
  283. if err != nil {
  284. br.Msg = "获取失败"
  285. br.ErrMsg = "获取失败,Err:" + err.Error()
  286. return
  287. }
  288. condition += ` ORDER BY art.active_state ASC, art.activity_time ASC `
  289. list, errList := models.GetActivityListAll(condition, pars, uid, startSize, pageSize)
  290. if errList != nil {
  291. br.Msg = "获取失败"
  292. br.ErrMsg = "获取失败,Err:" + errList.Error()
  293. return
  294. }
  295. for k, v := range list {
  296. if strings.Contains(v.ActivityName, "【") {
  297. list[k].IsBrackets = 1
  298. }
  299. if v.SignupNum > v.LimitPeopleNum {
  300. list[k].SignupNum = v.LimitPeopleNum
  301. }
  302. if services.GetShowSustainable() && v.ChartPermissionName == "研选" {
  303. list[k].IsShowSustainable = true
  304. }
  305. }
  306. page := paging.GetPaging(currentIndex, pageSize, total)
  307. resp := new(models.GetCygxActivityListRep)
  308. resp.List = list
  309. resp.Paging = page
  310. br.Ret = 200
  311. br.Success = true
  312. br.Msg = "获取成功"
  313. br.Data = resp
  314. }
  315. // @Title 我的日程
  316. // @Description 我的日程列表接口
  317. // @Param PageSize query int true "每页数据条数"
  318. // @Param CurrentIndex query int true "当前页页码,从1开始"
  319. // @Success 200 {object} models.GetCygxActivityListRep
  320. // @router /scheduleList [get]
  321. func (this *ActivityCoAntroller) ScheduleList() {
  322. br := new(models.BaseResponse).Init()
  323. defer func() {
  324. this.Data["json"] = br
  325. this.ServeJSON()
  326. }()
  327. user := this.User
  328. if user == nil {
  329. br.Msg = "请登录"
  330. br.ErrMsg = "请登录,SysUser Is Empty"
  331. return
  332. }
  333. uid := user.UserId
  334. pageSize, _ := this.GetInt("PageSize")
  335. currentIndex, _ := this.GetInt("CurrentIndex")
  336. var startSize int
  337. if pageSize <= 0 {
  338. pageSize = utils.PageSize20
  339. }
  340. if currentIndex <= 0 {
  341. currentIndex = 1
  342. }
  343. startSize = utils.StartIndex(currentIndex, pageSize)
  344. var condition string
  345. var pars []interface{}
  346. //condition += ` AND art.publish_status = 1 AND art.active_state IN(1,2) AND s.is_cancel = 0 AND s.fail_type = 0 `
  347. condition += ` AND art.publish_status = 1 AND art.active_state IN(1,2) `
  348. total, err := models.GetScheduleCount(uid)
  349. if err != nil {
  350. br.Msg = "获取失败"
  351. br.ErrMsg = "获取失败,Err:" + err.Error()
  352. return
  353. }
  354. list, errList := models.GetScheduleList(condition, pars, uid, startSize, pageSize)
  355. if errList != nil {
  356. br.Msg = "获取失败"
  357. br.ErrMsg = "获取失败,Err:" + errList.Error()
  358. return
  359. }
  360. for k, v := range list {
  361. if strings.Contains(v.ActivityName, "【") {
  362. list[k].IsBrackets = 1
  363. }
  364. if v.SignupNum > v.LimitPeopleNum {
  365. list[k].SignupNum = v.LimitPeopleNum
  366. }
  367. //是否展示限免标签
  368. if services.GetShowSustainable() && v.ChartPermissionName == "研选" {
  369. list[k].IsShowSustainable = true
  370. }
  371. }
  372. page := paging.GetPaging(currentIndex, pageSize, total)
  373. resp := new(models.GetCygxActivityListRep)
  374. resp.List = list
  375. resp.Paging = page
  376. br.Ret = 200
  377. br.Success = true
  378. br.Msg = "获取成功"
  379. br.Data = resp
  380. }
  381. // @Title 活动详情
  382. // @Description 获取活动详情接口
  383. // @Param ActivityId query int true "活动ID"
  384. // @Success Ret=200 {object} models.CygxActivityResp
  385. // @router /detail [get]
  386. func (this *ActivityCoAntroller) Detail() {
  387. br := new(models.BaseResponse).Init()
  388. defer func() {
  389. this.Data["json"] = br
  390. this.ServeJSON()
  391. }()
  392. user := this.User
  393. if user == nil {
  394. br.Msg = "请登录"
  395. br.ErrMsg = "请登录,用户信息为空"
  396. br.Ret = 408
  397. return
  398. }
  399. uid := user.UserId
  400. activityId, _ := this.GetInt("ActivityId")
  401. if activityId < 1 {
  402. br.Msg = "请输入活动ID"
  403. return
  404. }
  405. resp := new(models.CygxActivityResp)
  406. hasPermission := 0
  407. var companyDetailStatus string
  408. activityInfo, err := models.GetAddActivityInfoByIdShow(uid, activityId)
  409. if err != nil && err.Error() != utils.ErrNoRow() {
  410. br.Msg = "获取信息失败"
  411. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  412. return
  413. }
  414. if activityInfo == nil {
  415. br.Msg = "活动不存在"
  416. br.ErrMsg = "活动ID错误,Err:" + "activityId:" + strconv.Itoa(activityId)
  417. return
  418. }
  419. applyCount, err := models.GetApplyRecordCount(uid)
  420. if err != nil && err.Error() != utils.ErrNoRow() {
  421. br.Msg = "获取信息失败"
  422. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  423. return
  424. }
  425. if user.CompanyId <= 1 {
  426. companyDetailStatus = ""
  427. } else {
  428. companyPermission, err := models.GetCompanyPermission(user.CompanyId)
  429. if err != nil {
  430. br.Msg = "获取信息失败"
  431. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  432. return
  433. }
  434. if companyPermission == "" {
  435. if applyCount > 0 {
  436. hasPermission = 4
  437. } else {
  438. hasPermission = 3
  439. }
  440. resp.HasPermission = hasPermission
  441. resp.OperationMode = "Apply"
  442. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  443. br.Ret = 200
  444. br.Success = true
  445. br.Msg = "获取成功"
  446. br.Data = resp
  447. return
  448. }
  449. companyDetail, err := models.GetCompanyDetailById(user.CompanyId)
  450. if err != nil {
  451. br.Msg = "获取信息失败!"
  452. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  453. return
  454. }
  455. if companyDetail == nil {
  456. br.Msg = "获取信息失败!"
  457. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId)
  458. return
  459. }
  460. companyDetailStatus = companyDetail.Status
  461. }
  462. var userType int
  463. var permissionStr string
  464. if user.CompanyId <= 1 {
  465. userType = 0
  466. } else {
  467. companyDetail, err := models.GetCompanyDetailById(user.CompanyId)
  468. if err != nil {
  469. br.Msg = "获取信息失败!"
  470. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  471. return
  472. }
  473. if companyDetail == nil {
  474. br.Msg = "获取信息失败!"
  475. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId)
  476. return
  477. }
  478. //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //3、分行业套餐客户(开通对应行业的正式客户) //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户
  479. if companyDetail.Status == "永续" {
  480. userType = 1
  481. } else if companyDetail.Status == "试用" {
  482. userType = 5
  483. } else if companyDetail.Status == "正式" {
  484. permissionStr, err = models.GetCompanyPermission(user.CompanyId)
  485. if err != nil {
  486. br.Msg = "获取信息失败"
  487. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  488. return
  489. }
  490. if permissionStr == "专家" {
  491. userType = 4
  492. } else if strings.Contains(permissionStr, "医药") && strings.Contains(permissionStr, "消费") && strings.Contains(permissionStr, "科技") && strings.Contains(permissionStr, "智造") {
  493. userType = 2
  494. } else {
  495. userType = 3
  496. }
  497. }
  498. }
  499. if activityInfo.IsLimitPeople > 0 {
  500. var noPower bool
  501. if (userType == 1 || userType == 4 || userType == 5) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(userType)) {
  502. noPower = true
  503. }
  504. //带有专家权限的 2、大套餐客户(4个行业全开通的正式客户) 3、分行业套餐客户(开通对应行业的正式客户)
  505. 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)) {
  506. noPower = true
  507. }
  508. if userType == 2 && !strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(2)) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) {
  509. noPower = true
  510. }
  511. if userType == 3 && strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(4)) {
  512. noPower = true
  513. }
  514. if userType == 3 && !strings.Contains(permissionStr, "专家") && !strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(3)) {
  515. noPower = true
  516. }
  517. if noPower {
  518. br.Msg = "您暂无查看该活动权限"
  519. br.ErrMsg = "被分享客户不可见,获取信息失败"
  520. return
  521. }
  522. }
  523. if userType == 1 && activityInfo.ChartPermissionName == "研选" {
  524. br.Msg = "您暂无查看该活动权限"
  525. br.ErrMsg = "被分享客户不可见,永续客户无法查看研选行业"
  526. return
  527. }
  528. detail, errDetail := models.GetActivityTypeDetailById(activityInfo.ActivityTypeId)
  529. if errDetail != nil {
  530. br.Msg = "获取信息失败"
  531. br.ErrMsg = "获取信息失败,Err:" + errDetail.Error()
  532. return
  533. }
  534. if activityInfo.IsSignup > 0 {
  535. detail, errDetail := models.GetActivitySignupDetail(activityId, uid)
  536. if errDetail != nil {
  537. br.Msg = "获取信息失败"
  538. br.ErrMsg = "获取信息失败,Err:" + errDetail.Error()
  539. return
  540. }
  541. activityInfo.SignupType = detail.SignupType
  542. }
  543. activityInfo.ShowType = detail.ShowType
  544. //判断是否已经申请过
  545. if user.CompanyId > 1 {
  546. permissionStr, err := models.GetCompanyPermission(user.CompanyId)
  547. if err != nil {
  548. br.Msg = "获取信息失败"
  549. br.ErrMsg = "获取客户权限信息失败,Err:" + err.Error()
  550. return
  551. }
  552. companyItem, err := models.GetCompanyDetailAllById(user.CompanyId)
  553. //冻结客户
  554. if err != nil {
  555. if err.Error() == utils.ErrNoRow() {
  556. resp.HasPermission = 4
  557. resp.OperationMode = "Apply"
  558. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动"
  559. br.Ret = 200
  560. br.Success = true
  561. br.Msg = "获取成功"
  562. br.Data = resp
  563. return
  564. } else {
  565. br.Msg = "获取信息失败"
  566. br.ErrMsg = "获取客户公司信息失败,Err:" + err.Error()
  567. return
  568. }
  569. }
  570. //1专家电话会、2分析师电话会、3公司调研电话会、4公司线下调研、5专家线下沙龙、6分析师线下沙龙
  571. //OperationMode string `description:"操作方式 Apply:立即申请、Call:拨号 为空则为有权限"`
  572. var havePower bool
  573. if (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 3) && strings.Contains(permissionStr, "专家") && activityInfo.LimitPeopleNum == 0 {
  574. havePower = true
  575. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "正式" && strings.Contains(activityInfo.CustomerTypeIds, "4") {
  576. havePower = true
  577. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "试用" && strings.Contains(activityInfo.CustomerTypeIds, "5") {
  578. havePower = true
  579. } else if strings.Contains(permissionStr, activityInfo.ChartPermissionName) && strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(userType)) {
  580. havePower = true
  581. } else if strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  582. havePower = true
  583. }
  584. if havePower {
  585. hasPermission = 1
  586. resp.HaqveJurisdiction = true
  587. } else {
  588. if permissionStr == "专家" {
  589. resp.PopupMsg = "您暂无权限参加【" + activityInfo.ActivityTypeName + "】类型活动"
  590. resp.MsgType = "Type"
  591. } else {
  592. resp.PopupMsg = "您暂无权限参加【" + activityInfo.ChartPermissionName + "】行业活动"
  593. resp.MsgType = "Industry"
  594. }
  595. resp.SellerMobile = companyItem.Mobile
  596. resp.SellerName = companyItem.SellerName
  597. resp.OperationMode = "Call"
  598. hasPermission = 2
  599. }
  600. } else { //潜在客户
  601. if applyCount > 0 {
  602. hasPermission = 4
  603. } else {
  604. hasPermission = 3
  605. }
  606. resp.OperationMode = "Apply"
  607. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  608. }
  609. if hasPermission == 1 {
  610. //是否展示限免标签
  611. if services.GetShowSustainable() && activityInfo.ChartPermissionName == "研选" {
  612. activityInfo.IsShowSustainable = true
  613. }
  614. configCode := "description_of_research"
  615. detail, err := models.GetConfigByCode(configCode)
  616. if err != nil {
  617. br.Msg = "获取数据失败"
  618. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  619. return
  620. }
  621. activityInfo.Description = detail.ConfigValue
  622. if activityInfo.SignupNum > activityInfo.LimitPeopleNum {
  623. activityInfo.SignupNum = activityInfo.LimitPeopleNum
  624. }
  625. if activityInfo.ChartPermissionNames != "" {
  626. activityInfo.ChartPermissionName = activityInfo.ChartPermissionNames
  627. }
  628. resp.Detail = activityInfo
  629. }
  630. resp.HasPermission = hasPermission
  631. br.Ret = 200
  632. br.Success = true
  633. br.Msg = "获取成功"
  634. br.Data = resp
  635. }
  636. // @Title 活动报名
  637. // @Description 活动报名接口
  638. // @Param request body models.ActivitySingnupRep true "type json string"
  639. // @Success Ret=200 {object} models.SignupStatus
  640. // @router /signup/add [post]
  641. func (this *ActivityCoAntroller) SignupAdd() {
  642. br := new(models.BaseResponse).Init()
  643. defer func() {
  644. this.Data["json"] = br
  645. this.ServeJSON()
  646. }()
  647. user := this.User
  648. if user == nil {
  649. br.Msg = "请登录"
  650. br.ErrMsg = "请登录,用户信息为空"
  651. br.Ret = 408
  652. return
  653. }
  654. uid := user.UserId
  655. signupStatus := ""
  656. var req models.ActivitySingnupRep
  657. resp := new(models.SignupStatus)
  658. var total int
  659. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  660. if err != nil {
  661. br.Msg = "参数解析异常!"
  662. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  663. return
  664. }
  665. activityId := req.ActivityId
  666. signupType := req.SignupType
  667. hasPermission := 0
  668. if signupType == 1 && user.Mobile == "" && user.OutboundMobile == "" {
  669. resp.GoBindEmail = true
  670. }
  671. //判断是否已经申请过
  672. applyCount, err := models.GetApplyRecordCount(uid)
  673. if err != nil && err.Error() != utils.ErrNoRow() {
  674. br.Msg = "获取信息失败"
  675. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  676. return
  677. }
  678. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  679. if activityInfo == nil {
  680. br.Msg = "操作失败"
  681. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  682. return
  683. }
  684. if errInfo != nil {
  685. br.Msg = "操作失败"
  686. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  687. return
  688. }
  689. //SignupStatus "报名状态:人数已满:FullStarffed、单机构超过两人:TwoPeople、爽约次数过多:BreakPromise、超时:Overtime 、成功:Success"`
  690. //HasPermission "1:有该行业权限,正常展示,2:无该行业权限,3:潜在客户,未提交过申请,4:潜在客户,已提交过申请"`
  691. var companyDetailStatus string
  692. if user.CompanyId <= 1 {
  693. companyDetailStatus = ""
  694. } else {
  695. companyPermission, err := models.GetCompanyPermission(user.CompanyId)
  696. if err != nil {
  697. br.Msg = "获取信息失败"
  698. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  699. return
  700. }
  701. if companyPermission == "" {
  702. if applyCount > 0 {
  703. hasPermission = 4
  704. } else {
  705. hasPermission = 3
  706. }
  707. resp.HasPermission = hasPermission
  708. resp.OperationMode = "Apply"
  709. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  710. br.Ret = 200
  711. br.Success = true
  712. br.Msg = "获取成功"
  713. br.Data = resp
  714. return
  715. }
  716. companyDetail, err := models.GetCompanyDetailById(user.CompanyId)
  717. if err != nil {
  718. br.Msg = "获取信息失败!"
  719. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  720. return
  721. }
  722. if companyDetail == nil {
  723. br.Msg = "获取信息失败!"
  724. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId)
  725. return
  726. }
  727. companyDetailStatus = companyDetail.Status
  728. }
  729. var userType int
  730. var permissionStr string
  731. if user.CompanyId <= 1 {
  732. userType = 0
  733. } else {
  734. companyDetail, err := models.GetCompanyDetailById(user.CompanyId)
  735. if err != nil {
  736. br.Msg = "获取信息失败!"
  737. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  738. return
  739. }
  740. if companyDetail == nil {
  741. br.Msg = "获取信息失败!"
  742. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId)
  743. return
  744. }
  745. if companyDetail.Status == "永续" {
  746. userType = 1
  747. } else if companyDetail.Status == "试用" {
  748. userType = 5
  749. } else if companyDetail.Status == "正式" {
  750. permissionStr, err = models.GetCompanyPermission(user.CompanyId)
  751. if err != nil {
  752. br.Msg = "获取信息失败"
  753. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  754. return
  755. }
  756. if permissionStr == "专家" {
  757. userType = 4
  758. } else if strings.Contains(permissionStr, "医药") && strings.Contains(permissionStr, "消费") && strings.Contains(permissionStr, "科技") && strings.Contains(permissionStr, "智造") {
  759. userType = 2
  760. } else {
  761. userType = 3
  762. }
  763. }
  764. }
  765. if userType == 1 && activityInfo.ChartPermissionName == "研选" {
  766. br.Msg = "您暂无查看该活动权限"
  767. br.ErrMsg = "被分享客户不可见,永续客户无法查看研选行业"
  768. return
  769. }
  770. item := new(models.CygxActivitySignup)
  771. if user.CompanyId > 1 {
  772. permissionStr, err := models.GetCompanyPermission(user.CompanyId)
  773. if err != nil {
  774. br.Msg = "获取信息失败"
  775. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  776. return
  777. }
  778. companyItem, err := models.GetCompanyDetailAllById(user.CompanyId)
  779. //冻结客户
  780. if err != nil {
  781. if err.Error() == utils.ErrNoRow() {
  782. resp.HasPermission = 4
  783. resp.OperationMode = "Apply"
  784. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  785. br.Ret = 200
  786. br.Success = true
  787. br.Msg = "获取成功"
  788. br.Data = resp
  789. return
  790. } else {
  791. br.Msg = "获取信息失败"
  792. br.ErrMsg = "获取客户公司信息失败,Err:" + err.Error()
  793. return
  794. }
  795. }
  796. //1专家电话会、2分析师电话会、3公司调研电话会、4公司线下调研、5专家线下沙龙、6分析师线下沙龙
  797. //OperationMode string `description:"操作方式 Apply:立即申请、Call:拨号 为空则为有权限"`
  798. var havePower bool
  799. if (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 3) && strings.Contains(permissionStr, "专家") && activityInfo.LimitPeopleNum == 0 {
  800. havePower = true
  801. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "正式" && strings.Contains(activityInfo.CustomerTypeIds, "4") {
  802. havePower = true
  803. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "试用" && strings.Contains(activityInfo.CustomerTypeIds, "5") {
  804. havePower = true
  805. } else if strings.Contains(permissionStr, activityInfo.ChartPermissionName) && strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(userType)) {
  806. havePower = true
  807. } else if strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  808. havePower = true
  809. }
  810. if havePower {
  811. hasPermission = 1
  812. signupStatus = "Success"
  813. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  814. if time.Now().After(resultTime.Add(-time.Minute * 60)) {
  815. signupStatus = "Overtime"
  816. resp.SignupType = signupType
  817. resp.SignupStatus = signupStatus
  818. resp.HasPermission = hasPermission
  819. br.Ret = 200
  820. br.Success = true
  821. br.Msg = ""
  822. br.Data = resp
  823. return
  824. }
  825. //人数已满:FullStarffed、单机构超过两人:TwoPeople、爽约次数过多:BreakPromise、超时:Overtime 、成功:Success"`
  826. //如果是下面几种情况则对报名信息做判断限制 (公司调研电话会(限制人数)、公司线下调研、专家/分析师线下沙龙)
  827. if (activityInfo.ActivityTypeId == 3 && activityInfo.IsLimitPeople == 1) || activityInfo.ActivityTypeId > 3 {
  828. //判断优先级:总人数限制→单机构2人限制→爽约3次限制
  829. totalRestrict, err := models.GetUserRestrictCount(user.Mobile)
  830. if err != nil {
  831. br.Msg = "获取信息失败"
  832. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  833. return
  834. }
  835. if totalRestrict >= 1 {
  836. signupStatus = "BreakPromise"
  837. item.FailType = 3
  838. }
  839. totalSignupCompany, err := models.GetActivitySignupCompanyCount(activityId, user.CompanyId)
  840. if err != nil {
  841. br.Msg = "获取信息失败"
  842. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  843. return
  844. }
  845. if totalSignupCompany >= 2 {
  846. signupStatus = "TwoPeople"
  847. item.FailType = 2
  848. }
  849. totaSignupPeopleNum, err := models.GetActivitySignupSuccessCount(activityId)
  850. if err != nil {
  851. br.Msg = "获取信息失败"
  852. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  853. return
  854. }
  855. if totaSignupPeopleNum >= activityInfo.LimitPeopleNum {
  856. signupStatus = "FullStarffed"
  857. item.FailType = 1
  858. }
  859. totalUserRestrictCount, err := models.GetActivitySignupByUserRestrictCount(uid, activityId)
  860. if err != nil {
  861. br.Msg = "获取失败"
  862. br.ErrMsg = "获取失败,Err:" + err.Error()
  863. return
  864. }
  865. //解除报名限制之后二次报名相同活动
  866. if totalUserRestrictCount > 0 && totalRestrict == 0 && resp.GoBindEmail != true {
  867. item.UserId = uid
  868. item.ActivityId = activityId
  869. item.CreateTime = time.Now()
  870. item.Mobile = user.Mobile
  871. item.Email = user.Email
  872. item.CompanyId = user.CompanyId
  873. item.CompanyName = user.CompanyName
  874. item.SignupType = signupType
  875. item.FailType = 0
  876. item.DoFailType = 0
  877. _, errSignup := models.AddActivitySignupByRestrict(item)
  878. if errSignup != nil {
  879. br.Msg = "操作失败"
  880. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  881. return
  882. }
  883. resp.HaqveJurisdiction = true
  884. resp.SignupType = signupType
  885. resp.SignupStatus = "Success"
  886. resp.HasPermission = hasPermission
  887. resp.ActivityId = activityId
  888. total, err = models.GetUserMeetingReminderCount(user.UserId)
  889. if err != nil {
  890. br.Msg = "获取信息失败"
  891. br.ErrMsg = "获取日程数量信息失败,Err:" + err.Error()
  892. return
  893. }
  894. if total == 0 {
  895. resp.GoFollow = true
  896. }
  897. br.Ret = 200
  898. br.Success = true
  899. br.Msg = "操作成功"
  900. br.Data = resp
  901. return
  902. }
  903. totalMy, err := models.GetActivitySignupByUserCount(uid, activityId)
  904. if err != nil {
  905. br.Msg = "获取失败"
  906. br.ErrMsg = "获取失败,Err:" + err.Error()
  907. return
  908. }
  909. if signupStatus != "Success" && totalMy == 0 && resp.GoBindEmail != true {
  910. item.UserId = uid
  911. item.ActivityId = activityId
  912. item.CreateTime = time.Now()
  913. item.Mobile = user.Mobile
  914. item.Email = user.Email
  915. item.CompanyId = user.CompanyId
  916. item.CompanyName = user.CompanyName
  917. item.SignupType = signupType
  918. item.DoFailType = item.FailType
  919. if user.OutboundMobile != "" {
  920. item.OutboundMobile = user.OutboundMobile
  921. if user.OutboundCountryCode == "" {
  922. item.CountryCode = "86"
  923. } else {
  924. item.CountryCode = user.OutboundCountryCode
  925. }
  926. } else {
  927. item.OutboundMobile = user.Mobile
  928. if user.CountryCode == "" {
  929. item.CountryCode = "86"
  930. } else {
  931. item.CountryCode = user.CountryCode
  932. }
  933. }
  934. //添加报名信息,但是不加入日程
  935. _, errSignup := models.AddActivitySignupNoSchedule(item)
  936. if errSignup != nil {
  937. br.Msg = "操作失败"
  938. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  939. return
  940. }
  941. }
  942. }
  943. totalMySuccess, err := models.GetActivitySignupCount(uid, activityId)
  944. if err != nil {
  945. br.Msg = "获取失败"
  946. br.ErrMsg = "获取失败,Err:" + err.Error()
  947. return
  948. }
  949. if totalMySuccess > 0 {
  950. br.Msg = "您已报名这个活动"
  951. return
  952. }
  953. if signupStatus == "Success" && resp.GoBindEmail != true {
  954. item.UserId = uid
  955. item.ActivityId = activityId
  956. item.CreateTime = time.Now()
  957. item.Mobile = user.Mobile
  958. item.Email = user.Email
  959. item.CompanyId = user.CompanyId
  960. item.CompanyName = user.CompanyName
  961. item.SignupType = signupType
  962. item.FailType = 0
  963. item.DoFailType = 0
  964. item.OutboundMobile = user.Mobile
  965. if user.OutboundMobile != "" {
  966. item.OutboundMobile = user.OutboundMobile
  967. if user.OutboundCountryCode == "" {
  968. item.CountryCode = "86"
  969. } else {
  970. item.CountryCode = user.OutboundCountryCode
  971. }
  972. } else {
  973. item.OutboundMobile = user.Mobile
  974. if user.CountryCode == "" {
  975. item.CountryCode = "86"
  976. } else {
  977. item.CountryCode = user.CountryCode
  978. }
  979. }
  980. _, errSignup := models.AddActivitySignup(item)
  981. if errSignup != nil {
  982. br.Msg = "操作失败"
  983. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  984. return
  985. }
  986. resp.HaqveJurisdiction = true
  987. }
  988. } else {
  989. hasPermission = 2
  990. resp.SellerMobile = companyItem.Mobile
  991. resp.SellerName = companyItem.SellerName
  992. resp.MsgType = "Type"
  993. resp.OperationMode = "Call"
  994. if permissionStr == "专家" {
  995. resp.PopupMsg = "您暂无权限参加【" + activityInfo.ActivityTypeName + "】类型活动,若想参加请联系对口销售--" + companyItem.SellerName + ":" + companyItem.Mobile
  996. resp.MsgType = "Type"
  997. } else {
  998. resp.PopupMsg = "您暂无权限参加【" + activityInfo.ChartPermissionName + "】行业活动,若想参加请联系对口销售--" + companyItem.SellerName + ":" + companyItem.Mobile
  999. resp.MsgType = "Industry"
  1000. }
  1001. }
  1002. } else { //潜在客户
  1003. if applyCount > 0 {
  1004. hasPermission = 4
  1005. } else {
  1006. hasPermission = 3
  1007. }
  1008. resp.OperationMode = "Apply"
  1009. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  1010. }
  1011. if signupType == 1 && user.IsMsgOutboundMobile == 0 {
  1012. resp.GoOutboundMobile = true
  1013. if user.Mobile != "" || user.OutboundMobile != "" {
  1014. go models.ModifyWxUserIsMsgOutboundMobile(user.UserId)
  1015. }
  1016. }
  1017. if user.OutboundMobile == "" {
  1018. resp.Mobile = user.Mobile
  1019. if user.CountryCode == "" && len(user.Mobile) == 11 {
  1020. resp.CountryCode = "86"
  1021. } else {
  1022. resp.CountryCode = user.CountryCode
  1023. }
  1024. } else {
  1025. resp.Mobile = user.OutboundMobile
  1026. resp.CountryCode = user.OutboundCountryCode
  1027. }
  1028. //如果用户有绑定手机号,但是没有绑定外呼手机号
  1029. if signupType == 1 && user.Mobile != "" && user.OutboundMobile == "" {
  1030. var countryCode string
  1031. if len(user.Mobile) == 8 {
  1032. countryCode = "852"
  1033. } else if len(user.Mobile) == 9 {
  1034. countryCode = "886"
  1035. } else if len(user.Mobile) == 10 {
  1036. countryCode = "1"
  1037. } else if len(user.Mobile) >= 11 {
  1038. countryCode = "86"
  1039. }
  1040. models.BindUserOutboundMobileByMobile(user.Mobile, countryCode, uid)
  1041. }
  1042. resp.SignupType = signupType
  1043. resp.SignupStatus = signupStatus
  1044. resp.HasPermission = hasPermission
  1045. if signupStatus == "Success" {
  1046. resp.ActivityId = activityId
  1047. }
  1048. total, err = models.GetUserSignupCount(user.UserId)
  1049. if err != nil {
  1050. br.Msg = "获取信息失败"
  1051. br.ErrMsg = "获取日程数量信息失败,Err:" + err.Error()
  1052. return
  1053. }
  1054. if total <= 1 {
  1055. resp.GoFollow = true
  1056. }
  1057. br.Ret = 200
  1058. br.Success = true
  1059. br.Msg = "操作成功"
  1060. br.Data = resp
  1061. }
  1062. // @Title 活动取消报名
  1063. // @Description 活动取消报名接口
  1064. // @Param request body models.ActivitySingnupRep true "type json string"
  1065. // @Success Ret=200 {object} models.SignupStatus
  1066. // @router /signup/cancel [post]
  1067. func (this *ActivityCoAntroller) SignupCancel() {
  1068. br := new(models.BaseResponse).Init()
  1069. defer func() {
  1070. this.Data["json"] = br
  1071. this.ServeJSON()
  1072. }()
  1073. user := this.User
  1074. if user == nil {
  1075. br.Msg = "请登录"
  1076. br.ErrMsg = "请登录,用户信息为空"
  1077. br.Ret = 408
  1078. return
  1079. }
  1080. uid := user.UserId
  1081. var req models.ActivitySingnupRep
  1082. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1083. if err != nil {
  1084. br.Msg = "参数解析异常!"
  1085. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1086. return
  1087. }
  1088. activityId := req.ActivityId
  1089. signupType := req.SignupType
  1090. item := new(models.CygxActivitySignup)
  1091. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  1092. if activityInfo == nil {
  1093. br.Msg = "操作失败"
  1094. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  1095. return
  1096. }
  1097. if errInfo != nil {
  1098. br.Msg = "操作失败"
  1099. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  1100. return
  1101. }
  1102. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  1103. if time.Now().After(resultTime.Add(-time.Minute * 60)) {
  1104. if signupType == 1 {
  1105. br.Msg = "活动开始前1小时内无法取消预约外呼,请联系对口销售处理"
  1106. } else {
  1107. br.Msg = "活动开始前1小时内无法取消报名,请联系对口销售处理"
  1108. }
  1109. return
  1110. }
  1111. total, err := models.GetActivitySignupCount(uid, activityId)
  1112. if err != nil {
  1113. br.Msg = "获取失败"
  1114. br.ErrMsg = "获取失败,Err:" + err.Error()
  1115. return
  1116. }
  1117. if total == 0 {
  1118. br.Msg = "您暂未报名这个活动"
  1119. return
  1120. }
  1121. item.UserId = uid
  1122. item.ActivityId = activityId
  1123. item.CreateTime = time.Now()
  1124. item.Mobile = user.Mobile
  1125. item.Email = user.Email
  1126. item.CompanyId = user.CompanyId
  1127. item.CompanyName = user.CompanyName
  1128. resp := new(models.SignupStatus)
  1129. resp.ActivityId = activityId
  1130. _, errSignup := models.CancelActivitySignup(item)
  1131. if errSignup != nil {
  1132. br.Msg = "操作失败"
  1133. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  1134. return
  1135. }
  1136. br.Ret = 200
  1137. br.Success = true
  1138. br.Msg = "操作成功"
  1139. br.Data = resp
  1140. }
  1141. // @Title 用户搜索详情
  1142. // @Description 获取用户搜索详情接口
  1143. // @Param IsShowJurisdiction query int true "是否仅展示有权限的,默认为0,1是,2否 "
  1144. // @Success Ret=200 {object} models.ActivityUserSearchContentList
  1145. // @router /getUserSearchContent [get]
  1146. func (this *ActivityCoAntroller) GetUserSearchContent() {
  1147. br := new(models.BaseResponse).Init()
  1148. defer func() {
  1149. this.Data["json"] = br
  1150. this.ServeJSON()
  1151. }()
  1152. user := this.User
  1153. if user == nil {
  1154. br.Msg = "请登录"
  1155. br.ErrMsg = "请登录,用户信息为空"
  1156. br.Ret = 408
  1157. return
  1158. }
  1159. uid := user.UserId
  1160. detailSeearch := new(models.CygxActivityUserSearchContent)
  1161. detailSeearch.IsShowJurisdiction = 0
  1162. detailSeearch.ChartPermissionids = ""
  1163. detailSeearch.ActiveState = ""
  1164. resp := new(models.ActivityUserSearchContentList)
  1165. detail, _ := models.GetUserSearchContentByUid(uid)
  1166. if detail == nil {
  1167. detail = detailSeearch
  1168. }
  1169. isShowJurisdiction, _ := this.GetInt("IsShowJurisdiction")
  1170. listActivityType, errActivityType := models.GetActivityTypeList()
  1171. if errActivityType != nil {
  1172. br.Msg = "获取失败"
  1173. br.ErrMsg = "获取数据失败,Err:" + errActivityType.Error()
  1174. return
  1175. }
  1176. var listChartPermissionid []*models.ActivityChartPermission
  1177. var errChart error
  1178. if isShowJurisdiction == 1 {
  1179. listChartPermissionidAll, errChartAll := models.GetUserCompanyPermission(user.CompanyId)
  1180. listChartPermissionid = listChartPermissionidAll
  1181. errChart = errChartAll
  1182. } else if isShowJurisdiction == 2 {
  1183. listChartPermissionidAll, errChartAll := models.GetChartPermissionActivity()
  1184. listChartPermissionid = listChartPermissionidAll
  1185. errChart = errChartAll
  1186. } else {
  1187. if detail.IsShowJurisdiction == 1 {
  1188. listChartPermissionidAll, errChartAll := models.GetUserCompanyPermission(user.CompanyId)
  1189. listChartPermissionid = listChartPermissionidAll
  1190. errChart = errChartAll
  1191. } else {
  1192. listChartPermissionidAll, errChartAll := models.GetChartPermissionActivity()
  1193. listChartPermissionid = listChartPermissionidAll
  1194. errChart = errChartAll
  1195. }
  1196. }
  1197. if errChart != nil {
  1198. br.Msg = "获取信息失败"
  1199. br.ErrMsg = "获取品种信息失败,Err:" + errChart.Error()
  1200. return
  1201. }
  1202. if detail.IsShowJurisdiction == 1 {
  1203. resp.IsShowJurisdiction = true
  1204. }
  1205. fmt.Println(isShowJurisdiction)
  1206. if isShowJurisdiction == 1 || detail.IsShowJurisdiction == 1 {
  1207. resp.IsShowJurisdiction = true
  1208. for k, _ := range listChartPermissionid {
  1209. listChartPermissionid[k].IsChoose = true
  1210. }
  1211. }
  1212. if isShowJurisdiction == 2 {
  1213. resp.IsShowJurisdiction = false
  1214. }
  1215. activeStateList := []models.ActivityStaus{models.ActivityStaus{Id: 1, StatusName: "未开始", IsChoose: true}, models.ActivityStaus{Id: 2, StatusName: "进行中"}, models.ActivityStaus{Id: 3, StatusName: "已结束"}}
  1216. list2, err := models.GetChartPermissionActivity()
  1217. if err != nil {
  1218. br.Msg = "获取信息失败"
  1219. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  1220. return
  1221. }
  1222. resp.ListChartPermission2 = list2
  1223. if activeStateList[1].IsChoose == activeStateList[2].IsChoose == false {
  1224. activeStateList[0].IsChoose = true
  1225. }
  1226. var userType int
  1227. var permissionStr string
  1228. if user.CompanyId <= 1 {
  1229. userType = 0
  1230. } else {
  1231. total, err := models.GetCountCompanyDetailByIdGroup(user.CompanyId)
  1232. if err != nil {
  1233. br.Msg = "获取失败"
  1234. br.ErrMsg = "获取失败,Err:" + err.Error()
  1235. return
  1236. }
  1237. if total == 0 {
  1238. userType = 0
  1239. } else {
  1240. companyDetail, err := models.GetCompanyDetailByIdGroup(user.CompanyId)
  1241. if err != nil {
  1242. br.Msg = "获取信息失败!"
  1243. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  1244. return
  1245. }
  1246. if companyDetail == nil {
  1247. br.Msg = "获取信息失败!"
  1248. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId)
  1249. return
  1250. }
  1251. permissionStr, err = models.GetCompanyPermission(user.CompanyId)
  1252. if err != nil {
  1253. br.Msg = "获取信息失败"
  1254. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  1255. return
  1256. }
  1257. //1、永续客户 //2、大套餐客户(4个行业全开通的正式客户) //3、分行业套餐客户(开通对应行业的正式客户) //4、仅开通专家套餐的正式客户 //5、开通对应行业套餐或专家套餐的试用客户
  1258. if companyDetail.Status == "永续" {
  1259. userType = 1
  1260. } else if companyDetail.Status == "试用" {
  1261. userType = 5
  1262. } else if companyDetail.Status == "正式" {
  1263. if permissionStr == "专家" {
  1264. userType = 4
  1265. } else if strings.Contains(permissionStr, "医药") && strings.Contains(permissionStr, "消费") && strings.Contains(permissionStr, "科技") && strings.Contains(permissionStr, "智造") {
  1266. userType = 2
  1267. } else {
  1268. userType = 3
  1269. }
  1270. if userType == 3 {
  1271. if !strings.Contains(permissionStr, "医药") && !strings.Contains(permissionStr, "消费") && !strings.Contains(permissionStr, "科技") && !strings.Contains(permissionStr, "智造") {
  1272. userType = 4
  1273. }
  1274. }
  1275. }
  1276. }
  1277. }
  1278. var listChartPermissionidNew []*models.ActivityChartPermission
  1279. for _, v := range listChartPermissionid {
  1280. if userType == 1 {
  1281. if v.PermissionName != "研选" {
  1282. listChartPermissionidNew = append(listChartPermissionidNew, v)
  1283. }
  1284. } else {
  1285. listChartPermissionidNew = append(listChartPermissionidNew, v)
  1286. }
  1287. }
  1288. resp.ListActivityType = listActivityType
  1289. resp.ListChartPermission = listChartPermissionidNew
  1290. resp.ListActivityStaus = activeStateList
  1291. br.Ret = 200
  1292. br.Success = true
  1293. br.Msg = "获取成功"
  1294. br.Data = resp
  1295. }
  1296. // @Title 添加会议提醒
  1297. // @Description 添加会议提醒接口
  1298. // @Param request body models.ActivityIdRep true "type json string"
  1299. // @Success Ret=200 {object} models.SignupStatus
  1300. // @router /meetingReminder/add [post]
  1301. func (this *ActivityCoAntroller) MeetingReminderAdd() {
  1302. br := new(models.BaseResponse).Init()
  1303. defer func() {
  1304. this.Data["json"] = br
  1305. this.ServeJSON()
  1306. }()
  1307. user := this.User
  1308. if user == nil {
  1309. br.Msg = "请登录"
  1310. br.ErrMsg = "请登录,用户信息为空"
  1311. br.Ret = 408
  1312. return
  1313. }
  1314. uid := user.UserId
  1315. //var signupStatus string
  1316. signupStatus := "Success"
  1317. var req models.ActivityIdRep
  1318. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1319. if err != nil {
  1320. br.Msg = "参数解析异常!"
  1321. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1322. return
  1323. }
  1324. activityId := req.ActivityId
  1325. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  1326. if activityInfo == nil {
  1327. br.Msg = "操作失败"
  1328. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  1329. return
  1330. }
  1331. if errInfo != nil {
  1332. br.Msg = "操作失败"
  1333. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  1334. return
  1335. }
  1336. //判断是否已经申请过
  1337. applyCount, err := models.GetApplyRecordCount(uid)
  1338. if err != nil && err.Error() != utils.ErrNoRow() {
  1339. br.Msg = "获取信息失败"
  1340. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  1341. return
  1342. }
  1343. //SignupStatus string `description:"报名状态:人数已满:FullStarffed、单机构超过两人:TwoPeople、爽约次数过多:BreakPromise、超时:Overtime 、成功:Success"`
  1344. item := new(models.CygxActivityMeetingReminder)
  1345. resp := new(models.SignupStatus)
  1346. hasPermission := 0
  1347. var companyDetailStatus string
  1348. if user.CompanyId <= 1 {
  1349. companyDetailStatus = ""
  1350. } else {
  1351. companyPermission, err := models.GetCompanyPermission(user.CompanyId)
  1352. if err != nil {
  1353. br.Msg = "获取信息失败"
  1354. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  1355. return
  1356. }
  1357. if companyPermission == "" {
  1358. if applyCount > 0 {
  1359. hasPermission = 4
  1360. } else {
  1361. hasPermission = 3
  1362. }
  1363. resp.HasPermission = hasPermission
  1364. resp.OperationMode = "Apply"
  1365. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  1366. br.Ret = 200
  1367. br.Success = true
  1368. br.Msg = "获取成功"
  1369. br.Data = resp
  1370. return
  1371. }
  1372. companyDetail, err := models.GetCompanyDetailById(user.CompanyId)
  1373. if err != nil {
  1374. br.Msg = "获取信息失败!"
  1375. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  1376. return
  1377. }
  1378. if companyDetail == nil {
  1379. br.Msg = "获取信息失败!"
  1380. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId)
  1381. return
  1382. }
  1383. companyDetailStatus = companyDetail.Status
  1384. }
  1385. var userType int
  1386. var permissionStr string
  1387. if user.CompanyId <= 1 {
  1388. userType = 0
  1389. } else {
  1390. companyDetail, err := models.GetCompanyDetailById(user.CompanyId)
  1391. if err != nil {
  1392. br.Msg = "获取信息失败!"
  1393. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  1394. return
  1395. }
  1396. if companyDetail == nil {
  1397. br.Msg = "获取信息失败!"
  1398. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId)
  1399. return
  1400. }
  1401. if companyDetail.Status == "永续" {
  1402. userType = 1
  1403. } else if companyDetail.Status == "试用" {
  1404. userType = 5
  1405. } else if companyDetail.Status == "正式" {
  1406. permissionStr, err = models.GetCompanyPermission(user.CompanyId)
  1407. if err != nil {
  1408. br.Msg = "获取信息失败"
  1409. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  1410. return
  1411. }
  1412. if permissionStr == "专家" {
  1413. userType = 4
  1414. } else if strings.Contains(permissionStr, "医药") && strings.Contains(permissionStr, "消费") && strings.Contains(permissionStr, "科技") && strings.Contains(permissionStr, "智造") {
  1415. userType = 2
  1416. } else {
  1417. userType = 3
  1418. }
  1419. }
  1420. }
  1421. if userType == 1 && activityInfo.ChartPermissionName == "研选" {
  1422. br.Msg = "您暂无查看该活动权限"
  1423. br.ErrMsg = "被分享客户不可见,永续客户无法查看研选行业"
  1424. return
  1425. }
  1426. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  1427. if time.Now().After(resultTime.Add(-time.Minute * 15)) {
  1428. br.Msg = "活动开始前15分钟无法设置会议提醒"
  1429. return
  1430. }
  1431. if user.CompanyId > 1 {
  1432. permissionStr, err := models.GetCompanyPermission(user.CompanyId)
  1433. if err != nil {
  1434. br.Msg = "获取信息失败"
  1435. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  1436. return
  1437. }
  1438. companyItem, err := models.GetCompanyDetailAllById(user.CompanyId)
  1439. //冻结客户
  1440. if err != nil {
  1441. if err.Error() == utils.ErrNoRow() {
  1442. resp.HasPermission = 4
  1443. resp.OperationMode = "Apply"
  1444. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  1445. br.Ret = 200
  1446. br.Success = true
  1447. br.Msg = "获取成功"
  1448. br.Data = resp
  1449. return
  1450. } else {
  1451. br.Msg = "获取信息失败"
  1452. br.ErrMsg = "获取客户公司信息失败,Err:" + err.Error()
  1453. return
  1454. }
  1455. }
  1456. var havePower bool
  1457. if (activityInfo.ActivityTypeId == 1 || activityInfo.ActivityTypeId == 3) && strings.Contains(permissionStr, "专家") && activityInfo.LimitPeopleNum == 0 {
  1458. havePower = true
  1459. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "正式" && strings.Contains(activityInfo.CustomerTypeIds, "4") {
  1460. havePower = true
  1461. } else if activityInfo.ActivityTypeId == 3 && strings.Contains(permissionStr, "专家") && companyDetailStatus == "试用" && strings.Contains(activityInfo.CustomerTypeIds, "5") {
  1462. havePower = true
  1463. } else if strings.Contains(permissionStr, activityInfo.ChartPermissionName) && strings.Contains(activityInfo.CustomerTypeIds, strconv.Itoa(userType)) {
  1464. havePower = true
  1465. } else if strings.Contains(permissionStr, activityInfo.ChartPermissionName) {
  1466. havePower = true
  1467. }
  1468. if havePower {
  1469. hasPermission = 1
  1470. signupStatus = "Success"
  1471. totalMeeting, errMeeting := models.GetActivityMeetingReminderCount(uid, activityId)
  1472. if errMeeting != nil {
  1473. br.Msg = "获取失败"
  1474. br.ErrMsg = "获取失败,Err:" + errMeeting.Error()
  1475. return
  1476. }
  1477. if totalMeeting > 0 {
  1478. br.Msg = "您已预约,请勿重复预约"
  1479. return
  1480. }
  1481. item.UserId = uid
  1482. item.ActivityId = activityId
  1483. item.CreateTime = time.Now()
  1484. item.Mobile = user.Mobile
  1485. item.Email = user.Email
  1486. item.CompanyId = user.CompanyId
  1487. item.CompanyName = user.CompanyName
  1488. _, errSignup := models.AddActivityMeetingReminder(item)
  1489. if errSignup != nil {
  1490. br.Msg = "操作失败"
  1491. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  1492. return
  1493. }
  1494. resp.HaqveJurisdiction = true
  1495. } else {
  1496. hasPermission = 2
  1497. resp.SellerMobile = companyItem.Mobile
  1498. resp.SellerName = companyItem.SellerName
  1499. resp.MsgType = "Type"
  1500. resp.OperationMode = "Call"
  1501. if permissionStr == "专家" {
  1502. resp.PopupMsg = "您暂无权限参加【" + activityInfo.ActivityTypeName + "】类型活动,若想参加请联系对口销售--" + companyItem.SellerName + ":" + companyItem.Mobile
  1503. resp.MsgType = "Type"
  1504. } else {
  1505. resp.PopupMsg = "您暂无权限参加【" + activityInfo.ChartPermissionName + "】行业活动,若想参加请联系对口销售--" + companyItem.SellerName + ":" + companyItem.Mobile
  1506. resp.MsgType = "Industry"
  1507. }
  1508. }
  1509. } else { //潜在客户
  1510. if applyCount > 0 {
  1511. hasPermission = 4
  1512. } else {
  1513. hasPermission = 3
  1514. }
  1515. resp.OperationMode = "Apply"
  1516. resp.PopupMsg = "您暂无权限参加 【" + activityInfo.ChartPermissionName + "】行业活动,若想参加可以申请开通哦"
  1517. }
  1518. resp.HasPermission = hasPermission
  1519. resp.SignupStatus = signupStatus
  1520. resp.ActivityId = activityId
  1521. var total int
  1522. total, err = models.GetUserActivityMeetingReminderCount(user.UserId)
  1523. if err != nil {
  1524. br.Msg = "获取信息失败"
  1525. br.ErrMsg = "获取日程数量信息失败,Err:" + err.Error()
  1526. return
  1527. }
  1528. if total <= 1 {
  1529. resp.GoFollow = true
  1530. }
  1531. br.Ret = 200
  1532. br.Success = true
  1533. if hasPermission == 1 {
  1534. br.Msg = "设置成功,会前15分钟会为您推送微信消息提醒"
  1535. }
  1536. br.Data = resp
  1537. }
  1538. // @Title 取消会议提醒
  1539. // @Description 取消会议提醒接口
  1540. // @Param request body models.ActivityIdRep true "type json string"
  1541. // @Success Ret=200 {object} models.SignupStatus
  1542. // @router /meetingReminder/cancel [post]
  1543. func (this *ActivityCoAntroller) MeetingReminderCancel() {
  1544. br := new(models.BaseResponse).Init()
  1545. defer func() {
  1546. this.Data["json"] = br
  1547. this.ServeJSON()
  1548. }()
  1549. user := this.User
  1550. if user == nil {
  1551. br.Msg = "请登录"
  1552. br.ErrMsg = "请登录,用户信息为空"
  1553. br.Ret = 408
  1554. return
  1555. }
  1556. uid := user.UserId
  1557. var req models.ActivityIdRep
  1558. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  1559. if err != nil {
  1560. br.Msg = "参数解析异常!"
  1561. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  1562. return
  1563. }
  1564. activityId := req.ActivityId
  1565. signupStatus := "Success"
  1566. item := new(models.CygxActivityMeetingReminder)
  1567. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  1568. if activityInfo == nil {
  1569. br.Msg = "操作失败"
  1570. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  1571. return
  1572. }
  1573. if errInfo != nil {
  1574. br.Msg = "操作失败"
  1575. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  1576. return
  1577. }
  1578. //if signupStatus == "Success" {
  1579. total, err := models.GetActivityMeetingReminderCount(uid, activityId)
  1580. if err != nil {
  1581. br.Msg = "获取失败"
  1582. br.ErrMsg = "获取失败,Err:" + err.Error()
  1583. return
  1584. }
  1585. if total == 0 {
  1586. br.Msg = "您暂未添加该活动会议提醒"
  1587. return
  1588. }
  1589. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  1590. if time.Now().After(resultTime.Add(-time.Minute * 15)) {
  1591. br.Msg = "活动开始前15分钟无法取消会议提醒"
  1592. return
  1593. }
  1594. item.UserId = uid
  1595. item.ActivityId = activityId
  1596. item.CreateTime = time.Now()
  1597. item.Mobile = user.Mobile
  1598. item.Email = user.Email
  1599. item.CompanyId = user.CompanyId
  1600. item.CompanyName = user.CompanyName
  1601. _, errSignup := models.CancelActivityMeetingReminder(item)
  1602. if errSignup != nil {
  1603. br.Msg = "操作失败"
  1604. br.ErrMsg = "操作失败,Err:" + errSignup.Error()
  1605. return
  1606. }
  1607. //}
  1608. resp := new(models.SignupStatus)
  1609. resp.SignupStatus = signupStatus
  1610. resp.ActivityId = activityId
  1611. br.Ret = 200
  1612. br.Success = true
  1613. br.Msg = "会议提醒已取消"
  1614. br.Data = resp
  1615. }
  1616. // @Title 敏捷搜索关键词的列表
  1617. // @Description 获取敏捷搜索关键词的列表接口
  1618. // @Success 200 {object} models.ActivityFastsearchKeywordsListResp
  1619. // @router /fastSearchKeWord [get]
  1620. func (this *ActivityABaseController) FastSearch() {
  1621. br := new(models.BaseResponse).Init()
  1622. defer func() {
  1623. this.Data["json"] = br
  1624. this.ServeJSON()
  1625. }()
  1626. resp := new(models.ActivityFastsearchKeywordsListResp)
  1627. list, err := models.GetActivityFastsearchKeywordsList()
  1628. if err != nil {
  1629. br.Msg = "获取失败"
  1630. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  1631. return
  1632. }
  1633. resp.List = list
  1634. br.Ret = 200
  1635. br.Success = true
  1636. br.Msg = "获取成功"
  1637. br.Data = resp
  1638. }
  1639. // @Title 主题列表
  1640. // @Description 获取活动主题列表接口
  1641. // @Param ChartPermissionIds query string false "行业id 多个用 , 隔开"
  1642. // @Param ActivityTypeIds query string false "活动类型id 多个用 , 隔开"
  1643. // @Param ActiveState query string false "活动进行状态 未开始:1、进行中2、已结束3"
  1644. // @Param WhichDay query string false "哪一天 今天:1、明天:2,多个用 , 隔开"
  1645. // @Param Label query string false "搜索主题 多个用 , 隔开 (空为活动主题,非空为更多主题)"
  1646. // @Success 200 {object} models.GetCygxActivityLabelListRep
  1647. // @router /labelList [get]
  1648. func (this *ActivityCoAntroller) LabelList() {
  1649. br := new(models.BaseResponse).Init()
  1650. defer func() {
  1651. this.Data["json"] = br
  1652. this.ServeJSON()
  1653. }()
  1654. user := this.User
  1655. if user == nil {
  1656. br.Msg = "请登录"
  1657. br.ErrMsg = "请登录,SysUser Is Empty"
  1658. return
  1659. }
  1660. pageSize, _ := this.GetInt("PageSize")
  1661. //currentIndex, _ := this.GetInt("CurrentIndex")
  1662. chartPermissionIds := this.GetString("ChartPermissionIds")
  1663. activityTypeIds := this.GetString("ActivityTypeIds")
  1664. whichDay := this.GetString("WhichDay")
  1665. isShowJurisdiction, _ := this.GetInt("IsShowJurisdiction")
  1666. activeState := this.GetString("ActiveState")
  1667. label := this.GetString("Label")
  1668. var userType int
  1669. var permissionStr string
  1670. if user.CompanyId <= 1 {
  1671. userType = 0
  1672. } else {
  1673. total, err := models.GetCountCompanyDetailByIdGroup(user.CompanyId)
  1674. if err != nil {
  1675. br.Msg = "获取失败"
  1676. br.ErrMsg = "获取失败,Err:" + err.Error()
  1677. return
  1678. }
  1679. if total == 0 {
  1680. userType = 0
  1681. } else {
  1682. companyDetail, err := models.GetCompanyDetailByIdGroup(user.CompanyId)
  1683. if err != nil {
  1684. br.Msg = "获取信息失败!"
  1685. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  1686. return
  1687. }
  1688. if companyDetail == nil {
  1689. br.Msg = "获取信息失败!"
  1690. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId) + "CompanyId:" + strconv.Itoa(user.CompanyId)
  1691. return
  1692. }
  1693. permissionStr, err = models.GetCompanyPermission(user.CompanyId)
  1694. if err != nil {
  1695. br.Msg = "获取信息失败"
  1696. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  1697. return
  1698. }
  1699. //1、永续客户
  1700. //2、大套餐客户(4个行业全开通的正式客户)
  1701. //3、分行业套餐客户(开通对应行业的正式客户)
  1702. //4、仅开通专家套餐的正式客户
  1703. //5、开通对应行业套餐或专家套餐的试用客户
  1704. if companyDetail.Status == "永续" {
  1705. userType = 1
  1706. } else if companyDetail.Status == "试用" {
  1707. userType = 5
  1708. } else if companyDetail.Status == "正式" {
  1709. if permissionStr == "专家" {
  1710. userType = 4
  1711. } else if strings.Contains(permissionStr, "医药") && strings.Contains(permissionStr, "消费") && strings.Contains(permissionStr, "科技") && strings.Contains(permissionStr, "智造") {
  1712. userType = 2
  1713. } else {
  1714. userType = 3
  1715. }
  1716. if userType == 3 {
  1717. if !strings.Contains(permissionStr, "医药") && !strings.Contains(permissionStr, "消费") && !strings.Contains(permissionStr, "科技") && !strings.Contains(permissionStr, "智造") {
  1718. userType = 4
  1719. }
  1720. }
  1721. }
  1722. }
  1723. }
  1724. if isShowJurisdiction == 1 && chartPermissionIds == "" && userType == 4 {
  1725. activityTypeIds = "1,3"
  1726. }
  1727. var startSize int
  1728. //if pageSize <= 0 {
  1729. // pageSize = utils.PageSize20
  1730. //}
  1731. //currentIndex = 1
  1732. pageSize = 16
  1733. //startSize = utils.StartIndex(currentIndex, pageSize)
  1734. var condition string
  1735. var sortTime string
  1736. var pars []interface{}
  1737. //活动可见限制
  1738. var sqlExport string
  1739. slicePer := strings.Split(permissionStr, ",")
  1740. var permissionSqlStr string
  1741. //for _, v := range slicePer {
  1742. // permissionSqlStr += "'" + v + "',"
  1743. //}
  1744. for _, v := range slicePer {
  1745. if userType == 1 {
  1746. if v != "研选" {
  1747. permissionSqlStr += "'" + v + "',"
  1748. }
  1749. } else {
  1750. permissionSqlStr += "'" + v + "',"
  1751. }
  1752. }
  1753. permissionSqlStr = strings.TrimRight(permissionSqlStr, ",")
  1754. permissionSqlStr = ` AND art.chart_permission_name IN (` + permissionSqlStr + `)`
  1755. sqlExport = ` AND (art.customer_type_ids LIKE '%` + strconv.Itoa(userType) + `%' `
  1756. if userType == 2 {
  1757. sqlExport += ` OR art.customer_type_ids LIKE '%3%' `
  1758. }
  1759. if (userType == 2 || userType == 3) && strings.Contains(permissionStr, "专家") {
  1760. sqlExport += ` OR art.customer_type_ids LIKE '%4%' `
  1761. }
  1762. sqlExport += `) `
  1763. condition += ` AND art.publish_status = 1 AND art.label != '' `
  1764. //condition += ` AND art.active_state = 1 `
  1765. var conditionOr string
  1766. if (userType == 2 || userType == 3 || userType == 4) && strings.Contains(permissionStr, "专家") {
  1767. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%4%' ` + condition + `) `
  1768. }
  1769. if (userType == 5) && strings.Contains(permissionStr, "专家") {
  1770. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%5%' ` + condition + `) `
  1771. }
  1772. if userType == 1 {
  1773. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + permissionSqlStr + `) `
  1774. } else {
  1775. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + `) `
  1776. }
  1777. //conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + `) `
  1778. condition += `AND art.is_limit_people = 1 ` + permissionSqlStr + sqlExport + conditionOr
  1779. resp := new(models.GetCygxActivityLabelListRep)
  1780. //conditionLaable := condition
  1781. //主题
  1782. if label != "" {
  1783. sortTime = ` timesort DESC `
  1784. listAll, errList := models.GetActivityLabelListAll(condition, sortTime, pars, startSize, 32)
  1785. if errList != nil {
  1786. br.Msg = "获取失败"
  1787. br.ErrMsg = "获取失败,Err:" + errList.Error()
  1788. return
  1789. }
  1790. condition += ` AND art.active_state = 1 `
  1791. list1, errList := models.GetActivityLabelListAll(condition, sortTime, pars, startSize, 16)
  1792. if errList != nil {
  1793. br.Msg = "获取失败"
  1794. br.ErrMsg = "获取失败,Err:" + errList.Error()
  1795. return
  1796. }
  1797. for _, v := range listAll {
  1798. var isHAve bool
  1799. for _, v2 := range list1 {
  1800. if v2.KeyWord == v.KeyWord {
  1801. isHAve = true
  1802. }
  1803. }
  1804. if !isHAve {
  1805. resp.List = append(resp.List, v)
  1806. }
  1807. }
  1808. br.Ret = 200
  1809. br.Success = true
  1810. br.Msg = "获取成功"
  1811. br.Data = resp
  1812. return
  1813. } else {
  1814. //行业名称
  1815. condition = ` AND art.publish_status = 1 AND art.label != '' `
  1816. if len(chartPermissionIds) > 0 {
  1817. condition += ` AND art.chart_permission_id IN (` + chartPermissionIds + `)`
  1818. }
  1819. if activityTypeIds != "" {
  1820. condition += ` AND art.activity_type_id IN (` + activityTypeIds + `)`
  1821. }
  1822. var conditionOr string
  1823. if whichDay != "" {
  1824. var startDate string
  1825. var endDate string
  1826. if whichDay == "1" {
  1827. startDate = time.Now().Format(utils.FormatDate)
  1828. endDate = startDate
  1829. } else if whichDay == "2" {
  1830. startDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  1831. endDate = startDate
  1832. } else {
  1833. startDate = time.Now().Format(utils.FormatDate)
  1834. endDate = time.Now().AddDate(0, 0, +1).Format(utils.FormatDate)
  1835. }
  1836. condition += ` AND art.activity_time >= ` + "'" + startDate + " 00:00:00'"
  1837. condition += ` AND art.activity_time <= ` + "'" + endDate + " 23:59:59'"
  1838. }
  1839. if activeState != "" {
  1840. condition += ` AND art.active_state IN (` + activeState + `)`
  1841. } else {
  1842. condition += ` AND art.active_state IN (1)`
  1843. }
  1844. if (userType == 2 || userType == 3 || userType == 4) && strings.Contains(permissionStr, "专家") {
  1845. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%4%' ` + condition + `) `
  1846. }
  1847. if (userType == 5) && strings.Contains(permissionStr, "专家") {
  1848. conditionOr += ` OR ( art.is_limit_people = 1 AND art.customer_type_ids LIKE '%5%' ` + condition + `) `
  1849. }
  1850. if userType == 1 {
  1851. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + permissionSqlStr + `) `
  1852. } else {
  1853. conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + `) `
  1854. }
  1855. //conditionOr += ` OR ( art.is_limit_people = 0 ` + condition + `) `
  1856. condition += `AND art.is_limit_people = 1 ` + permissionSqlStr + sqlExport + conditionOr
  1857. }
  1858. sortTime = ` mintimesort ASC `
  1859. list, errList := models.GetActivityLabelListAll(condition, sortTime, pars, startSize, pageSize)
  1860. if errList != nil {
  1861. br.Msg = "获取失败"
  1862. br.ErrMsg = "获取失败,Err:" + errList.Error()
  1863. return
  1864. }
  1865. //resp := new(models.GetCygxActivityLabelListRep)
  1866. resp.List = list
  1867. br.Ret = 200
  1868. br.Success = true
  1869. br.Msg = "获取成功"
  1870. br.Data = resp
  1871. }
  1872. // @Title 上传公司名称excel
  1873. // @Description 上传参会表格数据
  1874. // @Param File query file true "文件"
  1875. // @Success 200 Ret=200 导入成功
  1876. // @router /activityMeet/import [post]
  1877. func (this *ActivityCoAntroller) Import() {
  1878. br := new(models.BaseResponse).Init()
  1879. defer func() {
  1880. this.Data["json"] = br
  1881. this.ServeJSON()
  1882. }()
  1883. sysUser := this.User
  1884. if sysUser == nil {
  1885. br.Msg = "请重新登录"
  1886. return
  1887. }
  1888. file, h, err := this.GetFile("File")
  1889. if err != nil {
  1890. br.Msg = "获取文件失败"
  1891. br.ErrMsg = "获取文件失败,Err:" + err.Error()
  1892. return
  1893. }
  1894. uploadDir := "static/xls"
  1895. err = os.MkdirAll(uploadDir, 766)
  1896. if err != nil {
  1897. br.Msg = "存储目录创建失败"
  1898. br.ErrMsg = "存储目录创建失败,Err:" + err.Error()
  1899. return
  1900. }
  1901. path := uploadDir + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + h.Filename
  1902. defer file.Close()
  1903. err = this.SaveToFile("File", path)
  1904. if err != nil {
  1905. br.Msg = "文件保存失败"
  1906. br.ErrMsg = "文件保存失败,Err:" + err.Error()
  1907. return
  1908. }
  1909. xlFile, err := xlsx.OpenFile(path)
  1910. if err != nil {
  1911. br.Msg = "文件导入失败"
  1912. br.ErrMsg = "文件导入失败,Err:" + err.Error()
  1913. return
  1914. }
  1915. //允许添加的联系人
  1916. needAddAttendanc := make([]*models.UserWhiteList, 0)
  1917. // 遍历sheet页读取
  1918. for _, sheet := range xlFile.Sheets {
  1919. //遍历行读取
  1920. maxRow := sheet.MaxRow
  1921. for i := 0; i < maxRow; i++ {
  1922. if i >= 1 {
  1923. row := sheet.Row(i)
  1924. cells := row.Cells
  1925. var companyName, permission string
  1926. for k, cell := range cells {
  1927. if k == 0 {
  1928. companyName = cell.String()
  1929. }
  1930. if k == 2 {
  1931. permission = cell.String()
  1932. }
  1933. }
  1934. //这些字段都没有的话,系统认为excel到底了
  1935. if companyName == "" {
  1936. break
  1937. }
  1938. item := new(models.UserWhiteList)
  1939. item.CompanyName = companyName
  1940. item.Permission = permission
  1941. needAddAttendanc = append(needAddAttendanc, item)
  1942. }
  1943. }
  1944. }
  1945. //var mobileStr string
  1946. var permissionStr string
  1947. for k, v := range needAddAttendanc {
  1948. if k > 0 && v.CompanyName != needAddAttendanc[k-1].CompanyName {
  1949. permissionStr, err = models.GetCompanyPermissionByName(v.CompanyName)
  1950. if err != nil {
  1951. br.Msg = "获取信息失败"
  1952. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  1953. return
  1954. }
  1955. }
  1956. if k == 0 {
  1957. permissionStr, err = models.GetCompanyPermissionByName(v.CompanyName)
  1958. if err != nil {
  1959. br.Msg = "获取信息失败"
  1960. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  1961. return
  1962. }
  1963. }
  1964. needAddAttendanc[k].Permission = permissionStr
  1965. fmt.Println(permissionStr)
  1966. }
  1967. defer func() {
  1968. os.Remove(path)
  1969. }()
  1970. //创建excel
  1971. dir, errFile := os.Executable()
  1972. exPath := filepath.Dir(dir)
  1973. downLoadnFilePath := exPath + "/" + time.Now().Format(utils.FormatDateTimeUnSpace) + ".xlsx"
  1974. xlsxFile := xlsx.NewFile()
  1975. if errFile != nil {
  1976. br.Msg = "生成文件失败Err:" + errFile.Error()
  1977. return
  1978. }
  1979. style := xlsx.NewStyle()
  1980. alignment := xlsx.Alignment{
  1981. Horizontal: "center",
  1982. Vertical: "center",
  1983. WrapText: true,
  1984. }
  1985. style.Alignment = alignment
  1986. style.ApplyAlignment = true
  1987. sheet, err := xlsxFile.AddSheet("白名单")
  1988. if err != nil {
  1989. br.Msg = "新增Sheet失败,Err:" + err.Error()
  1990. return
  1991. }
  1992. //标头
  1993. rowTitle := sheet.AddRow()
  1994. cellA := rowTitle.AddCell()
  1995. cellA.Value = ""
  1996. cellB := rowTitle.AddCell()
  1997. cellB.Value = "公司"
  1998. cellC := rowTitle.AddCell()
  1999. cellC.Value = "权限"
  2000. for _, item := range needAddAttendanc {
  2001. row := sheet.AddRow()
  2002. cellA := row.AddCell()
  2003. cellA.Value = item.CompanyName
  2004. cellB := row.AddCell()
  2005. if item.Permission == "" {
  2006. //item.Permission = "专家/医药/智造/消费/研选/科技/策略/路演服务"
  2007. }
  2008. cellB.Value = item.Permission
  2009. }
  2010. errFile = xlsxFile.Save(downLoadnFilePath)
  2011. if errFile != nil {
  2012. br.Msg = "保存文件失败Err:" + errFile.Error()
  2013. return
  2014. }
  2015. br.Msg = "导入成功"
  2016. br.Ret = 200
  2017. br.Success = true
  2018. }
  2019. // @Title 活动带问
  2020. // @Description 新增活动带问接口
  2021. // @Param request body models.AddCygxActivityHelpAsk true "type json string"
  2022. // @Success Ret=200 新增成功
  2023. // @router /askAdd [post]
  2024. func (this *ActivityCoAntroller) AskAdd() {
  2025. br := new(models.BaseResponse).Init()
  2026. defer func() {
  2027. this.Data["json"] = br
  2028. this.ServeJSON()
  2029. }()
  2030. user := this.User
  2031. if user == nil {
  2032. br.Msg = "请登录"
  2033. br.ErrMsg = "请登录,SysUser Is Empty"
  2034. br.Ret = 408
  2035. return
  2036. }
  2037. var req models.CygxActivityHelpAsk
  2038. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  2039. if err != nil {
  2040. br.Msg = "参数解析异常!"
  2041. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  2042. return
  2043. }
  2044. if req.Content == "" {
  2045. br.Msg = "建议内容不可为空"
  2046. return
  2047. }
  2048. activityId := req.ActivityId
  2049. content := req.Content
  2050. activityInfo, errInfo := models.GetAddActivityInfoById(activityId)
  2051. if activityInfo == nil {
  2052. br.Msg = "操作失败"
  2053. br.ErrMsg = "活动ID错误,不存在activityId:" + strconv.Itoa(activityId)
  2054. return
  2055. }
  2056. if errInfo != nil {
  2057. br.Msg = "操作失败"
  2058. br.ErrMsg = "操作失败,Err:" + errInfo.Error()
  2059. return
  2060. }
  2061. resultTime := utils.StrTimeToTime(activityInfo.ActivityTime) //时间字符串格式转时间格式
  2062. if time.Now().After(resultTime.Add(-time.Minute * 60)) {
  2063. br.Msg = "活动开始前1小时内无法提交问题"
  2064. return
  2065. }
  2066. companyDetail, err := models.GetCompanyDetailById(user.CompanyId)
  2067. if err != nil {
  2068. br.Msg = "提交失败!"
  2069. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  2070. return
  2071. }
  2072. if companyDetail == nil {
  2073. br.Msg = "提交失败!"
  2074. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId)
  2075. return
  2076. }
  2077. item := new(models.CygxActivityHelpAsk)
  2078. item.UserId = user.UserId
  2079. item.ActivityId = req.ActivityId
  2080. item.CompanyId = user.CompanyId
  2081. item.CompanyName = companyDetail.CompanyName
  2082. item.CreateTime = time.Now()
  2083. item.Mobile = user.Mobile
  2084. item.Email = user.Email
  2085. item.Content = content
  2086. _, err = models.AddActivityHelpAsk(item)
  2087. if err != nil {
  2088. br.Msg = "提交失败"
  2089. br.ErrMsg = "提交带问失败,Err:" + err.Error()
  2090. return
  2091. }
  2092. br.Ret = 200
  2093. br.Success = true
  2094. br.Msg = "新增成功"
  2095. }