src/Biz/Activity/Dao/Impl/ActivityLearnLogDaoImpl.php

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

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

<?php

namespace Biz\Activity\Dao\Impl;

use Biz\Activity\Dao\ActivityLearnLogDao;
use Biz\Lock;
use Codeages\Biz\Framework\Dao\GeneralDaoImpl;

class ActivityLearnLogDaoImpl extends GeneralDaoImpl implements ActivityLearnLogDao
{
    protected $table = 'activity_learn_log';

    protected $lock;

    public function create($fields)
    {
        $month = date('m', time());
        if (0 !== $month % 2) {
            return parent::create($fields);
        }
        $lock = $this->getLock();
        try {
            $suffix = date('Y_m', strtotime('-2 month'));
            $lock->get('activity_learn_log', 10);
            if ($this->isTableExists($suffix)) {
                $this->archiveLogs($suffix);
            }
            $lock->release('activity_learn_log');

            return parent::create($fields);
        } catch (\Exception $e) {
            $lock->release('activity_learn_log');
            throw $e;
        }
    }

    private function isTableExists($subfix)
    {
        $sql = "SHOW tables LIKE '{$this->table()}_{$subfix}'";
        $tables = $this->db()->fetchAll($sql, array());

        return !empty($tables);
    }

    private function archiveLogs($subfix)
    {
        $sql = "RENAME TABLE {$this->table()} TO {$this->table()}_{$subfix}";
        $this->db()->execute($sql);
        $sql = "CREATE TABLE {$this->table()} LIKE {$this->table()}_{$subfix}";
        $this->db()->execute($sql);
    }

    public function getRecentFinishedLogByActivityIdAndUserId($activityId, $userId)
    {
        $sql = "SELECT * FROM {$this->table()} WHERE activityId = ? and userId = ? and event = 'finish'";

        return $this->db()->fetchAll($sql, array($activityId, $userId)) ?: array();
    }

    /**