<?php

namespace Api\Models;

use Api\Core\Model;

class Assessment extends Model {
    protected $table = 'assessments';

    public function getBySchool($school_id) {
        $stmt = $this->db->prepare("SELECT * FROM assessments WHERE school_id = :school_id");
        $stmt->execute(['school_id' => $school_id]);
        return $stmt->fetchAll();
    }

    public function saveMarks($assessment_id, $marks) {
        $this->db->beginTransaction();
        try {
            $stmt = $this->db->prepare("INSERT INTO marks (assessment_id, learner_id, score) VALUES (:assessment_id, :learner_id, :score) ON DUPLICATE KEY UPDATE score = VALUES(score)");
            foreach ($marks as $mark) {
                $stmt->execute([
                    'assessment_id' => $assessment_id,
                    'learner_id' => $mark['learner_id'],
                    'score' => $mark['score']
                ]);
            }
            $this->db->commit();
            return true;
        } catch (\Exception $e) {
            $this->db->rollBack();
            return false;
        }
    }
}