package com.fang.server.schedule;

import java.util.TimerTask;

import com.fang.common.core.FTask;
import com.fang.common.core.StatusChangeEvent;
import com.fang.server.net.StatusChangeSender;

public class TaskThread extends TimerTask {
    private FTask task;
	
	public TaskThread (FTask task){
		this.task=task;
	}

	public void run() {
		        
		StatusChangeEvent event=new StatusChangeEvent();
		event.setTaskid(task.getId());
		event.setTask_status(StatusChangeEvent.RUNING);
		StatusChangeSender.sendStatusChange(event);
		
        if(CMDRunner.exec(task)){
        	event.setTask_status(StatusChangeEvent.SUCCESS);
        	
        }else {
        	event.setTask_status(StatusChangeEvent.FAILED);
        }		
        StatusChangeSender.sendStatusChange(event);
	}
	
}