From f59992f786d5b4e6395d725e35b2219529301c3c Mon Sep 17 00:00:00 2001 From: zhangyuan Date: Tue, 15 Nov 2022 13:45:10 +0800 Subject: [PATCH] =?UTF-8?q?=E6=88=90=E5=8A=9F=E4=B8=8D=E8=AE=B0=E5=BD=95?= =?UTF-8?q?=E6=8B=89=E5=8F=96=E6=97=A5=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../modules/item/service/impl/ItemServiceImpl.java | 12 +++++------- 1 file changed, 5 insertions(+), 7 deletions(-) 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 ebf7de633..be0c8c174 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 @@ -2811,16 +2811,14 @@ public class ItemServiceImpl extends BaseServiceImpl implem List allProcess = new ArrayList<>(); partition.forEach(itemList -> { - String successFlag = YesOrNoEnum.YES.value(); String ids = itemList.stream().map(ItemGridPlatformDTO::getTaskid).collect(Collectors.joining(",")); List processHistories = shiBeiCityGridApi.getBatchHistoryByRecIds(ids); allProcess.addAll(processHistories); if (processHistories.isEmpty()) { - successFlag = YesOrNoEnum.NO.value(); + // 失败的时候保存接口调用日志，成功就不需要了 + this.saveInterfaceLog(StringUtils.EMPTY, InterfaceLogBusinessTypeEnum.PULL_ITEM_HANDLE_PROCESS.getValue(), + ApiConstants.SearchCaseProcessByTaskId, YesOrNoEnum.NO.value(), ids, ApiConstants.batchHistoryUrl + "?recIds=" + ids); } - // 保存接口调用日志 - this.saveInterfaceLog(StringUtils.EMPTY, InterfaceLogBusinessTypeEnum.PULL_ITEM_HANDLE_PROCESS.getValue(), - ApiConstants.SearchCaseProcessByTaskId, successFlag, ids, ApiConstants.batchHistoryUrl + "?recIds=" + ids); }); Map processMap = allProcess.stream().collect(Collectors.toMap(EventProcessBatchHisResultDto::getRECID, process -> process)); @@ -4581,7 +4579,7 @@ public class ItemServiceImpl extends BaseServiceImpl implem throw new RenException("获取项目数据失败，项目Id->" + itemId); } //2.判断是已结案的不做处理（第二次可以评价了，没超过24小时用户评价了，此时就是已结案了） - if ("10".equals(entity.getItemState())) { + if (ItemHandleCategoryEnum.HANDLE_CLOSING_CASE.getValue() == entity.getItemState()) { return; } //查询项目反馈数据 @@ -4639,7 +4637,7 @@ public class ItemServiceImpl extends BaseServiceImpl implem throw new RenException("获取项目数据失败，项目Id->" + itemId); } //2.判断是已结案的不做处理（第二次可以评价了，没超过24小时用户评价了，此时就是已结案了） - if ("10".equals(entity.getItemState())) { + if (ItemHandleCategoryEnum.HANDLE_CLOSING_CASE.getValue() == entity.getItemState()) { return; } //查询项目反馈数据