1

# opcua/client.py

     2

     3

from __future__ import absolute_import

     4

     5

import os

     6

     7

from editors.ConfTreeNodeEditor import ConfTreeNodeEditor

     8

from PLCControler import LOCATION_CONFNODE, LOCATION_VAR_INPUT, LOCATION_VAR_OUTPUT

     9

from .opcua_client_maker import OPCUAClientPanel, OPCUAClientModel, UA_IEC_types

    10

    11

import util.paths as paths

    12

    13

# Paths to open62541 assume that 

    14

# - open62541 directory is aside beremiz directory

    15

# - open62541 was just built (not installed)

    16

    17

Open62541Path = paths.ThirdPartyPath("open62541")

    18

Open62541LibraryPath = os.path.join(Open62541Path,"build","bin") 

    19

Open62541IncludePaths = [os.path.join(Open62541Path, *dirs) for dirs in [

    20

    ("plugins","include"),

    21

    ("build","src_generated"),

    22

    ("include",),

    23

    ("arch",)]]

    24

    25

class OPCUAClientEditor(ConfTreeNodeEditor):

    26

    CONFNODEEDITOR_TABS = [

    27

        (_("OPC-UA Client"), "CreateOPCUAClient_UI")]

    28

    29

    def Log(self, msg):

    30

        self.Controler.GetCTRoot().logger.write(msg)

    31

    32

    def UriGetter(self):

    33

        return self.Controler.GetServerURI() 

    34

    35

    def CreateOPCUAClient_UI(self, parent):

    36

        return OPCUAClientPanel(parent, self.Controler.GetModelData(), self.Log, self.UriGetter)

    37

    38

class OPCUAClient(object):

    39

    XSD = """<?xml version="1.0" encoding="ISO-8859-1" ?>

    40

    <xsd:schema xmlns:xsd="http://www.w3.org/2001/XMLSchema">

    41

      <xsd:element name="OPCUAClient">

    42

        <xsd:complexType>

    43

          <xsd:attribute name="Server_URI" type="xsd:string" use="optional" default="opc.tcp://localhost:4840"/>

    44

        </xsd:complexType>

    45

      </xsd:element>

    46

    </xsd:schema>

    47

    """

    48

    49

    EditorType = OPCUAClientEditor

    50

    51

    def __init__(self):

    52

        self.modeldata = OPCUAClientModel()

    53

    54

        filepath = self.GetFileName()

    55

        if os.path.isfile(filepath):

    56

            self.modeldata.LoadCSV(filepath)

    57

    58

    def GetModelData(self):

    59

        return self.modeldata

    60

    61

    def GetServerURI(self):

    62

        return self.GetParamsAttributes("OPCUAClient.Server_URI")["value"]

    63

    64

    def GetFileName(self):

    65

        return os.path.join(self.CTNPath(), 'selected.csv')

    66

    67

    def OnCTNSave(self, from_project_path=None):

    68

        self.modeldata.SaveCSV(self.GetFileName())

    69

        return True

    70

    71

    def CTNGenerate_C(self, buildpath, locations):

    72

        current_location = self.GetCurrentLocation()

    73

        locstr = "_".join(map(str, current_location))

    74

        c_path = os.path.join(buildpath, "opcua_client__%s.c" % locstr)

    75

    76

        c_code = self.modeldata.GenerateC(c_path, locstr, 

    77

            self.GetParamsAttributes("OPCUAClient.Server_URI")["value"])

    78

    79

        with open(c_path, 'wb') as c_file:

    80

            c_file.write(c_code)

    81

    82

        LDFLAGS = [' "' + os.path.join(Open62541LibraryPath, "libopen62541.a") + '"']

    83

    84

        CFLAGS = ' '.join(['-I"' + path + '"' for path in Open62541IncludePaths])

    85

    86

        return [(c_path, CFLAGS)], LDFLAGS, True

    87

    88

    def GetVariableLocationTree(self):

    89

        current_location = self.GetCurrentLocation()

    90

        locstr = "_".join(map(str, current_location))

    91

        name = self.BaseParams.getName()

    92

        entries = []

    93

        for direction, data in self.modeldata.iteritems():

    94

            iec_direction_prefix = {"input": "__I", "output": "__Q"}[direction]

    95

            for row in data:

    96

                dname, ua_nsidx, ua_nodeid_type, _ua_node_id, ua_type, iec_number = row

    97

                iec_type, C_type, iec_size_prefix, ua_type_enum, ua_type = UA_IEC_types[ua_type]

    98

                c_loc_name = iec_direction_prefix + iec_size_prefix + locstr + "_" + str(iec_number)

    99

                entries.append({

   100

                    "name": dname,

   101

                    "type": {"input": LOCATION_VAR_INPUT, "output": LOCATION_VAR_OUTPUT}[direction],

   102

                    "size": {"X":1, "B":8, "W":16, "D":32, "L":64}[iec_size_prefix],

   103

                    "IEC_type": iec_type,

   104

                    "var_name": c_loc_name,

   105

                    "location": iec_size_prefix + ".".join([str(i) for i in current_location]) + "." + str(iec_number),

   106

                    "description": "",

   107

                    "children": []})

   108

        return {"name": name,

   109

                "type": LOCATION_CONFNODE,

   110

                "location": ".".join([str(i) for i in current_location]) + ".x",

   111

                "children": entries}

   112