emmymayo
133 lines
4.2 KiB
PHP
133 lines
4.2 KiB
PHP
<?php
|
|
include_once __DIR__ . "/mysql-database-service.php";
|
|
|
|
class CampaignModel extends MySqlDatabaseService
|
|
{
|
|
protected $_table = 'campaign';
|
|
protected $_primary_key = 'id';
|
|
protected $_return_type = 'array';
|
|
protected $_allowed_fields = [
|
|
'id', 'name', 'file_id', 'data', 'user_id', 'created_at', 'updated_at'
|
|
];
|
|
protected $_label_fields = [
|
|
'ID', 'Name', 'File ID', 'Data', 'User ID', 'Created At', 'Updated At'
|
|
];
|
|
protected $_use_timestamps = true;
|
|
protected $_created_field = 'created_at';
|
|
protected $_updated_field = 'updated_at';
|
|
protected $_validation_rules = [
|
|
['name', 'Name', 'required'],
|
|
['file_id', 'File ID', 'required'],
|
|
['data', 'Data', ''],
|
|
['user_id', 'User ID', 'required'],
|
|
['created_at', 'Created At', 'required'],
|
|
['updated_at', 'Updated At', 'required']
|
|
];
|
|
|
|
protected $_validation_edit_rules = [
|
|
['name', 'Name', 'required'],
|
|
['file_id', 'File ID', 'required'],
|
|
['data', 'Data', ''],
|
|
['user_id', 'User ID', 'required'],
|
|
['updated_at', 'Updated At', 'required']
|
|
];
|
|
|
|
protected $_validation_messages = [
|
|
['name', 'Name ', 'required'],
|
|
['file_id', 'File ID', 'required'],
|
|
['data', 'Data', ''],
|
|
['user_id', 'User ID', 'required'],
|
|
['updated_at', 'Updated At', 'required']
|
|
];
|
|
|
|
public function __construct()
|
|
{
|
|
parent::__construct();
|
|
}
|
|
|
|
public function get_mapping()
|
|
{
|
|
return [
|
|
// TODO: ADD MAPPING
|
|
];
|
|
}
|
|
|
|
public function csvToObject($csvString) {
|
|
$lines = explode("\n", $csvString);
|
|
$headers = array_map(function($header) {
|
|
return str_replace(' ', '_', trim(strtolower($header)));
|
|
}, explode(',', $lines[0])); // Convert headers to snake case
|
|
|
|
$object = [];
|
|
|
|
foreach ($headers as $header) {
|
|
$object[$header] = [];
|
|
}
|
|
|
|
for ($i = 1; $i < count($lines) - 1; $i++) {
|
|
$values = explode(',', $lines[$i]);
|
|
for ($j = 0; $j < count($headers) && $j < count($values); $j++) {
|
|
$value = trim($values[$j]);
|
|
if ($headers[$j] == 'duration' && $value === "-") {
|
|
$object[$headers[$j]][] = '00:00';
|
|
continue;
|
|
}
|
|
$object[$headers[$j]][] = $value;
|
|
}
|
|
}
|
|
|
|
return $object;
|
|
}
|
|
|
|
public function getFilteredData($campaign, $filters) {
|
|
$config = MkdConfig::get_instance()->get_config();
|
|
$userModel = new UserModel();
|
|
$user = $userModel->get($_SESSION['user']);
|
|
|
|
$oauth = new \Lib\Google\GoogleOAuth2(
|
|
$config['google_client_id'],
|
|
$config['google_client_secret'],
|
|
$config['google_redirect_uri']
|
|
);
|
|
|
|
$oauth->setRefreshToken($user->drive_refresh_token);
|
|
$oauth->refreshAccessToken();
|
|
|
|
$drive = new \Lib\Google\GoogleDrive($oauth);
|
|
|
|
// Download and parse the file
|
|
$content = $drive->downloadFile($campaign->file_id, 'text/csv');
|
|
$data = $this->csvToObject($content);
|
|
|
|
// Apply filters
|
|
$validRows = range(0, count($data['date']) - 1);
|
|
|
|
if ($filters['campaign_name']) {
|
|
$validRows = array_filter($validRows, function($i) use ($data, $filters) {
|
|
return $data['campaign_name'][$i] === $filters['campaign_name'];
|
|
});
|
|
}
|
|
|
|
if ($filters['ad_set_name']) {
|
|
$validRows = array_filter($validRows, function($i) use ($data, $filters) {
|
|
return $data['ad_set_name'][$i] === $filters['ad_set_name'];
|
|
});
|
|
}
|
|
|
|
if ($filters['ad_name']) {
|
|
$validRows = array_filter($validRows, function($i) use ($data, $filters) {
|
|
return $data['ad_name'][$i] === $filters['ad_name'];
|
|
});
|
|
}
|
|
|
|
// Filter the data
|
|
$filteredData = [];
|
|
foreach ($data as $column => $values) {
|
|
$filteredData[$column] = array_intersect_key($values, array_flip($validRows));
|
|
}
|
|
|
|
return $filteredData;
|
|
}
|
|
|
|
}
|