Core.php 4.0 KB

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