查询品牌bugfix

src/main/java/com/caimei365/commodity/service/impl/SearchProductServiceImpl.java

@@ -5,6 +5,7 @@ import com.aliyun.opensearch.sdk.dependencies.org.json.JSONException;
 import com.aliyun.opensearch.sdk.dependencies.org.json.JSONObject;
 import com.aliyun.opensearch.sdk.generated.commons.OpenSearchClientException;
 import com.aliyun.opensearch.sdk.generated.commons.OpenSearchException;
+import com.aliyun.opensearch.sdk.generated.search.DeepPaging;
 import com.aliyun.opensearch.sdk.generated.search.SearchParams;
 import com.caimei365.commodity.components.PriceUtilService;
 import com.caimei365.commodity.components.SearchOpenService;
@@ -172,12 +173,26 @@ public class SearchProductServiceImpl implements SearchProductService {
             }
         }
         SearchParams searchParams = searchOpenService.getParams(queryStr, identity, filter);
-        log.info("查询品牌发送参数---------------------------------------------------》"+searchParams.toString());
         // searchParams.setdeep
+        //设置scroll方式查询
+        DeepPaging deep = new DeepPaging();
+        //不设置默认为1m表示1分钟，该参数表示本次返回的scrollid的有效期
+        deep.setScrollExpire("3m");
+        //添加DeepPaging对象参数
+        searchParams.setDeepPaging(deep);
         // searchOpenService.getResultJsonObject 返回result获取scrollid
+        String scroll_id = null;
+        try {
+            JSONObject resultJson = searchOpenService.getResultJsonObject(queryStr, searchParams);
+            scroll_id = resultJson.getString("scroll_id");
+        } catch (Exception e) {
+            log.error("查询文档异常：" + e.getMessage());
+            return ResponseJson.error("查询文档异常：" + e.getMessage(), null);
+        }
+        deep.setScrollId(scroll_id);
+        searchParams.setDeepPaging(deep);
         // searchParams.setscrollid
         ResponseJson<Set<HashMap<String, Object>>> result = getBrandResult(searchParams, queryStr);
-        log.info("查询品牌返回参数---------------------------------------------------》"+result.toString());
         return result;
     }