From b8fed13b2db09ba79b21bb792ce5161bac62e29b Mon Sep 17 00:00:00 2001
From: sfd <sun.sunshine@163.com>
Date: 星期五, 23 五月 2025 15:15:35 +0800
Subject: [PATCH] Merge branch 'dev' of http://192.168.50.149:8085/r/aps-backend into dev
---
aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsPlate/ApsPlateProcessShopStatServiceImpl.java | 82 +++++++++++++++++++++--------------------
1 files changed, 42 insertions(+), 40 deletions(-)
diff --git a/aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsPlate/ApsPlateProcessShopStatServiceImpl.java b/aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsPlate/ApsPlateProcessShopStatServiceImpl.java
index 2436835..49350cd 100644
--- a/aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsPlate/ApsPlateProcessShopStatServiceImpl.java
+++ b/aps-modules/aps-core/src/main/java/com/aps/core/service/impl/ApsPlate/ApsPlateProcessShopStatServiceImpl.java
@@ -5,6 +5,8 @@
import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.Collectors;
+import cn.hutool.core.collection.ListUtil;
+import cn.hutool.core.util.IdUtil;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson2.JSON;
import com.alibaba.nacos.common.utils.JacksonUtils;
@@ -136,38 +138,34 @@
/**
* 淇濆瓨閽ｉ噾杞﹂棿缁熻
*/
- @Transactional
+ @Transactional( rollbackFor =Exception.class)
@Override
public void saveShopStat() {
- try {
- apsPlateProcessStatService.savePlateProcessStat();
+ // 瀹氫箟璇ュ姛鑳戒娇鐢ㄦ暟鎹簮涓哄崡閫氱殑宸ュ巶
+ final String plant = "FORTUNA";
+ final String major="BJ";
+ // 鏌ヨ鐩稿叧鏁版嵁
+ ApsPlatePlan platePlan = new ApsPlatePlan();
+ platePlan.setPlant(plant);
+ List<ApsPlatePlan> planList = apsPlatePlanMapper.selectApsPlatePlanList(platePlan);
+
+ ApsShop apsShop = new ApsShop();
+ apsShop.setPlantCode(plant);
+ List<ApsShop> shopList = shopMapper.selectApsShopList(apsShop);
+
+ ApsStandardProcess process = new ApsStandardProcess();
+ process.setPlant(plant);
+ process.setMajor(major);
+
+ List<ApsStandardProcess> shopProcesses = standardProcessMapper.selectApsStandardProcessList(process);
+
+ if (!planList.isEmpty() && !shopList.isEmpty() && !shopProcesses.isEmpty()) {
// 寮�濮嬩箣鍓嶅厛鍒犻櫎鎵�鏈夊巻鍙叉暟鎹�
+ apsPlateProcessStatMapper.deleteAll();
apsPlateProcessShopStatMapper.deleteAll();
-
- // 瀹氫箟璇ュ姛鑳戒娇鐢ㄦ暟鎹簮涓哄崡閫氱殑宸ュ巶
- final String plant = "FORTUNA";
- final String major="閽ｉ噾";
- // 鏌ヨ鐩稿叧鏁版嵁
- ApsPlatePlan platePlan = new ApsPlatePlan();
- platePlan.setPlant(plant);
- List<ApsPlatePlan> planList = apsPlatePlanMapper.selectApsPlatePlanList(platePlan);
-
- List<ApsPlateProcessStat> statList = apsPlateProcessStatMapper.selectApsPlateProcessStatList(new ApsPlateProcessStat());
-
- ApsShop apsShop = new ApsShop();
- apsShop.setPlantCode(plant);
- List<ApsShop> shopList = shopMapper.selectApsShopList(apsShop);
-
- ApsStandardProcess process = new ApsStandardProcess();
- process.setPlant(plant);
- process.setMajor(major);
- List<ApsStandardProcess> shopProcesses = standardProcessMapper.selectApsStandardProcessList(process);
- if (planList.isEmpty() || shopList.isEmpty() || shopProcesses.isEmpty()) {
- log.warn("璁″垝鍒楄〃銆佽溅闂村垪琛ㄦ垨宸ュ簭鍒楄〃涓虹┖锛屾棤娉曠敓鎴愮粺璁′俊鎭�");
- return;
- }
- // 鏋勫缓杞﹂棿鍚嶇О鍒板伐搴忓悕绉扮殑鏄犲皠
- Map<String, List<String>> shopToProcessNames = shopProcesses.stream()
+ List<ApsPlateProcessStat> statList =apsPlateProcessStatService.computePlateProcessStat();
+ // 鏋勫缓杞﹂棿鍚嶇О鍒板伐搴忓悕绉扮殑鏄犲皠
+ Map<String, List<String>> shopToProcessNames = shopProcesses.stream().filter(x -> null!=x.getWorkShop())
.collect(Collectors.groupingBy(ApsStandardProcess::getWorkShop,
Collectors.mapping(ApsStandardProcess::getProcessName, Collectors.toList())
));
@@ -179,18 +177,22 @@
statsToInsert.add(stat);
}
}
- // 鎵归噺鎻掑叆浠ユ彁楂樻�ц兘
- if (!statsToInsert.isEmpty()) {
- int batchSize = 1000;
- for (int i = 0; i < statsToInsert.size(); i += batchSize) {
- int end = Math.min(i + batchSize, statsToInsert.size());
- List<ApsPlateProcessShopStat> batch = statsToInsert.subList(i, end);
- apsPlateProcessShopStatMapper.batchInsert(batch);
- }
+ List<List<ApsPlateProcessStat>> processStatBatchList = ListUtil.split(statList, 1000);
+ processStatBatchList.forEach(batch -> apsPlateProcessStatMapper.batchInsertPlateStat(batch));
+
+
+ List<List<ApsPlateProcessShopStat>> shopStatBatchList = ListUtil.split(statsToInsert, 1000);
+ shopStatBatchList.forEach(batch -> apsPlateProcessShopStatMapper.batchInsert(batch));
+ }else {
+ if(shopProcesses.isEmpty()){
+ throw new RuntimeException("鏈壘鍒版爣鍑嗗伐搴忔暟鎹紒");
}
- } catch (Exception e) {
- log.error("淇濆瓨閽ｉ噾杞﹂棿缁熻鏃跺彂鐢熷紓甯�", e);
- throw new RuntimeException("淇濆瓨閽ｉ噾杞﹂棿缁熻澶辫触", e);
+ if(shopList.isEmpty()){
+ throw new RuntimeException("鏈壘鍒拌溅闂存暟鎹紒");
+ }
+ if(planList.isEmpty()){
+ throw new RuntimeException("鏈壘鍒板伐鍗曟暟鎹紒");
+ }
}
}
@@ -210,7 +212,6 @@
stat.setWorkCenter(plan.getWorkCenter());
stat.setProcessNumber(plan.getProcessNumber());
try {
-
List<String> processNames = shopToProcessNames.getOrDefault(shopName, Collections.emptyList());
if (!processNames.isEmpty()) {
@@ -253,6 +254,7 @@
}
} catch (Exception e) {
log.error("computer error:"+ JSONObject.toJSONString(stat));
+ throw new RuntimeException("璁＄畻杞﹂棿缁熻鏁版嵁寮傚父锛�");
}
return stat;
}
--
Gitblit v1.9.3