From 4cac66b1d1445a95585f9fec2a341a7e2edf0bd9 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=90=91=E6=9E=97?= <as2252258@163.com>
Date: Sat, 30 Sep 2023 19:56:58 +0800
Subject: [PATCH] eee

---
 ImplodeCommand.php | 27 ++++++++++++---------------
 1 file changed, 12 insertions(+), 15 deletions(-)

diff --git a/ImplodeCommand.php b/ImplodeCommand.php
index 16c4e5c..31b61d6 100644
--- a/ImplodeCommand.php
+++ b/ImplodeCommand.php
@@ -63,24 +63,21 @@ class ImplodeCommand extends Command
             }
 
             $waite = new Coroutine\WaitGroup();
-
-
             $stream = fopen($path, 'r');
-            if (!$stream) {
-                return 0;
-            }
-            while (($line = fgets($stream)) !== false) {
-                $insert = html_entity_decode($line);
-                if (!str_starts_with(strtoupper($insert), 'INSERT INTO')) {
-                    continue;
+            if ($stream) {
+                while (($line = fgets($stream)) !== false) {
+                    $insert = html_entity_decode($line);
+                    if (!str_starts_with(strtoupper($insert), 'INSERT INTO')) {
+                        continue;
+                    }
+                    $waite->add();
+                    Coroutine::create(function () use ($waite, $insert, $data) {
+                        Coroutine\defer(fn() => $waite->done());
+                        $data->createCommand($insert)->exec();
+                    });
                 }
-                $waite->add();
-                Coroutine::create(function () use ($waite, $insert, $data) {
-                    Coroutine\defer(fn() => $waite->done());
-                    $data->createCommand($insert)->exec();
-                });
+                fclose($stream);
             }
-            fclose($stream);
             $waite->wait();
 
             $output->write('dump data success');