|
|
@@ -14,6 +14,7 @@ import kd.bos.servicehelper.QueryServiceHelper;
|
|
|
import kd.bos.servicehelper.operation.SaveServiceHelper;
|
|
|
import kd.bos.util.StringUtils;
|
|
|
import kd.sdk.plugin.Plugin;
|
|
|
+import nckd.jxccl.base.common.constant.FormConstant;
|
|
|
|
|
|
|
|
|
import java.math.BigDecimal;
|
|
|
@@ -76,14 +77,13 @@ public class DelayedRetirementDateCalcTask extends AbstractTask implements Plug
|
|
|
// 将 Instant 转换回 Date
|
|
|
Date ninetyDaysAgoDate = Date.from(ninetyDaysAgoInstant);
|
|
|
//取员工档案
|
|
|
- String billKey = "hcsi_sinsurfile";
|
|
|
QFilter filter1 = new QFilter("iscurrentversion", QCP.equals, true); // 启用
|
|
|
QFilter filter2 = new QFilter("datastatus", QCP.equals, "1"); // 启用
|
|
|
QFilter filter3 = new QFilter("nckd_legaldate", QCP.large_equals, currentDate);
|
|
|
QFilter filter4 = new QFilter("nckd_legaldate", QCP.less_equals, ninetyDaysAgoDate);
|
|
|
|
|
|
String selectFields="id,employee.id,employee.number,employee.name,certificatenumber,nckd_recorddate,nckd_legaldate,nckd_newlegaldate";
|
|
|
- DynamicObject[] recordDyn = BusinessDataServiceHelper.load(billKey, selectFields, new QFilter[]{filter1.and(filter2).and(filter3).and(filter4)});
|
|
|
+ DynamicObject[] recordDyn = BusinessDataServiceHelper.load(FormConstant.HCSI_SINSURFILE, selectFields, new QFilter[]{filter1.and(filter2).and(filter3).and(filter4)});
|
|
|
|
|
|
Map<Long, DynamicObject> employeeFileMaps = Arrays.stream(recordDyn).collect(
|
|
|
Collectors.toMap(
|
|
|
@@ -102,7 +102,7 @@ public class DelayedRetirementDateCalcTask extends AbstractTask implements Plug
|
|
|
QFilter filter10 = new QFilter("postype.id", QCP.equals, 1010L); //主任职
|
|
|
|
|
|
String selectFields1 = "id,employee.id,company.id";
|
|
|
- DynamicObjectCollection empposorgreDyns = QueryServiceHelper.query("hrpi_empposorgrel", selectFields1, new QFilter[]{filter7 ,filter8,filter9,filter10});
|
|
|
+ DynamicObjectCollection empposorgreDyns = QueryServiceHelper.query(FormConstant.HRPI_EMPPOSORGREL, selectFields1, new QFilter[]{filter7 ,filter8,filter9,filter10});
|
|
|
|
|
|
Map<Long, DynamicObject> empposorgreMap = (Map)empposorgreDyns.stream().collect(Collectors.toMap((obj) -> {
|
|
|
return obj.getLong("employee.id");
|
|
|
@@ -118,7 +118,7 @@ public class DelayedRetirementDateCalcTask extends AbstractTask implements Plug
|
|
|
QFilter filter12 = new QFilter("credentialstype.id", QCP.equals, 1010L); // 启用
|
|
|
QFilter filter13 = new QFilter("employee.id", QCP.in, employeeIDs);
|
|
|
String selectFields2="id,employee.id,number,birthday";
|
|
|
- DynamicObjectCollection personDyns = QueryServiceHelper.query("hrpi_percre", selectFields2,new QFilter[]{ filter12, filter13});
|
|
|
+ DynamicObjectCollection personDyns = QueryServiceHelper.query(FormConstant.HRPI_PERCRE, selectFields2,new QFilter[]{ filter12, filter13});
|
|
|
|
|
|
Map<Long, DynamicObject> personMap = (Map)personDyns.stream().collect(Collectors.toMap((obj) -> {
|
|
|
return obj.getLong("employee.id");
|
|
|
@@ -134,7 +134,7 @@ public class DelayedRetirementDateCalcTask extends AbstractTask implements Plug
|
|
|
QFilter filter23 = new QFilter("employee.id", QCP.in, employeeIDs);
|
|
|
|
|
|
String selectFields3="id,employee.id,laborrelstatus.id";
|
|
|
- DynamicObjectCollection empentrelDyns = QueryServiceHelper.query("hrpi_empentrel", selectFields3,new QFilter[]{filter21, filter22, filter23});
|
|
|
+ DynamicObjectCollection empentrelDyns = QueryServiceHelper.query(FormConstant.HRPI_EMPENTREL, selectFields3,new QFilter[]{filter21, filter22, filter23});
|
|
|
|
|
|
Map<Long, DynamicObject> empentrelMap = (Map)empentrelDyns.stream().collect(Collectors.toMap((obj) -> {
|
|
|
return obj.getLong("employee.id");
|
|
|
@@ -146,7 +146,7 @@ public class DelayedRetirementDateCalcTask extends AbstractTask implements Plug
|
|
|
|
|
|
//查退休人员信息数据
|
|
|
QFilter qFilter = new QFilter("nckd_person.id", QCP.in, employeeIDs);
|
|
|
- List<Object> listIDs = QueryServiceHelper.queryPrimaryKeys("nckd_retirewarning",new QFilter[]{qFilter}, null, Integer.MAX_VALUE);
|
|
|
+ List<Object> listIDs = QueryServiceHelper.queryPrimaryKeys(FormConstant.NCKD_RETIREWARNING,new QFilter[]{qFilter}, null, Integer.MAX_VALUE);
|
|
|
DynamicObject retirewarnDyn = BusinessDataServiceHelper.newDynamicObject("nckd_retirewarning");
|
|
|
DynamicObject[] retirewarnDyns = BusinessDataServiceHelper.load(listIDs.toArray(),retirewarnDyn.getDynamicObjectType());
|
|
|
|
|
|
@@ -236,13 +236,12 @@ public class DelayedRetirementDateCalcTask extends AbstractTask implements Plug
|
|
|
// 将 Instant 转换回 Date
|
|
|
Date threeDaysAgoDate = Date.from(threeDaysAgoInstant);
|
|
|
//取员工档案
|
|
|
- String billKey = "hcsi_sinsurfile";
|
|
|
QFilter filter1 = new QFilter("iscurrentversion", QCP.equals, true); // 启用
|
|
|
QFilter filter2 = new QFilter("datastatus", QCP.equals, "1"); // 启用
|
|
|
QFilter filter5 = new QFilter("modifytime", QCP.large_equals, threeDaysAgoDate);
|
|
|
|
|
|
String selectFields="id,employee.id,employee.number,nckd_recorddate,nckd_legaldate,nckd_newlegaldate";
|
|
|
- DynamicObject[] datas = BusinessDataServiceHelper.load(billKey, selectFields, new QFilter[]{filter1.and(filter2).and(filter5)});
|
|
|
+ DynamicObject[] datas = BusinessDataServiceHelper.load(FormConstant.HCSI_SINSURFILE, selectFields, new QFilter[]{filter1.and(filter2).and(filter5)});
|
|
|
|
|
|
Map<Long, DynamicObject> employeeFileMaps = Arrays.stream(datas).collect(
|
|
|
Collectors.toMap(
|
|
|
@@ -475,7 +474,7 @@ public class DelayedRetirementDateCalcTask extends AbstractTask implements Plug
|
|
|
QFilter filter13 = new QFilter("employee.id", QCP.in, employeeIDs);
|
|
|
// 查人员基础信息中的性别
|
|
|
String selectFields2="id,employee.id,nckd_totalmon";
|
|
|
- DynamicObjectCollection personDyns = QueryServiceHelper.query("nckd_hrpi_specwrklog", selectFields2,new QFilter[]{filter11, filter13});
|
|
|
+ DynamicObjectCollection personDyns = QueryServiceHelper.query(FormConstant.NCKD_HRPI_SPECWRKLOG, selectFields2,new QFilter[]{filter11, filter13});
|
|
|
|
|
|
Map<Long, DynamicObject> specialWorkersMap = (Map)personDyns.stream().collect(Collectors.toMap((obj) -> {
|
|
|
return obj.getLong("employee.id");
|
|
|
@@ -499,7 +498,7 @@ public class DelayedRetirementDateCalcTask extends AbstractTask implements Plug
|
|
|
QFilter filter9 = new QFilter("employee.id", QCP.in, employeeIDs);
|
|
|
|
|
|
String selectFields1 = "id,employee.id,employee.number,position.nckd_jobseq.number";
|
|
|
- DynamicObjectCollection empposorgreDyns = QueryServiceHelper.query("hrpi_empposorgrel", selectFields1, new QFilter[]{filter7 ,filter9});
|
|
|
+ DynamicObjectCollection empposorgreDyns = QueryServiceHelper.query(FormConstant.HRPI_EMPPOSORGREL, selectFields1, new QFilter[]{filter7 ,filter9});
|
|
|
|
|
|
Map<Long, DynamicObject> empposorgreMap = (Map)empposorgreDyns.stream().collect(Collectors.toMap((obj) -> {
|
|
|
return obj.getLong("employee.id");
|
|
|
@@ -522,7 +521,7 @@ public class DelayedRetirementDateCalcTask extends AbstractTask implements Plug
|
|
|
QFilter filter13 = new QFilter("id", QCP.in, employeeIDs);
|
|
|
// 查人员基础信息中的性别
|
|
|
String selectFields2="id,number,name,birthday,gender.masterid";
|
|
|
- DynamicObjectCollection personDyns = QueryServiceHelper.query("hrpi_employee", selectFields2,new QFilter[]{filter11, filter12, filter13});
|
|
|
+ DynamicObjectCollection personDyns = QueryServiceHelper.query(FormConstant.HRPI_EMPLOYEE, selectFields2,new QFilter[]{filter11, filter12, filter13});
|
|
|
|
|
|
Map<Long, DynamicObject> personMap = (Map)personDyns.stream().collect(Collectors.toMap((obj) -> {
|
|
|
return obj.getLong("id");
|