zijia/source/plugin/xj_event/event_pay_wx_notify.php

<?php

define('IN_API', true);
define('CURSCRIPT', 'api');
require '../../../source/class/class_core.php';
require '../../../source/function/function_forum.php';
include 'include/sms_func.php';
if(!$_GET['echostr']){
	$_GET['formhash'] = formhash();
}
$discuz = C::app();
$discuz->init();


if(file_exists($xj_event_wxset = DISCUZ_ROOT.'./data/sysdata/cache_xj_event_wxset.php')) {
	@include $xj_event_wxset;
}

if(function_exists('file_get_contents')){
	$xml = file_get_contents("php://input");
}else{
	$xml = $GLOBALS["HTTP_RAW_POST_DATA"];
}
$post = xmlToArray($xml);

$paytype = DB::result_first("SELECT paytype FROM ".DB::table('xj_eventpay_log')." WHERE tradeno='".$post['out_trade_no']."'");

if($paytype == 'appwxpay'){
	$apikey = $wxset['open_apikey'];  //APIKEY
}elseif($paytype == 'xcxwxpay'){
	$apikey = $wxset['xcx_apikey'];  //APIKEY
}else{
	$apikey = $wxset['apikey'];  //APIKEY
}

if(checkSign($post)){

	if($post['result_code'] == 'SUCCESS'){
		$paylog = DB::fetch_first("SELECT * FROM ".DB::table('xj_eventpay_log')." WHERE tradeno='".$post['out_trade_no']."'");
		if($paylog['paystate'] != 3){	
			$data = array();
			$data['paystate'] = 3;
			$data['orderid'] = $post['transaction_id'];
			$data['pay_time'] = $_G['timestamp'];
			$data['notify_time'] = $_G['timestamp'];
			DB::update("xj_eventpay_log",$data,"tradeno='".$post['out_trade_no']."'");
			$paylog = DB::fetch_first("SELECT applyid,trade_status,uid,tid FROM ".DB::table('xj_eventpay_log')." WHERE tradeno='".$post['out_trade_no']."'");
			$tid = $paylog['tid'];
			$uid = $paylog['uid'];
			$data = array();
			$data['pay_state'] = 1;
			$data['verify'] = 1;
			DB::update("xj_eventapply",$data,"tid=$tid AND uid=$uid");
			
			
			//邀请的奖励处理
			$items = DB::fetch(DB::query("SELECT A.*,B.authorid,B.subject FROM ".DB::table('xj_event')." A LEFT JOIN ".DB::table('forum_thread')." B ON A.tid = B.tid WHERE A.tid = $tid"));
			$setting = unserialize($items['setting']);
			if($setting['yqjl_jfs']>0){
				$apply = DB::fetch_first("SELECT * FROM ".DB::table('xj_eventapply')." WHERE applyid = ".$paylog['applyid']);
				if($apply['fromuid'] > 0){
					$applynumber = DB::result_first("SELECT SUM(applynumber) FROM ".DB::table('xj_eventapply')." WHERE tid=".$tid." AND uid=".$uid);	
					$yqjl = array();
					$yqjl['tid'] = $tid;
					$yqjl['fromuid'] = $apply['fromuid'];
					$yqjl['applyuid'] = $uid;
					$yqjl['jfs'] = $setting['yqjl_jfs']*$applynumber;
					$yqjl['jflx'] = $setting['yqjl_jflx'];
					$yqjl['dateline'] = $_G['timestamp'];
					DB::insert('xj_event_yqjl_log',$yqjl);
					updatemembercount($yqjl['fromuid'],array($yqjl['jflx']=>+$yqjl['jfs']));
					$username = DB::result_first("SELECT username FROM ".DB::table('common_member')." WHERE uid=$uid");
					$eventtitle = DB::result_first("SELECT subject FROM ".DB::table('forum_thread')." WHERE tid = $tid");
					notification_add($yqjl['fromuid'],'system',$username.lang('plugin/xj_event','beiniyaoqinbaomincanjiale').' <a href="forum.php?mod=viewthread&tid='.$tid.'" target="_blank">'.$eventtitle.'</a> '.lang('plugin/xj_event','huodonghuode').$yqjl['jfs'].$_G['setting']['extcredits'][$yqjl['jflx']]['title'].lang('plugin/xj_event','jiangli'));
				}
			}
			paysmssend($tid,$uid);
			//通知
			$username = DB::result_first("SELECT username FROM ".DB::table('common_member')." WHERE uid=$uid");
			if($_G['charset']=='gbk'){
				notification_add($items['authorid'], 'system', $username.iconv('UTF-8','GBK','报名参加了你的活动').' <a href="forum.php?mod=viewthread&tid='.$tid.'" target="_blank">'.$items['subject'].'</a> '.iconv('UTF-8','GBK','并已支付活动费用'),array(),0);
			}else{
				notification_add($items['authorid'], 'system', $username.'报名参加了你的活动 <a href="forum.php?mod=viewthread&tid='.$tid.'" target="_blank">'.$items['subject'].'</a> 并已支付活动费用',array(),0);
			}
            //微信消息
            loadcache('plugin');
            if($_G['cache']['plugin']['xj_wxmessage']['wxlogin']){
                require_once DISCUZ_ROOT . './source/plugin/xj_wxmessage/class/core.class.php';
                $xj_wxmessagecore = new xj_wxmessagecore();
                $xj_wxmessagecore->send_eventmessage($uid,$tid,1);
                $xj_wxmessagecore->send_eventapplymessage($paylog['applyid'],$items['authorid'],2);
            }

			
		}
		$return = array();
		$return['return_code'] = 'SUCCESS';  //SUCCESS/FAIL   SUCCESS表示商户接收通知成功并校验成功
		$return['return_msg'] = 'ok';  //返回信息，如非空，为错误原因
	}else{
		$return = array();
		$return['return_code'] = 'FAIL';  //SUCCESS/FAIL   SUCCESS表示商户接收通知成功并校验成功
		$return['return_msg'] = 'ERROR';  //返回信息，如非空，为错误原因
	}
	echo arrayToXml($return);
}else{
	//调试记录开始
	$log_name="./wxpay.txt";//log文件路径
	log_result($log_name,"【签名".$apikey."不正确】:\r\n".$xml."\r\n【返回的信息】:".arrayToXml($return)."\r\n");
	//调试记录结
	exit('error');
}






//调试记录开始
//$log_name="./wxpay.txt";//log文件路径
//log_result($log_name,"【接收到的notify通知】:\r\n".$xml."\r\n【返回的信息】:".arrayToXml($return)."\r\n");
//调试记录结束




/*

$url='http://'.$_SERVER['SERVER_NAME'].$_SERVER["REQUEST_URI"];
$url = str_replace('source/plugin/xj_event/event_pay_wx_notify.php','plugin.php?id=xj_event:wsq_pay_notify',$url); 
$return = postxml($url,$xml);

*/




function paysmssend($tid,$uid){
	global $_G;
	//调试记录开始
	//$log_name="./alipay.txt";//log文件路径
	//log_result($log_name,"【接收到的notify通知】:\r\n".$xml."\r\n【返回的信息】:\r\n");
	//调试记录结束
	
	$apply = DB::fetch_first("SELECT * FROM ".DB::table('xj_eventapply')." WHERE first=1 AND tid=$tid AND uid=$uid");
	$thread = DB::fetch_first("SELECT authorid,userfield,setting,subject,starttime,event_address FROM ".DB::table('forum_thread')." A,".DB::table('xj_event')." B WHERE A.tid=$tid and A.tid = B.tid");
	$setting = unserialize($thread['setting']);
	$event_starttime = dgmdate($thread['starttime'],'dt');
	if($setting['seccode'] == 1){		
		$message = cutstr($thread['subject'],30).'活动报名成功，人数:'.$apply['applynumber'].'人 验证码:'.$apply['seccode'].' 活动时间:'.$event_starttime;
		$sendtype = '报名验证码短信';
		if($_G[charset]=='gbk'){
			$message = diconv($message,'UTF-8','GBK');
			$sendtype = diconv($sendtype,'UTF-8','GBK');
		}
		sendsms_vcode($apply['mobile'],$thread['subject'],$apply['applynumber'],$apply['seccode']);
		//xjsendsms(array($apply['mobile']),$message,$sendtype);
		sendpm($apply['uid'],'',$message,$thread['authorid']);
	}elseif($setting['success_sms'] == 1){
		sendsms_success($apply['mobile'],$thread['subject'],$event_starttime);
		//易活动短信
		//$smsuid = DB::result_first("SELECT uid FROM ".DB::table('common_member')." WHERE username='".$setting['event_admin'][0]."'");
		//$smsmobile = DB::result_first("SELECT mobile FROM ".DB::table('common_member_profile')." WHERE uid=$smsuid");
		//sendsms_notice_yhd($apply['mobile'],$thread['subject'],$event_starttime,$thread['event_address'],$smsmobile);
		
	}
}




function postxml($url,$data){
	$ch = curl_init($url); 
	curl_setopt($ch, CURLOPT_MUTE, 1); 
	curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0); 
	curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0); 
	curl_setopt($ch, CURLOPT_POST, 1); 
	curl_setopt($ch, CURLOPT_HTTPHEADER, array('Content-Type: text/xml')); 
	curl_setopt($ch, CURLOPT_POSTFIELDS, "$data"); 
	curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); 
	$output = curl_exec($ch); 
	curl_close($ch); 
	return $output;
}

/**
 * 	作用：array转xml
 */
function arrayToXml($arr)
{
	$xml = "<xml>";
	foreach ($arr as $key=>$val)
	{
		 if (is_numeric($val))
		 {
			$xml.="<".$key.">".$val."</".$key.">"; 

		 }
		 else
			$xml.="<".$key."><![CDATA[".$val."]]></".$key.">";  
	}
	$xml.="</xml>";
	return $xml; 
}

/**
 * 	作用：将xml转为array
 */
function xmlToArray($xml)
{		
	//将XML转为array        
	$array_data = json_decode(json_encode(simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA)), true);		
	return $array_data;
}

// 打印log
function  log_result($file,$word) 
{
	$fp = fopen($file,"a");
	flock($fp, LOCK_EX) ;
	fwrite($fp,"执行日期：".strftime("%Y-%m-%d-%H：%M：%S",time())."\n".$word."\n\n");
	flock($fp, LOCK_UN);
	fclose($fp);
}
/**
* 	作用：格式化参数，签名过程需要使用
*/
function formatBizQueryParaMap($paraMap, $urlencode)
{
	$buff = "";
	ksort($paraMap);
	foreach ($paraMap as $k => $v)
	{
		if($urlencode)
		{
		   $v = urlencode($v);
		}
		//$buff .= strtolower($k) . "=" . $v . "&";
		$buff .= $k . "=" . $v . "&";
	}
	$reqPar;
	if (strlen($buff) > 0) 
	{
		$reqPar = substr($buff, 0, strlen($buff)-1);
	}
	return $reqPar;
}
//生成签名
function getSign($Obj){
	global $apikey;
	foreach ($Obj as $k => $v)
	{
		$Parameters[$k] = $v;
	}
	//签名步骤一：按字典序排序参数
	ksort($Parameters);
	$String = formatBizQueryParaMap($Parameters, false);
	//echo '【string1】'.$String.'</br>';
	//签名步骤二：在string后加入KEY
	$String = $String."&key=$apikey";
	//echo "【string2】".$String."</br>";
	//签名步骤三：MD5加密
	$String = md5($String);
	//echo "【string3】 ".$String."</br>";
	//签名步骤四：所有字符转为大写
	$result_ = strtoupper($String);
	//echo "【result】 ".$result_."</br>";
	return $result_;
}
//验证签名是否正确
function checkSign($xmlarray){
	$tmpData = $xmlarray;
	unset($tmpData['sign']);
	$sign = getSign($tmpData);//本地签名
	//调试记录开始
	//$log_name="./wxpay.txt";//log文件路径
	//log_result($log_name,"【本地签名】:\r\n".$sign."\r\n");
	//调试记录结
	if ($xmlarray['sign'] == $sign) {
		return TRUE;
	}
	return FALSE;
}


function postXmlCurl($xml,$url,$second=30)
{		
	//初始化curl        
	$ch = curl_init();
	//设置超时
	curl_setopt($ch, CURLOP_TIMEOUT, $second);
	//这里设置代理，如果有的话
	//curl_setopt($ch,CURLOPT_PROXY, '8.8.8.8');
	//curl_setopt($ch,CURLOPT_PROXYPORT, 8080);
	curl_setopt($ch,CURLOPT_URL, $url);
	curl_setopt($ch,CURLOPT_SSL_VERIFYPEER,FALSE);
	curl_setopt($ch,CURLOPT_SSL_VERIFYHOST,FALSE);
	//设置header
	curl_setopt($ch, CURLOPT_HEADER, FALSE);
	//要求结果为字符串且输出到屏幕上
	curl_setopt($ch, CURLOPT_RETURNTRANSFER, TRUE);
	//post提交方式
	curl_setopt($ch, CURLOPT_POST, TRUE);
	curl_setopt($ch, CURLOPT_POSTFIELDS, $xml);
	//运行curl
	$data = curl_exec($ch);
	curl_close($ch);
	//返回结果
	if($data)
	{
		curl_close($ch);
		return $data;
	}
	else 
	{ 
		$error = curl_errno($ch);
		echo "curl error:$error"."<br>"; 
		echo "<a href='http://curl.haxx.se/libcurl/c/libcurl-errors.html'>error view</a></br>";
		curl_close($ch);
		return false;
	}
}
?>