client/order.go

@@ -119,3 +119,22 @@ func (o Order) GetSupplierOrders(p model.OrderSupplierQuery) (*model.SupplierOrd
 	}
 	return &r.Data, nil
 }
+
+// GetUserTotalWarningOrder ...
+func (o Order) GetUserTotalWarningOrder(p model.OrderGetTotalWarningPayload) (*model.OrderGetTotalWarningRes, error) {
+	msg, err := natsio.GetServer().Request(subject.Order.GetUserTotalWarningOrders, toBytes(p))
+	if err != nil {
+		return nil, err
+	}
+	var r struct {
+		Data  model.OrderGetTotalWarningRes `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
+}

model/order_request.go

@@ -49,3 +49,7 @@ type OrderSupplierQuery struct {
 	SupplierID   string   `json:"supplierId"`
 	WarehouseIDs []string `json:"warehouseIDs"`
 }
+
+type OrderGetTotalWarningPayload struct {
+	UserID string `json:"userId"`
+}

model/order_response.go

@@ -33,3 +33,9 @@ type SupplierOrderDelivery struct {
 	Status  string `json:"status" enums:"waiting_to_confirm,waiting_to_pick,picking,picked,delay_pickup,pickup_failed,delivering,delay_delivery,delivered,cancelled,delivery_failed,waiting_to_return,returning,delay_return,compensation,returned"`
 	TPLCode string `json:"tplCode" enums:"SLY,GHTK,GHN,SSC,SPY,VTP,SE,NTL,BEST"`
 }
+
+// OrderGetTotalWarningRes ...
+type OrderGetTotalWarningRes struct {
+	UserID             string `json:"userId"`
+	TotalWarningOrders int64  `json:"totalWarningOrders"`
+}

subject/order.go

@@ -8,6 +8,7 @@ func getOrderValue(val string) string {
 
 var Order = struct {
 	UpdateORStatus            string
+	GetUserTotalWarningOrders string
 	CancelDelivery            string
 	ChangeDeliveryStatus      string
 	UpdateLogisticInfoFailed  string
@@ -15,6 +16,7 @@ var Order = struct {
 	GetSupplierOrders         string
 }{
 	UpdateORStatus:            getOrderValue("update_outbound_request_status"),
+	GetUserTotalWarningOrders: getOrderValue("get_user_total_warning_orders"),
 	CancelDelivery:            getOrderValue("cancel_delivery"),
 	ChangeDeliveryStatus:      getOrderValue("change_delivery_status"),
 	UpdateLogisticInfoFailed:  getOrderValue("update_logistic_info_failed"),