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').' '.$eventtitle.' '.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','报名参加了你的活动').' '.$items['subject'].' '.iconv('UTF-8','GBK','并已支付活动费用'),array(),0);
}else{
notification_add($items['authorid'], 'system', $username.'报名参加了你的活动 '.$items['subject'].' 并已支付活动费用',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 = "";
foreach ($arr as $key=>$val)
{
if (is_numeric($val))
{
$xml.="<".$key.">".$val."";
}
else
$xml.="<".$key.">";
}
$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.'';
//签名步骤二：在string后加入KEY
$String = $String."&key=$apikey";
//echo "【string2】".$String."";
//签名步骤三：MD5加密
$String = md5($String);
//echo "【string3】 ".$String."";
//签名步骤四：所有字符转为大写
$result_ = strtoupper($String);
//echo "【result】 ".$result_."";
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"."
";
echo "error view";
curl_close($ch);
return false;
}
}
?>