huahuibao/biz-hd/order/classes/OrderClass.php

<?php

namespace bizHd\order\classes;

use biz\goods\classes\GoodsClass;
use biz\goods\models\Goods;
use biz\shop\classes\ShopAdminClass;
use biz\shop\models\Shop;
use biz\stat\classes\StatOrderCountClass;
use bizGhs\stat\classes\StatYjClass;
use bizHd\user\classes\UserClass;
use common\components\miniUtil;
use common\components\orderSn;
use common\components\util;
use Yii;
use bizHd\base\classes\BaseClass;
use yii\db\Expression;

class OrderClass extends BaseClass
{

    public static $baseFile = '\bizHd\order\models\Order';

    //已退款
    const ORDER_STATUS_REFUND = 6;
    //已取消
    const ORDER_STATUS_CANCEL = 5;
    //完成
    const ORDER_STATUS_COMPLETE = 4;
    //配送中
    const ORDER_STATUS_SENDING = 3;
    //待配送
    const ORDER_STATUS_UN_SEND = 2;
    //待付款
    const ORDER_STATUS_UN_PAY = 1;

    //订单总流程数
    const ORDER_TOTAL_FLOW = 4;

    //未确认配送方式
    const SEND_TYPE_UNKNOWN = 0;
    //自取
    const SEND_TYPE_NO = 1;
    //自己送
    const SEND_TYPE_MYSELF = 2;
    //快递送
    const SEND_TYPE_THIRD = 3;

    //送达时间段
    public static $reachPeriod = [0 => '上午', 1 => '下午', 2 => '晚上'];

    //优惠金额
    public static $randDiscount = [
        50 => [1, 3],
        100 => [5, 9],
        300 => [10, 15],
        500 => [16, 18],
        1000 => [18, 30],
        20000 => [90, 100],
    ];

    //添加订单 ssh 2019.12.5
    public static function addOrder($data)
    {
        $data['orderSn'] = orderSn::getOrderSn();
        $data['payStatus'] = 0;
        $shopId = $data['shopId'] ?? 0;
        //累计订单增加
        $shop = Shop::findBySql('select * from ' . Shop::tableName() . ' where id = :id for update', ['id' => $shopId])->one();
        $shop->unPayOrder += 1;
        $shop->totalOrder += 1;
        $shop->save();
        //将花店每月的总订单数作为编号
        $riseNum = StatOrderCountClass::addOrder($shop);
        $data['sendNum'] = $riseNum;
        $data['totalFlow'] = OrderClass::ORDER_TOTAL_FLOW;
        $return = self::add($data);

        //员工业绩、总业绩增加
        $shopAdminId = $return['shopAdminId'] ?? 0;
        if (!empty($shopAdminId)) {
            $amount = $return['actPrice'] ?? 0.00;
            $shopAdmin = ShopAdminClass::getById($shopAdminId, true);
            $shopAdmin->kdAmount = bcadd($shopAdmin->kdAmount, $amount, 2);
            $shopAdmin->save();
        }
        StatYjClass::addYj($return);

        return $return;
    }

    public static function getByOrderSn($orderSn)
    {
        return self::getByCondition(['orderSn' => $orderSn]);
    }

    //评价 ssh 2019.12.16
    public static function comment($data)
    {
        $id = $data['id'];
        unset($data['id']);
        return self::updateById($id, $data);
    }

    //订单
    public static function getOrderById($id)
    {
        $order = self::getById($id);
        if (empty($order)) {
            return [];
        }
        $order['goodsInfoList'] = OrderGoodsClass::getGoodsListById($id);
        return $order;
    }

    //根据订单查询 ssh 2020.1.4
    public static function getOrderBySn($orderSn)
    {
        $order = self::getByCondition(['orderSn' => $orderSn]);
        if (empty($order)) {
            return [];
        }
        $id = $order['id'];
        $order['goodsInfoList'] = OrderGoodsClass::getGoodsListById($id);
        return $order;
    }

    //返回随机优惠金额 ssh 2019.9.12
    public static function getRandDiscount($amount)
    {
        if ($amount <= 0) {
            return 0;
        }
        $randDiscount = self::$randDiscount;
        krsort($randDiscount);
        $rand = 0;
        foreach ($randDiscount as $currentAmount => $val) {
            if ($amount >= $currentAmount) {
                $rand = rand($val[0], $val[1]);
                break;
            }
        }
        return $rand / 10;
    }

    //第三方支付后回调处理流程 shish 2021.4.30
    public static function thirdPay($payWay, $orderSn, $totalFee, $attach)
    {
        $order = self::getByCondition(['orderSn' => $orderSn], true);
        if (empty($order)) {
            $msg = "没有找到零售订单 orderSn:{$orderSn}";
            Yii::info($msg);
            util::fail($msg);
        }
        if ($order->actPrice != $totalFee) {
            $msg = "零售订单金额与回调通知金额不一致 orderSn:{$orderSn} {$order->actPrice} {$totalFee}";
            Yii::info($msg);
            util::fail($msg);
        }
        $date = date("Y-m-d H:i:s");
        $order->payTime = $date;
        self::complete($order, $payWay);
    }

    //员工开单选择付款方式 shish 2021.5.4
    public static function staffKdPay($payWay, $orderSn)
    {
        $order = self::getByCondition(['orderSn' => $orderSn], true);
        if (empty($order)) {
            $msg = "没有找到零售订单 orderSn:{$orderSn}";
            Yii::info($msg);
            util::fail($msg);
        }
        self::complete($order, $payWay);
    }

    //订单完成 shish 2021.4.20
    public static function complete($order, $payWay)
    {
        if (empty($order)) {
            util::fail('没有找到订单');
        }
        if (isset($order->status) == false || $order->status != self::ORDER_STATUS_UN_PAY) {
            util::fail('订单不是待付款状态');
        }
        $orderGoods = OrderGoodsClass::getAllByCondition(['orderId' => $order->id], null, '*');
        if (empty($orderGoods)) {
            util::fail('没有找到订单商品');
        }
        
        $connection = Yii::$app->db;
        $transaction = $connection->beginTransaction();
        try {
            $order->status = self::ORDER_STATUS_UN_SEND;
            $order->currentFlow = 2;
            $order->payWay = $payWay;
            $order->save();

            //下单完成，开始制单
            $current = time();
            $orderId = $order->id;
            $orderSn = $order->orderSn;
            OrderSendClass::placeOrder(['orderId' => $orderId, 'payTime' => $current, 'orderSn' => $orderSn]);

            $shopId = $order->shopId;
            $shop = Shop::findBySql('select * from ' . Shop::tableName() . ' where id = :id for update', ['id' => $shopId])->one();
            $shop->finishOrder += 1;
            $shop->unSendOrder += 1;
            $shop->unPayOrder -= 1;
            $shop->save();

            // 扣库存
            self::decGoodsStock($orderGoods);

            // 增加销量
            self::updateGoodsActualSold($orderGoods);

            if (isset($order->shopAdminId) && !empty($order->shopAdminId)) {
                //员工开单，自取订单，直接完成
                if ($order->sendType == self::SEND_TYPE_NO) {
                    OrderSendClass::withoutSend($order);
                }
            } else {
                //门店和朋友圈订单并且没有填写收花人的直接将订单置为自取并且是完成状态
                if (isset($order->fromType) && in_array($order->fromType, [0, 2])) {
                    if (isset($order->receiveMobile) && isset($order->address)) {
                        if (empty($order->receiveMobile) && empty($order->address)) {
                            OrderSendClass::withoutSend($order);
                        }
                    }
                }
            };
            $transaction->commit();
        } catch (\Exception $exception) {
            $transaction->rollback();
        }
    }

    //转化出送到时间 ssh 2020.3.15
    public static function getReachTime($order)
    {
        $reachTime = '';
        if (isset($order['reachDate']) && !empty($order['reachDate'])) {
            $prev = date("n-j", strtotime($order['reachDate']));
            $periodData = self::$reachPeriod;
            $periodKey = $order['reachPeriod'];
            $period = isset($periodData[$periodKey]) ? $periodData[$periodKey] : '上午';
            $reachTime = $prev . ' ' . $period;
        }
        return $reachTime;
    }

    //支付成功获取unionId ssh 2020.5.12
    public static function payToUpdateUnionId($merchant, $merchantExtend, $orderSn, $user)
    {
        $mcId = $merchantExtend['wxPayMerchantId'];
        $miniOpenId = isset($user['miniOpenId']) ? $user['miniOpenId'] : '';
        $unionId = isset($user['unionId']) ? $user['unionId'] : '';
        $userId = $user['id'];
        if (empty($unionId)) {
            $unionId = miniUtil::getPaidUnionId($merchant, $miniOpenId, $mcId, (string)$orderSn, 0);
            if (!empty($unionId)) {
                $findUser = UserClass::getByUnionId($unionId);
                if (empty($findUser)) {
                    UserClass::updateByCondition(['id' => $userId], ['unionId' => $unionId]);
                } else {
                    UserClass::mergeUser($findUser, $user);
                }
            }
        }
    }

    //订单到期未付款的订单置成取消状态 ssh 2020.5.25
    public static function setExpire($order)
    {
        $now = time();
        if (!empty($order['deadline']) && $now > $order['deadline']) {
            if ($order['status'] == 0) {
                $id = $order['id'];
                OrderClass::updateById($id, ['status' => 4]);
            }
        }
    }

    // 扣库存
    public static function decGoodsStock($orderGoods)
    {
        foreach ($orderGoods as $goods) {
            Goods::updateAll([
                'stock' => new Expression('`stock` - '. $goods['num'])
            ], [
                'and',
                ['id' => $goods['goodsId']],
                ['<>', 'stock', Goods::FULL_STOCK]
            ]);
        }
    }

    // 更新商品销量
    public static function updateGoodsActualSold($orderGoods)
    {
        foreach ($orderGoods as $goods) {
            GoodsClass::updateById($goods['goodsId'], [
                'actualSold' => new Expression('`actualSold` + '. $goods['num'])
            ]);
        }
    }
}