package com.dy.rtuMw.server.rtuData;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import java.text.ParseException;

/**
 * 部分实现Task
 */
public abstract class TaskSurpport implements Task {

	private static final Logger log = LogManager.getLogger(TaskSurpport.class.getName()) ;
	
	//当前所处理的上行数据所属RTU的地址
	//public String rtuAddr_inRootTk ;//只在根root任务对象上会付此值
	//本节点配置
	protected TaskConfig conf ;
	//根任务
	protected TaskSurpport root ;
	//本任务的子任务
	protected TaskSurpport[] subTasks ;
	//本任务的处理结果
	protected Object[] taskResult ;

	/**
	 * 执行节点任务
	 * @param data 需要处理的数据
	 */
	@Override
	public abstract void execute(Object data) throws ParseException;
	
	/**
	 * 任务采用对象池，以便重用任务对象，
	 * 重用前要进行对象初始化，清除上次执行任务时遗留的对象属性数据
	 * 初始化本任务及所有子任务
	 */
	@Override
	public void cleanMeAndSubs() {
		//rtuAddr_inRootTk = null ;
		taskResult = null ;
		if(this.subTasks != null && this.subTasks.length > 0){
			for(int i = 0 ; i < this.subTasks.length; i++){
				this.subTasks[i].cleanMeAndSubs() ;
			}
		}
	}
	
	/**
	 * 得到本任务节点处理产生的中间结果，以供本节点所在树枝的下级任务节点及本树枝的左侧（根在上）所有树枝的节点应用本结果
	 * @return
	 */
	@Override
	public Object[] getMyResults(){
		return taskResult ;
	}
	
	/**
	 * 得到指定任务节点处理产生的中间结果，以供本节点所在树枝的下级任务节点及本树枝的左侧（根在上）所有树枝的节点应用本结果
	 * @param id 指定任务ID
	 * @return
	 */
	public Object[] getTaskResults(String id){
		if(root != null){
			return this.getTaskResults(root, id) ;
		}
		return null ;
	}
	private Object[] getTaskResults(TaskSurpport task, String id){ 
		if(task != null && task.conf != null && task.conf.id != null && task.conf.id.equals(id)){
			return task.getMyResults() ;
		}else{
			if(task.subTasks != null && task.subTasks.length > 0){
				Object[] rs = null ;
				for(int i = 0 ; i < task.subTasks.length; i++){
					rs = getTaskResults(task.subTasks[i], id) ;
					if(rs != null){
						return rs ;
					}
				}
			}
		}
		return null ;
	}

	/**
	 * 转下级任务节点处理，首先要实体化所有子节点。
	 * @param data 需要处理的数据
	 */
	@Override
	public void toNextTasks(Object data) {
		try {
			if(subTasks != null && subTasks.length > 0){
				for(int i = 0 ; i < subTasks.length ; i++){
					if(subTasks[i].conf.enable){
						subTasks[i].execute(data) ;
					}else{
						//本节点不起作用，直接进入本节的子节点
						subTasks[i].toNextTasks(data) ;
					}
				}
			}
		} catch (Exception e) {
			log.error("向下级任务传递工作时出错，" , e);
		}finally{
		}
	}

	/**
	 * 转下级某个任务节点处理 
	 * @param data 需要处理的数据
	 * @param id 指定任务ID
	 */
	public void toNextOneTask(Object data, String id){
		try {
			if(subTasks != null && subTasks.length > 0){
				for(int i = 0 ; i < subTasks.length ; i++){
					if(subTasks[i].conf.id.equals(id)){
						if(subTasks[i].conf.enable){
							subTasks[i].execute(data) ;
						}else{
							//本节点不起作用，直接进入本节的子节点
							subTasks[i].toNextTasks(data) ;
						}
					}
				}
			}
		} catch (Exception e) {
			log.error("向指定子任务（" + id + "）传递任务时出错，" , e);
		}finally{
		}
	}

}