From a440ec3bfaa1363f5841100b8948d852971a2eb1 Mon Sep 17 00:00:00 2001
From: 潘志宝 <979469083@qq.com>
Date: 星期二, 10 十二月 2024 13:19:58 +0800
Subject: [PATCH] MmPredictAlarmConfigService

---
 iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/mcs/pre/service/impl/MmPredictModelServiceImpl.java |   64 +++++++++++++++++++++++++------
 1 files changed, 51 insertions(+), 13 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 eb61a05..4738817 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
@@ -1,49 +1,78 @@
 package com.iailab.module.model.mcs.pre.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
-import com.iailab.framework.common.service.impl.BaseServiceImpl;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 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.List;
 import java.util.Map;
 import java.util.UUID;
+import java.util.concurrent.ConcurrentHashMap;
 
 /**
  * @author PanZhibao
  * @date 2021年04月27日 11:30
  */
-@Service("mmPredictModelService")
-public class MmPredictModelServiceImpl extends BaseServiceImpl<MmPredictModelDao, MmPredictModelEntity> implements MmPredictModelService {
+@Service
+public class MmPredictModelServiceImpl extends ServiceImpl<MmPredictModelDao, MmPredictModelEntity> implements MmPredictModelService {
+
+    @Autowired
+    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) {
         predictModel.setId(UUID.randomUUID().toString());
-        baseDao.insert(predictModel);
+        mmPredictModelDao.insert(predictModel);
+        clearCache();
     }
 
     @Override
     public void update(MmPredictModelEntity predictModel) {
         this.updateById(predictModel);
+        clearCache();
+    }
+
+    @Override
+    public MmPredictModelEntity getInfoFromCatch(String id) {
+        if (!modelEntityMap.containsKey(id)) {
+            MmPredictModelEntity modelEntity = getInfo(id);
+            if (modelEntity != null) {
+                modelEntityMap.put(id, modelEntity);
+            }
+        }
+        return modelEntityMap.get(id);
+    }
+
+    @Override
+    public void clearCache() {
+        modelEntityMap.clear();
+        activeModelMap.clear();
     }
 
     @Override
     public MmPredictModelEntity getInfo(String id) {
-        return baseDao.selectById(id);
+        return mmPredictModelDao.selectById(id);
     }
 
     @Override
     public BigDecimal getSampleLength(String id) {
         BigDecimal result = BigDecimal.ZERO;
-        List<MmPredictModelEntity> list = baseDao.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;
     }
@@ -51,13 +80,14 @@
     public void deleteBatch(String[] itemIds) {
         QueryWrapper<MmPredictModelEntity> queryWrapper = new QueryWrapper<>();
         queryWrapper.in("itemid", itemIds);
-        baseDao.delete(queryWrapper);
+        mmPredictModelDao.delete(queryWrapper);
+        clearCache();
     }
 
     public MmPredictModelEntity getByItemid(String itemid) {
         QueryWrapper<MmPredictModelEntity> queryWrapper = new QueryWrapper<>();
         queryWrapper.eq("itemid", itemid);
-        List<MmPredictModelEntity> list = baseDao.selectList(queryWrapper);
+        List<MmPredictModelEntity> list = mmPredictModelDao.selectList(queryWrapper);
         if (CollectionUtils.isEmpty(list)) {
             return new MmPredictModelEntity();
         }
@@ -66,11 +96,19 @@
 
     @Override
     public List<MmPredictModelEntity> getNoSettingmapPredictModel(Map<String, Object> params) {
-        return baseDao.getNoSettingmapPredictModel(params);
+        return mmPredictModelDao.getNoSettingmapPredictModel(params);
     }
 
     @Override
-    public List<MmPredictModelEntity> getActiveModelByItemId(String itemId) {
-        return baseDao.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