From 08ba9559a929722f2e2b1e7d57b5efc0b486c30e Mon Sep 17 00:00:00 2001
From: kanade <kanade@kumo.work>
Date: Mon, 21 Apr 2025 14:59:42 +0800
Subject: [PATCH] =?UTF-8?q?feat(shipment):=20=E6=B7=BB=E5=8A=A0=E5=90=8C?=
 =?UTF-8?q?=E6=AD=A5=E5=95=86=E5=93=81=E5=8A=9F=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 新增 ArgsSaleProductSync 结构体用于同步商品请求参数
- 在 saleProduct 服务中实现 Sync 方法，用于同步商品数据
- 通过 RPC 调用远程服务的 Sync 方法来实现商品同步
---
 erp/shipment/modify/saleProduct.go | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/erp/shipment/modify/saleProduct.go b/erp/shipment/modify/saleProduct.go
index 6678f3c..e7698c6 100644
--- a/erp/shipment/modify/saleProduct.go
+++ b/erp/shipment/modify/saleProduct.go
@@ -247,3 +247,18 @@ func (s *saleProduct) Delete(ctx context.Context, args ArgsSaleProductDelete) (e
 	reply := 0
 	return xClient.Call(ctx, "Delete", args, &reply)
 }
+
+type ArgsSaleProductSync struct {
+	ModifyId               int64   // 订舱修改单id
+	ShipmentSaleProductIds []int64 // 出运产品id
+}
+
+// Sync @TITLE 同步商品
+func (s *saleProduct) Sync(ctx context.Context, args ArgsSaleProductSync) (err error) {
+	xClient, err := client.GetClient(s)
+	if err != nil {
+		return
+	}
+	reply := 0
+	return xClient.Call(ctx, "Sync", args, &reply)
+}