yoho-search / yoho-search-consumer · Commits

Go to a project

Authored by unknown
Commit cba9d1a072790523aa3d8dbc9607b165d31d96bc 1 parent 257f7228

fix 全量建价格索引的bug

Inline Side-by-side
Showing 2 changed files with 11 additions and 13 deletions
package com.yoho.search.consumer.index.increment.productIndex;
import java.math.BigDecimal;
import java.util.HashMap;
import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import com.alibaba.fastjson.JSONObject;
import com.yoho.search.base.utils.ConvertUtils;
import com.yoho.search.base.utils.EventReportEnum;
import com.yoho.search.base.utils.ISearchConstants;
import com.yoho.search.consumer.index.common.IYohoIndexService;
import com.yoho.search.consumer.index.increment.AbstractIndexMqListener;
import com.yoho.search.consumer.service.base.ProductPriceService;
import com.yoho.search.consumer.service.base.ProductService;
import com.yoho.search.consumer.service.bo.ProductPriceBO;
import com.yoho.search.consumer.service.logic.productIndex.viewBuilder.ProductPriceBuilder;
import com.yoho.search.dal.ProductPriceMapper;
import com.yoho.search.dal.ProductPricePlanMapper;
import com.yoho.search.dal.model.Product;
import com.yoho.search.dal.model.ProductPrice;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.math.BigDecimal;
import java.util.HashMap;
import java.util.Map;
@Component
public class ProductPriceMqListener extends AbstractIndexMqListener {
... ... @@ -87,7 +85,7 @@ public class ProductPriceMqListener extends AbstractIndexMqListener {
}
private void updateProductIndex(Integer productId, ProductPrice pp) {
Map<String, Object> indexData = new HashMap<String, Object>(30);
Map<String, Object> indexData = new HashMap<String, Object>();
// 构造ProductPriceBO
ProductPriceBO productPriceBO = new ProductPriceBO(pp);
... ...
... ... @@ -49,7 +49,7 @@ public class ProductPriceBuilder implements ViewBuilder {
try {
// 如果价格不存在，则直接返回
ProductPrice productPrice = productPricesMap.get(pi.getProductId());
ProductPrice productPrice = productPricesMap.get(pi.getProductSkn());
if (productPrice == null) {
continue;
}
... ...