PayOperService.php 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535
  1. <?php
  2. namespace app\common\Service\Pay;
  3. use think\Db;
  4. use think\Exception;
  5. use app\common\model\User;
  6. use app\common\exception\BusinessException;
  7. use app\common\Enum\OrderEnum;
  8. use app\common\Service\OrderService;
  9. use addons\epay\library\Service;
  10. use Yansongda\Pay\Exceptions\GatewayException;
  11. use app\common\Service\Order\OrderGoodsService;
  12. use app\common\model\OrderAction;
  13. /**
  14. * 支付服务类
  15. * 封装订单创建相关逻辑
  16. */
  17. class PayOperService
  18. {
  19. /**
  20. * @ 支付
  21. * @param string $orderid
  22. * @param int $user_id
  23. * @param string $paytype
  24. * @param string $method
  25. * @param string $openid
  26. * @param string $notifyurl
  27. * @param string $returnurl
  28. * @return \addons\epay\library\Collection|\addons\epay\library\RedirectResponse|\addons\epay\library\Response|null
  29. * @throws \Exception
  30. */
  31. public static function pay($orderSn = "", $userId = 0, $paytype="", $method = '', $openid = '', $notifyurl = null, $returnurl = null)
  32. {
  33. $request = \think\Request::instance();
  34. $order = OrderService::getDetailByOrderSn($orderSn);
  35. if (!$order) {
  36. throw new BusinessException('订单不存在!');
  37. }
  38. if (!$order->canPayHandle()) {
  39. throw new BusinessException('该订单无法支付!');
  40. }
  41. //支付金额为0,无需支付
  42. if ($order->amount == 0) {
  43. // 走orderService 更新订单状态方法 穿订单状态 已支付 和支付时间
  44. $Order = OrderService::updateOrderStatus($order->id, $userId, OrderEnum::STATUS_PAY);
  45. if ($Order) {
  46. return $Order;
  47. }
  48. }
  49. $order_sn = $order->order_sn;
  50. $order->allowField(true)->save(['pay_type' => $paytype, 'open_id' => $openid]);
  51. $response = null;
  52. $epay = get_addon_info('epay');
  53. if ($epay && $epay['state']) {
  54. $notifyurl = $notifyurl ? $notifyurl : $request->root(true) . '/api/pay/notify/type/notify/paytype/' . $paytype;
  55. $returnurl = $returnurl ? $returnurl : $request->root(true) . '/api/pay/notify/type/return/paytype/' . $paytype . '/order_sn/' . $order_sn;
  56. //保证取出的金额一致,不一致将导致订单重复错误
  57. $amount = sprintf("%.2f", $order->amount);
  58. $params = [
  59. 'amount' => $amount,
  60. 'orderid' => $order_sn,
  61. 'type' => $paytype,
  62. 'title' => "支付{$amount}元",
  63. 'notifyurl' => $notifyurl,
  64. 'returnurl' => $returnurl,
  65. 'method' => $method,
  66. 'openid' => $openid
  67. ];
  68. try {
  69. $response = Service::submitOrder($params);
  70. } catch (GatewayException $e) {
  71. throw new \Exception(config('app_debug') ? $e->getMessage() : "支付失败,请稍后重试");
  72. }
  73. } else {
  74. throw new \Exception("请在后台安装配置微信支付宝整合插件");
  75. }
  76. return $response;
  77. }
  78. /**
  79. *
  80. * @ 订单结算
  81. * @param string $order_sn 订单号
  82. * @param float $payamount 支付金额
  83. * @param string $transactionid 流水号
  84. * @return bool
  85. */
  86. public static function settle($orderSn, $payamount, $transactionid = '')
  87. {
  88. $order = OrderService::getDetailByOrderSn($orderSn);
  89. if (!$order->canPayHandle()) {
  90. return false;
  91. }
  92. if ($payamount != $order->amount) {
  93. \think\Log::write("支付失败,订单支付金额不一致[{$orderSn}][{$payamount}][{$order->amount}]");
  94. return false;
  95. }
  96. // 启动事务
  97. Db::startTrans();
  98. try {
  99. $order->status = OrderEnum::STATUS_PAY;
  100. // $order->transaction_id = $transactionid;
  101. $order->pay_amount = $payamount;
  102. $order->pay_time = time();
  103. $order->save();
  104. if ($order->pay_amount == $order->amount) {
  105. //支付完成后,商品销量+1
  106. OrderGoodsService::setGoodsSalesInc($orderSn);
  107. }
  108. // 提交事务
  109. Db::commit();
  110. } catch (\Exception $e) {
  111. // 回滚事务
  112. Db::rollback();
  113. return false;
  114. }
  115. //记录操作
  116. OrderAction::push($orderSn, '系统', '订单支付成功');
  117. return true;
  118. }
  119. protected $user = null;
  120. /**
  121. * 实例化
  122. *
  123. * @param mixed $user
  124. */
  125. public function __construct($user = null)
  126. {
  127. // 优先使用传入的用户
  128. $this->user = $user ? (is_numeric($user) ? User::get($user) : $user) : auth_user();
  129. }
  130. /**
  131. * 微信预付款
  132. *
  133. * @param think\Model $order
  134. * @param float $money
  135. * @param string $order_type
  136. * @return think\Model
  137. */
  138. public function wechat($order, $money, $order_type = 'order')
  139. {
  140. $pay = $this->addPay($order, [
  141. 'order_type' => $order_type,
  142. 'pay_type' => 'wechat',
  143. 'pay_fee' => $money,
  144. 'real_fee' => $money,
  145. 'transaction_id' => null,
  146. 'payment_json' => [],
  147. 'status' => PayModel::PAY_STATUS_UNPAID
  148. ]);
  149. return $pay;
  150. }
  151. /**
  152. * 支付宝预付款
  153. *
  154. * @param think\Model $order
  155. * @param float $money
  156. * @param string $order_type
  157. * @return think\Model
  158. */
  159. public function alipay($order, $money, $order_type = 'order')
  160. {
  161. $pay = $this->addPay($order, [
  162. 'order_type' => $order_type,
  163. 'pay_type' => 'alipay',
  164. 'pay_fee' => $money,
  165. 'real_fee' => $money,
  166. 'transaction_id' => null,
  167. 'payment_json' => [],
  168. 'status' => PayModel::PAY_STATUS_UNPAID
  169. ]);
  170. return $pay;
  171. }
  172. /**
  173. * 余额付款
  174. *
  175. * @param think\Model $order
  176. * @param float $money
  177. * @param string $order_type
  178. * @return think\Model
  179. */
  180. public function money($order, $money, $order_type = 'order')
  181. {
  182. // 余额支付金额,传入金额和剩余支付金额最大值
  183. $money = $order->remain_pay_fee > $money ? $money : $order->remain_pay_fee; // 混合支付不能超过订单应支付总金额
  184. // 扣除用户余额
  185. WalletService::change($this->user, 'money', -$money, 'order_pay', [
  186. 'order_id' => $order->id,
  187. 'order_sn' => $order->order_sn,
  188. 'order_type' => $order_type,
  189. ]);
  190. // 添加支付记录
  191. $pay = $this->addPay($order, [
  192. 'order_type' => $order_type,
  193. 'pay_type' => 'money',
  194. 'pay_fee' => $money,
  195. 'real_fee' => $money,
  196. 'transaction_id' => null,
  197. 'payment_json' => [],
  198. 'status' => PayModel::PAY_STATUS_PAID
  199. ]);
  200. // 余额直接支付成功,更新订单剩余应付款金额,并检测订单状态
  201. return $this->checkAndPaid($order, $order_type);
  202. }
  203. /**
  204. * 积分支付
  205. *
  206. * @param think\Model $order
  207. * @param float $money
  208. * @param string $order_type
  209. * @return think\Model
  210. */
  211. public function score($order, $score, $order_type = 'order')
  212. {
  213. if ($order_type == 'order') {
  214. if ($order['type'] == 'score') {
  215. $log_type = 'score_shop_pay';
  216. $real_fee = $score; // 积分商城真实抵扣,就是积分
  217. } else {
  218. $log_type = 'order_pay';
  219. // $real_fee = ; // 积分商城真实抵扣,就是积分
  220. error_stop('缺少积分抵扣金额'); // 支持积分抵扣时补全
  221. }
  222. }
  223. WalletService::change($this->user, 'score', -$score, $log_type, [
  224. 'order_id' => $order->id,
  225. 'order_sn' => $order->order_sn,
  226. 'order_type' => $order_type,
  227. ]);
  228. // 添加支付记录
  229. $pay = $this->addPay($order, [
  230. 'order_type' => $order_type,
  231. 'pay_type' => 'score',
  232. 'pay_fee' => $score,
  233. 'real_fee' => $real_fee,
  234. 'transaction_id' => null,
  235. 'payment_json' => [],
  236. 'status' => PayModel::PAY_STATUS_PAID
  237. ]);
  238. // 积分直接支付成功,更新订单剩余应付款金额,并检测订单状态
  239. return $this->checkAndPaid($order, $order_type);
  240. }
  241. /**
  242. * 线下支付(货到付款)
  243. *
  244. * @param think\Model $order
  245. * @param float $money
  246. * @param string $order_type
  247. * @return think\Model
  248. */
  249. public function offline($order, $money, $order_type = 'order')
  250. {
  251. // 添加支付记录
  252. $pay = $this->addPay($order, [
  253. 'order_type' => $order_type,
  254. 'pay_type' => 'offline',
  255. 'pay_fee' => $money,
  256. 'real_fee' => $money,
  257. 'transaction_id' => null,
  258. 'payment_json' => [],
  259. 'status' => PayModel::PAY_STATUS_PAID
  260. ]);
  261. // 更新订单剩余应付款金额,并检测订单状态
  262. return $this->checkAndPaid($order, $order_type, 'offline');
  263. }
  264. /**
  265. * 微信支付宝支付回调通用方法
  266. *
  267. * @param \think\Model $pay
  268. * @param array $notify
  269. * @return void
  270. */
  271. public function notify($pay, $notify)
  272. {
  273. $pay->status = PayModel::PAY_STATUS_PAID;
  274. $pay->transaction_id = $notify['transaction_id'];
  275. $pay->buyer_info = $notify['buyer_info'];
  276. $pay->payment_json = $notify['payment_json'];
  277. $pay->paid_time = time();
  278. $pay->save();
  279. $orderModel = $this->getOrderModel($pay->order_type);
  280. $order = new $orderModel();
  281. $order = $order->where('id', $pay->order_id)->find();
  282. if (!$order) {
  283. // 订单未找到,非正常情况,这里记录日志
  284. Log::write('pay-notify-error:order notfound;pay:' . json_encode($pay) . ';notify:' . json_encode($notify));
  285. return false;
  286. }
  287. if ($order->status == $order::STATUS_UNPAID) { // 未支付,检测支付状态
  288. $order = $this->checkAndPaid($order, $pay->order_type);
  289. }
  290. return $order;
  291. }
  292. /**
  293. * 更新订单剩余应支付金额,并且检测订单状态
  294. *
  295. * @param think\Model $order
  296. * @param string $order_type
  297. * @return think\Model
  298. */
  299. public function checkAndPaid($order, $order_type, $pay_mode = 'online')
  300. {
  301. // 获取订单已支付金额
  302. $payed_fee = $this->getPayedFee($order, $order_type);
  303. $remain_pay_fee = bcsub($order->pay_fee, (string)$payed_fee, 2);
  304. $order->remain_pay_fee = $remain_pay_fee;
  305. if ($remain_pay_fee <= 0) {
  306. $order->remain_pay_fee = 0;
  307. $order->paid_time = time();
  308. $order->status = $order::STATUS_PAID;
  309. } else {
  310. if ($pay_mode == 'offline') {
  311. // 订单未支付成功,并且是线下支付(货到付款),将订单状态改为 pending
  312. $order->status = $order::STATUS_PENDING;
  313. $order->ext = array_merge($order->ext, ['pending_time' => time()]); // 货到付款下单时间
  314. $order->pay_mode = 'offline';
  315. }
  316. }
  317. $order->save();
  318. if ($order->status == $order::STATUS_PAID) {
  319. // 订单支付完成
  320. $user = User::where('id', $order->user_id)->find();
  321. if ($order_type == 'order') {
  322. if ($pay_mode == 'offline') {
  323. Action::add($order, null, auth_admin(), 'admin', '管理员操作自动货到付款支付成功');
  324. // 在控制器执行后续内容,这里不再处理
  325. return $order;
  326. } else {
  327. Action::add($order, null, $user, 'user', '用户支付成功');
  328. // 支付成功后续使用异步队列处理
  329. \think\Queue::push('\addons\shopro\job\OrderPaid@paid', ['order' => $order, 'user' => $user], 'shopro-high');
  330. }
  331. } else if ($order_type == 'trade_order') {
  332. // 支付成功后续使用异步队列处理
  333. \think\Queue::push('\addons\shopro\job\trade\OrderPaid@paid', ['order' => $order, 'user' => $user], 'shopro-high');
  334. }
  335. } else if ($order->status == $order::STATUS_PENDING) {
  336. // 货到付款,添加货到付款队列(后续也需要处理拼团, 减库存等等)
  337. $user = User::where('id', $order->user_id)->find();
  338. if ($order_type == 'order') {
  339. Action::add($order, null, $user, 'user', '用户货到付款下单成功');
  340. // 支付成功后续使用异步队列处理
  341. \think\Queue::push('\addons\shopro\job\OrderPaid@offline', ['order' => $order, 'user' => $user], 'shopro-high');
  342. }
  343. }
  344. return $order;
  345. }
  346. /**
  347. * 获取订单已支付金额,商城订单 计算 积分抵扣金额
  348. *
  349. * @param \think\Model $order
  350. * @param string $order_type
  351. * @return string
  352. */
  353. public function getPayedFee($order, $order_type)
  354. {
  355. // 锁定读取所有已支付的记录,判断已支付金额
  356. $pays = PayModel::{'type' . Str::studly($order_type)}()->paid()->where('order_id', $order->id)->lock(true)->select();
  357. // 商城或者积分商城订单
  358. $payed_fee = '0';
  359. foreach ($pays as $key => $pay) {
  360. if ($pay->pay_type == 'score') {
  361. if ($order_type == 'order' && $order['type'] == 'goods') {
  362. // 商城类型订单,并且不是积分商城订单,加上积分抵扣真实金额
  363. $payed_fee = bcadd($payed_fee, $pay->real_fee, 2);
  364. } else {
  365. // 其他类型,需要计算积分抵扣的金额时
  366. }
  367. } else {
  368. $payed_fee = bcadd($payed_fee, $pay->real_fee, 2);
  369. }
  370. }
  371. return $payed_fee;
  372. }
  373. /**
  374. * 获取剩余可退款的pays 记录(不含积分抵扣)
  375. *
  376. * @param integer $order_id
  377. * @param string $sort 排序:money=优先退回余额支付的钱
  378. * @return \think\Collection
  379. */
  380. public function getCanRefundPays($order_id, $sort = 'money')
  381. {
  382. // 商城订单,已支付的 pay 记录, 这里只查 钱的支付记录,不查积分
  383. $pays = PayModel::typeOrder()->paid()->isMoney()->where('order_id', $order_id)->lock(true)->order('id', 'asc')->select();
  384. $pays = collection($pays);
  385. if ($sort == 'money') {
  386. // 对 pays 进行排序,优先退 money 的钱
  387. $pays = $pays->sort(function ($a, $b) {
  388. if ($a['pay_type'] == 'money' && $b['pay_type'] == 'money') {
  389. return 0;
  390. } else if ($a['pay_type'] == 'money' && $b['pay_type'] != 'money') {
  391. return -1;
  392. } else if ($a['pay_type'] != 'money' && $b['pay_type'] == 'money') {
  393. return 1;
  394. } else {
  395. return 0;
  396. }
  397. });
  398. $pays = $pays->values();
  399. }
  400. return $pays;
  401. }
  402. /**
  403. * 获取剩余可退款金额,不含积分相关支付
  404. *
  405. * @param mixed $pays
  406. * @return string
  407. */
  408. public function getRemainRefundMoney($pays)
  409. {
  410. // 拿到 所有可退款的支付记录
  411. $pays = ($pays instanceof \think\Collection) ? $pays : $this->getCanRefundPays($pays);
  412. // 支付金额,除了已经退完款的金额 (这里不退积分)
  413. $payed_money = (string)array_sum($pays->column('pay_fee'));
  414. // 已经退款金额 (这里不退积分)
  415. $refunded_money = (string)array_sum($pays->column('refund_fee'));
  416. // 当前剩余的最大可退款金额,支付金额 - 已退款金额
  417. $remain_max_refund_money = bcsub($payed_money, $refunded_money, 2);
  418. return $remain_max_refund_money;
  419. }
  420. /**
  421. * 添加 pay 记录
  422. *
  423. * @param think\Model $order
  424. * @param array $params
  425. * @return think\Model
  426. */
  427. public function addPay($order, $params)
  428. {
  429. $payModel = new PayModel();
  430. $payModel->order_type = $params['order_type'];
  431. $payModel->order_id = $order->id;
  432. $payModel->pay_sn = get_sn($this->user->id, 'P');
  433. $payModel->user_id = $this->user->id;
  434. $payModel->pay_type = $params['pay_type'];
  435. $payModel->pay_fee = $params['pay_fee'];
  436. $payModel->real_fee = $params['real_fee'];
  437. $payModel->transaction_id = $params['transaction_id'];
  438. $payModel->payment_json = $params['payment_json'];
  439. $payModel->paid_time = $params['status'] == PayModel::PAY_STATUS_PAID ? time() : null;
  440. $payModel->status = $params['status'];
  441. $payModel->refund_fee = 0;
  442. $payModel->save();
  443. return $payModel;
  444. }
  445. public function getOrderModel($order_type)
  446. {
  447. switch ($order_type) {
  448. case 'trade_order':
  449. $orderModel = '';
  450. break;
  451. case 'order':
  452. $orderModel = '\\app\\common\\model\\order';
  453. break;
  454. default:
  455. $orderModel = '\\app\\common\\model\\order';
  456. break;
  457. }
  458. return $orderModel;
  459. }
  460. }