| | |
|---|
| | | private final AtomicBoolean subscription = new AtomicBoolean(false); |
|---|
| | | |
|---|
| | | // @Scheduled(cron = "0 0/1 * * * ?") |
|---|
| | | public void subscription() { |
|---|
| | | /*public void subscription() { |
|---|
| | | if (subscription.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(EStockType.MX.getCode(), f.getUserId()); |
|---|
| | | if(null != userAssets && userAssets.getAmountToBeCovered().compareTo(BigDecimal.ZERO) == 0){ |
|---|
| | | f.setStatus(4); |
|---|
| | | userStockSubscribeMapper.updateById(f); |
|---|
| | |
|---|
| | | } else { |
|---|
| | | log.info("自动转已认缴定时任务--------->上次任务还未执行完成，本次任务忽略"); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }*/ |
|---|
| | | |
|---|
| | | } |
|---|
