|
@@ -32,16 +32,20 @@ class LogConsumer implements ConsumerInterface
|
|
|
public function execute(AMQPMessage $msg)
|
|
|
{
|
|
|
$message = '';
|
|
|
+ $level = '';
|
|
|
+ $channel = '';
|
|
|
try {
|
|
|
$msgBody = json_decode($msg->body, true);
|
|
|
- if (!json_last_error() && isset($msgBody['message'])) {
|
|
|
+ if (!json_last_error() && isset($msgBody['message']) && !empty($msgBody['message'])) {
|
|
|
$message = $msgBody['message'];
|
|
|
+ $level = $msgBody['level_name'];
|
|
|
+ $channel = $msgBody['channel'];
|
|
|
}
|
|
|
} catch (\Exception $ex) {
|
|
|
$message = $ex->getMessage();
|
|
|
}
|
|
|
|
|
|
- $log = $this->createLog($message);
|
|
|
+ $log = $this->createLog($message, $level, $channel);
|
|
|
if (is_null($log)) {
|
|
|
var_dump('Error: log no creado');
|
|
|
} else {
|
|
@@ -58,12 +62,14 @@ class LogConsumer implements ConsumerInterface
|
|
|
*
|
|
|
* @return \WorkflowBundle\Services\LogBundle\Entity\Log
|
|
|
*/
|
|
|
- private function createLog($message)
|
|
|
+ private function createLog($message, $level, $channel)
|
|
|
{
|
|
|
$logClass = 'LogBundle\Entity\Log';
|
|
|
if ($message && class_exists($logClass)) {
|
|
|
$log = new $logClass();
|
|
|
$log->setMessage($message);
|
|
|
+ $log->setLevel($level);
|
|
|
+ $log->setChannel($channel);
|
|
|
|
|
|
$em = $this->serviceContainer->get('doctrine.orm.entity_manager');
|
|
|
$validator = $this->serviceContainer->get('validator');
|