ESX = exports["es_extended"]:getSharedObject()
playerCache = {}

function GetPlayerFromCache(source)
  if playerCache[tonumber(source)] == nil then
    playerCache[tonumber(source)] = ESX.GetPlayerFromId(source)
  end
  return playerCache[tonumber(source)]
end

LR = {}
LR.__index = LR
local playerInZone = {}
local os_time = os.time
local coroutine_yield = coroutine.yield
function LR:Init()
  local o = {}
  setmetatable(o, LR)
  o.LastCapture = 0
  o.Zones = Config.Occ
  o.ZoneData = {}
  o.CurrentCapture = {}
  o.IsOpen = false
  GlobalState.LastCapture = 0
  GlobalState.CurrentCapture = {}
  GlobalState.Occ = o.Zones
  o.OnDev = false
  o.PressedPLayer = {}
  o:EventHandler()
  o:DelayThread()
  o:SQL()
  GlobalState.ostime = 0
  GlobalState.GangBlips = {
    ['HM'] = {
      sprite = 16,
      color = 1
    },
    ['LORD'] = {
      sprite = 77,
      color = 1
    },
    ['HLG'] = {
      sprite = 355,
      color = 1
    },
    ['ALS'] = {
      sprite = 76,
      color = 1
    },
    ['AOE'] = {
      sprite = 78,
      color = 1
    },
    ['GC'] = {
      sprite = 80,
      color = 1
    },



  }
  GlobalState.OccOpen = o.IsOpen
  return o
end

function LR:SQL()
  MySQL.ready(function()
    for k, v in pairs(self.Zones) do
      local data = MySQL.Sync.fetchAll("SELECT * FROM occ_data WHERE `index` = @index", { ['@index'] = k })
      if data[1] then
        v.owner = data[1].owner
      else
        MySQL.Sync.execute("INSERT INTO occ_data (`index`, owner) VALUE (@index, @owner)",
          { ['@index'] = k, ['@owner'] = v.owner })
      end
      self.ZoneData[k] = {}
    end
    GlobalState.Occ = self.Zones
    GlobalState.ZoneData = self.ZoneData
  end)
end

function LR:DelayThread()
  --GlobalState.OccDelay = 0
  -- Citizen.CreateThread(function()
  --   while true do
  --     Wait(1000)
  --     local d = os_time() - self.LastCapture
  --     GlobalState.ostime = os_time()
  --   end
  -- end)

  Citizen.CreateThread(function()
    while true do
      Wait(10 * 60 * 1000)
      for k, v in pairs(self.Zones) do
        if v.owner then
          -- MySQL.Async.execute('UPDATE dh_rank SET scores = scores + @point WHERE name = @name', {
          --   ['@name'] = v.owner,
          --   ['@point'] = 5
          -- })

          MySQL.Async.execute('UPDATE jobs SET point = point + @point WHERE name = @name', {
            ['@name'] = v.owner,
            ['@point'] = 5
          })
        end
      end
    end
  end)
end

function LR:EventHandler()
  AddEventHandler("playerDropped", function(reason)
    if playerCache[tonumber(source)] then
      if playerInZone[source] then
        local org = playerCache[tonumber(source)].job.name
        for k, v in pairs(self.ZoneData) do
          if v[org] then
            v[org] = v[org] - 1
            if v[org] == 0 then
              v[org] = nil
            end
            GlobalState.ZoneData = self.ZoneData
            break
          end
        end
        playerInZone[source] = nil
      end
      playerCache[tonumber(source)] = nil
    end
  end)
  AddEventHandler("esx:setJob", function(playerId, _org, lastorg)
    if playerInZone[playerId] then
      local org = lastorg.name
      local neworg = _org.name
      for k, v in pairs(self.ZoneData) do
        if v[org] then
          v[org] = v[org] - 1
          if v[org] == 0 then
            v[org] = nil
          end
          if v[neworg] then
            v[neworg] = v[neworg] + 1
          else
            v[neworg] = 1
          end
          GlobalState.ZoneData = self.ZoneData
          break
        end
      end
    end
  end)
  RegisterNetEvent("lr_occ2:server:join", function(index)
    local src = source
    print(src)
    print(src)
    local xPlayer = GetPlayerFromCache(source)
    local org = xPlayer.job.name
    if self.ZoneData[index][org] then
      if self.ZoneData[index][org] == 30 then --so nguoi chiem dong
        SetEntityCoords(GetPlayerPed(source), 236.00483703613, -876.13092041016, 30.031923294067, false, false,
          false, false)
        TriggerClientEvent("esx:showNotification", source, "Vượt quá số người cho phép")
      else
        playerInZone[source] = true
        -- SetPlayerRoutingBucket(src, 10)
        self.ZoneData[index][org] = self.ZoneData[index][org] + 1
      end
    else
      playerInZone[source] = true
      self.ZoneData[index][org] = 1
    end
    GlobalState.ZoneData = self.ZoneData
  end)
  RegisterNetEvent("lr_occ2:server:leave", function(index)
    local src = source
    -- print(src)
    -- print(src)
    local xPlayer = GetPlayerFromCache(source)
    local org = xPlayer.job.name
    if self.ZoneData[index][org] and playerInZone[source] then
      self.ZoneData[index][org] = self.ZoneData[index][org] - 1
      if self.ZoneData[index][org] == 0 then
        self.ZoneData[index][org] = nil
      end
      GlobalState.ZoneData = self.ZoneData
      playerInZone[source] = nil
      -- SetPlayerRoutingBucket(src, 0)
    end
  end)
  ESX.RegisterServerCallback('lr_occ2:callback:cC', function(source, cb, index)
    if self.IsOpen then
      if os_time() - self.LastCapture >= Config.Delay then
        local crZone = self.Zones[index]
        if crZone.lastCapture == nil or os_time() - crZone.lastCapture >= Config.DelayPoint then
          if self.CurrentCapture[index] == nil then
            if getLenght(self.CurrentCapture) < 1 then
              local xPlayer = ESX.GetPlayerFromId(source)
              if not self.PressedPLayer[xPlayer.identifier] then
                if crZone.owner and crZone.owner == xPlayer.job.name then
                  self:TriggerClientEvent(source, ("Khu vực này đã thuộc về bạn"))
                  cb(false)
                  return
                end
                cb(true)
              else
                cb(false)
                self:TriggerClientEvent(source,
                  ("Hiện có khu vực đang bị chiếm nên không thể chiếm khu vực này"))
              end
            else
              cb(false)
              self:TriggerClientEvent(source,
                ("Hiện có khu vực đang bị chiếm nên không thể chiếm khu vực này"))
            end
          else
            cb(false)
            self:TriggerClientEvent(source,
              ("Khu vực %s đang bị chiếm bởi %s"):format(crZone.Label, self.CurrentCapture[index].name))
          end
        else
          cb(false)
          self:TriggerClientEvent(source,
            ("Cần %s giây để có thể chiếm khu vực %s"):format(
              Config.Delay - (os_time() - crZone.lastCapture), crZone.Label))
        end
      else
        cb(false)
        self:TriggerClientEvent(source,
          ("Cần %s giây để có thể chiếm"):format(Config.Delay - (os_time() - self.LastCapture)))
      end
    else
      cb(false)
      self:TriggerClientEvent(source, "Chưa đến thời gian chiếm đóng")
    end
  end)
  ESX.RegisterServerCallback("lr_occ2:callback:CanCapture", function(source, cb, index, moves)
    local xPlayer = ESX.GetPlayerFromId(source)
    if self.OnDev then
      if xPlayer.group ~= 'superadmin' then
        cb(false)
        return
      end
    end
    if self.IsOpen then
      print(os_time() - self.LastCapture)
      if os_time() - self.LastCapture >= Config.Delay then
        local crZone = self.Zones[index]
        if crZone.lastCapture == nil or os_time() - crZone.lastCapture >= Config.DelayPoint then
          if self.CurrentCapture[index] == nil then
            if getLenght(self.CurrentCapture) < 1 then
              local xPlayer = ESX.GetPlayerFromId(source)
              if not self.PressedPLayer[xPlayer.identifier] then
                if crZone.owner and crZone.owner == xPlayer.job.name then
                  self:TriggerClientEvent(source, ("Khu vực này đã thuộc về bạn"))
                  cb(false)
                  return
                end
                if not Config.ExceptJobs[xPlayer.job.name] then
                  self:TriggerClientEvent(source, ("Tổ chức của bạn không có quyền chiếm đóng"))
                  return
                end
                --self.PressedPLayer[xPlayer.identifier] = true
                self.CurrentCapture[index] = {
                  name = xPlayer.name,
                  playerId = source,
                  startAt = os_time()
                }
                --self.LastCapture = os_time()
                crZone.lastCapture = os_time()
                GlobalState.Occ = self.Zones
                GlobalState.CurrentCapture = self.CurrentCapture
                GlobalState.LastCapture = os_time() - 480
                TriggerClientEvent("lr_occ2:client:startCapture", -1, index, "[" .. xPlayer.job.name .. "] " .. xPlayer
                  .name)
                self.crC = index
                cb(true)
                Citizen.CreateThread(function()
                  local time = crZone.time + os_time()
                  while true do
                    coroutine_yield(0)
                    if self.CurrentCapture[index] ~= nil then
                      Wait(1000)
                      if time <= os_time() then
                        if crZone.owner == nil then

                        else
                          self:RemovePoint(crZone.owner, crZone.point)
                        end
                        crZone.owner = xPlayer.job.name
                        crZone.lastCapture = os_time()
                        self.LastCapture = os_time()
                        self.CurrentCapture[index] = nil
                        GlobalState.Occ = self.Zones
                        GlobalState.CurrentCapture = self.CurrentCapture
                        GlobalState.LastCapture = os_time()
                        TriggerClientEvent("lr_occ:client:captured", -1, index, xPlayer.name,
                          xPlayer.job.name)
                        self:AddPoint(xPlayer.job.name, crZone.point, index)
                        break
                      end
                    else
                      self.CurrentCapture[index] = nil
                      GlobalState.CurrentCapture = self.CurrentCapture
                      print("Canceled")
                      break
                    end
                  end
                end)
              else
                cb(false)
                self:TriggerClientEvent(source,
                  ("Hiện có khu vực đang bị chiếm nên không thể chiếm khu vực này"))
              end
            else
              cb(false)
              self:TriggerClientEvent(source,
                ("Hiện có khu vực đang bị chiếm nên không thể chiếm khu vực này"))
            end
          else
            cb(false)
            self:TriggerClientEvent(source,
              ("Khu vực %s đang bị chiếm bởi %s"):format(crZone.Label, self.CurrentCapture[index].name))
          end
        else
          cb(false)
          self:TriggerClientEvent(source,
            ("Cần %s giây để có thể chiếm khu vực %s"):format(
              Config.Delay - (os_time() - crZone.lastCapture), crZone.Label))
        end
      else
        cb(false)
        self:TriggerClientEvent(source,
          ("Cần %s giây để có thể chiếm"):format(Config.Delay - (os_time() - self.LastCapture)))
      end
    else
      cb(false)
      self:TriggerClientEvent(source, "Chưa đến thời gian chiếm đóng")
    end
  end)

  RegisterCommand("chiemdong", function(source, args, rawCommand)
    if self.IsOpen then
      TriggerClientEvent("hm_hud:client:addCD", -1, 5 * 10, 'chiếm đóng', 'Kết thúc sau', 'warning',
        'fas fa-skull-crossbones')
    else
      TriggerClientEvent("hm_hud:client:addCD", -1, 5 * 10, 'chiếm đóng', 'Bắt đầu sau', 'warning',
        'fas fa-skull-crossbones')
    end
    Wait(10 * 1000)
    self.IsOpen = not self.IsOpen
    GlobalState.OccOpen = self.IsOpen
    TriggerClientEvent("lr_occ2:client:openOcc", -1, self.IsOpen)
  end, true)

  -- RegisterCommand("vaochiemdong", function(source, args, rawCommand)
  --   if self.IsOpen then
  --     SetPlayerRoutingBucket(source, 10)
  --   end
  -- end, false)

  RegisterCommand("thoatchiemdong", function(source, args, rawCommand)
    SetPlayerRoutingBucket(source, 0)
  end, false)

  AddEventHandler("esx:playerDropped", function(playerId)
    for k, v in pairs(self.CurrentCapture) do
      if v.playerId == playerId then
        self.CurrentCapture[k] = nil
        self.LastCapture = os_time() - 480
        --self.Zones[k].lastCapture = os_time()
        TriggerClientEvent("lr_occ:client:cancelCapture", -1, k, "")
        GlobalState.LastCapture = os_time() - 480
        return
      end
    end
  end)

  RegisterNetEvent("lr_occ2:server:cancelCapture", function()
    for k, v in pairs(self.CurrentCapture) do
      if v.playerId == source then
        local xPlayer = ESX.GetPlayerFromId(source)
        self.LastCapture = os_time() - 480
        GlobalState.LastCapture = os_time() - 480
        self.CurrentCapture[k] = nil
        --self.LastCapture = os_time()
        self.Zones[k].lastCapture = os_time() - 1200
        GlobalState.Occ = self.Zones
        TriggerClientEvent("lr_occ:client:cancelCapture", -1, k, "[" .. xPlayer.job.name .. "] " .. xPlayer.name)
        return
      end
    end
  end)

  --[[RegisterNetEvent("lr_occ:server:addPoint", function(gang, point)
    local data = MySQL.Sync.fetchAll("SELECT * FROM dh_rank WHERE `name` = @name", {['@name'] = gang})
            if data[1] then
	MySQL.Async.execute('UPDATE dh_rank SET scores = scores + @scores WHERE name = @name', {
        ['@name'] = gang,
        ['@scores'] = tonumber(point)
    })
            end
    end)--]]

  RegisterCommand("occdev", function(source, args, rawCommand)
    self.OnDev = not self.OnDev
  end)
  lib.callback.register("lr_occ2:callback:getCurCapture", function(source)
    return self.crC
  end)
end

function LR:TriggerClientEvent(playerId, msg)
  TriggerClientEvent("esx:showNotification", playerId, msg)
end

function LR:AddPoint(orgName, point, index)
  MySQL.Async.execute('UPDATE jobs SET point = point + @point WHERE name = @name', {
    ['@name'] = orgName,
    ['@point'] = point
  })
  --[[MySQL.Async.execute('UPDATE dh_rank SET scores = scores + @point WHERE name = @name', {
        ['@name'] = orgName,
        ['@point'] = point
    })--]]
  MySQL.Async.execute("UPDATE occ_data SET owner = @owner WHERE `index` = @index", {
    ['@owner'] = orgName,
    ['@index'] = index
  })
end

function LR:RemovePoint(orgName, point)
  MySQL.Async.execute('UPDATE jobs SET point = point - @point WHERE name = @name', {
    ['@name'] = orgName,
    ['@point'] = point
  })
  --[[MySQL.Async.execute('UPDATE dh_rank SET scores = scores - @point WHERE name = @name', {
        ['@name'] = orgName,
        ['@point'] = point
    })--]]
end

function getLenght(tb)
  local c = 0
  for k, v in pairs(tb) do
    c = c + 1
  end
  return c
end

LR:Init()