vendor/codeages/biz-framework/src/Dao/BatchUpdateHelper.php

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

<?php

namespace Codeages\Biz\Framework\Dao;

class BatchUpdateHelper implements BatchHelperInterface
{
    /**
     * @var AdvancedDaoInterface
     */
    private $dao;

    private $identifies = array();

    private $updateColumnsList = array();

    public function __construct($dao)
    {
        $this->dao = $dao;
    }

    public function add($identifyColumn, $identifyKey, $updateColumns)
    {
        if (!array_key_exists($identifyColumn, $this->identifies)) {
            $this->identifies[$identifyColumn] = array();
        }

        $this->identifies[$identifyColumn][] = $identifyKey;
        $this->updateColumnsList[$identifyColumn][$identifyKey] = $updateColumns;
    }

    public function get($identifyColumn, $identifyKey)
    {
        if (isset($this->updateColumnsList[$identifyColumn])
            && isset($this->updateColumnsList[$identifyColumn][$identifyKey])) {
            return $this->updateColumnsList[$identifyColumn][$identifyKey];
        }

        return array();
    }

    public function findIdentifyKeys($identifyColumn)
    {
        if (isset($this->identifies[$identifyColumn])) {
            return $this->identifies[$identifyColumn];
        }

        return array();
    }

    public function flush()
    {
        foreach ($this->identifies as $identifyColumn => $identifyKeys) {
            $this->dao->batchUpdate($identifyKeys, $this->updateColumnsList[$identifyColumn], $identifyColumn);
            unset($this->identifies[$identifyColumn]);
            unset($this->updateColumnsList[$identifyColumn]);
        }
    }
}