<?php

namespace dokuwiki\plugin\bez\mdl;

use dokuwiki\plugin\bez\meta\ConsistencyViolationException;

class Thread_commentFactory extends Factory {

    public function get_table_view() {
        return 'thread_comment_view';
    }

    public function get_from_thread(Thread $thread, $filters=array(), $orderby='', $limit=false) {
        $filters['thread_id'] = $thread->id;
        return $this->get_all($filters, $orderby, array('thread' => $thread), $limit);
    }

    /**
     * @param Thread_comment $thread_comment
     * @param                $data
     * @throws \Exception
     */
    public function initial_save(Entity $thread_comment, $data) {
        try {
            $this->beginTransaction();

            if ($data['fn'] == 'comment_add' ||
                $data['fn'] == 'thread_close' ||
                $data['fn'] == 'thread_reject' ||
                $data['content'] != '') {
                parent::initial_save($thread_comment, $data);
                $thread_comment->thread->set_participant_flags($thread_comment->author, array('subscribent', 'commentator'));
                $notify = 'comment_added';
            }

            if ($data['fn'] == 'thread_close') {
                $thread_comment->thread->set_state('closed');
                $notify = 'mail_thread_closed';
            } elseif ($data['fn'] == 'thread_reject') {
                $thread_comment->thread->set_state('rejected');
                $notify = 'mail_thread_rejected';
            } elseif ($data['fn'] == 'thread_reopen') {
                $thread_comment->thread->set_state('opened');
                $notify = 'mail_thread_reopened';
            }

            $thread_comment->thread->update_last_activity();

            $this->commitTransaction();

            if ($notify == 'comment_added') {
                $thread_comment->mail_notify_add();
            } elseif (isset($notify)) {
                $thread_comment->thread->mail_notify_change_state($notify);
            }

        } catch(Exception $exception) {
            $this->rollbackTransaction();
        }
    }

    public function update_save(Entity $thread_comment, $data) {
        try {
            $this->beginTransaction();

            $prev_type = $thread_comment->type;

            parent::update_save($thread_comment, $data);

            //update task types
            if ($thread_comment->type != 'comment' && $thread_comment->type != $prev_type) {
                if ($thread_comment->type == 'cause') {
                    $task_type = 'corrective';
                } else {
                    $task_type = 'preventive';
                }
                $this->model->sqlite->query('UPDATE task SET type=? WHERE thread_comment_id=?',
                                            $task_type, $thread_comment->id);

            }

            $thread_comment->thread->update_last_activity();

            $this->commitTransaction();
        } catch(Exception $exception) {
            $this->rollbackTransaction();
        }
    }

    public function delete(Entity $obj) {

        if ($obj->task_count > 0) {
            throw new ConsistencyViolationException('cannot delete when task are assigned');
        }

        try {
            $this->beginTransaction();

            parent::delete($obj);
            $obj->thread->update_last_activity();
            //remove commentator flag
            if ($this->count(array('thread_id' => $obj->thread_id, 'author' => $obj->author)) == 0) {
                $obj->thread->remove_participant_flags($obj->author, array('commentator'));
            }

            $this->commitTransaction();
        } catch(Exception $exception) {
            $this->rollbackTransaction();
        }
    }

    public function report(\DatePeriod $period=NULL) {
        if ($period) {
            $from = $period->getStartDate()->format(\DateTime::ISO8601);
            $to = $period->getEndDate()->format(\DateTime::ISO8601);

            $sql = "SELECT type, COUNT(type) AS 'cnt'
                        FROM thread_comment
                        WHERE type != 'comment'
                            AND create_date BETWEEN ? AND ?
                        GROUP BY type";
            $r = $this->model->sqlite->query($sql, $from, $to);
        } else {
            $sql = "SELECT type, COUNT(type) AS 'cnt'
                        FROM thread_comment
                        WHERE type != 'comment'
                        GROUP BY type";
            $r = $this->model->sqlite->query($sql);
        }

        $counted = [
            'cause' => 0,
            'risk' => 0,
            'opportunity' => 0,
            'all' => 0
        ];

        $result = $r->fetchAll();
        foreach ($result as $row) {
            $cnt = (int) $row['cnt'];
            $counted[$row['type']] += $cnt;
            $counted['all'] += $cnt;
        }

        return $counted;
    }
}