
步骤 2: 在回调url中使用cookie
在response.php页面中,获取Cookie中存储的ID,并将其用于关联数据。
步骤 3: 修改数据库操作
在数据库中,使用Cookie中的ID作为关联键,替代原来的Session ID。在processor.php中插入数据时,将$unique_id存入数据库,在response.php中查询数据时,也使用$unique_id作为查询条件。
示例代码:修改后的processor.php
access_token; } $curl = curl_init(); curl_setopt($curl, CURLOPT_URL, $initiate_url); curl_setopt($curl, CURLOPT_HTTPHEADER, array('Content-Type:application/json','Authorization:Bearer '.newAccessToken())); $curl_post_data = array( 'BusinessShortCode' =>$BusinessShortCode, 'Password' => $Password, 'Timestamp' => $Timestamp, 'TransactionType' => 'CustomerPayBillOnline', 'Amount' => $Amount, 'PartyA' => $PartyA, 'PartyB' => $BusinessShortCode, 'PhoneNumber' => $PartyA, 'CallBackURL' => $callBackURL, 'AccountReference' => $AccountReference, 'TransactionDesc' => $TransactionDesc ); $data_string = json_encode($curl_post_data); curl_setopt($curl, CURLOPT_RETURNTRANSFER, true); curl_setopt($curl, CURLOPT_POST, true); curl_setopt($curl, CURLOPT_POSTFIELDS, $data_string); $curl_response = curl_exec($curl); curl_close($curl); // 在数据库中插入$unique_id $sql = "INSERT INTO duka (/* 其他字段 */, UniqueId) VALUES (/* 其他值 */, '$unique_id');"; // } ?>示例代码:修改后的response.php
Body->stkCallback->ResultCode==0) { $Items = $nowNow->Body->stkCallback->CallbackMetadata->Item; foreach($Items as $Item) { if ($Item->Name =='MpesaReceiptNumber') { $MpesaReceiptNumber = $Item->Value; } } }else{ $ResultCode = $nowNow->Body->stkCallback->ResultCode; $MerchantRequestID = $nowNow->Body->stkCallback->MerchantRequestID; $CheckoutRequestID = $nowNow->Body->stkCallback->CheckoutRequestID; $ResultDesc = $nowNow->Body->stkCallback->ResultDesc; $sql = "SELECT * FROM duka;"; $stmt = mysqli_stmt_init($conn); if (!mysqli_stmt_prepare($stmt, $sql)) { echo "SQL statement failed 1!"; }else{ mysqli_stmt_execute($stmt); $result = mysqli_stmt_get_result($stmt); $rowCount = mysqli_num_rows($result); // 使用$unique_id作为查询条件 $sql = "INSERT INTO duka(ResultCode, MerchantReqID, CheckoutReqID, ResultDesc, UniqueId) VALUES (?,?,?,?,?);"; if (!mysqli_stmt_prepare($stmt, $sql)) { echo "SQL statement failed 2!"; }else{ mysqli_stmt_bind_param($stmt,"sssss", $ResultCode, $MerchantRequestID,$CheckoutRequestID,$ResultDesc,$unique_id); mysqli_stmt_execute($stmt); } } } ?>示例代码:修改后的fromdb.php
0) { while ($row = mysqli_fetch_assoc($result)) { $data = $row["CheckoutReqID"]; } } //value to be printed using console.log following an ajax get method echo json_encode($data); ?>注意事项
- Cookie的安全性: Cookie存储在客户端,容易被篡改。因此,不要在Cookie中存储敏感信息。
- Cookie的有效期: 根据实际需求设置Cookie的有效期。
- Cookie的路径: 设置Cookie的路径,确保只有需要的页面可以访问该Cookie。
- 错误处理: 确保在response.php和fromdb.php中处理Cookie不存在的情况。
总结
通过使用Cookie替代Session,可以有效地解决回调URL页面Session ID变更的问题,从而保证请求与回调数据的正确关联。在实际应用中,需要注意Cookie的安全性、有效期和路径,并进行充分的错误处理。这种方法提供了一种简单而有效的解决方案,适用于需要在回调URL中保持ID一致性的场景。










