Merge pull request 'fix-holiday-product_merge_dev' (#131) from fix-holiday-product_merge_dev into develop

Reviewed-on: #131

client/warehouse.go

@@ -182,3 +182,23 @@ func (w Warehouse) UpdateORDeliveryStatus(p model.WarehouseORUpdateDeliveryStatu
 	}
 	return nil
 }
+
+// UpdatePendingActiveProductByWarehouseIDs ...
+func (w Warehouse) UpdatePendingActiveProductByWarehouseIDs(p model.UpdatePendingActiveProductRequest) error {
+	msg, err := natsio.GetServer().Request(subject.Warehouse.UpdatePendingActiveProductByWarehouseIDs, toBytes(p))
+	if err != nil {
+		return err
+	}
+
+	var r struct {
+		Error string `json:"error"`
+	}
+
+	if err = json.Unmarshal(msg.Data, &r); err != nil {
+		return fmt.Errorf("nats: update_pending_active_product_by_warehouse_ids %v", err)
+	}
+	if r.Error != "" {
+		return errors.New(r.Error)
+	}
+	return nil
+}

model/warehouse_request.go

@@ -114,3 +114,8 @@ type WarehouseORUpdateDeliveryStatus struct {
 	OrderID        string `json:"orderId"`
 	DeliveryStatus string `json:"deliveryStatus"`
 }
+
+// UpdatePendingActiveProductRequest ...
+type UpdatePendingActiveProductRequest struct {
+	WarehouseIDs []string `json:"warehouseIDs"`
+}

subject/warehouse.go

@@ -1,6 +1,8 @@
 package subject
 
-import "fmt"
+import (
+	"fmt"
+)
 
 func getWarehouseValue(val string) string {
 	return fmt.Sprintf("%s.%s", prefixes.Warehouse, val)
@@ -28,6 +30,7 @@ var Warehouse = struct {
 	UpdateIsClosedSupplier             string
 	GetWarehouses                      string
 	UpdateORDeliveryStatus             string
+	UpdatePendingActiveProductByWarehouseIDs string
 }{
 	SyncWarehouseIntoServiceSupplier: getWarehouseValue("sync_warehouse_into_service_supplier"),
 	CreateWarehouseIntoServiceSupplier: getWarehouseValue("create_warehouse_into_service_supplier"),
@@ -50,4 +53,5 @@ var Warehouse = struct {
 	UpdateIsClosedSupplier:             getWarehouseValue("update_is_closed_supplier"),
 	GetWarehouses:                      getWarehouseValue("get_warehouses"),
 	UpdateORDeliveryStatus:             getWarehouseValue("update_or_delivery_status"),
+	UpdatePendingActiveProductByWarehouseIDs: getWarehouseValue("update_pending_active_product_by_warehouse_ids"),
 }