@@ 286-288 (lines=3) @@ | ||
283 | count(*) as count |
|
284 | FROM uecode_qpush_message |
|
285 | where queue = "' . $this->name . '"'; |
|
286 | if (isset($data['from']) && $data['from'] !== null) { |
|
287 | $sql = $sql . ' and created >= "' . $data['from'] . '"'; |
|
288 | } |
|
289 | if (isset($data['to']) && $data['to'] !== null) { |
|
290 | $sql = $sql . ' and created <= "' . $data['to'] . '"'; |
|
291 | } |
|
@@ 289-291 (lines=3) @@ | ||
286 | if (isset($data['from']) && $data['from'] !== null) { |
|
287 | $sql = $sql . ' and created >= "' . $data['from'] . '"'; |
|
288 | } |
|
289 | if (isset($data['to']) && $data['to'] !== null) { |
|
290 | $sql = $sql . ' and created <= "' . $data['to'] . '"'; |
|
291 | } |
|
292 | $sql = $sql . ' group by floor(unix_timestamp(created)/' . $period . ')'; |
|
293 | $sql = $sql . ' order by floor(unix_timestamp(created)/' . $period . ') ASC'; |
|
294 | $statement = $this->em->getConnection()->prepare($sql); |