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

<?php

namespace common\helpers\bonus\Calc;


use common\models\CalcRecord;
use common\models\Period;

class CalcConsole extends BaseBusiness
{
    const  CALC_DB_NAME = 'dbCalc';

    public static function listenCalcPeriod()
    {
        $db        = self::CALC_DB_NAME;
        $allPeriod = \Yii::$app->$db->createCommand("SELECT * FROM AR_PERIOD ")->queryAll();
        $period    = [];
        foreach ($allPeriod as $v) {
            if ($v['IS_PREPARE'] > 0
                //&& todo 补全状态
            ) {
                $period = $v;
                break;
            }
        }

        $businessPeriod = Period::find()->where(['PERIOD_NUM' => $period['PERIOD_NUM']])
            ->asArray()->one();
        //用户选择是否自动执行
        $autoExec             = $businessPeriod['AUTO_EXEC'] > 0;
        $businessIsCalculated = $businessPeriod['IS_CALCULATED'] > 0;

        if (2 == $period['IS_PREPARE'] && 1 == $period['IS_PERFED'] && $autoExec) {
            //拉取期业绩
            CalcRecord::record($period['PERIOD_NUM'], '第' . $period['PERIOD_NUM'] . '期的业绩数据已生成');
            CalcRecord::record($period['PERIOD_NUM'], '开始获取第' . $period['PERIOD_NUM'] . '期的期业绩数据');

            Period::updatePeriodIsProcessing($period['PERIOD_NUM'], Period::IS_PROCESSING);
            $res = (new PullPerfDataFromCalc($period['PERIOD_NUM']))->start();
            if (200 == $res['code']) {
                Period::updatePeriodIsProcessing($period['PERIOD_NUM'], Period::NOT_PROCESSING);
                CalcRecord::record($period['PERIOD_NUM'], '第' . $period['PERIOD_NUM'] . '期的期业绩数据已获取');
            } else {
                //结束计算状态
                Period::updatePeriodIsProcessing($period['PERIOD_NUM'], Period::NOT_PROCESSING);
                CalcRecord::record($period['PERIOD_NUM'], '第' . $period['PERIOD_NUM'] . '期的期业绩数据获取失败，原因：' . $res['msg']);
                return $res;
            }

            //自动执行且IS_PREPARE为3 直接开始结算流程
            CalcRecord::record($period['PERIOD_NUM'], '开始计算第' . $period['PERIOD_NUM'] . '期的奖金');
            //同步周期表的值到业务系统
            self::pullPeriodForUpdate($period['PERIOD_NUM']);
            return \Yii::$app->$db->createCommand()->update('AR_PERIOD', ['IS_PREPARE' => 3], 'PERIOD_NUM=:PERIOD_NUM', ['PERIOD_NUM' => $period['PERIOD_NUM']])->execute();

        }

        if (4 == $period['IS_PREPARE'] && 1 == $period['IS_CALCULATED'] && $autoExec && !$businessIsCalculated) {
            CalcRecord::record($period['PERIOD_NUM'], '第' . $period['PERIOD_NUM'] . '期的奖金已计算完成');
            CalcRecord::record($period['PERIOD_NUM'], '开始拉取第' . $period['PERIOD_NUM'] . '期的奖金数据');

            Period::updatePeriodIsProcessing($period['PERIOD_NUM'], Period::IS_PROCESSING);
            //自动执行且IS_CALCULATED为1 直接开始拉取结算数据
            $res = (new PullCalcBonusData($period['PERIOD_NUM']))->start();
            if (200 == $res['code']) {
                CalcRecord::record($period['PERIOD_NUM'], '第' . $period['PERIOD_NUM'] . '期的奖金数据已全部拉取');
                //待拉取完成后再将计算完成标识改为已完成
                \Yii::$app->$db->createCommand()->update('AR_PERIOD', ['IS_CALCULATED' => 1], 'PERIOD_NUM=' . $period['PERIOD_NUM'])->execute();
                //自动执行完成 更新对应字段
                //计算结束
                Period::updatePeriodIsProcessing($period['PERIOD_NUM'], Period::NOT_PROCESSING);
                //流程结束
                //同步周期表的值到业务系统
                self::pullPeriodForUpdate($period['PERIOD_NUM']);
            } else {
                //结束计算状态
                Period::updatePeriodIsProcessing($period['PERIOD_NUM'], Period::NOT_PROCESSING);
                CalcRecord::record($period['PERIOD_NUM'], '第' . $period['PERIOD_NUM'] . '期的奖金数据获取失败，原因：' . $res['msg']);
                return $res;
            }
            return true;
        }

        return true;
    }

}