diff --git a/src/main/java/mjkf/xinke/main/controller/BudgetController.java b/src/main/java/mjkf/xinke/main/controller/BudgetController.java index 8672fc5..d420ff9 100644 --- a/src/main/java/mjkf/xinke/main/controller/BudgetController.java +++ b/src/main/java/mjkf/xinke/main/controller/BudgetController.java @@ -154,8 +154,6 @@ public class BudgetController { return FuHttpResponse.Builder().dataResponse(budgetItemList).build(); } - // todo-1 发布编码替换 - // todo-1 公众网站数据 // todo-1 公众网站历史数据 // todo-1 地图里程数据 // todo-1 价格权重调整 diff --git a/src/main/java/mjkf/xinke/main/controller/MaterialController.java b/src/main/java/mjkf/xinke/main/controller/MaterialController.java index ddd2a03..2762b0e 100644 --- a/src/main/java/mjkf/xinke/main/controller/MaterialController.java +++ b/src/main/java/mjkf/xinke/main/controller/MaterialController.java @@ -45,13 +45,12 @@ public class MaterialController { @ApiParam("类型") @RequestParam(value="type") Integer type ) { LambdaQueryWrapper query = new LambdaQueryWrapper<>(); - query.eq(Material::getIsTree, 1); + //query.eq(Material::getIsTree, 1); query.eq(Material::getType, type); List> maps = materialService.listMaps(query); - maps = maps.stream().map(map -> convertKeysToLowercase(map)).collect(Collectors.toList()); - // todo-3 列转树改为泛型对象入参 - List> result = CommonUtil.listToTree(maps, Material.Fields.id, StrUtil.toUnderlineCase(Material.Fields.parentId), "00.00.00.00"); - return FuHttpResponse.Builder().dataResponse(result).build(); + // maps = maps.stream().map(map -> convertKeysToLowercase(map)).collect(Collectors.toList()); + // List> result = CommonUtil.listToTree(maps, Material.Fields.id, StrUtil.toUnderlineCase(Material.Fields.parentId), "00.00.00.00"); + return FuHttpResponse.Builder().dataResponse(maps).build(); } private Map convertKeysToLowercase(Map originalMap) { diff --git a/src/main/java/mjkf/xinke/main/controller/PublicController.java b/src/main/java/mjkf/xinke/main/controller/PublicController.java index 6cbf21c..145e508 100644 --- a/src/main/java/mjkf/xinke/main/controller/PublicController.java +++ b/src/main/java/mjkf/xinke/main/controller/PublicController.java @@ -52,6 +52,7 @@ public class PublicController { @ApiParam(value = "父id") @RequestParam(value="parent_id", required = false) String parentId ) throws Exception { LambdaQueryWrapper query = pricePublishService.getQuery(year, month, null, name, spec, PricePublishType.CURRENT); + query.isNotNull(PricePublish::getMaterialId); // 材料编号禁止为空 if (keyword != null && ObjectUtil.isNotEmpty(keyword)) { query.and(e -> e .like(PricePublish::getName, keyword).or() @@ -66,6 +67,7 @@ public class PublicController { var currentData = pricePublishService.list(query); LambdaQueryWrapper queryPrevious = pricePublishService.getQuery(year - 1, month, null, name, spec, PricePublishType.CURRENT); + queryPrevious.isNotNull(PricePublish::getMaterialId); // 材料编号禁止为空 var previousData = pricePublishService.list(queryPrevious); // 计算同比, 组合 diff --git a/src/main/java/mjkf/xinke/main/model/vo/PublicResponse.java b/src/main/java/mjkf/xinke/main/model/vo/PublicResponse.java index b8832bb..d32a625 100644 --- a/src/main/java/mjkf/xinke/main/model/vo/PublicResponse.java +++ b/src/main/java/mjkf/xinke/main/model/vo/PublicResponse.java @@ -68,7 +68,11 @@ public class PublicResponse { private Float yoy; static public List list(List currentData, List previousData, String region) { - var previousPriceMap = previousData.stream().collect(Collectors.toMap(PricePublish::getMaterialId, item -> item.getRegionPrice(region))); + var previousPriceMap = previousData.stream().collect(Collectors.toMap( + PricePublish::getMaterialId, + item -> item.getRegionPrice(region), + (v1, v2) -> (BigDecimal)v2 + )); var result = currentData.stream().map(item -> new PublicResponse(item, previousPriceMap, region)).collect(Collectors.toList()); return result; }