From b82c01759625d1a6a3f4813e7f3eef579a0f3b6b Mon Sep 17 00:00:00 2001 From: Sinh Date: Fri, 19 Aug 2022 11:47:34 +0700 Subject: [PATCH] add cancel OR func --- client/warehouse.go | 21 +++++++++++++++++++-- 1 file changed, 19 insertions(+), 2 deletions(-) diff --git a/client/warehouse.go b/client/warehouse.go index f806bc5..d96d440 100644 --- a/client/warehouse.go +++ b/client/warehouse.go @@ -43,8 +43,25 @@ func (w Warehouse) UpdateOutboundRequestLogisticInfo(p model.UpdateOutboundReque return err } var r struct { - Data *model.OutboundRequestResponse `json:"data"` - Error string `json:"error"` + Error string `json:"error"` + } + if err = json.Unmarshal(msg.Data, &r); err != nil { + return err + } + if r.Error != "" { + return errors.New(r.Error) + } + return nil +} + +// CancelOutboundRequest ... +func (w Warehouse) CancelOutboundRequest(p model.CancelOutboundRequest) error { + msg, err := natsio.GetServer().Request(subject.WarehouseCancelOutboundRequest, toBytes(p)) + if err != nil { + return err + } + var r struct { + Error string `json:"error"` } if err = json.Unmarshal(msg.Data, &r); err != nil { return err