huahuibao/biz-hd/purchase/classes/PurchaseClearClass.php

<?php

namespace bizHd\purchase\classes;

use biz\ghs\classes\GhsClass;
use biz\shop\classes\ShopClass;
use biz\shop\classes\ShopYeChangeClass;
use biz\wx\classes\WxMessageClass;
use bizGhs\clear\classes\ClearClass;
use bizGhs\custom\classes\CustomClass;
use bizGhs\order\classes\OrderClass;
use bizHd\base\classes\BaseClass;
use bizHd\shop\classes\MainClass;
use common\components\dict;
use common\components\noticeUtil;
use common\components\orderSn;
use common\components\util;
use Yii;

class PurchaseClearClass extends BaseClass
{

    public static $baseFile = '\bizHd\purchase\models\PurchaseClear';

    const STATUS_AWAIT_PAY = 1;
    const STATUS_HAS_PAY = 2;
    const STATUS_EXPIRE = 3;

    public static function addOrder($data, $ghs)
    {
        $ghsId = $ghs->id;
        $customId = $ghs->customId;
        $custom = CustomClass::getById($customId, true);
        if (empty($custom)) {
            util::fail('没有找到客户');
        }

        $ghsShopId = $ghs->shopId ?? 0;
        $ghsShop = ShopClass::getById($ghsShopId, true);
        $ghsShopName = $ghsShop->shopName ?? '';
        $ghsShopName = $ghsShopName == '首店' ? '总店' : $ghsShopName;

        $orderSn = orderSn::getPurchaseClearSn();
        $purchaseIdStr = $data['purchaseIds'] ?? '';
        $arr = explode(',', $purchaseIdStr);
        if (empty($arr)) {
            util::fail('请选择采购单');
        }
        //订单太多数据库会报错
        if (count($arr) > 100) {
            util::fail('订单太多，请选月份再结');
        }
        $purchaseList = PurchaseClass::getAllByCondition(['id' => ['in', $arr]], null, '*', null, true);
        if (empty($purchaseList)) {
            util::fail('请选择采购单');
        }
        $totalPrice = 0;
        $currentGhsId = $data['ghsId'] ?? 0;
        foreach ($purchaseList as $purchase) {
            if ($purchase->debt != PurchaseClass::DEBT_YES) {
                util::fail('请选择有欠款的采购单');
            }
            if ($purchase->ghsId != $currentGhsId) {
                util::fail('请选择同个供货商的订单');
            }
            $totalPrice = bcadd($totalPrice, $purchase->remainDebtPrice, 2);
        }
        $data['prePrice'] = $totalPrice;
        $data['actPrice'] = $totalPrice;
        $data['realPrice'] = $totalPrice;
        $data['orderSn'] = $orderSn;
        // 生成并保存 salt 字段，用于结账单的验签和防篡改分享链接
        $data['salt'] = $data['salt'] ?? \common\components\stringUtil::charsShuffleLowerCase(10);
        //10个小时
        $deadTime = time() + 36000;
        $data['deadline'] = date("Y-m-d H:i:s", $deadTime);
        $params = [
            'ghsId' => $ghsId,
            'ghsName' => $ghs['name'] ?? '',
            'ghsMobile' => $ghs['mobile'] ?? '',
            'ghsAvatar' => $ghs['avatar'] ?? '',
            'ghsAddress' => $ghs['address'] ?? '',
            'customId' => $customId,
            'customName' => $custom['name'] ?? '',
            'customAvatar' => $custom['avatar'] ?? '',
            'customMobile' => $custom['mobile'] ?? '',
            'customAddress' => $custom['address'] ?? '',
            'num' => count($arr),
            'ghsShopName' => $ghsShopName,
        ];
        $data = array_merge($data, $params);
        $clear = self::add($data);
        $pairs = OrderCgClearClass::buildPairsFromPurchases($purchaseList);
        OrderCgClearClass::bindRelations($clear, $pairs);
        return $clear;
    }

    //第三方支付回调 ssh 2021.4.28
    public static function thirdPay($payWay, $orderSn, $totalFee, $attach, $transactionId)
    {
        $info = self::getByCondition(['orderSn' => $orderSn], true);
        $isOldSnPay = false; // 标记是否使用了老单号支付
        if (empty($info)) {
            // 尝试从 Redis 读取老单号映射，防止用户支付了已失效的旧单号导致回调找不到订单
            $redisKey = 'hd_clear_old_sn_map_' . $orderSn;
            $orderId = Yii::$app->redis->executeCommand('GET', [$redisKey]);
            if (!empty($orderId)) {
                $info = self::getById($orderId);
                $isOldSnPay = true; // 确认为老单号支付
            }
        }
        if (empty($info)) {
            $msg = "没有找到清算订单 orderSn:{$orderSn} {$attach}";
            noticeUtil::push($msg, '15280215347');
            Yii::info($msg);
            util::fail($msg);
        }
        if ($info->actPrice != $totalFee) {
            $msg = "清算订单金额与回调通知金额不一致 orderSn:{$orderSn} {$info->actPrice} {$totalFee} {$attach}";
            noticeUtil::push($msg, '15280215347');
            Yii::info($msg);
            util::fail($msg);
        }

        //临时解决微信一秒内通知二次问题
        $id = $info->id;
        $info = self::getLockById($id);

        // 如果是老单号支付，将数据库中的 orderSn 修正为实际支付的老单号，并同步更新关联表的 clearSn
        if ($isOldSnPay) {
            $info->orderSn = $orderSn;
            OrderCgClearClass::updateClearSnByClearId($id, $orderSn);
        }

        $info->payWay = $payWay;
        $info->onlinePay = dict::getDict('onlinePay', 'yes');
        $info->thirdNo = $transactionId;
        $info->save();

        self::complete($info, $payWay);
    }

    //支付成功后的流程 ssh 2021.4.28
    public static function complete($order, $payWay)
    {
        if (empty($order)) {
            util::fail('没有找到订单');
        }
        if (isset($order->status) && $order->status == self::STATUS_EXPIRE) {
            if ($order->onlinePay == dict::getDict('onlinePay', 'yes')) {
                $ghsName = $order->ghsName ?? '';
                $customName = $order->customName ?? '';
                $orderSn = $order->orderSn ?? '';
                noticeUtil::push("花店线上付款结账，但结账单是取消状态。供货商：{$ghsName}，客户：{$customName}，订单编号：{$orderSn}", '15280215347');
                $ghsShopId = $order->ghsShopId;
                $shop = ShopClass::getById($ghsShopId, true);
                if (!empty($shop)) {
                    //原路退回给客户
                    ClearClass::refundMoney($shop, $order);
                }
                util::stop("SUCCESS");
            }
        }
        if (!isset($order->status) || $order->status != self::STATUS_AWAIT_PAY) {
            $ghsName = $order->ghsName ?? '';
            $customName = $order->customName ?? '';
            $orderSn = $order->orderSn ?? '';
            if($order->status == self::STATUS_HAS_PAY){
                echo "SUCCESS";
                noticeUtil::push("花店线上付款结账，但结账单不是待付款状态。已经返回 success 。供货商：{$ghsName}，客户：{$customName}，订单编号：{$orderSn}", '15280215347');
                exit();
            }
            noticeUtil::push("花店线上付款结账，但结账单不是待付款状态。供货商：{$ghsName}，客户：{$customName}，订单编号：{$orderSn}", '15280215347');
            util::fail('订单不是待付款状态');
        }
        $order->status = self::STATUS_HAS_PAY;
        $order->payTime = date("Y-m-d H:i:s");
        $order->save();

        $clearId = $order->id;
        $orderSn = $order->orderSn;
        $arr = OrderCgClearClass::getCgIdsByClearId($clearId);

        //供货商欠款变更
        $ghsId = $order->ghsId;
        $ghs = GhsClass::getLockById($ghsId);
        if (empty($ghs)) {
            util::fail('没有找到供货商信息');
        }

        $customId = $ghs->customId;
        $custom = CustomClass::getLockById($customId);
        if (empty($custom)) {
            util::fail('没有找到客户信息');
        }

        \bizHd\ghs\classes\GhsClass::clearDebtAmountReduce($ghs, $custom, $order->actPrice, $order);

        $shopId = $ghs->shopId;
        $shop = ShopClass::getLockById($shopId);
        if (empty($shop)) {
            util::fail('没有找到供货商门店');
        }
        $mainId = $shop->mainId ?? 0;
        $main = MainClass::getLockById($mainId);
        if (empty($main)) {
            util::fail('没有main数据呢');
        }
        if ($order->onlinePay == dict::getDict('onlinePay', 'yes')) {
            //供货商门店余额增加
            ShopClass::customClearAddBalance($main, $shop, $order);
        }
        //供货商的门店应收客户款减少
        $currentGathering = bcsub($main->mayGathering, $order->actPrice, 2);
        $main->mayGathering = $currentGathering;
        $main->save();

        if (empty($arr)) {
            $msg = "结算订单 orderSn：{$orderSn} 支付成功，回调处理，没有找到采购订单";
            util::fail($msg);
        }
        $list = PurchaseClass::getAllByCondition(['id' => ['in', $arr]], null, '*', null, true);
        if (empty($list)) {
            $msg = "结算订单 orderSn：{$orderSn} 支付成功，回调处理，没有找到采购订单！";
            util::fail($msg);
        }
        $clearTime = date("Y-m-d H:i:s");
        //采购单状态变更
        $saleIds = OrderCgClearClass::getOrderIdsByClearId($clearId);
        foreach ($list as $purchase) {
            $purchase->debt = PurchaseClass::DEBT_NO;
            $purchase->payWay = $payWay;
            $purchase->clearId = $clearId;
            $purchase->remainDebtPrice = 0;
            $purchase->clearTime = $clearTime;
            $purchase->save();
        }

        //销售单状态变化
        if (!empty($saleIds)) {
            OrderClass::updateByIds($saleIds, ['debt' => OrderClass::DEBT_NO, 'clearId' => $clearId, 'remainDebtPrice' => 0, 'clearTime' => $clearTime]);
        }

        //客户付供货商款减少
        CustomClass::clearDebtAmountReduce($custom, $ghs, $order->actPrice, $order);
        OrderCgClearClass::markDoneByClearId($clearId);
    }

}