admin_consumer/app/Controller/CollectorController.php

<?php

declare(strict_types=1);
namespace App\Controller;

use App\JsonRpc\CollectorServiceInterface;
use App\Tools\PublicData;
use Hyperf\Di\Annotation\Inject;
use Hyperf\HttpServer\Annotation\AutoController;
use App\Tools\Result;
use Hyperf\Validation\Contract\ValidatorFactoryInterface;
use App\Constants\ErrorCode;
use Hyperf\Context\Context;
//use App\Service\GatherQueueService;
use App\Service\ImportQueueService;
/**
 * ClassCollectorController
 * @package App\Controller
 */

class CollectorController extends AbstractController
{
    #[Inject]
    protected ValidatorFactoryInterface $validationFactory;
//    #[Inject]
//    protected GatherQueueService $Gservice;
    #[Inject]
    protected ImportQueueService $Iservice;

    /**
     * @var CollectorServiceInterface
     */
    #[Inject]
    private $collectorServiceClient;
 
    /**
     * 添加网站
     * @return array
     */
    public function addWeb()
    {
        $requireData = $this->request->all();
        $validator = $this->validationFactory->make(
            $requireData,
            [
                'name'=> 'required',
                'url'=> 'required',
            ],
            [
                'name.required' => '网站名称不能为空',
                'url.required' => '网站地址不能为空',
            ]
        );
        if ($validator->fails()) {
            $errorMessage = $validator->errors()->first();
            return Result::error($errorMessage);
        }


        
        $result = $this->collectorServiceClient->addWeb($requireData);
        if ($result['code'] != ErrorCode::SUCCESS) {
            return Result::error($result['message'],0,[]);
        }
        return Result::success($result['data']);
    }
     /**
     * 获取网站
     * @return array
     */
    public function getWeb()
    {
        $requireData = $this->request->all();
        $validator = $this->validationFactory->make(
            $requireData,
            [
                'page'=> 'required',
                'pageSize'=> 'required',
            ],
            [
                'page.required' => '第几页不能为空',
                'pageSize.required' => '每页显示条数不能为空',
            ]
        );
        if(isset($requireData['keyWord'])){
            $validator = $this->validationFactory->make(
                $requireData,
                [
                    'keyWord'=> 'required'
                ],
                [
                    'keyWord.required' => '搜索词不能为空'
                ]
            );
        }
        
        if ($validator->fails()) {
            $errorMessage = $validator->errors()->first();
            return Result::error($errorMessage);
        }        
        $result = $this->collectorServiceClient->getWeb($requireData);
        if ($result['code'] != ErrorCode::SUCCESS) {
            return Result::error($result['message'],0,[]);
        }
        return Result::success($result['data']);
    }


    /**
     * 采集动作
     * @return array
     */
    public function sendCrawler()
    {
        $data = [];
        $data['admin_user_id'] = Context::get("UserId");
        $data['time'] = microtime();
        $requireData = $this->request->all();
        $validator = $this->validationFactory->make(
            $requireData,
            [
                'id'=> 'required',
            ],
            [
                'id.required' => '规则id不能为空',
            ]
        );
        if ($validator->fails()) {
            $errorMessage = $validator->errors()->first();
            return Result::error($errorMessage);
        }
//        $b  = $this->Iservice->push($data,1);
        $data['id'] = $requireData['id'];
        var_dump("发送数据：",$data);
        $result =  $this->collectorServiceClient->sendCrawler($data);
        return $result['code']==200?Result::success($result['data']):Result::error('采集失败');

    }

    /**
     * 发送请求
     * @param $data
     * @return array
     */
//    public function goSendCrawler($data=[])
//    {
//        var_dump("我要开始采集了！！！");
//        $this->collectorServiceClient->sendCrawler($data);
//        return Result::success([]);
//    }
      public function zhipu()
      {
          $requireData = $this->request->all();
          // 接口URL
          $apiUrl = 'https://open.bigmodel.cn/api/paas/v4/chat/completions';
            // API密钥
          $apiKey = 'be1856920c54ac537b530d69bc2eda73.gOO2BMq9NXavzEMq';
          // 请求参数
          $params = [
              "model"=>"glm-4",
              "messages"=>[
                  [
                      "role"=>"user",
                      "content"=>$requireData['message']
                  ]

              ]
          ];
          // 构建请求头部
          $headers = [
              'Content-Type: application/json',
              'Authorization: Bearer ' . $apiKey
          ];

        // 将参数转换为JSON格式
          $jsonParams = json_encode($params);
          var_dump("看看：",$jsonParams);
        // 初始化cURL会话
          $ch = curl_init($apiUrl);
          // 设置cURL选项
          curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
          curl_setopt($ch, CURLOPT_HTTPHEADER,$headers);
          curl_setopt($ch, CURLOPT_POST, true);
          curl_setopt($ch, CURLOPT_POSTFIELDS,$jsonParams);

        // 执行cURL会话
          $response = curl_exec($ch);

        // 检查是否有错误发生
          if (curl_errno($ch)) {
              echo 'cURL error: ' . curl_error($ch);
          } else {
              // 处理响应
              $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
              if ($httpCode == 200) {
                  // 解码JSON响应
                  $responseData = json_decode($response, true);
                  Result::success($responseData);
              } else {
                  echo "HTTP error: $httpCode\n";
                  echo "Response: $response\n";
              }
          }
// 关闭cURL会话
          curl_close($ch);
      }


}