<?php 

class JobDiffNotificationMapper extends Mapper
{
    const JOB_DIFF_TYPE_ADD = 1;
    const JOB_DIFF_TYPE_UPDATE = 2;
    const TBL = 'job_diff_notification';
    public function save($job_id, $job_diff_type, $content = '') {
        $sql = "insert into ".self::TBL."
            (job_id, content, job_diff_type, created_date) values
            (:job_id, :content, :job_diff_type, :created_date);";

        $stmt = $this->db->prepare($sql);
        if (self::JOB_DIFF_TYPE_ADD == $job_diff_type) {
            $result = $stmt->execute([
                "job_id" => $job_id,
                "created_date" => date("Y-m-d H:i:s"),
                "job_diff_type" => self::JOB_DIFF_TYPE_ADD,
                "content" => "新增",
            ]);
        } elseif (self::JOB_DIFF_TYPE_UPDATE == $job_diff_type) {
            $result = $stmt->execute([
                "job_id" => $job_id,
                "created_date" => date("Y-m-d H:i:s"),
                "job_diff_type" => self::JOB_DIFF_TYPE_UPDATE,
                "content" => $content,
            ]);
        }
    }

    public function getLastModifyDateTime($job_id){
        $sql = 'SELECT * FROM '.self::TBL.' WHERE job_id='.($job_id+0).' AND job_diff_type='.self::JOB_DIFF_TYPE_UPDATE.' ORDER BY `id` DESC LIMIT 1';
        $ret = $this->_getOne($sql); #false
        return $ret===false||!$ret ? null : $ret['created_date'];
    }

    public function findAllByJobId($job_id, $ASC_or_DESC='ASC'){
        $sql = 'SELECT * FROM '
                .self::TBL.' WHERE job_id='
                .($job_id+0).' ORDER BY `id` '.$ASC_or_DESC;
        return $this->_findAll($sql);
    }

}