Compare commits
No commits in common. 'master' and 'etl_0.4_Release' have entirely different histories.
master
...
etl_0.4_Re
29 changed files with 113 additions and 2424 deletions
@ -1,47 +0,0 @@
@@ -1,47 +0,0 @@
|
||||
#!/bin/bash |
||||
#Änderungen |
||||
#--------------------------------------------------------------------- |
||||
# Shell-Kommando "etl_execute_unload_job.x" |
||||
# |
||||
#--------------------------------------------------------------------- |
||||
|
||||
if [ "$1" = "" ] |
||||
then echo "Aufruf: etl_execute_unload_job.x job_uniquename FILTER <Ausgabedatei (optional)>" |
||||
echo " " |
||||
echo "Aktion: etl_execute_unload_job.x entlaedt Tabellen." |
||||
echo " Mit Hilfe von etl_execute_upload_job.x koennen diese Daten importiert werden." |
||||
echo " " |
||||
exit 0 |
||||
fi |
||||
|
||||
#------------------------------------------------------------------- |
||||
#-- Metadaten entladen |
||||
#------------------------------------------------------------------- |
||||
|
||||
JOB_UNIQUENAME=$1 |
||||
|
||||
FILTER=$2 |
||||
|
||||
if [ "$3" == "" ] |
||||
then outfile=$JOB_UNIQUENAME.xml |
||||
else |
||||
|
||||
outfile=$3 |
||||
|
||||
fi |
||||
|
||||
|
||||
|
||||
SX_CLIENT=jdbc |
||||
export SX_CLIENT |
||||
CP=".:$JDBC_CLASSPATH" |
||||
|
||||
CMD="java $JAVA_OPTS -cp $CP de.superx.elt.bin.EtlJobExecutor -dbproperties:$DB_PROPERTIES -job:$JOB_UNIQUENAME -outfile:$outfile -params:$FILTER" |
||||
|
||||
echo $CMD |
||||
|
||||
$CMD |
||||
|
||||
|
||||
|
||||
|
||||
@ -1,47 +0,0 @@
@@ -1,47 +0,0 @@
|
||||
#!/bin/bash |
||||
#Änderungen |
||||
#--------------------------------------------------------------------- |
||||
# Shell-Kommando "etl_execute_unload_job.x" |
||||
# |
||||
#--------------------------------------------------------------------- |
||||
|
||||
if [ "$1" = "" ] |
||||
then echo "Aufruf: etl_execute_upload_job.x job_uniquename FILTER <Eingabedatei (optional)>" |
||||
echo " " |
||||
echo "Aktion: etl_execute_upload_job.x laedt Tabellen." |
||||
echo " " |
||||
echo " " |
||||
exit 0 |
||||
fi |
||||
|
||||
#------------------------------------------------------------------- |
||||
#-- Metadaten entladen |
||||
#------------------------------------------------------------------- |
||||
|
||||
JOB_UNIQUENAME=$1 |
||||
|
||||
FILTER=$2 |
||||
|
||||
if [ "$3" == "" ] |
||||
then infile=$JOB_UNIQUENAME.xml |
||||
else |
||||
|
||||
infile=$3 |
||||
|
||||
fi |
||||
|
||||
|
||||
|
||||
SX_CLIENT=jdbc |
||||
export SX_CLIENT |
||||
CP=".:$JDBC_CLASSPATH" |
||||
|
||||
CMD="java $JAVA_OPTS -cp $CP de.superx.elt.bin.EtlJobExecutor -dbproperties:$DB_PROPERTIES -job:$JOB_UNIQUENAME -params:PATH_TO_INPUTFILE=$infile" |
||||
|
||||
echo $CMD |
||||
|
||||
$CMD |
||||
|
||||
|
||||
|
||||
|
||||
@ -1,6 +1,4 @@
@@ -1,6 +1,4 @@
|
||||
doku/etl_modul/etl.html |
||||
WEB-INF/conf/edustore/db/bin/SQL_ENV_etl.sam |
||||
WEB-INF/lib/superx-etl.jar |
||||
images/eye.svg |
||||
images/downloadblck.svg |
||||
|
||||
|
||||
@ -1,22 +0,0 @@
@@ -1,22 +0,0 @@
|
||||
--Freemarker Template |
||||
|
||||
--used in etl-job sx_insert_mask |
||||
<#if SQLdialect='Postgres'> |
||||
drop table if exists tmp_etl_qa_project; |
||||
drop table if exists tmp_etl_sachgeb_sichtarten; |
||||
</#if> |
||||
|
||||
|
||||
|
||||
CREATE TABLE tmp_etl_qa_project( |
||||
|
||||
uniquename VARCHAR(255) , |
||||
name VARCHAR(255) , |
||||
systeminfo_id INTEGER , |
||||
sachgebiete_id INTEGER , |
||||
active SMALLINT , |
||||
created_from INTEGER , |
||||
issue_link VARCHAR(255) |
||||
) |
||||
; |
||||
|
||||
@ -1,49 +0,0 @@
@@ -1,49 +0,0 @@
|
||||
--Freemarker Template |
||||
|
||||
--used in etl-job sx_insert_mask |
||||
<#if SQLdialect='Postgres'> |
||||
drop table if exists tmp_etl_sichten; |
||||
drop table if exists tmp_etl_sachgeb_sichtarten; |
||||
</#if> |
||||
|
||||
|
||||
|
||||
CREATE TABLE tmp_etl_sichten ( |
||||
-- tid integer, |
||||
-- |
||||
-- parent CHAR(255) , |
||||
systeminfoid INTEGER default 0 not null, |
||||
art CHAR(40) , |
||||
type INTEGER default 10 not null, |
||||
name_intern CHAR(200) , |
||||
name CHAR(200) , |
||||
-- beschreibung CHAR(255) , |
||||
sortnr INTEGER default 0 not null, |
||||
quelle TEXT , |
||||
-- alt_hier_id CHAR(150) , |
||||
-- treecfgtable CHAR(255) , |
||||
-- treecfgid CHAR(150) , |
||||
-- label SMALLINT default 0 not null, |
||||
-- user_rechte SMALLINT default 1 not null, |
||||
-- rechtequelle CHAR(255) , |
||||
-- sesamkey CHAR(100) , |
||||
standbutton SMALLINT default 0 not null, |
||||
-- attribut1 CHAR(255) , |
||||
-- attribut2 CHAR(255) , |
||||
-- attribut3 INTEGER , |
||||
-- attribut4 INTEGER , |
||||
-- xmlmaxentries INTEGER , |
||||
-- gueltig_seit DATE default date('01.01.1900') not null, |
||||
-- gueltig_bis DATE default date('01.01.3000') not null, |
||||
-- cacheapplet CHAR(255) , |
||||
-- cachexml CHAR(255) , |
||||
aktiv SMALLINT default 1 |
||||
); |
||||
|
||||
create table tmp_etl_sachgeb_sichtarten( |
||||
sachgebiete_id INTEGER , |
||||
sichtart CHAR(255) |
||||
) |
||||
; |
||||
|
||||
|
||||
@ -1,3 +0,0 @@
@@ -1,3 +0,0 @@
|
||||
1^MASK^Masken^0^sx_select_mask^sx_insert_mask^TID^42000^42006^1^ |
||||
2^SICHT^Sichten^0^sichten_unload^sichten_upload^SYSTEMINFO_ID^42000^42004^1^ |
||||
3^QA_PROJECT^Testfälle^0^qa_project_unload^qa_project_upload^QA_PROJECT_ID^42000^42007^1^ |
||||
@ -1,12 +0,0 @@
@@ -1,12 +0,0 @@
|
||||
--freemarker template |
||||
<sqlvars> |
||||
<sqlvar name="QA_installed"> |
||||
select 1 from xdummy where 0 < (select count(*) from db_version where his_system='qa') |
||||
union select 0 from xdummy where |
||||
0 = (select count(*) from db_version where his_system='qa'); |
||||
</sqlvar> |
||||
</sqlvars> |
||||
|
||||
<#if QA_installed==0> |
||||
update etl_manager_tab set active=0 where uniquename='QA_PROJECT'; |
||||
</#if> |
||||
@ -1,62 +0,0 @@
@@ -1,62 +0,0 @@
|
||||
begin work; |
||||
|
||||
delete from sichten where name_intern in (select name_intern from tmp_sichten); |
||||
|
||||
insert into sichten(parent, |
||||
systeminfoid, |
||||
art, |
||||
type, |
||||
name_intern, |
||||
name, |
||||
beschreibung, |
||||
sortnr, |
||||
quelle, |
||||
alt_hier_id, |
||||
treecfgtable, |
||||
treecfgid, |
||||
label, |
||||
user_rechte, |
||||
rechtequelle, |
||||
sesamkey, |
||||
standbutton, |
||||
attribut1, |
||||
attribut2, |
||||
attribut3, |
||||
attribut4, |
||||
xmlmaxentries, |
||||
gueltig_seit, |
||||
gueltig_bis, |
||||
cacheapplet, |
||||
cachexml, |
||||
aktiv) select parent, |
||||
systeminfoid, |
||||
art, |
||||
type, |
||||
name_intern, |
||||
name, |
||||
beschreibung, |
||||
sortnr, |
||||
quelle, |
||||
alt_hier_id, |
||||
treecfgtable, |
||||
treecfgid, |
||||
label, |
||||
user_rechte, |
||||
rechtequelle, |
||||
sesamkey, |
||||
standbutton, |
||||
attribut1, |
||||
attribut2, |
||||
attribut3, |
||||
attribut4, |
||||
xmlmaxentries, |
||||
gueltig_seit, |
||||
gueltig_bis, |
||||
cacheapplet, |
||||
cachexml, |
||||
aktiv from tmp_sichten; |
||||
|
||||
drop table tmp_sichten; |
||||
|
||||
commit; |
||||
|
||||
@ -1,52 +0,0 @@
@@ -1,52 +0,0 @@
|
||||
begin work; |
||||
|
||||
|
||||
delete from userinfo where benutzer in (select benutzer from tmp_userinfo); |
||||
|
||||
delete from user_institution where userid in (select userid from tmp_user_institution); |
||||
delete from user_masken_bez where userinfo_id in (select userinfo_id from tmp_user_masken_bez); |
||||
delete from user_sachgeb_bez where userinfo_id in (select userinfo_id from tmp_user_sachgeb_bez); |
||||
delete from user_pw where userinfo_id in (select userinfo_id from tmp_user_pw); |
||||
delete from user_sichtarten where userinfo_id in (select userinfo_id from tmp_user_sichtarten); |
||||
delete from user_sichten where userinfo_id in (select userinfo_id from tmp_user_sichten); |
||||
delete from groupinfo where tid in (select tid from tmp_groupinfo); |
||||
|
||||
delete from group_field_pref where groupinfo_id in (select groupinfo_id from tmp_group_field_pref); |
||||
delete from group_masken_bez where groupinfo_id in (select groupinfo_id from tmp_group_masken_bez); |
||||
delete from group_sachgeb_bez where groupinfo_id in (select groupinfo_id from tmp_group_sachgeb_bez); |
||||
delete from group_sichtarten where groupinfo_id in (select groupinfo_id from tmp_group_sichtarten); |
||||
delete from group_sichten where groupinfo_id in (select groupinfo_id from tmp_group_sichten); |
||||
delete from user_group_bez where groupinfo_id in (select groupinfo_id from tmp_user_group_bez); |
||||
|
||||
|
||||
insert into userinfo select * from tmp_userinfo ; |
||||
insert into user_institution select * from tmp_user_institution ; |
||||
insert into user_masken_bez select * from tmp_user_masken_bez ; |
||||
insert into user_sachgeb_bez select * from tmp_user_sachgeb_bez ; |
||||
insert into user_pw select * from tmp_user_pw ; |
||||
insert into user_sichtarten select * from tmp_user_sichtarten ; |
||||
insert into user_sichten select * from tmp_user_sichten ; |
||||
insert into groupinfo select * from tmp_groupinfo ; |
||||
insert into group_field_pref select * from tmp_group_field_pref ; |
||||
insert into group_masken_bez select * from tmp_group_masken_bez ; |
||||
insert into group_sachgeb_bez select * from tmp_group_sachgeb_bez ; |
||||
insert into group_sichtarten select * from tmp_group_sichtarten; |
||||
insert into group_sichten select * from tmp_group_sichten ; |
||||
insert into user_group_bez select * from tmp_user_group_bez ; |
||||
|
||||
drop table tmp_userinfo; |
||||
drop table tmp_user_institution; |
||||
drop table tmp_user_masken_bez; |
||||
drop table tmp_user_sachgeb_bez; |
||||
drop table tmp_user_pw; |
||||
drop table tmp_user_sichtarten; |
||||
drop table tmp_user_sichten; |
||||
drop table tmp_groupinfo; |
||||
drop table tmp_group_field_pref; |
||||
drop table tmp_group_masken_bez; |
||||
drop table tmp_group_sachgeb_bez; |
||||
drop table tmp_group_sichtarten; |
||||
drop table tmp_group_sichten; |
||||
drop table tmp_user_group_bez; |
||||
|
||||
commit; |
||||
File diff suppressed because it is too large
Load Diff
@ -1,61 +0,0 @@
@@ -1,61 +0,0 @@
|
||||
|
||||
update sichten set systeminfoid=T.systeminfoid, |
||||
art=T.art, |
||||
type=T.type, |
||||
name=T.name, |
||||
quelle=T.quelle , |
||||
sortnr=T.sortnr, |
||||
standbutton=T.standbutton, |
||||
aktiv=T.aktiv |
||||
|
||||
from tmp_etl_sichten T |
||||
where T.name_intern=sichten.name_intern |
||||
and sichten.name_intern in (select T2.name_intern from tmp_etl_sichten T2) |
||||
; |
||||
|
||||
delete from tmp_etl_sichten where name_intern in (select name_intern from sichten); |
||||
|
||||
INSERT INTO sichten( |
||||
systeminfoid , |
||||
art , |
||||
type , |
||||
name_intern , |
||||
name , |
||||
sortnr , |
||||
quelle , |
||||
standbutton , |
||||
gueltig_seit , |
||||
gueltig_bis , |
||||
aktiv) |
||||
select systeminfoid , |
||||
art , |
||||
type , |
||||
name_intern , |
||||
name , |
||||
sortnr , |
||||
quelle , |
||||
standbutton , |
||||
date_val('01.01.1900') as gueltig_seit , |
||||
date_val('01.01.3000') as gueltig_bis , |
||||
aktiv |
||||
from tmp_etl_sichten S; |
||||
|
||||
|
||||
delete from sachgeb_sichtarten |
||||
where (sachgebiete_id , |
||||
sichtart) in |
||||
(select sachgebiete_id , |
||||
sichtart from tmp_etl_sachgeb_sichtarten); |
||||
|
||||
insert into sachgeb_sichtarten( |
||||
sachgebiete_id , |
||||
sichtart) |
||||
select |
||||
sachgebiete_id , |
||||
sichtart |
||||
from tmp_etl_sachgeb_sichtarten; |
||||
|
||||
|
||||
drop table if exists tmp_etl_sichten; |
||||
drop table if exists tmp_etl_sachgeb_sichtarten; |
||||
|
||||
@ -1,42 +0,0 @@
@@ -1,42 +0,0 @@
|
||||
|
||||
--obsolete jobs: |
||||
|
||||
delete from etl_step |
||||
where tid in (select R.step_id |
||||
from etl_step_relation R, etl_job J |
||||
where R.job_id =J.tid |
||||
and J.uniquename in ('sx_select_mask', |
||||
'sx_insert_mask', |
||||
'kern_konstanten_update', |
||||
'sichten_unload', |
||||
'sos_gewichtung_unload') |
||||
and J.systeminfo_id=9); |
||||
|
||||
delete from etl_step_property |
||||
where etl_step_id in (select R.step_id |
||||
from etl_step_relation R, etl_job J |
||||
where R.job_id =J.tid |
||||
and J.uniquename in ('sx_select_mask', |
||||
'sx_insert_mask', |
||||
'kern_konstanten_update', |
||||
'sichten_unload', |
||||
'sos_gewichtung_unload') |
||||
and J.systeminfo_id=9); |
||||
|
||||
delete from etl_step_relation |
||||
where job_id in (select J.tid from etl_job J |
||||
where J.uniquename in ('sx_select_mask', |
||||
'sx_insert_mask', |
||||
'kern_konstanten_update', |
||||
'sichten_unload', |
||||
'sos_gewichtung_unload') |
||||
and J.systeminfo_id=9); |
||||
|
||||
delete from etl_job |
||||
where uniquename in ('sx_select_mask', |
||||
'sx_insert_mask', |
||||
'kern_konstanten_update', |
||||
'sichten_unload', |
||||
'sos_gewichtung_unload') |
||||
and systeminfo_id=9; |
||||
|
||||
@ -1,213 +0,0 @@
@@ -1,213 +0,0 @@
|
||||
/* |
||||
* de.superx.etl - a package for controlling ETL routines |
||||
* Copyright (C) 2021 Daniel Quathamer <danielq@memtext.de> |
||||
* |
||||
* This package is licensed under the CampusSource License; |
||||
* http://www.campussource.de/org/license/
|
||||
*/ |
||||
package de.superx.sxrest; |
||||
import javax.ws.rs.Consumes; |
||||
import javax.ws.rs.DELETE; |
||||
import javax.ws.rs.FormParam; |
||||
import javax.ws.rs.GET; |
||||
import javax.ws.rs.HEAD; |
||||
import javax.ws.rs.POST; |
||||
import javax.ws.rs.PUT; |
||||
import javax.ws.rs.Path; |
||||
import javax.ws.rs.PathParam; |
||||
import javax.ws.rs.core.Response; |
||||
import javax.xml.parsers.ParserConfigurationException; |
||||
import javax.xml.xpath.XPath; |
||||
import javax.xml.xpath.XPathConstants; |
||||
import javax.xml.xpath.XPathExpressionException; |
||||
import javax.xml.xpath.XPathFactory; |
||||
|
||||
|
||||
import org.w3c.dom.Document; |
||||
import org.w3c.dom.Node; |
||||
import org.w3c.dom.NodeList; |
||||
import org.xml.sax.SAXException; |
||||
|
||||
import javax.ws.rs.Produces; |
||||
import javax.ws.rs.QueryParam; |
||||
import javax.ws.rs.core.Context; |
||||
import javax.ws.rs.core.MediaType; |
||||
import javax.ws.rs.core.Request; |
||||
import de.memtext.util.DateUtils; |
||||
import de.superx.common.SxUser; |
||||
import de.superx.elt.EtlActionJob; |
||||
import de.superx.elt.EtlUtils; |
||||
import de.superx.servlet.SuperXManager; |
||||
|
||||
import java.io.BufferedWriter; |
||||
import java.io.File; |
||||
import java.io.FileWriter; |
||||
import java.io.IOException; |
||||
|
||||
import javax.servlet.http.HttpServletRequest; |
||||
|
||||
|
||||
@Path("/jobetlxml/get/{jobUniquename}/{jobParamName}") |
||||
|
||||
|
||||
public class JobEtlXml { |
||||
@Context |
||||
Request request; |
||||
|
||||
|
||||
@GET |
||||
@Path("/view/{param}") |
||||
@Produces(MediaType.APPLICATION_XML) |
||||
|
||||
public Document printXml(@PathParam("jobUniquename") String jobUniquename, |
||||
@PathParam("jobParamName") String jobParamName, |
||||
@PathParam("param") String param, |
||||
@Context HttpServletRequest request) { |
||||
String returntext=""; |
||||
returntext = getJobEtlXml(jobUniquename,jobParamName, param, request); |
||||
|
||||
return de.memtext.util.XMLUtils.buildDocumentFromString(returntext, false); |
||||
} |
||||
private String getJobEtlXml(String jobUniquename, |
||||
String jobParamName, |
||||
String param, |
||||
HttpServletRequest request) { |
||||
String returntext; |
||||
SxUser user = (SxUser) request.getSession().getAttribute("user"); |
||||
//TODO: valide Einträge prüfen:
|
||||
//ebenso param
|
||||
System.out.println("JOB"+jobUniquename + " mit param "+jobParamName); |
||||
String mandantenid= (String) request.getSession().getAttribute("MandantenID"); |
||||
if(mandantenid==null || mandantenid.equals("")) |
||||
mandantenid="default"; |
||||
|
||||
if (user == null || !user.isAdmin()) { |
||||
returntext="Fehlende Rechte"; |
||||
} |
||||
else |
||||
{ |
||||
|
||||
int returnCode=0; |
||||
EtlActionJob myJob=new EtlActionJob(jobUniquename); //TODO:Mandantid
|
||||
try { |
||||
myJob.initJob(jobUniquename,jobParamName+"="+param); |
||||
} catch (Exception e) { |
||||
// TODO Auto-generated catch block
|
||||
|
||||
returntext=e.toString(); |
||||
returntext+=myJob.getLogoutput(); |
||||
|
||||
} |
||||
System.out.println("Job "+ jobUniquename+" initialized"); |
||||
try { |
||||
returnCode= myJob.execute(""); |
||||
returntext=myJob.getSw().toString(); |
||||
|
||||
} catch (Exception e) { |
||||
// TODO Auto-generated catch block
|
||||
returntext=e.toString(); |
||||
returntext+=myJob.getLogoutput(); |
||||
} |
||||
} |
||||
return returntext; |
||||
} |
||||
@GET |
||||
@Path("/download/{param}") |
||||
@Produces(MediaType.APPLICATION_XML) |
||||
public String createDownloadXml( |
||||
@PathParam("jobUniquename") String jobUniquename, |
||||
@PathParam("jobParamName") String jobParamName, |
||||
@PathParam("param") String param, |
||||
@Context HttpServletRequest request) { |
||||
String returntext=""; |
||||
returntext = getJobEtlXml(jobUniquename,jobParamName,param, request); |
||||
return returntext; |
||||
//return de.memtext.util.XMLUtils.buildDocumentFromString(returntext, false);
|
||||
} |
||||
/* Aktuell noch nicht genutzt: */ |
||||
@GET |
||||
@Path("/saveget/{params}") |
||||
@Produces(MediaType.TEXT_PLAIN) |
||||
|
||||
|
||||
public String saveGetXml(@QueryParam("param") String tid, |
||||
@QueryParam("Inhalt") String src, |
||||
@Context HttpServletRequest request) { |
||||
String returntext=""; |
||||
SxUser user = (SxUser) request.getSession().getAttribute("user"); |
||||
String mandantenid= (String) request.getSession().getAttribute("MandantenID"); |
||||
if(mandantenid==null || mandantenid.equals("")) |
||||
mandantenid="default"; |
||||
|
||||
if (user == null || !user.isAdmin()) { |
||||
returntext="Fehlende Rechte"; |
||||
} |
||||
else |
||||
{ |
||||
returntext="tid="+tid+"-src="+src; |
||||
} |
||||
|
||||
return returntext; |
||||
} |
||||
/* Aktuell noch nicht genutzt: */ |
||||
@POST |
||||
@Path("/save") |
||||
@Consumes("application/x-www-form-urlencoded") |
||||
//@Consumes(MediaType.APPLICATION_FORM_URLENCODED)
|
||||
@Produces(MediaType.TEXT_PLAIN) |
||||
|
||||
public String saveXml(@FormParam("tid") String tid, |
||||
@FormParam("Inhalt") String src, |
||||
@Context HttpServletRequest request) { |
||||
String returntext=""; |
||||
String jobuniquename="sx_select_mask"; |
||||
int returnCode=0; |
||||
tid="16000"; |
||||
SxUser user = (SxUser) request.getSession().getAttribute("user"); |
||||
String mandantenid= (String) request.getSession().getAttribute("MandantenID"); |
||||
String searchString="/etlAction[@name=\""+jobuniquename+"\"]/unload[@name=\"unload_maskeninfo\"]/rs/row/fld[@name=\"tid\"]"; |
||||
if(mandantenid==null || mandantenid.equals("")) |
||||
mandantenid="default"; |
||||
|
||||
if (user == null || !user.isAdmin()) { |
||||
returntext="Fehlende Rechte"; |
||||
|
||||
} |
||||
else |
||||
{ |
||||
try { |
||||
if(de.superx.elt.EtlUtils.isNodeValueInXml(src,searchString,tid,jobuniquename)) |
||||
{ |
||||
String job="sx_insert_mask"; |
||||
returntext="TID="+tid; |
||||
String params="TID="+tid; |
||||
File temp; |
||||
temp = File.createTempFile("myTempFile", ".xml"); |
||||
|
||||
BufferedWriter bw = new BufferedWriter(new FileWriter(temp)); |
||||
bw.write(src); |
||||
|
||||
bw.close(); |
||||
params+=EtlUtils.NEWLINE+"PATH_TO_INPUTFILE="+temp.getAbsolutePath(); |
||||
params+=EtlUtils.NEWLINE+"FORMAT=XML"; |
||||
EtlActionJob myJob=new EtlActionJob(job); //TODO:Mandantid
|
||||
myJob.initJob(job,params); |
||||
returnCode= myJob.execute(""); |
||||
returntext=myJob.getSw().toString(); |
||||
|
||||
|
||||
|
||||
} |
||||
else |
||||
returntext="Übergebene TID "+tid+" entspricht nicht der XML-Datei "; |
||||
} catch (Exception e) { |
||||
returntext=e.toString(); |
||||
e.printStackTrace(); |
||||
} |
||||
|
||||
|
||||
} |
||||
return returntext; |
||||
} |
||||
|
||||
} |
||||
Binary file not shown.
@ -1,143 +0,0 @@
@@ -1,143 +0,0 @@
|
||||
<%@ taglib uri="/WEB-INF/dbforms.tld" prefix="db" %> |
||||
<%@page pageEncoding="utf-8" contentType="text/html; charset=UTF-8" %> |
||||
<%@ page import ="de.superx.servlet.ServletUtils" %> |
||||
<%@ page import ="de.superx.servlet.SxPools" %> |
||||
<%@ page import ="java.io.BufferedWriter" %> |
||||
<%@ page import ="java.io.File" %> |
||||
<%@ page import ="java.io.FileWriter" %> |
||||
<%@ page import ="java.io.IOException" %> |
||||
<%@ page import ="de.superx.elt.EtlActionJob" %> |
||||
<%@ page import ="de.superx.elt.EtlUtils" %> |
||||
<%@ page import ="de.superx.common.SxUser" %> |
||||
<html> |
||||
|
||||
<head> |
||||
<meta charset="utf-8"> |
||||
<meta http-equiv="X-UA-Compatible" content="IE=edge"> |
||||
<meta name="viewport" content="width=device-width, initial-scale=1"> |
||||
<title>Ausführung</title> |
||||
<link rel="stylesheet" href="../../style/bulma.css" /> |
||||
<script type="text/javascript" src="/superx/xml/js/memtext/sx_functions.js"></script> |
||||
</head> |
||||
|
||||
<body> |
||||
<% |
||||
//init Variables: |
||||
if (request.getCharacterEncoding() == null) |
||||
request.setCharacterEncoding("UTF-8"); |
||||
|
||||
String idparamName = request.getParameter("idparamName"); |
||||
String idparamValue = request.getParameter("idparamValue"); |
||||
String src = request.getParameter("src"); |
||||
String jobuniquename = request.getParameter("jobuniquename"); |
||||
String returntext=""; |
||||
int returnCode=0; |
||||
returntext=src; |
||||
|
||||
SxUser user = (SxUser) request.getSession().getAttribute("user"); |
||||
String mandantenid= (String) request.getSession().getAttribute("MandantenID"); |
||||
//String searchString="/etlAction[@name=\""+jobuniquename+"\"]/unload[@name=\"unload_maskeninfo\"]/rs/row/fld[@name=\"tid\"]"; |
||||
if(mandantenid==null || mandantenid.equals("")) |
||||
mandantenid="default"; |
||||
|
||||
if (user == null || !user.isAdmin()) { |
||||
returnCode=1; |
||||
returntext="Fehlende Rechte"; |
||||
|
||||
} |
||||
else |
||||
{ |
||||
try { |
||||
//if(de.superx.elt.EtlUtils.isNodeValueInXml(src,searchString,idparamValue,jobuniquename)) |
||||
//{ |
||||
|
||||
returntext=idparamName+"="+idparamValue; |
||||
String params=idparamName+"="+idparamValue; |
||||
File temp; |
||||
temp = File.createTempFile("myTempFile", ".xml"); |
||||
|
||||
BufferedWriter bw = new BufferedWriter(new FileWriter(temp)); |
||||
bw.write(src); |
||||
|
||||
bw.close(); |
||||
params+=EtlUtils.NEWLINE+"PATH_TO_INPUTFILE="+temp.getAbsolutePath(); |
||||
params+=EtlUtils.NEWLINE+"FORMAT=XML"; |
||||
EtlActionJob myJob=new EtlActionJob(jobuniquename); //TODO:Mandantid |
||||
myJob.initJob(jobuniquename,params); |
||||
returnCode= myJob.execute(""); |
||||
returntext+=myJob.getActionLog().toString(); |
||||
|
||||
|
||||
|
||||
/*} |
||||
else |
||||
{ |
||||
returntext="Übergebener Parameter "+idparamName+" Wert "+idparamValue+" entspricht nicht der XML-Datei "; |
||||
returnCode=1; |
||||
}*/ |
||||
} catch (Exception e) { |
||||
returnCode=1; |
||||
returntext=e.toString(); |
||||
e.printStackTrace(); |
||||
} |
||||
|
||||
|
||||
} |
||||
%> |
||||
<!-- START NAV --> |
||||
<nav class="navbar is-white"> |
||||
<div class="container"> |
||||
<div class="navbar-brand"> |
||||
|
||||
Masken laden |
||||
|
||||
<div class="navbar-burger burger" data-target="navMenu"> |
||||
<span>dd</span> |
||||
<span>dd</span> |
||||
<span>dd</span> |
||||
</div> |
||||
</div> |
||||
<!-- <div id="navMenu" class="navbar-menu"> |
||||
<div class="navbar-start"> |
||||
<a class="navbar-item" href="webapp_manager.jsp?tab=inst"> |
||||
Installation /Patches |
||||
</a> |
||||
<a class="navbar-item" href="webapp_manager.jsp?tab=load"> |
||||
Konnektoren |
||||
</a>--> |
||||
<a class="navbar-item" href="javascript:window.close()"> |
||||
Schließen |
||||
</a> |
||||
|
||||
</div> |
||||
|
||||
</div> |
||||
</div> |
||||
</nav> |
||||
<!-- END NAV --> |
||||
|
||||
<section class="section"> |
||||
<div class="container"> |
||||
|
||||
<h1 class="title" id="MaskHeader">Protokoll</h1> |
||||
<h2 class="subtitle"> |
||||
<div id="MaskSubHeader">Ergebnis der Ausführung</div> |
||||
</h2> |
||||
<p>Status: <%="Code "+ returnCode+ "("+de.superx.elt.EtlUtils.translateReturnCode2Html(returnCode)+")"%>, Logausgabe: |
||||
</p> |
||||
<div class="bd-snippet-code highlight-full "> |
||||
<figure class="highlight"><div class="buttons has-addons is-right"> |
||||
<button class="button is-small is-info" onClick="copyText('Inhalt');">Kopieren</button> |
||||
</div> |
||||
<textarea id="Inhalt" name="Inhalt" class="textarea" placeholder="Inhalt..." rows="20"><%= returntext %> |
||||
</textarea> |
||||
|
||||
|
||||
</figure> |
||||
</div> |
||||
|
||||
</div> |
||||
</section> |
||||
</body> |
||||
|
||||
</html> |
||||
Loading…
Reference in new issue