import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Properties;
import org.apache.commons.httpclient.methods.GetMethod;
import de.aja.main.HttpClientInvoker;
import lotus.domino.*;
public class JavaAgent extends AgentBase {
public void NotesMain() {
try {
Session session = getSession();
AgentContext agentContext = session.getAgentContext();
Document docConfig = null; //
Database db = agentContext.getCurrentDatabase();
//View vw = db.getView("vwConfig");
//docConfig = vw.getFirstDocument();
List urlDetails = new ArrayList();
urlDetails.add("DE03003827T1");
// mit add können beliebig viele urlDetails hinzugefügt werden.
downloadManager(docConfig, urlDetails);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* @param args
* @throws Exception
*/
public void downloadManager(Document docProps, List urlDetails)
throws Exception {
Properties propsMain = new Properties();
Properties propsPDF = new Properties();
Properties propsCommon = new Properties();
/*
* DIESE WERTE WIEDER MIT DEINEN ERSETZEN!!!
*/
/*
* IN EINEM ZWEITEN SCHRITT KANNST DU DIE WERTE FÜR DIE PROPS (das
* zweite Argument von den .put calls aus einem Notes Document docProps
* holen!
*/
propsCommon.put("de.aja.preparecall.AddReverseProxyBaseAuth.proxyHost",
"http://111.111.111.111");
propsCommon.put("de.aja.preparecall.AddReverseProxyBaseAuth.proxyPort",
"8080");
propsCommon.put("de.aja.preparecall.AddReverseProxyBaseAuth.proxyUser",
"axel");
propsCommon.put("de.aja.preparecall.AddReverseProxyBaseAuth.proxyPwd",
"kennwort");
propsCommon.put("folderDest", "D:/test/notes/");
// kann so bleiben, übersichtlicher aber von docConfig. Zugriff mit docConfig.getStringValue("fieldCookie");
propsMain.put("url", "http://depatisnet.dpma.de/");
propsMain.put("clazzesPrepareCall","de.aja.preparecall.AddReverseProxyBaseAuth");
propsMain.put("de.aja.preparecall.AddFollowRedirects.followRedirects",
"false");
propsMain.put("clazzProcessReturn",
"de.aja.docall.ReturnCookiesHandler");
// propsPDF.put("url","http://depatisnet.dpma.de/DepatisNet/depatisnet?action=textpdf&docid=DE03003827T1");
propsPDF.put("clazzesPrepareCall",
"de.aja.preparecall.AddRequestHeader:de.aja.preparecall.AddReverseProxyBaseAuth");
propsPDF.put("de.aja.preparecall.AddFollowRedirects.followRedirects",
"false");
propsPDF.put("clazzProcessReturn",
"de.aja.docall.ReturnBodyAsStreamHandler");
propsMain.putAll(propsCommon);
propsPDF.putAll(propsCommon);
Iterator it = urlDetails.iterator();
int counter = 0;
//this.cookie = docConfig.getItemValueString("cookie"); // cookie aus config Doc holen!
String cookie = null; // die Zeile auskommentieren, wenn cookie aus doc, ist logisch.
String cookieBefore = cookie; // die stehenlassen
while (it.hasNext()) {
String urlDetail = (String) it.next();
System.out.println("downloading doc " + urlDetail + " " + ++counter + " of " + urlDetails.size());
propsPDF.put("url",
"http://depatisnet.dpma.de/DepatisNet/depatisnet?action=textpdf&docid="
+ urlDetail);
if (cookie != null) {
boolean ret = callPDF(propsPDF, cookie);
if (!ret) {
System.out
.println("Probably cookie isn't valid no more. Try to get fresh cookie.");
cookie = callMain(propsMain);
callPDF(propsPDF, cookie);
}
} else {
System.out
.println("Can't find cookie. Probably its not there. Try to get cookie and save value to disk.");
cookie = callMain(propsMain);
callPDF(propsPDF, cookie);
}
} // end while it.hasNext()
if (cookie!= null) {
if (!cookie.equals(cookieBefore)) {
//docConfig.replaceItemValue("fieldCookie", cookie); // cookie in ConfigDoc speichern
// docConfig.save(true, false);
}
}
}
// find cookie to new value if needed.
public String callMain(Properties propsMain) throws Exception {
System.out.println("Calling Main with this properties" + propsMain);
HttpClientInvoker invoker = HttpClientInvoker
.getDefaultHttpClientInvoker(propsMain);
Object res = invoker.doInvoke(new GetMethod());
//Properties propsCookies = new Properties();
return (String) res;
}
public boolean callPDF(Properties propsPDF, String cookie) throws Exception {
propsPDF.put("globals.requestHeader.Cookie", cookie);
HttpClientInvoker invoker = HttpClientInvoker
.getDefaultHttpClientInvoker(propsPDF);
Object res = invoker.doInvoke(new GetMethod());
if (res instanceof java.lang.Integer) {
System.out.println("Return Integer is:" + res);
return false;
} else if (res instanceof java.io.InputStream) {
InputStream in = (InputStream) res;
savePDFToDisk(in, propsPDF, invoker);
} else {
System.out.println("Unexpected return"
+ (res == null ? "null" : res.getClass().getName()));
}
return true;
}
public void savePDFToDisk(InputStream in, Properties propsPDF,
HttpClientInvoker invoker) throws Exception {
String[] urlParts = invoker.getUrl().split("=");
File fileDest = new File(propsPDF.getProperty("folderDest")
+ urlParts[urlParts.length - 1] + ".pdf");
System.out.println("file destination is " + fileDest.getAbsolutePath());
OutputStream out = new FileOutputStream(fileDest);
// Transfer bytes from in to out
byte[] buf = new byte[1024];
int len;
while ((len = in.read(buf)) > 0) {
out.write(buf, 0, len);
}
in.close();
out.close();
System.out.println("DONE! Saved pdf to " + fileDest.getAbsolutePath());
}
}