566 lines
20 KiB
PHP
566 lines
20 KiB
PHP
<?php
|
|
|
|
class common_function {
|
|
|
|
protected $current_store_obj = null;
|
|
protected $store_user_id = null;
|
|
protected $store_name = null;
|
|
protected $store_email = null;
|
|
protected $app_status = null;
|
|
protected $app_plan = null;
|
|
protected $is_charge_approve = '';
|
|
protected $money_format = null;
|
|
protected $currency = null;
|
|
protected $shop_plan = '';
|
|
protected $timezone = '';
|
|
public $db_connection = null;
|
|
public $apisecrekkey = '$2y$10$9ygTfodVBVM0XVCdyzEUK.0FIuLnJT0D42sIE6dIu9r/KY3XaXXyS';
|
|
protected $last_query = '';
|
|
|
|
public function __construct($shop = '') {
|
|
if ($this->db_connection == null) {
|
|
$db_connection = new DB_Class();
|
|
$this->db_connection = $GLOBALS['conn'];
|
|
}
|
|
|
|
if ($shop != '') {
|
|
$this->set_user_data($shop);
|
|
}
|
|
}
|
|
|
|
public function set_user_data($shop) {
|
|
$selected_field = '*';
|
|
$where = array('shop' => $shop, 'status' => '1');
|
|
$user_store = $this->select_row(TABLE_USER_STORES, $selected_field, $where);
|
|
if (!empty($user_store)) {
|
|
$this->current_store_obj = $user_store;
|
|
$this->store_user_id = $user_store['store_user_id'];
|
|
$this->store_name = $user_store['name'];
|
|
$this->store_email = $user_store['email'];
|
|
$this->app_status = ((!empty($user_store['app_status'])) ? $user_store['app_status'] : "");
|
|
$this->app_plan = ((!empty($user_store['app_plan'])) ? $user_store['app_plan'] : "");
|
|
$this->shop_plan = $user_store['shop_plan'];
|
|
$this->money_format = $user_store['money_format'];
|
|
$this->currency = $user_store['currency'];
|
|
$this->charge_approve = ((!empty($user_store['charge_approve'])) ? $user_store['charge_approve'] : "");
|
|
$this->timezone = $user_store['iana_timezone'];
|
|
}
|
|
}
|
|
|
|
public function get_store_detail_obj() {
|
|
if ($this->current_store_obj != null) {
|
|
return $this->current_store_obj;
|
|
}
|
|
}
|
|
|
|
public function get_store_user_id() {
|
|
return $this->store_user_id;
|
|
}
|
|
|
|
public function get_store_name() {
|
|
return $this->store_name;
|
|
}
|
|
|
|
public function get_store_email() {
|
|
return $this->store_email;
|
|
}
|
|
|
|
public function get_app_status() {
|
|
return $this->app_status;
|
|
}
|
|
|
|
public function get_app_plan() {
|
|
return $this->app_plan;
|
|
}
|
|
|
|
public function get_shop_plan() {
|
|
return $this->shop_plan;
|
|
}
|
|
|
|
public function get_is_charge_approve() {
|
|
return $this->charge_approve;
|
|
}
|
|
|
|
public function get_currency() {
|
|
return $this->currency;
|
|
}
|
|
|
|
public function get_timezone() {
|
|
return $this->timezone;
|
|
}
|
|
|
|
function insert($table, $fields) {
|
|
$columns = $values = array();
|
|
foreach ($fields as $key => $value) {
|
|
$columns[] = $key;
|
|
$values[] = $value;
|
|
}
|
|
$insert_query = "INSERT INTO $table" . ' (' . implode(',', $columns) . ") VALUES('" . implode("','", $values) . "')";
|
|
$this->query($insert_query);
|
|
return $this->db_connection->insert_id;
|
|
}
|
|
|
|
function insert_on_duplicate_update($table, $fields) {
|
|
$insert_columns = $values = array();
|
|
$update_columns = '';
|
|
foreach ($fields as $key => $value) {
|
|
$insert_columns[] = $key;
|
|
$values[] = $value;
|
|
if ($key != 'created_on') {
|
|
$update_columns .= $key . "='$value',";
|
|
}
|
|
}
|
|
$insert_query = "INSERT INTO $table" . ' (' . implode(',', $insert_columns) . ") VALUES('" . implode("','", $values) . "')";
|
|
$update_query = "UPDATE " . rtrim($update_columns, ",");
|
|
|
|
$insert_on_duplicate_update_query = $insert_query . " ON DUPLICATE KEY " . $update_query . ";";
|
|
|
|
$this->query($insert_on_duplicate_update_query);
|
|
|
|
return $this->db_connection->insert_id;
|
|
}
|
|
|
|
function update($table, $fields, $where, $limit = NULL) {
|
|
$update_query = "UPDATE $table SET ";
|
|
$columns = '';
|
|
foreach ($fields as $key => $value) {
|
|
$columns .= $key . "='$value',";
|
|
}
|
|
|
|
$where = $this->prepare_where_condition($where);
|
|
|
|
if ($where == '') {
|
|
echo "<pre>update without where condition not allowed</pre>";
|
|
exit;
|
|
}
|
|
|
|
$update_query .= rtrim($columns, ",") . " $where ";
|
|
|
|
if (isset($limit) && is_numeric($limit) && $limit > 0) {
|
|
$update_query .= "LIMIT $limit";
|
|
}
|
|
|
|
$update_query .= " ;";
|
|
return $this->query($update_query);
|
|
}
|
|
|
|
function delete($table, $where, $limit = NULL) {
|
|
|
|
$where = $this->prepare_where_condition($where);
|
|
|
|
if ($where == '') {
|
|
echo "<pre>delete without where condition not allowed</pre>";
|
|
exit;
|
|
}
|
|
|
|
$delete_query = "DELETE FROM $table $where ";
|
|
|
|
if (isset($limit) && is_numeric($limit) && $limit > 0) {
|
|
$delete_query .= "LIMIT $limit";
|
|
}
|
|
|
|
$delete_query .= " ;";
|
|
|
|
return $this->query($delete_query);
|
|
}
|
|
|
|
function select_row($table, $selected_field = '*', $where = NULL) {
|
|
|
|
$where = $this->prepare_where_condition($where);
|
|
|
|
$sql = "SELECT " . $selected_field . " FROM " . $table . " " . $where . " LIMIT 1;";
|
|
|
|
$query_resource = $this->query($sql);
|
|
|
|
$table_data = array();
|
|
|
|
if ($query_resource && $query_resource->num_rows > 0) {
|
|
$table_data = $query_resource->fetch_assoc();
|
|
}
|
|
return $table_data;
|
|
}
|
|
|
|
function select_result($table, $selected_field = '*', $where = NULL, $orderBy = NULL, $groupBy = NULL, $limit = NULL, $offset = NULL) {
|
|
|
|
$where = $this->prepare_where_condition($where);
|
|
|
|
$sql = "SELECT " . $selected_field . " FROM " . $table . " " . $where;
|
|
|
|
if (isset($groupBy)) {
|
|
$sql .= " GROUP BY " . $groupBy . " ";
|
|
}
|
|
if (isset($orderBy)) {
|
|
$sql .= " ORDER BY " . $orderBy . " ";
|
|
}
|
|
if (isset($offset) && isset($limit)) {
|
|
$sql .= " LIMIT " . $offset . "," . $limit;
|
|
}
|
|
if (isset($limit) && !isset($offset)) {
|
|
$sql .= " LIMIT " . $limit;
|
|
}
|
|
$sql .= ";";
|
|
|
|
$query_resource = $this->query($sql);
|
|
|
|
$table_data = array();
|
|
|
|
if ($query_resource && $query_resource->num_rows > 0) {
|
|
while ($row = $query_resource->fetch_assoc()) {
|
|
$table_data[] = $row;
|
|
}
|
|
}
|
|
return $table_data;
|
|
}
|
|
|
|
function prepare_where_condition($where_condition) {
|
|
if (!isset($where_condition) || $where_condition == '') {
|
|
$where_condition = '';
|
|
} elseif (is_array($where_condition) && !empty($where_condition)) {
|
|
$where = array();
|
|
foreach ($where_condition as $field => $value) {
|
|
$where[] = "$field = '$value'";
|
|
}
|
|
$where_condition = " WHERE " . implode(" AND ", $where);
|
|
} else if (isset($where_condition) && is_string($where_condition)) {
|
|
$where_condition = " WHERE " . $where_condition;
|
|
}
|
|
return $where_condition;
|
|
}
|
|
|
|
function get_record_with_join($table, $selected_field = '', $where = NULL, $orderBy = NULL, $groupBy = NULL, $limit = NULL, $offset = NULL, $join_arr = array()) {
|
|
$sql = "SELECT " . $selected_field . " FROM " . $table . "";
|
|
if (!empty($join_arr)) {
|
|
foreach ($join_arr as $join) {
|
|
if ($join['join_type'] == '') {
|
|
$sql .= " INNER JOIN " . $join['table'] . " ON " . $join['join_table_id'] . " = " . $join['from_table_id'];
|
|
} else {
|
|
$sql .= " " . $join['join_type'] . " " . $join['table'] . " ON " . $join['join_table_id'] . " = " . $join['from_table_id'];
|
|
}
|
|
}
|
|
}
|
|
|
|
$where = $this->prepare_where_condition($where);
|
|
|
|
if ($where != '') {
|
|
$sql .= " " . $where;
|
|
}
|
|
|
|
if (isset($groupBy)) {
|
|
$sql .= " GROUP BY " . $groupBy . " ";
|
|
}
|
|
if (isset($orderBy)) {
|
|
$sql .= " ORDER BY " . $orderBy . " ";
|
|
}
|
|
if (isset($offset) && isset($limit)) {
|
|
$sql .= " LIMIT " . $offset . "," . $limit;
|
|
}
|
|
if (isset($limit) && !isset($offset)) {
|
|
$sql .= " LIMIT " . $limit;
|
|
}
|
|
$sql .= ";";
|
|
|
|
$query_resource = $this->query($sql);
|
|
$table_data = array();
|
|
|
|
if ($query_resource && $query_resource->num_rows > 0) {
|
|
while ($row = $query_resource->fetch_assoc()) {
|
|
$table_data[] = $row;
|
|
}
|
|
}
|
|
return $table_data;
|
|
}
|
|
|
|
function query($query) {
|
|
$this->last_query = $query;
|
|
|
|
$query_resource_obj = $this->db_connection->query($query);
|
|
|
|
/* if mode is dev and query getting error than below block display the query
|
|
* and stop execution of script
|
|
*/
|
|
if (!$query_resource_obj && MODE == 'dev') {
|
|
echo "<pre>" . mysqli_error($this->db_connection) . "<br>" . "\n";
|
|
print_r($query);
|
|
echo "\n" . "<br>" . "</pre>";
|
|
exit;
|
|
}
|
|
|
|
return $query_resource_obj;
|
|
}
|
|
|
|
function get_total_record($table, $where = NULL, $group_by = NULL, $join_arr = array()) {
|
|
$where = $this->prepare_where_condition($where);
|
|
$count = "COUNT(*)";
|
|
if (isset($group_by)) {
|
|
$count = "COUNT(DISTINCT $group_by)";
|
|
}
|
|
$sql = "SELECT $count as total_row FROM $table";
|
|
|
|
if (!empty($join_arr)) {
|
|
foreach ($join_arr as $join) {
|
|
if ($join['join_type'] == '') {
|
|
$sql .= " INNER JOIN " . $join['table'] . " ON " . $join['join_table_id'] . " = " . $join['from_table_id'];
|
|
} else {
|
|
$sql .= " " . $join['join_type'] . " " . $join['table'] . " ON " . $join['join_table_id'] . " = " . $join['from_table_id'];
|
|
}
|
|
}
|
|
}
|
|
$sql .= ' ' . $where . ';';
|
|
$mysql_resource = $this->query($sql);
|
|
if ($mysql_resource) {
|
|
return $mysql_resource->fetch_row()['0'];
|
|
} else {
|
|
return '0';
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Last query get
|
|
* @return (string)
|
|
*/
|
|
public function last_query() {
|
|
return $this->last_query;
|
|
}
|
|
|
|
public function verify_webhook($data, $hmac_header) {
|
|
$calculated_hmac = base64_encode(hash_hmac('sha256', $data, SHOPIFY_SECRET, true));
|
|
return ($hmac_header == $calculated_hmac);
|
|
}
|
|
|
|
function prepare_api_condition($api_main_url_arr, $url_param_arr = array(), $method = 'GET', $is_object = 1, $token = '', $shop = '', $request_headers = array()) {
|
|
if ($this->current_store_obj != NULL) {
|
|
$shop_info = $this->current_store_obj;
|
|
$token = $shop_info['token'];
|
|
$shop = $shop_info['shop'];
|
|
}
|
|
$shopify_api_version = '';
|
|
$date = strtotime('-1 day', strtotime(date('Y-m-d')));
|
|
$month = date('m', $date);
|
|
$year = date('Y', $date);
|
|
|
|
switch ($month) {
|
|
case $month <= 3:
|
|
$shopify_api_version = $year . '-01';
|
|
break;
|
|
case $month <= 6:
|
|
$shopify_api_version = $year . '-04';
|
|
break;
|
|
case $month <= 9:
|
|
$shopify_api_version = $year . '-07';
|
|
break;
|
|
case $month <= 12:
|
|
$shopify_api_version = $year . '-10';
|
|
break;
|
|
}
|
|
$api_main_url_arr = ($token != '') ? array_merge(array('/admin/api/' . $shopify_api_version), $api_main_url_arr) : array_merge(array('/admin'), $api_main_url_arr);
|
|
$api_main_url = ($token != '') ? implode('/', $api_main_url_arr) . '.json' : implode('/', $api_main_url_arr);
|
|
return $this->api_call($token, $shop, $api_main_url, $url_param_arr, $method, $is_object, $request_headers);
|
|
}
|
|
|
|
function api_call($token, $shop, $api_endpoint, $query = array(), $method = 'GET', $is_object, $request_headers) {
|
|
$url = "https://" . $shop . $api_endpoint;
|
|
if (!empty($query) && !is_null($query) && in_array($method, array('GET', 'DELETE'))) {
|
|
$url = $url . "?" . http_build_query($query);
|
|
} else {
|
|
$url = $url;
|
|
}
|
|
|
|
$ch = curl_init($url);
|
|
curl_setopt($ch, CURLOPT_HEADER, true);
|
|
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
|
|
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
|
|
curl_setopt($ch, CURLOPT_MAXREDIRS, 3);
|
|
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
|
|
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 2);
|
|
curl_setopt($ch, CURLOPT_USERAGENT, 'ohShopify-php-api-client');
|
|
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 30);
|
|
curl_setopt($ch, CURLOPT_TIMEOUT, 30);
|
|
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method);
|
|
|
|
$request_headers[] = "";
|
|
|
|
if (!is_null($token) && $token != '')
|
|
$request_headers[] = "X-Shopify-Access-Token: " . $token;
|
|
curl_setopt($ch, CURLOPT_HTTPHEADER, $request_headers);
|
|
if ($method != 'GET' && in_array($method, array('POST', 'PUT'))) {
|
|
if (is_array($query))
|
|
$query = http_build_query($query);
|
|
|
|
curl_setopt($ch, CURLOPT_POSTFIELDS, $query);
|
|
}
|
|
|
|
$response = curl_exec($ch);
|
|
if (count(preg_split("/\r\n\r\n|\n\n|\r\r/", $response)) == 3) {
|
|
list(, $headers, $body) = preg_split("/\r\n\r\n|\n\n|\r\r/", $response, 3);
|
|
} else {
|
|
list($headers, $body) = preg_split("/\r\n\r\n|\n\n|\r\r/", $response, 2);
|
|
}
|
|
|
|
$header_lines = preg_split("/\r\n|\n|\r/", $headers);
|
|
$header = array();
|
|
if (count(explode(' ', trim(array_shift($header_lines)), 3)) == '3') {
|
|
list(, $header['http_status_code'], $header['http_status_message']) = explode(' ', trim(array_shift($header_lines)), 3);
|
|
} else {
|
|
list($header['http_status_code'], $header['http_status_message']) = explode(' ', trim(array_shift($header_lines)), 2);
|
|
}
|
|
|
|
foreach ($header_lines as $header_line) {
|
|
list($name, $value) = explode(':', $header_line, 2);
|
|
$name = strtolower($name);
|
|
$header[$name] = str_replace(array('<', '>'), '', trim($value));
|
|
}
|
|
|
|
$error_number = curl_errno($ch);
|
|
$error_message = curl_error($ch);
|
|
curl_close($ch);
|
|
|
|
if ($error_number) {
|
|
return $error_message;
|
|
} else {
|
|
if ($is_object) {
|
|
return array('headers' => $header, 'body' => json_decode($body));
|
|
} else {
|
|
return array('headers' => $header, 'body' => json_decode($body, TRUE));
|
|
}
|
|
}
|
|
}
|
|
|
|
public function is_json($args) {
|
|
json_decode($args);
|
|
return (json_last_error() === JSON_ERROR_NONE);
|
|
}
|
|
|
|
public function get_data_key($domain, $email) {
|
|
$data = array(
|
|
'domain' => $domain,
|
|
'email' => $email,
|
|
'user_email' => $email,
|
|
'secret' => $this->apisecrekkey,
|
|
'platform' => 'shopify',
|
|
);
|
|
|
|
$curl = curl_init();
|
|
|
|
curl_setopt_array($curl, array(
|
|
CURLOPT_URL => "https://seersco.com/api/get-key-for-shopify",
|
|
CURLOPT_RETURNTRANSFER => true,
|
|
CURLOPT_ENCODING => "",
|
|
CURLOPT_MAXREDIRS => 10,
|
|
CURLOPT_TIMEOUT => 0,
|
|
CURLOPT_FOLLOWLOCATION => true,
|
|
CURLOPT_SSL_VERIFYPEER => false,
|
|
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
|
|
CURLOPT_CUSTOMREQUEST => "POST",
|
|
CURLOPT_POSTFIELDS => $data
|
|
));
|
|
|
|
$response = curl_exec($curl);
|
|
$error_number = curl_errno($curl);
|
|
$error_message = curl_error($curl);
|
|
curl_close($curl);
|
|
|
|
return json_decode($response, TRUE);
|
|
}
|
|
|
|
public function snippest_insert($shop, $token, $domain, $email) {
|
|
|
|
$selected_field = 'data_key';
|
|
$where = array('shop' => $shop, 'status' => '1');
|
|
$store_row = $this->select_row(TABLE_USER_STORES, $selected_field, $where);
|
|
$old_script = '';
|
|
$datakey = '';
|
|
if(!empty($store_row)){
|
|
$datakey = $store_row['data_key'];
|
|
}
|
|
|
|
$response = $this->get_data_key($domain, $email);
|
|
|
|
$datakey = $response['key'];
|
|
|
|
$fields['data_key'] = $response['key'];
|
|
$where = array('shop' => $shop);
|
|
$last_id = $this->update(TABLE_USER_STORES, $fields, $where);
|
|
|
|
$arrsrc = ['https://cmp.seersco.com/script/cb.js', 'https://seers-application-assets.s3.amazonaws.com/scripts/cbattributes.js?key=' . $datakey . '&name=CookieXray'];
|
|
$cbattrjspath = 'https://seers-application-assets.s3.amazonaws.com/scripts/cbattributes.js';
|
|
$arrscriptexist = [false, false];
|
|
|
|
|
|
//get all avialable tags
|
|
$allscriptags = $this->prepare_api_condition(array('script_tags'), array(), 'GET', '0', $token, $shop);
|
|
|
|
//print_r($allscriptags);
|
|
|
|
if(!empty($allscriptags['body']) && !empty($allscriptags['body']['script_tags'])) {
|
|
|
|
foreach ($allscriptags['body']['script_tags'] as $thescript) {
|
|
|
|
if (strcasecmp($thescript['src'], $arrsrc[0]) === 0) {
|
|
$arrscriptexist[0] = true;
|
|
} else if (strcasecmp($thescript['src'], $arrsrc[1]) === 0) {
|
|
$arrscriptexist[1] = true;
|
|
} else if (stripos($thescript['src'], $cbattrjspath) !== false && strcasecmp($thescript['src'], $arrsrc[1]) !== 0) {
|
|
$arrscriptexist[1] = false;
|
|
//remove the script
|
|
$scriptdel = $this->prepare_api_condition(array('script_tags', $thescript['id']), array(), 'DELETE', '0', $token, $shop);
|
|
}
|
|
}
|
|
|
|
|
|
}
|
|
|
|
foreach ($arrsrc as $sitind => $sitesrc) {
|
|
|
|
if (!$arrscriptexist[$sitind]) {
|
|
|
|
//add this src in scripts
|
|
$scriptinsert = $this->prepare_api_condition(array('script_tags'), array('script_tag' => array( "event"=>"onload", "src"=>$sitesrc)), 'POST', '0', $token, $shop);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
public function plugin_active_inactive($shopdetail, $isative = 0){
|
|
$postData = array(
|
|
'domain' => $shopdetail['shop'],
|
|
'isactive' => $isative,
|
|
'secret' => $this->apisecrekkey,
|
|
'platform' => 'shopify',
|
|
'pluginname' => $shopdetail['name']
|
|
);
|
|
$request_headers = array(
|
|
'Content-Type' => 'application/json',
|
|
'Referer' => $shopdetail['shop'],
|
|
);
|
|
//$url = "https://seersco.backend/api/plugin-domain";
|
|
$url = "https://cmp.seersco.com/api/plugin-domain";
|
|
$curl = curl_init();
|
|
|
|
curl_setopt_array($curl, array(
|
|
CURLOPT_URL => $url,
|
|
CURLOPT_RETURNTRANSFER => true,
|
|
CURLOPT_ENCODING => "",
|
|
CURLOPT_MAXREDIRS => 10,
|
|
CURLOPT_TIMEOUT => 0,
|
|
CURLOPT_FOLLOWLOCATION => true,
|
|
CURLOPT_SSL_VERIFYPEER => false,
|
|
CURLOPT_CUSTOMREQUEST => "POST",
|
|
CURLOPT_HTTPHEADER => $request_headers,
|
|
CURLOPT_POSTFIELDS => $postData
|
|
));
|
|
|
|
$response = curl_exec($curl);
|
|
$error_number = curl_errno($curl);
|
|
$error_message = curl_error($curl);
|
|
curl_close($curl);
|
|
|
|
$response =json_decode($response, TRUE);
|
|
|
|
return $response;
|
|
}
|
|
|
|
}
|
|
|
|
?>
|