From e58622f8f05bbb5279463a8de954cd74ba08f503 Mon Sep 17 00:00:00 2001 From: dfcarvajal Date: Wed, 12 Nov 2025 16:29:10 +0000 Subject: [PATCH] =?UTF-8?q?A=C3=B1adimos=20revisi=C3=B3n=20de=20errores?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- flows.json | 271 +++++++++++++++++++++++++++++++++++++++++------------ 1 file changed, 212 insertions(+), 59 deletions(-) diff --git a/flows.json b/flows.json index 8565554..2ae767a 100644 --- a/flows.json +++ b/flows.json @@ -171,8 +171,8 @@ "initialize": "", "finalize": "", "libs": [], - "x": 450, - "y": 640, + "x": 430, + "y": 880, "wires": [ [ "535b18bcfc71f9cd" @@ -243,8 +243,8 @@ "initialize": "", "finalize": "", "libs": [], - "x": 180, - "y": 640, + "x": 160, + "y": 880, "wires": [ [ "d647c9286ddb06ce" @@ -268,8 +268,8 @@ "topic": "", "payload": "", "payloadType": "date", - "x": 220, - "y": 700, + "x": 200, + "y": 940, "wires": [ [ "a5d5ef751185e3e9" @@ -288,8 +288,8 @@ "initialize": "", "finalize": "", "libs": [], - "x": 320, - "y": 760, + "x": 300, + "y": 1000, "wires": [ [ "495d54abe840ccc9" @@ -308,8 +308,8 @@ "initialize": "", "finalize": "", "libs": [], - "x": 410, - "y": 700, + "x": 390, + "y": 940, "wires": [ [ "3acef3e43d0415d4" @@ -329,8 +329,8 @@ "targetType": "msg", "statusVal": "", "statusType": "auto", - "x": 630, - "y": 760, + "x": 610, + "y": 1000, "wires": [] }, { @@ -346,8 +346,8 @@ "targetType": "msg", "statusVal": "", "statusType": "auto", - "x": 700, - "y": 640, + "x": 680, + "y": 880, "wires": [] }, { @@ -420,8 +420,8 @@ "split": false, "rowsPerMsg": 1, "outputs": 1, - "x": 790, - "y": 700, + "x": 770, + "y": 940, "wires": [ [] ] @@ -546,7 +546,7 @@ "type": "function", "z": "1a4b40705122dc91", "name": "Prepación de la Consulta", - "func": "// aggregation pipeline\nconst pipeline = [\n {\n $addFields: {\n TipoVia: { $ifNull: [\"$TipoVia1\", { $ifNull: [\"$TipoVia2\", \"CONSOLIDADO\"] }] },\n Calle: { $ifNull: [\"$Calle1\", { $ifNull: [\"$Calle2\", \"CONSOLIDADO\"] }] },\n Poblacion: { $ifNull: [\"$Poblacion1\", { $ifNull: [\"$Poblacion2\", \"CONSOLIDADO\"] }] },\n CP: { $ifNull: [\"$cp1\", { $ifNull: [\"$cp2\", \"00000\"] }] }\n }\n },\n {\n $project: {\n TipoVia1: 0,\n TipoVia2: 0,\n Calle1: 0,\n Calle2: 0,\n Poblacion1: 0,\n Poblacion2: 0,\n cp1: 0,\n cp2: 0\n }\n },\n {\n $out: \"servicios_consolidado_calle\" // guarda el resultado en otra colección\n }\n ];\n// optional: aggregate options\nconst options = {\n allowDiskUse: true\n};\n// payload for mongodb4 node\nmsg.collection = \"servicios_sin_filtrar\";\nmsg.operation = \"aggregate\";\nmsg.payload = [pipeline, options];\nreturn msg;", + "func": "// aggregation pipeline\nconst pipeline = [\n {\n $addFields: {\n TipoVia: { $ifNull: [\"$TipoVia1\", { $ifNull: [\"$TipoVia2\", \"CALLE\"] }] },\n Calle: { $ifNull: [\"$Calle1\", { $ifNull: [\"$Calle2\", \"SIN DATOS\"] }] },\n Poblacion: { $ifNull: [\"$Poblacion1\", { $ifNull: [\"$Poblacion2\", \"MADRID\"] }] },\n CP: { $ifNull: [\"$cp1\", { $ifNull: [\"$cp2\", \"00000\"] }] }\n }\n },\n {\n $project: {\n TipoVia1: 0,\n TipoVia2: 0,\n Calle1: 0,\n Calle2: 0,\n Poblacion1: 0,\n Poblacion2: 0,\n cp1: 0,\n cp2: 0\n }\n },\n {\n $out: \"servicios_consolidado_calle\" // guarda el resultado en otra colección\n }\n ];\n// optional: aggregate options\nconst options = {\n allowDiskUse: true\n};\n// payload for mongodb4 node\nmsg.collection = \"servicios_sin_filtrar\";\nmsg.operation = \"aggregate\";\nmsg.payload = [pipeline, options];\nreturn msg;", "outputs": 1, "timeout": 0, "noerr": 0, @@ -632,14 +632,14 @@ "type": "function", "z": "1a4b40705122dc91", "name": "Prepación de la Consulta", - "func": "// aggregation pipeline\nconst pipeline = [\n {\n $match: {\n $and: [\n { $expr: { $ne: [\"$Calle\", \"CONSOLIDADO\"] } },\n { $expr: { $ne: [\"$Poblacion\", \"CONSOLIDADO\"] } },\n ]\n }\n },\n {\n $out: \"servicios_consolidado_calle_filtrado\" // guarda el resultado en otra colección\n }\n ];\n// optional: aggregate options\nconst options = {\n allowDiskUse: true\n};\n// payload for mongodb4 node\nmsg.collection = \"servicios_consolidado_calle\";\nmsg.operation = \"aggregate\";\nmsg.payload = [pipeline, options];\nreturn msg;", + "func": "// aggregation pipeline\nconst pipeline = [\n {\n $match: {\n $and: [\n { $expr: { $ne: [\"$Calle\", \"SIN DATOS\"] } },\n ]\n }\n },\n {\n $out: \"servicios_consolidado_calle_filtrado\" // guarda el resultado en otra colección\n }\n ];\n// optional: aggregate options\nconst options = {\n allowDiskUse: true\n};\n// payload for mongodb4 node\nmsg.collection = \"servicios_consolidado_calle\";\nmsg.operation = \"aggregate\";\nmsg.payload = [pipeline, options];\nreturn msg;", "outputs": 1, "timeout": 0, "noerr": 0, "initialize": "", "finalize": "", "libs": [], - "x": 490, + "x": 530, "y": 400, "wires": [ [ @@ -659,7 +659,7 @@ "maxTimeMS": "0", "handleDocId": false, "name": "Consulta", - "x": 680, + "x": 720, "y": 400, "wires": [ [ @@ -680,7 +680,7 @@ "targetType": "full", "statusVal": "", "statusType": "auto", - "x": 820, + "x": 860, "y": 400, "wires": [] }, @@ -708,7 +708,7 @@ "t": "set", "p": "limit", "pt": "msg", - "to": "360", + "to": "500", "tot": "num" }, { @@ -765,8 +765,8 @@ "targetType": "full", "statusVal": "", "statusType": "auto", - "x": 860, - "y": 640, + "x": 840, + "y": 880, "wires": [] }, { @@ -785,8 +785,8 @@ ], "repeat": "", "crontab": "", - "once": false, - "onceDelay": 0.1, + "once": true, + "onceDelay": "1", "topic": "", "payload": "", "payloadType": "date", @@ -833,7 +833,7 @@ "payload": "", "payloadType": "date", "x": 180, - "y": 460, + "y": 660, "wires": [ [ "d66163bb05e6f12e", @@ -875,7 +875,7 @@ "to": "", "reg": false, "x": 460, - "y": 460, + "y": 660, "wires": [ [ "004948a143b907dd" @@ -894,8 +894,8 @@ "maxTimeMS": "0", "handleDocId": false, "name": "Consulta", - "x": 680, - "y": 460, + "x": 720, + "y": 660, "wires": [ [ "bb5ad864c986b15f" @@ -915,8 +915,8 @@ "targetType": "full", "statusVal": "", "statusType": "auto", - "x": 860, - "y": 460, + "x": 900, + "y": 660, "wires": [] }, { @@ -953,7 +953,7 @@ "to": "", "reg": false, "x": 450, - "y": 500, + "y": 700, "wires": [ [ "004948a143b907dd" @@ -1049,7 +1049,7 @@ "timeout": "5", "timeoutUnits": "seconds", "rate": "1", - "nbRateUnits": "5", + "nbRateUnits": "2", "rateUnits": "second", "randomFirst": "1", "randomLast": "5", @@ -1211,10 +1211,10 @@ "y": 200, "wires": [ [ - "4063e875162c944d" + "b176ccfcb67d19a0" ], [ - "59f364d9feca28e5" + "2432622b4a8371d9" ] ], "outputLabels": [ @@ -1385,19 +1385,8 @@ "links": [ "717811bdd780a620" ], - "x": 655, - "y": 180, - "wires": [] - }, - { - "id": "59f364d9feca28e5", - "type": "link out", - "z": "a796bfad8ab76fe4", - "name": "OUT - Error", - "mode": "link", - "links": [], - "x": 655, - "y": 220, + "x": 835, + "y": 200, "wires": [] }, { @@ -1455,12 +1444,12 @@ "tosidebar": true, "console": false, "tostatus": false, - "complete": "true", - "targetType": "full", + "complete": "consulta_calle", + "targetType": "msg", "statusVal": "", "statusType": "auto", - "x": 930, - "y": 300, + "x": 890, + "y": 340, "wires": [] }, { @@ -1519,7 +1508,9 @@ "x": 970, "y": 660, "wires": [ - [] + [ + "61bddcdd604826da" + ] ] }, { @@ -1557,7 +1548,7 @@ "type": "function", "z": "a796bfad8ab76fe4", "name": "Calles con Memoria Histórica", - "func": "// Referencia : https://www.elmundo.es/madrid/2016/07/21/5791123146163fd3028b45a3.html\n\nmsg.cambio = msg.cambio || {};\n\n// Internet\nif (msg.consulta_calle === \"CALLE JOSE LUIS DE ARRESE MADRID\") {\n msg.cambio.calle = \"POETA BLAS DE OTERO\";\n return msg;\n}\n// 12\nif (msg.consulta_calle === \"CALLE CAPITAN CORTES MADRID\") {\n msg.cambio.calle = \"MANUEL CHAVES NOGALES\";\n return msg;\n}\n\n// \nif (msg.consulta_calle === \"CALLE GENERAL ROMERO BASART 27 MADRID\") {\n msg.cambio.calle = \"BLAS CABRERA\";\n return msg;\n}\n\nif (msg.consulta_calle === \"CALLE GENERAL ORGAZ 1 MADRID\") {\n msg.cambio.calle = \"FORTUNATA Y JACINTA\";\n return msg;\n}\n\nif (msg.consulta_calle === \"CALLE GENERAL SALIQUET MADRID\") {\n msg.cambio.calle = \"SOLEDAD CAZORLA\";\n return msg;\n}\n\nif (msg.consulta_calle === \"CALLE COMANDANTE ZORITA 2 MADRID\") {\n msg.cambio.calle = \"AVIADOR ZORITA\";\n return msg;\n}\n\nif (msg.consulta_calle === \"PLAZA FERNANDEZ LADREDA 2 MADRID\") {\n msg.cambio.calle = \"ELIPTICA\";\n return msg;\n}\n\nif (msg.consulta_calle === \"GLORIETA PATINES MADRID\") {\n msg.cambio.calle = \"DE LOS NEVEROS\";\n return msg;\n}\n\n", + "func": "// Referencia : https://www.elmundo.es/madrid/2016/07/21/5791123146163fd3028b45a3.html\n\nmsg.cambio = msg.cambio || {};\n\n// Internet\nif (msg.consulta_calle === \"CALLE JOSE LUIS DE ARRESE MADRID\") {\n msg.cambio.calle = \"POETA BLAS DE OTERO\";\n return msg;\n}\n// 12\nif (msg.consulta_calle === \"CALLE CAPITAN CORTES MADRID\") {\n msg.cambio.calle = \"MANUEL CHAVES NOGALES\";\n return msg;\n}\n\n// \nif (msg.consulta_calle === \"CALLE GENERAL ROMERO BASART 27 MADRID\") {\n msg.cambio.calle = \"BLAS CABRERA\";\n return msg;\n}\n\nif (msg.consulta_calle === \"CALLE GENERAL ORGAZ 1 MADRID\") {\n msg.cambio.calle = \"FORTUNATA Y JACINTA\";\n return msg;\n}\n\nif (msg.consulta_calle === \"CALLE GENERAL SALIQUET MADRID\") {\n msg.cambio.calle = \"SOLEDAD CAZORLA\";\n return msg;\n}\n\nif (msg.consulta_calle === \"CALLE COMANDANTE ZORITA 2 MADRID\") {\n msg.cambio.calle = \"AVIADOR ZORITA\";\n return msg;\n}\n\nif (msg.consulta_calle === \"PLAZA FERNANDEZ LADREDA 2 MADRID\") {\n msg.cambio.calle = \"ELIPTICA\";\n return msg;\n}\n\nif (msg.consulta_calle === \"PLAZA FERNANDEZ LADREDA MADRID\") {\n msg.cambio.calle = \"ELIPTICA\";\n return msg;\n}\n\nif (msg.consulta_calle === \"GLORIETA PATINES MADRID\") {\n msg.cambio.calle = \"DE LOS NEVEROS\";\n return msg;\n}\n\nif (msg.consulta_calle === \"PLAZA HERMANOS FALCO Y ALVAREZ DE TOLEDO 13 MADRID\") {\n msg.cambio.calle = \"MAYOR DE BARAJAS\";\n return msg;\n}\n\nif (msg.consulta_calle === \"CALLE CAPITAN CORTES MADRID\") {\n msg.cambio.calle = \"MANUEL CHAVES NOGALES\";\n return msg;\n}\n\nif (msg.consulta_calle === \"CALLE GENERAL SALIQUET MADRID\") {\n msg.cambio.calle = \"SOLEDAD CAZORLA\";\n return msg;\n}\n\nif (msg.consulta_calle === \"PLAZA HERMANOS FALCO Y ALVAREZ DE TOLEDO 13 MADRID\") {\n msg.cambio.calle = \"MAYOR DE BARAJAS\";\n return msg;\n}\n\nif (msg.consulta_calle === \"PLAZA GENERAL SAGARDIA RAMOS 21 MADRID\") {\n msg.cambio.calle = \"PASEO DE LA MAESTRA MARIA SANCHEZ ARBOS\";\n return msg;\n}\n\nif (msg.consulta_calle === \"CALLE GARCIA MORATO MADRID\") {\n msg.cambio.calle = \"ROBERT CAPA\";\n return msg;\n}\n\nif (msg.consulta_calle === \"CALLE GENERAL YAGUE 5 MADRID\") {\n msg.cambio.calle = \"SAN GERMAN\";\n return msg;\n}\n\n", "outputs": 1, "timeout": 0, "noerr": 0, @@ -1577,7 +1568,7 @@ "type": "function", "z": "a796bfad8ab76fe4", "name": "Calles con Mala codificación", - "func": "msg.cambio = msg.cambio || {};\n\n// Es una campa de recogida de vehículos de renting\nif (msg.consulta_calle === \"CAMINO SALOBRAL MADRID\") {\n msg.cambio.tipovia = \"Carretera\"\n msg.cambio.calle = \"Estación de Contenedores\";\n msg.cambio.numero_retirada = \"4\"\n return msg;\n}\n\n// Quitamos el kilometro\nif (msg.consulta_calle === \"CARRETERA VILLAVERDE KM 4.8 GETAFE\") {\n msg.cambio.numero_retirada = \"4\"\n return msg;\n}\n\n// Añadimos el codigo postal para que lo localice\nif (msg.consulta_calle === \"GLORIETA SANDRO PERTINI MADRID\") {\n msg.cambio.extra_calle = \"28043\"\n return msg;\n}\n\n// La plaza de Ciudad lineal no tiene carto, se cambia por alcala\nif (msg.consulta_calle === \"PLAZA CIUDAD LINEAL MADRID\") {\n msg.cambio.tipovia = \"CALLE\"\n msg.cambio.calle = \"ALCALA\";\n msg.cambio.numero_retirada = \"423\"\n return msg;\n}\n\n// Error de nombre\nif (msg.consulta_calle === \"CAMINO CABESTREROS 9 MADRID\") {\n msg.cambio.tipovia = \"CALLE\";\n msg.cambio.calle = \"CABESTREROS\";\n return msg;\n}\n\n// Error de nombre\nif (msg.consulta_calle === \"PLAZA CORREGIDOR CONDE DE MACEDA Y TABOADA MADRID\") {\n msg.cambio.calle = \"PICO DE LOS ARTILLEROS\";\n msg.cambio.tipovia = \"CALLE\"\n msg.cambio.calle = \"PICO DE LOS ARTILLEROS\";\n msg.cambio.numero_retirada = \"150\"\n return msg;\n}\n\n// Error de nombre\nif (msg.consulta_calle === \"AVENIDA AMERICA 2 FUENLABRADA\") {\n msg.cambio.numero_retirada = \"SN\"\n msg.cambio.extra_calle = \"2\"\n return msg;\n}\n\n// Mala condificación\nif (msg.consulta_calle === \"CALLE TACONA COMISARÍA MADRID\") {\n msg.cambio.numero_retirada = \"33\"\n return msg;\n}\n\n// Mala condificación\nif (msg.consulta_calle === \"CALLE DOCTOR TOLOSA LATOUR FAROLA 62 MADRID\") {\n msg.cambio.numero_retirada = \"62\"\n return msg;\n}\n\n// Mala condificación\nif (msg.consulta_calle === \"PLAZA BARICHARA 4 MADRID\") {\n msg.cambio.tipovia = \"CALLE\"\n return msg;\n}", + "func": "msg.cambio = msg.cambio || {};\n\n// Es una campa de recogida de vehículos de renting\nif (msg.consulta_calle === \"CAMINO SALOBRAL MADRID\") {\n msg.cambio.tipovia = \"Carretera\"\n msg.cambio.calle = \"Estación de Contenedores\";\n msg.cambio.numero_retirada = \"4\"\n return msg;\n}\n\n// Quitamos el kilometro\nif (msg.consulta_calle === \"CARRETERA VILLAVERDE KM 4.8 GETAFE\") {\n msg.cambio.numero_retirada = \"4\"\n return msg;\n}\n\n// Añadimos el codigo postal para que lo localice\nif (msg.consulta_calle === \"GLORIETA SANDRO PERTINI MADRID\") {\n msg.cambio.extra_calle = \"28043\"\n return msg;\n}\n\n// La plaza de Ciudad lineal no tiene carto, se cambia por alcala\nif (msg.consulta_calle === \"PLAZA CIUDAD LINEAL MADRID\") {\n msg.cambio.tipovia = \"CALLE\"\n msg.cambio.calle = \"ALCALA\";\n msg.cambio.numero_retirada = \"423\"\n return msg;\n}\n\n// Error de nombre\nif (msg.consulta_calle === \"CAMINO CABESTREROS 9 MADRID\") {\n msg.cambio.tipovia = \"CALLE\";\n msg.cambio.calle = \"CABESTREROS\";\n return msg;\n}\n\n// Error de nombre\nif (msg.consulta_calle === \"PLAZA CORREGIDOR CONDE DE MACEDA Y TABOADA MADRID\") {\n msg.cambio.calle = \"PICO DE LOS ARTILLEROS\";\n msg.cambio.tipovia = \"CALLE\"\n msg.cambio.calle = \"PICO DE LOS ARTILLEROS\";\n msg.cambio.numero_retirada = \"150\"\n return msg;\n}\n\n// Error de nombre\nif (msg.consulta_calle === \"AVENIDA AMERICA 2 FUENLABRADA\") {\n msg.cambio.numero_retirada = \"SN\"\n msg.cambio.extra_calle = \"2\"\n return msg;\n}\n\nif (msg.consulta_calle === \"AVENIDA AMERICA FUENLABRADA\") {\n msg.cambio.numero_retirada = \"SN\"\n msg.cambio.extra_calle = \"2\"\n return msg;\n}\n\n// Mala condificación\nif (msg.consulta_calle === \"CALLE TACONA COMISARÍA MADRID\") {\n msg.cambio.numero_retirada = \"33\"\n return msg;\n}\n\n// Mala condificación\nif (msg.consulta_calle === \"CALLE DOCTOR TOLOSA LATOUR FAROLA 62 MADRID\") {\n msg.cambio.numero_retirada = \"62\"\n return msg;\n}\n\n// Mala condificación\nif (msg.consulta_calle === \"PLAZA BARICHARA 4 MADRID\") {\n msg.cambio.tipovia = \"CALLE\"\n return msg;\n}\n\n// Mala condificación\nif (msg.consulta_calle === \"CALLE QUINTANAORTUÑO MADRID\") {\n msg.cambio.calle = \"QUINTANAPALLA\"\n return msg;\n}\n\n// Mala condificación\nif (msg.consulta_calle === \"CALLE GABRIEL MIRO 1 MADRID\") {\n msg.cambio.tipovia = \"PLAZA\"\n return msg;\n}\n\nif (msg.consulta_calle === \"CAMINO CABESTROS 9 MADRID\") {\n msg.cambio.tipovia = \"CALLE\";\n msg.cambio.calle = \"CABESTREROS\";\n return msg;\n}\n\nif (msg.consulta_calle === \"CALLE BENIMAMET FRENTE 6 MADRID\") {\n msg.cambio.tipovia = \"CALLE\";\n msg.cambio.numero_retirada = \"6\";\n return msg;\n}\n\nif (msg.consulta_calle === \"GLORIETA DE LOS NEVEROS MADRID\") {\n msg.cambio.tipovia = \"CALLE\";\n msg.cambio.calle = \"PUERTA DEL ANGEL\";\n msg.cambio.numero_retirada = \"10\";\n return msg;\n}\n\nif (msg.consulta_calle === \"PASEO GENERAL SAGARDIA RAMOS 21 MADRID\") {\n msg.cambio.tipovia = \"PLAZA\";\n return msg;\n}\n\nif (msg.consulta_calle === \"CALLE LUSCINDA FTE 7 MADRID\") {\n msg.cambio.numero_retirada = \"7\";\n return msg;\n}\n\nif (msg.consulta_calle === \"CAMINO LEÑEROS MADRID\") {\n msg.cambio.tipovia = \"CALLE\";\n return msg;\n}\n\nif (msg.consulta_calle === \"CALLE SANTIAGO RUISEÑOR MADRID\") {\n msg.cambio.tipovia = \"SANTIAGO RUSIÑOL\";\n return msg;\n}\n\n\nif (msg.consulta_calle === \"CALLE PARQUE FERIAL JUAN CARLOS I MADRID\") {\n msg.cambio.tipovia = \"VIA\";\n msg.cambio.calle = \"DUBLIN\";\n msg.cambio.numero_retirada = \"6\";\n return msg;\n}", "outputs": 1, "timeout": 0, "noerr": 0, @@ -1674,7 +1665,7 @@ "type": "debug", "z": "a796bfad8ab76fe4", "name": "Información de servicios procesados", - "active": true, + "active": false, "tosidebar": true, "console": false, "tostatus": false, @@ -1682,8 +1673,170 @@ "targetType": "full", "statusVal": "", "statusType": "auto", - "x": 890, - "y": 780, + "x": 1230, + "y": 720, "wires": [] + }, + { + "id": "a1f0210367ec78c3", + "type": "debug", + "z": "a796bfad8ab76fe4", + "name": "debug 1", + "active": false, + "tosidebar": true, + "console": false, + "tostatus": false, + "complete": "true", + "targetType": "full", + "statusVal": "", + "statusType": "auto", + "x": 1360, + "y": 260, + "wires": [] + }, + { + "id": "b176ccfcb67d19a0", + "type": "function", + "z": "a796bfad8ab76fe4", + "name": "Calles a eliminar", + "func": "// Registro a eliminar sino procesamos\nif (msg.consulta_calle === \"CALLE SIN DETERMINAR MADRID\" ||\n msg.consulta_calle === \"BASE MEDIODIA 3 MADRID\" ||\n msg.consulta_calle === \"BASE COLON MADRID\" ||\n msg.consulta_calle === \"BASE MEDIODIA 2 1 MADRID\" ||\n msg.consulta_calle === \"CALLE No Codificada MADRID\" ||\n msg.consulta_calle === \"ACCESO POBLADO DE LAS BARRANQUILLAS sn MADRID\" ||\n msg.consulta_calle === \"BASE BARCELO MADRID\" ||\n msg.consulta_calle === \"EDIFICIO JUZGADO MADRID\" ||\n msg.consulta_calle === \"CALLE CAÑADA REAL GALIANA PARC 12 MADRID\" ||\n msg.consulta_calle === \"CALLE CAÑADA REAL GALIANA PARC. 127 MADRID\" ||\n msg.consulta_calle === \"CALLE No Codificada S / N MADRID\" ||\n msg.consulta_calle === \"CALLE No Codificada 8,400 MADRID\" ||\n msg.consulta_calle === \"CALLE No Codificada KM 12700 MADRID\" ||\n msg.consulta_calle === \"CALLE No Codificada KM 2.400 MADRID\" ||\n msg.consulta_calle === \"CALLE No Codificada - MADRID\" ||\n msg.consulta_calle === \"CALLE No Codificada S/N MADRID\" ||\n msg.consulta_calle === \"CALLE No Codificada FAROLA4 MADRID\" ||\n msg.consulta_calle === \"CALLE No Codificada 12500 MADRID\" ||\n msg.consulta_calle === \"CALLE No Codificada 6, 800 MADRID\" ||\n msg.consulta_calle === \"CALLE No Codificada 6, 500 MADRID\" ||\n msg.consulta_calle === \"CALLE No Codificada 6,800 MADRID\" ||\n msg.consulta_calle === \"CALLE No Codificada 6,500 MADRID\" ||\n msg.consulta_calle === \"CARRETERA A-3 ACCESO A VALDEMINGOMEZ MADRID\" ||\n msg.consulta_calle === \"CALLE No Codificada 2.200 MADRID\" ||\n msg.consulta_calle === \"CALLE No Codificada FAROLA 2 MADRID\" ||\n msg.consulta_calle === \"CALLE CAÑADA REAL GALIANA FAR. 31 MADRID\" ||\n msg.consulta_calle === \"ZONA COMISARIA HORTALEZA MADRID\" ||\n msg.consulta_calle === \"PASO PARTICULAR ELVIRA GOYA 12 MADRID\" ||\n msg.consulta_calle === \"PASO PARTICULAR ELVIRA GOYA 38 MADRID\" ||\n msg.consulta_calle === \"ACCESO AEROPUERTO DE BARAJAS T2 SALIDAS MADRID\"\n ) {\n return [msg, null]\n} else {\n return [null, msg]\n}\n\n", + "outputs": 2, + "timeout": 0, + "noerr": 0, + "initialize": "", + "finalize": "", + "libs": [], + "x": 720, + "y": 180, + "wires": [ + [ + "fa2e9116677470ca" + ], + [ + "4063e875162c944d" + ] + ] + }, + { + "id": "fa2e9116677470ca", + "type": "change", + "z": "a796bfad8ab76fe4", + "name": "Peparamos el identificador de calle a borrar", + "rules": [ + { + "t": "set", + "p": "operation", + "pt": "msg", + "to": "deleteOne", + "tot": "str" + }, + { + "t": "set", + "p": "collection", + "pt": "msg", + "to": "servicios_consolidado_calle_filtrado", + "tot": "str" + }, + { + "t": "set", + "p": "payload", + "pt": "msg", + "to": "[\t {\t \"_id\": direccion._id\t }\t]", + "tot": "jsonata" + } + ], + "action": "", + "property": "", + "from": "", + "to": "", + "reg": false, + "x": 990, + "y": 160, + "wires": [ + [ + "4eee84ac85459806" + ] + ] + }, + { + "id": "4eee84ac85459806", + "type": "mongodb4", + "z": "a796bfad8ab76fe4", + "clientNode": "648a51546e4dadc6", + "mode": "collection", + "collection": "", + "operation": "", + "output": "toArray", + "maxTimeMS": "0", + "handleDocId": false, + "name": "", + "x": 1250, + "y": 160, + "wires": [ + [ + "61bddcdd604826da" + ] + ] + }, + { + "id": "2432622b4a8371d9", + "type": "change", + "z": "a796bfad8ab76fe4", + "name": "Actualizamos los datos de todas las calles que sean iguales", + "rules": [ + { + "t": "set", + "p": "operation", + "pt": "msg", + "to": "updateMany", + "tot": "str" + }, + { + "t": "set", + "p": "collection", + "pt": "msg", + "to": "servicios_consolidado_calle_filtrado", + "tot": "str" + }, + { + "t": "set", + "p": "payload", + "pt": "msg", + "to": "[\t {\t \"TipoVia\": direccion.TipoVia,\t \"Calle\": direccion.Calle,\t \"numero_retirada\": direccion.numero_retirada,\t \"Poblacion\": direccion.Poblacion,\t \"CP\": direccion.CP \t\t },\t {\t \"$set\": {\t \"latitud\": payload[0].lat,\t \"longitud\": payload[0].lon,\t \"geocodingProcesado\": true\t } \t }\t]", + "tot": "jsonata" + } + ], + "action": "", + "property": "", + "from": "", + "to": "", + "reg": false, + "x": 900, + "y": 260, + "wires": [ + [ + "f33442e9c3fb97aa" + ] + ] + }, + { + "id": "f33442e9c3fb97aa", + "type": "mongodb4", + "z": "a796bfad8ab76fe4", + "clientNode": "648a51546e4dadc6", + "mode": "collection", + "collection": "", + "operation": "", + "output": "toArray", + "maxTimeMS": "0", + "handleDocId": false, + "name": "", + "x": 1210, + "y": 260, + "wires": [ + [ + "a1f0210367ec78c3" + ] + ] } ] \ No newline at end of file