<?php


namespace app\api\controller;

use addons\litestore\model\Litestoreorder;
use app\api\model\Deposit;
use app\api\model\DepositOrder;
use app\api\model\Industry;
use app\api\model\LitestoreBanner;
use app\api\model\LitestoreGoodsSpec;
use app\api\model\Report;
use app\api\model\StoreApply;
use app\api\model\StoreComment;
use app\api\model\StoreInform;
use app\api\model\StoreOrder;
use app\api\model\UserSearch;
use app\api\validate\StoreValidate;
use app\common\controller\Api;
use EasyWeChat\Foundation\Application;
use EasyWeChat\Payment\Order;
use think\Db;
use think\Exception;
use think\exception\PDOException;
use think\Request;

/**
 * 店铺接口
 */
class Store extends Api
{

    protected $noNeedLogin = [];
    protected $noNeedRight = ['*'];
    protected $store_model;
    protected $industry_model;
    protected $deposit_model;
    protected $deposit_order_model;
    protected $favorite_model;
    protected $comment_model;
    protected $good_model;
    protected $follow_model;
    protected $user_id;

    public function __construct(Request $request,\app\api\model\Store $store,Industry $industry,Deposit $deposit,DepositOrder $deposit_order)
    {
        parent::__construct($request);
        $this->industry_model = $industry;
        $this->deposit_model = $deposit;
        $this->deposit_order_model = $deposit_order;
        $this->store_model = $store;
        $this->user_id = $this->auth->id;
    }

    /**
     * 行业列表
     * @ApiWeigh    (80)
     *
     * @ApiTitle    (行业列表)
     * @ApiSummary  (行业列表)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/store/industry)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="keyword", type="string", required=true, description="关键词")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturn   ({
    'code':'1',
    'msg':'返回成功',
    "data": {
        "list": [
            {
            "id": 1,
            "name": "行业名称",
            "weigh": 0,
            }
        ]
    }
    })
     */
    public function industry()
    {
        if($this->request->isPost()){
            $keyword = $this->request->param('keyword','');
            $where = [
                'where' => []
            ];
            if($keyword) {
                $where['where'] = ['name'=>['like','%'.$keyword.'%']];
            }
            $indus = $this->industry_model->selectOrFail($where,false,'*','weigh');
            $return = [
                'list' => $indus,
            ];
            $this->success('请求成功',$return);
        }
    }

    /**
     * 店铺申请
     * @ApiWeigh    (55)
     *
     * @ApiTitle    (店铺申请)
     * @ApiSummary  (店铺申请)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/store/store_add)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="store_name", type="string", required=true, description="店铺名称")
     * @ApiParams   (name="house_ids", type="string", sample="店铺1id,店铺2id", required=true, description="入驻社区")
     * @ApiParams   (name="industry_id", type="string", required=true, description="行业/关键词id")
     * @ApiParams   (name="name", type="string", required=true, description="联系人姓名")
     * @ApiParams   (name="mobile", type="string", required=true, description="联系人手机号")
     * @ApiParams   (name="license", type="string", required=true, description="营业执照")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturn   ({
    'code':'1',
    'msg':'返回成功'
    })
     */
    public function store_add()
    {
        $param = (new StoreValidate())->goCheck('store_add');
        $order_sn = $param['order_sn'] = get_order_sn();
        $pay_data = [];
//        if($this->auth->end_time > time()) {
//            $param['status'] = 2;
//        } else {
            $param['status'] = 1;
//            // 获取小程序配置
//            $options = \config('miniprogram.basic');
//            $app = new Application($options);
//            $payment = $app->payment;
//            // 获取支付参数
//            $attributes = [
//                'body' => '发布招募合伙人',
//                'out_trade_no' => $order_sn,
//                'total_fee' => 1, // $param['money'] * 100
//                'spbill_create_ip' => request()->ip(), // 可选，如不传该参数，SDK 将会自动获取相应 IP 地址
//                'notify_url' => url('index/ajax/notify',[],true,true), // 支付结果通知网址，如果不设置则会使用配置里的默认地址
//                'trade_type' => 'JSAPI', // 请对应换成你的支付方式对应的值类型
//                'openid' => Db::name('third')->where('user_id',$this->auth->id)->value('openid'),
//            ];
//            $order = new Order($attributes);
//            $order_result = $payment->pay($order);
//            if($order_result['return_code'] == 'SUCCESS' && $order_result['result_code'] == 'SUCCESS') {
//                $prepayId = $order_result->prepay_id;
//                $pay_data = $payment->configForJSSDKPayment($prepayId);
//            } else {
//                $this->error($order_result['return_msg']);
//            }
//        }
        Db::startTrans();
        $result = false;
        $result_invite = true;
        try{
            $param['user_id'] = $this->auth->id;
            $result = $this->store_model->add($param);
            $id = $this->store_model->id;
            Db::commit();
        } catch (PDOException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
        if(!$result || !$result_invite) {
            $this->error('申请提交失败');
        }
        $this->success('申请提交成功',['id'=>$id,'status'=>$param['status'],'pay_data'=>$pay_data]);
    }

    /**
     * 开通社区提交
     * @ApiWeigh    (50)
     *
     * @ApiTitle    (开通社区提交)
     * @ApiSummary  (开通社区提交)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/store/store_apply)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="store_name", type="string", required=true, description="店铺名称")
     * @ApiParams   (name="province", type="string", required=true, description="省")
     * @ApiParams   (name="city", type="string", required=true, description="市")
     * @ApiParams   (name="region", type="string", required=true, description="区")
     * @ApiParams   (name="name", type="string", required=true, description="联系人姓名")
     * @ApiParams   (name="mobile", type="string", required=true, description="联系人手机号")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturn   ({
    'code':'1',
    'msg':'返回成功'
    })
     */
    public function store_apply()
    {
        $param = (new StoreValidate())->goCheck('store_apply');
        Db::startTrans();
        $result = false;
        try{
            $param['user_id'] = $this->auth->id;
            $model = new StoreApply();
            $result = $model->add($param);
            Db::commit();
        } catch (PDOException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
        if(!$result) {
            $this->error('提交失败');
        }
        $this->success('提交成功');
    }

    /**
     * 举报建议提交
     * @ApiWeigh    (45)
     *
     * @ApiTitle    (举报建议提交)
     * @ApiSummary  (举报建议提交)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/store/store_report)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="content", type="string", required=true, description="建议内容")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturn   ({
    'code':'1',
    'msg':'返回成功'
    })
     */
    public function store_report()
    {
        $param = (new StoreValidate())->goCheck('store_report');
        Db::startTrans();
        $result = false;
        try{
            $param['user_id'] = $this->auth->id;
            $model = new Report();
            $result = $model->add($param);
            $id = $model->id;
            Db::commit();
        } catch (PDOException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
        if(!$result) {
            $this->error('提交失败');
        }
        $this->success('提交成功');
    }

    /**
     * 商家首页
     * @ApiWeigh    (40)
     *
     * @ApiTitle    (商家首页)
     * @ApiSummary  (商家首页)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/store/store)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturn   ({
    'code':'1',
    'msg':'返回成功'
    })
     */
    public function store()
    {
        $store = $this->get_store();
        $return = [
            'id' => $store['id'],
            'store_name' => $store['store_name'],
            'image_arr' => $store['image_arr'],
        ];
        $this->success('成功',$return);
    }

    /**
     * 店铺信息更新
     * @ApiWeigh    (35)
     *
     * @ApiTitle    (店铺信息更新)
     * @ApiSummary  (店铺信息更新)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/store/store_edit)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="id", type="integer", required=true, description="店铺id")
     * @ApiParams   (name="store_icon", type="string", required=true, description="店铺图标")
     * @ApiParams   (name="store_name", type="string", required=true, description="店铺名称")
     * @ApiParams   (name="mobile", type="string", required=true, description="商家电话")
     * @ApiParams   (name="province", type="string", required=true, description="省")
     * @ApiParams   (name="city", type="string", required=true, description="市")
     * @ApiParams   (name="region", type="string", required=true, description="区")
     * @ApiParams   (name="images", type="string", required=true, description="宣传图/轮播图")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturn   ({
    'code':'1',
    'msg':'返回成功'
    })
     */
    public function store_edit()
    {
        $param = (new StoreValidate())->goCheck('store_edit');
        $store = $this->get_store($param['id']);
        Db::startTrans();
        $result = false;
        try{
            $param['user_id'] = $this->auth->id;
            $result = $this->store_model->edit($param);
            Db::commit();
        } catch (PDOException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
        if(!$result) {
            $this->error('保存失败');
        }
        $this->success('保存成功');
    }

    /**
     * 发布信息
     * @ApiWeigh    (30)
     *
     * @ApiTitle    (发布信息)
     * @ApiSummary  (发布信息)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/store/store_inform_add)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="content", type="string", required=true, description="详细内容")
     * @ApiParams   (name="images", type="string", required=true, description="图片")
     * @ApiParams   (name="house_ids", type="string", required=true, description="推广社区")
     * @ApiParams   (name="type", type="integer", required=true, description="推广类型1=红包推送信息2=一般信息")
     * @ApiParams   (name="red_package", type="string", required=false, description="红包总金额")
     * @ApiParams   (name="number", type="string", required=false, description="红包数量")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturn   ({
    'code':'1',
    'msg':'返回成功'
    })
     */
    public function store_inform_add()
    {
        $param = (new StoreValidate())->goCheck('store_inform_add');
        if($param['type'] == 1) {
            $param = (new StoreValidate())->goCheck('red');
        }
        $store = $this->get_store();
        if($param['type'] == 1) {
            $param['score'] = bcadd(config('site.send_score'),$param['red_package'],2);
        }
        Db::startTrans();
        $result = false;
        try{
            $param['user_id'] = $this->auth->id;
            $param['house_ids'] = ','.$param['house_ids'].',';
            $model = new StoreInform();
            $result = $model->add($param);
            Db::commit();
        } catch (PDOException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
        if(!$result) {
            $this->error('提交失败');
        }
        $this->success('提交成功');
    }

    /**
     * 绑定新社区
     * @ApiWeigh    (25)
     *
     * @ApiTitle    (绑定新社区)
     * @ApiSummary  (绑定新社区)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/store/store_new)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="house_ids", type="string", sample="店铺1id,店铺2id", required=true, description="绑定社区id")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturn   ({
    'code':'1',
    'msg':'返回成功'
    })
     */
    public function store_new()
    {
        $param = (new StoreValidate())->goCheck('store_new');
        $store = $this->get_store();
        $order_sn = $param['order_sn'] = get_order_sn();
        $pay_data = [];
        if($this->auth->end_time > time()) {
            $param['status'] = 2;
        } else {
            $param['status'] = 1;
            // 获取小程序配置
            $options = \config('miniprogram.basic');
            $app = new Application($options);
            $payment = $app->payment;
            // 获取支付参数
            $attributes = [
                'body' => '发布招募合伙人',
                'out_trade_no' => $order_sn,
                'total_fee' => 1, // $param['money'] * 100
                'spbill_create_ip' => request()->ip(), // 可选，如不传该参数，SDK 将会自动获取相应 IP 地址
                'notify_url' => url('index/ajax/notify',[],true,true), // 支付结果通知网址，如果不设置则会使用配置里的默认地址
                'trade_type' => 'JSAPI', // 请对应换成你的支付方式对应的值类型
                'openid' => Db::name('third')->where('user_id',$this->auth->id)->value('openid'),
            ];
            $order = new Order($attributes);
            $order_result = $payment->pay($order);
            if($order_result['return_code'] == 'SUCCESS' && $order_result['result_code'] == 'SUCCESS') {
                $prepayId = $order_result->prepay_id;
            } else {
                $this->error($order_result['return_msg']);
            }
        }
        $model = new StoreOrder();
        Db::startTrans();
        $result = false;
        $result_invite = true;
        try{
            $param['store_id'] = $store['id'];
            $param['user_id'] = $this->auth->id;
            $result = $model->add($param);
            $id = $model->id;
            Db::commit();
        } catch (PDOException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
        if(!$result || !$result_invite) {
            $this->error('提交失败');
        }
        $this->success('提交成功',['id'=>$id,'status'=>$param['status'],'pay_data'=>$pay_data]);
    }

    /**
     * 留言消息
     * @ApiWeigh    (80)
     *
     * @ApiTitle    (留言消息)
     * @ApiSummary  (留言消息)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/store/comment_list)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="page", type="integer", required=true, description="页数")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturn   ({
    'code':'1',
    'msg':'返回成功',
    "data": {
    "list": [
    {
    "id": 1,
    "name": "行业名称",
    "weigh": 0,
    }
    ]
    }
    })
     */
    public function store_list()
    {
        if($this->request->isPost()){
            $param = (new StoreValidate())->goCheck('comment_reply');
            $store = $this->get_store();
            $page = $param['page'];
            $where = [
                'where' => ['store_id'=>$store['id']],
                'with' => ['user_info']
            ];
            $order = ['number'=>'DESC','createtime'=>'DESC'];
            $model = new StoreComment();
            $comment = $model->pageSelect($page,$where,'*',$order,config('option.num'));
            $list = $comment->items();
            $return = [
                'list' => $list,
                'this_page' => $comment->currentPage(),
                'total_page' => $comment->lastPage()
            ];
            $this->success('请求成功',$return);
        }
    }

    /**
     * 留言消息
     * @ApiWeigh    (50)
     *
     * @ApiTitle    (留言消息)
     * @ApiSummary  (留言消息)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/store/comment_reply)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="comment_id", type="integer", required=true, description="留言id")
     * @ApiParams   (name="content", type="string", required=true, description="留言内容")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturn   ({
    'code':'1',
    'msg':'返回成功'
    })
     */
    public function comment_reply()
    {
        $param = (new StoreValidate())->goCheck('comment_reply');
        Db::startTrans();
        $result = false;
        try{
            $param['user_id'] = $this->auth->id;
            $model = new StoreComment();
            $result = $model->add($param);
            Db::commit();
        } catch (PDOException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
        if(!$result) {
            $this->error('提交失败');
        }
        $this->success('提交成功');
    }

    /**
     * 板币充值列表
     * @ApiWeigh    (20)
     *
     * @ApiTitle    (板币充值列表)
     * @ApiSummary  (板币充值列表)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/store/deposit)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturn   ({
    'code':'1',
    'msg':'返回成功',
    "data": {
    "list": [
    {
    "id": 1,
    "name": "行业名称",
    "weigh": 0,
    }
    ]
    }
    })
     */
    public function deposit()
    {
        if($this->request->isPost()){
            $keyword = $this->request->param('keyword','');
            $where = [
                'where' => []
            ];
            if($keyword) {
                $where['where'] = ['name'=>['like','%'.$keyword.'%']];
            }
            $indus = $this->industry_model->selectOrFail($where,false,'*','weigh');
            $return = [
                'list' => $indus,
            ];
            $this->success('请求成功',$return);
        }
    }

    /**
     * 板币充值提交
     * @ApiWeigh    (15)
     *
     * @ApiTitle    (板币充值提交)
     * @ApiSummary  (板币充值提交)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/store/deposit_order)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="deposit_id", type="integer", required=true, description="板币充值id")
     * @ApiReturnParams   (name="code", type="integer", required=true, sample="0")
     * @ApiReturnParams   (name="msg", type="string", required=true, sample="返回成功")
     * @ApiReturn   ({
    'code':'1',
    'msg':'返回成功'
    })
     */
    public function deposit_order()
    {
        $param = (new StoreValidate())->goCheck('deposit_order');
        $store = $this->get_store();
        $deposit = $this->deposit_model->findOrFail(['id'=>$param['depost_id']]);
        $order_sn = $param['order_sn'] = get_order_sn();
        $pay_data = [];
        if($this->auth->end_time > time()) {
            $param['status'] = 2;
        } else {
            $param['status'] = 1;
            // 获取小程序配置
            $options = \config('miniprogram.basic');
            $app = new Application($options);
            $payment = $app->payment;
            // 获取支付参数
            $attributes = [
                'body' => '板币充值',
                'out_trade_no' => $order_sn,
                'total_fee' => 1, // $param['money'] * 100
                'spbill_create_ip' => request()->ip(), // 可选，如不传该参数，SDK 将会自动获取相应 IP 地址
                'notify_url' => url('index/ajax/notify',[],true,true), // 支付结果通知网址，如果不设置则会使用配置里的默认地址
                'trade_type' => 'JSAPI', // 请对应换成你的支付方式对应的值类型
                'openid' => Db::name('third')->where('user_id',$this->auth->id)->value('openid'),
            ];
            $order = new Order($attributes);
            $order_result = $payment->pay($order);
            if($order_result['return_code'] == 'SUCCESS' && $order_result['result_code'] == 'SUCCESS') {
                $prepayId = $order_result->prepay_id;
            } else {
                $this->error($order_result['return_msg']);
            }
        }
        $model = $this->deposit_order_model;
        Db::startTrans();
        $result = false;
        $result_invite = true;
        try{
            $param['deposit_id'] = $store['id'];
            $param['user_id'] = $this->auth->id;
            $param['score'] = $deposit['score'];
            $param['money'] = $deposit['money'];
            $result = $model->add($param);
            $id = $model->id;
            Db::commit();
        } catch (PDOException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
        if(!$result || !$result_invite) {
            $this->error('提交失败');
        }
        $this->success('提交成功',['id'=>$id,'status'=>$param['status'],'pay_data'=>$pay_data]);
    }

    /**
     * 获取店铺信息
     * @param string $id 店铺id
     */
    private function get_store($id = null)
    {
        $where_s = ['user_id'=>$this->user_id];
        if($id) {
            $where_s['id'] = $id;
        }
        $where = [
            'where' => $where_s,
            'with' => ['user_info']
        ];
        $store = $this->store_model->findOrFail($where,false);
        if(!$store) {
            $this->error('请先提交商家入驻申请');
        }
        if($store['status'] == 4) {
            $this->error('请先提交商家入驻申请');
        }
        if($store['status'] == 1) {
            $this->error('未提交入驻申请');
        }
        if($store['status'] == 2) {
            $this->error('商家申请仍在审核中');
        }
        return $store;
    }
}