On Yii 2.0, the API of RESTful-style web service services, the implementation of POST batch new resources
1. \API\RESTS\PLAN_TASK\CreateAction.php, please refer to the URL for the specific implementation:https://github.com/yiisoft/yii2/blob/master/docs/guide-zh-CN/input-tabular-input.md, the code is as follows:
* @since 1.0
*/
class CreateAction extends Action
{
/**
* @var string the scenario to be assigned to the new model before it is validated and saved.
*/
public $scenario = Model::SCENARIO_DEFAULT;
/**
* Creates a new model.
* @return \yii\db\ActiveRecordInterface the model newly created
* @throws ServerErrorHttpException if there is any error when creating the model
*/
public function run()
{
if ($this->checkAccess) {
call_user_func($this->checkAccess, $this->id);
}
// 当前用户的身份实例，未认证用户则为 Null
$identity = Yii::$app->user->identity;
/* @var $model \yii\db\ActiveRecord */
/*
$model = new $this->modelClass([
'scenario' => 'create',
]);
*/
$requestParams = Yii::$app->getRequest()->getBodyParams();
$count = count($requestParams);
//创建一个初始的 $models 数组包含一个默认的模型
$scenario = 'create';
$models = [new $this->modelClass([
'scenario' => $scenario,
])];
for($i = 1; $i < $count; $i++) {
$models[] = new $this->modelClass([
'scenario' => $scenario,
]);
}
// 批量填充模型属性
if (!Model::loadMultiple($models, $requestParams, '')) {
return ['code' => 20010, 'message' => Yii::t('error', '20010')];
}
foreach ($models as $key => $model) {
$model->group_id = $identity->group_id;
$model->config_column_id = $model->plan['config_column_id'];
$model->create_user_id = $identity->id;
$model->create_name = $identity->login_name;
$model->exec_name = $model->userByExecUserId['login_name'];
$model->task_data = serialize([]);
$model->ended_at = time() + Yii::$app->params['planTaskExpire'];
$models[$key] = $model;
}
// 批量验证模型
if (Model::validateMultiple($models)) {
foreach ($models as $model) {
$model->save(false);
}
$response = Yii::$app->getResponse();
$response->setStatusCode(201);
} else {
return ['code' => 20011, 'message' => Yii::t('error', '20011')];
}
return ['code' => 10000, 'message' => Yii::t('success', '10006'), 'data' => ['items' => $models]];
}
}
2. On Postman, the request parameters are shown in Figure 1
0[plan_id]:1
0[title]:早间新闻的标题1下的任务7
0[config_task_id]:2
0[exec_user_id]:8
0[place]:早间新闻的标题1下的地点7
0[task_info]:早间新闻的标题1下的内容7
1[plan_id]:1
1[title]:早间新闻的标题1下的任务8
1[config_task_id]:2
1[exec_user_id]:8
1[place]:早间新闻的标题1下的地点8
1[task_info]:早间新闻的标题1下的地点8
Figure 1
3. At the request of the front-end, add the form name, \api\rests\plan_task\createaction.php, the code is as follows
* @since 1.0
*/
class CreateAction extends Action
{
/**
* @var string the scenario to be assigned to the new model before it is validated and saved.
*/
public $scenario = Model::SCENARIO_DEFAULT;
/**
* Creates a new model.
* @return \yii\db\ActiveRecordInterface the model newly created
* @throws ServerErrorHttpException if there is any error when creating the model
*/
public function run()
{
if ($this->checkAccess) {
call_user_func($this->checkAccess, $this->id);
}
// 当前用户的身份实例，未认证用户则为 Null
$identity = Yii::$app->user->identity;
/* @var $model \yii\db\ActiveRecord */
/*
$model = new $this->modelClass([
'scenario' => 'create',
]);
*/
$requestParams = Yii::$app->getRequest()->getBodyParams();
$formName = 'plan_task';
$count = count($requestParams[$formName]);
//创建一个初始的 $models 数组包含一个默认的模型
$scenario = 'create';
$models = [new $this->modelClass([
'scenario' => $scenario,
])];
for($i = 1; $i < $count; $i++) {
$models[] = new $this->modelClass([
'scenario' => $scenario,
]);
}
// 批量填充模型属性
if (!Model::loadMultiple($models, $requestParams, $formName)) {
return ['code' => 20010, 'message' => Yii::t('error', '20010')];
}
foreach ($models as $key => $model) {
$model->group_id = $identity->group_id;
$model->config_column_id = $model->planById['config_column_id'];
$model->create_user_id = $identity->id;
$model->create_name = $identity->login_name;
$model->exec_name = $model->userByExecUserId['login_name'];
$model->task_data = serialize([]);
$model->ended_at = time() + Yii::$app->params['planTaskExpire'];
$models[$key] = $model;
}
// 批量验证模型
if (Model::validateMultiple($models)) {
$modelResult = $model->createMultiple($models);
if (!$modelResult) {
return ['code' => 20015, 'message' => Yii::t('error', '20015')];
}
$response = Yii::$app->getResponse();
$response->setStatusCode(201);
} else {
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 ['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.');
}
foreach ($models as $key => $model) {
$model->task_data = unserialize($model->task_data);
$models[$key] = $model;
}
return ['code' => 10000, 'message' => Yii::t('success', '10006'), 'data' => ['items' => $models]];
}
}
4. \common\logics\plantask.php, the code is as follows
/**
* 批量指派(创建任务)
*
* @param $models
*
* @return bool the saved model or false if saving fails
* @throws \Throwable
*/
public function createMultiple($models)
{
$transaction = Yii::$app->db->beginTransaction();
$time = time();
try {
foreach ($models as $model) {
if (!$model->save(false)) {
throw new ServerErrorHttpException(Yii::t('error', '20015'), 20015);
}
/* 创建MySQL模型(选题任务步骤) */
$table = PlanTaskStep::tableName();
$columns = [ 'group_id', 'task_id', 'task_title', 'step_code', 'step_name', 'sort_order', 'updated_name', 'created_at', 'updated_at' ];
/* 将模型记录转换为索引数组 */
foreach ($model->configTaskSteps as $configTaskStep) {
if ($configTaskStep->status == ConfigTaskStep::CONFIG_TASK_STEP_STATUS_ENABLE && $configTaskStep->is_default == 1) {
$rows[] = [
$model->group_id,
$model->id,
$model->title,
$configTaskStep->step_code,
$configTaskStep->step_name,
$configTaskStep->sort_order,
$model->create_name,
$time,
$time,
];
}
}
}
Yii::$app->db->createCommand()->batchInsert($table, $columns, $rows)->execute();
$transaction->commit();
return true;
} catch (\Throwable $e) {
$transaction->rollBack();
throw $e;
}
}
5. On Postman, the request parameters are shown in Figure 2
plan_task[0][plan_id]:2
plan_task[0][title]:选题2的任务6的标题
plan_task[0][config_task_id]:2
plan_task[0][exec_user_id]:187
plan_task[0][place]:选题2的任务6的地点
plan_task[0][task_info]:选题2的任务6的内容
plan_task[1][plan_id]:2
plan_task[1][title]:选题2的任务7的标题
plan_task[1][config_task_id]:2
plan_task[1][exec_user_id]:191
plan_task[1][place]:选题2的任务7的地点
plan_task[1][task_info]:选题2的任务7的内容
Figure 2
6. On Postman, the response parameters are shown in Figure 3
{
"code": 10000,
"message": "指派(创建任务)成功",
"data": {
"items": [
{
"plan_id": "2",
"title": "选题2的任务6的标题",
"config_task_id": "2",
"exec_user_id": "187",
"place": "选题2的任务6的地点",
"task_info": "选题2的任务6的内容",
"group_id": "015ce30b116ce86058fa6ab4fea4ac63",
"config_column_id": 1,
"create_user_id": 8,
"create_name": "13281105967",
"exec_name": "test3",
"task_data": "a:0:{}",
"ended_at": 1529047691,
"created_at": 1526455691,
"updated_at": 1526455691,
"id": 37
},
{
"plan_id": "2",
"title": "选题2的任务7的标题",
"config_task_id": "2",
"exec_user_id": "191",
"place": "选题2的任务7的地点",
"task_info": "选题2的任务7的内容",
"group_id": "015ce30b116ce86058fa6ab4fea4ac63",
"config_column_id": 1,
"create_user_id": 8,
"create_name": "13281105967",
"exec_name": "test4",
"task_data": "a:0:{}",
"ended_at": 1529047691,
"created_at": 1526455692,
"updated_at": 1526455692,
"id": 38
}
]
}
}
Figure 3
