hc_live/application/common/service/OrderService.php

<?php
/**
 * Author: luzheng.liu
 * Time: 2020/12/24 13:44
 */

namespace app\common\service;


use app\api\controller\Order;
use app\api\exception\ApiException;
use app\api\model\AllocateModel;
use app\api\model\CartModel;
use app\api\model\OrderModel;
use app\api\model\OrderProductModel;
use app\api\model\ProductModel;
use app\api\model\RechargeOrder;
use app\api\model\RechargeRecordModel;
use app\api\model\StaffModel;
use app\api\model\StoreModel;
use app\api\model\UserModel;
use app\api\model\WriteOffModel;
use app\common\until\Until;
use GuzzleHttp\Client;
use think\Exception;
use think\facade\Cache;
use think\facade\Config;
use think\Model;
use const http\Client\Curl\Features\UNIX_SOCKETS;

class OrderService {

    public $userName = 'heshen';
    public $passwd = 'heshenit@0563';

    public $time = [];


    public function payOrder($input) {
        $userId = empty($input['userId']) ? Until::$userId : $input['userId'];
        $payCode = (new StoreModel())->getPayCode($input['storeId']);
        $this->time[] = 'start' . time();
        $orderSn = Until::createSn();
        $productModel = new ProductModel();
        $productModel->setWhere(['p.id' => $input['productId'],'spt.store_id' => $input['storeId']]);
        $productInfo = $productModel->getProductInfo();
        $userInfo = (new UserModel())::where(['id' => $userId])->find();
        $userInfo = Until::modelToArray($userInfo);
        if (empty($userInfo)) {
            throw new ApiException('无此用户');
        }
        $model = new OrderModel();
        try {
            $orderType = 1;
            if (Until::$isAdmin) {
                $orderType = 2;
            }
            $model->startTrans();
            $orderMoney = $productInfo['realPrice'] * (int)abs($input['num']);
            $orderId = $model->insertGetId([
                'order_sn'         => $orderSn,
                'order_money'      => $orderMoney,
                'product_id'       => $input['productId'],
                'staff_id'         => $input['staffId'] ?? 0,
                'num'              => (int)abs($input['num']),
                'store_id'         => $input['storeId'],
                'appointment_time' => $input['appointmentTime'],
                'end_time'         => $input['endTime'],
                'mobile'           => $input['mobile'],
                'status'           => 1,
                'order_type'       => $orderType,
                'user_id'          => $userId,
                'admin_id'         => Until::$adminId
            ]);
            (new AllocateModel())->insertGetId([
                'order_id'          => $orderId,
                'staff_id'          => $input['staffId'],
                'assign_admin_id'   => Until::$adminId,
                'server_start_time' => $input['appointmentTime'],
            ]);
            (new StaffModel())::where(['id' => $input['staffId']])->update(['server_status' => 2]);
            $opModel = new OrderProductModel();
            $opModel->insert([
                'order_id'        => $orderId,
                'product_id'      => $input['productId'],
                'product_num'     => (int)abs($input['num']),
                'current_price'   => $productInfo['current_price'],
                'real_price'      => $productInfo['realPrice'],
                'product_name'    => $productInfo['product_name'],
                'product_img'     => $productInfo['product_img'],
                'old_price'       => $productInfo['old_price'],
                'company_id'      => $productInfo['company_id'],
                'brand_id'        => $productInfo['brand_id'],
                'product_type_id' => $productInfo['product_type_id'],
                'type'            => $productInfo['type'],
                'product_snap'    => json_encode($productInfo)
            ]);
            (new WriteOffModel())->insertGetId([
                'write_off_code'   => '',
                'order_id'         => $orderId,
                'write_off_status' => 1,
            ]);
            $model->commit();
        } catch (\Exception $e) {
            $model->rollback();
            throw new ApiException($e->getMessage());
        }
        //{attach string支付主体的标识
        //mark string商品信息
        //money integer($int32)金额，分为单位
        //openId string小程序的openid
        //orderId string订单号
        //payCode string支付标识
        //username string用户名
        //}
        if (!Until::$isAdmin) {
            $otherData = [
                'openId'   => $userInfo['open_id'],
                'attach'   => 'storeId:' . $input['storeId'],
                'money'    => $orderMoney * 100,
                'mark'     => '购买了' . $productInfo['product_name'],
                'orderId'  => $orderSn,
                'username' => $userInfo['name'],
                'payCode'  => strtoupper($payCode),
            ];
            $this->time[] = 'leo-start' . time();
            $wxOrderInfo = $this->createOrderForOther($otherData);
            $order = [
                'nonceStr'  => $wxOrderInfo['nonceStr'],
                'package'   => $wxOrderInfo['pack'],
                'paySign'   => $wxOrderInfo['paySign'],
                'timeStamp' => $wxOrderInfo['timeStamp'],
                'signType'  => $wxOrderInfo['signType'],
                'orderSn'   => $orderSn,
                'orderId'   => $orderId
            ];
        }
        $this->time[] = 'leo-end' . time();
        $order['time'] = $this->time;
        return $order;
    }

    public function payFoodOrder($input) {
        $orderSn = Until::createSn();
        $cartModel = new CartModel();
        $cartModel->setFields('c.store_id,cp.num,p.*');
        $cartModel->setWhere(['c.id' => $input['cartId']]);
        $cartInfo = $cartModel->getCartList();
        $orderMoney = 0;
        $recordData = [];
        $storeId = 0;
        foreach ($cartInfo as $info) {
            $storeId = $info['store_id'];
            $orderMoney += $info['num'] * $info['current_price'];
        }
        $payCode = (new StoreModel())->getPayCode($storeId);
        $userInfo = (new UserModel())::where(['id' => Until::$userId])->find();
        $userInfo = Until::modelToArray($userInfo);
        if (empty($userInfo)) {
            throw new ApiException('无此用户');
        }
        $model = new OrderModel();
        try {
            $userId = Until::$userId;
            $orderType = 3;
            $model->startTrans();
            $cartModel::where(['id' => $input['cartId']])->update(['status' => 0]);
            $orderId = $model->insertGetId([
                'order_sn'         => $orderSn,
                'order_money'      => $orderMoney,
                'product_id'       => 0,
                'num'              => 0,
                'store_id'         => $storeId,
                'table_id'         => $input['tableId'],
                'appointment_time' => null,
                'end_time'         => null,
                'mobile'           => '',
                'order_type'       => $orderType,
                'user_id'          => $userId,
            ]);
            $opModel = new OrderProductModel();
            foreach ($cartInfo as $info) {
                $recordData[] = [
                    'order_id'        => $orderId,
                    'product_id'      => $info['id'],
                    'product_num'     => $info['num'],
                    'current_price'   => $info['current_price'],
                    'product_name'    => $info['product_name'],
                    'product_img'     => $info['product_img'],
                    'old_price'       => $info['old_price'],
                    'company_id'      => $info['company_id'],
                    'brand_id'        => $info['brand_id'],
                    'product_type_id' => $info['product_type_id'],
                    'type'            => $info['type'],
                    'product_snap'    => json_encode($info)
                ];
            }
            $opModel->insertAll($recordData);
            $cartModel::where(['id' => $input['cartId']])->update(['status' => 0]);
            $model->commit();
        } catch (\Exception $e) {
            $model->rollback();
            throw new ApiException($e->getMessage());
        }
        //{attach string支付主体的标识
        //mark string商品信息
        //money integer($int32)金额，分为单位
        //openId string小程序的openid
        //orderId string订单号
        //payCode string支付标识
        //username string用户名
        //}
        if (!Until::$isAdmin) {
            $otherData = [
                'openId'   => $userInfo['open_id'],
                'attach'   => 'storeId:' . $storeId,
                'money'    => $orderMoney * 100,
                'mark'     => '购买了小食',
                'orderId'  => $orderSn,
                'username' => $userInfo['name'],
                'payCode'  => strtoupper($payCode),
            ];
            $this->time[] = 'leo-start' . time();
            $wxOrderInfo = $this->createOrderForOther($otherData);
            $order = [
                'nonceStr'  => $wxOrderInfo['nonceStr'],
                'package'   => $wxOrderInfo['pack'],
                'paySign'   => $wxOrderInfo['paySign'],
                'timeStamp' => $wxOrderInfo['timeStamp'],
                'signType'  => $wxOrderInfo['signType'],
                'orderSn'   => $orderSn,
                'orderId'   => $orderId
            ];
        }
        $this->time[] = 'leo-end' . time();
        $order['time'] = $this->time;
        return $order;
    }

    public function payAgain(int $orderId) {
        $model = new OrderModel();
        $info = $model::where(['id' => $orderId])->find();
        $payCode = (new StoreModel())->getPayCode($info['store_id']);
        //        $productInfo = (new ProductModel())::where(['id' => $info['product_id']])->find();
        if ($info['status'] === OrderModel::IS_PAY) {
            throw new ApiException('订单已支付');
        }
        $userInfo = (new UserModel())::where(['id' => Until::$userId])->find();
        if (empty($userInfo)) {
            throw new ApiException('无此用户');
        }
        $paySn = Until::createSn();
        $model::where(['id' => $orderId])->update(['pay_sn' => $paySn]);
        $otherData = [
            'openId'   => $userInfo['open_id'],
            'attach'   => 'storeId:' . $info['store_id'],
            'money'    => $info['order_money'] * 100,
            'mark'     => '购买了商品',
            'orderId'  => $paySn,
            'username' => $userInfo['name'],
            'payCode'  => strtoupper($payCode),
        ];
        $wxOrderInfo = $this->createOrderForOther($otherData);
        $order = [
            'nonceStr'  => $wxOrderInfo['nonceStr'],
            'package'   => $wxOrderInfo['pack'],
            'paySign'   => $wxOrderInfo['paySign'],
            'timeStamp' => $wxOrderInfo['timeStamp'],
            'signType'  => $wxOrderInfo['signType'],
            'orderSn'   => $info['order_sn'],
            'orderId'   => $orderId
        ];
        return $order;
    }


    public function getPayToken() {
        $this->time[] = 'payToken-start-' . time();
        $key = 'payToken' . $this->userName;
        $token = Cache::get($key);
        if (empty($token)) {
            $token = $this->getAuthPay();
            Cache::set($key, $token, '7100');
            return $token;
        }
        $this->time[] = 'payToken-end-' . time();
        return $token;
    }

    public function getAuthPay() {
        $client = new Client();
        $time = Until::msectime();
        $res = $client->request('Post',
            Config::get('domain') . "api/auth/create", [
                'json' => [
                    'username'  => $this->userName,
                    "password"  => $this->passwd,
                    'timestamp' => $time,
                    'sign'      => md5($this->userName . $time . $this->passwd)
                ]
            ]);
        $info = json_decode((string)$res->getBody(), true);
        if ($info['code'] != 200) {
            throw new ApiException($info['msg']);
        }
        return $info['data']['token'];
    }

    public function createOrderForOther(array $data) {
        //        var_dump('start'.time());
        $this->time[] = 'createOrder-start-' . time();
        $client = new Client();
        $res = $client->request('Post',
            Config::get('domain') . "api/supers/wx-pay/gateway-no-order", [
                'json'    => $data,
                'headers' => [
                    'API-TOKEN-V1' => $this->getPayToken()
                ]
            ]);
        $info = json_decode((string)$res->getBody(), true);
        if ($info['code'] != 200) {
            throw new ApiException($info['msg']);
        }
        $this->time[] = 'createOrder-end-' . time();
        //        var_dump('end'.time());
        return $info['data'];
    }

    public function notify(string $orderSn) {
        $model = new OrderModel();
        $rs = $model::where(['order_sn' => $orderSn])->whereOr(['pay_sn' => $orderSn])->find();
        if (empty($rs) || $rs['status'] === 2) {
            $this->rechargeNotify($orderSn);
            return;
        }

        //        var_dump($rs);
        $model::where(['order_sn' => $orderSn])->update(['status' => 2, 'pay_time' => date('Y-m-d H:i:s')]);
        $model::where(['pay_sn' => $orderSn])->update(['status' => 2, 'pay_time' => date('Y-m-d H:i:s')]);
        $wModel = new WriteOffModel();
        $code = $this->changeCode();
        $wModel::where(['order_id' => $rs['id']])->update([
            'write_off_code' => $code,
            'over_time'      => date('Y-m-d  H:i:s', time() + 2 * 60),
        ]);
    }


    public function changeCode() {
        $wModel = new WriteOffModel();
        $codeList = $wModel::where(['write_off_status' => WriteOffModel::NO_WRITE_OFF])->field('write_off_code')->select();
        $codeList = Until::modelToArray($codeList);

        $codeArr = [];
        foreach ($codeList as $v) {
            $codeArr[] = $v['write_off_code'];
        }
        $code = $this->makeUniqCode($codeArr);
        return $code;
    }

    public function makeUniqCode(array $codeList) {
        $code = random_int(10000, 99999);
        if (in_array($code, $codeList)) {
            $this->makeUniqCode($codeList);
        }
        return $code;
    }

    public function createRechargeOrder(string $money) {
        $model = new RechargeOrder();
        $payCode = 'HESHEN';
        $orderSn = Until::createSn();
        $userModel = new UserModel();
        $userInfo = $userModel::where(['id' => Until::$userId])->find();
        $orderId = $model->insertGetId([
            'user_id' => Until::$userId,
            'recharge' => $money,
            'order_sn' => $orderSn,
        ]);
        $otherData = [
            'openId'   => $userInfo['open_id'],
            'attach'   => 'recharge',
            'money'    => $money * 100,
            'mark'     => '充值',
            'orderId'  => $orderSn,
            'username' => $userInfo['name'],
            'payCode'  => strtoupper($payCode),
        ];
        $wxOrderInfo = $this->createOrderForOther($otherData);
        $order = [
            'nonceStr'  => $wxOrderInfo['nonceStr'],
            'package'   => $wxOrderInfo['pack'],
            'paySign'   => $wxOrderInfo['paySign'],
            'timeStamp' => $wxOrderInfo['timeStamp'],
            'signType'  => $wxOrderInfo['signType'],
            'orderSn'   => $orderSn,
            'orderId'   => $orderId
        ];
        return $order;
    }

    /**
     * 充值订单的回调
     * @param string $orderSn
     * @throws \think\exception\PDOException
     */
    public function rechargeNotify(string $orderSn) {
        $rechargeOrderModel = new RechargeOrder();
        $rechargeInfo = $rechargeOrderModel::where(['order_sn' => $orderSn])->find();
        if (empty($rechargeInfo) || $rechargeInfo['pay_status'] == RechargeOrder::PAY) {
            return;
        }
        $rechargeModel = new RechargeRecordModel();
        $userModel = new UserModel();
        try {
            $rechargeOrderModel->startTrans();
            $userInfo = $userModel::where(['id' => $rechargeInfo['user_id']])->find();
            $userModel::where(['id' => $rechargeInfo['user_id']])->inc('money', $rechargeInfo['recharge'])->update();
            $rechargeOrderModel::where(['order_sn' => $orderSn, 'pay_status' => $rechargeOrderModel::NO_PAY])
                ->update([
                    'pay_status'       => $rechargeOrderModel::PAY,
                    'pay_success_time' => date('Y-m-d H:i:s'),
                ]);
            $rechargeModel->insert([
                'user_id'         => $userInfo['id'],
                'before_recharge' => $userInfo['money'],
                'recharge'        => $rechargeInfo['recharge'],
                'after_recharge'  => $userInfo['money'] + $rechargeInfo['recharge'],
            ]);
            $rechargeOrderModel->commit();
        } catch (Exception $e) {
            $rechargeOrderModel->rollback();
            throw new ApiException($e->getMessage());
        }
    }


}