@@ -174,24 +174,17 @@ class Msg
public function cron()
{
Dever::import('queue');
- $state = true;
- //如果是异步发送,每发送10次,休息3秒
- $time = 3;
+ $state = true;//同步发送
+ $total = 100;
$num = 0;
- $sync = true;//同步发送
- while ($state == true) {
+ while($num < $total) {
$data = Dever::pop();
if ($data) {
$num++;
$state = true;
$this->sendOne($data['key'], $data['project_id'], $data['touser'], $data['page'], $data['data'], $data['form_id'], $data['emphasis_keyword'], $state);
-
- if ($sync == false && $num == 10) {
- $num = 0;
- sleep($time);
- }
} else {
- $state = false;
+ $num = $total+1;
}
return 'ok';