XinYu_LZMES/.svn/pristine/97/970a2b3a1ac6d4c0c732d5ef9667e97c6c639b96.svn-base

package UIK.UIK01;

import java.sql.SQLException;

import CoreFS.SA01.CoreIComponent;
import CoreFS.SA06.CoreReturnObject;
public class UIK010040 extends CoreIComponent{

	public CoreReturnObject DoQuery(String starttiem,String endtime,Boolean flag) throws SQLException
	{
			CoreReturnObject cro = new CoreReturnObject();
			
			String str = "ACID_CONCENT_1,TEMPERATURE_1,FE_CONCENT_1,ACID_CONCENT_2,TEMPERATURE_2,FE_CONCENT_2,ACID_CONCENT_3,TEMPERATURE_3,FE_CONCENT_3,BEGIN_TIME,END_TIME,REG_ID,TO_CHAR(REG_DTIME,'YYYY-MM-DD HH24:MI:SS') REG_DTIME,ALTER_DTIME,REG_ACID,REG_FE,NEW_ACID,DIS_ACID,DIS_FE,TO_CHAR(SAM_TATE,'YYYY-MM-DD') SAM_TATE,SAM_TIME,SAM_ADDRESS,CL_DEEP";
			
			if(!flag)
			{
				
					String sqlQuery	=	"select " + str+" from C_TBK01_SX_RESULT";
				       
					cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
					
					return cro;
					
			}
			else
			{
								
					String sqlQuery	=	"select " + str+" from C_TBK01_SX_RESULT where REG_DTIME >= TO_DATE('"+starttiem+"','YYYY-MM-DD HH24:MI:SS') and REG_DTIME <= TO_DATE('"+endtime+"','YYYY-MM-DD HH24:MI:SS')";
				
					cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
					
					return cro;
				
			}
	}
	
	public CoreReturnObject DoSelect(String ireg_datetime ) throws SQLException
	{
			CoreReturnObject cro = new CoreReturnObject();
			
			String str = "ACID_CONCENT_1,TEMPERATURE_1,FE_CONCENT_1,ACID_CONCENT_2,TEMPERATURE_2,FE_CONCENT_2,ACID_CONCENT_3,TEMPERATURE_3,FE_CONCENT_3,BEGIN_TIME,END_TIME,REG_ID,REG_DTIME,ALTER_DTIME,REG_ACID,REG_FE,NEW_ACID,DIS_ACID,DIS_FE,TO_CHAR(SAM_TATE,'YYYY-MM-DD') SAM_TATE,SAM_TIME,SAM_ADDRESS,CL_DEEP";
			
			String sqlQuery	=	"select " + str+" from C_TBK01_SX_RESULT where REG_DTIME = TO_DATE('"+ireg_datetime+"','YYYY-MM-DD HH24:MI:SS')";
			
			cro = this.getDao("KgDao").ExcuteQuery(sqlQuery);
			
			return cro;
		
	}
	
	public CoreReturnObject DoUpdate(String IACID_CONCENT_1,String ITEMPERATURE_1,String IFE_CONCENT_1,String IACID_CONCENT_2,String ITEMPERATURE_2,String IFE_CONCENT_2,String IACID_CONCENT_3,String ITEMPERATURE_3,String IFE_CONCENT_3,String IREG_ID,String IALTER_DTIME ,String IREG_DTIME,String IREG_ACID,String IREG_FE,String INEW_ACID,String IDIS_ACID,String IDIS_FE,String ISAM_TATE,String ISAM_TIME,String ISAM_ADDRESS,String ICL) throws SQLException
	{
			CoreReturnObject cro = new CoreReturnObject();					
			
			String sqlQuery	="update C_TBK01_SX_RESULT  set ACID_CONCENT_1=?, TEMPERATURE_1=?, FE_CONCENT_1=?, ACID_CONCENT_2=?, TEMPERATURE_2=?, FE_CONCENT_2=?, ACID_CONCENT_3=?, TEMPERATURE_3=?, FE_CONCENT_3=?, REG_ID=?, ALTER_DTIME = TO_DATE('"+IALTER_DTIME+"','YYYY-MM-DD HH24:MI:SS'),REG_ACID = ?,REG_FE = ?,NEW_ACID = ?,DIS_ACID = ?,DIS_FE = ?,SAM_TATE = TO_DATE('"+ISAM_TATE+"','YYYY-MM-DD'),SAM_TIME = ?,SAM_ADDRESS = ?,CL_DEEP = ? where REG_DTIME =TO_DATE('"+IREG_DTIME+"','YYYY-MM-DD HH24:MI:SS')";
			
			Object[] obj = new Object[]{IACID_CONCENT_1, ITEMPERATURE_1, IFE_CONCENT_1, IACID_CONCENT_2, ITEMPERATURE_2, IFE_CONCENT_2, IACID_CONCENT_3, ITEMPERATURE_3, IFE_CONCENT_3, IREG_ID,IREG_ACID,IREG_FE,INEW_ACID,IDIS_ACID,IDIS_FE,ISAM_TIME,ISAM_ADDRESS,ICL };
			
			cro = this.getDao("KgDao").ExcuteNonQuery(sqlQuery,obj);	
			
			return cro;
		
	}
	
	public CoreReturnObject DoInsert(String IACID_CONCENT_1,String ITEMPERATURE_1,String IFE_CONCENT_1,String IACID_CONCENT_2,String ITEMPERATURE_2,String IFE_CONCENT_2,String IACID_CONCENT_3,String ITEMPERATURE_3,String IFE_CONCENT_3,String IREG_ID,String IREG_DTIME, String IREG_ACID,String IREG_FE,String INEW_ACID,String IDIS_ACID,String IDIS_FE,String ISAM_TATE,String ISAM_TIME,String ISAM_ADDRESS,String ICL) throws SQLException
	{
			CoreReturnObject cro = new CoreReturnObject();							
			
			String sqlQuery	=	"insert into C_TBK01_SX_RESULT(ACID_CONCENT_1,TEMPERATURE_1, FE_CONCENT_1, ACID_CONCENT_2, TEMPERATURE_2, FE_CONCENT_2, ACID_CONCENT_3, TEMPERATURE_3, FE_CONCENT_3, REG_ID, REG_DTIME,REG_ACID,REG_FE,NEW_ACID,DIS_ACID,DIS_FE,SAM_TATE,SAM_TIME,SAM_ADDRESS,CL_DEEP) values(?,?,?,?,?,?,?,?,?,?,TO_DATE('"+IREG_DTIME+"','YYYY-MM-DD HH24:MI:SS'),?,?,?,?,?,TO_DATE('"+ISAM_TATE+"','YYYY-MM-DD'),?,?,?)";
			
			Object[] obj = new Object[]{IACID_CONCENT_1, ITEMPERATURE_1, IFE_CONCENT_1, IACID_CONCENT_2, ITEMPERATURE_2, IFE_CONCENT_2, IACID_CONCENT_3, ITEMPERATURE_3, IFE_CONCENT_3, IREG_ID, IREG_ACID,IREG_FE,INEW_ACID,IDIS_ACID,IDIS_FE,ISAM_TIME,ISAM_ADDRESS,ICL};
			
			cro = this.getDao("KgDao").ExcuteNonQuery(sqlQuery,obj);
			
			return cro;
		
	}
}