Proyectos de Subversion LeadersLinked - Services

        // 🔹 Validar que $aiCompetencies sea un array no vacío y de objetos/datos

        if (empty($aiCompetencies) || !is_array($aiCompetencies) || count($aiCompetencies) === 0) {

            return [

                'success' => false,

                'message' => 'No se proporcionaron competencias para procesar.',

                'data' => []

            ];

        }

        $adapter = $this->adapter;

        $sql = new Sql($adapter);

        $results = [];

        foreach ($aiCompetencies as $comp) {

            // 🔹 Validar que cada elemento sea un array

            if (!is_array($comp)) {

                continue; // Ignoramos elementos inválidos

            }

            // 🔹 Preparar datos

            $name = trim($comp['name'] ?? '');

            $description = trim($comp['description'] ?? '');

            $hasIdRaw = str_replace("'", '"', $comp['has_id'] ?? '{"bool": false, "nro": 0}');

            $hasIdData = json_decode($hasIdRaw, true);

            if (!$name || !$description || !is_array($hasIdData)) {

                continue; // Datos incompletos o corruptos, ignoramos

            }

            $competencyId = null;

            $status = '';

            // 🔹 Crear nueva competencia si nro == 0

            if ((int) ($hasIdData['nro'] ?? 0) === 0) {

                $uuid = $this->generateUuid();

                $insert = $sql->insert(CompetencyMapper::_TABLE)

                    ->values([

                        'uuid' => $uuid,

                        'name' => $name,

                        'description' => $description,

                        'competency_type_id' => $competencyTypeId,

                        'status' => CompetencyMapper::STATUS_ACTIVE,

                        'added_on' => date('Y-m-d H:i:s'),

                        'updated_on' => date('Y-m-d H:i:s')

                    ]);

                $stmt = $sql->prepareStatementForSqlObject($insert)->execute();

                if ($stmt->getAffectedRows() === 0) {

                    return [

                        'success' => false,

                        'message' => "Error al insertar la competencia '{$name}'",

                        'data' => []

                    ];

                }

                $competencyId = $adapter->getDriver()->getLastGeneratedValue();

                $status = 'created';

            }

            // 🔹 Actualizar competencia existente si nro > 0

            else {

                $competencyId = (int) $hasIdData['nro'];

                $select = $sql->select(CompetencyMapper::_TABLE)

                    ->where(['id' => $competencyId]);

                $existing = $sql->prepareStatementForSqlObject($select)->execute()->current();

                if (!$existing) {

                    return [

                        'success' => false,

                        'message' => "ID de competencia {$competencyId} no encontrado",

                        'data' => []

                    ];

                }

                // Solo actualizar si cambia el nombre o la descripción

                if ($existing['name'] !== $name || $existing['description'] !== $description) {

                    $update = $sql->update(CompetencyMapper::_TABLE)

                        ->set([

                            'name' => $name,

                            'description' => $description,

                            'updated_on' => date('Y-m-d H:i:s')

                        ])

                        ->where(['id' => $competencyId]);

                    $stmt = $sql->prepareStatementForSqlObject($update)->execute();

                    if ($stmt->getAffectedRows() === 0) {

                        return [

                            'success' => false,

                            'message' => "Error al actualizar la competencia '{$name}' (ID {$competencyId})",

                            'data' => []

                        ];

                    }

                }

                $status = 'updated';

            }

            // 🔹 Vincular competencia con job description

            $linkCheck = $sql->select(JobDescriptionCompetencyMapper::_TABLE)

                ->where([

                    'job_description_id' => $jobDescriptionId,

                    'competency_id' => $competencyId

                ]);

            $existsLink = $sql->prepareStatementForSqlObject($linkCheck)->execute()->current();

            if (!$existsLink) {

                $linkInsert = $sql->insert(JobDescriptionCompetencyMapper::_TABLE)

                    ->values([

                        'job_description_id' => $jobDescriptionId,

                        'competency_id' => $competencyId

                    ]);

                $stmt = $sql->prepareStatementForSqlObject($linkInsert)->execute();

                if ($stmt->getAffectedRows() === 0) {

                    return [

                        'success' => false,

                        'message' => "Error al vincular competencia '{$name}' con la descripción {$jobDescriptionId}",

                        'data' => []

                    ];

                }

            }

            // 🔹 Guardar resultado exitoso

            $results[] = [

                'name' => $name,

                'competency_id' => $competencyId,

                'status' => $status

            ];

        }

        return [

            'success' => true,

            'message' => 'Procesamiento completado exitosamente.',

            'data' => $results