Bladeren bron

更新商品索引,销量存入阿里云

chao 3 jaren geleden
bovenliggende
commit
43b17488ff
1 gewijzigde bestanden met toevoegingen van 6 en 1 verwijderingen
  1. 6 1
      src/main/java/com/caimei365/commodity/service/impl/PriceServiceImpl.java

+ 6 - 1
src/main/java/com/caimei365/commodity/service/impl/PriceServiceImpl.java

@@ -13,6 +13,7 @@ import com.caimei365.commodity.model.vo.ProductSalesVo;
 import com.caimei365.commodity.model.vo.TaxVo;
 import com.caimei365.commodity.service.PageService;
 import com.caimei365.commodity.service.PriceService;
+import com.caimei365.commodity.service.SearchIndexService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
@@ -40,6 +41,8 @@ public class PriceServiceImpl implements PriceService {
     private PriceUtilService priceUtilService;
     @Resource
     private PageService pageService;
+    @Resource
+    private SearchIndexService searchIndexService;
 
     /**
      * 获取商品详情价格
@@ -158,7 +161,9 @@ public class PriceServiceImpl implements PriceService {
             }
             // 添加销量记录
             priceMapper.insertProductSalesRecord(productId, sales);
-            log.info("【更新商品销量】:" + salesVo.toString());
+            // 更新商品索引,销量存入阿里云
+            searchIndexService.updateProductIndexById(productId);
+            log.info("【更新商品销量】:" + salesVo);
         }
         return ResponseJson.success(null);
     }