From 443339e98893164231eb8af1857f7b9e150002fa Mon Sep 17 00:00:00 2001
From: Jay <csj123456>
Date: 星期二, 29 四月 2025 16:42:18 +0800
Subject: [PATCH] 新增修改预测模型配置接口

---
 iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/mcs/pre/service/impl/MmPredictModelServiceImpl.java |   30 ++++++++++++++++++++++--------
 1 files changed, 22 insertions(+), 8 deletions(-)

diff --git a/iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/mcs/pre/service/impl/MmPredictModelServiceImpl.java b/iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/mcs/pre/service/impl/MmPredictModelServiceImpl.java
index 892bae3..5aa03cf 100644
--- a/iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/mcs/pre/service/impl/MmPredictModelServiceImpl.java
+++ b/iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/mcs/pre/service/impl/MmPredictModelServiceImpl.java
@@ -2,17 +2,15 @@
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.iailab.framework.common.service.impl.BaseServiceImpl;
-import com.iailab.module.model.mcs.pre.dao.MmPredictMergeItemDao;
 import com.iailab.module.model.mcs.pre.dao.MmPredictModelDao;
 import com.iailab.module.model.mcs.pre.entity.MmPredictModelEntity;
 import com.iailab.module.model.mcs.pre.service.MmPredictModelService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.util.CollectionUtils;
+import org.springframework.util.ObjectUtils;
 
 import java.math.BigDecimal;
-import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.UUID;
@@ -29,6 +27,8 @@
     private MmPredictModelDao mmPredictModelDao;
 
     private static Map<String, MmPredictModelEntity> modelEntityMap = new ConcurrentHashMap<>();
+
+    private static Map<String, MmPredictModelEntity> activeModelMap = new ConcurrentHashMap<>();
 
     @Override
     public void savePredictModel(MmPredictModelEntity predictModel) {
@@ -57,6 +57,12 @@
     @Override
     public void clearCache() {
         modelEntityMap.clear();
+        activeModelMap.clear();
+    }
+
+    @Override
+    public MmPredictModelEntity getByModelCode(String modelCode) {
+        return mmPredictModelDao.selectOne("modelno", modelCode);
     }
 
     @Override
@@ -67,11 +73,11 @@
     @Override
     public BigDecimal getSampleLength(String id) {
         BigDecimal result = BigDecimal.ZERO;
-        List<MmPredictModelEntity> list = mmPredictModelDao.getSampleLength(id);
-        if (CollectionUtils.isEmpty(list)) {
+        MmPredictModelEntity entity = mmPredictModelDao.getSampleLength(id);
+        if (ObjectUtils.isEmpty(entity)) {
             return result;
         }
-        result = list.get(0).getPredictsamplength();
+        result = entity.getPredictsamplength();
 
         return result;
     }
@@ -99,7 +105,15 @@
     }
 
     @Override
-    public List<MmPredictModelEntity> getActiveModelByItemId(String itemId) {
-        return mmPredictModelDao.getActiveModelByItemId(itemId);
+    public MmPredictModelEntity getActiveModelByItemId(String itemId) {
+        if (activeModelMap.containsKey(itemId)) {
+            return activeModelMap.get(itemId);
+        }
+        List<MmPredictModelEntity> list = mmPredictModelDao.getActiveModelByItemId(itemId);
+        if (CollectionUtils.isEmpty(list)) {
+            return null;
+        }
+        activeModelMap.put(itemId, list.get(0));
+        return activeModelMap.get(itemId);
     }
 }

--
Gitblit v1.9.3