conn = $db; } public function create() { $query = "INSERT INTO " . $this->table_name . " SET journal_entry_id=:journal_entry_id, account_id=:account_id, debit_amount=:debit_amount, credit_amount=:credit_amount, description=:description, created_at=:created_at, updated_at=:updated_at"; $stmt = $this->conn->prepare($query); $this->journal_entry_id = htmlspecialchars(strip_tags($this->journal_entry_id)); $this->account_id = htmlspecialchars(strip_tags($this->account_id)); $this->debit_amount = htmlspecialchars(strip_tags($this->debit_amount)); $this->credit_amount = htmlspecialchars(strip_tags($this->credit_amount)); $this->description = htmlspecialchars(strip_tags($this->description)); $this->created_at = date('Y-m-d H:i:s'); $this->updated_at = date('Y-m-d H:i:s'); $stmt->bindParam(":journal_entry_id", $this->journal_entry_id); $stmt->bindParam(":account_id", $this->account_id); $stmt->bindParam(":debit_amount", $this->debit_amount); $stmt->bindParam(":credit_amount", $this->credit_amount); $stmt->bindParam(":description", $this->description); $stmt->bindParam(":created_at", $this->created_at); $stmt->bindParam(":updated_at", $this->updated_at); if($stmt->execute()) { return true; } return false; } public function read() { $query = "SELECT at.*, coa.account_name, coa.account_type, je.entry_number, je.entry_date FROM " . $this->table_name . " at LEFT JOIN chart_of_accounts coa ON at.account_id = coa.id LEFT JOIN journal_entries je ON at.journal_entry_id = je.id ORDER BY je.entry_date DESC, je.created_at DESC, at.id DESC"; $stmt = $this->conn->prepare($query); $stmt->execute(); return $stmt; } public function readOne() { $query = "SELECT at.*, coa.account_name, coa.account_type, je.entry_number, je.entry_date FROM " . $this->table_name . " at LEFT JOIN chart_of_accounts coa ON at.account_id = coa.id LEFT JOIN journal_entries je ON at.journal_entry_id = je.id WHERE at.id = ? LIMIT 0,1"; $stmt = $this->conn->prepare($query); $stmt->bindParam(1, $this->id); $stmt->execute(); $row = $stmt->fetch(PDO::FETCH_ASSOC); $this->journal_entry_id = $row['journal_entry_id']; $this->account_id = $row['account_id']; $this->debit_amount = $row['debit_amount']; $this->credit_amount = $row['credit_amount']; $this->description = $row['description']; $this->created_at = $row['created_at']; $this->updated_at = $row['updated_at']; } public function update() { $query = "UPDATE " . $this->table_name . " SET journal_entry_id=:journal_entry_id, account_id=:account_id, debit_amount=:debit_amount, credit_amount=:credit_amount, description=:description, updated_at=:updated_at WHERE id=:id"; $stmt = $this->conn->prepare($query); $this->journal_entry_id = htmlspecialchars(strip_tags($this->journal_entry_id)); $this->account_id = htmlspecialchars(strip_tags($this->account_id)); $this->debit_amount = htmlspecialchars(strip_tags($this->debit_amount)); $this->credit_amount = htmlspecialchars(strip_tags($this->credit_amount)); $this->description = htmlspecialchars(strip_tags($this->description)); $this->updated_at = date('Y-m-d H:i:s'); $stmt->bindParam(":journal_entry_id", $this->journal_entry_id); $stmt->bindParam(":account_id", $this->account_id); $stmt->bindParam(":debit_amount", $this->debit_amount); $stmt->bindParam(":credit_amount", $this->credit_amount); $stmt->bindParam(":description", $this->description); $stmt->bindParam(":updated_at", $this->updated_at); $stmt->bindParam(":id", $this->id); if($stmt->execute()) { return true; } return false; } public function delete() { $query = "DELETE FROM " . $this->table_name . " WHERE id = ?"; $stmt = $this->conn->prepare($query); $stmt->bindParam(1, $this->id); if($stmt->execute()) { return true; } return false; } public function search($search_term) { $query = "SELECT at.*, coa.account_name, coa.account_type, je.entry_number, je.entry_date FROM " . $this->table_name . " at LEFT JOIN chart_of_accounts coa ON at.account_id = coa.id LEFT JOIN journal_entries je ON at.journal_entry_id = je.id WHERE at.description LIKE ? OR coa.account_name LIKE ? OR je.entry_number LIKE ? OR je.entry_date LIKE ? ORDER BY je.entry_date DESC, je.created_at DESC, at.id DESC"; $stmt = $this->conn->prepare($query); $search_term = "%{$search_term}%"; $stmt->bindParam(1, $search_term); $stmt->bindParam(2, $search_term); $stmt->bindParam(3, $search_term); $stmt->bindParam(4, $search_term); $stmt->execute(); return $stmt; } public function getBalance($account_id) { $query = "SELECT SUM(debit_amount) - SUM(credit_amount) as balance FROM " . $this->table_name . " WHERE account_id = ?"; $stmt = $this->conn->prepare($query); $stmt->bindParam(1, $account_id); $stmt->execute(); $row = $stmt->fetch(PDO::FETCH_ASSOC); return $row['balance'] ?? 0; } public function getTransactionType() { if ($this->debit_amount > 0 && $this->credit_amount == 0) { return 'Debit'; } elseif ($this->debit_amount == 0 && $this->credit_amount > 0) { return 'Credit'; } else { return 'Mixed'; } } public function getAmount() { if ($this->debit_amount > 0) { return $this->debit_amount; } else { return $this->credit_amount; } } } ?>