|
@@ -1774,34 +1774,39 @@ public class FsStorePaymentServiceImpl implements IFsStorePaymentService {
|
|
|
for (FsStorePayment fsStorePayment : list) {
|
|
for (FsStorePayment fsStorePayment : list) {
|
|
|
CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
|
|
CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
|
|
|
try {
|
|
try {
|
|
|
- updateFsStorePaymentByDecryptForm(fsStorePayment.getPaymentId(),null);
|
|
|
|
|
- //查询是否改为已支付
|
|
|
|
|
- FsStorePayment finalPayment = fsStorePaymentMapper.selectFsStorePaymentByPaymentId(fsStorePayment.getPaymentId());
|
|
|
|
|
- try {
|
|
|
|
|
- Date createTime = finalPayment.getCreateTime();
|
|
|
|
|
- Date now = new Date();
|
|
|
|
|
- long value = now.getTime() - createTime.getTime();
|
|
|
|
|
- if(finalPayment.getStatus() == 0
|
|
|
|
|
- && finalPayment.getBusinessType() == 3
|
|
|
|
|
- && (value > TWENTY_DAYS_IN_MILLIS)
|
|
|
|
|
- && finalPayment.getBusinessId() != null){
|
|
|
|
|
- //套餐包超过20天取消订单
|
|
|
|
|
- FsPackageOrderCancelParam param = new FsPackageOrderCancelParam();
|
|
|
|
|
- param.setOrderId(Long.valueOf(finalPayment.getBusinessId()));
|
|
|
|
|
- packageOrderService.cancel(param);
|
|
|
|
|
|
|
+ //查询订单是否是20天前且已取消的订单
|
|
|
|
|
+ if (fsStorePayment.getCreateTime().before(DateUtils.addDateDay(-20))) {
|
|
|
|
|
+ logger.info("定时任务:同步支付状态在20天前,取消同步,payment_id:{}",fsStorePayment.getPaymentId());
|
|
|
|
|
+ } else {
|
|
|
|
|
+ updateFsStorePaymentByDecryptForm(fsStorePayment.getPaymentId(),null);
|
|
|
|
|
+ //查询是否改为已支付
|
|
|
|
|
+ FsStorePayment finalPayment = fsStorePaymentMapper.selectFsStorePaymentByPaymentId(fsStorePayment.getPaymentId());
|
|
|
|
|
+ try {
|
|
|
|
|
+ Date createTime = finalPayment.getCreateTime();
|
|
|
|
|
+ Date now = new Date();
|
|
|
|
|
+ long value = now.getTime() - createTime.getTime();
|
|
|
|
|
+ if(finalPayment.getStatus() == 0
|
|
|
|
|
+ && finalPayment.getBusinessType() == 3
|
|
|
|
|
+ && (value > TWENTY_DAYS_IN_MILLIS)
|
|
|
|
|
+ && finalPayment.getBusinessId() != null){
|
|
|
|
|
+ //套餐包超过20天取消订单
|
|
|
|
|
+ FsPackageOrderCancelParam param = new FsPackageOrderCancelParam();
|
|
|
|
|
+ param.setOrderId(Long.valueOf(finalPayment.getBusinessId()));
|
|
|
|
|
+ packageOrderService.cancel(param);
|
|
|
|
|
+ }
|
|
|
|
|
+ } catch (NumberFormatException e) {
|
|
|
|
|
+ logger.info("定时任务:同步支付状态超时取消订单失败,payment_id:{}",fsStorePayment.getPaymentId());
|
|
|
}
|
|
}
|
|
|
- } catch (NumberFormatException e) {
|
|
|
|
|
- logger.info("定时任务:同步支付状态超时取消订单失败,payment_id:{}",fsStorePayment.getPaymentId());
|
|
|
|
|
}
|
|
}
|
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
|
//添加失败记录
|
|
//添加失败记录
|
|
|
FsStorePaymentError fsStorePaymentError = new FsStorePaymentError();
|
|
FsStorePaymentError fsStorePaymentError = new FsStorePaymentError();
|
|
|
fsStorePaymentError.setOrderFlowNo(fsStorePayment.getTradeNo());
|
|
fsStorePaymentError.setOrderFlowNo(fsStorePayment.getTradeNo());
|
|
|
- String businessId = fsStorePayment.getBusinessId();
|
|
|
|
|
fsStorePaymentError.setBusinessType(fsStorePayment.getBusinessType());
|
|
fsStorePaymentError.setBusinessType(fsStorePayment.getBusinessType());
|
|
|
fsStorePaymentError.setMsg(e.getMessage());
|
|
fsStorePaymentError.setMsg(e.getMessage());
|
|
|
fsStorePaymentError.setStatus(0);
|
|
fsStorePaymentError.setStatus(0);
|
|
|
fsStorePaymentError.setCreateTime(new Date());
|
|
fsStorePaymentError.setCreateTime(new Date());
|
|
|
|
|
+ String businessId = fsStorePayment.getBusinessId();
|
|
|
if (businessId != null && fsStorePayment.getBusinessType() == 3) {
|
|
if (businessId != null && fsStorePayment.getBusinessType() == 3) {
|
|
|
fsStorePaymentError.setOrderId(Long.valueOf(businessId));
|
|
fsStorePaymentError.setOrderId(Long.valueOf(businessId));
|
|
|
FsPackageOrder fsPackageOrder = packageOrderService.selectFsPackageOrderByOrderId(Long.valueOf(businessId));
|
|
FsPackageOrder fsPackageOrder = packageOrderService.selectFsPackageOrderByOrderId(Long.valueOf(businessId));
|