61 lines
2.4 KiB
Java
61 lines
2.4 KiB
Java
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;
|
|
}
|
|
|
|
}
|
|
|
|
|