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

<?php

namespace common\helpers\bonus\Calc;


use common\helpers\Cache;
use common\helpers\Form;
use common\models\CalcOperation;
use common\models\CalcRecord;
use common\models\forms\PeriodForm;
use common\models\Period;
use Yii;

/**
 * 业务端计算服务监听脚本
 */
class CalcConsole extends BaseBusiness
{
    const  CALC_DB_NAME = 'dbCalcServer';

    /**监听计算服务
     * @return array|bool
     * @throws \yii\base\InvalidConfigException
     * @throws \yii\db\Exception
     */
    public static function listenCalcPeriod()
    {
        // 先检查redis的开关
        $calcingSwitch = Yii::$app->cache->get('isCalcing') ? 1 : 0;
        if(!$calcingSwitch){
            return true;
        }
        $db        = self::CALC_DB_NAME;
        $allPeriod = \Yii::$app->$db->createCommand("SELECT * FROM AR_PERIOD order by PERIOD_NUM desc")->queryAll();
        $period    = [];
        foreach ($allPeriod as $v) {
            if ($v['IS_PREPARE'] > 0) {
                $period = $v;
                break;
            }
        }
        if (empty($period)) {
            return true;
        }

        $businessPeriod = Period::find()->where(['PERIOD_NUM' => $period['PERIOD_NUM']])
            ->asArray()->one();

        if(!$period['CALC_ID'] || $period['CALC_ID'] != $businessPeriod['CALC_ID']) { // 如果计算ID不符，则退出
            return true;
        }

        if (empty($businessPeriod)) {
            return true;
        }

        if ($businessPeriod['SEND_STARTED_AT'] > 0 || $businessPeriod['IS_SENT'] > 0) {
            //开始挂网 或者 已挂网 则直接返回
            return true;
        }

        if ($businessPeriod['IS_CLOSED']==0) {
            // 如果没有封期 则直接返回
            return true;
        }

        //用户选择是否自动执行
        $autoExec             = $businessPeriod['AUTO_EXEC'] > Period::MANUAL_EXEC_CALC;
        $businessIsCalculated = $businessPeriod['IS_CALCULATED'] == Period::CALCULATE_FINISH;
        $startExecTime        = $businessPeriod['START_EXEC_TIME'] ?? 0;
        $businessIsProcessing = $businessPeriod['IS_PROCESSING'] ?? 0;

        echo $businessPeriod['IS_CALCING'];
        //同步计算进度日志到业务系统
        if (4 == $period['IS_PREPARE'] && 1 == $period['IS_CALCULATED'] && 1 == $businessPeriod['IS_CALCING']) {
            self::syncLogRecord($period['PERIOD_NUM'], $db, $startExecTime);
            \Yii::$app->db->createCommand()->update('AR_PERIOD', ['IS_CALCING' => 0], 'PERIOD_NUM=' . $period['PERIOD_NUM'])->execute();
        }

        if (2 == $period['IS_PREPARE'] && 1 == $period['IS_PERFED'] && $autoExec && !$businessIsProcessing) {
            //拉取期业绩
            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 && !$businessIsProcessing && !$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']);
                \Yii::$app->$db->createCommand()->update('AR_PERIOD', ['CALC_ID' => ''], 'PERIOD_NUM=:PERIOD_NUM', ['PERIOD_NUM' => $period['PERIOD_NUM']])->execute();
                CalcOperation::closeOperation($businessPeriod['CALC_ID']);
                //拉取计算系统的进度日志
                self::syncLogRecord($period['PERIOD_NUM'], $db, $startExecTime);
                //设置redis开关
                Yii::$app->cache->set('isCalcing', 0);
            } else {
                //结束计算状态
                Period::updatePeriodIsProcessing($period['PERIOD_NUM'], Period::NOT_PROCESSING);
                \Yii::$app->$db->createCommand()->update('AR_PERIOD', ['CALC_ID' => ''], 'PERIOD_NUM=:PERIOD_NUM', ['PERIOD_NUM' => $period['PERIOD_NUM']])->execute();
                CalcOperation::closeOperation($businessPeriod['CALC_ID']);
                CalcRecord::record($period['PERIOD_NUM'], '【奖金计算】第' . $period['PERIOD_NUM'] . '期的奖金数据获取失败，原因：' . $res['msg']);
                return $res;
            }
            return true;
        }

        return true;
    }

    public static function autoPrePerf(){ // 自动预结算
        $nowTs = time();
        $currentPeriod = Period::find()->where('START_TIME< :NOW_TIME',['NOW_TIME'=>$nowTs])->where('END_TIME>= :NOW_TIME',['NOW_TIME'=>$nowTs-6])->asArray()->one();
        $periodNum = $currentPeriod['PERIOD_NUM'];
        if (
            Period::isPreparing($periodNum)
            || $currentPeriod['IS_MONTH'] == 0
        ) {
            return;
        }
        if($nowTs+86400>$currentPeriod['END_TIME'] ){
            $nowMin = date("i", $nowTs);
            $nowSec = date("s", $nowTs);
            if(($nowMin!=0 || $nowSec >= 5 ) || Period::isPreparing($periodNum)){ // 当不是整点小时，当计算中，不计算
                return;
            }
            print_r($periodNum."该预结算".$nowMin.PHP_EOL.$nowSec);
            //设置计算进行中标识
            Period::updatePeriodIsPreparing($periodNum, Period::IS_PREPARING);
            //设置自动计算标识
            Period::updatePeriodIsAutoExec($periodNum, Period::MANUAL_EXEC_CALC);
            //记录开始计算的时间
            $calc_id = uniqid('calc_');
            CalcOperation::record($calc_id, $periodNum);
            Period::updateAll(['START_EXEC_TIME' => time(), 'CALC_ID' => $calc_id], ['PERIOD_NUM' => $periodNum]);
            $formModel = new PeriodForm();
            $formModel->scenario = 'autoPerf';

            if($formModel->load(['periodNum'=>$periodNum], '') && $formModel->autoPrePerf()) {
                echo('自动计算已开始，请等待'.PHP_EOL);
                //设置redis开关
                Yii::$app->cache->set('isPreparing', 1, 3600);
                CalcRecord::record($periodNum, '【定时计算】第' . $periodNum . '期，定时计算开始');
            } else {
                echo('自动计算未开始'.PHP_EOL);
                CalcRecord::record($periodNum, '【定时计算】第' . $periodNum . '期，定时计算未开始');
            }
            return;
        }else{
            return;
        }
    }

    public static function listenAutoPerfPeriod() // 拉取预结算的结果
    {
        // 先检查redis的开关
        $preparingSwitch = Yii::$app->cache->get('isPreparing') ? 1 : 0;
        if(!$preparingSwitch){
            return true;
        }
        $db        = self::CALC_DB_NAME;
        $allPeriod = \Yii::$app->$db->createCommand("SELECT * FROM AR_PERIOD order by PERIOD_NUM desc")->queryAll();
        $period    = [];
        foreach ($allPeriod as $v) {
            if ($v['IS_PREPARE'] > 0) {
                $period = $v;
                break;
            }
        }
        if (empty($period)) {
            return true;
        }
        $businessPeriod = Period::find()->where(['PERIOD_NUM' => $period['PERIOD_NUM']])->asArray()->one();

        if(!$period['CALC_ID'] || $period['CALC_ID'] != $businessPeriod['CALC_ID']) { // 如果计算ID不符，则退出
            return true;
        }

        $startExecTime = $businessPeriod['START_EXEC_TIME'] ?? 0;
        if (
            $businessPeriod['SEND_STARTED_AT'] > 0 || $businessPeriod['IS_SENT'] > 0 // 已挂网
            || 1 != $businessPeriod['IS_PREPARING'] // 未在预计算中
            || $period['PERFED_AT'] < $businessPeriod['START_EXEC_TIME'] // 计算服务中的计算时间，早于业务系统开始计算时间，说明是旧的，不拉取
        ){
            return false;
        }
        if (
            2 == $period['IS_PREPARE']
            && 1 == $period['IS_PERFED']
        ) {
            //拉取期业绩
            CalcRecord::record($period['PERIOD_NUM'], '【期业绩】第' . $period['PERIOD_NUM'] . '期的预计算业绩数据已生成');
            CalcRecord::record($period['PERIOD_NUM'], '【期业绩】开始获取第' . $period['PERIOD_NUM'] . '期的预计算期业绩数据');

            Period::updatePeriodIsPreparing($period['PERIOD_NUM'], Period::IS_PREPARING);
            $res = (new PullPerfDataFromCalc($period['PERIOD_NUM']))->start();
            if (200 == $res['code']) {
//                Period::updatePeriodIsProcessing($period['PERIOD_NUM'], Period::NOT_PROCESSING);
                //设置预计算标识
                Period::updatePeriodIsPreparing($period['PERIOD_NUM'], Period::NOT_PREPARING);
                CalcRecord::record($period['PERIOD_NUM'], '【期业绩】第' . $period['PERIOD_NUM'] . '期的预计算期业绩数据已获取');
                \Yii::$app->$db->createCommand()->update('AR_PERIOD', ['CALC_ID' => ''], 'PERIOD_NUM=:PERIOD_NUM', ['PERIOD_NUM' => $period['PERIOD_NUM']])->execute();
                CalcOperation::closeOperation($businessPeriod['CALC_ID']);
                self::syncLogRecord($period['PERIOD_NUM'], $db, $startExecTime);
                Yii::$app->cache->set('isPreparing', 0);
                return $res;
            } else {
                //结束计算状态
//                Period::updatePeriodIsProcessing($period['PERIOD_NUM'], Period::NOT_PROCESSING);
                //设置预计算标识
                Period::updatePeriodIsPreparing($period['PERIOD_NUM'], Period::NOT_PREPARING);
                \Yii::$app->$db->createCommand()->update('AR_PERIOD', ['CALC_ID' => ''], 'PERIOD_NUM=:PERIOD_NUM', ['PERIOD_NUM' => $period['PERIOD_NUM']])->execute();
                CalcOperation::closeOperation($businessPeriod['CALC_ID']);
                CalcRecord::record($period['PERIOD_NUM'], '【期业绩】第' . $period['PERIOD_NUM'] . '期的预计算期业绩数据获取失败，原因：' . $res['msg']);
                return $res;
            }
        }
        return true;
    }

    /**
     * 同步计算系统的计算进度日志到业务系统计算步骤表
     * @param $periodNum
     * @param $db
     * @param $startTime
     * @return bool|int
     * @throws \yii\base\InvalidConfigException
     * @throws \yii\db\Exception
     */
    public static function syncCalcRecord($periodNum, $db, $startTime = 0)
    {
        $type         = 'bonus';
        $calcTaskDesc = \Yii::$app->$db->createCommand("SELECT
        ID,PERIOD_NUM,TASK_DESCRIBE,START_AT FROM AR_SERVE_PROCESS 
        where TASK_TYPE='$type' AND PERIOD_NUM=$periodNum  AND START_AT>=$startTime
        order by START_AT desc")->queryAll();

        $calcTaskDescKeys = array_column($calcTaskDesc, null, 'ID');

        $currentRecordList    = CalcRecord::find()->where(['PERIOD_NUM' => $periodNum])->select('ID')->asArray()->column();
        $currentRecordListKey = array_flip($currentRecordList);

        $tableName = (new CalcRecord())->getTableSchema()->name;
        $result    = array_diff_key($calcTaskDescKeys, $currentRecordListKey);
        if (!empty($result)) {
            return \Yii::$app->db->createCommand()->batchInsert($tableName, ['ID', 'PERIOD_NUM', 'TEXT', 'CREATED_AT'], $result)->execute();
        }
        return true;
    }

    public static function syncLogRecord($periodNum, $db, $startTime = 0)
    {
        $calcTaskDesc = \Yii::$app->$db->createCommand("SELECT
        ID,PERIOD_NUM,LOG_DESCRIBE,CREATE_AT FROM AR_SERVE_LOG 
        where  PERIOD_NUM=$periodNum  AND CREATE_AT>=$startTime
        order by RECORD_SORT")->queryAll();

        $calcTaskDescKeys = array_column($calcTaskDesc, null, 'ID');

        $currentRecordList    = CalcRecord::find()->where(['PERIOD_NUM' => $periodNum])->select('ID')->asArray()->column();
        $currentRecordListKey = array_flip($currentRecordList);

        $tableName = (new CalcRecord())->getTableSchema()->name;
        $result    = array_diff_key($calcTaskDescKeys, $currentRecordListKey);
        if (!empty($result)) {
            return \Yii::$app->db->createCommand()->batchInsert($tableName, ['ID', 'PERIOD_NUM', 'TEXT', 'CREATED_AT'], $result)->execute();
        }
        return true;
    }
}