|
|
@ -112,6 +112,8 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService { |
|
|
|
private final ITrunklineDetailProductClient trunklineDetailProductClient; |
|
|
|
private final ITrunklineDetailProductClient trunklineDetailProductClient; |
|
|
|
private final ITrunklineAdvanceDetailClient trunklineAdvanceDetailClient; |
|
|
|
private final ITrunklineAdvanceDetailClient trunklineAdvanceDetailClient; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
private final IOrderCountClient orderCountClient; |
|
|
|
|
|
|
|
|
|
|
|
// @Override
|
|
|
|
// @Override
|
|
|
|
// public FactoryTokenVO getToken(String corpId, String appKey, String appSecret) throws NoSuchAlgorithmException {
|
|
|
|
// public FactoryTokenVO getToken(String corpId, String appKey, String appSecret) throws NoSuchAlgorithmException {
|
|
|
|
//
|
|
|
|
//
|
|
|
@ -381,6 +383,7 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService { |
|
|
|
total = total + ad.getTotal(); |
|
|
|
total = total + ad.getTotal(); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Map<String, String> supplyData = advanceDetailClient.getSupplyData(unitNo); |
|
|
|
Map<String, String> supplyData = advanceDetailClient.getSupplyData(unitNo); |
|
|
|
String destinationWarehouse= ""; |
|
|
|
String destinationWarehouse= ""; |
|
|
|
String takeCompany= ""; |
|
|
|
String takeCompany= ""; |
|
|
@ -396,6 +399,14 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService { |
|
|
|
throw new CustomerException(405, "仓库信息不存在"); |
|
|
|
throw new CustomerException(405, "仓库信息不存在"); |
|
|
|
} |
|
|
|
} |
|
|
|
Long warehouseId = basicdataWarehouseEntity.getId(); |
|
|
|
Long warehouseId = basicdataWarehouseEntity.getId(); |
|
|
|
|
|
|
|
Integer oldId = basicdataWarehouseEntity.getOldId(); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
OrderCountEntity orderCountEntity = orderCountClient.getEntityByOrderCode(orderSelfNum,oldId); |
|
|
|
|
|
|
|
if(Objects.isNull(orderCountEntity)){ |
|
|
|
|
|
|
|
log.warn("#################handleDataToPlatform: 未查询单订单信息 orderCode={}",orderSelfNum); |
|
|
|
|
|
|
|
throw new CustomerException(403,"未查询单订单信息"); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
//判断新系统是否有这条订单数据
|
|
|
|
//判断新系统是否有这条订单数据
|
|
|
|
DistributionStockArticleEntity distributionStockArticleEntity = distributionStockArticleClient.findStockArticleByOrderCodeAndWarehouseId(orderSelfNum,warehouseId); |
|
|
|
DistributionStockArticleEntity distributionStockArticleEntity = distributionStockArticleClient.findStockArticleByOrderCodeAndWarehouseId(orderSelfNum,warehouseId); |
|
|
|
|
|
|
|
|
|
|
@ -416,7 +427,8 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService { |
|
|
|
distributionStockArticleEntity.setMallName(takeCompany); |
|
|
|
distributionStockArticleEntity.setMallName(takeCompany); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
distributionStockArticleEntity.setWarehouseEntryTime(date); |
|
|
|
distributionStockArticleEntity.setWarehouseEntryTime(orderCountEntity.getCreateTime()); |
|
|
|
|
|
|
|
distributionStockArticleEntity.setWarehouseEntryTimeEnd(orderCountEntity.getLatestInTime()); |
|
|
|
distributionStockArticleEntity.setTotalNumber(total); |
|
|
|
distributionStockArticleEntity.setTotalNumber(total); |
|
|
|
distributionStockArticleEntity.setHandQuantity(0); |
|
|
|
distributionStockArticleEntity.setHandQuantity(0); |
|
|
|
distributionStockArticleEntity.setTenantId(TenantNum.HUITONGCODE);// 对应租户ID
|
|
|
|
distributionStockArticleEntity.setTenantId(TenantNum.HUITONGCODE);// 对应租户ID
|
|
|
@ -541,7 +553,7 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService { |
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
//保存包件信息
|
|
|
|
//保存包件信息
|
|
|
|
saveOrderPackage(unitNo, distributionStockArticleEntity, basicdataWarehouseEntity, waybillNoNum,operationTime); |
|
|
|
saveOrderPackage(unitNo, distributionStockArticleEntity, basicdataWarehouseEntity, waybillNoNum,operationTime,oldId); |
|
|
|
|
|
|
|
|
|
|
|
logger.info("#################handleDataToPlatform: 数据处理完成"); |
|
|
|
logger.info("#################handleDataToPlatform: 数据处理完成"); |
|
|
|
} else { |
|
|
|
} else { |
|
|
@ -645,7 +657,7 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService { |
|
|
|
* @param distributionStockArticleEntity 订单对象 |
|
|
|
* @param distributionStockArticleEntity 订单对象 |
|
|
|
* @param basicdataWarehouseEntity 仓库对象 |
|
|
|
* @param basicdataWarehouseEntity 仓库对象 |
|
|
|
*/ |
|
|
|
*/ |
|
|
|
private void saveOrderPackage(String unitNo, DistributionStockArticleEntity distributionStockArticleEntity, BasicdataWarehouseEntity basicdataWarehouseEntity, String waybillNo,String operationTime) { |
|
|
|
private void saveOrderPackage(String unitNo, DistributionStockArticleEntity distributionStockArticleEntity, BasicdataWarehouseEntity basicdataWarehouseEntity, String waybillNo,String operationTime,Integer oldWarehouseId) { |
|
|
|
|
|
|
|
|
|
|
|
DistributionParcelListEntityVO vo = advanceDetailClient.getByUnitNo(unitNo);; |
|
|
|
DistributionParcelListEntityVO vo = advanceDetailClient.getByUnitNo(unitNo);; |
|
|
|
// 判断当前查询包件不是否为皮阿落
|
|
|
|
// 判断当前查询包件不是否为皮阿落
|
|
|
@ -663,6 +675,9 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService { |
|
|
|
if(Objects.isNull(vo)){ |
|
|
|
if(Objects.isNull(vo)){ |
|
|
|
logger.warn("##############saveOrderPackage: 未在老系统查询到包件数据 unitNo={}",unitNo); |
|
|
|
logger.warn("##############saveOrderPackage: 未在老系统查询到包件数据 unitNo={}",unitNo); |
|
|
|
}else{ |
|
|
|
}else{ |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
OrderDetailEntity orderDetailEntity = orderDetailClient.findEntityByUnitNoAndOldWarehosueId(unitNo,oldWarehouseId); |
|
|
|
|
|
|
|
|
|
|
|
DistributionParcelListEntity entity = new DistributionParcelListEntity(); |
|
|
|
DistributionParcelListEntity entity = new DistributionParcelListEntity(); |
|
|
|
BeanUtil.copyProperties(vo, entity); |
|
|
|
BeanUtil.copyProperties(vo, entity); |
|
|
|
entity.setQuantity(1); |
|
|
|
entity.setQuantity(1); |
|
|
@ -695,7 +710,10 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService { |
|
|
|
//进销售
|
|
|
|
//进销售
|
|
|
|
entity.setDealerCode(distributionStockArticleEntity.getDealerCode()); |
|
|
|
entity.setDealerCode(distributionStockArticleEntity.getDealerCode()); |
|
|
|
entity.setDealerName(distributionStockArticleEntity.getDealerName()); |
|
|
|
entity.setDealerName(distributionStockArticleEntity.getDealerName()); |
|
|
|
entity.setWarehouseEntryTimeEnd(CommonUtil.StringToDate(operationTime)); |
|
|
|
|
|
|
|
|
|
|
|
if(!Objects.isNull(orderDetailEntity)){ |
|
|
|
|
|
|
|
entity.setWarehouseEntryTimeEnd(orderDetailEntity.getCreateTime()); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
// 绑定部门--仓库
|
|
|
|
// 绑定部门--仓库
|
|
|
|
if (!Objects.isNull(basicdataWarehouseEntity)) { |
|
|
|
if (!Objects.isNull(basicdataWarehouseEntity)) { |
|
|
|