ngds/console/controllers/BonusController.php

<?php
/**
 * Created by PhpStorm.
 * User: leo
 * Date: 2018/3/9
 * Time: 上午11:56
 */
namespace console\controllers;

use backendApi\modules\v1\models\lists\bonus\BalanceList;
use backendApi\modules\v1\models\lists\bonus\PerfOrderList;
use backendApi\modules\v1\models\lists\bonus\PeriodBonusList;
use common\helpers\Cache;
use common\helpers\Form;
use common\libs\export\module\BonusExport;
use common\models\forms\CalcServePeriodForm;
use common\models\forms\PeriodForm;
use yii\db\Exception;

class BonusController extends BaseController
{
    // 计算服务部分--------start
    /**
     * 计算服务---累计用户业绩---根据业务系统的业绩单
     */
    public function actionCalcServePerf($taskKey){
        $params = Cache::getAsyncParams($taskKey);
        $formModel = new CalcServePeriodForm();
        $handleResult = false;
        $periodNum = isset($params['periodNum']) && !empty($params['periodNum']) ? $params['periodNum'] : null;
        if($formModel->load($params, '') && $formModel->perfAsync($params['handleUserId'],$periodNum)){
            $handleResult = true;
            \Yii::$app->swooleAsyncTimer->pushAsyncResultToAdmin($params['handleUserId'], "累计用户业绩第{$params['periodNum']}期生成业绩单更新成功");
        } else {
            \Yii::$app->swooleAsyncTimer->pushAsyncResultToAdmin($params['handleUserId'], "累计用户业绩第{$params['periodNum']}期生成业绩单更新失败,原因：".Form::formatErrorsForApi($formModel->getErrors()), false);
        }
        if(!$handleResult){
            echo "计算服务累计业绩,第{$params['periodNum']}期生成业绩单更新失败，原因：".Form::formatErrorsForApi($formModel->getErrors());
        }
    }

    /**
     * 计算服务---计算奖金
     */
    /**
     * 结算奖金
     * @param $taskKey
     * @throws Exception
     * @throws \yii\base\Exception
     */
    public function actionCalcServeCalcBonus($taskKey){
        $params = Cache::getAsyncParams($taskKey);
        $formModel = new CalcServePeriodForm();
        $handleResult = false;
        if($formModel->load($params, '') && $formModel->calcAsync($params['handleUserId'])){
            $handleResult = true;
            \Yii::$app->swooleAsyncTimer->pushAsyncResultToAdmin($params['handleUserId'], "第{$params['periodNum']}期奖金结算更新成功");
        } else {
            \Yii::$app->swooleAsyncTimer->pushAsyncResultToAdmin($params['handleUserId'], "第{$params['periodNum']}期奖金结算更新失败,原因：".Form::formatErrorsForApi($formModel->getErrors()), false);
        }
        if(!$handleResult){
            echo "第{$params['periodNum']}期奖金结算更新失败，原因：".Form::formatErrorsForApi($formModel->getErrors());
        }
    }
    // 计算服务部分---------end

    /**
     * 生成业绩单并计算业绩
     * @param $taskKey
     * @throws Exception
     * @throws \yii\base\Exception
     */
    public function actionPerf($taskKey){
        $params = Cache::getAsyncParams($taskKey);
        $formModel = new PeriodForm();
        $handleResult = false;
        if($formModel->load($params, '') && $formModel->perfAsync($params['handleUserId'])){
            $handleResult = true;
            \Yii::$app->swooleAsyncTimer->pushAsyncResultToAdmin($params['handleUserId'], "第{$params['periodNum']}期生成业绩单更新成功");
        } else {
            \Yii::$app->swooleAsyncTimer->pushAsyncResultToAdmin($params['handleUserId'], "第{$params['periodNum']}期生成业绩单更新失败,原因：".Form::formatErrorsForApi($formModel->getErrors()), false);
        }
        if(!$handleResult){
            echo "第{$params['periodNum']}期生成业绩单更新失败，原因：".Form::formatErrorsForApi($formModel->getErrors());
            // Log::async([
//                'type' => LogAsync::TYPE_BONUS,
//                'route' => \Yii::$app->controller->id.'/'.\Yii::$app->controller->action->id,
//                'title' => "第{$params['periodNum']}期生成业绩单更新失败",
//                'detail' => "第{$params['periodNum']}期生成业绩单更新失败，原因：".Form::formatErrorsForApi($formModel->getErrors()),
//                'status' => 0,
//            ]);
        }
    }

    /**
     * 结算奖金
     * @param $taskKey
     * @throws Exception
     * @throws \yii\base\Exception
     */
    public function actionCalc($taskKey){
        $params = Cache::getAsyncParams($taskKey);
        $formModel = new PeriodForm();
        $handleResult = false;
        if($formModel->load($params, '') && $formModel->calcAsync($params['handleUserId'])){
            $handleResult = true;
            \Yii::$app->swooleAsyncTimer->pushAsyncResultToAdmin($params['handleUserId'], "第{$params['periodNum']}期奖金结算更新成功");
        } else {
            \Yii::$app->swooleAsyncTimer->pushAsyncResultToAdmin($params['handleUserId'], "第{$params['periodNum']}期奖金结算更新失败,原因：".Form::formatErrorsForApi($formModel->getErrors()), false);
        }
        if(!$handleResult){
            echo "第{$params['periodNum']}期奖金结算更新失败，原因：".Form::formatErrorsForApi($formModel->getErrors());
            // Log::async([
//                'type' => LogAsync::TYPE_BONUS,
//                'route' => \Yii::$app->controller->id.'/'.\Yii::$app->controller->action->id,
//                'title' => "第{$params['periodNum']}期奖金结算更新失败",
//                'detail' => "第{$params['periodNum']}期奖金结算更新失败，原因：".Form::formatErrorsForApi($formModel->getErrors()),
//                'status' => 0,
//            ]);
        }
    }

    /**
     * 奖金挂网
     * @param $taskKey
     * @throws Exception
     * @throws \yii\base\Exception
     */
    public function actionSend($taskKey){
        $params = Cache::getAsyncParams($taskKey);
        $formModel = new PeriodForm();
        $handleResult = false;
        if($formModel->load($params, '') && $formModel->sendAsync($params['handleUserId'])){
            $handleResult = true;
            \Yii::$app->swooleAsyncTimer->pushAsyncResultToAdmin($params['handleUserId'], "第{$params['periodNum']}期挂网成功");
        } else {
            \Yii::$app->swooleAsyncTimer->pushAsyncResultToAdmin($params['handleUserId'], "第{$params['periodNum']}期挂网失败,原因：".Form::formatErrorsForApi($formModel->getErrors()), false);
        }
        if(!$handleResult){
            echo "第{$params['periodNum']}期挂网失败，原因：".Form::formatErrorsForApi($formModel->getErrors());
            // Log::async([
//                'type' => LogAsync::TYPE_BONUS,
//                'route' => \Yii::$app->controller->id.'/'.\Yii::$app->controller->action->id,
//                'title' => "第{$params['periodNum']}期挂网失败",
//                'detail' => "第{$params['periodNum']}期挂网失败，原因：".Form::formatErrorsForApi($formModel->getErrors()),
//                'status' => 0,
//            ]);
        }
    }

    /**
     * 奖金余额导出
     * @param $taskId
     * @return bool
     */
    public function actionBalanceExport($taskId){
        return $this->_export($taskId, BalanceList::class, '会员奖金余额列表');
    }

    /**
     * 最新奖金列表导出
     * @param $taskId
     * @return bool
     */
    public function actionNewPeriodBonusExport($taskId){
        return $this->_export($taskId, PeriodBonusList::class, '最新奖金列表');
    }

    /**
     * 业绩单导出
     * @param $taskId
     * @return bool
     */
    public function actionPerfOrderExport($taskId){
        return $this->_export($taskId, PerfOrderList::class, '业绩单列表');
    }

    /**
     * 导出方法
     * @param $taskId
     * @param $className
     * @param $listName
     * @return bool
     */
    private function _export($taskId, $className, $listName){
        $factory = BonusExport::factory($taskId);
        $factory->listModelClass = $className;
        try {
            if ($factory->generate()) {
                \Yii::$app->swooleAsyncTimer->pushAsyncResultToAdmin($factory->getUserId(), $listName.'导出成功');
            }
            unset($factory, $taskId, $className, $listName);
            return true;
        } catch (\Exception $e) {
            echo $listName.'导出失败。详情：' . $e->getMessage();
            \Yii::$app->swooleAsyncTimer->pushAsyncResultToAdmin($factory->getUserId(), $listName.'导出失败。详情：' . $e->getMessage(), false);
        }
        unset($factory, $taskId, $className, $listName);
        return false;
    }
}