From d33644c57204637608e1f8e1416d6dc21d3e8afb Mon Sep 17 00:00:00 2001 From: xiaochou164 Date: Fri, 18 Aug 2023 08:53:46 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=B3=A8=E9=87=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../存储过程/SyncMesData_every_12_hours.sql | 8 ++--- .../存储过程/SyncMesData_every_2_hours.sql | 34 +++++++++---------- .../存储过程/UpdateAllfeedingdetail.sql | 1 + .../存储过程/UpdateEqpOnStoveStatusLog.sql | 9 +++-- .../存储过程/UpdateMesMoDailyYield.sql | 1 + .../存储过程&定时任务/存储过程/UpdateMostatus.sql | 2 ++ 6 files changed, 32 insertions(+), 23 deletions(-) diff --git a/数据库迁移sql/存储过程&定时任务/存储过程/SyncMesData_every_12_hours.sql b/数据库迁移sql/存储过程&定时任务/存储过程/SyncMesData_every_12_hours.sql index 6974d7f..b503145 100644 --- a/数据库迁移sql/存储过程&定时任务/存储过程/SyncMesData_every_12_hours.sql +++ b/数据库迁移sql/存储过程&定时任务/存储过程/SyncMesData_every_12_hours.sql @@ -38,7 +38,7 @@ BEGIN #REPLACE into mes_sync.mes_multi_cut SELECT * from mes_origin.mes_multi_cut; #REPLACE into mes_sync.mes_seed_crystal_machine_task SELECT * from mes_origin.mes_seed_crystal_machine_task; #REPLACE into mes_sync.mes_seed_crystal SELECT * from mes_origin.mes_seed_crystal; -REPLACE into mes_sync.mes_recycle_material_storage SELECT * from mes_origin.mes_recycle_material_storage; +REPLACE into mes_sync.mes_recycle_material_storage SELECT * from mes_origin.mes_recycle_material_storage;#更新循环料起托入库表 #REPLACE into mes_sync.mes_split_storage SELECT * from mes_origin.mes_split_storage; #REPLACE into mes_sync.mes_pre_clean SELECT * from mes_origin.mes_pre_clean; #REPLACE into mes_sync.mes_washable_silicon_qc_task SELECT * from mes_origin.mes_washable_silicon_qc_task; @@ -61,8 +61,8 @@ REPLACE into mes_sync.mes_recycle_material_storage SELECT * from mes_origin.mes_ #REPLACE into mes_sync.raipiot_log_error SELECT * from mes_origin.raipiot_log_error; #REPLACE into mes_sync.mes_electrical_performance_task_log SELECT * from mes_origin.mes_electrical_performance_task_log; #REPLACE into mes_sync.mes_work_order SELECT * from mes_origin.mes_work_order; -REPLACE into mes_sync.yz_mes_spec SELECT * from mes_origin.yz_mes_spec; -REPLACE into mes_sync.yz_mes_spec_value SELECT * from mes_origin.yz_mes_spec_value; +REPLACE into mes_sync.yz_mes_spec SELECT * from mes_origin.yz_mes_spec;#规格表 +REPLACE into mes_sync.yz_mes_spec_value SELECT * from mes_origin.yz_mes_spec_value;#规格属性表 #REPLACE into mes_sync.raipiot_log_api SELECT * from mes_origin.raipiot_log_api; #REPLACE into mes_sync.mes_work_order_job_detail SELECT * from mes_origin.mes_work_order_job_detail; #REPLACE into mes_sync.mes_mother_alloy_bind SELECT * from mes_origin.mes_mother_alloy_bind; @@ -74,6 +74,6 @@ REPLACE into mes_sync.yz_mes_spec_value SELECT * from mes_origin.yz_mes_spec_val #REPLACE into mes_sync.sys_dict_type SELECT * from mes_origin.sys_dict_type; #REPLACE into mes_sync.mes_dict SELECT * from mes_origin.mes_dict; #REPLACE into mes_sync.sys_dict_data SELECT * from mes_origin.sys_dict_data; -update reportdata.prod set rodtosquare = round/square; +update reportdata.prod set rodtosquare = round/square; ##更新圆方比 END; diff --git a/数据库迁移sql/存储过程&定时任务/存储过程/SyncMesData_every_2_hours.sql b/数据库迁移sql/存储过程&定时任务/存储过程/SyncMesData_every_2_hours.sql index 259509f..f04855f 100644 --- a/数据库迁移sql/存储过程&定时任务/存储过程/SyncMesData_every_2_hours.sql +++ b/数据库迁移sql/存储过程&定时任务/存储过程/SyncMesData_every_2_hours.sql @@ -7,23 +7,23 @@ drop procedure if exists SyncMesData_every_2_hours; create definer = root@`%` procedure SyncMesData_every_2_hours() BEGIN - -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; +##从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; diff --git a/数据库迁移sql/存储过程&定时任务/存储过程/UpdateAllfeedingdetail.sql b/数据库迁移sql/存储过程&定时任务/存储过程/UpdateAllfeedingdetail.sql index e47aeeb..0fe798a 100644 --- a/数据库迁移sql/存储过程&定时任务/存储过程/UpdateAllfeedingdetail.sql +++ b/数据库迁移sql/存储过程&定时任务/存储过程/UpdateAllfeedingdetail.sql @@ -7,6 +7,7 @@ drop procedure if exists UpdateAllfeedingdetail; create definer = admin@`%` procedure UpdateAllfeedingdetail() BEGIN +#配料明细没有主键,每次开始前先删除原有的 DELETE from reportdata.allfeedingdetail; replace into reportdata.allfeedingdetail(`month`,mfgdate,mesmoname,eqpid,moprodname,moproddesc, subprod,rx,stovetype,stovetypedesc,stovetime,prodname,proddesc,material_type,factory,serial_no,weight, diff --git a/数据库迁移sql/存储过程&定时任务/存储过程/UpdateEqpOnStoveStatusLog.sql b/数据库迁移sql/存储过程&定时任务/存储过程/UpdateEqpOnStoveStatusLog.sql index 2d4fb91..1e4f133 100644 --- a/数据库迁移sql/存储过程&定时任务/存储过程/UpdateEqpOnStoveStatusLog.sql +++ b/数据库迁移sql/存储过程&定时任务/存储过程/UpdateEqpOnStoveStatusLog.sql @@ -8,6 +8,7 @@ create definer = admin@`%` procedure UpdateEqpOnStoveStatusLog() comment '更新开炉记录日志表' BEGIN DROP TABLE IF EXISTS `eqponstovestatustmp`; +#创建一张临时表用于处理数据 create table eqponstovestatustmp ( area varchar(50), @@ -49,6 +50,7 @@ left join group by mesmoname) eql on eqs.mesmoname = eql.mesmoname set eqs.firststovetime = eql.stovetime; +##更新最近的工序动作的时间 update eqponstovestatustmp eqs left join (select es.eqpid, @@ -133,12 +135,13 @@ set eqpstatus = '拉棒时间超3天' where 1 = 1 and laststovetime is not null and laststovetime <= date_format(date_sub(now(), interval 3 day), '%Y-%m-%d'); - +##更新热场尺寸,产品规格 update eqponstovestatustmp esp inner join mes_sync.mes_crystal_order mco on (esp.mesmoname = mco.order_no) inner join reportdata.mostatus mo on (esp.mesmoname = mo.MESmoname) set esp.crusize = mco.thermal_field,esp.subprod = mo.subprod; +##将处理好的结果插入炉台开炉投炉日志表 insert into eqponstovestatus( area, area1, @@ -159,9 +162,11 @@ insert into eqponstovestatus( select * from eqponstovestatustmp; - +##更新保存时间 update eqponstovestatus set savedate = now() where savedate is null; +##更新归档日期 update eqponstovestatus set mfgdate = date_format(now()-8.5/24,'%Y-%m-%d') where mfgdate is null; +##删除临时表 drop table eqponstovestatustmp; END; diff --git a/数据库迁移sql/存储过程&定时任务/存储过程/UpdateMesMoDailyYield.sql b/数据库迁移sql/存储过程&定时任务/存储过程/UpdateMesMoDailyYield.sql index 35f64f3..eabd31a 100644 --- a/数据库迁移sql/存储过程&定时任务/存储过程/UpdateMesMoDailyYield.sql +++ b/数据库迁移sql/存储过程&定时任务/存储过程/UpdateMesMoDailyYield.sql @@ -175,6 +175,7 @@ update mesmodailyyieldtemp mmd set mmd.totalqcweight = mmd.totalqclength / mmd.rod where totalqcweight is null; +##从临时表查出来更新到完结工单产量表 replace into reportdata.mesmodailyyield select * from mesmodailyyieldtemp diff --git a/数据库迁移sql/存储过程&定时任务/存储过程/UpdateMostatus.sql b/数据库迁移sql/存储过程&定时任务/存储过程/UpdateMostatus.sql index 44e28ec..10c7061 100644 --- a/数据库迁移sql/存储过程&定时任务/存储过程/UpdateMostatus.sql +++ b/数据库迁移sql/存储过程&定时任务/存储过程/UpdateMostatus.sql @@ -9,6 +9,7 @@ create definer = admin@`%` procedure UpdateMostatus() BEGIN +##更新工单状态清单 REPLACE into reportdata.Mostatus(area1,MESmoname,ERPmoname,eqpid,prodname,proddesc,crusize,stovetime,feeding_task_id,crucible,subprod,mostatus,mostatusdesc,finish_time,runtime) select left(ft.stove_no,1) area1,ft.order_no MESmoname,co.job_code ERPmoname,ft.stove_no eqpid,ft.product_no prodname,ft.product_name proddesc, co.thermal_field crusize,ft.update_time stovetime,ft.feeding_task_id,fd.factory crucible, case when LOCATE('自产',product_name) >0 then mid(product_name,LOCATE('自产',product_name)+3,6) @@ -71,6 +72,7 @@ set mo.finish_time = f.max_time, mo.mostatusdesc = '完结', mo.runtime = datediff(f.max_time, mo.stovetime); +##更新加次 update reportdata.mostatus mo inner join (