<?php
namespace app\serviceapi\controller;

use app\serviceapi\model\PrizePrize as PrizePrizeModel;
use app\serviceapi\model\PrizeWin as PrizeWinModel;
use app\serviceapi\model\PrizeMember as PrizeMemberModel;
use app\serviceapi\model\PrizeRule as PrizeRuleModel;
use app\serviceapi\model\PrizeToken as PrizeTokenModel;
use think\Request;
use util\MCurl;
use think\Cache;
use think\Log;

header('Access-Control-Allow-Origin:*');
header('Content-Type: application/json; charset=utf-8');
header('Access-Control-Allow-Methods: GET, POST, PUT, DELETE, OPTIONS');
header("Access-Control-Allow-Headers: Origin, X-Requested-With, Content-Type, Accept");
/**
 * 抽奖
 * Created by PhpStorm.
 * User: niuyongqing
 * Date: 2020/7/20
 * Time: 11:37
 */
class Prize extends PingAn
{
    /**
     * 函数功能描述  获取微信token
     * Date: 2020/8/31
     * Time: 10:00
     * @author nyq
     */
    public function getAccessToken()
    {
        $prize_model = new PrizeTokenModel();
        $prize = $prize_model->getToken();
        return $prize;
    }

    /**
     * 函数功能描述  更新微信token
     * Date: 2020/8/31
     * Time: 10:00
     * @author nyq
     */
    public function updateAccessToken($data)
    {
        //$data = $this->request->post();
        if (isset($data['id']) && !empty($data['id'])) {
            $where['id'] = $data['id'];
        }
        $prize_model = new PrizeTokenModel();
        unset($data['id']);
        $prize = $prize_model->updataToken($where,$data);
        return $prize;
    }
    /**
     * 函数功能描述  添加微信token
     * Date: 2020/8/31
     * Time: 10:00
     * @author nyq
     */
    public function addAccessToken($data)
    {
        //$data = $this->request->post();
        $prize_model = new PrizeTokenModel();
        $prize = $prize_model->addToken($data);
        return $prize;
    }
    /**
     * 函数功能描述  奖品列表
     * Date: 2020/8/26
     * Time: 10:00
     * @author nyq
     */
    public function prizeList($data)
    {
       // $data = $this->request->post();
        $where=[];
        if (isset($data['id']) && !empty($data['id'])) {
            $where['id'] = $data['id'];
        }
        //姓名
        if (isset($data['name']) && !empty($data['name'])) {
            $where['name']=[ 'like', "%".$data['name']."%"];
            //$where['name']=['like','% .$data['name']];
            //   $where['name'] = $data['name'];
        }
        $prize_model = new PrizePrizeModel();
        $prize = $prize_model->getPrize($where, $data['offset'], $data['rows']);
        return $prize;
    }

    /**
     * 函数功能描述  添加奖品
     * Date: 2020/8/25
     * Time: 15:00
     * @author nyq
     */
    public function prizeAdd($data)
    {
        //$data = $this->request->post();
        $prize_model = new PrizePrizeModel();
        if(!empty($data['prize_id'])){
            $where['id']=$data['prize_id'];
            $prize_p = $prize_model->getPrizePrize($where);
            if($prize_p['img'] != $data['img']){
                $filename = ROOT_PATH . 'public' . $prize_p['img'];
                if(file_exists($filename)){
                    unlink($filename);
                }
            }
            unset($data['prize_id']);
            $prize = $prize_model->prizeUp($where,$data);
        }else{
            unset($data['prize_id']);
            $prize = $prize_model->prizeAdd($data);
        }
        return $prize;
    }
    /**
     * 函数功能描述  中奖用户列表
     * Date: 2020/8/26
     * Time: 10:00
     * @author nyq
     */
    public function prizeUserList($data)
    {
        //$data = $this->request->post();
        $where=[];
        //区部
        if (isset($data['source']) && !empty($data['source'])  && $data['source'] !=" ") {
            $where['source']=$data['source'];
        }
        //时间
        //时间搜索
        if (isset($data['start']) && !empty($data['start']) &&  isset($data['end']) && !empty($data['end'])) {
            $start_time = strtotime($data['start'].' 00:00:01');
            $end_time = strtotime($data['end'].' 23:59:59');
            $where['addTime'] = ['between', [$start_time, $end_time]];
        } else if (isset($data['start']) && !empty($data['start']) && isset($data['end']) == false) {
            $start_time = strtotime($data['start'].' 00:00:01');
            $where['addTime'] = ['egt', $start_time];
        } else if (isset($data['start']) == false && isset($data['end']) && !empty($data['end'])) {
            $end_time = strtotime($data['end'].' 23:59:59');
            $where['addTime'] = ['elt', $end_time];
        }
        //电话
        if (isset($data['phone']) && !empty($data['phone'])) {
            $wheres['phone']=$data['phone'];
            $prize_member_model = new PrizeMemberModel();
            $prize_member_phone_list = $prize_member_model->getPrizeMember($wheres);
            $prize_member_phone_list=json_decode($prize_member_phone_list,true);
            $array_type=array_column($prize_member_phone_list,'id');
            $str = implode(",", $array_type);
            $where['member_id']=['in',$str];
        }
        $where['receive']=1;
        //获取中奖列表
        $prize_win_model = new PrizeWinModel();

        if (isset($data['to_excel']) && !empty($data['to_excel'])) {
            $prize_user = $prize_win_model->getPrizeWinToExcel($where);
        }else{
            $prize_user = $prize_win_model->getPrizeWin($where, $data['offset'], $data['rows']);
        }

        $prize_win=json_decode($prize_user,true);

        $member_id = array_column($prize_win,'member_id');
        $prize_id = array_column($prize_win,'prize_id');
        //中奖的用户列表
        $map['id'] = ['in', $member_id];
        $prize_member_model = new PrizeMemberModel();
        $prize_member = $prize_member_model->getPrizeMember($map);
        $prize_member=json_decode($prize_member,true);

        //var_dump($prize_member);die;
        //中奖的奖品列表
        $arr['id'] = ['in', $prize_id];
        $prize_prize_model = new PrizePrizeModel();
        $prize_prize = $prize_prize_model->getPrizeList($arr);
        $prize_prize=json_decode($prize_prize,true);

        //合并数组
        //用户
        $name = array_column($prize_member, 'uname', 'id');
        $phone = array_column($prize_member, 'phone', 'id');

        //奖品
        $prizeName = array_column($prize_prize, 'name', 'id');
        foreach($prize_win as $key => $item) {
            $exist = array_key_exists($item['member_id'], $name);
            $prize_win[$key]['uname'] = $exist ? $name[$item['member_id']] : '';

            $exist = array_key_exists($item['member_id'], $phone);
            $prize_win[$key]['phone'] = $exist ? $phone[$item['member_id']] : '';

            $exist = array_key_exists($item['prize_id'], $prizeName);
            $prize_win[$key]['prizeName'] = $exist ? $prizeName[$item['prize_id']] : '';

        }
//        //手机号搜索
//        if(isset($data['phone'])&&!empty($data['phone'])){
//            foreach ($prize_win as $k=>$v){
//                if($v['phone']!=$data['phone']){
//                    unset($prize_win[$k]);
//                }
//            }
//        }


        //TODO 如果是执行数据导出 那么就只返回 搜索的数据
        if (isset($data['to_excel']) && !empty($data['to_excel'])) {
            $result=$prize_win;
        }else{
            $result["total"] =$this->prizeUserCount($where);
            $result['rows']=$prize_win;
        }
        return $result;
    }
    /**
     * 函数功能描述  统计中奖用户数两
     * Date: 2020/8/25
     * Time: 15:00
     * @author nyq
     */
    public function prizeUserCount($where)
    {
//        $data = $this->request->post();
//        unset($data['page'],$data['rows']);
//        $where=[];
//        //姓名
//        if (isset($data['source']) && !empty($data['source'])  && $data['source'] !=" ") {
//            $where['source']=$data['source'];
//        }
//        //时间搜索
//        if (isset($data['start']) && !empty($data['start']) &&  isset($data['end']) && !empty($data['end'])) {
//            $start_time = strtotime($data['start'].' 00:00:01');
//            $end_time = strtotime($data['end'].' 23:59:59');
//            $where['addTime'] = ['between', [$start_time, $end_time]];
//        } else if (isset($data['start']) && !empty($data['start']) && isset($data['end']) == false) {
//            $start_time = strtotime($data['start'].' 00:00:01');
//            $where['addTime'] = ['egt', $start_time];
//        } else if (isset($data['start']) == false && isset($data['end']) && !empty($data['end'])) {
//            $end_time = strtotime($data['end'].' 23:59:59');
//            $where['addTime'] = ['elt', $end_time];
//        }
//        //电话
//        if (isset($data['phone']) && !empty($data['phone'])) {
//            $wheres['phone']=$data['phone'];
//            $prize_member_model = new PrizeMemberModel();
//            $prize_member_phone_list = $prize_member_model->getPrizeMember($wheres);
//            $prize_member_phone_list=json_decode($prize_member_phone_list,true);
//            $array_type=array_column($prize_member_phone_list,'id');
//            $str = implode(",", $array_type);
//            $where['member_id']=['in',$str];
//        }
//        $where['receive']=1;
        $prize_win_model = new PrizeWinModel();
        $prize_user = $prize_win_model->getPrizeWinCount($where);
        return $prize_user;
    }
    /**
     * 函数功能描述  重置
     * Date: 2020/8/25
     * Time: 15:00
     * @author nyq
     */
    public function prizeReset()
    {
        //$data = $this->request->post();
        //查询当前规则
        $prize_rule_model = new PrizeRuleModel();
        $prize_rule = $prize_rule_model->getPrizeRule();

        $prize_rule=json_decode($prize_rule,true);
        $arr['frequency']=$prize_rule['number'];

        $wheres['frequency'] = ['neq', $prize_rule['number']];
        $prize_member_model = new PrizeMemberModel();
        $prize_member = $prize_member_model->prizeReset($wheres,$arr);

        return $prize_member;
    }
    /**
     * 函数功能描述  抽奖规则
     * Date: 2020/8/25
     * Time: 15:00
     * @author nyq
     */
    public function prizeRule()
    {
        //$data = $this->request->post();
        //查询当前规则
        $prize_rule_model = new PrizeRuleModel();
        $prize_rule = $prize_rule_model->getPrizeRule();

        return $prize_rule;
    }
    /**
     * 函数功能描述  删除奖项
     * Date: 2020/8/25
     * Time: 15:00
     * @author nyq
     */
    public function delUser($data)
    {
        //$data = $this->request->post();
        $where['id']=$data['id'];

        $prize_win_model = new PrizeWinModel();
        $prize_user = $prize_win_model->delUser($where);

        return $prize_user;
    }
    /**
     * 函数功能描述  编辑抽奖规则
     * Date: 2020/8/27
     * Time: 15:00
     * @author nyq
     */

    public function prizeRuleEdit($data)
    {
        //$data = $this->request->post();
        $prize_rule_model = new PrizeRuleModel();
        if(!empty($data['rule_id'])){
            $where['id']=$data['rule_id'];
            unset($data['rule_id']);
            $urle = $prize_rule_model->prizeRullEdit($where,$data);
        }else{
            unset($data['rule_id']);
            $urle = $prize_rule_model->prizeRullAdd($data);
        }
        return $urle;
    }
    /**
     * 函数功能描述     合适身份信息
     * Date: 2020/8/26
     * Time: 10:00
     * @author nyq
     */
    public function selPrizeMember($data)
    {
        //$data = $this->request->post();
        $where['openid']=$data['openid'];
        //传递 openID    prize_id   number设置的次数
        $prize_member_model = new PrizeMemberModel();
        $prize_member = $prize_member_model->getPrizeMember($where);
        $prize_member=json_decode($prize_member,true);
        if(count($prize_member)==0){
            //判断如果以openID为基准的用户不存在,就新增当前用户
            $rest['openid']=$data['openid'];
            $rest['frequency']=$data['number'];
            $rest['addTime']=time();
            $prize = $prize_member_model->getPrizeMemberAdd($rest);
        }else{
            $rest['openid']=$prize_member[0]['openid'];
            $rest['frequency']=$prize_member[0]['frequency'];
        }
        return $rest;
    }

    /**
     * 函数功能描述     抽奖接口
     * Date: 2020/8/26
     * Time: 10:00
     * @author nyq
     */
    public function luckDraw($data)
    {
        //$data = $this->request->post();
        //传递 openID    prize_id
        $map['openid']=$data['openid'];
        $prize_member_model = new PrizeMemberModel();
        $prize_member = $prize_member_model->getPrizeMember($map);
        $prize_member=json_decode($prize_member,true);

        if(($prize_member[0]['frequency'] - 1) < 0){
            $res['openid']=$prize_member[0]['openid'];
            $res['number']=-1;
            return $res;//抽奖次数不足
        }else{
            $where['id']=$prize_member[0]['id'];
            $are['frequency']=$prize_member[0]['frequency']-1;
            $prize_me = $prize_member_model->prizeReset($where,$are);
            //生成中奖用户信息
            $arr['member_id']=$prize_member[0]['id'];
            $arr['prize_id']=$data['prize_id'];
            $arr['receive']=0;
            $arr['source']=$data['source'];
            $arr['addTime']=time();

            $prize_win_model = new PrizeWinModel();
            $prize_user = $prize_win_model->prizeAdd($arr);
            $prize_win=json_decode($prize_user,true);
            //减库存
            $prize['id']=$data['prize_id'];
            //查询当前奖品的数量
            $prize_prize_model = new PrizePrizeModel();
            $prize_p = $prize_prize_model->getPrizePrize($prize);
            $prize_p=json_decode($prize_p,true);
            $aary['number']=$prize_p['number'] - 1;

            if($aary['number'] == 0){
                $aary['probability']=0;
            }
            $prize_set = $prize_prize_model->prizeUp($prize,$aary);
        }
        $res['openid']=$prize_member[0]['openid'];
        $res['number']=$prize_member[0]['frequency']-1;   //剩余
        $res['prize_number']=$aary['number'];

        return $res;
    }

    /**
     * 函数功能描述  中奖用户列表最新 20条
     * Date: 2020/8/26
     * Time: 10:00
     * @author nyq
     */
    public function prizeWinList($data)
    {
        //$data = $this->request->post();
        $where=[];

        //姓名
        $prize_member_model = new PrizeMemberModel();
        if (isset($data['openid']) && !empty($data['openid'])) {
            $where['openid'] = $data['openid'];
            $prize_member = $prize_member_model->getPrizeMember($where);
            unset($where['openid']);
            $where['member_id']=$prize_member[0]['id'];
        }
        //获取中奖列表
        $prize_win_model = new PrizeWinModel();
        $prize_user = $prize_win_model->getPrizeWinlist($where);
        $prize_win=json_decode($prize_user,true);
        $member_id = array_column($prize_win,'member_id');
        $prize_id = array_column($prize_win,'prize_id');
        //中奖的用户列表
        $map['id'] = ['in', $member_id];
        $prize_member = $prize_member_model->getPrizeMember($map);
        $prize_member=json_decode($prize_member,true);
        //var_dump($prize_member);die;
        //中奖的奖品列表
        $arr['id'] = ['in', $prize_id];
        $prize_prize_model = new PrizePrizeModel();
        $prize_prize = $prize_prize_model->getPrizeList($arr);
        $prize_prize=json_decode($prize_prize,true);
        //合并数组
        //用户
        $name = array_column($prize_member, 'uname', 'id');
        $phone = array_column($prize_member, 'phone', 'id');
        //奖品
        $prizeName = array_column($prize_prize, 'name', 'id');
        foreach($prize_win as $key => $item) {
            $exist = array_key_exists($item['member_id'], $name);
            $prize_win[$key]['uname'] = $exist ? $name[$item['member_id']] : '';

            $exist = array_key_exists($item['member_id'], $phone);
            $prize_win[$key]['phone'] = $exist ? $phone[$item['member_id']] : '';

            $exist = array_key_exists($item['prize_id'], $prizeName);
            $prize_win[$key]['prizeName'] = $exist ? $prizeName[$item['prize_id']] : '';
        }
        //新增随机抽奖记录中,没有用户名不显示
        if (!isset($data['openid']) && empty($data['openid'])) {
            $arr =array();
            foreach($prize_win as $key =>$val){
                if($val['uname'] !="")   {
                    $arr[$key]['uname']=$val['uname'];
                    $arr[$key]['prizeName']=$val['prizeName'];
                    $arr[$key]['addTime']=$val['addTime'];
                }
            }
            return $arr;
        }else{
            return $prize_win;
        }
    }

    /**
     * 函数功能描述    兑奖接口
     * Date: 2020/8/26
     * Time: 10:00
     * @author nyq
     */
    public function cashPrize($data)
    {
        //$data = $this->request->post();
        //传递 openID    prize_id
        $map['openid']=$data['openid'];
        $map['uname']=$data['name'];
        $map['phone']=$data['phone'];

        $where['openid'] = $data['openid'];
        $prize_member_model = new PrizeMemberModel();
        $prize_member = $prize_member_model->getMember($where);

        $prize_member=json_decode($prize_member,true);
        unset($where['openid']);
        $aa=[];
        $aa['id'] = $prize_member['id'];
        //补全用户信息
        $prize_mem = $prize_member_model->prizeReset($aa,$map);
        $bb=[];
        $bb['member_id'] = $prize_member['id'];
        $prize_win_model = new PrizeWinModel();
        $arr['receive'] = 1;
        $prize_user = $prize_win_model->winReset($bb,$arr);
        $prize_win=json_decode($prize_user,true);

        return $prize_win;
    }




}