1
1
var request = require ( "request" ) ;
2
- module . exports = function ( RED ) {
3
2
4
- function Dispatcher ( config ) {
3
+ module . exports = function ( RED ) {
4
+ function DataCollection ( config ) {
5
+
5
6
RED . nodes . createNode ( this , config ) ;
6
7
var node = this ;
7
8
var context = this . context ( ) ;
8
9
node . rules = config . rules ;
9
10
node . collect = config . collect ;
10
11
11
- this . on ( 'input' , function ( msg ) {
12
-
12
+ this . on ( 'input' , function ( msg ) {
13
13
14
14
var rules = node . rules ;
15
15
var collect = node . collect ;
16
- console . log ( collect ) ;
17
16
var output = [ ] ;
18
17
19
18
if ( collect == "query" )
@@ -31,18 +30,19 @@ module.exports = function (RED) {
31
30
msg . payload = rules [ context . get ( "dataCount" ) ] . topic ;
32
31
context . set ( "dataCount" , context . get ( "dataCount" ) - 1 ) ;
33
32
node . send ( output ) ;
34
- } else if ( context . get ( "dataCount" ) > - 1 ) {
35
- output [ 0 ] = msg ;
36
- output [ 1 ] = null ;
37
- var query = context . get ( "query" ) ;
38
- query [ rules [ context . get ( "dataCount" ) + 1 ] . topic2 ] = msg . payload . content ;
39
- context . set ( "query" , query ) ;
40
-
41
- msg . payload = rules [ context . get ( "dataCount" ) ] . topic ;
42
- context . set ( "dataCount" , context . get ( "dataCount" ) - 1 ) ;
33
+ }
34
+ else if ( context . get ( "dataCount" ) > - 1 ) {
35
+ output [ 0 ] = msg ;
36
+ output [ 1 ] = null ;
37
+ var query = context . get ( "query" ) ;
38
+ query [ rules [ context . get ( "dataCount" ) + 1 ] . topic2 ] = msg . payload . content ;
39
+ context . set ( "query" , query ) ;
43
40
44
- node . send ( output ) ;
45
- } else {
41
+ msg . payload = rules [ context . get ( "dataCount" ) ] . topic ;
42
+ context . set ( "dataCount" , context . get ( "dataCount" ) - 1 ) ;
43
+ node . send ( output ) ;
44
+ }
45
+ else {
46
46
output [ 0 ] = null ;
47
47
output [ 1 ] = msg ;
48
48
var query = context . get ( "query" ) ;
@@ -69,18 +69,20 @@ module.exports = function (RED) {
69
69
msg . payload = rules [ context . get ( "dataCount" ) ] . topic ;
70
70
context . set ( "dataCount" , context . get ( "dataCount" ) - 1 ) ;
71
71
node . send ( output ) ;
72
- } else if ( context . get ( "dataCount" ) > - 1 ) {
73
- output [ 0 ] = msg ;
74
- output [ 1 ] = null ;
75
- var userData = context . get ( "userData" ) ;
76
- userData [ rules [ context . get ( "dataCount" ) + 1 ] . topic2 ] = msg . payload . content ;
77
- context . set ( "userData" , userData ) ;
72
+ }
73
+ else if ( context . get ( "dataCount" ) > - 1 ) {
74
+ output [ 0 ] = msg ;
75
+ output [ 1 ] = null ;
76
+ var userData = context . get ( "userData" ) ;
77
+ userData [ rules [ context . get ( "dataCount" ) + 1 ] . topic2 ] = msg . payload . content ;
78
+ context . set ( "userData" , userData ) ;
78
79
79
- msg . payload = rules [ context . get ( "dataCount" ) ] . topic ;
80
- context . set ( "dataCount" , context . get ( "dataCount" ) - 1 ) ;
80
+ msg . payload = rules [ context . get ( "dataCount" ) ] . topic ;
81
+ context . set ( "dataCount" , context . get ( "dataCount" ) - 1 ) ;
81
82
82
- node . send ( output ) ;
83
- } else { //輸出第二個分支
83
+ node . send ( output ) ;
84
+ }
85
+ else {
84
86
output [ 0 ] = null ;
85
87
output [ 1 ] = msg ;
86
88
var userData = context . get ( "userData" ) ;
@@ -90,10 +92,7 @@ module.exports = function (RED) {
90
92
context . set ( "dataCount" , null ) ;
91
93
node . send ( output ) ;
92
94
}
93
-
94
-
95
95
} ) ;
96
96
}
97
-
98
- RED . nodes . registerType ( 'FCF-DataCollection' , Dispatcher ) ;
97
+ RED . nodes . registerType ( 'FCF-DataCollection' , DataCollection ) ;
99
98
} ;
0 commit comments