89 lines
2.5 KiB
PHP
89 lines
2.5 KiB
PHP
<?php
|
|
|
|
//display errors
|
|
//ini_set('display_errors', 1);
|
|
//ini_set('display_startup_errors', 1);
|
|
//error_reporting(E_ALL);
|
|
|
|
class VoiceCallHistoryJobController extends mfBaseController {
|
|
private User $me;
|
|
private string $VOICE_PORTAL_HOST = KOLMISOFT_API_HOST;
|
|
private string $VOICE_PORTAL_API_KEY = KOLMISOFT_API_KEY;
|
|
private string $VOICE_PORTAL_USERNAME = KOLMISOFT_API_USERNAME;
|
|
|
|
private KolmisoftMore $kolmisoftMore;
|
|
|
|
|
|
protected function init(): void {
|
|
$me = new User();
|
|
$me->loadMe();
|
|
$this->layout()->set("me", $me);
|
|
$this->me = $me;
|
|
|
|
if (!$this->me->isAdmin()) {
|
|
$this->redirect("dashboard");
|
|
}
|
|
|
|
$this->kolmisoftMore = new KolmisoftMore($this->VOICE_PORTAL_HOST, $this->VOICE_PORTAL_API_KEY, $this->VOICE_PORTAL_USERNAME);
|
|
|
|
}
|
|
|
|
protected function indexAction(): void {
|
|
$this->layout()->setTemplate("VoiceCallHistoryJob/Index");
|
|
}
|
|
|
|
protected function apiAction() {
|
|
$do = $this->request->do;
|
|
|
|
if (!$this->me->isAdmin()) {
|
|
$this->redirect("dashboard");
|
|
}
|
|
|
|
switch ($do) {
|
|
case "runJobs":
|
|
$return = $this->runJobs();
|
|
break;
|
|
default:
|
|
$return = false;
|
|
break;
|
|
}
|
|
|
|
if (!$return) {
|
|
$return = [
|
|
"status" => "error",
|
|
"message" => "Invalid request."
|
|
];
|
|
}
|
|
|
|
die(json_encode($return));
|
|
}
|
|
|
|
public function runJobs(): array {
|
|
VoiceCallHistoryJobModel::createJobsUntilToday();
|
|
|
|
$jobs = VoiceCallHistoryJobModel::getJobsNotDone();
|
|
|
|
$messages = [
|
|
"success" => [],
|
|
"error" => []
|
|
];
|
|
foreach ($jobs as $job) {
|
|
$startDate = strtotime(date("Y-m-d 00:00:00", strtotime($job->date)));
|
|
$endDate = strtotime(date("Y-m-d 00:00:00", strtotime($job->date . " +1 day")));
|
|
|
|
$callHistory = $this->kolmisoftMore->getVoiceCallHistory($startDate, $endDate);
|
|
|
|
$importedCalls = VoiceCallHistoryModel::importCallsFromKolmisoft($callHistory);
|
|
|
|
if ($importedCalls) {
|
|
$messages["success"][$job->date] = $importedCalls["message"];
|
|
VoiceCallHistoryJobModel::updateJobStatus($job->id, "success");
|
|
} else {
|
|
$messages["error"][$job->date] = "Failed to import calls for job $job->id.";
|
|
VoiceCallHistoryJobModel::updateJobStatus($job->id, "failed");
|
|
}
|
|
}
|
|
|
|
return $messages;
|
|
}
|
|
} |