sis/realtime/datatraining-server-cph-jn/src/main/java/com/gyee/datatraining/task/ThreadPoolTask5.java

package com.gyee.datatraining.task;

import java.io.Serializable;
import java.util.List;
import java.util.concurrent.Callable;

import com.gyee.datatraining.model.auto.Windpowerstation;
import com.gyee.datatraining.model.auto.Windturbine;
import com.gyee.datatraining.util.dd.LstmModelWt;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class ThreadPoolTask5 implements Callable<String>, Serializable {

	private Logger logger = LoggerFactory.getLogger(this.getClass());
	private static final long serialVersionUID = 0;
	private String unicode4hour="JKYC001"; 
	private String unicode1day="JKYC006"; 
	private String unicode3day="JKYC011"; 
	private String unicode7day="JKYC016"; 
	private String unicode1month="JKYC021"; 
	// 保存任务所需要的数据

	private Object threadPoolTaskData;
	private List<Windturbine> wtls;
	private LstmModelWt lstmModelWt;
	private Windpowerstation wp;

	public ThreadPoolTask5(Object tasks,List<Windturbine> wtls,Windpowerstation wp,LstmModelWt lstmModelWt) {

		this.threadPoolTaskData = tasks;
		this.wtls = wtls;
		this.wp = wp;
		this.lstmModelWt = lstmModelWt;
	}

	public synchronized String call() throws Exception {

		
		// 处理一个任务，这里的处理方式太简单了，仅仅是一个打印语句

		//System.out.println("开始执行任务：" + threadPoolTaskData);

		String result = "";

		// //便于观察，等待一段时间

		

		try {
			for(Windturbine wt:wtls)
			{
				lstmModelWt.castDataBy1Month(wt.getId(), unicode1month);
				logger.info(wt.getId()+"风机未来1个月数据保存成功！");

			}
//			if (StringUtils.notEmp(vo)) {
//								
//				lstmModelWt.castDataBy1Month(wt.getId(),unicode1month,vo.getMultiLayerNetwork(), vo.getMaxvalues(), vo.getMinvalues());
//				logger.info(wt.getId()+"风机未来1个月数据保存成功！");
//			}

		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		threadPoolTaskData = null;

		return result;

	}

}