trackHelper

segment2.0
beeajax 2 years ago
parent ac90480001
commit 9eac5df983

@ -43,10 +43,20 @@ public class VisitorProcessor extends AbstractProcessor {
return null; return null;
} }
@Override
public Object doProcess(TrackContext context) {
if (context.isError()) {
log.debug("=== AOP 异常通知 ===");
return afterThrowingProcess(context);
} else {
log.debug("=== AOP 后置通知 ===");
return afterReturnProcess(context);
}
}
/** /**
* *
*/ */
@Override
public Object afterReturnProcess(TrackContext context) { public Object afterReturnProcess(TrackContext context) {
Map<String, Object> params = context.getParams(); Map<String, Object> params = context.getParams();
Long taskId = (Long) params.get("taskId"); Long taskId = (Long) params.get("taskId");
@ -60,7 +70,6 @@ public class VisitorProcessor extends AbstractProcessor {
/** /**
* *
*/ */
@Override
public Object afterThrowingProcess(TrackContext context) { public Object afterThrowingProcess(TrackContext context) {
log.error(context.getExMessageResult()); log.error(context.getExMessageResult());
Map<String, Object> params = context.getParams(); Map<String, Object> params = context.getParams();

@ -2,6 +2,11 @@ package com.docus.server.ws.convert;
public interface IConverter<T> { public interface IConverter<T> {
/**
* @param message
* @param methodName
* @return T
*/
T convert(String message, String methodName); T convert(String message, String methodName);
} }

@ -20,7 +20,7 @@ public class TaskOriginalMessageServiceImpl extends ServiceImpl<TaskOriginalMess
private TaskOriginalMessageConverter converter; private TaskOriginalMessageConverter converter;
/** /**
* ws xml dept * ws xml
*/ */
@Transactional(rollbackFor = Exception.class) @Transactional(rollbackFor = Exception.class)
@Override @Override

@ -37,6 +37,8 @@ public abstract class AbstractProcessor implements ITrackProcessor {
return null; return null;
} }
protected abstract Object doProcess(TrackContext context);
/** /**
* *
*/ */
@ -46,25 +48,4 @@ public abstract class AbstractProcessor implements ITrackProcessor {
return null; return null;
} }
public Object doProcess(TrackContext context) {
if (context.isError()) {
logger.debug("=== AOP 异常通知 ===");
return afterThrowingProcess(context);
} else {
logger.debug("=== AOP 后置通知 ===");
return afterReturnProcess(context);
}
}
/**
*
*/
protected abstract Object afterReturnProcess(TrackContext context);
/**
*
*/
protected abstract Object afterThrowingProcess(TrackContext context);
} }

Loading…
Cancel
Save