| @@ -35,6 +35,7 @@ public class InvestListener implements ApplicationListener<InvestEvent> { | |||||
| LambdaQueryWrapper<InvestTaskEntity> query = new LambdaQueryWrapper<>(); | LambdaQueryWrapper<InvestTaskEntity> query = new LambdaQueryWrapper<>(); | ||||
| query.in(InvestTaskEntity::getTargetId, rentEventInfo.getTargetIds()); | query.in(InvestTaskEntity::getTargetId, rentEventInfo.getTargetIds()); | ||||
| query.eq(InvestTaskEntity::getTargetType, EnumInvestType.RENT); | query.eq(InvestTaskEntity::getTargetType, EnumInvestType.RENT); | ||||
| query.eq(InvestTaskEntity::getStatus, EnumTaskStatus.NEGOTIATING); | |||||
| List<InvestTaskEntity> tasks = taskService.list(query); | List<InvestTaskEntity> tasks = taskService.list(query); | ||||
| if (CollectionUtils.isEmpty(tasks)) { | if (CollectionUtils.isEmpty(tasks)) { | ||||
| log.warn("receive InvestEvent , tasks is empty : {}", tasks); | log.warn("receive InvestEvent , tasks is empty : {}", tasks); | ||||
| @@ -53,13 +54,13 @@ public class InvestListener implements ApplicationListener<InvestEvent> { | |||||
| status = EnumTaskStatus.FINISH; | status = EnumTaskStatus.FINISH; | ||||
| } | } | ||||
| if (status == EnumTaskStatus.FINISH) { | |||||
| //if (status != EnumTaskStatus.FINISH) { | |||||
| for (InvestTaskEntity task : tasks) { | for (InvestTaskEntity task : tasks) { | ||||
| task.setStatus(status); | task.setStatus(status); | ||||
| task.setContent(InvestHelper.addContractId(task.getContent(),rentEventInfo.getRentId(),rentEventInfo.getContractType())); | task.setContent(InvestHelper.addContractId(task.getContent(),rentEventInfo.getRentId(),rentEventInfo.getContractType())); | ||||
| } | } | ||||
| taskService.updateBatchById(tasks); | taskService.updateBatchById(tasks); | ||||
| } | |||||
| //} | |||||
| } | } | ||||
| } | } | ||||