<?php
// +----------------------------------------------------------------------
// | Niucloud-admin 企业快速开发的多应用管理平台
// +----------------------------------------------------------------------
// | 官方网址：https://www.niucloud.com
// +----------------------------------------------------------------------
// | niucloud团队 版权所有 开源版本可自由商用
// +----------------------------------------------------------------------
// | Author: Niucloud Team
// +----------------------------------------------------------------------

namespace app\service\api\member;

use addon\zhjw\app\model\classes\Classes;
use addon\zhjw\app\model\courses\Courses;
use addon\zhjw\app\model\students\Students;
use addon\zhjw\app\model\timetables\Timetables;
use addon\zhjw\app\model\venues\Venues;
use app\dict\sys\AppTypeDict;
use app\model\member\Member;
use app\service\core\member\CoreMemberService;
use core\base\BaseApiService;
use core\exception\ApiException;
use core\util\Barcode;
use core\util\TokenAuth;
use think\facade\Db;
use think\Model;

/**
 * 会员服务层
 * Class MemberService
 * @package app\service\api\member
 */
class MemberService extends BaseApiService
{
    public function __construct()
    {
        parent::__construct();
        $this->model = new Member();
    }

    /**
     * 新增会员
     */
    public function add(array $data){
        return $this->model->create($data)?->member_id ?? 0;
    }

    /**
     * 更新会员
     * @param array $data
     * @return true
     */
    public function edit(array $data)
    {
        $member = $this->findMemberInfo(['member_id' => $this->member_id]);

        if($member->isEmpty()) throw new ApiException('MEMBER_NOT_EXIST');
        $member->allowField(['nickname', 'headimg', 'birthday', 'sex', 'last_visit_time'])->save($data);
        return true;
    }

    /**
     * 获取会员信息
     * @return array
     */
    public function getInfo()
    {
        $field = 'member_id, username, member_no, mobile, register_channel, nickname, headimg, member_level, member_label, login_ip, login_type, login_time, create_time, last_visit_time, last_consum_time, sex, status, birthday, point, balance, growth, is_member, member_time, is_del, province_id, city_id, district_id, address, location, money, money_get, wx_openid, weapp_openid, commission, commission_get, commission_cash_outing';
        $info = $this->model->where([['member_id', '=', $this->member_id]])
            ->with(['member_level_name_bind'])
            ->field($field)
            ->append(['sex_name'])
            ->findOrEmpty()->toArray();
        $info['students_id'] = (new Students())->where(['user_id' => $this->member_id])->value('id');
        return $info;
    }

    /**
     * 检测会员信息是否存在
     * @return int
     */
    public function getCount($condition)
    {
        return $this->model->where($condition)->count();
    }

    /**
     * 会员中心信息
     */
    public function center()
    {
        $field = 'member_id, username, member_no, mobile, register_channel, nickname, headimg, member_level, member_label, login_ip, login_type, login_time, create_time, last_visit_time, last_consum_time, sex, status, birthday, point, balance, growth, is_member, member_time, is_del, province_id, city_id, district_id, address, location, money, money_get, commission, commission_get, commission_cash_outing';
        return $this->model->where([['member_id', '=', $this->member_id]])->field($field)->append(['sex_name'])->findOrEmpty()->toArray();
    }

    /**
     * 获取会员的模型对象(todo  慎用!!!  现主要用于登录)
     * @param array $data
     * @return Member|array|mixed|Model  !!! 仔细看,返回值是模型对象  如果想要判断是否为空  请用 $member->isEmpty()
     */
    public function findMemberInfo(array $data){
        //会员账号
        if(!empty($data['username']))
            $where[] = ['username', '=', $data['username']];
        //会员手机号
        if(!empty($data['mobile']))
            $where[] = ['mobile', '=', $data['mobile']];
        //会员id
        if(!empty($data['member_id']))
            $where[] = ['member_id', '=', $data['member_id']];
        //微信公众号openid
        if(!empty($data['wx_openid']))
            $where[] = ['wx_openid', '=', $data['wx_openid']];
        //微信小程序openid
        if(!empty($data['weapp_openid']))
            $where[] = ['weapp_openid', '=', $data['weapp_openid']];
        // 微信unionid
        if(!empty($data['wx_unionid']))
            $where[] = ['wx_unionid', '=', $data['wx_unionid']];
        if(!empty($data['username|mobile']))
            $where[] = ['username|mobile', '=', $data['username|mobile']];
        if(empty($where)){
            $where[] = ['member_id', '=', -1];
        }
        return $this->model->where($where)->findOrEmpty();
    }

    /**
     * 通过对象修改会员信息
     * @param $member
     * @param $data
     * @return void
     */
    public function editByFind($member, $data){
        return $member->save($data);
    }

    /**
     * 修改字段
     * @param string $field
     * @param $data
     * @return null
     */
    public function modify(string $field, $data)
    {
        return (new CoreMemberService())->modify($this->member_id, $field, $data);
    }

    public function getQrcode(){
        // 生成会员二维码
        $qrcode_dir = 'upload/member/temp';
        if (!is_dir($qrcode_dir)) mkdir($qrcode_dir, intval('0755', 8), true);
        $id = "member-".$this->member_id;
        $qrcode_path = "{$qrcode_dir}/order_qrcode_{$this->member_id}.png";
        \core\util\QRcode::png($id, $qrcode_path, 'L', 16, 1);

        // 生成会员条形码
        $barcode_path = (new Barcode(14, $id))->generateBarcode($qrcode_dir, 2);
        $detail = [];
        $detail['verify_code_qrcode'] = image_to_base64($qrcode_path, true);
        $detail['verify_code_barcode'] = image_to_base64($barcode_path);
        return $detail;
    }

    /**
     * 初始化会员数据
     */
    public function initMemberData(){
        if ($this->member_id) {
            event("MemberLoginAfter", ['member_id' => $this->member_id]);
        }
    }

    public function is_pass($data){
        $password = $this->model->where([['member_id', '=', $this->member_id]])->value("password");
        if (!check_password($data['password'], $password)){
            return fail("密码不正确");
        }
        return success("密码正确");
    }

    public function set_pass($data){
        if($data['old_password'] != $data['password']){
            return fail("两次密码输入不一致");
        }
        $password_hash = create_password($data['password']);
        $data = array(
            'password' => $password_hash,
        );
        $member_info = $this->findMemberInfo([ 'member_id' => $this->member_id ]);
        $this->editByFind($member_info, $data);
        TokenAuth::clearToken($this->member_id, AppTypeDict::API, $this->request->apiToken());
        return success("修改密码成功");
    }

    //课程列表
    public function course_list($data){
        $member_info = $this->getInfo();
        $venues = new Venues();
        $classes = new Classes();
        $timetables = new Timetables();
        $courses = new Courses();

        $classes_list = $classes
            ->alias("a")
            ->join(['school_venues' => 'b'],'a.venue_id = b.id','left')
            ->join(['school_timetables' => 'c'],'a.id = c.class_id','left')
            ->join(['school_courses' => 'd'],'c.courses_id = d.id','left')
            ->where('a.start_date', '<=', $data['schedule_date'])
            ->where('a.end_date', '>=', $data['schedule_date'])
            ->whereRaw("FIND_IN_SET(?, a.max_students)", [$member_info['students_id']])
            ->field("a.id,a.venue_id,a.start_date,a.end_date,a.max_students,a.name,b.name as address,d.name as courses_name,
                LENGTH(a.max_students) - LENGTH(REPLACE(a.max_students, ',', '')) + 1 as students_count,d.id as courses_id
            ")
            ->group("a.venue_id")
            ->select()->toArray();


        $groupedClassesList = [];
        foreach ($classes_list as $item) {

            $has_sign = Db::name("zhjw_students_sign")
                ->alias("a")
                ->join(['school_member' => 'b'],'a.students_id = b.member_id','left')
                ->where(['a.courses_id' => $item['courses_id']])
                ->field("a.id,b.headimg")
                ->select();
            $item['has_sign_count'] = count($has_sign);
            $item['has_sign_list'] = $has_sign;

            $venueId = $item['venue_id'];
            if (!isset($groupedClassesList[$venueId])) {
                $groupedClassesList[$venueId] = [];
            }
            $groupedClassesList[$venueId][] = $item;
        }

        return $groupedClassesList;


        $list = $venues->order("id desc")->select()->toArray();

        foreach ($list as $k=>$v){
            $list[$k]['list'] = [];
            $classes_list = $classes->where(['venue_id' => $v['id']])->select();
            if($classes_list){
                foreach ($classes_list as $k1=>$v1){
                    $timetables_info = $timetables->where(['class_id' => $v1['id'],'schedule_date' => $data['schedule_date']])->find();
                    $courses_info = $courses->where(['id' => $timetables_info['courses_id']])->find();
                    if($timetables_info and $courses_info){
                        $info = [
                            'bj' => $v1['name'],
                            'status' => $v1['status'],
                            'courses_info' => $courses_info,
                            'datetime' => $data['schedule_date'],
                            'address' => '',
                            'name' => $courses_info['name']
                        ];
                        $list[$k]['list'][] = $info;
                    }

                }
            }
        }

        return $list;
    }
}