module(...,package.seeall) function table_leng(t) local leng=0 for k, v in pairs(t) do leng=leng+1 end return leng; end local DIR_PATH = { Users = "/sdcard0/common", Wrench = "/sdcard0/common", WorkingParts = "/sdcard0/common", WorkingPosition = "/sdcard0/common", WorkPlan = "/sdcard0/common", File = "/sdcard0/log", Wind = "/sdcard0/common" } local ALLOWCUSTOM_FILE = { Fan = 1, WorkingParts = 1, WorkingPosition = 1 } -- 根据操作写文件 function operateFs(op, cntType, cntVersion, content ) -- body local opRes, count, desc = "",fileRes if op == "add" then -- body if DIR_PATH[cntType] then -- body if ALLOWCUSTOM_FILE[cntType] then -- body delBaseInfo(cntType, 0, DIR_PATH[cntType]) end opRes, desc = saveBaseInfo(cntType, content, DIR_PATH[cntType] ) else if ALLOWCUSTOM_FILE[cntType] then -- body delBaseInfo(cntType, 0, "/sdcard0/"..content.wnum) end if cntType == "WorkRecord" then -- body opRes, desc = saveBaseInfo(cntType, content, "/sdcard0/"..content.wnum .. "/" .. content.fnum) else opRes, desc = saveBaseInfo(cntType, content, "/sdcard0/"..content.wnum ) end end end if op == "update" then -- body if DIR_PATH[cntType] then -- body opRes,count, desc = updateBaseInfo(cntType, content, DIR_PATH[cntType] ) if not opRes or desc:sub(1, 29) == "this data not found where id=" then -- body opRes, desc = saveBaseInfo(cntType, content, DIR_PATH[cntType] ) end else if cntType == "WorkRecord" then -- body opRes,count, desc = updateBaseInfo(cntType, content, "/sdcard0/"..content.wnum .. "/" .. content.fnum) else opRes,count, desc = updateBaseInfo(cntType, content, "/sdcard0/"..content.wnum ) end if not opRes or desc:sub(1, 29) == "this data not found where id=" then -- body if cntType == "WorkRecord" then -- body opRes, desc = saveBaseInfo(cntType, content, "/sdcard0/"..content.wnum .. "/" .. content.fnum) else opRes, desc = saveBaseInfo(cntType, content, "/sdcard0/"..content.wnum ) end end end end if op == "delete" then -- body if DIR_PATH[cntType] then -- body opRes,count, desc = delBaseInfo(cntType, content.id, DIR_PATH[cntType] ) else if cntType == "WorkRecord" then -- body opRes,count, desc = delBaseInfo(cntType, content.id, "/sdcard0/"..content.wnum .. "/" .. content.fnum) else opRes,count, desc = delBaseInfo(cntType, content.id, "/sdcard0/"..content.wnum ) end end end if op == "directive" then if cntType == "File" then -- body if content.file_name == "/sdcard0/log/0" then -- body opRes = logModuel.readfile(nil) else opRes = logModuel.readfile(content.file_name) end end if cntType == "SysCMD" then -- body if content.cmd_content == "Reboot" then -- body opRes = true sys.restart("Sever send reboot CMD! ") end if content.cmd_content == "ResetUploadCache" then -- body rtos.remove_dir("/sdcard0/common/temp") sys.restart("Server send ResetUploadCache CMD! ") end if content.cmd_content == "FormatSD" then -- body local fg = io.format(io.SDCARD) log.info("format res", fg) if fg == 1 then -- body nvm.set("localCntVersion", "0") sys.restart("Server send Format SDcard CMD! ") else opRes = false desc = "格式化SDcard失败" end end end if cntType == "Config" then -- body for k,v in pairs(content) do nvm.set(k, v) end opRes = true sys.restart("Sever send config update! ") end end local localVersion = nvm.get("localCntVersion") if cntVersion > localVersion then -- body local dateObj = os.date("*t") local updateTime = dateObj.year .. dateObj.month .. dateObj.day .. dateObj.hour .. dateObj.min .. dateObj.sec nvm.set("localCntVersion", cntVersion) nvm.set("localCntUpdateTime", updateTime) log.info("nvm set success, value:", cntVersion) end -- log.info("optype:",op,"cntType:", cntType, "opRes:",opRes, "count:",count, "desc:",desc) if not opRes then -- body if not desc then -- body desc = "" end logModuel.debug_log("mqtt_recieve operate fs failed! desc:"..desc..",optype:"..op..",cntVersion:"..cntVersion) end return opRes,desc end --- MQTT客户端数据接收处理 -- @param mqttClient，MQTT客户端对象 -- @return 处理成功返回true，处理出错返回false -- @usage mqttInMsg.proc(mqttClient) function proc(mqttClient) local result,data,param while true do result, data, param = mqttClient:receive(30000,"LOCAL_PUB_MSG") --接收到数据 -- opType = "update"时，若不存在，则 add if result then local resData = json.decode(data.payload) log.info("origin mqttrec data:",data.payload) if resData.msgid and resData.success then -- body log.info("three topic msgid:",resData.msgid, "type:", type(resData.msgid)) sys.publish("WAIT_UPDATA_RESP_SUCCESS", resData.msgid ) break end local ack = { Imei = misc.getImei(), CntVersion = "", Succ = "", Extra = {} } --{"Extra":{},"Succ":"1","Imei":"863488052331447","CntVersion":"1659751519989"} local extrTable = {} local hasFile = false for k,v in pairs(resData) do local opRes, desc = operateFs(v.OpType, v.CntType, v.CntVersion, v.Content) if not opRes then -- body ack.Succ = "-1" table.insert(extrTable, "error_version:"..v.CntVersion..",OpType:"..v.OpType..",CntType:"..v.CntType..",desc:"..desc) end if v.OpType =="directive" and v.CntType == "File" then -- body table.insert(extrTable, "file_name:"..(v.Content.file_name or "unknown_file" )..",content:"..opRes) hasFile = true end end if ack.Succ == "" then -- body ack.Succ = "1" end ack.CntVersion = nvm.get("localCntVersion") ack.Extra = extrTable local mqttSendContent = "" if hasFile then -- body mqttSendContent = '{"Imei":' .. misc.getImei() ..',' .. '"CntVersion":'.. ack.CntVersion .. ',' .. '"Succ":'.. ack.Succ .. ','.. '"Extra":'.. table.concat(extrTable) .. '}' else mqttSendContent = json.encode(ack) end -- log.info("json temple:", att) -- mqttClient:publish("SHEGCL/IntelligenTool/Ack", json.encode(ack)) mqttClient:publish("SHEGCL/IntelligenTool/Ack", mqttSendContent) elseif data == "LOCAL_PUB_MSG" then if type(param) == "string" then -- body param = json.decode(param) if param.topic and param.data then -- body -- if param.topic == "SHEGCL/IntelligenTool/UploadWorkRecordMA" or param.topic == "SHEGCL/IntelligenTool/UploadWorkRecordFA" or param.topic == "SHEGCL/IntelligenTool/Heart" then -- -- body -- upData.msgid = devTool.guid() -- end local upData = param.data upData.PublishVersion = nvm.get("localCntVersion") upData.IMEI = misc.getImei() mqttClient:publish(param.topic, json.encode(upData)) end else log.error("mqtt_recieve.proc", "param type invalid!! param:",param) end elseif data == "timeout" then log.info("mqtt_recieve.proc", "mqtt wait receive timeout!") else break end end return result or data=="timeout" or data=="LOCAL_PUB_MSG" end --定时上传因网络问题未上传的数据 function uploadOfflineData( ) sys.wait(5000) -- body while true do if socket.isReady() then -- body local uploadData, cn, des = getBaseInfo_ununique("wait2upload", nil, "/sdcard0/common/temp") if not uploadData then -- body log.info("wait2upload file is empty!", "count:", cn, "des:", des) else for k,v in pairs(uploadData) do sys.publish("LOCAL_PUB_MSG", json.encode(v) ) local uploadRes,msgid = sys.waitUntil("WAIT_UPDATA_RESP_SUCCESS", 3000) -- log.info("msgid:", msgid, "v.data.msgid:", v.data.msgid) if uploadRes and msgid then local re,be,ce = delBaseInfo("wait2upload",v.data.msgid,"/sdcard0/common/temp") -- log.info("re:",re,"be:",be, "ce:",ce) end sys.wait(500) end end end sys.wait(10000) end end sys.taskInit(uploadOfflineData)