← All changes | back/Classes/ScenarioStepClass.php +156 -0 11.1.1 → 11.1.0 View file →

		@@ -1,0 +1,156 @@
	1	+<?php
	2	+
	3	+namespace AcyMailing\Classes;
	4	+
	5	+use AcyMailing\Core\AcymClass;
	6	+
	7	+class ScenarioStepClass extends AcymClass
	8	+{
	9	+ public function __construct()
	10	+ {
	11	+ parent::__construct();
	12	+
	13	+ $this->table = 'scenario_step';
	14	+ $this->pkey = 'id';
	15	+ }
	16	+
	17	+ public function save(object $element): ?int
	18	+ {
	19	+ if (!empty($element->params) && !is_string($element->params)) {
	20	+ $element->params = json_encode($element->params);
	21	+ }
	22	+
	23	+ // The id is a string
	24	+ $scenarioStep = acym_loadObject('SELECT * FROM #__acym_scenario_step WHERE `id` = '.acym_escapeDB($element->id));
	25	+
	26	+ $previousForce = $this->forceInsert;
	27	+ $this->forceInsert = empty($scenarioStep);
	28	+ $id = parent::save($element);
	29	+ $this->forceInsert = $previousForce;
	30	+
	31	+ return (int)$id;
	32	+ }
	33	+
	34	+ public function getAllByScenarioId(int $scenarioId): array
	35	+ {
	36	+ $steps = array_map([$this, 'formatStep'], acym_loadObjectList('SELECT * FROM #__acym_scenario_step WHERE scenario_id = '.$scenarioId, 'id'));
	37	+
	38	+ usort($steps, function ($a, $b) {
	39	+ if ($a->previous_id === $b->id) {
	40	+ return 1;
	41	+ }
	42	+
	43	+ if ($b->previous_id === $a->id) {
	44	+ return -1;
	45	+ }
	46	+
	47	+ return 0;
	48	+ });
	49	+
	50	+
	51	+ return $steps;
	52	+ }
	53	+
	54	+ public function getFirstStepByScenarioId(int $scenarioId): ?object
	55	+ {
	56	+ $step = acym_loadObject('SELECT * FROM #__acym_scenario_step WHERE previous_id IS NULL AND scenario_id = '.$scenarioId);
	57	+ if (empty($step)) {
	58	+ return null;
	59	+ }
	60	+
	61	+ return $this->formatStep($step);
	62	+ }
	63	+
	64	+ public function getStepByPreviousStepId(string $parentId): ?object
	65	+ {
	66	+ $step = acym_loadObject('SELECT * FROM #__acym_scenario_step WHERE previous_id = '.acym_escapeDB($parentId));
	67	+ if (empty($step)) {
	68	+ return null;
	69	+ }
	70	+
	71	+ return $this->formatStep($step);
	72	+ }
	73	+
	74	+ public function getAllStepsToDelete(int $scenarioId, array $stepIdsToKeep): array
	75	+ {
	76	+ $stepIdsToKeepEscaped = [];
	77	+ foreach ($stepIdsToKeep as $stepIdToKeep) {
	78	+ $stepIdsToKeepEscaped[] = acym_escapeDB($stepIdToKeep);
	79	+ }
	80	+
	81	+ $query = 'SELECT id FROM #__acym_scenario_step WHERE scenario_id = '.$scenarioId;
	82	+
	83	+ if (!empty($stepIdsToKeepEscaped)) {
	84	+ $query .= ' AND id NOT IN ('.implode(',', $stepIdsToKeepEscaped).')';
	85	+ }
	86	+
	87	+ return acym_loadResultArray($query);
	88	+ }
	89	+
	90	+ public function getStepByPreviousConditionId(string $parentId, bool $conditionValid): ?object
	91	+ {
	92	+ $conditionValidValue = $conditionValid ? 1 : 0;
	93	+
	94	+ $step = acym_loadObject('SELECT * FROM #__acym_scenario_step WHERE condition_valid = '.$conditionValidValue.' AND previous_id = '.acym_escapeDB($parentId));
	95	+ if (empty($step)) {
	96	+ return null;
	97	+ }
	98	+
	99	+ return $this->formatStep($step);
	100	+ }
	101	+
	102	+ public function getAvailableStepsByDate(string $date): array
	103	+ {
	104	+ $query = 'SELECT scenario_step.*, scenario_process.user_id, scenario_process.id AS scenario_process_id
	105	+ FROM #__acym_scenario_step AS scenario_step
	106	+ JOIN #__acym_scenario_queue AS scenario_queue ON scenario_step.id = scenario_queue.step_id AND scenario_queue.execution_date <= '.acym_escapeDB($date).'
	107	+ JOIN #__acym_scenario_process AS scenario_process ON scenario_queue.scenario_process_id = scenario_process.id';
	108	+
	109	+ return array_map([$this, 'formatStep'], acym_loadObjectList($query));
	110	+ }
	111	+
	112	+ public function getNumberOfProcessByStepByScenarioId(int $scenarioId): array
	113	+ {
	114	+ $query = 'SELECT scenario_history.scenario_step_id , COUNT(scenario_history.id) AS count
	115	+ FROM #__acym_scenario_step AS scenario_step
	116	+ JOIN #__acym_scenario_history_line AS scenario_history ON scenario_step.id = scenario_history.scenario_step_id AND scenario_history.scenario_step_id IS NOT NULL
	117	+ WHERE scenario_step.scenario_id = '.$scenarioId.'
	118	+ GROUP BY scenario_step_id';
	119	+
	120	+ return acym_loadObjectList($query, 'scenario_step_id');
	121	+ }
	122	+
	123	+ public function getAllStepIds(): array
	124	+ {
	125	+ return acym_loadResultArray('SELECT id FROM #__acym_scenario_step');
	126	+ }
	127	+
	128	+ public function generateNewStepId(array $allStepIds = []): string
	129	+ {
	130	+ if (empty($allStepIds)) {
	131	+ $allStepIds = $this->getAllStepIds();
	132	+ }
	133	+
	134	+ $letters = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz';
	135	+ $randomString = '';
	136	+ $length = 24;
	137	+
	138	+ for ($i = 0; $i < $length; $i++) {
	139	+ $randomIndex = acym_rand(0, strlen($letters) - 1);
	140	+ $randomString .= $letters[$randomIndex];
	141	+ }
	142	+
	143	+ if (in_array($randomString, $allStepIds)) {
	144	+ return $this->generateNewStepId($allStepIds);
	145	+ }
	146	+
	147	+ return $randomString;
	148	+ }
	149	+
	150	+ private function formatStep(object $step): object
	151	+ {
	152	+ $step->params = json_decode($step->params, true);
	153	+
	154	+ return $step;
	155	+ }
	156	+}