init code

Change-Id: Icd0948118397b256da70dfbcbbec5520dc5eafd4
Signed-off-by: Zhaoxing <meng.zhaoxing1@zte.com.cn>

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;
-
-  }
-}