diff --git a/rc-service/rc-service-wallet/wallet-application/src/main/java/com/red/circle/wallet/app/command/freight/SendFreightShipCmdExe.java b/rc-service/rc-service-wallet/wallet-application/src/main/java/com/red/circle/wallet/app/command/freight/SendFreightShipCmdExe.java index 8cb88eaf..318a3213 100644 --- a/rc-service/rc-service-wallet/wallet-application/src/main/java/com/red/circle/wallet/app/command/freight/SendFreightShipCmdExe.java +++ b/rc-service/rc-service-wallet/wallet-application/src/main/java/com/red/circle/wallet/app/command/freight/SendFreightShipCmdExe.java @@ -14,6 +14,7 @@ import com.red.circle.order.inner.endpoint.UserRechargeCountClient; import com.red.circle.order.inner.model.enums.MonthlyRechargeType; import com.red.circle.other.inner.endpoint.activity.AppRankCountClient; import com.red.circle.other.inner.endpoint.activity.CumulativeRechargeClient; +import com.red.circle.other.inner.endpoint.user.user.UserLevelClient; import com.red.circle.other.inner.model.dto.user.UserProfileDTO; import com.red.circle.tool.core.date.LocalDateTimeUtils; import com.red.circle.tool.core.json.JacksonUtils; @@ -67,6 +68,7 @@ public class SendFreightShipCmdExe { private final CumulativeRechargeClient cumulativeRechargeClient; private final FreightBalanceRunningWaterService freightBalanceRunningWaterService; private final TaskMqMessage taskMqMessage; + private final UserLevelClient userLevelClient; public BigDecimal execute(FreightShipSendCmd cmd) { @@ -157,6 +159,9 @@ public class SendFreightShipCmdExe { MonthlyRechargeType.SHIPPING_AGENT ); + //计入财富榜 + userLevelClient.incrWealthExp(cmd.getAcceptUserId(), cmd.getQuantity()); + appRankCountClient.incrRechargeQuantity(cmd.requireReqSysOrigin(), cmd.getAcceptUserId(), cmd.getQuantity().longValue()