Class SearchTask

src/main/java/com/github/threading/SearchTask.java:29–170

import java.util.concurrent.Callable;

@Slf4j
public class SearchTask implements Callable<List<SearchView>> {
    private final JNICLibraryV7_18_92ServiceWorker jnicLibraryV7_18_92ServiceWorker;
    private final RedisTemplate redisTemplate;

    public SearchTask(JNICLibraryV7_18_92ServiceWorker jnicLibraryV7_18_92ServiceWorker, RedisTemplate redisTemplate) {
        this.jnicLibraryV7_18_92ServiceWorker = jnicLibraryV7_18_92ServiceWorker;
        this.redisTemplate = redisTemplate;
    }


    private SearchRequest getSearchRequest(Keywords item) {
        String key = "keywords_" + item.getId() + "_filter";
        String keywordsFilter = (String) redisTemplate.opsForValue().get(key);
        if (StringUtils.isBlank(keywordsFilter)) {
            return null;
        }
        return JSONObject.parseObject(keywordsFilter, SearchRequest.class);
    }


    private String getTitleFilter(Keywords item) {
        String key = "keywords_title_" + item.getId() + "_filter";
        return (String) redisTemplate.opsForValue().get(key);
    }

    private String getSellFilter(Keywords item) {
        String key = "keywords_sell_" + item.getId() + "_filter";
        return (String) redisTemplate.opsForValue().get(key);
    }

    @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();