From b875469beb54bf7b5e720728e2fea318db770242 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 17:38:13 +0800 Subject: [PATCH] =?UTF-8?q?=E8=AE=A2=E5=8D=95=E5=88=B7=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E6=B5=8B=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../sqx/modules/job/task/TempOrdersTask.java | 28 ++++++++++++------- 1 file changed, 18 insertions(+), 10 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 b15876d4..01fa4597 100644 --- a/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java +++ b/src/main/java/com/sqx/modules/job/task/TempOrdersTask.java @@ -71,7 +71,10 @@ public class TempOrdersTask implements ITask { @Override public void run(String params) { logger.info("订单表数据处理开始"); - List orders = ordersDao.selectList(Wrappers.lambdaQuery().eq(Orders::getStatus, 0)); + List orders = ordersDao.selectList(Wrappers.lambdaQuery() + .eq(Orders::getStatus, 1) + .eq(Orders::getOrdersNo, "1000001111854076") + ); if (CollUtil.isEmpty(orders)) { return; } @@ -83,17 +86,22 @@ public class TempOrdersTask implements ITask { 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); + 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); + } + } catch (Exception e) { + logger.error("查询订单异常：{}", e); } } logger.info("订单表数据处理完毕");