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
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
|
<?php
namespace AutomateWoo\Jobs;
use AutomateWoo\Customer_Factory;
use AutomateWoo\Jobs\Traits\ValidateItemAsIntegerId;
use Exception;
/**
* Goes through every guest order and creates a customer for it.
*
* @since 5.2.0
*/
class SetupGuestCustomers extends AbstractRecurringBatchedActionSchedulerJob {
use ValidateItemAsIntegerId;
/**
* Setup guest customer complete option name
*
* @var string
*/
protected $complete_option = '_automatewoo_setup_guest_customers_complete';
/**
* Get the name of the job.
*
* @return string
*/
public function get_name() {
return 'setup_guest_customers';
}
/**
* Return the recurring job's interval in seconds.
*
* @since 6.0.0
* @return int The interval for the action in seconds
*/
public function get_interval() {
return JobService::FOUR_HOURS_INTERVAL;
}
/**
* Process a single item.
*
* @param int $order_id
* @param array $args The args for this instance of the job. Args are already validated.
*
* @throws JobException If item can't be found.
*/
protected function process_item( $order_id, array $args ) {
$order = wc_get_order( $order_id );
if ( ! $order ) {
throw JobException::item_not_found();
}
$customer = Customer_Factory::get_by_order( $order );
if ( ! $customer ) {
throw JobException::item_not_found();
}
if ( ! $customer->get_date_last_purchased() ) {
// set the last purchase date
$orders = wc_get_orders(
[
'type' => 'shop_order',
'status' => wc_get_is_paid_statuses(),
'limit' => 1,
'customer' => $customer->get_email(),
'orderby' => 'date',
'order' => 'DESC',
]
);
if ( $orders ) {
$customer->set_date_last_purchased( $orders[0]->get_date_created() );
$customer->save();
}
}
}
/**
* Get a new batch of items.
*
* @param int $batch_number The batch number increments for each new batch in the job cycle.
* @param array $args The args for this instance of the job. Args are already validated.
*
* @return int[]
* @throws Exception If an error occurs. The exception will be logged by ActionScheduler.
*/
protected function get_batch( int $batch_number, array $args ) {
if ( get_option( $this->complete_option ) ) {
return [];
}
// guest orders
return wc_get_orders(
[
'type' => 'shop_order',
'limit' => $this->get_batch_size(),
'offset' => $this->get_query_offset( $batch_number ),
'status' => wc_get_is_paid_statuses(),
'customer_id' => 0,
'return' => 'ids',
// order by ascending ID since new orders could be created while the job is running which would throw the offset off
'orderby' => 'ID',
'order' => 'ASC',
// exlude anonymized orders ( see https://github.com/woocommerce/automatewoo/issues/1643 )
'anonymized' => false,
]
);
}
/**
* Can the job start.
*
* @return bool Returns true if the job can start.
*
* @throws Exception If an error occurs. The exception will be logged by ActionScheduler.
*/
protected function can_start(): bool {
if ( get_option( $this->complete_option ) ) {
return false;
}
return parent::can_start();
}
/**
* Called when the job is completed.
*
* @param int $final_batch_number The final batch number when the job was completed.
* If equal to 1 then no items were processed by the job.
* @param array $args The args for this instance of the job.
*/
protected function handle_complete( int $final_batch_number, array $args ) {
update_option( $this->complete_option, true, false );
}
}
|