|
@@ -100,6 +100,7 @@ public class SyncPersonTask extends AbstractTask implements Plugin {
|
|
|
public DataSet getChangePerson() {
|
|
|
//获取人员查询sql
|
|
|
StringBuilder sb = SyncUtil.getPersonQuerySql();
|
|
|
+ StringBuilder updatePartSb = SyncUtil.getPersonPartTimeChangeSql(startTime, endTime);
|
|
|
//修改日期
|
|
|
sb.append(" and (");
|
|
|
sb.append(" (to_char(person.fmodifytime,'yyyy-MM-dd hh24:mi:ss') <= '"+endTime+"' and to_char(person.fmodifytime,'yyyy-MM-dd hh24:mi:ss') >= '"+startTime+"' ) or \n");
|
|
@@ -115,7 +116,8 @@ public class SyncPersonTask extends AbstractTask implements Plugin {
|
|
|
sb.append(" (to_char(m.fmodifytime,'yyyy-MM-dd hh24:mi:ss') <= '"+endTime+"' and to_char(m.fmodifytime,'yyyy-MM-dd hh24:mi:ss') >= '"+startTime+"' ) or \n");
|
|
|
sb.append(" (to_char(pos.fmodifytime,'yyyy-MM-dd hh24:mi:ss') <= '"+endTime+"' and to_char(pos.fmodifytime,'yyyy-MM-dd hh24:mi:ss') >= '"+startTime+"' ) or \n");
|
|
|
sb.append(" (to_char(pos1.fmodifytime,'yyyy-MM-dd hh24:mi:ss') <= '"+endTime+"' and to_char(pos1.fmodifytime,'yyyy-MM-dd hh24:mi:ss') >= '"+startTime+"' ) or \n");
|
|
|
- sb.append(" (a.fid in (select fpersonid from t_hrpi_ermanfile where to_char(fmodifytime,'yyyy-MM-dd hh24:mi:ss') <= '"+endTime+"' and to_char(fmodifytime,'yyyy-MM-dd hh24:mi:ss') >= '"+startTime+"')) \n");
|
|
|
+ sb.append(" (a.fid in (select fpersonid from t_hrpi_ermanfile where to_char(fmodifytime,'yyyy-MM-dd hh24:mi:ss') <= '"+endTime+"' and to_char(fmodifytime,'yyyy-MM-dd hh24:mi:ss') >= '"+startTime+"')) or \n");
|
|
|
+ sb.append(" (a.fid in (" + updatePartSb.toString() + ") \n");
|
|
|
sb.append(" )");
|
|
|
log.info("-------- 查询人员sql :" + sb.toString() + " -------- ");
|
|
|
DataSet dataSet = DB.queryDataSet(this.getClass().getName(), DBRoute.of("hr"), sb.toString());
|