|
@@ 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); |