内购流程:
1. 用户先拿到购买产品的单子,
2. 拿着单子去苹果那里交钱,交完钱让苹果在单子上盖个章
3.拿着盖了章的单子传给自己的服务器来验证是否真的支付成功,服务器是跟苹果验证(我们客户端也是可以跟苹果验证的,只是这样安全性不高)
4.根据服务器返回的信息做具体的处理
先上代码干货
* 设置这个监听对象,会在该界面时时监测支付的状态变化
```
-(void)viewWillAppear:(BOOL)animated{
[super viewWillAppear:animated];
// 添加观察者
[[SKPaymentQueue defaultQueue] addTransactionObserver:self];
}
-(void)viewWillDisappear:(BOOL)animated{
[super viewWillDisappear:animated];
// 移除观察者
[[SKPaymentQueue defaultQueue] removeTransactionObserver:self];
}
```
* 点击某个商品,开始购买流程
#pragma Mark -- 内购功能模块
-(void)buyYuBiWithId:(NSString *)ProductID{
if([SKPaymentQueue canMakePayments]){
// productID就是你在创建购买项目时所填写的产品ID
self.baseTableView.userInteractionEnabled = NO;
selectProductID = [NSString stringWithFormat:@"%@",ProductID];
[self requestProduct]; }else{
_isBuying = NO;
self.baseTableView.userInteractionEnabled = YES;
DebugLog(@"不允许程序内付费");
UIAlertView *alertError = [[UIAlertView alloc] initWithTitle:@"温馨提示"
message:@"请先开启应用内付费购买功能。"
delegate:nil
cancelButtonTitle:@"确定"
otherButtonTitles: nil];
[alertError show];
}
} #pragma mark 1.请求所有的商品ID
-(void)requestProduct{ // 1.拿到所有可卖商品的ID数组 NSSet *sets = [[NSSet alloc]initWithArray:_productIdArray]; // 2.向苹果发送请求,请求所有可买的商品
// 2.1.创建请求对象
SKProductsRequest *sKProductsRequest = [[SKProductsRequest alloc]initWithProductIdentifiers:sets];
// 2.2.设置代理(在代理方法里面获取所有的可卖的商品)
sKProductsRequest.delegate = self;
// 2.3.开始请求
[sKProductsRequest start]; }
#pragma mark 2.苹果那边的内购监听
-(void)productsRequest:(SKProductsRequest *)request didReceiveResponse:(SKProductsResponse *)response{ NSArray *product = response.products;
if([product count] == 0){ NSLog(@"没有商品");
return;
} for (SKProduct *sKProduct in product) { NSLog(@"pro info");
NSLog(@"SKProduct 描述信息:%@", sKProduct.description);
NSLog(@"localizedTitle 产品标题:%@", sKProduct.localizedTitle);
NSLog(@"localizedDescription 产品描述信息:%@",sKProduct.localizedDescription);
NSLog(@"price 价格:%@",sKProduct.price);
NSLog(@"productIdentifier Product id:%@",sKProduct.productIdentifier); if([sKProduct.productIdentifier isEqualToString:selectProductID]){ [self buyProduct:sKProduct]; break; }else{ //NSLog(@"没有这个商品");
}
} } #pragma mark 内购的代码调用
-(void)buyProduct:(SKProduct *)product{ // 1.创建票据
SKPayment *skpayment = [SKPayment paymentWithProduct:product]; // 2.将票据加入到交易队列
[[SKPaymentQueue defaultQueue] addPayment:skpayment]; }
* 下面这个方法就功能很多了
* 如果内购流程中的苹果支付完成,但是由于某些原因,没有结束该交易,苹果是会在页面出现的时候,回调这个交易的票据数据的,所以要有一个变量,标志SKPaymentTransactionStatePurchased是充值的时候,还是页面启动的时候回调的_isBuying
#pragma mark 4.实现观察者监听付钱的代理方法,只要交易发生变化就会走下面的方法
-(void)paymentQueue:(SKPaymentQueue *)queue updatedTransactions:(NSArray *)transactions{ /*
SKPaymentTransactionStatePurchasing, 正在购买
SKPaymentTransactionStatePurchased, 已经购买
SKPaymentTransactionStateFailed, 购买失败
SKPaymentTransactionStateRestored, 回复购买中
SKPaymentTransactionStateDeferred 交易还在队列里面,但最终状态还没有决定
*/ for (SKPaymentTransaction *transaction in transactions) {
switch (transaction.transactionState) {
case SKPaymentTransactionStatePurchasing:{
NSLog(@"正在购买");
//存储购买的人ID
[[NSUserDefaults standardUserDefaults] setObject:[UserModel uid] forKey:@"applePayMan"];
[[NSUserDefaults standardUserDefaults] synchronize];
}break;
case SKPaymentTransactionStatePurchased:{
//[[SKPaymentQueue defaultQueue] finishTransaction:transaction];
if (_isBuying) {//主动发起的回调
//存储支付成功的单子
[[StroeObserver shareStoreObserver] saveApplePayHisTransactionId:transaction.transactionIdentifier andState:@"0" isUpdate:NO];
[self buyAppleStoreProductSucceedWithPaymentTransactionp:transaction]; }else{//这是启动的回调 if (_dbArr.count>0) {//数据库有数据,判断是否有记录
//[SDIndicator showInfoWithMessage:@"数据库有数据"];
for (NSDictionary *dic in _dbArr) {
if ([[dic objectForKey:@"transactionIdentifier"] isEqualToString:transaction.transactionIdentifier]) {//这是数据库中的单子
if ([[dic objectForKey:@"state"] isEqualToString:@"2"]) {//单子流程已经结束
[[SKPaymentQueue defaultQueue] finishTransaction:transaction];
//删除数据库中流程结束的单子
[[StroeObserver shareStoreObserver] deleteSuc:transaction.transactionIdentifier];
break;
}else{//状态是0,1的都是支付成功了
//[SDIndicator showInfoWithMessage:@"数据库数据充值去"];
//购买后告诉交易队列,把这个成功的交易移除掉-- [queue finishTransaction:transaction]
[self buyAppleStoreProductSucceedWithPaymentTransactionp:transaction];
break;
}
}
}
} if ([[[NSUserDefaults standardUserDefaults] objectForKey:@"applePayMan"] isEqualToString:[UserModel uid]]) {
//[SDIndicator showInfoWithMessage:@"数据库无数据充值去"];
[self buyAppleStoreProductSucceedWithPaymentTransactionp:transaction];
}else{
//[SDIndicator showInfoWithMessage:@"结束交易"];
[[SKPaymentQueue defaultQueue] finishTransaction:transaction];
} } }break;
case SKPaymentTransactionStateFailed:{
[self hideHud];
NSLog(@"购买失败");
_isBuying = NO;
self.baseTableView.userInteractionEnabled = YES;
// 购买失败也要把这个交易移除掉
[queue finishTransaction:transaction];
}break;
case SKPaymentTransactionStateRestored:{
[self hideHud];
_isBuying = NO;
self.baseTableView.userInteractionEnabled = YES;
NSLog(@"恢复购买中,也叫做已经购买");
// 恢复购买中也要把这个交易移除掉
[queue finishTransaction:transaction];
}break;
case SKPaymentTransactionStateDeferred:{ NSLog(@"交易还在队列里面,但最终状态还没有决定");
}break;
default:
break;
}
}
}
我们可以看到,使用数据库了原因是
* 在苹果返回票据,支付成功的时候,之后的流程,我们走的是自己的服务器去验证,这样的话,中间流程一旦中断,这个交易就可能没有结束,然后呢,苹果的监听,就会给回调回来之前支付成功但是并未结束交易的票据数组。
* 但是并不能直接调用充值接口,因为我支付成功,立马杀掉进程,重新启动,换个账号,进入充值界面的话,就会充值给另一个用户,所以需要判断这个交易的用户属性,采用了数据库保存,发起的订单,当然成功的单子就删除了【当然也有个问题,及时极限操作,苹果的支付票据还没回来,我就杀掉app,自然也就不能本地保存了,虽然没人这么做,所以存了一下,发起交易的人的uid,方便处理漏掉的单子的时候,不要给另外的人存了钱,自然最后剩余的情况就让找客服吧,无解了】
下面是要拿苹果返回的交易票据,转成base64去验证(客户端,服务器验证两种)
// 苹果内购支付成功
- (void)buyAppleStoreProductSucceedWithPaymentTransactionp:(SKPaymentTransaction *)paymentTransactionp { NSString * productIdentifier = paymentTransactionp.payment.productIdentifier;
DebugLog(@"productIdentifier Product id:%@", productIdentifier);
NSString *transactionReceiptString= nil; //系统IOS7.0以上获取支付验证凭证的方式应该改变,切验证返回的数据结构也不一样了。
NSString *version = [UIDevice currentDevice].systemVersion;
if([version intValue] >= 7.0){
// 验证凭据,获取到苹果返回的交易凭据
// appStoreReceiptURL iOS7.0增加的,购买交易完成后,会将凭据存放在该地址
NSURLRequest * appstoreRequest = [NSURLRequest requestWithURL:[[NSBundle mainBundle]appStoreReceiptURL]];
NSError *error = nil;
NSData * receiptData = [NSURLConnection sendSynchronousRequest:appstoreRequest returningResponse:nil error:&error];
transactionReceiptString = [receiptData base64EncodedStringWithOptions:NSDataBase64EncodingEndLineWithLineFeed];
}else{ NSData * receiptData = paymentTransactionp.transactionReceipt;
// transactionReceiptString = [receiptData base64EncodedString];
transactionReceiptString = [receiptData base64EncodedStringWithOptions:NSDataBase64EncodingEndLineWithLineFeed];
}
// 去验证是否真正的支付成功了
[self checkAppStorePayResultWithBase64String:transactionReceiptString WithPaymentTransactionp:paymentTransactionp]; }
下面方法,接口调用成功的话,因为状态值是0的话,原因是已经充值成功,或者票据不对,这两种情况也必须直接结束交易,所以只要接口调用成功,一样结束交易
接口调用失败的话,再次调用,直到成功
- (void)checkAppStorePayResultWithBase64String:(NSString *)base64String WithPaymentTransactionp:(SKPaymentTransaction *)paymentTransactionp{ NSMutableDictionary *prgam = [[NSMutableDictionary alloc] init];
[prgam setValue:base64String forKey:@"receipt-data"]; __weak typeof(self)WS = self;
[Api requestWithMethod:nil withPath:API_URL_Apple_pay withParams:prgam withSuccess:^(id responseObject) {
[WS hideHud];
_isBuying = NO;
WS.baseTableView.userInteractionEnabled = YES; //返回1成功充值,返回0,该单已经充值过了,没结束交易 或者票据错误---都结束交易 //更新充值成功的单子
[[StroeObserver shareStoreObserver] saveApplePayHisTransactionId:paymentTransactionp.transactionIdentifier andState:@"2" isUpdate:YES];
//结束苹果pay的交易队列,不然会出现--(您已购买此 App 内购买项目。此项目将免费恢复)提示
[[SKPaymentQueue defaultQueue] finishTransaction:paymentTransactionp];
//删除数据库中流程结束的单子
[[StroeObserver shareStoreObserver] deleteSuc:paymentTransactionp.transactionIdentifier]; if ([responseObject[@"status"] integerValue] == 1) { if(_giftRequestBlock){
WS.giftRequestBlock(@"1");
}
[SDIndicator showSuccessWithMessage:@"充值成功"];
[WS getData];
}
} withError:^(NSError *error) {
_isBuying = YES;
WS.baseTableView.userInteractionEnabled = NO;
[WS checkAppStorePayResultWithBase64String:base64String WithPaymentTransactionp:paymentTransactionp];
}];
下面在说说,数据库存储的逻辑
#import <UIKit/UIKit.h>
#import "StroeObserver.h" @implementation StroeObserver + (StroeObserver *)shareStoreObserver
{
static StroeObserver *_storeOb = nil;
static dispatch_once_t onceToken;
dispatch_once(&onceToken, ^{
_storeOb = [[StroeObserver alloc] init];
}); return _storeOb;
} -(void)saveApplePayHisTransactionId:(NSString *)transactionId andState:(NSString *)state isUpdate:(BOOL)isUpdate
{
dispatch_sync(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
/*将数据存入数据库*/
/*打开数据库*/
DB_INIT(db);
NSString *str = DB_PATH;
DebugLog("%@",str); DB_OPEN;
/*创建数据库*/
NSString *tableName = [NSString stringWithFormat:@"ApplePayHis_%@",SWUID];
//字段有:transactionIdentifier、productIdentifier、uid、transactionDate(支付时间)、rechargeDate(充值到账时间)、state([未支付]「已支付」和「已充值」)
NSString *tableSql = [NSString stringWithFormat:@"create table if not exists %@(transactionIdentifier,state,uid)",tableName];
DB_CREATE(tableSql) BOOL INSERT; if (isUpdate) {
INSERT = [db executeUpdate:[NSString stringWithFormat:@"update %@ set state = ? where transactionIdentifier = ?",tableName],state,transactionId];
}else{
INSERT = [db executeUpdate:[NSString stringWithFormat:@"insert into %@ values(?,?,?)",tableName],transactionId,state,[UserModel uid]];
} DB_INSERT;
DB_CLOSE;
});
} //删除成功的交易
-(void)deleteSuc:(NSString*)transactionIdentifier{
dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
DB_INIT(db);
DB_OPEN;
NSString *tableName = [NSString stringWithFormat:@"ApplePayHis_%@",SWUID];
BOOL ret = [db executeUpdate:[NSString stringWithFormat:@"delete from %@ where transactionIdentifier='%@'", tableName,transactionIdentifier]];
if (!ret) {
DebugLog(@"删除失败");
}else{
DebugLog(@"删除成功");
}
DB_CLOSE;
});
} //获取数据库中的支付成功,充值不成功订单
- (void)initApplePayHisDataFromDB
{
_dataArray = [[NSMutableArray alloc]init]; dispatch_queue_t queue = dispatch_queue_create("initApplePayHisDataFromDB", DISPATCH_QUEUE_SERIAL);
dispatch_sync(queue, ^{
/*读取数据库旧数据*/
DB_INIT(db);
DB_OPEN;
NSString *tableName = [NSString stringWithFormat:@"ApplePayHis_%@",SWUID];
FMResultSet *rs = [db executeQuery:[NSString stringWithFormat:@"select * from %@ where uid=?",tableName],SWUID];
while ([rs next]) { NSDictionary *dic = [NSDictionary dictionaryWithObjectsAndKeys:
[rs stringForColumn:@"state"],@"state",
[rs stringForColumn:@"uid"],@"uid",
[rs stringForColumn:@"transactionIdentifier"],@"transactionIdentifier",nil]; [_dataArray addObject:dic];
}
DB_CLOSE;
});
} @end
就看效果了。。。
BYZqk
[https://www.jianshu.com/u/c6866a2b7547]
2018-04-2516:10:44