g33_network_int/sdModuel.lua

-- pm.wake("sdcard")

local comSize = 4 --每个公共目录下文件大小  单位 kb
-- 挂载SD卡,返回值0表示失败，1表示成功
-- local sdcard = io.mount(io.SDCARD)
-- log.info('mount sd card', sdcard)
local sdCardTotalSize = rtos.get_fs_total_size(1, 1)
log.info("sd card total size " .. sdCardTotalSize .. " KB")

local delimiter = '\0'

if io.opendir("/sdcard0/common") then
    for i=1,100 do
        local fType,fName,fSize = io.readdir()
        log.info("fname",fName)
        if fType==32 then
            -- log.info("sd card file",fName,fSize)
        elseif fType == nil then
            break
        end
    end
    io.closedir("/sdcard0/commmon")
end

-- 删除目录
-- local rmfile = rtos.remove_dir('/sdcard0/common')
-- log.info('delete', rmfile)
-- rtos.make_dir('/sdcard0/log')
-- debug_log('写入测试日志')
-- local del = os.remove(comDir .. '/user')
-- log.info('del user file', del)
-- local readval = readfile() -- 参数：完整路径文件名  不传或者传'/sdcard0/log/0'都是获取最新日志文件
-- print(readval)
--获取table长度
function table_leng(t)
    local leng=0
    for k, v in pairs(t) do
      leng=leng+1
    end
    return leng;
  end
-- 分割字符串
---@param str string 元字符串
---@param seq string 分割字符
---@return table
function split(str, seq)
    local nFindStartIndex = 1
    local nSplitIndex = 1
    local nSplitArray = {}
    while true do
       local nFindLastIndex = string.find(str, seq, nFindStartIndex)
       if not nFindLastIndex then
        nSplitArray[nSplitIndex] = string.sub(str, nFindStartIndex, string.len(str))
        break
       end
       nSplitArray[nSplitIndex] = string.sub(str, nFindStartIndex, nFindLastIndex - 1)
       nFindStartIndex = nFindLastIndex + string.len(seq)
       nSplitIndex = nSplitIndex + 1
    end
    return nSplitArray
end
--数组去重
function table.unique(t, bArray, mainKey)
    local check = {}
    local n = {}
    local idx = 1
    for k, v in pairs(t) do
        local judgeKey = v
        if mainKey then
            judgeKey = v[mainKey] or v
        end
        if not check[judgeKey] then
            if bArray then
                n[idx] = v
                idx = idx + 1
            else
                n[k] = v
            end
            check[judgeKey] = true
        end
    end
    return n
end
--循环创建文件夹
function createAllFolder(path)
-- print(path)
	local path_tb={}
	local new_path=""
	-- 分割路径保存到table
	for i,s in pairs(split(path,'/')) do
		if s~=nil then
			table.insert(path_tb,s)
		end
	end
    -- print(json.encode(path_tb))
	local cdir = false --创建结果
	-- 遍历并拼接路径检测是否存在，不存在则新建
	for k,v in ipairs(path_tb) do
        
        if v ~= '' then
            if k==1 then
                new_path=v
            else
                new_path=new_path.."/"..v
            end		
            -- print(new_path,io.opendir(new_path))
            local opflag = io.opendir(new_path)
            if opflag ~= 1 then
                cdir = rtos.make_dir(new_path)
                log.info("path:", new_path, "flag:",cdir)
            end
            
        end
	end
    io.closedir()
    return cdir
end
-- 打开sd卡公共目录，不存在则创建 获取最新文件,
function getComLastFile(dirPath,filename)
    local lastfile = filename --返回最新文件
    -- log.info('func:getComLastFile open dir', io.opendir(dirPath))
    if io.opendir(dirPath) ~= 0 then
        local file = {} -- 该目录所有文件名
        for i = 1, 999 do
            local fType, fName, fSize = io.readdir()
            -- log.info("file or dir",fType, fName, fSize)
            if fType == 32 then
                -- log.info("func getComLastFile common file", fName, fSize)
                local tname = split(fName,'-')
                -- log.debug('func:getComLastFile tname',tname,tname[1],tname[2])
                if tname[1] == filename then
                    if tname[2] then
                        table.insert(file,tname[2])
                    end
                end
                -- local c = io.readFile(dirPath..'/'..fName)
                -- log.info('文件内容',c)
            elseif fType == nil then
                break
            end
        end
        -- log.error('files',json.encode(file))
        --获取文件名后缀最大值
        local max = nil -- 最新的文件  即数字名称值最大的文件
        for i, v in pairs(file) do
            v = tonumber(v) --数组中是string类型   比较会有问题
            if max == nil then max = v end
            if max < v then max = v end
        end
        -- print(max)
        if max then
            -- 判断该最新文件大小
            local cnt = io.fileSize(dirPath .. '/' .. filename..'-'..max)
            if cnt then
                if cnt >= (comSize * 1024) then -- 文件大于设置的文件大小 新建新文件
                    max = max + 1
                end
                lastfile = filename..'-'..max
            end
        else
             -- 判断该最新文件大小
             local cnt = io.fileSize(dirPath .. '/' .. filename)
             if cnt then
                 if cnt >= (comSize * 1024) then -- 文件大于设置的文件大小 新建新文件
                     lastfile = filename..'-1'
                 end
             end
        end
        -- print(lastfile)
        log.debug('func:getComLastFile lastfile',lastfile)
        io.closedir()
        return lastfile
    else
      local cdir = createAllFolder(dirPath)
      if cdir then
          log.info('创建公共目录成功', dirPath)
      else
          log.error('创建公共目录失败',dirPath)
      end
      return lastfile
    end
end
--根据某个目录下文件名获取该类型所有文件  返回table
function getAllFiles( dir, file )
    local fs = {}
    if not file then
        return false,'fun:getAllFiles,desc:file not found'
    end
    log.error('open dir',io.opendir(dir))
    if io.opendir(dir) ~= 0 then
        for i = 1, 999 do
            local fType, fName, fSize = io.readdir()
            -- log.info("file or dir",fType, fName, fSize)
            if fType == 32 then
                local tname = split(fName,'-')
                -- log.debug('func:getAllFiles tname',tname,tname[1],tname[2])
                if tname[1] == file then
                    table.insert(fs,fName)
                end
            elseif fType == nil then
                break
            end
        end
    else
        io.closedir()
        return false,'fun:getAllFiles,desc:dir not found'
    end
    io.closedir()
    return fs,'fun:getAllFiles,desc:get all files is ok'
end
-- 保存基础信息所有扳手信息
-- 文件 所有扳手信息   查询条件扳手编号 wrench
-- 文件 所有风场信息 wind
-- 文件 部件列表 unit
-- 文件 用户信息  user     查询条件用户名+密码
-- 文件 任务计划 task      查询条件任务编号
-- 文件 工作位置列表  workspace  查询条件风机型号+部件号
-- 文件 待上传信息
-- 文件 配置信息 比如最后一次使用时间 用于存储空间不够时删除
--参数[filename]  文件名称 如wrench、wind、unit。。。[data] 保存数据 table类型
function saveBaseInfo( filename,data,dirPath)
    -- print(filename)
    if not filename then
        log.error('savebaseinfo','filename not fount')
        return false,'filename not fount'
    end
    if not data then
        log.error('savebaseinfo','data not fount')
        return false,'data not fount'
    end
    if not dirPath then
        log.error('savebaseinfo','dirPath not fount')
        return false,'dirPath not fount'
    end
    --最新文件名称
    local filename = getComLastFile(dirPath,filename)
    log.debug('func:saveBaseInfo last file',filename)
    local path = dirPath..'/'..filename
    log.info('save path',path)
    data = json.encode(data)..delimiter
    local c = io.writeFile(path,data, "a+b")
    if c then
        log.info('write result', c)
        return true
    else
        log.error('error', '基础信息写入失败')
        return false,'基础信息写入失败'
    end
end
-- 保存基础信息
-- local wrench = {id=1,name='测试设备'}
-- local res,desc= saveBaseInfo('wrench',wrench)
-- log.debug('save result',res,desc)
-- 模拟数据
-- for i=113,150 do
--     local user = {id=i,name='小亮'..i,pwd='49BA59ABBE56E057',time=os.time()}  --password  md5加密 16位大写  123456
--     local res,desc= saveBaseInfo('user',user,'/sdcard0/wind/12345')
--     log.debug('save result',res,desc)
--     break
-- end

--查询设备信息
--参数[filename]  文件名称 如wrench、wind、unit。。。[param] 保存数据 table类型 nil查询所有数据
--返回结果  result 结果 值true/false count--查询文件数量 desc --结果描述
 function getBaseInfo( filename,param,dirPath)
    local selectRes = {} --查询结果
    local count = 0 --查询文件个数
    if not filename then
        log.error('func:getBaseInfo','filename not fount')
        return false,count,'filename not fount'
    end
    if not dirPath then

        log.error('func:getBaseInfo','dirPath not fount')
        return false,count,'dirPath not fount'
    end
    --获取所有该文件及副本文件
    local files,desc = getAllFiles(dirPath,filename)
    local filevals = nil --文件内容
    if not files then
        return false,count,desc
    end
    local succ_cnt = 0; --比较成功个数
    for i,file in pairs(files) do
        local isbreak = false
        local path = dirPath..'/'..file
        local filehandle = io.open(path, "r") -- 第一个参数是文件名，第二个是打开方式，'r'读模式,'w'写模式，对数据进行覆盖,'a'附加模式,'b'加在模式后面表示以二进制形式打开
        if not filehandle then -- 判断文件是否存在
            isbreak = true
        end
        fileval = filehandle:read("*all") -- 读出文件内容
        -- print(fileval)
        if not fileval then
                isbreak = true
        end
        local filevaltable = split(fileval,delimiter)
        local table_length = table_leng(filevaltable)
        if table_length <= 1 then
            isbreak = true
        end
        
        -- log.info("isbreak:", isbreak, table_length)

        if not isbreak then
            -- body
            for a = 1,table_length-1 do
                local val = json.decode(filevaltable[a])
    
                if param then --有查询参数
                    local p_length = table_leng(param) --条件长度
                    for p,s in pairs(param) do
                        if filename == "Users" then
                            if p == 'pwd' then
                                s =  string.sub(string.upper(crypto.md5(s,#s,16)),9,24) --密码加密  加密结果32位  取16位（第9-24）字符
                            end
                        end
                        -- log.info("val[p] ", val[p] , "s", s, succ_cnt)
                        if val[p] == s then
                            succ_cnt = succ_cnt + 1
                        else
                            break
                        end
                    end
                    if p_length == succ_cnt then --找到结果 停止继续查找下个文件
                        selectRes[i] = val
                        isbreak = true
                        break
                    end
                else --无查询参数  查询所有
                    selectRes[i] = val
                end
            end
        end


        count = i
        -- if isbreak then --找到结果 停止继续查找下个文件
        --     break;
        -- end
        filehandle:close() -- 关闭文件
    end
    -- print(table_leng(selectRes),json.encode(selectRes))
    if table_leng(selectRes) > 0 then
         --去重
        local result = table.unique(selectRes,true,'id')
        return result,count,'select success'
    else
        return false,count,'this data is not found'
    end
end

-- 查询文件内容复数
function getBaseInfo_ununique( filename,param,dirPath)
    local selectRes = {} --查询结果
    local count = 0 --查询文件个数
    if not filename then
        log.error('func:getBaseInfo','filename not fount')
        return false,count,'filename not fount'
    end
    if not dirPath then
        log.error('func:getBaseInfo','dirPath not fount')
        return false,count,'dirPath not fount'
    end
    --获取所有该文件及副本文件
    local files,desc = getAllFiles(dirPath,filename)
    local filevals = nil --文件内容
    if not files then
        return false,count,desc
    end
    local succ_cnt = 0; --比较成功个数
    for i,file in pairs(files) do
        local isbreak = false
        local path = dirPath..'/'..file
        local filehandle = io.open(path, "r") -- 第一个参数是文件名，第二个是打开方式，'r'读模式,'w'写模式，对数据进行覆盖,'a'附加模式,'b'加在模式后面表示以二进制形式打开
        if not filehandle then -- 判断文件是否存在
            isbreak = true
        end
        fileval = filehandle:read("*all") -- 读出文件内容
        -- print(fileval)
        if not fileval then
                isbreak = true
        end
        local filevaltable = split(fileval,delimiter)
        local table_length = table_leng(filevaltable)
        if table_length <= 1 then
            isbreak = true
        end
        

        if not isbreak then
            -- body
            for a = 1,table_length-1 do
                local val = json.decode(filevaltable[a])
                succ_cnt = 0
                if param then --有查询参数
                    local p_length = table_leng(param) --条件长度
                    for p,s in pairs(param) do

                         
    
                        if val[p] == s then
                            -- log.info("val[p]:", val[p], "s:",s)
                            succ_cnt = succ_cnt + 1
                        else
                            break
                        end
                    end
    
                    if p_length == succ_cnt then --找到结果 停止继续查找下个文件
                        table.insert(selectRes, val)
                    end
                    
                else --无查询参数  查询所有
                    table.insert(selectRes, val)
                end
            end
        end

        count = i
        -- if isbreak then --找到结果 停止继续查找下个文件
        --     break;
        -- end
        filehandle:close() -- 关闭文件
    end
    -- print(table_leng(selectRes),json.encode(selectRes))
    if table_leng(selectRes) > 0 then
         --去重
        local result = table.unique(selectRes,true,'id')
        return result,count,'select success'
    else
        return false,count,'this data is not found'
    end
end

-- 查询文件内容复数_模糊查询
function getBaseInfo_ununique_dim( filename,param,dirPath)
    local selectRes = {} --查询结果
    local count = 0 --查询文件个数
    if not filename then
        log.error('func:getBaseInfo','filename not fount')
        return false,count,'filename not fount'
    end
    if not dirPath then
        log.error('func:getBaseInfo','dirPath not fount')
        return false,count,'dirPath not fount'
    end
    --获取所有该文件及副本文件
    local files,desc = getAllFiles(dirPath,filename)
    local filevals = nil --文件内容
    if not files then
        return false,count,desc
    end
    local succ_cnt = 0; --比较成功个数
    for i,file in pairs(files) do
        local isbreak = false
        local path = dirPath..'/'..file
        local filehandle = io.open(path, "r") -- 第一个参数是文件名，第二个是打开方式，'r'读模式,'w'写模式，对数据进行覆盖,'a'附加模式,'b'加在模式后面表示以二进制形式打开
        if not filehandle then -- 判断文件是否存在
            isbreak = true
            -- isbreak = true
        end
        fileval = filehandle:read("*all") -- 读出文件内容
        -- print(fileval)
        if not fileval then
            isbreak = true
            -- isbreak = true
        end
        local filevaltable = split(fileval,delimiter)
        local table_length = table_leng(filevaltable)
        if table_length <= 1 then
            isbreak = true
            -- isbreak = true
        end
       
        if not isbreak then
            -- body
            for a = 1,table_length-1 do
                local val = json.decode(filevaltable[a])
    
                if param then --有查询参数
                    local p_length = table_leng(param) --条件长度
                    local pattern = ""
                    for p,s in pairs(param) do
    
                        if succ_cnt > 49 then
                            -- body
                            break
                        end
    
                        -- log.info("val[p]:", val[p], "s:",s)
    
                        local wholeStr = val[p]
                        if type(val[p]) ~= "userdata" then
                            -- body
                            pattern = string.gsub(s, "[%[%]&=+%%%c%(%)%-%/%+]", function(c)
                                return "%"..c
                            end)
                            local a,b = string.find(wholeStr,pattern) 
                            local transMatchres = string.match(wholeStr,pattern)
        
                            
                            if a and (b-a+1) == #transMatchres then
                                succ_cnt = succ_cnt + 1
                                table.insert(selectRes, val) 
                            end
                        end
    
                    end
    
                    -- if p_length == succ_cnt then --找到结果 停止继续查找下个文件
                    --     table.insert(selectRes, val) 
                    -- end
                    
                else --无查询参数  查询所有
                    if succ_cnt > 49 then
                        -- body
                    else

                        if filename == "Wind" then
                            -- body
                            local fieldDisplayRadius = nvm.get("fieldDisplayRadius") or 200
                            local gpsLng, gpsLat = nvm.get("gpsLng"), nvm.get("gpsLat")
                            local dist = devTool.getDistance( val.lat, val.lon, gpsLat, gpsLng)
                            -- log.info("dist:",dist, json.encode(v))
                            if dist  <  fieldDisplayRadius then
                                -- body
                                -- log.info("cicle",v.lat)
                                val.dist = dist
                                table.insert(selectRes, val)
                                succ_cnt = succ_cnt+1
                            end
                        else
                            table.insert(selectRes, val)
                            succ_cnt = succ_cnt+1
                        end
                    end
                    
                end
            end
        end

        count = i
        -- if isbreak then --找到结果 停止继续查找下个文件
        --     break;
        -- end
        filehandle:close() -- 关闭文件
    end
    -- print(table_leng(selectRes),json.encode(selectRes))
    if table_leng(selectRes) > 0 then
         --去重
        local result = table.unique(selectRes,true,'id')
        return result,count,'select success'
    else
        return false,count,'this data is not found'
    end
end

-- local res,cnt,desc = getBaseInfo('user',{pwd="123456",name="小亮113"},'/sdcard0/wind/12345')
-- log.info('select result',res,cnt,desc)
-- for i,j in ipairs(res) do
--     for m,n in pairs(j) do
--         print(m,n)
--     end
-- end
--删除基本信息
--参数[filename]  文件名称 如wrench、wind、unit。。。[id] 删除数据id
function delBaseInfo(filename,id,dirPath)
    local res = false --删除结果
    local count = 0 --查询文件个数
    log.info("del process:",filename,id,dirPath)
    if not filename then
        log.error('func:delBaseInfo','filename not fount')
        return res,count,'filename not fount'
    end
    if not id then
        log.error('func:delBaseInfo','id not fount')
        return res,count,'id not fount'
    end
    if not dirPath then
        log.error('func:delBaseInfo','dirPath not fount')
        return res,count,'dirPath not fount'
    end
    --获取所有该文件及副本文件
    local files,desc = getAllFiles(dirPath,filename)
    local filevals = nil --文件内容
    if not files then
        return res,count,desc
    end
    local isCurFile = false --要删除文件是否找到
    for i,file in pairs(files) do
        local isbreak = false
        local path = dirPath..'/'..file
        local filehandle = io.open(path, "r") -- 第一个参数是文件名，第二个是打开方式，'r'读模式,'w'写模式，对数据进行覆盖,'a'附加模式,'b'加在模式后面表示以二进制形式打开
        if not filehandle then -- 判断文件是否存在
            isbreak = true
        end
        fileval = filehandle:read("*all") -- 读出文件内容
        if not fileval then
            isbreak = true
        end
        local filevaltable = split(fileval,delimiter)
        local table_lenght = table_leng(filevaltable)
        if table_lenght <= 1 then
            isbreak = true
        end
        local newfileval = "" --删除后文件内容
        if not isbreak then
            -- body
            for a = 1,table_lenght-1 do
                local val = json.decode(filevaltable[a])
    
                if val.id ~= id then
                    data = json.encode(val)
                    if newfileval ~= "" then
                        newfileval = newfileval..data..delimiter
                    else
                        newfileval = data..delimiter
                    end
                else
                    isCurFile = true
                end
            end
        end

        filehandle:close() -- 关闭文件
        if isCurFile then
            --删除旧文件
            local del = os.remove(path)
            log.debug('func:delBaseInfo del file', del)
            --保存删除后的内容
            local c = io.writeFile(path,newfileval, "a+b")
            if c then
                count = i
                log.info('func:delBaseInfo save file', c)
                return true,count,'del success'
            else
                log.error('error', '基础信息写入失败')
                return false,count,'del ok,but save fail'
            end
            break
        else
            count = i
        end
    end
    if not isCurFile then
        return false,count,'this data not found where id='..id
    end
end

function delOfflineCacheTemp( dirPath )
    -- body
    return   rtos.remove_dir(dirPath)
end

-- local res,cnt,desc = delBaseInfo('user',113,'/sdcard0/wind/12345')
-- log.info('del result',res,cnt,desc)
--修改基本信息
--参数[filename]  文件名称 如wrench、wind、unit。。。[data] 要修改的数据 table类型 要包含数据id
--返回结果  result 结果 值true/false count--查询文件数量 desc --结果描述
function updateBaseInfo( filename,data,dirPath)
    local res = false --修改结果
    local count = 0 --查询文件个数
    if not filename then
        log.error('func:updateBaseInfo','filename not fount')
        return res,count,'filename not fount'
    end
    if not data.id then
        log.error('func:updateBaseInfo','data not fount')
        return res,count,'the id of data is not fount'
    end
    --获取所有该文件及副本文件
    local files,desc = getAllFiles(dirPath,filename)
    local filevals = nil --文件内容
    if not files then
        return res,count,desc
    end
    local isCurFile = false --要修改数据文件是否找到
    for i,file in pairs(files) do
        local isbreak = false
        local path = dirPath..'/'..file
        local filehandle = io.open(path, "r") -- 第一个参数是文件名，第二个是打开方式，'r'读模式,'w'写模式，对数据进行覆盖,'a'附加模式,'b'加在模式后面表示以二进制形式打开
        if not filehandle then -- 判断文件是否存在
            isbreak = true
        end
        fileval = filehandle:read("*all") -- 读出文件内容
        if not fileval then
            isbreak = true
        end
        local filevaltable = split(fileval,delimiter)
        local table_length = table_leng(filevaltable)
        if table_length <= 1 then
            isbreak = true
        end
        local newfileval = nil --删除后文件内容
        if not isbreak then
            -- body
            for a = 1,table_length-1 do
                local val = json.decode(filevaltable[a])
                if val.id ~= data.id then --过滤要修改的那条数据
                    dataStr = json.encode(val)
                    if newfileval then
                        newfileval = newfileval..dataStr..delimiter
                    else
                        newfileval = dataStr..delimiter
                    end
                else
                    --将新数据放入新的文件内容中
                    local newData = json.encode(data)
                    if newfileval then
                        newfileval = newfileval..newData..delimiter
                    else
                        newfileval = newData..delimiter
                    end
                    isCurFile = true
                end
            end
        end

        filehandle:close() -- 关闭文件
        if isCurFile then
           if newfileval then
                --删除旧文件
                local del = os.remove(path)
                if not del then
                    return false,count,'func:updateBaseInfo del fail,please reoperate'
                end
                --保存删除后的内容
                local c = io.writeFile(path,newfileval, "a+b")
                if c then
                    count = i
                    return true,count,'func:updateBaseInfo update success'
                else
                    return false,count,'func:updateBaseInfo del success,but save fail'
                end
            else
                return false,count,'the file content after del create fail'
            end
            break
        else
            count = i
        end
    end
    if not isCurFile then
        return false,count,'this data not found where id='..data.id
    end
end



sys.taskInit(function()
    -- while true do
    --     log.info("test00")
    --     led.blinkPwm(blueLed,2000,1000)
    --     led.blinkPwm(redLed,3000,1000)

        
    --     sys.wait(2000)
    -- end

    sys.wait(5000)

    local moutedFlag = io.mount(io.SDCARD)
    log.info('mount sd card', moutedFlag)
    



    local sdCardTotalSize = rtos.get_fs_total_size(1,1)
    log.info("sd card total size "..sdCardTotalSize.." KB")
    
    if moutedFlag == 1 then
        -- body
        sys.publish("IO_SDCARD_MOUTED")
    end

end)