123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110 |
- const fs = require('fs');
- const turf = require('@turf/turf');
- const wkx = require('wkx');
- const Database = require('../db');
- const moment = require('moment');
- const uuid = require('uuid');
- const pool = new Database({
- host: '192.168.100.30',
- database: 'real3d',
- user: 'postgres',
- password: 'postgis',
- port: 5432,
- });
- async function importFactor(inFilePath, landTypeCode) {
- // 连接到数据库,设置模式
- await pool.connect();
- await pool.setSchema('base');
- try {
- // 同步读取GeoJSON文件
- const data = fs.readFileSync(inFilePath, 'utf8');
- // 清空表 base.t_fzss_fzxz_factor_temp
- // const deleteSql = `delete from t_fzss_fzxz_factor_temp`;
- // await pool.query(deleteSql);
- // 解析GeoJSON数据
- const dataInfos = JSON.parse(data);
- importItems(dataInfos, landTypeCode);
- console.log("插入模板成功" + inFilePath)
- } catch (err) {
- console.error('操作GeoJSON文件时出错:', err);
- }
- }
- async function importItems(insertItems, landTypeCode) {
- for (let index = 0; index < insertItems.length; index++) {
- const element = insertItems[index];
- // 生成uuid并且去掉下划线
- const id = uuid.v4().replace(/-/g, "");
- const insertObj = {
- id: id,
- landTypeCode: landTypeCode,
- factorId: element.id,
- factorBsm: element.bsm,
- factorName: element.name,
- order_index: index,
- condition_info: JSON.stringify(element.condition_info),
- system: true
- }
- // 生成数据库的插入语句
- const insertSql = `insert into t_fzss_fzxz_factor_temp (id,land_type_code,factor_id,factor_bsm,factor_name,order_index,condition_info,system)
- values('${insertObj.id}','${insertObj.landTypeCode}','${insertObj.factorId}','${insertObj.factorBsm}','${insertObj.factorName}',${insertObj.order_index},'${insertObj.condition_info}',${insertObj.system})`;
- console.log(insertSql);
- const res = await pool.query(insertSql);
- if (element.children && element.children.length > 0) {
- await importItems(element.children, id);
- }
- }
- }
- importFactor("./data/schedule/factor_temp/factor_residence.json", "0701")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "070101")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "070102")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "070103")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "08")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "0801")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "0802")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "0803")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "080301")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "080302")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "0804")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "080401")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "080402")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "080403")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "080404")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "080405")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "0805")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "080501")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "080502")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "0806")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "080601")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "080602")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "080603")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "0807")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "080701")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "080702")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "080703")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "080704")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "09")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "0901")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "090101")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "090102")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "090103")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "090104")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "090105")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "0902")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "0903")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "090301")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "090302")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "0904")
- importFactor("./data/schedule/factor_temp/factor_residence.json", "090401")
|