From eabee5f050bf1b689e84487b83116eb29eb7cfe6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=B0=AD=E5=87=AF=E5=87=AF?= Date: Thu, 26 Dec 2024 18:19:50 +0800 Subject: [PATCH] =?UTF-8?q?=E8=AE=A2=E5=8D=95=E5=88=B7=E6=95=B0=E6=8D=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../sqx/modules/job/task/TempOrdersTask.java | 36 +++++++++++-------- 1 file changed, 22 insertions(+), 14 deletions(-) diff --git a/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java b/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java index 550c44bc..f9d5d4d1 100644 --- a/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java +++ b/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java @@ -85,28 +85,36 @@ public class TempOrdersTask implements ITask { PayDetails payDetails = payDetailsDao.selectByOrderId(order.getOrdersNo()); if (payDetails == null) { order.setStatus(3); + ordersDao.updateById(order); continue; } if (payDetails.getState() == 1) { continue; } - BaseResp baseResp = WuyouPay.queryOrder(payDetails.getTradeNo(), order.getPayMoney().toString(), "Mozilla/5.0 (iPhone; CPU iPhone OS 16_6 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/16.6 Mobile/15E148 Safari/604.1 Edg/131.0.0.0"); - if (baseResp.getCode() == null || baseResp.getCode() != 200) { - continue; - } - if ("SUCCESS".equals(baseResp.getPayStatus())) { - if (payDetails.getState() == 1) { + try { + BaseResp baseResp = WuyouPay.queryOrder(payDetails.getTradeNo(), order.getPayMoney().toString(), "Mozilla/5.0 (iPhone; CPU iPhone OS 16_6 like Mac OS X) AppleWebKit/605.1.15 (KHTML, like Gecko) Version/16.6 Mobile/15E148 Safari/604.1 Edg/131.0.0.0"); + logger.info("baseResp：{} ", JSONUtil.toJsonStr(baseResp)); + if (baseResp.getCode() == null || baseResp.getCode() != 200) { continue; } - logger.info("payDetails：{} ", JSONUtil.toJsonStr(payDetails)); - logger.info("order：{} ", JSONUtil.toJsonStr(order)); - updateOrderStatus(payDetails, order); - }else { - order.setStatus(3); - payDetails.setState(2); - ordersDao.updateById(order); - payDetailsDao.updateById(payDetails); + if ("SUCCESS".equals(baseResp.getPayStatus())) { + if (payDetails.getState() == 1) { + continue; + } + logger.info("payDetails：{} ", JSONUtil.toJsonStr(payDetails)); + logger.info("order：{} ", JSONUtil.toJsonStr(order)); + updateOrderStatus(payDetails, order); + }else { + order.setStatus(3); + payDetails.setState(2); + ordersDao.updateById(order); + payDetailsDao.updateById(payDetails); + } + }catch (Exception e){ + e.printStackTrace(); + logger.error("订单数据处理异常：", e); } + } logger.info("订单表数据处理完毕"); }