where('Status', 'pending') ->whereNull('DelDate') ->orderBy('CreateDate', 'ASC') ->findAll($limit); } /** * Mark as processed */ public function markProcessed($id) { return $this->update($id, [ 'Status' => 'processed', 'ProcessedAt' => date('Y-m-d H:i:s') ]); } /** * Mark as error */ public function markError($id, $errorMessage) { return $this->update($id, [ 'Status' => 'error', 'ErrorMessage' => $errorMessage, 'ProcessedAt' => date('Y-m-d H:i:s') ]); } }