projectMonthFee.go 2.3 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556
  1. package dao
  2. import (
  3. "gorm.io/gorm"
  4. "server/global"
  5. )
  6. type ProjectMonthFee struct {
  7. global.GVA_MODEL
  8. ProjectCode string `json:"projectCode" form:"projectCode" gorm:"comment:项目编码"`
  9. Project Project `json:"project" form:"project" gorm:"foreignKey:ProjectCode;references:code;"`
  10. Genre int `json:"genre" form:"genre" gorm:"comment:费用类型Id"`
  11. ProjectFeeGenre ProjectFeeGenre `json:"projectFeeGenre" form:"projectFeeGenre" gorm:"foreignKey:Genre;references:id;"`
  12. TotalDeposit float64 `json:"totalDeposit" form:"totalDeposit" gorm:"comment:总支入;type:double(10,2)"`
  13. TotalExpenditure float64 `json:"totalExpenditure" form:"totalExpenditure" gorm:"comment:总支出;type:double(10,2)"`
  14. SettlementMonth string `json:"settlementMonth" form:"settlementMonth" gorm:"comment:结算月份"`
  15. }
  16. func (ProjectMonthFee) TableName() string {
  17. return "project_month_fee"
  18. }
  19. func QueryProjectMonthFee(monthTime, yearTime, code string) (monthFees []ProjectMonthFee, err error) {
  20. db := global.GVA_DB.Model(&ProjectMonthFee{}).Select("genre, SUM(total_deposit) AS total_deposit, SUM(total_expenditure) AS total_expenditure")
  21. if monthTime != "" {
  22. db = db.Where("DATE_FORMAT(CONCAT(settlement_month, '-01'), '%Y-%m') = ?", monthTime)
  23. }
  24. if yearTime != "" {
  25. db = db.Where("DATE_FORMAT(CONCAT(settlement_month, '-01'), '%Y') = ?", yearTime)
  26. }
  27. if code != "" {
  28. db = db.Where("project_code =?", code)
  29. }
  30. err = db.Group("genre").Preload("ProjectFeeGenre").Preload("Project").Find(&monthFees).Error
  31. return monthFees, err
  32. }
  33. func CreateProjectMonthFee() error {
  34. return global.GVA_DB.Transaction(func(tx *gorm.DB) error {
  35. tx = tx.Debug()
  36. txErr := tx.Session(&gorm.Session{AllowGlobalUpdate: true}).Unscoped().Delete(&ProjectMonthFee{}).Error
  37. if txErr != nil {
  38. return txErr
  39. }
  40. var fees []ProjectMonthFee
  41. txErr = tx.Raw(`SELECT DATE_FORMAT(fee_time, '%Y-%m') AS settlement_month,genre, project_code, SUM(deposit_amount) AS total_deposit, SUM(expenditure_amount) AS total_expenditure FROM project_fee GROUP BY DATE_FORMAT(fee_time, '%Y-%m'),genre,project_code`).Scan(&fees).Error
  42. if txErr != nil {
  43. return txErr
  44. }
  45. txErr = tx.Model(&ProjectMonthFee{}).Create(&fees).Error
  46. if txErr != nil {
  47. return txErr
  48. }
  49. return txErr
  50. })
  51. }