package UIK.UIK03;

import java.sql.SQLException;

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

public class UIK030020 extends CoreIComponent{

	public CoreReturnObject DoQuery(String mc_id,String starttiem,String endtime,Boolean flag ) throws SQLException
	{
			CoreReturnObject cro = new CoreReturnObject();
			
			String str = "MC_ID,MC_NAME,MC_MODEL,MC_SPEC,MC_FACTORY,MC_IN_DTIME,MC_PRICE,MC_CARE_SECTOR,MC_NOM_CAP,MC_UNIT,MC_TAI,MC_ACT,MC_MFACTUR_UNITS,MC_USE_YEAR,MC_USE_TIME,MC_INSTAL_LOCAL,MC_REG_OUT_STAT,MC_STAT,REG_OUT_DTIME,REG_OUT_ID,MC_PROCESS_REG,TO_CHAR(REG_IN_DTIME,'YYYY-MM-DD HH24:MI:SS') REG_IN_DTIME,MAIN_MC_NAME";
			
			if(!flag)
			{
				
					//String sqlQuery	=	"select " + str+" from C_TBK03_MACHINE_ONLINE WHERE MC_REG_OUT_STAT ='已报废'";
				    String sqlQuery	=	"select " + str+" from C_TBK03_MACHINE_ONLINE";  
					cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
					
					return cro;
					
			}
			else
			{
				if(mc_id.equals("")&& !starttiem.equals("")&&!endtime.equals(""))
				{
					if(starttiem == endtime)
					{
						String sqlQuery	=	"select " + str+" from C_TBK03_MACHINE_ONLINE where REG_OUT_DTIME = TO_DATE('"+starttiem+"','yyyy-mm-dd') and MC_REG_OUT_STAT ='已报废'";
						
						cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
						
						return cro;
					}
					else
					{
						String sqlQuery	=	"select " + str+" from C_TBK03_MACHINE_ONLINE where REG_OUT_DTIME >= TO_DATE('"+starttiem+"','yyyy-mm-dd') and REG_OUT_DTIME <= TO_DATE('"+endtime+"','yyyy-mm-dd') and MC_REG_OUT_STAT ='已报废'";
						
						cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
						
						return cro;
					}
				}
				
				if(!mc_id.equals("")&& starttiem.equals("")&&endtime.equals(""))
				{
					String sqlQuery	=	"select " + str+" from C_TBK03_MACHINE_ONLINE where MAIN_MC_NAME ='"+mc_id+"'";
					
					cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
					
					return cro;
				}
				
				if (!mc_id.equals("")&& !starttiem.equals("")&& !endtime.equals(""))
				{
					String sqlQuery	=	"select " + str+" from C_TBK03_MACHINE_ONLINE where MAIN_MC_NAME ="+mc_id+" and REG_OUT_DTIME >= TO_DATE('"+starttiem+"','yyyy-mm-dd') and REG_OUT_DTIME <= TO_DATE('"+endtime+"','yyyy-mm-dd')";
					
					cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
					
					return cro;
				}
			}
			return cro;

	}
	
	public CoreReturnObject DoSelect(String IREG_IN_DTIME ) throws SQLException
	{
			CoreReturnObject cro = new CoreReturnObject();
			
			String str = "MC_ID,MC_NAME,MC_MODEL,MC_SPEC,MC_FACTORY,MC_IN_DTIME,MC_PRICE,MC_CARE_SECTOR,MC_NOM_CAP,MC_UNIT,MC_TAI,MC_ACT,MC_MFACTUR_UNITS,MC_USE_YEAR,MC_USE_TIME,MC_INSTAL_LOCAL,MC_REG_OUT_STAT,MC_STAT,REG_OUT_DTIME,REG_OUT_ID,MC_PROCESS_REG,MAIN_MC_NAME";
			
			String sqlQuery	=	"select " + str+" from C_TBK03_MACHINE_ONLINE where REG_IN_DTIME =TO_DATE('"+IREG_IN_DTIME+"','YYYY-MM-DD HH24:MI:SS')";
			
			cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
			
			return cro;
		
	}
	
	public CoreReturnObject DoUpdate(String IMC_NAME,String IMC_MODEL,String IMC_SPEC,String IMC_FACTORY,String IMC_IN_DTIME,String IMC_PRICE,String IMC_CARE_SECTOR,String IMC_NOM_CAP,String IMC_UNIT,String IMC_TAI,String IMC_ACT,String IMC_MFACTUR_UNITS,String IMC_USE_YEAR,String IMC_USE_TIME,String IMC_INSTAL_LOCAL,String IMC_REG_OUT_STAT, String IMC_STAT,String IREG_OUT_DTIME,String IREG_OUT_ID,String IMAIN_MC_NAME,String IREG_IN_DTIME ) throws SQLException
	{
			CoreReturnObject cro = new CoreReturnObject();
		
			String sqlQuery	=	"update C_TBK03_MACHINE_ONLINE  set MC_NAME =?,MC_MODEL=?,MC_SPEC=?,MC_FACTORY=?,MC_IN_DTIME = TO_DATE('"+IMC_IN_DTIME+"','yyyy-mm-dd'),MC_PRICE=?,MC_CARE_SECTOR=?,MC_NOM_CAP=?,MC_UNIT=?,MC_TAI=?,MC_ACT=?,MC_MFACTUR_UNITS=?,MC_USE_YEAR=?,MC_USE_TIME=TO_DATE('"+IMC_USE_TIME+"','yyyy-mm-dd'),MC_INSTAL_LOCAL=?,MC_REG_OUT_STAT=?,MC_STAT=?,REG_OUT_DTIME=TO_DATE('"+IREG_OUT_DTIME+"','yyyy-mm-dd'),REG_OUT_ID=?,MAIN_MC_NAME=? where REG_IN_DTIME =TO_DATE('"+IREG_IN_DTIME+"','YYYY-MM-DD HH24:MI:SS')";
			
			Object[] obj = new Object[]{ IMC_NAME, IMC_MODEL, IMC_SPEC, IMC_FACTORY, IMC_PRICE, IMC_CARE_SECTOR, IMC_NOM_CAP, IMC_UNIT, IMC_TAI, IMC_ACT, IMC_MFACTUR_UNITS, IMC_USE_YEAR, IMC_INSTAL_LOCAL, IMC_REG_OUT_STAT, IMC_STAT,IREG_OUT_ID,IMAIN_MC_NAME};
		
			cro = this.getDao("KgDao").ExcuteNonQuery(sqlQuery,obj);
			
			return cro;
		
	}
	
	public CoreReturnObject DoInsert(String mcid,String IMC_NAME,String IMC_MODEL,String IMC_SPEC,String IMC_FACTORY,String IMC_IN_DTIME,String IMC_PRICE,String IMC_CARE_SECTOR,String IMC_NOM_CAP,String IMC_UNIT,String IMC_TAI,String IMC_ACT,String IMC_MFACTUR_UNITS,String IMC_USE_YEAR,String IMC_USE_TIME,String IMC_INSTAL_LOCAL,String IMC_REG_OUT_STAT,String IMC_STAT,String IREG_OUT_DTIME,String IREG_OUT_ID,String IMAIN_MC_NAME,String IREG_IN_DTIME ) throws SQLException
	{
			CoreReturnObject cro = new CoreReturnObject();
				
			String sqlQuery	=	"insert into C_TBK03_MACHINE_ONLINE(MC_ID,MC_NAME,MC_MODEL,MC_SPEC,MC_FACTORY,MC_IN_DTIME,MC_PRICE,MC_CARE_SECTOR,MC_NOM_CAP,MC_UNIT,MC_TAI,MC_ACT,MC_MFACTUR_UNITS,MC_USE_YEAR,MC_USE_TIME,MC_INSTAL_LOCAL,MC_REG_OUT_STAT,MC_STAT,REG_OUT_DTIME,REG_OUT_ID,MAIN_MC_NAME,REG_IN_DTIME) values(?,?,?,?,?,TO_DATE('"+IMC_IN_DTIME+"','yyyy-mm-dd'),?,?,?,?,?,?,?,?,TO_DATE('"+IMC_USE_TIME+"','yyyy-mm-dd'),?,?,?,TO_DATE('"+IREG_OUT_DTIME+"','yyyy-mm-dd'),?,?,TO_DATE('"+IREG_IN_DTIME+"','YYYY-MM-DD HH24:MI:SS'))";
			
			Object[] obj = new Object[]{mcid, IMC_NAME, IMC_MODEL, IMC_SPEC, IMC_FACTORY, IMC_PRICE, IMC_CARE_SECTOR, IMC_NOM_CAP, IMC_UNIT, IMC_TAI, IMC_ACT, IMC_MFACTUR_UNITS, IMC_USE_YEAR, IMC_INSTAL_LOCAL, IMC_REG_OUT_STAT, IMC_STAT, IREG_OUT_ID, IMAIN_MC_NAME};
			
			cro = this.getDao("KgDao").ExcuteNonQuery(sqlQuery,obj);
			
			return cro;
		
	}
	
	public CoreReturnObject DoUpdateMC_REG_OUT_STAT(String IMC_PROCESS_REG,String IREG_IN_DTIME) throws SQLException
	{
			CoreReturnObject cro = new CoreReturnObject();
		
			String sqlQuery	=	"update C_TBK03_MACHINE_ONLINE  set MC_PROCESS_REG =?  where REG_IN_DTIME =TO_DATE('"+IREG_IN_DTIME+"','YYYY-MM-DD HH24:MI:SS')";
			
			Object[] obj = new Object[]{IMC_PROCESS_REG };
		
			cro = this.getDao("KgDao").ExcuteNonQuery(sqlQuery,obj);
			
			return cro;		
	}
	
	public CoreReturnObject DoUpdateMC_PROCESS_REG(String IMC_REG_OUT_STAT,String IMC_STAT,String IMC_PROCESS_REG,String IREG_IN_DTIME) throws SQLException
	{
			CoreReturnObject cro = new CoreReturnObject();
		
			String sqlQuery	=	"update C_TBK03_MACHINE_ONLINE  set MC_REG_OUT_STAT =?,MC_STAT =?,MC_PROCESS_REG =?  where REG_IN_DTIME =TO_DATE('"+IREG_IN_DTIME+"','YYYY-MM-DD HH24:MI:SS')";
			
			Object[] obj = new Object[]{IMC_REG_OUT_STAT,IMC_STAT,IMC_PROCESS_REG };
		
			cro = this.getDao("KgDao").ExcuteNonQuery(sqlQuery,obj);
			
			return cro;		
	}
	
	public CoreReturnObject DoUpdateQUXIAO(String IMC_REG_OUT_STAT,String IMC_PROCESS_REG,String IREG_IN_DTIME) throws SQLException
	{
			CoreReturnObject cro = new CoreReturnObject();
		
			String sqlQuery	=	"update C_TBK03_MACHINE_ONLINE  set MC_REG_OUT_STAT =?,MC_PROCESS_REG =?  where REG_IN_DTIME =TO_DATE('"+IREG_IN_DTIME+"','YYYY-MM-DD HH24:MI:SS')";
			
			Object[] obj = new Object[]{IMC_REG_OUT_STAT,IMC_PROCESS_REG };
		
			cro = this.getDao("KgDao").ExcuteNonQuery(sqlQuery,obj);
			
			return cro;		
	}
	
	public CoreReturnObject DoUpdateREG_OUT_DTIME(String IREG_OUT_DTIME,String IREG_IN_DTIME) throws SQLException
	{
			CoreReturnObject cro = new CoreReturnObject();
		
			String sqlQuery	="update C_TBK03_MACHINE_ONLINE set REG_OUT_DTIME = TO_DATE('"+IREG_OUT_DTIME+"','yyyy-mm-dd hh24:mi:ss') WHERE REG_IN_DTIME =TO_DATE('"+IREG_IN_DTIME+"','YYYY-MM-DD HH24:MI:SS')";
			
			//Object[] obj = new Object[]{mcid };
		
			cro = this.getDao("KgDao").ExcuteNonQuery(sqlQuery);
			
			return cro;		
	}

}