package com.c2kernel.gui.lifecycle.desc;

import java.io.BufferedWriter;
import java.io.File;

import javax.swing.JOptionPane;
import javax.swing.JPanel;

import com.c2kernel.common.ObjectNotFoundException;
import com.c2kernel.entity.agent.Job;
import com.c2kernel.entity.proxy.ItemProxy;
import com.c2kernel.graph.model.GraphableVertex;
import com.c2kernel.gui.MainFrame;
import com.c2kernel.gui.graph.view.VertexPropertyPanel;
import com.c2kernel.gui.tabs.outcome.InvalidOutcomeException;
import com.c2kernel.gui.tabs.outcome.InvalidSchemaException;
import com.c2kernel.gui.tabs.outcome.OutcomeException;
import com.c2kernel.gui.tabs.outcome.OutcomeHandler;
import com.c2kernel.gui.tabs.outcome.OutcomeNotInitialisedException;
import com.c2kernel.lifecycle.ActivityDef;
import com.c2kernel.lifecycle.ActivitySlotDef;
import com.c2kernel.lifecycle.CompositeActivityDef;
import com.c2kernel.persistency.ClusterStorage;
import com.c2kernel.persistency.outcome.Viewpoint;
import com.c2kernel.process.Gateway;
import com.c2kernel.utils.FileStringUtility;
import com.c2kernel.utils.LocalObjectLoader;
import com.c2kernel.utils.Logger;

/**************************************************************************
 *
 * $Revision: 1.5 $
 * $Date: 2005/10/05 07:39:37 $
 *
 * Copyright (C) 2003 CERN - European Organization for Nuclear Research
 * All rights reserved.
 **************************************************************************/

public class ElemActDefOutcomeHandler extends VertexPropertyPanel implements OutcomeHandler {

    ActivityDef act;
    boolean unsaved;
    public ElemActDefOutcomeHandler() {
        super();
        createLayout(null);
    }

    /**
     *
     */
    @Override
	public void setOutcome(String outcome) throws InvalidOutcomeException {
        try {
            act = (ActivityDef)Gateway.getMarshaller().unmarshall(outcome);
            setVertex(act);
        } catch (Exception ex) {
            Logger.error(ex);
            throw new InvalidOutcomeException();
        }
    }

    /**
     *
     */
    @Override
	public void setDescription(String description)
            throws InvalidSchemaException {
        // ignore
    }

    /**
     *
     */
    @Override
	public void setReadOnly(boolean readOnly) {
        setEditable(!readOnly);

    }

    /**
     *
     */
    @Override
	public JPanel getPanel() throws OutcomeNotInitialisedException {
        return this;
    }

    /**
     *
     */
    @Override
	public String getOutcome() throws OutcomeException {
        try {
            return Gateway.getMarshaller().marshall(act);
        } catch (Exception ex) {
            Logger.error(ex);
            throw new OutcomeException();
        }
    }

    /**
     *
     */
    @Override
	public void run() {
        validate();
    }

    @Override
	public boolean isUnsaved() {
        return unsaved;
    }

    @Override
	public void saved() {
        unsaved = false;
    }

	@Override
	public void export(File targetFile) throws Exception {
		exportAct(targetFile.getParentFile(), null, act);
	}

	public static void exportAct(File dir, BufferedWriter imports, ActivityDef actDef) throws Exception {
		
		// Export associated schema
		exportSchema((String)actDef.getProperties().get("SchemaType"), actDef.getProperties().get("SchemaVersion"), imports, new File(dir, "OD"));
		// Export associated script
		exportScript((String)actDef.getProperties().get("ScriptName"), actDef.getProperties().get("ScriptVersion"), imports, new File(dir, "SC"));

		//Export child act if composite
		if (actDef instanceof CompositeActivityDef) {
			CompositeActivityDef compActDef = (CompositeActivityDef)actDef;
			for (int i=0; i<compActDef.getChildren().length; i++) { // export slot defined scripts and schemas
				GraphableVertex vert = compActDef.getChildren()[i];
				exportScript((String)vert.getProperties().get("ScriptName"), actDef.getProperties().get("ScriptVersion"), imports, new File(dir, "SC"));
				exportScript((String)vert.getProperties().get("RoutingScriptName"), actDef.getProperties().get("RoutingScriptVersion"), imports, new File(dir, "SC"));
				exportSchema((String)vert.getProperties().get("SchemaType"), actDef.getProperties().get("SchemaVersion"), imports, new File(dir, "OD"));
			}
			GraphableVertex[] childDefs = compActDef.getLayoutableChildren();
			for (GraphableVertex childDef : childDefs) {
				if (childDef instanceof ActivitySlotDef) {
					if ("last".equals(childDef.getProperties().get("Version"))) {
						resolveRealVersion((ActivitySlotDef)childDef);
					}
					exportAct(dir, imports, ((ActivitySlotDef)childDef).getTheActivityDef());
				}
			}
			// export marshalled compAct
			FileStringUtility.string2File(new File(new File(dir, "CA"), compActDef.getActName()+".xml"), Gateway.getMarshaller().marshall(compActDef));
			if (imports!=null) {
				imports.write("<Resource name=\""+compActDef.getActName()+"\" "+(compActDef.getVersion()==-1?"":"version=\""+compActDef.getVersion()+"\" ")+"type=\"CA\">boot/CA/"+compActDef.getActName()+".xml</Resource>\n");
			}
		}
		else {
			FileStringUtility.string2File(new File(new File(dir, "EA"), actDef.getActName()+".xml"), Gateway.getMarshaller().marshall(actDef));
			if (imports!=null) imports.write("<Resource name=\""+actDef.getActName()+"\" "+(actDef.getVersion()==-1?"":"version=\""+actDef.getVersion()+"\" ")+"type=\"EA\">boot/EA/"+actDef.getActName()+".xml</Resource>\n");
		}
	}

	private static void resolveRealVersion(ActivitySlotDef childDef) throws ObjectNotFoundException {
		String defName = childDef.getActName();
		ItemProxy actDefItem = LocalObjectLoader.loadLocalObjectDef("/desc/ActivityDesc/", defName);
		String actType = actDefItem.getProperty("Complexity");
		Viewpoint last = actDefItem.getViewpoint( actType + "ActivityDef", "last");
		String[] viewpoints = actDefItem.getContents(ClusterStorage.VIEWPOINT+"/"+actType + "ActivityDef");
		for (String viewName : viewpoints) {
			try {
				Integer.parseInt(viewName);
			} catch (NumberFormatException e) {
				continue; // only count integer viewnames
			}
			Viewpoint thisView = actDefItem.getViewpoint(actType + "ActivityDef", viewName);
			if (thisView.getEventId() == last.getEventId()) {
				JOptionPane.showMessageDialog(null, defName+" defined as 'last'. Will use view "+viewName+" instead");
				childDef.getProperties().put("Version", viewName);
				return;
			}
		}
		JOptionPane.showMessageDialog(null, "Last view for "+defName+" has not been materialized. Executing CreateFromLast");
		try {
			Job createJob = actDefItem.getJobByName("AssignNewActivityVersionFromLast", MainFrame.userAgent);
			MainFrame.userAgent.execute(createJob);
		} catch (Exception e) {
			Logger.error(e);
			throw new ObjectNotFoundException("Could not create new version of "+defName+" from last", "");
		}
		resolveRealVersion(childDef);
	}

	public static void exportScript(String name, Object version, BufferedWriter imports, File dir) {
		if (name == null || name.length()==0 || name.contains(":")) return;
		try {
			int intVersion;
			if (version instanceof String) intVersion = Integer.parseInt((String)version);
			else if (version instanceof Integer) intVersion = ((Integer)version).intValue();
			else return;

			FileStringUtility.string2File(new File(dir, name+".xml"),
			LocalObjectLoader.getScript(name, intVersion));
			if (imports!=null) imports.write("<Resource name=\""+name+"\" "+(version==null?"":"version=\""+version+"\" ")+"type=\"SC\">boot/SC/"+name+".xml</Resource>\n");
		} catch (NumberFormatException ex) {
			JOptionPane.showMessageDialog(null, "Invalid version number in script version:"+version);
		} catch (Exception ex) {
			Logger.error(ex);
			JOptionPane.showMessageDialog(null, "Could not export script "+name+"_"+version, "Error", JOptionPane.ERROR_MESSAGE);
		}
	}

	public static void exportSchema(String name, Object version, BufferedWriter imports, File dir) {
		if (name == null || name.length()==0) return;
		try {
			int intVersion;
			if (version instanceof String) intVersion = Integer.parseInt((String)version);
			else if (version instanceof Integer) intVersion = ((Integer)version).intValue();
			else return;
			FileStringUtility.string2File(new File(dir, name+".xsd"),
			LocalObjectLoader.getSchema(name, intVersion).schema);
			if (imports!=null) imports.write("<Resource name=\""+name+"\" "+(version==null?"":"version=\""+version+"\" ")+"type=\"OD\">boot/OD/"+name+".xsd</Resource>\n");
		} catch (NumberFormatException ex) {
			JOptionPane.showMessageDialog(null, "Invalid version number in script version:"+version);
		} catch (Exception ex) {
			Logger.error(ex);
			JOptionPane.showMessageDialog(null, "Could not export schema "+name+"_"+version, "Error", JOptionPane.ERROR_MESSAGE);
		}
	}
}