/**
 * 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());
  }

}