From e7a5da4be397ef7d358d17de9784071cffca93d3 Mon Sep 17 00:00:00 2001 From: csx <1981897232@qq.com> Date: Thu, 13 Nov 2025 16:40:03 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8F=90=E4=BA=A4=E4=BA=BA=EF=BC=9A=E9=99=88?= =?UTF-8?q?=E7=BB=8D=E9=91=AB=20=E6=97=A5=E6=9C=9F=EF=BC=9A2025/11/12=2015?= =?UTF-8?q?=EF=BC=9A30=20=E5=86=85=E5=AE=B9:=E5=A4=87=E6=A1=88=E7=94=B3?= =?UTF-8?q?=E8=AF=B7?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../SubmitOccupyFilingApplication.java | 23 ++++++++++++++++--- 1 file changed, 20 insertions(+), 3 deletions(-) diff --git a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/operation/SubmitOccupyFilingApplication.java b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/operation/SubmitOccupyFilingApplication.java index 3ba3e5b..7d113c5 100644 --- a/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/operation/SubmitOccupyFilingApplication.java +++ b/sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/operation/SubmitOccupyFilingApplication.java @@ -48,19 +48,27 @@ public class SubmitOccupyFilingApplication extends AbstractOperationServicePlugI public void afterExecuteOperationTransaction(AfterOperationArgs e) { super.afterExecuteOperationTransaction(e); logger.info("同步开始"); + //用于接收成功的数据 + ArrayList arrayList = new ArrayList(); DynamicObject[] dataEntities = e.getDataEntities(); for (DynamicObject dataEntity : dataEntities) { try { DynamicObject shkd_baed = dataEntity.getDynamicObject("shkd_baed"); if (shkd_baed!=null){ - UpdateFilingApplicationData(shkd_baed,dataEntity); + boolean res = UpdateFilingApplicationData(shkd_baed, dataEntity); + if (res){ + arrayList.add(dataEntity); + } } } catch (Exception ex) { logger.info("同步代码失败"); } } + DynamicObject[] results = (DynamicObject[]) arrayList.toArray(new DynamicObject[arrayList.size()]); + e.setDataEntities(results); } - public void UpdateFilingApplicationData(DynamicObject shkd_baed,DynamicObject dataEntity){ + public boolean UpdateFilingApplicationData(DynamicObject shkd_baed,DynamicObject dataEntity){ + boolean res=true; QFilter qFilter = new QFilter("billstatus", QCP.in, Arrays.asList("B", "C"));//提交，审核状态 //提款处理(银行提款处理，债券发行) QFilter zqfxqFilter = qFilter.and(new QFilter("shkd_baed", QCP.equals, shkd_baed.getLong("id"))); @@ -74,6 +82,8 @@ public class SubmitOccupyFilingApplication extends AbstractOperationServicePlugI zqfxmap.put("shkd_djlx","债券发行"); } else if (billno.contains("JKHT")) { zqfxmap.put("shkd_djlx","借款合同"); + } else if (billno.contains("RC")){ + zqfxmap.put("shkd_djlx","售后租回回款"); }else { zqfxmap.put("shkd_djlx","提款处理"); } @@ -105,7 +115,7 @@ public class SubmitOccupyFilingApplication extends AbstractOperationServicePlugI BigDecimal shkd_zed = shkd_filingapplication.getBigDecimal("shkd_zed"); if (shkd_zed.subtract(hebintotal).compareTo(BigDecimal.ZERO)<0){ this.getOperationResult().addErrorInfo(setErrorMessage(dataEntity, dataEntity.getString("billno")+"失败原因："+"备案申请余额不足")); - return; + return false; } shkd_filingapplication.set("shkd_zyed",hebintotal); shkd_filingapplication.set("shkd_syed",shkd_zed.subtract(hebintotal)); @@ -121,6 +131,12 @@ public class SubmitOccupyFilingApplication extends AbstractOperationServicePlugI for (Map stringObjectMap : result) { sum=sum.add((BigDecimal) stringObjectMap.get("shkd_zyje")); } + BigDecimal shkd_rzje = entry.getBigDecimal("shkd_rzje"); + if (shkd_rzje.compareTo(sum)<0){ + int seq = entry.getInt("seq"); + this.getOperationResult().addErrorInfo(setErrorMessage(dataEntity, dataEntity.getString("billno")+"失败原因："+"备案申请余额第"+seq+"行可以余额不足请检查")); + return false; + } entry.set("shkd_zyamount",sum); } @@ -135,6 +151,7 @@ public class SubmitOccupyFilingApplication extends AbstractOperationServicePlugI } SaveServiceHelper.save(new DynamicObject[]{shkd_filingapplication}); + return res; }