第171集电商分布式IDJava实战

/**
 * 电商分布式ID配置类
 * @author Java实战
 */
@Configuration
@EnableConfigurationProperties(EcommerceDistributedIdProperties.class)
public class EcommerceDistributedIdConfig {
    
    @Autowired
    private EcommerceDistributedIdProperties properties;
    
    /**
     * 电商雪花算法ID生成器
     * @return 电商雪花算法ID生成器
     */
    @Bean
    public EcommerceSnowflakeIdGenerator ecommerceSnowflakeIdGenerator() {
        return new EcommerceSnowflakeIdGenerator(
            properties.getSnowflake().getWorkerId(),
            properties.getSnowflake().getDatacenterId(),
            properties.getSnowflake().getEcommerceId()
        );
    }
    
    /**
     * 电商UUID生成器
     * @return 电商UUID生成器
     */
    @Bean
    public EcommerceUuidGenerator ecommerceUuidGenerator() {
        return new EcommerceUuidGenerator();
    }
    
    /**
     * 电商数据库自增ID生成器
     * @return 电商数据库自增ID生成器
     */
    @Bean
    public EcommerceDatabaseIdGenerator ecommerceDatabaseIdGenerator() {
        return new EcommerceDatabaseIdGenerator();
    }
    
    /**
     * 电商Redis ID生成器
     * @return 电商Redis ID生成器
     */
    @Bean
    public EcommerceRedisIdGenerator ecommerceRedisIdGenerator() {
        return new EcommerceRedisIdGenerator();
    }
    
    /**
     * 电商Zookeeper ID生成器
     * @return 电商Zookeeper ID生成器
     */
    @Bean
    public EcommerceZookeeperIdGenerator ecommerceZookeeperIdGenerator() {
        return new EcommerceZookeeperIdGenerator();
    }
    
    /**
     * 电商分布式ID服务
     * @return 电商分布式ID服务
     */
    @Bean
    public EcommerceDistributedIdService ecommerceDistributedIdService() {
        return new EcommerceDistributedIdService();
    }
    
    /**
     * 电商分布式ID监控服务
     * @return 电商分布式ID监控服务
     */
    @Bean
    public EcommerceDistributedIdMonitorService ecommerceDistributedIdMonitorService() {
        return new EcommerceDistributedIdMonitorService();
    }
    
    /**
     * 电商分布式ID业务服务
     * @return 电商分布式ID业务服务
     */
    @Bean
    public EcommerceDistributedIdBusinessService ecommerceDistributedIdBusinessService() {
        return new EcommerceDistributedIdBusinessService();
    }
    
    /**
     * 电商分布式ID秒杀服务
     * @return 电商分布式ID秒杀服务
     */
    @Bean
    public EcommerceDistributedIdSeckillService ecommerceDistributedIdSeckillService() {
        return new EcommerceDistributedIdSeckillService();
    }
    
    private static final Logger logger = LoggerFactory.getLogger(EcommerceDistributedIdConfig.class);
}

/**
 * 电商分布式ID属性配置
 * @author Java实战
 */
@Data
@ConfigurationProperties(prefix = "ecommerce-distributed-id")
public class EcommerceDistributedIdProperties {
    
    /**
     * 是否启用电商分布式ID
     */
    private boolean enableEcommerceDistributedId = true;
    
    /**
     * 默认ID生成器类型
     */
    private String defaultGeneratorType = "ECOMMERCE_SNOWFLAKE";
    
    /**
     * 电商雪花算法配置
     */
    private EcommerceSnowflakeConfig snowflake = new EcommerceSnowflakeConfig();
    
    /**
     * 电商UUID配置
     */
    private EcommerceUuidConfig uuid = new EcommerceUuidConfig();
    
    /**
     * 电商数据库自增配置
     */
    private EcommerceDatabaseConfig database = new EcommerceDatabaseConfig();
    
    /**
     * 电商Redis配置
     */
    private EcommerceRedisConfig redis = new EcommerceRedisConfig();
    
    /**
     * 电商Zookeeper配置
     */
    private EcommerceZookeeperConfig zookeeper = new EcommerceZookeeperConfig();
    
    /**
     * 业务配置
     */
    private BusinessConfig business = new BusinessConfig();
    
    /**
     * 秒杀配置
     */
    private SeckillConfig seckill = new SeckillConfig();
    
    /**
     * 库存配置
     */
    private InventoryConfig inventory = new InventoryConfig();
    
    /**
     * 是否启用监控
     */
    private boolean enableMonitoring = true;
    
    /**
     * 监控间隔（毫秒）
     */
    private long monitorInterval = 30000;
    
    /**
     * 是否启用告警
     */
    private boolean enableAlert = true;
    
    /**
     * 生成失败率告警阈值
     */
    private double failureRateAlertThreshold = 0.001;
    
    /**
     * 生成延迟告警阈值（毫秒）
     */
    private long latencyAlertThreshold = 50;
    
    /**
     * 电商雪花算法配置类
     */
    @Data
    public static class EcommerceSnowflakeConfig {
        /**
         * 工作机器ID
         */
        private long workerId = 1L;
        
        /**
         * 数据中心ID
         */
        private long datacenterId = 1L;
        
        /**
         * 电商ID
         */
        private long ecommerceId = 1L;
        
        /**
         * 起始时间戳
         */
        private long startTimestamp = 1609459200000L; // 2021-01-01 00:00:00
        
        /**
         * 是否启用电商雪花算法
         */
        private boolean enableSnowflake = true;
        
        /**
         * 序列号位数
         */
        private long sequenceBits = 10L;
        
        /**
         * 机器标识位数
         */
        private long workerIdBits = 5L;
        
        /**
         * 数据中心标识位数
         */
        private long datacenterIdBits = 5L;
        
        /**
         * 电商标识位数
         */
        private long ecommerceIdBits = 4L;
        
        /**
         * 时间戳位数
         */
        private long timestampBits = 40L;
        
        /**
         * 是否启用加密
         */
        private boolean enableEncryption = true;
        
        /**
         * 加密密钥
         */
        private String encryptionKey = "ecommerce-distributed-id-key";
    }
    
    /**
     * 电商UUID配置类
     */
    @Data
    public static class EcommerceUuidConfig {
        /**
         * UUID版本
         */
        private String version = "UUID4";
        
        /**
         * 是否启用电商UUID
         */
        private boolean enableUuid = false;
        
        /**
         * 是否使用连字符
         */
        private boolean useHyphens = true;
        
        /**
         * 是否转大写
         */
        private boolean useUpperCase = false;
        
        /**
         * 是否启用加密
         */
        private boolean enableEncryption = true;
        
        /**
         * 加密密钥
         */
        private String encryptionKey = "ecommerce-uuid-key";
    }
    
    /**
     * 电商数据库自增配置类
     */
    @Data
    public static class EcommerceDatabaseConfig {
        /**
         * 数据源名称
         */
        private String dataSourceName = "ecommerce";
        
        /**
         * 是否启用电商数据库自增
         */
        private boolean enableDatabase = false;
        
        /**
         * 表名
         */
        private String tableName = "ecommerce_id_generator";
        
        /**
         * 字段名
         */
        private String fieldName = "id";
        
        /**
         * 步长
         */
        private int step = 1;
        
        /**
         * 初始值
         */
        private long initialValue = 1L;
        
        /**
         * 是否启用加密
         */
        private boolean enableEncryption = true;
        
        /**
         * 加密密钥
         */
        private String encryptionKey = "ecommerce-database-key";
    }
    
    /**
     * 电商Redis配置类
     */
    @Data
    public static class EcommerceRedisConfig {
        /**
         * Redis键前缀
         */
        private String keyPrefix = "ecommerce:distributed:id:";
        
        /**
         * 是否启用电商Redis
         */
        private boolean enableRedis = false;
        
        /**
         * 过期时间（秒）
         */
        private long expireTime = 3600;
        
        /**
         * 步长
         */
        private int step = 1;
        
        /**
         * 初始值
         */
        private long initialValue = 1L;
        
        /**
         * 是否启用加密
         */
        private boolean enableEncryption = true;
        
        /**
         * 加密密钥
         */
        private String encryptionKey = "ecommerce-redis-key";
    }
    
    /**
     * 电商Zookeeper配置类
     */
    @Data
    public static class EcommerceZookeeperConfig {
        /**
         * Zookeeper连接地址
         */
        private String connectString = "localhost:2181";
        
        /**
         * 是否启用电商Zookeeper
         */
        private boolean enableZookeeper = false;
        
        /**
         * 会话超时时间（毫秒）
         */
        private int sessionTimeout = 30000;
        
        /**
         * 连接超时时间（毫秒）
         */
        private int connectionTimeout = 10000;
        
        /**
         * 根路径
         */
        private String rootPath = "/ecommerce-distributed-id";
        
        /**
         * 是否启用加密
         */
        private boolean enableEncryption = true;
        
        /**
         * 加密密钥
         */
        private String encryptionKey = "ecommerce-zookeeper-key";
    }
    
    /**
     * 业务配置类
     */
    @Data
    public static class BusinessConfig {
        /**
         * 是否启用业务隔离
         */
        private boolean enableBusinessIsolation = true;
        
        /**
         * 业务类型映射
         */
        private Map<String, String> businessTypeMapping = new HashMap<>();
        
        /**
         * 业务ID前缀
         */
        private Map<String, String> businessIdPrefix = new HashMap<>();
        
        /**
         * 业务ID长度
         */
        private Map<String, Integer> businessIdLength = new HashMap<>();
    }
    
    /**
     * 秒杀配置类
     */
    @Data
    public static class SeckillConfig {
        /**
         * 是否启用秒杀
         */
        private boolean enableSeckill = true;
        
        /**
         * 秒杀ID前缀
         */
        private String seckillIdPrefix = "SK";
        
        /**
         * 秒杀ID长度
         */
        private int seckillIdLength = 20;
        
        /**
         * 秒杀ID过期时间（秒）
         */
        private long seckillIdExpireTime = 3600;
        
        /**
         * 秒杀并发限制
         */
        private int seckillConcurrencyLimit = 10000;
    }
    
    /**
     * 库存配置类
     */
    @Data
    public static class InventoryConfig {
        /**
         * 是否启用库存管理
         */
        private boolean enableInventory = true;
        
        /**
         * 库存ID前缀
         */
        private String inventoryIdPrefix = "INV";
        
        /**
         * 库存ID长度
         */
        private int inventoryIdLength = 20;
        
        /**
         * 库存ID过期时间（秒）
         */
        private long inventoryIdExpireTime = 3600;
        
        /**
         * 库存并发限制
         */
        private int inventoryConcurrencyLimit = 10000;
    }
}

/**
 * 电商分布式ID数据模型类
 * @author Java实战
 */
@Data
@Table(name = "ecommerce_distributed_id_record")
public class EcommerceDistributedIdData {
    
    /**
     * 主键ID
     */
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "id")
    private Long id;
    
    /**
     * 电商分布式ID
     */
    @Column(name = "ecommerce_distributed_id", length = 64)
    private String ecommerceDistributedId;
    
    /**
     * ID类型
     */
    @Column(name = "id_type", length = 32)
    private String idType;
    
    /**
     * 生成器类型
     */
    @Column(name = "generator_type", length = 32)
    private String generatorType;
    
    /**
     * 业务类型
     */
    @Column(name = "business_type", length = 32)
    private String businessType;
    
    /**
     * 电商业务类型
     */
    @Column(name = "ecommerce_business_type", length = 32)
    private String ecommerceBusinessType;
    
    /**
     * 生成时间
     */
    @Column(name = "generate_time")
    private LocalDateTime generateTime;
    
    /**
     * 过期时间
     */
    @Column(name = "expire_time")
    private LocalDateTime expireTime;
    
    /**
     * 状态
     */
    @Column(name = "status", length = 20)
    private String status;
    
    /**
     * 加密状态
     */
    @Column(name = "encryption_status", length = 20)
    private String encryptionStatus;
    
    /**
     * 业务状态
     */
    @Column(name = "business_status", length = 20)
    private String businessStatus;
    
    /**
     * 秒杀状态
     */
    @Column(name = "seckill_status", length = 20)
    private String seckillStatus;
    
    /**
     * 库存状态
     */
    @Column(name = "inventory_status", length = 20)
    private String inventoryStatus;
    
    /**
     * 扩展属性（JSON格式）
     */
    @Column(name = "extended_properties", columnDefinition = "TEXT")
    private String extendedProperties;
    
    /**
     * 业务信息（JSON格式）
     */
    @Column(name = "business_info", columnDefinition = "TEXT")
    private String businessInfo;
    
    /**
     * 秒杀信息（JSON格式）
     */
    @Column(name = "seckill_info", columnDefinition = "TEXT")
    private String seckillInfo;
    
    /**
     * 库存信息（JSON格式）
     */
    @Column(name = "inventory_info", columnDefinition = "TEXT")
    private String inventoryInfo;
    
    /**
     * 创建时间
     */
    @Column(name = "create_time")
    @CreationTimestamp
    private LocalDateTime createTime;
    
    /**
     * 更新时间
     */
    @Column(name = "update_time")
    @UpdateTimestamp
    private LocalDateTime updateTime;
    
    public EcommerceDistributedIdData() {
        this.status = "ACTIVE";
        this.encryptionStatus = "ENCRYPTED";
        this.businessStatus = "PENDING";
        this.seckillStatus = "PENDING";
        this.inventoryStatus = "PENDING";
        this.generateTime = LocalDateTime.now();
    }
    
    public EcommerceDistributedIdData(String ecommerceDistributedId, String idType, String generatorType) {
        this();
        this.ecommerceDistributedId = ecommerceDistributedId;
        this.idType = idType;
        this.generatorType = generatorType;
    }
    
    /**
     * 验证电商分布式ID数据
     * @return 是否有效
     */
    public boolean validate() {
        if (ecommerceDistributedId == null || ecommerceDistributedId.isEmpty()) {
            return false;
        }
        
        if (idType == null || idType.isEmpty()) {
            return false;
        }
        
        if (generatorType == null || generatorType.isEmpty()) {
            return false;
        }
        
        if (ecommerceBusinessType == null || ecommerceBusinessType.isEmpty()) {
            return false;
        }
        
        return true;
    }
    
    /**
     * 是否过期
     * @return 是否过期
     */
    public boolean isExpired() {
        if (expireTime == null) {
            return false;
        }
        return LocalDateTime.now().isAfter(expireTime);
    }
    
    /**
     * 是否已加密
     * @return 是否已加密
     */
    public boolean isEncrypted() {
        return "ENCRYPTED".equals(this.encryptionStatus);
    }
    
    /**
     * 是否已业务处理
     * @return 是否已业务处理
     */
    public boolean isBusinessProcessed() {
        return "BUSINESS_PROCESSED".equals(this.businessStatus);
    }
    
    /**
     * 是否已秒杀处理
     * @return 是否已秒杀处理
     */
    public boolean isSeckillProcessed() {
        return "SECKILL_PROCESSED".equals(this.seckillStatus);
    }
    
    /**
     * 是否已库存处理
     * @return 是否已库存处理
     */
    public boolean isInventoryProcessed() {
        return "INVENTORY_PROCESSED".equals(this.inventoryStatus);
    }
    
    /**
     * 设置扩展属性
     * @param key 键
     * @param value 值
     */
    public void setExtendedProperty(String key, Object value) {
        Map<String, Object> properties = getExtendedPropertiesMap();
        properties.put(key, value);
        this.extendedProperties = JSON.toJSONString(properties);
    }
    
    /**
     * 获取扩展属性
     * @param key 键
     * @return 值
     */
    public Object getExtendedProperty(String key) {
        Map<String, Object> properties = getExtendedPropertiesMap();
        return properties.get(key);
    }
    
    /**
     * 获取扩展属性Map
     * @return 扩展属性Map
     */
    private Map<String, Object> getExtendedPropertiesMap() {
        if (extendedProperties == null || extendedProperties.isEmpty()) {
            return new HashMap<>();
        }
        try {
            return JSON.parseObject(extendedProperties, new TypeReference<Map<String, Object>>() {});
        } catch (Exception e) {
            return new HashMap<>();
        }
    }
    
    /**
     * 设置扩展属性Map
     * @param properties 扩展属性Map
     */
    public void setExtendedPropertiesMap(Map<String, Object> properties) {
        this.extendedProperties = JSON.toJSONString(properties);
    }
    
    /**
     * 设置业务信息
     * @param businessInfo 业务信息
     */
    public void setBusinessInfo(Map<String, Object> businessInfo) {
        this.businessInfo = JSON.toJSONString(businessInfo);
    }
    
    /**
     * 获取业务信息
     * @return 业务信息
     */
    public Map<String, Object> getBusinessInfo() {
        if (businessInfo == null || businessInfo.isEmpty()) {
            return new HashMap<>();
        }
        try {
            return JSON.parseObject(businessInfo, new TypeReference<Map<String, Object>>() {});
        } catch (Exception e) {
            return new HashMap<>();
        }
    }
    
    /**
     * 设置秒杀信息
     * @param seckillInfo 秒杀信息
     */
    public void setSeckillInfo(Map<String, Object> seckillInfo) {
        this.seckillInfo = JSON.toJSONString(seckillInfo);
    }
    
    /**
     * 获取秒杀信息
     * @return 秒杀信息
     */
    public Map<String, Object> getSeckillInfo() {
        if (seckillInfo == null || seckillInfo.isEmpty()) {
            return new HashMap<>();
        }
        try {
            return JSON.parseObject(seckillInfo, new TypeReference<Map<String, Object>>() {});
        } catch (Exception e) {
            return new HashMap<>();
        }
    }
    
    /**
     * 设置库存信息
     * @param inventoryInfo 库存信息
     */
    public void setInventoryInfo(Map<String, Object> inventoryInfo) {
        this.inventoryInfo = JSON.toJSONString(inventoryInfo);
    }
    
    /**
     * 获取库存信息
     * @return 库存信息
     */
    public Map<String, Object> getInventoryInfo() {
        if (inventoryInfo == null || inventoryInfo.isEmpty()) {
            return new HashMap<>();
        }
        try {
            return JSON.parseObject(inventoryInfo, new TypeReference<Map<String, Object>>() {});
        } catch (Exception e) {
            return new HashMap<>();
        }
    }
}

/**
 * 电商分布式ID生成结果类
 * @author Java实战
 */
@Data
public class EcommerceDistributedIdResult {
    
    /**
     * 是否成功
     */
    private boolean success;
    
    /**
     * 生成的ID
     */
    private String id;
    
    /**
     * ID类型
     */
    private String idType;
    
    /**
     * 生成器类型
     */
    private String generatorType;
    
    /**
     * 业务类型
     */
    private String businessType;
    
    /**
     * 电商业务类型
     */
    private String ecommerceBusinessType;
    
    /**
     * 生成时间
     */
    private LocalDateTime generateTime;
    
    /**
     * 错误信息
     */
    private String error;
    
    /**
     * 开始时间
     */
    private long startTime;
    
    /**
     * 结束时间
     */
    private long endTime;
    
    /**
     * 重试次数
     */
    private int retryCount;
    
    /**
     * 加密状态
     */
    private String encryptionStatus;
    
    /**
     * 业务状态
     */
    private String businessStatus;
    
    /**
     * 秒杀状态
     */
    private String seckillStatus;
    
    /**
     * 库存状态
     */
    private String inventoryStatus;
    
    /**
     * 扩展属性
     */
    private Map<String, Object> extendedProperties;
    
    /**
     * 业务信息
     */
    private Map<String, Object> businessInfo;
    
    /**
     * 秒杀信息
     */
    private Map<String, Object> seckillInfo;
    
    /**
     * 库存信息
     */
    private Map<String, Object> inventoryInfo;
    
    public EcommerceDistributedIdResult() {
        this.success = false;
        this.retryCount = 0;
        this.extendedProperties = new HashMap<>();
        this.businessInfo = new HashMap<>();
        this.seckillInfo = new HashMap<>();
        this.inventoryInfo = new HashMap<>();
        this.encryptionStatus = "ENCRYPTED";
        this.businessStatus = "PENDING";
        this.seckillStatus = "PENDING";
        this.inventoryStatus = "PENDING";
    }
    
    public EcommerceDistributedIdResult(String id, String idType, String generatorType) {
        this();
        this.id = id;
        this.idType = idType;
        this.generatorType = generatorType;
        this.generateTime = LocalDateTime.now();
    }
    
    /**
     * 获取生成耗时
     * @return 生成耗时（毫秒）
     */
    public long getDuration() {
        return endTime - startTime;
    }
    
    /**
     * 是否成功
     * @return 是否成功
     */
    public boolean isSuccess() {
        return success;
    }
    
    /**
     * 增加重试次数
     */
    public void incrementRetryCount() {
        this.retryCount++;
    }
    
    /**
     * 是否已加密
     * @return 是否已加密
     */
    public boolean isEncrypted() {
        return "ENCRYPTED".equals(this.encryptionStatus);
    }
    
    /**
     * 是否已业务处理
     * @return 是否已业务处理
     */
    public boolean isBusinessProcessed() {
        return "BUSINESS_PROCESSED".equals(this.businessStatus);
    }
    
    /**
     * 是否已秒杀处理
     * @return 是否已秒杀处理
     */
    public boolean isSeckillProcessed() {
        return "SECKILL_PROCESSED".equals(this.seckillStatus);
    }
    
    /**
     * 是否已库存处理
     * @return 是否已库存处理
     */
    public boolean isInventoryProcessed() {
        return "INVENTORY_PROCESSED".equals(this.inventoryStatus);
    }
}

/**
 * 电商分布式ID状态信息类
 * @author Java实战
 */
@Data
public class EcommerceDistributedIdStatus {
    
    /**
     * 总生成数
     */
    private long totalGenerated;
    
    /**
     * 成功生成数
     */
    private long successGenerated;
    
    /**
     * 失败生成数
     */
    private long failureGenerated;
    
    /**
     * 重试生成数
     */
    private long retryGenerated;
    
    /**
     * 加密生成数
     */
    private long encryptedGenerated;
    
    /**
     * 业务处理数
     */
    private long businessProcessed;
    
    /**
     * 秒杀处理数
     */
    private long seckillProcessed;
    
    /**
     * 库存处理数
     */
    private long inventoryProcessed;
    
    /**
     * 成功率
     */
    private double successRate;
    
    /**
     * 失败率
     */
    private double failureRate;
    
    /**
     * 重试率
     */
    private double retryRate;
    
    /**
     * 加密率
     */
    private double encryptionRate;
    
    /**
     * 业务处理率
     */
    private double businessProcessRate;
    
    /**
     * 秒杀处理率
     */
    private double seckillProcessRate;
    
    /**
     * 库存处理率
     */
    private double inventoryProcessRate;
    
    /**
     * 平均生成时间（毫秒）
     */
    private double averageGenerateTime;
    
    /**
     * 最大生成时间（毫秒）
     */
    private long maxGenerateTime;
    
    /**
     * 最小生成时间（毫秒）
     */
    private long minGenerateTime;
    
    /**
     * 最后检查时间
     */
    private Long lastCheckTime;
    
    /**
     * 系统状态
     */
    private String systemStatus;
    
    /**
     * 各生成器状态
     */
    private Map<String, EcommerceGeneratorStatus> generatorStatuses;
    
    public EcommerceDistributedIdStatus() {
        this.lastCheckTime = System.currentTimeMillis();
        this.systemStatus = "HEALTHY";
        this.generatorStatuses = new HashMap<>();
    }
    
    /**
     * 计算成功率
     * @return 成功率
     */
    public double calculateSuccessRate() {
        if (totalGenerated > 0) {
            return (double) successGenerated / totalGenerated;
        }
        return 0.0;
    }
    
    /**
     * 计算失败率
     * @return 失败率
     */
    public double calculateFailureRate() {
        if (totalGenerated > 0) {
            return (double) failureGenerated / totalGenerated;
        }
        return 0.0;
    }
    
    /**
     * 计算重试率
     * @return 重试率
     */
    public double calculateRetryRate() {
        if (totalGenerated > 0) {
            return (double) retryGenerated / totalGenerated;
        }
        return 0.0;
    }
    
    /**
     * 计算加密率
     * @return 加密率
     */
    public double calculateEncryptionRate() {
        if (totalGenerated > 0) {
            return (double) encryptedGenerated / totalGenerated;
        }
        return 0.0;
    }
    
    /**
     * 计算业务处理率
     * @return 业务处理率
     */
    public double calculateBusinessProcessRate() {
        if (totalGenerated > 0) {
            return (double) businessProcessed / totalGenerated;
        }
        return 0.0;
    }
    
    /**
     * 计算秒杀处理率
     * @return 秒杀处理率
     */
    public double calculateSeckillProcessRate() {
        if (totalGenerated > 0) {
            return (double) seckillProcessed / totalGenerated;
        }
        return 0.0;
    }
    
    /**
     * 计算库存处理率
     * @return 库存处理率
     */
    public double calculateInventoryProcessRate() {
        if (totalGenerated > 0) {
            return (double) inventoryProcessed / totalGenerated;
        }
        return 0.0;
    }
    
    /**
     * 是否健康
     * @return 是否健康
     */
    public boolean isHealthy() {
        return successRate >= 0.999 && failureRate <= 0.001 && 
               encryptionRate >= 0.999 && businessProcessRate >= 0.999 && 
               seckillProcessRate >= 0.999 && inventoryProcessRate >= 0.999;
    }
}

/**
 * 电商生成器状态类
 * @author Java实战
 */
@Data
public class EcommerceGeneratorStatus {
    
    /**
     * 生成器类型
     */
    private String generatorType;
    
    /**
     * 总生成数
     */
    private long totalGenerated;
    
    /**
     * 成功生成数
     */
    private long successGenerated;
    
    /**
     * 失败生成数
     */
    private long failureGenerated;
    
    /**
     * 加密生成数
     */
    private long encryptedGenerated;
    
    /**
     * 业务处理数
     */
    private long businessProcessed;
    
    /**
     * 秒杀处理数
     */
    private long seckillProcessed;
    
    /**
     * 库存处理数
     */
    private long inventoryProcessed;
    
    /**
     * 平均生成时间（毫秒）
     */
    private double averageGenerateTime;
    
    /**
     * 最后生成时间
     */
    private LocalDateTime lastGenerateTime;
    
    /**
     * 生成器状态
     */
    private String status;
    
    public EcommerceGeneratorStatus() {
        this.status = "ACTIVE";
    }
    
    public EcommerceGeneratorStatus(String generatorType) {
        this();
        this.generatorType = generatorType;
    }
    
    /**
     * 计算成功率
     * @return 成功率
     */
    public double calculateSuccessRate() {
        if (totalGenerated > 0) {
            return (double) successGenerated / totalGenerated;
        }
        return 0.0;
    }
    
    /**
     * 计算加密率
     * @return 加密率
     */
    public double calculateEncryptionRate() {
        if (totalGenerated > 0) {
            return (double) encryptedGenerated / totalGenerated;
        }
        return 0.0;
    }
    
    /**
     * 计算业务处理率
     * @return 业务处理率
     */
    public double calculateBusinessProcessRate() {
        if (totalGenerated > 0) {
            return (double) businessProcessed / totalGenerated;
        }
        return 0.0;
    }
    
    /**
     * 计算秒杀处理率
     * @return 秒杀处理率
     */
    public double calculateSeckillProcessRate() {
        if (totalGenerated > 0) {
            return (double) seckillProcessed / totalGenerated;
        }
        return 0.0;
    }
    
    /**
     * 计算库存处理率
     * @return 库存处理率
     */
    public double calculateInventoryProcessRate() {
        if (totalGenerated > 0) {
            return (double) inventoryProcessed / totalGenerated;
        }
        return 0.0;
    }
    
    /**
     * 是否健康
     * @return 是否健康
     */
    public boolean isHealthy() {
        return calculateSuccessRate() >= 0.999 && 
               calculateEncryptionRate() >= 0.999 && 
               calculateBusinessProcessRate() >= 0.999 && 
               calculateSeckillProcessRate() >= 0.999 && 
               calculateInventoryProcessRate() >= 0.999;
    }
}