daocha_serve/Source/server/staticFile/siweidaotu.js

/* 准备工作 */

// 应急预案入库
var path = require("path");
var fs = require("fs");
const express = require('express');
const pgclient = require("../DataBase/Postgresql/pgClient.js")
const fileaddres = require("./fileaddres.js")

const {
    Pool,
    Client
} = require('pg')
const pool = new Pool({
    user: 'postgres',
    host: '39.107.237.131',
    database: 'taijiu0820db',
    password: '123456',
    port: 5432,
})
// let indexnumber = 0





/* 读取 */

/* 同步读取 */



// 第一级目录里面所有的 文件夹
// 第一层 过滤

var ppChildren = fs.readdirSync(`${fileaddres.mindmapndiskpath}`);
let path2Arr = []
ppChildren.forEach(ppchild => {
    let path2 = path.join(`${fileaddres.mindmapndiskpath}`, ppchild);

    var stat = fs.lstatSync(path2);
    if (stat.isDirectory()) {
        path2Arr.push(path2)
    }

});


path2Arr.forEach(path2 => {



    var file3NamesArr = fs.readdirSync(path2);

    file3NamesArr.forEach(file3Name => {
        if (file3Name.indexOf("思维导图") != -1) {
            let file3Path = path.join(path2, file3Name);
            let name = file3Name.substring(0, file3Name.length - 10);
            let time = path2.slice(-4);

            let serverUrl = `${fileaddres.mindmapfileserver}` + time + "/" + file3Name + ";" + `${fileaddres.mindmapfileserver}` + time + "/" + name + "（流程图）.png"

            let sql = `insert into t_siweidaotu("name","date","mapurl1") values ('${name}','${time}','${serverUrl}') `
            pool.query(sql, (err, ress) => {
                if (!err) {

                } else {
                    console.log(err);
                }


            })
        }






    })


})