diff options
author | 2017-08-08 14:02:53 +0800 | |
---|---|---|
committer | 2017-08-08 14:02:53 +0800 | |
commit | c0604184b2aa8cff924ca783ec6b36f1f5988775 (patch) | |
tree | 1c70ffe1ad90c915b3382a37eb2fa80901519c7b /logging-sdk/src/main/java/org/openo/log/impl | |
parent | 706fc9fed496972968fde136c3e4e10f9578a5b3 (diff) |
init code
Change-Id: Icd0948118397b256da70dfbcbbec5520dc5eafd4
Signed-off-by: Zhaoxing <meng.zhaoxing1@zte.com.cn>
Diffstat (limited to 'logging-sdk/src/main/java/org/openo/log/impl')
4 files changed, 0 insertions, 506 deletions
diff --git a/logging-sdk/src/main/java/org/openo/log/impl/Facitility.java b/logging-sdk/src/main/java/org/openo/log/impl/Facitility.java deleted file mode 100644 index 82445bb..0000000 --- a/logging-sdk/src/main/java/org/openo/log/impl/Facitility.java +++ /dev/null @@ -1,137 +0,0 @@ -/** - * Copyright 2017 ZTE Corporation. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.openo.log.impl; - -import java.io.IOException; -import java.io.StringWriter; -import java.io.Writer; -import java.text.SimpleDateFormat; -import java.util.Date; -import java.util.HashMap; -import java.util.Iterator; -import java.util.Map; -import java.util.Map.Entry; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import com.fasterxml.jackson.databind.ObjectMapper; - -public class Facitility { - private static final Logger LOGGER = LoggerFactory.getLogger(Facitility.class.getName()); - - private Facitility() { - - } - - public static String oToJ(Object o) { - ObjectMapper om = new ObjectMapper(); - Writer w = new StringWriter(); - String json = null; - try { - - om.setDateFormat(new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ssZ")); - om.writeValue(w, o); - json = w.toString(); - w.close(); - } catch (IOException e) { - LOGGER.error("IOException", e); - } - return json; - } - - public static Map<String, String> readJson2Map(String json) { - ObjectMapper objectMapper = new ObjectMapper(); - try { - Map<String, String> maps = objectMapper.readValue(json, Map.class); - return maps; - } catch (Exception e) { - LOGGER.error("IOException", e); - return null; - } - } - - public static String hashMapToJson(HashMap<String, String> map) { - String string = "{"; - for (Iterator it = map.entrySet().iterator(); it.hasNext();) { - Entry e = (Entry) it.next(); - string += "\"" + e.getKey() + "\":"; - string += "\"" + e.getValue() + "\","; - } - string = string.substring(0, string.lastIndexOf(",")); - string += "}"; - return string; - } - - public static String dateFormat(Date date) { - SimpleDateFormat time = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ssZ"); - return time.format(date); - } - - public static String checkRequiredParam(HashMap<String, Object> checkParamsMap) { - StringBuilder errMsg = new StringBuilder(); - java.util.Iterator<String> hashMapIt = checkParamsMap.keySet().iterator(); - int count = 0; - while (hashMapIt.hasNext()) { - String key = hashMapIt.next(); - Object value = checkParamsMap.get(key); - if (value == null || "".equals(value)) { - errMsg.append(key); - count++; - if (count < checkParamsMap.size() - 1) { - errMsg.append(" and "); - } - } - - } - if (count > 0) { - errMsg.append(" can't be null or \"\"!\n "); - } - return errMsg.toString(); - } - - public static String checkRequiredJsonParam(String jsonParam, String key) { - return ""; -// StringBuilder errMsg = new StringBuilder(); -// try { -// ObjectMapper mapper = new ObjectMapper(); -// JsonNode jsonValue; -// -// -// jsonValue = mapper.readTree(jsonParam.toString()); -// Iterator<Entry<String, JsonNode>> elements = jsonValue.fields(); -// while (elements.hasNext()) { -// Entry<String, JsonNode> node = elements.next(); -// String childValue = node.getValue().asText(); -// if (childValue == null || "".equals(childValue)) { -// errMsg.append( -// "Both Chinese and English descriptions of this field cannot be empty: " + key + "/n"); -// break; -// } -// } -// -// return errMsg.toString(); -// } catch (JsonProcessingException e) { -// // TODO Auto-generated catch block -// LOGGER.error("JsonProcessingException" , e); -// return errMsg.toString(); -// } catch (IOException e) { -// // TODO Auto-generated catch block -// LOGGER.error("IOException" , e); -// return errMsg.toString(); -// } - } -} diff --git a/logging-sdk/src/main/java/org/openo/log/impl/InsertLogHandler.java b/logging-sdk/src/main/java/org/openo/log/impl/InsertLogHandler.java deleted file mode 100644 index ea5570f..0000000 --- a/logging-sdk/src/main/java/org/openo/log/impl/InsertLogHandler.java +++ /dev/null @@ -1,265 +0,0 @@ -/** - * Copyright 2017 ZTE Corporation. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.openo.log.impl; - -import java.util.HashMap; -import org.slf4j.Logger; - -import org.openo.log.api.LogMessage; -import org.openo.log.api.LogService; -import org.openo.log.api.OperLogMessage; -import org.openo.log.api.SecLogMessage; -import org.openo.log.api.SysLogMessage; -import org.slf4j.LoggerFactory; - - - -public class InsertLogHandler { - private static final Logger LOGGER = LoggerFactory.getLogger(InsertLogHandler.class.getName()); - - public void insertLog(LogMessage msg, String logIndex, String logType) { - String logJson = Facitility.hashMapToJson(msg.getLocaleMap()); - msg.setLocalMap(null); - - if (msg.getExtendedFields() != null) { - String exendedFieldsJson = Facitility.oToJ(msg.getExtendedFields()); - logJson = logJson.substring(0, logJson.lastIndexOf("}")) + "," - + exendedFieldsJson.substring(1) + "\n"; - msg.setExtendedFields(null); - } - LOGGER.info(logJson, logIndex, logType); - - - } - - public boolean checkCmdLog(OperLogMessage msg) { - StringBuilder errMsg = new StringBuilder(); - boolean errFlag = false; - HashMap<String, Object> checkParamsMap = new HashMap<>(); - checkParamsMap.put("userName", msg.getUserName()); - checkParamsMap.put("operation", msg.getOperation()); - checkParamsMap.put("descriptionInfo", msg.getDescriptionInfo()); - checkParamsMap.put("hostname", msg.getHostname()); - checkParamsMap.put("detail", msg.getDetail()); - checkParamsMap.put("logStartDate", msg.getLogStartDate()); - checkParamsMap.put("logEndDate", msg.getLogEndDate()); - errMsg.append(Facitility.checkRequiredParam(checkParamsMap)); - - - errMsg.append(checkCmdRank(msg.getRank())); - errMsg.append(checkConnectMode(msg.getConnectMode())); - errMsg.append(checkOperateResult(msg.getOperateResult())); - errMsg.append(checkIsDisplay(msg.getIsDisplay())); - - if (msg.getOperation() != null && !("").equals(msg.getOperation())) { - errMsg.append(Facitility.checkRequiredJsonParam(msg.getOperation(), "operation")); - } - if (msg.getDescriptionInfo() != null && !("").equals(msg.getDescriptionInfo())) { - errMsg.append(Facitility.checkRequiredJsonParam(msg.getDescriptionInfo(), "descriptionInfo")); - } - if (msg.getDetail() != null && !("").equals(msg.getDetail())) { - errMsg.append(Facitility.checkRequiredJsonParam(msg.getDetail(), "detail")); - } - if (msg.getFailReason() != null && !("").equals(msg.getFailReason())) { - errMsg.append(Facitility.checkRequiredJsonParam(msg.getFailReason(), "failReason")); - } - if (!"".equals(errMsg.toString())) { - LOGGER.warn(errMsg.toString()); - printCmdLog(msg); - errFlag = true; - } - return !errFlag; - } - - private String checkIsDisplay(int isDisplay) { - StringBuilder errMsg = new StringBuilder(); - if (isDisplay != LogService.LOG_DISPLAY && isDisplay != LogService.LOG_DISPLAY_NOT) { - errMsg.append("isDisplay must be 'LogService.LOG_DISPLAY'"); - errMsg.append(" or 'LogService.LOG_DISPLAY_NOT'\n"); - - } - return errMsg.toString(); - } - - private String checkOperateResult(String operateResult) { - StringBuilder errMsg = new StringBuilder(); - if ((operateResult != LogService.OPERLOG_SUCCESS) - && (operateResult != LogService.OPERLOG_ERROR)) { - errMsg.append("operateResult must be ' LogService.OPERLOG_ERROR'"); - errMsg.append(" or 'LogService.OPERLOG_SUCCESS'\n"); - - } - return errMsg.toString(); - } - - private String checkConnectMode(String connectMode) { - StringBuilder errMsg = new StringBuilder(); - if (!(connectMode.equals(LogService.CONNECT_TYPE_WEB) - || connectMode.equals(LogService.CONNECT_TYPE_TELNET) - || connectMode.equals(LogService.CONNECT_TYPE_SSH) - || connectMode.equals(LogService.CONNECT_TYPE_EM))) { - errMsg.append("connectMode must be 'LogService.CONNECT_TYPE_WEB'"); - errMsg.append(" or 'LogService.CONNECT_TYPE_TELNET'"); - errMsg.append(" or 'LogService.CONNECT_TYPE_SSH'"); - errMsg.append(" or 'LogService.CONNECT_TYPE_EM'\n"); - - } - - return errMsg.toString(); - } - - private String checkCmdRank(String rank) { - StringBuilder errMsg = new StringBuilder(); - boolean isExist = false; - String[] ranks = {LogService.OPERLOG_RANK_NOTICE, LogService.OPERLOG_RANK_NORMAL, - LogService.OPERLOG_RANK_IMPORTANT, LogService.OPERLOG_RANK_VERYIMPORTANT}; - for (int i = 0; i < ranks.length; i++) { - if (rank.equalsIgnoreCase(ranks[i])) { - isExist = true; - break; - } - } - if (!isExist) { - errMsg.append("rank must be 'LogService.OPERLOG_RANK_NORMAL'"); - errMsg.append(" or 'LogService.OPERLOG_RANK_NOTICE'"); - errMsg.append(" or 'LogService.OPERLOG_RANK_IMPORTANT'"); - errMsg.append(" or 'LogService.OPERLOG_RANK_VERYIMPORTANT'\n"); - - } - - return errMsg.toString(); - } - - public void printCmdLog(OperLogMessage msg) { - LOGGER.warn("CMD Log Error Detail msg"); - LOGGER.warn("UserName :" + msg.getUserName()); - LOGGER.warn("operation :" + msg.getOperation()); - LOGGER.warn("hostname :" + msg.getHostname()); - LOGGER.warn("descriptionInfo :" + msg.getDescriptionInfo()); - LOGGER.warn("operateResult :" + msg.getOperateResult()); - LOGGER.warn("FailReason :" + msg.getFailReason()); - LOGGER.warn("detail :" + msg.getDetail()); - LOGGER.warn("ConnectMode:" + msg.getConnectMode()); - LOGGER.warn("OperateResource :" + msg.getOperateResource()); - LOGGER.warn("logStartDate :" + msg.getOperateResource()); - LOGGER.warn("logEndDate :" + msg.getLogEndDate()); - LOGGER.warn("Rank :" + msg.getRank()); - } - - /** - * 检查日志�数是�符��求 - * - * @return true - */ - public boolean checkSecLog(SecLogMessage msg) { - StringBuilder errMsg = new StringBuilder(); - boolean errFlag = false; - HashMap<String, Object> checkParamsMap = new HashMap<>(); - checkParamsMap.put("userName", msg.getUserName()); - checkParamsMap.put("logName", msg.getLogName()); - checkParamsMap.put("hostname", msg.getHostname()); - checkParamsMap.put("detail", msg.getDetail()); - checkParamsMap.put("logDate", msg.getLogDate()); - errMsg.append(Facitility.checkRequiredParam(checkParamsMap)); - errMsg.append(checkConnectMode(msg.getConnectMode())); - - if (msg.getLogName() != null && !("").equals(msg.getLogName())) { - errMsg.append(Facitility.checkRequiredJsonParam(msg.getLogName(), "logName")); - } - if (msg.getDetail() != null && !("").equals(msg.getDetail())) { - errMsg.append(Facitility.checkRequiredJsonParam(msg.getDetail(), "detail")); - } - if (!"".equals(errMsg.toString())) { - LOGGER.warn(errMsg.toString()); - this.printSecLog(msg); - errFlag = true; - } - return !errFlag; - } - - public void printSecLog(SecLogMessage secLog) { - LOGGER.warn("SCRT Log Error Detail msg"); - LOGGER.warn("logDate :" + secLog.getLogDate()); - LOGGER.warn("logName :" + secLog.getLogName()); - LOGGER.warn("userName :" + secLog.getUserName()); - LOGGER.warn("hostname :" + secLog.getHostname()); - LOGGER.warn("connectMode:" + secLog.getConnectMode()); - LOGGER.warn("detail :" + secLog.getDetail()); - } - - public boolean checkSysLog(SysLogMessage msg) { - StringBuilder errMsg = new StringBuilder(); - boolean errFlag = false; - HashMap<String, Object> checkParamsMap = new HashMap<>(); - - checkParamsMap.put("logName", msg.getLogName()); - checkParamsMap.put("logStartDate", msg.getLogStartDate()); - checkParamsMap.put("logEndDate", msg.getLogEndDate()); - checkParamsMap.put("hostname", msg.getHostname()); - checkParamsMap.put("detail", msg.getDetail()); - errMsg.append(Facitility.checkRequiredParam(checkParamsMap)); - errMsg.append(checkSysRank(msg.getRank())); - if (msg.getLogName() != null && !("").equals(msg.getLogName())) { - errMsg.append(Facitility.checkRequiredJsonParam(msg.getLogName(), "logName")); - } - if (msg.getDetail() != null && !("").equals(msg.getDetail())) { - errMsg.append(Facitility.checkRequiredJsonParam(msg.getDetail(), "detail")); - } - if (!"".equals(errMsg.toString())) { - LOGGER.warn(errMsg.toString()); - printSysLog(msg); - errFlag = true; - } - return !errFlag; - } - - private String checkSysRank(String rank) { - StringBuilder errMsg = new StringBuilder(); - boolean isExist = false; - String[] ranks = {LogService.SYSLOG_RANK_INFORM, LogService.SYSLOG_RANK_NOTICE, - LogService.SYSLOG_RANK_WARN, LogService.SYSLOG_RANK_ERROR, LogService.SYSLOG_RANK_ALERT, - LogService.SYSLOG_RANK_EMERG}; - for (int i = 0; i < ranks.length; i++) { - if (rank.equalsIgnoreCase(ranks[i])) { - isExist = true; - break; - } - } - if (!isExist) { - errMsg.append("rank must be 'LogService.SYSLOG_INFORM'"); - errMsg.append(" or 'LogService.SYSLOG_NOTICE'"); - errMsg.append(" or 'LogService.SYSLOG_WARN'"); - errMsg.append(" or 'LogService.SYSLOG_ERROR'"); - errMsg.append(" or 'LogService.SYSLOG_ALTERT'"); - errMsg.append(" or 'LogService.SYSLOG_EMERG'\n"); - - } - - return errMsg.toString(); - } - - public void printSysLog(SysLogMessage msg) { - LOGGER.warn("System Log Error Detail msg"); - LOGGER.warn("logName :" + msg.getLogName()); - LOGGER.warn("rank :" + msg.getRank()); - LOGGER.warn("source :" + msg.getSource()); - LOGGER.warn("logStartDate :" + msg.getLogStartDate()); - LOGGER.warn("logEndDate :" + msg.getLogEndDate()); - LOGGER.warn("detail :" + msg.getDetail()); - } - -} - diff --git a/logging-sdk/src/main/java/org/openo/log/impl/LogConst.java b/logging-sdk/src/main/java/org/openo/log/impl/LogConst.java deleted file mode 100644 index 1e45313..0000000 --- a/logging-sdk/src/main/java/org/openo/log/impl/LogConst.java +++ /dev/null @@ -1,37 +0,0 @@ -/** - * Copyright 2017 ZTE Corporation. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.openo.log.impl; - -public class LogConst { - private LogConst() { - - } - - public final static int CMD_LOG_FLAG = 1; - public final static int SYS_LOG_FLAG = 2; - public final static int SECRET_LOG_FLAG = 3; - - public final static String AUDITLOG_OPERATION = "auditlog_operation"; - public final static String AUDITLOG_SECURITY = "auditlog_security"; - public final static String AUDITLOG_SYSTEM = "auditlog_system"; - - public final static String OPERLOG_TYPE = "operlog"; - public final static String SERLOG_TYPE = "seclog"; - public final static String SYSLOG_TYPE = "syslog"; - - - -} diff --git a/logging-sdk/src/main/java/org/openo/log/impl/LogIdTool.java b/logging-sdk/src/main/java/org/openo/log/impl/LogIdTool.java deleted file mode 100644 index 4dea43b..0000000 --- a/logging-sdk/src/main/java/org/openo/log/impl/LogIdTool.java +++ /dev/null @@ -1,67 +0,0 @@ -/** - * Copyright 2017 ZTE Corporation. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.openo.log.impl; - -import java.util.Date; -import java.util.Random; - - - -public class LogIdTool { - private static Random cmdRand = new Random(); - - private static Random sysRand = new Random(); - - private static Random secRand = new Random(); - - private LogIdTool() { - - } - - public static long getRandomID(int logType, long startDate) { - String strCtime = "" + startDate; - if (strCtime.length() > 13) { - strCtime = strCtime.substring(strCtime.length() - 13); - } - int seed1; - if (logType == LogConst.CMD_LOG_FLAG) { - seed1 = cmdRand.nextInt(100000); - } else if (logType == LogConst.SYS_LOG_FLAG) { - seed1 = sysRand.nextInt(100000); - } else if (logType == LogConst.SECRET_LOG_FLAG) { - seed1 = secRand.nextInt(100000); - } else { - return 0; - } - String seed2 = "" + seed1; - int shouldFillLen = 5 - seed2.length(); - for (int i = 0; i < shouldFillLen; i++) { - seed2 = "0" + seed2; - } - return Long.parseLong(strCtime + seed2); - } - - public static long transTimeCond2ID(Date time, boolean isStart) { - long timeLong = time.getTime(); - if (isStart) { - timeLong = timeLong * 100000; - } else { - timeLong = timeLong * 100000 + 99999; - } - return timeLong; - - } -} |