<?php

#创建日期：2012-4-17 下午3:18:45
#作者：zhouliang

include_once '/Common/MongoCommon.php';
include_once '/Common/ConfigReader.php';
include_once '/Common/CommFunc.php';
include_once '/Common/logging.php';
include_once '/ProjComm/CommonOperate.php';
include_once "/ProjComm/CfgReader.php";


function SendGameQueryCoin($qid, $orderAmount, $orderInfo, $orderID, $appID)
{

    \CfgReader\GetConfigData("Config", "GMKey", $key);

    $tool_page = "http://127.0.0.1/Server/Tool.php";
    if(\CfgReader\GetConfigData("ServerInfo", "GameServerWebPort_".$appID, $GameServerWebPort))
    {
        $tool_page = "http://127.0.0.1:".$GameServerWebPort."/Server/Tool.php";
    }
    $pack_data = array("queryType"=>"accID");
    $pack_data["playerFind"] = $qid;
    $pack_data["pack_type"] = "GMT_GetCoinReq";
    $pack_data["key"] = $key;
    $pack_data['coding'] = "gbk";

    //使用key加密
    $pack_data_dict = json_encode($pack_data);
    $sign = md5($pack_data_dict.$key);
    $post = array();
    $post['pack'] = $pack_data_dict;
    $post['sign'] = $sign;

    \Logging\LogInfo("post to page".$tool_page);
    \Logging\LogInfo("Send : ".print_r($post, true));
    \CommFunc\DoPost($tool_page, $post);

}


function Process_DataArray($DataArray, $DoName)
{
    \Logging\LogInfo("type: ".$DoName." recv: ".print_r($DataArray, true));
    
    # 返回充值结果
    $returnArr = array();
    $returnArr["errorcode"] = 0;
    $returnArr["errordesc"] = "fail";

    
    if (!array_key_exists("AccountID", $DataArray) ||
        !array_key_exists("RegionName", $DataArray) ||
        !array_key_exists("OrderAmount", $DataArray) ||
        !array_key_exists("BillNO", $DataArray) ||
        !array_key_exists("OrderInfo", $DataArray) ||
        !array_key_exists("OperatorID", $DataArray) ||
        !array_key_exists("Sign", $DataArray))
    {
        # \Logging\LogError("Param Err!".print_r($DataArray, true));
        $returnArr["errordesc"] = "param error.";
        echo json_encode($returnArr);
        return ;
    }

    $getServer_id = $DataArray["RegionName"];

    //读取配置文件
    if (!\CfgReader\ReadConfig())
    {
    	\Logging\LogError("读取配置文件失败, 错误原因:".\CfgReader\GetConfigErrInfo());
        $returnArr["errordesc"] = "Server init error.";
        echo json_encode($returnArr);
    	exit();
    }
    
    $opqid = $DataArray['AccountID'];
    $orderID = $DataArray["BillNO"];
    $orderAmount = $DataArray['OrderAmount'];
    $operatorID = $DataArray['OperatorID'];
    
    $changeAppID = '';  //新增一种平台标志，用于区分账号，如IOS和安卓是否混服同角色号处理
    if(!\CfgReader\GetConfigData("ServerInfo", "appid_".$operatorID, $changeAppID))
    {
        $changeAppID = $operatorID;     //未配置的取原appid
    }
    
    $qid = \CommonOperate\GetGameQid( $opqid, $getServer_id, $changeAppID);
    $recvSign = $DataArray['Sign'];
    
    \Logging\LogAddObj( \Logging\strServerDir, $getServer_id, ' SID:'.$getServer_id );
    \Logging\LogAddObj( \Logging\strUIDDir, $qid , ' QID:'.$qid  );
    
    \Logging\LogInfo( 'server_id:'.$getServer_id.' QID:'.$qid );
    
    if (!is_numeric($orderAmount)){
    	\Logging\LogError("发现参数order_amount数据异常 = ".$orderAmount);
        $returnArr["errordesc"] = "OrderAmount error.";
        echo json_encode($returnArr);
    	exit;
    }
    
    $strKey='';
    $isDecryptKey='';
    if( !\CfgReader\GetConfigData("ExChange", "Key_".$operatorID, $strKey) ||
        !\CfgReader\GetConfigData("Config", "IsDecryptKey", $isDecryptKey))
    {
        $returnArr["errordesc"] = "Server init error.";
        echo json_encode($returnArr);
    	return;	
    }
    
    //如果配置了需要解密，对登录key进行解密
    if ($isDecryptKey == 1)
    {
    	\Logging\LogInfo("需要对登录key进行解密，解密前key值:".$strKey);
    	$strKey = \CommFunc\GetDecodePsw($strKey);
    }
    
    \Logging\LogInfo("密钥key:".$strKey);
    
    
    #判断sign是否相等
    $sign=md5( $opqid.$orderAmount.$orderID.$getServer_id.$strKey );
    if( $sign!=$recvSign )	# $_GET['sign'] 一定得是字符串才可以通过此判断 所以不需要转换
    {
    	\Logging\LogInfo( '自己算出的签名是:'.$sign );
    	\Logging\LogInfo( '对方的签名是:'.$recvSign );
    	\Logging\LogWarn( '签名校验错误' );
        $returnArr["errordesc"] = "Sign error.";
        echo json_encode($returnArr);
    	return;
    }
    
    \Logging\LogInfo( '签名校验成功' );
    
    $scaleNum = 1;
    if(!\CfgReader\GetConfigData("ExChange", "ExChangeScale_".$operatorID, $scaleNum))
    {
        if(!\CfgReader\GetConfigData("ExChange", "ExChangeScale", $scaleNum))
        {
            \Logging\LogError( '读取充值转化比例出错' );
            exit;
        }
    }
    
    //支持两位小数
    $nOrderAmount = intval(round(floatval($orderAmount) * $scaleNum));
    
	$noOrderAmount = 0;
	\CfgReader\GetConfigData("ExChange", "NoOrderAmount", $noOrderAmount);
    if( $nOrderAmount<1 && $noOrderAmount != 1)
    {
        $returnArr["errordesc"] = "OrderAmount error.";
        echo json_encode($returnArr);
        return ;
    }
    
    \Logging\LogInfo( "传来的order_amount=".$orderAmount." 转换后:".$nOrderAmount );
    
    
    #先连接数据库
    if( !\CommonOperate\GetMongoDB( dirname(__FILE__).'\\..\\..\\InterfaceConfig.php',
    		'db', $mongoOpt ) )
    {
        $returnArr["errordesc"] = "db init error.";
        echo json_encode($returnArr);
    	return;
    }
    
    #查询数据库是否有数据，如果有返回重复
    
    $arrayCheck=array('ServerID'=>$getServer_id, 'AccID'=>$qid,
    					'OrderID'=>$orderID);
    
    if( $mongoOpt->IsDataExist( 'tagPayInfo', $arrayCheck ) )
    {
    	\Logging\LogInfo( '数据:'.var_export( $arrayCheck, true ).'已经存在，返回重复' );
    	$returnArr["errorcode"] = 2;
        $returnArr["errordesc"] = "Repeat Commit";
        echo json_encode($returnArr);
    	return;
    }

    $Extras = array_key_exists("Extras", $DataArray) ? $DataArray["Extras"] : "";

    // EndOrderTime 兑换游戏币成功后设置, IsProcess为0代表还没兑换
    $arrayInsert=array( '_id'=>$orderID, 'ServerID'=>$getServer_id, 
    					'AccID'=>$qid, 'OrderAmount'=>$nOrderAmount, 
    					'OrderID'=>$orderID, 'Sign'=>$recvSign, 
    					'BeginOrderTime'=>date("Y-m-d H:i:s"), 'EndOrderTime'=>0, 
                        'IsProcess'=>0, "OrderInfo"=>$DataArray['OrderInfo'], "Extras"=>$Extras);
    
    $arrayIndex=array( 'ServerID'=>1, 'AccID'=>1 );
    
    $mongoOpt->insert( 'tagPayInfo', $arrayInsert, $arrayIndex );
    
    if( $mongoOpt->IsDataExist( 'tagPayInfo', $arrayCheck ) )
    {
    	\Logging\LogInfo( '成功插入充值数据:'.var_export( $arrayInsert, true ) );
    	$returnArr["errorcode"] = 1;
    	$returnArr["errordesc"] = "Success";
    	echo json_encode($returnArr);
    	// 通知游戏有充值，需立即查询到账
    	// SendGameQueryCoin($qid, $nOrderAmount, $DataArray['OrderInfo'], $orderID, $changeAppID);
    	return;
    }
    
    else
    {
    	\Logging\LogError( '插入充值数据:'.var_export( $arrayInsert, true ).'失败' );
    	echo json_encode($returnArr);
    	return;
    }
}


function Process()
{
    \Logging\CreateLogging( "exchange" );
    \Logging\LogDebug("start...");
    \CommFunc\GLOBAL_RECV("Process_DataArray");
    \Logging\LogDebug("over...");
}

Process();

?>