<?php

require_once('Mgc.php');

class Subscribes extends Mgc {

    /*Выборка всех подписчиков*/
    public function get_subscribes($filter = array()) {
        $limit = 100;
        $page = 1;
        $keyword_filter = '';
        if(isset($filter['limit'])) {
            $limit = max(1, intval($filter['limit']));
        }
        if(isset($filter['page'])) {
            $page = max(1, intval($filter['page']));
        }
        $sql_limit = $this->db->placehold(' LIMIT ?, ? ', ($page-1)*$limit, $limit);
        if (isset($filter['keyword'])) {
            $keyword_filter = 'and s.email like "%'.$this->db->escape(trim($filter['keyword'])).'%"';
        }
        
        $query = $this->db->placehold("SELECT 
                s.id, 
                s.email
            FROM __subscribe_mailing s 
            WHERE 
                1 
                $keyword_filter 
            $sql_limit
        ");
        $this->db->query($query);
        return $this->db->results();
    }

    /*Подсчет количества подписчиков*/
    public function count_subscribes($filter = array()) {
        $keyword_filter = '';
        if (isset($filter['keyword'])) {
            $keyword_filter = 'and s.email like "%'.$this->db->escape(trim($filter['keyword'])).'%"';
        }
        $query = "SELECT count(distinct s.id) as count
            FROM __subscribe_mailing AS s
            WHERE 
                1
                $keyword_filter
        ";
        
        $this->db->query($query);
        return $this->db->result('count');
    }

    /*Выборка конкретного подписчика*/
    public function get_subscribe($id) {
        $filter = $this->db->placehold('AND id = ?', $id);
        $query = "SELECT 
                id, 
                email
            FROM __subscribe_mailing 
            WHERE 
                1 
                $filter 
            LIMIT 1";
        $this->db->query($query);
        return $this->db->result();
    }

    /*Добавление подписчика*/
    public function add_subscribe($subscribe) {
        $subscribe = (array)$subscribe;
        $this->db->query("INSERT INTO __subscribe_mailing SET ?%", $subscribe);
        return $this->db->insert_id();
    }

    /*Обновления подписчика*/
    public function update_subscribe($id, $subscribe) {
        $query = $this->db->placehold("UPDATE __subscribe_mailing SET ?% WHERE id=? LIMIT 1", $subscribe, intval($id));
        $this->db->query($query);
        return $id;
    }

    /*Удаление подписчка*/
    public function delete_subscribe($ids) {
        if(!empty($ids)) {
        	$this->db->query('delete from __subscribe_mailing where id in(?@)', $ids);
        }
    }
    
}