고객 데이터 CRM 동기화

// 고객 데이터 동기화 - 통합 Webhook 시스템 class MakeCom_CRM_Sync { private $webhook_url; public function __construct() { $this->webhook_url = get_option('makecom_crm_webhook_url'); // 이벤트 1: 새 주문 완료 add_action('woocommerce_order_status_completed', [$this, 'sync_order']); add_action('woocommerce_order_status_processing', [$this, 'sync_order']); // 이벤트 2: 회원가입 add_action('user_register', [$this, 'sync_new_user']); // 이벤트 3: 프로필 업데이트 add_action('profile_update', [$this, 'sync_profile_update'], 10, 2); // 이벤트 4: 리뷰 작성 add_action('comment_post', [$this, 'sync_review'], 10, 3); } public function sync_order($order_id) { $order = wc_get_order($order_id); $customer_id = $order->get_customer_id(); // 고객 통계 계산 $total_orders = wc_get_customer_order_count($customer_id); $total_spent = wc_get_customer_total_spent($customer_id); $avg_order = $total_orders > 0 ? $total_spent / $total_orders : 0; // 고객 세그먼트 결정 $segment = $this->calculate_segment($total_orders, $total_spent); // 구매 상품 목록 $products = []; $categories = []; foreach ($order->get_items() as $item) { $product = $item->get_product(); $products[] = [ 'name' => $item->get_name(), 'sku' => $product ? $product->get_sku() : '', 'price' => $item->get_total(), 'quantity' => $item->get_quantity(), ]; // 구매 카테고리 수집 if ($product) { $cat_ids = $product->get_category_ids(); foreach ($cat_ids as $cid) { $term = get_term($cid); if ($term) $categories[] = $term->name; } } } // RFM 분석 데이터 $last_order_date = $order->get_date_created(); $days_since_last = floor((time() - $last_order_date->getTimestamp()) / 86400); $payload = [ 'event' => 'order_completed', 'customer_id' => $customer_id, 'email' => $order->get_billing_email(), 'first_name' => $order->get_billing_first_name(), 'last_name' => $order->get_billing_last_name(), 'phone' => $order->get_billing_phone(), 'total_orders' => $total_orders, 'total_spent' => round($total_spent, 0), 'avg_order_value' => round($avg_order, 0), 'segment' => $segment, 'last_order_id' => $order_id, 'last_order_date' => $last_order_date->date('Y-m-d'), 'last_order_total' => $order->get_total(), 'products' => $products, 'purchase_categories' => array_unique($categories), 'days_since_last' => $days_since_last, 'rfm_recency' => $this->rfm_score('recency', $days_since_last), 'rfm_frequency' => $this->rfm_score('frequency', $total_orders), 'rfm_monetary' => $this->rfm_score('monetary', $total_spent), ]; $this->send_webhook($payload); } private function calculate_segment($orders, $spent) { if ($orders >= 10 || $spent >= 500000) return 'vip'; if ($orders >= 5 || $spent >= 200000) return 'loyal'; if ($orders >= 2) return 'repeat'; return 'new'; } private function rfm_score($type, $value) { switch ($type) { case 'recency': if ($value return 5; if ($value return 4; if ($value return 3; if ($value return 2; return 1; case 'frequency': if ($value >= 10) return 5; if ($value >= 5) return 4; if ($value >= 3) return 3; if ($value >= 2) return 2; return 1; case 'monetary': if ($value >= 500000) return 5; if ($value >= 200000) return 4; if ($value >= 100000) return 3; if ($value >= 50000) return 2; return 1; } return 1; } public function sync_new_user($user_id) { $user = get_userdata($user_id); $this->send_webhook([ 'event' => 'new_customer', 'email' => $user->user_email, 'name' => $user->display_name, 'user_id' => $user_id, 'registered' => $user->user_registered, 'segment' => 'new', 'source' => get_user_meta($user_id, 'registration_source', true) ?: 'direct', ]); } private function send_webhook($data) { if (empty($this->webhook_url)) return; wp_remote_post($this->webhook_url, [ 'headers' => ['Content-Type' => 'application/json'], 'body' => wp_json_encode($data), 'timeout' => 15, ]); } } new MakeCom_CRM_Sync();