| | |
|---|
| | | |
|---|
| | | 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, |
|---|
| | |
|---|
| | | $s = $stats[0] ?? null; |
|---|
| | | if (!$s) continue; |
|---|
| | | |
|---|
| | | $this->stats->table->query(" |
|---|
| | | $this->stats->queryResults(" |
|---|
| | | INSERT INTO {table} (date, type, total_operations, successful_operations, failed_permanent_operations, total_items_processed) |
|---|
| | | VALUES (%s, %s, %d, %d, %d, %d) |
|---|
| | | ON DUPLICATE KEY UPDATE |
|---|
