diff --git a/src/main/java/com/sqx/OneTimeTaskListener.java b/src/main/java/com/sqx/OneTimeTaskListener.java index 8b7b28be..d6e7c1cf 100644 --- a/src/main/java/com/sqx/OneTimeTaskListener.java +++ b/src/main/java/com/sqx/OneTimeTaskListener.java @@ -71,47 +71,47 @@ public class OneTimeTaskListener implements ApplicationListener cashOutList = cashOutDao.selectList(new LambdaQueryWrapper() - .eq(CashOut::getState, 2) - .isNull(CashOut::getOutAt) - .eq(CashOut::getRefund, "订单不存在") - .between(CashOut::getCreateAt, "2025-01-07 19:00:00", "2025-01-08 09:26:00")); - logger.info("待处理订单{}", cashOutList.size()); - int i = 0; - for (CashOut cashOut : cashOutList) { - logger.info("处理体现订单: {}, 剩余数量: {}", cashOut.getId(), cashOutList.size() - ++i); - try { - BaseResp baseResp = wuyouPay.queryExtractOrder(cashOut.getOrderNumber(), cashOut.getUserId(), cashOut.getUserType() != 2, cashOut.getMoney()); - logger.info("baseResp:{} ", JSONUtil.toJsonStr(baseResp)); - if (cashOut.getUserType() != null && cashOut.getUserType().equals(2)) { - SysUserMoney sysUserMoney = sysUserMoneyDao.selectOne(new LambdaQueryWrapper().eq(SysUserMoney::getUserId, cashOut.getUserId())); - if (sysUserMoney != null) { - sysUserMoneyDao.decrMoney(cashOut.getMoney(), cashOut.getUserId()); - } - }else { - UserMoney userMoney = userMoneyDao.selectOne(new LambdaQueryWrapper().eq(UserMoney::getUserId, cashOut.getUserId())); - if (userMoney != null) { - userMoneyDao.decrMoney(cashOut.getMoney(), cashOut.getUserId()); - } - } - - cashOutDao.update(null, new LambdaUpdateWrapper() - .eq(CashOut::getUserId, cashOut.getUserId()) - .eq(CashOut::getState, 3) - .set(CashOut::getRefund, "异常提现") - .set(CashOut::getState, 2)); - - if (baseResp.getStatus() != null && (baseResp.getStatus().equals(2) || baseResp.getStatus().equals(10000))){ - logger.info("成功订单: {}, {}", cashOut.getId(), cashOut.getUserName()); - cashOut.setState(1); - cashOut.setRefund("异常提现1"); - cashOut.setOutAt(DateUtil.now()); - cashOutDao.update(cashOut, new LambdaQueryWrapper().eq(CashOut::getUserId, cashOut.getUserId()).eq(CashOut::getId, cashOut.getId())); - } - }catch (Exception e) { - logger.error("", e); - } - } +// List cashOutList = cashOutDao.selectList(new LambdaQueryWrapper() +// .eq(CashOut::getState, 2) +// .isNull(CashOut::getOutAt) +// .eq(CashOut::getRefund, "订单不存在") +// .between(CashOut::getCreateAt, "2025-01-07 19:00:00", "2025-01-08 09:26:00")); +// logger.info("待处理订单{}", cashOutList.size()); +// int i = 0; +// for (CashOut cashOut : cashOutList) { +// logger.info("处理体现订单: {}, 剩余数量: {}", cashOut.getId(), cashOutList.size() - ++i); +// try { +// BaseResp baseResp = wuyouPay.queryExtractOrder(cashOut.getOrderNumber(), cashOut.getUserId(), cashOut.getUserType() != 2, cashOut.getMoney()); +// logger.info("baseResp:{} ", JSONUtil.toJsonStr(baseResp)); +// if (cashOut.getUserType() != null && cashOut.getUserType().equals(2)) { +// SysUserMoney sysUserMoney = sysUserMoneyDao.selectOne(new LambdaQueryWrapper().eq(SysUserMoney::getUserId, cashOut.getUserId())); +// if (sysUserMoney != null) { +// sysUserMoneyDao.decrMoney(cashOut.getMoney(), cashOut.getUserId()); +// } +// }else { +// UserMoney userMoney = userMoneyDao.selectOne(new LambdaQueryWrapper().eq(UserMoney::getUserId, cashOut.getUserId())); +// if (userMoney != null) { +// userMoneyDao.decrMoney(cashOut.getMoney(), cashOut.getUserId()); +// } +// } +// +// cashOutDao.update(null, new LambdaUpdateWrapper() +// .eq(CashOut::getUserId, cashOut.getUserId()) +// .eq(CashOut::getState, 3) +// .set(CashOut::getRefund, "异常提现") +// .set(CashOut::getState, 2)); +// +// if (baseResp.getStatus() != null && (baseResp.getStatus().equals(2) || baseResp.getStatus().equals(10000))){ +// logger.info("成功订单: {}, {}", cashOut.getId(), cashOut.getUserName()); +// cashOut.setState(1); +// cashOut.setRefund("异常提现1"); +// cashOut.setOutAt(DateUtil.now()); +// cashOutDao.update(cashOut, new LambdaQueryWrapper().eq(CashOut::getUserId, cashOut.getUserId()).eq(CashOut::getId, cashOut.getId())); +// } +// }catch (Exception e) { +// logger.error("", e); +// } +// } } }