Enfocus Community

Code: Select all

// Is invoked each time a new job arrives in one of the input folders for the flow element.
// The newly arrived job is passed as the second parameter.
function jobArrived( s : Switch, job : Job )
{	
	
/*
<?xml version="1.0" encoding="UTF-8"?>
<JMF xmlns="http://www.CIP4.org/JDFSchema_1_1" SenderID="Switch Send JMF" TimeStamp="2015-05-18T13:51:16" Version="1.4">
  <Command ID="qid1431949876717" Type="SubmitQueueEntry">
    <QueueSubmissionParams URL="http://appl01:8083/jdf/Switch/Switch.jdf" ReturnJMF="http://appl01:8083/jmf"/>
  </Command>
</JMF>
*/
	//Create JMF XML	
	jmfTempLoc = s.createPathWithName(job.getVariableAsString("[Job.NameProper]") + ".jmf");
	var jmfDoc = new Document();
	//Create map for various namespaces
	var jdfMap = jmfDoc.createEmptyMap();
	jdfMap.put("","http://www.CIP4.org/JDFSchema_1_1");
	
	var jmfElem = jmfDoc.createElement("JMF", jdfMap);
	jmfDoc.setDocumentElement(jmfElem);
	jmfElem.addAttribute("xmlns", jdfMap, "http://www.CIP4.org/JDFSchema_1_1");
	jmfElem.addAttribute("SenderID", jdfMap, "Switch Send JMF");
	var time = new Date();
	jmfElem.addAttribute("TimeStamp", jdfMap, time.toString());
	jmfElem.addAttribute("Version", jdfMap, "1.4");
	
	var queryElem = jmfDoc.createElement("Command");
	var queryID = "qid" + time.getTime().toString();
	queryElem.addAttribute("ID", jdfMap, queryID);
	jmfElem.appendChild(queryElem);
	
	queryElem.addAttribute("Type", jdfMap, "SubmitQueueEntry");

	var statusQuParamsElem = jmfDoc.createElement("QueueSubmissionParams");	
	queryElem.appendChild(statusQuParamsElem);
	statusQuParamsElem.addAttribute("URL", null,"http://appl01:8083/jdf/Switch/" + job.getVariableAsString("[Job.Name]"));
	statusQuParamsElem.addAttribute("ReturnJMF", null, "http://appl01:8083/jmf");
	
	jmfDoc.save(jmfTempLoc);
	
	s.copy(job.getPath(), "\\\\appl01\\JDF\\JDFPickup\\Switch\\" + job.getVariableAsString("[Job.Name]"));
			
	var jobJMF = s.createNewJob();	
	
	//Setup http method for sending JMF message and collecting response	
	var httpClient = new HTTP();
	httpClient.url = "http://hpprocenter:8080/jmf/HPProCenter";
	httpClient.setAttachedFile(jmfTempLoc);
	var responsePath = jobJMF.createPathWithName(job.getVariableAsString("[Job.NameProper]") + ".xml");
	httpClient.setLocalFilePath(responsePath);
	httpClient.addHeader("Content-Type", "application/vnd.cip4-jmf+xml");
	httpClient.addHeader("charset", "UTF-8");
	httpClient.post();
	
	while (!httpClient.waitForFinished( 1 )) {
	//no need to sleep here, the 1 in the waitForFinished function sets the delay time (in seconds)
	//You could send log updates here to show progress if needed or check against a timeout value.
	}
	if (httpClient.finishedStatus == HTTP.Ok){
		s.log(1, "HTTP response was: " + httpClient.statusDescription + " with additional messages: " + httpClient.lastError);
		jobJMF.sendToData(1, responsePath);
		job.sendToData(1, job.getPath());
		job.sendToData(1, jmfTempLoc);
	}
	else {
		s.log(2, "Issue with JMF query. HTTP Status = " + httpClient.finishedStatus + " Last Error = " + httpClient.lastError );
		jobJMF.sendToData(3, responsePath);
		job.sendToData(3, job.getPath());
		job.sendToData(3, jmfTempLoc);
	}
//	job.sendToSingle(jmfTempLoc);
//	job.sendToSingle(job.getPath());
}