From f58dfd42910fd18f710d12a601f6ade087342a95 Mon Sep 17 00:00:00 2001 From: kingphon Date: Fri, 22 Sep 2023 14:47:16 +0700 Subject: [PATCH] add-migration --- client/warehouse.go | 18 ++++++++++++++++++ subject/warehouse.go | 2 ++ 2 files changed, 20 insertions(+) diff --git a/client/warehouse.go b/client/warehouse.go index 61639bb..9c4bbfd 100644 --- a/client/warehouse.go +++ b/client/warehouse.go @@ -202,3 +202,21 @@ func (w Warehouse) UpdateStatusWarehousePendingInactive(p model.UpdateStatusWare } return nil } + +// MigrationSellyMall ... +func (w Warehouse) MigrationSellyMall() error { + _, err := natsio.GetServer().Request(subject.Warehouse.MigrationIsSellyMall, toBytes("")) + if err != nil { + return err + } + + var r struct { + Error string `json:"error"` + } + + if r.Error != "" { + return errors.New(r.Error) + } + + return nil +} diff --git a/subject/warehouse.go b/subject/warehouse.go index 4a63cc0..34e49c2 100644 --- a/subject/warehouse.go +++ b/subject/warehouse.go @@ -29,6 +29,7 @@ var Warehouse = struct { GetWarehouses string UpdateORDeliveryStatus string UpdateStatusWarehousePendingInactive string + MigrationIsSellyMall string }{ CreateWarehouseIntoServiceSupplier: getWarehouseValue("create_warehouse_into_service_supplier"), UpdateWarehouseIntoServiceSupplier: getWarehouseValue("update_warehouse_into_service_supplier"), @@ -50,4 +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"), }