StellaSora_DataLua/lua/gamecore/event/eventmanager.lua

local Event = require("GameCore.Event.Event")
local EntityEvent = require("GameCore.Event.EntityEvent")
local TimerManager
local TimerScaleType = require("GameCore.Timer.TimerScaleType")
local TimerResetType = require("GameCore.Timer.TimerResetType")
local EventManager = {}
local mapEvent, mapTempAdd, mapTempRemove, mapOnHitEventId, timerCheckReset
local timerCallback = function()
	local sEvent = ""
	for nId, _ in pairs(mapOnHitEventId or {}) do
		sEvent = sEvent .. tostring(nId) .. ", "
	end
	if sEvent ~= "" then
		printLog("EventManager 检查，没有复位事件：" .. sEvent)
	end
end
local CheckReset = function()
	if TimerManager == nil then
		TimerManager = require("GameCore.Timer.TimerManager")
	end
	if timerCheckReset == nil then
		timerCheckReset = TimerManager.Add(0, 10, EventManager, timerCallback, true, false, TimerScaleType.RealTime)
	else
		timerCheckReset:Reset(TimerResetType.ResetElapsed)
	end
end
local Pairlist = function(...)
	local tbParam = {}
	for i = 1, select("#", ...) do
		local param = select(i, ...)
		table.insert(tbParam, param)
	end
	return tbParam
end
local ProcAdd = function(nEventId)
	if mapEvent == nil or mapTempAdd == nil then
		return
	end
	local tbEventAdd = mapTempAdd[nEventId]
	if tbEventAdd == nil then
		return
	end
	if mapEvent[nEventId] == nil then
		mapTempAdd[nEventId] = nil
		return
	end
	local tbEventExist = mapEvent[nEventId]
	for iAdd, eventAdd in ipairs(tbEventAdd) do
		local bCanAdd = true
		for iExist, eventExist in ipairs(tbEventExist) do
			if eventExist._listener == eventAdd._listener and eventExist._callback == eventAdd._callback then
				bCanAdd = false
				break
			end
		end
		if bCanAdd == true then
			table.insert(tbEventExist, eventAdd)
		end
	end
	mapTempAdd[nEventId] = nil
end
local ProcRemove = function(nEventId)
	if mapEvent == nil or mapTempRemove == nil then
		return
	end
	local tbEventRemove = mapTempRemove[nEventId]
	if tbEventRemove == nil then
		return
	end
	if mapEvent[nEventId] == nil then
		mapTempRemove[nEventId] = nil
		return
	end
	local tbEventExist = mapEvent[nEventId]
	for iRemove, eventRemove in ipairs(tbEventRemove) do
		local nIndexExist
		for iExist, eventExist in ipairs(tbEventExist) do
			if eventExist._listener == eventRemove._listener and eventExist._callback == eventRemove._callback then
				nIndexExist = iExist
				break
			end
		end
		if nIndexExist ~= nil then
			table.remove(tbEventExist, nIndexExist)
		end
	end
	mapTempRemove[nEventId] = nil
end
function EventManager.Init()
	mapEvent = {}
	mapTempAdd = {}
	mapTempRemove = {}
	mapOnHitEventId = {}
	EventManager.InitEntityEvent()
end
function EventManager.Add(nEventId, listener, callback)
	if mapEvent == nil or mapOnHitEventId == nil or mapTempAdd == nil then
		return
	end
	if listener == nil or callback == nil then
		return
	end
	if mapOnHitEventId[nEventId] == nil then
		if mapEvent[nEventId] == nil then
			mapEvent[nEventId] = {}
		end
		local tbEvent = mapEvent[nEventId]
		for i, event in ipairs(tbEvent) do
			if event._listener == listener and event._callback == callback then
				return
			end
		end
		table.insert(tbEvent, Event.new(listener, callback))
	else
		if mapTempAdd[nEventId] == nil then
			mapTempAdd[nEventId] = {}
		end
		local tbEventAdd = mapTempAdd[nEventId]
		for i, eventAdd in ipairs(tbEventAdd) do
			if eventAdd._listener == listener and eventAdd._callback == callback then
				return
			end
		end
		table.insert(tbEventAdd, Event.new(listener, callback))
	end
end
function EventManager.Remove(nEventId, listener, callback)
	if mapEvent == nil or mapOnHitEventId == nil or mapTempRemove == nil then
		return
	end
	if listener == nil or callback == nil then
		return
	end
	if mapOnHitEventId[nEventId] == nil then
		local tbEvent = mapEvent[nEventId]
		if tbEvent == nil then
			return
		end
		local nIndex
		for i, event in ipairs(tbEvent) do
			if event._listener == listener and event._callback == callback then
				nIndex = i
				break
			end
		end
		if nIndex ~= nil then
			table.remove(tbEvent, nIndex)
		end
	else
		if mapTempRemove[nEventId] == nil then
			mapTempRemove[nEventId] = {}
		end
		local tbEventRemove = mapTempRemove[nEventId]
		for iRemove, eventRemove in ipairs(tbEventRemove) do
			if eventRemove._listener == listener and eventRemove._callback == callback then
				return
			end
		end
		table.insert(tbEventRemove, Event.new(listener, callback))
	end
end
function EventManager.RemoveAll(nEventId)
	if type(mapEvent) == "table" then
		mapEvent[nEventId] = nil
	end
	if type(mapTempAdd) == "table" then
		mapTempAdd[nEventId] = nil
	end
	if type(mapTempRemove) == "table" then
		mapTempRemove[nEventId] = nil
	end
end
function EventManager.Hit(nEventId, ...)
	if mapEvent == nil or mapOnHitEventId == nil then
		return
	end
	CheckReset()
	local tbEvent = mapEvent[nEventId]
	if tbEvent ~= nil and mapOnHitEventId[nEventId] == nil then
		mapOnHitEventId[nEventId] = true
		for i, event in ipairs(tbEvent) do
			if event ~= nil and event._listener ~= nil and event._callback ~= nil then
				if AVG_EDITOR == true then
					local bIgnore = false
					if event._listener.GetPanelId ~= nil and AVG_EDITOR_PLAYING == true and event._listener:GetPanelId() == PanelId.AvgEditor then
						bIgnore = true
					end
					if bIgnore ~= true then
						event._callback(event._listener, ...)
					end
				else
					event._callback(event._listener, ...)
				end
			end
		end
		mapOnHitEventId[nEventId] = nil
		ProcAdd(nEventId)
		ProcRemove(nEventId)
	elseif mapOnHitEventId[nEventId] ~= nil then
		printWarn("在同一帧里，不应重复触发同一事件，EvendId:" .. tostring(nEventId))
	end
end
local mapEntityEvent, mapTempEntityEventAdd, mapTempEntityEventRemove, mapOnHitEntityEventId
local ProcAddEntityEvent = function(nEventId)
	if mapEntityEvent == nil or mapTempEntityEventAdd == nil then
		return
	end
	local _mapExist = mapEntityEvent[nEventId]
	local _mapAdd = mapTempEntityEventAdd[nEventId]
	if _mapAdd == nil then
		return
	end
	if _mapExist == nil then
		mapTempEntityEventAdd[nEventId] = nil
		return
	end
	for nEntityId, tbEntityEventAdd in pairs(_mapAdd) do
		local tbEntityEventExist = _mapExist[nEntityId]
		if tbEntityEventExist == nil then
			_mapExist[nEntityId] = {}
			tbEntityEventExist = _mapExist[nEntityId]
		end
		for i, entityEventAdd in ipairs(tbEntityEventAdd) do
			local bCanAdd = true
			for ii, entityEventExist in ipairs(tbEntityEventExist) do
				if entityEventExist._listener == entityEventAdd._listener and entityEventExist._callback == entityEventAdd._callback then
					bCanAdd = false
					break
				end
			end
			if bCanAdd == true then
				table.insert(tbEntityEventExist, entityEventAdd)
			end
		end
	end
	mapTempEntityEventAdd[nEventId] = nil
end
local ProcRemoveEntityEvent = function(nEventId)
	if mapEntityEvent == nil or mapTempEntityEventRemove == nil then
		return
	end
	local _mapExist = mapEntityEvent[nEventId]
	local _mapRemove = mapTempEntityEventRemove[nEventId]
	if _mapRemove == nil then
		return
	end
	if _mapExist == nil then
		mapTempEntityEventRemove[nEventId] = nil
		return
	end
	for nEntityId, tbEntityEventRemove in pairs(_mapRemove) do
		local tbEntityEventExist = _mapExist[nEntityId]
		if tbEntityEventExist ~= nil then
			for i, entityEventRemove in ipairs(tbEntityEventRemove) do
				local nIndexExist
				for ii, entityEventExist in ipairs(tbEntityEventExist) do
					if entityEventExist._listener == entityEventRemove._listener and entityEventExist._callback == entityEventRemove._callback then
						nIndexExist = ii
						break
					end
				end
				if nIndexExist ~= nil then
					table.remove(tbEntityEventExist, nIndexExist)
				end
			end
		end
	end
	mapTempEntityEventRemove[nEventId] = nil
end
function EventManager.InitEntityEvent()
	mapEntityEvent = {}
	mapTempEntityEventAdd = {}
	mapTempEntityEventRemove = {}
	mapOnHitEntityEventId = {}
end
function EventManager.AddEntityEvent(nEventId, nEntityId, listener, callback)
	if mapEntityEvent == nil or mapOnHitEntityEventId == nil or mapTempEntityEventAdd == nil then
		return
	end
	if nEntityId == nil or listener == nil or callback == nil then
		return
	end
	if mapOnHitEntityEventId[nEventId] == nil then
		if mapEntityEvent[nEventId] == nil then
			mapEntityEvent[nEventId] = {}
		end
		local _map = mapEntityEvent[nEventId]
		if _map[nEntityId] == nil then
			mapEntityEvent[nEventId][nEntityId] = {}
		end
		local tbEntityEvent = _map[nEntityId]
		for i, entityEvent in ipairs(tbEntityEvent) do
			if entityEvent._listener == listener and entityEvent._callback == callback then
				return
			end
		end
		table.insert(tbEntityEvent, EntityEvent.new(listener, nEntityId, callback))
	else
		if mapTempEntityEventAdd[nEventId] == nil then
			mapTempEntityEventAdd[nEventId] = {}
		end
		local _map = mapTempEntityEventAdd[nEventId]
		if _map[nEntityId] == nil then
			mapTempEntityEventAdd[nEventId][nEntityId] = {}
		end
		local tbEntityEventAdd = _map[nEntityId]
		for i, entityEventAdd in ipairs(tbEntityEventAdd) do
			if entityEventAdd._listener == listener and entityEventAdd._callback == callback then
				return
			end
		end
		table.insert(tbEntityEventAdd, EntityEvent.new(listener, nEntityId, callback))
	end
end
function EventManager.RemoveEntityEvent(nEventId, nEntityId, listener, callback)
	if mapEntityEvent == nil or mapOnHitEntityEventId == nil or mapTempEntityEventRemove == nil then
		return
	end
	if nEntityId == nil or listener == nil or callback == nil then
		return
	end
	if mapOnHitEntityEventId[nEventId] == nil then
		local _map = mapEntityEvent[nEventId]
		if _map == nil then
			return
		end
		local tbEntityEvent = _map[nEntityId]
		if tbEntityEvent == nil then
			return
		end
		local nIndex
		for i, entityEvent in ipairs(tbEntityEvent) do
			if entityEvent._listener == listener and entityEvent._callback == callback then
				nIndex = i
				break
			end
		end
		if nIndex ~= nil then
			table.remove(tbEntityEvent, nIndex)
		end
	else
		if mapTempEntityEventRemove[nEventId] == nil then
			mapTempEntityEventRemove[nEventId] = {}
		end
		local _map = mapTempEntityEventRemove[nEventId]
		if _map[nEntityId] == nil then
			mapTempEntityEventRemove[nEventId][nEntityId] = {}
		end
		local tbEntityEventRemove = _map[nEntityId]
		for i, entityEventRemove in ipairs(tbEntityEventRemove) do
			if entityEventRemove._listener == listener and entityEventRemove._callback == callback then
				return
			end
		end
		table.insert(tbEntityEventRemove, EntityEvent.new(listener, nEntityId, callback))
	end
end
function EventManager.HitEntityEvent(nEventId, nEntityId, ...)
	if mapEntityEvent == nil or mapOnHitEntityEventId == nil then
		return
	end
	local _map = mapEntityEvent[nEventId]
	if _map ~= nil and mapOnHitEntityEventId[nEventId] == nil then
		local tbEntityEvent = _map[nEntityId]
		if tbEntityEvent ~= nil then
			mapOnHitEntityEventId[nEventId] = true
			for i, entityEvent in ipairs(tbEntityEvent) do
				if entityEvent ~= nil and entityEvent._listener ~= nil and entityEvent._callback ~= nil then
					entityEvent._callback(entityEvent._listener, ...)
				end
			end
			mapOnHitEntityEventId[nEventId] = nil
			ProcAddEntityEvent(nEventId)
			ProcRemoveEntityEvent(nEventId)
		end
	end
end
return EventManager