log

src/main/java/com/caimei/modules/opensearch/SearchUitls.java

@@ -1,6 +1,8 @@
 package com.caimei.modules.opensearch;
 
 import com.thinkgem.jeesite.common.config.Global;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Component;
 import org.springframework.util.LinkedMultiValueMap;
 import org.springframework.util.MultiValueMap;
@@ -14,7 +16,7 @@ import org.springframework.web.client.RestTemplate;
  */
 @Component
 public class SearchUitls {
-
+	Logger logger = LoggerFactory.getLogger(getClass());
     public void updateProductIndex(Integer productId){
         MultiValueMap<String, Integer> paramMap = new LinkedMultiValueMap<>();
         paramMap.add("productId", productId);
@@ -46,7 +48,7 @@ public class SearchUitls {
     public void updateShopIndex(Integer shopId){
         MultiValueMap<String, Integer> paramMap = new LinkedMultiValueMap<>();
         paramMap.add("shopId", shopId);
-        updatePost("/update/supplier", paramMap);
+        updatePost("/update/shop", paramMap);
     }
 
     public void updateEquipmentIndex(Integer equipmentId){
@@ -61,10 +63,10 @@ public class SearchUitls {
         RestTemplate restTemplate = new RestTemplate();
         String uri = coreServer + "/commodity/search/index" + path;
         // 打印参数
-        System.out.println("更新索引uri：" + uri +"，参数："+ paramMap.toString());
+        logger.info("更新索引uri：" + uri +"，参数："+ paramMap.toString());
         // 发起Post请求
         String result = restTemplate.postForObject(uri, paramMap, String.class);
-        System.out.println("更新索引result：" + result);
+        logger.info("更新索引result：" + result);
     }
 
 

src/main/java/com/caimei/modules/product/web/ProductNewController.java

@@ -327,8 +327,6 @@ public class ProductNewController extends BaseController {
             }
         }
         addMessage(redirectAttributes, "保存商品成功");
-        // 更新索引
-        searchUitls.updateProductIndex(product.getProductID());
         String editFlag = product.getEditFlag();
         if (StringUtils.equals("1", editFlag)) {
             redirectAttributes.addAttribute("id", product.getId());
@@ -348,6 +346,8 @@ public class ProductNewController extends BaseController {
         }
         // 有数据变动时需要清除缓存
         cleanRedisCache();
+        // 更新索引
+        searchUitls.updateProductIndex(product.getProductID());
         return "redirect:" + Global.getAdminPath() + "/product/new/list/";
     }