修改权益支付回调

share-system/src/main/java/share/system/service/impl/EquityMembersOrderServiceImpl.java

@@ -52,6 +52,8 @@ public class EquityMembersOrderServiceImpl extends ServiceImpl<EquityMembersOrde
     private MemberConfigService memberConfigService;
     @Autowired
     private RedisUtil redisUtil;
+    @Autowired
+    private ConsumerWalletService consumerWalletService;
 
     /**
      * 查询权益会员订单
@@ -160,6 +162,7 @@ public class EquityMembersOrderServiceImpl extends ServiceImpl<EquityMembersOrde
     @Override
     public void paymentSuccessful(EquityMembersOrder equityMembersOrder) {
         ConsumerMember consumerMember = consumerMemberService.getOne(new LambdaQueryWrapper<ConsumerMember>().eq(ConsumerMember::getConsumerId, equityMembersOrder.getConsumerId()));
+        ConsumerWallet consumerWallet = consumerWalletService.getOne(new LambdaQueryWrapper<ConsumerWallet>().eq(ConsumerWallet::getConsumerId, equityMembersOrder.getConsumerId()));
         EquityMembersOrderConfig equityMembersOrderConfig = equityMembersOrderConfigService.selectEquityMembersOrderConfigById(equityMembersOrder.getEquityMembersConfigId());
         if (ObjectUtil.isEmpty(consumerMember)) {
             ConsumerMember newConsumerMember = new ConsumerMember();
@@ -210,6 +213,15 @@ public class EquityMembersOrderServiceImpl extends ServiceImpl<EquityMembersOrde
             JSONObject json = new JSONObject(map);
             redisUtil.set(ReceiptRdeisEnum.EQUITY_MEMBERS_TIME.getValue() + equityMembersOrder.getConsumerId(), json.toString());
         }
+        if (ObjectUtil.isEmpty(consumerWallet)) {
+            ConsumerWallet consumerWalletOne = new ConsumerWallet();
+            consumerWalletOne.setConsumerId(equityMembersOrder.getConsumerId());
+            consumerWalletOne.setBalance(BigDecimal.ZERO);
+            consumerWalletOne.setRemainingDuration(BigDecimal.ZERO);
+            consumerWalletOne.setRemainingIntegral(BigDecimal.ZERO);
+            consumerWalletOne.setCreateTime(new Date());
+            consumerWalletService.save(consumerWalletOne);
+        }
         updateEquityMembersOrder(equityMembersOrder);
     }