forked from chenlinzhong/php-delayqueue
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathadd.php
More file actions
94 lines (91 loc) · 3.16 KB
/
add.php
File metadata and controls
94 lines (91 loc) · 3.16 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
<?php
include 'DqMysql.php';
$op = $_GET['op'];
switch ($op){
case 'redis_add':
$data=array(
't_name'=>$_GET['t_name'],
't_content'=>$_GET['t_content'],
);
if($_GET['id']>0) {
if (DqMysql::updateData('dq_redis', $data,'id='.$_GET['id'])) {
echo json_encode(array('code' => 1, 'msg' => 'succ'));
} else {
echo json_encode(array('code' => 0, 'msg' => 'fail'));
}
}else{
if (DqMysql::insertData('dq_redis', $data)) {
echo json_encode(array('code' => 1, 'msg' => 'succ'));
} else {
echo json_encode(array('code' => 0, 'msg' => 'fail'));
}
}
break;
case 'topic_add':
$data=array(
't_name'=>$_GET['t_name'],
'delay'=>$_GET['delay'],
'callback'=>$_GET['callback'],
'timeout'=>$_GET['timeout'],
'email'=>$_GET['email'],
'topic'=>$_GET['topic'],
'createor'=>$_GET['createor'],
'method'=>$_GET['method'],
're_notify_flag'=>$_GET['re_notify_flag'],
);
if($_GET['id']>0) {
if (DqMysql::updateData('dq_topic', $data,'id='.$_GET['id'])) {
echo json_encode(array('code' => 1, 'msg' => 'succ'));
} else {
echo json_encode(array('code' => 0, 'msg' => 'fail'));
}
}else{
if (DqMysql::insertData('dq_topic', $data)) {
echo json_encode(array('code' => 1, 'msg' => 'succ'));
} else {
echo json_encode(array('code' => 0, 'msg' => 'fail'));
}
}
break;
case 'del':
$table = $_GET['table'];
$id = $_GET['id'];
if (DqMysql::delete($table, $id)) {
echo json_encode(array('code' => 1, 'msg' => 'succ'));
} else {
echo json_encode(array('code' => 0, 'msg' => 'fail'));
}
break;
case 'alert':
$data=array(
'host'=>$_GET['host'],
'port'=>$_GET['port'],
'user'=>$_GET['user'],
'pwd'=>$_GET['pwd'],
'ext'=>addslashes(json_encode($_GET['ext'])),
);
if(isset($_GET['id']) && $_GET['id']>0) {
if (DqMysql::updateData('dq_alert', $data,'id='.$_GET['id'])) {
echo json_encode(array('code' => 1, 'msg' => 'succ'));
} else {
echo json_encode(array('code' => 0, 'msg' => 'fail'));
}
}else{
if (DqMysql::insertData('dq_alert', $data)) {
echo json_encode(array('code' => 1, 'msg' => 'succ'));
} else {
echo json_encode(array('code' => 0, 'msg' => 'fail'));
}
}
break;
case 'update_status':
$table = $_GET['table'];
$id = $_GET['id'];
$arrData=array('status'=>$_GET['status']);
if (DqMysql::updateData($table,$arrData,'id='.$id)) {
echo json_encode(array('code' => 1, 'msg' => 'succ'));
} else {
echo json_encode(array('code' => 0, 'msg' => 'fail'));
}
break;
}