import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.ResourceBundle;
import java.util.Vector;
import lotus.domino.*;
import nu.xom.Attribute;
import nu.xom.Document;
import nu.xom.Element;
import nu.xom.Serializer;
import com.zehon.FileTransferStatus;
import com.zehon.exception.FileTransferException;
import com.zehon.sftp.SFTPClient;
public class JavaAgent extends AgentBase {
public String tempdir() {
String tempdir = System.getProperty("java.io.tmpdir");
if (!(tempdir.endsWith("/") || tempdir.endsWith("\\")))
tempdir = tempdir + System.getProperty("file.separator");
return tempdir;
}
public void NotesMain() {
try {
Session session = getSession();
AgentContext agentContext = session.getAgentContext();
// (Your code goes here)
boolean debug = false;
if (debug) System.out.println("Start");
ResourceBundle settingsRes = ResourceBundle.getBundle("Sett");
String ExportFileName = settingsRes.getString("ExportFile");
String[] srvList = settingsRes.getString("ServerList").split(",");
File exportFile = new File(tempdir() + ExportFileName);
boolean flag = false;
View vw = null;
lotus.domino.Document doc = null;
lotus.domino.Document tmpdoc = null;
long cnt = 0;
Element expRoot = new Element("ContactList");
for (int i = 0; i < srvList.length; i++) {
if (debug) System.out.println(srvList);
Database db = session.getDatabase(srvList.toString(), "names.nsf", false); //session.getCurrentDatabase();
if (db != null && db.isOpen()) {
if (debug) System.out.println(db.getTitle());
vw = db.getView("EmailUser");
if (vw.getEntryCount() > 0) {
doc = vw.getFirstDocument();
while (doc != null) {
//if (debug) System.out.println(doc.getFirstItem("MailFile").getValues().elementAt(0).toString());
if (doc.getItemValueString("FirstName").length() != 0) {
if (debug) System.out.println(doc.getItemValueString("FirstName"));
Element child = new Element("Contact");
Element tag = new Element("DisplayName");
lotus.domino.Item docfields = doc.getFirstItem("FullName");
Vector values = docfields.getValues();
docfields.recycle();
tag.appendChild(values.get(values.size()-1).toString());
child.appendChild(tag);
tag = new Element("LastName");
tag.appendChild(doc.getItemValueString("LastName"));
child.appendChild(tag);
tag = new Element("GivenName");
tag.appendChild(doc.getItemValueString("FirstName"));
child.appendChild(tag);
tag = new Element("Company");
tag.appendChild(doc.getItemValueString("CompanyName"));
child.appendChild(tag);
tag = new Element("SMTPAddress");
tag.appendChild(doc.getItemValueString("InternetAddress"));
child.appendChild(tag);
expRoot.appendChild(child);
flag = true;
++cnt;
if (debug) System.out.println("98");
}
if (debug) System.out.println("100");
tmpdoc = vw.getNextDocument(doc);
doc.recycle();
doc = tmpdoc;
if (debug) System.out.println("104");
}
}
}
vw.recycle();
db.recycle();
if (doc != null) doc.recycle();
if (tmpdoc != null) tmpdoc.recycle();
}
if (flag) {
Attribute count = new Attribute("Count",String.valueOf(cnt));
expRoot.addAttribute(count);
FileOutputStream ExportFile = new FileOutputStream(exportFile.getAbsoluteFile());
Document expDoc = new Document(expRoot);
try {
Serializer serializer = new Serializer(ExportFile, "ISO-8859-1");
serializer.setIndent(4);
serializer.setMaxLength(64);
serializer.write(expDoc);
ExportFile.close();
}
catch (IOException ioEx) {
ioEx.printStackTrace();
}
}
String host = settingsRes.getString("host");
String username = settingsRes.getString("username");
String password = settingsRes.getString("password");
String sftpFolder = settingsRes.getString("sftpFolder");
String writeToLocalFolder = tempdir();
String ImportFile = settingsRes.getString("ImportFile");
SFTPClient SFTPObj = new SFTPClient(host, username,password);
if (flag) {
try {
int status = SFTPObj.sendFile(tempdir() + ExportFileName, sftpFolder); //SFTPObj.getFile(ExportFile, "/", writeToLocalFolder);
if (FileTransferStatus.SUCCESS == status)
if (debug) System.out.println("Send");
else if (FileTransferStatus.FAILURE == status)
if (debug) System.out.println("Can not sent sftp");
}
catch(FileTransferException ex) {
ex.getCause().printStackTrace();
}
}
try {
int status = SFTPObj.getFile(ImportFile, sftpFolder, writeToLocalFolder);
if (FileTransferStatus.SUCCESS == status)
if (debug) System.out.println("Copy to " + writeToLocalFolder);
else if(FileTransferStatus.FAILURE == status)
if (debug) System.out.println("Can not copy from sftp");
}
catch(FileTransferException ex) {
ex.getCause().printStackTrace();
}
SFTPClient.closeCache();
if (debug) System.out.println("Done");
agentContext.recycle();
session.recycle();
System.gc();
}
catch (Exception e) {
e.getCause().printStackTrace();
}
}
}
