java_project
/
logisticsplatform-service
4
0
Fork 0
Code Issues Pull Requests Activity
Browse Source

增加商家端推送数据

dev
汤建军 3 weeks ago
parent
9a419ae295
commit
7d5a938f72
1 changed files with 15 additions and 0 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 15
      blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionReservationServiceImpl.java

15
blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionReservationServiceImpl.java
Unescape View File

@ -498,6 +498,10 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
} }
} }
Map<String,List> map = new HashMap<>();
List<DistributionReservationPackageEntity> reservationPackageEntityList = new ArrayList<>();
List<DistributionReservationZeroPackageEntity> reservationZeroPackageEntityList = new ArrayList<>();
List<DistributionReservationStocklistEntity> reservationStocklistEntityList = new ArrayList<>();
//构建预约单 //构建预约单
DistributionReservationEntity reservationEntity = new DistributionReservationEntity(); DistributionReservationEntity reservationEntity = new DistributionReservationEntity();
Func.copy(distributionReservationDTO, reservationEntity); Func.copy(distributionReservationDTO, reservationEntity);
@ -620,6 +624,7 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
distributionReservationPackageEntity.setParceListId(dp.getId()); distributionReservationPackageEntity.setParceListId(dp.getId());
distributionReservationPackageEntity.setStockArticleId(s.getId()); distributionReservationPackageEntity.setStockArticleId(s.getId());
distributionReservationPackageEntity.setPacketBarCode(dp.getOrderPackageCode()); distributionReservationPackageEntity.setPacketBarCode(dp.getOrderPackageCode());
reservationPackageEntityList.add(distributionReservationPackageEntity);
//维护订单下包件信息 //维护订单下包件信息
distributionReservationPackageService.save(distributionReservationPackageEntity); distributionReservationPackageService.save(distributionReservationPackageEntity);
//此时订单下的所有包件都处于预约状态，可用数为0 //此时订单下的所有包件都处于预约状态，可用数为0
@ -652,6 +657,7 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
distributionReservationPackageEntity.setParceListId(p.getId()); distributionReservationPackageEntity.setParceListId(p.getId());
distributionReservationPackageEntity.setStockArticleId(s.getId()); distributionReservationPackageEntity.setStockArticleId(s.getId());
distributionReservationPackageEntity.setPacketBarCode(p.getOrderPackageCode()); distributionReservationPackageEntity.setPacketBarCode(p.getOrderPackageCode());
reservationPackageEntityList.add(distributionReservationPackageEntity);
distributionReservationPackageService.save(distributionReservationPackageEntity); distributionReservationPackageService.save(distributionReservationPackageEntity);
packageNum.getAndAdd(p.getQuantity()); packageNum.getAndAdd(p.getQuantity());
p.setOrderPackageReservationStatus(OrderPackageReservationStatusConstant.yiyueyue.getValue()); p.setOrderPackageReservationStatus(OrderPackageReservationStatusConstant.yiyueyue.getValue());
@ -725,6 +731,7 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
distributionReservationZeroPackageEntity.setParcelListId(p.getParcelListId()); distributionReservationZeroPackageEntity.setParcelListId(p.getParcelListId());
distributionReservationZeroPackageEntity.setType(DistributionTypeConstant.shipie.getValue()); distributionReservationZeroPackageEntity.setType(DistributionTypeConstant.shipie.getValue());
distributionReservationZeroPackageEntity.setZeroPackageStatus(ReservationOrderStatusConstant.zhengchang.getValue()); distributionReservationZeroPackageEntity.setZeroPackageStatus(ReservationOrderStatusConstant.zhengchang.getValue());
reservationZeroPackageEntityList.add(distributionReservationZeroPackageEntity);
distributionReservationZeroPackageService.save(distributionReservationZeroPackageEntity); distributionReservationZeroPackageService.save(distributionReservationZeroPackageEntity);
//统计数量 //统计数量
zeroPackageNum.getAndAdd(distributionReservationZeroPackageEntity.getQuantity()); zeroPackageNum.getAndAdd(distributionReservationZeroPackageEntity.getQuantity());
@ -751,6 +758,7 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
distributionReservationZeroPackageEntity.setCategoryName(l.getFirsts()); distributionReservationZeroPackageEntity.setCategoryName(l.getFirsts());
distributionReservationZeroPackageEntity.setType(DistributionTypeConstant.shipie.getValue()); distributionReservationZeroPackageEntity.setType(DistributionTypeConstant.shipie.getValue());
distributionReservationZeroPackageEntity.setZeroPackageStatus(ReservationOrderStatusConstant.zhengchang.getValue()); distributionReservationZeroPackageEntity.setZeroPackageStatus(ReservationOrderStatusConstant.zhengchang.getValue());
reservationZeroPackageEntityList.add(distributionReservationZeroPackageEntity);
distributionReservationZeroPackageService.save(distributionReservationZeroPackageEntity); distributionReservationZeroPackageService.save(distributionReservationZeroPackageEntity);
//统计数量 //统计数量
zeroPackageNum.getAndAdd(distributionReservationZeroPackageEntity.getQuantity()); zeroPackageNum.getAndAdd(distributionReservationZeroPackageEntity.getQuantity());
@ -826,6 +834,7 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
distributionReservationStocklistEntity.setStockListStatus("1"); distributionReservationStocklistEntity.setStockListStatus("1");
distributionReservationStocklistEntity.setLoadingStatus(ReservationInventoryLoadingStatusConstant.weizhuangche.getValue()); distributionReservationStocklistEntity.setLoadingStatus(ReservationInventoryLoadingStatusConstant.weizhuangche.getValue());
distributionReservationStocklistEntity.setSigningStatus(ReservationInventorySigningStatusConstant.weiqianshou.getValue()); distributionReservationStocklistEntity.setSigningStatus(ReservationInventorySigningStatusConstant.weiqianshou.getValue());
reservationStocklistEntityList.add(distributionReservationStocklistEntity);
distributionReservationStocklistService.save(distributionReservationStocklistEntity); distributionReservationStocklistService.save(distributionReservationStocklistEntity);
stockListCount.getAndAdd(distributionReservationStocklistEntity.getReservationNum()); stockListCount.getAndAdd(distributionReservationStocklistEntity.getReservationNum());
List<DisStockListDetailEntity> detailEntities = new ArrayList<>(); List<DisStockListDetailEntity> detailEntities = new ArrayList<>();
@ -898,6 +907,12 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
reservationEntity.setSigningStatus(ReservationSigningStatusConstant.daiqianshou.getValue()); reservationEntity.setSigningStatus(ReservationSigningStatusConstant.daiqianshou.getValue());
reservationEntity.setWarehouseId(reservationEntity.getWarehouseId()); reservationEntity.setWarehouseId(reservationEntity.getWarehouseId());
distributionReservationMapper.updateById(reservationEntity); distributionReservationMapper.updateById(reservationEntity);
map.put("1",reservationPackageEntityList);
map.put("2",reservationZeroPackageEntityList);
map.put("3",reservationStocklistEntityList);
NodeFanoutMsg<ReservationVO> nodeFanoutMsg = buildNodeFanoutMsgByReservation(reservationEntity,map,BizOperationEnums.ADD);
distributionNodeWorkService.planReservation(nodeFanoutMsg,AuthUtil.getUser());
handleCreatedReservationPlanLog(reservationEntity,AuthUtil.getUser(),myCurrentWarehouse);
return R.status(true); return R.status(true);
} }

Write Preview
Loading…
Cancel
Save