管道基础大数据平台系统开发-【后端】-Server
13693261870
2023-01-05 43f760eb9dff0d983d58dc801772877f9cb1865f
1.5.3
已修改7个文件
已删除1个文件
195 ■■■■ 文件已修改
src/main/java/com/lf/server/controller/all/BaseUploadController.java 6 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/controller/data/MetaController.java 7 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/mapper/data/MetaMapper.java 16 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/service/data/DataLoaderService.java 27 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/service/data/DataUploadService.java 30 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/service/data/MetaService.java 14 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/data/MetaFileMapper.xml 78 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/data/MetaMapper.xml 17 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/controller/all/BaseUploadController.java
@@ -137,7 +137,7 @@
    @SysLog()
    @ApiOperation(value = "删除文件")
    @ApiImplicitParams({
            @ApiImplicitParam(name = "list", value = "实体类集合", dataType = "MetaFileEntity", paramType = "body")
            @ApiImplicitParam(name = "list", value = "实体类集合", dataType = "MetaEntity", paramType = "body")
    })
    @ResponseBody
    @PostMapping(value = "/deleteFiles")
@@ -171,9 +171,7 @@
                return fail("id数组不能为空", -1);
            }
            // int count = metaService.deletes(ids)
            String idStr = StringHelper.join(ids, ",");
            int count = metaService.deleteCascade(idStr);
            int count = metaService.deletes(ids);
            return success(count);
        } catch (Exception ex) {
src/main/java/com/lf/server/controller/data/MetaController.java
@@ -233,8 +233,7 @@
    @GetMapping(value = "/delete")
    public ResponseMsg<Integer> delete(int id) {
        try {
            // int count = metaService.delete(id)
            int count = metaService.deleteCascade(String.valueOf(id));
            int count = metaService.delete(id);
            return success(count);
        } catch (Exception ex) {
@@ -254,9 +253,7 @@
                return fail("id数组不能为空", -1);
            }
            // int count = metaService.deletes(ids)
            String idStr = StringHelper.join(ids, ",");
            int count = metaService.deleteCascade(idStr);
            int count = metaService.deletes(ids);
            return success(count);
        } catch (Exception ex) {
src/main/java/com/lf/server/mapper/data/MetaMapper.java
@@ -73,6 +73,14 @@
    public MetaEntity selectById(int id);
    /**
     * æ ¹æ®GUID查询
     *
     * @param guid æ–‡ä»¶GUID
     * @return
     */
    public MetaEntity selectByGuid(String guid);
    /**
     * æŸ¥è¯¢å…ƒæ•°æ®æ–‡ä»¶
     *
     * @param ids å…ƒæ•°æ®ID集合
@@ -111,14 +119,6 @@
     * @return
     */
    public Integer deletes(List<Integer> ids);
    /**
     * çº§è”删除
     *
     * @param ids
     * @return
     */
    public Integer deleteCascade(String ids);
    /**
     * æ›´æ–°ä¸€æ¡
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,13 +307,15 @@
    /**
     * åˆ›å»ºå…ƒæ•°æ®å®žä½“
     */
    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.setDirid(entity.getDirid());
        me.setVerid(entity.getVerid());
        me.setType(getType(mf.getName().toLowerCase()));
        me.setName(mf.getName());
        me.setGuid(entity.getGuid());
        me.setPath(FileHelper.getRelativePath(filePath));
        me.setSizes(mf.getSizes());
        me.setBstab(tab);
        me.setBsrows(rows);
@@ -326,22 +323,6 @@
        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;
    }
    /**
src/main/java/com/lf/server/service/data/DataUploadService.java
@@ -31,14 +31,8 @@
                String filePath = getFilePath(temp, root, mf);
                // å…ƒæ•°æ®
                MetaEntity me = createMetaEntity(entity, mf);
                if (metaService.insert(me) < 1) {
                    continue;
                }
                // å…ƒæ•°æ®æ–‡ä»¶
                MetaEntity mfe = createMetaFileEntity(me, mf, filePath);
                if (metaService.insert(mfe) > 0) {
                MetaEntity me = createMetaEntity(entity, mf, filePath);
                if (metaService.insert(me) > 0) {
                    count++;
                }
            }
@@ -74,33 +68,19 @@
    /**
     * åˆ›å»ºå…ƒæ•°æ®å®žä½“
     */
    private MetaEntity createMetaEntity(MetaEntity entity, MetaEntity mf) {
    private MetaEntity createMetaEntity(MetaEntity entity, MetaEntity mf, String filePath) {
        MetaEntity me = new MetaEntity();
        me.setDepid(entity.getDepid());
        me.setDirid(entity.getDirid());
        me.setVerid(entity.getVerid());
        me.setType("file");
        me.setGuid(entity.getGuid());
        me.setPath(FileHelper.getRelativePath(filePath));
        me.setName(mf.getName());
        me.setSizes(mf.getSizes());
        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;
    }
}
src/main/java/com/lf/server/service/data/MetaService.java
@@ -56,6 +56,11 @@
    }
    @Override
    public MetaEntity selectByGuid(String guid) {
        return metaMapper.selectByGuid(guid);
    }
    @Override
    public List<MetaEntity> selectMetaFiles(List<Integer> ids) {
        return metaMapper.selectMetaFiles(ids);
    }
@@ -81,11 +86,6 @@
    }
    @Override
    public Integer deleteCascade(String ids) {
        return metaMapper.deleteCascade(ids);
    }
    @Override
    public Integer update(MetaEntity entity) {
        return metaMapper.update(entity);
    }
@@ -93,9 +93,5 @@
    @Override
    public Integer updates(List<MetaEntity> list) {
        return metaMapper.updates(list);
    }
    public MetaEntity selectByGuid(String guid){
        return null;
    }
}
src/main/resources/mapper/data/MetaFileMapper.xml
ÎļþÒÑɾ³ý
src/main/resources/mapper/data/MetaMapper.xml
@@ -82,17 +82,17 @@
        </selectKey>
        insert into lf.sys_meta
        (name,dirid,depid,verid,type,sizes,tab,rows,cs,scale,resolution,gather,batch,descr,create_user,create_time,geom)
        (eventid,metaid,dirid,depid,verid,name,type,guid,path,sizes,bstab,bsrows,mdtab,mdrows,create_user,create_time,bak,geom)
        values
        (#{name},#{dirid},#{depid},#{verid},#{type},#{sizes},#{tab},#{rows},#{cs},#{scale},#{resolution},#{createTime},#{batch},#{descr},#{createUser},#{createTime},#{geom})
        (#{eventid},#{metaid},#{dirid},#{depid},#{verid},#{name},#{type},#{guid},#{path},#{sizes},#{bstab},#{bsrows},#{mdtab},#{mdrows},#{createUser},now(),#{bak},#{geom})
    </insert>
    <insert id="inserts">
        insert into lf.sys_meta
        (name,dirid,depid,verid,type,sizes,tab,rows,cs,scale,resolution,gather,batch,descr,create_user,create_time,geom)
        (eventid,metaid,dirid,depid,verid,name,type,guid,path,sizes,bstab,bsrows,mdtab,mdrows,create_user,create_time,bak,geom)
        values
        <foreach collection="list" item="item" index="index" separator=",">
            (#{item.name},#{item.dirid},#{item.depid},#{item.verid},#{item.type},#{item.sizes},#{item.tab},#{item.rows},#{item.cs},#{item.scale},#{item.resolution},now(),#{item.batch},#{item.descr},#{item.createUser},now(),#{item.geom})
            (#{item.eventid},#{item.metaid},#{item.dirid},#{item.depid},#{item.verid},#{item.name},#{item.type},#{item.guid},#{item.path},#{item.sizes},#{item.bstab},#{item.bsrows},#{item.mdtab},#{item.mdrows},#{item.createUser},now(),#{item.bak},#{item.geom})
        </foreach>
    </insert>
@@ -107,14 +107,9 @@
        </foreach>
    </delete>
    <delete id="deleteCascade">
        delete from lf.sys_meta_file where metaid in (${ids});
        delete from lf.sys_meta where id in (${ids});
    </delete>
    <update id="update">
        update lf.sys_meta
        set name=#{name},dirid=#{dirid},depid=#{depid},verid=#{verid},type=#{type},sizes=#{sizes},tab=#{tab},rows=#{rows},cs=#{cs},scale=#{scale},resolution=#{resolution},gather=now(),batch=#{batch},descr=#{descr},update_user=#{updateUser},update_time=now(),geom=#{geom}
        set eventid=#{eventid},metaid=#{metaid},dirid=#{dirid},depid=#{depid},verid=#{verid},name=#{name},type=#{type},guid=#{guid},path=#{path},sizes=#{sizes},bstab=#{bstab},bsrows=#{bsrows},mdtab=#{mdtab},mdrows=#{mdrows},update_user=#{updateUser},update_time=now(),bak=#{bak},geom=#{geom}
        where id=#{id}
    </update>
@@ -122,7 +117,7 @@
        <foreach collection="list" item="item" index="index" separator=";">
            update lf.sys_meta
            <set>
                name=#{item.name},dirid=#{item.dirid},depid=#{item.depid},verid=#{item.verid},type=#{item.type},sizes=#{item.sizes},tab=#{item.tab},rows=#{item.rows},cs=#{item.cs},scale=#{item.scale},resolution=#{item.resolution},gather=now(),batch=#{item.batch},descr=#{item.descr},update_user=#{item.updateUser},update_time=now(),geom=#{item.geom}
                eventid=#{item.eventid},metaid=#{item.metaid},dirid=#{item.dirid},depid=#{item.depid},verid=#{item.verid},name=#{item.name},type=#{item.type},guid=#{item.guid},path=#{item.path},sizes=#{item.sizes},bstab=#{item.bstab},bsrows=#{item.bsrows},mdtab=#{item.mdtab},mdrows=#{item.mdrows},update_user=#{item.updateUser},update_time=now(),bak=#{item.bak},geom=#{item.geom}
            </set>
            where id = #{item.id}
        </foreach>