package com.java110.log.smo.impl;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.java110.common.exception.GenerateCodeException;
|
import com.java110.common.log.LoggerEngine;
|
import com.java110.common.util.Assert;
|
import com.java110.common.util.DateUtil;
|
import com.java110.core.base.smo.BaseServiceSMO;
|
import com.java110.core.factory.GenerateCodeFactory;
|
import com.java110.log.dao.LogServiceDao;
|
import com.java110.log.smo.ILogServiceSMO;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import java.rmi.NoSuchObjectException;
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
/**
|
* 日志 消息处理类
|
* Created by wuxw on 2017/4/11.
|
*/
|
@Service("logServiceSMOImpl")
|
@Transactional
|
public class LogServiceSMOImpl extends BaseServiceSMO implements ILogServiceSMO {
|
|
private final static Logger logger = LoggerFactory.getLogger(LogServiceSMOImpl.class);
|
|
@Autowired
|
private LogServiceDao logServiceDaoImpl;
|
|
/**
|
* 保存日志信息
|
* @param logMessage 需要保存的日志信息
|
*/
|
@Override
|
public void saveLogMessage(String logMessage) {
|
logger.debug("received log message : {}" ,logMessage);
|
|
try{
|
doSaveLogMessage(logMessage);
|
}catch (Exception e){
|
logger.error("save log message error :",e);
|
}
|
}
|
|
|
/**
|
*
|
* @param logMessage 需要保存的日志信息
|
*/
|
private void doSaveLogMessage(String logMessage) throws Exception {
|
|
JSONObject logMessageObj = JSONObject.parseObject(logMessage);
|
//校验
|
validateLogMessage(logMessageObj);
|
|
// 调用服务生成log_id
|
String log_id = GenerateCodeFactory.getInnerTransactionId();
|
|
// 封装日志保存参数
|
Map logMessageParams= new HashMap();
|
logMessageParams.put("logId",log_id);
|
builderLogMessageParams(logMessageParams,logMessageObj);
|
|
//保存日志
|
logServiceDaoImpl.saveTransactionLog(logMessageParams);
|
//保存日志（交互报文）
|
logServiceDaoImpl.saveTransactionLogMessage(logMessageParams);
|
|
}
|
|
/**
|
* 封装日志保存参数
|
* @param logMessageParams 日志保存参数
|
*/
|
private void builderLogMessageParams(Map logMessageParams,JSONObject logMessageObj) throws Exception{
|
|
logMessageParams.putAll(logMessageObj);
|
//#{requestHeader},#{responseHeader},#{requestMessage},#{responseMessage},#{remark}
|
String requestMessage = logMessageObj.getString("requestMessage");
|
String responseMessage = logMessageObj.getString("responseMessage");
|
|
JSONObject requestMessageObj = JSONObject.parseObject(requestMessage);
|
JSONObject responseMessageObj = JSONObject.parseObject(responseMessage);
|
|
logMessageParams.put("requestHeader",requestMessageObj.getString("headers"));
|
logMessageParams.put("requestMessage",requestMessageObj.getString("body"));
|
logMessageParams.put("responseHeader",responseMessageObj.getString("headers"));
|
logMessageParams.put("responseMessage",responseMessageObj.getString("body"));
|
|
logMessageParams.put("timestamp", DateUtil.getDefaultDateFromString(logMessageObj.getString("timestamp")));
|
}
|
|
/**
|
* 校验 日志报文 必填节点是否存在
|
* @param logMessageObj JSON 化的日志信息
|
*/
|
private void validateLogMessage(JSONObject logMessageObj){
|
|
Assert.hasKeyAndValue(logMessageObj,"transactionId","can not find transactionId node or transactionId is null");
|
|
Assert.hasKeyAndValue(logMessageObj,"dataFlowId","can not find dataFlowId node or dataFlowId is null");
|
|
Assert.hasKeyAndValue(logMessageObj,"ip","can not find ip node or ip is null");
|
|
Assert.hasKeyAndValue(logMessageObj,"port","can not find port node or port is null");
|
|
Assert.hasKeyAndValue(logMessageObj,"appId","can not find appId node or appId is null");
|
|
Assert.hasKeyAndValue(logMessageObj,"timestamp","can not find timestamp node or timestamp is null");
|
|
Assert.hasKeyAndValue(logMessageObj,"logStatus","can not find logStatus node or logStatus is null");
|
|
Assert.hasKey(logMessageObj,"requestMessage","can not find requestMessage node ");
|
|
Assert.hasKey(logMessageObj,"responseMessage","can not find responseMessage node ");
|
}
|
|
|
public LogServiceDao getLogServiceDaoImpl() {
|
return logServiceDaoImpl;
|
}
|
|
public void setLogServiceDaoImpl(LogServiceDao logServiceDaoImpl) {
|
this.logServiceDaoImpl = logServiceDaoImpl;
|
}
|
}
|
