Authored by wangnan

添加增量逻辑

... ... @@ -137,24 +137,6 @@ public class ProductPoolDetailMqListener extends AbstractMqListener implements C
//更新productPool
Map<String, Object> indexData = new HashMap<>();
ProductPool productPool = productPoolService.getById(productPoolDetail.getId());
// indexData.put("poolId",productPool.getPoolId());
// indexData.put("productSkn",productPool.getProductSkn());
// indexData.put("productId",productPool.getProductId());
// indexData.put("sales",productPool.getSales());
// indexData.put("brandId",productPool.getBrandId());
// indexData.put("status",productPool.getStatus());
// indexData.put("attribute",productPool.getAttribute());
// indexData.put("smallSortId",productPool.getSmallSortId());
// indexData.put("middleSortId",productPool.getMiddleSortId());
// indexData.put("maxSortId",productPool.getMaxSortId());
// indexData.put("gender",productPool.getGender());
// indexData.put("storageNum",productPool.getStorageNum());
// indexData.put("salesNum",productPool.getSalesNum());
// indexData.put("marketPrice",productPool.getMarketPrice());
// indexData.put("vipDiscountType",productPool.getVipDiscountType());
// indexData.put("isDiscount",productPool.getIsDiscount());
// indexData.put("isOutlets",productPool.getIsOutlets());
// indexData.put("sizeIds",productPool.getSizeIds());
this.updateProductPoolIndexWithDataMap(JSON.toJSONString(productPool), productPool.getId(), key,System.currentTimeMillis());
}
}
... ...