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

<?php

namespace bizGhs\order\classes;

use biz\shop\classes\ShopAdminClass;
use biz\shop\classes\ShopClass;
use biz\shop\models\Shop;
use bizGhs\custom\models\Custom;
use bizGhs\express\services\DadaExpressServices;
use bizGhs\order\models\Order;
use bizGhs\order\traits\OrderTrait;
use bizGhs\product\classes\ProductClass;
use bizGhs\admin\classes\AdminClass;
use bizGhs\custom\classes\CustomClass;
use bizGhs\stat\classes\StatOrderCountClass;
use bizGhs\stat\classes\StatYjClass;
use bizGhs\stock\classes\StockRecordClass;
use bizGhs\stock\services\StockRecordService;
use bizHd\purchase\classes\PurchaseClass;
use bizHd\stat\classes\StatIncomeClass;
use bizHd\stat\classes\StatOrderClass;
use common\components\dict;
use common\components\httpUtil;
use common\components\imgUtil;
use common\components\orderSn;
use common\components\stringUtil;
use common\components\util;
use bizGhs\base\classes\BaseClass;

class OrderClass extends BaseClass
{
    use OrderTrait;
    public static $baseFile = '\bizGhs\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 SEND_TYPE_UNKNOWN = 1;
    //自取
    const SEND_TYPE_NO = 2;
    //自己送
    const SEND_TYPE_MYSELF = 3;
    //快递送
    const SEND_TYPE_THIRD = 4;


    //待付款
    const PAY_STATUS_UN_PAY = 1;
    //已付款
    const PAY_STATUS_HAS_PAY = 2;


    //待配送
    const SEND_STATUS_UN_SEND = 1;
    //配送中
    const SEND_STATUS_SENDING = 2;
    //配送完成
    const SEND_STATUS_COMPLETE = 3;


    //订单总流程数
    const TOTAL_FLOW = 3;

    //清算方式
    //欠款
    const CLEAR_DEBT = 1;
    //已付款
    const CLEAR_HAS_GATHERING = 2;

    //没有欠款
    const DEBT_NO = 0;
    //欠款
    const DEBT_YES = 1;

    //供应商开单生成
    const ORDER_TYPE_GHS_ADD = 1;
    //零售采购生成
    const ORDER_TYPE_HD_ADD = 2;

    public static $sendTypeMap = [
        self::SEND_TYPE_UNKNOWN => '未确认',
        self::SEND_TYPE_NO => '自取',
        self::SEND_TYPE_MYSELF => '商家配送',
        self::SEND_TYPE_THIRD => '快递配送',
    ];


    //添加订单 ssh 2019.12.5
    public static function addOrder($data)
    {
        $sjId = $data['sjId'] ?? 0;
        $month = date("Ym");
        $orderSn = orderSn::getGhsOrderSn();
        $data['orderSn'] = $orderSn;
        $data['payStatus'] = self::PAY_STATUS_UN_PAY;
        $data['customId'] = isset($data['customId']) && !empty($data['customId']) ? $data['customId'] : 0;

        //花材列表
        $product = $data['product'];
        $respond = OrderItemClass::replaceItem($orderSn, $product);

        $sendCost = isset($data['sendCost']) && is_numeric($data['sendCost']) ? $data['sendCost'] : 0;
        $data['sendCost'] = $sendCost;
        $data['bigNum'] = $respond['bigNum'] ?? 0;
        $data['smallNum'] = $respond['smallNum'] ?? 0;
        $price = $respond['price'] ?? 0;
        $currentPrice = bcadd($price, $sendCost, 2);
        $data['prePrice'] = $currentPrice;

        if (isset($data['modifyPrice'])) {
            //商家打折，修改金额
            $modifyPrice = $data['modifyPrice'] ?? 0;
            if ($modifyPrice > $currentPrice) {
                util::fail('实收金额大于订单总金额');
            }
            if ($modifyPrice < $currentPrice) {
                $data['discountAmount'] = bcsub($currentPrice, $modifyPrice, 2);
                $data['discountType'] = dict::getDict('discountType', 'discount');
                $currentPrice = $modifyPrice;
            }
        }

        $data['actPrice'] = $currentPrice;
        $data['realPrice'] = $currentPrice;

        //如果有平台补贴
        if (isset($data['discountType']) && $data['discountType'] == dict::getDict('discountType', 'usePtCoupon')) {
            $discountAmount = $data['discountAmount'] ?? 0;
            $data['realPrice'] = bcsub($currentPrice, $discountAmount, 2);
        }

        //将花店每月的总   订单数作为编号
        $data['sendNum'] = StatOrderCountClass::addOrder($month, $sjId);
        $data['sendTime'] = isset($data['sendTime']) && !empty($data['sendTime']) ? $data['sendTime'] : '0000-00-00 00:00:00';
        //订单有效期
        $validTime = dict::getDict('sale_purchase_order_valid');
        $current = time() + $validTime;
        $data['deadline'] = date("Y-m-d H:i:s", $current);
        $data['status'] = self::ORDER_STATUS_UN_PAY;
        $currentShopId = $data['shopId'] ?? 0;
        //计算总重量(kg)
        $weight = 0;
        $productMapData = ProductClass::getProductMapData($product);
        foreach ($product as $key => $val) {
            $w = ProductClass::getWeight($val['productId'], $val['bigNum'], $val['smallNum']);
            $productId = $val['productId'];
            $weight = bcadd($w, $weight, 2);
            //减库存
            $orderType = $data['orderType'] ?? 1;
            $checkStock = $orderType == OrderClass::ORDER_TYPE_HD_ADD ? true : false;
            $stockInfo = ProductClass::decreaseStock($val['productId'], $val['bigNum'], $val['smallNum'], $checkStock);
            //记录库存流水
            $recordData = [];
            $recordData['sjId'] = $sjId;
            $recordData['shopId'] = $currentShopId;
            $recordData['itemId'] = $productMapData[$productId]['itemId'] ?? 0;
            $ratio = $productMapData[$productId]['ratio'] ?? 0;
            $recordData['itemNum'] = ProductClass::mergeItemNum($val['bigNum'], $val['smallNum'], $ratio);
            $recordData['oldStock'] = $stockInfo['oldStock'];
            $recordData['newStock'] = $stockInfo['newStock'];
            $recordData['productId'] = $productId;
            $recordData['orderSn'] = $orderSn;
            StockRecordService::addSellStockOrderRecord($recordData);
        }

        $data['weight'] = $weight;

        //门店总订单数+1

        $shop = ShopClass::getLockById($currentShopId);
        if (empty($shop)) {
            util::fail('没有找到门店');
        }
        $shop->totalOrder += 1;
        $shop->unPayOrder += 1;
        $shop->save();
        $current = time() + 300;
        $data['deadline'] = isset($data['deadline']) ? $data['deadline'] : date("Y-m-d H:i:s", $current);
        $return = self::add($data, true);
        return $return;
    }

    //根据订单编号查询 ssh 2021.19
    public static function getByOrderSn($orderSn, $returnObj = false)
    {
        return self::getByCondition(['orderSn' => $orderSn], $returnObj);
    }

    //订单列表 ssh 2021.1.19
    public static function getOrderList($where)
    {
        $data = self::getList('*', $where, 'addTime DESC');
        $data['list'] = self::groupOrder($data['list'], true, false, false, true);
        return $data;
    }

    //显示操作按钮
    public static function getShowButton($showButton, $isList, $order)
    {
        if ($showButton == false) {
            return [];
        }

        $print = ['type' => 'print', 'show' => 1, 'disable' => 0, 'name' => '打印'];

        if ($isList) {

            //订单列表页显示的按钮

            $item = ['type' => 'item', 'show' => 0, 'disable' => 1, 'name' => '改花材'];
            $send = ['type' => 'send', 'show' => 1, 'disable' => 0, 'name' => '发货'];
            $selfGet = ['type' => 'selfGet', 'show' => 1, 'disable' => 1, 'name' => '自取'];
            if ($order['status'] == self::ORDER_STATUS_UN_PAY) {
                //待付款订单，改花材按钮可点击
                $item['disable'] = 0;
                $send['disable'] = 1;
                $selfGet['disable'] = 1;
                $print['disable'] = 1;
            }
            if ($order['status'] == self::ORDER_STATUS_UN_SEND) {
                //待配送订单，改花材按钮不可点，自取可点
                $item['disable'] = 1;
                $selfGet['disable'] = 0;
            }

            //自取订单发货按钮置灰
            if ($order['sendType'] == self::SEND_TYPE_NO) {
                $send['disable'] = 1;
            }

            //取消订单置灰
            if ($order['status'] == self::ORDER_STATUS_CANCEL) {
                $send['disable'] = 1;
                $selfGet['disable'] = 1;
            }
            return [$item, $send, $selfGet, $print];

        } else {

            //订单详情页显示的按钮

            //待确认订单显示延期付和已付款
            if ($order['status'] == self::ORDER_STATUS_UN_PAY) {
                $debtPay = ['type' => 'debtPay', 'show' => 0, 'disable' => 0];
                $hasPay = ['type' => 'hasPay', 'show' => 0, 'disable' => 0];
                return [$debtPay, $hasPay];
            }

            //待配送订单显示打印、发货和自取
            if ($order['status'] == self::ORDER_STATUS_UN_SEND) {

                $item = ['type' => 'item', 'show' => 0, 'disable' => 1];
                $selfGet = ['type' => 'selfGet', 'show' => 1, 'disable' => 1];
                $send = ['type' => 'send', 'show' => 1, 'disable' => 1];
                if ($order['hasItem'] == 2) {
                    return [$print, $item, $selfGet, $send];
                }
                $selfGet['disable'] = 0;
                $send['disable'] = 0;
                $item['disable'] = 0;
                return [$print, $item, $selfGet, $send];
            }
            //配送中显示按钮
            if ($order['status'] == self::ORDER_STATUS_SENDING) {
                $send = ['type' => 'send', 'show' => 1, 'disable' => 0];
                return [$print, $send];
            }
            //完成
            if ($order['status'] == self::ORDER_STATUS_COMPLETE) {
                $send = ['type' => 'send', 'show' => 1, 'disable' => 0];
                //自取订单不显示发货按钮
                if ($order['sendType'] == self::SEND_TYPE_NO) {
                    $send['show'] = 0;
                }
                return [$print, $send];
            }

            //取消订单置灰
            if ($order['status'] == self::ORDER_STATUS_CANCEL) {
                $selfGet['disable'] = 1;
                $send['disable'] = 1;
                $print['disable'] = 1;
            }

            return [];
        }

    }

    //显示进度 ssh 2021.3.1
    public static function getShowProgress($showProgress, $order)
    {
        if ($showProgress == false) {
            return [];
        }
        $create = ['name' => '创建', 'complete' => 1];
        $unConfirm = ['name' => '待确认', 'complete' => 0];
        if ($order['status'] > 0) {
            $unConfirm['complete'] = 1;
        }
        $out = ['name' => '出库', 'complete' => 0];
        if ($order['status'] > 1) {
            $out['complete'] = 1;
        }
        return [$create, $unConfirm, $out];
    }

    public static function getShowItem($showItem, $order)
    {
        if ($showItem == false) {
            return ['list' => [], 'itemStat' => []];
        }
        $orderSn = $order['orderSn'];
        $list = OrderItemClass::getOrderItem($orderSn);
        $totalPrice = 0;
        $totalBigNum = 0;
        $totalSmallNum = 0;
        $kind = 0;
        $itemStat = [];
        if (!empty($list)) {
            foreach ($list as $key => $val) {
                $list[$key]['property'] = $val['rank'] . '级';
                $price = $val['price'];
                $totalPrice = stringUtil::calcAdd($totalPrice, $price);
                $kind++;
                $currentBigNum = $val['bigNum'];
                $currentSmallNum = $val['smallNum'];
                $totalBigNum = stringUtil::calcAdd($totalBigNum, $currentBigNum);
                $totalSmallNum = stringUtil::calcAdd($totalSmallNum, $currentSmallNum);
            }
            $itemStat = ['kind' => $kind, 'bigNum' => $totalBigNum, 'smallNun' => $totalSmallNum, 'totalPrice' => $totalPrice];
        }
        return ['list' => $list, 'itemStat' => $itemStat];
    }

    //整合订单员工和供应商等信息 ssh 2021.1.19
    //$isList 是否列表页
    public static function groupOrder($list, $showButton = false, $showItem = false, $showExpress = false, $isList = false)
    {
        if (empty($list)) {
            return $list;
        }

        $adminIds = array_unique(array_filter(array_column($list, 'adminId')));
        $adminInfo = AdminClass::getAdminByIds($adminIds, null, 'id');

        foreach ($list as $key => $val) {
            $adminId = $val['adminId'] ?? 0;
            $list[$key]['adminName'] = $adminInfo[$adminId]['name'] ?? '';
            $list[$key]['customAddress'] = $val['fullAddress'] ?? '';

            //显示列表页的操作按钮
            $list[$key]['buttonList'] = self::getShowButton($showButton, $isList, $val);

            //显示产品
            $showItem = self::getShowItem($showItem, $val);
            $list[$key]['product'] = $showItem['list'];
            $list[$key]['productStat'] = $showItem['itemStat'];

            $showResetItem = 0;
            //待付款订单显示改花材按钮
            if ($val['status'] == self::PAY_STATUS_UN_PAY) {
                $showResetItem = 1;
            }

            $list[$key]['showResetItem'] = $showResetItem;

            //获取配送进展
            $expressProgress = '';
            if ($val['sendType'] == 4) {
                $expressInfo = OrderExpressClass::getByCondition(['orderSn' => $val['orderSn']]);
                if ($expressInfo) {
                    $expressProgress = ['progressName' => OrderExpressClass::$statusMap[$expressInfo['status']] ?? ''];
                }
            }
            $list[$key]['sendTypeName'] = self::$sendTypeMap[$val['sendType']] ?? '未知';
            $list[$key]['expressProgress'] = $expressProgress;
            $list[$key]['customAvatarUrl'] = imgUtil::groupImg($val['customAvatar']);
            $list[$key]['customName'] = isset($val['customId']) && !empty($val['customId']) ? $val['customName'] : '散客';
        }
        return $list;
    }

    //订单的验证 ssh 2021.3.2
    public static function valid($info, $shopId)
    {
        if (empty($info)) {
            util::fail('没有找到订单');
        }
        if (isset($info['shopId']) && $info['shopId'] == $shopId) {
            return true;
        }
        util::fail('没有权限操作的订单');
    }

    //订单到期未付款未确认的订单置成取消状态 ssh 2021.1.23
    public static function setExpire($order)
    {
        $now = time();
        if (isset($order['deadline']) && $now > $order['deadline']) {
            if ($order['status'] == self::ORDER_STATUS_UN_PAY) {
                $id = $order['id'];
                self::updateById($id, ['status' => self::ORDER_STATUS_CANCEL]);
            }
        }
    }

    //快递送 ssh 2021.3.16
    public static function thirdSend($order, $expressInfo)
    {
        if ($order->status == self::ORDER_STATUS_UN_PAY) {
            util::fail('订单未付款');
        }
        if ($order->status != self::ORDER_STATUS_UN_SEND) {
            util::fail('不是待配送状态');
        }
        $id = $order->id;
        $expressId = $expressInfo['expressId'] ?? 1;
        $expressName = $expressInfo['deliveryName'] ?? '达达';
        $expressRemark = $expressInfo['remark'] ?? '';

        $order->status = self::ORDER_STATUS_SENDING;
        $order->sendType = self::SEND_TYPE_THIRD;
        $order->expressId = $expressId;
        $order->save();

        $shopId = $order->shopId;
        $shop = Shop::findBySql('select * from ' . Shop::tableName() . ' where id = :id for update', ['id' => $shopId])->one();
        if (empty($shop)) {
            util::fail('没有找到门店');
        }
        $shop->unSendOrder -= 1;
        $shop->sendingOrder += 1;
        $shop->save();

        $express = OrderExpressClass::getByCondition(['orderId' => $id]);
        if (!empty($express)) {
            util::fail('已经发过了');
        }

        //达达

        $dadaRes = DadaExpressServices::addOrder($order, $expressRemark);

        $orderSn = $order->orderSn;
        $sjId = $order->sjId ?? 0;

        /*
        $getInfo = ExpressClass::getExpressInfo($expressId);
        $hour = $expressInfo['sendTime'] ?? '12:00';
        $sendCost = 12;
        $distance = 5;

        $sendTime = strtotime(date("Y-m-d ") . $hour);
        OrderSendClass::thirdSend($order);
          */
        $sendTime = $order->sendTime;
        if ($sendTime == '0000-00-00 00:00:00') {
            $sendTime = time();
        } else {
            $sendTime = strtotime($order->sendTime);
        }
        $expData = [
            'orderId' => $id,
            'orderSn' => $orderSn,
            'sjId' => $sjId,
            'expressId' => $expressId,
            'sendTime' => $sendTime,
            'cost' => $dadaRes['fee'],
            'distance' => $dadaRes['distance'],
            'status' => 1,
            'expressName' => $expressName,
            'remark' => $expressRemark,
        ];
        OrderExpressClass::addExpress($expData);
        OrderSendClass::thirdSend($order);
        $respond = [
            'expressName' => $expressName,
            'expressId' => $expressId,
            'distance' => $dadaRes['distance'],
            'cost' => $dadaRes['fee'],
            'status' => 2,
            'tip' => 0,
        ];

        //采购单变成已发货
        $purchaseId = $order->purchaseId ?? 0;
        PurchaseClass::sending($purchaseId);

        return $respond;
    }

    //本店送 ssh 2021.1.24
    public static function selfSend($info)
    {
        if ($info->status == self::ORDER_STATUS_UN_PAY) {
            util::fail('订单未付款');
        }
        if ($info->status != self::ORDER_STATUS_UN_SEND) {
            util::fail('不是待配送状态');
        }
        $info->status = self::ORDER_STATUS_SENDING;
        $info->sendType = self::SEND_TYPE_MYSELF;
        $info->save();

        $shopId = $info->shopId;
        $shop = Shop::findBySql('select * from ' . Shop::tableName() . ' where id = :id for update', ['id' => $shopId])->one();
        if (empty($shop)) {
            util::fail('没有找到门店');
        }
        $shop->unSendOrder -= 1;
        $shop->sendingOrder += 1;
        $shop->save();

        OrderSendClass::selfSend($info);
        //采购单变成已发货
        $purchaseId = $info->purchaseId ?? 0;
        PurchaseClass::sending($purchaseId);
    }

    //订单完成 ssh 2020.3.12
    public static function complete($order, $shop)
    {
        $order->status = OrderClass::ORDER_STATUS_COMPLETE;
        $order->currentFlow = self::TOTAL_FLOW;
        $order->totalFlow = self::TOTAL_FLOW;
        $order->save();

        $shop->finishOrder += 1;
        $shop->sendingOrder -= 1;
        $shop->save();
        return $order;
    }

    //修改订单表的配送信息 linqh 2021.3.28
    public static function updateCustomExpressInfo($id, $expressAddInfo)
    {
        $data = [
            'province' => $expressAddInfo['province'],
            'city' => $expressAddInfo['city'],
            'address' => $expressAddInfo['address'],
            'floor' => $expressAddInfo['floor'],
            'fullAddress' => $expressAddInfo['city'] . $expressAddInfo['address'] . $expressAddInfo['floor'],
            'lat' => $expressAddInfo['lat'],
            'long' => $expressAddInfo['long'],
            'sendTime' => $expressAddInfo['sendTime'],
        ];
        return self::updateById($id, $data);
    }

    //最客户最近的订单 shish 2021.5.4
    public static function getCustomOrder($id, $limit = 10, $order = null, $with = null)
    {
        $where = ['customId' => $id, 'payStatus' => 1];
        return self::getLimitList('*', $where, $limit, $order, $with);
    }

    //销售单取消 shish 2021.5.14
    public static function cancel($id)
    {
        $order = self::getLockById($id);
        if ($order->status != OrderClass::ORDER_STATUS_UN_PAY) {
            util::fail("销售单{$id}不是待付款状态，无法取消");
        }
        $order->status = self::ORDER_STATUS_CANCEL;
        $order->save();

        $shopId = $order->shopId;
        $shop = ShopClass::getLockById($shopId);
        if (empty($shop)) {
            util::fail('没有找到门店');
        }
        $shop->unPayOrder -= 1;
        $shop->cancelOrder += 1;
        $shop->save();
        //加回库存
        $orderItem = OrderItemClass::getOrderItem($order->orderSn);
        foreach ($orderItem as $v) {
            $stockInfo = ProductClass::addStockByItemNum($v['productId'], $v['num']);
            $recordData = [];
            $recordData['sjId'] = $order->sjId;
            $recordData['shopId'] = $shopId;
            $recordData['itemId'] = $v['itemId'] ?? 0;
            $recordData['itemNum'] = $v['num'];
            $recordData['oldStock'] = $stockInfo['oldStock'];
            $recordData['newStock'] = $stockInfo['newStock'];
            $recordData['productId'] = $v['productId'];
            $recordData['orderSn'] = $order->orderSn;
            StockRecordService::addSellStockOrderCancelRecord($recordData);
        }
        return $order;
    }

}