WAP订购管理接口源程序(php版本)


答案：WAP订购接口其实很简单，用以前1.5的实现方法http post方式也可以实现。

思路很简单:程序作为http post服务器接收一个xml消息后，对消息体进行解析，进行入库操作(入库操作起不到实际作用，主要是为了对账，你完全可以不处理任何消息，而直接返回一个xml处理成功的包)，然后向卓望返回一个处理结果的xml包。

代码供刚入门wap的php程序员学习，附源代码如下：

＜?php
ob_start();
$isParseTransactionID=FALSE; //是否解析到
$isParseServiceID=FALSE; //是否解析到服务ID
$isParseMID=FALSE; //否解析到梦网ID
$isDestUser=FALSE; //否解析到普通用户的信息
$isParseActionID=FALSE; //用户操作码
$TransactionID=NULL; //事物ID
$ParseServiceID=NULL; //服务ID
$ParseMID=NULL; //梦网ID
$ParseActionID=NULL;
$ResultID=0; //处理结果。默认为成功
$data=$HTTP_RAW_POST_DATA;
writeFile("1.txt",$data);//写接收内容到文件
$parser=xml_parser_create(); //创建解析器实例
xml_set_element_handler($parser,"startElement","endElement"); //开始和结束时执行，函数自定义的
xml_set_character_data_handler($parser,"characterData"); //数据操作，函数自定义的
xml_parse($parser,$data,true); //解析器实例|数据|是否动送出最后的资料区段
xml_parser_free($parser); //释放解析器,以下进行数据库操作，判断定购关系，并返回给卓望处理结果
include_once "include/mysql.php";
$operator=new MySQL($host,$user,$passwd,$database);
$conn=$operator-＞Connect();
$SPServiceID="0000000111"; //服务ID
$datatime=date("Y-m-d H:i:s"); //得到当前日期
$sql = "select state from custom where mid ='$ParseMID' and service_id ='$SPServiceID'"; //查找是否定购了服务
$sql1 = "insert into custom values('$SPServiceID','$ParseMID','1','$datatime')"; //插入MID的订购记录
$sql5 = "update custom set state = '1' where mid ='$ParseMID' and service_id ='$SPServiceID'"; //MID取消该服务的订购的状态
$sql2 = "update custom set state = '2' where mid ='$ParseMID' and service_id ='$SPServiceID'"; //MID取消该服务的订购的状态
$sql3 = "update custom set state = '3' where mid ='$ParseMID' and service_id ='$SPServiceID'"; //MID激活该服务的订购状态 
$sql4 = "update custom set state = '4' where mid ='$ParseMID' and service_id ='$SPServiceID'"; //暂停服务
switch($ParseActionID)
{
case 1: //开通服务
if(FindServiceID($ParseServiceID))
{//找到serviceid
if(FindMID($ParseMID))
{
$res=$operator-＞Query($sql,$conn);
$rows=$operator-＞getRowsTop($res);//取出顶层对象
if($rows[0]==1)//4007： MISC 同步开通服务,但SP 端已存在订购关系,且状态为开通
{
$ResultID = "4007";
}
if($rows[0]==2)
{
$res=$operator-＞Query($sql5,$conn);
$ResultID = "0";
}
}
else
{//没找到就插入
$operator-＞Query($sql1,$conn);
$ResultID = "0"; //0 ： 成功开通
}
}
else //服务ID错误了
{//4004： 无效的serviceID
$ResultID = "4004";
}
break;




case 2:
if(FindServiceID($ParseServiceID))
{//取消服务，只要找到mid立刻让他取消
if(FindMID($ParseMID))
{
$res=$operator-＞Query($sql2,$conn);
$ResultID = "0";
}
else
{//4005： 无效的pseudocode
$ResultID = "4005";
}
}
else
{//4004： 无效的serviceID
$ResultID = "4004";
}
break;



case 3:
if(FindServiceID($ParseServiceID)) 
{
if(FindMID($ParseMID))
{
$res=$operator-＞Query($sql,$conn);
$rows=$operator-＞getRowsTop($res);//取出顶层对象
if($rows[0]==4)
{//激活成功
$operator-＞Query($sql3,$conn);
$ResultID = "0";
}
else
{//4015： MISC 同步激活服务, 但SP 端已存在订购关系, 且状态为开通
$ResultID = "4015";
}
}
else
{//无效的pseudocode
$ResultID = "4005";
}
}
else
{//4004： 无效的serviceID
$ResultID = "4004";
}
break;
case 4:
if(FindServiceID($ParseServiceID)) 
{
if(FindMID($ParseMID))
{
$res=$operator-＞Query($sql,$conn);
$rows=$operator-＞getRowsTop($res);//取出顶层对象
if($rows[0]==4)
{
$ResultID = "4014";
}
else
{//MISC 同步暂停服务, 但SP 端已存在订购关系, 且状态为暂停
$operator-＞Query($sql4,$conn);
$ResultID = "0";
}
}
else
{
$ResultID = "4005";
}
}
else
{
//4004： 无效的serviceID
$ResultID = "4004";
}
break;
default:
$ResultID="4001";
}
$operator-＞Close($conn);
$XMLData='
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xmlns:xsd="http://www.w3.org/2001/XMLSchema";
xmlns:SOAP-ENV="http://schemas.xmlsoap.org/soap/envelope/";
xmlns:SOAP-ENC="http://schemas.xmlsoap.org/soap/encoding/";＞

'"＞http://www.monternet.com/dsmp/schemas/";＞';
$XMLData.="$TransactionID";
$XMLData.='



1.5.0
SyncOrderRelationResp
'.$ResultID.'


';
$XMLData=trim($XMLData);
$length = strlen($XMLData); 
writeFile("2.txt",$XMLData);
header('Connection: close'); 
header('Content-Length:'.$length); 
header('Content-Type: text/xml'); 
header('Date: '.date('r')); 
echo $XMLData;
function FindServiceID($sid) 
{ //查找本项业务是