lanjingling/application/common/service/OrderService.php

<?php
namespace app\common\service;

use addons\epay\library\Service;
use fast\Random;
use think\Db;
use think\Exception;

class OrderService
{
    private $model =  null;

    /**
     * 初始化方法
     */
    public function __construct()
    {
        $this->model = Db::name('order');
    }

    /**
     * 套餐支付
     * @param $params
     * @return array
     */
    public function orderPay($params=[])
    {
        $result = [
            'status' => 1,
            'msg' => '操作成功',
            'data' => [],
        ];
        try {
            $payType   = isset($params['pay_type']) ? $params['pay_type'] : 'wechat';
            $platform  = isset($params['platform']) ? $params['platform'] : 'miniapp';
            $userId    = isset($params['user_id']) ? $params['user_id'] : 0;
            $carId     = isset($params['car_id']) ? $params['car_id'] : 0;
            $companyId = isset($params['company_id']) ? $params['company_id'] : 0;
            $packageId = isset($params['package_id']) ? $params['package_id'] : 0;
            $miniOpenId = isset($params['mini_openid']) ? $params['mini_openid'] : '';

            //验证车辆
            $userCarWhere['user_id'] = $userId;
            $userCarWhere['id'] = $carId;
            $userCar = Db::name('user_car')->where($userCarWhere)->find();
            if (empty($userCar)) {
                throw new Exception('未找到车辆信息');
            }
            //验证套餐
            $packageWhere['id'] = $packageId;
            $packageWhere['status'] = 1;
            $packageWhere['num'] = ['gt',0];
            $package = Db::name('package')->where($packageWhere)->find();
            if (empty($package)) {
                throw new Exception('未找到套餐信息');
            }
            /*if ($package['company_id'] != $companyId) {
                throw new Exception('您绑定的门店和购买套餐门店不一致');
            }*/
            if ($payType == 'wallet') {//验证余额
                $userWalletWhere['user_id'] = $userId;
                $userWalletWhere['company_id'] = $companyId;
                $userWallet = Db::name('user_wallet')->where($userWalletWhere)->find();
                if (empty($userWallet)) {
                    throw new Exception('钱包异常');
                }
                if ($userWallet['money'] < $package['price']) {
                    throw new Exception('您的余额不足,请充值。');
                }
            }

            $gift_amount = 0.00;
            $order_amount = $package['price'];
            $extData = ['car_id'=>$carId];
            $time = time();
            //创建订单
            $data['company_id'] = $companyId;
            $data['user_id'] = $userId;
            $data['out_trade_no'] = createUniqueNo('O',$userId); // 数据库订单号加密
            $data['order_amount'] = $order_amount;
            $data['gift_amount'] = $gift_amount;
            $data['createtime'] = time();
            $data['pay_type'] = $payType;
            $data['order_status'] = 0;
            $data['table_name'] = 'package';
            $data['table_id'] = $packageId;
            $data['ext_data'] = json_encode($extData);

            $payOrderId = Db::name('pay_order')->insertGetId($data);
            //支付方式:wallet=钱包,wechat=微信
            if ($payType == 'wechat') {//微信支付 记录日志，生成订单，商家端操作完成增加收入
                $httpStr = $_SERVER['REQUEST_SCHEME'].'://'.$_SERVER['HTTP_HOST'];
                //下单
                $payTest = config('param.pay_test');
                $orderAmount = $payTest == 1 ? 0.01 : $data['order_amount'];
                $paramsData = [
                    'type'      => $payType,
                    'orderid'   => $data['out_trade_no'],
                    'title'     => '购买套餐',
                    'amount'    => $orderAmount,
                    'method'    => $platform,
                    'openid'    => $miniOpenId,
                    'notifyurl' => $httpStr.'/api/pay/order_notify_base/paytype/'.$payType.'/func/package_do',
                    'returnurl' => '',
                ];

                $resData = Service::submitOrder($paramsData);
                $resData = json_decode($resData,true);
            } else {//余额支付 扣减余额，记录日志，生成订单 商家端不变
                //扣减金额
                $oldMoney = $userWallet['money'];
                $newMoney = bcsub($oldMoney,$package['price'],2);
                $userWalletData['money'] = $newMoney;
                $userWalletData['updatetime'] = $time;
                $userWalletWhere['user_id'] = $userId;
                $userWalletWhere['company_id'] = $companyId;
                $userWalletRes = Db::name('user_wallet')->where($userWalletWhere)->update($userWalletData);
                if (!$userWalletRes) {
                    throw new Exception('支付失败');
                }
                //余额明细记录
                $userMoneyLogData = [
                    'company_id' => $companyId,
                    'user_id' => $userId,
                    'log_type' => 103,//购买套餐
                    'before' => $oldMoney,
                    'change_value' => $package['price'],
                    'remain' => $newMoney,
                    'table' => 'pay_order',
                    'table_id' => $payOrderId,
                    'remark' => '购买套餐',
                    'createtime' => $time,
                    'updatetime' => $time,
                ];
                $userMoneyLogRes = Db::name('user_money_log')->insertGetId($userMoneyLogData);
                if (!$userMoneyLogRes) {
                    throw new Exception('余额明细记录失败');
                }
                //生成订单
                $params['order_paytype'] = 2;//支付方式:1=线下,2=余额,3=微信
                $params['pay_order_id'] = $payOrderId;
                $orderRes = $this->addOrder($params);
                if (!$orderRes['status']) {
                    throw new Exception($orderRes['msg']);
                }
                $orderId = isset($orderRes['data']['order_id']) ? $orderRes['data']['order_id'] : 0;
                $wallet_rs = model('walletcompany')->lockChangeAccountRemain($companyId,'money',$package['price'],207,'购买套餐订单','order',$orderId);
                if($wallet_rs['status'] === false){
                    throw new Exception($wallet_rs['msg']);
                }
                //更新支付状态
                $payOrderData['order_status'] = 1;
                $payOrderWhere['id'] = $payOrderId;
                $payOrderRes = Db::name('pay_order')->where($payOrderWhere)->update($payOrderData);
                if (!$payOrderRes) {
                    throw new Exception('支付失败');
                }
            }
            $resData['order_id'] = isset($orderRes['data']['order_id']) ? $orderRes['data']['order_id'] : 0;
            $resData['pay_order_id'] = $payOrderId;
            $resData['template_ids'] = config('param.wechat_template_ids');//微信消息模版ID
            $result['data'] = $resData;
        } catch (Exception $e) {
            $result['status'] = 0;
            $result['msg'] = $e->getMessage();
        }
        return $result;
    }

    /**
     * 生成订单
     * @return void
     */
    public function addOrder($params)
    {
        $result = [
            'status' => 1,
            'msg' => '操作成功',
            'data' => [],
        ];
        try {
            $packageId = isset($params['package_id']) ? $params['package_id'] : 0;
            $companyId = isset($params['company_id']) ? $params['company_id'] : 0;
            $userId    = isset($params['user_id']) ? $params['user_id'] : 0;
            $carId     = isset($params['car_id']) ? $params['car_id'] : 0;
            $payOrderId= isset($params['pay_order_id']) ? $params['pay_order_id'] : 0;
            $orderPayType = isset($params['order_paytype']) ? $params['order_paytype'] : 3;//支付方式:1=线下,2=余额,3=微信
            //生成订单
            $time = time();
            $packageWhere['id'] = $packageId;
            $packageWhere['num'] = ['gt',0];
            $package = Db::name('package')->where($packageWhere)->lock(true)->find();
            if (empty($package)) {
                throw new Exception('未找到套餐信息');
            }
            $userWhere['id'] = $userId;
            $user = Db::name('user')->where($userWhere)->find();
            //绑定门店
            $userService = new UserService();
            $userParams = [
                'user_id' => $userId,
                'company_id' => $companyId,
                'comefrom' => '平台引流',//来源
            ];
            $userBindRes = $userService->userWallet($userParams);
            if (!$userBindRes['status']) {
                throw new Exception($userBindRes['msg']);
            }
            $userCarWhere['id'] = $carId;
            $userCar = Db::name('user_car')->where($userCarWhere)->find();
            //生成订单
            $checkCode[] = Random::alnum(8);
            $orderService = new OrderService();//防重复
            $checkCodeRes = $orderService->getCheckOrder($checkCode);
            if ($checkCodeRes['status']) {
                $checkCodeStr = isset($checkCodeRes['data'][0]) ? $checkCodeRes['data'][0] : '';
            } else {
                $checkCodeStr = Random::alnum(8);
            }
            if ($package['type'] == 2) {//卡券类型直接已完成
                $orderStatus = 3;
                $finishTime = $time;
                $userCouponsParams = [
                    'package_id' => $packageId,
                    'company_id' => $companyId,
                    'user_id'    => $userId,
                    'payorder_id'=> $payOrderId,
                ];
                $userCouponsRes = $userService->packageCoupons($userCouponsParams);
                if (!$userCouponsRes['status']) {
                    throw new Exception($userCouponsRes['msg']);
                }
            } else {
                $orderStatus = 1;
                $finishTime = 0;
            }
            $orderData = [
                'check_code'      => $checkCodeStr,
                'orderno'         => createUniqueNo('O', $userId),//订单号
                'ordertype'       => 3,//类型:1=预约下单,2=在线下单,3=套餐订单
                'company_id'      => $companyId,//门店ID
                'user_id'         => $userId,//用户ID
                'user_name'       => isset($user['nickname']) ? $user['nickname'] : '',//用户姓名
                'user_car_id'     => isset($userCar['id']) ? $userCar['id'] : 0,//车辆ID
                'user_car_number' => isset($userCar['car_number']) ? $userCar['car_number'] : '',//用户车牌
                'user_mobile'     => isset($user['mobile']) ? $user['mobile'] : '',//用户手机
                'pre_order_id'    => 0,//预约单ID
                'package_id'      => isset($package['id']) ? $package['id'] : 0,//套餐ID
                'servicetype_id'  => isset($package['servicetype_id']) ? $package['servicetype_id'] : 0,//服务类型
                'server_info'     => isset($package['title']) ? $package['title'] : '',//套餐主标题
                'server_images'   => isset($package['images']) ? $package['images'] : '',//套餐图片
                'pay_fee'         => isset($package['price']) ? $package['price'] : 0.00,//套餐价格
                'status'          => $orderStatus,//状态:1=待核销,2=已接单,3=已完成,4=已取消
                'pay_time'        => $time,
                'paytype'         => $orderPayType,//支付方式:1=线下,2=余额,3=微信
                'total_fee'       => isset($package['price']) ? $package['price'] : 0.00,//支付总额
                'createtime'      => $time,//下单时间
                'pay_order_id'    => $payOrderId,//支付ID
                'finish_time'     => $finishTime,//完成时间
            ];
            $orderRes = Db::name('order')->insertGetId($orderData);
            if (!$orderRes) {
                throw new Exception('生成订单失败');
            }
            $newNum = $package['num'] - 1;
            $packageRes = Db::name('package')->where($packageWhere)->update(['num'=>$newNum]);
            if (!$packageRes) {
                throw new Exception('扣减库存失败');
            }
            $result['data'] = [
                'order_id' => $orderRes,
                'pay_order_id' => $payOrderId,
            ];
        } catch (Exception $e) {
            $result['status'] = 0;
            $result['msg'] = $e->getMessage();
        }
        return $result;
    }
    
    /**
     * 获取车辆预计下次保养时间
     * @return void
     */
    public function getCarNextDate($params=[])
    {
        $result = [
            'status' => 1,
            'msg' => '获取成功',
            'data' => [],
        ];
        try {
            $userId = isset($params['user_id']) ? $params['user_id'] : 0;
            $companyId = isset($params['company_id']) ? $params['company_id'] : 0;
            $carId = isset($params['car_id']) ? $params['car_id'] : [];
            $carNumber = isset($params['car_number']) ? $params['car_number'] : [];
            if (!empty($carNumber)) {
                $orderWhere['user_car_number'] = ['in',$carNumber];
            } else {
                $orderWhere['user_car_id'] = ['in',$carId];
            }
            $orderWhere['user_id'] = $userId;
            $orderWhere['company_id'] = $companyId;
            $orderWhere['next_date'] = ['neq',''];
            $orderWhere['status'] = 3;//状态:2=已接单,3=已完成,4=已取消
            $subQuery = Db::name('order')->alias('o')->where($orderWhere)
                ->order(['finish_time' => 'desc'])
                ->buildSql(); //构建查询语句

            $order = Db::table($subQuery)->alias('o')->field('id,user_car_id,user_car_number,next_date')
                ->group('user_car_id')->order('finish_time desc')->select();
            $row = [];
            if (!empty($order)) {
                foreach ($order as $key => $value) {
                    $row[$value['user_car_number']]['next_date'] = $value['next_date'];
                }
            }
            $result['data'] = $row;
        } catch (Exception $e) {
            $result['status'] = 0;
            $result['msg'] = $e->getMessage();
        }
        return $result;
    }

    /**
     * 查看是否重复-卡券
     * @return void
     */
    public function getCheckCoupons($checkCode=[])
    {
        try {
            if (!empty($checkCode)) {
                $where['check_code'] = ['in', $checkCode];
                $userCoupons = Db::name('user_coupon')->field('id,check_code')->where($where)->select();
                if (!empty($userCoupons)) {
                    $checkCodeDbArr = array_column($userCoupons,'check_code');
                    foreach ($checkCode as $key => $code) {
                        if (in_array($code,$checkCodeDbArr)) {
                            $checkCode[$key] = Random::alnum(8);
                        }
                    }
                    $checkCodeRes = $this->getCheckCoupons($checkCode);
                    if ($checkCodeRes['status']) {
                        $checkCode = $checkCodeRes['data'];
                    }
                }
            }
            $result['data'] = $checkCode;
        } catch (Exception $e) {
            $result['status'] = 0;
            $result['msg'] = $e->getMessage();
        }
        return $result;
    }

    /**
     * 查看是否重复-订单
     * @return void
     */
    public function getCheckOrder($checkCode=[])
    {
        $result = [
            'status' => 1,
            'msg' => '',
            'data' => [],
        ];
        try {
            if (!empty($checkCode)) {
                $where['check_code'] = ['in', $checkCode];
                $userCoupons = Db::name('order')->field('id,check_code')->where($where)->select();
                if (!empty($userCoupons)) {
                    $checkCodeDbArr = array_column($userCoupons,'check_code');
                    foreach ($checkCode as $key => $code) {
                        if (in_array($code,$checkCodeDbArr)) {
                            $checkCode[$key] = Random::alnum(8);
                        }
                    }
                    $checkCodeRes = $this->getCheckOrder($checkCode);
                    if ($checkCodeRes['status']) {
                        $checkCode = $checkCodeRes['data'];
                    }
                }
            }
            $result['data'] = $checkCode;
        } catch (Exception $e) {
            $result['status'] = 0;
            $result['msg'] = $e->getMessage();
        }
        return $result;
    }
}