import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.Reader;
import java.io.UnsupportedEncodingException;
import java.text.SimpleDateFormat;
import java.util.Date;
import com.sap.aii.mapping.api.AbstractTransformation;
import com.sap.aii.mapping.api.DynamicConfiguration;
import com.sap.aii.mapping.api.DynamicConfigurationKey;
import com.sap.aii.mapping.api.StreamTransformationException;
import com.sap.aii.mapping.api.TransformationInput;
import com.sap.aii.mapping.api.TransformationOutput;
public class RenameFile extends AbstractTransformation {
private static final DynamicConfigurationKey KEY_FILENAME =
DynamicConfigurationKey.create("http://sap.com/xi/XI/System/File","FileName");
@Override
public void transform(TransformationInput in, TransformationOutput out)
throws StreamTransformationException {
// TODO Auto-generated method stub
String newFileName = null;
Date date = new Date(); // get the current date
SimpleDateFormat dateFormatter = new SimpleDateFormat ("yyyyMMddHHmmSSS"); // set the format for date
String dfmt = dateFormatter.format(date);
String timestamp = dfmt.substring(0, 14); // for yyyyMMddHHmmss
String monthDay = dfmt.substring(4,8); // for MMdd
String mins = dfmt.substring(10,12); // for mm
String millisecs = dfmt.substring(12); // for SSS
String seqID = monthDay + mins + millisecs; // the format being MMddmmSSS
DynamicConfiguration conf = in.getDynamicConfiguration();
String oldFileName = conf.get(KEY_FILENAME);
oldFileName = oldFileName.replaceAll(".txt", "");
newFileName = oldFileName + seqID + ".txt." ; // the final filename
String inData = convertStreamToString(in.getInputPayload().getInputStream());
String outData = inData;
try {
out.getOutputPayload().getOutputStream().write(outData.getBytes("UTF-8"));
} catch (UnsupportedEncodingException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
conf.put(KEY_FILENAME,newFileName);
}
public String convertStreamToString(InputStream in){
StringBuffer sb = new StringBuffer();
try
{
InputStreamReader isr = new InputStreamReader(in);
Reader reader =
new BufferedReader(isr);
int ch;
while((ch = in.read()) > -1) {
sb.append((char)ch);}
reader.close();
}
catch(Exception exception) { }
return sb.toString();
}
}
You must be a registered user to add a comment. If you've already registered, sign in. Otherwise, register and sign in.