123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250 |
- <?php
- namespace app\common\library;
- use think\Db;
- class Transaction
- {
-
- public static function autoRenew($transaction_info, $is_upgrade = false)
- {
- $original_transaction_id = isset($transaction_info['originalTransactionId']) ? $transaction_info['originalTransactionId'] : '';
- $transaction_id = isset($transaction_info['transactionId']) ? $transaction_info['transactionId'] : '';
- $product_id = isset($transaction_info['productId']) ? $transaction_info['productId'] : '';
- if (!$original_transaction_id || !$transaction_id || !$product_id) {
- return '参数有误';
- }
- filePut("\r\n\r\n".'新的S2S');
- $prefix = '[S2S]originalTransactionId:'.$original_transaction_id.',transactionId:'.$transaction_id.',productId:'.$product_id.'。';
-
- $check_map = [
- 'original_transaction_id' => $original_transaction_id,
- 'transaction_id' => $transaction_id,
- ];
- $check_order = Db::name('user_vipxufei_task')->where($check_map)->field('id')->find();
- if($check_order){
- filePut($prefix.'续费早已完成');
- return '续费早已完成';
- }
- Db::startTrans();
-
- $order_map = [
- 'original_transaction_id' => $original_transaction_id,
- ];
- $order_info = Db::name('user_vipxufei_task')->where($order_map)->order('expires_date_ms desc')->find();
- if (!$order_info) {
- Db::rollback();
- filePut($prefix.'不存在的订单');
- return '不存在的订单';
- }
-
-
- $order_info_bundle_id = $order_info['bundle_id'];
- $order_info_user_id = $order_info['user_id'];
- if($product_id != $order_info['bundle_id']){
- $pay_order_map = [
- 'user_id' => $order_info['user_id'],
- 'bundle_id' => $product_id,
- 'order_status' => 0,
- 'table_name' => 'vip_recharge',
- ];
- $pay_order = Db::name('pay_order')->where($pay_order_map)->order('id desc')->lock(true)->find();
- if(!$pay_order){
- Db::rollback();
- filePut($prefix.'未找到匹配的交易,新订单找不到');
- return '未找到匹配的交易,新订单找不到';
- }
-
- $update_order = [
- 'notifytime'=>time(),
- 'order_status'=>1,
- 'original_transaction_id' => $original_transaction_id,
- 'transaction_info' => json_encode($transaction_info),
- ];
- $ros = Db::name('pay_order')->where(['id' => $pay_order['id']])->update($update_order);
- if($ros === false) {
- filePut($prefix.'修改订单状态失败');
- Db::rollback();
- return '修改订单状态失败';
- }
- $args = json_decode($pay_order['args'],true);
-
- $order_info['order_id'] = $pay_order['id'];
- $order_info['user_id'] = $pay_order['user_id'];
- $order_info['bundle_id'] = $pay_order['bundle_id'];
- $order_info['days'] = $args['days'];
- $order_info['original_transaction_id'] = $original_transaction_id;
- }
-
- if($transaction_info['purchaseDate'] <= $order_info['purchase_date_ms'] || $transaction_info['expiresDate'] <= $order_info['expires_date_ms']){
- Db::rollback();
- filePut($prefix.'时间对不上,返回成功,finish掉');
- return '时间对不上,返回成功,finish掉';
- }
-
-
- $user_info = Db::name('user_wallet')->where('user_id',$order_info['user_id'])->lock(true)->find();
- if($user_info['vip_endtime'] < time()){
-
- $vip_endtime = time() + (intval($order_info['days']) * 86400);
- }else{
-
- $vip_endtime = $user_info['vip_endtime'] + (intval($order_info['days']) * 86400);
- }
- $update_data = [
- 'vip_endtime'=>$vip_endtime,
- ];
- $result = Db::name('user_wallet')->where('user_id',$order_info['user_id'])->update($update_data);
- if($result === false)
- {
- filePut($prefix.'逻辑续费vip时间失败');
- Db::rollback();
- return '逻辑续费vip时间失败';
- }
-
-
- $task_data = $order_info;
- unset($task_data['id']);
- $task_data['createtime'] = time();
- $task_data['apple_receipt'] = '';
- $task_data['in_app_one'] = '';
- $task_data['transaction_id'] = $transaction_id;
- $task_data['times'] = $order_info['times'] + 1;
- $task_data['original_purchase_date_ms'] = $transaction_info['originalPurchaseDate'];
- $task_data['purchase_date_ms'] = $transaction_info['purchaseDate'];
- $task_data['expires_date_ms'] = $transaction_info['expiresDate'];
- $task_data['transaction_info'] = json_encode($transaction_info);
- if($product_id != $order_info_bundle_id){
- $task_data['times'] = 1;
- }
- $task_id = Db::name('user_vipxufei_task')->insertGetId($task_data);
- if(!$task_id)
- {
- filePut($prefix.'用户添加vipxufei_task失败');
- Db::rollback();
- return '用户添加vipxufei_task失败';
- }
- Db::commit();
- filePut($prefix.'充值成功'.$task_id);
- return '充值成功'.$task_id;
-
- }
-
- public static function refund($transaction_info)
- {
- return true;
-
- }
-
- public static function updateSubscribed($transaction_info, $subtype)
- {
- return true;
- }
-
- public static function updateExpiredTrans($transaction_info)
- {
- return true;
- }
-
- public static function updateRenewFailTrans($transaction_info)
- {
- return true;
- }
-
- public static function changeRenewStatus($transaction_info, $subtype)
- {
- return true;
- }
- }
|