From ecd84b4672bede8e56e19bc645d80b3c73209ed1 Mon Sep 17 00:00:00 2001
From: Yueng <14617246+YuengMeYuuer@user.noreply.gitee.com>
Date: Thu, 10 Oct 2024 14:25:30 +0800
Subject: [PATCH] =?UTF-8?q?find()=E9=A2=84=E8=AD=A6=E7=BC=93=E5=AD=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cache/warn/VehicleCacheWarnService.java   | 27 +++++++++++++++++++
 ...ot.autoconfigure.AutoConfiguration.imports |  1 +
 .../service/impl/WarnStrategyServiceImpl.java | 19 ++++++++++++-
 3 files changed, 46 insertions(+), 1 deletion(-)
 create mode 100644 cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-cache/src/main/java/com/muyu/enterprise/cache/warn/VehicleCacheWarnService.java

diff --git a/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-cache/src/main/java/com/muyu/enterprise/cache/warn/VehicleCacheWarnService.java b/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-cache/src/main/java/com/muyu/enterprise/cache/warn/VehicleCacheWarnService.java
new file mode 100644
index 0000000..9af32af
--- /dev/null
+++ b/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-cache/src/main/java/com/muyu/enterprise/cache/warn/VehicleCacheWarnService.java
@@ -0,0 +1,27 @@
+package com.muyu.enterprise.cache.warn;
+
+import com.muyu.common.cache.CacheAbsBasic;
+import com.muyu.domain.WarnStrategy;
+import com.muyu.domain.resp.CarFenceResp;
+
+import java.util.List;
+
+/**
+ * 电子围栏缓存
+ * @Author：yang
+ * @Package：com.muyu.cache
+ * @Project：cloud-server-8
+ * @name：VehicleCacheService
+ * @Date：2024/9/30 11:50
+ */
+public class VehicleCacheWarnService extends CacheAbsBasic<String, List<WarnStrategy>> {
+    @Override
+    public String keyPre() {
+        return "WarnStrategy:info:";
+    }
+
+    @Override
+    public String decode(String key) {
+        return key.replace("vehicle:info:","");
+    }
+}
diff --git a/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-cache/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports b/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-cache/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
index bf4ac0d..8811818 100644
--- a/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-cache/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
+++ b/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-cache/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports
@@ -6,3 +6,4 @@ com.muyu.enterprise.cache.faultCode.VehicleCacheFaultCodeAddService
 com.muyu.enterprise.cache.fence.VehicleCacheFenceService
 com.muyu.enterprise.cache.fence.VehicleCacheFenceAddService
 com.muyu.enterprise.cache.fault.VehicleCacheFaultService
+com.muyu.enterprise.cache.warn.VehicleCacheWarnService
diff --git a/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/server/service/impl/WarnStrategyServiceImpl.java b/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/server/service/impl/WarnStrategyServiceImpl.java
index fca8086..8d028d5 100644
--- a/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/server/service/impl/WarnStrategyServiceImpl.java
+++ b/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-server/src/main/java/com/muyu/server/service/impl/WarnStrategyServiceImpl.java
@@ -3,11 +3,15 @@ package com.muyu.server.service.impl;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.muyu.common.core.utils.StringUtils;
+import com.muyu.domain.CarInformation;
 import com.muyu.domain.CarType;
 import com.muyu.domain.WarnStrategy;
 import com.muyu.domain.req.WarnStrategyReq;
+import com.muyu.enterprise.cache.warn.VehicleCacheWarnService;
 import com.muyu.server.mapper.WarnStrategyMapper;
+import com.muyu.server.service.CarInformationService;
 import com.muyu.server.service.WarnStrategyService;
+import lombok.AllArgsConstructor;
 import org.springframework.stereotype.Service;
 import org.springframework.util.Assert;
 
@@ -23,10 +27,14 @@ import java.util.List;
  * @Date：2024/9/20 下午7:29
  */
 @Service
+@AllArgsConstructor
 public class WarnStrategyServiceImpl
         extends ServiceImpl<WarnStrategyMapper, WarnStrategy>
         implements WarnStrategyService {
 
+    private final CarInformationService carInformationService;
+    private final VehicleCacheWarnService vehicleCacheWarnService;
+
     /**
      * 精确查询预警策略
      *
@@ -62,7 +70,16 @@ public class WarnStrategyServiceImpl
         if (StringUtils.isNotNull(warnStrategy.getMsgId())){
             queryWrapper.eq(WarnStrategy::getMsgId, warnStrategy.getMsgId());
         }
-        return this.list(queryWrapper);
+        List<WarnStrategy> list = this.list(queryWrapper);
+        list.forEach(warnStrategy1 -> {
+            List<CarInformation> list1 = carInformationService
+                    .list(new LambdaQueryWrapper<CarInformation>()
+                    .eq(CarInformation::getCarInformationType, warnStrategy1.getCarTypeId()));
+            list1.forEach(carInformation -> {
+                vehicleCacheWarnService.put(vehicleCacheWarnService.keyPre()+carInformation.getCarInformationVIN(),list);
+            });
+        });
+        return list;
     }
 
     /**