Core.php 4.3 KB

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