salesforce integration

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.rmi.RemoteException;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.Date;
import java.util.GregorianCalendar;
import java.util.HashMap;
import java.util.Vector;
import javax.xml.rpc.ServiceException;
import org.apache.axis.message.MessageElement;
import org.apache.log4j.BasicConfigurator;
import org.apache.log4j.Level;
import org.apache.log4j.Logger;
import org.w3c.dom.Element;
import com.sforce.soap.partner.*;
import com.sforce.soap.partner.DeleteResult;
import com.sforce.soap.partner.DescribeGlobalResult;
import com.sforce.soap.partner.DescribeLayout;
import com.sforce.soap.partner.DescribeLayoutItem;
import com.sforce.soap.partner.DescribeLayoutResult;
import com.sforce.soap.partner.DescribeLayoutRow;
import com.sforce.soap.partner.DescribeLayoutSection;
import com.sforce.soap.partner.DescribeSObjectResult;
import com.sforce.soap.partner.DescribeSoftphoneLayoutCallType;
import com.sforce.soap.partner.DescribeSoftphoneLayoutInfoField;
import com.sforce.soap.partner.DescribeSoftphoneLayoutItem;
import com.sforce.soap.partner.DescribeSoftphoneLayoutResult;
import com.sforce.soap.partner.DescribeSoftphoneLayoutSection;
import com.sforce.soap.partner.DescribeTab;
import com.sforce.soap.partner.DescribeTabSetResult;
import com.sforce.soap.partner.Field;
import com.sforce.soap.partner.FieldType;
import com.sforce.soap.partner.GetDeletedResult;
import com.sforce.soap.partner.GetUpdatedResult;
import com.sforce.soap.partner.GetUserInfoResult;
import com.sforce.soap.partner.LeadConvert;
import com.sforce.soap.partner.LeadConvertResult;
import com.sforce.soap.partner.LoginResult;
import com.sforce.soap.partner.MergeRequest;
import com.sforce.soap.partner.MergeResult;
import com.sforce.soap.partner.PicklistEntry;
import com.sforce.soap.partner.ProcessRequest;
import com.sforce.soap.partner.ProcessResult;
import com.sforce.soap.partner.ProcessSubmitRequest;
import com.sforce.soap.partner.ProcessWorkitemRequest;
import com.sforce.soap.partner.QueryOptions;
import com.sforce.soap.partner.QueryResult;
import com.sforce.soap.partner.ResetPasswordResult;
import com.sforce.soap.partner.SaveResult;
import com.sforce.soap.partner.SearchRecord;
import com.sforce.soap.partner.SearchResult;
import com.sforce.soap.partner.SessionHeader;
import com.sforce.soap.partner.SetPasswordResult;
import com.sforce.soap.partner.SforceServiceLocator;
import com.sforce.soap.partner.SoapBindingStub;
import com.sforce.soap.partner.UndeleteResult;
import com.sforce.soap.partner.UpsertResult;
import com.sforce.soap.partner.fault.ApiFault;
import com.sforce.soap.partner.fault.InvalidQueryLocatorFault;
import com.sforce.soap.partner.fault.LoginFault;
import com.sforce.soap.partner.fault.UnexpectedErrorFault;
import com.sforce.soap.partner.sobject.SObject;
import com.sforce.soap.partner.AssignmentRuleHeader;

public class SalesForcePartnerAPI {
	public static void main(String[] args) {
		SalesForcePartnerAPI sfpObj = new SalesForcePartnerAPI();

		sfpObj.login("yourLogin@domain.com", "passworddYmtLvyz6TR4FVSoLCIdeBEmis");
		sfpObj.setDebug("yes");

		// sfpObj.getMappings("Account");
		// sfpObj.getMappings("Contact");
		// sfpObj.getMappings("Case");
		sfpObj.getMappings("Lead");
		// sfpObj.getMappings("Warranty_reg__c");
		// sfpObj.getMappings("Warranty_Equipment__c");

		// get all objects and relevant mappings
		// String[] tempObjects = sfpObj.getAllObjects(); if (!(tempObjects == null)) { for (int i = 0; i < tempObjects.length; i++) { sfpObj.getMappings(tempObjects[i].trim()); } }

		String strTemp = "";
		String opCompare = "like"; // like or equalto

		// Account
		strTemp = "Id=|Name=test10 account name 1|";
		// sfpObj.getRecord("Account", strTemp, opCompare);
		// sfpObj.checkRecord("Account", strTemp, opCompare);
		// sfpObj.upsertRecord("Account", strTemp);

		// Contact
		strTemp = "Id=|LastName=test10 contact last name 1|";
		// sfpObj.getRecord("Contact", strTemp, opCompare);
		// sfpObj.checkRecord("Contact", strTemp, opCompare);
		// sfpObj.upsertRecord("Contact", strTemp);

		// Case
		strTemp = "Id=|SuppliedName=test13 case SuppliedName 1|";
		// sfpObj.getRecord("Case", strTemp, opCompare);
		// sfpObj.checkRecord("Case", strTemp, opCompare);
		// sfpObj.upsertRecord("Case", strTemp);

		// Lead
		// strTemp = "Id=|LastName=test13 contact last name 1|company=test13|";
		// strTemp = "Id=|FirstName=Drew - form test
		// 5|LastName=sqa|Company=test|Email=test@test.com|Phone=123 456 7890| Description=Verify software|";
		//strTemp = "Id=|FirstName=testJul10_008 fn's|LastName=testJul10_008 ln's|Company=testJul10_008|Email=testJul10_008@test.com|Phone=1234567890|";
		 strTemp = "Id=|LastName=%Ketan's%|Company=|Email=|";
		try {
			sfpObj.getRecord("Lead", strTemp, opCompare);
		} catch (Exception ex) {
			ex.printStackTrace();
		}

		// strTemp = "FirstName=test| LastName=test |abc__CurrentGenerators__c=dfsrCustomPost | Company=test |";
		// sfpObj.getRecord("Lead", strTemp, opCompare);
		// sfpObj.checkRecord("Lead", strTemp, null);
		//sfpObj.upsertRecord("Lead", strTemp);

		// //////////////////
		// custom objects //
		// //////////////////
		opCompare = "equalto"; // cannot retrieve mutiple records for custom
		// objects

		// Warranty_reg__c
		// strTemp =
		// "Id=|Account__c=0015000000HupPPAAZ|Installer__c=0035000000O4NekAAF|Date_of_Installation__c=2007-02-01|";
		// sfpObj.getRecord("Warranty_reg__c", strTemp, opCompare);
		// sfpObj.checkRecord("Warranty_reg__c", strTemp, opCompare);
		// sfpObj.upsertRecord("Warranty_reg__c", strTemp);

		// Warranty_Equipment__c
		// strTemp =
		// "Id=|Warranty_Registration__c=a0R500000001j0EEAQ|Model_Number__c=test10
		// Warranty_Registration__c model number 1|Serial_Number__c=test10
		// Warranty_Registration__c serial number 1|";
		// sfpObj.getRecord("Warranty_Equipment__c", strTemp, opCompare);
		// sfpObj.checkRecord("Warranty_Equipment__c", strTemp, opCompare);
		// sfpObj.upsertRecord("Warranty_Equipment__c", strTemp);

		if (sfpObj.isDebug) {
			System.out.println("-- done");
		}
	}

	private SoapBindingStub binding;
	private LoginResult loginResult = null;
	private String un = null;
	private String pwd = null;
	private boolean loggedIn = false;
	private GetUserInfoResult userInfo = null;
	private String[] tasks = null;
	private String PARTNER_SOBJECT_NS = "urn:sobject.partner.soap.sforce.com";
	private boolean logOn = false;
	private boolean isDebug = false;

	public SalesForcePartnerAPI() {
	}

	public String login(String un, String pwd) {
		String retVal = "";

		try {
			isDebug = false;
			loggedIn = false;
			this.un = un.trim();
			this.pwd = pwd.trim();

			binding = (SoapBindingStub) new SforceServiceLocator().getSoap();
			binding.setTimeout(60000);
			loginResult = binding.login(this.un, this.pwd);

			// set the session header for subsequent call authentication
			binding._setProperty(SoapBindingStub.ENDPOINT_ADDRESS_PROPERTY, loginResult.getServerUrl());

			// Create a new session header object and set the session id to that
			// returned by the login
			SessionHeader sh = new SessionHeader();
			sh.setSessionId(loginResult.getSessionId());
			binding.setHeader(new SforceServiceLocator().getServiceName().getNamespaceURI(), "SessionHeader", sh);

			// Use the following in your login method, before you make your
			// login call to the service. set the call option for client id and
			// bind it to the current soap session
			// String clientID = "KetanJetty/";
			// CallOptions co = new CallOptions();
			// co.setClient(clientID);
			// binding.setHeader("SforceService", "CallOptions", co);

			setAssignmentRules();

			// assignrule.useDefaultRule = True
			// binding.AssignmentRuleHeaderValue = assignrule
			// 'end setting bindings to use current rules

			loggedIn = true;

			// retVal = loginResult.getUserId().getValue();
			retVal = loginResult.getUserId();
		} catch (Exception ex) {
			ex.printStackTrace();
			retVal = "Error [SalesForce]: " + retVal + ex.toString();
			System.err.println(retVal);
		}

		// System.out.println(retVal);
		return retVal;
	}

	public void setAssignmentRules() {

		/*
		 * // lead assignment rules AssignmentRuleHeader arh = new AssignmentRuleHeader(); binding.setHeader(new SforceServiceLocator().getServiceName().getNamespaceURI(), "AssignmentRuleHeader", arh); arh.setUseDefaultRule(new Boolean(true));
		 */

		try {
			String asgnRule = "Test Assignment Rule";
			QueryResult ar = binding.query("SELECT Id FROM AssignmentRule");
			for (int i = 0; i < ar.getSize(); i++) {

				SObject temp = ar.getRecords(i);

				// AssignmentRule rule = (AssignmentRule)ar.getRecords(i);
				// logger.debug("\tID: " + rule.getId() + " Name: " +
				// rule.getName()
				// + " Type: " + rule.getRuleType());
			}

			AssignmentRuleHeader arh = new AssignmentRuleHeader();
			arh.setUseDefaultRule(new Boolean(true));
			// arh.setAssignmentRuleId(ar.getRecords(0).getId());
			binding.setHeader(new SforceServiceLocator().getServiceName().getNamespaceURI(), "AssignmentRuleHeader", arh);
		} catch (Exception ex) {
			ex.printStackTrace();
		}

	}

	public void setDebug(String val) {
		isDebug = false;
		if (val != null) {
			if (val.trim().equalsIgnoreCase("1") || val.trim().equalsIgnoreCase("yes") || val.trim().equalsIgnoreCase("true")) {
				isDebug = true;
			}
		}
	}

	public String[] getMappings(String type) {
		String[] sourceVal = new String[10000];
		String[] retVal = null;

		try {
			DescribeSObjectResult[] rslts = binding.describeSObjects(new String[] { type });

			int k = 0;
			for (int i = 0; i < rslts.length; i++) {
				Field[] flds = rslts[i].getFields();

				for (int j = 0; j < flds.length; j++) {
					if (flds[j].isUpdateable()) {
						sourceVal[k] = rslts[i].getLabel() + "|" + flds[j].getName() + "|" + flds[j].getLabel();
						k++;

						if (isDebug) {
							System.out.println(rslts[i].getLabel() + " [" + rslts[i].getName() + "]: " + flds[j].getLabel() + " [" + flds[j].getName() + "]");
						}
					}
				}
			}

			// resize the array
			retVal = new String[k];
			System.arraycopy(sourceVal, 0, retVal, 0, k);
			sourceVal = null;
		} catch (Exception ex) {
			ex.printStackTrace();
			System.err.println("Error [SalesForce]:" + ex.getMessage());
		}

		return retVal;
	}

	private MessageElement newMessageElement(String name, Object value) throws Exception {
		MessageElement me = new MessageElement("", name.trim()); // , value);
		me.setObjectValue(value);
		Element e = me.getAsDOM();
		e.removeAttribute("xsi:type");
		e.removeAttribute("xmlns:ns1");
		e.removeAttribute("xmlns:xsd");
		e.removeAttribute("xmlns:xsi");
		me = new MessageElement(e);
		return me;
	}

	private String getFieldValue(MessageElement[] value, String name) {
		for (int i = 0; i < value.length; i++) {
			if (value[i].getName().toLowerCase().equals(name.toLowerCase()))
				return value[i].getValue();
		}
		return " ";
	}

	public String createDynamicSql(String recordType, String dataKeyValues, String comparer) {
		String retVal = "";
		StringBuffer sb = new StringBuffer();
		SimpleDateFormat sdf = null;
		Date tempDate = null;
		Date tempDate2000 = null;
		boolean putAND = false;

		String[] avoidKeys = { "Description" };

		try {
			if (dataKeyValues != null && dataKeyValues.length() > 0) {
				sdf = new SimpleDateFormat("yyyy-MM-dd");
				tempDate2000 = sdf.parse("2000-01-01");
				String[] aryKeyValues = dataKeyValues.split("\\|");
				sb.append("select ");

				if (dataKeyValues != null && dataKeyValues.length() > 0) {
					for (int j = 0; j < aryKeyValues.length; j++) {
						if (aryKeyValues[j].length() > 0 && aryKeyValues[j].indexOf("=", 0) > 0) {
							String[] aryKeyValue = aryKeyValues[j].split("\\=");
							if (aryKeyValue != null) {
								// System.out.println(aryKeyValue[0].toString());
								for (int k = 0; k < avoidKeys.length; k++) {
									if (!aryKeyValue[0].toString().trim().equalsIgnoreCase(avoidKeys[k].toString().trim())) {
										if (j > 0) {
											sb.append(", ");
										}

										sb.append(aryKeyValue[0]);
									}
								}
							}
						}
					}
				}

				sb.append(" from " + recordType + " where ");

				// System.out.println(sb.toString());

				for (int i = 0; i < aryKeyValues.length; i++) {
					if (aryKeyValues[i].length() > 0 && aryKeyValues[i].indexOf("=", 0) > 0) {
						String[] aryKeyValue = aryKeyValues[i].split("\\=");
						if (aryKeyValue != null) {
							for (int k = 0; k < avoidKeys.length; k++) {
								if (!aryKeyValue[0].toString().trim().equalsIgnoreCase(avoidKeys[k].toString().trim())) {

									if (aryKeyValue.length > 1 && (aryKeyValue[0].trim().length() > 0 && aryKeyValue[1].trim().length() > 0)) {
										try {
											tempDate = sdf.parse(aryKeyValue[1].trim());
										} catch (Exception exDate) {
											tempDate = null;
										}

										if (tempDate != null) {
											if (tempDate.after(tempDate2000) && aryKeyValue[1].trim().length() == 10) {
												if (putAND) {
													sb.append(" and ");
												}

												sb.append(aryKeyValue[0] + " = " + aryKeyValue[1]);
											}
										} else {
											if (putAND) {
												sb.append(" and ");
											}

											// escape the single quote
											String tempAryKeyValue1 = aryKeyValue[1].toString().trim();

											if (tempAryKeyValue1.contains("'")) {
												tempAryKeyValue1 = tempAryKeyValue1.replaceAll("'", "\\\\'");
											}

											if (comparer != null && comparer.trim().equalsIgnoreCase("like")) {
												sb.append(aryKeyValue[0] + " like '" + tempAryKeyValue1 + "%'");
											} else {
												sb.append(aryKeyValue[0] + " = '" + tempAryKeyValue1 + "'");
											}
										}

										putAND = true;
									}

								}
							}
						}
					}
				}

				retVal = sb.toString();
			}
		} catch (Exception ex) {
			ex.printStackTrace();
			retVal = "Error [SalesForce]: " + retVal + ex.toString();
			System.err.println(retVal);
		}

		if (isDebug) {
			System.out.println("from createDynamicSql(): " + retVal);
		}

		return retVal;
	}

	public String getRecord(String recordType, String dataKeyValues, String comparer) throws Exception {
		String retVal = "";
		StringBuffer sb = new StringBuffer();

		try {
			if (dataKeyValues != null && dataKeyValues.trim().length() > 0) {
				String strSqlSelect = createDynamicSql(recordType, dataKeyValues, comparer);
				QueryResult qr = binding.query(strSqlSelect);

				if (qr.getSize() > 0) {
					for (int i = 0; i < qr.getRecords().length; i++) {
						SObject sobj = qr.getRecords(i);
						if (i > 0) {
							sb.append("|");
						}

						if (dataKeyValues != null && dataKeyValues.length() > 0) {
							String[] aryKeyValues = dataKeyValues.split("\\|");

							for (int j = 0; j < aryKeyValues.length; j++) {
								if (aryKeyValues[j].length() > 0 && aryKeyValues[j].indexOf("=", 0) > 0) {
									String[] aryKeyValue = aryKeyValues[j].split("\\=");
									if (aryKeyValue != null) {
										sb.append(recordType + aryKeyValue[0] + "=" + getFieldValue(sobj.get_any(), aryKeyValue[0]) + ";");
									}
								}
							}
						}
					}
				}
			}

			retVal = sb.toString();
		} catch (Exception ex) {
			ex.printStackTrace();
			retVal = "Error [SalesForce]: " + retVal + ex.toString();
			System.err.println(retVal);
		}

		if (isDebug) {
			System.out.println("from getRecord(): " + retVal);
		}

		return retVal;
	}

	public String checkRecord(String recordType, String dataKeyValues, String comparer) throws Exception {
		String retVal = "";

		try {
			if (dataKeyValues != null && dataKeyValues.trim().length() > 0) {
				String strSqlSelect = createDynamicSql(recordType, dataKeyValues, comparer);
				QueryResult qr = binding.query(strSqlSelect);

				if (qr.getSize() > 0) {
					for (int i = 0; i < qr.getRecords().length; i++) {
						SObject sobj = qr.getRecords(i);

						if (dataKeyValues != null && dataKeyValues.length() > 0) {
							String[] aryKeyValues = dataKeyValues.split("\\|");

							for (int j = 0; j < aryKeyValues.length; j++) {
								if (aryKeyValues[j].length() > 0 && aryKeyValues[j].indexOf("=", 0) > 0) {
									String[] aryKeyValue = aryKeyValues[j].split("\\=");
									if (aryKeyValue != null) {
										// sb.append(recordType + aryKeyValue[0]
										// + "=" + getFieldValue(sobj.get_any(),
										// aryKeyValue[0]) + ";");

										if (aryKeyValue[0].trim().equalsIgnoreCase("id")) {
											retVal = getFieldValue(sobj.get_any(), aryKeyValue[0]);
										}
									}
								}
							}
						}
					}
				}
			}
		} catch (Exception ex) {
			ex.printStackTrace();
			retVal = "Error [SalesForce]: " + retVal + ex.toString();
			System.err.println(retVal);
		}

		if (isDebug) {
			System.out.println("from checkRecord(): " + recordType + " " + retVal);
		}

		return retVal;
	}

	public String upsertRecord(String recordType, String dataKeyValues) {
		String retVal = "";
		MessageElement[] me = null;
		SObject[] newSObject = null;
		SaveResult[] sr = null;

		try {
			if (dataKeyValues != null && dataKeyValues.trim().length() > 0) {
				String[] aryKeyValues = dataKeyValues.split("\\|");
				me = new MessageElement[aryKeyValues.length];

				for (int i = 0; i < aryKeyValues.length; i++) {
					if (aryKeyValues[i].trim().length() > 0 && aryKeyValues[i].indexOf("=", 0) > 0) {
						String[] aryKeyValue = aryKeyValues[i].split("\\=");
						if (aryKeyValue != null) {
							if (aryKeyValue.length > 1 && (aryKeyValue[0].trim().length() > 0 && aryKeyValue[1].trim().length() > 0)) {
								me[i] = newMessageElement(aryKeyValue[0], aryKeyValue[1]);
							} else if (aryKeyValue[0].trim().length() > 0) {
								me[i] = newMessageElement(aryKeyValue[0], "");
							}
						}
					}
				}

				// String result = getRecord(recordType, dataKeyValues, null);
				String result = checkRecord(recordType, dataKeyValues, null);
				retVal = result;

				if (result != null && result.trim().length() == 0) {
					newSObject = new SObject[1];
					newSObject[0] = new SObject();
					newSObject[0].setType(recordType);
					newSObject[0].set_any(me);

					sr = binding.create(newSObject);

					for (int j = 0; j < sr.length; j++) {
						if (sr[j].isSuccess()) {
							// retVal = recordType + " record is created with an
							// id of: "+ sr[j].getId();
							// retVal = sr[j].getId().getValue();
							retVal = sr[j].getId();
						} else {
							for (int k = 0; k < sr[j].getErrors().length; k++) {
								com.sforce.soap.partner.Error err = sr[j].getErrors()[k];
								retVal = "Error [SalesForce]: " + err.getMessage() + " [" + err.getStatusCode().toString() + "]";
							}
						}
					}
				}
			}
		} catch (Exception ex) {
			ex.printStackTrace();
			retVal = "Error [SalesForce]: " + retVal + ex.toString();
			System.err.println(retVal);
		}

		if (isDebug) {
			System.out.println("from upsertRecord(): " + recordType + " " + retVal);
		}

		return retVal;
	}

	public String[] getAllObjects() {
		String[] retVal = new String[0];

		try {
			DescribeGlobalResult describeGlobalResult = binding.describeGlobal();
			if (!(describeGlobalResult == null)) {
				retVal = describeGlobalResult.getTypes();
				if (isDebug) {
					if (!(retVal == null)) {
						for (int i = 0; i < retVal.length; i++) {
							System.out.println(retVal[i]);
						}
					}
				}
			}
		} catch (Exception ex) {
			ex.printStackTrace();
			retVal[0] = "Error [SalesForce]: " + retVal + ex.toString();
			System.err.println(retVal);
		}

		return retVal;
	}
}