diff --git a/src/main/java/com/example/demo/serviceImpl/cash/BankServiceImpl.java b/src/main/java/com/example/demo/serviceImpl/cash/BankServiceImpl.java index 3d07ab2..326adf1 100644 --- a/src/main/java/com/example/demo/serviceImpl/cash/BankServiceImpl.java +++ b/src/main/java/com/example/demo/serviceImpl/cash/BankServiceImpl.java @@ -325,7 +325,8 @@ public class BankServiceImpl implements BankService { // 创建StripeDTO列表用于存储所有处理后的数据 List stripeDTOList = new ArrayList<>(); - + // 获取需要处理的订单号列表 + List orderNoList = cashCollectionMapper.selectStripeList(); // 处理每一条Stripe数据 for (Charge charge : allCharges) { try { @@ -373,14 +374,16 @@ public class BankServiceImpl implements BankService { // 如果订单号存在,且在selectStripeList返回的列表中,则更新数据库中的记录 if (stripeDTO.getOrderNo() != null && !stripeDTO.getOrderNo().isEmpty()) { - // 获取需要处理的订单号列表 - List orderNoList = cashCollectionMapper.selectStripeList(); + // 检查当前订单号是否在列表中 if (orderNoList.contains(stripeDTO.getOrderNo())) { cashCollectionMapper.updateByGoldCoinOrderCodeByStripe(stripeDTO); + messages.add("成功处理订单: " + stripeDTO.getOrderNo()); + } + else{ + messages.add("订单号不在数据库中: " + stripeDTO.getOrderNo()); } } - messages.add("成功处理订单: " + stripeDTO.getOrderNo()); } catch (Exception e) { log.error("处理Stripe数据失败,chargeId: " + charge.getId(), e); // 继续处理其他数据,不中断整个流程 @@ -579,7 +582,7 @@ public class BankServiceImpl implements BankService { // 创建StripeDTO列表用于存储所有处理后的数据 List stripeDTOList = new ArrayList<>(); - + List orderNoList = cashCollectionMapper.selectStripe2List(); // 处理每一条Stripe数据 for (Charge charge : allCharges) { try { @@ -628,13 +631,16 @@ public class BankServiceImpl implements BankService { // 如果订单号存在,且在selectStripeList返回的列表中,则更新数据库中的记录 if (stripeDTO.getOrderNo() != null && !stripeDTO.getOrderNo().isEmpty()) { // 获取需要处理的订单号列表 - List orderNoList = cashCollectionMapper.selectStripe2List(); + // 检查当前订单号是否在列表中 if (orderNoList.contains(stripeDTO.getOrderNo())) { cashCollectionMapper.updateByGoldCoinOrderCodeByStripe2(stripeDTO); + messages.add("成功处理订单: " + stripeDTO.getOrderNo()); + } + else{ + messages.add("订单号不在数据库中: " + stripeDTO.getOrderNo()); } } - messages.add("成功处理订单: " + stripeDTO.getOrderNo()); } catch (Exception e) { log.error("处理Stripe数据失败,chargeId: " + charge.getId(), e); // 继续处理其他数据,不中断整个流程