get_base_path();
add_action( 'plugins_loaded', array( $this, 'setup_main' ) );
register_deactivation_hook(__FILE__,array($this,'deactivate'));
register_activation_hook(__FILE__,(array($this,'activate')));
}
/**
* Plugin starting point. Will load appropriate files
*
*/
public function init(){
self::$gf_status= $this->gravity_forms_status();
if(self::$gf_status !== 1){
add_action( 'admin_notices', array( $this, 'install_gf_notice' ) );
$slug=$this->get_slug();
add_action( 'after_plugin_row_'.$slug, array( $this, 'install_gf_notice_plugin_row' ) );
return;
}
$pro_file=self::$path . 'wp/crmperks-notices.php';
if(file_exists($pro_file)){
include_once($pro_file);
self::$is_pr=false;
}else{
$this->plugin_api(true);
self::$is_pr=true;
$pro_file=self::$path . 'pro/add-ons.php';
if(file_exists($pro_file)){
include_once($pro_file);
} }
require_once(self::$path . "includes/crmperks-gf.php");
require_once(self::$path . "includes/plugin-pages.php");
}
/**
* install plugin
*
*/
public function setup_main(){
include_once(self::$path. "includes/edit-form.php");
//handling post submission. gform_after_submission runs after gform_replace_merge_tags
add_action('gform_entry_created', array($this, 'gf_entry_created_before'), 99, 2);
//added via GF API
add_action("gform_post_add_entry", array($this, 'gf_entry_created_before'), 40, 2);
if(self::$is_pr){
// add_action("gform_post_payment_status", array($this, 'gf_entry_paid'), 10, 2); //$feed,$entry
add_action("gform_post_payment_completed", array($this, 'gf_entry_paid_normal'), 10, 2); //$entry,$pay_info
add_action('gform_after_submission', array($this, 'gf_entry_created_after'), 99, 2);
add_action("gform_post_add_subscription_payment", array($this, 'gf_entry_paid_subscription'), 10, 2); //$entry,$pay_info
}
add_filter("gform_confirmation", array($this, 'confirmation_error'));
add_filter("gform_custom_merge_tags", array($this, 'add_tags'),10,4);
add_filter( 'gform_replace_merge_tags', array($this,'replace_tags'), 10, 7 );
if(is_admin()){
add_action('init', array($this,'init'));
//loading translations
load_plugin_textdomain('gravity-forms-salesforce-crm', FALSE, $this->plugin_dir_name(). '/languages/' );
self::$db_version=get_option($this->type."_version");
if(self::$db_version != $this->version && current_user_can( 'manage_options' )){
$this->install_plugin();
update_option($this->type."_version", $this->version);
// $log_str="Installing ".self::$title." version=".$this->version;
// $this->log_msg($log_str);
}
}
}
public function plugin_api($start_instance=false){
if(empty(self::$path)){ self::$path=$this->get_base_path(); }
$file=self::$path . "pro/plugin-api.php";
if(!class_exists('vxcf_plugin_api') && file_exists($file)){
require_once($file);
}
if(class_exists('vxcf_plugin_api')){
$slug=$this->get_slug();
$settings_link=$this->link_to_settings();
$is_plugin_page=$this->is_crm_page();
self::$plugin=new vxcf_plugin_api($this->id,$this->version,$this->type,$this->domain,$this->update_id,self::$title,$slug,self::$path,$settings_link,$is_plugin_page);
if($start_instance){
self::$plugin->instance();
}
} }
public function install_plugin(){
$data=$this->get_data_object();
$data->update_table();
//add post permissions
require_once(self::$path . "includes/install.php");
$install=new vxg_install_salesforce();
$install->create_roles();
}
public function install_gf_notice(){
$message=self::$gf_status_msg;
if(!empty($message)){
$this->display_msg('admin',$message,'gravity');
$this->notice_js=true;
}
}
/**
* Install Gravity Forms Notice (plugin row)
*
*/
public function install_gf_notice_plugin_row(){
$message=self::$gf_status_msg;
if(!empty($message)){
$this->display_msg('',$message,'gravity');
}
}
/**
* display admin notice
*
* @param mixed $type
* @param mixed $message
* @param mixed $id
*/
public function display_msg($type,$message,$id=""){
//exp
global $wp_version;
$ver=floatval($wp_version);
if($type == "admin"){
if($ver<4.2){
?>
';
echo wp_kses_post($message);
echo '
';
}
public function add_tags( $merge_tags, $form_id, $fields, $element_id ) {
$data_db=$this->get_data_object();
$feeds=$data_db->get_feed_by_form($form_id,true);
foreach($feeds as $v){
$merge_tags[] = array('label' => substr($v['name'],0,20).' Salesforce Link', 'tag' => '{salesforcelink_'.$v['id'].'}');
$merge_tags[] = array('label' => substr($v['name'],0,20).' Salesforce ID', 'tag' => '{salesforceid_'.$v['id'].'}');
}
return $merge_tags;
}
public function replace_tags( $text, $form, $entry, $url_encode, $esc_html, $nl2br, $format ) {
if(!empty($form['id']) && strpos( $text, '{salesforce' ) !== false ){
$data_db=$this->get_data_object();
$feeds=$data_db->get_feed_by_form($form['id'],true);
$tags=array();
foreach($feeds as $v){
$id=$v['id'];
if( !empty(self::$feeds_res[$id]) ){
$link= !empty(self::$feeds_res[$id]['link']) ? self::$feeds_res[$id]['link'] : '#'.self::$feeds_res[$id]['id'];
$tags['{salesforcelink_'.$v['id'].'}']=$link;
$tags['{salesforceid_'.$v['id'].'}']=self::$feeds_res[$id]['id'];
}
}
$text = str_replace( array_keys($tags), array_values($tags), $text );
} //var_dump($text); //die();
return $text;
}
/**
* Gravity forms status
*
*/
public function gravity_forms_status() {
$installed = 0;
if(!class_exists('RGForms')) {
if(file_exists(WP_PLUGIN_DIR.'/gravityforms/gravityforms.php')) {
$installed=2;
}
}else{
$installed=1;
if(!$this->is_gravityforms_supported()){
$installed=3;
}
}
if($installed !=1){
if($installed === 0){ // not found
$message = sprintf(__("%sGravity Forms%s is required. %sPurchase it today!%s", 'gravity-forms-salesforce-crm'), "", " ", "", " ");
}else if($installed === 2){ // not active
$message = sprintf(__('Gravity Forms is installed but not active. %sActivate Gravity Forms%s to use the Gravity Forms Salesforce Plugin','gravity-forms-salesforce-crm'), '', ' ", " ", "", " ");
}
self::$gf_status_msg=$message;
}
return $installed;
}
/**
* display error to admin only in form front
*
* @param mixed $confirmation
* @param mixed $form
* @param mixed $lead
* @param mixed $ajax
*/
public function confirmation_error($confirmation, $form = '', $lead = '', $ajax ='' ) {
if(current_user_can('administrator') && !empty($_REQUEST['VXGSalesforceError'])) {
if(is_array($_REQUEST['VXGSalesforceError'])){ $_REQUEST['VXGSalesforceError']=json_encode($_REQUEST['VXGSalesforceError']); }
$confirmation .= sprintf(__('%sThe entry was not added to Salesforce because: %s. %sYou are only being shown this because you are an administrator. Other users will not see this message.%s', 'gravity-forms-salesforce-crm'), '',''.esc_html($_REQUEST['VXGSalesforceError']). ' ', '', '
');
}
return $confirmation;
}
/**
* Returns true if the current page is an Feed pages. Returns false if not
*
* @param mixed $page
*/
public function is_crm_page($page=""){
if(empty($page)) {
$page = $this->post("page");
}
if(isset($_GET['subview'])){
$page = $this->post("subview");
}
return $page == $this->id;
}
/**
* Called when entry is manually updated in the Single Entry view of Gravity Forms.
*
* @param mixed $form
* @param mixed $entry_id
*/
public function manual_export( $form, $entry_id = NULL ) {
global $plugin_page;
// Is this the Gravity Forms entries page?
if(false === ($this->is_gravity_page('gf_entries') && rgget("view") == 'entry' && (rgget('lid') || !rgblank(rgget('pos'))))) {
return;
}
$entry=array();
// Both admin_init and gforms_after_update_entry will have this set
if( empty( $_POST['gforms_save_entry'] ) || empty( $_POST['action'] ) ) { return; }
// Different checks since admin_init runs in both cases but we need to wait for entry update
$current_hook = current_filter();
if( $current_hook == 'admin_init' && empty( $_POST[$this->id.'_send'] ) ) { return; }
if( $current_hook == 'gform_after_update_entry' && empty( $_POST[$this->id.'_update'] ) ) { return; }
// Verify authenticity of request
check_admin_referer('gforms_save_entry', 'gforms_save_entry');
// For admin_init hook, get the entry ID from the URL
if(empty($entry_id)) {
$entry_id = rgget('lid');
$form_id = rgget('id');
// fetch alternative entry id: look for gf list details when using pagination
if(empty($entry_id)) {
$entry_id=$this->get_entry_id($form_id);
}
$form = RGFormsModel::get_form_meta($form_id);
}
$entry=$this->get_gf_entry($entry_id);
if(!current_user_can($this->id."_send_to_crm")){
return;
}
// Export the entry
$push=$this->push($entry, $form,"",true);
if(!empty($push['msg'])){
$this->screen_msg($push['msg'],$push['class']);
}
// Don't send twice.
unset($_POST[$this->id.'_update']);
unset($_POST[$this->id.'_send']);
}
/**
* get entry id
*
* @param mixed $form_id
*/
public function get_entry_id($form_id){
$entry_id='';
$position = rgget('pos');
$paging = array('offset' => $position, 'page_size' => 1);
$entries = GFAPI::get_entries($form_id, array(), null, $paging);
if(!empty($entries)) {
// pluck first entry to use id from, should always only be one
$entry = array_shift($entries);
$entry_id = $entry['id'];
}
return $entry_id;
}
/**
* web2lead fields
*
* @param mixed $module
* @param mixed $map
*/
public function web_fields($module,$map){
////////////////////////////
$web['Lead']='{"1":{"label":"First Name","max":"40","name":"first_name","type":"text"},"2":{"label":"Last Name","max":"80","name":"last_name","type":"text","req":"true"},"3":{"label":"Email","max":"80","name":"email","type":"text","req":"true"},"4":{"label":"Company","max":"40","name":"company","type":"text"},"5":{"label":"City","max":"40","name":"city","type":"text"},"6":{"label":"State/Province","max":"20","name":"state","type":"text"},"7":{"label":"Salutation","name":"salutation","type":"select"},"8":{"label":"Title","max":"40","name":"title","type":"text"},"9":{"label":"Website","max":"80","name":"URL","type":"text"},"10":{"label":"Phone","max":"40","name":"phone","type":"text"},"11":{"label":"Mobile","max":"40","name":"mobile","type":"text"},"12":{"label":"Fax","max":"40","name":"fax","type":"text"},"13":{"label":"Address","name":"street","type":"select"},"14":{"label":"Zip","max":"20","name":"zip","type":"text"},"15":{"label":"Country","max":"40","name":"country","type":"text"},"16":{"label":"Description","name":"description","type":"select"},"17":{"label":"Lead Source","name":"lead_source","type":"select"},"18":{"label":"Industry","name":"industry","type":"select"},"19":{"label":"Rating","name":"rating","type":"select"},"20":{"label":"Annual Revenue","name":"revenue","type":"text"},"21":{"label":"Employees","name":"employees","type":"text"},"22":{"label":"Email Opt Out","name":"emailOptOut","type":"checkbox"},"23":{"label":"Fax Opt Out","name":"faxOptOut","type":"checkbox"},"24":{"label":"Do Not Call","name":"doNotCall","type":"checkbox"}}';
$web['Case']='{"1":{"label":"Contact Name","max":"80","name":"name","type":"text"},"2":{"label":"Email","max":"80","name":"email","type":"text"},"3":{"label":"Phone","max":"40","name":"phone","type":"text"},"4":{"label":"Subject","max":"80","name":"subject","type":"text"},"5":{"label":"Description","name":"description","type":"select"},"6":{"label":"Company","max":"80","name":"company","type":"text"},"7":{"label":"Type","name":"type","type":"select"},"8":{"label":"Status","name":"status","type":"select"},"9":{"label":"Case Reason","name":"reason","type":"select"},"10":{"label":"Priority","name":"priority","type":"select"}}';
//////////////////
if(isset($web[$module])){
$fields_arr=json_decode($web[$module],true);
$fields=array();
$phone=array('phone','mobile','fax');
foreach($fields_arr as $k=>$v){
if(!vxg_salesforce::$is_pr && in_array($v['name'],$phone)){ continue; }
$fields[$v['name']]=$v;
}
foreach($map as $k=>$v){
if(isset($v['name_c']))
$fields[$k]=$v;
}
}
return $fields;
}
/**
* settings link
*
* @param mixed $escaped
*/
public function link_to_settings( $escaped = true ) {
$url = admin_url('admin.php?page=gf_settings&subview='.$this->id);
return $url;
}
/**
* Get CRM info
*
*/
public function get_info($id){
$data=$this->get_data_object();
$info=$data->get_account($id);
$info_arr=$data=array(); $meta=array();
if(is_array($info)){
if(!empty($info['data'])){
$info['data']=trim($info['data']);
if(strpos($info['data'],'{') !== 0){
$info['data']=$this->de_crypt($info['data']);
}
$info_arr=json_decode($info['data'],true);
if(!is_array($info_arr)){
$info_arr=array();
}
}
$info_arr['time']=$info['time'];
$info_arr['id']=$info['id'];
$info['data']=$info_arr;
if(!empty($info['meta'])){
$meta=json_decode($info['meta'],true);
}
$info['meta']=is_array($meta) ? $meta : array();
if(!empty($info['time'])){
$info['time']=strtotime($info['time']);
}
}
return $info;
}
/**
* update account
*
* @param mixed $data
* @param mixed $id
*/
public function update_info($data,$id) {
if(empty($id)){
return;
}
$time = current_time( 'mysql' ,1);
$sql=array('updated'=>$time);
if(is_array($data)){
if(isset($data['meta'])){
$sql['meta']= json_encode($data['meta']);
}
if( isset($data['data']) && is_array($data['data'])){
$_data=$this->get_data_object();
$acount=$_data->get_account($id);
if(empty($acount['time'])){
$sql['time']= $time;
}
$sql['status']='2';
if(isset($data['data']['class'])){
$sql['status']= $data['data']['class'] == 'updated' ? '1' : '2';
}
if(isset($data['data']['meta'])){
unset($data['data']['meta']);
}
if(isset($data['data']['status'])){
unset($data['data']['status']);
}
if(isset($data['data']['name'])){
$sql['name']=$data['data']['name'];
// unset($data['data']['name']);
}else if(isset($_GET['id'])){
$sql['name']="Account #".$this->post('id');
}
$enc_str=json_encode($data['data']);
// $enc_str=$this->en_crypt($enc_str);
$sql['data']=$enc_str;
}
}
$data=$this->get_data_object();
$result = $data->update_account($sql,$id);
return $result;
}
/**
* gravity forms field values, modify check boxes etc
*
* @param mixed $entry
* @param mixed $form
* @param mixed $gf_field_id
* @param mixed $crm_field_id
* @param mixed $custom
*/
public function verify_field_val($entry,$form,$gf_field_id,$crm_field_id="",$custom=""){
$value=false;
/* if(empty($field)){
return $value;
}*/
if(isset($entry[$gf_field_id])){
$value=maybe_unserialize($entry[$gf_field_id]);
if(in_array($gf_field_id,array('date_created','payment_date'))){
$value=date('c', strtotime($value));
}
if(is_numeric($gf_field_id)){
$field = RGFormsModel::get_field($form, $gf_field_id);
if(isset($field->type) && in_array($field->type,array('option','product')) ){
$found=strpos($value,'|');
if($found){
if(!empty($custom)){ //it is empty with process_tags function
$value=substr($value,$found+1);
}else{
$value=substr($value,0,$found);
}
}
}
if( (isset($field->storageType) && $field->storageType == 'json') || $field->type == 'fileupload' ){
$value_temp=json_decode($value,1); if(!empty($value_temp)){ $value=$value_temp; }
}
if(in_array($field->type, array('survey','quiz')) && !empty($field->choices)){
$val_temp=explode(':',$value);
if(count($val_temp) > 1){ $value=$val_temp[1]; }
foreach($field->choices as $v){
if($v['value'] == $value){
$value=!empty($v['score']) ? $v['score'] : $v['text'];
break;
}
}
}
if($field->type == 'date' && !empty($value) ){
$formats=array('mdy'=>'m/d/Y','dmy'=>'d/M/Y','dmy_dash'=>'d-m-Y','dmy_dot'=>'d.m.Y','ymd_slash'=>'Y/m/d','ymd_dash'=>'Y-m-d','ymd_dot'=>'Y.m.d');
$date_formate=$field->dateFormat;
if($date_formate == 'mdy' && $this->is_api){ //do not convert with web2lead
$date_formate='dmy';
$temp_date=explode('/',$value);
if(count($temp_date)>2){
$value=$temp_date[1].'-'.$temp_date[0].'-'.$temp_date[2];
}
}
if( !empty($date_formate) && isset($formats[$date_formate])){
$value=date($formats[$date_formate],strtotime($value));
}
}else if($field->type == 'list' && is_array($value)){
$v_temp=array();
foreach($value as $v){
if(is_array($v)){
$v=trim(implode(', ',array_values($v)));
}
$v_temp[]=$v;
}
$value=trim(implode(" - \n",$v_temp));
} }
$val=true;
}else{ //check if full address
if($gf_field_id=='entry_url'){
$value=add_query_arg(array('page'=>'gf_entries','view'=>'entry','lid'=>$entry['id'],'id'=>$entry['form_id']), admin_url('admin.php'));
$val=true;
}else if($gf_field_id=="form_title"){
$value=$form['title'];
$val=true;
}else{
$field = RGFormsModel::get_field($form, $gf_field_id);
if(!empty($field)){
if($field->type == "address"){
$address_type="";
if($crm_field_id!=""){
$address_type=isset($custom[$crm_field_id]['type']) && $custom[$crm_field_id]['type'] == "address" ? "json" : "";
}
$value=$this->get_address($entry,$gf_field_id,$address_type);
$val=true;
}else{
// This is for checkboxes
$elements = array();
foreach($entry as $key => $val_e) {
if(is_numeric($key) && floor($key) == floor($gf_field_id) && !empty($val_e)) {
$elements[] = htmlspecialchars($val_e);
}}
if(count($elements)>0){
$value=$elements; $val=true;
}
}
}else if(isset($_REQUEST[$gf_field_id])){
$value=$this->post($gf_field_id);
}
}
}
if($value && is_array($value)){
// $value=implode(", ",$value);
}
return $value;
}
/**
* filter enteries
*
* @param mixed $feed
* @param mixed $entry
* @param mixed $form
*/
public function check_filter($feed,$entry,$form){
$filters=$this->post('filters',$feed);
$final=$this->filter_condition=null;
if(is_array($filters)){
$time=current_time('timestamp');
foreach($filters as $filter_s){
$check=null; $and=null; $and_c=array();
if(is_array($filter_s)){
foreach($filter_s as $filter){
$field=$filter['field'];
$fval=$filter['value'];
$val=$this->verify_field_val($entry,$form,$field);
if(is_array($val)){ $val=implode(' ',$val); }
switch($filter['op']){
case"is": $check=$fval == $val; break;
case"is_not": $check=$fval != $val; break;
case"contains": $check=preg_match('/'.$fval.'/i', $val) > 0; break;
case"not_contains": $check=preg_match('/'.$fval.'/i', $val) === 0; break;
case"is_in": $check=strpos($fval,$val) !==false; break;
case"not_in": $check=strpos($fval,$val) ===false; break;
case"starts": $check=strpos($val,$fval) === 0; break;
case"not_starts": $check=strpos($val,$fval) !== 0; break;
case"ends": $check=(strrpos($val,$fval)+strlen($fval)) == strlen($val); break;
case"not_ends": $check=(strrpos($val,$fval)+strlen($fval)) != strlen($val); break;
case"less": $check=(float)$val<(float)$fval; break;
case"greater": $check=(float)$val>(float)$fval; break;
case"less_date": $check=strtotime($val,$time) < strtotime($fval,$time); break;
case"greater_date": $check=strtotime($val,$time) > strtotime($fval,$time); break;
case"equal_date": $check=strtotime($val,$time) == strtotime($fval,$time); break;
case"empty": $check=$val == ""; break;
case"not_empty": $check=$val != ""; break;
}
$and_c[]=array("check"=>$check,"field_val"=>$fval,"input"=>$val,"field"=>$field,"op"=>$filter['op']);
if($check !== null){
if($and !== null){
$and=$and && $check;
}else{
$and=$check;
}
}
} //end and loop filter
}
if($and !== null){
if($final !== null){
$final=$final || $and;
}else{
$final=$and;
}
}
$this->filter_condition[]=$and_c;
} // end or loop
}
// var_dump($final); die();
return $final === null ? true : $final;
}
/**
* get address components
*
* @param mixed $entry
* @param mixed $field_id
* @param mixed $type
*/
private function get_address($entry, $field_id,$type=""){
$street_value = str_replace(" ", " ", trim($entry[$field_id . ".1"]));
$street2_value = str_replace(" ", " ", trim($entry[$field_id . ".2"]));
$city_value = str_replace(" ", " ", trim($entry[$field_id . ".3"]));
$state_value = str_replace(" ", " ", trim($entry[$field_id . ".4"]));
$zip_value = trim($entry[$field_id . ".5"]);
if(method_exists('GF_Field_Address','get_country_code')){
$field_c=new GF_Field_Address();
$country_value=$field_c->get_country_code(trim($entry[$field_id . ".6"]));
}else{
$country_value = GFCommon::get_country_code(trim($entry[$field_id . ".6"]));
}
$country =trim($entry[$field_id . ".6"]);
$address = $street_value;
$address .= !empty($address) && !empty($street2_value) ? " $street2_value" : $street2_value;
if($type =="json"){
$arr=array("street"=>$address,"city"=>$city_value,"state"=>$state_value,"zip"=>$zip_value,"country"=>$country);
return json_encode($arr);
}
$address .= !empty($address) && (!empty($city_value) || !empty($state_value)) ? " $city_value" : $city_value;
$address .= !empty($address) && !empty($city_value) && !empty($state_value) ? " $state_value" : $state_value;
$address .= !empty($address) && !empty($zip_value) ? " $zip_value" : $zip_value;
$address .= !empty($address) && !empty($country_value) ? " $country_value" : $country_value;
return $address;
}
/**
* if gravity forms page
*
* @param mixed $page
*/
public function is_gravity_page($page = array()){
if(!class_exists('RGForms')) { return false; }
$current_page = trim(strtolower(RGForms::get("page")));
if(empty($page)) {
$gf_pages = array("gf_edit_forms","gf_new_form","gf_entries","gf_settings","gf_export","gf_help");
} else {
$gf_pages = is_array($page) ? $page : array($page);
}
return in_array($current_page, $gf_pages);
}
/**
* Add checkbox to entry info - option to send entry to crm
*
* @param mixed $form_id
* @param mixed $lead
*/
public function entry_info_send_checkbox( $form_id, $lead ) {
// If this entry's form isn't connected to crm, don't show the checkbox
if(!$this->show_send_to_crm_button() ) { return; }
// If this is not the Edit screen, get outta here.
if(empty($_POST["screen_mode"]) || $_POST["screen_mode"] === 'view') { return; }
if(!current_user_can($this->id."_send_to_crm")){return; }
if( apply_filters( $this->id.'_show_manual_export_button', true ) ) {
printf('%s '.__('Salesforce Logs','gravity-forms-salesforce-crm').' ';
}
return $button;
}
/**
* Whether to show the Entry "Send to CRM" button or not
*
* If the entry's form has been mapped to CRM feed, show the Send to CRM button. Otherwise, don't.
*
* @return boolean True: Show the button; False: don't show the button.
*/
public function show_send_to_crm_button() {
$form_id = rgget('id');
return $this->has_feed($form_id);
}
/**
* Does the current form have a feed assigned to it?
* @param INT $form_id Form ID
* @return boolean
*/
function has_feed($form_id) {
$data=$this->get_data_object();
$feeds = $data->get_feed_by_form( $form_id , true);
return !empty($feeds);
}
/**
* Add note to GF Entry
* @param int $id Entry ID
* @param string $note Note text
*/
private function add_note($id, $note) {
RGFormsModel::add_note($id, 0, esc_html__('Gravity Forms Salesforce Plugin','gravity-forms-salesforce-crm'), $note);
}
/**
* if gravity forms installed and supported
*
*/
private function is_gravityforms_supported(){
if(class_exists("GFCommon")){
$is_correct_version = version_compare(GFCommon::$version, $this->min_gravityforms_version, ">=");
return $is_correct_version;
}
else{
return false;
}
}
/**
* uninstall plugin
*
*/
public function uninstall(){
//droping all tables
require_once(self::$path . "includes/install.php");
$install=new vxg_install_salesforce();
do_action('uninstall_vx_plugin_'.$install->id);
$install->remove_data();
}
/**
* email validation
*
* @param mixed $email
*/
public function is_valid_email($email){
if(function_exists('filter_var')){
if(filter_var($email, FILTER_VALIDATE_EMAIL)){
return true;
}
}else{
if(strpos($email,"@")>1){
return true;
}
}
return false;
}
/**
* deactivate
*
* @param mixed $action
*/
public function deactivate($action="deactivate"){
do_action('plugin_status_'.$this->type,$action);
}
/**
* activate plugin
*
*/
public function activate(){
$this->plugin_api(true);
$this->install_plugin();
do_action('plugin_status_'.$this->type,'activate');
}
/**
* Send CURL Request
*
* @param mixed $body
* @param mixed $path
* @param mixed $method
*/
public function request($path="",$method='POST',$body="",$head=array()) {
$args = array(
'body' => $body,
'headers'=> $head,
'method' => strtoupper($method), // GET, POST, PUT, DELETE, etc.
'sslverify' => false,
'timeout' => 20,
);
$response = wp_remote_request($path, $args);
if(is_wp_error($response)) {
$this->error_msg= $response->get_error_message();
return false;
} else if(isset($response['response']['code']) && $response['response']['code'] != 200 && $response['response']['code'] != 404) {
$this->error_msg = strip_tags($response['body']);
return false;
} else if(!$response) {
return false;
}
$result=wp_remote_retrieve_body($response);
return $result;
}
/**
* Adds feed tooltips to the list of tooltips
*
* @param mixed $tooltips
*/
public function tooltips($tooltips){
$crm_tooltips = array(
'vx_feed_name' => '' . esc_html__('Feed Name', 'gravity-forms-salesforce-crm') . ' ' . esc_html__('Enter feed name of your choice.', 'gravity-forms-salesforce-crm'),
'vx_sel_object' => '' .__('Salesforce Object', 'gravity-forms-salesforce-crm') . ' ' . esc_html__('Select the Object to Create when a Form is Submitted.', 'gravity-forms-salesforce-crm'),
'vx_sel_account' => '' .__('Salesforce Account', 'gravity-forms-salesforce-crm') . ' ' . esc_html__('Select the Salesforce account you would like to export entries to.', 'gravity-forms-salesforce-crm'),
'vx_sel_form' => '' . esc_html__('Gravity Form', 'gravity-forms-salesforce-crm') . ' ' . esc_html__('Select the Gravity Form you would like to integrate with Salesforce. Contacts generated by this form will be automatically added to your Salesforce account.', 'gravity-forms-salesforce-crm'),
'vx_map_fields' => '' . esc_html__('Map Standard Fields', 'gravity-forms-salesforce-crm') . ' ' . esc_html__('Associate your Salesforce fields to the appropriate Gravity Form fields.', 'gravity-forms-salesforce-crm'),
'vx_optin_condition' => '' . esc_html__('Opt-In Condition', 'gravity-forms-salesforce-crm') . ' ' . esc_html__('When the opt-in condition is enabled, form submissions will only be exported to Salesforce when the condition is met. When disabled all form submissions will be exported.', 'gravity-forms-salesforce-crm'),
'vx_manual_export' => '' . esc_html__('Manual Export', 'gravity-forms-salesforce-crm') . ' ' . esc_html__('If you do not want all entries sent to Salesforce, but only specific, approved entries, check this box. To manually send an entry to Salesforce, go to Entries, choose the entry you would like to send to Salesforce, and then click the "Send to Salesforce" button.', 'gravity-forms-salesforce-crm'),
'vx_entry_notes' => '' . esc_html__('Entry Notes', 'gravity-forms-salesforce-crm') . ' ' . esc_html__('Enable this option if you want to synchronize Gravity Forms entry notes to Salesforce Object notes. For example , when you add a note to a Gravity Forms entry, it will be added to the Salesforce Object selected in the feed.', 'gravity-forms-salesforce-crm'),
'vx_primary_key' => '' . esc_html__('Primary Key', 'gravity-forms-salesforce-crm') . ' ' . esc_html__('Which field should be used to update existing objects?', 'gravity-forms-salesforce-crm'),
'vx_web' => '' . esc_html__('Web to Lead', 'gravity-forms-salesforce-crm') . ' ' . sprintf(__('Web-to-Lead is available for all Salesforce Editions. If you are not sure if your Salesforce Edition supports the API, you should use Web-to-Lead. Editions that do not support the Salesforce API: %s 1: Personal Edition %s 2: Group Edition %s 3: Professional Edition %s Note: You can purchase API access for a Professional Edition', 'gravity-forms-salesforce-crm'),'' . esc_html__('Salesforce API', 'gravity-forms-salesforce-crm') . ' ' .sprintf(__('The API features are more powerful than Web-to-Lead. You can create different object types, as well as other advanced features. If you have any of the following Salesforce Editions, you can use the included API Add-on: %s 1: Enterprise Edition %s 2: Unlimited Edition %s 3: Developer Edition %s 4: Professional Edition - Requires API Upgrade', 'gravity-forms-salesforce-crm'),'' . esc_html__('Custom App', 'gravity-forms-salesforce-crm') . ' ' .__('This option is for advanced users who want to override default Salesforce App.','gravity-forms-salesforce-crm'),
'vx_camps'=>'' . esc_html__('Salesforce Campaigns', 'gravity-forms-salesforce-crm') . ' ' .__('Get Campaigns and Status list from salesforce.','gravity-forms-salesforce-crm'),
'vx_sel_price_book'=>__('Which Pricebook should be searched for product','gravity-forms-salesforce-crm'),
'vx_sel_camp'=>'' . esc_html__('Select Campaign', 'gravity-forms-salesforce-crm') . ' ' .__('Which Campaign should be assigned to this object.','gravity-forms-salesforce-crm'),
'vx_sel_status'=>'' . esc_html__('Campaign Status', 'gravity-forms-salesforce-crm') . ' ' .__('What should be Member Status.','gravity-forms-salesforce-crm'),
'vx_pro_desc'=>'' . esc_html__('Price Book', 'gravity-forms-salesforce-crm') . ' ' .__('A new product will be created in selected Pricebook. You can add a description for new products created by this plugin.','gravity-forms-salesforce-crm'),
'vx_assign_account'=>'' . esc_html__('Salesforce Account', 'gravity-forms-salesforce-crm') . ' ' .__('Enable this option if you want to assign an account this object.','gravity-forms-salesforce-crm'),
'vx_sel_account'=>'' . esc_html__('Select Account', 'gravity-forms-salesforce-crm') . ' ' .__('Object created by this feed will be assigned to the selected Account.','gravity-forms-salesforce-crm'),
'vx_assign_contract'=>'' . esc_html__('Assign Contract', 'gravity-forms-salesforce-crm') . ' ' .__('Enable this option , if you want to assign a Contract to this object','gravity-forms-salesforce-crm'),
'vx_sel_contract'=>'' . esc_html__('Select Contact', 'gravity-forms-salesforce-crm') . ' ' .__('Select Contract feed. Contract created by this feed will be assigned to this object','gravity-forms-salesforce-crm'),
'vx_camp_check'=>'' . esc_html__('Add to Campaign', 'gravity-forms-salesforce-crm') . ' ' .__('If enabled, Lead/Contact will be added to selected Campaign','gravity-forms-salesforce-crm'),
'vx_owner_check'=>'' . esc_html__('Assign Owner', 'gravity-forms-salesforce-crm') . ' ' .__('Enable this option if you want to assign another object owner.','gravity-forms-salesforce-crm'),
'vx_owners'=>'' . esc_html__('Salesforce Users', 'gravity-forms-salesforce-crm') . ' ' .__('Get Users list from Salesforce','gravity-forms-salesforce-crm'),
'vx_order_notes'=>'' . esc_html__('Entry Notes', 'gravity-forms-salesforce-crm') . ' ' .__('Enable this option if you want to synchronize Entry notes to Salesforce Object notes. For example, when you add a note to a Entry, it will be added to the Salesforce Object selected in the feed.','gravity-forms-salesforce-crm'),
'vx_sel_owner'=>'' . esc_html__('Select Owner', 'gravity-forms-salesforce-crm') . ' ' .__('Select a user as a owner of this object','gravity-forms-salesforce-crm'),
'vx_entry_note'=>'' . esc_html__('Entry Note', 'gravity-forms-salesforce-crm') . ' ' .__('Check this option if you want to send more data as CRM entry note.', 'gravity-forms-salesforce-crm'),
'vx_note_fields'=>'' . esc_html__('Note Fields', 'gravity-forms-salesforce-crm') . ' ' .__('Select fields which you want to send as a note', 'gravity-forms-salesforce-crm'),
'vx_disable_note'=>'' . esc_html__('Note Fields', 'gravity-forms-salesforce-crm') . ' ' .__('Enable this option if you want to add note only for new CRM entry', 'gravity-forms-salesforce-crm')
);
return array_merge($tooltips,$crm_tooltips);
}
/**
* Formates User Informations and submitted form to string
* This string is sent to email and salesforce
* @param array $info User informations
* @param bool $is_html If HTML needed or not
* @return string formated string
*/
public function format_user_info($info,$is_html=false){
$str=""; $file="";
if($is_html){
if(file_exists(self::$path."templates/email.php")){
ob_start();
include_once(self::$path."templates/email.php");
$file= ob_get_contents(); // data is now in here
ob_end_clean();
}
if(trim($file) == "")
$is_html=false;
}
if(isset($info['info']) && is_array($info['info'])){
if($is_html){
if(isset($info['info_title'])){
$str.=''.$info['info_title'].' ';
foreach($info['info'] as $f_k=>$f_val){
$str.=''.$f_k.' '.$f_val.'
'.$feed_log['crm_id'].' ';
}
// delete not and save extra info
if( $event == 'delete_note'){
$feed_log_arr= json_decode($feed_log['extra'],true);
if(isset($feed_log_arr['note_object_link'])){
$feed['note_object_link']=$feed_log_arr['note_object_link'];
}
$temp=array('ParentId'=>array('value'=> $feed['crm_id']));
}
//delete object
if( $event == 'delete'){
$temp=array('Id'=>array('value'=> $feed['crm_id']));
}
//
if(!in_array($event , array('update','restore') )){
//do not apply filters when adding note , deleting note , entry etc
$force_send=true;
}
if($event == 'restore'){ // send as new entry
unset($feed['crm_id']);
}
//do not post comment in al other cases
$post_comment=false;
}
// var_dump(self::$note,$object,$feed['note_object'],$feed['object'],$feed['crm_id'],$feed['event'],$temp,$force_send);
//not submitted by admin
$feed_event=$this->post('manual_export',$data);
if(!$is_admin){
if($event == 'submit' && $feed_event != ''){ //if manual export is yes
continue;
}
if($event == 'after_submit' && $feed_event != '4'){
continue;
}
if($event == 'subscription_paid' && $feed_event != '3'){
continue;
}
if($event == 'paid' && $feed_event != '2'){ // only process paid event, if set in feed
continue;
}
}
if(!$force_send && isset($data['map']) && is_array($data['map']) && count($data['map'])>0){
if($api_type =="web"){
$meta['fields']=$this->web_fields($object,$data['map']);
}
$custom= isset($meta['fields']) && is_array($meta['fields']) ? $meta['fields'] : array();
$skip_feed=false;
foreach($data['map'] as $k=>$v){
$value=false;
if(!empty($v)){ //if value not empty
$field_type=$this->post('type',$v);
if( !empty($field_type) ){ //custom value
$value=trim($this->post('value',$v));
$value=$this->process_tags($entry,$form,$value);
if($field_type == 'value_date'){
$value=date('d/m/Y',strtotime($value));
}else if($field_type == 'value_time'){
$value=date('d/m/Y',strtotime($value));
}
}else{ //general field
$field=$this->post('field',$v);
if($field !=""){
if(strpos($field,'_vx_feed-') !== false){
$temp_feed_id=substr($field,9);
if(isset(self::$feeds_res[$temp_feed_id])){
$value= !empty(self::$feeds_res[$temp_feed_id]['id']) ? self::$feeds_res[$temp_feed_id]['id'] : '';
}else if($n < count($feeds_meta) ){ // it is not last element
$feeds_meta[]=$feed; $skip_feed=true;
break;
}
}else{
$value=$this->verify_field_val($entry,$form,$field,$k,$custom);
if($value == ''){ $value=false; }
$gf_field= RGFormsModel::get_field($form, $field);
if(!empty($gf_field) && in_array($gf_field->type,array('checkbox')) && !empty($gf_field->choices) && count($gf_field->choices)< 2 ){
if(!empty($value)){ $value='1'; } //single checkbox or acceptance field , salesforce web2lead accepts only 1 for checkbox field
}
}
}
}
if($value!== false){
if(isset($custom[$k]['name'])){
$temp[$k]=array('value'=>$value,'label'=>$custom[$k]['label']);
}else if(isset($custom[$k]['name_c'])){
$temp[$custom[$k]['name_c']]=array('value'=>$value,'label'=>$custom[$k]['name_c']);
}
}
}
}
if($skip_feed){ continue; }
if($object == 'Order'){
$temp['Status']=array('value'=>'Draft','label'=>'Draft');
}
//change owner id
if(isset($data['owner']) && !empty($data['user'])){
$temp['OwnerId']=array('value'=>apply_filters('vx_assigned_user_id',$data['user'],$this->id,$feed['id'],$entry,$form),'label'=>'Owner ID');
}
//add account or contract
if(!empty($data['contract_check']) && !empty($data['object_contract'])){
$contract_feed=$data['object_contract'];
if( isset(self::$feeds_res[$contract_feed]) ){
$contract_res=self::$feeds_res[$contract_feed];
/////
if(!empty($contract_res['id'])){
$temp['ContractId']=array('value'=> $contract_res['id'],'label'=>'Contract ID');
}else{ //if empty continue
continue;
}
}
}
if(!empty($data['account_check']) && !empty($data['object_account'])){
$account_feed=$data['object_account'];
if( isset(self::$feeds_res[$account_feed]) ){
$account_res=self::$feeds_res[$account_feed];
/////
if(!empty($account_res['id'])){
$temp['AccountId']=array('value'=> $account_res['id'],'label'=>'Account ID');
}else{ //if empty continue
continue;
}
}
}
if(!empty($data['contact_check']) && !empty($data['contact_feed'])){
$contact_feed=$data['contact_feed'];
if( isset(self::$feeds_res[$contact_feed]) ){
$contact_res=self::$feeds_res[$contact_feed];
/////
if(!empty($contact_res['id'])){
$temp['contact_id']=$contact_res['id'];
}else{ //if empty continue
// continue;
}
}
}
//add note
if(!empty($data['note_check']) ){
$entry_note=''; $entry_note_title='';
if(!empty($data['note_fields']) && is_array($data['note_fields'])){
$data['note_val']='{'.implode("}\n{",$data['note_fields'])."}\n";
}
if(!empty($data['note_val'])){
$entry_note=$this->process_tags($entry,$form,$data['note_val']);
$entry_note=str_replace("'", "", $entry_note);
$entry_note=esc_html($entry_note);
if(empty($entry_note_title)){
$pos=strpos($entry_note,'?');
if($pos > 0){
$entry_note_title=substr($entry_note,0,$pos);
$entry_note=substr($entry_note,$pos+1);
}else{
$entry_note_title=substr($entry_note,0,20);
} }
if(!empty($entry_note)){
$feed['__vx_entry_note']=array('Title'=>$entry_note_title,'Body'=>$entry_note);
}
}
}
}
$no_filter=true;
if(isset($_REQUEST['bulk_action']) && $_REQUEST['bulk_action'] =="send_to_crm_bulk_force" && !empty($log_id)){
$force_send=true;
}
$temp=apply_filters($this->id.'_post_data', $temp ,$entry);
if(!$force_send && $this->post('optin_enabled',$data) == "1"){ //apply filters if not sending by force and optin is enabled
$no_filter=$this->check_filter($data,$entry,$form);
$res=array("status"=>"4","extra"=>array("filter"=>$this->filter_condition),"data"=>$temp);
}
//var_dump($temp,$entry); die();
$feed_id=$this->post('id',$feed);
if($no_filter){ //get $res if no filter , other wise use filtered $res
$api=$this->get_api($info);
$feed_arr=$feed;
if(is_array($meta) && is_array($data)){
$feed_arr=array_merge($meta,$data,$feed);
}
$res=$api->push_object($feed['object'],$temp,$feed_arr);
$res=apply_filters($this->id . '_response', $res, $entry, $object);
if(!empty($res['id'])){
$entry['_vx_feed-'.$feed_id]= $res['id'];
if($object == 'Contact'){
$entry['sf_contact_id']=$res['id'];
} }
}
self::$feeds_res[$feed_id]=$res;
$status=$res['status']; $error="";
$id=$this->post('id',$res);
$added=false;
if($api_type != 'web' && !empty($id)){
$added=true;
}else if($api_type == 'web' && !empty($status)){
$added=true;
}
if( $added){
$id=$res['id'];
$action=$this->post('action',$res);
if($action == "Added"){
if(empty($res['link'])){
$msg=sprintf(__('Successfully Added to Salesforce (%s) with ID # %s .', 'gravity-forms-salesforce-crm'),$feed['object'],$res['id']);
}else{
$msg=sprintf(__('Successfully Added to Salesforce (%s) with ID # %s . View entry at %s', 'gravity-forms-salesforce-crm'),$feed['object'],$res['id'],$res['link']);
}
$screen_msg=__( 'Entry added in Salesforce', 'gravity-forms-salesforce-crm');
}else{
if(empty($res['link'])){
$msg=sprintf(__('Successfully Updated to Salesforce (%s) with ID # %s . View entry at %s', 'gravity-forms-salesforce-crm'),$feed['object'],$res['id'],$res['link']);
}else{
$msg=sprintf(__('Successfully Updated to Salesforce (%s) with ID # %s .', 'gravity-forms-salesforce-crm'),$feed['object'],$res['id']);
}
$screen_msg=__( 'Entry updated in Salesforce', 'gravity-forms-salesforce-crm');
}
}else if($this->post('status',$res) == 4){
$screen_msg=$msg=__( 'Entry filtered', 'gravity-forms-salesforce-crm');
}else if($this->post('status',$res) == 6){
$status='2'; $screen_msg=$error=$res['error'];
}else{
$status=0; $screen_msg_class="error";
$screen_msg=__('Errors when adding to Salesforce. Entry not sent! Check the Entry Notes below for more details.' , 'gravity-forms-salesforce-crm' );
if($log_id!=""){
//message for bulk actions in logs
$screen_msg=__('Errors when adding to Salesforce. Entry not sent' , 'gravity-forms-salesforce-crm' );
}
$msg=sprintf(__('Error while creating %s', 'gravity-forms-salesforce-crm'),$feed['object']);
if($this->post('error',$res)!=""){
$error= is_array($res['error']) ? json_encode($res['error']) : $res['error'];
$msg.=" ($error)";
$_REQUEST['VXGSalesforceError']=$msg; //front end form error for admin only
}
if(!$is_admin){
$info_data['msg']=$msg;
$this->send_error_email($info_data,$entry,$form);
}
}
//insert log
$arr=array("object"=>$feed["object"],"form_id"=>$form_id,"status"=>$status,"entry_id"=>$entry_id,"crm_id"=>$id,"meta"=>$error,"time"=>date('Y-m-d H:i:s'),"data"=>$temp,"response"=>$this->post('response',$res),"extra"=>$this->post('extra',$res),"feed_id"=>$this->post('id',$feed),"link"=>$this->post('link',$res),'parent_id'=>$parent_id,'event'=>$event);
$settings=get_option($this->type.'_settings',array());
if($this->post('disable_log',$settings) !="yes"){
$insert_id=$data_db->insert_log($arr,$log_id);
}
if(!empty($insert_id)){ //
$log_url=admin_url( 'admin.php?page=gf_edit_forms&view=settings&subview='.$this->id.'&tab=log&log_id='.$insert_id.'&id='.$form_id);
$log_link=' '.__('View Detail','gravity-forms-salesforce-crm')." ";
$screen_msg.=$log_link;
}
if($post_comment){
//insert entry comment
// $this->add_note($entry["id"], $msg);
}
if($notice!=""){
$notice.=''.$object.': '.$screen_msg;
}
}
return array("msg"=>$notice,"class"=>$screen_msg_class);
}
public function process_tags($entry,$form,$value,$crm_field_id='',$custom=''){
//starts with { and ends } , any char in brackets except {
preg_match_all('/\{[^\{]+\}/',$value,$matches);
if(!empty($matches[0])){
$vals=array();
foreach($matches[0] as $m){
$m=trim($m,'{}');
$val_cust=$this->verify_field_val($entry,$form,$m,$crm_field_id,$custom);
if(is_array($val_cust)){ $val_cust=trim(implode(' ',$val_cust)); }
$vals['{'.$m.'}']=$val_cust;
}
$value=str_replace(array_keys($vals),array_values($vals),$value);
}
return $value;
}
/**
* Send error email
*
* @param mixed $info
* @param mixed $entry
* @param mixed $form
*/
public function send_error_email($info,$entry,$form){
if( trim($this->post('error_email',$info))!=""){
$subject="Error While Posting to Salesforce";
$entry_link=add_query_arg(array('page' => 'gf_entries','view'=>'entry', 'id' => $entry['form_id'],'lid'=>$entry['id']), admin_url('admin.php'));
$page_url = ( is_ssl() ? 'https://' : 'http://' ) . $_SERVER['HTTP_HOST'] . $_SERVER['REQUEST_URI'];
$detail=array(
"Time"=>date('d/M/y H:i:s',current_time('timestamp')),
"Page URL"=>''.$page_url.' ',
"Entry ID"=>''.$entry_link.' '
);
if(isset($form['title'])){
$detail["Form Name"]=$form['title'];
$detail["Form Id"]=$form['id'];
}
$email_info=array("msg"=>$info['msg'],"title"=>__('Salesforce','gravity-forms-salesforce-crm')." Error","info_title"=>"More Detail","info"=>$detail);
$email_body=$this->format_user_info($email_info,true);
$error_emails=explode(",",$info['error_email']);
$headers = array('Content-Type: text/html; charset=UTF-8');
foreach($error_emails as $email)
wp_mail(trim($email),$subject, $email_body,$headers);
}
}
/**
* Get Objects from local options or from salesforce
*
* @param mixed $check_option
* @return array
*/
public function get_objects($info="",$refresh=false){
$data=$this->post('data',$info);
$api_type=$this->post('api',$data);
$web_objects=array("Lead"=>"Lead","Case"=>"Case");
if($api_type == "web"){
return $web_objects;
}
if(empty($info)){
$option=get_option($this->id.'_meta',array());
return !empty($option['objects']) ? $option['objects'] : '';
}
$objects=array();
$meta=$this->post('meta',$info);
if(! isset($meta['objects'])){
$refresh=true;
}else{
$objects=$meta['objects'];
}
//get objects from salesforce
if($refresh){
$api=$this->get_api($info);
$objects=$api->get_crm_objects();
if(is_array($objects)){
$option=get_option($this->id.'_meta',array());
$option_objects=array_merge($objects,$web_objects);
if(!empty($option['objects']) && is_array($option['objects'])){
$option_objects=array_merge($option_objects,$option['objects']);
}
$option['objects']=$option_objects;
update_option($this->id.'_meta',$option); //save objects for logs search option
$meta["objects"]=$objects;
$this->update_info(array("meta"=>$meta),$info['id']);
}
}
return $objects;
}
/**
* check if user conected to crm
*
* @param mixed $settings
*/
public function api_is_valid($info="") {
if(!empty($info['data']['api']) && $info['data']['api'] == 'web'){
return true;
}
if(isset($info['data']) && is_array($info['data']) && isset($info['data']['access_token']) && !empty($info['data']['access_token'])){
return true;
}else{
return false;}
}
}
endif;
$vxg_salesforce=new vxg_salesforce();
$vxg_salesforce->instance();
$vx_gf['vxg_salesforce']='vxg_salesforce';