# Write in PLC siemens using nodeS7

**URL:** <https://discourse.nodered.org/t/write-in-plc-siemens-using-nodes7/88405>\
**Category:** General\
**Created:** [31 May 2024 09:42 UTC](https://discourse.nodered.org/t/write-in-plc-siemens-using-nodes7/88405 "2024-05-31T09:42:32Z")\
**Posts on this page:** 5\
**Page:** 1

<div class="post-metadata">

**Author:** ![Mohamed\_1711](https://avatars.discourse-cdn.com/v4/letter/m/eb9ed0/32.png) [@Mohamed\_1711](https://discourse.nodered.org/u/Mohamed_1711)\
**Post date:** [31 May 2024 09:42 UTC](https://discourse.nodered.org/t/write-in-plc-siemens-using-nodes7/88405/1 "2024-05-31T09:42:32Z")

</div>

I made this flow for read data from PLC siemens and it works well [I used the nodes7 module]  
My issue is if I want to write how can I do this ??

I get the data and the structure that I will write in it from my database:  
the output of the database is :  
id IP rack slot port address  
4 172.31.51.5 0 3 102 DB247,WORD0  
4 172.31.51.5 0 3 102 DB247,WORD2  
4 172.31.51.5 0 3 102 DB247,DWORD4  
4 172.31.51.5 0 3 102 DB247,DWORD12  
4 172.31.51.5 0 3 102 DB247,WORD16  
4 172.31.51.5 0 3 102 DB247,WORD20  
4 172.31.51.5 0 3 102 DB247,WORD22  
4 172.31.51.5 0 3 102 DB247,WORD30  
4 172.31.51.5 0 3 102 DB247,WORD32  
4 172.31.51.5 0 3 102 DB247,DWORD64  
4 172.31.51.5 0 3 102 DB247,DWORD72  
4 172.31.51.5 0 3 102 DB247,WORD76  
4 172.31.51.5 0 3 102 DB247,WORD80  
4 172.31.51.5 0 3 102 DB247,WORD82  
4 172.31.51.5 0 3 102 DB247,WORD90  
4 172.31.51.5 0 3 102 DB247,WORD92  
4 172.31.51.5 0 3 102 DB247,DWORD124  
4 172.31.51.5 0 3 102 DB247,DWORD132  
4 172.31.51.5 0 3 102 DB247,WORD136  
4 172.31.51.5 0 3 102 DB247,WORD140  
4 172.31.51.5 0 3 102 DB247,WORD142  
4 172.31.51.5 0 3 102 DB247,WORD150  
4 172.31.51.5 0 3 102 DB247,WORD152  
4 172.31.51.5 0 3 102 DB247,DWORD184  
4 172.31.51.5 0 3 102 DB247,DWORD192  
4 172.31.51.5 0 3 102 DB247,WORD196  
4 172.31.51.5 0 3 102 DB247,WORD200  
4 172.31.51.5 0 3 102 DB247,WORD202  
4 172.31.51.5 0 3 102 DB247,WORD210  
4 172.31.51.5 0 3 102 DB247,WORD212  
4 172.31.51.5 0 3 102 DB247,DWORD244  
4 172.31.51.5 0 3 102 DB247,DWORD252  
4 172.31.51.5 0 3 102 DB247,WORD256  
4 172.31.51.5 0 3 102 DB247,WORD260  
4 172.31.51.5 0 3 102 DB247,WORD262  
4 172.31.51.5 0 3 102 DB247,WORD270  
4 172.31.51.5 0 3 102 DB247,WORD272  
4 172.31.51.5 0 3 102 DB247,DWORD304  
4 172.31.51.5 0 3 102 DB247,DWORD312  
4 172.31.51.5 0 3 102 DB247,WORD316  
4 172.31.51.5 0 3 102 DB247,WORD320  
4 172.31.51.5 0 3 102 DB247,WORD322  
4 172.31.51.5 0 3 102 DB247,WORD330  
4 172.31.51.5 0 3 102 DB247,WORD332  
4 172.31.51.5 0 3 102 DB247,DWORD364  
4 172.31.51.5 0 3 102 DB247,DWORD372  
4 172.31.51.5 0 3 102 DB247,WORD376  
4 172.31.51.5 0 3 102 DB247,WORD380  
4 172.31.51.5 0 3 102 DB247,WORD382  
4 172.31.51.5 0 3 102 DB247,WORD390  
4 172.31.51.5 0 3 102 DB247,WORD392  
4 172.31.51.5 0 3 102 DB247,DWORD424  
4 172.31.51.5 0 3 102 DB247,DWORD432  
4 172.31.51.5 0 3 102 DB247,WORD436  
4 172.31.51.5 0 3 102 DB247,WORD440  
4 172.31.51.5 0 3 102 DB247,WORD442  
4 172.31.51.5 0 3 102 DB247,WORD450  
4 172.31.51.5 0 3 102 DB247,WORD452  
4 172.31.51.5 0 3 102 DB247,DWORD484  
4 172.31.51.5 0 3 102 DB247,DWORD492  
4 172.31.51.5 0 3 102 DB247,WORD496  
4 172.31.51.5 0 3 102 DB247,WORD500  
4 172.31.51.5 0 3 102 DB247,WORD502  
4 172.31.51.5 0 3 102 DB247,WORD510  
4 172.31.51.5 0 3 102 DB247,WORD512  
4 172.31.51.5 0 3 102 DB247,DWORD544  
4 172.31.51.5 0 3 102 DB247,DWORD552  
4 172.31.51.5 0 3 102 DB247,WORD556  
4 172.31.51.5 0 3 102 DB247,WORD560  
4 172.31.51.5 0 3 102 DB247,WORD562  
4 172.31.51.5 0 3 102 DB247,WORD570  
4 172.31.51.5 0 3 102 DB247,WORD572  
4 172.31.51.5 0 3 102 DB247,WORD604

the Json Code :

```auto

[
    {
        "id": "508cdba203cf6e44",
        "type": "inject",
        "z": "2cbd64164b60e010",
        "name": "",
        "props": [
            {
                "p": "payload"
            },
            {
                "p": "topic",
                "vt": "str"
            }
        ],
        "repeat": "",
        "crontab": "",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "payload": "",
        "payloadType": "date",
        "x": 360,
        "y": 340,
        "wires": [
            [
                "f428c5dd30965452"
            ]
        ]
    },
    {
        "id": "5eb5b24d87e3d498",
        "type": "comment",
        "z": "2cbd64164b60e010",
        "name": "Reset Counter And Read Structure of Message Once",
        "info": "Reset Counter",
        "x": 810,
        "y": 240,
        "wires": []
    },
    {
        "id": "f428c5dd30965452",
        "type": "function",
        "z": "2cbd64164b60e010",
        "name": "MSG_1222",
        "func": "let node_Status = flow.get('NODE_STATUS_FIRE');\nlet node_Status_value = msg.node_Status_value\n\n\nif ((node_Status_value === 10) || (node_Status === undefined)) {\n msg.payload = \"\"\n\n let variablesToInitialize = [\n 'Allocated_Billets', 'Hold_Data_From_Database','NODE_STATUS_FIRE'\n];\n\n\n\n\n for (let variable of variablesToInitialize) {\n flow.set(variable, 0);\n }\n\n\n\n msg.payload = `SELECT\n HCP.ID AS id,\n HCP.IP AS ip,\n HCP.RACK AS rack,\n HCP.SLOT AS slot,\n HCP.PORT AS port,\n 'DB' + CAST(CMV.DATA_BLOCK AS varchar(200)) + ',' + CAST(CDBT.TYPE AS varchar(200)) + CAST(CMV.ADDRESS AS varchar(200)) AS address\nFROM [dbo].[CONFIGURATION_PLC] HCP\nLEFT OUTER JOIN [dbo].[CONFIGURATION_MESSAGE_VARIABLES] CMV ON HCP.ID = CMV.PLC_ID\nLEFT OUTER JOIN [dbo].[CONFIGURATION_DATA_BLOCK_TYPE] CDBT ON CMV.TYPE = CDBT.ID\nWHERE HCP.ENABLED = 1\n AND PLC_ID IN (4)\n AND CMV.TYPE <> 1\n AND (CMV.MESSAGE_NAME IN ('MSG_1222'))\n ORDER BY CMV.ID ASC;\n`\n\n\n return msg;\n}",
        "outputs": 1,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 650,
        "y": 340,
        "wires": [
            [
                "9a6703f45afa61b3"
            ]
        ]
    },
    {
        "id": "9a6703f45afa61b3",
        "type": "MSSQL",
        "z": "2cbd64164b60e010",
        "mssqlCN": "8e11ccb0.5a6eb",
        "name": "",
        "outField": "payload",
        "returnType": 0,
        "throwErrors": 1,
        "query": "",
        "modeOpt": "queryMode",
        "modeOptType": "query",
        "queryOpt": "payload",
        "queryOptType": "editor",
        "paramsOpt": "queryParams",
        "paramsOptType": "none",
        "rows": "rows",
        "rowsType": "msg",
        "parseMustache": true,
        "params": [],
        "x": 1000,
        "y": 340,
        "wires": [
            [
                "bc9622c95d65eea7"
            ]
        ]
    },
    {
        "id": "bc9622c95d65eea7",
        "type": "function",
        "z": "2cbd64164b60e010",
        "name": "Hold Data Structure",
        "func": "flow.set('Hold_Data_From_Database', flow.get('Hold_Data_From_Database') || msg.payload);\nreturn msg;",
        "outputs": 1,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 1270,
        "y": 340,
        "wires": [
            [
                "92cd43a533dae40a"
            ]
        ]
    },
    {
        "id": "53d5e932b6255bf9",
        "type": "function",
        "z": "2cbd64164b60e010",
        "name": "Set NODE_STATUS_FIRE ",
        "func": "flow.set('NODE_STATUS_FIRE', undefined)\n\n\nreturn msg;",
        "outputs": 1,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 800,
        "y": 120,
        "wires": [
            [
                "71143e694e9289b2"
            ]
        ]
    },
    {
        "id": "bd4440ac5c7a17a1",
        "type": "inject",
        "z": "2cbd64164b60e010",
        "name": "",
        "props": [
            {
                "p": "payload"
            },
            {
                "p": "topic",
                "vt": "str"
            }
        ],
        "repeat": "",
        "crontab": "",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "payload": "",
        "payloadType": "date",
        "x": 600,
        "y": 120,
        "wires": [
            [
                "53d5e932b6255bf9"
            ]
        ]
    },
    {
        "id": "71143e694e9289b2",
        "type": "debug",
        "z": "2cbd64164b60e010",
        "name": "debug 258",
        "active": false,
        "tosidebar": true,
        "console": false,
        "tostatus": false,
        "complete": "false",
        "statusVal": "",
        "statusType": "auto",
        "x": 1050,
        "y": 120,
        "wires": []
    },
    {
        "id": "3f976c218e6fd163",
        "type": "comment",
        "z": "2cbd64164b60e010",
        "name": "Set NODE_STATUS_FIRE with 0",
        "info": "Set NODE_STATUS_FIRE with 0",
        "x": 750,
        "y": 40,
        "wires": []
    },
    {
        "id": "0a5232eea47fa17a",
        "type": "debug",
        "z": "2cbd64164b60e010",
        "name": "Read Whole Message from PLC 1222",
        "active": true,
        "tosidebar": true,
        "console": false,
        "tostatus": false,
        "complete": "payload.var0",
        "targetType": "msg",
        "statusVal": "",
        "statusType": "auto",
        "x": 1470,
        "y": 640,
        "wires": []
    },
    {
        "id": "059c770775cb964b",
        "type": "function",
        "z": "2cbd64164b60e010",
        "name": "Open Connection and Write Data to PLC",
        "func": "let check_Node_Status = msg.node_Status_value\n\nif (check_Node_Status === 5) {\n\n\n let holdStructurefromDatabase = flow.get('Hold_Data_From_Database')\n\n let connPLCs = [...holdStructurefromDatabase]; // create a copy of holdStructurefromDatabase\n let dataReadfromPLC = [];\n\n\n // Remove the 'address' property from each object\n let connectionPLC_without_address = connPLCs.map(obj => {\n let newObj = { ...obj }; // create a copy of each object\n delete newObj.address; // remove the 'address' property from the copy\n return newObj;\n });\n\n // Remove duplicates from the array\n let connectionPLC = [...new Set(connectionPLC_without_address.map(JSON.stringify))].map(JSON.parse);\n\n for (let i = 0; i < connectionPLC.length; i++) {\n\n\n let connParam_linkID = connectionPLC[i].id;\n let connParam_Port = connectionPLC[i].port; //102;\n let connParam_IPAddress = connectionPLC[i].ip; //'192.168.150.10';\n let connParam_rack = connectionPLC[i].rack; //0;\n let connParam_slot = connectionPLC[i].slot;\n\n\n let conn = new nodes7;\n let doneReading = false;\n let doneWriting = false;\n\n let variables = getAddressesById(holdStructurefromDatabase, connectionPLC[i].id);\n let var_names = Object.keys(variables);\n\n dataReadfromPLC.push(var_names);\n\n conn.initiateConnection({ port: connParam_Port, host: connParam_IPAddress, rack: connParam_rack, slot: connParam_slot, debug: true }, connected); // slot 2 for 300/400, slot 1 for 1200/1500, change debug to true to get more info\n\n function connected(err) {\n if (typeof (err) !== \"undefined\") {\n console.log(err);\n }\n conn.setTranslationCB(function (tag) { return variables[tag]; }); // This sets the \"translation\" to allow us to work with object names\n conn.addItems(var_names);\n\nconsole.log('Here We Reached ');\n\n\n conn.readAllItems(valuesReady)\n }\n function valuesReady(anythingBad, values) {\n if (anythingBad) {\n node.warn(\"SOMETHING WENT WRONG READING VALUES!!!!\");\n conn.dropConnection();\n conn.connectionCleanup();\n }\n // console.log(values);\n msg.payload = values;\n // flow.set('PLC1_Data', values)\n node.send(msg);\n\n conn.dropConnection();\n conn.connectionCleanup();\n }\n\n }\n\n\n\n\n\n // return { payload: dataReadfromPLC }\n if (\n !(dataReadfromPLC.length === 1 && Array.isArray(dataReadfromPLC[0]) && dataReadfromPLC[0].length === 93)\n ) {\n return { payload: dataReadfromPLC };\n }\n\n}\n\n\n\n\nfunction getAddressesById(cfg, id) {\n // filter the array of objects to include only objects with the given id\n let filteredCfg = cfg.filter(obj => obj.id === id);\n\n //map the filtered objects to an array of only the \"address\" values\n let addresses = filteredCfg.map(obj => obj.address);\n\n // create an empty result object\n let result = {};\n\n //loop over the addresses array and add each address to the result object with a unique \"var\" key\n addresses.forEach((address, index) => {\n result[`var${index}`] = address;\n });\n\n //return the result object\n return result;\n}\n\n\n\n",
        "outputs": 1,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [
            {
                "var": "nodes7",
                "module": "nodes7"
            }
        ],
        "x": 840,
        "y": 640,
        "wires": [
            [
                "0a5232eea47fa17a"
            ]
        ]
    },
    {
        "id": "43ce51de65dd73bf",
        "type": "function",
        "z": "2cbd64164b60e010",
        "name": "Check_Node_Status",
        "func": "let node_Status = flow.get('NODE_STATUS_FIRE');\n\nif (node_Status === undefined) {\n msg.node_Status_value = 10;\n}\nelse {\n msg.node_Status_value = 5;\n}\n\n\nmsg.payload = node_Status\n\nreturn msg;",
        "outputs": 1,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 480,
        "y": 640,
        "wires": [
            [
                "059c770775cb964b",
                "f428c5dd30965452"
            ]
        ]
    },
    {
        "id": "92cd43a533dae40a",
        "type": "debug",
        "z": "2cbd64164b60e010",
        "name": "debug 259",
        "active": true,
        "tosidebar": true,
        "console": false,
        "tostatus": false,
        "complete": "false",
        "statusVal": "",
        "statusType": "auto",
        "x": 1490,
        "y": 340,
        "wires": []
    },
    {
        "id": "531461e7383f3676",
        "type": "comment",
        "z": "2cbd64164b60e010",
        "name": "Write Allocated Billets",
        "info": "Write Allocated Billets",
        "x": 780,
        "y": 500,
        "wires": []
    },
    {
        "id": "484965dde731ce1b",
        "type": "inject",
        "z": "2cbd64164b60e010",
        "name": "",
        "props": [
            {
                "p": "payload"
            },
            {
                "p": "topic",
                "vt": "str"
            }
        ],
        "repeat": "",
        "crontab": "",
        "once": false,
        "onceDelay": "1",
        "topic": "",
        "payload": "1",
        "payloadType": "num",
        "x": 270,
        "y": 640,
        "wires": [
            [
                "43ce51de65dd73bf"
            ]
        ]
    },
    {
        "id": "8e11ccb0.5a6eb",
        "type": "MSSQL-CN",
        "name": "TESR",
        "server": "172.31.51.100",
        "port": "1433",
        "encyption": false,
        "trustServerCertificate": false,
        "database": "SUEZSTEELRM_RML",
        "useUTC": false,
        "connectTimeout": "",
        "requestTimeout": "",
        "cancelTimeout": "",
        "pool": "",
        "parseJSON": false,
        "enableArithAbort": true
    }
]

```

---

<div class="post-metadata">

**Author:** ![marcus-j-davies](https://sea2.discourse-cdn.com/flex026/user_avatar/discourse.nodered.org/marcus-j-davies/32/103435_2.png) [@marcus-j-davies](https://discourse.nodered.org/u/marcus-j-davies)\
**Post date:** [31 May 2024 09:51 UTC](https://discourse.nodered.org/t/write-in-plc-siemens-using-nodes7/88405/2 "2024-05-31T09:51:22Z")

</div>

Hi @Mohamed_1711  
No one is going to be able to help, unless you format that code.

![Screenshot 2024-05-31 at 10.50.43](https://us1.discourse-cdn.com/flex026/uploads/nodered/original/3X/2/f/2f563f077ccf3718c395d8e670717fbabed70fe0.png)

````auto
```
JSON
```

````

---

<div class="post-metadata">

**Author:** ![E1cid](https://sea2.discourse-cdn.com/flex026/user_avatar/discourse.nodered.org/e1cid/32/77971_2.png) [@E1cid](https://discourse.nodered.org/u/E1cid)\
**Post date:** [31 May 2024 10:04 UTC](https://discourse.nodered.org/t/write-in-plc-siemens-using-nodes7/88405/3 "2024-05-31T10:04:25Z")

</div>

Just to note.  
In my browser the `</>` is hidden in the settings icon.

 ![Screenshot_20240531-110134](https://us1.discourse-cdn.com/flex026/uploads/nodered/original/3X/5/b/5b67236f3b56efeeb1924b3d681a028eaa71e6e4.png)

---

<div class="post-metadata">

**Author:** ![Mohamed\_1711](https://avatars.discourse-cdn.com/v4/letter/m/eb9ed0/32.png) [@Mohamed\_1711](https://discourse.nodered.org/u/Mohamed_1711)\
**Post date:** [31 May 2024 10:57 UTC](https://discourse.nodered.org/t/write-in-plc-siemens-using-nodes7/88405/4 "2024-05-31T10:57:47Z")

</div>

So Sorry for this ... the json File

```auto
[
    {
        "id": "508cdba203cf6e44",
        "type": "inject",
        "z": "2cbd64164b60e010",
        "name": "",
        "props": [
            {
                "p": "payload"
            },
            {
                "p": "topic",
                "vt": "str"
            }
        ],
        "repeat": "",
        "crontab": "",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "payload": "",
        "payloadType": "date",
        "x": 360,
        "y": 340,
        "wires": [
            [
                "f428c5dd30965452"
            ]
        ]
    },
    {
        "id": "5eb5b24d87e3d498",
        "type": "comment",
        "z": "2cbd64164b60e010",
        "name": "Reset Counter And Read Structure of Message Once",
        "info": "Reset Counter",
        "x": 810,
        "y": 240,
        "wires": []
    },
    {
        "id": "f428c5dd30965452",
        "type": "function",
        "z": "2cbd64164b60e010",
        "name": "MSG_1222",
        "func": "let node_Status = flow.get('NODE_STATUS_FIRE');\nlet node_Status_value = msg.node_Status_value\n\n\nif ((node_Status_value === 10) || (node_Status === undefined)) {\n msg.payload = \"\"\n\n let variablesToInitialize = [\n 'Allocated_Billets', 'Hold_Data_From_Database','NODE_STATUS_FIRE'\n];\n\n\n\n\n for (let variable of variablesToInitialize) {\n flow.set(variable, 0);\n }\n\n\n\n msg.payload = `SELECT\n HCP.ID AS id,\n HCP.IP AS ip,\n HCP.RACK AS rack,\n HCP.SLOT AS slot,\n HCP.PORT AS port,\n 'DB' + CAST(CMV.DATA_BLOCK AS varchar(200)) + ',' + CAST(CDBT.TYPE AS varchar(200)) + CAST(CMV.ADDRESS AS varchar(200)) AS address\nFROM [dbo].[CONFIGURATION_PLC] HCP\nLEFT OUTER JOIN [dbo].[CONFIGURATION_MESSAGE_VARIABLES] CMV ON HCP.ID = CMV.PLC_ID\nLEFT OUTER JOIN [dbo].[CONFIGURATION_DATA_BLOCK_TYPE] CDBT ON CMV.TYPE = CDBT.ID\nWHERE HCP.ENABLED = 1\n AND PLC_ID IN (4)\n AND CMV.TYPE <> 1\n AND (CMV.MESSAGE_NAME IN ('MSG_1222'))\n ORDER BY CMV.ID ASC;\n`\n\n\n return msg;\n}",
        "outputs": 1,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 650,
        "y": 340,
        "wires": [
            [
                "9a6703f45afa61b3"
            ]
        ]
    },
    {
        "id": "9a6703f45afa61b3",
        "type": "MSSQL",
        "z": "2cbd64164b60e010",
        "mssqlCN": "8e11ccb0.5a6eb",
        "name": "",
        "outField": "payload",
        "returnType": 0,
        "throwErrors": 1,
        "query": "",
        "modeOpt": "queryMode",
        "modeOptType": "query",
        "queryOpt": "payload",
        "queryOptType": "editor",
        "paramsOpt": "queryParams",
        "paramsOptType": "none",
        "rows": "rows",
        "rowsType": "msg",
        "parseMustache": true,
        "params": [],
        "x": 1000,
        "y": 340,
        "wires": [
            [
                "bc9622c95d65eea7"
            ]
        ]
    },
    {
        "id": "bc9622c95d65eea7",
        "type": "function",
        "z": "2cbd64164b60e010",
        "name": "Hold Data Structure",
        "func": "flow.set('Hold_Data_From_Database', flow.get('Hold_Data_From_Database') || msg.payload);\nreturn msg;",
        "outputs": 1,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 1270,
        "y": 340,
        "wires": [
            [
                "92cd43a533dae40a"
            ]
        ]
    },
    {
        "id": "53d5e932b6255bf9",
        "type": "function",
        "z": "2cbd64164b60e010",
        "name": "Set NODE_STATUS_FIRE ",
        "func": "flow.set('NODE_STATUS_FIRE', undefined)\n\n\nreturn msg;",
        "outputs": 1,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 800,
        "y": 120,
        "wires": [
            [
                "71143e694e9289b2"
            ]
        ]
    },
    {
        "id": "bd4440ac5c7a17a1",
        "type": "inject",
        "z": "2cbd64164b60e010",
        "name": "",
        "props": [
            {
                "p": "payload"
            },
            {
                "p": "topic",
                "vt": "str"
            }
        ],
        "repeat": "",
        "crontab": "",
        "once": false,
        "onceDelay": 0.1,
        "topic": "",
        "payload": "",
        "payloadType": "date",
        "x": 600,
        "y": 120,
        "wires": [
            [
                "53d5e932b6255bf9"
            ]
        ]
    },
    {
        "id": "71143e694e9289b2",
        "type": "debug",
        "z": "2cbd64164b60e010",
        "name": "debug 258",
        "active": false,
        "tosidebar": true,
        "console": false,
        "tostatus": false,
        "complete": "false",
        "statusVal": "",
        "statusType": "auto",
        "x": 1050,
        "y": 120,
        "wires": []
    },
    {
        "id": "3f976c218e6fd163",
        "type": "comment",
        "z": "2cbd64164b60e010",
        "name": "Set NODE_STATUS_FIRE with 0",
        "info": "Set NODE_STATUS_FIRE with 0",
        "x": 750,
        "y": 40,
        "wires": []
    },
    {
        "id": "0a5232eea47fa17a",
        "type": "debug",
        "z": "2cbd64164b60e010",
        "name": "Read Whole Message from PLC 1222",
        "active": true,
        "tosidebar": true,
        "console": false,
        "tostatus": false,
        "complete": "payload.var0",
        "targetType": "msg",
        "statusVal": "",
        "statusType": "auto",
        "x": 1470,
        "y": 640,
        "wires": []
    },
    {
        "id": "059c770775cb964b",
        "type": "function",
        "z": "2cbd64164b60e010",
        "name": "Open Connection and Write Data to PLC",
        "func": "let check_Node_Status = msg.node_Status_value\n\nif (check_Node_Status === 5) {\n\n\n let holdStructurefromDatabase = flow.get('Hold_Data_From_Database')\n\n let connPLCs = [...holdStructurefromDatabase]; // create a copy of holdStructurefromDatabase\n let dataReadfromPLC = [];\n\n\n // Remove the 'address' property from each object\n let connectionPLC_without_address = connPLCs.map(obj => {\n let newObj = { ...obj }; // create a copy of each object\n delete newObj.address; // remove the 'address' property from the copy\n return newObj;\n });\n\n // Remove duplicates from the array\n let connectionPLC = [...new Set(connectionPLC_without_address.map(JSON.stringify))].map(JSON.parse);\n\n for (let i = 0; i < connectionPLC.length; i++) {\n\n\n let connParam_linkID = connectionPLC[i].id;\n let connParam_Port = connectionPLC[i].port; //102;\n let connParam_IPAddress = connectionPLC[i].ip; //'192.168.150.10';\n let connParam_rack = connectionPLC[i].rack; //0;\n let connParam_slot = connectionPLC[i].slot;\n\n\n let conn = new nodes7;\n let doneReading = false;\n let doneWriting = false;\n\n let variables = getAddressesById(holdStructurefromDatabase, connectionPLC[i].id);\n let var_names = Object.keys(variables);\n\n dataReadfromPLC.push(var_names);\n\n conn.initiateConnection({ port: connParam_Port, host: connParam_IPAddress, rack: connParam_rack, slot: connParam_slot, debug: true }, connected); // slot 2 for 300/400, slot 1 for 1200/1500, change debug to true to get more info\n\n function connected(err) {\n if (typeof (err) !== \"undefined\") {\n console.log(err);\n }\n conn.setTranslationCB(function (tag) { return variables[tag]; }); // This sets the \"translation\" to allow us to work with object names\n conn.addItems(var_names);\n\nconsole.log('Here We Reached ');\n\n\n conn.readAllItems(valuesReady)\n }\n function valuesReady(anythingBad, values) {\n if (anythingBad) {\n node.warn(\"SOMETHING WENT WRONG READING VALUES!!!!\");\n conn.dropConnection();\n conn.connectionCleanup();\n }\n // console.log(values);\n msg.payload = values;\n // flow.set('PLC1_Data', values)\n node.send(msg);\n\n conn.dropConnection();\n conn.connectionCleanup();\n }\n\n }\n\n\n\n\n\n // return { payload: dataReadfromPLC }\n if (\n !(dataReadfromPLC.length === 1 && Array.isArray(dataReadfromPLC[0]) && dataReadfromPLC[0].length === 93)\n ) {\n return { payload: dataReadfromPLC };\n }\n\n}\n\n\n\n\nfunction getAddressesById(cfg, id) {\n // filter the array of objects to include only objects with the given id\n let filteredCfg = cfg.filter(obj => obj.id === id);\n\n //map the filtered objects to an array of only the \"address\" values\n let addresses = filteredCfg.map(obj => obj.address);\n\n // create an empty result object\n let result = {};\n\n //loop over the addresses array and add each address to the result object with a unique \"var\" key\n addresses.forEach((address, index) => {\n result[`var${index}`] = address;\n });\n\n //return the result object\n return result;\n}\n\n\n\n",
        "outputs": 1,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [
            {
                "var": "nodes7",
                "module": "nodes7"
            }
        ],
        "x": 840,
        "y": 640,
        "wires": [
            [
                "0a5232eea47fa17a"
            ]
        ]
    },
    {
        "id": "43ce51de65dd73bf",
        "type": "function",
        "z": "2cbd64164b60e010",
        "name": "Check_Node_Status",
        "func": "let node_Status = flow.get('NODE_STATUS_FIRE');\n\nif (node_Status === undefined) {\n msg.node_Status_value = 10;\n}\nelse {\n msg.node_Status_value = 5;\n}\n\n\nmsg.payload = node_Status\n\nreturn msg;",
        "outputs": 1,
        "noerr": 0,
        "initialize": "",
        "finalize": "",
        "libs": [],
        "x": 480,
        "y": 640,
        "wires": [
            [
                "059c770775cb964b",
                "f428c5dd30965452"
            ]
        ]
    },
    {
        "id": "92cd43a533dae40a",
        "type": "debug",
        "z": "2cbd64164b60e010",
        "name": "debug 259",
        "active": true,
        "tosidebar": true,
        "console": false,
        "tostatus": false,
        "complete": "false",
        "statusVal": "",
        "statusType": "auto",
        "x": 1490,
        "y": 340,
        "wires": []
    },
    {
        "id": "531461e7383f3676",
        "type": "comment",
        "z": "2cbd64164b60e010",
        "name": "Write Allocated Billets",
        "info": "Write Allocated Billets",
        "x": 780,
        "y": 500,
        "wires": []
    },
    {
        "id": "484965dde731ce1b",
        "type": "inject",
        "z": "2cbd64164b60e010",
        "name": "",
        "props": [
            {
                "p": "payload"
            },
            {
                "p": "topic",
                "vt": "str"
            }
        ],
        "repeat": "",
        "crontab": "",
        "once": false,
        "onceDelay": "1",
        "topic": "",
        "payload": "1",
        "payloadType": "num",
        "x": 270,
        "y": 640,
        "wires": [
            [
                "43ce51de65dd73bf"
            ]
        ]
    },
    {
        "id": "8e11ccb0.5a6eb",
        "type": "MSSQL-CN",
        "name": "TESR",
        "server": "172.31.51.100",
        "port": "1433",
        "encyption": false,
        "trustServerCertificate": false,
        "database": "SUEZSTEELRM_RML",
        "useUTC": false,
        "connectTimeout": "",
        "requestTimeout": "",
        "cancelTimeout": "",
        "pool": "",
        "parseJSON": false,
        "enableArithAbort": true
    }
]

```

[Json Data.txt](https://discourse.nodered.org/uploads/short-url/dE6r0E69Zvq237O3z4KvPWhzpGa.txt) (12.0 KB)

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/flex026/uploads/nodered/original/1X/d073cd938eafa2e558d7c2cd59003b3ef4963033.png) [@system](https://discourse.nodered.org/u/system)\
**Post date:** [29 August 2024 10:58 UTC](https://discourse.nodered.org/t/write-in-plc-siemens-using-nodes7/88405/5 "2024-08-29T10:58:40Z")

</div>

This topic was automatically closed 90 days after the last reply. New replies are no longer allowed.