daocha_serve/Source/server/staticFile/emergencyfile.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.emergencyPlandiskpath}`);
let path2Arr = []
ppChildren.forEach(ppchild => {
    let path2 = path.join(`${fileaddres.emergencyPlandiskpath}`, ppchild);

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

});


path2Arr.forEach(path2 => {



    var file3NamesArr = fs.readdirSync(path2);

    file3NamesArr.forEach(file3Name => {


        let file3Path = path.join(path2, file3Name);
        let name = file3Name.substring(0, file3Name.length - 4);
        let time = path2.slice(-4);
        let type = "预案"


        let serverUrl = `${fileaddres.emergencyfileserver}` + time + "/" + file3Name;

        let sql = `insert into t_emergencyplan("name","date","serverurl","type") values ('${name}','${time}','${serverUrl}','${type}') `


        pool.query(sql, (err, ress) => {
            if (!err) {

            } else {
                console.log(err);
            }


        })


    })


})

// 都完成以后执行这个


let hebingsql = `update t_emergencyplan set mapurl = (select mapurl1 from  t_siweidaotu where t_siweidaotu.name = t_emergencyplan.name)`;
pool.query(hebingsql, (err, ress) => {
    if (!err) {
    } else {
        console.log(err);
    }


})