|
|
@@ -54,7 +54,7 @@ class MqDiscussion extends Command
|
|
|
$this->info(" [*] Waiting for {$queue}. To exit press CTRL+C");
|
|
|
Log::info("discussion worker start .");
|
|
|
Mq::worker($exchange,$queue,function ($message){
|
|
|
- Log::info('mq discussion start {message}',['message'=>json_encode($message,JSON_UNESCAPED_UNICODE)]);
|
|
|
+ Log::info('mq discussion receive {message}',['message'=>json_encode($message,JSON_UNESCAPED_UNICODE)]);
|
|
|
$result = 0;
|
|
|
switch ($message->res_type) {
|
|
|
case 'sentence':
|
|
|
@@ -97,7 +97,7 @@ class MqDiscussion extends Command
|
|
|
->where('title',$articleTitle)
|
|
|
->value('content');
|
|
|
if(empty($tpl)){
|
|
|
- Log::error('mq:pr 模版不能为空',['tpl_title'=>$articleTitle]);
|
|
|
+ Log::error('mq:discussion 模版不能为空',['tpl_title'=>$articleTitle]);
|
|
|
return 1;
|
|
|
}
|
|
|
$m = new \Mustache_Engine(array('entity_flags'=>ENT_QUOTES,
|
|
|
@@ -140,10 +140,10 @@ class MqDiscussion extends Command
|
|
|
}
|
|
|
|
|
|
if($ok === 0){
|
|
|
- Log::debug('mq:pr: success {url}',['url'=>$hook->url]);
|
|
|
+ Log::debug('mq:discussion: send success {url}',['url'=>$hook->url]);
|
|
|
WebHook::where('id',$hook->id)->increment('success');
|
|
|
}else{
|
|
|
- Log::error('mq:pr: success {url}',['url'=>$hook->url]);
|
|
|
+ Log::error('mq:discussion: send fail {url}',['url'=>$hook->url]);
|
|
|
WebHook::where('id',$hook->id)->increment('fail');
|
|
|
}
|
|
|
}
|
visuddhinanda