From 28178e0c31a477403054968c135919fbc3f45b06 Mon Sep 17 00:00:00 2001 From: Sinh Date: Tue, 10 Oct 2023 16:11:19 +0700 Subject: [PATCH] add func update warehouse config --- client/warehouse_dao.go | 19 +++++++++++++++++++ model/common_request.go | 6 ++++++ subject/warehouse.go | 2 ++ 3 files changed, 27 insertions(+) diff --git a/client/warehouse_dao.go b/client/warehouse_dao.go index 56c046f..f2564ed 100644 --- a/client/warehouse_dao.go +++ b/client/warehouse_dao.go @@ -3,6 +3,7 @@ package client import ( "encoding/json" "errors" + "git.selly.red/Selly-Modules/natsio" "git.selly.red/Selly-Modules/natsio/model" "git.selly.red/Selly-Modules/natsio/subject" @@ -83,3 +84,21 @@ func (w Warehouse) FindByCondition(p model.FindWithCondition) ([]*model.Warehous } return r.Data, nil } + +// UpdateWarehouseConfig ... +func (w Warehouse) UpdateWarehouseConfig(p model.UpdatePayload) error { + msg, err := natsio.GetServer().Request(subject.Warehouse.UpdateWarehouseConfig, bsonToBytes(p)) + if err != nil { + return err + } + var r struct { + 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 +} diff --git a/model/common_request.go b/model/common_request.go index 447ae57..a36f30c 100644 --- a/model/common_request.go +++ b/model/common_request.go @@ -43,3 +43,9 @@ type RequestCondition struct { Page int64 `json:"page"` Limit int64 `json:"limit"` } + +type UpdatePayload struct { + Conditions interface{} `json:"conditions"` + Payload interface{} `json:"payload"` + Opts []*options.UpdateOptions `json:"opts"` +} diff --git a/subject/warehouse.go b/subject/warehouse.go index 9131f07..47a8be4 100644 --- a/subject/warehouse.go +++ b/subject/warehouse.go @@ -30,6 +30,7 @@ var Warehouse = struct { UpdateORDeliveryStatus string UpdateStatusWarehousePendingInactive string UpdateIsSellyMall string + UpdateWarehouseConfig string }{ CreateWarehouseIntoServiceSupplier: getWarehouseValue("create_warehouse_into_service_supplier"), UpdateWarehouseIntoServiceSupplier: getWarehouseValue("update_warehouse_into_service_supplier"), @@ -52,4 +53,5 @@ var Warehouse = struct { UpdateORDeliveryStatus: getWarehouseValue("update_or_delivery_status"), UpdateStatusWarehousePendingInactive: getWarehouseValue("update_status_warehouse_pending_inactive"), UpdateIsSellyMall: getWarehouseValue("update_is_selly_mall"), + UpdateWarehouseConfig: getWarehouseValue("update_warehouse_config"), }