wangdian

upstream/wangdian/wd_order.go

@@ -74,7 +74,8 @@ type TradePushRes struct {
 	ChgCount int    `json:"chg_count"`
 }
 
-/**
+/*
+*
 创建原始订单
 */
 func (s *order) TradePush(ctx context.Context, req *TradePushReq) (res *TradePushRes, err error) {
@@ -246,7 +247,8 @@ type TradeQueryRes struct {
 	} `json:"stockout_list"`
 }
 
-/**
+/*
+*
 查询销售出库单
 */
 func (s *order) TradeQuery(ctx context.Context, req *TradeQueryReq) (res *TradeQueryRes, err error) {
@@ -423,7 +425,8 @@ type SalesTradeQueryRes struct {
 	} `json:"trades"`
 }
 
-/**
+/*
+*
 查询订单管理
 */
 func (s *order) SalesTradeQuery(ctx context.Context, req *SalesTradeQueryReq) (res *SalesTradeQueryRes, err error) {
@@ -526,7 +529,8 @@ type SalesApiTradeQueryRes struct {
 	} `json:"trade_list"`
 }
 
-/**
+/*
+*
 查询原始订单
 */
 func (s *order) SalesApiTradeQuery(ctx context.Context, req *SalesApiTradeQueryReq) (res *SalesApiTradeQueryRes, err error) {
@@ -568,7 +572,8 @@ type LogisticsMultiQueryRes struct {
 	} `json:"logistics_multi_list"`
 }
 
-/**
+/*
+*
 查询多物流单号
 */
 func (s *order) LogisticsMultiQuery(ctx context.Context, req *LogisticsMultiQueryReq) (res *LogisticsMultiQueryRes, err error) {
@@ -580,3 +585,70 @@ func (s *order) LogisticsMultiQuery(ctx context.Context, req *LogisticsMultiQuer
 	err = gjson.New(result).Scan(&res)
 	return
 }
+
+type LogisticsSyncQueryReq struct {
+	Limit  int    `json:"limit"`   // 获取条数 100
+	ShopNo string `json:"shop_no"` //店铺编号
+}
+
+type LogisticsSyncQueryRes struct {
+	Code    int    `json:"code"`
+	Message string `json:"message"`
+	Trades  []struct {
+		RecId            string `json:"rec_id"`
+		ShopNo           string `json:"shop_no"`
+		Tid              string `json:"tid"`
+		LogisticsType    string `json:"logistics_type"`
+		LogisticsNo      string `json:"logistics_no"`
+		DeliveryTerm     string `json:"delivery_term"`
+		ConsignTime      string `json:"consign_time"`
+		Oids             string `json:"oids"`
+		IsPartSync       string `json:"is_part_sync"`
+		PlatformId       string `json:"platform_id"`
+		TradeId          string `json:"trade_id"`
+		LogisticsNameErp string `json:"logistics_name_erp"`
+		LogisticsCodeErp string `json:"logistics_code_erp"`
+		LogisticsName    string `json:"logistics_name"`
+	} `json:"trades"`
+}
+
+/*
+*查询物流同步
+ */
+func (s *order) LogisticsSyncQuery(ctx context.Context, req *LogisticsSyncQueryReq) (res *LogisticsSyncQueryRes, err error) {
+
+	result, err := post(ctx, "/openapi2/logistics_sync_query.php", req)
+	if nil != err {
+		return
+	}
+	err = gjson.New(result).Scan(&res)
+	return
+}
+
+type LogisticsSyncAckReq struct {
+	RecId   string `json:"rec_id"`
+	Status  string `json:"status"`
+	Message string `json:"message"`
+}
+
+type LogisticsSyncAckRes struct {
+	Code    int    `json:"code"`
+	Message string `json:"message"`
+	Errors  []struct {
+		RecId string `json:"rec_id"`
+		Error string `json:"error"`
+	} `json:"errors"`
+}
+
+/*
+物流同步回写
+*/
+func (s *order) LogisticsSyncAck(ctx context.Context, req []*LogisticsSyncAckReq) (res *LogisticsSyncAckRes, err error) {
+
+	result, err := post(ctx, "/openapi2/logistics_sync_ack.php", req)
+	if nil != err {
+		return
+	}
+	err = gjson.New(result).Scan(&res)
+	return
+}