static void *procesar_guardar_articulo(t_Articulo *src, EMUFS_REG_SIZE *size, t_LstArticulos *lst);
static int procesar_leer_articulo(t_Articulo *dst, void *src, EMUFS_REG_SIZE size, t_LstArticulos *lst);
+static void dump_articulos(char *tmpfile);
+
#ifdef TP_PRIMER_ENTREGA
/* Manejo de la lista doble */
static t_Reg_Articulo *crear_nodo_articulo(EMUFS_REG_ID reg, unsigned int num);
PERR("Voy a agregar un indice");
emufs_agregar_indice(tmp->fp, "presentacion", IND_EXAHUSTIVO, param->ind_art[2].tipo_arbol, IDX_STRING, STRUCT_OFFSET(un_articulo, desc), param->ind_art[2].tam_bloque, 1);
emufs_agregar_indice(tmp->fp, "desc", IND_EXAHUSTIVO, param->ind_art[1].tipo_arbol, IDX_STRING, STRUCT_OFFSET(un_articulo, desc), param->ind_art[1].tam_bloque, 0);
- emufs_agregar_indice(tmp->fp, "codigo", IND_PRIMARIO, param->ind_art[0].tipo_arbol, IDX_INT, 0, param->ind_art[0].tam_bloque, 0);
+
+ /* Para secuencial indexado el indice primario siempre es el B+ */
+ if ((param->tipo_arch_art != T4) && (param->tipo_arch_art != T5))
+ emufs_agregar_indice(tmp->fp, "codigo", IND_PRIMARIO, param->ind_art[0].tipo_arbol, IDX_INT, 0, param->ind_art[0].tam_bloque, 0);
+ else
+ emufs_agregar_indice(tmp->fp, "codigo", IND_PRIMARIO, IND_B_PLUS, IDX_INT, 0, param->ind_art[0].tam_bloque, 0);
if (!tmp->fp) {
PERR("NO SE PUDO CREAR ARCHIVO ARTICULOS");
free(tmp);
prop = xml_get_prop(node, "NroArtículo");
art.numero = atoi(prop);
xmlFree(prop);
- strncpy(art.desc, prop = xml_get_prop(node, "Descripción"), 50); xmlFree(prop);
- art.desc[50] = '\0'; /* Me aseguro de que este */
- strncpy(art.presentacion, prop = xml_get_prop(node, "Presentación"), 30); xmlFree(prop);
- art.presentacion[30] = '\0'; /* Me aseguro de que este */
- strncpy(art.existencia, prop = xml_get_prop(node, "Existencia"), 8); xmlFree(prop);
- art.existencia[8] = '\0'; /* Me aseguro de que este */
- strncpy(art.ubicacion, prop = xml_get_prop(node, "Ubicación"), 30); xmlFree(prop);
- strncpy(art.pvu, prop = xml_get_prop(node, "PVU"), 8); xmlFree(prop);
- art.pvu[8] = '\0'; /* Me aseguro de que este */
- strncpy(art.emin, prop = xml_get_prop(node, "Emín"), 8); xmlFree(prop);
- art.emin[8] = '\0'; /* Me aseguro de que este */
+ strcpy(art.desc, prop = xml_get_prop(node, "Descripción")); xmlFree(prop);
+ art.desc[50] = '\0';
+ strcpy(art.presentacion, prop = xml_get_prop(node, "Presentación")); xmlFree(prop);
+ art.presentacion[30] = '\0';
+ strcpy(art.existencia, prop = xml_get_prop(node, "Existencia")); xmlFree(prop);
+ art.existencia[8] = '\0';
+ strcpy(art.ubicacion, prop = xml_get_prop(node, "Ubicación")); xmlFree(prop);
+ art.ubicacion[30] = '\0';
+ strcpy(art.pvu, prop = xml_get_prop(node, "PVU")); xmlFree(prop);
+ art.pvu[8] = '\0';
+ strcpy(art.emin, prop = xml_get_prop(node, "Emín")); xmlFree(prop);
+ art.emin[8] = '\0';
/* Ya leido el articulo ahora paso a guardarlo en el archivo y agregarlo a la lista */
save = procesar_guardar_articulo(&art, &size, lst_articulos);
if (save != NULL) {
} else {
PERR("Voy a recuperar desde un archivo");
tmp->fp = emufs_abrir("articulos");
- fprintf(stderr, "PTR=%p %p\n", tmp, tmp->fp);
if (tmp->fp == NULL) {
PERR("No se pudo cargar archivo de articulos.");
free(tmp);
error = 0;
k = emufs_indice_generar_clave_desde_valor(lst->fp->indices, (char *)&numero);
tmp = lst->fp->leer_registro(lst->fp, k, &size, &error);
- if (error) {
+ if (tmp == NULL) {
free(art);
return NULL;
}
return tmp;
}
-void art_reformatear(int tipo, int tam_bloque, int tam_reg)
+void art_reformatear(t_Parametros *param)
{
-#ifdef NO_SE_PUEDE_USAR
- EMUFS *nuevo, *old;
- EMUFS_REG_ID *indices, id;
- EMUFS_REG_SIZE indices_total, i, size;
- t_Articulo art;
- t_LstArticulos *lst_nueva;
- int error;
+ char *tmpfile = "tmp_file.xxx";
+ FILE *fp;
char *save;
+ int error;
+ EMUFS_REG_SIZE size;
+ EMUFS *emu;
+ t_Articulo articulo, *un_articulo;
- PERR("==== EMPIEZO ====\n");
- old = lst_articulos->fp;
-
- /* Creo el nuevo file */
- PERR("Creo el archivo\n");
- nuevo = emufs_crear("emufs_tmp", tipo, tam_bloque, sizeof(t_Articulo));
- if (nuevo == NULL) {
- PERR("ARCHIVO NUEVO NO CREADO");
- return;
- }
+ /* Creo el archivo temporal con los datos actuales */
+ PERR("Creo dumpfile");
+ dump_articulos(tmpfile);
+ PERR("Listo");
- /* Creo la nueva lista */
- lst_nueva = (t_LstArticulos *)malloc(sizeof(t_LstArticulos));
- lst_nueva->primero = NULL;
- lst_nueva->fp = nuevo;
-
- /* Leo los indices del archivo viejo */
- PERR("Obtengo Indices\n");
- indices = emufs_idx_get(old, &indices_total);
- if (indices == NULL) {
- art_liberar(lst_nueva);
- return;
- }
+ /* Destruyo el EMUFS y todos sus indices */
+ art_liberar(NULL);
- PERR("Proceso datos\n");
- for(i=0; i<indices_total; i++) {
- error = 0;
- save = old->leer_registro(old, indices[i], &size, &error);
- if (procesar_leer_articulo(&art, save, size, lst_articulos) == 1) {
+ /* vuelvo a crear el EMUFS y sus indices (esto deberia pisar lo actual) */
+ PERR("Creando todo de nuevo")
+
+ lst_articulos = (t_LstArticulos *)malloc(sizeof(t_LstArticulos));
+ lst_articulos->primero = NULL;
+
+ emu = lst_articulos->fp = emufs_crear("articulos", param->tipo_arch_art, param->tam_bloque_art, sizeof(t_Articulo));
+ emufs_agregar_indice(emu, "presentacion", IND_EXAHUSTIVO, param->ind_art[2].tipo_arbol, IDX_STRING, STRUCT_OFFSET(un_articulo, desc), param->ind_art[2].tam_bloque, 1);
+ emufs_agregar_indice(emu, "desc", IND_EXAHUSTIVO, param->ind_art[1].tipo_arbol, IDX_STRING, STRUCT_OFFSET(un_articulo, desc), param->ind_art[1].tam_bloque, 0);
+ if ((param->tipo_arch_art != T4) && (param->tipo_arch_art != T5))
+ emufs_agregar_indice(emu, "codigo", IND_PRIMARIO, param->ind_art[0].tipo_arbol, IDX_INT, 0, param->ind_art[0].tam_bloque, 0);
+ else
+ emufs_agregar_indice(emu, "codigo", IND_PRIMARIO, IND_B_PLUS, IDX_INT, 0, param->ind_art[0].tam_bloque, 0);
+ PERR("Listo");
+ /* Ahora solo resta volver a meter todos los datos en el archivo */
+ fp = fopen(tmpfile, "rb");
+ PERR("Agregando datos de nuevo")
+ while (!feof(fp)) {
+ if (fread(&articulo, sizeof(t_Articulo), 1, fp) != 1) continue;
+ save = procesar_guardar_articulo(&articulo, &size, lst_articulos);
+ if (save) {
+ error = 0;
+ emu->grabar_registro(emu, save, size, &error);
free(save);
- /* Lei un registro Ok. Lo salvo en el archivo nuevo */
- save = procesar_guardar_articulo(&art, &size, lst_nueva);
- if (save) {
- error = 0;
- id = nuevo->grabar_registro(nuevo, save, size, &error);
- agregar_nodo_articulo(lst_nueva, crear_nodo_articulo(id, art.numero));
- free(save);
- }
}
}
-
- free(indices);
-
- PERR("Libero lo viejo\n");
- art_liberar(lst_articulos);
-
- PERR("Ahora tengo lo nuevo\n");
- lst_articulos = lst_nueva;
-
- /* El nuevo tiene como nombre emufs_tmp, lo cambio a mano! */
- free(lst_articulos->fp->nombre);
- lst_articulos->fp->nombre = (char *)malloc(sizeof(char)*(strlen("articulos")+1));
- strcpy(lst_articulos->fp->nombre, "articulos");
-
- /* Muevo los archivos! */
- /* TODO : Poner en otro lugar mas generico! */
- PERR("Renombre!!\n");
- rename("emufs_tmp.dat", "articulos.dat");
- rename("emufs_tmp.idx", "articulos.idx");
- rename("emufs_tmp.fsc", "articulos.fsc");
- rename("emufs_tmp.did", "articulos.did");
- PERR("==== TERMINE ====\n");
-#endif
+ fclose(fp);
+ PERR("Todo listo");
+ unlink(tmpfile);
}
int art_exportar_xml(const char *filename)
k = menor;
if (k.i_clave > mayor.i_clave)
hasta_codigo = mayor.i_clave;
- fprintf(stderr, "k.i_clave = %d -- hasta_codigo = %d\n", k.i_clave, hasta_codigo);
+
while ((k.i_clave != -1) && (k.i_clave <= hasta_codigo)) {
PERR("BUSCO ARTICULO");
+ fprintf(stderr, "CLAVE = %d\n", k.i_clave);
articulo = art_obtener(lst_articulos, k.i_clave, &dummy);
PERR("LO TENGO");
if (articulo != NULL) {
PERR("AGREGO A LA LISTA");
- fprintf(stderr, "%d - %s\n", articulo->numero, articulo->desc);
lista_agregar_fila(lista,
articulo->numero,
articulo->desc,
}
PERR("OBTENGO SIGUIENTE CLAVE");
k = idx->obtener_sig_clave(idx, k);
- fprintf(stderr, "k.i_clave = %d -- hasta_codigo = %d\n", k.i_clave, hasta_codigo);
}
curs_set(0);
datos = idx->buscar_entradas(idx, k, &cant);
else
datos = emufs_buscar_registros(lst_articulos->fp, "desc", desc, &cant);
- fprintf(stderr, "obtuve %d claves para %s\n", cant, desc);
for(i=0; i<cant; i++) {
error = 1;
k1.i_clave = datos[i].id;
* claves con repeticion
*/
PERR("=== MODIFICANDO ===");
- fprintf(stderr, "Desc=%s , PVU=%s, Codigo=%d\n", articulo.desc, articulo.pvu, articulo.numero);
lst_articulos->fp->modificar_registro(lst_articulos->fp, k1, tmp, size, &error, datos[i]);
PERR("=== FIN ===");
}
free(art);
art = NULL;
} else {
- fprintf(stderr, "Tengo %d datos\n", cant);
error = 1;
k.i_clave = datos[0].id;
PERR("Leo el primer dato");
*/
PERR("Guardando modificacion de Stock");
error = 0;
- fprintf(stderr, "PTR=%p %p\n", lst_articulos, lst_articulos->fp);
fp = lst_articulos->fp;
PERR("Pase1");
- fprintf(stderr, "METODO : %p\n", fp->modificar_registro);
fp->modificar_registro(fp, k, tmp, size, &error, dummy1);
PERR("Pase2");
PERR("Listo");
}
}
+static void dump_articulos(char *tmpfile)
+{
+ t_Articulo *art;
+ EMUFS_REG_ID id;
+ FILE *fp;
+ CLAVE k;
+ INDICE *idx;
+
+ idx = lst_articulos->fp->indices;
+
+ k = idx->obtener_menor_clave(idx);
+
+ if (!(fp = fopen(tmpfile, "wb"))) return;
+
+ while (k.i_clave != -1) {
+ art = art_obtener(lst_articulos, k.i_clave, &id);
+ if (art != NULL) {
+ fwrite(art, 1, sizeof(t_Articulo), fp);
+ free(art);
+ }
+ k = idx->obtener_sig_clave(idx, k);
+ }
+
+ fclose(fp);
+ return;
+}
+
projects / z.facultad / 75.06 / emufs.git / blobdiff