杜洪波
2024-08-28 25fa030044c7de10ccaaf4a9728c6037a29fa6ba
代码提交
已修改1个文件
20 ■■■■ 文件已修改
src/main/java/com/product/file/service/FileManagerService.java 20 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/product/file/service/FileManagerService.java
@@ -424,17 +424,27 @@
     *     根据附件表数据生成文档索引
     */
    public void readAttachmentCreateIndex() {
        // 遍历附件表
        DataTableEntity dtAttachment = baseDao.listTable(CmnConst.PRODUCT_SYS_ATTACHMENTS);
        if (BaseUtil.dataTableIsEmpty(dtAttachment)) {
            return ;
        }
        for (int i = 0; i < dtAttachment.getRows(); i++) {
            // 获取附件信息,并判断是否有表和字段
            FieldSetEntity fseAttachment = dtAttachment.getFieldSetEntity(i);
            FieldSetEntity fseIndex = new FieldSetEntity();
            fseIndex.setTableName("fseIndex");
            fseIndex.setValue("function_uuid", fseAttachment.getString("function_uuid"));
            fseIndex.setValue("attachment_uuid", fseAttachment.getUUID());
            CreateDocumentIndexThread.getInstance().appendAttaInfo(fseIndex);
            if(BaseUtil.strIsNull(fseAttachment.getString("attachment_data_field")) || BaseUtil.strIsNull(fseAttachment.getString("attachment_data_field"))) {
                continue;
            }
            // 查询原数据,有原数据再生成文档检索
            FieldSetEntity fseRecord = baseDao.getFieldSetEntityByFilter(fseAttachment.getString("attachment_data_table"), fseAttachment.getString("attachment_data_field") + " LIKE ?", new Object[] {"%"+fseAttachment.getUUID()+"%"}, false);
            if(fseRecord != null) {
                // 生成文档检索信息
                FieldSetEntity fseIndex = new FieldSetEntity();
                fseIndex.setTableName("fseIndex");
                fseIndex.setValue("function_uuid", fseAttachment.getString("function_uuid"));
                fseIndex.setValue("attachment_uuid", fseAttachment.getUUID());
                CreateDocumentIndexThread.getInstance().appendAttaInfo(fseIndex);
            }
        }
    }