迁移库名

src/main/java/cn/gov/customs/data/timer/H2018ZhDangerGoodsUtil.java

@@ -311,7 +311,7 @@ public class H2018ZhDangerGoodsUtil {
 							ids = sb.toString();
 							// 进口新舱单水运、空运的I_E_DATE精准值由MANIFEST_LIST_NEW的REAL_ARRIVE_DATE给定
 							// 注意：提运单号会被重用，当天的也可能有不同报关单使用了相同的提运单号
-							sql = "select a.ENTRY_ID, b.REAL_ARRIVE_DATE from ENTRY_HEAD a, `g_whdb_h2000_ims_recv`.MANIFEST_LIST_NEW b where a.ENTRY_ID in ("
+							sql = "select a.ENTRY_ID, b.REAL_ARRIVE_DATE from ENTRY_HEAD a, `g_whdb_zmqd`.mft_MANIFEST_LIST_NEW b where a.ENTRY_ID in ("
 									+ ids + ") and a.BILL_NO = b.BILL_NO and a.I_E_PORT = b.CUSTOMS_CODE and to_char(a.I_E_DATE,'yyyyMMdd') = to_char(b.REAL_ARRIVE_DATE,'yyyyMMdd')";
 
 							list = (List<Object[]>) h2018Dao.getQueryBySql(sql);
@@ -332,7 +332,7 @@ public class H2018ZhDangerGoodsUtil {
 							// 出口新舱单水运、空运可能提前但航班晚到，无法用时间去精准定位哪一条会卸载很多次，精准值由MANIFEST_MONITOR_NEW的ARRIVAL_DATE给定
 							// 注意：提运单号会被重用，当天的也可能有不同报关单使用了相同的提运单号,ARRIVAL_DATE为00:00:00的赋值12:00:00
 							//20210508舱单只获取和武汉海关有关的数据进行时间赋值，所以a.I_E_PORT = b.CUSTOMS_CODE
-							sql = "select a.ENTRY_ID, min(b.ARRIVAL_DATE) from ENTRY_HEAD a, `g_whdb_h2000_ims_recv`.MANIFEST_MONITOR_NEW b where a.ENTRY_ID in ("
+							sql = "select a.ENTRY_ID, min(b.ARRIVAL_DATE) from ENTRY_HEAD a, `g_whdb_zmqd`.mft_MANIFEST_MONITOR_NEW b where a.ENTRY_ID in ("
 									+ ids + ") and a.BILL_NO = b.BILL_NO and a.I_E_PORT = b.CUSTOMS_CODE group by a.ENTRY_ID";
 
 							list = (List<Object[]>) h2018Dao.getQueryBySql(sql);
@@ -922,8 +922,8 @@ public class H2018ZhDangerGoodsUtil {
 							sb.deleteCharAt(sb.length() - 1);
 							ids = sb.toString();
 							// 部分转关类型的报关单需要通过新舱单系统拿到转关数据发送时间和转关数据核销时间
-							sql = "select a.ENTRY_ID, b.EXAM_TIME, b.CHECK_TIME from ENTRY_HEAD a, `g_whdb_h2000_ims_recv`.IM_DECL_CUR_HEAD b, " +
-									"`g_whdb_h2000_ims_recv`.MANIFEST_CHK_NEW c where a.ENTRY_ID in ("
+							sql = "select a.ENTRY_ID, b.EXAM_TIME, b.CHECK_TIME from ENTRY_HEAD a, `g_whdb_rh2k`.rh2k_IM_DECL_CUR_HEAD b, " +
+									"`g_whdb_zmqd`.mft_MANIFEST_CHK_NEW c where a.ENTRY_ID in ("
 									+ ids + ") and (a.ENTRY_ID = c.FORM_ID and c.MANIFEST_ID = b.PRE_NO)";
 
 							list = (List<Object[]>) h2018Dao.getQueryBySql(sql);
@@ -946,8 +946,8 @@ public class H2018ZhDangerGoodsUtil {
 								// 经过数据分析，放弃上面方案，改为若I_E_DATE时分为0的改为12点
 
 								// 只考虑入境报关单的转关数据：可能查到多余报关单量的数据
-								sql = "select a.ENTRY_ID, b.EXAM_TIME, b.CHECK_TIME from ENTRY_HEAD a,`g_whdb_h2000_ims_recv`.IM_DECL_CUR_HEAD b," +
-										"`g_whdb_h2000_ims_recv`.IM_TRANS_LIST_REL c where a.ENTRY_ID in ("
+								sql = "select a.ENTRY_ID, b.EXAM_TIME, b.CHECK_TIME from ENTRY_HEAD a,`g_whdb_rh2k`.rh2k_IM_DECL_CUR_HEAD b," +
+										"`g_whdb_rh2k`.rh2k_IM_TRANS_LIST_REL c where a.ENTRY_ID in ("
 										+ ids + ") and (a.ENTRY_ID = c.ENTRY_NO and c.PRE_NO = b.PRE_NO)";
 
 								list = (List<Object[]>) h2018Dao.getQueryBySql(sql);
@@ -963,8 +963,8 @@ public class H2018ZhDangerGoodsUtil {
 								if (sb.length() > 0) {
 									sb.deleteCharAt(sb.length() - 1);
 									ids = sb.toString();
-									sql = "select a.ENTRY_ID, b.EXAM_TIME, b.CHECK_TIME from ENTRY_HEAD a,`g_whdb_h2000_ims_recv`.IM_DECL_CUR_HEAD b," +
-											"`g_whdb_h2000_ims_recv`.IM_TRANS_LIST_REL c where a.ENTRY_ID in ("
+									sql = "select a.ENTRY_ID, b.EXAM_TIME, b.CHECK_TIME from ENTRY_HEAD a,`g_whdb_rh2k`.rh2k_IM_DECL_CUR_HEAD b," +
+											"`g_whdb_rh2k`.rh2k_IM_TRANS_LIST_REL c where a.ENTRY_ID in ("
 											+ ids + ") and (a.BILL_NO = c.BILL_NO and c.PRE_NO = b.PRE_NO)";
 
 									list = (List<Object[]>) h2018Dao.getQueryBySql(sql);
@@ -981,7 +981,7 @@ public class H2018ZhDangerGoodsUtil {
 								if (sb.length() > 0) {
 									sb.deleteCharAt(sb.length() - 1);
 									ids = sb.toString();
-									sql = "select a.ENTRY_ID, b.EXAM_TIME, b.CHECK_TIME from ENTRY_HEAD a,`g_whdb_h2000_ims_recv`.IM_DECL_CUR_HEAD b " +
+									sql = "select a.ENTRY_ID, b.EXAM_TIME, b.CHECK_TIME from ENTRY_HEAD a,`g_whdb_rh2k`.rh2k_IM_DECL_CUR_HEAD b " +
 											"where a.ENTRY_ID in (" + ids + ") and instr(a.TRAF_NAME,b.PRE_NO) > 0";
 
 									list = (List<Object[]>) h2018Dao.getQueryBySql(sql);
@@ -1002,7 +1002,7 @@ public class H2018ZhDangerGoodsUtil {
 							ids = sb.toString();
 							// 进口新舱单水运、空运的I_E_DATE精准值由MANIFEST_LIST_NEW的REAL_ARRIVE_DATE给定
 							// 注意：提运单号会被重用，当天的也可能有不同报关单使用了相同的提运单号
-							sql = "select a.ENTRY_ID, b.REAL_ARRIVE_DATE from ENTRY_HEAD a,`g_whdb_h2000_ims_recv`.MANIFEST_LIST_NEW b where a.ENTRY_ID in ("
+							sql = "select a.ENTRY_ID, b.REAL_ARRIVE_DATE from ENTRY_HEAD a,`g_whdb_zmqd`.mft_MANIFEST_LIST_NEW b where a.ENTRY_ID in ("
 									+ ids + ") and a.BILL_NO = b.BILL_NO and a.I_E_PORT = b.CUSTOMS_CODE and to_char(a.I_E_DATE,'yyyyMMdd') = to_char(b.REAL_ARRIVE_DATE,'yyyyMMdd')";
 
 							list = (List<Object[]>) h2018Dao.getQueryBySql(sql);
@@ -1023,7 +1023,7 @@ public class H2018ZhDangerGoodsUtil {
 							// 出口新舱单水运、空运可能提前但航班晚到，无法用时间去精准定位哪一条会卸载很多次，精准值由MANIFEST_MONITOR_NEW的ARRIVAL_DATE给定
 							// 注意：提运单号会被重用，当天的也可能有不同报关单使用了相同的提运单号,ARRIVAL_DATE为00:00:00的赋值12:00:00
 							//20210508舱单只获取和武汉海关有关的数据进行时间赋值，所以a.I_E_PORT = b.CUSTOMS_CODE
-							sql = "select a.ENTRY_ID, min(b.ARRIVAL_DATE) from ENTRY_HEAD a, `g_whdb_h2000_ims_recv`.MANIFEST_MONITOR_NEW b where a.ENTRY_ID in ("
+							sql = "select a.ENTRY_ID, min(b.ARRIVAL_DATE) from ENTRY_HEAD a, `g_whdb_zmqd`.mft_MANIFEST_MONITOR_NEW b where a.ENTRY_ID in ("
 									+ ids + ") and a.BILL_NO = b.BILL_NO and a.I_E_PORT = b.CUSTOMS_CODE group by a.ENTRY_ID";
 
 							list = (List<Object[]>) h2018Dao.getQueryBySql(sql);
@@ -1637,7 +1637,7 @@ public class H2018ZhDangerGoodsUtil {
 							ids = sb.toString();
 							// 进口新舱单水运、空运的I_E_DATE精准值由MANIFEST_LIST_NEW的REAL_ARRIVE_DATE给定
 							// 注意：提运单号会被重用，当天的也可能有不同报关单使用了相同的提运单号
-							sql = "select a.ENTRY_ID, b.REAL_ARRIVE_DATE from ENTRY_HEAD a, `g_whdb_h2000_ims_recv`.MANIFEST_LIST_NEW b where a.ENTRY_ID in ("
+							sql = "select a.ENTRY_ID, b.REAL_ARRIVE_DATE from ENTRY_HEAD a, `g_whdb_zmqd`.mft_MANIFEST_LIST_NEW b where a.ENTRY_ID in ("
 									+ ids + ") and a.BILL_NO = b.BILL_NO and a.I_E_PORT = b.CUSTOMS_CODE and to_char(a.I_E_DATE,'yyyyMMdd') = to_char(b.REAL_ARRIVE_DATE,'yyyyMMdd')";
 
 							list = (List<Object[]>) h2018Dao.getQueryBySql(sql);
@@ -1658,7 +1658,7 @@ public class H2018ZhDangerGoodsUtil {
 							// 出口新舱单水运、空运可能提前但航班晚到，无法用时间去精准定位哪一条会卸载很多次，精准值由MANIFEST_MONITOR_NEW的ARRIVAL_DATE给定
 							// 注意：提运单号会被重用，当天的也可能有不同报关单使用了相同的提运单号,ARRIVAL_DATE为00:00:00的赋值12:00:00
 							//20210508舱单只获取和武汉海关有关的数据进行时间赋值，所以a.I_E_PORT = b.CUSTOMS_CODE
-							sql = "select a.ENTRY_ID, min(b.ARRIVAL_DATE) from ENTRY_HEAD a, `g_whdb_h2000_ims_recv`.MANIFEST_MONITOR_NEW b where a.ENTRY_ID in ("
+							sql = "select a.ENTRY_ID, min(b.ARRIVAL_DATE) from ENTRY_HEAD a, `g_whdb_zmqd`.mft_MANIFEST_MONITOR_NEW b where a.ENTRY_ID in ("
 									+ ids + ") and a.BILL_NO = b.BILL_NO and a.I_E_PORT = b.CUSTOMS_CODE group by a.ENTRY_ID";
 
 							list = (List<Object[]>) h2018Dao.getQueryBySql(sql);

src/main/java/cn/gov/customs/data/timer/H2018ZhOldDangerGoodsUtil.java

@@ -311,7 +311,7 @@ public class H2018ZhOldDangerGoodsUtil {
 							ids = sb.toString();
 							// 进口新舱单水运、空运的I_E_DATE精准值由MANIFEST_LIST_NEW的REAL_ARRIVE_DATE给定
 							// 注意：提运单号会被重用，当天的也可能有不同报关单使用了相同的提运单号
-							sql = "select a.ENTRY_ID, b.REAL_ARRIVE_DATE from ENTRY_HEAD a, `g_whdb_h2000_ims_recv`.MANIFEST_LIST_NEW b where a.ENTRY_ID in ("
+							sql = "select a.ENTRY_ID, b.REAL_ARRIVE_DATE from ENTRY_HEAD a, `g_whdb_zmqd`.mft_MANIFEST_LIST_NEW b where a.ENTRY_ID in ("
 									+ ids + ") and a.BILL_NO = b.BILL_NO and a.I_E_PORT = b.CUSTOMS_CODE and to_char(a.I_E_DATE,'yyyyMMdd') = to_char(b.REAL_ARRIVE_DATE,'yyyyMMdd')";
 
 							list = (List<Object[]>) h2018Dao.getQueryBySql(sql);
@@ -332,7 +332,7 @@ public class H2018ZhOldDangerGoodsUtil {
 							// 出口新舱单水运、空运可能提前但航班晚到，无法用时间去精准定位哪一条会卸载很多次，精准值由MANIFEST_MONITOR_NEW的ARRIVAL_DATE给定
 							// 注意：提运单号会被重用，当天的也可能有不同报关单使用了相同的提运单号,ARRIVAL_DATE为00:00:00的赋值12:00:00
 							//20210508舱单只获取和武汉海关有关的数据进行时间赋值，所以a.I_E_PORT = b.CUSTOMS_CODE
-							sql = "select a.ENTRY_ID, min(b.ARRIVAL_DATE) from ENTRY_HEAD a, `g_whdb_h2000_ims_recv`.MANIFEST_MONITOR_NEW b where a.ENTRY_ID in ("
+							sql = "select a.ENTRY_ID, min(b.ARRIVAL_DATE) from ENTRY_HEAD a, `g_whdb_zmqd`.mft_MANIFEST_MONITOR_NEW b where a.ENTRY_ID in ("
 									+ ids + ") and a.BILL_NO = b.BILL_NO and a.I_E_PORT = b.CUSTOMS_CODE group by a.ENTRY_ID";
 
 							list = (List<Object[]>) h2018Dao.getQueryBySql(sql);
@@ -923,8 +923,8 @@ public class H2018ZhOldDangerGoodsUtil {
 							sb.deleteCharAt(sb.length() - 1);
 							ids = sb.toString();
 							// 部分转关类型的报关单需要通过新舱单系统拿到转关数据发送时间和转关数据核销时间
-							sql = "select a.ENTRY_ID, b.EXAM_TIME, b.CHECK_TIME from ENTRY_HEAD a, `g_whdb_h2000_ims_recv`.IM_DECL_CUR_HEAD b, " +
-									"`g_whdb_h2000_ims_recv`.MANIFEST_CHK_NEW c where a.ENTRY_ID in ("
+							sql = "select a.ENTRY_ID, b.EXAM_TIME, b.CHECK_TIME from ENTRY_HEAD a, `g_whdb_rh2k`.rh2k_IM_DECL_CUR_HEAD b, " +
+									"`g_whdb_zmqd`.MANIFEST_CHK_NEW c where a.ENTRY_ID in ("
 									+ ids + ") and (a.ENTRY_ID = c.FORM_ID and c.MANIFEST_ID = b.PRE_NO)";
 
 							list = (List<Object[]>) h2018Dao.getQueryBySql(sql);
@@ -947,8 +947,8 @@ public class H2018ZhOldDangerGoodsUtil {
 								// 经过数据分析，放弃上面方案，改为若I_E_DATE时分为0的改为12点
 
 								// 只考虑入境报关单的转关数据：可能查到多余报关单量的数据
-								sql = "select a.ENTRY_ID, b.EXAM_TIME, b.CHECK_TIME from ENTRY_HEAD a,`g_whdb_h2000_ims_recv`.IM_DECL_CUR_HEAD b," +
-										"`g_whdb_h2000_ims_recv`.IM_TRANS_LIST_REL c where a.ENTRY_ID in ("
+								sql = "select a.ENTRY_ID, b.EXAM_TIME, b.CHECK_TIME from ENTRY_HEAD a,`g_whdb_rh2k`.rh2k_IM_DECL_CUR_HEAD b," +
+										"`g_whdb_rh2k`.rh2k_IM_TRANS_LIST_REL c where a.ENTRY_ID in ("
 										+ ids + ") and (a.ENTRY_ID = c.ENTRY_NO and c.PRE_NO = b.PRE_NO)";
 
 								list = (List<Object[]>) h2018Dao.getQueryBySql(sql);
@@ -964,8 +964,8 @@ public class H2018ZhOldDangerGoodsUtil {
 								if (sb.length() > 0) {
 									sb.deleteCharAt(sb.length() - 1);
 									ids = sb.toString();
-									sql = "select a.ENTRY_ID, b.EXAM_TIME, b.CHECK_TIME from ENTRY_HEAD a,`g_whdb_h2000_ims_recv`.IM_DECL_CUR_HEAD b," +
-											"`g_whdb_h2000_ims_recv`.IM_TRANS_LIST_REL c where a.ENTRY_ID in ("
+									sql = "select a.ENTRY_ID, b.EXAM_TIME, b.CHECK_TIME from ENTRY_HEAD a,`g_whdb_rh2k`.rh2k_IM_DECL_CUR_HEAD b," +
+											"`g_whdb_rh2k`.rh2k_IM_TRANS_LIST_REL c where a.ENTRY_ID in ("
 											+ ids + ") and (a.BILL_NO = c.BILL_NO and c.PRE_NO = b.PRE_NO)";
 
 									list = (List<Object[]>) h2018Dao.getQueryBySql(sql);
@@ -982,7 +982,7 @@ public class H2018ZhOldDangerGoodsUtil {
 								if (sb.length() > 0) {
 									sb.deleteCharAt(sb.length() - 1);
 									ids = sb.toString();
-									sql = "select a.ENTRY_ID, b.EXAM_TIME, b.CHECK_TIME from ENTRY_HEAD a,`g_whdb_h2000_ims_recv`.IM_DECL_CUR_HEAD b " +
+									sql = "select a.ENTRY_ID, b.EXAM_TIME, b.CHECK_TIME from ENTRY_HEAD a,`g_whdb_rh2k`.rh2k_IM_DECL_CUR_HEAD b " +
 											"where a.ENTRY_ID in (" + ids + ") and instr(a.TRAF_NAME,b.PRE_NO) > 0";
 
 									list = (List<Object[]>) h2018Dao.getQueryBySql(sql);
@@ -1003,7 +1003,7 @@ public class H2018ZhOldDangerGoodsUtil {
 							ids = sb.toString();
 							// 进口新舱单水运、空运的I_E_DATE精准值由MANIFEST_LIST_NEW的REAL_ARRIVE_DATE给定
 							// 注意：提运单号会被重用，当天的也可能有不同报关单使用了相同的提运单号
-							sql = "select a.ENTRY_ID, b.REAL_ARRIVE_DATE from ENTRY_HEAD a,`g_whdb_h2000_ims_recv`.MANIFEST_LIST_NEW b where a.ENTRY_ID in ("
+							sql = "select a.ENTRY_ID, b.REAL_ARRIVE_DATE from ENTRY_HEAD a,`g_whdb_zmqd`.mft_MANIFEST_LIST_NEW b where a.ENTRY_ID in ("
 									+ ids + ") and a.BILL_NO = b.BILL_NO and a.I_E_PORT = b.CUSTOMS_CODE and to_char(a.I_E_DATE,'yyyyMMdd') = to_char(b.REAL_ARRIVE_DATE,'yyyyMMdd')";
 
 							list = (List<Object[]>) h2018Dao.getQueryBySql(sql);
@@ -1024,7 +1024,7 @@ public class H2018ZhOldDangerGoodsUtil {
 							// 出口新舱单水运、空运可能提前但航班晚到，无法用时间去精准定位哪一条会卸载很多次，精准值由MANIFEST_MONITOR_NEW的ARRIVAL_DATE给定
 							// 注意：提运单号会被重用，当天的也可能有不同报关单使用了相同的提运单号,ARRIVAL_DATE为00:00:00的赋值12:00:00
 							//20210508舱单只获取和武汉海关有关的数据进行时间赋值，所以a.I_E_PORT = b.CUSTOMS_CODE
-							sql = "select a.ENTRY_ID, min(b.ARRIVAL_DATE) from ENTRY_HEAD a, `g_whdb_h2000_ims_recv`.MANIFEST_MONITOR_NEW b where a.ENTRY_ID in ("
+							sql = "select a.ENTRY_ID, min(b.ARRIVAL_DATE) from ENTRY_HEAD a, `g_whdb_zmqd`.mft_MANIFEST_MONITOR_NEW b where a.ENTRY_ID in ("
 									+ ids + ") and a.BILL_NO = b.BILL_NO and a.I_E_PORT = b.CUSTOMS_CODE group by a.ENTRY_ID";
 
 							list = (List<Object[]>) h2018Dao.getQueryBySql(sql);
@@ -1638,7 +1638,7 @@ public class H2018ZhOldDangerGoodsUtil {
 							ids = sb.toString();
 							// 进口新舱单水运、空运的I_E_DATE精准值由MANIFEST_LIST_NEW的REAL_ARRIVE_DATE给定
 							// 注意：提运单号会被重用，当天的也可能有不同报关单使用了相同的提运单号
-							sql = "select a.ENTRY_ID, b.REAL_ARRIVE_DATE from ENTRY_HEAD a, `g_whdb_h2000_ims_recv`.MANIFEST_LIST_NEW b where a.ENTRY_ID in ("
+							sql = "select a.ENTRY_ID, b.REAL_ARRIVE_DATE from ENTRY_HEAD a, `g_whdb_zmqd`.mft_MANIFEST_LIST_NEW b where a.ENTRY_ID in ("
 									+ ids + ") and a.BILL_NO = b.BILL_NO and a.I_E_PORT = b.CUSTOMS_CODE and to_char(a.I_E_DATE,'yyyyMMdd') = to_char(b.REAL_ARRIVE_DATE,'yyyyMMdd')";
 
 							list = (List<Object[]>) h2018Dao.getQueryBySql(sql);
@@ -1659,7 +1659,7 @@ public class H2018ZhOldDangerGoodsUtil {
 							// 出口新舱单水运、空运可能提前但航班晚到，无法用时间去精准定位哪一条会卸载很多次，精准值由MANIFEST_MONITOR_NEW的ARRIVAL_DATE给定
 							// 注意：提运单号会被重用，当天的也可能有不同报关单使用了相同的提运单号,ARRIVAL_DATE为00:00:00的赋值12:00:00
 							//20210508舱单只获取和武汉海关有关的数据进行时间赋值，所以a.I_E_PORT = b.CUSTOMS_CODE
-							sql = "select a.ENTRY_ID, min(b.ARRIVAL_DATE) from ENTRY_HEAD a, `g_whdb_h2000_ims_recv`.MANIFEST_MONITOR_NEW b where a.ENTRY_ID in ("
+							sql = "select a.ENTRY_ID, min(b.ARRIVAL_DATE) from ENTRY_HEAD a, `g_whdb_zmqd`.mft_MANIFEST_MONITOR_NEW b where a.ENTRY_ID in ("
 									+ ids + ") and a.BILL_NO = b.BILL_NO and a.I_E_PORT = b.CUSTOMS_CODE group by a.ENTRY_ID";
 
 							list = (List<Object[]>) h2018Dao.getQueryBySql(sql);