Authored by unknown

fix

... ... @@ -25,6 +25,7 @@ import com.yoho.search.consumer.service.bo.ProductIBO;
import com.yoho.search.consumer.service.logic.productIndex.viewBuilder.ProductPriceBuilder;
import com.yoho.search.dal.model.Product;
import com.yoho.search.dal.model.ProductPrice;
import com.yoho.search.dal.model.ProductPriceHistory;
@Component
public class ProductMqListener extends AbstractIndexMqListener {
... ... @@ -95,7 +96,8 @@ public class ProductMqListener extends AbstractIndexMqListener {
// 2、构建ProductPrice
ProductPrice productPrice = productPriceService.getBySkn(productSkn);
Map<String, Object> productPriceModelMap = productPriceBuilder.getProductPriceModelMap(productId, productIBO.getFirstShelveTime(), productPrice);
ProductPriceHistory productPriceHistory = productPriceService.selectProductPriceHistory(productSkn);
Map<String, Object> productPriceModelMap = productPriceBuilder.getProductPriceModelMap(productId, productIBO.getFirstShelveTime(), productPrice,productPriceHistory);
logger.info("[step2=getProductPrice][productId={}][cost={}ms]", productId, costStatistics.getCost());
// 3、更新到ES
... ...