放款正常失败状态

This commit is contained in:
liuzhao 2018-08-30 14:04:05 +08:00
parent cdaed5f0a1
commit 6094f2394c
2 changed files with 89 additions and 5 deletions

View File

@ -78,11 +78,6 @@ public class LBContractLoanApply extends BaseBussiness {
}catch(Exception e){
tx.rollback();
e.printStackTrace();
}finally{
if(Sqlca!=null){
Sqlca.disConnect();
Sqlca = null;
}
}

View File

@ -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();
}
}
}