seller.go 40 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197
  1. package census
  2. import (
  3. "bytes"
  4. "fmt"
  5. "github.com/gin-gonic/gin"
  6. "github.com/go-playground/validator/v10"
  7. "github.com/shopspring/decimal"
  8. "github.com/tealeg/xlsx"
  9. "hongze/fms_api/controller/resp"
  10. "hongze/fms_api/global"
  11. "hongze/fms_api/models/base"
  12. "hongze/fms_api/models/crm"
  13. "hongze/fms_api/models/fms"
  14. crmService "hongze/fms_api/services/crm"
  15. "hongze/fms_api/utils"
  16. "net/http"
  17. "sort"
  18. "strconv"
  19. "strings"
  20. "time"
  21. )
  22. // SellerController 销售统计
  23. type SellerController struct{}
  24. // GroupInvoiceList
  25. // @Title 销售组开票统计列表-弃用
  26. // @Description 销售组开票统计列表-弃用
  27. // @Param StartDate query string false "开始日期"
  28. // @Param EndDate query string false "结束日期"
  29. // @Param SortField query int false "排序字段: 1-开票金额; 2-组别占比"
  30. // @Param SortType query int false "排序方式: 1-正序; 2-倒序"
  31. // @Param IsExport query int false "是否导出: 0-否; 1-是"
  32. // @Success 200 {object} fms.CensusSellerGroupInvoiceItem
  33. // @router /census/seller/group_invoice_list [get]
  34. func (ct *SellerController) GroupInvoiceList(c *gin.Context) {
  35. var req fms.CensusSellerGroupInvoiceListReq
  36. if e := c.BindQuery(&req); e != nil {
  37. err, ok := e.(validator.ValidationErrors)
  38. if !ok {
  39. resp.FailData("参数解析失败", "Err:"+e.Error(), c)
  40. return
  41. }
  42. resp.FailData("参数解析失败", err.Translate(global.Trans), c)
  43. return
  44. }
  45. var departmentId int
  46. if req.SellerType == 1 {
  47. departmentId = crm.SellerDepartmentId
  48. } else if req.SellerType == 2 {
  49. departmentId = crm.RaiSellerDepartmentId
  50. } else if req.SellerType == 0 {
  51. resp.Fail("请选择销售类型", c)
  52. return
  53. } else {
  54. resp.Fail("请选择正确的销售类型", c)
  55. return
  56. }
  57. outCond := ` department_id = %d AND parent_id = 0 `
  58. outCond = fmt.Sprintf(outCond, departmentId)
  59. cond := ` (invoice_type = %d OR invoice_type = %d) AND a.is_deleted = 0 AND a.seller_id != 0 `
  60. cond = fmt.Sprintf(cond, fms.ContractInvoiceTypeMake, fms.ContractInvoiceTypePreMake)
  61. //adminCond := ` (invoice_type = %d OR invoice_type = %d) AND is_deleted = 0 AND seller_group_id != 0 `
  62. //adminCond = fmt.Sprintf(cond, fms.ContractInvoiceTypeMake, fms.ContractInvoiceTypePreMake)
  63. pars := make([]interface{}, 0)
  64. // 开票日期
  65. if req.StartDate != "" && req.EndDate != "" {
  66. st := fmt.Sprint(req.StartDate, " 00:00:00")
  67. ed := fmt.Sprint(req.EndDate, " 23:59:59")
  68. cond += ` AND (invoice_time BETWEEN '%s' AND '%s')`
  69. cond = fmt.Sprintf(cond, st, ed)
  70. //adminCond += ` AND (invoice_time BETWEEN '%s' AND '%s')`
  71. //adminCond = fmt.Sprintf(cond, st, ed)
  72. }
  73. if req.CompanyType == 1 {
  74. cond += ` AND b.contract_type = 1 `
  75. //historyCond += ` AND new_company = 1 `
  76. } else if req.CompanyType == 2 {
  77. cond += ` AND b.contract_type IN (2,3,4) `
  78. //historyCond += ` AND new_company = 0 `
  79. }
  80. page := new(base.Page)
  81. page.SetPageSize(req.PageSize)
  82. page.SetCurrent(req.Current)
  83. // 排序, 默认开票金额倒序
  84. sortFieldMap := map[int]string{0: "invoice_amount", 1: "invoice_amount", 2: "group_rate"}
  85. sortTypeMap := map[int]bool{0: false, 1: true, 2: false}
  86. page.AddOrderItem(base.OrderItem{Column: sortFieldMap[req.SortField], Asc: sortTypeMap[req.SortType]})
  87. if req.IsExport == 1 {
  88. page.SetPageSize(10000)
  89. page.SetCurrent(1)
  90. }
  91. // 查询开票金额总和(减少子查询)
  92. invOB := new(fms.ContractInvoice)
  93. sumCond := cond
  94. sumPars := make([]interface{}, 0)
  95. invSum, e := invOB.Sum("amount", sumCond, sumPars)
  96. if e != nil {
  97. resp.FailMsg("获取失败", "获取开票金额总和失败, Err: "+e.Error(), c)
  98. return
  99. }
  100. // 查询列表
  101. groupOB := new(crm.SysGroup)
  102. //totalCond := outCond
  103. //totalPars := make([]interface{}, 0)
  104. //total, e := groupOB.Count(totalCond, totalPars)
  105. //if e != nil {
  106. // resp.FailMsg("获取失败", "获取销售组开票统计列表总数失败, Err: "+e.Error(), c)
  107. // return
  108. //}
  109. //list, e := fms.GetCensusSellerGroupInvoicePageList(page, cond, outCond, pars, invSum)
  110. //if e != nil {
  111. // resp.FailMsg("获取失败", "获取销售组开票统计列表失败, Err: "+e.Error(), c)
  112. // return
  113. //}
  114. groupCond := ` department_id = %d AND parent_id = 0 `
  115. groupCond = fmt.Sprintf(groupCond, departmentId)
  116. groupPars := make([]interface{}, 0)
  117. groupList, e := groupOB.List(groupCond, groupPars)
  118. if e != nil {
  119. resp.FailMsg("获取失败", "获取组别列表失败, Err: "+e.Error(), c)
  120. return
  121. }
  122. //total := len(groupList)
  123. groupMap := make(map[int]*crm.SysGroup)
  124. groupIdSlice := make([]string, 0)
  125. for i := range groupList {
  126. groupMap[groupList[i].GroupId] = groupList[i]
  127. groupIdSlice = append(groupIdSlice, strconv.Itoa(groupList[i].GroupId))
  128. }
  129. groupStr := strings.Join(groupIdSlice, ",")
  130. total, list, e := fms.GetCensusSellerGroupInvoicePageListV2(page, groupStr, cond, pars, invSum)
  131. if e != nil {
  132. resp.FailMsg("获取失败", "获取销售组开票统计列表失败, Err: "+e.Error(), c)
  133. return
  134. }
  135. for _, v := range list {
  136. if group, ok := groupMap[v.GroupId]; ok {
  137. v.GroupName = group.GroupName
  138. }
  139. }
  140. // 处理百分比, 乘100并保留两位小数
  141. mulNum := decimal.NewFromFloat(100)
  142. for i := range list {
  143. d := decimal.NewFromFloat(list[i].GroupRate)
  144. d = d.Mul(mulNum).Round(2)
  145. a, _ := d.Float64()
  146. list[i].GroupRate = a
  147. }
  148. // 是否导出
  149. if req.IsExport == 1 {
  150. ExportGroupInvoiceList(c, list, req)
  151. return
  152. }
  153. page.SetTotal(int64(total))
  154. baseData := new(base.BaseData)
  155. baseData.SetPage(page)
  156. baseData.SetList(list)
  157. resp.OkData("获取成功", baseData, c)
  158. }
  159. // ExportGroupInvoiceList 导出销售组开票统计列表
  160. func ExportGroupInvoiceList(c *gin.Context, list []*fms.CensusSellerGroupInvoiceItem, req fms.CensusSellerGroupInvoiceListReq) {
  161. // 生成Excel文件
  162. xlsxFile := xlsx.NewFile()
  163. style := xlsx.NewStyle()
  164. alignment := xlsx.Alignment{
  165. Horizontal: "center",
  166. Vertical: "center",
  167. WrapText: true,
  168. }
  169. style.Alignment = alignment
  170. style.ApplyAlignment = true
  171. sheetName := "销售组开票统计"
  172. sheet, err := xlsxFile.AddSheet(sheetName)
  173. if err != nil {
  174. resp.FailData("新增Sheet失败", "Err:"+err.Error(), c)
  175. return
  176. }
  177. // 存在筛选则前两行显示时间信息
  178. if req.StartDate != "" && req.EndDate != "" {
  179. timeData := fmt.Sprintf("时间:%s至%s", req.StartDate, req.EndDate)
  180. rowA := sheet.AddRow()
  181. cellAA := rowA.AddCell()
  182. cellAA.SetString("销售统计表")
  183. cellAA.SetStyle(style)
  184. rowB := sheet.AddRow()
  185. rowB.AddCell().SetString(timeData)
  186. // 第三行空出
  187. sheet.AddRow()
  188. }
  189. // 数据表头
  190. rowTitle := []string{"排名", "销售组别", "收入金额(元)", "组别占比"}
  191. titleRow := sheet.AddRow()
  192. for i := range rowTitle {
  193. v := titleRow.AddCell()
  194. v.SetString(rowTitle[i])
  195. v.SetStyle(style)
  196. }
  197. // 填充数据
  198. for k, v := range list {
  199. dataRow := sheet.AddRow()
  200. dataRow.AddCell().SetString(fmt.Sprint(k + 1)) // 排名
  201. dataRow.AddCell().SetString(v.GroupName) // 销售组别
  202. dataRow.AddCell().SetString(fmt.Sprint(v.InvoiceAmount)) // 开票金额
  203. dataRow.AddCell().SetString(fmt.Sprint(v.GroupRate, "%")) // 组别占比
  204. }
  205. // 输出文件
  206. var buffer bytes.Buffer
  207. _ = xlsxFile.Write(&buffer)
  208. content := bytes.NewReader(buffer.Bytes())
  209. randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  210. fileName := sheetName + randStr + ".xlsx"
  211. c.Writer.Header().Add("Content-Disposition", fmt.Sprintf(`attachment; filename="%s"`, fileName))
  212. c.Writer.Header().Add("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet")
  213. http.ServeContent(c.Writer, c.Request, fileName, time.Now(), content)
  214. }
  215. // InvoiceList
  216. // @Title 销售开票统计列表
  217. // @Description 销售开票统计列表
  218. // @Param GroupId query int false "组别ID"
  219. // @Param StartDate query string false "开始日期"
  220. // @Param EndDate query string false "结束日期"
  221. // @Param SortField query int false "排序字段: 1-开票金额; 2-组别占比; 3-全员占比"
  222. // @Param SortType query int false "排序方式: 1-正序; 2-倒序"
  223. // @Param IsExport query int false "是否导出: 0-否; 1-是"
  224. // @Success 200 {object} fms.CensusSellerInvoiceListReq
  225. // @router /census/seller/invoice_list [get]
  226. func (ct *SellerController) InvoiceList(c *gin.Context) {
  227. var req fms.CensusSellerInvoiceListReq
  228. if e := c.BindQuery(&req); e != nil {
  229. err, ok := e.(validator.ValidationErrors)
  230. if !ok {
  231. resp.FailData("参数解析失败", "Err:"+e.Error(), c)
  232. return
  233. }
  234. resp.FailData("参数解析失败", err.Translate(global.Trans), c)
  235. return
  236. }
  237. var departmentId int
  238. if req.SellerType == 1 {
  239. departmentId = crm.SellerDepartmentId
  240. } else if req.SellerType == 2 {
  241. departmentId = crm.RaiSellerDepartmentId
  242. } else if req.SellerType == 0 {
  243. resp.Fail("请选择销售类型", c)
  244. return
  245. } else {
  246. resp.Fail("请选择正确的销售类型", c)
  247. return
  248. }
  249. pars := make([]interface{}, 0)
  250. adminPars := make([]interface{}, 0)
  251. outCond := ` a.department_id = %d `
  252. outCond = fmt.Sprintf(outCond, departmentId)
  253. adminCond := ` department_id = %d `
  254. adminCond = fmt.Sprintf(adminCond, departmentId)
  255. totalCond := ` department_id = %d `
  256. totalCond = fmt.Sprintf(totalCond, departmentId)
  257. totalPars := make([]interface{}, 0)
  258. if !req.ShowResign {
  259. adminCond += ` AND enabled = 1 `
  260. }
  261. if req.GroupId > 0 {
  262. // 筛选组别时, 查询当前组别的下级组(因为admin表存的group_id, 有三级的存的是子ID, 只有二级的存的才是父ID =_=!)
  263. groupCond := `parent_id = ?`
  264. groupPars := make([]interface{}, 0)
  265. groupPars = append(groupPars, req.GroupId)
  266. groupOB := new(crm.SysGroup)
  267. groupList, e := groupOB.List(groupCond, groupPars)
  268. if e != nil {
  269. resp.FailMsg("获取失败", "获取组别下级组列表失败, Err: "+e.Error(), c)
  270. return
  271. }
  272. groupIds := make([]int, 0)
  273. groupIds = append(groupIds, req.GroupId)
  274. for i := range groupList {
  275. groupIds = append(groupIds, groupList[i].GroupId)
  276. }
  277. outCond += ` AND a.group_id IN (?) `
  278. pars = append(pars, groupIds)
  279. adminCond += ` AND group_id IN (?) `
  280. adminPars = append(adminPars, groupIds)
  281. totalCond += ` AND group_id IN (?) `
  282. totalPars = append(totalPars, groupIds)
  283. }
  284. sumCond := ` (invoice_type = ? OR invoice_type = ? ) AND a.is_deleted = 0 AND a.seller_id != 0 `
  285. sumPars := make([]interface{}, 0)
  286. sumPars = append(sumPars, fms.ContractInvoiceTypeMake, fms.ContractInvoiceTypePreMake)
  287. cond := ` (c.invoice_type = %d OR c.invoice_type = %d) AND c.is_deleted = 0 AND c.seller_id != 0 `
  288. inCond := ` (invoice_type = %d OR invoice_type = %d) AND is_deleted = 0 AND seller_id != 0 `
  289. cond = fmt.Sprintf(cond, fms.ContractInvoiceTypeMake, fms.ContractInvoiceTypePreMake)
  290. inCond = fmt.Sprintf(inCond, fms.ContractInvoiceTypeMake, fms.ContractInvoiceTypePreMake)
  291. if req.CompanyType == 1 {
  292. cond += ` AND b.contract_type = 1 `
  293. //historyCond += ` AND new_company = 1 `
  294. } else if req.CompanyType == 2 {
  295. cond += ` AND b.contract_type IN (2,3,4) `
  296. //historyCond += ` AND new_company = 0 `
  297. }
  298. // 开票日期
  299. if req.StartDate != "" && req.EndDate != "" {
  300. st := fmt.Sprint(req.StartDate, " 00:00:00")
  301. ed := fmt.Sprint(req.EndDate, " 23:59:59")
  302. cond += ` AND (c.invoice_time BETWEEN '%s' AND '%s')`
  303. inCond += ` AND (invoice_time BETWEEN '%s' AND '%s')`
  304. cond = fmt.Sprintf(cond, st, ed)
  305. inCond = fmt.Sprintf(inCond, st, ed)
  306. sumCond += ` AND (invoice_time BETWEEN ? AND ?)`
  307. sumPars = append(sumPars, st, ed)
  308. }
  309. page := new(base.Page)
  310. page.SetPageSize(req.PageSize)
  311. page.SetCurrent(req.Current)
  312. // 排序, 默认开票金额倒序
  313. sortFieldMap := map[int]string{0: "invoice_amount", 1: "invoice_amount", 2: "group_rate", 3: "seller_rate"}
  314. sortTypeMap := map[int]bool{0: false, 1: true, 2: false}
  315. page.AddOrderItem(base.OrderItem{Column: sortFieldMap[req.SortField], Asc: sortTypeMap[req.SortType]})
  316. if req.IsExport == 1 {
  317. page.SetPageSize(10000)
  318. page.SetCurrent(1)
  319. }
  320. // 查询开票金额总和(减少子查询)
  321. invOB := new(fms.ContractInvoice)
  322. invSum, e := invOB.Sum("amount", sumCond, sumPars)
  323. if e != nil {
  324. resp.FailMsg("获取失败", "获取开票金额总和失败, Err: "+e.Error(), c)
  325. return
  326. }
  327. // 查询列表
  328. adminOB := new(crm.Admin)
  329. //total, e := adminOB.Count(totalCond, totalPars)
  330. //if e != nil {
  331. // resp.FailMsg("获取失败", "获取销售开票统计列表总数失败, Err: "+e.Error(), c)
  332. // return
  333. //}
  334. //list, e := fms.GetCensusSellerInvoicePageList(page, cond, outCond, pars, invSum)
  335. //if e != nil {
  336. // resp.FailMsg("获取失败", "获取销售开票统计列表失败, Err: "+e.Error(), c)
  337. // return
  338. //}
  339. adminList, e := adminOB.List(adminCond, adminPars)
  340. if e != nil {
  341. resp.FailMsg("获取失败", "获取销售列表失败, Err: "+e.Error(), c)
  342. return
  343. }
  344. //total := len(adminList)
  345. adminIdSlice := make([]string, 0)
  346. sellerMap := make(map[int]*crm.Admin)
  347. for i := range adminList {
  348. sellerMap[adminList[i].AdminId] = adminList[i]
  349. adminIdSlice = append(adminIdSlice, strconv.Itoa(adminList[i].AdminId))
  350. }
  351. adminStr := strings.Join(adminIdSlice, ",")
  352. total, list, e := fms.GetCensusSellerInvoicePageListV2(page, adminStr, inCond, cond, pars, invSum)
  353. if e != nil {
  354. resp.FailMsg("获取失败", "获取销售开票统计列表失败, Err: "+e.Error(), c)
  355. return
  356. }
  357. for _, v := range list {
  358. if admin, ok := sellerMap[v.SellerId]; ok {
  359. v.GroupName = admin.GroupName
  360. v.SellerName = admin.RealName
  361. v.GroupId = admin.GroupId
  362. }
  363. }
  364. // 分组信息, list的groupId可能是三级的ID, 要转为对应的二级
  365. groupMap, e := crmService.GetSellerTeamGroupMap()
  366. if e != nil {
  367. resp.FailMsg("获取失败", "获取组别对应信息失败, Err: "+e.Error(), c)
  368. return
  369. }
  370. mulNum := decimal.NewFromFloat(100)
  371. for i := range list {
  372. g := groupMap[list[i].GroupId]
  373. if g != nil {
  374. list[i].GroupId = g.GroupId
  375. list[i].GroupName = g.GroupName
  376. }
  377. // 处理百分比, 乘100并保留两位小数
  378. d := decimal.NewFromFloat(list[i].GroupRate)
  379. d = d.Mul(mulNum).Round(2)
  380. a, _ := d.Float64()
  381. list[i].GroupRate = a
  382. d2 := decimal.NewFromFloat(list[i].SellerRate)
  383. d2 = d2.Mul(mulNum).Round(2)
  384. a2, _ := d2.Float64()
  385. list[i].SellerRate = a2
  386. }
  387. // 是否导出
  388. if req.IsExport == 1 {
  389. ExportInvoiceList(c, list, req)
  390. return
  391. }
  392. page.SetTotal(int64(total))
  393. baseData := new(base.BaseData)
  394. baseData.SetPage(page)
  395. baseData.SetList(list)
  396. resp.OkData("获取成功", baseData, c)
  397. }
  398. func (this *SellerController) InvoiceListV2(c *gin.Context) {
  399. var req fms.CensusSellerInvoiceListReq
  400. if e := c.BindQuery(&req); e != nil {
  401. err, ok := e.(validator.ValidationErrors)
  402. if !ok {
  403. resp.FailData("参数解析失败", "Err:"+e.Error(), c)
  404. return
  405. }
  406. resp.FailData("参数解析失败", err.Translate(global.Trans), c)
  407. return
  408. }
  409. page := new(base.Page)
  410. page.SetPageSize(req.PageSize)
  411. page.SetCurrent(req.Current)
  412. if req.IsExport == 1 {
  413. page.SetPageSize(10000)
  414. page.SetCurrent(1)
  415. }
  416. //收入统计
  417. //获取最新的开票到款日期
  418. cond1 := ``
  419. historyCond := ``
  420. //pars1 := make([]interface{}, 0)
  421. //historyPars1 := make([]interface{}, 0)
  422. //if req.SellerIds != "" {
  423. // sellerIds := strings.Split(req.SellerIds, ",")
  424. // cond += ` AND (a.seller_id in ? ) `
  425. // historyCond += ` AND (seller_id in ? ) `
  426. // pars = append(pars, sellerIds)
  427. // historyPars = append(historyPars, sellerIds)
  428. //}
  429. if req.CompanyType == 1 {
  430. cond1 += ` AND b.contract_type = 1 `
  431. historyCond += ` AND new_company = 1 `
  432. } else if req.CompanyType == 2 {
  433. cond1 += ` AND b.contract_type IN (2,3,4) `
  434. historyCond += ` AND new_company = 0 `
  435. }
  436. var departmentId int
  437. if req.SellerType == 1 {
  438. departmentId = crm.SellerDepartmentId
  439. } else if req.SellerType == 2 {
  440. departmentId = crm.RaiSellerDepartmentId
  441. } else if req.SellerType == 0 {
  442. resp.Fail("请选择销售类型", c)
  443. return
  444. } else {
  445. resp.Fail("请选择正确的销售类型", c)
  446. return
  447. }
  448. var totalMoneySlice []float64
  449. var reqStartDate, reqEndDate time.Time
  450. historyTime, _ := time.Parse(utils.FormatDate, "2023-04-01")
  451. if req.StartDate != "" && req.EndDate != "" {
  452. st := fmt.Sprint(req.StartDate, "-01 00:00:00")
  453. ed := fmt.Sprint(req.EndDate, "-01 23:59:59")
  454. reqStartDate, _ = time.Parse(utils.FormatDateTime, st)
  455. reqEndDate, _ = time.Parse(utils.FormatDateTime, ed)
  456. }
  457. // 累计值
  458. var accumulate float64
  459. //dataList := make([]*fms.IncomeSummaryItem, 0)
  460. //historydataList := make([]*fms.IncomeSummaryItem, 0)
  461. //timeNow, _ := time.Parse("2006-01", time.Now().Format("2006-01"))
  462. var prevStartDate string
  463. var startDate, endDate string
  464. //开始日期
  465. if req.StartDate != "" && req.EndDate != "" {
  466. startDate = reqStartDate.Format("2006-01")
  467. prevStartDate = reqStartDate.Format("2006-01")
  468. }
  469. startDate = fmt.Sprint(startDate, "-01")
  470. prevStartDate = fmt.Sprint(prevStartDate, "-01")
  471. startDateTime, _ := time.Parse(utils.FormatDate, startDate)
  472. endDateTime, _ := time.Parse(utils.FormatDate, endDate)
  473. //结束日期
  474. if req.StartDate != "" && req.EndDate != "" {
  475. endDate = reqEndDate.Format("2006-01")
  476. }
  477. cond := `1 = 1`
  478. histrtyCond := `1 = 1`
  479. pars := make([]interface{}, 0)
  480. historyPars := make([]interface{}, 0)
  481. if req.CompanyType == 1 {
  482. cond += ` AND b.contract_type = 1 `
  483. histrtyCond += ` AND new_company = 1 `
  484. } else if req.CompanyType == 2 {
  485. cond += ` AND b.contract_type IN (2,3,4) `
  486. histrtyCond += ` AND new_company = 0 `
  487. }
  488. //if req.SellerIds != "" {
  489. // sellerIds := strings.Split(req.SellerIds, ",")
  490. // cond += ` AND (c.seller_id in ? OR d.seller_id in ?)`
  491. // pars = append(pars, sellerIds, sellerIds)
  492. // prevCond += ` AND (c.seller_id in ? OR d.seller_id in ?)`
  493. // prevPars = append(prevPars, sellerIds, sellerIds)
  494. // histrtyCond += ` AND seller_id in ? `
  495. // prevHistoryCond += ` AND seller_id in ? `
  496. // historyPars = append(historyPars, sellerIds)
  497. // prevHistoryPars = append(prevHistoryPars, sellerIds)
  498. //}
  499. st := fmt.Sprint(startDate, " 00:00:00")
  500. ed := fmt.Sprint(endDate, " 23:59:59")
  501. groupInvoiceMap := make(map[int]float64)
  502. sellerInvoiceMap := make(map[int]float64)
  503. sellerGroupMap := make(map[int]int)
  504. //校验日期,分段查询
  505. if req.StartDate == "" && req.EndDate == "" {
  506. summaryIds, e := fms.GetInvoicePaymentCensusSummaryDataIds(cond, pars)
  507. if e != nil {
  508. return
  509. }
  510. // 开票到款金额合计(换算后)
  511. var amountTotal float64
  512. if len(summaryIds) > 0 {
  513. amountCond := `a.id IN ? `
  514. amountPars := make([]interface{}, 0)
  515. amountPars = append(amountPars, summaryIds)
  516. //if req.SellerIds != "" {
  517. // sellerIds := strings.Split(req.SellerIds, ",")
  518. // amountCond += ` AND (( b.seller_id IN ? AND a.invoice_id <> 0 AND b.invoice_time BETWEEN ? AND ?)`
  519. // amountCond += `OR ( d.seller_id IN ? AND a.payment_id <> 0 AND a.invoice_id = 0 AND d.invoice_time BETWEEN ? AND ?)) `
  520. // amountPars = append(amountPars, sellerIds, st, ed, sellerIds, st, ed)
  521. //} else {
  522. // amountCond += ` AND ((a.invoice_id <> 0 AND b.invoice_time BETWEEN ? AND ?)`
  523. // amountCond += `OR (a.payment_id <> 0 AND a.invoice_id = 0 AND d.invoice_time BETWEEN ? AND ?))`
  524. // amountPars = append(amountPars, st, ed, st, ed)
  525. //}
  526. results, e := fms.GetContractSummaryIncomeAmount(amountCond, amountPars)
  527. if e != nil {
  528. resp.FailMsg("查询错误", fmt.Sprintf("获取汇总数据失败, Err: %s", e.Error()), c)
  529. return
  530. }
  531. //dataList = append(dataList, results...)
  532. var amountSum float64
  533. for _, result := range results {
  534. amountSum += result.Amount
  535. fmt.Println("result.Amount:", result.Amount)
  536. if _, ok := groupInvoiceMap[result.SellerGroupId]; ok {
  537. groupInvoiceMap[result.SellerGroupId] += result.Amount
  538. } else {
  539. groupInvoiceMap[result.SellerGroupId] = result.Amount
  540. }
  541. if _, ok := sellerInvoiceMap[result.FinalSellerId]; ok {
  542. sellerInvoiceMap[result.FinalSellerId] += result.Amount
  543. } else {
  544. sellerInvoiceMap[result.FinalSellerId] = result.Amount
  545. }
  546. if _, ok := sellerGroupMap[result.FinalSellerId]; !ok {
  547. sellerGroupMap[result.FinalSellerId] = result.SellerGroupId
  548. }
  549. }
  550. amountTotal, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", amountSum), 64)
  551. accumulate += amountTotal
  552. //var amountTotal float64
  553. results, e = fms.GetIncomeHistory(histrtyCond, historyPars)
  554. if e != nil {
  555. resp.FailMsg("查询错误", fmt.Sprintf("获取汇总数据失败, Err: %s", e.Error()), c)
  556. return
  557. }
  558. //dataList = append(dataList, results...)
  559. for _, result := range results {
  560. amountSum += result.Amount
  561. if _, ok := groupInvoiceMap[result.SellerGroupId]; ok {
  562. groupInvoiceMap[result.SellerGroupId] += result.Amount
  563. } else {
  564. groupInvoiceMap[result.SellerGroupId] = result.Amount
  565. }
  566. if _, ok := sellerInvoiceMap[result.FinalSellerId]; ok {
  567. sellerInvoiceMap[result.FinalSellerId] += result.Amount
  568. } else {
  569. sellerInvoiceMap[result.FinalSellerId] = result.Amount
  570. }
  571. if _, ok := sellerGroupMap[result.FinalSellerId]; !ok {
  572. sellerGroupMap[result.FinalSellerId] = result.SellerGroupId
  573. }
  574. }
  575. amountTotal, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", amountSum), 64)
  576. accumulate += amountTotal
  577. }
  578. } else if startDateTime.After(historyTime) || startDateTime.Equal(historyTime) {
  579. //全部走新查询
  580. //fmt.Println("新查询")
  581. if st != "" && ed != "" {
  582. cond += ` AND ((c.invoice_time BETWEEN ? AND ?) or (d.invoice_time BETWEEN ? AND ?))`
  583. pars = append(pars, st, ed, st, ed)
  584. }
  585. summaryIds, e := fms.GetInvoicePaymentCensusSummaryDataIds(cond, pars)
  586. if e != nil {
  587. return
  588. }
  589. // 开票到款金额合计(换算后)
  590. var amountTotal float64
  591. if len(summaryIds) > 0 {
  592. amountCond := `a.id IN ? `
  593. amountPars := make([]interface{}, 0)
  594. amountPars = append(amountPars, summaryIds)
  595. //if req.SellerIds != "" {
  596. // sellerIds := strings.Split(req.SellerIds, ",")
  597. // amountCond += ` AND (( b.seller_id IN ? AND a.invoice_id <> 0 AND b.invoice_time BETWEEN ? AND ?)`
  598. // amountCond += `OR ( d.seller_id IN ? AND a.payment_id <> 0 AND a.invoice_id = 0 AND d.invoice_time BETWEEN ? AND ?)) `
  599. // amountPars = append(amountPars, sellerIds, st, ed, sellerIds, st, ed)
  600. //} else {
  601. // amountCond += ` AND ((a.invoice_id <> 0 AND b.invoice_time BETWEEN ? AND ?)`
  602. // amountCond += `OR (a.payment_id <> 0 AND a.invoice_id = 0 AND d.invoice_time BETWEEN ? AND ?))`
  603. // amountPars = append(amountPars, st, ed, st, ed)
  604. //}
  605. results, e := fms.GetContractSummaryIncomeAmount(amountCond, amountPars)
  606. if e != nil {
  607. resp.FailMsg("查询错误", fmt.Sprintf("获取汇总数据失败, Err: %s", e.Error()), c)
  608. return
  609. }
  610. //dataList = append(dataList, results...)
  611. var amountSum float64
  612. for _, result := range results {
  613. amountSum += result.Amount
  614. fmt.Println("result.Amount:", result.Amount)
  615. if _, ok := groupInvoiceMap[result.SellerGroupId]; ok {
  616. groupInvoiceMap[result.SellerGroupId] += result.Amount
  617. } else {
  618. groupInvoiceMap[result.SellerGroupId] = result.Amount
  619. }
  620. if _, ok := sellerInvoiceMap[result.FinalSellerId]; ok {
  621. sellerInvoiceMap[result.FinalSellerId] += result.Amount
  622. } else {
  623. sellerInvoiceMap[result.FinalSellerId] = result.Amount
  624. }
  625. if _, ok := sellerGroupMap[result.FinalSellerId]; !ok {
  626. sellerGroupMap[result.FinalSellerId] = result.SellerGroupId
  627. }
  628. }
  629. amountTotal, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", amountSum), 64)
  630. accumulate += amountTotal
  631. }
  632. } else if endDateTime.Before(historyTime) || endDateTime.Equal(historyTime) {
  633. //全部走旧查询
  634. //fmt.Println("旧查询")
  635. //fmt.Println("st:",st)
  636. //fmt.Println("ed:",ed)
  637. if st != "" && ed != "" {
  638. histrtyCond += ` AND (invoice_time BETWEEN ? AND ? )`
  639. historyPars = append(historyPars, st, ed)
  640. }
  641. //fmt.Println("st:",st)
  642. //fmt.Println("ed:",ed)
  643. // 开票到款金额合计(换算后)
  644. var amountTotal float64
  645. results, e := fms.GetIncomeHistory(histrtyCond, historyPars)
  646. if e != nil {
  647. resp.FailMsg("查询错误", fmt.Sprintf("获取汇总数据失败, Err: %s", e.Error()), c)
  648. return
  649. }
  650. var amountSum float64
  651. //dataList = append(dataList, results...)
  652. for _, result := range results {
  653. amountSum += result.Amount
  654. if _, ok := groupInvoiceMap[result.SellerGroupId]; ok {
  655. groupInvoiceMap[result.SellerGroupId] += result.Amount
  656. } else {
  657. groupInvoiceMap[result.SellerGroupId] = result.Amount
  658. }
  659. if _, ok := sellerInvoiceMap[result.FinalSellerId]; ok {
  660. sellerInvoiceMap[result.FinalSellerId] += result.Amount
  661. } else {
  662. sellerInvoiceMap[result.FinalSellerId] = result.Amount
  663. }
  664. if _, ok := sellerGroupMap[result.FinalSellerId]; !ok {
  665. sellerGroupMap[result.FinalSellerId] = result.SellerGroupId
  666. }
  667. }
  668. amountTotal, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", amountSum), 64)
  669. accumulate += amountTotal
  670. //fmt.Println("partAccumulate:",partAccumulate)
  671. }
  672. fmt.Println("totalMoneySlice:", len(totalMoneySlice))
  673. if req.SellerType == 1 {
  674. departmentId = crm.SellerDepartmentId
  675. } else if req.SellerType == 2 {
  676. departmentId = crm.RaiSellerDepartmentId
  677. } else if req.SellerType == 0 {
  678. resp.FailMsg("查询错误", "请选择正确的销售类型", c)
  679. return
  680. } else {
  681. resp.FailMsg("查询错误", "请选择正确的销售类型", c)
  682. return
  683. }
  684. adminOB := new(crm.Admin)
  685. adminPars := make([]interface{}, 0)
  686. adminCond := ` department_id = %d `
  687. adminCond = fmt.Sprintf(adminCond, departmentId)
  688. adminList, e := adminOB.List(adminCond, adminPars)
  689. if e != nil {
  690. resp.FailMsg("获取失败", "获取销售列表失败, Err: "+e.Error(), c)
  691. return
  692. }
  693. // 获取销售分组信息
  694. sellerList, e := crmService.GetSellerDepartmentListWithEnable()
  695. if e != nil {
  696. resp.FailData("获取销售失败", "Err:"+e.Error(), c)
  697. return
  698. }
  699. sellerMap := make(map[int]*crm.SellerAdminWithGroupTeam)
  700. for i := range sellerList {
  701. sellerMap[sellerList[i].SellerId] = sellerList[i]
  702. }
  703. list := make([]*fms.CensusSellerInvoiceItem, 0)
  704. for _, v := range adminList {
  705. if vv, ok := sellerInvoiceMap[v.AdminId]; ok {
  706. rate := vv / accumulate
  707. mulNum := decimal.NewFromFloat(100)
  708. newRate := decimal.NewFromFloat(rate)
  709. newRate = newRate.Mul(mulNum).Round(2)
  710. finalRate, _ := newRate.Float64()
  711. groupId := sellerGroupMap[v.AdminId]
  712. groupRate := vv / groupInvoiceMap[groupId]
  713. newGroupRate := decimal.NewFromFloat(groupRate)
  714. newGroupRate = newGroupRate.Mul(mulNum).Round(2)
  715. finalGroupRate, _ := newGroupRate.Float64()
  716. amuont, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", vv), 64)
  717. var sellerName, groupName string
  718. if seller, ok := sellerMap[v.AdminId]; ok {
  719. sellerName = seller.SellerName
  720. groupName = seller.GroupName
  721. }
  722. list = append(list, &fms.CensusSellerInvoiceItem{
  723. SellerId: v.AdminId,
  724. SellerName: sellerName,
  725. GroupId: groupId,
  726. GroupName: groupName,
  727. InvoiceAmount: amuont,
  728. GroupRate: finalGroupRate,
  729. SellerRate: finalRate,
  730. })
  731. }
  732. }
  733. var respList fms.CensusSellerList
  734. respList = list
  735. sort.Sort(respList)
  736. // 是否导出
  737. //if req.IsExport == 1 {
  738. // ExportIncomeList(c, incomeList.DataList)
  739. // return
  740. //}
  741. page.SetTotal(int64(len(list)))
  742. baseData := new(base.BaseData)
  743. baseData.SetPage(page)
  744. if req.Current*req.PageSize > int64(len(list)) {
  745. baseData.SetList(respList[(req.Current-1)*req.PageSize:len(list)])
  746. } else {
  747. baseData.SetList(respList[(req.Current-1)*req.PageSize:req.Current*req.PageSize])
  748. }
  749. resp.OkData("获取成功", baseData, c)
  750. }
  751. // ExportInvoiceList 导出销售开票统计列表
  752. func ExportInvoiceList(c *gin.Context, list []*fms.CensusSellerInvoiceItem, req fms.CensusSellerInvoiceListReq) {
  753. // 生成Excel文件
  754. xlsxFile := xlsx.NewFile()
  755. style := xlsx.NewStyle()
  756. alignment := xlsx.Alignment{
  757. Horizontal: "center",
  758. Vertical: "center",
  759. WrapText: true,
  760. }
  761. style.Alignment = alignment
  762. style.ApplyAlignment = true
  763. sheetName := "销售开票统计"
  764. sheet, err := xlsxFile.AddSheet(sheetName)
  765. if err != nil {
  766. resp.FailData("新增Sheet失败", "Err:"+err.Error(), c)
  767. return
  768. }
  769. // 存在筛选则前两行显示时间信息
  770. if req.StartDate != "" && req.EndDate != "" {
  771. timeData := fmt.Sprintf("时间:%s至%s", req.StartDate, req.EndDate)
  772. rowA := sheet.AddRow()
  773. cellAA := rowA.AddCell()
  774. cellAA.SetString("销售统计表")
  775. cellAA.SetStyle(style)
  776. rowB := sheet.AddRow()
  777. rowB.AddCell().SetString(timeData)
  778. // 第三行空出
  779. sheet.AddRow()
  780. }
  781. // 数据表头
  782. rowTitle := []string{"排名", "销售员", "销售组别", "收入金额(元)", "小组占比", "全员占比"}
  783. titleRow := sheet.AddRow()
  784. for i := range rowTitle {
  785. v := titleRow.AddCell()
  786. v.SetString(rowTitle[i])
  787. v.SetStyle(style)
  788. }
  789. // 填充数据
  790. for k, v := range list {
  791. dataRow := sheet.AddRow()
  792. dataRow.AddCell().SetString(fmt.Sprint(k + 1)) // 排名
  793. dataRow.AddCell().SetString(v.SellerName) // 销售员
  794. dataRow.AddCell().SetString(v.GroupName) // 销售组别
  795. dataRow.AddCell().SetString(fmt.Sprint(v.InvoiceAmount)) // 开票金额
  796. dataRow.AddCell().SetString(fmt.Sprint(v.GroupRate, "%")) // 小组占比
  797. dataRow.AddCell().SetString(fmt.Sprint(v.SellerRate, "%")) // 全员占比
  798. }
  799. // 输出文件
  800. var buffer bytes.Buffer
  801. _ = xlsxFile.Write(&buffer)
  802. content := bytes.NewReader(buffer.Bytes())
  803. randStr := time.Now().Format(utils.FormatDateTimeUnSpace)
  804. fileName := sheetName + randStr + ".xlsx"
  805. c.Writer.Header().Add("Content-Disposition", fmt.Sprintf(`attachment; filename="%s"`, fileName))
  806. c.Writer.Header().Add("Content-Type", "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet")
  807. http.ServeContent(c.Writer, c.Request, fileName, time.Now(), content)
  808. }
  809. // GroupInvoiceList
  810. // @Title 销售组开票统计列表
  811. // @Description 销售组开票统计列表
  812. // @Param StartDate query string false "开始日期"
  813. // @Param EndDate query string false "结束日期"
  814. // @Param SortField query int false "排序字段: 1-开票金额; 2-组别占比"
  815. // @Param SortType query int false "排序方式: 1-正序; 2-倒序"
  816. // @Param IsExport query int false "是否导出: 0-否; 1-是"
  817. // @Success 200 {object} fms.CensusSellerGroupInvoiceItem
  818. // @router /census/seller/group_invoice_list [get]
  819. func (this *SellerController) GroupInvoiceListV2(c *gin.Context) {
  820. var req fms.CensusSellerGroupInvoiceListReq
  821. if e := c.BindQuery(&req); e != nil {
  822. err, ok := e.(validator.ValidationErrors)
  823. if !ok {
  824. resp.FailData("参数解析失败", "Err:"+e.Error(), c)
  825. return
  826. }
  827. resp.FailData("参数解析失败", err.Translate(global.Trans), c)
  828. return
  829. }
  830. //收入统计
  831. //获取最新的开票到款日期
  832. cond1 := ``
  833. historyCond := ``
  834. //pars1 := make([]interface{}, 0)
  835. //historyPars1 := make([]interface{}, 0)
  836. //if req.SellerIds != "" {
  837. // sellerIds := strings.Split(req.SellerIds, ",")
  838. // cond += ` AND (a.seller_id in ? ) `
  839. // historyCond += ` AND (seller_id in ? ) `
  840. // pars = append(pars, sellerIds)
  841. // historyPars = append(historyPars, sellerIds)
  842. //}
  843. if req.CompanyType == 1 {
  844. cond1 += ` AND b.contract_type = 1 `
  845. historyCond += ` AND new_company = 1 `
  846. } else if req.CompanyType == 2 {
  847. cond1 += ` AND b.contract_type IN (2,3,4) `
  848. historyCond += ` AND new_company = 0 `
  849. }
  850. var totalMoneySlice []float64
  851. var reqStartDate, reqEndDate time.Time
  852. historyTime, _ := time.Parse(utils.FormatDate, "2023-04-01")
  853. if req.StartDate != "" && req.EndDate != "" {
  854. st := fmt.Sprint(req.StartDate, "-01 00:00:00")
  855. ed := fmt.Sprint(req.EndDate, "-01 23:59:59")
  856. reqStartDate, _ = time.Parse(utils.FormatDateTime, st)
  857. reqEndDate, _ = time.Parse(utils.FormatDateTime, ed)
  858. }
  859. // 累计值
  860. var accumulate float64
  861. //dataList := make([]*fms.IncomeSummaryItem, 0)
  862. //historydataList := make([]*fms.IncomeSummaryItem, 0)
  863. //timeNow, _ := time.Parse("2006-01", time.Now().Format("2006-01"))
  864. var prevStartDate string
  865. var startDate, endDate string
  866. //开始日期
  867. if req.StartDate != "" && req.EndDate != "" {
  868. startDate = reqStartDate.Format("2006-01")
  869. prevStartDate = reqStartDate.Format("2006-01")
  870. }
  871. startDate = fmt.Sprint(startDate, "-01")
  872. prevStartDate = fmt.Sprint(prevStartDate, "-01")
  873. startDateTime, _ := time.Parse(utils.FormatDate, startDate)
  874. endDateTime, _ := time.Parse(utils.FormatDate, endDate)
  875. //结束日期
  876. if req.StartDate != "" && req.EndDate != "" {
  877. endDate = reqEndDate.Format("2006-01")
  878. }
  879. cond := `1 = 1`
  880. histrtyCond := `1 = 1`
  881. pars := make([]interface{}, 0)
  882. historyPars := make([]interface{}, 0)
  883. if req.CompanyType == 1 {
  884. cond += ` AND b.contract_type = 1 `
  885. histrtyCond += ` AND new_company = 1 `
  886. } else if req.CompanyType == 2 {
  887. cond += ` AND b.contract_type IN (2,3,4) `
  888. histrtyCond += ` AND new_company = 0 `
  889. }
  890. //if req.SellerIds != "" {
  891. // sellerIds := strings.Split(req.SellerIds, ",")
  892. // cond += ` AND (c.seller_id in ? OR d.seller_id in ?)`
  893. // pars = append(pars, sellerIds, sellerIds)
  894. // prevCond += ` AND (c.seller_id in ? OR d.seller_id in ?)`
  895. // prevPars = append(prevPars, sellerIds, sellerIds)
  896. // histrtyCond += ` AND seller_id in ? `
  897. // prevHistoryCond += ` AND seller_id in ? `
  898. // historyPars = append(historyPars, sellerIds)
  899. // prevHistoryPars = append(prevHistoryPars, sellerIds)
  900. //}
  901. st := fmt.Sprint(startDate, " 00:00:00")
  902. ed := fmt.Sprint(endDate, " 23:59:59")
  903. groupInvoiceMap := make(map[int]float64)
  904. //校验日期,分段查询
  905. if req.StartDate == "" && req.EndDate == "" {
  906. summaryIds, e := fms.GetInvoicePaymentCensusSummaryDataIds(cond, pars)
  907. if e != nil {
  908. return
  909. }
  910. // 开票到款金额合计(换算后)
  911. var amountTotal float64
  912. if len(summaryIds) > 0 {
  913. amountCond := `a.id IN ? `
  914. amountPars := make([]interface{}, 0)
  915. amountPars = append(amountPars, summaryIds)
  916. //if req.SellerIds != "" {
  917. // sellerIds := strings.Split(req.SellerIds, ",")
  918. // amountCond += ` AND (( b.seller_id IN ? AND a.invoice_id <> 0 AND b.invoice_time BETWEEN ? AND ?)`
  919. // amountCond += `OR ( d.seller_id IN ? AND a.payment_id <> 0 AND a.invoice_id = 0 AND d.invoice_time BETWEEN ? AND ?)) `
  920. // amountPars = append(amountPars, sellerIds, st, ed, sellerIds, st, ed)
  921. //} else {
  922. // amountCond += ` AND ((a.invoice_id <> 0 AND b.invoice_time BETWEEN ? AND ?)`
  923. // amountCond += `OR (a.payment_id <> 0 AND a.invoice_id = 0 AND d.invoice_time BETWEEN ? AND ?))`
  924. // amountPars = append(amountPars, st, ed, st, ed)
  925. //}
  926. results, e := fms.GetContractSummaryIncomeAmount(amountCond, amountPars)
  927. if e != nil {
  928. resp.FailMsg("查询错误", fmt.Sprintf("获取汇总数据失败, Err: %s", e.Error()), c)
  929. return
  930. }
  931. //dataList = append(dataList, results...)
  932. var amountSum float64
  933. for _, result := range results {
  934. amountSum += result.Amount
  935. fmt.Println("result.Amount:", result.Amount)
  936. if _, ok := groupInvoiceMap[result.SellerGroupId]; ok {
  937. groupInvoiceMap[result.SellerGroupId] += result.Amount
  938. } else {
  939. groupInvoiceMap[result.SellerGroupId] = result.Amount
  940. }
  941. }
  942. amountTotal, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", amountSum), 64)
  943. accumulate += amountTotal
  944. //var amountTotal float64
  945. results, e = fms.GetIncomeHistory(histrtyCond, historyPars)
  946. if e != nil {
  947. resp.FailMsg("查询错误", fmt.Sprintf("获取汇总数据失败, Err: %s", e.Error()), c)
  948. return
  949. }
  950. //dataList = append(dataList, results...)
  951. for _, result := range results {
  952. amountSum += result.Amount
  953. if _, ok := groupInvoiceMap[result.SellerGroupId]; ok {
  954. groupInvoiceMap[result.SellerGroupId] += result.Amount
  955. } else {
  956. groupInvoiceMap[result.SellerGroupId] = result.Amount
  957. }
  958. }
  959. amountTotal, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", amountSum), 64)
  960. accumulate += amountTotal
  961. }
  962. } else if startDateTime.After(historyTime) || startDateTime.Equal(historyTime) {
  963. //全部走新查询
  964. //fmt.Println("新查询")
  965. if st != "" && ed != "" {
  966. cond += ` AND ((c.invoice_time BETWEEN ? AND ?) or (d.invoice_time BETWEEN ? AND ?))`
  967. pars = append(pars, st, ed, st, ed)
  968. }
  969. summaryIds, e := fms.GetInvoicePaymentCensusSummaryDataIds(cond, pars)
  970. if e != nil {
  971. return
  972. }
  973. // 开票到款金额合计(换算后)
  974. var amountTotal float64
  975. if len(summaryIds) > 0 {
  976. amountCond := `a.id IN ? `
  977. amountPars := make([]interface{}, 0)
  978. amountPars = append(amountPars, summaryIds)
  979. //if req.SellerIds != "" {
  980. // sellerIds := strings.Split(req.SellerIds, ",")
  981. // amountCond += ` AND (( b.seller_id IN ? AND a.invoice_id <> 0 AND b.invoice_time BETWEEN ? AND ?)`
  982. // amountCond += `OR ( d.seller_id IN ? AND a.payment_id <> 0 AND a.invoice_id = 0 AND d.invoice_time BETWEEN ? AND ?)) `
  983. // amountPars = append(amountPars, sellerIds, st, ed, sellerIds, st, ed)
  984. //} else {
  985. // amountCond += ` AND ((a.invoice_id <> 0 AND b.invoice_time BETWEEN ? AND ?)`
  986. // amountCond += `OR (a.payment_id <> 0 AND a.invoice_id = 0 AND d.invoice_time BETWEEN ? AND ?))`
  987. // amountPars = append(amountPars, st, ed, st, ed)
  988. //}
  989. results, e := fms.GetContractSummaryIncomeAmount(amountCond, amountPars)
  990. if e != nil {
  991. resp.FailMsg("查询错误", fmt.Sprintf("获取汇总数据失败, Err: %s", e.Error()), c)
  992. return
  993. }
  994. //dataList = append(dataList, results...)
  995. var amountSum float64
  996. for _, result := range results {
  997. amountSum += result.Amount
  998. fmt.Println("result.Amount:", result.Amount)
  999. if _, ok := groupInvoiceMap[result.SellerGroupId]; ok {
  1000. groupInvoiceMap[result.SellerGroupId] += result.Amount
  1001. } else {
  1002. groupInvoiceMap[result.SellerGroupId] = result.Amount
  1003. }
  1004. }
  1005. amountTotal, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", amountSum), 64)
  1006. accumulate += amountTotal
  1007. }
  1008. } else if endDateTime.Before(historyTime) || endDateTime.Equal(historyTime) {
  1009. //全部走旧查询
  1010. //fmt.Println("旧查询")
  1011. //fmt.Println("st:",st)
  1012. //fmt.Println("ed:",ed)
  1013. if st != "" && ed != "" {
  1014. histrtyCond += ` AND (invoice_time BETWEEN ? AND ? )`
  1015. historyPars = append(historyPars, st, ed)
  1016. }
  1017. //fmt.Println("st:",st)
  1018. //fmt.Println("ed:",ed)
  1019. // 开票到款金额合计(换算后)
  1020. var amountTotal float64
  1021. results, e := fms.GetIncomeHistory(histrtyCond, historyPars)
  1022. if e != nil {
  1023. resp.FailMsg("查询错误", fmt.Sprintf("获取汇总数据失败, Err: %s", e.Error()), c)
  1024. return
  1025. }
  1026. var amountSum float64
  1027. //dataList = append(dataList, results...)
  1028. for _, result := range results {
  1029. amountSum += result.Amount
  1030. if _, ok := groupInvoiceMap[result.SellerGroupId]; ok {
  1031. groupInvoiceMap[result.SellerGroupId] += result.Amount
  1032. } else {
  1033. groupInvoiceMap[result.SellerGroupId] = result.Amount
  1034. }
  1035. }
  1036. amountTotal, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", amountSum), 64)
  1037. accumulate += amountTotal
  1038. //fmt.Println("partAccumulate:",partAccumulate)
  1039. }
  1040. fmt.Println("totalMoneySlice:", len(totalMoneySlice))
  1041. var departmentId int
  1042. if req.SellerType == 1 {
  1043. departmentId = crm.SellerDepartmentId
  1044. } else if req.SellerType == 2 {
  1045. departmentId = crm.RaiSellerDepartmentId
  1046. } else if req.SellerType == 0 {
  1047. resp.FailMsg("查询错误", "请选择正确的销售类型", c)
  1048. return
  1049. } else {
  1050. resp.FailMsg("查询错误", "请选择正确的销售类型", c)
  1051. return
  1052. }
  1053. groupCond := ` department_id = %d AND parent_id = 0 `
  1054. groupCond = fmt.Sprintf(groupCond, departmentId)
  1055. groupPars := make([]interface{}, 0)
  1056. groupOB := new(crm.SysGroup)
  1057. groupList, e := groupOB.List(groupCond, groupPars)
  1058. if e != nil {
  1059. resp.FailMsg("查询错误", fmt.Sprintf("获取组别列表失败, Err: %s", e.Error()), c)
  1060. return
  1061. }
  1062. //total := len(groupList)
  1063. groupMap := make(map[int]*crm.SysGroup)
  1064. groupIdSlice := make([]string, 0)
  1065. for i := range groupList {
  1066. groupMap[groupList[i].GroupId] = groupList[i]
  1067. groupIdSlice = append(groupIdSlice, strconv.Itoa(groupList[i].GroupId))
  1068. }
  1069. list := make([]*fms.CensusSellerGroupInvoiceItem, 0)
  1070. for k, v := range groupInvoiceMap {
  1071. rate := v / accumulate
  1072. mulNum := decimal.NewFromFloat(100)
  1073. newRate := decimal.NewFromFloat(rate)
  1074. newRate = newRate.Mul(mulNum).Round(2)
  1075. finalRate, _ := newRate.Float64()
  1076. amuont, _ := strconv.ParseFloat(fmt.Sprintf("%.2f", v), 64)
  1077. groupName := ""
  1078. if groupItem, ok := groupMap[k]; ok {
  1079. groupName = groupItem.GroupName
  1080. }
  1081. list = append(list, &fms.CensusSellerGroupInvoiceItem{
  1082. GroupId: k,
  1083. GroupName: groupName,
  1084. InvoiceAmount: amuont,
  1085. GroupRate: finalRate,
  1086. })
  1087. }
  1088. var respList fms.CensusSellerGroupList
  1089. respList = list
  1090. sort.Sort(respList)
  1091. // 是否导出
  1092. //if req.IsExport == 1 {
  1093. // ExportIncomeList(c, incomeList.DataList)
  1094. // return
  1095. //}
  1096. resp.OkData("获取成功", respList, c)
  1097. }