Merge branch 'kiotviet' into develop

client/warehouse_dao.go

@@ -102,3 +102,21 @@ func (w Warehouse) UpdateWarehouseConfig(p model.UpdatePayload) error {
 	}
 	return nil
 }
+
+// BulkWriteWarehouseConfig ...
+func (w Warehouse) BulkWriteWarehouseConfig(p model.UpdatePayload) error {
+	msg, err := natsio.GetServer().Request(subject.Warehouse.BulkWriteWarehouseConfig, 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
+}

subject/warehouse.go

@@ -33,6 +33,7 @@ var Warehouse = struct {
 	UpdateStatusWarehousePendingInactive string
 	UpdateIsSellyMall                    string
 	UpdateWarehouseConfig                string
+	BulkWriteWarehouseConfig             string
 }{
 	SyncWarehouseIntoServiceSupplier: getWarehouseValue("sync_warehouse_into_service_supplier"),
 	CreateWarehouseIntoServiceSupplier: getWarehouseValue("create_warehouse_into_service_supplier"),
@@ -58,4 +59,5 @@ var Warehouse = struct {
 	UpdateStatusWarehousePendingInactive: getWarehouseValue("update_pending_active_product_by_warehouse_ids"),
 	UpdateIsSellyMall:                    getWarehouseValue("update_is_selly_mall"),
 	UpdateWarehouseConfig:                getWarehouseValue("update_warehouse_config"),
+	BulkWriteWarehouseConfig:             getWarehouseValue("bulk_write_warehouse_config"),
 }