1:dispatch//调度方法 告诉集成平台 如何调用接口API及接口参数:params
1.1 在调度方法中,第一步是初始化常用变量操作$this->setVariable();
1.2递增记录调度次数 $times++
1.3从MongoDdb取得一批【待处理】数据
1.4在调度方法中,第一步是初如化变量操作$this->setVariable();该操作中,主要是定义了页码等一些变量
1.5 调用$this->generateRequestParams()方法,得到写入请求参数。
1.6 写入任务队列到写入队列池$jobId = $this->getAsynTargetJobStorage()->insertOne($this->metaData[‘api’], $request, $this->getDataStorage()->ids , $this->getDataStorage()->dataRange );
1.7 设置数据状态。$this->getDataStorage()->setFetchStatus(DataStatus::QUEUE, null, null, new \MongoDB\BSON\ObjectId($jobId));
1.8 排队操作$this->asynTargetJob(1, $jobId);
2:handleResponse 处理响应方法 成功/失败
2.1 定位响应参数状态,根据响应状态,判断响应成功与否,如果失败调用 $this->handleError($response, $jobId);方法
2.2 更新队列状态。$this->getAsynTargetJobStorage()->updateResponse($jobId, DataStatus::FINISHED, $response , [] , null, $this->active );
2.3 调用回调方法$this->handleSuccessCallback($response, $jobId);
3:connect // 连接方法-如何实例化SDK
3.1 实例化SDK,并调用SDK中connection方法得到连接信息。