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

提现定时任务修改

Browse Source
This commit is contained in:
张松
2025-01-08 11:10:32 +08:00
parent d541c4b173
commit de7213e37a
1 changed files with 41 additions and 41 deletions
Download Patch File Download Diff File Expand all files Collapse all files

82
src/main/java/com/sqx/OneTimeTaskListener.java
View File

@@ -71,47 +71,47 @@ public class OneTimeTaskListener implements ApplicationListener<ApplicationReady
public void onApplicationEvent(ApplicationReadyEvent event) { public void onApplicationEvent(ApplicationReadyEvent event) {
logger.info("应用启动完成后执行一次性方法"); logger.info("应用启动完成后执行一次性方法");
List<CashOut> cashOutList = cashOutDao.selectList(new LambdaQueryWrapper<CashOut>() // List<CashOut> cashOutList = cashOutDao.selectList(new LambdaQueryWrapper<CashOut>()
.eq(CashOut::getState, 2) // .eq(CashOut::getState, 2)
.isNull(CashOut::getOutAt) // .isNull(CashOut::getOutAt)
.eq(CashOut::getRefund, "订单不存在") // .eq(CashOut::getRefund, "订单不存在")
.between(CashOut::getCreateAt, "2025-01-07 19:00:00", "2025-01-08 09:26:00")); // .between(CashOut::getCreateAt, "2025-01-07 19:00:00", "2025-01-08 09:26:00"));
logger.info("待处理订单{}", cashOutList.size()); // logger.info("待处理订单{}", cashOutList.size());
int i = 0; // int i = 0;
for (CashOut cashOut : cashOutList) { // for (CashOut cashOut : cashOutList) {
logger.info("处理体现订单: {}, 剩余数量: {}", cashOut.getId(), cashOutList.size() - ++i); // logger.info("处理体现订单: {}, 剩余数量: {}", cashOut.getId(), cashOutList.size() - ++i);
try { // try {
BaseResp baseResp = wuyouPay.queryExtractOrder(cashOut.getOrderNumber(), cashOut.getUserId(), cashOut.getUserType() != 2, cashOut.getMoney()); // BaseResp baseResp = wuyouPay.queryExtractOrder(cashOut.getOrderNumber(), cashOut.getUserId(), cashOut.getUserType() != 2, cashOut.getMoney());
logger.info("baseResp：{} ", JSONUtil.toJsonStr(baseResp)); // logger.info("baseResp：{} ", JSONUtil.toJsonStr(baseResp));
if (cashOut.getUserType() != null && cashOut.getUserType().equals(2)) { // if (cashOut.getUserType() != null && cashOut.getUserType().equals(2)) {
SysUserMoney sysUserMoney = sysUserMoneyDao.selectOne(new LambdaQueryWrapper<SysUserMoney>().eq(SysUserMoney::getUserId, cashOut.getUserId())); // SysUserMoney sysUserMoney = sysUserMoneyDao.selectOne(new LambdaQueryWrapper<SysUserMoney>().eq(SysUserMoney::getUserId, cashOut.getUserId()));
if (sysUserMoney != null) { // if (sysUserMoney != null) {
sysUserMoneyDao.decrMoney(cashOut.getMoney(), cashOut.getUserId()); // sysUserMoneyDao.decrMoney(cashOut.getMoney(), cashOut.getUserId());
} // }
}else { // }else {
UserMoney userMoney = userMoneyDao.selectOne(new LambdaQueryWrapper<UserMoney>().eq(UserMoney::getUserId, cashOut.getUserId())); // UserMoney userMoney = userMoneyDao.selectOne(new LambdaQueryWrapper<UserMoney>().eq(UserMoney::getUserId, cashOut.getUserId()));
if (userMoney != null) { // if (userMoney != null) {
userMoneyDao.decrMoney(cashOut.getMoney(), cashOut.getUserId()); // userMoneyDao.decrMoney(cashOut.getMoney(), cashOut.getUserId());
} // }
} // }
//
cashOutDao.update(null, new LambdaUpdateWrapper<CashOut>() // cashOutDao.update(null, new LambdaUpdateWrapper<CashOut>()
.eq(CashOut::getUserId, cashOut.getUserId()) // .eq(CashOut::getUserId, cashOut.getUserId())
.eq(CashOut::getState, 3) // .eq(CashOut::getState, 3)
.set(CashOut::getRefund, "异常提现") // .set(CashOut::getRefund, "异常提现")
.set(CashOut::getState, 2)); // .set(CashOut::getState, 2));
//
if (baseResp.getStatus() != null && (baseResp.getStatus().equals(2) || baseResp.getStatus().equals(10000))){ // if (baseResp.getStatus() != null && (baseResp.getStatus().equals(2) || baseResp.getStatus().equals(10000))){
logger.info("成功订单: {}, {}", cashOut.getId(), cashOut.getUserName()); // logger.info("成功订单: {}, {}", cashOut.getId(), cashOut.getUserName());
cashOut.setState(1); // cashOut.setState(1);
cashOut.setRefund("异常提现1"); // cashOut.setRefund("异常提现1");
cashOut.setOutAt(DateUtil.now()); // cashOut.setOutAt(DateUtil.now());
cashOutDao.update(cashOut, new LambdaQueryWrapper<CashOut>().eq(CashOut::getUserId, cashOut.getUserId()).eq(CashOut::getId, cashOut.getId())); // cashOutDao.update(cashOut, new LambdaQueryWrapper<CashOut>().eq(CashOut::getUserId, cashOut.getUserId()).eq(CashOut::getId, cashOut.getId()));
} // }
}catch (Exception e) { // }catch (Exception e) {
logger.error("", e); // logger.error("", e);
} // }
} // }
} }
} }