874 lines
37 KiB
PHP
Executable File
874 lines
37 KiB
PHP
Executable File
<?php declare(strict_types=1); namespace IR\App\Controllers; if (!defined('IR_START')) exit('<pre>No direct script access allowed</pre>');
|
|
/**
|
|
* @framework iResponse Framework
|
|
* @version 1.0
|
|
* @author Amine Idrissi <contact@iresponse.tech>
|
|
* @date 2019
|
|
* @name OapiProduction.php
|
|
*/
|
|
|
|
# core
|
|
use IR\Core\Application as Application;
|
|
|
|
# mvc
|
|
use IR\Mvc\Controller as Controller;
|
|
|
|
# models
|
|
use IR\App\Models\Admin\OapiUser as OapiUser;
|
|
|
|
use IR\App\Models\Affiliate\AffiliateNetwork as AffiliateNetwork;
|
|
use IR\App\Models\Affiliate\Offer as Offer;
|
|
use IR\App\Models\Affiliate\FromName as FromName;
|
|
use IR\App\Models\Affiliate\Subject as Subject;
|
|
use IR\App\Models\Admin\Isp as Isp;
|
|
use IR\App\Models\Lists\DataProvider as DataProvider;
|
|
use IR\App\Models\Affiliate\Vertical as Vertical;
|
|
use IR\App\Models\Production\OapiProcess as OapiProcess;
|
|
use IR\App\Models\Production\AutoResponder as AutoResponder;
|
|
use IR\App\Models\Production\Team as Team;
|
|
use IR\App\Models\Production\TeamAuthorisation as TeamAuthorisation;
|
|
use IR\App\Models\Admin\User as User;
|
|
use IR\App\Models\Lists\DataList as DataList;
|
|
|
|
# helpers
|
|
use IR\App\Helpers\Api as Api;
|
|
use IR\App\Helpers\Page as Page;
|
|
use IR\App\Helpers\DataTable as DataTable;
|
|
use IR\App\Helpers\Permissions as Permissions;
|
|
use IR\App\Helpers\Authentication as Authentication;
|
|
|
|
# http
|
|
use IR\Http\Request as Request;
|
|
|
|
# exceptions
|
|
use IR\Exceptions\Types\PageException as PageException;
|
|
|
|
/**
|
|
* @name OapiProduction
|
|
* @description OapiProduction Controller
|
|
*/
|
|
class OapiProduction extends Controller
|
|
{
|
|
/**
|
|
* @app
|
|
* @readwrite
|
|
*/
|
|
protected $app;
|
|
|
|
/**
|
|
* @app
|
|
* @readwrite
|
|
*/
|
|
protected $authenticatedUser;
|
|
|
|
/**
|
|
* @name init
|
|
* @description initializing process before the action method executed
|
|
* @once
|
|
* @protected
|
|
*/
|
|
public function init()
|
|
{
|
|
|
|
# set the current application to a local variable
|
|
$this->app = Application::getCurrent();
|
|
|
|
# connect to the database
|
|
$this->app->database('system')->connect();
|
|
|
|
# check for authentication
|
|
if(!Authentication::isUserAuthenticated())
|
|
{
|
|
Page::redirect($this->app->http->request->getBaseURL() . RDS . 'auth' . RDS . 'login.' . DEFAULT_EXTENSION);
|
|
}
|
|
|
|
# check users roles
|
|
Authentication::checkUserRoles();
|
|
|
|
# get the authenticated user
|
|
$this->authenticatedUser = Authentication::getAuthenticatedUser();
|
|
}
|
|
|
|
/**
|
|
* @name main
|
|
* @description the main action
|
|
* @before init
|
|
* @after closeConnections
|
|
*/
|
|
public function main()
|
|
{
|
|
Page::redirect($this->app->http->request->getBaseURL() . RDS . 'oapi-production' . RDS . 'send-process' . RDS . DEFAULT_EXTENSION);
|
|
}
|
|
|
|
/**
|
|
* @name sendProcess
|
|
* @description the sendProcess action
|
|
* @before init
|
|
* @after closeConnections,checkForMessage
|
|
*/
|
|
public function sendProcess_old()
|
|
{
|
|
|
|
# check for permissions
|
|
$access = Permissions::checkForAuthorization($this->authenticatedUser,__CLASS__,__FUNCTION__);
|
|
|
|
if($access == false)
|
|
{
|
|
throw new PageException('Access Denied !',403);
|
|
}
|
|
|
|
# set menu status
|
|
$this->masterView->set([
|
|
'oapi_production' => 'true',
|
|
'drops_oapi_send' => 'true'
|
|
]);
|
|
|
|
$arguments = func_get_args();
|
|
|
|
$processType = isset($arguments) && count($arguments) > 0 ? $arguments[0] : null;
|
|
$processId = isset($arguments) && count($arguments) > 1 ? $arguments[1] : null;
|
|
|
|
# set data to the page view
|
|
$this->pageView->set([
|
|
'users' => OapiUser::all(OapiUser::FETCH_ARRAY,['status = ? ',['Activated']],['id','email'],'id','ASC'),
|
|
|
|
'affiliateNetworks' => AffiliateNetwork::all(AffiliateNetwork::FETCH_ARRAY,['status = ?','Activated'],['id','name']),
|
|
|
|
'isps' => Isp::all(Isp::FETCH_ARRAY,['status = ?','Activated'],['id','name'],'name','ASC'),
|
|
'dataProviders' => DataProvider::all(DataProvider::FETCH_ARRAY,['status = ?','Activated'],['id','name']),
|
|
'verticals' => Vertical::all(Vertical::FETCH_ARRAY,['status = ?','Activated'],['id','name']),
|
|
'processId' => $processId,
|
|
'processType' => $processType
|
|
|
|
]);
|
|
}
|
|
/**
|
|
* @name sendProcess
|
|
* @description the sendProcess action
|
|
* @before init
|
|
* @after closeConnections,checkForMessage
|
|
*/
|
|
public function sendProcess()
|
|
{
|
|
|
|
# check for permissions
|
|
$access = Permissions::checkForAuthorization($this->authenticatedUser,__CLASS__,__FUNCTION__);
|
|
|
|
if($access == false)
|
|
{
|
|
throw new PageException('Access Denied !',403);
|
|
}
|
|
|
|
# set menu status
|
|
$this->masterView->set([
|
|
'oapi_production' => 'true',
|
|
'drops_oapi_send' => 'true'
|
|
]);
|
|
|
|
$arguments = func_get_args();
|
|
|
|
$processType = isset($arguments) && count($arguments) > 0 ? $arguments[0] : null;
|
|
$processId = isset($arguments) && count($arguments) > 1 ? $arguments[1] : null;
|
|
$AllUsers=OapiUser::all(OapiUser::FETCH_ARRAY,['status = ? ',['Activated']],['id','email','message'],'id','ASC');
|
|
//$AllDomains=OapiUser::all(OapiUser::FETCH_ARRAY,['status = ? ',['Activated']],['domain'],'id','ASC');
|
|
//print_r($AllDomains);
|
|
//exit;
|
|
$AllUsersDomain=[];
|
|
foreach ($AllUsers as $key => $value) {
|
|
|
|
$domain=explode("@", $value["email"])[1];
|
|
$AllUsersDomain[$domain]=$domain;
|
|
}
|
|
# set data to the page view
|
|
$this->pageView->set([
|
|
//'users' => OapiUser::all(OapiUser::FETCH_ARRAY,['status = ? ',['Activated']],['id','email'],'id','ASC'),
|
|
//'users' => [],
|
|
'usersdomain' => $AllUsersDomain,
|
|
|
|
'affiliateNetworks' => AffiliateNetwork::all(AffiliateNetwork::FETCH_ARRAY,['status = ?','Activated'],['id','name']),
|
|
|
|
'isps' => Isp::all(Isp::FETCH_ARRAY,['status = ?','Activated'],['id','name'],'name','ASC'),
|
|
'dataProviders' => DataProvider::all(DataProvider::FETCH_ARRAY,['status = ?','Activated'],['id','name']),
|
|
'verticals' => Vertical::all(Vertical::FETCH_ARRAY,['status = ?','Activated'],['id','name']),
|
|
'processId' => $processId,
|
|
'processType' => $processType
|
|
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* @name gapiDrops
|
|
* @description the gapi drops action
|
|
* @before init
|
|
* @after closeConnections,checkForMessage
|
|
*/
|
|
public function oapiDrops()
|
|
{
|
|
# check for permissions
|
|
$access = Permissions::checkForAuthorization($this->authenticatedUser,__CLASS__,__FUNCTION__);
|
|
|
|
if($access == false)
|
|
{
|
|
throw new PageException('Access Denied !',403);
|
|
}
|
|
|
|
# set menu status
|
|
$this->masterView->set([
|
|
'oapi_production' => 'true',
|
|
'drops_oapi_drops' => 'true'
|
|
]);
|
|
|
|
# get isps
|
|
$isps = Isp::all(Isp::FETCH_ARRAY,['status = ?','Activated'],['id','name'],'name','ASC');
|
|
|
|
# preparing the columns array to create the list
|
|
$columnsArray = [
|
|
'id',
|
|
'start_time',
|
|
'mailer',
|
|
'isp',
|
|
'users',
|
|
'offer',
|
|
'lists',
|
|
'status',
|
|
'start',
|
|
'total',
|
|
'progress',
|
|
'delivered',
|
|
'bounced',
|
|
'opens',
|
|
'clicks',
|
|
'leads',
|
|
'unsubs'
|
|
];
|
|
|
|
$columnsSizes = [
|
|
'start_time' => ' style="width:3%" ',
|
|
'mailer' => ' style="width:7%" ',
|
|
'users' => ' style="width:9%" ',
|
|
'isp' => ' style="width: 5.5%" ',
|
|
'offer' => ' style="width:13%" ',
|
|
'status' => ' style="width:3%" ',
|
|
'start' => ' style="width:0.5%" ',
|
|
'lists' => ' style="width:10%" ',
|
|
'total' => ' style="width:0.5%" ',
|
|
'progress' => ' style="width:0.5%" ',
|
|
'delivered' => ' style="width:0.5%" ',
|
|
'bounced' => ' style="width:0.5%" ',
|
|
'opens' => ' style="width:0.5%" ',
|
|
'clicks' => ' style="width:0.5%" ',
|
|
'leads' => ' style="width:0.5%" ',
|
|
'unsubs' => ' style="width:0.5%" '
|
|
];
|
|
|
|
# creating the html part of the list
|
|
$index = 1;
|
|
$columns = '';
|
|
$filters = '';
|
|
$footer = '<th class="ft_' . $index . '"></th>';
|
|
|
|
foreach ($columnsArray as $column)
|
|
{
|
|
$footer .= '<th class="ft_' . $index . '"></th>'; $index++;
|
|
|
|
if($column != 'id')
|
|
{
|
|
$size = key_exists($column,$columnsSizes) ? $columnsSizes[$column] : '';
|
|
|
|
$columns .= '<th>' . ucwords(str_replace('_',' ',strtolower($column))) . '</th>' . PHP_EOL;
|
|
|
|
if(strpos($column,'_date') > -1 || strpos($column,'_time') > -1)
|
|
{
|
|
$filters .= '<td ' . $size . '> <div id="' . $column . '_range" class="input-group date-range-picker"> <input type="text" class="form-control form-filter" name="' . $column . '_range"> <span class="input-group-btn"> <button class="btn default date-range-toggle" type="button"> <i class="fa fa-calendar"></i> </button> </span> </div> </td>' . PHP_EOL;
|
|
}
|
|
else if($column == 'status')
|
|
{
|
|
$filters .= '<td ' . $size . '> <select name="status" class="form-control form-filter input-sm"> <option value="" selected>All</option> <option value="In Progress">In Progress</option> <option value="Completed">Completed</option> <option value="Paused">Paused</option> <option value="Error">Error</option> <option value="Interrupted">Interrupted</option> </select> </td>' . PHP_EOL;
|
|
}
|
|
else if($column == 'isp')
|
|
{
|
|
$filters .= '<td ' . $size . '> <select name="isp" class="form-control form-filter input-sm"><option value="" selected>All</option>';
|
|
|
|
foreach ($isps as $isp)
|
|
{
|
|
$filters .= "<option value='{$isp['name']}' selected>{$isp['name']}</option>";
|
|
}
|
|
|
|
$filters .= '</select> </td>' . PHP_EOL;
|
|
}
|
|
else if($column == 'offer')
|
|
{
|
|
$filters .= '<td ' . $size . '><input type="text" class="form-control form-filter" name="' . $column . '"></td>' . PHP_EOL;
|
|
}
|
|
else
|
|
{
|
|
$filters .= '<td ' . $size . '><input type="text" class="form-control form-filter" name="' . $column . '"></td>' . PHP_EOL;
|
|
}
|
|
}
|
|
}
|
|
|
|
$footer .= '<th class="ft_' . $index . '"></th>';
|
|
|
|
# set data to the page view
|
|
$this->pageView->set([
|
|
'columns' => $columns,
|
|
'filters' => $filters,
|
|
'footer' => $footer
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* @name getoapiDrops
|
|
* @description the get oapi drops action
|
|
* @before init
|
|
* @after closeConnections,checkForMessage
|
|
*/
|
|
public function getoapiDrops()
|
|
{
|
|
# check for permissions
|
|
$access = Permissions::checkForAuthorization($this->authenticatedUser,__CLASS__,'oapiDrops');
|
|
|
|
if($access == false)
|
|
{
|
|
throw new PageException('Access Denied !',403);
|
|
}
|
|
|
|
# get post data
|
|
$data = $this->app->http->request->retrieve(Request::ALL,Request::POST);
|
|
|
|
if(count($data))
|
|
{
|
|
# preparing the columns array to create the list
|
|
|
|
$columns = [
|
|
'd.id' => 'id',
|
|
"to_char(start_time, 'YYYY-MM-DD HH24:MI')" => 'start_time',
|
|
"u.first_name || ' ' || u.last_name" => 'mailer',
|
|
'i.name' => 'isp',
|
|
"'<button style=\"margin-top:-7px\" class=\"btn btn-sm blue-madison show-process-servers\" data-type=\"md\" title=\"Show Process Servers\" data-id=\"' || d.id || '\"><i class=\"fa fa-globe\"></i></button>' || replace((SELECT string_agg(name, ',') FROM admin.mta_servers s WHERE s.id = ANY (string_to_array(d.servers_ids,',')::int[])),',',' ')" => 'servers',
|
|
"'(' || off.production_id || ') ' || off.name" => 'offer',
|
|
"'<button style=\"margin-top:-7px\" class=\"btn btn-sm green-dark show-process-lists\" data-type=\"md\" title=\"Show Process Lists\" data-id=\"' || d.id || '\"><i class=\"fa fa-at\"></i></button>' || replace((SELECT string_agg(name, ',') FROM lists.data_lists dt WHERE dt.id = ANY (string_to_array(d.lists,',')::int[])),',',' ') " => 'lists',
|
|
'd.status' => 'status',
|
|
'COALESCE(d.data_start,0)' => 'start',
|
|
'COALESCE(d.total_emails,0)' => 'total',
|
|
'COALESCE(d.progress,0)' => 'progress',
|
|
"COALESCE((SELECT SUM(ips.delivered) FROM production.mta_processes_ips ips WHERE ips.process_id = d.id),0)" => 'delivered',
|
|
"COALESCE((SELECT SUM(ips.hard_bounced) FROM production.mta_processes_ips ips WHERE ips.process_id = d.id),0)" => 'bounced',
|
|
"(SELECT COUNT(1) FROM actions.opens op WHERE op.process_id = d.id)" => 'opens',
|
|
"(SELECT COUNT(1) FROM actions.clicks cl WHERE cl.process_id = d.id)" => 'clicks',
|
|
"(SELECT COUNT(1) FROM actions.leads ld WHERE ld.process_id = d.id)" => 'leads',
|
|
"(SELECT COUNT(1) FROM actions.unsubscribes un WHERE un.process_id = d.id)" => 'unsubs'
|
|
];
|
|
|
|
|
|
# prepare query
|
|
$query = $this->app->database('system')->query()->from('production.oapi_processes d',$columns)
|
|
->join('admin.users u','d.user_id = u.id')
|
|
->join('admin.isps i','d.isp_id = i.id')
|
|
->join('affiliate.offers off','d.offer_id = off.id')
|
|
->where('d.process_type = ?',['drop']);
|
|
|
|
# fetching the results to create the ajax list
|
|
if(Authentication::getAuthenticatedUser()->getMasterAccess() != 'Enabled')
|
|
{
|
|
$userTeams = [];
|
|
$authorisations = TeamAuthorisation::all(TeamAuthorisation::FETCH_ARRAY,['team_member_id = ?',Authentication::getAuthenticatedUser()->getId()],['team_id']);
|
|
|
|
foreach ($authorisations as $authorisation)
|
|
{
|
|
$userTeams[] = $authorisation['team_id'];
|
|
}
|
|
|
|
if(count($userTeams) != 0)
|
|
{
|
|
# check if the user is a team leader
|
|
$userIds = [Authentication::getAuthenticatedUser()->getId()];
|
|
$teams = Team::all(Team::FETCH_ARRAY,["status = ? and " . $userIds[0] . " = ANY (string_to_array(team_leaders_ids,',')::int[])",['Activated']],['id','name']);
|
|
|
|
if(count($teams))
|
|
{
|
|
foreach ($teams as $team)
|
|
{
|
|
$members = TeamAuthorisation::all(TeamAuthorisation::FETCH_ARRAY,['team_member_id > 0 AND team_id = ?',$team['id']],['id','team_id','team_member_id']);
|
|
|
|
if(count($members))
|
|
{
|
|
foreach ($members as $member)
|
|
{
|
|
$userIds[] = intval($member['team_member_id']);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
$query->where('d.user_id in ?',[$userIds]);
|
|
}
|
|
}
|
|
|
|
die(json_encode(DataTable::init($data,'production.oapi_processes d',$columns,new OapiProcess(),'oapi-production' . RDS . 'oapi-drops','DESC',$query,false)));
|
|
}
|
|
}
|
|
|
|
/**
|
|
* @name oapiTests
|
|
* @description the oapi tests action
|
|
* @before init
|
|
* @after closeConnections,checkForMessage
|
|
*/
|
|
public function oapiTests()
|
|
{
|
|
|
|
# check for permissions
|
|
$access = Permissions::checkForAuthorization($this->authenticatedUser,__CLASS__,__FUNCTION__);
|
|
|
|
if($access == false)
|
|
{
|
|
throw new PageException('Access Denied !',403);
|
|
}
|
|
|
|
# set menu status
|
|
$this->masterView->set([
|
|
'oapi_production' => 'true',
|
|
'drops_oapi_tests' => 'true'
|
|
]);
|
|
|
|
# get isps
|
|
$isps = Isp::all(Isp::FETCH_ARRAY,['status = ?','Activated'],['id','name'],'name','ASC');
|
|
|
|
# preparing the columns array to create the list
|
|
$columnsArray = [
|
|
'id',
|
|
'start_time',
|
|
'mailer',
|
|
'isp_name' => 'isp',
|
|
'users',
|
|
'offer',
|
|
'status',
|
|
'total',
|
|
'progress',
|
|
'delivered',
|
|
'bounced',
|
|
'opens',
|
|
'clicks',
|
|
'leads',
|
|
'unsubs'
|
|
];
|
|
|
|
$columnsSizes = [
|
|
'start_time' => ' style="width:2%" ',
|
|
'mailer' => ' style="width:7%" ',
|
|
'users' => ' style="width:9%" ',
|
|
'isp' => ' style="width: 5.5%" ',
|
|
'offer' => ' style="width:10%" ',
|
|
'status' => ' style="width:3%" ',
|
|
'start' => ' style="width:0.5%" ',
|
|
'total' => ' style="width:0.5%" ',
|
|
'progress' => ' style="width:0.5%" ',
|
|
'delivered' => ' style="width:0.5%" ',
|
|
'bounced' => ' style="width:0.5%" ',
|
|
'opens' => ' style="width:0.5%" ',
|
|
'leads' => ' style="width:0.5%" ',
|
|
'clicks' => ' style="width:0.5%" ',
|
|
'unsubs' => ' style="width:0.5%" '
|
|
];
|
|
|
|
# creating the html part of the list
|
|
$index = 1;
|
|
$columns = '';
|
|
$filters = '';
|
|
$footer = '<th class="ft_' . $index . '"></th>';
|
|
|
|
foreach ($columnsArray as $column)
|
|
{
|
|
$footer .= '<th class="ft_' . $index . '"></th>'; $index++;
|
|
|
|
if($column != 'id')
|
|
{
|
|
$size = key_exists($column,$columnsSizes) ? $columnsSizes[$column] : '';
|
|
|
|
$columns .= '<th>' . ucwords(str_replace('_',' ',strtolower($column))) . '</th>' . PHP_EOL;
|
|
|
|
if(strpos($column,'_date') > -1 || strpos($column,'_time') > -1)
|
|
{
|
|
$filters .= '<td ' . $size . '> <div id="' . $column . '_range" class="input-group date-range-picker"> <input type="text" class="form-control form-filter" name="' . $column . '_range"> <span class="input-group-btn"> <button class="btn default date-range-toggle" type="button"> <i class="fa fa-calendar"></i> </button> </span> </div> </td>' . PHP_EOL;
|
|
}
|
|
else if($column == 'status')
|
|
{
|
|
$filters .= '<td ' . $size . '> <select name="status" class="form-control form-filter input-sm"> <option value="" selected>All</option> <option value="In Progress">In Progress</option> <option value="Completed">Completed</option> <option value="Paused">Paused</option> <option value="Error">Error</option> <option value="Interrupted">Interrupted</option> </select> </td>' . PHP_EOL;
|
|
}
|
|
else if($column == 'isp')
|
|
{
|
|
$filters .= '<td ' . $size . '> <select name="isp" class="form-control form-filter input-sm"><option value="" selected>All</option>';
|
|
|
|
foreach ($isps as $isp)
|
|
{
|
|
$filters .= "<option value='{$isp['name']}' selected>{$isp['name']}</option>";
|
|
}
|
|
|
|
$filters .= '</select> </td>' . PHP_EOL;
|
|
}
|
|
else if($column == 'offer')
|
|
{
|
|
$filters .= '<td ' . $size . '><input type="text" class="form-control form-filter" name="' . $column . '"></td>' . PHP_EOL;
|
|
}
|
|
else
|
|
{
|
|
$filters .= '<td ' . $size . '><input type="text" class="form-control form-filter" name="' . $column . '"></td>' . PHP_EOL;
|
|
}
|
|
}
|
|
}
|
|
|
|
$footer .= '<th class="ft_' . $index . '"></th>';
|
|
|
|
# set data to the page view
|
|
$this->pageView->set([
|
|
'columns' => $columns,
|
|
'filters' => $filters,
|
|
'footer' => $footer
|
|
]);
|
|
}
|
|
|
|
/**
|
|
* @name getoapiTests
|
|
* @description the get oapi tests action
|
|
* @before init
|
|
* @after closeConnections,checkForMessage
|
|
*/
|
|
public function getoapiTests()
|
|
{
|
|
# check for permissions
|
|
$access = Permissions::checkForAuthorization($this->authenticatedUser,__CLASS__,'oapiTests');
|
|
|
|
if($access == false)
|
|
{
|
|
throw new PageException('Access Denied !',403);
|
|
}
|
|
|
|
# get post data
|
|
$data = $this->app->http->request->retrieve(Request::ALL,Request::POST);
|
|
|
|
if(count($data))
|
|
{
|
|
# preparing the columns array to create the list
|
|
|
|
$columns = [
|
|
't.id' => 'id',
|
|
"to_char(start_time, 'YYYY-MM-DD HH24:MI')" => 'start_time',
|
|
"u.first_name || ' ' || u.last_name" => 'mailer',
|
|
'i.name' => 'isp',
|
|
"'<button style=\"margin-top:-7px\" class=\"btn btn-sm blue-madison show-process-servers\" data-type=\"ot\" title=\"Show Process Servers\" data-id=\"' || t.id || '\"><i class=\"fa fa-globe\"></i></button>' || substring(replace((SELECT string_agg(email, ',') FROM admin.oapi_users s WHERE s.id = ANY (string_to_array(t.servers_ids,',')::int[])),',',' '),1,18)" => 'servers',
|
|
"'(' || off.production_id || ') ' || off.name" => 'offer',
|
|
't.status' => 'status',
|
|
'COALESCE(t.total_emails,0)' => 'total',
|
|
'COALESCE(t.progress,0)' => 'progress',
|
|
'COALESCE(t.delivered,0)' => 'delivered',
|
|
'COALESCE(t.hard_bounced,0)' => 'bounced',
|
|
"COALESCE(t.opens,0)" => 'opens',
|
|
"COALESCE(t.clicks,0)" => 'clicks',
|
|
"COALESCE(t.leads,0)" => 'leads',
|
|
"COALESCE(t.unsubs,0)" => 'unsubs'
|
|
];
|
|
|
|
|
|
# prepare query
|
|
$query = $this->app->database('system')->query()->from('production.oapi_processes t',$columns)
|
|
->join('admin.users u','t.user_id = u.id')
|
|
->join('admin.isps i','t.isp_id = i.id')
|
|
->join('affiliate.offers off','t.offer_id = off.id')
|
|
->where("t.process_type NOT LIKE 'drop'",[]);
|
|
|
|
# fetching the results to create the ajax list
|
|
if(Authentication::getAuthenticatedUser()->getMasterAccess() != 'Enabled')
|
|
{
|
|
$userTeams = [];
|
|
$authorisations = TeamAuthorisation::all(TeamAuthorisation::FETCH_ARRAY,['team_member_id = ?',Authentication::getAuthenticatedUser()->getId()],['team_id']);
|
|
|
|
foreach ($authorisations as $authorisation)
|
|
{
|
|
$userTeams[] = $authorisation['team_id'];
|
|
}
|
|
|
|
if(count($userTeams) != 0)
|
|
{
|
|
# check if the user is a team leader
|
|
$userIds = [Authentication::getAuthenticatedUser()->getId()];
|
|
$teams = Team::all(Team::FETCH_ARRAY,["status = ? and " . $userIds[0] . " = ANY (string_to_array(team_leaders_ids,',')::int[])",['Activated']],['id','name']);
|
|
|
|
|
|
if(count($teams))
|
|
{
|
|
foreach ($teams as $team)
|
|
{
|
|
$members = TeamAuthorisation::all(TeamAuthorisation::FETCH_ARRAY,['team_member_id > 0 AND team_id = ?',$team['id']],['id','team_id','team_member_id']);
|
|
|
|
if(count($members))
|
|
{
|
|
foreach ($members as $member)
|
|
{
|
|
$userIds[] = intval($member['team_member_id']);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
$query->where('t.user_id in ?',[$userIds]);
|
|
}
|
|
}
|
|
|
|
die(json_encode(DataTable::init($data,'production.oapi_processes t',$columns,new OapiProcess(),'oapi-production' . RDS . 'oapi-tests','DESC',$query,false)));
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* @name processDetails
|
|
* @description the mta process details action
|
|
* @before init
|
|
* @after closeConnections,checkForMessage
|
|
*/
|
|
public function processDetails()
|
|
{
|
|
$arguments = func_get_args();
|
|
$type = isset($arguments) && count($arguments) > 0 ? $arguments[0] : null;
|
|
$id = isset($arguments) && count($arguments) > 1 ? $arguments[1] : null;
|
|
|
|
# check for permissions
|
|
$method = '';
|
|
|
|
switch ($type)
|
|
{
|
|
case 'ot' : $method = 'oapiTests'; break;
|
|
case 'od' : $method = 'oapiDrops'; break;
|
|
}
|
|
|
|
$access = Permissions::checkForAuthorization($this->authenticatedUser,__CLASS__,$method);
|
|
|
|
if($access == false)
|
|
{
|
|
throw new PageException('Access Denied !',403);
|
|
}
|
|
|
|
$valid = true;
|
|
|
|
# set menu status
|
|
$this->masterView->set([
|
|
'oapi_production' => 'true',
|
|
'drops_gapi' => 'true',
|
|
'drops_oapi_show' => 'true'
|
|
]);
|
|
|
|
if(!isset($id) || !is_numeric($id) || intval($id) == 0)
|
|
{
|
|
$valid = false;
|
|
}
|
|
|
|
$where = ['id = ?',$id];
|
|
|
|
if(Authentication::getAuthenticatedUser()->getMasterAccess() != 'Enabled')
|
|
{
|
|
$hasAdminRole = Permissions::hasAdminBasedRole(Authentication::getAuthenticatedUser());
|
|
|
|
if($hasAdminRole == false)
|
|
{
|
|
# check if the user is a team leader
|
|
$userIds = [Authentication::getAuthenticatedUser()->getId()];
|
|
$teams = Team::all(Team::FETCH_ARRAY,["status = ? and " . $userIds[0] . " = ANY (string_to_array(team_leaders_ids,',')::int[])",['Activated']],['id','name']);
|
|
|
|
if(count($teams))
|
|
{
|
|
foreach ($teams as $team)
|
|
{
|
|
$members = TeamAuthorisation::all(TeamAuthorisation::FETCH_ARRAY,['team_member_id > 0 AND team_id = ?',$team['id']],['id','team_id','team_member_id']);
|
|
|
|
if(count($members))
|
|
{
|
|
foreach ($members as $member)
|
|
{
|
|
$userIds[] = intval($member['team_member_id']);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
$where = ['id = ? AND user_id in ?',[$id,$userIds]];
|
|
}
|
|
}
|
|
|
|
$process = OapiProcess::first(OapiProcess::FETCH_ARRAY,$where) ;
|
|
|
|
if(count($process) == 0)
|
|
{
|
|
$valid = false;
|
|
}
|
|
|
|
if($valid == true)
|
|
{
|
|
$json = json_decode(base64_decode($process['content']),true);
|
|
|
|
if(count($json) == 0)
|
|
{
|
|
# stores the message in the session
|
|
Page::registerMessage('error','Invalid drop content !');
|
|
|
|
# redirect to lists page
|
|
Page::redirect();
|
|
}
|
|
|
|
$processDetails = [];
|
|
$serversIds = [];
|
|
$vmtasIds = [];
|
|
|
|
# fill with basic data
|
|
foreach ($process as $key => $row)
|
|
{
|
|
if($key != 'content')
|
|
{
|
|
$processDetails[$key] = $row;
|
|
}
|
|
}
|
|
|
|
# type
|
|
$processDetails['process_type'] = $type == 'mt' || $type == 'md' ? 'mta' : 'smtp';
|
|
$processDetails['type'] = $this->app->utils->arrays->get($json,'type');
|
|
|
|
# get mailer info
|
|
$user = User::first(User::FETCH_ARRAY,['id = ?',$processDetails['user_id']],['id','first_name','last_name','production_id']);
|
|
|
|
if(count($user))
|
|
{
|
|
$processDetails['user_production_id'] = $user['production_id'];
|
|
$processDetails['user_full_name'] = $user['first_name'] . ' ' . $user['last_name'] ;
|
|
}
|
|
|
|
# servers and vmtas
|
|
foreach ($this->app->utils->arrays->get($json,'selected-vmtas') as $val)
|
|
{
|
|
$serversIds[] = intval($this->app->utils->arrays->get(explode('|',$val),0));
|
|
$vmtasIds[] = intval($this->app->utils->arrays->get(explode('|',$val),1));
|
|
}
|
|
|
|
$processDetails['servers'] = ($processDetails['process_type'] == 'mta') ? OapiUser::all(OapiUser::FETCH_ARRAY,['id IN ?',[$serversIds]],['id','name'])
|
|
: SmtpServer::all(SmtpServer::FETCH_ARRAY,['id IN ?',[$serversIds]],['id','name']);
|
|
|
|
if($processDetails['process_type'] == 'mta')
|
|
{
|
|
$processDetails['vmtas'] = ServerVmta::all(ServerVmta::FETCH_ARRAY,['id IN ?',[$vmtasIds]],['id','name','domain','ip','mta_server_name']);
|
|
}
|
|
else
|
|
{
|
|
$processDetails['smtp_users'] = SmtpUser::all(SmtpUser::FETCH_ARRAY,['id IN ?',[$vmtasIds]],['id','username','smtp_server_name']);
|
|
}
|
|
|
|
# test emails & placeholders
|
|
$processDetails['test_emails'] = $this->app->utils->arrays->get($json,'rcpts');
|
|
$processDetails['placeholders_one'] = $this->app->utils->arrays->get($json,'placeholders-one');
|
|
$processDetails['placeholders_two'] = $this->app->utils->arrays->get($json,'placeholders-two');
|
|
$processDetails['placeholders_three'] = $this->app->utils->arrays->get($json,'placeholders-three');
|
|
|
|
# rotations & combinations
|
|
$processDetails['vmtas_rotation'] = $this->app->utils->arrays->get($json,'vmta-rotation',1);
|
|
$processDetails['test_rotation'] = $this->app->utils->arrays->get($json,'rcpt-rotation',1);
|
|
$processDetails['test_after'] = $this->app->utils->arrays->get($json,'test-after',1000);
|
|
$processDetails['test_emails_combination'] = $this->app->utils->arrays->get($json,'rcpt-combination','off');
|
|
$processDetails['placeholders_one_rotation'] = $this->app->utils->arrays->get($json,'placeholders-one-rotation','off');
|
|
$processDetails['placeholders_one_combination'] = $this->app->utils->arrays->get($json,'placeholders-one-combination','off');
|
|
$processDetails['placeholders_two_rotation'] = $this->app->utils->arrays->get($json,'placeholders-two-rotation','off');
|
|
$processDetails['placeholders_two_combination'] = $this->app->utils->arrays->get($json,'placeholders-two-combination','off');
|
|
$processDetails['placeholders_three_rotation'] = $this->app->utils->arrays->get($json,'placeholders-three-rotation','off');
|
|
$processDetails['placeholders_three_combination'] = $this->app->utils->arrays->get($json,'placeholders-three-combination','off');
|
|
$processDetails['split_emails_type'] = $this->app->utils->arrays->get($json,'emails-split-type');
|
|
$processDetails['emails_process_type'] = $this->app->utils->arrays->get($json,'vmtas-emails-process');
|
|
$processDetails['batch'] = $this->app->utils->arrays->get($json,'batch');
|
|
$processDetails['x_delay'] = $this->app->utils->arrays->get($json,'x-delay');
|
|
$processDetails['return_path'] = $this->app->utils->arrays->get($json,'return-path');
|
|
$processDetails['static_domain'] = $this->app->utils->arrays->get($json,'static-domain');
|
|
$processDetails['charset'] = $this->app->utils->arrays->get($json,'creative-charset');
|
|
$processDetails['content_type'] = $this->app->utils->arrays->get($json,'creative-content-type');
|
|
$processDetails['content_transfer_encoding'] = $this->app->utils->arrays->get($json,'creative-content-transfert-encoding');
|
|
$processDetails['link_type'] = $this->app->utils->arrays->get($json,'link-type');
|
|
|
|
# affiliate
|
|
$processDetails['affiliate_network_name'] = $process['affiliate_network_id'] > 0 ?
|
|
$this->app->utils->arrays->get(AffiliateNetwork::first(AffiliateNetwork::FETCH_ARRAY,['id = ?',intval($process['affiliate_network_id'])],['name']),'name') : '';
|
|
$processDetails['offer_name'] = $process['offer_id'] > 0 ?
|
|
$this->app->utils->arrays->get(Offer::first(Offer::FETCH_ARRAY,['id = ?',intval($process['offer_id'])],['name']),'name') : '';
|
|
$processDetails['from_name'] = intval($this->app->utils->arrays->get($json,'from-name-id')) > 0 ?
|
|
$this->app->utils->arrays->get(FromName::first(FromName::FETCH_ARRAY,['id = ?',intval($this->app->utils->arrays->get($json,'from-name-id'))],['value']),'value') : '';
|
|
$processDetails['from_name_encoding'] = $this->app->utils->arrays->get($json,'from-name-encoding');
|
|
$processDetails['subject'] = intval($this->app->utils->arrays->get($json,'subject-id')) > 0 ?
|
|
$this->app->utils->arrays->get(Subject::first(Subject::FETCH_ARRAY,['id = ?',intval($this->app->utils->arrays->get($json,'subject-id'))],['value']),'value') : '';
|
|
$processDetails['subject_encoding'] = $this->app->utils->arrays->get($json,'subject-encoding');
|
|
|
|
# data and isps
|
|
$processDetails['isp_name'] = $process['isp_id'] > 0 ?
|
|
$this->app->utils->arrays->get(Isp::first(Isp::FETCH_ARRAY,['id = ?',intval($process['isp_id'])],['name']),'name') : '';
|
|
$processDetails['countries'] = key_exists('countries',$json) && is_array($json['countries']) ? implode(',',$json['countries']): 'US';
|
|
$processDetails['data_start'] = $this->app->utils->arrays->get($json,'data-start');
|
|
$processDetails['data_count'] = $this->app->utils->arrays->get($json,'data-count');
|
|
$processDetails['data_duplicate'] = $this->app->utils->arrays->get($json,'data-duplicate',1);
|
|
|
|
if(strlen($process['lists']) > 0)
|
|
{
|
|
$processDetails['lists'] = DataList::all(DataList::FETCH_ARRAY,['id IN ?',[explode(',',$process['lists'])]],['id','name','data_provider_name']);
|
|
}
|
|
else
|
|
{
|
|
$processDetails['lists'] = [];
|
|
}
|
|
|
|
# data flags
|
|
$processDetails['is_fresh'] = array_key_exists('fresh-filter',$json) ? 'on' : 'off';
|
|
$processDetails['is_clean'] = array_key_exists('clean-filter',$json) ? 'on' : 'off';
|
|
$processDetails['is_openers'] = array_key_exists('openers-filter',$json) ? 'on' : 'off';
|
|
$processDetails['is_clickers'] = array_key_exists('clickers-filter',$json) ? 'on' : 'off';
|
|
$processDetails['is_leaders'] = array_key_exists('leaders-filter',$json) ? 'on' : 'off';
|
|
$processDetails['is_optouts'] = array_key_exists('optouts-filter',$json) ? 'on' : 'off';
|
|
$processDetails['is_unsubs'] = array_key_exists('unsubs-filter',$json) ? 'on' : 'off';
|
|
$processDetails['is_seeds'] = array_key_exists('seeds-filter',$json) ? 'on' : 'off';
|
|
|
|
# header and body
|
|
$headers = $this->app->utils->arrays->get($json,'headers',[]);
|
|
$processDetails['headers'] = is_array($headers) && count($headers) ? implode(PHP_EOL . '_SEPARATOR_' . PHP_EOL,$headers): '';
|
|
$processDetails['body'] = $this->app->utils->arrays->get($json,'body');
|
|
|
|
# set data to the page view
|
|
$this->pageView->set([
|
|
'process' => $processDetails
|
|
]);
|
|
}
|
|
else
|
|
{
|
|
# stores the message in the session
|
|
Page::registerMessage('error','Invalid process id !');
|
|
|
|
# redirect to lists page
|
|
Page::redirect();
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* @name closeConnections
|
|
* @description close all connections
|
|
* @once
|
|
* @protected
|
|
*/
|
|
public function closeConnections()
|
|
{
|
|
# connect to the database
|
|
$this->app->database('system')->disconnect();
|
|
$this->app->database('clients')->disconnect();
|
|
}
|
|
|
|
/**
|
|
* @name checkForMessage
|
|
* @description checks for session messages
|
|
* @once
|
|
* @protected
|
|
*/
|
|
public function checkForMessage()
|
|
{
|
|
# check for message
|
|
Page::checkForMessage($this);
|
|
}
|
|
} |