Compare commits

..

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

1 changed files with 3 additions and 20 deletions

View File

@ -48,27 +48,19 @@ 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){
boolean res = UpdateFilingApplicationData(shkd_baed, dataEntity); 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 boolean UpdateFilingApplicationData(DynamicObject shkd_baed,DynamicObject dataEntity){ public void 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")));
@ -82,8 +74,6 @@ 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","提款处理");
} }
@ -115,7 +105,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 false; return;
} }
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));
@ -131,12 +121,6 @@ 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);
} }
@ -151,7 +135,6 @@ public class SubmitOccupyFilingApplication extends AbstractOperationServicePlugI
} }
SaveServiceHelper.save(new DynamicObject[]{shkd_filingapplication}); SaveServiceHelper.save(new DynamicObject[]{shkd_filingapplication});
return res;
} }