Files
accounting_dev/application/controllers/Cronjob.php
T
2026-07-12 22:10:02 +07:00

673 lines
25 KiB
PHP

<?php
defined('BASEPATH') OR exit('No direct script access allowed');
class Cronjob extends CI_Controller {
public function __construct()
{
parent::__construct();
$this->load->database();
// ONLY CLI ACCESS
// if (!$this->input->is_cli_request()) {
// exit('No direct access allowed');
// }
}
public function generate_insight()
{
$period = date('Y-m');
// =====================================================
// 🔥 REPLACE MODE (hapus data lama dulu)
// =====================================================
$this->db->where('period', $period);
$this->db->delete('ai_insights');
// =====================================================
// 1. FINANCE - OVERDUE INVOICE
// =====================================================
$overdue = $this->db->query("
SELECT COUNT(*) as total
FROM invoices
WHERE status != 'paid'
AND jatuh_tempo < CURDATE()
AND deleted_at IS NULL
")->row()->total;
if ($overdue > 0) {
$this->db->insert('ai_insights', [
'type' => 'finance',
'severity' => 'warning',
'message' => "$overdue invoice sudah melewati jatuh tempo",
'meta' => json_encode([
'overdue_count' => (int)$overdue
]),
'period' => $period
]);
}
// =====================================================
// 2. FINANCE - CASHFLOW BULAN INI
// =====================================================
$cash = $this->db->query("
SELECT COALESCE(SUM(jd.debit),0) as cash_in
FROM journal_details jd
JOIN journals j ON j.id = jd.journal_id
WHERE MONTH(j.tanggal) = MONTH(CURDATE())
AND YEAR(j.tanggal) = YEAR(CURDATE())
")->row()->cash_in;
if ($cash > 0) {
$this->db->insert('ai_insights', [
'type' => 'finance',
'severity' => ($cash > 10000000) ? 'info' : 'warning',
'message' => "Cashflow bulan ini Rp " . number_format($cash),
'meta' => json_encode([
'cash_in' => (float)$cash
]),
'period' => $period
]);
}
// =====================================================
// 3. STOCK - KRITIS
// =====================================================
$stocks = $this->db->query("
SELECT
i.kode_id,
k.nama_barang,
SUM(i.stok) as total_stok,
k.limit_stock
FROM items i
JOIN kode_barang k ON k.id = i.kode_id
GROUP BY i.kode_id, k.nama_barang, k.limit_stock
HAVING total_stok <= k.limit_stock
")->result();
foreach ($stocks as $s) {
$this->db->insert('ai_insights', [
'type' => 'stock',
'severity' => 'critical',
'message' => "Stok {$s->nama_barang} kritis ({$s->total_stok})",
'meta' => json_encode([
'kode_id' => $s->kode_id,
'item' => $s->nama_barang,
'stok' => (int)$s->total_stok,
'limit' => (int)$s->limit_stock
]),
'period' => $period
]);
}
// =====================================================
// 4. CUSTOMER - PAYMENT RISK
// =====================================================
$lateCustomers = $this->db->query("
SELECT
c.nama,
COUNT(i.id) as total_invoice
FROM invoices i
JOIN customers c ON c.id = i.customer_id
WHERE i.status != 'paid'
AND i.jatuh_tempo < CURDATE()
GROUP BY i.customer_id
HAVING total_invoice > 2
")->result();
foreach ($lateCustomers as $c) {
$this->db->insert('ai_insights', [
'type' => 'customer',
'severity' => 'warning',
'message' => "Customer {$c->nama} memiliki {$c->total_invoice} invoice overdue",
'meta' => json_encode([
'customer' => $c->nama,
'overdue_invoice' => (int)$c->total_invoice
]),
'period' => $period
]);
}
// =====================================================
// RESPONSE
// =====================================================
echo json_encode([
'status' => true,
'message' => 'AI Insight generated (REPLACE MODE)',
'period' => $period
]);
}
// =====================================================
// CRONJOB UNTUK LIHAT KEHADIRAN SELAMA 1 BULAN
// =====================================================
// | Kriteria | Pengurangan |
// | ---------------------- | ------------------: |
// | Alpha | -20 poin / hari |
// | Terlambat | -2 poin / kejadian |
// | Izin (permit) | -1 poin / hari |
// | Akumulasi telat | -1 poin / 60 menit |
// | Akumulasi pulang cepat | -1 poin / 120 menit |
public function generateMonthlyAttendance()
{
$month = date('Y-m-01');
$startDate = date('Y-m-01', strtotime($month));
$endDate = date('Y-m-t', strtotime($month));
$employees = $this->db
->where('is_active', 1)
->get('k_employees')
->result();
$processed = 0;
$this->db->trans_begin();
try {
foreach ($employees as $employee) {
// Total Hari Kerja
$schedule = $this->db->query("
SELECT
COUNT(*) AS total_hari_kerja
FROM k_employee_shift_schedules
WHERE employee_id = ?
AND status IN ('published','done')
AND schedule_date BETWEEN ? AND ?
", array(
$employee->id,
$startDate,
$endDate
))->row();
$total_hari_kerja = (int) $schedule->total_hari_kerja;
// Rekap Absensi
$attendance = $this->db->query("
SELECT
COALESCE(SUM(attendance_status='present'),0) AS total_present,
COALESCE(SUM(attendance_status='late'),0) AS total_late,
COALESCE(SUM(attendance_status='alpha'),0) AS total_alpha,
COALESCE(SUM(attendance_status='sick'),0) AS total_sick,
COALESCE(SUM(attendance_status='permit'),0) AS total_permit,
COALESCE(SUM(attendance_status='annual'),0) AS total_annual,
COALESCE(SUM(late_minutes),0) AS total_late_minutes,
COALESCE(SUM(early_leave_minutes),0) AS total_early_leave_minutes,
COALESCE(SUM(work_hours),0) AS total_work_hours,
COALESCE(SUM(overtime_hours),0) AS total_overtime_hours
FROM k_attendances
WHERE employee_id = ?
AND attendance_date BETWEEN ? AND ?
", array(
$employee->id,
$startDate,
$endDate
))->row();
$total_present = (int) $attendance->total_present;
$total_late = (int) $attendance->total_late;
$total_alpha = (int) $attendance->total_alpha;
$total_sick = (int) $attendance->total_sick;
$total_permit = (int) $attendance->total_permit;
$total_annual = (int) $attendance->total_annual;
// Kehadiran
$total_hadir = $total_present + $total_late;
$attendance_percentage = 0;
if ($total_hari_kerja > 0) {
$attendance_percentage = round(
($total_hadir / $total_hari_kerja) * 100,
2
);
}
// SCOR
$score = 100;
// Alpha
$score -= ($total_alpha * 20);
// Telat
$score -= ($total_late * 2);
// Izin
$score -= ($total_permit * 1);
// Total menit telat
$score -= floor(
((int) $attendance->total_late_minutes) / 60
);
// Total menit pulang cepat
$score -= floor(
((int) $attendance->total_early_leave_minutes) / 120
);
if ($score < 0) {
$score = 0;
}
// LOGIKA STATUS
if ($score >= 90) {
$status = 'baik sekali';
} elseif ($score >= 75) {
$status = 'baik';
} elseif ($score >= 60) {
$status = 'kurang baik';
} else {
$status = 'buruk';
}
// INSERT OR UPDATE TO k_attendance_monthly
$sql = "
INSERT INTO k_attendance_monthly (
employee_id, month,
total_present, total_late, total_alpha, total_sick, total_permit, total_annual,
total_late_minutes, total_early_leave_minutes,
total_work_hours, total_overtime_hours,
total_hari_kerja, total_hadir, attendance_percentage,
score, status
)
VALUES (
?, ?,
?, ?, ?, ?, ?, ?,
?, ?,
?, ?,
?, ?, ?,
?, ?
)
ON DUPLICATE KEY UPDATE
total_present = VALUES(total_present),
total_late = VALUES(total_late),
total_alpha = VALUES(total_alpha),
total_sick = VALUES(total_sick),
total_permit = VALUES(total_permit),
total_annual = VALUES(total_annual),
total_late_minutes = VALUES(total_late_minutes),
total_early_leave_minutes = VALUES(total_early_leave_minutes),
total_work_hours = VALUES(total_work_hours),
total_overtime_hours = VALUES(total_overtime_hours),
total_hari_kerja = VALUES(total_hari_kerja),
total_hadir = VALUES(total_hadir),
attendance_percentage = VALUES(attendance_percentage),
score = VALUES(score),
status = VALUES(status),
updated_at = CURRENT_TIMESTAMP
";
$this->db->query($sql, array(
$employee->id,
$month,
$total_present,
$total_late,
$total_alpha,
$total_sick,
$total_permit,
$total_annual,
(int)$attendance->total_late_minutes,
(int)$attendance->total_early_leave_minutes,
(float)$attendance->total_work_hours,
(float)$attendance->total_overtime_hours,
$total_hari_kerja,
$total_hadir,
$attendance_percentage,
$score,
$status
));
$processed++;
}
if ($this->db->trans_status() === FALSE) {
throw new Exception('Transaction failed');
}
$this->db->trans_commit();
echo json_encode(array(
'status' => true,
'month' => $month,
'processed' => $processed,
'message' => 'Monthly attendance generated successfully'
));
} catch (Exception $e) {
$this->db->trans_rollback();
echo json_encode(array(
'status' => false,
'month' => $month,
'message' => $e->getMessage()
));
}
}
// =====================================================
// CRONJOB AUTO PENYUSUTAN ASSET BULANAN
// =====================================================
public function depreciation_asset()
{
$period = date('Y-m');
$runDate = date('Y-m-d');
$akun_beban_penyusutan = 54;
$assets = $this->db
->select('id, nama_asset, nilai_perolehan, nilai_buku, nilai_residu, penyusutan_per_bulan, masa_manfaat, tanggal_perolehan, akumulasi_penyusutan, account_debit_id')
->from('assets')
->where('status', 'aktif')
->where('nilai_buku > nilai_residu', null, false)
->where('penyusutan_per_bulan >', 0)
->get()
->result();
$processed = 0;
$success = 0;
$skipped = 0;
$errors = 0;
$details = [];
$this->db->trans_begin();
try {
foreach ($assets as $a) {
$processed++;
$assetDetails = [
'asset_id' => (int)$a->id,
'asset_name' => $a->nama_asset,
'processed_months' => [],
'skipped_months' => []
];
$account_parent = $this->db
->select('id')
->where('parent_id', $a->account_debit_id)
->get('accounts')
->row();
if (!$account_parent || empty($account_parent->id)) {
$skipped++;
$assetDetails['status'] = 'skip';
$assetDetails['reason'] = 'account_parent_not_found';
$details[] = $assetDetails;
continue;
}
$akun_akumulasi_penyusutan = (int)$account_parent->id;
$mutasiPatokan = $this->db
->select('tanggal_dibuat')
->from('asset_mutations')
->where('asset_id', $a->id)
->where_in('tipe', ['perolehan', 'penambahan'])
->order_by('tanggal_dibuat', 'DESC')
->order_by('id', 'DESC')
->limit(1)
->get()
->row();
$tanggalPatokan = null;
if ($mutasiPatokan && !empty($mutasiPatokan->tanggal_dibuat)) {
$tanggalPatokan = $mutasiPatokan->tanggal_dibuat;
}
if (empty($tanggalPatokan)) {
$tanggalPatokan = $a->tanggal_perolehan;
}
if (empty($tanggalPatokan)) {
$skipped++;
$assetDetails['status'] = 'skip';
$assetDetails['reason'] = 'tanggal_patokan_tidak_ditemukan';
$details[] = $assetDetails;
continue;
}
$startMonth = date('Y-m', strtotime(date('Y-m-01', strtotime($tanggalPatokan)) . ' +1 month'));
$currentMonth = $period;
if ($startMonth > $currentMonth) {
$skipped++;
$assetDetails['status'] = 'skip';
$assetDetails['reason'] = 'start_next_month_after_acquisition';
$assetDetails['tanggal_patokan'] = $tanggalPatokan;
$details[] = $assetDetails;
continue;
}
$nilaiPerolehan = (float)$a->nilai_perolehan;
$nilaiResidu = (float)$a->nilai_residu;
$susutPerBulan = (float)$a->penyusutan_per_bulan;
$masaManfaat = (int)$a->masa_manfaat;
$akumulasiMutasi = $this->db
->select('COALESCE(SUM(nilai),0) total', false)
->from('asset_mutations')
->where('asset_id', $a->id)
->where('tipe', 'penyusutan')
->get()
->row();
$akumulasiBerjalan = (float)($akumulasiMutasi ? $akumulasiMutasi->total : 0);
$nilaiBukuBerjalan = $nilaiPerolehan - $akumulasiBerjalan;
if ($nilaiBukuBerjalan < $nilaiResidu) {
$nilaiBukuBerjalan = $nilaiResidu;
$akumulasiBerjalan = $nilaiPerolehan - $nilaiBukuBerjalan;
}
$iterMonth = $startMonth;
$assetHasSuccess = false;
while ($iterMonth <= $currentMonth) {
$monthsUsed = 0;
$start = new DateTime(date('Y-m-01', strtotime($tanggalPatokan)));
$end = new DateTime(date('Y-m-01', strtotime($iterMonth . '-01')));
$diff = $start->diff($end);
$monthsUsed = ($diff->y * 12) + $diff->m;
if ($monthsUsed < 0) {
$skipped++;
$assetDetails['skipped_months'][] = [
'period' => $iterMonth,
'reason' => 'tanggal_patokan_after_period'
];
$iterMonth = date('Y-m', strtotime($iterMonth . '-01 +1 month'));
continue;
}
if ($masaManfaat > 0 && $monthsUsed >= $masaManfaat) {
$skipped++;
$assetDetails['skipped_months'][] = [
'period' => $iterMonth,
'reason' => 'masa_manfaat_finished'
];
break;
}
$acqDay = (int)date('d', strtotime($tanggalPatokan));
$lastDayOfMonth = (int)date('t', strtotime($iterMonth . '-01'));
$dueDay = min($acqDay, $lastDayOfMonth);
$dueDateThisMonth = $iterMonth . '-' . str_pad($dueDay, 2, '0', STR_PAD_LEFT);
// Untuk bulan berjalan, tetap hormati due date.
// Untuk bulan yang sudah lewat, langsung boleh diproses (catch-up).
if ($iterMonth === $currentMonth && strtotime($runDate) < strtotime($dueDateThisMonth)) {
$skipped++;
$assetDetails['skipped_months'][] = [
'period' => $iterMonth,
'reason' => 'not_due_date_today',
'due_date' => $dueDateThisMonth,
'run_date' => $runDate
];
$iterMonth = date('Y-m', strtotime($iterMonth . '-01 +1 month'));
continue;
}
$startDate = $iterMonth . '-01';
$endDate = date('Y-m-d', strtotime($startDate . ' +1 month'));
$already = $this->db
->where('asset_id', $a->id)
->where('tipe', 'penyusutan')
->where('tanggal_dibuat >=', $startDate)
->where('tanggal_dibuat <', $endDate)
->count_all_results('asset_mutations');
if ($already > 0) {
$skipped++;
$assetDetails['skipped_months'][] = [
'period' => $iterMonth,
'reason' => 'already_depreciated_this_month'
];
$iterMonth = date('Y-m', strtotime($iterMonth . '-01 +1 month'));
continue;
}
if ($nilaiBukuBerjalan <= $nilaiResidu) {
$skipped++;
$assetDetails['skipped_months'][] = [
'period' => $iterMonth,
'reason' => 'nothing_to_depreciate'
];
break;
}
$maxSusut = max(0, $nilaiBukuBerjalan - $nilaiResidu);
$susut = min($susutPerBulan, $maxSusut);
if ($susut <= 0) {
$skipped++;
$assetDetails['skipped_months'][] = [
'period' => $iterMonth,
'reason' => 'nothing_to_depreciate'
];
break;
}
$akumulasiBefore = $akumulasiBerjalan;
$nilaiBukuBefore = $nilaiBukuBerjalan;
$akumulasiBerjalan += $susut;
$nilaiBukuBerjalan = $nilaiPerolehan - $akumulasiBerjalan;
if ($nilaiBukuBerjalan < $nilaiResidu) {
$nilaiBukuBerjalan = $nilaiResidu;
$akumulasiBerjalan = $nilaiPerolehan - $nilaiBukuBerjalan;
}
$this->db->insert('asset_mutations', [
'asset_id' => $a->id,
'tipe' => 'penyusutan',
'nilai' => $susut,
'keterangan' => 'Penyusutan otomatis periode ' . $iterMonth . ' (cronjob)',
'tanggal_dibuat' => $dueDateThisMonth
]);
$no_ref = 'DEP-' . date('YmdHis') . '-' . $a->id . '-' . str_replace('-', '', $iterMonth);
$this->db->insert('journals', [
'tanggal' => $dueDateThisMonth,
'no_ref' => $no_ref,
'keterangan' => 'Penyusutan Asset ' . $a->nama_asset . ' periode ' . $iterMonth,
'ref_type' => 'assets',
'ref_id' => $a->id,
'created_by' => 1
]);
$jid = $this->db->insert_id();
$this->db->insert('journal_details', [
'journal_id' => $jid,
'account_id' => $akun_beban_penyusutan,
'debit' => $susut,
'kredit' => 0
]);
$this->db->insert('journal_details', [
'journal_id' => $jid,
'account_id' => $akun_akumulasi_penyusutan,
'debit' => 0,
'kredit' => $susut
]);
$success++;
$assetHasSuccess = true;
$assetDetails['processed_months'][] = [
'period' => $iterMonth,
'depreciation' => (float)$susut,
'due_date' => $dueDateThisMonth,
'akumulasi_before' => (float)$akumulasiBefore,
'akumulasi_after' => (float)$akumulasiBerjalan,
'nilai_buku_before' => (float)$nilaiBukuBefore,
'nilai_buku_after' => (float)$nilaiBukuBerjalan,
'journal_no_ref' => $no_ref
];
$iterMonth = date('Y-m', strtotime($iterMonth . '-01 +1 month'));
}
if ($assetHasSuccess) {
$this->db->where('id', $a->id)->update('assets', [
'akumulasi_penyusutan' => $akumulasiBerjalan,
'nilai_buku' => $nilaiBukuBerjalan
]);
$assetDetails['status'] = 'success';
$assetDetails['akumulasi_final'] = (float)$akumulasiBerjalan;
$assetDetails['nilai_buku_final'] = (float)$nilaiBukuBerjalan;
} else {
$assetDetails['status'] = 'skip';
if (empty($assetDetails['reason'])) {
$assetDetails['reason'] = 'no_eligible_month_to_process';
}
}
$details[] = $assetDetails;
}
if ($this->db->trans_status() === FALSE) {
throw new Exception('Transaction failed');
}
$this->db->trans_commit();
echo json_encode([
'status' => true,
'period' => $period,
'processed' => $processed,
'success' => $success,
'skipped' => $skipped,
'errors' => $errors,
'message' => 'Depreciation cron executed',
'details' => $details
]);
} catch (Exception $e) {
$this->db->trans_rollback();
$errors++;
echo json_encode([
'status' => false,
'period' => $period,
'processed' => $processed,
'success' => $success,
'skipped' => $skipped,
'errors' => $errors,
'message' => $e->getMessage()
]);
}
}
}