GTsoft/mps-batch
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

初始插入员工数据时，添加create_by栏位

Browse Source
This commit is contained in:
CYQ 2025-09-24 22:42:18 +08:00
parent fe37c2a266
commit 9bcf6a5379
3 changed files with 12 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
MpsFormalBatch/src/main/java/com/gtsoft/mps/batch/processor/init/InitInsertProcessor.java
View File

@ -58,7 +58,7 @@ public class InitInsertProcessor extends AbstractBusinessProcessor {
String insertJbSql = String.format( String insertJbSql = String.format(
"INSERT INTO %s (" + "INSERT INTO %s (" +
" branch_name, branch_id, marketer_name, marketer_id_card, marketer_code," + " branch_name, branch_id, marketer_name, marketer_id_card, marketer_code," +
" marketer_position, record_date, tenant_id, create_dept,report_type,create_time) " + " marketer_position, record_date, tenant_id, create_dept,report_type,create_time,create_by) " +
"(SELECT " + "(SELECT " +
" DISTINCT " + " DISTINCT " +
" e.dept_name AS branch_name," + " e.dept_name AS branch_name," +
@ -71,7 +71,8 @@ public class InitInsertProcessor extends AbstractBusinessProcessor {
" b.tenant_id," + " b.tenant_id," +
" b.dept_id ," + " b.dept_id ," +
" 'm' ," + " 'm' ," +
" ? " + " ?, " +
" b.user_id " +
"FROM mps_market a " + "FROM mps_market a " +
"INNER JOIN sys_user b ON a.jb_id = b.mkt_no AND b.del_flag = '0' " + "INNER JOIN sys_user b ON a.jb_id = b.mkt_no AND b.del_flag = '0' " +
"LEFT JOIN sys_dept e ON b.dept_id = e.dept_id " + "LEFT JOIN sys_dept e ON b.dept_id = e.dept_id " +
@ -87,7 +88,7 @@ public class InitInsertProcessor extends AbstractBusinessProcessor {
String insertYxSql = String.format( String insertYxSql = String.format(
"INSERT INTO %s (" + "INSERT INTO %s (" +
" branch_name, branch_id, marketer_name, marketer_id_card, marketer_code," + " branch_name, branch_id, marketer_name, marketer_id_card, marketer_code," +
" marketer_position, record_date, tenant_id, create_dept,report_type,create_time) " + " marketer_position, record_date, tenant_id, create_dept,report_type,create_time,create_by) " +
"(SELECT " + "(SELECT " +
" DISTINCT " + " DISTINCT " +
" e.dept_name AS branch_name," + " e.dept_name AS branch_name," +
@ -100,7 +101,8 @@ public class InitInsertProcessor extends AbstractBusinessProcessor {
" b.tenant_id," + " b.tenant_id," +
" b.dept_id, " + " b.dept_id, " +
" 'm' ," + " 'm' ," +
" ? " + " ?, " +
" b.user_id " +
"FROM mps_market a " + "FROM mps_market a " +
"INNER JOIN sys_user b ON a.yx_id = b.mkt_no AND b.del_flag = '0' " + "INNER JOIN sys_user b ON a.yx_id = b.mkt_no AND b.del_flag = '0' " +
"LEFT JOIN sys_dept e ON b.dept_id = e.dept_id " + "LEFT JOIN sys_dept e ON b.dept_id = e.dept_id " +

10
MpsSimulationBatch/src/main/java/com/gtsoft/mps/batch/processor/BIZ000Processor.java
View File

@ -39,7 +39,7 @@ public class BIZ000Processor extends AbstractBusinessProcessor {
String insertJbSql = String insertJbSql =
"INSERT INTO marketing_performance (" + "INSERT INTO marketing_performance (" +
" branch_name, branch_id, marketer_name, marketer_id_card, marketer_code," + " branch_name, branch_id, marketer_name, marketer_id_card, marketer_code," +
" marketer_position, record_date, tenant_id, create_dept,report_type,create_time) " + " marketer_position, record_date, tenant_id, create_dept,report_type,create_time,create_by) " +
"(SELECT " + "(SELECT " +
" DISTINCT " + " DISTINCT " +
" e.dept_name AS branch_name," + " e.dept_name AS branch_name," +
@ -52,7 +52,8 @@ public class BIZ000Processor extends AbstractBusinessProcessor {
" b.tenant_id," + " b.tenant_id," +
" b.dept_id ," + " b.dept_id ," +
" 'd' ," + " 'd' ," +
" ? " + " ?, " +
" b.user_id " +
"FROM mps_market a " + "FROM mps_market a " +
"INNER JOIN sys_user b ON a.jb_id = b.mkt_no AND b.del_flag = '0' " + "INNER JOIN sys_user b ON a.jb_id = b.mkt_no AND b.del_flag = '0' " +
"LEFT JOIN sys_dept e ON b.dept_id = e.dept_id " + "LEFT JOIN sys_dept e ON b.dept_id = e.dept_id " +
@ -67,7 +68,7 @@ public class BIZ000Processor extends AbstractBusinessProcessor {
String insertYxSql = String insertYxSql =
"INSERT INTO marketing_performance (" + "INSERT INTO marketing_performance (" +
" branch_name, branch_id, marketer_name, marketer_id_card, marketer_code," + " branch_name, branch_id, marketer_name, marketer_id_card, marketer_code," +
" marketer_position, record_date, tenant_id, create_dept,report_type,create_time) " + " marketer_position, record_date, tenant_id, create_dept,report_type,create_time,create_by) " +
"(SELECT " + "(SELECT " +
" DISTINCT " + " DISTINCT " +
" e.dept_name AS branch_name," + " e.dept_name AS branch_name," +
@ -80,7 +81,8 @@ public class BIZ000Processor extends AbstractBusinessProcessor {
" b.tenant_id," + " b.tenant_id," +
" b.dept_id, " + " b.dept_id, " +
" 'd' ," + " 'd' ," +
" ? " + " ?, " +
" b.user_id " +
"FROM mps_market a " + "FROM mps_market a " +
"INNER JOIN sys_user b ON a.yx_id = b.mkt_no AND b.del_flag = '0' " + "INNER JOIN sys_user b ON a.yx_id = b.mkt_no AND b.del_flag = '0' " +
"LEFT JOIN sys_dept e ON b.dept_id = e.dept_id " + "LEFT JOIN sys_dept e ON b.dept_id = e.dept_id " +

BIN
MpsSimulationBatch/target/classes/com/gtsoft/mps/batch/processor/BusinessProcessorFactory.class
View File

Binary file not shown.