m3 = require("oi_base_mobox")
|
lua = require("oi_base_func")
|
json = require("json")
|
mobox = require("OILua_JavelinExt")
|
wms_base = require("wms_base")
|
wms_cntr = require("wms_container")
|
|
local ams_plc = {
|
_version = "0.1.1"
|
}
|
|
-- 读出线体任务号 转换为我们的任务号
|
function ams_plc.ReadPlcTaskNo(strLuaDEID, taskno1, taskno2)
|
lua.Debug(strLuaDEID, debug.getinfo(1), "ReadPlcTaskNo:", "IN")
|
|
local no1 = tostring(taskno1) -- 确保输入是字符串
|
if #no1 < 4 then
|
no1 = string.rep("0", 4 - #no1) .. no1
|
end
|
|
local no2 = tostring(taskno2) -- 确保输入是字符串
|
if #no2 < 4 then
|
no2 = string.rep("0", 4 - #no2) .. no2
|
end
|
local shortYear = os.date("%y")
|
return "TA" .. shortYear .. no1 .. "-" .. no2
|
end
|
|
-- 将我们的任务号 转换为写入线体的任务号
|
function ams_plc.WritePlcTaskNo(strLuaDEID, taskno)
|
-- 2. 截取倒数第五位到倒数第八位（共4个字符）
|
local no1 = string.sub(taskno, -9, -6)
|
-- 1. 截取最后四位
|
local no2 = string.sub(taskno, -4)
|
|
-- 转换为数字再转回字符串（自动去除前导零）
|
local Numberno1 = tonumber(no1)
|
-- 转换为数字再转回字符串（自动去除前导零）
|
local Numberno2 = tonumber(no2)
|
|
return Numberno1, Numberno2
|
end
|
|
-- 写连续数据到S7的通讯项
|
function ams_plc.WriteMultiS7PLCCommsData(strLuaDEID, devicecode, commcode, comm_value)
|
local nRet, strRetInfo, canshu
|
|
-- comm_value为数组 {1}、{1,2} 可以写DInt
|
local canshu = {
|
device_code = devicecode,
|
comm_code = commcode,
|
value = comm_value
|
}
|
|
local strKey = "OpenInfo"
|
local strSecret = "OpenInfoSecret"
|
local strHeader = ''
|
-- 获取Header
|
nRet, strHeader = mobox.genReqVerify(strKey, strSecret)
|
strHeader = string.gsub(strHeader, "ReqTime", "\nReqTime")
|
strHeader = string.gsub(strHeader, "ReqVerify", "\nReqVerify")
|
-- lua.DebugEx(strLuaDEID, "strHeader:", strHeader)
|
local strurl = "http://192.168.1.205:5121/api/devctrl/WriteMultiData"
|
local strBody = lua.table2str(canshu)
|
-- lua.DebugEx(strLuaDEID, "接口调用前参数:", strBody)
|
nRet, strRetInfo = mobox.sendHttpRequest(strurl, strHeader, strBody)
|
if (nRet ~= 0 or strRetInfo == '') then
|
lua.Stop(strLuaDEID,
|
"S7PLC 写入失败! device_code = " .. devicecode .. " comm_code = " .. commcode .. "错误码:" .. nRet ..
|
" " .. strRetInfo)
|
return
|
end
|
-- lua.DebugEx(strLuaDEID, "写PLC返回信息:", strRetInfo)
|
local api_ret = json.decode(strRetInfo)
|
if (api_ret.err_code ~= 0) then
|
lua.Stop(strLuaDEID,
|
"S7PLC 写入失败! device_code = " .. devicecode .. " comm_code = " .. commcode .. "错误码:" ..
|
api_ret.err_code .. " --> " .. api_ret.err_msg)
|
end
|
|
return nRet
|
end
|
--- 从内存中获取设备信息
|
function ams_plc.ReadS7PLCCommsData(strLuaDEID, devicecode, commcode)
|
|
local nRet, strRetInfo, api_ret
|
-- 开始调用
|
local canshu = {
|
device_code = devicecode,
|
comm_code = commcode
|
}
|
|
local strKey = "OpenInfo"
|
local strSecret = "OpenInfoSecret"
|
local strHeader = ''
|
-- 获取Header
|
nRet, strHeader = mobox.genReqVerify(strKey, strSecret)
|
strHeader = string.gsub(strHeader, "ReqTime", "\nReqTime")
|
strHeader = string.gsub(strHeader, "ReqVerify", "\nReqVerify")
|
-- lua.DebugEx(strLuaDEID, "strHeader:", strHeader)
|
|
local strBody = lua.table2str(canshu)
|
local strurl = "http://192.168.1.205:5121/api/devctrl/GetCommData"
|
-- lua.DebugEx(strLuaDEID, "接口调用前参数:", strBody)
|
|
nRet, strRetInfo = mobox.sendHttpRequest(strurl, strHeader, strBody)
|
-- lua.DebugEx(strLuaDEID, "接口调用后返回信息:", strRetInfo)
|
if (nRet ~= 0 or strRetInfo == '') then
|
lua.Stop(strLuaDEID,
|
"调用OIDeviceCommS接口ReadData失败! device_code = " .. devicecode .. " comm_code = " .. commcode ..
|
"错误码:" .. nRet .. " " .. strRetInfo)
|
return 1
|
end
|
local api_ret = json.decode(strRetInfo)
|
if (api_ret.err_code ~= 0) then
|
lua.Stop(strLuaDEID,
|
"调用OIDeviceCommS接口ReadData失败! device_code = " .. devicecode .. " comm_code = " .. commcode ..
|
"错误码:" .. api_ret.err_code .. " " .. api_ret.err_msg)
|
return 1
|
end
|
|
local retinfo = api_ret.result
|
return retinfo
|
end
|
|
-- 写数据到PLC
|
function ams_plc.WriteS7PLCCommsData(strLuaDEID, devicecode, commcode, comm_value)
|
local nRet, strRetInfo, canshu
|
|
-- comm_value为数组 {1}、{1,2} 可以写DInt
|
local canshu = {
|
device_code = devicecode,
|
comm_code = commcode,
|
value = comm_value
|
}
|
|
local strKey = "OpenInfo"
|
local strSecret = "OpenInfoSecret"
|
local strHeader = ''
|
-- 获取Header
|
nRet, strHeader = mobox.genReqVerify(strKey, strSecret)
|
strHeader = string.gsub(strHeader, "ReqTime", "\nReqTime")
|
strHeader = string.gsub(strHeader, "ReqVerify", "\nReqVerify")
|
lua.Debug(strLuaDEID, debug.getinfo(1), "strHeader:", strHeader)
|
local strurl = "http://192.168.1.205:5121/api/devctrl/writedata"
|
local strBody = lua.table2str(canshu)
|
lua.Debug(strLuaDEID, debug.getinfo(1), "接口调用前参数:", strBody)
|
nRet, strRetInfo = mobox.sendHttpRequest(strurl, strHeader, strBody)
|
if (nRet ~= 0 or strRetInfo == '') then
|
lua.Error(strLuaDEID, debug.getinfo(1),
|
"S7PLC 写入失败! device_code = " .. devicecode .. " comm_code = " .. commcode .. "错误码:" .. nRet ..
|
" " .. strRetInfo)
|
end
|
-- lua.Debug(strLuaDEID, debug.getinfo(1), "写PLC返回信息:", strRetInfo)
|
local api_ret = json.decode(strRetInfo)
|
if (api_ret.err_code ~= 0) then
|
lua.Error(strLuaDEID, debug.getinfo(1),
|
"S7PLC 写入失败! device_code = " .. devicecode .. " comm_code = " .. commcode .. "错误码:" ..
|
api_ret.err_code .. " --> " .. api_ret.err_msg)
|
end
|
return 0
|
end
|
|
-- 根据任务号或托盘号返回当前任务信息
|
function ams_plc.ReturnTaskEnd(strLuaDEID, task_no, cntr_code)
|
|
-- lua.Debug(strLuaDEID, debug.getinfo(1), "ReturnTaskEnd:", "IN")
|
|
local nRet, task_info, end_loc
|
if (task_no ~= "") then
|
nRet, task_info = m3.GetDataObjByCondition(strLuaDEID, "Task", "S_CODE = '" .. task_no .. "'", "T_CREATE DESC")
|
if (nRet ~= 0) then
|
lua.Stop(strLuaDEID, " ReturnTaskEnd 获取属性失败! " .. task_info)
|
end
|
-- lua.DebugEx(strLuaDEID, "task_info:", task_info)
|
|
-- end_loc = task_info.end_loc_code -- 当前任务终点
|
end
|
|
if (cntr_code ~= "") then
|
nRet, task_info = m3.GetDataObjByCondition(strLuaDEID, "Task", "S_CNTR_CODE = '" .. cntr_code .. "'",
|
"T_CREATE DESC")
|
if (nRet ~= 0) then
|
lua.Stop(strLuaDEID, " ReturnTaskEnd 获取属性失败! " .. task_info)
|
end
|
-- end_loc = task_info.end_loc_code -- 当前任务终点
|
end
|
-- lua.DebugEx(strLuaDEID, "ReturnTaskEnd end_loc:", end_loc)
|
|
return task_info
|
end
|
|
-- 根据任务终点或托盘 返回是否有执行中的任务 yes/no
|
function ams_plc.IsTaskExec(strLuaDEID, end_loc, cntr_code)
|
local nRet, task_info, isexist
|
-- 获取任务信息
|
if (end_loc ~= "") then
|
local sqlCondition = "S_END_LOC = '" .. end_loc .. "' AND N_B_STATE = 2"
|
nRet, isexist = mobox.existThisData(strLuaDEID, "Task", sqlCondition)
|
if (nRet ~= 0) then
|
lua.Error("IsTaskExec 获取【任务表】信息失败! " .. isexist)
|
end
|
-- lua.Debug(strLuaDEID, debug.getinfo(1), " IsTaskExec 获取【终点】" .. end_loc .. "信息成功!", isexist)
|
end
|
|
if (cntr_code ~= "") then
|
local sqlCondition = "S_CNTR_CODE = '" .. cntr_code .. "' AND N_B_STATE = 2"
|
nRet, isexist = mobox.existThisData(strLuaDEID, "Task", sqlCondition)
|
if (nRet ~= 0) then
|
lua.Error("IsTaskExec 获取【任务表】信息失败! " .. isexist)
|
end
|
-- lua.Debug(strLuaDEID, debug.getinfo(1), "IsTaskExec 获取【任务】" .. cntr_code .. "信息成功!", isexist)
|
end
|
return isexist
|
end
|
|
-- 更新输送线任务终点
|
function ams_plc.UpdateEndLoc(strLuaDEID, task_no, end_loc)
|
-- lua.Debug(strLuaDEID, debug.getinfo(1), "UpdateEndLoc", "IN")
|
local nRet, updateTask
|
-- 更新容器表
|
local strCondition = "S_CODE = '" .. task_no .. "' "
|
nRet, updateTask = mobox.updateDataAttrByCondition(strLuaDEID, "Task", strCondition,
|
"S_END_LOC = '" .. end_loc .. "'")
|
if (nRet ~= 0) then
|
lua.Error(strLuaDEID, debug.getinfo(1), " UpdateEndLoc 修改【任务终点】信息失败! " .. updateTask)
|
end
|
lua.Debug(strLuaDEID, debug.getinfo(1), "UpdateEndLoc 修改【任务" .. task_no .. "终点】信息成功!",
|
updateTask)
|
return 0
|
end
|
|
-- 输入任务号，设置任务为完成状态
|
function ams_plc.SetTaskComplete(strLuaDEID, task_no)
|
-- lua.Debug(strLuaDEID, debug.getinfo(1), " SetTaskComplete", "IN")
|
local nRet, task_info, strRetInfo, updateTask
|
local strCondition = "S_CODE = '" .. task_no .. "' "
|
nRet, updateTask = mobox.updateDataAttrByCondition(strLuaDEID, "Task", strCondition,
|
"S_B_STATE = '完成',N_B_STATE = 3")
|
if (nRet ~= 0) then
|
lua.stop(strLuaDEID, debug.getinfo(1), " SetTaskComplete 设置任务信息失败! " .. updateTask)
|
return
|
end
|
lua.Debug(strLuaDEID, debug.getinfo(1), " SetTaskComplete 设置任务" .. task_no .. "为完成状态成功!",
|
updateTask)
|
return 0
|
end
|
|
-- 根据作业编码判断是否存在已创建的堆垛机任务 yes/no
|
function ams_plc.IsExistTask(strLuaDEID, op_code)
|
-- lua.Debug(strLuaDEID, debug.getinfo(1), " IsExistTask", "IN")
|
local nRet, isExist_Task
|
local sqlCondition = "S_OP_CODE = '" .. op_code .. "' AND N_TYPE = 5 "
|
nRet, isExist_Task = mobox.existThisData(strLuaDEID, "Task", sqlCondition)
|
if (nRet ~= 0) then
|
lua.stop(" GetTaskInfo 获取【任务表】信息失败! " .. isExist_Task)
|
return
|
end
|
-- lua.DebugEx(strLuaDEID, " GetTaskInfo 获取【任务】" .. op_code .. "信息成功!", isExist_Task)
|
return isExist_Task
|
end
|
|
-- 根据堆垛机任务起点 判断是否存在已创建的堆垛机任务 yes/no
|
function ams_plc.IsExistTaskByStartLoc(strLuaDEID, start_loc)
|
-- lua.Debug(strLuaDEID, debug.getinfo(1), " IsExistTaskByStartLoc", "IN")
|
local nRet, isExist_Task
|
local sqlCondition = "S_START_LOC = '" .. start_loc .. "' AND N_TYPE = 5 AND N_B_STATE = 0 "
|
nRet, isExist_Task = mobox.existThisData(strLuaDEID, "Task", sqlCondition)
|
if (nRet ~= 0) then
|
lua.stop(" GetTaskInfo 获取【任务表】信息失败! " .. isExist_Task)
|
return
|
end
|
return isExist_Task
|
end
|
|
-- 判断有无正在执行的输送线入库任务 (入库接驳位时用，判断是否推双托) yes/no
|
function ams_plc.IsExistLineTask(strLuaDEID)
|
-- lua.DebugEx(strLuaDEID, "IsExistLineTask 查询有无正在执行的输送线入库任务", "IN")
|
local sqlCondition = "N_TYPE = 1 and N_SCHEDULE_TYPE = 4 and N_B_STATE = 2"
|
local nRet, isExist_LineTask = mobox.existThisData(strLuaDEID, "Task", sqlCondition)
|
if (nRet ~= 0) then
|
lua.stop(strLuaDEID, "IsExistLineTask 获取【任务表】信息失败! " .. isExist_LineTask)
|
return
|
end
|
-- lua.DebugEx(strLuaDEID, "IsExistLineTask 查询有无正在执行的输送线入库任务返回", isExist_LineTask)
|
return isExist_LineTask
|
end
|
|
-- 根据任务号/ 托盘码获取当前任务信息 (入库接驳位时用)
|
function ams_plc.GetTaskInfobyTaskno(strLuaDEID, task_no, cntr_code)
|
-- lua.DebugEx(strLuaDEID, "GetTaskInfobyTaskno!", "IN")
|
local nRet, strRetInfo
|
-- 根据任务号获取
|
if (task_no ~= "") then
|
nRet, strRetInfo = m3.GetDataObjByCondition(strLuaDEID, "Task", "S_CODE = '" .. task_no .. "'", "T_CREATE DESC")
|
if (nRet ~= 0) then
|
lua.Stop(strLuaDEID, "GetTaskInfobyTaskno 获取任务" .. task_no .. "信息失败! " .. strRetInfo)
|
return
|
end
|
end
|
|
-- 根据托盘码获取输送线入库执行中的任务
|
if (cntr_code ~= "") then
|
nRet, strRetInfo = m3.GetDataObjByCondition(strLuaDEID, "Task", "S_CNTR_CODE = '" .. cntr_code ..
|
"' AND N_TYPE = 1 AND N_B_STATE = 2", "T_CREATE DESC")
|
if (nRet ~= 0) then
|
lua.Stop(strLuaDEID, "GetTaskInfobyTaskno 获取任务" .. task_no .. "信息失败! " .. strRetInfo)
|
return
|
end
|
end
|
-- lua.DebugEx(strLuaDEID, "GetTaskInfobyTaskno返回的任务信息:", strRetInfo)
|
return strRetInfo
|
end
|
|
-- 托盘号查作业信息 (1072、1085、1099 入库称重点时用)
|
function ams_plc.QueryOpbyTray(strLuaDEID, cntr_code, op_code)
|
local nRet, strRetInfo
|
-- lua.DebugEx(strLuaDEID, "QueryOpbyTray", "IN")
|
if (cntr_code ~= "") then
|
local strCondition = "S_CNTR_CODE = '" .. cntr_code .. "'"
|
nRet, strRetInfo = m3.GetDataObjByCondition(strLuaDEID, "Operation", strCondition, "T_CREATE DESC")
|
if (nRet ~= 0) then
|
lua.Stop(strLuaDEID, "QueryOpbyTray 根据托盘" .. cntr_code .. "获取作业信息失败! " .. strRetInfo)
|
return
|
end
|
end
|
|
if (op_code ~= "") then
|
local strCondition = "S_OP_CODE = '" .. op_code .. "'"
|
nRet, strRetInfo = m3.GetDataObjByCondition(strLuaDEID, "Task", strCondition, "T_CREATE DESC")
|
if (nRet ~= 0) then
|
lua.Stop(strLuaDEID,
|
"QueryOpbyTray 根据作业" .. op_code .. "获取任务信息信息失败! " .. strRetInfo)
|
end
|
end
|
|
return strRetInfo
|
end
|
|
-- 创建入库输送线任务 1072->1019
|
-- 入库作业启动创建任务 创建后，将作业、输送线任务改为执行中
|
function ams_plc.PutInCreateTask(strLuaDEID, op_info, start_loc)
|
local nRet, updateOperation, updateTask
|
-- 创建输送线任务
|
-- 生成【任务】编码
|
local strCode
|
local strHeader = 'TA' .. os.date("%y%m%d") .. '-'
|
nRet, strCode = mobox.getSerialNumber("任务", strHeader, 4)
|
if (nRet ~= 0) then
|
lua.Stop(strLuaDEID, '申请【任务】编码失败!' .. strCode)
|
return
|
end
|
|
local task = m3.AllocObject(strLuaDEID, "Task")
|
task.code = strCode
|
task.op_code = op_info.code -- 作业编码
|
task.op_name = op_info.op_def_name -- 作业名称
|
task.factory = op_info.factory -- 工厂
|
task.cntr_code = op_info.cntr_code -- 托盘
|
task.start_lan = op_info.start_aisle -- 巷道
|
-- 起点
|
task.start_wh_code = op_info.start_wh_code
|
task.start_area_code = op_info.start_area_code
|
task.start_loc_code = start_loc -- 起点货位
|
|
-- 终点
|
task.end_wh_code = op_info.end_wh_code
|
task.end_area_code = op_info.end_area_code
|
task.end_loc_code = "1019" -- 终点
|
task.bs_state = 2
|
task.type = 1
|
task.schedule_type = 4
|
|
-- lua.Debug(strLuaDEID, debug.getinfo(1), 'WCS作业启动:', "生成作业数据" .. task)
|
-- 创建任务
|
nRet, task = m3.CreateDataObj(strLuaDEID, task)
|
if (nRet ~= 0) then
|
lua.Stop(strLuaDEID, "创建输送线任务失败!" .. task)
|
return
|
end
|
|
-- 更新作业状态为 1 执行
|
local strCondition = "S_CODE = '" .. op_info.code .. "' "
|
nRet, updateOperation = mobox.updateDataAttrByCondition(strLuaDEID, "Operation", strCondition,
|
"N_B_STATE = 1,S_B_STATE = '执行'")
|
if (nRet ~= 0) then
|
lua.Stop(strLuaDEID, " UpdateEndLoc 修改【任务终点】信息失败! " .. updateOperation)
|
return
|
end
|
return strCode
|
end
|
|
-- 创建堆垛机入库任务 (ok)
|
function ams_plc.CreateTask(strLuaDEID, start_loc, task_info)
|
|
lua.DebugEx(strLuaDEID, "创建堆垛机任务方法CreateTask", "IN")
|
-- 申请一个堆垛机任务号
|
-- 生成一个任务号
|
local nRet, task_no
|
local strCode
|
local strHeader = 'TA' .. os.date("%y%m%d") .. '-'
|
nRet, strCode = mobox.getSerialNumber("任务", strHeader, 4)
|
if (nRet ~= 0) then
|
lua.Stop(strLuaDEID, '申请【任务】编码失败!' .. strCode)
|
return
|
end
|
|
local task = m3.AllocObject(strLuaDEID, "Task")
|
task.code = strCode -- 任务号
|
task.op_code = task_info.op_code -- 作业编码
|
task.op_name = task_info.op_name -- 作业名称
|
task.factory = task_info.factory -- 工厂
|
task.cntr_code = task_info.cntr_code -- 托盘
|
|
-- 起点
|
task.start_wh_code = task_info.start_wh_code
|
task.start_area_code = task_info.start_area_code
|
task.start_loc_code = start_loc
|
-- 终点
|
task.end_wh_code = task_info.end_wh_code
|
task.end_area_code = task_info.end_area_code
|
task.end_loc_code = start_loc
|
|
-- task.type = wms_base.WMS_nConst(strLuaDEID, "任务类型-堆垛机入库搬运") -- 任务类型
|
-- task.schedule_type = wms_base.WMS_nConst(strLuaDEID, "调度类型-堆垛机") -- 设置调度类型
|
task.type = 5
|
task.schedule_type = 5
|
|
-- 创建任务
|
nRet, task = m3.CreateDataObj(strLuaDEID, task)
|
if (nRet ~= 0) then
|
lua.Stop(strLuaDEID, "创建堆垛机入库搬运任务失败!" .. task)
|
return
|
end
|
lua.DebugEx(strLuaDEID, "创建【线体编号为" .. start_loc .. "的输送线任务】信息成功!", task)
|
return strCode
|
end
|
|
-- 查作业信息 (1072、1085、1099 入库称重点时用)
|
function ams_plc.QueryOpbyopcode(strLuaDEID, op_code)
|
|
local nRet, strRetInfo
|
-- lua.DebugEx(strLuaDEID, "QueryOpbyTray", "IN")
|
local strCondition = "S_CODE = '" .. op_code .. "'"
|
nRet, strRetInfo = m3.GetDataObjByCondition(strLuaDEID, "Operation", strCondition, "T_CREATE DESC")
|
if (nRet ~= 0) then
|
lua.Stop(strLuaDEID, "QueryOpbyTray 根据作业号" .. op_code .. "获取作业信息失败! " .. strRetInfo)
|
return
|
end
|
return strRetInfo
|
end
|
|
-- 根据起点、状态获取任务信息 (获取wms堆垛机任务终点时用)
|
function ams_plc.Gettaskinfoforend(strLuaDEID, start_loc, status)
|
local nRet, strRetInfo
|
local strCondition = "S_START_LOC = '" .. start_loc .. "' AND N_B_STATE = " .. status
|
|
-- lua.DebugEx(strLuaDEID, "Gettaskinfoforend strCondition", strCondition)
|
nRet, strRetInfo = m3.GetDataObjByCondition(strLuaDEID, "Task", strCondition, "T_CREATE DESC")
|
if (nRet ~= 0) then
|
lua.Stop(strLuaDEID, "Gettaskinfoforend 根据起点" .. start_loc .. "获取作业信息失败! " .. strRetInfo)
|
return
|
end
|
-- lua.DebugEx(strLuaDEID, "Gettaskinfoforend 返回的信息", strCondition)
|
|
return strRetInfo
|
end
|
|
|
-- 接驳口创建设备动作优化用
|
function ams_plc.GetddjTaskInfo(strLuaDEID, op_code)
|
local nRet, strRetInfo
|
local strCondition = "S_OP_CODE = '" .. op_code .. "' AND N_TYPE = 5 AND N_B_STATE = 1 "
|
|
local nRet, isExistTask = mobox.existThisData(strLuaDEID, "Task", strCondition)
|
if (nRet ~= 0) then
|
lua.stop(strLuaDEID, "IsExistLineTask 获取【任务表】信息失败! " .. isExistTask)
|
return
|
end
|
-- lua.DebugEx(strLuaDEID, "IsExistLineTask 查询有无正在执行的输送线入库任务返回", isExist_LineTask)
|
return isExistTask
|
end
|
|
|
return ams_plc
|
