diff --git a/src/main/java/com/yau/digitalrmb/shared/wallet/WalletRuntimeResetService.java b/src/main/java/com/yau/digitalrmb/shared/wallet/WalletRuntimeResetService.java index c8de82e..4c5a0aa 100644 --- a/src/main/java/com/yau/digitalrmb/shared/wallet/WalletRuntimeResetService.java +++ b/src/main/java/com/yau/digitalrmb/shared/wallet/WalletRuntimeResetService.java @@ -64,8 +64,9 @@ public class WalletRuntimeResetService { } if (!paymentIds.isEmpty()) { currencyIds.addAll(queryCurrencyIdsByBusiness("PAYMENT", paymentIds)); - currencyIds.addAll(jdbc.queryForList("SELECT DISTINCT currency_id FROM payment_coin_reservation WHERE " - + in(paymentIds.size()), String.class, paymentIds.toArray())); + currencyIds.addAll(jdbc.queryForList("SELECT DISTINCT currency_id FROM payment_coin_reservation " + + "WHERE payment_id IN (" + in(paymentIds.size()) + ")", + String.class, paymentIds.toArray())); } if (!ownWalletIds.isEmpty()) { currencyIds.addAll(jdbc.queryForList("SELECT currency_id FROM central_bank_currency_ownership "