From 47ee6bd60e4cd34b7fd8496061ff3020fe1c5baf Mon Sep 17 00:00:00 2001 From: ptt <2403326863@qq.com> Date: Thu, 26 Jun 2025 14:34:18 +0800 Subject: [PATCH] =?UTF-8?q?=E8=80=83=E5=AF=9F=E8=AE=A1=E5=88=92=E5=8F=91?= =?UTF-8?q?=E5=B8=83=E8=80=83=E5=AF=9F=E4=BB=BB=E5=8A=A1=E6=97=B6=EF=BC=8C?= =?UTF-8?q?=E8=87=AA=E5=8A=A8=E5=8C=96=E6=8F=90=E4=BA=A4(=E6=9C=AA?= =?UTF-8?q?=E5=BC=80=E5=8F=91=E5=AE=8C=E6=88=90)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../repc/resm/opplugin/newExamPlanOp.java | 40 +++++++++++++++++++ 1 file changed, 40 insertions(+) create mode 100644 main/java/shkd/repc/resm/opplugin/newExamPlanOp.java diff --git a/main/java/shkd/repc/resm/opplugin/newExamPlanOp.java b/main/java/shkd/repc/resm/opplugin/newExamPlanOp.java new file mode 100644 index 0000000..f520b24 --- /dev/null +++ b/main/java/shkd/repc/resm/opplugin/newExamPlanOp.java @@ -0,0 +1,40 @@ +package shkd.repc.resm.opplugin; + +import kd.bos.dataentity.OperateOption; +import kd.bos.dataentity.entity.DynamicObject; +import kd.bos.dataentity.entity.DynamicObjectCollection; +import kd.bos.entity.operate.result.OperationResult; +import kd.bos.entity.plugin.args.BeginOperationTransactionArgs; +import kd.bos.orm.query.QFilter; +import kd.bos.servicehelper.BusinessDataServiceHelper; +import kd.bos.servicehelper.operation.DeleteServiceHelper; +import kd.bos.servicehelper.operation.OperationServiceHelper; +import kd.bos.servicehelper.operation.SaveServiceHelper; +import kd.repc.resm.opplugin.exam.ExamPlanOp; + +import java.util.Arrays; +import java.util.List; +import java.util.Objects; +import java.util.stream.Collectors; + +public class newExamPlanOp extends ExamPlanOp { + + @Override + protected void botPubTask(DynamicObject dataEntity) { +// super.botPubTask(dataEntity); + DynamicObjectCollection plandetails = dataEntity.getDynamicObjectCollection("plandetails"); + List evalTaskIdList = (List)plandetails.stream().filter((item) -> { + return item.getDynamicObject("evaltask") != null; + }).map((item) -> { + return item.getDynamicObject("evaltask").getPkValue(); + }).collect(Collectors.toList()); + QFilter qFilter = new QFilter("id", "in", evalTaskIdList); + DynamicObject[] load = BusinessDataServiceHelper.load("resm_exam_task", "id", qFilter.toArray()); + DynamicObject[] objects = Arrays.stream(load) // 将数组转换为 Stream + .map(dynamicObject -> BusinessDataServiceHelper.loadSingle(dynamicObject.getPkValue(), "resm_exam_task")) // 对每个元素进行处理 + .filter(Objects::nonNull) // 过滤掉 null 元素 + .toArray(DynamicObject[]::new); + OperationResult result = OperationServiceHelper.executeOperate("submit", "resm_exam_task", objects, OperateOption.create()); + //提交失败，等候答复 + } +}