OrderService.php 7.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219
  1. <?php
  2. namespace App\Services;
  3. use App\Components\Helpers;
  4. use App\Models\Order;
  5. use App\Models\ReferralLog;
  6. use App\Models\User;
  7. use Log;
  8. class OrderService
  9. {
  10. public static $order;
  11. public static $user;
  12. public static $goods;
  13. public static $payment;
  14. public function __construct(Order $order)
  15. {
  16. // 获取需要的信息
  17. self::$order = $order;
  18. self::$user = $order->user;
  19. self::$goods = $order->goods;
  20. self::$payment = $order->payment;
  21. }
  22. // 支付成功后处理
  23. public function receivedPayment(): bool
  24. {
  25. if (self::$payment) {// 是否为余额购买套餐
  26. if (self::$payment->status === 1) {// 已处理
  27. return true;
  28. }
  29. self::$payment->update(['status' => 1]);
  30. // 余额充值
  31. if (self::$order->goods_id === 0 || self::$order->goods_id === null) {
  32. return $this->chargeCredit();
  33. }
  34. }
  35. $goods = self::$order->goods;
  36. switch ($goods->type) {// 商品为流量或者套餐
  37. case 1:// 流量包
  38. $this->activatePackage();
  39. break;
  40. case 2:// 套餐
  41. if (Order::userActivePlan(self::$user->id)->where('id', '<>', self::$order->id)->exists()) {// 判断套餐是否直接激活
  42. $this->setPrepaidPlan();
  43. } else {
  44. $this->activatePlan();
  45. }
  46. $this->setCommissionExpense(self::$user); // 返利
  47. break;
  48. default:
  49. Log::warning('【处理订单】出现错误-未知套餐类型');
  50. }
  51. return true;
  52. }
  53. // 余额充值
  54. private function chargeCredit(): bool
  55. {
  56. $credit = self::$user->credit;
  57. $ret = self::$user->updateCredit(self::$order->origin_amount);
  58. // 余额变动记录日志
  59. if ($ret) {
  60. Helpers::addUserCreditLog(self::$order->user_id, self::$order->id, $credit, self::$user->credit, self::$order->amount, '用户通过'.self::$order->pay_way.'充值余额');
  61. }
  62. return $ret;
  63. }
  64. // 激活流量包
  65. private function activatePackage(): bool
  66. {
  67. if (self::$user->incrementData(self::$goods->traffic * MB)) {
  68. return Helpers::addUserTrafficModifyLog(
  69. self::$order->user_id,
  70. self::$order->id,
  71. self::$user->transfer_enable - self::$goods->traffic * MB,
  72. self::$user->transfer_enable,
  73. '['.self::$order->pay_way.']加上用户购买的套餐流量'
  74. );
  75. }
  76. return false;
  77. }
  78. // 设置预支付套餐
  79. private function setPrepaidPlan(): bool
  80. {
  81. self::$order->status = 3; // 3为预支付
  82. // 预支付订单, 刷新账号有效时间用于流量重置判断
  83. return self::$order->save()
  84. && self::$user->update(['expired_at' => date('Y-m-d', strtotime(self::$user->expired_at.' +'.self::$goods->days.' days'))]);
  85. }
  86. // 激活套餐
  87. private function activatePlan(): bool
  88. {
  89. Order::whereId(self::$order->id)->update(['expired_at' => date('Y-m-d H:i:s', strtotime('+'.self::$goods->days.' days'))]);
  90. $oldData = self::$user->transfer_enable;
  91. $updateData = [
  92. 'invite_num' => self::$user->invite_num + (self::$goods->invite_num ?: 0),
  93. 'level' => self::$goods->level,
  94. 'enable' => 1,
  95. ];
  96. // 无端口用户 添加端口
  97. if (self::$user->port === null || self::$user->port === 0) {
  98. $updateData['port'] = Helpers::getPort();
  99. }
  100. $ret = self::$user->update(array_merge($this->resetTimeAndData(), $updateData));
  101. if ($ret) {
  102. return Helpers::addUserTrafficModifyLog(
  103. self::$order->user_id,
  104. self::$order->id,
  105. $oldData,
  106. self::$user->transfer_enable,
  107. '【'.self::$order->pay_way.'】加上用户购买的套餐流量'
  108. );
  109. }
  110. return false;
  111. }
  112. // 计算下次重置与账号过期时间
  113. public function resetTimeAndData($expired_at = null): array
  114. {
  115. $data = ['u' => 0, 'd' => 0];
  116. // 账号有效期
  117. if (! $expired_at) {
  118. $expired_at = date('Y-m-d', strtotime('+'.self::$goods->days.' days'));
  119. foreach (Order::userPrepay(self::$order->user_id)->get() as $paidOrder) {//拿出可能存在的其余套餐, 推算最新的到期时间
  120. //取出对应套餐信息
  121. $expired_at = date('Y-m-d', strtotime("$expired_at +".$paidOrder->goods->days.' days'));
  122. }
  123. $data['expired_at'] = $expired_at;
  124. }
  125. //账号流量重置日期
  126. $nextResetTime = date('Y-m-d', strtotime('+'.self::$goods->period.' days'));
  127. if ($nextResetTime >= $expired_at) {
  128. $nextResetTime = null;
  129. }
  130. return array_merge($data, [
  131. 'transfer_enable' => self::$goods->traffic * MB,
  132. 'reset_time' => $nextResetTime,
  133. ]);
  134. }
  135. // 佣金计算
  136. private function setCommissionExpense(User $user): bool
  137. {
  138. $referralType = sysConfig('referral_type');
  139. if ($referralType && $user->inviter_id) {// 是否需要支付佣金
  140. $inviter = $user->inviter;
  141. // 获取历史返利记录
  142. $referral = ReferralLog::whereInviteeId(self::$order->user_id)->doesntExist();
  143. // 无记录 / 首次返利
  144. if ($referral && sysConfig('is_invite_register')) {
  145. // 邀请注册功能开启时,返还邀请者邀请名额
  146. $inviter->update(['invite_num' => $inviter->invite_num + 1]);
  147. }
  148. // 按照返利模式进行返利判断
  149. if ($referralType == 2 || $referral) {
  150. return $this->addReferralLog(
  151. $user->id,
  152. $inviter->id,
  153. self::$order->id,
  154. self::$order->amount,
  155. self::$order->amount * sysConfig('referral_percent')
  156. );
  157. }
  158. }
  159. return true;
  160. }
  161. /**
  162. * 添加返利日志.
  163. *
  164. * @param int $inviteeId 用户ID
  165. * @param int $inviterId 返利对象ID
  166. * @param int $oid 订单ID
  167. * @param int $amount 发生金额
  168. * @param int $commission 返利金额
  169. *
  170. * @return bool
  171. */
  172. private function addReferralLog(int $inviteeId, int $inviterId, int $oid, int $amount, int $commission): bool
  173. {
  174. $log = new ReferralLog();
  175. $log->invitee_id = $inviteeId;
  176. $log->inviter_id = $inviterId;
  177. $log->order_id = $oid;
  178. $log->amount = $amount;
  179. $log->commission = $commission;
  180. $log->status = 0;
  181. return $log->save();
  182. }
  183. // 激活预支付套餐
  184. public function activatePrepaidPlan(): bool
  185. {
  186. self::$order->update([
  187. 'expired_at' => date('Y-m-d H:i:s', strtotime('+'.self::$goods->days.' days')),
  188. 'status' => 2,
  189. ]);
  190. return $this->activatePlan();
  191. }
  192. }