user.go 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "hongze/hongze_cygx/models"
  5. "hongze/hongze_cygx/services"
  6. "hongze/hongze_cygx/utils"
  7. "rdluck_tools/paging"
  8. "strconv"
  9. "strings"
  10. "time"
  11. )
  12. //用户
  13. type UserController struct {
  14. BaseAuthController
  15. }
  16. // @Title 登录
  17. // @Description 登录接口
  18. // @Param request body models.LoginReq true "type json string"
  19. // @Success 200 {object} models.LoginResp
  20. // @router /login [post]
  21. func (this *UserController) Login() {
  22. br := new(models.BaseResponse).Init()
  23. defer func() {
  24. this.Data["json"] = br
  25. this.ServeJSON()
  26. }()
  27. var req models.LoginReq
  28. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  29. if err != nil {
  30. br.Msg = "参数解析异常!"
  31. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  32. return
  33. }
  34. user := this.User
  35. if user == nil {
  36. br.Msg = "请登录"
  37. br.ErrMsg = "请登录"
  38. br.Ret = 408
  39. return
  40. }
  41. unionId := this.User.UnionId
  42. userId := this.User.UserId
  43. if unionId == "" {
  44. br.Msg = "参数错误"
  45. br.ErrMsg = "参数错误,unionId 为空"
  46. return
  47. }
  48. newUserId := 0
  49. if req.LoginType == 1 {
  50. //BindMobile(openId, mobile string, userId, loginType int) (err error) {
  51. req.Mobile = strings.Trim(req.Mobile, " ")
  52. newUserId, err = models.PcBindMobile(unionId, req.Mobile, userId, req.LoginType)
  53. } else if req.LoginType == 2 {
  54. if req.Email == "" {
  55. br.ErrMsg = "邮箱不能为空,请输入邮箱"
  56. br.Msg = "邮箱不能为空,请输入邮箱"
  57. return
  58. }
  59. if !utils.ValidateEmailFormatat(req.Email) {
  60. br.ErrMsg = "邮箱格式错误,请重新输入"
  61. br.Msg = "邮箱格式错误,请重新输入"
  62. return
  63. }
  64. newUserId, err = models.PcBindMobile(unionId, req.Email, userId, req.LoginType)
  65. } else {
  66. br.Msg = "无效的登录方式"
  67. br.ErrMsg = "无效的登录方式,Err:" + err.Error()
  68. return
  69. }
  70. var token string
  71. tokenItem, err := models.GetTokenByUid(newUserId)
  72. if err != nil && err.Error() != utils.ErrNoRow() {
  73. br.Msg = "登录失败"
  74. br.ErrMsg = "登录失败,获取token失败:" + err.Error()
  75. return
  76. }
  77. if tokenItem == nil || (err != nil && err.Error() == utils.ErrNoRow()) {
  78. timeUnix := time.Now().Unix()
  79. timeUnixStr := strconv.FormatInt(timeUnix, 10)
  80. token = utils.MD5(strconv.Itoa(userId)) + utils.MD5(timeUnixStr)
  81. //新增session
  82. {
  83. session := new(models.CygxSession)
  84. session.OpenId = unionId
  85. session.UnionId = unionId
  86. session.UserId = userId
  87. session.CreatedTime = time.Now()
  88. session.LastUpdatedTime = time.Now()
  89. session.ExpireTime = time.Now().AddDate(0, 1, 0)
  90. session.AccessToken = token
  91. err = models.AddSession(session)
  92. if err != nil {
  93. br.Msg = "登录失败"
  94. br.ErrMsg = "登录失败,新增用户session信息失败:" + err.Error()
  95. return
  96. }
  97. }
  98. } else {
  99. token = tokenItem.AccessToken
  100. }
  101. //新增登录日志
  102. {
  103. loginLog := new(models.WxUserLog)
  104. loginLog.UserId = userId
  105. loginLog.OpenId = unionId
  106. loginLog.Mobile = req.Mobile
  107. loginLog.Email = req.Email
  108. loginLog.CreateTime = time.Now()
  109. loginLog.Handle = "wechat_user_login"
  110. loginLog.Remark = token
  111. go models.AddWxUserLog(loginLog)
  112. }
  113. resp := new(models.LoginResp)
  114. resp.UserId = newUserId
  115. resp.Authorization = token
  116. br.Ret = 200
  117. br.Success = true
  118. br.Data = resp
  119. br.Msg = "登录成功"
  120. }
  121. // @Title 获取用户详情
  122. // @Description 获取用户详情接口
  123. // @Success 200 {object} models.UserDetail
  124. // @router /detail [get]
  125. func (this *UserController) Detail() {
  126. br := new(models.BaseResponse).Init()
  127. defer func() {
  128. this.Data["json"] = br
  129. this.ServeJSON()
  130. }()
  131. user := this.User
  132. if user == nil {
  133. br.Msg = "请登录"
  134. br.ErrMsg = "请登录,用户信息为空"
  135. br.Ret = 408
  136. return
  137. }
  138. uid := user.UserId
  139. item, err := models.GetUserDetailByUserId(uid)
  140. if err != nil {
  141. br.Msg = "获取信息失败"
  142. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  143. return
  144. }
  145. var hasPermission int
  146. if user.CompanyId > 1 {
  147. companyItem, err := models.GetCompanyDetailById(user.CompanyId)
  148. if err != nil && err.Error() != utils.ErrNoRow() {
  149. br.Msg = "获取信息失败"
  150. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  151. return
  152. }
  153. if companyItem != nil && companyItem.CompanyId > 0 {
  154. item.CompanyName = companyItem.CompanyName
  155. if companyItem.Status == "试用" || companyItem.Status == "永续" || companyItem.Status == "正式" {
  156. permissionStr, err := models.GetCompanyPermission(companyItem.CompanyId)
  157. if err != nil {
  158. br.Msg = "获取信息失败"
  159. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  160. return
  161. }
  162. item.PermissionName = permissionStr
  163. } else {
  164. hasPermission = 1
  165. }
  166. item.SellerName = companyItem.SellerName
  167. item.SellerMobile = companyItem.Mobile
  168. } else {
  169. hasPermission = 1
  170. }
  171. } else {
  172. //判断是否已经申请过
  173. applyCount, err := models.GetApplyRecordCount(uid)
  174. if err != nil && err.Error() != utils.ErrNoRow() {
  175. br.Msg = "获取信息失败"
  176. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  177. return
  178. }
  179. if applyCount > 0 {
  180. hasPermission = 3
  181. } else {
  182. hasPermission = 2
  183. }
  184. }
  185. item.HasPermission = hasPermission
  186. br.Ret = 200
  187. br.Success = true
  188. br.Msg = "获取成功"
  189. br.Data = item
  190. }
  191. // @Title 校验用户状态信息
  192. // @Description 校验用户状态信息
  193. // @Success 200 {object} models.CheckStatusResp
  194. // @router /check/status [get]
  195. func (this *UserController) CheckLogin() {
  196. br := new(models.BaseResponse).Init()
  197. defer func() {
  198. this.Data["json"] = br
  199. this.ServeJSON()
  200. }()
  201. if this.User == nil {
  202. br.Msg = "请登录"
  203. br.ErrMsg = "请登录"
  204. br.Ret = 408
  205. return
  206. }
  207. uid := this.User.UserId
  208. //判断token是否过期
  209. userItem, err := models.GetWxUserItemByUserId(uid)
  210. if err != nil {
  211. br.Msg = "获取用户信息失败"
  212. br.ErrMsg = "获取用户信息失败,Err:" + err.Error()
  213. return
  214. }
  215. resp := new(models.CheckStatusResp)
  216. permissionStr, err := models.GetCompanyPermission(userItem.CompanyId)
  217. if err != nil {
  218. br.Msg = "获取信息失败"
  219. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  220. return
  221. }
  222. resp.PermissionName = permissionStr
  223. if userItem.Mobile == "" && userItem.Email == "" {
  224. resp.IsBind = true
  225. }
  226. if userItem.UnionId == "" {
  227. resp.IsAuth = true
  228. }
  229. br.Success = true
  230. br.Msg = "获取成功"
  231. br.Data = resp
  232. br.Ret = 200
  233. }
  234. //
  235. //// @Title 绑定手机号或邮箱
  236. //// @Description 绑定手机号或邮箱
  237. //// @Param request body models.WxGetPhoneNumberReq true "type json string"
  238. //// @Success 200 {object} models.WxGetPhoneNumberResp
  239. //// @router /bind [post]
  240. //func (this *WechatController) Bind() {
  241. // br := new(models.BaseResponse).Init()
  242. // defer func() {
  243. // this.Data["json"] = br
  244. // this.ServeJSON()
  245. // }()
  246. // var req models.WxGetPhoneNumberReq
  247. // err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  248. // if err != nil {
  249. // br.Msg = "参数解析异常!"
  250. // br.ErrMsg = "参数解析失败,Err:" + err.Error()
  251. // return
  252. // }
  253. // if req.EncryptedData == "" || req.Iv == "" {
  254. // br.Msg = "参数错误"
  255. // return
  256. // }
  257. // user := this.User
  258. // if user == nil {
  259. // br.Msg = "请登陆"
  260. // br.Ret = 408
  261. // return
  262. // }
  263. // sessionKey := user.SessionKey
  264. // wxMobile, err := weapp.DecryptMobile(sessionKey, req.EncryptedData, req.Iv)
  265. // if err != nil {
  266. // br.Msg = "解析用户手机号信息失败"
  267. // br.ErrMsg = "解析用户手机号信息失败,Err:" + err.Error()
  268. // return
  269. // }
  270. // err = models.ModifyUsersMobile(user.UserId, wxMobile.PurePhoneNumber)
  271. // if err != nil {
  272. // br.Msg = "获取失败"
  273. // br.ErrMsg = "获取失败,Err:" + err.Error()
  274. // return
  275. // }
  276. // resp := new(models.WxGetPhoneNumberResp)
  277. // resp.Authorization = this.Token
  278. // resp.PhoneNumber = wxMobile.PhoneNumber
  279. // resp.PurePhoneNumber = wxMobile.PurePhoneNumber
  280. // resp.CountryCode = wxMobile.CountryCode
  281. // br.Msg = "获取成功!"
  282. // br.Ret = 200
  283. // br.Success = true
  284. // br.Data = resp
  285. //}
  286. // @Title 获取我的收藏
  287. // @Description 获取我的收藏列表
  288. // @Param PageSize query int true "PageSize"
  289. // @Param CurrentIndex query int true "CurrentIndex"
  290. // @Success 200 {object} models.ArticleCollectListResp
  291. // @router /collect/list [get]
  292. func (this *UserController) CollectList() {
  293. br := new(models.BaseResponse).Init()
  294. defer func() {
  295. this.Data["json"] = br
  296. this.ServeJSON()
  297. }()
  298. userId := this.User.UserId
  299. var pageSize, currentIndex, startSize int
  300. pageSize, _ = this.GetInt("PageSize")
  301. currentIndex, _ = this.GetInt("CurrentIndex")
  302. if pageSize <= 0 {
  303. pageSize = utils.PageSize20
  304. }
  305. if currentIndex <= 0 {
  306. currentIndex = 1
  307. }
  308. startSize = utils.StartIndex(currentIndex, pageSize)
  309. total, err := models.GetArticleUserCollectCount(userId)
  310. if err != nil {
  311. br.Msg = "获取数据失败"
  312. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  313. return
  314. }
  315. list, err := models.GetArticleUserCollectList(startSize, pageSize, userId)
  316. if err != nil {
  317. br.Msg = "获取数据失败"
  318. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  319. return
  320. }
  321. var articleIds []string
  322. for _, v := range list {
  323. articleIds = append(articleIds, strconv.Itoa(v.ArticleId))
  324. }
  325. articleIdStr := strings.Join(articleIds, ",")
  326. articleMap := make(map[int]*models.ArticleDetail)
  327. if articleIdStr != "" {
  328. articleList, err := models.GetArticleDetailByIdStr(articleIdStr)
  329. if err != nil {
  330. br.Msg = "获取数据失败"
  331. br.ErrMsg = "获取报告详情信息失败,Err:" + err.Error()
  332. return
  333. }
  334. for _, v := range articleList {
  335. if _, ok := articleMap[v.ArticleId]; !ok {
  336. articleMap[v.ArticleId] = v
  337. }
  338. }
  339. }
  340. lenList := len(list)
  341. for i := 0; i < lenList; i++ {
  342. item := list[i]
  343. article := articleMap[item.ArticleId]
  344. list[i].Title = article.Title
  345. list[i].TitleEn = article.TitleEn
  346. list[i].UpdateFrequency = article.UpdateFrequency
  347. list[i].CreateDate = article.CreateDate
  348. list[i].PublishDate = article.PublishDate
  349. list[i].Body, _ = services.GetReportContentTextSub(article.Body)
  350. list[i].Abstract = article.Abstract
  351. list[i].CategoryName = article.CategoryName
  352. list[i].SubCategoryName = article.SubCategoryName
  353. }
  354. page := paging.GetPaging(currentIndex, pageSize, total)
  355. resp := new(models.ArticleCollectListResp)
  356. resp.List = list
  357. resp.Paging = page
  358. br.Msg = "获取成功!"
  359. br.Ret = 200
  360. br.Success = true
  361. br.Data = resp
  362. }
  363. // @Title 获取申请访谈列表
  364. // @Description 获取申请访谈列表
  365. // @Param PageSize query int true "PageSize"
  366. // @Param CurrentIndex query int true "CurrentIndex"
  367. // @Success 200 {object} models.ArticleInterviewApplyListResp
  368. // @router /interview/apply/list [get]
  369. func (this *UserController) InterviewApplyList() {
  370. br := new(models.BaseResponse).Init()
  371. defer func() {
  372. this.Data["json"] = br
  373. this.ServeJSON()
  374. }()
  375. userId := this.User.UserId
  376. var pageSize, currentIndex, startSize int
  377. pageSize, _ = this.GetInt("PageSize")
  378. currentIndex, _ = this.GetInt("CurrentIndex")
  379. if pageSize <= 0 {
  380. pageSize = utils.PageSize20
  381. }
  382. if currentIndex <= 0 {
  383. currentIndex = 1
  384. }
  385. startSize = utils.StartIndex(currentIndex, pageSize)
  386. total, err := models.GetArticleUserInterviewApplyCount(userId)
  387. if err != nil {
  388. br.Msg = "获取数据失败"
  389. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  390. return
  391. }
  392. list, err := models.GetArticleUserInterviewApplyList(startSize, pageSize, userId)
  393. if err != nil {
  394. br.Msg = "获取数据失败"
  395. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  396. return
  397. }
  398. var articleIds []string
  399. for _, v := range list {
  400. articleIds = append(articleIds, strconv.Itoa(v.ArticleId))
  401. }
  402. articleIdStr := strings.Join(articleIds, ",")
  403. articleMap := make(map[int]*models.ArticleDetail)
  404. if articleIdStr != "" {
  405. articleList, err := models.GetArticleDetailByIdStr(articleIdStr)
  406. if err != nil {
  407. br.Msg = "获取数据失败"
  408. br.ErrMsg = "获取报告详情信息失败,Err:" + err.Error()
  409. return
  410. }
  411. for _, v := range articleList {
  412. if _, ok := articleMap[v.ArticleId]; !ok {
  413. articleMap[v.ArticleId] = v
  414. }
  415. }
  416. }
  417. lenList := len(list)
  418. for i := 0; i < lenList; i++ {
  419. item := list[i]
  420. article := articleMap[item.ArticleId]
  421. list[i].Title = article.Title
  422. list[i].TitleEn = article.TitleEn
  423. list[i].UpdateFrequency = article.UpdateFrequency
  424. list[i].CreateDate = article.CreateDate
  425. list[i].PublishDate = article.PublishDate
  426. list[i].Body, _ = services.GetReportContentTextSub(article.Body)
  427. list[i].Abstract = article.Abstract
  428. list[i].CategoryName = article.CategoryName
  429. list[i].SubCategoryName = article.SubCategoryName
  430. }
  431. page := paging.GetPaging(currentIndex, pageSize, total)
  432. resp := new(models.ArticleInterviewApplyListResp)
  433. resp.List = list
  434. resp.Paging = page
  435. br.Msg = "获取成功!"
  436. br.Ret = 200
  437. br.Success = true
  438. br.Data = resp
  439. }
  440. // @Title 获取浏览历史列表
  441. // @Description 获取浏览历史列表
  442. // @Param PageSize query int true "PageSize"
  443. // @Param CurrentIndex query int true "CurrentIndex"
  444. // @Success 200 {object} models.ArticleBrowseHistoryListResp
  445. // @router /browse/history/list [get]
  446. func (this *UserController) BrowseHistoryList() {
  447. br := new(models.BaseResponse).Init()
  448. defer func() {
  449. this.Data["json"] = br
  450. this.ServeJSON()
  451. }()
  452. userId := this.User.UserId
  453. var pageSize, currentIndex, startSize int
  454. pageSize, _ = this.GetInt("PageSize")
  455. currentIndex, _ = this.GetInt("CurrentIndex")
  456. if pageSize <= 0 {
  457. pageSize = utils.PageSize20
  458. }
  459. if currentIndex <= 0 {
  460. currentIndex = 1
  461. }
  462. startSize = utils.StartIndex(currentIndex, pageSize)
  463. endDate := time.Now().AddDate(0, -1, 0).Format(utils.FormatDate)
  464. total, err := models.GetArticleUserBrowseHistoryCount(userId, endDate)
  465. if err != nil {
  466. br.Msg = "获取数据失败"
  467. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  468. return
  469. }
  470. list, err := models.GetArticleUserBrowseHistoryList(startSize, pageSize, userId, endDate)
  471. if err != nil {
  472. br.Msg = "获取数据失败"
  473. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  474. return
  475. }
  476. var articleIds []string
  477. for _, v := range list {
  478. articleIds = append(articleIds, strconv.Itoa(v.ArticleId))
  479. }
  480. articleIdStr := strings.Join(articleIds, ",")
  481. articleMap := make(map[int]*models.ArticleDetail)
  482. if articleIdStr != "" {
  483. articleList, err := models.GetArticleDetailByIdStr(articleIdStr)
  484. if err != nil {
  485. br.Msg = "获取数据失败"
  486. br.ErrMsg = "获取报告详情信息失败,Err:" + err.Error()
  487. return
  488. }
  489. for _, v := range articleList {
  490. if _, ok := articleMap[v.ArticleId]; !ok {
  491. articleMap[v.ArticleId] = v
  492. }
  493. }
  494. }
  495. lenList := len(list)
  496. for i := 0; i < lenList; i++ {
  497. item := list[i]
  498. article := articleMap[item.ArticleId]
  499. if article != nil {
  500. list[i].Title = article.Title
  501. list[i].TitleEn = article.TitleEn
  502. list[i].UpdateFrequency = article.UpdateFrequency
  503. list[i].CreateDate = article.CreateDate
  504. list[i].PublishDate = article.PublishDate
  505. list[i].Body, _ = services.GetReportContentTextSub(article.Body)
  506. list[i].Abstract = article.Abstract
  507. list[i].CategoryName = article.CategoryName
  508. list[i].SubCategoryName = article.SubCategoryName
  509. }
  510. }
  511. page := paging.GetPaging(currentIndex, pageSize, total)
  512. resp := new(models.ArticleBrowseHistoryListResp)
  513. resp.List = list
  514. resp.Paging = page
  515. br.Msg = "获取成功!"
  516. br.Ret = 200
  517. br.Success = true
  518. br.Data = resp
  519. }
  520. // @Title 未付费申请试用
  521. // @Description 未付费申请试用
  522. // @Param request body models.ApplyTryReq true "type json string"
  523. // @Success 200
  524. // @router /apply/try [post]
  525. func (this *UserController) ApplyTryOut() {
  526. br := new(models.BaseResponse).Init()
  527. defer func() {
  528. this.Data["json"] = br
  529. this.ServeJSON()
  530. }()
  531. user := this.User
  532. if user == nil {
  533. br.Msg = "请登录"
  534. br.ErrMsg = "请登录,SysUser Is Empty"
  535. br.Ret = 408
  536. return
  537. }
  538. mobile := user.Mobile
  539. var req models.ApplyTryReq
  540. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  541. if err != nil {
  542. br.Msg = "参数解析异常!"
  543. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  544. return
  545. }
  546. //判断是否存在申请
  547. var sellerMobile string
  548. if req.ApplyMethod == 2 {
  549. if req.BusinessCardUrl == "" {
  550. br.Msg = "请上传名片"
  551. return
  552. }
  553. if req.RealName == "" {
  554. br.Msg = "请输入姓名"
  555. return
  556. }
  557. if req.CompanyName == "" {
  558. br.Msg = "请输入公司名称"
  559. return
  560. }
  561. if req.BusinessCardUrl != "" && utils.RunMode == "release" {
  562. card, err := services.GetBusinessCard(req.BusinessCardUrl)
  563. if err != nil {
  564. br.Msg = "名片识别失败"
  565. br.ErrMsg = "名片识别失败,Err:" + err.Error()
  566. return
  567. }
  568. mobileStr := strings.Join(card.WordsResult.MOBILE, ",")
  569. isFlag := true
  570. if mobile != "" {
  571. if strings.Contains(mobileStr, mobile) || mobileStr == "" {
  572. isFlag = true
  573. } else {
  574. isFlag = false
  575. }
  576. }
  577. if !isFlag {
  578. //阿里云识别
  579. if utils.RunMode == "release" {
  580. aliyunResult, err := services.AliyunBusinessCard(req.BusinessCardUrl)
  581. if err != nil {
  582. br.Msg = "识别失败"
  583. br.ErrMsg = "识别失败,Err:" + err.Error()
  584. return
  585. }
  586. if !aliyunResult.Success {
  587. br.Msg = "识别失败"
  588. br.ErrMsg = "识别失败"
  589. return
  590. }
  591. mobileStr := strings.Join(aliyunResult.TelCell, ",")
  592. if mobile != "" {
  593. if strings.Contains(mobileStr, mobile) {
  594. isFlag = true
  595. } else {
  596. isFlag = false
  597. }
  598. }
  599. }
  600. }
  601. if !isFlag {
  602. br.Msg = "名片手机号与所填手机号不匹配,请重新填写"
  603. br.ErrMsg = "mobile:" + mobile
  604. return
  605. }
  606. }
  607. } else {
  608. //获取销售信息
  609. sellerItem, err := models.GetSellerByCompanyId(user.CompanyId)
  610. if err != nil && err.Error() != utils.ErrNoRow() {
  611. br.Msg = "申请失败"
  612. br.ErrMsg = "获取销售信息失败,Err:" + err.Error()
  613. return
  614. }
  615. if sellerItem != nil {
  616. sellerMobile = sellerItem.Mobile
  617. }
  618. }
  619. err = models.AddApplyRecord(&req, user.Mobile, user.CompanyName, user.UserId, user.CompanyId)
  620. if err != nil {
  621. br.Msg = "申请失败"
  622. br.ErrMsg = "申请失败,Err:" + err.Error()
  623. return
  624. }
  625. br.Msg = "申请成功!"
  626. br.Ret = 200
  627. br.Success = true
  628. br.Data = sellerMobile
  629. }