();
attachments_tSendMail_1.add(context.CTX_PRM_FichierLogs);
contentTransferEncoding_tSendMail_1.add("DEFAULT");
attachments_tSendMail_1.add(context.CTX_PRM_ArchiveLogs);
contentTransferEncoding_tSendMail_1.add("DEFAULT");
String message_tSendMail_1 = (("Bonjour,
\n\nL'alimentation GALAXIE TALEND est désormais terminée avec succès.
\nVeuillez trouver ci-joint l'archive des logs applicatifs rassemblant les différentes informations et éventuellement les erreurs rencontrées durant l'alimentation.\n
\n\n\n \n \n | L'état d'exécution des JOBs d'import | \n
\n \n \n \n | CEV Clients | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES")).get("CEV_CLIENTS")
+ " | \n
\n \n | CEV Chéque | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES"))
.get("CEV_CHEQUE_FID")
+ " | \n
\n \n | CEV Transactions | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES"))
.get("CEV_CHEQUE_FID")
+ " | \n
\n \n | RSERVIT Clients | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES"))
.get("RESERVIT_CLIENTS")
+ " | \n
\n \n | RSERVIT Resas | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES")).get("RESERVIT_RESA")
+ " | \n
\n \n | RESERVIT Dossier | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES"))
.get("RESERVIT_DOSSIER")
+ " | \n
\n \n | MKG Olakala | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES")).get("MKG_OLAKALA") + " | \n
\n \n
\n\nCordialement,\n
") == null || ""
.equals("Bonjour,
\n\nL'alimentation GALAXIE TALEND est désormais terminée avec succès.
\nVeuillez trouver ci-joint l'archive des logs applicatifs rassemblant les différentes informations et éventuellement les erreurs rencontrées durant l'alimentation.\n
\n\n\n \n \n | L'état d'exécution des JOBs d'import | \n
\n \n \n \n | CEV Clients | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES"))
.get("CEV_CLIENTS")
+ " | \n
\n \n | CEV Chéque | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES"))
.get("CEV_CHEQUE_FID")
+ " | \n
\n \n | CEV Transactions | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES"))
.get("CEV_CHEQUE_FID")
+ " | \n
\n \n | RSERVIT Clients | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES"))
.get("RESERVIT_CLIENTS")
+ " | \n
\n \n | RSERVIT Resas | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES"))
.get("RESERVIT_RESA")
+ " | \n
\n \n | RESERVIT Dossier | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES"))
.get("RESERVIT_DOSSIER")
+ " | \n
\n \n | MKG Olakala | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES"))
.get("MKG_OLAKALA")
+ " | \n
\n \n
\n\nCordialement,\n
")) ? "\"\""
: ("Bonjour,
\n\nL'alimentation GALAXIE TALEND est désormais terminée avec succès.
\nVeuillez trouver ci-joint l'archive des logs applicatifs rassemblant les différentes informations et éventuellement les erreurs rencontrées durant l'alimentation.\n
\n\n\n \n \n | L'état d'exécution des JOBs d'import | \n
\n \n \n \n | CEV Clients | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES"))
.get("CEV_CLIENTS")
+ " | \n
\n \n | CEV Chéque | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES"))
.get("CEV_CHEQUE_FID")
+ " | \n
\n \n | CEV Transactions | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES"))
.get("CEV_CHEQUE_FID")
+ " | \n
\n \n | RSERVIT Clients | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES"))
.get("RESERVIT_CLIENTS")
+ " | \n
\n \n | RSERVIT Resas | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES"))
.get("RESERVIT_RESA")
+ " | \n
\n \n | RESERVIT Dossier | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES"))
.get("RESERVIT_DOSSIER")
+ " | \n
\n \n | MKG Olakala | \n | \n "
+ (String) ((java.util.Map) globalMap
.get("SharedMap_EXE_RES"))
.get("MKG_OLAKALA") + " | \n
\n \n
\n\nCordialement,\n
");
java.util.Properties props_tSendMail_1 = System.getProperties();
props_tSendMail_1.put("mail.smtp.host", smtpHost_tSendMail_1);
props_tSendMail_1.put("mail.smtp.port", smtpPort_tSendMail_1);
props_tSendMail_1.put("mail.mime.encodefilename", "true");
try {
props_tSendMail_1.put("mail.smtp.auth", "false");
javax.mail.Session session_tSendMail_1 = javax.mail.Session
.getInstance(props_tSendMail_1, null);
javax.mail.Message msg_tSendMail_1 = new javax.mail.internet.MimeMessage(
session_tSendMail_1);
msg_tSendMail_1
.setFrom(new javax.mail.internet.InternetAddress(
from_tSendMail_1, null));
msg_tSendMail_1.setRecipients(
javax.mail.Message.RecipientType.TO,
javax.mail.internet.InternetAddress.parse(
to_tSendMail_1, false));
if (cc_tSendMail_1 != null)
msg_tSendMail_1.setRecipients(
javax.mail.Message.RecipientType.CC,
javax.mail.internet.InternetAddress.parse(
cc_tSendMail_1, false));
if (bcc_tSendMail_1 != null)
msg_tSendMail_1.setRecipients(
javax.mail.Message.RecipientType.BCC,
javax.mail.internet.InternetAddress.parse(
bcc_tSendMail_1, false));
msg_tSendMail_1.setSubject(subject_tSendMail_1);
for (int i_tSendMail_1 = 0; i_tSendMail_1 < headers_tSendMail_1
.size(); i_tSendMail_1++) {
java.util.Map header_tSendMail_1 = headers_tSendMail_1
.get(i_tSendMail_1);
msg_tSendMail_1.setHeader(
header_tSendMail_1.get("KEY"),
header_tSendMail_1.get("VALUE"));
}
msg_tSendMail_1.setSentDate(new Date());
msg_tSendMail_1.setHeader("X-Priority", "3"); // High->1
// Normal->3
// Low->5
javax.mail.Multipart mp_tSendMail_1 = new javax.mail.internet.MimeMultipart();
javax.mail.internet.MimeBodyPart mbpText_tSendMail_1 = new javax.mail.internet.MimeBodyPart();
mbpText_tSendMail_1.setText(message_tSendMail_1,
"ISO-8859-15", "html");
mp_tSendMail_1.addBodyPart(mbpText_tSendMail_1);
javax.mail.internet.MimeBodyPart mbpFile_tSendMail_1 = null;
for (int i_tSendMail_1 = 0; i_tSendMail_1 < attachments_tSendMail_1
.size(); i_tSendMail_1++) {
String filename_tSendMail_1 = attachments_tSendMail_1
.get(i_tSendMail_1);
javax.activation.FileDataSource fds_tSendMail_1 = null;
java.io.File file_tSendMail_1 = new java.io.File(
filename_tSendMail_1);
if (!file_tSendMail_1.exists()) {
continue;
}
if (file_tSendMail_1.isDirectory()) {
java.io.File[] subFiles_tSendMail_1 = file_tSendMail_1
.listFiles();
for (java.io.File subFile_tSendMail_1 : subFiles_tSendMail_1) {
if (subFile_tSendMail_1.isFile()) {
fds_tSendMail_1 = new javax.activation.FileDataSource(
subFile_tSendMail_1
.getAbsolutePath());
mbpFile_tSendMail_1 = new javax.mail.internet.MimeBodyPart();
mbpFile_tSendMail_1
.setDataHandler(new javax.activation.DataHandler(
fds_tSendMail_1));
mbpFile_tSendMail_1
.setFileName(javax.mail.internet.MimeUtility
.encodeText(fds_tSendMail_1
.getName()));
if (contentTransferEncoding_tSendMail_1
.get(i_tSendMail_1)
.equalsIgnoreCase("base64")) {
mbpFile_tSendMail_1.setHeader(
"Content-Transfer-Encoding",
"base64");
}
mp_tSendMail_1
.addBodyPart(mbpFile_tSendMail_1);
}
}
} else {
mbpFile_tSendMail_1 = new javax.mail.internet.MimeBodyPart();
fds_tSendMail_1 = new javax.activation.FileDataSource(
filename_tSendMail_1);
mbpFile_tSendMail_1
.setDataHandler(new javax.activation.DataHandler(
fds_tSendMail_1));
mbpFile_tSendMail_1
.setFileName(javax.mail.internet.MimeUtility
.encodeText(fds_tSendMail_1
.getName()));
if (contentTransferEncoding_tSendMail_1.get(
i_tSendMail_1).equalsIgnoreCase("base64")) {
mbpFile_tSendMail_1.setHeader(
"Content-Transfer-Encoding", "base64");
}
mp_tSendMail_1.addBodyPart(mbpFile_tSendMail_1);
}
}
// -- set the content --
msg_tSendMail_1.setContent(mp_tSendMail_1);
// add handlers for main MIME types
javax.activation.MailcapCommandMap mc_tSendMail_1 = (javax.activation.MailcapCommandMap) javax.activation.CommandMap
.getDefaultCommandMap();
mc_tSendMail_1
.addMailcap("text/html;; x-java-content-handler=com.sun.mail.handlers.text_html");
mc_tSendMail_1
.addMailcap("text/xml;; x-java-content-handler=com.sun.mail.handlers.text_xml");
mc_tSendMail_1
.addMailcap("text/plain;; x-java-content-handler=com.sun.mail.handlers.text_plain");
mc_tSendMail_1
.addMailcap("multipart/*;; x-java-content-handler=com.sun.mail.handlers.multipart_mixed");
mc_tSendMail_1
.addMailcap("message/rfc822;; x-java-content-handler=com.sun.mail.handlers.message_rfc822");
javax.activation.CommandMap
.setDefaultCommandMap(mc_tSendMail_1);
// -- Send the message --
javax.mail.Transport.send(msg_tSendMail_1);
} catch (java.lang.Exception e) {
throw (e);
} finally {
props_tSendMail_1.remove("mail.smtp.host");
props_tSendMail_1.remove("mail.smtp.port");
props_tSendMail_1.remove("mail.mime.encodefilename");
props_tSendMail_1.remove("mail.smtp.auth");
}
tos_count_tSendMail_1++;
/**
* [tSendMail_1 main ] stop
*/
/**
* [tSendMail_1 end ] start
*/
currentComponent = "tSendMail_1";
ok_Hash.put("tSendMail_1", true);
end_Hash.put("tSendMail_1", System.currentTimeMillis());
/**
* [tSendMail_1 end ] stop
*/
}// end the resume
if (resumeEntryMethodName == null || globalResumeTicket) {
resumeUtil
.addLog("CHECKPOINT",
"CONNECTION:SUBJOB_OK:tSendMail_1:OnSubjobOk",
"", Thread.currentThread().getId() + "", "",
"", "", "", "");
}
tFileDelete_1Process(globalMap);
} catch (java.lang.Exception e) {
TalendException te = new TalendException(e, currentComponent,
globalMap);
throw te;
} catch (java.lang.Error error) {
throw error;
} finally {
try {
/**
* [tSendMail_1 finally ] start
*/
currentComponent = "tSendMail_1";
/**
* [tSendMail_1 finally ] stop
*/
} catch (java.lang.Exception e) {
// ignore
} catch (java.lang.Error error) {
// ignore
}
resourceMap = null;
}
globalMap.put("tSendMail_1_SUBPROCESS_STATE", 1);
}
public String resuming_logs_dir_path = null;
public String resuming_checkpoint_path = null;
public String parent_part_launcher = null;
private String resumeEntryMethodName = null;
private boolean globalResumeTicket = false;
public boolean watch = false;
// portStats is null, it means don't execute the statistics
public Integer portStats = null;
public int portTraces = 4334;
public String clientHost;
public String defaultClientHost = "localhost";
public String contextStr = "RE7";
public boolean isDefaultContext = true;
public String pid = "0";
public String rootPid = null;
public String fatherPid = null;
public String fatherNode = null;
public long startTime = 0;
public boolean isChildJob = false;
public String log4jLevel = "";
private boolean execStat = true;
private ThreadLocal> threadLocal = new ThreadLocal>() {
protected java.util.Map initialValue() {
java.util.Map threadRunResultMap = new java.util.HashMap();
threadRunResultMap.put("errorCode", null);
threadRunResultMap.put("status", "");
return threadRunResultMap;
};
};
private java.util.Properties context_param = new java.util.Properties();
public java.util.Map parentContextMap = new java.util.HashMap();
public String status = "";
public static void main(String[] args) {
final GALAXIE__PCKG GALAXIE__PCKGClass = new GALAXIE__PCKG();
int exitCode = GALAXIE__PCKGClass.runJobInTOS(args);
System.exit(exitCode);
}
public String[][] runJob(String[] args) {
int exitCode = runJobInTOS(args);
String[][] bufferValue = new String[][] { { Integer.toString(exitCode) } };
return bufferValue;
}
public boolean hastBufferOutputComponent() {
boolean hastBufferOutput = false;
return hastBufferOutput;
}
public int runJobInTOS(String[] args) {
// reset status
status = "";
String lastStr = "";
for (String arg : args) {
if (arg.equalsIgnoreCase("--context_param")) {
lastStr = arg;
} else if (lastStr.equals("")) {
evalParam(arg);
} else {
evalParam(lastStr + " " + arg);
lastStr = "";
}
}
if (clientHost == null) {
clientHost = defaultClientHost;
}
if (pid == null || "0".equals(pid)) {
pid = TalendString.getAsciiRandomString(6);
}
if (rootPid == null) {
rootPid = pid;
}
if (fatherPid == null) {
fatherPid = pid;
} else {
isChildJob = true;
}
try {
// call job/subjob with an existing context, like:
// --context=production. if without this parameter, there will use
// the default context instead.
java.io.InputStream inContext = GALAXIE__PCKG.class
.getClassLoader().getResourceAsStream(
"fil_galaxie/galaxie__pckg_0_1/contexts/"
+ contextStr + ".properties");
if (isDefaultContext && inContext == null) {
} else {
if (inContext != null) {
// defaultProps is in order to keep the original context
// value
defaultProps.load(inContext);
inContext.close();
context = new ContextProperties(defaultProps);
} else {
// print info and job continue to run, for case:
// context_param is not empty.
System.err.println("Could not find the context "
+ contextStr);
}
}
if (!context_param.isEmpty()) {
context.putAll(context_param);
}
context.CTX_EMAIL_Destinataire = (String) context
.getProperty("CTX_EMAIL_Destinataire");
context.CTX_EMAIL_Destinataire_copie = (String) context
.getProperty("CTX_EMAIL_Destinataire_copie");
context.CTX_EMAIL_Destinataire_copie_cachee = (String) context
.getProperty("CTX_EMAIL_Destinataire_copie_cachee");
context.CTX_EMAIL_Emetteur = (String) context
.getProperty("CTX_EMAIL_Emetteur");
try {
context.CTX_EMAIL_Envoi_active = routines.system.ParserUtils
.parseTo_Integer(context
.getProperty("CTX_EMAIL_Envoi_active"));
} catch (NumberFormatException e) {
context.CTX_EMAIL_Envoi_active = null;
}
context.CTX_EMAIL_Login = (String) context
.getProperty("CTX_EMAIL_Login");
String pwd_CTX_EMAIL_Password_value = context
.getProperty("CTX_EMAIL_Password");
context.CTX_EMAIL_Password = null;
if (pwd_CTX_EMAIL_Password_value != null) {
if (context_param.containsKey("CTX_EMAIL_Password")) {// no need
// to
// decrypt
// if it
// come
// from
// program
// argument
// or
// parent
// job
// runtime
context.CTX_EMAIL_Password = pwd_CTX_EMAIL_Password_value;
} else if (!pwd_CTX_EMAIL_Password_value.isEmpty()) {
try {
context.CTX_EMAIL_Password = routines.system.PasswordEncryptUtil
.decryptPassword(pwd_CTX_EMAIL_Password_value);
context.put("CTX_EMAIL_Password",
context.CTX_EMAIL_Password);
} catch (java.lang.RuntimeException e) {
// do nothing
}
}
}
context.CTX_EMAIL_Serveur_port = (String) context
.getProperty("CTX_EMAIL_Serveur_port");
context.CTX_EMAIL_Serveur_SMTP = (String) context
.getProperty("CTX_EMAIL_Serveur_SMTP");
context.CTX_PGS_COMPTAFIL_Database = (String) context
.getProperty("CTX_PGS_COMPTAFIL_Database");
context.CTX_PGS_COMPTAFIL_Login = (String) context
.getProperty("CTX_PGS_COMPTAFIL_Login");
String pwd_CTX_PGS_COMPTAFIL_Password_value = context
.getProperty("CTX_PGS_COMPTAFIL_Password");
context.CTX_PGS_COMPTAFIL_Password = null;
if (pwd_CTX_PGS_COMPTAFIL_Password_value != null) {
if (context_param.containsKey("CTX_PGS_COMPTAFIL_Password")) {// no
// need
// to
// decrypt
// if
// it
// come
// from
// program
// argument
// or
// parent
// job
// runtime
context.CTX_PGS_COMPTAFIL_Password = pwd_CTX_PGS_COMPTAFIL_Password_value;
} else if (!pwd_CTX_PGS_COMPTAFIL_Password_value.isEmpty()) {
try {
context.CTX_PGS_COMPTAFIL_Password = routines.system.PasswordEncryptUtil
.decryptPassword(pwd_CTX_PGS_COMPTAFIL_Password_value);
context.put("CTX_PGS_COMPTAFIL_Password",
context.CTX_PGS_COMPTAFIL_Password);
} catch (java.lang.RuntimeException e) {
// do nothing
}
}
}
context.CTX_PGS_COMPTAFIL_Port = (String) context
.getProperty("CTX_PGS_COMPTAFIL_Port");
context.CTX_PGS_COMPTAFIL_Schema = (String) context
.getProperty("CTX_PGS_COMPTAFIL_Schema");
context.CTX_PGS_COMPTAFIL_Server = (String) context
.getProperty("CTX_PGS_COMPTAFIL_Server");
context.CTX_PGS_COMPTALIS_Database = (String) context
.getProperty("CTX_PGS_COMPTALIS_Database");
context.CTX_PGS_COMPTALIS_Login = (String) context
.getProperty("CTX_PGS_COMPTALIS_Login");
String pwd_CTX_PGS_COMPTALIS_Password_value = context
.getProperty("CTX_PGS_COMPTALIS_Password");
context.CTX_PGS_COMPTALIS_Password = null;
if (pwd_CTX_PGS_COMPTALIS_Password_value != null) {
if (context_param.containsKey("CTX_PGS_COMPTALIS_Password")) {// no
// need
// to
// decrypt
// if
// it
// come
// from
// program
// argument
// or
// parent
// job
// runtime
context.CTX_PGS_COMPTALIS_Password = pwd_CTX_PGS_COMPTALIS_Password_value;
} else if (!pwd_CTX_PGS_COMPTALIS_Password_value.isEmpty()) {
try {
context.CTX_PGS_COMPTALIS_Password = routines.system.PasswordEncryptUtil
.decryptPassword(pwd_CTX_PGS_COMPTALIS_Password_value);
context.put("CTX_PGS_COMPTALIS_Password",
context.CTX_PGS_COMPTALIS_Password);
} catch (java.lang.RuntimeException e) {
// do nothing
}
}
}
context.CTX_PGS_COMPTALIS_Port = (String) context
.getProperty("CTX_PGS_COMPTALIS_Port");
context.CTX_PGS_COMPTALIS_Schema = (String) context
.getProperty("CTX_PGS_COMPTALIS_Schema");
context.CTX_PGS_COMPTALIS_Server = (String) context
.getProperty("CTX_PGS_COMPTALIS_Server");
try {
context.CTX_PGS_CRM_CommitInterval = routines.system.ParserUtils
.parseTo_Integer(context
.getProperty("CTX_PGS_CRM_CommitInterval"));
} catch (NumberFormatException e) {
context.CTX_PGS_CRM_CommitInterval = null;
}
context.CTX_PGS_CRM_Database = (String) context
.getProperty("CTX_PGS_CRM_Database");
context.CTX_PGS_CRM_Login = (String) context
.getProperty("CTX_PGS_CRM_Login");
String pwd_CTX_PGS_CRM_Password_value = context
.getProperty("CTX_PGS_CRM_Password");
context.CTX_PGS_CRM_Password = null;
if (pwd_CTX_PGS_CRM_Password_value != null) {
if (context_param.containsKey("CTX_PGS_CRM_Password")) {// no
// need
// to
// decrypt
// if it
// come
// from
// program
// argument
// or
// parent
// job
// runtime
context.CTX_PGS_CRM_Password = pwd_CTX_PGS_CRM_Password_value;
} else if (!pwd_CTX_PGS_CRM_Password_value.isEmpty()) {
try {
context.CTX_PGS_CRM_Password = routines.system.PasswordEncryptUtil
.decryptPassword(pwd_CTX_PGS_CRM_Password_value);
context.put("CTX_PGS_CRM_Password",
context.CTX_PGS_CRM_Password);
} catch (java.lang.RuntimeException e) {
// do nothing
}
}
}
context.CTX_PGS_CRM_Port = (String) context
.getProperty("CTX_PGS_CRM_Port");
context.CTX_PGS_CRM_Schema = (String) context
.getProperty("CTX_PGS_CRM_Schema");
context.CTX_PGS_CRM_Server = (String) context
.getProperty("CTX_PGS_CRM_Server");
try {
context.CTX_PGS_DSA_CommitInterval = routines.system.ParserUtils
.parseTo_Integer(context
.getProperty("CTX_PGS_DSA_CommitInterval"));
} catch (NumberFormatException e) {
context.CTX_PGS_DSA_CommitInterval = null;
}
context.CTX_PGS_DSA_Database = (String) context
.getProperty("CTX_PGS_DSA_Database");
context.CTX_PGS_DSA_Login = (String) context
.getProperty("CTX_PGS_DSA_Login");
String pwd_CTX_PGS_DSA_Password_value = context
.getProperty("CTX_PGS_DSA_Password");
context.CTX_PGS_DSA_Password = null;
if (pwd_CTX_PGS_DSA_Password_value != null) {
if (context_param.containsKey("CTX_PGS_DSA_Password")) {// no
// need
// to
// decrypt
// if it
// come
// from
// program
// argument
// or
// parent
// job
// runtime
context.CTX_PGS_DSA_Password = pwd_CTX_PGS_DSA_Password_value;
} else if (!pwd_CTX_PGS_DSA_Password_value.isEmpty()) {
try {
context.CTX_PGS_DSA_Password = routines.system.PasswordEncryptUtil
.decryptPassword(pwd_CTX_PGS_DSA_Password_value);
context.put("CTX_PGS_DSA_Password",
context.CTX_PGS_DSA_Password);
} catch (java.lang.RuntimeException e) {
// do nothing
}
}
}
context.CTX_PGS_DSA_Port = (String) context
.getProperty("CTX_PGS_DSA_Port");
context.CTX_PGS_DSA_Schema = (String) context
.getProperty("CTX_PGS_DSA_Schema");
context.CTX_PGS_DSA_Server = (String) context
.getProperty("CTX_PGS_DSA_Server");
try {
context.CTX_PGS_ODS_CommitInterval = routines.system.ParserUtils
.parseTo_Integer(context
.getProperty("CTX_PGS_ODS_CommitInterval"));
} catch (NumberFormatException e) {
context.CTX_PGS_ODS_CommitInterval = null;
}
context.CTX_PGS_ODS_Database = (String) context
.getProperty("CTX_PGS_ODS_Database");
context.CTX_PGS_ODS_Login = (String) context
.getProperty("CTX_PGS_ODS_Login");
String pwd_CTX_PGS_ODS_Password_value = context
.getProperty("CTX_PGS_ODS_Password");
context.CTX_PGS_ODS_Password = null;
if (pwd_CTX_PGS_ODS_Password_value != null) {
if (context_param.containsKey("CTX_PGS_ODS_Password")) {// no
// need
// to
// decrypt
// if it
// come
// from
// program
// argument
// or
// parent
// job
// runtime
context.CTX_PGS_ODS_Password = pwd_CTX_PGS_ODS_Password_value;
} else if (!pwd_CTX_PGS_ODS_Password_value.isEmpty()) {
try {
context.CTX_PGS_ODS_Password = routines.system.PasswordEncryptUtil
.decryptPassword(pwd_CTX_PGS_ODS_Password_value);
context.put("CTX_PGS_ODS_Password",
context.CTX_PGS_ODS_Password);
} catch (java.lang.RuntimeException e) {
// do nothing
}
}
}
context.CTX_PGS_ODS_Port = (String) context
.getProperty("CTX_PGS_ODS_Port");
context.CTX_PGS_ODS_Schema = (String) context
.getProperty("CTX_PGS_ODS_Schema");
context.CTX_PGS_ODS_Server = (String) context
.getProperty("CTX_PGS_ODS_Server");
context.CTX_PRM_ArchiveLogs = (String) context
.getProperty("CTX_PRM_ArchiveLogs");
context.CTX_PRM_CEV = (String) context.getProperty("CTX_PRM_CEV");
try {
context.CTX_PRM_CodeRetour = routines.system.ParserUtils
.parseTo_Integer(context
.getProperty("CTX_PRM_CodeRetour"));
} catch (NumberFormatException e) {
context.CTX_PRM_CodeRetour = null;
}
try {
String context_CTX_PRM_DateDebut_value = context
.getProperty("CTX_PRM_DateDebut");
if (context_CTX_PRM_DateDebut_value == null) {
context_CTX_PRM_DateDebut_value = "";
}
int context_CTX_PRM_DateDebut_pos = context_CTX_PRM_DateDebut_value
.indexOf(";");
String context_CTX_PRM_DateDebut_pattern = "yyyy-MM-dd HH:mm:ss";
if (context_CTX_PRM_DateDebut_pos > -1) {
context_CTX_PRM_DateDebut_pattern = context_CTX_PRM_DateDebut_value
.substring(0, context_CTX_PRM_DateDebut_pos);
context_CTX_PRM_DateDebut_value = context_CTX_PRM_DateDebut_value
.substring(context_CTX_PRM_DateDebut_pos + 1);
}
context.CTX_PRM_DateDebut = (java.util.Date) (new java.text.SimpleDateFormat(
context_CTX_PRM_DateDebut_pattern)
.parse(context_CTX_PRM_DateDebut_value));
} catch (ParseException e) {
context.CTX_PRM_DateDebut = null;
}
try {
String context_CTX_PRM_DateFin_value = context
.getProperty("CTX_PRM_DateFin");
if (context_CTX_PRM_DateFin_value == null) {
context_CTX_PRM_DateFin_value = "";
}
int context_CTX_PRM_DateFin_pos = context_CTX_PRM_DateFin_value
.indexOf(";");
String context_CTX_PRM_DateFin_pattern = "yyyy-MM-dd HH:mm:ss";
if (context_CTX_PRM_DateFin_pos > -1) {
context_CTX_PRM_DateFin_pattern = context_CTX_PRM_DateFin_value
.substring(0, context_CTX_PRM_DateFin_pos);
context_CTX_PRM_DateFin_value = context_CTX_PRM_DateFin_value
.substring(context_CTX_PRM_DateFin_pos + 1);
}
context.CTX_PRM_DateFin = (java.util.Date) (new java.text.SimpleDateFormat(
context_CTX_PRM_DateFin_pattern)
.parse(context_CTX_PRM_DateFin_value));
} catch (ParseException e) {
context.CTX_PRM_DateFin = null;
}
context.CTX_PRM_Edeal_ASSO_FIL = (String) context
.getProperty("CTX_PRM_Edeal_ASSO_FIL");
context.CTX_PRM_Edeal_ASSO_LIS = (String) context
.getProperty("CTX_PRM_Edeal_ASSO_LIS");
context.CTX_PRM_EdealBascounter = (String) context
.getProperty("CTX_PRM_EdealBascounter");
context.CTX_PRM_EdealBasid = (String) context
.getProperty("CTX_PRM_EdealBasid");
context.CTX_PRM_EdealCodeActor = (String) context
.getProperty("CTX_PRM_EdealCodeActor");
context.CTX_PRM_EdealIdActor = (String) context
.getProperty("CTX_PRM_EdealIdActor");
context.CTX_PRM_EdealLicence = (String) context
.getProperty("CTX_PRM_EdealLicence");
try {
context.CTX_PRM_EncryptedPassword = routines.system.ParserUtils
.parseTo_Integer(context
.getProperty("CTX_PRM_EncryptedPassword"));
} catch (NumberFormatException e) {
context.CTX_PRM_EncryptedPassword = null;
}
context.CTX_PRM_Environnement = (String) context
.getProperty("CTX_PRM_Environnement");
context.CTX_PRM_EQUALITING = (String) context
.getProperty("CTX_PRM_EQUALITING");
context.CTX_PRM_Exec_RES = (Object) context
.getProperty("CTX_PRM_Exec_RES");
context.CTX_PRM_FichierConfiguration = (String) context
.getProperty("CTX_PRM_FichierConfiguration");
context.CTX_PRM_FichierLog = (String) context
.getProperty("CTX_PRM_FichierLog");
context.CTX_PRM_FichierLogs = (String) context
.getProperty("CTX_PRM_FichierLogs");
context.CTX_PRM_FichierMetrique = (String) context
.getProperty("CTX_PRM_FichierMetrique");
context.CTX_PRM_FichierStatistique = (String) context
.getProperty("CTX_PRM_FichierStatistique");
context.CTX_PRM_fileEncodage = (String) context
.getProperty("CTX_PRM_fileEncodage");
context.CTX_PRM_fileName = (String) context
.getProperty("CTX_PRM_fileName");
try {
context.CTX_PRM_IdAudit = routines.system.ParserUtils
.parseTo_Long(context.getProperty("CTX_PRM_IdAudit"));
} catch (NumberFormatException e) {
context.CTX_PRM_IdAudit = null;
}
try {
context.CTX_PRM_IdEtape = routines.system.ParserUtils
.parseTo_Integer(context.getProperty("CTX_PRM_IdEtape"));
} catch (NumberFormatException e) {
context.CTX_PRM_IdEtape = null;
}
try {
context.CTX_PRM_IdEtapeDebut = routines.system.ParserUtils
.parseTo_Integer(context
.getProperty("CTX_PRM_IdEtapeDebut"));
} catch (NumberFormatException e) {
context.CTX_PRM_IdEtapeDebut = null;
}
try {
context.CTX_PRM_IdEtapeFin = routines.system.ParserUtils
.parseTo_Integer(context
.getProperty("CTX_PRM_IdEtapeFin"));
} catch (NumberFormatException e) {
context.CTX_PRM_IdEtapeFin = null;
}
context.CTX_PRM_listOfTableToDisableConstraints = (String) context
.getProperty("CTX_PRM_listOfTableToDisableConstraints");
try {
context.CTX_PRM_LKPCursorSize = routines.system.ParserUtils
.parseTo_Integer(context
.getProperty("CTX_PRM_LKPCursorSize"));
} catch (NumberFormatException e) {
context.CTX_PRM_LKPCursorSize = null;
}
context.CTX_PRM_NomAppliSource = (String) context
.getProperty("CTX_PRM_NomAppliSource");
context.CTX_PRM_NomSource = (String) context
.getProperty("CTX_PRM_NomSource");
context.CTX_PRM_OLAKALA_ERROR = (String) context
.getProperty("CTX_PRM_OLAKALA_ERROR");
context.CTX_PRM_OLAKALA_FINISHED = (String) context
.getProperty("CTX_PRM_OLAKALA_FINISHED");
context.CTX_PRM_OLAKALA_PROGRESS = (String) context
.getProperty("CTX_PRM_OLAKALA_PROGRESS");
try {
context.CTX_PRM_ProfondeurRetentionLogs = routines.system.ParserUtils
.parseTo_Integer(context
.getProperty("CTX_PRM_ProfondeurRetentionLogs"));
} catch (NumberFormatException e) {
context.CTX_PRM_ProfondeurRetentionLogs = null;
}
try {
context.CTX_PRM_ProfondeurRetentionRejets = routines.system.ParserUtils
.parseTo_Integer(context
.getProperty("CTX_PRM_ProfondeurRetentionRejets"));
} catch (NumberFormatException e) {
context.CTX_PRM_ProfondeurRetentionRejets = null;
}
context.CTX_PRM_RepertoireConf = (String) context
.getProperty("CTX_PRM_RepertoireConf");
context.CTX_PRM_RepertoireData = (String) context
.getProperty("CTX_PRM_RepertoireData");
context.CTX_PRM_RepertoireDataArchive = (String) context
.getProperty("CTX_PRM_RepertoireDataArchive");
context.CTX_PRM_RepertoireDataIn = (String) context
.getProperty("CTX_PRM_RepertoireDataIn");
context.CTX_PRM_RepertoireDataOut = (String) context
.getProperty("CTX_PRM_RepertoireDataOut");
context.CTX_PRM_RepertoireLog = (String) context
.getProperty("CTX_PRM_RepertoireLog");
context.CTX_PRM_RepertoireRacine = (String) context
.getProperty("CTX_PRM_RepertoireRacine");
context.CTX_PRM_RepertoireSql = (String) context
.getProperty("CTX_PRM_RepertoireSql");
context.CTX_PRM_RepertoireTmp = (String) context
.getProperty("CTX_PRM_RepertoireTmp");
context.CTX_PRM_RESERVIT = (String) context
.getProperty("CTX_PRM_RESERVIT");
context.CTX_PRM_SoucheVersion = (String) context
.getProperty("CTX_PRM_SoucheVersion");
try {
context.CTX_PRM_SRCCursorSize = routines.system.ParserUtils
.parseTo_Integer(context
.getProperty("CTX_PRM_SRCCursorSize"));
} catch (NumberFormatException e) {
context.CTX_PRM_SRCCursorSize = null;
}
context.CTX_PRM_TalendRootPackage = (String) context
.getProperty("CTX_PRM_TalendRootPackage");
context.CTX_PRM_TalendRootPid = (String) context
.getProperty("CTX_PRM_TalendRootPid");
} catch (java.io.IOException ie) {
System.err.println("Could not load context " + contextStr);
ie.printStackTrace();
}
// get context value from parent directly
if (parentContextMap != null && !parentContextMap.isEmpty()) {
if (parentContextMap.containsKey("CTX_EMAIL_Destinataire")) {
context.CTX_EMAIL_Destinataire = (String) parentContextMap
.get("CTX_EMAIL_Destinataire");
}
if (parentContextMap.containsKey("CTX_EMAIL_Destinataire_copie")) {
context.CTX_EMAIL_Destinataire_copie = (String) parentContextMap
.get("CTX_EMAIL_Destinataire_copie");
}
if (parentContextMap
.containsKey("CTX_EMAIL_Destinataire_copie_cachee")) {
context.CTX_EMAIL_Destinataire_copie_cachee = (String) parentContextMap
.get("CTX_EMAIL_Destinataire_copie_cachee");
}
if (parentContextMap.containsKey("CTX_EMAIL_Emetteur")) {
context.CTX_EMAIL_Emetteur = (String) parentContextMap
.get("CTX_EMAIL_Emetteur");
}
if (parentContextMap.containsKey("CTX_EMAIL_Envoi_active")) {
context.CTX_EMAIL_Envoi_active = (Integer) parentContextMap
.get("CTX_EMAIL_Envoi_active");
}
if (parentContextMap.containsKey("CTX_EMAIL_Login")) {
context.CTX_EMAIL_Login = (String) parentContextMap
.get("CTX_EMAIL_Login");
}
if (parentContextMap.containsKey("CTX_EMAIL_Password")) {
context.CTX_EMAIL_Password = (java.lang.String) parentContextMap
.get("CTX_EMAIL_Password");
}
if (parentContextMap.containsKey("CTX_EMAIL_Serveur_port")) {
context.CTX_EMAIL_Serveur_port = (String) parentContextMap
.get("CTX_EMAIL_Serveur_port");
}
if (parentContextMap.containsKey("CTX_EMAIL_Serveur_SMTP")) {
context.CTX_EMAIL_Serveur_SMTP = (String) parentContextMap
.get("CTX_EMAIL_Serveur_SMTP");
}
if (parentContextMap.containsKey("CTX_PGS_COMPTAFIL_Database")) {
context.CTX_PGS_COMPTAFIL_Database = (String) parentContextMap
.get("CTX_PGS_COMPTAFIL_Database");
}
if (parentContextMap.containsKey("CTX_PGS_COMPTAFIL_Login")) {
context.CTX_PGS_COMPTAFIL_Login = (String) parentContextMap
.get("CTX_PGS_COMPTAFIL_Login");
}
if (parentContextMap.containsKey("CTX_PGS_COMPTAFIL_Password")) {
context.CTX_PGS_COMPTAFIL_Password = (java.lang.String) parentContextMap
.get("CTX_PGS_COMPTAFIL_Password");
}
if (parentContextMap.containsKey("CTX_PGS_COMPTAFIL_Port")) {
context.CTX_PGS_COMPTAFIL_Port = (String) parentContextMap
.get("CTX_PGS_COMPTAFIL_Port");
}
if (parentContextMap.containsKey("CTX_PGS_COMPTAFIL_Schema")) {
context.CTX_PGS_COMPTAFIL_Schema = (String) parentContextMap
.get("CTX_PGS_COMPTAFIL_Schema");
}
if (parentContextMap.containsKey("CTX_PGS_COMPTAFIL_Server")) {
context.CTX_PGS_COMPTAFIL_Server = (String) parentContextMap
.get("CTX_PGS_COMPTAFIL_Server");
}
if (parentContextMap.containsKey("CTX_PGS_COMPTALIS_Database")) {
context.CTX_PGS_COMPTALIS_Database = (String) parentContextMap
.get("CTX_PGS_COMPTALIS_Database");
}
if (parentContextMap.containsKey("CTX_PGS_COMPTALIS_Login")) {
context.CTX_PGS_COMPTALIS_Login = (String) parentContextMap
.get("CTX_PGS_COMPTALIS_Login");
}
if (parentContextMap.containsKey("CTX_PGS_COMPTALIS_Password")) {
context.CTX_PGS_COMPTALIS_Password = (java.lang.String) parentContextMap
.get("CTX_PGS_COMPTALIS_Password");
}
if (parentContextMap.containsKey("CTX_PGS_COMPTALIS_Port")) {
context.CTX_PGS_COMPTALIS_Port = (String) parentContextMap
.get("CTX_PGS_COMPTALIS_Port");
}
if (parentContextMap.containsKey("CTX_PGS_COMPTALIS_Schema")) {
context.CTX_PGS_COMPTALIS_Schema = (String) parentContextMap
.get("CTX_PGS_COMPTALIS_Schema");
}
if (parentContextMap.containsKey("CTX_PGS_COMPTALIS_Server")) {
context.CTX_PGS_COMPTALIS_Server = (String) parentContextMap
.get("CTX_PGS_COMPTALIS_Server");
}
if (parentContextMap.containsKey("CTX_PGS_CRM_CommitInterval")) {
context.CTX_PGS_CRM_CommitInterval = (Integer) parentContextMap
.get("CTX_PGS_CRM_CommitInterval");
}
if (parentContextMap.containsKey("CTX_PGS_CRM_Database")) {
context.CTX_PGS_CRM_Database = (String) parentContextMap
.get("CTX_PGS_CRM_Database");
}
if (parentContextMap.containsKey("CTX_PGS_CRM_Login")) {
context.CTX_PGS_CRM_Login = (String) parentContextMap
.get("CTX_PGS_CRM_Login");
}
if (parentContextMap.containsKey("CTX_PGS_CRM_Password")) {
context.CTX_PGS_CRM_Password = (java.lang.String) parentContextMap
.get("CTX_PGS_CRM_Password");
}
if (parentContextMap.containsKey("CTX_PGS_CRM_Port")) {
context.CTX_PGS_CRM_Port = (String) parentContextMap
.get("CTX_PGS_CRM_Port");
}
if (parentContextMap.containsKey("CTX_PGS_CRM_Schema")) {
context.CTX_PGS_CRM_Schema = (String) parentContextMap
.get("CTX_PGS_CRM_Schema");
}
if (parentContextMap.containsKey("CTX_PGS_CRM_Server")) {
context.CTX_PGS_CRM_Server = (String) parentContextMap
.get("CTX_PGS_CRM_Server");
}
if (parentContextMap.containsKey("CTX_PGS_DSA_CommitInterval")) {
context.CTX_PGS_DSA_CommitInterval = (Integer) parentContextMap
.get("CTX_PGS_DSA_CommitInterval");
}
if (parentContextMap.containsKey("CTX_PGS_DSA_Database")) {
context.CTX_PGS_DSA_Database = (String) parentContextMap
.get("CTX_PGS_DSA_Database");
}
if (parentContextMap.containsKey("CTX_PGS_DSA_Login")) {
context.CTX_PGS_DSA_Login = (String) parentContextMap
.get("CTX_PGS_DSA_Login");
}
if (parentContextMap.containsKey("CTX_PGS_DSA_Password")) {
context.CTX_PGS_DSA_Password = (java.lang.String) parentContextMap
.get("CTX_PGS_DSA_Password");
}
if (parentContextMap.containsKey("CTX_PGS_DSA_Port")) {
context.CTX_PGS_DSA_Port = (String) parentContextMap
.get("CTX_PGS_DSA_Port");
}
if (parentContextMap.containsKey("CTX_PGS_DSA_Schema")) {
context.CTX_PGS_DSA_Schema = (String) parentContextMap
.get("CTX_PGS_DSA_Schema");
}
if (parentContextMap.containsKey("CTX_PGS_DSA_Server")) {
context.CTX_PGS_DSA_Server = (String) parentContextMap
.get("CTX_PGS_DSA_Server");
}
if (parentContextMap.containsKey("CTX_PGS_ODS_CommitInterval")) {
context.CTX_PGS_ODS_CommitInterval = (Integer) parentContextMap
.get("CTX_PGS_ODS_CommitInterval");
}
if (parentContextMap.containsKey("CTX_PGS_ODS_Database")) {
context.CTX_PGS_ODS_Database = (String) parentContextMap
.get("CTX_PGS_ODS_Database");
}
if (parentContextMap.containsKey("CTX_PGS_ODS_Login")) {
context.CTX_PGS_ODS_Login = (String) parentContextMap
.get("CTX_PGS_ODS_Login");
}
if (parentContextMap.containsKey("CTX_PGS_ODS_Password")) {
context.CTX_PGS_ODS_Password = (java.lang.String) parentContextMap
.get("CTX_PGS_ODS_Password");
}
if (parentContextMap.containsKey("CTX_PGS_ODS_Port")) {
context.CTX_PGS_ODS_Port = (String) parentContextMap
.get("CTX_PGS_ODS_Port");
}
if (parentContextMap.containsKey("CTX_PGS_ODS_Schema")) {
context.CTX_PGS_ODS_Schema = (String) parentContextMap
.get("CTX_PGS_ODS_Schema");
}
if (parentContextMap.containsKey("CTX_PGS_ODS_Server")) {
context.CTX_PGS_ODS_Server = (String) parentContextMap
.get("CTX_PGS_ODS_Server");
}
if (parentContextMap.containsKey("CTX_PRM_ArchiveLogs")) {
context.CTX_PRM_ArchiveLogs = (String) parentContextMap
.get("CTX_PRM_ArchiveLogs");
}
if (parentContextMap.containsKey("CTX_PRM_CEV")) {
context.CTX_PRM_CEV = (String) parentContextMap
.get("CTX_PRM_CEV");
}
if (parentContextMap.containsKey("CTX_PRM_CodeRetour")) {
context.CTX_PRM_CodeRetour = (Integer) parentContextMap
.get("CTX_PRM_CodeRetour");
}
if (parentContextMap.containsKey("CTX_PRM_DateDebut")) {
context.CTX_PRM_DateDebut = (java.util.Date) parentContextMap
.get("CTX_PRM_DateDebut");
}
if (parentContextMap.containsKey("CTX_PRM_DateFin")) {
context.CTX_PRM_DateFin = (java.util.Date) parentContextMap
.get("CTX_PRM_DateFin");
}
if (parentContextMap.containsKey("CTX_PRM_Edeal_ASSO_FIL")) {
context.CTX_PRM_Edeal_ASSO_FIL = (String) parentContextMap
.get("CTX_PRM_Edeal_ASSO_FIL");
}
if (parentContextMap.containsKey("CTX_PRM_Edeal_ASSO_LIS")) {
context.CTX_PRM_Edeal_ASSO_LIS = (String) parentContextMap
.get("CTX_PRM_Edeal_ASSO_LIS");
}
if (parentContextMap.containsKey("CTX_PRM_EdealBascounter")) {
context.CTX_PRM_EdealBascounter = (String) parentContextMap
.get("CTX_PRM_EdealBascounter");
}
if (parentContextMap.containsKey("CTX_PRM_EdealBasid")) {
context.CTX_PRM_EdealBasid = (String) parentContextMap
.get("CTX_PRM_EdealBasid");
}
if (parentContextMap.containsKey("CTX_PRM_EdealCodeActor")) {
context.CTX_PRM_EdealCodeActor = (String) parentContextMap
.get("CTX_PRM_EdealCodeActor");
}
if (parentContextMap.containsKey("CTX_PRM_EdealIdActor")) {
context.CTX_PRM_EdealIdActor = (String) parentContextMap
.get("CTX_PRM_EdealIdActor");
}
if (parentContextMap.containsKey("CTX_PRM_EdealLicence")) {
context.CTX_PRM_EdealLicence = (String) parentContextMap
.get("CTX_PRM_EdealLicence");
}
if (parentContextMap.containsKey("CTX_PRM_EncryptedPassword")) {
context.CTX_PRM_EncryptedPassword = (Integer) parentContextMap
.get("CTX_PRM_EncryptedPassword");
}
if (parentContextMap.containsKey("CTX_PRM_Environnement")) {
context.CTX_PRM_Environnement = (String) parentContextMap
.get("CTX_PRM_Environnement");
}
if (parentContextMap.containsKey("CTX_PRM_EQUALITING")) {
context.CTX_PRM_EQUALITING = (String) parentContextMap
.get("CTX_PRM_EQUALITING");
}
if (parentContextMap.containsKey("CTX_PRM_Exec_RES")) {
context.CTX_PRM_Exec_RES = (Object) parentContextMap
.get("CTX_PRM_Exec_RES");
}
if (parentContextMap.containsKey("CTX_PRM_FichierConfiguration")) {
context.CTX_PRM_FichierConfiguration = (String) parentContextMap
.get("CTX_PRM_FichierConfiguration");
}
if (parentContextMap.containsKey("CTX_PRM_FichierLog")) {
context.CTX_PRM_FichierLog = (String) parentContextMap
.get("CTX_PRM_FichierLog");
}
if (parentContextMap.containsKey("CTX_PRM_FichierLogs")) {
context.CTX_PRM_FichierLogs = (String) parentContextMap
.get("CTX_PRM_FichierLogs");
}
if (parentContextMap.containsKey("CTX_PRM_FichierMetrique")) {
context.CTX_PRM_FichierMetrique = (String) parentContextMap
.get("CTX_PRM_FichierMetrique");
}
if (parentContextMap.containsKey("CTX_PRM_FichierStatistique")) {
context.CTX_PRM_FichierStatistique = (String) parentContextMap
.get("CTX_PRM_FichierStatistique");
}
if (parentContextMap.containsKey("CTX_PRM_fileEncodage")) {
context.CTX_PRM_fileEncodage = (String) parentContextMap
.get("CTX_PRM_fileEncodage");
}
if (parentContextMap.containsKey("CTX_PRM_fileName")) {
context.CTX_PRM_fileName = (String) parentContextMap
.get("CTX_PRM_fileName");
}
if (parentContextMap.containsKey("CTX_PRM_IdAudit")) {
context.CTX_PRM_IdAudit = (Long) parentContextMap
.get("CTX_PRM_IdAudit");
}
if (parentContextMap.containsKey("CTX_PRM_IdEtape")) {
context.CTX_PRM_IdEtape = (Integer) parentContextMap
.get("CTX_PRM_IdEtape");
}
if (parentContextMap.containsKey("CTX_PRM_IdEtapeDebut")) {
context.CTX_PRM_IdEtapeDebut = (Integer) parentContextMap
.get("CTX_PRM_IdEtapeDebut");
}
if (parentContextMap.containsKey("CTX_PRM_IdEtapeFin")) {
context.CTX_PRM_IdEtapeFin = (Integer) parentContextMap
.get("CTX_PRM_IdEtapeFin");
}
if (parentContextMap
.containsKey("CTX_PRM_listOfTableToDisableConstraints")) {
context.CTX_PRM_listOfTableToDisableConstraints = (String) parentContextMap
.get("CTX_PRM_listOfTableToDisableConstraints");
}
if (parentContextMap.containsKey("CTX_PRM_LKPCursorSize")) {
context.CTX_PRM_LKPCursorSize = (Integer) parentContextMap
.get("CTX_PRM_LKPCursorSize");
}
if (parentContextMap.containsKey("CTX_PRM_NomAppliSource")) {
context.CTX_PRM_NomAppliSource = (String) parentContextMap
.get("CTX_PRM_NomAppliSource");
}
if (parentContextMap.containsKey("CTX_PRM_NomSource")) {
context.CTX_PRM_NomSource = (String) parentContextMap
.get("CTX_PRM_NomSource");
}
if (parentContextMap.containsKey("CTX_PRM_OLAKALA_ERROR")) {
context.CTX_PRM_OLAKALA_ERROR = (String) parentContextMap
.get("CTX_PRM_OLAKALA_ERROR");
}
if (parentContextMap.containsKey("CTX_PRM_OLAKALA_FINISHED")) {
context.CTX_PRM_OLAKALA_FINISHED = (String) parentContextMap
.get("CTX_PRM_OLAKALA_FINISHED");
}
if (parentContextMap.containsKey("CTX_PRM_OLAKALA_PROGRESS")) {
context.CTX_PRM_OLAKALA_PROGRESS = (String) parentContextMap
.get("CTX_PRM_OLAKALA_PROGRESS");
}
if (parentContextMap.containsKey("CTX_PRM_ProfondeurRetentionLogs")) {
context.CTX_PRM_ProfondeurRetentionLogs = (Integer) parentContextMap
.get("CTX_PRM_ProfondeurRetentionLogs");
}
if (parentContextMap
.containsKey("CTX_PRM_ProfondeurRetentionRejets")) {
context.CTX_PRM_ProfondeurRetentionRejets = (Integer) parentContextMap
.get("CTX_PRM_ProfondeurRetentionRejets");
}
if (parentContextMap.containsKey("CTX_PRM_RepertoireConf")) {
context.CTX_PRM_RepertoireConf = (String) parentContextMap
.get("CTX_PRM_RepertoireConf");
}
if (parentContextMap.containsKey("CTX_PRM_RepertoireData")) {
context.CTX_PRM_RepertoireData = (String) parentContextMap
.get("CTX_PRM_RepertoireData");
}
if (parentContextMap.containsKey("CTX_PRM_RepertoireDataArchive")) {
context.CTX_PRM_RepertoireDataArchive = (String) parentContextMap
.get("CTX_PRM_RepertoireDataArchive");
}
if (parentContextMap.containsKey("CTX_PRM_RepertoireDataIn")) {
context.CTX_PRM_RepertoireDataIn = (String) parentContextMap
.get("CTX_PRM_RepertoireDataIn");
}
if (parentContextMap.containsKey("CTX_PRM_RepertoireDataOut")) {
context.CTX_PRM_RepertoireDataOut = (String) parentContextMap
.get("CTX_PRM_RepertoireDataOut");
}
if (parentContextMap.containsKey("CTX_PRM_RepertoireLog")) {
context.CTX_PRM_RepertoireLog = (String) parentContextMap
.get("CTX_PRM_RepertoireLog");
}
if (parentContextMap.containsKey("CTX_PRM_RepertoireRacine")) {
context.CTX_PRM_RepertoireRacine = (String) parentContextMap
.get("CTX_PRM_RepertoireRacine");
}
if (parentContextMap.containsKey("CTX_PRM_RepertoireSql")) {
context.CTX_PRM_RepertoireSql = (String) parentContextMap
.get("CTX_PRM_RepertoireSql");
}
if (parentContextMap.containsKey("CTX_PRM_RepertoireTmp")) {
context.CTX_PRM_RepertoireTmp = (String) parentContextMap
.get("CTX_PRM_RepertoireTmp");
}
if (parentContextMap.containsKey("CTX_PRM_RESERVIT")) {
context.CTX_PRM_RESERVIT = (String) parentContextMap
.get("CTX_PRM_RESERVIT");
}
if (parentContextMap.containsKey("CTX_PRM_SoucheVersion")) {
context.CTX_PRM_SoucheVersion = (String) parentContextMap
.get("CTX_PRM_SoucheVersion");
}
if (parentContextMap.containsKey("CTX_PRM_SRCCursorSize")) {
context.CTX_PRM_SRCCursorSize = (Integer) parentContextMap
.get("CTX_PRM_SRCCursorSize");
}
if (parentContextMap.containsKey("CTX_PRM_TalendRootPackage")) {
context.CTX_PRM_TalendRootPackage = (String) parentContextMap
.get("CTX_PRM_TalendRootPackage");
}
if (parentContextMap.containsKey("CTX_PRM_TalendRootPid")) {
context.CTX_PRM_TalendRootPid = (String) parentContextMap
.get("CTX_PRM_TalendRootPid");
}
}
// Resume: init the resumeUtil
resumeEntryMethodName = ResumeUtil
.getResumeEntryMethodName(resuming_checkpoint_path);
resumeUtil = new ResumeUtil(resuming_logs_dir_path, isChildJob, rootPid);
resumeUtil.initCommonInfo(pid, rootPid, fatherPid, projectName,
jobName, contextStr, jobVersion);
List parametersToEncrypt = new java.util.ArrayList();
parametersToEncrypt.add("CTX_EMAIL_Password");
parametersToEncrypt.add("CTX_PGS_COMPTAFIL_Password");
parametersToEncrypt.add("CTX_PGS_COMPTALIS_Password");
parametersToEncrypt.add("CTX_PGS_CRM_Password");
parametersToEncrypt.add("CTX_PGS_DSA_Password");
parametersToEncrypt.add("CTX_PGS_ODS_Password");
// Resume: jobStart
resumeUtil.addLog("JOB_STARTED", "JOB:" + jobName,
parent_part_launcher, Thread.currentThread().getId() + "", "",
"", "", "",
resumeUtil.convertToJsonText(context, parametersToEncrypt));
java.util.concurrent.ConcurrentHashMap concurrentHashMap = new java.util.concurrent.ConcurrentHashMap();
globalMap.put("concurrentHashMap", concurrentHashMap);
long startUsedMemory = Runtime.getRuntime().totalMemory()
- Runtime.getRuntime().freeMemory();
long endUsedMemory = 0;
long end = 0;
startTime = System.currentTimeMillis();
this.globalResumeTicket = true;// to run tPreJob
this.globalResumeTicket = false;// to run others jobs
try {
errorCode = null;
tJava_1Process(globalMap);
if (!"failure".equals(status)) {
status = "end";
}
} catch (TalendException e_tJava_1) {
globalMap.put("tJava_1_SUBPROCESS_STATE", -1);
e_tJava_1.printStackTrace();
}
this.globalResumeTicket = true;// to run tPostJob
try {
errorCode = null;
tPostjob_1Process(globalMap);
if (!"failure".equals(status)) {
status = "end";
}
} catch (TalendException e_tPostjob_1) {
globalMap.put("tPostjob_1_SUBPROCESS_STATE", -1);
e_tPostjob_1.printStackTrace();
}
end = System.currentTimeMillis();
if (watch) {
System.out.println((end - startTime) + " milliseconds");
}
endUsedMemory = Runtime.getRuntime().totalMemory()
- Runtime.getRuntime().freeMemory();
if (false) {
System.out.println((endUsedMemory - startUsedMemory)
+ " bytes memory increase when running : GALAXIE__PCKG");
}
int returnCode = 0;
if (errorCode == null) {
returnCode = status != null && status.equals("failure") ? 1 : 0;
} else {
returnCode = errorCode.intValue();
}
resumeUtil.addLog("JOB_ENDED", "JOB:" + jobName, parent_part_launcher,
Thread.currentThread().getId() + "", "", "" + returnCode, "",
"", "");
return returnCode;
}
// only for OSGi env
public void destroy() {
}
private java.util.Map getSharedConnections4REST() {
java.util.Map connections = new java.util.HashMap();
return connections;
}
private void evalParam(String arg) {
if (arg.startsWith("--resuming_logs_dir_path")) {
resuming_logs_dir_path = arg.substring(25);
} else if (arg.startsWith("--resuming_checkpoint_path")) {
resuming_checkpoint_path = arg.substring(27);
} else if (arg.startsWith("--parent_part_launcher")) {
parent_part_launcher = arg.substring(23);
} else if (arg.startsWith("--watch")) {
watch = true;
} else if (arg.startsWith("--stat_port=")) {
String portStatsStr = arg.substring(12);
if (portStatsStr != null && !portStatsStr.equals("null")) {
portStats = Integer.parseInt(portStatsStr);
}
} else if (arg.startsWith("--trace_port=")) {
portTraces = Integer.parseInt(arg.substring(13));
} else if (arg.startsWith("--client_host=")) {
clientHost = arg.substring(14);
} else if (arg.startsWith("--context=")) {
contextStr = arg.substring(10);
isDefaultContext = false;
} else if (arg.startsWith("--father_pid=")) {
fatherPid = arg.substring(13);
} else if (arg.startsWith("--root_pid=")) {
rootPid = arg.substring(11);
} else if (arg.startsWith("--father_node=")) {
fatherNode = arg.substring(14);
} else if (arg.startsWith("--pid=")) {
pid = arg.substring(6);
} else if (arg.startsWith("--context_param")) {
String keyValue = arg.substring(16);
int index = -1;
if (keyValue != null && (index = keyValue.indexOf('=')) > -1) {
if (fatherPid == null) {
context_param.put(keyValue.substring(0, index),
replaceEscapeChars(keyValue.substring(index + 1)));
} else { // the subjob won't escape the especial chars
context_param.put(keyValue.substring(0, index),
keyValue.substring(index + 1));
}
}
} else if (arg.startsWith("--log4jLevel=")) {
log4jLevel = arg.substring(13);
}
}
private final String[][] escapeChars = { { "\\\\", "\\" }, { "\\n", "\n" },
{ "\\'", "\'" }, { "\\r", "\r" }, { "\\f", "\f" }, { "\\b", "\b" },
{ "\\t", "\t" } };
private String replaceEscapeChars(String keyValue) {
if (keyValue == null || ("").equals(keyValue.trim())) {
return keyValue;
}
StringBuilder result = new StringBuilder();
int currIndex = 0;
while (currIndex < keyValue.length()) {
int index = -1;
// judege if the left string includes escape chars
for (String[] strArray : escapeChars) {
index = keyValue.indexOf(strArray[0], currIndex);
if (index >= 0) {
result.append(keyValue.substring(currIndex,
index + strArray[0].length()).replace(strArray[0],
strArray[1]));
currIndex = index + strArray[0].length();
break;
}
}
// if the left string doesn't include escape chars, append the left
// into the result
if (index < 0) {
result.append(keyValue.substring(currIndex));
currIndex = currIndex + keyValue.length();
}
}
return result.toString();
}
public Integer getErrorCode() {
return errorCode;
}
public String getStatus() {
return status;
}
ResumeUtil resumeUtil = null;
}
/************************************************************************************************
* 261296 characters generated by Talend Open Studio for Data Integration on the
* 26 mars 2020 14:29:04 CET
************************************************************************************************/