dbxe/fusionpbx
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Add. Use params in call_flow.lua (#2145)

Browse Source
This commit is contained in:
Alexey Melnichuk
2016-11-22 11:09:48 -07:00
committed by FusionPBX
parent 4b26e8d237
commit a7bd0b0864
1 changed files with 17 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
resources/install/scripts/call_flow.lua
+17 -7
View File
@@ -37,6 +37,12 @@
local file = require "resources.functions.file" local file = require "resources.functions.file"
local log = require "resources.functions.log".call_flow local log = require "resources.functions.log".call_flow
--include json library
local json
if (debug["sql"]) then
json = require "resources.functions.lunajson"
end
--connect to the database --connect to the database
local dbh = Database.new('system'); local dbh = Database.new('system');
@@ -72,14 +78,15 @@ local function find_file(dbh, domain_name, domain_uuid, file_name)
local storage_type = settings:get('recordings', 'storage_type', 'text') or '' local storage_type = settings:get('recordings', 'storage_type', 'text') or ''
if storage_type == 'base64' then if storage_type == 'base64' then
local sql = "SELECT recording_base64 FROM v_recordings " local sql = "SELECT recording_base64 FROM v_recordings "
.. "WHERE domain_uuid = '" .. domain_uuid .."'" .. "WHERE domain_uuid = :domain_uuid"
.. "AND recording_filename = '".. file_name.. "' " .. "AND recording_filename = :file_name "
local params = {domain_uuid = domain_uuid, file_name = file_name};
if (debug["sql"]) then if (debug["sql"]) then
log.notice("SQL: " .. sql) log.notice("SQL: " .. sql .. "; params: " .. json.encode(params))
end end
local dbh = Database.new('system', 'base64/read') local dbh = Database.new('system', 'base64/read')
local recording_base64 = dbh:first_value(sql); local recording_base64 = dbh:first_value(sql, params);
dbh:release(); dbh:release();
if recording_base64 and #recording_base64 > 32 then if recording_base64 and #recording_base64 > 32 then
@@ -149,11 +156,12 @@ if (session:ready()) then
local default_voice = session:getVariable("default_voice") or 'callie'; local default_voice = session:getVariable("default_voice") or 'callie';
--get the extension list --get the extension list
local sql = "SELECT * FROM v_call_flows where call_flow_uuid = '"..call_flow_uuid.."'" local sql = "SELECT * FROM v_call_flows where call_flow_uuid = :call_flow_uuid"
-- .. "and call_flow_enabled = 'true'" -- .. "and call_flow_enabled = 'true'"
local params = {call_flow_uuid = call_flow_uuid};
--log.notice("SQL: %s", sql); --log.notice("SQL: %s", sql);
dbh:query(sql, function(row) dbh:query(sql, params, function(row)
call_flow_name = row.call_flow_name; call_flow_name = row.call_flow_name;
call_flow_extension = row.call_flow_extension; call_flow_extension = row.call_flow_extension;
call_flow_feature_code = row.call_flow_feature_code; call_flow_feature_code = row.call_flow_feature_code;
@@ -210,7 +218,9 @@ if (session:ready()) then
log.noticef("label=%s,status=%s,uuid=%s,audio=%s", active_flow_label, toggle, call_flow_uuid, audio_file) log.noticef("label=%s,status=%s,uuid=%s,audio=%s", active_flow_label, toggle, call_flow_uuid, audio_file)
--store in database --store in database
dbh:query("UPDATE v_call_flows SET call_flow_status = '"..toggle.."' WHERE call_flow_uuid = '"..call_flow_uuid.."'"); dbh:query("UPDATE v_call_flows SET call_flow_status = :toggle WHERE call_flow_uuid = :call_flow_uuid", {
toggle = toggle, call_flow_uuid = call_flow_uuid
});
--answer --answer
session:answer(); session:answer();