package com.qxueyou.scc.base.service.impl;
|
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Propagation;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import com.qxueyou.scc.base.model.Result;
|
import com.qxueyou.scc.base.service.IONSExceptionLogService;
|
import com.qxueyou.scc.base.util.TraceUtils;
|
import com.qxueyou.scc.sys.model.SysLog;
|
import com.qxueyou.scc.sys.service.ISysLogService;
|
|
/**
|
* ONS严格异常处理，消息处理都捕获Exception，并且不抛出，将异常存入表中
|
* @author ody.yuan
|
*
|
*/
|
@Service(value = "ONSExceptionLogService")
|
public class ONSExceptionLogService implements IONSExceptionLogService {
|
|
@Autowired
|
ISysLogService syslogService;
|
|
@Override
|
@Transactional(propagation=Propagation.REQUIRES_NEW)
|
public Result logSaveExceptionLog(String topic, String msgType,String businessId ,String desp ) {
|
|
// 处理长度
|
String currTopic = null == topic ? "" : topic ;
|
String currDesp = StringUtils.isNotBlank(desp) && desp.length() > 125 ? desp.substring(0,125) : desp ;
|
|
SysLog log = new SysLog();
|
TraceUtils.setCreateTrace(log);
|
|
log.setContent(getContent(currTopic, businessId, msgType));
|
log.setModule("ONS_EXCEPTION_LOG");
|
log.setDesp( currDesp );
|
log.setDeleteFlag(false);
|
log.setType(SysLog.LOG_TYPE_BUSINESS);
|
|
this.syslogService.insertLog(log);
|
|
return new Result(true);
|
|
}
|
|
private String getContent(String currTopic, String businessId ,String msgType){
|
String content = currTopic.concat(" - ");
|
if(StringUtils.isNotBlank(msgType)){
|
content = content.concat(msgType).concat(" - ");
|
}
|
if(StringUtils.isNotBlank(businessId)){
|
content = content.concat(businessId);
|
}
|
return content.length() > 255 ? content.substring(0,255) : content ;
|
}
|
|
}
|
