czg_team/cashier_server
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

map映射

Browse Source
This commit is contained in:
wangw
2025-11-25 14:30:35 +08:00
parent 03a98de023
commit 043d09bee8
4 changed files with 16 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
cash-api/order-server/src/main/java/com/czg/task/StatisticTask.java
View File

@@ -16,6 +16,7 @@ import java.time.LocalDate;
import java.util.List;
/**
* 统计任务
* @author Administrator
*/
@Component

2
cash-common/cash-common-service/src/main/java/com/czg/order/vo/ProductCostAmountVO.java
View File

@@ -15,4 +15,6 @@ public class ProductCostAmountVO {
private Long productId;
private Long skuId;
private Long count;
private BigDecimal costAmount;
}

5
cash-service/order-service/src/main/java/com/czg/service/order/mapper/ShopOrderStatisticMapper.java
View File

@@ -268,7 +268,7 @@ public interface ShopOrderStatisticMapper extends BaseMapper<ShopOrderStatistic>
" product.shop_id = #{shopId} " +
" AND sku.cost_price > 0")
@MapKey("skuId")
Map<Long, BigDecimal> getSkuCostAmount(Long shopId);
List<ProductCostAmountVO> getSkuCostAmount(Long shopId);
@Select("SELECT" +
" relation.product_id as productId," +
@@ -279,8 +279,7 @@ public interface ShopOrderStatisticMapper extends BaseMapper<ShopOrderStatistic>
" WHERE" +
" relation.shop_id = #{shopId} " +
" order by relation.product_id")
@MapKey("productId")
Map<Long, BigDecimal> getConsCostAmount(Long shopId);
List<ProductCostAmountVO> getConsCostAmount(Long shopId);
@Select("SELECT " +

17
cash-service/order-service/src/main/java/com/czg/service/order/service/impl/ShopOrderStatisticServiceImpl.java
View File

@@ -23,6 +23,7 @@ import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.Optional;
import java.util.stream.Collectors;
/**
@@ -192,9 +193,9 @@ public class ShopOrderStatisticServiceImpl extends ServiceImpl<ShopOrderStatisti
*/
private BigDecimal getProductCostAmount(Long shopId, LocalDate day) {
//获取商品sku成本价 productId skuId price
Map<Long, BigDecimal> skuCostAmountList = mapper.getSkuCostAmount(shopId);
List<ProductCostAmountVO> skuCostAmountList = mapper.getSkuCostAmount(shopId);
// //获取商品耗材成本价 productId price
Map<Long, BigDecimal> consCostAmountList = mapper.getConsCostAmount(shopId);
List<ProductCostAmountVO> consCostAmountList = mapper.getConsCostAmount(shopId);
//获取orderDetail信息 productId skuId 数量
BigDecimal productCostAmount = BigDecimal.ZERO;
if (CollUtil.isEmpty(skuCostAmountList) && CollUtil.isEmpty(consCostAmountList)) {
@@ -204,12 +205,16 @@ public class ShopOrderStatisticServiceImpl extends ServiceImpl<ShopOrderStatisti
if (CollUtil.isEmpty(orderDetailProduct)) {
return productCostAmount;
}
Map<Long, BigDecimal> skuCostAmountMap = skuCostAmountList.stream()
.collect(Collectors.toMap(ProductCostAmountVO::getSkuId, ProductCostAmountVO::getCostAmount));
Map<Long, BigDecimal> consCostAmountMap = consCostAmountList.stream()
.collect(Collectors.toMap(ProductCostAmountVO::getProductId, ProductCostAmountVO::getCostAmount));
for (ProductCostAmountVO productCostAmountVO : orderDetailProduct) {
if (skuCostAmountList.containsKey(productCostAmountVO.getSkuId())) {
BigDecimal costAmount = skuCostAmountList.get(productCostAmountVO.getSkuId());
if (skuCostAmountMap.containsKey(productCostAmountVO.getSkuId())) {
BigDecimal costAmount = skuCostAmountMap.get(productCostAmountVO.getSkuId());
productCostAmount = productCostAmount.add(costAmount.multiply(new BigDecimal(productCostAmountVO.getCount())).setScale(2, RoundingMode.HALF_UP));
} else if (consCostAmountList.containsKey(productCostAmountVO.getProductId())) {
BigDecimal costAmount = consCostAmountList.get(productCostAmountVO.getProductId());
} else if (consCostAmountMap.containsKey(productCostAmountVO.getProductId())) {
BigDecimal costAmount = consCostAmountMap.get(productCostAmountVO.getProductId());
productCostAmount = productCostAmount.add(costAmount.multiply(new BigDecimal(productCostAmountVO.getCount())).setScale(2, RoundingMode.HALF_UP));
}
}