|
|
|
@ -264,6 +264,13 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
|
|
|
|
|
if (startCarType == 1) { |
|
|
|
|
//车辆配载发车
|
|
|
|
|
Integer realLoadingNumber = carsLoadEntity.getRealLoadingNumber(); |
|
|
|
|
if(NumberUtil.equals(realLoadingNumber,0)){ |
|
|
|
|
log.warn("#############startCarByLoadId: 车辆还未装车 loadId={} realLoadingNumber={}", loadId, realLoadingNumber); |
|
|
|
|
throw new CustomerException(405, "车辆还未装车"); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//查询发站仓节点信息
|
|
|
|
|
TrunklineCarsLoadLineEntity carsLoadLineEntity = trunklineCarsLoadLineService.findStartNodeByLoadId(loadId); |
|
|
|
|
String nodeStatus = carsLoadLineEntity.getNodeStatus();//节点状态 0未到达 1到车 2发车
|
|
|
|
@ -515,6 +522,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
.content(value.stream().map(data->{ |
|
|
|
|
return PushData.builder() |
|
|
|
|
.packageCode(data.getPackageCode()) |
|
|
|
|
.waybillNumber(data.getWaybillNumber()) |
|
|
|
|
.warehouseName(warehouseEntity.getName()) |
|
|
|
|
.orderCode(data.getOrderCode()) |
|
|
|
|
.build(); |
|
|
|
@ -2442,6 +2450,14 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
updateNumByLoadId(loadId); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public R findCarsLoadingOrderPlan(Long loadId, Long warehouseId) { |
|
|
|
|
|
|
|
|
|
List<CarsLoadPackagePlanVO> list = trunklineCarsOrderService.findLoadingOrderPlan(loadId, warehouseId); |
|
|
|
|
|
|
|
|
|
return R.data(list); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Transactional(rollbackFor = Exception.class) |
|
|
|
|
@Override |
|
|
|
@ -4488,9 +4504,9 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public R findCarsLoadingOrderDetail(Long loadId, String orderCode, Long warehouseId) { |
|
|
|
|
public R findCarsLoadingOrderDetail(Long loadId, String orderCode, Long warehouseId,String waybillNo) { |
|
|
|
|
|
|
|
|
|
List<OrderScanDetailVO> orderScanDetailList = trunklineCarsLoadScanService.findCarsLoadingOrderDetail(loadId, orderCode, warehouseId); |
|
|
|
|
List<OrderScanDetailVO> orderScanDetailList = trunklineCarsLoadScanService.findCarsLoadingOrderDetail(loadId, orderCode, warehouseId,waybillNo); |
|
|
|
|
if(CollUtil.isNotEmpty(orderScanDetailList)){ |
|
|
|
|
//把orderScanDetailList中所有元素的loadScanId放入一个List
|
|
|
|
|
List<Long> loadScanIdList = orderScanDetailList.stream().map(OrderScanDetailVO::getLoadScanId).collect(Collectors.toList()); |
|
|
|
@ -8293,7 +8309,9 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
QueryWrapper<TrunklineCarsLoadScanEntity> queryWrapper = new QueryWrapper<>(); |
|
|
|
|
queryWrapper.eq("load_id", loadId) |
|
|
|
|
.eq("warehouse_id", warehouseId) |
|
|
|
|
.eq("loading_abnormal", 1); |
|
|
|
|
.eq("loading_abnormal", 1) |
|
|
|
|
.eq("is_data", 0) |
|
|
|
|
.orderByDesc("update_time"); |
|
|
|
|
List<TrunklineCarsLoadScanEntity> exceptionList = trunklineCarsLoadScanService.list(queryWrapper); |
|
|
|
|
|
|
|
|
|
TrunklineCarsLoadVO trunklineCarsLoadVO = new TrunklineCarsLoadVO(); |
|
|
|
@ -8861,6 +8879,14 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
//查询包件是否签收
|
|
|
|
|
DistributionParcelListEntity signDistributionParcelListEntity = distributionParcelListClient.findOrderPackageCodeAndStatus(orderPackageCode,"70"); |
|
|
|
|
if (!Objects.isNull(distributionParcelListEntity)) { |
|
|
|
|
log.warn("##############unloadPackage: 包件已签收 orderPackageCode={} warehouseId={}", orderPackageCode, warehouseId); |
|
|
|
|
return R.fail(405, "包件已签收"); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
QueryWrapper<TrunklineCarsLoadScanEntity> neloadScanQueryWrapper = new QueryWrapper<>(); |
|
|
|
|
neloadScanQueryWrapper.eq("load_id", loadId) |
|
|
|
|
.eq("scan_code", orderPackageCode) |
|
|
|
@ -8869,6 +8895,11 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
TrunklineCarsLoadScanEntity scanEntity = trunklineCarsLoadScanService.getOne(neloadScanQueryWrapper); |
|
|
|
|
|
|
|
|
|
if (!Objects.isNull(scanEntity)) { |
|
|
|
|
Integer isData1 = scanEntity.getIsData(); |
|
|
|
|
if (isData1.equals(0)) { |
|
|
|
|
log.warn("##############unloadPackage: 系统无编码 orderPackageCode={} warehouseId={}", orderPackageCode, warehouseId); |
|
|
|
|
return R.fail(405, "系统无编码"); |
|
|
|
|
} |
|
|
|
|
log.warn("##############unloadPackage: 包件已卸车 orderPackageCode={} warehouseId={}", orderPackageCode, warehouseId); |
|
|
|
|
return R.fail(405, "包件已卸车"); |
|
|
|
|
} |
|
|
|
@ -9522,6 +9553,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
.content(Collections.singletonList(PushData.builder() |
|
|
|
|
.packageCode(orderPackageCode) |
|
|
|
|
.warehouseName(warehouseName) |
|
|
|
|
.waybillNumber(parcelListEntity.getWaybillNumber()) |
|
|
|
|
.destinationWarehouse(ObjectUtil.isNotEmpty(parcelListEntity) ? parcelListEntity.getAcceptWarehouseName():"") |
|
|
|
|
.waybillStartWarehouse(ObjectUtil.isNotEmpty(parcelListEntity) ? parcelListEntity.getSendWarehouseName():"") |
|
|
|
|
.orderCode(orderCode) |
|
|
|
@ -9541,9 +9573,9 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
Integer abnormalUnloadNum = jsonObject.getInteger("abnormalUnloadNum"); |
|
|
|
|
StringBuilder audio = new StringBuilder(); |
|
|
|
|
audio.append("卸车").append(totalUnloadNum).append("件"); |
|
|
|
|
if(!Objects.isNull(abnormalUnloadNum) && !abnormalUnloadNum.equals(0)){ |
|
|
|
|
audio.append("异常卸车").append(abnormalUnloadNum).append("件"); |
|
|
|
|
} |
|
|
|
|
// if(!Objects.isNull(abnormalUnloadNum) && !abnormalUnloadNum.equals(0)){
|
|
|
|
|
// audio.append("异常卸车").append(abnormalUnloadNum).append("件");
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
List<String> orderPackageCodeList = new ArrayList<>(); |
|
|
|
|
orderPackageCodeList.add(orderPackageCode); |
|
|
|
@ -9557,26 +9589,28 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Transactional(rollbackFor = Exception.class) |
|
|
|
|
@Override |
|
|
|
|
public R unloadPackageNoXz(Long loadId, String orderPackageCode, Long warehouseId, Integer unbindTray, String remark, Integer incomingType,String unloadTrayName,String unloadTrayCode) { |
|
|
|
|
log.info("#############unloadPackage: 卸车包件"); |
|
|
|
|
log.info("#############unloadPackageNoXz: 卸车包件"); |
|
|
|
|
|
|
|
|
|
BasicdataWarehouseEntity basicdataWarehouseEntity = basicdataWarehouseClient.getEntityWarehouseId(warehouseId); |
|
|
|
|
if (Objects.isNull(basicdataWarehouseEntity)) { |
|
|
|
|
log.warn("##############unloadPackage: 仓库信息不存在"); |
|
|
|
|
log.warn("##############unloadPackageNoXz: 仓库信息不存在"); |
|
|
|
|
return R.fail(405, "仓库信息不存在"); |
|
|
|
|
} |
|
|
|
|
String warehouseName = basicdataWarehouseEntity.getName(); |
|
|
|
|
|
|
|
|
|
TrunklineCarsLoadEntity carsLoadEntity = baseMapper.selectById(loadId); |
|
|
|
|
if (Objects.isNull(carsLoadEntity)) { |
|
|
|
|
log.warn("##############unloadPackage: 配载计划信息不存在 loadId={}", loadId); |
|
|
|
|
log.warn("##############unloadPackageNoXz: 配载计划信息不存在 loadId={}", loadId); |
|
|
|
|
return R.fail(405, "配载计划信息不存在"); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
String loadCode = carsLoadEntity.getCarsNo(); |
|
|
|
|
TrunklineCarsLoadLineEntity carsLoadLineEntity = trunklineCarsLoadLineService.findEntityByLoadIdAndNodeId(loadId, warehouseId); |
|
|
|
|
if (Objects.isNull(carsLoadLineEntity)) { |
|
|
|
|
log.warn("############unloadPackage: 配载计划节点信息不存在 loadId={} warehouseId={}", loadId, warehouseId); |
|
|
|
|
log.warn("############unloadPackageNoXz: 配载计划节点信息不存在 loadId={} warehouseId={}", loadId, warehouseId); |
|
|
|
|
return R.fail(405, "配载计划节点信息不存在"); |
|
|
|
|
} |
|
|
|
|
// String unloadStatus = carsLoadLineEntity.getUnloadStatus();
|
|
|
|
@ -9598,15 +9632,41 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
if (!Objects.isNull(distributionParcelListEntity)) { |
|
|
|
|
String orderPackageStatus = distributionParcelListEntity.getOrderPackageStatus(); |
|
|
|
|
if ("20".equals(orderPackageStatus) || "30".equals(orderPackageStatus)) { |
|
|
|
|
log.warn("##############unloadPackage: 包件已入库 orderPackageCode={} warehouseId={}", orderPackageCode, warehouseId); |
|
|
|
|
log.warn("##############unloadPackageNoXz: 包件已入库 orderPackageCode={} warehouseId={}", orderPackageCode, warehouseId); |
|
|
|
|
return R.fail(405, "包件已入库"); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
//查询包件是否签收
|
|
|
|
|
DistributionParcelListEntity signDistributionParcelListEntity = distributionParcelListClient.findOrderPackageCodeAndStatus(orderPackageCode,"70"); |
|
|
|
|
if (!Objects.isNull(distributionParcelListEntity)) { |
|
|
|
|
log.warn("##############unloadPackage: 包件已签收 orderPackageCode={} warehouseId={}", orderPackageCode, warehouseId); |
|
|
|
|
return R.fail(405, "包件已签收"); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
QueryWrapper<TrunklineCarsLoadScanEntity> neloadScanQueryWrapper = new QueryWrapper<>(); |
|
|
|
|
neloadScanQueryWrapper.eq("load_id", loadId) |
|
|
|
|
.eq("scan_code", orderPackageCode) |
|
|
|
|
.eq("unload_node_id", warehouseId) |
|
|
|
|
.ne("scan_status", "1"); |
|
|
|
|
TrunklineCarsLoadScanEntity scanEntity = trunklineCarsLoadScanService.getOne(neloadScanQueryWrapper); |
|
|
|
|
|
|
|
|
|
if (!Objects.isNull(scanEntity)) { |
|
|
|
|
Integer isData1 = scanEntity.getIsData(); |
|
|
|
|
if (isData1.equals(0)) { |
|
|
|
|
log.warn("##############unloadPackage: 系统无编码 orderPackageCode={} warehouseId={}", orderPackageCode, warehouseId); |
|
|
|
|
return R.fail(405, "系统无编码"); |
|
|
|
|
} |
|
|
|
|
log.warn("##############unloadPackage: 包件已卸车 orderPackageCode={} warehouseId={}", orderPackageCode, warehouseId); |
|
|
|
|
return R.fail(405, "包件已卸车"); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
//先判断包件是否在配载计划的装车扫描中
|
|
|
|
|
QueryWrapper<TrunklineCarsLoadScanEntity> loadScanQueryWrapper = new QueryWrapper<>(); |
|
|
|
|
loadScanQueryWrapper.eq("load_id", loadId) |
|
|
|
|
.eq("scan_code", orderPackageCode); |
|
|
|
|
.eq("scan_code", orderPackageCode) |
|
|
|
|
.eq("scan_status","1"); |
|
|
|
|
TrunklineCarsLoadScanEntity carsLoadScanEntity = trunklineCarsLoadScanService.getOne(loadScanQueryWrapper); |
|
|
|
|
//判断是否有装车扫描记录
|
|
|
|
|
if (Objects.isNull(carsLoadScanEntity)) { |
|
|
|
@ -9646,10 +9706,11 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
trunklineCarsLoadScanEntity.setUnloadNodeName(warehouseName); |
|
|
|
|
trunklineCarsLoadScanEntity.setUnloadNodeId(warehouseId); |
|
|
|
|
trunklineCarsLoadScanEntity.setUnloadNum(1); |
|
|
|
|
trunklineCarsLoadScanEntity.setIsSupple(0); |
|
|
|
|
trunklineCarsLoadScanEntity.setIsSupple(1); |
|
|
|
|
trunklineCarsLoadScanEntity.setLoadingUserName(AuthUtil.getNickName()); |
|
|
|
|
trunklineCarsLoadScanEntity.setUnloadUserName(AuthUtil.getNickName()); |
|
|
|
|
trunklineCarsLoadScanEntity.setUnloadTime(new Date()); |
|
|
|
|
trunklineCarsLoadScanEntity.setRemark("异常补录卸车"); |
|
|
|
|
trunklineCarsLoadScanService.save(trunklineCarsLoadScanEntity); |
|
|
|
|
loadScanId = trunklineCarsLoadScanEntity.getId(); |
|
|
|
|
|
|
|
|
@ -9683,12 +9744,12 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
trunklineCarsLoadScanEntity.setUnloadNodeName(warehouseName); |
|
|
|
|
trunklineCarsLoadScanEntity.setUnloadNodeId(warehouseId); |
|
|
|
|
trunklineCarsLoadScanEntity.setUnloadNum(1); |
|
|
|
|
trunklineCarsLoadScanEntity.setIsSupple(0); |
|
|
|
|
trunklineCarsLoadScanEntity.setIsSupple(1); |
|
|
|
|
trunklineCarsLoadScanEntity.setLoadingUserName(AuthUtil.getNickName()); |
|
|
|
|
trunklineCarsLoadScanEntity.setUnloadUserName(AuthUtil.getNickName()); |
|
|
|
|
trunklineCarsLoadScanEntity.setUnloadTime(new Date()); |
|
|
|
|
trunklineCarsLoadScanEntity.setFromWarehouseId(nowWarehouseId); |
|
|
|
|
trunklineCarsLoadScanEntity.setRemark("无装车记录卸车"); |
|
|
|
|
trunklineCarsLoadScanEntity.setRemark("无装车记录 异常补录卸车"); |
|
|
|
|
trunklineCarsLoadScanService.save(trunklineCarsLoadScanEntity); |
|
|
|
|
loadScanId = trunklineCarsLoadScanEntity.getId(); |
|
|
|
|
|
|
|
|
@ -9702,13 +9763,13 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
try { |
|
|
|
|
carsLoadAsyncService.abnormalListUnloadByLoadIdAndWarehouseId(loadId, warehouseId, warehouseName, loadScanId, AuthUtil.getTenantId(), AuthUtil.getUserId(), AuthUtil.getNickName(), Func.firstLong(AuthUtil.getDeptId())); |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
log.warn("###############unloadPackage: 存入异常列表记录失败"); |
|
|
|
|
log.warn("###############unloadPackageNoXz: 存入异常列表记录失败"); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
DistributionParcelListEntity nowParcelListEntity = distributionParcelListClient.findByPacketBarCodeAndWarehouseId(orderPackageCode, nowWarehouseId); |
|
|
|
|
if(Objects.isNull(nowParcelListEntity)){ |
|
|
|
|
log.warn("###############unloadPackage: 包件信息不存在 orderPackageCode={},nowWarehouseId={}",orderPackageCode,nowWarehouseId); |
|
|
|
|
log.warn("###############unloadPackageNoXz: 包件信息不存在 orderPackageCode={},nowWarehouseId={}",orderPackageCode,nowWarehouseId); |
|
|
|
|
return R.fail(405,"包件信息不存在"); |
|
|
|
|
} |
|
|
|
|
orderCode = nowParcelListEntity.getOrderCode(); |
|
|
|
@ -9718,7 +9779,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
|
|
|
|
|
DistributionStockArticleEntity nowDistributionStockArticle = distributionStockArticleClient.findStockArticleByOrderCodeAndWarehouseId(orderCode, nowWarehouseId); |
|
|
|
|
if(Objects.isNull(nowDistributionStockArticle)){ |
|
|
|
|
log.warn("###############unloadPackage: 订单信息不存在 orderCode={},nowWarehouseId={}",orderCode,nowWarehouseId); |
|
|
|
|
log.warn("###############unloadPackageNoXz: 订单信息不存在 orderCode={},nowWarehouseId={}",orderCode,nowWarehouseId); |
|
|
|
|
return R.fail(405,"订单信息不存在"); |
|
|
|
|
} |
|
|
|
|
Long articleId = nowDistributionStockArticle.getId(); |
|
|
|
@ -9805,36 +9866,41 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
}else{ |
|
|
|
|
//需要补装车扫记录
|
|
|
|
|
TrunklineCarsLoadScanEntity trunklineCarsLoadScanEntity = new TrunklineCarsLoadScanEntity(); |
|
|
|
|
trunklineCarsLoadScanEntity.setWarehouseId(warehouseId); |
|
|
|
|
trunklineCarsLoadScanEntity.setWarehouseName(warehouseName); |
|
|
|
|
trunklineCarsLoadScanEntity.setLoadId(loadId); |
|
|
|
|
trunklineCarsLoadScanEntity.setLoadCode(loadCode); |
|
|
|
|
trunklineCarsLoadScanEntity.setOrderCode("--"); |
|
|
|
|
trunklineCarsLoadScanEntity.setScanCode(orderPackageCode); |
|
|
|
|
trunklineCarsLoadScanEntity.setScanStatus("2"); |
|
|
|
|
trunklineCarsLoadScanEntity.setNum(1); |
|
|
|
|
trunklineCarsLoadScanEntity.setType(1); |
|
|
|
|
trunklineCarsLoadScanEntity.setIsData(0); |
|
|
|
|
isData=0; |
|
|
|
|
trunklineCarsLoadScanEntity.setLoadingAbnormal(1); |
|
|
|
|
trunklineCarsLoadScanEntity.setUnloadAbnormal(1); |
|
|
|
|
trunklineCarsLoadScanEntity.setUnloadNodeName(warehouseName); |
|
|
|
|
trunklineCarsLoadScanEntity.setUnloadNodeId(warehouseId); |
|
|
|
|
trunklineCarsLoadScanEntity.setUnloadNum(1); |
|
|
|
|
trunklineCarsLoadScanEntity.setIsSupple(0); |
|
|
|
|
trunklineCarsLoadScanEntity.setLoadingUserName(AuthUtil.getNickName()); |
|
|
|
|
trunklineCarsLoadScanEntity.setUnloadUserName(AuthUtil.getNickName()); |
|
|
|
|
trunklineCarsLoadScanEntity.setUnloadTime(new Date()); |
|
|
|
|
trunklineCarsLoadScanService.save(trunklineCarsLoadScanEntity); |
|
|
|
|
loadScanId = trunklineCarsLoadScanEntity.getId(); |
|
|
|
|
|
|
|
|
|
trunklineCarsLoadingLogService.savaLoadingLog(warehouseId, warehouseName, loadId, loadCode, null, null, null, orderPackageCode, 1, |
|
|
|
|
1, 0, 1, trayId, trayCode, trayName, null, loadScanId, "无数据,补装车计划,异常装车"); |
|
|
|
|
log.info("################unloadPackageNoXz: 无系统编码 orderPackageCode={}",orderPackageCode); |
|
|
|
|
return R.fail(405,"无系统编码"); |
|
|
|
|
|
|
|
|
|
trunklineCarsUnloadLogService.savaUnloadLog(warehouseId, warehouseName, loadId, loadCode, null, null, null, orderPackageCode, 1, |
|
|
|
|
1, 0, 1, trayId, trayCode, trayName, null, loadScanId, "无数据,异常卸车"); |
|
|
|
|
//需要补装车扫记录
|
|
|
|
|
// TrunklineCarsLoadScanEntity trunklineCarsLoadScanEntity = new TrunklineCarsLoadScanEntity();
|
|
|
|
|
// trunklineCarsLoadScanEntity.setWarehouseId(warehouseId);
|
|
|
|
|
// trunklineCarsLoadScanEntity.setWarehouseName(warehouseName);
|
|
|
|
|
// trunklineCarsLoadScanEntity.setLoadId(loadId);
|
|
|
|
|
// trunklineCarsLoadScanEntity.setLoadCode(loadCode);
|
|
|
|
|
// trunklineCarsLoadScanEntity.setOrderCode("--");
|
|
|
|
|
// trunklineCarsLoadScanEntity.setScanCode(orderPackageCode);
|
|
|
|
|
// trunklineCarsLoadScanEntity.setScanStatus("2");
|
|
|
|
|
// trunklineCarsLoadScanEntity.setNum(1);
|
|
|
|
|
// trunklineCarsLoadScanEntity.setType(1);
|
|
|
|
|
// trunklineCarsLoadScanEntity.setIsData(0);
|
|
|
|
|
// isData=0;
|
|
|
|
|
// trunklineCarsLoadScanEntity.setLoadingAbnormal(1);
|
|
|
|
|
// trunklineCarsLoadScanEntity.setUnloadAbnormal(1);
|
|
|
|
|
// trunklineCarsLoadScanEntity.setUnloadNodeName(warehouseName);
|
|
|
|
|
// trunklineCarsLoadScanEntity.setUnloadNodeId(warehouseId);
|
|
|
|
|
// trunklineCarsLoadScanEntity.setUnloadNum(1);
|
|
|
|
|
// trunklineCarsLoadScanEntity.setIsSupple(1);
|
|
|
|
|
// trunklineCarsLoadScanEntity.setLoadingUserName(AuthUtil.getNickName());
|
|
|
|
|
// trunklineCarsLoadScanEntity.setUnloadUserName(AuthUtil.getNickName());
|
|
|
|
|
// trunklineCarsLoadScanEntity.setUnloadTime(new Date());
|
|
|
|
|
// trunklineCarsLoadScanEntity.setRemark("异常补录卸车");
|
|
|
|
|
// trunklineCarsLoadScanService.save(trunklineCarsLoadScanEntity);
|
|
|
|
|
// loadScanId = trunklineCarsLoadScanEntity.getId();
|
|
|
|
|
//
|
|
|
|
|
// trunklineCarsLoadingLogService.savaLoadingLog(warehouseId, warehouseName, loadId, loadCode, null, null, null, orderPackageCode, 1,
|
|
|
|
|
// 1, 0, 1, trayId, trayCode, trayName, null, loadScanId, "无数据,补装车计划,异常装车");
|
|
|
|
|
//
|
|
|
|
|
// trunklineCarsUnloadLogService.savaUnloadLog(warehouseId, warehouseName, loadId, loadCode, null, null, null, orderPackageCode, 1,
|
|
|
|
|
// 1, 0, 1, trayId, trayCode, trayName, null, loadScanId, "无数据,异常卸车");
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
} else { |
|
|
|
@ -9847,7 +9913,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
|
|
|
|
|
DistributionStockArticleEntity stockArticleEntity = distributionStockArticleClient.findStockArticleByOrderCodeAndWarehouseId(orderCode, wid); |
|
|
|
|
if (Objects.isNull(stockArticleEntity)) { |
|
|
|
|
log.warn("##############unloadPackage: 订单信息不存在 orderCode={} wid={}", orderCode, wid); |
|
|
|
|
log.warn("##############unloadPackageNoXz: 订单信息不存在 orderCode={} wid={}", orderCode, wid); |
|
|
|
|
return R.fail(405, "订单信息不存在"); |
|
|
|
|
} |
|
|
|
|
Long articleId = stockArticleEntity.getId(); |
|
|
|
@ -9879,6 +9945,8 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
trunklineCarsLoadScanEntity.setLoadingUserName(AuthUtil.getNickName()); |
|
|
|
|
trunklineCarsLoadScanEntity.setUnloadUserName(AuthUtil.getNickName()); |
|
|
|
|
trunklineCarsLoadScanEntity.setUnloadTime(new Date()); |
|
|
|
|
trunklineCarsLoadScanEntity.setIsSupple(1); |
|
|
|
|
trunklineCarsLoadScanEntity.setRemark("无计划异常补录卸车"); |
|
|
|
|
trunklineCarsLoadScanService.save(trunklineCarsLoadScanEntity); |
|
|
|
|
|
|
|
|
|
isData = 1; |
|
|
|
@ -10012,6 +10080,8 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
carsLoadScanEntity.setScanStatus("2"); |
|
|
|
|
carsLoadScanEntity.setUnloadUserName(AuthUtil.getNickName()); |
|
|
|
|
carsLoadScanEntity.setUnloadTime(new Date()); |
|
|
|
|
carsLoadScanEntity.setUnloadAbnormal(1); |
|
|
|
|
carsLoadScanEntity.setIsSupple(1); |
|
|
|
|
trayCode = carsLoadScanEntity.getTrayCode(); |
|
|
|
|
if (!StringUtil.isBlank(trayCode)) { |
|
|
|
|
BasicdataTrayEntity trayEntity = basicdataTrayClient.getTrayByTrayCode(trayCode); |
|
|
|
@ -10209,12 +10279,24 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
.content(Collections.singletonList(PushData.builder() |
|
|
|
|
.packageCode(orderPackageCode) |
|
|
|
|
.warehouseName(warehouseName) |
|
|
|
|
.waybillNumber(parcelListEntity.getWaybillNumber()) |
|
|
|
|
.destinationWarehouse(ObjectUtil.isNotEmpty(parcelListEntity) ? parcelListEntity.getAcceptWarehouseName():"") |
|
|
|
|
.waybillStartWarehouse(ObjectUtil.isNotEmpty(parcelListEntity) ? parcelListEntity.getSendWarehouseName():"") |
|
|
|
|
.orderCode(orderCode) |
|
|
|
|
.build())) |
|
|
|
|
.build(); |
|
|
|
|
factoryDataMessageSender.sendNodeDataByBrand(nodePushMsg); |
|
|
|
|
|
|
|
|
|
//卸车确认
|
|
|
|
|
Long warehouseId1 = parcelListEntity.getWarehouseId(); |
|
|
|
|
Long acceptWarehouseId = parcelListEntity.getAcceptWarehouseId(); |
|
|
|
|
WorkNodeEnums node = WorkNodeEnums.TRANSFER_WAREHOUSE_UNLOADING; |
|
|
|
|
if(NumberUtil.equals(warehouseId1,acceptWarehouseId)){ |
|
|
|
|
node = WorkNodeEnums.END_WAREHOUSE_UNLOADING; |
|
|
|
|
} |
|
|
|
|
List<LoadScanBrandDTO> brands = this.baseMapper.fingPackageCodeByLoadId(loadId, warehouseId); |
|
|
|
|
sendFactoryData(brands, node, warehouseId, 2); |
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
log.error("入库推送失败:{}", e); |
|
|
|
@ -10222,15 +10304,14 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
} catch (Exception e) { |
|
|
|
|
log.warn("#########卸车存入日志失败"); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
JSONObject jsonObject = trunklineCarsLoadScanService.findUnloadNumAudio(loadId,warehouseId); |
|
|
|
|
Integer totalUnloadNum = jsonObject.getInteger("totalUnloadNum"); |
|
|
|
|
Integer abnormalUnloadNum = jsonObject.getInteger("abnormalUnloadNum"); |
|
|
|
|
StringBuilder audio = new StringBuilder(); |
|
|
|
|
audio.append("卸车").append(totalUnloadNum).append("件"); |
|
|
|
|
if(!Objects.isNull(abnormalUnloadNum) && !abnormalUnloadNum.equals(0)){ |
|
|
|
|
audio.append("异常卸车").append(abnormalUnloadNum).append("件"); |
|
|
|
|
} |
|
|
|
|
// if(!Objects.isNull(abnormalUnloadNum) && !abnormalUnloadNum.equals(0)){
|
|
|
|
|
// audio.append("异常卸车").append(abnormalUnloadNum).append("件");
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
List<String> orderPackageCodeList = new ArrayList<>(); |
|
|
|
@ -10760,27 +10841,28 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
|
|
|
|
|
//查询已扫描卸车的包件
|
|
|
|
|
List<UnloadScanOrderVO> unloadScanOrderList = trunklineCarsLoadScanService.findPackageWithOrderList(loadId, warehouseId); |
|
|
|
|
|
|
|
|
|
List<UnloadPackageVO> unloadList = trunklineCarsLoadScanService.findUnloadPackageListByLoadIdAndFinalNodeId(loadId,warehouseId); |
|
|
|
|
|
|
|
|
|
if(CollUtil.isNotEmpty(unloadScanOrderList)){ |
|
|
|
|
//把unloadScanOrderList中所有元素转化成以orderCode为key的map
|
|
|
|
|
// Map<String, List<UnloadScanOrderVO>> unloadScanOrderMap = unloadScanOrderList.stream().collect(Collectors.toMap(UnloadScanOrderVO::getOrderCode, Function.identity()));
|
|
|
|
|
Set<String> orderCodeSet = unloadScanOrderList.stream().map(UnloadScanOrderVO::getOrderCode).collect(Collectors.toSet()); |
|
|
|
|
// Set<String> orderCodeSet = unloadScanOrderList.stream().map(UnloadScanOrderVO::getOrderCode).collect(Collectors.toSet());
|
|
|
|
|
// Map<String, List<UnloadScanOrderVO>> unloadScanOrderMap =unloadScanOrderList.stream().map(UnloadScanOrderVO::getOrderCode).collect(Collectors.toList())
|
|
|
|
|
// Set<String> orderCodeSet = unloadScanOrderMap.keySet();
|
|
|
|
|
List<OrderCodeNumVO> orderCodeNumList = trunklineAdvanceDetailService.findTotalNumByOrderCodes(orderCodeSet); |
|
|
|
|
// List<OrderCodeNumVO> orderCodeNumList = trunklineAdvanceDetailService.findTotalNumByOrderCodes(orderCodeSet);
|
|
|
|
|
//把orderCodeNumList中所有元素转化成以orderCode为key的map
|
|
|
|
|
Map<String, OrderCodeNumVO> orderCodeNumMap = orderCodeNumList.stream().collect(Collectors.toMap(OrderCodeNumVO::getOrderCode, Function.identity())); |
|
|
|
|
|
|
|
|
|
List<UnloadPackageVO> unloadList = trunklineCarsLoadScanService.findUnloadPackageListByLoadIdAndFinalNodeId(loadId,warehouseId); |
|
|
|
|
// Map<String, OrderCodeNumVO> orderCodeNumMap = orderCodeNumList.stream().collect(Collectors.toMap(OrderCodeNumVO::getOrderCode, Function.identity()));
|
|
|
|
|
|
|
|
|
|
for (UnloadScanOrderVO unloadScanOrderVO : unloadScanOrderList) { |
|
|
|
|
String waybillNo = StringUtil.isBlank(unloadScanOrderVO.getWaybillNo())?"null":unloadScanOrderVO.getWaybillNo(); |
|
|
|
|
String orderCode = StringUtil.isBlank(unloadScanOrderVO.getOrderCode())?"null":unloadScanOrderVO.getOrderCode(); |
|
|
|
|
OrderCodeNumVO orderCodeNumVO = orderCodeNumMap.get(orderCode); |
|
|
|
|
if(!Objects.isNull(orderCodeNumVO)){ |
|
|
|
|
unloadScanOrderVO.setTotalNumber(orderCodeNumVO.getTotalNum()); |
|
|
|
|
}else{ |
|
|
|
|
unloadScanOrderVO.setTotalNumber(0); |
|
|
|
|
} |
|
|
|
|
// OrderCodeNumVO orderCodeNumVO = orderCodeNumMap.get(orderCode);
|
|
|
|
|
// if(!Objects.isNull(orderCodeNumVO)){
|
|
|
|
|
// unloadScanOrderVO.setTotalNumber(orderCodeNumVO.getTotalNum());
|
|
|
|
|
// }else{
|
|
|
|
|
// unloadScanOrderVO.setTotalNumber(0);
|
|
|
|
|
// }
|
|
|
|
|
|
|
|
|
|
List<UnloadPackageVO> unloadPackageList = new ArrayList<>(); |
|
|
|
|
unloadList.forEach(unloadPackageVO -> { |
|
|
|
@ -10833,7 +10915,9 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
|
|
|
|
|
QueryWrapper<TrunklineCarsLoadScanEntity> queryWrapper = new QueryWrapper<>(); |
|
|
|
|
queryWrapper.eq("load_id", loadId) |
|
|
|
|
.eq("unload_node_id", warehouseId) |
|
|
|
|
.eq("unload_abnormal", 1); |
|
|
|
|
.eq("unload_abnormal", 1) |
|
|
|
|
.eq("is_data", 0) |
|
|
|
|
.orderByDesc("update_time"); |
|
|
|
|
List<TrunklineCarsLoadScanEntity> exceptionList = trunklineCarsLoadScanService.list(queryWrapper); |
|
|
|
|
|
|
|
|
|
TrunklineCarsLoadVO trunklineCarsLoadVO = new TrunklineCarsLoadVO(); |
|
|
|
|