<?php
/**
 * Created by PhpStorm.
 * User: Administrator
 * Date: 2020/7/10
 * Time: 17:32
 */

namespace app\api\controller;


use app\common\controller\Api;
use think\Cache;
use think\Db;
use think\Validate;
use EasyWeChat\Foundation\Application as WXPAY_APP;
use EasyWeChat\Payment\Order as WXPAY_ORDER;
use addons\third\model\Third;

 /**
 * 社区公告
 */
class HouseBoard extends Api
{
    protected $noNeedLogin = ['*'];
    protected $noNeedRight = ['*'];

    /**
     * @ApiTitle    (社区公告-首页)
     * @ApiSummary  (社区公告-首页)
     * @ApiMethod   (POST)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiReturn({
        "code": 1,
        "msg": "成功",
        "time": "1571492001",
        "data": {
              "is_binding"://是否绑定1已绑定2未绑定
              "house"://社区信息
              "house_board"://最新公告信息
        }
    })
     */
    public function index()
    {
        $user_id = $this->auth->id;
        $data = Db::name('user')->where('id',$user_id)->field('id,house_id')->find();
        if(empty($data['house_id'])){
            $info['is_binding'] = 2;
        }else{
            $info['is_binding'] = 1;
            /*小区信息*/
            $house = Db::name('house')
                ->where('id',$data['house_id'])
                ->field('image,name,thumbnail,bindnum')
                ->find();
            // 消息红点
            $message = Db::name('message')
                    ->where('house_id',$data['house_id'])
                    ->where('to_user_id',$user_id)
                    ->where('is_read',2)
                    ->field('id')
                    ->find();
            $house['have_message'] = !empty($message) ? 1 : 2;
            $house['image'] = cdnurl($house['image'],true);
            /*最新公告信息*/
            $house_board = Db::name('house_board')
                ->where('house_id',$data['house_id'])
                ->order('createtime desc')
                ->field('id,title,content,look_num,createtime')
                ->find();
            if(!empty($house_board)){
                $house_board['createtime'] = date('Y-m-d',$house_board['createtime']);
                // 最新公告是否已读
                $is_read = Db::name('house_board_detail')
                    ->where('user_id',$user_id)
                    ->where('house_board_id',$house_board['id'])
                    ->find();
                $house_board['is_new'] = !empty($is_read) ? 1 : 2;
                // 最新公告-用户头像
                $house_board['avatar'] = Db::name('house_board_detail')
                    ->alias('a')
                    ->join('user b','a.user_id = b.id')
                    ->where('a.house_board_id',$house_board['id'])
                    ->field('b.avatar,b.id')
                    ->limit(6)
                    ->select();
            }
            $info = array_merge($info,compact('house','house_board'));
        }
        $this->success('success',$info);
    }

    /**
     * @ApiTitle    (社区公告-业主信息)
     * @ApiSummary  (社区公告-业主信息)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/house/avatar)
     *
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="house_board_id", type="inter", required=true, description="公告id")
     *
     *
     * @ApiReturn({
        "code": 1,
        "msg": "成功",
        "time": "1571492001",
        "data": {
            "id"://用户id
            "avatar"://用户头像
        }
    })
     */
    public function avatar()
    {
        (new House)->avatar();
    }

    /**
     * @ApiTitle    (社区公告-轮播图)
     * @ApiSummary  (社区公告-轮播图)
     * @ApiMethod   (POST)
     *
     * @ApiReturn({
        "code": 1,
        "msg": "成功",
        "time": "1571492001",
        "data": {
            "id"://id
            "image"://图片
            "url"://跳转地址
            "typeswitch"://开关0关1开
            "createtime"://创建时间
        }
    })
     */
    public function banner()
    {
        $data = Db::name('advertising')->field('updatetime',true)->order('createtime desc')->select();
        foreach ($data as &$v){
            $v['image'] = cdnurl($v['image'],true);
            $v['createtime'] = date('Y-m-d H:i:s',$v['createtime']);
        }
        $this->success('success',$data);
    }


    /**
     * @ApiTitle    (社区公告-公告列表)
     * @ApiSummary  (社区公告-公告列表)
     * @ApiMethod   (POST)
     *
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="house_id", type=inter, required=true, description="社区id")
     * @ApiParams   (name="page", type="inter", required=false, description="当前页(默认1)")
     * @ApiParams   (name="pageNum", type="inter", required=false, description="每页显示数据个数（默认10）")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "成功",
        "time": "1571492001",
        "data": {
            "total_num"://总条数
            "info":[
                "id"://公告id
                "title"://社区公告标题
                "content"://公告内容
                "look_num"://浏览人数
                "createtime"://时间
                "avatar"://用户头像
            ]
        }
    })
     */
    public function house_board_list()
    {
        $page = $this->request->param('page', 1, 'intval');
        $pageNum = $this->request->param('pageNum', 10, 'intval');
        $user_id = $this->auth->id;
        $house_id = $this->request->param('house_id');
        if(empty($house_id)){
            $this->error('社区id不能为空');
        }
        $data['total_num'] = Db::name('house_board')
            ->where('house_id',$house_id)
            ->count();
        $data['info'] = Db::name('house_board')
            ->where('house_id',$house_id)
            ->order('weigh desc')
            ->page($page,$pageNum)
            ->select();
        foreach ($data['info'] as &$v){
            $v['createtime'] = date('Y-m-d',$v['createtime']);
            //查询用户是否在已读公告详情中
            $house_board_detail = Db::name('house_board_detail')
                ->where('user_id',$user_id)
                ->where('house_board_id',$v['id'])
                ->find();
            if(empty($house_board_detail)){
                $info['user_id'] = $user_id;
                $info['house_board_id'] = $v['id'];
                $info['createtime'] = time();
                Db::name('house_board_detail')->insertGetId($info);
                Db::name('house_board')->where('id',$v['id'])->setInc('look_num');
            }

            $v['avatar'] = Db::name('house_board_detail')
                ->alias('a')
                ->join('user b','a.user_id = b.id')
                ->where('a.house_board_id',$v['id'])
                ->field('b.avatar,b.id')
                ->limit(6)
                ->select();
        }
        $this->success('success',$data);
    }

    /**
     * @ApiTitle    (社区公告-服务电话)
     * @ApiSummary  (社区公告-服务电话)
     * @ApiMethod   (POST)
     *
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="house_id", type="string", required=true, description="小区id")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "成功",
        "time": "1571492001",
        "data": {
              "id"://id
              "name"://电话名称
              "phone"://电话
        }
    })
     */
    public function house_phone()
    {
        $user_id = $this->auth->id;
        $house_id = $this->request->param('house_id');
        if(empty($house_id)){
            $this->error('缺少必要参数');
        }
        $data = Db::name('house_phone')->field('id,name,phone')->where('house_id',$house_id)->select();
        $this->success('success',$data);
    }


    /**
     * @ApiTitle    (社区公告-物业留言)
     * @ApiSummary  (社区公告-物业留言)
     * @ApiMethod   (POST)
     *
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="house_id", type="string", required=true, description="小区id")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "成功",
        "time": "1571492001",
        "data": {
            "user_id"://用户id
            "avatar"://管理员头像
            "nickname"://昵称
            "is_have"://是否带有红标签 1有2没有
        }
    })
     */
    public function house_admin_list()
    {
        $user_id = $this->auth->id;
        $house_id = $this->request->param('house_id');
        if(empty($house_id)){
            $this->error('缺少必要参数');
        }

        $data = Db::name('house_admin')
            ->alias('a')
            ->join('user b','a.user_id = b.id')
            ->where('a.house_id',$house_id)
            ->field('a.user_id,b.avatar,b.nickname')
            ->order('a.is_direct')
            ->select();
        foreach ($data as &$v){
            $mes = Db::name('message')
                ->where('house_id',$house_id)
                ->where('user_id',$v['user_id'])
                ->where('to_user_id',$user_id)
                ->where('is_read',2)
                ->find();
            if(empty($mes)){
                $v['is_have'] = 2;
            }else{
                $v['is_have'] = 1;
            }
        }
        $this->success('success',$data);
    }

    /**
     * @ApiTitle    (社区公告-物业留言-详情)
     * @ApiSummary  (社区公告-物业留言-详情)
     * @ApiMethod   (POST)
     *
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="house_id", type="inter", required=true, description="社区id")
     * @ApiParams   (name="user_id", type="inter", required=true, description="社区物业管理员用户id")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "成功",
        "time": "1571492001",
        "data": {
            "id"://id
            "user_id"://发送者id
            "house_id"://社区id
            "to_user_id"://接收者用户id
            "type"://消息类型1文字类型2图片类型
            "content"://文字消息
            "image"://图片消息
            "is_read"://是否已读1已读2未读
            "createtime"://创建时间
            "updatetime"://修改时间
            "nickname"://昵称
            "is_have"://是否带有红标签 1有2没有
            "is_left"://是否在右边  1是2否
        }
    })
     */
    public function chat_record()
    {
        $user_id = $this->auth->id;    //当前登录用户id
        $house_id = $this->request->param('house_id');      //社区id
        $wuye_user_id = $this->request->param('user_id');   //物业用户id
        if(empty($house_id) || empty($wuye_user_id)){
            $this->error('缺少必要参数');
        }

        $house_admin = Db::name('house_admin')->where('user_id',$wuye_user_id)->where('house_id',$house_id)->find();
        if(empty($house_admin)){
            $this->error('参数有误,社区与管理员id不匹配');
        }

        $data = Db::name('message')
            ->where('house_id',$house_id)
            ->where('user_id',$user_id)
            ->where('to_user_id',$wuye_user_id)
            ->order('createtime desc')
            ->select();
        foreach ($data as &$v){
            $v['is_right'] = 1;
            if($v['type'] == 2){
                $v['image'] = cdnurl($v['image'],true);
            }
        }
        $arr = Db::name('message')
            ->where('house_id',$house_id)
            ->where('user_id',$wuye_user_id)
            ->where('to_user_id',$user_id)
            ->order('createtime desc')
            ->select();
        foreach ($arr as &$v){
            $v['is_right'] = 2;
            if($v['type'] == 2){
                $v['image'] = cdnurl($v['image'],true);
            }
        }

        $info = array_merge($data,$arr);

        array_multisort(array_column($info,'createtime'),SORT_DESC,$info);
        foreach ($info as &$val){
            $val['createtime'] = date('Y-m-d H:i:s',$val['createtime']);
        }

        $this->success('success',$info);

    }

    /**
     * @ApiTitle    (社区公告-社区活动)
     * @ApiSummary  (社区公告-社区活动)
     * @ApiMethod   (POST)
     *
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="house_id", type="inter", required=true, description="社区id")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "success",
        "time": "1598587213",
        "data": [
            {
              "id": // 活动id
              "title": // 活动标题
              "spec_type": // 活动规格:0=无规格,免费,1=单规格,2=多规格
              "content": // 活动描述
              "activity_time": 活动日期
              "price": // 报名费用
              "status": { // 活动状态
                "text": // 状态名称
                "value": // 状态值 0=报名中,1=已报名,2=已到期
              }
            }
        ]
    })
     */
    public function activity()
    {
        $user_id = $this->auth->id;
        $house_id = $this->request->param('house_id');      //社区id
        empty($house_id) && $this->error('缺少必要参数');
        $list = $this->getActivityList("find_in_set({$house_id},house_ids)");
        $this->success('success',$list);
    }

    /**
     * @ApiTitle    (社区公告-社区活动-详情)
     * @ApiSummary  (社区公告-社区活动-详情)
     * @ApiMethod   (POST)
     *
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="house_activity_id", type="inter", required=true, description="社区活动id")
     *
     * @ApiReturn({
        "code": 1,
        "msg": "success",
        "time": "1598587213",
        "data": {
            "id": // 活动id
            "title": // 活动标题
            "spec_type": // 活动规格:0=无规格,免费,1=单规格,2=多规格
            "content": // 活动描述
            "activity_time": 活动日期
            "price": // 报名费用
            "status": { // 活动状态
                "text": // 状态名称
                "value": // 状态值 0=报名中,1=已报名,2=已到期
            }
        }
    })
     */
    public function activityInfo()
    {
        $user_id = $this->auth->id;
        $house_activity_id = $this->request->param('house_activity_id');      //社区id
        empty($house_activity_id) && $this->error('缺少必要参数');
        $list = $this->getActivityList(['ha.id'=>$house_activity_id]);
        $info = !empty($list) ? $list[0] : [];
        $this->success('success',$info);
    }

    /**
     * 获取活动信息
     */
    private function getActivityList($where){
        $list = Db::name('house_activity')
            ->alias('ha')
            ->join('house_join hj','hj.house_activity_id = ha.id','left')
            ->where($where)
            ->field('
                ha.id,
                ha.title,
                ha.content,
                ha.start_time,
                ha.end_time,
                ha.spec_type,
                hj.join_status
            ')
            ->order("ha.createtime desc")
            ->select();
        foreach ($list as $k => &$v) {
            // 活动报名费用
            $price = Db::name('house_activity_spec')->where('house_activity_id',$v['id'])->value('price');
            $v['price'] = $price > 0 ? $price : 0;
            // 活动日期
            $v['activity_time'] = date('Y-m-d',$v['start_time']).'-'.date('Y-m-d',$v['end_time']);
            // 活动状态
            if($v['join_status'] == '1'){
                $status = ['text'=>'已报名','value'=>1];
            }else{
                $status = $v['end_time'] < time() ? ['text'=>'已到期','value'=>2] : ['text'=>'报名中','value'=>0];
            }
            $v['status'] = $status;
            unset($v['start_time'],$v['end_time'],$v['join_status']);
        }
        return $list;
    }

    /**
     * @ApiTitle    (社区公告-社区活动-获取规格)
     * @ApiSummary  (社区公告-社区活动-获取规格)
     * @ApiMethod   (POST)
     * @ApiParams   (name="house_activity_id", type="integer", required=true, description="活动ID")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturnParams   (name="data", type="object", description="扩展数据返回")
     * @ApiReturn   ({
            "code": 1,
            "msg": "成功",
            "time": "1598600665",
            "data": {
                "spec_attr": [
                    {
                      "group_id": 25,
                      "group_name": "颜色",
                      "spec_items": [
                        {
                          "item_id": 52,
                          "spec_value": "白色"
                        },
                        {
                          "item_id": 54,
                          "spec_value": "黑色"
                        }
                      ]
                    }
                ],
                "spec_list": {
                    "52_50": {
                      "spec_sku_id": "52_50",
                      "price": "12.00"
                    }
                },
                "price": "12.00"
            }
        })
     */
    public function specData()
    {
        $house_activity_id = $this->request->param('house_activity_id');
        $activity = \app\admin\model\HouseActivity::get($house_activity_id);
        empty($activity) && $this->error('活动信息不存在');
        // 规格信息
        $spec_data = $activity['spec_type'] == '2' ? $activity->getManySpecData($activity['spec_rel'], $activity['spec']) : null;
        // 规格价格信息
        if($spec_data){
            $spec_list = [];
            foreach($spec_data['spec_list'] as $v){
                $spec_list[$v['spec_sku_id']]['spec_sku_id'] = $v['spec_sku_id'];
                $spec_list[$v['spec_sku_id']]['price'] = $v['form']['price'];
            }
            $spec_data['spec_list'] = $spec_list;
        }
        $price = Db::name('house_activity_spec')->where('house_activity_id',$activity['id'])->value('price');
        // 默认报名费
        $spec_data['price'] = $price > 0 ? $price : 0;
        $this->success(__('成功'),$spec_data);
    }

    /**
     * @ApiTitle    (社区公告-社区活动-报名)
     * @ApiSummary  (社区公告-社区活动-报名)
     * @ApiMethod   (POST)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="house_activity_id", type="integer", required=true, description="活动id")
     * @ApiParams   (name="total_num", type="integer", required=true, description="数量")
     * @ApiParams   (name="spec_sku_id", type="integer", description="活动规格sku")
     * @ApiParams   (name="contact", type="string", required=true, description="姓名")
     * @ApiParams   (name="mobile", type="string", required=true, description="联系方式")
     * @ApiParams   (name="remark", type="string", description="备注")
     * @ApiReturn   ({
    'code':'1',
    'msg':'返回成功',
    "data": {
    }
    })
     */
    public function join(){
        $house_activity_id = $this->request->param('house_activity_id');
        $total_num = $this->request->param('total_num');
        $spec_sku_id = $this->request->param('spec_sku_id','');
        $contact = $this->request->param('contact');
        $mobile = $this->request->param('mobile');
        $remark = $this->request->param('remark');
        // 验证
        empty($house_activity_id) && $this->error('缺少必要参数');
        empty($total_num) && $this->error('缺少必要参数');
        empty($contact) && $this->error('缺少必要参数');
        empty($mobile) && $this->error('缺少必要参数');
        $activity = Db::name('house_activity')
            ->where('id',$house_activity_id)
            ->field('title,content,spec_type,start_time,end_time')
            ->find();
        empty($activity) && $this->error('活动信息不存在');
        if($activity['spec_type'] == '2' && empty($spec_sku_id)){
            $this->error('多规格活动，请传入spec_sku_id');
        }
        // 必要数据查询
        $price = 0; //报名费
        $total_price = 0; // 总报名费
        $house_activity_spec_id = 0; // 活动规格ID
        if($activity['spec_type'] > '0'){
            $house_activity_spec = Db::name('house_activity_spec')
                ->where('house_activity_id',$house_activity_id)
                ->where('spec_sku_id',$spec_sku_id)
                ->field('id,price')
                ->find();
            $price = $house_activity_spec['price'];
            $total_price = $price * $total_num;
            $house_activity_spec_id = $house_activity_spec['id'];
        }
        // 生成报名订单
        $house_join_id = Db::name('house_join')->insertGetId(array_merge([
            'order_no' => date('Ymd') . substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8),
            'contact' => $contact,
            'mobile' => $mobile,
            'remark' => $remark,
            'total_price' => $total_price,
            'pay_price' => $total_price,
            'user_id' => $this->auth->id,
            'house_activity_id' => $house_activity_id,
            'price' => $price,
            'total_num' => $total_num,
            'spec_sku_id' => $spec_sku_id,
            'house_activity_spec_id' => $house_activity_spec_id,
            'createtime' => time()
        ],$activity));
        if($total_price > 0){
            // 调起支付
            $this->init_wx_pay_for_gzh(true);
            $this->make_wx_pay('wechat',$house_join_id);
        }
        // 免费活动直接报名成功
        Db::name('house_join')->where('id',$house_join_id)->setField('join_status','1');
        $this->success(__('报名成功'));
    }

    private function init_wx_pay_for_gzh($Ischeck=false){
        //这里首先判断 此用户是否绑定了微信公众号
        if($Ischeck){
            $third = Third::where(['user_id' => $this->auth->id, 'platform' => 'wechat'])->find();
            if(!$third){
                //从这里自动绑定微信公众号的账户
                $this->error('您未绑定微信号',null,1008);
            }
        }

        $config = get_addon_config('litestore');

        $third_config = get_addon_config('third');
        $third_options = array_intersect_key($third_config, array_flip(['wechat']));
        $third_options = $third_options['wechat'];

        $options = [
            'debug'  => true,
            'log' => [
                'level' => 'debug',
                'file'  => '/tmp/easywechat.log',
            ],
            'app_id'   => $third_options['app_id'],
            'secret'   => $third_options['app_secret'],
            'payment' => [
                'merchant_id'        =>  $config['MCHIDGZH'],
                'key'                =>  $config['APIKEYGZH'],
                'notify_url'         =>  \think\Request::instance()->domain().'/index/ajax/callback_for_wxgzh',
            ],

        ];
        $this->wxapp = new WXPAY_APP($options);
    }

    private function make_wx_pay($platform,$house_join_id){
        // 报名是否存在
        $join = Db::name('house_join')->where('id',$house_join_id)->find();
        empty($join) && $this->error('报名信息不存在');
        $join['pay_status'] == '1' && $this->error('已支付，请勿重复操作');

        $third = Third::where(['user_id' => $this->auth->id, 'platform' => $platform])->find();
        $payment = $this->wxapp->payment;

        $attributes = [
            'trade_type'       => 'JSAPI',
            'body'             => $join['order_no'],
            'detail'           => 'OrderID:'.$join['id'],
            'out_trade_no'     => $join['order_no'],
            //'total_fee'        => $this->model['pay_price'] * 100, // 单位：分
            'total_fee'        => 1, // 单位：分
            'openid'           => $third['openid'],
        ];
        $order = new WXPAY_ORDER($attributes);

        $result = $payment->prepare($order);
        if ($result->return_code == 'SUCCESS' && $result->result_code == 'SUCCESS'){
            $prepayId = $result->prepay_id;
            $config = $payment->configForJSSDKPayment($prepayId); // 返回数组
            return $this->success('预支付成功',$config);
        }
        return $this->error('微信支付调用失败',$result);
    }
}