zm/tougao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
wangjinlei
2025-02-25 16:02:09 +08:00
parent 3620475d2d
commit 3d64e93839
2 changed files with 145 additions and 63 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
application/api/controller/Base.php
View File

@@ -86,6 +86,7 @@ class Base extends Controller
protected $article_main_check_obj = "";
protected $major_to_user_obj = "";
protected $major_to_article_obj = "";
protected $paystation_obj = "";
public function __construct(\think\Request $request = null)
@@ -167,6 +168,7 @@ class Base extends Controller
$this->article_main_check_obj = Db::name("article_main_check");
$this->major_to_user_obj = Db::name("major_to_user");
$this->major_to_article_obj = Db::name("major_to_article");
$this->paystation_obj = Db::name("paystation");
}

206
application/api/controller/Order.php
View File

@@ -19,6 +19,7 @@ use think\db\exception\DataNotFoundException;
use think\Env;
use think\db\exception\ModelNotFoundException;
use think\Exception;
use think\Request;
use think\exception\DbException;
use think\exception\PDOException;
use think\Queue;
@@ -31,10 +32,118 @@ class Order extends base{
public function __construct(\think\Request $request = null)
{
parent::__construct($request);
}
public function paystationTest(){
$sn = 'TMR'.date('Ymd') . strtoupper(bin2hex(random_bytes(8)));
$accessToken = createPayStationToken();
$data_array = [
'paystation_id' => Env::get("paystation.client_id"),
'gateway_id' => "PAYSTATION",//GATEWAY_ID,
"merchant_session" => $sn,
"merchant_reference"=>$sn,
"amount" =>100,
"return_url"=>"https://www.tmrjournals.com/",
"response_url"=>"http://api.tmrjournals.com/public/index.php/api/Order/completePaystation"
];
$data = json_encode($data_array);
$purchase = postPayStationQuery('v1/hosted/purchases', $accessToken, $data);
$paystation_res = object_to_array(json_decode($purchase));
return jsonSuccess($paystation_res);
}
public function completePaystation(Request $request){
// 获取请求的原始数据（Paystation 发送的 payload）
$payload = $request->getContent();
$filePath = ROOT_PATH . '/payload_log.txt';
// 将payload写入文本文件
file_put_contents($filePath, $payload . PHP_EOL, FILE_APPEND);
// 获取请求头
// $headers = $request->header();
//
// // 获取HMAC签名和时间戳
// $hmac_signature = $headers['x-signature'] ?? '';
// $timestamp = $headers['x-timestamp'] ?? '';
//
// // 使用HMAC密钥验证签名
// $get_hmac = hash_hmac('sha512', $timestamp . $payload, config('paystation.HMAC_KEY'));
//
// if ($hmac_signature != $get_hmac) {
// Log::error('HMAC验证失败', ['timestamp' => $timestamp, 'hmac_signature' => $hmac_signature, 'calculated_hmac' => $get_hmac]);
// return 'HMAC verification failed';
// }
// 解析JSON格式的payload
$data = json_decode($payload);
// 检查result字段是否为空
if (empty($data->result)) {
return jsonError("Paystation responds with no results");
} else {
// 交易成功或失败的处理
if ($data->result->success) {
return jsonSuccess([]);
} else {
return jsonError('Transaction failed');
}
}
// $sn = $request->param("sn");
// $order_info = $this->order_obj->where("order_sn",$sn)->find();
//
// $this->article_obj->where("article_id",$order_info['article_id'])->update(['is_buy'=>1]);
// $this->order_obj->where("order_sn",$order_info['order_sn'])->update(['state'=>1]);
//
// return jsonSuccess([]);
}
public function testPaystationLookup(){
$accessToken = createPayStationToken();
$curl = curl_init();
curl_setopt_array($curl, array(
CURLOPT_URL => 'https://api.paystation.co.nz/v1/transactions?paystation_id=616562&gateway_id=PAYSTATION&merchant_session=TMR20250225E4F6EA2F38793055&transaction_id=217661437',
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => '',
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 0,
CURLOPT_FOLLOWLOCATION => true,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => 'GET',
CURLOPT_HTTPHEADER => array(
'Authorization: Bearer '.$accessToken
)
));
$response = curl_exec($curl);
curl_close($curl);
return jsonSuccess(object_to_array(json_decode($response)));
}
/**
* @throws DataNotFoundException
* @throws ModelNotFoundException
@@ -79,24 +188,9 @@ class Order extends base{
$re['paystation'] = null;
return jsonSuccess($re);
}else{
$cache_sn = 'TMR'.date('Ymd') . strtoupper(bin2hex(random_bytes(8)));
$accessToken = createPayStationToken();
$data_array = [
'paystation_id' => Env::get("paystation.client_id"),
'gateway_id' => "PAYSTATION",//GATEWAY_ID,
"order_name" => $cache_sn,
"amount" =>100,
"test_mode"=>true
];
$data = json_encode($data_array);
$purchase = postPayStationQuery('v1/payme/purchases', $accessToken, $data);
$paystation_res = object_to_array(json_decode($purchase));
$check['pay_type'] = 2;
$check['paystation_url'] = $paystation_res['payme_url'];
$this->order_obj->update($check);
$re['detail'] = $check;
$re['paypal'] = null;
$re['paystation'] = $paystation_res;
$re['paystation'] = $check['ps_id']==0?null:$this->paystation_obj->where("ps_id",$check['ps_id'])->find();
return jsonSuccess($re);
}
}
@@ -104,12 +198,13 @@ class Order extends base{
if($payType==0){//支付方式为paypal
$insert['order_sn'] = 'TMR'.date('Ymd') . strtoupper(bin2hex(random_bytes(8)));
$insert['user_id'] = $article_info['user_id'];
$insert['type'] = 0;
$insert['pay_type'] = 0;
$insert["article_id"] = $data['article_id'];
$insert['currency'] = "USD";
$insert['order_fee'] = $journal_info['fee'];
$insert['real_fee'] = $journal_info['fee'];
$frag["paypal"] = $this->createPaypalOrder($insert['real_fee']);
if(!isset($paypal['jsonResponse']['status'])||$paypal['jsonResponse']['status']!="CREATED"){
if(!isset($paypal['jsonResponse']['status'])){
return jsonError("system error");
}else{
$insert['paypal_order_id'] = $paypal['jsonResponse']['id'];
@@ -119,26 +214,43 @@ class Order extends base{
$frag['paystation'] = null;
}elseif ($payType==2){//支付方式为paystation
$ca_sn = 'TMR'.date('Ymd') . strtoupper(bin2hex(random_bytes(8)));
$insert['order_sn'] = $ca_sn;
$insert['user_id'] = $article_info['user_id'];
$insert['type'] = 2;
$insert["article_id"] = $data['article_id'];
$insert['order_fee'] = $journal_info['fee'];
$insert['real_fee'] = $journal_info['fee'];
$insert1['order_sn'] = $ca_sn;
$insert1['user_id'] = $article_info['user_id'];
$insert1['pay_type'] = 2;
$insert1["article_id"] = $data['article_id'];
$insert1["currency"] = "USD";
$insert1['order_fee'] = $journal_info['fee'];
$insert1['real_fee'] = $journal_info['fee'];
$accessToken = createPayStationToken();
$data_array = [
'paystation_id' => Env::get("paystation.client_id"),
'gateway_id' => "PAYSTATION",//GATEWAY_ID,
"order_name" => $ca_sn,
"amount" =>100,
"test_mode"=>true
"merchant_session" => $ca_sn,
"merchant_reference"=>$ca_sn,
"amount" =>(int)((((int)$journal_info['fee'])*726/416)*100),
// "currency"=>"USD",//目前paystation仅支持nzd
"return_url"=>"https://www.tmrjournals.com/",
"response_url"=>"http://api.tmrjournals.com/public/index.php/api/Order/completePaystation"
];
$data = json_encode($data_array);
$purchase = postPayStationQuery('v1/payme/purchases', $accessToken, $data);
$purchase = postPayStationQuery('v1/hosted/purchases', $accessToken, $data);
$paystation_res = object_to_array(json_decode($purchase));
$insert['paystation_url'] = $paystation_res['payme_url'];
$insert['ctime'] = time();
$id = $this->order_obj->insertGetId($insert);
// return jsonSuccess($paystation_res);
$ps_insert['transaction_id'] = $paystation_res['transaction_id'];
$ps_insert['session_id'] = $paystation_res['session_id'];
$ps_insert['paystation_id'] = $paystation_res['paystation_id'];
$ps_insert['currency'] = $paystation_res['currency'];
$ps_insert['amount'] = $paystation_res['amount'];
$ps_insert['merchant_session'] = $paystation_res['merchant_session'];
$ps_insert['request_time'] = $paystation_res['request_time'];
$ps_insert['payment_url'] = $paystation_res['payment_url'];
$ps_insert['data'] = json_encode($paystation_res);
$ps_id = $this->paystation_obj->insertGetId($ps_insert);
$insert1['ps_id'] = $ps_id;
$insert1['paystation_url'] = $paystation_res['payment_url'];
$insert1['ctime'] = time();
$id = $this->order_obj->insertGetId($insert1);
$frag['paystation'] = $paystation_res;
$frag["paypal"] = null;
}else{//暂时不处理，其他情况
@@ -196,13 +308,6 @@ class Order extends base{
return jsonSuccess($re);
}
public function mytt(){
$re = $this->createPaypalOrder(600);
return jsonSuccess($re);
}
private function createPaypalOrder($fee)
{
$client = $this->createClient();
@@ -228,31 +333,6 @@ class Order extends base{
}
public function testCreat(){
$client = PaypalServerSdkClientBuilder::init()
->clientCredentialsAuthCredentials(
ClientCredentialsAuthCredentialsBuilder::init(
"AeTurTFJvsivep-zB7vigyuBHX_cyzLqY5K0GCHLaOrs0eHaXA5V-fwJoVEFjlvN1jK_IqYoEbKEBKiH",
"EA-F_RYl1oJBTjHYn87L7vnNv-mWp5yRyTjmkVCOD_bu5T9nfm0E6rfNRKALj1n6AH70QKqB-mmO6tsE"
)
)
->environment(Environment::SANDBOX)
->build();
$orderBody = [
"body"=> OrderRequestBuilder::init("CAPTURE",[
]
)->build()
];
}
public function completeOrder(){
$data = $this->request->post();
$rule = new Validate([