XinYu_LZMES/.svn/pristine/34/340a45f45e35b6ca0e3ead02abbac53bf58103f9.svn-base

package UIK.UIK05;

import java.sql.SQLException;

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

public class UIK050050 extends CoreIComponent{

	public CoreReturnObject DoQueryShang(String zgNum, String zgAr,Boolean flag,String beginTime ,String endTime) throws SQLException
	{
			CoreReturnObject cro = new CoreReturnObject();			
			String str = "SPEC_NO,MEG_FLAG,STAND_ID,ROLL_TYPE,ROLLID_UP,REASON_CODE,TO_CHAR(MOUNT_TIME,'YYYY-MM-DD HH24:MI:SS') MOUNT_TIME,SHIFT,CREW,ROLL_AREA,REG_ID,TO_CHAR(REG_DTIME,'YYYY-MM-DD HH24:MI:SS') REG_DTIME";
			if(!flag)
			{
				
					String sqlQuery	="select "+str+" from C_TBK05_ROLL_UP order by REG_DTIME";
				       
					cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
					
					return cro;
					
			}
			else
			{
				if(!zgNum.equals("") && !zgAr.equals(""))
				{
					String sqlQuery	=	"select "+str+" from C_TBK05_ROLL_UP where STAND_ID = '"+zgNum+"'and ROLL_AREA= '"+zgAr+"'and (TO_CHAR(REG_DTIME,'YYYYMMDDHH24MISS') between '"+beginTime+"' and '"+endTime+"')";
					
					cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
					return cro;
				}
				else
				{
				if(!zgNum.equals("")&& zgAr.equals(""))
				{
						String sqlQuery	=	"select "+str+" from C_TBK05_ROLL_UP where STAND_ID ='"+ zgNum+"'and (TO_CHAR(REG_DTIME,'YYYYMMDDHH24MISS') between '"+beginTime+"' and '"+endTime+"')";
						
						cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
						return cro;	
				}
					
				if(zgNum.equals("")&& !zgAr.equals("") )
				{
						String sqlQuery	=	"select  "+str+"  from C_TBK05_ROLL_UP where ROLL_AREA ='" + zgAr+"'and (TO_CHAR(REG_DTIME,'YYYYMMDDHH24MISS') between '"+beginTime+"' and '"+endTime+"')";
						
						cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
						return cro;	
				}
				if(zgNum.equals("")&& zgAr.equals("") )
				{
						String sqlQuery	=	"select  "+str+"  from C_TBK05_ROLL_UP where  (TO_CHAR(REG_DTIME,'YYYYMMDDHH24MISS') between '"+beginTime+"' and '"+endTime+"')";
						
						cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
						return cro;	
				}
				}
				
			}
			
			return cro;
	}
	
	public CoreReturnObject DoQueryXia(String zgNum, String zgAr,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,STAND_ID,ROLL_TYPE,ROLLID_LO,REASON_CODE,TO_CHAR(MOUNT_TIME,'YYYY-MM-DD HH24:MI:SS') MOUNT_TIME,SHIFT,CREW,ROLL_AREA";
			if(!flag)
			{
				
					String sqlQuery	="select "+str+" from C_TBK05_ROLL_UP order by REG_DTIME";
				       
					cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
					
					return cro;
					
			}
			else
			{
				if(!zgNum.equals("") && !zgAr.equals(""))
				{
					String sqlQuery	=	"select "+str+" from C_TBK05_ROLL_UP where STAND_ID = '"+zgNum+"'and ROLL_AREA= '"+zgAr+"'and (TO_CHAR(REG_DTIME,'YYYYMMDDHH24MISS') between '"+beginTime+"' and '"+endTime+"')";
					
					cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
					return cro;
				}
				else
				{
				if(!zgNum.equals("")&& zgAr.equals(""))
				{
						String sqlQuery	=	"select "+str+" from C_TBK05_ROLL_UP where STAND_ID ='"+ zgNum+"'and (TO_CHAR(REG_DTIME,'YYYYMMDDHH24MISS') between '"+beginTime+"' and '"+endTime+"')";
						
						cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
						return cro;	
				}
					
				if(zgNum.equals("")&& !zgAr.equals("") )
				{
						String sqlQuery	=	"select  "+str+"  from C_TBK05_ROLL_UP where ROLL_AREA ='" + zgAr+"'and (TO_CHAR(REG_DTIME,'YYYYMMDDHH24MISS') between '"+beginTime+"' and '"+endTime+"')";
						
						cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
						return cro;	
				}
				if(zgNum.equals("")&& zgAr.equals("") )
				{
						String sqlQuery	=	"select  "+str+"  from C_TBK05_ROLL_UP where  (TO_CHAR(REG_DTIME,'YYYYMMDDHH24MISS') between '"+beginTime+"' and '"+endTime+"')";
						
						cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
						return cro;	
				}
				}
				
			}
			
			return cro;
	}
	
	public CoreReturnObject PlanAdd(String spec_No, String sand_id,String roll_Type,String roll_Area,String reason,String z_time,String banci,String banbie,String shang_id,String xia_id,String reg_id, String reg_dtime) throws SQLException
	{
		CoreReturnObject cro = new CoreReturnObject();

		String addSql = "insert into C_TBK05_ROLL_UP(SPEC_NO,STAND_ID,ROLL_TYPE,ROLL_AREA,REASON_CODE,MOUNT_TIME,SHIFT,CREW,ROLLID_UP,ROLLID_LO,REG_ID,REG_DTIME,MEG_FLAG)values(?,?,?,?,?,TO_DATE('"+z_time+"','YYYY-MM-DD'),?,?,?,?,?,TO_DATE('"+reg_dtime+"','YYYY-MM-DD HH24:MI:SS'),'·ñ')";
		
		cro = this.getDao("KgDao").ExcuteNonQuery(addSql,new Object[]{spec_No, sand_id, roll_Type, roll_Area, reason, banci, banbie,shang_id, xia_id, reg_id});
		return cro;
	 
	}
	
	public CoreReturnObject DoSelect(String reg_dtime) throws SQLException
	{
		CoreReturnObject cro = new CoreReturnObject();
		
		String str = "STAND_ID,ROLL_TYPE,REASON_CODE,TO_CHAR(MOUNT_TIME,'YYYY-MM-DD') MOUNT_TIME,SHIFT,CREW,ROLLID_UP,ROLLID_LO,SPEC_NO,REG_DTIME,ROLL_AREA";
		
		String sqlQuery	= "select "+str+" from C_TBK05_ROLL_UP where REG_DTIME =TO_DATE('"+reg_dtime+"','YYYY-MM-DD HH24:MI:SS')";
		       
		cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
		
		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 create_time,String uid) throws SQLException
	{
		
			CoreReturnObject cro = new CoreReturnObject();
			
			String sql = "insert into TBS02_ROLL_CHANGE_MOU(SEQ_NO,STAND_ID,ROLL_TYPE,AREA,ROLLID_UP,ROLLID_LO,MOUNT_TIME,REASON_CODE,SHIFT,CREW,TRANS_DTIME,PROC_NAME) values(?,?,?,?,?,?,TO_DATE('"+z_time+"','yyyy-mm-dd')"+",?,?,?,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,uid};
			
			cro = this.getDao("KgDao").ExcuteNonQuery(sql , obj);
			
			return cro;
	}
	
	public CoreReturnObject DoUpdate(String reg_dtime) throws SQLException
	{
			CoreReturnObject cro = new CoreReturnObject();					
			
			String sqlQuery	= "update C_TBK05_ROLL_UP set MEG_FLAG = 'ÊÇ' where REG_DTIME = TO_DATE('"+reg_dtime+"','yyyy-mm-dd hh24:mi:ss') ";
				       
			cro = this.getDao("KgDao").ExcuteNonQuery(sqlQuery);
				
			return cro;
		
	}
	                
}