laputa-trigger-modules

version：0.2.x

description

Laputa项目，由某程序触发进行相关业务；项目没有入口，以module为主；前置程序触发调用，如node-red

使用

初始化，并执行

新增运行模式，两种模式 whole/specify 完整模式和指定模式；

• whole 表示对全部租户库支持;该项为默认配置

• specify 表示对指定租户库支持，需要额外传入租户库名配置

  options={runningMode:'specify',tenants:['laputa']}

//连接rethinkdb配置对象，不定义则使用默认配置文件中的配置
//运行模式 whole/specify
let options={runningMode:'specify',tenants:['laputa']};
//调用模块
const trigger = require('laputa-trigger-modules');
//获取r模块
//获取初始化模块，并初始化环境，初始化业务会将表 “system” 和 “deviceType” 数据缓存
async function begin() {
    const r = trigger.rethinkdb.init(options.db);
    options.r = r;
    const appInit = trigger.appInit(options);
    const caches = await appInit.init();
    const frame = { r: r, caches:caches};
    return frame;
}
begin();

自动生成工单业务

传入的数据主体为msgpack序列化格式 topic 格式中包含tenant库名;符合如“rcg/event/sh/laputa/env”，第4位为库名

生成的新工单数据会放入回调方法中被执行

/**
* ticket 新生成的工单数据对象
* topic 租户库名
**/
callback(ticket,topic){}

调用方法

/**
 * ......
 * ......
 * 省略启动时执行
 **/

//获取自动生成工单模块
const autoTicket = trigger.autoTicket;

//假设进入的数据
const message = {
    "deviceId": "5b2f68a5-1adb-4c8e-8fbf-811523779698",
    "monitorId": "436cf7b3-d6c0-4077-a1a7-25406ca11308",
    "state": "alarm",
    "value": 67.57,
    "_updateTime": 1503987070305
}

const _message=msgpack.encode(message);
const topic='rcg/event/sh/laputa/env';

begin().then(frame => {
    autoTicket(frame, topic, _message, function (ticket, topic) {
        console.log('new ticket', ticket, topic);
    });
});
    

推送数据Hook模块

• 用于生成web hook，触发数据推送

    //调用模块
    const {PushMessageQueue} = require('laputa-trigger-modules').manual2Push;

    //初始化接收推送数据队列
    const queuePush = new PushMessageQueue();

    //数据传入
    queuePush.start_check(topic, pushData);

    //获取最新待推送数据
    let msg=queuePush.oneByOne();
    console.log(JSON.stringify(msg.app));

内部模块调用消息推送

    const {  InnerProcess } = require('laputa-trigger-modules').manual2Push;
    //必须要已经有创建好的‘queuePush’
    const innerPush = new InnerProcess(queuePush);
    //推送消息
    innerPush.okMessage(pushData);

License

公司内部使用