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 09:41:20 +08:00
parent e585b10566
commit 69741be97c
4 changed files with 131 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/main/java/com/sqx/modules/job/task/TempCashOutTask.java
View File

@@ -4,7 +4,9 @@ import cn.hutool.core.date.DateUtil;
import cn.hutool.json.JSONUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.sqx.modules.app.dao.UserMoneyDao;
import com.sqx.modules.app.dao.UserMoneyDetailsDao;
import com.sqx.modules.app.entity.UserMoney;
import com.sqx.modules.app.entity.UserMoneyDetails;
import com.sqx.modules.pay.dao.CashOutDao;
import com.sqx.modules.pay.entity.CashOut;
import com.sqx.modules.pay.wuyou.BaseResp;
@@ -19,6 +21,7 @@ import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
import java.math.BigDecimal;
import java.util.List;
@Component
@@ -35,6 +38,8 @@ public class TempCashOutTask{
private UserMoneyDao userMoneyDao;
@Autowired
private SysUserMoneyDao sysUserMoneyDao;
@Autowired
private UserMoneyDetailsDao userMoneyDetailsDao;
@Scheduled(cron = "0 0/8 * * * ? ")
public void run() {
@@ -73,6 +78,18 @@ public class TempCashOutTask{
cashOut.setState(2);
cashOut.setRefund(baseResp.getMsg());
cashOutDao.update(cashOut, new LambdaQueryWrapper<CashOut>().eq(CashOut::getUserId, cashOut.getUserId()).eq(CashOut::getId, cashOut.getId()));
UserMoneyDetails details = new UserMoneyDetails();
details.setUserId(cashOut.getUserId());
details.setTitle("提现失败存入余额" + cashOut.getMoney() + "元");
details.setClassify(4);
details.setType(1);
details.setState(2);
details.setMoney(new BigDecimal(cashOut.getMoney()));
details.setContent("提现失败存入余额");
details.setMoneyType(1);
details.setCreateTime(DateUtil.date().toString());
userMoneyDetailsDao.insert(details);
}
}catch (Exception e) {
logger.error("体现定时任务查询出错", e);