contract_service.go 8.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257
  1. /*
  2. * @description: 合同数据相关操作
  3. * @Author: CP
  4. * @Date: 2020-10-27 11:28:24
  5. * @FilePath: \construction_management\services\contract_service.go
  6. */
  7. package services
  8. import (
  9. "errors"
  10. "fmt"
  11. "log"
  12. "strconv"
  13. "time"
  14. "github.com/kataras/iris/v12"
  15. "go.mod/dao"
  16. "go.mod/datasource"
  17. "go.mod/models"
  18. "go.mod/web/viewmodels"
  19. )
  20. //定义项目用户Service接口
  21. type ContractService interface {
  22. ValidRuleDepth(ctx iris.Context) (*viewmodels.TreeSectionContract, error)
  23. ValidRuleTemplate(ctx iris.Context) (*viewmodels.TreeSectionContract, error)
  24. ValidRuleSectionAdd(ctx iris.Context) (*viewmodels.TreeSectionContract, error)
  25. ValidRuleSectionDelete(ctx iris.Context) (*viewmodels.TreeSectionContract, error)
  26. ValidRuleGet(ctx iris.Context) (*viewmodels.TreeSectionContract, error)
  27. ValidRuleSerial(ctx iris.Context) (*viewmodels.TreeSectionContract, error)
  28. ValidRuleContractAdd(ctx iris.Context) (*viewmodels.Contracts, error)
  29. Get(treeId int, bidsectionId int, projectId int) *viewmodels.TreeSectionContract
  30. GetSectionTreeContract(attribution string, bidsectionId int, projectId int) []*viewmodels.Contracts
  31. GetSecionTree(bidsectionId int, projectId int) *viewmodels.TreeSectionContract
  32. SetSection(templateNumber int, bidsectionId int, projectIdInt int) error
  33. SectionAdd(sectionData *viewmodels.TreeSectionContract, bidsectionId int, projectId int) error
  34. SectionSave(sectionData *viewmodels.TreeSectionContract, bidsectionId int, projectId int) error
  35. UpdateSerial(sectionData *viewmodels.TreeSectionContract, bidsectionId int, projectId int) error
  36. SectionDelete(treeId int, bidsectionId int, projectId int) error
  37. MoveDepth(sectionData *viewmodels.TreeSectionContract, bidsectionId int, projectId int) error
  38. MoveSerial(sectionData *viewmodels.TreeSectionContract, bidsectionId int, projectId int) error
  39. GetContract(contractId int) *models.CmContracts
  40. Add(contractData *viewmodels.Contracts, projectId int, bidsectionId int, treeId int) error
  41. }
  42. //返回service操作类
  43. type contractService struct {
  44. treeContractDao *dao.TreeContractDao
  45. contractDao *dao.ContractDao
  46. // dao *dao.ProjectAccountDao
  47. // projectDao *dao.ProjectDao
  48. // bidsectionDao *dao.BidsectionDao
  49. // bidAccountDao *dao.BidAccountDao
  50. }
  51. //创建项目用户service
  52. func NewContractService() ContractService {
  53. return &contractService{
  54. treeContractDao: dao.NewTreeContractDao(datasource.InstanceDbMaster()),
  55. contractDao: dao.NewContractDao(datasource.InstanceDbMaster()),
  56. // projectAccountDao: dao.NewProjectAccountDao(datasource.InstanceDbMaster()),
  57. // projectDao: dao.NewProjectDao(datasource.InstanceDbMaster()),
  58. // bidsectionDao: dao.NewBidsectionDao(datasource.InstanceDbMaster()),
  59. // bidAccountDao: dao.NewBidAccountDao(datasource.InstanceDbMaster()),
  60. }
  61. }
  62. // 升级降级规则验证
  63. func (s *contractService) ValidRuleDepth(ctx iris.Context) (*viewmodels.TreeSectionContract, error) {
  64. treeSectionVaild := &viewmodels.TreeSectionContract{}
  65. err := ctx.ReadJSON(treeSectionVaild)
  66. if err != nil {
  67. log.Println("folder-ValidRule-ReadForm转换异常, error=", err)
  68. return treeSectionVaild, err
  69. }
  70. err = treeSectionVaild.ValidateDepth()
  71. if err != nil {
  72. log.Println("参数验证错误, error=", err)
  73. return treeSectionVaild, err
  74. }
  75. return treeSectionVaild, nil
  76. }
  77. // 模板规则验证
  78. func (s *contractService) ValidRuleTemplate(ctx iris.Context) (*viewmodels.TreeSectionContract, error) {
  79. treeSectionVaild := &viewmodels.TreeSectionContract{}
  80. err := ctx.ReadJSON(treeSectionVaild)
  81. if err != nil {
  82. log.Println("folder-ValidRule-ReadForm转换异常, error=", err)
  83. return treeSectionVaild, err
  84. }
  85. err = treeSectionVaild.ValidateTemplate()
  86. if err != nil {
  87. log.Println("参数验证错误, error=", err)
  88. return treeSectionVaild, err
  89. }
  90. return treeSectionVaild, nil
  91. }
  92. // 模板规则新增项目节
  93. func (s *contractService) ValidRuleSectionAdd(ctx iris.Context) (*viewmodels.TreeSectionContract, error) {
  94. treeSectionVaild := &viewmodels.TreeSectionContract{}
  95. err := ctx.ReadJSON(treeSectionVaild)
  96. if err != nil {
  97. log.Println("folder-ValidRule-ReadForm转换异常, error=", err)
  98. return treeSectionVaild, err
  99. }
  100. err = treeSectionVaild.ValidateSectionAdd()
  101. if err != nil {
  102. log.Println("参数验证错误, error=", err)
  103. return treeSectionVaild, err
  104. }
  105. return treeSectionVaild, nil
  106. }
  107. // 模板规则新增项目节
  108. func (s *contractService) ValidRuleSectionDelete(ctx iris.Context) (*viewmodels.TreeSectionContract, error) {
  109. treeSectionVaild := &viewmodels.TreeSectionContract{}
  110. err := ctx.ReadForm(treeSectionVaild)
  111. if err != nil {
  112. log.Println("folder-ValidRule-ReadForm转换异常, error=", err)
  113. return treeSectionVaild, err
  114. }
  115. err = treeSectionVaild.ValidateSectionDelete()
  116. if err != nil {
  117. log.Println("参数验证错误, error=", err)
  118. return treeSectionVaild, err
  119. }
  120. return treeSectionVaild, nil
  121. }
  122. func (s *contractService) ValidRuleGet(ctx iris.Context) (*viewmodels.TreeSectionContract, error) {
  123. treeSectionVaild := &viewmodels.TreeSectionContract{}
  124. err := ctx.ReadForm(treeSectionVaild)
  125. if err != nil {
  126. log.Println("folder-ValidRule-ReadForm转换异常, error=", err)
  127. return treeSectionVaild, err
  128. }
  129. err = treeSectionVaild.ValidateSectionDelete()
  130. if err != nil {
  131. log.Println("参数验证错误, error=", err)
  132. return treeSectionVaild, err
  133. }
  134. return treeSectionVaild, nil
  135. }
  136. // 验证序号相关
  137. func (s *contractService) ValidRuleSerial(ctx iris.Context) (*viewmodels.TreeSectionContract, error) {
  138. treeSectionVaild := &viewmodels.TreeSectionContract{}
  139. err := ctx.ReadForm(treeSectionVaild)
  140. if err != nil {
  141. log.Println("folder-ValidRule-ReadForm转换异常, error=", err)
  142. return treeSectionVaild, err
  143. }
  144. err = treeSectionVaild.ValidateSectionSerial()
  145. if err != nil {
  146. log.Println("参数验证错误, error=", err)
  147. return treeSectionVaild, err
  148. }
  149. return treeSectionVaild, nil
  150. }
  151. // 新增合同参数验证
  152. func (s *contractService) ValidRuleContractAdd(ctx iris.Context) (*viewmodels.Contracts, error) {
  153. // 创建一个存放前端传过来参数
  154. contractsVaild := &viewmodels.Contracts{}
  155. // 存放raw的值,放入到contractsVaild
  156. err := ctx.ReadJSON(contractsVaild)
  157. if err != nil {
  158. log.Println("folder-ValidRule-ReadForm转换异常, error=", err)
  159. return contractsVaild, err
  160. }
  161. // 验证合同传参
  162. err = contractsVaild.ValidateAdd()
  163. if err != nil {
  164. log.Println("参数验证错误, error=", err)
  165. return contractsVaild, err
  166. }
  167. return contractsVaild, nil
  168. }
  169. // 获得项目节
  170. func (s *contractService) Get(treeId int, bidsectionId int, projectId int) *viewmodels.TreeSectionContract {
  171. // 1.获得项目节
  172. section := s.treeContractDao.Get(treeId, bidsectionId, projectId)
  173. // 2.构造数据
  174. sectionVM := s.makeSectionView(section)
  175. return sectionVM
  176. }
  177. // 获得合同详情
  178. func (s *contractService) GetContract(contractId int) *models.CmContracts {
  179. return s.contractDao.Get(contractId)
  180. }
  181. // 新增合同
  182. func (s *contractService) Add(contractData *viewmodels.Contracts, projectId int, bidsectionId int, treeId int) error {
  183. // 1. 项目节存在
  184. contracts := s.treeContractDao.Get(treeId, bidsectionId, projectId)
  185. if contracts.Id == 0 {
  186. return errors.New("未找到项目节")
  187. }
  188. // k := int32(projectId)
  189. // 2.项目节是没有合同
  190. if contracts.ContractId != 0 {
  191. return errors.New("该项目节上已经存在合同")
  192. }
  193. // 3.新增合同 --合计标段上的金额
  194. contractsCm := &models.CmContracts{}
  195. contractsCm.Code = contractData.Code
  196. contractsCm.Name = contractData.Name
  197. contractsCm.ContractsType = contractData.ContractsType
  198. contractsCm.Price = contractData.Price
  199. contractsCm.Returned = "0"
  200. contractsCm.Paid = "0"
  201. contractsCm.TreeId = treeId
  202. contractsCm.ProjectId = projectId
  203. contractsCm.BidsectionId = bidsectionId
  204. contractsCm.Status = 0
  205. contractsCm.CreateTime = time.Now()
  206. contractsCm.UpdateTime = time.Now()
  207. // 获得该标段下合同总数 - 总收入金额
  208. contractList := s.treeContractDao.GetContract(bidsectionId, projectId)
  209. priceTotal := 0.00
  210. for _, item := range contractList {
  211. contractPrice, _ := strconv.ParseFloat(item.ContractPrice, 64)
  212. priceTotal = priceTotal + contractPrice
  213. }
  214. // 合同总数
  215. contractTotal := len(contractList) + 1
  216. // 合同收入总金额
  217. price, _ := strconv.ParseFloat(contractsCm.Price, 64)
  218. priceTotal = priceTotal + price
  219. // 保留2位小数
  220. priceTotal, _ = strconv.ParseFloat(fmt.Sprintf("%.2f", priceTotal), 64)
  221. err := s.contractDao.Add(contractsCm, contractTotal, priceTotal)
  222. if err != nil {
  223. return err
  224. }
  225. return nil
  226. }