diff --git a/src/main/java/com/sqx/OneTimeTaskListener.java b/src/main/java/com/sqx/OneTimeTaskListener.java index 0a3edc6f..e19ea01c 100644 --- a/src/main/java/com/sqx/OneTimeTaskListener.java +++ b/src/main/java/com/sqx/OneTimeTaskListener.java @@ -3,6 +3,7 @@ package com.sqx; import cn.hutool.core.date.DateUtil; import cn.hutool.json.JSONUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import com.sqx.modules.app.dao.UserDao; import com.sqx.modules.app.dao.UserMoneyDao; import com.sqx.modules.app.dao.UserMoneyDetailsDao; @@ -80,21 +81,28 @@ public class OneTimeTaskListener implements ApplicationListener().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()); - 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()); - } - } cashOut.setState(1); - cashOut.setRefund("二次询问成功"); + cashOut.setRefund("异常提现1"); cashOut.setOutAt(DateUtil.now()); cashOutDao.update(cashOut, new LambdaQueryWrapper().eq(CashOut::getUserId, cashOut.getUserId()).eq(CashOut::getId, cashOut.getId())); }