box-cost/boxcost/api/bill.go

package api

import (
	"box-cost/db/model"
	"box-cost/db/repo"
	"box-cost/log"
	"errors"
	"fmt"
	"time"

	"github.com/gin-gonic/gin"
	"go.mongodb.org/mongo-driver/bson"
	"go.mongodb.org/mongo-driver/bson/primitive"
)

// 单据管理
func Bill(r *GinRouter) {

	// 创建单据
	r.POST("/bill/purchase/create", CreateBill)

	// 获取单据详情
	r.GET("/bill/purchase/detail/:id", GetBill)

	// 获取单据列表
	r.GET("/bill/purchase/list", GetBills)

	// 更新单据
	r.POST("/bill/purchase/update", UpdateBill)

	// 删除单据
	r.POST("/bill/purchase/delete/:id", DelBill)
}

type MatBillReq struct {
	Bill      *model.PurchaseBill
	CompIndex *int
	MatIndex  *int
	//MatKey    string //components.0.mats.0.billId
}

// 创建单据
func CreateBill(c *gin.Context, apictx *ApiSession) (interface{}, error) {

	req := &MatBillReq{}
	err := c.ShouldBindJSON(req)
	if err != nil || req.Bill == nil || req.CompIndex == nil || req.MatIndex == nil {
		fmt.Println(err)
		return nil, errors.New("参数错误！compIndex, matIndex 不能为空")
	}
	ctx := apictx.CreateRepoCtx()
	bill := req.Bill

	if bill.PackId.Hex() == "" {
		return nil, errors.New("包装产品id为空")
	}
	if bill.PlanId.Hex() == "" {
		return nil, errors.New("生产计划id为空")
	}
	if bill.Type == "" {
		return nil, errors.New("类型为空")
	}

	bill.Status = "created"
	bill.CreateTime = time.Now()
	bill.UpdateTime = time.Now()

	result, err := repo.RepoAddDoc(ctx, repo.CollectionBillPurchase, &bill)
	if err != nil {
		return nil, err
	}

	updat := bson.M{}
	matkey := fmt.Sprintf("pack.components.%d.mats.%d.billId", *req.CompIndex, *req.MatIndex)
	updat[matkey] = result
	ret, err := repo.RepoUpdateSetDocProps(apictx.CreateRepoCtx(), repo.CollectionProductPlan, bill.PlanId.Hex(), bson.M{"$set": updat})
	if ret.ModifiedCount == 1 && err == nil {
		return result, nil
	}
	return nil, fmt.Errorf("创建失败")
}

// 获取单据信息
func GetBill(c *gin.Context, apictx *ApiSession) (interface{}, error) {
	billId := c.Param("id")
	id, err := primitive.ObjectIDFromHex(billId)
	if err != nil {
		return nil, errors.New("非法id")
	}
	var bill model.PurchaseBill
	option := &repo.DocSearchOptions{
		CollectName: repo.CollectionBillPurchase,
		Query:       repo.Map{"_id": id},
	}
	found, err := repo.RepoSeachDoc(apictx.CreateRepoCtx(), option, &bill)
	if !found || err != nil {
		log.Info(err)
		return nil, errors.New("数据未找到")
	}

	return bill, nil
}

// 获取单据列表
func GetBills(c *gin.Context, apictx *ApiSession) (interface{}, error) {

	page, size, query := UtilQueryPageSize(c)

	if query["packId"] != nil {
		query["packId"], _ = primitive.ObjectIDFromHex(query["packId"].(string))
	}
	if query["planId"] != nil {
		query["planId"], _ = primitive.ObjectIDFromHex(query["planId"].(string))
	}

	option := &repo.PageSearchOptions{
		CollectName: repo.CollectionBillPurchase,
		Query:       query,
		Page:        page,
		Size:        size,
		Sort:        bson.M{"createTime": -1},
	}
	return repo.RepoPageSearch(apictx.CreateRepoCtx(), option)
}

// 更新单据
func UpdateBill(c *gin.Context, apictx *ApiSession) (interface{}, error) {
	var bill model.PurchaseBill
	err := c.ShouldBindJSON(&bill)
	if err != nil {
		return nil, errors.New("参数错误")
	}
	if bill.Id.Hex() == "" {
		return nil, errors.New("id的为空")
	}
	bill.UpdateTime = time.Now()
	return repo.RepoUpdateSetDoc(apictx.CreateRepoCtx(), repo.CollectionBillPurchase, bill.Id.Hex(), &bill)
}

// 删除单据
func DelBill(c *gin.Context, apictx *ApiSession) (interface{}, error) {
	billId := c.Param("id")
	if billId == "" {
		return nil, errors.New("id为空")
	}

	return repo.RepoDeleteDoc(apictx.CreateRepoCtx(), repo.CollectionBillPurchase, billId)
}