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
    }
    
    
}