Estoy intentando guardar los datos de un archivo CSV
que estoy descargando de la Web y estos mismos los quiero insertar a la bd, pero no me permite hacerlo, sé que debo agregarle un ciclo para que me vaya iterando los datos, pero no sé cómo colocarlo, agradecería mucho su ayuda.
Tengo 2 condiciones, una para la inserción inicial y otro para la actualización en caso de que ya tenga datos.
Según mi idea era colocar un ciclo for
, pero como les digo, no se como armarlo. No sé, estaría genial que me puedan apoyar con un ejemplo para darme una idea.
<?php
/* El siguiente código se encarga de realizar la descarga del archivo de descripcion
* de los contribuyentes con algún tipo de adeudo ante el SAT, a través de la libreria
* CURL de php.
*/
header('Content-type: application/json');
/* Hace el llamado a la conexion a la BD */
require "../../APIs/conexion.php";
/* URL desde dónde se hará la descarga del archivo en formato excel .csv */
$url = "http://omawww.sat.gob.mx/cifras_sat/Documents/Listado_Completo_69-B.csv";
/* Inicializa la función para obtener el archivo de la URL */
$ch = curl_init($url);
/* Devuelve el resultado de la transferencia como string */
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
/* Ejecuta la descarga del archivo desde la URL */
$output = curl_exec($ch);
/* Realiza el guardado del archivo con el nombre listasNegras.csv y se le da la propiedad de solo lectura con 'w' */
$fh = fopen('listasNegras.csv', 'w');
/* Verifica que el archivo se haya guardado correctamente en el mismo directorio donde se encuentra guardado descargaIncumplidos.php */
if(fwrite($fh, $output))
{
echo "Guardado con exito!"; //Si fue guardado correctamente, manda un mensaje en pantalla
}
else
{
echo "No guardado"; //De lo contrario, también manda un mensaje en pantalla
}
/* Cierra el archivo creado listasNegras.csv */
fclose($fh);
/* Comprueba la existencia del archivo descargado */
if(file_exists('listasNegras.csv'))
{
/* Mensaje en pantalla que indica que el archivo existe */
echo "\n Existe\n";
/* Bandera que demarca las filas del archivo */
$j = 0;
/* Abre el archivo con privilegios de lectura y escritura */
if(($fh = fopen('listasNegras.csv', 'r')) !== false)
{
/* Comprueba que la tabla no tenga nigun */
if(mysqli_num_rows(mysqli_query($conectar, "SELECT * FROM catContribuyentes")) < 1)
{
/* Mensaje de salida que indica el resultado de la comparacion anterior */
echo "NO hay!\n";
/* Mientras el archivo contenga datos, se mostrarán en pantalla los datos del archivo */
while(($file = fgetcsv($fh, 1000, ',')) !== false)
{
/* Se mostrarán todas las filas excepto las primeras 3, las cuales de acuerdo al documento, no necesitamos guardar en la base */
if($j > 2)
{
/* Imprime en pantalla los datos del archivo .CSV */
echo utf8_encode($file[0]."\t".$file[2]."\t".$file[17]."\n");
$num = count($file);
/* Sentencia que inserta los datos en la tabla de la base */
if(mysqli_query($conectar, "INSERT INTO catContribuyentes (noContri, rfcContri, nombreContri, situacionContri, numFecContri, publicacionContri, numFecContriP, pubDOFContri, pubDesvContri, numFecDesvContri, publicacionDOFDes, numFecDefi, punlicacionDefi, publicacionDOFDef, numFecSentFav, pubSentSATFav, numFecSentFavD, pubDOFSentFav) VALUES ('$file[0]', '$file[1]', '$file[2]', '$file[3]', '$file[4]', '$file[5]', '$file[6]', '$file[7]', '$file[8]', '$file[9]', '$file[10]', '$file[11]', '$file[12]', '$file[13]', '$file[14]', '$file[15]', '$file[16]', '$file[17]')"))
{
echo "Guardado\n"; //Mensaje en pantalla
echo $num;
/* Cierra el archivo creado listasNegras.csv */
fclose($fh);
}
else
{
echo "No se guardo\n"; //Mensaje en pantalla
}
}
$j++; //Se incrementa la variable en uno
}
}
else
{
echo "\n Ya hay registros\n";
/* Mientras el archivo contenga datos, se mostrarán en pantalla los datos del archivo */
while(($file = fgetcsv($fh, 1000, ',')) !== false)
{
/* Se mostrarán todas las filas excepto las primeras 3, las cuales de acuerdo al documento, no necesitamos guardar en la base */
if($j > 2)
{
/* Imprime en pantalla los datos del archivo .CSV */
//echo utf8_encode($file[0]."\t".$file[2]."\t".$file[17]."\n");
$num = count($file);
/* Sentencia que inserta los datos en la tabla de la base */
if(mysqli_query($conectar, "UPDATE catContribuyentes SET noContri = '$file[0]', rfcContri = '$file[1]', nombreContri = '$file[2]', situacionContri = '$file[3]', numFecContri = '$file[4]', publicacionContri = '$file[5]', numFecContriP = '$file[6]', pubDOFContri = '$file[7]', pubDesvContri = '$file[8]', numFecDesvContri = '$file[9]', publicacionDOFDes = '$file[10]', numFecDefi = '$file[11]', punlicacionDefi = '$file[12]', publicacionDOFDef = '$file[13]', numFecSentFav = '$file[14]', pubSentSATFav = '$file[15]', numFecSentFavD = '$file[16]', pubDOFSentFav = '$file[17]'"))
{
echo "Actualizado\n"; //Mensaje en pantalla
}
else
{
echo "No se actualizo\n"; //Mensaje en pantalla
}
}
$j++; //Se incrementa la variable en uno
}
}
}
else
{
echo "No se abrió";
}
}
else
{
echo "\n no Existe";
}
?>