索引中加入实时计算的断码率

 package com.yoho.search.dal.model;
 package com.yoho.search.dal.model;
 
 
-
 /**
 /**
  * Created by wangnan on 2016/6/30.
  * Created by wangnan on 2016/6/30.
  */
  */
@@ -9,6 +8,7 @@ public class ProductSizes {
 	private String sizeIds;
 	private String sizeIds;
 	private String sizeNames;
 	private String sizeNames;
 	private Integer storageNum;
 	private Integer storageNum;
+	private double breakSizePercent = 100;
 
 
 	public Integer getProductId() {
 	public Integer getProductId() {
 		return productId;
 		return productId;
@@ -41,4 +41,13 @@ public class ProductSizes {
 	public void setSizeNames(String sizeNames) {
 	public void setSizeNames(String sizeNames) {
 		this.sizeNames = sizeNames;
 		this.sizeNames = sizeNames;
 	}
 	}
+
+	public double getBreakSizePercent() {
+		return breakSizePercent;
+	}
+
+	public void setBreakSizePercent(double breakSizePercent) {
+		this.breakSizePercent = breakSizePercent;
+	}
+
 }
 }

@@ -39,13 +39,19 @@ public abstract class AbstractStorageRelatedMqListener extends AbstractMqListene
 
 
 	protected void fillStorageNumAndSizeInfo(Integer productId, Map<String, Object> indexData) {
 	protected void fillStorageNumAndSizeInfo(Integer productId, Map<String, Object> indexData) {
 		List<Storage> storageList = storageService.getStoragesByProductId(productId);
 		List<Storage> storageList = storageService.getStoragesByProductId(productId);
+		// 过滤掉下架的storage
 		if (CollectionUtils.isNotEmpty(storageList)) {
 		if (CollectionUtils.isNotEmpty(storageList)) {
-            // 过滤掉下架的无库存的storage
-            storageList = storageList.stream()
-                    .filter(storage -> Integer.valueOf(1).equals(storage.getStatus()))
-                    .filter(storage -> storage.getStorageNum() != null && storage.getStorageNum().intValue() > 0)
-                    .collect(Collectors.toList());
+			storageList = storageList.stream().filter(storage -> Integer.valueOf(1).equals(storage.getStatus())).collect(Collectors.toList());
 		}
 		}
+		int totalSizeCount = storageList.size();
+
+		// 过滤掉无库存的storage
+		if (CollectionUtils.isNotEmpty(storageList)) {
+			storageList = storageList.stream().filter(storage -> storage.getStorageNum() != null && storage.getStorageNum().intValue() > 0).collect(Collectors.toList());
+		}
+		int effectiveSizeCount = storageList.size();
+		
+		float breakSizePercent = 100 * (totalSizeCount - effectiveSizeCount)/totalSizeCount;
 		
 		
 		if (CollectionUtils.isEmpty(storageList)) {
 		if (CollectionUtils.isEmpty(storageList)) {
 			indexData.put("storageNum", 0);
 			indexData.put("storageNum", 0);
@@ -53,6 +59,7 @@ public abstract class AbstractStorageRelatedMqListener extends AbstractMqListene
 			indexData.put("isSoldOut", "Y");
 			indexData.put("isSoldOut", "Y");
 			indexData.put("soldOut", 0);
 			indexData.put("soldOut", 0);
 			indexData.put("sizeIds", null);
 			indexData.put("sizeIds", null);
+			indexData.put("breakSizePercent", 100);
 		} else {
 		} else {
 			int storageNum = 0;
 			int storageNum = 0;
 			Set<String> sizeSet = new HashSet<String>();
 			Set<String> sizeSet = new HashSet<String>();
@@ -74,6 +81,7 @@ public abstract class AbstractStorageRelatedMqListener extends AbstractMqListene
 				indexData.put("sizeIds", null);
 				indexData.put("sizeIds", null);
 				indexData.put("sizeNames", null);
 				indexData.put("sizeNames", null);
 			}
 			}
+			indexData.put("breakSizePercent", breakSizePercent);
 		}
 		}
 	}
 	}
 
 
@@ -87,7 +95,7 @@ public abstract class AbstractStorageRelatedMqListener extends AbstractMqListene
 			ProductGoodsBO productGoodsBO = productGoodsBOList.get(0);
 			ProductGoodsBO productGoodsBO = productGoodsBOList.get(0);
 			String goodsListJsonArrayStr = productGoodsBO.getGoodsList();
 			String goodsListJsonArrayStr = productGoodsBO.getGoodsList();
 			JSONArray goodsListJsonArray = JSONArray.parseArray(goodsListJsonArrayStr);
 			JSONArray goodsListJsonArray = JSONArray.parseArray(goodsListJsonArrayStr);
-            productGoodsLogicService.getColorSet(goodsListJsonArray, colorIdSet, colorNameSet);//获取有库存且状态正常的color
+			productGoodsLogicService.getColorSet(goodsListJsonArray, colorIdSet, colorNameSet);// 获取有库存且状态正常的color
 			indexData.put("goodsList", goodsListJsonArray);
 			indexData.put("goodsList", goodsListJsonArray);
 			indexData.put("colorIds", StringUtils.join(colorIdSet, ","));
 			indexData.put("colorIds", StringUtils.join(colorIdSet, ","));
 			indexData.put("colorNames", StringUtils.join(colorNameSet, ","));
 			indexData.put("colorNames", StringUtils.join(colorNameSet, ","));

@@ -781,6 +781,9 @@
         "type": "string",
         "type": "string",
         "analyzer": "comma_spliter"
         "analyzer": "comma_spliter"
       },
       },
+       "breakSizePercent": {
+        "type": "double"
+      },
       "standardIds": {
       "standardIds": {
         "type": "string",
         "type": "string",
         "analyzer": "comma_spliter"
         "analyzer": "comma_spliter"

@@ -126,6 +126,8 @@ public class ProductIndexService {
         map.put(ProductIndexEsField.colorNames, productIndexBO.getColorNames());
         map.put(ProductIndexEsField.colorNames, productIndexBO.getColorNames());
         map.put(ProductIndexEsField.sizeIds, productIndexBO.getSizeIds());
         map.put(ProductIndexEsField.sizeIds, productIndexBO.getSizeIds());
         map.put(ProductIndexEsField.sizeNames, productIndexBO.getSizeNames());
         map.put(ProductIndexEsField.sizeNames, productIndexBO.getSizeNames());
+        map.put(ProductIndexEsField.breakSizePercent, productIndexBO.getBreakSizePercent());
+        
         map.put(ProductIndexEsField.standardIds, productIndexBO.getStandardIds());
         map.put(ProductIndexEsField.standardIds, productIndexBO.getStandardIds());
         map.put(ProductIndexEsField.standardNames, productIndexBO.getStandardNames());
         map.put(ProductIndexEsField.standardNames, productIndexBO.getStandardNames());
         map.put(ProductIndexEsField.styleIds, productIndexBO.getStyleIds());
         map.put(ProductIndexEsField.styleIds, productIndexBO.getStyleIds());

@@ -53,6 +53,7 @@ public class ProductIndexBO extends ProductIBO implements Serializable {
 	private Integer soldOut;
 	private Integer soldOut;
 	private String sizeIds;
 	private String sizeIds;
 	private String sizeNames;
 	private String sizeNames;
+	private double breakSizePercent;
 
 
 	// from product_15day_salesnum
 	// from product_15day_salesnum
 	private Integer salesNum;
 	private Integer salesNum;
@@ -416,6 +417,14 @@ public class ProductIndexBO extends ProductIBO implements Serializable {
 		return sizeNames;
 		return sizeNames;
 	}
 	}
 
 
+	public double getBreakSizePercent() {
+		return breakSizePercent;
+	}
+
+	public void setBreakSizePercent(double breakSizePercent) {
+		this.breakSizePercent = breakSizePercent;
+	}
+
 	public String getIsStudentPrice() {
 	public String getIsStudentPrice() {
 		return isStudentPrice;
 		return isStudentPrice;
 	}
 	}

@@ -8,6 +8,7 @@ import com.yoho.search.dal.model.Goods;
 import com.yoho.search.dal.model.ProductSizes;
 import com.yoho.search.dal.model.ProductSizes;
 import com.yoho.search.dal.model.Size;
 import com.yoho.search.dal.model.Size;
 import com.yoho.search.dal.model.Storage;
 import com.yoho.search.dal.model.Storage;
+
 import org.apache.commons.collections.CollectionUtils;
 import org.apache.commons.collections.CollectionUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Component;
@@ -37,26 +38,38 @@ public class ProductSizesLogicService {
 
 
 	/**
 	/**
 	 * 获取ProductSizes列表
 	 * 获取ProductSizes列表
+	 * 
 	 * @return
 	 * @return
 	 */
 	 */
 	public List<ProductSizes> getData(List<Integer> ids) {
 	public List<ProductSizes> getData(List<Integer> ids) {
-        //获取ProductId对应的上架的goodsId列表
+		// 获取ProductId对应的上架的goodsId列表
 		List<Goods> goodsList = goodsMapper.getByIdsAndStatus(ids);
 		List<Goods> goodsList = goodsMapper.getByIdsAndStatus(ids);
-        if(CollectionUtils.isEmpty(goodsList)){
+		if (CollectionUtils.isEmpty(goodsList)) {
 			return new ArrayList<>();
 			return new ArrayList<>();
 		}
 		}
 
 
-        //获取goodsId对应得Storage列表
+		// 获取goodsId对应得Storage列表
 		List<Integer> goodsIdList = goodsList.parallelStream().map(Goods::getId).collect(Collectors.toList());
 		List<Integer> goodsIdList = goodsList.parallelStream().map(Goods::getId).collect(Collectors.toList());
 		List<Storage> storageList = storageMapper.getByGoodsIds(goodsIdList);
 		List<Storage> storageList = storageMapper.getByGoodsIds(goodsIdList);
 		if (CollectionUtils.isEmpty(storageList)) {
 		if (CollectionUtils.isEmpty(storageList)) {
 			return new ArrayList<>();
 			return new ArrayList<>();
 		}
 		}
 
 
-        //过滤状态是上架的且有库存的Goods和Storage
-        storageList = storageList.parallelStream().filter(storageItem -> VALID_STATUS.equals(storageItem.getStatus()))
-                .filter(storageItem -> storageItem.getStorageNum() != null && storageItem.getStorageNum().intValue() > 0).collect(Collectors.toList());
-        if(CollectionUtils.isEmpty(storageList)){
+		// 过滤掉下架的sku
+		storageList = storageList.parallelStream().filter(storageItem -> VALID_STATUS.equals(storageItem.getStatus())).collect(Collectors.toList());
+
+		// 计算每个skn则总尺码数
+		Map<Integer, Integer> sknSizeCountMap = new HashMap<Integer, Integer>();
+		for (Storage storage : storageList) {
+			Integer productId = storage.getProductId();
+			int count = sknSizeCountMap.getOrDefault(productId, 0);
+			sknSizeCountMap.put(productId, count + 1);
+		}
+
+		// 过滤状态是上架的且有库存的Goods和Storage
+		storageList = storageList.parallelStream().filter(storageItem -> storageItem.getStorageNum() != null && storageItem.getStorageNum().intValue() > 0)
+				.collect(Collectors.toList());
+		if (CollectionUtils.isEmpty(storageList)) {
 			return new ArrayList<>();
 			return new ArrayList<>();
 		}
 		}
 
 
@@ -68,8 +81,7 @@ public class ProductSizesLogicService {
 				validErpSkuIdList.add(s.getErpSkuId());
 				validErpSkuIdList.add(s.getErpSkuId());
 			}
 			}
 		}
 		}
-
-        //判断sku列表是否为空
+		// 判断sku列表是否为空
 		if (validErpSkuIdList == null || validErpSkuIdList.isEmpty()) {
 		if (validErpSkuIdList == null || validErpSkuIdList.isEmpty()) {
 			return new ArrayList<>();
 			return new ArrayList<>();
 		}
 		}
@@ -90,24 +102,38 @@ public class ProductSizesLogicService {
 			}
 			}
 		}
 		}
 
 
+		// 获取尺码信息
 		List<Size> sizeList = sizeMapper.getByIds(sizeIdSet.stream().collect(Collectors.toList()));
 		List<Size> sizeList = sizeMapper.getByIds(sizeIdSet.stream().collect(Collectors.toList()));
+
+		// 填充尺码信息和断码率
 		if (CollectionUtils.isNotEmpty(sizeList)) {
 		if (CollectionUtils.isNotEmpty(sizeList)) {
 			Map<Integer, String> sizeMap = sizeList.stream().collect(Collectors.toMap(Size::getId, Size::getSizeName));
 			Map<Integer, String> sizeMap = sizeList.stream().collect(Collectors.toMap(Size::getId, Size::getSizeName));
-            //productSizesList.forEach(ps -> ps.setSizeNames(Arrays.stream(ps.getSizeIds().split(",")).map(Integer::valueOf).map(sizeId -> sizeMap.get(sizeId)).collect(Collectors.joining(","))));
 			for (ProductSizes ps : productSizesList) {
 			for (ProductSizes ps : productSizesList) {
 				String sizeArray[] = ps.getSizeIds().split(",");
 				String sizeArray[] = ps.getSizeIds().split(",");
+				// 计算断码率
+				double breakSizePercent = this.getBreakSizePercent(sknSizeCountMap.getOrDefault(ps.getProductId(), 0), sizeArray == null ? 0 : sizeArray.length);
+				ps.setBreakSizePercent(breakSizePercent);
+				// 填充尺码名称
 				if (sizeArray != null) {
 				if (sizeArray != null) {
 					for (int i = 0; i < sizeArray.length; i++) {
 					for (int i = 0; i < sizeArray.length; i++) {
 						if (i == 0) {
 						if (i == 0) {
-                            ps.setSizeNames(sizeMap.get(Integer.valueOf(sizeArray[i]))+ ",");
+							ps.setSizeNames(sizeMap.get(Integer.valueOf(sizeArray[i])) + ",");
 						} else {
 						} else {
-                            ps.setSizeNames(ps.getSizeNames() + sizeMap.get(Integer.valueOf(sizeArray[i]))+ ",");
+							ps.setSizeNames(ps.getSizeNames() + sizeMap.get(Integer.valueOf(sizeArray[i])) + ",");
 						}
 						}
 					}
 					}
+
 				}
 				}
 			}
 			}
 		}
 		}
-
 		return productSizesList;
 		return productSizesList;
 	}
 	}
+
+	private double getBreakSizePercent(int totalSizeCount, int effectiveSizeCount) {
+		if (totalSizeCount == 0 || effectiveSizeCount == 0) {
+			return 100d;
+		}
+		return 100d * (effectiveSizeCount - totalSizeCount) / totalSizeCount;
+	}
+
 }
 }

@@ -19,6 +19,7 @@ public class ProductSizesBuilder implements ViewBuilder {
 
 
 	@Autowired
 	@Autowired
 	private ProductSizesLogicService productSizesLogicService;
 	private ProductSizesLogicService productSizesLogicService;
+
 	/**
 	/**
 	 * 构建ProductSizes数据
 	 * 构建ProductSizes数据
 	 */
 	 */
@@ -31,6 +32,7 @@ public class ProductSizesBuilder implements ViewBuilder {
 			productIndexBO.setIsSoonSoldOut("N");
 			productIndexBO.setIsSoonSoldOut("N");
 			productIndexBO.setIsSoldOut("N");
 			productIndexBO.setIsSoldOut("N");
 			productIndexBO.setSoldOut(1);
 			productIndexBO.setSoldOut(1);
+			productIndexBO.setBreakSizePercent(100);
 			if (productSizes != null) {
 			if (productSizes != null) {
 				productIndexBO.setStorageNum(BigDecimal.valueOf(productSizes.getStorageNum()));
 				productIndexBO.setStorageNum(BigDecimal.valueOf(productSizes.getStorageNum()));
 				if (productSizes.getStorageNum() <= 2) {
 				if (productSizes.getStorageNum() <= 2) {
@@ -42,11 +44,12 @@ public class ProductSizesBuilder implements ViewBuilder {
 				}
 				}
 				productIndexBO.setSizeIds(productSizes.getSizeIds());
 				productIndexBO.setSizeIds(productSizes.getSizeIds());
 				productIndexBO.setSizeNames(productSizes.getSizeNames());
 				productIndexBO.setSizeNames(productSizes.getSizeNames());
-            }
-            else {
+				productIndexBO.setBreakSizePercent(productSizes.getBreakSizePercent());
+			} else {
 				productIndexBO.setStorageNum(BigDecimal.valueOf(0));
 				productIndexBO.setStorageNum(BigDecimal.valueOf(0));
 				productIndexBO.setIsSoldOut("Y");
 				productIndexBO.setIsSoldOut("Y");
 				productIndexBO.setSoldOut(0);
 				productIndexBO.setSoldOut(0);
+				productIndexBO.setBreakSizePercent(100);
 			}
 			}
 		}
 		}
 	}
 	}