From ae2c704bb783812b64034fabfeab12b567a210dd Mon Sep 17 00:00:00 2001 From: zhaoqifeng Date: Fri, 28 Oct 2022 19:53:59 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../epdc/modules/item/redis/ItemAutoProcessRedis.java | 11 ++++++++--- .../esua/epdc/modules/item/service/ItemService.java | 2 +- .../modules/item/service/impl/ItemServiceImpl.java | 2 +- 3 files changed, 10 insertions(+), 5 deletions(-) diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/redis/ItemAutoProcessRedis.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/redis/ItemAutoProcessRedis.java index dbb5fdeca..75e87a0e1 100644 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/redis/ItemAutoProcessRedis.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/redis/ItemAutoProcessRedis.java @@ -31,8 +31,7 @@ import org.springframework.stereotype.Component; import javax.annotation.Resource; import java.io.IOException; -import java.util.Date; -import java.util.Set; +import java.util.*; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; @@ -93,7 +92,13 @@ public class ItemAutoProcessRedis{ for (ZSetOperations.TypedTuple itemSerialNo : itemSerialNos) { log.info("诉求" + itemSerialNo.getValue() + "开始处理"); try{ - itemService.itemClosed(itemSerialNo.getValue()); + List list = Arrays.asList(Objects.requireNonNull(itemSerialNo.getValue()).split(":")); + String id = list.get(0); + String type = null; + if (list.size() > 1) { + type = list.get(1); + } + itemService.itemClosed(id, type); } catch(Exception ex){ ex.printStackTrace(); diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/ItemService.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/ItemService.java index ae17dedb8..f54b3d170 100755 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/ItemService.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/ItemService.java @@ -742,7 +742,7 @@ public interface ItemService extends BaseService { /** * 定时任务：是否可以结案处理 */ - void itemClosed(String itemId); + void itemClosed(String itemId, String type); /** * 诉求初验 diff --git a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java index c6eb9ddc8..d53cc6365 100755 --- a/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java +++ b/esua-epdc/epdc-module/epdc-events/epdc-events-server/src/main/java/com/elink/esua/epdc/modules/item/service/impl/ItemServiceImpl.java @@ -4468,7 +4468,7 @@ public class ItemServiceImpl extends BaseServiceImpl implem * 定时任务：是否可以结案处理 */ @Override - public void itemClosed(String itemId) { + public void itemClosed(String itemId, String type) { logger.info("开始执行结案操作,项目Id->"+itemId); //1.获取项目基础数据 ItemEntity entity = baseDao.selectById(itemId);