From aa102503723309b8d07186b39c581bf9b40962a2 Mon Sep 17 00:00:00 2001
From: xiaochou164 <xiaochou164@icloud.com>
Date: Mon, 21 Aug 2023 10:10:07 +0800
Subject: [PATCH] =?UTF-8?q?=E7=BC=A9=E7=9F=AD=E6=9B=B4=E6=96=B0=E8=8C=83?=
 =?UTF-8?q?=E5=9B=B4,=E4=BC=98=E5=8C=96=E6=89=A7=E8=A1=8C=E6=80=A7?=
 =?UTF-8?q?=E8=83=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../存储过程/SyncMesData_every_2_hours.sql    | 119 ++++++++++++++----
 1 file changed, 94 insertions(+), 25 deletions(-)

diff --git a/数据库迁移sql/存储过程/SyncMesData_every_2_hours.sql b/数据库迁移sql/存储过程/SyncMesData_every_2_hours.sql
index 4da2628..e2d72f4 100644
--- a/数据库迁移sql/存储过程/SyncMesData_every_2_hours.sql
+++ b/数据库迁移sql/存储过程/SyncMesData_every_2_hours.sql
@@ -7,32 +7,101 @@ drop procedure if exists SyncMesData_every_2_hours;
 create
     definer = root@`%` procedure SyncMesData_every_2_hours()
 BEGIN
-##从MES_ORIGIN插入到MES_SYNC库
-REPLACE into mes_sync.mes_report_task SELECT * from mes_origin.mes_report_task;#报料任务表
-REPLACE into mes_sync.mes_crystal_order SELECT * from mes_origin.mes_crystal_order;#工单排产表
-REPLACE into mes_sync.mes_poi_formula SELECT * from mes_origin.mes_poi_formula;#配方表
-REPLACE into mes_sync.mes_feeding_task SELECT * from mes_origin.mes_feeding_task;#投料任务表
-REPLACE into mes_sync.mes_feeding_detail SELECT * from mes_origin.mes_feeding_detail;#投料明细表
-REPLACE into mes_sync.mes_transport_task SELECT * from mes_origin.mes_transport_task;#运输任务表
-REPLACE into mes_sync.mes_furnace_task SELECT * from mes_origin.mes_furnace_task;#投炉任务表
-REPLACE into mes_sync.mes_furnace_detail SELECT * from mes_origin.mes_furnace_detail;#投炉明细表
-REPLACE into mes_sync.mes_stick_task SELECT * from mes_origin.mes_stick_task;#取棒任务表
-REPLACE into mes_sync.mes_production SELECT * from mes_origin.mes_production;#毛棒表
-REPLACE into mes_sync.mes_round_bar SELECT * from mes_origin.mes_round_bar;#圆棒表
-REPLACE into mes_sync.mes_round_bar_status SELECT * from mes_origin.mes_round_bar_status;#圆棒状态表
-REPLACE into mes_sync.mes_roll_rub_quality_task SELECT * from mes_origin.mes_roll_rub_quality_task;#圆棒质检任务表
-REPLACE into mes_sync.mes_square SELECT * from mes_origin.mes_square;#方棒表
-REPLACE into mes_sync.mes_lifting_box_task SELECT * from mes_origin.mes_lifting_box_task;#
-REPLACE into mes_sync.mes_packing_task SELECT * from mes_origin.mes_packing_task;#打包任务表
-REPLACE into mes_sync.erp_job_mtl_confirm SELECT * from mes_origin.erp_job_mtl_confirm;
-REPLACE into mes_sync.erp_job_mtl_send SELECT * from mes_origin.erp_job_mtl_send;
-REPLACE into mes_sync.mes_draw_line_task SELECT * from mes_origin.mes_draw_line_task;
-REPLACE into mes_sync.mes_disposable_qc_task SELECT * from mes_origin.mes_disposable_qc_task;
-REPLACE into mes_sync.mes_truncation_task SELECT * from mes_origin.mes_truncation_task;
-REPLACE into mes_sync.mes_square_task SELECT * from mes_origin.mes_square_task;
-REPLACE into mes_sync.mes_roll_rub_task SELECT * from mes_origin.mes_roll_rub_task;
+    ##从MES_ORIGIN插入到MES_SYNC库
+    REPLACE into mes_sync.mes_report_task
+    SELECT *
+    from mes_origin.mes_report_task
+    where update_time >= date_sub(now(), interval 30 day);#报料任务表
+    REPLACE into mes_sync.mes_crystal_order
+    SELECT *
+    from mes_origin.mes_crystal_order
+    where update_time >= date_sub(now(), interval 30 day);#工单排产表
+    REPLACE into mes_sync.mes_poi_formula
+    SELECT *
+    from mes_origin.mes_poi_formula
+    where update_time >= date_sub(now(), interval 30 day);#配方表
+    REPLACE into mes_sync.mes_feeding_task
+    SELECT *
+    from mes_origin.mes_feeding_task
+    where update_time >= date_sub(now(), interval 30 day);#投料任务表
+    REPLACE into mes_sync.mes_feeding_detail
+    SELECT *
+    from mes_origin.mes_feeding_detail
+    where update_time >= date_sub(now(), interval 30 day);#投料明细表
+    REPLACE into mes_sync.mes_transport_task
+    SELECT *
+    from mes_origin.mes_transport_task
+    where update_time >= date_sub(now(), interval 30 day);#运输任务表
+    REPLACE into mes_sync.mes_furnace_task
+    SELECT *
+    from mes_origin.mes_furnace_task
+    where update_time >= date_sub(now(), interval 30 day);#投炉任务表
+    REPLACE into mes_sync.mes_furnace_detail
+    SELECT *
+    from mes_origin.mes_furnace_detail
+    where update_time >= date_sub(now(), interval 30 day);#投炉明细表
+    REPLACE into mes_sync.mes_stick_task
+    SELECT *
+    from mes_origin.mes_stick_task
+    where update_time >= date_sub(now(), interval 30 day);#取棒任务表
+    REPLACE into mes_sync.mes_production
+    SELECT *
+    from mes_origin.mes_production
+    where update_time >= date_sub(now(), interval 30 day);#毛棒表
+    REPLACE into mes_sync.mes_round_bar
+    SELECT *
+    from mes_origin.mes_round_bar
+    where update_time >= date_sub(now(), interval 30 day);#圆棒表
+    REPLACE into mes_sync.mes_round_bar_status
+    SELECT *
+    from mes_origin.mes_round_bar_status
+    where update_time >= date_sub(now(), interval 30 day);#圆棒状态表
+    REPLACE into mes_sync.mes_roll_rub_quality_task
+    SELECT *
+    from mes_origin.mes_roll_rub_quality_task
+    where update_time >= date_sub(now(), interval 30 day);#圆棒质检任务表
+    REPLACE into mes_sync.mes_square
+    SELECT *
+    from mes_origin.mes_square
+    where update_time >= date_sub(now(), interval 30 day);#方棒表
+    REPLACE into mes_sync.mes_lifting_box_task
+    SELECT *
+    from mes_origin.mes_lifting_box_task
+    where update_time >= date_sub(now(), interval 30 day);#
+    REPLACE into mes_sync.mes_packing_task
+    SELECT *
+    from mes_origin.mes_packing_task
+    where update_time >= date_sub(now(), interval 30 day);#打包任务表
+    REPLACE into mes_sync.erp_job_mtl_confirm
+    SELECT *
+    from mes_origin.erp_job_mtl_confirm
+    where update_time >= date_sub(now(), interval 30 day);
+    REPLACE into mes_sync.erp_job_mtl_send
+    SELECT *
+    from mes_origin.erp_job_mtl_send
+    where update_time >= date_sub(now(), interval 30 day);
+    REPLACE into mes_sync.mes_draw_line_task
+    SELECT *
+    from mes_origin.mes_draw_line_task
+    where update_time >= date_sub(now(), interval 30 day);
+    REPLACE into mes_sync.mes_disposable_qc_task
+    SELECT *
+    from mes_origin.mes_disposable_qc_task
+    where update_time >= date_sub(now(), interval 30 day);
+    REPLACE into mes_sync.mes_truncation_task
+    SELECT *
+    from mes_origin.mes_truncation_task
+    where update_time >= date_sub(now(), interval 30 day);
+    REPLACE into mes_sync.mes_square_task
+    SELECT *
+    from mes_origin.mes_square_task
+    where update_time >= date_sub(now(), interval 30 day);
+    REPLACE into mes_sync.mes_roll_rub_task
+    SELECT *
+    from mes_origin.mes_roll_rub_task
+    where update_time >= date_sub(now(), interval 30 day);
 
-set global sql_mode = 'STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_ENGINE_SUBSTITUTION';
+    set global sql_mode ='STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_ENGINE_SUBSTITUTION';
 
 END;