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
+}

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"`
+}

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"),
 }