package com.example.server.sysOss.service;
|
|
import cn.hutool.core.collection.CollectionUtil;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.io.IoUtil;
|
import cn.hutool.core.util.NumberUtil;
|
import cn.hutool.core.util.ReflectUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.IdWorker;
|
import com.example.client.entity.ErrorCode;
|
import com.example.client.entity.RenException;
|
import com.example.client.service.BaseService;
|
import com.example.server.sysOss.dao.SysOssDao;
|
import com.example.server.sysOss.dto.OssDto;
|
import com.example.server.sysOss.model.SysOss;
|
import lombok.SneakyThrows;
|
import org.apache.commons.io.FileUtils;
|
import org.apache.commons.io.FilenameUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.multipart.MultipartFile;
|
import sun.misc.BASE64Decoder;
|
|
import javax.annotation.PostConstruct;
|
import javax.crypto.Cipher;
|
import javax.crypto.KeyGenerator;
|
import java.io.*;
|
import java.lang.reflect.Field;
|
import java.security.Key;
|
import java.security.SecureRandom;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
/**
|
* 文件上传
|
*
|
* @author hehz
|
*/
|
@Service
|
public class SysOssService extends BaseService<SysOssDao, SysOss> {
|
@Autowired
|
OssEncryptService ossEncryptService;
|
@Value("${zt.oss.local-path}")
|
private String localPath;
|
|
|
private static final String CIPHER_ALGORITHM = "AES";
|
private static final String key = "zhpt-key#%W";
|
|
/**
|
* 通过业务id BusiId和业务类型 busiType获取附件数据
|
*
|
* @return
|
*/
|
public List<SysOss> getList(Long busiId, String busiType) {
|
return baseDao.getList(busiId, busiType);
|
}
|
|
public void upload(SysOss oss) {
|
oss.setId(IdWorker.getId());
|
File oldFile = new File(oss.getPath());
|
oss.setSize(NumberUtil.round(oldFile.length() / 1024, 2).doubleValue());
|
String uuid = UUID.randomUUID().toString().replaceAll("-", "");
|
// 文件路径
|
String path = DateUtil.format(new Date(), "yyyyMMdd") + "/" + uuid;
|
String newPath = "life-protection/" + path + FilenameUtils.getExtension(oss.getPath());
|
oss.setPath(newPath);
|
oss.setType(FilenameUtils.getExtension(oss.getPath()));
|
String newFullPath = localPath + newPath;
|
File newFile = new File(newFullPath);
|
try {
|
FileUtils.copyToFile(ossEncryptService.encryptStream(FileUtils.openInputStream(oldFile), ossEncryptService.getKey(key)), newFile);
|
} catch (Exception e) {
|
throw new RenException(ErrorCode.OSS_UPLOAD_FILE_ERROR.getCode(), e, "");
|
}
|
oss.setUrl("http://127.0.0.1:8050/life-protection/sys/oss/content?_zt_oss_id=" + oss.getId());
|
this.insert(oss);
|
}
|
|
|
public Integer getBusiFieldNameCount(Long busiId, String busiType) {
|
return baseDao.getBusiFieldNameCount(busiId, busiType);
|
}
|
|
public List<SysOss> getSysOssByBusiType(Map<String, Object> params) {
|
return baseDao.getSysOssByBusiType(params);
|
}
|
|
}
|
