aklast/common/helpers/bonus/BonusCalc.php

<?php
/**
 * Created by PhpStorm.
 * User: leo
 * Date: 2018/8/2
 * Time: 上午10:32
 */

namespace common\helpers\bonus;

use common\helpers\Cache;
use common\helpers\Date;
use common\helpers\LoggerTool;
use common\helpers\snowflake\SnowFake;
use common\helpers\Tool;
use common\models\BsBonus103Calc;
use common\models\BsBonus103CalcEvent;
use common\models\CalcBonus;
use common\models\CalcBonusBD;
use common\models\CalcBonusBS;
use common\models\CalcBonusBsDefaultBonus;
use common\models\CalcBonusBT;
use common\models\CalcBonusCF;
use common\models\CalcBonusFL;
use common\models\CalcBonusFW;
use common\models\CalcBonusFX;
use common\models\CalcBonusGL;
use common\models\CalcBonusGX;
use common\models\CalcBonusHB;
use common\models\CalcBonusLS;
use common\models\CalcBonusLX;
use common\models\CalcBonusQY;
use common\models\CalcBonusST;
use common\models\CalcBonusStandard;
use common\models\CalcBonusTG;
use common\models\CalcBonusVIP;
use common\models\CalcBonusXF;
use common\models\CalcBonusYC;
use common\models\CalcBonusYJ;
use common\models\CalcMonthBonusUser;
use common\models\Config;
use common\models\FlowDeductZR;
use common\models\PerfCompany;
use common\models\PerfMonth;
use common\models\PerfPeriod;
use common\models\Period;
use common\models\ResendQY;
use common\models\DeclarationLevel;
use common\models\DecOrder;
use common\models\EmployLevel;
use common\models\FlowBonus;
use common\models\PerfActiveUser;
use common\models\ScoreMonth;
use common\models\StorePerfLog;
use common\models\User;
use common\models\UserInfo;
use common\models\UserPerf;
use SebastianBergmann\CodeCoverage\Report\PHP;
use Yii;
use yii\base\BaseObject;
use yii\base\Exception;
use yii\base\StaticInstanceTrait;
use yii\db\Expression;
use yii\helpers\Json;

class BonusCalc extends BaseObject {
    use StaticInstanceTrait;

    private $_limit = 10000;
    private $_gxLimit = 500;
    private $_handleUserId;
    private $_companyMonthPerf = 0;
    private $_cfTotalPercent = 0;
    private $_lxTotalPercent = 0;
    private $_sysConfig = [];
    private $_decLevelConfig = [];
    private $_empLevelConfig = [];
    private $_decRoleConfig = [];
    private $_errors = [];
    private $_periodNum = 0;
    private $_periodId;
    private $_isCalcMonth = 0;
    private $_calcYear;
    private $_calcMonth;
    private $_calcYearMonth;
    private $_calcMonthPeriodNumCount = 0;
    private $_lastCalcYear;
    private $_lastCalcMonth;
    private $_lastCalcYearMonth;
    private $_lastPeriodNum;
    private $_lastPeriodYear;
    private $_lastPeriodMonth;
    private $_lastPeriodYearMonth;
    //pv
    private $_pvRatio;

    const LOOP_FINISH = 1;
    const LOOP_CONTINUE = 2;
    const GX_FLOOR_LIMIT = 5; // 共享奖向上找的最大层级
    const GX_LIMIT_SWITCH = true; // 是否开启共享奖向上找的最大限制  true 为开启 false 关闭  

    const ORDER_TYPE_TO_FW_COEFFICIENT = [
        'ZC' => 'fwCoefficientFromZc',
        'FX_CASH' => 'fwCoefficientFromFxCash',
        'FX_POINT' => 'fwCoefficientFromFxPoint',
    ];

    const JX_STANDARD_BASE_AMOUNT = 10000;
    const JX_STANDARD_MAX_TIMES = 50;
    const JX_STANDARD_BONUS_PERCENT = 15;


    //最小报单pv
    const MIN_BD_PV = 980;

    const QUALIFIED_NONE = 0;   // 无达标状态
    const QUALIFIED_SELF = 1;       // 自身业绩达标
    const QUALIFIED_CASCADE = 2;   // 级联被动达标

    /**
     * 1、抓取所有报单、订单，把能当时产生业绩的报单存入业绩单。例如注册单，订单
     * 2、从业绩单中循环，并计算上下级业绩
     * 3、计算级别
     * 4、计算各个奖项
     * 5、给会员追加总业绩，在结算中不妥，打算把追加总业绩放到挂网中，因为结算完成以后的业绩都不是最终的，有可能还会变
     */

    /**
     * 初始化
     */
    public function init() {
        parent::init();

    }

    /**
     * 设置期数
     * @param int $periodNum
     * @return int
     */
    public function setPeriodNum(int $periodNum) {
        return $this->_periodNum = $periodNum;
    }

    /**
     * 获取期数
     * @return int
     */
    public function getPeriodNum() {
        return $this->_periodNum;
    }

    /**
     * 加入错误错误
     * @param $attr
     * @param $error
     */
    public function addError($attr, $error) {
        $this->_errors[$attr][] = $error;
    }

    /**
     * 获取错误信息
     * @return array
     */
    public function getErrors() {
        return $this->_errors;
    }

    /**
     * 开始执行结算步骤
     * @param $periodNum
     * @param null $handleUserId
     * @return bool
     */
    public function calcStep($periodNum, $handleUserId = null) {
        try {
            $this->_errors = [];
            $this->setPeriodNum($periodNum);
            $this->_handleUserId = $handleUserId;
            $t1 = microtime(true);
            // 初始化结算任务
            $this->initCalcTask();
            // 设置结算状态
            $this->setCalcStatus('start');
            // 清空所有本期结算用到的缓存
            CalcCache::clearCalcBonusCache($this->_periodNum);
            // 清空相关表数据
            $this->clearCalcTableData();
            $t2 = microtime(true);
            echo('初始化、清空缓存及相关数据表完成，耗时：' . round($t2 - $t1, 3) . ',内存使用：' . (round(memory_get_usage() / 1024 / 1024, 3)) . 'MB' . PHP_EOL);
            $this->_updatePercent(5);
            $t3 = microtime(true);
            $this->_updatePercent(10);
            // 奖金部分
            if($this->_sysConfig['openFW']['VALUE']) {
                $this->calcBonusBDStepOne();
                $this->calcBonusBDStepTwo();
            }
            $t4 = microtime(true);
            echo('计算服务奖'.($this->_sysConfig['openFW']['VALUE']?'完成':'关闭').'，耗时：' . round($t4 - $t3, 3) . ',内存使用：' . (round(memory_get_usage() / 1024 / 1024, 3)) . 'MB' . PHP_EOL);
            $this->_updatePercent(15);

            if($this->_sysConfig['openTG']['VALUE']) {
                $this->calcBonusTG();
            }
            $t5 = microtime(true);
            echo('计算推广奖'.($this->_sysConfig['openTG']['VALUE']?'完成':'关闭').'，耗时：' . round($t5 - $t4, 3) . ',内存使用：' . (round(memory_get_usage() / 1024 / 1024, 3)) . 'MB' . PHP_EOL);
            $this->_updatePercent(20);

            $t8 = microtime(true);
            if($this->_sysConfig['openQY']['VALUE']) {
                $this->calcBonusQY();
                $this->calcBonusBdQY();
                $this->calcBonusFxQY();
            }
            $t9 = microtime(true);
            echo('计算团队奖'.($this->_sysConfig['openQY']['VALUE']?'完成':'关闭').'，耗时：' . round($t9 - $t8, 3) . ',内存使用：' . (round(memory_get_usage() / 1024 / 1024, 3)) . 'MB' . PHP_EOL);
            $this->_updatePercent(65);

            if($this->_sysConfig['openGX']['VALUE']) {
                $this->calcBonusGXBefore();
                $this->calcBonusGX();
            }
            $t11 = microtime(true);
            echo('计算共享奖'.($this->_sysConfig['openGX']['VALUE']?'完成':'关闭').'，耗时：' . round($t11 - $t9, 3) . ',内存使用：' . (round(memory_get_usage() / 1024 / 1024, 3)) . 'MB' . PHP_EOL);
            $this->_updatePercent(68);

            if($this->_sysConfig['openGL']['VALUE']) {
                $this->calcBonusBdGL();
            }
            $t13 = microtime(true);
            echo('计算报单管理奖'.($this->_sysConfig['openGL']['VALUE']?'完成':'关闭').'，耗时：' . round($t13 - $t11, 3) . ',内存使用：' . (round(memory_get_usage() / 1024 / 1024, 3)) . 'MB' . PHP_EOL);
            $this->_updatePercent(50);

            // 计算店服务奖 月奖
            if($this->_sysConfig['openStore']['VALUE']) {
                if ($this->_sysConfig['openStoreReduce']['VALUE']) {
                    // 开启了紧缩方式,计算店服务
                    $this->calcStoreBonusReduce();
                } else {
                    // 未开启紧缩方式,计算店服务
                    $this->calcStoreBonus();
                }
            }
            $t16 = microtime(true);
            echo('计算店服务奖金'.($this->_sysConfig['openStore']['VALUE']?'完成':'关闭').'，耗时：' . round($t16 - $t13, 3) . ',内存使用：' . (round(memory_get_usage() / 1024 / 1024, 3)) . 'MB' . PHP_EOL);
            $this->_updatePercent(55);

            $t17 = microtime(true);
            // 蓝星奖入库,实际上是插入有奖金会员数据缓存中.
            // 调用存储过程,计算蓝星管理奖金
//            $this->calcBsProcedure();
//            // 将有蓝星管理奖金的用户加入到有奖金缓存用户中
//            $this->calcBonusBsGL();
//            $this->calcBonusBsGLCF();
//            $this->calcBonusBsYJCF();

            // 不是结算月,则不进行计算
            if ($this->_isCalcMonth) {
                echo('计算蓝星管理奖开始，' . PHP_EOL);
                // 期数配置
                $calcData = Period::findOneAsArray('PERIOD_NUM=:PERIOD_NUM', [':PERIOD_NUM' => $this->_periodNum]);
                // 删除日志
                BsBonus103CalcEvent::deleteAll();
                // 清除数据
                $this->calcClean($this->_periodNum);
                // 初始化
                $this->calcBsInitProcedure($this->_periodNum, $calcData['CALC_MONTH'], $calcData['CALC_YEAR']);

                // 推荐网最大层级，用于循环
                $maxLayer = BsBonus103Calc::getMaxLayer($periodNum);

                // 报单业绩上推
                $this->calcBsPushPerf($this->_periodNum, $maxLayer);
                // 业绩汇总
                $this->calcBsSummaryPerf($this->_periodNum);
                // 第一次紧缩网络、连带达标
                $this->calcBsNetworkAusterity($this->_periodNum, $maxLayer);
                // 计算1星奖金、赋星级
//                $this->calcBsBonus($this->_periodNum);

                // TODO: 任务进度
                $this->calcTask(10, '完成', $this->_periodNum);

                $t18 = microtime(true);
                echo('计算蓝星管理奖'.($this->_sysConfig['openGL']['VALUE']?'完成':'关闭').'，耗时：' . round($t18 - $t17, 3) . ',内存使用：' . (round(memory_get_usage() / 1024 / 1024, 3)) . 'MB' . PHP_EOL);
                $this->_updatePercent(65);

            }

            //把奖金会员写入缓存
            $this->loopMonthBonusUserFromDbToCache();
            $t19 = microtime(true);
            echo('奖金会员写入缓存完成，耗时：' . round($t19 - $t18, 3) . ',内存使用：' . (round(memory_get_usage() / 1024 / 1024, 3)) . 'MB' . PHP_EOL);
            $this->_updatePercent(70);

            //奖金写库 -- 注意,必须在月奖会员加入缓存之后loopMonthBonusUserFromDbToCache()
            $this->loopBonusUsers();
            // 入库完成,将各个奖金计算流水会员聘级,更新成蓝星奖当时计算的聘级
            $this->loopCalcBlueEmpLv();
            $this->_updatePercent(85);
            unset($calcWrite);
            $t20 = microtime(true);
            echo('奖金写库操作完成，耗时：' . round($t20 - $t19, 3) . ',内存使用：' . (round(memory_get_usage() / 1024 / 1024, 3)) . 'MB' . PHP_EOL);

            //把本期奖金会员入库 - 把缓存中的月奖用户信息存到数据库.存储过程的入库不在这里进行,这里代码取的缓存,存储过程没有缓存,在上面进行入库
            $this->loopMonthBonusUserToDb();
            $t21 = microtime(true);
            echo('奖金会员入库完成，耗时：' . round($t21 - $t20, 3) . ',内存使用：' . (round(memory_get_usage() / 1024 / 1024, 3)) . 'MB' . PHP_EOL);
            $this->_updatePercent(100);

            $t30 = microtime(true);
            echo('结算全部完成，共耗时：' . round($t30 - $t1, 3) . ',内存使用：' . (round(memory_get_usage() / 1024 / 1024, 3)) . 'MB' . PHP_EOL);
        } catch (\Exception $e) {
            $this->errorCalcTask();
            $this->addError('calc', $e->getMessage());
            return false;
        }
        return true;
    }

    /**
     * 结算完成
     */
    public function endCalcTask() {
        // 更新结算状态
        $this->setCalcStatus('end');
    }

    /**
     * 结算错误
     */
    public function errorCalcTask() {
        // 清空所有本期结算用到的缓存
        CalcCache::clearCalcBonusCache($this->_periodNum);
        // 更新结算状态
        $this->setCalcStatus('fail');
    }

    /**
     * 初始化结算任务
     * @throws \yii\db\Exception
     */
    public function initCalcTask() {
        $this->_sysConfig = Cache::getSystemConfig();
        $this->_decLevelConfig = Cache::getDecLevelConfig();
        $this->_empLevelConfig = Cache::getEmpLevelConfig();
        $this->_decRoleConfig = CalcCache::getDecRoleConfig($this->_periodNum);
        $periodNum = $this->_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);
        $this->_calcMonthPeriodNumCount = $periodObj->getYearMonthAllPeriodNumCount($this->_calcYear, $this->_calcMonth);
        $lastYearMonthArr = $periodObj->getLastMonth($periodNum);
        $this->_lastCalcYear = $lastYearMonthArr['year'];
        $this->_lastCalcMonth = $lastYearMonthArr['month'];
        $this->_lastCalcYearMonth = $lastYearMonthArr['yearMonth'];
        $this->_lastPeriodNum = $periodNum - 1;
        if (Period::isExistsPeriodNum($this->_lastPeriodNum)) {
            $this->_lastPeriodYear = $periodObj->getYear($this->_lastPeriodNum);
            $this->_lastPeriodMonth = $periodObj->getMonth($this->_lastPeriodNum);
            $this->_lastPeriodYearMonth = $periodObj->getYearMonth($this->_lastPeriodNum);
        } else {
            $this->_lastPeriodYear = 0;
            $this->_lastPeriodMonth = 0;
            $this->_lastPeriodYearMonth = 0;
        }
        $this->_cfTotalPercent = CalcCache::getCFTotalPercent($this->_periodNum);
        $this->_lxTotalPercent = CalcCache::getLXTotalPercent($this->_periodNum);
        $this->_pvRatio = $this->_sysConfig['pvRatio']['VALUE'];
        if($perfCompany = PerfCompany::findOne(['CALC_MONTH' => $this->_calcYearMonth])){
            $this->_companyMonthPerf = $perfCompany['PV'];
        }
    }

    /**
     * 设置结算状态
     * @param $type
     * start|end|fail
     */
    public function setCalcStatus($type) {
        if ($type == 'start') {
            Period::updateAll(['IS_CALCING' => 1, 'IS_CALCULATED' => Period::CALCULATE_NONE, 'CALCULATE_STARTED_AT' => Date::nowTime()], 'PERIOD_NUM=:PERIOD_NUM', [':PERIOD_NUM' => $this->_periodNum]);
        } elseif ($type == 'end') {
            Period::updateAll(['IS_CALCING' => 0, 'IS_CALCULATED' => Period::CALCULATE_FINISH, 'CALCULATED_AT' => Date::nowTime()], 'PERIOD_NUM=:PERIOD_NUM', [':PERIOD_NUM' => $this->_periodNum]);
        } elseif ($type == 'fail') {
            Period::updateAll(['IS_CALCING' => 0, 'IS_CALCULATED' => Period::CALCULATE_FAIL, 'CALCULATED_AT' => 0], 'PERIOD_NUM=:PERIOD_NUM', [':PERIOD_NUM' => $this->_periodNum]);
        }
    }

    /**
     * 清空相关表数据
     */
    public function clearCalcTableData() {
        // 奖金表
        CalcBonus::pageDeleteAll('PERIOD_NUM='.$this->_periodNum);

        CalcBonusQY::pageDeleteAll('PERIOD_NUM='.$this->_periodNum);
        CalcBonusBD::pageDeleteAll('PERIOD_NUM='.$this->_periodNum);
        CalcBonusTG::pageDeleteAll('PERIOD_NUM='.$this->_periodNum);
        CalcBonusYJ::pageDeleteAll('PERIOD_NUM='.$this->_periodNum);
        CalcBonusGX::pageDeleteAll('PERIOD_NUM='.$this->_periodNum);
        CalcBonusGL::pageDeleteAll('PERIOD_NUM='.$this->_periodNum);
        // 月结时要清空的数据
        if ($this->_isCalcMonth) {
            CalcBonusST::pageDeleteAll('PERIOD_NUM='.$this->_periodNum);
            CalcBonusYC::pageDeleteAll('PERIOD_NUM='.$this->_periodNum);
            CalcBonusVIP::pageDeleteAll('PERIOD_NUM='.$this->_periodNum);
            CalcBonusStandard::pageDeleteAll('PERIOD_NUM='.$this->_periodNum);
            ScoreMonth::pageDeleteAll('PERIOD_NUM='.$this->_periodNum);
        }
    }

    /**
     * === 奖金结算部分 ===
     */

    /**
     * 服务奖
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBonusBD(int $offset = 0) {
        $periodNum = $this->_periodNum;
        // 从缓存获取分页有业绩的会员信息
        $allData = CalcCache::getHasBDUsers($this->_periodNum, $offset, $this->_limit);
        if ($allData) {
            $insertBonusData = [];
            foreach ($allData as $userId) {
                $decInfo = CalcCache::getBDUsersInfo($userId, $this->_periodNum);
                if( !$decInfo ) continue;

                //服务奖使用报单原金额
                $decBonus = Tool::formatPrice($decInfo['DEC_AMOUNT'] * $this->_sysConfig['decPercent']['VALUE'] / 100);
                if ($decBonus <= 0) continue;
                $bonusUserId = $decInfo['DEC_ID'];
                if( !$bonusUserId ) continue;
                // 获取会员的报单级别
                $bonusUserInfo = CalcCache::getUserInfo($bonusUserId, $this->_periodNum);

                //总金额限制
                $decBonus = $this->bonusTotalLimit($decBonus, $bonusUserId, $bonusUserInfo['REC_NUM'], $bonusUserInfo['ZC_AMOUNT']);
                if( $decBonus <= 0 ) continue;


                //扣除相应的复消积分和管理费
                $deductData = $this->deduct($bonusUserId, $decBonus);

                // 把对碰后的奖金存入缓存中
                CalcCache::bonus($bonusUserId, $periodNum, 'BONUS_BD', $decBonus, $deductData);

                //来源会员信息
                $fromUserInfo = CalcCache::getUserInfo($userId, $this->_periodNum);
                //服务奖流水
                $insertBonusData[] = [
                    'ID' => SnowFake::instance()->generateId(),
                    'USER_ID' => $bonusUserId,
                    'LAST_DEC_LV' => $bonusUserInfo['DEC_LV'],
                    'LAST_EMP_LV' => $bonusUserInfo['EMP_LV'],
                    'LAST_STATUS' => $bonusUserInfo['STATUS'],
                    'FROM_USER_ID' => $userId,
                    'LAST_FROM_DEC_LV' => $fromUserInfo['DEC_LV'],
                    'LAST_FROM_EMP_LV' => $fromUserInfo['EMP_LV'],
                    'LAST_FROM_STATUS' => $fromUserInfo['STATUS'],
                    'AMOUNT' => $deductData['surplus'],
                    'RECONSUME_POINTS' => $deductData['reConsumePoints'],
                    'MANAGE_TAX' => $deductData['manageTax'],
                    'ORI_BONUS' => $decBonus,
                    'PERIOD_NUM' => $this->_periodNum,
                    'CALC_YEAR' => $this->_calcYear,
                    'CALC_MONTH' => $this->_calcYearMonth,
                    'P_CALC_MONTH' => Date::ociToDate($this->_calcYearMonth, Date::OCI_TIME_FORMAT_SHORT_MONTH),
                    'CREATED_AT' => Date::nowTime(),
                    'LOGS' => json_encode([
                        'decInfoArr' => $decInfo,
                        'decPercentConfig' => $this->_sysConfig['decPercent']['VALUE'],
                        'recNum' => $bonusUserInfo['REC_NUM'],
                        'decAmount' => $bonusUserInfo['ZC_AMOUNT'],
                    ]),
                ];

                unset($decInfo, $decBonus, $bonusUserId, $bonusUserInfo, $userId, $deductData, $fromUserInfo);
            }
            CalcBonusBD::batchInsert($insertBonusData);
            unset($allData, $insertBonusData);
            return $this->calcBonusBD($offset + $this->_limit);
        }
        unset($allData);
        return true;
    }

    /**
     * 推广奖
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBonusTG(int $offset = 0) {
        $periodNum = $this->_periodNum;
        // 从缓存获取分页有业绩的会员信息
        $allData = CalcCache::getHasPerfUsers($this->_periodNum, $offset, $this->_limit);
        if ($allData) {
            $insertBonusData = [];
            foreach ($allData as $userId) {
                // 从缓存中获取会员的业绩信息
                $perfData = CalcCache::nowPeriodPerf($userId, $periodNum);
                if( !$perfData ) continue;
                //个人业绩都算推荐奖，包括报单和复消、二次购物
                $perfPv = $perfData['PV_PCS_ZC'] ?? 0;
                if( $perfPv <= 0 ) continue;

                //推广奖使用个人PCS
                $recBonus = Tool::formatPrice($perfPv * $this->_sysConfig['recPercent']['VALUE'] / 100);
                if ($recBonus <= 0) continue;
                // 把对碰后的奖金存入缓存中
                $perfUserInfo = CalcCache::getUserInfo($userId, $periodNum);
                $bonusUserId = $perfUserInfo['REC_UID'] ?? '';
                if( !$bonusUserId ) continue;

                // 获取会员的报单级别
                $userBaseInfo = CalcCache::getUserInfo($bonusUserId, $this->_periodNum);
                //判断级别上限
//                $recBonus = $this->declarationLevelCap($recBonus, $bonusUserId, $userBaseInfo['DEC_LV']);
//                if( $recBonus <= 0 ) continue;

                $recBonus = $this->bonusTotalLimit($recBonus, $bonusUserId, $userBaseInfo['REC_NUM'], $userBaseInfo['ZC_AMOUNT']);
                if( $recBonus <= 0 ) continue;

                //扣除相应的复消积分和管理费
                $deductData = $this->deduct($bonusUserId, $recBonus);

                CalcCache::bonus($bonusUserId, $periodNum, 'BONUS_TG', $recBonus, $deductData);

                //来源会员信息
                $fromUserInfo = CalcCache::getUserInfo($userId, $this->_periodNum);
                //推广奖流水
                $insertBonusData[] = [
                    'ID' => SnowFake::instance()->generateId(),
                    'USER_ID' => $bonusUserId,
                    'LAST_DEC_LV' => $userBaseInfo['DEC_LV'],
                    'LAST_EMP_LV' => $userBaseInfo['EMP_LV'],
                    'LAST_STATUS' => $userBaseInfo['STATUS'],
                    'FROM_USER_ID' => $userId,
                    'LAST_FROM_DEC_LV' => $fromUserInfo['DEC_LV'],
                    'LAST_FROM_EMP_LV' => $fromUserInfo['EMP_LV'],
                    'LAST_FROM_STATUS' => $fromUserInfo['STATUS'],
                    'AMOUNT' => $deductData['surplus'],
                    'ORI_BONUS' => $recBonus,
                    'RECONSUME_POINTS' => $deductData['reConsumePoints'],
                    'MANAGE_TAX' => $deductData['manageTax'],
                    'PERIOD_NUM' => $this->_periodNum,
                    'CALC_YEAR' => $this->_calcYear,
                    'CALC_MONTH' => $this->_calcYearMonth,
                    'P_CALC_MONTH' => Date::ociToDate($this->_calcYearMonth, Date::OCI_TIME_FORMAT_SHORT_MONTH),
                    'CREATED_AT' => Date::nowTime(),
                    'LOGS' => json_encode([
                        'perfPv' => $perfPv,
                        'recPercentConfig' => $this->_sysConfig['recPercent']['VALUE'],
                        'recNum' => $userBaseInfo['REC_NUM'],
                        'decAmount' => $userBaseInfo['ZC_AMOUNT'],
                        'decLevel' => $userBaseInfo['DEC_LV'],
                    ]),
                ];

                unset($perfData, $perfPv, $perfUserInfo, $recBonus, $bonusUserId, $userBaseInfo, $userId, $deductData, $fromUserInfo);
            }
            CalcBonusTG::batchInsert($insertBonusData);
            unset($allData, $insertBonusData);
            return $this->calcBonusTG($offset + $this->_limit);
        }
        unset($allData);
        return true;
    }

    /**
     * 消费奖-推荐人
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBonusXFToRec(int $offset = 0) {
        $periodNum = $this->_periodNum;
        // 从缓存获取分页有业绩的会员信息
        $allData = CalcCache::getHasPerfUsers($this->_periodNum, $offset, $this->_limit);
        if ($allData) {
            $insertBonusData = [];
            foreach ($allData as $userId) {
                // 从缓存中获取会员的业绩信息
                $perfData = CalcCache::nowPeriodPerf($userId, $periodNum);
                if( !$perfData ) continue;
                //个人业绩都算推荐奖，包括报单和复消、二次购物
                $perfPv = $perfData['PV_PCS_FX'] ?? 0;
                if( $perfPv <= 0 ) continue;

                //推广奖使用个人PCS
                $recBonus = Tool::formatPrice($perfPv * $this->_sysConfig['consumeRecPercent']['VALUE'] / 100);
                if ($recBonus <= 0) continue;
                // 把对碰后的奖金存入缓存中
                $perfUserInfo = CalcCache::getUserInfo($userId, $periodNum);
                $bonusUserId = $perfUserInfo['REC_UID'] ?? '';
                if( !$bonusUserId ) continue;

                // 获取会员的报单级别
                $userBaseInfo = CalcCache::getUserInfo($bonusUserId, $this->_periodNum);
                //判断级别上限
//                $recBonus = $this->declarationLevelCap($recBonus, $bonusUserId, $userBaseInfo['DEC_LV']);
//                if( $recBonus <= 0 ) continue;

                $recBonus = $this->bonusTotalLimit($recBonus, $bonusUserId, $userBaseInfo['REC_NUM'], $userBaseInfo['ZC_AMOUNT']);
                if( $recBonus <= 0 ) continue;

                //扣除相应的复消积分和管理费
                $deductData = $this->deduct($bonusUserId, $recBonus);

                CalcCache::bonus($bonusUserId, $periodNum, 'BONUS_XF', $recBonus, $deductData);

                //来源会员信息
                $fromUserInfo = CalcCache::getUserInfo($userId, $this->_periodNum);
                //推广奖流水
                $insertBonusData[] = [
                    'ID' => SnowFake::instance()->generateId(),
                    'USER_ID' => $bonusUserId,
                    'LAST_DEC_LV' => $userBaseInfo['DEC_LV'],
                    'LAST_EMP_LV' => $userBaseInfo['EMP_LV'],
                    'LAST_STATUS' => $userBaseInfo['STATUS'],
                    'FROM_USER_ID' => $userId,
                    'LAST_FROM_DEC_LV' => $fromUserInfo['DEC_LV'],
                    'LAST_FROM_EMP_LV' => $fromUserInfo['EMP_LV'],
                    'LAST_FROM_STATUS' => $fromUserInfo['STATUS'],
                    'AMOUNT' => $deductData['surplus'],
                    'ORI_BONUS' => $recBonus,
                    'RECONSUME_POINTS' => $deductData['reConsumePoints'],
                    'MANAGE_TAX' => $deductData['manageTax'],
                    'PERIOD_NUM' => $this->_periodNum,
                    'CALC_YEAR' => $this->_calcYear,
                    'CALC_MONTH' => $this->_calcYearMonth,
                    'P_CALC_MONTH' => Date::ociToDate($this->_calcYearMonth, Date::OCI_TIME_FORMAT_SHORT_MONTH),
                    'CREATED_AT' => Date::nowTime(),
                    'LOGS' => json_encode([
                        'perfPv' => $perfPv,
                        'recPercentConfig' => $this->_sysConfig['consumeRecPercent']['VALUE'],
                        'recNum' => $userBaseInfo['REC_NUM'],
                        'decAmount' => $userBaseInfo['ZC_AMOUNT'],
                        'decLevel' => $userBaseInfo['DEC_LV'],
                    ]),
                ];

                unset($perfData, $perfPv, $perfUserInfo, $recBonus, $bonusUserId, $userBaseInfo, $userId, $deductData, $fromUserInfo);
            }
            CalcBonusXF::batchInsert($insertBonusData);
            unset($allData, $insertBonusData);
            return $this->calcBonusXFToRec($offset + $this->_limit);
        }
        unset($allData);
        return true;
    }

    /**
     * 消费奖-自己
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBonusXFToSelf(int $offset = 0) {
        $periodNum = $this->_periodNum;
        // 从缓存获取分页有业绩的会员信息
        $allData = CalcCache::getHasPerfUsers($this->_periodNum, $offset, $this->_limit);
        if ($allData) {
            $insertBonusData = [];
            foreach ($allData as $userId) {
                // 从缓存中获取会员的业绩信息
                $perfData = CalcCache::nowPeriodPerf($userId, $periodNum);
                if( !$perfData ) continue;
                //个人业绩都算推荐奖，包括报单和复消、二次购物
                $perfPv = $perfData['PV_PCS_FX'] ?? 0;
                if( $perfPv <= 0 ) continue;

                //推广奖使用个人PCS
                $recBonus = Tool::formatPrice($perfPv * $this->_sysConfig['consumeSelfPercent']['VALUE'] / 100);
                if ($recBonus <= 0) continue;
                // 把对碰后的奖金存入缓存中
//                $perfUserInfo = CalcCache::getUserInfo($userId, $periodNum);
                $bonusUserId = $userId;
                if( !$bonusUserId ) continue;

                // 获取会员的报单级别
                $userBaseInfo = CalcCache::getUserInfo($bonusUserId, $this->_periodNum);
                //判断级别上限
//                $recBonus = $this->declarationLevelCap($recBonus, $bonusUserId, $userBaseInfo['DEC_LV']);
//                if( $recBonus <= 0 ) continue;

                $recBonus = $this->bonusTotalLimit($recBonus, $bonusUserId, $userBaseInfo['REC_NUM'], $userBaseInfo['ZC_AMOUNT']);
                if( $recBonus <= 0 ) continue;

                //扣除相应的复消积分和管理费
                $deductData = $this->deduct($bonusUserId, $recBonus);

                CalcCache::bonus($bonusUserId, $periodNum, 'BONUS_XF', $recBonus, $deductData);

                //来源会员信息
                $fromUserInfo = CalcCache::getUserInfo($userId, $this->_periodNum);
                //推广奖流水
                $insertBonusData[] = [
                    'ID' => SnowFake::instance()->generateId(),
                    'USER_ID' => $bonusUserId,
                    'LAST_DEC_LV' => $userBaseInfo['DEC_LV'],
                    'LAST_EMP_LV' => $userBaseInfo['EMP_LV'],
                    'LAST_STATUS' => $userBaseInfo['STATUS'],
                    'FROM_USER_ID' => $userId,
                    'LAST_FROM_DEC_LV' => $fromUserInfo['DEC_LV'],
                    'LAST_FROM_EMP_LV' => $fromUserInfo['EMP_LV'],
                    'LAST_FROM_STATUS' => $fromUserInfo['STATUS'],
                    'AMOUNT' => $deductData['surplus'],
                    'ORI_BONUS' => $recBonus,
                    'RECONSUME_POINTS' => $deductData['reConsumePoints'],
                    'MANAGE_TAX' => $deductData['manageTax'],
                    'PERIOD_NUM' => $this->_periodNum,
                    'CALC_YEAR' => $this->_calcYear,
                    'CALC_MONTH' => $this->_calcYearMonth,
                    'P_CALC_MONTH' => Date::ociToDate($this->_calcYearMonth, Date::OCI_TIME_FORMAT_SHORT_MONTH),
                    'CREATED_AT' => Date::nowTime(),
                    'LOGS' => json_encode([
                        'perfPv' => $perfPv,
                        'recPercentConfig' => $this->_sysConfig['consumeSelfPercent']['VALUE'],
                        'recNum' => $userBaseInfo['REC_NUM'],
                        'decAmount' => $userBaseInfo['ZC_AMOUNT'],
                        'decLevel' => $userBaseInfo['DEC_LV'],
                    ]),
                ];

                unset($perfData, $perfPv, $recBonus, $bonusUserId, $userBaseInfo, $userId, $deductData, $fromUserInfo);
            }
            CalcBonusXF::batchInsert($insertBonusData);
            unset($allData, $insertBonusData);
            return $this->calcBonusXFToSelf($offset + $this->_limit);
        }
        unset($allData);
        return true;
    }


    /**
     * 服务奖第一步
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBonusBDStepOne(int $offset = 0) {
        echo sprintf("时间:[%s]服务奖第【1】步，当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()) , $offset);
        $periodNum = $this->_periodNum;
        // 从缓存获取分页有业绩的会员信息
        $allData = CalcCache::getHasPerfUsers($this->_periodNum, $offset, $this->_limit);
        if ($allData) {
            $insertBonusData = [];
            foreach ($allData as $userId) {
                // 从缓存中获取会员的业绩信息
                $perfData = CalcCache::nowPeriodPerf($userId, $periodNum);
                if( !$perfData ) continue;

                //
                $decRoleBonusFrom = explode(',', $this->_sysConfig['decRoleBonusFrom']['VALUE']);
                $validPvPcs = 0;
                foreach ($decRoleBonusFrom as $orderType) {
                    $orderTypeName = sprintf('PV_PCS_%s', $orderType);
                    $orderTypeValue = $perfData[$orderTypeName] ?? 0;

                    $coefficientName = self::ORDER_TYPE_TO_FW_COEFFICIENT[$orderType];
                    $coefficient = $this->_sysConfig[$coefficientName]['VALUE'] ?? 1;
                    $validPvPcs += $orderTypeValue * $coefficient;

                    unset($orderType, $orderTypeName, $orderTypeValue, $coefficientName, $coefficient);
                }
                unset($perfData, $decRoleBonusFrom);
                if ( $validPvPcs <= 0 ) continue;

                $this->loopRelationParentDo($userId, function ($parent) use($userId, $validPvPcs){

                    //判断parent的报单中心级别 和 服务奖比例
                    $bonusUserId = $parent['PARENT_UID'];
                    //计算级别之后更新过userInfo的缓存,缓存中级别发生了变化
                    $bonusUserInfo = CalcCache::getUserInfo($bonusUserId, $this->_periodNum);
                    $isDec = $bonusUserInfo['IS_DEC'];
                    if($isDec == 0) return self::LOOP_CONTINUE;
                    $decRoleId = $bonusUserInfo['DEC_ROLE_ID'];
                    if( !$decRoleId ) return self::LOOP_CONTINUE;
                    if( !isset($this->_decRoleConfig[$decRoleId]) ) return self::LOOP_CONTINUE;

                    $parentDecRoleLevel = $this->_decRoleConfig[$decRoleId];
                    $parentFwBonusPercent = $parentDecRoleLevel['FW_BONUS_PERCENT'] ?? 0;
                    $cacheMaxPercent = CalcCache::fwMaxBonusPercent($userId, $this->_periodNum);
                    $diffPercent = $parentFwBonusPercent - $cacheMaxPercent;
                    if( $diffPercent <= 0 ) return self::LOOP_CONTINUE;

                    $fwBonus = $validPvPcs * $diffPercent / 100;
                    if( $fwBonus <= 0  ) return self::LOOP_CONTINUE;

                    //给本人添加服务奖比例
                    CalcCache::fwMaxBonusPercent($userId, $this->_periodNum, $parentFwBonusPercent);
                    //记录奖金和奖金来源到缓存 并实现在缓存中奖金累加
                    CalcCache::saveFwBonusList($bonusUserId, $this->_periodNum, $fwBonus, ['fromUid'=>$userId, 'fromPvPcs'=>$validPvPcs]);
                    CalcCache::addHasFwBonusUsers($bonusUserId, $this->_periodNum);

                    //达到最大的比例就不在向上找了
//                    if( $parentFwBonusPercent >= $maxLevelPercent ) return self::LOOP_FINISH;
                    unset($bonusUserId, $bonusUserInfo, $isDec, $decRoleId, $parentDecRoleLevel, $parentFwBonusPercent, $cacheMaxPercent, $diffPercent, $fwBonus);
                });

                unset($userId, $validPvPcs);


            }
            unset($allData, $insertBonusData);
            return $this->calcBonusBDStepOne($offset + $this->_limit);
        }
        unset($allData);
        return true;
    }

    /**
     * 服务奖第二步
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBonusBDStepTwo(int $offset = 0) {
        echo sprintf("时间:[%s]服务奖第【2】步，当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()) , $offset);

        $allData = CalcCache::getHasFwBonusUsers($this->_periodNum, $offset, $this->_limit);
        if ($allData) {
            $insertBonusData = [];
            foreach ($allData as $userId) {
                $fwBonusData = CalcCache::getFwBonusList($userId, $this->_periodNum);
                if( !$fwBonusData ) continue;
                $fwBonus = $fwBonusData['fwBonus'] ?? 0;
                if( $fwBonus <=0  ) continue;
                //总金额限制
                $userBaseInfo = CalcCache::getUserInfo($userId, $this->_periodNum);
                $fwBonus = $this->bonusTotalLimit($fwBonus, $userId, $userBaseInfo['REC_NUM'], $userBaseInfo['ZC_AMOUNT']);

                if( $fwBonus <= 0 ) continue;

                //扣除相应的复消积分和管理费
//                $deductData = $this->deduct($userId, $fwBonus);

                CalcCache::bonus($userId, $this->_periodNum, 'BONUS_BD', $fwBonus);

                $decRoleId = $userBaseInfo['DEC_ROLE_ID'];
                $insertBonusData[] = [
                    'ID' => SnowFake::instance()->generateId(),
                    'USER_ID' => $userId,
                    'LAST_DEC_LV' => $userBaseInfo['DEC_LV'],
                    'LAST_EMP_LV' => $userBaseInfo['EMP_LV'],
                    'LAST_STATUS' => $userBaseInfo['STATUS'],
                    'FROM_USER_ID' => $userId,
                    'LAST_FROM_DEC_LV' => $userBaseInfo['DEC_LV'],
                    'LAST_FROM_EMP_LV' => $userBaseInfo['EMP_LV'],
                    'LAST_FROM_STATUS' => $userBaseInfo['STATUS'],
                    'AMOUNT' => $fwBonus,
                    'ORI_BONUS' => $fwBonus,
                    'RECONSUME_POINTS' => 0,
                    'MANAGE_TAX' => 0,
                    'PERIOD_NUM' => $this->_periodNum,
                    'CALC_YEAR' => $this->_calcYear,
                    'CALC_MONTH' => $this->_calcYearMonth,
                    'P_CALC_MONTH' => Date::ociToDate($this->_calcYearMonth, Date::OCI_TIME_FORMAT_SHORT_MONTH),
                    'CREATED_AT' => Date::nowTime(),
                    'LOGS' => json_encode([
                        'decRoleId' => $decRoleId,
                    ])
//                    'FROM_DATA' => json_encode($ycBonusData['fromData']),
                ];

                unset($userId, $fwBonusData, $userBaseInfo, $decRoleId, $fwBonus);

            }

            CalcBonusBD::batchInsert($insertBonusData);
            unset($insertBonusData, $allData);
            $this->calcBonusBDStepTwo($offset + $this->_limit);
        }

        unset($allData);
        return true;
    }

    // 紧缩计算店服务奖,不活跃,则给一个活跃的店铺
    public function calcStoreBonusReduce(int $offset = 0) {
        if( !$this->_isCalcMonth ) {
            // 不是结算月,则不进行计算
            echo sprintf("时间:[%s]店服务奖金非月节点，不进行计算，当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()) , $offset);
            return false;
        }
        echo sprintf("时间:[%s]店服务奖金计算--紧缩方式，当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()) , $offset);
        $allData = CalcCache::getHasPerfUsers($this->_periodNum, $offset, $this->_limit);
        if ($allData) {
            $insertBonusData = [];
            foreach ($allData as $userId) {
                $storeBonus = $this->verifyStorePerf($userId);
                if (empty($storeBonus)) continue;
                // 判断此店铺是否是活跃用户,如果不活跃,则往上找一个活跃的店铺获得此奖
                $isActive = $this->_isMonthPerfLimit($userId);
                $bonusUserId = '';
                // 如果用户不活跃,且上面没有活跃的,则不累计了,是不是
                if (!$isActive) {
                    // 如果此店铺不活跃,则找最近的一个店铺获得此奖
                    $this->loopRelationParentDo($userId, function ($parent) use (&$bonusUserId) {
                        if ($this->_isMonthPerfLimit($parent['PARENT_UID'])) {
                            // 判断是否是店铺
                            $parentUser = CalcCache::getUserInfo($parent['PARENT_UID'], $this->_periodNum);
                            if ($parentUser['IS_STUDIO'] == 1) {
                                $bonusUserId = $parent['PARENT_UID'];

                                return self::LOOP_FINISH;
                            }
                            
                        }
                        unset($parent);
                    });
                }
                if (!$isActive && !$bonusUserId) {
                    continue;
                }
               
                $realBonusUserId = $bonusUserId ? $bonusUserId : $userId; 
                //扣除相应的复消积分和管理费
                $deductData = $this->deduct($realBonusUserId, $storeBonus);
                // 把对碰后的奖金存入缓存中
                CalcCache::bonus($realBonusUserId, $this->_periodNum, 'BONUS_STORE', $storeBonus, $deductData);
                $surplus = $deductData['surplus'];
                $manageTax = $deductData['manageTax'];
                $reConsumePoints = $deductData['reConsumePoints'];
                
                //店服务奖流水
                $insertBonusData[] = [
                    'ID' => SnowFake::instance()->generateId(),
                    'USER_ID' => $realBonusUserId,
                    'FROM_USER_ID' => $bonusUserId ? $userId : '', // 分享店铺的ID.只有紧缩且未活跃,才有此值
                    'AMOUNT' => $surplus,
                    'ORI_BONUS' => $storeBonus,
                    'RECONSUME_POINTS' => $reConsumePoints,
                    'MANAGE_TAX' => $manageTax,
                    'PERIOD_NUM' => $this->_periodNum,
                    'CALC_YEAR' => $this->_calcYear,
                    'CALC_MONTH' => $this->_calcYearMonth,
                    'P_CALC_MONTH' => Date::ociToDate($this->_calcYearMonth, Date::OCI_TIME_FORMAT_SHORT_MONTH),
                    'CREATED_AT' => Date::nowTime()
                ];

                unset($bonusUserId, $userId, $deductData);
            }
            CalcBonusST::batchInsert($insertBonusData);
            unset($allData, $insertBonusData);
            return $this->calcStoreBonusReduce($offset + $this->_limit);
        }
    
        unset($allData);
    
        return true;
    }

    // 未开启紧缩方式计算店服务奖,不活跃即不给奖金 
    public function calcStoreBonus(int $offset = 0) {
        if( !$this->_isCalcMonth ) {
            // 不是结算月,则不进行计算
            echo sprintf("时间:[%s]店服务奖金非月节点，不进行计算，当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()) , $offset);
            return false;
        }
        echo sprintf("时间:[%s]店服务奖金计算--非紧缩方式，当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()) , $offset);
        $allData = CalcCache::getHasPerfUsers($this->_periodNum, $offset, $this->_limit);
        if ($allData) {
            $insertBonusData = [];
            foreach ($allData as $userId) {
                $storeBonus = $this->verifyStorePerf($userId);
                if (empty($storeBonus)) continue;
                // 未开启紧缩,不活跃,则不发放了
                $isActive = $this->_isMonthPerfLimit($userId);
                if (!$isActive) continue;
                $surplus = $storeBonus;
                //扣除相应的复消积分和管理费
                $deductData = $this->deduct($userId, $storeBonus);
                CalcCache::bonus($userId, $this->_periodNum, 'BONUS_STORE', $storeBonus, $deductData);
                $surplus = $deductData['surplus'];
                $manageTax = $deductData['manageTax'];
                $reConsumePoints = $deductData['reConsumePoints'];

                //店服务奖流水
                $insertBonusData[] = [
                    'ID' => SnowFake::instance()->generateId(),
                    'USER_ID' => $userId,
                    'AMOUNT' => $surplus,
                    'ORI_BONUS' => $storeBonus,
                    'RECONSUME_POINTS' => $reConsumePoints,
                    'MANAGE_TAX' => $manageTax,
                    'PERIOD_NUM' => $this->_periodNum,
                    'CALC_YEAR' => $this->_calcYear,
                    'CALC_MONTH' => $this->_calcYearMonth,
                    'P_CALC_MONTH' => Date::ociToDate($this->_calcYearMonth, Date::OCI_TIME_FORMAT_SHORT_MONTH),
                    'CREATED_AT' => Date::nowTime()
                ];

                unset($userId, $deductData);
            }
            CalcBonusST::batchInsert($insertBonusData);
            unset($allData, $insertBonusData);
            return $this->calcStoreBonus($offset + $this->_limit);
        }
    
        unset($allData);
    
        return true;
    }

    /**
     * 通过用户id,校验店服务奖,此用户是否有原奖金
     */
    public function verifyStorePerf($userId) {
        // 从缓存中获取会员的业绩信息
        $perfData = CalcCache::nowPeriodPerf($userId, $this->_periodNum);
        if( !$perfData ) {
            return false;
        }
        // 获取小组+自己的业绩
        $perfPv = $perfData['STORE_PV_GRAND'] ?? 0;
        if( $perfPv <= 0 ) {
            return false;
        }
        StorePerfLog::stGroupPv($this->_periodNum,$this->_calcYearMonth, $userId, $perfPv);
        // 业绩乘以比例为奖金
        $storeBonus = Tool::formatPrice($perfPv * $this->_sysConfig['storePercent']['VALUE'] / 100);
        if ($storeBonus <= 0) {
            return false;
        }
        // 获取会员的报单级别
        $userBaseInfo = CalcCache::getUserInfo($userId, $this->_periodNum);
        $storeBonus = $this->bonusTotalLimit($storeBonus, $userId, $userBaseInfo['REC_NUM'], $userBaseInfo['ZC_AMOUNT']);
        if( $storeBonus <= 0 ) {
            return false;
        }

        unset($perfData, $perfPv, $userBaseInfo, $userId);

        return $storeBonus;
    }

    /**
     * 报单业绩奖
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBonusBdYJ(int $offset = 0) {
        $periodNum = $this->_periodNum;
        // 从缓存获取分页有业绩的会员信息
        $allData = CalcCache::getHasPerfUsers($this->_periodNum, $offset, $this->_limit);
        if ($allData) {
            foreach ($allData as $userId) {
                $insertBonusData = [];

                // 从缓存中获取会员的业绩信息
                $perfData = CalcCache::nowPeriodPerf($userId, $periodNum);
                if( !$perfData ) continue;
                //个人业绩都算见点奖，包括报单和复消、二次购物
                $perfPv = $perfData['PV_PCS_ZC'] ?? 0;
                if( $perfPv <= 0 ) continue;

                //业绩奖使用报单PV
//                $oriPointsBonus = Tool::formatPrice($perfPv * $this->_sysConfig['pointsPercent']['VALUE'] / 100);
//                if ($oriPointsBonus <= 0) continue;
                //偶数层数
                $pointsEvenLayer = $this->_sysConfig['pointsLayer']['VALUE'];
                $userBaseInfo = CalcCache::getUserInfo($userId, $this->_periodNum);
                $userEmpLevel = $userBaseInfo['EMP_LV'];
                $netWorkParents = Cache::getAllNetworkParents($userId);
                foreach ($netWorkParents as $netWorkParent) {
//                    $pointsBonus = $oriPointsBonus;
                    //自已距顶端的深度减去父级距顶端的深度
                    $diffLayer = $netWorkParent['TOP_DEEP'] - $netWorkParent['PARENT_DEEP'];
                    if( $diffLayer <= 0) continue;

                    if( $diffLayer > 2 * $pointsEvenLayer ) continue;

                    if( $diffLayer % 2 == 1 ) continue;

                    $pointsPercentName = sprintf('pointsPercent_%d', $diffLayer);
                    if( isset($this->_sysConfig[$pointsPercentName]['VALUE']) ) {
                        $diffLayerPercent = $this->_sysConfig[$pointsPercentName]['VALUE'];
                    }else {
                        $diffLayerPercent = $this->_sysConfig['pointsPercent']['VALUE'];
                    }
                    $pointsBonus = Tool::formatPrice($perfPv * $diffLayerPercent / 100);
                    if( $pointsBonus <= 0 ) continue;

                    // 把对碰后的奖金存入缓存中
                    $bonusUserId = $netWorkParent['PARENT_UID'];
                    if( !$bonusUserId ) continue;

                    // 获取会员的报单级别
                    $bonusUserBaseInfo = CalcCache::getUserInfo($bonusUserId, $this->_periodNum);
                    //判断上限 包括级别奖金上限和总上限
//                    $pointsBonus = $this->declarationLevelCap($pointsBonus, $bonusUserId, $bonusUserBaseInfo['DEC_LV']);
//                    if( $pointsBonus <= 0 ) continue;

                    //总金额限制
                    $pointsBonus = $this->bonusTotalLimit($pointsBonus, $bonusUserId, $bonusUserBaseInfo['REC_NUM'], $bonusUserBaseInfo['ZC_AMOUNT']);
                    if( $pointsBonus <= 0 ) continue;

                    //扣除相应的复消积分和管理费
                    $deductData = $this->deduct($bonusUserId, $pointsBonus);

                    CalcCache::bonus($bonusUserId, $periodNum, 'BONUS_YJ', $pointsBonus, $deductData, CalcCache::FROM_MEANS_BD);

                    //业绩奖流水
                    $insertBonusData[] = [
                        'ID' => SnowFake::instance()->generateId(),
                        'USER_ID' => $bonusUserId,
                        'LAST_DEC_LV' => $bonusUserBaseInfo['DEC_LV'],
                        'LAST_EMP_LV' => $bonusUserBaseInfo['EMP_LV'],
                        'LAST_STATUS' => $bonusUserBaseInfo['STATUS'],
                        'FROM_USER_ID' => $userId,
                        'LAST_FROM_DEC_LV' => $userBaseInfo['DEC_LV'],
                        'LAST_FROM_EMP_LV' => $userEmpLevel,
                        'LAST_FROM_STATUS' => $userBaseInfo['STATUS'],
                        'AMOUNT' => $deductData['surplus'],
                        'ORI_BONUS' => $pointsBonus,
                        'RECONSUME_POINTS' => $deductData['reConsumePoints'],
                        'MANAGE_TAX' => $deductData['manageTax'],
                        'PERIOD_NUM' => $this->_periodNum,
                        'CALC_YEAR' => $this->_calcYear,
                        'CALC_MONTH' => $this->_calcYearMonth,
                        'P_CALC_MONTH' => Date::ociToDate($this->_calcYearMonth, Date::OCI_TIME_FORMAT_SHORT_MONTH),
                        'CREATED_AT' => Date::nowTime(),
                        'LOGS' => json_encode([
                            'perfPv' => $perfPv,
                            'pointsLayerConfig' => $this->_sysConfig['pointsLayer']['VALUE'],
                            'pointsPercentConfig' => $diffLayerPercent,
                            'recNum' => $bonusUserBaseInfo['REC_NUM'],
                            'decAmount' => $bonusUserBaseInfo['ZC_AMOUNT'],
                            'decLevel' => $bonusUserBaseInfo['DEC_LV'],
                        ]),
                    ];

                    unset($netWorkParent, $pointsBonus, $diffLayer, $bonusUserId, $bonusUserBaseInfo, $deductData, $diffLayerPercent, $pointsPercentName);

                }

                CalcBonusYJ::batchInsert($insertBonusData);

                unset($insertBonusData, $userId, $perfData, $perfPv, $oriPointsBonus, $pointsEvenLayer, $userBaseInfo, $userEmpLevel, $netWorkParents);
            }
            unset($allData);
            return $this->calcBonusBdYJ($offset + $this->_limit);
        }
        unset($allData);
        return true;
    }


    /**
     * 复消业绩奖
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBonusFxYJ(int $offset = 0) {
        $periodNum = $this->_periodNum;
        // 从缓存获取分页有业绩的会员信息
        $allData = CalcCache::getHasPerfUsers($this->_periodNum, $offset, $this->_limit);
        if ($allData) {
            foreach ($allData as $userId) {
                $insertBonusData = [];

                // 从缓存中获取会员的业绩信息
                $perfData = CalcCache::nowPeriodPerf($userId, $periodNum);
                if( !$perfData ) continue;
                //个人业绩都算见点奖，包括报单和复消、二次购物
                $perfPv = $perfData['PV_PCS_FX'] ?? 0;
                if( $perfPv <= 0 ) continue;

                //业绩奖使用报单PV
//                $oriPointsBonus = Tool::formatPrice($perfPv * $this->_sysConfig['pointsPercent']['VALUE'] / 100);
//                if ($oriPointsBonus <= 0) continue;
                //偶数层数
                $pointsEvenLayer = $this->_sysConfig['fxPointsLayer']['VALUE'];
                $userBaseInfo = CalcCache::getUserInfo($userId, $this->_periodNum);
                $userEmpLevel = $userBaseInfo['EMP_LV'];
                $netWorkParents = Cache::getAllNetworkParents($userId);
                foreach ($netWorkParents as $netWorkParent) {
//                    $pointsBonus = $oriPointsBonus;
                    //自已距顶端的深度减去父级距顶端的深度
                    $diffLayer = $netWorkParent['TOP_DEEP'] - $netWorkParent['PARENT_DEEP'];
                    if( $diffLayer <= 0) continue;

                    if( $diffLayer > 2 * $pointsEvenLayer ) continue;

                    if( $diffLayer % 2 == 1 ) continue;

                    $pointsPercentName = sprintf('fxPointsPercent_%d', $diffLayer);
                    if( isset($this->_sysConfig[$pointsPercentName]['VALUE']) ) {
                        $diffLayerPercent = $this->_sysConfig[$pointsPercentName]['VALUE'];
                    }else {
                        $diffLayerPercent = $this->_sysConfig['fxPointsPercent']['VALUE'];
                    }
                    $pointsBonus = Tool::formatPrice($perfPv * $diffLayerPercent / 100);
                    if( $pointsBonus <= 0 ) continue;

                    // 把对碰后的奖金存入缓存中
                    $bonusUserId = $netWorkParent['PARENT_UID'];
                    if( !$bonusUserId ) continue;

                    // 获取会员的报单级别
                    $bonusUserBaseInfo = CalcCache::getUserInfo($bonusUserId, $this->_periodNum);
                    //判断上限 包括级别奖金上限和总上限
//                    $pointsBonus = $this->declarationLevelCap($pointsBonus, $bonusUserId, $bonusUserBaseInfo['DEC_LV']);
//                    if( $pointsBonus <= 0 ) continue;

                    //总金额限制
                    $pointsBonus = $this->bonusTotalLimit($pointsBonus, $bonusUserId, $bonusUserBaseInfo['REC_NUM'], $bonusUserBaseInfo['ZC_AMOUNT']);
                    if( $pointsBonus <= 0 ) continue;

                    //扣除相应的复消积分和管理费
                    $deductData = $this->deduct($bonusUserId, $pointsBonus);

                    CalcCache::bonus($bonusUserId, $periodNum, 'BONUS_YJ', $pointsBonus, $deductData, CalcCache::FROM_MEANS_FX);

                    //业绩奖流水
                    $insertBonusData[] = [
                        'ID' => SnowFake::instance()->generateId(),
                        'USER_ID' => $bonusUserId,
                        'LAST_DEC_LV' => $bonusUserBaseInfo['DEC_LV'],
                        'LAST_EMP_LV' => $bonusUserBaseInfo['EMP_LV'],
                        'LAST_STATUS' => $bonusUserBaseInfo['STATUS'],
                        'FROM_USER_ID' => $userId,
                        'LAST_FROM_DEC_LV' => $userBaseInfo['DEC_LV'],
                        'LAST_FROM_EMP_LV' => $userEmpLevel,
                        'LAST_FROM_STATUS' => $userBaseInfo['STATUS'],
                        'AMOUNT' => $deductData['surplus'],
                        'ORI_BONUS' => $pointsBonus,
                        'RECONSUME_POINTS' => $deductData['reConsumePoints'],
                        'MANAGE_TAX' => $deductData['manageTax'],
                        'PERIOD_NUM' => $this->_periodNum,
                        'CALC_YEAR' => $this->_calcYear,
                        'CALC_MONTH' => $this->_calcYearMonth,
                        'P_CALC_MONTH' => Date::ociToDate($this->_calcYearMonth, Date::OCI_TIME_FORMAT_SHORT_MONTH),
                        'CREATED_AT' => Date::nowTime(),
                        'LOGS' => json_encode([
                            'perfPv' => $perfPv,
                            'pointsLayerConfig' => $this->_sysConfig['fxPointsLayer']['VALUE'],
                            'pointsPercentConfig' => $diffLayerPercent,
                            'recNum' => $bonusUserBaseInfo['REC_NUM'],
                            'decAmount' => $bonusUserBaseInfo['ZC_AMOUNT'],
                            'decLevel' => $bonusUserBaseInfo['DEC_LV'],
                        ]),
                    ];

                    unset($netWorkParent, $pointsBonus, $diffLayer, $bonusUserId, $bonusUserBaseInfo, $deductData, $diffLayerPercent, $pointsPercentName);

                }

                CalcBonusYJ::batchInsert($insertBonusData);

                unset($insertBonusData, $userId, $perfData, $perfPv, $oriPointsBonus, $pointsEvenLayer, $userBaseInfo, $userEmpLevel, $netWorkParents);
            }
            unset($allData);
            return $this->calcBonusFxYJ($offset + $this->_limit);
        }
        unset($allData);
        return true;
    }

    /**
     * 团队奖
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBonusQY(int $offset = 0) {
        echo sprintf("时间:[%s]团队奖，当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()) , $offset);
        $periodNum = $this->_periodNum;
        // 从缓存获取分页有业绩的会员信息
        $allData = CalcCache::getHasPerfUsers($this->_periodNum, $offset, $this->_limit);
        if ($allData) {
            $insertBonusData = [];
            foreach ($allData as $userId) {
                // 从缓存中获取会员的业绩信息
                $perfData = CalcCache::nowPeriodPerf($userId, $periodNum);
                // 从缓存中获取会员的上期结余业绩信息
                $pervSurplusPerf = CalcCache::surplusPerf($userId, $periodNum);
                // 本期 + 上期结余
                $perfArr = [
                    'SURPLUS_1L' => $perfData['PV_1L_TOUCH'] + $pervSurplusPerf['SURPLUS_1L'],
                    'SURPLUS_2L' => $perfData['PV_2L_TOUCH'] + $pervSurplusPerf['SURPLUS_2L'],
                    'SURPLUS_3L' => $perfData['PV_3L_TOUCH'] + $pervSurplusPerf['SURPLUS_3L'],
                    'SURPLUS_4L' => $perfData['PV_4L_TOUCH'] + $pervSurplusPerf['SURPLUS_4L'],
                    'SURPLUS_5L' => $perfData['PV_5L_TOUCH'] + $pervSurplusPerf['SURPLUS_5L'],
                ];
                $oriPerfArr = [
                    'perfArr' => $perfArr,
                    'touchBonus' => 0,
                ];
                // 获取会员的报单级别
                $userBaseInfo = CalcCache::getUserInfo($userId, $this->_periodNum);
                $decLevelConfig = $this->_decLevelConfig;
                $nowDecLevelConfig = $decLevelConfig[$userBaseInfo['DEC_LV']];
                // 对碰
                $touchBonusArr = $this->touchPerf($oriPerfArr, $perfArr, $nowDecLevelConfig['QY_PERCENT']/100);
                $touchPerfArr = [];
                foreach ($touchBonusArr['perfArr'] as $keyR => $perfR) {
                    $touchPerfArr[$keyR] = $perfR;
                }
                // 对碰完成后把结余的业绩存入本期业绩缓存中
                CalcCache::nowPeriodPerf($userId, $periodNum, $touchPerfArr);
                //更新数据库
                PerfPeriod::updateAll($touchPerfArr, 'USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM', [
                    'USER_ID' => $userId,
                    'PERIOD_NUM' => $periodNum,
                ]);
                if ($touchBonusArr['touchBonus'] <= 0) continue;

                $teamBonus = $touchBonusArr['touchBonus'];
                //判断级别上限
                $teamBonus = $this->declarationLevelCap($teamBonus, $userId, $userBaseInfo['DEC_LV']);
                if( $teamBonus <= 0 ) continue;

                $teamBonus = $this->bonusTotalLimit($teamBonus, $userId, $userBaseInfo['REC_NUM'], $userBaseInfo['ZC_AMOUNT']);
                if( $teamBonus <= 0 ) continue;

                //扣除相应的复消积分和管理费
                $deductData = $this->deduct($userId, $teamBonus);

                // 把对碰后的奖金存入缓存中
                CalcCache::bonus($userId, $periodNum, 'BONUS_QY', $teamBonus, $deductData);

                //团队奖流水
                $insertBonusData[] = [
                    'ID' => SnowFake::instance()->generateId(),
                    'USER_ID' => $userId,
                    'LAST_DEC_LV' => $userBaseInfo['DEC_LV'],
                    'LAST_EMP_LV' => $userBaseInfo['EMP_LV'],
                    'LAST_STATUS' => $userBaseInfo['STATUS'],
                    'AMOUNT' => $deductData['surplus'],
                    'ORI_BONUS' => $teamBonus,
                    'RECONSUME_POINTS' => $deductData['reConsumePoints'],
                    'MANAGE_TAX' => $deductData['manageTax'],
                    'PERIOD_NUM' => $this->_periodNum,
                    'CALC_YEAR' => $this->_calcYear,
                    'CALC_MONTH' => $this->_calcYearMonth,
                    'P_CALC_MONTH' => Date::ociToDate($this->_calcYearMonth, Date::OCI_TIME_FORMAT_SHORT_MONTH),
                    'CREATED_AT' => Date::nowTime(),
                    'LOGS' => json_encode([
                        'perfArr' => $perfArr,
                        'touchPerfArrOri' => $touchBonusArr['perfArr'],
                        'touchPerfArr' => $touchPerfArr,
                        'nowDecLevelConfig' => $nowDecLevelConfig,
                        'decLevel' => $userBaseInfo['DEC_LV'],

                    ]),
                ];

                unset($perfData, $pervSurplusPerf, $perfArr, $oriPerfArr, $touchPerfArr, $userBaseInfo, $decLevelConfig, $touchBonusArr, $userId, $nowDecLevelConfig, $teamBonus, $deductData);
            }
            CalcBonusQY::batchInsert($insertBonusData);
            unset($allData, $insertBonusData);
            return $this->calcBonusQY($offset + $this->_limit);
        }
        unset($allData);
        return true;
    }

    /**
     * 报单团队奖
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBonusBdQY(int $offset = 0) {
        echo sprintf("时间:[%s]报单团队奖，当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()) , $offset);
        $periodNum = $this->_periodNum;
        // 从缓存获取分页有业绩的会员信息
        $allData = CalcCache::getHasPerfUsers($this->_periodNum, $offset, $this->_limit);
        if ($allData) {
            $insertBonusData = [];
            foreach ($allData as $userId) {
                // 从缓存中获取会员的业绩信息
                $perfData = CalcCache::nowPeriodPerf($userId, $periodNum);
                // 从缓存中获取会员的上期结余业绩信息
                $pervSurplusPerf = CalcCache::surplusPerf($userId, $periodNum);
                // 本期 + 上期结余
                $perfArr = [
                    'SURPLUS_1L_ZC' => $perfData['PV_1L_ZC'] + $pervSurplusPerf['SURPLUS_1L_ZC'],
                    'SURPLUS_2L_ZC' => $perfData['PV_2L_ZC'] + $pervSurplusPerf['SURPLUS_2L_ZC'],
                    'SURPLUS_3L_ZC' => $perfData['PV_3L_ZC'] + $pervSurplusPerf['SURPLUS_3L_ZC'],
                    'SURPLUS_4L_ZC' => $perfData['PV_4L_ZC'] + $pervSurplusPerf['SURPLUS_4L_ZC'],
                    'SURPLUS_5L_ZC' => $perfData['PV_5L_ZC'] + $pervSurplusPerf['SURPLUS_5L_ZC'],
                ];
                $oriPerfArr = [
                    'perfArr' => $perfArr,
                    'touchBonus' => 0,
                ];
                // 获取会员的报单级别
                $userBaseInfo = CalcCache::getUserInfo($userId, $this->_periodNum);
                $decLevelConfig = $this->_decLevelConfig;
                $nowDecLevelConfig = $decLevelConfig[$userBaseInfo['DEC_LV']];
                // 对碰
                $touchBonusArr = $this->touchPerf($oriPerfArr, $perfArr, $nowDecLevelConfig['QY_PERCENT']/100);
                $touchPerfArr = [];
                foreach ($touchBonusArr['perfArr'] as $keyR => $perfR) {
                    $touchPerfArr[$keyR] = $perfR;
                }
                // 对碰完成后把结余的业绩存入本期业绩缓存中
                CalcCache::nowPeriodPerf($userId, $periodNum, $touchPerfArr);
                //更新数据库
                PerfPeriod::updateAll($touchPerfArr, 'USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM', [
                    'USER_ID' => $userId,
                    'PERIOD_NUM' => $periodNum,
                ]);
                if ($touchBonusArr['touchBonus'] <= 0) continue;

                $teamBonus = $touchBonusArr['touchBonus'];
                //判断级别上限
//                $teamBonus = $this->declarationLevelCap($teamBonus, $userId, $userBaseInfo['DEC_LV']);
//                if( $teamBonus <= 0 ) continue;

//                $teamBonus = $this->bonusTotalLimit($teamBonus, $userId, $userBaseInfo['REC_NUM'], $userBaseInfo['ZC_AMOUNT']);
//                if( $teamBonus <= 0 ) continue;

                //扣除相应的复消积分和管理费
//                $deductData = $this->deduct($userId, $teamBonus);

                // 把对碰后的奖金存入缓存中
                CalcCache::bonus($userId, $periodNum, 'BONUS_QY_BD', $teamBonus);

                unset($perfData, $pervSurplusPerf, $perfArr, $oriPerfArr, $touchPerfArr, $userBaseInfo, $decLevelConfig, $touchBonusArr, $userId, $nowDecLevelConfig, $teamBonus, $deductData);
            }
            unset($allData, $insertBonusData);
            return $this->calcBonusBdQY($offset + $this->_limit);
        }
        unset($allData);
        return true;
    }


    /**
     * 复消团队奖
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBonusFxQY(int $offset = 0) {
        echo sprintf("时间:[%s]复消团队奖，当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()) , $offset);
        $periodNum = $this->_periodNum;
        // 从缓存获取分页有业绩的会员信息
        $allData = CalcCache::getHasPerfUsers($this->_periodNum, $offset, $this->_limit);
        if ($allData) {
            $insertBonusData = [];
            foreach ($allData as $userId) {
                // 从缓存中获取会员的业绩信息
                $perfData = CalcCache::nowPeriodPerf($userId, $periodNum);
                // 从缓存中获取会员的上期结余业绩信息
                $pervSurplusPerf = CalcCache::surplusPerf($userId, $periodNum);
                // 本期 + 上期结余
                $perfArr = [
                    'SURPLUS_1L_FX' => $perfData['PV_1L_FX'] + $pervSurplusPerf['SURPLUS_1L_FX'],
                    'SURPLUS_2L_FX' => $perfData['PV_2L_FX'] + $pervSurplusPerf['SURPLUS_2L_FX'],
                    'SURPLUS_3L_FX' => $perfData['PV_3L_FX'] + $pervSurplusPerf['SURPLUS_3L_FX'],
                    'SURPLUS_4L_FX' => $perfData['PV_4L_FX'] + $pervSurplusPerf['SURPLUS_4L_FX'],
                    'SURPLUS_5L_FX' => $perfData['PV_5L_FX'] + $pervSurplusPerf['SURPLUS_5L_FX'],
                ];
                $oriPerfArr = [
                    'perfArr' => $perfArr,
                    'touchBonus' => 0,
                ];
                // 获取会员的报单级别
                $userBaseInfo = CalcCache::getUserInfo($userId, $this->_periodNum);
                $decLevelConfig = $this->_decLevelConfig;
                $nowDecLevelConfig = $decLevelConfig[$userBaseInfo['DEC_LV']];
                // 对碰
                $touchBonusArr = $this->touchPerf($oriPerfArr, $perfArr, $nowDecLevelConfig['QY_PERCENT']/100);
                //大区封顶
                $touchPerfArr = [];
                foreach ($touchBonusArr['perfArr'] as $keyR => $perfR) {
//                    if ($perfR > $nowDecLevelConfig['QY_BIG_CAP']) $perfR = $nowDecLevelConfig['QY_BIG_CAP'];
                    $touchPerfArr[$keyR] = $perfR;
                }
                // 对碰完成后把结余的业绩存入本期业绩缓存中
                CalcCache::nowPeriodPerf($userId, $periodNum, $touchPerfArr);
                //更新数据库
                PerfPeriod::updateAll($touchPerfArr, 'USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM', [
                    'USER_ID' => $userId,
                    'PERIOD_NUM' => $periodNum,
                ]);
                if ($touchBonusArr['touchBonus'] <= 0) continue;

                $teamBonus = $touchBonusArr['touchBonus'];
                //判断级别上限
//                $teamBonus = $this->declarationLevelCap($teamBonus, $userId, $userBaseInfo['DEC_LV']);
//                if( $teamBonus <= 0 ) continue;
//
//                $teamBonus = $this->bonusTotalLimit($teamBonus, $userId, $userBaseInfo['REC_NUM'], $userBaseInfo['ZC_AMOUNT']);
//                if( $teamBonus <= 0 ) continue;

                //扣除相应的复消积分和管理费
//                $deductData = $this->deduct($userId, $teamBonus);

                // 把对碰后的奖金存入缓存中
                CalcCache::bonus($userId, $periodNum, 'BONUS_QY_FX', $teamBonus);
                unset($perfData, $pervSurplusPerf, $perfArr, $oriPerfArr, $touchPerfArr, $userBaseInfo, $decLevelConfig, $touchBonusArr, $userId, $nowDecLevelConfig, $teamBonus, $deductData);
            }
            unset($allData, $insertBonusData);
            return $this->calcBonusFxQY($offset + $this->_limit);
        }
        unset($allData);
        return true;
    }

    /**
     * 计算共享奖之前的操作
     * @param int $offset
     * @return bool
     */
    public function calcBonusGXBefore(int $offset = 0) {
        //获取所有激活会员
        $allData = CalcCache::getActiveUsers($this->_periodNum, $offset, $this->_limit);
        if ($allData) {
            echo sprintf("时间:[%s]共享奖之前，当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()) , $offset);
            foreach ($allData as $userId) {
                //判断$userId 能否得共享奖

                // //判断 是否本期小市场（安置关系）新增980pv 能否得奖
                // if ( !$this->checkSmallMarketPerf($userId) ) {
                //     unset($userId);
                //     continue;
                // }

                // 20220407 小市场980判断->改成判断此期用户是否有原报单团队奖金
                if ( !$this->checkHasOriBonusQyBd($userId) ) {
                    unset($userId);
                    continue;
                }

                //获取当前会员所有的推荐上级， 并查看是否有首单团队奖
                $validDeep = 0;
                $this->loopRelationParentDo($userId, function ($parent) use ($userId, &$validDeep) {
                    //判断$parent是否有首单团队奖
                    $parentBonus = CalcCache::bonus($parent['PARENT_UID'], $this->_periodNum);
                    if( $parentBonus['ORI_BONUS_QY_BD'] > 0 ) {
                        $validDeep += 1;

                        //记录得奖缓存
                        CalcCache::addShareBonusOneRelation($userId, $parent['PARENT_UID'], $this->_periodNum, $validDeep);
                    }
                    unset($parent, $parentBonus);

                    if ( $validDeep >= 2 ) {
                        return self::LOOP_FINISH;
                    }
                });

                unset($userId, $validDeep);
            }
            unset($allData);
            return $this->calcBonusGXBefore($offset + $this->_limit);
        }

        unset($allData);
        return true;
    }

    /**
     * 共享奖
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBonusGX(int $offset = 0) {
        // 从缓存获取分页有的会员信息
        $allData = CalcCache::getHasIncomeUsers($this->_periodNum, $offset, $this->_gxLimit);
        if ($allData) {
            echo sprintf("时间:[%s]共享奖，当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()) , $offset);
            $insertBonusData = [];
            // 获取线上找几层和是否开启找几层的限制
            $configsGx = Config::find()->where(
                'CONFIG_NAME="gxNoPvFindLimitSwitch" OR CONFIG_NAME="gxNoPvFindLimitTimes"'
            )->orderBy('SORT ASC')->indexBy('CONFIG_NAME')->asArray()->all();
            $openFindLimit = isset($configsGx['gxNoPvFindLimitSwitch']) ? $configsGx['gxNoPvFindLimitSwitch']['VALUE'] : 1; // 是否开放了 得奖人不满足980就找一个满足980的人来得这个奖 的最大向上循环次数
            $findLimitTimes = isset($configsGx['gxNoPvFindLimitTimes']) ? $configsGx['gxNoPvFindLimitTimes']['VALUE'] : 5 ; // 开放的限制层数
            $shareOutTimes = Config::find()
            ->where(
                'CONFIG_NAME="shareOutTimes"'
            )
            ->indexBy('CONFIG_NAME')
            ->asArray()
            ->all();// 获取向上找五次超过次数限制
            $shareOutTimes = isset($shareOutTimes['shareOutTimes']) ? $shareOutTimes['shareOutTimes']['VALUE'] : 5;
            foreach ($allData as $userId) {
                $bonusUserData = [];
                $bonusPercentOne = $this->_sysConfig['shareRecPercent']['VALUE'] / 100;
                $bonusPercentTwo = $this->_sysConfig['sharePercent']['VALUE'] / 100;

                // 从缓存中获取会员的收入信息
                $incomeBonus = CalcCache::bonus($userId, $this->_periodNum);
                $lastTwoIncome = $incomeBonus['ORI_BONUS_QY_BD'] ?? 0;
                $shareBonusOne = $lastTwoIncome * $bonusPercentOne;
                unset($lastTwoIncome);
                //找到上2代 新增个人+推荐团队业绩 加权平均分配 这个奖
                if( $shareBonusOne > 0) {
                    $bonusOneData = $this->gxLastTwoBonusData($userId, 1, $shareBonusOne);
                    $bonusTwoData = $this->gxLastTwoBonusData($userId, 2, $shareBonusOne);
                    $bonusUserData = array_merge($bonusUserData, $bonusOneData);
                    $bonusUserData = array_merge($bonusUserData, $bonusTwoData);
                    unset($bonusOneData, $bonusTwoData);
                }

                $nextFiveIncome = $incomeBonus['ORI_BONUS_QY_BD'] ?? 0;
                $shareBonusTwo = $nextFiveIncome * $bonusPercentTwo;
                unset($nextFiveIncome);

                //找到下5代(安置网) 紧缩 相对偶数层2、4、6、8、10层
                if( $shareBonusTwo > 0 ) {
                    $validDeep = 1;
                    $periodNum = $this->_periodNum;
                    $this->loopNetworkParentDo($userId, function ($parent) use ($shareOutTimes, $periodNum, $userId, $shareBonusTwo, &$validDeep, &$bonusUserData) {
                        if ( $validDeep % 2 === 0 ) {
                            $shareTimes = CalcCache::gxShareTimes($userId, $periodNum);
                            // 增加判断,是否分共享奖奖金次数超过了五次,如果超过五次则不进行循环了
                            if ($shareTimes > $shareOutTimes) {
                                return self::LOOP_FINISH;
                            }
                            $bonusUserData[] = [
                                'bonusUid' => $parent['PARENT_UID'],
                                'bonus' => $shareBonusTwo,
                                'validMinPv' => true,
                            ];
                        }
                        //判断$parent是否有首单团队奖
                        $parentBonus = CalcCache::bonus($parent['PARENT_UID'], $this->_periodNum);
                        if( $parentBonus['ORI_BONUS_QY_BD'] > 0 ) {//有效层
                            $validDeep += 1;
                        }

                        unset($parent, $parentBonus);

                        if ( $validDeep >= 11 ) {
                            return self::LOOP_FINISH;
                        }
                    });

                    unset($validDeep);
                }
                if ( !$bonusUserData ) continue;

                $userBaseInfo = CalcCache::getUserInfo($userId, $this->_periodNum);
                $userEmpLevel = $userBaseInfo['EMP_LV'];
                foreach ($bonusUserData as $bonusUserDataEvery) {
                    $bonusUserId = $bonusUserDataEvery['bonusUid'];
                    //判断 是否本期小市场（安置关系）新增980pv 能否得奖->20220407改成判断得奖人此期是否有报单团队奖金
                    // if ( $bonusUserDataEvery['validMinPv'] && !$this->checkSmallMarketPerf($bonusUserId) ) { 20220407
                    if ( $bonusUserDataEvery['validMinPv'] && !$this->checkHasOriBonusQyBd($bonusUserId) ) {
//                        unset($bonusUserDataEvery, $bonusUserId); 
//                        continue;
                        //得奖人不满足980就找一个满足980的人来得这个奖
                        // 20220407改成判断得奖人此期是否有报单团队奖金,如果没有则找一个此期有报单团队奖金得人
                        $bonusUserId = $this->getMinBdPvNetworkParent($bonusUserId, $openFindLimit, $findLimitTimes);
                        if ( !$bonusUserId ) {
                            unset($bonusUserDataEvery, $bonusUserId);
                            continue;
                        }
                    }

                    $bonus = Tool::formatPrice($bonusUserDataEvery['bonus']);
                    $bonusUserBaseInfo = CalcCache::getUserInfo($bonusUserId, $this->_periodNum);
                    //总金额限制
                    $bonus = $this->bonusTotalLimit($bonus, $bonusUserId, $bonusUserBaseInfo['REC_NUM'], $bonusUserBaseInfo['ZC_AMOUNT']);
                    if( $bonus <= 0 ) continue;

                    
                    // //扣除相应的复消积分和管理费
                    // 共享奖调整,周共享奖信息,不扣除管理费和复消费积分
                    // $deductData = $this->deduct($bonusUserId, $bonus);
                    // CalcCache::bonus($bonusUserId, $this->_periodNum, 'BONUS_GX', $bonus, $deductData,'',true);
                    CalcCache::bonus($bonusUserId, $this->_periodNum, 'BONUS_GX', $bonus);
                    CalcCache::addHasMonthBonusUsers($bonusUserId, $this->_periodNum);

                    //共享奖流水 rm1820 月总扣除复消积分和管理费,流水中不扣除.
                    $insertBonusData[] = [
                        'ID' => SnowFake::instance()->generateId(),
                        'USER_ID' => $bonusUserId,
                        'LAST_DEC_LV' => $bonusUserBaseInfo['DEC_LV'],
                        'LAST_EMP_LV' => $bonusUserBaseInfo['EMP_LV'],
                        'LAST_STATUS' => $bonusUserBaseInfo['STATUS'],
                        'FROM_USER_ID' => $userId,
                        'LAST_FROM_DEC_LV' => $userBaseInfo['DEC_LV'],
                        'LAST_FROM_EMP_LV' => $userEmpLevel,
                        'LAST_FROM_STATUS' => $userBaseInfo['STATUS'],
                        // 'AMOUNT' => 0,
                        'ORI_BONUS' => $bonus,
                        // 'RECONSUME_POINTS' => 0,
                        // 'MANAGE_TAX' => 0,
                        'PERIOD_NUM' => $this->_periodNum,
                        'CALC_YEAR' => $this->_calcYear,
                        'CALC_MONTH' => $this->_calcYearMonth,
                        'P_CALC_MONTH' => Date::ociToDate($this->_calcYearMonth, Date::OCI_TIME_FORMAT_SHORT_MONTH),
                        'CREATED_AT' => Date::nowTime(),
                        'LOGS' => json_encode([
                            'sharePercent' => $bonusPercentOne,
                            'incomeBonus' => $incomeBonus,
                            'recNum' => $userBaseInfo['REC_NUM'],
                            'decAmount' => $userBaseInfo['ZC_AMOUNT'],
                        ]),
                    ];

                    unset($bonusUserDataEvery, $bonusUserId, $bonus, $bonusUserBaseInfo);
                }
                unset($userId, $bonusUserData, $userBaseInfo, $userEmpLevel, $bonusPercentOne, $bonusPercentTwo, $incomeBonus, $sharePerson);
//                echo ('内存使用：' . (round(memory_get_usage() / 1024 / 1024, 3)) . 'MB' . PHP_EOL);
            }
            if($insertBonusData) CalcBonusGX::batchInsert($insertBonusData);
            unset($allData, $insertBonusData);
            return $this->calcBonusGX($offset + $this->_gxLimit);
        }
        unset($allData);
        return true;
    }

    // 执行蓝星管理奖金的存储过程
    public function calcBsProcedure() {
        if( !$this->_isCalcMonth ) {
            // 不是结算月,则不进行计算
            return false;
        }
        $result = \Yii::$app->db->createCommand("CALL CalcBlue(:periodNum)") 
                      ->bindValue(':periodNum' , $this->_periodNum )
                      ->execute();
                      
        return $result;
    }

    /**
     * 记录任务进度
     * @param $taskId
     * @param $taskName
     * @param $period
     * @return int
     * @throws \yii\db\Exception
     */
    public function calcTask($taskId, $taskName, $period) {
        // 写任务进度
        return \Yii::$app->db->createCommand("CALL CalcRecord(:taskId, :taskName, :period, :time)")
            ->bindValues([':taskId' => $taskId, ':taskName' => $taskName, ':period' => $period, ':time' => date('Y-m-d H:i:s')])
            ->execute();
    }

    /**
     * 清除数据
     * @param $periodNum
     * @return int
     * @throws \yii\db\Exception
     */
    public function calcClean($periodNum)
    {
        // 任务进度
        $this->calcTask(1, '清除数据', $periodNum);
        // 蓝星奖初始化
        return \Yii::$app->db->createCommand("CALL CalcClean(:periodNum)")
            ->bindValue(':periodNum' , $this->_periodNum )
            ->execute();
    }

    /**
     * 蓝星奖初始化
     * @throws \yii\db\Exception
     */
    public function calcBsInitProcedure($periodNum, $calcMonth, $calcYear) {
        // 任务进度
        $this->calcTask(2, '初始化', $periodNum);
        // 蓝星奖初始化
        return \Yii::$app->db->createCommand("CALL CalcInit(:periodNum, :calcMonth, :calcYear)")
            ->bindValues([':periodNum' => $periodNum, ':calcMonth' => $calcMonth, ':calcYear' => $calcYear])
            ->execute();
    }

    /**
     * 报单业绩上推
     * @param $periodNum
     * @param $maxLayer
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBsPushPerf($periodNum, $maxLayer) {
        // 任务进度
        $this->calcTask(3, '报单业绩上推', $periodNum);
        for ($i = $maxLayer; $i > 0; $i--) {
            // 查询本层会员
            $calcLayers = BsBonus103Calc::findAllAsArray('CALC_PERIOD_ID=:CALC_PERIOD_ID AND LAYER=:LAYER AND PV_ZC>0', [':CALC_PERIOD_ID' => $periodNum, ':LAYER' => $i]);
            foreach ($calcLayers as $data) {
                // 会员报单业绩上推
                BsBonus103Calc::updateAll(
                    ['PV_UP_ZC' => new Expression('PV_UP_ZC+' . $data['PV_ZC'])],
                    'USER_ID=:USER_ID AND CALC_PERIOD_ID=:CALC_PERIOD_ID',
                    [':USER_ID' => $data['INTRODUCER_ID'], ':CALC_PERIOD_ID' => $data['CALC_PERIOD_ID']]);
            }
        }

        return true;
    }

    /**
     * 业绩汇总
     * @param $periodNum
     * @return int
     * @throws \yii\db\Exception
     */
    public function calcBsSummaryPerf($periodNum) {
        // 任务进度
        $this->calcTask(4, '业绩汇总', $periodNum);
        return BsBonus103Calc::updateAll(['GPV10' => new Expression('PV_UP_ZC+PV_FX')], 'CALC_PERIOD_ID=:CALC_PERIOD_ID', [':CALC_PERIOD_ID' => $periodNum]);
    }

    /**
     * 第一次紧缩网络、连带达标、赋星级
     * @param $periodNum
     * @param $maxLayer
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBsNetworkAusterity($periodNum, $maxLayer): bool
    {
        // 任务进度
        $this->calcTask(5, '第一次紧缩网络&连带达标&赋星', $periodNum);
        // 一星达标业绩
        $achievePv = Cache::getEmpLevelConfig()['E121497617216708615']['ACHIEVE_PV'];

        for ($i = $maxLayer; $i >= 0; $i--) {
            if ($i > 0) {
                // 需要清空业绩的会员
                $unQualified = [];
                // 查询本层会员
                $calcLayers = BsBonus103Calc::findAllAsArray('CALC_PERIOD_ID=:CALC_PERIOD_ID AND LAYER=:LAYER AND GPV10 > 0', [':CALC_PERIOD_ID' => $periodNum, ':LAYER' => $i]);

                foreach ($calcLayers as $data) {
                    LoggerTool::debug(['qualified', $data['USER_ID'], $data['LAYER'], $data['GPV10']]);
                    $t1 = microtime(true);
                    // 业绩达标
                    if ($data['GPV10'] >= $achievePv) {
                        // 标记自身业绩达标、赋星级、汇总业绩
                        BsBonus103Calc::updateAll(
                            ['QUALIFIED' => self::QUALIFIED_SELF, 'USER_TYPE10' => 10],
                            'USER_ID=:USER_ID AND CALC_PERIOD_ID=:CALC_PERIOD_ID',
                            [':USER_ID' => $data['USER_ID'], ':CALC_PERIOD_ID' => $data['CALC_PERIOD_ID']]);

                        // 所有上级
                        $introducerList = $this->getIntroducerList($data['USER_ID'], $data['CALC_PERIOD_ID']);
                        LoggerTool::debug([$data['USER_ID'], $introducerList]);
                        if ($introducerList) {
                            $introducerList = implode(',', $introducerList);
                            // 连带达标
                            BsBonus103Calc::updateAll(
                                ['QUALIFIED' => self::QUALIFIED_CASCADE],
                                'USER_ID IN (:USER_ID) AND CALC_PERIOD_ID=:CALC_PERIOD_ID',
                                [':USER_ID' => $introducerList, ':CALC_PERIOD_ID' => $data['CALC_PERIOD_ID']]);
                        }
                    } else if ($data['QUALIFIED'] == self::QUALIFIED_NONE) {
                        // 未达标会员，且未被连带达标,业绩上推给上级
                        BsBonus103Calc::updateAll(
                            ['GPV10' => new Expression('GPV10+' . $data['GPV10'])],
                            'USER_ID=:INTRODUCER_ID AND CALC_PERIOD_ID=:CALC_PERIOD_ID',
                            [':INTRODUCER_ID' => $data['INTRODUCER_ID'], ':CALC_PERIOD_ID' => $data['CALC_PERIOD_ID']]);
                        // 清空自身业绩
                        $unQualified[] = $data['USER_ID'];
                    }

                    $t2 = microtime(true);
                    LoggerTool::notice(['calcBsNetworkAusterityForEach', $i, round($t2 - $t1, 3)]);
                }

                if ($unQualified) {
                    // 清空自身业绩
                    BsBonus103Calc::updateAll(
                        ['GPV10' => 0],
                        'USER_ID IN (:USER_ID) AND CALC_PERIOD_ID=:CALC_PERIOD_ID',
                        [':USER_ID' => implode(',', $unQualified), ':CALC_PERIOD_ID' => $periodNum]);
                }
            } else {
                // 查询本层会员
                $calcLayers = BsBonus103Calc::findAllAsArray('CALC_PERIOD_ID=:CALC_PERIOD_ID AND LAYER=:LAYER AND GPV10 > 0', [':CALC_PERIOD_ID' => $periodNum, ':LAYER' => $i]);

                foreach ($calcLayers as $data) {
                    LoggerTool::debug(['qualified', $data['USER_ID'], $data['LAYER'], $data['GPV10']]);
                    $t1 = microtime(true);
                    // 自身业绩达标
                    if ($data['GPV10'] >= $achievePv) {
                        // 标记自身业绩达标
                        BsBonus103Calc::updateAll(
                            ['QUALIFIED' => self::QUALIFIED_SELF, 'USER_TYPE10' => 10, 'GPV10' => new Expression('GPV10+' . $data['GPV10'])],
                            'USER_ID=:USER_ID AND CALC_PERIOD_ID=:CALC_PERIOD_ID',
                            [':USER_ID' => $data['USER_ID'], ':CALC_PERIOD_ID' => $data['CALC_PERIOD_ID']]);
                    } else if ($data['QUALIFIED'] == self::QUALIFIED_NONE) {
                        // 未达标会员，且未被连带达标，清空自身业绩
                        BsBonus103Calc::updateAll(
                            ['GPV10' => 0],
                            'USER_ID IN (:USER_ID) AND CALC_PERIOD_ID=:CALC_PERIOD_ID',
                            [':USER_ID' => $data['USER_ID'], ':CALC_PERIOD_ID' => $periodNum]);
                    }

                    $t2 = microtime(true);
                    LoggerTool::notice(['calcBsNetworkAusterityForEach', $i, round($t2 - $t1, 3)]);
                }
            }
        }

        return true;
    }

    /**
     * 计算奖金
     * @param $periodNum
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBsBonus($periodNum): bool
    {
        // 任务进度
        $this->calcTask(4, '计算一星奖金', $periodNum);
        // 一星奖金比例
        $percent = Cache::getEmpLevelConfig()['E121497617216708615']['BS_PERCENT'] / 100;
        // 推荐网最大层级，用于循环
        $maxLayer = BsBonus103Calc::getMaxLayer($periodNum);

        $rows = [];
        for ($i = $maxLayer; $i >= 0; $i--) {
            // 查询本层会员
            $calcLayers = BsBonus103Calc::find()->where('CALC_PERIOD_ID=:CALC_PERIOD_ID AND LAYER=:LAYER AND QUALIFIED>:QUALIFIED', [':CALC_PERIOD_ID' => $periodNum, ':LAYER' => $i, ':QUALIFIED' => 0])->all();

            foreach ($calcLayers as $data) {
                $rows[] = [
                    $data['USER_ID'],
                    $data['INTRODUCER_ID'],
                    $data['USER_TYPE10'],
                    $data['GPV10'] * $percent,
                    $data['GPV10'],
                    $percent,
                    $data['CALC_PERIOD_ID'],
                ];
            }
        }

        if ($rows) {
            // 奖金入库
            $columns = ['USER_ID', 'INTRODUCER_ID', 'LAST_EMP_LV', 'LAST_EMP_LV', 'ORI_BONUS', 'PV', 'RATE', 'PERIOD_NUM'];
            Yii::$app->db->createCommand()->batchInsert(CalcBonusBsDefaultBonus::tableName(), $columns, $rows)->execute();
        }

        return true;
    }

    /**
     * 获取上级
     * @param $userId
     * @param $period
     * @param array $introducerList
     * @return array
     */
    public function getIntroducerList($userId, $period, array $introducerList = []): array
    {
        $introducer = BsBonus103Calc::getIntroducer($userId, $period);
        // 如果会员的上级已经被标记达标，则不再向上查找
        if ($introducer['QUALIFIED'] == self::QUALIFIED_NONE) {
            $introducerList[] = $introducer['INTRODUCER_ID'];
            $this->getIntroducerList($introducer['INTRODUCER_ID'], $period, $introducerList);
        }
        return $introducerList;
    }

    /**
     * 蓝星管理奖金未拆分
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBonusBsGL(int $offset = 0) {
        if( !$this->_isCalcMonth ) {
            // 不是结算月,则不进行计算
            return false;
        }
        // 从缓存获取分页有收入的会员信息
        $allData = CalcBonusBS::findUseDbCalc()
            ->where('PERIOD_NUM=:PERIOD_NUM', [':PERIOD_NUM' => $this->_periodNum])
            ->groupBy('USER_ID')
            ->offset($offset)
            ->limit($this->_limit)
            ->asArray()
            ->all();
        if ($allData) {
            foreach ($allData as $user) {
                // 添加到有奖励信息的数据中
                CalcCache::addHasBonusUsers($user['USER_ID'], $this->_periodNum);
                $fxStatus = $this->_isMonthPerfLimit($user['USER_ID']);
                if ($fxStatus) {
                    //扣除相应的复消积分和管理费
                    $deductData = $this->deduct($user['USER_ID'], $user['ORI_BONUS']);
                    // 把对碰后的奖金存入缓存中
                    CalcCache::bonus($user['USER_ID'], $this->_periodNum, 'BONUS_BS', $user['ORI_BONUS'], $deductData);
                    //CalcCache::bonus($user['USER_ID'], $this->_periodNum, 'BONUS_BS', $user['ORI_BONUS']);
                    $realBonusBs = $deductData['surplus']; // 扣除管理费和复消积分后的实发蓝星奖金
                    $manageTax = $deductData['manageTax']; // 管理费
                    $point = $deductData['reConsumePoints'];// 复消积分
                } else {
                    // 如果未满足月消费,则不扣除管理费和复消积分了
                    CalcCache::bonus($user['USER_ID'], $this->_periodNum, 'BONUS_BS', $user['ORI_BONUS']);
                    $realBonusBs = $user['ORI_BONUS'];
                    $manageTax = 0; // 管理费
                    $point = 0;// 复消积分
                }

                // 更新蓝星奖金存储过程的实发金额数据
                CalcBonusBS::updateAll(['AMOUNT' => $realBonusBs, 'MANAGE_TAX' => $manageTax, 'RECONSUME_POINTS' => $point],
                    'USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM',
                    [':USER_ID' => $user['USER_ID'], ':PERIOD_NUM' => $this->_periodNum]);
            }
            return $this->calcBonusBsGL($offset + $this->_limit);
        }
        unset($allData);
        return true;
    }

    /**
     * 蓝星管理奖金
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBonusBsGLCF(int $offset = 0) {
        if( !$this->_isCalcMonth ) {
            // 不是结算月,则不进行计算
            return false;
        }
        // 从缓存获取分页有收入的会员信息
        $allData = CalcBonusBS::findUseDbCalc()
            ->where('PERIOD_NUM=:PERIOD_NUM', [':PERIOD_NUM' => $this->_periodNum])
            ->groupBy('USER_ID')
            ->offset($offset)
            ->limit($this->_limit)
            ->asArray()
            ->all();
        if ($allData) {
            foreach ($allData as $user) {
                $fxStatus = $this->_isMonthPerfLimit($user['USER_ID']);
                if ($fxStatus) {
                    //扣除相应的复消积分和管理费
                    $deductData = $this->deduct($user['USER_ID'], $user['ORI_BONUS_MNT']);
                    // 把对碰后的奖金存入缓存中
                    CalcCache::bonus($user['USER_ID'], $this->_periodNum, 'BONUS_MNT', $user['ORI_BONUS_MNT']);
                    $realBonusBs = $deductData['surplus']; // 扣除管理费和复消积分后的实发蓝星奖金
                    $manageTax = $deductData['manageTax']; // 管理费
                    $point = $deductData['reConsumePoints'];// 复消积分
                } else {
                    // 如果未满足月消费,则不扣除管理费和复消积分了
                    CalcCache::bonus($user['USER_ID'], $this->_periodNum, 'BONUS_MNT', $user['ORI_BONUS_MNT']);
                    $realBonusBs = $user['ORI_BONUS_MNT'];
                    $manageTax = 0; // 管理费
                    $point = 0;// 复消积分
                }
                

                // 更新蓝星奖金存储过程的实发金额数据
                CalcBonusBS::updateAll(['AMOUNT_MNT' => $realBonusBs, 'MANAGE_TAX_MNT' => $manageTax, 'MNT_RECONSUME_POINTS' => $point],
                'USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM', 
                [':USER_ID' => $user['USER_ID'], ':PERIOD_NUM' => $this->_periodNum]);
            }
            return $this->calcBonusBsGLCF($offset + $this->_limit);
        }
        unset($allData);
        return true;
    }

    /**
     * 蓝星业绩奖金
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBonusBsYJCF(int $offset = 0) {
        if( !$this->_isCalcMonth ) {
            // 不是结算月,则不进行计算
            return false;
        }
        // 从缓存获取分页有收入的会员信息
        $allData = CalcBonusBS::findUseDbCalc()
            ->where('PERIOD_NUM=:PERIOD_NUM', [':PERIOD_NUM' => $this->_periodNum])
            ->groupBy('USER_ID')
            ->offset($offset)
            ->limit($this->_limit)
            ->asArray()
            ->all();
        if ($allData) {
            foreach ($allData as $user) {
                $fxStatus = $this->_isMonthPerfLimit($user['USER_ID']);
                if ($fxStatus) {
                    //扣除相应的复消积分和管理费
                    $deductData = $this->deduct($user['USER_ID'], $user['ORI_BONUS_ABBR']);
                    // 把对碰后的奖金存入缓存中
                    CalcCache::bonus($user['USER_ID'], $this->_periodNum, 'BONUS_ABBR', $user['ORI_BONUS_ABBR']);
                    $realBonusBs = $deductData['surplus']; // 扣除管理费和复消积分后的实发蓝星奖金
                    $manageTax = $deductData['manageTax']; // 管理费
                    $point = $deductData['reConsumePoints'];// 复消积分
                } else {
                    // 如果未满足月消费,则不扣除管理费和复消积分了
                    CalcCache::bonus($user['USER_ID'], $this->_periodNum, 'BONUS_ABBR', $user['ORI_BONUS_ABBR']);
                    $realBonusBs = $user['ORI_BONUS_ABBR'];
                    $manageTax = 0; // 管理费
                    $point = 0;// 复消积分
                }


                // 更新蓝星奖金存储过程的实发金额数据
                CalcBonusBS::updateAll(['AMOUNT_ABBR' => $realBonusBs, 'MANAGE_TAX_ABBR' => $manageTax, 'ABBR_RECONSUME_POINTS' => $point],
                    'USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM',
                    [':USER_ID' => $user['USER_ID'], ':PERIOD_NUM' => $this->_periodNum]);
            }
            return $this->calcBonusBsYJCF($offset + $this->_limit);
        }
        unset($allData);
        return true;
    }



    /**
     * 报单管理奖
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBonusBdGL(int $offset = 0) {
        // 从缓存获取分页有收入的会员信息
        $allData = CalcCache::getHasIncomeUsers($this->_periodNum, $offset, $this->_limit);
        if ($allData) {
            $insertBonusData = [];
            foreach ($allData as $userId) {
                $bonusUserData = [];
                //会员信息
                $validDeep = 1;
                $this->loopRelationParentDo($userId, function ($parent) use ($userId, &$validDeep, &$bonusUserData) {
                    //判断$parent是否有首单团队奖
                    $bonusUserId = $parent['PARENT_UID'];
                    $bonusUserBaseInfo = CalcCache::getUserInfo($bonusUserId, $this->_periodNum);

                    $nowDecLevelConfig = $this->_decLevelConfig[$bonusUserBaseInfo['DEC_LV']];
                    $recNum = $bonusUserBaseInfo['REC_NUM'];
                    if( $recNum <= 0 ) {
                        $maxOddLayer = 0;
                    }else if( $recNum == 1 ) {
                        $maxOddLayer = $nowDecLevelConfig['GL_ODD_DEEP_ONE'] ?? 0;
                    }else if( $recNum == 2 ) {
                        $maxOddLayer = $nowDecLevelConfig['GL_ODD_DEEP_TWO'] ?? 0;
                    }else {
                        $maxOddLayer = $nowDecLevelConfig['GL_ODD_DEEP_THREE'] ?? 0;
                    }

                    if ( $validDeep < 2 * $maxOddLayer && $validDeep % 2 === 1 ) {//奇数层
                        $bonusUserData[] =  [
                            'bonusUid' => $parent['PARENT_UID'],
                            'validDeep' => $validDeep
                        ];
                    }

                    $parentBonus = CalcCache::bonus($bonusUserId, $this->_periodNum);
                    if( $parentBonus['ORI_BONUS_QY_BD'] > 0 ) {//有效层
                        $validDeep += 1;
                    }

                    unset($parent, $parentBonus, $bonusUserId, $bonusUserBaseInfo, $nowDecLevelConfig, $recNum, $maxOddLayer);

                    //超过代数上限则结束
                    if ( $validDeep >= 18 ) {
                        return self::LOOP_FINISH;
                    }
                });

                //发奖
                $userBaseInfo = CalcCache::getUserInfo($userId, $this->_periodNum);
                $userBonus = CalcCache::bonus($userId, $this->_periodNum);
                foreach ($bonusUserData as $everyData) {
                    $bonusUserId = $everyData['bonusUid'];
                    //判断 是否本期小市场（安置关系）新增980pv 能否得奖
                    if ( !$this->checkSmallMarketPerf($bonusUserId) ) {
//                        unset($bonusUserId);
//                        continue;
                        //得奖人不满足980就找一个满足980的人来得这个奖
                        $bonusUserId = $this->getMinBdPvRelationParent($bonusUserId);
                        if ( !$bonusUserId ) {
                            unset($bonusUserId);
                            continue;
                        }
                    }

                    $parentOddPercentValue = floor($everyData['validDeep']/6);
                    $parentOddPercentName = sprintf('parentOddPercent_%s', $parentOddPercentValue);
                    if( !isset($this->_sysConfig[$parentOddPercentName]) ) continue;
                    $bonusPercent = $this->_sysConfig[$parentOddPercentName]['VALUE'];

                    $manageBonus = Tool::formatPrice($userBonus['ORI_BONUS_QY_BD'] * $bonusPercent / 100);
                    if ($manageBonus <= 0) continue;

                    //总金额限制
                    $bonusUserBaseInfo = CalcCache::getUserInfo($bonusUserId, $this->_periodNum);
                    $recNum = $bonusUserBaseInfo['REC_NUM'];
                    $manageBonus = $this->bonusTotalLimit($manageBonus, $bonusUserId, $recNum, $bonusUserBaseInfo['ZC_AMOUNT']);
                    if( $manageBonus <= 0 ) continue;

                    //扣除相应的复消积分和管理费
                    $deductData = $this->deduct($bonusUserId, $manageBonus);

                    CalcCache::bonus($bonusUserId, $this->_periodNum, 'BONUS_GL', $manageBonus, $deductData, CalcCache::FROM_MEANS_BD);
                    CalcCache::addHasMonthBonusUsers($bonusUserId, $this->_periodNum);

                    //管理奖流水
                    $insertBonusData[] = [
                        'ID' => SnowFake::instance()->generateId(),
                        'USER_ID' => $bonusUserId,
                        'LAST_DEC_LV' => $bonusUserBaseInfo['DEC_LV'],
                        'LAST_EMP_LV' => $bonusUserBaseInfo['EMP_LV'],
                        'LAST_STATUS' => $bonusUserBaseInfo['STATUS'],
                        'FROM_USER_ID' => $userId,
                        'LAST_FROM_DEC_LV' => $userBaseInfo['DEC_LV'],
                        'LAST_FROM_EMP_LV' => $userBaseInfo['EMP_LV'],
                        'LAST_FROM_STATUS' => $userBaseInfo['STATUS'],
                        'AMOUNT' => $deductData['surplus'],
                        'ORI_BONUS' => $manageBonus,
                        'RECONSUME_POINTS' => $deductData['reConsumePoints'],
                        'MANAGE_TAX' => $deductData['manageTax'],
                        'PERIOD_NUM' => $this->_periodNum,
                        'CALC_YEAR' => $this->_calcYear,
                        'CALC_MONTH' => $this->_calcYearMonth,
                        'P_CALC_MONTH' => Date::ociToDate($this->_calcYearMonth, Date::OCI_TIME_FORMAT_SHORT_MONTH),
                        'CREATED_AT' => Date::nowTime(),
                        'LOGS' => json_encode([
                            $parentOddPercentName => $this->_sysConfig[$parentOddPercentName]['VALUE'],
                            'validDeep' => $everyData['validDeep'],
                            'recNum' => $bonusUserBaseInfo['REC_NUM'],
                            'decAmount' => $bonusUserBaseInfo['ZC_AMOUNT'],
                            'fromUserId' => $userId,
                            'decLevel' => $bonusUserBaseInfo['DEC_LV'],
                        ]),
                    ];

                    unset($everyData, $bonusUserId, $parentOddPercentValue, $parentOddPercentName, $bonusPercent, $manageBonus, $deductData);
                }

                unset($userId, $validDeep, $userBaseInfo, $userBonus, $bonusUserData);
            }
            if($insertBonusData) CalcBonusGL::batchInsert($insertBonusData);
            unset($allData, $insertBonusData);
            return $this->calcBonusBdGL($offset + $this->_limit);
        }
        unset($allData);
        return true;
    }

    /**
     * 复消管理奖
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBonusFxGL(int $offset = 0) {
        $periodNum = $this->_periodNum;
        // 从缓存获取分页有收入的会员信息
        $allData = CalcCache::getHasIncomeUsers($this->_periodNum, $offset, $this->_limit);
        if ($allData) {
            $insertBonusData = [];
            foreach ($allData as $userId) {
                //会员信息
                $decLevelConfig = $this->_decLevelConfig;
                $netWorkParents = Cache::getAllRelationParents($userId);
                $userBaseInfo = CalcCache::getUserInfo($userId, $this->_periodNum);
                $userEmpLevel = $userBaseInfo['EMP_LV'];
                foreach ($netWorkParents as $netWorkParent) {
                    //自已距顶端的深度减去父级距顶端的深度
                    $diffLayer = $netWorkParent['TOP_DEEP'] - $netWorkParent['PARENT_DEEP'];
                    if( $diffLayer <= 0) continue;

                    //@todo 超过最大代数就跳出本次循环

                    //偶数代跳过
                    if( $diffLayer % 2 == 0 ) continue;

                    // 获取会员的报单级别
                    $bonusUserId = $netWorkParent['PARENT_UID'];
                    if( !$bonusUserId ) continue;
                    $bonusUserBaseInfo = CalcCache::getUserInfo($bonusUserId, $this->_periodNum);

                    $nowDecLevelConfig = $decLevelConfig[$bonusUserBaseInfo['DEC_LV']];
                    if( !$nowDecLevelConfig ) continue;
                    //推荐人数
                    $recNum = $bonusUserBaseInfo['REC_NUM'];
                    if( $recNum <= 0 ) continue;
                    if( $recNum == 1 ) {
                        $maxOddLayer = $nowDecLevelConfig['GL_ODD_DEEP_ONE'];
                    }else if( $recNum == 2 ) {
                        $maxOddLayer = $nowDecLevelConfig['GL_ODD_DEEP_TWO'];
                    }else {
                        $maxOddLayer = $nowDecLevelConfig['GL_ODD_DEEP_THREE'];
                    }

                    //超过代数上限也跳过
                    if( $diffLayer >= 2 * $maxOddLayer ) continue;

//                    $everyLayer = floor(2 * $nowDecLevelConfig['GL_ODD_DEEP_THREE'] / $nowDecLevelConfig['SORT']);
                    //多少代
//                    $theLayer = $diffLayer % $everyLayer;
//                    $theLayerLevel = floor($diffLayer/$everyLayer);
                    $theLayerLevel = floor($diffLayer/6);
                    $parentOddPercentName = sprintf('parentOddPercent_%s', $theLayerLevel);
                    if( !isset($this->_sysConfig[$parentOddPercentName]) ) continue;
                    $bonusPercent = $this->_sysConfig[$parentOddPercentName]['VALUE'];

                    // 从缓存中获取会员的收入信息
                    $incomeBonus = CalcCache::bonus($userId, $periodNum);
                    $parentOddIncomeFromName = sprintf('parentOddIncomeFrom_%s', $theLayerLevel);
                    $parentOddIncomeFrom = explode(',', $this->_sysConfig[$parentOddIncomeFromName]['VALUE']);
                    $parentOddIncome = 0;
                    foreach ($parentOddIncomeFrom as $incomeType) {
                        if( $incomeType === 'XF' ) {
                            $incomeTypeName = sprintf('ORI_BONUS_%s', $incomeType);
                        }else {
                            $incomeTypeName = sprintf('ORI_BONUS_%s_FX', $incomeType);
                        }
                        $incomeTypeValue = $incomeBonus[$incomeTypeName] ?? 0;
                        $parentOddIncome += $incomeTypeValue;
                        unset($incomeType, $incomeTypeName, $incomeTypeValue);
                    }
                    unset($parentOddIncomeFrom);
                    $manageBonus = Tool::formatPrice($parentOddIncome * $bonusPercent / 100);
                    if ($manageBonus <= 0) continue;

                    //总金额限制
                    $manageBonus = $this->bonusTotalLimit($manageBonus, $bonusUserId, $recNum, $bonusUserBaseInfo['ZC_AMOUNT']);
                    if( $manageBonus <= 0 ) continue;

                    //扣除相应的复消积分和管理费
                    $deductData = $this->deduct($bonusUserId, $manageBonus);

                    CalcCache::bonus($bonusUserId, $periodNum, 'BONUS_GL', $manageBonus, $deductData, CalcCache::FROM_MEANS_FX);

                    //管理奖流水
                    $insertBonusData[] = [
                        'ID' => SnowFake::instance()->generateId(),
                        'USER_ID' => $bonusUserId,
                        'LAST_DEC_LV' => $bonusUserBaseInfo['DEC_LV'],
                        'LAST_EMP_LV' => $bonusUserBaseInfo['EMP_LV'],
                        'LAST_STATUS' => $bonusUserBaseInfo['STATUS'],
                        'FROM_USER_ID' => $userId,
                        'LAST_FROM_DEC_LV' => $userBaseInfo['DEC_LV'],
                        'LAST_FROM_EMP_LV' => $userEmpLevel,
                        'LAST_FROM_STATUS' => $userBaseInfo['STATUS'],
                        'AMOUNT' => $deductData['surplus'],
                        'ORI_BONUS' => $manageBonus,
                        'RECONSUME_POINTS' => $deductData['reConsumePoints'],
                        'MANAGE_TAX' => $deductData['manageTax'],
                        'PERIOD_NUM' => $this->_periodNum,
                        'CALC_YEAR' => $this->_calcYear,
                        'CALC_MONTH' => $this->_calcYearMonth,
                        'P_CALC_MONTH' => Date::ociToDate($this->_calcYearMonth, Date::OCI_TIME_FORMAT_SHORT_MONTH),
                        'CREATED_AT' => Date::nowTime(),
                        'LOGS' => json_encode([
                            $parentOddPercentName => $this->_sysConfig[$parentOddPercentName]['VALUE'],
                            $parentOddIncomeFromName => $this->_sysConfig[$parentOddIncomeFromName]['VALUE'],
                            'decLevelConfig' => $nowDecLevelConfig,
                            'recNum' => $bonusUserBaseInfo['REC_NUM'],
                            'decAmount' => $bonusUserBaseInfo['ZC_AMOUNT'],
                            'fromUserId' => $userId,
                            'decLevel' => $bonusUserBaseInfo['DEC_LV'],
                        ]),
                    ];

                    unset($netWorkParent, $diffLayer, $bonusUserId, $bonusUserBaseInfo, $bonusPercent, $nowDecLevelConfig, $manageBonus, $incomeBonus, $maxOddLayer, $theLayerLevel, $recNum, $parentOddPercentName, $parentOddIncomeFromName, $deductData);

                }

                unset($userId, $userBaseInfo, $userEmpLevel, $netWorkParents, $decLevelConfig);

            }
            CalcBonusGL::batchInsert($insertBonusData);
            unset($allData, $insertBonusData);
            return $this->calcBonusFxGL($offset + $this->_limit);
        }
        unset($allData);
        return true;
    }


    /**
     * 结算荣衔奖第一步
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     * @throws \Exception
     */
    public function calcBonusYCStepOne(int $offset = 0) {
        // 月结，如果不是月结点，则直接退出
        if (!$this->_isCalcMonth) {
            return true;
        }
        echo sprintf("时间:[%s]荣衔奖第【1】步，当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()) , $offset);
        //从缓存获取分页有本月业绩的会员
        $allData = CalcCache::getHasMonthPerfUsers($this->_periodNum, $offset, $this->_limit);
        if ($allData) {
            $maxLevelId = EmployLevel::SHX_ZJ_LEVEL_ID;
            $maxLevel = $this->_empLevelConfig[$maxLevelId];
            $maxLevelPercent = $maxLevel['RX_PERCENT'] ?? 0;
            unset($maxLevelId, $maxLevel);

            foreach ($allData as $userId) {
//                echo sprintf("时间:[%s]荣衔奖，当前用户ID为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()) , $userId);
                $nowMonthPerf = CalcCache::nowMonthPerf($userId, $this->_periodNum);
                $monthPvPcs = $nowMonthPerf['PV_PCS'] ?? 0;
                if( $monthPvPcs <= 0 ) continue;

                $userBaseInfo = CalcCache::getUserInfo($userId, $this->_periodNum);

                //个人业绩的奖金
                $empLevelId = $userBaseInfo['EMP_LV'];
                $empLevel = $this->_empLevelConfig[$empLevelId];
                $rxPercent = $empLevel['RX_PERCENT'] ?? 0;
                $empBonus = $monthPvPcs * $rxPercent / 100;
                if( $empBonus > 0 ) {
                    //给本人添加聘级比例
                    CalcCache::ycMaxBonusPercent($userId, $this->_periodNum, $rxPercent);
                    //记录奖金和奖金来源到缓存 并实现在缓存中奖金累加
                    CalcCache::saveYCBonusList($userId, $this->_periodNum, $empBonus, ['fromUid'=>$userId, 'fromPvPcs'=>$monthPvPcs]);
                    CalcCache::addHasYcBonusUsers($userId, $this->_periodNum);
                    //达到最大的比例其它人就得不到了
                    if( $rxPercent >= $maxLevelPercent ) continue;
                }
                unset($empLevelId, $empLevel, $rxPercent, $empBonus);

                //获取所有的父级
                $this->loopRelationParentDo($userId, function ($parent) use ($userId, $monthPvPcs, $maxLevelPercent) {
                    $bonusUserId = $parent['PARENT_UID'];
                    //计算级别之后更新过userInfo的缓存,缓存中级别发生了变化
                    $bonusUserInfo = CalcCache::getUserInfo($bonusUserId, $this->_periodNum);
                    $parentEmpLevelId = $bonusUserInfo['EMP_LV'];
                    $parentEmpLevel = $this->_empLevelConfig[$parentEmpLevelId];
                    $parentRxPercent = $parentEmpLevel['RX_PERCENT'] ?? 0;
                    $cacheMaxPercent = CalcCache::ycMaxBonusPercent($userId, $this->_periodNum);
                    $diffPercent = $parentRxPercent - $cacheMaxPercent;
                    if( $diffPercent <= 0 ) return self::LOOP_CONTINUE;

                    $empBonus = $monthPvPcs * $diffPercent / 100;
                    if( $empBonus <= 0  ) return self::LOOP_CONTINUE;

                    //给本人添加聘级比例
                    CalcCache::ycMaxBonusPercent($userId, $this->_periodNum, $parentRxPercent);
                    //记录奖金和奖金来源到缓存 并实现在缓存中奖金累加
                    CalcCache::saveYCBonusList($bonusUserId, $this->_periodNum, $empBonus, ['fromUid'=>$userId, 'fromPvPcs'=>$monthPvPcs]);
                    CalcCache::addHasYcBonusUsers($bonusUserId, $this->_periodNum);

                    unset($cacheMaxPercent, $diffPercent, $parentEmpLevel, $bonusUserId, $bonusUserInfo, $parentEmpLevelId, $empBonus);

                    //达到最大的比例就不在向上找了
                    if( $parentRxPercent >= $maxLevelPercent ) return self::LOOP_FINISH;
                    unset($parentRxPercent);

                });

                unset($nowMonthPerf, $monthPvPcs);
            }

            unset($allData, $maxLevelPercent);
            $this->calcBonusYCStepOne($offset + $this->_limit);
        }
        unset($periodNum, $allData);
        return true;
    }


    /**
     * 结算荣衔奖第二步
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBonusYCStepTwo(int $offset = 0) {
        // 月结，如果不是月结点，则直接退出
        if (!$this->_isCalcMonth) {
            return true;
        }
        echo sprintf("时间:[%s]荣衔奖第【2】步，当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()) , $offset);

        $allData = CalcCache::getHasYcBonusUsers($this->_periodNum, $offset, $this->_limit);
        if ($allData) {
            $insertBonusData = [];
            foreach ($allData as $userId) {
                $monthPerfData = CalcCache::nowMonthPerf($userId, $this->_periodNum);
                $fxPvStatus = $monthPerfData['PV_PCS_FX'] >= $this->_sysConfig['monthPcsPvFxCondition']['VALUE'];
                unset($monthPerfData);
                if( !$fxPvStatus ) continue;
                unset($fxPvStatus);

                $ycBonusData = CalcCache::getYCBonusList($userId, $this->_periodNum);
                if( !$ycBonusData ) continue;
                $empBonus = $ycBonusData['empBonus'] ?? 0;
                if( $empBonus <=0  ) continue;
                //总金额限制
                $userBaseInfo = CalcCache::getUserInfo($userId, $this->_periodNum);
                $empBonus = $this->bonusTotalLimit($empBonus, $userId, $userBaseInfo['REC_NUM'], $userBaseInfo['ZC_AMOUNT']);

                if( $empBonus <= 0 ) continue;

                //扣除相应的复消积分和管理费
                $empBonus = Tool::formatPrice($empBonus);
                $deductData = $this->deduct($userId, $empBonus);

                CalcCache::bonus($userId, $this->_periodNum, 'BONUS_YC', $empBonus, $deductData);

                $empLevelId = $userBaseInfo['EMP_LV'];
                $insertBonusData[] = [
                    'ID' => SnowFake::instance()->generateId(),
                    'USER_ID' => $userId,
                    'LAST_DEC_LV' => $userBaseInfo['DEC_LV'],
                    'LAST_EMP_LV' => $userBaseInfo['EMP_LV'],
                    'LAST_STATUS' => $userBaseInfo['STATUS'],
                    'FROM_USER_ID' => $userId,
                    'LAST_FROM_DEC_LV' => $userBaseInfo['DEC_LV'],
                    'LAST_FROM_EMP_LV' => $userBaseInfo['EMP_LV'],
                    'LAST_FROM_STATUS' => $userBaseInfo['STATUS'],
                    'DEEP' => 0,
                    'AMOUNT' => $deductData['surplus'],
                    'ORI_BONUS' => $empBonus,
                    'RECONSUME_POINTS' => $deductData['reConsumePoints'],
                    'MANAGE_TAX' => $deductData['manageTax'],
                    'BONUS_TYPE' => CalcBonusYC::BONUS_TYPE_YC,
                    'PERIOD_NUM' => $this->_periodNum,
                    'CALC_MONTH' => $this->_calcYearMonth,
                    'P_CALC_MONTH' => Date::ociToDate($this->_calcYearMonth, Date::OCI_TIME_FORMAT_SHORT_MONTH),
                    'CREATED_AT' => Date::nowTime(),
                    'LOGS' => json_encode([
                        'empLevelId' => $empLevelId,
                    ])
//                    'FROM_DATA' => json_encode($ycBonusData['fromData']),
                ];

                unset($ycBonusData, $deductData);

                //如果是总监以上拿平级2代
                $empLevel = $this->_empLevelConfig[$empLevelId];
                $userEmpLevelSort = $empLevel['SORT'] ?? EmployLevel::EMP_LEVEL_SORT['NO_LEVEL'];
//                if( $userEmpLevelSort >= EmployLevel::EMP_LEVEL_SORT['JX_ZR_LEVEL'] ) {}
                $newInsertBonusData = $this->calcParentYC($userId, $userBaseInfo, $userEmpLevelSort, $empBonus);
                $insertBonusData = array_merge($insertBonusData, $newInsertBonusData);
                unset($newInsertBonusData);

                unset($userId, $userBaseInfo, $empLevel, $empLevelId, $userEmpLevelSort, $empBonus);

            }

            CalcBonusYC::batchInsert($insertBonusData);
            unset($insertBonusData, $allData);
            $this->calcBonusYCStepTwo($offset + $this->_limit);
        }

        unset($allData);
        return true;
    }

    /**
     * VIP奖
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBonusVIP(int $offset = 0)
    {
        // 月结，如果不是月结点，则直接退出
        if (!$this->_isCalcMonth) {
            return true;
        }
        echo sprintf("时间:[%s]VIP奖，当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()), $offset);
        //从缓存获取分页有本月业绩的会员
        $allData = CalcCache::getHasMonthPerfUsers($this->_periodNum, $offset, $this->_limit);
        if ($allData) {
            $insertBonusData = [];
            foreach ($allData as $userId) {
                $userBaseInfo = CalcCache::getUserInfo($userId, $this->_periodNum);
                //条件一：级别必须为VIP
                $isVip = false;
                if( $userBaseInfo['DEC_LV'] === DeclarationLevel::VIP_LEVEL_ID ) {
                    $isVip= true;
                }
                if( $this->_sysConfig['vipBonusGoldDecLevel']['VALUE'] && $userBaseInfo['DEC_LV'] === DeclarationLevel::JIN_ZUAN_LEVEL_ID ) {
                    $isVip = true;
                }
                if ( !$isVip ) {
                    unset($userId, $userBaseInfo);
                    continue;
                }

                //判断其它两个条件，满足则计算月团队奖，不满足则留下大区剩余业绩，清除其它区的剩余业绩
                //获取本月的业绩
                $monthPerfData = CalcCache::nowMonthPerf($userId, $this->_periodNum);
                // 从缓存中获取会员的上期结余业绩信息
                $pervSurplusPerf = CalcCache::surplusPerf($userId, $this->_periodNum);
                // 本期 + 上期结余
                $perfArr = [
                    'VIP_SURPLUS_1L_ZC' => $monthPerfData['VIP_PV_1L_ZC'] + $pervSurplusPerf['VIP_SURPLUS_1L_ZC'],
                    'VIP_SURPLUS_2L_ZC' => $monthPerfData['VIP_PV_2L_ZC'] + $pervSurplusPerf['VIP_SURPLUS_2L_ZC'],
                    'VIP_SURPLUS_3L_ZC' => $monthPerfData['VIP_PV_3L_ZC'] + $pervSurplusPerf['VIP_SURPLUS_3L_ZC'],
                    'VIP_SURPLUS_4L_ZC' => $monthPerfData['VIP_PV_4L_ZC'] + $pervSurplusPerf['VIP_SURPLUS_4L_ZC'],
                    'VIP_SURPLUS_5L_ZC' => $monthPerfData['VIP_PV_5L_ZC'] + $pervSurplusPerf['VIP_SURPLUS_5L_ZC'],
                ];
                //条件二：本月复消金额达到300元
                //fix-2021-03-26修改 条件二：本月个人复消PV300
                $fxPvStatus = $monthPerfData['PV_PCS_FX'] >= $this->_sysConfig['monthPcsPvFxCondition']['VALUE'];
                unset($monthPerfData, $pervSurplusPerf);
                if( !$fxPvStatus ) {
                    $this->dealWithMaxPerf($userId, $perfArr);
                    unset($userBaseInfo, $userId, $perfArr, $fxPvStatus);
                    continue;
                }
                //条件三：其它市场业绩
                $isCanOtherDepartPerf = $this->_isCanVipBonusOtherAreaPerf($perfArr);
                if ( !$isCanOtherDepartPerf ) {
                    $this->dealWithMaxPerf($userId, $perfArr);
                    unset($userBaseInfo, $userId, $perfArr, $isCanOtherDepartPerf);
                    continue;
                }

                $oriPerfArr = [
                    'perfArr' => $perfArr,
                    'touchBonus' => 0,
                ];
                // 对碰
                $touchBonusArr = $this->touchPerf($oriPerfArr, $perfArr, $this->_sysConfig['vipBonusPercent']['VALUE']/100);
                unset($oriPerfArr, $perfArr);
                $touchPerfArr = [];
                foreach ($touchBonusArr['perfArr'] as $keyR => $perfR) {
                    $touchPerfArr[$keyR] = $perfR;
                }
                // 对碰完成后把结余的业绩存入本期业绩缓存中
//                CalcCache::nowPeriodPerf($userId, $this->_periodNum, $touchPerfArr);
                //更新数据库
                PerfMonth::updateAll($touchPerfArr, 'USER_ID=:USER_ID AND CALC_MONTH=:CALC_MONTH', [
                    'USER_ID' => $userId,
                    'CALC_MONTH' => $this->_calcYearMonth,
                ]);
                if ($touchBonusArr['touchBonus'] <= 0) continue;

                $vipBonus = $touchBonusArr['touchBonus'];

                //判断级别上限
                $vipBonus = $this->declarationLevelCap($vipBonus, $userId, $userBaseInfo['DEC_LV']);
                if( $vipBonus <= 0 ) continue;

                $vipBonus = $this->bonusTotalLimit($vipBonus, $userId, $userBaseInfo['REC_NUM'], $userBaseInfo['ZC_AMOUNT']);

                if( $vipBonus <= 0 ) continue;

                //扣除相应的复消积分和管理费
                $deductData = $this->deduct($userId, $vipBonus);

                CalcCache::bonus($userId, $this->_periodNum, 'BONUS_VIP', $vipBonus, $deductData);

                $insertBonusData[] = [
                    'ID' => SnowFake::instance()->generateId(),
                    'USER_ID' => $userId,
                    'LAST_DEC_LV' => $userBaseInfo['DEC_LV'],
                    'LAST_EMP_LV' => $userBaseInfo['EMP_LV'],
                    'LAST_STATUS' => $userBaseInfo['STATUS'],
                    'FROM_USER_ID' => $userId,
                    'LAST_FROM_DEC_LV' => $userBaseInfo['DEC_LV'],
                    'LAST_FROM_EMP_LV' => $userBaseInfo['EMP_LV'],
                    'LAST_FROM_STATUS' => $userBaseInfo['STATUS'],
                    'AMOUNT' => $deductData['surplus'],
                    'ORI_BONUS' => $vipBonus,
                    'RECONSUME_POINTS' => $deductData['reConsumePoints'],
                    'MANAGE_TAX' => $deductData['manageTax'],
                    'PERIOD_NUM' => $this->_periodNum,
                    'CALC_YEAR' => $this->_calcYear,
                    'CALC_MONTH' => $this->_calcYearMonth,
                    'P_CALC_MONTH' => Date::ociToDate($this->_calcYearMonth, Date::OCI_TIME_FORMAT_SHORT_MONTH),
                    'CREATED_AT' => Date::nowTime(),
                    'LOGS' => json_encode($touchPerfArr)
                ];

                unset($userBaseInfo, $userId, $perfArr, $fxAmountStatus, $isCanOtherDepartPerf, $touchBonusArr, $touchPerfArr, $vipBonus, $deductData);
            }

            if( $insertBonusData ) CalcBonusVIP::batchInsert($insertBonusData);
            unset($insertBonusData, $allData);
            $this->calcBonusVIP($offset + $this->_limit);
        }

        unset($allData);
        return true;
    }

    /**
     * 见习达标奖
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function calcBonusStandard(int $offset = 0)
    {
        // 月结，如果不是月结点，则直接退出
        if (!$this->_isCalcMonth) {
            return true;
        }
        echo sprintf("时间:[%s]见习达标奖，当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()), $offset);
        //从缓存获取分页有本月业绩的会员
        $allData = CalcCache::getHasStandardMonthPerfUsers($this->_periodNum, $offset, $this->_limit);
        if ($allData) {
            $minSaleCondition = $this->_jxStandardMinSaleCondition();
            $insertBonusData = [];
            foreach ($allData as $userId) {
                $userBaseInfo = CalcCache::getUserInfo($userId, $this->_periodNum);
                //条件一：聘级必须为见习主任
                if( $userBaseInfo['EMP_LV'] != EmployLevel::JX_ZR_LEVEL_ID ) {
                    unset($userId, $userBaseInfo);
                    continue;
                }

                $standardMonthPerf = CalcCache::nowStandardMonthPerf($userId, $this->_periodNum);
                $totalAmount = $standardMonthPerf['AMOUNT_PCS'] + $standardMonthPerf['AMOUNT_PSS'];
                if( $totalAmount < $minSaleCondition ) {
                    unset($userId, $userBaseInfo, $standardMonthPerf, $totalAmount);
                    continue;
                }

                $standardBonus = $this->_jxStandardAwardAmount($totalAmount);
                if( $standardBonus <= 0 ) {
                    unset($userId, $userBaseInfo, $standardMonthPerf, $totalAmount, $standardBonus);
                    continue;
                }

                CalcCache::standardBonus($userId, $this->_periodNum, $standardBonus);

                $insertBonusData[] = [
                    'ID' => SnowFake::instance()->generateId(),
                    'USER_ID' => $userId,
                    'LAST_DEC_LV' => $userBaseInfo['DEC_LV'],
                    'LAST_EMP_LV' => $userBaseInfo['EMP_LV'],
                    'LAST_STATUS' => $userBaseInfo['STATUS'],
                    'FROM_USER_ID' => $userId,
                    'LAST_FROM_DEC_LV' => $userBaseInfo['DEC_LV'],
                    'LAST_FROM_EMP_LV' => $userBaseInfo['EMP_LV'],
                    'LAST_FROM_STATUS' => $userBaseInfo['STATUS'],
                    'AMOUNT' => $standardBonus,
                    'ORI_BONUS' => $standardBonus,
                    'RECONSUME_POINTS' => 0,
                    'MANAGE_TAX' => 0,
                    'PERIOD_NUM' => $this->_periodNum,
                    'CALC_YEAR' => $this->_calcYear,
                    'CALC_MONTH' => $this->_calcYearMonth,
                    'P_CALC_MONTH' => Date::ociToDate($this->_calcYearMonth, Date::OCI_TIME_FORMAT_SHORT_MONTH),
                    'CREATED_AT' => Date::nowTime(),
                    'LOGS' => json_encode($standardMonthPerf)
                ];

                unset($userId, $userBaseInfo, $standardMonthPerf, $totalAmount);
            }

            if( $insertBonusData ) CalcBonusStandard::batchInsert($insertBonusData);

            unset($insertBonusData, $minSaleCondition, $insertBonusData, $allData);
            $this->calcBonusStandard($offset + $this->_limit);
        }

        unset($allData);
        return true;
    }

    /**
     * === 运算相关的辅助功能开始 ===
     */

    /**
     * 获取上2代的得奖人信息
     * @param $userId
     * @param $validDeep
     * @param $shareBonusOne
     * @return array
     */
    protected function gxLastTwoBonusData($userId, $validDeep, $shareBonusOne) {
        $bonusUserList = CalcCache::getShareBonusOneRelation($userId, $this->_periodNum, $validDeep);
        if( !$bonusUserList ) {
            unset($bonusUserList);
            return [];
        }

        $bonusUserData = [];
        $bonusUserTotalPerf = 0;
        $bonusUserRealList = [];
        foreach ($bonusUserList as $bonusUserId) {
            //查看该用户的个人业绩和团队新增业绩总和
            $nowPeriodData = CalcCache::nowPeriodPerf($bonusUserId, $this->_periodNum);
            //本期新增业绩
            $bonusUserPerf = $nowPeriodData['PV_PCS'] + $nowPeriodData['PV_PSS'];
            if ($bonusUserPerf <= 0) {
                unset($bonusUserId, $nowPeriodData, $bonusUserPerf);
                continue;
            }

            $bonusUserTotalPerf += $bonusUserPerf;
            $bonusUserRealList[] = [
                'bonusUserId' => $bonusUserId,
                'bonusUserPerf' => $bonusUserPerf,
            ];

            unset($bonusUserId, $nowPeriodData, $bonusUserPerf);
        }
        unset($bonusUserList);

        foreach ($bonusUserRealList as $everyData) {
            $bonusUserData[] = [
                'bonusUid' => $everyData['bonusUserId'],
                'bonus' => $shareBonusOne * $everyData['bonusUserPerf'] / $bonusUserTotalPerf,
                'validMinPv' => false

            ];
            
            unset($everyData);
        }

        unset($bonusUserRealList);

        return $bonusUserData;
    }

    /**
     * 获取达标奖的金额
     * @param $amount
     * @return int|mixed
     */
    private function _jxStandardAwardAmount($amount) {
//        $jxStandardConfig = Json::decode($this->_sysConfig['jxStandard']['VALUE']);
//        $awardAmount = 0;
//        foreach ($jxStandardConfig as $everyData) {
//            if( $amount >= $everyData['salesCondition'] ) {
//                $awardAmount = $everyData['awardAmount'];
//            }
//            unset($everyData);
//        }
//
//        return $awardAmount;
        $realTimes = floor($amount/self::JX_STANDARD_BASE_AMOUNT);
        $calcTimes = min($realTimes, self::JX_STANDARD_MAX_TIMES);
        $awardAmount = $calcTimes * self::JX_STANDARD_BASE_AMOUNT * self::JX_STANDARD_BONUS_PERCENT / 100;

        unset($amount, $realTimes, $calcTimes);
        return $awardAmount;
    }

    /**
     * 获取达标奖的最小条件
     * @return int|mixed
     */
    private function _jxStandardMinSaleCondition() {
        return self::JX_STANDARD_BASE_AMOUNT;
    }

    /**
     * 处理只留最大业绩的逻辑
     * @param $userId
     * @param $perfArr
     */
    private function dealWithMaxPerf($userId, $perfArr) {
        $maxPerf = max($perfArr);
        $hitMaxPerf = false;
        foreach ($perfArr as $key=>$everyPerf) {
            if( !$hitMaxPerf && $everyPerf == $maxPerf ) {
                $hitMaxPerf = true;
            }else {
                $perfArr[$key] = 0;
            }

            unset($key, $everyPerf);
        }

        //更新数据库
        PerfMonth::updateAll($perfArr, 'USER_ID=:USER_ID AND CALC_MONTH=:CALC_MONTH', [
            'USER_ID' => $userId,
            'CALC_MONTH' => $this->_calcYearMonth
        ]);

        unset($userId, $maxPerf, $hitMaxPerf, $perfArr);
    }

    /**
     * VIP奖其它市场的报单业绩是否能满足
     * @param $perfArr
     * @return bool
     */
    private function _isCanVipBonusOtherAreaPerf($perfArr) {
        $maxAreaPerf = max($perfArr);
        $totalAreaPerf = array_sum($perfArr);

        $diffAreaPerf = strval($totalAreaPerf - $maxAreaPerf);
        if( $diffAreaPerf >= $this->_sysConfig['vipBonusOtherDepartPvCondition']['VALUE'] ) {
            unset($maxAreaPerf, $totalAreaPerf, $perfArr);
            return true;
        }else {
            unset($maxAreaPerf, $totalAreaPerf, $perfArr);
            return false;
        }
    }

    /**
     * 给父级计算的荣衔奖
     * @param $userId
     * @param $userBaseInfo
     * @param $userEmpLevelSort
     * @param $qyBonus
     * @return array
     */
    public function calcParentYC($userId, $userBaseInfo, $userEmpLevelSort, $qyBonus) {
        if( $userEmpLevelSort <= EmployLevel::EMP_LEVEL_SORT['NO_LEVEL'] ) return [];

        $validDeep = 0;
        $bonusDataList = [];
        $this->loopRelationParentDo($userId, function ($parent) use ($userId, $userEmpLevelSort, &$validDeep, &$bonusDataList) {
            $bonusUserId = $parent['PARENT_UID'];
            $bonusUserInfo = CalcCache::getUserInfo($bonusUserId, $this->_periodNum);
            $bonusUserEmpLevel = $this->_empLevelConfig[$bonusUserInfo['EMP_LV']];
            $bonusUserEmpLevelSort = $bonusUserEmpLevel['SORT'] ?? EmployLevel::EMP_LEVEL_SORT['NO_LEVEL'];
            unset($bonusUserInfo, $bonusUserEmpLevel);

            //必须是有聘级的用户
            if( $bonusUserEmpLevelSort <= EmployLevel::EMP_LEVEL_SORT['NO_LEVEL'] ) return self::LOOP_CONTINUE;

            //超过级别就停止
            if( $bonusUserEmpLevelSort > $userEmpLevelSort) return self::LOOP_FINISH;

            //级别小于就跳过
            if( $bonusUserEmpLevelSort < $userEmpLevelSort ) return self::LOOP_CONTINUE;

            $validDeep++;
            array_push($bonusDataList, [
                'bonusUserId' => $bonusUserId,
                'bonusType' => $validDeep,
            ]);
            if( $validDeep >= 2 ) return self::LOOP_FINISH;

            unset($bonusUserId, $bonusUserEmpLevelSort);
        });

        $insertBonusData = [];
        foreach ($bonusDataList as $bonusUserData) {
            $bonusUserId = $bonusUserData['bonusUserId'];

            $bonusMonthPerfData = CalcCache::nowMonthPerf($bonusUserId, $this->_periodNum);
            $fxPvStatus = $bonusMonthPerfData['PV_PCS_FX'] >= $this->_sysConfig['monthPcsPvFxCondition']['VALUE'];
            unset($bonusMonthPerfData);
            if( !$fxPvStatus ) continue;
            unset($fxPvStatus);

            $bonusUserInfo = CalcCache::getUserInfo($bonusUserId, $this->_periodNum);
            $bonusEmpLevelId = $bonusUserInfo['EMP_LV'];

            $newEmpBonus = Tool::formatPrice($qyBonus * $this->_sysConfig['sameEmpLevelPercent']['VALUE'] / 100);


            //总金额限制
            $newEmpBonus = $this->bonusTotalLimit($newEmpBonus, $bonusUserId, $bonusUserInfo['REC_NUM'], $bonusUserInfo['ZC_AMOUNT']);
            if( $newEmpBonus <= 0 ) continue;

            //扣除相应的复消积分和管理费
            $newEmpBonus = Tool::formatPrice($newEmpBonus);
            $deductData = $this->deduct($bonusUserId, $newEmpBonus);

            CalcCache::bonus($bonusUserId, $this->_periodNum, 'BONUS_YC_EXTRA', $newEmpBonus, $deductData);


            // 把育成津贴追加到育成津贴结算表，以便奖金追溯育成津贴用
            $insertBonusData[] = [
                'ID' => SnowFake::instance()->generateId(),
                'USER_ID' => $bonusUserId,
                'LAST_DEC_LV' => $bonusUserInfo['DEC_LV'],
                'LAST_EMP_LV' => $bonusUserInfo['EMP_LV'],
                'LAST_STATUS' => $bonusUserInfo['STATUS'],
                'FROM_USER_ID' => $userId,
                'LAST_FROM_DEC_LV' => $userBaseInfo['DEC_LV'],
                'LAST_FROM_EMP_LV' => $userBaseInfo['EMP_LV'],
                'LAST_FROM_STATUS' => $userBaseInfo['STATUS'],
                'DEEP' => 1,
                'AMOUNT' => $deductData['surplus'],
                'ORI_BONUS' => $newEmpBonus,
                'RECONSUME_POINTS' => $deductData['reConsumePoints'],
                'MANAGE_TAX' => $deductData['manageTax'],
                'BONUS_TYPE' => $bonusUserData['bonusType'],
                'PERIOD_NUM' => $this->_periodNum,
                'CALC_MONTH' => $this->_calcYearMonth,
                'P_CALC_MONTH' => Date::ociToDate($this->_calcYearMonth, Date::OCI_TIME_FORMAT_SHORT_MONTH),
                'CREATED_AT' => Date::nowTime(),
                'LOGS' => json_encode([
                    'empLevelId' => $bonusEmpLevelId,
                    'qyBonus' => $qyBonus,
                    'sameEmpLevelPercent' => $this->_sysConfig['sameEmpLevelPercent']['VALUE'],
                ]),
            ];

            unset($newEmpBonus, $bonusEmpLevelId, $bonusUserId, $bonusUserInfo, $deductData);
        }

        unset($userId, $userBaseInfo, $userEmpLevelSort, $qyBonus, $bonusDataList);


        return $insertBonusData;
    }

    /**
     * 对碰
     * @param array $oriPerfArr
     * @param array $perfArr
     * @param $percent
     * @param $loopTimes
     * @return array
     */
    public function touchPerf(array $oriPerfArr, array $perfArr, $percent, $loopTimes=1) {
        $resultArr = $oriPerfArr;
        foreach ($perfArr as $keyT => $perfT) {
            if ($perfT <= 0) {
                unset($perfArr[$keyT]);
            }
        }
        if (count($perfArr) >= 2 && $loopTimes < 6) {
            arsort($perfArr, SORT_NUMERIC);
            $onePerf = null;
            $oneKey = null;
            // $touchSurplusAmount = 0;
            $touchAmount = 0;
            // 前两个进行对碰
            foreach ($perfArr as $key => $perf) {
                if ($onePerf === null) {
                    $oneKey = $key;
                    $onePerf = $perf;
                } else {
                    $touchSurplusAmount = $perf - $onePerf;
                    if ($touchSurplusAmount > 0) {
                        unset($perfArr[$oneKey]);
                        $resultArr['perfArr'][$oneKey] = 0;
                        $perfArr[$key] = $touchSurplusAmount;
                        $touchAmount = $onePerf;
                    } elseif ($touchSurplusAmount < 0) {
                        unset($perfArr[$key]);
                        $resultArr['perfArr'][$key] = 0;
                        $perfArr[$oneKey] = abs($touchSurplusAmount);
                        $touchAmount = $perf;
                    } else {
                        unset($perfArr[$oneKey], $perfArr[$key]);
                        $resultArr['perfArr'][$oneKey] = 0;
                        $resultArr['perfArr'][$key] = 0;
                        $touchAmount = $perf;
                    }
                    break;
                }
            }
            /*if ($touchAmount > $nowDecLevelConfig['QY_TOUCH_CAP']) {
                $touchAmount = $nowDecLevelConfig['QY_TOUCH_CAP'];
            }*/
            $touchBonus = Tool::formatPrice($touchAmount * $percent);
//            if ($touchBonus > $nowDecLevelConfig['QY_TOUCH_CAP']) {
//                $resultArr['touchBonus'] += $nowDecLevelConfig['QY_TOUCH_CAP'];
//            } else {
//                $resultArr['touchBonus'] += $touchBonus;
//            }
            $resultArr['touchBonus'] += $touchBonus;

            foreach ($perfArr as $keyR => $perfR) {
                $resultArr['perfArr'][$keyR] = $perfR;
            }
            return $this->touchPerf($resultArr, $perfArr, $percent, $loopTimes+1);

        }
        return $resultArr;
    }

    /**
     * 对碰
     * @param array $oriPerfArr
     * @param array $perfArr
     * @param $decLevel
     * @param $decLevelConfig
     * @param $loopTimes
     * @return array
     */
    public function touchPerfBefore(array $oriPerfArr, array $perfArr, $decLevel, $decLevelConfig, $loopTimes=1) {
        $resultArr = $oriPerfArr;
        foreach ($perfArr as $keyT => $perfT) {
            if ($perfT <= 0) {
                unset($perfArr[$keyT]);
            }
        }
        if (count($perfArr) >= 2 && $loopTimes < 6) {
            $nowDecLevelConfig = $decLevelConfig[$decLevel];
            arsort($perfArr, SORT_NUMERIC);
            $onePerf = null;
            $oneKey = null;
            // $touchSurplusAmount = 0;
            $touchAmount = 0;
            // 前两个进行对碰
            foreach ($perfArr as $key => $perf) {
                if ($onePerf === null) {
                    $oneKey = $key;
                    $onePerf = $perf;
                } else {
                    $touchSurplusAmount = $perf - $onePerf;
                    if ($touchSurplusAmount > 0) {
                        unset($perfArr[$oneKey]);
                        $resultArr['perfArr'][$oneKey] = 0;
                        $perfArr[$key] = $touchSurplusAmount;
                        $touchAmount = $onePerf;
                    } elseif ($touchSurplusAmount < 0) {
                        unset($perfArr[$key]);
                        $resultArr['perfArr'][$key] = 0;
                        $perfArr[$oneKey] = abs($touchSurplusAmount);
                        $touchAmount = $perf;
                    } else {
                        unset($perfArr[$oneKey], $perfArr[$key]);
                        $resultArr['perfArr'][$oneKey] = 0;
                        $resultArr['perfArr'][$key] = 0;
                        $touchAmount = $perf;
                    }
                    break;
                }
            }
            /*if ($touchAmount > $nowDecLevelConfig['QY_TOUCH_CAP']) {
                $touchAmount = $nowDecLevelConfig['QY_TOUCH_CAP'];
            }*/
            $touchBonus = Tool::formatPrice($touchAmount * 2 / 100);
//            if ($touchBonus > $nowDecLevelConfig['QY_TOUCH_CAP']) {
//                $resultArr['touchBonus'] += $nowDecLevelConfig['QY_TOUCH_CAP'];
//            } else {
//                $resultArr['touchBonus'] += $touchBonus;
//            }
            $resultArr['touchBonus'] += $touchBonus;

            foreach ($perfArr as $keyR => $perfR) {
                $resultArr['perfArr'][$keyR] = $perfR;
            }
            return $this->touchPerfBefore($resultArr, $perfArr, $decLevel, $decLevelConfig, $loopTimes+1);

        }
        return $resultArr;
    }

    /**
     * 循环父级并执行回调函数
     * @param $userId
     * @param callable $callbackFunc
     * @param int $offset
     * @return bool
     */
    public function loopNetworkParentDo($userId, callable $callbackFunc, int $offset = 0) {
        $allParents = Cache::getAllNetworkParents($userId);
        $allData = array_slice($allParents, $offset, $this->_limit);
        unset($allParents);
        if ($allData) {
            foreach ($allData as $data) {
                $funcResult = $callbackFunc($data);
                if ($funcResult === self::LOOP_FINISH) {
                    return true;
                } elseif ($funcResult === self::LOOP_CONTINUE) {
                    continue;
                }
                unset($data, $funcResult);
            }
            unset($allData);
            return $this->loopNetworkParentDo($userId, $callbackFunc, $offset + $this->_limit);
        }
        return true;
    }

    /**
     * 循环推荐网络的父级
     * @param $userId
     * @param callable $callbackFunc
     * @param int $offset
     * @return bool
     */
    public function loopRelationParentDo($userId, callable $callbackFunc, int $offset = 0) {
        $allParents = Cache::getAllRelationParents($userId);
        $allData = array_slice($allParents, $offset, $this->_limit);
        unset($allParents);
        if ($allData) {
            foreach ($allData as $data) {
                $funcResult = $callbackFunc($data);
                if ($funcResult === self::LOOP_FINISH) {
                    return true;
                } elseif ($funcResult === self::LOOP_CONTINUE) {
                    continue;
                }
                unset($data, $funcResult);
            }

            unset($allData);
            return $this->loopRelationParentDo($userId, $callbackFunc, $offset + $this->_limit);
        }
        return true;
    }

    /**
     * 共享奖,判断当期此用户,是否有原报单团队奖金
     */
    public function checkHasOriBonusQyBd($userId) {
        //判断$parent是否有首单团队奖
        $bonus = CalcCache::bonus($userId, $this->_periodNum);
        if( isset($bonus['ORI_BONUS_QY_BD']) && $bonus['ORI_BONUS_QY_BD'] > 0 ) {
            return true;
        }

        return false;
    }

    /**
     * 判断除大市场外 其它市场的报单业绩
     * @param $userId
     * @return bool
     * @throws \yii\db\Exception
     */
    public function checkSmallMarketPerf($userId) {
        // 从缓存中获取会员的上期结余业绩信息
        $pervSurplusPerf = CalcCache::surplusPerf($userId, $this->_periodNum);
        //判断出大市场
        $areaNums = [1, 2, 3];
        $maxArea = 0;
        $maxSurplusPerf = 0;
        foreach ($areaNums as $area) {
            $areaKey = sprintf('SURPLUS_%dL', $area);
            if ( isset($pervSurplusPerf[$areaKey]) && $pervSurplusPerf[$areaKey] > $maxSurplusPerf ) {
                $maxArea = $area;
                $maxSurplusPerf = $pervSurplusPerf[$areaKey];
            }

            unset($area, $areaKey);
        }
        unset($pervSurplusPerf, $maxSurplusPerf);


        $otherAreaZcPv = 0;
        $nowPeriodPerf = CalcCache::nowPeriodPerf($userId, $this->_periodNum);
        foreach ($areaNums as $area) {
            if( $maxArea > 0 && $area === $maxArea ) continue;
            $areaKey = sprintf('PV_%dL_ZC', $area);
            if ( isset($nowPeriodPerf[$areaKey]) && $nowPeriodPerf[$areaKey] > 0 ) {
                $otherAreaZcPv += $nowPeriodPerf[$areaKey];
            }

            unset($area, $areaKey);
        }
        unset($nowPeriodPerf, $areaNums, $maxArea);

        return $otherAreaZcPv >= self::MIN_BD_PV;
    }

    /**
     * 获取有最小报单PV的用效父级
     * @param $userId
     * @return string
     */
    public function getMinBdPvRelationParent($userId) {
        $validParentId = '';
        $this->loopRelationParentDo($userId, function ($parent) use(&$validParentId) {
            if ( $this->checkSmallMarketPerf($parent['PARENT_UID']) ) {
                $validParentId = $parent['PARENT_UID'];
                unset($parent);
                return self::LOOP_FINISH;
            }
            unset($parent);
        });

        return$validParentId;
    }

    /**
     * 获取有最小报单PV的用效父级 20220407修改成是否此期此用户有原报单团队奖金
     * @param $userId
     * @return string
     */
    public function getMinBdPvNetworkParent($userId, $openFindLimit = 1, $findLimitTimes = 5) {
        $validParentId = '';
        $validDeep = 1;
        $this->loopNetworkParentDo($userId, function ($parent) use(&$validParentId,&$validDeep,$openFindLimit,$findLimitTimes) {
            if ( $this->checkHasOriBonusQyBd($parent['PARENT_UID']) ) {
                $validParentId = $parent['PARENT_UID'];
                unset($parent);
                return self::LOOP_FINISH;
            }
            // 只找5层
            if ( $openFindLimit && $validDeep >= $findLimitTimes ) {
                unset($parent);
                return self::LOOP_FINISH;
            }

            $validDeep += 1;
            unset($parent);
        });

        return$validParentId;
    }
    // public function getMinBdPvNetworkParent($userId, $openFindLimit = 1, $findLimitTimes = 5) {
    //     $validParentId = '';
    //     $validDeep = 1;
    //     $this->loopNetworkParentDo($userId, function ($parent) use(&$validParentId,&$validDeep,$openFindLimit,$findLimitTimes) {
    //         if ( $this->checkSmallMarketPerf($parent['PARENT_UID']) ) {
    //             $validParentId = $parent['PARENT_UID'];
    //             unset($parent);
    //             return self::LOOP_FINISH;
    //         }
    //         // 只找5层
    //         if ( $openFindLimit && $validDeep >= $findLimitTimes ) {
    //             unset($parent);
    //             return self::LOOP_FINISH;
    //         }

    //         $validDeep += 1;
    //         unset($parent);
    //     });

    //     return$validParentId;
    // }

    /**
     * 按级别的收入上限
     * 新的需求调整: 改成不按月进行限制,并且去掉vip奖
     * @param $bonus
     * @param $userId
     * @param $declarationLevel
     * @return float
     */
    public function declarationLevelCap($bonus, $userId, $declarationLevel) {
        $decLevelConfig = $this->_decLevelConfig;
        $nowDecLevelConfig = $decLevelConfig[$declarationLevel];
        unset($decLevelConfig);
        $maxGetBonus = $nowDecLevelConfig['INCOME_CAP'];
        if( $bonus <= $maxGetBonus) {
            return $bonus;
        }else {
            return $maxGetBonus;
        }
    }

    // public function declarationLevelCap($bonus, $userId, $declarationLevel) {
    //     $decLevelConfig = $this->_decLevelConfig;
    //     $nowDecLevelConfig = $decLevelConfig[$declarationLevel];
    //     unset($decLevelConfig);

    //     //本月往期奖金 这里执行速度可能慢一些，但需求如此没有办法
    //     $lastData = CalcCache::lastPeriodMonthCalcBonus($userId, $this->_periodNum, $this->_calcMonth);
    //     $lastTotal = $lastData['ORI_BONUS_QY_SUM'] + $lastData['ORI_BONUS_VIP_SUM'];

    //     // 从缓存中获取用户的奖金
    //     $bonusData = CalcCache::bonus($userId, $this->_periodNum);
    //     $thisTotal = $bonusData['ORI_BONUS_QY'] + $bonusData['ORI_BONUS_VIP'];
    //     $maxGetBonus = $nowDecLevelConfig['INCOME_CAP'] * $this->_calcMonthPeriodNumCount - $lastTotal - $thisTotal;
    //     unset($lastData, $lastTotal, $bonusData, $thisTotal);
    //     if( $maxGetBonus <= 0 ) return 0.00;

    //     if( $bonus <= $maxGetBonus) {
    //         return $bonus;
    //     }else {
    //         return $maxGetBonus;
    //     }
    // }

    /**
     * 总奖金限制
     * @param $bonus
     * @param $userId
     * @param $recNum
     * @param $decAmount
     * @return float
     */
    public function bonusTotalLimit($bonus, $userId, $recNum, $decAmount) {
        //@todo 临时不做总奖金限制
        return $bonus;

        if( $recNum >= 3 ) return $bonus;

        $limitAmount = 0;
        switch ($recNum) {
            case 0:
                $limitAmount = $decAmount * $this->_sysConfig['bonusTotalZeroLimit']['VALUE'];
                break;
            case 1:
                $limitAmount = $decAmount * $this->_sysConfig['bonusTotalOneLimit']['VALUE'];
                break;
            case 2:
                $limitAmount = $decAmount * $this->_sysConfig['bonusTotalTwoLimit']['VALUE'];
                break;
            default:
                break;
        }

        // 从缓存中获取用户的奖金
        $lastUserBonus = CalcCache::LastUserBonus($userId, $this->_periodNum);//往期的总金额
        $bonusData = CalcCache::bonus($userId, $this->_periodNum);
        $bonusTotal = $bonusData['BONUS_TOTAL'] + $lastUserBonus['BONUS_TOTAL'];
        unset($lastUserBonus, $userId, $recNum, $decAmount, $bonusData);

        if( $bonusTotal >= $limitAmount ) return 0.00;

        if( $bonusTotal + $bonus <= $limitAmount) {
            return $bonus;
        }else {
            return $limitAmount - $bonusTotal;
        }
    }

    /**
     * 扣除复消积分和管理费
     * @param $userId
     * @param $bonus
     * @return array
     * @throws \yii\db\Exception
     */
    public function deductNoReconsumePoints($userId, $bonus): array
    {
        $manageTax = $bonus * $this->_sysConfig['manageTaxPercent']['VALUE'] / 100;
        $surplus = $bonus - $manageTax;
        return [
            'reConsumePoints' => 0.00,
            'manageTax' => Tool::formatPrice($manageTax),
            'surplus' => Tool::formatPrice($surplus),
        ];
    }


    /**
     * 扣除复消积分和管理费
     * @param $userId
     * @param $bonus
     * @return array
     * @throws \yii\db\Exception
     */
    public function deduct($userId, $bonus, $isGx = false) {
        // 如果是共享奖金,则只有最后一期,才扣除管理费?其他三期不扣除管理费.
        //判断是否达到了本月扣除复消的上限
        $cacheData = CalcCache::monthLastPeriodReconsumePoints($userId, $this->_periodNum, $this->_calcYearMonth);
        $bonusCache = CalcCache::bonus($userId, $this->_periodNum);
        $reConsumePointsTotal = $bonusCache['RECONSUME_POINTS'] + $cacheData['RECONSUME_POINTS_SUM'];
        $reConsumePointsCap = $this->_sysConfig['reConsumePointsMonthCap']['VALUE'];
        unset($cacheData, $bonusCache);

        $reConsumePoints = 0;
        if( $reConsumePointsTotal < $reConsumePointsCap ) {
            $reConsumePoints = $bonus * $this->_sysConfig['reConsumePointsPercent']['VALUE'] / 100;

            // 2022/06/07上限改成10000000   奖金乘以比例           上限1000                     // 当月总复消积分 前三期加当前的
            $reConsumePoints = min($reConsumePoints, $reConsumePointsCap-$reConsumePointsTotal);
        }
        unset($reConsumePointsTotal, $reConsumePointsCap);

        $manageTax = $bonus * $this->_sysConfig['manageTaxPercent']['VALUE'] / 100;
        $surplus = $bonus - $reConsumePoints - $manageTax;
        return [
            'reConsumePoints' => Tool::formatPrice($reConsumePoints),
            'manageTax' => Tool::formatPrice($manageTax),
            'surplus' => Tool::formatPrice($surplus),
        ];
    }

    /**
     * 更新百分比并发送
     * @param $percent
     */
    private function _updatePercent($percent) {
        // 把数据写入数据库中
        Period::updateAll(['CALC_PERCENT' => $percent], 'PERIOD_NUM=:PERIOD_NUM', [':PERIOD_NUM' => $this->_periodNum]);
        \Yii::$app->swooleAsyncTimer->pushAsyncPercentToAdmin($percent, ['MODEL' => 'PERIOD', 'ID' => $this->_periodId, 'FIELD' => 'CALC_PERCENT']);
    }

    /**
     * 把往期有月奖金的会员加到本期有奖会员缓存列表中 
     * @param int $offset
     * @return bool
     */
    public function loopMonthBonusUserFromDbToCache($offset = 0) {
        if (!$this->_isCalcMonth) {
            return true;
        }

        $allData = CalcMonthBonusUser::findUseDbCalc()->where('CALC_MONTH=:CALC_MONTH', [':CALC_MONTH' => $this->_calcYearMonth])->offset($offset)->limit($this->_limit)->asArray()->all();

        if ( $allData ) {
            foreach ($allData as $everyData) {

                CalcCache::addHasBonusUsers($everyData['USER_ID'], $this->_periodNum);

                unset($everyData);

            }

            unset($allData);

            $this->loopMonthBonusUserFromDbToCache($offset + $this->_limit);
        }

        unset($allData);

        return true;
    }

    /**
     * 把缓存中的月奖用户信息存到数据库
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function loopMonthBonusUserToDb($offset = 0) {
        echo sprintf("时间:[%s]月奖会员入库，当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()) , $offset);
        $allData = CalcCache::getHasMonthBonusUsers($this->_periodNum, $offset, $this->_limit);
        if($allData) {
            $insertDataBonusUser = [];
            foreach($allData as $userId){
                $insertDataBonusUser[] = [
                    'ID' => SnowFake::instance()->generateId(),
                    'USER_ID' => $userId,
                    'CALC_MONTH' => $this->_calcYearMonth,
                    'PERIOD_NUM' => $this->_periodNum,
                    'CREATED_AT' => Date::nowTime()
                ];

                unset($userId);
            }

            if( $insertDataBonusUser ) CalcMonthBonusUser::batchInsert($insertDataBonusUser);

            unset($insertDataBonus, $allData);
            return $this->loopMonthBonusUserToDb($offset + $this->_limit);
        }

        unset($allData);
        return true;
    }

    //奖金入库
    /**
     * 循环奖服务奖金会员，并入库
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function loopBonusUsers($offset = 0) {
        echo sprintf("时间:[%s]缓存奖金数据入库，当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()) , $offset);
        // 从缓存列表里面从底层往上倒序获取会员
        $allData = CalcCache::getHasBonusUsers($this->_periodNum, $offset, $this->_limit);

        if($allData){
            $insertDataBonus = [];
            foreach($allData as $userId){
                $tempBonusData = $this->bonusData($userId);
                if(!empty($tempBonusData['result'])){
                    $insertDataBonus[] = $tempBonusData['result'];
                }

                unset($userId, $tempBonusData);
            }
//            echo json_encode($insertDataBonus);
//            exit();
            CalcBonus::batchInsert($insertDataBonus);

            unset($insertDataBonus, $allData);
            return $this->loopBonusUsers($offset + $this->_limit);
        }
        return true;
    }

    // 奖金入库完成,将各个奖金计算流水会员聘级,更新成蓝星奖当时计算的聘级
    public function loopCalcBlueEmpLv($offset = 0) {
        $allData = CalcBonus::findUseDbCalc()
            ->where('PERIOD_NUM=:PERIOD_NUM', [':PERIOD_NUM' => $this->_periodNum])
            ->offset($offset)
            ->limit($this->_limit)
            ->asArray()
            ->all();
        if ($allData) {
            foreach ($allData as $data) {
                // 会员的最新级别，查看上一期，如果无数据，则就是无级别。 上一期到下一期结算月之间，都显示上一期的最新级别。
                if ($this->_isCalcMonth) {
                    // 如果是结算月,则直接获取当期结算结果
                    $blueBsInfo = CalcBonusBS::findOneAsArray(
                        'PERIOD_NUM=:PERIOD_NUM  AND USER_ID=:USER_ID', 
                        [':PERIOD_NUM'=>$this->_periodNum, ':USER_ID'=>$data['USER_ID']]
                    );
                    if (!empty($blueBsInfo)) {
                        $nowBsEmpLv = $blueBsInfo['LEVEL_ID']; // 当前蓝星奖计算(即管理奖) 的等级
                    } else {
                        $nowBsEmpLv = EmployLevel::NO_LEVEL_ID;
                    }
                } else {
                    // 如果不是结算月,则找上一期的结算月数据
                    $forwardMonthPeriod = Period::find()
                    ->where('IS_MONTH=1 AND PERIOD_NUM<:PERIOD_NUM', [':PERIOD_NUM'=>$this->_periodNum])
                    ->orderBy('PERIOD_NUM DESC')
                    ->asArray()
                    ->one();
                    $forwardPeriodNum = $forwardMonthPeriod['PERIOD_NUM'];
                    $blueBsInfo = CalcBonusBS::findOneAsArray(
                        'PERIOD_NUM=:PERIOD_NUM  AND USER_ID=:USER_ID', 
                        [':PERIOD_NUM'=>$forwardPeriodNum, ':USER_ID'=>$data['USER_ID']]
                    );
                    if (!empty($blueBsInfo)) {
                        $nowBsEmpLv = $blueBsInfo['LEVEL_ID']; // 当前蓝星奖计算(即管理奖) 的等级
                    } else {
                        $nowBsEmpLv = EmployLevel::NO_LEVEL_ID;
                    }
                }
                // 修改AR_CALC_BONUS的LAST_EMP_LV聘级,修改奖金流水的聘级AR_FLOW_BONUS表的LAST_EMP_LV
                // 期结算结果
                CalcBonus::updateAll(['LAST_EMP_LV' => $nowBsEmpLv], 'USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM', 
                    [
                        ':USER_ID' => $data['USER_ID'],
                        ':PERIOD_NUM' => $this->_periodNum
                    ]
                );
//                // 奖金流水
//                FlowBonus::updateAll(['LAST_EMP_LV' => $nowBsEmpLv], 'USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM',
//                    [
//                        ':USER_ID' => $data['USER_ID'],
//                        ':PERIOD_NUM' => $this->_periodNum
//                    ]
//                );
                // 共享奖流水
                CalcBonusGX::updateAll(['LAST_EMP_LV' => $nowBsEmpLv], 'USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM', 
                    [
                        ':USER_ID' => $data['USER_ID'],
                        ':PERIOD_NUM' => $this->_periodNum
                    ]
                );
                // 推广奖流水
                CalcBonusTG::updateAll(['LAST_EMP_LV' => $nowBsEmpLv], 'USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM', 
                    [
                        ':USER_ID' => $data['USER_ID'],
                        ':PERIOD_NUM' => $this->_periodNum
                    ]
                );
                // 团队奖流水
                CalcBonusQY::updateAll(['LAST_EMP_LV' => $nowBsEmpLv], 'USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM', 
                    [
                        ':USER_ID' => $data['USER_ID'],
                        ':PERIOD_NUM' => $this->_periodNum
                    ]
                );
                // 服务奖流水
                CalcBonusBD::updateAll(['LAST_EMP_LV' => $nowBsEmpLv], 'USER_ID=:USER_ID AND PERIOD_NUM=:PERIOD_NUM', 
                    [
                        ':USER_ID' => $data['USER_ID'],
                        ':PERIOD_NUM' => $this->_periodNum
                    ]
                );
                // 更新form的聘级
                CalcBonusGX::updateAll(['LAST_FROM_EMP_LV' => $nowBsEmpLv], 'FROM_USER_ID=:FROM_USER_ID AND PERIOD_NUM=:PERIOD_NUM', 
                    [
                        ':FROM_USER_ID' => $data['USER_ID'],
                        ':PERIOD_NUM' => $this->_periodNum
                    ]
                );
                CalcBonusTG::updateAll(['LAST_FROM_EMP_LV' => $nowBsEmpLv], 'FROM_USER_ID=:FROM_USER_ID AND PERIOD_NUM=:PERIOD_NUM', 
                    [
                        ':FROM_USER_ID' => $data['USER_ID'],
                        ':PERIOD_NUM' => $this->_periodNum
                    ]
                );
                CalcBonusBD::updateAll(['LAST_FROM_EMP_LV' => $nowBsEmpLv], 'FROM_USER_ID=:FROM_USER_ID AND PERIOD_NUM=:PERIOD_NUM', 
                    [
                        ':FROM_USER_ID' => $data['USER_ID'],
                        ':PERIOD_NUM' => $this->_periodNum
                    ]
                );
            }
            unset($allData);
            return $this->loopCalcBlueEmpLv($offset + $this->_limit);
        }
        unset($allData);
        return true;
    }

    /**
     * 奖金 
     * @param $userId
     * @return array
     * @throws \yii\db\Exception
     */
    public function bonusData($userId) {
        // 从缓存中获取用户的奖金
        $bonus = CalcCache::bonus($userId, $this->_periodNum);
        $standardBonus = CalcCache::standardBonus($userId, $this->_periodNum);
        $baseInfo = CalcCache::getUserInfo($userId, $this->_periodNum);
        $perfData = CalcCache::nowPeriodPerf($userId, $this->_periodNum);
        $empLv = $baseInfo['EMP_LV'];
        $pervSurplusPerf = CalcCache::surplusPerf($userId, $this->_periodNum);

        //没有共享和管理奖
        $bonusReal = $bonus['BONUS_BD'] + $bonus['BONUS_TG'] + $bonus['BONUS_XF'] + $bonus['BONUS_YJ'] + $bonus['BONUS_QY'] + $bonus['BONUS_YC'] + $bonus['BONUS_YC_EXTRA'] + $bonus['BONUS_VIP'] + $standardBonus;
        $realBonusGx = 0;
        $realBonusGl = 0;
        $realBonusBs = 0; // 蓝星管理奖. BlueStar
        $blueStartAmount = 0;
        $buleStartOriBonus = 0;
        $buleStartManageTax = 0;
        $exchangePoints = 0; // 蓝星奖管理奖. 产生的兑换积分

        $blueBonusGL = 0; //拆分蓝星管理奖，原奖金
        $blueBonusYJ = 0; //拆分蓝星业绩奖，原奖金
        $blueBonusGLSF = 0;//拆分蓝星管理奖，实发
        $blueBonusYJSF = 0;//拆分蓝星业绩奖，实发

        // rm1820 共享奖周算且不计入总原奖金中,所以需要在总原奖金中去掉
        $bonus['BONUS_TOTAL'] = $bonus['BONUS_TOTAL'] - $bonus['ORI_BONUS_GX'];
        $oriGxMonthBonus = 0; // 月共享奖金,结算月之和原总金额
        $monthGxReal = $monthGxManageTax = $monthGxpoint = 0;
        $bonus['BONUS_GX'] = 0; // 以前的周共享奖实发金额,新版本每周不发,不扣除复消积分管理费,所以这里给0
        if( $this->_isCalcMonth ) {
            $fxPvStatus = $this->_isMonthPerfLimit($userId);
            // BONUS_REAL 字段是发到用户的真实奖金
            if ( $fxPvStatus ) {
                // 月节点,获取蓝星管理奖数据
                $userBS = CalcBonusBS::find()
                ->where(
                    'PERIOD_NUM=:PERIOD_NUM AND USER_ID=:USER_ID',
                    [
                        ':PERIOD_NUM' => $this->_periodNum,
                        ':USER_ID' => $userId
                    ]
                )
                ->select('AMOUNT,ORI_BONUS,MANAGE_TAX,LEVEL_ID,PRODUCT_POINT,ORI_BONUS_ABBR,AMOUNT_ABBR,ORI_BONUS_MNT,AMOUNT_MNT')
                ->limit(1)
                ->orderBy('CREATED_AT DESC')
                ->asArray()
                ->all();
                $userBS = is_array($userBS) ? reset($userBS) : [];
                $blueStartAmount = isset($userBS['AMOUNT']) && !empty($userBS['AMOUNT']) ? $userBS['AMOUNT'] : 0; // 奖金
                $buleStartOriBonus = isset($userBS['ORI_BONUS']) && !empty($userBS['ORI_BONUS']) ? $userBS['ORI_BONUS'] : 0; // 原奖金

                $blueBonusGL = isset($userBS['ORI_BONUS_MNT']) && !empty($userBS['ORI_BONUS_MNT']) ? $userBS['ORI_BONUS_MNT'] : 0; // 拆分管理奖原奖金
                $blueBonusYJ = isset($userBS['ORI_BONUS_ABBR']) && !empty($userBS['ORI_BONUS_ABBR']) ? $userBS['ORI_BONUS_ABBR'] : 0; // 拆分业绩奖原奖金

                $blueBonusGLSF = isset($userBS['AMOUNT_MNT']) && !empty($userBS['AMOUNT_MNT']) ? $userBS['AMOUNT_MNT'] : 0; // 拆分管理奖 实发
                $blueBonusYJSF = isset($userBS['AMOUNT_ABBR']) && !empty($userBS['AMOUNT_ABBR']) ? $userBS['AMOUNT_ABBR'] : 0; // 拆分业绩奖 实发

                //$blueStartAmount = $blueBonusGLSF + $blueBonusYJSF; // 总实发，管理奖实发+业绩奖实发
                #rm1820 共享奖金月节点合起来原奖金一起扣除管理费和复消积分
                $monthSumData = CalcBonus::findUseSlaves()
                ->select('SUM(ORI_BONUS_GX) AS BONUS_GX_SUM, SUM(BONUS_GL) AS BONUS_GL_SUM')
                ->where('USER_ID=:USER_ID AND CALC_MONTH=:CALC_MONTH', 
                    [
                        'USER_ID'=>$userId, 
                        'CALC_MONTH'=>$this->_calcYearMonth
                    ]
                )
                ->asArray()
                ->one();
                $bonusGxSum = $monthSumData['BONUS_GX_SUM'] ?? 0;
                $bonusGxSum = $bonus['ORI_BONUS_GX'] + $bonusGxSum;
                $oriGxMonthBonus = $bonusGxSum;
                if ($bonusGxSum > 0) {
                    // 扣除管理费和复消积分
                    //扣除相应的复消积分和管理费
                    $deductData = $this->deduct($userId, $bonusGxSum);
                    $monthGxReal = $deductData['surplus']; // 扣除管理费和复消积分后的实发金额
                    $monthGxManageTax = $deductData['manageTax']; // 管理费
                    $monthGxpoint = $deductData['reConsumePoints'];// 复消积分
                }
                $realBonusGx = $monthGxReal;
                $bonusGlSum = $monthSumData['BONUS_GL_SUM'] ?? 0;
                $bonus['RECONSUME_POINTS'] = $bonus['RECONSUME_POINTS'] + $monthGxpoint;
                $bonus['MANAGE_TAX'] = $bonus['MANAGE_TAX'] + $monthGxManageTax;
                $realBonusGl += $bonusGlSum + $bonus['BONUS_GL'];
                $realBonusBs = $blueStartAmount;
                $bonusReal += $realBonusGx + $realBonusBs + $realBonusGl + $bonus['BONUS_STORE']; // 再加上店服务奖的实发
                $exchangePoints = isset($userBS['PRODUCT_POINT']) && !empty($userBS['PRODUCT_POINT']) ? $userBS['PRODUCT_POINT'] : 0; // 兑换积分
                unset($monthSumData, $bonusGxSum, $bonusGlSum);
                $oriBonusBs = isset($bonus['ORI_BONUS_BS']) && $bonus['ORI_BONUS_BS'] > 0 ? $bonus['ORI_BONUS_BS'] : 0;
                $bonus['BONUS_TOTAL'] = $bonus['BONUS_TOTAL'] - $blueBonusGL - $blueBonusYJ;
                // 共享奖最后一起算,所以总原奖金中,需要加上整个月的数据
                $bonus['BONUS_TOTAL'] = $bonus['BONUS_TOTAL'] + $oriGxMonthBonus;
                $empLv = $userBS['LEVEL_ID'] ?? $empLv;
            } else {
                // 蓝星奖原奖金在扣管理费的时候被加入到了BONUS_TOTAL,需要再减去原奖金
                $oriBonusBs = isset($bonus['ORI_BONUS_BS']) && $bonus['ORI_BONUS_BS'] > 0 ? $bonus['ORI_BONUS_BS'] : 0;
                // 如果未满足,则复消积分,应该不能发放
                $oriBonusBsYJCF = isset($bonus['ORI_BONUS_ABBR']) && $bonus['ORI_BONUS_ABBR'] > 0 ? $bonus['ORI_BONUS_ABBR'] : 0;
                $oriBonusBsGLCF = isset($bonus['ORI_BONUS_MNT']) && $bonus['ORI_BONUS_MNT'] > 0 ? $bonus['ORI_BONUS_MNT'] : 0;
                $bonus['BONUS_TOTAL'] = $bonus['BONUS_TOTAL'] - $oriBonusBs - $oriBonusBsYJCF - $oriBonusBsGLCF;
                $empLv = EmployLevel::getDefaultLevelId();
            }
        }
        
        $result = [
            'USER_ID' => $userId,
            'LAST_USER_NAME' => $baseInfo['USER_NAME'],
            'LAST_REAL_NAME' => $baseInfo['REAL_NAME'],
            'LAST_DEC_LV' => $baseInfo['DEC_LV'],
            'LAST_EMP_LV' => $empLv,
            'LAST_STATUS' => $baseInfo['STATUS'],
            'LAST_MOBILE' => $baseInfo['MOBILE'],
            'LAST_PERIOD_AT' => $baseInfo['PERIOD_NUM'],
            'LAST_CREATED_AT' => $baseInfo['CREATED_AT'],
            'LAST_SUB_COM_ID' => $baseInfo['SUB_COM_ID'],
            'LAST_PROVINCE' => $baseInfo['PROVINCE'],
            'LAST_CITY' => $baseInfo['CITY'],
            'LAST_COUNTY' => $baseInfo['COUNTY'],
            'LAST_SYSTEM_ID' => $baseInfo['SYSTEM_ID'] ? $baseInfo['SYSTEM_ID'] : '',
            'LAST_IS_DIRECT_SELLER' => $baseInfo['IS_DIRECT_SELLER'],
            'LAST_REC_USER_NAME' => $baseInfo['REC_USER_NAME'],
            'LAST_REC_REAL_NAME' => $baseInfo['REC_REAL_NAME'],
            'LAST_CON_USER_NAME' => $baseInfo['CON_USER_NAME'],
            'LAST_CON_REAL_NAME' => $baseInfo['CON_REAL_NAME'],
            'EXCHANGE_POINTS' => $exchangePoints, // 兑换积分
//            'LAST_LOCATION' => $baseInfo['LOCATION'] ? $baseInfo['LOCATION'] : 1,
            //@todo
            'LAST_LOCATION' => 1,
            'BONUS_BD' => $bonus['BONUS_BD'],
            'BONUS_TG' => $bonus['BONUS_TG'],
            'BONUS_XF' => $bonus['BONUS_XF'],
            'BONUS_YJ' => $bonus['BONUS_YJ'],
            'BONUS_GX' => $bonus['BONUS_GX'],
            'BONUS_GL' => $bonus['BONUS_GL'],
            'BONUS_QY' => $bonus['BONUS_QY'],
            'BONUS_YC' => $bonus['BONUS_YC'] + $bonus['BONUS_YC_EXTRA'],
            'BONUS_VIP' => $bonus['BONUS_VIP'],
            'RECONSUME_POINTS' => $bonus['RECONSUME_POINTS'],
            'MANAGE_TAX' => $bonus['MANAGE_TAX'],
            'BONUS_INCOME'=>$bonus['INCOME_TOTAL'],
            'BONUS_REAL'=>  $bonusReal,
            'BONUS_TOTAL'=>$bonus['BONUS_TOTAL'],
            'ORI_BONUS_BD' => $bonus['ORI_BONUS_BD'],
            'ORI_BONUS_TG' => $bonus['ORI_BONUS_TG'],
            'ORI_BONUS_XF' => $bonus['ORI_BONUS_XF'],
            'ORI_BONUS_YJ' => $bonus['ORI_BONUS_YJ'],
            'ORI_BONUS_YJ_BD' => $bonus['ORI_BONUS_YJ_BD'],
            'ORI_BONUS_YJ_FX' => $bonus['ORI_BONUS_YJ_FX'],
            'ORI_BONUS_GX' => $bonus['ORI_BONUS_GX'],
            'ORI_MONTH_GX_BONUS' => $oriGxMonthBonus,
            'GX_MANAGE_TAX' => $monthGxManageTax, //月共享奖管理费
            'GX_RECONSUME_POINTS' => $monthGxpoint, //月共享奖复消积分
            'REAL_BONUS_GX' => $realBonusGx,
            'ORI_BONUS_GL' => $bonus['ORI_BONUS_GL'],
            'REAL_BONUS_GL' => $realBonusGl,
            'BONUS_BS' => $realBonusBs, // 新的管理奖金,即蓝星管理奖
            'ORI_BONUS_BS' => $buleStartOriBonus, // 蓝星管理奖金原奖金,即包含管理费
            'REAL_BONUS_BS' => $realBonusBs, // 实发蓝星管理奖金
            'ORI_BONUS_GL_BD' => $bonus['ORI_BONUS_GL_BD'],
            'ORI_BONUS_GL_FX' => $bonus['ORI_BONUS_GL_FX'],
            'ORI_BONUS_QY' => $bonus['ORI_BONUS_QY'],
            'ORI_BONUS_QY_BD' => $bonus['ORI_BONUS_QY_BD'],
            'ORI_BONUS_QY_FX' => $bonus['ORI_BONUS_QY_FX'],
            'ORI_BONUS_YC' => $bonus['ORI_BONUS_YC'] + $bonus['ORI_BONUS_YC_EXTRA'],
            'ORI_BONUS_VIP' => $bonus['ORI_BONUS_VIP'],
            'ORI_BONUS_STANDARD' => $standardBonus,
            'BONUS_ST' => $bonus['BONUS_STORE'], // 店服务奖实发
            'ORI_BONUS_ST' => $bonus['ORI_BONUS_STORE'], // 店服务奖原奖金

            'BONUS_MNT' => $blueBonusGLSF,
            'ORI_BONUS_MNT' => $blueBonusGL,

            'ORI_BONUS_ABBR' => $blueBonusYJ,
            'BONUS_ABBR' => $blueBonusYJSF,

            //以下没有用
            'BONUS_FW' => 0,
            'BONUS_FX' => $bonus['BONUS_FX'],
            'BONUS_LS' => $bonus['BONUS_LS'],
            'BONUS_BT' => $bonus['BONUS_BT'],
            'BONUS_BT_PROD' => $bonus['BONUS_BT_PROD'],
            'BONUS_BT_TOOL' => $bonus['BONUS_BT_TOOL'],
            'DEDUCT_ZR' => $bonus['DEDUCT_ZR'],
            'BONUS_FL' => $bonus['BONUS_FL'],
            'BONUS_CF' => $bonus['BONUS_CF'],
            'BONUS_LX' => $bonus['BONUS_LX'],
            'SHOULD_QY' => $bonus['BONUS_QY'],
            'SHOULD_DEDUCT_ZR' => $bonus['DEDUCT_ZR'],

            'PV_1L' => $perfData['PV_1L_TOUCH'],//TOUCH为碰业绩
            'QY_1L' => $perfData['PV_1L_TOUCH'] + $pervSurplusPerf['SURPLUS_1L'],
            'SURPLUS_1L' => $perfData['SURPLUS_1L'],
            'PV_2L' => $perfData['PV_2L_TOUCH'],
            'QY_2L' => $perfData['PV_2L_TOUCH'] + $pervSurplusPerf['SURPLUS_2L'],
            'SURPLUS_2L' => $perfData['SURPLUS_2L'],
            'PV_3L' => $perfData['PV_3L_TOUCH'],
            'QY_3L' => $perfData['PV_3L_TOUCH'] + $pervSurplusPerf['SURPLUS_3L'],
            'SURPLUS_3L' => $perfData['SURPLUS_3L'],
            'PV_4L' => $perfData['PV_4L_TOUCH'],
            'QY_4L' => $perfData['PV_4L_TOUCH'] + $pervSurplusPerf['SURPLUS_4L'],
            'SURPLUS_4L' => $perfData['SURPLUS_4L'],
            'PV_5L' => $perfData['PV_5L_TOUCH'],
            'QY_5L' => $perfData['PV_5L_TOUCH'] + $pervSurplusPerf['SURPLUS_5L'],
            'SURPLUS_5L' => $perfData['SURPLUS_5L'],
            'PV_PCS' => $perfData['PV_PCS'],
            'PV_LS_TOUCH' => 0.00,
            'SURPLUS_LS' => 0.00,
            'QY_LS' => 0.00,
            'PV_TOUCH' => Tool::formatPrice($perfData['PV_1L_TOUCH'] + $perfData['PV_2L_TOUCH'] + $perfData['PV_3L_TOUCH'] + $perfData['PV_4L_TOUCH'] + $perfData['PV_5L_TOUCH'] + $perfData['PV_LS_TOUCH']),
            'PERIOD_NUM' => $this->_periodNum,
            'CALC_YEAR' => $this->_calcYear,
            'CALC_MONTH' => $this->_calcYearMonth,
            'CALCULATED_AT' => Date::nowTime(),
            'P_CALC_MONTH' => Date::ociToDate($this->_calcYearMonth, Date::OCI_TIME_FORMAT_SHORT_MONTH),
            'CREATED_AT' => Date::nowTime(),
        ];
        $resend = [];

        unset($bonus, $realBonusGx, $realBonusGl, $bonusReal);
        return ['result'=>$result,'resend'=>$resend];
    }

    /**
     * 根据本有收入计算基础积分
     * @param int $offset
     * @return bool
     */
    public function calcBaseScore(int $offset=0) {
        if (!$this->_isCalcMonth) {
            return true;
        }
        echo sprintf("时间:[%s]基础积分，当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()) , $offset);

        //查询本月的，每人的累计总收入
        $allData = CalcBonus::findUseDbCalc()->select('USER_ID, SUM(BONUS_TOTAL) AS TOTAL_SUM, SUM(ORI_BONUS_BD) AS BD_TOTAL_SUM')->where('CALC_MONTH=:CALC_MONTH', [':CALC_MONTH' => $this->_calcYearMonth])->groupBy('USER_ID')->orderBy('USER_ID DESC')->offset($offset)->limit($this->_limit)->asArray()->all();
        if ($allData) {
            foreach ($allData as $everyData) {
                $validTotalSum = $everyData['TOTAL_SUM'] - $everyData['BD_TOTAL_SUM'];
                if( $validTotalSum <=0 ) continue;

                //达不到 见习主任级别，不产生基础积分
                $userBaseInfo = CalcCache::getUserInfo($everyData['USER_ID'], $this->_periodNum);
                $userEmpLevel = $this->_empLevelConfig[$userBaseInfo['EMP_LV']];
                $userEmpLevelSort = $userEmpLevel['SORT'] ?? EmployLevel::EMP_LEVEL_SORT['NO_LEVEL'];
                unset($userBaseInfo, $userEmpLevel);
                if( $userEmpLevelSort < EmployLevel::EMP_LEVEL_SORT['JX_ZR_LEVEL'] ) {
                    unset($userEmpLevelSort);
                    continue;
                }
                unset($userEmpLevelSort);


                //根据总收入获取积分
                $baseScore = $this->_getBaseScoreByTotalBonus($validTotalSum);
                //根据用户的级别判断 能否得到级别积分
                if( $baseScore > 0 ) {
                    CalcCache::nowMonthScore($everyData['USER_ID'], $this->_periodNum, [
                        'BASE_SCORE' => $baseScore,
                    ]);

                    CalcCache::addHasScoreUsers($everyData['USER_ID'], $this->_periodNum);
                }

                unset($everyData, $validTotalSum, $baseScore);
            }

            unset($allData);
            return $this->calcBaseScore($offset + $this->_limit);
        }

        unset($allData);
        return true;
    }


    /**
     * 循环积分入库
     * @param int $offset
     * @return bool
     * @throws \yii\db\Exception
     */
    public function loopWriteScore(int $offset = 0) {
        if(!$this->_isCalcMonth){
            return true;
        }
        echo sprintf("时间:[%s]积分入库，当前offset为:【%s】" . PHP_EOL, date('Y-m-d H:i:s', time()) , $offset);
        // 从缓存列表里面从底层往上倒序获取会员
        $allData = CalcCache::getHasScoreUsers($this->_periodNum, $offset, $this->_limit);
        if($allData){
            $insertDataMonthScore = [];
            foreach($allData as $userId){
                $monthScoreData = CalcCache::nowMonthScore($userId, $this->_periodNum);
                $totalScore = $monthScoreData['BASE_SCORE'] + $monthScoreData['LEVEL_SCORE'] + $monthScoreData['UPGRADE_SCORE'];
                if( $totalScore <= 0 ) continue;

                $insertDataMonthScore[] = [
                    'USER_ID' => $userId,
                    'BASE_SCORE' => $monthScoreData['BASE_SCORE'],
                    'LEVEL_SCORE' => $monthScoreData['LEVEL_SCORE'],
                    'UPGRADE_SCORE' => $monthScoreData['UPGRADE_SCORE'],
                    'TOTAL_SCORE' => $totalScore,
                    'PERIOD_NUM' => $this->_periodNum,
                    'CALC_MONTH' => $this->_calcYearMonth,
                    'CREATED_AT' => Date::nowTime(),
                ];

                unset($userId, $monthScoreData, $totalScore);
            }

            ScoreMonth::batchInsert($insertDataMonthScore);
            unset($insertDataMonthScore, $allData);
            return $this->loopWriteScore($offset + $this->_limit);
        }

        unset($allData);
        return true;
    }

    /**
     * 根据总收入获取相应的基础积分
     * @param $totalBonus
     * @return int|mixed
     */
    private function _getBaseScoreByTotalBonus($totalBonus) {
        $baseScoreConfig = Json::decode($this->_sysConfig['baseScore']['VALUE']);
        $baseScore = 0;
        foreach ($baseScoreConfig as $everyScoreData) {
            if( $totalBonus < $everyScoreData['monthTotalPvMin'] ) continue;

            if( $everyScoreData['monthTotalPvMax'] != 0 && $totalBonus >= $everyScoreData['monthTotalPvMax'] ) continue;

            $baseScore = $everyScoreData['score'];
            unset($everyScoreData);
            break;
        }

        unset($baseScoreConfig, $totalBonus);
        return $baseScore;
    }

    // 判断是否满足月最低消费
    public function _isMonthPerfLimit($userId) {
        $userMonthTotal = PerfMonth::find()->where(
            'USER_ID=:USER_ID AND CALC_MONTH=:CALC_MONTH', 
            ['USER_ID'=>$userId, 'CALC_MONTH'=>$this->_calcYearMonth]
        )
        ->asArray()
        ->one();
        $fxPvStatus = false;
        if (isset($userMonthTotal['PV_PCS']) && $userMonthTotal['PV_PCS'] >= $this->_sysConfig['monthPcsPvFxCondition']['VALUE']) {
            $fxPvStatus = true;
        }
        
        return $fxPvStatus;
    }
}