czg_team/video_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

订单状态同步定时任务修改

Browse Source
This commit is contained in:
张松
2024-12-31 17:14:14 +08:00
parent 5419dd4102
commit fb00873494
2 changed files with 30 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

53
src/main/java/com/sqx/modules/job/task/TempOrdersTask.java
View File

@@ -89,43 +89,42 @@ public class TempOrdersTask {
return; return;
} }
logger.info("订单表数据处理开始"); logger.info("订单表数据处理开始");
List<Orders> orders = ordersDao.selectList(Wrappers.<Orders>lambdaQuery() // List<Orders> orders = ordersDao.selectList(Wrappers.<Orders>lambdaQuery()
.eq(Orders::getStatus, 0) // .eq(Orders::getStatus, 0)
.lt(Orders::getCreateTime, DateUtil.offsetMinute(DateUtil.date(), -15))); // .lt(Orders::getCreateTime, DateUtil.offsetMinute(DateUtil.date(), -15)));
if (CollUtil.isEmpty(orders)) { List<PayDetails> payDetailsList = payDetailsDao.selectList(new LambdaQueryWrapper<PayDetails>()
.eq(PayDetails::getState, 0)
.lt(PayDetails::getCreateTime, DateUtil.offsetMinute(DateUtil.date(), -15)));
if (CollUtil.isEmpty(payDetailsList)) {
return; return;
} }
for (Orders order : orders) { logger.info("待处理数据{}条", payDetailsList.size());
ThreadUtil.sleep(100);
PayDetails payDetails = payDetailsDao.selectOneByLimit(order.getOrdersNo()); for (PayDetails details : payDetailsList) {
if (payDetails == null) {
order.setStatus(3);
ordersDao.updateById(order);
continue;
}
if (payDetails.getState() == 1) {
continue;
}
try { 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"); ThreadUtil.sleep(100);
Orders orders = ordersDao.selectOne(new LambdaQueryWrapper<Orders>()
.eq(Orders::getOrdersNo, details.getOrderId()));
BaseResp baseResp = wuyouPay.queryOrder(details.getTradeNo(), details.getMoney().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)); logger.info("baseResp：{} ", JSONUtil.toJsonStr(baseResp));
if (baseResp.getCode() == null || baseResp.getCode() != 200) { if (baseResp.getCode() == null || baseResp.getCode() != 200) {
logger.info("code错误跳过");
continue; continue;
} }
if ("SUCCESS".equals(baseResp.getPayStatus())) { if ("SUCCESS".equals(baseResp.getPayStatus()) || "SUCCESS".equals(baseResp.getPayStatus2())) {
if (payDetails.getState() == 1) { logger.info("payDetails：{} ", JSONUtil.toJsonStr(details));
continue; logger.info("order：{} ", JSONUtil.toJsonStr(orders));
} updateOrderStatus(details, orders);
logger.info("payDetails：{} ", JSONUtil.toJsonStr(payDetails));
logger.info("order：{} ", JSONUtil.toJsonStr(order));
updateOrderStatus(payDetails, order);
} else { } else {
order.setStatus(3); logger.info("订单未支付，修改状态: {}", details.getTradeNo());
payDetails.setState(2); if (orders != null) {
ordersDao.updateById(order); orders.setStatus(3);
payDetailsDao.updateById(payDetails); ordersDao.updateById(orders);
}
details.setState(2);
payDetailsDao.updateById(details);
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();

4
src/main/java/com/sqx/modules/pay/wuyou/BaseResp.java
View File

@@ -17,10 +17,14 @@ public class BaseResp {
// 支付 只有 SUCCESS 是成功的 // 支付 只有 SUCCESS 是成功的
@JSONField(name = "pay_status") @JSONField(name = "pay_status")
private String payStatus; private String payStatus;
@JSONField(name = "payStatus")
private String payStatus2;
@JSONField(name = "error_msg") @JSONField(name = "error_msg")
private String errorMsg; private String errorMsg;
@JSONField(name = "error_code") @JSONField(name = "error_code")
private String errorCode; private String errorCode;
} }