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