Eu tenho um campo id dentro um arquivo csv que é lido como um array. Esse campo id vem com dois id em um campo pois os id possui um campo de resposta idêntico chamado "resposta". Em vez de repetir esse campo idêntico como (exemplo: ID:2334 REPOSTA: EU SOU LEGAL ID 2187: REPOSTA: EU SOU LEGAL.) a pessoa que fez o csv juntoU os id que possui a mesma resposta idêntico.(EXEMPLO:ID:2334,2187 RESPOSTA: EU SOU LEGAL) Como consigo duplicar esse campo idêntico pelo id quando ler o arquivo csv COMO O EXEMPLO ANOTADO EM CIMA (exemplo: ID:2334 REPOSTA: EU SOU LEGAL ID 2187: REPOSTA: EU SOU LEGAL.)EM PHP???
<?php
ini_set('memory_limit', '-1');
include 'utils.php';
// Filename contem o nome do CSV passado por parêmetro na linha de comando
$filename = (count($argv) > 3) ? $argv[3] : '';
// Lê o arquivo e o converte para um array com a lista de dados
$csv = parseCsv($filename);
// Extrai metadados do nome do
$path_parts = pathinfo($filename);
/**
* Dicionário de colunas.
* Cada item desse array deve conter a chave igual a coluna do cabeçalho do CSV
* e no valor o nome da coluna no banco de dados.
*/
$dicionario_colunas = [
'ID SKU' => 'ID',
'Categorias de TR relacionadas' => 'CTG_TR_RELACIONADAS',
'Nº da pergunta' => 'N_PERGUNTAS',
'Pergunta' => 'PERGUNTA',
'Tip (i)' => 'TIP',
'Opções' => 'OPÇÕES',
'Se SIM' => 'SIM',
'Se NÃO' => 'NÃO',
];
$csv = normalizeCsvArrayKeys($csv, $dicionario_colunas);
if (empty($csv)) {//verificando se o seu file.csv está vazio
die("Arquivo csv vazio\n");
}
$perguntas = [];
$duplicate = [];
foreach ($csv as $linha) {
$perguntaId = trim($linha['ID']);
if (!array_key_exists($perguntaId, $perguntas)) {
$perguntas[$perguntaId] = [
'ID' => $perguntaId,
'CTG_TR_RELACIONADAS' => trim($linha['CTG_TR_RELACIONADAS']),
'N_PERGUNTAS' => trim($linha['N_PERGUNTAS']),
'PERGUNTA' => trim($linha['PERGUNTA']),
'TIP' => trim($linha['TIP']),
'OPÇÕES' => trim($linha['OPÇÕES']),
'SIM' => trim($linha['SIM']),
'NÃO' => trim($linha['NÃO']),
];
}
}
$migrationID = date('YmdHis');
$migrationRef = 'exames';
$migrationName = $path_parts['filename'];
$outputName = $migrationID . '_' . $migrationRef . '_' . $migrationName . '.sql';
$output = fopen(ROOT . '/db_crx/migrations/' . $outputName, "w"); # not readedlines
try {
echo "\nProcessando os dados\n";
echo "Iniciando output.\n";
fwrite($output, "SET search_path = \"rx_ref\";\n");
fwrite($output, 'BEGIN;' . "\n\n");
fwrite($output, "UPDATE tr_equipamento_perguntas SET obsoleto = NOW();\n");
fwrite($output, "UPDATE tr_equipamentos SET obsoleto = NOW();\n");
if (!empty($perguntas)) {
fwrite($output, "\n" . "-- insert / update tr_fabricantes\n");
foreach ($perguntas as $perg) {
$stmt = "INSERT INTO tr_equipamento_perguntas (tr_equipamento_id, ordem_pergunta, pergunta, dica_1,resposta_sim,resposta_nao) VALUES (" .
"'{$perg['ID']}', '{$perg['N_PERGUNTAS']}', '{$perg['PERGUNTA']}', '{$perg['TIP']}','{$perg['SIM']}', '{$perg['NÃO']}')\n" .
"ON CONFLICT (id) DO UPDATE SET NúmeroPergunta = '{$perg['N_PERGUNTAS']}', Pergunta = '{$perg['PERGUNTA']}', Dica = '{$perg['TIP']}',
RespostaSim = '{$perg['SIM']}', RespostaNão = '{$perg['NÃO']}'," .
"obsoleto = null;\n";
fwrite($output, $stmt);
}
}
fwrite($output, "DELETE FROM tr_equipamento_perguntas WHERE obsoleto IS NOT NULL;\n");
fwrite($output, "\n" .
"INSERT INTO public.crx_migrations (id, reference, description, filename) VALUES ('$migrationID', '$migrationRef', '$migrationName', '$outputName');\n");
fwrite($output, "\nCOMMIT;\n");
echo "Output pronto.\nVerifique o arquivo $outputName na pasta de migrações\n";
}
catch (Exception $e) {
echo "\n" . "Ocorreu uma exceção durante a geração do script:\n";
echo $e->getMessage() . "\n";
echo $e->getTraceAsString() . "\n";
if (file_exists($output)) {
unlink($output);
}
}