package com.qianwen.mdc.collect.handler; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Component; import com.qianwen.mdc.collect.dto.PackedTelemetryData; @Component public class CountDataHandler implements TelemetryDataHandler { private static final Logger log = LoggerFactory.getLogger(CountDataHandler.class); @Override public void handleData(PackedTelemetryData data) { /* WorkstationOutput workstationOutput = TelemetryOutputWrapper.build().entityVO(data); IOutputAggregateService outputAggregateService = (IOutputAggregateService) SpringUtil.getBean(IOutputAggregateService.class); outputAggregateService.outputRealTimeAggregate(workstationOutput); */ //log.info("产量 实时聚合完成:数据{} ", workstationOutput); } }