MpGeneratePicTask.php 2.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788
  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. 'alias_segment_id',
  11. 'prompt',
  12. 'width',
  13. 'height',
  14. 'image_num',
  15. 'scale',
  16. 'ref_img_url',
  17. 'mask_img_url',
  18. 'extra_params',
  19. 'status',
  20. 'result_url',
  21. 'error_message',
  22. 'started_at',
  23. 'completed_at',
  24. 'created_at',
  25. 'updated_at',
  26. 'result_json',
  27. 'model',
  28. 'charge_info', // 新增: 计费关联数据
  29. ];
  30. protected $casts = [
  31. 'result_url' => 'array',
  32. 'ref_img_url' => 'array',
  33. 'mask_img_url' => 'array',
  34. 'extra_params' => 'array',
  35. 'result_json' => 'array',
  36. 'charge_info' => 'array',
  37. 'started_at' => 'datetime',
  38. 'completed_at' => 'datetime',
  39. ];
  40. const STATUS_PENDING = 'pending';
  41. const STATUS_PROCESSING = 'processing';
  42. const STATUS_SUCCESS = 'success';
  43. const STATUS_FAILED = 'failed';
  44. /**
  45. * 更新任务状态
  46. *
  47. * @param string $status
  48. * @param array $data
  49. * @return bool
  50. */
  51. public function updateStatus(string $status, array $data = [])
  52. {
  53. $updateData = ['status' => $status];
  54. if (!$this->created_at) {
  55. $updateData['created_at'] = now();
  56. }
  57. $updateData['updated_at'] = now();
  58. if (isset($data['extra_params'])) $updateData['extra_params'] = $data['extra_params'];
  59. if (isset($data['result_json'])) $updateData['result_json'] = $data['result_json'];
  60. if ($status === self::STATUS_PROCESSING) {
  61. if (isset($data['task_id'])) $updateData['task_id'] = $data['task_id'];
  62. if (!$this->started_at) $updateData['started_at'] = now();
  63. }
  64. if (in_array($status, [self::STATUS_SUCCESS, self::STATUS_FAILED])) {
  65. $updateData['completed_at'] = now();
  66. if (isset($data['result_url'])) {
  67. $updateData['result_url'] = $data['result_url'];
  68. }
  69. if (isset($data['error_message'])) {
  70. $updateData['error_message'] = $data['error_message'];
  71. }
  72. }
  73. return $this->update($updateData);
  74. }
  75. }