ngds/common/helpers/bonus/Calc/BaseBusiness.php

<?php

namespace common\helpers\bonus\Calc;

use common\models\Period;
use common\traits\ResponseTrait;

class BaseBusiness
{
    use ResponseTrait;

    protected $_periodNum = 0;

    protected $_calc_db_name = 'dbCalc';

    const CALC_DB_NAME = 'dbCalc';

    protected $_limit = 10000;


    public function __construct($periodNum)
    {
        if (is_numeric($periodNum)) {
            $this->_periodNum = $periodNum;
            $periodObj        = Period::instance();
//            $periodDataArr = $periodObj->setPeriodNum($periodNum);
//            $this->_periodId = $periodDataArr['ID'];
            $this->_isCalcMonth = $periodObj->isCalcMonth($periodNum);
//            $this->_calcYear = $periodObj->getYear($periodNum);
//            $this->_calcMonth     = $periodObj->getMonth($periodNum);
            $this->_calcYearMonth = $periodObj->getYearMonth($periodNum);
        } else {
            //todo
            return false;
        }
    }

    /**
     *  从结算系统拉取周期信息并更新
     * @return int
     */
    public static function pullPeriodForUpdate($periodNum = 0): int
    {
        if (empty($periodNum) || !is_numeric($periodNum)) {
            return 0;
        }
        $db     = self::CALC_DB_NAME;
        //同步字段去掉 IS_CALCULATED, 否则自动拉取的轮询间隔之间奖金计算完成后更新该字段则会认为已经拉取过奖金数据
        $period = \Yii::$app->$db->createCommand("SELECT 
                PERIOD_NUM,
                IS_PERFED,
                IS_PERFING,
                IS_CALCING,
                PERF_PERCENT,
                CALC_PERCENT,
                PERF_STARTED_AT,
                PERFED_AT,
                CALCULATE_STARTED_AT,
                CALCULATED_AT
                FROM AR_PERIOD where PERIOD_NUM = $periodNum")->queryOne();

        return Period::updateAll($period, ['PERIOD_NUM' => $periodNum]);
    }

    public function getCalcPeriod()
    {
        $db = $this->_calc_db_name;
        return \Yii::$app->$db->createCommand("SELECT * FROM AR_PERIOD where PERIOD_NUM = $this->_periodNum")->queryOne();
    }

}