cmds func fin v1

This commit is contained in:
Jay 2018-07-02 23:02:48 +08:00
parent d6f1b81796
commit d7c64b3c65
4 changed files with 33 additions and 5 deletions

View File

@ -2,7 +2,8 @@
"versions":[
{"file": "main.sql", "version": 1},
{"file": "20180628-1.sql", "version": 2},
{"file": "20180628-2.sql", "version": 3}
{"file": "20180628-2.sql", "version": 3},
{"file": "20180702-1.sql", "version": 4}
],
"test": []
}

View File

@ -375,10 +375,15 @@ const delTwitch = async (txt = '', source = {}, db) => {
}
}
const hello = async () => {
return 'Hello World'
}
module.exports = {
addgroup: run.bind(null, addGroup),
addpage: run.bind(null, addPage),
delpage: run.bind(null, delPage),
addtwitch: run.bind(null, addTwitch),
deltwitch: run.bind(null, delTwitch)
deltwitch: run.bind(null, delTwitch),
hello: run.bind(null, hello)
}

View File

@ -15,11 +15,14 @@ const parseCMD = async (text = '', source = {}) => {
try {
let result = await db.query({
text: `select "message" from "public"."commands" where "cmd" = $1`,
values: [cmd]
text: `select "message", "group" from "public"."commands" where "cmd" = $1 and ("group" = '' or "group" = $2)`,
values: [cmd, source.groupId]
})
if (result.rowCount > 0) {
let content = result.rows[0].message
let obj = result.rows.filter(t => t.group === source.groupId)
if (obj.length === 0) obj = result.rows[0]
else obj = obj[0]
let content = obj.message
let m = content.match(/{{(.+?)}}/g)
if (m !== null && m.length > 0) {
for (let i = 0; i < m.length; i++) {

19
schema/20180702-1.sql Normal file
View File

@ -0,0 +1,19 @@
-- auto-generated definition
create table "public"."commands"
(
cmd varchar(200) not null
constraint commands_pkey
primary key,
message varchar(300) default '' :: character varying not null,
ctime timestamp with time zone default CURRENT_TIMESTAMP not null,
mtime timestamp with time zone default CURRENT_TIMESTAMP not null,
"group" varchar(100) default '' :: character varying not null
);
insert into "public"."commands" ("cmd", "message", "ctime", "mtime", "group") values
('addgroup', '{{addgroup}}', now(), now(), ''),
('addpage', '{{addpage}}', now(), now(), ''),
('delpage', '{{delpage}}', now(), now(), ''),
('addtwitch', '{{addtwitch}}', now(), now(), ''),
('deltwitch', '{{deltwitch}}', now(), now(), ''),
('hello', '{{hello}}', now(), now(), '');