提供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