wenlukang1
/
CTSK_DEV
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

提交人：陈绍鑫 

日期：2025/11/12 15：30
内容:备案申请
This commit is contained in:
陈绍鑫 2025-11-13 16:40:03 +08:00
parent c8da9848e5
commit e7a5da4be3
1 changed files with 20 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
sys/shkd-sys-sys/src/main/java/shkd/sys/sys/plugin/operation/SubmitOccupyFilingApplication.java
View File

@ -48,19 +48,27 @@ public class SubmitOccupyFilingApplication extends AbstractOperationServicePlugI
public void afterExecuteOperationTransaction(AfterOperationArgs e) { public void afterExecuteOperationTransaction(AfterOperationArgs e) {
super.afterExecuteOperationTransaction(e); super.afterExecuteOperationTransaction(e);
logger.info("同步开始"); logger.info("同步开始");
//用于接收成功的数据
ArrayList arrayList = new ArrayList();
DynamicObject[] dataEntities = e.getDataEntities(); DynamicObject[] dataEntities = e.getDataEntities();
for (DynamicObject dataEntity : dataEntities) { for (DynamicObject dataEntity : dataEntities) {
try { try {
DynamicObject shkd_baed = dataEntity.getDynamicObject("shkd_baed"); DynamicObject shkd_baed = dataEntity.getDynamicObject("shkd_baed");
if (shkd_baed!=null){ if (shkd_baed!=null){
UpdateFilingApplicationData(shkd_baed,dataEntity); boolean res = UpdateFilingApplicationData(shkd_baed, dataEntity);
if (res){
arrayList.add(dataEntity);
}
} }
} catch (Exception ex) { } catch (Exception ex) {
logger.info("同步代码失败"); 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 qFilter = new QFilter("billstatus", QCP.in, Arrays.asList("B", "C"));//提交，审核状态
//提款处理(银行提款处理，债券发行) //提款处理(银行提款处理，债券发行)
QFilter zqfxqFilter = qFilter.and(new QFilter("shkd_baed", QCP.equals, shkd_baed.getLong("id"))); 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","债券发行"); zqfxmap.put("shkd_djlx","债券发行");
} else if (billno.contains("JKHT")) { } else if (billno.contains("JKHT")) {
zqfxmap.put("shkd_djlx","借款合同"); zqfxmap.put("shkd_djlx","借款合同");
} else if (billno.contains("RC")){
zqfxmap.put("shkd_djlx","售后租回回款");
}else { }else {
zqfxmap.put("shkd_djlx","提款处理"); zqfxmap.put("shkd_djlx","提款处理");
} }
@ -105,7 +115,7 @@ public class SubmitOccupyFilingApplication extends AbstractOperationServicePlugI
BigDecimal shkd_zed = shkd_filingapplication.getBigDecimal("shkd_zed"); BigDecimal shkd_zed = shkd_filingapplication.getBigDecimal("shkd_zed");
if (shkd_zed.subtract(hebintotal).compareTo(BigDecimal.ZERO)<0){ if (shkd_zed.subtract(hebintotal).compareTo(BigDecimal.ZERO)<0){
this.getOperationResult().addErrorInfo(setErrorMessage(dataEntity, dataEntity.getString("billno")+"失败原因："+"备案申请余额不足")); this.getOperationResult().addErrorInfo(setErrorMessage(dataEntity, dataEntity.getString("billno")+"失败原因："+"备案申请余额不足"));
return; return false;
} }
shkd_filingapplication.set("shkd_zyed",hebintotal); shkd_filingapplication.set("shkd_zyed",hebintotal);
shkd_filingapplication.set("shkd_syed",shkd_zed.subtract(hebintotal)); shkd_filingapplication.set("shkd_syed",shkd_zed.subtract(hebintotal));
@ -121,6 +131,12 @@ public class SubmitOccupyFilingApplication extends AbstractOperationServicePlugI
for (Map<String, Object> stringObjectMap : result) { for (Map<String, Object> stringObjectMap : result) {
sum=sum.add((BigDecimal) stringObjectMap.get("shkd_zyje")); 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); entry.set("shkd_zyamount",sum);
} }
@ -135,6 +151,7 @@ public class SubmitOccupyFilingApplication extends AbstractOperationServicePlugI
} }
SaveServiceHelper.save(new DynamicObject[]{shkd_filingapplication}); SaveServiceHelper.save(new DynamicObject[]{shkd_filingapplication});
return res;
} }