文件上传数据表

package nexus.io.tio.boot.admin.vo;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.Accessors;

@Data
@NoArgsConstructor
@AllArgsConstructor
@Accessors(chain = true)
public class UploadResult {
  private Long id;
  private Long size;
  private String name, targetName, url, md5;

  public UploadResult(long id, String filename, Long size, String url, String md5) {
    this.id = id;
    this.name = filename;
    this.size = size;
    this.url = url;
    this.md5 = md5;
  }

  public UploadResult(long id, String filename, String url, String md5) {
    this.id = id;
    this.name = filename;
    this.url = url;
    this.md5 = md5;
  }

  public UploadResult(long id, String filename, String targetName, String url, String md5) {
    this.id = id;
    this.name = filename;
    this.targetName = targetName;
    this.url = url;
    this.md5 = md5;
  }
}

package nexus.io.tio.boot.admin.dao;

import nexus.io.db.activerecord.Db;
import nexus.io.db.activerecord.Row;

public class SystemUploadFileDao {
  public static final String tableName = "tio_boot_admin_system_upload_file";
  public static final String getFileBasicInfoByMd5Sql = String.format(
      //
      "select id,name,size,bucket_name,target_name from %s  where md5=? and deleted=0", tableName);

  public static final String getFileBasicInfoByIdSql = String.format(
      //
      "select md5,name,size,bucket_name,target_name from %s where id=? and deleted=0", tableName);

  public Row getFileBasicInfoByMd5(String md5) {
    return Db.findFirst(getFileBasicInfoByMd5Sql, md5);
  }

  public Row getFileBasicInfoById(long id) {
    return Db.findFirst(getFileBasicInfoByIdSql, id);
  }

  public boolean save(long id, String md5, String originname, int fileSize, String platform, String bucketName,
      //
      String targetName) {
    Row row = Row.by("id", id)
        //
        .set("md5", md5).set("name", originname).set("size", fileSize)
        //
        .set("platform", platform).set("bucket_name", bucketName)
        //
        .set("target_name", targetName);

    return Db.save(tableName, row);
  }
}

package nexus.io.tio.boot.admin.services;

import com.jfinal.kit.Kv;
import nexus.io.db.activerecord.Row;
import nexus.io.jfinal.aop.Aop;
import nexus.io.tio.boot.admin.dao.SystemUploadFileDao;
import nexus.io.tio.boot.admin.utils.AwsS3Utils;
import nexus.io.model.upload.UploadResult;

public class SystemUploadFileService {
  public UploadResult getUrlById(String id) {
    return getUrlById(Long.parseLong(id));
  }

  public UploadResult getUrlById(long id) {
    Row row = Aop.get(SystemUploadFileDao.class).getFileBasicInfoById(id);
    if (row == null) {
      return null;
    }
    String url = this.getUrl(row.getStr("bucket_name"), row.getStr("target_name"));
    String originFilename = row.getStr("fielename");
    String md5 = row.getStr("md5");
    Long size = row.getLong("size");
    return new UploadResult(id, originFilename, size, url, md5);
  }

  public UploadResult getUrlByMd5(String md5) {
    Row row = Aop.get(SystemUploadFileDao.class).getFileBasicInfoByMd5(md5);
    if (row == null) {
      return null;
    }
    Long id = row.getLong("id");
    String url = this.getUrl(row.getStr("bucket_name"), row.getStr("target_name"));
    Kv kv = row.toKv();
    kv.set("url", url);
    kv.set("md5", md5);
    String originFilename = row.getStr("name");
    Long size = row.getLong("size");
    return new UploadResult(id, originFilename, size, url, md5);
  }

  public String getUrl(String bucketName, String targetName) {
    return String.format(AwsS3Utils.urlFormat, AwsS3Utils.bucketName, targetName);
  }
}

package nexus.io.tio.boot.admin.services;

import nexus.io.model.body.RespBodyVo;
import nexus.io.model.upload.UploadResult;
import nexus.io.model.upload.UploadFile;

public interface StorageService {

  public RespBodyVo upload(String category, UploadFile uploadFile);

  public UploadResult uploadBytes(String category, String originname, int size, byte[] fileContent);

  public UploadResult uploadBytes(long id, String originname, String targetName, byte[] fileContent,
      //
      int size, String suffix);

  public String getUrl(String bucketName, String targetName);

  public UploadResult getUrlById(String id);

  public UploadResult getUrlById(long id);

  public UploadResult getUrlByMd5(String md5);

}