| 提交 | 用户 | 时间 | ||
| e7c126 | 1 | package com.iailab.module.infra.dal.dataobject.file; |
| H | 2 | |
| 3 | import cn.hutool.core.util.StrUtil; | |
| 4 | import com.iailab.framework.common.util.json.JsonUtils; | |
| 5 | import com.iailab.framework.mybatis.core.dataobject.BaseDO; | |
| 6 | import com.iailab.module.infra.framework.file.core.client.FileClientConfig; | |
| 7 | import com.iailab.module.infra.framework.file.core.client.db.DBFileClientConfig; | |
| 8 | import com.iailab.module.infra.framework.file.core.client.ftp.FtpFileClientConfig; | |
| 9 | import com.iailab.module.infra.framework.file.core.client.local.LocalFileClientConfig; | |
| 10 | import com.iailab.module.infra.framework.file.core.client.s3.S3FileClientConfig; | |
| 11 | import com.iailab.module.infra.framework.file.core.client.sftp.SftpFileClientConfig; | |
| 12 | import com.iailab.module.infra.framework.file.core.enums.FileStorageEnum; | |
| 13 | import com.baomidou.mybatisplus.annotation.KeySequence; | |
| 14 | import com.baomidou.mybatisplus.annotation.TableField; | |
| 15 | import com.baomidou.mybatisplus.annotation.TableName; | |
| 16 | import com.baomidou.mybatisplus.extension.handlers.AbstractJsonTypeHandler; | |
| 17 | import com.fasterxml.jackson.core.type.TypeReference; | |
| 18 | import lombok.*; | |
| 19 | ||
| 20 | /** | |
| 21 | * 文件配置表 | |
| 22 | * | |
| 23 | * @author iailab | |
| 24 | */ | |
| 25 | @TableName(value = "infra_file_config", autoResultMap = true) | |
| 26 | @KeySequence("infra_file_config_seq") // 用于 Oracle、PostgreSQL、Kingbase、DB2、H2 数据库的主键自增。如果是 MySQL 等数据库，可不写。 | |
| 27 | @Data | |
| 28 | @EqualsAndHashCode(callSuper = true) | |
| 29 | @ToString(callSuper = true) | |
| 30 | @Builder | |
| 31 | @NoArgsConstructor | |
| 32 | @AllArgsConstructor | |
| 33 | public class FileConfigDO extends BaseDO { | |
| 34 | ||
| 35 | /** | |
| 36 | * 配置编号，数据库自增 | |
| 37 | */ | |
| 38 | private Long id; | |
| 39 | /** | |
| 40 | * 配置名 | |
| 41 | */ | |
| 42 | private String name; | |
| 43 | /** | |
| 44 | * 存储器 | |
| 45 | * | |
| 46 | * 枚举 {@link FileStorageEnum} | |
| 47 | */ | |
| 48 | private Integer storage; | |
| 49 | /** | |
| 50 | * 备注 | |
| 51 | */ | |
| 52 | private String remark; | |
| 53 | /** | |
| 54 | * 是否为主配置 | |
| 55 | * | |
| 56 | * 由于我们可以配置多个文件配置，默认情况下，使用主配置进行文件的上传 | |
| 57 | */ | |
| 58 | private Boolean master; | |
| 59 | ||
| 60 | /** | |
| 61 | * 支付渠道配置 | |
| 62 | */ | |
| 63 | @TableField(typeHandler = FileClientConfigTypeHandler.class) | |
| 64 | private FileClientConfig config; | |
| 65 | ||
| 66 | public static class FileClientConfigTypeHandler extends AbstractJsonTypeHandler<Object> { | |
| 67 | ||
| 68 | @Override | |
| 69 | protected Object parse(String json) { | |
| 70 | FileClientConfig config = JsonUtils.parseObjectQuietly(json, new TypeReference<FileClientConfig>() {}); | |
| 71 | if (config != null) { | |
| 72 | return config; | |
| 73 | } | |
| 74 | ||
| 75 | // 兼容老版本的包路径 | |
| 76 | String className = JsonUtils.parseObject(json, "@class", String.class); | |
| 77 | className = StrUtil.subAfter(className, ".", true); | |
| 78 | switch (className) { | |
| 79 | case "DBFileClientConfig": | |
| 80 | return JsonUtils.parseObject2(json, DBFileClientConfig.class); | |
| 81 | case "FtpFileClientConfig": | |
| 82 | return JsonUtils.parseObject2(json, FtpFileClientConfig.class); | |
| 83 | case "LocalFileClientConfig": | |
| 84 | return JsonUtils.parseObject2(json, LocalFileClientConfig.class); | |
| 85 | case "SftpFileClientConfig": | |
| 86 | return JsonUtils.parseObject2(json, SftpFileClientConfig.class); | |
| 87 | case "S3FileClientConfig": | |
| 88 | return JsonUtils.parseObject2(json, S3FileClientConfig.class); | |
| 89 | default: | |
| 90 | throw new IllegalArgumentException("未知的 FileClientConfig 类型：" + json); | |
| 91 | } | |
| 92 | } | |
| 93 | ||
| 94 | @Override | |
| 95 | protected String toJson(Object obj) { | |
| 96 | return JsonUtils.toJsonString(obj); | |
| 97 | } | |
| 98 | ||
| 99 | } | |
| 100 | ||
| 101 | } | |
