1. /**
    2.  * 用于模拟测试数据
    3.  * 每3秒生成一次数据
    4.  */
    5. const pg = require('pg');
    7. const config = {
    8.   user: 'postgres',
    9.   host: 'localhost',
    10.   database: 'police_rs',
    11.   password: '3337',
    12.   port: 5432
    13. };
    14. const pool = new pg.Pool(config);
    15. const timer = 3000; // 时间间隔 3s
    16. const device_num = 100;      // 初始化数据库模拟设备的数量
    17. const signxMap={};
    18. const signyMap={};
    19. const prexMap={};
    20. const preyMap={};
    22. const typeMap = {};
    23. const bx = [515834, 518373], by = [3688409, 3690194];
    24. const future = new Date('2220/3/28 11:25:50').toISOString();  // 未来的相当长时间
    25. let cnt=0;
    27. initDatabase(device_num);
    29. // loopfn();
    31. async function initDatabase(device_num){ // 根据设备的数量初始化数据库
    32.   // 清空历史表和实时表
    33.   console.log("重置history_info");
    34.   await pool.query(`
    35.     DROP TABLE IF EXISTS public.history_info;
    36.     CREATE TABLE IF NOT EXISTS public.history_info
    37.     (
    38.       geometry geometry NOT NULL,
    39.       device_id character varying(100) NOT NULL,
    40.       id serial,
    41.       state character varying(8) DEFAULT 0,
    42.       valid_time timestamp(6) with time zone,
    43.       unvalid_time timestamp(6) with time zone,
    44.       type character varying(8) ,
    45.       meta character varying(200),
    46.       name character varying(100),
    47.       CONSTRAINT history_main_pkey PRIMARY KEY (id)
    48.     );
    49.   `);
    50.   // 插入首条数据
    51.   let start = new Date("2022-05-20 12:00:00").getTime();
    52.   let cur = new Date().getTime();
    53.   for(let id = 0; id < device_num; id++){
    54.     typeMap[id] = Math.random() > 0.5? "0":"1";
    55.     prexMap[id] =  Math.random()*(bx[1]-bx[0]) + bx[0];
    56.     preyMap[id] = Math.random()*(by[1]-by[0]) + by[0];
    57.     signxMap[id] = Math.random() * 2 - 1;
    58.     signyMap[id] = Math.random() * 2 - 1;
    59.     let item = {
    60.       device_id: '' + id,
    61.       name: typeMap[id] + '-' + id,
    62.       x:prexMap[id],
    63.       y:preyMap[id], 
    64.       state:"1", 
    65.       valid_time:new Date(start).toISOString(), 
    66.       unvalid_time:new Date(start + 30  *60*1000).toISOString(), 
    67.       meta: "{}",
    68.       type: typeMap[id],
    69.     }; 
    70.     // 初始化 历史表
    71.     await pool.query(`INSERT INTO public.history_info(device_id, geometry, state, valid_time, unvalid_time, type, meta, name) VALUES(
    72.       ${item.device_id}, point(${item.x},${item.y})::geometry,'${item.state}', '${item.valid_time}', '${item.unvalid_time}',${item.type},'${item.meta}','${item.name}'
    73.     )`);
    75.   }
    77.   // 快速插入历史模拟数据
    78.   for(start += 30  *60*1000; start < cur; start += 30 *60*1000){ // 间隔半小时 
    79.     for(let id = 0; id < device_num; id++){
    80.       prexMap[id] += signxMap[id] * Math.random() * 5;
    81.       preyMap[id] += signyMap[id] * Math.random() * 5;
    82.       if(prexMap[id] < bx[0]) signxMap[id] = Math.random();
    83.       else if(prexMap[id] > bx[1])  signxMap[id] = -Math.random();
    85.       if(preyMap[id] < by[0]) signyMap[id] = Math.random();
    86.       else if(preyMap[id] > by[1])  signyMap[id] = -Math.random();
    88.       let item = {
    89.         device_id: '' + id,
    90.         name: typeMap[id] + '-' + id,
    91.         x : prexMap[id],
    92.         y : preyMap[id], 
    93.         state:"1", 
    94.         valid_time:new Date(start).toISOString(), 
    95.         unvalid_time:new Date(start + 30 *60*1000).toISOString(), 
    96.         meta: "{}",
    97.         type: typeMap[id],
    98.       }; 
    99.       // 初始化 历史表
    100.       await pool.query(`INSERT INTO public.history_info(device_id, geometry, state, valid_time, unvalid_time, type, meta, name) VALUES(
    101.         ${item.device_id}, point(${item.x},${item.y})::geometry,'${item.state}', '${item.valid_time}', '${item.unvalid_time}',${item.type},'${item.meta}','${item.name}'
    102.       )`);
    104.     }
    106.   }
    107. }