Browse Source

feat(salary): 调整薪资数据同步逻辑

- 移除入职单查询中的职位序列字段
- 移除调动单查询中的职位序列字段
- 简化定调薪记录创建逻辑
- 优化部门和岗位信息获取方式
turborao 4 days ago
parent
commit
ed76395bf8

+ 2 - 5
code/swc/nckd-jxccl-swc/src/main/java/nckd/jxccl/swc/init/business/SynPendingSalaryAdjDataServiceImpl.java

@@ -110,7 +110,7 @@ public class SynPendingSalaryAdjDataServiceImpl implements SynPendingSalaryAdjDa
         /**
          * 查询入职单
          */
-        String selectField2 = "id,billno,b_effectivedate,createtime,ba_em_tid,ba_em_empnumber,ba_em_name,ba_po_position.boid,ba_po_adminorg,ba_po_job.id,ajoblevel.id,ba_po_job.jobseq.id";
+        String selectField2 = "id,billno,b_effectivedate,createtime,ba_em_tid,ba_em_empnumber,ba_em_name,ba_po_position.boid,ba_po_adminorg";
         QFilter qFilter1 = new QFilter("enrollstatus", QCP.equals, "3"); // 入职状态 = 已入职
         QFilter qFilter2 = new QFilter("billstatus", QCP.equals, "C"); // 单据状态 = 已审核
         QFilter qFilter3 = new QFilter("b_effectivedate", QCP.large_equals, daysAgo);
@@ -160,7 +160,6 @@ public class SynPendingSalaryAdjDataServiceImpl implements SynPendingSalaryAdjDa
             dyn.set("nckd_salaryadjus", salaryTypeDyns.get(0).getLong("id"));  //定调薪类型
             dyn.set("nckd_newhradminorg", onhasonbrdDyn.getLong("ba_po_adminorg"));  //部门
             dyn.set("nckd_newposition", onhasonbrdDyn.getLong("ba_po_position.boid"));  //岗位
-            //dyn.set("nckd_newjobseqhr", onhasonbrdDyn.getLong("ba_po_job.jobseq.id"));  //职位序列
             dyn.set("nckd_newsalaryrank", salaryRankDyn.getLong("id"));
             onhasonbrdCount++;
             billDynList.add(dyn);
@@ -170,7 +169,7 @@ public class SynPendingSalaryAdjDataServiceImpl implements SynPendingSalaryAdjDa
         /**
          * 查询调动单
          */
-        String selectField1 = "id,billno,b_effectivedate,createtime,bb_em_tid,ba_em_empnumber,bb_po_position.boid,aposition.boid,bb_po_adminorg.id,aorg.id,bb_po_job.jobseq.id,ajob.jobseq.id";
+        String selectField1 = "id,billno,b_effectivedate,createtime,bb_em_tid,ba_em_empnumber,bb_po_position.boid,aposition.boid,bb_po_adminorg.boid,aorg.boid";
         QFilter qFilter12 = new QFilter("billstatus", QCP.equals, "C"); // 单据状态 = 已审核
         QFilter qFilter13 = new QFilter("b_effectivedate", QCP.large_equals, daysAgo);  //实际调动日期
         QFilter qFilter14 = new QFilter("b_effectivedate", QCP.less_equals, currentDate);  //实际调动日期
@@ -222,7 +221,6 @@ public class SynPendingSalaryAdjDataServiceImpl implements SynPendingSalaryAdjDa
              */
             dyn.set("nckd_oldhradminorg", transferDyn.getLong("bb_po_adminorg.id"));  //部门
             dyn.set("nckd_oldposition", transferDyn.getLong("bb_po_position.boid"));  //岗位
-            //dyn.set("nckd_oldjobseqhr", transferDyn.getLong("bb_po_job.jobseq.id"));  //职位序列
             DynamicObject adjRecordDyn  = adjRecordMap.get(employeeID);
             if(adjRecordDyn != null) {
                 dyn.set("nckd_oldsalaryrank", adjRecordDyn.getLong("salaryrank.id"));  //薪档
@@ -232,7 +230,6 @@ public class SynPendingSalaryAdjDataServiceImpl implements SynPendingSalaryAdjDa
              */
             dyn.set("nckd_newhradminorg", transferDyn.getLong("aorg.id"));  //部门
             dyn.set("nckd_newposition", transferDyn.getLong("aposition.boid"));  //岗位
-            //dyn.set("nckd_newjobseqhr", transferDyn.getLong("ajob.jobseq.id"));  //职位序列
             dyn.set("nckd_newsalaryrank", salaryRankDyn.getLong("id"));   //薪档
             transferCount++;
             billDynList.add(dyn);