package UIK.UIK05;

import java.sql.SQLException;

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

public class UIK050030 extends CoreIComponent {

	public CoreReturnObject DoQueryShang(String zgNum,Boolean flag,String beginTime,String endTime) throws SQLException
	{
			CoreReturnObject cro = new CoreReturnObject();
			String str = "STAND_ID,ROLL_TYPE,ROLLID_UP,ROLLID_LO,decode(REASON_CODE,'0','变规格','1','变品种','2','辊印','3','轧烂','4','刀花印','5','划伤','6','色差','7','乳化斑','8','板形差','9','到吨位','10','打滑','11','断带','12','横折印') REASON_CODE,TO_CHAR(DISMOUNT_TIME,'YYYY-MM-DD HH24:MI:SS') DISMOUNT_TIME,SHIFT,CREW,ROLLED_LENGTH_UP, ROLLED_WEIGHT_UP,ROLLED_TIME_UP,SPEC_NO,MEG_FLAG,REG_ID,TO_CHAR(REG_DTIME,'YYYY-MM-DD HH24:MI:SS') REG_DTIME";
			
			if(!flag)
			{
				
					String sqlQuery	=	"select " + str+" from C_TBK05_ROLL_DOWN  order by REG_DTIME";                                        
				       
					cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
					
					return cro;
					
			}
			else
			{
					String sqlQuery	=	"select " + str+" from C_TBK05_ROLL_DOWN  where STAND_ID = '"+zgNum+"' and (TO_CHAR(REG_DTIME,'YYYYMMDDHH24MISS') between '"+beginTime+"' and '"+endTime+"')";
					
					cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
					
					return cro;
			}
			
	}
	                        
	public CoreReturnObject DoQueryXia(String zgNum,Boolean flag,String beginTime,String endTime) throws SQLException
	{
			CoreReturnObject cro = new CoreReturnObject();
			String str ="STAND_ID,ROLL_TYPE,ROLLID_LO,REASON_CODE,TO_CHAR(DISMOUNT_TIME,'YYYY-MM-DD HH24:MI:SS') DISMOUNT_TIME,SHIFT,CREW,ROLLED_LENGTH_LO,to_char(ROLLED_WEIGHT_LO/1000) ROLLED_WEIGHT_LO,ROLLED_TIME_LO,SPEC_NO,REG_ID,TO_CHAR(REG_DTIME,'YYYY-MM-DD HH24:MI:SS') REG_DTIME";
			
			if(!flag)
			{
				
				String sqlQuery	=	"select " + str+" from C_TBK05_ROLL_DOWN  order by REG_DTIME";
			       
				cro = this.getDao("KgDao").ExcuteQuery(sqlQuery );
				return cro;
				
			}
			
			else
			{
				
					String sqlQuery	=	"select " + str+" from C_TBK05_ROLL_DOWN  where STAND_ID = '"+zgNum+"' and (TO_CHAR(REG_DTIME,'YYYYMMDDHH24MISS') between '"+beginTime+"' and '"+endTime+"')";
					
					cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
					return cro;
			}
				
	}
	public CoreReturnObject DoQueryShang1(String zgNum,Boolean flag,String beginTime,String endTime) throws SQLException
	{
			CoreReturnObject cro = new CoreReturnObject();
			String str = "SPEC_NO,STAND_ID,ROLL_TYPE,ROLLID_UP,ROLLID_LO,decode(REASON_CODE,'0','变规格','1','变品种','2','辊印','3','轧烂','4','刀花印','5','划伤','6','色差','7','乳化斑','8','板形差','9','到吨位','10','打滑','11','断带','12','横折印') REASON_CODE,TO_CHAR(DISMOUNT_TIME,'YYYY-MM-DD HH24:MI:SS') DISMOUNT_TIME,SHIFT,CREW,ROLLED_LENGTH_UP, ROLLED_WEIGHT_UP,ROLLED_TIME_UP,REG_ID,TO_CHAR(REG_DTIME,'YYYY-MM-DD HH24:MI:SS') REG_DTIME,MEG_FLAG";
			
			
					String sqlQuery	=	"select " + str+" from C_TBK05_ROLL_DOWN  where  (TO_CHAR(REG_DTIME,'YYYYMMDDHH24MISS') between '"+beginTime+"' and '"+endTime+"')" ;
					
					cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
					
					return cro;
			
			
	}
	                        
	public CoreReturnObject DoQueryXia1(String zgNum,Boolean flag,String beginTime,String endTime) throws SQLException
	{
			CoreReturnObject cro = new CoreReturnObject();
			String str ="SPEC_NO,REG_ID,TO_CHAR(REG_DTIME,'YYYY-MM-DD HH24:MI:SS') REG_DTIME,ROLLID_LO,REASON_CODE,TO_CHAR(DISMOUNT_TIME,'YYYY-MM-DD HH24:MI:SS') DISMOUNT_TIME,SHIFT,CREW,ROLLED_LENGTH_LO,to_char(ROLLED_WEIGHT_LO/1000) ROLLED_WEIGHT_LO,ROLLED_TIME_LO,STAND_ID,ROLL_TYPE";
			
			
				
					String sqlQuery	=	"select " + str+" from C_TBK05_ROLL_DOWN  where  (TO_CHAR(REG_DTIME,'YYYYMMDDHH24MISS') between '"+beginTime+"' and '"+endTime+"')";
					
					cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
					return cro;
			
				
	}
	public CoreReturnObject DoSelect(String create_time) throws SQLException
	{
		CoreReturnObject cro = new CoreReturnObject();
		
		String str = "SPEC_NO,STAND_ID,ROLL_TYPE,ROLL_AREA,ROLLID_UP,ROLLID_LO,REG_ID,TO_CHAR(DISMOUNT_TIME,'YYYY-MM-DD') DISMOUNT_TIME,REASON_CODE,SHIFT,CREW,ROLLED_LENGTH_UP,ROLLED_WEIGHT_UP,ROLLED_TIME_UP,ROLLED_LENGTH_LO,ROLLED_WEIGHT_LO,ROLLED_TIME_LO,REG_DTIME";
		
		String sqlQuery	= "select "+str+" from C_TBK05_ROLL_DOWN where REG_DTIME =TO_DATE('"+create_time+"','YYYY-MM-DD HH24:MI:SS')";
		       
		cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
		
		return cro;
			
	}
	
	public CoreReturnObject PlanAdd(String spec_No,String sand_Id,String roll_Type,String roll_Area,String roll_Id_up,String roll_Id_lo,String z_time,String reason,String s_chang,String s_liang,String create_time) throws SQLException
	{
		CoreReturnObject cro = new CoreReturnObject();
		

		String addSql = "insert into C_TBK05_ROLL_DOWN(SPEC_NO,STAND_ID,ROLL_TYPE,ROLL_AREA,ROLLID_UP,ROLLID_LO,REG_ID,DISMOUNT_TIME,REASON_CODE,SHIFT,CREW,ROLLED_LENGTH_UP,ROLLED_WEIGHT_UP,ROLLED_TIME_UP,ROLLED_LENGTH_LO,ROLLED_WEIGHT_LO,ROLLED_TIME_LO,REG_DTIME,MEG_FLAG)values(?,?,?,?,?,?,null,TO_DATE('"+z_time+"', 'YYYY-MM-DD hh24:mi:ss'),?,null,null,?,?,null, null,null,null,TO_DATE('"+create_time+"', 'YYYY-MM-DD HH24:MI:SS'),'否')";
		
		cro = this.getDao("KgDao").ExcuteNonQuery(addSql,new Object[]{spec_No, sand_Id, roll_Type, roll_Area, roll_Id_up, roll_Id_lo, reason, s_chang, s_liang});
		return cro;
	 
	}

	public CoreReturnObject DoSend(String spec_No,String sand_Id,String roll_Type,String roll_Area,String roll_Id_up,String roll_Id_lo,String z_time,String reason,String banci,String banbie, String s_chang,String s_liang,String s_shi,String x_chang,String x_liang,String x_shi,String create_time,String uid) throws SQLException
	{
		
			CoreReturnObject cro = new CoreReturnObject();
			
			String sql = "insert into TBS02_ROLL_CHANGE_DIS(SEQ_NO,STAND_NO,ROLL_TYPE,AREA,ROLLID_UP,ROLLID_LO,DISMOUNT_TIME,REASON_CODE,SHIFT,CREW,ROLLED_LENGTH_UP,ROLLED_WEIGHT_UP,ROLLED_TIME_UP,ROLLED_LENGTH_LO,ROLLED_WEIGHT_LO,ROLLED_TIME_LO,TRANS_DTIME,PROC_NAME) values(?,?,?,?,?,?,TO_DATE('"+z_time+"','yyyy-mm-dd hh24:mi:ss')"+",?,?,?,?,?,?,?,?,?,TO_DATE('"+create_time+"','yyyy-mm-dd hh24:mi:ss')"+",?)";
			
			Object[] obj	=	new Object[]{spec_No, sand_Id, roll_Type, roll_Area, roll_Id_up, roll_Id_lo, reason, banci, banbie, s_chang, s_liang, s_shi, x_chang, x_liang, x_shi,uid};
			
			cro = this.getDao("KgDao").ExcuteNonQuery(sql , obj);
			
			return cro;
	}
	
	public CoreReturnObject DoUpdate(String reason,String zhazhiliang,String zhazhicd,String timexg,String number,String iddown,String idup,String namerg) throws SQLException
	{
			CoreReturnObject cro = new CoreReturnObject();					
			
			String sqlQuery	= "update C_TBK05_ROLL_DOWN set REASON_CODE = decode('"+reason+"','变规格','0','变品种','1','辊印','2','轧烂','3','刀花印','4','划伤','5','色差','6','乳化斑','7','板形差','8','到吨位','9','打滑','10','断带','11','横折印','12'),ROLLED_WEIGHT_UP='"+zhazhiliang+"' , ROLLED_LENGTH_UP='"+zhazhicd+"',reg_id='"+namerg+"',REG_DTIME = TO_DATE('"+timexg+"','YYYY-MM-DD HH24:MI:SS') where SPEC_NO='"+number+"' and ROLLID_UP='"+idup+"' and rollid_lo='"+iddown+"'";
			//REG_DTIME = TO_DATE('"+create_time+"','YYYY-MM-DD HH24:MI:SS')	       
			cro = this.getDao("KgDao").ExcuteNonQuery(sqlQuery);
				
			return cro;
		
	}

}