mapo/adjustEvents.js at master · nexacenter/mapo · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
var fs = require('fs');


var cleanTelefono = function (number) {
    return number //TODO fai la pulizia
}

var cleanFields = function (org) {
    //spesso nel campo id vi è un url ma non esiste il campo link
    org.link = org.id;

    if (org.telefono !== undefined)
        org.telefono = cleanTelefono(org.telefono);
    if (org.fax !== undefined)
        org.fax = cleanTelefono(org.fax);

    return org;
}

var removeEmptyFields = function (obj) {
    for (property in obj) {
        if (obj[property] === "")
            delete obj[property];
    }
    return obj;
}

var isEmpty = function (obj) {
    if (Object.keys(obj).length)
        return 0;
    return 1;
}

var alreadyExist = function (obj) {
    for (var i = 0; i < orgArray.length; i++) {
        //per ora controllo solo la concordanza del sito web
        if (obj.link !== undefined && obj.link === orgArray[i].link)
            return orgArray[i].id.split("/")[5];
    }
    return 0;
}

var comuneExist = function (code) {
    for (var i = 0; i < comuniArray.length; i++) {
        if (code === comuniArray[i].codIstat)
            return 1;
    }
    return 0;
}

var mergeWith = function (index, obj) {
    //se orgArray[index] è vuoto allora riempi con il relativo valore di obj
    for (p in obj) {
        if (orgArray[index][p] === undefined)
            orgArray[index][p] = obj[p];
    }
}

//TODO controlla che non esista già un file con le organizzazioni, se esiste popola l'array
var orgArray = [];
var eventArray = [];
var comuniArray = [];
var eventJson = JSON.parse(fs.readFileSync("data/appuntamenti.json", "utf-8"));

eventJson.forEach(function (e) {
    var org = cleanFields(e.organizzazione);
    org = removeEmptyFields(org);
    e = removeEmptyFields(e);

    if (isEmpty(org)) {
        delete e.organizzazione;
    } else {
        //controllo se questa organizzazione è già presente nel vettore
        if (alreadyExist(org) !== 0) {
            //se è presente cerco di unire eventuali campi extra o discordanti
            mergeWith(alreadyExist(org) - 1, org);
            e.organizzazione = orgArray[alreadyExist(org) - 1].id;
        } else {
            //se non è presente la aggiungo assegnando un nuovo identificativo
            var i = orgArray.length + 1;
            org.id = "http://mapo.nexacenter.org/id/organizzazioni/" + i;
            orgArray.push(org);
            e.organizzazione = org.id;
        }
    }


    var codIstat = e.comune.codIstat;
    if (!comuneExist(codIstat)) {
        var comune = {};
        comune.nome = e.comune.nome;
        comune.id = "http://mapo.nexacenter.org/id/comuni/" + codIstat;
        comune.url = e.comune.url;
        comune.provincia = e.comune.provincia;
        comune.codIstat = e.comune.codIstat;
        comuniArray.push(comune);
    }


    if (e.foto != undefined && e.foto !== "")
        e.foto = e.comune.url + "/"+ e.foto;
    e.id = "http://mapo.nexacenter.org/id/eventi/" + e.id;
    e.categoria = "http://mapo.nexacenter.org/id/eventi/categorie/" + e.categoria.replace(/ /g, '_');
    e.comune = "http://mapo.nexacenter.org/id/comuni/" + codIstat;
    eventArray.push(e);
});

fs.writeFileSync("data/eventi.json", JSON.stringify(eventArray, null, 4));
fs.writeFileSync("data/organizzazioni.json", JSON.stringify(orgArray, null, 4));
fs.writeFileSync("data/comuni.json", JSON.stringify(comuniArray, null, 4));