package com.qianwen.mdc.collect.handler;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import com.qianwen.mdc.collect.dto.PackedTelemetryData;
|
import com.qianwen.mdc.collect.entity.iotdb.Output;
|
import com.qianwen.mdc.collect.service.OutputAggregateService;
|
|
@Component
|
public class OutputDataHandler implements TelemetryDataHandler {
|
private static final Logger log = LoggerFactory.getLogger(OutputDataHandler.class);
|
@Autowired
|
private OutputAggregateService outputAggregateService;
|
@Override
|
public void handleData(PackedTelemetryData packedData) {
|
|
Output output = new Output();
|
output.setCalendarCode(packedData.getCalendarCode());
|
output.setFactoryYear(packedData.getFactoryYear());
|
output.setFactoryMonth(packedData.getFactoryMonth());
|
output.setFactoryWeek(packedData.getFactoryWeek());
|
output.setFactoryDate(packedData.getFactoryDate());
|
output.setIsSync(false);
|
output.setParamType(packedData.getParamType());
|
output.setShiftIndex(packedData.getShiftIndex());
|
output.setShiftTimeType(packedData.getShiftTimeType());
|
output.setTime(packedData.getTime());
|
output.setValueCollect(Long.parseLong(packedData.getValue()));
|
output.setWorkstationId(packedData.getWorkstationId());
|
/*
|
WorkstationOutput workstationOutput = TelemetryOutputWrapper.build().entityVO(data);
|
IOutputAggregateService outputAggregateService = (IOutputAggregateService) SpringUtil.getBean(IOutputAggregateService.class);
|
outputAggregateService.outputRealTimeAggregate(workstationOutput);
|
*/
|
outputAggregateService.outputRealTimeAggregate(output);
|
log.info("产量实时聚合完成:数据{} ",output);//, workstationOutput
|
}
|
|
|
}
|
