<?
namespace soft;

use core\db\structure\Column as C;
use core\db\structure\eColumnType;
use soft\subscribe\Free;
use soft\subscribe\Group;
use soft\subscribe\Group\soft as GroupSoft;
use soft\Subscribe\structure\ESoftSubscribeStatus;
use soft\user\Payment;
use themes\mybooks\Book\structure\tMybbooksBookLang;
use ui\form\structure\eInputType;
use ui\Form;
use ui\input\Input;
use core\lang\structure\LangVariable as V;
use ms\ms\structure\msModuleTable;
use soft\subscribe\structure\softSubscribeLang as Vars;


class Subscribe extends msModuleTable {
    static $self;
    static $table_name = 'softSubscribe';
    static $controller  = 'soft.subscribe';

    static $easy_left_joins;

    static $ID        = 'id';
    static $SOFT      = 'soft';
    static $PROFILE   = 'profile';
    static $ARCHIVE   = 'archive'; // 0 - активно, 1 - архив, 2 - оплачивается в другой группе
    static $PRICE     = 'price';
    static $GROUP     = 'group';
    static $BEGIN     = 'begin';
    static $END       = 'end';
    static $SUPER     = 'super';
    static $ACCOUNT   = 'account';
    static $CREATED   = 'created';
    static $UPDATED   = 'updated';


    static function getTitle(){return V::get(Vars::$MODULE_NAME);}
    static function getSystemLangValues():array{ return Vars::getArray(); }
    public function _update(\Where $w, array $values) {
        $values[self::$UPDATED] = time();
        return parent::_update($w, $values);
    }
    public function __construct($install_id = null) {
        parent::__construct($install_id);
        self::$easy_left_joins = [
            [Group::$table_name,Group::$ID,self::$GROUP],
        ];
    }

    public static function installUniques() {
        //\DB::addUnique(self::$table_name,self::$table_name.'_unique',[self::$PROFILE,self::$SOFT]);
    }


    static function hasSuperSubscribe($pid = PID){
        if(!IF_PROFILE) return false;
        $pid = intval($pid);
        $r = self::select([
            \Query::WHERE => new \Where(\Where::_and([
                \Where::_operator(self::$ARCHIVE,'=',ESoftSubscribeStatus::ACTIVE),
                \Where::_operator(self::$PROFILE,'=',$pid),
                \Where::_operator(self::$SUPER,'=',1),
            ])),
            \Query::COUNT => 1,
        ]);
        return boolval(\DB::numRows($r));
    }


    static function payForSoft($soft_id,$pid = PID){
        // 1. Проверяем, есть ли бесплатные дни доступа
        // 1.1. Если есть, то начинаем списываем один бесплатный день
        // 1.2. Есть нет, то списываем первый платёж.
        $subscribe = self::getByProfileAndSoft($soft_id,$pid);
        if(!$subscribe) return;

        // Получаем информацию о софте и сколько всего бесплатных дней есть.
        $soft = Soft::getByID($soft_id);
        $free_days = $soft[Soft::$FREE_DAYS];

        // Теперь надо выяснить, сколько дней мы ужи списали
        $subscribe_id = $subscribe[Subscribe::$ID];
        $r = Free::select([
            \Query::SELECT => ['COUNT('.Subscribe::$ID.') as cc'],
            \Query::WHERE => new \Where(\Where::_and([
                \Where::_operator(Free::$SOFT,'=',$soft_id),
                \Where::_operator(Free::$PROFILE,'=',$pid),
            ]))
        ]);
        $l = \DB::fetch($r);
        $used = intval($l['cc']);

        // Если бесплатных дней использовано меньше, чем доступно, то списываем их
        if($used < $free_days) {
            Free::insert([
                Free::$DATE => date('Y-m-d'),
                Free::$SOFT => $soft_id,
                Free::$SUBSCRIBE => $subscribe_id,
                Free::$PROFILE => $pid,
            ]);
        // Иначе списываем деньги с баланса
        } else {
            Payment::add([
                Payment::$PROFILE   => $pid,
                Payment::$VALUE     => -$subscribe[Subscribe::$PRICE],
                Payment::$SUBSCRIBE => $subscribe_id,
                Payment::$SOFT      => $soft_id,
                Payment::$DATE      => date('Y-m-d'),
            ]);
        }
    }


    static function startSoftSubscribe($soft_id,$pid = PID):bool{
        // 1. Надо определить, нет ли уже супер подписки
        // 2. Надо определить, нет ли уже такой подписки
        // 3. Если всё нормально, стартуем подписку
        // 4. Осуществляем первый платёж
        $soft_id = intval($soft_id);
        $pid     = intval($pid);
        if(!$soft_id || !$pid) return false;
        $isSuper = self::hasSuperSubscribe($pid);
        if($isSuper) return false;
        $subscribe = self::getByProfileAndSoft($soft_id,$pid);
        if($subscribe) return false;
        $soft = soft::getByID($soft_id);
        // Если подписки нет, то стартуем подписку
        Subscribe::insert([
            self::$SOFT       => $soft_id,
            self::$PROFILE    => $pid,
            self::$PRICE      => $soft[Soft::$PRICE],
        ]);
        // Теперь производим оплату за первый день
        self::payForSoft($soft_id,$pid);
        return true;
    }


    static function startGroupSoftSubscribe($group_id,$pid=PID):bool{
        // А этой функцией стартуем групповую подписку
        // 1. Сначала надо определить, нет ли супер подписки
        // 2. Если такой нет. То ищем группу и проверяем, активна ли она
        // 3. Если активна, то отменяем все подписки на софт, которые есть в этой группе и уже есть у этого пользователя
        // 4. Создаём новые подписки на софт из группы по стоимости из группы.
        $group_id = intval($group_id);
        $pid      = intval($pid);
        if(!$group_id || !$pid) return false;
        $isSuper = self::hasSuperSubscribe($pid);
        if($isSuper) return false;

        $group = Group::getByID($group_id);
        if(!$group || !$group[Group::$ACTIVE]) return false;

        // Получаем список программ на которые подписываемся
        $a = GroupSoft::select([
            \Query::WHERE => new \Where(\Where::_and([
                \Where::_operator(GroupSoft::$GROUP,'=',$group_id),
            ]))
        ],true);
        $soft_ids = [];
        foreach ($a as $v){
            $soft_ids[] = $v[GroupSoft::$SOFT];
        }
        if(!$soft_ids) return false;

        // Отменяем текущие подписки
        Subscribe::update(new \Where(\Where::_and([
            \Where::_operator(Subscribe::$PROFILE,'=',$pid),
            \Where::_operator(Subscribe::$ARCHIVE,'=',ESoftSubscribeStatus::ACTIVE),
            \Where::_in(Subscribe::$SOFT,$soft_ids),
        ])),[
            Subscribe::$ARCHIVE=>ESoftSubscribeStatus::PAUSE ,
        ]);

        // Создаём новые подписки
        // И берём за них первый платёж
        foreach ($a as $v){
            $price   = $v[GroupSoft::$PRICE];
            $soft_id = $v[GroupSoft::$SOFT];
            $r = Subscribe::insert([
                self::$SOFT       => $soft_id,
                self::$PROFILE    => $pid,
                self::$GROUP      => $group_id,
                self::$PRICE      => $price,
            ]);
            Payment::add([
                Payment::$PROFILE   => $pid,
                Payment::$VALUE     => -$price,
                Payment::$SUBSCRIBE => $r->id,
                Payment::$SOFT      => $soft_id,
                Payment::$DATE      => date('Y-m-d'),
            ]);
        }
        return true;
    }

    static function startSuperSubscribe($group_id,$pid = PID):bool{
        // 1. Находим выбранную подписку
        // 2. Проверяем, активная ли она и является ли супер подпиской.
        // 3. Если да, то отменяем все остальные подписки и начинаем супер подписку.
        // 4. Ну и списываем первый платёж
        $group_id = intval($group_id);
        $pid      = intval($pid);
        $group    = Group::getByID($group_id);
        if($group[Group::$ACTIVE] and $group[Group::$SUPER]){

            // Отменяем текущие подписки
            Subscribe::update(new \Where(\Where::_and([
                \Where::_operator(Subscribe::$PROFILE,'=',$pid),
            ])),[
                Subscribe::$ARCHIVE=>ESoftSubscribeStatus::ARCHIVE,
            ]);

            $price = $group[Group::$TOTAL];

            $r = Subscribe::insert([
                self::$PROFILE    => $pid,
                self::$GROUP      => $group_id,
                self::$PRICE      => $price,
                self::$SUPER      => 1,
            ]);
            $subscribe_id = $r->id;

            $date = date('Y-m-d');
            $a =Payment::select([
                \Query::LEFT_JOINS =>[
                    [Subscribe::$table_name,Subscribe::$ID,Payment::$SUBSCRIBE]
                ],
                \Query::WHERE => new \Where(\Where::_and([
                    \Where::_operator(Payment::$PROFILE,'=',$pid),
                    \Where::_operator(Payment::$SOFT,'=',0),
                    \Where::_operator(Payment::$DATE,'=',$date),
                    \Where::_operator(Subscribe::$GROUP,'=',$group_id),
                ])),
                \Query::COUNT => 1,
            ],true);
            if(!$a) {
                Payment::add([
                    Payment::$PROFILE => $pid,
                    Payment::$VALUE => -$price,
                    Payment::$SUBSCRIBE => $subscribe_id,
                    Payment::$SOFT => 0,
                    Payment::$DATE => $date,
                ]);
            }
            return true;
        }
        return false;
    }


    static function cancelSuperSubscribe($subscribe_id,$pid=PID):bool{
        // 1. Получаем информацию о подписке
        // 2. Проверяем, принадлежит ли пользователю и активна ли она и является ли она супер подпиской
        // 3. Если всё норм, то отменяем
        $subscribe_id = intval($subscribe_id);
        $pid          = intval($pid);
        $subscribe    = Subscribe::getByID($subscribe_id);
        if($subscribe[Subscribe::$PROFILE]==$pid and $subscribe[Subscribe::$SUPER] and $subscribe[Subscribe::$ARCHIVE]==ESoftSubscribeStatus::ACTIVE){
            Subscribe::updateById($subscribe_id,[
               Subscribe::$ARCHIVE => ESoftSubscribeStatus::ARCHIVE,
            ]);
            return true;
        }
        return false;
    }

    static function cancelSoftSubscribe($subscribe_id,$pid=PID):bool{
        // 1. Получаем информацию о подписке
        // 2. Проверяем, принадлежит ли пользователю и активна ли она и не является ли она групповой
        // 3. Если всё норм, то отменяем
        $subscribe_id = intval($subscribe_id);
        $pid          = intval($pid);
        $subscribe    = Subscribe::getByID($subscribe_id);
        if($subscribe[Subscribe::$PROFILE]==$pid and !$subscribe[Subscribe::$GROUP]) {//} and $subscribe[Subscribe::$ARCHIVE]==ESoftSubscribeStatus::ACTIVE){
            Subscribe::updateById($subscribe_id,[
                Subscribe::$ARCHIVE => ESoftSubscribeStatus::ARCHIVE,
            ]);
            return true;
        }
        return false;
    }

    static function cancelGroupSubscribe($group_id,$pid=PID):bool{
        // 1. Сначала получаем информацию о группе
        // 2. Затем получаем список подписок пользователя в этой группе
        // 3. Надо запомнить программы в этих подписках
        // 4. Затем эти подписки отменить
        // 5. Проверить все остальные активные групповые подписки пользователя
        // 6. И если там есть такая программа, с отменённой подпиской, то включить её
        // 7. Но только по одной подписка на программу

        $group_id = intval($group_id);
        $pid      = intval($pid);
        $group    = Group::getByID($group_id);

        /*
        $group_soft = GroupSoft::getByGroup($group_id);
        $soft_ids   = [];
        foreach ($group_soft as $v){
            $soft_ids[] = $v[GroupSoft::$SOFT];
        }
        //*/

        $soft_ids = [];
        $r = Subscribe::select([
            \Query::SELECT => [Subscribe::$SOFT],
            \Query::WHERE => new \Where(\Where::_and([
                \Where::_operator(Subscribe::$GROUP,'=',$group_id),
                \Where::_operator(Subscribe::$ARCHIVE,'=',ESoftSubscribeStatus::ACTIVE),
                \Where::_operator(Subscribe::$PROFILE,'=',$pid),
            ]))
        ]);
        while($l = \DB::fetch($r)){
            $soft_ids[] = $l[Subscribe::$SOFT];
        }

        // Список программ получен, теперь отменяем подписки в этой группе у этого пользователя
        Subscribe::update(new \Where(\Where::_and([
           \Where::_operator(Subscribe::$GROUP,'=',$group_id),
           \Where::_operator(Subscribe::$PROFILE,'=',$pid),
        ])),[
            Subscribe::$ARCHIVE=>ESoftSubscribeStatus::ARCHIVE,
        ]);

        if($soft_ids) {
            $r = Subscribe::select([
                \Query::WHERE => new \Where(\Where::_and([
                    \Where::_operator(Subscribe::$PROFILE, '=', $pid),
                    \Where::_operator(Subscribe::$ARCHIVE, '=', ESoftSubscribeStatus::PAUSE),
                    \Where::_operator(Subscribe::$GROUP, '<>', $group_id),
                    \Where::_in(Subscribe::$SOFT, $soft_ids),
                ])),
                //\Query::GROUP_BY => Subscribe::$GROUP,
                \Query::SORT => [Subscribe::$PRICE=>'ASC'],
                //\Query::COUNT => 1,
            ]);
            $groups = [];
            $subscribe_ids = [];
            while ($l = \DB::fetch($r)) {
                $soft_id = $l[Subscribe::$SOFT];
                $subscribe_id = $l[Subscribe::$ID];
                if (!$subscribe_ids[$soft_id]) {
                    $subscribe_ids[$soft_id] = $subscribe_id;
                }
            }
            foreach ($subscribe_ids as $subscribe_id){
                Subscribe::updateById($subscribe_id,[
                    Subscribe::$ARCHIVE => ESoftSubscribeStatus::ACTIVE,
                ]);
            }
        }
        return true;
    }


    static public function format($v){
        return [
            'id'           => intval($v[self::$ID]),
            'soft'         => intval($v[self::$SOFT]),
            'group_id'     => intval($v[self::$GROUP]),
            'archive'      => boolval($v[self::$ARCHIVE]),
            'group'        => boolval($v[self::$GROUP]),
            'super'        => boolval($v[self::$SUPER]),
            'price'        => cfloatval($v[self::$PRICE]),
            'status'       => intval($v[self::$ARCHIVE]),
            'status_name'  => ESoftSubscribeStatus::getName($v[self::$ARCHIVE]),
        ];
    }

    static public function getActiveByProfileFormatted($profile_id = PID){
        $res = [];
        $a = self::getActiveByProfile($profile_id);
        foreach ($a as $v){
            $res[$v[self::$SOFT]] = self::format($v);
        }
        return $res;
    }

    static public function getByProfileAndSoft($soft_id,$profile_id = PID){
        $res = null;
        $soft_id = intval($soft_id);
        $profile_id = intval($profile_id);
        if($profile_id and $soft_id) {
            $r = self::select([
                \Query::WHERE => new \Where(\Where::_and([
                    \Where::_operator(self::$PROFILE,'=',$profile_id),
                    \Where::_operator(self::$SOFT,'=',$soft_id),
                    \Where::_operator(self::$ARCHIVE,'=',ESoftSubscribeStatus::ACTIVE),
                ])),
                \Query::COUNT => 1,
            ]);
            if(\DB::numRows($r)){
                $res = \DB::fetch($r);
            }
        }
        return $res;
    }

    static public function getFormattedByProfileAndSoft($soft_id,$profile_id = PID){
        $res = self::getByProfileAndSoft($soft_id,$profile_id);
        return self::format($res);
    }

    static public function getActiveByProfile($profile_id = PID,$isAssoc = true){
        $res = null;
        $profile_id = intval($profile_id);
        if($profile_id) {
            $res = self::select([
                \Query::WHERE => new \Where(\Where::_and([
                    \Where::_operator(self::$PROFILE, '=', $profile_id),
                    \Where::_operator(self::$ARCHIVE, '=', ESoftSubscribeStatus::ACTIVE),
                ]))
            ], $isAssoc);
        }
        return $res;
    }
    static public function getForListByProfile($profile_id = PID,$isAssoc = true){
        $res = null;
        $profile_id = intval($profile_id);
        if($profile_id) {
            $res = self::select([
                \Query::WHERE => new \Where(\Where::_and([
                    \Where::_operator(self::$PROFILE, '=', $profile_id),
                    \Where::_in(self::$ARCHIVE, [ ESoftSubscribeStatus::ACTIVE, ESoftSubscribeStatus::PAUSE]),
                ]))
            ], $isAssoc);
        }
        return $res;
    }

    static function columnInfo() : array {
        return [
            new C([
                C::VAR_NAME         =>&self::$ID,
                C::TYPE             =>eColumnType::INT,
                C::AUTO_INCREMENT   =>true,
                C::PRIMARY          =>true,
                C::DEFAULT          =>0,
                C::HIDDEN           =>true,
                C::TH               =>V::get(Vars::$ID),
            ]),
            new C([
                C::VAR_NAME         => &self::$SOFT,
                C::TYPE             => eColumnType::INT,
            ]),
            new C([
                C::VAR_NAME         => &self::$PROFILE,
                C::TYPE             => eColumnType::INT,
            ]),
            new C([
                C::VAR_NAME         => &self::$PRICE,
                C::TYPE             => eColumnType::DOUBLE,
                C::LENGTH           => '10,2'
            ]),
            new C([
                C::VAR_NAME         => &self::$GROUP,
                C::TYPE             => eColumnType::INT,
            ]),
            new C([
                C::VAR_NAME         => &self::$ARCHIVE,
                C::TYPE             => eColumnType::INT,
                C::DEFAULT          => 0,
            ]),
            new C([
                C::VAR_NAME         => &self::$SUPER,
                C::TYPE             => eColumnType::INT,
                C::DEFAULT          => 0,
            ]),
            new C([
                C::VAR_NAME         => &self::$BEGIN,
                C::TYPE             => eColumnType::DATE,
                C::DEFAULT          => date('Y-m-d'),
            ]),
            new C([
                C::VAR_NAME         => &self::$END,
                C::TYPE             => eColumnType::DATE,
                C::DEFAULT          => '0000-00-00',
            ]),


            new C([
                C::VAR_NAME         => &self::$ACCOUNT,
                C::TYPE             => eColumnType::INT,
                C::LENGTH           => 11,
                C::TH               => V::get(Vars::$ACCOUNT),
                C::DEFAULT          => intval(\Site::$owner_id),
                c::HIDDEN=>true,
                c::FUNC_VALUE       => function($v){
                    if($id = $v[self::$ACCOUNT]) {
                        return \Account::getName(  \Account::getByID($id) );
                    } else return '-';
                },
            ]),
            new C([
                C::VAR_NAME         => &self::$CREATED,
                C::TYPE             => eColumnType::INT,
                C::LENGTH           => 11,
                C::TH               => V::get(Vars::$CREATED),
                C::DEFAULT          => time(),
                c::FUNC_VALUE       => function($v){return self::formatDate($v[self::$CREATED]);},
                c::HIDDEN=>true,
            ]),
            new C([
                C::VAR_NAME         => &self::$UPDATED,
                C::TYPE             => eColumnType::INT,
                C::DEFAULT          => time(),
                C::TH               => V::get(Vars::$UPDATED),
                c::FUNC_VALUE       => function($v){return self::formatDate($v[self::$UPDATED]);},
                c::HIDDEN=>true,
            ]),
        ];
    }

}
new Subscribe();