From 90e7de2eac04e38fbd4ab19d800ed7a2874f065e Mon Sep 17 00:00:00 2001
From: zhangbb <zhangbb@DESKTOP-GH0CKE6>
Date: Thu, 13 Dec 2018 15:38:48 +0800
Subject: [PATCH] =?UTF-8?q?1.=E5=9B=9E=E7=9B=98=E5=90=8E=EF=BC=8C=E6=98=8E?=
 =?UTF-8?q?=E7=BB=86=E5=9B=9E=E7=9B=98=E7=8A=B6=E6=80=81=E9=94=99=E8=AF=AF?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/CmbToCallbackController.java   | 39 +++++++++++++------
 1 file changed, 28 insertions(+), 11 deletions(-)

diff --git a/src_cmb/com/tenwa/sdk/controller/CmbToCallbackController.java b/src_cmb/com/tenwa/sdk/controller/CmbToCallbackController.java
index e97f186d4..80ea520dc 100644
--- a/src_cmb/com/tenwa/sdk/controller/CmbToCallbackController.java
+++ b/src_cmb/com/tenwa/sdk/controller/CmbToCallbackController.java
@@ -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();
+			}
+		}
 	}
 	/**
 	 * 将银行返回的结果保存项目进度表