浏览代码

UserWalletService 添加一个 approveAllCharges 方法

reghao 1 年之前
父节点
当前提交
34760edca8

+ 1 - 0
user/user-api/src/main/java/cn/reghao/tnb/user/api/iface/UserWalletService.java

@@ -14,6 +14,7 @@ public interface UserWalletService {
     void charge(ChargeReq chargeReq);
     List<WalletChargeDto> getChargeReqs();
     void approveCharge(long chargeId);
+    void approveAllCharges();
     void declineCharge(long chargeId);
     Result pay(long fromUserId, double amount, long toUserId);
 }

+ 9 - 0
user/user-service/src/main/java/cn/reghao/tnb/user/app/rpc/UserWalletServiceImpl.java

@@ -84,6 +84,15 @@ public class UserWalletServiceImpl implements UserWalletService {
         userMessageService.addMessage(userMessageDto);
     }
 
+    @Override
+    public void approveAllCharges() {
+        int status = 1;
+        walletChargeMapper.findByStatus(status).forEach(walletChargeDto -> {
+            long chargeId = walletChargeDto.getChargeId();
+            approveCharge(chargeId);
+        });
+    }
+
     @Override
     public void declineCharge(long chargeId) {
         WalletCharge walletCharge = walletChargeMapper.findByChargeId(chargeId);