package UIB.UIB03;

import java.util.Map;

import org.springframework.jdbc.support.rowset.SqlRowSet;
import org.springframework.jdbc.support.rowset.SqlRowSetMetaData;

import UIB.COM.XmlSqlParsersFactory;
import CoreFS.SA01.CoreIComponent;
import CoreFS.SA06.CoreReturnObject;

/**
 * 
 * @desc   材质实绩查询
 * @author meiguiping
 * @date   2010 4:24:36 PM
 */
public class UIB030130 extends CoreIComponent
{
	public CoreReturnObject	queryCoilQltyValue(String sTime , String  eTime ,String  Pline)	throws Exception
	{
		CoreReturnObject	cro		=	new CoreReturnObject();
		//获取满足条件的所有检验项目
		String				sqlOne="";
		if("酸洗".equals(Pline))  
		{
			sqlOne			=	XmlSqlParsersFactory.getSql("UIB030130_04.SELECT");
		}
		else
		{
			sqlOne			=	XmlSqlParsersFactory.getSql("UIB030130_01.SELECT");
		}
		//String				sqlOne	=	XmlSqlParsersFactory.getSql("UIB030130_01.SELECT");
		cro	=	this.getDao("KgDao").ExecutequeryForRowSet(sqlOne, new Object[]{sTime , eTime});
		SqlRowSet			srs		=	(SqlRowSet)cro.getResult();

//		SqlRowSetMetaData rsmd	=	srs.getMetaData();
//		int count=rsmd.getColumnCount();
//		for(int i=0;i<count;i++)
//			  System.out.println("------------------------------------------>"+rsmd.getColumnName(i+1));
	
		String				repSql	=	",MAX(DECODE('{2}' , WQ.QLTY_CD ,WQ.QLTY_VAL_WK , NULL)) \"{3}\""; //{2}用检验项目替代，{3}用名称替代
		String				temp	=	"";
		StringBuffer		sBuffer	=	new StringBuffer(350);
		String				qltyNm	=	"";
		while(srs.next())
		{	
			qltyNm	=	srs.getString(2).replaceFirst("\\[", "").replaceFirst("\\]", "").replaceFirst(",", "").replaceFirst("/", "").replaceFirst("\\.", "D").replaceFirst("-", "F");
			temp	=	repSql.replaceFirst("[{]+[2]+[}]+", srs.getString(1));//检验项目
			temp	=	temp.replaceFirst("[{]+[3]+[}]+", qltyNm);//检验项目名称
			sBuffer.append(temp);
		}
		//最终SQL语句
		String	sqlAim;
		if("酸洗".equals(Pline))  
		{
			sqlAim			=	XmlSqlParsersFactory.getSql("UIB030130_03.SELECT").replaceFirst("[{]+[1]+[}]+", sBuffer.toString());
		}
		else
		{
			sqlAim			=	XmlSqlParsersFactory.getSql("UIB030130_02.SELECT").replaceFirst("[{]+[1]+[}]+", sBuffer.toString());
		}
//		System.out.println(sqlAim);
		cro						=	this.getDao("KgDao").ExcuteQuery(sqlAim , new Object[]{sTime , eTime} );
		return cro;
	}
}