MpGeneratePicTask.php 2.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283
  1. <?php
  2. namespace App\Models;
  3. use Illuminate\Database\Eloquent\Factories\HasFactory;
  4. use Illuminate\Database\Eloquent\Model;
  5. class MpGeneratePicTask extends Model
  6. {
  7. use HasFactory;
  8. protected $fillable = [
  9. 'task_id',
  10. 'prompt',
  11. 'width',
  12. 'height',
  13. 'image_num',
  14. 'scale',
  15. 'ref_img_url',
  16. 'mask_img_url',
  17. 'extra_params',
  18. 'status',
  19. 'result_url',
  20. 'error_message',
  21. 'started_at',
  22. 'completed_at',
  23. 'created_at',
  24. 'updated_at',
  25. 'result_json'
  26. ];
  27. protected $casts = [
  28. 'result_url' => 'array',
  29. 'ref_img_url' => 'array',
  30. 'mask_img_url' => 'array',
  31. 'extra_params' => 'array',
  32. 'result_json' => 'array',
  33. 'started_at' => 'datetime',
  34. 'completed_at' => 'datetime',
  35. ];
  36. const STATUS_PENDING = 'pending';
  37. const STATUS_PROCESSING = 'processing';
  38. const STATUS_SUCCESS = 'success';
  39. const STATUS_FAILED = 'failed';
  40. /**
  41. * 更新任务状态
  42. *
  43. * @param string $status
  44. * @param array $data
  45. * @return bool
  46. */
  47. public function updateStatus(string $status, array $data = [])
  48. {
  49. $updateData = ['status' => $status];
  50. if (!$this->created_at) {
  51. $updateData['created_at'] = now();
  52. }
  53. $updateData['updated_at'] = now();
  54. if (isset($data['extra_params'])) $updateData['extra_params'] = $data['extra_params'];
  55. if ($status === self::STATUS_PROCESSING) {
  56. if (isset($data['task_id'])) $updateData['task_id'] = $data['task_id'];
  57. if (!$this->started_at) $updateData['started_at'] = now();
  58. }
  59. if (in_array($status, [self::STATUS_SUCCESS, self::STATUS_FAILED])) {
  60. $updateData['completed_at'] = now();
  61. if (isset($data['result_url'])) {
  62. $updateData['result_url'] = $data['result_url'];
  63. }
  64. if (isset($data['error_message'])) {
  65. $updateData['error_message'] = $data['error_message'];
  66. }
  67. }
  68. return $this->update($updateData);
  69. }
  70. }