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("订单表数据处理完毕");