huahuibao/console/controllers/GhsPurchaseBalanceMergeController.php

<?php

namespace console\controllers;

use biz\ghs\classes\GhsClass as BizGhsClass;
use bizGhs\custom\classes\AccountMoneyClass;
use common\components\dict;
use yii\console\Controller;

/**
 * ghsApp 采购供货商 xhGhs 余额合并（按采购待结订单重算）
 *
 * 【用途】仅处理 ghsApp 采购供货商行（ownPtStyle=ghs/kmGhs），不处理 hd 花店侧 xhGhs 行（ownPtStyle=hd）。
 * 【公式】净 balance = max(当前正余额,0) - 待结 ghs 采购单 actPrice 合计；debtNum 与有效待结单数对齐。
 * 【可重复执行】默认 force=1，已 balanceMerged 的行也会重算，并清理 actPrice<=0/已取消仍标待结的幽灵单。
 *
 * hd 花店侧供货商请用：php yii balance-merge/run
 *
 * 用法：php yii ghs-purchase-balance-merge/run
 * 预览：php yii ghs-purchase-balance-merge/run --dryRun=1
 * 单户：php yii ghs-purchase-balance-merge/run --ghsId=123
 * 仅未合并：php yii ghs-purchase-balance-merge/run --force=0
 */
class GhsPurchaseBalanceMergeController extends Controller
{
    /** 1=只预览不写库 */
    public $dryRun = 0;

    /** 指定 xhGhs.id，0=扫全表符合条件的 ghsApp 采购供货商行 */
    public $ghsId = 0;

    /** 1=已合并行也重算（默认）；0=仅处理未合并行 */
    public $force = 1;

    public function options($actionID)
    {
        return array_merge(parent::options($actionID), ['dryRun', 'ghsId', 'force']);
    }

    /**
     * 执行或预览：仅 ghsApp 采购供货商（ownPtStyle=ghs/kmGhs）按采购待结订单重算净余额。
     */
    public function actionRun()
    {
        $dry = (int)$this->dryRun === 1;
        $force = (int)$this->force === 1;
        $ghsId = intval($this->ghsId);
        echo $dry ? "【预览：ghsApp 采购供货商按订单重算余额】\n" : "【执行：ghsApp 采购供货商按订单重算余额】\n";
        echo 'force=' . ($force ? '1（含已合并）' : '0（仅未合并）') . PHP_EOL;

        if ($ghsId > 0) {
            $count = $this->mergeOneGhs($ghsId, $dry, $force) ? 1 : 0;
            echo "完成：处理 {$count} 条，dryRun=" . ($dry ? '1' : '0') . PHP_EOL;
            return;
        }

        $count = 0;
        $purchasePtStyles = $this->getGhsAppPurchasePtStyles();
        $where = [
            'ownShopId>' => 0,
            'ownPtStyle' => ['in', $purchasePtStyles],
        ];
        if (!$force && $this->columnExists('xhGhs', 'balanceMerged')) {
            $where['balanceMerged'] = 0;
        } elseif (!$force) {
            $where['debtAmount>'] = 0;
        }

        $list = BizGhsClass::getAllByCondition($where, null, 'id,ownShopId,ownPtStyle,balance,debtAmount,debtNum,balanceMerged', null, true);
        foreach ($list as $ghs) {
            if ($this->mergeOneGhs(intval($ghs->id ?? 0), $dry, $force)) {
                $count++;
            }
        }

        // ownPtStyle 未回填的历史行
        $legacyWhere = [
            'ownShopId>' => 0,
            'ownPtStyle' => 0,
        ];
        if (!$force && $this->columnExists('xhGhs', 'balanceMerged')) {
            $legacyWhere['balanceMerged'] = 0;
        }
        $legacyList = BizGhsClass::getAllByCondition($legacyWhere, null, 'id,ownShopId,ownPtStyle,balance,debtAmount,debtNum,balanceMerged', null, true);
        foreach ($legacyList as $ghs) {
            if ($this->mergeOneGhs(intval($ghs->id ?? 0), $dry, $force)) {
                $count++;
            }
        }

        echo "完成：处理 {$count} 条，dryRun=" . ($dry ? '1' : '0') . PHP_EOL;
    }

    /**
     * ghsApp 采购买方平台类型：二级批发(2)、基地端(4)；不含 hd 花店(1)。
     */
    protected function getGhsAppPurchasePtStyles()
    {
        return [
            (int)dict::getDict('ptStyle', 'ghs'),
            (int)dict::getDict('ptStyle', 'kmGhs'),
        ];
    }

    /**
     * 合并单行；预览模式只打印将写入的金额。
     */
    protected function mergeOneGhs($ghsId, $dry, $force)
    {
        if ($ghsId <= 0) {
            return false;
        }
        $ghs = BizGhsClass::getById($ghsId, true);
        if (empty($ghs)) {
            echo "[跳过] id={$ghsId} 不存在" . PHP_EOL;
            return false;
        }
        if (!AccountMoneyClass::isGhsAppPurchaseSupplierRow($ghs)) {
            $ownPtStyle = intval($ghs->ownPtStyle ?? 0);
            echo "[跳过] id={$ghsId} 非 ghsApp 采购供货商行（ownPtStyle={$ownPtStyle}，hd 行请用 balance-merge）" . PHP_EOL;
            return false;
        }

        $ownShopId = intval($ghs->ownShopId ?? 0);
        $oldBalance = bcadd((string)($ghs->balance ?? '0'), '0', 2);
        $oldDebtNum = intval($ghs->debtNum ?? 0);
        $fixedOrders = AccountMoneyClass::countInvalidPurchaseDebtOrders($ghsId);
        $debtStats = AccountMoneyClass::getValidPurchaseDebtStats($ghsId);
        $orderDebt = $debtStats['amount'];
        $orderDebtNum = $debtStats['num'];
        $positiveCredit = bccomp($oldBalance, '0', 2) > 0 ? $oldBalance : '0.00';
        $newBalance = bcsub($positiveCredit, $orderDebt, 2);

        if ($dry) {
            echo "[ghsApp采购供货商] id={$ghsId} ownShopId={$ownShopId} ownPtStyle={$ghs->ownPtStyle}"
                . " 原balance={$oldBalance} 原debtNum={$oldDebtNum}"
                . " 清理幽灵单={$fixedOrders}"
                . " 待结{$orderDebtNum}笔合计={$orderDebt} => 新balance={$newBalance} 新debtNum={$orderDebtNum}" . PHP_EOL;
            return true;
        }

        $locked = BizGhsClass::getLockById($ghsId);
        $fixedOrders = AccountMoneyClass::syncInvalidPurchaseDebtOrders($ghsId);
        AccountMoneyClass::mergeOwnShopGhsBalanceFromPurchaseOrdersIfNeeded($locked, false, $force);
        echo "[已重算] id={$ghsId} 清理幽灵单={$fixedOrders} 待结{$orderDebtNum}笔合计={$orderDebt}"
            . " balance {$oldBalance}=>{$newBalance} debtNum {$oldDebtNum}=>{$orderDebtNum}" . PHP_EOL;
        return true;
    }

    /**
     * 判断 xhGhs 是否已有 balanceMerged 字段。
     */
    protected function columnExists($table, $column)
    {
        $db = \Yii::$app->db;
        $schema = $db->getTableSchema($table, true);
        return $schema && isset($schema->columns[$column]);
    }
}