MpGeneratePicTask.php 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081
  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. ];
  26. protected $casts = [
  27. 'result_url' => 'array',
  28. 'ref_img_url' => 'array',
  29. 'mask_img_url' => 'array',
  30. 'extra_params' => 'array',
  31. 'started_at' => 'datetime',
  32. 'completed_at' => 'datetime',
  33. ];
  34. const STATUS_PENDING = 'pending';
  35. const STATUS_PROCESSING = 'processing';
  36. const STATUS_SUCCESS = 'success';
  37. const STATUS_FAILED = 'failed';
  38. /**
  39. * 更新任务状态
  40. *
  41. * @param string $status
  42. * @param array $data
  43. * @return bool
  44. */
  45. public function updateStatus(string $status, array $data = [])
  46. {
  47. $updateData = ['status' => $status];
  48. if (!$this->created_at) {
  49. $updateData['created_at'] = now();
  50. }
  51. $updateData['updated_at'] = now();
  52. if (isset($data['extra_params'])) $updateData['extra_params'] = $data['extra_params'];
  53. if ($status === self::STATUS_PROCESSING) {
  54. if (isset($data['task_id'])) $updateData['task_id'] = $data['task_id'];
  55. if (!$this->started_at) $updateData['started_at'] = now();
  56. }
  57. if (in_array($status, [self::STATUS_SUCCESS, self::STATUS_FAILED])) {
  58. $updateData['completed_at'] = now();
  59. if (isset($data['result_url'])) {
  60. $updateData['result_url'] = $data['result_url'];
  61. }
  62. if (isset($data['error_message'])) {
  63. $updateData['error_message'] = $data['error_message'];
  64. }
  65. }
  66. return $this->update($updateData);
  67. }
  68. }