contract_invoice.go 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506
  1. package fms
  2. import (
  3. "fmt"
  4. "hongze/fms_api/global"
  5. "hongze/fms_api/models/base"
  6. "hongze/fms_api/utils"
  7. "time"
  8. )
  9. // ContractInvoice 合同开票表
  10. type ContractInvoice struct {
  11. ContractInvoiceId int `gorm:"primaryKey;column:contract_invoice_id" json:"contract_invoice_id" description:"开票ID"`
  12. ContractRegisterId int `gorm:"column:contract_register_id" json:"contract_register_id" description:"登记ID"`
  13. ContractCode string `gorm:"column:contract_code" json:"contract_code" description:"合同编号"`
  14. Amount float64 `gorm:"column:amount" json:"amount" description:"换算后的金额(人民币)"`
  15. OriginAmount float64 `gorm:"column:origin_amount" json:"origin_amount" description:"开票/到款金额"`
  16. CurrencyUnit string `gorm:"column:currency_unit" json:"currency_unit" description:"货币国际代码"`
  17. InvoiceType int `gorm:"column:invoice_type" json:"invoice_type" description:"类型: 1-开票登记; 2-到款登记"`
  18. InvoiceDate time.Time `gorm:"column:invoice_time" json:"invoice_time" description:"开票日期/到款月"`
  19. SellerId int `gorm:"column:seller_id" json:"seller_id" description:"销售ID"`
  20. SellerName string `gorm:"column:seller_name" json:"seller_name" description:"销售名称"`
  21. SellerGroupId int `gorm:"column:seller_group_id" json:"seller_group_id" description:"销售分组ID"`
  22. SellerGroupName string `gorm:"column:seller_group_name" json:"seller_group_name" description:"销售分组名称"`
  23. SellerTeamId int `gorm:"column:seller_team_id" json:"seller_team_id" description:"销售小组ID"`
  24. SellerTeamName string `gorm:"column:seller_team_name" json:"seller_team_name" description:"销售小组名称"`
  25. PayType int `gorm:"column:pay_type" json:"pay_type" description:"付款方式:0-无;1-年付;2-半年付;3-季付;4-次付;5-异常"`
  26. AdminId int `gorm:"column:admin_id" json:"admin_id" description:"操作人ID"`
  27. AdminName string `gorm:"column:admin_name" json:"admin_name" description:"操作人姓名"`
  28. Remark string `gorm:"column:remark" json:"remark" description:"备注信息"`
  29. IsDeleted int `gorm:"column:is_deleted" json:"is_deleted" description:"是否已删除: 0-正常; 1-已删除"`
  30. ServiceProductId int `gorm:"column:service_product_id" json:"service_product_id" description:"套餐类型:1ficc套餐,2权益套餐"`
  31. IsPrePay int `gorm:"column:is_pre_pay" json:"is_pre_pay" description:"是否预付款: 0-不是; 1-是"`
  32. base.TimeBase
  33. }
  34. func (c *ContractInvoice) TableName() string {
  35. return "contract_invoice"
  36. }
  37. // ContractInvoiceItem 合同开票/到款
  38. type ContractInvoiceItem struct {
  39. ContractInvoiceId int `gorm:"column:contract_invoice_id" json:"contract_invoice_id" description:"开票ID"`
  40. ContractRegisterId int `gorm:"column:contract_register_id" json:"contract_register_id" description:"登记ID"`
  41. ContractCode string `gorm:"column:contract_code" json:"contract_code" description:"合同编号"`
  42. ContractStatus int `json:"contract_status" description:"合同状态: 1-已审批; 2-单章寄出; 3-已签回"`
  43. Amount float64 `gorm:"column:amount" json:"amount" description:"换算金额"`
  44. OriginAmount float64 `gorm:"column:origin_amount" json:"origin_amount" description:"开票/到款金额"`
  45. CurrencyUnit string `gorm:"column:currency_unit" json:"currency_unit" description:"货币国际代码"`
  46. UnitName string `json:"unit_name" description:"货币单位名称"`
  47. InvoiceType int `gorm:"column:invoice_type" json:"invoice_type" description:"类型: 1-开票登记; 2-到款登记"`
  48. InvoiceDate string `gorm:"column:invoice_time" json:"invoice_time" description:"开票日期/到款月"`
  49. SellerId int `gorm:"column:seller_id" json:"seller_id" description:"销售ID"`
  50. SellerName string `gorm:"column:seller_name" json:"seller_name" description:"销售名称"`
  51. PayType int `gorm:"column:pay_type" json:"pay_type" description:"付款方式:0-无;1-年付;2-半年付;3-季付;4-次付;5-异常"`
  52. Remark string `gorm:"column:remark" json:"remark" description:"备注信息"`
  53. ServiceProductId int `gorm:"column:service_product_id" json:"service_product_id" description:"套餐类型:1ficc套餐,2权益套餐"`
  54. IsPrePay int `gorm:"column:is_pre_pay" json:"is_pre_pay" description:"是否预付款: 0-不是; 1-是"`
  55. CreateTime string `gorm:"column:create_time" json:"create_time" description:"创建时间"`
  56. CompanyName string `gorm:"column:company_name" json:"company_name" description:"客户名称"`
  57. }
  58. func (c *ContractInvoice) Create() (err error) {
  59. err = global.DEFAULT_MYSQL.Create(c).Error
  60. return
  61. }
  62. func (c *ContractInvoice) AddInBatches(list []*ContractInvoice) (err error) {
  63. err = global.DEFAULT_MYSQL.CreateInBatches(list, len(list)).Error
  64. return
  65. }
  66. func (c *ContractInvoice) Update(updateCols []string) (err error) {
  67. err = global.DEFAULT_MYSQL.Model(c).Select(updateCols).Updates(c).Error
  68. return
  69. }
  70. func (c *ContractInvoice) Fetch(id int) (item *ContractInvoice, err error) {
  71. err = global.DEFAULT_MYSQL.Model(c).Where("is_deleted = 0 AND contract_invoice_id = ?", id).First(&item).Error
  72. return
  73. }
  74. func (c *ContractInvoice) Sum(field, condition string, pars []interface{}) (total float64, err error) {
  75. totalList := make([]float64, 0)
  76. err = global.DEFAULT_MYSQL.Model(c).
  77. Where("is_deleted = 0").
  78. Where(condition, pars...).
  79. Pluck(field, &totalList).Error
  80. for i := range totalList {
  81. total += totalList[i]
  82. }
  83. return
  84. }
  85. func (c *ContractInvoice) List(condition string, pars []interface{}, orderRule string) (list []*ContractInvoice, err error) {
  86. list = make([]*ContractInvoice, 0)
  87. query := global.DEFAULT_MYSQL.Model(c).
  88. Where("is_deleted = 0").
  89. Where(condition, pars...)
  90. if orderRule != "" {
  91. query.Order(orderRule)
  92. } else {
  93. query.Order("contract_invoice_id ASC")
  94. }
  95. err = query.Find(&list).Error
  96. return
  97. }
  98. func (c *ContractInvoice) PageList(page base.IPage, condition string, pars []interface{}) (count int64, results []*ContractInvoice, err error) {
  99. results = make([]*ContractInvoice, 0)
  100. query := global.DEFAULT_MYSQL.Model(c).
  101. Where("is_deleted = 0").
  102. Where(condition, pars...)
  103. query.Count(&count)
  104. if len(page.GetOrderItemsString()) > 0 {
  105. query = query.Order(page.GetOrderItemsString())
  106. }
  107. err = query.Limit(int(page.GetPageSize())).Offset(int(page.Offset())).Find(&results).Error
  108. return
  109. }
  110. // DeleteAndCreateNewInvoice 删除并新增登记
  111. func (c *ContractInvoice) DeleteAndCreateNewInvoice(contractRegisterId, invoiceType int, deleteInvoiceIds []int, invoices []*ContractInvoice) (err error) {
  112. tx := global.DEFAULT_MYSQL.Begin()
  113. defer func() {
  114. if err != nil {
  115. tx.Rollback()
  116. } else {
  117. tx.Commit()
  118. }
  119. }()
  120. if len(deleteInvoiceIds) > 0 {
  121. err = tx.Model(c).
  122. Where("contract_register_id = ? AND invoice_type = ? AND contract_invoice_id IN (?)", contractRegisterId, invoiceType, deleteInvoiceIds).
  123. UpdateColumn("is_deleted", 1).Error
  124. if err != nil {
  125. return
  126. }
  127. }
  128. if len(invoices) > 0 {
  129. err = tx.CreateInBatches(invoices, len(invoices)).Error
  130. if err != nil {
  131. return
  132. }
  133. }
  134. return
  135. }
  136. // ContractInvoiceSaveReq 合同开票-请求体
  137. type ContractInvoiceSaveReq struct {
  138. ContractRegisterId int `json:"contract_register_id" binding:"required,gte=1" description:"登记ID"`
  139. InvoiceType int `json:"invoice_type" binding:"oneof=1 2 3" description:"类型: 1-开票登记; 2-到款登记; 3-预到款登记"`
  140. AmountList []*ContractInvoiceSaveItem `json:"amount_list"`
  141. }
  142. // ContractInvoiceSaveItem 合同开票数据
  143. type ContractInvoiceSaveItem struct {
  144. ServiceProductId int `json:"service_product_id" binding:"oneof=1 2" description:"套餐类型:1ficc套餐,2权益套餐"`
  145. InvoiceId int `json:"invoice_id" description:"开票ID"`
  146. OriginAmount float64 `json:"origin_amount" description:"开票(到款)金额"`
  147. Amount float64 `json:"amount" description:"换算后的金额"`
  148. InvoiceDate string `json:"invoice_date" description:"开票日期/到款月"`
  149. Remark string `json:"remark" description:"备注"`
  150. SellerId int `json:"seller_id" description:"销售ID"`
  151. }
  152. // GetContractInvoiceItemList 获取开票到款列表
  153. func GetContractInvoiceItemList(condition string, pars []interface{}) (itemList []*ContractInvoiceItem, err error) {
  154. list := make([]*ContractInvoice, 0)
  155. err = global.DEFAULT_MYSQL.Model(ContractInvoice{}).
  156. Where("is_deleted = 0").
  157. Where(condition, pars...).
  158. Order("contract_invoice_id ASC").
  159. Find(&list).Error
  160. if err != nil {
  161. return
  162. }
  163. itemList = formatContractInvoice2ItemList(list)
  164. return
  165. }
  166. // formatContractInvoice2ItemList 格式化ContractInvoice
  167. func formatContractInvoice2ItemList(list []*ContractInvoice) (itemList []*ContractInvoiceItem) {
  168. itemList = make([]*ContractInvoiceItem, 0)
  169. for i := range list {
  170. itemList = append(itemList, &ContractInvoiceItem{
  171. ContractInvoiceId: list[i].ContractInvoiceId,
  172. ContractRegisterId: list[i].ContractRegisterId,
  173. ContractCode: list[i].ContractCode,
  174. Amount: list[i].Amount,
  175. OriginAmount: list[i].OriginAmount,
  176. CurrencyUnit: list[i].CurrencyUnit,
  177. InvoiceType: list[i].InvoiceType,
  178. InvoiceDate: utils.TimeTransferString(utils.FormatDate, list[i].InvoiceDate),
  179. SellerId: list[i].SellerId,
  180. SellerName: list[i].SellerName,
  181. PayType: list[i].PayType,
  182. Remark: list[i].Remark,
  183. IsPrePay: list[i].IsPrePay,
  184. CreateTime: utils.TimeTransferString(utils.FormatDateTime, list[i].CreateTime),
  185. ServiceProductId: list[i].ServiceProductId,
  186. })
  187. }
  188. return
  189. }
  190. // ContractInvoiceListReq 合同开票/到款登记列表请求体
  191. type ContractInvoiceListReq struct {
  192. InvoiceType int `json:"invoice_type" form:"invoice_type" binding:"oneof=1 2" description:"类型: 1-开票登记; 2-到款登记"`
  193. SellerIds string `json:"seller_ids" form:"seller_ids" description:"销售ID, 多个id用逗号拼接"`
  194. ContractCode string `json:"contract_code" form:"contract_code" binding:"omitempty" description:"合同编号"`
  195. StartDate string `json:"start_date" form:"start_date" binding:"omitempty,datetime=2006-01-02" description:"开始日期"`
  196. EndDate string `json:"end_date" form:"end_date" binding:"omitempty,datetime=2006-01-02" description:"结束日期"`
  197. MinAmount float64 `json:"min_amount" form:"min_amount" description:"开票金额区间-最小值"`
  198. MaxAmount float64 `json:"max_amount" form:"max_amount" description:"开票金额区间-最大值"`
  199. IsExport int `json:"is_export" form:"is_export" description:"是否导出: 0-否; 1-是"`
  200. ServiceProductId int `json:"service_product_id" form:"service_product_id" description:"套餐类型:1ficc套餐,2权益套餐"`
  201. base.PageReq
  202. }
  203. // GetContractInvoiceItemPageList 获取合同开票/到款列表-分页
  204. func GetContractInvoiceItemPageList(page base.IPage, condition string, pars []interface{}) (count int64, results []*ContractInvoiceItem, err error) {
  205. list := make([]*ContractInvoiceRespItem, 0)
  206. query := global.DEFAULT_MYSQL.Table("contract_invoice AS a").
  207. Select("a.*, b.company_name").
  208. Joins("JOIN contract_register b ON a.contract_register_id = b.contract_register_id").
  209. Where("a.is_deleted = 0").
  210. Where(condition, pars...)
  211. query.Count(&count)
  212. if len(page.GetOrderItemsString()) > 0 {
  213. query = query.Order(page.GetOrderItemsString())
  214. }
  215. err = query.Limit(int(page.GetPageSize())).Offset(int(page.Offset())).Find(&list).Error
  216. if err != nil {
  217. return
  218. }
  219. for i := range list {
  220. results = append(results, formatContractInvoice2Item(list[i]))
  221. }
  222. return
  223. }
  224. // formatContractInvoice2Item 格式化ContractInvoiceItem
  225. func formatContractInvoice2Item(item *ContractInvoiceRespItem) (formatItem *ContractInvoiceItem) {
  226. formatItem = new(ContractInvoiceItem)
  227. formatItem.ContractInvoiceId = item.ContractInvoiceId
  228. formatItem.ContractRegisterId = item.ContractRegisterId
  229. formatItem.ContractCode = item.ContractCode
  230. formatItem.Amount = item.Amount
  231. formatItem.OriginAmount = item.OriginAmount
  232. formatItem.CurrencyUnit = item.CurrencyUnit
  233. formatItem.InvoiceType = item.InvoiceType
  234. formatItem.InvoiceDate = utils.TimeTransferString(utils.FormatDate, item.InvoiceDate)
  235. formatItem.SellerId = item.SellerId
  236. formatItem.SellerName = item.SellerName
  237. formatItem.PayType = item.PayType
  238. formatItem.Remark = item.Remark
  239. formatItem.IsPrePay = item.IsPrePay
  240. formatItem.ServiceProductId = item.ServiceProductId
  241. formatItem.CreateTime = utils.TimeTransferString(utils.FormatDateTime, item.CreateTime)
  242. formatItem.CompanyName = item.CompanyName
  243. return
  244. }
  245. // DeleteContractInvoicesByRegisterId 根据合同登记ID删除开票/到款记录
  246. func DeleteContractInvoicesByRegisterId(registerId int) (err error) {
  247. sql := `UPDATE contract_invoice SET is_deleted = 1 WHERE contract_register_id = ?`
  248. err = global.DEFAULT_MYSQL.Exec(sql, registerId).Error
  249. return
  250. }
  251. // InvoicePaymentCensusListReq 商品到款统计列表请求体
  252. type InvoicePaymentCensusListReq struct {
  253. Keyword string `json:"keyword" form:"keyword" binding:"omitempty" description:"关键词"`
  254. SellerIds string `json:"seller_ids" form:"seller_ids" description:"销售ID,多个ID之间用逗号拼接"`
  255. ServiceTypes string `json:"service_types" form:"service_types" description:"套餐类型, 多个套餐之间用逗号拼接"`
  256. StartDate string `json:"start_date" form:"start_date" binding:"omitempty,datetime=2006-01-02" description:"开始日期"`
  257. EndDate string `json:"end_date" form:"end_date" binding:"omitempty,datetime=2006-01-02" description:"结束日期"`
  258. HasInvoice string `json:"has_invoice" form:"has_invoice" description:"是否已开票: 0-否; 1-是; 空-全部"`
  259. HasPayment string `json:"has_payment" form:"has_payment" description:"是否已到款: 0-否; 1-是; 空-全部"`
  260. IsExport int `json:"is_export" form:"is_export" description:"是否导出: 0-否; 1-是"`
  261. SortParam string `json:"sort_param" form:"sort_param" description:"排序字段参数,用来排序的字段, 枚举值:'invoice_time':开票日 、 'payment_date':到款日"`
  262. SortType string `json:"sort_type" form:"sort_type" description:"如何排序,是正序还是倒序,枚举值:asc 正序,desc 倒叙"`
  263. TimeType int `json:"time_type" form:"time_type" description:"时间类型: 1-开票时间; 2-到款时间;3-开票时间&到款时间"`
  264. base.PageReq
  265. }
  266. // GetInvoicePaymentCensusPageListV2 获取商品到款统计列表-分页
  267. func GetInvoicePaymentCensusPageListV2(page base.IPage, condition string, pars []interface{}) (results []*ContractRegister, registerIds []int, err error) {
  268. query := global.DEFAULT_MYSQL.Table("contract_invoice AS a").
  269. Select("b.*").
  270. Joins("JOIN contract_register AS b ON a.contract_register_id = b.contract_register_id").
  271. Where("a.is_deleted = 0 AND b.is_deleted = 0").
  272. Where(condition, pars...).
  273. Group("b.contract_register_id")
  274. if len(page.GetOrderItemsString()) > 0 {
  275. query = query.Order(page.GetOrderItemsString())
  276. }
  277. err = query.Limit(int(page.GetPageSize())).Offset(int(page.Offset())).Find(&results).Error
  278. if err != nil {
  279. return
  280. }
  281. // 计数
  282. queryCount := global.DEFAULT_MYSQL.Table("contract_invoice AS a").
  283. Select("b.contract_register_id").
  284. Joins("JOIN contract_register AS b ON a.contract_register_id = b.contract_register_id").
  285. Where("a.is_deleted = 0 AND b.is_deleted = 0").
  286. Where(condition, pars...).
  287. Group("b.contract_register_id")
  288. queryCount.Find(&registerIds)
  289. return
  290. }
  291. // InvoicePaymentCensusResp 商品到款统计响应体
  292. type InvoicePaymentCensusResp struct {
  293. DataList []*InvoicePaymentCensusItem `json:"data_list"`
  294. InvoiceTotal float64 `json:"invoice_total" description:"开票总金额(换算后)"`
  295. PaymentTotal float64 `json:"payment_total" description:"到款总金额(换算后)"`
  296. InvoiceCurrencyTotal []*InvoiceListCurrencyTotal `json:"invoice_currency_total" description:"开票-分币种总金额"`
  297. PaymentCurrencyTotal []*InvoiceListCurrencyTotal `json:"payment_currency_total" description:"到款-分币种总金额"`
  298. }
  299. // InvoicePaymentCensusItem 商品到款统计信息
  300. type InvoicePaymentCensusItem struct {
  301. SummaryId int `json:"summary_id" description:"汇总ID"`
  302. ContractRegisterId int `json:"contract_register_id" description:"登记ID"`
  303. CompanyName string `json:"company_name" description:"客户名称"`
  304. NewCompany int `json:"new_company" description:"是否为新客户: 0-否; 1-是"`
  305. StartDate string `json:"start_date" description:"合同开始日期"`
  306. EndDate string `json:"end_date" description:"合同结束日期"`
  307. ServicesName string `json:"services_name" description:"套餐信息字符串拼接"`
  308. InvoicePaymentList []*InvoicePaymentCensusInfo `json:"invoice_payment_list" description:"开票到款列表"`
  309. }
  310. // InvoicePaymentCensusInfo 开票到款统计信息
  311. type InvoicePaymentCensusInfo struct {
  312. InvoiceId int `json:"invoice_id" description:"开票ID"`
  313. InvoiceDate string `json:"invoice_time" description:"开票日期"`
  314. InvoiceAmount float64 `json:"invoice_amount" description:"开票金额"`
  315. SellerId int `json:"seller_id" description:"销售ID"`
  316. SellerName string `json:"seller_name" description:"销售名称"`
  317. SellerGroupId int `json:"seller_group_id" description:"销售组别ID"`
  318. SellerGroupName string `json:"seller_group_name" description:"销售组别名称"`
  319. PaymentId int `json:"payment_id" description:"到款ID"`
  320. PaymentDate string `json:"payment_date" description:"到款日期"`
  321. PaymentAmount float64 `json:"payment_amount" description:"到款金额"`
  322. PayType int `json:"pay_type" description:"付款方式:0-无;1-年付;2-半年付;3-季付;4-次付;5-异常"`
  323. ServiceAmountList []*ContractPaymentServiceAmountItem `json:"service_amount_list" description:"到款套餐金额分配信息"`
  324. SellerType int `json:"seller_type" description:"销售类型:1ficc销售,2权益销售"`
  325. }
  326. // ContractInvoiceAmountTotal 开票到款金额合计信息
  327. type ContractInvoiceAmountTotal struct {
  328. InvoiceType int `json:"invoice_type" description:"类型: 1-开票; 2-到款"`
  329. TotalAmount float64 `json:"total_amount" description:"金额合计"`
  330. }
  331. // GetContractInvoiceAmountTotal 获取开票到款金额合计信息
  332. func GetContractInvoiceAmountTotal(condition string, pars []interface{}) (results []*ContractInvoiceAmountTotal, err error) {
  333. query := global.DEFAULT_MYSQL.Table("contract_invoice").
  334. Select("invoice_type, SUM(amount) AS total_amount").
  335. Where("is_deleted = 0").
  336. Where(condition, pars...).
  337. Group("invoice_type")
  338. err = query.Find(&results).Error
  339. return
  340. }
  341. // UpdatePaymentPayTypeReq 到款登记-修改付款方式请求体
  342. type UpdatePaymentPayTypeReq struct {
  343. ContractPaymentId int `json:"contract_payment_id" binding:"required,gte=1" description:"到款登记ID"`
  344. PayType int `json:"pay_type" binding:"oneof=1 2 3 4" description:"付款方式: 1-年付; 2-半年付; 3-季付; 4-次付"`
  345. }
  346. // CensusSellerGroupInvoiceListReq 销售组开票统计列表请求体
  347. type CensusSellerGroupInvoiceListReq struct {
  348. StartDate string `json:"start_date" form:"start_date" binding:"omitempty,datetime=2006-01-02" description:"开始日期"`
  349. EndDate string `json:"end_date" form:"end_date" binding:"omitempty,datetime=2006-01-02" description:"结束日期"`
  350. SortField int `json:"sort_field" form:"sort_field" description:"排序字段: 1-开票金额; 2-组别占比"`
  351. SortType int `json:"sort_type" form:"sort_type" description:"排序方式: 1-正序; 2-倒序"`
  352. IsExport int `json:"is_export" form:"is_export" description:"是否导出: 0-否; 1-是"`
  353. SellerType int `json:"seller_type" form:"seller_type" description:"销售类型:1ficc销售,2权益销售"`
  354. base.PageReq
  355. }
  356. // CensusSellerGroupInvoiceItem 销售组开票统计数据
  357. type CensusSellerGroupInvoiceItem struct {
  358. GroupId int `json:"group_id" description:"分组ID"`
  359. GroupName string `json:"group_name" description:"分组名称"`
  360. InvoiceAmount float64 `json:"invoice_amount" description:"开票金额"`
  361. GroupRate float64 `json:"group_rate" description:"分组占比"`
  362. }
  363. // GetCensusSellerGroupInvoicePageList 获取销售组开票统计列表-分页
  364. func GetCensusSellerGroupInvoicePageList(page base.IPage, condition, outCond string, pars []interface{}, amountSum float64) (results []*CensusSellerGroupInvoiceItem, err error) {
  365. tableName := `weekly_report.sys_group`
  366. if global.CONFIG.Serve.RunMode == "debug" {
  367. tableName = `test_v2_weekly_report.sys_group`
  368. }
  369. sql := `SELECT a.group_id, a.group_name, b.invoice_amount, b.group_rate FROM %s AS a LEFT JOIN `
  370. sql += ` (
  371. SELECT
  372. seller_group_id,
  373. seller_group_name,
  374. SUM(amount) AS invoice_amount,
  375. SUM(amount) / %f AS group_rate
  376. FROM
  377. contract_invoice
  378. WHERE
  379. %s
  380. GROUP BY
  381. seller_group_id
  382. ) AS b ON a.group_id = b.seller_group_id`
  383. sql += ` WHERE %s ORDER BY %s LIMIT %d,%d`
  384. sql = fmt.Sprintf(sql, tableName, amountSum, condition, outCond, page.GetOrderItemsString(), page.Offset(), page.GetPageSize())
  385. err = global.DEFAULT_MYSQL.Raw(sql, pars).Scan(&results).Error
  386. return
  387. }
  388. // CensusSellerInvoiceListReq 销售开票统计列表请求体
  389. type CensusSellerInvoiceListReq struct {
  390. GroupId int `json:"group_id" form:"group_id" description:"销售组别ID"`
  391. StartDate string `json:"start_date" form:"start_date" binding:"omitempty,datetime=2006-01-02" description:"开始日期"`
  392. EndDate string `json:"end_date" form:"end_date" binding:"omitempty,datetime=2006-01-02" description:"结束日期"`
  393. SortField int `json:"sort_field" form:"sort_field" description:"排序字段: 1-开票金额; 2-小组占比; 3-全员占比"`
  394. SortType int `json:"sort_type" form:"sort_type" description:"排序方式: 1-正序; 2-倒序"`
  395. IsExport int `json:"is_export" form:"is_export" description:"是否导出: 0-否; 1-是"`
  396. SellerType int `json:"seller_type" form:"seller_type" description:"销售类型:1ficc销售,2权益销售"`
  397. base.PageReq
  398. }
  399. // CensusSellerInvoiceItem 销售组开票统计数据
  400. type CensusSellerInvoiceItem struct {
  401. SellerId int `json:"seller_id" description:"销售ID"`
  402. SellerName string `json:"seller_name" description:"销售名称"`
  403. GroupId int `json:"group_id" description:"分组ID"`
  404. GroupName string `json:"group_name" description:"分组名称"`
  405. InvoiceAmount float64 `json:"invoice_amount" description:"开票金额"`
  406. GroupRate float64 `json:"group_rate" description:"分组占比"`
  407. SellerRate float64 `json:"seller_rate" description:"全员占比"`
  408. }
  409. // GetCensusSellerInvoicePageList 获取销售开票统计列表-分页
  410. func GetCensusSellerInvoicePageList(page base.IPage, condition, outCond string, pars []interface{}, amountSum float64) (results []*CensusSellerInvoiceItem, err error) {
  411. tableName := `weekly_report.admin`
  412. if global.CONFIG.Serve.RunMode == "debug" {
  413. tableName = `test_v2_weekly_report.admin`
  414. }
  415. sql := `SELECT a.admin_id AS seller_id, a.real_name AS seller_name, a.group_id, b.invoice_amount, b.group_rate, b.seller_rate FROM %s AS a LEFT JOIN `
  416. sql += ` (
  417. SELECT c.seller_id, c.seller_group_id, SUM(c.amount) AS invoice_amount,
  418. SUM(c.amount) / (
  419. SELECT SUM(amount) FROM contract_invoice WHERE seller_group_id = c.seller_group_id AND %s
  420. ) AS group_rate,
  421. SUM(c.amount) / %f AS seller_rate
  422. FROM contract_invoice AS c
  423. WHERE %s
  424. GROUP BY c.seller_id
  425. ) AS b ON a.admin_id = b.seller_id `
  426. sql += ` WHERE %s ORDER BY %s LIMIT %d,%d`
  427. sql = fmt.Sprintf(sql, tableName, condition, amountSum, condition, outCond, page.GetOrderItemsString(), page.Offset(), page.GetPageSize())
  428. err = global.DEFAULT_MYSQL.Raw(sql, pars...).Scan(&results).Error
  429. return
  430. }
  431. // InvoiceListRespData 开票/到款列表响应体
  432. type InvoiceListRespData struct {
  433. Page *base.Page `json:"page"`
  434. List interface{} `json:"list"`
  435. AmountTotal float64 `json:"amount_total"`
  436. CurrencyTotal []*InvoiceListCurrencyTotal `json:"currency_total"`
  437. }
  438. // InvoiceListCurrencyTotal 开票/到款列表分币种合计信息
  439. type InvoiceListCurrencyTotal struct {
  440. Name string `json:"name" description:"货币名称"`
  441. UnitName string `json:"unit_name" description:"单位名称"`
  442. Code string `json:"code" description:"国际代码"`
  443. Amount float64 `json:"amount" description:"金额"`
  444. FlagImg string `json:"flag_img" description:"国旗图标"`
  445. }
  446. // InvoiceListCurrencySum 开票/到款列表分币种总和
  447. type InvoiceListCurrencySum struct {
  448. CurrencyUnit string `json:"currency_unit" description:"货币代码"`
  449. InvoiceType int `json:"invoice_type" description:"开票类型:1-开票; 2-到款"`
  450. AmountTotal float64 `json:"amount_total" description:"换算后合计金额"`
  451. OriginAmountTotal float64 `json:"origin_amount_total" description:"原合计金额"`
  452. }
  453. // GetInvoiceListCurrencySum 获取开票/到款分货币合计
  454. func GetInvoiceListCurrencySum(condition string, pars []interface{}, groupRule string) (results []*InvoiceListCurrencySum, err error) {
  455. query := global.DEFAULT_MYSQL.Table("contract_invoice").
  456. Select("currency_unit, invoice_type, SUM(amount) AS amount_total, SUM(origin_amount) AS origin_amount_total").
  457. Where("is_deleted = 0").
  458. Where(condition, pars...).
  459. Group(groupRule)
  460. err = query.Find(&results).Error
  461. return
  462. }
  463. type ContractInvoiceRespItem struct {
  464. ContractInvoice
  465. CompanyName string `gorm:"column:company_name" json:"company_name" description:"客户名称"`
  466. }