XinYu_LZMES/.svn/pristine/05/05c7906772c4b98e069a14f801d31e4c6815f01b.svn-base

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;
		
	}

}