Cash.php 6.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214
  1. <?php namespace Pay\Yspay;
  2. use Dever;
  3. class Cash
  4. {
  5. # 入账:待确认
  6. public function add($mid, $amount, $order_num, $source_order_num, $fenzhang = 0)
  7. {
  8. $merchant = Dever::db('pay/yspay_merchant')->one(array('mid' => $mid));
  9. if ($merchant) {
  10. $data = array();
  11. $data['account_id'] = $merchant['account_id'];
  12. $data['merchant_id'] = $merchant['id'];
  13. $data['order_num'] = $order_num;
  14. $data['source_order_num'] = $source_order_num;
  15. $info = Dever::db('pay/yspay_cash')->find($data);
  16. if ($amount && $amount > 0) {
  17. $this->getCash($amount, $merchant, $data, $fenzhang);
  18. }
  19. $data['status'] = 1;
  20. if ($info) {
  21. $data['where_id'] = $id = $info['id'];
  22. Dever::db('pay/yspay_cash')->update($data);
  23. } else {
  24. $id = Dever::db('pay/yspay_cash')->insert($data);
  25. }
  26. return $id;
  27. }
  28. return false;
  29. }
  30. # 修改状态
  31. public function up($id, $status = 2, $amount = false)
  32. {
  33. if ($amount) {
  34. $amount = $amount * 100;
  35. }
  36. if (is_numeric($id)) {
  37. $where['id'] = $id;
  38. } else {
  39. $where['source_order_num'] = $id;
  40. }
  41. $info = Dever::db('pay/yspay_cash')->find($where);
  42. if ($info) {
  43. $merchant = Dever::db('pay/yspay_merchant')->one($info['merchant_id']);
  44. if ($merchant) {
  45. $update = array('status' => $status, 'where_id' => $info['id']);
  46. if ($status == 3) {
  47. # 开始划付
  48. $state = $this->huafu_act($info);
  49. if ($state != 'ok') {
  50. return false;
  51. }
  52. $update['rdate'] = time();
  53. } elseif ($status == 4) {
  54. # 开始提现
  55. $state = $this->tixian_act($info);
  56. if ($state != 'ok') {
  57. return false;
  58. }
  59. $update['tdate'] = time();
  60. } elseif ($status == 2 && $amount && $amount > 0 && $info['ycash'] != $amount) {
  61. # 待入账 可以修改金额
  62. $this->getCash($amount, $merchant, $update);
  63. }
  64. $state = Dever::db('pay/yspay_cash')->update($update);
  65. if ($state) {
  66. if ($status == 3) {
  67. $total = Dever::db('pay/yspay_cash')->getTotal(array('status' => 3, 'merchant_id' => $info['merchant_id']));
  68. if ($total) {
  69. Dever::db('pay/yspay_merchant')->update(array('where_id' => $info['merchant_id'], 'cash' => $total['cash'], 'hf_cash' => $total['hf_cash'], 'fz_cash' => $total['fz_cash']));
  70. }
  71. }
  72. return $state;
  73. }
  74. }
  75. }
  76. return false;
  77. }
  78. private function getCash($amount, $merchant, &$data, $fenzhang = 0)
  79. {
  80. $yspay = Dever::db('pay/yspay')->one(array('account_id' => $merchant['account_id']));
  81. if ($yspay) {
  82. $cash_per = 0;
  83. if ($merchant['type'] == 1 && $yspay['type'] == 2) {
  84. $cash_per = $merchant['cash_per'];
  85. if (!$cash_per) {
  86. if ($yspay && $yspay['cash_per']) {
  87. $cash_per = $yspay['cash_per'];
  88. }
  89. }
  90. if (!$cash_per || $cash_per <= 0) {
  91. $cash_per = 0;
  92. } else {
  93. $cash_per = $cash_per/100;
  94. }
  95. }
  96. $per = $yspay['per']/100;
  97. $cash_jy_per = $yspay['cash_jy_per']/100;
  98. $data['ycash'] = $amount/100;
  99. $data['yl_cash'] = round($data['ycash'] * $per, 2);
  100. $data['pt_cash'] = round($data['ycash'] * $cash_jy_per, 2);
  101. $data['cash'] = round($data['ycash'] - $data['yl_cash'] - $data['pt_cash'], 2);
  102. if ($yspay['cash_type'] == 1) {
  103. $fz_cash = $data['ycash'];
  104. } else {
  105. $fz_cash = $data['cash'];
  106. }
  107. $data['fz_cash'] = round($fz_cash*$cash_per, 2);
  108. if ($fenzhang && $fenzhang > 0) {
  109. $data['fz_cash'] += $fenzhang;
  110. }
  111. $data['hf_cash'] = round($data['cash'] - $data['fz_cash'], 2);
  112. $data['yl_cash'] *= 100;
  113. $data['pt_cash'] *= 100;
  114. $data['cash'] *= 100;
  115. $data['fz_cash'] *= 100;
  116. $data['hf_cash'] *= 100;
  117. }
  118. }
  119. private function huafu_act($info)
  120. {
  121. $merchant = Dever::db('pay/yspay_merchant')->one($info['merchant_id']);
  122. if ($merchant) {
  123. $config = Dever::db('pay/yspay')->one(array('account_id' => $merchant['account_id']));
  124. if ($config) {
  125. return Dever::load('pay/yspay/multi')->act($config, $merchant, $info);
  126. }
  127. }
  128. return false;
  129. }
  130. private function tixian_act($info)
  131. {
  132. $merchant = Dever::db('pay/yspay_merchant')->one($info['merchant_id']);
  133. if ($merchant) {
  134. $config = Dever::db('pay/yspay')->one(array('account_id' => $merchant['account_id']));
  135. if ($config) {
  136. return Dever::load('pay/yspay/account')->act($config, $merchant, $info);
  137. }
  138. }
  139. return false;
  140. }
  141. # 定时获取总额
  142. # 测试数据
  143. public function test_add_api()
  144. {
  145. $info['mid'] = 'test';
  146. $info['merOrderId'] = 'test123';
  147. $info['amount'] = 10000;
  148. $this->add('test123', array(), $info);
  149. return 'ok';
  150. }
  151. # 将测试数据改成待入账
  152. public function test_edit_api()
  153. {
  154. $data = Dever::db('pay/yspay_cash')->select(array('order_num' => 'test123', 'status' => 1));
  155. if ($data) {
  156. foreach ($data as $k => $v) {
  157. $this->up($v['id'], 2);
  158. }
  159. }
  160. return 'ok';
  161. }
  162. # 资金划付
  163. public function huafu_commit_api()
  164. {
  165. $where = array('status' => 2);
  166. $account_id = Dever::input('account_id');
  167. if ($account_id) {
  168. $where['account_id'] = $account_id;
  169. }
  170. $merchant_id = Dever::input('merchant_id');
  171. if ($merchant_id) {
  172. $where['merchant_id'] = $merchant_id;
  173. }
  174. $data = Dever::db('pay/yspay_cash')->select($where);
  175. if ($data) {
  176. foreach ($data as $k => $v) {
  177. $this->up($v['id'], 3);
  178. }
  179. }
  180. return 'ok';
  181. }
  182. # 随机获取平台商户
  183. public function getMid($account_id)
  184. {
  185. $merchant = Dever::db('pay/yspay_merchant')->select(array('type' => 2, 'account_id' => $account_id, 'status' => 1));
  186. if ($merchant) {
  187. $key = array_rand($merchant);
  188. if (isset($merchant[$key])) {
  189. return $merchant[$key]['mid'];
  190. }
  191. }
  192. return false;
  193. }
  194. }