--[[
    创建日期： 2021-9-3
    创建人：   HAN

    功能:
        一些常用的和数据处理相关 Lua 函数

    函数:


    变更记录:
    
--]]

lua   = require ("oi_base_func")
mobox = require ("OILua_JavelinExt")

local m3 = {_version = "0.1.1"} -- 定义一个空表，用于存储模块的函数和变量

-- 把 [{"attr":"a1","value":"xxx"},..] 的json对象转成 {"a1":"xxx","b1":"xxx"}
function m3.KeyValueAttrsToObjAttr( attrs )
    local n, nCount

    if ( type(attrs) ~= "table" ) then error( "KeyValueAttrsToObjAttr的输入参数必须是table" ) end
    nCount = #attrs
    local objattr = {}

    if (nCount == 0) then return nil end
    for n = 1, nCount do
        if (attrs[n].attr ~= '') then
            objattr[attrs[n].attr] = attrs[n].value
        end
    end
    return objattr
end

-- 导出数据类标识 = cls_id 条件满足 condition 的数据对象到文件 fn 中，导出的数据集的顺序为 order
function m3.OI_DataObject_Export( strLuaDEID, fn, cls_id, condition, order )
    local nRet, strRetInfo

    if ( fn == nil ) then return 1, "OI_DataObject_Export 中参数 file_io 不能为空" end
    if ( cls_id == nil or cls_id == '') then return 1, "OI_DataObject_Export 中参数 cls_id不能为空" end
    if ( condition == nil ) then condition = '' end
    if ( order == nil ) then order = '' end

    -- 获取数据对象数量大于1000因此采用 queryDataObjAttr2      
    nRet, strRetInfo = mobox.queryDataObjAttr2( strLuaDEID, cls_id, condition, order, 100 )
    if ( nRet ~= 0 ) then return 2, "queryDataObjAttr2: "..strRetInfo end  
    if ( strRetInfo == '' ) then return 0 end 

    local success, queryInfo
    success, queryInfo = pcall( json.decode, strRetInfo )
    if ( success == false ) then return 2, "queryDataObjAttr2 返回非法的JSON字符串!" end

    local queryID = queryInfo.queryID
    local nPageCount = queryInfo.pageCount
    local nPage = 1
    local dataSet = queryInfo.dataSet       -- 查询出来的数据集
    local data_obj_json = {}

    while (nPage <= nPageCount) do

        for i = 1, #dataSet do
            obj_attrs = m3.KeyValueAttrsToObjAttr(dataSet[i].attrs)  
            obj_attrs.cls_id = cls_id
            obj_attrs.obj_id = dataSet[i].id
            fn:write( lua.table2str(obj_attrs).."\n" )          
        end

        nPage = nPage + 1
        if ( nPage <= nPageCount ) then
            -- 取下一页
            nRet, strRetInfo = mobox.queryDataObjAttr2( queryID, nPage)
            if ( nRet ~= 0 ) then
                return 2, "queryDataObjAttr2失败! nPage="..nPage.."  "..strRetInfo
            end 
            queryInfo = json.decode(strRetInfo) 
            dataSet = queryInfo.dataSet 
        end
    end  
    return 0        
end

-- 导入用 OI_DataObject_Export 导出的数据
function m3.OI_DataObject_Import( strLuaDEID, import_file )
    local nRet, strRetInfo

    if ( import_file == nil or import_file == '') then
        return 1, "导入文件名不能为空!"
    end

    local str_line
    local success, data_attrs_json
    local data_obj = {}
    local n = 1
    for str_line in io.lines( import_file ) do
        if ( str_line ~= nil and str_line ~= '' ) then
            success, data_attrs_json = pcall( json.decode, str_line )
            if ( success == false ) then return 2, "导入的数据文件格式不是 DataObject 类型!" end  
            if ( data_attrs_json.cls_id == nil or data_attrs_json.cls_id == '' ) then
                return 2, "导入的数据文件格式不是 DataObject 类型!"
            end

            data_obj = mobox.objJsonToObjAttr( data_attrs_json.cls_id, lua.table2str( data_attrs ))
            nRet, strRetInfo = mobox.createDataObj( strLuaDEID, data_attrs_json.cls_id, data_obj, 0 )  
            if ( nRet ~= 0 ) then
                lua.Debug( strLuaDEID, debug.getinfo(1), "OI_DataObject_Import lua.Error In Line"..n )
                return 2, "创建'"..data_attrs_json.cls_id.."'时失败! "..strRetInfo
            end
            n = n + 1
        end
    end    
end

-- 获取当前Lua环境中的DataJson，并且转换成Json对象
function m3.GetSysDataJson( strLuaDEID )
    local nRet, strDataJson

    nRet, strDataJson = mobox.getCurEditDataPacket( strLuaDEID )
    if ( nRet ~=0 ) then
        return nRet, "无法获取Lua数据包!"
    end  
    if ( strDataJson == '' ) then
        return 2, "Lua数据包为空!"
    end
    local jsonObj, success
    success, jsonObj = pcall( json.decode, strDataJson)
    if ( success == false ) then
        return 2, "Lua数据包的JSON格式非法! 原因:"..jsonObj..'  --> '..strDataJson
    end
    return 0, jsonObj
end

-- 获取当前Lua环境中的全局变量，并且转换成Json对象
function m3.GetSysGloablAttr( strLuaDEID )
    local nRet, strGlobalAttr
    nRet, strGlobalAttr = mobox.getGlobalAttr2( strLuaDEID )
    if ( nRet ~=0 ) then return 2, "无法获取Lua中的全局变量!"  end  
    if ( strGlobalAttr == '' ) then return 0, "" end  
    local global_attr, success
    success, global_attr = pcall( json.decode, strGlobalAttr)
    if ( success == false ) then return 2, "Lua数据包的JSON格式非法! 原因:"..global_attr..'  --> '..strDataJson end
    return 0, global_attr
end

-- 获取外部输入的参数，并且把参数转化成 [{"attr":"a1","value":"xxx"},..]的json对象
-- 注意返回的是Json对象
function m3.GetSysInputParameter( strLuaDEID )
    local nRet, strRetInfo
    nRet, strRetInfo = mobox.getInputParameter2(strLuaDEID)
    if (nRet ~= 0) then
        return nRet, "getInputParameter2 失败!"
    end
    if ( strRetInfo == '') then return 0, "" end
    local attrs, success
    success, attrs = pcall( json.decode, strRetInfo )
    if ( success == false ) then
        return nRet, "外部输入参数的Json格式非法!"..strRetInfo
    end
    return 0, attrs
end

-- 获取当前运行环境参数
function m3.GetRuntimeParam( strLuaDEID )
   local nRet, strRetInfo

   nRet, strRetInfo = mobox.getCurEditExtInfo(strLuaDEID)
   if (nRet ~= 0) then
       return nRet, "getCurEditExtInfo 失败!"
   end
   if ( strRetInfo == '') then return 0, "" end
   local attrs, success
   success, attrs = pcall( json.decode, strRetInfo )
   if ( success == false ) then
       return nRet, "运行环境参数的Json格式非法!"..strRetInfo
   end
   return 0, attrs
end

-- 获取当前运行环境参数中的面板输入参数
-- 根据运行时环境参数中的 panel 属性，获取名为 XX 的面板的输入长胡是
-- 返回 1 表示不存在，2 表示错误
function m3.GetRuntimePanel_InputParamter( strLuaDEID, panel, panel_name )
   local nRet, strRetInfo

   if ( panel == nil or type(panel) ~= "table" ) then
       return 2, "GetRuntimePanel_InputParamter 函数的输入参数错误， panel 必须有值而且必须是 table 对象!"
   end

   if ( panel_name == nil or type(panel_name) ~= "string" ) then
       return 2, "GetRuntimePanel_InputParamter 函数的输入参数错误， panel_name 必须有值而且必须是字符串!"
   end    
   local  n

   for n = 1, #panel do
       if ( panel[n].panel_name == panel_name ) then
           return 0, panel[n].input_parameter
       end
   end
   return 1, "运行时环境参数中不存在名为 '"..panel_name.."'的面板输入参数!"
end


-- 获取外部输入的参数参数格式是某个数据类的属性键值对 [{"attr":"a1","value":"xxx"},..]
-- 直接转成Lua对象
function m3.SysInputParamToDataObj( strLuaDEID, strClsID )
   local nRet, strRetInfo

   if  ( strClsID == nil or strClsID == '' ) then return 1, "SysInputParamToLuaObj 函数中 strClsID 不能为空或nil!" end

   nRet, strRetInfo = mobox.getInputParameter2(strLuaDEID)
   if (nRet ~= 0) then return 1, "getInputParameter2 失败!" end
   -- 把 [{"attr":"xxx","value":""},...] 转换成 json object
   local strObjJson
   nRet, strObjJson = mobox.objAttrsToLuaJson( strClsID, strRetInfo )
   if ( nRet ~= 0  ) then return 1, "objAttrsToLuaJson 转 "..strClsID.." 失败! "..strObjJson end
   local success
   local luaObj
   success, luaObj = pcall( json.decode, strObjJson )
   if ( success == false ) then return 1, "objAttrsToLuaJson 转 "..strClsID.." 返回的的JSON格式不合法 !"..luaObj  end

   return 0, luaObj
end


-- 如果 attrs 是多表联查返回的，一般属性上会带 a. 如  a.S_ITEM_CODE
-- 通过这个函数会转成  {a_S_ITEM_CODE ="xxx"}
function m3.KeyValueAttrsToObjAttr2( attrs )
   local n, nCount

   if ( type(attrs) ~= "table" ) then error( "KeyValueAttrsToObjAttr的输入参数必须是table" ) end
   nCount = #attrs
   local objattr = {}
   local attr
   
   if (nCount == 0) then return nil end
   for n = 1, nCount do
       if (attrs[n].attr ~= '') then
         attr = attrs[n].attr
         attr = string.gsub( attr,"%.","_")
         objattr[attr] = attrs[n].value
       end
   end
   return objattr
end

-- 获取当前Lua数据交换区里的当前编辑对象属性，并且把参数转化成 [{"attr":"a1","value":"xxx"},..]一个table
-- 如：{"a1":xxx,"b1":"xxx"}
function m3.GetSysCurEditDataAttrs(strLuaDEID)
    local nRet, strRetInfo

    nRet, strRetInfo = mobox.getCurEditDataObjAttr(strLuaDEID)
    if (nRet ~= 0 ) then
        return nRet, "getCurEditDataObjAttr 失败! "
    end
    if ( strRetInfo == '') then 
        return nRet,  "当前编辑数据对象属性为空!"
    end
    local attrs, success
    success, attrs = pcall( json.decode, strRetInfo )
    if ( success == false ) then
        return nRet, "当前编辑数据对象属性的Json格式非法!"..strRetInfo
    end
    local obj_attrs = m3.KeyValueAttrsToObjAttr(attrs)

    return 0, obj_attrs
end

-- 获取当前Lua数据交换区里的当前编辑对象属性中的一个名为 attr_name 的属性值，返回一个字符串值
function m3.GetSysCurEditDataOneAttr(strLuaDEID, attr_name )
   local nRet, strRetInfo
    nRet, strRetInfo = mobox.getCurEditDataObjAttr( strLuaDEID, attr_name )
    if (nRet ~= 0 or  strRetInfo == '') then return 2, "无法获取当前编辑对象中的名为'"..attr_name.."'的值!" end
    local retAttrs = json.decode(strRetInfo)
    return 0, retAttrs[1].value
end

-- 获取当前Lua数据交换区里的当前编辑对象属性，并且把参数转化成 Json 对象
-- 注意返回的是Json对象
function m3.GetSysCurEditDataObj( strLuaDEID, strClsID )
    local nRet, strRetInfo, strErr

    strErr = ''
    strClsID = lua.trim(strClsID)

    nRet, strRetInfo = mobox.getCurEditDataObjAttr( strLuaDEID )
    if ( nRet ~= 0 or strRetInfo == '') then
        strErr = "getCurEditDataObjID 失败!"..strRetInfo
        return 2, strErr
    end
    local strObjJson
    nRet, strObjJson = mobox.objAttrsToLuaJson( strClsID, strRetInfo )
    if ( nRet ~= 0  ) then
        strErr = "objAttrsToLuaJson 失败! 数据类标识 = "..strClsID.." 原因:"..strObjJson
        return 2, strErr
    end

    local obj, success
    success, obj = pcall( json.decode, strObjJson )
    if ( success == false ) then
        strErr = "objAttrsToLuaJson 返回的的JSON格式不合法 ! 数据类标识 = "..strClsID.." 原因:"..obj
        return 2, strErr
    end

    local strClsID, strObjID
    nRet, strClsID, strObjID = mobox.getCurEditDataObjID( strLuaDEID )
    if ( nRet == 0 ) then
        obj.id = strObjID
        obj.cls = strClsID
    end

    return 0, obj
end

-- 获取当前Lua数据交换区里的当前编辑对象属性在变化前的属性，并且把参数转化成 Json 对象
-- 注意返回的是Json对象
function m3.GetSysCurEditOldDataObj( strLuaDEID, strClsID )
   local nRet, strRetInfo, strErr

   strErr = ''
   strClsID = lua.trim(strClsID)

   nRet, strRetInfo = mobox.getCurEditOldDataObjAttr( strLuaDEID )
   if ( nRet ~= 0 or strRetInfo == '') then
       strErr = "getCurEditDataObjID 失败!"..strRetInfo
       return 2, strErr
   end
   local strObjJson
   nRet, strObjJson = mobox.objAttrsToLuaJson( strClsID, strRetInfo )
   if ( nRet ~= 0  ) then
       strErr = "objAttrsToLuaJson 失败! 数据类标识 = "..strClsID.." 原因:"..strObjJson
       return 2, strErr
   end

   local obj, success
   success, obj = pcall( json.decode, strObjJson )
   if ( success == false ) then
       strErr = "objAttrsToLuaJson 返回的的JSON格式不合法 ! 数据类标识 = "..strClsID.." 原因:"..obj
       return 2, strErr
   end

   return 0, obj
end

-- 获取当前登录人员所属单位标识/编码
function m3.GetMyFactory( strLuaDEID )
    local strUserLogin, strUserName, nRet
    nRet, strUserLogin, strUserName = mobox.getCurUserInfo( strLuaDEID )
    if ( nRet ~= 0 ) then return 2, "获取当前操作人员信息失败! "..strUserLogin end
    -- 获取当前操作人员的单位编码，作为工厂标识
    nRet, strRetInfo = mobox.getUserSectionUnit( strUserLogin )
    if ( nRet ~= 0 ) then return 2, "获取当前操作人员所属单位失败! "..strRetInfo end
    local factory = ''
    if ( strRetInfo ~= '' ) then
       local orgInfo = json.decode( strRetInfo ) 
       factory = orgInfo.company_code
    end
    return 0, factory
end

-- 分配一个数据类对象，属性为缺省值
function m3.AllocObject( strLuaDEID, strClsID )
   local nRet, strJson

   strClsID = lua.trim(strClsID)
   nRet, strJson = mobox.allocObject(strClsID)
   if (nRet ~= 0 ) then
       lua.Error( strLuaDEID, debug.getinfo(1), "allocObject失败:"..strJson )
   end

   local object, success
   success, object = pcall( json.decode, strJson )
   if ( success == false ) then
       lua.Error( strLuaDEID, debug.getinfo(1), "allocObject("..strClsID..") 返回的的JSON格式不合法!" )
   end
   return object
end

--[[ 
   查询数据对象
   参数：
       strClsID 数据类标识
       strCondition 查询条件
       [strOrder] 排序，可以不输入
   返回2个参数
       第一个参数：非零表示错误，0 表示成功
       第二个参数：如果第一个参数是非零，第二个参数是错误信息
                  否则，第二个参数的是一个数据对象数组
                  [{"id"："","attrs":[{"attr":"S_CODE","value":""},...]}]

--]]
function m3.QueryDataObject( strLuaDEID, strClsID, strCondition, strOrder )
   local nRet, strRetInfo
   -- 参数检查
   if ( strClsID == nil or strClsID == '' ) then 
       return 1, "QueryDataObject 中 strClsID 不能为空!"
   end  
   if ( strCondition == nil ) then  strCondition =  "" end 
   if ( strOrder == nil ) then strOrder = '' end

   nRet, strRetInfo = mobox.queryDataObjAttr(strLuaDEID, strClsID, strCondition, strOrder)
   if ( nRet ~= 0  ) then
       return nRet, "queryDataObjAttr 发生错误!"..strRetInfo
   end

   if ( strRetInfo == '' ) then return 0, "" end

   local objects, success
   success, objects = pcall( json.decode, strRetInfo )
   if ( success == false ) then
       return 2, "queryDataObjAttr 返回的的JSON格式不合法!"
   end
   return 0, objects      
end

--[[ 
   查询数据对象
   参数：
       strClsID 数据类标识
       strCondition 查询条件
       [strOrder] 排序，可以不输入
       [count] 查询记录条数，默认1000

   返回2个参数
       第一个参数：非零表示错误，0 表示成功
       第二个参数：如果第一个参数是非零，第二个参数是错误信息
                  否则，第二个参数的是一个数据对象数组
                  [{"id"："","attrs":[{"attr":"S_CODE","value":""},...]}]

--]]
function m3.QueryDataObject3( strLuaDEID, strClsID, strCondition, strOrder, count )
   local nRet, strRetInfo
   -- 参数检查
   if ( strClsID == nil or strClsID == '' ) then 
       return 1, "QueryDataObject 中 strClsID 不能为空!"
   end  
   if ( strCondition == nil or strCondition == '' ) then 
       return 1, "QueryDataObject 中 strCondition 不能为空!"
   end 
   if ( strOrder == nil ) then strOrder = '' end
   if ( count == nil or  count <= 0 ) then count = 1000 end

   nRet, strRetInfo = mobox.queryDataObjAttr3(strLuaDEID, strClsID, strCondition, count, strOrder)
   if ( nRet ~= 0  ) then
       return nRet, "queryDataObjAttr3 发生错误!"..strRetInfo
   end

   if ( strRetInfo == '' ) then return 0, "" end

   local objects, success
   success, objects = pcall( json.decode, strRetInfo )
   if ( success == false ) then
       return 2, "queryDataObjAttr3 返回的的JSON格式不合法!"
   end
   return 0, objects      
end

--[[ 
   获取对象属性，返回数据类定义的Lua属性
   返回 1 表示不存在
--]]
function m3.GetDataObjectByKey( strLuaDEID, cls_id, key_attr, key_value )
   -- 参数检查
   if ( cls_id == nil or cls_id == '' ) then 
       return 2, "GetDataObjectByKey 中 cls_id 不能为空!"
   end  
   if ( key_attr == nil or key_attr == '' ) then 
       return 2, "GetDataObjectByKey 中 key_attr 不能为空!"
   end             
   if ( key_value == nil or key_value == '' ) then
       return 2, "GetDataObjectByKey 中 key_value 不能为空!"
   end

   local nRet, strRetInfo, id
   local strCondition = key_attr.." = '"..key_value.."'"
   nRet, id, strRetInfo = mobox.getDataObjAttrByKeyAttr( strLuaDEID, cls_id, strCondition )

   if ( nRet == 1 ) then
       return 1, key_attr.."='"..key_value.."'的"..cls_id.."不存在!"
   end
   if ( nRet ~= 0  ) then
       return 2, "getDataObjAttrByKeyAttr 发生错误!"..id
   end

   local strJson
   nRet, strJson = mobox.objAttrsToLuaJson( cls_id, strRetInfo )
   if ( nRet ~= 0  ) then
       return 2, "objAttrsToLuaJson Supplier 失败!"..strJson
   end

   local object, success
   success, object = pcall( json.decode, strJson )
   if ( success == false ) then
       return 2, "objAttrsToLuaJson 返回的的JSON格式不合法!"
   end
   object.id = id
   object.cls = cls_id
   return 0, object
end

--[[ 
   根据数据类标识和数据对象标识获取对象属性，返回数据类定义的Lua属性

   返回值：
   nRet 0 正确 1 对象不存在 > 1 错误
   object 
--]]
function m3.GetDataObject( strLuaDEID, cls_id, obj_id )

   -- 参数检查
   if ( cls_id == nil or cls_id == '' ) then 
       return 1, "GetDataObjInfo 中 cls_id 不能为空!"
   end  
   if ( obj_id == nil or obj_id == '' ) then 
       return 1, "GetDataObjInfo 中 obj_id 不能为空!"
   end             

   local nRet, strRetInfo
   nRet, strRetInfo = mobox.getDataObjAttr( strLuaDEID, cls_id, obj_id )

   if ( nRet == 1 ) then
       return 1, "ID ='"..obj_id.."'的"..cls_id.."对象不存在!"
   end
   if ( nRet ~= 0  ) then
       return 2, "getDataObjAttr 发生错误!"..id
   end

   local strJson
   nRet, strJson = mobox.objAttrsToLuaJson( cls_id, strRetInfo )
   if ( nRet ~= 0  ) then
       return 2, "objAttrsToLuaJson Supplier 失败!"..strRetInfo
   end

   local object, success
   success, object = pcall( json.decode, strJson )
   if ( success == false ) then
       error( "objAttrsToLuaJson 返回的的JSON格式不合法!" )
   end
   object.id = obj_id
   object.cls = cls_id
   return 0, object
end

--[[ 
   根据数据类标识和数据对象标识+数据对象属性设置数据库数据记录

   返回值：
   nRet 0 正确 1 对象不存在 > 1 错误
   object 
--]]
function m3.SetDataObject( strLuaDEID, data_obj )
    local nRet, strRetInfo

    if ( data_obj == nil or type(data_obj) ~= "table" ) then
        return  1, "SetDataObject 函数中的 data_obj 必须有值，必须是table类型!"
    end
    -- 参数检查
    if ( data_obj.cls == nil or data_obj.cls == '' ) then 
        return 1, "SetDataObject 中 data_obj 类型非法!"
    end  
    if ( data_obj.id == nil or data_obj.id == '' ) then 
        return 1, "SetDataObject 中 data_obj 类型非法!"
    end             
    local strAttrs
    nRet, strAttrs = mobox.luaJsonToObjAttrs( data_obj.cls, lua.table2str(data_obj))
    if ( nRet ~= 0 ) then return nRet, strAttrs end

    nRet, strRetInfo = mobox.setDataObjAttr( strLuaDEID, data_obj.cls, data_obj.id, strAttrs )
    if ( nRet ~= 0  ) then
        return 2, "setDataObjAttr 发生错误!"..strRetInfo
    end
 
    return 0
end

--[[ 
   根据查询条件获取一条对象属性，返回数据类定义的Lua属性
--]]
function m3.GetDataObjByCondition( strLuaDEID, cls_id, strCondition, strOrder )
   -- 参数检查
   if ( cls_id == nil or cls_id == '' ) then 
       return 2, "GetDataObjByCondition 中 cls_id 不能为空!"
   end  
   if ( strCondition == nil or strCondition == '' ) then 
       return 2, "GetDataObjByCondition 中 strCondition 不能为空!"
   end       
   if ( strOrder == nil ) then strOrder = '' end

   local nRet, strRetInfo, id
   nRet, strRetInfo = mobox.queryOneDataObjAttr2( strLuaDEID, cls_id, strCondition, strOrder )
   if ( nRet ~= 0  ) then return 2, "GetDataObjByCondition 发生错误!"..strRetInfo end
   if ( strRetInfo == '' ) then
       return 1, "条件："..strCondition.."的"..cls_id.."不存在!"
   end
   local ret_info, success
   success, ret_info = pcall( json.decode, strRetInfo )
   if ( success == false ) then return 2, "queryOneDataObjAttr 返回的的JSON格式不合法!" end

   local strJson
   nRet, strJson = mobox.objAttrsToLuaJson( cls_id, lua.table2str(ret_info.attrs) )
   if ( nRet ~= 0  ) then return 2, "objAttrsToLuaJson Supplier 失败!"..strRetInfo end

   local object
   success, object = pcall( json.decode, strJson )
   if ( success == false ) then
       return 2, "objAttrsToLuaJson 返回的的JSON格式不合法!"
   end
   object.id = ret_info.id
   object.cls = cls_id
   return 0, object
end

-- 创建一个数据对象 update_exist = 0/1 1-- 表示如果创建时对象已经存在就覆盖
-- 返回 dataobj Json 对象
function m3.CreateDataObj( strLuaDEID, dataObj, update_exist )
    local nRet, strRetInfo 

    if ( update_exist == nil ) then update_exist = 0 end
    if ( dataObj == nil or dataObj.cls == nil or  dataObj.cls == '' ) then
        return 2, "AddDataObj 中的dataObj不是一个mobox数据对象!"
    end

    local attrs
    nRet, attrs = mobox.luaJsonToObjAttrs(dataObj.cls, lua.table2str(dataObj))
    if ( nRet ~= 0 ) then
        return 2, 'luaJsonToObjAttrs时失败! 数据类标识 = '..dataObj.cls..' 原因:'..attrs.." dataobj = "..lua.table2str(dataObj)
    end    

    nRet, strRetInfo = mobox.createDataObj( strLuaDEID, dataObj.cls, attrs, 1, update_exist )        -- 返回的是Lua attr
    if ( nRet ~= 0 ) then
        strRetInfo = string.gsub(strRetInfo, "\n", "")
        strRetInfo = string.gsub(strRetInfo, "\r", "")
        return nRet, 'createDataObj失败! 数据类标识 = '..dataObj.cls..' 原因:'..strRetInfo
    end

    local retInfo, success
    success, retInfo = pcall( json.decode, strRetInfo )
    if ( success == false ) then
        return 2, "createDataObj 返回的的JSON格式不合法!"..strRetInfo
    end

    local strClsID = dataObj.cls

    dataObj = retInfo.lua_attr
    dataObj.id = retInfo.id
    dataObj.cls = strClsID

    return 0, dataObj
end

-- 把一个[{"attr": "XXXX", "value": "XXXX" }, … ]字符串转成一个 json对象
-- {"item_code":"xxx","item_name":"xxx",...}
function m3.ObjAttrStrToLuaObj( strClsID, strAttrs )
   local nRet, strRetInfo
   if ( type(strAttrs) == "table" ) then
       strAttrs = lua.table2str( strAttrs )
   end
   nRet, strRetInfo = mobox.objAttrsToLuaJson( strClsID, strAttrs )
   if ( nRet ~= 0  ) then
       return 2, "objAttrsToLuaJson Operation 失败!"..strRetInfo
   end

   local object, success
   success, object = pcall( json.decode, strRetInfo )
   if ( success == false ) then
       return 2, "objAttrsToLuaJson('Operation') 返回的的JSON格式不合法!"
   end
   return 0, object
end

--[[
    是否存在关键字段=XX的数据对象，适合判断KEY是单个的数据类
    如期KeyAttr必须是字符串类型
    返回：nRet, false/true
]]
function m3.ExistThisDataObject( strLuaDEID, strClsID, strKeyAttr, strKeyValue )
    local strCondition, nRet, strRetInfo

    if ( strClsID == nil or  strClsID == '' ) then return 1, "ExistThisDataObject 函数 strClsID 必须有值" end
    if ( strKeyAttr == nil or  strKeyAttr == '' ) then return 1, "ExistThisDataObject 函数 strKeyAttr 必须有值"  end
    if ( strKeyValue == nil or  strKeyValue == '' ) then return 1,  "ExistThisDataObject 函数 strKeyValue 必须有值" end

    strCondition = strKeyAttr.." = '"..strKeyValue.."'"
	nRet, strRetInfo = mobox.existThisData( strLuaDEID, strClsID, strCondition )
    if ( nRet ~= 0 ) then return 2, "existThisData 函数失败!"..strRetInfo end

    if ( strRetInfo == 'no') then return 0, false end
    return 0, true
end

-- 新增一个后台处理脚本
--[[
    paramter 参数是一个json包
    {
        "wfp_type":1,2
        "datajson":{...}
        "cls":"数据类标识或名称"
        "obj_id":""
        "obj_name":""
        "trigger_type":0\1\2\3
        "trigger_time":"2024-6-10 8:20:10"
        "trigger_event":"xxx"
        'wfp_name':""
    }
    如果：wfp_type = 1 cls + obj_id 均有值 触发数据对象的事件，如果 obj_id 没值，触发数据类事件
]]
function m3.AddSysWFP( strLuaDEID, paramter )
    local nRet, strRetInfo
    local wfp_list_show_name = ''
    local cls = paramter.cls
    local id  = paramter.obj_id
    local obj_display_name = paramter.obj_name
    local trigger_time = paramter.trigger_time
    local trigger_event = ""
    local trigger_type = paramter.trigger_type
    local strDataJson = ''

    if ( paramter.datajson == nil ) then 
        strDataJson = ''
    elseif (type(paramter.datajson) ~= "table" ) then
        strDataJson = paramter.datajson
    else
        strDataJson = lua.table2str( paramter.datajson )
    end

    if (trigger_type == nil ) then trigger_type = 0 end
    if (strDataJson == nil ) then strDataJson = '' end
    if (obj_display_name == nil ) then obj_display_name = '' end
    if (trigger_time == nil ) then trigger_time = '' end
    if (id == nil ) then id = '' end
    if (paramter.wfp_type == nil ) then 
        paramter.wfp_type = 1
    end

    if ( paramter.wfp_type == 1) then
        -- 触发数据类事件
        if ( paramter.cls == nil or paramter.cls == '') then
            return 1, "AddSysWFP 参数paramter缺少cls属性!"
        end
        if ( paramter.trigger_event == nil or paramter.trigger_event == '') then
            return 1, "AddSysWFP 参数paramter缺少trigger_event属性!"
        end  
        trigger_event = paramter.trigger_event
        if ( obj_display_name == '' ) then
            wfp_list_show_name = "触发数据类'"..paramter.cls.."'对象事件'"..paramter.trigger_event.."'"  
        else
            wfp_list_show_name = obj_display_name
        end
    elseif ( paramter.wfp_type == 2 ) then
        -- 触发Zone、Zon_Cls 
        wfp_list_show_name = "触发数据类'"..paramter.cls.."'对象事件'"..paramter.trigger_event.."'" 
        if ( paramter.wfp_name == nil or paramter.wfp_name == '') then
            wfp_list_show_name = paramter.wfp_name  
        end
        if ( paramter.obj_id == nil or paramter.obj_id == '') then
            return 1, "AddSysWFP 参数paramter缺少obj_id属性!"
        end            
        if ( paramter.cls == nil or paramter.cls == '') then
            return 1, "AddSysWFP 参数paramter缺少cls属性!"
        end
        if ( paramter.trigger_event == nil or paramter.trigger_event == '') then
            return 1, "AddSysWFP 参数paramter缺少trigger_event属性!"
        end  
        trigger_event = paramter.trigger_event
    elseif (  paramter.wfp_type == 0 ) then
        if (strDataJson == '') then
            return 1, "AddSysWFP 参数paramter缺少 datajson 属性!"
        end
    else
        return 1, "AddSysWFP 参数paramter中的wfp_type属性值不正确只能是0,1,2!"        
    end

    nRet, strRetInfo = mobox.addSysWFP( strLuaDEID, paramter.wfp_type, strDataJson, cls, id, 
                                        obj_display_name, trigger_type, 
                                        trigger_time,
                                        trigger_event, 
                                        wfp_list_show_name, "", 0 )
    if (nRet ~= 0 ) then return 1, "addSysWFP 失败!"..strRetInfo end    

    return 0
end

--[[ 动态可编程接口返回函数
    err_code = 0 表示接口成功
    err_msg -- 接口Lua返回给调用方的错误信息
]]
function m3.EPI_Return( strLuaDEID, json_return_value )
    mobox.returnValue( strLuaDEID, 1, lua.table2str(json_return_value) )  
end

-- 获取当前编辑对象属性和ID
function m3.GetCurEditDataObj( strLuaDEID )
    local nRet, data_obj
    local strClsID, strObjID
    nRet, strClsID, strObjID = mobox.getCurEditDataObjID( strLuaDEID )
    if ( nRet ~= 0 )  then return 2, "getCurEditDataObjID失败!  "..strClsID end

    nRet, data_obj = m3.GetSysCurEditDataObj( strLuaDEID, strClsID )
    if (nRet ~= 0) then return 2, "获取【'"..strClsID.."'】对象属性失败!"..data_obj  end
    return 0, data_obj
end

-- 获取Lua数据交换区所有参数，用于Lua lua.Debug
function m3.PrintLuaDEInfo( strLuaDEID )
    local nRet, obj_attr, data_json, runtime, input_paramter, global_attr
    local strClsID, strObjID

    nRet, strClsID, strObjID = mobox.getCurEditDataObjID( strLuaDEID )
    if ( nRet ~= 0 )  then 
        strClsID = ''
        strObjID = ''
    end

    obj_attr = {}
    if ( strObjID ~= '' and strObjID ~= nil ) then
        nRet, obj_attr = m3.GetSysCurEditDataAttrs( strLuaDEID )
        if (nRet ~= 0) then return 2, "获取【'"..strClsID.."'】对象属性失败!"..obj_attr  end
    elseif ( strClsID ~= '' ) then
        nRet, obj_attr = m3.GetSysCurEditDataAttrs(strLuaDEID)
        if (nRet ~= 0) then return 2, "获取正在编辑的【'"..strClsID.."'】对象属性失败!"..obj_attr  end
    end

    local lua_ed = {
        cls_id = strClsID,
        obj_id = strObjID,
        obj_attr = obj_attr,
        data_json = {},
        ext_info = {},
        global_attr = {},
        input_param = {}
    }

    nRet, lua_ed.data_json = mobox.getCurEditDataPacket( strLuaDEID )
    if ( nRet ~= 0 ) then
        lua_ed.data_json = {}
    end
    nRet, global_attr = m3.GetSysGloablAttr( strLuaDEID )
    if ( nRet == 0 ) then 
        lua_ed.global_attr = global_attr
    end
    nRet, input_paramter = m3.GetSysInputParameter( strLuaDEID )
    if ( nRet == 0 ) then 
        lua_ed.input_param = input_paramter
    end
    nRet, runtime = m3.GetRuntimeParam( strLuaDEID )
    if ( nRet == 0 ) then 
        lua_ed.ext_info = runtime
    end        

    lua.Debug( strLuaDEID, debug.getinfo(1), "Lua脚本数据交换区内容-->", lua_ed )
end

-- 从内存获取数据对象属性
function m3.GetDataFromCache( cls_id, key )
    local nRet, strRetInfo
    
    if ( lua.StrIsEmpty( cls_id ) ) then return 1, "函数 GetDataFromCache 中 cls_id 必须要有值!" end
    if ( lua.StrIsEmpty( key ) ) then return 1, "函数 GetDataFromCache 中 key 必须要有值!" end

    nRet, strRetInfo = mobox.getMemoryDataObjInfo( cls_id, key )
    if ( nRet ~= 0 ) then return 2, strRetInfo end
    if ( strRetInfo == '' ) then 
        return 1, " 数据类标识 '"..cls_id.."' 的缓存中不存在 key = '"..key.."'的数据对象!"
    end
    local success, data
    success, data = pcall( json.decode, strRetInfo )
    if ( success == false ) then return 2, "getMemoryDataObjInfo 返回非法的JSON字符串!" end
    return 0, data
end
return m3