From 9fd774b1d10c38d3016fcec588b0662428c0ef36 Mon Sep 17 00:00:00 2001
From: zhanghl <253316343@qq.com>
Date: 星期五, 25 四月 2025 16:16:11 +0800
Subject: [PATCH] 定时任务-增加同步气柜数据
---
aps-modules/aps-job/src/main/java/com/aps/job/service/IApsWorkOrderJobService.java | 3 +
aps-modules/aps-job/src/main/resources/mapper/job/ApsWorkOrderJobMapper.xml | 36 ++++++++++++++++-
aps-modules/aps-job/src/main/java/com/aps/job/mapper/ApsWorkOrderJobMapper.java | 4 ++
aps-modules/aps-job/src/main/java/com/aps/job/task/RyTask.java | 25 ++++++++++++
aps-modules/aps-job/src/main/resources/mapper/job/ApsWorkOrderProcessMapper.xml | 2
aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderJobServiceImpl.java | 11 +++++
6 files changed, 76 insertions(+), 5 deletions(-)
diff --git a/aps-modules/aps-job/src/main/java/com/aps/job/mapper/ApsWorkOrderJobMapper.java b/aps-modules/aps-job/src/main/java/com/aps/job/mapper/ApsWorkOrderJobMapper.java
index b8928d1..4e52e2b 100644
--- a/aps-modules/aps-job/src/main/java/com/aps/job/mapper/ApsWorkOrderJobMapper.java
+++ b/aps-modules/aps-job/src/main/java/com/aps/job/mapper/ApsWorkOrderJobMapper.java
@@ -89,4 +89,8 @@
* 鎵归噺鎻掑叆閽ｉ噾璁″垝宸ュ崟
* */
int batchInsertPlatePlan();
+
+
+ int deleteAllGasPiping();
+ int batchInsertGasPiping();
}
diff --git a/aps-modules/aps-job/src/main/java/com/aps/job/service/IApsWorkOrderJobService.java b/aps-modules/aps-job/src/main/java/com/aps/job/service/IApsWorkOrderJobService.java
index 2189b5e..85dc42b 100644
--- a/aps-modules/aps-job/src/main/java/com/aps/job/service/IApsWorkOrderJobService.java
+++ b/aps-modules/aps-job/src/main/java/com/aps/job/service/IApsWorkOrderJobService.java
@@ -78,4 +78,7 @@
@Transactional
void syncPlateOrderData();
+
+ @Transactional
+ void syncGasPipingData();
}
diff --git a/aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderJobServiceImpl.java b/aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderJobServiceImpl.java
index 6778319..9881784 100644
--- a/aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderJobServiceImpl.java
+++ b/aps-modules/aps-job/src/main/java/com/aps/job/service/impl/ApsWorkOrderJobServiceImpl.java
@@ -343,4 +343,15 @@
apsWorkOrderJobMapper.batchInsertPlatePlan();
}
+
+ /**
+ * 鍚屾閽ｉ噾宸ュ崟淇℃伅
+ * */
+ @Transactional
+ @Override
+ public void syncGasPipingData() {
+ apsWorkOrderJobMapper.deleteAllGasPiping();
+ apsWorkOrderJobMapper.batchInsertGasPiping();
+ }
+
}
diff --git a/aps-modules/aps-job/src/main/java/com/aps/job/task/RyTask.java b/aps-modules/aps-job/src/main/java/com/aps/job/task/RyTask.java
index 66556b3..eefc16c 100644
--- a/aps-modules/aps-job/src/main/java/com/aps/job/task/RyTask.java
+++ b/aps-modules/aps-job/src/main/java/com/aps/job/task/RyTask.java
@@ -67,7 +67,13 @@
iApsWorkOrderJobService.syncPlateOrderData();
}
-
+ /**
+ * 姣忔棩鍚屾姘旀煖绠¤矾鏁版嵁
+ * */
+ public void syncGasPipingData ()
+ {
+ iApsWorkOrderJobService.syncGasPipingData();
+ }
/**
* 姣忔棩鍚屾鎵�鏈夊伐鍗曟暟鎹�
* */
@@ -91,7 +97,24 @@
currentPage++;
}
}
+ /**
+ * 姣忔棩鍚屾鎵�鏈夊伐鍗曟暟鎹�
+ * */
+ public void syncAllWorkOrder()
+ {
+ boolean continueFlag = true;
+ Integer currentPage = 1;
+ ApsWorkOrderJobParam param=new ApsWorkOrderJobParam();
+ param.setPageIndex(currentPage);
+ param.setDocState(Arrays.asList(0,1,2,4));
+ param.setPageSize(1000);
+ while (continueFlag){
+ param.setPageIndex(currentPage);
+ continueFlag= iApsWorkOrderJobService.batchSaveByPager(param);
+ currentPage++;
+ }
+ }
/**
* 灏嗗伐鍗曞伐搴忔暟鎹悓姝ュ埌涓氬姟琛ㄤ腑
*/
diff --git a/aps-modules/aps-job/src/main/resources/mapper/job/ApsWorkOrderJobMapper.xml b/aps-modules/aps-job/src/main/resources/mapper/job/ApsWorkOrderJobMapper.xml
index eb2a7b7..01a811e 100644
--- a/aps-modules/aps-job/src/main/resources/mapper/job/ApsWorkOrderJobMapper.xml
+++ b/aps-modules/aps-job/src/main/resources/mapper/job/ApsWorkOrderJobMapper.xml
@@ -242,7 +242,7 @@
update_time,
org_code,
process_status,
- std_op,
+ std_op
</trim>
values
<foreach collection="list" item="job" separator=",">
@@ -278,7 +278,7 @@
#{job.updateTime},
#{job.orgCode},
#{job.processStatus},
- #{job.stdOp},
+ #{job.stdOp}
)
</foreach>
</insert>
@@ -351,10 +351,40 @@
op_num,work_center,dept,
start_date,complete_date,next_dept,
is_hold_release,is_out_source,org_code,
- order_id,now(),'0',org_code,doc_status,,std_op
+ order_id,now(),'0',org_code,doc_status,std_op
from aps_work_order_job
where ( doc_status in (0,1,2,4)
and (mainitem_code like 'M03%' or mainitem_code like 'M04%'or mainitem_code like 'A75%')
);
</insert>
+
+ <delete id="deleteAllGasPiping" >
+ delete from aps_gas_piping_plan where del_flag in ('0','1')
+ </delete>
+ <insert id="batchInsertGasPiping">
+ insert into aps_gas_piping_plan
+ (
+ document_number,main_part_number,main_part_drawing_number,
+ customer,business_type,requirement_type,
+ document_status,item_number,drawing_no,
+ version_number,production_quantity,good_products_quantity,
+ process_number,work_center,department,
+ plan_start_day,plan_end_day,next_process_deparment,
+ is_suspended,is_outsourcing,account,
+ id,create_time,del_flag,plant,order_status,std_op,plan_type
+ )
+ select
+ doc_no,mainitem_code,mainitem_figure,
+ customer_name,business_type,demand_type,
+ doc_status,item_code,item_figure,
+ item_figure_version,pruduct_qty,work_qty,
+ op_num,work_center,dept,
+ start_date,complete_date,next_dept,
+ is_hold_release,is_out_source,org_code,
+ order_id,now(),'0',org_code,doc_status,std_op,
+ case when substr(mainitem_code,3)='A65' then 'gas' else 'piping' end as plan_type
+ from aps_work_order_job
+ where ( doc_status in (0,1,2,4)
+ and (mainitem_code like 'A65%' or mainitem_code like 'W%'));
+ </insert>
</mapper>
\ No newline at end of file
diff --git a/aps-modules/aps-job/src/main/resources/mapper/job/ApsWorkOrderProcessMapper.xml b/aps-modules/aps-job/src/main/resources/mapper/job/ApsWorkOrderProcessMapper.xml
index eba3238..9565f61 100644
--- a/aps-modules/aps-job/src/main/resources/mapper/job/ApsWorkOrderProcessMapper.xml
+++ b/aps-modules/aps-job/src/main/resources/mapper/job/ApsWorkOrderProcessMapper.xml
@@ -180,7 +180,7 @@
#{item.scrapQty},
#{item.opStatus},
#{item.org},
- #{item.orgCode}
+ #{item.orgCode},
#{item.workCenter}
)
</foreach>
--
Gitblit v1.9.3