XinYu_LZMES/.svn/pristine/7b/7bdb59dabb78b71eec8828b7fb62fd5a62122097.svn-base

package UIK.UIK03;

import java.sql.SQLException;

import CoreFS.SA01.CoreIComponent;
import CoreFS.SA06.CoreReturnObject;
public class UIK030050 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_SERVICEREASON,MC_SERVICE_ID,MC_STARSERVICE,MC_ENDESERVICE,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_SERVICEREASON,MC_SERVICE_ID,MC_STARSERVICE,MC_ENDESERVICE,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";
			
			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_SERVICEREASON,String IMC_SERVICE_ID,String IMC_STARSERVICE,String IMC_ENDESERVICE,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 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_SERVICEREASON =?, MC_SERVICE_ID =?, MC_STARSERVICE =TO_DATE('"+IMC_STARSERVICE+"','yyyy-mm-dd'), MC_ENDESERVICE =TO_DATE('"+IMC_ENDESERVICE+"','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_SERVICEREASON, IMC_SERVICE_ID, IMC_CARE_SECTOR, IMC_NOM_CAP, IMC_UNIT, IMC_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_SERVICEREASON,String IMC_SERVICE_ID,String IMC_STARSERVICE,String IMC_ENDESERVICE,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 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_SERVICEREASON,MC_SERVICE_ID,MC_STARSERVICE,MC_ENDESERVICE,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_STARSERVICE+"','yyyy-mm-dd'),TO_DATE('"+IMC_ENDESERVICE+"','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_SERVICEREASON, IMC_SERVICE_ID, IMC_CARE_SECTOR, IMC_NOM_CAP, IMC_UNIT, IMC_TAI, IMC_ACT, IMC_MFACTUR_UNITS, IMC_USE_YEAR, IMC_INSTAL_LOCAL,IMAIN_MC_NAME};
			//Object[] obj = new Object[]{mcid,IMC_NAME, IMC_MODEL, IMC_SPEC, IMC_FACTORY,IMC_IN_DTIME, IMC_PRICE, IMC_CARE_SECTOR, IMC_NOM_CAP, IMC_UNIT, IMC_TAI, IMC_ACT, IMC_MFACTUR_UNITS, IMC_USE_YEAR,IMC_USE_TIME, IMC_INSTAL_LOCAL, IREG_IN_ID,IREG_IN_DTIME, IMC_STAT};
			cro = this.getDao("KgDao").ExcuteNonQuery(sqlQuery,obj);
			
			return cro;
		
	}

}