big_data_ott/saveOSSAGitte.js

const client = require("ssh2-sftp-client");
const path = require("path");
const fs = require("fs");

const { execSync } = require("child_process");

(async function Init() {
  const localDir = "dist/";
  const dirPath = path.resolve(__dirname, "./" + localDir);
  const list = [];

  /**
   * 获取localDir下的所有文件路径
   * @param {string} pathDir
   */
  async function getFiles(pathDir) {
    const dirList = fs.readdirSync(pathDir) || [];
    for (let i = 0; i < dirList.length; i++) {
      const P = [pathDir, dirList[i]];
      const stat = fs.lstatSync(P.join("\\"));
      if (!stat.isDirectory()) {
        list.push(P);
      } else getFiles(P.join("\\"));
    }
  }

  async function upServer() {
    const config = {
      path: {
        // 远程地址
        romotePath: "/var/www/test",
        // 本地地址
        localPath: path.resolve(__dirname, "./dist"),
      },
      romote: {
        // 服务器 ip 地址
        host: "123.57.195.226",
        // 端口号,默认是 22
        port: 22,
        // 登录的用户名
        username: "root",
        // 登录密码
        password: "581100Li.",
      },
    };
    const sftp = new client();
    try{
        await sftp.connect(config.romote);
        await sftp.rmdir(config.path.romotePath + '/css', true);
        await sftp.rmdir(config.path.romotePath + '/fonts', true);
        await sftp.rmdir(config.path.romotePath + '/js', true);
        await sftp.delete(config.path.romotePath + '/index.html', true);
        console.log("已清空原有文件");
        // await sftp.uploadDir(config.path.localPath, config.path.romotePath);
        // console.log("上传完成");
        // 断开连接
        sftp.end();
        console.log("断开链接");
    }catch(err){
        console.log("更新失败",err);
    }
  }

  /**
   * 上传git
   */
  function execFun() {
    try {
      execSync("git add .");
      execSync('git commit -m "提交"');
      execSync("git push");
      console.log("上传git---完成");
    } catch (e) {
      console.log("上传git---失败");
      console.error(e);
    }
  }

  execFun();
  try {
    await getFiles(dirPath);
    await upServer();
    console.log("获取文件路径---完成");
  } catch (err) {
    console.log("数据上传oss---失败");
  }
})();