JAM_Garage_Server.lua

local JAG = JAM.Garage

function JAG:GetPlayerVehicles(identifier)  
  local playerVehicles = {}
  local data = MySQL.Sync.fetchAll("SELECT * FROM owned_vehicles WHERE owner=@identifier",{['@identifier'] = identifier}) 
  for key,val in pairs(data) do
    if (not val.job or val.job == nil) and (val.type and val.type == "car") then
      local playerVehicle = json.decode(val.vehicle)
      table.insert(playerVehicles, {owner = val.owner, veh = val.vehicle, vehicle = playerVehicle, plate = val.plate, state = val.jamstate})
    end
  end
  return playerVehicles
end

ESX.RegisterServerCallback('JAG:StoreVehicle', function(source, cb, vehicleProps)
  local isFound = false
  local xPlayer = ESX.GetPlayerFromId(source)
  while not xPlayer do
    xPlayer = ESX.GetPlayerFromId(source)
    Citizen.Wait(0)
  end

  local playerVehicles = JAG:GetPlayerVehicles(xPlayer.getIdentifier())
  local plate = vehicleProps.plate

  for key,val in pairs(playerVehicles) do
    if(plate == val.plate) then
      local vehProps = json.encode(vehicleProps)
      MySQL.Sync.execute("UPDATE owned_vehicles SET vehicle=@vehProps WHERE plate=@plate",{['@vehProps'] = vehProps, ['@plate'] = val.plate})
      isFound = true
      break
    end
  end
  cb(isFound)
end)

ESX.RegisterServerCallback('JAG:GetVehicles', function(source, cb)
  local xPlayer = ESX.GetPlayerFromId(source)
  while not xPlayer do
    xPlayer = ESX.GetPlayerFromId(source)
    Citizen.Wait(0)
  end
  local vehicles = JAG:GetPlayerVehicles(xPlayer.getIdentifier())
  cb(vehicles)
end)


RegisterNetEvent('JAG:FinePlayer')
AddEventHandler('JAG:FinePlayer', function(amount)
  local xPlayer = ESX.GetPlayerFromId(source)
  while not xPlayer do
    xPlayer = ESX.GetPlayerFromId(source)
    Citizen.Wait(0)
  end

  xPlayer.removeMoney(amount)
end)

RegisterNetEvent('JAG:ChangeState')
AddEventHandler('JAG:ChangeState', function(plate, state)
  local xPlayer = ESX.GetPlayerFromId(source)
  while not xPlayer do
    xPlayer = ESX.GetPlayerFromId(source)
    Citizen.Wait(0)
  end

  local vehicles = JAG:GetPlayerVehicles(xPlayer.getIdentifier())
  for key,val in pairs(vehicles) do
    if(plate == val.plate) then
      MySQL.Sync.execute("UPDATE owned_vehicles SET jamstate=@state WHERE plate=@plate",{['@state'] = state , ['@plate'] = plate})
      break
    end   
  end
end)

function JAG.Startup()
  while not JAM.SQLReady do 
    Citizen.Wait(0)
  end

  local dbconvar = GetConvar('mysql_connection_string', 'Empty')
  if dbconvar == "Empty" then print("JAG.Startup(): Error: local dbconvar is empty."); return; end

  local strStart,strEnd = string.find(dbconvar, "database=")
  local dbStart,dbEnd = string.find(dbconvar,";",strEnd)
  local dbName = string.sub(dbconvar, strEnd + 1, dbEnd - 1)  

    local dbconfig  =
    {
      ["@dbname@"]  = dbName,
      ["@dbtable@"] = "owned_vehicles",
      ["@dbfield@"] = "jamstate",
      ["@dbfieldconf@"] = "int(11) NOT NULL DEFAULT 0",
    }

    local query1 = "SELECT * FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_SCHEMA ='@dbname@' and COLUMN_NAME='@dbfield@' and TABLE_NAME='@dbtable@';"
    local query2 = "ALTER TABLE `@dbtable@` ADD COLUMN `@dbfield@` @dbfieldconf@;"

    local curquery1 = JAG.Replace(dbconfig,query1)
    local curquery2 = JAG.Replace(dbconfig,query2)

    local data = MySQL.Sync.fetchAll( curquery1 )
    if #data == 0 then MySQL.Sync.fetchAll( curquery2 );  end;
end

function JAG.Replace(c,q)
    for repThis,repWith in pairs(type(c) == "table" and c or {}) do q = tostring(q):gsub(repThis,repWith); end;
    return q
end

RegisterNetEvent('JAG:Startup')
AddEventHandler('JAG:Startup', JAG.Startup)