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

Compare commits

base: wenlukang1:e90cf2c1fefa1fe43963237d9fe26e72a69d103f
Branches Tags
wenlukang1:main
..
compare: wenlukang1:839b8716d15d48baba74c6309ef79394ccb7fca6
Branches Tags
wenlukang1:main

No commits in common. "e90cf2c1fefa1fe43963237d9fe26e72a69d103f" and "839b8716d15d48baba74c6309ef79394ccb7fca6" have entirely different histories.
e90cf2c1fe ... 839b8716d1

1 changed files with 3 additions and 20 deletions
Show Stats Expand all files Collapse all files

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

@ -48,27 +48,19 @@ 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){
boolean res = UpdateFilingApplicationData(shkd_baed, dataEntity);
if (res){
arrayList.add(dataEntity);
}
UpdateFilingApplicationData(shkd_baed,dataEntity);
}
} catch (Exception ex) {
logger.info("同步代码失败");
}
}
DynamicObject[] results = (DynamicObject[]) arrayList.toArray(new DynamicObject[arrayList.size()]);
e.setDataEntities(results);
}
public boolean UpdateFilingApplicationData(DynamicObject shkd_baed,DynamicObject dataEntity){
boolean res=true;
public void UpdateFilingApplicationData(DynamicObject shkd_baed,DynamicObject dataEntity){
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")));
@ -82,8 +74,6 @@ 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","提款处理");
}
@ -115,7 +105,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 false;
return;
}
shkd_filingapplication.set("shkd_zyed",hebintotal);
shkd_filingapplication.set("shkd_syed",shkd_zed.subtract(hebintotal));
@ -131,12 +121,6 @@ public class SubmitOccupyFilingApplication extends AbstractOperationServicePlugI
for (Map<String, Object> 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);
}
@ -151,7 +135,6 @@ public class SubmitOccupyFilingApplication extends AbstractOperationServicePlugI
}
SaveServiceHelper.save(new DynamicObject[]{shkd_filingapplication});
return res;
}