...
|
...
|
@@ -92,6 +92,7 @@ public class PromotionProductMqListener extends AbstractMqListener implements Ch |
|
|
private void updateProductIndex(Integer productSkn, long currentTimeMillis,String key){
|
|
|
String promotionIds=promotionProductService.getPromotionIds(productSkn);
|
|
|
Integer productId=productService.selectProductIdBySkn(productSkn);
|
|
|
logger.info("[func=updateProductIndex][step=saveToES][key={}][productId={}][promotionIds={}]", key,productId, promotionIds);
|
|
|
Map<String, Object> indexData = new HashMap<String, Object>();
|
|
|
indexData.put("productId", productId);
|
|
|
indexData.put("promotionIds", promotionIds);
|
...
|
...
|
|