package com.javaweb.quartz.task;

import com.javaweb.common.config.Global;
import com.javaweb.common.utils.StringUtils;
import com.javaweb.framework.manager.AsyncManager;
import com.javaweb.framework.manager.factory.AsyncFactory;
import com.javaweb.quartz.config.DbParamConfig;
import com.javaweb.quartz.service.ISysJobService;
import com.javaweb.quartz.util.BatCommandUtil;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.io.File;
import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.Date;

/**
 * 定时任务调度测试
 * 
 * @author ruoyi
 */
@Component("ryTask")
public class RyTask
{
    private static final Logger log = LoggerFactory.getLogger(RyTask.class);
    @Autowired
    DbParamConfig dbParamConfig;
    @Autowired
    ISysJobService jobService;
    private static String mysqlBasedir = null;

    private void initMysqlDir(){
        if(mysqlBasedir==null){
            mysqlBasedir = jobService.getMysqlBasedir();
        }
    }

    public void recoverDBFile(String fileId) {
        log.info("------------------执行定时任务------------ryTask.recoverDBFile，参数:"+fileId);
        if(fileId.indexOf(".sql")==-1){
            fileId = fileId+".sql";
        }
        try {
            File sqlFile = new File(Global.getDbBackupPath()+fileId);
            if(!sqlFile.exists()){
                log.error("数据库恢复时录入的文件id值不存在："+fileId);
                return;
            }
            initMysqlDir();
            importDBFile(sqlFile.getPath());
        } catch (Exception e) {
            e.printStackTrace();
            log.error("执行数数据库恢复时发生异常："+e.getMessage());
        }
    }
    public void backupDB() {
        log.info("------------------执行定时任务------------ryTask.backupDB");
        try {
            initMysqlDir();
            //备份数据库
            backup(Global.getDbBackupPath());

            //默认清理操作30天的数据库备份文件
            final Integer days=30;
            final String folder= Global.getDbBackupPath();
            AsyncManager.me().execute(AsyncFactory.cleanOutDateBackupFile(days,folder));

        } catch (Exception e) {
            log.error("执行数据库备份时发生异常："+e.getMessage());
        }
    }
    //===============================================内部方法=========================================
    private void importDBFile(String filePath) throws IOException{
        StringBuilder cmdStr = new StringBuilder();
        cmdStr.append(" -u").append(dbParamConfig.getUsername())
                .append(" -p").append(dbParamConfig.getPassword())
                .append(" -h").append(dbParamConfig.getHost())
                .append(" -P").append(dbParamConfig.getPort())
                .append(" ").append(dbParamConfig.getDatabaseName())
                .append("<").append(filePath);
        if (isWindows()) {
            BatCommandUtil.writeAndExcute(Global.getDbBackupPath()+"recoverMysqlDb.bat",new StringBuilder()
                    .append("cd /d ").append(mysqlBasedir).append("bin").append("\r\n")
                    .append("mysql").append(cmdStr.toString()).toString());
        } else {
            throw new RuntimeException("暂时只支持windows系统！");
        }
    }
    /**
     * 备份数据库操作
     *
     * @param fileBasePath 文保存件路径
     * @return
     */
    private void backup(String fileBasePath) throws IOException {
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy_MM_dd_HH_mm_ss_SSS");
        String name = dbParamConfig.getDatabaseName()+"_"+sdf.format(new Date())+".sql";

        File sqlFile = BatCommandUtil.createFile(fileBasePath+File.separator+ name);
        StringBuilder cmdStr = new StringBuilder();
        // 构建数据库备份参数
        cmdStr.append(" -u").append(dbParamConfig.getUsername())
                //注意：如果数据库密码为空，导不出来
                .append(" -p").append(dbParamConfig.getPassword())
                .append(" -h").append(dbParamConfig.getHost())
                .append(" -P").append(dbParamConfig.getPort())
                .append(" ").append(dbParamConfig.getDatabaseName())
                .append(" ").append("--hex-blob")//使用十六进制符号转储二进制字符序列，防止乱码
                .append(" > ").append(sqlFile.getPath());
        if (isWindows()) {
            BatCommandUtil.writeAndExcute(fileBasePath+File.separator+"backupmysql.bat",new StringBuilder()
                    .append("cd /d ").append(mysqlBasedir).append("bin").append("\r\n")
                    .append("mysqldump").append(cmdStr.toString()).toString());
        } else {
            throw new RuntimeException("暂时只支持windows系统！");
        }
    }


    private static boolean isWindows() {
        return System.getProperty("os.name").indexOf("Windows") != -1;
    }

    //---------------------demo---------------------
    public void ryMultipleParams(String s, Boolean b, Long l, Double d, Integer i)
    {
        System.out.println(StringUtils.format("执行多参方法： 字符串类型{}，布尔类型{}，长整型{}，浮点型{}，整形{}", s, b, l, d, i));
    }

    public void ryParams(String params)
    {
        System.out.println("执行有参方法：" + params);
    }

    public void ryNoParams()
    {
        System.out.println("执行无参方法");
    }


}