Order.php 5.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146
  1. <?php
  2. // +----------------------------------------------------------------------
  3. // | 萤火商城系统 [ 致力于通过产品和服务,帮助商家高效化开拓市场 ]
  4. // +----------------------------------------------------------------------
  5. // | Copyright (c) 2017~2024 https://www.yiovo.com All rights reserved.
  6. // +----------------------------------------------------------------------
  7. // | Licensed 这不是一个自由软件,不允许对程序代码以任何形式任何目的的再发行
  8. // +----------------------------------------------------------------------
  9. // | Author: 萤火科技 <admin@yiovo.com>
  10. // +----------------------------------------------------------------------
  11. declare (strict_types=1);
  12. namespace app\timer\service;
  13. use app\timer\model\Order as OrderModel;
  14. use app\common\service\BaseService;
  15. use app\common\service\Order as OrderService;
  16. use app\common\service\order\Complete as OrderCompleteService;
  17. use app\common\enum\order\OrderStatus as OrderStatusEnum;
  18. use app\common\library\helper;
  19. use app\timer\library\Tools;
  20. /**
  21. * 服务类:订单模块
  22. * Class Order
  23. * @package app\timer\service
  24. */
  25. class Order extends BaseService
  26. {
  27. /**
  28. * 未支付订单自动关闭
  29. * @param int $storeId
  30. * @param int $closeHours 自定关闭订单有效期 (小时)
  31. * @throws \think\db\exception\DataNotFoundException
  32. * @throws \think\db\exception\DbException
  33. * @throws \think\db\exception\ModelNotFoundException
  34. */
  35. public function closeEvent(int $storeId, int $closeHours)
  36. {
  37. // 截止时间
  38. $deadlineTime = time() - ((int)$closeHours * 60 * 60);
  39. // 查询截止时间未支付的订单
  40. $model = new OrderModel;
  41. $list = $model->getListByClose($storeId, $deadlineTime);
  42. // 订单ID集
  43. $orderIds = helper::getArrayColumn($list, 'order_id');
  44. if (!empty($orderIds)) {
  45. // 取消订单事件
  46. foreach ($list as $order) {
  47. OrderService::cancelEvent($order);
  48. }
  49. // 批量更新订单状态为已取消
  50. $model->onBatchUpdate($orderIds, ['order_status' => OrderStatusEnum::CANCELLED]);
  51. }
  52. // 记录日志
  53. Tools::taskLogs('Order', 'closeEvent', [
  54. 'storeId' => $storeId,
  55. 'closeHours' => $closeHours,
  56. 'deadlineTime' => $deadlineTime,
  57. 'orderIds' => helper::jsonEncode($orderIds)
  58. ]);
  59. }
  60. /**
  61. * 已发货订单自动确认收货
  62. * @param int $storeId
  63. * @param int $receiveDays 自动收货天数
  64. * @throws \think\db\exception\DataNotFoundException
  65. * @throws \think\db\exception\DbException
  66. * @throws \think\db\exception\ModelNotFoundException
  67. */
  68. public function receiveEvent(int $storeId, int $receiveDays)
  69. {
  70. // 截止时间
  71. $deadlineTime = time() - ((int)$receiveDays * 86400);
  72. // 查询截止时间未确认收货的订单ID集
  73. $model = new OrderModel;
  74. $orderIds = $model->getOrderIdsByReceive($storeId, $deadlineTime);
  75. // 更新订单收货状态
  76. if (!empty($orderIds)) {
  77. // 批量更新订单状态为已收货
  78. $model->onUpdateReceived($orderIds);
  79. // 批量处理已完成的订单
  80. $this->onReceiveCompleted($storeId, $orderIds);
  81. }
  82. // 记录日志
  83. Tools::taskLogs('Order', 'receiveEvent', [
  84. 'storeId' => $storeId,
  85. 'receiveDays' => $receiveDays,
  86. 'deadlineTime' => $deadlineTime,
  87. 'orderIds' => helper::jsonEncode($orderIds)
  88. ]);
  89. }
  90. /**
  91. * 已完成订单自动结算
  92. * @param int $storeId
  93. * @param int $refundDays 售后期限天数
  94. * @throws \think\db\exception\DataNotFoundException
  95. * @throws \think\db\exception\DbException
  96. * @throws \think\db\exception\ModelNotFoundException
  97. */
  98. public function settledEvent(int $storeId, int $refundDays)
  99. {
  100. // 截止时间
  101. $deadlineTime = time() - ((int)$refundDays * 86400);
  102. // 查询截止时间确认收货的订单ID集
  103. $model = new OrderModel;
  104. $list = $model->getOrderListBySettled($storeId, $deadlineTime);
  105. // 订单ID集
  106. $orderIds = helper::getArrayColumn($list, 'order_id');
  107. // 订单结算服务
  108. if (!empty($orderIds)) {
  109. $OrderCompleteService = new OrderCompleteService();
  110. $OrderCompleteService->settled($list);
  111. }
  112. // 记录日志
  113. Tools::taskLogs('Order', 'settledEvent', [
  114. 'storeId' => $storeId,
  115. 'refundDays' => $refundDays,
  116. 'deadlineTime' => $deadlineTime,
  117. 'orderIds' => helper::jsonEncode($orderIds)
  118. ]);
  119. }
  120. /**
  121. * 批量处理已完成的订单
  122. * @param int $storeId 商城ID
  123. * @param array $orderIds 订单ID集
  124. * @return void
  125. * @throws \think\db\exception\DataNotFoundException
  126. * @throws \think\db\exception\DbException
  127. * @throws \think\db\exception\ModelNotFoundException
  128. */
  129. private function onReceiveCompleted(int $storeId, array $orderIds): void
  130. {
  131. // 获取已完成的订单列表
  132. $model = new OrderModel;
  133. $list = $model->getListByOrderIds($storeId, $orderIds);
  134. // 执行订单完成后的操作
  135. if (!$list->isEmpty()) {
  136. $OrderCompleteService = new OrderCompleteService();
  137. $OrderCompleteService->complete($list, $storeId);
  138. }
  139. }
  140. }