Payios.php 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779
  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. if($only_trans['product_id'] != $order_info['bundle_id']){
  233. $pay_order_map = [
  234. 'user_id' => $this->auth->id,
  235. 'bundle_id' => $only_trans['product_id'],
  236. 'order_status' => 0,
  237. 'table_name' => 'vip_recharge',
  238. ];
  239. $pay_order = Db::name('pay_order')->where($pay_order_map)->order('id desc')->lock(true)->find();
  240. if(!$pay_order){
  241. Db::rollback();
  242. filePut($prefix.'未找到匹配的交易,新订单找不到');
  243. $this->error('未找到匹配的新订单');
  244. }
  245. // 修改订单状态
  246. $update_order = [
  247. 'notifytime'=>time(),
  248. 'order_status'=>1,
  249. 'original_transaction_id' => $only_trans['original_transaction_id'],
  250. 'in_app_one' => json_encode($only_trans),
  251. ];
  252. $ros = Db::name('pay_order')->where(['id' => $pay_order['id']])->update($update_order);
  253. if($ros === false) {
  254. filePut($prefix.'修改订单状态失败');
  255. Db::rollback();
  256. $this->error('充值失败');
  257. }
  258. $args = json_decode($pay_order['args'],true);
  259. //修改order_info
  260. $order_info['order_id'] = $pay_order['id'];
  261. $order_info['user_id'] = $pay_order['user_id'];
  262. $order_info['bundle_id'] = $pay_order['bundle_id'];
  263. $order_info['days'] = $args['days'];
  264. $order_info['original_transaction_id'] = $only_trans['original_transaction_id'];//多余
  265. }
  266. //验证时间
  267. if($only_trans['purchase_date_ms'] <= $order_info['purchase_date_ms'] || $only_trans['expires_date_ms'] <= $order_info['expires_date_ms']){
  268. Db::rollback();
  269. filePut($prefix.'时间对不上,返回成功,finish掉');
  270. $this->success(1);
  271. }
  272. //逻辑开始
  273. //先充值
  274. $user_info = Db::name('user_wallet')->where('user_id',$order_info['user_id'])->lock(true)->find();
  275. if($user_info['vip_endtime'] < time()){
  276. //过期了
  277. $vip_endtime = time() + (intval($order_info['days']) * 86400);
  278. }else{
  279. //追加vip
  280. $vip_endtime = $user_info['vip_endtime'] + (intval($order_info['days']) * 86400);
  281. }
  282. $update_data = [
  283. 'vip_endtime'=>$vip_endtime,
  284. ];
  285. $result = Db::name('user_wallet')->where('user_id',$order_info['user_id'])->update($update_data);
  286. if($result === false)
  287. {
  288. filePut($prefix.'逻辑续费vip时间失败');
  289. Db::rollback();
  290. $this->error('充值失败');
  291. }
  292. //添加新的一个task
  293. $task_data = $order_info;
  294. unset($task_data['id']);
  295. $task_data['createtime'] = time();
  296. $task_data['apple_receipt'] = $receipt_data;
  297. $task_data['in_app_one'] = json_encode($only_trans);
  298. $task_data['transaction_id'] = $transaction_id;
  299. $task_data['times'] = $order_info['times'] + 1;
  300. $task_data['original_purchase_date_ms'] = $only_trans['original_purchase_date_ms'];
  301. $task_data['purchase_date_ms'] = $only_trans['purchase_date_ms'];
  302. $task_data['expires_date_ms'] = $only_trans['expires_date_ms'];
  303. if($only_trans['product_id'] != $order_info['bundle_id']){
  304. $task_data['times'] = 1;//回归1
  305. }
  306. $task_id = Db::name('user_vipxufei_task')->insertGetId($task_data);
  307. if(!$task_id)
  308. {
  309. filePut($prefix.'用户添加vipxufei_task失败');
  310. Db::rollback();
  311. $this->error('充值失败');
  312. }
  313. Db::commit();
  314. filePut($prefix.'充值成功');
  315. $this->success('充值成功');
  316. //逻辑结束
  317. }
  318. //金币+vip,苹果内购支付回调,app请求的接口
  319. public function gold_notify_iosnew(){
  320. $original_transaction_id = input('original_transaction_id','','trim');
  321. if(!empty($original_transaction_id)){
  322. //订阅信息
  323. $this->expires();
  324. }
  325. //苹果内购的验证收据
  326. $receipt_data = input('apple_receipt', '', 'trim');
  327. $out_trade_no = input('out_trade_no', '', 'trim');
  328. $transaction_id = input('transaction_id', '', 'trim');
  329. if (!$receipt_data || !$out_trade_no || !$transaction_id) {
  330. $this->error('缺少参数');
  331. }
  332. filePut("\r\n\r\n".'新请求');
  333. $prefix = 'ios充值,登录user_id:'.$this->auth->id.',out_trade_no:'.$out_trade_no.',传入transaction_id:'.$transaction_id.'。';
  334. filePut($prefix.'参数apple_receipt:'.$receipt_data);
  335. Db::startTrans();
  336. // 查找订单
  337. $order_map = [
  338. // 'user_id' => $this->auth->id,
  339. 'out_trade_no' => $out_trade_no,
  340. ];
  341. $order_info = Db::name('pay_order')->where($order_map)->lock(true)->find();
  342. if (!$order_info) {
  343. Db::rollback();
  344. filePut($prefix.'不存在的订单');
  345. $this->error('不存在的订单');
  346. }
  347. if ($order_info['order_status'] == 1) {
  348. Db::rollback();
  349. filePut($prefix.'充值早已完成');
  350. $this->success('充值已完成');
  351. }
  352. // 验证支付状态
  353. $result = $this->validate_apple_pay($receipt_data);
  354. if (!$result['status']) {// 验证不通过
  355. Db::rollback();
  356. filePut($prefix.'验证'.$result['message']);
  357. $this->error($result['message']);
  358. }
  359. $in_app = $result['data']['receipt']['in_app'];
  360. $only_trans = [];
  361. foreach($in_app as $key => $trans){
  362. //非订阅信息,原始信息
  363. // $trans['transaction_id'] == $transaction_id 这个不重要,重要的是后面2个。应该也重要,保证这次处理的是初始交易
  364. if($trans['transaction_id'] == $transaction_id && $transaction_id == $trans['original_transaction_id'] && $trans['product_id'] == $order_info['bundle_id']){
  365. $only_trans = $trans;
  366. break;
  367. }
  368. }
  369. if(empty($only_trans)){
  370. Db::rollback();
  371. filePut($prefix.'未找到匹配的交易,产品id'.$order_info['bundle_id'].',原始交易id'.$transaction_id);
  372. $this->error('未找到匹配的交易,产品id'.$order_info['bundle_id'].',原始交易id'.$transaction_id);
  373. }
  374. /*
  375. $count = count($result['data']['receipt']['in_app']);
  376. $use_count = $count - 1;
  377. $product_id = $result['data']['receipt']['in_app'][$use_count]['product_id'];
  378. $my_transaction_id = $result['data']['receipt']['in_app'][$use_count]['transaction_id'];
  379. if($product_id != $order_info['bundle_id']){
  380. Db::rollback();
  381. filePut($prefix.'验证'.'非法请求,请立刻停止product_id:'.$product_id.'!='.$order_info['bundle_id']);
  382. $this->error('非法请求,请立刻停止,产品id错误');
  383. }
  384. if($my_transaction_id != $transaction_id){
  385. Db::rollback();
  386. filePut($prefix.'验证'.'非法请求,请立刻停止transaction_id:'.$my_transaction_id.'!='.$transaction_id);
  387. $this->error('非法请求,请立刻停止,交易id错误');
  388. }*/
  389. //逻辑开始
  390. $args = json_decode($order_info['args'],true);
  391. //先充值
  392. if($order_info['table_name'] == 'gold_recharge'){
  393. $result = model('Wallet')->lockChangeAccountRemain($order_info['user_id'],'gold',$args['gold'],10, '金币充值','pay_order',$order_info['id']);
  394. if($result['status']===false)
  395. {
  396. filePut($prefix.'逻辑添加金币失败');
  397. Db::rollback();
  398. $this->error('充值失败');
  399. }
  400. }
  401. //先充值
  402. if($order_info['table_name'] == 'vip_recharge'){
  403. $user_info = Db::name('user_wallet')->where('user_id',$order_info['user_id'])->lock(true)->find();
  404. if($user_info['vip_endtime'] < time()){
  405. //过期了
  406. $vip_endtime = time() + (intval($args['days']) * 86400);
  407. }else{
  408. //追加vip
  409. $vip_endtime = $user_info['vip_endtime'] + (intval($args['days']) * 86400);
  410. }
  411. $update_data = [
  412. 'vip_endtime'=>$vip_endtime,
  413. ];
  414. $result = Db::name('user_wallet')->where('user_id',$order_info['user_id'])->update($update_data);
  415. if($result === false)
  416. {
  417. filePut($prefix.'逻辑续费vip时间失败');
  418. Db::rollback();
  419. $this->error('充值失败');
  420. }
  421. //订阅vip需要多加的逻辑
  422. if($order_info['is_lianxu'] == 1){
  423. $task_data = [
  424. 'order_id' => $order_info['id'],
  425. 'user_id' => $order_info['user_id'],
  426. 'bundle_id' => $order_info['bundle_id'],
  427. 'days' => $args['days'],
  428. 'createtime' => time(),
  429. 'apple_receipt' => $receipt_data,
  430. 'in_app_one' => json_encode($only_trans),
  431. 'original_transaction_id' => $only_trans['original_transaction_id'],
  432. 'transaction_id' => $only_trans['transaction_id'],
  433. 'status' => 1,
  434. 'times' => 1,
  435. //'notification_type' => 'INITIAL_BUY'.',首次订阅',
  436. 'original_purchase_date_ms' => $only_trans['original_purchase_date_ms'],
  437. 'purchase_date_ms' => $only_trans['purchase_date_ms'],
  438. 'expires_date_ms' => $only_trans['purchase_date_ms'], //第一次借用购买时间戳
  439. ];
  440. $task_id = Db::name('user_vipxufei_task')->insertGetId($task_data);
  441. if(!$task_id)
  442. {
  443. filePut($prefix.'用户添加vipxufei_task失败');
  444. Db::rollback();
  445. $this->error('充值失败');
  446. }
  447. }
  448. }
  449. // 修改订单状态
  450. $update_order = [
  451. 'notifytime'=>time(),
  452. 'order_status'=>1,
  453. 'original_transaction_id' => $only_trans['original_transaction_id'],//理论上与 transaction_id 相等
  454. 'in_app_one' => json_encode($only_trans),
  455. ];
  456. $ros = Db::name('pay_order')->where(['id' => $order_info['id']])->update($update_order);
  457. if($ros === false) {
  458. filePut($prefix.'修改订单状态失败');
  459. Db::rollback();
  460. $this->error('充值失败');
  461. }
  462. Db::commit();
  463. filePut($prefix.'充值成功');
  464. $this->success('充值成功');
  465. //逻辑结束
  466. }
  467. //因前端不传入订单号,作废
  468. public function gold_notify_ios(){
  469. //苹果内购的验证收据
  470. $receipt_data = input('apple_receipt', '', 'trim');
  471. $order_no = input('order_no', '', 'trim');
  472. filePut('金币 ios充值:参数apple_receipt='.$receipt_data.',order_no='.$order_no);
  473. if (!$receipt_data || !$order_no) {
  474. $this->error('缺少参数');
  475. }
  476. Db::startTrans();
  477. // 查找订单
  478. $order_info = Db::name('pay_order')->where(['out_trade_no' => $order_no])->lock(true)->find();
  479. if (!$order_info) {
  480. Db::rollback();
  481. filePut('金币 ios充值:订单丢失out_trade_no='.$order_no);
  482. $this->error('订单丢失');
  483. }
  484. if ($order_info['order_status'] == 1) {
  485. Db::rollback();
  486. $this->success('充值成功');
  487. }
  488. // 验证支付状态
  489. $result = $this->validate_apple_pay($receipt_data);
  490. if (!$result['status']) {// 验证不通过
  491. Db::rollback();
  492. filePut('金币 ios充值:验证out_trade_no='.$order_no.','.$result['message']);
  493. $this->error($result['message']);
  494. }
  495. $count = count($result['data']['receipt']['in_app']);
  496. $use_count = $count - 1;
  497. $args = json_decode($order_info['args'],true);
  498. if ($result['data']['receipt']['in_app'][$use_count]['product_id'] != $order_info['bundle_id']) {
  499. Db::rollback();
  500. filePut('金币 ios充值:非法请求,请立刻停止out_trade_no='.$order_no.','.$result['message'].','.$result['data']['receipt']['in_app'][$use_count]['product_id'].'!='.$order_info['bundle_id']);
  501. $this->error('非法请求,请立刻停止');
  502. }
  503. //逻辑开始
  504. //先充值
  505. $result = model('Wallet')->lockChangeAccountRemain($order_info['user_id'],'gold',$args['gold'],10, '金币充值','pay_order',$order_info['id']);
  506. if($result['status']===false)
  507. {
  508. filePut('金币 ios充值:验证out_trade_no='.$order_no.',逻辑添加金币失败');
  509. Db::rollback();
  510. return false;
  511. }
  512. // 修改订单状态
  513. $ros = Db::name('pay_order')->where(['out_trade_no' => $order_no])->update(['order_status'=>1,'notifytime'=>time()]);
  514. if($ros === false) {
  515. filePut('金币 ios充值:充值失败out_trade_no='.$order_no.','.$result['message'].','.'修改订单状态失败');
  516. Db::rollback();
  517. $this->error('充值失败');
  518. }
  519. Db::commit();
  520. $this->success('充值成功');
  521. //逻辑结束
  522. }
  523. ////////////////////////////////////
  524. //苹果自动扣费回调
  525. public function auto_renewal_vip_notify(){
  526. $this->notify_log_start('ios');
  527. }
  528. ///////////////////////////////////////////////////////////////////////////////////////////////
  529. //异步日志
  530. private function notify_log_start($paytype = 'ios'){
  531. //记录支付回调数据
  532. ignore_user_abort(); // run script in background
  533. set_time_limit(30);
  534. // 日志文件 start
  535. $log_base_dir = '../paylog/'.$paytype.'/';
  536. if (!is_dir($log_base_dir))
  537. {
  538. mkdir($log_base_dir, 0770, true);
  539. @chmod($log_base_dir, 0770);
  540. }
  541. $notify_file = $log_base_dir.'notify.txt';
  542. if(!file_exists($notify_file)) {
  543. @touch($notify_file);
  544. @chmod($notify_file, 0770);
  545. }
  546. if(filesize($notify_file)>5242880)//大于5M自动切换
  547. {
  548. rename($notify_file, $log_base_dir.'notify_'.date('Y_m_d_H_i_s').'.txt');
  549. }
  550. if(!file_exists($notify_file)) {
  551. @touch($notify_file);
  552. @chmod($notify_file, 0770);
  553. }
  554. // 日志文件 end
  555. //开始写入
  556. $_REQUEST = isset($_REQUEST) ? $_REQUEST : array();
  557. if($_REQUEST && $paytype == 'alipay') {
  558. file_put_contents($notify_file, "\r\n\r\n".date('Y-m-d H:i:s')." [notify][入口接收request]".json_encode($_REQUEST), FILE_APPEND);
  559. } else {
  560. $xml = file_get_contents("php://input");
  561. file_put_contents($notify_file, "\r\n\r\n".date('Y-m-d H:i:s')." [notify][入口接收php://input流原始数据] \n".$xml, FILE_APPEND);
  562. $xmlObj = simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA);
  563. file_put_contents($notify_file, "\r\n\r\n".date('Y-m-d H:i:s')." [notify][入口接收php://input流] ".json_encode($xmlObj), FILE_APPEND);
  564. }
  565. ini_set('display_errors','On');
  566. return $notify_file;
  567. }
  568. /**
  569. * 验证AppStore内付
  570. * @param string $receipt_data 付款后凭证
  571. * @return array 验证是否成功
  572. */
  573. function validate_apple_pay($receipt_data = '') {
  574. // 验证参数
  575. if (strlen($receipt_data) < 20) {
  576. $result = array(
  577. 'status' => false,
  578. 'message' => '非法参数'
  579. );
  580. return $result;
  581. }
  582. // 请求验证
  583. $html = $this->curl($receipt_data);
  584. $data = json_decode($html, true);
  585. $data['sandbox'] = '0';
  586. // p($data);die;
  587. if ($data['status'] == '21002') {
  588. $result = array(
  589. 'status' => false,
  590. 'message' => 'status:21002'
  591. );
  592. return $result;
  593. }
  594. // 如果是沙盒数据 则验证沙盒模式 21008;正式数据 21007
  595. if ($data['status'] == '21007') {
  596. // 请求验证
  597. $html = $this->curl($receipt_data, 1);
  598. $data = json_decode($html, true);
  599. $data['sandbox'] = '1';
  600. }
  601. if (isset($_GET['debug'])) {
  602. exit(json_encode($data));
  603. }
  604. if ($data['receipt']['bundle_id'] != 'com.huxiu.tken') {
  605. $result = array(
  606. 'status' => false,
  607. 'message' => '非法请求',
  608. 'data' => $data
  609. );
  610. return $result;
  611. }
  612. // 判断是否购买成功
  613. if (intval($data['status']) === 0) {
  614. $result = array(
  615. 'status' => true,
  616. 'message' => '购买成功',
  617. 'data' => $data
  618. );
  619. } else {
  620. $result = array(
  621. 'status' => false,
  622. 'message' => '购买失败 status:' . $data['status']
  623. );
  624. }
  625. // dump($result);
  626. return $result;
  627. }
  628. /**
  629. * 0 票据校验成功
  630. * 21000 App Store不能读取你提供的JSON对象25
  631. * 21002 receipt-data域的数据有问题
  632. * 21003 receipt无法通过验证
  633. * 21004 提供的shared secret不匹配你账号中的shared secret
  634. * 21005 receipt服务器当前不可用
  635. * 21006 receipt合法,但是订阅已过期。服务器接收到这个状态码时,receipt数据仍然会解码并一起发送
  636. * 21007 receipt是Sandbox receipt,但却发送至生产系统的验证服务
  637. * 21008 receipt是生产receipt,但却发送至Sandbox环境的验证服务
  638. */
  639. //苹果也是建议这个校验逻辑由服务端完成。服务器需要先去请求正式环境。如果receipt是正式环境的,那么这个时候苹果会返回(21007)告诉我们这个是沙盒的receipt,那么服务器再去请求sandbox环境。
  640. function curl($receipt_data,$sandbox = 0) {
  641. //小票信息
  642. $POSTFIELDS = [
  643. 'receipt-data' => $receipt_data,
  644. 'password' => '09ef214173a944808ac648b15fa02167'
  645. ];
  646. $POSTFIELDS = json_encode($POSTFIELDS, 320);
  647. //正式购买地址 沙盒购买地址
  648. $url_buy = "https://buy.itunes.apple.com/verifyReceipt";
  649. $url_sandbox = "https://sandbox.itunes.apple.com/verifyReceipt";
  650. //默认后台控制
  651. if (config('site.ios_pay_sandbox') > 0 ) {
  652. $url = $url_buy;
  653. } else {
  654. $url = $url_sandbox;
  655. }
  656. //强制沙盒
  657. if($sandbox == 1){
  658. $url = $url_sandbox;
  659. }
  660. $ch = curl_init($url);
  661. curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
  662. curl_setopt($ch, CURLOPT_POST, true);
  663. curl_setopt($ch, CURLOPT_POSTFIELDS, $POSTFIELDS);
  664. curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0); //这两行一定要加,不加会报SSL 错误
  665. curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
  666. $response = curl_exec($ch);
  667. $errno = curl_errno($ch);
  668. curl_close($ch);
  669. if ($errno != 0) {
  670. return $errno;
  671. } else {
  672. return $response;
  673. }
  674. }
  675. }