yoho-search / yoho-search-consumer · Commits

Go to a project

Authored by wangnan9279
Commit 403ce5aebfd9ed597e40cba7912b6d99dfde4546 1 parent 55c5cb7f

fix

Inline Side-by-side
Showing 2 changed files with 7 additions and 4 deletions
@@ -150,10 +150,7 @@ public class TblToYohoIndexBuilder extends IIndexBuilder { @@ -150,10 +150,7 @@ public class TblToYohoIndexBuilder extends IIndexBuilder {
150 this.tblSizeLogicService.build(tblProductSkuMap, productIndexBO, tblProduct, sizeMap); 150 this.tblSizeLogicService.build(tblProductSkuMap, productIndexBO, tblProduct, sizeMap);
151 // 特殊处理逻辑 151 // 特殊处理逻辑
152 specialDealLogicService.specialDealForProductIBO(productIndexBO); 152 specialDealLogicService.specialDealForProductIBO(productIndexBO);
153 - // 状态不是有效的丢掉  
154 - if (productIndexBO.getStatus() != 0) {  
155 - productIndexBOList.add(productIndexBO);  
156 - } 153 + productIndexBOList.add(productIndexBO);
157 } 154 }
158 return productIndexBOList; 155 return productIndexBOList;
159 } catch (Exception e) { 156 } catch (Exception e) {
@@ -40,6 +40,8 @@ public class CutdownPriceProductMqListener extends AbstractMqListener { @@ -40,6 +40,8 @@ public class CutdownPriceProductMqListener extends AbstractMqListener {
40 @Autowired 40 @Autowired
41 private ProductService productService; 41 private ProductService productService;
42 42
  43 + @Autowired
  44 +
43 @Override 45 @Override
44 public String getIndexName() { 46 public String getIndexName() {
45 return ISearchConstants.INDEX_NAME_CUTDOWN_PRICE_PRODUCT; 47 return ISearchConstants.INDEX_NAME_CUTDOWN_PRICE_PRODUCT;
@@ -52,8 +54,12 @@ public class CutdownPriceProductMqListener extends AbstractMqListener { @@ -52,8 +54,12 @@ public class CutdownPriceProductMqListener extends AbstractMqListener {
52 54
53 @Override 55 @Override
54 protected void deleteData(String id) throws Exception { 56 protected void deleteData(String id) throws Exception {
  57 + CutdownPriceProduct cutdownPriceProduct = cutdownPriceProductMapper.selectByPrimaryKey(Integer.valueOf(id));
55 cutdownPriceProductService.delete(Integer.valueOf(id)); 58 cutdownPriceProductService.delete(Integer.valueOf(id));
56 indexService.deleteIndexData(this.getIndexName(), id); 59 indexService.deleteIndexData(this.getIndexName(), id);
  60 + if(cutdownPriceProduct!=null){
  61 + updateProductIndex(cutdownPriceProduct.getProductSkn());
  62 + }
57 } 63 }
58 64
59 @Override 65 @Override