提交 ce2ae05a authored 作者: 马路路's avatar 马路路

履约进度表模块-履约进度列表接口-查询异常上报信息-1

上级 c204bc05
...@@ -7,15 +7,11 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page; ...@@ -7,15 +7,11 @@ import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.clx.open.sdk.callback.OpenCallBackClient; import com.clx.open.sdk.callback.OpenCallBackClient;
import com.clx.open.sdk.callback.message.OrderInfoMessage; import com.clx.open.sdk.callback.message.OrderInfoMessage;
import com.clx.open.sdk.callback.message.TransportExceptionReportMessage; import com.clx.open.sdk.callback.message.TransportExceptionReportMessage;
import com.clx.open.sdk.request.action.InternalReportRouteExceptionAction;
import com.clx.open.sdk.request.dto.InternalReportRouteExceptionDTO;
import com.clx.order.enums.SyncPlatformEnum; import com.clx.order.enums.SyncPlatformEnum;
import com.clx.order.feign.InternalReportRouteExceptionFeign; import com.clx.order.feign.InternalReportRouteExceptionFeign;
import com.clx.order.feign.OrderFeign; import com.clx.order.feign.OrderFeign;
import com.clx.order.vo.feign.FeignAddressVO; import com.clx.order.param.feign.InternalReportRouteExceptionParam;
import com.clx.order.vo.feign.FeignOrderInfoVO; import com.clx.order.vo.feign.*;
import com.clx.order.vo.feign.FeignOrderVO;
import com.clx.order.vo.feign.SystemAddressVO;
import com.clx.performance.config.ThirdAppConfig; import com.clx.performance.config.ThirdAppConfig;
import com.clx.performance.dao.OrderChildDao; import com.clx.performance.dao.OrderChildDao;
import com.clx.performance.dao.OrderGoodsDao; import com.clx.performance.dao.OrderGoodsDao;
...@@ -699,10 +695,10 @@ public class PerformanceProgressServiceImpl implements PerformanceProgressServi ...@@ -699,10 +695,10 @@ public class PerformanceProgressServiceImpl implements PerformanceProgressServi
*/ */
public Map<String, String> getInternalReportRouteException(List<String> orderNoList) { public Map<String, String> getInternalReportRouteException(List<String> orderNoList) {
// 构建查询参数 // 构建查询参数
InternalReportRouteExceptionAction action = new InternalReportRouteExceptionAction(); InternalReportRouteExceptionParam action = new InternalReportRouteExceptionParam();
action.setOrderNoList(orderNoList); action.setOrderNoList(orderNoList);
// 远程查询,异常上报信息 // 远程查询,异常上报信息
List<InternalReportRouteExceptionDTO> list = Optional.of(internalReportRouteExceptionFeign List<InternalReportRouteExceptionFeignVO> list = Optional.of(internalReportRouteExceptionFeign
.getInternalReportRouteExceptionList(action)).filter(Result::succeed) .getInternalReportRouteExceptionList(action)).filter(Result::succeed)
.map(Result::getData).orElse(null); .map(Result::getData).orElse(null);
// 如果为空,返回空map集合 // 如果为空,返回空map集合
...@@ -710,6 +706,6 @@ public class PerformanceProgressServiceImpl implements PerformanceProgressServi ...@@ -710,6 +706,6 @@ public class PerformanceProgressServiceImpl implements PerformanceProgressServi
return new HashMap<>(); return new HashMap<>();
} }
// 以订单编号作为key,多条异常上报信息作为value,构建map集合 // 以订单编号作为key,多条异常上报信息作为value,构建map集合
return list.stream().collect(Collectors.toMap(InternalReportRouteExceptionDTO::getOrderNo, InternalReportRouteExceptionDTO::getExceptionInfo)); return list.stream().collect(Collectors.toMap(InternalReportRouteExceptionFeignVO::getOrderNo, InternalReportRouteExceptionFeignVO::getExceptionInfo));
} }
} }
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论