| | |
| | | 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; |
| | |
| | | |
| | | @Autowired |
| | | DownloadMapper downloadMapper; |
| | | |
| | | @Autowired |
| | | MetaDownService metaDownService; |
| | | |
| | | private final static Log log = LogFactory.getLog(DownloadService.class); |
| | | |
| | |
| | | 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; |
| | | } |
| | | |
| | | /** |
| | |
| | | |
| | | 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); |
| | | } |
| | | } |