|
|
|
@ -66,8 +66,6 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService {
|
|
|
|
|
|
|
|
|
|
private static final Logger logger = LoggerFactory.getLogger(PanFactoryDataServiceImpl.class); |
|
|
|
|
|
|
|
|
|
// private final IFactoryAccountService factoryAccountService;
|
|
|
|
|
// private final IFactoryTokenService factoryTokenService;
|
|
|
|
|
|
|
|
|
|
private final IPanFactoryOrderService factoryOrderService; |
|
|
|
|
private final IPanPackageInfoService packageInfoService; |
|
|
|
@ -76,13 +74,10 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService {
|
|
|
|
|
private final PanFactoryProperties panFactoryProperties; |
|
|
|
|
private final IOrderStatusLogService panOrderStatusLogService; |
|
|
|
|
private final IPanPackageInfoService panPackageInfoService; |
|
|
|
|
private final IPanFactoryOrderService panFactoryOrderService; |
|
|
|
|
private final IAdvanceDetailClient advanceDetailClient; |
|
|
|
|
private final IWarehouseClient warehouseClient; |
|
|
|
|
private final IOrderClient orderClient; |
|
|
|
|
private final IOrderDetailClient orderDetailClient; |
|
|
|
|
private final IAdvanceClient advanceClient; |
|
|
|
|
// private final IMainlineWaybillClient mainlineWaybillClient;
|
|
|
|
|
private final IWayBillClient wayBillClient; |
|
|
|
|
|
|
|
|
|
private final IDistributionParcelListClient distributionParcelListClient; |
|
|
|
@ -375,7 +370,7 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService {
|
|
|
|
|
//判断新系统是否有这条订单数据
|
|
|
|
|
DistributionStockArticleEntity distributionStockArticleEntity = distributionStockArticleClient.findByAdvanceId(advanceId); |
|
|
|
|
|
|
|
|
|
Long id = null; |
|
|
|
|
Long id; |
|
|
|
|
String waybillNoNum = advanceEntity.getWaybillNo(); |
|
|
|
|
|
|
|
|
|
if (Objects.isNull(distributionStockArticleEntity)) { |
|
|
|
@ -391,8 +386,7 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService {
|
|
|
|
|
// 其实是客户
|
|
|
|
|
distributionStockArticleEntity.setMallName(takeCompany); |
|
|
|
|
|
|
|
|
|
distributionStockArticleEntity.setWarehouse(destinationWarehouse); |
|
|
|
|
distributionStockArticleEntity.setWarehouseId(basicdataWarehouseEntity.getId()); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
distributionStockArticleEntity.setWarehouseEntryTime(date); |
|
|
|
|
distributionStockArticleEntity.setTotalNumber(total); |
|
|
|
@ -408,7 +402,7 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService {
|
|
|
|
|
} else { |
|
|
|
|
distributionStockArticleEntity.setCompleteSet(0); |
|
|
|
|
} |
|
|
|
|
logger.info("############basicdataWarehouseEntity}", basicdataWarehouseEntity); |
|
|
|
|
logger.info("############basicdataWarehouseEntity {}", basicdataWarehouseEntity); |
|
|
|
|
if (!Objects.isNull(basicdataWarehouseEntity)) { |
|
|
|
|
distributionStockArticleEntity.setCreateDept(basicdataWarehouseEntity.getDepartment()); |
|
|
|
|
} |
|
|
|
@ -421,7 +415,7 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService {
|
|
|
|
|
distributionStockArticleEntity.setConsigneeAddress(wayBillEntity.getTakeAddress());//收货人地址
|
|
|
|
|
distributionStockArticleEntity.setConsigneeMobile(wayBillEntity.getTakePhone());//收货人电话
|
|
|
|
|
|
|
|
|
|
// 根据老的运单上的仓库名称找寻新的仓库名称
|
|
|
|
|
// 根据老运单上的仓库名称找寻新的仓库名称
|
|
|
|
|
|
|
|
|
|
// 发站
|
|
|
|
|
String warehouseName = wayBillEntity.getStartSite(); |
|
|
|
@ -432,14 +426,16 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService {
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
//收货仓库
|
|
|
|
|
warehouseName = wayBillEntity.getArriveSite(); |
|
|
|
|
warehouseName = wayBillEntity.getWarehouseName(); |
|
|
|
|
t = basicdataWarehouseClient.findByName(warehouseName); |
|
|
|
|
if(ObjectUtils.isNotNull(t)){ |
|
|
|
|
distributionStockArticleEntity.setAcceptWarehouseName(t.getName()); |
|
|
|
|
distributionStockArticleEntity.setAcceptWarehouseId(t.getId()); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// TODO 这里存在问题 后需要知道当前作业仓库
|
|
|
|
|
distributionStockArticleEntity.setWarehouse(t.getName()); |
|
|
|
|
distributionStockArticleEntity.setWarehouseId(t.getId()); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
String customerName = wayBillEntity.getTakeCompany();//客户名称
|
|
|
|
@ -455,9 +451,8 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService {
|
|
|
|
|
distributionStockArticleEntity.setMallCode(basicdataClientEntity.getClientCode()); |
|
|
|
|
|
|
|
|
|
// todo 这里需要去查询门店 和新系统的门店ID 进行绑定
|
|
|
|
|
|
|
|
|
|
String peisongType = getPeisongTypeByClientId(basicdataClientEntity.getId()); |
|
|
|
|
logger.info("订单同步peisongType{} ", peisongType); |
|
|
|
|
logger.info("订单同步peisongType {} ", peisongType); |
|
|
|
|
|
|
|
|
|
if (StringUtil.isNoneBlank(peisongType)) { |
|
|
|
|
distributionStockArticleEntity.setTypeService(peisongType); |
|
|
|
@ -507,7 +502,7 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService {
|
|
|
|
|
distributionStockArticleEntity.setWaybillNumber(waybillNumber); |
|
|
|
|
|
|
|
|
|
// 修改入库状态
|
|
|
|
|
distributionStockArticleEntity.setHandQuantity(distributionStockArticleEntity.getHandQuantity().intValue()+1); |
|
|
|
|
distributionStockArticleEntity.setHandQuantity(distributionStockArticleEntity.getHandQuantity() +1); |
|
|
|
|
String orderStatus = checkDistributionStockArticleOrderStatus(distributionStockArticleEntity); |
|
|
|
|
distributionStockArticleEntity.setOrderStatus(orderStatus); |
|
|
|
|
|
|
|
|
@ -522,7 +517,7 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService {
|
|
|
|
|
distributionStockArticleEntity.setWarehouseEntryTimeEnd(new Date()); |
|
|
|
|
distributionStockArticleClient.saveOrUpdate(distributionStockArticleEntity); |
|
|
|
|
|
|
|
|
|
// //包件保存成功去修改订单的数量
|
|
|
|
|
// 包件保存成功去修改订单的数量
|
|
|
|
|
// distributionStockArticleClient.addHandQuantity(id, 1);
|
|
|
|
|
logger.info("#################handleDataToPlatform: 数据处理完成"); |
|
|
|
|
} else { |
|
|
|
@ -533,8 +528,8 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService {
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
|
* 根据订单的在库数联返回订单的状态 |
|
|
|
|
* @param distributionStockArticleEntity |
|
|
|
|
* @return |
|
|
|
|
* @param distributionStockArticleEntity 订单对象 |
|
|
|
|
* @return String 状态码值 |
|
|
|
|
*/ |
|
|
|
|
private String checkDistributionStockArticleOrderStatus(DistributionStockArticleEntity distributionStockArticleEntity) { |
|
|
|
|
|
|
|
|
@ -554,8 +549,8 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService {
|
|
|
|
|
/** |
|
|
|
|
* 根据客户ID 查询客户的配送类型 |
|
|
|
|
* |
|
|
|
|
* @param id |
|
|
|
|
* @return |
|
|
|
|
* @param id 客户ID |
|
|
|
|
* @return String 客户的服务类型 |
|
|
|
|
*/ |
|
|
|
|
private String getPeisongTypeByClientId(Long id) { |
|
|
|
|
BasicdataStoreBusinessEntity basicdataStoreBusinessEntity = basicdataStoreBusinessClient.findByClientIdAndTypeService(id, 3); |
|
|
|
@ -570,10 +565,9 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService {
|
|
|
|
|
/** |
|
|
|
|
* 保存包件信息 |
|
|
|
|
* |
|
|
|
|
* @param unitNo |
|
|
|
|
* @param distributionStockArticleEntity |
|
|
|
|
* @param id |
|
|
|
|
* @param basicdataWarehouseEntity |
|
|
|
|
* @param unitNo 包条码 |
|
|
|
|
* @param distributionStockArticleEntity 订单对象 |
|
|
|
|
* @param basicdataWarehouseEntity 仓库对象 |
|
|
|
|
*/ |
|
|
|
|
private void saveOrderPackage(String unitNo, DistributionStockArticleEntity distributionStockArticleEntity, BasicdataWarehouseEntity basicdataWarehouseEntity, String waybillNo) { |
|
|
|
|
DistributionParcelListEntityVO vo = advanceDetailClient.getByUnitNo(unitNo); |
|
|
|
@ -740,8 +734,8 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService {
|
|
|
|
|
/** |
|
|
|
|
* 构建订单的经销商信息和门店信息 |
|
|
|
|
* |
|
|
|
|
* @param distributionStockArticleEntity |
|
|
|
|
* @param advanceEntity |
|
|
|
|
* @param distributionStockArticleEntity 订单对象 |
|
|
|
|
* @param advanceEntity 老订单对象 |
|
|
|
|
*/ |
|
|
|
|
private void buildDealerAndStore(DistributionStockArticleEntity distributionStockArticleEntity, AdvanceEntity advanceEntity) { |
|
|
|
|
|
|
|
|
@ -757,14 +751,15 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService {
|
|
|
|
|
distributionStockArticleEntity.setCustomerAddress(advanceEntity.getCustomerRoad()); |
|
|
|
|
distributionStockArticleEntity.setCustomerTelephone(advanceEntity.getCustomerPhone()); |
|
|
|
|
|
|
|
|
|
// 服务号
|
|
|
|
|
distributionStockArticleEntity.setServiceNumber(advanceEntity.getServiceNum()); |
|
|
|
|
|
|
|
|
|
distributionStockArticleEntity.setDescriptionGoods(advanceEntity.getFirstPackName()); |
|
|
|
|
|
|
|
|
|
// 品牌
|
|
|
|
|
distributionStockArticleEntity.setBrand(advanceEntity.getType()); |
|
|
|
|
distributionStockArticleEntity.setResource(advanceEntity.getType()); |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
@ -793,7 +788,7 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService {
|
|
|
|
|
QueryWrapper<PanFactoryOrder> queryWrapper = new QueryWrapper<>(); |
|
|
|
|
queryWrapper.eq("order_no", orderNo); |
|
|
|
|
List<PanFactoryOrder> one = factoryOrderService.list(queryWrapper); |
|
|
|
|
if (!Objects.isNull(one) && one.size() > 0) { |
|
|
|
|
if (!Objects.isNull(one) && !one.isEmpty()) { |
|
|
|
|
//如果订单已存在就去验证订单下面的包件信息
|
|
|
|
|
List<PanPackageInfoDTO> order_attributes = factoryOrderDTO.getORDER_ATTRIBUTES(); |
|
|
|
|
QueryWrapper<PanPackageInfo> qw = new QueryWrapper<>(); |
|
|
|
@ -811,7 +806,7 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService {
|
|
|
|
|
} |
|
|
|
|
factoryOrderDTO.setORDER_ATTRIBUTES(order_attributes); |
|
|
|
|
|
|
|
|
|
if (order_attributes.size() == 0) { |
|
|
|
|
if (order_attributes.isEmpty()) { |
|
|
|
|
logger.info("###########saveData: 没有新增包件,不保存信息"); |
|
|
|
|
return null; |
|
|
|
|
} |
|
|
|
|