config = $config;
}
public function log_error($api_name, $api_params, $log)
{
$model = new ApiErrors();
$model->api_name = $api_name;
$model->api_param = $api_params;
$log = str_replace("'", "", $log);
$log = str_replace('"', "", $log);
$model->log = $log;
$model->created_at = date('Y-m-d H:i:s');
$model->save();
}
public function process_notif()
{
$recipient = $this->config['log_api_error_recipient'];
if (!empty($recipient)) {
$interval = $this->config["log_api_error_interval"];
date_default_timezone_set("Asia/Jakarta");
$formattedawal = date('d-m-Y H:i:s', strtotime("-$interval hour"));
$formattedakhir = date('d-m-Y H:i:s');
$awal = gmdate('Y-m-d H:i:s', strtotime("-$interval hour"));
$akhir = gmdate('Y-m-d H:i:s');
$result = ApiErrors::query()
->columns("ApiErrors.api_name, count(*) as cnt")
->where("ApiErrors.created_at >= :date_filter:")
->bind(['date_filter' => $awal])
->groupBy("ApiErrors.api_name")
->orderBy("ApiErrors.api_name")->execute()->toArray();
if (count($result) > 0) {
$message = "
Daftar API Error $formattedawal - $formattedakhir
Berikut adalah Summary Error Pemanggilan API:
";
$message .= "";
$message .= "";
$message .= "";
$message .= "| No | ";
$message .= "API Name | ";
$message .= "Count | ";
$message .= "
";
$message .= "";
$message .= "";
$no = 1;
foreach ($result as $res) {
$api_name = $res["api_name"];
$cnt = $res['cnt'];
$message .= "";
$message .= "| " . $no++ . " | ";
$message .= "" . $api_name . " | ";
$message .= "" . $cnt . " | ";
$message .= "
";
}
$message .= "";
$message .= "
";
$recipients = explode(",", $recipient);
$subject = $this->config['log_api_error_subject'];
foreach ($recipients as $email) {
if (empty($email)) {
continue;
}
$mail = new MailHelper($this->config["mail_config"]);
$mail->queue($email, $subject, $message, true);
}
}
}
}
public function process_notif_job()
{
$recipient = $this->config['log_api_error_recipient'];
$message = '';
if (!empty($recipient)) {
$result = [];
$queue = new Beanstalk($this->config["beanstalk_config"]);
$duration = $this->config['log_job_error_duration'];
$job = $queue->peekReady();
$stats = $job->stats();
if ($stats['age'] > $duration) {
$tubeStats = $queue->statsTube($stats['tube']);
$body = $job->getBody();
#region Process Send Email
date_default_timezone_set("Asia/Jakarta");
$date = date('d-m-Y H:i:s');
$message = "
Summary Job Error $date
Berikut adalah Summary Error Proses Job:
";
$message .= "";
$message .= "";
$message .= "";
$message .= "| Properties | ";
$message .= "Value | ";
$message .= "
";
$message .= "";
$message .= "";
#region Total Jobs
$message .= "";
$message .= "| Total Jobs | ";
$message .= "" . $tubeStats['total-jobs'] . " | ";
$message .= "
";
#endregion
#region Jobs Ready
$message .= "";
$message .= "| Current Jobs Ready | ";
$message .= "" . $tubeStats['current-jobs-ready'] . " | ";
$message .= "
";
#endregion
$message .= " |
";
#region Blocking Jobs
$message .= "";
$message .= "| Blocking Job Information | ";
$message .= "
";
#region Job ID
$message .= "";
$message .= "| Job ID | ";
$message .= "" . $stats['id'] . " | ";
$message .= "
";
#endregion
#region Job Tube
$message .= "";
$message .= "| Job Tube | ";
$message .= "" . $stats['tube'] . " | ";
$message .= "
";
#endregion
#region Job Age
$message .= "";
$message .= "| Job Age | ";
$message .= "" . gmdate('z \H\a\r\i H \J\a\m i \M\e\n\i\t s \D\e\t\i\k', $stats['age']) . " | ";
$message .= "
";
#endregion
$message .= " |
";
#region Job Details
$message .= "";
$message .= "| Job Details | ";
$message .= "
";
#region Class
$message .= "";
$message .= "| Class | ";
$message .= "" . $body['class'] . " | ";
$message .= "
";
#endregion
#region Method
$message .= "";
$message .= "| Method | ";
$message .= "" . $body['method'] . " | ";
$message .= "
";
#endregion
#region Method Type
$message .= "";
$message .= "| Method Type | ";
$message .= "" . $body['method_type'] . " | ";
$message .= "
";
#endregion
#endregion
#endregion
$message .= "";
$message .= "
";
$recipients = explode(",", $recipient);
$subject = $this->config['log_api_error_subject'];
foreach ($recipients as $email) {
if (empty($email)) {
continue;
}
$mail = new MailHelper($this->config["mail_config"]);
$mail->sendMail($email, $subject, $message, true);
}
#endregion
}
}
return $message;
}
}