contract_paid_dao.go 4.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155
  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. _, err := d.engine.Where("id = ? and contracts_id = ? and bidsection_id=? ", contractsReturn.Id, contracts_id, bidsectionId).Update(contractsReturn)
  56. return err
  57. }
  58. // 删除回款
  59. func (d *ContractPaidDao) Delete(id int, contractsId int, bidsectionId int, projectId int) error {
  60. data := &models.CmContractsPaid{}
  61. _, err := d.engine.Where("id = ? and contracts_id = ? and project_id =? and bidsection_id = ? ", id, contractsId, projectId, bidsectionId).Delete(data)
  62. return err
  63. }
  64. // 更新已支付总金额
  65. func (d *ContractPaidDao) UpdatePaidTotalPrice(projectId int, bidsectionId int, contractsId int) error {
  66. session := d.engine.NewSession()
  67. defer session.Close()
  68. err := session.Begin()
  69. if err != nil {
  70. return errors.New("session出错-db")
  71. }
  72. // 0.获得合同金额
  73. contractsDetail := &models.CmContracts{}
  74. _, err = d.engine.Where(" id = ? ", contractsId).Get(contractsDetail)
  75. if err != nil {
  76. return errors.New("未找到合同")
  77. }
  78. // 1.获得合同支付总金额
  79. datalist := make([]models.CmContractsPaid, 0)
  80. err = d.engine.Where(" project_id =? and bidsection_id = ? ", projectId, bidsectionId).Find(&datalist)
  81. if err != nil {
  82. session.Rollback()
  83. return errors.New("编辑合同出错-项目节更新失败")
  84. }
  85. priceTotal := 0.00
  86. contractsPrice := 0.00
  87. for _, item := range datalist {
  88. price, _ := strconv.ParseFloat(item.Price, 64)
  89. priceTotal = priceTotal + price
  90. if item.ContractsId == contractsId {
  91. contractsPrice = contractsPrice + price
  92. }
  93. }
  94. priceTotal, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", priceTotal), 64)
  95. contractsPrice, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", contractsPrice), 64)
  96. // 1-1合同状态的判定
  97. contractsDetailPrice, _ := strconv.ParseFloat(contractsDetail.Price, 64)
  98. // 总回款大于等于合同金额 待关闭
  99. contractStatus := 0
  100. if contractsPrice >= contractsDetailPrice {
  101. contractStatus = 1
  102. }
  103. // 2.更新合同表 合同下回款总金额
  104. _, err = session.Exec("UPDATE cm_contracts SET `paid` = ? , status = ?,locking=0 where id = ? ", contractsPrice, contractStatus, contractsId)
  105. if err != nil {
  106. session.Rollback()
  107. return errors.New("金额更新失败")
  108. }
  109. // 3.更新项目节 合同下回款总金额
  110. _, err = session.Exec("UPDATE cm_tree_contracts SET `contracts_paid` = ? , contract_status = ?,contract_locking=0 where project_id = ? and bidsection_id=? and contract_id=? ",
  111. contractsPrice, contractStatus, projectId, bidsectionId, contractsId)
  112. if err != nil {
  113. session.Rollback()
  114. return errors.New("金额更新失败")
  115. }
  116. // 4.更新标段树 整个标段下回款总金额
  117. _, err = session.Exec("UPDATE cm_tree SET `contracts_paid` = ? where project_id = ? and bidsection_id=? ", priceTotal, projectId, bidsectionId)
  118. if err != nil {
  119. session.Rollback()
  120. return errors.New("金额更新失败")
  121. }
  122. err = session.Commit()
  123. if err != nil {
  124. session.Rollback()
  125. return errors.New("session出错-db")
  126. }
  127. return nil
  128. }
  129. // 筛选出应用了当前规则的条数
  130. func (d *ContractPaidDao) CountPaidRuleCode(bid int) (int64, error) {
  131. data := &models.CmContractsPaid{}
  132. total, err := d.engine.Where("`bidsection_id` = ?", bid).Count(data)
  133. if err != nil {
  134. total = 0
  135. }
  136. return total, err
  137. }