bill.go 2.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124
  1. package api
  2. import (
  3. "box-cost/db/model"
  4. "box-cost/db/repo"
  5. "box-cost/log"
  6. "errors"
  7. "fmt"
  8. "time"
  9. "github.com/gin-gonic/gin"
  10. "go.mongodb.org/mongo-driver/bson"
  11. "go.mongodb.org/mongo-driver/bson/primitive"
  12. )
  13. // 单据管理
  14. func Bill(r *GinRouter) {
  15. // 创建单据
  16. r.POST("/bill", CreateBill)
  17. // 获取单据详情
  18. r.GET("/bill/:id", GetBill)
  19. // 获取单据列表
  20. r.GET("/bills", GetBills)
  21. // 更新单据
  22. r.POST("/bill/update", UpdateBill)
  23. // 删除单据
  24. r.POST("/bill/delete/:id", DelBill)
  25. }
  26. // 创建单据
  27. func CreateBill(c *gin.Context, apictx *ApiSession) (interface{}, error) {
  28. var bill model.Bill
  29. err := c.ShouldBindJSON(&bill)
  30. if err != nil {
  31. fmt.Println(err)
  32. return nil, errors.New("参数错误!")
  33. }
  34. ctx := apictx.CreateRepoCtx()
  35. if bill.PackId.Hex() == "" {
  36. return nil, errors.New("包装产品id为空")
  37. }
  38. if bill.PlanId.Hex() == "" {
  39. return nil, errors.New("生产计划id为空")
  40. }
  41. if bill.Type == "" {
  42. return nil, errors.New("类型为空")
  43. }
  44. bill.Status = "created"
  45. bill.CreateTime = time.Now()
  46. bill.UpdateTime = time.Now()
  47. result, err := repo.RepoAddDoc(ctx, repo.CollectionBill, &bill)
  48. return result, err
  49. }
  50. // 获取单据信息
  51. func GetBill(c *gin.Context, apictx *ApiSession) (interface{}, error) {
  52. billId := c.Param("id")
  53. id, err := primitive.ObjectIDFromHex(billId)
  54. if err != nil {
  55. return nil, errors.New("非法id")
  56. }
  57. var bill model.Bill
  58. option := &repo.DocSearchOptions{
  59. CollectName: repo.CollectionBill,
  60. Query: repo.Map{"_id": id},
  61. }
  62. found, err := repo.RepoSeachDoc(apictx.CreateRepoCtx(), option, &bill)
  63. if !found || err != nil {
  64. log.Info(err)
  65. return nil, errors.New("数据未找到")
  66. }
  67. return bill, nil
  68. }
  69. // 获取单据列表
  70. func GetBills(c *gin.Context, apictx *ApiSession) (interface{}, error) {
  71. page, size, query := UtilQueryPageSize(c)
  72. option := &repo.PageSearchOptions{
  73. CollectName: repo.CollectionBill,
  74. Query: query,
  75. Page: page,
  76. Size: size,
  77. Sort: bson.M{"createTime": -1},
  78. }
  79. return repo.RepoPageSearch(apictx.CreateRepoCtx(), option)
  80. }
  81. // 更新单据
  82. func UpdateBill(c *gin.Context, apictx *ApiSession) (interface{}, error) {
  83. var bill model.Bill
  84. err := c.ShouldBindJSON(&bill)
  85. if err != nil {
  86. return nil, errors.New("参数错误")
  87. }
  88. if bill.Id.Hex() == "" {
  89. return nil, errors.New("id的为空")
  90. }
  91. bill.UpdateTime = time.Now()
  92. return repo.RepoUpdateSetDoc(apictx.CreateRepoCtx(), repo.CollectionBill, bill.Id.Hex(), &bill)
  93. }
  94. // 删除单据
  95. func DelBill(c *gin.Context, apictx *ApiSession) (interface{}, error) {
  96. billId := c.Param("id")
  97. if billId == "" {
  98. return nil, errors.New("id为空")
  99. }
  100. return repo.RepoDeleteDoc(apictx.CreateRepoCtx(), repo.CollectionBill, billId)
  101. }