fix:修复文件检索找不到功能，无法跳转的错误

许鹏程

2025-01-20 d334dfae15726489656d582c8f9356ef02d0686a

fix:修复文件检索找不到功能，无法跳转的错误

 src/main/java/com/product/lucene/service/LuceneService.java

@@ -12,6 +12,7 @@
import com.product.lucene.util.FileUtils;
import com.product.util.BaseUtil;

import com.product.util.UnifySQLSymbol;
import org.apache.lucene.analysis.cn.smart.SmartChineseAnalyzer;
import org.apache.lucene.document.*;
import org.apache.lucene.index.IndexWriter;
@@ -33,6 +34,7 @@
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;

/**
@@ -52,11 +54,11 @@

    @Autowired
    private SearcherManager searcherManager;
	


    /**
     * 创建索引
     * 
     *
     * @param fse
     * @throws IOException
     */
@@ -65,7 +67,7 @@
        File file = (File) fse.getObject("file"); // 获取附件

        // 获取全文检索配置
        FieldSetEntity fseConfig = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_DOCUMENT_SEARCH, "function_uuid=?", new Object[] { function_uuid }, false);
        FieldSetEntity fseConfig = baseDao.getFieldSetEntityByFilter(CmnConst.PRODUCT_SYS_DOCUMENT_SEARCH, "function_uuid=?", new Object[]{function_uuid}, false);
        if (fseConfig == null)
            return;
        String table_uuid = fseConfig.getString(CmnConst.TABLE_NAME);
@@ -111,7 +113,7 @@

    /**
     *     文档检索
     * 
     *
     * @param fse
     * @return
     * @throws Exception
@@ -128,13 +130,13 @@
        try {
            // 获取安全的IndexSearcher实例
            indexSearcher = searcherManager.acquire();
			

            // 获取条件查询结果
            Query finalQuery = searchFilterParse(fse);
	

            // 获取高亮匹配器
            Highlighter highlighter = highlighterParse(finalQuery);
			

            // 分页查询文档
            TopDocs topDocs = searchByPage(fse.getInteger(CoreConst.CPAGE), fse.getInteger(CoreConst.PAGESIZE),
                    indexSearcher, finalQuery);
@@ -144,11 +146,31 @@
            for (int i = 0; i < hits.length; i++) {
                // 获取检索命中的文档信息
                Document doc = indexSearcher.doc(hits[i].doc);
				

                JSONObject jsonFile = new JSONObject();
                jsonFile.put(CmnConst.FILE_UUID, doc.get(CoreConst.UUID));
                jsonFile.put(CoreConst.FUNCTION_UUID, doc.get(CoreConst.FUNCTION_UUID));
	

                if (!StringUtils.isEmpty(doc.get(CoreConst.FUNCTION_UUID))) {
                    FieldSetEntity fs = BaseUtil.getSingleInfoByCache("所有功能", new String[]{jsonFile.getString(CoreConst.FUNCTION_UUID)});
                    if (FieldSetEntity.isEmpty(fs)) {
                        //找不到功能重新根据表名查找
                        //清空
                        jsonFile.remove(CoreConst.FUNCTION_UUID);
                    }
                }

                if (StringUtils.isEmpty(jsonFile.get(CoreConst.FUNCTION_UUID))) {
                    //查询功能信息
                    String sql = "SELECT * FROM product_sys_functions where table_uuid =(select uuid from product_sys_datamodel_table where table_name=?) limit 1";
                    FieldSetEntity fseFunction = baseDao.getFieldSetBySQL(sql, new String[]{doc.get(CmnConst.TABLE_NAME)}, false);
                    if (fseFunction != null) {
                        jsonFile.put(CoreConst.FUNCTION_UUID, fseFunction.getString(CoreConst.UUID));
                        //回写功能信息到文档信息中
                        doc.add(new StoredField(CoreConst.FUNCTION_UUID, fseFunction.getString(CoreConst.UUID)));
                        indexWriter.updateDocument(new Term(CoreConst.UUID, doc.get(CoreConst.UUID)), doc);
                    }
                }
                // 文件名增加高亮显示
                String fileName = doc.get(CmnConst.FILE_NAME);
                String file_name = highlighter.getBestFragment(new SmartChineseAnalyzer(), CmnConst.FILE_NAME,
@@ -163,7 +185,7 @@
                if (StringUtils.isEmpty(file_content)) {
                    file_content = fileContent;
                }
				

                jsonFile.put(CmnConst.FILE_NAME, file_name);
                jsonFile.put(CmnConst.FILE_CONTENT, file_content);
                listJsonFile.add(jsonFile);
@@ -182,14 +204,14 @@
        }
        return jsonReturn;
    }
	

    /**
     *     解析查询条件
     * @param fse
     * @return
     * @throws ParseException
     */
    public Query searchFilterParse(FieldSetEntity fse) throws ParseException   {
    public Query searchFilterParse(FieldSetEntity fse) throws ParseException {
        // 上传人
        String uploadUser = fse.getString("upload_user");
        String startDate = fse.getString("start_date");
@@ -198,7 +220,7 @@

        // 创建查询条件
        BooleanQuery.Builder boolQuery = new BooleanQuery.Builder();
		

        // 上传人过滤
        if (!BaseUtil.strIsNull(uploadUser)) {
            Query uploaderQuery = new TermQuery(new Term("upload_user", uploadUser));
@@ -221,13 +243,13 @@
        // 关键词过滤
        if (!BaseUtil.strIsNull(searchKey)) {
            QueryParser queryParser = new MultiFieldQueryParser(
                    new String[] { CmnConst.FILE_NAME, CmnConst.FILE_CONTENT }, new SmartChineseAnalyzer());
                    new String[]{CmnConst.FILE_NAME, CmnConst.FILE_CONTENT}, new SmartChineseAnalyzer());
            Query query = queryParser.parse(searchKey);
            boolQuery.add(query, BooleanClause.Occur.MUST);
        }
        return boolQuery.build();
    }
	

    /**
     *     查询文件高亮匹配器
     * @param finalQuery
@@ -236,7 +258,7 @@
    public Highlighter highlighterParse(Query finalQuery) {
        // 高亮格式
        SimpleHTMLFormatter simpleHTMLFormatter = new SimpleHTMLFormatter(CmnConst.HIGHLIGHT_BEFORE,
            CmnConst.HIGHLIGHT_AFTER);
                CmnConst.HIGHLIGHT_AFTER);
        // 高亮匹配器
        Highlighter highlighter = new Highlighter(simpleHTMLFormatter, new QueryScorer(finalQuery));
        Fragmenter fragmenter = new SimpleFragmenter(100);
@@ -249,24 +271,21 @@
     * @param listJsonFile
     */
    public void getFileInfo(List<JSONObject> listJsonFile) {
           StringBuilder sql = new StringBuilder();
        for (int i = 0; i < listJsonFile.size(); i++) {
            JSONObject jsonFile = listJsonFile.get(i);
            if (i > 0) {
                sql.append("UNION ALL \n");
            }
            sql.append("SELECT \n");
            sql.append(" A.uuid,A.attachment_data_table,A.attachment_data_field,DATE_FORMAT(A.created_utc_datetime,'%Y-%m-%d') AS upload_date, \n");
            sql.append(" B.org_fields,B.user_fields,B.title_field,B.time_field, \n");
            sql.append(" C.uuid AS function_uuid,C.function_name,D.user_name AS upload_user ");
            sql.append("FROM product_sys_attachments A \n");
            sql.append("LEFT JOIN product_sys_document_search B ON B.table_name = A.attachment_data_table \n");
            sql.append("LEFT JOIN product_sys_functions C ON C.uuid = B.function_uuid \n");
            sql.append("LEFT JOIN product_sys_users D ON D.user_id = A.created_by \n");
            sql.append("WHERE A.uuid = '").append(jsonFile.get("file_uuid")).append("' \n");
        }
        StringBuilder sql = new StringBuilder();
        Set<String> fileUuids = listJsonFile.stream().map(jsonFile -> jsonFile.getString(CmnConst.FILE_UUID)).collect(Collectors.toSet());

        sql.append("SELECT \n");
        sql.append(" A.uuid,A.attachment_data_table,A.attachment_data_field,DATE_FORMAT(A.created_utc_datetime,'%Y-%m-%d') AS upload_date, \n");
        sql.append(" B.org_fields,B.user_fields,B.title_field,B.time_field, \n");
        sql.append(" C.uuid AS function_uuid,C.function_name,D.user_name AS upload_user ");
        sql.append("FROM product_sys_attachments A \n");
        sql.append(" JOIN product_sys_datamodel_table as " + UnifySQLSymbol.getSymbol("table") + " on A.attachment_data_table=" + UnifySQLSymbol.getSymbol("table") + ".table_name \n");
        sql.append("LEFT JOIN product_sys_document_search B ON B.table_name = " + UnifySQLSymbol.getSymbol("table") + ".uuid \n");
        sql.append("LEFT JOIN product_sys_functions C ON C.uuid = B.function_uuid \n");
        sql.append("LEFT JOIN product_sys_users D ON D.user_id = A.created_by \n");
        sql.append("WHERE ").append(BaseUtil.buildQuestionMarkFilter("A.uuid", fileUuids.size(), true));
        // 获取文档附件、配置信息
        DataTableEntity dtConfig = baseDao.listTable(sql.toString(), new Object[] {});
        DataTableEntity dtConfig = baseDao.listTable(sql.toString(), fileUuids.toArray());
        if (!BaseUtil.dataTableIsEmpty(dtConfig)) {
            StringBuilder sqlService = new StringBuilder();
            for (int i = 0; i < dtConfig.getRows(); i++) {
@@ -292,13 +311,13 @@
                sqlService.append("ON B.").append(fseConfig.getString(CmnConst.ATTACHMENT_DATA_FIELD)).append(" LIKE '%").append(fseConfig.getUUID()).append("%' \n");
            }
            // 获取文档业务数据信息
            DataTableEntity dtService = baseDao.listTable(sqlService.toString(), new Object[] {});
            DataTableEntity dtService = baseDao.listTable(sqlService.toString(), new Object[]{});
            if (!BaseUtil.dataTableIsEmpty(dtService)) {
                Map<String, FieldSetEntity> map = dtService.getData().stream()  
                        .collect(Collectors.toMap(  
                                fseService -> fseService.getUUID(),
                                fseService -> fseService
                        ));
                Map<String, FieldSetEntity> map = dtService.getData().stream()
                        .collect(Collectors.toMap(
                                fseService -> fseService.getUUID(),
                                fseService -> fseService
                        ));
                for (int i = 0; i < listJsonFile.size(); i++) {
                    JSONObject jsonFile = listJsonFile.get(i);
                    FieldSetEntity fseService = map.get(jsonFile.get(CmnConst.FILE_UUID));
@@ -315,7 +334,7 @@
            }
        }
    }
	

    public JSONObject permission(String uuid, String function_uuid) {
        JSONObject json = new JSONObject();
        StringBuilder searchConfigSql = new StringBuilder();
@@ -329,7 +348,7 @@
        searchConfigSql.append("WHERE A.function_uuid=?");

        // 获取文档检索配置(功能，跳转按钮)
        FieldSetEntity fseConfig = baseDao.getFieldSetEntityBySQL(searchConfigSql.toString(), new Object[] { function_uuid }, false);
        FieldSetEntity fseConfig = baseDao.getFieldSetEntityBySQL(searchConfigSql.toString(), new Object[]{function_uuid}, false);
        if (fseConfig != null) {

            // 获取跳转按钮 并 判断跳转权限
@@ -373,12 +392,12 @@
                // 获取原数据
                FieldSetEntity fseService = baseDao.getFieldSetEntityByFilter(
                        fseAttachment.getString(CmnConst.ATTACHMENT_DATA_TABLE), filter.toString(),
                        new Object[] { uuid }, false);
                        new Object[]{uuid}, false);
                if (fseService == null) {
                    // 获取无权限过滤的原数据
                    FieldSetEntity fseService2 = baseDao.getFieldSetEntityByFilter(
                            fseAttachment.getString(CmnConst.ATTACHMENT_DATA_TABLE),
                            fseAttachment.getString(CmnConst.ATTACHMENT_DATA_FIELD) + "=?", new Object[] { uuid },
                            fseAttachment.getString(CmnConst.ATTACHMENT_DATA_FIELD) + "=?", new Object[]{uuid},
                            false);
                    if (fseService2 == null) {
                        json.put("permission_msg", "数据异常-业务数据不存在");
@@ -401,7 +420,7 @@
                        // 获取单位文档所属目录权限
                        FieldSetEntity fseDirectRight = baseDao.getFieldSetByFilter(
                                CmnConst.PRODUCT_OA_DIRECTORY_RIGHTS, "directory_uuid=?",
                                new Object[] { fseService.getString(CmnConst.DIRECTORY_UUID) }, false);
                                new Object[]{fseService.getString(CmnConst.DIRECTORY_UUID)}, false);
                        if (fseDirectRight == null) {
                            json.put("permission_msg", "文档权限策略-此文档您没有查看权限");
                            json.put(CmnConst.IS_PERSSION, 4);
@@ -422,7 +441,7 @@

    /**
     * 文件检索查询分页
     * 
     *
     * @param cpage    当前页
     * @param pagesize 每页大小
     * @param searcher 查询器
@@ -450,7 +469,7 @@

    /**
     * 根据附件uuid删除索引
     * 
     *
     * @param uuid
     * @throws IOException
     */