package com.kpmg.bmwsfm.service;

import com.csvreader.CsvWriter;
import com.kpmg.bmwsfm.biz.entity.ModelEntity;
import com.kpmg.bmwsfm.common.Constants;
import com.kpmg.bmwsfm.common.ExecuteResult;
import com.kpmg.bmwsfm.util.CommonUtils;
import com.kpmg.bmwsfm.util.PropertiesUtils;
import com.kpmg.bmwsfm.util.SftpUtil;
import org.apache.commons.collections.CollectionUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.core.io.support.PropertiesLoaderUtils;
import org.springframework.stereotype.Component;

import java.io.File;
import java.io.IOException;
import java.nio.charset.Charset;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.List;
import java.util.Properties;

/**
 * @author lucasliang
 * @date 12/11/2018 3:44 afternoon
 */
@Component
public class ExportExcelService {

  private Logger logger = LoggerFactory.getLogger(ExportExcelService.class);

  private static final String CONFIGURATION_FILE = "configurationfile";


  /**
 *@param: [serverPath, type]
 *@return com.kpmg.bmwsfm.common.ExecuteResult
 *@author lucasliang
 *@date 03/12/2018 10:12 afternoon
 *@Description generate thirteen and not thirteen carmodel order
*/
  public ExecuteResult generateCsv(String serverPath, String type,
      List<ModelEntity> carModelEntityList) {
    return generateAllCarmodelOrderCsv(serverPath, type, carModelEntityList);
  }


  /**
     *@param: [serverPath, type, carModelEntityList]
     *@return com.kpmg.bmwsfm.common.ExecuteResult
     *@author lucasliang
     *@date 12/12/2018
     *@Description generate carmodel order
    */
  @SuppressWarnings("unchecked")
  private ExecuteResult generateAllCarmodelOrderCsv(String serverPath, String type,
      List<ModelEntity> carModelEntityList) {
    ExecuteResult executeResult = new ExecuteResult();
    String filePath = serverPath.concat(File.separator).concat(type)
        .concat(Constants.SUFFIX_CSV);
    Path path = Paths.get(filePath);
    CommonUtils.deleteFileByPath(path);
    CsvWriter csvWriter = new CsvWriter(filePath, ',',
        Charset.forName("UTF-8"));

    String[] header = {"MODEL_CATEGORY", "MODEL_NAME"};
    try {
      csvWriter.writeRecord(header);
      if (CollectionUtils.isNotEmpty(carModelEntityList)) {
        for (ModelEntity modelEntity : carModelEntityList) {
          String[] content = {
              modelEntity.getModelCategory(),
              modelEntity.getModelName(),
          };
          csvWriter.writeRecord(content);
        }
        executeResult.setSuccess(true);
        executeResult.setData("ok");
      } else {
        executeResult.setSuccess(false);
        executeResult.setData("車型順序表數(shù)據(jù)為空");
        return executeResult;
      }
    } catch (IOException e) {
      logger.error("", e);
    } finally {
      csvWriter.close();
    }

    Properties properties = null;
    try {
      properties = PropertiesLoaderUtils.loadAllProperties("sftp.properties");
    } catch (IOException e) {
      logger.error("", e);
    }

    if (properties != null) {
      String userName = PropertiesUtils.getValue(Constants.SFTP_USERNAME, properties);
      String ip = PropertiesUtils.getValue(Constants.SFTP_IP, properties);
      Integer port = Integer.valueOf(PropertiesUtils.getValue(Constants.SFTP_PORT, properties));
      String privateKeyPath = PropertiesUtils.getValue(Constants.SFTP_KEYPATH, properties);

      SftpUtil sftpUtil = new SftpUtil(userName, ip, port, privateKeyPath);
      try {
        sftpUtil.login();
      } catch (Exception e) {
        logger.error("", e);
      }

      String sftpPath = PropertiesUtils.getValue(Constants.SFTP_REMOTE_PATH, properties);
      executeResult = sftpUtil.uploadSingleFile(sftpPath.concat(CONFIGURATION_FILE), path.toFile()
              , type);
      sftpUtil.getSession().getTimeout();
      sftpUtil.logout();
      if (logger.isInfoEnabled()) {
        logger.info(String.format(" 登出:%s", sftpUtil.getSession()));
        logger.info(String.format("SFTP logout success : %s", sftpUtil.getSession()));
      }
    }

    return executeResult;
  }

}