From c81122c3abd5b43360208bec31eb1477f877ffab Mon Sep 17 00:00:00 2001 From: xuhaihui <2098865055@qq.com> Date: Thu, 27 Nov 2025 15:28:35 +0800 Subject: [PATCH] =?UTF-8?q?=E5=90=88=E5=90=8C=E6=88=90=E6=9C=AC=E6=A0=B8?= =?UTF-8?q?=E7=AE=97=E8=87=AA=E5=8A=A8=E5=8F=96=E6=95=B0=E9=80=BB=E8=BE=91?= =?UTF-8?q?=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../plugin/form/EntCostSplitBillPlugin.java | 504 ++++++++++-------- 1 file changed, 281 insertions(+), 223 deletions(-) diff --git a/code/zcdev/zcgj-zcdev-zcdev-pr/src/main/java/zcgj/zcdev/zcdev/pr/plugin/form/EntCostSplitBillPlugin.java b/code/zcdev/zcgj-zcdev-zcdev-pr/src/main/java/zcgj/zcdev/zcdev/pr/plugin/form/EntCostSplitBillPlugin.java index c02114a..dce2533 100644 --- a/code/zcdev/zcgj-zcdev-zcdev-pr/src/main/java/zcgj/zcdev/zcdev/pr/plugin/form/EntCostSplitBillPlugin.java +++ b/code/zcdev/zcgj-zcdev-zcdev-pr/src/main/java/zcgj/zcdev/zcdev/pr/plugin/form/EntCostSplitBillPlugin.java @@ -1,6 +1,7 @@ package zcgj.zcdev.zcdev.pr.plugin.form; import kd.bos.bill.AbstractBillPlugIn; +import kd.bos.dataentity.OperateOption; import kd.bos.dataentity.entity.DynamicObject; import kd.bos.dataentity.entity.DynamicObjectCollection; import kd.bos.dataentity.entity.LocaleString; @@ -11,8 +12,15 @@ import kd.bos.entity.MainEntityType; import kd.bos.entity.ValueMapItem; import kd.bos.entity.datamodel.events.ChangeData; import kd.bos.entity.datamodel.events.PropertyChangedArgs; +import kd.bos.entity.operate.OperateOptionConst; +import kd.bos.entity.operate.result.OperationResult; import kd.bos.entity.property.ComboProp; +import kd.bos.form.ConfirmCallBackListener; +import kd.bos.form.MessageBoxOptions; +import kd.bos.form.MessageBoxResult; +import kd.bos.form.control.events.BeforeItemClickEvent; import kd.bos.form.events.BeforeDoOperationEventArgs; +import kd.bos.form.events.MessageBoxClosedEvent; import kd.bos.form.field.BasedataEdit; import kd.bos.form.field.ComboEdit; import kd.bos.form.field.ComboItem; @@ -24,6 +32,8 @@ import kd.bos.orm.query.QCP; import kd.bos.orm.query.QFilter; import kd.bos.servicehelper.BusinessDataServiceHelper; import kd.bos.servicehelper.QueryServiceHelper; +import kd.bos.servicehelper.operation.OperationServiceHelper; +import kd.sdk.plugin.Plugin; import java.math.BigDecimal; import java.util.*; @@ -35,12 +45,13 @@ import java.util.*; * 3：子分录成本分解结构过滤逻辑 * 工序即为成本分解结构 */ -public class EntCostSplitBillPlugin extends AbstractBillPlugIn implements BeforeF7SelectListener { +public class EntCostSplitBillPlugin extends AbstractBillPlugIn implements BeforeF7SelectListener, Plugin { @Override public void registerListener(EventObject e) { super.registerListener(e); BasedataEdit cbs = (BasedataEdit) this.getControl("zcgj_cbs"); cbs.addBeforeF7SelectListener(this); + this.addItemClickListeners("advcontoolbarap"); } @Override @@ -114,231 +125,29 @@ public class EntCostSplitBillPlugin extends AbstractBillPlugIn implements Before } } + @Override + public void beforeItemClick(BeforeItemClickEvent evt) { + super.beforeItemClick(evt); + if (evt.getItemKey().equals("zcgj_autofetch")) { + + } + } + + @Override + public void confirmCallBack(MessageBoxClosedEvent messageBoxClosedEvent) { + super.confirmCallBack(messageBoxClosedEvent); + //判断是否是对应确认框的点击回调事件 + if (("autogetdata").equals(messageBoxClosedEvent.getCallBackId())) { + if (MessageBoxResult.Yes.equals(messageBoxClosedEvent.getResult())) { + autoFetchData(); + } + } + } + public void beforeDoOperation(BeforeDoOperationEventArgs args) { super.beforeDoOperation(args); FormOperate formOperate = (FormOperate) args.getSource(); - if ("autogetdata".equals(formOperate.getOperateKey())) { - //自动取数 - Object org = this.getModel().getValue("org");//所属组织 - if (org == null) { - this.getView().showTipNotification("请选择组织"); - return; - } - Object period = this.getModel().getValue("period");//期间 - if (period == null) { - this.getView().showTipNotification("请选择期间"); - return; - } - this.getModel().beginInit(); - DynamicObject org1 = (DynamicObject) org;//所属组织 - DynamicObject period1 = (DynamicObject) period;//期间 - DynamicObjectCollection entryCollection = this.getModel().getDataEntity(true).getDynamicObjectCollection("entryentity");//企业费用成本分摊明细分录 - DynamicObjectType entryType = entryCollection.getDynamicObjectType(); - if (entryCollection.size() > 0) { - entryCollection.clear(); - } - - QFilter filter = new QFilter("zcgj_org", QCP.equals, org1.getPkValue());//核算组织 - filter.and(new QFilter("zcgj_period", QCP.equals, period1.getPkValue()));//期间 -// filter.and(new QFilter("zcgj_isnew", QCP.equals, true));//是否最新 - DynamicObjectCollection rptAssistBalanceGxCollection = QueryServiceHelper.query("zcgj_rpt_assistbalancegx", - "id,zcgj_account,zcgj_processname,zcgj_debitlocal,zcgj_costcompanyname", - new QFilter[]{filter});//"核算维度余额取数表(矿山工序维度)" - - // 在循环开始前定义汇总Map - Map summaryMap = new HashMap<>(); - - for (DynamicObject rptAssistBalanceGx : rptAssistBalanceGxCollection) { - Object debitLocal = rptAssistBalanceGx.get("zcgj_debitlocal");//本期发生借方 - if (debitLocal == null || - (debitLocal instanceof BigDecimal && ((BigDecimal) debitLocal).compareTo(BigDecimal.ZERO) <= 0) || - (debitLocal instanceof String && ((String) debitLocal).equals("0"))) { - continue; - } - - QFilter[] qFilter = new QFilter[]{new QFilter("id", QCP.equals, rptAssistBalanceGx.get("zcgj_account"))};//科目ID - DynamicObject bd_accountview = BusinessDataServiceHelper.loadSingle("bd_accountview", - "id,number,name", qFilter);//"会计科目" - if (bd_accountview == null) { - continue; - } - - QFilter filter3 = new QFilter("zcgj_companyblentry.zcgj_org", QCP.equals, org1.getPkValue());//组织 - DynamicObject zcgj_companybelong = QueryServiceHelper.queryOne("zcgj_companybelong", "id", - new QFilter[]{filter3});//"公司归属区域" - Long id = 0L; - if (zcgj_companybelong != null) { - id = (Long) zcgj_companybelong.get("id"); - } - - QFilter filter1 = new QFilter("zcgj_acccostentry.zcgj_accountnumber", QCP.equals, bd_accountview.getString("number"));//科目编码 - filter1.and(new QFilter("zcgj_belongcompany", QCP.equals, id)); - DynamicObject zcgj_accountcost = QueryServiceHelper.queryOne("zcgj_accountcost", - "id,zcgj_acccostentry.zcgj_costtype,zcgj_acccostentry.zcgj_sectype", - new QFilter[]{filter1});//"会计科目与成本项目" - - QFilter[] qFilters = new QFilter[]{new QFilter("name", QCP.equals, rptAssistBalanceGx.get("zcgj_processname"))};//工序名称 - DynamicObject ec_ecbd_pro_cbs = BusinessDataServiceHelper.loadSingle("ec_ecbd_pro_cbs", "id", qFilters);//"项目工序" - - QFilter filter2 = new QFilter("fiaccountorg", QCP.equals, org1.getPkValue());//财务记账组织 - filter2.and(new QFilter("billstatus", QCP.equals, "C"));//单据状态 - DynamicObject[] ec_projects = BusinessDataServiceHelper.load("ec_project", "id,zcgj_init", new QFilter[]{filter2});// "项目" - - if (ec_ecbd_pro_cbs == null && zcgj_accountcost == null && ec_projects.length == 0) { - continue; - } - - // 构建去重key - 根据工序或成本中心分别处理 - String processName = rptAssistBalanceGx.getString("zcgj_processname"); // 工序名称 - String costCompanyName = rptAssistBalanceGx.getString("zcgj_costcompanyname"); // 成本中心名称 - Object costType = zcgj_accountcost != null ? zcgj_accountcost.get("zcgj_acccostentry.zcgj_costtype") : null; // 成本项 - Object secType = zcgj_accountcost != null ? zcgj_accountcost.get("zcgj_acccostentry.zcgj_sectype") : null; // 二级分类 - - if (costType == null) { - continue; - } - - String secTypeName = ""; - if (secType != null) { - secTypeName = secType.toString(); - } - String costTypeName = costType.toString(); - - // 如果二级分类为"70.55"且成本项为"70"，则对该行的成本金额进行扣减 - if ("70.55".equals(secTypeName) && "70.".equals(costTypeName)) { - QFilter filter5 = new QFilter("billstatus", QCP.equals, "C");//单据状态 - filter5.and(new QFilter("zcgj_entryentity.zcgj_assperiod", QCP.equals, period1.getPkValue()));//折旧期间 - filter5.and(new QFilter("zcgj_entryentity.zcgj_zjuseorg", QCP.equals, org1.getPkValue()));//使用组织 - DynamicObjectCollection eceq_equipinfoCollection = QueryServiceHelper.query("eceq_equipinfo", - "id,zcgj_entryentity.zcgj_shareamount", - new QFilter[]{filter5});//"设备详情" - if (eceq_equipinfoCollection.size() > 0) { - BigDecimal zcgj_shareamounts = BigDecimal.ZERO; - for (DynamicObject eceq_equipinfo : eceq_equipinfoCollection) { - BigDecimal shareAmount = eceq_equipinfo.getBigDecimal("zcgj_entryentity.zcgj_shareamount"); - if (shareAmount != null) { - zcgj_shareamounts = zcgj_shareamounts.add(shareAmount); - } - } - - // 扣减成本金额 - Object currentAmount = rptAssistBalanceGx.get("zcgj_debitlocal"); - BigDecimal newAmount = new BigDecimal(currentAmount != null ? currentAmount.toString() : "0") - .subtract(zcgj_shareamounts); - - // 确保不会出现负数 - if (newAmount.compareTo(BigDecimal.ZERO) < 0) { - newAmount = BigDecimal.ZERO; - } - - // 更新rptAssistBalanceGx中的金额 - rptAssistBalanceGx.set("zcgj_debitlocal", newAmount); - } - } - - String uniqueKey = ""; - if (processName != null && !processName.isEmpty()) { - // 存在工序时，按照工序+成本项+二级分类去重 - uniqueKey = "PROCESS_" + processName + "_" + (costType != null ? costType.toString() : "") + "_" + (secType != null ? secType.toString() : ""); - } else { - // 如果没有工序，则按照成本项+二级分类去重 - uniqueKey = "NONE_" + (costType != null ? costType.toString() : "") + "_" + (secType != null ? secType.toString() : ""); - } - - DynamicObject existingEntry = summaryMap.get(uniqueKey); - if (existingEntry != null) { - // 如果已存在相同key的记录，则累加成本金额 - Object existingAmount = existingEntry.get("costamount"); - Object newAmount = rptAssistBalanceGx.get("zcgj_debitlocal");//本期发生借方 - - // 进行金额累加 - BigDecimal totalAmount = new BigDecimal(existingAmount != null ? existingAmount.toString() : "0") - .add(new BigDecimal(newAmount != null ? newAmount.toString() : "0")); - existingEntry.set("costamount", totalAmount); - - // 同时更新子分录的金额 - DynamicObject subEntry = existingEntry.getDynamicObjectCollection("zcgj_subentryentity").get(0); - if (subEntry != null) { - subEntry.set("zcgj_costamount", totalAmount); - } - } else { - // 如果不存在相同key的记录，则创建新记录 - DynamicObject newEntry = new DynamicObject(entryType); - DynamicObjectCollection subEntryEntityCollection = newEntry.getDynamicObjectCollection("zcgj_subentryentity");//成本核算维度明细 - DynamicObjectType subEntryEntityType = subEntryEntityCollection.getDynamicObjectType(); - DynamicObject newEntrySubEntryEntity = new DynamicObject(subEntryEntityType); - - if (ec_projects.length != 0) { - for (DynamicObject ec_project : ec_projects) { - boolean zcgj_init = ec_project.getBoolean("zcgj_init");//默认项目 - if (zcgj_init) { - - DynamicObject ec_project_f7 = BusinessDataServiceHelper.loadSingle("ec_project_f7", "id", - new QFilter[]{new QFilter("id", QCP.equals, ec_project.getPkValue())});//"项目" - - newEntry.set("project", ec_project_f7);//项目 - newEntrySubEntryEntity.set("zcgj_project", ec_project_f7);//项目 - break; - } - } - Object project = newEntry.get("project"); - if (project == null) { - - DynamicObject ec_project_f7 = BusinessDataServiceHelper.loadSingle("ec_project_f7", "id", - new QFilter[]{new QFilter("id", QCP.equals, ec_projects[0].getPkValue())});//"项目" - - newEntry.set("project", ec_project_f7);//项目 - newEntrySubEntryEntity.set("zcgj_project", ec_project_f7);//项目 - } - } - if (ec_ecbd_pro_cbs != null) { - newEntry.set("cbs", ec_ecbd_pro_cbs);//成本分解结构 - newEntrySubEntryEntity.set("zcgj_cbs", ec_ecbd_pro_cbs);//成本分解结构 - } - if (zcgj_accountcost != null) { - newEntry.set("costtype", zcgj_accountcost.get("zcgj_acccostentry.zcgj_costtype"));//成本项 - newEntry.set("zcgj_sectype", zcgj_accountcost.get("zcgj_acccostentry.zcgj_sectype"));//二级分类 - newEntrySubEntryEntity.set("zcgj_costtype", zcgj_accountcost.get("zcgj_acccostentry.zcgj_costtype"));//成本项 - newEntrySubEntryEntity.set("zcgj_sectype1", zcgj_accountcost.get("zcgj_acccostentry.zcgj_sectype"));//二级分类 - } - newEntry.set("costamount", rptAssistBalanceGx.get("zcgj_debitlocal"));//成本金额 - newEntrySubEntryEntity.set("zcgj_costamount", rptAssistBalanceGx.get("zcgj_debitlocal"));//成本金额 - - summaryMap.put(uniqueKey, newEntry); - subEntryEntityCollection.add(newEntrySubEntryEntity); - } - } - - // 在添加数据前进行排序 - // 将summaryMap转换为List并按成本项数值排序 - List sortedEntries = new ArrayList<>(summaryMap.values()); - sortedEntries.sort((entry1, entry2) -> { - Object costType1 = entry1.get("costtype"); - Object costType2 = entry2.get("costtype"); - - if (costType1 == null && costType2 == null) return 0; - if (costType1 == null) return -1; - if (costType2 == null) return 1; - - try { - Double num1 = Double.parseDouble(costType1.toString()); - Double num2 = Double.parseDouble(costType2.toString()); - return num1.compareTo(num2); - } catch (NumberFormatException e) { - return costType1.toString().compareTo(costType2.toString()); - } - }); - - entryCollection.clear(); - // 按排序后的顺序添加数据 - entryCollection.addAll(sortedEntries); - - this.getView().updateView("entryentity");//刷新分录 - this.getView().updateView("zcgj_subentryentity");//刷新分录 - this.getModel().endInit(); - this.getView().invokeOperation("save");//保存用于刷新 - this.getView().invokeOperation("refresh");//刷新全局页面 - } else if ("newentry1".equals(formOperate.getOperateKey())) { + if ("newentry1".equals(formOperate.getOperateKey())) { //成本核算维度明细子分录增行按钮 int rowIndex = this.getModel().getEntryCurrentRowIndex("entryentity");//企业费用成本分摊明细分录行索引 int rowCount = this.getModel().getEntryRowCount("entryentity");//企业费用成本分摊明细分录总行数 @@ -353,9 +162,258 @@ public class EntCostSplitBillPlugin extends AbstractBillPlugIn implements Before this.getView().showTipNotification(ResManager.loadKDString("请先选中1行企业费用成本分摊明细分录行数据", "MaterialCostBillPlugin_1", "ec-ecco-formplugin", new Object[0])); args.setCancel(true); } + } else if ("autogetdata".equals(formOperate.getOperateKey())) { + DynamicObjectCollection entryEntityCollection = this.getModel().getDataEntity(true).getDynamicObjectCollection("entryentity");//企业费用成本分摊明细分录 + if (entryEntityCollection.size() > 0) { + args.setCancel(true); + ConfirmCallBackListener confirmCallBackListener = new ConfirmCallBackListener("autogetdata", this); + //设置页面确认框，参数为：标题，选项框类型，回调监听 + this.getView().showConfirm("自动取数将清空列表数据，您确认执行吗？", MessageBoxOptions.YesNo, confirmCallBackListener); + } else { + autoFetchData(); + } } } + /** + * 自动取数处理方法 + */ + private void autoFetchData() { + //自动取数 + Object org = this.getModel().getValue("org");//所属组织 + if (org == null) { + this.getView().showTipNotification("请选择组织"); + return; + } + Object period = this.getModel().getValue("period");//期间 + if (period == null) { + this.getView().showTipNotification("请选择期间"); + return; + } + this.getModel().beginInit(); + DynamicObject org1 = (DynamicObject) org;//所属组织 + DynamicObject period1 = (DynamicObject) period;//期间 + DynamicObjectCollection entryCollection = this.getModel().getDataEntity(true).getDynamicObjectCollection("entryentity");//企业费用成本分摊明细分录 + DynamicObjectType entryType = entryCollection.getDynamicObjectType(); + if (entryCollection.size() > 0) { + entryCollection.clear(); + } + + QFilter filter = new QFilter("zcgj_org", QCP.equals, org1.getPkValue());//核算组织 + filter.and(new QFilter("zcgj_period", QCP.equals, period1.getPkValue()));//期间 +// filter.and(new QFilter("zcgj_isnew", QCP.equals, true));//是否最新 + DynamicObjectCollection rptAssistBalanceGxCollection = QueryServiceHelper.query("zcgj_rpt_assistbalancegx", + "id,zcgj_account,zcgj_processname,zcgj_debitlocal,zcgj_costcompanyname", + new QFilter[]{filter});//"核算维度余额取数表(矿山工序维度)" + + // 在循环开始前定义汇总Map + Map summaryMap = new HashMap<>(); + + for (DynamicObject rptAssistBalanceGx : rptAssistBalanceGxCollection) { + Object debitLocal = rptAssistBalanceGx.get("zcgj_debitlocal");//本期发生借方 + if (debitLocal == null || + (debitLocal instanceof BigDecimal && ((BigDecimal) debitLocal).compareTo(BigDecimal.ZERO) <= 0) || + (debitLocal instanceof String && ((String) debitLocal).equals("0"))) { + continue; + } + + QFilter[] qFilter = new QFilter[]{new QFilter("id", QCP.equals, rptAssistBalanceGx.get("zcgj_account"))};//科目ID + DynamicObject bd_accountview = BusinessDataServiceHelper.loadSingle("bd_accountview", + "id,number,name", qFilter);//"会计科目" + if (bd_accountview == null) { + continue; + } + + QFilter filter3 = new QFilter("zcgj_companyblentry.zcgj_org", QCP.equals, org1.getPkValue());//组织 + DynamicObject zcgj_companybelong = QueryServiceHelper.queryOne("zcgj_companybelong", "id", + new QFilter[]{filter3});//"公司归属区域" + Long id = 0L; + if (zcgj_companybelong != null) { + id = (Long) zcgj_companybelong.get("id"); + } + + QFilter filter1 = new QFilter("zcgj_acccostentry.zcgj_accountnumber", QCP.equals, bd_accountview.getString("number"));//科目编码 + filter1.and(new QFilter("zcgj_belongcompany", QCP.equals, id)); + DynamicObject zcgj_accountcost = QueryServiceHelper.queryOne("zcgj_accountcost", + "id,zcgj_acccostentry.zcgj_costtype,zcgj_acccostentry.zcgj_sectype", + new QFilter[]{filter1});//"会计科目与成本项目" + + QFilter[] qFilters = new QFilter[]{new QFilter("name", QCP.equals, rptAssistBalanceGx.get("zcgj_processname"))};//工序名称 + DynamicObject ec_ecbd_pro_cbs = BusinessDataServiceHelper.loadSingle("ec_ecbd_pro_cbs", "id", qFilters);//"项目工序" + + QFilter filter2 = new QFilter("fiaccountorg", QCP.equals, org1.getPkValue());//财务记账组织 + filter2.and(new QFilter("billstatus", QCP.equals, "C"));//单据状态 + DynamicObject[] ec_projects = BusinessDataServiceHelper.load("ec_project", "id,zcgj_init", new QFilter[]{filter2});// "项目" + + if (ec_ecbd_pro_cbs == null && zcgj_accountcost == null && ec_projects.length == 0) { + continue; + } + + // 构建去重key - 根据工序或成本中心分别处理 + String processName = rptAssistBalanceGx.getString("zcgj_processname"); // 工序名称 + String costCompanyName = rptAssistBalanceGx.getString("zcgj_costcompanyname"); // 成本中心名称 + Object costType = zcgj_accountcost != null ? zcgj_accountcost.get("zcgj_acccostentry.zcgj_costtype") : null; // 成本项 + Object secType = zcgj_accountcost != null ? zcgj_accountcost.get("zcgj_acccostentry.zcgj_sectype") : null; // 二级分类 + + if (costType == null) { + continue; + } + + String secTypeName = ""; + if (secType != null) { + secTypeName = secType.toString(); + } + String costTypeName = costType.toString(); + + // 如果二级分类为"70.55"且成本项为"70"，则对该行的成本金额进行扣减 + if ("70.55".equals(secTypeName) && "70.".equals(costTypeName)) { + QFilter filter5 = new QFilter("billstatus", QCP.equals, "C");//单据状态 + filter5.and(new QFilter("zcgj_entryentity.zcgj_assperiod", QCP.equals, period1.getPkValue()));//折旧期间 + filter5.and(new QFilter("zcgj_entryentity.zcgj_zjuseorg", QCP.equals, org1.getPkValue()));//使用组织 + DynamicObjectCollection eceq_equipinfoCollection = QueryServiceHelper.query("eceq_equipinfo", + "id,zcgj_entryentity.zcgj_shareamount", + new QFilter[]{filter5});//"设备详情" + if (eceq_equipinfoCollection.size() > 0) { + BigDecimal zcgj_shareamounts = BigDecimal.ZERO; + for (DynamicObject eceq_equipinfo : eceq_equipinfoCollection) { + BigDecimal shareAmount = eceq_equipinfo.getBigDecimal("zcgj_entryentity.zcgj_shareamount"); + if (shareAmount != null) { + zcgj_shareamounts = zcgj_shareamounts.add(shareAmount); + } + } + + // 扣减成本金额 + Object currentAmount = rptAssistBalanceGx.get("zcgj_debitlocal"); + BigDecimal newAmount = new BigDecimal(currentAmount != null ? currentAmount.toString() : "0") + .subtract(zcgj_shareamounts); + + // 确保不会出现负数 + if (newAmount.compareTo(BigDecimal.ZERO) < 0) { + newAmount = BigDecimal.ZERO; + } + + // 更新rptAssistBalanceGx中的金额 + rptAssistBalanceGx.set("zcgj_debitlocal", newAmount); + } + } + + String uniqueKey = ""; + if (processName != null && !processName.isEmpty()) { + // 存在工序时，按照工序+成本项+二级分类去重 + uniqueKey = "PROCESS_" + processName + "_" + (costType != null ? costType.toString() : "") + "_" + (secType != null ? secType.toString() : ""); + } else { + // 如果没有工序，则按照成本项+二级分类去重 + uniqueKey = "NONE_" + (costType != null ? costType.toString() : "") + "_" + (secType != null ? secType.toString() : ""); + } + + DynamicObject existingEntry = summaryMap.get(uniqueKey); + if (existingEntry != null) { + // 如果已存在相同key的记录，则累加成本金额 + Object existingAmount = existingEntry.get("costamount"); + Object newAmount = rptAssistBalanceGx.get("zcgj_debitlocal");//本期发生借方 + + // 进行金额累加 + BigDecimal totalAmount = new BigDecimal(existingAmount != null ? existingAmount.toString() : "0") + .add(new BigDecimal(newAmount != null ? newAmount.toString() : "0")); + existingEntry.set("costamount", totalAmount); + + // 同时更新子分录的金额 + DynamicObject subEntry = existingEntry.getDynamicObjectCollection("zcgj_subentryentity").get(0); + if (subEntry != null) { + subEntry.set("zcgj_costamount", totalAmount); + } + } else { + // 如果不存在相同key的记录，则创建新记录 + DynamicObject newEntry = new DynamicObject(entryType); + DynamicObjectCollection subEntryEntityCollection = newEntry.getDynamicObjectCollection("zcgj_subentryentity");//成本核算维度明细 + DynamicObjectType subEntryEntityType = subEntryEntityCollection.getDynamicObjectType(); + DynamicObject newEntrySubEntryEntity = new DynamicObject(subEntryEntityType); + + if (ec_projects.length != 0) { + for (DynamicObject ec_project : ec_projects) { + boolean zcgj_init = ec_project.getBoolean("zcgj_init");//默认项目 + if (zcgj_init) { + + DynamicObject ec_project_f7 = BusinessDataServiceHelper.loadSingle("ec_project_f7", "id", + new QFilter[]{new QFilter("id", QCP.equals, ec_project.getPkValue())});//"项目" + + newEntry.set("project", ec_project_f7);//项目 + newEntrySubEntryEntity.set("zcgj_project", ec_project_f7);//项目 + break; + } + } + Object project = newEntry.get("project"); + if (project == null) { + + DynamicObject ec_project_f7 = BusinessDataServiceHelper.loadSingle("ec_project_f7", "id", + new QFilter[]{new QFilter("id", QCP.equals, ec_projects[0].getPkValue())});//"项目" + + newEntry.set("project", ec_project_f7);//项目 + newEntrySubEntryEntity.set("zcgj_project", ec_project_f7);//项目 + } + } + if (ec_ecbd_pro_cbs != null) { + newEntry.set("cbs", ec_ecbd_pro_cbs);//成本分解结构 + newEntrySubEntryEntity.set("zcgj_cbs", ec_ecbd_pro_cbs);//成本分解结构 + } + if (zcgj_accountcost != null) { + newEntry.set("costtype", zcgj_accountcost.get("zcgj_acccostentry.zcgj_costtype"));//成本项 + newEntry.set("zcgj_sectype", zcgj_accountcost.get("zcgj_acccostentry.zcgj_sectype"));//二级分类 + newEntrySubEntryEntity.set("zcgj_costtype", zcgj_accountcost.get("zcgj_acccostentry.zcgj_costtype"));//成本项 + newEntrySubEntryEntity.set("zcgj_sectype1", zcgj_accountcost.get("zcgj_acccostentry.zcgj_sectype"));//二级分类 + } + newEntry.set("costamount", rptAssistBalanceGx.get("zcgj_debitlocal"));//成本金额 + newEntrySubEntryEntity.set("zcgj_costamount", rptAssistBalanceGx.get("zcgj_debitlocal"));//成本金额 + + summaryMap.put(uniqueKey, newEntry); + subEntryEntityCollection.add(newEntrySubEntryEntity); + } + } + + // 在添加数据前进行排序 + // 将summaryMap转换为List并按成本项数值排序 + List sortedEntries = new ArrayList<>(summaryMap.values()); + sortedEntries.sort((entry1, entry2) -> { + Object costType1 = entry1.get("costtype"); + Object costType2 = entry2.get("costtype"); + + if (costType1 == null && costType2 == null) return 0; + if (costType1 == null) return -1; + if (costType2 == null) return 1; + + try { + Double num1 = Double.parseDouble(costType1.toString()); + Double num2 = Double.parseDouble(costType2.toString()); + return num1.compareTo(num2); + } catch (NumberFormatException e) { + return costType1.toString().compareTo(costType2.toString()); + } + }); + + entryCollection.clear(); + StringBuilder costTypeBuilder = new StringBuilder(); + for (int i = 0; i < sortedEntries.size(); i++) { + DynamicObject dynamicObject = sortedEntries.get(i); + String costtype = dynamicObject.getString("costtype"); + + if (i > 0) { + costTypeBuilder.append("+"); + } + costTypeBuilder.append(costtype); + } + String mergedCostTypes = costTypeBuilder.toString(); + this.getModel().setValue("description", mergedCostTypes); + // 按排序后的顺序添加数据 + entryCollection.addAll(sortedEntries); + + this.getModel().endInit(); + OperateOption option = OperateOption.create(); + option.setVariableValue(OperateOptionConst.ISSHOWMESSAGE, "false"); + OperationServiceHelper.executeOperate("save", this.getView().getEntityId(), + new DynamicObject[]{this.getModel().getDataEntity()}, option); + this.getView().showSuccessNotification("已完成取数"); + this.getView().invokeOperation("refresh");//刷新全局页面 + } private static Integer getSortValue(String type) { if ("10.".equals(type)) return 10;