nsinnovations/fusionpbx
2
0
Fork 0
mirror of https://github.com/fusionpbx/fusionpbx.git synced 2026-01-06 11:43:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add. Use params in follow_me.lua (#2117)

Browse Source
This commit is contained in:
Alexey Melnichuk
2016-11-22 08:04:44 +03:00
committed by FusionPBX
parent 15b9b33a5f
commit f39a1147c5
1 changed files with 25 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

42
resources/install/scripts/follow_me.lua
View File

@@ -32,6 +32,10 @@
local log = require "resources.functions.log".follow_me
local cache = require "resources.functions.cache"
local Database = require "resources.functions.database"
local json
if (debug["sql"]) then
json = require "resources.functions.lunajson"
end
--check if the session is ready
if not session:ready() then return end
@@ -62,13 +66,14 @@
--determine whether to update the dial string
local sql = "select extension, number_alias, accountcode, follow_me_uuid ";
sql = sql .. "from v_extensions ";
sql = sql .. "where domain_uuid = '"..domain_uuid.."' ";
sql = sql .. "and extension_uuid = '"..extension_uuid.."' ";
sql = sql .. "where domain_uuid = :domain_uuid ";
sql = sql .. "and extension_uuid = :extension_uuid ";
local params = {domain_uuid=domain_uuid, extension_uuid=extension_uuid};
if (debug["sql"]) then
log.notice(sql);
log.notice("SQL: %s; params: %s", sql, json.encode(params));
end
local row = dbh:first_row(sql)
local row = dbh:first_row(sql, params)
if not row then return end
local extension = row.extension;
@@ -79,13 +84,14 @@
--determine whether to update the dial string
sql = "select follow_me_enabled, call_prompt, cid_name_prefix, cid_number_prefix, dial_string "
sql = sql .. "from v_follow_me ";
sql = sql .. "where domain_uuid = '"..domain_uuid.."' ";
sql = sql .. "and follow_me_uuid = '"..follow_me_uuid.."' ";
sql = sql .. "where domain_uuid = :domain_uuid ";
sql = sql .. "and follow_me_uuid = :follow_me_uuid ";
local params = {domain_uuid=domain_uuid, follow_me_uuid=follow_me_uuid};
if (debug["sql"]) then
log.notice(sql);
log.notice("SQL: %s; params: %s", sql, json.encode(params));
end
row = dbh:first_row(sql)
row = dbh:first_row(sql, params)
if not row then return end
local enabled = row.follow_me_enabled;
@@ -123,28 +129,30 @@
else
sql = sql .. "follow_me_enabled = 'true' ";
end
sql = sql .. "where domain_uuid = '"..domain_uuid.."' ";
sql = sql .. "and follow_me_uuid = '"..follow_me_uuid.."' ";
sql = sql .. "where domain_uuid = :domain_uuid ";
sql = sql .. "and follow_me_uuid = :follow_me_uuid ";
local params = {domain_uuid=domain_uuid, follow_me_uuid=follow_me_uuid};
if (debug["sql"]) then
log.notice(sql);
log.notice("SQL: %s; params: %s", sql, json.encode(params));
end
dbh:query(sql);
dbh:query(sql, params);
--update the extension
sql = "update v_extensions set ";
if (enabled == "true") then
sql = sql .. "dial_string = null, ";
else
sql = sql .. "dial_string = '"..dial_string:gsub("'", "''").."', ";
sql = sql .. "dial_string = :dial_string, ";
end
sql = sql .. "do_not_disturb = 'false', ";
sql = sql .. "forward_all_enabled= 'false' ";
sql = sql .. "where domain_uuid = '"..domain_uuid.."' ";
sql = sql .. "and extension_uuid = '"..extension_uuid.."' ";
sql = sql .. "where domain_uuid = :domain_uuid ";
sql = sql .. "and extension_uuid = :extension_uuid ";
local params = {domain_uuid=domain_uuid, extension_uuid=extension_uuid, dial_string = dial_string};
if (debug["sql"]) then
log.notice(sql);
log.notice("SQL: %s; params: %s", sql, json.encode(params));
end
dbh:query(sql);
dbh:query(sql, params);
--clear the cache
if (extension ~= nil) and cache.support() then