contract_allocation.go 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775
  1. package cygx
  2. import (
  3. "encoding/json"
  4. "fmt"
  5. "github.com/rdlucklib/rdluck_tools/paging"
  6. "hongze/hz_crm_api/controllers"
  7. "hongze/hz_crm_api/models"
  8. "hongze/hz_crm_api/models/company"
  9. "hongze/hz_crm_api/models/contract"
  10. "hongze/hz_crm_api/models/cygx"
  11. "hongze/hz_crm_api/models/system"
  12. cygxService "hongze/hz_crm_api/services/cygx"
  13. "hongze/hz_crm_api/utils"
  14. "strconv"
  15. "strings"
  16. "time"
  17. )
  18. // ContractAllocationController 权益合同派单
  19. type ContractAllocationController struct {
  20. controllers.BaseAuthController
  21. }
  22. // getQueryParams 获取基础查询信息
  23. func getQueryParams(condition string, pars []interface{}, sysUser *system.Admin, tableAlias string) (newCondition string, newPars []interface{}) {
  24. if sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_ADMIN {
  25. condition += " AND " + tableAlias + "product_id=?"
  26. pars = append(pars, 1)
  27. } else if sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_ADMIN {
  28. condition += " AND " + tableAlias + "product_id=?"
  29. pars = append(pars, 2)
  30. } else if sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_ADMIN || sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_FINANCE {
  31. //超级管理员账户,不做条件限制
  32. } else {
  33. //如果不是研究员,那么去找对应的 部门、小组、销售
  34. if sysUser.Authority == 0 {
  35. //普通用户
  36. condition += " AND " + tableAlias + "seller_id=?"
  37. pars = append(pars, sysUser.AdminId)
  38. } else if sysUser.Authority == 1 {
  39. //部门主管
  40. condition += " AND " + tableAlias + "department_id=?"
  41. pars = append(pars, sysUser.DepartmentId)
  42. } else if sysUser.Authority == 2 && sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_RAI_GROUP {
  43. //权益小组负责人
  44. condition += " AND " + tableAlias + "group_id=?"
  45. pars = append(pars, sysUser.GroupId)
  46. } else if sysUser.Authority == 2 && sysUser.RoleTypeCode == utils.ROLE_TYPE_CODE_FICC_GROUP {
  47. //ficc销售主管
  48. pid, err := company.GetParentIdFromGroup(sysUser.GroupId)
  49. if err != nil {
  50. fmt.Println(err.Error())
  51. return
  52. }
  53. var ids []*string
  54. if pid != nil && *pid != 0 {
  55. ids, err = company.GetGroupIdsByParentId(*pid)
  56. if err != nil {
  57. fmt.Println(err.Error())
  58. }
  59. } else {
  60. ids, err = company.GetGroupIdsByParentId(sysUser.GroupId)
  61. if err != nil {
  62. fmt.Println(err.Error())
  63. }
  64. }
  65. var idSlice []string
  66. var sid string
  67. for _, id := range ids {
  68. idSlice = append(idSlice, *id)
  69. }
  70. //加入父级groupId
  71. if *pid > 0 {
  72. idSlice = append(idSlice, strconv.Itoa(*pid))
  73. } else {
  74. idSlice = append(idSlice, strconv.Itoa(sysUser.GroupId))
  75. }
  76. sid = strings.Join(idSlice, ",")
  77. condition += " AND " + tableAlias + `group_id IN (` + sid + `) `
  78. fmt.Println("condition:", condition)
  79. //pars = append(pars, sysUser.GroupId)
  80. } else if sysUser.Authority == 4 {
  81. //ficc小组负责人
  82. condition += " AND " + tableAlias + "group_id=?"
  83. pars = append(pars, sysUser.GroupId)
  84. } else {
  85. //不知道什么类型的用户(后面新增的位置类型客户)
  86. condition += " AND " + tableAlias + "seller_id=?"
  87. pars = append(pars, sysUser.AdminId)
  88. }
  89. }
  90. newCondition = condition
  91. newPars = pars
  92. return
  93. }
  94. // @Title 合同列表
  95. // @Description 合同列表接口
  96. // @Param PageSize query int true "每页数据条数"
  97. // @Param CurrentIndex query int true "当前页页码,从1开始"
  98. // @Param Keyword query string true "客户名称"
  99. // @Param AdminId query string true "销售id,多个用英文逗号隔开,空字符串为全部"
  100. // @Param StartDate query string false "开始日期"
  101. // @Param EndDate query string false "结束日期"
  102. // @Param ContractType query string false "合同类型,枚举值:“,`新签合同`,`续约合同`,`补充协议`"
  103. // @Param FormalType query string false "转正类型,枚举值:“,`标准`,`非标`"
  104. // @Param IsExport query bool false "是否导出excel,默认是false"
  105. // @Param ResearcherRealName query string false "研究员姓名"
  106. // @Param IsAllocation query int false "派点状态: -1-默认全部; 0-未派点; 1-已派点"
  107. // @Success 200 {object} cygx.CompanyContractListResp
  108. // @router /allocation/company_contract_list [get]
  109. func (this *ContractAllocationController) CompanyContractList() {
  110. br := new(models.BaseResponse).Init()
  111. defer func() {
  112. this.Data["json"] = br
  113. this.ServeJSON()
  114. }()
  115. sysUser := this.SysUser
  116. if sysUser == nil {
  117. br.Msg = "请登录"
  118. br.ErrMsg = "请登录,SysUser Is Empty"
  119. br.Ret = 408
  120. return
  121. }
  122. pageSize, _ := this.GetInt("PageSize")
  123. currentIndex, _ := this.GetInt("CurrentIndex")
  124. adminId := this.GetString("AdminId")
  125. formalType := this.GetString("FormalType")
  126. contractType := this.GetString("ContractType")
  127. keyword := this.GetString("Keyword")
  128. startDate := this.GetString("StartDate")
  129. endDate := this.GetString("EndDate")
  130. researcherRealName := this.GetString("ResearcherRealName")
  131. isAllocation, _ := this.GetInt("IsAllocation", -1) // CRM 13.9
  132. if startDate == "" {
  133. startDate = "2015-01-01"
  134. }
  135. if endDate == "" {
  136. endDate = time.Now().Format(utils.FormatDate)
  137. }
  138. var startSize int
  139. if pageSize <= 0 {
  140. pageSize = utils.PageSize20
  141. }
  142. if currentIndex <= 0 {
  143. currentIndex = 1
  144. }
  145. startSize = utils.StartIndex(currentIndex, pageSize)
  146. //是否导出报表
  147. isExport, _ := this.GetBool("IsExport")
  148. if isExport {
  149. pageSize = 10000
  150. currentIndex = 1
  151. }
  152. var condition string
  153. var pars []interface{}
  154. //条件
  155. if adminId != "" {
  156. condition += ` AND c.seller_id in (` + adminId + `) `
  157. //pars = append(pars, adminId)
  158. } else {
  159. //根据当前角色来获取查询条件
  160. condition, pars = getQueryParams(condition, pars, sysUser, "c.")
  161. }
  162. //关键字搜索
  163. if keyword != "" {
  164. condition += ` and b.company_name like "%` + keyword + `%" `
  165. }
  166. //是否派点
  167. if isAllocation != -1 {
  168. condition += ` AND a.product_id = ? `
  169. pars = append(pars, isAllocation)
  170. }
  171. // 标准非标查询
  172. switch formalType {
  173. case "标准":
  174. condition += ` AND a.source = ? `
  175. pars = append(pars, "系统合同")
  176. case "非标":
  177. condition += ` AND a.source = ? `
  178. pars = append(pars, "上传附件")
  179. }
  180. if contractType != "" {
  181. condition += ` AND a.contract_type = ? `
  182. pars = append(pars, contractType)
  183. }
  184. //默认只查询权益 2023-06-01 之后的合同
  185. condition += ` AND c.product_id = ? AND a.start_date > ? `
  186. pars = append(pars, 2, "2023-01-01")
  187. mapMoneyPoint := make(map[int]float64)
  188. //研究员姓名查询
  189. if researcherRealName != "" {
  190. var conditionAllocation string
  191. var parsAllocation []interface{}
  192. conditionAllocation = " AND real_name = ? "
  193. parsAllocation = append(parsAllocation, researcherRealName)
  194. allocationCompanyContractList, err := cygx.GetCygxAllocationCompanyContractList(conditionAllocation, parsAllocation)
  195. if err != nil {
  196. br.Msg = "获取失败"
  197. br.ErrMsg = "获取失败,GetCygxAllocationCompanyContractListErr:" + err.Error()
  198. return
  199. }
  200. var companyContractIds []int
  201. for _, v := range allocationCompanyContractList {
  202. companyContractIds = append(companyContractIds, v.CompanyContractId)
  203. mapMoneyPoint[v.CompanyContractId] = v.Money
  204. }
  205. lenCon := len(companyContractIds)
  206. if lenCon == 0 {
  207. condition += ` AND a.company_contract_id = 0 `
  208. } else {
  209. condition += ` AND a.company_contract_id IN (` + utils.GetOrmInReplace(lenCon) + `)`
  210. pars = append(pars, companyContractIds)
  211. }
  212. }
  213. var list []*cygx.CompanyContractResp
  214. total, err := cygx.GetCompanyContractCountJoinCompany(condition, pars)
  215. if err != nil && err.Error() != utils.ErrNoRow() {
  216. br.Msg = "获取失败"
  217. br.ErrMsg = "获取失败,Err:" + err.Error()
  218. return
  219. }
  220. //列表页数据
  221. list, err = cygx.GetCompanyContractListJoinCompany(condition, pars, startSize, pageSize)
  222. if err != nil {
  223. br.Msg = "获取失败"
  224. br.ErrMsg = "获取失败,Err:" + err.Error()
  225. return
  226. }
  227. mapCompamy := make(map[int]string)
  228. listLen := len(list)
  229. if listLen == 0 {
  230. list = make([]*cygx.CompanyContractResp, 0)
  231. } else {
  232. var contractCodes []string
  233. for _, v := range list {
  234. switch v.Source {
  235. case "系统合同":
  236. v.FormalType = "标准"
  237. case "上传附件":
  238. v.FormalType = "非标"
  239. }
  240. contractCodes = append(contractCodes, v.ContractCode)
  241. mapCompamy[v.CompanyId] = strconv.Itoa(v.CompanyContractId)
  242. lencontractCodes := len(contractCodes)
  243. if lencontractCodes > 0 {
  244. //获取标准合同的ID,这里上面的查询已经关联了三张表,拆分吧。。。
  245. condition = ""
  246. joinStr := ""
  247. pars = make([]interface{}, 0)
  248. condition = " AND a.contract_code IN (" + utils.GetOrmInReplace(lencontractCodes) + ") "
  249. pars = append(pars, contractCodes)
  250. listContract, err := contract.GetContractList(condition, joinStr, pars, 0, lencontractCodes)
  251. if err != nil {
  252. br.Msg = "获取合同列表失败!"
  253. br.ErrMsg = "获取合同列表失败,Err:" + err.Error()
  254. return
  255. }
  256. mapContractCode := make(map[string]int)
  257. for _, v := range listContract {
  258. mapContractCode[v.ContractCode] = v.ContractId
  259. }
  260. //合并合同所对应的权限
  261. mappermissionName, err := cygxService.GetCompanyContractPermissionNameMapById(mapCompamy)
  262. if err != nil {
  263. br.Msg = "获取失败"
  264. br.ErrMsg = "获取失败,Err:" + err.Error()
  265. return
  266. }
  267. for _, v := range list {
  268. v.ContractId = mapContractCode[v.ContractCode]
  269. v.MoneyPoint = mapMoneyPoint[v.CompanyContractId]
  270. v.PermissionName = mappermissionName[v.CompanyId]
  271. }
  272. }
  273. }
  274. }
  275. page := paging.GetPaging(currentIndex, pageSize, total)
  276. resp := cygx.CompanyContractListResp{
  277. Paging: page,
  278. List: list,
  279. }
  280. //导出excel
  281. if isExport {
  282. //IncrementalCompanyListExport(this, dataType, resp, br)
  283. return
  284. }
  285. br.Ret = 200
  286. br.Success = true
  287. br.Msg = "获取成功"
  288. br.Data = resp
  289. }
  290. // @Title 详情
  291. // @Description 获取详情接口
  292. // @Param CompanyContractId query int true "ID"
  293. // @Param ShowDetail query bool false "是否是派点详情展示"
  294. // @Success Ret=200 {object} cygx.CygxAllocationCompanyContractDetailResp
  295. // @router /allocation/detail [get]
  296. func (this *ContractAllocationController) CompanyContracDetail() {
  297. br := new(models.BaseResponse).Init()
  298. defer func() {
  299. this.Data["json"] = br
  300. this.ServeJSON()
  301. }()
  302. AdminUser := this.SysUser
  303. if AdminUser == nil {
  304. br.Msg = "请登录"
  305. br.ErrMsg = "请登录,用户信息为空"
  306. br.Ret = 408
  307. return
  308. }
  309. resp := new(cygx.CygxAllocationCompanyContractDetailResp)
  310. companyContractId, _ := this.GetInt("CompanyContractId")
  311. if companyContractId < 1 {
  312. br.Msg = "请输入详情ID"
  313. return
  314. }
  315. showDetail, _ := this.GetBool("ShowDetail", false)
  316. contractItem, err := company.GetCompanyContractById(companyContractId)
  317. if err != nil {
  318. br.Msg = "获取信息失败"
  319. br.ErrMsg = "获取合同信息失败,Err:" + err.Error()
  320. return
  321. }
  322. total, err := cygx.GetCygxAllocationCompanyContractCountByCompanyContractId(companyContractId)
  323. if err != nil {
  324. br.Msg = "获取信息失败"
  325. br.ErrMsg = "获取合同信息失败,GetCygxAllocationCompanyContractCountByCompanyContractId Err:" + err.Error()
  326. return
  327. }
  328. //var contractPermissionList []*company.ContractPermissionList
  329. expMap := map[int]string{0: "(3w)", 1: "(5w)"} // 买方研选价格
  330. //classifyName := "权益"
  331. //plist := new(company.ContractPermissionList)
  332. hasPermissions, e := company.GetCompanyContractPermissionByCompanyContractId(companyContractId)
  333. if e != nil {
  334. br.Msg = "获取失败"
  335. br.ErrMsg = "获取合同权限信息失败,Err:" + e.Error()
  336. return
  337. }
  338. hasMap := make(map[int]*company.CompanyContractPermission)
  339. for _, p := range hasPermissions {
  340. hasMap[p.ChartPermissionId] = p
  341. }
  342. checkItems := make([]*company.PermissionLookItem, 0)
  343. raiPermissions, e := company.GetPermissionLookItemsExt("2", utils.COMPANY_PRODUCT_RAI_NAME)
  344. if e != nil {
  345. br.Msg = "获取失败"
  346. br.ErrMsg = "获取权益权限列表失败, Err: " + e.Error()
  347. return
  348. }
  349. mapPermissionNameHave := make(map[string]bool) // 判断合同是否存在某一行业权限种类
  350. var expensiveYx int
  351. for _, n := range raiPermissions {
  352. match := hasMap[n.ChartPermissionId]
  353. if match == nil {
  354. continue
  355. }
  356. // 升级
  357. if match.IsUpgrade == 1 {
  358. n.IsUpgrade = 1
  359. checkItems = append(checkItems, n)
  360. continue
  361. }
  362. mapPermissionNameHave[n.PermissionName] = true
  363. // 买方研选(3w/5w)
  364. if n.PermissionName == utils.CHART_PERMISSION_NAME_MF_YANXUAN {
  365. expensiveYx = match.ExpensiveYx
  366. n.PermissionName += expMap[match.ExpensiveYx]
  367. checkItems = append(checkItems, n)
  368. continue
  369. }
  370. checkItems = append(checkItems, n)
  371. }
  372. resp.Money = contractItem.Money / 10000
  373. //有研选时,对研选套餐类型做文案处理
  374. respItemYx := new(cygx.AllocationPermissionListResp)
  375. if mapPermissionNameHave[utils.CHART_PERMISSION_NAME_MF_YANXUAN] {
  376. var moneyYx float64
  377. if expensiveYx == 0 {
  378. moneyYx = 3
  379. }
  380. if expensiveYx == 1 {
  381. moneyYx = 5
  382. }
  383. resp.TotalPointsContent = fmt.Sprint(resp.Money, "W,", "其中", moneyYx, "w默认归属买方研选,请对剩余", resp.Money-moneyYx, "w按照100%进行比值分配")
  384. if showDetail {
  385. resp.TotalPointsContent = fmt.Sprint(resp.Money, "W")
  386. }
  387. resp.Money = resp.Money - moneyYx
  388. respItemYx.Proportion = moneyYx
  389. respItemYx.ChartPermissionName = utils.CHART_PERMISSION_NAME_MF_YANXUAN
  390. respItemYx.List = append(respItemYx.List, &cygx.AllocationRealNameListResp{utils.CHART_PERMISSION_NAME_MF_YANXUAN, 0, 0})
  391. } else {
  392. resp.TotalPointsContent = fmt.Sprint(resp.Money, "W")
  393. }
  394. sysUserList, err := cygx.GetAskEmailList()
  395. if err != nil {
  396. br.Msg = "获取失败"
  397. br.ErrMsg = "获取失败,GetAskEmailList Err: " + err.Error()
  398. return
  399. }
  400. mapPermissionUser := make(map[string][]*cygx.AllocationRealNameListResp)
  401. var respList []*cygx.AllocationPermissionListResp
  402. if total == 0 {
  403. for _, v := range sysUserList {
  404. if !mapPermissionNameHave[v.ChartPermissionName] {
  405. continue
  406. }
  407. item := new(cygx.AllocationRealNameListResp)
  408. item.RealName = v.Name
  409. mapPermissionUser[v.ChartPermissionName] = append(mapPermissionUser[v.ChartPermissionName], item)
  410. }
  411. for k, v := range mapPermissionUser {
  412. respItem := new(cygx.AllocationPermissionListResp)
  413. respItem.ChartPermissionName = k
  414. respItem.List = v
  415. respList = append(respList, respItem)
  416. }
  417. if respItemYx.ChartPermissionName != "" {
  418. respList = append(respList, respItemYx)
  419. }
  420. } else {
  421. listUser, err := cygx.GetCygxAllocationCompanyContractListById(companyContractId)
  422. if err != nil {
  423. br.Msg = "获取失败"
  424. br.ErrMsg = "获取失败,GetCygxAllocationCompanyContractListById Err: " + err.Error()
  425. return
  426. }
  427. for _, v := range listUser {
  428. if showDetail && v.Proportion == 0 {
  429. continue
  430. }
  431. item := new(cygx.AllocationRealNameListResp)
  432. item.RealName = v.RealName
  433. item.Money = v.Money
  434. item.Proportion = v.Proportion
  435. mapPermissionUser[v.ChartPermissionName] = append(mapPermissionUser[v.ChartPermissionName], item)
  436. }
  437. listPermission, err := cygx.GetCygxAllocationCompanyContractPermissionListById(companyContractId)
  438. if err != nil {
  439. br.Msg = "获取失败"
  440. br.ErrMsg = "获取失败,GetCygxAllocationCompanyContractPermissionListById Err: " + err.Error()
  441. return
  442. }
  443. for _, v := range listPermission {
  444. if showDetail && v.Proportion == 0 {
  445. continue
  446. }
  447. respItem := new(cygx.AllocationPermissionListResp)
  448. respItem.ChartPermissionName = v.ChartPermissionName
  449. respItem.Money = v.Money
  450. respItem.Proportion = v.Proportion
  451. respItem.List = mapPermissionUser[v.ChartPermissionName]
  452. respList = append(respList, respItem)
  453. }
  454. }
  455. resp.List = respList
  456. resp.CompanyContractId = companyContractId
  457. br.Ret = 200
  458. br.Success = true
  459. br.Msg = "获取成功"
  460. br.Data = resp
  461. }
  462. // @Title 更新派点
  463. // @Description 更新派点接口
  464. // @Param request body cygx.AddProductInteriorReq true "type json string"
  465. // @Success 200 {object} "保存成功"
  466. // @router /allocation/update [post]
  467. func (this *ContractAllocationController) CompanyContracUpdate() {
  468. br := new(models.BaseResponse).Init()
  469. defer func() {
  470. this.Data["json"] = br
  471. this.ServeJSON()
  472. }()
  473. sysUser := this.SysUser
  474. if sysUser == nil {
  475. br.Msg = "请登录"
  476. br.ErrMsg = "请登录,SysUser Is Empty"
  477. br.Ret = 408
  478. return
  479. }
  480. var req cygx.UpdateAllocationCompanyContractReq
  481. err := json.Unmarshal(this.Ctx.Input.RequestBody, &req)
  482. if err != nil {
  483. br.Msg = "参数解析异常!"
  484. br.ErrMsg = "参数解析失败,Err:" + err.Error()
  485. return
  486. }
  487. companyContractId := req.CompanyContractId
  488. if companyContractId == 0 {
  489. br.Msg = "参数错误"
  490. br.ErrMsg = "参数错误,id不可为空"
  491. return
  492. }
  493. contractItem, err := company.GetCompanyContractById(companyContractId)
  494. if err != nil {
  495. br.Msg = "获取信息失败"
  496. br.ErrMsg = "获取合同信息失败,Err:" + err.Error()
  497. return
  498. }
  499. list := req.List
  500. var items []*cygx.CygxAllocationCompanyContract
  501. var itemsPermission []*cygx.CygxAllocationCompanyContractPermission
  502. for _, v := range list {
  503. itemPermission := new(cygx.CygxAllocationCompanyContractPermission)
  504. itemPermission.CompanyContractId = companyContractId
  505. itemPermission.AdminId = sysUser.AdminId
  506. itemPermission.AdminName = sysUser.RealName
  507. itemPermission.Proportion = v.Proportion
  508. itemPermission.Money = v.Money
  509. itemPermission.ChartPermissionName = v.ChartPermissionName
  510. itemPermission.CreateTime = time.Now()
  511. itemPermission.ModifyTime = time.Now()
  512. itemsPermission = append(itemsPermission, itemPermission)
  513. for _, v2 := range v.List {
  514. item := new(cygx.CygxAllocationCompanyContract)
  515. item.CompanyContractId = companyContractId
  516. item.AdminId = sysUser.AdminId
  517. item.AdminName = sysUser.RealName
  518. item.Proportion = v2.Proportion
  519. item.Money = v2.Money
  520. item.RealName = v2.RealName
  521. item.ChartPermissionName = v.ChartPermissionName
  522. item.CreateTime = time.Now()
  523. item.ModifyTime = time.Now()
  524. items = append(items, item)
  525. }
  526. }
  527. err = cygx.AddAndUpdateCygxAllocationCompanyContract(items, itemsPermission, companyContractId)
  528. if err != nil {
  529. br.Msg = "操作失败"
  530. br.ErrMsg = "操作失败,AddAndUpdateCygxAllocationCompanyContract Err:" + err.Error()
  531. return
  532. }
  533. br.Ret = 200
  534. br.Success = true
  535. br.IsAddLog = true
  536. br.Msg = "操作成功"
  537. }
  538. // @Title 研究员派点统计
  539. // @Description 研究员派点统计接口
  540. // @Param PageSize query int true "每页数据条数"
  541. // @Param CurrentIndex query int true "当前页页码,从1开始"
  542. // @Param Keyword query string true "客户名称"
  543. // @Param StartDate query string false "开始日期"
  544. // @Param EndDate query string false "结束日期"
  545. // @Param IsExport query bool false "是否导出excel,默认是false"
  546. // @Success 200 {object} cygx.CompanyContractListResp
  547. // @router /allocation/statistics [get]
  548. func (this *ContractAllocationController) CompanyContractStatistics() {
  549. br := new(models.BaseResponse).Init()
  550. defer func() {
  551. this.Data["json"] = br
  552. this.ServeJSON()
  553. }()
  554. sysUser := this.SysUser
  555. if sysUser == nil {
  556. br.Msg = "请登录"
  557. br.ErrMsg = "请登录,SysUser Is Empty"
  558. br.Ret = 408
  559. return
  560. }
  561. keyword := this.GetString("Keyword")
  562. startDate := this.GetString("StartDate")
  563. endDate := this.GetString("EndDate")
  564. if startDate == "" {
  565. startDate = "2015-01-01"
  566. }
  567. if endDate == "" {
  568. endDate = time.Now().Format(utils.FormatDate)
  569. }
  570. //是否导出报表
  571. isExport, _ := this.GetBool("IsExport")
  572. var condition string
  573. var pars []interface{}
  574. //根据当前角色来获取查询条件
  575. condition, pars = getQueryParams(condition, pars, sysUser, "c.")
  576. //关键字搜索
  577. if keyword != "" {
  578. condition += ` and b.company_name like "%` + keyword + `%" `
  579. }
  580. //默认只查询权益 2023-06-01 之后的合同
  581. condition += ` AND c.product_id = ? AND a.start_date > ? `
  582. pars = append(pars, 2, "2023-06-01")
  583. //列表页数据
  584. listContract, err := cygx.GetCompanyContractListJoinCompany(condition, pars, 0, 1000)
  585. if err != nil {
  586. br.Msg = "获取失败"
  587. br.ErrMsg = "获取失败,Err:" + err.Error()
  588. return
  589. }
  590. var companyContractIds []int
  591. for _, v := range listContract {
  592. companyContractIds = append(companyContractIds, v.CompanyContractId)
  593. }
  594. lenArr := len(companyContractIds)
  595. mapUserAllocation := make(map[string]float64) // 关联合同
  596. mapUserMoney := make(map[string]float64) // 派点金额
  597. mapPermissionAllocation := make(map[string]float64)
  598. mapPermissionMoney := make(map[string]float64)
  599. totalContract := lenArr //所有的关联合同
  600. var totalMoney float64 //所有的关联合同的金额 单位万
  601. if lenArr > 0 {
  602. var conditionAllocation string
  603. var parsAllocation []interface{}
  604. allocationCompanyContractList, err := cygx.GetCygxAllocationCompanyContractList(conditionAllocation, parsAllocation)
  605. if err != nil {
  606. br.Msg = "获取失败"
  607. br.ErrMsg = "获取失败,Err:" + err.Error()
  608. return
  609. }
  610. for _, v := range allocationCompanyContractList {
  611. if v.Proportion != 0 {
  612. mapUserAllocation[v.RealName] += 1
  613. mapUserMoney[v.RealName] += v.Money
  614. mapPermissionAllocation[v.ChartPermissionName] += 1
  615. mapPermissionMoney[v.ChartPermissionName] += v.Money
  616. totalMoney += v.Money
  617. }
  618. }
  619. }
  620. sysUserList, err := cygx.GetAskEmailList()
  621. if err != nil {
  622. br.Msg = "获取失败"
  623. br.ErrMsg = "获取失败,GetAskEmailList Err: " + err.Error()
  624. return
  625. }
  626. mapPermissionUser := make(map[string][]*cygx.AllocationRealNameStatisticsListResp)
  627. for _, v := range sysUserList {
  628. item := new(cygx.AllocationRealNameStatisticsListResp)
  629. item.RealName = v.Name
  630. item.TotalRelatedContract = mapUserAllocation[v.Name]
  631. item.TotalDispatchPoint = fmt.Sprint(mapUserMoney[v.Name])
  632. if item.TotalDispatchPoint == "" {
  633. item.TotalDispatchPoint = "0"
  634. }
  635. //组内占比
  636. item.GroupProportion = fmt.Sprint(mapUserMoney[v.Name] / mapPermissionMoney[v.ChartPermissionName] * 100)
  637. if item.GroupProportion == "" {
  638. item.GroupProportion = "0"
  639. }
  640. item.GroupProportion += "%"
  641. //部门占比
  642. item.DepartmentProportion = fmt.Sprint(mapUserMoney[v.Name] / totalMoney * 100)
  643. if item.DepartmentProportion == "" {
  644. item.DepartmentProportion = "0"
  645. }
  646. item.DepartmentProportion += "%"
  647. mapPermissionUser[v.ChartPermissionName] = append(mapPermissionUser[v.ChartPermissionName], item)
  648. }
  649. for k, v := range mapPermissionUser {
  650. lenUser := len(v)
  651. item := new(cygx.AllocationRealNameStatisticsListResp)
  652. item.RealName = "合计"
  653. item.TotalRelatedContract = mapPermissionAllocation[k]
  654. item.TotalDispatchPoint = fmt.Sprint(mapPermissionMoney[k], "/", "300")
  655. item.GroupProportion = "100%"
  656. // 部门占比
  657. item.DepartmentProportion = fmt.Sprint(mapPermissionMoney[k] / totalMoney * 100)
  658. if item.DepartmentProportion == "" {
  659. item.DepartmentProportion = "0"
  660. }
  661. item.DepartmentProportion += "%"
  662. mapPermissionUser[k] = append(mapPermissionUser[k], item)
  663. item = new(cygx.AllocationRealNameStatisticsListResp)
  664. item.RealName = "平均"
  665. item.TotalRelatedContract = mapPermissionAllocation[k] / float64(lenUser)
  666. item.TotalDispatchPoint = fmt.Sprint(mapPermissionMoney[k] / float64(lenUser))
  667. //组内占比
  668. item.GroupProportion = fmt.Sprint(float64(lenUser) / mapPermissionMoney[k] * 100)
  669. if item.GroupProportion == "" {
  670. item.GroupProportion = "0"
  671. }
  672. item.GroupProportion += "%"
  673. // 部门占比
  674. item.DepartmentProportion = fmt.Sprint(mapPermissionMoney[k] / totalMoney * 100 / float64(len(mapPermissionUser[k])))
  675. if item.DepartmentProportion == "" {
  676. item.DepartmentProportion = "0"
  677. }
  678. item.DepartmentProportion += "%"
  679. mapPermissionUser[k] = append(mapPermissionUser[k], item)
  680. }
  681. var list []*cygx.AllocationPermissionStatisticsListResp
  682. permissionNameArr := []string{"医药", "消费", "科技", "智造", "策略"}
  683. for _, v := range permissionNameArr {
  684. item := new(cygx.AllocationPermissionStatisticsListResp)
  685. item.ChartPermissionName = v
  686. item.List = mapPermissionUser[v]
  687. list = append(list, item)
  688. }
  689. resp := cygx.CygxAllocationCompanyContractDetailStatisticsResp{
  690. List: list,
  691. }
  692. resp.TotalContract = totalContract
  693. resp.TotalMoney = totalMoney
  694. //导出excel
  695. if isExport {
  696. //IncrementalCompanyListExport(this, dataType, resp, br)
  697. return
  698. }
  699. br.Ret = 200
  700. br.Success = true
  701. br.Msg = "获取成功"
  702. br.Data = resp
  703. }