package UIF.UIF04;

import java.sql.SQLException;
import java.util.ArrayList;

import UIB.COM.XmlSqlParsersFactory;

import CoreFS.SA01.CoreIComponent;
import CoreFS.SA06.CoreReturnObject;
import CoreFS.SA06.CoreSqlType;

public class UIF042020 extends CoreIComponent {
	public CoreReturnObject query01() throws SQLException
	{
		CoreReturnObject cro=new CoreReturnObject();
		StringBuffer str = new StringBuffer();
		str.append("SELECT A.REG_DTIME                  --指示时间													\n");
		str.append("       ,A.ROLL_EDT_SEQ              --轧制单元编制序号                	\n");
		str.append("       ,A.ROLL_MANA_NO              --轧制单元管理号                  	\n");
		str.append("       ,A.ROLL_COIL_CNT             --单元内卷数                      	\n");
		str.append("       ,A.ROLL_COIL_WGT             --单元重量                        	\n");
		str.append("       ,NVL(B.RES_ROLL_COIL_CNT,0) RES_ROLL_COIL_CNT        --剩余卷数	\n");	
		str.append("       ,NVL(B.RES_ROLL_COIL_WGT,0) RES_ROLL_COIL_WGT        --剩余重量	\n");
		str.append("       ,NVL(C.END_COIL_CNT,0) END_COIL_CNT             --已经完成卷数 	\n");
		str.append("       ,NVL(C.END_COIL_WGT,0) END_COIL_WGT            --已经完成重量  	\n");
		str.append("       ,'FALSE' CHK                                                        	\n");
		str.append("FROM C_TBF03_SPEC_ROLL A,                                             	\n");
		str.append("     (SELECT T.ROLL_MANA_NO                                           	\n");
		str.append("             ,COUNT(T.COIL_NO) RES_ROLL_COIL_CNT                      	\n");
		str.append("             ,SUM(T.COIL_WGT) RES_ROLL_COIL_WGT                       	\n");
		str.append("      FROM C_TBF03_SPEC_MILL T                                        	\n");
		str.append("      WHERE T.STATUS_CD IN ('A','B')                                  	\n");
		str.append("      GROUP BY T.ROLL_MANA_NO                                         	\n");
		str.append("     )B,                                                              	\n");
		str.append("     (SELECT T.ROLL_MANA_NO                                           	\n");
		str.append("             ,COUNT(T.COIL_NO) END_COIL_CNT                           	\n");
		str.append("             ,SUM(T.COIL_WGT) END_COIL_WGT                            	\n");
		str.append("      FROM C_TBF03_SPEC_MILL T                                        	\n");
		str.append("      WHERE T.STATUS_CD = 'C'                                         	\n");
		str.append("      GROUP BY T.ROLL_MANA_NO                                         	\n");
		str.append("     )C                                                               	\n");
		str.append("WHERE A.ROLL_MANA_NO = B.ROLL_MANA_NO(+)                              	\n");
		str.append("AND   A.ROLL_MANA_NO = C.ROLL_MANA_NO(+)                              	\n");
		str.append("AND   A.STATUS_CD IN ('A','B')                              	        \n");
		String sql = str.toString();
		cro=this.getDao("KgDao").ExcuteQuery(sql);
		
		System.out.println(cro);
		return cro;
	}
	public CoreReturnObject update01(String rollNO,String pos,String type) throws Exception
	{
		CoreReturnObject cro=new CoreReturnObject();
		ArrayList param = new ArrayList();
		ArrayList paramType = new ArrayList();
		param.add(pos);
		paramType.add(CoreSqlType.CoreOracleType.STRING_TYPE);
		param.add(rollNO);
		paramType.add(CoreSqlType.CoreOracleType.STRING_TYPE);
		param.add(type);
		paramType.add(CoreSqlType.CoreOracleType.STRING_TYPE);
		String sql = "{call C_PKG_NIF043020.ROLL_SEQ_ARRENGE(?,?,?)}";
		cro=this.getDao("KgDao").ExcuteProcedure(sql,paramType,param);
		return cro;
		
	}
	public CoreReturnObject queryInitdata() throws SQLException
	{
		CoreReturnObject cro=new CoreReturnObject();
		StringBuffer str = new StringBuffer();
		str.append(" SELECT ROLL_MANA_NO NAME_,ROLL_MANA_NO ID_ FROM C_TBF03_SPEC_ROLL T			\n");
		str.append(" WHERE T.STATUS_CD IN ('A','B')                  	    \n");
		String sql = str.toString();
		cro=this.getDao("KgDao").ExcuteQuery(sql);
		
		System.out.println(cro);
		return cro;
	}
	public CoreReturnObject QueryRollPlan()
	{
		try
		{
			CoreReturnObject rtnobj=new CoreReturnObject();
			String Sql = XmlSqlParsersFactory.getSql("UIF042020.Query_RollPlan_List");
			rtnobj=this.getDao("KgDao").ExcuteQuery(Sql);
			return rtnobj;
		}
		catch(Exception ex)
		{
			CoreReturnObject err = new CoreReturnObject();
			err.SetErrInfo(ex.toString());
			return err;
		}
	}
	
}