384 lines
12 KiB
Groovy
Executable File
384 lines
12 KiB
Groovy
Executable File
import com.dvelop.d3.server.Document
|
|
import com.dvelop.d3.server.core.D3Interface
|
|
import com.dvelop.d3.server.exceptions.SQLException
|
|
import com.dvelop.d3.server.exceptions.D3Exception
|
|
import groovy.transform.Field
|
|
|
|
|
|
|
|
D3Interface d3 = getProperty( "d3" );
|
|
|
|
@Field prg = "anlegen_equipm_akten.groovy";
|
|
@Field version = "0.1";
|
|
@Field kunde = "Optima";
|
|
|
|
|
|
//////////////////////////////////////////////////////////////////////////////////////////
|
|
|
|
|
|
|
|
|
|
// debug:
|
|
// 0 => es finden Änderungen am Datenbestand statt
|
|
// 1 => es finden keine Änderungen am Datenbestand statt
|
|
@Field debug = 0;
|
|
|
|
|
|
// Dokumente pro Durchlauf
|
|
// Gibt an, wie viele Dokumente maximal pro Durchlauf verarbeitet werden
|
|
@Field dokumente_pro_durchlauf = 1000000;
|
|
|
|
|
|
|
|
|
|
//////////////////////////////////////////////////////////////////////////////////////////
|
|
|
|
def debugtext;
|
|
|
|
switch ( debug )
|
|
{
|
|
case 0:
|
|
debugtext = "ausgeschaltet";
|
|
break;
|
|
default:
|
|
debugtext = "eingeschaltet (keine Aenderungen am Datenbestand)";
|
|
break;
|
|
}
|
|
|
|
def aktengruppe = ['AG101', 'AG102', 'AG103'];
|
|
//def aktengruppe = ['Projektorganisation', 'Spezifikation', 'Technik'];
|
|
|
|
def ag_sortmap = [ "AG101":"50", "AG102":"60", "AG103":"70" ];
|
|
def ua_sortmap = [ "AK029":"51", "AK007":"52", "AK008":"53", "AK016":"54", "AK003":"55", "AK024":"61", "AK012":"62", "AK013":"63", "AK028":"64", "AK006":"71", "AK018":"72", "AK015":"73", "AK001":"74", "AK020":"75", "AK023":"76", "AK019":"77" ];
|
|
|
|
|
|
xlog( d3, 4, "********************************************************" );
|
|
xlog( d3, 4, "* Programm : " + prg );
|
|
xlog( d3, 4, "* Version : " + version );
|
|
xlog( d3, 4, "* Kunde : " + kunde );
|
|
xlog( d3, 4, "* geschrieben von : calb / d.velop AG" );
|
|
xlog( d3, 4, "* (c) d.velop AG " );
|
|
xlog( d3, 4, "********************************************************" );
|
|
|
|
xlog( d3, 4, "Parameter: " );
|
|
xlog( d3, 4, "* Debug : " + debugtext );
|
|
xlog( d3, 4, "* Dokumente pro Durchlauf : " + dokumente_pro_durchlauf );
|
|
|
|
|
|
xlog( d3, 4, "********************************************************" );
|
|
|
|
def sqlQuery = "select top " + dokumente_pro_durchlauf + " doku_id, dok_dat_feld_9 from firmen_spezifisch where kue_dokuart = 'AEQUI'";
|
|
|
|
resultRows = d3.sql.executeAndGet( (String) sqlQuery );
|
|
|
|
|
|
|
|
|
|
if ( resultRows.size() > 0 )
|
|
{
|
|
xlog( d3, 4, " Es wurden " + resultRows.size() + " Treffer gefunden." );
|
|
xlog( d3, 4, "********************************************************" );
|
|
|
|
def i = 0;
|
|
def allesgut = true;
|
|
|
|
|
|
for ( i = 0; i < resultRows.size(); i++ )
|
|
{
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Equipmentakte Doku-ID " + resultRows[ i ].doku_id + " / E-Nr. " + resultRows[ i ].dok_dat_feld_9 );
|
|
xlog( d3, 4, "*************************************" );
|
|
// Lade Equipment:
|
|
|
|
def eq_akte = d3.archive.getDocument( resultRows[ i ].doku_id );
|
|
|
|
// Lege die Aktengruppe-Akten an:
|
|
|
|
def doku_id_eq;
|
|
|
|
aktengruppe.each
|
|
{
|
|
//xlog( d3, 3, "Nr. " + (i+1) + ": Aktengruppe. " + it );
|
|
|
|
// Prüfen, ob diee Aktengruppe bereits für dieses Equipment existiert
|
|
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": pruefe: Equpmentaktegruppe | DDF16 = " + it + " | DDF9 = " + eq_akte.field[ 9 ] );
|
|
|
|
def STATEMENT_1 = "select doku_id from firmen_spezifisch where kue_dokuart = 'AEQE1' and dok_dat_feld_9 = '" + eq_akte.field[ 9 ] + "' and dok_dat_feld_16 = '" + it + "'";
|
|
|
|
xlog( d3, 5, "Nr. " + (i+1) + ": " + STATEMENT_1 );
|
|
|
|
def ergebnis_1 = d3.sql.executeAndGet( STATEMENT_1 );
|
|
|
|
if ( ergebnis_1.size() == 0 )
|
|
{
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Equipmentaktengruppe. " + it + " existiert nicht. Lege Aktengruppe an ..." )
|
|
Document neue_akte = d3.archive.newDocument();
|
|
|
|
neue_akte.type = "AEQE1";
|
|
neue_akte.status = Document.DocStatus.DOC_STAT_RELEASE;
|
|
//neue_akte.editor = "d3tadm";
|
|
|
|
neue_akte.field[ 9 ] = eq_akte.field[ 9 ]; // Equipmentnummer
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Equipmentnummer : " + neue_akte.field[ 9 ] );
|
|
neue_akte.field[ 22 ] = eq_akte.field[ 22 ]; // Kundennummer
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Kundennummer : " + neue_akte.field[ 22 ] );
|
|
neue_akte.field[ 36 ] = eq_akte.field[ 36 ]; // Linie
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Linie : " + neue_akte.field[ 36 ] );
|
|
neue_akte.field[ 12 ] = eq_akte.field[ 12 ]; // Netzplan_Nr
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Netzplan_Nr : " + neue_akte.field[ 12 ] );
|
|
neue_akte.field[ 19 ] = eq_akte.field[ 19 ]; // Projekt-Nr
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Projekt-Nr : " + neue_akte.field[ 19 ] );
|
|
neue_akte.field[ 2 ] = eq_akte.field[ 2 ]; // PSP-Element
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": PSP-Element : " + neue_akte.field[ 2 ] );
|
|
neue_akte.field[ 1 ] = eq_akte.field[ 1 ]; // SAP-Status
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": SAP-Status : " + neue_akte.field[ 1 ] );
|
|
neue_akte.field[ 40 ] = eq_akte.field[ 40 ]; // Beschreibung
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Beschreibung : " + neue_akte.field[ 40 ] );
|
|
neue_akte.field[ 28 ] = eq_akte.field[ 28 ]; // Buchungskreis
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Buchungskreis : " + neue_akte.field[ 28 ] );
|
|
neue_akte.field[ 35 ] = eq_akte.field[ 35 ]; // Equipmenttyp
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Equipmenttyp : " + neue_akte.field[ 35 ] );
|
|
neue_akte.field[ 23 ] = eq_akte.field[ 23 ]; // Kunden_Name
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Kunden_Name : " + neue_akte.field[ 23 ] );
|
|
neue_akte.field[ 37 ] = eq_akte.field[ 37 ]; // Submission
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Submission : " + neue_akte.field[ 37 ] );
|
|
neue_akte.field[ 3 ] = eq_akte.field[ 3 ]; // Prozess
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Prozess : " + neue_akte.field[ 3 ] );
|
|
neue_akte.field[ 16 ] = it; // Aktengruppe
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Aktengruppe : " + it );
|
|
neue_akte.field[ 30 ] = ag_sortmap[ it ] ; // Sortierreihenfolge
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Sortierreihenfolge : " + neue_akte.field[ 30 ] );
|
|
|
|
|
|
//xlog( d3, 4, "Nr. " + (i+1) + ": Setze Mehrfachfelder Regionalorganisation und Intercompany ..." );
|
|
|
|
for ( int j = 1; j <= Integer.valueOf( d3.config.value( "CUR_60er_FIELD_NR" ) ); j++ )
|
|
{
|
|
neue_akte.field[ 68 ][ j ] = eq_akte.field[ 68 ][ j ]; // Intercompany
|
|
neue_akte.field[ 67 ][ j ] = eq_akte.field[ 67 ][ j ]; // Regionalorganisation
|
|
}
|
|
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Setze Mehrfachfelder Regionalorganisation und Intercompany => fertig." );
|
|
|
|
allesgut = true;
|
|
|
|
try
|
|
{
|
|
if ( debug == 0 )
|
|
{
|
|
neue_akte = d3.archive.importDocument( neue_akte );
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Aktengruppe. " + it + " angelegt mit Doku-ID " + neue_akte.id() );
|
|
doku_id_eq = neue_akte.id();
|
|
}
|
|
else
|
|
{
|
|
xlog( d3, 3, "Nr. " + (i+1) + ": keine Aktenanlage, da DEBUG-Modus eingeschaltet. " );
|
|
}
|
|
}
|
|
catch ( D3Exception e )
|
|
{
|
|
xlog( d3, 2, "Nr. " + (i+1) + ": Akte konnte nicht angelegt werden: " + e.message )
|
|
allesgut = false;
|
|
}
|
|
|
|
|
|
}
|
|
else
|
|
{
|
|
xlog( d3, 3, "Nr. " + (i+1) + ": Aktengruppe " + it + " existiert mit Doku-ID " + ergebnis_1[ 0 ].doku_id + ". Keine Aktion erforderlich." )
|
|
doku_id_eq = ergebnis_1[ 0 ].doku_id;
|
|
}
|
|
|
|
if ( allesgut )
|
|
{
|
|
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Doku_id Equipmentaktengruppe: " + doku_id_eq );
|
|
xlog( d3, 4, "*************************************" );
|
|
// Lege nun die Unterakten an:
|
|
|
|
// Feststellen, welche Unterakten angelegt werden müssen:
|
|
def STATEMENT_2 = "select dok_dat_feld_26 from firmen_spezifisch where kue_dokuart = 'aafol' and dok_dat_feld_45 = 'DEQUI' and dok_dat_feld_48 = '" + it + "' ";
|
|
|
|
def ergebnis_2 = d3.sql.executeAndGet( STATEMENT_2 );
|
|
|
|
if ( ergebnis_2.size() > 0 )
|
|
{
|
|
for ( int m = 0; m < ergebnis_2.size(); m++ )
|
|
{
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": pruefe: Equpmentunterakte | DDF16 = " + it + " | DDF9 = " + eq_akte.field[ 9 ] + " | DDF48 = " + ergebnis_2[ m ].dok_dat_feld_26 );
|
|
|
|
// Feststellen, ob die Unterakte bereits existiert
|
|
|
|
def STATEMENT_3 = " select doku_id from firmen_spezifisch where kue_dokuart = 'AEQE2' and dok_dat_feld_16 = '" + it + "' and dok_dat_feld_9 = '" + eq_akte.field[ 9 ] + "' and dok_dat_feld_48 = '" + ergebnis_2[ m ].dok_dat_feld_26 + "'";
|
|
xlog( d3, 5, "Nr. " + (i+1) + ": Statement zum Test ob Unterakte existiert: " + STATEMENT_3 );
|
|
|
|
def ergebnis_3 = d3.sql.executeAndGet( STATEMENT_3 );
|
|
|
|
if ( ergebnis_3.size() == 0 )
|
|
{
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Equipmentunterakte " + it + " / " + ergebnis_2[ m ].dok_dat_feld_26 + " existiert nicht. Lege Equipmentunterakte an ..." )
|
|
Document eua = d3.archive.newDocument();
|
|
|
|
eua.type = "AEQE2";
|
|
//eua.status = Document.DocStatus.DOC_STAT_PROCESSING;
|
|
eua.status = Document.DocStatus.DOC_STAT_RELEASE;
|
|
//eua.editor = "d3tadm";
|
|
|
|
eua.field[ 9 ] = eq_akte.field[ 9 ]; // Equipmentnummer
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Equipmentnummer : " + eq_akte.field[ 9 ] );
|
|
eua.field[ 16 ] = it; // Aktengruppe
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Aktengruppe : " + it );
|
|
eua.field[ 48 ] = ergebnis_2[ m ].dok_dat_feld_26; // Akte
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Akte : " + ergebnis_2[ m ].dok_dat_feld_26 );
|
|
eua.field[ 30 ] = ua_sortmap[ ergebnis_2[ m ].dok_dat_feld_26 ] ; // Sortierreihenfolge
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Sortierreihenfolge: " + eua.field[ 30 ] );
|
|
|
|
|
|
try
|
|
{
|
|
if ( debug == 0 )
|
|
{
|
|
eua = d3.archive.importDocument( eua );
|
|
xlog( d3, 4, "Nr. " + (i+1) + ": Equipmentunterakte " + eua.field[ 16 ] + " / Akte " + eua.field[ 48 ] + " angelegt mit Doku-ID " + eua.id() );
|
|
}
|
|
else
|
|
{
|
|
xlog( d3, 3, "Nr. " + (i+1) + ": keine Aktenanlage, da DEBUG-Modus eingeschaltet. " );
|
|
}
|
|
}
|
|
catch ( D3Exception e )
|
|
{
|
|
xlog( d3, 2, "Nr. " + (i+1) + ": Equipmentunterakte konnte nicht angelegt werden: " + e.message )
|
|
}
|
|
|
|
xlog( d3, 4, "***************************" );
|
|
|
|
}
|
|
else
|
|
{
|
|
xlog( d3, 3, "Nr. " + (i+1) + ": Kombination existiert bereits mit Doku-ID " + ergebnis_3[ 0 ].doku_id );
|
|
}
|
|
|
|
}
|
|
}
|
|
else
|
|
{
|
|
xlog( d3, 2, "Nr. " + (i+1) + ": keine Unterakten fuer " + it + " gefunden." );
|
|
}
|
|
}
|
|
|
|
|
|
xlog( d3, 4, "*************************************" );
|
|
}
|
|
|
|
|
|
|
|
}
|
|
|
|
xlog( d3, 4, "*************************************************" );
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
def xlog( D3Interface d3, int loglevel, String logtext )
|
|
{
|
|
def logdatei = "d:\\d3\\logs\\" + prg + ".txt";
|
|
def g_loglevel = 4;
|
|
def g_logdirect = "BEIDE";
|
|
|
|
def date = new Date();
|
|
def zeitstempel = date.format( "yyyy.MM.dd HH:mm:ss", TimeZone.getTimeZone('CET') );
|
|
def loglevel_lang = "[INFO ]";
|
|
|
|
|
|
|
|
if ( loglevel <= g_loglevel )
|
|
{
|
|
switch ( loglevel )
|
|
{
|
|
case 1:
|
|
loglevel_lang = "[FATAL]";
|
|
if ( ( g_logdirect == "D3LOG" ) || ( g_logdirect == "BEIDE" ) )
|
|
{
|
|
d3.log.critical( logtext );
|
|
}
|
|
break;
|
|
case 2:
|
|
loglevel_lang = "[ERROR]";
|
|
if ( ( g_logdirect == "D3LOG" ) || ( g_logdirect == "BEIDE" ) )
|
|
{
|
|
d3.log.error( logtext );
|
|
}
|
|
break;
|
|
case 3:
|
|
loglevel_lang = "[WARN ]";
|
|
if ( ( g_logdirect == "D3LOG" ) || ( g_logdirect == "BEIDE" ) )
|
|
{
|
|
d3.log.warn( logtext );
|
|
}
|
|
break;
|
|
case 4:
|
|
loglevel_lang = "[INFO ]";
|
|
if ( ( g_logdirect == "D3LOG" ) || ( g_logdirect == "BEIDE" ) )
|
|
{
|
|
d3.log.info( logtext );
|
|
}
|
|
break;
|
|
case 5:
|
|
loglevel_lang = "[DEBUG]";
|
|
if ( ( g_logdirect == "D3LOG" ) || ( g_logdirect == "BEIDE" ) )
|
|
{
|
|
d3.log.debug( logtext );
|
|
}
|
|
break;
|
|
}
|
|
|
|
if ( ( g_logdirect == "DATEI" ) || ( g_logdirect == "BEIDE" ) )
|
|
{
|
|
new File( logdatei ).append( zeitstempel + " " + loglevel_lang + " " + logtext + "\n", "UTF8" );
|
|
}
|
|
|
|
|
|
return 0;
|
|
}
|
|
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|