ngds/console/controllers/BonusController.php

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

use common\helpers\Cache;
use common\helpers\Form;
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,
//            ]);
        }
    }
}