<?php
require_once dirname(__FILE__) . '/Settings.php';

class GoogleMaps {
private $apiKey;
private $db;

public function __construct($db) {
$this->db = $db;

// API anahtarını Settings sınıfından al
$settings = Settings::getInstance();
$this->apiKey = $settings->get('google_maps_api_key');

// Eğer API anahtarı boşsa, varsayılan anahtarı kullan
if (empty($this->apiKey)) {
$this->apiKey = 'AIzaSyCGvO76XTaMK1P2zhdP8S_BCuYtHp_ukcw'; // Varsayılan API anahtarı
error_log("Google Maps API anahtarı ayarlardan bulunamadı. Varsayılan anahtar kullanılıyor.");
}
}

public function searchBusinesses($city, $district, $sector) {
try {
$query = urlencode("$sector in $district, $city, Turkey");
$url = "https://maps.googleapis.com/maps/api/place/textsearch/json?query={$query}&key={$this->apiKey}";

// Debug bilgileri
error_log("API Request URL: " . $url);

// CURL kullanarak isteği yapalım
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);

$response = curl_exec($ch);
$httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);

// CURL hata kontrolü
if(curl_errno($ch)) {
error_log("CURL Error: " . curl_error($ch));
throw new Exception("API isteği başarısız oldu: " . curl_error($ch));
}

curl_close($ch);

// HTTP yanıt kodu kontrolü
error_log("HTTP Response Code: " . $httpCode);
error_log("API Response: " . $response);

$result = json_decode($response, true);

if (!$result) {
error_log("JSON Decode Error: " . json_last_error_msg());
throw new Exception("API yanıtı JSON formatında değil");
}

if (isset($result['status']) && $result['status'] !== 'OK') {
error_log("API Error Status: " . $result['status']);
if (isset($result['error_message'])) {
error_log("API Error Message: " . $result['error_message']);
}
throw new Exception("API hatası: " . ($result['error_message'] ?? $result['status']));
}

// Sonuçları işle ve veritabanına kaydet
if (isset($result['results']) && is_array($result['results'])) {
foreach ($result['results'] as $place) {
$data = [
'business_name' => $place['name'],
'phone' => null, // Detay API'sinden alınacak
'whatsapp_number' => null,
'address' => $place['formatted_address'],
'city' => $city,
'district' => $district,
'sector' => $sector,
'latitude' => $place['geometry']['location']['lat'],
'longitude' => $place['geometry']['location']['lng'],
'is_whatsapp_active' => 1
];

// İşletmeyi veritabanına kaydet
$this->saveToDatabase($data);

// Detay bilgilerini al (telefon numarası için)
if (isset($place['place_id'])) {
$this->getBusinessDetails($place['place_id']);
}
}
return true;
}

return false;

} catch (Exception $e) {
error_log("Exception in searchBusinesses: " . $e->getMessage());
throw $e;
}
}

private function getBusinessDetails($placeId) {
try {
$url = "https://maps.googleapis.com/maps/api/place/details/json?place_id={$placeId}&fields=name,formatted_phone_number,formatted_address,geometry&key={$this->apiKey}";

error_log("Details API Request URL: " . $url);

$response = file_get_contents($url);

if ($response === false) {
error_log("Details API isteği başarısız oldu: " . error_get_last()['message']);
return false;
}

$result = json_decode($response, true);

error_log("Details API Response: " . print_r($result, true));

if ($result['status'] == 'OK') {
$place = $result['result'];

$phone = isset($place['formatted_phone_number']) ?
$this->formatPhoneNumber($place['formatted_phone_number']) : null;

$data = [
'business_name' => $place['name'],
'phone' => $phone,
'whatsapp_number' => $phone,
'address' => $place['formatted_address'],
'city' => isset($_POST['city']) ? $_POST['city'] : '',
'district' => isset($_POST['district']) ? $_POST['district'] : '',
'sector' => isset($_POST['sector']) ? $_POST['sector'] : '',
'latitude' => $place['geometry']['location']['lat'],
'longitude' => $place['geometry']['location']['lng'],
'is_whatsapp_active' => 1
];

return $this->saveToDatabase($data);
}
return false;
} catch (Exception $e) {
error_log("Details API Hatası: " . $e->getMessage());
return false;
}
}

private function formatPhoneNumber($phone) {
// Telefon numarasını temizle (sadece rakamları al)
$phone = preg_replace('/[^0-9]/', '', $phone);

// Türkiye formatına çevir
if (strlen($phone) == 10) {
return '+90' . $phone;
} elseif (strlen($phone) == 11 && substr($phone, 0, 1) == '0') {
return '+9' . $phone;
}
return $phone;
}

private function saveToDatabase($data) {
try {
// Önce bu işletmenin daha önce eklenip eklenmediğini kontrol et
$checkSql = "SELECT id FROM businesses WHERE business_name = :name AND address = :address LIMIT 1";
$checkStmt = $this->db->prepare($checkSql);
$checkStmt->execute([
':name' => $data['business_name'],
':address' => $data['address']
]);

if ($checkStmt->fetch()) {
// İşletme zaten var, güncelle
$sql = "UPDATE businesses SET
phone = COALESCE(:phone, phone),
whatsapp_number = COALESCE(:whatsapp, whatsapp_number),
city = COALESCE(:city, city),
district = COALESCE(:district, district),
sector = COALESCE(:sector, sector),
latitude = COALESCE(:lat, latitude),
longitude = COALESCE(:lng, longitude),
is_whatsapp_active = :is_whatsapp
WHERE business_name = :name AND address = :address";
} else {
// Yeni işletme ekle
$sql = "INSERT INTO businesses (
business_name, phone, whatsapp_number,
address, city, district, sector,
latitude, longitude, is_whatsapp_active
) VALUES (
:name, :phone, :whatsapp,
:address, :city, :district, :sector,
:lat, :lng, :is_whatsapp
)";
}

$stmt = $this->db->prepare($sql);

return $stmt->execute([
':name' => $data['business_name'],
':phone' => $data['phone'],
':whatsapp' => $data['whatsapp_number'],
':address' => $data['address'],
':city' => $data['city'],
':district' => $data['district'],
':sector' => $data['sector'],
':lat' => $data['latitude'],
':lng' => $data['longitude'],
':is_whatsapp' => $data['is_whatsapp_active']
]);

} catch(PDOException $e) {
error_log("Error saving business: " . $e->getMessage());
return false;
}
}
}
?>