In Yii 2 Advanced Template, the channel publishing interface (publishing the same article to Penguin, WeChat public account, etc.) architecture design, based on queue and console commands to drive workflow
1. The copy API application is QQ and WX. After adjusting the corresponding configuration, the final application directory structure is as follows
common 公共(所有应用程序共有的文件)
config/ 包含公共配置
fixtures/ 包含公共类的测试夹具
logics/ 包含在接口、前端、后端和控制台中使用的模型逻辑类
mail/ 包含电子邮件的视图文件
messages/ 包含国际化的消息文件
models/ 包含在接口、前端、后端和控制台中使用的模型数据类
services/ 包含在接口、前端、后端和控制台中使用的服务类(多个模型的逻辑类)
tests/ 包含公共类的各种测试
widgets/ 包含公共的小部件
console 控制台
config/ 包含控制台配置
controllers/ 包含控制台的控制器类(命令)
migrations/ 包含数据库迁移
models/ 包含控制台的模型类
runtime/ 包含运行时生成的文件，例如日志和缓存文件
services/ 包含控制台的服务类
backend 后端
assets/ 包含应用程序的资源文件(javascript 和 css)
config/ 包含后端配置
controllers/ 包含后端的Web控制器类
models/ 包含后端的模型类
runtime/ 包含运行时生成的文件，例如日志和缓存文件
services/ 包含后端的服务类
tests/ 包含后端应用程序的各种测试
views/ 包含Web应用程序的视图文件
web/ Web 应用根目录，包含 Web 入口文件
frontend 前端
assets/ 包含应用程序的资源文件(javascript 和 css)
config/ 包含前端配置
controllers/ 包含前端的Web控制器类
models/ 包含前端的模型类
runtime/ 包含运行时生成的文件，例如日志和缓存文件
services/ 包含前端的服务类
tests/ 包含前端应用程序的各种测试
views/ 包含Web应用程序的视图文件
web/ Web 应用根目录，包含 Web 入口文件
widgets/ 包含前端的小部件
api 接口(跨渠道)
behaviors/ 包含接口的行为类
config/ 包含接口配置
controllers/ 包含接口的Web控制器类
fixtures/ 包含接口的测试夹具
messages/ 包含国际化的消息文件
models/ 包含接口的模型类
modules/ 包含接口的模块
rests/ 包含接口的 REST API 类
runtime/ 包含运行时生成的文件，例如日志和缓存文件
services/ 包含接口的服务类
tests/ 包含接口应用程序的各种测试
views/ 包含Web应用程序的视图文件
web/ Web 应用根目录，包含 Web 入口文件
qq 接口(企鹅号)
behaviors/ 包含接口的行为类
config/ 包含接口配置
controllers/ 包含接口的Web控制器类
fixtures/ 包含接口的测试夹具
messages/ 包含国际化的消息文件
models/ 包含接口的模型类
modules/ 包含接口的模块
rests/ 包含接口的 REST API 类
runtime/ 包含运行时生成的文件，例如日志和缓存文件
services/ 包含接口的服务类
tests/ 包含接口应用程序的各种测试
views/ 包含Web应用程序的视图文件
web/ Web 应用根目录，包含 Web 入口文件
wx 接口(微信公众帐号)
behaviors/ 包含接口的行为类
config/ 包含接口配置
controllers/ 包含接口的Web控制器类
fixtures/ 包含接口的测试夹具
messages/ 包含国际化的消息文件
models/ 包含接口的模型类
modules/ 包含接口的模块
rests/ 包含接口的 REST API 类
runtime/ 包含运行时生成的文件，例如日志和缓存文件
services/ 包含接口的服务类
tests/ 包含接口应用程序的各种测试
views/ 包含Web应用程序的视图文件
web/ Web 应用根目录，包含 Web 入口文件
rpc 远程过程调用
assets/ 包含应用程序的资源文件(javascript 和 css)
config/ 包含远程过程调用配置
controllers/ 包含远程过程调用的Web控制器类
messages/ 包含国际化的消息文件
models/ 包含远程过程调用的模型类
modules/ 包含远程过程调用的模块
runtime/ 包含运行时生成的文件，例如日志和缓存文件
services/ 包含远程过程调用的服务类
tests/ 包含远程过程调用应用程序的各种测试
views/ 包含Web应用程序的视图文件
web/ Web 应用根目录，包含 Web 入口文件
vendor/ 包含相关的第三方软件包
environments/ 包含基于环境的覆盖
.gitignore 包含由 git 版本系统忽略的目录列表。如果你需要的东西从来没有到你的源代码存储库，添加它。
composer.json Composer 配置文件
init 初始化脚本描述文件
init.bat Windows 下的初始化脚本描述文件
LICENSE.md 许可信息。 把你的项目许可证放到这里。特别是开源醒目。
README.md 安装模板的基本信息。请考虑将其替换为有关您的项目及其安装的信息。
requirements.php 安装使用 Yii 需求检查器。
yii 控制台应用程序引导。
yii.bat Windows下的控制台应用程序引导。
2. Nginx-based single domain name configuration on Yii 2 advanced project template, refer to the website:https://www.shuijingwanwq.com/2018/08/16/2836/, the API application is cross-channel, the QQ application is Penguin, and the WX application is the WeChat public account, for example: POSThttp://api.channel-pub-api.localhost/qq/v1/articles/video?group_id=spider, in fact, the final request is routed to:\qq\rests\article\videocreateaction.php
3. Take the article type: video (video) to Penguin as an example to illustrate the overall architecture design.https://www.shuijingwanwq.com/2018/10/19/2952/, edit \common\config\main-local.php
'copyAssetQueue' => [ // 复制资源文件队列
'class' => 'yii\queue\redis\Queue',
'redis' => 'redis', // Redis 连接组件或它的配置
'channel' => 'cpa:queue:copy:asset', // 队列键前缀
'ttr' => 10 * 60, // 作业处理的最长时间，单位(秒)
'on afterExec' => ['common\components\queue\CopyAssetEventHandler', 'afterExec'], // 每次成功执行作业后
'on afterError' => ['common\components\queue\CopyAssetEventHandler', 'afterError'], // 在作业执行期间发生未捕获的异常时
'as log' => 'yii\queue\LogBehavior',
],
'uploadAssetQueue' => [ // 上传资源文件队列
'class' => 'yii\queue\redis\Queue',
'redis' => 'redis', // Redis 连接组件或它的配置
'channel' => 'cpa:queue:upload:asset', // 队列键前缀
'ttr' => 2 * 60 * 60, // 作业处理的最长时间，单位(秒)
'on afterExec' => ['common\components\queue\UploadAssetEventHandler', 'afterExec'], // 每次成功执行作业后
'on afterError' => ['common\components\queue\UploadAssetEventHandler', 'afterError'], // 在作业执行期间发生未捕获的异常时
'as log' => 'yii\queue\LogBehavior',
],
'pubArticleQueue' => [ // 发布文章队列
'class' => 'yii\queue\redis\Queue',
'redis' => 'redis', // Redis 连接组件或它的配置
'channel' => 'cpa:queue:pub:article', // 队列键前缀
'ttr' => 5 * 60, // 作业处理的最长时间，单位(秒)
'on afterExec' => ['common\components\queue\PubArticleEventHandler', 'afterExec'], // 每次成功执行作业后
'on afterError' => ['common\components\queue\PubArticleEventHandler', 'afterError'], // 在作业执行期间发生未捕获的异常时
'as log' => 'yii\queue\LogBehavior',
],
'sourceCallbackQueue' => [ // 来源回调队列
'class' => 'yii\queue\redis\Queue',
'redis' => 'redis', // Redis 连接组件或它的配置
'channel' => 'cpa:queue:source:callback', // 队列键前缀
'ttr' => 5 * 60, // 作业处理的最长时间，单位(秒)
'on afterExec' => ['common\components\queue\SourceCallbackEventHandler', 'afterExec'], // 每次成功执行作业后
'on afterError' => ['common\components\queue\SourceCallbackEventHandler', 'afterError'], // 在作业执行期间发生未捕获的异常时
'as log' => 'yii\queue\LogBehavior',
],
4. Realize the channel publishing interface (Penguin number): the type of the published article: the article of the video (video) is published to the channel, edited \qq\rests\article\action.php
* @since 1.0
*/
class Action extends \yii\rest\Action
{
/**
* Returns the data model based on the primary key given.
* If the data model is not found, a 404 HTTP exception will be raised.
* @param string $id the ID of the model to be loaded. If the model has a composite primary key,
* the ID must be a string of the primary key values separated by commas.
* The order of the primary key values should follow that returned by the `primaryKey()` method
* of the model.
* @return ActiveRecordInterface the model found
* @throws NotFoundHttpException if the model cannot be found
*/
public function findModel($id)
{
if ($this->findModel !== null) {
return call_user_func($this->findModel, $id, $this);
}
/* @var $modelClass ActiveRecordInterface */
$modelClass = $this->modelClass;
$keys = $modelClass::primaryKey();
if (count($keys) > 1) {
$values = explode(',', $id);
if (count($keys) === count($values)) {
$model = $modelClass::findOne(array_combine($keys, $values));
}
} elseif ($id !== null) {
$model = $modelClass::findOne($id);
}
if (isset($model)) {
return $model;
}
throw new NotFoundHttpException(Yii::t('error', Yii::t('error', Yii::t('error', '20002'), ['id' => $id])), 20002);
}
/**
* 处理模型填充与验证
* @param object $model 模型
* @param array $requestParams 请求参数
* @return array
* 格式如下：
*
* [
* 'status' => true, // 成功
* ]
*
* [
* 'status' => false, // 失败
* 'code' => 20004, // 返回码
* 'message' => '数据验证失败：企鹅号ID(UUID)是无效的。', // 说明
* ]
*
* @throws ServerErrorHttpException
*/
public static function handleLoadAndValidate($model, $requestParams)
{
// 把请求数据填充到模型中
if (!$model->load($requestParams)) {
return ['status' => false, 'code' => 40009, 'message' => Yii::t('error', '40009')];
}
// 验证模型
if (!$model->validate()) {
return self::handleValidateError($model);
}
return ['status' => true];
}
/**
* 处理模型错误
* @param object $model 模型
* @return array
* 格式如下：
*
* [
* 'status' => false, // 失败
* 'code' => 20004, // 返回码
* 'message' => '数据验证失败：代码是无效的。', // 说明
* ]
*
* @throws ServerErrorHttpException
*/
public static function handleValidateError($model)
{
if ($model->hasErrors()) {
$response = Yii::$app->getResponse();
$response->setStatusCode(422, 'Data Validation Failed.');
foreach ($model->getFirstErrors() as $message) {
$firstErrors = $message;
break;
}
return ['status' => false, 'code' => 20004, 'message' => Yii::t('error', Yii::t('error', Yii::t('error', '20004'), ['firstErrors' => $firstErrors]))];
} elseif (!$model->hasErrors()) {
throw new ServerErrorHttpException('Failed to create the object for unknown reason.');
}
}
/**
* 处理模型错误
* @param array $models 模型列表
* @return array
* 格式如下：
*
* [
* 'status' => false, // 失败
* 'code' => 20004, // 返回码
* 'message' => '数据验证失败：代码是无效的。', // 说明
* ]
*
* @throws ServerErrorHttpException
*/
public static function handleValidateMultipleError($models)
{
foreach ($models as $model) {
if ($model->hasErrors()) {
$response = Yii::$app->getResponse();
$response->setStatusCode(422, 'Data Validation Failed.');
foreach ($model->getFirstErrors() as $message) {
$firstErrors = $message;
break;
}
return ['status' => false, 'code' => 20004, 'message' => Yii::t('error', Yii::t('error', Yii::t('error', '20004'), ['firstErrors' => $firstErrors]))];
}
}
throw new ServerErrorHttpException('Failed to create the object for unknown reason.');
}
}
5. Realize the channel publishing interface (Penguin number): the type of the published article: the article of the video (video) is published to the channel, edited \qq\rests\article\videocreateaction.php
* @since 1.0
*/
class VideoCreateAction extends Action
{
/**
* @var string the scenario to be assigned to the new model before it is validated and saved.
*/
public $scenario = Model::SCENARIO_DEFAULT;
/**
* @var string the name of the view action. This property is need to create the URL when the model is successfully created.
*/
public $viewAction = 'view';
/**
* Creates a new model.
* @return array
* @throws ServerErrorHttpException if there is any error when creating the model
* @throws \Throwable
*/
public function run()
{
if ($this->checkAccess) {
call_user_func($this->checkAccess, $this->id);
}
// 基于代码查找状态为启用的单个数据模型(渠道)
$channelEnabledItem = ChannelService::findModelEnabledByCode(Channel::CODE_QQ);
$requestParams = Yii::$app->getRequest()->getBodyParams();
/* 判断请求体参数中租户ID是否存在 */
if (!isset($requestParams['group_id'])) {
$requestParams = ArrayHelper::merge($requestParams, ['group_id' => Yii::$app->params['groupId']]);
}
/* 视频(视频)的文章发布参数 */
$qqArticleVideoCreateParam = new QqArticleVideoCreateParam();
// 把请求数据填充到模型中
if (!$qqArticleVideoCreateParam->load($requestParams, '')) {
return ['code' => 40009, 'message' => Yii::t('error', '40009')];
}
// 验证模型
if (!$qqArticleVideoCreateParam->validate()) {
$qqArticleVideoCreateParamResult = self::handleValidateError($qqArticleVideoCreateParam);
if ($qqArticleVideoCreateParamResult['status'] === false) {
return ['code' => $qqArticleVideoCreateParamResult['code'], 'message' => $qqArticleVideoCreateParamResult['message']];
}
}
/* 基于文章类型代码定义场景 */
$this->scenario = QqArticle::SCENARIO_VIDEO_CREATE;
/* 实例化多个模型 */
// 渠道的应用的来源
if (!is_array($requestParams['channel_app_source_uuids'])) {
return ['code' => 40009, 'message' => Yii::t('error', '40009')];
}
// 基于多个UUID返回状态为启用，且渠道的类型代码必须一致的数据模型(渠道的应用的来源)列表
$channelAppSourceEnabledItems = ChannelAppSourceService::findModelsEnabledByUuids($requestParams['channel_app_source_uuids']);
// 获取、判断渠道的类型代码，获取应用的数据模型列表
$channelTypeCode = $channelAppSourceEnabledItems[$requestParams['channel_app_source_uuids'][0]]->channel_type_code;
if ($channelTypeCode == ChannelType::CODE_QQ_CW) {
// 基于代码查找状态为启用的单个数据模型(渠道的类型)
$channelTypeEnabledItem = ChannelTypeService::findModelEnabledByCode(ChannelType::CODE_QQ_CW);
// 基于多个UUID返回状态为启用的数据模型(企鹅号的内容网站应用)列表
$qqAppEnabledItems = QqCwAppService::findModelsEnabledByChannelAppSourceUuids($requestParams['channel_app_source_uuids']);
} else {
// 基于代码查找状态为启用的单个数据模型(渠道的类型)
$channelTypeEnabledItem = ChannelTypeService::findModelEnabledByCode(ChannelType::CODE_QQ_TP);
// 企鹅号的第三方服务平台应用的企鹅媒体用户
if (!is_array($requestParams['uuid'])) {
return ['code' => 40009, 'message' => Yii::t('error', '40009')];
}
$count = count($requestParams['uuid']);
// 创建一个初始的 $qqTpAppPenguins 数组包含一个默认的模型
$qqTpAppPenguins = [new QqTpAppPenguin([
'scenario' => $this->scenario,
])];
for($i = 1; $i < $count; $i++) {
$qqTpAppPenguins[] = new QqTpAppPenguin([
'scenario' => $this->scenario,
]);
}
foreach ($requestParams['uuid'] as $key => $uuid) {
// 转换视频(视频)的文章发布参数，多模型的填充、验证的实现
$requestParams[$qqTpAppPenguins[0]->formName()][$key]['uuid'] = $uuid;
}
// 批量填充模型属性
if (!Model::loadMultiple($qqTpAppPenguins, $requestParams, $qqTpAppPenguins[0]->formName())) {
return ['code' => 40009, 'message' => Yii::t('error', '40009')];
}
// 批量验证模型
if (!Model::validateMultiple($qqTpAppPenguins)) {
$qqTpAppPenguinsResult = self::handleValidateMultipleError($qqTpAppPenguins);
if ($qqTpAppPenguinsResult['status'] === false) {
return ['code' => $qqTpAppPenguinsResult['code'], 'message' => $qqTpAppPenguinsResult['message']];
}
}
}
// 任务
$task = new Task([
'scenario' => Task::SCENARIO_CREATE,
]);
// 转换视频(视频)的文章发布参数，多模型的填充、验证的实现
$requestParams[$task->formName()] = [
'group_id' => $requestParams['group_id'],
'source' => $qqArticleVideoCreateParam->source,
'source_uuid' => $qqArticleVideoCreateParam->source_uuid,
'source_pub_user_id' => $qqArticleVideoCreateParam->source_pub_user_id,
'source_callback_url' => $qqArticleVideoCreateParam->source_callback_url,
];
$taskResult = self::handleLoadAndValidate($task, $requestParams);
if ($taskResult['status'] === false) {
return ['code' => $taskResult['code'], 'message' => $taskResult['message']];
}
// 基于代码查找状态为启用的单个数据模型(文章类型)
$articleTypeEnabledItem = ArticleTypeService::findModelEnabledByCode(ArticleType::CODE_VIDEO);
// 基于代码查找状态为启用的单个数据模型(企鹅号的文章类型)
$qqArticleTypeEnabledItem = QqArticleTypeService::findModelEnabledByCode(QqArticleType::CODE_MULTIVIDEOS);
// 文章分类
$articleCategory = new ArticleCategory([
'scenario' => $this->scenario,
]);
// 转换视频(视频)的文章发布参数，多模型的填充、验证的实现
$requestParams[$articleCategory->formName()]['id'] = $qqArticleVideoCreateParam->article_category_id;
$articleCategoryResult = self::handleLoadAndValidate($articleCategory, $requestParams);
if ($articleCategoryResult['status'] === false) {
return ['code' => $articleCategoryResult['code'], 'message' => $articleCategoryResult['message']];
}
// 基于文章分类ID查找状态为启用的单个数据模型(企鹅号的文章类型(视频)的文章分类)
$qqArticleCategoryMultivideosEnabledItem = QqArticleCategoryMultivideosService::findModelEnabledByArticleCategoryId($qqArticleVideoCreateParam->article_category_id);
// 企鹅号的文章
$model = new $this->modelClass([
'scenario' => $this->modelClass::SCENARIO_CREATE,
]);
// 转换视频(视频)的文章发布参数，多模型的填充、验证的实现
$requestParams[$model->formName()] = [
'group_id' => $requestParams['group_id'],
'article_category_id' => $qqArticleVideoCreateParam->article_category_id,
'title' => $qqArticleVideoCreateParam->title,
'author' => $qqArticleVideoCreateParam->author,
'source_article_id' => $qqArticleVideoCreateParam->source_article_id,
];
$modelResult = self::handleLoadAndValidate($model, $requestParams);
if ($modelResult['status'] === false) {
return ['code' => $modelResult['code'], 'message' => $modelResult['message']];
}
// 企鹅号的文章类型(视频)的文章
$qqArticleMultivideos = new QqArticleMultivideos([
'scenario' => QqArticleMultivideos::SCENARIO_CREATE,
]);
// 转换视频(视频)的文章发布参数，多模型的填充、验证的实现
$requestParams[$qqArticleMultivideos->formName()] = [
'media' => $qqArticleVideoCreateParam->media_absolute_url,
'tag' => $qqArticleVideoCreateParam->tag,
'desc' => $qqArticleVideoCreateParam->desc,
'apply' => $qqArticleVideoCreateParam->apply,
];
$qqArticleMultivideosResult = self::handleLoadAndValidate($qqArticleMultivideos, $requestParams);
if ($qqArticleMultivideosResult['status'] === false) {
return ['code' => $qqArticleMultivideosResult['code'], 'message' => $qqArticleMultivideosResult['message']];
}
if ($channelTypeCode == ChannelType::CODE_QQ_TP) {
// 企鹅号的第三方服务平台应用的访问令牌(Redis)
// 创建一个初始的 $redisQqAuthQqTpAppAccessTokens 数组包含一个默认的模型
$redisQqAuthQqTpAppAccessTokens = [new RedisQqAuthQqTpAppPenguinAccessToken([
'scenario' => $this->scenario,
])];
for($i = 1; $i < $count; $i++) {
$redisQqAuthQqTpAppAccessTokens[] = new RedisQqAuthQqTpAppPenguinAccessToken([
'scenario' => $this->scenario,
]);
}
foreach ($requestParams['uuid'] as $key => $uuid) {
// 转换视频(视频)的文章发布参数，多模型的填充、验证的实现
$requestParams[$redisQqAuthQqTpAppAccessTokens[0]->formName()][$key]['qq_tp_app_penguin_uuid'] = $uuid;
}
// 批量填充模型属性
if (!Model::loadMultiple($redisQqAuthQqTpAppAccessTokens, $requestParams, $redisQqAuthQqTpAppAccessTokens[0]->formName())) {
return ['code' => 40009, 'message' => Yii::t('error', '40009')];
}
// 批量验证模型
if (!Model::validateMultiple($redisQqAuthQqTpAppAccessTokens)) {
$redisQqAuthQqTpAppAccessTokensResult = self::handleValidateMultipleError($redisQqAuthQqTpAppAccessTokens);
if ($redisQqAuthQqTpAppAccessTokensResult['status'] === false) {
$qqTpAppPenguinUuids = [];
foreach ($redisQqAuthQqTpAppAccessTokens as $redisQqAuthQqTpAppAccessToken) {
if ($redisQqAuthQqTpAppAccessToken->hasErrors()) {
$qqTpAppPenguinUuids[] = $redisQqAuthQqTpAppAccessToken->qq_tp_app_penguin_uuid;
}
}
if (!empty($qqTpAppPenguinUuids)) {
$qqTpAppPenguinUuids = implode(";", $qqTpAppPenguinUuids);
}
throw new HttpException(302, Yii::t('error', Yii::t('error', Yii::t('error', '40020'), ['qq_tp_app_penguin_uuids' => $qqTpAppPenguinUuids])), 40008);
}
}
}
/* 操作数据(事务) */
$qqArticleService = new QqArticleService();
$result = $qqArticleService->videoCreate($channelEnabledItem, $channelTypeEnabledItem, $channelAppSourceEnabledItems, $qqAppEnabledItems, $articleTypeEnabledItem, $qqArticleTypeEnabledItem, $qqArticleCategoryMultivideosEnabledItem, $task, $model, $qqArticleMultivideos);
if ($result['status'] === false) {
throw new ServerErrorHttpException($result['message'], $result['code']);
}
return ['code' => 10000, 'message' => Yii::t('success', '30016'), 'data' => $result['data']];
}
}
6. Implement the channel publishing interface (Penguin number): the type of the published article: the article of the video (video) is published to the channel, edited \common\services\qqArticleService.php
/**
* 发布视频(视频)的文章至渠道发布
*
* @param object $channel 渠道
* @param object $channelType 渠道的类型
* @param array $channelAppSources 渠道的应用的来源列表
* @param array $qqApps 企鹅号的应用列表
* @param object $articleType 文章类型
* @param object $qqArticleType 企鹅号的文章类型
* @param object $qqArticleCategoryMultivideos 企鹅号的文章类型(视频)的文章
* @param object $task 任务
* 格式如下：
* [
* 'group_id' => 'spider', // 租户ID
* 'source' => 'spider', // 来源，xContent：内容库；vms：视频管理系统；cms：内容管理系统；spider：自媒体；channel-pub-api：渠道发布接口
* 'source_uuid' => '825e6d5e36468cc4bf536799ce3565cf', // 来源ID(UUID)
* 'source_pub_user_id' => 1, // 来源发布用户ID
* 'source_callback_url' => 'http://www.source_callback_url.com', // 来源回调地址
* ]
*
* @param object $qqArticle 企鹅号的文章
* 格式如下：
* [
* 'group_id' => 'spider', // 租户ID
* 'article_category_id' => 226, // 文章分类ID
* 'title' => '综艺节目 - 20181121 - 1', // 标题
* 'author' => '综艺节目 - 20181121 - 1', // 作者
* 'source_article_id' => 1, // 来源文章ID
* ]
*
* @param object $qqArticleMultivideos 企鹅号的文章类型(视频)的文章
* 格式如下：
* [
* 'media' => 'http://127.0.0.1/channel-pub-api/storage/spider/videos/3d35e17a32fb48cfb76f39a1b1bf33ce_h264_1200k_mp4', // 视频文件
* 'tag' => '综艺', // 视频文章标签，以英文半角逗号分隔，最多5个，每个标签最多8个字
* 'desc' => '综艺节目 - 20181121 - 1', // 视频描述
* 'apply' => 0, // 是否申请原创文章，0：否；1：是(需要用户具有发表视频原创文章资格否则无效)
* ]
*
* @param bool $isCopyAssetsAsync 是否复制来源的资源文件至渠道发布的资源目录，队列任务执行成功后，调用相应服务，否则，插入发布日志(异步)，默认为 true
*
* @return array
* 格式如下：
*
* [
* 'status' => true, // 成功
* 'data' => [ // array
* [ // object
* 'channel_id' => 1, // 渠道ID
* 'channel_code' => 'qq', // 渠道代码，qq：企鹅号；wx：微信公众帐号
* 'channel_type_id' => 1, // 渠道的类型ID
* 'channel_type_code' => 'qq_cw', // 渠道的类型代码，qq_cw：企鹅号的内容网站应用；qq_tp：企鹅号的第三方服务平台应用；wx：微信公众帐号应用
* 'channel_app_source_id' => 1, // 渠道的应用的来源ID
* 'channel_app_source_uuid' => 'a3f87610e17011e88f0154ee75d2ebc1', // 渠道的应用的来源ID(UUID)
* 'task_id' => 8, // 任务ID
* 'status' => 1, // 状态，0：禁用；1：启用
* 'created_at' => 1541730602, // 创建时间
* 'updated_at' => 1541730602, // 更新时间
* 'uuid' => '5ce1f7f2e3c711e8bc2354ee75d2ebc1', // 渠道的应用的任务ID(UUID)
* 'id' => 13, // ID
* ],
* [ // object
* 'channel_id' => 1, // 渠道ID
* 'channel_code' => 'qq', // 渠道代码，qq：企鹅号；wx：微信公众帐号
* 'channel_type_id' => 1, // 渠道的类型ID
* 'channel_type_code' => 'qq_cw', // 渠道的类型代码，qq_cw：企鹅号的内容网站应用；qq_tp：企鹅号的第三方服务平台应用；wx：微信公众帐号应用
* 'channel_app_source_id' => 2, // 渠道的应用的来源ID
* 'channel_app_source_uuid' => '2369c1d8e25211e8bbf154ee75d2ebc1', // 渠道的应用的来源ID(UUID)
* 'task_id' => 8, // 任务ID
* 'status' => 1, // 状态，0：禁用；1：启用
* 'created_at' => 1541730603, // 创建时间
* 'updated_at' => 1541730603, // 更新时间
* 'uuid' => '5ce3a8d6e3c711e8b2bd54ee75d2ebc1', // 渠道的应用的任务ID(UUID)
* 'id' => 14, // ID
* ],
* ]
* ]
*
* [
* 'status' => false, // 失败
* 'code' => 20004, // 返回码
* 'message' => '文章类型代码：video，的状态为未启用', // 说明
* ]
*
* @throws \Throwable
*/
public function videoCreate($channel, $channelType, $channelAppSources, $qqApps, $articleType, $qqArticleType, $qqArticleCategoryMultivideos, $task, $qqArticle, $qqArticleMultivideos, $isCopyAssetsAsync = true)
{
if ($isCopyAssetsAsync) {
$absoluteUrl = $qqArticleMultivideos->media;
}
/* 操作数据(事务) */
$transaction = Yii::$app->db->beginTransaction();
try {
/* 创建 MySQL 模型(任务) */
$taskService = new TaskService();
$task->channel_id = $channel->id;
$task->channel_code = $channel->code;
$task->channel_type_id = $channelType->id;
$task->channel_type_code = $channelType->code;
$task->status = Task::STATUS_ENABLED;
$taskServiceCreateResult = $taskService->create($task, false);
if ($taskServiceCreateResult['status'] === false) {
throw new ServerErrorHttpException($taskServiceCreateResult['message'], $taskServiceCreateResult['code']);
}
/* 循环创建 MySQL 模型(渠道的应用的任务、企鹅号的内容网站应用的任务/企鹅号的第三方服务平台应用的企鹅媒体用户的任务) */
$channelAppTasks = [];
$channelAppTaskService = new ChannelAppTaskService();
$qqCwAppTaskService = new QqCwAppTaskService();
foreach ($channelAppSources as $channelAppSource) {
$channelAppTask = new ChannelAppTask();
$channelAppTask->channel_id = $channel->id;
$channelAppTask->channel_code = $channel->code;
$channelAppTask->channel_type_id = $channelType->id;
$channelAppTask->channel_type_code = $channelType->code;
$channelAppTask->channel_app_source_id = $channelAppSource->id;
$channelAppTask->channel_app_source_uuid = $channelAppSource->uuid;
$channelAppTask->task_id = $task->id;
$channelAppTask->status = ChannelAppTask::STATUS_ENABLED;
$channelAppTaskServiceCreateResult = $channelAppTaskService->create($channelAppTask, false);
if ($channelAppTaskServiceCreateResult['status'] === false) {
throw new ServerErrorHttpException($channelAppTaskServiceCreateResult['message'], $channelAppTaskServiceCreateResult['code']);
}
if ($channelType->code == ChannelType::CODE_QQ_CW) {
$qqCwAppTask = new QqCwAppTask();
$qqCwAppTask->channel_app_task_id = $channelAppTask->id;
$qqCwAppTask->channel_app_task_uuid = $channelAppTask->uuid;
$qqCwAppTask->qq_cw_app_id = $qqApps[$channelAppSource->uuid]->id;
$qqCwAppTask->task_id = $task->id;
$qqCwAppTask->status = QqCwAppTask::STATUS_WAIT_PUBLISH;
$qqCwAppTaskServiceCreateResult = $qqCwAppTaskService->create($qqCwAppTask, false);
if ($qqCwAppTaskServiceCreateResult['status'] === false) {
throw new ServerErrorHttpException($qqCwAppTaskServiceCreateResult['message'], $qqCwAppTaskServiceCreateResult['code']);
}
} else {
}
$channelAppTask->status = $qqCwAppTask->status;
$channelAppTasks[] = $channelAppTask;
}
/* 创建 MySQL 模型(企鹅号的文章) */
$qqArticle->qq_app_type = $channelType->code == ChannelType::CODE_QQ_CW ? QqArticle::QQ_APP_TYPE_CW : QqArticle::QQ_APP_TYPE_TP;
$qqArticle->article_type_id = $articleType->id;
$qqArticle->qq_article_type_id = $qqArticleType->id;
$qqArticle->qq_article_category_id = $qqArticleCategoryMultivideos->id;
$qqArticle->task_id = $task->id;
$qqArticle->status = QqArticle::STATUS_ENABLED;
$thisCreateResult = $this->create($qqArticle, false);
if ($thisCreateResult['status'] === false) {
throw new ServerErrorHttpException($thisCreateResult['message'], $thisCreateResult['code']);
}
/* 创建 MySQL 模型(企鹅号的文章类型(视频)的文章) */
$qqArticleMultivideosService = new QqArticleMultivideosService();
$qqArticleMultivideos->qq_article_id = $qqArticle->id;
$qqArticleMultivideos->category = $qqArticleCategoryMultivideos->id;
$qqArticleMultivideos->md5 = '';
$qqArticleMultivideos->media = '';
$qqArticleMultivideos->vid = '';
$qqArticleMultivideos->task_id = $task->id;
$qqArticleMultivideos->status = QqArticleMultivideos::STATUS_ENABLED;
$qqArticleMultivideosServiceCreateResult = $qqArticleMultivideosService->create($qqArticleMultivideos, false);
if ($qqArticleMultivideosServiceCreateResult['status'] === false) {
throw new ServerErrorHttpException($qqArticleMultivideosServiceCreateResult['message'], $qqArticleMultivideosServiceCreateResult['code']);
}
$transaction->commit();
} catch(\Throwable $e) {
$transaction->rollBack();
throw $e;
}
if ($isCopyAssetsAsync) {
/* 复制来源的资源文件至渠道发布的资源目录，队列任务执行成功后，调用相应服务，否则，插入发布日志(异步) */
$assetServiceCopyAssetsAsyncData = [
'channel_id' => $channel->id,
'channel_code' => $channel->code,
'channel_type_id' => $channelType->id,
'channel_type_code' => $channelType->code,
'source' => $task->source,
'task_id' => $task->id,
];
$assets = [
[
'type' => Asset::TYPE_VIDEO,
'channel_article_id' => $qqArticle->id,
'absolute_url' => $absoluteUrl,
],
];
$assetServiceCopyAssetsAsyncResult = AssetService::copyAssetsAsync($assetServiceCopyAssetsAsyncData, $assets);
}
return ['status' => true, 'data' => $channelAppTasks];
}
7. Realize the channel publishing interface (Penguin number): the type of published article: the article of the video (video) is published to the channel, and the source resource file is copied to the resource directory published by the channel. \common\services\AssetService.php
/**
* 复制来源的资源文件至渠道发布的资源目录，队列任务执行成功后，调用相应服务，否则，插入发布日志(异步)
* @param array $data 数据
* 格式如下：
* [
* 'channel_id' => 1, // 渠道ID
* 'channel_code' => 'qq', // 渠道代码，qq：企鹅号；wx：微信公众帐号
* 'channel_type_id' => 1, // 渠道的类型ID
* 'channel_type_code' => 'qq_cw', // 渠道的类型代码，qq_cw：企鹅号的内容网站应用；qq_tp：企鹅号的第三方服务平台应用；wx：微信公众帐号应用
* 'source' => 'spider', // 来源，xContent：内容库；vms：视频管理系统；cms：内容管理系统；spider：自媒体；channel-pub-api：渠道发布接口
* 'task_id' => 1, // 任务ID
* ]
*
* @param array $assets 来源的资源文件的绝对URL
* 格式如下：
* [
* [
* 'type' => 'image', // 资源文件的类型，image：图片；video：视频
* 'channel_article_id' => 1, // 渠道的文章ID
* 'absolute_url' => 'http://localhost/spider/storage/spider/images/1.png', // 来源的资源文件的绝对URL
* ],
* [
* 'type' => 'video', // 资源文件的类型，image：图片；video：视频
* 'channel_article_id' => 1, // 渠道的文章ID
* 'absolute_url' => 'http://127.0.0.1/channel-pub-api/storage/spider/videos/7月份北上广深等十大城市租金环比上涨 看东方 20180820 高清_高清.mp4', // 来源的资源文件的绝对URL
* ],
* ]
*
* @throws Exception execution failed
*/
public static function copyAssetsAsync($data, $assets)
{
// file_put_contents('E:/wwwroot/channel-pub-api/qq/runtime/copy-assets-async-data-' . $data['task_id'] . time() . '.txt', print_r($data, true));
// file_put_contents('E:/wwwroot/channel-pub-api/qq/runtime/copy-assets-async-assets-' . $data['task_id'] . time() . '.txt', print_r($assets, true));
// 批量创建资源
static::createMultiple($data, $assets);
// 将任务发送到队列(复制资源文件队列)，通过标准工作人员进行处理
Yii::$app->copyAssetQueue->push(new CopyAssetJob([
'taskId' => $data['task_id'],
]));
}
8. Posthttp://api.channel-pub-api.localhost/qq/v1/articles/video?group_id=spider, the execution is successful, and the value of media_absolute_url is deliberately wrong, so as to test the subsequent processing of the job copying the resource file queue failure; specially let source_callback_url The value is wrong to test the subsequent processing after the job execution of the callback queue fails
request body
{
"channel_app_source_uuids": ["bba4e024eba111e89fa754ee75d2ebc1"],
"source": "spider",
"source_uuid": "825e6d5e36468cc4bf536799ce3565cf",
"source_pub_user_id": 1,
"source_callback_url": "http://www.source_callback_url.com",
"article_category_id": 226,
"title": "综艺节目 - 20181123 - 1",
"author": "综艺节目 - 20181123 - 1",
"source_article_id": 1,
"media_absolute_url": "http://127.0.0.1/channel-pub-api/storage/spider/videos/3d35e17a32fb48cfb76f39a1b1bf33ce_h264_1200k_mp4",
"tag": "综艺",
"apply": 0,
"desc": "综艺节目 - 20181123 - 1"
}
Response body
{
"code": 10000,
"message": "发布文章类型：视频(视频)的文章成功",
"data": [
{
"channel_id": 1,
"channel_code": "qq",
"channel_type_id": 1,
"channel_type_code": "qq_cw",
"channel_app_source_id": 6,
"channel_app_source_uuid": "bba4e024eba111e89fa754ee75d2ebc1",
"task_id": 19,
"status": 1,
"created_at": 1542960204,
"updated_at": 1542960204,
"uuid": "40e5a938eef611e88d6254ee75d2ebc1",
"id": 19
}
]
}
9. Execute the SQL statement as follows:
SELECT * FROM `cpa_channel` WHERE (`code`='qq') AND (`is_deleted`=0)
SELECT * FROM `cpa_channel_app_source` WHERE (`uuid`='bba4e024eba111e89fa754ee75d2ebc1') AND (`is_deleted`=0)
SELECT * FROM `cpa_channel_type` WHERE (`code`='qq_cw') AND (`is_deleted`=0)
SELECT * FROM `cpa_qq_cw_app` WHERE (`channel_app_source_uuid`='bba4e024eba111e89fa754ee75d2ebc1') AND (`is_deleted`=0)
SELECT * FROM `cpa_article_type` WHERE (`code`='video') AND (`is_deleted`=0)
SELECT * FROM `cpa_qq_article_type` WHERE (`code`='multivideos') AND (`is_deleted`=0)
SELECT EXISTS(SELECT * FROM `cpa_article_category` WHERE (`cpa_article_category`.`id`=226) AND ((`is_deleted`=0) AND (`status`=1)))
SELECT * FROM `cpa_qq_article_category_multivideos` WHERE (`article_category_id`=226) AND (`is_deleted`=0)
INSERT INTO `cpa_task` (`group_id`, `source`, `source_uuid`, `source_pub_user_id`, `source_callback_url`, `channel_id`, `channel_code`, `channel_type_id`, `channel_type_code`, `status`, `created_at`, `updated_at`) VALUES ('spider', 'spider', '825e6d5e36468cc4bf536799ce3565cf', 1, 'http://www.source_callback_url.com', 1, 'qq', 1, 'qq_cw', 1, 1542960204, 1542960204)
INSERT INTO `cpa_channel_app_task` (`channel_id`, `channel_code`, `channel_type_id`, `channel_type_code`, `channel_app_source_id`, `channel_app_source_uuid`, `task_id`, `status`, `created_at`, `updated_at`, `uuid`) VALUES (1, 'qq', 1, 'qq_cw', 6, 'bba4e024eba111e89fa754ee75d2ebc1', 19, 1, 1542960204, 1542960204, '40e5a938eef611e88d6254ee75d2ebc1')
INSERT INTO `cpa_qq_cw_app_task` (`channel_app_task_id`, `channel_app_task_uuid`, `qq_cw_app_id`, `task_id`, `status`, `created_at`, `updated_at`) VALUES (19, '40e5a938eef611e88d6254ee75d2ebc1', 5, 19, 1, 1542960205, 1542960205)
INSERT INTO `cpa_qq_article` (`group_id`, `article_category_id`, `title`, `author`, `source_article_id`, `qq_app_type`, `article_type_id`, `qq_article_type_id`, `qq_article_category_id`, `task_id`, `status`, `created_at`, `updated_at`) VALUES ('spider', 226, '综艺节目 - 20181123 - 1', '综艺节目 - 20181123 - 1', 1, 'cw', 3, 2, 2808, 19, 1, 1542960205, 1542960205)
INSERT INTO `cpa_qq_article_multivideos` (`media`, `tag`, `desc`, `apply`, `qq_article_id`, `category`, `md5`, `vid`, `task_id`, `status`, `created_at`, `updated_at`) VALUES ('', '综艺', '综艺节目 - 20181123 - 1', 0, 19, 2808, '', '', 19, 1, 1542960205, 1542960205)
INSERT INTO `cpa_asset` (`channel_id`, `channel_code`, `channel_type_id`, `channel_type_code`, `source`, `type`, `absolute_url`, `relative_path`, `size`, `task_id`, `channel_article_id`, `status`, `is_deleted`, `created_at`, `updated_at`, `deleted_at`) VALUES (1, 'qq', 1, 'qq_cw', 'spider', 'video', 'http://127.0.0.1/channel-pub-api/storage/spider/videos/3d35e17a32fb48cfb76f39a1b1bf33ce_h264_1200k_mp4', '', 0, 19, 19, 1, 0, 1542960205, 1542960205, 0)
10. View the status information of 4 queues
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/info --color=0
Jobs
- waiting: 1
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii upload-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii pub-article-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
11. Queue job: copy the source resource file to the resource directory published by the channel, edit \common\jobs\copyassetjob.php
* @since 1.0
*/
class CopyAssetJob extends Job
{
public $taskId;
/*
* @throws ServerErrorHttpException 如果基于任务ID查找状态为启用的资源列表为空，将抛出 500 HTTP 异常
*/
public function execute($queue)
{
// 基于ID查找状态为启用的单个数据模型(任务)
$taskEnabledItem = TaskService::findModelEnabledById($this->taskId);
// 基于任务ID查找状态为启用的资源列表
$assetEnabledItems = Asset::findAllEnabledByTaskId($this->taskId);
if (empty($assetEnabledItems)) {
throw new ServerErrorHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35020'), ['task_id' => $this->taskId])), 35020);
}
$source = $taskEnabledItem->source;
$assets = [];
foreach ($assetEnabledItems as $assetEnabledItem) {
$assets[] = [
'type' => $assetEnabledItem->type,
'absolute_url' => $assetEnabledItem->absolute_url,
];
}
// 复制来源的资源文件至渠道发布的资源目录，返回相对路径(同步)
$assetServiceCopyAssetsSyncResult = AssetService::copyAssetsSync($source, $assets);
foreach ($assetEnabledItems as $key => $assetEnabledItem) {
$assetEnabledItem->relative_path = $assetServiceCopyAssetsSyncResult[$key]['relative_path'];
// 取得文件大小，单位(字节)
$assetEnabledItem->size = filesize(Yii::$app->params['channelPubApi']['asset'][$assetEnabledItem->type]['basePath'] . $assetServiceCopyAssetsSyncResult[$key]['relative_path']);
$assetEnabledItems[$key] = $assetEnabledItem;
}
// 批量更新资源
Asset::updateMultiple($assetEnabledItems);
}
}
12. Queue event handler (after each successful execution of jobs): call the corresponding service (after the job execution is successful) for subsequent processing, call the corresponding service failure (that is, the service throws an exception), only insert the system log; the queue Event handler (when an uncaught exception occurs during job execution): call the corresponding service (after the job execution fails) for subsequent processing, call the corresponding service (that is, the service throws an exception), and only insert the system log. Edit \Common\Components\Queue\CopyAssetEventHandler.php
* @since 1.0
*/
class CopyAssetEventHandler extends Component
{
/**
* @param ExecEvent $event
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws UnprocessableEntityHttpException 如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
*/
public static function afterExec(ExecEvent $event)
{
$taskId = $event->job->taskId;
// 基于ID查找状态为启用的单个数据模型(任务)
$taskEnabledItem = TaskService::findModelEnabledById($taskId);
// 调用相应服务进行后续处理
$serviceClass = 'common\services\\' . str_replace(' ', '', ucwords(str_replace('_', ' ', $taskEnabledItem->channel_type_code))) . 'AssetService'; // 例：common\services\QqCwAssetService
$serviceAction = 'copyAssetExecHandler';
$serviceClass::$serviceAction($taskEnabledItem->id);
}
/**
* @param ExecEvent $event
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws UnprocessableEntityHttpException 如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
*/
public static function afterError(ExecEvent $event)
{
$taskId = $event->job->taskId;
// 基于ID查找状态为启用的单个数据模型(任务)
$taskEnabledItem = TaskService::findModelEnabledById($taskId);
// 调用相应服务进行后续处理
$serviceClass = 'common\services\\' . str_replace(' ', '', ucwords(str_replace('_', ' ', $taskEnabledItem->channel_type_code))) . 'AssetService'; // 例：common\services\QqCwAssetService
$serviceAction = 'copyAssetErrorHandler';
$serviceClass::$serviceAction($taskEnabledItem->id, $event->error);
}
}
13. The subsequent processing of the job copying the resource file queue is successful: the file is uploaded, and the uploaded resource file queue task is successfully executed, and the corresponding service is called, otherwise, the release log (asynchronous) is inserted. Take Penguin as an example, edit \common\services\qqcwassetservice.php
/**
* 复制资源文件队列的作业执行成功后的后续处理
*
* @param int $taskId 任务ID
* 格式如下：1
*
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws UnprocessableEntityHttpException 如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
* @throws \yii\base\Exception if the directory could not be created (i.e. php error due to parallel changes)
*/
public static function copyAssetExecHandler($taskId)
{
// 基于ID查找状态为启用的单个数据模型(任务)
$taskEnabledItem = TaskService::findModelEnabledById($taskId);
// 基于条件查找状态为启用的资源列表
$assetEnabledWhere = [
'channel_id' => $taskEnabledItem->channel_id,
'channel_type_id' => $taskEnabledItem->channel_type_id,
'type' => Asset::TYPE_VIDEO,
'task_id' => $taskEnabledItem->id,
];
$assetEnabledItems = Asset::findAllEnabledByWhere($assetEnabledWhere);
if (empty($assetEnabledItems)) {
} else {
// 企鹅号的内容网站应用的视频文件分片上传，队列任务执行成功后，调用相应服务，否则，插入发布日志(异步)
$assets = [];
foreach ($assetEnabledItems as $assetEnabledItem) {
$assets[] = [
'job_type' => UploadAssetJob::JOB_TYPE_VIDEO_MULTIPART,
'id' => $assetEnabledItem->id,
];
}
static::uploadAssetVideoMultipartAsync($taskId, $assets);
}
}
14. The subsequent processing of the job of copying the resource file queue fails to update the task in batches based on the task ID (Scenario: The job of copying the resource file queue After the execution fails, the number of publishings can be reduced by 1, status, 3: in the release (failed); insert the release log, and push the job to the source callback queue (asynchronous). Take Penguin as an example, edit \common\services\qqcwassetservice.php
/**
* 复制资源文件队列的作业执行失败后的后续处理
*
* @param int $taskId 任务ID
* 格式如下：1
* @param object $eventError 事件错误
*
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws UnprocessableEntityHttpException 如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
* @throws \yii\base\Exception if the directory could not be created (i.e. php error due to parallel changes)
*/
public static function copyAssetErrorHandler($taskId, $eventError)
{
// 基于ID查找状态为启用的单个数据模型(任务)
$taskEnabledItem = TaskService::findModelEnabledById($taskId);
// 基于任务ID查找状态为启用的资源列表
$channelAppTaskEnabledItems = ChannelAppTask::findAllEnabledByTaskId($taskId);
if (empty($channelAppTaskEnabledItems)) {
throw new ServerErrorHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35021'), ['task_id' => $taskId])), 35021);
}
// 基于任务ID批量更新企鹅号的内容网站应用的任务(场景：复制资源文件队列的作业执行失败后，可发布次数减1，状态，3：发布中(已失败))
QqCwAppTask::updateMultiplePublishErrorByTaskId($taskId);
$pubLogDatas = [];
foreach ($channelAppTaskEnabledItems as $key => $channelAppTaskEnabledItem) {
// 基于渠道的应用的任务ID查找单个数据模型(企鹅号的内容网站应用的任务)
$qqCwAppTaskItem = QqCwAppTaskService::findModelByChannelAppTaskId($channelAppTaskEnabledItem->id);
$pubLogDatas[$key] = [
'channel_app_source_uuid' => $channelAppTaskEnabledItem->channel_app_source_uuid,
'channel_app_task_uuid' => $channelAppTaskEnabledItem->uuid,
'channel_code' => $channelAppTaskEnabledItem->channel_code,
'channel_type_code' => $channelAppTaskEnabledItem->channel_type_code,
'channel_app_task_status' => $qqCwAppTaskItem->status,
];
}
// 发布任务失败后，插入发布日志，将作业推送至来源回调队列(异步)
SourceCallbackService::sourceCallbackAsync($channelAppTaskEnabledItems, $eventError->getCode(), $eventError->getMessage(), $pubLogDatas, PubLog::STATUS_ERROR);
// 基于企鹅号的内容网站应用的任务ID查找状态为启用的单个资源(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)
$wxTaskQqCwTaskRelationItem = WxTaskQqCwTaskRelation::findOneEnabledByQqCwTaskId($taskEnabledItem->id);
if (isset($wxTaskQqCwTaskRelationItem)) {
WxAssetService::copyAssetErrorHandler($wxTaskQqCwTaskRelationItem->wx_task_id, $eventError);
}
}
15. After the posting task is successful/failed, insert the release log, and push the job to the source callback queue (asynchronous); the subsequent processing after the job of the source callback queue is successfully executed; the subsequent processing after the job of the source callback queue fails to execute. Edit \Common\Services\SourceCallbackService.php
* @since 1.0
*/
class SourceCallbackService extends Service
{
/**
* 发布任务成功/失败后，插入发布日志，将作业推送至来源回调队列(异步)
*
* @param array $channelAppTasks 渠道的应用的任务列表
* 格式如下：
* [
* [ // object
* 'id' => 18, // ID
* 'uuid' => '967f4948ee0211e8a99754ee75d2ebc1', // 渠道的应用的任务ID(UUID)
* 'channel_id' => 1, // 渠道ID
* 'channel_code' => 'qq', // 渠道代码，qq：企鹅号；wx：微信公众帐号
* 'channel_type_id' => 1, // 渠道的类型ID
* 'channel_type_code' => 'qq_cw', // 渠道的类型代码，qq_cw：企鹅号的内容网站应用；qq_tp：企鹅号的第三方服务平台应用；wx：微信公众帐号应用
* 'channel_app_source_id' => 6, // 渠道的应用的来源ID
* 'channel_app_source_uuid' => 'bba4e024eba111e89fa754ee75d2ebc1', // 渠道的应用的来源ID(UUID)
* 'task_id' => 18, // 任务ID
* 'status' => 1, // 状态，0：禁用；1：启用
* 'is_deleted' => 0, // 是否被删除，0：否；1：是
* 'created_at' => 1542855551, // 创建时间
* 'updated_at' => 1542855551, // 更新时间
* 'deleted_at' => 0, // 删除时间
* ],
* [ // object
* 'id' => 19, // ID
* 'uuid' => '52f10106ed5511e88f8354ee75d2ebc1', // 渠道的应用的任务ID(UUID)
* 'channel_id' => 1, // 渠道ID
* 'channel_code' => 'qq', // 渠道代码，qq：企鹅号；wx：微信公众帐号
* 'channel_type_id' => 1, // 渠道的类型ID
* 'channel_type_code' => 'qq_cw', // 渠道的类型代码，qq_cw：企鹅号的内容网站应用；qq_tp：企鹅号的第三方服务平台应用；wx：微信公众帐号应用
* 'channel_app_source_id' => 6, // 渠道的应用的来源ID
* 'channel_app_source_uuid' => 'bba4e024eba111e89fa754ee75d2ebc1', // 渠道的应用的来源ID(UUID)
* 'task_id' => 19, // 任务ID
* 'status' => 1, // 状态，0：禁用；1：启用
* 'is_deleted' => 0, // 是否被删除，0：否；1：是
* 'created_at' => 1542855551, // 创建时间
* 'updated_at' => 1542855551, // 更新时间
* 'deleted_at' => 0, // 删除时间
* ],
* ]
*
* @param int $code 代码
* @param string $message 说明
* @param array $datas 数据
* 格式如下：
* [
* [
* 'channel_app_source_uuid' => 'bba4e024eba111e89fa754ee75d2ebc1', // 渠道的应用的来源ID(UUID)
* 'channel_app_task_uuid' => '967f4948ee0211e8a99754ee75d2ebc1', // 渠道的应用的任务ID(UUID)
* 'channel_code' => 'qq', // 渠道代码，qq：企鹅号；wx：微信公众帐号
* 'channel_type_code' => 'qq_cw', // 渠道的类型代码，qq_cw：企鹅号的内容网站应用；qq_tp：企鹅号的第三方服务平台应用；wx：微信公众帐号应用
* 'channel_app_task_status' => 3, // 渠道的应用的任务状态，0：禁用；1：待发布；2：发布中；3：发布中(已失败)；4：审核中；5：未发布；6：已发布
* ],
* [
* 'channel_app_source_uuid' => 'bba4e024eba111e89fa754ee75d2ebc1', // 渠道的应用的来源ID(UUID)
* 'channel_app_task_uuid' => '52f10106ed5511e88f8354ee75d2ebc1', // 渠道的应用的任务ID(UUID)
* 'channel_code' => 'qq', // 渠道代码，qq：企鹅号；wx：微信公众帐号
* 'channel_type_code' => 'qq_cw', // 渠道的类型代码，qq_cw：企鹅号的内容网站应用；qq_tp：企鹅号的第三方服务平台应用；wx：微信公众帐号应用
* 'channel_app_task_status' => 3, // 渠道的应用的任务状态，0：禁用；1：待发布；2：发布中；3：发布中(已失败)；4：审核中；5：未发布；6：已发布
* ],
* ]
*
* @param int $status 状态，0：禁用；1：成功；2：失败
*
* @throws Exception execution failed
*/
public static function sourceCallbackAsync($channelAppTasks, $code, $message, $datas, $status)
{
// 循环创建 MySQL 模型(发布日志)
$pubLogData = [];
$time = time();
foreach ($channelAppTasks as $key => $channelAppTask) {
$pubLogData[] = [
'channel_id' => $channelAppTask['channel_id'],
'channel_code' => $channelAppTask['channel_code'],
'channel_type_id' => $channelAppTask['channel_type_id'],
'channel_type_code' => $channelAppTask['channel_type_code'],
'task_id' => $channelAppTask['task_id'],
'channel_app_task_id' => $channelAppTask['id'],
'channel_app_task_uuid' => $channelAppTask['uuid'],
'code' => $code,
'message' => $message,
'data' => Json::encode($datas[$key], 0),
'have_callback_number' => PubLog::HAVE_CALLBACK_NUMBER_DEFAULT,
'callback_status' => PubLog::CALLBACK_STATUS_NO,
'status' => $status,
'is_deleted' => PubLog::IS_DELETED_NO,
'created_at' => $time,
'updated_at' => $time,
'deleted_at' => PubLog::DELETED_AT_DEFAULT,
];
}
// 获取渠道的应用的任务ID值列表
$channelAppTaskIds = ArrayHelper::getColumn($pubLogData, 'channel_app_task_id');
// 基于多个渠道的应用的任务ID查找资源列表(发布日志)
$pubLogItems = PubLog::findAllByChannelAppTaskIds($channelAppTaskIds);
// 遍历资源列表，如果数据中已经存在，则销毁
if (!empty($pubLogItems)) {
$pubLogData = ArrayHelper::index($pubLogData, 'channel_app_task_id');
foreach ($pubLogItems as $pubLogItem) {
unset($pubLogData[$pubLogItem->channel_app_task_id]);
}
}
if (!empty($pubLogData)) {
// 批量创建资源
$pubLog = new PubLog();
$pubLog->createMultiple($pubLogData);
// 将任务发送到队列，通过标准工作人员进行处理
foreach ($pubLogData as $value) {
Yii::$app->sourceCallbackQueue->push(new SourceCallbackJob([
'channelAppTaskId' => $value['channel_app_task_id'],
]));
}
}
}
/**
* 来源回调队列的作业执行成功后的后续处理
*
* @param int $channelAppTaskId 渠道的应用的任务ID
* 格式如下：1
*/
public static function sourceCallbackExecHandler($channelAppTaskId)
{
// 基于渠道的应用的任务ID更新发布日志(场景：来源回调队列的作业执行成功后，可回调次数减 1；回调状态，1：成功)
PubLog::updateMultipleCallbackStatusSuccesByChannelAppTaskId($channelAppTaskId);
}
/**
* 来源回调队列的作业执行失败后的后续处理
*
* @param int $channelAppTaskId 渠道的应用的任务ID
* 格式如下：1
*
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
*/
public static function sourceCallbackErrorHandler($channelAppTaskId)
{
// 基于渠道的应用的任务ID更新发布日志(场景：来源回调队列的作业执行失败后，可回调次数减 1；回调状态，2：失败)
PubLog::updateMultipleCallbackStatusErrorByChannelAppTaskId($channelAppTaskId);
// 基于渠道的应用的任务ID查找单个数据模型(发布日志)
$pubLogItem = PubLogService::findModelByChannelAppTaskId($channelAppTaskId);
// 判断可回调次数，如果大于 0，将任务重新发送到来源回调队列
if ($pubLogItem->have_callback_number > 0) {
// 将任务发送到队列，通过标准工作人员进行处理(延时 10 分钟运行)
Yii::$app->sourceCallbackQueue->delay(Yii::$app->params['sourceCallbackQueue']['delay'])->push(new SourceCallbackJob([
'channelAppTaskId' => $channelAppTaskId,
]));
}
}
}
16. The run command obtains and executes the tasks in the loop (copy the resource file queue) until the queue is empty
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/run --verbose=1 --isolate=1 --color=0
2018-11-23 16:17:05 [pid: 140472] - Worker is started
2018-11-23 16:17:06 [1] common\jobs\CopyAssetJob (attempt: 1, pid: 140472) - Started
2018-11-23 16:17:06 [1] common\jobs\CopyAssetJob (attempt: 1, pid: 140472) - Error (0.274 s)
> yii\web\NotFoundHttpException: Source resource file: 0, does not exist
2018-11-23 16:17:06 [pid: 140472] - Worker is stopped (0:00:01)
17. The job execution of the copy of the resource file queue failed, the execution result is as expected, the publishing log has been inserted, and the job has been pushed to the source callback queue, as shown in Figure 1
Figure 1
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 1
PS E:\wwwroot\channel-pub-api> ./yii upload-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii pub-article-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 1
- delayed: 0
- reserved: 0
- done: 0
18. The run command obtains and executes the tasks in the loop (source callback queue) until the queue is empty
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/run --verbose=1 --isolate=1 --color=0
2018-11-23 16:20:16 [pid: 143548] - Worker is started
2018-11-23 16:20:16 [1] common\jobs\SourceCallbackJob (attempt: 1, pid: 143548) - Started
2018-11-23 16:20:17 [1] common\jobs\SourceCallbackJob (attempt: 1, pid: 143548) - Error (0.745 s)
> yii\httpclient\Exception: Curl error: #6 - Could not resolve host: www.source_callback_url.com
2018-11-23 16:20:17 [pid: 143548] - Worker is stopped (0:00:01)
19. The job execution of the source callback queue failed, the execution result is as expected, the release log has been updated, and the task ID of the channel-based application updates the release log (the number of callbacks is reduced by 1; the callback status, 2: failure); if the number of callbacks is greater than that 0. Resend the task to the source callback queue, and the delay is 1 minute to run (the delay time is set to 10 minutes in the production environment). Figure 2, Figure 3
Figure 2
Figure 3
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 0
- delayed: 1
- reserved: 0
- done: 1
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/run --verbose=1 --isolate=1 --color=0
2018-11-23 16:23:16 [pid: 141492] - Worker is started
2018-11-23 16:23:16 [2] common\jobs\SourceCallbackJob (attempt: 1, pid: 141492) - Started
2018-11-23 16:23:16 [2] common\jobs\SourceCallbackJob (attempt: 1, pid: 141492) - Error (0.195 s)
> yii\httpclient\Exception: Curl error: #6 - Could not resolve host: www.source_callback_url.com
2018-11-23 16:23:16 [pid: 141492] - Worker is stopped (0:00:00)
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 0
- delayed: 1
- reserved: 0
- done: 2
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/run --verbose=1 --isolate=1 --color=0
2018-11-23 16:25:16 [pid: 145080] - Worker is started
2018-11-23 16:25:16 [3] common\jobs\SourceCallbackJob (attempt: 1, pid: 145080) - Started
2018-11-23 16:25:16 [3] common\jobs\SourceCallbackJob (attempt: 1, pid: 145080) - Error (0.226 s)
> yii\httpclient\Exception: Curl error: #6 - Could not resolve host: www.source_callback_url.com
2018-11-23 16:25:16 [pid: 145080] - Worker is stopped (0:00:00)
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 3
20. Posthttp://api.channel-pub-api.localhost/qq/v1/articles/video?group_id=spider, the execution is successful, and the value of media_absolute_url is deliberately wrong, so as to test the subsequent processing of the job copying the resource file queue failure; specially let source_callback_url The value is correct, and the subsequent processing after the job of the test source callback queue is successfully executed
request body
{
"channel_app_source_uuids": ["bba4e024eba111e89fa754ee75d2ebc1"],
"source": "spider",
"source_uuid": "825e6d5e36468cc4bf536799ce3565cf",
"source_pub_user_id": 1,
"source_callback_url": "http://wjdev.chinamcloud.com:8609/cms/api/thirdPush/callBack",
"article_category_id": 226,
"title": "综艺节目 - 20181123 - 2",
"author": "综艺节目 - 20181123 - 2",
"source_article_id": 1,
"media_absolute_url": "http://127.0.0.1/channel-pub-api/storage/spider/videos/3d35e17a32fb48cfb76f39a1b1bf33ce_h264_1200k_mp4",
"tag": "综艺",
"apply": 0,
"desc": "综艺节目 - 20181123 - 2"
}
Response body
{
"code": 10000,
"message": "发布文章类型：视频(视频)的文章成功",
"data": [
{
"channel_id": 1,
"channel_code": "qq",
"channel_type_id": 1,
"channel_type_code": "qq_cw",
"channel_app_source_id": 6,
"channel_app_source_uuid": "bba4e024eba111e89fa754ee75d2ebc1",
"task_id": 20,
"status": 1,
"created_at": 1542961817,
"updated_at": 1542961817,
"uuid": "01c9b588eefa11e8a7ba54ee75d2ebc1",
"id": 20
}
]
}
21. Execute the SQL statement as follows:
SELECT * FROM `cpa_channel` WHERE (`code`='qq') AND (`is_deleted`=0)
SELECT * FROM `cpa_channel_app_source` WHERE (`uuid`='bba4e024eba111e89fa754ee75d2ebc1') AND (`is_deleted`=0)
SELECT * FROM `cpa_channel_type` WHERE (`code`='qq_cw') AND (`is_deleted`=0)
SELECT * FROM `cpa_qq_cw_app` WHERE (`channel_app_source_uuid`='bba4e024eba111e89fa754ee75d2ebc1') AND (`is_deleted`=0)
SELECT * FROM `cpa_article_type` WHERE (`code`='video') AND (`is_deleted`=0)
SELECT * FROM `cpa_qq_article_type` WHERE (`code`='multivideos') AND (`is_deleted`=0)
SELECT EXISTS(SELECT * FROM `cpa_article_category` WHERE (`cpa_article_category`.`id`=226) AND ((`is_deleted`=0) AND (`status`=1)))
SELECT * FROM `cpa_qq_article_category_multivideos` WHERE (`article_category_id`=226) AND (`is_deleted`=0)
INSERT INTO `cpa_task` (`group_id`, `source`, `source_uuid`, `source_pub_user_id`, `source_callback_url`, `channel_id`, `channel_code`, `channel_type_id`, `channel_type_code`, `status`, `created_at`, `updated_at`) VALUES ('spider', 'spider', '825e6d5e36468cc4bf536799ce3565cf', 1, 'http://wjdev.chinamcloud.com:8609/cms/api/thirdPush/callBack', 1, 'qq', 1, 'qq_cw', 1, 1542961817, 1542961817)
INSERT INTO `cpa_channel_app_task` (`channel_id`, `channel_code`, `channel_type_id`, `channel_type_code`, `channel_app_source_id`, `channel_app_source_uuid`, `task_id`, `status`, `created_at`, `updated_at`, `uuid`) VALUES (1, 'qq', 1, 'qq_cw', 6, 'bba4e024eba111e89fa754ee75d2ebc1', 20, 1, 1542961817, 1542961817, '01c9b588eefa11e8a7ba54ee75d2ebc1')
INSERT INTO `cpa_qq_cw_app_task` (`channel_app_task_id`, `channel_app_task_uuid`, `qq_cw_app_id`, `task_id`, `status`, `created_at`, `updated_at`) VALUES (20, '01c9b588eefa11e8a7ba54ee75d2ebc1', 5, 20, 1, 1542961817, 1542961817)
INSERT INTO `cpa_qq_article` (`group_id`, `article_category_id`, `title`, `author`, `source_article_id`, `qq_app_type`, `article_type_id`, `qq_article_type_id`, `qq_article_category_id`, `task_id`, `status`, `created_at`, `updated_at`) VALUES ('spider', 226, '综艺节目 - 20181123 - 2', '综艺节目 - 20181123 - 2', 1, 'cw', 3, 2, 2808, 20, 1, 1542961817, 1542961817)
INSERT INTO `cpa_qq_article_multivideos` (`media`, `tag`, `desc`, `apply`, `qq_article_id`, `category`, `md5`, `vid`, `task_id`, `status`, `created_at`, `updated_at`) VALUES ('', '综艺', '综艺节目 - 20181123 - 2', 0, 20, 2808, '', '', 20, 1, 1542961817, 1542961817)
INSERT INTO `cpa_asset` (`channel_id`, `channel_code`, `channel_type_id`, `channel_type_code`, `source`, `type`, `absolute_url`, `relative_path`, `size`, `task_id`, `channel_article_id`, `status`, `is_deleted`, `created_at`, `updated_at`, `deleted_at`) VALUES (1, 'qq', 1, 'qq_cw', 'spider', 'video', 'http://127.0.0.1/channel-pub-api/storage/spider/videos/3d35e17a32fb48cfb76f39a1b1bf33ce_h264_1200k_mp4', '', 0, 20, 20, 1, 0, 1542961817, 1542961817, 0)
22. View the status information of 4 queues
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/info --color=0
Jobs
- waiting: 1
- delayed: 0
- reserved: 0
- done: 1
PS E:\wwwroot\channel-pub-api> ./yii upload-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii pub-article-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 3
23. The run command obtains and executes the tasks in the loop (copy the resource file queue) until the queue is empty
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/run --verbose=1 --isolate=1 --color=0
2018-11-23 16:36:40 [pid: 146364] - Worker is started
2018-11-23 16:36:40 [2] common\jobs\CopyAssetJob (attempt: 1, pid: 146364) - Started
2018-11-23 16:36:41 [2] common\jobs\CopyAssetJob (attempt: 1, pid: 146364) - Error (0.180 s)
> yii\web\NotFoundHttpException: Source resource file: 0, does not exist
2018-11-23 16:36:41 [pid: 146364] - Worker is stopped (0:00:01)
24. The job execution of the copy of the resource file queue failed, the execution result is as expected, the publishing log has been inserted, and the job has been pushed to the source callback queue, as shown in Figure 4
Figure 4
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 2
PS E:\wwwroot\channel-pub-api> ./yii upload-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii pub-article-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 1
- delayed: 0
- reserved: 0
- done: 3
25. The run command obtains and executes the tasks in the loop (source callback queue) until the queue is empty
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/run --verbose=1 --isolate=1 --color=0
2018-11-23 16:38:53 [pid: 141652] - Worker is started
2018-11-23 16:38:54 [4] common\jobs\SourceCallbackJob (attempt: 1, pid: 141652) - Started
2018-11-23 16:38:54 [4] common\jobs\SourceCallbackJob (attempt: 1, pid: 141652) - Done (0.623 s)
2018-11-23 16:38:55 [pid: 141652] - Worker is stopped (0:00:02)
26. The job of the source callback queue is successfully executed, the execution result is in line with expectations, the release log has been updated, and the task ID of the channel-based application updates the release log (the number of callbacks is reduced by 1; the callback status, 1: success). As shown in Figure 5, Figure 6
Figure 5
Figure 6
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 4
27. Implementation of resource service (the video file of the content website application of Penguin is uploaded in sharding, and after the queue task is successfully executed, the corresponding service is called, otherwise, the release log is inserted). Edit \common\services\qqcwassetservice.php
* @since 1.0
*/
class QqCwAssetService extends Service
{
/**
* 复制资源文件队列的作业执行成功后的后续处理
*
* @param int $taskId 任务ID
* 格式如下：1
*
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws UnprocessableEntityHttpException 如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
* @throws \yii\base\Exception if the directory could not be created (i.e. php error due to parallel changes)
*/
public static function copyAssetExecHandler($taskId)
{
// 基于ID查找状态为启用的单个数据模型(任务)
$taskEnabledItem = TaskService::findModelEnabledById($taskId);
// 基于条件查找状态为启用的资源列表
$assetEnabledWhere = [
'channel_id' => $taskEnabledItem->channel_id,
'channel_type_id' => $taskEnabledItem->channel_type_id,
'type' => Asset::TYPE_VIDEO,
'task_id' => $taskEnabledItem->id,
];
$assetEnabledItems = Asset::findAllEnabledByWhere($assetEnabledWhere);
if (empty($assetEnabledItems)) {
} else {
// 企鹅号的内容网站应用的视频文件分片上传，队列任务执行成功后，调用相应服务，否则，插入发布日志(异步)
$assets = [];
foreach ($assetEnabledItems as $assetEnabledItem) {
$assets[] = [
'job_type' => UploadAssetJob::JOB_TYPE_VIDEO_MULTIPART,
'id' => $assetEnabledItem->id,
];
}
static::uploadAssetVideoMultipartAsync($taskId, $assets);
}
}
/**
* 复制资源文件队列的作业执行失败后的后续处理
*
* @param int $taskId 任务ID
* 格式如下：1
* @param object $eventError 事件错误
*
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws UnprocessableEntityHttpException 如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
* @throws \yii\base\Exception if the directory could not be created (i.e. php error due to parallel changes)
*/
public static function copyAssetErrorHandler($taskId, $eventError)
{
// 基于ID查找状态为启用的单个数据模型(任务)
$taskEnabledItem = TaskService::findModelEnabledById($taskId);
// 基于任务ID查找状态为启用的资源列表
$channelAppTaskEnabledItems = ChannelAppTask::findAllEnabledByTaskId($taskId);
if (empty($channelAppTaskEnabledItems)) {
throw new ServerErrorHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35021'), ['task_id' => $taskId])), 35021);
}
// 基于任务ID批量更新企鹅号的内容网站应用的任务(场景：复制资源文件队列的作业执行失败后，可发布次数减1，状态，3：发布中(已失败))
QqCwAppTask::updateMultiplePublishErrorByTaskId($taskId);
$pubLogDatas = [];
foreach ($channelAppTaskEnabledItems as $key => $channelAppTaskEnabledItem) {
// 基于渠道的应用的任务ID查找单个数据模型(企鹅号的内容网站应用的任务)
$qqCwAppTaskItem = QqCwAppTaskService::findModelByChannelAppTaskId($channelAppTaskEnabledItem->id);
$pubLogDatas[$key] = [
'channel_app_source_uuid' => $channelAppTaskEnabledItem->channel_app_source_uuid,
'channel_app_task_uuid' => $channelAppTaskEnabledItem->uuid,
'channel_code' => $channelAppTaskEnabledItem->channel_code,
'channel_type_code' => $channelAppTaskEnabledItem->channel_type_code,
'channel_app_task_status' => $qqCwAppTaskItem->status,
];
}
// 发布任务失败后，插入发布日志，将作业推送至来源回调队列(异步)
SourceCallbackService::sourceCallbackAsync($channelAppTaskEnabledItems, $eventError->getCode(), $eventError->getMessage(), $pubLogDatas, PubLog::STATUS_ERROR);
// 基于企鹅号的内容网站应用的任务ID查找状态为启用的单个资源(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)
$wxTaskQqCwTaskRelationItem = WxTaskQqCwTaskRelation::findOneEnabledByQqCwTaskId($taskEnabledItem->id);
if (isset($wxTaskQqCwTaskRelationItem)) {
WxAssetService::copyAssetErrorHandler($wxTaskQqCwTaskRelationItem->wx_task_id, $eventError);
}
}
/**
* 上传资源文件队列的作业执行成功后的后续处理
*
* @param int $assetId 资源ID
* 格式如下：1
*
* @param int $channelAppTaskId 渠道的应用的任务ID
* 格式如下：4
*
*/
public static function uploadAssetVideoMultipartExecHandler($assetId, $channelAppTaskId)
{
}
/**
* 上传资源文件队列的作业执行失败后的后续处理
*
* @param int $assetId 资源ID
* 格式如下：1
*
* @param int $channelAppTaskId 渠道的应用的任务ID
* 格式如下：4
*
* @param object $eventError 事件错误
*
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws UnprocessableEntityHttpException 如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
* @throws ServerErrorHttpException
* @throws \Throwable
*/
public static function uploadAssetVideoMultipartErrorHandler($assetId, $channelAppTaskId, $eventError)
{
// 基于ID查找状态为启用的单个数据模型(资源)
$assetEnabledItem = AssetService::findModelEnabledById($assetId);
if ($assetEnabledItem->type != Asset::TYPE_VIDEO) {
throw new ServerErrorHttpException(Yii::t('common/error', '35040'), 35040);
}
// 基于ID查找状态为启用的单个数据模型(渠道的应用的任务)
$channelAppTaskEnabledItem = ChannelAppTaskService::findModelEnabledById($channelAppTaskId);
// 基于渠道的应用的任务ID更新企鹅号的内容网站应用的任务(场景：上传资源文件队列的作业执行失败后，可发布次数减1，状态，3：发布中(已失败))
QqCwAppTask::updatePublishErrorByChannelAppTaskId($channelAppTaskEnabledItem->id);
$channelAppTaskEnabledItems[] = $channelAppTaskEnabledItem;
$pubLogDatas = [];
foreach ($channelAppTaskEnabledItems as $key => $channelAppTaskEnabledItem) {
// 基于渠道的应用的任务ID查找单个数据模型(企鹅号的内容网站应用的任务)
$qqCwAppTaskItem = QqCwAppTaskService::findModelByChannelAppTaskId($channelAppTaskEnabledItem->id);
$pubLogDatas[$key] = [
'channel_app_source_uuid' => $channelAppTaskEnabledItem->channel_app_source_uuid,
'channel_app_task_uuid' => $channelAppTaskEnabledItem->uuid,
'channel_code' => $channelAppTaskEnabledItem->channel_code,
'channel_type_code' => $channelAppTaskEnabledItem->channel_type_code,
'channel_app_task_status' => $qqCwAppTaskItem->status,
];
}
// 发布任务失败后，插入发布日志，将作业推送至来源回调队列(异步)
SourceCallbackService::sourceCallbackAsync($channelAppTaskEnabledItems, $eventError->getCode(), $eventError->getMessage(), $pubLogDatas, PubLog::STATUS_ERROR);
// 基于ID查找状态为启用的单个数据模型(任务)
$taskEnabledItem = TaskService::findModelEnabledById($assetEnabledItem->task_id);
// 基于企鹅号的内容网站应用的任务ID查找状态为启用的单个资源(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)
$wxTaskQqCwTaskRelationItem = WxTaskQqCwTaskRelation::findOneEnabledByQqCwTaskId($taskEnabledItem->id);
if (isset($wxTaskQqCwTaskRelationItem)) {
WxAssetService::qqCwUploadAssetVideoMultipartErrorHandler($wxTaskQqCwTaskRelationItem->wx_task_id, $eventError);
}
// 判断任务的渠道的类型代码
if ($taskEnabledItem->channel_type_code != ChannelType::CODE_QQ_CW) {
throw new ServerErrorHttpException(Yii::t('common/error', '35032'), 35032);
}
// 基于渠道的应用的任务ID查找单个数据模型(企鹅号的内容网站应用的任务)
$qqCwAppTaskItem = QqCwAppTaskService::findModelByChannelAppTaskId($channelAppTaskId);
// 企鹅号的内容网站应用的视频文件分片上传失败后的后续处理
$qqCwVideoMultipartUploadService = new QqCwVideoMultipartUploadService();
$result = $qqCwVideoMultipartUploadService->uploadErrorHandler($assetId, $qqCwAppTaskItem->id);
}
/**
* 企鹅号的内容网站应用的视频文件分片上传，队列任务执行成功后，调用相应服务，否则，插入发布日志(异步)
*
* @param int $taskId 任务ID
* 格式如下：1
*
* @param array $assets 多个资源ID
* 格式如下：
* [
* [
* 'job_type' => 'video_multipart', // 作业类型，video_multipart：视频文件分片
* 'id' => 2, // ID
* ],
* [
* 'job_type' => 'video_multipart', // 作业类型，video_multipart：视频文件分片
* 'id' => 4, // ID
* ],
* ]
*
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
*/
public static function uploadAssetVideoMultipartAsync($taskId, $assets)
{
// 基于任务ID查找状态为启用的资源列表
$channelAppTaskEnabledItems = ChannelAppTask::findAllEnabledByTaskId($taskId);
foreach ($channelAppTaskEnabledItems as $channelAppTaskEnabledItem) {
// 基于渠道的应用的任务ID查找单个数据模型(企鹅号的内容网站应用的任务)
$qqCwAppTaskItem = QqCwAppTaskService::findModelByChannelAppTaskId($channelAppTaskEnabledItem->id);
// 更新企鹅号的内容网站应用的任务状态，2：发布中
$qqCwAppTaskItem->status = QqCwAppTask::STATUS_PUBLISH;
$qqCwAppTaskItem->save();
// 将任务发送到队列，通过标准工作人员进行处理
Yii::$app->uploadAssetQueue->push(new UploadAssetJob([
'channelAppTaskId' => $channelAppTaskEnabledItem->id,
'assets' => $assets,
]));
}
}
/**
* 企鹅号的内容网站应用的视频文件分片上传(同步)
*
* @param int $assetId 资源ID
* 格式如下：1
*
* @param int $channelAppTaskId 渠道的应用的任务ID
* 格式如下：4
*
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws UnprocessableEntityHttpException 如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
* @throws ServerErrorHttpException
* @throws \Throwable
*/
public static function uploadAssetVideoMultipartSync($assetId, $channelAppTaskId)
{
// 基于ID查找状态为启用的单个数据模型(资源)
$assetEnabledItem = AssetService::findModelEnabledById($assetId);
if ($assetEnabledItem->type != Asset::TYPE_VIDEO) {
throw new ServerErrorHttpException(Yii::t('common/error', '35040'), 35040);
}
// 基于ID查找状态为启用的单个数据模型(渠道的应用的任务)
$channelAppTaskEnabledItem = ChannelAppTaskService::findModelEnabledById($channelAppTaskId);
// 基于ID查找状态为启用的单个数据模型(任务)
$taskEnabledItem = TaskService::findModelEnabledById($assetEnabledItem->task_id);
// 判断任务的渠道的类型代码
if ($taskEnabledItem->channel_type_code != ChannelType::CODE_QQ_CW) {
throw new ServerErrorHttpException(Yii::t('common/error', '35032'), 35032);
}
// 基于渠道的应用的任务ID查找单个数据模型(企鹅号的内容网站应用的任务)
$qqCwAppTaskItem = QqCwAppTaskService::findModelByChannelAppTaskId($channelAppTaskId);
// 基于ID查找状态为启用的单个数据模型(企鹅号的内容网站应用)
$qqCwAppEnabledItem = QqCwAppService::findModelEnabledById($qqCwAppTaskItem->qq_cw_app_id);
// 企鹅号的内容网站应用的视频文件分片上传
$qqCwVideoMultipartUploadService = new QqCwVideoMultipartUploadService();
$result = $qqCwVideoMultipartUploadService->upload($assetId, $qqCwAppTaskItem->id);
}
}
28. Implementation of the upload resource file queue job, edit \common\jobs\uploadassetjob.php
* @since 1.0
*/
class UploadAssetJob extends Job
{
const JOB_TYPE_VIDEO_MULTIPART = 'video_multipart'; //作业类型：视频文件分片
public $channelAppTaskId;
public $assets;
/*
* @throws UnprocessableEntityHttpException
* @throws ServerErrorHttpException 如果基于任务ID查找状态为启用的资源列表为空，将抛出 500 HTTP 异常
*/
public function execute($queue)
{
// 查找状态为启用的数据模型(渠道的类型)
$channelTypeEnabledItems = ChannelType::find()->isDeletedNo()->enabled()->all();
// 基于ID查找状态为启用的单个数据模型(渠道的应用的任务)
$channelAppTaskEnabledItem = ChannelAppTaskService::findModelEnabledById($this->channelAppTaskId);
// 基于ID查找状态为启用的单个数据模型(任务)
$taskEnabledItem = TaskService::findModelEnabledById($channelAppTaskEnabledItem->task_id);
// 基于任务ID查找状态为启用的资源列表
$assetEnabledItems = Asset::findAllEnabledByTaskId($taskEnabledItem->id);
if (empty($assetEnabledItems)) {
throw new ServerErrorHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35020'), ['task_id' => $taskEnabledItem->id])), 35020);
}
// 获取基于任务ID查找状态为启用的资源列表的id值列表
$assetEnabledIds = ArrayHelper::getColumn($assetEnabledItems, 'id');
// 不属于当前任务ID下的资源ID
$notBelongIds = [];
// 作业类型不支持的资源ID
$jobTypeNotSupportIds = [];
// 作业类型与渠道的类型代码不匹配的资源ID
$notMatchChannelTypeCodeIds = [];
$assets = $this->assets;
foreach ($this->assets as $assetKey => $asset) {
$assetJobType = $taskEnabledItem->channel_type_code . '_' . $asset['job_type'];
// 不属于当前任务ID下的资源ID
if (!in_array($asset['id'], $assetEnabledIds)) {
$notBelongIds[] = $asset['id'];
}
// 作业类型不支持的资源ID
if (!in_array($asset['job_type'], [self::JOB_TYPE_VIDEO_MULTIPART])) {
$jobTypeNotSupportIds[] = $assetJobType;
}
// 作业类型与渠道的类型代码不匹配的资源ID
$matchChannelTypeCode = false;
foreach ($channelTypeEnabledItems as $itemKey => $channelTypeEnabledItem) {
$pos = strpos($assetJobType, $channelTypeEnabledItem->code);
if ($pos !== false) {
$assets[$assetKey]['service_class'] = 'common\services\\' . str_replace(' ', '', ucwords(str_replace('_', ' ', $channelTypeEnabledItem->code))) . 'AssetService'; // 例：common\services\QqCwAssetService
$assets[$assetKey]['service_action'] = 'uploadAsset' . str_replace(' ', '', ucwords(str_replace('_', ' ', $asset['job_type']))) . 'Sync'; // 例：uploadAssetVideoMultipartSync
$matchChannelTypeCode = true;
break;
}
}
if (!$matchChannelTypeCode) {
$notMatchChannelTypeCodeIds[] = $assetJobType;
}
}
if (!empty($notBelongIds)) {
$notBelongIds = implode(",", $notBelongIds);
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35025'), ['not_belong_ids' => $notBelongIds, 'task_id' => $taskEnabledItem->id])), 35025);
}
if (!empty($jobTypeNotSupportIds)) {
$jobTypeNotSupportIds = implode(",", array_unique($jobTypeNotSupportIds));
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35026'), ['job_type_not_support_ids' => $jobTypeNotSupportIds])), 35026);
}
if (!empty($notMatchChannelTypeCodeIds)) {
$notMatchChannelTypeCodeIds = implode(",", array_unique($notMatchChannelTypeCodeIds));
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35027'), ['not_match_channel_type_code_ids' => $notMatchChannelTypeCodeIds])), 35027);
}
// 基于作业类型调用相应上传服务
foreach ($assets as $asset) {
$serviceAction = $asset['service_action'];
$asset['service_class']::$serviceAction($asset['id'], $this->channelAppTaskId);
}
}
}
29. The specific realization of the video file uploading of the content website application of the Penguin account, edit \common\services\qqcwVideoMultipartUploadService.php
* @since 1.0
*/
class QqCwVideoMultipartUploadService extends Service
{
/**
* HTTP请求，申请企鹅号的内容网站应用的视频文件分片上传的唯一事务ID
*
* @param array $data 数据
* 格式如下：
*
* [
* 'accessToken' => 'KCK0TIV8NDY44ONAEFI2QW', // 企鹅平台企鹅号应用授权调用凭据
* 'size' => 9135849, // 视频文件大小，单位(字节)
* 'md5' => 'd081c619ef7dc62eb2aa29c7c83c6f26', // 视频文件MD5值
* 'sha' => '28a1076b867bed8202df5b3f656b798148e58ced', // 视频文件SHA-1值
* ]
*
* @return array
* 格式如下：
*
* [
* 'transaction_id' => '780930255958621794', // 上传的唯一事务ID
* ]
*
* @throws ServerErrorHttpException
*/
public function httpUploadReady($data)
{
/* HTTP请求，申请企鹅号的内容网站应用的视频文件分片上传的唯一事务ID */
$httpQqApiVideo = new HttpQqApiVideo();
$uploadReady = $httpQqApiVideo->clientUploadReady($data);
if ($uploadReady === false) {
if ($httpQqApiVideo->hasErrors()) {
foreach ($httpQqApiVideo->getFirstErrors() as $message) {
$firstErrors = $message;
break;
}
throw new ServerErrorHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35042'), ['firstErrors' => $firstErrors])), 35042);
} elseif (!$httpQqApiVideo->hasErrors()) {
throw new ServerErrorHttpException('Penguin\'s content website application api HTTP requests fail for unknown reasons.');
}
}
return $uploadReady['data'];
}
/**
* HTTP请求，企鹅号的内容网站应用的视频文件分片上传
* @param array $data 数据
* 格式如下：
*
* [
* 'accessToken' => 'LQVHLUQDNEKIDBFARJ1OOA', // 企鹅平台企鹅号应用授权调用凭据
* 'transactionId' => '780930287703152921', // 上传的唯一事务ID
* 'mediatrunk' => 'E:/wwwroot/channel-pub-api/storage/channel-pub-api/videos/2018/10/27/1540632234.9842.66697370.mp4', // 视频 mediatrunk 文件
* 'startOffset' => 0, // 分片的起始位置(从0开始计数)
* ]
*
* @return array
* 格式如下：
*
* [
* 'end_offset' => 2198151, // 分片的结束位置
* 'start_offset' => 2198151, // 分片的起始位置
* 'transaction_id' => 780930255958621794, // 上传的唯一事务ID
* ]
*
* @throws ServerErrorHttpException
*/
public function httpUploadTrunk($data)
{
/* HTTP请求，企鹅号的内容网站应用的视频文件分片上传 */
$httpQqApiVideo = new HttpQqApiVideo();
$uploadTrunk = $httpQqApiVideo->clientUploadTrunk($data);
if ($uploadTrunk === false) {
if ($httpQqApiVideo->hasErrors()) {
foreach ($httpQqApiVideo->getFirstErrors() as $message) {
$firstErrors = $message;
break;
}
throw new ServerErrorHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35042'), ['firstErrors' => $firstErrors])), 35042);
} elseif (!$httpQqApiVideo->hasErrors()) {
throw new ServerErrorHttpException('Penguin\'s content website application api HTTP requests fail for unknown reasons.');
}
}
return $uploadTrunk['data'];
}
/**
* 企鹅号的内容网站应用的视频文件分片上传
*
* @param int $assetId 资源ID
* 格式如下：1
*
* @param int $qqCwAppTaskId 企鹅号的内容网站应用的任务ID
* 格式如下：6
*
* @throws ServerErrorHttpException
* @throws \Throwable
*/
public function upload($assetId, $qqCwAppTaskId)
{
// 基于ID查找状态为启用的单个数据模型(资源)
$assetEnabledItem = AssetService::findModelEnabledById($assetId);
// 基于ID查找状态为启用的单个数据模型(任务)
$taskEnabledItem = TaskService::findModelEnabledById($assetEnabledItem->task_id);
// 基于ID查找状态为发布中的单个数据模型(企鹅号的内容网站应用的任务)
$qqCwAppTaskPublishItem = QqCwAppTaskService::findModelPublishById($qqCwAppTaskId);
// 基于ID查找状态为启用的单个数据模型(企鹅号的内容网站应用)
$qqCwAppEnabledItem = QqCwAppService::findModelEnabledById($qqCwAppTaskPublishItem->qq_cw_app_id);
// 基于企鹅号的内容网站应用ID获取有效的 Access Token
$qqCwAccessTokenService = new QqCwAccessTokenService();
$accessTokenValidity = $qqCwAccessTokenService->getAccessTokenValidityByQqCwAppId($qqCwAppEnabledItem->id);
// 基于资源ID、企鹅号的应用的任务ID获取企鹅号的视频文件分片上传的单个数据模型
$qqVideoMultipartUploadItem = $this->getModelByAssetIdAndQqAppTaskId($assetId, $qqCwAppTaskPublishItem->id);
$data = [
'assetId' => $qqVideoMultipartUploadItem->asset_id,
'qqAppTaskId' => $qqVideoMultipartUploadItem->qq_app_task_id,
'qqAppId' => $qqVideoMultipartUploadItem->qq_app_id,
'qqAppType' => $qqVideoMultipartUploadItem->qq_app_type,
'size' => $qqVideoMultipartUploadItem->size,
'md5' => $qqVideoMultipartUploadItem->md5,
'sha' => $qqVideoMultipartUploadItem->sha,
'transactionId' => (string) $qqVideoMultipartUploadItem->transaction_id,
'mediatrunk' => $qqVideoMultipartUploadItem->mediatrunk,
'startOffset' => $qqVideoMultipartUploadItem->start_offset,
'endOffset' => $qqVideoMultipartUploadItem->end_offset,
'vid' => $qqVideoMultipartUploadItem->vid,
'status' => $qqVideoMultipartUploadItem->status,
];
// 文件切片
AssetService::cut(Yii::$app->params['channelPubApi']['asset'][$assetEnabledItem->type]['basePath'] . $qqVideoMultipartUploadItem->mediatrunk, HttpQqApiVideo::CUT_SIZE);
// 获取需要切片的文件的路径信息
$pathInfo = pathinfo(Yii::$app->params['channelPubApi']['asset'][$assetEnabledItem->type]['basePath'] . $qqVideoMultipartUploadItem->mediatrunk);
// 判断分片的起始位置与分片的结束位置是否等于视频文件大小，如果相等则中断分片上传，否则继续执行分片上传
$i = 0;
while ($qqVideoMultipartUploadItem->start_offset != $qqVideoMultipartUploadItem->size && $qqVideoMultipartUploadItem->end_offset != $qqVideoMultipartUploadItem->size) {
// file_put_contents('E:/wwwroot/channel-pub-api/qq/runtime/while_' . $assetId . '_' . $qqCwAppId . '_' . $qqVideoMultipartUploadItem->start_offset . '_' . $qqVideoMultipartUploadItem->end_offset . '_' . time() . '.txt', $assetId);
// HTTP请求，企鹅号的内容网站应用的视频文件分片上传
$httpUploadTrunkData = [
'accessToken' => $accessTokenValidity->access_token,
'transactionId' => $qqVideoMultipartUploadItem->transaction_id,
'mediatrunk' => $pathInfo['dirname'] . '/' . $pathInfo['filename'] . '_' . $i . '.' . $pathInfo['extension'],
'startOffset' => $qqVideoMultipartUploadItem->start_offset,
];
$uploadTrunkData = $this->httpUploadTrunk($httpUploadTrunkData);
// 基于资源ID、企鹅号的内容网站应用ID插入/更新数据至企鹅号的内容网站应用的视频文件分片上传
$data['startOffset'] = $uploadTrunkData['start_offset'];
$data['endOffset'] = $uploadTrunkData['end_offset'];
if ($uploadTrunkData['start_offset'] != $qqVideoMultipartUploadItem->size && $uploadTrunkData['end_offset'] != $qqVideoMultipartUploadItem->size) {
$data['status'] = QqVideoMultipartUpload::STATUS_UPLOADING;
} else {
// HTTP请求，基于上传的唯一事务ID获取事务信息
$qqTransactionService = new QqTransactionService();
$qqTransactionServiceHttpTransactionInfoData = [
'accessToken' => $accessTokenValidity->access_token,
'transactionId' => $qqVideoMultipartUploadItem->transaction_id,
];
$qqTransactionServiceHttpTransactionInfoResult = $qqTransactionService->httpTransactionInfo($qqTransactionServiceHttpTransactionInfoData);
// 创建企鹅号的事务
$qqTransaction = new QqTransaction();
$qqTransaction->attributes = [
'group_id' => $taskEnabledItem->group_id,
'qq_app_task_id' => $qqVideoMultipartUploadItem->qq_app_task_id,
'qq_app_id' => $qqVideoMultipartUploadItem->qq_app_id,
'qq_app_type' => $qqVideoMultipartUploadItem->qq_app_type,
'qq_article_id' => 0,
'qq_video_multipart_upload_id' => $qqVideoMultipartUploadItem->id,
'transaction_id' => $qqVideoMultipartUploadItem->transaction_id,
'type' => $qqTransactionService::getTypeByHttpQqApiTransactionType($qqTransactionServiceHttpTransactionInfoResult['transaction_type']),
'transaction_ctime' => $qqTransactionServiceHttpTransactionInfoResult['transaction_ctime'],
'ext_err' => $qqTransactionServiceHttpTransactionInfoResult['ext_err'],
'transaction_err_msg' => $qqTransactionServiceHttpTransactionInfoResult['transaction_err_msg'],
'article_abstract' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_abstract'],
'article_type' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_type'],
'article_type_code' => '',
'article_url' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_url'],
'article_imgurl' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_imgurl'],
'article_title' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_title'],
'article_pub_flag' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_pub_flag'],
'article_pub_time' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_pub_time'],
'article_video_title' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_video_info']['title'],
'article_video_desc' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_video_info']['desc'],
'article_video_type' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_video_info']['type'],
'article_video_vid' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_video_info']['vid'],
'task_id' => $assetEnabledItem->task_id,
'status' => QqTransaction::STATUS_PROCESSING,
];
$qqTransactionServiceCreateResult = $qqTransactionService->create($qqTransaction);
if ($qqTransactionServiceCreateResult['status'] === false) {
throw new ServerErrorHttpException($qqTransactionServiceCreateResult['message'], $qqTransactionServiceCreateResult['code']);
}
$data['status'] = QqVideoMultipartUpload::STATUS_UPLOADED;
}
$qqVideoMultipartUploadService = new QqVideoMultipartUploadService();
$result = $qqVideoMultipartUploadService->saveModelByData($data);
if ($result['status'] === false) {
throw new ServerErrorHttpException($result['message'], $result['code']);
}
// 基于资源ID、企鹅号的应用的任务ID获取企鹅号的视频文件分片上传的单个数据模型
$qqVideoMultipartUploadItem = $this->getModelByAssetIdAndQqAppTaskId($assetId, $qqCwAppTaskPublishItem->id);
$i++;
}
}
/**
* 企鹅号的内容网站应用的视频文件分片上传失败后的后续处理
*
* @param int $assetId 资源ID
* 格式如下：1
*
* @param int $qqCwAppTaskId 企鹅号的应用的任务ID
* 格式如下：6
*
* @throws ServerErrorHttpException
* @throws \Throwable
*/
public function uploadErrorHandler($assetId, $qqCwAppTaskId)
{
// 基于资源ID、企鹅号的应用的任务ID查找单个数据模型(企鹅号的内容网站应用的视频文件分片上传)
$qqVideoMultipartUploadItem = QqVideoMultipartUpload::find()->where(['asset_id' => $assetId, 'qq_app_task_id' => $qqCwAppTaskId, 'qq_app_type' => QqArticle::QQ_APP_TYPE_CW])->isDeletedNo()->one();
if (isset($qqVideoMultipartUploadItem)) {
$data = [
'assetId' => $qqVideoMultipartUploadItem->asset_id,
'qqAppTaskId' => $qqVideoMultipartUploadItem->qq_app_task_id,
'qqAppId' => $qqVideoMultipartUploadItem->qq_app_id,
'qqAppType' => $qqVideoMultipartUploadItem->qq_app_type,
'size' => $qqVideoMultipartUploadItem->size,
'md5' => $qqVideoMultipartUploadItem->md5,
'sha' => $qqVideoMultipartUploadItem->sha,
'transactionId' => (string) $qqVideoMultipartUploadItem->transaction_id,
'mediatrunk' => $qqVideoMultipartUploadItem->mediatrunk,
'startOffset' => $qqVideoMultipartUploadItem->start_offset,
'endOffset' => $qqVideoMultipartUploadItem->end_offset,
'vid' => $qqVideoMultipartUploadItem->vid,
'status' => $qqVideoMultipartUploadItem->status,
];
// 判断分片的起始位置与分片的结束位置是否等于视频文件大小，如果不相等则修改为，3：上传中(已失败)
if ($qqVideoMultipartUploadItem->start_offset != $qqVideoMultipartUploadItem->size || $qqVideoMultipartUploadItem->end_offset != $qqVideoMultipartUploadItem->size) {
$data['status'] = QqVideoMultipartUpload::STATUS_UPLOADING_ERROR;
$qqVideoMultipartUploadService = new QqVideoMultipartUploadService();
$result = $qqVideoMultipartUploadService->saveModelByData($data);
if ($result['status'] === false) {
throw new ServerErrorHttpException($result['message'], $result['code']);
}
}
}
}
/**
* 基于资源ID、企鹅号的应用的任务ID获取企鹅号的视频文件分片上传的单个数据模型
*
* @param int $assetId 资源ID
* 格式如下：1
*
* @param int $qqAppTaskId 企鹅号的应用的任务ID
* 格式如下：6
*
* @return object
* 格式如下：
*
* [
* 'id' => 1, // ID
* 'qq_app_task_id' => 2, // 企鹅号的应用的任务ID
* 'qq_app_id' => 6, // 企鹅号的应用ID
* 'qq_app_type' => 'cw', // 企鹅号的应用类型，cw：内容网站应用；tp：第三方服务平台应用
* 'channel_app_source_id' => 8, // 渠道的应用的来源ID
* 'channel_app_source_uuid' => '29e3c876d82811e8a95954ee75d2ebc1', // 渠道的应用的来源ID(UUID)
* 'grant_type' => 'clientcredentials', // 授权类型，clientcredentials：企鹅号应用授权模式
* 'access_token' => 'LR7WL2MAMTI8DFMIPSGEZG', // 企鹅平台企鹅号应用授权调用凭据
* 'expires_in' => 7200, // 授权方接口调用凭据有效期，单位(秒)
* 'expires_at' => 1540797813, // 授权方接口调用凭据有效截止时间
* 'openid' => '9476dfbaaf799033718b4016f01f9590', // 企鹅平台企鹅号应用对应的企鹅媒体用户唯一标识
* 'status' => 1, // 状态，0：禁用；1：启用
* 'is_deleted' => 0, // 是否被删除，0：否；1：是
* 'created_at' => 1540790913, // 创建时间
* 'updated_at' => 1540790913, // 更新时间
* 'deleted_at' => 0, // 删除时间
* ]
*
* @throws ServerErrorHttpException
* @throws \Throwable
*/
public function getModelByAssetIdAndQqAppTaskId($assetId, $qqAppTaskId)
{
// 基于资源ID、企鹅号的应用的任务ID、企鹅号的应用类型，cw：内容网站应用查找单个数据模型(企鹅号的内容网站应用的视频文件分片上传)
$qqVideoMultipartUploadItem = QqVideoMultipartUpload::find()->where(['asset_id' => $assetId, 'qq_app_task_id' => $qqAppTaskId, 'qq_app_type' => QqArticle::QQ_APP_TYPE_CW])->isDeletedNo()->one();
// 返回模型
if (isset($qqVideoMultipartUploadItem)) {
return $qqVideoMultipartUploadItem;
}
// 基于ID查找状态为发布中的单个数据模型(企鹅号的内容网站应用的任务)
$qqCwAppTaskPublishItem = QqCwAppTaskService::findModelPublishById($qqAppTaskId);
// 基于ID查找状态为启用的单个数据模型(企鹅号的内容网站应用)
$qqCwAppEnabledItem = QqCwAppService::findModelEnabledById($qqCwAppTaskPublishItem->qq_cw_app_id);
// 基于ID查找状态为启用的单个数据模型(资源)
$assetEnabledItem = AssetService::findModelEnabledById($assetId);
// 基于企鹅号的内容网站应用ID获取有效的 Access Token
$qqCwAccessTokenService = new QqCwAccessTokenService();
$accessTokenValidity = $qqCwAccessTokenService->getAccessTokenValidityByQqCwAppId($qqCwAppEnabledItem->id);
// 渠道发布的资源文件的绝对路径
$assetAbsolutePath = Yii::$app->params['channelPubApi']['asset'][$assetEnabledItem->type]['basePath'] . $assetEnabledItem->relative_path;
$assetMd5 = md5_file($assetAbsolutePath);
$assetSha = sha1_file($assetAbsolutePath);
// HTTP请求，申请企鹅号的内容网站应用的视频文件分片上传的唯一事务ID
$httpUploadReadyData = [
'accessToken' => $accessTokenValidity->access_token,
'size' => $assetEnabledItem->size,
'md5' => $assetMd5,
'sha' => $assetSha,
];
$uploadReadyData = $this->httpUploadReady($httpUploadReadyData);
// 基于资源ID、企鹅号的内容网站应用ID插入/更新数据至企鹅号的内容网站应用的视频文件分片上传
$data = [
'assetId' => $assetId,
'qqAppTaskId' => $qqAppTaskId,
'qqAppId' => $qqCwAppEnabledItem->id,
'qqAppType' => QqArticle::QQ_APP_TYPE_CW,
'size' => $assetEnabledItem->size,
'md5' => $assetMd5,
'sha' => $assetSha,
'transactionId' => (string) $uploadReadyData['transaction_id'],
'mediatrunk' => $assetEnabledItem->relative_path,
'startOffset' => 0,
'endOffset' => 0,
'vid' => '',
'status' => QqVideoMultipartUpload::STATUS_WAIT_UPLOAD,
];
$qqVideoMultipartUploadService = new QqVideoMultipartUploadService();
$result = $qqVideoMultipartUploadService->saveModelByData($data);
if ($result['status'] === false) {
throw new ServerErrorHttpException($result['message'], $result['code']);
}
return $result['data'];
}
}
30. Access token authorized by Penguin, edit \common\logics\http\qq_auth\accesstoken.php
* @since 1.0
*/
class AccessToken extends Model
{
/**
* HTTP请求，企鹅号的内容网站应用通过 Client ID 和 Client Secret 获取 Access Token
* @param array $data 数据
* 格式如下：
*
* [
* 'grantType' => 'clientcredentials', // 授权类型，clientcredentials：企鹅号应用授权模式
* 'clientId' => '41e05276490ed0936a7c947cf82cf285', // Client ID
* 'clientSecret' => '3a9949ddccf861c3993bad2e21adbae0e863d618', // Client Secret
* ]
*
* @return array|false
*
* 格式如下：
*
* 企鹅号的内容网站应用授权的 Access Token
* [
* 'message' => '', // 说明
* 'data' => [ // 数据
* 'access_token' => 'F2RM000PNSU9Q38L8NC_QQ', // 企鹅平台企鹅号应用授权调用凭据
* 'expires_in' => 7200, // 授权方接口调用凭据有效期，单位(秒)
* 'openid' => '9476dfbaaf799033718b4016f01f9590', // 企鹅平台企鹅号应用对应的企鹅媒体用户唯一标识
* ],
* ]
*
* 失败(将错误保存在 [[yii\base\Model::errors]] 属性中)
* false
*
* @throws ServerErrorHttpException 如果响应状态码不等于20x
*/
public function clientAccessToken($data)
{
$response = Yii::$app->qqAuthHttp->createRequest()
->setMethod('post')
->setUrl('accesstoken')
->setData([
'grant_type' => $data['grantType'],
'client_id' => $data['clientId'],
'client_secret' => $data['clientSecret'],
])
->send();
// 检查响应状态码是否等于20x
if ($response->isOk) {
// 检查业务逻辑是否成功
if ($response->data['code'] === '0') {
$responseData = ['message' => '', 'data' => $response->data['data']];
return $responseData;
} else {
$this->addError('id', $response->data['msg']);
return false;
}
} else {
throw new ServerErrorHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35038'), ['statusCode' => $response->getStatusCode()])), 35038);
}
}
}
31. Video implementation of the Penguin interface, edit \common\logics\http\qq_api\video.php
* @since 1.0
*/
class Video extends Model
{
const CUT_SIZE = 104857600; //视频分片上传的切片大小：100M
/**
* HTTP请求，申请企鹅号的内容网站应用的视频文件分片上传的唯一事务ID
*
* @param array $data 数据
* 格式如下：
* [
* 'accessToken' => 'KCK0TIV8NDY44ONAEFI2QW', // 企鹅平台企鹅号应用授权调用凭据
* 'size' => 9135849, // 视频文件大小，单位(字节)
* 'md5' => 'd081c619ef7dc62eb2aa29c7c83c6f26', // 视频文件MD5值
* 'sha' => '28a1076b867bed8202df5b3f656b798148e58ced', // 视频文件SHA-1值
* ]
*
* @return array|false
* 格式如下：
* 企鹅号的内容网站应用的视频文件分片上传的唯一事务ID
* [
* 'message' => '', // 说明
* 'data' => [ // 数据
* 'transaction_id' => '780930255958621794', // 上传的唯一事务ID
* ],
* ]
*
* 失败(将错误保存在 [[yii\base\Model::errors]] 属性中)
* false
*
* @throws ServerErrorHttpException 如果响应状态码不等于20x
*/
public function clientUploadReady($data)
{
$response = Yii::$app->qqApiHttps->createRequest()
->setMethod('post')
->setUrl('video/clientuploadready')
->setData([
'access_token' => $data['accessToken'],
'size' => $data['size'],
'md5' => $data['md5'],
'sha' => $data['sha'],
])
->send();
// file_put_contents('E:/wwwroot/channel-pub-api/qq/runtime/client-upload-ready_' . $data['size'] . '_' . time() . '.txt', $response->data['data']['transaction_id']);
// 检查响应状态码是否等于20x
if ($response->isOk) {
// 检查业务逻辑是否成功
if ($response->data['code'] === 0) {
$responseData = ['message' => '', 'data' => $response->data['data']];
return $responseData;
} else {
$this->addError('id', $response->data['msg']);
return false;
}
} else {
throw new ServerErrorHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35041'), ['statusCode' => $response->getStatusCode()])), 35041);
}
}
/**
* HTTP请求，企鹅号的内容网站应用的视频文件分片上传
*
* @param array $data 数据
* 格式如下：
* [
* 'accessToken' => 'LQVHLUQDNEKIDBFARJ1OOA', // 企鹅平台企鹅号应用授权调用凭据
* 'transactionId' => '780930287703152921', // 上传的唯一事务ID
* 'mediatrunk' => 'E:/wwwroot/channel-pub-api/storage/channel-pub-api/videos/2018/10/27/1540632234.9842.66697370.mp4', // 视频 mediatrunk 文件
* 'startOffset' => 0, // 分片的起始位置(从0开始计数)
* ]
*
* @return array|false
* 格式如下：
* 企鹅号的内容网站应用的视频文件分片上传
* [
* 'message' => '', // 说明
* 'data' => [ // 数据
* 'end_offset' => 2198151, // 分片的结束位置
* 'start_offset' => 2198151, // 分片的起始位置
* 'transaction_id' => 780930255958621794, // 上传的唯一事务ID
* ],
* ]
*
* 失败(将错误保存在 [[yii\base\Model::errors]] 属性中)
* false
*
* @throws ServerErrorHttpException 如果响应状态码不等于20x
*/
public function clientUploadTrunk($data)
{
$response = Yii::$app->qqApiHttp->createRequest()
->setMethod('post')
->setUrl('video/clientuploadtrunk?access_token=' . $data['accessToken'] . '&transaction_id=' . $data['transactionId'] . '&start_offset=' . $data['startOffset'])
->addFile('mediatrunk', $data['mediatrunk'])
->send();
// file_put_contents('E:/wwwroot/channel-pub-api/qq/runtime/client-upload-trunk_' . $data['transactionId'] . '_' . $data['startOffset'] . '_' . time() . '.txt', $response->data['code']);
// 检查响应状态码是否等于20x
if ($response->isOk) {
// 检查业务逻辑是否成功
if ($response->data['code'] === 0) {
$responseData = ['message' => '', 'data' => $response->data['data']];
return $responseData;
} elseif ($response->data['code'] === 40027) { // 无效的事务ID
$this->addError('id', $response->data['code']);
return false;
} else {
$this->addError('id', $response->data['msg']);
return false;
}
} else {
throw new ServerErrorHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35041'), ['statusCode' => $response->getStatusCode()])), 35041);
}
}
}
32. Transaction implementation of the Penguin interface, edit \common\logics\http\qq_api\transaction.php
* @since 1.0
*/
class Transaction extends Model
{
const STATUS_SUCCESS = '成功'; //状态：成功
const STATUS_ERROR = '失败'; //状态：失败
const STATUS_PROCESSING = '处理中'; //状态：处理中
const TYPE_ARTICLE = '文章'; //类型：文章
const TYPE_VIDEO = '视频'; //类型：视频
const ARTICLE_TYPE_NORMAL = '普通文章'; //文章类型：普通文章
const ARTICLE_TYPE_IMAGES = '图文文章'; //文章类型：图文文章
const ARTICLE_TYPE_MULTIVIDEOS = '视频文章'; //文章类型：视频文章
const ARTICLE_TYPE_LIVE = '直播文章'; //文章类型：直播文章
const ARTICLE_TYPE_RTMP_LIVE = 'RTMP直播文章'; //文章类型：RTMP直播文章
const ARTICLE_PUB_FLAG_PUBLISHED = '发布成功'; //文章发布状态：发布成功
const ARTICLE_PUB_FLAG_UNPUBLISHED = '未发布'; //文章发布状态：未发布
const ARTICLE_PUB_FLAG_REVIEW = '审核中'; //文章发布状态：审核中
/**
* HTTP请求，基于上传的唯一事务ID获取事务信息
*
* @param array $data 数据
* 格式如下：
* [
* 'accessToken' => 'LQVHLUQDNEKIDBFARJ1OOA', // 企鹅平台企鹅号应用授权调用凭据
* 'transactionId' => '780931016953455275', // 上传的唯一事务ID
* ]
*
* @return array|false
* 格式如下：
* 企鹅号的内容网站应用的视频文件分片上传的唯一事务ID
* [
* 'message' => 'SUCCESS', // 说明
* 'data' => [ // 数据
* 'transaction_id' => '780931016953455275', // 唯一事务id
* 'transaction_status' => '处理中', // 事务处理状态，取值：成功，失败，处理中
* 'ext_err' => '', //
* 'transaction_err_msg' => '', //
* 'transaction_type' => '视频', // 事务类型，取值：文章，视频
* 'vid' => 'd0776lmbvso', // 视频文件唯一标示ID
* 'transaction_ctime' => '2018-10-31 19:49:43', // 事务创建时间
* 'article_info' => [ // 文章信息字段，当事务类型为文章时候有此内容
* 'article_title' => '', // 文章标题
* 'article_type' => '', // 文章类型，取值：普通文章，图文文章，视频文章，直播文章，RTMP直播文章
* 'article_abstract' => '', // 文章摘要
* 'article_imgurl' => '', // 文章封面图
* 'article_pub_flag' => '', // 文章发布状态，取值：未发布，发布成功，审核中
* 'article_pub_time' => '', // 文章发布时间
* 'article_id' => '', // 上传的唯一事务ID
* 'article_url' => '', // 文章快报链接
* 'article_video_info' => [ // 视频文章信息字段，有此内容
* 'vid' => '', // 视频唯一id
* 'title' => '', // 视频标题
* 'desc' => '', // 视频描述
* 'type' => '', // 类型，视频
* ],
* 'article_pid' => '', //
* ],
* ],
* ]
*
* 失败(将错误保存在 [[yii\base\Model::errors]] 属性中)
* false
*
* @throws ServerErrorHttpException 如果响应状态码不等于20x
*/
public function clientInfo($data)
{
$response = Yii::$app->qqApiHttps->createRequest()
->setMethod('get')
->setUrl('transaction/infoclient')
->setData([
'access_token' => $data['accessToken'],
'transaction_id' => $data['transactionId'],
])
->send();
// file_put_contents('E:/wwwroot/channel-pub-api/qq/runtime/client-info_' . $data['transactionId'] . time() . '.txt', $response->data['code']);
// 检查响应状态码是否等于20x
if ($response->isOk) {
// 检查业务逻辑是否成功
if ($response->data['code'] === 0) {
$responseData = ['message' => $response->data['msg'], 'data' => $response->data['data']];
return $responseData;
} else {
$this->addError('id', $response->data['msg']);
return false;
}
} else {
throw new ServerErrorHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35041'), ['statusCode' => $response->getStatusCode()])), 35041);
}
}
}
33. Implementation of the queue (upload resource file queue) event handler, edit \common\components\queue\UploadAssetEventHandler.php
* @since 1.0
*/
class UploadAssetEventHandler extends Component
{
/**
* @param ExecEvent $event
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws UnprocessableEntityHttpException 如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
* @throws ServerErrorHttpException 如果基于任务ID查找状态为启用的资源列表为空，将抛出 500 HTTP 异常
*/
public static function afterExec(ExecEvent $event)
{
$channelAppTaskId = $event->job->channelAppTaskId;
// 基于ID查找状态为启用的单个数据模型(渠道的应用的任务)
$channelAppTaskEnabledItem = ChannelAppTaskService::findModelEnabledById($channelAppTaskId);
// 查找状态为启用的数据模型(渠道的类型)
$channelTypeEnabledItems = ChannelType::find()->isDeletedNo()->enabled()->all();
// 基于ID查找状态为启用的单个数据模型(任务)
$taskEnabledItem = TaskService::findModelEnabledById($channelAppTaskEnabledItem->task_id);
// 基于任务ID查找状态为启用的资源列表
$assetEnabledItems = Asset::findAllEnabledByTaskId($taskEnabledItem->id);
if (empty($assetEnabledItems)) {
throw new ServerErrorHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35020'), ['task_id' => $taskEnabledItem->id])), 35020);
}
// 获取基于任务ID查找状态为启用的资源列表的id值列表
$assetEnabledIds = ArrayHelper::getColumn($assetEnabledItems, 'id');
// 不属于当前任务ID下的资源ID
$notBelongIds = [];
// 作业类型不支持的资源ID
$jobTypeNotSupportIds = [];
// 作业类型与渠道的类型代码不匹配的资源ID
$notMatchChannelTypeCodeIds = [];
$assets = $event->job->assets;
foreach ($event->job->assets as $assetKey => $asset) {
$assetJobType = $taskEnabledItem->channel_type_code . '_' . $asset['job_type'];
// 不属于当前任务ID下的资源ID
if (!in_array($asset['id'], $assetEnabledIds)) {
$notBelongIds[] = $asset['id'];
}
// 作业类型不支持的资源ID
if (!in_array($asset['job_type'], [UploadAssetJob::JOB_TYPE_VIDEO_MULTIPART])) {
$jobTypeNotSupportIds[] = $assetJobType;
}
// 作业类型与渠道的类型代码不匹配的资源ID
$matchChannelTypeCode = false;
foreach ($channelTypeEnabledItems as $itemKey => $channelTypeEnabledItem) {
$pos = strpos($assetJobType, $channelTypeEnabledItem->code);
if ($pos !== false) {
$assets[$assetKey]['service_class'] = 'common\services\\' . str_replace(' ', '', ucwords(str_replace('_', ' ', $channelTypeEnabledItem->code))) . 'AssetService'; // 例：common\services\QqCwAssetService
$assets[$assetKey]['service_action'] = 'uploadAsset' . str_replace(' ', '', ucwords(str_replace('_', ' ', $asset['job_type']))) . 'ExecHandler'; // 例：uploadAssetVideoMultipartExecHandler
$matchChannelTypeCode = true;
break;
}
}
if (!$matchChannelTypeCode) {
$notMatchChannelTypeCodeIds[] = $assetJobType;
}
}
if (!empty($notBelongIds)) {
$notBelongIds = implode(",", $notBelongIds);
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35025'), ['not_belong_ids' => $notBelongIds, 'task_id' => $taskEnabledItem->id])), 35025);
}
if (!empty($jobTypeNotSupportIds)) {
$jobTypeNotSupportIds = implode(",", array_unique($jobTypeNotSupportIds));
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35026'), ['job_type_not_support_ids' => $jobTypeNotSupportIds])), 35026);
}
if (!empty($notMatchChannelTypeCodeIds)) {
$notMatchChannelTypeCodeIds = implode(",", array_unique($notMatchChannelTypeCodeIds));
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35027'), ['not_match_channel_type_code_ids' => $notMatchChannelTypeCodeIds])), 35027);
}
// 基于作业类型调用相应服务进行后续处理
foreach ($assets as $asset) {
$serviceAction = $asset['service_action'];
$asset['service_class']::$serviceAction($asset['id'], $channelAppTaskId);
}
}
/**
* @param ExecEvent $event
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws UnprocessableEntityHttpException 如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
* @throws ServerErrorHttpException 如果基于任务ID查找状态为启用的资源列表为空，将抛出 500 HTTP 异常
*/
public static function afterError(ExecEvent $event)
{
$channelAppTaskId = $event->job->channelAppTaskId;
// 基于ID查找状态为启用的单个数据模型(渠道的应用的任务)
$channelAppTaskEnabledItem = ChannelAppTaskService::findModelEnabledById($channelAppTaskId);
// 查找状态为启用的数据模型(渠道的类型)
$channelTypeEnabledItems = ChannelType::find()->isDeletedNo()->enabled()->all();
// 基于ID查找状态为启用的单个数据模型(任务)
$taskEnabledItem = TaskService::findModelEnabledById($channelAppTaskEnabledItem->task_id);
// 基于任务ID查找状态为启用的资源列表
$assetEnabledItems = Asset::findAllEnabledByTaskId($taskEnabledItem->id);
if (empty($assetEnabledItems)) {
throw new ServerErrorHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35020'), ['task_id' => $taskEnabledItem->id])), 35020);
}
// 获取基于任务ID查找状态为启用的资源列表的id值列表
$assetEnabledIds = ArrayHelper::getColumn($assetEnabledItems, 'id');
// 不属于当前任务ID下的资源ID
$notBelongIds = [];
// 作业类型不支持的资源ID
$jobTypeNotSupportIds = [];
// 作业类型与渠道的类型代码不匹配的资源ID
$notMatchChannelTypeCodeIds = [];
$assets = $event->job->assets;
foreach ($event->job->assets as $assetKey => $asset) {
$assetJobType = $taskEnabledItem->channel_type_code . '_' . $asset['job_type'];
// 不属于当前任务ID下的资源ID
if (!in_array($asset['id'], $assetEnabledIds)) {
$notBelongIds[] = $asset['id'];
}
// 作业类型不支持的资源ID
if (!in_array($asset['job_type'], [UploadAssetJob::JOB_TYPE_VIDEO_MULTIPART])) {
$jobTypeNotSupportIds[] = $assetJobType;
}
// 作业类型与渠道的类型代码不匹配的资源ID
$matchChannelTypeCode = false;
foreach ($channelTypeEnabledItems as $itemKey => $channelTypeEnabledItem) {
$pos = strpos($assetJobType, $channelTypeEnabledItem->code);
if ($pos !== false) {
$assets[$assetKey]['service_class'] = 'common\services\\' . str_replace(' ', '', ucwords(str_replace('_', ' ', $channelTypeEnabledItem->code))) . 'AssetService'; // 例：common\services\QqCwAssetService
$assets[$assetKey]['service_action'] = 'uploadAsset' . str_replace(' ', '', ucwords(str_replace('_', ' ', $asset['job_type']))) . 'ErrorHandler'; // 例：uploadAssetVideoMultipartErrorHandler
$matchChannelTypeCode = true;
break;
}
}
if (!$matchChannelTypeCode) {
$notMatchChannelTypeCodeIds[] = $assetJobType;
}
}
if (!empty($notBelongIds)) {
$notBelongIds = implode(",", $notBelongIds);
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35025'), ['not_belong_ids' => $notBelongIds, 'task_id' => $taskEnabledItem->id])), 35025);
}
if (!empty($jobTypeNotSupportIds)) {
$jobTypeNotSupportIds = implode(",", array_unique($jobTypeNotSupportIds));
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35026'), ['job_type_not_support_ids' => $jobTypeNotSupportIds])), 35026);
}
if (!empty($notMatchChannelTypeCodeIds)) {
$notMatchChannelTypeCodeIds = implode(",", array_unique($notMatchChannelTypeCodeIds));
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35027'), ['not_match_channel_type_code_ids' => $notMatchChannelTypeCodeIds])), 35027);
}
// 基于作业类型调用相应服务进行后续处理
foreach ($assets as $asset) {
$serviceAction = $asset['service_action'];
$asset['service_class']::$serviceAction($asset['id'], $channelAppTaskId, $event->error);
}
}
}
34. Clear the previous test data, posthttp://api.channel-pub-api.localhost/qq/v1/articles/video?group_id=spider, the execution is successful, and the media_absolute_url is specially made The value is correct, in order to test the subsequent processing after successful execution of the copy of the resource file queue, that is, the video file of the content website application of the Penguin number is uploaded. The file represented by media_absolute_url is a file of size 2.1 GB to test the subsequent processing after the job of uploading the resource file queue fails to execute.
request body
{
"channel_app_source_uuids": ["bba4e024eba111e89fa754ee75d2ebc1"],
"source": "spider",
"source_uuid": "825e6d5e36468cc4bf536799ce3565cf",
"source_pub_user_id": 1,
"source_callback_url": "http://wjdev.chinamcloud.com:8609/cms/api/thirdPush/callBack",
"article_category_id": 226,
"title": "综艺节目 - 20181126 - 1",
"author": "综艺节目 - 20181126 - 1",
"source_article_id": 1,
"media_absolute_url": "http://127.0.0.1/channel-pub-api/storage/spider/videos/13f05f8f4633d8b9e9340089be533f7e_h264_500k_mp4.mp4",
"tag": "综艺",
"apply": 0,
"desc": "综艺节目 - 20181126 - 1"
}
Response body
{
"code": 10000,
"message": "发布文章类型：视频(视频)的文章成功",
"data": [
{
"channel_id": 1,
"channel_code": "qq",
"channel_type_id": 1,
"channel_type_code": "qq_cw",
"channel_app_source_id": 6,
"channel_app_source_uuid": "bba4e024eba111e89fa754ee75d2ebc1",
"task_id": 21,
"status": 1,
"created_at": 1543224918,
"updated_at": 1543224918,
"uuid": "96cc4ffef15e11e88b6b54ee75d2ebc1",
"id": 21
}
]
}
35. Execute the SQL statement as follows:
SELECT * FROM `cpa_channel` WHERE (`code`='qq') AND (`is_deleted`=0)
SELECT * FROM `cpa_channel_app_source` WHERE (`uuid`='bba4e024eba111e89fa754ee75d2ebc1') AND (`is_deleted`=0)
SELECT * FROM `cpa_channel_type` WHERE (`code`='qq_cw') AND (`is_deleted`=0)
SELECT * FROM `cpa_qq_cw_app` WHERE (`channel_app_source_uuid`='bba4e024eba111e89fa754ee75d2ebc1') AND (`is_deleted`=0)
SELECT * FROM `cpa_article_type` WHERE (`code`='video') AND (`is_deleted`=0)
SELECT * FROM `cpa_qq_article_type` WHERE (`code`='multivideos') AND (`is_deleted`=0)
SELECT EXISTS(SELECT * FROM `cpa_article_category` WHERE (`cpa_article_category`.`id`=226) AND ((`is_deleted`=0) AND (`status`=1)))
SELECT * FROM `cpa_qq_article_category_multivideos` WHERE (`article_category_id`=226) AND (`is_deleted`=0)
INSERT INTO `cpa_task` (`group_id`, `source`, `source_uuid`, `source_pub_user_id`, `source_callback_url`, `channel_id`, `channel_code`, `channel_type_id`, `channel_type_code`, `status`, `created_at`, `updated_at`) VALUES ('spider', 'spider', '825e6d5e36468cc4bf536799ce3565cf', 1, 'http://wjdev.chinamcloud.com:8609/cms/api/thirdPush/callBack', 1, 'qq', 1, 'qq_cw', 1, 1543224918, 1543224918)
INSERT INTO `cpa_channel_app_task` (`channel_id`, `channel_code`, `channel_type_id`, `channel_type_code`, `channel_app_source_id`, `channel_app_source_uuid`, `task_id`, `status`, `created_at`, `updated_at`, `uuid`) VALUES (1, 'qq', 1, 'qq_cw', 6, 'bba4e024eba111e89fa754ee75d2ebc1', 21, 1, 1543224918, 1543224918, '96cc4ffef15e11e88b6b54ee75d2ebc1')
INSERT INTO `cpa_qq_cw_app_task` (`channel_app_task_id`, `channel_app_task_uuid`, `qq_cw_app_id`, `task_id`, `status`, `created_at`, `updated_at`) VALUES (21, '96cc4ffef15e11e88b6b54ee75d2ebc1', 5, 21, 1, 1543224919, 1543224919)
INSERT INTO `cpa_qq_article` (`group_id`, `article_category_id`, `title`, `author`, `source_article_id`, `qq_app_type`, `article_type_id`, `qq_article_type_id`, `qq_article_category_id`, `task_id`, `status`, `created_at`, `updated_at`) VALUES ('spider', 226, '综艺节目 - 20181126 - 1', '综艺节目 - 20181126 - 1', 1, 'cw', 3, 2, 2808, 21, 1, 1543224919, 1543224919)
INSERT INTO `cpa_qq_article_multivideos` (`media`, `tag`, `desc`, `apply`, `qq_article_id`, `category`, `md5`, `vid`, `task_id`, `status`, `created_at`, `updated_at`) VALUES ('', '综艺', '综艺节目 - 20181126 - 1', 0, 21, 2808, '', '', 21, 1, 1543224919, 1543224919)
INSERT INTO `cpa_asset` (`channel_id`, `channel_code`, `channel_type_id`, `channel_type_code`, `source`, `type`, `absolute_url`, `relative_path`, `size`, `task_id`, `channel_article_id`, `status`, `is_deleted`, `created_at`, `updated_at`, `deleted_at`) VALUES (1, 'qq', 1, 'qq_cw', 'spider', 'video', 'http://127.0.0.1/channel-pub-api/storage/spider/videos/13f05f8f4633d8b9e9340089be533f7e_h264_500k_mp4.mp4', '', 0, 21, 21, 1, 0, 1543224919, 1543224919, 0)
36. View status information for 4 queues
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/info --color=0
Jobs
- waiting: 1
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii upload-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii pub-article-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
37. The run command obtains and executes the tasks in the loop (copy the resource file queue) until the queue is empty
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/run --verbose=1 --isolate=1 --color=0
2018-11-26 17:40:44 [pid: 169228] - Worker is started
2018-11-26 17:40:45 [1] common\jobs\CopyAssetJob (attempt: 1, pid: 169228) - Started
2018-11-26 17:41:51 [1] common\jobs\CopyAssetJob (attempt: 1, pid: 169228) - Done (66.431 s)
2018-11-26 17:41:51 [pid: 169228] - Worker is stopped (0:01:07)
38. The job of copying the resource file queue is successful, the execution result is in line with expectations, the resource has been updated in batches, and the job has been pushed to the uploaded resource file queue, as shown in Figure 7
Figure 7
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 1
PS E:\wwwroot\channel-pub-api> ./yii upload-asset-queue/info --color=0
Jobs
- waiting: 1
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii pub-article-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
39. The run command obtains and executes the tasks in the loop (uploading the resource file queue) until the queue is empty. During the execution of the task, we deliberately use the wall-turning software (the network quality is poor) to test the subsequent processing of the job uploading the resource file queue failed to execute. The task id of the channel-based application update the task of the content website application of the Penguin number (scenario: After the job of uploading the resource file queue fails, the number of publishing can be reduced by 1, status, 3: in the release (failed)); insert the release log, push the job Send it to the source callback queue (asynchronous); the task ID of the application based on the resource ID and Penguin finds a single data model (the video file fragment of the content website application of the Penguin number is uploaded), and if there is, it will be updated to, 3: Uploading (failed). as shown in Figure 8
8
PS E:\wwwroot\channel-pub-api> ./yii upload-asset-queue/run --verbose=1 --isolate=1 --color=0
2018-11-26 17:57:46 [pid: 172564] - Worker is started
2018-11-26 17:57:46 [1] common\jobs\UploadAssetJob (attempt: 1, pid: 172564) - Started
2018-11-26 18:00:43 [1] common\jobs\UploadAssetJob (attempt: 1, pid: 172564) - Error (176.710 s)
> yii\httpclient\Exception: Curl error: #6 - Could not resolve host: api.om.qq.com
2018-11-26 18:00:43 [pid: 172564] - Worker is stopped (0:02:57)
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 1
PS E:\wwwroot\channel-pub-api> ./yii upload-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 1
PS E:\wwwroot\channel-pub-api> ./yii pub-article-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 1
- delayed: 0
- reserved: 0
- done: 0
40. Clear the previous test data, posthttp://api.channel-pub-api.localhost/qq/v1/articles/video?group_id=spider, the execution is successful, and the media_absolute_url is specially made The value is correct, in order to test the subsequent processing after successful execution of the copy of the resource file queue, that is, the video file of the content website application of the Penguin number is uploaded. The file represented by media_absolute_url is a file of size 8.44 MB to test the subsequent processing after the job of uploading the resource file queue is successfully executed.
request body
{
"channel_app_source_uuids": ["bba4e024eba111e89fa754ee75d2ebc1"],
"source": "spider",
"source_uuid": "825e6d5e36468cc4bf536799ce3565cf",
"source_pub_user_id": 1,
"source_callback_url": "http://wjdev.chinamcloud.com:8609/cms/api/thirdPush/callBack",
"article_category_id": 226,
"title": "综艺节目 - 20181126 - 2",
"author": "综艺节目 - 20181126 - 2",
"source_article_id": 1,
"media_absolute_url": "http://127.0.0.1/channel-pub-api/storage/spider/videos/3d35e17a32fb48cfb76f39a1b1bf33ce_h264_1200k_mp4.mp4",
"tag": "综艺",
"apply": 0,
"desc": "综艺节目 - 20181126 - 2"
}
Response body
{
"code": 10000,
"message": "发布文章类型：视频(视频)的文章成功",
"data": [
{
"channel_id": 1,
"channel_code": "qq",
"channel_type_id": 1,
"channel_type_code": "qq_cw",
"channel_app_source_id": 6,
"channel_app_source_uuid": "bba4e024eba111e89fa754ee75d2ebc1",
"task_id": 22,
"status": 1,
"created_at": 1543227265,
"updated_at": 1543227265,
"uuid": "0d54f23ef16411e8abbe54ee75d2ebc1",
"id": 22
}
]
}
41. View the status information of 4 queues
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/info --color=0
Jobs
- waiting: 1
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii upload-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii pub-article-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
42. The run command obtains and executes the tasks in the loop (copy the resource file queue) until the queue is empty
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/run --verbose=1 --isolate=1 --color=0
2018-11-26 18:15:48 [pid: 168344] - Worker is started
2018-11-26 18:15:48 [1] common\jobs\CopyAssetJob (attempt: 1, pid: 168344) - Started
2018-11-26 18:15:49 [1] common\jobs\CopyAssetJob (attempt: 1, pid: 168344) - Done (0.440 s)
2018-11-26 18:15:49 [pid: 168344] - Worker is stopped (0:00:01)
43. The job of copying the resource file queue is successful, the execution result is in line with expectations, the resource has been updated in batches, and the job has been pushed to the uploaded resource file queue
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 1
PS E:\wwwroot\channel-pub-api> ./yii upload-asset-queue/info --color=0
Jobs
- waiting: 1
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii pub-article-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
44. Run The command obtains and executes the tasks in the loop (upload the resource file queue) until the queue is empty. The file (the network quality is good), and the follow-up processing after the successful execution of the uploaded resource file queue is tested, and the method is empty for the time being. There are already corresponding records in the transaction table, as shown in Figure 9
Figure 9
PS E:\wwwroot\channel-pub-api> ./yii upload-asset-queue/run --verbose=1 --isolate=1 --color=0
2018-11-26 18:23:08 [pid: 173512] - Worker is started
2018-11-26 18:23:08 [4] common\jobs\UploadAssetJob (attempt: 1, pid: 173512) - Started
2018-11-26 18:23:17 [4] common\jobs\UploadAssetJob (attempt: 1, pid: 173512) - Done (8.575 s)
2018-11-26 18:23:17 [pid: 173512] - Worker is stopped (0:00:09)
45. The video transaction controller of the content website application of the Penguin number, the realization of the video transaction of the synchronous interface, edit \console\controllers\qqcwTransactionVideoController.php
* @since 1.0
*/
class QqCwTransactionVideoController extends Controller
{
/**
* 控制台命令：获取企鹅号的内容网站应用的企鹅号接口的视频事务，同步至企鹅号的内容网站应用的企鹅号的视频事务 qq-cw-transaction-video/sync(qq-cw-transaction-video/sync)
*
* 1、输入数据验证规则
* (1)查询渠道代码，qq：企鹅号是否存在，如果不存在，则返回失败
* (2)判断渠道代码，qq：企鹅号的状态是否启用，如果未启用，则返回失败
* (3)如果渠道的类型代码，qq_cw：企鹅号的内容网站应用，查询渠道的类型代码，qq_cw：企鹅号的内容网站应用是否存在，如果不存在，则返回失败
* (4)如果渠道的类型代码，qq_cw：企鹅号的内容网站应用，判断渠道的类型代码，qq_cw：企鹅号的内容网站应用的状态是否启用，如果未启用，则返回失败
*
* 2、操作数据(事务)
* (1)查询企鹅号的应用类型，cw：内容网站应用 && 类型，2：视频 && 状态，3：处理中的20条记录，基于ID顺序排列(企鹅号的事务)
* (2)如果企鹅号的事务列表不为空，遍历处理(单个处理后延缓执行 10 秒)，如果为空(延缓执行 60 秒)，则退出
* (3)基于ID查找单个数据模型(企鹅号的事务)，判断企鹅号的事务状态，如果不为，3：处理中，则跳出本次循环
* (4)基于企鹅号的内容网站应用ID获取有效的 Access Token
* (5)HTTP请求，基于上传的唯一事务ID获取事务信息
* (6)基于企鹅号接口的事务类型获取企鹅号的事务类型
* (7)基于企鹅号接口的事务状态获取企鹅号的事务状态
* (8)判断企鹅号的事务状态，如果为，3：处理中，则跳出本次循环
* (9)判断企鹅号的事务状态，如果为，1：成功
* (10)基于企鹅号的应用的视频文件分片上传ID查找状态为已上传的单个数据模型(企鹅号的内容网站应用的视频文件分片上传)
* (11)如果未找到数据模型，将抛出 404 HTTP 异常
* (12)如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
* (13)更新企鹅号的视频文件分片上传的视频文件唯一标示ID
* (14)更新企鹅号的事务的状态，1：成功
* (15)判断更新企鹅号的事务时受影响的行数，是否等于 1，如果不等于 1，则跳出本次循环
* (16)企鹅号的内容网站应用的企鹅号的视频事务成功后的后续处理，例：QqCwTransactionService::videoExecHandler($qqTransactionId)
* (17)判断企鹅号的事务状态，如果为，2：失败
* (18)更新企鹅号的事务的状态，2：失败
* (19)企鹅号的内容网站应用的企鹅号的视频事务失败后的后续处理，例：QqCwTransactionService::videoErrorHandler($qqTransactionId)
*
* 3、企鹅号的内容网站应用的企鹅号的视频事务成功后的后续处理
* (1)基于ID查找状态为成功的单个数据模型(企鹅号的事务)
* (2)如果未找到数据模型，将抛出 404 HTTP 异常
* (3)如果找到数据模型，状态未成功，将抛出 422 HTTP 异常
* (4)判断企鹅号的应用类型，如果不是，cw：内容网站应用，将抛出 422 HTTP 异常
* (5)判断类型，如果不是，2：视频，将抛出 422 HTTP 异常
* (6)基于企鹅号的内容网站应用的任务ID查找状态为启用的单个数据模型(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)
* (7)如果找到数据模型(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)，基于微信公众帐号应用的任务ID查找状态为启用的资源列表
* (8)如果找到数据模型(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)，获取微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联的企鹅号的内容网站应用的任务ID值列表
* (9)如果找到数据模型(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)，基于任务ID查询企鹅号的应用类型，cw：内容网站应用 && 类型，2：视频 && 状态，1：成功的资源列表
* (10)如果找到数据模型(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)，判断微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联数量和事务数量是否相等，如果相等，则遍历资源列表，基于ID查找状态为发布中的单个数据模型(企鹅号的内容网站应用的任务)，企鹅号的内容网站应用的发布文章类型：视频(视频)的文章至企鹅号平台，队列任务执行成功后，调用相应服务，否则，插入发布日志(异步)，调用：WxAssetService::qqCwTransactionVideoExecHandler($taskId)
* (11)如果未找到数据模型(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)，基于ID查找状态为发布中的单个数据模型(企鹅号的内容网站应用的任务)
* (12)如果未找到数据模型(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)，如果未找到数据模型(企鹅号的内容网站应用的任务)，将抛出 404 HTTP 异常
* (13)如果未找到数据模型(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)，如果找到数据模型(企鹅号的内容网站应用的任务)，状态未发布中，将抛出 422 HTTP 异常
* (14)企鹅号的内容网站应用的发布文章类型：视频(视频)的文章至企鹅号平台，队列任务执行成功后，调用相应服务，否则，插入发布日志(异步)
*
* 4、企鹅号的内容网站应用的企鹅号的视频事务失败后的后续处理
* (1)基于ID查找状态为失败的单个数据模型(企鹅号的事务)
* (2)如果未找到数据模型，将抛出 404 HTTP 异常
* (3)如果找到数据模型，状态未失败，将抛出 422 HTTP 异常
* (4)判断企鹅号的应用类型，如果不是，cw：内容网站应用，将抛出 422 HTTP 异常
* (5)判断类型，如果不是，2：视频，将抛出 422 HTTP 异常
* (6)基于ID查找状态为发布中的单个数据模型(企鹅号的内容网站应用的任务)
* (7)如果未找到数据模型(企鹅号的内容网站应用的任务)，将抛出 404 HTTP 异常
* (8)如果找到数据模型(企鹅号的内容网站应用的任务)，状态未发布中，将抛出 422 HTTP 异常
* (9)基于ID查找状态为启用的单个数据模型(渠道的应用的任务)
* (10)如果未找到数据模型，将抛出 404 HTTP 异常
* (11)如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
* (12)基于渠道的应用的任务ID更新企鹅号的内容网站应用的任务(场景：企鹅号的视频事务失败后，可发布次数减1，状态，3：发布中(已失败))
* (13)发布任务失败后，插入发布日志，将作业推送至来源回调队列(异步)
* (14)基于企鹅号的内容网站应用的任务ID查找状态为启用的单个资源(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)，如果存在，调用：WxAssetService::qqCwTransactionVideoErrorHandler($taskId, $errorCode, $errorMessage)
*
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws ServerErrorHttpException
* @throws \Throwable
*/
public function actionSync()
{
// 基于代码查找状态为启用的单个数据模型(渠道)
$channelEnabledItem = ChannelService::findModelEnabledByCode(Channel::CODE_QQ);
// 基于代码查找状态为启用的单个数据模型(渠道的类型)
$channelTypeEnabledItem = ChannelTypeService::findModelEnabledByCode(ChannelType::CODE_QQ_CW);
// 查询企鹅号的应用类型，cw：内容网站应用 && 类型，2：视频 && 状态，3：处理中的20条记录，基于ID顺序排列
$qqTransactionVideoItems = QqTransaction::find()->where(['qq_app_type' => QqArticle::QQ_APP_TYPE_CW, 'type' => QqTransaction::TYPE_VIDEO])->isDeletedNo()->processing()->orderBy(['id' => SORT_ASC])->limit(20)->all();
if ($qqTransactionVideoItems) {
foreach ($qqTransactionVideoItems as $qqTransactionVideoItem) {
// 基于ID查找单个数据模型(企鹅号的事务)
$qqTransactionVideoItem = QqTransaction::findOne($qqTransactionVideoItem->id);
// 判断企鹅号的事务状态，如果不为，3：处理中，则跳出本次循环
if($qqTransactionVideoItem->status != QqTransaction::STATUS_PROCESSING){
continue;
}
// 基于企鹅号的内容网站应用ID获取有效的 Access Token
$qqCwAccessTokenService = new QqCwAccessTokenService();
$accessTokenValidity = $qqCwAccessTokenService->getAccessTokenValidityByQqCwAppId($qqTransactionVideoItem->qq_app_id);
// HTTP请求，基于上传的唯一事务ID获取事务信息
$qqTransactionService = new QqTransactionService();
$qqTransactionServiceHttpTransactionInfoData = [
'accessToken' => $accessTokenValidity->access_token,
'transactionId' => $qqTransactionVideoItem->transaction_id,
];
$qqTransactionServiceHttpTransactionInfoResult = $qqTransactionService->httpTransactionInfo($qqTransactionServiceHttpTransactionInfoData);
// 基于企鹅号接口的事务状态获取企鹅号的事务状态
$qqTransactionStatus = QqTransactionService::getStatusByHttpQqApiTransactionStatus($qqTransactionServiceHttpTransactionInfoResult['transaction_status']);
// 判断企鹅号的事务状态，如果为，3：处理中，则跳出本次循环
if ($qqTransactionStatus == QqTransaction::STATUS_PROCESSING) {
continue;
}
/* 判断企鹅号的事务状态 */
if ($qqTransactionStatus == QqTransaction::STATUS_SUCCESS) { // 状态，1：成功
// 基于企鹅号的应用的视频文件分片上传ID查找状态为已上传的单个数据模型(企鹅号的内容网站应用的视频文件分片上传)
$qqVideoMultipartUploadItem = QqVideoMultipartUploadService::findModelUploadedById($qqTransactionVideoItem->qq_video_multipart_upload_id);
/* 操作数据(事务) */
$transaction = Yii::$app->db->beginTransaction();
try {
// 更新企鹅号的视频文件分片上传的视频文件唯一标示ID
$qqVideoMultipartUploadService = new QqVideoMultipartUploadService();
$qqVideoMultipartUploadItem->vid = $qqTransactionServiceHttpTransactionInfoResult['vid'];
$qqVideoMultipartUploadServiceUpdateResult = $qqVideoMultipartUploadService->update($qqVideoMultipartUploadItem);
if ($qqVideoMultipartUploadServiceUpdateResult['status'] === false) {
throw new ServerErrorHttpException($qqVideoMultipartUploadServiceUpdateResult['message'], $qqVideoMultipartUploadServiceUpdateResult['code']);
}
// 更新企鹅号的事务的状态，1：成功
$qqTransactionVideoItem->status = QqTransaction::STATUS_SUCCESS;
$qqTransactionVideoItemUpdateResult = $qqTransactionVideoItem->update();
if ($qqTransactionVideoItemUpdateResult !== false) {
} elseif ($qqTransactionVideoItem->hasErrors()) {
foreach ($qqTransactionVideoItem->getFirstErrors() as $message) {
$firstErrors = $message;
break;
}
throw new ServerErrorHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35087'), ['model' => $qqTransactionVideoItem->formName(), 'first_errors' => $firstErrors])), 35087);
} elseif (!$qqTransactionVideoItem->hasErrors()) {
throw new ServerErrorHttpException('Failed to update the object for unknown reason.');
}
$transaction->commit();
} catch(\Throwable $e) {
$transaction->rollBack();
throw $e;
}
// 判断更新企鹅号的事务时受影响的行数，是否等于 1，如果不等于 1，则跳出本次循环
if ($qqTransactionVideoItemUpdateResult != 1) {
continue;
}
// 企鹅号的内容网站应用的企鹅号的视频事务成功后的后续处理
QqCwTransactionService::videoExecHandler($qqTransactionVideoItem->id);
} elseif ($qqTransactionStatus == QqTransaction::STATUS_ERROR) { // 状态，2：失败
// 更新企鹅号的事务的状态，2：失败
$qqTransactionVideoItem->ext_err = $qqTransactionServiceHttpTransactionInfoResult['ext_err'];
$qqTransactionVideoItem->transaction_err_msg = $qqTransactionServiceHttpTransactionInfoResult['transaction_err_msg'];
$qqTransactionVideoItem->status = QqTransaction::STATUS_ERROR;
$qqTransactionServiceUpdateResult = $qqTransactionService->update($qqTransactionVideoItem);
if ($qqTransactionServiceUpdateResult['status'] === false) {
throw new ServerErrorHttpException($qqTransactionServiceUpdateResult['message'], $qqTransactionServiceUpdateResult['code']);
}
// 企鹅号的内容网站应用的企鹅号的视频事务失败后的后续处理
QqCwTransactionService::videoErrorHandler($qqTransactionVideoItem->id);
}
}
// 延缓执行 10 秒
sleep(Yii::$app->params['qqTransaction']['isEmptyNoSleepTime']);
} else {
// 延缓执行 60 秒
sleep(Yii::$app->params['qqTransaction']['isEmptyYesSleepTime']);
}
return ExitCode::OK;
}
}
46. The article transaction controller of the content website application of the Penguin, the realization of the article transaction of the synchronous interface, edit \console\controllers\qqcwTransactionArticleController.php
* @since 1.0
*/
class QqCwTransactionArticleController extends Controller
{
/**
* 控制台命令：获取企鹅号的内容网站应用的企鹅号接口的文章事务，同步至企鹅号的内容网站应用的企鹅号的文章事务 qq-cw-transaction-article/sync(qq-cw-transaction-article/sync)
*
* 1、输入数据验证规则
* (1)查询渠道代码，qq：企鹅号是否存在，如果不存在，则返回失败
* (2)判断渠道代码，qq：企鹅号的状态是否启用，如果未启用，则返回失败
* (3)如果渠道的类型代码，qq_cw：企鹅号的内容网站应用，查询渠道的类型代码，qq_cw：企鹅号的内容网站应用是否存在，如果不存在，则返回失败
* (4)如果渠道的类型代码，qq_cw：企鹅号的内容网站应用，判断渠道的类型代码，qq_cw：企鹅号的内容网站应用的状态是否启用，如果未启用，则返回失败
*
* 2、操作数据(事务)
* (1)查询企鹅号的应用类型，cw：内容网站应用 && 类型，1：文章 && 状态，3：处理中 && 文章发布状态：审核中的20条记录，基于ID顺序排列(企鹅号的事务)
* (2)如果企鹅号的事务列表不为空，遍历处理(单个处理后延缓执行 10 秒)，如果为空(延缓执行 60 秒)，则退出
* (3)基于ID查找单个数据模型(企鹅号的事务)，判断企鹅号的事务状态，如果不为，3：处理中，则跳出本次循环
* (4)基于企鹅号的内容网站应用ID获取有效的 Access Token
* (5)HTTP请求，基于上传的唯一事务ID获取事务信息
* (6)基于企鹅号接口的事务类型获取企鹅号的事务类型
* (7)基于企鹅号接口的事务状态获取企鹅号的事务状态
* (8)判断企鹅号的事务状态，如果为，3：处理中，则跳出本次循环
* (9)判断企鹅号的事务状态，如果为，1：成功 && 判断企鹅号的事务文章发布状态，如果为，审核中，则跳出本次循环
* (10)判断企鹅号的事务状态，如果为，1：成功 && 判断企鹅号的事务文章发布状态，如果为，发布成功
* (11)更新企鹅号的事务
* (12)判断更新企鹅号的事务时受影响的行数，是否等于 1，如果不等于 1，则跳出本次循环
* (13)企鹅号的内容网站应用的企鹅号的文章事务成功后，基于文章类型调用相应服务进行后续处理，例：QqCwTransactionService::articleMultivideosExecHandler($qqTransactionId)
* (14)判断企鹅号的事务状态，如果为，2：失败 || (判断企鹅号的事务状态，如果为，1：成功 && 判断企鹅号的事务文章发布状态，如果为，未发布)
* (15)更新企鹅号的事务
* (16)企鹅号的内容网站应用的企鹅号的文章事务失败后，基于文章类型调用相应服务进行后续处理，例：QqCwTransactionService::articleMultivideosErrorHandler($qqTransactionId)
*
* 3、企鹅号的内容网站应用的企鹅号的文章事务成功后的后续处理
* (1)基于ID查找状态为成功的单个数据模型(企鹅号的事务)
* (2)如果未找到数据模型，将抛出 404 HTTP 异常
* (3)如果找到数据模型，状态未成功，将抛出 422 HTTP 异常
* (4)判断企鹅号的应用类型，如果不是，cw：内容网站应用，将抛出 422 HTTP 异常
* (5)判断类型，如果不是，1：文章，将抛出 422 HTTP 异常
* (6)基于ID查找状态为审核中的单个数据模型(企鹅号的内容网站应用的任务)
* (7)如果未找到数据模型(企鹅号的内容网站应用的任务)，将抛出 404 HTTP 异常
* (8)如果找到数据模型(企鹅号的内容网站应用的任务)，状态未审核中，将抛出 422 HTTP 异常
* (9)基于ID查找状态为启用的单个数据模型(渠道的应用的任务)
* (10)如果未找到数据模型(渠道的应用的任务)，将抛出 404 HTTP 异常
* (11)如果找到数据模型(渠道的应用的任务)，状态未启用，将抛出 422 HTTP 异常
* (12)基于渠道的应用的任务ID更新企鹅号的内容网站应用的任务(场景：企鹅号的文章事务成功后，可发布次数减1，状态，6：已发布)
* (13)发布任务成功后，插入发布日志，将作业推送至来源回调队列(异步)
* (14)基于企鹅号的内容网站应用的任务ID查找状态为启用的单个数据模型(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)
* (15)如果找到数据模型(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)，基于微信公众帐号应用的任务ID查找状态为启用的资源列表
* (16)如果找到数据模型(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)，获取微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联的企鹅号的内容网站应用的任务ID值列表
* (17)如果找到数据模型(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)，基于任务ID查询企鹅号的应用类型，cw：内容网站应用 && 类型，1：文章 && 状态，1：成功 && 文章发布状态，发布成功的资源列表
* (18)如果找到数据模型(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)，判断微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联数量和事务数量是否相等，如果相等，调用：WxArticleService::qqCwTransactionArticleVideoExecHandler($taskId)
*
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws ServerErrorHttpException
* @throws \Throwable
*/
public function actionSync()
{
// 基于代码查找状态为启用的单个数据模型(渠道)
$channelEnabledItem = ChannelService::findModelEnabledByCode(Channel::CODE_QQ);
// 基于代码查找状态为启用的单个数据模型(渠道的类型)
$channelTypeEnabledItem = ChannelTypeService::findModelEnabledByCode(ChannelType::CODE_QQ_CW);
// 查询企鹅号的应用类型，cw：内容网站应用 && 类型，1：文章 && 状态，3：处理中 && 文章发布状态：审核中的20条记录，基于ID顺序排列(企鹅号的事务)
$qqTransactionArticleItems = QqTransaction::find()->where(['qq_app_type' => QqArticle::QQ_APP_TYPE_CW, 'type' => QqTransaction::TYPE_ARTICLE, 'article_pub_flag' => HttpQqApiTransaction::ARTICLE_PUB_FLAG_REVIEW])->isDeletedNo()->processing()->orderBy(['id' => SORT_ASC])->limit(20)->all();
if ($qqTransactionArticleItems) {
foreach ($qqTransactionArticleItems as $qqTransactionArticleItem) {
// 基于ID查找单个数据模型(企鹅号的事务)
$qqTransactionArticleItem = QqTransaction::findOne($qqTransactionArticleItem->id);
// 判断企鹅号的事务状态，如果不为，3：处理中，则跳出本次循环
if($qqTransactionArticleItem->status != QqTransaction::STATUS_PROCESSING){
continue;
}
// 基于企鹅号的内容网站应用ID获取有效的 Access Token
$qqCwAccessTokenService = new QqCwAccessTokenService();
$accessTokenValidity = $qqCwAccessTokenService->getAccessTokenValidityByQqCwAppId($qqTransactionArticleItem->qq_app_id);
// HTTP请求，基于上传的唯一事务ID获取事务信息
$qqTransactionService = new QqTransactionService();
$qqTransactionServiceHttpTransactionInfoData = [
'accessToken' => $accessTokenValidity->access_token,
'transactionId' => $qqTransactionArticleItem->transaction_id,
];
$qqTransactionServiceHttpTransactionInfoResult = $qqTransactionService->httpTransactionInfo($qqTransactionServiceHttpTransactionInfoData);
// 基于企鹅号接口的事务状态获取企鹅号的事务状态
$qqTransactionStatus = QqTransactionService::getStatusByHttpQqApiTransactionStatus($qqTransactionServiceHttpTransactionInfoResult['transaction_status']);
// 判断企鹅号的事务状态，如果为，3：处理中，则跳出本次循环
if ($qqTransactionStatus == QqTransaction::STATUS_PROCESSING) {
continue;
}
// 判断企鹅号的事务状态，如果为，1：成功 && 判断企鹅号的事务文章发布状态，如果为，审核中，则跳出本次循环
if ($qqTransactionStatus == QqTransaction::STATUS_SUCCESS && $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_pub_flag'] == HttpQqApiTransaction::ARTICLE_PUB_FLAG_REVIEW) {
continue;
}
// 更新企鹅号的事务
$qqTransactionArticleItem->type = $qqTransactionService::getTypeByHttpQqApiTransactionType($qqTransactionServiceHttpTransactionInfoResult['transaction_type']);
$qqTransactionArticleItem->transaction_ctime = $qqTransactionServiceHttpTransactionInfoResult['transaction_ctime'];
$qqTransactionArticleItem->ext_err = $qqTransactionServiceHttpTransactionInfoResult['ext_err'];
$qqTransactionArticleItem->transaction_err_msg = $qqTransactionServiceHttpTransactionInfoResult['transaction_err_msg'];
$qqTransactionArticleItem->article_abstract = $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_abstract'];
$qqTransactionArticleItem->article_type = $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_type'];
$qqTransactionArticleItem->article_url = $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_url'];
$qqTransactionArticleItem->article_imgurl = $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_imgurl'];
$qqTransactionArticleItem->article_title = $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_title'];
$qqTransactionArticleItem->article_pub_flag = $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_pub_flag'];
$qqTransactionArticleItem->article_pub_time = $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_pub_time'];
$qqTransactionArticleItem->article_video_title = $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_video_info']['title'];
$qqTransactionArticleItem->article_video_desc = $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_video_info']['desc'];
$qqTransactionArticleItem->article_video_type = $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_video_info']['type'];
$qqTransactionArticleItem->article_video_vid = $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_video_info']['vid'];
$qqTransactionArticleItem->status = $qqTransactionStatus;
/* 判断企鹅号的事务状态 */
if ($qqTransactionStatus == QqTransaction::STATUS_SUCCESS && $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_pub_flag'] == HttpQqApiTransaction::ARTICLE_PUB_FLAG_PUBLISHED) { // 状态，1：成功 && 文章发布状态，发布成功
// 更新企鹅号的事务
$qqTransactionVideoItemUpdateResult = $qqTransactionArticleItem->update();
if ($qqTransactionVideoItemUpdateResult !== false) {
} elseif ($qqTransactionArticleItem->hasErrors()) {
foreach ($qqTransactionArticleItem->getFirstErrors() as $message) {
$firstErrors = $message;
break;
}
throw new ServerErrorHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35087'), ['model' => $qqTransactionArticleItem->formName(), 'first_errors' => $firstErrors])), 35087);
} elseif (!$qqTransactionArticleItem->hasErrors()) {
throw new ServerErrorHttpException('Failed to update the object for unknown reason.');
}
// 判断更新企鹅号的事务时受影响的行数，是否等于 1，如果不等于 1，则跳出本次循环
if ($qqTransactionVideoItemUpdateResult != 1) {
continue;
}
$serviceAction = 'article' . str_replace(' ', '', ucwords(str_replace('_', ' ', $qqTransactionArticleItem->article_type_code))) . 'ExecHandler'; // 例：articleMultivideosExecHandler
// 企鹅号的内容网站应用的企鹅号的文章事务成功后，基于文章类型调用相应服务进行后续处理
QqCwTransactionService::$serviceAction($qqTransactionArticleItem->id);
} elseif ($qqTransactionStatus == QqTransaction::STATUS_ERROR || ($qqTransactionStatus == QqTransaction::STATUS_SUCCESS && $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_pub_flag'] == HttpQqApiTransaction::ARTICLE_PUB_FLAG_UNPUBLISHED)) { // 状态，2：失败 || (状态，1：成功 && 文章发布状态，未发布)
// 更新企鹅号的事务
$qqTransactionServiceUpdateResult = $qqTransactionService->update($qqTransactionArticleItem);
if ($qqTransactionServiceUpdateResult['status'] === false) {
throw new ServerErrorHttpException($qqTransactionServiceUpdateResult['message'], $qqTransactionServiceUpdateResult['code']);
}
$serviceAction = 'article' . str_replace(' ', '', ucwords(str_replace('_', ' ', $qqTransactionArticleItem->article_type_code))) . 'ErrorHandler'; // 例：articleMultivideosErrorHandler
// 企鹅号的内容网站应用的企鹅号的文章事务失败后，基于文章类型调用相应服务进行后续处理
QqCwTransactionService::$serviceAction($qqTransactionArticleItem->id);
}
}
// 延缓执行 10 秒
sleep(Yii::$app->params['qqTransaction']['isEmptyNoSleepTime']);
} else {
// 延缓执行 60 秒
sleep(Yii::$app->params['qqTransaction']['isEmptyYesSleepTime']);
}
return ExitCode::OK;
}
}
47. The realization of the transaction service of the content website application of Penguin, edit \common\services\qqcwTransactionservice.php
* @since 1.0
*/
class QqCwTransactionService extends Service
{
/**
* 企鹅号的内容网站应用的企鹅号的视频事务成功后的后续处理
*
* @param int $qqTransactionId 企鹅号的事务ID
* 格式如下：1
*
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws UnprocessableEntityHttpException 如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
* @throws \yii\base\Exception if the directory could not be created (i.e. php error due to parallel changes)
*/
public static function videoExecHandler($qqTransactionId)
{
// 基于ID查找状态为成功的单个数据模型(企鹅号的事务)
$qqTransactionVideoSuccessItem = QqTransactionService::findModelSuccessById($qqTransactionId);
/* 判断企鹅号的应用类型，如果不是，cw：内容网站应用，将抛出 422 HTTP 异常 */
if ($qqTransactionVideoSuccessItem->qq_app_type !== QqArticle::QQ_APP_TYPE_CW) {
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35060'), ['id' => $qqTransactionVideoSuccessItem->id])), 35060);
}
/* 判断类型，如果不是，2：视频，将抛出 422 HTTP 异常 */
if ($qqTransactionVideoSuccessItem->type !== $qqTransactionVideoSuccessItem::TYPE_VIDEO) {
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35061'), ['id' => $qqTransactionVideoSuccessItem->id])), 35061);
}
// 基于企鹅号的内容网站应用的任务ID查找状态为启用的单个数据模型(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)
$wxTaskQqCwTaskRelationItem = WxTaskQqCwTaskRelation::findOneEnabledByQqCwTaskId($qqTransactionVideoSuccessItem->task_id);
if (isset($wxTaskQqCwTaskRelationItem)) {
// 基于微信公众帐号应用的任务ID查找状态为启用的资源列表
$wxTaskQqCwTaskRelationItems = WxTaskQqCwTaskRelation::findAllEnabledByWxTaskId($wxTaskQqCwTaskRelationItem->wx_task_id);
// 获取微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联的企鹅号的内容网站应用的任务ID值列表
$wxTaskQqCwTaskRelationQqCwTaskIds = ArrayHelper::getColumn($wxTaskQqCwTaskRelationItems, 'qq_cw_task_id');
// 基于任务ID查询企鹅号的应用类型，cw：内容网站应用 && 类型，2：视频 && 状态，1：成功的资源列表
$qqTransactionVideoSuccessItems = QqTransaction::find()->where(['qq_app_type' => QqArticle::QQ_APP_TYPE_CW, 'type' => QqTransaction::TYPE_VIDEO])->andWhere(['in', 'task_id', $wxTaskQqCwTaskRelationQqCwTaskIds])->isDeletedNo()->success()->all();
// 判断微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联数量和事务数量是否相等，如果相等，则遍历资源列表
if (count($wxTaskQqCwTaskRelationQqCwTaskIds) == count($qqTransactionVideoSuccessItems)) {
foreach ($qqTransactionVideoSuccessItems as $qqTransactionVideoSuccessItem) {
// 基于ID查找状态为发布中的单个数据模型(企鹅号的内容网站应用的任务)
$QqCwAppTaskPublishItem = QqCwAppTaskService::findModelPublishById($qqTransactionVideoSuccessItem->qq_app_task_id);
// 企鹅号的内容网站应用的发布文章类型：视频(视频)的文章至企鹅号平台，队列任务执行成功后，调用相应服务，否则，插入发布日志(异步)
QqCwArticleService::pubArticleVideoAsync($QqCwAppTaskPublishItem->channel_app_task_id);
}
}
} else {
// 基于ID查找状态为发布中的单个数据模型(企鹅号的内容网站应用的任务)
$QqCwAppTaskPublishItem = QqCwAppTaskService::findModelPublishById($qqTransactionVideoSuccessItem->qq_app_task_id);
// 企鹅号的内容网站应用的发布文章类型：视频(视频)的文章至企鹅号平台，队列任务执行成功后，调用相应服务，否则，插入发布日志(异步)
QqCwArticleService::pubArticleVideoAsync($QqCwAppTaskPublishItem->channel_app_task_id);
}
}
/**
* 企鹅号的内容网站应用的企鹅号的视频事务失败后的后续处理
*
* @param int $qqTransactionId 企鹅号的事务ID
* 格式如下：1
*
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws UnprocessableEntityHttpException 如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
* @throws \yii\base\Exception if the directory could not be created (i.e. php error due to parallel changes)
*/
public static function videoErrorHandler($qqTransactionId)
{
// 基于ID查找状态为失败的单个数据模型(企鹅号的事务)
$qqTransactionVideoErrorItem = QqTransactionService::findModelErrorById($qqTransactionId);
/* 判断企鹅号的应用类型，如果不是，cw：内容网站应用，将抛出 422 HTTP 异常 */
if ($qqTransactionVideoErrorItem->qq_app_type !== QqArticle::QQ_APP_TYPE_CW) {
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35060'), ['id' => $qqTransactionVideoErrorItem->id])), 35060);
}
/* 判断类型，如果不是，2：视频，将抛出 422 HTTP 异常 */
if ($qqTransactionVideoErrorItem->type !== $qqTransactionVideoErrorItem::TYPE_VIDEO) {
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35061'), ['id' => $qqTransactionVideoErrorItem->id])), 35061);
}
// 基于ID查找状态为发布中的单个数据模型(企鹅号的内容网站应用的任务)
$QqCwAppTaskPublishItem = QqCwAppTaskService::findModelPublishById($qqTransactionVideoErrorItem->qq_app_task_id);
// 基于ID查找状态为启用的单个数据模型(渠道的应用的任务)
$channelAppTaskEnabledItem = ChannelAppTaskService::findModelEnabledById($QqCwAppTaskPublishItem->channel_app_task_id);
// 基于渠道的应用的任务ID更新企鹅号的内容网站应用的任务(场景：企鹅号的视频事务失败后，可发布次数减1，状态，3：发布中(已失败))
QqCwAppTask::updatePublishErrorByChannelAppTaskId($channelAppTaskEnabledItem->id);
$channelAppTaskEnabledItems[] = $channelAppTaskEnabledItem;
$pubLogDatas = [];
foreach ($channelAppTaskEnabledItems as $key => $channelAppTaskEnabledItem) {
// 基于渠道的应用的任务ID查找单个数据模型(企鹅号的内容网站应用的任务)
$qqCwAppTaskItem = QqCwAppTaskService::findModelByChannelAppTaskId($channelAppTaskEnabledItem->id);
$pubLogDatas[$key] = [
'channel_app_source_uuid' => $channelAppTaskEnabledItem->channel_app_source_uuid,
'channel_app_task_uuid' => $channelAppTaskEnabledItem->uuid,
'channel_code' => $channelAppTaskEnabledItem->channel_code,
'channel_type_code' => $channelAppTaskEnabledItem->channel_type_code,
'channel_app_task_status' => $qqCwAppTaskItem->status,
];
}
$errorCode = 35088;
$errorMessage = Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35088'), ['error_message' => $qqTransactionVideoErrorItem->transaction_err_msg]));
// 发布任务失败后，插入发布日志，将作业推送至来源回调队列(异步)
SourceCallbackService::sourceCallbackAsync($channelAppTaskEnabledItems, $errorCode, $errorMessage, $pubLogDatas, PubLog::STATUS_ERROR);
// 基于企鹅号的内容网站应用的任务ID查找状态为启用的单个资源(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)
$wxTaskQqCwTaskRelationItem = WxTaskQqCwTaskRelation::findOneEnabledByQqCwTaskId($qqTransactionVideoErrorItem->task_id);
if (isset($wxTaskQqCwTaskRelationItem)) {
// file_put_contents('E:/wwwroot/channel-pub-api/qq/runtime/video-error-handler-' . $qqTransactionVideoErrorItem->id . '-' . $wxTaskQqCwTaskRelationItem->wx_task_id . '-' . time() . '.txt', '');
WxAssetService::qqCwTransactionVideoErrorHandler($wxTaskQqCwTaskRelationItem->wx_task_id, $errorCode, $errorMessage);
}
}
/**
* 企鹅号的内容网站应用的企鹅号的视频文章事务成功后的后续处理
*
* @param int $qqTransactionId 企鹅号的事务ID
* 格式如下：1
*
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws UnprocessableEntityHttpException 如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
* @throws \yii\base\Exception if the directory could not be created (i.e. php error due to parallel changes)
*/
public static function articleMultivideosExecHandler($qqTransactionId)
{
// 基于ID查找状态为成功的单个数据模型(企鹅号的事务)
$qqTransactionArticleSuccessItem = QqTransactionService::findModelSuccessById($qqTransactionId);
/* 判断企鹅号的应用类型，如果不是，cw：内容网站应用，将抛出 422 HTTP 异常 */
if ($qqTransactionArticleSuccessItem->qq_app_type !== QqArticle::QQ_APP_TYPE_CW) {
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35060'), ['id' => $qqTransactionArticleSuccessItem->id])), 35060);
}
/* 判断类型，如果不是，1：文章，将抛出 422 HTTP 异常 */
if ($qqTransactionArticleSuccessItem->type !== $qqTransactionArticleSuccessItem::TYPE_ARTICLE) {
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35061'), ['id' => $qqTransactionArticleSuccessItem->id])), 35061);
}
// 基于ID查找状态为审核中的单个数据模型(企鹅号的内容网站应用的任务)
$QqCwAppTaskPublishItem = QqCwAppTaskService::findModelReviewById($qqTransactionArticleSuccessItem->qq_app_task_id);
// 基于ID查找状态为启用的单个数据模型(渠道的应用的任务)
$channelAppTaskEnabledItem = ChannelAppTaskService::findModelEnabledById($QqCwAppTaskPublishItem->channel_app_task_id);
// 基于渠道的应用的任务ID更新企鹅号的内容网站应用的任务(场景：企鹅号的文章事务成功后，可发布次数减1，状态，6：已发布)
QqCwAppTask::updatePublishedByChannelAppTaskId($channelAppTaskEnabledItem->id);
$channelAppTaskEnabledItems[] = $channelAppTaskEnabledItem;
$pubLogDatas = [];
foreach ($channelAppTaskEnabledItems as $key => $channelAppTaskEnabledItem) {
// 基于渠道的应用的任务ID查找单个数据模型(企鹅号的内容网站应用的任务)
$qqCwAppTaskItem = QqCwAppTaskService::findModelByChannelAppTaskId($channelAppTaskEnabledItem->id);
$pubLogDatas[$key] = [
'channel_app_source_uuid' => $channelAppTaskEnabledItem->channel_app_source_uuid,
'channel_app_task_uuid' => $channelAppTaskEnabledItem->uuid,
'channel_code' => $channelAppTaskEnabledItem->channel_code,
'channel_type_code' => $channelAppTaskEnabledItem->channel_type_code,
'channel_app_task_status' => $qqCwAppTaskItem->status,
];
}
$successCode = 25002;
$successMessage = Yii::t('common/success', 25002);
// 发布任务成功后，插入发布日志，将作业推送至来源回调队列(异步)
SourceCallbackService::sourceCallbackAsync($channelAppTaskEnabledItems, $successCode, $successMessage, $pubLogDatas, PubLog::STATUS_SUCCESS);
// 基于企鹅号的内容网站应用的任务ID查找状态为启用的单个数据模型(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)
$wxTaskQqCwTaskRelationItem = WxTaskQqCwTaskRelation::findOneEnabledByQqCwTaskId($qqTransactionArticleSuccessItem->task_id);
if (isset($wxTaskQqCwTaskRelationItem)) {
// 基于微信公众帐号应用的任务ID查找状态为启用的资源列表
$wxTaskQqCwTaskRelationItems = WxTaskQqCwTaskRelation::findAllEnabledByWxTaskId($wxTaskQqCwTaskRelationItem->wx_task_id);
// 获取微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联的企鹅号的内容网站应用的任务ID值列表
$wxTaskQqCwTaskRelationQqCwTaskIds = ArrayHelper::getColumn($wxTaskQqCwTaskRelationItems, 'qq_cw_task_id');
// 基于任务ID查询企鹅号的应用类型，cw：内容网站应用 && 类型，1：文章 && 状态，1：成功 && 文章发布状态，发布成功的资源列表
$qqTransactionArticleSuccessItems = QqTransaction::find()->where(['qq_app_type' => QqArticle::QQ_APP_TYPE_CW, 'type' => QqTransaction::TYPE_ARTICLE, 'article_pub_flag' => HttpQqApiTransaction::ARTICLE_PUB_FLAG_PUBLISHED])->andWhere(['in', 'task_id', $wxTaskQqCwTaskRelationQqCwTaskIds])->isDeletedNo()->success()->all();
// 判断微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联数量和事务数量是否相等，如果相等，则遍历资源列表
if (count($wxTaskQqCwTaskRelationQqCwTaskIds) == count($qqTransactionArticleSuccessItems)) {
// file_put_contents('E:/wwwroot/channel-pub-api/qq/runtime/article-multivideos-exec-handler-' . $qqTransactionArticleSuccessItem->id . '-' . $wxTaskQqCwTaskRelationItem->wx_task_id . '-' . time() . '.txt', '');
WxArticleService::qqCwTransactionArticleVideoExecHandler($wxTaskQqCwTaskRelationItem->wx_task_id);
}
}
}
/**
* 企鹅号的内容网站应用的企鹅号的视频文章事务失败后的后续处理
*
* @param int $qqTransactionId 企鹅号的事务ID
* 格式如下：1
*
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws UnprocessableEntityHttpException 如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
* @throws \yii\base\Exception if the directory could not be created (i.e. php error due to parallel changes)
*/
public static function articleMultivideosErrorHandler($qqTransactionId)
{
// 基于ID查找状态为失败的单个数据模型(企鹅号的事务)
$qqTransactionArticleErrorItem = QqTransactionService::findModelErrorById($qqTransactionId);
/* 判断企鹅号的应用类型，如果不是，cw：内容网站应用，将抛出 422 HTTP 异常 */
if ($qqTransactionArticleErrorItem->qq_app_type !== QqArticle::QQ_APP_TYPE_CW) {
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35060'), ['id' => $qqTransactionArticleErrorItem->id])), 35060);
}
/* 判断类型，如果不是，1：文章，将抛出 422 HTTP 异常 */
if ($qqTransactionArticleErrorItem->type !== $qqTransactionArticleErrorItem::TYPE_ARTICLE) {
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35061'), ['id' => $qqTransactionArticleErrorItem->id])), 35061);
}
// 基于ID查找状态为审核中的单个数据模型(企鹅号的内容网站应用的任务)
$QqCwAppTaskPublishItem = QqCwAppTaskService::findModelReviewById($qqTransactionArticleErrorItem->qq_app_task_id);
// 基于ID查找状态为启用的单个数据模型(渠道的应用的任务)
$channelAppTaskEnabledItem = ChannelAppTaskService::findModelEnabledById($QqCwAppTaskPublishItem->channel_app_task_id);
// 基于渠道的应用的任务ID更新企鹅号的内容网站应用的任务(场景：企鹅号的文章事务失败后，可发布次数减1，状态，5：未发布)
QqCwAppTask::updateUnpublishedByChannelAppTaskId($channelAppTaskEnabledItem->id);
$channelAppTaskEnabledItems[] = $channelAppTaskEnabledItem;
$pubLogDatas = [];
foreach ($channelAppTaskEnabledItems as $key => $channelAppTaskEnabledItem) {
// 基于渠道的应用的任务ID查找单个数据模型(企鹅号的内容网站应用的任务)
$qqCwAppTaskItem = QqCwAppTaskService::findModelByChannelAppTaskId($channelAppTaskEnabledItem->id);
$pubLogDatas[$key] = [
'channel_app_source_uuid' => $channelAppTaskEnabledItem->channel_app_source_uuid,
'channel_app_task_uuid' => $channelAppTaskEnabledItem->uuid,
'channel_code' => $channelAppTaskEnabledItem->channel_code,
'channel_type_code' => $channelAppTaskEnabledItem->channel_type_code,
'channel_app_task_status' => $qqCwAppTaskItem->status,
];
}
$errorCode = 35095;
$errorMessage = Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35095'), ['error_message' => $qqTransactionArticleErrorItem->transaction_err_msg]));
// 发布任务失败后，插入发布日志，将作业推送至来源回调队列(异步)
SourceCallbackService::sourceCallbackAsync($channelAppTaskEnabledItems, $errorCode, $errorMessage, $pubLogDatas, PubLog::STATUS_ERROR);
// 基于企鹅号的内容网站应用的任务ID查找状态为启用的单个资源(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)
$wxTaskQqCwTaskRelationItem = WxTaskQqCwTaskRelation::findOneEnabledByQqCwTaskId($qqTransactionArticleErrorItem->task_id);
if (isset($wxTaskQqCwTaskRelationItem)) {
// file_put_contents('E:/wwwroot/channel-pub-api/qq/runtime/article-multivideos-error-handler-' . $qqTransactionArticleErrorItem->id . '-' . $wxTaskQqCwTaskRelationItem->wx_task_id . '-' . time() . '.txt', '');
WxArticleService::qqCwTransactionArticleVideoErrorHandler($wxTaskQqCwTaskRelationItem->wx_task_id, $errorCode, $errorMessage);
}
}
}
48. Queue jobs: publish articles, edit \common\jobs\pubarticlejob.php
* @since 1.0
*/
class PubArticleJob extends Job
{
public $channelAppTaskId;
/*
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws UnprocessableEntityHttpException 如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
* @throws ServerErrorHttpException 如果基于任务ID查找状态为启用的资源列表为空，将抛出 500 HTTP 异常
*/
public function execute($queue)
{
// 基于ID查找状态为启用的单个数据模型(渠道的应用的任务)
$channelAppTaskEnabledItem = ChannelAppTaskService::findModelEnabledById($this->channelAppTaskId);
// 基于ID查找状态为启用的单个数据模型(任务)
$taskEnabledItem = TaskService::findModelEnabledById($channelAppTaskEnabledItem->task_id);
$serviceClass = 'common\services\\' . str_replace(' ', '', ucwords(str_replace('_', ' ', $taskEnabledItem->channel_type_code))) . 'ArticleService'; // 例：common\services\QqCwArticleService
$articleModel = 'common\logics\\' . str_replace(' ', '', ucwords(str_replace('_', ' ', $taskEnabledItem->channel_code))) . 'Article'; // 例：common\logics\QqArticle
// 基于任务ID查找单个数据模型(渠道的文章)
$articleModelItem = $articleModel::find()->where(['task_id' => $taskEnabledItem->id])->isDeletedNo()->one();
// 如果未找到数据模型，将抛出 404 HTTP 异常
if (!isset($articleModelItem)) {
throw new NotFoundHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35091'), ['task_id' => $taskEnabledItem->id])), 35091);
}
/* 判断状态，如果未启用，将抛出 422 HTTP 异常 */
if ($articleModelItem->status !== $articleModelItem::STATUS_ENABLED) {
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35092'), ['task_id' => $taskEnabledItem->id])), 35092);
}
// 基于ID查找状态为启用的单个数据模型(文章类型)
$articleTypeEnabledItem = ArticleTypeService::findModelEnabledById($articleModelItem->article_type_id);
$serviceAction = 'pubArticle' . str_replace(' ', '', ucwords(str_replace('_', ' ', $articleTypeEnabledItem->code))) . 'Sync'; // 例：pubArticleVideoSync
$serviceClass::$serviceAction($this->channelAppTaskId);
}
}
49. Queue event handler (after each successful execution of the job): call the corresponding service (after the job execution is successful) for subsequent processing, the call of the corresponding service fails (that is, the service throws an exception), and only inserts the system log; the queue Event handler (when an uncaught exception occurs during job execution): call the corresponding service (after the job execution fails) for subsequent processing, call the corresponding service (that is, the service throws an exception), and only insert the system log. Edit \Common\Components\Queue\PubarticleEventHandler.php
* @since 1.0
*/
class PubArticleEventHandler extends Component
{
/**
* @param ExecEvent $event
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws UnprocessableEntityHttpException 如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
*/
public static function afterExec(ExecEvent $event)
{
$channelAppTaskId = $event->job->channelAppTaskId;
// 基于ID查找状态为启用的单个数据模型(渠道的应用的任务)
$channelAppTaskEnabledItem = ChannelAppTaskService::findModelEnabledById($channelAppTaskId);
// 基于ID查找状态为启用的单个数据模型(任务)
$taskEnabledItem = TaskService::findModelEnabledById($channelAppTaskEnabledItem->task_id);
$serviceClass = 'common\services\\' . str_replace(' ', '', ucwords(str_replace('_', ' ', $taskEnabledItem->channel_type_code))) . 'ArticleService'; // 例：common\services\QqCwArticleService
$articleModel = 'common\logics\\' . str_replace(' ', '', ucwords(str_replace('_', ' ', $taskEnabledItem->channel_code))) . 'Article'; // 例：common\logics\QqArticle
// 基于任务ID查找单个数据模型(渠道的文章)
$articleModelItem = $articleModel::find()->where(['task_id' => $taskEnabledItem->id])->isDeletedNo()->one();
// 如果未找到数据模型，将抛出 404 HTTP 异常
if (!isset($articleModelItem)) {
throw new NotFoundHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35091'), ['task_id' => $taskEnabledItem->id])), 35091);
}
/* 判断状态，如果未启用，将抛出 422 HTTP 异常 */
if ($articleModelItem->status !== $articleModelItem::STATUS_ENABLED) {
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35092'), ['task_id' => $taskEnabledItem->id])), 35092);
}
// 基于ID查找状态为启用的单个数据模型(文章类型)
$articleTypeEnabledItem = ArticleTypeService::findModelEnabledById($articleModelItem->article_type_id);
$serviceAction = 'pubArticle' . str_replace(' ', '', ucwords(str_replace('_', ' ', $articleTypeEnabledItem->code))) . 'ExecHandler'; // 例：pubArticleVideoExecHandler
$serviceClass::$serviceAction($channelAppTaskId);
}
/**
* @param ExecEvent $event
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws UnprocessableEntityHttpException 如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
*/
public static function afterError(ExecEvent $event)
{
$channelAppTaskId = $event->job->channelAppTaskId;
// 基于ID查找状态为启用的单个数据模型(渠道的应用的任务)
$channelAppTaskEnabledItem = ChannelAppTaskService::findModelEnabledById($channelAppTaskId);
// 基于ID查找状态为启用的单个数据模型(任务)
$taskEnabledItem = TaskService::findModelEnabledById($channelAppTaskEnabledItem->task_id);
$serviceClass = 'common\services\\' . str_replace(' ', '', ucwords(str_replace('_', ' ', $taskEnabledItem->channel_type_code))) . 'ArticleService'; // 例：common\services\QqCwArticleService
$articleModel = 'common\logics\\' . str_replace(' ', '', ucwords(str_replace('_', ' ', $taskEnabledItem->channel_code))) . 'Article'; // 例：common\logics\QqArticle
// 基于任务ID查找单个数据模型(渠道的文章)
$articleModelItem = $articleModel::find()->where(['task_id' => $taskEnabledItem->id])->isDeletedNo()->one();
// 如果未找到数据模型，将抛出 404 HTTP 异常
if (!isset($articleModelItem)) {
throw new NotFoundHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35091'), ['task_id' => $taskEnabledItem->id])), 35091);
}
/* 判断状态，如果未启用，将抛出 422 HTTP 异常 */
if ($articleModelItem->status !== $articleModelItem::STATUS_ENABLED) {
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35092'), ['task_id' => $taskEnabledItem->id])), 35092);
}
// 基于ID查找状态为启用的单个数据模型(文章类型)
$articleTypeEnabledItem = ArticleTypeService::findModelEnabledById($articleModelItem->article_type_id);
$serviceAction = 'pubArticle' . str_replace(' ', '', ucwords(str_replace('_', ' ', $articleTypeEnabledItem->code))) . 'ErrorHandler'; // 例：pubArticleVideoErrorHandler
$serviceClass::$serviceAction($channelAppTaskId, $event->error);
}
}
50. The realization of the article service of the content website application of the Penguin account, edit \common\services\qqcWarticleservice.php
id);
$channelAppTaskEnabledItems[] = $channelAppTaskEnabledItem;
$pubLogDatas = [];
foreach ($channelAppTaskEnabledItems as $key => $channelAppTaskEnabledItem) {
// 基于渠道的应用的任务ID查找单个数据模型(企鹅号的内容网站应用的任务)
$qqCwAppTaskItem = QqCwAppTaskService::findModelByChannelAppTaskId($channelAppTaskEnabledItem->id);
$pubLogDatas[$key] = [
'channel_app_source_uuid' => $channelAppTaskEnabledItem->channel_app_source_uuid,
'channel_app_task_uuid' => $channelAppTaskEnabledItem->uuid,
'channel_code' => $channelAppTaskEnabledItem->channel_code,
'channel_type_code' => $channelAppTaskEnabledItem->channel_type_code,
'channel_app_task_status' => $qqCwAppTaskItem->status,
];
}
// 发布任务失败后，插入发布日志，将作业推送至来源回调队列(异步)
SourceCallbackService::sourceCallbackAsync($channelAppTaskEnabledItems, $eventError->getCode(), $eventError->getMessage(), $pubLogDatas, PubLog::STATUS_ERROR);
// 基于ID查找状态为启用的单个数据模型(任务)
$taskEnabledItem = TaskService::findModelEnabledById($channelAppTaskEnabledItem->task_id);
// 基于企鹅号的内容网站应用的任务ID查找状态为启用的单个资源(微信公众帐号应用的任务与企鹅号的内容网站应用的任务的关联)
$wxTaskQqCwTaskRelationItem = WxTaskQqCwTaskRelation::findOneEnabledByQqCwTaskId($taskEnabledItem->id);
if (isset($wxTaskQqCwTaskRelationItem)) {
WxArticleService::qqCwPubArticleVideoErrorHandler($wxTaskQqCwTaskRelationItem->wx_task_id, $eventError);
}
}
/**
* 企鹅号的内容网站应用的发布文章类型：视频(视频)的文章至企鹅号平台，队列任务执行成功后，调用相应服务，否则，插入发布日志(异步)
*
* @param int $channelAppTaskId 渠道的应用的任务ID
* 格式如下：37
*
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws UnprocessableEntityHttpException 如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
*/
public static function pubArticleVideoAsync($channelAppTaskId)
{
// 基于ID查找状态为启用的单个数据模型(渠道的应用的任务)
$channelAppTaskEnabledItem = ChannelAppTaskService::findModelEnabledById($channelAppTaskId);
// 将任务发送到队列，通过标准工作人员进行处理
Yii::$app->pubArticleQueue->push(new PubArticleJob([
'channelAppTaskId' => $channelAppTaskEnabledItem->id,
]));
}
/**
* 企鹅号的内容网站应用的发布文章类型：视频(视频)的文章至企鹅号平台(同步)
*
* @param int $channelAppTaskId 渠道的应用的任务ID
* 格式如下：37
*
* @throws NotFoundHttpException 如果未找到数据模型，将抛出 404 HTTP 异常
* @throws UnprocessableEntityHttpException 如果找到数据模型，状态未启用，将抛出 422 HTTP 异常
* @throws ServerErrorHttpException
* @throws \Throwable
*/
public static function pubArticleVideoSync($channelAppTaskId)
{
// 基于ID查找状态为启用的单个数据模型(渠道的应用的任务)
$channelAppTaskEnabledItem = ChannelAppTaskService::findModelEnabledById($channelAppTaskId);
// 基于ID查找状态为启用的单个数据模型(任务)
$taskEnabledItem = TaskService::findModelEnabledById($channelAppTaskEnabledItem->task_id);
// 基于任务ID查找状态为启用的单个数据模型(企鹅号的文章)
$qqArticleEnabledItem = QqArticleService::findModelEnabledByTaskId($taskEnabledItem->id);
// 基于企鹅号的文章ID查找状态为启用的单个数据模型(企鹅号的文章类型(视频)的文章)
$qqArticleMultivideosEnabledItem = QqArticleMultivideosService::findModelEnabledByQqArticleId($qqArticleEnabledItem->id);
// 基于渠道的应用的任务ID查找状态为发布中的单个数据模型(企鹅号的内容网站应用的任务)
$qqCwAppTaskItem = QqCwAppTaskService::findModelPublishByChannelAppTaskId($channelAppTaskId);
// 基于ID查找状态为启用的单个数据模型(企鹅号的内容网站应用)
$qqCwAppEnabledItem = QqCwAppService::findModelEnabledById($qqCwAppTaskItem->qq_cw_app_id);
// 基于企鹅号的内容网站应用ID获取有效的 Access Token
$qqCwAccessTokenService = new QqCwAccessTokenService();
$accessTokenValidity = $qqCwAccessTokenService->getAccessTokenValidityByQqCwAppId($qqCwAppEnabledItem->id);
// 基于企鹅号的应用类型、类型、企鹅号的应用的任务ID查找状态为成功的单个数据模型(企鹅号的事务)
$qqTransactionSuccessItem = QqTransactionService::findModelSuccessByQqAppTypeAndTypeAndQqAppTaskId(QqArticle::QQ_APP_TYPE_CW, QqTransaction::TYPE_VIDEO, $qqCwAppTaskItem->id);
// 基于企鹅号的应用的视频文件分片上传ID查找状态为已上传的单个数据模型(企鹅号的内容网站应用的视频文件分片上传)
$qqCwVideoMultipartUploadUploadedItem = QqVideoMultipartUploadService::findModelUploadedById($qqTransactionSuccessItem->qq_video_multipart_upload_id);
// 子字符串替换，将 ，替换为 空格
$tag = str_replace(',', ' ', $qqArticleMultivideosEnabledItem->tag);
// HTTP请求，基于企鹅号的内容网站应用的视频文件唯一标示ID发布视频文章
$httpPubVideoData = [
'accessToken' => $accessTokenValidity->access_token,
'title' => $qqArticleEnabledItem->title,
'tag' => $tag,
'category' => $qqArticleMultivideosEnabledItem->category,
'desc' => $qqArticleMultivideosEnabledItem->desc,
'vid' => $qqCwVideoMultipartUploadUploadedItem->vid,
'apply' => $qqArticleMultivideosEnabledItem->apply,
];
$pubVideoData = static::httpPubVideo($httpPubVideoData);
// $pubVideoData = ['transaction_id' => 780935222316202025];
// HTTP请求，基于视频文章的唯一事务ID获取事务信息
$qqTransactionService = new QqTransactionService();
$qqTransactionServiceHttpTransactionInfoData = [
'accessToken' => $accessTokenValidity->access_token,
'transactionId' => $pubVideoData['transaction_id'],
];
$qqTransactionServiceHttpTransactionInfoResult = $qqTransactionService->httpTransactionInfo($qqTransactionServiceHttpTransactionInfoData);
// 创建企鹅号的事务
$qqTransaction = new QqTransaction();
$qqTransaction->attributes = [
'group_id' => $taskEnabledItem->group_id,
'qq_app_task_id' => $qqCwVideoMultipartUploadUploadedItem->qq_app_task_id,
'qq_app_id' => $qqCwVideoMultipartUploadUploadedItem->qq_app_id,
'qq_app_type' => QqArticle::QQ_APP_TYPE_CW,
'qq_article_id' => $qqArticleEnabledItem->id,
'qq_video_multipart_upload_id' => 0,
'transaction_id' => (string) $pubVideoData['transaction_id'],
'type' => $qqTransactionService::getTypeByHttpQqApiTransactionType($qqTransactionServiceHttpTransactionInfoResult['transaction_type']),
'transaction_ctime' => $qqTransactionServiceHttpTransactionInfoResult['transaction_ctime'],
'ext_err' => $qqTransactionServiceHttpTransactionInfoResult['ext_err'],
'transaction_err_msg' => $qqTransactionServiceHttpTransactionInfoResult['transaction_err_msg'],
'article_abstract' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_abstract'],
'article_type' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_type'],
'article_type_code' => QqArticleType::CODE_MULTIVIDEOS,
'article_url' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_url'],
'article_imgurl' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_imgurl'],
'article_title' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_title'],
'article_pub_flag' => HttpQqApiTransaction::ARTICLE_PUB_FLAG_REVIEW,
'article_pub_time' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_pub_time'],
'article_video_title' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_video_info']['title'],
'article_video_desc' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_video_info']['desc'],
'article_video_type' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_video_info']['type'],
'article_video_vid' => $qqTransactionServiceHttpTransactionInfoResult['article_info']['article_video_info']['vid'],
'task_id' => $taskEnabledItem->id,
'status' => QqTransaction::STATUS_PROCESSING,
];
$qqTransactionServiceCreateResult = $qqTransactionService->create($qqTransaction);
if ($qqTransactionServiceCreateResult['status'] === false) {
throw new ServerErrorHttpException($qqTransactionServiceCreateResult['message'], $qqTransactionServiceCreateResult['code']);
}
// 更新企鹅号的内容网站应用的任务状态，4：审核中
$qqCwAppTaskService = new QqCwAppTaskService();
$qqCwAppTaskItem->status = QqCwAppTask::STATUS_REVIEW;
$qqCwAppTaskServiceUpdateResult = $qqCwAppTaskService->update($qqCwAppTaskItem);
if ($qqCwAppTaskServiceUpdateResult['status'] === false) {
throw new ServerErrorHttpException($qqCwAppTaskServiceUpdateResult['message'], $qqCwAppTaskServiceUpdateResult['code']);
}
}
/**
* HTTP请求，基于企鹅号的内容网站应用的视频文件唯一标示ID发布视频文章
* @param array $data 数据
* 格式如下：
*
* [
* 'accessToken' => 'QVBII-BJMBCYQZ9XYU3OAQ', // 企鹅平台企鹅号应用授权调用凭据
* 'title' => '标题 - 20180901 - 1', // 视频文章标题
* 'tag' => '北上广深 租金 上涨', // 视频文章标签
* 'category' => 100, // 视频分类，即企鹅号的文章类型(视频)的文章分类ID
* 'desc' => '视频描述', // 视频描述
* 'vid' => 'j0789dzdjut', // 视频文件唯一标示ID
* 'apply' => 0, // 是否申请原创文章，0：否；1：是(需要用户具有发表视频原创文章资格否则无效)
* ]
*
* @return array
* 格式如下：
*
* [
* 'transaction_id' => 780930255958621794, // 视频文章的唯一事务ID
* ]
*
* @throws ServerErrorHttpException
*/
public static function httpPubVideo($data)
{
/* HTTP请求，基于企鹅号的内容网站应用的视频文件唯一标示ID发布视频文章 */
$httpQqApiArticle = new HttpQqApiArticle();
$pubVideo = $httpQqApiArticle->clientPubVideo($data);
if ($pubVideo === false) {
if ($httpQqApiArticle->hasErrors()) {
foreach ($httpQqApiArticle->getFirstErrors() as $message) {
$firstErrors = $message;
break;
}
throw new ServerErrorHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35042'), ['firstErrors' => $firstErrors])), 35042);
} elseif (!$httpQqApiArticle->hasErrors()) {
throw new ServerErrorHttpException('Penguin\'s content website application api HTTP requests fail for unknown reasons.');
}
}
return $pubVideo['data'];
}
/**
* 发布视频(视频)的文章至渠道发布(提供给其他渠道使用)，输入数据验证规则可参考：发布文章类型：视频(视频)的文章至渠道发布 /articles/video(article/video-create)
*
* @param array $data 数据
* 格式如下：
*
* [
* 'source' => 'spider', // 来源，xContent：内容库；vms：视频管理系统；cms：内容管理系统；spider：自媒体；channel-pub-api：渠道发布接口
* 'source_uuid' => '825e6d5e36468cc4bf536799ce3565cf', // 来源ID(UUID)
* 'source_pub_user_id' => 1, // 来源发布用户ID
* 'source_callback_url' => 'source_callback_url', // 来源回调地址
* 'article_category_id' => 1, // 文章分类ID
* 'title' => '标题 - 20180901 - 1', // 标题
* 'author' => '作者 - 20180901 - 1', // 作者
* 'source_article_id' => 1, // 来源文章ID
* 'media_absolute_url' => 'http://127.0.0.1/channel-pub-api/storage/spider/videos/7月份北上广深等十大城市租金环比上涨 看东方 20180820 高清_高清.mp4', // 视频文件的绝对URL
* 'tag' => '北上广深,租金,上涨', // 视频文章标签，以英文半角逗号分隔，最多5个，每个标签最多8个字
* 'apply' => 0, // 是否申请原创文章，0：否；1：是(需要用户具有发表视频原创文章资格否则无效)
* 'desc' => '视频描述', // 视频描述
* 'group_id' => 'spider', // 租户ID
* ]
*
* @param string $channelTypeCode 渠道的类型代码
*
* @return array
* 格式如下：
*
* [
* 'status' => true, // 成功
* 'code' => 10000, // 返回码
* 'message' => '发布文章类型：视频(视频)的文章成功', // 说明
* 'data' => [ // array
* [ // object
* 'channel_id' => 1, // 渠道ID
* 'channel_code' => 'qq', // 渠道代码，qq：企鹅号；wx：微信公众帐号
* 'channel_type_id' => 1, // 渠道的类型ID
* 'channel_type_code' => 'qq_cw', // 渠道的类型代码，qq_cw：企鹅号的内容网站应用；qq_tp：企鹅号的第三方服务平台应用；wx：微信公众帐号应用
* 'channel_app_source_id' => 1, // 渠道的应用的来源ID
* 'channel_app_source_uuid' => 'a3f87610e17011e88f0154ee75d2ebc1', // 渠道的应用的来源ID(UUID)
* 'task_id' => 8, // 任务ID
* 'status' => 1, // 状态，0：禁用；1：启用
* 'created_at' => 1541730602, // 创建时间
* 'updated_at' => 1541730602, // 更新时间
* 'uuid' => '5ce1f7f2e3c711e8bc2354ee75d2ebc1', // 渠道的应用的任务ID(UUID)
* 'id' => 13, // ID
* ],
* ]
* ]
*
* [
* 'status' => false, // 失败
* 'code' => 35024, // 返回码
* 'message' => '文章类型代码：video，的状态为未启用', // 说明
* ]
*
* @throws UnprocessableEntityHttpException
* @throws ServerErrorHttpException
* @throws \Throwable
*/
public function videoCreate($data, $channelTypeCode)
{
// 判断渠道的类型代码
if ($channelTypeCode == ChannelType::CODE_WX) {
// 基于 Client ID 查找状态为启用的单个数据模型(企鹅号的内容网站应用)
$qqCwAppEnabledItem = QqCwAppService::findModelEnabledByClientId(Yii::$app->params['qqAuth']['cwApp']['clientId']);
} else {
// 基于 Client ID 查找状态为启用的单个数据模型(企鹅号的内容网站应用)
$qqCwAppEnabledItem = QqCwAppService::findModelEnabledByClientId(Yii::$app->params['qqAuth']['cwApp']['clientId']);
}
$data['channel_app_source_uuids'] = [$qqCwAppEnabledItem->channel_app_source_uuid];
// 基于代码查找状态为启用的单个数据模型(渠道)
$channelEnabledItem = ChannelService::findModelEnabledByCode(Channel::CODE_QQ);
/* 视频(视频)的文章发布参数 */
$qqArticleVideoCreateParam = new QqArticleVideoCreateParam();
// 把请求数据填充到模型中
if (!$qqArticleVideoCreateParam->load($data, '')) {
return ['status' => false, 'code' =>35073, 'message' => Yii::t('common/error', '35073')];
}
// 验证模型
if (!$qqArticleVideoCreateParam->validate()) {
$qqArticleVideoCreateParamResult = self::handleValidateError($qqArticleVideoCreateParam);
if ($qqArticleVideoCreateParamResult['status'] === false) {
return ['status' => false, 'code' =>$qqArticleVideoCreateParamResult['code'], 'message' => $qqArticleVideoCreateParamResult['message']];
}
}
/* 基于文章类型代码定义场景 */
$scenario = QqArticle::SCENARIO_VIDEO_CREATE;
/* 实例化多个模型 */
// 渠道的应用的来源
if (!is_array($data['channel_app_source_uuids'])) {
return ['status' => false, 'code' =>35073, 'message' => Yii::t('common/error', '35073')];
}
// 基于多个UUID返回状态为启用，且渠道的类型代码必须一致的数据模型(渠道的应用的来源)列表
$channelAppSourceEnabledItems = ChannelAppSourceService::findModelsEnabledByUuids($data['channel_app_source_uuids']);
// 获取、判断渠道的类型代码，获取应用的数据模型列表
$channelTypeCode = $channelAppSourceEnabledItems[$data['channel_app_source_uuids'][0]]->channel_type_code;
if ($channelTypeCode == ChannelType::CODE_QQ_CW) {
// 基于代码查找状态为启用的单个数据模型(渠道的类型)
$channelTypeEnabledItem = ChannelTypeService::findModelEnabledByCode(ChannelType::CODE_QQ_CW);
// 基于多个UUID返回状态为启用的数据模型(企鹅号的内容网站应用)列表
$qqAppEnabledItems = QqCwAppService::findModelsEnabledByChannelAppSourceUuids($data['channel_app_source_uuids']);
} else {
throw new UnprocessableEntityHttpException(Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35074'), ['channel_type_code' => $channelTypeCode])), 35074);
}
// 任务
$task = new Task([
'scenario' => Task::SCENARIO_CREATE,
]);
// 转换视频(视频)的文章发布参数，多模型的填充、验证的实现
$data[$task->formName()] = [
'group_id' => $data['group_id'],
'source' => $qqArticleVideoCreateParam->source,
'source_uuid' => $qqArticleVideoCreateParam->source_uuid,
'source_pub_user_id' => $qqArticleVideoCreateParam->source_pub_user_id,
'source_callback_url' => $qqArticleVideoCreateParam->source_callback_url,
];
$taskResult = self::handleLoadAndValidate($task, $data);
if ($taskResult['status'] === false) {
return ['status' => false, 'code' =>$taskResult['code'], 'message' => $taskResult['message']];
}
// 基于代码查找状态为启用的单个数据模型(文章类型)
$articleTypeEnabledItem = ArticleTypeService::findModelEnabledByCode(ArticleType::CODE_VIDEO);
// 基于代码查找状态为启用的单个数据模型(企鹅号的文章类型)
$qqArticleTypeEnabledItem = QqArticleTypeService::findModelEnabledByCode(QqArticleType::CODE_MULTIVIDEOS);
// 文章分类
$articleCategory = new ArticleCategory([
'scenario' => $scenario,
]);
// 转换视频(视频)的文章发布参数，多模型的填充、验证的实现
$data[$articleCategory->formName()]['id'] = $qqArticleVideoCreateParam->article_category_id;
$articleCategoryResult = self::handleLoadAndValidate($articleCategory, $data);
if ($articleCategoryResult['status'] === false) {
return ['status' => false, 'code' =>$articleCategoryResult['code'], 'message' => $articleCategoryResult['message']];
}
// 基于文章分类ID查找状态为启用的单个数据模型(企鹅号的文章类型(视频)的文章分类)
$qqArticleCategoryMultivideosEnabledItem = QqArticleCategoryMultivideosService::findModelEnabledByArticleCategoryId($qqArticleVideoCreateParam->article_category_id);
// 企鹅号的文章
$model = new QqArticle([
'scenario' => QqArticle::SCENARIO_CREATE,
]);
// 转换视频(视频)的文章发布参数，多模型的填充、验证的实现
$data[$model->formName()] = [
'group_id' => $data['group_id'],
'article_category_id' => $qqArticleVideoCreateParam->article_category_id,
'title' => $qqArticleVideoCreateParam->title,
'author' => $qqArticleVideoCreateParam->author,
'source_article_id' => $qqArticleVideoCreateParam->source_article_id,
];
$modelResult = self::handleLoadAndValidate($model, $data);
if ($modelResult['status'] === false) {
return ['status' => false, 'code' =>$modelResult['code'], 'message' => $modelResult['message']];
}
// 企鹅号的文章类型(视频)的文章
$qqArticleMultivideos = new QqArticleMultivideos([
'scenario' => QqArticleMultivideos::SCENARIO_CREATE,
]);
// 转换视频(视频)的文章发布参数，多模型的填充、验证的实现
$data[$qqArticleMultivideos->formName()] = [
'media' => $qqArticleVideoCreateParam->media_absolute_url,
'tag' => $qqArticleVideoCreateParam->tag,
'desc' => $qqArticleVideoCreateParam->desc,
'apply' => $qqArticleVideoCreateParam->apply,
];
$qqArticleMultivideosResult = self::handleLoadAndValidate($qqArticleMultivideos, $data);
if ($qqArticleMultivideosResult['status'] === false) {
return ['status' => false, 'code' =>$qqArticleMultivideosResult['code'], 'message' => $qqArticleMultivideosResult['message']];
}
/* 操作数据(事务) */
$qqArticleService = new QqArticleService();
$result = $qqArticleService->videoCreate($channelEnabledItem, $channelTypeEnabledItem, $channelAppSourceEnabledItems, $qqAppEnabledItems, $articleTypeEnabledItem, $qqArticleTypeEnabledItem, $qqArticleCategoryMultivideosEnabledItem, $task, $model, $qqArticleMultivideos, false);
if ($result['status'] === false) {
throw new ServerErrorHttpException($result['message'], $result['code']);
}
return ['status' => true, 'code' =>10000, 'message' => Yii::t('common/success', '25001'), 'data' => $result['data']];
}
/**
* 处理模型填充与验证
* @param object $model 模型
* @param array $requestParams 请求参数
* @return array
* 格式如下：
*
* [
* 'status' => true, // 成功
* ]
*
* [
* 'status' => false, // 失败
* 'code' => 35024, // 返回码
* 'message' => '数据验证失败：企鹅号ID(UUID)是无效的。', // 说明
* ]
*
* @throws ServerErrorHttpException
*/
public static function handleLoadAndValidate($model, $requestParams)
{
// 把请求数据填充到模型中
if (!$model->load($requestParams)) {
return ['status' => false, 'code' => 35073, 'message' => Yii::t('common/error', '35073')];
}
// 验证模型
if (!$model->validate()) {
return self::handleValidateError($model);
}
return ['status' => true];
}
/**
* 处理模型错误
* @param object $model 模型
* @return array
* 格式如下：
*
* [
* 'status' => false, // 失败
* 'code' => 35024, // 返回码
* 'message' => '数据验证失败：代码是无效的。', // 说明
* ]
*
* @throws ServerErrorHttpException
*/
public static function handleValidateError($model)
{
if ($model->hasErrors()) {
$response = Yii::$app->getResponse();
$response->setStatusCode(422, 'Data Validation Failed.');
foreach ($model->getFirstErrors() as $message) {
$firstErrors = $message;
break;
}
return ['status' => false, 'code' => 35024, 'message' => Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35024'), ['firstErrors' => $firstErrors]))];
} elseif (!$model->hasErrors()) {
throw new ServerErrorHttpException('Failed to create the object for unknown reason.');
}
}
/**
* 处理模型错误
* @param array $models 模型列表
* @return array
* 格式如下：
*
* [
* 'status' => false, // 失败
* 'code' => 35024, // 返回码
* 'message' => '数据验证失败：代码是无效的。', // 说明
* ]
*
* @throws ServerErrorHttpException
*/
public static function handleValidateMultipleError($models)
{
foreach ($models as $model) {
if ($model->hasErrors()) {
$response = Yii::$app->getResponse();
$response->setStatusCode(422, 'Data Validation Failed.');
foreach ($model->getFirstErrors() as $message) {
$firstErrors = $message;
break;
}
return ['status' => false, 'code' => 35024, 'message' => Yii::t('common/error', Yii::t('common/error', Yii::t('common/error', '35024'), ['firstErrors' => $firstErrors]))];
}
}
throw new ServerErrorHttpException('Failed to create the object for unknown reason.');
}
}
51. Start from scratch, test the normal process, and publish an article to 2 penguins at the same time (and 2 are successful, in the last process), POSThttp://api.channel-pub-api.localhost/qq/v1/articles/video?group_id=spider
request body
{
"channel_app_source_uuids": ["dc74d79ef6ca11e88b4654ee75d2ebc1", "0102512cf6cb11e89b1754ee75d2ebc1"],
"source": "spider",
"source_uuid": "825e6d5e36468cc4bf536799ce3565cf",
"source_pub_user_id": 1,
"source_callback_url": "http://wjdev.chinamcloud.com:8609/cms/api/thirdPush/callBack",
"article_category_id": 110,
"title": "Flutter移动应用：动画的介绍",
"author": "华栖云秀",
"source_article_id": 1,
"media_absolute_url": "http://127.0.0.1/channel-pub-api/storage/spider/videos/flutter-animation-00-00-intro-1940143128.mp4",
"tag": "Flutter,移动,应用,动画,介绍",
"apply": 0,
"desc": "这个课程我们会学一下怎么样创建和使用 Flutter 里的 Animation .. 也就是动画 .. 先了解一下 AnimationController .. 动画控制器 .. 它可以控制动画的运行状态 .."
}
Response body
{
"code": 10000,
"message": "发布文章类型：视频(视频)的文章成功",
"data": [
{
"channel_id": 1,
"channel_code": "qq",
"channel_type_id": 1,
"channel_type_code": "qq_cw",
"channel_app_source_id": 11,
"channel_app_source_uuid": "dc74d79ef6ca11e88b4654ee75d2ebc1",
"task_id": 81,
"status": 1,
"created_at": 1543975716,
"updated_at": 1543975716,
"uuid": "ace019b2f83211e8a1e154ee75d2ebc1",
"id": 91
},
{
"channel_id": 1,
"channel_code": "qq",
"channel_type_id": 1,
"channel_type_code": "qq_cw",
"channel_app_source_id": 12,
"channel_app_source_uuid": "0102512cf6cb11e89b1754ee75d2ebc1",
"task_id": 81,
"status": 1,
"created_at": 1543975716,
"updated_at": 1543975716,
"uuid": "ace1aff2f83211e888c154ee75d2ebc1",
"id": 92
}
]
}
52. Execute the SQL statement as follows:
SELECT * FROM `cpa_channel` WHERE (`code`='qq') AND (`is_deleted`=0)
SELECT * FROM `cpa_channel_app_source` WHERE (`uuid` IN ('dc74d79ef6ca11e88b4654ee75d2ebc1', '0102512cf6cb11e89b1754ee75d2ebc1')) AND (`is_deleted`=0)
SELECT * FROM `cpa_channel_type` WHERE (`code`='qq_cw') AND (`is_deleted`=0)
SELECT * FROM `cpa_qq_cw_app` WHERE (`channel_app_source_uuid` IN ('dc74d79ef6ca11e88b4654ee75d2ebc1', '0102512cf6cb11e89b1754ee75d2ebc1')) AND (`is_deleted`=0)
SELECT * FROM `cpa_article_type` WHERE (`code`='video') AND (`is_deleted`=0)
SELECT * FROM `cpa_qq_article_type` WHERE (`code`='multivideos') AND (`is_deleted`=0)
SELECT EXISTS(SELECT * FROM `cpa_article_category` WHERE (`cpa_article_category`.`id`=110) AND ((`is_deleted`=0) AND (`status`=1)))
SELECT * FROM `cpa_qq_article_category_multivideos` WHERE (`article_category_id`=110) AND (`is_deleted`=0)
INSERT INTO `cpa_task` (`group_id`, `source`, `source_uuid`, `source_pub_user_id`, `source_callback_url`, `channel_id`, `channel_code`, `channel_type_id`, `channel_type_code`, `status`, `created_at`, `updated_at`) VALUES ('spider', 'spider', '825e6d5e36468cc4bf536799ce3565cf', 1, 'http://wjdev.chinamcloud.com:8609/cms/api/thirdPush/callBack', 1, 'qq', 1, 'qq_cw', 1, 1543975716, 1543975716)
INSERT INTO `cpa_channel_app_task` (`channel_id`, `channel_code`, `channel_type_id`, `channel_type_code`, `channel_app_source_id`, `channel_app_source_uuid`, `task_id`, `status`, `created_at`, `updated_at`, `uuid`) VALUES (1, 'qq', 1, 'qq_cw', 11, 'dc74d79ef6ca11e88b4654ee75d2ebc1', 81, 1, 1543975716, 1543975716, 'ace019b2f83211e8a1e154ee75d2ebc1')
INSERT INTO `cpa_qq_cw_app_task` (`channel_app_task_id`, `channel_app_task_uuid`, `qq_cw_app_id`, `task_id`, `status`, `created_at`, `updated_at`) VALUES (91, 'ace019b2f83211e8a1e154ee75d2ebc1', 8, 81, 1, 1543975716, 1543975716)
INSERT INTO `cpa_channel_app_task` (`channel_id`, `channel_code`, `channel_type_id`, `channel_type_code`, `channel_app_source_id`, `channel_app_source_uuid`, `task_id`, `status`, `created_at`, `updated_at`, `uuid`) VALUES (1, 'qq', 1, 'qq_cw', 12, '0102512cf6cb11e89b1754ee75d2ebc1', 81, 1, 1543975716, 1543975716, 'ace1aff2f83211e888c154ee75d2ebc1')
INSERT INTO `cpa_qq_cw_app_task` (`channel_app_task_id`, `channel_app_task_uuid`, `qq_cw_app_id`, `task_id`, `status`, `created_at`, `updated_at`) VALUES (92, 'ace1aff2f83211e888c154ee75d2ebc1', 9, 81, 1, 1543975716, 1543975716)
INSERT INTO `cpa_qq_article` (`group_id`, `article_category_id`, `title`, `author`, `source_article_id`, `qq_app_type`, `article_type_id`, `qq_article_type_id`, `qq_article_category_id`, `task_id`, `status`, `created_at`, `updated_at`) VALUES ('spider', 110, 'Flutter移动应用：动画的介绍', '华栖云秀', 1, 'cw', 3, 2, 807, 81, 1, 1543975716, 1543975716)
INSERT INTO `cpa_qq_article_multivideos` (`media`, `tag`, `desc`, `apply`, `qq_article_id`, `category`, `md5`, `vid`, `task_id`, `status`, `created_at`, `updated_at`) VALUES ('', 'Flutter,移动,应用,动画,介绍', '这个课程我们会学一下怎么样创建和使用 Flutter 里的 Animation .. 也就是动画 .. 先了解一下 AnimationController .. 动画控制器 .. 它可以控制动画的运行状态 ..', 0, 73, 807, '', '', 81, 1, 1543975716, 1543975716)
INSERT INTO `cpa_asset` (`channel_id`, `channel_code`, `channel_type_id`, `channel_type_code`, `source`, `type`, `absolute_url`, `relative_path`, `size`, `task_id`, `channel_article_id`, `status`, `is_deleted`, `created_at`, `updated_at`, `deleted_at`) VALUES (1, 'qq', 1, 'qq_cw', 'spider', 'video', 'http://127.0.0.1/channel-pub-api/storage/spider/videos/flutter-animation-00-00-intro-1940143128.mp4', '', 0, 81, 73, 1, 0, 1543975716, 1543975716, 0)
53. View the status information of 4 queues
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/info --color=0
Jobs
- waiting: 1
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii upload-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii pub-article-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
54. The run command obtains and executes the tasks in the loop (copying the resource file queue) until the queue is empty, the job of the copy of the resource file queue is successfully executed, and the execution result is as expected, and the job has been pushed to the upload resource queue
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/run --verbose=1 --isolate=1 --color=0
2018-12-05 10:10:36 [pid: 22424] - Worker is started
2018-12-05 10:10:37 [1] common\jobs\CopyAssetJob (attempt: 1, pid: 22424) - Started
2018-12-05 10:10:37 [1] common\jobs\CopyAssetJob (attempt: 1, pid: 22424) - Done (0.261 s)
2018-12-05 10:10:37 [pid: 22424] - Worker is stopped (0:00:01)
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 1
PS E:\wwwroot\channel-pub-api> ./yii upload-asset-queue/info --color=0
Jobs
- waiting: 2
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii pub-article-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
55. The run command obtains and executes the tasks in the loop (upload resource file queues) until the queue is empty, the job of uploading the resource file queue is successful, and the execution result is as expected, and the video transaction record has been inserted into the transaction table, as shown in Figure 10
Figure 10
PS E:\wwwroot\channel-pub-api> ./yii upload-asset-queue/run --verbose=1 --isolate=1 --color=0
2018-12-05 10:11:52 [pid: 20084] - Worker is started
2018-12-05 10:11:52 [1] common\jobs\UploadAssetJob (attempt: 1, pid: 20084) - Started
2018-12-05 10:11:58 [1] common\jobs\UploadAssetJob (attempt: 1, pid: 20084) - Done (5.706 s)
2018-12-05 10:11:58 [2] common\jobs\UploadAssetJob (attempt: 1, pid: 20084) - Started
2018-12-05 10:12:03 [2] common\jobs\UploadAssetJob (attempt: 1, pid: 20084) - Done (5.028 s)
2018-12-05 10:12:04 [pid: 20084] - Worker is stopped (0:00:12)
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 1
PS E:\wwwroot\channel-pub-api> ./yii upload-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 2
PS E:\wwwroot\channel-pub-api> ./yii pub-article-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
56. Console command: get the video transaction of the Penguin interface of the content website application of the Penguin number, and synchronize it to the video transaction of the Penguin number of the content website application of the Penguin number.
PS E:\wwwroot\channel-pub-api> ./yii qq-cw-transaction-video/sync
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 1
PS E:\wwwroot\channel-pub-api> ./yii upload-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 2
PS E:\wwwroot\channel-pub-api> ./yii pub-article-queue/info --color=0
Jobs
- waiting: 2
- delayed: 0
- reserved: 0
- done: 0
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
57. The run command obtains and executes the tasks in the loop (publishing article queue), until the queue is empty, the job of the published article queue is successfully executed, and the execution result is as expected, and the article transaction record has been inserted into the transaction table, as shown in Figure 11
Figure 11
PS E:\wwwroot\channel-pub-api> ./yii pub-article-queue/run --verbose=1 --isolate=1 --color=0
2018-12-05 10:13:56 [pid: 19856] - Worker is started
2018-12-05 10:13:56 [1] common\jobs\PubArticleJob (attempt: 1, pid: 19856) - Started
2018-12-05 10:13:58 [1] common\jobs\PubArticleJob (attempt: 1, pid: 19856) - Done (2.107 s)
2018-12-05 10:13:59 [2] common\jobs\PubArticleJob (attempt: 1, pid: 19856) - Started
2018-12-05 10:14:01 [2] common\jobs\PubArticleJob (attempt: 1, pid: 19856) - Done (2.107 s)
2018-12-05 10:14:01 [pid: 19856] - Worker is stopped (0:00:05)
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 1
PS E:\wwwroot\channel-pub-api> ./yii upload-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 2
PS E:\wwwroot\channel-pub-api> ./yii pub-article-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 2
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 0
58. Console command: get the article transaction of the Penguin interface of the content website application of the Penguin account, and synchronize it to the content website application of the Penguin number. Penguin’s article transaction, the execution result is in line with expected, the article transaction record has been updated to the transaction table, and the job has been pushed to the source callback queue
PS E:\wwwroot\channel-pub-api> ./yii qq-cw-transaction-article/sync
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 1
PS E:\wwwroot\channel-pub-api> ./yii upload-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 2
PS E:\wwwroot\channel-pub-api> ./yii pub-article-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 2
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 2
- delayed: 0
- reserved: 0
- done: 0
59. The run command obtains and executes the tasks in the loop (source callback queue) until the queue is empty, the job of the source callback queue is successfully executed, the execution result is as expected, and has been updated to the release log table
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/run --verbose=1 --isolate=1 --color=0
2018-12-05 10:49:54 [pid: 25376] - Worker is started
2018-12-05 10:49:54 [1] common\jobs\SourceCallbackJob (attempt: 1, pid: 25376) - Started
2018-12-05 10:50:06 [1] common\jobs\SourceCallbackJob (attempt: 1, pid: 25376) - Error (11.899 s)
> yii\httpclient\Exception: Curl error: #6 - Could not resolve host: wjdev.chinamcloud.com
2018-12-05 10:50:07 [2] common\jobs\SourceCallbackJob (attempt: 1, pid: 25376) - Started
2018-12-05 10:50:07 [2] common\jobs\SourceCallbackJob (attempt: 1, pid: 25376) - Done (0.424 s)
2018-12-05 10:50:07 [pid: 25376] - Worker is stopped (0:00:13)
PS E:\wwwroot\channel-pub-api> ./yii copy-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 1
PS E:\wwwroot\channel-pub-api> ./yii upload-asset-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 2
PS E:\wwwroot\channel-pub-api> ./yii pub-article-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 2
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 0
- delayed: 1
- reserved: 0
- done: 2
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/run --verbose=1 --isolate=1 --color=0
2018-12-05 11:00:10 [pid: 25616] - Worker is started
2018-12-05 11:00:10 [3] common\jobs\SourceCallbackJob (attempt: 1, pid: 25616) - Started
2018-12-05 11:00:14 [3] common\jobs\SourceCallbackJob (attempt: 1, pid: 25616) - Done (3.800 s)
2018-12-05 11:00:14 [pid: 25616] - Worker is stopped (0:00:04)
PS E:\wwwroot\channel-pub-api> ./yii source-callback-queue/info --color=0
Jobs
- waiting: 0
- delayed: 0
- reserved: 0
- done: 3
60. Log in to the Penguin number respectively, the article has been successfully published, as shown in Figure 12 and 13
Figure 12
Figure 13
61. Check the information in the transaction table and open the article link:http://kuaibao.qq.com/s/20181205V0E6C600,http://kuaibao.qq.com/s/20181205V0E6DU00, the result is as expected and can be opened normally
62. To sum up, the overall program structure is as follows:
0：未实现
1：已经实现
2：待实现
3：不实现
// 复制资源文件队列作业：复制来源的资源文件至渠道发布的资源目录
\common\jobs\CopyAssetJob.php execute($queue) 1
// 资源服务，复制来源的资源文件至渠道发布的资源目录，返回相对路径(同步)
AssetService.php copyAssetsSync($source, $assets) 1
// 复制资源文件队列事件处理器，复制资源文件队列的作业执行成功后
\common\components\queue\CopyAssetEventHandler.php afterExec(ExecEvent $event) 1
// 复制资源文件队列事件处理器，复制资源文件队列的作业执行失败后
\common\components\queue\CopyAssetEventHandler.php afterError(ExecEvent $event) 1
// 企鹅号的内容网站应用的资源服务，复制资源文件队列的作业执行成功后的后续处理
QqCwAssetService.php copyAssetExecHandler($taskId) 1
// 企鹅号的第三方服务平台应用的资源服务，复制资源文件队列的作业执行成功后的后续处理
QqTpAssetService.php copyAssetExecHandler($taskId) 0
// 微信公众帐号应用的资源服务，复制资源文件队列的作业执行成功后的后续处理
WxAssetService.php copyAssetExecHandler($taskId) 1
// 企鹅号的内容网站应用的资源服务，复制资源文件队列的作业执行失败后的后续处理
QqCwAssetService.php copyAssetErrorHandler($taskId, $eventError) 1
// 企鹅号的第三方服务平台应用的资源服务，复制资源文件队列的作业执行失败后的后续处理
QqTpAssetService.php copyAssetErrorHandler($taskId, $eventError) 0
// 微信公众帐号应用的资源服务，复制资源文件队列的作业执行失败后的后续处理
WxAssetService.php copyAssetErrorHandler($taskId, $eventError) 1
// 上传资源文件队列作业：上传资源文件
\common\jobs\UploadAssetJob.php execute($queue) 1
// 企鹅号的内容网站应用的资源服务，企鹅号的内容网站应用的视频文件分片上传(同步)
QqCwAssetService.php uploadAssetVideoMultipartSync($assetId, $channelAppTaskId) 1
// 企鹅号的第三方服务平台应用的资源服务，企鹅号的第三方服务平台应用的视频文件分片上传(同步)
QqTpAssetService.php uploadAssetVideoMultipartSync($assetId, $channelAppTaskId) 0
// 微信公众帐号应用的资源服务，微信公众帐号应用的资源上传(同步)
WxAssetService.php uploadAssetSync($assetId, $channelAppTaskId) 0
// 微信公众帐号应用的资源服务，企鹅号的内容网站应用的视频文件分片上传(同步)
WxAssetService.php qqCwUploadAssetVideoMultipartSync($taskId) 3
// 上传资源文件队列事件处理器，上传资源文件队列的作业执行成功后
\common\components\queue\UploadAssetEventHandler.php afterExec(ExecEvent $event) 1
// 上传资源文件队列事件处理器，上传资源文件队列的作业执行失败后
\common\components\queue\UploadAssetEventHandler.php afterError(ExecEvent $event) 1
// 企鹅号的内容网站应用的资源服务，上传资源文件队列的作业执行成功后的后续处理
QqCwAssetService.php uploadAssetVideoMultipartExecHandler($assetId, $channelAppTaskId) 1(留空)
// 企鹅号的第三方服务平台应用的资源服务，上传资源文件队列的作业执行成功后的后续处理
QqTpAssetService.php uploadAssetVideoMultipartExecHandler($assetId, $channelAppTaskId) 0
// 微信公众帐号应用的资源服务，上传资源文件队列的作业执行成功后的后续处理
WxAssetService.php uploadAssetExecHandler($assetId, $channelAppTaskId) 0
// 微信公众帐号应用的资源服务，企鹅号的内容网站应用的上传资源文件队列的作业执行成功后的后续处理
WxAssetService.php qqCwUploadAssetVideoMultipartExecHandler($taskId) 3
// 企鹅号的内容网站应用的资源服务，上传资源文件队列的作业执行失败后的后续处理
QqCwAssetService.php uploadAssetVideoMultipartErrorHandler($assetId, $channelAppTaskId, $eventError) 1
// 企鹅号的第三方服务平台应用的资源服务，上传资源文件队列的作业执行失败后的后续处理
QqTpAssetService.php uploadAssetVideoMultipartErrorHandler($assetId, $channelAppTaskId, $eventError) 0
// 微信公众帐号应用的资源服务，上传资源文件队列的作业执行失败后的后续处理
WxAssetService.php uploadAssetErrorHandler($assetId, $channelAppTaskId, $eventError) 0
// 微信公众帐号应用的资源服务，企鹅号的内容网站应用的上传资源文件队列的作业执行失败后的后续处理
WxAssetService.php qqCwUploadAssetVideoMultipartErrorHandler($taskId, $eventError) 1
// 企鹅号的内容网站应用的视频事务控制器，同步接口的视频事务
QqCwTransactionVideoController.php actionSync() 1
// 企鹅号的第三方服务平台应用的视频事务控制器，同步接口的视频事务
QqTpTransactionVideoController.php actionSync() 0
// 企鹅号的内容网站应用的事务服务，企鹅号的内容网站应用的企鹅号的视频事务成功后的后续处理
QqCwTransactionService.php videoExecHandler($qqTransactionId) 1
// 企鹅号的第三方服务平台应用的事务服务，企鹅号的第三方服务平台应用的企鹅号的视频事务成功后的后续处理
QqTpTransactionService.php videoExecHandler($qqTransactionId) 0
// 微信公众帐号应用的资源服务，企鹅号的第三方服务平台应用的企鹅号的视频事务成功后的后续处理
WxAssetService.php qqCwTransactionVideoExecHandler($taskId) 3
// 企鹅号的内容网站应用的事务服务，企鹅号的内容网站应用的企鹅号的视频事务失败后的后续处理
QqCwTransactionService.php videoErrorHandler($qqTransactionId) 1
// 企鹅号的第三方服务平台应用的事务服务，企鹅号的第三方服务平台应用的企鹅号的视频事务失败后的后续处理
QqTpTransactionService.php videoErrorHandler($qqTransactionId) 0
// 微信公众帐号应用的资源服务，企鹅号的第三方服务平台应用的企鹅号的视频事务失败后的后续处理
WxAssetService.php qqCwTransactionVideoErrorHandler($taskId, $errorCode, $errorMessage) 2
// 发布文章队列作业：发布文章
\common\jobs\PubArticleJob.php execute($queue) 1
// 企鹅号的内容网站应用的文章服务，企鹅号的内容网站应用的发布文章类型：视频(视频)的文章至企鹅号平台(同步)
QqCwArticleService.php pubArticleVideoSync($channelAppTaskId) 1
// 企鹅号的第三方服务平台应用的文章服务，企鹅号的第三方服务平台应用的发布文章类型：视频(视频)的文章至企鹅号平台(同步)
QqTpArticleService.php pubArticleVideoSync($channelAppTaskId) 0
// 微信公众帐号应用的文章服务，微信公众帐号应用的发布文章类型：视频(视频)的文章至微信公众帐号平台(同步)
WxArticleService.php pubArticleVideoSync($channelAppTaskId) 0
// 微信公众帐号应用的文章服务，企鹅号的内容网站应用的发布文章类型：视频(视频)的文章至企鹅号平台(同步)
WxArticleService.php qqCwPubArticleVideoSync($taskId) 3
// 发布文章队列事件处理器，发布文章队列的作业执行成功后
\common\components\queue\PubArticleEventHandler.php afterExec(ExecEvent $event) 1
// 发布文章队列事件处理器，发布文章队列的作业执行失败后
\common\components\queue\PubArticleEventHandler.php afterError(ExecEvent $event) 1
// 企鹅号的内容网站应用的文章服务，发布文章队列的作业执行成功后的后续处理
QqCwArticleService.php pubArticleVideoExecHandler($channelAppTaskId) 1(留空)
// 企鹅号的第三方服务平台应用的文章服务，发布文章队列的作业执行成功后的后续处理
QqTpArticleService.php pubArticleVideoExecHandler($channelAppTaskId) 0
// 微信公众帐号应用的文章服务，发布文章队列的作业执行成功后的后续处理
WxArticleService.php pubArticleVideoExecHandler($channelAppTaskId) 0
// 微信公众帐号应用的文章服务，企鹅号的内容网站应用的发布文章队列的作业执行成功后的后续处理
WxArticleService.php qqCwPubArticleVideoExecHandler($taskId) 3
// 企鹅号的内容网站应用的文章服务，发布文章队列的作业执行失败后的后续处理
QqCwArticleService.php pubArticleVideoErrorHandler($channelAppTaskId, $eventError) 1
// 企鹅号的第三方服务平台应用的文章服务，发布文章队列的作业执行失败后的后续处理
QqTpArticleService.php pubArticleVideoErrorHandler($channelAppTaskId, $eventError) 0
// 微信公众帐号应用的文章服务，发布文章队列的作业执行失败后的后续处理
WxArticleService.php pubArticleVideoErrorHandler($channelAppTaskId, $eventError) 1
// 微信公众帐号应用的文章服务，企鹅号的内容网站应用的发布文章队列的作业执行失败后的后续处理
WxArticleService.php qqCwPubArticleVideoErrorHandler($taskId, $eventError) 1
// 企鹅号的内容网站应用的文章事务控制器，同步接口的文章事务
QqCwTransactionArticleController.php actionSync() 1
// 企鹅号的第三方服务平台应用的文章事务控制器，同步接口的文章事务
QqTpTransactionArticleController.php actionSync() 0
// 企鹅号的内容网站应用的事务服务，企鹅号的内容网站应用的企鹅号的视频文章事务成功后的后续处理
QqCwTransactionService.php articleMultivideosExecHandler($qqTransactionId) 1
// 企鹅号的第三方服务平台应用的事务服务，企鹅号的内容网站应用的企鹅号的视频文章事务成功后的后续处理
QqTpTransactionService.php articleMultivideosExecHandler($qqTransactionId) 0
// 微信公众帐号应用的文章服务，企鹅号的内容网站应用的企鹅号的视频文章事务成功后的后续处理
WxArticleService.php qqCwTransactionArticleVideoExecHandler($taskId) 2
// 企鹅号的内容网站应用的事务服务，企鹅号的内容网站应用的企鹅号的视频文章事务失败后的后续处理
QqCwTransactionService.php articleMultivideosErrorHandler($qqTransactionId) 1
// 企鹅号的第三方服务平台应用的事务服务，企鹅号的内容网站应用的企鹅号的视频文章事务失败后的后续处理
QqTpTransactionService.php articleMultivideosErrorHandler($qqTransactionId) 0
// 微信公众帐号应用的文章服务，企鹅号的内容网站应用的企鹅号的视频文章事务失败后的后续处理
WxArticleService.php qqCwTransactionArticleVideoErrorHandler($taskId, $errorCode, $errorMessage) 2
// 来源回调队列作业：来源回调
\common\jobs\SourceCallbackJob.php execute($queue) 1
// 来源回调队列事件处理器，来源回调队列的作业执行成功后
\common\components\queue\SourceCallbackEventHandler.php afterExec(ExecEvent $event) 1
// 来源回调队列事件处理器，来源回调队列的作业执行失败后
\common\components\queue\SourceCallbackEventHandler.php afterError(ExecEvent $event) 1
// 来源回调服务，来源回调队列的作业执行成功后的后续处理
SourceCallbackService.php sourceCallbackExecHandler($channelAppTaskId) 1
// 来源回调服务，来源回调队列的作业执行失败后的后续处理
SourceCallbackService.php sourceCallbackErrorHandler($channelAppTaskId) 1
![在执行数据库迁移时，报错：SQLSTATE[42000]: Syntax error or access violation: 1059 Identifier name 'theme_installation_version_preset_theme_store_theme_version_id_index' is too long](https://www.shuijingwanwq.com/wp-content/uploads/2022/06/1-3-520x245.png)
![在 CakePHP v2.6.4 中，报错：SQLSTATE[HY000] [2002] Connection timed out。](https://www.shuijingwanwq.com/wp-content/uploads/2020/08/1-16-520x245.png)
