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; } }