local protoc = require "protoc"
-- load schema from text
assert(protoc:loadfile("../proto/zmqmsg.proto"))

--数据采集数据包模拟


--接收到数据包接口
function recvTask(self, uuid, pri, typeName, bytes)
	local data = assert(pb.decode(typeName, bytes))
	print("数据采集任务:", uuid)
	print(require "serpent".block(data))
	
	local execDir
	if string.find(uuid, 'CPRIPORT1') ~= nil then
		execDir = 'F:\\ISON_Linux\\TestData\\HW\\CDD\\first'
	elseif string.find(uuid, 'CPRIPORT2') ~= nil then
		execDir = 'F:\\ISON_Linux\\TestData\\HW\\CDD\\second'
	else
		execDir = 'F:\\ISON_Linux\\TestData\\HW\\CDD\\data'
	end 
	
	
	local decoderData = {
		collReq = data.cllReq,
		execRsltDir = execDir
	}
	decoderData.collReq.ossName = data.ossNames[1]
	print("Decoder:")
	print(require "serpent".block(decoderData))
	
	--生成解码任务
	local  decoderBytes = assert(pb.encode("zmqmsg.DataDecodeReq", decoderData))
	self:sendRequest( "HW_DECODER", uuid..".Decoder", pri, "zmqmsg.DataDecodeReq", decoderBytes)
	
	local repData = {taskName = data.taskName, code = pb.enum("zmqmsg.taskReply.type", "SUCCESS")}
	local  bytes = assert(pb.encode("zmqmsg.taskReply", repData))
	return bytes
end