NN2022081301/application/api/controller/v1/Taxi.php

<?php


namespace app\api\controller\v1;

use app\api\controller\ApiController;
use app\api\service\SmsCode;
use app\common\validate\IDMustBePositiveInt;
use EasyWeChat\Factory;
use think\facade\Cache;

class Taxi extends ApiController
{
    /**
     * 获取车辆
     *
     * @url GET /taxi/nearby?page=1
     * @author 许祖兴 < zuxing.xu@lettered.cn>
     * @date 2020/7/3 16:29
     *
     * @return \think\response\Json
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function getNearby()
    {
        $param = $this->request->param();
        $param['category_id'] = $this->request->param('category_id', 0);
        $limit = 10;

        $map['status'] = 1;
        if ($param['category_id']) {
            $map['category_id'] = $param['category_id'];
        }

        //
        $taxi = model('common/Taxi')->with(['user'])
            ->where($map)
            ->select();

        return $this->ApiJson(0,'获取成功', $taxi);
    }


    /**
     * 用车信息
     *
     * @url GET /taxi/:id
     * @author 许祖兴 < zuxing.xu@lettered.cn>
     * @date 2020/7/1 10:37
     *
     * @param int $id 用车ID
     * @return \think\response\Json
     * @throws \Lettered\Support\Exceptions\EvidentException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function getTaxiByID($id)
    {
        (new IDMustBePositiveInt())->valid();

        $taxi =  model('common/Taxi')->with(['user'])->hidden(['user.id_card'])
            ->find($id);
        if (!$taxi){

            return $this->ApiJson(-1, '不存在用车编号');
        }

        return $this->ApiJson(0, '获取用车信息成功', $taxi);
    }

    /**
     * 用车
     */
    public function callTaxi()
    {
        $params = $this->request->param();
        // 参数校验
        $valid = $this->validate($params, [
            'taxi_id|关联车辆' => 'require',
            'mobile|联系方式' => 'require',
            'count|乘车人数' => 'require',
            'depart|起始位置' => 'require',
            'arrive|送达位置' => 'require',
            'km|公里数' => 'require',
            'price|价格' => 'require',
        ]);
        // 错误返回
        if(true !== $valid){
            return $this->ApiJson(-1, $valid);
        };
        $user = $this->auth->user();
        // 统计订单
        $count = model('common/TaxiOrder')->where('status','>=','2')->where(['is_free' => '1','user_id' =>  $user['id']])->count('id');

        // 创建订单
        $params['order_no'] = get_order_no();
        $params['user_id'] = $user['id'];
 
        $order = model('common/TaxiOrder')::create($params,true);
        // 
        if ($order){
            // 创建对应支付记录
            $trade_no = get_order_no();
            $logID = model('common/OrderPaylog')->storeBy([
                'out_trade_no' => $trade_no,
                'total_price' => $params['price'],
                'order_idx' =>  $order['id'],
                'ascription' => 'motor' // 归属订单
            ]);
            // 免单优惠 20201201 添加条件  仅限xx 公里以下 不包含 xx 公里
            if ($count < sys_config('taxi_order_free_num','store') && $params['km'] < sys_config('taxi_order_free_km','store')){

                model('common/OrderPaylog')->updateBy($logID,[
                    'pay_price' => $params['price'],
                    'is_pay' => 1
                ]);
                model('common/TaxiOrder')->updateBy($order['id'], [
                    'is_free' => 1, // 免单
                    'status' => 2
                ]);
                // 后台推送
//                push_socket_data('motor',[
//                    'id' => $order['id'],
//                    'msg' => '有新的(免费)摩的订单等待处理哟，点击前往！'
//                ]);
                return $this->ApiJson(0,"本单免费，等待师傅接驾", [
                    'type' => 'free',
                    'success' => "ok!"
                ]);
            }
            // 返回支付单号
            return $this->ApiJson(0,'订单提交成功', [
                'type' => 'wx',
                'success' => "ok!",
                'trade_no' => $trade_no
            ]);
        }

        return $this->ApiJson(-1,'发生异常，请骚后重试...');
    }

    /**
     * 用车，新的地图下单方式
     */
    public function newCallTaxi()
    {
        $params = $this->request->param();
        // 参数校验
        $valid = $this->validate($params, [
            'mobile|联系方式' => 'require',
            'count|乘车人数' => 'require',
            'depart|起始位置' => 'require',
            'arrive|送达位置' => 'require',
            'km|公里数' => 'require',
            'price|价格' => 'require',
        ]);
        // 错误返回
        if(true !== $valid){
            return $this->ApiJson(-1, $valid);
        };
        $user = $this->auth->user();
        // 统计订单
        $count = model('common/TaxiOrder')->where('status','>=','2')->where(['is_free' => '1','user_id' =>  $user['id']])->count('id');

        // 创建订单
        $params['order_no'] = get_order_no();
        $params['user_id'] = $user['id'];

        // 验证是否有未支付订单，有则直接更新订单为新订单
        $hasOrderId = model('common/TaxiOrder')->where(['user_id'=> $user['id'],'status'=> 1])->order('created_at','desc')->value('id');
        if($hasOrderId){
            model('common/TaxiOrder')->updateBy($hasOrderId, $params);
        }else{
            $order = model('common/TaxiOrder')::create($params,true);
        }

        // 订单信息验证处理
        if ($order){
            // 创建对应支付记录
            $trade_no = get_order_no();
            $logID = model('common/OrderPaylog')->storeBy([
                'out_trade_no' => $trade_no,
                'total_price' => $params['price'],
                'order_idx' =>  $order['id'],
                'ascription' => 'motor' // 归属订单
            ]);
            // 免单优惠 20201201 添加条件  仅限xx 公里以下 不包含 xx 公里
            if ($count < sys_config('taxi_order_free_num','store') && $params['km'] < sys_config('taxi_order_free_km','store')){

                model('common/OrderPaylog')->updateBy($logID,[
                    'pay_price' => $params['price'],
                    'is_pay' => 1
                ]);
                model('common/TaxiOrder')->updateBy($order['id'], [
                    'is_free' => 1, // 免单
                    'status' => 2
                ]);
                // 后台推送
//                push_socket_data('motor',[
//                    'id' => $order['id'],
//                    'msg' => '有新的(免费)摩的订单等待处理哟，点击前往！'
//                ]);
                return $this->ApiJson(0,"本单免费，等待师傅接驾", [
                    'type' => 'free',
                    'success' => "ok!"
                ]);
            }
            // 返回支付单号
            return $this->ApiJson(0,'订单提交成功', [
                'type' => 'wx',
                'success' => "ok!",
                'trade_no' => $trade_no
            ]);
        }

        return $this->ApiJson(-1,'发生异常，请骚后重试...');
    }


    /**
     * 订单详情
     *
     * @author 许祖兴 < zuxing.xu@lettered.cn>
     * @date 2020/7/6 11:09
     *
     * @return \think\response\Json
     * @throws \Lettered\Support\Exceptions\FailedException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function orderInfo()
    {
        $param = $this->request->param();
        // 数据校验
        $valid = $this->validate($param, [
            'order_no' => 'require',
        ]);
        // 错误
        if (true !== $valid) {
            return $this->ApiJson(-1, $valid);
        }

        $info = model('common/TaxiOrder')
            ->with(['paylog','taxi','user'])
            ->where(['user_id' => $this->auth->user()['id'], 'order_no'=> $param['order_no']])
            ->findOrFail();
        return $this->ApiJson(0,'获取成功', $info);
    }

    /**
     * 订单
     *
     * @author 许祖兴 < zuxing.xu@lettered.cn>
     * @date 2020/7/6 11:09
     *
     * @return \think\response\Json
     * @throws \Lettered\Support\Exceptions\FailedException
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function order()
    {
        $param = $this->request->param();
        $limit = 10;
        // 数据校验
        $valid = $this->validate($param, [
            'page' => 'require',
        ]);
        // 错误
        if (true !== $valid) {
            return $this->ApiJson(-1, $valid);
        }
        $orders = model('common/TaxiOrder')
            ->with(['paylog'])
            ->where(['user_id' => $this->auth->user()['id']])
            ->limit((($param['page'] - 1) * $limit) . "," . $limit)
            ->order(['id' => 'desc'])
            ->select();
        return $this->ApiJson(0,'获取成功', $orders);
    }

    /**
     * @desc 取消订单
     * @return \think\response\Json
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     * @author weichuanbao<654745815@qq.com>
     * @date 2021/12/2 0002
     */
    public function cancelOrder()
    {
        $param = $this->request->param();
        // 数据校验
        $valid = $this->validate($param, [
            'id' => 'require|number',
        ]);
        // 错误
        if (true !== $valid) {
            return $this->ApiJson(-1, $valid);
        }
        $row = model('common/TaxiOrder')->with(['paylog'])
            ->field('id,status,created_at')
            ->whereNotIn('status', [0,5])
            ->find($param['id']);
        $user = $this->auth->user();

        if ($row) {
            if (time() - $row['created_at'] < (60 * 10)) {
//                return $this->ApiJson(-1, '10分钟内无法取消订单');
            }
            if ($row['status'] == 2 || $row['status'] == 3) {
                $config = Cache::get('system_config');
                $total_price = $row->paylog['total_price'];

                // 如果平台已指派司机,则扣除部分金额
                if ($row['status'] == 3) {
                    $total_price = $total_price * (1 - $config['store']['store_cancel_order']/100);
                }
                if ($row->paylog['pay_type'] == 'balance') {
                    model('common/Users')->changeBalance(
                        $user['id'],
                        $total_price,
                        "取消成功，取消金额【" . $total_price . "】",
                        true
                    );
                } else if ($row->paylog['pay_type'] == 'property') {
                    model('common/Users')->changeProperty(
                        $user['id'],
                        $total_price,
                        "取消成功，取消资产【{$total_price}】",
                        true
                    );
                } else if ($row->paylog['pay_type'] == 'wechat') {
                    // 加载配置
                    $wechat = sys_config('', 'wechat');
                    $config = [
                        // 前面的appid什么的也得保留哦
                        'app_id' => $wechat['mini_appid'],
                        'mch_id' => $wechat['pay_mch_id'],
                        'key' => $wechat['pay_secret_key'],
                        // 如需使用敏感接口（如退款、发送红包等）需要配置 API 证书路径(登录商户平台下载 API 证书)
                        'cert_path'          => $wechat['cert_path'], // XXX: 绝对路径！！！！
                        'key_path'           => $wechat['key_path'],      // XXX: 绝对路径！！！！
//                        'notify_url'         => 'https://api.gxrrj.cn/api/v1/wechat/notify',
//                        'notify_url'         => 'http://rrj.gxnwsoft.com/api/v1/wechat/refundNotify',
                        // 'sandbox' => true
                    ];
                    // 创建应用实例
                    $app = Factory::payment($config);
                    // Example:
                    $result = $app->refund->byOutTradeNumber($row->paylog['out_trade_no'], get_order_no(), $row->paylog['total_price'] * 100, $total_price * 100, [
                        // 可在此处传入其他参数，详细参数见微信支付文档
                        'refund_desc' => '用户申请退款',
                    ]);
                    app()->log(json_encode($result));
                    if ($result['return_code'] == 'SUCCESS') {
                        if ($result['result_code'] != 'SUCCESS') {
                            $this->ApiJson(-1, '失败');
                        }
                    }
                    else {
                        $this->ApiJson(-1, '成功');
                    }
                }
            }

            // 后台推送
            push_socket_data('motor',[
                'id' => $row['id'],
                'msg' => '有用户取消订单，点击前往！'
            ]);

            $row->status = 5;
            $row->save();

            return $this->ApiJson(0, '取消成功', $row);
        }
        return $this->ApiJson(-1, '取消失败');
    }
}