fix(hr): 优化三定任务消息发送功能

- 添加日志记录功能用于消息发送状态跟踪
- 实现批量消息发送结果处理和错误捕获
- 使用HRCollUtil工具类优化集合空值检查
- 修改buildMessage方法以支持消息信息收集
- 添加消息发送人ID设置确保消息来源标识
- 增加异常处理机制防止消息发送失败影响主流程

code/hr/nckd-jxccl-hr/src/main/java/nckd/jxccl/hr/sdm/plugin/operate/SendTaskOpPlugin.java

@@ -17,6 +17,8 @@ import kd.bos.entity.plugin.args.BeginOperationTransactionArgs;
 import kd.bos.entity.plugin.args.EndOperationTransactionArgs;
 import kd.bos.exception.ErrorCode;
 import kd.bos.exception.KDBizException;
+import kd.bos.logging.Log;
+import kd.bos.logging.LogFactory;
 import kd.bos.orm.ORM;
 import kd.bos.orm.query.QCP;
 import kd.bos.orm.query.QFilter;
@@ -25,10 +27,12 @@ import kd.bos.servicehelper.operation.SaveServiceHelper;
 import kd.bos.servicehelper.user.UserServiceHelper;
 import kd.bos.servicehelper.workflow.MessageCenterServiceHelper;
 import kd.bos.url.UrlService;
+import kd.bos.util.JSONUtils;
 import kd.bos.workflow.engine.msg.info.MessageInfo;
 import kd.hr.hbp.business.servicehelper.HRBaseServiceHelper;
 import kd.hr.hbp.business.servicehelper.HRQueryEntityHelper;
 import kd.hr.hbp.common.constants.history.HisModelDataStatusEnum;
+import kd.hr.hbp.common.util.HRCollUtil;
 import kd.hr.hbp.common.util.HRDateTimeUtils;
 import kd.hr.hbp.common.util.HRObjectUtils;
 import kd.sdk.hr.hrpi.business.helper.HRPIEmployeeServiceHelper;
@@ -40,6 +44,7 @@ import nckd.jxccl.hr.sdm.business.SdmBusinessService;
 import nckd.jxccl.hr.sdm.common.SanDingConstant;
 import nckd.jxccl.hr.sdm.common.SanDingPlanEntryStatus;
 
+import java.io.IOException;
 import java.util.ArrayList;
 import java.util.Arrays;
 import java.util.Collections;
@@ -60,6 +65,7 @@ import java.util.stream.Collectors;
  * @date: 2025/12/3 15:01
  */
 public class SendTaskOpPlugin extends AbstractOperationServicePlugIn {
+    private static final Log logger = LogFactory.getLog(SendTaskOpPlugin.class);
 
     /** 特殊借调变动操作编码 */
     private static final String TSJD_CHGACTION_NUMBER = "JTCC_1001";
@@ -101,10 +107,37 @@ public class SendTaskOpPlugin extends AbstractOperationServicePlugIn {
             for (DynamicObject dyo : dyos) {
                 DynamicObjectCollection entryDyoColl = dyo.getDynamicObjectCollection(SanDingConstant.NCKD_ENTRYENTITY);
                 for (DynamicObject entryDyo : entryDyoColl) {
-                    buildMessage(entryDyo);
+                    buildMessage(messageInfos, entryDyo);
+                }
+            }
+            if (HRCollUtil.isNotEmpty(messageInfos)) {
+                try {
+                    Map<String, Object> sendMsgResult = MessageCenterServiceHelper.batchSendMessages(messageInfos);
+                    boolean success = (Boolean)sendMsgResult.get("success");
+                    String description = (String)sendMsgResult.get("description");
+                    logger.info(String.format("successToSendMessageSanDingTaskSendTask: messageInfos.size: %s, success: %s, description: %s", messageInfos.size(), success, description));
+                    Map<String, Object> data = (Map<String, Object>) sendMsgResult.getOrDefault("data", new HashMap());
+                    if (!data.isEmpty()) {
+                        for(Long successMsgId : (List<Long>) data.getOrDefault("successMsgIds", new ArrayList())) {
+                            logger.info(String.format("successToSendMessageSanDingTaskSendTask-success: %s, messageID: %s", null, successMsgId));
+                        }
+
+                        Map<MessageInfo, String> failMsgs = (Map<MessageInfo, String>) data.getOrDefault("failMsgs", new HashMap());
+
+                        for(Map.Entry<MessageInfo, String> failMsg : failMsgs.entrySet()) {
+                            MessageInfo failMessageInfo = failMsg.getKey();
+                            String failDescription = failMsg.getValue();
+                            logger.info(String.format("successToSendMessageSanDingTaskSendTask-fail: %s, messageID: %s, description: %s", JSONUtils.toString(failMessageInfo), failMessageInfo.getId(), failDescription));
+                        }
+                    }
+                } catch (Exception var45) {
+                    try {
+                        logger.error("FailedSendMessageSanDingTaskSendTask: " + JSONUtils.toString(messageInfos));
+                    } catch (IOException var43) {
+                        logger.error("Failed to parse message: " + messageInfos);
+                    }
                 }
             }
-            MessageCenterServiceHelper.batchSendMessages(messageInfos);
         } catch (Exception ex) {
             throw new KDBizException(ex, new ErrorCode("sendMessageError", ex.getMessage()));
         }
@@ -340,35 +373,34 @@ public class SendTaskOpPlugin extends AbstractOperationServicePlugIn {
             // 构建单据体
             DynamicObjectCollection sanDingTaskEntryDyoColl = sanDingTaskDyo.getDynamicObjectCollection(SanDingConstant.NCKD_ENTRYENTITY);
             List<Map<String, Long>> positionBoIdList = companyPositionMap.get(entryDyo.getLong(companyBoIdKey));
-            if (positionBoIdList == null || positionBoIdList.isEmpty()) {
-                continue;
-            }
-            for (Map<String, Long> positionOrgMap : positionBoIdList) {
-                DynamicObject sanDingTaskEntryDyo = sanDingTaskEntryDyoColl.addNew();
-                // 岗位BOID
-                Long positionBoId = positionOrgMap.get("positionBoId");
-                // 设置 组织
-                sanDingTaskEntryDyo.set(SanDingConstant.NCKD_ADMINORG, EntityHelper.newEntity(SanDingConstant.ADMINORG_ENTITYID, positionOrgMap.get("adminOrgSourceVid")));
-                // 设置 岗位
-                sanDingTaskEntryDyo.set(SanDingConstant.NCKD_POSITION_KEY, EntityHelper.newEntity(SanDingConstant.HBPM_POSITIONHR, positionOrgMap.get("positionSourceVid")));
-                // 设置 定员数
-                sanDingTaskEntryDyo.set(SanDingConstant.NCKD_AUTHORIZEDSTRENGTH_KEY, lastSanDingTaskMap.getOrDefault(entryDyo.getLong(companyBoIdKey)+"@"+positionBoId, 0));
-                // 设置 实际占编人数
-                sanDingTaskEntryDyo.set(SanDingConstant.NCKD_ACTUALSTAFFCOUNT_KEY, positionInStaffEmployeeCountMap.getOrDefault(positionBoId, 0));
-                // 设置 缺编人数
-                sanDingTaskEntryDyo.set(SanDingConstant.NCKD_STAFFINGSHORTFALL_KEY, 0);
-                // 设置 前一年流失人数（系统数）
-                sanDingTaskEntryDyo.set(SanDingConstant.NCKD_Y1OUT_SYS_KEY, y1OutSysMap.getOrDefault(positionBoId + "@" + y1, 0) + kgsddEmpPosOrgRelMap.getOrDefault(positionBoId + "@" + y1, 0));
-                // 设置 前两年流失人数（系统数）
-                sanDingTaskEntryDyo.set(SanDingConstant.NCKD_Y2OUT_SYS_KEY, y2OutSysMap.getOrDefault(positionBoId + "@" + y2, 0) + kgsddEmpPosOrgRelMap.getOrDefault(positionBoId + "@" + y2, 0));
-                // 设置 前三年流失人数（系统数）
-                sanDingTaskEntryDyo.set(SanDingConstant.NCKD_Y3OUT_SYS_KEY, y3OutSysMap.getOrDefault(positionBoId + "@" + y3, 0) + kgsddEmpPosOrgRelMap.getOrDefault(positionBoId + "@" + y3, 0));
-                // 设置 前一年流失人数（确认数）
-                sanDingTaskEntryDyo.set(SanDingConstant.NCKD_Y1OUT_CONF_KEY, sanDingTaskEntryDyo.get(SanDingConstant.NCKD_Y1OUT_SYS_KEY));
-                // 设置 前两年流失人数（确认数）
-                sanDingTaskEntryDyo.set(SanDingConstant.NCKD_Y2OUT_CONF_KEY, sanDingTaskEntryDyo.get(SanDingConstant.NCKD_Y2OUT_SYS_KEY));
-                // 设置 前三年流失人数（确认数）
-                sanDingTaskEntryDyo.set(SanDingConstant.NCKD_Y3OUT_CONF_KEY, sanDingTaskEntryDyo.get(SanDingConstant.NCKD_Y3OUT_SYS_KEY));
+            if (HRCollUtil.isNotEmpty(positionBoIdList)) {
+                for (Map<String, Long> positionOrgMap : positionBoIdList) {
+                    DynamicObject sanDingTaskEntryDyo = sanDingTaskEntryDyoColl.addNew();
+                    // 岗位BOID
+                    Long positionBoId = positionOrgMap.get("positionBoId");
+                    // 设置 组织
+                    sanDingTaskEntryDyo.set(SanDingConstant.NCKD_ADMINORG, EntityHelper.newEntity(SanDingConstant.ADMINORG_ENTITYID, positionOrgMap.get("adminOrgSourceVid")));
+                    // 设置 岗位
+                    sanDingTaskEntryDyo.set(SanDingConstant.NCKD_POSITION_KEY, EntityHelper.newEntity(SanDingConstant.HBPM_POSITIONHR, positionOrgMap.get("positionSourceVid")));
+                    // 设置 定员数
+                    sanDingTaskEntryDyo.set(SanDingConstant.NCKD_AUTHORIZEDSTRENGTH_KEY, lastSanDingTaskMap.getOrDefault(entryDyo.getLong(companyBoIdKey)+"@"+positionBoId, 0));
+                    // 设置 实际占编人数
+                    sanDingTaskEntryDyo.set(SanDingConstant.NCKD_ACTUALSTAFFCOUNT_KEY, positionInStaffEmployeeCountMap.getOrDefault(positionBoId, 0));
+                    // 设置 缺编人数
+                    sanDingTaskEntryDyo.set(SanDingConstant.NCKD_STAFFINGSHORTFALL_KEY, 0);
+                    // 设置 前一年流失人数（系统数）
+                    sanDingTaskEntryDyo.set(SanDingConstant.NCKD_Y1OUT_SYS_KEY, y1OutSysMap.getOrDefault(positionBoId + "@" + y1, 0) + kgsddEmpPosOrgRelMap.getOrDefault(positionBoId + "@" + y1, 0));
+                    // 设置 前两年流失人数（系统数）
+                    sanDingTaskEntryDyo.set(SanDingConstant.NCKD_Y2OUT_SYS_KEY, y2OutSysMap.getOrDefault(positionBoId + "@" + y2, 0) + kgsddEmpPosOrgRelMap.getOrDefault(positionBoId + "@" + y2, 0));
+                    // 设置 前三年流失人数（系统数）
+                    sanDingTaskEntryDyo.set(SanDingConstant.NCKD_Y3OUT_SYS_KEY, y3OutSysMap.getOrDefault(positionBoId + "@" + y3, 0) + kgsddEmpPosOrgRelMap.getOrDefault(positionBoId + "@" + y3, 0));
+                    // 设置 前一年流失人数（确认数）
+                    sanDingTaskEntryDyo.set(SanDingConstant.NCKD_Y1OUT_CONF_KEY, sanDingTaskEntryDyo.get(SanDingConstant.NCKD_Y1OUT_SYS_KEY));
+                    // 设置 前两年流失人数（确认数）
+                    sanDingTaskEntryDyo.set(SanDingConstant.NCKD_Y2OUT_CONF_KEY, sanDingTaskEntryDyo.get(SanDingConstant.NCKD_Y2OUT_SYS_KEY));
+                    // 设置 前三年流失人数（确认数）
+                    sanDingTaskEntryDyo.set(SanDingConstant.NCKD_Y3OUT_CONF_KEY, sanDingTaskEntryDyo.get(SanDingConstant.NCKD_Y3OUT_SYS_KEY));
+                }
             }
             sanDingTaskDyoList.add(sanDingTaskDyo);
             SANDING_TASK_MAP.put(entryDyo.getLong(SanDingConstant.ID_KEY), sanDingTaskDyo.getLong(SanDingConstant.ID_KEY));
@@ -401,7 +433,7 @@ public class SendTaskOpPlugin extends AbstractOperationServicePlugIn {
         SaveServiceHelper.save(dyos);
     }
 
-    private void buildMessage(DynamicObject entryDyo) {
+    private void buildMessage(List<MessageInfo> messageInfos, DynamicObject entryDyo) {
         // 构建 消息
         MessageInfo messageInfo = new MessageInfo();
         // 设置 消息标题
@@ -422,6 +454,9 @@ public class SendTaskOpPlugin extends AbstractOperationServicePlugIn {
         messageInfo.setUserIds(userIds);
         // 设置 消息Web端url
         messageInfo.setContentUrl(UrlService.getDomainContextUrl() + "/index.html?formId="+SanDingConstant.NCKD_SANDINGTASK_ENTITY+"&pkId=" + SANDING_TASK_MAP.get(entryDyo.getLong(SanDingConstant.ID_KEY)));
+        // 设置发送人
+        messageInfo.setSenderId(UserServiceHelper.getCurrentUserId());
+        messageInfos.add(messageInfo);
     }
 
     private List<Long> getUserIds(List<Long> managerBoIdList) {

code/hrmp/nckd-jxccl-hrmp/src/main/java/nckd/jxccl/hrmp/hbpm/business/hr/PositionBillAfterBindDataService.java

@@ -0,0 +1,31 @@
+package nckd.jxccl.hrmp.hbpm.business.hr;
+
+import kd.bos.form.IFormView;
+import kd.bos.orm.ORM;
+import nckd.jxccl.hrmp.hbpm.common.hr.PositionBillConstant;
+
+/**
+ * 岗位申请单后置绑定数据服务
+ * @from: kd.hr.homs.business.domain.batchbill.service.impl.AdminOrgBatchBillAfterBindDataService
+ * @author: jtd
+ * @date: 2025/12/27 21:48
+ */
+public class PositionBillAfterBindDataService extends PositionBillBaseService {
+    public PositionBillAfterBindDataService(IFormView view) {
+        super(view);
+    }
+
+    public void afterBindData() {
+        genBillIdIfNotExist();
+        getModel().setDataChanged(false);
+    }
+
+    private void genBillIdIfNotExist() {
+        long billId = getModel().getDataEntity().getLong(PositionBillConstant.ID_KEY);
+        if (billId == 0L) {
+            billId = ORM.create().genLongId(getView().getEntityId());
+            getModel().setValue(PositionBillConstant.ID_KEY, billId);
+        }
+    }
+
+}

code/hrmp/nckd-jxccl-hrmp/src/main/java/nckd/jxccl/hrmp/hbpm/business/hr/PositionBillClosedCallBackService.java

@@ -14,6 +14,7 @@ import kd.bos.form.events.ClosedCallBackEvent;
 import kd.bos.orm.query.QCP;
 import kd.bos.orm.query.QFilter;
 import kd.hr.hbp.business.servicehelper.HRBaseServiceHelper;
+import kd.hr.hbp.common.util.HRDyObjectPropUtil;
 import nckd.jxccl.hrmp.hbpm.common.hr.PositionBillConstant;
 import nckd.jxccl.hrmp.hbpm.common.hr.PositionChangeTypeEnum;
 
@@ -64,7 +65,7 @@ public class PositionBillClosedCallBackService extends PositionBillBaseService {
         for(IDataEntityProperty iDataEntityProperty : entryEntityInfo) {
             String entryPropName = iDataEntityProperty.getName();
             if (entryPropName.endsWith(lineSuffix)) {
-                String entryPropNameSub = entryPropName.substring(0, entryPropName.lastIndexOf(lineSuffix));
+                String entryPropNameSub = PositionBillServiceHelper.getNoLineSuffixProp(entryPropName, lineSuffix);
                 if (addNamePropMap.containsKey(entryPropNameSub)) {
                     selectPropList.add(entryPropNameSub);
                     toSetValueEntryPropList.add(entryPropName);
@@ -76,7 +77,7 @@ public class PositionBillClosedCallBackService extends PositionBillBaseService {
         Map<String, String> transKeyMap = PositionBillServiceHelper.getPosBillEntryTransKeyMap();
         transKeyMap.forEach((key, value) -> {
             selectPropList.add(value);// 岗位查询字段放入分录页面字段
-            toSetValueEntryPropList.add(key);// 放入单据分录字段
+            toSetValueEntryPropList.add(key+lineSuffix);// 放入单据分录字段(带后缀)
         });
         toSetValueEntryPropList.add(PositionBillConstant.ID_KEY);
 
@@ -95,12 +96,11 @@ public class PositionBillClosedCallBackService extends PositionBillBaseService {
             for(String entryPropName : toSetValueEntryPropList) {
                 if (entryPropName.equals(PositionBillConstant.ID_KEY)) {
                     values.add(addPositionDy.getLong(PositionBillConstant.ID_KEY));
-                } else if (transKeyMap.containsKey(entryPropName)) {
-                    values.add(addPositionDy.get(transKeyMap.get(entryPropName)));
                 } else {
-                    String propName = entryPropName.substring(0, entryPropName.lastIndexOf(lineSuffix));
+                    String propName = PositionBillServiceHelper.getNoLineSuffixProp(entryPropName, lineSuffix);
+                    propName = transKeyMap.getOrDefault(propName, propName);
                     if (addPositionDy.get(propName) instanceof DynamicObject) {
-                        values.add(((DynamicObject) addPositionDy.get(propName)).getLong(PositionBillConstant.ID_KEY));
+                        values.add(HRDyObjectPropUtil.getIdLongObject(addPositionDy.getDynamicObject(propName)));
                     } else {
                         values.add(addPositionDy.get(propName));
                     }

code/hrmp/nckd-jxccl-hrmp/src/main/java/nckd/jxccl/hrmp/hbpm/business/hr/PositionBillConfirmCallBackService.java

@@ -196,7 +196,7 @@ public class PositionBillConfirmCallBackService extends PositionBillBaseService
             for(IDataEntityProperty iDataEntityProperty : entryEntityInfo) {
                 String propName = iDataEntityProperty.getName();
                 if (PatternUtil.isExProperty(propName) && propName.endsWith(lineSuffix)) {
-                    String selectName = propName.substring(0, propName.lastIndexOf(lineSuffix));
+                    String selectName = PositionBillServiceHelper.getNoLineSuffixProp(propName, lineSuffix);
                     queryFieldBuilder.add(transKeyMap.getOrDefault(selectName, selectName));
                 }
             }
@@ -211,7 +211,7 @@ public class PositionBillConfirmCallBackService extends PositionBillBaseService
             for(IDataEntityProperty iDataEntityProperty : entryEntityInfo) {
                 String propName = iDataEntityProperty.getName();
                 if (nckd.jxccl.hrmp.hbpm.business.hr.PatternUtil.isExProperty(propName) && propName.endsWith(lineSuffix)) {
-                    String selectName = propName.substring(0, propName.lastIndexOf(lineSuffix));
+                    String selectName = PositionBillServiceHelper.getNoLineSuffixProp(propName, lineSuffix);
                     if (positionExcludeKeyList.contains(selectName) || HRStringUtils.equals(selectName, PositionBillConstant.NCKD_POSDUTY_ENTRY_ENTITY_KEY)) {
                         continue;
                     }

code/hrmp/nckd-jxccl-hrmp/src/main/java/nckd/jxccl/hrmp/hbpm/business/hr/PositionBillPropertyChangedService.java

@@ -91,7 +91,7 @@ public class PositionBillPropertyChangedService extends PositionBillBaseService
         for(IDataEntityProperty iDataEntityProperty : entryEntityInfo) {
             String propName = iDataEntityProperty.getName();
             if (PatternUtil.isExProperty(propName) && propName.endsWith(lineSuffix)) {
-                String selectName = propName.substring(0, propName.lastIndexOf(lineSuffix));
+                String selectName = PositionBillServiceHelper.getNoLineSuffixProp(propName, lineSuffix);
                 selectSqlBuilder.append(",").append(transKeyMap.getOrDefault(selectName, selectName));
             }
         }
@@ -121,7 +121,7 @@ public class PositionBillPropertyChangedService extends PositionBillBaseService
             for(IDataEntityProperty iDataEntityProperty : entryEntityInfo) {
                 String propName = iDataEntityProperty.getName();
                 if (PatternUtil.isExProperty(propName) && propName.endsWith(lineSuffix)) {
-                    String selectName = propName.substring(0, propName.lastIndexOf(lineSuffix));
+                    String selectName = PositionBillServiceHelper.getNoLineSuffixProp(propName, lineSuffix);
                     if (positionExcludeKeyList.contains(selectName) || HRStringUtils.equals(selectName, PositionBillConstant.NCKD_POSDUTY_ENTRY_ENTITY_KEY)) {
                         continue;
                     }

code/hrmp/nckd-jxccl-hrmp/src/main/java/nckd/jxccl/hrmp/hbpm/business/hr/PositionBillSaveHelper.java

@@ -8,6 +8,7 @@ import nckd.jxccl.hrmp.hbpm.common.hr.PositionChangeTypeEnum;
 
 /**
  * 岗位申请单保存服务
+ * @from: kd.hr.homs.business.domain.orgbatch.service.impl.OrgBatchBillSaveHelper
  * @author: jtd
  * @date: 2025/12/27 15:04
  */
@@ -21,22 +22,23 @@ public class PositionBillSaveHelper {
 
     public Long getPositionId(DynamicObject entryEntityDynFromPage, String suffix) {
         String idFieldName = String.join(".", PositionBillConstant.NCKD_POSITION, PositionBillConstant.ID_KEY);
-        if (entryEntityDynFromPage.getString(spliceTwoStringByUnderLine(String.join(".", PositionBillConstant.NCKD_CHANGETYPE, PositionBillConstant.NUMBER_KEY), suffix)) == PositionChangeTypeEnum.ADD.getNumber()) {
+        if (entryEntityDynFromPage.getString(spliceTwoStringByUnderLine(suffix, String.join(".", PositionBillConstant.NCKD_CHANGETYPE, PositionBillConstant.NUMBER_KEY))) == PositionChangeTypeEnum.ADD.getNumber()) {
             idFieldName = PositionBillConstant.NCKD_POSITION;
         }
 
-        String positionFiledName = spliceTwoStringByUnderLine(idFieldName, suffix);
+        String positionFiledName = spliceTwoStringByUnderLine(suffix, idFieldName);
         return entryEntityDynFromPage.getLong(positionFiledName);
     }
 
     public String getSuffixFromEntryEntityDyn(DynamicObject entryEntityDynFromPage) {
         String entryEntityName = entryEntityDynFromPage.getDynamicObjectType().getName();
-        int lastUnderLineIndex = entryEntityName.indexOf("_");
+        int lastUnderLineIndex = entryEntityName.lastIndexOf("_");
         return entryEntityName.substring(lastUnderLineIndex + 1);
     }
 
     public String spliceTwoStringByUnderLine(String oneString, String otherString) {
-        return oneString + "_" + otherString;
+        String[] str = otherString.split("\\.");
+        return str.length > 1 ? str[0] + "_" + oneString + "." + str[1] : otherString + "_" + oneString;
     }
 
 }

code/hrmp/nckd-jxccl-hrmp/src/main/java/nckd/jxccl/hrmp/hbpm/business/hr/PositionBillServiceHelper.java

@@ -59,6 +59,13 @@ public class PositionBillServiceHelper {
 
     private static final Log log = LogFactory.getLog(PositionBillServiceHelper.class);
 
+    public static String getNoLineSuffixProp(String prop, String lineSuffix) {
+        if (prop.endsWith(lineSuffix)) {
+            return prop.lastIndexOf(lineSuffix) >= 0 ? prop.substring(0, prop.lastIndexOf(lineSuffix)) : prop;
+        }
+        return prop;
+    }
+
     /**
      * 获取分录序号
      * @param iDataModel
@@ -160,7 +167,7 @@ public class PositionBillServiceHelper {
     }
 
     public static QFilter filterCurrentBillOrg(IFormView iFormView) {
-        List<Long> list = new ArrayList();// 378
+        List<Long> list = new ArrayList();
         DynamicObjectCollection change = new DynamicObjectCollection();
         if (iFormView.getEntityId().equals(PositionBillConstant.NCKD_POSITIONBILL_ENTITY)) {
             change = iFormView.getModel().getDataEntity(true).getDynamicObjectCollection(PositionBillConstant.NCKD_ENTRYENTITY_CHANGE_KEY);
@@ -357,7 +364,7 @@ public class PositionBillServiceHelper {
         if (bill == null) {
             return "";
         } else {
-            DynamicObjectCollection positionEntryDys = new DynamicObjectCollection();// 2238
+            DynamicObjectCollection positionEntryDys = new DynamicObjectCollection();
             positionEntryDys.addAll(bill.getDynamicObjectCollection(PositionBillConstant.NCKD_ENTRYENTITY_ADD_KEY));
             positionEntryDys.addAll(bill.getDynamicObjectCollection(PositionBillConstant.NCKD_ENTRYENTITY_CHANGE_KEY));
             PositionBillSaveHelper helper = PositionBillSaveHelper.getInstance();
@@ -370,7 +377,7 @@ public class PositionBillServiceHelper {
                 if (PositionChangeTypeEnum.ADD.getNumber().equals(changeTypeNumber)) {
                     positionBoId = helper.getPositionId(entryDy, suffix);
                 } else {
-                    DynamicObject positionDyRef = entryDy.getDynamicObject(helper.spliceTwoStringByUnderLine(PositionBillConstant.NCKD_POSITION, suffix));
+                    DynamicObject positionDyRef = entryDy.getDynamicObject(helper.spliceTwoStringByUnderLine(suffix, PositionBillConstant.NCKD_POSITION));
                     if (positionDyRef != null) {
                         positionBoId = positionDyRef.getLong(PositionBillConstant.BOID_KEY);
                     }
@@ -404,11 +411,11 @@ public class PositionBillServiceHelper {
             for(DynamicObject positionEntryDy : positionNumberEntryDys) {
                 String suffix = helper.getSuffixFromEntryEntityDyn(positionEntryDy);
                 long positionId = 0L;
-                String positionNumber = positionEntryDy.getString(helper.spliceTwoStringByUnderLine(PositionBillConstant.NCKD_NUMBER_KEY, suffix));
+                String positionNumber = positionEntryDy.getString(helper.spliceTwoStringByUnderLine(suffix, PositionBillConstant.NCKD_NUMBER_KEY));
                 if (PositionBillConstant.NCKD_ENTRYENTITY_ADD_KEY.equals(positionEntryDy.getDynamicObjectType().getName())) {
-                    positionId = positionEntryDy.getLong(helper.spliceTwoStringByUnderLine(PositionBillConstant.NCKD_POSITION, suffix));
+                    positionId = positionEntryDy.getLong(helper.spliceTwoStringByUnderLine(suffix, PositionBillConstant.NCKD_POSITION));
                 } else {
-                    DynamicObject positionDy = positionEntryDy.getDynamicObject(helper.spliceTwoStringByUnderLine(PositionBillConstant.NCKD_POSITION, suffix));
+                    DynamicObject positionDy = positionEntryDy.getDynamicObject(helper.spliceTwoStringByUnderLine(suffix, PositionBillConstant.NCKD_POSITION));
                     if (positionDy != null) {
                         positionId = positionDy.getLong(PositionBillConstant.BOID_KEY);
                     }

code/hrmp/nckd-jxccl-hrmp/src/main/java/nckd/jxccl/hrmp/hbpm/plugin/form/hr/PosBillEntryAddFormPlugin.java

@@ -209,7 +209,7 @@ public class PosBillEntryAddFormPlugin extends AbstractFormPlugin {
         if (selectObject != null) {
             String lineSuffix = "_"+PositionBillConstant.ADD_TAG;
             Map<String, Object> map = SerializationUtils.fromJsonString(selectObject.toString(), Map.class);
-            Map<String, Object> noPrefixMap = map.entrySet().stream().collect(HashMap::new, (m, v) -> m.put(v.getKey().substring(0, v.getKey().lastIndexOf(lineSuffix)), v.getValue()), HashMap::putAll);
+            Map<String, Object> noPrefixMap = map.entrySet().stream().collect(HashMap::new, (m, v) -> m.put(PositionBillServiceHelper.getNoLineSuffixProp(v.getKey(), lineSuffix), v.getValue()), HashMap::putAll);
             List<String> props = new ArrayList();
 
             for(String prop : noPrefixMap.keySet()) {
@@ -241,7 +241,7 @@ public class PosBillEntryAddFormPlugin extends AbstractFormPlugin {
             if (value != null) {
                 if (propertyType.equals(DynamicObject.class) && dynamicProperty instanceof BasedataProp) {
                     // 岗位特殊处理
-                    Object id = PositionBillConstant.NCKD_POSITION.equals(key) ? value : ((Map)value).get(PositionBillConstant.ID_KEY);
+                    Object id = PositionBillConstant.NCKD_POSITION.equals(key) ? value : ((Map) value).get(PositionBillConstant.ID_KEY);
                     if (id != null && !HRStringUtils.equals(value.toString(), "0")) {
                         getModel().setValue(key, id);
                     }
@@ -249,11 +249,11 @@ public class PosBillEntryAddFormPlugin extends AbstractFormPlugin {
                     MulBasedataProp property = (MulBasedataProp) getModel().getDataEntityType().getProperty(key);
                     DynamicObjectCollection dynamicObjectCollection = new DynamicObjectCollection();
                         HRBaseServiceHelper serviceHelper = new HRBaseServiceHelper(property.getBaseEntityId());
-                    ((List)value).forEach((map) -> {
+                    ((List) value).forEach((map) -> {
                         DynamicObject dy = new DynamicObject(property.getDynamicCollectionItemPropertyType());
-                        dy.set("fbasedataid_id", ((Map)map).get("fbasedataid_id"));
+                        dy.set("fbasedataid_id", ((Map) map).get("fbasedataid_id"));
                         DynamicObject emptyDynamicObject = serviceHelper.generateEmptyDynamicObject();
-                        emptyDynamicObject.set(PositionBillConstant.ID_KEY, ((Map)map).get("fbasedataid_id"));
+                        emptyDynamicObject.set(PositionBillConstant.ID_KEY, ((Map) map).get("fbasedataid_id"));
                         dy.set("fbasedataid", emptyDynamicObject);
                         dynamicObjectCollection.add(dy);
                     });

code/hrmp/nckd-jxccl-hrmp/src/main/java/nckd/jxccl/hrmp/hbpm/plugin/form/hr/PositionBillFormPlugin.java

@@ -41,7 +41,6 @@ import kd.bos.list.ListShowParameter;
 import kd.bos.logging.Log;
 import kd.bos.logging.LogFactory;
 import kd.bos.mvc.bill.BillView;
-import kd.bos.orm.ORM;
 import kd.bos.orm.query.QCP;
 import kd.bos.orm.query.QFilter;
 import kd.bos.orm.util.CollectionUtils;
@@ -55,6 +54,7 @@ import kd.hr.hbp.common.util.HRDynamicObjectUtils;
 import kd.hr.hbp.common.util.HRStringUtils;
 import kd.hr.hbp.common.util.concurrent.NullableConcurrentHashMap;
 import kd.sdk.hr.hdm.common.enums.reg.RegBillStatusEnum;
+import nckd.jxccl.hrmp.hbpm.business.hr.PositionBillAfterBindDataService;
 import nckd.jxccl.hrmp.hbpm.business.hr.PositionBillClosedCallBackService;
 import nckd.jxccl.hrmp.hbpm.business.hr.PositionBillConfirmCallBackService;
 import nckd.jxccl.hrmp.hbpm.business.hr.PositionBillPropertyChangedService;
@@ -67,6 +67,7 @@ import java.util.Collections;
 import java.util.Date;
 import java.util.EventObject;
 import java.util.List;
+import java.util.Locale;
 import java.util.Map;
 import java.util.Objects;
 
@@ -84,20 +85,10 @@ public class PositionBillFormPlugin extends AbstractFormPlugin implements Before
     public void afterBindData(EventObject e) {
         super.afterBindData(e);
 
-        // 生成临时单据ID
-        genBillIdIfNotExist();
-        getModel().setDataChanged(false);
-    }
-
-    /**
-     * 生成临时单据ID
-     */
-    private void genBillIdIfNotExist() {
-        long billId = getModel().getDataEntity().getLong(PositionBillConstant.ID_KEY);
-        if (billId == 0L) {
-            billId = ORM.create().genLongId(getView().getEntityId());
-            getModel().setValue(PositionBillConstant.ID_KEY, billId);
-        }
+        long startTime = System.currentTimeMillis();
+        PositionBillAfterBindDataService afterBindDataService = new PositionBillAfterBindDataService(getView());
+        afterBindDataService.afterBindData();
+        LOG.info(String.format(Locale.ROOT, "PositionBillFormPlugin afterBindData() time cost is: %s", System.currentTimeMillis() - startTime));
     }
 
     public void beforeBasedataSetValue(BeforeBasedataSetValueEvent beforeBasedataSetValueEvent) {
@@ -319,7 +310,7 @@ public class PositionBillFormPlugin extends AbstractFormPlugin implements Before
             DynamicObject dynamicObject = dynamicObjectCollection.get(beforeF7SelectEvent.getRow());
             String name = property.getName();
             String lineSuffix = name.substring(name.lastIndexOf("_"));
-            String fieldKey = name.substring(0, name.lastIndexOf(lineSuffix));
+            String fieldKey = PositionBillServiceHelper.getNoLineSuffixProp(name, lineSuffix);
             if (PositionBillConstant.ORG_KEY.equals(fieldKey)) {
                 return false;
             } else if (!dynamicObject.getDataEntityType().getProperties().containsKey(String.join(PositionBillConstant.ORG_KEY +lineSuffix))) {

code/hrmp/nckd-jxccl-hrmp/src/main/java/nckd/jxccl/hrmp/hbpm/plugin/operate/hr/PosBillEntryAddSaveOpPlugin.java

@@ -19,7 +19,7 @@ public class PosBillEntryAddSaveOpPlugin extends PositionBillEntrySaveOpPlugin {
         super.onAddValidators(e);
 
         OperateOption option = getOption();
-        String onlyValidate = option.getVariableValue(OperateOptionConst.ONLY_VALIDATE, Boolean.FALSE.toString());// 22
+        String onlyValidate = option.getVariableValue(OperateOptionConst.ONLY_VALIDATE, Boolean.FALSE.toString());
         if (Boolean.TRUE.toString().equals(onlyValidate)) {
             e.addValidator(new PositionAddSaveValidator());
         }