| | |
|---|
| | | |
|---|
| | | public function insert(Operation $op): bool |
|---|
| | | { |
|---|
| | | $result = $this->table->insert([ |
|---|
| | | 'id' => $op->id, |
|---|
| | | 'type' => $op->type, |
|---|
| | | 'user_id' => $op->userId, |
|---|
| | | $existing = $this->find($op->id); |
|---|
| | | if ($existing && in_array($existing->state, ['completed', 'processing'] )) { |
|---|
| | | $op->id = Queue::generateId($op->userId); |
|---|
| | | } |
|---|
| | | $result = $this->table->findOrCreate([ |
|---|
| | | 'id' => $op->id, |
|---|
| | | 'type' => $op->type, |
|---|
| | | 'user_id' => $op->userId, |
|---|
| | | ],[ |
|---|
| | | 'request_data' => json_encode($op->requestData), |
|---|
| | | 'total_items' => $op->totalItems, |
|---|
| | | 'processed_items' => $op->processedItems, |
|---|
