Commit 9ae40a65 authored by wansari's avatar wansari

W15GSUN003 updated table name from interface to wms_to_host and interface2 to swms_to_awms.


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@98974 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 1d0ebfa8
...@@ -104,17 +104,13 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -104,17 +104,13 @@ public class ScheduleAWMSInOutTasks implements Schedule
conn = connDriver.getConnectDB("DriverITM"); conn = connDriver.getConnectDB("DriverITM");
connDriver = null; connDriver = null;
conn.setAutoCommit(false); conn.setAutoCommit(false);
/*sql = "SELECT IN_OUT,ERR_COD,MSG_STAT,TRANS_DT_ACK,TRAN_ID," //Changed by wasim on 02-11-15 to change table name from interface to wms_to_host[start]
+ "ITEM_CODE,DESCR,UNIT,ITEM_TYPE,FAMILY_GRP,REF_SER," /*sql = "SELECT DISTINCT REF_ID,REF_SER FROM INTERFACE WHERE REF_ID IN "
+ "LOT_NO,REF_ID,LOT_SL,QUANTITY,NO_ART,EXP_DATE,MFG_DATE," + "(SELECT REF_ID FROM INTERFACE2 WHERE SCHEDULE_STATUS IS NULL)";*/
+ "PALLET_NO,PALLET_STATUS,LOCK_STAT,QC_TYPE,STRO_PREF,PALLET_REJ," sql = "SELECT DISTINCT REF_ID,REF_SER FROM WMS_TO_HOST WHERE REF_ID IN "
+ "PALLET_REJ_DESC,REF_LINE_NO FROM INTERFACE " + "(SELECT REF_ID FROM SWMS_TO_AWMS WHERE SCHEDULE_STATUS IS NULL)";
+ "WHERE SYSDATE > TRANS_DT_ACK";*/ //Changed by wasim on 02-11-15 to change table name from interface to wms_to_host[end]
//sql = "SELECT DISTINCT REF_ID,REF_SER,IN_OUT,MSG_STAT FROM INTERFACE WHERE SYSDATE > TRANS_DT_ACK";
sql = "SELECT DISTINCT REF_ID,REF_SER FROM INTERFACE WHERE REF_ID IN "
+ "(SELECT REF_ID FROM INTERFACE2 WHERE SCHEDULE_STATUS IS NULL)";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
while(rs.next()) while(rs.next())
...@@ -131,8 +127,10 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -131,8 +127,10 @@ public class ScheduleAWMSInOutTasks implements Schedule
countError = 0; countError = 0;
flag = 0; flag = 0;
sqlInf = "SELECT COUNT(*) AS COUNT FROM INTERFACE WHERE REF_ID = ? AND MSG_STAT = 'E' " /*sqlInf = "SELECT COUNT(*) AS COUNT FROM INTERFACE WHERE REF_ID = ? AND MSG_STAT = 'E' "
+ "AND LINE_NO IN (SELECT LINE_NO FROM INTERFACE2 WHERE REF_ID = ? AND SCHEDULE_STATUS IS NULL)"; + "AND LINE_NO IN (SELECT LINE_NO FROM INTERFACE2 WHERE REF_ID = ? AND SCHEDULE_STATUS IS NULL)";*/
sqlInf = "SELECT COUNT(*) AS COUNT FROM WMS_TO_HOST WHERE REF_ID = ? AND MSG_STAT = 'E' "
+ "AND LINE_NO IN (SELECT LINE_NO FROM SWMS_TO_AWMS WHERE REF_ID = ? AND SCHEDULE_STATUS IS NULL)";
interfacePstmt = conn.prepareStatement(sqlInf); interfacePstmt = conn.prepareStatement(sqlInf);
interfacePstmt.setString(1, refId); interfacePstmt.setString(1, refId);
interfacePstmt.setString(2, refId); interfacePstmt.setString(2, refId);
...@@ -295,8 +293,10 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -295,8 +293,10 @@ public class ScheduleAWMSInOutTasks implements Schedule
pstmtDet = conn.prepareStatement(insertSql); pstmtDet = conn.prepareStatement(insertSql);
sqlInterface = "SELECT LINE_NO FROM INTERFACE WHERE REF_ID = ? AND MSG_STAT != 'E'" /*sqlInterface = "SELECT LINE_NO FROM INTERFACE WHERE REF_ID = ? AND MSG_STAT != 'E'"
+ " AND LINE_NO IN (SELECT LINE_NO FROM INTERFACE2 WHERE REF_ID = ? AND SCHEDULE_STATUS IS NULL)"; + " AND LINE_NO IN (SELECT LINE_NO FROM INTERFACE2 WHERE REF_ID = ? AND SCHEDULE_STATUS IS NULL)";*/
sqlInterface = "SELECT LINE_NO FROM WMS_TO_HOST WHERE REF_ID = ? AND MSG_STAT != 'E'"
+ " AND LINE_NO IN (SELECT LINE_NO FROM SWMS_TO_AWMS WHERE REF_ID = ? AND SCHEDULE_STATUS IS NULL)";
pstmtInterface = conn.prepareStatement(sqlInterface); pstmtInterface = conn.prepareStatement(sqlInterface);
pstmtInterface.setString(1, refId); pstmtInterface.setString(1, refId);
pstmtInterface.setString(2, refId); pstmtInterface.setString(2, refId);
...@@ -420,7 +420,7 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -420,7 +420,7 @@ public class ScheduleAWMSInOutTasks implements Schedule
} }
} }
sqlUpdate = "UPDATE INTERFACE2 SET SCHEDULE_STATUS = 'Y' WHERE REF_ID = ? AND LINE_NO = ?"; sqlUpdate = "UPDATE SWMS_TO_AWMS SET SCHEDULE_STATUS = 'Y' WHERE REF_ID = ? AND LINE_NO = ?";
pstmtUpdate = conn.prepareStatement(sqlUpdate); pstmtUpdate = conn.prepareStatement(sqlUpdate);
pstmtUpdate.setString(1, refId); pstmtUpdate.setString(1, refId);
pstmtUpdate.setString(2, lineNoInterface); pstmtUpdate.setString(2, lineNoInterface);
...@@ -643,8 +643,10 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -643,8 +643,10 @@ public class ScheduleAWMSInOutTasks implements Schedule
} }
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
sqlInterface = "SELECT LINE_NO FROM INTERFACE WHERE REF_ID = ? AND MSG_STAT = 'E'" /*sqlInterface = "SELECT LINE_NO FROM INTERFACE WHERE REF_ID = ? AND MSG_STAT = 'E'"
+ "AND LINE_NO IN (SELECT LINE_NO FROM INTERFACE2 WHERE REF_ID = ? AND SCHEDULE_STATUS IS NULL)"; + "AND LINE_NO IN (SELECT LINE_NO FROM INTERFACE2 WHERE REF_ID = ? AND SCHEDULE_STATUS IS NULL)";*/
sqlInterface = "SELECT LINE_NO FROM WMS_TO_HOST WHERE REF_ID = ? AND MSG_STAT = 'E'"
+ "AND LINE_NO IN (SELECT LINE_NO FROM SWMS_TO_AWMS WHERE REF_ID = ? AND SCHEDULE_STATUS IS NULL)";
pstmtInterface = conn.prepareStatement(sqlInterface); pstmtInterface = conn.prepareStatement(sqlInterface);
pstmtInterface.setString(1, refId); pstmtInterface.setString(1, refId);
pstmtInterface.setString(2, refId); pstmtInterface.setString(2, refId);
...@@ -712,7 +714,7 @@ public class ScheduleAWMSInOutTasks implements Schedule ...@@ -712,7 +714,7 @@ public class ScheduleAWMSInOutTasks implements Schedule
rs.close();rs = null; rs.close();rs = null;
pstmt.close();pstmt = null; pstmt.close();pstmt = null;
sqlUpdate = "UPDATE INTERFACE2 SET SCHEDULE_STATUS = 'Y' WHERE REF_ID = ? AND LINE_NO = ?"; sqlUpdate = "UPDATE SWMS_TO_AWMS SET SCHEDULE_STATUS = 'Y' WHERE REF_ID = ? AND LINE_NO = ?";
pstmtUpdate = conn.prepareStatement(sqlUpdate); pstmtUpdate = conn.prepareStatement(sqlUpdate);
pstmtUpdate.setString(1, refId); pstmtUpdate.setString(1, refId);
pstmtUpdate.setString(2, lineNoInterface); pstmtUpdate.setString(2, lineNoInterface);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment