Commit e5fc1ff4 authored by Liu lu's avatar Liu lu

日志格式化

parent 0d0bde63
...@@ -31,8 +31,14 @@ class AsyncCoroutineAspect extends AbstractAspect ...@@ -31,8 +31,14 @@ class AsyncCoroutineAspect extends AbstractAspect
// 在调用前进行某些处理 // 在调用前进行某些处理
return Coroutine::create(function ()use($proceedingJoinPoint){ return Coroutine::create(function ()use($proceedingJoinPoint){
LogTraceHandler::recordProcess(
'投递到子协程任务,id:'.Coroutine::id()
.' ,类:'.$proceedingJoinPoint->className
.' ,方法:'.$proceedingJoinPoint->methodName
,
true
);
$result = $proceedingJoinPoint->process(); $result = $proceedingJoinPoint->process();
LogTraceHandler::recordProcess('投递到子协程任务,id:'.Coroutine::id());
LogTraceHandler::recordProcess($result,true); LogTraceHandler::recordProcess($result,true);
}); });
......
...@@ -28,9 +28,9 @@ class LogTraceQueue extends RedisQueueBatchHandler ...@@ -28,9 +28,9 @@ class LogTraceQueue extends RedisQueueBatchHandler
$updateArr[$arr['request_id']]['is_completed'] = $arr['is_completed']; $updateArr[$arr['request_id']]['is_completed'] = $arr['is_completed'];
$process_info = isset($updateArr[$arr['request_id']]['process_info'])? $process_info = isset($updateArr[$arr['request_id']]['process_info'])?
$updateArr[$arr['request_id']]['process_info']:''; ($updateArr[$arr['request_id']]['process_info']."\n\n"):'';
$updateArr[$arr['request_id']]['process_info'] = $process_info."\n\n".$arr['process_info']; $updateArr[$arr['request_id']]['process_info'] = $process_info.$arr['process_info'];
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment