Feat: Added money transfer functions

server/functions.lua

@@ -609,3 +609,51 @@ function QBCore.Functions.PrepForSQL(source, data, pattern)
     end
     return true
 end
+
+---Do a money transactio between players
+---@param emitercid string
+---@param emitermoneytype string -- Only money types in QBConfig.Money.MoneyTypes
+---@param receivercid string
+---@param receivermoneytype string -- Only money types in QBConfig.Money.MoneyTypes
+---@param quant number
+---@param reason string
+---@return boolean
+function QBCore.Functions.TransferMoney(emitercid, emitermoneytype, receivercid, receivermoneytype, quant, reason)
+    local EmiterPlayer = QBCore.Functions.GetPlayerByCitizenId(emitercid)
+    local ReceiverPlayer = QBCore.Functions.GetPlayerByCitizenId(receivercid)
+    if not tonumber(quant) then return false end
+    quant = tonumber(quant) or 0
+    local errorOnLast = false
+    if EmiterPlayer then
+        if not EmiterPlayer.Functions.RemoveMoney(quant, emitermoneytype, reason) then return false end
+    else
+        local result = MySQL.single.await('SELECT money FROM players WHERE citizendid = ?', { emitercid })
+        if not result then return false end
+        result = json.decode(result)
+        result[emitermoneytype] -= quant
+        if not MySQL.update.await('UPDATE players SET money = ? WHERE citizenid = ?', { json.encode(result), emitercid }) then return false end
+    end
+    if ReceiverPlayer then
+        if not ReceiverPlayer.Functions.AddMoney(quant, receivermoneytype, reason) then errorOnLast = true end
+    else
+        local result = MySQL.single.await('SELECT money FROM players WHERE citizendid = ?', { receivercid })
+        if not result then errorOnLast = true end
+        result = json.decode(result)
+        result[receivermoneytype] += quant
+        if not MySQL.update.await('UPDATE players SET money = ? WHERE citizenid = ?', { json.encode(result), receivercid }) then return false end
+    end
+
+    if errorOnLast then
+        if EmiterPlayer then
+            if not EmiterPlayer.Functions.AddMoney(quant, emitermoneytype, reason) then return false end
+        else
+            local result = MySQL.single.await('SELECT money FROM players WHERE citizendid = ?', { emitercid })
+            if not result then return false end
+            result = json.decode(result)
+            result[emitermoneytype] += quant
+            if not MySQL.update.await('UPDATE players SET money = ? WHERE citizenid = ?', { json.encode(result), emitercid }) then return false end
+        end
+        return false
+    end
+    return true
+end

server/player.lua

@@ -337,6 +337,29 @@ function QBCore.Player.CreatePlayer(PlayerData, Offline)
         return true
     end
 
+    function self.Functions.TransferMoneyTo(emitermoneytype, receivercid, receivermoneytype, quant, reason)
+        local ReceiverPlayer = QBCore.Functions.GetPlayerByCitizenId(receivercid)
+        if not tonumber(quant) then return false end
+        quant = tonumber(quant) or 0
+        local errorOnLast = false
+        if not self.Functions.RemoveMoney(quant, emitermoneytype, reason) then return false end
+        if ReceiverPlayer then
+            if not ReceiverPlayer.Functions.AddMoney(quant, receivermoneytype, reason) then errorOnLast = true end
+        else
+            local result = MySQL.single.await('SELECT money FROM players WHERE citizendid = ?', { receivercid })
+            if not result then errorOnLast = true end
+            result = json.decode(result)
+            result[receivermoneytype] += quant
+            if not MySQL.update.await('UPDATE players SET money = ? WHERE citizenid = ?', { json.encode(result), receivercid }) then return false end
+        end
+
+        if errorOnLast then
+            self.Functions.AddMoney(quant, emitermoneytype, reason)
+            return false
+        end
+        return true
+    end
+
     function self.Functions.GetMoney(moneytype)
         if not moneytype then return false end
         moneytype = moneytype:lower()