<?php
// +----------------------------------------------------------------------
// | 天诚科技 [ 刘海东 17600099397赋能开发者，助力企业发展 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2016~2020 https://www.tczxkj.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed 该系统并不是自由软件，未经许可不能去掉相关版权
// +----------------------------------------------------------------------
// | Author:甘肃天诚志信电子商务有限公司 刘海东 联系电话维系17600099397
// +----------------------------------------------------------------------

namespace app\web\model\special;

use app\web\model\special\SpecialSource;
use app\web\model\special\StoreOrder;
use app\web\model\user\User;
use basic\ModelBasic;
use service\SystemConfigService;
use think\Url;
use traits\ModelTrait;
use think\Db;
use app\web\model\live\LiveStudio;
use app\web\model\live\LivePlayback;
use app\web\model\special\LearningRecords;
use app\web\model\special\SpecialSubject;
use app\web\model\special\SpecialReply;
use app\web\model\material\DataDownload;

/**专题表
 * Class Special
 * @package app\web\model\special
 */
class Special extends ModelBasic
{
    use ModelTrait;

    /**获取专题详情内容
     * @return \think\model\relation\HasOne
     */
    public function profile()
    {
        return $this->hasOne('SpecialContent', 'special_id', 'id')->field('content');
    }

    /**获取轻专题链接或视频点播ID
     * @return \think\model\relation\HasOne
     */
    public function singleProfile()
    {
        return $this->hasOne('SpecialContent', 'special_id', 'id')->field('is_try,try_time,try_content,link,videoId,content');
    }

    public static function getAddTimeAttr($value)
    {
        return date('Y-m-d H:i:s', $value);
    }

    public static function getBannerAttr($value)
    {
        return is_string($value) ? json_decode($value, true) : $value;
    }

    public static function getLabelAttr($value)
    {
        return is_string($value) ? json_decode($value, true) : $value;
    }

    /**
     * 设置专题显示条件
     * @param string $alias 别名
     * @param null $model model
     * @param bool $isAL 是否起别名,默认执行
     * @return $this
     */
    public static function PreWhere($alias = '', $model = null, $isAL = false)
    {
        if (is_null($model)) $model = new self();
        if ($alias) {
            $isAL || $model = $model->alias($alias);
            $alias .= '.';
        }
        return $model->where(["{$alias}is_del" => 0, "{$alias}is_show" => 1, "{$alias}status" => 1]);
    }

    /**
     * 获取单个专题的详细信息
     * @param $uid 用户id
     * @param $id 专题id
     * @param $pinkId 拼团id
     * */
    public static function getOneSpecial($uid, $id)
    {
        $special = self::PreWhere()->where('is_light', 0)->find($id);
        if (!$special) return self::setErrorInfo('您要查看的专题不存在!');
        if ($special->is_show == 0) return self::setErrorInfo('您要查看的专题已下架!');
        $title = $special->title;
        if ($uid) {
            $special->collect = self::getDb('special_relation')->where(['link_id' => $id, 'type' => 0, 'uid' => $uid, 'category' => 1])->count() ? true : false;
        } else {
            $special->collect = false;
        }
        $special->content = htmlspecialchars_decode($special->profile->content);
        $special->profile->content = '';
        return compact('special', 'title');
    }

    /**获取单个轻专题
     * @param $uid
     * @param $id
     * @return array|bool
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public static function getSingleOneSpecial($uid, $id)
    {
        $special = self::PreWhere()->where('is_light', 1)->find($id);
        if (!$special) return self::setErrorInfo('您要查看的专题不存在!');
        if ($special->is_show == 0) return self::setErrorInfo('您要查看的专题已下架!');
        $title = $special->title;
        $special->abstract = htmlspecialchars_decode($special->abstract);
        $special->singleProfile = $special->singleProfile;
        unset($special['singleProfile']['link'], $special['singleProfile']['videoId'], $special['singleProfile']['content']);
        if ($uid) {
            $special->collect = self::getDb('special_relation')->where(['link_id' => $id, 'type' => 0, 'uid' => $uid, 'category' => 1])->count() ? true : false;
        } else {
            $special->collect = false;
        }
        return compact('special', 'title');
    }

    /**获取轻专题内容
     * @param $id
     * @return array|bool
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public static function getSingleSpecialContent($id)
    {
        $special = self::PreWhere()->where('is_light', 1)->find($id);
        if (!$special) return self::setErrorInfo('您要查看的专题不存在!');
        if ($special->is_show == 0) return self::setErrorInfo('您要查看的专题已下架!');
        $special->singleProfile = $special->singleProfile;
        $special->content = htmlspecialchars_decode($special->singleProfile->content);
        return $special;
    }

    public static function set_my_collection_where($uid, $model, $type)
    {
        return self::PreWhere('a', $model)->join('__SPECIAL_RELATION__ s', 'a.id=s.link_id')->where(['s.type' => $type, 's.uid' => $uid]);
    }

    /**
     * 我的收藏
     * @param int $type 1=收藏,0=我的购买
     * @param int $page 页码
     * @param int $limit 每页显示条数
     * @param int $uid 用户uid
     * @return array
     * */
    public static function getGradeList($page, $limit, $uid, $is_member, $active = 0)
    {
        if ($active) {
            $model = self::set_my_collection_where($uid, new DataDownload, 1);
            $list = $model->order('a.sort desc')->field('a.*')->page($page, $limit)->select();
            $count = self::set_my_collection_where($uid, new DataDownload, 1)->count();
        } else {
            $model = self::set_my_collection_where($uid, new self, 0);
            if (!$is_member) $model = $model->where(['a.is_mer_visible' => 0]);
            $list = $model->order('a.sort desc')->field('a.*')->page($page, $limit)->select();
            $modelCount = self::set_my_collection_where($uid, new self, 0);
            if (!$is_member) $modelCount = $modelCount->where(['a.is_mer_visible' => 0]);
            $count = $modelCount->count();
        }
        foreach ($list as &$item) {
            if (!$active) {
                $item['image'] = get_oss_process($item['image'], 4);
                if (is_string($item['label'])) $item['label'] = json_decode($item['label'], true);
                $item['s_id'] = $item['id'];
                $item['count'] = self::numberChapters($item['type'], $item['s_id']);
                if ($item['is_light']) {
                    $item['type'] = self::lightType($item['light_type']);
                }
            }
        }
        return compact('list', 'count');
    }

    public static function set_my_where($uid)
    {
        return self::PreWhere('s')->join('SpecialBuy b', 's.id=b.special_id')->group('b.special_id')->where(['b.is_del' => 0, 'b.uid' => $uid]);
    }

    /**我的课程
     * @param $page
     * @param $limit
     * @param $uid
     * @param $is_member
     * @return array
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public static function getMySpecialList($page, $limit, $uid)
    {
        $model = self::set_my_where($uid)->order('b.add_time desc');
        $list = $model->field('s.*,b.add_time,b.special_id,b.uid,b.is_del')->page($page, $limit)->select();
        $list = count($list) > 0 ? $list->toArray() : [];
        foreach ($list as &$item) {
            $item['image'] = get_oss_process($item['image'], 4);
            if (is_string($item['label'])) $item['label'] = json_decode($item['label'], true);
            $item['s_id'] = $item['id'];
            $item['count'] = self::numberChapters($item['type'], $item['s_id']);
            if ($item['is_light']) {
                $item['type'] = self::lightType($item['light_type']);
            }
        }
        $count = self::set_my_where($uid)->count();
        return compact('list', 'count');
    }

    /**
     * 获取某个专题的详细信息
     * @param int $id 专题id
     * @return array
     * */
    public static function getSpecialInfo($id)
    {
        $special = self::PreWhere()->find($id);
        if (!$special) return self::setErrorInfo('没有找到此专题');
        $special->abstract = self::HtmlToMbStr($special->abstract);
        return $special->toArray();
    }

    /**
     * 设置查询条件
     * @param $where
     * @return $this
     */
    public static function setWhere($where, $is_member, $alias = '')
    {
        $model = self::PreWhere($alias);
        if ($alias) {
            $alias .= '.';
        }
        if (isset($where['subject_id']) && $where['subject_id']) {
            $model = $model->where("{$alias}subject_id", $where['subject_id']);
        } else if (isset($where['subject_id']) && $where['subject_id'] == 0 && isset($where['cate_id']) && $where['cate_id']) {
            $subject_ids = SpecialSubject::subjectId($where['cate_id']);
            $model = $model->where("{$alias}subject_id", 'in', $subject_ids);
        }
        if (isset($where['search']) && $where['search'] != '') {
            $model = $model->where("{$alias}title", 'LIKE', "%$where[search]%");
        }
        if (isset($where['type']) && $where['type'] != '') {
            $type = explode(',', $where['type']);
            $model = $model->where("{$alias}type", 'in', $type);
        }
        if (isset($where['is_pay']) && $where['is_pay'] != '') {
            $model = $model->where("{$alias}pay_type", $where['is_pay']);
        }
        if (!$is_member) $model = $model->where(["{$alias}is_mer_visible" => 0]);
        $baseOrder = '';
        if (isset($where['salesOrder']) && $where['salesOrder']) {
            $baseOrder = $where['salesOrder'] == 'desc' ? "{$alias}sales DESC" : "{$alias}sales ASC";//销量
        }
        if (isset($where['scoreOrder']) && $where['scoreOrder']) {
            $baseOrder = $where['scoreOrder'] == 'desc' ? "{$alias}score DESC" : "{$alias}score ASC";//评价
        }
        if ($baseOrder) $baseOrder .= ',';
        $model = $model->order($baseOrder . "{$alias}sort DESC," . "{$alias}add_time DESC");
        return $model;
    }

    /**
     * 获取专题列表
     * @param $where
     * @return mixed
     */
    public static function get_special_list($where, $is_member)
    {
        $field = ['browse_count', 'image', 'title', 'type', 'sort', 'IFNULL(browse_count,0) + IFNULL(fake_sales,0) as sales', 'is_light', 'light_type', 'is_mer_visible', 'money', 'member_money', 'subject_id', 'pay_type', 'label', 'id', 'fake_sales', 'add_time'];
        $model = self::setWhere($where, $is_member)->field($field);
        $data = $model->page($where['page'], $where['limit'])->select();
        $data = count($data) ? $data->toArray() : [];
        foreach ($data as &$item) {
            $item['count'] = self::numberChapters($item['type'], $item['id']);
            $count = self::learning_records($item['id']);
            $item['browse_count'] = processingData(bcadd($count, $item['fake_sales'], 0));
            if ($item['is_light']) {
                $item['type'] = self::lightType($item['light_type']);
            }
        }
        $count = $model = self::setWhere($where, $is_member)->count();
        return compact('data', 'count');
    }

    /**获得专题真实学习人数
     * @param int $special_id
     * @return int
     */
    public static function learning_records($special_id = 0)
    {
        $uids = LearningRecords::where(['special_id' => $special_id])->column('uid');
        $uids = array_unique($uids);
        return count($uids);
    }

    /**讲师名下课程
     * @return array
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public static function getLecturerSpecialList($mer_id = 0, $page = 1, $limit = 10)
    {
        if ($mer_id) {
            $field = ['browse_count', 'image', 'title', 'type', 'money', 'pink_money', 'is_light', 'light_type', 'is_mer_visible', 'member_money', 'is_pink', 'subject_id', 'pay_type', 'label', 'id', 'is_show', 'is_del', 'lecturer_id', 'mer_id'];
            $model = self::PreWhere();
            $model = $model->where(['mer_id' => $mer_id])->order('sort desc,id desc');
            $data = $model->field($field)->page($page, $limit)->select();
            $data = count($data) ? $data->toArray() : [];
            foreach ($data as &$item) {
                $item['count'] = self::numberChapters($item['type'], $item['id']);
            }
            $count = self::PreWhere()->where(['mer_id' => $mer_id])->count();
        } else {
            $data = [];
            $count = 0;
        }
        return compact('data', 'count');
    }


    /**专题下章节数量
     * @param int $type
     * @param int $id
     * @return int|string
     * @throws \think\Exception
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public static function numberChapters($type = 0, $id = 0)
    {
        $count = 0;
        if ($type != 5 && $type != 4) {
            $specialSourceId = SpecialSource::getSpecialSource($id);
            if ($specialSourceId) $count = count($specialSourceId);
        } else if ($type == 5) {
            $specialSourceId = SpecialSource::getSpecialSource($id);
            if (count($specialSourceId)) {
                $specialSource = $specialSourceId->toArray();
                foreach ($specialSource as $key => $value) {
                    $specialSourcetaskId = SpecialSource::getSpecialSource($value['source_id']);
                    if (count($specialSourcetaskId) == 0) {
                        $is_light = self::PreWhere()->where('id', $value['source_id'])->value('is_light');
                        if ($is_light) {
                            $count = bcadd($count, 1, 0);
                        }
                    } else {
                        $count = bcadd($count, count($specialSourcetaskId), 0);
                    }
                }
            }
            $count = (int)$count;
        } else if ($type == 4) {
            $liveStudio = LiveStudio::where(['special_id' => $id])->find();
            if (!$liveStudio) return $count = 0;
            if (!$liveStudio['stream_name']) return $count = 0;
            if ($liveStudio['is_playback'] == 1) {
                $where['stream_name'] = $liveStudio['stream_name'];
                $where['start_time'] = '';
                $where['end_time'] = '';
                $count = LivePlayback::setUserWhere($where)->count();
            }
        }
        return $count;
    }

    /**轻专题类型处理
     * @param $light_type
     * @return int
     */
    public static function lightType($light_type)
    {
        switch ($light_type) {
            case 1:
                $type = 1;
                break;
            case 2:
                $type = 2;
                break;
            case 3:
                $type = 3;
                break;
        }
        return $type;
    }

    /**首页课程排行
     * @param $is_member
     * @return array|false|\PDOStatement|string|\think\Collection
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public static function course_ranking_list($is_member, $order = 'browse_count', $limit = 3)
    {
        $field = ['browse_count', 'fake_sales', 'IFNULL(browse_count,0) + IFNULL(fake_sales,0) as sales', 'image', 'title', 'type', 'money', 'pink_money', 'is_light', 'light_type', 'is_mer_visible', 'subject_id', 'pay_type', 'label', 'id', 'is_show', 'is_del'];
        $model = self::PreWhere();
        if (!$is_member) $model = $model->where(['is_mer_visible' => 0]);
        if ($order == 'browse_count') {
            $model = $model->order('sales desc');
        } else if ($order == 'add_time') {
            $model = $model->order('add_time desc');
        } else {
            $model = $model->order('sort desc,id desc');
        }
        $list = $model->limit($limit)->field($field)->select();
        $list = count($list) ? $list->toArray() : [];
        foreach ($list as $key => &$item) {
            $count = self::learning_records($item['id']);
            $item['sales'] = bcadd($item['fake_sales'], $count, 0);
            $item['browse_count'] = processingData($item['sales']);
        }
        if ($order == 'browse_count') {
            $browse = array_column($list, 'sales');
            array_multisort($browse, SORT_DESC, $list);
        }
        return $list;
    }

    /**好课推荐列表
     * @param $is_member
     * @return array|false|\PDOStatement|string|\think\Collection
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public static function good_class_recommend_list($is_member)
    {
        $model = self::PreWhere()->field(['image', 'title', 'type', 'sort', 'score', 'money', 'is_light', 'light_type', 'is_mer_visible', 'pay_type', 'label', 'id', 'is_show']);
        if (!$is_member) $model = $model->where(['is_mer_visible' => 0]);
        $list = $model->limit(3)->order('score desc,sort desc')->select();
        $list = count($list) ? $list->toArray() : [];
        return $list;
    }

    /**首页分类推荐
     * @param $is_member
     * @param $cateId
     * @return array
     */
    public static function cate_special_recommen_list($is_member, $cateId)
    {
        $field = ['browse_count', 'fake_sales', 'sort', 'IFNULL(browse_count,0) + IFNULL(fake_sales,0) as sales', 'image', 'title', 'type', 'money', 'pink_money', 'is_light', 'light_type', 'is_mer_visible', 'subject_id', 'pay_type', 'label', 'id', 'is_show', 'is_del'];
        $model = self::PreWhere();
        if (!$is_member) $model = $model->where(['is_mer_visible' => 0]);
        if (count($cateId)) $model = $model->where('subject_id', 'in', $cateId);
        $model = $model->order('sales desc,sort desc')->limit(4);
        $list = $model->field($field)->select();
        $list = count($list) ? $list->toArray() : [];
        foreach ($list as $key => &$item) {
            $count = Special::learning_records($item['id']);
            $item['sales'] = bcadd($item['fake_sales'], $count, 0);
            $item['browse_count'] = processingData($item['sales']);
        }
        $browse = array_column($list, 'sales');
        array_multisort($browse, SORT_DESC, $list);
        return $list;
    }

    /**
     * 获取直播专题列表
     * @param $where
     * @return mixed
     */
    public static function get_live_special_list_all($where, $is_member)
    {
        $field = ['s.browse_count', 's.image', 'IFNULL(s.browse_count,0) + IFNULL(s.fake_sales,0) as sales', 's.title', 's.type', 's.sort', 's.is_light', 's.light_type', 's.is_mer_visible', 's.money', 's.member_money', 's.subject_id', 's.lecturer_id', 's.pay_type', 's.label', 's.id', 's.fake_sales', 's.add_time', 'l.is_play', 'l.playback_record_id', 'l.start_play_time'];
        $model = self::setWhere($where, $is_member, 's')->field($field);
        $model = $model->join('__LIVE_STUDIO__ l', 's.id=l.special_id', 'LEFT');
        $data = $model->page($where['page'], $where['limit'])->select();
        $data = count($data) ? $data->toArray() : [];
        foreach ($data as &$item) {
            if ($item['lecturer_id']) $item['lecturer_name'] = Lecturer::where('id', $item['lecturer_id'])->value('lecturer_name');
            else $item['lecturer_name'] = '';
            $start_play_time = LiveStudio::where('special_id', $item['id'])->value('start_play_time');
            if ($start_play_time) {
                $item['start_play_time'] = date('m-d H:i', strtotime($start_play_time));
            }
            if ($item['playback_record_id'] && !$item['is_play']) {
                $item['status'] = 2; //没在直播 有回放
            } else if ($item['is_play']) {
                $item['status'] = 1; //正在直播
            } else if (!$item['playback_record_id'] && !$item['is_play'] && strtotime($start_play_time) > time()) {
                $item['status'] = 3; //等待直播
            } else {
                $item['status'] = 4; //直播结束
            }
            $count = Special::learning_records($item['id']);
            $item['browse_count'] = processingData(bcadd($item['fake_sales'], $count, 0));
        }
        $count = $model = self::setWhere($where, $is_member, 's')->join('__LIVE_STUDIO__ l', 's.id=l.special_id', 'LEFT')->count();
        return compact('data', 'count');
    }

    /**条件处理
     * @param $is_member
     * @param int $type
     * @return Special
     */
    public static function set_where_pro($is_member, $type = 0)
    {
        $model = self::PreWhere();
        if (!$is_member) $model = $model->where(['is_mer_visible' => 0]);
        if ($type) $model = $model->where(['type' => $type]);
        return $model;
    }

    /**
     * 获取单独分销设置
     */
    public static function getIndividualDistributionSettings($id = 0)
    {
        $data = self::where('id', $id)->field('is_alone,brokerage_ratio,brokerage_two')->find();
        if ($data) return $data;
        else return [];
    }
}