zl-opd-gather/src/main/java/com/hb/proj/gather/business/DataTransRepTask.java

package com.hb.proj.gather.business;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.hb.proj.gather.model.DiagramPO;
import com.hb.proj.gather.model.WellParamVO;
import com.hb.proj.gather.rep.GatherDataRepService;
import com.hb.xframework.util.ApplicationContextUtils;

public class DataTransRepTask implements Runnable{
	
	private final static  Logger logger = LoggerFactory.getLogger(DataTransRepTask.class);

	private DiagramPO  diagramPO;
	
	public DataTransRepTask(DiagramPO  diagramPO) {
		this.diagramPO=diagramPO;
	}
	
	
	@Override
	public void run() {
		logger.info("开始数据转换处理{}",diagramPO.getDevSerial());
		WellParamVO paramConfig=DataTransConfig.get(diagramPO.getDevSerial()+"_"+diagramPO.getParamCode());
		if(paramConfig==null) {
			logger.info("未找到参数配置{}_{}",diagramPO.getDevSerial(),diagramPO.getParamCode());
			return;
		}
		
		
		
		DataTransUtils.transMulti(diagramPO, paramConfig); //数据转换
		
		logger.info("数据转换完：{}",diagramPO.getParamCode());
		
		GatherDataRepService repService=ApplicationContextUtils.getBean("gatherDataRepService", GatherDataRepService.class);
		
		repService.save(diagramPO);  //入库
	}

}