CleanupTaskController.php 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289
  1. <?php
  2. namespace App\Module\Cleanup\AdminControllers;
  3. use App\Module\Cleanup\Models\CleanupTask;
  4. use App\Module\Cleanup\Repositories\CleanupTaskRepository;
  5. use App\Module\Cleanup\Enums\TASK_STATUS;
  6. use UCore\DcatAdmin\AdminController;
  7. use Dcat\Admin\Form;
  8. use Dcat\Admin\Grid;
  9. use Dcat\Admin\Show;
  10. use Dcat\Admin\Layout\Content;
  11. /**
  12. * 清理任务管理控制器
  13. *
  14. * @route /admin/cleanup/tasks
  15. */
  16. class CleanupTaskController extends AdminController
  17. {
  18. /**
  19. * 页面标题
  20. */
  21. protected $title = '清理任务管理';
  22. /**
  23. * 数据仓库
  24. */
  25. protected function repository()
  26. {
  27. return CleanupTaskRepository::class;
  28. }
  29. /**
  30. * 列表页面
  31. */
  32. protected function grid(): Grid
  33. {
  34. return Grid::make(new CleanupTaskRepository(), function (Grid $grid) {
  35. // 基础设置
  36. $grid->column('id', 'ID')->sortable();
  37. $grid->column('task_name', '任务名称')->sortable();
  38. // 关联计划
  39. $grid->column('plan.plan_name', '关联计划')->sortable();
  40. // 任务状态
  41. $grid->column('status', '任务状态')->using([
  42. 1 => '待执行',
  43. 2 => '备份中',
  44. 3 => '执行中',
  45. 4 => '已完成',
  46. 5 => '已失败',
  47. 6 => '已取消',
  48. 7 => '已暂停',
  49. ])->label([
  50. 1 => 'secondary',
  51. 2 => 'info',
  52. 3 => 'primary',
  53. 4 => 'success',
  54. 5 => 'danger',
  55. 6 => 'warning',
  56. 7 => 'dark',
  57. ])->sortable();
  58. // 进度信息
  59. $grid->column('progress', '执行进度')->display(function ($progress) {
  60. $color = 'secondary';
  61. if ($progress >= 100) $color = 'success';
  62. elseif ($progress >= 50) $color = 'primary';
  63. elseif ($progress > 0) $color = 'info';
  64. return "<div class='progress' style='height: 20px;'>
  65. <div class='progress-bar bg-{$color}' style='width: {$progress}%'>{$progress}%</div>
  66. </div>";
  67. });
  68. $grid->column('current_step', '当前步骤');
  69. // 统计信息
  70. $grid->column('processed_tables', '处理进度')->display(function () {
  71. return "{$this->processed_tables}/{$this->total_tables}";
  72. });
  73. $grid->column('deleted_records', '删除记录数')->display(function ($value) {
  74. return number_format($value);
  75. });
  76. // 执行时间
  77. $grid->column('execution_time', '执行时间(秒)')->display(function ($value) {
  78. return number_format($value, 3);
  79. });
  80. // 时间信息
  81. $grid->column('started_at', '开始时间')->sortable();
  82. $grid->column('completed_at', '完成时间')->sortable();
  83. $grid->column('created_at', '创建时间')->sortable();
  84. // 筛选器
  85. $grid->filter(function (Grid\Filter $filter) {
  86. $filter->equal('status', '任务状态')->select([
  87. 1 => '待执行',
  88. 2 => '备份中',
  89. 3 => '执行中',
  90. 4 => '已完成',
  91. 5 => '已失败',
  92. 6 => '已取消',
  93. 7 => '已暂停',
  94. ]);
  95. $filter->equal('plan_id', '关联计划')->select(
  96. \App\Module\Cleanup\Models\CleanupPlan::pluck('plan_name', 'id')->toArray()
  97. );
  98. $filter->like('task_name', '任务名称');
  99. $filter->between('created_at', '创建时间')->datetime();
  100. $filter->between('started_at', '开始时间')->datetime();
  101. $filter->between('completed_at', '完成时间')->datetime();
  102. });
  103. // 行操作
  104. $grid->actions(function (Grid\Displayers\Actions $actions) {
  105. $row = $actions->row;
  106. // 根据状态显示不同操作
  107. if ($row->status == 1) { // 待执行
  108. $actions->append(new \App\Module\Cleanup\AdminControllers\Actions\StartTaskAction());
  109. } elseif ($row->status == 3) { // 执行中
  110. $actions->append(new \App\Module\Cleanup\AdminControllers\Actions\PauseTaskAction());
  111. $actions->append(new \App\Module\Cleanup\AdminControllers\Actions\CancelTaskAction());
  112. } elseif ($row->status == 7) { // 已暂停
  113. $actions->append(new \App\Module\Cleanup\AdminControllers\Actions\ResumeTaskAction());
  114. $actions->append(new \App\Module\Cleanup\AdminControllers\Actions\CancelTaskAction());
  115. }
  116. $actions->append(new \App\Module\Cleanup\AdminControllers\Actions\ViewTaskLogsAction());
  117. if ($row->backup_id) {
  118. $actions->append(new \App\Module\Cleanup\AdminControllers\Actions\ViewBackupAction());
  119. }
  120. });
  121. // 批量操作
  122. $grid->batchActions([
  123. new \App\Module\Cleanup\AdminControllers\Actions\BatchCancelTaskAction(),
  124. ]);
  125. // 工具栏
  126. $grid->tools([
  127. new \App\Module\Cleanup\AdminControllers\Actions\CreateTaskAction(),
  128. ]);
  129. // 设置每页显示数量
  130. $grid->paginate(20);
  131. // 默认排序
  132. $grid->model()->orderBy('created_at', 'desc');
  133. });
  134. }
  135. /**
  136. * 详情页面
  137. */
  138. protected function detail($id): Show
  139. {
  140. return Show::make($id, new CleanupTaskRepository(), function (Show $show) {
  141. $show->field('id', 'ID');
  142. $show->field('task_name', '任务名称');
  143. $show->field('plan.plan_name', '关联计划');
  144. $show->field('status', '任务状态')->using([
  145. 1 => '待执行',
  146. 2 => '备份中',
  147. 3 => '执行中',
  148. 4 => '已完成',
  149. 5 => '已失败',
  150. 6 => '已取消',
  151. 7 => '已暂停',
  152. ]);
  153. $show->field('progress', '执行进度')->display(function ($progress) {
  154. return $progress . '%';
  155. });
  156. $show->field('current_step', '当前步骤');
  157. // 统计信息
  158. $show->field('total_tables', '总表数');
  159. $show->field('processed_tables', '已处理表数');
  160. $show->field('total_records', '总记录数')->display(function ($value) {
  161. return number_format($value);
  162. });
  163. $show->field('deleted_records', '已删除记录数')->display(function ($value) {
  164. return number_format($value);
  165. });
  166. // 性能信息
  167. $show->field('backup_size', '备份大小')->display(function ($value) {
  168. return \App\Module\Cleanup\Helpers\FormatHelper::formatBytes($value);
  169. });
  170. $show->field('execution_time', '执行时间')->display(function ($value) {
  171. return number_format($value, 3) . ' 秒';
  172. });
  173. $show->field('backup_time', '备份时间')->display(function ($value) {
  174. return number_format($value, 3) . ' 秒';
  175. });
  176. // 时间信息
  177. $show->field('started_at', '开始时间');
  178. $show->field('backup_completed_at', '备份完成时间');
  179. $show->field('completed_at', '完成时间');
  180. $show->field('error_message', '错误信息');
  181. $show->field('created_by', '创建者ID');
  182. $show->field('created_at', '创建时间');
  183. $show->field('updated_at', '更新时间');
  184. // 显示任务日志
  185. $show->relation('logs', '执行日志', function ($model) {
  186. $grid = new Grid(new \App\Module\Cleanup\Models\CleanupLog());
  187. $grid->model()->where('task_id', $model->id);
  188. $grid->column('table_name', '表名');
  189. $grid->column('cleanup_type', '清理类型')->using([
  190. 1 => '清空表',
  191. 2 => '删除所有',
  192. 3 => '按时间删除',
  193. 4 => '按用户删除',
  194. 5 => '按条件删除',
  195. ]);
  196. $grid->column('before_count', '清理前记录数')->display(function ($value) {
  197. return number_format($value);
  198. });
  199. $grid->column('after_count', '清理后记录数')->display(function ($value) {
  200. return number_format($value);
  201. });
  202. $grid->column('deleted_records', '删除记录数')->display(function ($value) {
  203. return number_format($value);
  204. });
  205. $grid->column('execution_time', '执行时间(秒)');
  206. $grid->column('created_at', '执行时间');
  207. $grid->disableActions();
  208. $grid->disableCreateButton();
  209. $grid->disableFilter();
  210. $grid->disablePagination();
  211. return $grid;
  212. });
  213. });
  214. }
  215. /**
  216. * 创建表单
  217. */
  218. protected function form(): Form
  219. {
  220. return Form::make(new CleanupTaskRepository(), function (Form $form) {
  221. $form->display('id', 'ID');
  222. $form->text('task_name', '任务名称')->required();
  223. $form->select('plan_id', '关联计划')
  224. ->options(\App\Module\Cleanup\Models\CleanupPlan::where('is_enabled', 1)->pluck('plan_name', 'id'))
  225. ->required();
  226. $form->hidden('status')->value(1); // 待执行
  227. $form->hidden('created_by')->value(admin_user_id());
  228. $form->display('created_at', '创建时间');
  229. $form->display('updated_at', '更新时间');
  230. // 禁用编辑(任务创建后不允许修改)
  231. $form->editing(function (Form $form) {
  232. $form->display('task_name', '任务名称');
  233. $form->display('plan.plan_name', '关联计划');
  234. $form->display('status', '任务状态')->using([
  235. 1 => '待执行',
  236. 2 => '备份中',
  237. 3 => '执行中',
  238. 4 => '已完成',
  239. 5 => '已失败',
  240. 6 => '已取消',
  241. 7 => '已暂停',
  242. ]);
  243. });
  244. });
  245. }
  246. }