QueueController.php 1.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283
  1. <?php
  2. namespace backend\controllers;
  3. use backend\forms\QueueForm;
  4. use components\Exception;
  5. use Yii;
  6. class QueueController extends BaseController
  7. {
  8. /**
  9. * [创建队列]
  10. * @author: libingke
  11. * @return array
  12. * @throws Exception
  13. */
  14. public function actionCreate()
  15. {
  16. if (!Yii::$app->request->isPost)
  17. throw new Exception('1001');
  18. $model = new QueueForm();
  19. $model->setScenario('create_queue');
  20. $model->load(['QueueForm' => Yii::$app->request->post()]);
  21. $data = [];
  22. if ($model->validate()) {
  23. $data = $model->createQueue();
  24. } else {
  25. $model->handleError();//处理验证失败
  26. }
  27. return [
  28. 'code' => 200,
  29. 'message' => Yii::t('error', 200),
  30. 'data' => $data
  31. ];
  32. }
  33. /**
  34. * 删除队列
  35. * @author: libingke
  36. * @return array
  37. * @throws Exception
  38. */
  39. public function actionDelete()
  40. {
  41. if (!Yii::$app->request->isPost)
  42. throw new Exception('1001');
  43. $model = new QueueForm();
  44. $model->setScenario('delete_queue');
  45. $model->load(['QueueForm' => Yii::$app->request->post()]);
  46. $data = [];
  47. if ($model->validate()) {
  48. $data = $model->deleteQueue();
  49. } else {
  50. $model->handleError();
  51. }
  52. return [
  53. 'code' => 200,
  54. 'message' => Yii::t('error', 200),
  55. 'data' => $data
  56. ];
  57. }
  58. /**
  59. * 获取队列列表
  60. * @author: libingke
  61. */
  62. public function actionList()
  63. {
  64. $model = new QueueForm();
  65. $data = $model->getQueueList();
  66. return [
  67. 'code' => 200,
  68. 'message' => Yii::t('error', 200),
  69. 'data' => $data
  70. ];
  71. }
  72. }