<?php


namespace app\api\controller;

use app\api\model\Deposit;
use app\api\model\DepositOrder;
use app\api\model\Industry;
use app\api\model\Message;
use app\api\model\StoreComment;
use app\api\model\StoreInform;
use app\api\model\StoreInformGood;
use app\api\model\StoreInformLog;
use app\api\model\StoreInformView;
use app\api\model\UserHouse;
use app\api\model\UserMoneyLog;
use app\api\validate\HotValidate;
use app\common\controller\Api;
use think\Db;
use think\Exception;
use think\exception\PDOException;
use think\Request;

/**
 * 周边热点接口
 */
class Hot extends Api
{
    protected $noNeedLogin = ['banner'];
    protected $noNeedRight = ['*'];
    protected $store_model;
    protected $store_inform_model;
    protected $store_inform_good_model;
    protected $user_house_model;
    protected $industry_model;
    protected $favorite_model;
    protected $comment_model;
    protected $good_model;
    protected $user_id;

    public function __construct(Request $request,\app\api\model\Store $store,Industry $industry,StoreInform $store_inform,UserHouse $user_house,StoreInformGood $store_inform_good)
    {
        parent::__construct($request);
        $this->industry_model = $industry;
        $this->store_model = $store;
        $this->store_inform_model = $store_inform;
        $this->store_inform_good_model = $store_inform_good;
        $this->user_house_model = $user_house;
        $this->user_id = $this->auth->id;
    }

    /**
     * 商圈信息列表
     * @ApiWeigh    (90)
     * @ApiTitle    (首页轮播图)
     * @ApiSummary  (首页轮播图)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/hot/banner)
     *
     * @ApiReturn({
        "code": 1,
        "msg": "success",
        "time": "1600064624",
        "data": [{
            "id": 1,
            "image": "http://community.qiniu.brotop.cn/uploads/20200910/0afb1f6a54b2ca30a2fa3f3f6cafbd3f.jpg",
            "url"://跳转地址
            "typeswitch"://开关0关1开
            "weigh": 1,
            "createtime": "2020-09-10 11:47:28"
        }]
    })
     */
    public function banner()
    {
        $data = Db::name('store_banner')
            ->field('updatetime',true)
            ->order(['weigh'=>'desc','createtime'=>'asc'])
            ->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);
    }

    /**
     * 商圈信息列表
     * @ApiWeigh    (80)
     *
     * @ApiTitle    (商圈信息列表)
     * @ApiSummary  (商圈信息列表)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/hot/store_list)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="store_id", type="integer", required=false, description="店铺id")
     * @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": 5,
            "user_id": 1,
            "store_id": 0,
            "content": "内容",
            "images": "http://cloud.caiyunpan.brotop.cn/assets/img/qrcode.png",
            "house_ids": ",1,",
            "type": 类型1=红包2=一般信息,
            "score": "5800",
            "red_package": "5000",
            "number": 红包数量,
            "single": "单人领取金额",
            "get": 已领数量,
            "surplus": 剩余数量,
            "views": 浏览量,
            "good_count": 点赞总数,
            "is_good": 是否点赞0=否1=是
            "image_arr"图片: [
                "http://cloud.caiyunpan.brotop.cn/assets/img/qrcode.png"
            ],
            "store": {
                "id": 1,
                "store_name": "店铺名称",
                "store_icon": "图标",
                "industry_id": "行业标签",
                },
            },
        ],
        "this_page": 当前页数,
        "total_page": 总页数
    }
    })
     */
    public function store_list()
    {
        if($this->request->isPost()){
            $page = $this->request->param('page',1,'intval');
            $store_id = $this->request->param('store_id',0,'intval');
//            $house_ids = $this->user_house_model->where('user_id',$this->user_id)->column('house_id');
//            $query = function ($query) use ($house_ids){
//                if($this->store_id) {
//                    $query->where('store_id',$this->store_id);
//                }
//                foreach ($house_ids as $k=>$v){
//                    $w = ['house_ids'=>['like','%,'.$v.',%']];
//                    if($k == 0) {
//                        $query->where($w);
//                    } else {
//                        $query->whereOr($w);
//                    }
//                }
//            };
            $where_h = [
                'status'=>2,
            ];
            if($store_id) {
                $where_h['store_id'] = $store_id;
            } else {
                $where_h['house_ids'] = ['like',['%'.$this->auth->house_id.'%']];
            }
            $where = [
                'where' => $where_h,
                'with' => ['store']
            ];
            $order = ['red_package'=>'DESC','surplus'=>'DESC','createtime'=>'DESC'];
            $inform = $this->store_inform_model->pageSelect($page,$where,'*',$order,config('option.num'));
            $list = $inform->items();
            $view_model = new StoreInformView();
            foreach ($list as &$v) {
                // 发布时间调整
                $v['createtime'] = tranTime($v['createtime']);
                // 获取点赞数及是否点赞
                $where_g = [
                    'object_id' => $v['id']
                ];
                $v['good_count'] = $this->store_inform_good_model->getCount($where_g);
                $where_g['user_id'] = $this->user_id;
                $v['is_good'] = $this->store_inform_good_model->getCount($where_g);
                // 记录浏览量
                $where_v = [
                    'user_id' => $this->auth->id,
                    'object_id' => $v['id']
                ];
                $view = $view_model->where($where_v)->find();
                if($view) {
                    $where_v = [
                        'id' => $view['id']
                    ];
                    $view_model->where($where_v)->setInc('count');
                } else {
                    $insert = [
                        'user_id' => $this->auth->id,
                        'object_id' => $v['id'],
                        'createtime' => time()
                    ];
                    $view_model->insertGetId($insert);
                }
                $this->store_inform_model->where('id',$v['id'])->setInc('views');
            }
            $return = [
                'list' => $list,
                'this_page' => $inform->currentPage(),
                'total_page' => $inform->lastPage()
            ];
            $this->success('请求成功',$return);
        }
    }

    /**
     * 商圈店铺主页
     * @ApiWeigh    (75)
     *
     * @ApiTitle    (商圈店铺主页)
     * @ApiSummary  (商圈店铺主页)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/hot/store_detail)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="store_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':'返回成功',
    "data": {
        "store": {
            "id": 1,
            "user_id": 1,
            "store_name": "店铺名称",
            "industry_id": "行业标签",
            "name": "测试11",
            "mobile": "联系电话",
            "store_icon": "图标",
            "province": "地址省",
            "city": "市",
            "region": "区",
            "address": "详细地址",
            "lat": "纬度",
            "lng": "经度",
            "images": "/assets/img/qrcode.png,/assets/img/qrcode.png",
            "content": "店铺详情",
            "image_arr"店铺轮播: [
                "http://cloud.caiyunpan.brotop.cn/assets/img/qrcode.png",
                "http://cloud.caiyunpan.brotop.cn/assets/img/qrcode.png"
            ]
        }
    }
    })
     */
    public function store_detail()
    {
        if($this->request->isPost()){
            $store_id = $this->request->param('store_id',0,'intval');
            $where = [
                'where' => ['id'=>$store_id]
            ];
            $store = $this->store_model->findOrFail($where);
            $return = [
                'store' => $store
            ];
            $this->success('请求成功',$return);
        }
    }

    /**
     * 点赞
     * @ApiWeigh    (61)
     *
     * @ApiTitle    (点赞)
     * @ApiSummary  (点赞)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/hot/good)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="object_id", type="int", 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':'返回成功',
    "data": {}
    })
     */
    public function good()
    {
        if($this->request->isPost()) {
            $param = (new HotValidate())->goCheck('good');
            // 判断是否点赞
            $this->good_model = new StoreInformGood();
            $where = [
                'where' => [
                    'user_id' => $this->auth->id,
                    'object_id' => $param['object_id'],
                ]
            ];
            $cancel = '';
            $user_good = $this->good_model->findOrFail($where,false);
            // 执行点赞/取消点赞操作
            Db::startTrans();
            if($user_good) {
                $cancel = '取消';
                $result = $this->good_model->where('id',$user_good['id'])->delete();
            } else {
                // 判断要点赞的数据是否存在
                $data = $this->store_inform_model->where('id',$param['object_id'])->find();
                if(!$data) {
                    Db::rollback();
                    $this->error('点赞的商圈信息不存在');
                }
                $insert = [
                    'user_id' => $this->auth->id,
                    'object_id' => $param['object_id'],
                ];
                $result = $this->good_model->save($insert);
            }
            if(!$result) {
                Db::rollback();
                $this->error($cancel.'点赞失败');
            }
            Db::commit();
            $this->success($cancel.'点赞成功');
        }
    }

    /**
     * 领取红包
     * @ApiWeigh    (60)
     *
     * @ApiTitle    (领取红包)
     * @ApiSummary  (领取红包)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/hot/get_red_package)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="store_inform_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':'返回成功',
    "data": {
    }
    })
     */
    public function get_red_package()
    {
        if($this->request->isPost()){
            $param = (new HotValidate())->goCheck('get_red_package');
            $where = [
                'where' => ['id'=>$param['store_inform_id'],'status'=>2]
            ];
            $inform = $this->store_inform_model->findOrFail($where);
            if($inform['type'] == 2) {
                $this->error('一般信息无法领取红包');
            }
            if($inform['surplus'] == 0) {
                $this->error('红包已抢完');
            }
            $log_model = new StoreInformLog();
            $user_model = new \app\api\model\User();
            $money_log_model = new UserMoneyLog();
            $where_l = [
                'where' => [
                    'user_id' => $this->auth->id,
                    'inform_id' => $inform['id'],
                ]
            ];
            $log = $log_model->findOrFail($where_l,false);
            if($log) {
                $this->error('已领取过该商圈红包');
            }
            Db::startTrans();
            // 录入领取记录
            $log_data = [
                'user_id' => $this->auth->id,
                'inform_id' => $inform['id'],
                'money' => $inform['single']
            ];
            $res_log = $log_model->add($log_data);
            // 修改已领取、剩余红包数量
            $inform_edit = [
                'id' => $inform['id'],
                'get' => $inform['get'] + 1,
                'surplus' => $inform['number'] - $inform['get'] - 1,
            ];
            $res_inform = $this->store_inform_model->edit($inform_edit);
            // 新增用户余额
            $res_user = $user_model->where('id',$this->auth->id)->setInc('money',$inform['single']);
            // 新增余额记录
            $money_log_data = [
                'user_id' => $this->auth->id,
                'money' => $inform['single'],
                'before' => $this->auth->money,
                'after' => bcadd($this->auth->money,$inform['single'],2),
                'memo' => '领取红包'
            ];
            $res_moeny_log = $money_log_model->add($money_log_data);
            if(!$res_log || !$res_inform || !$res_user || !$res_moeny_log) {
                Db::rollback();
                $this->error('红包领取失败');
            }
            Db::commit();
            $this->success('领取成功');
        }
    }

    /**
     * 留言列表
     * @ApiWeigh    (50)
     *
     * @ApiTitle    (留言列表)
     * @ApiSummary  (留言列表)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/hot/comment_list)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="store_id", type="integer", required=true, description="店铺id")
     * @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':'返回成功'
    })
     */
    public function comment_list()
    {
        $param = (new HotValidate())->goCheck('common');
        $where = [
            'where' => ['user_id'=>$this->auth->id,'store_id' => $param['store_id']]
        ];
        $model = new StoreComment();
        $order = ['createtime'=>'DESC'];
        $comment = $model->pageSelect($param['page'],$where,'*',$order,config('option.num'));
        $list = $comment->items();
        if($list) {
            foreach ($list as &$v) {
                $v['is_self'] = $v['type'] == 1 ? 1 : 0;
                if($v['is_self'] == 1) {
                    $user = $this->auth->getUserinfo();
                    $v['nickname'] = $user['nickname'];
                    $v['avatar'] = $user['avatar'];
                } else {
                    $where_s = [
                        'where' => [
                            'id' => $v['store_id']
                        ]
                    ];
                    $store = $this->store_model->findOrFail($where_s,false,'id,store_name as nickname,store_icon as avatar');
                    $v['nickname'] = $store['nickname'];
                    $v['avatar'] = !empty($store['avatar']) ? cdnurl($store['avatar']) : request()->domain().'/assets/img/avatar.png';
                }
            }
//            $list = array_sort($list,'id',SORT_ASC);
            array_multisort(array_column($list,'createtime'),SORT_ASC,$list);
        }
        $return = [
            'list' => $list,
            'this_page' => $comment->currentPage(),
            'total_page' => $comment->lastPage()
        ];
        $this->success('成功',$return);
    }

    /**
     * 留言提交
     * @ApiWeigh    (50)
     *
     * @ApiTitle    (留言提交)
     * @ApiSummary  (留言提交)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/hot/comment_add)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     * @ApiParams   (name="store_id", type="integer", required=true, description="店铺id")
     * @ApiParams   (name="content", type="string", required=true, description="留言内容")
     * @ApiParams   (name="image", 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_add()
    {
        $param = (new HotValidate())->goCheck('comment_add');
        if(empty($param['content']) && empty($param['image'])) {
            $this->error('请填写内容或上传图片');
        }
        $where = [
            'where' => ['id' => $param['store_id']]
        ];
        $store = $this->store_model->findOrFail($where);
        Db::startTrans();
        $result = false;
        try{
            $param['user_id'] = $this->auth->id;
            $param['store_user_id'] = $store['user_id'];
            $model = new StoreComment();
            $result = $model->add($param);
            // 记录最新内容
            $msg_model = new Message();
            $where_m = [
                'user_id' => $this->auth->id,
                'object_id' => $store['id'],
                'object_user_id' => $store['user_id'],
                'type' => 2
            ];
            $msg = $msg_model->where($where_m)->find();
            if($msg) {
                $update = [
                    'id' => $msg['id'],
                    'content' => $param['content'],
                    'image' => $param['image'],
                    'is_read_user' => 1,
                    'is_read_object' => 2,
                ];
                $res_msg = $msg_model->edit($update);
                $msg_id = $msg['id'];
            } else {
                $insert = $where_m;
                $insert['type'] = 2;
                $insert['content'] = $param['content'];
                $insert['image'] = $param['image'];
                $insert['is_read_user'] = 1;
                $res_msg = $msg_model->add($insert);
                $msg_id = $msg_model->id;
            }
            // 发送模板消息
            $send_data = array(
                "first"  => '您有一条新的消息',
                'keyword1' => $param['content'] ? $param['content'] : '【图片消息】',
                "keyword2"  => date('Y-m-s H:i:s',time()),
                "remark" => ['点击查看详情','#FF0000'],
            );
            $openid = Db::name('third')->where('user_id',$store['user_id'])->value('openid');
            $url = config('option.vue_url') . '/messageto?is_template=1&id='.$msg_id;
            (new \app\index\controller\Ajax)->wxsendmessage($openid,$send_data,config('option.template')['msg'],$url);
            Db::commit();
        } catch (PDOException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
        if(!$result || !$res_msg) {
            $this->error('留言失败');
        }
        $this->success('留言成功');
    }
}