• 提供OpcUA 数据服务应用示例

    提供OpcUA 数据服务应用示例

    • 使用了opcua的Lua模块: open62541-lua
    • 作为OPCUA服务器
    • 发布所有设备的数据项

    代码:

    1. local class = require 'middleclass'
    2. local opcua = require 'opcua'
    4. --- 注册对象(请尽量使用唯一的标识字符串)
    5. local app = class("IOT_OPCUA_SERVER_APP")
    6. --- 设定应用最小运行接口版本(目前版本为1,为了以后的接口兼容性)
    7. app.API_VER = 1
    9. ---
    10. -- 应用对象初始化函数
    11. -- @param name: 应用本地安装名称。 如modbus_com_1
    12. -- @param sys: 系统sys接口对象。参考API文档中的sys接口说明
    13. -- @param conf: 应用配置参数。由安装配置中的json数据转换出来的数据对象
    14. function app:initialize(name, sys, conf)
    15.     self._name = name
    16.     self._sys = sys
    17.     self._conf = conf
    18.     --- 获取数据接口
    19.     self._api = sys:data_api()
    20.     --- 获取日志接口
    21.     self._log = sys:logger()
    22.     self._nodes = {}
    23. end
    25. --- 设定变量的默认值
    26. local default_vals = {
    27.     int = 0,
    28.     string = '',
    29. }
    31. --- 创建OPCUA变量
    32. -- @param idx: 命名空间
    33. -- @param devobj: 设备OPCUA对象
    34. -- @param input: 输入项名称
    35. -- @param device: 系统设备对象用以获取当前数值
    36. local function create_var(idx, devobj, input, device)
    37.     local var, err = devobj:getChild(input.name)
    38.     if var then
    39.         var:setDescription(opcua.LocalizedText.new('zh_CN', input.desc))
    40.         return var
    41.     end
    42.     local attr = opcua.VariableAttributes.new()
    43.     attr.displayName = opcua.LocalizedText.new("zh_CN", input.name)
    44.     if input.desc then
    45.         attr.description = opcua.LocalizedText.new("zh_CN", input.desc)
    46.     end
    48.     local current = device:get_input_prop(input.name, 'value')
    49.     local val = input.vt and default_vals[input.vt] or 0.0
    50.     attr.value = opcua.Variant.new(current or val)
    52.     return devobj:addVariable(opcua.NodeId.new(idx, 0), input.name, attr)
    53. end
    55. --- 设定变量的当前值
    56. -- @param var: OPCUA变量对象
    57. -- @param value: 变量的当前值
    58. -- @param timestamp: 时间戳
    59. -- @param quality: 质量戳
    60. local function set_var_value(var, value, timestamp, quality)
    61.     -- TODO: for timestamp and quality
    62.     var:setValue(opcua.Variant.new(value))
    64.     --[[
    65.     local val = opcua.DataValue.new(opcua.Variant.new(value))
    66.     val.status = quality
    67.     local tm = opcua.DateTime.fromUnixTime(math.floor(timestamp)) +  math.floor((timestamp%1) * 100) * 100000
    68.     val.sourceTimestamp = tm
    69.     --var.dataValue = val
    70.     var:setDataValue(val)
    71.     ]]--
    72. end
    74. --- 创建数据回调对象
    75. -- @param app: 应用实例对象
    76. local function create_handler(app)
    77.     local api = app._api
    78.     local server = app._server
    79.     local log = app._log
    80.     local idx = app._idx
    81.     local nodes = app._nodes
    82.     return {
    83.         --- 处理设备对象添加消息
    84.         on_add_device = function(app, sn, props)
    85.             --- 获取对象目录
    86.             local objects = server:getObjectsNode()
    87.             --- 使用设备SN来生成设备对象的ID
    88.             local id = opcua.NodeId.new(idx, sn)
    89.             local device = api:get_device(sn)
    91.             ---检测OPCUA对象是否已经存在
    92.             local devobj, err = objects:getChild(idx..":"..sn)
    93.             if not r or not devobj then
    94.                 --- 设备对象不存在增加设备对象
    95.                 local attr = opcua.ObjectAttributes.new()
    96.                 --- 设定显示名称
    97.                 attr.displayName = opcua.LocalizedText.new("zh_CN", "Device "..sn)
    98.                 --- 添加OPCUA对象
    99.                 devobj, err = objects:addObject(opcua.NodeId.new(idx, sn), sn, attr)
    100.                 if not devobj then
    101.                     log:warning('Create device object failed, error', devobj)
    102.                     return
    103.                 end
    104.             end
    106.             --- 记录设备对象
    107.             local node = nodes[sn] or {
    108.                 device = device,
    109.                 devobj = devobj,
    110.                 vars = {}
    111.             }
    112.             local vars = node.vars
    113.             --- 将设备的输入项映射成为OPCUA对象的变量
    114.             for i, input in ipairs(props.inputs) do
    115.                 local var = vars[input.name]
    116.                 if not var then
    117.                     vars[input.name] = create_var(idx, devobj, input, device)
    118.                 else
    119.                     --- 如果存在尝试修改变量描述
    120.                     var:setDescription(opcua.LocalizedText.new('zh_CN', input.desc))
    121.                 end
    122.             end
    123.             nodes[sn] = node
    124.         end,
    125.         --- 处理设备对象删除消息
    126.         on_del_device = function(app, sn)
    127.             local node = nodes[sn]
    128.             if node then
    129.                 --- 删除设备对象
    130.                 server:deleteNode(node.devobj.id, true)
    131.                 nodes[sn] = nil
    132.             end
    133.         end,
    134.         --- 处理设备对象修改消息
    135.         on_mod_device = function(app, sn, props)
    136.             local node = nodes[sn]
    137.             if not node or not node.vars then
    138.                 -- TODO:
    139.             end
    140.             local vars = node.vars
    141.             for i, input in ipairs(props.inputs) do
    142.                 local var = vars[input.name]
    143.                 ---不存在就增加变量，存在则修改描述，确保描述一致
    144.                 if not var then
    145.                     vars[input.name] = create_var(idx, node.devobj, input, node.device)
    146.                 else
    147.                     var:setDescription(opcua.LocalizedText.new('zh_CN', input.desc))
    148.                 end
    149.             end
    150.         end,
    151.         --- 处理设备输入项数值变更消息
    152.         on_input = function(app, sn, input, prop, value, timestamp, quality)
    153.             local node = nodes[sn]
    154.             if not node or not node.vars then
    155.                 log:error("Unknown sn", sn)
    156.                 return
    157.             end
    158.             --- 设定OPCUA变量的当前值
    159.             local var = node.vars[input]
    160.             if var and prop == 'value' then
    161.                 set_var_value(var, value, timestamp, quality)
    162.             end
    163.         end,
    164.     }
    165. end
    167. --- 应用启动函数
    168. function app:start()
    169.     --- 处理OPCUA模块的日志
    170.     local Level_Funcs = {}
    171.     Level_Funcs[opcua.LogLevel.TRACE] = assert(self._log.trace)
    172.     Level_Funcs[opcua.LogLevel.DEBUG] = assert(self._log.debug)
    173.     Level_Funcs[opcua.LogLevel.INFO] = assert(self._log.info)
    174.     Level_Funcs[opcua.LogLevel.WARNING] = assert(self._log.warning)
    175.     Level_Funcs[opcua.LogLevel.ERROR] = assert(self._log.error)
    176.     Level_Funcs[opcua.LogLevel.FATAL] = assert(self._log.fatal)
    177.     Category_Names = {}
    178.     Category_Names[opcua.LogCategory.NETWORK] = "network"
    179.     Category_Names[opcua.LogCategory.SECURECHANNEL] = "channel"
    180.     Category_Names[opcua.LogCategory.SESSION] = "session"
    181.     Category_Names[opcua.LogCategory.SERVER] = "server"
    182.     Category_Names[opcua.LogCategory.CLIENT] = "client"
    183.     Category_Names[opcua.LogCategory.USERLAND] = "userland"
    184.     Category_Names[opcua.LogCategory.SECURITYPOLICY] = "securitypolicy"
    186.     self._logger = function(level, category, ...)
    187.         Level_Funcs[level](self._log, Category_Names[category], ...)
    188.     end
    189.     opcua.setLogger(self._logger)
    191.     --- 生成OPCUA服务器实例
    192.     local server = opcua.Server.new()
    194.     --- 设定服务器地址
    195.     server.config:setServerURI("urn:://opcua.symid.com")
    197.     --- 添加命名空间
    198.     local id = self._sys:id()
    199.     local idx = server:addNamespace("http://iot.symid.com/"..id)
    201.     self._server = server
    202.     self._idx = idx
    203.     --- 设定回调处理对象
    204.     self._handler = create_handler(self)
    205.     self._api:set_handler(self._handler, true)
    207.     --- List all devices and then create opcua object
    208.     self._sys:fork(function()
    209.         local devs = self._api:list_devices() or {}
    210.         for sn, props in pairs(devs) do
    211.             --- Calling handler for creating opcua object
    212.             self._handler.on_add_device(self, sn, props)
    213.         end
    214.     end)
    216.     --- 启动服务器
    217.     server:startup()
    219.     self._log:notice("Started!!!!")
    220.     return true
    221. end
    223. --- 应用退出函数
    224. function app:close(reason)
    225.     self._server:shutdown()
    226.     self._server = nil
    227. end
    229. --- 应用运行入口
    230. function app:run(tms)
    231.     --- OPCUA模块运行入口
    232.     while self._server.running do
    233.         local ms = self._server:run_once(false)
    234.         --- 暂停OPCUA模块运行，处理FreeIOE系统消息
    235.         self._sys:sleep(ms % 10)
    236.     end
    237.     print('XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX')
    239.     return 1000
    240. end
    242. --- 返回应用对象
    243. return app