@startuml
title 数据集成服务类图

' 数据获取器
class ApiDataFetcher {
  - apiEndpoint: String
  + fetchApiData(String url)
  + configureApiEndpoint(String endpoint)
}
class KafkaDataFetcher {
  - kafkaBroker: String
  - groupId: String
  + fetchKafkaData(String topic)
  + configureKafka(String broker, String groupId)
}

' 抽象处理器
abstract class Handler {
  - dataFetcher: DataFetcher
  - dataCache: List<DataModel>
  + fetchData(): List<DataModel>
  + processData(List<DataModel> data): void
  + validateData(DataModel data): boolean
}

' 具体处理器
class AwarenessHandler
class NetworkHandler
class DcimHandler
class CloudHandler
class MonitoringHandler
class CDOSHandler

' 数据集成服务
class IntegrationService {
  - handlers: List<Handler>
  + DataIntegrate()
  + registerHandler(Handler handler): void
  + scheduleIntegration(): void
  + generateReport(): String
}

' 数据库服务
class DatabaseService {
  + saveData(data: List<DataModel>)
  + queryData(String condition): List<DataModel>
  + deleteData(String condition): void
  + updateData(DataModel newData): void
}

' 数据模型
class DataModel {
  + id: int
  + name: String
  + value: String
  + timestamp: String
  + source: String
}

' 继承关系
Handler <|-- AwarenessHandler
Handler <|-- NetworkHandler
Handler <|-- DcimHandler
Handler <|-- CloudHandler
Handler <|-- MonitoringHandler
Handler <|-- CDOSHandler

' 依赖关系
Handler --> ApiDataFetcher : uses
Handler --> KafkaDataFetcher : uses
IntegrationService --> Handler : uses
IntegrationService --> DatabaseService : stores
DatabaseService --> DataModel : saves

@enduml