1

business/jxstore/cms/store.go

@@ -876,6 +876,28 @@ func GetVendorStore(ctx *jxcontext.Context, vendorID int, vendorOrgCode, vendorS
 	return nil, err
 }
 
+// QueryPlatformBalance 获取三方配送平台账号余额
+func QueryPlatformBalance(vendorID int) (int64, error) {
+	handlerInfo := partner.GetDeliveryPlatformFromVendorID(vendorID)
+	if handlerInfo.Handler != nil {
+		return handlerInfo.Handler.GetPlatformBalance()
+	}
+	return 0, fmt.Errorf("vendorId 解析异常")
+}
+
+// BalanceRecharge 三方配送平台账号余额充值
+func BalanceRecharge(vendorID int, param *utils.RechargeBalance) (string, error) {
+	handlerInfo := partner.GetDeliveryPlatformFromVendorID(vendorID)
+	if handlerInfo.Handler != nil {
+		return handlerInfo.Handler.BalanceRecharge(&utils.RechargeBalance{
+			Amount:    param.Amount,
+			Category:  param.Category,
+			NotifyUrl: param.NotifyUrl,
+		})
+	}
+	return "", fmt.Errorf("vendorId 解析异常")
+}
+
 func isUpdateStoreNeedSync(valid map[string]interface{}) bool {
 	for k := range valid {
 		if storeKeyPropertyMap[k] == 1 {

business/partner/delivery/dada/waybill.go

@@ -648,3 +648,15 @@ func (c *DeliveryHandler) GetDeliverLiquidatedDamages(orderId string, deliverId
 	//}
 	//return vendorPrice, nil
 }
+
+func (c *DeliveryHandler) GetPlatformBalance() (balance int64, err error) {
+	return api.DadaAPI.QueryBillBalance()
+}
+
+func (c *DeliveryHandler) BalanceRecharge(param *utils.RechargeBalance) (url string, err error) {
+	return api.DadaAPI.BalanceRecharge(&dadaapi.RechargeParam{
+		Amount:    param.Amount,
+		Category:  param.Category,
+		NotifyUrl: param.NotifyUrl,
+	})
+}

business/partner/delivery/fn/waybill.go

@@ -608,3 +608,10 @@ func (c *DeliveryHandler) GetWaybillTip(ctx *jxcontext.Context, vendorOrgCode, v
 	}
 	return tipFee, err
 }
+
+func (c *DeliveryHandler) GetPlatformBalance() (balance int64, err error) {
+	return api.FnAPI.QueryBillBalance()
+}
+func (c *DeliveryHandler) BalanceRecharge(param *utils.RechargeBalance) (url string, err error) {
+	return "", fmt.Errorf("此平台暂不支持充值")
+}

business/partner/delivery/jdeclp/waybill.go

@@ -109,3 +109,9 @@ func (c *DeliveryHandler) GetRiderInfo(orderId string, deliveryId int64, mtPeiso
 func (c *DeliveryHandler) GetDeliverLiquidatedDamages(orderId string, deliverId string) (money int64, err error) {
 	return 0, err
 }
+func (c *DeliveryHandler) GetPlatformBalance() (balance int64, err error) {
+	return 0, fmt.Errorf("暂不支持此功能")
+}
+func (c *DeliveryHandler) BalanceRecharge(param *utils.RechargeBalance) (url string, err error) {
+	return "", fmt.Errorf("此平台暂不支持充值")
+}

business/partner/delivery/mtps/waybill.go

@@ -612,3 +612,10 @@ func (c *DeliveryHandler) UpdateWaybillTip(ctx *jxcontext.Context, vendorOrgCode
 func (c *DeliveryHandler) GetWaybillTip(ctx *jxcontext.Context, vendorOrgCode, vendorStoreID, vendorOrderID, vendorWaybillID, vendorWaybillID2 string) (tipFee int64, err error) {
 	return tipFee, err
 }
+
+func (c *DeliveryHandler) GetPlatformBalance() (balance int64, err error) {
+	return 0, fmt.Errorf("暂不支持此功能")
+}
+func (c *DeliveryHandler) BalanceRecharge(param *utils.RechargeBalance) (url string, err error) {
+	return "", fmt.Errorf("此平台暂不支持充值")
+}

business/partner/delivery/sfps/waybill.go

@@ -758,3 +758,10 @@ func getReallyStoreID(storeID, jxStoreID int) int {
 		return storeID
 	}
 }
+
+func (c *DeliveryHandler) GetPlatformBalance() (balance int64, err error) {
+	return 0, fmt.Errorf("暂不支持此功能")
+}
+func (c *DeliveryHandler) BalanceRecharge(param *utils.RechargeBalance) (url string, err error) {
+	return "", fmt.Errorf("此平台暂不支持充值")
+}

business/partner/delivery/uupt/waybill.go

@@ -499,3 +499,10 @@ func getReallyStoreID(storeID, jxStoreID int) int {
 func (c *DeliveryHandler) UpdateStoreName(storeId, name string) (err error) {
 	return err
 }
+
+func (c *DeliveryHandler) GetPlatformBalance() (balance int64, err error) {
+	return 0, fmt.Errorf("暂不支持此功能")
+}
+func (c *DeliveryHandler) BalanceRecharge(param *utils.RechargeBalance) (url string, err error) {
+	return "", fmt.Errorf("此平台暂不支持充值")
+}

business/partner/partner_delivery.go

@@ -50,6 +50,10 @@ type IDeliveryPlatformHandler interface {
 
 	// GetDeliverLiquidatedDamages 获取配送单的违约金:京西订单id:orderId,配送方id:deliverId
 	GetDeliverLiquidatedDamages(orderId string, deliverId string) (money int64, err error)
+	// GetPlatformBalance 获取平台账户余额
+	GetPlatformBalance() (balance int64, err error)
+	// BalanceRecharge 充值配送平台
+	BalanceRecharge(param *utils.RechargeBalance) (url string, err error)
 }
 
 type IDeliveryUpdateStoreHandler interface {