Payios.php 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787
  1. <?php
  2. namespace app\api\controller;
  3. use app\common\controller\Api;
  4. use think\Db;
  5. use addons\epay\library\Service;
  6. /**
  7. * 充值配置与充值订单
  8. */
  9. class Payios extends Api
  10. {
  11. protected $noNeedLogin = ['auto_renewal_vip_notify'];
  12. protected $noNeedRight = ['*'];
  13. //vip ios用的
  14. public function vip_config_ios(){
  15. $list = Db::name('payvip_config_ios')->field('id,money,days,title,info,bundle_id,is_lianxu')->where('is_show',1)->order('weight asc,id asc')->select();
  16. $data['vipconfig'] = $list;
  17. $data['vip_endtime'] = model('wallet')->getWallet($this->auth->id,'vip_endtime');
  18. $data['is_vip'] = $data['vip_endtime'] > time() ? 1 : 0;
  19. $data['avatar'] = localpath_to_netpath($this->auth->avatar);
  20. $this->success('success',$data);
  21. }
  22. //vip用的,创建订单
  23. public function vip_recharge_ios(){
  24. $rc_id = input('rc_id',0);
  25. $platform = 'app';
  26. $uid = $this->auth->id;
  27. if(!$rc_id){
  28. $this->error('请选择会员套餐');
  29. }
  30. if(!$this->user_auth_limit()){
  31. $this->error('请先完成实名认证');
  32. }
  33. //赋值money
  34. $recharge_config = Db::name('payvip_config_ios')->where('id',$rc_id)->find();
  35. $money = $recharge_config['money'];
  36. if($money<=0)
  37. {
  38. $this->error('支付金额必须大于0');
  39. }
  40. if($money > 10000){
  41. $this->error('支付金额太大');
  42. }
  43. //创建订单
  44. $data = [];
  45. $data['user_id'] = $uid;
  46. $data['out_trade_no'] = createUniqueNo('V',$uid); // 数据库订单号加密
  47. $data['order_amount'] = $money;
  48. $data['createtime'] = time();
  49. $data['pay_type'] = 'ios';
  50. $data['platform'] = $platform;
  51. $data['order_status'] = 0;
  52. $data['table_name'] = 'vip_recharge';
  53. $data['table_id'] = 0;
  54. $data['args'] = json_encode(['days'=>$recharge_config['days']]);
  55. $data['bundle_id'] = $recharge_config['bundle_id'];
  56. $data['is_lianxu'] = $recharge_config['is_lianxu'];
  57. $orderid = Db::name('pay_order')->insertGetId($data);
  58. $this->success('success',$data['out_trade_no']);
  59. }
  60. //vip,苹果内购支付回调
  61. //因前端不传入订单号,作废,且与gold_notify_iosnew 已完成合并
  62. public function vip_notify_ios(){
  63. //苹果内购的验证收据
  64. $receipt_data = input('apple_receipt', '', 'trim');
  65. $order_no = input('order_no', '', 'trim');
  66. filePut('VIP ios充值:参数apple_receipt='.$receipt_data.',order_no='.$order_no);
  67. if (!$receipt_data || !$order_no) {
  68. $this->error('缺少参数');
  69. }
  70. Db::startTrans();
  71. // 查找订单
  72. $order_info = Db::name('pay_order')->where(['out_trade_no' => $order_no])->lock(true)->find();
  73. if (!$order_info) {
  74. Db::rollback();
  75. filePut('VIP ios充值:订单丢失out_trade_no='.$order_no);
  76. $this->error('订单丢失');
  77. }
  78. if ($order_info['order_status'] == 1) {
  79. Db::rollback();
  80. $this->success('充值成功');
  81. }
  82. // 验证支付状态
  83. $result = $this->validate_apple_pay($receipt_data);
  84. if (!$result['status']) {// 验证不通过
  85. Db::rollback();
  86. filePut('VIP ios充值:验证out_trade_no='.$order_no.','.$result['message']);
  87. $this->error($result['message']);
  88. }
  89. $count = count($result['data']['receipt']['in_app']);
  90. $use_count = $count - 1;
  91. $args = json_decode($order_info['args'],true);
  92. if ($result['data']['receipt']['in_app'][$use_count]['product_id'] != $order_info['bundle_id']) {
  93. Db::rollback();
  94. filePut('VIP ios充值:非法请求,请立刻停止out_trade_no='.$order_no.','.$result['message'].','.$result['data']['receipt']['in_app'][$use_count]['product_id'].'!='.$order_info['bundle_id']);
  95. $this->error('非法请求,请立刻停止');
  96. }
  97. //逻辑开始
  98. //先充值
  99. $user_info = Db::name('user_wallet')->where('user_id',$order_info['user_id'])->lock(true)->find();
  100. if($user_info['vip_endtime'] < time()){
  101. //过期了
  102. $vip_endtime = time() + (intval($args['days']) * 86400);
  103. }else{
  104. //追加vip
  105. $vip_endtime = $user_info['vip_endtime'] + (intval($args['days']) * 86400);
  106. }
  107. $update_data = [
  108. 'vip_endtime'=>$vip_endtime,
  109. ];
  110. $result = Db::name('user_wallet')->where('user_id',$order_info['user_id'])->update($update_data);
  111. if($result === false)
  112. {
  113. Db::rollback();
  114. filePut('VIP ios充值:验证out_trade_no='.$order_no.',逻辑续费vip时间失败');
  115. $this->error('充值失败');
  116. }
  117. // 修改订单状态
  118. $ros = Db::name('pay_order')->where(['out_trade_no' => $order_no])->update(['order_status'=>1,'notifytime'=>time()]);
  119. if($ros === false) {
  120. filePut('VIP ios充值:充值失败out_trade_no='.$order_no.','.$result['message'].','.'修改订单状态失败');
  121. Db::rollback();
  122. $this->error('充值失败');
  123. }
  124. Db::commit();
  125. $this->success('充值成功');
  126. //逻辑结束
  127. }
  128. ////////////////////////////////
  129. //金币充值
  130. public function gold_config_ios(){
  131. $list = Db::name('paygold_webcon_ios')->field('id,money,gold,bundle_id')->where('is_show',1)->order('weigh asc,id asc')->select();
  132. $data['goldconfig'] = $list;
  133. $wallet = model('wallet')->getWallet($this->auth->id);
  134. $data['wallet'] = $wallet;
  135. $data['money_to_gold'] = config('site.money_to_gold');
  136. $this->success('success',$data);
  137. }
  138. //充值金币 创建订单
  139. public function gold_recharge_ios(){
  140. $rc_id = input_post('rc_id',0);
  141. $pay_type = 'ios';
  142. $platform = 'app';
  143. $uid = $this->auth->id;
  144. if(!$rc_id){
  145. $this->error('请选择充值金额');
  146. }
  147. if(!$this->user_auth_limit()){
  148. $this->error('请先完成实名认证');
  149. }
  150. //赋值money
  151. $recharge_config = Db::name('paygold_webcon_ios')->where('id',$rc_id)->find();
  152. $money = $recharge_config['money'] ?: 0;
  153. $gold = $recharge_config['gold'] ?: 0;
  154. //
  155. if($money<=0)
  156. {
  157. $this->error('支付金额必须大于0');
  158. }
  159. if($money > 10000){
  160. $this->error('支付金额太大');
  161. }
  162. //创建订单
  163. $data['user_id'] = $uid;
  164. $data['out_trade_no'] = createUniqueNo('P',$uid); // 数据库订单号加密
  165. $data['order_amount'] = $money;
  166. $data['createtime'] = time();
  167. $data['pay_type'] = $pay_type;
  168. $data['platform'] = $platform;
  169. $data['order_status'] = 0;
  170. $data['table_name'] = 'gold_recharge';
  171. $data['table_id'] = 0;
  172. $data['args'] = json_encode(['gold'=>$gold]);
  173. $data['bundle_id'] = $recharge_config['bundle_id'];
  174. $orderid = Db::name('pay_order')->insertGetId($data);
  175. $this->success('success',$data['out_trade_no']);
  176. }
  177. //订阅信息处理
  178. public function expires(){
  179. //苹果订阅的验证收据
  180. $original_transaction_id = input('original_transaction_id','','trim');
  181. $receipt_data = input('apple_receipt', '', 'trim');
  182. $transaction_id = input('transaction_id', '', 'trim');
  183. if (!$receipt_data || !$original_transaction_id || !$transaction_id) {
  184. $this->error('缺少参数');
  185. }
  186. filePut("\r\n\r\n".'新请求VIP订阅');
  187. $prefix = 'iosVIP订阅'.',传入original_transaction_id:'.$original_transaction_id.',传入transaction_id:'.$transaction_id.'。';
  188. filePut($prefix.'参数apple_receipt:'.$receipt_data);
  189. //检查重复订单
  190. $check_map = [
  191. 'original_transaction_id' => $original_transaction_id,
  192. 'transaction_id' => $transaction_id,
  193. ];
  194. $check_order = Db::name('user_vipxufei_task')->where($check_map)->field('id')->find();
  195. if($check_order){
  196. filePut($prefix.'续费早已完成');
  197. $this->success('充值已完成');
  198. }
  199. Db::startTrans();
  200. //查找订单
  201. $order_map = [
  202. 'original_transaction_id' => $original_transaction_id,
  203. ];
  204. $order_info = Db::name('user_vipxufei_task')->where($order_map)->order('expires_date_ms desc')->lock(true)->find();
  205. if (!$order_info) {
  206. Db::rollback();
  207. filePut($prefix.'不存在的订单');
  208. $this->error('不存在的订单');
  209. }
  210. // 验证支付状态
  211. $result = $this->validate_apple_pay($receipt_data);
  212. if (!$result['status']) {// 验证不通过
  213. Db::rollback();
  214. filePut($prefix.'验证'.$result['message']);
  215. $this->error($result['message']);
  216. }
  217. $in_app = $result['data']['receipt']['in_app'];
  218. $only_trans = [];
  219. foreach($in_app as $key => $trans){
  220. //非订阅信息,原始信息
  221. if($trans['transaction_id'] == $transaction_id && $original_transaction_id == $trans['original_transaction_id']/* && $trans['product_id'] == $order_info['bundle_id']*/){
  222. $only_trans = $trans;
  223. break;
  224. }
  225. }
  226. if(empty($only_trans)){
  227. Db::rollback();
  228. filePut($prefix.'未找到匹配的交易');
  229. $this->error('未找到匹配的交易');
  230. }
  231. //续订,但是换了产品了,重新定义order_info
  232. $order_info_bundle_id = $order_info['bundle_id'];
  233. if($only_trans['product_id'] != $order_info['bundle_id']){
  234. $pay_order_map = [
  235. 'user_id' => $this->auth->id,
  236. 'bundle_id' => $only_trans['product_id'],
  237. 'order_status' => 0,
  238. 'table_name' => 'vip_recharge',
  239. ];
  240. $pay_order = Db::name('pay_order')->where($pay_order_map)->order('id desc')->lock(true)->find();
  241. if(!$pay_order){
  242. Db::rollback();
  243. filePut($prefix.'未找到匹配的交易,新订单找不到');
  244. $this->error('未找到匹配的新订单');
  245. }
  246. // 修改订单状态
  247. $update_order = [
  248. 'notifytime'=>time(),
  249. 'order_status'=>1,
  250. 'original_transaction_id' => $only_trans['original_transaction_id'],
  251. 'in_app_one' => json_encode($only_trans),
  252. ];
  253. $ros = Db::name('pay_order')->where(['id' => $pay_order['id']])->update($update_order);
  254. if($ros === false) {
  255. filePut($prefix.'修改订单状态失败');
  256. Db::rollback();
  257. $this->error('充值失败');
  258. }
  259. $args = json_decode($pay_order['args'],true);
  260. //修改order_info
  261. $order_info['order_id'] = $pay_order['id'];
  262. $order_info['user_id'] = $pay_order['user_id'];
  263. $order_info['bundle_id'] = $pay_order['bundle_id'];
  264. $order_info['days'] = $args['days'];
  265. $order_info['original_transaction_id'] = $only_trans['original_transaction_id'];//多余
  266. }
  267. //验证时间
  268. if($only_trans['purchase_date_ms'] <= $order_info['purchase_date_ms'] || $only_trans['expires_date_ms'] <= $order_info['expires_date_ms']){
  269. Db::rollback();
  270. filePut($prefix.'时间对不上,返回成功,finish掉');
  271. $this->success(1);
  272. }
  273. //逻辑开始
  274. //先充值
  275. $user_info = Db::name('user_wallet')->where('user_id',$order_info['user_id'])->lock(true)->find();
  276. if($user_info['vip_endtime'] < time()){
  277. //过期了
  278. $vip_endtime = time() + (intval($order_info['days']) * 86400);
  279. }else{
  280. //追加vip
  281. $vip_endtime = $user_info['vip_endtime'] + (intval($order_info['days']) * 86400);
  282. }
  283. $update_data = [
  284. 'vip_endtime'=>$vip_endtime,
  285. ];
  286. $result = Db::name('user_wallet')->where('user_id',$order_info['user_id'])->update($update_data);
  287. if($result === false)
  288. {
  289. filePut($prefix.'逻辑续费vip时间失败');
  290. Db::rollback();
  291. $this->error('充值失败');
  292. }
  293. //添加新的一个task
  294. $task_data = $order_info;
  295. unset($task_data['id']);
  296. $task_data['createtime'] = time();
  297. $task_data['apple_receipt'] = $receipt_data;
  298. $task_data['in_app_one'] = json_encode($only_trans);
  299. $task_data['transaction_id'] = $transaction_id;
  300. $task_data['times'] = $order_info['times'] + 1;
  301. $task_data['original_purchase_date_ms'] = $only_trans['original_purchase_date_ms'];
  302. $task_data['purchase_date_ms'] = $only_trans['purchase_date_ms'];
  303. $task_data['expires_date_ms'] = $only_trans['expires_date_ms'];
  304. if($only_trans['product_id'] != $order_info_bundle_id){
  305. $task_data['times'] = 1;//回归1
  306. }
  307. $task_id = Db::name('user_vipxufei_task')->insertGetId($task_data);
  308. if(!$task_id)
  309. {
  310. filePut($prefix.'用户添加vipxufei_task失败');
  311. Db::rollback();
  312. $this->error('充值失败');
  313. }
  314. Db::commit();
  315. filePut($prefix.'充值成功');
  316. $this->success('充值成功');
  317. //逻辑结束
  318. }
  319. //金币+vip,苹果内购支付回调,app请求的接口
  320. public function gold_notify_iosnew(){
  321. $original_transaction_id = input('original_transaction_id','','trim');
  322. if(!empty($original_transaction_id)){
  323. //订阅信息
  324. $this->expires();
  325. }
  326. //苹果内购的验证收据
  327. $receipt_data = input('apple_receipt', '', 'trim');
  328. $out_trade_no = input('out_trade_no', '', 'trim');
  329. $transaction_id = input('transaction_id', '', 'trim');
  330. if (!$receipt_data || !$out_trade_no || !$transaction_id) {
  331. $this->error('缺少参数');
  332. }
  333. filePut("\r\n\r\n".'新请求');
  334. $prefix = 'ios充值,登录user_id:'.$this->auth->id.',out_trade_no:'.$out_trade_no.',传入transaction_id:'.$transaction_id.'。';
  335. filePut($prefix.'参数apple_receipt:'.$receipt_data);
  336. Db::startTrans();
  337. // 查找订单
  338. $order_map = [
  339. // 'user_id' => $this->auth->id,
  340. 'out_trade_no' => $out_trade_no,
  341. ];
  342. $order_info = Db::name('pay_order')->where($order_map)->lock(true)->find();
  343. if (!$order_info) {
  344. Db::rollback();
  345. filePut($prefix.'不存在的订单');
  346. $this->error('不存在的订单');
  347. }
  348. if ($order_info['order_status'] == 1) {
  349. Db::rollback();
  350. filePut($prefix.'充值早已完成');
  351. $this->success('充值已完成');
  352. }
  353. // 验证支付状态
  354. $result = $this->validate_apple_pay($receipt_data);
  355. if (!$result['status']) {// 验证不通过
  356. Db::rollback();
  357. filePut($prefix.'验证'.$result['message']);
  358. $this->error($result['message']);
  359. }
  360. $in_app = $result['data']['receipt']['in_app'];
  361. $only_trans = [];
  362. foreach($in_app as $key => $trans){
  363. //非订阅信息,原始信息
  364. // $trans['transaction_id'] == $transaction_id 这个不重要,重要的是后面2个。应该也重要,保证这次处理的是初始交易
  365. if($trans['transaction_id'] == $transaction_id && $transaction_id == $trans['original_transaction_id'] && $trans['product_id'] == $order_info['bundle_id']){
  366. $only_trans = $trans;
  367. break;
  368. }
  369. }
  370. if(empty($only_trans)){
  371. Db::rollback();
  372. filePut($prefix.'未找到匹配的交易,产品id'.$order_info['bundle_id'].',原始交易id'.$transaction_id);
  373. $this->error('未找到匹配的交易,产品id'.$order_info['bundle_id'].',原始交易id'.$transaction_id);
  374. }
  375. /*
  376. $count = count($result['data']['receipt']['in_app']);
  377. $use_count = $count - 1;
  378. $product_id = $result['data']['receipt']['in_app'][$use_count]['product_id'];
  379. $my_transaction_id = $result['data']['receipt']['in_app'][$use_count]['transaction_id'];
  380. if($product_id != $order_info['bundle_id']){
  381. Db::rollback();
  382. filePut($prefix.'验证'.'非法请求,请立刻停止product_id:'.$product_id.'!='.$order_info['bundle_id']);
  383. $this->error('非法请求,请立刻停止,产品id错误');
  384. }
  385. if($my_transaction_id != $transaction_id){
  386. Db::rollback();
  387. filePut($prefix.'验证'.'非法请求,请立刻停止transaction_id:'.$my_transaction_id.'!='.$transaction_id);
  388. $this->error('非法请求,请立刻停止,交易id错误');
  389. }*/
  390. //逻辑开始
  391. $args = json_decode($order_info['args'],true);
  392. //先充值
  393. if($order_info['table_name'] == 'gold_recharge'){
  394. $result = model('Wallet')->lockChangeAccountRemain($order_info['user_id'],'gold',$args['gold'],10, '金币充值','pay_order',$order_info['id']);
  395. if($result['status']===false)
  396. {
  397. filePut($prefix.'逻辑添加金币失败');
  398. Db::rollback();
  399. $this->error('充值失败');
  400. }
  401. }
  402. //先充值
  403. if($order_info['table_name'] == 'vip_recharge'){
  404. $user_info = Db::name('user_wallet')->where('user_id',$order_info['user_id'])->lock(true)->find();
  405. if($user_info['vip_endtime'] < time()){
  406. //过期了
  407. $vip_endtime = time() + (intval($args['days']) * 86400);
  408. }else{
  409. //追加vip
  410. $vip_endtime = $user_info['vip_endtime'] + (intval($args['days']) * 86400);
  411. }
  412. $update_data = [
  413. 'vip_endtime'=>$vip_endtime,
  414. ];
  415. $result = Db::name('user_wallet')->where('user_id',$order_info['user_id'])->update($update_data);
  416. if($result === false)
  417. {
  418. filePut($prefix.'逻辑续费vip时间失败');
  419. Db::rollback();
  420. $this->error('充值失败');
  421. }
  422. //订阅vip需要多加的逻辑
  423. if($order_info['is_lianxu'] == 1){
  424. $task_data = [
  425. 'order_id' => $order_info['id'],
  426. 'user_id' => $order_info['user_id'],
  427. 'bundle_id' => $order_info['bundle_id'],
  428. 'days' => $args['days'],
  429. 'createtime' => time(),
  430. 'apple_receipt' => $receipt_data,
  431. 'in_app_one' => json_encode($only_trans),
  432. 'original_transaction_id' => $only_trans['original_transaction_id'],
  433. 'transaction_id' => $only_trans['transaction_id'],
  434. 'status' => 1,
  435. 'times' => 1,
  436. //'notification_type' => 'INITIAL_BUY'.',首次订阅',
  437. 'original_purchase_date_ms' => $only_trans['original_purchase_date_ms'],
  438. 'purchase_date_ms' => $only_trans['purchase_date_ms'],
  439. 'expires_date_ms' => $only_trans['purchase_date_ms'], //第一次借用购买时间戳
  440. ];
  441. $task_id = Db::name('user_vipxufei_task')->insertGetId($task_data);
  442. if(!$task_id)
  443. {
  444. filePut($prefix.'用户添加vipxufei_task失败');
  445. Db::rollback();
  446. $this->error('充值失败');
  447. }
  448. }
  449. }
  450. // 修改订单状态
  451. $update_order = [
  452. 'notifytime'=>time(),
  453. 'order_status'=>1,
  454. 'original_transaction_id' => $only_trans['original_transaction_id'],//理论上与 transaction_id 相等
  455. 'in_app_one' => json_encode($only_trans),
  456. ];
  457. $ros = Db::name('pay_order')->where(['id' => $order_info['id']])->update($update_order);
  458. if($ros === false) {
  459. filePut($prefix.'修改订单状态失败');
  460. Db::rollback();
  461. $this->error('充值失败');
  462. }
  463. Db::commit();
  464. filePut($prefix.'充值成功');
  465. $this->success('充值成功');
  466. //逻辑结束
  467. }
  468. //因前端不传入订单号,作废
  469. public function gold_notify_ios(){
  470. //苹果内购的验证收据
  471. $receipt_data = input('apple_receipt', '', 'trim');
  472. $order_no = input('order_no', '', 'trim');
  473. filePut('金币 ios充值:参数apple_receipt='.$receipt_data.',order_no='.$order_no);
  474. if (!$receipt_data || !$order_no) {
  475. $this->error('缺少参数');
  476. }
  477. Db::startTrans();
  478. // 查找订单
  479. $order_info = Db::name('pay_order')->where(['out_trade_no' => $order_no])->lock(true)->find();
  480. if (!$order_info) {
  481. Db::rollback();
  482. filePut('金币 ios充值:订单丢失out_trade_no='.$order_no);
  483. $this->error('订单丢失');
  484. }
  485. if ($order_info['order_status'] == 1) {
  486. Db::rollback();
  487. $this->success('充值成功');
  488. }
  489. // 验证支付状态
  490. $result = $this->validate_apple_pay($receipt_data);
  491. if (!$result['status']) {// 验证不通过
  492. Db::rollback();
  493. filePut('金币 ios充值:验证out_trade_no='.$order_no.','.$result['message']);
  494. $this->error($result['message']);
  495. }
  496. $count = count($result['data']['receipt']['in_app']);
  497. $use_count = $count - 1;
  498. $args = json_decode($order_info['args'],true);
  499. if ($result['data']['receipt']['in_app'][$use_count]['product_id'] != $order_info['bundle_id']) {
  500. Db::rollback();
  501. filePut('金币 ios充值:非法请求,请立刻停止out_trade_no='.$order_no.','.$result['message'].','.$result['data']['receipt']['in_app'][$use_count]['product_id'].'!='.$order_info['bundle_id']);
  502. $this->error('非法请求,请立刻停止');
  503. }
  504. //逻辑开始
  505. //先充值
  506. $result = model('Wallet')->lockChangeAccountRemain($order_info['user_id'],'gold',$args['gold'],10, '金币充值','pay_order',$order_info['id']);
  507. if($result['status']===false)
  508. {
  509. filePut('金币 ios充值:验证out_trade_no='.$order_no.',逻辑添加金币失败');
  510. Db::rollback();
  511. return false;
  512. }
  513. // 修改订单状态
  514. $ros = Db::name('pay_order')->where(['out_trade_no' => $order_no])->update(['order_status'=>1,'notifytime'=>time()]);
  515. if($ros === false) {
  516. filePut('金币 ios充值:充值失败out_trade_no='.$order_no.','.$result['message'].','.'修改订单状态失败');
  517. Db::rollback();
  518. $this->error('充值失败');
  519. }
  520. Db::commit();
  521. $this->success('充值成功');
  522. //逻辑结束
  523. }
  524. ////////////////////////////////////
  525. //苹果自动扣费回调
  526. public function auto_renewal_vip_notify(){
  527. $this->notify_log_start('ios');
  528. }
  529. ///////////////////////////////////////////////////////////////////////////////////////////////
  530. //异步日志
  531. private function notify_log_start($paytype = 'ios'){
  532. //记录支付回调数据
  533. ignore_user_abort(); // run script in background
  534. set_time_limit(30);
  535. // 日志文件 start
  536. $log_base_dir = '../paylog/'.$paytype.'/';
  537. if (!is_dir($log_base_dir))
  538. {
  539. mkdir($log_base_dir, 0770, true);
  540. @chmod($log_base_dir, 0770);
  541. }
  542. $notify_file = $log_base_dir.'notify.txt';
  543. if(!file_exists($notify_file)) {
  544. @touch($notify_file);
  545. @chmod($notify_file, 0770);
  546. }
  547. if(filesize($notify_file)>5242880)//大于5M自动切换
  548. {
  549. rename($notify_file, $log_base_dir.'notify_'.date('Y_m_d_H_i_s').'.txt');
  550. }
  551. if(!file_exists($notify_file)) {
  552. @touch($notify_file);
  553. @chmod($notify_file, 0770);
  554. }
  555. // 日志文件 end
  556. //开始写入
  557. $_REQUEST = isset($_REQUEST) ? $_REQUEST : array();
  558. if($_REQUEST && $paytype == 'alipay') {
  559. file_put_contents($notify_file, "\r\n\r\n".date('Y-m-d H:i:s')." [notify][入口接收request]".json_encode($_REQUEST), FILE_APPEND);
  560. } else {
  561. $xml = file_get_contents("php://input");
  562. file_put_contents($notify_file, "\r\n\r\n".date('Y-m-d H:i:s')." [notify][入口接收php://input流原始数据] \n".$xml, FILE_APPEND);
  563. $xmlObj = simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA);
  564. file_put_contents($notify_file, "\r\n\r\n".date('Y-m-d H:i:s')." [notify][入口接收php://input流] ".json_encode($xmlObj), FILE_APPEND);
  565. }
  566. ini_set('display_errors','On');
  567. return $notify_file;
  568. }
  569. public function test(){
  570. $a = input('apple_receipt');
  571. $b = $this->validate_apple_pay($a);
  572. dump($b);
  573. }
  574. /**
  575. * 验证AppStore内付
  576. * @param string $receipt_data 付款后凭证
  577. * @return array 验证是否成功
  578. */
  579. function validate_apple_pay($receipt_data = '') {
  580. // 验证参数
  581. if (strlen($receipt_data) < 20) {
  582. $result = array(
  583. 'status' => false,
  584. 'message' => '非法参数'
  585. );
  586. return $result;
  587. }
  588. // 请求验证
  589. $html = $this->curl($receipt_data);
  590. $data = json_decode($html, true);
  591. $data['sandbox'] = '0';
  592. // p($data);die;
  593. if ($data['status'] == '21002') {
  594. $result = array(
  595. 'status' => false,
  596. 'message' => 'status:21002'
  597. );
  598. return $result;
  599. }
  600. // 如果是沙盒数据 则验证沙盒模式 21008;正式数据 21007
  601. if ($data['status'] == '21007') {
  602. // 请求验证
  603. $html = $this->curl($receipt_data, 1);
  604. $data = json_decode($html, true);
  605. $data['sandbox'] = '1';
  606. }
  607. if (isset($_GET['debug'])) {
  608. exit(json_encode($data));
  609. }
  610. if ($data['receipt']['bundle_id'] != 'com.huxiu.tken') {
  611. $result = array(
  612. 'status' => false,
  613. 'message' => '非法请求',
  614. 'data' => $data
  615. );
  616. return $result;
  617. }
  618. // 判断是否购买成功
  619. if (intval($data['status']) === 0) {
  620. $result = array(
  621. 'status' => true,
  622. 'message' => '购买成功',
  623. 'data' => $data
  624. );
  625. } else {
  626. $result = array(
  627. 'status' => false,
  628. 'message' => '购买失败 status:' . $data['status']
  629. );
  630. }
  631. // dump($result);
  632. return $result;
  633. }
  634. /**
  635. * 0 票据校验成功
  636. * 21000 App Store不能读取你提供的JSON对象25
  637. * 21002 receipt-data域的数据有问题
  638. * 21003 receipt无法通过验证
  639. * 21004 提供的shared secret不匹配你账号中的shared secret
  640. * 21005 receipt服务器当前不可用
  641. * 21006 receipt合法,但是订阅已过期。服务器接收到这个状态码时,receipt数据仍然会解码并一起发送
  642. * 21007 receipt是Sandbox receipt,但却发送至生产系统的验证服务
  643. * 21008 receipt是生产receipt,但却发送至Sandbox环境的验证服务
  644. */
  645. //苹果也是建议这个校验逻辑由服务端完成。服务器需要先去请求正式环境。如果receipt是正式环境的,那么这个时候苹果会返回(21007)告诉我们这个是沙盒的receipt,那么服务器再去请求sandbox环境。
  646. function curl($receipt_data,$sandbox = 0) {
  647. //小票信息
  648. $POSTFIELDS = [
  649. 'receipt-data' => $receipt_data,
  650. 'password' => '09ef214173a944808ac648b15fa02167'
  651. ];
  652. $POSTFIELDS = json_encode($POSTFIELDS, 320);
  653. //正式购买地址 沙盒购买地址
  654. $url_buy = "https://buy.itunes.apple.com/verifyReceipt";
  655. $url_sandbox = "https://sandbox.itunes.apple.com/verifyReceipt";
  656. //默认后台控制
  657. if (config('site.ios_pay_sandbox') > 0 ) {
  658. $url = $url_buy;
  659. } else {
  660. $url = $url_sandbox;
  661. }
  662. //强制沙盒
  663. if($sandbox == 1){
  664. $url = $url_sandbox;
  665. }
  666. $ch = curl_init($url);
  667. curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  668. curl_setopt($ch, CURLOPT_POST, true);
  669. curl_setopt($ch, CURLOPT_POSTFIELDS, $POSTFIELDS);
  670. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0); //这两行一定要加,不加会报SSL 错误
  671. curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
  672. $response = curl_exec($ch);
  673. $errno = curl_errno($ch);
  674. curl_close($ch);
  675. if ($errno != 0) {
  676. return $errno;
  677. } else {
  678. return $response;
  679. }
  680. }
  681. }