article.go 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795
  1. package controllers
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "hongze/hongze_clpt/models"
  6. "hongze/hongze_clpt/services"
  7. "hongze/hongze_clpt/utils"
  8. "strconv"
  9. "strings"
  10. "time"
  11. )
  12. type ArticleController struct {
  13. BaseAuthController
  14. }
  15. type ArticleCommonController struct {
  16. BaseCommonController
  17. }
  18. // @Title 获取报告详情
  19. // @Description 获取报告详情接口
  20. // @Param ArticleId query int true "报告ID"
  21. // @Success 200 {object} models.ArticleDetailResp
  22. // @router /detail [get]
  23. func (this *ArticleController) Detail() {
  24. br := new(models.BaseResponse).Init()
  25. defer func() {
  26. this.Data["json"] = br
  27. this.ServeJSON()
  28. }()
  29. user := this.User
  30. if user == nil {
  31. br.Msg = "请登录"
  32. br.ErrMsg = "请登录,用户信息为空"
  33. br.Ret = 408
  34. return
  35. }
  36. resp := new(models.ArticleDetailResp)
  37. uid := user.UserId
  38. articleId, err := this.GetInt("ArticleId")
  39. if articleId <= 0 {
  40. br.Msg = "文章不存在"
  41. br.ErrMsg = "文章不存在,文章ID错误"
  42. return
  43. }
  44. detail := new(models.ArticleDetail)
  45. hasPermission := 0
  46. hasFree := 0
  47. var haveResearch bool
  48. //判断是否已经申请过
  49. applyCount, err := models.GetApplyRecordCount(uid)
  50. if err != nil && err.Error() != utils.ErrNoRow() {
  51. br.Msg = "获取信息失败"
  52. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  53. return
  54. }
  55. //resp := new(models.ArticleDetailResp)
  56. detail, err = models.GetArticleDetailById(articleId)
  57. if err != nil {
  58. br.Msg = "获取信息失败"
  59. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  60. return
  61. }
  62. // 判断是否属于研选类型的报告
  63. if strings.Contains(detail.CategoryName, utils.CHART_PERMISSION_NAME_YANXUAN) {
  64. resp.IsResearch = true
  65. }
  66. // 高毅资产的联系人,有权限的行业也不能查看报告详情页。提示无权限页面
  67. if detail.ArticleTypeId == 0 && user.CompanyId == utils.GAO_YI_ZI_CHAN_COMPANY_ID {
  68. _, sellerName, sellerMobile, popupMsg, err := services.GetUserHasPermissionArticle(user)
  69. if err != nil {
  70. br.Msg = "获取信息失败"
  71. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  72. return
  73. }
  74. resp.PopupMsg = popupMsg
  75. resp.HasPermission = 3
  76. resp.SellerName = sellerName
  77. resp.SellerMobile = sellerMobile
  78. detail.Body = ""
  79. detail.Abstract = ""
  80. detail.Seller.SellerName = sellerName
  81. detail.Seller.SellerMobile = sellerMobile
  82. resp.Detail = detail
  83. br.Ret = 200
  84. br.Success = true
  85. br.Msg = "获取成功"
  86. br.Data = resp
  87. return
  88. }
  89. //是否属于专项调研报告
  90. if detail.SubCategoryName == "专项调研" {
  91. detail.IsSpecialArticle = true
  92. havePower, err := services.GetSpecialArticleDetailUserPower(user, detail)
  93. if err != nil {
  94. br.Msg = "获取信息失败"
  95. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  96. return
  97. }
  98. resp.IsSpecialArticle = true
  99. if !havePower {
  100. hasPermission, sellerName, sellerMobile, popupMsg, err := services.GetUserHasPermissionArticle(user)
  101. if err != nil {
  102. br.Msg = "获取信息失败"
  103. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  104. return
  105. }
  106. resp.PopupMsg = popupMsg
  107. resp.HasPermission = hasPermission
  108. resp.SellerName = sellerName
  109. resp.SellerMobile = sellerMobile
  110. detail.Body = ""
  111. detail.Abstract = ""
  112. detail.Seller.SellerName = sellerName
  113. detail.Seller.SellerMobile = sellerMobile
  114. resp.Detail = detail
  115. br.Ret = 200
  116. br.Success = true
  117. br.Msg = "获取成功"
  118. br.Data = resp
  119. return
  120. }
  121. }
  122. //HasPermission int `description:"1:有该行业权限,正常展示,2:无该行业权限,不存在权益客户下(ficc),3:无该品类权限,已提交过申请,4:无该品类权限,未提交过申请,5:潜在客户,未提交过申请,6:潜在客户,已提交过申请"`
  123. if user.CompanyId > 1 {
  124. companyPermission, err := models.GetCompanyPermission(user.CompanyId)
  125. if err != nil {
  126. br.Msg = "获取信息失败"
  127. br.ErrMsg = "判断是否已申请访谈失败,Err:" + strconv.Itoa(uid) + ";articleId" + strconv.Itoa(articleId)
  128. return
  129. }
  130. detail, err = models.GetArticleDetailById(articleId)
  131. if err != nil {
  132. br.Msg = "获取信息失败"
  133. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  134. return
  135. }
  136. detail.Body = services.GetReportContentTextArticleBody(detail.Body)
  137. detail.Abstract, _ = services.GetReportContentTextSub(detail.Abstract)
  138. if companyPermission == "" {
  139. if applyCount > 0 {
  140. hasPermission = 6
  141. } else {
  142. hasPermission = 2
  143. }
  144. hasFree = 2
  145. goto Loop
  146. } else {
  147. hasPermission = 1
  148. hasFree = 1
  149. var articlePermissionPermissionName string
  150. if detail.CategoryId > 0 {
  151. articlePermission, err := models.GetArticlePermission(detail.CategoryId)
  152. if err != nil {
  153. br.Msg = "获取信息失败"
  154. br.ErrMsg = "获取报告权限失败,Err:" + err.Error() + strconv.Itoa(uid) + ";articleId" + strconv.Itoa(articleId)
  155. return
  156. }
  157. if articlePermission == nil {
  158. br.Msg = "获取信息失败"
  159. br.ErrMsg = "报告权限不存在,Err:" + strconv.Itoa(uid) + ";articleId" + strconv.Itoa(articleId)
  160. return
  161. }
  162. articlePermissionPermissionName = articlePermission.PermissionName
  163. } else {
  164. articlePermissionPermissionName = detail.CategoryName
  165. }
  166. var hasPersion bool
  167. slice := strings.Split(articlePermissionPermissionName, ",")
  168. for _, v := range slice {
  169. if strings.Contains(companyPermission, v) {
  170. hasPersion = true
  171. }
  172. }
  173. userType, _, err := services.GetUserType(user.CompanyId)
  174. if err != nil {
  175. br.Msg = "获取信息失败"
  176. br.ErrMsg = "获取用户信息失败,Err:" + err.Error()
  177. return
  178. }
  179. if userType == 1 && strings.Contains(detail.CategoryName, "研选") {
  180. hasPersion = false
  181. }
  182. if detail.IsReport == 1 {
  183. detailCategory, err := models.GetdetailByCategoryIdSando(detail.CategoryId)
  184. if err != nil && err.Error() != utils.ErrNoRow() {
  185. br.Msg = "获取信息失败"
  186. br.ErrMsg = "获取信息失败,Err:" + err.Error() + "categoryID 不存在:" + strconv.Itoa(detail.CategoryId)
  187. return
  188. }
  189. permissionStr, err := models.GetCompanyPermissionByUser(user.CompanyId)
  190. if err != nil {
  191. br.Msg = "获取信息失败"
  192. br.ErrMsg = "获取客户信息失败,Err:" + err.Error()
  193. return
  194. }
  195. if detailCategory != nil {
  196. if detailCategory.PermissionType == 1 {
  197. if !strings.Contains(permissionStr, detailCategory.ChartPermissionName+"(主观)") {
  198. hasPersion = false
  199. }
  200. } else if detailCategory.PermissionType == 2 {
  201. if !strings.Contains(permissionStr, detailCategory.ChartPermissionName+"(客观)") {
  202. hasPersion = false
  203. }
  204. }
  205. }
  206. }
  207. if !hasPersion {
  208. if applyCount == 0 {
  209. hasPermission = 4
  210. } else {
  211. hasPermission = 3
  212. }
  213. }
  214. }
  215. collectCount, err := models.GetArticleCollectCount(uid, articleId)
  216. if err != nil && err.Error() != utils.ErrNoRow() {
  217. br.Msg = "获取信息失败"
  218. br.ErrMsg = "判断是否已收藏失败,Err:" + strconv.Itoa(uid) + ";articleId" + strconv.Itoa(articleId)
  219. return
  220. }
  221. if collectCount > 0 {
  222. detail.IsCollect = true
  223. }
  224. interviewApplyItem, err := models.GetArticleInterviewApply(uid, articleId)
  225. if err != nil && err.Error() != utils.ErrNoRow() {
  226. br.Msg = "获取信息失败"
  227. br.ErrMsg = "判断是否已申请访谈失败,Err:" + strconv.Itoa(uid) + ";articleId" + strconv.Itoa(articleId)
  228. return
  229. }
  230. if interviewApplyItem != nil && interviewApplyItem.InterviewApplyId > 0 {
  231. detail.IsInterviewApply = true
  232. detail.InterviewApplyStatus = interviewApplyItem.Status
  233. }
  234. //获取销售手机号
  235. sellerItem, err := models.GetSellerByCompanyId(user.CompanyId)
  236. if err != nil && err.Error() != utils.ErrNoRow() {
  237. br.Msg = "获取信息失败"
  238. br.ErrMsg = "获取销售数据失败2,Err:" + err.Error() + strconv.Itoa(uid) + ";articleId" + strconv.Itoa(articleId)
  239. return
  240. }
  241. if sellerItem != nil {
  242. detail.Seller.SellerMobile = sellerItem.Mobile
  243. detail.Seller.SellerName = sellerItem.RealName
  244. }
  245. //作者头像
  246. if detail.DepartmentId > 0 {
  247. departmentDetail, err := models.GetArticleDepartmentDateilById(detail.DepartmentId)
  248. if err == nil {
  249. detail.DepartmentDetail = departmentDetail
  250. }
  251. }
  252. } else { //潜在客户
  253. if applyCount > 0 {
  254. hasPermission = 6
  255. } else {
  256. hasPermission = 5
  257. }
  258. }
  259. Loop:
  260. if hasPermission != 1 {
  261. detail.Body = ""
  262. } else {
  263. articleFollowdetail, err := models.GetArticleFollowDetail(articleId, uid)
  264. if err != nil {
  265. br.Msg = "获取信息失败"
  266. br.ErrMsg = "获取关注信息失败,Err:" + err.Error()
  267. return
  268. }
  269. detail.FollowNum = articleFollowdetail.DNum
  270. detail.CollectionNum = articleFollowdetail.AcNum
  271. detail.Disclaimers = utils.DISCLAIMERS
  272. if articleFollowdetail.MdNum > 0 {
  273. detail.IsFollow = true
  274. }
  275. haveResearch = true
  276. }
  277. if hasPermission == 2 || hasPermission == 4 {
  278. //获取销售手机号
  279. sellerItem, err := models.GetSellerByCompanyId(user.CompanyId)
  280. if err != nil && err.Error() != utils.ErrNoRow() {
  281. br.Msg = "获取信息失败"
  282. br.ErrMsg = "获取销售数据失败2,Err:" + err.Error() + strconv.Itoa(uid) + ";articleId" + strconv.Itoa(articleId)
  283. return
  284. }
  285. if sellerItem != nil {
  286. detail.Seller.SellerMobile = sellerItem.Mobile
  287. detail.Seller.SellerName = sellerItem.RealName
  288. }
  289. }
  290. if detail.ArticleId < utils.SummaryArticleId {
  291. if user.Mobile != "" {
  292. chartUserTokenByMobile, _ := services.GetUserTokenByMobile(user.Mobile)
  293. detail.HttpUrl = utils.StrategyPlatform + strconv.Itoa(articleId) + "?token=" + chartUserTokenByMobile
  294. } else {
  295. detail.HttpUrl = utils.StrategyPlatform + strconv.Itoa(articleId)
  296. }
  297. detail.IsNeedJump = true
  298. }
  299. //hasFree := 0
  300. //var haveResearch bool
  301. fmt.Println(hasFree)
  302. fmt.Println(haveResearch)
  303. if hasPermission == 1 {
  304. go services.ArticleHistory(articleId, user)
  305. key := "CYGX_ARTICLE_READ" + strconv.Itoa(articleId) + "_" + strconv.Itoa(uid)
  306. if !utils.Rc.IsExist(key) {
  307. go services.ArticleUserRemind(user, detail, 1)
  308. utils.Rc.Put(key, 1, 30*time.Second)
  309. }
  310. }
  311. if detail.SubCategoryName == "专项调研" {
  312. detail.IsSpecialArticle = true
  313. }
  314. resp.HasPermission = hasPermission
  315. resp.IsSpecialArticle = detail.IsSpecialArticle
  316. resp.Detail = detail
  317. br.Ret = 200
  318. br.Success = true
  319. br.Msg = "获取成功"
  320. br.Data = resp
  321. }
  322. // @Title 收藏\取消收藏
  323. // @Description 收藏\取消收藏
  324. // @Param request body models.ArticleCollectReq true "type json string"
  325. // @Success 200 {object} models.ArticleCollectResp
  326. // @router /collect [post]
  327. func (this *ArticleController) ArticleCollect() {
  328. br := new(models.BaseResponse).Init()
  329. defer func() {
  330. this.Data["json"] = br
  331. this.ServeJSON()
  332. }()
  333. user := this.User
  334. if user == nil {
  335. br.Msg = "请重新登录"
  336. br.Ret = 408
  337. return
  338. }
  339. uid := user.UserId
  340. var req models.ArticleCollectReq
  341. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  342. if err != nil {
  343. br.Msg = "参数解析异常!"
  344. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  345. return
  346. }
  347. articleId := req.ArticleId
  348. detail, err := models.GetArticleDetailById(articleId)
  349. if err != nil {
  350. br.Msg = "获取信息失败"
  351. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  352. return
  353. }
  354. count, err := models.GetArticleCollectCount(uid, articleId)
  355. if err != nil {
  356. br.Msg = "获取数据失败!"
  357. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  358. return
  359. }
  360. resp := new(models.ArticleCollectResp)
  361. if count <= 0 {
  362. item := new(models.CygxArticleCollect)
  363. item.ArticleId = req.ArticleId
  364. item.UserId = uid
  365. item.CreateTime = time.Now()
  366. item.Mobile = user.Mobile
  367. item.Email = user.Email
  368. item.CompanyId = user.CompanyId
  369. item.CompanyName = user.CompanyName
  370. item.RealName = user.RealName
  371. _, err = models.AddCygxArticleCollect(item)
  372. if err != nil {
  373. br.Msg = "收藏失败"
  374. br.ErrMsg = "收藏失败,Err:" + err.Error()
  375. return
  376. }
  377. br.Msg = "收藏成功"
  378. resp.Status = 1
  379. // 文章收藏消息发送
  380. go services.ArticleUserRemind(user, detail, 1)
  381. } else {
  382. err = models.RemoveArticleCollect(uid, articleId)
  383. if err != nil {
  384. br.Msg = "取消收藏失败"
  385. br.ErrMsg = "取消收藏失败,Err:" + err.Error()
  386. return
  387. }
  388. br.Msg = "已取消收藏"
  389. resp.Status = 2
  390. }
  391. collectTotal, err := models.GetArticleCollectUsersCount(articleId)
  392. if err != nil {
  393. br.Msg = "获取数据失败"
  394. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  395. return
  396. }
  397. resp.CollectCount = collectTotal
  398. br.Ret = 200
  399. br.Success = true
  400. br.Data = resp
  401. }
  402. // @Title 访谈申请\取消访谈申请
  403. // @Description 访谈申请\取消访谈申请
  404. // @Param request body models.ArticleInterviewApplyReq true "type json string"
  405. // @Success 200 {object} models.FontsCollectResp
  406. // @router /interview/apply [post]
  407. func (this *ArticleController) InterviewApply() {
  408. br := new(models.BaseResponse).Init()
  409. defer func() {
  410. this.Data["json"] = br
  411. this.ServeJSON()
  412. }()
  413. user := this.User
  414. if user == nil {
  415. br.Msg = "请重新登录"
  416. br.Ret = 408
  417. return
  418. }
  419. uid := user.UserId
  420. var req models.ArticleInterviewApplyReq
  421. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  422. if err != nil {
  423. br.Msg = "参数解析异常!"
  424. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  425. return
  426. }
  427. article, err := models.GetArticleDetailById(req.ArticleId)
  428. if err != nil {
  429. br.Msg = "获取纪要失败!"
  430. br.ErrMsg = "获取纪要失败,Err:" + err.Error()
  431. return
  432. }
  433. count, err := models.GetArticleInterviewApplyCount(uid, req.ArticleId)
  434. if err != nil {
  435. br.Msg = "获取数据失败!"
  436. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  437. return
  438. }
  439. resp := new(models.ArticleInterviewApplyResp)
  440. if count <= 0 {
  441. item := new(models.CygxInterviewApply)
  442. item.ArticleId = req.ArticleId
  443. item.UserId = uid
  444. item.CompanyId = user.CompanyId
  445. item.Status = "待邀请"
  446. item.Sort = 1
  447. item.ArticleTitle = article.Title
  448. item.CreateTime = time.Now()
  449. item.ModifyTime = time.Now()
  450. item.ArticleIdMd5 = article.ArticleIdMd5
  451. _, err = models.AddCygxInterviewApply(item)
  452. if err != nil {
  453. br.Msg = "申请失败"
  454. br.ErrMsg = "申请失败,Err:" + err.Error()
  455. return
  456. }
  457. br.Msg = "申请成功"
  458. resp.Status = 1
  459. //发送模板消息
  460. if user.CompanyId > 1 {
  461. mobile := user.Mobile
  462. if mobile == "" {
  463. mobile = user.Email
  464. }
  465. sellerItem, _ := models.GetSellerByCompanyId(user.CompanyId)
  466. if sellerItem != nil && sellerItem.AdminId > 0 && user.Mobile != "" {
  467. openIpItem, _ := models.GetUserRecordByMobile(4, sellerItem.Mobile)
  468. if openIpItem != nil && openIpItem.OpenId != "" {
  469. go services.SendInterviewApplyTemplateMsg(user.RealName, sellerItem.CompanyName, mobile, article.Title, openIpItem)
  470. }
  471. }
  472. }
  473. } else {
  474. err = models.RemoveArticleInterviewApply(uid, req.ArticleId)
  475. if err != nil {
  476. br.Msg = "取消申请失败"
  477. br.ErrMsg = "取消申请失败,Err:" + err.Error()
  478. return
  479. }
  480. br.Msg = "已取消申请"
  481. resp.Status = 2
  482. if user.CompanyId > 1 {
  483. mobile := user.Mobile
  484. if mobile == "" {
  485. mobile = user.Email
  486. }
  487. sellerItem, _ := models.GetSellerByCompanyId(user.CompanyId)
  488. if sellerItem != nil && sellerItem.AdminId > 0 && user.Mobile != "" {
  489. openIpItem, _ := models.GetUserRecordByMobile(4, sellerItem.Mobile)
  490. if openIpItem != nil && openIpItem.OpenId != "" {
  491. go services.SendInterviewApplyCancelTemplateMsg(user.RealName, sellerItem.CompanyName, mobile, article.Title, openIpItem)
  492. }
  493. }
  494. }
  495. }
  496. br.Ret = 200
  497. br.Success = true
  498. br.Data = resp
  499. }
  500. // @Title 文章带问
  501. // @Description 新增文章带问接口
  502. // @Param request body models.AddArticleAskRep true "type json string"
  503. // @Success Ret=200 新增成功
  504. // @router /askAdd [post]
  505. func (this *ArticleController) AskAdd() {
  506. br := new(models.BaseResponse).Init()
  507. defer func() {
  508. this.Data["json"] = br
  509. this.ServeJSON()
  510. }()
  511. user := this.User
  512. if user == nil {
  513. br.Msg = "请登录"
  514. br.ErrMsg = "请登录,SysUser Is Empty"
  515. br.Ret = 408
  516. return
  517. }
  518. var req models.AddArticleAskRep
  519. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  520. if err != nil {
  521. br.Msg = "参数解析异常!"
  522. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  523. return
  524. }
  525. if req.Content == "" {
  526. br.Msg = "建议内容不可为空"
  527. return
  528. }
  529. content := req.Content
  530. //accessToken, err := models.GetWxAccessTokenByXzs()
  531. //itemToken, err := services.WxGetToken()
  532. //if err != nil {
  533. // br.Msg = "GetWxAccessToken Err:" + err.Error()
  534. // return
  535. //}
  536. //if accessToken == "" {
  537. // br.Msg = "accessToken is empty"
  538. // return
  539. //}
  540. //commerr, err := weapp.MSGSecCheck(accessToken, content)
  541. //if err != nil {
  542. // br.Msg = "内容校验失败!"
  543. // br.ErrMsg = "内容校验失败,Err:" + err.Error()
  544. //
  545. // return
  546. //}
  547. //fmt.Println(commerr)
  548. //if commerr.ErrCode != 0 {
  549. // br.Msg = "内容违规,请重新提交!"
  550. // br.ErrMsg = "颜文字内容违规,Err:" + commerr.ErrMSG
  551. // return
  552. //}
  553. articleId := req.ArticleId
  554. count, _ := models.GetArticleCountById(articleId)
  555. if count == 0 {
  556. br.Msg = "操作失败"
  557. br.ErrMsg = "文章ID错误,不存在 articleId:" + strconv.Itoa(articleId)
  558. return
  559. }
  560. companyDetail, err := models.GetCompanyDetailById(user.CompanyId)
  561. if err != nil {
  562. br.Msg = "提交失败!"
  563. br.ErrMsg = "获取客户详情失败,Err:" + err.Error()
  564. return
  565. }
  566. if companyDetail == nil {
  567. br.Msg = "提交失败!"
  568. br.ErrMsg = "客户不存在,uid:" + strconv.Itoa(user.UserId)
  569. return
  570. }
  571. item := new(models.CygxArticleAsk)
  572. item.UserId = user.UserId
  573. item.ArticleId = req.ArticleId
  574. item.CompanyId = user.CompanyId
  575. item.CompanyName = companyDetail.CompanyName
  576. item.CreateTime = time.Now()
  577. item.Mobile = user.Mobile
  578. item.Email = user.Email
  579. item.Content = content
  580. _, err = models.AddArticleAsk(item)
  581. if err != nil {
  582. br.Msg = "提交失败"
  583. br.ErrMsg = "提交失败,Err:" + err.Error()
  584. return
  585. }
  586. companyItem, err := models.GetSellerDetailAllByCompanyId(user.CompanyId)
  587. if err != nil {
  588. br.Msg = "获取信息失败"
  589. br.ErrMsg = "获取所属销售信息失败,Err:" + err.Error()
  590. return
  591. }
  592. var mobile string
  593. if utils.RunMode == "release" {
  594. //mobile = utils.WxMsgTemplateIdAskMsgMobileAll + "," + companyItem.Mobile
  595. mobile = utils.WxMsgTemplateIdAskMsgMobileAll
  596. } else {
  597. mobile = utils.WxMsgTemplateIdAskMsgMobile
  598. }
  599. openIdList, err := models.GetWxOpenIdByMobileList(mobile)
  600. if err != nil {
  601. br.Msg = "提交失败"
  602. br.ErrMsg = "提交失败,Err:" + err.Error()
  603. return
  604. }
  605. detail, err := models.GetArticleDetailById(articleId)
  606. if err != nil {
  607. br.Msg = "获取信息失败"
  608. br.ErrMsg = "获取信息失败,Err:" + err.Error()
  609. return
  610. }
  611. companyName := user.CompanyName + "-" + user.RealName + "(" + companyItem.SellerName + ")"
  612. go services.SendWxMsgWithAsk(companyName, time.Now().Format(utils.FormatDateTime), content, detail.Title, openIdList, req.ArticleId)
  613. br.Ret = 200
  614. br.Success = true
  615. br.Msg = "提交成功"
  616. }
  617. // @Title 文章相关热门收藏
  618. // @Description 文章相关热门收藏接口
  619. // @Param ArticleId query int true "文章ID"
  620. // @Success 200 {object} models.ArticleCollectionLIstResp
  621. // @router /hotList [get]
  622. func (this *ArticleController) ArticleHotList() {
  623. br := new(models.BaseResponse).Init()
  624. defer func() {
  625. this.Data["json"] = br
  626. this.ServeJSON()
  627. }()
  628. user := this.User
  629. if user == nil {
  630. br.Msg = "请重新登录"
  631. br.Ret = 408
  632. return
  633. }
  634. articleId, _ := this.GetInt("ArticleId")
  635. if articleId < 1 {
  636. br.Msg = "请输入分类ID"
  637. return
  638. }
  639. var condition string
  640. condition = ` AND a.article_id IN (SELECT article_id FROM cygx_industrial_article_group_management WHERE industrial_management_id IN (SELECT industrial_management_id FROM cygx_industrial_article_group_management WHERE article_id = ` + strconv.Itoa(articleId) + ` ) ) AND a.article_id != ` + strconv.Itoa(articleId) + ` AND a.category_name LIKE '%研选%' AND publish_status = 1 GROUP BY a.article_id ORDER BY collect_num DESC, publish_date DESC LIMIT 3 `
  641. list, err := models.GetArticleCollectionList(condition, user.UserId)
  642. if err != nil {
  643. br.Msg = "获取信息失败"
  644. br.ErrMsg = "获取品种信息失败,Err:" + err.Error()
  645. return
  646. }
  647. resp := new(models.ArticleCollectionLIstResp)
  648. if len(list) == 0 {
  649. list = make([]*models.ArticleCollectionResp, 0)
  650. }
  651. resp.List = list
  652. br.Ret = 200
  653. br.Success = true
  654. br.Msg = "获取成功"
  655. br.Data = resp
  656. }
  657. // @Title 上传文章阅读时间
  658. // @Description 上传文章阅读时间接口
  659. // @Param request body models.AddStopTimeRep true "type json string"
  660. // @Success 200 {object} models.ArticleDetailResp
  661. // @router /addStopTime [post]
  662. func (this *ArticleController) AddStopTime() {
  663. br := new(models.BaseResponse).Init()
  664. defer func() {
  665. this.Data["json"] = br
  666. this.ServeJSON()
  667. }()
  668. user := this.User
  669. if user == nil {
  670. br.Msg = "请登录"
  671. br.ErrMsg = "请登录,用户信息为空"
  672. br.Ret = 408
  673. return
  674. }
  675. var req models.AddStopTimeRep
  676. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  677. if err != nil {
  678. br.Msg = "参数解析异常!"
  679. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  680. return
  681. }
  682. uid := user.UserId
  683. articleId := req.ArticleId
  684. stopTime := req.StopTime
  685. outType := req.OutType
  686. //source := req.Source
  687. if articleId <= 0 {
  688. br.Msg = "参数错误"
  689. br.ErrMsg = "参数错误"
  690. return
  691. }
  692. if stopTime == 0 {
  693. stopTime = 1
  694. }
  695. if outType != 2 {
  696. outType = 1
  697. }
  698. //source = "WEB"
  699. detail := new(models.ArticleDetail)
  700. hasPermission := 0
  701. hasFree := 0
  702. //判断是否已经申请过
  703. applyCount, err := models.GetApplyRecordCount(uid)
  704. if err != nil && err.Error() != utils.ErrNoRow() {
  705. br.Msg = "获取信息失败"
  706. br.ErrMsg = "判断是否已申请过试用失败,Err:" + err.Error()
  707. return
  708. }
  709. //`description:"1:有该行业权限,正常展示,2:无该行业权限,不存在权益客户下,3:无该品类权限,4:潜在客户,未提交过申请,5:潜在客户,已提交过申请"`
  710. if user.CompanyId > 1 {
  711. companyPermission, err := models.GetCompanyPermission(user.CompanyId)
  712. if err != nil {
  713. br.Msg = "获取信息失败"
  714. br.ErrMsg = "判断是否已申请访谈失败,Err:" + strconv.Itoa(uid) + ";articleId" + strconv.Itoa(articleId)
  715. return
  716. }
  717. detail, err = models.GetArticleDetailById(articleId)
  718. if err != nil {
  719. br.Msg = "获取信息失败"
  720. br.ErrMsg = "获取文章信息失败,Err:" + err.Error() + strconv.Itoa(uid) + ";articleId" + strconv.Itoa(articleId)
  721. return
  722. }
  723. if companyPermission == "" {
  724. if applyCount > 0 {
  725. hasPermission = 5
  726. } else {
  727. hasPermission = 2
  728. }
  729. hasFree = 2
  730. goto Loop
  731. } else {
  732. hasFree = 1
  733. var articlePermissionPermissionName string
  734. if detail.CategoryId > 0 {
  735. articlePermission, err := models.GetArticlePermission(detail.CategoryId)
  736. if err != nil {
  737. br.Msg = "获取信息失败"
  738. br.ErrMsg = "获取报告权限失败,Err:" + err.Error() + strconv.Itoa(uid) + ";articleId" + strconv.Itoa(articleId)
  739. return
  740. }
  741. if articlePermission == nil {
  742. br.Msg = "获取信息失败"
  743. br.ErrMsg = "报告权限不存在,Err:" + strconv.Itoa(uid) + ";articleId" + strconv.Itoa(articleId)
  744. return
  745. }
  746. articlePermissionPermissionName = articlePermission.PermissionName
  747. } else {
  748. articlePermissionPermissionName = detail.CategoryName
  749. }
  750. var hasPersion bool
  751. slice := strings.Split(articlePermissionPermissionName, ",")
  752. for _, v := range slice {
  753. if strings.Contains(companyPermission, v) {
  754. hasPersion = true
  755. }
  756. }
  757. if hasPersion {
  758. go services.ArticleHistoryStopTime(articleId, stopTime, outType, user)
  759. } else { //无该行业权限
  760. hasPermission = 3
  761. }
  762. }
  763. } else { //潜在客户
  764. if applyCount > 0 {
  765. hasPermission = 5
  766. } else {
  767. hasPermission = 4
  768. }
  769. }
  770. Loop:
  771. resp := new(models.ArticleDetailAddStopTimeRep)
  772. resp.HasPermission = hasPermission
  773. resp.HasFree = hasFree
  774. br.Ret = 200
  775. br.Success = true
  776. br.Msg = "操作成功"
  777. br.Data = resp
  778. }