审查视图

application/api/controller/Pay.php 32.1 KB
郭盛 authored
1 2 3 4 5 6 7 8 9 10 11 12 13 14
<?php

namespace app\api\controller;

use app\common\controller\Api;
use EasyWeChat\Factory;
use function GuzzleHttp\Promise\inspect;
use think\Db;
use app\admin\model\User;
use think\Log;
use fast\Http;
use think\Validate;
use Exception;
use function EasyWeChat\Kernel\Support\generate_sign;
郭盛 authored
15
use app\nsms\nsms;
郭盛 authored
16 17 18 19 20
/**
 * 支付接口
 */
class Pay extends Api
{
郭盛 authored
21
    protected $noNeedLogin = ['test','payOrderNotify','vippayOrderNotify','picOrderNotify','videoOrderNotify'];
郭盛 authored
22
    protected $noNeedRight = ['*'];
郭盛 authored
23 24 25 26 27 28 29 30 31
    protected $uid = '';//token存贮uid
    protected $order_status = [];//订单状态
    public function _initialize()
    {
        parent::_initialize();
        $this->uid = $this->auth->getUserId();
    }

    /**
32
     * @ApiTitle    (充值支付)
郭盛 authored
33 34 35 36 37
     * @ApiSummary  (充值支付)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/pay/pay)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
38
     * @ApiParams   (name="order_id", type="inter", required=true, description="订单id")
郭盛 authored
39 40 41
     *
     */
    public function pay(){
42
        $rule = config('verify.path');
郭盛 authored
43
        if($this->request->isPost()){
44 45
            $order_id = $this->request->post('order_id');
            $openid = $this->getopenid();
郭盛 authored
46 47 48
            if(empty($openid)){
                $this->error(['code'=>2,'msg'=>'openid不能为空']);
            }
49 50 51 52
            $data = Db::name('toporder')->where('id',$order_id)->find();
            if($data){
                if($data['status'] == 2){
                    $this->error('该订单已支付过了');
郭盛 authored
53 54 55 56 57 58 59 60
                }else{
                    //创建支付对象
                    $config = config('verify.wx_pay');
                    $app = Factory::payment($config);
                    $result = $app->order->unify([
                        'body' => '山东航拍',
                        'out_trade_no' => $data['num'],//支付订单号
                        'total_fee' => $data['money']*100,//单位分
郭盛 authored
61
                        'notify_url' => 'https://areial.w.broing.cn/api/pay/payOrderNotify', // 支付结果通知网址,如果不设置则会使用配置里的默认地址
郭盛 authored
62
                        'trade_type' => 'JSAPI', // 请对应换成你的支付方式对应的值类型
郭盛 authored
63
                        'openid' => $openid['openid'],
郭盛 authored
64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87
                    ]);
                    if($result['return_code'] === 'SUCCESS' && $result['result_code'] === 'SUCCESS'){
                        $params = [
                            'appId'     => $config['app_id'],
                            'timeStamp' => time(),
                            'nonceStr'  => $result['nonce_str'], // 统一下单返回的随机字符串
                            'package'   => 'prepay_id='.$result['prepay_id'], // 统一下单Id
                            'signType'  => 'MD5', // 签名方法
                        ];
                        // 注意这里用的是商户平台的Key进行二次签名
                        $params['paySign'] = generate_sign($params, $config['key']);
                        $this->success('成功',$params);
                    }
                    $this->error($result['err_code_des']);
                }
            }else{
                $this->error('无效的订单');
            }
        }else{
            $this->error('请求方式错误');
        }
    }

    /**
郭盛 authored
88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115
     * @ApiTitle    (开通会员支付)
     * @ApiSummary  (开通会员支付)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/pay/vippay)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="order_id", type="inter", required=true, description="订单id")
     *
     */
    public function vippay(){
        $rule = config('verify.path');
        if($this->request->isPost()){
            $order_id = $this->request->post('order_id');
            $openid = $this->getopenid();
            if(empty($openid)){
                $this->error(['code'=>2,'msg'=>'openid不能为空']);
            }
            $data = Db::name('viporder')->where('id',$order_id)->find();
            if($data){
                if($data['status'] == 2){
                    $this->error('该订单已支付过了');
                }else{
                    //创建支付对象
                    $config = config('verify.wx_pay');
                    $app = Factory::payment($config);
                    $result = $app->order->unify([
                        'body' => '山东航拍',
                        'out_trade_no' => $data['num'],//支付订单号
郭盛 authored
116
                        'total_fee' => $data['total']*100,//单位分
郭盛 authored
117
                        'notify_url' => 'https://areial.w.broing.cn/api/pay/vippayOrderNotify', // 支付结果通知网址,如果不设置则会使用配置里的默认地址
郭盛 authored
118
                        'trade_type' => 'JSAPI', // 请对应换成你的支付方式对应的值类型
郭盛 authored
119
                        'openid' => $openid['openid'],
郭盛 authored
120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143
                    ]);
                    if($result['return_code'] === 'SUCCESS' && $result['result_code'] === 'SUCCESS'){
                        $params = [
                            'appId'     => $config['app_id'],
                            'timeStamp' => time(),
                            'nonceStr'  => $result['nonce_str'], // 统一下单返回的随机字符串
                            'package'   => 'prepay_id='.$result['prepay_id'], // 统一下单Id
                            'signType'  => 'MD5', // 签名方法
                        ];
                        // 注意这里用的是商户平台的Key进行二次签名
                        $params['paySign'] = generate_sign($params, $config['key']);
                        $this->success('成功',$params);
                    }
                    $this->error($result['err_code_des']);
                }
            }else{
                $this->error('无效的订单');
            }
        }else{
            $this->error('请求方式错误');
        }
    }

    /**
郭盛 authored
144 145 146 147 148 149 150
     * @ApiTitle    (图片购买支付)
     * @ApiSummary  (图片购买支付)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/pay/picpay)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="order_id", type="inter", required=true, description="订单id")
郭盛 authored
151
     * @ApiParams   (name="type", type="inter", required=true, description="支付方式 1 为余额支付 2为微信支付")
郭盛 authored
152 153 154 155 156 157
     *
     */
    public function picpay(){
        $rule = config('verify.path');
        if($this->request->isPost()){
            $order_id = $this->request->post('order_id');
郭盛 authored
158
            $type = $this->request->post('type');
郭盛 authored
159
            //判断付费类型
郭盛 authored
160 161 162
            if(empty($type)){
                $this->error(['code'=>2,'msg'=>'缺少必要参数']);
            }
郭盛 authored
163
            $openid = $this->getopenid();
郭盛 authored
164
            //判断openid
郭盛 authored
165 166 167 168
            if(empty($openid)){
                $this->error(['code'=>2,'msg'=>'openid不能为空']);
            }
            $data = Db::name('order')->where('id',$order_id)->find();
郭盛 authored
169
            $pic_id = [];
郭盛 authored
170
            if(!empty($data['pic_id'])){
郭盛 authored
171 172
                $pic_id = explode(',',$data['pic_id']);
            }
郭盛 authored
173
            $video_id = unserialize($data['video_id']);
郭盛 authored
174
            //查询用户表 取出手机号
郭盛 authored
175 176
            $user = Db::name('user')->where('id',$data['user_id'])->find();
            $mobile = $user['mobile'];
郭盛 authored
177
            $str = "【仁甲看见SHOP】,感谢您购买仁甲看见SHOP素材。";
郭盛 authored
178
郭盛 authored
179 180 181 182 183
            if($type == 1){
                if($data){
                    if($data['status'] == 2){
                        $this->error('该订单已支付过了');
                    }else{
郭盛 authored
184
                        //判断总价是否正确
郭盛 authored
185
                        if($data['total'] > $user['money']){
郭盛 authored
186 187
                            $this->error(['code'=>2,'msg'=>'余额不足,请充值后重试']);
                        }
郭盛 authored
188
                        $money = $user['money'] - $data['total'];
郭盛 authored
189
                        $uid = $this->uid;
郭盛 authored
190 191
                        $login = Db::name('user')
                            ->where('id',$uid)
郭盛 authored
192
                            ->field('id,is_vip')
郭盛 authored
193
                            ->find();
郭盛 authored
194 195 196
                        // 启动事务
                        Db::startTrans();
                        try{
郭盛 authored
197
                            if(!empty($pic_id)){
郭盛 authored
198 199
                                //将购买次数加1
                                foreach ($pic_id as $key => $v){
郭盛 authored
200
                                    //非会员
郭盛 authored
201
                                    if($login['is_vip'] == 0){
郭盛 authored
202 203
                                        $pic = Db::name('pic')->field('id,price,buy_num,money')->where('id',$v)->find();
                                        Db::name('pic')->where('id',$pic['id'])->update(['buy_num'=>$pic['buy_num']+1,'money'=>$pic['money']+$pic['price']]);
郭盛 authored
204 205
                                    }else{
                                        //是会员
郭盛 authored
206
                                        $pic = Db::name('pic')->field('id,price,buy_num,money')->where('id',$v)->find();
郭盛 authored
207
                                        $total_money = $pic['money'] + ($pic['price']*0.75);
郭盛 authored
208
                                        Db::name('pic')->where('id',$pic['id'])->update(['buy_num'=>$pic['buy_num']+1,'money'=>$total_money]);
郭盛 authored
209
                                    }
郭盛 authored
210
                                }
郭盛 authored
211 212 213 214 215
                                //拼接发送短信的内容
                                foreach ($pic_id as $key => $v){
                                    $pic = Db::name('pic')->field('id,title,url,code')->where('id',$v)->find();
                                    $str .= "图片标题:$pic[title],云盘地址:$pic[url],提取码:$pic[code],";
                                }
郭盛 authored
216 217
                            }
                            if(!empty($video_id)){
郭盛 authored
218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246
                                //判断是否为会员
                                if($login['is_vip'] == 0){
                                    //不是会员的情况
                                    //将购买次数加1
                                    foreach ($video_id as $key => $val){
                                        $video = Db::name('video')->field('id,buy_num,price,four_price,eight_price,money')->where('id',$val['id'])->find();
                                        if($val['attr'] == 1){
                                            $video_money = $video['money'] + $video['price'];
                                        }elseif ($val['attr'] == 2){
                                            $video_money = $video['money'] + $video['four_price'];
                                        }else{
                                            $video_money = $video['money'] + $video['eight_price'];
                                        }
                                        Db::name('video')->where('id',$video['id'])->update(['buy_num'=>$video['buy_num']+1,'money'=>$video_money]);
                                    }
                                }else{
                                    //是会员的情况
                                    //将购买次数加1
                                    foreach ($video_id as $key => $val){
                                        $video = Db::name('video')->field('id,buy_num,price,four_price,eight_price,money')->where('id',$val['id'])->find();
                                        if($val['attr'] == 1){
                                            $video_money = $video['money'] + ($video['price']*0.75);
                                        }elseif ($val['attr'] == 2){
                                            $video_money = $video['money'] + ($video['four_price']*0.75);
                                        }else{
                                            $video_money = $video['money'] + ($video['eight_price']*0.75);
                                        }
                                        Db::name('video')->where('id',$video['id'])->update(['buy_num'=>$video['buy_num']+1,'money'=>$video_money]);
                                    }
郭盛 authored
247
                                }
郭盛 authored
248
郭盛 authored
249
                                //判断视频的属性
郭盛 authored
250 251 252 253 254 255 256 257 258
                                foreach ($video_id as &$val){
                                    if($val['attr'] == 1){
                                        $val['attr'] = '2k';
                                    }elseif ($val['attr'] == 2){
                                        $val['attr'] = '4k';
                                    }else{
                                        $val['attr'] = '8k';
                                    }
                                }
郭盛 authored
259
                                //拼接发送短信的内容
郭盛 authored
260 261 262 263 264 265 266 267 268 269 270 271 272
                                foreach ($video_id as $k=>$v){
                                    if($v['attr'] == '4k'){
                                        $video = Db::name('video')->field('id,title,four_url,four_code')->where('id',$v['id'])->find();
                                        $str .= "视频标题:$video[title],云盘地址:$video[four_url],提取码:$video[four_code]";
                                    }elseif ($v['attr'] == '2k'){
                                        $video = Db::name('video')->field('id,title,two_url,two_code')->where('id',$v['id'])->find();
                                        $str .= "视频标题:$video[title],云盘地址:$video[two_url],提取码:$video[two_code]";
                                    }elseif ($v['attr'] == '8k'){
                                        $video = Db::name('video')->field('id,title,eight_url,eight_code')->where('id',$v['id'])->find();
                                        $str .= "视频标题:$video[title],云盘地址:$video[eight_url],提取码:$video[eight_code]";
                                    }
                                }
                            }
郭盛 authored
273
                            //发送短信
郭盛 authored
274 275 276
                            if(!empty($mobile)){
                                $result = $this->sms($mobile,$str);
                            }
郭盛 authored
277 278 279 280 281 282 283 284 285 286 287
                            $arr = Db::name('user')->where('id',$data['user_id'])->update(['money'=>$money]);
                            $res = Db::name('order')->where('id',$order_id)->update(['status'=>2,'paytime'=>time()]);
                            if($res && $arr){
                                true;
                            }
                            // 提交事务
                            Db::commit();
                        } catch (\Exception $e) {
                            dump($e->getMessage());
                            // 回滚事务
                            Db::rollback();
郭盛 authored
288
                            $this->error('购买失败');
郭盛 authored
289
                        }
郭盛 authored
290
                        $this->success('SUCCESS','支付成功');
291
                    }
郭盛 authored
292 293
                }else{
                    $this->error('无效的订单');
郭盛 authored
294
                }
295
            }else{
郭盛 authored
296 297 298 299 300 301 302 303 304 305 306
                if($data){
                    if($data['status'] == 2){
                        $this->error('该订单已支付过了');
                    }else{
                        //创建支付对象
                        $config = config('verify.wx_pay');
                        $app = Factory::payment($config);
                        $result = $app->order->unify([
                            'body' => '山东航拍',
                            'out_trade_no' => $data['num'],//支付订单号
                            'total_fee' => $data['total']*100,//单位分
郭盛 authored
307
                            'notify_url' => 'https://areial.w.broing.cn/api/pay/picOrderNotify', // 支付结果通知网址,如果不设置则会使用配置里的默认地址
郭盛 authored
308
                            'trade_type' => 'JSAPI', // 请对应换成你的支付方式对应的值类型
郭盛 authored
309
                            'openid' => $openid['openid'],
郭盛 authored
310 311 312 313 314 315 316 317 318 319 320 321 322 323
                        ]);
                        if($result['return_code'] === 'SUCCESS' && $result['result_code'] === 'SUCCESS'){
                            $params = [
                                'appId'     => $config['app_id'],
                                'timeStamp' => time(),
                                'nonceStr'  => $result['nonce_str'], // 统一下单返回的随机字符串
                                'package'   => 'prepay_id='.$result['prepay_id'], // 统一下单Id
                                'signType'  => 'MD5', // 签名方法
                            ];
                            // 注意这里用的是商户平台的Key进行二次签名
                            $params['paySign'] = generate_sign($params, $config['key']);
                            $this->success('成功',$params);
                        }
                        $this->error($result['err_code_des']);
郭盛 authored
324
郭盛 authored
325 326 327 328
                    }
                }else{
                    $this->error('无效的订单');
                }
郭盛 authored
329 330 331 332 333 334
            }
        }else{
            $this->error('请求方式错误');
        }
    }
郭盛 authored
335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352

    /**
     * @ApiTitle    (预约拍摄)
     * @ApiSummary  (预约拍摄)
     * @ApiMethod   (POST)
     * @ApiRoute    (/api/pay/appointment)
     * @ApiHeaders  (name=token, type=string, required=true, description="请求的Token")
     *
     * @ApiParams   (name="phone", type="inter", required=true, description="手机号")
     *
     */
    public function appointment()
    {
        $u_id = $this->uid;
        $phone = $this->request->param('phone');
        if(empty($phone)){
            $this->error('缺少必要参数');
        }
郭盛 authored
353 354
        $mobile = 13780608990;
        $content = "【仁甲看见SHOP】提醒您,您有新预约客户,客户电话为:$phone ,请您及时回复!";
郭盛 authored
355 356
        //发送短信
        $result = $this->sms($mobile,$content);
郭盛 authored
357 358 359 360 361
        if($result == 1){
            $this->success('success','成功');
        }else{
            $this->error('失败');
        }
郭盛 authored
362 363
    }
郭盛 authored
364 365 366 367 368
    //发送短信
    public function sms($mobile,$content){
        $note = array(
            'content' 	=> $content,//短信内容
            'mobile' 	=> $mobile,//手机号码
郭盛 authored
369
            'productid' => '676767',//模板id
郭盛 authored
370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386
            'xh'		=> ''//小号
        );
        $result = $this->send_sms($note);
        return $result;
    }
    function send_sms($data){
        //todo 短信账号密码
//        require_once EXTEND_PATH . 'nsms/nsms.php';
        $url 		= "http://www.ztsms.cn/sendNSms.do";
        $username 	= 'hangpai';
        $password 	= 'Cxz307312';
        $sendAPI = new nsms($url, $username, $password);
        $sendAPI->data = $data;/*初始化数据包*/
        $return = $sendAPI->sendSMS('POST');
        return $return;
    }
387
    //支付订单结果通知(无需调用)
郭盛 authored
388 389 390 391
    public function payOrderNotify(){
        $config = config('verify.wx_pay');
        $app = Factory::payment($config);
        $response = $app->handlePaidNotify(function($message, $fail){
392 393 394
            $data = Db::name('toporder')
                ->where('num',$message['out_trade_no'])
                ->find();
郭盛 authored
395 396 397 398 399
            //return_code 表示通信状态
            if ($message['return_code'] === 'SUCCESS') {

                if ($message['result_code'] === 'SUCCESS') {
                    //支付成功,更新订单状态
400 401 402 403 404 405
                    $toporder['status'] = 2;
                    $toporder['paytime'] = time();
                    $money = $data['money'];
                    // 启动事务
                    Db::startTrans();
                    try{
郭盛 authored
406 407 408 409 410 411
                        //判断用户充值金额是否大于等于8000
                        if($data['money']>=8000){
                            //大于等于的情况
                            $res = Db::name('toporder')->where('num',$message['out_trade_no'])->update($toporder);
                            $arr = Db::name('user')->where('id',$data['user_id'])->find();
                            //判断用户是否已经是会员了
郭盛 authored
412
                            if($arr['is_vip'] == 1){
郭盛 authored
413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431
                                //已经是会员
                                $list['money'] = $arr['money'] + $money;
                                $info = Db::name('user')->where('id',$data['user_id'])->update(['money'=>$list['money']]);
                                if($res && $info){
                                    true;
                                }
                                // 提交事务
                                Db::commit();
                            }else{
                                //不是会员
                                $list['money'] = $arr['money'] + $money;
                                $list['is_vip'] = 1;
                                $info = Db::name('user')->where('id',$data['user_id'])->update($list);
                                if($res && $info){
                                    true;
                                }
                                // 提交事务
                                Db::commit();
                            }
432
                        }else{
郭盛 authored
433 434 435 436 437 438
                            //小于8000的情况
                            $res = Db::name('toporder')->where('num',$message['out_trade_no'])->update($toporder);
                            $arr = Db::name('user')->where('id',$data['user_id'])->find();
                            $list['money'] = $arr['money'] + $money;
                            $info = Db::name('user')->where('id',$data['user_id'])->update(['money'=>$list['money']]);
                            if($res && $info){
郭盛 authored
439 440 441 442 443
                                true;
                            }
                            // 提交事务
                            Db::commit();
                        }
郭盛 authored
444
                        $this->success('SUCCESS');
郭盛 authored
445 446 447 448
                    } catch (\Exception $e) {
                        dump($e->getMessage());
                        // 回滚事务
                        Db::rollback();
郭盛 authored
449
                        $this->error(['code'=>2,'msg'=>'充值失败']);
郭盛 authored
450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482
                    }
                }else{
                    //支付失败
                    Db::name('toporder')->where('num',$message['out_trade_no'])->update(['status'=>1]);
                }
            }else{
                return $fail('通信失败,请稍后再通知我');
            }
            return true; // 返回处理完成
        });
        $response->send();
    }

    //支付开通会员结果通知(无需调用)
    public function vippayOrderNotify(){
        $config = config('verify.wx_pay');
        $app = Factory::payment($config);
        $response = $app->handlePaidNotify(function($message, $fail){
            $data = Db::name('viporder')
                ->where('num',$message['out_trade_no'])
                ->find();
            //return_code 表示通信状态
            if ($message['return_code'] === 'SUCCESS') {

                if ($message['result_code'] === 'SUCCESS') {
                    //支付成功,更新订单状态
                    $toporder['status'] = 2;
                    $toporder['paytime'] = time();
                    $money = $data['money'];
                    // 启动事务
                    Db::startTrans();
                    try{
                        //判断用户充值金额是否大于等于8000
郭盛 authored
483
                        if($data['money']>=8000){
郭盛 authored
484
                            //大于等于的情况
郭盛 authored
485
                            $res = Db::name('viporder')->where('num',$message['out_trade_no'])->update($toporder);
郭盛 authored
486 487 488 489 490 491 492 493 494 495 496 497
                            $arr = Db::name('user')->where('id',$data['user_id'])->find();
                            //不是会员
                            $list['money'] = $arr['money'] + $money;
                            $list['is_vip'] = 1;
                            $info = Db::name('user')->where('id',$data['user_id'])->update($list);
                            if($res && $info){
                                true;
                            }
                            // 提交事务
                            Db::commit();
                        }else{
                            //小于8000的情况
郭盛 authored
498
                            $res = Db::name('viporder')->where('num',$message['out_trade_no'])->update($toporder);
郭盛 authored
499 500 501 502
                            $arr = Db::name('user')->where('id',$data['user_id'])->find();
                            $list['money'] = $arr['money'] + $money;
                            $info = Db::name('user')->where('id',$data['user_id'])->update(['money'=>$list['money']]);
                            if($res && $info){
郭盛 authored
503 504 505 506
                                true;
                            }
                            // 提交事务
                            Db::commit();
507
                        }
郭盛 authored
508
                        $this->success('SUCCESS','支付成功');
509 510 511 512
                    } catch (\Exception $e) {
                        dump($e->getMessage());
                        // 回滚事务
                        Db::rollback();
郭盛 authored
513
                        $this->error(['code'=>2,'msg'=>'开通会员失败']);
514 515
                    }
                }else{
郭盛 authored
516
                    //支付失败
郭盛 authored
517 518
                    Db::name('viporder')->where('num',$message['out_trade_no'])->update(['status'=>1]);
                    $this->error(['code'=>2,'msg'=>'支付失败']);
郭盛 authored
519
                }
520
            }else{
郭盛 authored
521 522 523 524 525 526
                return $fail('通信失败,请稍后再通知我');
            }
            return true; // 返回处理完成
        });
        $response->send();
    }
郭盛 authored
527
    
郭盛 authored
528 529 530 531
    //图片支付订单结果通知(无需调用)
    public function picOrderNotify(){
        $config = config('verify.wx_pay');
        $app = Factory::payment($config);
郭盛 authored
532
郭盛 authored
533
        $response = $app->handlePaidNotify(function($message, $fail){
郭盛 authored
534 535 536 537 538 539 540 541 542 543 544 545 546

            //找到该订单信息
            $data = Db::name('order')->where('num',$message['out_trade_no'])->find();
            $pic_id = [];
            if(!empty($data['pic_id'])){
                $pic_id = explode(',',$data['pic_id']);
            }
            $video_id = unserialize($data['video_id']);
            //查询该用户信息以及是否为会员身份
            $user = Db::name('user')->where('id',$data['user_id'])->find();
            $mobile = $user['mobile'];
            $str = "【仁甲看见SHOP】,感谢您购买仁甲看见SHOP素材。";
郭盛 authored
547 548 549
            //return_code 表示通信状态
            if ($message['return_code'] === 'SUCCESS') {
                if ($message['result_code'] === 'SUCCESS') {
郭盛 authored
550 551
                    //图片
                    if(!empty($pic_id)){
郭盛 authored
552 553 554
                        //将购买次数加1
                        foreach ($pic_id as $key => $v){
                            //非会员
郭盛 authored
555
                            if($user['is_vip'] == 0){
郭盛 authored
556
                                $pic = Db::name('pic')->field('id,price,buy_num,money')->where('id',$v)->find();
郭盛 authored
557
                                Db::name('pic')->where('id',$pic['id'])->update(['buy_num'=>$pic['buy_num']+1,'money'=>$pic['money']+$pic['price']]);
558
                            }else{
郭盛 authored
559
                                //是会员
郭盛 authored
560
                                $pic = Db::name('pic')->field('id,price,buy_num,money')->where('id',$v)->find();
郭盛 authored
561 562
                                $total_money = $pic['money'] + ($pic['price']*0.75);
                                Db::name('pic')->where('id',$pic['id'])->update(['buy_num'=>$pic['buy_num']+1,'money'=>$total_money]);
563
                            }
郭盛 authored
564
                        }
郭盛 authored
565 566 567 568 569
                        //拼接发送短信的内容
                        foreach ($pic_id as $key => $v){
                            $pic = Db::name('pic')->field('id,title,url,code')->where('id',$v)->find();
                            $str .= "图片标题:$pic[title],云盘地址:$pic[url],提取码:$pic[code],";
                        }
郭盛 authored
570
                    }
郭盛 authored
571 572
                    //视频
                    if(!empty($video_id)){
郭盛 authored
573
                        //判断是否为会员
郭盛 authored
574
                        if($user['is_vip'] == 0){
郭盛 authored
575 576 577 578
                            //不是会员的情况
                            //将购买次数加1
                            foreach ($video_id as $key => $val){
                                $video = Db::name('video')->field('id,buy_num,price,four_price,eight_price,money')->where('id',$val['id'])->find();
郭盛 authored
579
                                if($val['attr'] == 1){
郭盛 authored
580
                                    $video_money = $video['money'] + $video['price'];
郭盛 authored
581
                                }elseif ($val['attr'] == 2){
郭盛 authored
582
                                    $video_money = $video['money'] + $video['four_price'];
郭盛 authored
583
                                }else{
郭盛 authored
584
                                    $video_money = $video['money'] + $video['eight_price'];
郭盛 authored
585
                                }
郭盛 authored
586
                                Db::name('video')->where('id',$video['id'])->update(['buy_num'=>$video['buy_num']+1,'money'=>$video_money]);
郭盛 authored
587
                            }
郭盛 authored
588 589 590 591 592 593 594 595 596 597 598
                        }else{
                            //是会员的情况
                            //将购买次数加1
                            foreach ($video_id as $key => $val){
                                $video = Db::name('video')->field('id,buy_num,price,four_price,eight_price,money')->where('id',$val['id'])->find();
                                if($val['attr'] == 1){
                                    $video_money = $video['money'] + ($video['price']*0.75);
                                }elseif ($val['attr'] == 2){
                                    $video_money = $video['money'] + ($video['four_price']*0.75);
                                }else{
                                    $video_money = $video['money'] + ($video['eight_price']*0.75);
郭盛 authored
599
                                }
郭盛 authored
600
                                Db::name('video')->where('id',$video['id'])->update(['buy_num'=>$video['buy_num']+1,'money'=>$video_money]);
郭盛 authored
601 602
                            }
                        }
郭盛 authored
603 604 605 606 607 608 609 610 611 612

                        //判断视频的属性
                        foreach ($video_id as &$val){
                            if($val['attr'] == 1){
                                $val['attr'] = '2k';
                            }elseif ($val['attr'] == 2){
                                $val['attr'] = '4k';
                            }else{
                                $val['attr'] = '8k';
                            }
郭盛 authored
613
                        }
郭盛 authored
614 615 616 617 618 619 620 621 622 623 624 625
                        //拼接发送短信的内容
                        foreach ($video_id as $k=>$v){
                            if($v['attr'] == '4k'){
                                $video = Db::name('video')->field('id,title,four_url,four_code')->where('id',$v['id'])->find();
                                $str .= "视频标题:$video[title],云盘地址:$video[four_url],提取码:$video[four_code]";
                            }elseif ($v['attr'] == '2k'){
                                $video = Db::name('video')->field('id,title,two_url,two_code')->where('id',$v['id'])->find();
                                $str .= "视频标题:$video[title],云盘地址:$video[two_url],提取码:$video[two_code]";
                            }elseif ($v['attr'] == '8k'){
                                $video = Db::name('video')->field('id,title,eight_url,eight_code')->where('id',$v['id'])->find();
                                $str .= "视频标题:$video[title],云盘地址:$video[eight_url],提取码:$video[eight_code]";
                            }
郭盛 authored
626
                        }
郭盛 authored
627
                    }
郭盛 authored
628 629 630 631 632
                    //发送短信
                    if(!empty($mobile)){
                        $result = $this->sms($mobile,$str);
                    }
                    //支付成功,更新订单状态
郭盛 authored
633
                    $toporder['status'] = 2;
郭盛 authored
634
                    $toporder['paytime'] = time();
郭盛 authored
635 636 637 638
                }else{
                    //支付失败
                    $toporder['status'] = 1;
                }
郭盛 authored
639
                Db::name('order')->where('num',$message['out_trade_no'])->update($toporder);
郭盛 authored
640 641 642
            }else{
                return $fail('通信失败,请稍后再通知我');
            }
郭盛 authored
643
            return true;
郭盛 authored
644 645 646 647 648 649 650 651 652 653 654 655 656 657 658
        });
        $response->send();
    }

    //获取用户openid
    public function getopenid()
    {
        $user_id = $this->uid;
        $openid = Db::name('user')
            ->where('id',$user_id)
            ->field('openid')
            ->find();

        return $openid;
    }
郭盛 authored
659
}