Mükerrer kişileri telefon ve e-postadan birleştir

void automation.mergeContactsByPhoneMobileEmail(String contactId)
{
try
{
	info "===== Contact Mükerrer Birleştirme Başladı =====";
	info "Master Contact ID: " + contactId;

	if(contactId == null || contactId.trim() == "")
	{
		info "Contact ID boş.";
		return;
	}

	contactId = contactId.trim();
	masterContact = zoho.crm.getRecordById("Contacts",contactId.toLong());

	if(masterContact == null || masterContact.isEmpty())
	{
		info "Master Contact bulunamadı.";
		return;
	}

	searchPhones = List();
	masterPhoneKeys = List();
	masterEmail = "";

	if(masterContact.get("Phone") != null && masterContact.get("Phone").toString().trim() != "")
	{
		searchPhones.add(masterContact.get("Phone").toString().trim());
	}

	if(masterContact.get("Mobile") != null && masterContact.get("Mobile").toString().trim() != "")
	{
		mobileValue = masterContact.get("Mobile").toString().trim();

		if(!searchPhones.contains(mobileValue))
		{
			searchPhones.add(mobileValue);
		}
	}

	if(masterContact.get("Email") != null && masterContact.get("Email").toString().trim() != "")
	{
		masterEmail = masterContact.get("Email").toString().trim().toLowerCase();
	}

	if(searchPhones.size() == 0 && masterEmail == "")
	{
		info "Phone, Mobile ve Email alanları boş.";
		return;
	}

	for each searchPhone in searchPhones
	{
		phoneKey = searchPhone.replaceAll("[^0-9]","");

		if(phoneKey.startsWith("0090") && phoneKey.length() == 14)
		{
			phoneKey = phoneKey.subString(4,phoneKey.length());
		}
		else if(phoneKey.startsWith("90") && phoneKey.length() == 12)
		{
			phoneKey = phoneKey.subString(2,phoneKey.length());
		}
		else if(phoneKey.startsWith("0") && phoneKey.length() == 11)
		{
			phoneKey = phoneKey.subString(1,phoneKey.length());
		}

		if(phoneKey != "" && !masterPhoneKeys.contains(phoneKey))
		{
			masterPhoneKeys.add(phoneKey);
		}
	}

	duplicateIds = List();

	for each searchPhone in searchPhones
	{
		try
		{
			searchParams = Map();
			searchParams.put("phone",searchPhone);
			searchParams.put("page",1);
			searchParams.put("per_page",200);

			searchResponse = invokeurl
			[
				url :"https://www.zohoapis.eu/crm/v8/Contacts/search"
				type :GET
				parameters:searchParams
				connection:"crm_oauth_v8"
			];

			if(searchResponse != null && searchResponse.get("data") != null)
			{
				for each foundContact in searchResponse.get("data")
				{
					foundId = ifnull(foundContact.get("id"),"").toString();

					foundPhoneKey = ifnull(foundContact.get("Phone"),"").toString().replaceAll("[^0-9]","");
					foundMobileKey = ifnull(foundContact.get("Mobile"),"").toString().replaceAll("[^0-9]","");

					if(foundPhoneKey.startsWith("0090") && foundPhoneKey.length() == 14)
					{
						foundPhoneKey = foundPhoneKey.subString(4,foundPhoneKey.length());
					}
					else if(foundPhoneKey.startsWith("90") && foundPhoneKey.length() == 12)
					{
						foundPhoneKey = foundPhoneKey.subString(2,foundPhoneKey.length());
					}
					else if(foundPhoneKey.startsWith("0") && foundPhoneKey.length() == 11)
					{
						foundPhoneKey = foundPhoneKey.subString(1,foundPhoneKey.length());
					}

					if(foundMobileKey.startsWith("0090") && foundMobileKey.length() == 14)
					{
						foundMobileKey = foundMobileKey.subString(4,foundMobileKey.length());
					}
					else if(foundMobileKey.startsWith("90") && foundMobileKey.length() == 12)
					{
						foundMobileKey = foundMobileKey.subString(2,foundMobileKey.length());
					}
					else if(foundMobileKey.startsWith("0") && foundMobileKey.length() == 11)
					{
						foundMobileKey = foundMobileKey.subString(1,foundMobileKey.length());
					}

					exactMatch = false;

					if(foundPhoneKey != "" && masterPhoneKeys.contains(foundPhoneKey))
					{
						exactMatch = true;
					}

					if(foundMobileKey != "" && masterPhoneKeys.contains(foundMobileKey))
					{
						exactMatch = true;
					}

					if(foundId != "" && foundId != contactId && exactMatch && !duplicateIds.contains(foundId))
					{
						duplicateIds.add(foundId);
					}
				}
			}
		}
		catch (searchError)
		{
			info "Telefon arama hatası: " + searchError.toString();
		}
	}

	if(masterEmail != "")
	{
		try
		{
			emailParams = Map();
			emailParams.put("email",masterEmail);
			emailParams.put("page",1);
			emailParams.put("per_page",200);

			emailResponse = invokeurl
			[
				url :"https://www.zohoapis.eu/crm/v8/Contacts/search"
				type :GET
				parameters:emailParams
				connection:"crm_oauth_v8"
			];

			if(emailResponse != null && emailResponse.get("data") != null)
			{
				for each foundContact in emailResponse.get("data")
				{
					foundId = ifnull(foundContact.get("id"),"").toString();
					foundEmail = ifnull(foundContact.get("Email"),"").toString().trim().toLowerCase();

					if(foundId != "" && foundId != contactId && foundEmail == masterEmail && !duplicateIds.contains(foundId))
					{
						duplicateIds.add(foundId);
					}
				}
			}
		}
		catch (emailSearchError)
		{
			info "Email arama hatası: " + emailSearchError.toString();
		}
	}

	if(duplicateIds.size() == 0)
	{
		info "Birleştirilecek mükerrer Contact bulunamadı.";
		return;
	}

	info "Mükerrer Contact ID'leri: " + duplicateIds;

	transferFields = List();
	transferFields.add("Salutation");
	transferFields.add("First_Name");
	transferFields.add("Last_Name");
	transferFields.add("Email");
	transferFields.add("Secondary_Email");
	transferFields.add("Phone");
	transferFields.add("Mobile");
	transferFields.add("Home_Phone");
	transferFields.add("Other_Phone");
	transferFields.add("Fax");
	transferFields.add("Title");
	transferFields.add("Department");
	transferFields.add("Mailing_Street");
	transferFields.add("Mailing_City");
	transferFields.add("Mailing_State");
	transferFields.add("Mailing_Zip");
	transferFields.add("Mailing_Country");
	transferFields.add("Other_Street");
	transferFields.add("Other_City");
	transferFields.add("Other_State");
	transferFields.add("Other_Zip");
	transferFields.add("Other_Country");
	transferFields.add("Description");

	requestHeaders = Map();
	requestHeaders.put("Content-Type","application/json");

	mergedCount = 0;
	mergeCanContinue = true;

	for each childId in duplicateIds
	{
		if(mergeCanContinue)
		{
			currentMaster = zoho.crm.getRecordById("Contacts",contactId.toLong());
			childContact = zoho.crm.getRecordById("Contacts",childId.toLong());

			if(currentMaster == null || currentMaster.isEmpty())
			{
				info "Master Contact bulunamadığı için işlem durduruldu.";
				mergeCanContinue = false;
			}
			else if(childContact == null || childContact.isEmpty())
			{
				info "Child Contact bulunamadı: " + childId;
			}
			else
			{
				fieldList = List();

				for each fieldApiName in transferFields
				{
					masterValue = currentMaster.get(fieldApiName);
					childValue = childContact.get(fieldApiName);

					if((masterValue == null || masterValue.toString().trim() == "") && childValue != null && childValue.toString().trim() != "")
					{
						fieldMap = Map();
						fieldMap.put("api_name",fieldApiName);
						fieldList.add(fieldMap);
					}
				}

				if(fieldList.size() == 0)
				{
					for each fieldApiName in transferFields
					{
						if(fieldList.size() == 0)
						{
							masterValue = currentMaster.get(fieldApiName);
							childValue = childContact.get(fieldApiName);

							if(masterValue != null && childValue != null && masterValue.toString().trim() != "" && masterValue.toString().trim().toLowerCase() == childValue.toString().trim().toLowerCase())
							{
								fieldMap = Map();
								fieldMap.put("api_name",fieldApiName);
								fieldList.add(fieldMap);
							}
						}
					}
				}

				if(fieldList.size() == 0)
				{
					info "Güvenli aktarım alanı bulunamadı; merge atlandı: " + childId;
				}
				else
				{
					childMap = Map();
					childMap.put("id",childId);
					childMap.put("_fields",fieldList);

					dataList = List();
					dataList.add(childMap);

					mergeObject = Map();
					mergeObject.put("data",dataList);

					mergeList = List();
					mergeList.add(mergeObject);

					payload = Map();
					payload.put("merge",mergeList);

					try
					{
						mergeResponse = invokeurl
						[
							url :"https://www.zohoapis.eu/crm/v8/Contacts/" + contactId + "/actions/merge"
							type :POST
							body:payload.toString()
							headers:requestHeaders
							connection:"crm_oauth_v8"
						];

						info "Merge response: " + mergeResponse;

						if(mergeResponse != null && mergeResponse.get("merge") != null && mergeResponse.get("merge").size() > 0)
						{
							mergeResult = mergeResponse.get("merge").get(0);
							mergeCode = ifnull(mergeResult.get("code"),"").toString();

							if(mergeCode == "SUCCESS")
							{
								mergedCount = mergedCount + 1;
							}
							else if(mergeCode == "SCHEDULED")
							{
								info "Merge zamanlandı. Kalan kayıtlar sonraki çalışmaya bırakıldı.";
								mergeCanContinue = false;
							}
						}
					}
					catch (mergeError)
					{
						info "Merge hatası | Child ID: " + childId + " | " + mergeError.toString();
					}
				}
			}
		}
	}

	info "Başarılı merge sayısı: " + mergedCount;
}
catch (e)
{
	info "Genel hata: " + e.toString();
}
}