在不同的 JSON 对象 node-red 中合并 3 个以上的 csv 文件

如何解决在不同的 JSON 对象 node-red 中合并 3 个以上的 csv 文件

我有一个包含多行的 main.csv 文件（现在我们可以假设有 3 行——第一行是标题，2 行是数据），每个数据行包含一些数据 + 对另一个 csv 文件的引用以及其他详细信息。我想逐行读取 main.csv 文件，从每一行获取文件名，从另一个 csv 文件获取详细信息，并为 main.csv 的每一行创建唯一的 JSON 对象。

我设法为 main.csv 的每一行创建了单独的对象，但是当我合并它们时，我得到第一个没有细节嵌套对象的 JSON 对象，第二个有两个细节对象。我的流程在这里：

[{"id":"c1e08c1e.09e96","type":"file in","z":"130a7976.464137","name":"","filename":"/home/ros_test/main.csv","format":"lines","chunk":false,"sendError":false,"encoding":"utf8","x":170,"y":180,"wires":[["cce2b9f5.cf50e"]]},{"id":"37206cf9.513154","type":"inject","name":"start","props":[{"p":"payload"},{"p":"topic","vt":"str"}],"repeat":"","crontab":"","once":true,"onceDelay":0.1,"topic":"","payload":"","payloadType":"date","x":110,"y":100,"wires":[["c1e08c1e.09e96"]]},{"id":"cce2b9f5.cf50e","type":"csv","sep":";","hdrin":true,"hdrout":"none","multi":"one","ret":"\\n","temp":"","skip":"0","strings":true,"include_empty_strings":"","include_null_values":"","x":370,"wires":[["175217cc.5791f"]]},{"id":"175217cc.5791f","type":"function","func":"var temp = msg.payload;\nvar jsonObj = {};\njsonObj.group = temp.Gruppo;\njsonObj.unit = temp.Unit;\njsonObj.name = temp.Nome;\njsonObj.pointInd = temp.IndicePunto;\njsonObj.point = temp.Punto;\njsonObj.date = temp.Data_Ora;\nvar nestedJsonObj = {};\nvar nesNestObj = {};\nnestedJsonObj.RMedia =  temp.RMedia;\nnestedJsonObj.IMedia = temp.IMedia;\nnestedJsonObj.Energia = temp.Energia;\nnestedJsonObj.Tempo = temp.Tempo;\nnestedJsonObj.punti = temp.punti;\nnestedJsonObj.Ravv = temp.Ravv;\nnestedJsonObj.ResistenzaIn = temp.ResistenzaIn;\nnestedJsonObj.ResistenzaF = temp.ResistenzaF;\nnestedJsonObj.ResistenzaMax = temp.ResistenzaMax;\nnestedJsonObj.ResistenzaMin = temp.ResistenzaMin;\nnestedJsonObj.IstDiMax = temp.IstDiMax;\nnestedJsonObj.TDiSalita = temp.TDiSalita;\nnestedJsonObj.IndCresc = temp.IndCresc;\nnestedJsonObj.TDiDisc = temp.TDiDisc;\nnestedJsonObj.IndDecr = temp.IndDecr;\nnestedJsonObj.DiffResMinMax = temp.DiffResMinMax;\nnestedJsonObj.DiffResMaxEnd = temp.DiffResMaxEnd;\nnestedJsonObj.IndSpruz = temp.IndSpruz;\njsonObj.message = nestedJsonObj;\n\nvar file_name=temp.NomeFile;\nconsole.log(\"TEMP =\" + JSON.stringify(jsonObj));\nmsg.payload = file_name;\nvar msg1 = {payload:jsonObj,topic:\"main\"};\n//var msg1 = jsonObj;\n\nreturn [msg,msg1];\n\n","outputs":2,"noerr":0,"initialize":"","finalize":"","x":520,"wires":[["f557afc2.257818"],["1c3a587a.e1fff8"]]},{"id":"5b915b21.4b0ae4","filename":"","x":770,"y":60,"wires":[["7520e51d.f51fd4"]]},{"id":"f557afc2.257818","type":"change","rules":[{"t":"set","p":"filename","pt":"msg","to":"payload","tot":"msg"}],"action":"","property":"","from":"","to":"","reg":false,"x":590,"wires":[["5b915b21.4b0ae4"]]},{"id":"cc445e4.e3abaa","name":"merge 2 parts","func":"var temp = msg.payload;\nvar mainPart = temp.main;\nvar details = temp.details;\nconsole.log(\"TEMP =\" + JSON.stringify(mainPart));\nconsole.log(\"Details =\" + JSON.stringify(details));\n/*var corrente = temp.Corrente;\nvar resistenza = temp.Resistenza;\nvar tensione = temp.Tensione;\nvar potenza = temp.Potenza;*/\n\nvar jsonObj = {};\njsonObj = mainPart;\njsonObj.message.details = details;\nconsole.log(\"OBJ =\" + JSON.stringify(jsonObj));\n\nreturn jsonObj;\n\n","outputs":1,"x":1020,"y":200,"wires":[[]]},{"id":"7520e51d.f51fd4","name":"csv to json","multi":"mult","x":930,"wires":[["bf9f2157.030ee"]]},{"id":"1c3a587a.e1fff8","type":"join","name":"json merge","mode":"custom","build":"object","property":"payload","propertyType":"msg","key":"topic","joiner":"{}","joinerType":"str","accumulate":true,"timeout":"","count":"1","reduceRight":false,"reduceExp":"","reduceInit":"","reduceInitType":"","reduceFixup":"","x":750,"wires":[["cc445e4.e3abaa","6787cd8b.97ee6c"]]},{"id":"bf9f2157.030ee","name":"set topic","p":"topic","to":"details","tot":"str"}],"x":1120,"wires":[["1c3a587a.e1fff8"]]},{"id":"6787cd8b.97ee6c","type":"debug","name":"TEST2","active":true,"tosidebar":true,"console":false,"tostatus":false,"complete":"true","targetType":"full","statusVal":"","statusType":"auto","x":920,"y":300,"wires":[]}]

main.csv 示例

Gruppo;Unit;Nome;NomeFile
5;1;PAZ50WB1;tbl_log_res_1420745212_0.csv
5;1;PAZ50WB1;tbl_log_res_1420763227_1.csv

tbl_log_res_1420745212_0.csv 示例

Corrente;Resistenza;Tensione;Potenza
0,717514;3987,835693;2,861328;2,053043
1,507996;1868,296387;2,817383;4,248601
2,237671;1197,970703;2,680664;5,998444

预期结果应该是两条消息，第一条消息是这样的：

{
"group": 5,"unit": 1,"name": "PAZ50WB1","details":[{ "Corrente":"0.717514","Resistenza":"3987.835693","Tensione":"2.861328","Potenza":"2.053043"
    },{
        "Corrente":"1.507996","Resistenza":"31868.296387","Tensione":"2.817383","Potenza":"4.248601"
    },{
        "Corrente":"2.237671","Resistenza":"1197.970703","Tensione":"2.680664","Potenza":"5.998444"
    }
    ]}
    

如何解决这个问题？