feat(pm): 新增调薪推送功能

- 在 SalAdjTrackerConstant 中增加推送调薪相关常量
- 新增 PushAdjustOpPlugin 插件实现调薪推送逻辑
- 支持“确认推送调薪”和“不需要调薪”两种操作
- 验证调薪状态并控制操作权限
- 自动创建定调薪申请单并推送至系统
- 更新 SalaryAdjOpPlugin 以支持调薪档案关联
- 记录调薪创建人信息以便追踪

code/opmc/nckd-jxccl-opmc/src/main/java/nckd/jxccl/opmc/pm/common/SalAdjTrackerConstant.java

@@ -46,4 +46,10 @@ public class SalAdjTrackerConstant extends FormConstant {
     public static final String NCKD_POSITION = "nckd_position";
     /** 调薪差 */
     public static final String NCKD_ADJUSTDIFF = "nckd_adjustdiff";
+    /** 确认推送调薪 */
+    public static final String PUSHADJUST_OP = "pushadjust";
+    /** 不需要调薪 */
+    public static final String NOPUSHADJUST_OP = "nopushadjust";
+    /**定调薪档案*/
+    public static final String NCKD_ADJFILEINFO = "nckd_adjfileinfo";
 }

code/opmc/nckd-jxccl-opmc/src/main/java/nckd/jxccl/opmc/pm/plugin/operate/salary/PushAdjustOpPlugin.java

@@ -0,0 +1,153 @@
+package nckd.jxccl.opmc.pm.plugin.operate.salary;
+
+import kd.bos.context.RequestContext;
+import kd.bos.dataentity.entity.DynamicObject;
+import kd.bos.entity.ExtendedDataEntity;
+import kd.bos.entity.plugin.AbstractOperationServicePlugIn;
+import kd.bos.entity.plugin.AddValidatorsEventArgs;
+import kd.bos.entity.plugin.PreparePropertysEventArgs;
+import kd.bos.entity.plugin.args.BeginOperationTransactionArgs;
+import kd.bos.entity.validate.AbstractValidator;
+import kd.bos.servicehelper.BusinessDataServiceHelper;
+import kd.bos.servicehelper.operation.SaveServiceHelper;
+import kd.sdk.plugin.Plugin;
+import kd.sdk.swc.hcdm.business.helper.HCDMApplyBillServiceHelper;
+import nckd.jxccl.base.common.constant.FormConstant;
+import nckd.jxccl.base.common.exception.ValidationException;
+import nckd.jxccl.base.common.utils.ConvertUtil;
+import nckd.jxccl.base.common.utils.StrFormatter;
+import nckd.jxccl.opmc.pm.common.SalAdjTrackerConstant;
+
+import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.StringJoiner;
+import java.util.UUID;
+
+/**
+* 调薪情况-确认推送调薪/不需要调薪
+* 实体标识：nckd_saladjtracker
+* @author W.Y.C
+* @date 2025/11/26 9:34
+* @version 1.0
+*/
+public class PushAdjustOpPlugin extends AbstractOperationServicePlugIn implements Plugin {
+
+    @Override
+    public void onPreparePropertys(PreparePropertysEventArgs e) {
+        e.getFieldKeys().addAll(this.billEntityType.getAllFields().keySet());
+    }
+
+    @Override
+    public void onAddValidators(AddValidatorsEventArgs e){
+        e.addValidator(new AbstractValidator() {
+            @Override
+            public void validate() {
+                String operateKey = this.getOperateKey();
+                //pushadjust：确认推送调薪
+                //nopushadjust：不需要调薪
+                for (ExtendedDataEntity rowDataEntity : getDataEntities()) {
+                    DynamicObject data = rowDataEntity.getDataEntity();
+                    DynamicObject person = data.getDynamicObject(SalAdjTrackerConstant.NCKD_PERFMANAGER).getDynamicObject(FormConstant.NCKD_PERSON);
+                    String wageStatus = data.getString(SalAdjTrackerConstant.NCKD_WAGESTATUS);
+                    if(SalAdjTrackerConstant.PUSHADJUST_OP.equalsIgnoreCase(operateKey)){
+                        if(!"1".equalsIgnoreCase(wageStatus)){
+                            this.addFatalErrorMessage(rowDataEntity,"只有【待处理】状态的调薪才可以推送");
+                        }
+                    }else if(SalAdjTrackerConstant.NOPUSHADJUST_OP.equalsIgnoreCase(operateKey)){
+                        if(!"1".equalsIgnoreCase(wageStatus)){
+                            this.addErrorMessage(rowDataEntity,StrFormatter.format("【{}】的调薪处理状态已是【{}】状态，本次操作忽略此条处理；", person.getString(FormConstant.NAME_KEY),
+                                    "2".equalsIgnoreCase(wageStatus) ? "已处理":"已忽略"));
+                        }
+                    }
+                }
+            }
+        });
+    }
+
+    @Override
+    public void beginOperationTransaction(BeginOperationTransactionArgs e) {
+
+        String operateKey = e.getOperationKey();
+        List<DynamicObject> pushAdjusts = new ArrayList<>();
+        List<DynamicObject> updateAdjusts = new ArrayList<>();
+        for (DynamicObject dataEntity : e.getDataEntities()) {
+            if(SalAdjTrackerConstant.PUSHADJUST_OP.equalsIgnoreCase(operateKey)){
+                //推送调薪
+                pushAdjusts.add(dataEntity);
+            }else if(SalAdjTrackerConstant.NOPUSHADJUST_OP.equalsIgnoreCase(operateKey)){
+                dataEntity.set(SalAdjTrackerConstant.NCKD_WAGESTATUS, "3");
+                updateAdjusts.add(dataEntity);
+            }
+        }
+        if(!updateAdjusts.isEmpty()){
+            SaveServiceHelper.update(updateAdjusts.toArray(new DynamicObject[0]));
+        }
+        //开始推送定调薪
+        if(!pushAdjusts.isEmpty()) {
+            Map<String, Object> papams = new HashMap<>();
+            List<Map<String, Object>> applyBillData = new ArrayList<>();
+            for (DynamicObject pushAdjust : pushAdjusts) {
+                Map<String, Object> applyBill = new HashMap<>();
+                /**
+                 * 必填字段
+                 * "billname", "billtype", "org", "billcountry", "salaryadjrsn", "salaryadjscm", "billcurrency", "effectivedate", "exchangeratedate", "exctable"
+                 */
+                applyBill.put("billname", "岗位工资动态调整-生成");
+
+                Long orgId = RequestContext.get().getOrgId();
+
+                String uniquecode = UUID.randomUUID().toString().replace("-", "");
+                applyBill.put("_uniquecode", uniquecode);
+                applyBill.put("org", orgId);
+                //定调薪明细字段显示方案   调薪明细字段
+                applyBill.put("billtype", 2215975998602655744L);
+                //国家
+                applyBill.put("billcountry", 1000001L);
+                //定调薪类型
+                applyBill.put("salaryadjrsn", 2352340656979984384L);
+                //默认币种
+                applyBill.put("billcurrency", 1L);
+                //定调薪方案
+                applyBill.put("salaryadjscm", 2322515162646457344L);
+                //汇率日期
+                applyBill.put("exchangeratedate", new Date());
+                //汇率表
+                applyBill.put("exctable", 2321965096026258432L);
+                //默认生效日期
+                applyBill.put("effectivedate", new Date());
+                //草稿状态
+                applyBill.put("isdraft", "1");
+                //审核状态
+                applyBill.put("auditstatus", "A");
+                //申请单数据来源   //1:手工新增  2:接口写入
+                applyBill.put("datasource", "2");
+                List<Map<String, Object>> applyBillEntryData = new ArrayList<>();
+                Map<String, Object> applyBillEntry = new HashMap<>();
+                Long employeeId = pushAdjust.getDynamicObject(SalAdjTrackerConstant.NCKD_PERFMANAGER).getDynamicObject(FormConstant.NCKD_PERSON).getLong(FormConstant.ID_KEY);
+                Long positionId = pushAdjust.getDynamicObject(SalAdjTrackerConstant.NCKD_POSITION).getLong(FormConstant.ID_KEY);
+                applyBillEntry.put("adjfile", pushAdjust.getDynamicObject(SalAdjTrackerConstant.NCKD_ADJFILEINFO).getLong(FormConstant.ID_KEY));
+                applyBillEntry.put("employee", employeeId);
+                applyBillEntry.put("standarditem", 2321899710350111744L);    //定调薪项目   岗位工资标准
+                applyBillEntry.put("frequency", 1095454108284088320L);       //频度  月
+                applyBillEntry.put("amount", pushAdjust.getBigDecimal(SalAdjTrackerConstant.NCKD_MONEY));
+//            applyBillEntry.put("nckd_postgrade", salaryfile.getLong("position.nckd_postgrade.id"));  //岗级
+                applyBillEntry.put("position", positionId);
+                applyBillEntry.put("salarygrade", pushAdjust.getDynamicObject(SalAdjTrackerConstant.NCKD_SALARYGRADE));
+                applyBillEntry.put("salaryrank", pushAdjust.getDynamicObject(SalAdjTrackerConstant.NCKD_SALARYRANK));
+                applyBillEntry.put("reason", pushAdjust.getString(SalAdjTrackerConstant.NCKD_WAGEEXPLAIN));
+                applyBillEntryData.add(applyBillEntry);
+                applyBill.put("applybillent", applyBillEntryData);
+                applyBillData.add(applyBill);
+            }
+            papams.put("data", applyBillData);
+            Map<String, Object> result = HCDMApplyBillServiceHelper.saveDraftApplyBill(papams);
+            if (!ConvertUtil.toBoolean(result.get("success"))) {
+                throw new ValidationException("推送定调薪失败，原因：" + result.get("message").toString());
+            }
+        }
+    }
+}

code/opmc/nckd-jxccl-opmc/src/main/java/nckd/jxccl/opmc/pm/plugin/operate/salary/SalaryAdjOpPlugin.java

@@ -270,6 +270,7 @@ public class SalaryAdjOpPlugin extends AbstractOperationServicePlugIn implements
                                     DynamicObject salaryRank = dynamicObject.getDynamicObject("salaryrank");
                                     //金额
                                     BigDecimal amount = dynamicObject.getBigDecimal("amount");
+                                    salaryAdjustmentResult.adjFileInfo = dynamicObject.getDynamicObject("adjfile");
                                     salaryAdjustmentResult.salaryStDv = salaryStDv;
                                     salaryAdjustmentResult.oldStandardItem = standardItem;
                                     salaryAdjustmentResult.oldSalaryGrade = salaryGrade;
@@ -386,6 +387,7 @@ public class SalaryAdjOpPlugin extends AbstractOperationServicePlugIn implements
                     newSalAdjTracker.set(FormConstant.CTRLSTRATEGY_KEY, CtrlStrategyEnum.GLOBAL_SHARE.getCtrlStrategy());
                     newSalAdjTracker.set(FormConstant.NAME_KEY,StrFormatter.format("{}的调薪", result.personName));
                     newSalAdjTracker.set(SalAdjTrackerConstant.NCKD_PERFMANAGER,EntityHelper.newEntity(PerfManagerFormConstant.PERFMANAGER_ENTITYID, result.id));
+                    newSalAdjTracker.set(SalAdjTrackerConstant.NCKD_ADJFILEINFO, result.adjFileInfo);
                     newSalAdjTracker.set(SalAdjTrackerConstant.NCKD_OLDSALARYGRADE, result.oldSalaryGrade);
                     newSalAdjTracker.set(SalAdjTrackerConstant.NCKD_OLDSALARYRANK, result.oldSalaryRank);
                     newSalAdjTracker.set(SalAdjTrackerConstant.NCKD_OLDMONEY, result.oldAmount);
@@ -401,6 +403,7 @@ public class SalaryAdjOpPlugin extends AbstractOperationServicePlugIn implements
                     newSalAdjTracker.set(SalAdjTrackerConstant.NCKD_ADJMONEY, result.amount.subtract(result.oldAmount));
                     newSalAdjTracker.set(SalAdjTrackerConstant.NCKD_DEP,EntityHelper.newEntity(FormConstant.ADMINORGHR_ENTITYID, result.depId));
                     newSalAdjTracker.set(SalAdjTrackerConstant.NCKD_POSITION,EntityHelper.newEntity(PerfManagerFormConstant.HBPM_POSITIONHR, result.positionId));
+                    newSalAdjTracker.set(SalAdjTrackerConstant.CREATOR_KEY,UserServiceHelper.getCurrentUserId());
                     ids.add(result.id);
                     addSalAdjTrackerList.add(newSalAdjTracker);
                 }
@@ -684,6 +687,8 @@ public class SalaryAdjOpPlugin extends AbstractOperationServicePlugIn implements
         int level;
         /** 调薪原因*/
         String reason;
+        /**定调薪档案*/
+        DynamicObject adjFileInfo;
         /**薪酬标准表*/
         DynamicObject salaryStDv;
         /** 原定调薪项目 */