| | |
|---|
| | | private final AtomicBoolean ballot = new AtomicBoolean(false); |
|---|
| | | |
|---|
| | | |
|---|
| | | @Scheduled(cron = "0 0/10 * * * ?") |
|---|
| | | @Scheduled(cron = "0 0/1 * * * ?") |
|---|
| | | public void ballot() { |
|---|
| | | if (ballot.get()) { // 判断任务是否在处理中 |
|---|
| | | return; |
|---|
| | |
|---|
| | | List<UserStockSubscribe> userStockSubscribes = userStockSubscribeMapper.selectList(new LambdaQueryWrapper<UserStockSubscribe>() |
|---|
| | | .eq(UserStockSubscribe::getStatus, 3)); |
|---|
| | | userStockSubscribes.forEach(f->{ |
|---|
| | | UserAssets userAssets = userAssetsServices.assetsByTypeAndUserId("IN",f.getUserId()); |
|---|
| | | UserAssets userAssets = userAssetsServices.assetsByTypeAndUserId("MAS",f.getUserId()); |
|---|
| | | if(null != userAssets && userAssets.getAmountToBeCovered().compareTo(BigDecimal.ZERO) == 0){ |
|---|
| | | f.setStatus(4); |
|---|
| | | userStockSubscribeMapper.updateById(f); |
|---|
