1、新增采购换机相关接口；

app/admin/apis/purchasemanage/purchase_change.go

@@ -0,0 +1,363 @@
+package purchasemanage
+
+import (
+	"errors"
+	"github.com/gin-gonic/gin"
+	model "go-admin/app/admin/models"
+	orm "go-admin/common/global"
+	"go-admin/logger"
+	"go-admin/tools"
+	"go-admin/tools/app"
+	"net/http"
+	"time"
+)
+
+// ErpPurchaseChangeCreate 采购换机-新增
+// @Summary 采购换机-新增
+// @Tags 采购换机, V1.4.5
+// @Produce json
+// @Accept json
+// @Param request body models.ErpPurchaseChangeCreateReq true "采购换机-新增模型"
+// @Success 200 {object} models.ErpPurchaseChangeOrder
+// @Router /api/v1/erp_purchase/change/create [post]
+func ErpPurchaseChangeCreate(c *gin.Context) {
+	req := new(model.ErpPurchaseChangeCreateReq)
+	if err := c.ShouldBindJSON(&req); err != nil {
+		logger.Error("ShouldBindJSON err:", logger.Field("err", err))
+		app.Error(c, http.StatusBadRequest, errors.New("para err"), "参数错误"+err.Error())
+		return
+	}
+	sysUser, err := model.GetSysUserByCtx(c)
+	if err != nil {
+		logger.Error("sys user err:", logger.Field("err", err))
+		app.Error(c, http.StatusInternalServerError, err, "操作失败")
+		return
+	}
+
+	// 检验参数
+	err = model.CheckCreateErpPurchaseChangeOrderParam(req)
+	if err != nil {
+		logger.Error("CheckCreateErpPurchaseOrderParam err:", logger.Field("err", err))
+		app.Error(c, http.StatusInternalServerError, err, err.Error())
+		return
+	}
+
+	if len(req.Commodities) == 0 {
+		logger.Error("erp purchase change commodities is nil")
+		app.Error(c, http.StatusInternalServerError, err, "操作失败")
+		return
+	}
+
+	// 校验入参门店是否包含在用户所有门店中，是否过期
+	if !(tools.GetRoleName(c) == "admin" || tools.GetRoleName(c) == "系统管理员") {
+		if !model.CheckUserStore(req.StoreId, sysUser) {
+			app.Error(c, http.StatusInternalServerError, errors.New("操作失败：您没有该门店权限"), "操作失败：您没有该门店权限")
+			return
+		}
+	}
+
+	purchaseOrder, err := model.CreateErpPurchaseChangeOrder(req, sysUser)
+	if err != nil {
+		logger.Error("CreateErpPurchaseOrder err:", logger.Field("err", err))
+		app.Error(c, http.StatusInternalServerError, err, "新增失败:"+err.Error())
+		return
+	}
+
+	purchaseOrder.Commodities = req.Commodities
+
+	app.OK(c, purchaseOrder, "")
+	return
+}
+
+// ErpPurchaseChangeEdit 采购换机-编辑
+// @Summary 采购换机-编辑
+// @Tags 采购换机, V1.4.5
+// @Produce json
+// @Accept json
+// @Param request body models.ErpPurchaseChangeEditReq true "采购换机-编辑模型"
+// @Success 200 {object} models.ErpPurchaseChangeEditResp
+// @Router /api/v1/erp_purchase/change/edit [post]
+func ErpPurchaseChangeEdit(c *gin.Context) {
+	req := new(model.ErpPurchaseChangeEditReq)
+	if err := c.ShouldBindJSON(&req); err != nil {
+		logger.Error("ShouldBindJSON err:", logger.Field("err", err))
+		app.Error(c, http.StatusBadRequest, errors.New("para err"), "参数错误"+err.Error())
+		return
+	}
+
+	sysUser, err := model.GetSysUserByCtx(c)
+	if err != nil {
+		logger.Error("sys user err:", logger.Field("err", err))
+		app.Error(c, http.StatusInternalServerError, err, "操作失败")
+		return
+	}
+
+	// 检验参数
+	err = model.CheckEditErpPurchaseChangeOrderParam(req)
+	if err != nil {
+		logger.Error("CheckEditErpPurchaseChangeOrderParam err:", logger.Field("err", err))
+		app.Error(c, http.StatusInternalServerError, err, err.Error())
+		return
+	}
+
+	if len(req.Commodities) == 0 {
+		logger.Error("erp purchase change commodities is nil")
+		app.Error(c, http.StatusInternalServerError, err, "操作失败")
+		return
+	}
+
+	// 校验入参门店是否包含在用户所有门店中，是否过期
+	if !(tools.GetRoleName(c) == "admin" || tools.GetRoleName(c) == "系统管理员") {
+		if !model.CheckUserStore(req.StoreId, sysUser) {
+			app.Error(c, http.StatusInternalServerError, errors.New("操作失败：您没有该门店权限"), "操作失败：您没有该门店权限")
+			return
+		}
+	}
+
+	// 更新订单信息
+	purchaseOrder, err := model.EditErpPurchaseChangeOrder(req, sysUser)
+	if err != nil {
+		logger.Error("EditErpPurchaseChangeOrder err:", logger.Field("err", err))
+		app.Error(c, http.StatusInternalServerError, err, "编辑失败:"+err.Error())
+		return
+	}
+
+	purchaseOrder.Commodities = req.Commodities
+	app.OK(c, purchaseOrder, "")
+	return
+}
+
+// ErpPurchaseChangeList 采购换机列表
+// @Summary 采购换机列表
+// @Tags 采购换机, V1.4.5
+// @Produce json
+// @Accept json
+// @Param request body models.ErpPurchaseChangeOrderListReq true "采购换机列表模型"
+// @Success 200 {object} models.ErpPurchaseChangeListResp
+// @Router /api/v1/erp_purchase/change/list [post]
+func ErpPurchaseChangeList(c *gin.Context) {
+	req := &model.ErpPurchaseChangeOrderListReq{}
+	if err := c.ShouldBindJSON(&req); err != nil {
+		logger.Error("ShouldBindJSON err:", logger.Field("err", err))
+		app.Error(c, http.StatusBadRequest, errors.New("para err"), "参数错误")
+		return
+	}
+
+	resp, err := req.List(c)
+	if err != nil {
+		logger.Error("ErpPurchaseChangeList err:", logger.Field("err", err))
+		app.Error(c, http.StatusInternalServerError, err, "获取失败"+err.Error())
+		return
+	}
+
+	app.OK(c, resp, "")
+	return
+}
+
+// ErpPurchaseChangeDelete 采购换机-删除
+// @Summary 采购换机-删除
+// @Tags 采购换机, V1.4.5
+// @Produce json
+// @Accept json
+// @Param request body models.ErpPurchaseChangeDeleteReq true "采购换机-删除模型"
+// @Success 200 {object} app.Response
+// @Router /api/v1/erp_purchase/change/delete [post]
+func ErpPurchaseChangeDelete(c *gin.Context) {
+	var req = new(model.ErpPurchaseChangeDeleteReq)
+	if err := c.ShouldBindJSON(&req); err != nil {
+		logger.Error("ShouldBindJSON err:", logger.Field("err", err))
+		app.Error(c, http.StatusBadRequest, err, "参数错误:"+err.Error())
+		return
+	}
+
+	err := tools.Validate(req) //必填参数校验
+	if err != nil {
+		app.Error(c, http.StatusBadRequest, err, err.Error())
+		return
+	}
+
+	sysUser, err := model.GetSysUserByCtx(c)
+	if err != nil {
+		logger.Error("sys user err:", logger.Field("err", err))
+		app.Error(c, http.StatusInternalServerError, err, "操作失败")
+		return
+	}
+
+	var erpPurchaseChangeOrder model.ErpPurchaseChangeOrder
+	err = orm.Eloquent.Table("erp_purchase_change_order").Where("serial_number = ?", req.SerialNumber).Find(&erpPurchaseChangeOrder).Error
+	if err != nil {
+		logger.Error("order err:", logger.Field("err", err))
+		app.Error(c, http.StatusInternalServerError, err, "删除失败:"+err.Error())
+		return
+	}
+
+	// 校验入参门店是否包含在用户所有门店中，是否过期
+	if !(tools.GetRoleName(c) == "admin" || tools.GetRoleName(c) == "系统管理员") {
+		if !model.CheckUserStore(erpPurchaseChangeOrder.StoreId, sysUser) {
+			app.Error(c, http.StatusInternalServerError, errors.New("操作失败：您没有该门店权限"), "操作失败：您没有该门店权限")
+			return
+		}
+	}
+
+	if erpPurchaseChangeOrder.SerialNumber == "" {
+		logger.Error("order is null")
+		app.Error(c, http.StatusInternalServerError, err, "删除失败:订单不存在")
+		return
+	}
+
+	// 仅待审核订单可删除
+	if erpPurchaseChangeOrder.State != model.ErpPurchaseChangeOrderUnAudit {
+		logger.Error("order err, erpPurchaseChangeOrder.State is:", logger.Field("erpPurchaseChangeOrder.State", erpPurchaseChangeOrder.State))
+		app.Error(c, http.StatusInternalServerError, err, "删除失败:仅待审核订单可删除")
+		return
+	}
+
+	begin := orm.Eloquent.Begin()
+	// 1-删除采购订单表
+	err = begin.Delete(erpPurchaseChangeOrder).Error
+	if err != nil {
+		logger.Error("order delete1 err:", logger.Field("err", err))
+		app.Error(c, http.StatusInternalServerError, err, "删除失败:"+err.Error())
+		return
+	}
+
+	// 2-删除采购订单商品表
+	var commodities []model.ErpPurchaseChangeCommodity
+	err = orm.Eloquent.Table("erp_purchase_change_commodity").Where("change_order_id = ?", erpPurchaseChangeOrder.ID).Find(&commodities).Error
+	if err != nil {
+		logger.Error("query erp_purchase_change_commodity err:", logger.Field("err", err))
+		app.Error(c, http.StatusInternalServerError, err, "删除失败:"+err.Error())
+		return
+	}
+
+	if len(commodities) != 0 {
+		err = begin.Delete(&commodities).Error
+		if err != nil {
+			logger.Error("更新商品订单信息-删除 error")
+			app.Error(c, http.StatusInternalServerError, err, "删除失败:"+err.Error())
+			return
+		}
+	}
+
+	err = begin.Commit().Error
+	if err != nil {
+		begin.Rollback()
+		logger.Error("commit err:", logger.Field("err", err))
+		return
+	}
+
+	app.OK(c, nil, "删除成功")
+	return
+}
+
+// ErpPurchaseChangeAudit 采购换机-审核
+// @Summary 采购换机-审核
+// @Tags 采购换机, V1.4.5
+// @Produce json
+// @Accept json
+// @Param request body models.ErpPurchaseChangeAuditReq true "采购换机-审核模型"
+// @Success 200 {object} app.Response
+// @Router /api/v1/erp_purchase/change/audit [post]
+func ErpPurchaseChangeAudit(c *gin.Context) {
+	var req = new(model.ErpPurchaseChangeAuditReq)
+	if err := c.ShouldBindJSON(&req); err != nil {
+		logger.Error("ShouldBindJSON err:", logger.Field("err", err))
+		app.Error(c, http.StatusBadRequest, err, "参数错误:"+err.Error())
+		return
+	}
+
+	err := tools.Validate(req) //必填参数校验
+	if err != nil {
+		app.Error(c, http.StatusBadRequest, err, err.Error())
+		return
+	}
+
+	sysUser, err := model.GetSysUserByCtx(c)
+	if err != nil {
+		logger.Error("sys user err:", logger.Field("err", err))
+		app.Error(c, http.StatusInternalServerError, err, "操作失败")
+		return
+	}
+
+	var erpPurchaseChangeOrder model.ErpPurchaseChangeOrder
+	err = orm.Eloquent.Table("erp_purchase_change_order").Where("serial_number = ?", req.SerialNumber).
+		Find(&erpPurchaseChangeOrder).Error
+	if err != nil {
+		logger.Error("order err:", logger.Field("err", err))
+		app.Error(c, http.StatusInternalServerError, err, "审核失败:"+err.Error())
+		return
+	}
+
+	// 校验入参门店是否包含在用户所有门店中，是否过期
+	if !(tools.GetRoleName(c) == "admin" || tools.GetRoleName(c) == "系统管理员") {
+		if !model.CheckUserStore(erpPurchaseChangeOrder.StoreId, sysUser) {
+			app.Error(c, http.StatusInternalServerError, errors.New("操作失败：您没有该门店权限"),
+				"操作失败：您没有该门店权限")
+			return
+		}
+	}
+
+	begin := orm.Eloquent.Begin()
+	// 判断入参state：1-审核，2-取消审核
+	orderState := 0
+	switch req.State {
+	case 1: // 1-审核：待审核状态可以审核
+		if erpPurchaseChangeOrder.State == model.ErpPurchaseChangeOrderUnAudit {
+			orderState = model.ErpPurchaseChangeOrderFinished
+		} else {
+			app.OK(c, nil, "订单已审核")
+			return
+		}
+	case 2: // 2-取消审核：取消后对应的退库或入库
+		if erpPurchaseChangeOrder.State == model.ErpPurchaseChangeOrderUnAudit {
+			app.OK(c, nil, "订单已取消审核")
+			return
+		}
+		if model.IsMonthEndClosed(*erpPurchaseChangeOrder.AuditTime) {
+			app.Error(c, http.StatusInternalServerError, errors.New("反审核失败，财务已月结"),
+				"反审核失败，财务已月结")
+			return
+		}
+
+		orderState = model.ErpPurchaseChangeOrderUnAudit
+	default:
+		logger.Error("order err, req.State is:", logger.Field("req.State", req.State))
+		app.Error(c, http.StatusInternalServerError, err, "审核失败:参数有误")
+		return
+	}
+
+	// 更新库存信息
+	// 审核：旧机器出库、新机器入库
+	// 反审核：旧机器入库、新机器出库
+	err = model.AuditChangeOrder(begin, erpPurchaseChangeOrder, orderState)
+	if err != nil {
+		begin.Rollback()
+		app.Error(c, http.StatusInternalServerError, err, "审核失败:"+err.Error())
+		return
+	}
+
+	err = begin.Table("erp_purchase_change_order").Where("id = ?", erpPurchaseChangeOrder.ID).
+		Updates(map[string]interface{}{
+			"state":        orderState,
+			"auditor_id":   sysUser.UserId,
+			"audit_time":   time.Now(),
+			"auditor_name": sysUser.NickName,
+		}).Error
+	if err != nil {
+		begin.Rollback()
+		logger.Error("update erp_purchase_change_order err:", logger.Field("err", err))
+		app.Error(c, http.StatusInternalServerError, err, "审核失败:"+err.Error())
+		return
+	}
+
+	err = begin.Commit().Error
+	if err != nil {
+		begin.Rollback()
+		logger.Errorf("commit err:", err)
+		app.Error(c, http.StatusInternalServerError, err, "审核失败")
+		return
+	}
+
+	app.OK(c, nil, "操作成功")
+	return
+}

app/admin/models/commodity.go

@@ -37,6 +37,7 @@ const (
 	CheckOut       = 6 // 盘点出库
 	OnSale         = 7 // 销售锁定中
 	PurchaseCancel = 8 // 采购订单反审核
+	PurchaseChange = 9 // 采购换机
 )
 
 // ErpStock 库存列表

app/admin/models/purchase.go

@@ -34,6 +34,9 @@ const (
 
 	ErpDemandStateWait   = 1 // 待采购
 	ErpDemandStateFinish = 2 // 完成采购
+
+	ErpPurchaseChangeOrderUnAudit  = 1 // 采购换机-待审核
+	ErpPurchaseChangeOrderFinished = 2 // 采购换机-已完成
 )
 
 // ErpPurchaseOrder 采购订单表

app/admin/models/purchase_change.go

@@ -0,0 +1,582 @@
+package models
+
+import (
+	"errors"
+	"fmt"
+	"github.com/gin-gonic/gin"
+	orm "go-admin/common/global"
+	"go-admin/logger"
+	"go-admin/tools"
+	"gorm.io/gorm"
+	"math/rand"
+	"time"
+)
+
+// ErpPurchaseChangeOrder 采购换机订单表
+type ErpPurchaseChangeOrder struct {
+	Model
+	SerialNumber    string                       `json:"serial_number" gorm:"index"`   // 单据编号
+	StoreId         uint32                       `json:"store_id" gorm:"index"`        // 门店id
+	StoreName       string                       `json:"store_name"`                   // 门店名称
+	ErpSupplierId   uint32                       `json:"erp_supplier_id" gorm:"index"` // 供应商id
+	ErpSupplierName string                       `json:"erp_supplier_name"`            // 供应商名称
+	MakerTime       *time.Time                   `json:"maker_time"`                   // 制单时间
+	MakerId         uint32                       `json:"maker_id" gorm:"index"`        // 制单人id
+	MakerName       string                       `json:"maker_name"`                   // 制单人名称
+	AuditTime       *time.Time                   `json:"audit_time"`                   // 审核时间
+	AuditorId       uint32                       `json:"auditor_id" gorm:"index"`      // 审核人id
+	AuditorName     string                       `json:"auditor_name"`                 // 审核人名称
+	State           uint32                       `json:"state"`                        // 1-待审核 2-已完成
+	Remark          string                       `json:"remark"`                       // 备注
+	Commodities     []ErpPurchaseChangeCommodity `json:"commodities" gorm:"-"`         // 采购换机商品信息
+}
+
+// ErpPurchaseChangeCommodity 采购换机订单商品表
+type ErpPurchaseChangeCommodity struct {
+	Model
+	ChangeOrderId         uint32 `json:"change_order_id" gorm:"index"`         // 采购换机订单id
+	ErpCommodityId        uint32 `json:"erp_commodity_id" gorm:"index"`        // 商品id
+	ErpCommodityName      string `json:"erp_commodity_name"`                   // 商品名称
+	CommoditySerialNumber string `json:"commodity_serial_number" gorm:"index"` // 商品编号
+	IMEIType              uint32 `json:"imei_type"`                            // 1-无串码 2-串码
+	OriginIMEI            string `json:"origin_imei"`                          // 原机身串码
+	NewIMEI               string `json:"new_imei"`                             // 新机身串码
+	Count                 uint32 `json:"count"`                                // 数量
+	OriginColor           string `json:"origin_color"`                         // 原机身颜色
+	NewColor              string `json:"new_color"`                            // 新机身颜色
+	Remark                string `json:"remark"`                               // 备注
+}
+
+// ErpPurchaseChangeCreateReq 新建采购换机订单入参
+type ErpPurchaseChangeCreateReq struct {
+	StoreId       uint32                       `json:"store_id"`                       // 门店id:入库必传
+	ErpSupplierId uint32                       `json:"erp_supplier_id"`                // 供应商id:入库必传
+	Remark        string                       `json:"remark"`                         // 备注
+	Commodities   []ErpPurchaseChangeCommodity `json:"commodities" binding:"required"` // 采购换机商品信息
+}
+
+// ErpPurchaseChangeEditReq 编辑采购换机订单入参
+type ErpPurchaseChangeEditReq struct {
+	ChangeOrderId uint32                       `json:"change_order_id" gorm:"index"`   // 采购换机订单id
+	StoreId       uint32                       `json:"store_id"`                       // 门店id:入库必传
+	ErpSupplierId uint32                       `json:"erp_supplier_id"`                // 供应商id:入库必传
+	Remark        string                       `json:"remark"`                         // 备注
+	Commodities   []ErpPurchaseChangeCommodity `json:"Commodities" binding:"required"` // 采购商品信息
+}
+
+// ErpPurchaseChangeOrderListReq 查询采购换机订单列表入参
+type ErpPurchaseChangeOrderListReq struct {
+	SerialNumber   string   `json:"serial_number"`    // 单据编号
+	StoreId        uint32   `json:"store_id"`         // 门店id
+	ErpSupplierId  uint32   `json:"erp_supplier_id"`  // 供应商id
+	AuditTimeStart string   `json:"audit_time_start"` // 审核开始时间
+	AuditTimeEnd   string   `json:"audit_time_end"`   // 审核结束时间
+	State          []uint32 `json:"state"`            // 状态：1-待审核 2-已完成 3-已终止
+	HandlerId      uint32   `json:"handler_id"`       // 经手人id
+	PageIndex      int      `json:"pageIndex"`        // 页码
+	PageSize       int      `json:"pageSize"`         // 页面条数
+}
+
+// ErpPurchaseChangeOrderListResp 查询采购换机订单列表出参
+type ErpPurchaseChangeOrderListResp struct {
+	List      []ErpPurchaseChangeOrder `json:"list"`
+	Total     int                      `json:"total"`     // 总条数
+	PageIndex int                      `json:"pageIndex"` // 页码
+	PageSize  int                      `json:"pageSize"`  // 页面条数
+}
+
+// ErpPurchaseChangeDeleteReq 删除采购换机订单入参
+type ErpPurchaseChangeDeleteReq struct {
+	SerialNumber string `json:"serial_number" binding:"required"` // 单据编号
+}
+
+// ErpPurchaseChangeAuditReq 审核采购换机订单入参
+type ErpPurchaseChangeAuditReq struct {
+	SerialNumber string `json:"serial_number" binding:"required"` // 单据编号
+	State        int    `json:"state"  binding:"required"`        // 审核操作: 1-审核 2-取消审核
+}
+
+// newErpPurchaseChangeSn 生成采购换机订单号
+func newErpPurchaseChangeSn() string {
+	var prefix string
+	prefix = "cgh"
+
+	nowTime := time.Now()
+	rand.Seed(nowTime.UnixNano())
+	max := 1
+	for {
+		if max > 5 {
+			logger.Error("create sn err")
+			return ""
+		}
+		random := rand.Intn(9000) + 1000
+		sn := fmt.Sprintf("%s%d", nowTime.Format("060102"), random)
+		exist, err := QueryRecordExist(fmt.Sprintf("SELECT * FROM erp_purchase_change_order WHERE "+
+			"serial_number='%s'", prefix+sn))
+		if err != nil {
+			logger.Error("exist sn err")
+		}
+		if !exist {
+			return prefix + sn
+		}
+
+		max++
+	}
+}
+
+// IdInit 添加商户和供应商信息
+func (m *ErpPurchaseChangeOrder) IdInit() error {
+	if m.StoreId != 0 {
+		store, err := GetStore(m.StoreId)
+		if err != nil {
+			logger.Error("get store err:", logger.Field("err", err))
+			return err
+		}
+		m.StoreName = store.Name
+	}
+
+	if m.ErpSupplierId != 0 {
+		supplier, err := GetErpSupplier(m.ErpSupplierId)
+		if err != nil {
+			logger.Error("get supplier err:", logger.Field("err", err))
+			return err
+		}
+		m.ErpSupplierName = supplier.Name
+	}
+
+	return nil
+}
+
+// CheckCreateErpPurchaseChangeOrderParam 新增采购换机订单-检查参数
+func CheckCreateErpPurchaseChangeOrderParam(req *ErpPurchaseChangeCreateReq) error {
+	if req.StoreId == 0 {
+		return errors.New("操作失败:门店id为空")
+	}
+	if req.ErpSupplierId == 0 {
+		return errors.New("操作失败:供应商id为空")
+	}
+	for _, item := range req.Commodities {
+		if item.Count <= 0 {
+			return errors.New("操作失败:采购换机数量需大于0")
+		}
+
+		// 判断是否是串码商品，非串码商品不支持
+		if item.IMEIType == 1 {
+			return errors.New("操作失败:非串码商品不支持")
+		}
+
+		var imeiStockCommodity ErpStockCommodity
+		err := orm.Eloquent.Table("erp_stock_commodity").Where("imei = ? and state = ?",
+			item.OriginIMEI, InStock).Find(&imeiStockCommodity).Error
+		if err != nil {
+			return err
+		}
+
+		if imeiStockCommodity.ID == 0 {
+			return errors.New("商品" + "[" + item.OriginIMEI + "]不在库")
+		}
+
+		if imeiStockCommodity.StoreId != req.StoreId {
+			return errors.New(item.OriginIMEI + "商品非所选门店库存，请检查")
+		}
+
+		// 判断新商品串码是否已录入或者使用过
+		var newImeiStockCommodity ErpStockCommodity
+		err = orm.Eloquent.Table("erp_stock_commodity").Where("imei = ?",
+			item.NewIMEI).Find(&newImeiStockCommodity).Error
+		if err != nil {
+			return err
+		}
+
+		if imeiStockCommodity.ID != 0 {
+			return errors.New("串码" + "[" + item.OriginIMEI + "]重复")
+		}
+	}
+
+	return nil
+}
+
+// CheckEditErpPurchaseChangeOrderParam 编辑采购换机订单-检查参数
+func CheckEditErpPurchaseChangeOrderParam(req *ErpPurchaseChangeEditReq) error {
+	if req.StoreId == 0 {
+		return errors.New("操作失败:门店id为空")
+	}
+	if req.ErpSupplierId == 0 {
+		return errors.New("操作失败:供应商id为空")
+	}
+	for _, item := range req.Commodities {
+		if item.Count <= 0 {
+			return errors.New("操作失败:采购换机数量需大于0")
+		}
+
+		// 判断是否是串码商品，非串码商品不支持
+		if item.IMEIType == 1 {
+			return errors.New("操作失败:非串码商品不支持")
+		}
+
+		var imeiStockCommodity ErpStockCommodity
+		err := orm.Eloquent.Table("erp_stock_commodity").Where("imei = ? and state = ?",
+			item.OriginIMEI, InStock).Find(&imeiStockCommodity).Error
+		if err != nil {
+			return err
+		}
+
+		if imeiStockCommodity.ID == 0 {
+			return errors.New("商品" + "[" + item.OriginIMEI + "]不在库")
+		}
+
+		if imeiStockCommodity.StoreId != req.StoreId {
+			return errors.New(item.OriginIMEI + "商品非所选门店库存，请检查")
+		}
+
+		// 判断新商品串码是否已录入或者使用过
+		var newImeiStockCommodity ErpStockCommodity
+		err = orm.Eloquent.Table("erp_stock_commodity").Where("imei = ?",
+			item.NewIMEI).Find(&newImeiStockCommodity).Error
+		if err != nil {
+			return err
+		}
+
+		if imeiStockCommodity.ID != 0 {
+			return errors.New("串码" + "[" + item.OriginIMEI + "]重复")
+		}
+	}
+
+	return nil
+}
+
+// CreateErpPurchaseChangeOrder 新增采购换机订单
+func CreateErpPurchaseChangeOrder(req *ErpPurchaseChangeCreateReq, sysUser *SysUser) (*ErpPurchaseChangeOrder, error) {
+	var err error
+	nowTime := time.Now()
+
+	purchaseOrder := &ErpPurchaseChangeOrder{}
+	purchaseOrder = &ErpPurchaseChangeOrder{
+		SerialNumber:  newErpPurchaseChangeSn(),
+		StoreId:       req.StoreId,
+		ErpSupplierId: req.ErpSupplierId,
+		MakerTime:     &nowTime,
+		MakerId:       uint32(sysUser.UserId),
+		MakerName:     sysUser.NickName,
+		State:         ErpPurchaseChangeOrderUnAudit, // 1-待审核
+		Remark:        req.Remark,
+	}
+	err = purchaseOrder.IdInit()
+	if err != nil {
+		logger.Error("info err:", logger.Field("err", err))
+		return nil, err
+	}
+
+	begin := orm.Eloquent.Begin()
+	err = begin.Create(purchaseOrder).Error
+	if err != nil {
+		begin.Rollback()
+		logger.Error("create  purchase order err:", logger.Field("err", err))
+		return nil, err
+	}
+
+	for i, _ := range req.Commodities {
+		req.Commodities[i].ChangeOrderId = purchaseOrder.ID
+		err = begin.Create(&req.Commodities[i]).Error
+		if err != nil {
+			begin.Rollback()
+			logger.Error("create purchase commodity err:", logger.Field("err", err))
+			return nil, err
+		}
+	}
+	err = begin.Commit().Error
+	if err != nil {
+		begin.Rollback()
+		logger.Error("commit purchase commodity err:", logger.Field("err", err))
+		return nil, err
+	}
+
+	return purchaseOrder, nil
+}
+
+// EditErpPurchaseChangeOrder 编辑采购订单
+func EditErpPurchaseChangeOrder(req *ErpPurchaseChangeEditReq, sysUser *SysUser) (*ErpPurchaseChangeOrder, error) {
+	// 查询订单信息
+	var purchaseChangeOrder ErpPurchaseChangeOrder
+	err := orm.Eloquent.Table("erp_purchase_change_order").Where("id=?", req.ChangeOrderId).Find(&purchaseChangeOrder).Error
+	if err != nil {
+		logger.Error("purchase change order err:", logger.Field("err", err))
+		return nil, err
+	}
+
+	if purchaseChangeOrder.State != ErpPurchaseChangeOrderUnAudit { // 只有待审核的订单才能编辑
+		return nil, errors.New("订单不是待审核状态")
+	}
+
+	if req.StoreId == 0 {
+		return nil, errors.New("操作失败:门店id为空")
+	}
+
+	begin := orm.Eloquent.Begin()
+	// 1-更新采购订单信息
+	purchaseChangeOrder.StoreId = req.StoreId
+	purchaseChangeOrder.ErpSupplierId = req.ErpSupplierId
+	purchaseChangeOrder.MakerId = uint32(sysUser.UserId)
+	purchaseChangeOrder.MakerName = sysUser.NickName
+	purchaseChangeOrder.Remark = req.Remark
+	err = purchaseChangeOrder.IdInit()
+	if err != nil {
+		logger.Error("purchase change IdInit err:", logger.Field("err", err))
+		return nil, err
+	}
+
+	err = begin.Model(&ErpPurchaseChangeOrder{}).Where("id = ?", req.ChangeOrderId).
+		Omit("created_at").Save(purchaseChangeOrder).Error
+	if err != nil {
+		begin.Rollback()
+		logger.Error("update erp_order err:", logger.Field("err", err))
+		return nil, err
+	}
+
+	// 2-更新采购订单商品表
+	err = updatePurchaseChangeCommodityData(begin, req.ChangeOrderId, req)
+	if err != nil {
+		begin.Rollback()
+		logger.Error("update erp_purchase_commodity err:", logger.Field("err", err))
+		return nil, err
+	}
+
+	err = begin.Commit().Error
+	if err != nil {
+		begin.Rollback()
+		logger.Error("commit err:", logger.Field("err", err))
+		return nil, err
+	}
+
+	return &purchaseChangeOrder, nil
+}
+
+// updatePurchaseChangeCommodityData 更新采购订单商品信息
+func updatePurchaseChangeCommodityData(gdb *gorm.DB, orderId uint32, req *ErpPurchaseChangeEditReq) error {
+	// 查询现有的零售订单信息
+	var commodities []ErpPurchaseChangeCommodity
+	err := orm.Eloquent.Table("erp_purchase_change_commodity").Where("change_order_id = ?", orderId).Find(&commodities).Error
+	if err != nil {
+		logger.Error("query erp_purchase_change_commodity err:", logger.Field("err", err))
+		return err
+	}
+
+	// 1-删除所有的商品信息
+	if len(commodities) != 0 {
+		err = gdb.Delete(&commodities).Error
+		if err != nil {
+			logger.Error("更新商品订单信息-删除 error")
+			return errors.New("操作失败:" + err.Error())
+		}
+	}
+
+	for i, _ := range req.Commodities {
+		req.Commodities[i].ID = 0
+		if req.Commodities[i].ChangeOrderId == 0 { //发现前端有时会没传，后端打补丁
+			req.Commodities[i].ChangeOrderId = req.ChangeOrderId
+		}
+	}
+
+	// 2-更新商品订单信息-新增
+	if len(req.Commodities) != 0 {
+		err = gdb.Create(&req.Commodities).Error
+		if err != nil {
+			logger.Error("更新商品订单信息-新增 error")
+			return errors.New("操作失败:" + err.Error())
+		}
+	}
+
+	return nil
+}
+
+// List 查询采购订单列表
+func (m *ErpPurchaseChangeOrderListReq) List(c *gin.Context) (*ErpPurchaseChangeOrderListResp, error) {
+	resp := &ErpPurchaseChangeOrderListResp{
+		PageIndex: m.PageIndex,
+		PageSize:  m.PageSize,
+	}
+	page := m.PageIndex - 1
+	if page < 0 {
+		page = 0
+	}
+	if m.PageSize == 0 {
+		m.PageSize = 10
+	}
+	qs := orm.Eloquent.Table("erp_purchase_change_order")
+
+	if m.SerialNumber != "" {
+		qs = qs.Where("serial_number=?", m.SerialNumber)
+	} else {
+		if m.StoreId != 0 {
+			qs = qs.Where("store_id=?", m.StoreId)
+		}
+		// 非管理员才判断所属门店
+		if !(tools.GetRoleName(c) == "admin" || tools.GetRoleName(c) == "系统管理员") {
+			sysUser, err := GetSysUserByCtx(c)
+			if err != nil {
+				return nil, errors.New("操作失败:" + err.Error())
+			}
+
+			// 返回sysUser未过期的门店id列表
+			storeList := GetValidStoreIDs(sysUser.StoreData)
+			if len(storeList) > 0 {
+				if len(storeList) == 1 {
+					qs = qs.Where("store_id = ?", storeList[0])
+				} else {
+					qs = qs.Where("store_id IN (?)", storeList)
+				}
+			} else {
+				return nil, errors.New("用户未绑定门店")
+			}
+		}
+		if m.ErpSupplierId != 0 {
+			qs = qs.Where("erp_supplier_id=?", m.ErpSupplierId)
+		}
+		if len(m.State) > 0 {
+			qs = qs.Where("state IN (?)", m.State)
+		}
+		if m.AuditTimeStart != "" {
+			parse, err := time.Parse(QueryTimeFormat, m.AuditTimeStart)
+			if err != nil {
+				logger.Errorf("erpPurchaseChangeOrderList err:", err)
+				return nil, err
+			}
+			qs = qs.Where("audit_time > ?", parse)
+		}
+		if m.AuditTimeEnd != "" {
+			parse, err := time.Parse(QueryTimeFormat, m.AuditTimeEnd)
+			if err != nil {
+				logger.Errorf("erpPurchaseChangeOrderList err:", err)
+				return nil, err
+			}
+			//parse = parse.AddDate(0, 0, 1)
+			qs = qs.Where("audit_time < ?", parse)
+		}
+		if m.HandlerId != 0 {
+			qs = qs.Where("handler_id=?", m.HandlerId)
+		}
+	}
+
+	var count int64
+	err := qs.Count(&count).Error
+	if err != nil {
+		logger.Error("count err:", logger.Field("err", err))
+		return resp, err
+	}
+	resp.Total = int(count)
+	var orders []ErpPurchaseChangeOrder
+	err = qs.Order("id DESC").Offset(page * m.PageSize).Limit(m.PageSize).Find(&orders).Error
+	if err != nil && err != RecordNotFound {
+		logger.Error("erp commodity list err:", logger.Field("err", err))
+		return resp, err
+	}
+
+	// 校验时间，如果为01-01-01 08:05，则赋值为空
+	for i, v := range orders {
+		if v.MakerTime != nil && v.MakerTime.IsZero() {
+			orders[i].MakerTime = nil
+		}
+
+		if v.AuditTime != nil && v.AuditTime.IsZero() {
+			orders[i].AuditTime = nil
+		}
+	}
+
+	resp.List = orders
+	return resp, nil
+}
+
+// AuditChangeOrder 审核采购换机订单
+func AuditChangeOrder(begin *gorm.DB, req ErpPurchaseChangeOrder, state int) error {
+	var purchaseChangeOrder ErpPurchaseChangeOrder
+	err := orm.Eloquent.Table("erp_purchase_change_order").Where("id=?", req.ID).Find(&purchaseChangeOrder).Error
+	if err != nil {
+		logger.Error("check erp_purchase_change_order err:", logger.Field("err", err))
+		return err
+	}
+
+	if state == ErpPurchaseChangeOrderUnAudit { // 反向审核，状态更新为：待审核
+		for i, _ := range req.Commodities {
+			if req.Commodities[i].IMEIType == 2 || req.Commodities[i].IMEIType == 3 { // 串码商品
+				// 旧串码商品出库
+				if req.Commodities[i].OriginIMEI == "" {
+					return errors.New("串码为空")
+				}
+
+				var imeiStockCommodity ErpStockCommodity
+				err = orm.Eloquent.Table("erp_stock_commodity").Where("imei = ? and state = ?",
+					req.Commodities[i].OriginIMEI, InStock).Find(&imeiStockCommodity).Error
+				if err != nil {
+					return err
+				}
+
+				if imeiStockCommodity.ID == 0 {
+					return errors.New("商品" + "[" + req.Commodities[i].ErpCommodityName + "]库存不足")
+				}
+
+				if imeiStockCommodity.StoreId != req.StoreId {
+					return errors.New(req.Commodities[i].ErpCommodityName + "商品非所选门店库存，请检查")
+				}
+
+				err = begin.Table("erp_stock_commodity").Where("imei = ?", req.Commodities[i].OriginIMEI).
+					Updates(map[string]interface{}{
+						"state":      PurchaseChange,
+						"updated_at": time.Now(),
+					}).Error // 状态更新为"采购换机"
+				if err != nil {
+					begin.Rollback()
+					logger.Error("commodities err:", logger.Field("err", err))
+					return err
+				}
+
+				// 新串码商品入库
+				newStockCommodity := imeiStockCommodity
+				newStockCommodity.ID = 0
+				newStockCommodity.IMEI = req.Commodities[i].NewIMEI
+				err = begin.Create(newStockCommodity).Error
+				if err != nil {
+					begin.Rollback()
+					logger.Error("create  purchase order err:", logger.Field("err", err))
+					return err
+				}
+			} else {
+				return errors.New("非串码商品不支持采购换货")
+			}
+		}
+	} else if state == ErpPurchaseChangeOrderFinished { // 正向审核，状态更新为：已完成
+		for i, _ := range req.Commodities {
+			// 查询新串码的库存情况
+			var imeiStockCommodity ErpStockCommodity
+			err = orm.Eloquent.Table("erp_stock_commodity").Where("imei = ? and state = ?",
+				req.Commodities[i].NewIMEI, InStock).Find(&imeiStockCommodity).Error
+			if err != nil {
+				return err
+			}
+
+			if imeiStockCommodity.ID == 0 {
+				return errors.New("商品" + "[" + req.Commodities[i].NewIMEI + "]不在库")
+			}
+
+			err = begin.Delete(imeiStockCommodity).Error // 删除新串码库存
+			if err != nil {
+				begin.Rollback()
+				logger.Error("commodities err:", logger.Field("err", err))
+				return err
+			}
+
+			// 更新旧串码为在库状态
+			err = begin.Table("erp_stock_commodity").Where("imei = ?", req.Commodities[i].OriginIMEI).
+				Updates(map[string]interface{}{
+					"state":      InStock,
+					"updated_at": time.Now(),
+				}).Error // 状态更新为"在库"
+			if err != nil {
+				begin.Rollback()
+				logger.Error("commodities err:", logger.Field("err", err))
+				return err
+			}
+		}
+	}
+
+	return nil
+}

app/admin/router/purchasemanage.go

@@ -29,4 +29,9 @@ func registerErpPurchaseManageRouter(v1 *gin.RouterGroup, authMiddleware *jwt.Gi
 	r.POST("report/supplier", purchasemanage.ErpPurchaseReportBySupplier)   // 供应商采购汇总
 	r.POST("report/detail", purchasemanage.ErpPurchaseReportDetail)         // 采购明细
 
+	r.POST("change/create", purchasemanage.ErpPurchaseChangeCreate) // 采购换机-新增
+	r.POST("change/edit", purchasemanage.ErpPurchaseChangeEdit)     // 采购换机-编辑
+	r.POST("change/list", purchasemanage.ErpPurchaseChangeList)     // 采购换机列表
+	r.POST("change/delete", purchasemanage.ErpPurchaseChangeDelete) // 采购换机-删除
+	r.POST("change/audit", purchasemanage.ErpPurchaseChangeAudit)   // 采购换机-审核
 }