facebook conversion api client for perl - end0tknr's kipple - web写経開発
先程のentryのphp版です
目次
form_fb_capi.php
<?php require_once './form/lib/XeimForm4FacebookConversion.php'; $fb_api = new XeimForm4FacebookConversion(); $form_url = $_POST["referrer"]; $fb_api->notify_to_facebook("sexyxeim_com",$form_url,$_POST);
XeimForm4FacebookConversion.php
<?php require_once 'XeimForm.php'; class XeimForm4FacebookConversion extends XeimForm { function __construct() { $this->ini_set(); } function error_mail_subject(){ return "【FacebookConversion】ERROR通知メール"; } function error_mail_body($name_1,$refferer,$endpoint,$http_res_code){ $mail_body =<<<EOF $name_1 様の申し込みがfacebookへ連携されませんでした。 フォームURL : $refferer facebook URL : $endpoint HTTP RESPONSE CODE : $http_res_code EOF; return $mail_body; } function notify_to_facebook($facebook_rule_name, $refferer, $req_params ){ $func_name = __CLASS__." ".__FUNCTION__; $this->write_log("START $func_name for $facebook_rule_name $refferer"); $facebook_rule = $this->facebook_rule($facebook_rule_name); if(! $facebook_rule ){ $tmp_msg = "ERROR fail $func_name $facebook_rule_name"; $this->write_log($tmp_msg); $tmp_msg = print_r($req_params,true); $this->write_log($tmp_msg); return false; } $form_data = [ ["user_data" => $this->conv_req_params_for_facebook($req_params, $facebook_rule), "action_source" =>"website", "event_name" =>"FromRequest", "event_time" => time(), "event_source_url"=>$refferer] ]; //$this->write_log(print_r($form_data,true)); $endpoint = $facebook_rule["FACEBOOK_URL"]; $req_data = [ "access_token"=>$facebook_rule["ACCESS_TOKEN"], "data"=> $this->json_encode($form_data), ]; $http_res_code = $this->post_to_facebook($req_data, $endpoint); if ( in_array($http_res_code,["200","204"], true) ){ $tmp_msg = "DONE $func_name $facebook_rule_name"; $this->write_log($tmp_msg); return true; } $tmp_msg = "ERROR $func_name $facebook_rule_name HTTP_CODE:$http_res_code"; $this->write_log($tmp_msg); $this->notify_error($req_params,$refferer,$endpoint,$http_res_code); return false; } private function notify_error($req_params,$refferer,$endpoint,$http_res_code){ $func_name = __CLASS__." ".__FUNCTION__; $mail_body = $this->error_mail_body($req_params['name1'], $refferer, $endpoint, $http_res_code); //全体のシステム管理者へ、メール通知 $sendmail = new XeimForm4Sendmail(); $sendmail->mail_to_sys_admin(self::ERR_MAIL_SUBJECT, $mail_body); $tmp_msg = "ERROR $func_name"; $this->write_log($tmp_msg); $this->write_log($mail_body); $this->write_log(print_r($req_params,true)); } private function conv_req_params_for_facebook($org_params, $facebook_rule){ $cooperation_items_def = $facebook_rule["COOPERATION_ITEM"]; $new_params = []; foreach($cooperation_items_def as $facebook_key => $from_key){ //$this->write_log( "$facebook_key , $from_key" ); if(! isset($org_params[$from_key]) or mb_strlen($org_params[$from_key]) == 0){ continue; } //$this->write_log("$facebook_key $from_key , ".$org_params[$from_key]); $new_params[$facebook_key] = $org_params[$from_key]; # refer to https://developers.facebook.com/docs/marketing-api/conversions-api/parameters if( strcmp($facebook_key, "em") == 0 ){ $new_params[$facebook_key] = [ hash('sha256', $new_params[$facebook_key]) ]; } } return $new_params; } private function facebook_rule($rule_name){ $func_name = __CLASS__." ".__FUNCTION__; $conf_dir = $this->conf_dir(); $file_path = $conf_dir ."/facebook/$rule_name.json"; try{ $file_obj = new SplFileObject($file_path,"rb"); $json_str = $file_obj->fread($file_obj->getSize()); } catch (Exception $e) { $tmp_msg = "ERROR fail open $file_path $func_name ". $e->getMessage(); $this->write_log($tmp_msg); return; } $ret_def = $this->json_decode($json_str); return $ret_def; } private function post_to_facebook($postdata, $endpoint){ $func_name = __CLASS__." ".__FUNCTION__; $this->write_log("START $func_name to $endpoint"); //$this->write_log(print_r($postdata,true)); $ch = curl_init(); curl_setopt($ch, CURLOPT_POST, true); curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($postdata)); curl_setopt($ch, CURLOPT_URL, $endpoint); curl_setopt($ch, CURLOPT_SSL_VERIFYPEER,FALSE); curl_setopt($ch, CURLOPT_SSL_VERIFYHOST,FALSE); curl_setopt($ch, CURLOPT_RETURNTRANSFER,TRUE); curl_setopt($ch, CURLOPT_FAILONERROR, TRUE); $res_body_json = curl_exec($ch); $curl_getinfo = curl_getinfo($ch); $status_code = $curl_getinfo["http_code"]; if (curl_errno($ch)) { $tmp_msg = "ERROR $func_name $endpoint $status_code $res_body_json"; $this->write_log($tmp_msg); return; } $res_body = $this->json_decode($res_body_json); if( $res_body["events_received"] != 1 ){ $tmp_msg = "ERROR $func_name $endpoint $status_code $res_body_json"; $this->write_log($tmp_msg); return; } curl_close($ch); return (string)$status_code; } }
sexyxeim_com.json
{"//":"ex. https://graph.facebook.com/{API_VERSION}/{PIXEL_ID}/events", "FACEBOOK_URL":"https://graph.facebook.com/v12.0/ないしょ/events", "ACCESS_TOKEN":"ないしょ", "NOTIFY_TO":"hogehoge1@example.com,hogehoge2@example.com", "//":"連携項目", "COOPERATION_ITEM" : {"em" :"email1"} }
実行例
$ curl -X POST \ -F 'email1=hogehoge@gmail.com' \ -F 'referrer=https://hoge.example.com/cgi-bin/form.cgi' \ http://localhost/cgi-bin2/form_fb_capi.php
