Core.php 5.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220
  1. <?php namespace Pay\Lib;
  2. use Dever;
  3. class Core
  4. {
  5. public $order_id;
  6. /**
  7. * 更新订单状态
  8. */
  9. public function updateOrder($order_id, $cash, $desc = '')
  10. {
  11. $project_id = $this->checkOrder($order_id);
  12. if ($project_id) {
  13. $info = array();
  14. $info['status'] = 1;
  15. $info['order_id'] = $order_id;
  16. $info['project_id'] = $project_id;
  17. } else {
  18. $db = Dever::db('pay/order');
  19. $info = $db->one(array('order_id' => $order_id, 'rand' => time() . rand(1,1000)));
  20. }
  21. if ($info && $info['status']) {
  22. $param['status'] = 2;
  23. $msg = '支付成功';
  24. if ($desc) {
  25. $param['status'] = 3;
  26. $param['status_desc'] = $desc;
  27. $msg = '支付失败||' . $desc;
  28. }
  29. $this->log($msg, $info);
  30. if (isset($info['id'])) {
  31. $param['where_id'] = $info['id'];
  32. if ($param['status']) {
  33. $param['pay_time'] = time();
  34. }
  35. $db->update($param);
  36. }
  37. $notify = false;
  38. $key = false;
  39. if (isset($info['project_id']) && $info['project_id']) {
  40. $project = Dever::db('pay/project')->one($info['project_id']);
  41. if ($project && $project['notify']) {
  42. $notify = $project['notify'];
  43. //$key = md5($project['key']);
  44. $key = $project['key'];
  45. }
  46. }
  47. if (!$notify) {
  48. $notify = Dever::config('base', 'project')->pay_notify;
  49. //$key = md5($notify);
  50. $key = $notify;
  51. }
  52. if ($notify && $key) {
  53. $send = array();
  54. $send['pay_product_id'] = $info['product_id'];
  55. $send['pay_uid'] = $info['uid'];
  56. $send['pay_cash'] = $info['cash'];
  57. $send['pay_order_id'] = $order_id;
  58. $send['pay_status'] = $param['status'];
  59. $send['pay_msg'] = $msg;
  60. $send['pay_id'] = $info['id'];
  61. # 2020-08-20 取消之前的加密方式,使用自动加密
  62. /*
  63. $send['pay_time'] = time();
  64. $send['pay_nonce'] = Dever::nonce();
  65. ksort($send);
  66. $send['signature'] = md5($key . '&' . http_build_query($send));
  67. */
  68. $send['dever_token'] = $key;
  69. $this->log($notify, $send);
  70. if (strstr($notify, 'http://') || strstr($notify, 'https://')) {
  71. Dever::curl($notify, $send);
  72. } else {
  73. Dever::load($notify, $send);
  74. }
  75. }
  76. } else {
  77. $this->log('支付失败', '错误的订单id:' . $order_id);
  78. }
  79. }
  80. /**
  81. * 更新订单的支付信息
  82. */
  83. protected function updateOrderParam($order_id, $data)
  84. {
  85. if ($this->checkOrder($order_id)) {
  86. return false;
  87. }
  88. $db = Dever::db('pay/order');
  89. $info = $db->one(array('order_id' => $order_id, 'status' => 1));
  90. if ($info) {
  91. $param['where_id'] = $info['id'];
  92. $param['param'] = Dever::array_encode($data);
  93. $db->update($param);
  94. }
  95. }
  96. /**
  97. * 创建订单
  98. */
  99. protected function createOrder($uid, $username, $account_id, $project_id, $product_id, $name, $cash, $type, $order_id = false)
  100. {
  101. if ($this->checkOrder($order_id)) {
  102. return $this->order_id = $order_id;
  103. }
  104. $state = $order_id;
  105. $db = Dever::db('pay/order');
  106. if (!$state) {
  107. $order_id = Dever::order();
  108. }
  109. $this->order_id = $order_id;
  110. $info = $db->one(array('order_id' => $order_id));
  111. if ($info) {
  112. if (!$state) {
  113. return $this->createOrder($uid, $username, $account_id, $project_id, $product_id, $name, $cash, $type);
  114. } else {
  115. return $order_id;
  116. }
  117. } else {
  118. if (!$username && Dever::project('passport')) {
  119. $user = Dever::db('passport/user')->one($uid);
  120. if ($user) {
  121. $username = $user['username'];
  122. }
  123. }
  124. $add['status'] = 1;
  125. $add['uid'] = $uid;
  126. $add['username'] = $username;
  127. $add['account_id'] = $account_id;
  128. $add['project_id'] = $project_id;
  129. $add['name'] = $name;
  130. $add['cash'] = $cash;
  131. $add['type'] = $type;
  132. $add['order_id'] = $order_id;
  133. $add['product_id'] = $product_id;
  134. $add['id'] = $db->insert($add);
  135. $msg = '发起支付';
  136. $this->log($msg, $add);
  137. }
  138. return $order_id;
  139. }
  140. public function checkOrder($order_id)
  141. {
  142. if (strstr($order_id, 'O')) {
  143. $array = explode('O', $order_id);
  144. return $array[1];
  145. }
  146. return false;
  147. }
  148. /**
  149. * 获取回调url
  150. */
  151. protected function url($type, $account_id)
  152. {
  153. //$project = Dever::project('pay');
  154. //return $project['url'] . 'daemon/notify/'.$type.'.php';
  155. return str_replace('?', '', Dever::url('api.notify?account_id=' . $account_id, 'pay'));
  156. }
  157. # 退款
  158. public function refundByOrder($order_id, $refund_order_id = false, $refund_cash = false)
  159. {
  160. $info = Dever::db('pay/order')->one(array('order_id' => $order_id));
  161. if ($info && ($info['status'] == 1 || $info['status'] == 2 || $info['status'] == 6)) {
  162. if ($info['param']) {
  163. $info['param'] = Dever::array_decode($info['param']);
  164. }
  165. $cash = $refund_cash ? $refund_cash : $info['cash'];
  166. $state = $this->refund($info['order_id'], $cash, $info, $refund_order_id);
  167. if ($state) {
  168. if ($refund_order_id) {
  169. $status = 6;
  170. } else {
  171. $status = 5;
  172. }
  173. Dever::db('pay/order')->update(array('where_id' => $info['id'], 'status' => $status, 'refund_cash' => $cash));
  174. return 'yes';
  175. } else {
  176. return false;
  177. }
  178. }
  179. return false;
  180. }
  181. /**
  182. * 写日志
  183. */
  184. public function log($msg, $data = array())
  185. {
  186. if ($data) {
  187. $data = Dever::json_encode($data);
  188. $msg .= '||' . $data;
  189. /*
  190. $insert = $data;
  191. $insert['cdate'] = time();
  192. Dever::db('pay/order_log')->insert($insert);
  193. */
  194. }
  195. Dever::log($msg, 'pay');
  196. }
  197. }