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-26 17:38:13 +08:00
committed by Tankaikai
parent f681af7fd8
commit b875469beb
1 changed files with 18 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -71,7 +71,10 @@ public class TempOrdersTask implements ITask {
@Override @Override
public void run(String params) { public void run(String params) {
logger.info("订单表数据处理开始"); logger.info("订单表数据处理开始");
List<Orders> orders = ordersDao.selectList(Wrappers.<Orders>lambdaQuery().eq(Orders::getStatus, 0)); List<Orders> orders = ordersDao.selectList(Wrappers.<Orders>lambdaQuery()
.eq(Orders::getStatus, 1)
.eq(Orders::getOrdersNo, "1000001111854076")
);
if (CollUtil.isEmpty(orders)) { if (CollUtil.isEmpty(orders)) {
return; return;
} }
@@ -83,17 +86,22 @@ public class TempOrdersTask implements ITask {
if (payDetails.getState() == 1) { if (payDetails.getState() == 1) {
continue; 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"); try {
if (baseResp.getCode() == null || baseResp.getCode() != 200) { 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");
continue; logger.info("baseResp：{} ", JSONUtil.toJsonStr(baseResp));
} if (baseResp.getCode() == null || baseResp.getCode() != 200) {
if ("SUCCESS".equals(baseResp.getPayStatus())) {
if (payDetails.getState() == 1) {
continue; continue;
} }
logger.info("payDetails：{} ", JSONUtil.toJsonStr(payDetails)); if ("SUCCESS".equals(baseResp.getPayStatus())) {
logger.info("order：{} ", JSONUtil.toJsonStr(order)); if (payDetails.getState() == 1) {
updateOrderStatus(payDetails, order); continue;
}
logger.info("payDetails：{} ", JSONUtil.toJsonStr(payDetails));
logger.info("order：{} ", JSONUtil.toJsonStr(order));
updateOrderStatus(payDetails, order);
}
} catch (Exception e) {
logger.error("查询订单异常：{}", e);
} }
} }
logger.info("订单表数据处理完毕"); logger.info("订单表数据处理完毕");