rai_serve.go 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529
  1. package cygx
  2. import (
  3. "fmt"
  4. "github.com/rdlucklib/rdluck_tools/paging"
  5. "hongze/hz_crm_api/controllers"
  6. "hongze/hz_crm_api/models"
  7. "hongze/hz_crm_api/models/cygx"
  8. "hongze/hz_crm_api/utils"
  9. "strconv"
  10. "strings"
  11. )
  12. // 权益服务类型
  13. type RaiServeCoAntroller struct {
  14. controllers.BaseAuthController
  15. }
  16. // @Title 服务类型列表
  17. // @Description 服务类型列表接口
  18. // @Success 200 {object} cygx.RaiServeTypeListResp
  19. // @router /rai_serve/type_list [get]
  20. func (this *RaiServeCoAntroller) TypeList() {
  21. br := new(models.BaseResponse).Init()
  22. defer func() {
  23. this.Data["json"] = br
  24. this.ServeJSON()
  25. }()
  26. sysUser := this.SysUser
  27. if sysUser == nil {
  28. br.Msg = "请登录"
  29. br.ErrMsg = "请登录,SysUser Is Empty"
  30. br.Ret = 408
  31. return
  32. }
  33. resp := new(cygx.RaiServeTypeListResp)
  34. var condition string
  35. list, err := cygx.GetRaiServeTypeRespList(condition)
  36. if err != nil {
  37. br.Msg = "获取失败"
  38. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  39. return
  40. }
  41. resp.List = list
  42. br.Ret = 200
  43. br.Success = true
  44. br.Msg = "获取成功"
  45. br.Data = resp
  46. }
  47. // @Title 标签搜索
  48. // @Description 标签搜索接口
  49. // @Param KeyWord query string false "搜索关键词"
  50. // @Success 200 {object} cygx.RaiServeTagListResp
  51. // @router /rai_serve/search_tag [get]
  52. func (this *RaiServeCoAntroller) SearchTag() {
  53. br := new(models.BaseResponse).Init()
  54. defer func() {
  55. this.Data["json"] = br
  56. this.ServeJSON()
  57. }()
  58. sysUser := this.SysUser
  59. if sysUser == nil {
  60. br.Msg = "请登录"
  61. br.ErrMsg = "请登录,SysUser Is Empty"
  62. br.Ret = 408
  63. return
  64. }
  65. keyWord := this.GetString("KeyWord")
  66. if keyWord == "" {
  67. br.Msg = "请输入搜索关键词"
  68. return
  69. }
  70. //keyWordSlice := strings.Split(keyWord, ",")
  71. //var conditionindustrial string
  72. //var conditionsubject string
  73. //for _, v := range keyWordSlice {
  74. // conditionindustrial += ` OR i.industry_name LIKE '%` + v + `%' `
  75. // conditionsubject += ` OR s.subject_name LIKE '%` + v + `%' `
  76. //}
  77. resp := new(cygx.RaiServeTagListResp)
  78. list, err := cygx.GetRaiServeSearchTagRespList(keyWord)
  79. if err != nil {
  80. br.Msg = "获取失败"
  81. br.ErrMsg = "获取数据失败,Err:" + err.Error()
  82. return
  83. }
  84. //如果有固收或者策略就去查询行业表
  85. if strings.Contains("固收", keyWord) || strings.Contains("策略", keyWord) {
  86. var condition string
  87. var pars []interface{}
  88. keyWord = "%" + keyWord + "%"
  89. condition = ` AND product_id = 2 AND permission_name IN ('策略','固收') AND permission_name LIKE ? `
  90. pars = append(pars, keyWord)
  91. listChartPermission, err := models.GetChartPermissionListByCondition(condition, pars)
  92. if err != nil {
  93. br.Msg = "获取失败"
  94. br.ErrMsg = "获取数据失败,GetChartPermissionListByCondition Err:" + err.Error()
  95. return
  96. }
  97. for _, v := range listChartPermission {
  98. item := new(cygx.RaiServeTagResp)
  99. item.TagType = 3
  100. item.TagId = v.ChartPermissionId
  101. item.TagName = v.PermissionName
  102. list = append(list, item)
  103. }
  104. }
  105. if len(list) == 0 {
  106. list = make([]*cygx.RaiServeTagResp, 0)
  107. } else {
  108. for _, v := range list {
  109. v.Md5Key = utils.MD5(fmt.Sprintf("K_", v.TagType, "V_", v.TagId))
  110. }
  111. }
  112. resp.List = list
  113. br.Ret = 200
  114. br.Success = true
  115. br.Msg = "获取成功"
  116. br.Data = resp
  117. }
  118. // @Title 标签搜索(研究员日历添加到会信息)
  119. // @Description 标签搜索接口
  120. // @Param KeyWord query string false "搜索关键词"
  121. // @Param ResearcherId query int false "研究员ID"
  122. // @Success 200 {object} cygx.RaiServeTagListResp
  123. // @router /rai_serve/search_tag_by_calendar [get]
  124. func (this *RaiServeCoAntroller) SearchTagCalendar() {
  125. br := new(models.BaseResponse).Init()
  126. defer func() {
  127. this.Data["json"] = br
  128. this.ServeJSON()
  129. }()
  130. sysUser := this.SysUser
  131. if sysUser == nil {
  132. br.Msg = "请登录"
  133. br.ErrMsg = "请登录,SysUser Is Empty"
  134. br.Ret = 408
  135. return
  136. }
  137. keyWord := this.GetString("KeyWord")
  138. researcherId := this.GetString("ResearcherId")
  139. askEmailList, err := cygx.GetAskEmailListByAdminIds(researcherId)
  140. if err != nil {
  141. br.Msg = "获取失败"
  142. br.ErrMsg = "GetAskEmailCountByCelue,Err:" + err.Error()
  143. return
  144. }
  145. var hasCelue bool
  146. var permissionName []string
  147. for _, v := range askEmailList {
  148. permissionName = append(permissionName, v.ChartPermissionName)
  149. if v.ChartPermissionName == "策略" || v.ChartPermissionName == "固收" {
  150. hasCelue = true
  151. }
  152. }
  153. var permissionNameSql []string
  154. for _, v := range permissionName {
  155. permissionNameSql = append(permissionNameSql, "'"+v+"'")
  156. }
  157. chartList, err := models.GetChartPermissionByNamesByRai(permissionNameSql)
  158. if err != nil {
  159. br.Msg = "获取失败"
  160. br.ErrMsg = "获取数据失败,GetChartPermissionByNames Err:" + err.Error()
  161. return
  162. }
  163. var list []*cygx.RaiServeTagResp
  164. resp := new(cygx.RaiServeTagListResp)
  165. if hasCelue {
  166. for _, v := range chartList {
  167. item := new(cygx.RaiServeTagResp)
  168. item.TagType = 3
  169. item.TagId = v.ChartPermissionId
  170. item.TagName = v.PermissionName
  171. list = append(list, item)
  172. }
  173. } else {
  174. if keyWord == "" {
  175. br.Msg = "请输入搜索关键词"
  176. return
  177. }
  178. keyWordSlice := strings.Split(keyWord, ",")
  179. var conditionindustrial string
  180. var conditionsubject string
  181. for _, v := range keyWordSlice {
  182. conditionindustrial += ` OR i.industry_name LIKE '%` + v + `%' `
  183. conditionsubject += ` OR s.subject_name LIKE '%` + v + `%' `
  184. }
  185. var permissionId []string
  186. for _, v := range chartList {
  187. permissionId = append(permissionId, strconv.Itoa(v.ChartPermissionId))
  188. }
  189. list, err = cygx.GetRaiServeSearchTagRespListBycharId(keyWord, strings.Join(permissionId, ","), conditionindustrial, conditionsubject)
  190. if err != nil {
  191. br.Msg = "获取失败"
  192. br.ErrMsg = "获取数据失败,GetRaiServeSearchTagRespListBycharId Err:" + err.Error()
  193. return
  194. }
  195. }
  196. if len(list) == 0 {
  197. list = make([]*cygx.RaiServeTagResp, 0)
  198. } else {
  199. for _, v := range list {
  200. v.Md5Key = utils.MD5(fmt.Sprintf("K_", v.TagType, "V_", v.TagId))
  201. }
  202. }
  203. resp.List = list
  204. br.Ret = 200
  205. br.Success = true
  206. br.Msg = "获取成功"
  207. br.Data = resp
  208. }
  209. // @Title 校验是否属于策略固收
  210. // @Description 校验是否属于策略固收接口
  211. // @Param ResearcherId query int false "研究员ID"
  212. // @Success 200 {object} cygx.RaiServeTagListResp
  213. // @router /rai_serve/chcck_PermissionName [get]
  214. func (this *RaiServeCoAntroller) ChcckPermissionName() {
  215. br := new(models.BaseResponse).Init()
  216. defer func() {
  217. this.Data["json"] = br
  218. this.ServeJSON()
  219. }()
  220. sysUser := this.SysUser
  221. if sysUser == nil {
  222. br.Msg = "请登录"
  223. br.ErrMsg = "请登录,SysUser Is Empty"
  224. br.Ret = 408
  225. return
  226. }
  227. researcherId := this.GetString("ResearcherId")
  228. askEmailList, err := cygx.GetAskEmailListByAdminIds(researcherId)
  229. if err != nil {
  230. br.Msg = "获取失败"
  231. br.ErrMsg = "GetAskEmailCountByCelue,Err:" + err.Error()
  232. return
  233. }
  234. var belong bool
  235. var permissionNameResp []string
  236. var permissionNames []string
  237. for _, v := range askEmailList {
  238. permissionNames = append(permissionNames, v.ChartPermissionName)
  239. if v.ChartPermissionName == "策略" || v.ChartPermissionName == "固收" {
  240. belong = true
  241. permissionNameResp = append(permissionNameResp, v.ChartPermissionName)
  242. }
  243. }
  244. resp := new(cygx.ChekChartPermissionNameResp)
  245. resp.Belong = belong
  246. resp.ChartPermissionName = strings.Join(permissionNameResp, ",")
  247. br.Ret = 200
  248. br.Success = true
  249. br.Msg = "获取成功"
  250. br.Data = resp
  251. }
  252. // @Title 权益服务统计列表
  253. // @Description 权益服务统计列表接口
  254. // @Param PageSize query int true "每页数据条数"
  255. // @Param CurrentIndex query int true "当前页页码,从1开始"
  256. // @Param SellerId query string false "销售id"
  257. // @Param ShareSellerId query string false "共享销售ID"
  258. // @Param ServeTypeId int int false "服务类型ID"
  259. // @Param TagType int string false "标签类型"
  260. // @Param TagId int string false "标签ID"
  261. // @Param Status query string false "客户状态,正式、未续约(除了正式之外的所有)"
  262. // @Param SortType query string true "如何排序,是正序还是倒序,枚举值:`asc 正序`,`desc 倒叙`"
  263. // @Param IsExport query bool false "是否导出excel,默认是false"
  264. // @Success 200 {object} cygx.RaiServeTagListResp
  265. // @router /rai_serve/list [get]
  266. func (this *RaiServeCoAntroller) List() {
  267. br := new(models.BaseResponse).Init()
  268. defer func() {
  269. this.Data["json"] = br
  270. this.ServeJSON()
  271. }()
  272. sysUser := this.SysUser
  273. if sysUser == nil {
  274. br.Msg = "请登录"
  275. br.ErrMsg = "请登录,SysUser Is Empty"
  276. br.Ret = 408
  277. return
  278. }
  279. pageSize, _ := this.GetInt("PageSize")
  280. currentIndex, _ := this.GetInt("CurrentIndex")
  281. status := this.GetString("Status")
  282. sellerId := this.GetString("SellerId")
  283. shareSellerId := this.GetString("ShareSellerId")
  284. sortType := this.GetString("SortType")
  285. tagType, _ := this.GetInt("TagType")
  286. tagId, _ := this.GetInt("TagId")
  287. serveTypeId, _ := this.GetInt("ServeTypeId")
  288. isExport, _ := this.GetBool("IsExport")
  289. resp := new(cygx.CygxRaiServeCompanyListResp)
  290. var startSize int
  291. if pageSize <= 0 {
  292. pageSize = utils.PageSize20
  293. }
  294. if currentIndex <= 0 {
  295. currentIndex = 1
  296. }
  297. startSize = utils.StartIndex(currentIndex, pageSize)
  298. var condition string
  299. var sortStr string
  300. var pars []interface{}
  301. if status != "" {
  302. if status == "正式" {
  303. condition = " AND status = '正式' "
  304. } else {
  305. condition = " AND status != '正式' "
  306. }
  307. }
  308. if sellerId != "" {
  309. condition = " AND seller_id IN (?) "
  310. pars = append(pars, sellerId)
  311. }
  312. if shareSellerId != "" {
  313. condition = " AND share_seller_id IN (?) "
  314. pars = append(pars, shareSellerId)
  315. }
  316. if sortType != "" {
  317. if sortType == "asc" {
  318. sortStr = " ORDER BY money ASC "
  319. } else if sortType == "desc" {
  320. sortStr = " ORDER BY money DESC "
  321. }
  322. } else {
  323. sortStr = " ORDER BY end_date DESC "
  324. }
  325. total, err := cygx.GetCygxRaiServeCompanyCount(condition, pars)
  326. if err != nil {
  327. br.Msg = "获取失败"
  328. br.ErrMsg = "获取失败,GetCygxRaiServeCompanyCountErr:" + err.Error()
  329. return
  330. }
  331. listRaiServeCompany, err := cygx.GetCygxRaiServeCompanyList(condition+sortStr, pars, startSize, pageSize)
  332. if err != nil {
  333. br.Msg = "获取失败"
  334. br.ErrMsg = "获取失败,Err:" + err.Error()
  335. return
  336. }
  337. switch tagType {
  338. case 1:
  339. fmt.Println(tagId)
  340. case 2:
  341. case 3:
  342. }
  343. if serveTypeId > 0 {
  344. }
  345. if isExport {
  346. }
  347. for _, v := range listRaiServeCompany {
  348. item := new(cygx.CygxRaiServeCompanyResp)
  349. item.CompanyId = v.CompanyId
  350. item.CompanyName = v.CompanyName
  351. item.Money = v.Money
  352. item.ServeCoverageRate = v.ServeCoverageRate + "%"
  353. item.SellerId = v.SellerId
  354. item.SellerName = v.SellerName
  355. item.StartDate = v.StartDate
  356. item.StartDate = v.StartDate
  357. item.EndDate = v.EndDate
  358. item.ShareSeller = v.ShareSeller
  359. item.ShareSellerId = v.ShareSellerId
  360. item.Status = v.Status
  361. item.PermissionName = v.PermissionName
  362. item.ThisWeekAmount = 99
  363. item.LastWeekAmount = 99
  364. item.TwoWeekAmount = 99
  365. item.ThreeWeekAmount = 99
  366. resp.List = append(resp.List, item)
  367. }
  368. page := paging.GetPaging(currentIndex, pageSize, total)
  369. resp.Paging = page
  370. br.Ret = 200
  371. br.Success = true
  372. br.Msg = "获取成功"
  373. br.Data = resp
  374. }
  375. // @Title 近四周覆盖率
  376. // @Description 近四周覆盖率接口
  377. // @Param CompanyId query int false "公司ID"
  378. // @Success 200 {object} cygx.RaiServeTagListResp
  379. // @router /rai_serve/coverage_rate [get]
  380. func (this *RaiServeCoAntroller) CoverageRate() {
  381. br := new(models.BaseResponse).Init()
  382. defer func() {
  383. this.Data["json"] = br
  384. this.ServeJSON()
  385. }()
  386. sysUser := this.SysUser
  387. if sysUser == nil {
  388. br.Msg = "请登录"
  389. br.ErrMsg = "请登录,SysUser Is Empty"
  390. br.Ret = 408
  391. return
  392. }
  393. companyId := this.GetString("CompanyId")
  394. fmt.Println(companyId)
  395. resp := new(cygx.RaiServeCoverageRateResp)
  396. //ThisWeekAmount string `comment:"本周互动量"`
  397. //LastWeekAmount string `comment:"上周互动量"`
  398. //TwoWeekAmount string `comment:"上上周互动量"`
  399. //ThreeWeekAmount string `comment:"上三周互动量"`
  400. resp.ThisWeekAmount = "22%"
  401. resp.LastWeekAmount = "33%"
  402. resp.TwoWeekAmount = "44%"
  403. resp.ThreeWeekAmount = "55%"
  404. //resp.List = []string{"22%", "33%", "44%", "55%"}
  405. br.Ret = 200
  406. br.Success = true
  407. br.Msg = "获取成功"
  408. br.Data = resp
  409. }
  410. // @Title 明细列表
  411. // @Description 明细列表接口
  412. // @Param PageSize query int true "每页数据条数"
  413. // @Param CurrentIndex query int true "当前页页码,从1开始"
  414. // @Param CompanyId query int false "公司ID"
  415. // @Param TagType query int false "标签类型"
  416. // @Param TagId query int false "标签ID"
  417. // @Param ServeTypeId int int false "服务类型ID"
  418. // @Param WhatWeek query int false "哪一周 ,1:本周、2:上周、3:上上周、4上三周"
  419. // @Success 200 {object} cygx.RaiServeTagListResp
  420. // @router /rai_serve/bill_list [get]
  421. func (this *RaiServeCoAntroller) BillList() {
  422. br := new(models.BaseResponse).Init()
  423. defer func() {
  424. this.Data["json"] = br
  425. this.ServeJSON()
  426. }()
  427. sysUser := this.SysUser
  428. if sysUser == nil {
  429. br.Msg = "请登录"
  430. br.ErrMsg = "请登录,SysUser Is Empty"
  431. br.Ret = 408
  432. return
  433. }
  434. pageSize, _ := this.GetInt("PageSize")
  435. currentIndex, _ := this.GetInt("CurrentIndex")
  436. companyId, _ := this.GetInt("CompanyId")
  437. tagType, _ := this.GetInt("TagType")
  438. tagId, _ := this.GetInt("TagId")
  439. serveTypeId, _ := this.GetInt("ServeTypeId")
  440. var startSize int
  441. if pageSize <= 0 {
  442. pageSize = utils.PageSize20
  443. }
  444. if currentIndex <= 0 {
  445. currentIndex = 1
  446. }
  447. startSize = utils.StartIndex(currentIndex, pageSize)
  448. if companyId == 0 {
  449. br.Msg = "请选择对应公司ID"
  450. return
  451. }
  452. var condition string
  453. var pars []interface{}
  454. condition = " AND company_id = ? "
  455. pars = append(pars, companyId)
  456. if serveTypeId > 0 {
  457. condition += " AND serve_type_id = ? "
  458. pars = append(pars, serveTypeId)
  459. }
  460. switch tagType {
  461. case 1:
  462. fmt.Println(tagId)
  463. case 2:
  464. case 3:
  465. }
  466. total, err := cygx.GetCygxRaiServeBillCount(condition, pars)
  467. if err != nil {
  468. br.Msg = "获取失败"
  469. br.ErrMsg = "获取失败,GetCygxRaiServeBillCount:" + err.Error()
  470. return
  471. }
  472. list, err := cygx.GetCygxRaiServeBillRespList(condition, pars, startSize, pageSize)
  473. if err != nil {
  474. br.Msg = "获取失败"
  475. br.ErrMsg = "获取失败,GetCygxRaiServeBillRespList:" + err.Error()
  476. return
  477. }
  478. page := paging.GetPaging(currentIndex, pageSize, total)
  479. resp := new(cygx.CygxRaiServeBillListResp)
  480. resp.Paging = page
  481. if len(list) == 0 {
  482. resp.List = make([]*cygx.CygxRaiServeBillResp, 0)
  483. } else {
  484. for _, v := range list {
  485. v.Tag = "云计算,阿里云,华为云,移动&联通"
  486. }
  487. resp.List = list
  488. }
  489. br.Ret = 200
  490. br.Success = true
  491. br.Msg = "获取成功"
  492. br.Data = resp
  493. }