ngds/common/models/forms/OrderPeriodAdjustForm.php

<?php

namespace common\models\forms;

use backendApi\modules\v1\models\Admin;
use common\components\Model;
use common\helpers\Date;
use common\libs\logging\operate\AdminOperate;
use common\models\DecOrder;
use common\models\FlowExchangePoints;
use common\models\FlowGaragePoints;
use common\models\FlowReconsumePoints;
use common\models\FlowTourismPoints;
use common\models\FlowVillaPoints;
use common\models\FlowWallet;
use common\models\Order;
use common\models\OrderPeriodAdjust;
use common\models\Period;
use common\models\User;
use common\models\UserInfo;
use Yii;

/**
 * Order period adjust form.
 */
class OrderPeriodAdjustForm extends Model
{
    public $orderSn;
    public $modernPeriod;
    public $operateUser;

    public $order;

    public function init()
    {
        parent::init();
        $this->adminOperateLogger = new AdminOperate([
            'fetchClass' => OrderPeriodAdjust::class,
        ]);
    }

    public function rules()
    {
        return [
            [['orderSn', 'modernPeriod'], 'trim'],
            [['orderSn', 'modernPeriod'], 'required'],
        ];
    }

    public function attributeLabels()
    {
        return [
            'orderSn' => '订单号',
            'modernPeriod' => '调整后期数',
        ];
    }

    public function scenarios()
    {
        $parentScenarios = parent::scenarios();
        $customScenarios = [
            'orderPeriodAdjust' => ['orderSn', 'modernPeriod'],
        ];
        return array_merge($parentScenarios, $customScenarios);
    }

    public function beforeValidate()
    {
        $parentValidate = parent::beforeValidate();

        $this->order = Order::findOne(['SN' => $this->orderSn, 'IS_DELETE' => 0]);
        if (!$this->order) {
            $this->addError('orderSn', Yii::t('ctx', 'orderNotExist'));
            return false;
        }

        $period = Period::getInfoByPeriodNum($this->modernPeriod);
        if (!$period) {
            $this->addError('modernPeriod', Yii::t('ctx', 'invalidPcNo'));
            return false;
        }
        if ($period['IS_SENT'] == 1) {
            $this->addError('orderSn', Yii::t('ctx', 'orderHasBeenConnected'));
            return false;
        }

        return $parentValidate;
    }

    public function periodAdjust()
    {
        if (!$this->validate()) {
            return null;
        }

        $operator = $this->operateUser ?: Admin::getAdminNameById(\Yii::$app->user->id);
        $this->adminOperateLogger->saveBeforeContent = Order::findOneAsArray('SN=:SN', [':SN' => $this->orderSn]);

        $db = \Yii::$app->db;
        $transaction = $db->beginTransaction();
        try {
            Order::updateAll(['PERIOD_NUM' => $this->modernPeriod], 'SN = :SN', [':SN' => $this->orderSn]);

            if ($this->order->ORDER_TYPE === 'ZC') {
                DecOrder::updateAll(['PERIOD_NUM' => $this->modernPeriod], 'ORDER_SN = :ORDER_SN', ['ORDER_SN' => $this->orderSn]);
                User::updateAll(['PERIOD_AT' => $this->modernPeriod], 'ID = :USER_ID', ['USER_ID' => $this->order->USER_ID]);
                UserInfo::updateAll(['HIGHEST_EMP_LV_PERIOD' => $this->modernPeriod], 'USER_ID = :USER_ID', ['USER_ID' => $this->order->USER_ID]);
            }

            switch ($this->order->PAY_TYPE) {
                case 'cash':
                    FlowWallet::updateAll(['PERIOD_NUM' => $this->modernPeriod], 'ORDER_SN = :ORDER_SN', ['ORDER_SN' => $this->orderSn]);
                    break;
                case 'exchange':
                    FlowExchangePoints::updateAll(['PERIOD_NUM' => $this->modernPeriod], 'ORDER_SN = :ORDER_SN', ['ORDER_SN' => $this->orderSn]);
                    break;
                case 'tourism_points':
                    FlowTourismPoints::updateAll(['PERIOD_NUM' => $this->modernPeriod], 'ORDER_SN = :ORDER_SN', ['ORDER_SN' => $this->orderSn]);
                    break;
                case 'garage_points':
                    FlowGaragePoints::updateAll(['PERIOD_NUM' => $this->modernPeriod], 'ORDER_SN = :ORDER_SN', ['ORDER_SN' => $this->orderSn]);
                    break;
                case 'villa_points':
                    FlowVillaPoints::updateAll(['PERIOD_NUM' => $this->modernPeriod], 'ORDER_SN = :ORDER_SN', ['ORDER_SN' => $this->orderSn]);
                    break;
                case 'reconsume_points':
                    FlowReconsumePoints::updateAll(['PERIOD_NUM' => $this->modernPeriod], 'ORDER_SN = :ORDER_SN', ['ORDER_SN' => $this->orderSn]);
                    break;
                default:
                    break;
            }

            $orderModel = new OrderPeriodAdjust();
            $orderModel->ORDER_SN = $this->orderSn;
            $orderModel->ORIGIN_PERIOD = $this->order->PERIOD_NUM;
            $orderModel->MODERN_PERIOD = $this->modernPeriod;
            $orderModel->ADMIN_ID = $operator;
            $orderModel->CREATED_AT = Date::nowTime();
            if (!$orderModel->save()) {
                $this->addErrors($orderModel->getErrors());
                return false;
            }

            $transaction->commit();
        } catch (\Exception $e) {
            $transaction->rollBack();
            $this->addError('periodAdjust', $e->getMessage());
            return null;
        }

        $this->adminOperateLogger->saveAfterContent = Order::findOneAsArray('SN=:SN', [':SN' => $this->orderSn]);
        $this->adminOperateLogger->clean()->save([
            'optType' => 'Adjust order period',
            'adminId' => $operator,
            'adminName' => $operator,
        ]);

        return true;
    }
}