JavaScript ThingsBoard

Js将Json对象解析成key:value格式

ThingsBoard中通过网关遥测存入的数据必须是key:value格式的，不能包含json对象。所以编写了一个规则引擎处理逻辑。用于转换

Posted by felix on November 16, 2018

Js将Json对象解析成key:value格式

json对象：

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

{
    "FareGateFaultInfo": {
        "StatusInfo": {
            "StatusCode": "0",
            "MaintainsDateTime": "2017/01/01 01:01:01"
        },
        "DoorContinuous": {
            "-Name": "属性1",
            "FlapTotal": "0",
            "FlapUpdTime": "2017/02/02 02:02:02",
            "FaultCode": "001001001001000",
            "MaintainsDateTime": "2017/03/03 03:03:03"
        },
        "MagneticModule": [
            {
                "-Name": "属性2",
                "FaultCode": "001001001002000",
                "MaintainsDateTime": "2017/04/04 04:04:04"
            },
            {
                "-Name": "属性3",
                "FaultCode": "001001001002000",
                "MaintainsDateTime": "2017/05/05 05:05:05"
            }
        ],
        "SAMCard": {
            "-Name": "属性4",
            "FaultCode": "001001001003000",
            "MaintainsDateTime": "2017/06/06 06:06:06"
        },
        "CardReader": [
            {
                "-Name": "属性5",
                "FaultCode": "001001001004000",
                "MaintainsDateTime": "2017/07/07 07:07:07"
            },
            {
                "-Name": "属性6",
                "FaultCode": "001001001004000",
                "MaintainsDateTime": "2017/08/08 08:08:08"
            }
        ],
        "WriteDateTime": "2017/09/09  09:09:09"
    }
}

比对代码：

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

function convertKV(jsonObj, parentKey, result) {
    for (key in jsonObj) {
        var itemkey = key;
        var val = jsonObj[itemkey];
        // 对象
        if (isJson(val) == 1) {
            convertKV(val, parentKey + itemkey + ".", result);
        }
        // 数组
        else if (isJson(val) == 2) {
            for (var i = 0; i < val.length; i++) {
                var valElement = val[i];
                convertKV(valElement, parentKey + itemkey + i + ".", result);
            }
        }
        // 值
        else {
            result[parentKey + itemkey] = val;
        }
    }
}

function isJson(obj) {
    // json对象
    if (Object.prototype.toString.call(obj).toLowerCase() == "[object object]" && !obj.length) {
        return 1;
    } else
    // json数组
    if (typeof(obj) == "object" && obj.length) {
        return 2;
    }
    // 值
    else {
        return 0;
    }
}

调用

1
2

convertKV(data, "", result);
console.log(JSON.stringify(result));

返回值

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

{
    "FareGateFaultInfo.StatusInfo.StatusCode":"0",
    "FareGateFaultInfo.StatusInfo.MaintainsDateTime":"2017/01/01 01:01:01",
    "FareGateFaultInfo.DoorContinuous.-Name":"属性1",
    "FareGateFaultInfo.DoorContinuous.FlapTotal":"0",
    "FareGateFaultInfo.DoorContinuous.FlapUpdTime":"2017/02/02 02:02:02",
    "FareGateFaultInfo.DoorContinuous.FaultCode":"001001001001000",
    "FareGateFaultInfo.DoorContinuous.MaintainsDateTime":"2017/03/03 03:03:03",
    "FareGateFaultInfo.MagneticModule0.-Name":"属性2",
    "FareGateFaultInfo.MagneticModule0.FaultCode":"001001001002000",
    "FareGateFaultInfo.MagneticModule0.MaintainsDateTime":"2017/04/04 04:04:04",
    "FareGateFaultInfo.MagneticModule1.-Name":"属性3",
    "FareGateFaultInfo.MagneticModule1.FaultCode":"001001001002000",
    "FareGateFaultInfo.MagneticModule1.MaintainsDateTime":"2017/05/05 05:05:05",
    "FareGateFaultInfo.SAMCard.-Name":"属性4",
    "FareGateFaultInfo.SAMCard.FaultCode":"001001001003000",
    "FareGateFaultInfo.SAMCard.MaintainsDateTime":"2017/06/06 06:06:06",
    "FareGateFaultInfo.CardReader0.-Name":"属性5",
    "FareGateFaultInfo.CardReader0.FaultCode":"001001001004000",
    "FareGateFaultInfo.CardReader0.MaintainsDateTime":"2017/07/07 07:07:07",
    "FareGateFaultInfo.CardReader1.-Name":"属性6",
    "FareGateFaultInfo.CardReader1.FaultCode":"001001001004000",
    "FareGateFaultInfo.CardReader1.MaintainsDateTime":"2017/08/08 08:08:08",
    "FareGateFaultInfo.WriteDateTime":"2017/09/09 09:09:09"
}

升级版本：加入指定key值取name

比对代码

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

function convertKV(jsonObj, parentKey, keyName, result) {
    for (key in jsonObj) {
        var itemkey = key;
        var val = jsonObj[itemkey];
        // 对象
        if (isJson(val) == 1) {
            convertKV(val, parentKey + itemkey + ".", keyName, result);
        }
        // 数组
        else if (isJson(val) == 2) {
            for (var i = 0; i < val.length; i++) {
                var valElement = val[i];
                var item = i;
                if (valElement[keyName]) {
                    item = valElement[keyName];
                }
                convertKV(valElement, parentKey + itemkey + "." + item + ".", keyName, result);
            }
        }
        // 值
        else {
            result[parentKey + itemkey] = val;
        }
    }
}

function isJson(obj) {
    // json对象
    if (Object.prototype.toString.call(obj).toLowerCase() == "[object object]" && !obj.length) {
        return 1;
    } else
    // json数组
    if (typeof(obj) == "object" && obj.length) {
        return 2;
    }
    // 值
    else {
        return 0;
    }
}

返回值

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

{
    "FareGateFaultInfo.StatusInfo.StatusCode":"0",
    "FareGateFaultInfo.StatusInfo.MaintainsDateTime":"2017/01/01 01:01:01",
    "FareGateFaultInfo.DoorContinuous.-Name":"属性1",
    "FareGateFaultInfo.DoorContinuous.FlapTotal":"0",
    "FareGateFaultInfo.DoorContinuous.FlapUpdTime":"2017/02/02 02:02:02",
    "FareGateFaultInfo.DoorContinuous.FaultCode":"001001001001000",
    "FareGateFaultInfo.DoorContinuous.MaintainsDateTime":"2017/03/03 03:03:03",
    "FareGateFaultInfo.MagneticModule.属性2.-Name":"属性2",
    "FareGateFaultInfo.MagneticModule.属性2.FaultCode":"001001001002000",
    "FareGateFaultInfo.MagneticModule.属性2.MaintainsDateTime":"2017/04/04 04:04:04",
    "FareGateFaultInfo.MagneticModule.属性3.-Name":"属性3",
    "FareGateFaultInfo.MagneticModule.属性3.FaultCode":"001001001002000",
    "FareGateFaultInfo.MagneticModule.属性3.MaintainsDateTime":"2017/05/05 05:05:05",
    "FareGateFaultInfo.SAMCard.-Name":"属性4",
    "FareGateFaultInfo.SAMCard.FaultCode":"001001001003000",
    "FareGateFaultInfo.SAMCard.MaintainsDateTime":"2017/06/06 06:06:06",
    "FareGateFaultInfo.CardReader.属性5.-Name":"属性5",
    "FareGateFaultInfo.CardReader.属性5.FaultCode":"001001001004000",
    "FareGateFaultInfo.CardReader.属性5.MaintainsDateTime":"2017/07/07 07:07:07",
    "FareGateFaultInfo.CardReader.属性6.-Name":"属性6",
    "FareGateFaultInfo.CardReader.属性6.FaultCode":"001001001004000",
    "FareGateFaultInfo.CardReader.属性6.MaintainsDateTime":"2017/08/08 08:08:08",
    "FareGateFaultInfo.WriteDateTime":"2017/09/09 09:09:09"
}

修复Bug：如果是字符串则直接输出

json对象

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

{
    "ip": [
        "192.168.1.1",
        "192.168.1.2",
        "192.168.1.3",
        "192.168.1.4"
    ],
    "a": {
        "b": "2",
        "c": [{
            "d": 3
        }, {
            "e": 222
        }]
    }
}

上一版本转换结果

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

{
    "ip.0.0":"1",
    "ip.0.1":"9",
    "ip.0.2":"2",
    "ip.0.3":".",
    "ip.0.4":"1",
    "ip.0.5":"6",
    "ip.0.6":"8",
    "ip.0.7":".",
    "ip.0.8":"1",
    "ip.0.9":".",
    "ip.0.10":"1",
    "ip.1.0":"1",
    "ip.1.1":"9",
    "ip.1.2":"2",
    "ip.1.3":".",
    "ip.1.4":"1",
    "ip.1.5":"6",
    "ip.1.6":"8",
    "ip.1.7":".",
    "ip.1.8":"1",
    "ip.1.9":".",
    "ip.1.10":"2",
    "ip.2.0":"1",
    "ip.2.1":"9",
    "ip.2.2":"2",
    "ip.2.3":".",
    "ip.2.4":"1",
    "ip.2.5":"6",
    "ip.2.6":"8",
    "ip.2.7":".",
    "ip.2.8":"1",
    "ip.2.9":".",
    "ip.2.10":"3",
    "ip.3.0":"1",
    "ip.3.1":"9",
    "ip.3.2":"2",
    "ip.3.3":".",
    "ip.3.4":"1",
    "ip.3.5":"6",
    "ip.3.6":"8",
    "ip.3.7":".",
    "ip.3.8":"1",
    "ip.3.9":".",
    "ip.3.10":"4",
    "a.b":"2",
    "a.c.0.d":3,
    "a.c.1.e":222
}

把字符串数组也进行递归解析了

更新比对代码

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

function convertKV(jsonObj, parentKey, keyName, result) {
    if (isJson(jsonObj) == 0) {
        // 数组，取消分隔符
        result[parentKey.substring(0, parentKey.length - 1)] = jsonObj;
        return;
    }
    for (var key in jsonObj) {
        var itemkey = key;
        var val = jsonObj[itemkey];
        // 对象
        if (isJson(val) == 1) {
            convertKV(val, parentKey + itemkey + ".", keyName, result);
        }
        // 对象数组
        else if (isJson(val) == 2) {
            for (var i = 0; i < val.length; i++) {
                var valElement = val[i];
                var item = i;
                if (valElement[keyName]) {
                    item = valElement[keyName];
                }
                convertKV(valElement, parentKey + itemkey + "." + item + ".", keyName, result);
            }
        }
        // 值
        else {
            result[parentKey + itemkey] = val;
        }
    }
}

结果

1
2
3
4
5
6
7
8
9

{
    "ip.0":"192.168.1.1",
    "ip.1":"192.168.1.2",
    "ip.2":"192.168.1.3",
    "ip.3":"192.168.1.4",
    "a.b":"2",
    "a.c.0.d":3,
    "a.c.1.e":222
}
CATALOG
    FEATURED TAGS
    Test SpringBoot ThingsBoard IOT
    FRIENDS