|
|
|
|
@ -1,39 +1,66 @@
|
|
|
|
|
package com.logpm.statistics.service.impl; |
|
|
|
|
|
|
|
|
|
import cn.hutool.core.collection.CollUtil; |
|
|
|
|
import cn.hutool.core.util.NumberUtil; |
|
|
|
|
import cn.hutool.core.util.ObjectUtil; |
|
|
|
|
import cn.hutool.core.util.StrUtil; |
|
|
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
|
|
|
|
import com.baomidou.mybatisplus.core.metadata.IPage; |
|
|
|
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; |
|
|
|
|
import com.logpm.basicdata.entity.BasicdataPriceTemplateEntity; |
|
|
|
|
import com.logpm.basicdata.feign.IBasicdataCodeClient; |
|
|
|
|
import com.logpm.basicdata.feign.IBasicdataPriceClient; |
|
|
|
|
import com.logpm.basicdata.vo.BasicdatPriceApiVO; |
|
|
|
|
import com.logpm.basicdata.vo.PriceClientVO; |
|
|
|
|
import com.logpm.basicdata.vo.PriceDispatchBasicVO; |
|
|
|
|
import com.logpm.basicdata.vo.PriceDispatchVO; |
|
|
|
|
import com.logpm.basicdata.vo.PriceWarehouseAdditionalVO; |
|
|
|
|
import com.logpm.basicdata.vo.PriceWarehouseBasicVO; |
|
|
|
|
import com.logpm.basicdata.vo.PriceWarehouseVO; |
|
|
|
|
import com.logpm.statistics.dto.ChangesRecordDTO; |
|
|
|
|
import com.logpm.statistics.dto.MerchantStatisticsDTO; |
|
|
|
|
import com.logpm.statistics.entity.StatisticsBalanceOrderInfoEntity; |
|
|
|
|
import com.logpm.statistics.entity.StatisticsChangesPhotoEntity; |
|
|
|
|
import com.logpm.statistics.entity.StatisticsChangesRecordEntity; |
|
|
|
|
import com.logpm.statistics.entity.StatisticsDistributionPackageEntity; |
|
|
|
|
import com.logpm.statistics.entity.StatisticsOrderInfoEntity; |
|
|
|
|
import com.logpm.statistics.entity.StatisticsWarehousePackageEntity; |
|
|
|
|
import com.logpm.statistics.mapper.StatisticsOrderInfoMapper; |
|
|
|
|
import com.logpm.statistics.service.IStatisticsBalanceOrderInfoService; |
|
|
|
|
import com.logpm.statistics.service.IStatisticsChangesPhotoService; |
|
|
|
|
import com.logpm.statistics.service.IStatisticsChangesRecordService; |
|
|
|
|
import com.logpm.statistics.service.IStatisticsDistributionPackageService; |
|
|
|
|
import com.logpm.statistics.service.IStatisticsOrderInfoService; |
|
|
|
|
import com.logpm.statistics.service.IStatisticsWarehousePackageService; |
|
|
|
|
import com.logpm.statistics.vo.StatisticsChangesRecordVO; |
|
|
|
|
import com.logpm.statistics.vo.StatisticsOrderInfoVO; |
|
|
|
|
import lombok.AllArgsConstructor; |
|
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
|
import org.springblade.common.constant.CodeNumConstant; |
|
|
|
|
import org.springblade.common.constant.DictBizConstant; |
|
|
|
|
import org.springblade.common.enums.BooleanZeroOneEnums; |
|
|
|
|
import org.springblade.common.exception.CustomerException; |
|
|
|
|
import org.springblade.common.utils.CommonUtil; |
|
|
|
|
import org.springblade.core.mp.base.BaseServiceImpl; |
|
|
|
|
import org.springblade.core.secure.utils.AuthUtil; |
|
|
|
|
import org.springblade.core.tool.api.R; |
|
|
|
|
import org.springblade.core.tool.utils.BeanUtil; |
|
|
|
|
import org.springblade.core.tool.utils.DateUtil; |
|
|
|
|
import org.springblade.system.cache.DictBizCache; |
|
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
|
import org.springframework.transaction.annotation.Transactional; |
|
|
|
|
|
|
|
|
|
import java.math.BigDecimal; |
|
|
|
|
import java.util.*; |
|
|
|
|
import java.util.ArrayList; |
|
|
|
|
import java.util.Collections; |
|
|
|
|
import java.util.Comparator; |
|
|
|
|
import java.util.Date; |
|
|
|
|
import java.util.HashSet; |
|
|
|
|
import java.util.List; |
|
|
|
|
import java.util.Map; |
|
|
|
|
import java.util.Objects; |
|
|
|
|
import java.util.Set; |
|
|
|
|
import java.util.concurrent.TimeUnit; |
|
|
|
|
import java.util.concurrent.atomic.AtomicReference; |
|
|
|
|
import java.util.stream.Collectors; |
|
|
|
|
|
|
|
|
|
@ -46,6 +73,9 @@ public class StatisticsOrderInfoServiceImpl extends BaseServiceImpl<StatisticsOr
|
|
|
|
|
private final IStatisticsChangesPhotoService changesPhotoService; |
|
|
|
|
private final IBasicdataCodeClient basicdataCodeClient; |
|
|
|
|
private final IStatisticsBalanceOrderInfoService balanceOrderInfoService; |
|
|
|
|
private final IBasicdataPriceClient priceClient; |
|
|
|
|
private final IStatisticsDistributionPackageService distributionPackageService; |
|
|
|
|
private final IStatisticsWarehousePackageService warehousePackageService; |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public List<StatisticsOrderInfoEntity> findListByWaybillId(Long waybillId) { |
|
|
|
|
@ -201,7 +231,6 @@ public class StatisticsOrderInfoServiceImpl extends BaseServiceImpl<StatisticsOr
|
|
|
|
|
List<BigDecimal> yPays = new ArrayList();// 月结
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
list.forEach(statisticsOrderInfoVO -> { |
|
|
|
|
Long orderInfoId = statisticsOrderInfoVO.getOrderInfoId(); |
|
|
|
|
Integer confirmStatisticsOrder = statisticsOrderInfoVO.getConfirmStatisticsOrder(); |
|
|
|
|
@ -393,6 +422,443 @@ public class StatisticsOrderInfoServiceImpl extends BaseServiceImpl<StatisticsOr
|
|
|
|
|
return statementListByOrderInfoIds.get(0); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
@Override |
|
|
|
|
public boolean calculateRealCost(Long id) { |
|
|
|
|
StatisticsOrderInfoEntity orderInfoEntity = this.getOne(new QueryWrapper<StatisticsOrderInfoEntity>().lambda().eq(StatisticsOrderInfoEntity::getId, id)); |
|
|
|
|
if (ObjectUtil.isEmpty(orderInfoEntity)) { |
|
|
|
|
log.warn("#############calculateRealCost: 订单信息不存在"); |
|
|
|
|
throw new CustomerException("订单信息不存在"); |
|
|
|
|
} |
|
|
|
|
Long brandId = orderInfoEntity.getBrandId(); |
|
|
|
|
Long consigneeId = orderInfoEntity.getConsigneeId(); |
|
|
|
|
if (!ObjectUtil.isAllNotEmpty(brandId, consigneeId)) { |
|
|
|
|
log.warn("#############calculateRealCost: 品牌{} 收货单位{}", brandId, consigneeId); |
|
|
|
|
throw new CustomerException("结算单信息不完整，缺少品牌和收货单位，请联系系统管理员。"); |
|
|
|
|
} |
|
|
|
|
Date createTime = orderInfoEntity.getCreateTime(); |
|
|
|
|
// 根据 品牌 收货单位 开单时间 获取价格体系
|
|
|
|
|
PriceClientVO price = priceClient.price(BasicdatPriceApiVO.builder() |
|
|
|
|
.clientId(consigneeId.toString()) |
|
|
|
|
.brandId(brandId.toString()) |
|
|
|
|
.time(DateUtil.formatTime(createTime)) |
|
|
|
|
.build()); |
|
|
|
|
if (ObjectUtil.isEmpty(price)) { |
|
|
|
|
log.warn("#############calculateRealCost: 未维护价格，无法计算。"); |
|
|
|
|
throw new CustomerException("未维护价格，无法计算。"); |
|
|
|
|
} |
|
|
|
|
// 查询包件数据
|
|
|
|
|
List<StatisticsDistributionPackageEntity> distributionPackageEntities = distributionPackageService.list(new QueryWrapper<StatisticsDistributionPackageEntity>().lambda().eq(StatisticsDistributionPackageEntity::getOrderInfoId, id)); |
|
|
|
|
// 校验是否全部配送完成
|
|
|
|
|
if (distributionPackageEntities.stream().anyMatch(distributionPackageEntity -> distributionPackageEntity.getIsSign() == 0)) { |
|
|
|
|
log.warn("#############calculateRealCost: 订单未全部配送完成，无法计算。"); |
|
|
|
|
throw new CustomerException("订单未全部配送完成，无法计算。"); |
|
|
|
|
} |
|
|
|
|
List<StatisticsWarehousePackageEntity> warehousePackageEntities = warehousePackageService.list(new QueryWrapper<StatisticsWarehousePackageEntity>().lambda().eq(StatisticsWarehousePackageEntity::getOrderInfoId, id)); |
|
|
|
|
PriceDispatchVO dispatch = price.getDispatch(); |
|
|
|
|
PriceWarehouseVO warehouse = price.getWarehouse(); |
|
|
|
|
|
|
|
|
|
BasicdataPriceTemplateEntity template = price.getTemplate(); |
|
|
|
|
if (ObjectUtil.isEmpty(template)) { |
|
|
|
|
log.warn("#############calculateRealCost: 未维护模版，无法计算。"); |
|
|
|
|
throw new CustomerException("未维护模版，无法计算。"); |
|
|
|
|
} |
|
|
|
|
String serviceType = template.getServiceType(); |
|
|
|
|
Integer dispatchIsMinCost = template.getDispatchIsMinCost(); |
|
|
|
|
|
|
|
|
|
// 模版的服务类型
|
|
|
|
|
String typeService = orderInfoEntity.getTypeService(); |
|
|
|
|
if (StrUtil.isNotEmpty(serviceType)) { |
|
|
|
|
// 模版是否有仓储
|
|
|
|
|
if (StrUtil.contains(serviceType, "3")) { |
|
|
|
|
if (CollUtil.isNotEmpty(warehousePackageEntities)) { |
|
|
|
|
calculateWarehouseCost(warehouse, warehousePackageEntities, template); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
// 模版是否有配送
|
|
|
|
|
if (StrUtil.contains(serviceType, "4")) { |
|
|
|
|
if (CollUtil.isNotEmpty(distributionPackageEntities)) { |
|
|
|
|
calculateDispatchCost(template, typeService, distributionPackageEntities, dispatch, dispatchIsMinCost); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
return Boolean.TRUE; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private void calculateWarehouseCost(PriceWarehouseVO warehouse, List<StatisticsWarehousePackageEntity> warehousePackageEntities, BasicdataPriceTemplateEntity template) { |
|
|
|
|
if (ObjectUtil.isNotEmpty(warehouse)) { |
|
|
|
|
// 取出 warehousePackageEntities 中的最小的入库时间 warehouseEntryTimeEnd 和最大的签收时间 signTime。两个时间相差的天数为在库周期
|
|
|
|
|
// 过滤掉无用无用数据
|
|
|
|
|
warehousePackageEntities.removeIf(entity -> entity.getWarehouseEntryTimeEnd() == null || entity.getSignTime() == null); |
|
|
|
|
Long diff = null; |
|
|
|
|
if (CollUtil.isNotEmpty(warehousePackageEntities)) { |
|
|
|
|
// 找到最早的入库结束时间和最晚的签收时间
|
|
|
|
|
StatisticsWarehousePackageEntity earliestEntity = Collections.min(warehousePackageEntities, Comparator.comparing(StatisticsWarehousePackageEntity::getWarehouseEntryTimeEnd)); |
|
|
|
|
StatisticsWarehousePackageEntity latestEntity = Collections.max(warehousePackageEntities, Comparator.comparing(StatisticsWarehousePackageEntity::getSignTime)); |
|
|
|
|
Date warehouseEntryTimeEnd = earliestEntity.getWarehouseEntryTimeEnd(); |
|
|
|
|
Date signTime = latestEntity.getSignTime(); |
|
|
|
|
// 计算在库周期（相差天数）
|
|
|
|
|
long diffInMillies = Math.abs(signTime.getTime() - warehouseEntryTimeEnd.getTime()); |
|
|
|
|
diff = (diffInMillies + TimeUnit.DAYS.toMillis(1) - 1) / TimeUnit.DAYS.toMillis(1); |
|
|
|
|
} |
|
|
|
|
if (diff != null && diff > 0) { |
|
|
|
|
for (StatisticsWarehousePackageEntity warehousePackageEntity : warehousePackageEntities) { |
|
|
|
|
buildBasicWarehouseCost(warehousePackageEntity, warehouse, template, diff); |
|
|
|
|
} |
|
|
|
|
if (CollUtil.isNotEmpty(warehousePackageEntities)) { |
|
|
|
|
// 计算配送服务费 realDeliveryServiceFee = 所有real费用的和
|
|
|
|
|
warehousePackageEntities.stream().forEach(entity -> { |
|
|
|
|
entity.setRealWarehouseServiceFee(entity.getRealWarehouseFee() |
|
|
|
|
.add(entity.getRealWarehouseManageFee()) |
|
|
|
|
.add(entity.getRealWarehouseSortingFee()) |
|
|
|
|
.add(entity.getRealWarehouseOperatingFee()) |
|
|
|
|
); |
|
|
|
|
}); |
|
|
|
|
warehousePackageService.updateBatchById(warehousePackageEntities); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private void calculateDispatchCost(BasicdataPriceTemplateEntity template, String typeService, List<StatisticsDistributionPackageEntity> distributionPackageEntities, PriceDispatchVO dispatch, Integer dispatchIsMinCost) { |
|
|
|
|
String dispatchPricingType = template.getDispatchPricingType(); |
|
|
|
|
// 服务类型与模版的服务类型一致
|
|
|
|
|
if (StrUtil.equals(dispatchPricingType, typeService)) { |
|
|
|
|
// 计算基础配送费
|
|
|
|
|
Integer dispatchIsByCategory = template.getDispatchIsByCategory(); |
|
|
|
|
if (ObjectUtil.isNotEmpty(dispatch)) { |
|
|
|
|
for (StatisticsDistributionPackageEntity statisticsDistributionPackageEntity : distributionPackageEntities) { |
|
|
|
|
buildBasicDispatchCost(statisticsDistributionPackageEntity, dispatch, dispatchIsByCategory); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
// 保底价
|
|
|
|
|
// 1 是否有最低价 2 最低价的计费类型是按订单还是按配送任务 3 按价格还是件方重量
|
|
|
|
|
if (ObjectUtil.equals(BooleanZeroOneEnums.YES.getCode(), dispatchIsMinCost)) { |
|
|
|
|
// 1 订单 2 配送任务
|
|
|
|
|
Integer dispatchMinCostMode = template.getDispatchMinCostMode(); |
|
|
|
|
// 1 价格 2 件 3 方 4 重量
|
|
|
|
|
Integer dispatchMinCostType = template.getDispatchMinCostType(); |
|
|
|
|
// 最低价
|
|
|
|
|
Double minCost = dispatch.getMinCost(); |
|
|
|
|
// 加算价格
|
|
|
|
|
Double additionalCost = dispatch.getAdditionalCost(); |
|
|
|
|
if (ObjectUtil.equals(1, dispatchMinCostMode)) { |
|
|
|
|
buildDispatchCostToPackage(dispatchMinCostType, distributionPackageEntities, minCost, additionalCost); |
|
|
|
|
} else if (ObjectUtil.equals(2, dispatchMinCostMode)) { |
|
|
|
|
Map<String, List<StatisticsDistributionPackageEntity>> map = distributionPackageEntities.stream().collect(Collectors.groupingBy(StatisticsDistributionPackageEntity::getTrainNumber)); |
|
|
|
|
if (CollUtil.isNotEmpty(map)) { |
|
|
|
|
for (Map.Entry<String, List<StatisticsDistributionPackageEntity>> entry : map.entrySet()) { |
|
|
|
|
List<StatisticsDistributionPackageEntity> value = entry.getValue(); |
|
|
|
|
buildDispatchCostToPackage(dispatchMinCostType, value, minCost, additionalCost); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
// 保存配送包件信息
|
|
|
|
|
if (CollUtil.isNotEmpty(distributionPackageEntities)) { |
|
|
|
|
// 计算配送服务费 realDeliveryServiceFee = 所有real费用的和
|
|
|
|
|
distributionPackageEntities.stream().forEach(entity -> { |
|
|
|
|
entity.setRealDeliveryServiceFee(entity.getRealDeliveryFee() |
|
|
|
|
.add(entity.getRealDeliveryLoadingFee()) |
|
|
|
|
.add(entity.getRealDeliveryMoveFee()) |
|
|
|
|
.add(entity.getRealDeliveryCrossingFee()) |
|
|
|
|
.add(entity.getRealDeliverySortingFee()) |
|
|
|
|
.add(entity.getRealDeliveryUpfloorFee()) |
|
|
|
|
.add(entity.getRealDeliveryDistance())); |
|
|
|
|
}); |
|
|
|
|
distributionPackageService.saveOrUpdateBatch(distributionPackageEntities); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private void buildBasicDispatchCost(StatisticsDistributionPackageEntity statisticsDistributionPackageEntity, PriceDispatchVO dispatch, Integer dispatchIsByCategory) { |
|
|
|
|
List<PriceDispatchBasicVO> pieceCategory = dispatch.getPieceCategory(); |
|
|
|
|
if (CollUtil.isNotEmpty(pieceCategory)) { |
|
|
|
|
List<PriceDispatchBasicVO> pieceList = pieceCategory; |
|
|
|
|
if (1 == dispatchIsByCategory) { |
|
|
|
|
pieceList = pieceCategory.stream().filter(priceDispatchBasicVO -> { |
|
|
|
|
return StrUtil.equals(String.valueOf(priceDispatchBasicVO.getCategoryId()), statisticsDistributionPackageEntity.getProductId()); |
|
|
|
|
}).collect(Collectors.toList()); |
|
|
|
|
} |
|
|
|
|
if (CollUtil.isNotEmpty(pieceList)) { |
|
|
|
|
PriceDispatchBasicVO priceDispatchBasicVO = pieceList.get(0); |
|
|
|
|
// TODO 如果是遗留件 按遗留件单价来计算 目前只有欧派有遗留件
|
|
|
|
|
Double price1 = priceDispatchBasicVO.getPrice(); |
|
|
|
|
// 配送费 = 按件单价
|
|
|
|
|
statisticsDistributionPackageEntity.setRealDeliveryFee(NumberUtil.toBigDecimal(price1)); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
List<PriceDispatchBasicVO> cubeCategory = dispatch.getCubeCategory(); |
|
|
|
|
if (CollUtil.isNotEmpty(cubeCategory)) { |
|
|
|
|
List<PriceDispatchBasicVO> cubeList = cubeCategory; |
|
|
|
|
if (1 == dispatchIsByCategory) { |
|
|
|
|
cubeList = cubeCategory.stream().filter(priceDispatchBasicVO -> { |
|
|
|
|
return StrUtil.equals(String.valueOf(priceDispatchBasicVO.getCategoryId()), statisticsDistributionPackageEntity.getProductId()); |
|
|
|
|
}).collect(Collectors.toList()); |
|
|
|
|
} |
|
|
|
|
if (CollUtil.isNotEmpty(cubeList)) { |
|
|
|
|
PriceDispatchBasicVO priceDispatchBasicVO = cubeList.get(0); |
|
|
|
|
// TODO 如果是遗留件 按遗留件单价来计算 目前只有欧派有遗留件
|
|
|
|
|
Double price1 = priceDispatchBasicVO.getPrice(); |
|
|
|
|
BigDecimal totalVolume = statisticsDistributionPackageEntity.getTotalVolume(); |
|
|
|
|
// 配送费 = 按方单价 * 体积
|
|
|
|
|
if (ObjectUtil.isNotEmpty(totalVolume)) { |
|
|
|
|
statisticsDistributionPackageEntity.setRealDeliveryFee(NumberUtil.toBigDecimal(price1).multiply(totalVolume)); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
List<PriceDispatchBasicVO> weightCategory = dispatch.getWeightCategory(); |
|
|
|
|
if (CollUtil.isNotEmpty(weightCategory)) { |
|
|
|
|
List<PriceDispatchBasicVO> weightList = weightCategory; |
|
|
|
|
if (1 == dispatchIsByCategory) { |
|
|
|
|
weightList = weightCategory.stream().filter(priceDispatchBasicVO -> { |
|
|
|
|
return StrUtil.equals(String.valueOf(priceDispatchBasicVO.getCategoryId()), statisticsDistributionPackageEntity.getProductId()); |
|
|
|
|
}).collect(Collectors.toList()); |
|
|
|
|
} |
|
|
|
|
if (CollUtil.isNotEmpty(weightList)) { |
|
|
|
|
PriceDispatchBasicVO priceDispatchBasicVO = weightList.get(0); |
|
|
|
|
// TODO 如果是遗留件 按遗留件单价来计算 目前只有欧派有遗留件
|
|
|
|
|
Double price1 = priceDispatchBasicVO.getPrice(); |
|
|
|
|
BigDecimal totalWeight = statisticsDistributionPackageEntity.getTotalWeight(); |
|
|
|
|
// 配送费 = 按重量单价 * 重量
|
|
|
|
|
if (ObjectUtil.isNotEmpty(totalWeight)) { |
|
|
|
|
statisticsDistributionPackageEntity.setRealDeliveryFee(NumberUtil.toBigDecimal(price1).multiply(totalWeight)); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private void buildBasicWarehouseCost(StatisticsWarehousePackageEntity statisticsDistributionPackageEntity, PriceWarehouseVO warehouseVO, BasicdataPriceTemplateEntity template, Long diff) { |
|
|
|
|
// 1 按件 2 按方 3 按重量
|
|
|
|
|
Integer warehousePricingType = template.getWarehousePricingType(); |
|
|
|
|
// 1 分段式 2 最高标准
|
|
|
|
|
Integer warehousePricingMode = template.getWarehousePricingMode(); |
|
|
|
|
// 计费标准 1 按件/天 2 按件/月
|
|
|
|
|
Integer warehouseCalculationBasis = template.getWarehouseCalculationBasis(); |
|
|
|
|
if (!ObjectUtil.isAllNotEmpty(warehousePricingType, warehousePricingMode, warehouseCalculationBasis)) { |
|
|
|
|
log.warn("模版参数不全不计算"); |
|
|
|
|
return; |
|
|
|
|
} |
|
|
|
|
// 仓储费是否按品类计费 1 是 0 否
|
|
|
|
|
Integer warehouseIsByCategory = template.getWarehouseIsByCategory(); |
|
|
|
|
List<PriceWarehouseBasicVO> catergory = warehouseVO.getCatergory(); |
|
|
|
|
if (CollUtil.isNotEmpty(catergory)) { |
|
|
|
|
List<PriceWarehouseBasicVO> pieceList = catergory; |
|
|
|
|
if (1 == warehouseIsByCategory) { |
|
|
|
|
pieceList = catergory.stream().filter(priceDispatchBasicVO -> { |
|
|
|
|
return StrUtil.equals(String.valueOf(priceDispatchBasicVO.getCategoryId()), statisticsDistributionPackageEntity.getProductId()); |
|
|
|
|
}).collect(Collectors.toList()); |
|
|
|
|
} |
|
|
|
|
if (CollUtil.isNotEmpty(pieceList)) { |
|
|
|
|
BigDecimal totalVolume = statisticsDistributionPackageEntity.getTotalVolume(); |
|
|
|
|
BigDecimal totalWeight = statisticsDistributionPackageEntity.getTotalWeight(); |
|
|
|
|
PriceWarehouseBasicVO priceDispatchBasicVO = pieceList.get(0); |
|
|
|
|
Double withinThirtyPrice = priceDispatchBasicVO.getWithinThirtyPrice(); |
|
|
|
|
Double betweenThirtySixtyPrice = priceDispatchBasicVO.getBetweenThirtySixtyPrice(); |
|
|
|
|
Double beyondSixtyPrice = priceDispatchBasicVO.getBeyondSixtyPrice(); |
|
|
|
|
Double beyondNinetyPrice = priceDispatchBasicVO.getBeyondNinetyPrice(); |
|
|
|
|
// 计算仓储费
|
|
|
|
|
if (ObjectUtil.equals(1, warehousePricingType)) { |
|
|
|
|
if (ObjectUtil.equals(1, warehousePricingMode)) { |
|
|
|
|
fenDuan(statisticsDistributionPackageEntity, diff, warehouseCalculationBasis, withinThirtyPrice, BigDecimal.ONE, betweenThirtySixtyPrice, beyondSixtyPrice, beyondNinetyPrice); |
|
|
|
|
} else if (ObjectUtil.equals(2, warehousePricingMode)) { |
|
|
|
|
zuiGao(statisticsDistributionPackageEntity, diff, warehouseCalculationBasis, withinThirtyPrice, BigDecimal.ONE, betweenThirtySixtyPrice, beyondSixtyPrice, beyondNinetyPrice); |
|
|
|
|
} |
|
|
|
|
} else if (ObjectUtil.equals(2, warehousePricingType)) { |
|
|
|
|
if (ObjectUtil.equals(1, warehousePricingMode)) { |
|
|
|
|
fenDuan(statisticsDistributionPackageEntity, diff, warehouseCalculationBasis, withinThirtyPrice, totalVolume, betweenThirtySixtyPrice, beyondSixtyPrice, beyondNinetyPrice); |
|
|
|
|
} else if (ObjectUtil.equals(2, warehousePricingMode)) { |
|
|
|
|
zuiGao(statisticsDistributionPackageEntity, diff, warehouseCalculationBasis, withinThirtyPrice, totalVolume, betweenThirtySixtyPrice, beyondSixtyPrice, beyondNinetyPrice); |
|
|
|
|
} |
|
|
|
|
} else if (ObjectUtil.equals(3, warehousePricingType)) { |
|
|
|
|
if (ObjectUtil.equals(1, warehousePricingMode)) { |
|
|
|
|
fenDuan(statisticsDistributionPackageEntity, diff, warehouseCalculationBasis, withinThirtyPrice, totalWeight, betweenThirtySixtyPrice, beyondSixtyPrice, beyondNinetyPrice); |
|
|
|
|
} else if (ObjectUtil.equals(2, warehousePricingMode)) { |
|
|
|
|
zuiGao(statisticsDistributionPackageEntity, diff, warehouseCalculationBasis, withinThirtyPrice, totalWeight, betweenThirtySixtyPrice, beyondSixtyPrice, beyondNinetyPrice); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
Integer warehouseIsAddFee = template.getWarehouseIsAddFee(); |
|
|
|
|
if (ObjectUtil.equals(BooleanZeroOneEnums.YES.getCode(), warehouseIsAddFee)) { |
|
|
|
|
// 是否有管理费
|
|
|
|
|
Integer warehouseIsManageFee = template.getWarehouseIsManageFee(); |
|
|
|
|
// 是否有分拣费
|
|
|
|
|
Integer warehouseIsSortFee = template.getWarehouseIsSortFee(); |
|
|
|
|
// 是否有操作费
|
|
|
|
|
Integer warehouseIsOperatingFee = template.getWarehouseIsOperateFee(); |
|
|
|
|
// 是否按品类附加费
|
|
|
|
|
Integer warehouseIsCategorySubjoin = template.getWarehouseIsCategorySubjoin(); |
|
|
|
|
List<PriceWarehouseAdditionalVO> additionalCategory = warehouseVO.getAdditionalCategory(); |
|
|
|
|
if (CollUtil.isNotEmpty(additionalCategory)) { |
|
|
|
|
List<PriceWarehouseAdditionalVO> additionalList = additionalCategory; |
|
|
|
|
if (ObjectUtil.equals(BooleanZeroOneEnums.YES.getCode(), warehouseIsCategorySubjoin)) { |
|
|
|
|
additionalList = additionalCategory.stream().filter(additionalVO -> { |
|
|
|
|
return StrUtil.equals(String.valueOf(additionalVO.getCategoryId()), statisticsDistributionPackageEntity.getProductId()); |
|
|
|
|
}).collect(Collectors.toList()); |
|
|
|
|
} |
|
|
|
|
if (CollUtil.isNotEmpty(additionalList)) { |
|
|
|
|
PriceWarehouseAdditionalVO additionalVO = additionalList.get(0); |
|
|
|
|
Double operatePrice = additionalVO.getOperatePrice(); |
|
|
|
|
Double managementPrice = additionalVO.getWarehouseManagementPrice(); |
|
|
|
|
Double warehouseSortPrice = additionalVO.getWarehouseSortPrice(); |
|
|
|
|
if (ObjectUtil.equals(BooleanZeroOneEnums.YES.getCode(), warehouseIsManageFee)) { |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseManageFee(NumberUtil.toBigDecimal(managementPrice)); |
|
|
|
|
} |
|
|
|
|
if (ObjectUtil.equals(BooleanZeroOneEnums.YES.getCode(), warehouseIsSortFee)) { |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseSortingFee(NumberUtil.toBigDecimal(warehouseSortPrice)); |
|
|
|
|
} |
|
|
|
|
if (ObjectUtil.equals(BooleanZeroOneEnums.YES.getCode(), warehouseIsOperatingFee)) { |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseOperatingFee(NumberUtil.toBigDecimal(operatePrice)); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private static void zuiGao(StatisticsWarehousePackageEntity statisticsDistributionPackageEntity, Long diff, Integer warehouseCalculationBasis, Double withinThirtyPrice, BigDecimal number, Double betweenThirtySixtyPrice, Double beyondSixtyPrice, Double beyondNinetyPrice) { |
|
|
|
|
if (ObjectUtil.equals(1, warehouseCalculationBasis)) { |
|
|
|
|
// 方 最高 天
|
|
|
|
|
BigDecimal realWarehouseFee = BigDecimal.ZERO; |
|
|
|
|
if (diff <= 30) { |
|
|
|
|
realWarehouseFee = NumberUtil.mul(withinThirtyPrice, diff, number); |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseFeeInterval("30天内"); |
|
|
|
|
} else if (diff <= 60) { |
|
|
|
|
realWarehouseFee = NumberUtil.mul(betweenThirtySixtyPrice, diff, number); |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseFeeInterval("31-60天"); |
|
|
|
|
} else if (diff <= 90) { |
|
|
|
|
realWarehouseFee = NumberUtil.mul(beyondSixtyPrice, diff, number); |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseFeeInterval("61-90天"); |
|
|
|
|
} else if (diff > 90) { |
|
|
|
|
realWarehouseFee = NumberUtil.mul(beyondNinetyPrice, diff, number); |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseFeeInterval("91天以上"); |
|
|
|
|
} |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseFee(realWarehouseFee); |
|
|
|
|
} else if (ObjectUtil.equals(2, warehouseCalculationBasis)) { |
|
|
|
|
// 方 最高 月
|
|
|
|
|
BigDecimal realWarehouseFee = BigDecimal.ZERO; |
|
|
|
|
if (diff <= 30) { |
|
|
|
|
realWarehouseFee = NumberUtil.mul(withinThirtyPrice, 1, number); |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseFeeInterval("30天内"); |
|
|
|
|
} else if (diff <= 60) { |
|
|
|
|
realWarehouseFee = NumberUtil.mul(betweenThirtySixtyPrice, 2, number); |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseFeeInterval("31-60天"); |
|
|
|
|
} else if (diff <= 90) { |
|
|
|
|
realWarehouseFee = NumberUtil.mul(beyondSixtyPrice, 3, number); |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseFeeInterval("61-90天"); |
|
|
|
|
} else if (diff > 90) { |
|
|
|
|
long time = diff - 90; |
|
|
|
|
// time 以 30 天为维度 计算 ，向上取整
|
|
|
|
|
Double ceil = Math.ceil(time / 30); |
|
|
|
|
realWarehouseFee = NumberUtil.mul(beyondNinetyPrice, NumberUtil.add(ceil, 3, BigDecimal.ZERO), number); |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseFeeInterval("91天以上"); |
|
|
|
|
} |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseFee(realWarehouseFee); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private static void fenDuan(StatisticsWarehousePackageEntity statisticsDistributionPackageEntity, Long diff, Integer warehouseCalculationBasis, Double withinThirtyPrice, BigDecimal number, Double betweenThirtySixtyPrice, Double beyondSixtyPrice, Double beyondNinetyPrice) { |
|
|
|
|
if (ObjectUtil.equals(1, warehouseCalculationBasis)) { |
|
|
|
|
// 方 分段 天
|
|
|
|
|
BigDecimal realWarehouseFee = BigDecimal.ZERO; |
|
|
|
|
if (diff <= 30) { |
|
|
|
|
realWarehouseFee = NumberUtil.mul(withinThirtyPrice, diff, number); |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseFeeInterval("30天内"); |
|
|
|
|
} else if (diff <= 60) { |
|
|
|
|
realWarehouseFee = NumberUtil.add( |
|
|
|
|
NumberUtil.mul(withinThirtyPrice, 30, number), |
|
|
|
|
NumberUtil.mul(betweenThirtySixtyPrice, NumberUtil.sub(diff, 30, BigDecimal.ZERO), number) |
|
|
|
|
); |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseFeeInterval("31-60天"); |
|
|
|
|
} else if (diff <= 90) { |
|
|
|
|
realWarehouseFee = NumberUtil.add( |
|
|
|
|
NumberUtil.mul(withinThirtyPrice, 30, number), |
|
|
|
|
NumberUtil.mul(betweenThirtySixtyPrice, 30, number), |
|
|
|
|
NumberUtil.mul(beyondSixtyPrice, NumberUtil.sub(diff, 60, BigDecimal.ZERO), number) |
|
|
|
|
); |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseFeeInterval("61-90天"); |
|
|
|
|
} else if (diff > 90) { |
|
|
|
|
realWarehouseFee = NumberUtil.add( |
|
|
|
|
NumberUtil.mul(withinThirtyPrice, 30, number), |
|
|
|
|
NumberUtil.mul(betweenThirtySixtyPrice, 30, number), |
|
|
|
|
NumberUtil.mul(beyondSixtyPrice, 30, number), |
|
|
|
|
NumberUtil.mul(beyondNinetyPrice, NumberUtil.sub(diff, 90, BigDecimal.ZERO), number) |
|
|
|
|
); |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseFeeInterval("91天以上"); |
|
|
|
|
} |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseFee(realWarehouseFee); |
|
|
|
|
} else if (ObjectUtil.equals(2, warehouseCalculationBasis)) { |
|
|
|
|
// 方 分段 月
|
|
|
|
|
BigDecimal realWarehouseFee = BigDecimal.ZERO; |
|
|
|
|
if (diff <= 30) { |
|
|
|
|
realWarehouseFee = NumberUtil.mul(withinThirtyPrice, number); |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseFeeInterval("30天内"); |
|
|
|
|
} else if (diff <= 60) { |
|
|
|
|
realWarehouseFee = NumberUtil.mul(number, NumberUtil.add(withinThirtyPrice, betweenThirtySixtyPrice, BigDecimal.ZERO)); |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseFeeInterval("31-60天"); |
|
|
|
|
} else if (diff <= 90) { |
|
|
|
|
realWarehouseFee = NumberUtil.mul(number, NumberUtil.add(withinThirtyPrice, betweenThirtySixtyPrice, beyondSixtyPrice)); |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseFeeInterval("61-90天"); |
|
|
|
|
} else if (diff > 90) { |
|
|
|
|
long time = diff - 90; |
|
|
|
|
// time 以 30 天为维度 计算 ，向上取整
|
|
|
|
|
Double ceil = Math.ceil(time / 30); |
|
|
|
|
realWarehouseFee = NumberUtil.mul(number, NumberUtil.add(withinThirtyPrice, betweenThirtySixtyPrice, beyondSixtyPrice, NumberUtil.mul(ceil, beyondNinetyPrice))); |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseFeeInterval("91天以上"); |
|
|
|
|
} |
|
|
|
|
statisticsDistributionPackageEntity.setRealWarehouseFee(realWarehouseFee); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private void buildDispatchCostToPackage(Integer dispatchMinCostType, List<StatisticsDistributionPackageEntity> distributionPackageEntities, Double minCost, Double additionalCost) { |
|
|
|
|
if (ObjectUtil.equals(1, dispatchMinCostType)) { |
|
|
|
|
// 计算总价
|
|
|
|
|
BigDecimal sumDeliveryFee = distributionPackageEntities.stream().map(StatisticsDistributionPackageEntity::getRealDeliveryFee).reduce(BigDecimal.ZERO, BigDecimal::add); |
|
|
|
|
// 总价和最低价 取大的值
|
|
|
|
|
BigDecimal max = NumberUtil.max(sumDeliveryFee, NumberUtil.toBigDecimal(minCost)); |
|
|
|
|
// 分摊价格个到包件上
|
|
|
|
|
// max - sumDeliveryFee 大于 0 则分摊价格个到包件上
|
|
|
|
|
if (max.compareTo(sumDeliveryFee) > 0) { |
|
|
|
|
// 分摊价格个到包件上 (原单价 + (max - sumDeliveryFee)/件数)
|
|
|
|
|
BigDecimal divide = max.subtract(sumDeliveryFee).divide(NumberUtil.toBigDecimal(distributionPackageEntities.size()), 2, BigDecimal.ROUND_HALF_UP); |
|
|
|
|
distributionPackageEntities.forEach(statisticsDistributionPackageEntity -> { |
|
|
|
|
statisticsDistributionPackageEntity.setRealDeliveryFee(statisticsDistributionPackageEntity.getRealDeliveryFee().add(divide)); |
|
|
|
|
}); |
|
|
|
|
} |
|
|
|
|
} else if (ObjectUtil.equals(2, dispatchMinCostType)) { |
|
|
|
|
// 总件数
|
|
|
|
|
int size = distributionPackageEntities.size(); |
|
|
|
|
// 总件数 < 最低价 则计算保底价
|
|
|
|
|
if (size < minCost) { |
|
|
|
|
// 分摊到包件上 原单价 + 加算价格
|
|
|
|
|
distributionPackageEntities.forEach(statisticsDistributionPackageEntity -> { |
|
|
|
|
statisticsDistributionPackageEntity.setRealDeliveryFee(statisticsDistributionPackageEntity.getRealDeliveryFee().add(NumberUtil.toBigDecimal(additionalCost))); |
|
|
|
|
}); |
|
|
|
|
} |
|
|
|
|
} else if (ObjectUtil.equals(3, dispatchMinCostType)) { |
|
|
|
|
// 总体积
|
|
|
|
|
BigDecimal totalVolume = distributionPackageEntities.stream().map(StatisticsDistributionPackageEntity::getTotalVolume).reduce(BigDecimal.ZERO, BigDecimal::add); |
|
|
|
|
// 总件数 < 最低价 则计算保底价
|
|
|
|
|
if (NumberUtil.compare(NumberUtil.toDouble(totalVolume), minCost) < 0) { |
|
|
|
|
// 分摊到包件上 原单价 + 加算价格
|
|
|
|
|
distributionPackageEntities.forEach(statisticsDistributionPackageEntity -> { |
|
|
|
|
statisticsDistributionPackageEntity.setRealDeliveryFee(statisticsDistributionPackageEntity.getRealDeliveryFee().add(NumberUtil.toBigDecimal(additionalCost))); |
|
|
|
|
}); |
|
|
|
|
} |
|
|
|
|
} else if (ObjectUtil.equals(4, dispatchMinCostType)) { |
|
|
|
|
// 总重量
|
|
|
|
|
BigDecimal totalWeight = distributionPackageEntities.stream().map(StatisticsDistributionPackageEntity::getTotalWeight).reduce(BigDecimal.ZERO, BigDecimal::add); |
|
|
|
|
// 总件数 < 最低价 则计算保底价
|
|
|
|
|
if (NumberUtil.compare(NumberUtil.toDouble(totalWeight), minCost) < 0) { |
|
|
|
|
// 分摊到包件上 原单价 + 加算价格
|
|
|
|
|
distributionPackageEntities.forEach(statisticsDistributionPackageEntity -> { |
|
|
|
|
statisticsDistributionPackageEntity.setRealDeliveryFee(statisticsDistributionPackageEntity.getRealDeliveryFee().add(NumberUtil.toBigDecimal(additionalCost))); |
|
|
|
|
}); |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private void updateOrderChangesFee(Long orderInfoId) { |
|
|
|
|
|
|
|
|
|
StatisticsOrderInfoEntity statisticsOrderInfoEntity = baseMapper.selectById(orderInfoId); |
|
|
|
|
|
