基础适配器Adapter的使用方法

在所有适配器中，我们需要引入基础适配器Adapter并使用其提供的继承方法。命名空间为：use Domain\Datahub\Instance\Adapter\Adapter;。

日志记录方法

使用$this->getLogStorage()->insertOne([$content], $status);进行日志记录。其中，$content为日志内容（数组形式），$status为日志错误类型。如果$status为错误，需要引入命名空间LogStatus，调用方法为$this->getLogStorage()->insertOne([$content], LogStatus::RECORD);。

获取数据方法

在写入调度者时，需要从数据管理中获取一条数据，并根据配置的metaData中的operation参数。代码如下：

$operation = null;
if (isset($this->metaData['operation'])) {
    $operation = $this->metaData['operation'];
}
$data = $this->getDataStorage()->fetch($operation);

其中，$this->metaData保存了请求调度者和写入调度者的配置参数，包括对应的$api接口地址。

生成参数方法

此方法主要用于将请求调度者和写入调度者的配置参数转换为接口所需的参数。可以直接调用父类（Adapter）的generateRequestParams方法。代码如下：

$request = $this->generateRequestParams();
$request = $this->generateRequestParams($data);

在实际过程中，我们可以使用以下代码：

try {
    $request = $this->generateRequestParams($data);
} catch (\Throwable $th) {
    $this->getLogStorage()->insertOne(['text' => LogMessage::DISPATCH_SOURCE_FAIL, 'response' => $th->getMessage(), 'data' => $data], LogStatus::ERROR);
    $this->getDataStorage()->setFetchStatus(DataStatus::CONTINUE);
    return $this->dispatch();
}

插入源平台请求队列方法

使用上一步得到的$request，向请求队列中插入任务数据，并获取任务ID。代码如下：

$jobId = $this->getAsynSourceJobStorage()->insertOne($this->metaData['api'], $request);

基础适配器，源平台排队方法

调用父类的asynSourceJob方法，$time表示多少秒后执行队列任务（0表示立即执行），$jobId表示任务ID。代码如下：

$this->asynSourceJob($time, $jobId);

基础适配器，目标平台写入队列方法

调用Adapter父类的asynTargetJob方法，$this->metaData['api']表示方案设置的接口地址，$request表示请求参数，$this->getDataStorage()->ids表示数据ID，$this->getDataStorage()->dataRange表示数据范围。代码如下：

$jobId = $this->getAsynTargetJobStorage()->insertOne($this->metaData['api'], $request, $this->getDataStorage()->ids, $this->getDataStorage()->dataRange);

基础适配器，目标平台队列生成后，更新数据状态

调用getDataStorage中的setFetchStatus方法，标记数据状态为队列中。$jobId表示任务ID。代码如下：

$this->getDataStorage()->setFetchStatus(DataStatus::QUEUE, null, null, new \MongoDB\BSON\ObjectId($jobId));

基础适配器，目标平台排队方法

调用父类的asynTargetJob方法，$time表示多少秒后执行队列任务（0表示立即执行），$jobId表示任务ID。代码如下：

$this->asynTargetJob(round($this->asynTimes), $jobId);

数据存储写入数据方法

在查询适配器中，如果得到正确的结果集，调用getDataStorage中的insertOne方法，将数据写入数据管理。$id为主键字段，$number为业务编码字段，$response表示接口返回的结果集，$jobId表示任务ID。代码如下：

$this->getDataStorage()->insertOne($id, $number, $response, false, $jobId);

基础适配器，重试方法`reQueue`

在处理响应时，如果响应结果不正确，调用父类的reQueue方法进行任务重试。代码如下：

$this->reQueue();

基础适配器，异常错误处理方法

在适配器中，我们定义了一个handleError方法用于处理异常。代码如下：

public function handleError($response, $jobId = null)
{
    $throw = new HuidinhuoThrowable($this);
    $throw->handle($jobId, $response);
    $this->getAsynSourceJobStorage()->updateResponse($jobId, DataStatus::ERROR, $response, 0, $this->active);
    $this->getLogStorage()->insertOne(['text' => LogMessage::INVOKE_FAIL, 'response' => $response], LogStatus::ERROR);
    return $response;
}