diff --git a/client/warehouse.go b/client/warehouse.go index 9c4bbfd..3e4a54d 100644 --- a/client/warehouse.go +++ b/client/warehouse.go @@ -203,9 +203,9 @@ func (w Warehouse) UpdateStatusWarehousePendingInactive(p model.UpdateStatusWare return nil } -// MigrationSellyMall ... -func (w Warehouse) MigrationSellyMall() error { - _, err := natsio.GetServer().Request(subject.Warehouse.MigrationIsSellyMall, toBytes("")) +// UpdateIsSellyMall ... +func (w Warehouse) UpdateIsSellyMall(p model.UpdateIsSellyMallRequest) error { + msg, err := natsio.GetServer().Request(subject.Warehouse.UpdateIsSellyMall, toBytes(p)) if err != nil { return err } @@ -214,9 +214,11 @@ func (w Warehouse) MigrationSellyMall() error { Error string `json:"error"` } + if err = json.Unmarshal(msg.Data, &r); err != nil { + return fmt.Errorf("nats: update_is_selly_mall %v", err) + } if r.Error != "" { return errors.New(r.Error) } - return nil } diff --git a/model/warehouse_request.go b/model/warehouse_request.go index c1dac9c..d211345 100644 --- a/model/warehouse_request.go +++ b/model/warehouse_request.go @@ -120,6 +120,11 @@ type UpdateStatusWarehousePendingInactiveRequest struct { Warehouses []UpdateStatusWarehousePendingInactive `json:"warehouses"` } +// UpdateIsSellyMallRequest ... +type UpdateIsSellyMallRequest struct { + SupplierID string `json:"supplier"` +} + // UpdateStatusWarehousePendingInactive ... type UpdateStatusWarehousePendingInactive struct { WarehouseID string `json:"warehouse"` diff --git a/subject/warehouse.go b/subject/warehouse.go index 34e49c2..9131f07 100644 --- a/subject/warehouse.go +++ b/subject/warehouse.go @@ -29,7 +29,7 @@ var Warehouse = struct { GetWarehouses string UpdateORDeliveryStatus string UpdateStatusWarehousePendingInactive string - MigrationIsSellyMall string + UpdateIsSellyMall string }{ CreateWarehouseIntoServiceSupplier: getWarehouseValue("create_warehouse_into_service_supplier"), UpdateWarehouseIntoServiceSupplier: getWarehouseValue("update_warehouse_into_service_supplier"), @@ -51,5 +51,5 @@ var Warehouse = struct { GetWarehouses: getWarehouseValue("get_warehouses"), UpdateORDeliveryStatus: getWarehouseValue("update_or_delivery_status"), UpdateStatusWarehousePendingInactive: getWarehouseValue("update_status_warehouse_pending_inactive"), - MigrationIsSellyMall: getWarehouseValue("migration_is_selly_mall"), + UpdateIsSellyMall: getWarehouseValue("update_is_selly_mall"), }