Method call

src/main/java/com/github/threading/SearchTask.java:60–105

()

    }

    @Override
    public List<SearchView> call() throws Exception {
        List<SearchView> searchViewList = new ArrayList<>();
        String json = (String) redisTemplate.opsForValue().get("keywords");
        if (json != null) {
            List<Keywords> keywordsList = JSONObject.parseObject(json, new TypeReference<List<Keywords>>() {
            });
            for (Keywords item : keywordsList) {
                SearchRequest searchRequest = getSearchRequest(item);
                assert searchRequest != null;
                searchRequest.rowsPerPage = searchRequest.pageNumber * searchRequest.rowsPerPage;
                String titleFilter = getTitleFilter(item);
                String sellFilter = getSellFilter(item);

                String t = String.valueOf(System.currentTimeMillis() / 1000);
                String dataJson = JSONObject.toJSONString(searchRequest);
                Map<String, String> param = RequestParamBuilder.builderParam(t, dataJson, CommonConstants.searchApi);
                String input = MapConvert.convertInnerBaseStrMap(CommonConstants.appKey, param, true).get("INPUT").toString();
                Map<String, String> signResult = jnicLibraryV7_18_92ServiceWorker.doCommandNative_70102(CommonConstants.appKey, input, CommonConstants.searchApi).get();

                try {

                    String cookie = Optional.ofNullable(redisTemplate.opsForValue().get("cookie"))
                            .map(Object::toString)
                            .orElse(null);
                    Map<String, String> headers = RequestParamBuilder.builderHeaders(signResult.get("x-sgext"), signResult.get("x-sign"), signResult.get("x-mini-wua"), t, signResult.get("x-umt"), cookie);
                    param.clear();
                    param.put("data", URLEncoder.encode(dataJson, "UTF-8"));
                    String url = "https://acs.m.goofish.com/gw/mtop.taobao.idlemtopsearch.search/1.0/";
                    JSONArray resultList = JSONObject.parseObject(OkHttpUtil.postForm(url, headers, dataJson)).getJSONObject("data").getJSONArray("resultList");
                    for (int i = 0; i < resultList.size(); i++) {
                        SearchView searchView = buildSearchView(resultList.getJSONObject(i), searchRequest);
                        // 标题关键字过滤
                        if (searchView != null && isCheckTitleFilter(titleFilter, searchView.getTitle()) && isSellFilter(sellFilter, searchView.getUserNickName())) {
                            if (searchView.getUserNickName() != null) {
                                searchViewList.add(searchView);
                            }
                        }
                    }
                } catch (IOException e) {
                    log.error(e.getMessage(), e);
                }
            }
        }
        return searchViewList;
    }


    private SearchView buildSearchView(JSONObject jsonObject, SearchRequest searchRequest) {