contract_paid_dao.go 4.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151
  1. /*
  2. * @description:已支付相关数据操作
  3. * @Author: CP
  4. * @Date: 2020-12-22 14:46:06
  5. * @FilePath: \construction_management\dao\contract_paid_dao.go
  6. */
  7. package dao
  8. import (
  9. "errors"
  10. "fmt"
  11. "strconv"
  12. "github.com/go-xorm/xorm"
  13. "go.mod/models"
  14. )
  15. //数据库操作引擎
  16. type ContractPaidDao struct {
  17. engine *xorm.Engine
  18. }
  19. //获得一个DAO对象
  20. func NewContractPaidDao(engine *xorm.Engine) *ContractPaidDao {
  21. return &ContractPaidDao{
  22. engine: engine,
  23. }
  24. }
  25. // 获得回款
  26. func (d *ContractPaidDao) Get(id int, contractsId int, bidsectionId int) *models.CmContractsPaid {
  27. data := &models.CmContractsPaid{Id: id, ContractsId: contractsId, BidsectionId: bidsectionId}
  28. ok, err := d.engine.Get(data)
  29. if ok && err == nil {
  30. return data
  31. } else {
  32. data.Id = 0
  33. return data
  34. }
  35. }
  36. func (d *ContractPaidDao) GetAll(projectId int, bidsectionId int, contractsId int) []models.CmContractsPaid {
  37. datalist := make([]models.CmContractsPaid, 0)
  38. err := d.engine.
  39. Where("project_id = ? and bidsection_id =? and contracts_id=?", projectId, bidsectionId, contractsId).
  40. Desc("id").
  41. Find(&datalist)
  42. if err != nil {
  43. return datalist
  44. } else {
  45. return datalist
  46. }
  47. }
  48. // 创建已支付
  49. func (d *ContractPaidDao) Add(contractsPaid *models.CmContractsPaid) error {
  50. _, err := d.engine.Insert(contractsPaid)
  51. return err
  52. }
  53. // 更新已支付
  54. func (d *ContractPaidDao) Update(contractsReturn *models.CmContractsPaid, contracts_id int, bidsectionId int) error {
  55. is, err := d.engine.Where("id = ? and contracts_id = ? and bidsection_id=? ", contractsReturn.Id, contracts_id, bidsectionId).Update(contractsReturn)
  56. if is == 0 {
  57. return errors.New("未找到已支付信息")
  58. }
  59. return err
  60. }
  61. // 删除回款
  62. func (d *ContractPaidDao) Delete(id int, contractsId int, bidsectionId int, projectId int) error {
  63. data := &models.CmContractsPaid{}
  64. is, err := d.engine.Where("id = ? and contracts_id = ? and project_id =? and bidsection_id = ? ", id, contractsId, projectId, bidsectionId).Delete(data)
  65. if is == 0 {
  66. return errors.New("未找到已支付信息")
  67. }
  68. return err
  69. }
  70. // 更新已支付总金额
  71. func (d *ContractPaidDao) UpdatePaidTotalPrice(projectId int, bidsectionId int, contractsId int) error {
  72. session := d.engine.NewSession()
  73. defer session.Close()
  74. err := session.Begin()
  75. if err != nil {
  76. return errors.New("session出错-db")
  77. }
  78. // 0.获得合同金额
  79. contractsDetail := &models.CmContracts{}
  80. _, err = d.engine.Where(" id = ? ", contractsId).Get(contractsDetail)
  81. if err != nil {
  82. return errors.New("未找到合同")
  83. }
  84. // 1.获得合同支付总金额
  85. datalist := make([]models.CmContractsPaid, 0)
  86. err = d.engine.Where(" project_id =? and bidsection_id = ? ", projectId, bidsectionId).Find(&datalist)
  87. if err != nil {
  88. session.Rollback()
  89. return errors.New("编辑合同出错-项目节更新失败")
  90. }
  91. priceTotal := 0.00
  92. contractsPrice := 0.00
  93. for _, item := range datalist {
  94. price, _ := strconv.ParseFloat(item.Price, 64)
  95. priceTotal = priceTotal + price
  96. if item.ContractsId == contractsId {
  97. contractsPrice = contractsPrice + price
  98. }
  99. }
  100. priceTotal, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", priceTotal), 64)
  101. contractsPrice, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", contractsPrice), 64)
  102. // 1-1合同状态的判定
  103. contractsDetailPrice, _ := strconv.ParseFloat(contractsDetail.Price, 64)
  104. // 总回款大于等于合同金额 待关闭
  105. contractStatus := 0
  106. if contractsPrice >= contractsDetailPrice {
  107. contractStatus = 1
  108. }
  109. // 2.更新合同表 合同下回款总金额
  110. _, err = session.Exec("UPDATE cm_contracts SET `paid` = ? , status = ? where id = ? ", contractsPrice, contractStatus, contractsId)
  111. if err != nil {
  112. session.Rollback()
  113. return errors.New("金额更新失败")
  114. }
  115. // 3.更新项目节 合同下回款总金额
  116. _, err = session.Exec("UPDATE cm_tree_contracts SET `contracts_paid` = ? , contract_status = ? where project_id = ? and bidsection_id=? and contract_id=? ",
  117. contractsPrice, contractStatus, projectId, bidsectionId, contractsId)
  118. if err != nil {
  119. session.Rollback()
  120. return errors.New("金额更新失败")
  121. }
  122. // 4.更新标段树 整个标段下回款总金额
  123. _, err = session.Exec("UPDATE cm_tree SET `contracts_paid` = ? where project_id = ? and bidsection_id=? ", priceTotal, projectId, bidsectionId)
  124. if err != nil {
  125. session.Rollback()
  126. return errors.New("金额更新失败")
  127. }
  128. err = session.Commit()
  129. if err != nil {
  130. session.Rollback()
  131. return errors.New("session出错-db")
  132. }
  133. return nil
  134. }