Node+fs+定时器(node-schedule)+MySql

{
  "name": "zqz",
  "dependencies": {
    "mysql": "^2.10.2",
    "node-schedule": "^1.1.0"
  }
}

var schedule = require('node-schedule');
var mysql = require('mysql');
var fs = require('fs');
const desktopPath = 'C:/Users/Administrator/Desktop/';
const targetPath = 'F://Blog_ScreenShot//';
const metaInfo = 'blog';
var operationType = {
    0 : '插入',
    1 : '删除',
    2 : '修改',
    3 : '查询'
}

/**
 * 轮询桌面
 * @return {[type]} [description]
 */
function timePoll(){
    console.log('--------[开始轮询]----------')
    schedule.scheduleJob('30 * * * * *', function(){
        visitDesk();
          console.log('每分钟的30s都会执行!:' + (new Date).toLocaleTimeString());
    }); 
}

/**
 * 访问桌面
 * @return {[type]} [description]
 */
function visitDesk(){
    console.log('--------开始访问桌面----------')
    fs.readdir(desktopPath,function(err, files){
       if (err) {
           return console.error(err);
       }

           files.forEach( function (file){
              if(file && judgeImage(file)){
                   saveImageToFile(file);
              }else{
                   console.log('桌面无资源!');
                   return;
              }

           });
    });
}

/**
 * 判断文件类型，取出我们需要的png图片
 * @return {[type]} [description]
 */
function judgeImage(file){
    var postfix = getPostfix(file);
    if(postfix === 'png' && file.indexOf(metaInfo) > -1){
        return file;
    }
}

function getPostfix(file){
    var dotIndex = file.indexOf('.');
    var fileLen = file.length;
    return file.substring(dotIndex+1,fileLen);
}

/**
 * 将获取的图片存入
 * pipe，它以用来把当前的可读流和另外一个可写流连接起来。可读流中的数据会被自动写入到可写流中
 * @return {[type]} [description]
 */
function saveImageToFile(file){
    var fileReadStream = fs.createReadStream(desktopPath + file);
    var lastPath = targetPath + createDateFolder();
    if(!isFolderHave(lastPath)){
        createLastFloder(lastPath);
    }
    var fileWriteStream = fs.createWriteStream(lastPath + file);
    fileReadStream.pipe(fileWriteStream);
    fileWriteStream.on('close',function(){
          console.log('复制成功!');
          deleteDeskImage(file);
          //写入数据库
          connectMysql(file, lastPath, '0');
    })
}

/**
 * 删除桌面文件
 * @param  {[type]} file [description]
 * @return {[type]}      [description]
 */
function deleteDeskImage(file){
    fs.unlink(desktopPath + file, function(){
        console.log('删除成功!')
    })
}

/**
 * 以系统时间创建文件夹/年月日
 * @return {[type]} [description]
 */
function createDateFolder(){
    var day = (new Date).getDate();
    var month = (new Date).getMonth()+1;
    var year = (new Date).getFullYear();
    return year + '_' + month + '_' + day + '//';
}

/**
 * 判断文件夹是否存在
 * @return {[type]} [description]
 */
function isFolderHave(lastPath){
    fs.exists(lastPath, function(exists){
        if(exists){
            return true;
        }else{
            return false;
        }
    })
}

/**
 * 创建最终目标文件夹
 * @param  {[type]} lastPath [description]
 * @return {[type]}          [description]
 */
function createLastFloder(lastPath){
    fs.mkdir( lastPath, function(){
        console.log('[文件夹创建]-' +lastPath + "成功!");
    })
}

/**
 * 连接数据库
 * @return {[type]} [description]
 */
function connectMysql(picname, picurl, time){
    var connection = mysql.createConnection({
      host     : 'localhost',
      user     : 'root',
      password : 'root',
      database : 'nodejs'
    });

    connection.connect(function(err){
        if(err){
            console.log(err);
            return;
        }
        console.log('连接成功!');
    });

    saveToDataBase(connection, picname, picurl);
    
    connection.end(function(err){
        if(err){
            return;
        }
        console.log('关闭连接成功!');
    });
}

/**
 * 将数据存入数据库，进行持久化
 * @return {[type]} [description]
 */
function saveToDataBase( connection, picname, picurl){
    var  querySql = 'INSERT INTO scaingDeskImg(Id,picname,picurl,time) VALUES(0,?,?,?)';
    
    //注意存入数据库中的数据如果有中文会出现，乱码错误，导致执行失败！
    var  querySql_Params = [picname, targetPath+picurl+picname, new Date];
    
    operationDataBase( connection,querySql, querySql_Params, operationType['0']);
}

/**
 * 对数据库的操作
 * @return {[type]} [description]
 */
function operationDataBase( connection, querySql, querySql_Params,flag){
    connection.query( querySql, querySql_Params, function (err, result) {
        if(err){
         console.log('[' + flag + 'ERROR] - ',err.message);
         return;
        }        

       console.log(flag + '成功!'); 
    });
}

timePoll();

schedule.scheduleJob('30 * * * * *', function(){
    visitDesk();
      console.log('每分钟的30s都会执行!:' + (new Date).toLocaleTimeString());
});