pay/alipaynew/notify_url.php

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

<?php
require_once("../../function/conn.php");
require_once("../../function/function.php");


$alipayPublicKey=$C_alipaynewkey2;
$aliPay = new AlipayService($alipayPublicKey);
$_POST['fund_bill_list'] = stripslashes($_POST['fund_bill_list']);
$result = $aliPay->rsaCheck($_POST,$_POST['sign_type']);


$trade_no=$_POST["trade_no"];
$total_fee=$_POST["total_amount"];


if($result==1 && $_POST['trade_status'] == 'TRADE_SUCCESS'){
    echo 'success';

	if (strpos($_POST["body"], "|") !== false) {
	    $body = explode("|", $_POST["body"]);
	} else {
	    $O_ids = $_POST["body"];
	    $subject = $_POST["subject"];
	    $M_id = getrx("select * from ".TABLE."orders where O_id=" . intval(splitx($O_ids, ",", 0)) , "O_member");
	}

	if ($_POST["trade_status"] = "TRADE_SUCCESS") {
	    if (strpos($_POST["body"], "|") !== false) {
	        $sql = "Select * from ".TABLE."list Where L_no='" . t($trade_no) . "'";
	        $result = mysqli_query($conn, $sql);
	        $row = mysqli_fetch_assoc($result);
	        if (mysqli_num_rows($result) <= 0) {
	            mysqli_query($conn, "update ".TABLE."member set M_money=M_money+" . $body[1] . " where M_id=" . intval($body[0]));
	            mysqli_query($conn, "insert into ".TABLE."list(L_mid,L_title,L_change,L_time,L_no,L_type) values(" . $body[0] . ",'用户充值'," . $body[1] . ",'" . date('Y-m-d H:i:s') . "','" . $trade_no . "',0)");
	            sendmail("有用户通过支付宝充值", "用户ID：" . $body[0] . "<br>充值金额：" . $body[1] . "元<br>交易单号：" . $trade_no, $C_email);
	        }
	    } else {
	        $sql = "Select * from ".TABLE."list Where L_no='" . t($trade_no) . "'";
	        $result = mysqli_query($conn, $sql);
	        $row = mysqli_fetch_assoc($result);
	        if (mysqli_num_rows($result) <= 0) {
	            $O_id = explode(",", $O_ids);
	            for ($i = 0; $i < count($O_id); $i++) {
	                mysqli_query($conn, "update ".TABLE."orders set O_state=1,O_tradeno='" . $trade_no . "（支付宝付款）' where O_id=" . intval($O_id[$i]));

	                //虚拟商品发货
	                $O_pid=getrx("select * from ".TABLE."orders where O_id=".$O_id[$i],"O_pid");
	                $P_info=getrs("select * from ".TABLE."product where P_id=".$O_pid);
	                if($P_info["P_sence"]==1){
	                    mysqli_query($conn, "update ".TABLE."orders set O_state=3 where O_id=" . intval($O_id[$i]));
	                    $M_email=getrx("select * from ".TABLE."member where M_id=".$M_id,"M_email");
	                    sendmail("您购买的商品已发货","<p>商品名称：".lang($P_info["P_title"])."</p><p>价格：".$P_info["P_price"]."</p><p>发货内容：".$P_info["P_sell"]."</p>",URLDecode($M_email));
	                }

	            }
	            mysqli_query($conn, "update ".TABLE."member set M_fen=M_fen+" . $total_fee * $C_1yuan . " where M_id=" . intval($M_id));
	            mysqli_query($conn, "insert into ".TABLE."list(L_mid,L_title,L_change,L_time,L_no,L_type) values(" . $M_id . ",'用户充值'," . $total_fee . ",'" . date('Y-m-d H:i:s') . "','" . $trade_no . "',0)");
	            mysqli_query($conn, "insert into ".TABLE."list(L_mid,L_title,L_change,L_time,L_no,L_type) values(" . $M_id . ",'购买商品',-" . $total_fee . ",'" . date('Y-m-d H:i:s') . "','" . $trade_no . "',0)");
	            if ($C_1yuan > 0) {
	                mysqli_query($conn, "insert into ".TABLE."list(L_title,L_mid,L_change,L_time,L_type,L_no) values('购买商品'," . $M_id . "," . $total_fee * $C_1yuan . ",'" . date('Y-m-d H:i:s') . "',1,'" . $trade_no . "')");