asterisk 使用php脚本连接oralce数据库 通过AMI端口实现预拨号(批量外呼)
2011-06-27 17:07
1161 查看
1. cat /var/www/html/pre_dial.php
<?php
$server='10.236.22.116';
$port='5038';
$errstr='登陆失败';
$timeout=1;
$socket = fsockopen($server,$port, $errno, $errstr, $timeout); //连接服务器
if( $socket == false) { die ($errno.':'.$errstr); }
fputs($socket, "Action: login/r/n"); //登录
fputs($socket, "Username: admin/r/n"); //用户名
fputs($socket, "Secret: admin/r/n/r/n");//密码
if ($conn=OCILogon("kai","fjelite","linux"))
{ echo "SUCCESS ! Connected to database/n";
}
else
{echo "Failed :-( Could not connect to database/n";}
$stmt = OCIParse($conn,"select tel,area from hkh_tel where dial_mark= 0 ");//解析
OCIDefineByName($stmt,"TEL",&$TEL);//绑定
OCIDefineByName($stmt,"AREA",&$AREA);//绑定
OCIExecute($stmt);//执行语句
while
(
OCIFetch($stmt))
{
fputs($socket, "Action: Originate/r/n");
fputs($socket, "Channel: Local/$AREA$TEL@user/r/n");
fputs($socket, "CallerID: 10016/r/n");//来电显示的号码
fputs($socket, "WaitTime: 30/r/n");//等待被叫应答振铃时间
fputs($socket, "Exten: queue1/r/n");
fputs($socket, "Context: user/r/n");
fputs($socket, "Priority: 1/r/n");
fputs($socket, "Async: yes/r/n/r/n" );
$wrets=fgets($socket,128);
if (empty($TEL))
{
$p_num = '0';
}
else
{
$p_num = $TEL;
}
{
echo "TEL:".$TEL;
echo $p_num;
}
$Sql = " update hkh_tel set dial_mark=1 where tel= $p_num ";
$upd=OCIParse($conn,$Sql);
$result=OCIExecute($upd, OCI_DEFAULT);
if (!$result)
{
OCIRollback($conn);//不成功则回滚
OCIFreeStatement($upd); //释放资源
}
}
OCICommit($conn);//如果都成功则提交
OCIFreeStatement($stmt);//释放资源
OCILogoff($conn);
?>
2. /usr/bin/php /var/www/html/pre_dial.php
<?php
$server='10.236.22.116';
$port='5038';
$errstr='登陆失败';
$timeout=1;
$socket = fsockopen($server,$port, $errno, $errstr, $timeout); //连接服务器
if( $socket == false) { die ($errno.':'.$errstr); }
fputs($socket, "Action: login/r/n"); //登录
fputs($socket, "Username: admin/r/n"); //用户名
fputs($socket, "Secret: admin/r/n/r/n");//密码
if ($conn=OCILogon("kai","fjelite","linux"))
{ echo "SUCCESS ! Connected to database/n";
}
else
{echo "Failed :-( Could not connect to database/n";}
$stmt = OCIParse($conn,"select tel,area from hkh_tel where dial_mark= 0 ");//解析
OCIDefineByName($stmt,"TEL",&$TEL);//绑定
OCIDefineByName($stmt,"AREA",&$AREA);//绑定
OCIExecute($stmt);//执行语句
while
(
OCIFetch($stmt))
{
fputs($socket, "Action: Originate/r/n");
fputs($socket, "Channel: Local/$AREA$TEL@user/r/n");
fputs($socket, "CallerID: 10016/r/n");//来电显示的号码
fputs($socket, "WaitTime: 30/r/n");//等待被叫应答振铃时间
fputs($socket, "Exten: queue1/r/n");
fputs($socket, "Context: user/r/n");
fputs($socket, "Priority: 1/r/n");
fputs($socket, "Async: yes/r/n/r/n" );
$wrets=fgets($socket,128);
if (empty($TEL))
{
$p_num = '0';
}
else
{
$p_num = $TEL;
}
{
echo "TEL:".$TEL;
echo $p_num;
}
$Sql = " update hkh_tel set dial_mark=1 where tel= $p_num ";
$upd=OCIParse($conn,$Sql);
$result=OCIExecute($upd, OCI_DEFAULT);
if (!$result)
{
OCIRollback($conn);//不成功则回滚
OCIFreeStatement($upd); //释放资源
}
}
OCICommit($conn);//如果都成功则提交
OCIFreeStatement($stmt);//释放资源
OCILogoff($conn);
?>
2. /usr/bin/php /var/www/html/pre_dial.php
相关文章推荐
- asterisk 使用php脚本socket通过AMI端口实现自动打电话报警
- PHP使用PHPExcel实现批量上传到数据库的方法
- 使用PHP连接多种数据库的实现代码(mysql,access,sqlserver,Oracle)
- 使用PHP连接数据库_实现用户数据的增删改查的整体操作示例
- 使用PHP连接多种数据库的实现代码(mysql,access,sqlserver,Oracle)
- 使用PHP连接数据库实现留言板功能的实例讲解(推荐)
- 通过代理类实现java连接数据库(使用dao层操作数据)实例分享
- 通过VS中的数据源选择对话框实现数据库连接配置(用户使用)
- 使用shell脚本实现php应用的批量更新
- 通过Visual Studio 2005 中的数据源选择对话框实现数据库连接配置(用户使用)
- java 连接数据库sql出现”通过端口 1433 连接到主机 localhost 的 TCP/IP 连接失败“
- PHP连接MySQL数据库及以表格输出数据库数据的实现
- 利用javabean轻松实现对数据库的连接、查询以及增删改!------使用范例
- 通过Modem拨号实现连接
- PHP实现基于PDO扩展连接PostgreSQL对象关系数据库示例
- PHP使用sqlSrv连接微软数据库
- php使用PDO扩展连接PostgreSQL对象关系数据库
- VC++中使用MFC通过ADO连接数据库方法小结
- PHP MYSQL 使用 PDO 连接数据库并执行 SQL 语句
- PHP中使用mysqli连接数据库例子