In Yii 2.0, edit and update the tenant’s task type and step settings (multiple records, tree structure) implementation (2)
1. The requirements for editing and updating the tenant’s task type and step settings have changed, and users need to allow users to add task types independently, and then select some of them from the 18 steps to add to the newly added task type. Implementation of the previous version:https://www.shuijingwanwq.com/2019/11/06/3583/, in the previous version, only the user was allowed to delete or uncheck the existing task type and steps, but the task type cannot be added.
2. In the global task step configuration table, add another step under the manual task (upload material), and each tenant will enter the editing page for the first time, and the default task steps are all 5 task types, and the task steps under each task type are all checked. At this point, the user can add the task type autonomously, and then select some of them from the 18 steps to add to the newly added task type. Task types can be (add, delete, rename their names, sort), but not (check, not check). Task steps can be selected from the list of 18 task steps (add, delete, check, uncheck, sort).
3. Create a new database migration file (\console\migrations\m191108_073439_config_ta sk_steps.php), create a new step configuration table, initialize the record of the step configuration table, delete the tenant’s task configuration table, and delete the tenant’s task step configuration table
<?php
use yii\db\Migration;
/**
* Class m191108_073439_config_task_steps
*/
class m191108_073439_config_task_steps extends Migration
{
/**
* {@inheritdoc}
*/
public function safeUp()
{
$tableOptions = null;
if ($this->db->driverName === 'mysql') {
$tableOptions = 'CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci ENGINE=InnoDB COMMENT="步骤配置"';
}
$this->createTable('{{%config_step}}', [
'id' => $this->primaryKey(),
'group_id' => $this->string(32)->notNull()->comment('租户ID'),
'code' => $this->string(32)->notNull()->comment('代码'),
'name' => $this->string(32)->notNull()->comment('名称'),
'category' => $this->smallInteger(1)->notNull()->defaultValue(1)->comment('类型，1：系统内置；2：用户定义'),
'status' => $this->smallInteger()->notNull()->defaultValue(1)->comment('状态，0：禁用；1：启用'),
'is_not_isolated' => $this->smallInteger()->notNull()->defaultValue(0)->comment('是否跨租户(不隔离)，0：否；1：是'),
'is_deleted' => $this->smallInteger()->notNull()->defaultValue(0)->comment('是否被删除，0：否；1：是'),
'created_at' => $this->integer()->notNull()->defaultValue(0)->comment('创建时间'),
'updated_at' => $this->integer()->notNull()->defaultValue(0)->comment('更新时间'),
'deleted_at' => $this->integer()->notNull()->defaultValue(0)->comment('删除时间'),
], $tableOptions);
$this->createIndex('idx_code', '{{%config_step}}', ['code'], $unique = false);
$this->insert('{{%config_step}}', [
'id' => 1,
'group_id' => '',
'code' => 'retrieval',
'name' => '取稿',
'category' => 1,
'status' => 1,
'is_not_isolated' => 0,
'is_deleted' => 0,
'created_at' => time(),
'updated_at' => time(),
'deleted_at' => 0,
]);
$this->insert('{{%config_step}}', [
'id' => 2,
'group_id' => '',
'code' => 'begin_shot',
'name' => '上传素材',
'category' => 1,
'status' => 1,
'is_not_isolated' => 0,
'is_deleted' => 0,
'created_at' => time(),
'updated_at' => time(),
'deleted_at' => 0,
]);
$this->insert('{{%config_step}}', [
'id' => 3,
'group_id' => '',
'code' => 'material_review',
'name' => '素材审核',
'category' => 1,
'status' => 1,
'is_not_isolated' => 0,
'is_deleted' => 0,
'created_at' => time(),
'updated_at' => time(),
'deleted_at' => 0,
]);
$this->insert('{{%config_step}}', [
'id' => 4,
'group_id' => '',
'code' => 'writing',
'name' => '撰写稿件',
'category' => 1,
'status' => 1,
'is_not_isolated' => 0,
'is_deleted' => 0,
'created_at' => time(),
'updated_at' => time(),
'deleted_at' => 0,
]);
$this->insert('{{%config_step}}', [
'id' => 5,
'group_id' => '',
'code' => 'end_shot',
'name' => '拍摄完成',
'category' => 1,
'status' => 1,
'is_not_isolated' => 0,
'is_deleted' => 1,
'created_at' => time(),
'updated_at' => time(),
'deleted_at' => time(),
]);
$this->insert('{{%config_step}}', [
'id' => 6,
'group_id' => '',
'code' => 'commit_doc',
'name' => '提交稿件',
'category' => 1,
'status' => 1,
'is_not_isolated' => 0,
'is_deleted' => 1,
'created_at' => time(),
'updated_at' => time(),
'deleted_at' => time(),
]);
$this->insert('{{%config_step}}', [
'id' => 7,
'group_id' => '',
'code' => 'manuscript_review',
'name' => '稿件审核',
'category' => 1,
'status' => 1,
'is_not_isolated' => 0,
'is_deleted' => 0,
'created_at' => time(),
'updated_at' => time(),
'deleted_at' => 0,
]);
$this->insert('{{%config_step}}', [
'id' => 8,
'group_id' => '',
'code' => 'writing_draft',
'name' => '撰写通稿',
'category' => 1,
'status' => 1,
'is_not_isolated' => 0,
'is_deleted' => 0,
'created_at' => time(),
'updated_at' => time(),
'deleted_at' => 0,
]);
$this->insert('{{%config_step}}', [
'id' => 9,
'group_id' => '',
'code' => 'newspaper_issued',
'name' => '报纸签发',
'category' => 1,
'status' => 1,
'is_not_isolated' => 0,
'is_deleted' => 0,
'created_at' => time(),
'updated_at' => time(),
'deleted_at' => 0,
]);
$this->insert('{{%config_step}}', [
'id' => 10,
'group_id' => '',
'code' => 'video_editing',
'name' => '视频编辑',
'category' => 1,
'status' => 1,
'is_not_isolated' => 0,
'is_deleted' => 0,
'created_at' => time(),
'updated_at' => time(),
'deleted_at' => 0,
]);
$this->insert('{{%config_step}}', [
'id' => 11,
'group_id' => '',
'code' => 'tandem_list',
'name' => '串联单',
'category' => 1,
'status' => 1,
'is_not_isolated' => 0,
'is_deleted' => 0,
'created_at' => time(),
'updated_at' => time(),
'deleted_at' => 0,
]);
$this->insert('{{%config_step}}', [
'id' => 12,
'group_id' => '',
'code' => 'wechat_group_reference',
'name' => '微信组稿引用',
'category' => 1,
'status' => 1,
'is_not_isolated' => 0,
'is_deleted' => 0,
'created_at' => time(),
'updated_at' => time(),
'deleted_at' => 0,
]);
$this->insert('{{%config_step}}', [
'id' => 13,
'group_id' => '',
'code' => 'finish_interview',
'name' => '结束采访',
'category' => 1,
'status' => 1,
'is_not_isolated' => 0,
'is_deleted' => 0,
'created_at' => time(),
'updated_at' => time(),
'deleted_at' => 0,
]);
$this->insert('{{%config_step}}', [
'id' => 14,
'group_id' => '',
'code' => 'program_render',
'name' => '节目上传',
'category' => 1,
'status' => 1,
'is_not_isolated' => 0,
'is_deleted' => 0,
'created_at' => time(),
'updated_at' => time(),
'deleted_at' => 0,
]);
$this->insert('{{%config_step}}', [
'id' => 15,
'group_id' => '',
'code' => 'website_release',
'name' => '网站发布',
'category' => 1,
'status' => 1,
'is_not_isolated' => 0,
'is_deleted' => 0,
'created_at' => time(),
'updated_at' => time(),
'deleted_at' => 0,
]);
$this->insert('{{%config_step}}', [
'id' => 16,
'group_id' => '',
'code' => 'program_authen',
'name' => '节目审查',
'category' => 1,
'status' => 1,
'is_not_isolated' => 0,
'is_deleted' => 0,
'created_at' => time(),
'updated_at' => time(),
'deleted_at' => 0,
]);
$this->insert('{{%config_step}}', [
'id' => 17,
'group_id' => '',
'code' => 'app_release',
'name' => 'APP发布',
'category' => 1,
'status' => 1,
'is_not_isolated' => 0,
'is_deleted' => 0,
'created_at' => time(),
'updated_at' => time(),
'deleted_at' => 0,
]);
$this->insert('{{%config_step}}', [
'id' => 18,
'group_id' => '',
'code' => 'wechat_release',
'name' => '微信发布',
'category' => 1,
'status' => 1,
'is_not_isolated' => 0,
'is_deleted' => 0,
'created_at' => time(),
'updated_at' => time(),
'deleted_at' => 0,
]);
$this->insert('{{%config_step}}', [
'id' => 19,
'group_id' => '',
'code' => 'blog_release',
'name' => '微博发布',
'category' => 1,
'status' => 1,
'is_not_isolated' => 0,
'is_deleted' => 0,
'created_at' => time(),
'updated_at' => time(),
'deleted_at' => 0,
]);
$this->insert('{{%config_step}}', [
'id' => 20,
'group_id' => '',
'code' => 'qq_release',
'name' => '企鹅号发布',
'category' => 1,
'status' => 1,
'is_not_isolated' => 0,
'is_deleted' => 0,
'created_at' => time(),
'updated_at' => time(),
'deleted_at' => 0,
]);
$this->alterColumn('{{%config_task_step}}', 'config_task_id', $this->integer()->notNull()->comment('任务配置ID'));
$this->addColumn('{{%config_task_step}}', 'config_task_code', $this->string(32)->notNull()->comment('任务配置代码')->after('config_task_id'));
$this->addColumn('{{%config_task_step}}', 'config_step_id', $this->integer()->notNull()->comment('步骤配置ID')->after('config_task_code'));
$this->update('{{%config_task_step}}', ['config_task_code' => 'tv_broadcast'], ['config_task_id' => 1]);
$this->update('{{%config_task_step}}', ['config_task_code' => 'inter_view'], ['config_task_id' => 2]);
$this->update('{{%config_task_step}}', ['config_task_code' => 'rich_doc'], ['config_task_id' => 3]);
$this->update('{{%config_task_step}}', ['config_step_id' => 1], ['step_code' => 'retrieval']);
$this->update('{{%config_task_step}}', ['config_step_id' => 2], ['step_code' => 'begin_shot']);
$this->update('{{%config_task_step}}', ['config_step_id' => 3], ['step_code' => 'material_review']);
$this->update('{{%config_task_step}}', ['config_step_id' => 4], ['step_code' => 'writing']);
$this->update('{{%config_task_step}}', ['config_step_id' => 5, 'status' => 1], ['step_code' => 'end_shot']);
$this->update('{{%config_task_step}}', ['config_step_id' => 6, 'is_default' => 1, 'is_deleted' => 1, 'deleted_at' => time()], ['step_code' => 'commit_doc']);
$this->update('{{%config_task_step}}', ['config_step_id' => 7], ['step_code' => 'manuscript_review']);
$this->update('{{%config_task_step}}', ['config_step_id' => 8], ['step_code' => 'writing_draft']);
$this->update('{{%config_task_step}}', ['config_step_id' => 9], ['step_code' => 'newspaper_issued']);
$this->update('{{%config_task_step}}', ['config_step_id' => 10], ['step_code' => 'video_editing']);
$this->update('{{%config_task_step}}', ['config_step_id' => 11], ['step_code' => 'tandem_list']);
$this->update('{{%config_task_step}}', ['config_step_id' => 12], ['step_code' => 'wechat_group_reference']);
$this->update('{{%config_task_step}}', ['config_step_id' => 13], ['step_code' => 'finish_interview']);
$this->update('{{%config_task_step}}', ['config_step_id' => 14], ['step_code' => 'program_render']);
$this->update('{{%config_task_step}}', ['config_step_id' => 15], ['step_code' => 'website_release']);
$this->update('{{%config_task_step}}', ['config_step_id' => 16], ['step_code' => 'program_authen']);
$this->update('{{%config_task_step}}', ['config_step_id' => 17], ['step_code' => 'app_release']);
$this->update('{{%config_task_step}}', ['config_step_id' => 18], ['step_code' => 'wechat_release']);
$this->update('{{%config_task_step}}', ['config_step_id' => 19], ['step_code' => 'blog_release']);
$this->update('{{%config_task_step}}', ['config_step_id' => 20], ['step_code' => 'qq_release']);
$this->dropTable('{{%config_group_task}}');
$this->dropTable('{{%config_group_task_step}}');
$this->insert('{{%config_task_step}}', [
'id' => 27,
'group_id' => '',
'config_task_id' => 4,
'config_task_code' => 'other',
'config_step_id' => 2,
'step_code' => 'begin_shot',
'step_name' => '上传素材',
'sort_order' => 1,
'is_default' => 1,
'up_status_type' => 2,
'status' => 1,
'created_at' => time(),
'updated_at' => time()
]);
$this->dropIndex('uc_group_id_config_task_id_step_code_is_deleted_deleted_at', '{{%config_task_step}}');
$this->createIndex('uc_group_id_config_task_code_step_code_is_deleted_deleted_at', '{{%config_task_step}}', ['group_id', 'config_task_code', 'step_code', 'is_deleted', 'deleted_at'], $unique = true);
}
/**
* {@inheritdoc}
*/
public function safeDown()
{
echo "m191108_073439_config_task_steps cannot be reverted.\n";
return false;
}
/*
// Use up()/down() to run migration code without a transaction.
public function up()
{
}
public function down()
{
echo "m191108_073439_config_task_steps cannot be reverted.\n";
return false;
}
*/
}
4. Open the table: task configuration, as shown in Figure 1
Figure 1
5. Open the table: step configuration, as shown in Figure 2
Figure 2
6. Open the table: task step configuration, as shown in Figure 3
Figure 3
7. Edit the routing configuration file, \api\config\urlmanager.php
// 基础设置 - 步骤配置
[
'class' => 'yii\rest\UrlRule',
'controller' => ['v1/config-step'],
'only' => ['index'],
],
// 基础设置 - 租户设置 - 租户的任务类型与步骤设置
[
'class' => 'yii\rest\UrlRule',
'controller' => ['v1/config-task-step'],
'only' => ['view', 'edit', 'update'],
'tokens' => ['{id}' => ''],
'extraPatterns' => [
'GET edit/{id}' => 'edit',
],
],
// 移动端 - 获取租户的任务类型与步骤设置详情
[
'class' => 'yii\rest\UrlRule',
'controller' => ['v1/mobile/config-task-step'],
'only' => ['view'],
'tokens' => ['{id}' => ''],
'extraPatterns' => [
],
],
8. Edit the controller file, \API\Controllers\ConfigTaskStepController.php
<?php
/**
* Created by PhpStorm.
* User: Qiang Wang
* Date: 2018/04/04
* Time: 15:35
*/
namespace api\controllers;
use yii\rest\ActiveController;
/**
* Class ConfigTaskStepController
* @package api\controllers
*
* @author Qiang Wang <shuijingwanwq@163.com>
* @since 1.0
*/
class ConfigTaskStepController extends ActiveController
{
/**
* @inheritdoc
*/
public function actions()
{
$actions = parent::actions();
// 禁用"index"、"create"、"delete"、"options"动作
unset($actions['index'], $actions['create'], $actions['delete'], $actions['options']);
$actions['view']['class'] = 'api\rests\config_task_step\ViewAction';
$actions['update']['class'] = 'api\rests\config_task_step\UpdateAction';
$actions['edit'] = [
'class' => 'api\rests\config_task_step\EditAction',
'modelClass' => $this->modelClass,
'checkAccess' => [$this, 'checkAccess'],
];
return $actions;
}
}
9. Create the method file of the task type and step setting of the edit tenant (\api\rests\config_task_step\editaction.php)
<?php
/**
* @link http://www.yiiframework.com/
* @copyright Copyright (c) 2008 Yii Software LLC
* @license http://www.yiiframework.com/license/
*/
namespace api\rests\config_task_step;
use Yii;
use api\models\redis\cmc_console\User as RedisCmcConsoleUser;
use api\services\ConfigTaskStepService;
use yii\web\UnprocessableEntityHttpException;
/**
* 编辑租户的任务类型与步骤设置：/config-task-steps/edit/my-group-id(config-task-step/edit)
*
* For more details and usage information on ViewAction, see the [guide article on rest controllers](guide:rest-controllers).
*
* @author Qiang Wang <shuijingwanwq@163.com>
* @since 1.0
*/
class EditAction extends Action
{
/**
* Displays a model.
* @param string $id the primary key of the model.
* @return array
* @throws UnprocessableEntityHttpException
*/
public function run($id)
{
// 当前用户的身份实例，未认证用户则为 Null
/* @var $identity RedisCmcConsoleUser */
$identity = Yii::$app->user->identity;
// 比对：group_id，检查其值是否等于：my-group-id
if ($id != 'my-group-id') {
throw new UnprocessableEntityHttpException(Yii::t('error', '226053'), 226053);
}
// 基于租户ID返回数据模型(任务步骤配置)列表
$configTaskStepItems = ConfigTaskStepService::findModelsByGroupId($identity->group_id, false);
return ['code' => 10000, 'message' => Yii::t('success', '126038'), 'data' => array_values($configTaskStepItems)];
}
}
10. Edit the service file of the tenant’s task type (\common\services\configtaskservice.php)
<?php
/**
* Created by PhpStorm.
* User: Qiang Wang
* Date: 2019/11/01
* Time: 10:19
*/
namespace common\services;
use Yii;
use common\logics\ConfigTask;
class ConfigTaskService extends Service
{
/**
* 基于租户ID返回数据模型列表
* @param string $groupId 租户ID
* @return array 一个 ActiveRecord 实例数组
* 格式如下：
* [
* [ // object
* 'id' => 1, // ID
* 'group_id' => '', // 租户ID
* 'code' => 'tv_broadcast', // 任务代码
* 'name' => '电视播出', // 任务名称
* 'sort_order' => 1, // 顺序，顺序排列
* 'category' => 1, // 任务类型，1：系统内置；2：用户定义
* 'parameter' => '', // 自定义参数，序列化存储
* 'status' => 1, // 状态，0：禁用；1：启用
* 'is_deleted' => 0, // 是否被删除，0：否；1：是
* 'created_at' => 1573439809, // 创建时间
* 'updated_at' => 1573439809, // 更新时间
* 'deleted_at' => 0, // 删除时间
* ],
* [
* 'id' => 1,
* 'group_id' => '',
* 'code' => 'inter_view',
* 'name' => '采访任务',
* 'sort_order' => 2,
* 'category' => 1,
* 'parameter' => '',
* 'status' => 1,
* 'is_deleted' => 0,
* 'created_at' => 1573439809,
* 'updated_at' => 1573439809,
* 'deleted_at' => 0,
* ],
* ...
* ]
*/
public static function findModelsByGroupId($groupId)
{
// 基于租户ID查找资源(任务配置)列表
$configTaskItems = ConfigTask::find()->where(['group_id' => $groupId])->all();
if (empty($configTaskItems)) {
$groupId = '';
}
// 基于租户ID查找资源(任务配置、是否被删除：否)列表
return ConfigTask::findAllByGroupId($groupId);
}
}
11. Edit the service file of the tenant’s task type and step settings (\common\services\configTaskStepService.php)
<?php
/**
* Created by PhpStorm.
* User: terryhong
* Date: 2018/12/20
* Time: 3:10 PM
*/
namespace common\services;
use Yii;
use common\logics\ConfigTask;
use common\logics\ConfigTaskStep;
use yii\web\NotFoundHttpException;
use yii\web\UnprocessableEntityHttpException;
class ConfigTaskStepService extends Service
{
/**
* 基于租户ID返回数据模型(任务步骤配置)列表
* @param string $groupId 租户ID
* @param bool $isDefaultYes 是否添加条件，默认步骤，1：是
* @return array 一个 ActiveRecord 实例数组
* 格式如下：
* [
* 1 = > [
* 'id' => 1, // ID
* 'code' => 'tv_broadcast', // 代码
* 'name' => '电视播出', // 名称
* 'sort_order' => 1, // 顺序，顺序排列
* 'steps' => [ // 步骤列表
* [
* 'id' => 2, // ID
* 'code' => 'begin_shot', // 代码
* 'name' => '上传素材', // 名称
* 'sort_order' => 1, // 顺序，顺序排列
* 'is_default' => 1, // 是否默认步骤，1：是；0：否
* ],
* [
* 'id' => 4, // ID
* 'code' => 'writing', // 代码
* 'name' => '撰写稿件', // 名称
* 'sort_order' => 2, // 顺序，顺序排列
* 'is_default' => 1, // 是否默认步骤，1：是；0：否
* ],
* ...
* ],
* ],
* ...
* ]
*/
public static function findModelsByGroupId($groupId, $isDefaultYes = true)
{
// 基于租户ID查找资源(任务步骤配置)列表
$configTaskStepItems = ConfigTaskStep::find()->where(['group_id' => $groupId])->all();
if (empty($configTaskStepItems)) {
$groupId = '';
}
// 基于租户ID查找资源(任务步骤配置、是否被删除：否)列表
if ($isDefaultYes) {
$configTaskStepIsDeletedNoItems = ConfigTaskStep::findAllIsDefaultYesByGroupId($groupId);
} else {
$configTaskStepIsDeletedNoItems = ConfigTaskStep::findAllByGroupId($groupId);
}
// 基于 任务配置ID 分组
$configTaskStepGroupItems = [];
foreach ($configTaskStepIsDeletedNoItems as $configTaskStepIsDeletedNoItem) {
$configTaskStepGroupItems[$configTaskStepIsDeletedNoItem->config_task_id][] = [
'id' => $configTaskStepIsDeletedNoItem->config_step_id,
'code' => $configTaskStepIsDeletedNoItem->step_code,
'name' => $configTaskStepIsDeletedNoItem->step_name,
'sort_order' => $configTaskStepIsDeletedNoItem->sort_order,
'is_default' => $configTaskStepIsDeletedNoItem->is_default,
];
}
// 基于租户ID返回数据模型(任务配置)列表
$configTaskItems = ConfigTaskService::findModelsByGroupId($groupId);
$data = [];
foreach ($configTaskItems as $configTaskItem) {
$data[$configTaskItem->id] = [
'id' => $configTaskItem->id,
'code' => $configTaskItem->code,
'name' => $configTaskItem->name,
'sort_order' => $configTaskItem->sort_order,
'steps' => isset($configTaskStepGroupItems[$configTaskItem->id]) ? $configTaskStepGroupItems[$configTaskItem->id] : [],
];
}
return $data;
}
12. Get in Postman:http://api.pcs-api.localhost/v1/config-task-steps/edit/my-group-idWhen the tenant is not customized, that is, when there is no record in the task configuration table and task step configuration table, the default is obtained.
{
"code": 10000,
"message": "编辑租户的任务类型与步骤设置成功",
"data": {
"items": [
{
"id": 1,
"code": "tv_broadcast",
"name": "电视播出",
"sort_order": 1,
"steps": [
{
"id": 2,
"code": "begin_shot",
"name": "上传素材",
"sort_order": 1,
"is_default": 1
},
{
"id": 4,
"code": "writing",
"name": "撰写稿件",
"sort_order": 2,
"is_default": 1
},
{
"id": 7,
"code": "manuscript_review",
"name": "稿件审核",
"sort_order": 4,
"is_default": 1
},
{
"id": 10,
"code": "video_editing",
"name": "视频编辑",
"sort_order": 5,
"is_default": 1
},
{
"id": 11,
"code": "tandem_list",
"name": "串联单",
"sort_order": 6,
"is_default": 1
},
{
"id": 14,
"code": "program_render",
"name": "节目上传",
"sort_order": 7,
"is_default": 1
},
{
"id": 16,
"code": "program_authen",
"name": "节目审查",
"sort_order": 8,
"is_default": 1
}
]
},
{
"id": 2,
"code": "inter_view",
"name": "采访任务",
"sort_order": 2,
"steps": [
{
"id": 2,
"code": "begin_shot",
"name": "上传素材",
"sort_order": 1,
"is_default": 1
},
{
"id": 3,
"code": "material_review",
"name": "素材审核",
"sort_order": 2,
"is_default": 1
},
{
"id": 4,
"code": "writing",
"name": "撰写稿件",
"sort_order": 4,
"is_default": 1
},
{
"id": 8,
"code": "writing_draft",
"name": "撰写通稿",
"sort_order": 5,
"is_default": 1
},
{
"id": 7,
"code": "manuscript_review",
"name": "稿件审核",
"sort_order": 6,
"is_default": 1
},
{
"id": 13,
"code": "finish_interview",
"name": "结束采访",
"sort_order": 7,
"is_default": 1
}
]
},
{
"id": 3,
"code": "rich_doc",
"name": "互联网发布",
"sort_order": 3,
"steps": [
{
"id": 1,
"code": "retrieval",
"name": "取稿",
"sort_order": 1,
"is_default": 1
},
{
"id": 4,
"code": "writing",
"name": "撰写稿件",
"sort_order": 2,
"is_default": 1
},
{
"id": 7,
"code": "manuscript_review",
"name": "稿件审核",
"sort_order": 4,
"is_default": 1
},
{
"id": 9,
"code": "newspaper_issued",
"name": "报纸签发",
"sort_order": 5,
"is_default": 1
},
{
"id": 12,
"code": "wechat_group_reference",
"name": "微信组稿引用",
"sort_order": 6,
"is_default": 1
},
{
"id": 15,
"code": "website_release",
"name": "网站发布",
"sort_order": 7,
"is_default": 1
},
{
"id": 17,
"code": "app_release",
"name": "APP发布",
"sort_order": 8,
"is_default": 1
},
{
"id": 18,
"code": "wechat_release",
"name": "微信发布",
"sort_order": 9,
"is_default": 1
},
{
"id": 19,
"code": "blog_release",
"name": "微博发布",
"sort_order": 10,
"is_default": 1
},
{
"id": 20,
"code": "qq_release",
"name": "企鹅号发布",
"sort_order": 11,
"is_default": 1
}
]
},
{
"id": 4,
"code": "other",
"name": "手动任务",
"sort_order": 4,
"steps": [
{
"id": 2,
"code": "begin_shot",
"name": "上传素材",
"sort_order": 1,
"is_default": 1
}
]
}
]
}
}
SELECT * FROM `pa_config_task_step` WHERE `group_id`='015ce30b116ce86058fa6ab4fea4ac63'
SELECT * FROM `pa_config_task_step` WHERE (`group_id`='') AND (`is_deleted`=0) ORDER BY `sort_order`, `id` DESC
SELECT * FROM `pa_config_task` WHERE `group_id`=''
SELECT * FROM `pa_config_task` WHERE (`group_id`='') AND (`is_deleted`=0) ORDER BY `sort_order`, `id` DESC
13. Create a new method file for obtaining the step configuration list, \api\rests\config_step\indexaction.php
<?php
/**
* @link http://www.yiiframework.com/
* @copyright Copyright (c) 2008 Yii Software LLC
* @license http://www.yiiframework.com/license/
*/
namespace api\rests\config_step;
use Yii;
use api\models\ConfigStep;
use yii\base\InvalidConfigException;
use yii\data\ActiveDataProvider;
use yii\web\UnprocessableEntityHttpException;
/**
* 获取步骤配置列表：/config-steps(config-step/index)
*
* For more details and usage information on IndexAction, see the [guide article on rest controllers](guide:rest-controllers).
*
* @author Qiang Wang <shuijingwanwq@163.com>
* @since 1.0
*/
class IndexAction extends \yii\rest\IndexAction
{
/**
* Prepares the data provider that should return the requested collection of the models.
* @return mixed|object|ActiveDataProvider
* @throws InvalidConfigException if the configuration is invalid.
* @throws UnprocessableEntityHttpException
*/
protected function prepareDataProvider()
{
$requestParams = Yii::$app->getRequest()->getBodyParams();
if (empty($requestParams)) {
$requestParams = Yii::$app->getRequest()->getQueryParams();
}
$filter = null;
if ($this->dataFilter !== null) {
$this->dataFilter = Yii::createObject($this->dataFilter);
if ($this->dataFilter->load($requestParams)) {
$filter = $this->dataFilter->build();
if ($filter === false) {
$firstError = '';
foreach ($this->dataFilter->getFirstErrors() as $message) {
$firstError = $message;
break;
}
throw new UnprocessableEntityHttpException(Yii::t('error', Yii::t('error', Yii::t('error', '224003'), ['first_error' => $firstError])), 224003);
}
}
}
if ($this->prepareDataProvider !== null) {
return call_user_func($this->prepareDataProvider, $this, $filter);
}
/* @var $modelClass ConfigStep */
$modelClass = $this->modelClass;
// 查询步骤配置
$query = $modelClass::find()->isDeletedNo();
// 设置每页资源数量为资源总数
$count = $query->count();
$requestParams['per-page'] = $count;
return Yii::createObject([
'class' => ActiveDataProvider::className(),
'query' => $query,
'pagination' => [
'params' => $requestParams,
'pageSizeLimit' => [1, $count],
],
'sort' => [
'params' => $requestParams,
],
]);
}
}
14. Create a new serialization file for the acquisition step configuration list, \api\rests\config_step\serializer.php
<?php
/**
* @link http://www.yiiframework.com/
* @copyright Copyright (c) 2008 Yii Software LLC
* @license http://www.yiiframework.com/license/
*/
namespace api\rests\config_step;
use Yii;
use yii\data\DataProviderInterface;
/**
* Serializer converts resource objects and collections into array representation.
*
* Serializer is mainly used by REST controllers to convert different objects into array representation
* so that they can be further turned into different formats, such as JSON, XML, by response formatters.
*
* The default implementation handles resources as [[Model]] objects and collections as objects
* implementing [[DataProviderInterface]]. You may override [[serialize()]] to handle more types.
*
* @author Qiang Wang <shuijingwanwq@163.com>
* @since 1.0
*/
class Serializer extends \yii\rest\Serializer
{
/**
* Serializes a data provider.
* @param DataProviderInterface $dataProvider
* @return array the array representation of the data provider.
*/
protected function serializeDataProvider($dataProvider)
{
if ($this->preserveKeys) {
$models = $dataProvider->getModels();
} else {
$models = array_values($dataProvider->getModels());
}
$models = $this->serializeModels($models);
if (($pagination = $dataProvider->getPagination()) !== false) {
$this->addPaginationHeaders($pagination);
}
if ($this->request->getIsHead()) {
return null;
} elseif ($this->collectionEnvelope === null) {
return $models;
}
$result = [
$this->collectionEnvelope => $models,
];
if ($pagination !== false) {
return ['code' => 10000, 'message' => Yii::t('success', '126040'), 'data' => array_merge($result, $this->serializePagination($pagination))];
}
return ['code' => 10000, 'message' => Yii::t('success', '126040'), 'data' => $result];
}
}
15. Get in Postman:http://api.pcs-api.localhost/v1/config-steps, get the step configuration list, so that the user selects the steps to add to the corresponding type, the response data and the executed SQL are as follows
{
"code": 10000,
"message": "获取步骤配置列表成功",
"data": {
"items": [
{
"id": 1,
"group_id": "",
"code": "retrieval",
"name": "取稿",
"category": 1,
"status": 1,
"is_not_isolated": 0,
"is_deleted": 0,
"created_at": 1573439819,
"updated_at": 1573439819,
"deleted_at": 0
},
{
"id": 2,
"group_id": "",
"code": "begin_shot",
"name": "上传素材",
"category": 1,
"status": 1,
"is_not_isolated": 0,
"is_deleted": 0,
"created_at": 1573439819,
"updated_at": 1573439819,
"deleted_at": 0
},
{
"id": 3,
"group_id": "",
"code": "material_review",
"name": "素材审核",
"category": 1,
"status": 1,
"is_not_isolated": 0,
"is_deleted": 0,
"created_at": 1573439819,
"updated_at": 1573439819,
"deleted_at": 0
},
{
"id": 4,
"group_id": "",
"code": "writing",
"name": "撰写稿件",
"category": 1,
"status": 1,
"is_not_isolated": 0,
"is_deleted": 0,
"created_at": 1573439819,
"updated_at": 1573439819,
"deleted_at": 0
},
{
"id": 7,
"group_id": "",
"code": "manuscript_review",
"name": "稿件审核",
"category": 1,
"status": 1,
"is_not_isolated": 0,
"is_deleted": 0,
"created_at": 1573439819,
"updated_at": 1573439819,
"deleted_at": 0
},
{
"id": 8,
"group_id": "",
"code": "writing_draft",
"name": "撰写通稿",
"category": 1,
"status": 1,
"is_not_isolated": 0,
"is_deleted": 0,
"created_at": 1573439819,
"updated_at": 1573439819,
"deleted_at": 0
},
{
"id": 9,
"group_id": "",
"code": "newspaper_issued",
"name": "报纸签发",
"category": 1,
"status": 1,
"is_not_isolated": 0,
"is_deleted": 0,
"created_at": 1573439819,
"updated_at": 1573439819,
"deleted_at": 0
},
{
"id": 10,
"group_id": "",
"code": "video_editing",
"name": "视频编辑",
"category": 1,
"status": 1,
"is_not_isolated": 0,
"is_deleted": 0,
"created_at": 1573439819,
"updated_at": 1573439819,
"deleted_at": 0
},
{
"id": 11,
"group_id": "",
"code": "tandem_list",
"name": "串联单",
"category": 1,
"status": 1,
"is_not_isolated": 0,
"is_deleted": 0,
"created_at": 1573439819,
"updated_at": 1573439819,
"deleted_at": 0
},
{
"id": 12,
"group_id": "",
"code": "wechat_group_reference",
"name": "微信组稿引用",
"category": 1,
"status": 1,
"is_not_isolated": 0,
"is_deleted": 0,
"created_at": 1573439819,
"updated_at": 1573439819,
"deleted_at": 0
},
{
"id": 13,
"group_id": "",
"code": "finish_interview",
"name": "结束采访",
"category": 1,
"status": 1,
"is_not_isolated": 0,
"is_deleted": 0,
"created_at": 1573439819,
"updated_at": 1573439819,
"deleted_at": 0
},
{
"id": 14,
"group_id": "",
"code": "program_render",
"name": "节目上传",
"category": 1,
"status": 1,
"is_not_isolated": 0,
"is_deleted": 0,
"created_at": 1573439819,
"updated_at": 1573439819,
"deleted_at": 0
},
{
"id": 15,
"group_id": "",
"code": "website_release",
"name": "网站发布",
"category": 1,
"status": 1,
"is_not_isolated": 0,
"is_deleted": 0,
"created_at": 1573439819,
"updated_at": 1573439819,
"deleted_at": 0
},
{
"id": 16,
"group_id": "",
"code": "program_authen",
"name": "节目审查",
"category": 1,
"status": 1,
"is_not_isolated": 0,
"is_deleted": 0,
"created_at": 1573439819,
"updated_at": 1573439819,
"deleted_at": 0
},
{
"id": 17,
"group_id": "",
"code": "app_release",
"name": "APP发布",
"category": 1,
"status": 1,
"is_not_isolated": 0,
"is_deleted": 0,
"created_at": 1573439819,
"updated_at": 1573439819,
"deleted_at": 0
},
{
"id": 18,
"group_id": "",
"code": "wechat_release",
"name": "微信发布",
"category": 1,
"status": 1,
"is_not_isolated": 0,
"is_deleted": 0,
"created_at": 1573439819,
"updated_at": 1573439819,
"deleted_at": 0
},
{
"id": 19,
"group_id": "",
"code": "blog_release",
"name": "微博发布",
"category": 1,
"status": 1,
"is_not_isolated": 0,
"is_deleted": 0,
"created_at": 1573439819,
"updated_at": 1573439819,
"deleted_at": 0
},
{
"id": 20,
"group_id": "",
"code": "qq_release",
"name": "企鹅号发布",
"category": 1,
"status": 1,
"is_not_isolated": 0,
"is_deleted": 0,
"created_at": 1573439819,
"updated_at": 1573439819,
"deleted_at": 0
}
],
"_links": {
"self": {
"href": "http://api.pcs-api.localhost/v1/config-steps?login_id=2e368664c41b8bf511bcc9c65d86dbc3&login_tid=549e02e6b704dbb437618029a711f7c8&per-page=18&page=1"
}
},
"_meta": {
"totalCount": 18,
"pageCount": 1,
"currentPage": 1,
"perPage": 18
}
}
}
SELECT COUNT(*) FROM `pa_config_step` WHERE `is_deleted`=0
SELECT COUNT(*) FROM `pa_config_step` WHERE `is_deleted`=0
SELECT * FROM `pa_config_step` WHERE `is_deleted`=0 LIMIT 18
16. Create a new method file for updating task types and steps (\API\RESTS\CONFIG_TASK_Step\updateAction.php)
?php
/**
* @link http://www.yiiframework.com/
* @copyright Copyright (c) 2008 Yii Software LLC
* @license http://www.yiiframework.com/license/
*/
namespace api\rests\config_task_step;
use Yii;
use api\models\ConfigTask;
use api\models\ConfigTaskStep;
use api\models\redis\cmc_console\User as RedisCmcConsoleUser;
use api\services\ConfigTaskStepService;
use yii\base\Model;
use yii\base\InvalidConfigException;
use yii\helpers\ArrayHelper;
use yii\web\UnprocessableEntityHttpException;
use yii\web\ServerErrorHttpException;
/**
* 更新租户的任务类型与步骤设置：/config-task-steps/{group_id}(config-task-step/update)
*
* For more details and usage information on CreateAction, see the [guide article on rest controllers](guide:rest-controllers).
*
* @author Qiang Wang <shuijingwanwq@163.com>
* @since 1.0
*/
class UpdateAction extends Action
{
/**
* @var string the scenario to be assigned to the model before it is validated and updated.
* $id {config_column_id}
*/
public $scenario = Model::SCENARIO_DEFAULT;
/**
* Updates an existing model.
* @param string $id the primary key of the model.
* @return array the model being updated
* @throws InvalidConfigException if a registered parser does not implement the [[RequestParserInterface]].
* @throws ServerErrorHttpException if there is any error when updating the model
* @throws \Throwable
*/
public function run($id)
{
// 当前用户的身份实例，未认证用户则为 Null
/* @var $identity RedisCmcConsoleUser */
$identity = Yii::$app->user->identity;
// 比对：group_id，检查其值是否等于：my-group-id
if ($id != 'my-group-id') {
throw new UnprocessableEntityHttpException(Yii::t('error', '226053'), 226053);
}
/* @var $modelClass ConfigTaskStep */
$modelClass = $this->modelClass;
$requestParams = Yii::$app->getRequest()->getBodyParams();
/* @var $configGroupTaskItem ConfigTask */
// 基于租户ID查找资源(任务配置、是否被删除：否)列表
$configTaskIsDeletedNoItems = ConfigTask::find()->where(['group_id' => $identity->group_id])->isDeletedNo()->indexBy(['code'])->all();
// 基于租户ID查找资源(任务配置)列表
$configTaskItems = ConfigTask::find()->where(['group_id' => $identity->group_id])->indexBy(['code'])->all();
/* @var $configGroupTaskStepItem ConfigTaskStep */
// 基于租户ID查找资源(任务步骤配置、是否被删除：否)列表
$configTaskStepIsDeletedNoItems = $modelClass::find()->where(['group_id' => $identity->group_id])->isDeletedNo()->indexBy(function ($row) { return $row['config_task_code'] . ':' . $row['step_code']; })->all();
// 基于租户ID查找资源(任务步骤配置)列表
$configTaskStepItems = $modelClass::find()->where(['group_id' => $identity->group_id])->indexBy(function ($row) { return $row['config_task_code'] . ':' . $row['step_code']; })->all();
if (!is_array($requestParams)) {
return ['code' => 226010, 'message' => Yii::t('error', '226010')];
}
$configTasks = [];
$configTaskSteps = [];
foreach ($requestParams as $configTask) {
// 检查 任务配置的(代码、名称、顺序) 是否存在
if (!ArrayHelper::keyExists('code', $configTask) || !ArrayHelper::keyExists('name', $configTask) || !ArrayHelper::keyExists('sort_order', $configTask)) {
throw new UnprocessableEntityHttpException(Yii::t('error', '226080'), 226080);
}
$configTasks[$configTask['code']] = [
'group_id' => $identity->group_id,
'code' => $configTask['code'],
'name' => $configTask['name'],
'sort_order' => $configTask['sort_order'],
];
// 检查 步骤配置列表 是否存在
if (ArrayHelper::keyExists('steps', $configTask)) {
foreach ($configTask['steps'] as $configTaskStep) {
// 检查 步骤代码、顺序、是否默认步骤 是否存在
if (!ArrayHelper::keyExists('code', $configTaskStep) || !ArrayHelper::keyExists('sort_order', $configTaskStep) || !ArrayHelper::keyExists('is_default', $configTaskStep)) {
throw new UnprocessableEntityHttpException(Yii::t('error', '226080'), 226080);
}
$configTaskSteps[$configTask['code'] . ':' . $configTaskStep['code']] = [
'group_id' => $identity->group_id,
'config_task_code' => $configTask['code'],
'step_code' => $configTaskStep['code'],
'sort_order' => $configTaskStep['sort_order'],
'is_default' => $configTaskStep['is_default'],
];
}
}
}
/* 任务配置 */
// 使用键名比较计算数组的差集，如果不为空，则删除 (软删除) 出现在 任务配置模型(MySQL) 中但是未出现在 任务配置 中的记录
$configTaskDiffItems = array_diff_key($configTaskIsDeletedNoItems, $configTasks);
$configTasks = array_values($configTasks);
$configTaskModels = [];
foreach ($configTasks as $configTask) {
if (isset($configTaskItems[$configTask['code']])) {
$configTaskItems[$configTask['code']]->scenario = ConfigTask::SCENARIO_UPDATE;
$configTaskModels[] = $configTaskItems[$configTask['code']];
} else {
$configTaskModels[] = new ConfigTask([
'scenario' => ConfigTask::SCENARIO_UPDATE,
]);
}
}
// 批量填充模型属性
if (!empty($configTaskModels) && !Model::loadMultiple($configTaskModels, $configTasks, '')) {
return ['code' => 226010, 'message' => Yii::t('error', '226010')];
}
// 批量验证模型
if (!empty($configTaskModels) && !Model::validateMultiple($configTaskModels)) {
$configTaskModelsResult = self::handleValidateMultipleError($configTaskModels);
if ($configTaskModelsResult['status'] === false) {
return ['code' => $configTaskModelsResult['code'], 'message' => $configTaskModelsResult['message']];
}
}
/* 任务步骤配置 */
// 使用键名比较计算数组的差集，如果不为空，则删除 (软删除) 出现在 任务步骤配置模型(MySQL) 中但是未出现在 任务步骤配置 中的记录
$configTaskStepDiffItems = array_diff_key($configTaskStepIsDeletedNoItems, $configTaskSteps);
$configTaskSteps = array_values($configTaskSteps);
$configTaskStepModels = [];
foreach ($configTaskSteps as $configTaskStep) {
$index = $configTaskStep['config_task_code'] . ':' . $configTaskStep['step_code'];
if (isset($configTaskStepItems[$index])) {
$configTaskStepItems[$index]->scenario = ConfigTask::SCENARIO_UPDATE;
$configTaskStepModels[] = $configTaskStepItems[$index];
} else {
$configTaskStepModels[] = new $modelClass([
'scenario' => $modelClass::SCENARIO_UPDATE,
]);
}
}
// 批量填充模型属性
if (!empty($configTaskStepModels) && !Model::loadMultiple($configTaskStepModels, $configTaskSteps, '')) {
return ['code' => 226010, 'message' => Yii::t('error', '226010')];
}
// 批量验证模型
if (!empty($configTaskStepModels) && !Model::validateMultiple($configTaskStepModels)) {
$configTaskStepModelsResult = self::handleValidateMultipleError($configTaskStepModels);
if ($configTaskStepModelsResult['status'] === false) {
return ['code' => $configTaskStepModelsResult['code'], 'message' => $configTaskStepModelsResult['message']];
}
}
/* 操作数据(事务) */
$configTaskStepService = new ConfigTaskStepService();
$result = $configTaskStepService->update($configTaskDiffItems, $configTaskModels, $configTaskStepDiffItems, $configTaskStepModels, $identity);
if ($result['status'] === false) {
throw new ServerErrorHttpException($result['message'], $result['code']);
}
return ['code' => 10000, 'message' => Yii::t('success', '126039')];
}
}
17. Create a new service file of the update task type and step settings (\API\Services\ConfigTaskService.php)
<?php
/**
* Created by PhpStorm.
* User: Qiang Wang
* Date: 2019/11/01
* Time: 10:17
*/
namespace api\services;
use Yii;
use api\models\ConfigTask;
use yii\web\ServerErrorHttpException;
class ConfigTaskService extends \common\services\ConfigTaskService
{
/**
* 创建任务配置
* @param object $model 对象
*
* @param bool $runValidation 保存记录之前是否执行验证 (调用 [[validate()]])，默认为 true
*
* @return array
* 格式如下：
*
* [
* 'status' => true, // 成功
* 'data' => [ // object
* ]
* ]
*
* [
* 'status' => false, // 失败
* 'code' => 226081, // 返回码
* 'message' => '', // 说明
* ]
*
* @throws ServerErrorHttpException
*/
public function create($model, $runValidation = true)
{
if ($model->save($runValidation)) {
return ['status' => true, 'data' => $model];
} elseif ($model->hasErrors()) {
$firstError = '';
foreach ($model->getFirstErrors() as $message) {
$firstError = $message;
break;
}
return ['status' => false, 'code' => 226081, 'message' => Yii::t('error', Yii::t('error', Yii::t('error', '226081'), ['first_error' => $firstError]))];
} elseif (!$model->hasErrors()) {
throw new ServerErrorHttpException('Failed to create the object (task configuration) for unknown reason.');
}
}
/**
* 更新任务配置
* @param object $model 对象
*
* @param bool $runValidation 保存记录之前是否执行验证 (调用 [[validate()]])，默认为 true
*
* @return array
* 格式如下：
*
* [
* 'status' => true, // 成功
* 'data' => [ // object
* ]
* ]
*
* [
* 'status' => false, // 失败
* 'code' => 226082, // 返回码
* 'message' => '', // 说明
* ]
*
* @throws ServerErrorHttpException
*/
public function update($model, $runValidation = true)
{
if ($model->save($runValidation)) {
return ['status' => true, 'data' => $model];
} elseif ($model->hasErrors()) {
$firstError = '';
foreach ($model->getFirstErrors() as $message) {
$firstError = $message;
break;
}
return ['status' => false, 'code' => 226082, 'message' => Yii::t('error', Yii::t('error', Yii::t('error', '226082'), ['first_error' => $firstError]))];
} elseif (!$model->hasErrors()) {
throw new ServerErrorHttpException('Failed to update the object (task configuration) for unknown reason.');
}
}
/**
* 批量删除(删除任务配置)
*
* @param $models
*
* @return bool the saved model or false if saving fails
* @throws \Throwable
*/
public function deleteMultiple($models)
{
$transaction = Yii::$app->db->beginTransaction();
try {
foreach ($models as $model) {
/* @var $model ConfigTask */
if($model->softDelete() === false) {
throw new ServerErrorHttpException(Yii::t('error', '226083'), 226083);
}
}
$transaction->commit();
return true;
} catch (\Throwable $e) {
$transaction->rollBack();
throw $e;
}
}
}
18. Create a new service file of the update task type and step settings (\API\Services\ConfigTaskStepService.php)
<?php
/**
* Created by PhpStorm.
* User: terryhong
* Date: 2018/12/20
* Time: 3:09 PM
*/
namespace api\services;
use Yii;
use api\models\ConfigTask;
use api\models\ConfigStep;
use api\models\ConfigTaskStep;
use yii\web\ServerErrorHttpException;
class ConfigTaskStepService extends \common\services\ConfigTaskStepService
{
/**
* 创建任务步骤配置
* @param object $model 对象
*
* @param bool $runValidation 保存记录之前是否执行验证 (调用 [[validate()]])，默认为 true
*
* @return array
* 格式如下：
*
* [
* 'status' => true, // 成功
* 'data' => [ // object
* ]
* ]
*
* [
* 'status' => false, // 失败
* 'code' => 226084, // 返回码
* 'message' => '', // 说明
* ]
*
* @throws ServerErrorHttpException
*/
public function create($model, $runValidation = true)
{
if ($model->save($runValidation)) {
return ['status' => true, 'data' => $model];
} elseif ($model->hasErrors()) {
$firstError = '';
foreach ($model->getFirstErrors() as $message) {
$firstError = $message;
break;
}
return ['status' => false, 'code' => 226084, 'message' => Yii::t('error', Yii::t('error', Yii::t('error', '226084'), ['first_error' => $firstError]))];
} elseif (!$model->hasErrors()) {
throw new ServerErrorHttpException('Failed to create the object (task step configuration) for unknown reason.');
}
}
/**
* 添加|还原|更新|删除任务配置、添加|还原|更新|删除任务步骤配置
*
* @param array $deletedConfigTasks 需要删除的任务配置
* 格式如下：
* [
* [ // object
* 'id' => 32, // ID
* 'group_id' => '015ce30b116ce86058fa6ab4fea4ac63', // 租户ID
* 'code' => 'other', // 代码
* 'name' => '手动任务', // 名称
* 'sort_order' => 1, // 顺序
* 'category' => 2, // 任务类型，1：系统内置；2：用户定义
* 'parameter' => 's:0:"";', // 自定义参数，序列化存储
* 'status' => 1, // 状态，0：禁用；1：启用
* 'is_deleted' => 0, // 是否被删除，0：否；1：是
* 'created_at' => 1573632826, // 创建时间
* 'updated_at' => 1573632826, // 更新时间
* 'deleted_at' => 0, // 删除时间
* ],
* ...
* ]
*
* @param array $configTasks 任务配置
* 格式如下：
* [
* [ // object
* 'group_id' => '015ce30b116ce86058fa6ab4fea4ac63', // 租户ID
* 'code' => 'tv_broadcast', // 代码
* 'name' => '电视播出', // 名称
* 'sort_order' => 1, // 顺序
* ],
* [ // object
* 'id' => 29, // ID
* 'group_id' => '015ce30b116ce86058fa6ab4fea4ac63', // 租户ID
* 'code' => 'tv_broadcast', // 代码
* 'name' => '电视播出', // 名称
* 'sort_order' => 1, // 顺序
* 'category' => 2, // 任务类型，1：系统内置；2：用户定义
* 'parameter' => 's:0:"";', // 自定义参数，序列化存储
* 'status' => 1, // 状态，0：禁用；1：启用
* 'is_deleted' => 0, // 是否被删除，0：否；1：是
* 'created_at' => 1573632826, // 创建时间
* 'updated_at' => 1573632826, // 更新时间
* 'deleted_at' => 0, // 删除时间
* ],
* ...
* ]
*
* @param array $deletedConfigTaskSteps 需要删除的任务步骤配置
* 格式如下：
* [
* [ // object
* 'id' => 145, // ID
* 'group_id' => '015ce30b116ce86058fa6ab4fea4ac63', // 租户ID
* 'config_task_id' => 32, // 任务配置ID
* 'config_task_code' => 'other', // 任务配置代码
* 'config_step_id' => 2, // 步骤配置ID
* 'step_code' => 'begin_shot', // 步骤配置代码
* 'step_name' => '上传素材', // 步骤配置名称
* 'sort_order' => 1, // 步骤顺序，顺序排列
* 'is_default' => 1, // 是否默认步骤，1：是；0：否
* 'up_status_type' => 2, // 状态更新方式，1：接口；2：人工
* 'status' => 1, // 状态，0：禁用；1：启用
* 'is_deleted' => 0, // 是否被删除，0：否；1：是
* 'created_at' => 1573632826, // 创建时间
* 'updated_at' => 1573632826, // 更新时间
* 'deleted_at' => 0, // 删除时间
* ],
* ...
* ]
*
*
* @param array $configTaskSteps 任务步骤配置
* 格式如下：
* [
* [ // object
* 'group_id' => '015ce30b116ce86058fa6ab4fea4ac63', // 租户ID
* 'config_task_code' => 'tv_broadcast', // 任务配置代码
* 'step_code' => 'begin_shot', // 步骤代码
* 'sort_order' => 1, // 顺序
* 'is_default' => 1, // 是否默认步骤，1：是；0：否
* ],
* [ // object
* 'id' => 122, // ID
* 'group_id' => '015ce30b116ce86058fa6ab4fea4ac63', // 租户ID
* 'config_task_id' => 29, // 任务配置ID
* 'config_task_code' => 'tv_broadcast', // 任务配置代码
* 'config_step_id' => 2, // 步骤配置ID
* 'step_code' => 'begin_shot', // 步骤配置代码
* 'step_name' => '上传素材', // 步骤配置名称
* 'sort_order' => 1, // 步骤顺序，顺序排列
* 'is_default' => 1, // 是否默认步骤，1：是；0：否
* 'up_status_type' => 2, // 状态更新方式，1：接口；2：人工
* 'status' => 1, // 状态，0：禁用；1：启用
* 'is_deleted' => 0, // 是否被删除，0：否；1：是
* 'created_at' => 1573632826, // 创建时间
* 'updated_at' => 1573632826, // 更新时间
* 'deleted_at' => 0, // 删除时间
* ],
* ...
* ]
*
* @param object $identity 当前用户的身份实例
*
* @return array
* 格式如下：
*
* [
* 'status' => true, // 成功
* ]
*
* @throws \Throwable
*/
public function update($deletedConfigTasks, $configTasks, $deletedConfigTaskSteps, $configTaskSteps, $identity)
{
/* 操作数据(事务) */
$transaction = Yii::$app->db->beginTransaction();
try {
$configTaskService = new ConfigTaskService();
// 使用键名比较计算数组的差集，如果不为空，则删除 (软删除) 出现在 任务配置模型(MySQL) 中但是未出现在 任务配置列表 中的记录
$configTaskService->deleteMultiple($deletedConfigTasks);
// 遍历模型数组，判断在 任务配置 中是否存在，如果不存在则插入，如果存在则更新(已删除则先还原)
foreach ($configTasks as $configTask) {
$configTaskItem = ConfigTask::find()->where(['group_id' => $identity->group_id, 'code' => $configTask->code])->one();
/* @var $model ConfigTask */
if (!isset($configTaskItem)) {
$configTask->category = $configTask::CATEGORY_CUSTOMIZE;
$configTask->parameter = serialize('');
$configTask->status = $configTask::STATUS_ENABLED;
$configTask->is_deleted = $configTask::IS_DELETED_NO;
$configTask->deleted_at = $configTask::DELETED_AT_DEFAULT;
$configTaskServiceCreateResult = $configTaskService->create($configTask, false);
if ($configTaskServiceCreateResult['status'] === false) {
throw new ServerErrorHttpException($configTaskServiceCreateResult['message'], $configTaskServiceCreateResult['code']);
}
} else if (isset($configTaskItem)) {
if ($configTaskItem->is_deleted == ConfigTask::IS_DELETED_YES && $configTaskItem->restore() === false) {
throw new ServerErrorHttpException('Failed to restore the object (task configuration) for unknown reason.');
}
$configTaskItem->name = $configTask->name;
$configTaskItem->sort_order = $configTask->sort_order;
$configTaskItemServiceUpdateResult = $configTaskService->update($configTaskItem, false);
if ($configTaskItemServiceUpdateResult['status'] === false) {
throw new ServerErrorHttpException($configTaskItemServiceUpdateResult['message'], $configTaskItemServiceUpdateResult['code']);
}
}
}
// 使用键名比较计算数组的差集，如果不为空，则删除 (软删除) 出现在 任务步骤配置模型(MySQL) 中但是未出现在 任务步骤配置列表 中的记录
$this->deleteMultiple($deletedConfigTaskSteps);
$configTaskItems = ConfigTask::find()->where(['group_id' => $identity->group_id])->indexBy(['code'])->all();
$configStepItems = ConfigStep::find()->isDeletedNo()->indexBy(['code'])->all();
// 遍历模型数组，判断在 任务步骤配置 中是否存在，如果不存在则插入，如果存在则更新(已删除则先还原)
foreach ($configTaskSteps as $configTaskStep) {
$configTaskStepItem = ConfigTaskStep::find()->where(['group_id' => $identity->group_id, 'config_task_code' => $configTaskStep->config_task_code, 'step_code' => $configTaskStep->step_code])->one();
/* @var $model ConfigTaskStep */
if (!isset($configTaskStepItem)) {
$configTaskStep->config_task_id = $configTaskItems[$configTaskStep->config_task_code]->id;
$configTaskStep->config_step_id = $configStepItems[$configTaskStep->step_code]->id;
$configTaskStep->step_name = $configStepItems[$configTaskStep->step_code]->name;
$configTaskStep->status = $configTaskStep::STATUS_ENABLED;
$configTaskStep->is_deleted = $configTaskStep::IS_DELETED_NO;
$configTaskStep->deleted_at = $configTaskStep::DELETED_AT_DEFAULT;
$thisCreateResult = $this->create($configTaskStep, false);
if ($thisCreateResult['status'] === false) {
throw new ServerErrorHttpException($thisCreateResult['message'], $thisCreateResult['code']);
}
} else if (isset($configTaskStepItem)) {
if ($configTaskStepItem->is_deleted == ConfigTaskStep::IS_DELETED_YES && $configTaskStepItem->restore() === false) {
throw new ServerErrorHttpException('Failed to restore the object (task step configuration) for unknown reason.');
}
$configTaskStepItem->sort_order = $configTaskStep->sort_order;
$configTaskStepItem->is_default = $configTaskStep->is_default;
if ($configTaskStepItem->save(false)) {
// return ['status' => true, 'data' => $configTaskStepItem];
} elseif ($configTaskStepItem->hasErrors()) {
$firstError = '';
foreach ($configTaskStepItem->getFirstErrors() as $message) {
$firstError = $message;
break;
}
throw new ServerErrorHttpException(Yii::t('error', Yii::t('error', Yii::t('error', '226085'), ['first_error' => $firstError])), 226085);
} elseif (!$configTaskStepItem->hasErrors()) {
throw new ServerErrorHttpException('Failed to update the object (task step configuration) for unknown reason.');
}
}
}
$transaction->commit();
} catch(\Throwable $e) {
$transaction->rollBack();
throw $e;
}
return ['status' => true];
}
/**
* 批量删除(删除任务步骤配置)
*
* @param $models
*
* @return bool the saved model or false if saving fails
* @throws \Throwable
*/
public function deleteMultiple($models)
{
$transaction = Yii::$app->db->beginTransaction();
try {
foreach ($models as $model) {
if($model->softDelete() === false) {
throw new ServerErrorHttpException(Yii::t('error', '226086'), 226086);
}
}
$transaction->commit();
return true;
} catch (\Throwable $e) {
$transaction->rollBack();
throw $e;
}
}
}
19. Edit the model file of the update task settings (\API\Models\ConfigTask.php)
<?php
namespace api\models;
use yii\helpers\ArrayHelper;
class ConfigTask extends \common\logics\ConfigTask
{
const SCENARIO_UPDATE = 'update';
public function scenarios()
{
$scenarios = parent::scenarios();
$scenarios[self::SCENARIO_UPDATE] = ['group_id', 'code', 'name', 'sort_order', 'is_deleted', 'deleted_at'];
return $scenarios;
}
/**
* @inheritdoc
*/
public function rules()
{
$rules = [
];
$parentRules = parent::rules();
return ArrayHelper::merge($rules, $parentRules);
}
/**
* {@inheritdoc}
* @return ConfigTaskQuery the active query used by this AR class.
*/
public static function find()
{
return new ConfigTaskQuery(get_called_class());
}
}
20. Edit the model file of the update task step settings (\API\Models\ConfigTaskStep.php)
<?php
namespace api\models;
use yii\helpers\ArrayHelper;
class ConfigTaskStep extends \common\logics\ConfigTaskStep
{
const SCENARIO_UPDATE = 'update';
public function scenarios()
{
$scenarios = parent::scenarios();
$scenarios[self::SCENARIO_UPDATE] = ['group_id', 'config_task_code', 'step_code', 'sort_order', 'is_default', 'is_deleted', 'deleted_at'];
return $scenarios;
}
/**
* @inheritdoc
*/
public function rules()
{
$rules = [
/* 添加、更新任务步骤配置 */
['step_code', 'exist', 'targetClass' => '\api\models\ConfigStep', 'targetAttribute' => 'code', 'filter' => ['is_deleted' => ConfigStep::IS_DELETED_NO], 'on' => self::SCENARIO_UPDATE],
[['is_default'], 'in', 'range' => [static::IS_DEFAULT_NO, static::IS_DEFAULT_YES], 'on' => self::SCENARIO_UPDATE],
];
$parentRules = parent::rules();
return ArrayHelper::merge($rules, $parentRules);
}
/**
* {@inheritdoc}
* @return ConfigTaskStepQuery the active query used by this AR class.
*/
public static function find()
{
return new ConfigTaskStepQuery(get_called_class());
}
}
21. Put in Postman:http://api.pcs-api.localhost/v1/config-task-steps/my-group-id, the request data (NULL) and the executed SQL (data not inserted) are as follows, as shown in Figure 4
Figure 4
SELECT * FROM `pa_config_task` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`is_deleted`=0)
SELECT * FROM `pa_config_task` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63')
SELECT * FROM `pa_config_task_step` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`is_deleted`=0)
SELECT * FROM `pa_config_task_step` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63')
Begin transaction
SELECT * FROM `pa_config_task` WHERE `group_id`='015ce30b116ce86058fa6ab4fea4ac63'
Commit transaction
22. Put in Postman:http://api.pcs-api.localhost/v1/config-task-steps/my-group-id, request data ([]) and the executed SQL (no data inserted) as follows, as shown in Figure 5
![在 Postman 中 PUT：http://api.pcs-api.localhost/v1/config-task-steps/my-group-id ，请求数据([])与执行的 SQL (未插入数据) 如下](https://www.shuijingwanwq.com/wp-content/uploads/2019/11/5-1.png)
Figure 5
SELECT * FROM `pa_config_task` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`is_deleted`=0)
SELECT * FROM `pa_config_task` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63')
SELECT * FROM `pa_config_task_step` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`is_deleted`=0)
SELECT * FROM `pa_config_task_step` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63')
Begin transaction
SELECT * FROM `pa_config_task` WHERE `group_id`='015ce30b116ce86058fa6ab4fea4ac63'
Commit transaction
23. Put in Postman:http://api.pcs-api.localhost/v1/config-task-steps/my-group-id, the request data (when the response data of the editing interface is edited) and the executed SQL (insert 4 and 24 records respectively) are as follows, open the table, as shown in Figure 6
Figure 6
[
{
"code": "tv_broadcast",
"name": "电视播出",
"sort_order": 1,
"steps": [
{
"code": "begin_shot",
"sort_order": 1,
"is_default": 1
},
{
"code": "writing",
"sort_order": 2,
"is_default": 1
},
{
"code": "manuscript_review",
"sort_order": 4,
"is_default": 1
},
{
"code": "video_editing",
"sort_order": 5,
"is_default": 1
},
{
"code": "tandem_list",
"sort_order": 6,
"is_default": 1
},
{
"code": "program_render",
"sort_order": 7,
"is_default": 1
},
{
"code": "program_authen",
"sort_order": 8,
"is_default": 1
}
]
},
{
"code": "inter_view",
"name": "采访任务",
"sort_order": 2,
"steps": [
{
"code": "begin_shot",
"sort_order": 1,
"is_default": 1
},
{
"code": "material_review",
"sort_order": 2,
"is_default": 1
},
{
"code": "writing",
"sort_order": 4,
"is_default": 1
},
{
"code": "writing_draft",
"sort_order": 5,
"is_default": 1
},
{
"code": "manuscript_review",
"sort_order": 6,
"is_default": 1
},
{
"code": "finish_interview",
"sort_order": 7,
"is_default": 1
}
]
},
{
"code": "rich_doc",
"name": "互联网发布",
"sort_order": 3,
"steps": [
{
"code": "retrieval",
"sort_order": 1,
"is_default": 1
},
{
"code": "writing",
"sort_order": 2,
"is_default": 1
},
{
"code": "manuscript_review",
"sort_order": 4,
"is_default": 1
},
{
"code": "newspaper_issued",
"sort_order": 5,
"is_default": 1
},
{
"code": "wechat_group_reference",
"sort_order": 6,
"is_default": 1
},
{
"code": "website_release",
"sort_order": 7,
"is_default": 1
},
{
"code": "app_release",
"sort_order": 8,
"is_default": 1
},
{
"code": "wechat_release",
"sort_order": 9,
"is_default": 1
},
{
"code": "blog_release",
"sort_order": 10,
"is_default": 1
},
{
"code": "qq_release",
"sort_order": 11,
"is_default": 1
}
]
},
{
"code": "other",
"name": "手动任务",
"sort_order": 4,
"steps": [
{
"code": "begin_shot",
"sort_order": 1,
"is_default": 1
}
]
}
]
SELECT * FROM `pa_config_task` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`is_deleted`=0)
SELECT * FROM `pa_config_task` WHERE `group_id`='015ce30b116ce86058fa6ab4fea4ac63'
SELECT * FROM `pa_config_task_step` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`is_deleted`=0)
SELECT * FROM `pa_config_task_step` WHERE `group_id`='015ce30b116ce86058fa6ab4fea4ac63'
SELECT EXISTS(SELECT * FROM `pa_config_task` WHERE (`pa_config_task`.`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`pa_config_task`.`code`='tv_broadcast') AND (`pa_config_task`.`is_deleted`=0) AND (`pa_config_task`.`deleted_at`=0)) // 总计 4 次执行
SELECT EXISTS(SELECT * FROM `pa_config_task` WHERE (`pa_config_task`.`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`pa_config_task`.`code`='inter_view') AND (`pa_config_task`.`is_deleted`=0) AND (`pa_config_task`.`deleted_at`=0)) // 总计 4 次执行
SELECT EXISTS(SELECT * FROM `pa_config_task` WHERE (`pa_config_task`.`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`pa_config_task`.`code`='rich_doc') AND (`pa_config_task`.`is_deleted`=0) AND (`pa_config_task`.`deleted_at`=0)) // 总计 4 次执行
SELECT EXISTS(SELECT * FROM `pa_config_task` WHERE (`pa_config_task`.`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`pa_config_task`.`code`='other') AND (`pa_config_task`.`is_deleted`=0) AND (`pa_config_task`.`deleted_at`=0)) // 总计 4 次执行
SELECT EXISTS(SELECT * FROM `pa_config_step` WHERE (`pa_config_step`.`code`='begin_shot') AND (`is_deleted`=0)) // 总计 24 次执行【SELECT EXISTS(SELECT * FROM `pa_config_step` WHERE (`pa_config_step`.`code`=】
SELECT EXISTS(SELECT * FROM `pa_config_task_step` WHERE (`pa_config_task_step`.`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`pa_config_task_step`.`config_task_code`='tv_broadcast') AND (`pa_config_task_step`.`step_code`='begin_shot') AND (`pa_config_task_step`.`is_deleted`=0) AND (`pa_config_task_step`.`deleted_at`=0)) // 总计 120 次执行【SELECT EXISTS(SELECT * FROM `pa_config_task_step` WHERE (`pa_config_task_step`.`group_id`】
Begin transaction
SELECT * FROM `pa_config_task` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`code`='tv_broadcast') // 总计 4 次执行【SELECT * FROM `pa_config_task` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`code`=】
INSERT INTO `pa_config_task` (`group_id`, `code`, `name`, `sort_order`, `is_deleted`, `deleted_at`, `category`, `parameter`, `status`, `created_at`, `updated_at`) VALUES ('015ce30b116ce86058fa6ab4fea4ac63', 'tv_broadcast', '电视播出', 1, 0, 0, 2, 's:0:\"\";', 1, 1573626589, 1573626589) // 总计 4 次执行【SELECT * FROM `pa_config_task` WHERE (INSERT INTO `pa_config_task` (`group_id`, `code`, `name`, `sort_order`, `is_deleted`, `deleted_at`, `category`, `parameter`, `status`, `created_at`, `updated_at`) VALUES ('015ce30b116ce86058fa6ab4fea4ac63'】
SELECT * FROM `pa_config_task` WHERE `group_id`='015ce30b116ce86058fa6ab4fea4ac63'
SELECT * FROM `pa_config_step` WHERE `is_deleted`=0
SELECT * FROM `pa_config_task_step` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`config_task_code`='tv_broadcast') AND (`step_code`='begin_shot') // 总计 24 次执行【SELECT * FROM `pa_config_task_step` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`config_task_code`=】
INSERT INTO `pa_config_task_step` (`group_id`, `config_task_code`, `step_code`, `sort_order`, `is_default`, `is_deleted`, `deleted_at`, `config_task_id`, `config_step_id`, `step_name`, `status`, `created_at`, `updated_at`) VALUES ('015ce30b116ce86058fa6ab4fea4ac63', 'tv_broadcast', 'begin_shot', 1, 1, 0, 0, 17, 2, '上传素材', 1, 1573626589, 1573626589) // 总计 24 次执行【INSERT INTO `pa_config_task_step` (`group_id`, `config_task_code`, `step_code`, `sort_order`, `is_default`, `is_deleted`, `deleted_at`, `config_task_id`, `config_step_id`, `step_name`, `status`, `created_at`, `updated_at`) VALUES ('015ce30b116ce86058fa6ab4fea4ac63'】
Commit transaction
24. Get in Postman:http://api.pcs-api.localhost/v1/config-task-steps/edit/my-group-id, when the tenant is customized, that is, when there is a record of the current tenant in the task configuration table and task step configuration table, the record of the current tenant ID in the task configuration table and task step configuration table is obtained by default. The response data and the executed sql are as follows
{
"code": 10000,
"message": "编辑租户的任务类型与步骤设置成功",
"data": {
"items": [
{
"id": 17,
"code": "tv_broadcast",
"name": "电视播出",
"sort_order": 1,
"steps": [
{
"id": 2,
"code": "begin_shot",
"name": "上传素材",
"sort_order": 1,
"is_default": 1
},
{
"id": 4,
"code": "writing",
"name": "撰写稿件",
"sort_order": 2,
"is_default": 1
},
{
"id": 7,
"code": "manuscript_review",
"name": "稿件审核",
"sort_order": 4,
"is_default": 1
},
{
"id": 10,
"code": "video_editing",
"name": "视频编辑",
"sort_order": 5,
"is_default": 1
},
{
"id": 11,
"code": "tandem_list",
"name": "串联单",
"sort_order": 6,
"is_default": 1
},
{
"id": 14,
"code": "program_render",
"name": "节目上传",
"sort_order": 7,
"is_default": 1
},
{
"id": 16,
"code": "program_authen",
"name": "节目审查",
"sort_order": 8,
"is_default": 1
}
]
},
{
"id": 18,
"code": "inter_view",
"name": "采访任务",
"sort_order": 2,
"steps": [
{
"id": 2,
"code": "begin_shot",
"name": "上传素材",
"sort_order": 1,
"is_default": 1
},
{
"id": 3,
"code": "material_review",
"name": "素材审核",
"sort_order": 2,
"is_default": 1
},
{
"id": 4,
"code": "writing",
"name": "撰写稿件",
"sort_order": 4,
"is_default": 1
},
{
"id": 8,
"code": "writing_draft",
"name": "撰写通稿",
"sort_order": 5,
"is_default": 1
},
{
"id": 7,
"code": "manuscript_review",
"name": "稿件审核",
"sort_order": 6,
"is_default": 1
},
{
"id": 13,
"code": "finish_interview",
"name": "结束采访",
"sort_order": 7,
"is_default": 1
}
]
},
{
"id": 19,
"code": "rich_doc",
"name": "互联网发布",
"sort_order": 3,
"steps": [
{
"id": 1,
"code": "retrieval",
"name": "取稿",
"sort_order": 1,
"is_default": 1
},
{
"id": 4,
"code": "writing",
"name": "撰写稿件",
"sort_order": 2,
"is_default": 1
},
{
"id": 7,
"code": "manuscript_review",
"name": "稿件审核",
"sort_order": 4,
"is_default": 1
},
{
"id": 9,
"code": "newspaper_issued",
"name": "报纸签发",
"sort_order": 5,
"is_default": 1
},
{
"id": 12,
"code": "wechat_group_reference",
"name": "微信组稿引用",
"sort_order": 6,
"is_default": 1
},
{
"id": 15,
"code": "website_release",
"name": "网站发布",
"sort_order": 7,
"is_default": 1
},
{
"id": 17,
"code": "app_release",
"name": "APP发布",
"sort_order": 8,
"is_default": 1
},
{
"id": 18,
"code": "wechat_release",
"name": "微信发布",
"sort_order": 9,
"is_default": 1
},
{
"id": 19,
"code": "blog_release",
"name": "微博发布",
"sort_order": 10,
"is_default": 1
},
{
"id": 20,
"code": "qq_release",
"name": "企鹅号发布",
"sort_order": 11,
"is_default": 1
}
]
},
{
"id": 20,
"code": "other",
"name": "手动任务",
"sort_order": 4,
"steps": [
{
"id": 2,
"code": "begin_shot",
"name": "上传素材",
"sort_order": 1,
"is_default": 1
}
]
}
]
}
}
SELECT * FROM `pa_config_task_step` WHERE `group_id`='015ce30b116ce86058fa6ab4fea4ac63'
SELECT * FROM `pa_config_task_step` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`is_deleted`=0) ORDER BY `sort_order`, `id` DESC
SELECT * FROM `pa_config_task` WHERE `group_id`='015ce30b116ce86058fa6ab4fea4ac63'
SELECT * FROM `pa_config_task` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`is_deleted`=0) ORDER BY `sort_order`, `id` DESC
25. Put in Postman:http://api.pcs-api.localhost/v1/config-task-steps/my-group-id, request data (delete task configuration (interview task) 6 step configuration; delete 1 task configuration (manual task) and 1 step configuration in it; add 1 task configuration after Internet release (custom 1) and add 0 in it Item step configuration; add 1 task configuration after Custom 1 (custom 2) and add 2 step configurations in it; update 1 task configuration (Internet release) and 1 of the steps in it) and the executed SQL Insert statement, 2 update statements; task step configuration table: 2 insert statements, 8 update statements) As follows, open the table, as shown in Figure 7
Figure 7
[
{
"code": "tv_broadcast",
"name": "电视播出",
"sort_order": 1,
"steps": [
{
"code": "begin_shot",
"sort_order": 1,
"is_default": 1
},
{
"code": "writing",
"sort_order": 2,
"is_default": 1
},
{
"code": "manuscript_review",
"sort_order": 4,
"is_default": 1
},
{
"code": "video_editing",
"sort_order": 5,
"is_default": 1
},
{
"code": "tandem_list",
"sort_order": 6,
"is_default": 1
},
{
"code": "program_render",
"sort_order": 7,
"is_default": 1
},
{
"code": "program_authen",
"sort_order": 8,
"is_default": 1
}
]
},
{
"code": "inter_view",
"name": "采访任务",
"sort_order": 2,
"steps": []
},
{
"code": "rich_doc",
"name": "互联网发布更新",
"sort_order": 4,
"steps": [
{
"code": "retrieval",
"sort_order": 1,
"is_default": 1
},
{
"code": "writing",
"sort_order": 2,
"is_default": 1
},
{
"code": "manuscript_review",
"sort_order": 3,
"is_default": 1
},
{
"code": "newspaper_issued",
"sort_order": 5,
"is_default": 1
},
{
"code": "wechat_group_reference",
"sort_order": 6,
"is_default": 1
},
{
"code": "website_release",
"sort_order": 7,
"is_default": 1
},
{
"code": "app_release",
"sort_order": 8,
"is_default": 1
},
{
"code": "wechat_release",
"sort_order": 9,
"is_default": 1
},
{
"code": "blog_release",
"sort_order": 10,
"is_default": 1
},
{
"code": "qq_release",
"sort_order": 11,
"is_default": 1
}
]
},
{
"code": "zdy1",
"name": "自定义一",
"sort_order": 5,
"steps": []
},
{
"code": "zdy2",
"name": "自定义二",
"sort_order": 6,
"steps": [
{
"code": "begin_shot",
"sort_order": 1,
"is_default": 1
},
{
"code": "program_render",
"sort_order": 7,
"is_default": 1
}
]
}
]
SELECT * FROM `pa_config_task` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`is_deleted`=0)
SELECT * FROM `pa_config_task` WHERE `group_id`='015ce30b116ce86058fa6ab4fea4ac63'
SELECT * FROM `pa_config_task_step` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`is_deleted`=0)
SELECT * FROM `pa_config_task_step` WHERE `group_id`='015ce30b116ce86058fa6ab4fea4ac63'
SELECT `pa_config_task`.`id` FROM `pa_config_task` WHERE (`pa_config_task`.`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`pa_config_task`.`code`='tv_broadcast') AND (`pa_config_task`.`is_deleted`=0) AND (`pa_config_task`.`deleted_at`=0) LIMIT 2 // 总计 12 次执行【SELECT `pa_config_task`.`id` FROM `pa_config_task` WHERE (`pa_config_task`.`group_id`=】
SELECT EXISTS(SELECT * FROM `pa_config_task` WHERE (`pa_config_task`.`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`pa_config_task`.`code`='zdy1') AND (`pa_config_task`.`is_deleted`=0) AND (`pa_config_task`.`deleted_at`=0)) // 总计 8 次执行【SELECT EXISTS(SELECT * FROM `pa_config_task` WHERE (`pa_config_task`.`group_id`=】
SELECT EXISTS(SELECT * FROM `pa_config_step` WHERE (`pa_config_step`.`code`='begin_shot') AND (`is_deleted`=0)) // 总计 19 次执行【SELECT EXISTS(SELECT * FROM `pa_config_step` WHERE (`pa_config_step`.`code`=】
SELECT `pa_config_task_step`.`id` FROM `pa_config_task_step` WHERE (`pa_config_task_step`.`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`pa_config_task_step`.`config_task_code`='tv_broadcast') AND (`pa_config_task_step`.`step_code`='begin_shot') AND (`pa_config_task_step`.`is_deleted`=0) AND (`pa_config_task_step`.`deleted_at`=0) LIMIT 2 // 总计 85 次执行【SELECT `pa_config_task_step`.`id` FROM `pa_config_task_step` WHERE (`pa_config_task_step`.`group_id`=】
SELECT EXISTS(SELECT * FROM `pa_config_step` WHERE (`pa_config_step`.`code`='writing') AND (`is_deleted`=0)) // 总计 19 次执行【SELECT EXISTS(SELECT * FROM `pa_config_step` WHERE (`pa_config_step`.`code`=】
Begin transaction
UPDATE `pa_config_task` SET `is_deleted`=1, `deleted_at`=1573630064 WHERE `id`=20
SELECT * FROM `pa_config_task` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`code`='tv_broadcast') // 总计 5 次执行【SELECT * FROM `pa_config_task` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`code`=】
UPDATE `pa_config_task` SET `name`='互联网发布更新', `sort_order`=4, `updated_at`=1573630064 WHERE `id`=19
INSERT INTO `pa_config_task` (`group_id`, `code`, `name`, `sort_order`, `is_deleted`, `deleted_at`, `category`, `parameter`, `status`, `created_at`, `updated_at`) VALUES ('015ce30b116ce86058fa6ab4fea4ac63', 'zdy1', '自定义一', 5, 0, 0, 2, 's:0:\"\";', 1, 1573630064, 1573630064)
INSERT INTO `pa_config_task` (`group_id`, `code`, `name`, `sort_order`, `is_deleted`, `deleted_at`, `category`, `parameter`, `status`, `created_at`, `updated_at`) VALUES ('015ce30b116ce86058fa6ab4fea4ac63', 'zdy2', '自定义二', 6, 0, 0, 2, 's:0:\"\";', 1, 1573630064, 1573630064)
UPDATE `pa_config_task_step` SET `is_deleted`=1, `deleted_at`=1573630064 WHERE `id`=83 // 总计 7 次执行【UPDATE `pa_config_task_step` SET `is_deleted`=1】
SELECT * FROM `pa_config_task` WHERE `group_id`='015ce30b116ce86058fa6ab4fea4ac63'
SELECT * FROM `pa_config_step` WHERE `is_deleted`=0
SELECT * FROM `pa_config_task_step` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`config_task_code`='tv_broadcast') AND (`step_code`='begin_shot') // 总计 19 次执行【SELECT * FROM `pa_config_task_step` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`config_task_code`=】
UPDATE `pa_config_task_step` SET `sort_order`=3, `updated_at`=1573630064 WHERE `id`=91
INSERT INTO `pa_config_task_step` (`group_id`, `config_task_code`, `step_code`, `sort_order`, `is_default`, `is_deleted`, `deleted_at`, `config_task_id`, `config_step_id`, `step_name`, `status`, `created_at`, `updated_at`) VALUES ('015ce30b116ce86058fa6ab4fea4ac63', 'zdy2', 'begin_shot', 1, 1, 0, 0, 22, 2, '上传素材', 1, 1573630064, 1573630064)
INSERT INTO `pa_config_task_step` (`group_id`, `config_task_code`, `step_code`, `sort_order`, `is_default`, `is_deleted`, `deleted_at`, `config_task_id`, `config_step_id`, `step_name`, `status`, `created_at`, `updated_at`) VALUES ('015ce30b116ce86058fa6ab4fea4ac63', 'zdy2', 'program_render', 7, 1, 0, 0, 22, 14, '节目上传', 1, 1573630064, 1573630064)
Commit transaction
26. In Postman get:http://api.pcs-api.localhost/v1/config-task-steps/edit/my-group-id, when the tenant is customized, that is, when there is a record of the current tenant in the task configuration table and task step configuration table, the record of the current tenant ID in the task configuration table and task step configuration table is obtained by default. The response data and the executed sql are as follows
{
"code": 10000,
"message": "编辑租户的任务类型与步骤设置成功",
"data": {
"items": [
{
"id": 17,
"code": "tv_broadcast",
"name": "电视播出",
"sort_order": 1,
"steps": [
{
"id": 2,
"code": "begin_shot",
"name": "上传素材",
"sort_order": 1,
"is_default": 1
},
{
"id": 4,
"code": "writing",
"name": "撰写稿件",
"sort_order": 2,
"is_default": 1
},
{
"id": 7,
"code": "manuscript_review",
"name": "稿件审核",
"sort_order": 4,
"is_default": 1
},
{
"id": 10,
"code": "video_editing",
"name": "视频编辑",
"sort_order": 5,
"is_default": 1
},
{
"id": 11,
"code": "tandem_list",
"name": "串联单",
"sort_order": 6,
"is_default": 1
},
{
"id": 14,
"code": "program_render",
"name": "节目上传",
"sort_order": 7,
"is_default": 1
},
{
"id": 16,
"code": "program_authen",
"name": "节目审查",
"sort_order": 8,
"is_default": 1
}
]
},
{
"id": 18,
"code": "inter_view",
"name": "采访任务",
"sort_order": 2,
"steps": []
},
{
"id": 19,
"code": "rich_doc",
"name": "互联网发布更新",
"sort_order": 4,
"steps": [
{
"id": 1,
"code": "retrieval",
"name": "取稿",
"sort_order": 1,
"is_default": 1
},
{
"id": 4,
"code": "writing",
"name": "撰写稿件",
"sort_order": 2,
"is_default": 1
},
{
"id": 7,
"code": "manuscript_review",
"name": "稿件审核",
"sort_order": 3,
"is_default": 1
},
{
"id": 9,
"code": "newspaper_issued",
"name": "报纸签发",
"sort_order": 5,
"is_default": 1
},
{
"id": 12,
"code": "wechat_group_reference",
"name": "微信组稿引用",
"sort_order": 6,
"is_default": 1
},
{
"id": 15,
"code": "website_release",
"name": "网站发布",
"sort_order": 7,
"is_default": 1
},
{
"id": 17,
"code": "app_release",
"name": "APP发布",
"sort_order": 8,
"is_default": 1
},
{
"id": 18,
"code": "wechat_release",
"name": "微信发布",
"sort_order": 9,
"is_default": 1
},
{
"id": 19,
"code": "blog_release",
"name": "微博发布",
"sort_order": 10,
"is_default": 1
},
{
"id": 20,
"code": "qq_release",
"name": "企鹅号发布",
"sort_order": 11,
"is_default": 1
}
]
},
{
"id": 21,
"code": "zdy1",
"name": "自定义一",
"sort_order": 5,
"steps": []
},
{
"id": 22,
"code": "zdy2",
"name": "自定义二",
"sort_order": 6,
"steps": [
{
"id": 2,
"code": "begin_shot",
"name": "上传素材",
"sort_order": 1,
"is_default": 1
},
{
"id": 14,
"code": "program_render",
"name": "节目上传",
"sort_order": 7,
"is_default": 1
}
]
}
]
}
}
SELECT * FROM `pa_config_task_step` WHERE `group_id`='015ce30b116ce86058fa6ab4fea4ac63'
SELECT * FROM `pa_config_task_step` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`is_deleted`=0) ORDER BY `sort_order`, `id` DESC
SELECT * FROM `pa_config_task` WHERE `group_id`='015ce30b116ce86058fa6ab4fea4ac63'
SELECT * FROM `pa_config_task` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`is_deleted`=0) ORDER BY `sort_order`, `id` DESC
27. Put in Postman:http://api.pcs-api.localhost/v1/config-task-steps/my-group-id, request data (1 task configuration that was deleted before adding the interview task (manual task, adjusting the order value of 3) and the configuration of 1 item in it) and the updated SQL (task configuration table: 2 Article update statement (restore and then update); task step configuration table: 1 update statement) as follows, open the table, as shown in Figure 8
8
[
{
"code": "tv_broadcast",
"name": "电视播出",
"sort_order": 1,
"steps": [
{
"code": "begin_shot",
"sort_order": 1,
"is_default": 1
},
{
"code": "writing",
"sort_order": 2,
"is_default": 1
},
{
"code": "manuscript_review",
"sort_order": 4,
"is_default": 1
},
{
"code": "video_editing",
"sort_order": 5,
"is_default": 1
},
{
"code": "tandem_list",
"sort_order": 6,
"is_default": 1
},
{
"code": "program_render",
"sort_order": 7,
"is_default": 1
},
{
"code": "program_authen",
"sort_order": 8,
"is_default": 1
}
]
},
{
"code": "inter_view",
"name": "采访任务",
"sort_order": 2,
"steps": []
},
{
"code": "other",
"name": "手动任务",
"sort_order": 3,
"steps": [
{
"code": "begin_shot",
"sort_order": 1,
"is_default": 1
}
]
},
{
"code": "rich_doc",
"name": "互联网发布更新",
"sort_order": 4,
"steps": [
{
"code": "retrieval",
"sort_order": 1,
"is_default": 1
},
{
"code": "writing",
"sort_order": 2,
"is_default": 1
},
{
"code": "manuscript_review",
"sort_order": 3,
"is_default": 1
},
{
"code": "newspaper_issued",
"sort_order": 5,
"is_default": 1
},
{
"code": "wechat_group_reference",
"sort_order": 6,
"is_default": 1
},
{
"code": "website_release",
"sort_order": 7,
"is_default": 1
},
{
"code": "app_release",
"sort_order": 8,
"is_default": 1
},
{
"code": "wechat_release",
"sort_order": 9,
"is_default": 1
},
{
"code": "blog_release",
"sort_order": 10,
"is_default": 1
},
{
"code": "qq_release",
"sort_order": 11,
"is_default": 1
}
]
},
{
"code": "zdy1",
"name": "自定义一",
"sort_order": 5,
"steps": []
},
{
"code": "zdy2",
"name": "自定义二",
"sort_order": 6,
"steps": [
{
"code": "begin_shot",
"sort_order": 1,
"is_default": 1
},
{
"code": "program_render",
"sort_order": 7,
"is_default": 1
}
]
}
]
Begin transaction
UPDATE `pa_config_task` SET `is_deleted`=0, `deleted_at`=0 WHERE `id`=20
UPDATE `pa_config_task` SET `sort_order`=3, `updated_at`=1573632089 WHERE `id`=20
UPDATE `pa_config_task_step` SET `is_deleted`=0, `deleted_at`=0 WHERE `id`=99
Commit transaction
28. There are already 3 tenant custom task types and step settings, the total number of rows of 2 tables (20, 97), and the SQL analysis is as follows based on EXPLAIN (Type: const|ref, rows) The index is at most 1/4 of the total number of rows in the table, the index is reasonable, as shown in Figure 9
Note:
(1) Type: The access type is displayed, which is a more important indicator. The result value from good to bad is:
system > const > eq_ref > ref > fulltext > ref_or_null & index_merge > UNIQUE_SUBQUERY > index_subquery > range > index > all
(2) rows: This number indicates how much data mysql needs to traverse to find, at most 1/4 of the total number of rows in the table, which is an ideal situation
Figure 9
EXPLAIN SELECT * FROM `pa_config_task` WHERE `group_id`=''
id select_type table partitions type possible_keys key key_len ref rows filtered Extra
1 SIMPLE pa_config_task ref uc_group_id_code_is_deleted_deleted_at uc_group_id_code_is_deleted_deleted_at 130 const 4 100.00
EXPLAIN SELECT * FROM `pa_config_task` WHERE `group_id`='015ce30b116ce86058fa6ab4fea4ac63'
id select_type table partitions type possible_keys key key_len ref rows filtered Extra
1 SIMPLE pa_config_task ref uc_group_id_code_is_deleted_deleted_at uc_group_id_code_is_deleted_deleted_at 130 const 6 100.00
EXPLAIN SELECT * FROM `pa_config_task` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`is_deleted`=0)
id select_type table partitions type possible_keys key key_len ref rows filtered Extra
1 SIMPLE pa_config_task ref uc_group_id_code_is_deleted_deleted_at uc_group_id_code_is_deleted_deleted_at 130 const 6 10.00 Using index condition
EXPLAIN SELECT * FROM `pa_config_task` WHERE (`group_id`='') AND (`is_deleted`=0) ORDER BY `sort_order`, `id` DESC
id select_type table partitions type possible_keys key key_len ref rows filtered Extra
1 SIMPLE pa_config_task ref uc_group_id_code_is_deleted_deleted_at uc_group_id_code_is_deleted_deleted_at 130 const 4 10.00 Using index condition; Using filesort
EXPLAIN SELECT * FROM `pa_config_task_step` WHERE `group_id`='015ce30b116ce86058fa6ab4fea4ac63'
id select_type table partitions type possible_keys key key_len ref rows filtered Extra
1 SIMPLE pa_config_task_step ref uc_group_id_config_task_code_step_code_is_deleted_deleted_at uc_group_id_config_task_code_step_code_is_deleted_deleted_at 130 const 26 100.00
EXPLAIN SELECT * FROM `pa_config_task_step` WHERE (`group_id`='') AND (`is_deleted`=0) ORDER BY `sort_order`, `id` DESC
id select_type table partitions type possible_keys key key_len ref rows filtered Extra
1 SIMPLE pa_config_task_step ref uc_group_id_config_task_code_step_code_is_deleted_deleted_at uc_group_id_config_task_code_step_code_is_deleted_deleted_at 130 const 27 10.00 Using index condition; Using filesort
EXPLAIN SELECT * FROM `pa_config_task_step` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`is_deleted`=0) ORDER BY `sort_order`, `id` DESC
id select_type table partitions type possible_keys key key_len ref rows filtered Extra
1 SIMPLE pa_config_task_step ref uc_group_id_config_task_code_step_code_is_deleted_deleted_at uc_group_id_config_task_code_step_code_is_deleted_deleted_at 130 const 26 10.00 Using index condition; Using filesort
EXPLAIN SELECT `pa_config_task`.`id` FROM `pa_config_task` WHERE (`pa_config_task`.`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`pa_config_task`.`code`='tv_broadcast') AND (`pa_config_task`.`is_deleted`=0) AND (`pa_config_task`.`deleted_at`=0) LIMIT 2
id select_type table partitions type possible_keys key key_len ref rows filtered Extra
1 SIMPLE pa_config_task const uc_group_id_code_is_deleted_deleted_at uc_group_id_code_is_deleted_deleted_at 266 const,const,const,const 1 100.00 Using index
EXPLAIN SELECT EXISTS(SELECT * FROM `pa_config_task` WHERE (`pa_config_task`.`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`pa_config_task`.`code`='zdy1') AND (`pa_config_task`.`is_deleted`=0) AND (`pa_config_task`.`deleted_at`=0))
id select_type table partitions type possible_keys key key_len ref rows filtered Extra
1 PRIMARY No tables used
2 SUBQUERY pa_config_task const uc_group_id_code_is_deleted_deleted_at uc_group_id_code_is_deleted_deleted_at 266 const,const,const,const 1 100.00 Using index
EXPLAIN SELECT EXISTS(SELECT * FROM `pa_config_step` WHERE (`pa_config_step`.`code`='writing') AND (`is_deleted`=0))
id select_type table partitions type possible_keys key key_len ref rows filtered Extra
1 PRIMARY No tables used
2 SUBQUERY pa_config_step ref idx_code idx_code 130 const 1 10.00 Using where
EXPLAIN SELECT * FROM `pa_config_task_step` WHERE (`group_id`='015ce30b116ce86058fa6ab4fea4ac63') AND (`config_task_code`='tv_broadcast') AND (`step_code`='begin_shot')
id select_type table partitions type possible_keys key key_len ref rows filtered Extra
1 SIMPLE pa_config_task_step ref uc_group_id_config_task_code_step_code_is_deleted_deleted_at uc_group_id_config_task_code_step_code_is_deleted_deleted_at 390 const,const,const 1 100.00
![在 MySQL 8.0 中设置 datetime 的默认值为 '0000-00-00 00:00:00' 时报错：SQLSTATE[42000]: Syntax error or access violation: 1067 Invalid default value for 'operated_at_gmt'](https://www.shuijingwanwq.com/wp-content/uploads/2024/02/1-3-520x245.png)
