OrderService.php 8.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257
  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->complete();
  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. $this->activatePlan();
  42. // if (Order::userActivePlan(self::$user->id)->where('id', '<>', self::$order->id)->exists()) {// 判断套餐是否直接激活
  43. // $this->setPrepaidPlan();
  44. // } else {
  45. // $this->activatePlan();
  46. // }
  47. $this->setCommissionExpense(self::$user); // 返利
  48. break;
  49. default:
  50. Log::warning('【处理订单】出现错误-未知套餐类型');
  51. }
  52. return true;
  53. }
  54. // 余额充值
  55. private function chargeCredit(): bool
  56. {
  57. $credit = self::$user->credit;
  58. $ret = self::$user->updateCredit(self::$order->origin_amount);
  59. // 余额变动记录日志
  60. if ($ret) {
  61. Helpers::addUserCreditLog(self::$order->user_id, self::$order->id, $credit, self::$user->credit, self::$order->amount, '用户通过'.self::$order->pay_way.'充值余额');
  62. }
  63. return $ret;
  64. }
  65. // 激活流量包
  66. private function activatePackage(): bool
  67. {
  68. if (self::$user->incrementData(self::$goods->traffic * MB)) {
  69. return Helpers::addUserTrafficModifyLog(
  70. self::$order->user_id,
  71. self::$order->id,
  72. self::$user->transfer_enable - self::$goods->traffic * MB,
  73. self::$user->transfer_enable,
  74. '['.self::$order->pay_way.']加上用户购买的套餐流量'
  75. );
  76. }
  77. return false;
  78. }
  79. // 设置预支付套餐
  80. private function setPrepaidPlan(): bool
  81. {
  82. self::$order->status = 3; // 3为预支付
  83. $oldData = self::$user->transfer_enable;
  84. // 预支付订单, 刷新账号有效时间用于流量重置判断
  85. return self::$order->save()
  86. && self::$user->update(['expired_at' => date('Y-m-d H:i:s', strtotime(self::$user->expired_at.' +'.self::$goods->days.' days'))]);
  87. }
  88. // 激活套餐
  89. private function activatePlan(): bool
  90. {
  91. Order::whereId(self::$order->id)->update(['status'=>2,'expired_at' => date('Y-m-d H:i:s', strtotime('+'.self::$goods->days.' days'))]);
  92. $oldData = self::$user->transfer_enable;
  93. $expired_at = self::$user->expired_at;
  94. //如果用户到期 就用当前时间增加....
  95. if (self::$user->expired_at >= date('Y-m-d H:i:s')){
  96. $expired_at = date('Y-m-d H:i:s', strtotime("$expired_at +".self::$goods->days.' days'));
  97. }
  98. else {
  99. $expired_at = date('Y-m-d H:i:s', strtotime(' +'.self::$goods->days.' days'));
  100. }
  101. Log::info('购买用户'.self::$user->email.'到期时间'.self::$user->expired_at."修改时间".$expired_at);
  102. foreach (Order::userPrepay(self::$order->user_id)->get() as $paidOrder) {//拿出可能存在的其余套餐, 推算最新的到期时间
  103. //取出对应套餐信息
  104. $expired_at = date('Y-m-d H:i:s', strtotime("$expired_at +".$paidOrder->goods->days.' days'));
  105. }
  106. //账号流量重置日期
  107. $nextResetTime = $expired_at;
  108. if ($nextResetTime >= self::$user->expired_at) {
  109. $nextResetTime = null;
  110. }
  111. $countt = self::$goods->traffic * MB;
  112. $updateData = [
  113. 'invite_num' => self::$user->invite_num + (self::$goods->invite_num ?: 0),
  114. 'level' => self::$goods->level,
  115. 'enable' => 1,
  116. 'expired_at' => $expired_at,
  117. 'reset_time' => $nextResetTime,
  118. 'transfer_enable' => $countt,
  119. 'd' => 0,
  120. 'u' => 0
  121. ];
  122. // 无端口用户 添加端口
  123. if (self::$user->port === null || self::$user->port === 0) {
  124. $updateData['port'] = Helpers::getPort();
  125. }
  126. $ret = self::$user->update($updateData);
  127. //$ret = self::$user->update(array_merge($this->resetTimeAndData(), $updateData));
  128. if ($ret) {
  129. return Helpers::addUserTrafficModifyLog(
  130. self::$order->user_id,
  131. self::$order->id,
  132. $oldData,
  133. self::$user->transfer_enable,
  134. '【'.self::$order->pay_way.'】加上用户购买的套餐流量'
  135. );
  136. }
  137. return false;
  138. }
  139. // 计算下次重置与账号过期时间
  140. public function resetTimeAndData($expired_at = null): array
  141. {
  142. $data = ['u' => 0, 'd' => 0];
  143. // 账号有效期
  144. if (! $expired_at) {
  145. $expired_at = date('Y-m-d H:i:s', strtotime('+'.self::$goods->days.' days'));
  146. foreach (Order::userPrepay(self::$order->user_id)->get() as $paidOrder) {//拿出可能存在的其余套餐, 推算最新的到期时间
  147. //取出对应套餐信息
  148. $expired_at = date('Y-m-d H:i:s', strtotime("$expired_at +".$paidOrder->goods->days.' days'));
  149. }
  150. $data['expired_at'] = $expired_at;
  151. }
  152. //账号流量重置日期
  153. $nextResetTime = date('Y-m-d H:i:s', strtotime('+'.self::$goods->period.' days'));
  154. if ($nextResetTime >= $expired_at) {
  155. $nextResetTime = null;
  156. }
  157. return array_merge($data, [
  158. 'transfer_enable' => self::$goods->traffic * MB,
  159. 'reset_time' => $nextResetTime,
  160. ]);
  161. }
  162. // 佣金计算
  163. private function setCommissionExpense(User $user): bool
  164. {
  165. $referralType = sysConfig('referral_type');
  166. if ($referralType && $user->inviter_id) {// 是否需要支付佣金
  167. $inviter = $user->inviter;
  168. // 获取历史返利记录
  169. $referral = ReferralLog::whereInviteeId(self::$order->user_id)->doesntExist();
  170. // 无记录 / 首次返利
  171. if ($referral && sysConfig('is_invite_register')) {
  172. // 邀请注册功能开启时,返还邀请者邀请名额
  173. $inviter->update(['invite_num' => $inviter->invite_num + 1]);
  174. }
  175. // 按照返利模式进行返利判断
  176. if ($referralType == 2 || $referral) {
  177. return $this->addReferralLog(
  178. $user->id,
  179. $inviter->id,
  180. self::$order->id,
  181. self::$order->amount,
  182. self::$order->amount * sysConfig('referral_percent')
  183. );
  184. }
  185. }
  186. return true;
  187. }
  188. /**
  189. * 添加返利日志.
  190. *
  191. * @param int $inviteeId 用户ID
  192. * @param int $inviterId 返利对象ID
  193. * @param int $oid 订单ID
  194. * @param int $amount 发生金额
  195. * @param int $commission 返利金额
  196. *
  197. * @return bool
  198. */
  199. private function addReferralLog(int $inviteeId, int $inviterId, int $oid, int $amount, int $commission): bool
  200. {
  201. $log = new ReferralLog();
  202. $log->invitee_id = $inviteeId;
  203. $log->inviter_id = $inviterId;
  204. $log->order_id = $oid;
  205. $log->amount = $amount;
  206. $log->commission = $commission;
  207. return $log->save();
  208. }
  209. // 激活预支付套餐
  210. public function activatePrepaidPlan(): bool
  211. {
  212. self::$order->update([
  213. 'expired_at' => date('Y-m-d H:i:s', strtotime('+'.self::$goods->days.' days')),
  214. 'status' => 2,
  215. ]);
  216. return $this->activatePlan();
  217. }
  218. }