Skip to content

K
kettle_yuejuan_new
Commit 1c5d7c70 by zsy
Options

zsy

parent 4b6ab3c0
Showing with 337 additions and 94 deletions
monitor_intelligent_test/union_yuejuan_monitor/transfer/core.kjb
......@@ -7,7 +7,7 @@
<created_user/>
<created_date>2020/10/27 07:07:11.144</created_date>
<modified_user>admin</modified_user>
<modified_date>2020/10/27 07:25:21.524</modified_date>
<modified_date>2020/10/27 13:22:40.160</modified_date>
<parameters>
</parameters>
<connection>
......@@ -371,8 +371,8 @@
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>1504</xloc>
<yloc>64</yloc>
<xloc>1456</xloc>
<yloc>496</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -410,8 +410,8 @@
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>1328</xloc>
<yloc>176</yloc>
<xloc>1296</xloc>
<yloc>400</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -432,8 +432,8 @@
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>608</xloc>
<yloc>368</yloc>
<xloc>128</xloc>
<yloc>400</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -469,8 +469,8 @@
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>480</xloc>
<yloc>368</yloc>
<xloc>128</xloc>
<yloc>592</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -481,8 +481,8 @@
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>608</xloc>
<yloc>480</yloc>
<xloc>256</xloc>
<yloc>688</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -520,8 +520,8 @@
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>480</xloc>
<yloc>480</yloc>
<xloc>128</xloc>
<yloc>688</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -542,8 +542,8 @@
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>32</xloc>
<yloc>64</yloc>
<xloc>64</xloc>
<yloc>128</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -579,8 +579,8 @@
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>1328</xloc>
<yloc>368</yloc>
<xloc>1008</xloc>
<yloc>400</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -618,8 +618,8 @@
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>624</xloc>
<yloc>64</yloc>
<xloc>560</xloc>
<yloc>128</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -641,7 +641,7 @@
<draw>Y</draw>
<nr>0</nr>
<xloc>208</xloc>
<yloc>64</yloc>
<yloc>128</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -653,7 +653,7 @@
<draw>Y</draw>
<nr>0</nr>
<xloc>256</xloc>
<yloc>160</yloc>
<yloc>208</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -674,8 +674,8 @@
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>768</xloc>
<yloc>64</yloc>
<xloc>704</xloc>
<yloc>128</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -711,8 +711,8 @@
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>880</xloc>
<yloc>368</yloc>
<xloc>512</xloc>
<yloc>400</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -748,8 +748,8 @@
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>896</xloc>
<yloc>64</yloc>
<xloc>800</xloc>
<yloc>128</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -787,8 +787,8 @@
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>1168</xloc>
<yloc>368</yloc>
<xloc>864</xloc>
<yloc>400</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -838,7 +838,7 @@
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>1328</xloc>
<xloc>1008</xloc>
<yloc>480</yloc>
<attributes_kjc/>
</entry>
......@@ -860,8 +860,8 @@
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>1040</xloc>
<yloc>368</yloc>
<xloc>672</xloc>
<yloc>400</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -899,8 +899,8 @@
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>736</xloc>
<yloc>368</yloc>
<xloc>336</xloc>
<yloc>400</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -911,8 +911,8 @@
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>1072</xloc>
<yloc>480</yloc>
<xloc>656</xloc>
<yloc>496</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -950,8 +950,8 @@
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>880</xloc>
<yloc>480</yloc>
<xloc>512</xloc>
<yloc>496</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -971,8 +971,8 @@ values (3,'${stage}',0);</sql>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>432</xloc>
<yloc>160</yloc>
<xloc>400</xloc>
<yloc>208</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -983,8 +983,8 @@ values (3,'${stage}',0);</sql>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>48</xloc>
<yloc>528</yloc>
<xloc>496</xloc>
<yloc>592</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -1020,8 +1020,8 @@ values (3,'${stage}',0);</sql>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>432</xloc>
<yloc>64</yloc>
<xloc>400</xloc>
<yloc>128</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -1059,8 +1059,8 @@ values (3,'${stage}',0);</sql>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>48</xloc>
<yloc>368</yloc>
<xloc>320</xloc>
<yloc>592</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -1098,8 +1098,8 @@ values (3,'${stage}',0);</sql>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>1024</xloc>
<yloc>64</yloc>
<xloc>928</xloc>
<yloc>128</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -1110,8 +1110,8 @@ values (3,'${stage}',0);</sql>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>768</xloc>
<yloc>160</yloc>
<xloc>624</xloc>
<yloc>208</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -1149,8 +1149,8 @@ values (3,'${stage}',0);</sql>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>896</xloc>
<yloc>160</yloc>
<xloc>800</xloc>
<yloc>208</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -1171,8 +1171,8 @@ values (3,'${stage}',0);</sql>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>1328</xloc>
<yloc>272</yloc>
<xloc>1136</xloc>
<yloc>400</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -1208,8 +1208,20 @@ where b.id is null;</sql>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>1328</xloc>
<yloc>64</yloc>
<xloc>1456</xloc>
<yloc>400</yloc>
<attributes_kjc/>
</entry>
<entry>
<name>成功 3</name>
<description/>
<type>SUCCESS</type>
<attributes/>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>1296</xloc>
<yloc>496</yloc>
<attributes_kjc/>
</entry>
<entry>
......@@ -1230,20 +1242,183 @@ where b.id is null;</sql>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>1184</xloc>
<yloc>64</yloc>
<xloc>1456</xloc>
<yloc>320</yloc>
<attributes_kjc/>
</entry>
<entry>
<name>成功 3</name>
<name>stage_is_success</name>
<description/>
<type>SET_VARIABLES</type>
<attributes/>
<replacevars>Y</replacevars>
<filename/>
<file_variable_type>ROOT_JOB</file_variable_type>
<fields>
<field>
<variable_name>stage</variable_name>
<variable_value>is_success</variable_value>
<variable_type>ROOT_JOB</variable_type>
</field>
</fields>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>1088</xloc>
<yloc>128</yloc>
<attributes_kjc/>
</entry>
<entry>
<name>set_variable</name>
<description/>
<type>TRANS</type>
<attributes/>
<specification_method>rep_name</specification_method>
<trans_object_id/>
<filename/>
<transname>set_variable</transname>
<directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/total_control/set_variable</directory>
<arg_from_previous>N</arg_from_previous>
<params_from_previous>N</params_from_previous>
<exec_per_row>N</exec_per_row>
<clear_rows>N</clear_rows>
<clear_files>N</clear_files>
<set_logfile>N</set_logfile>
<logfile/>
<logext/>
<add_date>N</add_date>
<add_time>N</add_time>
<loglevel>Basic</loglevel>
<cluster>N</cluster>
<slave_server_name/>
<set_append_logfile>N</set_append_logfile>
<wait_until_finished>Y</wait_until_finished>
<follow_abort_remote>N</follow_abort_remote>
<create_parent_folder>N</create_parent_folder>
<logging_remote_work>N</logging_remote_work>
<run_configuration>Pentaho local</run_configuration>
<parameters>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>1216</xloc>
<yloc>128</yloc>
<attributes_kjc/>
</entry>
<entry>
<name>检验字段的值</name>
<description/>
<type>SIMPLE_EVAL</type>
<attributes/>
<valuetype>variable</valuetype>
<fieldname/>
<variablename>is_run</variablename>
<fieldtype>number</fieldtype>
<mask/>
<comparevalue>0</comparevalue>
<minvalue/>
<maxvalue/>
<successcondition>equal</successcondition>
<successnumbercondition>greater</successnumbercondition>
<successbooleancondition>false</successbooleancondition>
<successwhenvarset>N</successwhenvarset>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>1456</xloc>
<yloc>128</yloc>
<attributes_kjc/>
</entry>
<entry>
<name>write_log_success 3 2</name>
<description/>
<type>TRANS</type>
<attributes/>
<specification_method>rep_name</specification_method>
<trans_object_id/>
<filename/>
<transname>write_log_success</transname>
<directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/total_control</directory>
<arg_from_previous>N</arg_from_previous>
<params_from_previous>N</params_from_previous>
<exec_per_row>N</exec_per_row>
<clear_rows>N</clear_rows>
<clear_files>N</clear_files>
<set_logfile>N</set_logfile>
<logfile/>
<logext/>
<add_date>N</add_date>
<add_time>N</add_time>
<loglevel>Basic</loglevel>
<cluster>N</cluster>
<slave_server_name/>
<set_append_logfile>N</set_append_logfile>
<wait_until_finished>Y</wait_until_finished>
<follow_abort_remote>N</follow_abort_remote>
<create_parent_folder>N</create_parent_folder>
<logging_remote_work>N</logging_remote_work>
<run_configuration>Pentaho local</run_configuration>
<parameters>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>1456</xloc>
<yloc>240</yloc>
<attributes_kjc/>
</entry>
<entry>
<name>write_log_unsuccess 3 2</name>
<description/>
<type>TRANS</type>
<attributes/>
<specification_method>rep_name</specification_method>
<trans_object_id/>
<filename/>
<transname>write_log_unsuccess</transname>
<directory>/monitor_intelligent_test/union_yuejuan_monitor/transfer/total_control</directory>
<arg_from_previous>N</arg_from_previous>
<params_from_previous>N</params_from_previous>
<exec_per_row>N</exec_per_row>
<clear_rows>N</clear_rows>
<clear_files>N</clear_files>
<set_logfile>N</set_logfile>
<logfile/>
<logext/>
<add_date>N</add_date>
<add_time>N</add_time>
<loglevel>Basic</loglevel>
<cluster>N</cluster>
<slave_server_name/>
<set_append_logfile>N</set_append_logfile>
<wait_until_finished>Y</wait_until_finished>
<follow_abort_remote>N</follow_abort_remote>
<create_parent_folder>N</create_parent_folder>
<logging_remote_work>N</logging_remote_work>
<run_configuration>Pentaho local</run_configuration>
<parameters>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>1456</xloc>
<yloc>32</yloc>
<attributes_kjc/>
</entry>
<entry>
<name>成功 3 2</name>
<description/>
<type>SUCCESS</type>
<attributes/>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>1504</xloc>
<yloc>160</yloc>
<xloc>1312</xloc>
<yloc>32</yloc>
<attributes_kjc/>
</entry>
</entries>
......@@ -1285,24 +1460,6 @@ where b.id is null;</sql>
<unconditional>Y</unconditional>
</hop>
<hop>
<from>write_log_success 2</from>
<to>stage_del_log</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>stage_del_log</from>
<to>insert_del_log</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>insert_del_log</from>
<to>write_log_success 3</to>
<from_nr>0</from_nr>
......@@ -1527,6 +1684,78 @@ where b.id is null;</sql>
<evaluation>N</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>write_log_success 2</from>
<to>stage_is_success</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>stage_is_success</from>
<to>set_variable</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>stage_del_log</from>
<to>insert_del_log</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>set_variable</from>
<to>检验字段的值</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>检验字段的值</from>
<to>write_log_success 3 2</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>检验字段的值</from>
<to>write_log_unsuccess 3 2</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>N</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>write_log_unsuccess 3 2</from>
<to>成功 3 2</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>write_log_success 3 2</from>
<to>stage_del_log</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
</hops>
<notepads>
</notepads>
......
monitor_intelligent_test/union_yuejuan_monitor/transfer/roll_back/delete_source_process.ktr
......@@ -428,7 +428,7 @@
<created_user/>
<created_date>2020/10/27 07:07:09.772</created_date>
<modified_user>admin</modified_user>
<modified_date>2020/10/27 07:16:44.432</modified_date>
<modified_date>2020/10/27 13:23:40.726</modified_date>
<key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
<is_key_private>N</is_key_private>
</info>
......@@ -506,9 +506,6 @@
<sql>delete from union_yuejuan_source_process.bus_objective_question_config where id in (select id from union_yuejuan_source.bus_objective_question_config);
delete from union_yuejuan_source_process.bus_subjective_question_config where id in (select id from union_yuejuan_source.bus_subjective_question_config);
delete from union_yuejuan_source_process.dic_question_type where id in (select id from union_yuejuan_source.dic_question_type);
delete from union_yuejuan_source_process.bus_marking_task_config;
delete from union_yuejuan_source_process.bus_marking_judgment_task;
delete from union_yuejuan_source_process.bus_marking_teacher_task;
-----------
-----------
delete from union_yuejuan_source_process.bus_student_obj_ques_score where id in (select id from union_yuejuan_source.bus_student_obj_ques_score);
......
monitor_intelligent_test/union_yuejuan_monitor/transfer/source_process/bus_marking_judgment_task.ktr
......@@ -428,7 +428,7 @@
<created_user/>
<created_date>2020/10/27 07:07:10.249</created_date>
<modified_user>admin</modified_user>
<modified_date>2020/10/27 07:21:16.621</modified_date>
<modified_date>2020/10/27 13:21:57.253</modified_date>
<key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
<is_key_private>N</is_key_private>
</info>
......@@ -503,7 +503,10 @@
<single_statement>N</single_statement>
<replace_variables>N</replace_variables>
<quoteString>N</quoteString>
<sql>insert into union_yuejuan_source_process.bus_marking_judgment_task(
<sql>begin;
delete from union_yuejuan_source_process.bus_marking_judgment_task;
insert into union_yuejuan_source_process.bus_marking_judgment_task(
id,
question_config_id,
marking_config_id,
......@@ -525,7 +528,9 @@ create_id,
create_time,
modify_id,
modify_time
from union_yuejuan_source.bus_marking_judgment_task</sql>
from union_yuejuan_source.bus_marking_judgment_task;
end;</sql>
<set_params>N</set_params>
<insert_field/>
<update_field/>
......
monitor_intelligent_test/union_yuejuan_monitor/transfer/source_process/bus_marking_task_config.ktr
......@@ -428,7 +428,7 @@
<created_user/>
<created_date>2020/10/27 07:07:10.281</created_date>
<modified_user>admin</modified_user>
<modified_date>2020/10/27 07:21:04.651</modified_date>
<modified_date>2020/10/27 13:13:34.174</modified_date>
<key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
<is_key_private>N</is_key_private>
</info>
......@@ -503,7 +503,12 @@
<single_statement>N</single_statement>
<replace_variables>N</replace_variables>
<quoteString>N</quoteString>
<sql>insert into union_yuejuan_source_process.bus_marking_task_config(
<sql>begin;
delete from union_yuejuan_source_process.bus_marking_task_config;
insert into union_yuejuan_source_process.bus_marking_task_config(
id,
exam_id,
subject_id,
......@@ -535,7 +540,9 @@ create_id,
create_time,
modify_id,
modify_time
from union_yuejuan_source.bus_marking_task_config</sql>
from union_yuejuan_source.bus_marking_task_config;
end;</sql>
<set_params>N</set_params>
<insert_field/>
<update_field/>
......
monitor_intelligent_test/union_yuejuan_monitor/transfer/source_process/bus_marking_teacher_task.ktr
......@@ -428,7 +428,7 @@
<created_user/>
<created_date>2020/10/27 07:07:10.294</created_date>
<modified_user>admin</modified_user>
<modified_date>2020/10/27 07:20:52.815</modified_date>
<modified_date>2020/10/27 13:22:14.853</modified_date>
<key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
<is_key_private>N</is_key_private>
</info>
......@@ -503,7 +503,10 @@
<single_statement>N</single_statement>
<replace_variables>N</replace_variables>
<quoteString>N</quoteString>
<sql>insert into union_yuejuan_source_process.bus_marking_teacher_task(
<sql>begin;
delete from union_yuejuan_source_process.bus_marking_teacher_task;
insert into union_yuejuan_source_process.bus_marking_teacher_task(
id,
question_config_id,
marking_config_id,
......@@ -529,7 +532,9 @@ create_id,
create_time,
modify_id,
modify_time
from union_yuejuan_source.bus_marking_teacher_task</sql>
from union_yuejuan_source.bus_marking_teacher_task;
end;</sql>
<set_params>N</set_params>
<insert_field/>
<update_field/>
......
monitor_intelligent_test/union_yuejuan_monitor/transfer/total_control/gp_time/gp_time_interval.kjb
......@@ -7,7 +7,7 @@
<created_user/>
<created_date>2020/10/27 07:07:11.267</created_date>
<modified_user>admin</modified_user>
<modified_date>2020/10/27 07:24:39.553</modified_date>
<modified_date>2020/10/27 11:15:34.686</modified_date>
<parameters>
</parameters>
<connection>
......
monitor_intelligent_test/union_yuejuan_monitor/transfer/total_control/gp_time/set_variable_end_time.ktr
......@@ -428,7 +428,7 @@
<created_user/>
<created_date>2020/10/27 07:07:10.565</created_date>
<modified_user>admin</modified_user>
<modified_date>2020/10/27 07:24:30.915</modified_date>
<modified_date>2020/10/27 11:15:30.952</modified_date>
<key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
<is_key_private>N</is_key_private>
</info>
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment