← All changes | includes/Core/Database/FormEntryLogModel.php +51 -0 3.2.0 → 3.3.1 View file →

		@@ -110,8 +110,59 @@
110	110	$now = current_time('mysql');
111	111	return $this->execute($sql, [$now, absint($minAgeMinutes), $now, absint($maxAgeHours), absint($limit)])->getResult();
112	112	}
113	113
	114	+ /**
	115	+ * Newest still-queued workflow row of an entry, for callers that hold the
	116	+ * entry id but not the queue log id (the payment endpoints).
	117	+ *
	118	+ * @return object|null row with id and response_obj
	119	+ */
	120	+ public function latestQueuedWorkflowByEntry($entryID)
	121	+ {
	122	+ $sql = "SELECT ld.id, ld.response_obj
	123	+ FROM `{$this->app_db->prefix}bitforms_form_log_details` ld
	124	+ JOIN `{$this->app_db->prefix}bitforms_form_entry_log` el ON el.id = ld.log_id
	125	+ WHERE el.form_entry_id = %d
	126	+ AND ld.integration_id = 0
	127	+ AND ld.response_type = 'queued'
	128	+ ORDER BY ld.id DESC
	129	+ LIMIT 1";
	130	+ $rows = $this->execute($sql, [absint($entryID)])->getResult();
	131	+
	132	+ return is_wp_error($rows) || empty($rows) ? null : $rows[0];
	133	+ }
	134	+
	135	+ /**
	136	+ * Patch a queued row's payload. The 'queued' condition keeps it off rows a
	137	+ * trigger or the reclaim cron has already claimed.
	138	+ *
	139	+ * @return mixed rows affected, or WP_Error
	140	+ */
	141	+ public function updateQueuedWorkflowResponse($queueLogId, array $responseObj)
	142	+ {
	143	+ return $this->update(
	144	+ ['response_obj' => wp_json_encode($responseObj)],
	145	+ ['id' => absint($queueLogId), 'response_type' => 'queued']
	146	+ );
	147	+ }
	148	+
	149	+ /**
	150	+ * Latest execution per integration of a form: last run time plus the
	151	+ * response_type of that newest log row. integration_id 0 (workflow queue) excluded.
	152	+ */
	153	+ public function getIntegrationLastRuns($formId)
	154	+ {
	155	+ $sql = "SELECT ld.integration_id,
	156	+ MAX(ld.created_at) AS lastRun,
	157	+ SUBSTRING_INDEX(GROUP_CONCAT(ld.response_type ORDER BY ld.created_at DESC, ld.id DESC), ',', 1) AS lastStatus
	158	+ FROM `{$this->app_db->prefix}bitforms_form_log_details` ld
	159	+ JOIN `{$this->app_db->prefix}bitforms_form_entry_log` el ON el.id = ld.log_id
	160	+ WHERE el.form_id = %d AND ld.integration_id > 0
	161	+ GROUP BY ld.integration_id";
	162	+ return $this->execute($sql, [absint($formId)])->getResult();
	163	+ }
	164	+
114	165	public function logUpdate($updateValue, $logID)
115	166	{
116	167	if (empty($logID)) {
117	168	return false;