管道基础大数据平台系统开发-【后端】-Server
1
13693261870
2023-02-26 fbb748083ba961607fdc905034c84d3b1e1f9d01
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);
    }
}