updatecollector

app/Controller/CollectorController.php

@@ -1,4 +1,5 @@
 <?php
+
 declare(strict_types=1);
 namespace App\Controller;
 
@@ -14,11 +15,13 @@ use Hyperf\Context\Context;
  * ClassCollectorController
  * @package App\Controller
  */
+
 class CollectorController extends AbstractController
 {
     #[Inject]
     protected ValidatorFactoryInterface $validationFactory;
 
+
     /**
      * @var CollectorServiceInterface
      */
@@ -96,6 +99,18 @@ class CollectorController extends AbstractController
         }
         return Result::success($result['data']);
     }
- 
+
+
+    /**
+     * @return array
+     */
+    public function sendCrawler()
+    {
+        $requireData = $this->request->all();
+        $result = $this->collectorServiceClient->sendCrawler($requireData);
+
+        return $result?Result::success($result['data']):Result::error($result['message']);
+    }
+
 
 }

app/JsonRpc/CollectorService.php

@@ -33,4 +33,12 @@ class CollectorService extends AbstractServiceClient implements CollectorService
     {
         return $this->__request(__FUNCTION__, $data);
     }
+     /**
+     * @param array $data
+     * @return array|mixed
+     */
+    public function sendCrawler(array $data)
+    {
+        return $this->__request(__FUNCTION__, $data);
+    }
 }

app/JsonRpc/CollectorServiceInterface.php

@@ -13,4 +13,9 @@ interface CollectorServiceInterface
      * @param array $data
      */
     public function getWeb(array $data);
+     /**
+     * @param array $data
+     * @return mixed
+     */
+    public function sendCrawler(array $data);
 }

config/api/collector.php

@@ -40,7 +40,8 @@ Router::addGroup(
         //关联导航
         Router::get('/addCatid', [CollectorController::class, 'addCatid']);
         
+        Router::post('/sendCrawler', [CollectorController::class, 'sendCrawler']);
+        
     },
     ['middleware' => [FooMiddleware::class]]
 );
-

config/autoload/services.php

@@ -87,6 +87,7 @@ return [
             //广告订单服务
             'name' => 'CollectorService',
             'service' => \App\JsonRpc\CollectorServiceInterface::class,
+
             // 直接对指定的节点进行消费，通过下面的 nodes 参数来配置服务提供者的节点信息
             'nodes' => [
                 ['host' => '127.0.0.1', 'port' => 9509],

config/routes.php

@@ -35,4 +35,5 @@ require __DIR__ . '/api/news.php';
 require __DIR__ . '/api/website.php';
 require __DIR__ . '/api/web.php';
 require __DIR__ . '/api/order.php';
-require __DIR__ . '/api/collector.php';
+require __DIR__ . '/api/collector.php';
+