管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2023-02-26 fbb748083ba961607fdc905034c84d3b1e1f9d01
1
已修改2个文件
36 ■■■■■ 文件已修改
src/main/java/com/lf/server/service/data/DownloadService.java 32 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/resources/mapper/data/DownloadMapper.xml 4 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/main/java/com/lf/server/service/data/DownloadService.java
@@ -5,9 +5,11 @@
import com.lf.server.entity.data.DownloadEntity;
import com.lf.server.entity.data.MetaEntity;
import com.lf.server.entity.show.PipelineEntity;
import com.lf.server.entity.sys.MetaDownEntity;
import com.lf.server.entity.sys.UserEntity;
import com.lf.server.helper.*;
import com.lf.server.mapper.data.DownloadMapper;
import com.lf.server.service.sys.MetaDownService;
import net.lingala.zip4j.ZipFile;
import net.lingala.zip4j.model.FileHeader;
import net.lingala.zip4j.model.ZipParameters;
@@ -32,6 +34,9 @@
    @Autowired
    DownloadMapper downloadMapper;
    @Autowired
    MetaDownService metaDownService;
    private final static Log log = LogFactory.getLog(DownloadService.class);
@@ -197,10 +202,14 @@
        addMetaFiles(zip, params, list);
        String dbPwd = Md5Helper.reverse(Md5Helper.generate(pwd));
        DownloadEntity downloadEntity = getDownloadEntity(ue, zipFile, dbPwd);
        int rows = downloadMapper.insert(downloadEntity);
        DownloadEntity de = getDownloadEntity(ue, zipFile, dbPwd);
        return rows > 0 ? downloadEntity.getGuid() : null;
        downloadMapper.insert(de);
        if (de.getId() > 0) {
            insertMetaDown(ue, list, de);
        }
        return de.getId() > 0 ? de.getGuid() : null;
    }
    /**
@@ -332,4 +341,21 @@
        return de;
    }
    /**
     * 插入源数据-下载表
     */
    private void insertMetaDown(UserEntity ue, List<MetaEntity> metas, DownloadEntity de) {
        List<MetaDownEntity> list = new ArrayList<>();
        for (MetaEntity me : metas) {
            MetaDownEntity md = new MetaDownEntity();
            md.setMetaid(me.getId());
            md.setDownid(de.getId());
            md.setCreateUser(ue.getId());
            list.add(md);
        }
        metaDownService.inserts(list);
    }
}
src/main/resources/mapper/data/DownloadMapper.xml
@@ -56,6 +56,10 @@
    </select>
    <insert id="insert" parameterType="com.lf.server.entity.data.DownloadEntity">
        <selectKey resultType="java.lang.Integer" order="AFTER" keyProperty="id">
            select currval('lf.sys_download_id_seq'::regclass) as id
        </selectKey>
       insert into lf.sys_download
       (name,type,depid,sizes,dcount,pwd,url,descr,guid,create_user,create_time,download_user,download_time,geom,bak)
       values