minghui/mh_server
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
dev_1.6.0
mh_server/model/erp_commodity.go

617 lines
30 KiB
Go
Raw Permalink Normal View History

1、删除不再需要的erp零售相关接口（前端直接调用的erp后端代码接口）； 2、修改商城下单和付款回调接口；
2025-08-29 10:33:35 +00:00
package model
import (
"fmt"
"github.com/codinl/go-logger"
"github.com/jinzhu/gorm"
"math/rand"
"time"
)
const (
ErpOrderStateAudited = "audited" // 已审核
HavePaid = 2 // 已支付
NoPrint = 1 // 未打印
RetailTypeSale = "sale" // 零售销售订单
SysUserIdByAdmin = 1 // 系统管理员id
SysUserNameByAdmin = "系统管理员" // 系统管理员名称
SoldOut = 2 // 已售
)
// ErpStock 库存列表
type ErpStock struct {
Model
StoreId uint32 `json:"store_id" gorm:"index"` // 门店编号
StoreName string `json:"store_name"` // 门店名称
ErpCommodityId uint32 `json:"erp_commodity_id" gorm:"index"` // 商品id
ErpCommodityName string `json:"erp_commodity_name"` // 商品名称
ErpCategoryId uint32 `json:"erp_category_id" gorm:"index"` // 分类id
ErpCategoryName string `json:"erp_category_name"` // 分类名称
CommoditySerialNumber string `json:"commodity_serial_number" gorm:"index"` // 商品编码/串码
IMEIType uint32 `json:"imei_type"` // 1-无串码 2-串码（系统生成） 3-串码（手动添加）
RetailPrice float64 `json:"retail_price"` // 指导零售价
MinRetailPrice float64 `json:"min_retail_price"` // 最低零售价
Count uint32 `json:"count"` // 数量
DispatchCount uint32 `json:"dispatch_count"` // 调拨中数量（调拨中调入）
DecisionStoreId []uint32 `json:"decision_store_id" gorm:"-"` // 门店编号列表（查询进销存的时候使用）
Commodities []ErpStockCommodity `json:"commodities" gorm:"-"` //
}
// ErpStockCommodity 库存详情
type ErpStockCommodity struct {
Model
ErpStockId uint32 `json:"erp_stock_id" gorm:"index"` // 库存id
StoreId uint32 `json:"store_id" gorm:"index"` // 门店id
StoreName string `json:"store_name"` // 门店名称
ErpCommodityId uint32 `json:"erp_commodity_id" gorm:"index"` // 商品id
ErpCommodityName string `json:"erp_commodity_name"` // 商品名称
CommoditySerialNumber string `json:"commodity_serial_number" gorm:"index"` // 商品编号
ErpCategoryId uint32 `json:"erp_category_id" gorm:"index"` // 分类id
ErpCategoryName string `json:"erp_category_name"` // 分类名称
ErpBarcode string `json:"erp_barcode"` // 商品条码
IMEIType uint32 `json:"imei_type"` // 是否串码：1-无串码 2-串码（系统生成） 3-串码（手动添加）
IMEI string `json:"imei"` // 商品串码
ErpSupplierId uint32 `json:"erp_supplier_id" gorm:"index"` // 供应商id
ErpSupplierName string `json:"erp_supplier_name"` // 供应商名称
StockTime time.Time `json:"stock_time"` // 最近入库时间
RetailPrice float64 `json:"retail_price"` // 指导零售价
MinRetailPrice float64 `json:"min_retail_price"` // 最低零售价
StaffCostPrice float64 `json:"staff_cost_price"` // 员工成本价加价（如：加价50，不是加价后的价格）
WholesalePrice float64 `json:"wholesale_price"` // 指导采购价
MemberDiscount float64 `json:"member_discount"` // 会员优惠
State uint32 `json:"state"` // 状态:1-在库 2-已售 3-采购退货 4-调拨中 5-销售锁定中 6-产品出库 7-盘点出库
Count uint32 `json:"count"` // 数量
StorageType uint32 `json:"storage_type"` // 入库方式：1-系统入库 2-采购入库 3-产品入库 4-盘点入库
FirstStockTime time.Time `json:"first_stock_time"` // 首次入库时间
StockSn string `json:"stock_sn"` // 库存订单编号（跟采购入库的入库编号关联）
OriginalSn string `json:"original_sn" gorm:"index"` // 首次入库订单编号(单据编号）
StockStartTime time.Time `json:"stock_start_time" gorm:"-"` // 最近入库开始时间
StockEndTime time.Time `json:"stock_end_time" gorm:"-"` // 最近入库结束时间
Age uint32 `json:"age" gorm:"-"` // 最近库龄
AllAge uint32 `json:"all_age" gorm:"-"` // 总库龄
Remark string `json:"remark"` // 备注
CategoryNumber string `json:"category_number" gorm:"-"` // 商品分类编号
}
// ErpCommodity 商品表
type ErpCommodity struct {
Model
SerialNumber string `json:"serial_number"` // 商品编号
Number uint32 `json:"number"` // 商品数量
Name string `json:"name"` // 商品名称
ErpCategoryId uint32 `json:"erp_category_id" gorm:"index"` // 商品分类id
ErpCategoryName string `json:"erp_category_name"` // 商品分类名称
ErpBarcode string `json:"erp_barcode"` // 商品条码
IMEIType uint32 `json:"imei_type"` // 1-无串码 2-串码（系统生成） 3-串码（手动添加）
IMEI string `json:"imei"` // 串码
ErpSupplierId uint32 `json:"erp_supplier_id" gorm:"index"` // 主供应商id
ErpSupplierName string `json:"erp_supplier_name"` // 主供应商名称
RetailPrice uint32 `json:"retail_price"` // 指导零售价
MinRetailPrice uint32 `json:"min_retail_price"` // 最低零售价
StaffCostPrice uint32 `json:"staff_cost_price"` // 员工成本价加价（如：加价50，不是加价后的价格）
WholesalePrice uint32 `json:"wholesale_price"` // 指导采购价
Brokerage1 float64 `json:"brokerage_1"` // 销售毛利提成
Brokerage2 float64 `json:"brokerage_2"` // 员工毛利提成
MemberDiscount float64 `json:"member_discount"` // 会员优惠
Origin string `json:"origin"` // 产地
Remark string `json:"remark" gorm:"type:varchar(512)"` // 备注
Img string `json:"img"` // 图片
StopPurchase uint32 `json:"stop_purchase"` // 0-未勾选，正常采购；1-勾选，停止采购
ManufacturerCode string `json:"manufacturer_code"` // 厂家编码
IsSyncedToMall uint32 `json:"is_synced_to_mall"` // 是否同步到小程序商城：0-否；1-是
GoodsId uint32 `json:"goods_id"` // 小程序商城-商品ID
SaleStatus uint32 `json:"sale_status"` // 小程序商城-在售状态 1-在售 2-下架
ErpCategory *ErpCategory `json:"erp_category" gorm:"-"`
}
// ErpCategory 商品分类
type ErpCategory struct {
Model
Name string `json:"name"` // 名称
Priority string `json:"priority"` // 分类
Number uint32 `json:"number"` //
FullNum uint32 `json:"full_num"` //
State uint32 `json:"state"` // 1-未使用 2-使用 3-隐藏
Level uint32 `json:"level"` // 分类层级
Pid uint32 `json:"pid" gorm:"index"` //
Sort uint32 `json:"sort"` //
SubCats []ErpCategory `json:"sub_cats" gorm:"-"` // 子列表
}
// ErpOrder 零售订单表
type ErpOrder struct {
Model
BillSn string `json:"bill_sn" gorm:"index"` // 单据编号
RetailType string `json:"retail_type"` // 销售类型:sale 零售销售； rejected 零售退货
GoodsOrderId uint32 `json:"goods_order_id" gorm:"index"` // 小程序商城订单id
Uid int `json:"uid"` // 用户id
UserType int `json:"user_type"` // 会员类别：1-普通会员 2-黄金会员 4-白金会员 5-黑金会员 6-尊享会员 7-黄金&尊享 8-白金&尊享 9-黑金&尊享
Tel string `json:"tel" gorm:"index"` // 客户手机号
StoreId uint32 `json:"store_id" gorm:"index"` // 门店id
StoreName string `json:"store_name"` // 门店名称
MakerId uint32 `json:"maker_id" gorm:"index"` // 制单人id
MakerName string `json:"maker_name"` // 制单人名称
MakerTime time.Time `json:"maker_time"` // 制单时间
AuditorId uint32 `json:"auditor_id" gorm:"index"` // 审核人id
AuditorName string `json:"auditor_name"` // 审核人姓名
AuditTime *time.Time `json:"audit_time"` // 审核时间
CashierList string `json:"cashier_list" gorm:"type:text"` // 付款方式，存储json数据
SalesmanList string `json:"salesman_list" gorm:"type:text"` // 销售员信息，存储json数据
MemberType string `json:"member_type"` // 会员类型:general 普通； member 会员
State string `json:"state" gorm:"index"` // 订单状态:un_audit 待审核； audited 已审核
TotalRetailPrice float64 `json:"total_retail_price"` // 订单总指导零售价
TotalAmount float64 `json:"total_amount"` // 订单实收金额
TotalCount int32 `json:"total_count"` // 订单商品数量
TotalSalesProfit float64 `json:"total_sales_profit"` // 订单总销售毛利
TotalStaffProfit float64 `json:"total_staff_profit"` // 订单总员工毛利
VmCount uint32 `json:"vm_count"` // 使用会员积分
SaleOrderId uint32 `json:"sale_order_id"` // 销售订单id
PayStatus uint32 `json:"pay_status"` // 支付状态 0-未创建 ；1-待支付； 2-已支付
IsPrint uint32 `json:"is_print"` // 是否打印小票 1-未打印 2-已打印
PrintCount uint32 `json:"print_count"` // 小票打印次数
InvoiceCode string `json:"invoice_code"` // 发票代码
InvoiceNumber string `json:"invoice_number"` // 发票编码
RejectedTotalAmount float64 `json:"rejected_total_amount" gorm:"-"` // 订单总退货金额
RejectedTotalCount uint32 `json:"rejected_total_count" gorm:"-"` // 订单总退货数量
StorePer float64 `json:"store_per"` // 门店提成：订单总员工毛利X该门店设置好的提成比例，保留到小数后两位多余舍去
TotalDiscount float64 `json:"total_discount"` // 订单总优惠：订单所有商品零售优惠+会员优惠+会员积分抵扣之和
BankTrxNo string `json:"bank_trx_no" gorm:"-"` // 银行流水号
Commodities []ErpOrderCommodity `json:"commodities" gorm:"-"` // 零售订单商品信息
Cashiers []ErpOrderCashier `json:"cashiers" gorm:"-"` // 收付款方式
Salesman []ErpOrderSales `json:"salesman" gorm:"-"` // 销售员信息
}
// ErpOrderSales 销售员信息
type ErpOrderSales struct {
Model
ErpOrderId uint32 `json:"erp_order_id" gorm:"index"` // 零售订单id（后端生成）
Uid uint32 `json:"userId" binding:"required"` // 销售员用户ID（20240322：更换为系统用户表主键id）
Name string `json:"name"` // 销售员用户姓名
SalesProfitPer float64 `json:"sales_profit_per"` // 销售毛利提成：每个商品销售毛利X其对应的提成比例后求和；如果是两个销售员参与则分别除以2 ，保留到小数后两位多余舍去
StaffProfitPer float64 `json:"staff_profit_per"` // 员工毛利提成：每个商品员工毛利X其对应的提成比例后求和；如果是两个销售员参与则分别除以2 ，保留到小数后两位多余舍去
SalesmanPer float64 `json:"salesman_per"` // 销售员提成：订单总员工毛利X该销售员设置好的提成比例；如果是两个销售员参与，那么两个人算出的提成均除以2，保留到小数后两位多余舍去
}
// ErpOrderCashier 订单收款方式
type ErpOrderCashier struct {
CashierId uint32 `json:"cashier_id"` // 收付款方式id
Name string `json:"name"` // 收付款方式名称
Amount float64 `json:"amount"` // 金额
}
// ErpOrderCommodity 零售订单商品表
type ErpOrderCommodity struct {
Model
ErpOrderId uint32 `json:"erp_order_id" gorm:"index"` // 零售订单id（后端生成）
ErpCategoryId uint32 `json:"erp_category_id" gorm:"index"` // 分类id
ErpCategoryName string `json:"erp_category_name"` // 分类名称
ErpCommodityId uint32 `json:"erp_commodity_id" gorm:"index"` // 商品id
ErpCommodityName string `json:"erp_commodity_name"` // 商品名称
ErpSupplierId uint32 `json:"erp_supplier_id" gorm:"index"` // 主供应商id
ErpSupplierName string `json:"erp_supplier_name"` // 主供应商名称
IMEIType uint32 `json:"imei_type"` // 1-无串码 2-串码
IMEI string `json:"imei" gorm:"index"` // 串码
PresentType uint32 `json:"present_type"` // 赠送类型:1-非赠送 2-赠送
RetailPrice float64 `json:"retail_price"` // 指导零售价
SalePrice float64 `json:"sale_price"` // 零售价
Count int32 `json:"count"` // 销售数量
SaleDiscount float64 `json:"sale_discount"` // 零售优惠
MemberDiscount float64 `json:"member_discount"` // 会员优惠
VmDiscount float64 `json:"vm_discount"` // 会员积分抵扣
CouponID uint32 `json:"coupon_id"` // 优惠券ID
CouponDiscount float64 `json:"coupon_discount"` // 优惠券抵扣
CouponCode string `json:"coupon_code"` // 优惠券券码
CouponName string `json:"coupon_name"` // 优惠券名称
Amount float64 `json:"amount"` // 实际零售价
ReceivedAmount float64 `json:"received_amount"` // 商品实收金额
Remark string `json:"remark"` // 销售备注
RejectedRemark string `json:"rejected_remark"` // 退货备注
RejectedPrice float64 `json:"rejected_price"` // 退货单价
RejectedCount uint32 `json:"rejected_count"` // 退货数量
RejectedAmount float64 `json:"rejected_amount"` // 退货金额
RejectedOrderCommodityId uint32 `json:"rejected_order_commodity_id"` // 退货订单商品id
StaffCostPrice float64 `json:"staff_cost_price"` // 员工成本价加价（如：加价50，不是加价后的价格）
WholesalePrice float64 `json:"wholesale_price"` // 指导采购价
SalesProfit float64 `json:"sales_profit"` // 销售毛利：实际零售价-采购单价；如果为退货订单，则为实际退货价-采购单价
StaffProfit float64 `json:"staff_profit"` // 员工毛利：实际零售价-员工成本价；如果为退货订单，则为实际退货价-员工成本价
ErpStockCommodityID string `json:"erp_stock_commodity_id"` // 库存商品表主键id
StaffPrice float64 `json:"staff_price" gorm:"-"` // 员工成本价
CommoditySerialNumber string `json:"commodity_serial_number" gorm:"-"` // 商品编号
CategoryNumber string `json:"category_number" gorm:"-"` // 商品分类编号
}
// NewErpBillSn 生成零售订单号
func NewErpBillSn() string {
nowTime := time.Now()
rand.Seed(nowTime.UnixNano())
max := 1
for {
if max > 5 {
logger.Error("create sn err")
return ""
}
random := rand.Int31n(9999) + 1000
sn := fmt.Sprintf("%s%d", nowTime.Format("060102"), random)
exist, err := QueryRecordExist(fmt.Sprintf("SELECT * FROM erp_order WHERE bill_sn='%s'", sn))
if err != nil {
logger.Error("exist sn err")
}
if !exist {
return sn
}
max++
}
}
// SelectDeliveryStock 选择发货库存
// commodityId: 商品ID
// storeId: 指定门店ID（0 表示不指定）
// return: 选中的库存记录
func SelectDeliveryStock(commodityId, storeId uint32) (*ErpStockCommodity, error) {
1、小程序商城下单流程优化，支持单笔订单多个商品；
2025-09-11 10:06:20 +00:00
// 先校验门店
if storeId == 0 {
return nil, fmt.Errorf("无法确定最近门店，请先设置 NearestStoreId")
}
1、删除不再需要的erp零售相关接口（前端直接调用的erp后端代码接口）； 2、修改商城下单和付款回调接口；
2025-08-29 10:33:35 +00:00
var stock ErpStockCommodity
// 1️⃣ 优先指定门店
err := DB.Table("erp_stock_commodity").
1、小程序商城下单流程优化，支持单笔订单多个商品；
2025-09-11 10:06:20 +00:00
Where("erp_commodity_id = ? AND store_id = ? AND state = 1 AND count > 0",
commodityId, storeId).
1、删除不再需要的erp零售相关接口（前端直接调用的erp后端代码接口）； 2、修改商城下单和付款回调接口；
2025-08-29 10:33:35 +00:00
Order("first_stock_time ASC").
1、小程序商城下单流程优化，支持单笔订单多个商品；
2025-09-11 10:06:20 +00:00
First(&stock).Error
if err == nil {
return &stock, nil
1、删除不再需要的erp零售相关接口（前端直接调用的erp后端代码接口）； 2、修改商城下单和付款回调接口；
2025-08-29 10:33:35 +00:00
}
1、小程序商城下单流程优化，支持单笔订单多个商品；
2025-09-11 10:06:20 +00:00
// 2️⃣ 如果指定门店无库存，则报错（不允许跨门店）
return nil, fmt.Errorf("商品 %d 在门店 %d 无可用库存", commodityId, storeId)
1、删除不再需要的erp零售相关接口（前端直接调用的erp后端代码接口）； 2、修改商城下单和付款回调接口；
2025-08-29 10:33:35 +00:00
}
1、小程序商城下单流程优化，支持单笔订单多个商品；
2025-09-11 10:06:20 +00:00
//func SelectDeliveryStock(commodityId, storeId uint32) (*ErpStockCommodity, error) {
// var stock ErpStockCommodity
//
// // 1️⃣ 优先指定门店
// if storeId > 0 {
// err := DB.Table("erp_stock_commodity").
// Where("erp_commodity_id = ? AND store_id = ? AND state = 1 AND count > 0", commodityId, storeId).
// Order("first_stock_time ASC").
// First(&stock).Error
// if err == nil {
// return &stock, nil
// }
// }
//
// // 2️⃣ 其他门店，优先库龄最久
// var otherStocks []ErpStockCommodity
// err := DB.Table("erp_stock_commodity").
// Where("erp_commodity_id = ? AND state = 1 AND count > 0", commodityId).
// Order("first_stock_time ASC").
// Find(&otherStocks).Error
// if err != nil {
// return nil, err
// }
// if len(otherStocks) == 0 {
// return nil, fmt.Errorf("无可用库存")
// }
//
// // 3️⃣ 多个相同库龄，随机一个
// oldestTime := otherStocks[0].FirstStockTime
// var oldestStocks []ErpStockCommodity
// for _, s := range otherStocks {
// if s.FirstStockTime.Equal(oldestTime) {
// oldestStocks = append(oldestStocks, s)
// } else {
// break
// }
// }
//
// rand.Seed(time.Now().UnixNano())
// chosen := oldestStocks[rand.Intn(len(oldestStocks))]
// return &chosen, nil
//}
//// CreateErpOrder 根据小程序订单生成ERP零售订单
//func CreateErpOrder(goodsOrder *GoodsOrder, goods *Goods) error {
// logger.Infof("enter CreateErpOrder")
// logger.Infof("goods: %+v", goods)
// logger.Infof("goodsOrder: %+v", goodsOrder)
// tx := DB.Begin()
// if tx.Error != nil {
// return tx.Error
// }
//
// defer func() {
// if r := recover(); r != nil {
// logger.Errorf("事务 panic 回滚: %v", r)
// tx.Rollback()
// }
// }()
//
// // 1. 查找用户信息
// var user User
// if err := tx.Where("uid = ?", goodsOrder.Uid).First(&user).Error; err != nil {
// logger.Infof("用户 %d 不存在", goodsOrder.Uid)
// return fmt.Errorf("用户不存在: %w", err)
// }
//
// var orderCommodities []ErpOrderCommodity
// var totalAmount, totalRetailPrice, totalSalesProfit, totalStaffProfit float64
// var totalCount int32
//
// // 遍历小程序订单的商品明细
// // 选择库存：优先指定门店 → 其他门店库龄最久
// stock, err := SelectDeliveryStock(goods.ErpCommodityId, goodsOrder.NearestStoreId)
// if err != nil {
// tx.Rollback()
// logger.Infof("商品 %d 无库存: %v", goods.ErpCommodityId, err)
// return fmt.Errorf("商品 %d 无库存: %v", goods.ErpCommodityId, err)
// }
// logger.Infof("stock: %+v", stock)
//
// // 扣减库存
// err = tx.Table("erp_stock_commodity").Where("id = ?", stock.ID).
// Updates(map[string]interface{}{
// "state": SoldOut,
// "updated_at": time.Now(),
// }).Error // 状态更新为已销售
// if err != nil {
// logger.Error("update erp_stock_commodity err:", err)
// tx.Rollback()
// return fmt.Errorf("库存扣减失败: %v", err)
// }
//
// err = tx.Table("erp_stock").Where("store_id = ? and erp_commodity_id = ? AND count > 0",
// stock.StoreId, stock.ErpCommodityId).
// Updates(map[string]interface{}{
// "count": gorm.Expr("count - ?", 1),
// "updated_at": time.Now(),
// }).Error // 库存数量-1
// if err != nil {
// logger.Error("update erp_stock err:", err)
// tx.Rollback()
// return fmt.Errorf("库存不足")
// }
//
// // 金额计算
// receivedAmount := float64(goodsOrder.Quantity) * float64(goods.PriceRm/100)
// salesProfit := receivedAmount - stock.WholesalePrice*float64(goodsOrder.Quantity)
// staffProfit := receivedAmount - (stock.WholesalePrice+stock.StaffCostPrice)*float64(goodsOrder.Quantity)
//
// orderCommodities = append(orderCommodities, ErpOrderCommodity{
// ErpCategoryId: stock.ErpCategoryId,
// ErpCategoryName: stock.ErpCategoryName,
// ErpCommodityId: stock.ErpCommodityId,
// ErpCommodityName: stock.ErpCommodityName,
// ErpSupplierId: stock.ErpSupplierId,
// ErpSupplierName: stock.ErpSupplierName,
// IMEIType: stock.IMEIType,
// IMEI: "",
// PresentType: 1,
// RetailPrice: stock.RetailPrice,
// SalePrice: float64(goods.PriceRm / 100),
// Count: int32(goodsOrder.Quantity),
// Amount: receivedAmount,
// ReceivedAmount: receivedAmount,
// StaffCostPrice: stock.StaffCostPrice,
// WholesalePrice: stock.WholesalePrice,
// SalesProfit: salesProfit,
// StaffProfit: staffProfit,
// ErpStockCommodityID: fmt.Sprintf("%d", stock.ID),
// })
// logger.Infof("orderCommodities 长度: %d", len(orderCommodities))
//
// totalAmount += receivedAmount
// totalRetailPrice += stock.RetailPrice * float64(goodsOrder.Quantity)
// totalSalesProfit += salesProfit
// totalStaffProfit += staffProfit
// totalCount += int32(goodsOrder.Quantity)
//
// nowTime := time.Now()
// // ERP订单
// order := ErpOrder{
// BillSn: NewErpBillSn(),
// GoodsOrderId: goodsOrder.OrderId,
// RetailType: RetailTypeSale,
// Uid: int(goodsOrder.Uid),
// UserType: int(user.MemberLevel),
// Tel: user.Tel,
// StoreId: stock.StoreId,
// StoreName: stock.StoreName,
// MakerId: SysUserIdByAdmin,
// MakerName: SysUserNameByAdmin,
// MakerTime: nowTime,
// AuditorId: SysUserIdByAdmin,
// AuditorName: SysUserNameByAdmin,
// AuditTime: &nowTime,
// State: ErpOrderStateAudited,
// TotalRetailPrice: totalRetailPrice,
// TotalAmount: totalAmount,
// TotalCount: totalCount,
// TotalSalesProfit: totalSalesProfit,
// TotalStaffProfit: totalStaffProfit,
// PayStatus: HavePaid, // 已支付
// IsPrint: NoPrint, // 未打印
// PrintCount: 0,
// }
//
// if err = tx.Create(&order).Error; err != nil {
// logger.Infof("新建erp零售订单失败: %v", err)
// tx.Rollback()
// return fmt.Errorf("新建erp零售订单失败: %v", err)
// }
//
// // 绑定订单ID
// for i := range orderCommodities {
// orderCommodities[i].ErpOrderId = order.ID
// if err = tx.Create(&orderCommodities[i]).Error; err != nil {
// logger.Errorf("新建erp零售订单商品信息失败: %v", err)
// tx.Rollback()
// return fmt.Errorf("新建erp零售订单商品信息失败: %v", err)
// }
// }
//
// if err = tx.Commit().Error; err != nil {
// logger.Infof("提交事务失败: %v", err)
// return fmt.Errorf("提交事务失败: %v", err)
// }
//
// logger.Infof("leave CreateErpOrder")
// return nil
//}
// CreateErpOrder 根据小程序订单生成ERP零售订单（支持多商品）
func CreateErpOrder(goodsOrder *GoodsOrder, commodities []GoodsOrderCommodity) error {
1、删除不再需要的erp零售相关接口（前端直接调用的erp后端代码接口）； 2、修改商城下单和付款回调接口；
2025-08-29 10:33:35 +00:00
logger.Infof("enter CreateErpOrder")
tx := DB.Begin()
if tx.Error != nil {
return tx.Error
}
defer func() {
if r := recover(); r != nil {
logger.Errorf("事务 panic 回滚: %v", r)
tx.Rollback()
}
}()
// 1. 查找用户信息
var user User
if err := tx.Where("uid = ?", goodsOrder.Uid).First(&user).Error; err != nil {
logger.Infof("用户 %d 不存在", goodsOrder.Uid)
return fmt.Errorf("用户不存在: %w", err)
}
var orderCommodities []ErpOrderCommodity
var totalAmount, totalRetailPrice, totalSalesProfit, totalStaffProfit float64
var totalCount int32
1、小程序商城下单流程优化，支持单笔订单多个商品；
2025-09-11 10:06:20 +00:00
for _, commodity := range commodities {
var goods Goods
err := NewGoodsQuerySet(tx).GoodsIdEq(commodity.GoodsId).One(&goods)
if err != nil {
logger.Errorf("商品不存在: %d, err: %v", commodity.GoodsId, err)
tx.Rollback()
return err
}
1、删除不再需要的erp零售相关接口（前端直接调用的erp后端代码接口）； 2、修改商城下单和付款回调接口；
2025-08-29 10:33:35 +00:00
1、小程序商城下单流程优化，支持单笔订单多个商品；
2025-09-11 10:06:20 +00:00
// 选择库存
stock, err := SelectDeliveryStock(goods.ErpCommodityId, goodsOrder.NearestStoreId)
if err != nil {
tx.Rollback()
logger.Infof("商品 %d 无库存: %v", goods.ErpCommodityId, err)
return fmt.Errorf("商品 %d 无库存: %v", goods.ErpCommodityId, err)
}
1、删除不再需要的erp零售相关接口（前端直接调用的erp后端代码接口）； 2、修改商城下单和付款回调接口；
2025-08-29 10:33:35 +00:00
1、小程序商城下单流程优化，支持单笔订单多个商品；
2025-09-11 10:06:20 +00:00
// 扣减库存
err = tx.Table("erp_stock_commodity").Where("id = ?", stock.ID).
Updates(map[string]interface{}{"state": SoldOut, "updated_at": time.Now()}).Error
if err != nil {
tx.Rollback()
return fmt.Errorf("erp_stock_commodity 扣减库存失败: %v", err)
}
err = tx.Table("erp_stock").Where("store_id = ? AND erp_commodity_id = ? AND count > 0",
stock.StoreId, stock.ErpCommodityId).Updates(map[string]interface{}{
"count": gorm.Expr("count - ?", commodity.Quantity),
1、删除不再需要的erp零售相关接口（前端直接调用的erp后端代码接口）； 2、修改商城下单和付款回调接口；
2025-08-29 10:33:35 +00:00
"updated_at": time.Now(),
1、小程序商城下单流程优化，支持单笔订单多个商品；
2025-09-11 10:06:20 +00:00
}).Error
if err != nil {
tx.Rollback()
return fmt.Errorf("erp_stock 扣减库存失败: %v", err)
}
1、删除不再需要的erp零售相关接口（前端直接调用的erp后端代码接口）； 2、修改商城下单和付款回调接口；
2025-08-29 10:33:35 +00:00
1、小程序商城下单流程优化，支持单笔订单多个商品；
2025-09-11 10:06:20 +00:00
// 金额计算
receivedAmount := float64(commodity.Quantity) * float64(goods.PriceRm/100)
salesProfit := receivedAmount - stock.WholesalePrice*float64(commodity.Quantity)
staffProfit := receivedAmount - (stock.WholesalePrice+stock.StaffCostPrice)*float64(commodity.Quantity)
orderCommodities = append(orderCommodities, ErpOrderCommodity{
ErpCategoryId: stock.ErpCategoryId,
ErpCategoryName: stock.ErpCategoryName,
ErpCommodityId: stock.ErpCommodityId,
ErpCommodityName: stock.ErpCommodityName,
ErpSupplierId: stock.ErpSupplierId,
ErpSupplierName: stock.ErpSupplierName,
IMEIType: stock.IMEIType,
IMEI: "",
PresentType: 1,
RetailPrice: stock.RetailPrice,
SalePrice: float64(goods.PriceRm / 100),
Count: int32(commodity.Quantity),
Amount: receivedAmount,
ReceivedAmount: receivedAmount,
StaffCostPrice: stock.StaffCostPrice,
WholesalePrice: stock.WholesalePrice,
SalesProfit: salesProfit,
StaffProfit: staffProfit,
ErpStockCommodityID: fmt.Sprintf("%d", stock.ID),
})
totalAmount += receivedAmount
totalRetailPrice += stock.RetailPrice * float64(commodity.Quantity)
totalSalesProfit += salesProfit
totalStaffProfit += staffProfit
totalCount += int32(commodity.Quantity)
}
1、删除不再需要的erp零售相关接口（前端直接调用的erp后端代码接口）； 2、修改商城下单和付款回调接口；
2025-08-29 10:33:35 +00:00
1、小程序商城下单流程优化，支持单笔订单多个商品；
2025-09-11 10:06:20 +00:00
// 创建ERP订单
1、删除不再需要的erp零售相关接口（前端直接调用的erp后端代码接口）； 2、修改商城下单和付款回调接口；
2025-08-29 10:33:35 +00:00
nowTime := time.Now()
order := ErpOrder{
BillSn: NewErpBillSn(),
GoodsOrderId: goodsOrder.OrderId,
RetailType: RetailTypeSale,
Uid: int(goodsOrder.Uid),
UserType: int(user.MemberLevel),
Tel: user.Tel,
1、小程序商城下单流程优化，支持单笔订单多个商品；
2025-09-11 10:06:20 +00:00
StoreId: goodsOrder.NearestStoreId,
StoreName: goodsOrder.NearestStoreName,
1、删除不再需要的erp零售相关接口（前端直接调用的erp后端代码接口）； 2、修改商城下单和付款回调接口；
2025-08-29 10:33:35 +00:00
MakerId: SysUserIdByAdmin,
MakerName: SysUserNameByAdmin,
MakerTime: nowTime,
AuditorId: SysUserIdByAdmin,
AuditorName: SysUserNameByAdmin,
AuditTime: &nowTime,
State: ErpOrderStateAudited,
TotalRetailPrice: totalRetailPrice,
TotalAmount: totalAmount,
TotalCount: totalCount,
TotalSalesProfit: totalSalesProfit,
TotalStaffProfit: totalStaffProfit,
1、小程序商城下单流程优化，支持单笔订单多个商品；
2025-09-11 10:06:20 +00:00
PayStatus: HavePaid,
IsPrint: NoPrint,
1、删除不再需要的erp零售相关接口（前端直接调用的erp后端代码接口）； 2、修改商城下单和付款回调接口；
2025-08-29 10:33:35 +00:00
PrintCount: 0,
}
1、小程序商城下单流程优化，支持单笔订单多个商品；
2025-09-11 10:06:20 +00:00
if err := tx.Create(&order).Error; err != nil {
1、删除不再需要的erp零售相关接口（前端直接调用的erp后端代码接口）； 2、修改商城下单和付款回调接口；
2025-08-29 10:33:35 +00:00
tx.Rollback()
1、小程序商城下单流程优化，支持单笔订单多个商品；
2025-09-11 10:06:20 +00:00
return fmt.Errorf("创建ERP订单失败: %v", err)
1、删除不再需要的erp零售相关接口（前端直接调用的erp后端代码接口）； 2、修改商城下单和付款回调接口；
2025-08-29 10:33:35 +00:00
}
1、小程序商城下单流程优化，支持单笔订单多个商品；
2025-09-11 10:06:20 +00:00
// 绑定商品明细
1、删除不再需要的erp零售相关接口（前端直接调用的erp后端代码接口）； 2、修改商城下单和付款回调接口；
2025-08-29 10:33:35 +00:00
for i := range orderCommodities {
orderCommodities[i].ErpOrderId = order.ID
1、小程序商城下单流程优化，支持单笔订单多个商品；
2025-09-11 10:06:20 +00:00
if err := tx.Create(&orderCommodities[i]).Error; err != nil {
1、删除不再需要的erp零售相关接口（前端直接调用的erp后端代码接口）； 2、修改商城下单和付款回调接口；
2025-08-29 10:33:35 +00:00
tx.Rollback()
1、小程序商城下单流程优化，支持单笔订单多个商品；
2025-09-11 10:06:20 +00:00
return fmt.Errorf("创建ERP商品明细失败: %v", err)
1、删除不再需要的erp零售相关接口（前端直接调用的erp后端代码接口）； 2、修改商城下单和付款回调接口；
2025-08-29 10:33:35 +00:00
}
}
1、小程序商城下单流程优化，支持单笔订单多个商品；
2025-09-11 10:06:20 +00:00
if err := tx.Commit().Error; err != nil {
1、删除不再需要的erp零售相关接口（前端直接调用的erp后端代码接口）； 2、修改商城下单和付款回调接口；
2025-08-29 10:33:35 +00:00
return fmt.Errorf("提交事务失败: %v", err)
}
logger.Infof("leave CreateErpOrder")
return nil
}
Reference in New Issue Copy Permalink