97 lines
3.7 KiB
PHP
97 lines
3.7 KiB
PHP
<?php
|
|
require_once 'db/config.php';
|
|
require_once 'lib/ErrorHandler.php';
|
|
|
|
register_error_handler();
|
|
|
|
session_start();
|
|
|
|
function validate_definition_json($json) {
|
|
if (empty($json)) {
|
|
return; // No validation for empty json
|
|
}
|
|
$data = json_decode($json, true);
|
|
if (json_last_error() !== JSON_ERROR_NONE) {
|
|
http_response_code(422);
|
|
throw new WorkflowRuleFailedException('Invalid JSON format in definition.');
|
|
}
|
|
|
|
$allowed_statuses = ['none', 'negative', 'in_progress', 'positive', 'active', 'processing', 'paused', 'completed', 'terminated'];
|
|
|
|
if (isset($data['nodes'])) {
|
|
foreach ($data['nodes'] as $node) {
|
|
if (isset($node['ui_hints']['status']) && !in_array($node['ui_hints']['status'], $allowed_statuses)) {
|
|
http_response_code(422);
|
|
throw new WorkflowRuleFailedException('Invalid status in ui_hints. Allowed values are: ' . implode(', ', $allowed_statuses));
|
|
}
|
|
}
|
|
}
|
|
|
|
if (isset($data['transitions'])) {
|
|
foreach ($data['transitions'] as $transition) {
|
|
if (isset($transition['actions'])) {
|
|
foreach ($transition['actions'] as $action) {
|
|
if ($action['type'] === 'start_process' && isset($action['process_name'])) {
|
|
http_response_code(422);
|
|
throw new WorkflowRuleFailedException('Use process_code instead of process_name in transition actions.');
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
if (isset($data['eligibility_rules'])) {
|
|
foreach ($data['eligibility_rules'] as $rule) {
|
|
if ($rule['type'] === 'process_completed' && isset($rule['process_name'])) {
|
|
http_response_code(422);
|
|
throw new WorkflowRuleFailedException('Use process_code instead of process_name in eligibility_rules.');
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
try {
|
|
if ($_SERVER['REQUEST_METHOD'] === 'POST') {
|
|
$processId = $_POST['process_id'] ?? null;
|
|
$name = $_POST['name'] ?? '';
|
|
$definition_json = $_POST['definition_json'] ?? '';
|
|
|
|
validate_definition_json($definition_json);
|
|
|
|
// Generate a simple code from the name
|
|
$code = strtolower(trim(preg_replace('/[^A-Za-z0-9-]+/', '-', $name)));
|
|
|
|
if (empty($name)) {
|
|
throw new WorkflowRuleFailedException('Process name is required.');
|
|
}
|
|
|
|
$pdo = db();
|
|
|
|
if (empty($processId)) {
|
|
// Create new process
|
|
$sql = 'INSERT INTO process_definitions (name, code, definition_json, is_active) VALUES (?, ?, ?, 1)';
|
|
$params = [$name, $code, $definition_json];
|
|
$message = 'Process created successfully.';
|
|
} else {
|
|
// Update existing process
|
|
$is_active = isset($_POST['is_active']) ? (int)$_POST['is_active'] : 0;
|
|
$sql = 'UPDATE process_definitions SET name = ?, definition_json = ?, is_active = ? WHERE id = ?';
|
|
$params = [$name, $definition_json, $is_active, $processId];
|
|
$message = 'Process updated successfully.';
|
|
}
|
|
|
|
$stmt = $pdo->prepare($sql);
|
|
$stmt->execute($params);
|
|
if (isset($_SERVER['HTTP_ACCEPT']) && strpos($_SERVER['HTTP_ACCEPT'], 'application/json') !== false) {
|
|
header('Content-Type: application/json');
|
|
echo json_encode(['message' => $message]);
|
|
} else {
|
|
$_SESSION['success_message'] = $message;
|
|
header('Location: process_definitions.php');
|
|
exit();
|
|
}
|
|
}
|
|
} catch (WorkflowRuleFailedException $e) {
|
|
header('Content-Type: application/json');
|
|
echo json_encode(['error' => $e->getMessage()]);
|
|
} |