清洗修改

dataCenter-manager/src/main/java/com/mortals/xhx/modules/implementlist/service/RybMatterListService.java

@@ -2,8 +2,10 @@ package com.mortals.xhx.modules.implementlist.service;
 
 import com.mortals.xhx.modules.implementlist.model.RybMatterListEntry;
 
+import java.util.Map;
+
 
 public interface RybMatterListService {
 
-    RybMatterListEntry getThImplement(String event_code);
+    RybMatterListEntry getThImplement(Map<String, RybMatterListEntry> map, String event_code);
 }
\ No newline at end of file

dataCenter-manager/src/main/java/com/mortals/xhx/modules/implementlist/service/impl/RybMatterListServiceImpl.java

@@ -10,6 +10,8 @@ import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
 import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
 
 @Service
 @RequiredArgsConstructor(onConstructor = @__(@Autowired))
@@ -18,12 +20,9 @@ public class RybMatterListServiceImpl implements RybMatterListService {
     @Resource
     private RybMatterDao rybMatterDao;
 
-    private final Cache<String, Object> caffeineCache;
-
     @Override
-    public RybMatterListEntry getThImplement(String event_code) {
-        caffeineCache.getIfPresent(event_code);
-        RybMatterListEntry thImplementList = (RybMatterListEntry) caffeineCache.asMap().get(event_code);
+    public RybMatterListEntry getThImplement(Map<String, RybMatterListEntry> map, String event_code) {
+        RybMatterListEntry thImplementList = map.get(event_code);
         if (thImplementList != null) {
             return thImplementList;
         }
@@ -32,7 +31,7 @@ public class RybMatterListServiceImpl implements RybMatterListService {
         if (rybMatterListEntries.size() > 0) {
             for (RybMatterListEntry entity : rybMatterListEntries) {
                 thImplementList=entity;
-                caffeineCache.put(event_code, entity);
+                map.put(event_code, entity);
             }
         }
         return thImplementList;

dataCenter-manager/src/main/java/com/mortals/xhx/modules/supplement/task/SupplementTaskImpl.java

@@ -34,6 +34,8 @@ import java.text.SimpleDateFormat;
 import java.util.ArrayList;
 import java.util.Date;
 import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
 import java.util.stream.Collectors;
 
 /**
@@ -63,6 +65,8 @@ public class SupplementTaskImpl implements ITaskExcuteService {
     @Autowired
     private ArameterService arameterService;
 
+    private final Map<String, RybMatterListEntry> map = new ConcurrentHashMap<>();
+
     @Override
     public void excuteTask(ITask task) throws AppException {
         //1.查询上月的表是否存在未清洗的数据 //蓉易办
@@ -91,7 +95,7 @@ public class SupplementTaskImpl implements ITaskExcuteService {
         if (!supplementEntities.isEmpty()) {
             List<SupplementEntity> collect = supplementEntities.parallelStream().map(e -> {
                 //TODO：查询实施清单信息，通过事项编码查询有问题（但因数据库存储的事项数据是条件过滤后的，故暂时不改动查询），后期改动
-                RybMatterListEntry thImplement = rybMatterListService.getThImplement(e.getImplCode());
+                RybMatterListEntry thImplement = rybMatterListService.getThImplement(map, e.getImplCode());
                 try {
                     InformationEntity informationQuery = new InformationEntity();
                     //组装第一次业务数据（清洗后的）