package com.zbooksoft.gdmis.controller;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.mapper.SqlRunner;
import com.fasterxml.jackson.core.type.TypeReference;
import com.ruili.wcp.common.CustomConfigUtil;
import com.ruili.wcp.common.JSONUtil;
import com.ruili.wcp.data.entity.config.TableColumn;
import com.ruili.wcp.data.entity.management.User;
import com.ruili.wcp.data.vo.config.AdvancedConditionVO;
import com.ruili.wcp.engine.DataSourceConfig;
import com.ruili.wcp.service.config.TableColumnService;
import com.ruili.wcp.web.common.LicenseException;
import com.ruili.wcp.web.model.AjaxResponse;
import com.ruili.wcp.web.model.ErrorInfo;
import com.ruili.wcp.web.model.easyui.DataTableVO;
import com.ruili.wcp.web.model.easyui.PagedAndFilteredInputDto;
import com.ruili.wcp.web.model.easyui.PagedSortedAndFilteredInputDto;
import com.zbooksoft.gdmis.config.ArchivesCustomConfig;
import com.zbooksoft.gdmis.data.entity.*;
import com.zbooksoft.gdmis.service.CatAjjxxService;
import com.zbooksoft.gdmis.service.CatCgwjxxService;
import com.zbooksoft.gdmis.service.CatSwajxxService;
import com.zbooksoft.gdmis.service.CatYswjxxService;
import org.apache.commons.lang3.StringEscapeUtils;
import org.apache.shiro.SecurityUtils;
import org.apache.shiro.authz.annotation.RequiresUser;
import org.apache.shiro.session.Session;
import org.apache.shiro.subject.Subject;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.text.Text;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.index.query.*;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightField;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.servlet.ModelAndView;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.util.*;
import java.util.concurrent.TimeUnit;

/**
 * @Description:资料检索
 * @Author: zhai
 * @Date: 2024/8/28
 **/
@Controller
@RequestMapping("/search")
public class SearchController {
    @Autowired
    CatAjjxxService catAjjxxService;
    @Autowired
    CatCgwjxxService catCgwjxxService;
    @Autowired
    CatSwajxxService catSwajxxService;

    @Autowired
    CatYswjxxService catYswjxxService;
    @Autowired
    CustomConfigUtil customConfigUtil;
    @Autowired
    TableColumnService tableColumnService;
    @Autowired
    JdbcTemplate jdbcTemplate;
    @Autowired
    RestHighLevelClient restHighLevelClient;


    private static final Logger logger = LoggerFactory.getLogger(SearchController.class);

    /**
     * 资料检索页面
     *
     * @return
     */
    @RequestMapping(value = "/retrieve")
    @RequiresUser
    public ModelAndView retrieve() {
        ModelAndView mv = new ModelAndView("gh/search/retrieve");
        return mv;
    }

    /**
     * 全文案卷目录检索结果页
     *
     * @param keyword
     * @return
     * @throws Exception
     */
    @RequestMapping("/searchResult")
    @RequiresUser
    public ModelAndView searchResult(Integer isSuperSearch, String selectedValue, String keyword) throws Exception {
        ModelAndView mav = null;
        ArchivesCustomConfig archivesCustomConfig = customConfigUtil.getConfigObj(ArchivesCustomConfig.class);
        mav = new ModelAndView("gh/search/searchResult");
        mav.addObject("archivesCustomConfig", archivesCustomConfig);
        mav.addObject("selectedValue", selectedValue);
        mav.addObject("keyword", keyword);
        return mav;
    }


    /**
     * 全文内容检索结果页
     *
     * @param archivesType
     * @param keyword
     * @param request
     * @param response
     * @return
     * @throws Exception
     */
    @RequestMapping("attach")
    @RequiresUser
    public ModelAndView attachSearch(Long archivesType, String keyword, HttpServletRequest request, HttpServletResponse response) throws Exception {
        ModelAndView mav = new ModelAndView("gh/search/result_attach");

        Subject currentUser = SecurityUtils.getSubject();
        Session session = currentUser.getSession();
        mav.addObject("archivesType", archivesType);
        mav.addObject("keyword", keyword);
        return mav;
    }

    @RequestMapping("/getAttachSearchData")
    @ResponseBody
    @RequiresUser
    public Object getAttachSearchData(Long archivesType, PagedAndFilteredInputDto input, String filterMapStr) throws IOException, LicenseException {
        boolean isFieldUpper = DataSourceConfig.checkFieldNameIsNeedUpper();

        try {
            BoolQueryBuilder boolBuilder = QueryBuilders.boolQuery();
            SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
            // 从全文内容和标题中检索关键字
            MultiMatchQueryBuilder matchQueryBuilder = QueryBuilders.multiMatchQuery(input.getSearchText(), "fullText", "WJM")
                    .minimumShouldMatch("50%").operator(Operator.OR);
            boolBuilder.must(matchQueryBuilder);

            if (filterMapStr != null && !filterMapStr.equals("")) {
                Map<String, String> filterMap = JSONUtil.string2Obj(filterMapStr, new TypeReference<Map<String, String>>() {
                });
                for (Map.Entry<String, String> entry : filterMap.entrySet()) {
                    String mapKey = getAvailableString(entry.getKey(), isFieldUpper);

                    String mapValue = entry.getValue();
                    if (!mapValue.equals("") && !mapValue.equals(null)) {
                        boolBuilder.must(new TermQueryBuilder(mapKey, mapValue));
                    }
                }
            }

            MatchPhraseQueryBuilder matchPhraseQueryBuilder = QueryBuilders.matchPhraseQuery("fullText", input.getSearchText()).slop(50);
            boolBuilder.should(matchPhraseQueryBuilder);
            sourceBuilder.query(boolBuilder); // 设置查询，可以是任何类型的QueryBuilder。

            // 设置高亮显示字段
            HighlightBuilder highlightBuilder = new HighlightBuilder();
            highlightBuilder.field(getAvailableString("WJM", isFieldUpper), 250, 1);
            highlightBuilder.field("fullText", 250, 1);
            sourceBuilder.highlighter(highlightBuilder);

            int from = (input.getPage() - 1) * input.getRows();
            sourceBuilder.from(from); // 设置确定结果要从哪个索引开始搜索的from选项，默认为0
            sourceBuilder.size(input.getRows()); // 设置确定搜素命中返回数的size选项，默认为10

            sourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS)); // 设置一个可选的超时，控制允许搜索的时间。

            SearchRequest searchRequest = new SearchRequest("attach"); // 索引
            searchRequest.source(sourceBuilder);
            SearchResponse response = this.restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);
            SearchHits hits = response.getHits(); // SearchHits提供有关所有匹配的全局信息，例如总命中数或最高分数：.
            List<Map<String, Object>> rows = new ArrayList<Map<String, Object>>();

            SearchHit[] hitsList = hits.getHits();
            for (int i = 0; i < hitsList.length; i++) {
                Map<String, Object> hitMap = hitsList[i].getSourceAsMap();
                Map<String, HighlightField> highlightFields = hitsList[i].getHighlightFields(); // 获取对应的高亮域

                Map<String, Object> row = new HashMap<String, Object>();
                row.put("physicalName", getFieldValue(hitMap, highlightFields, getAvailableString("WJTM", isFieldUpper)));
                row.put("fullText", getFieldValue(hitMap, highlightFields, "fullText"));
                Object extension = hitMap.get(getAvailableString("WJGS", isFieldUpper));
                if (extension != null) {
                    extension = extension.toString().toLowerCase();
                }
                row.put("extension", extension);
                row.put("attachId", hitMap.get(getAvailableString("attach_id", isFieldUpper)));
                row.put("moduleId", hitMap.get(getAvailableString("module_id", isFieldUpper)));
                row.put("keyId", hitMap.get(getAvailableString("ID", isFieldUpper)));
                rows.add(row);
            }

            Map<String, Object> data = new HashMap<String, Object>();
            long total = hits.getTotalHits();
            if (total >= 10000) {
                total = 10000;
            }
            data.put("total", total);
            data.put("rows", rows);
            data.put("searchTime", (double) (response.getTook().getMillis()) / 1000);
            return new AjaxResponse(data);
        } catch (Exception e) {
            logger.error(e.getMessage(), e);
            return new AjaxResponse(new ErrorInfo(e.getMessage()), false);
        }
    }


    @RequestMapping("/getSearchData")
    @ResponseBody
    @RequiresUser
    public Object getSearchData(String selectedValue, String keyword, String keywordMapStr, PagedSortedAndFilteredInputDto pageInput) {
        try {
            String selSql = "select * from view_all_utlization  where  1=1";
            if (selectedValue != null && !selectedValue.equals("") && keyword != null && !keyword.equals("")) {
                selSql += " and " + selectedValue + " like '%" + keyword + "%'";
            }
            if (keywordMapStr != null && !keywordMapStr.equals("")) {
                keywordMapStr = StringEscapeUtils.unescapeHtml4(keywordMapStr);
                Map<String, String> filterMap = JSONUtil.string2Obj(keywordMapStr, new TypeReference<Map<String, String>>() {
                });
                for (Map.Entry<String, String> entry : filterMap.entrySet()) {
                    String value = entry.getValue();
                    String key = entry.getKey();
                    if (!value.equals("") && !value.equals(null)) {
                        selSql += " and " + key + " like '%" + value + "%'";
                    }
                }
            }

            // 添加分页支持
            String countSql = "SELECT COUNT(*) FROM (" + selSql + ") tmp_count";
            Integer total = jdbcTemplate.queryForObject(countSql, Integer.class);

            // 添加分页查询
            String pageSql = selSql + " LIMIT " + (pageInput.getPage() - 1) * pageInput.getRows() + ", " + pageInput.getRows();
            List<Map<String, Object>> rows = jdbcTemplate.queryForList(pageSql);

            // 构造分页结果
            Map<String, Object> result = new HashMap<>();
            result.put("total", total);
            result.put("rows", rows);
            return result;
        } catch (Exception e) {
            logger.error(e.getMessage(), e);
            return new AjaxResponse(new ErrorInfo(e.getMessage()), false);
        }
    }

//    @RequestMapping("/getSearchData")
//    @ResponseBody
//    @RequiresUser
//    public Object getSearchData(String selectedValue, String keyword, String keywordMapStr, PagedSortedAndFilteredInputDto pageInput) {
//        try {
//            Page<CatAjjxx> page = new Page(pageInput.getPage(), pageInput.getRows());
//            QueryWrapper<CatAjjxx> catAjjxxQueryWrapper = new QueryWrapper<>();
//            catAjjxxQueryWrapper.eq("fbzt", "1");
//            if (keywordMapStr != null && !keywordMapStr.equals("")) {
//                Map<String, String> filterMap = JSONUtil.string2Obj(keywordMapStr, new TypeReference<Map<String, String>>() {
//                });
//                //{"XCSJ":"60年代","GZCD":"1:50000","ZLLB":"海洋区域地质调查","KC":"钛矿"}
//                for (Map.Entry<String, String> entry : filterMap.entrySet()) {
//                    String value = entry.getValue();
//                    String key = entry.getKey();
//                    if ("DESC".equals(value)) {
//                        catAjjxxQueryWrapper.orderByDesc(key);
//                    } else if ("GZCD".equals(key) && !"".equals(value)) {
//                        catAjjxxQueryWrapper.eq("GZCD", value);
//                    } else if ("ZLLB".equals(key) && !"".equals(value)) {
//                        catAjjxxQueryWrapper.eq("ZLLB", value);
//                    } else if ("KCMC".equals(key) && !"".equals(value)) {
//                        catAjjxxQueryWrapper.like("KCMC", value);
//                    } else if ("XCSJV".equals(key) && !"".equals(value)) {
//                        switch (value) {
//                            case "50年代":
//                                catAjjxxQueryWrapper.between("XCSJ", "1950-01-01", "1960-01-01");
//                                break;
//                            case "60年代":
//                                catAjjxxQueryWrapper.between("XCSJ", "1960-01-01", "1970-01-01");
//                                break;
//                            case "70年代":
//                                catAjjxxQueryWrapper.between("XCSJ", "1970-01-01", "1980-01-01");
//                                break;
//                            case "80年代":
//                                catAjjxxQueryWrapper.between("XCSJ", "1980-01-01", "1990-01-01");
//                                break;
//                            case "90年代":
//                                catAjjxxQueryWrapper.between("XCSJ", "1990-01-01", "2000-01-01");
//                                break;
//                            case "2000年以后":
//                                catAjjxxQueryWrapper.gt("XCSJ", "2000-01-01");
//                                break;
//                            case "解放前":
//                                catAjjxxQueryWrapper.lt("XCSJ", "1949-01-01");
//                                break;
//                        }
//                    }
//                }
//            }
//            if (keyword == null || "".equals(keyword)) {
//                IPage<CatAjjxx> logPage = catAjjxxService.page(page, catAjjxxQueryWrapper);
//                DataTableVO<CatAjjxx> dataTable = new DataTableVO();
//                dataTable.setTotal(logPage.getTotal());
//                dataTable.setRows(logPage.getRecords());
//                return dataTable;
//            }
//            if (selectedValue != null && !"".equals(selectedValue)) {
//                String[] keywords = keyword.split(",");
//                for (String kw : keywords) {
//                    if ("SGDH".equals(selectedValue)) {
//                        catAjjxxQueryWrapper.eq(selectedValue, kw);
//                    } else {
//                        catAjjxxQueryWrapper.like(selectedValue, kw);
//                    }
//                }
//                IPage<CatAjjxx> logPage = catAjjxxService.page(page, catAjjxxQueryWrapper);
//                DataTableVO<CatAjjxx> dataTable = new DataTableVO();
//                dataTable.setTotal(logPage.getTotal());
//                dataTable.setRows(logPage.getRecords());
//                return dataTable;
//            }
//
//            catAjjxxQueryWrapper.like("zlmc", keyword).or().like("dh", keyword);
//            IPage<CatAjjxx> logPage = catAjjxxService.page(page, catAjjxxQueryWrapper);
//            DataTableVO<CatAjjxx> dataTable = new DataTableVO();
//            dataTable.setTotal(logPage.getTotal());
//            dataTable.setRows(logPage.getRecords());
//            return dataTable;
//
//        } catch (Exception e) {
//            logger.error(e.getMessage(), e);
//            return new AjaxResponse(new ErrorInfo(e.getMessage()), false);
//        }
//    }

    @RequestMapping("/getSuperSearchData")
    @ResponseBody
    @RequiresUser
    public Object getSuperSearchData(@RequestParam String keywordMapStr, PagedSortedAndFilteredInputDto pageInput) {

        keywordMapStr = StringEscapeUtils.unescapeHtml4(keywordMapStr);

        try {
            String selSql = "select * from view_all_utlization  where  1=1";

            if (keywordMapStr != null && !keywordMapStr.equals("")) {
                String customSql = getAdvancedConditionsSql(keywordMapStr, 1984044085226344449l);
                selSql += " and" + customSql;
            }
            // 添加分页支持
            String countSql = "SELECT COUNT(*) FROM (" + selSql + ") tmp_count";
            Integer total = jdbcTemplate.queryForObject(countSql, Integer.class);

            // 添加分页查询
            String pageSql = selSql + " LIMIT " + (pageInput.getPage() - 1) * pageInput.getRows() + ", " + pageInput.getRows();
            List<Map<String, Object>> rows = jdbcTemplate.queryForList(pageSql);

            // 构造分页结果
            Map<String, Object> result = new HashMap<>();
            result.put("total", total);
            result.put("rows", rows);
            return result;
        } catch (Exception e) {
            logger.error(e.getMessage(), e);
            return new AjaxResponse(new ErrorInfo(e.getMessage()), false);
        }
    }

    @RequestMapping({"/advancedQuery"})
    @RequiresUser
    public ModelAndView advancedQuery() {
        ModelAndView mav = new ModelAndView("gh/search/advancedQuery");
//        ArrayList<HashMap<String, String>> columnList = new ArrayList<>();
//        HashMap<String, String> stringStringHashMap = new HashMap<>();
//        stringStringHashMap.put("columnName", "SGDH");
//        stringStringHashMap.put("columnLabel", "案卷号");
//        columnList.add(stringStringHashMap);
//        stringStringHashMap = new HashMap<>();
//        stringStringHashMap.put("columnName", "ZLMC");
//        stringStringHashMap.put("columnLabel", "资料名称");
//        columnList.add(stringStringHashMap);
//        stringStringHashMap = new HashMap<>();
//        stringStringHashMap.put("columnName", "DH");
//        stringStringHashMap.put("columnLabel", "案卷号");
//        columnList.add(stringStringHashMap);
//        mav.addObject("columnList", columnList);
        return mav;
    }

    /**
     * 高级查询页面
     *
     * @param keyword
     * @return
     * @throws Exception
     */
    @RequestMapping("/searchFrom")
    @RequiresUser
    public ModelAndView searchFrom(String selectedValue, String keyword) throws Exception {
        ModelAndView mav = new ModelAndView("gh/search/searchFrom");
        return mav;
    }

    /**
     * 资料详情页面
     *
     * @return
     */
    @RequestMapping(value = "/details")
    @RequiresUser
    public ModelAndView details(Long keyId) {
        CatAjjxx catAjjxx = catAjjxxService.getById(keyId);
        String zlmc = catAjjxx.getZlmc();
//        Long swId = catAjjxx.getSwId();
        ModelAndView mv = new ModelAndView("gh/search/details");
        mv.addObject("zlmc", zlmc);
        mv.addObject("keyId", keyId);
//        mv.addObject("swId", swId);

        return mv;
    }


    @RequestMapping("/getDetails")
    @ResponseBody
    @RequiresUser
    public Object getDetails(Long keyId) {
        try {
            String sql = "select * from CAT_FILE_AJJXX where id =" + keyId;
            Map<String, Object> map = jdbcTemplate.queryForMap(sql);
            //其他编著者资料
            String bzzs = map.get("BZZ") == null ? "" : map.get("BZZ").toString();
            bzzs = bzzs.replace("[", "").replace("]", "");
            String[] split = bzzs.split(",");
            ArrayList<String> bzzqtzlList = new ArrayList<>();
            for (int i = 0; i < split.length; i++) {
                QueryWrapper<CatAjjxx> catAjjxxQueryWrapper = new QueryWrapper<>();
                catAjjxxQueryWrapper.like("BZZ", split[i]);
                catAjjxxQueryWrapper.eq("fbzt", 1);
                List<CatAjjxx> list = catAjjxxService.list(catAjjxxQueryWrapper);
                for (CatAjjxx catAjjxx : list) {
                    bzzqtzlList.add(catAjjxx.getZlmc() + "_" + catAjjxx.getId() + "_" + catAjjxx.getBzz());
                }
            }
            map.put("BZZQTZL", bzzqtzlList);
            //形成单位其他资料
            String xcda = map.get("XCDWMC") == null ? "" : map.get("XCDWMC").toString();
            ArrayList<String> xcdwqtzlList = new ArrayList<>();
            QueryWrapper<CatAjjxx> queryWrapper = new QueryWrapper<>();
            queryWrapper.like("XCDWMC", xcda);
            queryWrapper.eq("fbzt", 1);
            List<CatAjjxx> list = catAjjxxService.list(queryWrapper);
            for (CatAjjxx catAjjxx : list) {
                xcdwqtzlList.add(catAjjxx.getZlmc() + "_" + catAjjxx.getId() + "_" + catAjjxx.getBzz());
            }
            map.put("XCDWQTZL", xcdwqtzlList);

            //成果文件目录
            ArrayList<String> wjmuList = new ArrayList<>();
            QueryWrapper<CatCgwjxx> cgwjxxQueryWrapper = new QueryWrapper<>();
            cgwjxxQueryWrapper.eq("AJ_ID", keyId);
            List<CatCgwjxx> catCgwjxxList = catCgwjxxService.list(cgwjxxQueryWrapper);
            for (CatCgwjxx catCgwjxx : catCgwjxxList) {
                wjmuList.add(catCgwjxx.getWjm() + " " + catCgwjxx.getWjtm() + "_" + catCgwjxx.getId());
            }
            map.put("CGWJMU", wjmuList);

            //原始文件目录
            ArrayList<String> yswjmuList = new ArrayList<>();
            QueryWrapper<CatYswjxx> ysWrapper = new QueryWrapper<>();
            ysWrapper.eq("AJ_ID", keyId);
            List<CatYswjxx> catYswjxxList = catYswjxxService.list(ysWrapper);
            for (CatYswjxx catYswjxx : catYswjxxList) {
                yswjmuList.add(catYswjxx.getWjm() + " " + catYswjxx.getWjtm() + "_" + catYswjxx.getId());
            }
            map.put("YSWJMU", yswjmuList);

            //相识资料
            ArrayList<String> xszlList = new ArrayList<>();
            String gjz = map.get("GJZ") == null ? "" : map.get("GJZ").toString();
            String[] gjzs = gjz.split("[，,]");
            for (int i = 0; i < gjzs.length; i++) {
                String gjzValue = gjzs[i];
                if (!"".equals(gjzValue)) {
                    QueryWrapper<CatAjjxx> wrapper = new QueryWrapper<>();
                    wrapper.like("GJZ", gjzs[i]);
                    wrapper.like("fbzt", 1);

                    List<CatAjjxx> xsList = catAjjxxService.list(wrapper);
                    for (CatAjjxx catAjjxx : xsList) {
                        xszlList.add(catAjjxx.getZlmc() + "_" + catAjjxx.getId() + "_" + catAjjxx.getBzz());
                    }
                }
            }
            map.put("XSZL", xszlList);
            return new AjaxResponse(map);
        } catch (Exception e) {
            logger.error(e.getMessage(), e);
            return new AjaxResponse(new ErrorInfo(e.getMessage()), false);
        }
    }

//    @RequestMapping("/getPhysicalDetails")
//    @ResponseBody
//    @RequiresUser
//    public Object getPhysicalDetails(Long keyId) {
//        try {
//
//            String sql = "select * from CAT_FILE_SWAJXX where id =" + keyId;
//            Map<String, Object> map = jdbcTemplate.queryForMap(sql);
//
//            //文件目录
//            ArrayList<String> wjmuList = new ArrayList<>();
//            QueryWrapper<CatSwyxxx> swzkxxQueryWrapper = new QueryWrapper<>();
//            swzkxxQueryWrapper.eq("AJ_ID", keyId);
//            List<CatSwyxxx> catSwyxxxList = catSwyxxxService.list(swzkxxQueryWrapper);
//            for (CatSwyxxx catSwyxxx : catSwyxxxList) {
//                wjmuList.add(catSwyxxx.getZkbh() + "_" + catSwyxxx.getId());
//            }
//            map.put("ZKML", wjmuList);
//
//            return new AjaxResponse(map);
//        } catch (Exception e) {
//            logger.error(e.getMessage(), e);
//            return new AjaxResponse(new ErrorInfo(e.getMessage()), false);
//        }
//    }

    /**
     * 实物资料详情页面
     *
     * @return
     */
    @RequestMapping(value = "/physicalDetails")
    @RequiresUser
    public ModelAndView physicalDetails(Long keyId) {
        CatSwajxx catSwajxx = catSwajxxService.getById(keyId);
        ModelAndView mv = new ModelAndView("gh/search/physicalDetails");
        mv.addObject("keyId", keyId);
        mv.addObject("zlmc", catSwajxx.getSwzltm());
        return mv;
    }

    private String getFieldValue(Map<String, Object> hitMap, Map<String, HighlightField> highlightFields, String fieldName) {
        String fieldValue = "";
        HighlightField highlightFullText = highlightFields.get(fieldName);

        if (highlightFullText != null) {
            // 为title串值增加自定义的高亮标签
            Text[] titleTexts = highlightFullText.fragments();
            String highlightText = "";
            for (Text text : titleTexts) {
                highlightText += text;
            }

            fieldValue = highlightText;
        } else {
            if (hitMap.get(fieldName) != null)
                fieldValue = hitMap.get(fieldName).toString();
        }
        return fieldValue;
    }

    private String getAvailableString(String sourceStr, boolean isFieldUpper) {
        if (isFieldUpper) {
            return sourceStr.toUpperCase();
        } else {
            return sourceStr;
        }
    }

    protected String getAdvancedConditionsSql(String advancedConditionsStr, Long tableId) {
        String conditionsSql = "";
        AdvancedConditionVO advancedCondition = null;

        try {
            advancedConditionsStr = StringEscapeUtils.unescapeHtml4(advancedConditionsStr);
            advancedCondition = (AdvancedConditionVO) JSONUtil.string2Obj(advancedConditionsStr, AdvancedConditionVO.class);
        } catch (Exception var6) {
            logger.error("高级查询条件字符串转换为查询条件对象失败", var6);
        }

        if (advancedCondition != null) {
            List<TableColumn> tableColumns = this.tableColumnService.getColumnListByTableId(tableId);
            conditionsSql = generalGroupAdvancedConditionSql(advancedCondition, tableColumns);
        }

        return conditionsSql;
    }


    protected String generalGroupAdvancedConditionSql(AdvancedConditionVO advancedCondition, List<TableColumn> tableColumns) {
        StringBuffer sqlBuffer = new StringBuffer();
        if (advancedCondition.getChildren() != null && advancedCondition.getChildren().size() > 0) {
            sqlBuffer.append("(");
            Iterator var4 = advancedCondition.getChildren().iterator();

            while (true) {
                while (var4.hasNext()) {
                    AdvancedConditionVO condition = (AdvancedConditionVO) var4.next();
                    String subSqlStr;
                    if (!condition.getOp().equals("and") && !condition.getOp().equals("or")) {
                        subSqlStr = generalRuleAdvancedConditionSql(condition, tableColumns);
                        if (!subSqlStr.equals("")) {
                            if (sqlBuffer.length() > 1) {
                                sqlBuffer.append(" " + condition.getLogicOp());
                            }

                            sqlBuffer.append(" " + subSqlStr);
                        }
                    } else {
                        subSqlStr = this.generalGroupAdvancedConditionSql(condition, tableColumns);
                        if (!subSqlStr.equals("")) {
                            if (sqlBuffer.length() > 1) {
                                sqlBuffer.append(" " + condition.getOp());
                            }

                            sqlBuffer.append(" " + subSqlStr);
                        }
                    }
                }

                sqlBuffer.append(")");
                break;
            }
        }

        return sqlBuffer.toString();
    }

    protected String generalRuleAdvancedConditionSql(AdvancedConditionVO advancedCondition, List<TableColumn> tableColumns) {
        StringBuffer sqlBuffer = new StringBuffer();
        sqlBuffer.append(advancedCondition.getField());
        String operatorQueryText = "";
        String queryValue = "'" + advancedCondition.getValue() + "'";
        TableColumn tableColumn = (TableColumn) tableColumns.stream().filter((a) -> {
            return a.getColumnName().equals(advancedCondition.getField());
        }).findFirst().orElse(null);
        byte var8;
        if (tableColumn != null) {
            switch (tableColumn.getDataType()) {
                case "datetime":
                    if (DataSourceConfig.getDbType().getDb().equalsIgnoreCase("ORACLE")) {
                        queryValue = "to_date('" + advancedCondition.getValue() + " 00:00:00','yyyy-mm-dd hh24:mi:ss')";
                    }
                    break;
                case "int":
                case "float":
                case "decimal":
                case "bit":
                case "tinyint":
                case "bigint":
                    queryValue = advancedCondition.getValue();
            }
        }

        switch (advancedCondition.getOp()) {
            case "equal":
                operatorQueryText = "=";
                break;
            case "notequal":
                operatorQueryText = "!=";
                break;
            case "greater":
                operatorQueryText = ">";
                break;
            case "greaterorequal":
                operatorQueryText = ">=";
                break;
            case "less":
                operatorQueryText = "<";
                break;
            case "lessorequal":
                operatorQueryText = "<=";
                break;
            case "contains":
                operatorQueryText = " like ";
                queryValue = "'%" + advancedCondition.getValue() + "%'";
                break;
            case "notcontains":
                operatorQueryText = " not like ";
                queryValue = "'%" + advancedCondition.getValue() + "%'";
                break;
            case "beginwith":
                operatorQueryText = " like ";
                queryValue = "'" + advancedCondition.getValue() + "%'";
                break;
            case "endwith":
                operatorQueryText = " like ";
                queryValue = "'%" + advancedCondition.getValue() + "'";
                break;
            default:
                operatorQueryText = "=";
        }

        sqlBuffer.append(operatorQueryText + queryValue);
        return sqlBuffer.toString();
    }
}