init

2024-11-20 16:40:08 +03:00
commit c24d319159
13 changed files with 918 additions and 0 deletions
--- a/console/MoleController.php
+++ b/console/MoleController.php
@@ -0,0 +1,99 @@
+<?php
+
+/**
+ * @link https://www.kuvalda.ru/
+ * @copyright
+ * @license
+ */
+
+namespace dominion\cron\console;
+
+use Yii;
+use yii\console\Controller;
+use yii\console\ExitCode;
+use dominion\cron\models\MoleTask;
+use yii\base\InlineAction;
+
+/**
+ * Запуск агента по расписанию
+ *
+ * @author Rybkin Sasha <ribkin@dominion.ru>
+ * @since 0.1
+ */
+class MoleController extends Controller
+{
+
+    /**
+     * Запуск всех агентов для проекта yii из mole_task
+     * @return int Exit code
+     */
+    public function actionIndex()
+    {
+        $filePatch = Yii::getAlias('@app/runtime/lock.lock');
+        if (!file_exists($filePatch))
+        {
+            $fp = fopen($filePatch, "w");
+            fwrite($fp, "");
+            fclose($fp);
+        }
+        $file = fopen($filePatch, 'r+');
+
+        if (flock($file, LOCK_EX | LOCK_NB))
+        {
+            $model = new MoleTask;
+            $tasks = $model->getAllTask();
+            foreach ($tasks as $task)
+            {
+                try
+                {
+                    $task->dateStart = date('Y-m-d H:i:s');
+                   $task->save();
+                    $params = explode('/', $task->controller);
+                    $controller = $this->format($params[0]);
+                    $action = 'actionIndex';
+                    if (isset($params[1]))
+                    {
+                        $action = 'action' . $this->format($params[1]);
+                    }
+                    if(stripos($controller, 'Controller') === false)
+                    {
+                        $controller .= 'Controller';
+                    }
+
+                    $class = 'app\\commands\\' . $controller;
+                    if (class_exists($class))
+                    {
+                        $control = new $class($task->controller, 'product');
+                        if (method_exists($control, $action))
+                        {
+                            $params = $control->{$action}(unserialize($task->params));
+                            if(!empty($params))
+                            {
+                                $task->params = serialize($params);
+                            }
+                            $task->isReady = 1;
+                        }
+                    }
+                    $task->setCompleted();
+                } catch (\Exception $ex)
+                {
+                    $task->dateStart = null;
+                    $task->save();
+                    print_r($ex->getMessage());
+                }
+            }
+        }
+        return ExitCode::OK;
+    }
+
+    protected function format($controller)
+    {
+        $params = explode('-', $controller);
+        foreach ($params as $key => $value)
+        {
+            $params[$key] = ucfirst($value);
+        }
+        return implode('', $params);
+    }
+
+}