|
|
@@ -153,6 +153,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
private final KwtWaybillOrderTicketRepository kwtWaybillOrderTicketRepository;
|
|
|
private final KwtWaybillOrderNodeRepository kwtWaybillOrderNodeRepository;
|
|
|
private final VehicleTraceClient vehicleTraceClient;
|
|
|
+ private final KwtGatekeeperWaybillOrderRepository gatekeeperWaybillOrderRepository;
|
|
|
|
|
|
@Resource
|
|
|
private StreamBridge streamBridge;
|
|
|
@@ -3216,10 +3217,22 @@ public class KwtWaybillOrderV1Service {
|
|
|
.orElse(List.of()).stream()
|
|
|
.collect(Collectors.toMap(x->x.getContractId()+"-"+x.getGoodsId(), Function.identity(), (k1, k2) -> k1));
|
|
|
|
|
|
+ //查询门卫订单
|
|
|
+ log.debug("开始查询门卫订单");
|
|
|
+ Map<Long, KwtGatekeeperWaybillOrder> gatekeeperMap = new HashMap<>();
|
|
|
+ Set<Long> wOrderId = records.stream().map(KwtWaybillOrderSubtask::getWOrderId).collect(Collectors.toSet());
|
|
|
+ List<KwtGatekeeperWaybillOrder> gatekeeperList = gatekeeperWaybillOrderRepository.queryGatekeeperWaybillOrderByWOrderIds(wOrderId);
|
|
|
+
|
|
|
+ if (CollectionUtils.isNotEmpty(gatekeeperList)) {
|
|
|
+ gatekeeperMap = gatekeeperList.stream()
|
|
|
+ .collect(Collectors.toMap(KwtGatekeeperWaybillOrder::getWOrderId,
|
|
|
+ Function.identity(), (x, y) -> y));
|
|
|
+ }
|
|
|
+
|
|
|
// 转换为响应对象
|
|
|
log.debug("开始转换为响应对象");
|
|
|
List<WaybillOrderResp> resps = convertToWaybillOrderRespList(
|
|
|
- records, orderData, dictValueAndDictResDtoMap,logisticsOrderMap, tradeOrderContractVoMap,orderContracGoodstoMap);
|
|
|
+ records, orderData, dictValueAndDictResDtoMap,logisticsOrderMap, tradeOrderContractVoMap,orderContracGoodstoMap, gatekeeperMap);
|
|
|
log.info("转换完成,响应对象数量: {}", resps.size());
|
|
|
|
|
|
return PageDataResult.of(page, resps);
|
|
|
@@ -3461,10 +3474,11 @@ public class KwtWaybillOrderV1Service {
|
|
|
Map<String, Map<String, String>> dictValueAndDictResDtoMap,
|
|
|
Map<Long, KwtLogisticsOrder> logisticsOrderMap,
|
|
|
Map<Long, TradeOrderContractVo> tradeOrderContractVoMap,
|
|
|
- Map<String, TradeContractGoodsDto> orderContracGoodstoMap) {
|
|
|
+ Map<String, TradeContractGoodsDto> orderContracGoodstoMap,
|
|
|
+ Map<Long, KwtGatekeeperWaybillOrder> gatekeeperMap) {
|
|
|
|
|
|
return records.stream()
|
|
|
- .map(record -> buildWaybillOrderResp(record, orderData, dictValueAndDictResDtoMap,logisticsOrderMap, tradeOrderContractVoMap,orderContracGoodstoMap))
|
|
|
+ .map(record -> buildWaybillOrderResp(record, orderData, dictValueAndDictResDtoMap,logisticsOrderMap, tradeOrderContractVoMap,orderContracGoodstoMap, gatekeeperMap))
|
|
|
.collect(Collectors.toList());
|
|
|
}
|
|
|
|
|
|
@@ -3477,7 +3491,8 @@ public class KwtWaybillOrderV1Service {
|
|
|
Map<String, Map<String, String>> dictValueAndDictResDtoMap,
|
|
|
Map<Long, KwtLogisticsOrder> logisticsOrderMap,
|
|
|
Map<Long, TradeOrderContractVo> tradeOrderContractVoMap,
|
|
|
- Map<String, TradeContractGoodsDto> orderContracGoodstoMap) {
|
|
|
+ Map<String, TradeContractGoodsDto> orderContracGoodstoMap,
|
|
|
+ Map<Long, KwtGatekeeperWaybillOrder> gatekeeperMap) {
|
|
|
|
|
|
return getWaybillOrderResp(
|
|
|
record,
|
|
|
@@ -3494,7 +3509,8 @@ public class KwtWaybillOrderV1Service {
|
|
|
orderData.getTicketMap(),
|
|
|
logisticsOrderMap,
|
|
|
tradeOrderContractVoMap,
|
|
|
- orderContracGoodstoMap);
|
|
|
+ orderContracGoodstoMap,
|
|
|
+ gatekeeperMap);
|
|
|
}
|
|
|
|
|
|
public WaybillOrderSaleVo saleSum() {
|
|
|
@@ -4138,7 +4154,8 @@ public class KwtWaybillOrderV1Service {
|
|
|
Map<String, KwtWaybillOrderTicket> ticketMap,
|
|
|
Map<Long, KwtLogisticsOrder> logisticsOrderMap,
|
|
|
Map<Long, TradeOrderContractVo> tradeOrderContractVoMap,
|
|
|
- Map<String, TradeContractGoodsDto> orderContracGoodstoMap) {
|
|
|
+ Map<String, TradeContractGoodsDto> orderContracGoodstoMap,
|
|
|
+ Map<Long, KwtGatekeeperWaybillOrder> gatekeeperMap) {
|
|
|
WaybillOrderResp waybillOrderResp = new WaybillOrderResp();
|
|
|
KwtWaybillOrder billOrder = finalWaybillOrderIdAndBillOrderMap.getOrDefault(record.getWOrderId(),
|
|
|
new KwtWaybillOrder());
|
|
|
@@ -4257,6 +4274,8 @@ public class KwtWaybillOrderV1Service {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ KwtGatekeeperWaybillOrder gatekeeper = gatekeeperMap.getOrDefault(billOrder.getId(), new KwtGatekeeperWaybillOrder());
|
|
|
+ waybillOrderResp.setGatekeeperId(gatekeeper.getId());
|
|
|
|
|
|
return waybillOrderResp;
|
|
|
}
|