第一版

huangsijun

2025-09-22 a78c011de350b188afb03beb2f26a73f35f71986

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
<?php
 
namespace app\job\model\order;
 
use app\common\model\order\Order as OrderModel;
use app\common\model\order\OrderAdvance as OrderAdvanceModel;
use app\common\service\product\factory\ProductFactory;
use app\common\library\helper;
 
/**
 * 订单模型
 */
class Order extends OrderModel
{
    /**
     * 获取订单列表
     */
    public function getCloseList($with)
    {
        return $this->with($with)
            ->where('pay_status', '=', 10)
            ->where('order_status', '=', 10)
            ->where('pay_end_time', '<=', time())
            ->where('pay_end_time', '>', 0)
            ->where('is_delete', '=', 0)
            ->where('order_source', '<>', 70)
            ->select();
    }
 
 
    /**
     * 获取订单列表
     */
    public function getReceiveList($orderIds, $with = [])
    {
        return $this->with($with)
            ->where('order_id', 'in', $orderIds)
            ->select();
    }
 
    /**
     * 获取订单列表
     */
    public function getSettledList($deadlineTime, $with = [], $app_id)
    {
        return $this->with($with)
            ->where('order_status', '=', 30)
            ->where('receipt_time', '<=', $deadlineTime)
            ->where('is_settled', '=', 0)
            ->where('app_id', '=', $app_id)
            ->select();
    }
 
    /**
     * 获取订单列表
     */
    public function getAdvanceCloseList($with = [])
    {
        return $this->with($with)
            ->where('pay_status', '=', 10)
            ->where('order_status', '=', 10)
            ->where('pay_end_time', '<=', time())
            ->where('pay_end_time', '>', 0)
            ->where('is_delete', '=', 0)
            ->where('order_source', '=', 70)
            ->select();
    }
 
    /**
     * 未支付订单自动关闭
     */
    public function close()
    {
        // 查询截止时间未支付的订单
        $list = $this->getAdvanceCloseList();
        $closeOrderIds = helper::getArrayColumn($list, 'order_id');
        // 取消订单事件
        $this->startTrans();
        try {
            if (!empty($closeOrderIds)) {
                $advanceList = OrderAdvanceModel::where('order_id', 'in', $closeOrderIds)
                    ->where('order_status', '=', 10)
                    ->select();
                $closeOrderAdvanceIds = helper::getArrayColumn($advanceList, 'order_advance_id');
                foreach ($list as &$order) {
                    // 回退商品库存
                    ProductFactory::getFactory($order['order_source'])->backProductStock($order['product'], true);
                }
                // 批量更新订单状态为已取消
                (new OrderModel)->onBatchUpdate($closeOrderIds, ['order_status' => 20]);
                (new OrderAdvanceModel)->where('order_advance_id', 'in', $closeOrderAdvanceIds)->update(['order_status' => 20]);
            }
            $this->commit();
            return $closeOrderIds;
        } catch (\Exception $e) {
            $this->error = $e->getMessage();
            $this->rollback();
        }
    }
 
}