package com.tenwa.lease.app.cache;

import com.amarsoft.are.jbo.JBOException;
import com.amarsoft.awe.util.ASResultSet;
import com.amarsoft.awe.util.SqlObject;
import com.amarsoft.awe.util.Transaction;
import com.amarsoft.dict.als.cache.CacheLoaderFactory;

/**
 * 
 * 保险覆盖融资期限
 * */
public class ContractInsuranceCache {
	/**
	 * 获取已全部投放的合同号
	 * @return
	 * @throws JBOException
	 */
	public static String getContractIds()throws JBOException{
		String result="";
		String contractIds="";
		Transaction Sqlca =null;
		try {
			 Sqlca =  Transaction.createTransaction(CacheLoaderFactory.getDataSource());
//			 String sql="SELECT lci.ID FROM LB_CONTRACT_INFO lci LEFT JOIN (SELECT CONTRACT_ID,SUM(EQUIP_AMT) cleanmoney FROM LC_CONTRACT_CONDITION GROUP BY CONTRACT_ID) lcc ON lcc.CONTRACT_ID= lci.ID LEFT JOIN  (SELECT lfi.CONTRACT_ID,(SUM(lfi.FACT_MONEY)+SUM(lfi.FEE_ADJUST)) summoney FROM LC_FUND_INCOME lfi WHERE lfi.PAY_STATUS='have_paid' AND lfi.FEE_TYPE='feetype10' AND lfi.ROLL_BACK='0' GROUP BY lfi.CONTRACT_ID) lfisum ON lfisum.CONTRACT_ID=lci.ID WHERE lcc.cleanmoney=lfisum.summoney AND lci.ISFILEARCHIVED IS NULL  ";
			 String sql="SELECT lci.ID FROM LB_CONTRACT_INFO lci LEFT JOIN (SELECT CONTRACT_ID,SUM(EQUIP_AMT) cleanmoney FROM LC_CONTRACT_CONDITION GROUP BY CONTRACT_ID) lcc ON lcc.CONTRACT_ID= lci.ID LEFT JOIN  (SELECT lfi.CONTRACT_ID,(SUM(lfi.FACT_MONEY)+SUM(lfi.FEE_ADJUST)) summoney FROM LC_FUND_INCOME lfi WHERE lfi.PAY_STATUS='have_paid' AND lfi.FEE_TYPE='feetype10' AND lfi.ROLL_BACK='0' GROUP BY lfi.CONTRACT_ID) lfisum ON lfisum.CONTRACT_ID=lci.ID WHERE lci.CONTRACT_STATUS='31' AND lci.ISFILEARCHIVED IS NULL  ";
			 SqlObject asql = new SqlObject(sql);
			 ASResultSet rs = null;
			 rs = Sqlca.getASResultSet(asql);
			 while(rs.next()){
				 contractIds+=rs.getStringValue("ID")+",";
			 }
			 if(!contractIds.equals("")){
				 contractIds = contractIds.substring(0,contractIds.length()-1);
				 String[] contractid = contractIds.split(",");
				 result += "(";
				 for(int i=0;i<contractid.length;i++){
					 if(i==0){
						 result+="'"+contractid[i]+"'";
					 }else{
						 result+=",'"+contractid[i]+"'";
					 }
				 } 
				 result += ")";
			 }
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			if(Sqlca!=null){
		        Sqlca.disConnect();
		        Sqlca = null;
		    }
		}
		return result;
	}
	
}