XinYu_LZMES/.svn/pristine/58/58b3ecc62533ea18b60e2eccf25e57fe7c0227ba.svn-base

package UIK.UIK03;

import java.sql.SQLException;

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

public class UIK030040 extends CoreIComponent{

	public CoreReturnObject DoQuery(String mc_id,String starttiem,String endtime) throws SQLException
	{
			CoreReturnObject cro = new CoreReturnObject();
			
			String str = "MC_ID,MC_NAME,MC_STAT,MC_MODEL,MC_SPEC,MC_EGIS_REASON,MC_EGIS_ID,MC_EGIS_DTIME,MC_CARE_SECTOR,MC_NOM_CAP,MC_UNIT,MC_TAI,MC_ACT,MC_MFACTUR_UNITS,MC_USE_YEAR,MC_USE_TIME,MC_INSTAL_LOCAL,MAIN_MC_NAME,TO_CHAR(REG_IN_DTIME,'YYYY-MM-DD HH24:MI:SS') REG_IN_DTIME";
			
			
				if(mc_id.equals("")&& !starttiem.equals("")&&!endtime.equals(""))
				{
					if(starttiem == endtime)
					{
						String sqlQuery	=	"select " + str+" from C_TBK03_MACHINE_ONLINE where MC_STARSERVICE = TO_DATE('"+starttiem+"','yyyy-mm-dd')";
						
						cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
						
						return cro;
					}
					else
					{
						String sqlQuery	=	"select " + str+" from C_TBK03_MACHINE_ONLINE where MC_STARSERVICE >= TO_DATE('"+starttiem+"','yyyy-mm-dd') and MC_STARSERVICE <= TO_DATE('"+endtime+"','yyyy-mm-dd')";
						
						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 MC_STARSERVICE >= TO_DATE('"+starttiem+"','yyyy-mm-dd') and MC_STARSERVICE <= 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_STAT,MC_MODEL,MC_SPEC,MC_EGIS_REASON,MC_EGIS_ID,MC_EGIS_DTIME,MC_CARE_SECTOR,MC_NOM_CAP,MC_UNIT,MC_TAI,MC_ACT,MC_MFACTUR_UNITS,MC_USE_YEAR,MC_USE_TIME,MC_INSTAL_LOCAL,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_STAT,String IMC_MODEL,String IMC_SPEC,String IMC_EGIS_REASON,String IMC_EGIS_ID,String IMC_EGIS_DTIME,String IMC_CARE_SECTOR,String IMC_NOM_CAP,String IMC_UNIT,String MC_TAI,String IMC_ACT,String IMC_MFACTUR_UNITS,String IMC_USE_YEAR,String IMC_USE_TIME,String IMC_INSTAL_LOCAL,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_STAT =?,MC_MODEL =?,MC_SPEC =?,MC_EGIS_REASON =?,MC_EGIS_ID =?,MC_EGIS_DTIME =TO_DATE('"+IMC_EGIS_DTIME+"','yyyy-mm-dd'),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 =?,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_STAT, IMC_MODEL, IMC_SPEC, IMC_EGIS_REASON, IMC_EGIS_ID, IMC_CARE_SECTOR, IMC_NOM_CAP, IMC_UNIT, MC_TAI, IMC_ACT, IMC_MFACTUR_UNITS, IMC_USE_YEAR, IMC_INSTAL_LOCAL,IMAIN_MC_NAME };
						
			cro = this.getDao("KgDao").ExcuteNonQuery(sqlQuery,obj);
			
			return cro;
		
	}
	
	public CoreReturnObject DoInsert(String mcid,String IMC_NAME,String IMC_STAT,String IMC_MODEL,String IMC_SPEC,String IMC_EGIS_REASON,String IMC_EGIS_ID,String IMC_EGIS_DTIME,String IMC_CARE_SECTOR,String IMC_NOM_CAP,String IMC_UNIT,String MC_TAI,String IMC_ACT,String IMC_MFACTUR_UNITS,String IMC_USE_YEAR,String IMC_USE_TIME,String IMC_INSTAL_LOCAL,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_STAT,MC_MODEL,MC_SPEC,MC_EGIS_REASON,MC_EGIS_ID,MC_EGIS_DTIME,MC_CARE_SECTOR,MC_NOM_CAP,MC_UNIT,MC_TAI,MC_ACT,MC_MFACTUR_UNITS,MC_USE_YEAR,MC_USE_TIME,MC_INSTAL_LOCAL, MAIN_MC_NAME, REG_IN_DTIME) values(?,?,?,?,?,?,?,TO_DATE('"+IMC_EGIS_DTIME+"','yyyy-mm-dd'),?,?,?,?,?,?,?,TO_DATE('"+IMC_USE_TIME+"','yyyy-mm-dd'),?,?,TO_DATE('"+IREG_IN_DTIME+"','YYYY-MM-DD HH24:MI:SS'))";
			
			Object[] obj = new Object[]{mcid, IMC_NAME, IMC_STAT, IMC_MODEL, IMC_SPEC, IMC_EGIS_REASON, IMC_EGIS_ID, IMC_CARE_SECTOR, IMC_NOM_CAP, IMC_UNIT, MC_TAI, IMC_ACT, IMC_MFACTUR_UNITS, IMC_USE_YEAR, IMC_INSTAL_LOCAL,IMAIN_MC_NAME };
			
			cro = this.getDao("KgDao").ExcuteNonQuery(sqlQuery,obj);
			
			return cro;
		
	}

}