dept_ability
Normal
/
input_db_ip
172.17.0.1
input_db_port
27017
out_db_ip
172.17.0.1
out_db_name
ry
out_db_port
3306
out_db_pwd
sckjadmin
out_db_username
root
ID_BATCH
Y
ID_BATCH
CHANNEL_ID
Y
CHANNEL_ID
TRANSNAME
Y
TRANSNAME
STATUS
Y
STATUS
LINES_READ
Y
LINES_READ
LINES_WRITTEN
Y
LINES_WRITTEN
LINES_UPDATED
Y
LINES_UPDATED
LINES_INPUT
Y
LINES_INPUT
LINES_OUTPUT
Y
LINES_OUTPUT
LINES_REJECTED
Y
LINES_REJECTED
ERRORS
Y
ERRORS
STARTDATE
Y
STARTDATE
ENDDATE
Y
ENDDATE
LOGDATE
Y
LOGDATE
DEPDATE
Y
DEPDATE
REPLAYDATE
Y
REPLAYDATE
LOG_FIELD
Y
LOG_FIELD
EXECUTING_SERVER
N
EXECUTING_SERVER
EXECUTING_USER
N
EXECUTING_USER
CLIENT
N
CLIENT
ID_BATCH
Y
ID_BATCH
SEQ_NR
Y
SEQ_NR
LOGDATE
Y
LOGDATE
TRANSNAME
Y
TRANSNAME
STEPNAME
Y
STEPNAME
STEP_COPY
Y
STEP_COPY
LINES_READ
Y
LINES_READ
LINES_WRITTEN
Y
LINES_WRITTEN
LINES_UPDATED
Y
LINES_UPDATED
LINES_INPUT
Y
LINES_INPUT
LINES_OUTPUT
Y
LINES_OUTPUT
LINES_REJECTED
Y
LINES_REJECTED
ERRORS
Y
ERRORS
INPUT_BUFFER_ROWS
Y
INPUT_BUFFER_ROWS
OUTPUT_BUFFER_ROWS
Y
OUTPUT_BUFFER_ROWS
ID_BATCH
Y
ID_BATCH
CHANNEL_ID
Y
CHANNEL_ID
LOG_DATE
Y
LOG_DATE
LOGGING_OBJECT_TYPE
Y
LOGGING_OBJECT_TYPE
OBJECT_NAME
Y
OBJECT_NAME
OBJECT_COPY
Y
OBJECT_COPY
REPOSITORY_DIRECTORY
Y
REPOSITORY_DIRECTORY
FILENAME
Y
FILENAME
OBJECT_ID
Y
OBJECT_ID
OBJECT_REVISION
Y
OBJECT_REVISION
PARENT_CHANNEL_ID
Y
PARENT_CHANNEL_ID
ROOT_CHANNEL_ID
Y
ROOT_CHANNEL_ID
ID_BATCH
Y
ID_BATCH
CHANNEL_ID
Y
CHANNEL_ID
LOG_DATE
Y
LOG_DATE
TRANSNAME
Y
TRANSNAME
STEPNAME
Y
STEPNAME
STEP_COPY
Y
STEP_COPY
LINES_READ
Y
LINES_READ
LINES_WRITTEN
Y
LINES_WRITTEN
LINES_UPDATED
Y
LINES_UPDATED
LINES_INPUT
Y
LINES_INPUT
LINES_OUTPUT
Y
LINES_OUTPUT
LINES_REJECTED
Y
LINES_REJECTED
ERRORS
Y
ERRORS
LOG_FIELD
N
LOG_FIELD
ID_BATCH
Y
ID_BATCH
CHANNEL_ID
Y
CHANNEL_ID
LOG_DATE
Y
LOG_DATE
METRICS_DATE
Y
METRICS_DATE
METRICS_CODE
Y
METRICS_CODE
METRICS_DESCRIPTION
Y
METRICS_DESCRIPTION
METRICS_SUBJECT
Y
METRICS_SUBJECT
METRICS_TYPE
Y
METRICS_TYPE
METRICS_VALUE
Y
METRICS_VALUE
0.0
0.0
10000
50
50
N
Y
50000
Y
N
1000
100
-
2020/08/03 09:36:42.416
-
2020/08/03 09:36:42.416
H4sIAAAAAAAAAAMAAAAAAAAAAAA=
N
ry_ability
${out_db_ip}
MYSQL
Native
${out_db_name}
${out_db_port}
${out_db_username}
${out_db_pwd}
EXTRA_OPTION_MYSQL.characterEncoding
UTF-8
EXTRA_OPTION_MYSQL.defaultFetchSize
500
EXTRA_OPTION_MYSQL.useCursorFetch
true
FORCE_IDENTIFIERS_TO_LOWERCASE
N
FORCE_IDENTIFIERS_TO_UPPERCASE
N
IS_CLUSTERED
N
PORT_NUMBER
${out_db_port}
PRESERVE_RESERVED_WORD_CASE
Y
QUOTE_ALL_FIELDS
N
STREAM_RESULTS
Y
SUPPORTS_BOOLEAN_DATA_TYPE
Y
SUPPORTS_TIMESTAMP_DATA_TYPE
Y
USE_POOLING
N
dept_ability1
更新ability
Y
dept_ability 2
更新ability 2
Y
dept_ability3
更新ability 3
Y
dept_ability4
更新ability 4
Y
dept_ability5
更新ability 5
Y
dept_ability 2
MongoDbInput
Y
1
none
${input_db_ip}
${input_db_port}
N
info_admin
sys_dept
json
{ $match: {"level":'2',code:{$regex:"22"}} },
{ $lookup: { from: 'info', localField: '_id', foreignField: 'dept2', as: 'infos' } },
{ $unwind: { path: '$infos', preserveNullAndEmptyArrays: true } },
{ $unwind: { path: '$infos.status', preserveNullAndEmptyArrays: true } },
{ $match: { 'infos.status': '3' } },
{ $group:
{ _id: '$_id',
tyep_disability: {
$sum: {
$cond: [{ $eq: [ '$infos.ability', '失能' ] }, 1, 0 ],
},
},
},
},
{ $sort: { order: 1 } },
Encrypted
N
N
primary
N
Y
N
_id
$._id
String
tyep_disability
$.tyep_disability
Integer
240
240
Y
dept_ability1
MongoDbInput
Y
1
none
${input_db_ip}
${input_db_port}
N
info_admin
sys_dept
json
{ $match: {"level":'1',code:{$regex:"22"}} },
{ $lookup: { from: 'info', localField: '_id', foreignField: 'dept1', as: 'infos' } },
{ $unwind: { path: '$infos', preserveNullAndEmptyArrays: true } },
{ $unwind: { path: '$infos.status', preserveNullAndEmptyArrays: true } },
{ $match: { 'infos.status': '3' } },
{ $group:
{ _id: '$_id',
tyep_disability: {
$sum: {
$cond: [{ $eq: [ '$infos.ability', '失能' ] }, 1, 0 ],
},
},
},
},
{ $sort: { order: 1 } },
Encrypted
N
N
primary
N
Y
N
_id
$._id
String
tyep_disability
$.tyep_disability
Integer
240
128
Y
dept_ability3
MongoDbInput
Y
1
none
${input_db_ip}
${input_db_port}
N
info_admin
sys_dept
json
{ $match: {"level":'3',code:{$regex:"22"}} },
{ $lookup: { from: 'info', localField: '_id', foreignField: 'dept3', as: 'infos' } },
{ $unwind: { path: '$infos', preserveNullAndEmptyArrays: true } },
{ $unwind: { path: '$infos.status', preserveNullAndEmptyArrays: true } },
{ $match: { 'infos.status': '3' } },
{ $group:
{ _id: '$_id',
tyep_disability: {
$sum: {
$cond: [{ $eq: [ '$infos.ability', '失能' ] }, 1, 0 ],
},
},
},
},
{ $sort: { order: 1 } },
Encrypted
N
N
primary
N
Y
N
_id
$._id
String
tyep_disability
$.tyep_disability
Integer
240
368
Y
dept_ability4
MongoDbInput
Y
1
none
${input_db_ip}
${input_db_port}
N
info_admin
sys_dept
json
{ $match: {"level":'4',code:{$regex:"22"}} },
{ $lookup: { from: 'info', localField: '_id', foreignField: 'dept4', as: 'infos' } },
{ $unwind: { path: '$infos', preserveNullAndEmptyArrays: true } },
{ $unwind: { path: '$infos.status', preserveNullAndEmptyArrays: true } },
{ $match: { 'infos.status': '3' } },
{ $group:
{ _id: '$_id',
tyep_disability: {
$sum: {
$cond: [{ $eq: [ '$infos.ability', '失能' ] }, 1, 0 ],
},
},
},
},
{ $sort: { order: 1 } },
Encrypted
N
N
primary
N
Y
N
_id
$._id
String
tyep_disability
$.tyep_disability
Integer
240
496
Y
dept_ability5
MongoDbInput
Y
1
none
${input_db_ip}
${input_db_port}
N
info_admin
sys_dept
json
{ $match: {"level":'5',code:{$regex:"22"}} },
{ $lookup: { from: 'info', localField: '_id', foreignField: 'dept5', as: 'infos' } },
{ $unwind: { path: '$infos', preserveNullAndEmptyArrays: true } },
{ $unwind: { path: '$infos.status', preserveNullAndEmptyArrays: true } },
{ $match: { 'infos.status': '3' } },
{ $group:
{ _id: '$_id',
tyep_disability: {
$sum: {
$cond: [{ $eq: [ '$infos.ability', '失能' ] }, 1, 0 ],
},
},
},
},
{ $sort: { order: 1 } },
Encrypted
N
N
primary
N
Y
N
_id
$._id
String
tyep_disability
$.tyep_disability
Integer
240
656
Y
更新ability
Update
Y
1
none
ry_ability
N
20000
N
N
ry
_id
dept_id
=
tyep_disability
tyep_disability
560
128
Y
更新ability 2
Update
Y
1
none
ry_ability
N
20000
N
N
ry
_id
dept_id
=
tyep_disability
tyep_disability
560
240
Y
更新ability 3
Update
Y
1
none
ry_ability
N
20000
N
N
ry
_id
dept_id
=
tyep_disability
tyep_disability
560
368
Y
更新ability 4
Update
Y
1
none
ry_ability
N
20000
N
N
ry
_id
dept_id
=
tyep_disability
tyep_disability
560
496
Y
更新ability 5
Update
Y
1
none
ry_ability
N
20000
N
N
ry
_id
dept_id
=
tyep_disability
tyep_disability
560
656
Y
N