订单妥投

supply/channel/mq.go

@@ -11,6 +11,7 @@ const (
 	MqSubscribeNameSkuChange      = "sku_change"       // sku信息变动
 	MqSubscribeNameOrderSplit     = "order_split"      // 订单拆单
 	MqSubscribeNameOrderStockOut  = "order_stock_out"  // 订单出库
+	MqSubscribeNameOrderDelivered = "order_delivered"  // 订单签收
 	MqSubscribeNameOrderFinish    = "order_finish"     // 订单完成
 	MqSubscribeNameOrderCancel    = "order_cancel"     // 订单取消
 	MqSubscribeNameAfsDeliver     = "afs_deliver"      // 需要客户发货

supply/channel/order.go

@@ -205,6 +205,7 @@ type OrderItem struct {
 	FreightFee     decimal.Decimal `json:"freightFee"`
 	OrderFee       decimal.Decimal `json:"orderFee"`
 	LadingBillAt   int64           `json:"ladingBillAt"`
+	DeliveredAt    int64           `json:"deliveredAt"`
 	FinishAt       int64           `json:"finishAt"`
 	Status         uint            `json:"status"`
 	CancelStatus   uint            `json:"cancelStatus"`

supply/order.go

@@ -104,6 +104,22 @@ func (o *order) StockOut(ctx context.Context, args ArgsOrderStockOut) (err error
 //	return
 //}
 
+type ArgsOrderDelivered struct {
+	Source        source // 商品来源
+	SourceOrderSn string // 供应商订单号
+}
+
+// Delivered @Title 订单签收/妥投
+func (o *order) Delivered(ctx context.Context, args ArgsOrderDelivered) (err error) {
+	xClient, err := client.GetClient(o)
+	if err != nil {
+		return
+	}
+	reply := 0
+	err = xClient.Call(ctx, "Delivered", args, &reply)
+	return
+}
+
 type ArgsOrderFinish struct {
 	Source        source // 商品来源
 	SourceOrderSn string // 供应商订单号