新增问诊类型

app/Command/getProductCommand.php

@@ -11,6 +11,7 @@ use Extend\Prescription\Prescription;
 use Hyperf\Command\Command as HyperfCommand;
 use Hyperf\Command\Annotation\Command;
 use Hyperf\DbConnection\Db;
+use Hyperf\Utils\Coroutine\Concurrent;
 use Psr\Container\ContainerInterface;
 use Symfony\Component\Console\Input\InputArgument;
 
@@ -40,12 +41,16 @@ class getProductCommand extends HyperfCommand
             $prescription = new Prescription();
 
             $page = 1;
-            $page_size = 10;
-            $result = $prescription->getProd(1, 10);
+            $page_size = 100;
+            $result = $prescription->getProd(1, 100);
             if (!empty($result['rows'])){
+                $concurrent = new Concurrent(10);
+
                 foreach ($result['rows'] as $item) {
-                    // 执行入库
-                    $this->handleData($item);
+                    $concurrent->create(function () use($item) {
+                        // 执行入库
+                        $this->handleData($item);
+                    });
                 }
 
                 $count = ceil($result['count'] / $page * $page_size);
@@ -54,8 +59,10 @@ class getProductCommand extends HyperfCommand
                     for ($i = 2; $i < $count; $i++) {
                         $result = $prescription->getProd($i, $page_size);
                         foreach ($result['rows'] as $item) {
-                            // 执行入库
-                            $this->handleData($item);
+                            $concurrent->create(function () use($item) {
+                                // 执行入库
+                                $this->handleData($item);
+                            });
                         }
                     }
                 }