import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Calendar;
import java.util.GregorianCalendar;
import java.util.HashMap;
import java.util.Map;
import lotus.domino.AgentBase;
import lotus.domino.AgentContext;
import lotus.domino.Database;
import lotus.domino.Document;
import lotus.domino.Item;
import lotus.domino.NotesException;
import lotus.domino.Session;
import lotus.domino.View;
import java.util.Iterator;
public class yyystellenPruefung extends AgentBase {
private long lastMillis = System.currentTimeMillis();
private Database dbCurrent = null; // aktuelle DB
// für Oracle-Verbindung
private Document logDoc;
private Item logItem;
// zu bearbeitende Dokumente
private String strOracleView;
private long newDocs = 0;
private long logCount;
private long logDocCount;
private Connection connectToOracle(Document docOracleConfig) throws SQLException, NotesException {
logEvent("vor Driver " + System.currentTimeMillis());
DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());
logEvent("vor conn " + System.currentTimeMillis());
String strOracleServer = docOracleConfig
.getItemValueString("OracleServer");
String strOracleUser = docOracleConfig.getItemValueString("OracleUser");
String strOraclePwd = docOracleConfig.getItemValueString("OraclePwd");
Connection conn = DriverManager.getConnection("jdbc:oracle:thin:@"
+ strOracleServer, strOracleUser, strOraclePwd); // Aufbau
// Verbindung
if (conn.isClosed()) {
logEvent("Oracle Connection is not open yet.");
return null;
}
return conn;
}
public void NotesMain() {
Connection conn = null;
try {
System.out
.println("Agent: Check für yyystellenaenderungen neu gestartet");
Session session = getSession();
AgentContext agentContext = session.getAgentContext();
dbCurrent = agentContext.getCurrentDatabase(); // aktuelle Datenbank
// holen
// Erstellung Protokolldokument
Calendar cal = new GregorianCalendar();
logDoc = dbCurrent.createDocument();
logDoc.replaceItemValue("Form", "Log");
logDoc.replaceItemValue("Lauf", "Lauf vom: "
+ cal.get(Calendar.DATE) + "."
+ (cal.get(Calendar.MONTH) + 1) + "."
+ cal.get(Calendar.YEAR) + " "
+ cal.get(Calendar.HOUR_OF_DAY) + ":"
+ cal.get(Calendar.MINUTE) + " Uhr");
logDoc.replaceItemValue("Start", cal.get(Calendar.DATE) + "."
+ (cal.get(Calendar.MONTH) + 1) + "."
+ cal.get(Calendar.YEAR) + " "
+ cal.get(Calendar.HOUR_OF_DAY) + ":"
+ cal.get(Calendar.MINUTE) + " Uhr");
logDoc.replaceItemValue("Log", "");
logItem = logDoc.getFirstItem("Log");
logEvent("neuer Agent: Check für yyystellenüberprüfung gestartet");
logDoc.save(true, false); // einmal abspeichern, damit Abbruch
// ersichtlich wird
// Einlesen der Oraclekonfigurationseinstellung
View oracleConfigView = dbCurrent.getView("(luConfig)");
Document docOracleConfig = oracleConfigView.getDocumentByKey("OracleConfig");
strOracleView = docOracleConfig.getItemValueString("OracleView");
// Erstellen der Verbindung
// achtung: wenn hier Fehlermeldung kommt wegen fehlendem
// Oracle-treiber --->
// im Agent müssen die Klassen als JArdatei eingehängt sein, wird
// unter 'Projekt bearbeiten' angezeigt, notfalls auf
// OracleHomeopage suchen
conn = connectToOracle(docOracleConfig);
if (conn != null) {
logEvent("Datenbankanbindung an ACAT erfolgreich hergestellt");
// Ermitteln der zu überprüfenden Dokumente
View terminalView = dbCurrent.getView("(luACATAbfrage)");
Document terminalDoc = terminalView.getFirstDocument();
// writes all old info in notes in vo objects in a map, using bkuname as key
Map mapTerminalDoc = new HashMap();
while (terminalDoc != null) {
Document nextDoc = terminalView
.getNextDocument(terminalDoc);
VOTerminalDoc termDoc = new VOTerminalDoc();
termDoc.setBkuName(terminalDoc
.getItemValueString("BKUName"));
termDoc.setNotesUniversalId(terminalDoc.getUniversalID());
termDoc.setXxxstelle(terminalDoc
.getItemValueString("xxxstelle"));
termDoc.setYyystelle(terminalDoc
.getItemValueString("yyystelle"));
mapTerminalDoc.put(termDoc.getBkuName(), termDoc);
terminalDoc.recycle();
terminalDoc = nextDoc;
} // Ende While
checkyyyInfo(mapTerminalDoc, conn);
logDoc.save(true, false);
logDoc.recycle();
// terminalView.recycle();
// docOracleConfig.recycle();
// oracleConfigView.recycle();
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (conn != null) {
conn.close();
}
} catch (SQLException e) {
}
}
} // Schließen Main
public void checkyyyInfo(Map mapTerminalDoc, Connection conn) {
try {
logEvent("vor Abfrage " + System.currentTimeMillis());
String query = "Select BKUName, name_von_spalte_3, name_von_spalte_4 From "
+ strOracleView
+ " WHERE BKUName IN "
+ buildSelectInQueryCondition(mapTerminalDoc.keySet()
.iterator());
System.out.println("QUERY=" + query);
Statement stmt = conn.createStatement();
ResultSet rs = stmt.executeQuery(query);
logEvent(query + "-->" + System.currentTimeMillis());
if (rs.next()) {
String bkuName = rs.getString("BKUName");
VOTerminalDoc termDoc = (VOTerminalDoc) mapTerminalDoc
.get(bkuName);
String strxxxstelleFromDb = new String(rs
.getString("name_von_spalte_3"));
String stryyystelleFromDb = new String(rs
.getString("name_von_spalte_4"));
if (strxxxstelleFromDb != termDoc.getXxxstelle()
|| strxxxstelleFromDb != termDoc.getYyystelle()) {
Document updateDoc = dbCurrent.getDocumentByUNID(termDoc
.getNotesUniversalId());
System.out.println("updating doc ->" + termDoc);
fillyyyInfo(updateDoc, strxxxstelleFromDb,
stryyystelleFromDb);
}
}
// updateDoc.recycle();
rs.close();
}
catch (Exception e) {
e.printStackTrace();
}
}// Schliessen checkyyystellenInfo
private String buildSelectInQueryCondition(Iterator itKeys) {
StringBuffer buf = new StringBuffer();
buf.append("(");
while (itKeys.hasNext()) {
String key = itKeys.next().toString();
buf.append("'");
buf.append(key);
buf.append("'");
}
buf.append(")");
return buf.toString();
}
private void fillyyyInfo(Document updateDoc, String stryyystelle,
String strxxxstelle) {
try {
String common = updateDoc.getItemValueString("zzzName");
updateDoc.replaceItemValue("xxxstelle", stryyystelle);
updateDoc.replaceItemValue("yyystelle", strxxxstelle);
logEvent(common + System.currentTimeMillis());
updateDoc.save(true, false);
updateDoc.recycle();
}
catch (Exception e) {
e.printStackTrace();
}
}// Schliessen FillyyystellenInfo
private void logEvent(String eventToBeLogged) {
try {
Calendar cal = new GregorianCalendar();
logCount++;
logItem.appendToTextList(eventToBeLogged);
if (logCount > 200) {
logDocCount++;
logCount = 0;
logDoc.save(true, false);
logDoc = dbCurrent.createDocument();
logDoc.replaceItemValue("Form", "Log");
logDoc.replaceItemValue("Lauf", "Lauf vom: "
+ cal.get(Calendar.DATE) + "."
+ (cal.get(Calendar.MONTH) + 1) + "."
+ cal.get(Calendar.YEAR) + " "
+ cal.get(Calendar.HOUR_OF_DAY) + ":"
+ cal.get(Calendar.MINUTE) + " Uhr " + logDocCount
+ ". Teil");
logDoc.replaceItemValue("Log", "");
logItem = logDoc.getFirstItem("Log");
}
} catch (Exception e) {
e.printStackTrace();
}
}// Ende logEvent
public long getDifMillis() {
long newMillis = System.currentTimeMillis();
long dif = newMillis - lastMillis;
lastMillis = newMillis;
return dif;
}// Ende getDifMillis()
}
class VOTerminalDoc {
private String bkuName;
private String notesUniversalId;
private String xxxstelle;
private String yyystelle;
public String getBkuName() {
return bkuName;
}
public void setBkuName(String bkuName) {
this.bkuName = bkuName;
}
public String getNotesUniversalId() {
return notesUniversalId;
}
public void setNotesUniversalId(String notesUniversalId) {
this.notesUniversalId = notesUniversalId;
}
public String getXxxstelle() {
return xxxstelle;
}
public void setXxxstelle(String xxxstelle) {
this.xxxstelle = xxxstelle;
}
public String getYyystelle() {
return yyystelle;
}
public void setYyystelle(String yyystelle) {
this.yyystelle = yyystelle;
}
public String toString() {
return "[" + getClass().getName() + "\n\tbkuName=" + getBkuName()
+ "\n\tnotesUniversalId=" + getNotesUniversalId()
+ "\n\txxxstelle=" + getXxxstelle() + "\n\tyyystelle="
+ getYyystelle() + "\n]";
}
}