diff --git a/mallinkService/src/main/java/com/iformall/service/invest/event/InvestListener.java b/mallinkService/src/main/java/com/iformall/service/invest/event/InvestListener.java index af47da419..a8bf194bf 100644 --- a/mallinkService/src/main/java/com/iformall/service/invest/event/InvestListener.java +++ b/mallinkService/src/main/java/com/iformall/service/invest/event/InvestListener.java @@ -35,6 +35,7 @@ public class InvestListener implements ApplicationListener { LambdaQueryWrapper query = new LambdaQueryWrapper<>(); query.in(InvestTaskEntity::getTargetId, rentEventInfo.getTargetIds()); query.eq(InvestTaskEntity::getTargetType, EnumInvestType.RENT); + query.eq(InvestTaskEntity::getStatus, EnumTaskStatus.NEGOTIATING); List tasks = taskService.list(query); if (CollectionUtils.isEmpty(tasks)) { log.warn("receive InvestEvent , tasks is empty : {}", tasks); @@ -53,13 +54,13 @@ public class InvestListener implements ApplicationListener { status = EnumTaskStatus.FINISH; } - if (status == EnumTaskStatus.FINISH) { + //if (status != EnumTaskStatus.FINISH) { for (InvestTaskEntity task : tasks) { task.setStatus(status); task.setContent(InvestHelper.addContractId(task.getContent(),rentEventInfo.getRentId(),rentEventInfo.getContractType())); } taskService.updateBatchById(tasks); - } + //} } }