From f3bae56355836ff6b0d371a8db001b39c3664c00 Mon Sep 17 00:00:00 2001 From: Burce Date: Tue, 29 Oct 2019 16:15:26 +0800 Subject: [PATCH] =?UTF-8?q?[=E6=8B=9B=E5=95=86][=E4=BB=BB=E5=8A=A1]?= =?UTF-8?q?=E7=8A=B6=E6=80=81=E6=9B=B4=E6=96=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/iformall/service/invest/event/InvestListener.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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); - } + //} } }