Pay.php 4.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147
  1. <?php
  2. # 支付
  3. namespace Goods\Lib;
  4. use Dever;
  5. class Pay
  6. {
  7. # 发起支付
  8. public function action($parent_uid, $uid, $id, $sku, $num, $address_id, $source, $type = false, $type_id = false)
  9. {
  10. if (!$uid) {
  11. Dever::alert('错误的用户信息');
  12. }
  13. $goods = Dever::load('goods/lib/info')->getPayInfo($id, $sku);
  14. $shop = Dever::db('goods/shop')->one($goods['shop_id']);
  15. $user = Dever::db('passport/user')->one($uid);
  16. if ($parent_uid) {
  17. $order_data['parent_uid'] = $parent_uid;
  18. }
  19. $order_data['type'] = $type;
  20. $order_data['type_id'] = $type_id;
  21. $order_data['uid'] = $uid;
  22. $order_data['status'] = 1;
  23. $order_data['info_id'] = $goods['id'];
  24. $order_data['sku_id'] = $sku;
  25. $order_data['address_id'] = $address_id;
  26. $order_data['name'] = $goods['name'];
  27. $order_data['cash'] = $goods['price'];
  28. $order_data['num'] = $num;
  29. $order_data['source'] = $source;
  30. $order_data['order_id'] = $this->getOrderId();
  31. $id = Dever::db('goods/order')->insert($order_data);
  32. if (!$id) {
  33. Dever::alert('支付失败');
  34. }
  35. $refer = 'test';
  36. $param = array
  37. (
  38. 'project_id' => 1,
  39. 'channel_id' => $shop['channel_id'],
  40. 'system_source' => $source,
  41. 'uid' => $uid,
  42. 'username' => $user['username'],
  43. 'name' => $order_data['name'],
  44. 'cash' => $order_data['cash'] * $order_data['num'],
  45. 'product_id' => $goods['id'],
  46. 'order_id' => $order_data['order_id'],
  47. 'refer' => $refer
  48. );
  49. $receipt = Dever::input('receipt');
  50. if ($receipt) {
  51. $param['receipt'] = $receipt;
  52. }
  53. $result['pay'] = Dever::load('pay/api.pay', $param);
  54. $result['order_id'] = $order_data['order_id'];
  55. return $result;
  56. }
  57. # 支付成功回调 安全加密 设置token
  58. public function success_secure_api_token()
  59. {
  60. $project_id = Dever::input('pay_project_id');
  61. $info = Dever::db('pay/project')->one($project_id);
  62. if ($info) {
  63. return $info['key'];
  64. }
  65. return 'goods_dever_2020';
  66. }
  67. # 支付成功回调 安全加密
  68. public function success_secure_api($param = array())
  69. {
  70. $this->success($param);
  71. }
  72. # 支付成功回调
  73. public function success($param = array())
  74. {
  75. $send = $param ? $param : Dever::preInput('pay_');
  76. $order_id = $send['pay_order_id'];
  77. $status = $send['pay_status'];
  78. $msg = $send['pay_msg'];
  79. $order = Dever::db('goods/order')->one(array('order_id' => $order_id));
  80. if ($order && $order['status'] == 1) {
  81. if ($status == 2) {
  82. # 减少库存 增加销量
  83. $update['where_id'] = $order['info_id'];
  84. $update['sell_num'] = $order['num'];
  85. Dever::db('goods/info')->updateSell($update);
  86. if ($order['sku_id'] > 0) {
  87. $update['where_id'] = $order['sku_id'];
  88. $update['sell_num'] = $order['num'];
  89. Dever::db('goods/info_sku')->updateSell($update);
  90. }
  91. # 增加积分
  92. if ($order['parent_uid'] > 0) {
  93. $uid = $order['parent_uid'] . '_' . $order['uid'];
  94. } else {
  95. $uid = $order['uid'];
  96. }
  97. Dever::score($uid, 'buy_my_goods', '购买自营商品', false, false, false, $order['type'], $order['type_id']);
  98. # 发消息
  99. if (Dever::project('message')) {
  100. Dever::load('message/lib/data')->push(-1, $order['uid'], '购买提醒', '购买成功', 11);
  101. }
  102. }
  103. $update['status'] = $status;
  104. $update['where_id'] = $order['id'];
  105. Dever::db('goods/order')->update($update);
  106. }
  107. return 'ok';
  108. }
  109. # 生成订单号
  110. public function getOrderId()
  111. {
  112. $where['order_id'] = Dever::order();
  113. $state = Dever::db('goods/order')->one($where);
  114. if (!$state) {
  115. return $where['order_id'];
  116. } else {
  117. return $this->getOrderId();
  118. }
  119. }
  120. }