苹果 server to server

application/api/controller/Demo.php

@@ -3,7 +3,7 @@
 namespace app\api\controller;
 
 use app\common\controller\Api;
-
+use app\common\library\Transaction;
 /**
  * 示例接口
  */
@@ -109,8 +109,10 @@ class Demo extends Api
      * ios 事件通知
      * @return bool
      */
-    public function iosNotify()
+    public function auto_renewal_vip_notify()
     {
+        //$this->notify_log_start('ios');
+
         // 通知事件
         // 订阅类型-入库  首次订阅 重新订阅 续费 套餐升级
         // 自动续费状态   自动订阅状态 1开启 2-关闭
@@ -129,45 +131,40 @@ class Demo extends Api
             if (empty($data)) {
                 //timbao add
                 //记录苹果通知逻辑中的bug
-
-                return true;
+                exit;
             }
 
-
-
             $transaction_info = $this->verifyAppleToken($data['data']['signedTransactionInfo']);
             dump($transaction_info);
             switch ($data['notificationType']) {
                 case 'DID_RENEW': // 续订
-//                    Transaction::autoRenew($transaction_info);
+                    Transaction::autoRenew($transaction_info);
                     break;
                 case 'REFUND': // 退款
-//                    Transaction::refund($transaction_info);
+                    Transaction::refund($transaction_info);
                     break;
                 case 'DID_CHANGE_RENEWAL_STATUS': // 连续续订状态 变更
-//                    Transaction::changeRenewStatus($transaction_info, $data['subtype']);
+                    Transaction::changeRenewStatus($transaction_info, $data['subtype']);
                     break;
                 case 'EXPIRED': // 过期通知
-//                    Transaction::updateExpiredTrans($transaction_info);
+                    Transaction::updateExpiredTrans($transaction_info);
                     break;
                 case 'SUBSCRIBED': // 订阅通知
-//                    Transaction::updateSubscribed($transaction_info, $data['subtype']);
+                    Transaction::updateSubscribed($transaction_info, $data['subtype']);
                     break;
                 case 'DID_FAIL_TO_RENEW': // 续订失败
-//                    Transaction::updateRenewFailTrans($transaction_info);
+                    Transaction::updateRenewFailTrans($transaction_info);
                     break;
                 case 'DID_CHANGE_RENEWAL_PREF': //升级 降级
                     if ($data['subtype'] == 'UPGRADE') {
-//                        Transaction::autoRenew($transaction_info, true);
+                        Transaction::autoRenew($transaction_info, true);
                     }
                     break;
             }
 
             exit;
-        } catch (\Throwable $t) {
-            //timbao add
-            //记录自动续费逻辑中的bug
-
+        }catch (Exception $e) {
+            echo $e->getMessage();
             exit;
         }
     }

application/common/library/Transaction.php

@@ -0,0 +1,335 @@
+<?php
+
+namespace app\common\library;
+
+use think\Db;
+
+/**
+ * 苹果server to server
+ */
+class Transaction
+{
+
+    protected $table = 'transaction';
+    protected $primaryKey = 'id';
+
+    protected $guarded = [];
+
+    protected function serializeDate(DateTimeInterface $date)
+    {
+        return $date->format('Y-m-d H:i:s');
+    }
+
+    /**
+     * 续费or升级
+     *
+     * @param $transaction_info
+     * @param bool $is_upgrade
+     * @return bool
+     */
+    public static function autoRenew($transaction_info, $is_upgrade = false)
+    {
+        $original_transaction_id = isset($transaction_info['originalTransactionId']) ? $transaction_info['originalTransactionId'] : ''; // 订阅原始ID
+        $transaction_id          = isset($transaction_info['transactionId'])         ? $transaction_info['transactionId']         : ''; // 苹果订单号
+        $product_id              = isset($transaction_info['productId'])             ? $transaction_info['productId']             : ''; // 产品id
+
+        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 true;
+        }
+
+        Db::startTrans();
+        //查找订单，可能找到以前的，非当前用户的。根据原始id 和 用户id不是终生绑定
+        $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
+        //原始id换给别人用了
+        $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_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 true;
+        }
+
+        //逻辑开始
+        //先充值
+        $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
+            $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 '充值失败';
+        }
+        //逻辑结束
+
+        //添加新的一个task
+        $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;//回归1
+        }
+
+        $task_id = Db::name('user_vipxufei_task')->insertGetId($task_data);
+        if(!$task_id)
+        {
+            filePut($prefix.'用户添加vipxufei_task失败');
+            Db::rollback();
+            return '充值失败';
+        }
+
+        Db::commit();
+        filePut($prefix.'充值成功');
+        return true;
+
+        //逻辑结束
+
+
+    }
+
+    /**
+     * 退款
+     *
+     * @param $transaction_info
+     * @return bool
+     */
+    public static function refund($transaction_info)
+    {
+        return true;
+        /*$original_transaction_id = $transaction_info['originalTransactionId']; // 订阅ID
+        $web_order_line_item_id  = $transaction_info['webOrderLineItemId']; // 交易ID
+
+        $base_msg = self::_getBaseMsg($original_transaction_id, $web_order_line_item_id) . '- 退款：';
+
+        $transaction_info_data = Transaction::query()
+            ->where('web_order_line_item_id', '=', $transaction_info['webOrderLineItemId'])
+            ->where('original_transaction_id', '=', $transaction_info['originalTransactionId'])
+            ->first();
+        if (!$transaction_info_data) {
+            Log::channel('transaction')->warning($base_msg . ' not find transaction info');
+            return false;
+        }
+
+        // 修改退款时间以及状态
+        Transaction::query()
+            ->where('web_order_line_item_id', '=', $transaction_info['webOrderLineItemId'])
+            ->where('original_transaction_id', '=', $transaction_info['originalTransactionId'])
+            ->update([
+                'cancellation_date_ms' => date('Y-m-d H:i:s', $transaction_info['revocationDate'] / 1000),
+                'is_cancellation'      => 1,
+            ]);
+
+        // 修改用户会员为到期
+        User::saveExpireVip($transaction_info_data->user_id);
+
+        return true;*/
+    }
+
+    /**
+     * 订阅
+     *
+     * @param $transaction_info
+     * @param $subtype
+     * @return bool
+     */
+    public static function updateSubscribed($transaction_info, $subtype)
+    {
+        return true;
+    }
+
+    /**
+     * 续订失败
+     *
+     * @param $transaction_info
+     * @return bool
+     */
+    public static function updateExpiredTrans($transaction_info)
+    {
+        return true;
+    }
+
+    /**
+     * 续订失败
+     *
+     * @param $transaction_info
+     * @return bool
+     */
+    public static function updateRenewFailTrans($transaction_info)
+    {
+        return true;
+    }
+
+    /**
+     * 自动续费状态修改
+     *
+     * @param $transaction_info
+     * @param $subtype
+     * @return bool
+     */
+    public static function changeRenewStatus($transaction_info, $subtype)
+    {
+        return true;
+    }
+
+
+    /**
+     * 检测交易
+     *
+     * @param $transaction_info
+     * @param $base_msg
+     * @return array
+     */
+    private static function _checkTransaction($transaction_info)
+    {
+        $ret = [
+            'check' => false,
+            'data'  => [],
+        ];
+
+        // 2.判断交易ID是否已经入库过
+        $is_exist = Db::name('user_vipxufei_task')
+            ->where('original_transaction_id', $transaction_info['originalTransactionId'])
+            ->where('transaction_id', $transaction_info['transactionId'])
+            ->find();
+        if ($is_exist) {
+            return $ret;
+        }
+
+        //查找订单，可能找到以前的，非当前用户的。根据原始id 和 用户id不是终生绑定
+        $order_map = [
+            'original_transaction_id' => $transaction_info['originalTransactionId'],
+        ];
+        $order_info = Db::name('user_vipxufei_task')->where($order_map)->order('expires_date_ms desc')->find();
+        if (!$order_info) {
+            return $ret;
+        }
+
+        //
+
+        $ret['check'] = true;
+        $ret['data']  = $order_info;
+
+
+        return $ret;
+    }
+
+    /**
+     * 获取日志
+     *
+     * @param $original_transaction_id
+     * @param $web_order_line_item_id
+     * @return string
+     */
+    private static function _getBaseMsg($original_transaction_id, $web_order_line_item_id)
+    {
+        return "notify-{$original_transaction_id}-{$web_order_line_item_id} ";
+    }
+
+    /**
+     * 获取入库信息
+     *
+     * @param $user_id
+     * @param $transaction_info
+     * @return array
+     */
+    private static function _getAddData($user_id, $transaction_info)
+    {
+        return [
+            'user_id'                       => $user_id, // fixme 此处不考虑用户ID切换
+            'transaction_id'                => $transaction_info['transactionId'],
+            'product_id'                    => $transaction_info['productId'],
+            'web_order_line_item_id'        => $transaction_info['webOrderLineItemId'],
+            'original_transaction_id'       => $transaction_info['originalTransactionId'],
+            'original_purchase_date_ms'     => date('Y-m-d H:i:s', $transaction_info['originalPurchaseDate'] / 1000), //首次订阅时间
+            'purchase_date_ms'              => date('Y-m-d H:i:s', $transaction_info['purchaseDate'] / 1000), // 购买时间
+            'expires_date_ms'               => date('Y-m-d H:i:s', $transaction_info['expiresDate'] / 1000), // 过期时间
+            'subscription_group_identifier' => $transaction_info['subscriptionGroupIdentifier'] ?? '',
+                'in_app_ownership_type'         => $transaction_info['inAppOwnershipType'],
+                'environment'                   => $transaction_info['environment'] ?? '',
+                'sub_type'                      => 'DID_RENEW', // DID_RENEW UPGRADE  SUBSCRIBED-INITIAL_BUY  SUBSCRIBED-RESUBSCRIBE
+                'auto_renew_result'             => 1, // 自动续费结果 0默认 1成功 2失败 3过期
+                'auto_renew_status'             => 1, // 自动订阅状态 1开启 2-关闭
+            ];
+    }
+}