diff --git a/client/warehouse.go b/client/warehouse.go index 3e4a54d..9993fd7 100644 --- a/client/warehouse.go +++ b/client/warehouse.go @@ -146,6 +146,25 @@ func (w Warehouse) GetConfigByWarehouseID(warehouseID string) (*model.WarehouseC return r.Data, nil } +// GetListConfig ... +func (w Warehouse) GetListConfig(req model.GetListWarehouseConfigReq) ([]*model.WarehouseConfiguration, error) { + msg, err := natsio.GetServer().Request(subject.Warehouse.GetListWarehouseConfig, toBytes(req)) + if err != nil { + return nil, err + } + var r struct { + Data []*model.WarehouseConfiguration `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 +} + // GetWarehouses ... func (w Warehouse) GetWarehouses(p model.GetWarehousesRequest) (*model.GetWarehousesResponse, error) { msg, err := natsio.GetServer().Request(subject.Warehouse.GetWarehouses, toBytes(p)) diff --git a/model/warehouse_request.go b/model/warehouse_request.go index 905d15a..2bec44b 100644 --- a/model/warehouse_request.go +++ b/model/warehouse_request.go @@ -131,3 +131,7 @@ type UpdateStatusWarehousePendingInactive struct { WarehouseID string `json:"warehouse"` PendingInactive bool `json:"pendingInactive"` } + +type GetListWarehouseConfigReq struct { + ConfigPartnerCode string `json:"configPartnerCode"` +} diff --git a/model/warehouse_response.go b/model/warehouse_response.go index 55d4f44..02c3001 100644 --- a/model/warehouse_response.go +++ b/model/warehouse_response.go @@ -182,3 +182,9 @@ type GetWarehousesResponse struct { Limit int64 `json:"limit"` List []WarehouseInfo `json:"list"` } + +type GetListWarehouseConfigRes struct { + Total int64 `json:"total"` + Limit int64 `json:"limit"` + List []WarehouseConfiguration `json:"list"` +} diff --git a/subject/product.go b/subject/product.go index 39c5a2b..5177fea 100644 --- a/subject/product.go +++ b/subject/product.go @@ -8,15 +8,17 @@ func getProductValue(val string) string { } var Product = struct { - ApplyRequest string - CreateRequestStep string - ProcessApplyRequest string - RequestChangeStatus string - WebhookStockUpdate string + ApplyRequest string + CreateRequestStep string + ProcessApplyRequest string + RequestChangeStatus string + WebhookStockUpdate string // WebhookStockUpdate Kiotviet queue + OPWebhookStockUpdate string // OPWebhookStockUpdate Onpoint queue }{ - ApplyRequest: getProductValue("apply_request"), - CreateRequestStep: getProductValue("create_request_step"), - ProcessApplyRequest: getProductValue("process_apply_request"), - RequestChangeStatus: getProductValue("request_change_status"), - WebhookStockUpdate: getProductValue("webhook_stock_update"), + ApplyRequest: getProductValue("apply_request"), + CreateRequestStep: getProductValue("create_request_step"), + ProcessApplyRequest: getProductValue("process_apply_request"), + RequestChangeStatus: getProductValue("request_change_status"), + WebhookStockUpdate: getProductValue("webhook_stock_update"), + OPWebhookStockUpdate: getProductValue("op_webhook_stock_update"), } diff --git a/subject/warehouse.go b/subject/warehouse.go index 9cc6f9c..f5b2873 100644 --- a/subject/warehouse.go +++ b/subject/warehouse.go @@ -34,6 +34,7 @@ var Warehouse = struct { UpdateIsSellyMall string UpdateWarehouseConfig string BulkWriteWarehouseConfig string + GetListWarehouseConfig string }{ SyncWarehouseIntoServiceSupplier: getWarehouseValue("sync_warehouse_into_service_supplier"), CreateWarehouseIntoServiceSupplier: getWarehouseValue("create_warehouse_into_service_supplier"), @@ -60,4 +61,5 @@ var Warehouse = struct { UpdateIsSellyMall: getWarehouseValue("update_is_selly_mall"), UpdateWarehouseConfig: getWarehouseValue("update_warehouse_config"), BulkWriteWarehouseConfig: getWarehouseValue("bulk_write_warehouse_config"), + GetListWarehouseConfig: getWarehouseValue("get_list_warehouse_config"), }