package com.hpf.cloud.filter;

import com.alibaba.druid.filter.config.ConfigFilter;
import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.druid.pool.DruidDataSourceFactory;
import com.alibaba.druid.proxy.jdbc.DataSourceProxy;
import com.baomidou.mybatisplus.core.toolkit.AES;
import lombok.NoArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.env.ConfigurableEnvironment;
import org.springframework.core.env.PropertySource;
import org.springframework.core.env.SimpleCommandLinePropertySource;
import org.springframework.stereotype.Component;

import java.sql.SQLException;
import java.util.Properties;

/**
 * @description: 兼容druid與mp加解密，重寫(xiě)druid的解密，替換為mp的解密方式
 * @datetime: 2020/11/22 16:12
 * @author: huangpengfei
 */
@NoArgsConstructor
@Slf4j
@Component
public class DruidForMybatisPlusDecryptFilter extends FilterAdapter {

  /**
   * 獲取命令行中的key
   */
  @Autowired
  private ConfigurableEnvironment configurableEnvironment;

  /**
   * 重寫(xiě)獲取密碼解密
   * 1. 參考DruidFilter的代碼，取的是file類(lèi)型的配置文件，這里從啟動(dòng)參數(shù)中獲取即可
   * 2. 如果不配置，且不需要解密則放行
   *
   * @param dataSourceProxy
   */
  @Override
  public void init(DataSourceProxy dataSourceProxy) {
    if (!(dataSourceProxy instanceof DruidDataSource)) {
      log.error("ConfigLoader only support DruidDataSource");
    }
    DruidDataSource dataSource = (DruidDataSource) dataSourceProxy;
    String mpwKey = null;
    for (PropertySource<?> ps : configurableEnvironment.getPropertySources()) {
      if (ps instanceof SimpleCommandLinePropertySource) {
        SimpleCommandLinePropertySource source = (SimpleCommandLinePropertySource) ps;
        mpwKey = source.getProperty("mpw.key");
        break;
      }
    }
    if (null != mpwKey) {
      // 證明加密
      Properties properties = this.setProperties(dataSource, mpwKey);
      try {
        // 將信息配置進(jìn)druid
        DruidDataSourceFactory.config(dataSource, properties);
      } catch (SQLException e) {
        e.printStackTrace();
      }
    }
    log.info("數(shù)據(jù)庫(kù)連接成功！");
  }

  /**
   * 通過(guò)命令行的密鑰進(jìn)行解密
   *
   * @param dataSource 數(shù)據(jù)源
   * @param mpwKey   解密key
   * @return
   */
  private Properties setProperties(DruidDataSource dataSource, String mpwKey) {
    Properties properties = new Properties();
    // 先解密
    try {
      String userName = AES.decrypt(dataSource.getUsername().substring(4), mpwKey);
      properties.setProperty(DruidDataSourceFactory.PROP_USERNAME, userName);
      dataSource.setUsername(userName);
      String password = AES.decrypt(dataSource.getPassword().substring(4), mpwKey);
      properties.setProperty(DruidDataSourceFactory.PROP_PASSWORD, password);
      dataSource.setPassword(password);
      String url = AES.decrypt(dataSource.getUrl().substring(4), mpwKey);
      properties.setProperty(DruidDataSourceFactory.PROP_URL, url);
      dataSource.setUrl(url);
    } catch (Exception e) {
      log.info("druid decrypt failed!");
      e.printStackTrace();
    }
    return properties;
  }

}