|
|
@@ -508,9 +508,9 @@ public class KwtWaybillOrderV1Service {
|
|
|
//子运单
|
|
|
List<KwtWaybillOrderSubtask> subtasks = waybillOrderSubtaskDao.findByWOrderId(waybillOrder.getWOrderId());
|
|
|
//子运单
|
|
|
- List<KwtWaybillOrderAddress> loadAddresses = waybillOrderAddressDao.findByAddresses(waybillOrder.getWOrderId(), AddressDefaultTypeEnum.SHIPMENT.getCode());
|
|
|
+ List<KwtWaybillOrderAddress> loadAddresses = waybillOrderAddressDao.findByAddresses(waybillOrder.getWOrderId(), AddressTypeEnum.SHIPMENT.getCode());
|
|
|
//子运单
|
|
|
- List<KwtWaybillOrderAddress> unloadAddresses = waybillOrderAddressDao.findByAddresses(waybillOrder.getWOrderId(), AddressDefaultTypeEnum.TAKE.getCode());
|
|
|
+ List<KwtWaybillOrderAddress> unloadAddresses = waybillOrderAddressDao.findByAddresses(waybillOrder.getWOrderId(), AddressTypeEnum.TAKE.getCode());
|
|
|
//装货时间
|
|
|
Optional<KwtWaybillOrderSubtask> unloadDate = subtasks.stream().max(Comparator.comparing(KwtWaybillOrderSubtask::getUnloadTime));
|
|
|
//卸货时间
|
|
|
@@ -586,7 +586,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
//数据处理
|
|
|
List<String> loadUrl = new ArrayList<>(), unloadUrl = new ArrayList<>();
|
|
|
for (KwtWaybillOrderTicket ticket:tickets) {
|
|
|
- if(ticket.getType().equals(AddressDefaultTypeEnum.SHIPMENT.getCode())){
|
|
|
+ if(ticket.getType().equals(AddressTypeEnum.SHIPMENT.getCode())){
|
|
|
loadUrl.add(FileUtils.spliceBatch(ticket.getUrls()));
|
|
|
} else {
|
|
|
unloadUrl.add(FileUtils.spliceBatch(ticket.getUrls()));
|
|
|
@@ -633,7 +633,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
//运单地址状态处理(到达装货点、已装货、到达卸货点、已卸货)
|
|
|
List<KwtWaybillOrderAddress> addresses = waybillOrderAddressDao.findByAddresses(wOrderId, null);
|
|
|
for (KwtWaybillOrderAddress address:addresses) {
|
|
|
- if (address.getAddressType().equals(AddressDefaultTypeEnum.SHIPMENT.getCode())) {
|
|
|
+ if (address.getAddressType().equals(AddressTypeEnum.SHIPMENT.getCode())) {
|
|
|
statusList = new ArrayList<>(){{add(CarWaybillEnum.WAIT_LOADING.getCode()); add(CarWaybillEnum.COMPLETION_LOADING.getCode());}};
|
|
|
} else {
|
|
|
statusList = new ArrayList<>(){{add(CarWaybillEnum.WAIT_UNLOADING.getCode()); add(CarWaybillEnum.COMPLETION_UNLOADING.getCode());}};
|
|
|
@@ -877,7 +877,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
//物流订单地址委托量信息-装货信息
|
|
|
KwtLogisticsOrderAddress queryAmount = new KwtLogisticsOrderAddress();
|
|
|
queryAmount.setLOrderId(lOrderId);
|
|
|
- queryAmount.setAddressType(AddressDefaultTypeEnum.SHIPMENT.getCode());
|
|
|
+ queryAmount.setAddressType(AddressTypeEnum.SHIPMENT.getCode());
|
|
|
List<KwtLogisticsOrderAmount> logisticsOrderAmounts = logisticsOrderAmountDao.findByAddress(queryAmount);
|
|
|
for (KwtLogisticsOrderAmount orderAmount:logisticsOrderAmounts) {
|
|
|
BigDecimal truckEntrustAmount = truckTotalEntrustAmount.get(orderAmount.getLAddressId());
|
|
|
@@ -944,7 +944,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
//计划装卸货时间
|
|
|
Date planTime = sendCarEntrust.getPlanTime();
|
|
|
//装货+卸货
|
|
|
- if (sendCarEntrust.getAddressType() == AddressDefaultTypeEnum.SHIPMENT.getCode()) {
|
|
|
+ if (sendCarEntrust.getAddressType() == AddressTypeEnum.SHIPMENT.getCode()) {
|
|
|
entrustAmount = entrustAmount.add(amount);
|
|
|
loadTime.add(planTime);
|
|
|
} else {
|
|
|
@@ -986,7 +986,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
//委派量
|
|
|
BigDecimal amount = BigDecimal.valueOf(sendCarEntrust.getEntrustAmount());
|
|
|
//装货+卸货
|
|
|
- if (sendCarEntrust.getAddressType() == AddressDefaultTypeEnum.SHIPMENT.getCode()) {
|
|
|
+ if (sendCarEntrust.getAddressType() == AddressTypeEnum.SHIPMENT.getCode()) {
|
|
|
if (lEntrustAmount.get(sendCarEntrust.getLOrderId()) == null) {
|
|
|
lEntrustAmount.put(sendCarEntrust.getLOrderId(), amount);
|
|
|
} else {
|
|
|
@@ -1174,7 +1174,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
/*4、回退物流订单委托量*/
|
|
|
/*4.1、装货址委派量entrustAmount回退*/
|
|
|
//运单装货地址
|
|
|
- List<KwtWaybillOrderAddress> orderAddresses = waybillOrderAddressDao.findByAddresses(wOrderId, AddressDefaultTypeEnum.SHIPMENT.getCode());
|
|
|
+ List<KwtWaybillOrderAddress> orderAddresses = waybillOrderAddressDao.findByAddresses(wOrderId, AddressTypeEnum.SHIPMENT.getCode());
|
|
|
for (KwtWaybillOrderAddress address:orderAddresses) {
|
|
|
//物流订单-装卸货地址运量信息
|
|
|
KwtLogisticsOrderAmount logisticsOrderAmount = logisticsOrderAmountDao.findByLAddressId(address.getLAddressId());
|
|
|
@@ -1251,7 +1251,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
/*6、累加物流订单委托量(循环运单)*/
|
|
|
/*6.1、装货址委派量entrustAmount累加*/
|
|
|
//运单装货地址
|
|
|
- List<KwtWaybillOrderAddress> orderAddresses = waybillOrderAddressDao.findByAddresses(wOrderId, AddressDefaultTypeEnum.SHIPMENT.getCode());
|
|
|
+ List<KwtWaybillOrderAddress> orderAddresses = waybillOrderAddressDao.findByAddresses(wOrderId, AddressTypeEnum.SHIPMENT.getCode());
|
|
|
for (KwtWaybillOrderAddress address:orderAddresses) {
|
|
|
//物流订单-装卸货地址运量信息
|
|
|
KwtLogisticsOrderAmount logisticsOrderAmount = logisticsOrderAmountDao.findByLAddressId(address.getLAddressId());
|
|
|
@@ -1316,7 +1316,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
/*5、回退物流订单委托量(循环运单)*/
|
|
|
/*5.1、装货址委派量entrustAmount回退*/
|
|
|
//运单装货地址
|
|
|
- List<KwtWaybillOrderAddress> orderAddresses = waybillOrderAddressDao.findByAddresses(wOrderId, AddressDefaultTypeEnum.SHIPMENT.getCode());
|
|
|
+ List<KwtWaybillOrderAddress> orderAddresses = waybillOrderAddressDao.findByAddresses(wOrderId, AddressTypeEnum.SHIPMENT.getCode());
|
|
|
for (KwtWaybillOrderAddress address:orderAddresses) {
|
|
|
//物流订单-装卸货地址运量信息
|
|
|
KwtLogisticsOrderAmount logisticsOrderAmount = logisticsOrderAmountDao.findByLAddressId(address.getLAddressId());
|
|
|
@@ -1444,7 +1444,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
/*5、回退物流订单委托量*/
|
|
|
/*5.1、装货址委派量entrustAmount回退*/
|
|
|
//运单装货地址
|
|
|
- List<KwtWaybillOrderAddress> orderAddresses = waybillOrderAddressDao.findByAddresses(wOrderId, AddressDefaultTypeEnum.SHIPMENT.getCode());
|
|
|
+ List<KwtWaybillOrderAddress> orderAddresses = waybillOrderAddressDao.findByAddresses(wOrderId, AddressTypeEnum.SHIPMENT.getCode());
|
|
|
for (KwtWaybillOrderAddress address:orderAddresses) {
|
|
|
//物流订单-装卸货地址运量信息
|
|
|
KwtLogisticsOrderAmount logisticsOrderAmount = logisticsOrderAmountDao.findByLAddressId(address.getLAddressId());
|
|
|
@@ -1784,9 +1784,9 @@ public class KwtWaybillOrderV1Service {
|
|
|
//物流运单信息
|
|
|
KwtLogisticsOrder logisticsOrder = logisticsOrderDao.selectById(orderSubtask.getLOrderId());
|
|
|
//运单-子单装货榜单信息
|
|
|
- List<KwtWaybillOrderTicket> loadTickets = waybillOrderTicketDao.findWaybillOrderTicketV1(wOrderId, ticket.getWSubtaskId(), AddressDefaultTypeEnum.SHIPMENT.getCode(), orderSubtask.getUnit());
|
|
|
+ List<KwtWaybillOrderTicket> loadTickets = waybillOrderTicketDao.findWaybillOrderTicketV1(wOrderId, ticket.getWSubtaskId(), AddressTypeEnum.SHIPMENT.getCode(), orderSubtask.getUnit());
|
|
|
//运单-子单卸货榜单信息
|
|
|
- List<KwtWaybillOrderTicket> unloadTickets = waybillOrderTicketDao.findWaybillOrderTicketV1(wOrderId, ticket.getWSubtaskId(), AddressDefaultTypeEnum.TAKE.getCode(), orderSubtask.getUnit());
|
|
|
+ List<KwtWaybillOrderTicket> unloadTickets = waybillOrderTicketDao.findWaybillOrderTicketV1(wOrderId, ticket.getWSubtaskId(), AddressTypeEnum.TAKE.getCode(), orderSubtask.getUnit());
|
|
|
//装货-总量
|
|
|
BigDecimal loadAmount = loadTickets.stream().map(KwtWaybillOrderTicket::getAmount ).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
//卸货-总量
|
|
|
@@ -1890,9 +1890,9 @@ public class KwtWaybillOrderV1Service {
|
|
|
//物流运单信息
|
|
|
KwtLogisticsOrder logisticsOrder = logisticsOrderDao.selectById(orderSubtask.getLOrderId());
|
|
|
//运单-子单装货榜单信息
|
|
|
- List<KwtWaybillOrderTicket> loadTickets = waybillOrderTicketDao.findWaybillOrderTicketV1(wOrderId, ticket.getWSubtaskId(), AddressDefaultTypeEnum.SHIPMENT.getCode(), orderSubtask.getUnit());
|
|
|
+ List<KwtWaybillOrderTicket> loadTickets = waybillOrderTicketDao.findWaybillOrderTicketV1(wOrderId, ticket.getWSubtaskId(), AddressTypeEnum.SHIPMENT.getCode(), orderSubtask.getUnit());
|
|
|
//运单-子单卸货榜单信息
|
|
|
- List<KwtWaybillOrderTicket> unloadTickets = waybillOrderTicketDao.findWaybillOrderTicketV1(wOrderId, ticket.getWSubtaskId(), AddressDefaultTypeEnum.TAKE.getCode(), orderSubtask.getUnit());
|
|
|
+ List<KwtWaybillOrderTicket> unloadTickets = waybillOrderTicketDao.findWaybillOrderTicketV1(wOrderId, ticket.getWSubtaskId(), AddressTypeEnum.TAKE.getCode(), orderSubtask.getUnit());
|
|
|
//装货-总量
|
|
|
BigDecimal loadAmount = loadTickets.stream().map(KwtWaybillOrderTicket::getAmount ).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
//卸货-总量
|
|
|
@@ -2104,9 +2104,9 @@ public class KwtWaybillOrderV1Service {
|
|
|
//物流运单信息
|
|
|
KwtLogisticsOrder logisticsOrder = logisticsOrderDao.selectById(orderSubtask.getLOrderId());
|
|
|
//运单-子单装货榜单信息
|
|
|
- List<KwtWaybillOrderTicket> loadTickets = waybillOrderTicketDao.findWaybillOrderTicketV1(wOrderId, ticket.getWSubtaskId(), AddressDefaultTypeEnum.SHIPMENT.getCode(), orderSubtask.getUnit());
|
|
|
+ List<KwtWaybillOrderTicket> loadTickets = waybillOrderTicketDao.findWaybillOrderTicketV1(wOrderId, ticket.getWSubtaskId(), AddressTypeEnum.SHIPMENT.getCode(), orderSubtask.getUnit());
|
|
|
//运单-子单卸货榜单信息
|
|
|
- List<KwtWaybillOrderTicket> unloadTickets = waybillOrderTicketDao.findWaybillOrderTicketV1(wOrderId, ticket.getWSubtaskId(), AddressDefaultTypeEnum.TAKE.getCode(), orderSubtask.getUnit());
|
|
|
+ List<KwtWaybillOrderTicket> unloadTickets = waybillOrderTicketDao.findWaybillOrderTicketV1(wOrderId, ticket.getWSubtaskId(), AddressTypeEnum.TAKE.getCode(), orderSubtask.getUnit());
|
|
|
//装货-总量
|
|
|
BigDecimal loadAmount = loadTickets.stream().map(KwtWaybillOrderTicket::getAmount ).reduce(BigDecimal.ZERO, BigDecimal::add);
|
|
|
//卸货-总量
|
|
|
@@ -2167,7 +2167,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
queryParams.put("lAddressId", amount.getLAddressId());
|
|
|
queryParams.put("passStatus", Global.NUMERICAL_ONE);
|
|
|
WaybillCountVo waybillCount = waybillOrderV1Dao.findTicketCountByAddress(queryParams);
|
|
|
- if (address.getAddressType().equals(AddressDefaultTypeEnum.SHIPMENT.getCode())) {
|
|
|
+ if (address.getAddressType().equals(AddressTypeEnum.SHIPMENT.getCode())) {
|
|
|
//计算单个地址需要回退委派量
|
|
|
BigDecimal countEntrustAmount = countEntrustAmount(subtask, amount.getLAddressId());
|
|
|
amount.setEntrustAmount(amount.getEntrustAmount().subtract(countEntrustAmount));
|
|
|
@@ -2195,7 +2195,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
* @date 2024/3/7
|
|
|
**/
|
|
|
public BigDecimal countEntrustAmount(KwtWaybillOrderSubtask subtask, Long lAddressId){
|
|
|
- List<KwtWaybillOrderAddress> addresses = waybillOrderAddressDao.findBySubtaskId(subtask.getId(), AddressDefaultTypeEnum.SHIPMENT.getCode());
|
|
|
+ List<KwtWaybillOrderAddress> addresses = waybillOrderAddressDao.findBySubtaskId(subtask.getId(), AddressTypeEnum.SHIPMENT.getCode());
|
|
|
//运单地址进行统计
|
|
|
Map<String, Object> queryParams = new HashMap<>(NumberConstant.SIXTEEN);
|
|
|
queryParams.put("wOrderId", subtask.getWOrderId());
|
|
|
@@ -2245,7 +2245,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
queryParams.put("unit", logisticsOrder.getUnit());
|
|
|
queryParams.put("passStatus", Global.NUMERICAL_ONE);
|
|
|
WaybillCountVo waybillCount1 = waybillOrderV1Dao.findTicketCountByAddress(queryParams);
|
|
|
- if (address.getAddressType().equals(AddressDefaultTypeEnum.SHIPMENT.getCode())) {
|
|
|
+ if (address.getAddressType().equals(AddressTypeEnum.SHIPMENT.getCode())) {
|
|
|
amount.setTotalLoadAmount(waybillCount1.getAmount());
|
|
|
} else {
|
|
|
amount.setTotalUnloadAmount(waybillCount1.getAmount());
|
|
|
@@ -2297,7 +2297,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
|
|
|
/*数据处理*/
|
|
|
List<Map<String, Object>> addressList = new ArrayList<>();
|
|
|
- List<Integer> typeList = new ArrayList<>(){{add(AddressDefaultTypeEnum.SHIPMENT.getCode()); add(AddressDefaultTypeEnum.TAKE.getCode());}};
|
|
|
+ List<Integer> typeList = new ArrayList<>(){{add(AddressTypeEnum.SHIPMENT.getCode()); add(AddressTypeEnum.TAKE.getCode());}};
|
|
|
for (Integer type:typeList) {
|
|
|
//装货地址
|
|
|
List<KwtWaybillOrderAddress> addresses = waybillOrderAddressDao.findByAddresses(wOrderId, type);
|
|
|
@@ -2469,7 +2469,7 @@ public class KwtWaybillOrderV1Service {
|
|
|
//运单状态处理(到达装货点、已装货、到达卸货点、已卸货)
|
|
|
List<KwtWaybillOrderAddress> addresses = waybillOrderAddressDao.findByAddresses(wOrderId, null);
|
|
|
for (KwtWaybillOrderAddress address:addresses) {
|
|
|
- if (address.getAddressType().equals(AddressDefaultTypeEnum.SHIPMENT.getCode())) {
|
|
|
+ if (address.getAddressType().equals(AddressTypeEnum.SHIPMENT.getCode())) {
|
|
|
statusList = new ArrayList<>(){{add(CarWaybillEnum.WAIT_LOADING.getCode()); add(CarWaybillEnum.COMPLETION_LOADING.getCode());}};
|
|
|
} else {
|
|
|
statusList = new ArrayList<>(){{add(CarWaybillEnum.WAIT_UNLOADING.getCode()); add(CarWaybillEnum.COMPLETION_UNLOADING.getCode());}};
|