|
@@ -28,6 +28,7 @@ import com.sckw.order.api.model.OrderUnitInfoDetailVO;
|
|
|
import com.sckw.product.api.dubbo.GoodsInfoService;
|
|
import com.sckw.product.api.dubbo.GoodsInfoService;
|
|
|
import com.sckw.product.api.model.KwpGoods;
|
|
import com.sckw.product.api.model.KwpGoods;
|
|
|
import com.sckw.system.api.RemoteSystemService;
|
|
import com.sckw.system.api.RemoteSystemService;
|
|
|
|
|
+import com.sckw.system.api.model.dto.res.SysDictResDto;
|
|
|
import com.sckw.system.api.model.dto.res.UserCacheResDto;
|
|
import com.sckw.system.api.model.dto.res.UserCacheResDto;
|
|
|
import com.sckw.transport.handler.*;
|
|
import com.sckw.transport.handler.*;
|
|
|
import com.sckw.transport.model.*;
|
|
import com.sckw.transport.model.*;
|
|
@@ -299,12 +300,23 @@ public class WaybillOrderService {
|
|
|
.collect(Collectors.groupingBy(KwtLogisticsOrder::getTOrderId));
|
|
.collect(Collectors.groupingBy(KwtLogisticsOrder::getTOrderId));
|
|
|
Map<Long, List<KwtWaybillOrderSubtask>> logisticsOrderIdAndSubtaskList = orderSubtaskList.stream()
|
|
Map<Long, List<KwtWaybillOrderSubtask>> logisticsOrderIdAndSubtaskList = orderSubtaskList.stream()
|
|
|
.collect(Collectors.groupingBy(KwtWaybillOrderSubtask::getLOrderId));
|
|
.collect(Collectors.groupingBy(KwtWaybillOrderSubtask::getLOrderId));
|
|
|
|
|
+
|
|
|
|
|
+ //查询字典
|
|
|
|
|
+ List<SysDictResDto> sysDictResDtos = remoteSystemService.queryDictByType(DictTypeEnum.PRODUCT_NAME_TYPE.getType());
|
|
|
|
|
+ Map<String, SysDictResDto> dictValueAndDictResDtoMap = new HashMap<>();
|
|
|
|
|
+ if (CollectionUtils.isNotEmpty(sysDictResDtos)){
|
|
|
|
|
+ //字典value映射字典
|
|
|
|
|
+ dictValueAndDictResDtoMap = sysDictResDtos.stream()
|
|
|
|
|
+ .collect(Collectors.toMap(SysDictResDto::getValue, Function.identity(), (x, y) -> x));
|
|
|
|
|
+ }
|
|
|
//组装数据
|
|
//组装数据
|
|
|
Map<Long, OrderDetailVo> finalTradeIdAndOrderDetailVoMap = tradeIdAndOrderDetailVoMap;
|
|
Map<Long, OrderDetailVo> finalTradeIdAndOrderDetailVoMap = tradeIdAndOrderDetailVoMap;
|
|
|
|
|
+ Map<String, SysDictResDto> finaldictValueAndDictResDtoMap = dictValueAndDictResDtoMap;
|
|
|
List<LogisticsOrderResp> ordderList = logOrderList.stream()
|
|
List<LogisticsOrderResp> ordderList = logOrderList.stream()
|
|
|
.map(order -> {
|
|
.map(order -> {
|
|
|
return getLogisticsOrderResp(order, logOrderIdAndGoodsMap, goodsIdAndGoodsMap, logOrderIdAndUnitMap,
|
|
return getLogisticsOrderResp(order, logOrderIdAndGoodsMap, goodsIdAndGoodsMap, logOrderIdAndUnitMap,
|
|
|
- tOrderIdAndUnitMap, logOrderIdAndAddressMap, logOrderIdAndCirculateMap, finalTradeIdAndOrderDetailVoMap,tradeIdAndLogOrderList,logisticsOrderIdAndSubtaskList);
|
|
|
|
|
|
|
+ tOrderIdAndUnitMap, logOrderIdAndAddressMap, logOrderIdAndCirculateMap, finalTradeIdAndOrderDetailVoMap,
|
|
|
|
|
+ tradeIdAndLogOrderList,logisticsOrderIdAndSubtaskList,finaldictValueAndDictResDtoMap);
|
|
|
}).collect(Collectors.toList());
|
|
}).collect(Collectors.toList());
|
|
|
log.info("查询司机关联车辆的物流订单成功!");
|
|
log.info("查询司机关联车辆的物流订单成功!");
|
|
|
return PageDataResult.success(param.getPageNum(), param.getPageSize(), (long) ordderList.size(), ordderList);
|
|
return PageDataResult.success(param.getPageNum(), param.getPageSize(), (long) ordderList.size(), ordderList);
|
|
@@ -345,15 +357,19 @@ public class WaybillOrderService {
|
|
|
Map<Long, KwtLogisticsOrderCirculate> logOrderIdAndCirculateMap,
|
|
Map<Long, KwtLogisticsOrderCirculate> logOrderIdAndCirculateMap,
|
|
|
Map<Long, OrderDetailVo> tradeIdAndOrderDetailVoMap,
|
|
Map<Long, OrderDetailVo> tradeIdAndOrderDetailVoMap,
|
|
|
Map<Long, List<KwtLogisticsOrder>> tradeIdAndLogOrderList ,
|
|
Map<Long, List<KwtLogisticsOrder>> tradeIdAndLogOrderList ,
|
|
|
- Map<Long, List<KwtWaybillOrderSubtask>> logisticsOrderIdAndSubtaskList) {
|
|
|
|
|
|
|
+ Map<Long, List<KwtWaybillOrderSubtask>> logisticsOrderIdAndSubtaskList,
|
|
|
|
|
+ Map<String, SysDictResDto> dictValueAndDictResDtoMap) {
|
|
|
LogisticsOrderResp orderResp = new LogisticsOrderResp();
|
|
LogisticsOrderResp orderResp = new LogisticsOrderResp();
|
|
|
orderResp.setLogisticsOrderId(Optional.ofNullable(order.getId()).map(String::valueOf).orElse(null));
|
|
orderResp.setLogisticsOrderId(Optional.ofNullable(order.getId()).map(String::valueOf).orElse(null));
|
|
|
orderResp.setLogisticsOrderNo(order.getLOrderNo());
|
|
orderResp.setLogisticsOrderNo(order.getLOrderNo());
|
|
|
//商品
|
|
//商品
|
|
|
KwtLogisticsOrderGoods orderGoods = logOrderIdAndGoodsMap.getOrDefault(order.getId(), new KwtLogisticsOrderGoods());
|
|
KwtLogisticsOrderGoods orderGoods = logOrderIdAndGoodsMap.getOrDefault(order.getId(), new KwtLogisticsOrderGoods());
|
|
|
KwpGoods goods = goodsIdAndGoodsMap.getOrDefault(orderGoods.getGoodsId(), new KwpGoods());
|
|
KwpGoods goods = goodsIdAndGoodsMap.getOrDefault(orderGoods.getGoodsId(), new KwpGoods());
|
|
|
- orderResp.setGoodsId(String.valueOf(goods.getId()));
|
|
|
|
|
- orderResp.setGoodsName(goods.getName());
|
|
|
|
|
|
|
+ if (Objects.nonNull(goods)){
|
|
|
|
|
+ SysDictResDto sysDictResDto = dictValueAndDictResDtoMap.getOrDefault(goods.getGoodsType(), new SysDictResDto());
|
|
|
|
|
+ orderResp.setGoodsId(String.valueOf(goods.getId()));
|
|
|
|
|
+ orderResp.setGoodsName(goods.getName()+ "/" +sysDictResDto.getLabel()+"/"+ goods.getSpec());
|
|
|
|
|
+ }
|
|
|
|
|
|
|
|
//托运企业
|
|
//托运企业
|
|
|
KwtLogisticsOrderUnit consignEnt = logOrderIdAndUnitMap.getOrDefault(order.getId() + "-" + UnitTypeEnum.CONSIGN.getCode(), new KwtLogisticsOrderUnit());
|
|
KwtLogisticsOrderUnit consignEnt = logOrderIdAndUnitMap.getOrDefault(order.getId() + "-" + UnitTypeEnum.CONSIGN.getCode(), new KwtLogisticsOrderUnit());
|
|
@@ -386,7 +402,7 @@ public class WaybillOrderService {
|
|
|
orderResp.setStartTime(DateUtils.format(order.getStartTime(), DateUtils.DATE_PATTERN));
|
|
orderResp.setStartTime(DateUtils.format(order.getStartTime(), DateUtils.DATE_PATTERN));
|
|
|
orderResp.setEndTime(DateUtils.format(order.getEndTime(), DateUtils.DATE_PATTERN));
|
|
orderResp.setEndTime(DateUtils.format(order.getEndTime(), DateUtils.DATE_PATTERN));
|
|
|
KwtLogisticsOrderCirculate orderCirculate = logOrderIdAndCirculateMap.getOrDefault(order.getId(), new KwtLogisticsOrderCirculate());
|
|
KwtLogisticsOrderCirculate orderCirculate = logOrderIdAndCirculateMap.getOrDefault(order.getId(), new KwtLogisticsOrderCirculate());
|
|
|
- orderResp.setSendTime(DateUtils.format(orderCirculate.getCreateTime(), DateUtils.DATE_PATTERN));
|
|
|
|
|
|
|
+ orderResp.setSendTime(DateUtils.format(orderCirculate.getCreateTime(), DateUtils.DATE_TIME_PATTERN));
|
|
|
|
|
|
|
|
//派单人信息
|
|
//派单人信息
|
|
|
UserCacheResDto userCacheResDto = remoteSystemService.queryUserCacheById(orderCirculate.getCreateBy());
|
|
UserCacheResDto userCacheResDto = remoteSystemService.queryUserCacheById(orderCirculate.getCreateBy());
|