anpeng/apzl_leasing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1.回盘后，明细回盘状态错误问题。

Browse Source
This commit is contained in:
zhangbb 2018-12-13 15:38:48 +08:00
parent 08c3ba7e16
commit 90e7de2eac
1 changed files with 28 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
src_cmb/com/tenwa/sdk/controller/CmbToCallbackController.java
View File

@ -164,30 +164,32 @@ public class CmbToCallbackController extends BaseFlowStartAction {
callback_detail_bo.setAttributeValue("RTNNAR",callback_detail.getRTNNAR());
this.initTabeUserInfo(callback_detail_bo);
callback_detail_bom.saveObject(callback_detail_bo);
String RTNFLG = callback_detail.getRTNFLG();
/*String RTNFLG = callback_detail.getRTNFLG();
String sql1="";
if("S".equals(RTNFLG)){
sql1 = "update O set O.EBANK_STATUS='05' where O.FLOWUNID='"+FLOWUNID+"'";
}else{
sql1 = "update O set O.EBANK_STATUS='04' where O.FLOWUNID='"+FLOWUNID+"'";
}
JBOFactory.createBizObjectQuery(LC_FUND_INCOME_TEMP.CLASS_NAME,sql1).executeUpdate();
JBOFactory.createBizObjectQuery(LC_FUND_INCOME_TEMP.CLASS_NAME,sql1).executeUpdate();*/
//保存项目进度表
saveBusinessStatus(FLOWUNID);
}
tx.commit();
sql(tx);
map.put("code", "0") ;
map.put("msg", "查询结果刷新成功") ;
JSONObject jsonObj = JSONObject.fromObject(map);
return jsonObj.toString();
}else {
sql();
sql(tx);
map.put("code", "1") ;
map.put("msg", "没有找到相关数据,请检查") ;
JSONObject jsonObj = JSONObject.fromObject(map);
return jsonObj.toString();
}
}else {
sql();
sql(tx);
map.put("code", "1") ;
map.put("msg", result.getInfo().getERRMSG()) ;
JSONObject jsonObj = JSONObject.fromObject(map);
@ -195,19 +197,34 @@ public class CmbToCallbackController extends BaseFlowStartAction {
}
}else {
sql();
sql(tx);
map.put("code", "1") ;
map.put("msg", "暂无支付申请发起成功数据,请检查") ;
JSONObject jsonObj = JSONObject.fromObject(map);
return jsonObj.toString();
}
}
public void sql() throws JBOException{
String sql2 = "update O left join jbo.com.tenwa.lease.comm.LB_CONTRACT_INFO lci on lci.id=O.contract_id"
+" left join jbo.com.tenwa.lease.comm.LC_FUND_INCOME_CALLBACK_DETAIL_TEMP tt on tt.DISTRIBUTOR_ID=lci.distributor_id"
+" and O.FLOWUNID=tt.FLOWUNID set O.EBANK_STATUS=case when tt.RTNFLG='S' then '05' else '04' end where O.FLOWUNID='"+FLOWUNID+"'" ;
JBOFactory.createBizObjectQuery(LC_FUND_INCOME_TEMP.CLASS_NAME,sql2).executeUpdate();
/**
* 遍历循环付款信息
* 放款成功和放款失败
*/
public void sql(JBOTransaction tx) throws JBOException{
BizObjectManager callback_detail_bom1 = JBOFactory.getBizObjectManager(LC_FUND_INCOME_CALLBACK_DETAIL_TEMP.CLASS_NAME) ;
tx.join(callback_detail_bom1);
List<BizObject> callback_detail_di = callback_detail_bom1.createQuery("select o.DISTRIBUTOR_ID from o where FLOWUNID=:FLOWUNID").setParameter("FLOWUNID", FLOWUNID).getResultList();
String sql1="update O set O.EBANK_STATUS='04' where O.FLOWUNID='"+FLOWUNID+"'";
JBOFactory.createBizObjectQuery(LC_FUND_INCOME_TEMP.CLASS_NAME,sql1).executeUpdate();
String distributor_id=null;
if(callback_detail_di!=null||(!"".equals(callback_detail_di))){
for(BizObject di:callback_detail_di){
distributor_id=di.getAttribute("DISTRIBUTOR_ID").toString();
String sql2 = "update O left join jbo.com.tenwa.lease.comm.LB_CONTRACT_INFO lci on lci.id=O.contract_id"
+" left join jbo.com.tenwa.lease.comm.LC_FUND_INCOME_CALLBACK_DETAIL_TEMP tt on tt.DISTRIBUTOR_ID=lci.distributor_id"
+" and O.FLOWUNID=tt.FLOWUNID set O.EBANK_STATUS=case when tt.RTNFLG='S' then '05' else '04' end where O.FLOWUNID='"+FLOWUNID+"'and tt.DISTRIBUTOR_ID='"+distributor_id+"'" ;
JBOFactory.createBizObjectQuery(LC_FUND_INCOME_TEMP.CLASS_NAME,sql2).executeUpdate();
}
}
}
/**
* 将银行返回的结果保存项目进度表