<?php
/**
 * link: http://www.zjhejiang.com/
 * copyright: Copyright (c) 2018 浙江禾匠信息科技有限公司
 * author: wxf
 */

namespace app\models;

use app\jobs\UserActionJob;
use app\models\BaseQuery\BaseActiveQuery;

class ModelActiveRecord extends \yii\db\ActiveRecord
{
    public $fillable = [];
    public $guarded = [];
    public $isLog = true; // 单独开关
    public static $log = true; // 全局开关

    /**
     * 有sql添加、更新操作时自动追加添加时间、更新时间
     * @return bool
     */
    public function beforeValidate()
    {
        $time = date('Y-m-d H:i:s', time());
        $insert = $this->isNewRecord;

        $isCreatedAt = false;
        $isUpdatedAt = false;
        $isDeletedAt = false;
        $isDelete = false;
        if (isset($this->attributes) && is_array($this->attributes())) {
            foreach ($this->attributes() as $item) {
                $item === 'created_at' ? $isCreatedAt = true : '';
                $item === 'updated_at' ? $isUpdatedAt = true : '';
                $item === 'deleted_at' ? $isDeletedAt = true : '';
                $item === 'is_delete' ? $isDelete = true : '';
            }
        }

        if ($insert === true && $isCreatedAt === true) {
            $this->created_at = $time;
        }

        if ($isUpdatedAt === true) {
            $this->updated_at = $time;
        }

        if ($isDelete === true && $isDeletedAt === true) {
            if ((int)$this->is_delete === 1) {
                $this->deleted_at = $time;
            } else {
                $this->deleted_at = '0000-00-00 00:00:00';
            }
        }

        return parent::beforeValidate();
    }

    /**
     * @return BaseActiveQuery
     */
    public static function find()
    {
        return \Yii::createObject(BaseActiveQuery::className(), [get_called_class()]);
    }

    public function afterSave($insert, $changedAttributes)
    {
        if (!($this->isLog === true && self::$log === true)) {
            parent::afterSave($insert, $changedAttributes);
            return true;
        }
        try {
            $isSave = true;
            try {
                if (!\Yii::$app->user->isGuest) {
                    $userId = \Yii::$app->user->id;
                    /** @var User $user */
                    $user = \Yii::$app->user->identity;
                    $userIdentity = $user->identity;
                    if ($user->mch_id == 0) {
                        // 会员影响队列时间
                        // 小程序端操作不记录日志
                        if ($userIdentity->is_super_admin == 0 && $userIdentity->is_admin == 0
                            && $userIdentity->is_operator == 0) {
                            $isSave = false;
                        }
                        // 管理员 新增操作不记录日志
                        if (($userIdentity->is_super_admin == 1 || $userIdentity->is_admin == 1) && $insert === true) {
                            $isSave = false;
                        }
                    }
                } else {
                    $userId = 0;
                }
            } catch (\Exception $e) {
                $userId = 0;
            }
            try {
                $mallId = \Yii::$app->mall->id;
            } catch (\Exception $e) {
                $mallId = 0;
            }

            // 更新时 保存日志
            if ($this->isLog === true && $isSave) {
                // 去除以下字段 不记录日志
                $arr = ['created_at', 'updated_at', 'deleted_at'];
                $afterUpdate = $this->attributes;
                $newBeforeUpdate = [];
                $newAfterUpdate = [];
                $remark = '数据更新';
                if (isset($afterUpdate['is_delete']) && $afterUpdate['is_delete'] == 1) {
                    $remark = '数据删除';
                }

                foreach ($changedAttributes as $key => $item) {
                    if (in_array($key, $arr)) {
                        unset($changedAttributes[$key]);
                        continue;
                    }
                    if ($item != $afterUpdate[$key]) {
                        try {
                            $newBeforeUpdate[$key] = \Yii::$app->serializer->decode($item);
                        } catch (\Exception $e) {
                            $newBeforeUpdate[$key] = $item;
                        }

                        try {
                            $newAfterUpdate[$key] = \Yii::$app->serializer->decode($afterUpdate[$key]);
                        } catch (\Exception $e) {
                            $newAfterUpdate[$key] = $afterUpdate[$key];
                        }
                    }
                }

                if ($newBeforeUpdate) {
                    // 黑名单之外的数据
                    if ($this->guarded) {
                        foreach ($this->guarded as $item) {
                            unset($newBeforeUpdate[$item]);
                            unset($newAfterUpdate[$item]);
                        }
                    }

                    // 白名单之内的数据
                    if (!$this->guarded && $this->fillable) {
                        foreach ($newBeforeUpdate as $key => $item) {
                            if (!in_array($key, $this->fillable)) {
                                unset($newBeforeUpdate[$key]);
                                unset($newAfterUpdate[$key]);
                            }
                        }
                    }

                    $modelName = self::className();
                    $dataArr = [
                        'newBeforeUpdate' => $newBeforeUpdate,
                        'newAfterUpdate' => $newAfterUpdate,
                        'modelName' => $modelName,
                        'modelId' => $this->attributes['id'],
                        'remark' => $remark,
                        'user_id' => $userId,
                        'mall_id' => $mallId
                    ];
                    $class = new UserActionJob($dataArr);
                    $queueId = \Yii::$app->queue3->delay(10)->push($class);
                }
            }
            parent::afterSave($insert, $changedAttributes); // TODO: Change the autogenerated stub
        } catch (\Exception $e) {
            throw $e;
        }
    }
}