From 6094f2394c92bf9e5d2536fd0dbebeac574ab7d9 Mon Sep 17 00:00:00 2001
From: liuzhao <liuzhao@DESKTOP-NULDTFM>
Date: Thu, 30 Aug 2018 14:04:05 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=BE=E6=AC=BE=E6=AD=A3=E5=B8=B8=E5=A4=B1?=
 =?UTF-8?q?=E8=B4=A5=E7=8A=B6=E6=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../commbusiness/LBContractLoanApply.java     |  5 --
 .../LBContractLoanSuccessOrFail.java          | 89 +++++++++++++++++++
 2 files changed, 89 insertions(+), 5 deletions(-)
 create mode 100644 src_tenwa/com/tenwa/lease/flow/contract/commbusiness/LBContractLoanSuccessOrFail.java

diff --git a/src_tenwa/com/tenwa/lease/flow/contract/commbusiness/LBContractLoanApply.java b/src_tenwa/com/tenwa/lease/flow/contract/commbusiness/LBContractLoanApply.java
index 30d1695d6..fcce288d5 100644
--- a/src_tenwa/com/tenwa/lease/flow/contract/commbusiness/LBContractLoanApply.java
+++ b/src_tenwa/com/tenwa/lease/flow/contract/commbusiness/LBContractLoanApply.java
@@ -78,11 +78,6 @@ public class LBContractLoanApply extends BaseBussiness {
 	  }catch(Exception e){
 		  tx.rollback();
 		  e.printStackTrace();
-	  }finally{
-			if(Sqlca!=null){
-		        Sqlca.disConnect();
-		        Sqlca = null;
-		    }
 	  }
 
 	
diff --git a/src_tenwa/com/tenwa/lease/flow/contract/commbusiness/LBContractLoanSuccessOrFail.java b/src_tenwa/com/tenwa/lease/flow/contract/commbusiness/LBContractLoanSuccessOrFail.java
new file mode 100644
index 000000000..ffb9ed7a6
--- /dev/null
+++ b/src_tenwa/com/tenwa/lease/flow/contract/commbusiness/LBContractLoanSuccessOrFail.java
@@ -0,0 +1,89 @@
+package com.tenwa.lease.flow.contract.commbusiness;
+
+import jbo.com.tenwa.lease.carbrand.BUSINESS_STATUS;
+
+import com.amarsoft.are.jbo.BizObject;
+import com.amarsoft.are.jbo.BizObjectManager;
+import com.amarsoft.are.jbo.JBOFactory;
+import com.amarsoft.are.jbo.JBOTransaction;
+import com.amarsoft.are.util.StringFunction;
+import com.amarsoft.awe.util.ASResultSet;
+import com.amarsoft.awe.util.SqlObject;
+import com.amarsoft.awe.util.Transaction;
+import com.amarsoft.context.ASUser;
+import com.tenwa.flow.baseBussion.BaseBussiness;
+
+public class LBContractLoanSuccessOrFail extends BaseBussiness{
+	@Override
+	public Object run(Transaction Sqlca) throws Exception {
+		this.initBussinessParam(Sqlca);
+		ASUser asUser = new ASUser(this.getAttribute("CurUserID").toString());
+		String FlowUnid = this.getAttribute("ObjectNo").toString();
+		this.saveBusinessStatus(Sqlca, asUser, FlowUnid);
+		String sMessage = "true";
+		return sMessage;
+	}
+
+	private void saveBusinessStatus(Transaction Sqlca, ASUser asUser,
+			String FlowUnid) throws Exception {
+		JBOTransaction tx = null;
+		tx = JBOFactory.createJBOTransaction();
+		String contractId="";
+		String contractNumber="";
+		String REQSTS ="";//银行处理状态    正常为  FIN
+		String RTNFLG ="";//业务处理结果    正常为  S
+		BizObjectManager bsbom = JBOFactory.getBizObjectManager(BUSINESS_STATUS.CLASS_NAME,tx);
+		
+		BizObject bsbo = bsbom.newObject();
+		
+		try{
+		
+			String sql = "SELECT lci.id,lci.contract_number,lfi.REQSTS,lfi.RTNFLG,lfi.flowunid FROM LC_FUND_INCOME_TEMP_HXM lfi LEFT JOIN LC_FUND_INCOME_TEMP lf ON lf.flowunid=lfi.flowunid LEFT JOIN lb_contract_info lci ON lci.id=lf.contract_id WHERE lfi.FLOWUNID=:FlowUnid GROUP BY lci.id";
+			SqlObject asql = new SqlObject(sql).setParameter("FlowUnid", FlowUnid);
+	
+			ASResultSet rs = null;
+			rs = Sqlca.getASResultSet(asql);
+			
+	
+			while (rs.next()) {
+				contractId = rs.getStringValue("id");
+				contractNumber = rs.getStringValue("contract_number");
+				REQSTS = rs.getStringValue("REQSTS");
+				RTNFLG = rs.getStringValue("RTNFLG");
+				if(REQSTS=="FIN" && RTNFLG=="S"){
+					BizObject businessStatus = JBOFactory.createBizObjectQuery(BUSINESS_STATUS.CLASS_NAME, "contract_number=:contract_number and business_status='31'").setParameter("contract_number", contractNumber).getSingleResult(false);
+					if(businessStatus==null){
+						bsbo.setAttributeValue(BUSINESS_STATUS.contract_number,contractNumber);
+						bsbo.setAttributeValue(BUSINESS_STATUS.business_status, "31");
+						bsbo.setAttributeValue(BUSINESS_STATUS.inputuserid,asUser.getUserID());
+						bsbo.setAttributeValue(BUSINESS_STATUS.inputtime,StringFunction.getTodayNow());
+						bsbo.setAttributeValue(BUSINESS_STATUS.inputorgid,asUser.getOrgID());
+						bsbom.saveObject(bsbo);
+					}else{
+						bsbom.createQuery("update o set inputuserid='"+asUser.getUserID()+"',inputtime='"+StringFunction.getTodayNow()+"',inputorgid='"+asUser.getOrgID()+"' where contract_number='"+contractNumber+"' and business_status='31'").executeUpdate();
+					}
+				} else {
+					BizObject businessStatus = JBOFactory.createBizObjectQuery(BUSINESS_STATUS.CLASS_NAME, "contract_number=:contract_number and business_status='32'").setParameter("contract_number", contractNumber).getSingleResult(false);
+					if(businessStatus==null){
+						
+						bsbo.setAttributeValue(BUSINESS_STATUS.contract_number,contractNumber);
+						bsbo.setAttributeValue(BUSINESS_STATUS.business_status, "32");
+						bsbo.setAttributeValue(BUSINESS_STATUS.inputuserid,asUser.getUserID());
+						bsbo.setAttributeValue(BUSINESS_STATUS.inputtime,StringFunction.getTodayNow());
+						bsbo.setAttributeValue(BUSINESS_STATUS.inputorgid,asUser.getOrgID());
+						bsbom.saveObject(bsbo);
+					}else{
+						bsbom.createQuery("update o set inputuserid='"+asUser.getUserID()+"',inputtime='"+StringFunction.getTodayNow()+"',inputorgid='"+asUser.getOrgID()+"' where contract_number='"+contractNumber+"' and business_status='32'").executeUpdate();
+					}
+				}
+			}
+		
+			tx.commit();
+	  }catch(Exception e){
+		  tx.rollback();
+		  e.printStackTrace();
+	  }
+
+	
+	}
+}