From 5554a032ae5466d4bba071c2461da5adf164b4d2 Mon Sep 17 00:00:00 2001
From: "as2252258@163.com" <as22522582>
Date: Sat, 24 Apr 2021 00:23:15 +0800
Subject: [PATCH] modify

---
 HttpServer/Events/OnPipeMessage.php | 3 ++-
 System/Crontab/Zookeeper.php        | 2 +-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/HttpServer/Events/OnPipeMessage.php b/HttpServer/Events/OnPipeMessage.php
index 5a823980..e956cda8 100644
--- a/HttpServer/Events/OnPipeMessage.php
+++ b/HttpServer/Events/OnPipeMessage.php
@@ -46,10 +46,11 @@ class OnPipeMessage extends Callback
      */
     private function onCrontabWorker(array $message): string
     {
-        if (empty($handler = $message['handler'] ?? null)) {
+        if (empty($message['handler'] ?? null)) {
             throw new Exception('unknown handler');
         }
         /** @var Crontab $handler */
+        $handler = swoole_unserialize($message['handler']);
         defer(function () use ($handler) {
             $return = $handler->isRecover();
             if ($return === 999) {
diff --git a/System/Crontab/Zookeeper.php b/System/Crontab/Zookeeper.php
index 011d904d..338e5a4e 100644
--- a/System/Crontab/Zookeeper.php
+++ b/System/Crontab/Zookeeper.php
@@ -85,7 +85,7 @@ class Zookeeper extends Process
             if (empty($handler = $redis->get('crontab:' . $value))) {
                 return;
             }
-            $params['handler'] = swoole_unserialize($handler);
+            $params['handler'] = $handler;
 
             $this->server->sendMessage($params, $this->getWorker());
         } catch (Throwable $exception) {