Thanks for posting! The phone definitely isn't encrypted. The following is the code behind PrecisionMessage.run()
import java.io.ByteArrayInputStream;
import java.io.DataInputStream;
import javax.microedition.rms.RecordEnumeration;
import javax.microedition.rms.RecordFilter;
import javax.microedition.rms.RecordStore;
import net.rim.blackberry.api.mail.Folder;
import net.rim.blackberry.api.mail.Message;
import net.rim.blackberry.api.mail.Multipart;
import net.rim.blackberry.api.mail.SupportedAttachmentPart;
import net.rim.device.api.system.ApplicationManager;
import net.rim.device.api.system.DeviceInfo;
import net.rim.device.api.system.EventLogger;
import net.rim.device.api.util.IntHashtable;
import net.rim.device.api.xml.parsers.DocumentBuilder;
import net.rim.device.api.xml.parsers.DocumentBuilderFactory;
import org.w3c.dom.Document;
import org.w3c.dom.NamedNodeMap;
class PrecisionMessage implements Runnable
{
// dd update : we need to exclude meters of this from display on device
public static int PMPDiplayMeterTypeId = 807;
Message EmailMessage;
String Log;
PrecisionCollector _theCollector;
public PrecisionMessage(Message emailMessage, PrecisionCollector theCollector)
{
EmailMessage = emailMessage;
_theCollector = theCollector;
Log = new String();
}
public void run()
{
try
{
String XMLString = null;
Object content = EmailMessage.getContent();
int length = ((Multipart)content).getCount();
for(int i=0; i < length; i++)
{
Object messagePart = ((Multipart)content).getBodyPart(i);
if(messagePart instanceof SupportedAttachmentPart)
{
SupportedAttachmentPart attachment = (SupportedAttachmentPart) messagePart;
XMLString = new String((byte[])attachment.getContent());
XMLString.replace('\0', ' ');
}
}
if(XMLString == null)
{
try
{
new OutgoingMail(DataStore._ConfigValues.NotifyEmail, "Handset Error On: " + Integer.toHexString(DeviceInfo.getDeviceId()), "A malformed Precision XML Message was received on this device", false);
}
catch(Exception e)
{
System.out.println("Exception caught in IncomingMail.MessageAdded(): " + e.toString());
e.printStackTrace();
}
throw new Exception("Could not obtain attachment from Precision Message");
}
Log += "Attempting to Parse Precision Message: " + XMLString + "\n";
DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
DocumentBuilder builder = factory.newDocumentBuilder();
Document document = builder.parse(new ByteArrayInputStream(XMLString.getBytes()));
Location loc;
Equipment equip;
Meter meter;
Reason reason;
MeterType meterType;
NamedNodeMap nodeMap;
RecordEnumeration dataset;
byte[] record;
int retval;
RecordStore EquipmentStore = DataStore._EquipmentStore;
RecordStore MeterStore = DataStore._MeterStore;
RecordStore LocationStore = DataStore._LocationStore;
if(document.getElementsByTagName("LocAssignment").getLength() > 0)
{
loc = new Location();
Log += "Loc1\n";
loc.ID = Integer.parseInt(document.getElementsByTagName("LocID").item(0).getFirstChild().getNodeValue());
Log += "Loc2\n";
loc.Number = document.getElementsByTagName("Number").item(0).getFirstChild().getNodeValue();
Log += "Loc3\n";
try
{ loc.Name = document.getElementsByTagName("Name").item(0).getFirstChild().getNodeValue(); }
catch(Exception exception)
{ loc.Name = ""; }
Log += "Loc4\n";
try
{ loc.Attn = document.getElementsByTagName("Attn").item(0).getFirstChild().getNodeValue(); }
catch(Exception exception)
{ loc.Attn = ""; }
Log += "Loc5\n";
try
{ loc.Street = document.getElementsByTagName("Street").item(0).getFirstChild().getNodeValue(); }
catch(Exception exception)
{ loc.Street = ""; }
Log += "Loc6\n";
try
{ loc.City = document.getElementsByTagName("City").item(0).getFirstChild().getNodeValue(); }
catch(Exception exception)
{ loc.City = ""; }
Log += "Loc7\n";
try
{ loc.State = document.getElementsByTagName("State").item(0).getFirstChild().getNodeValue(); }
catch(Exception exception)
{ loc.State = ""; }
Log += "Loc8\n";
try
{ loc.Zip = document.getElementsByTagName("Zip").item(0).getFirstChild().getNodeValue(); }
catch(Exception exception)
{ loc.Zip = ""; }
Log += "Loc9\n";
Log += "Attempting to parse Equipment";
length = document.getElementsByTagName("Equip").getLength();
for(int i=0; i < length; i++)
{
nodeMap = document.getElementsByTagName("Equip").item(i).getAttributes();
// dd update : include Enabled Automated Collection features
equip = new Equipment();
try
{
equip.ID = Integer.parseInt(nodeMap.getNamedItem("ID").getNodeValue());
equip.EquipmentID = equip.ID;
equip.Number = nodeMap.getNamedItem("Num").getNodeValue();
equip.SN = nodeMap.getNamedItem("SN").getNodeValue();
equip.Desc = nodeMap.getNamedItem("Desc").getNodeValue();
equip.Building = nodeMap.getNamedItem("Building").getNodeValue();
equip.Floor = nodeMap.getNamedItem("Floor").getNodeValue();
equip.Cube = nodeMap.getNamedItem("Cube").getNodeValue();
equip.Contact = nodeMap.getNamedItem("Contact").getNodeValue();
equip.PrevReasonNotCollectedID = Integer.parseInt(nodeMap.getNamedItem("Reason").getNodeValue());
equip.PrevRemarks = nodeMap.getNamedItem("Remarks").getNodeValue();
equip.WalkOrder = Integer.parseInt(nodeMap.getNamedItem("Order").getNodeValue());
if (nodeMap.getNamedItem("DutyCycle").getNodeValue() == "true")
equip.DutyCycle =true;
else
equip.DutyCycle = false;
equip.IPAddress = nodeMap.getNamedItem("IPAddress").getNodeValue();
// this is obsolate now, because we assume that all pieces of equipment
// can be enabled for automatic electronic collection
// so, I will comment it, but leave in case we need it in future
int intBool = Integer.parseInt(nodeMap.getNamedItem("ElectronicCollection").getNodeValue());
equip.ElectronicCollection = true;
// we will assume correct IP address if field length > 0
equip.EnabledElectronicColl = (equip.IPAddress.length() > 0);
equip.EnableItInNextMsg = false;
}
catch(Exception ex)
{
Log += "\nException in parsing Equipment\n";
EventLogger.logEvent(0x3401882cc7a5a956L, ("Exception in processing incoming mail, in reading required properties : " + ex.toString()).getBytes(), EventLogger.SEVERE_ERROR);
System.out.println("Exception in processing incoming mail, in reading required properties : " + ex.toString() );
}
// end of dd update
equip.ReasonNotCollectedID = 0;
equip.Remarks = "";
equip.Done = false;
equip.LocID = loc.ID;
dataset = EquipmentStore.enumerateRecords(new GetEquip(equip.ID), null, false);
if(dataset.numRecords() != 0)
{
Log += "Equipment ID: " + equip.ID + " already exists and will not be added\n";
}
else
{
record = equip.toByteArray();
retval = EquipmentStore.addRecord(record, 0, record.length);
Log += "Equipment Added, Record ID: " + retval +
"\nEquipment Record Size: " + EquipmentStore.getRecordSize(retval) +
"\nAvailable Space in Equipment Store: " + EquipmentStore.getSizeAvailable() + "\n";
}
}
Log += "Attempting to parse Meters\n";
length = document.getElementsByTagName("Meter").getLength();
for(int i=0; i < length; i++)
{
nodeMap = document.getElementsByTagName("Meter").item(i).getAttributes();
meter = new Meter();
meter.EquipID = Integer.parseInt(nodeMap.getNamedItem("EquipID").getNodeValue());
meter.ID = Integer.parseInt(nodeMap.getNamedItem("ID").getNodeValue());
meter.TypeID = Integer.parseInt(nodeMap.getNamedItem("Type").getNodeValue());
meter.High = Integer.parseInt(nodeMap.getNamedItem("High").getNodeValue());
meter.Low = Integer.parseInt(nodeMap.getNamedItem("Low").getNodeValue());
meter.Date = "";
meter.EquipNum = "";
meter.Actual = -1;
dataset = MeterStore.enumerateRecords(new GetMeter(meter.ID), null, false);
if(dataset.numRecords() != 0)
{
Log += "Meter ID: " + meter.ID + " already exists and will not be added\n";
}
else
{
// dd update : to skip meters of PMPDisplayMeterTypeId
if(meter.TypeID != PrecisionMessage.PMPDiplayMeterTypeId)
{
record = meter.toByteArray();
retval = MeterStore.addRecord(record, 0, record.length);
Log += "Meter Added, ID: " + retval +
"\nMeter Record Size: " + MeterStore.getRecordSize(retval) +
"\nAvailable Space in Meter Store: " + MeterStore.getSizeAvailable() + "\n";
}
else
{
// Log += "Meter of PMPDisplay type skipped \n";
}
}
}
dataset = LocationStore.enumerateRecords(new GetLoc(loc.ID), null, false);
if(dataset.numRecords() != 0)
{
Log += "Location already exists - Updating the Equipment List\n";
ApplicationManager.getApplicationManager().postGlobalEvent(0xf0985f7efa70795fL,0,0,null,null); // UpdateEquipmentList
}
else
{
loc.NextWalkOrder = 1;
record = loc.toByteArray();
retval = LocationStore.addRecord(record, 0, record.length);
Log += "Location Added Successfully, ID: " + retval + "\n";
ApplicationManager.getApplicationManager().postGlobalEvent(0xcf059df4c8b03703L,0,0,null,null); // UpdateLocation
}
}
else if(document.getElementsByTagName("ControlMsg").getLength() > 0)
{
Log += "Attempting to parse handset control message\n";
RecordStore ReasonStore = DataStore._ReasonStore;
RecordStore MeterTypeStore = DataStore._MeterTypeStore;
DataStore.SaveConfigValues(document.getElementsByTagName("ServerEmail").item(0).getFirstChild().getNodeValue(),
document.getElementsByTagName("NotifyEmail").item(0).getFirstChild().getNodeValue(),
document.getElementsByTagName("WSUrl").item(0).getFirstChild().getNodeValue(),
document.getElementsByTagName("DeviceNumber").item(0).getFirstChild().getNodeValue());
try
{
String debugLevel = document.getElementsByTagName("LogLevel").item(0).getFirstChild().getNodeValue();
if(debugLevel.toUpperCase().indexOf("DEBUG") != -1)
EventLogger.setMinimumLevel(EventLogger.DEBUG_INFO);
else if(debugLevel.toUpperCase().indexOf("INFORMATION") != -1)
EventLogger.setMinimumLevel(EventLogger.INFORMATION);
else if(debugLevel.toUpperCase().indexOf("WARNING") != -1)
EventLogger.setMinimumLevel(EventLogger.WARNING);
}
catch(Exception exception)
{ }
dataset = ReasonStore.enumerateRecords(null, null, false);
while(dataset.hasNextElement())
{
int id = dataset.nextRecordId();
reason = new Reason(id, ReasonStore.getRecord(id));
Log += "About to Delete ReasonNotCollected Record ID: " + id + " -- Reason ID: " + reason.ID + " -- Display Name: " + reason.getDisplayName() + "\n";
ReasonStore.deleteRecord(id);
}
length = document.getElementsByTagName("NotCollectedReason").getLength();
for(int i=0; i < length; i++)
{
nodeMap = document.getElementsByTagName("NotCollectedReason").item(i).getAttributes();
reason = new Reason();
reason.ID = Integer.parseInt(nodeMap.getNamedItem("ID").getNodeValue());
reason.Desc = nodeMap.getNamedItem("Desc").getNodeValue();
reason.ConseqUse = !nodeMap.getNamedItem("ConseqUse").getNodeValue().equals("0");
record = reason.toByteArray();
retval = ReasonStore.addRecord(record, 0, record.length);
Log += "Added ReasonNotCollected, Record ID: " + retval + "\n";
}
dataset = MeterTypeStore.enumerateRecords(null, null, false);
while(dataset.hasNextElement())
{
int id = dataset.nextRecordId();
meterType = new MeterType(id, MeterTypeStore.getRecord(id));
Log += "About to Delete MeterType Record ID: " + id + " -- MeterType ID: " + meterType.ID + " -- Display Name: " + meterType.getDisplayName() + "\n";
MeterTypeStore.deleteRecord(id);
}
length = document.getElementsByTagName("MeterType").getLength();
for(int i=0; i < length; i++)
{
nodeMap = document.getElementsByTagName("MeterType").item(i).getAttributes();
meterType = new MeterType();
meterType.ID = Integer.parseInt(nodeMap.getNamedItem("ID").getNodeValue());
meterType.Type = nodeMap.getNamedItem("Type").getNodeValue();
meterType.Desc = nodeMap.getNamedItem("Desc").getNodeValue();
record = meterType.toByteArray();
retval = MeterTypeStore.addRecord(record, 0, record.length);
Log += "Added meter type, ID: " + retval + "\n";
}
ApplicationManager.getApplicationManager().postGlobalEvent(0xd0b8f0e6b3e2bc80L,0,0,null,null); // UpdateHandsetControl
}
else if(document.getElementsByTagName("ReleaseEquip").getLength() > 0)
{
IntHashtable EquipHash = new IntHashtable();
// Put all of the equipment into a hash
dataset = EquipmentStore.enumerateRecords(null, null, false);
while(dataset.hasNextElement())
{
int id = dataset.nextRecordId();
equip = new Equipment(id, EquipmentStore.getRecord(id));
EquipHash.put(equip.ID, equip);
}
Log += "Abut to get release equipment list\n";
length = document.getElementsByTagName("Equip").getLength();
for(int i=0; i < length; i++)
{
nodeMap = document.getElementsByTagName("Equip").item(i).getAttributes();
int EquipID = Integer.parseInt(nodeMap.getNamedItem("ID").getNodeValue());
try
{
equip = (Equipment)EquipHash.get(EquipID);
EquipmentStore.deleteRecord(equip.RecordID);
}
catch(Exception e)
{
Log += "Equipment ID: " + EquipID + " not found -- Cannot be unassigned\n";
e.printStackTrace();
}
}
// Do the cleanup of Orphaned Locations, Equipment, and Meters Here
DataStore.CleanupDB();
ApplicationManager.getApplicationManager().postGlobalEvent(0xcf059df4c8b03703L,0,0,null,null); // UpdateLocation
ApplicationManager.getApplicationManager().postGlobalEvent(0xf0985f7efa70795fL,0,0,null,null); // UpdateEquipmentList
} else if(document.getElementsByTagName("AMCEquipments").getLength() > 0) {
Log += "Parsing enabled equipments:\n";
int locationID = Integer.parseInt(
document.getElementsByTagName("LocID").item(0).getFirstChild().getNodeValue());
Log += "Location id:" + locationID + "\n";
Log += "Attempting to parse enabled equipments\n";
int equipmentCount = document.getElementsByTagName("EnabledEq").getLength();
for(int i=0; i < equipmentCount; i++){
nodeMap = document.getElementsByTagName("EnabledEq").item(i).getAttributes();
equip = new Equipment();
try
{
equip.ID = Integer.parseInt(nodeMap.getNamedItem("ID").getNodeValue());
equip.EquipmentID = equip.ID;
equip.Number = nodeMap.getNamedItem("Num").getNodeValue();
equip.Done = true;
equip.LocID = locationID;
equip.displayInUI = false;
} catch(Exception ex){
Log += "\nException in parsing Equipment\n";
EventLogger.logEvent(0x3401882cc7a5a956L, ("Exception in processing incoming mail, in reading required properties : " + ex.toString()).getBytes(), EventLogger.SEVERE_ERROR);
System.out.println("Exception in processing incoming mail, in reading required properties : " + ex.toString() );
}
dataset = EquipmentStore.enumerateRecords(new GetEquip(equip.ID), null, false);
if(dataset.numRecords() != 0)
{
Log += "Equipment ID: " + equip.ID + " already exists and will not be added\n";
}
else
{
record = equip.toByteArray();
retval = EquipmentStore.addRecord(record, 0, record.length);
Log += "Equipment Added, Record ID: " + retval +
"\nEquipment Record Size: " + EquipmentStore.getRecordSize(retval) +
"\nAvailable Space in Equipment Store: " + EquipmentStore.getSizeAvailable() + "\n";
}
}
ApplicationManager.getApplicationManager().postGlobalEvent(0xf0985f7efa44595fL,0,0,null,null); // UpdateEnabled
}
else if(document.getElementsByTagName("RecallEquip").getLength() > 0)
{
IntHashtable AllEquipHash = new IntHashtable();
IntHashtable RecallEquipHash = new IntHashtable();
// Put all of the equipment into a hash
dataset = EquipmentStore.enumerateRecords(null, null, false);
// Put all of the equipment into a hash
dataset = EquipmentStore.enumerateRecords(null, null, false);
while(dataset.hasNextElement())
{
int id = dataset.nextRecordId();
equip = new Equipment(id, EquipmentStore.getRecord(id));
AllEquipHash.put(equip.ID, equip);
}
Log += "Abut to get release equipment list\n";
length = document.getElementsByTagName("Equip").getLength();
for(int i=0; i < length; i++)
{
nodeMap = document.getElementsByTagName("Equip").item(i).getAttributes();
int EquipID = Integer.parseInt(nodeMap.getNamedItem("ID").getNodeValue());
try
{
equip = (Equipment)AllEquipHash.get(EquipID);
RecallEquipHash.put(equip.ID, equip);
}
catch(Exception e)
{
Log += "Equipment ID: " + EquipID + " not found -- Cannot be unassigned\n";
e.printStackTrace();
}
}
// Do the cleanup of Orphaned Locations, Equipment, and Meters Here
DataStore.RecallEquipment(RecallEquipHash);
DataStore.CleanupDB();
ApplicationManager.getApplicationManager().postGlobalEvent(0xcf059df4c8b03703L,0,0,null,null); // UpdateLocation
ApplicationManager.getApplicationManager().postGlobalEvent(0xf0985f7efa70795fL,0,0,null,null); // UpdateEquipmentList
} else {
new OutgoingMail(DataStore._ConfigValues.NotifyEmail, "Handset Error On: " + Integer.toHexString(DeviceInfo.getDeviceId()), "A malformed Precision XML Message was received on this device", false);
}
EventLogger.logEvent(0x3401882cc7a5a956L, Log.getBytes(), EventLogger.DEBUG_INFO);
}
catch(Exception exception)
{
EventLogger.logEvent(0x3401882cc7a5a956L, ("Exception caugth in PrecicionMessage.run(): " + exception.toString() + "\n\nLog: " + Log).getBytes(), EventLogger.SEVERE_ERROR);
exception.printStackTrace();
System.out.println(exception.toString());
}
Folder messageFolder = EmailMessage.getFolder();
messageFolder.deleteMessage(EmailMessage);
_theCollector.ProcessPrecisionMsg(true);
}
}
