<?php

class modelSubscriptions extends cmsModel {

    public function verifySubscription($confirm_token) {

        return $this->filterEqual('confirm_token', $confirm_token)->
            updateFiltered('subscriptions_bind', [
                'is_confirmed' => 1
            ]);
    }

    public function getSubscriptionByToken($confirm_token) {
        return $this->filterEqual('confirm_token', $confirm_token)->getItem('subscriptions_bind');
    }

    public function deleteUserSubscriptions($user_id) {

        return $this->filterEqual('user_id', $user_id)->deleteFiltered('subscriptions_bind');
    }

    public function getSubscriptionItem($hash_or_id) {

        if (is_numeric($hash_or_id)) {
            $this->filterEqual('id', $hash_or_id);
        } else {
            $this->filterEqual('hash', $hash_or_id);
        }

        return $this->getItem('subscriptions', function ($item, $model) {

            $item['params'] = cmsModel::stringToArray($item['params']);

            return $item;
        });
    }

    public function isSubscribed($target, $subscribe) {

        if (empty($target['hash'])) {
            $target['hash'] = md5(serialize($target));
        }

        $list_item_id = $this->filterEqual('hash', $target['hash'])->getFieldFiltered('subscriptions', 'id');

        if (!$list_item_id) {
            return false;
        }

        if (!empty($subscribe['user_id'])) {
            return $this->isUserSubscribed($subscribe['user_id'], $list_item_id);
        }

        return $this->isGuestSubscribed($subscribe['guest_email'], $list_item_id);
    }

    public function isUserSubscribed($user_id, $list_item_id) {

        $this->filterEqual('user_id', $user_id);
        $this->filterEqual('subscription_id', $list_item_id);

        return $this->getFieldFiltered('subscriptions_bind', 'id');
    }

    public function isGuestSubscribed($subscriber_email, $list_item_id) {

        $this->filterEqual('guest_email', $subscriber_email);
        $this->filterEqual('subscription_id', $list_item_id);

        return $this->getFieldFiltered('subscriptions_bind', 'id');
    }

    public function subscribe($target, $subscribe) {

        $is_now_create_list = false;

        if (empty($target['hash'])) {
            $target['hash'] = md5(serialize($target));
        }

        // проверяем, нет ли такого списка
        $subscribe['subscription_id'] = $this->filterEqual('hash', $target['hash'])->getFieldFiltered('subscriptions', 'id');

        // создаём список
        if (!$subscribe['subscription_id']) {

            $subscribe['subscription_id'] = $this->insert('subscriptions', $target, true);

            $is_now_create_list = $subscribe['subscription_id'];
        }

        $sid = $this->insert('subscriptions_bind', $subscribe);

        $this->reCountSubscribers($subscribe['subscription_id']);

        return [$is_now_create_list, $sid];
    }

    public function unsubscribe($target, $subscribe) {

        if (empty($target['hash'])) {
            $target['hash'] = md5(serialize($target));
        }

        $list_item_id = $this->filterEqual('hash', $target['hash'])->getFieldFiltered('subscriptions', 'id');

        if (!$list_item_id) {
            return false;
        }

        if (!empty($subscribe['user_id'])) {

            $this->filterEqual('user_id', $subscribe['user_id']);
            $this->filterEqual('subscription_id', $list_item_id);

            $this->deleteFiltered('subscriptions_bind', 'id');

        } else {

            $this->filterEqual('guest_email', $subscribe['guest_email']);
            $this->filterEqual('subscription_id', $list_item_id);

            $this->deleteFiltered('subscriptions_bind', 'id');
        }

        $this->reCountSubscribers($list_item_id);

        return true;
    }

    public function reCountSubscribers($subscription_id) {

        $this->db->query("UPDATE {#}subscriptions SET subscribers_count=(SELECT COUNT(id) FROM {#}subscriptions_bind WHERE subscription_id = '{$subscription_id}' AND is_confirmed = 1) WHERE id = '{$subscription_id}'");

        return $this;
    }

    public function getSubscriptions() {

        $this->joinUser()->joinSessionsOnline();

        $this->selectList([
            's.title'             => 'title',
            's.controller'        => 'controller',
            's.subject'           => 'subject',
            's.subject_url'       => 'subject_url',
            's.params'            => 'params',
            's.subscribers_count' => 'subscribers_count',
            's.hash'              => 'hash'
        ]);

        $this->join('subscriptions', 's', 's.id = i.subscription_id');

        return $this->get('subscriptions_bind', function ($item, $model) {

            $item['user'] = [
                'id'         => $item['user_id'],
                'nickname'   => $item['user_nickname'],
                'is_online'  => $item['is_online'],
                'is_deleted' => $item['user_is_deleted'],
                'avatar'     => $item['user_avatar']
            ];

            $item['params'] = cmsModel::stringToArray($item['params']);

            $item['target'] = [
                'controller' => $item['controller'],
                'subject'    => $item['subject'],
                'params'     => $item['params']
            ];

            return $item;
        }, false);
    }

    public function deleteSubscriptionsList($id) {

        $this->filterEqual('subscription_id', $id)->lockFilters();

        $subscriptions = $this->get('subscriptions_bind');

        $this->unlockFilters()->deleteFiltered('subscriptions_bind');

        $this->filterEqual('id', $id)->deleteFiltered('subscriptions');

        return $subscriptions;
    }

    public function getSubscriptionsList() {

        return $this->get('subscriptions', function ($item, $model) {

            $item['params'] = cmsModel::stringToArray($item['params']);

            $item['target'] = [
                'controller' => $item['controller'],
                'subject'    => $item['subject'],
                'params'     => $item['params']
            ];

            return $item;
        });
    }

    public function getNotifiedUsers($subscription_id) {

        $this->limit(false);

        $this->selectList([
            'i.id'             => 'id',
            'i.email'          => 'email',
            'i.nickname'       => 'nickname',
            'i.notify_options' => 'notify_options',
            'sb.confirm_token' => 'confirm_token',
            'sb.guest_email'   => 'guest_email',
            'sb.guest_name'    => 'guest_name'
        ], true);

        $this->filterIsNull('is_locked');
        $this->filterIsNull('is_deleted');

        $this->joinRight('subscriptions_bind', 'sb', 'sb.user_id = i.id')->
                filterEqual('sb.subscription_id', $subscription_id)->
                filterEqual('sb.is_confirmed', 1);

        return $this->get('{users}', function ($user, $model) {

            // гость
            if (!$user['id']) {
                $user['email']    = $user['guest_email'];
                $user['nickname'] = $user['guest_name'];
            }

            $user['notify_options'] = cmsModel::yamlToArray($user['notify_options']);

            // умолчания
            if (!isset($user['notify_options']['subscriptions'])) {
                $user['notify_options']['subscriptions'] = $user['id'] ? 'both' : 'email';
            }

            // отключены уведомления
            if (empty($user['notify_options']['subscriptions'])) {
                return false;
            }

            return $user;
        }, false);
    }

}