1.6

13693261870

2023-01-06 d12b5b41ee33e7eb57f3c3fe00f4fae53eb93388

 src/main/java/com/lf/server/service/data/DataLoaderService.java

@@ -249,16 +249,11 @@
                        continue;
                    }

                    MetaEntity me = createMetaEntity(entity, mf, tab.getTab(), tab.getRows());
                    MetaEntity me = createMetaEntity(entity, mf, tab.getTab(), tab.getRows(), filePath);
                    if (metaService.insert(me) == 0) {
                        continue;
                    }

                    MetaEntity mfe = createMetaFileEntity(me, mf, filePath);
                    if (metaService.insert(mfe) == 0) {
                        metaService.delete(me.getId());
                        continue;
                    }
                    count += tab.getRows();
                }

@@ -312,36 +307,24 @@
    /**
     * 创建元数据实体
     */
    private MetaEntity createMetaEntity(MetaEntity entity, MetaEntity mf, String tab, int rows) {
    private MetaEntity createMetaEntity(MetaEntity entity, MetaEntity mf, String tab, int rows, String filePath) {
        MetaEntity me = new MetaEntity();
        me.setDepid(entity.getDepid());
        me.setEventid(StringHelper.getGuid());
        me.setDirid(entity.getDirid());
        me.setDepid(entity.getDepid());
        me.setVerid(entity.getVerid());
        me.setType(getType(mf.getName().toLowerCase()));
        me.setName(mf.getName());
        me.setType(getType(mf.getName().toLowerCase()));
        me.setGuid(entity.getGuid());
        me.setPath(FileHelper.getRelativePath(filePath));
        me.setSizes(mf.getSizes());
        me.setBstab(tab);
        me.setBsrows(rows);
        // me.setMdtab()
        me.setCreateTime(entity.getCreateTime());
        me.setCreateUser(entity.getCreateUser());

        return me;
    }

    /**
     * 创建元数据文件实体
     */
    private MetaEntity createMetaFileEntity(MetaEntity me, MetaEntity entity, String filePath) {
        MetaEntity mfe = new MetaEntity();
        mfe.setName(entity.getName());
        mfe.setMetaid(me.getId());
        mfe.setGuid(entity.getGuid());
        mfe.setSizes(entity.getSizes());
        mfe.setPath(FileHelper.getRelativePath(filePath));
        mfe.setCreateUser(me.getCreateUser());
        mfe.setCreateTime(me.getCreateTime());

        return mfe;
    }

    /**
@@ -389,6 +372,8 @@

            for (T t : list) {
                BaseEntity be = (BaseEntity) t;
                be.setEventid(StringHelper.getGuid());
                be.setParentid(me.getEventid());
                be.setCreateuser(me.getCreateUser());
                be.setCreatetime(me.getCreateTime());
                be.setDirid(me.getDirid());