From aab1103fc809404f66b571f60802ed78ac6eb82a Mon Sep 17 00:00:00 2001
From: Sinh <luuvansinh555@gmail.com>
Date: Fri, 30 Sep 2022 10:32:33 +0700
Subject: [PATCH] define warehouse method

---
 client/warehouse.go         | 19 +++++++++++++++++++
 model/warehouse_request.go  | 11 +++++++++++
 model/warehouse_response.go | 27 +++++++++++++++++++++++++++
 subject/warehouse.go        |  2 ++
 4 files changed, 59 insertions(+)

diff --git a/client/warehouse.go b/client/warehouse.go
index fdb70b8..5ae07db 100644
--- a/client/warehouse.go
+++ b/client/warehouse.go
@@ -144,3 +144,22 @@ func (w Warehouse) GetConfigByWarehouseID(warehouseID string) (*model.WarehouseC
 	}
 	return r.Data, nil
 }
+
+// GetWarehouses ...
+func (w Warehouse) GetWarehouses(p model.GetWarehousesRequest) (*model.GetWarehousesResponse, error) {
+	msg, err := natsio.GetServer().Request(subject.Warehouse.GetWarehouses, toBytes(p))
+	if err != nil {
+		return nil, err
+	}
+	var r struct {
+		Data  *model.GetWarehousesResponse `json:"data"`
+		Error string                       `json:"error"`
+	}
+	if err = json.Unmarshal(msg.Data, &r); err != nil {
+		return nil, err
+	}
+	if r.Error != "" {
+		return nil, errors.New(r.Error)
+	}
+	return r.Data, nil
+}
diff --git a/model/warehouse_request.go b/model/warehouse_request.go
index b546725..fc52b78 100644
--- a/model/warehouse_request.go
+++ b/model/warehouse_request.go
@@ -80,3 +80,14 @@ type SupplierIsClosed struct {
 	Supplier string `json:"supplier"`
 	IsClosed bool   `json:"isClosed"`
 }
+
+// GetWarehousesRequest ...
+type GetWarehousesRequest struct {
+	Keyword      string `json:"keyword"`
+	Status       string `json:"status"`
+	Supplier     string `json:"supplier"`
+	BusinessType string `json:"businessType"`
+
+	Page  int64 `json:"page"`
+	Limit int64 `json:"limit"`
+}
diff --git a/model/warehouse_response.go b/model/warehouse_response.go
index f2d60a9..88ba2f1 100644
--- a/model/warehouse_response.go
+++ b/model/warehouse_response.go
@@ -135,3 +135,30 @@ type WarehouseNatsResponse struct {
 	CreatedAt      time.Time                 `json:"createdAt"`
 	UpdatedAt      time.Time                 `json:"updatedAt"`
 }
+
+// WarehouseInfo ...
+type WarehouseInfo struct {
+	ID           string                    `json:"_id"`
+	Name         string                    `json:"name"`
+	BusinessType string                    `json:"businessType"`
+	Status       string                    `json:"status"`
+	Slug         string                    `json:"slug"`
+	Supplier     WarehouseSupplierInfo     `json:"supplier"`
+	Location     ResponseWarehouseLocation `json:"location"`
+	Contact      ResponseWarehouseContact  `json:"contact"`
+	CreatedAt    string                    `json:"createdAt"`
+	UpdatedAt    string                    `json:"updatedAt"`
+}
+
+// WarehouseSupplierInfo ...
+type WarehouseSupplierInfo struct {
+	ID   string `json:"_id"`
+	Name string `json:"name"`
+}
+
+// GetWarehousesResponse ...
+type GetWarehousesResponse struct {
+	Total int64           `json:"total"`
+	Limit int64           `json:"limit"`
+	List  []WarehouseInfo `json:"list"`
+}
diff --git a/subject/warehouse.go b/subject/warehouse.go
index a0480ae..378e1a8 100644
--- a/subject/warehouse.go
+++ b/subject/warehouse.go
@@ -21,6 +21,7 @@ var Warehouse = struct {
 	AfterUpdateWarehouse          string
 	AfterCreateWarehouse          string
 	UpdateIsClosedSupplier        string
+	GetWarehouses                 string
 }{
 	AfterCreateWarehouse:          getWarehouseValue("after_create_warehouse"),
 	AfterUpdateWarehouse:          getWarehouseValue("after_update_warehouse"),
@@ -36,4 +37,5 @@ var Warehouse = struct {
 	Distinct:                      getWarehouseValue("distinct"),
 	Count:                         getWarehouseValue("count"),
 	UpdateIsClosedSupplier:        getWarehouseValue("update_is_closed_supplier"),
+	GetWarehouses:                 getWarehouseValue("get_warehouses"),
 }