Hi,
The below mentioned code is for sending email with attachment using Java Mapping which was implemented in PI 7.0
I know the API for PI 7.1 has changed, I changed the below code using extends AbstractTransformation using Transform instead of implements streamTransformation and few other changes but I get lot of issues.
Could anyone point out what and all need to be changed in PI 7.1 for the below mentioned code. It would be greatly if anyone could let me know the changes
package dynamicconfmail;
import com.sap.aii.mapping.api.*;
import java.io.BufferedReader;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.util.HashMap;
import java.util.Map;
import java.util.Properties;
import javax.mail.*;
import javax.activation.*;
import javax.mail.internet.*;
import javax.mail.util.ByteArrayDataSource;
public class DynamicConfMail implements StreamTransformation {
private Map param;
//// Start of Main Class
// public static void main(String[] args) throws Exception
// {
// try
// {
// FileInputStream fin = new FileInputStream("c:/test/sam.txt");
// FileOutputStream fout = new FileOutputStream("H:/test/sam2_O.txt");
// DynamicConfMail mapping = new DynamicConfMail();
// mapping.execute(fin, fout);
// }
// catch (Exception e)
// {
// // e.printStackTrace();
// }
// }
// //End of Main Class
public DynamicConfMail() {
}
public void setParameter(Map map) {
param = map;
if (param == null) {
param = new HashMap();
}
}
public void execute(InputStream inputstream, OutputStream outputstream)
{
int IO_BUFFER_SIZE = 4 * 1024;
String llkj = "1111";
String llkj_f = "llkj.txt";
String llkj_dir = "/usr/sap/llkj/in";
String xyzv = "9999";
String xyzv_f = "xyzv.txt";
String xyzv_dir = "/usr/sap/xyzv/in";
String default_dir = "/usr/sap/Error";
String Flag = "";
String FileName = "";
try
{
// The following is for the FileName in the File Adapter
DynamicConfiguration conf = (DynamicConfiguration) param.get("DynamicConfiguration");
DynamicConfigurationKey key = DynamicConfigurationKey.create("http://sap.com/xi/XI/System/File", "FileName");
DynamicConfigurationKey key1 = DynamicConfigurationKey.create("http://sap.com/xi/XI/System/File", "Directory");
InputStream ins = inputstream;
// Start Copy the InputStream to OutputStream
byte[] b = new byte[IO_BUFFER_SIZE];
int read;
StringBuffer out = new StringBuffer();
try {
while ((read = inputstream.read(b)) != -1)
{
out.append(new String(b, 0, read));
String InputString = out.toString();
String substr = InputString.substring(2, 18);
System.out.println(substr);
if (substr.equals(llkj))
{
System.out.println("The given string is equals");
conf.put(key, llkj_f);
conf.put(key1, llkj_dir );
FileName = llkj_f;
}
else if (substr.equals(xyzv))
{
System.out.println("The given string is equals");
conf.put(key, xyzv_f);
conf.put(key1, xyzv_dir);
FileName = xyzv_f;
}
else
{
conf.put(key1, default_dir);
Flag = "F";
System.out.println("The given string is not equals");
FileName = substr;
}
// Writes to outputstream
outputstream.write(b, 0, read);
if (Flag.equals(""))
{
//* Code to Send Email*/
String att = outputstream.toString();
email obj1 = new email();
obj1.send("mailhost", "emailID", "Success", "Success", "emailID",InputString, FileName);
//End of Email Code/
}
else if (Flag.equals("F"))
{
//* Code to Send Email*/
String att = outputstream.toString();
email obj1 = new email();
obj1.send("mailhost", "emailID", "Failed", "Failed", "emailID",InputString, FileName);
//End of Email Code/
}
}
}
catch (IOException ex)
{
ex.printStackTrace();
}
// End of Copy the InputStream to OutputStream
}
catch (Throwable throwable)
{
throwable.printStackTrace();
}
}
public class email {
public void postMail(String mailhst, String recivers, String subject, String message, String from, String attachment, String FileName) throws MessagingException
{
boolean debug = false;
byte[] AttByteArray = attachment.getBytes();
Properties props = new Properties();
props.put("mail.smtp.host", mailhst);
Session session = Session.getDefaultInstance(props, null);
session.setDebug(debug);
Message msg = new MimeMessage(session);
InternetAddress addressFrom = new InternetAddress(from);
msg.setFrom(addressFrom);
String recipients[] = recivers.split(",");
InternetAddress[] addressTo = new InternetAddress[recipients.length];
for (int i = 0; i < recipients.length; i++)
addressTo<i> = new InternetAddress(recipients<i>);
msg.setRecipients(Message.RecipientType.TO, addressTo);
msg.addHeader("MyHeaderName", "myHeaderValue");
msg.setSubject(subject);
// Create the message part
BodyPart messageBodyPart = new MimeBodyPart();
// Fill the message
messageBodyPart.setText("TEST");
Multipart multipart = new MimeMultipart();
multipart.addBodyPart(messageBodyPart);
// Part two is attachment
messageBodyPart = new MimeBodyPart();
DataSource source = new ByteArrayDataSource("Test","text/plain", AttByteArray );
messageBodyPart.setDataHandler(new DataHandler(source));
messageBodyPart.setFileName(FileName);
multipart.addBodyPart(messageBodyPart);
// Put parts in message
msg.setContent(multipart);
Transport.send(msg);
}
public void send(String mailhst, String recivers, String subject, String message, String from, String attachment, String FileName)
{
try {
this.postMail(mailhst, recivers, subject, message, from, attachment, FileName );
}
catch (MessagingException mex) {
System.out.println("send failed, exception: " + mex);
}
}
class ByteArrayDataSource implements DataSource {
byte[] bytes;
String contentType;
String name;
ByteArrayDataSource( String name, String contentType, byte[] bytes ) {
this.name = name;
this.bytes = bytes;
this.contentType = contentType;
}
public String getContentType() {
return contentType;
}
public InputStream getInputStream() {
return new ByteArrayInputStream(bytes);
}
public String getName() {
return name;
}
public OutputStream getOutputStream() throws IOException {
throw new FileNotFoundException();
}
}
}
}
Edited by: PI-seeker on Feb 3, 2011 10:58 PM
You must be a registered user to add a comment. If you've already registered, sign in. Otherwise, register and sign in.