Mükerrer lead'leri telefondan birleştir

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

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

	leadId = leadId.trim();
	masterLead = zoho.crm.getRecordById("Leads",leadId.toLong());

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

	searchPhones = List();
	masterPhoneKeys = List();

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

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

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

	if(searchPhones.size() == 0)
	{
		info "Phone ve Mobile 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/Leads/search"
				type :GET
				parameters:searchParams
				connection:"crm_oauth_v8"
			];

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

					foundPhoneKey = ifnull(foundLead.get("Phone"),"").toString().replaceAll("[^0-9]","");
					foundMobileKey = ifnull(foundLead.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 != leadId && exactMatch && !duplicateIds.contains(foundId))
					{
						duplicateIds.add(foundId);
					}
				}
			}
		}
		catch (searchError)
		{
			info "Telefon arama hatası: " + searchError.toString();
		}
	}

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

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

	transferFields = List();
	transferFields.add("Salutation");
	transferFields.add("First_Name");
	transferFields.add("Last_Name");
	transferFields.add("Company");
	transferFields.add("Email");
	transferFields.add("Secondary_Email");
	transferFields.add("Phone");
	transferFields.add("Mobile");
	transferFields.add("Fax");
	transferFields.add("Designation");
	transferFields.add("Website");
	transferFields.add("Street");
	transferFields.add("City");
	transferFields.add("State");
	transferFields.add("Zip_Code");
	transferFields.add("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("Leads",leadId.toLong());
			childLead = zoho.crm.getRecordById("Leads",childId.toLong());

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

				for each fieldApiName in transferFields
				{
					masterValue = currentMaster.get(fieldApiName);
					childValue = childLead.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 = childLead.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/Leads/" + leadId + "/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();
}
}