管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2023-01-30 6b13c28539ae366e0eebc92d9148eb92140a7c30
src/main/java/com/lf/server/service/data/UploadService.java
@@ -125,7 +125,15 @@
            return;
        }
        List<?> list = null;
        MetaEntity old = metaService.selectByGuid(mf.getGuid(), tabName);
        if (old != null) {
            mf.setEntity(old.getLayer());
            mf.setTab(old.getTab());
            mf.setRows(old.getRows());
            return;
        }
        List<?> list;
        if (StaticData.SHP.equals(mf.getExtName())) {
            list = ShpHelper.readData(clazz, mf.getPath());
        } else {
@@ -138,6 +146,7 @@
        int rows = basicMapper.insertBatch(list);
        if (rows > 0) {
            mf.setEntity(mf.getTab());
            mf.setTab(tabName);
            mf.setRows(rows);
        }
@@ -194,8 +203,8 @@
                        String path = findPathByGuid(list, mf);
                        if (null != path) {
                            mf.setPath(path);
                            continue;
                        }
                        continue;
                    }
                    gdbList.add(mf.getPath());
@@ -218,9 +227,12 @@
            return -1;
        }
        MetaEntity old = metaService.selectByGuid(mf.getGuid());
        MetaEntity old = metaService.selectByGuid(mf.getGuid(), null);
        if (null != old) {
            mf.setPath(old.getPath());
            mf.setTab(old.getTab());
            mf.setEntity(old.getLayer());
            mf.setRows(old.getRows());
            file.delete();
            return 0;
        }
@@ -288,7 +300,7 @@
            return;
        }
        MetaEntity old = metaService.selectByGuid(mf.getGuid());
        MetaEntity old = metaService.selectByGuid(mf.getGuid(), null);
        if (null != old) {
            mf.setPath(old.getPath());
            FileHelper.deleteFiles(file);
@@ -324,7 +336,7 @@
     */
    private String findPathByGuid(List<MetaFileEntity> list, MetaFileEntity mf) {
        for (MetaFileEntity meta : list) {
            if (meta.getGuid().equals(mf.getGuid())) {
            if (meta.getGuid().equals(mf.getGuid()) && !meta.getEventid().equals(mf.getEventid())) {
                return meta.getPath();
            }
        }
@@ -368,6 +380,9 @@
        if (mf.getRows() > 0) {
            me.setTab(mf.getTab());
        }
        if (!StringHelper.isEmpty(mf.getEntity())) {
            me.setLayer(mf.getEntity());
        }
        me.setRows(mf.getRows());
        me.setCreateUser(mf.getCreateUser());
        me.setCreateTime(mf.getCreateTime());
@@ -403,7 +418,15 @@
        for (MetaFileEntity mf : list) {
            boolean isXls = StaticData.XLS.equals(mf.getExtName()) || StaticData.XLSX.equals(mf.getExtName());
            if (mf.getRows() > -1 && isXls) {
                xlsList.add(mf);
                MetaEntity old = metaService.selectByGuid(mf.getGuid(), null);
                if (null == old) {
                    xlsList.add(mf);
                } else {
                    mf.setPath(old.getPath());
                    mf.setTab(old.getTab());
                    mf.setEntity(old.getLayer());
                    mf.setRows(old.getRows());
                }
            }
        }
@@ -433,11 +456,11 @@
        MetaFileEntity meta = new MetaFileEntity();
        meta.setPath(StringHelper.join(pathList, ","));
        meta.setEpsgCode(xlsList.get(0).getEpsgCode());
        meta.setName(StringHelper.join(dirList, ","));
        meta.setName(StringHelper.join(dirList, ";"));
        meta.setDepid(xlsList.get(0).getDepid());
        meta.setVerid(xlsList.get(0).getVerid());
        meta.setCreateUser(xlsList.get(0).getCreateUser());
        meta.setEventid(StringHelper.join(pidList, ","));
        meta.setEventid(StringHelper.join(pidList, ";"));
        return meta;
    }