绩效考核项目时限设置存入redis

esua-epdc/epdc-commons/epdc-commons-tools/src/main/java/com/elink/esua/epdc/commons/tools/redis/RedisKeys.java

@@ -145,4 +145,11 @@ public class RedisKeys {
     public static String getEventsCategoryKey() {
         return rootPrefix.concat("options:category:events");
     }
+
+    /**
+     * 按项目分类设置项目响应/关闭时限
+     */
+    public static String getKpiItemTimeLimitKey(String categoryId) {
+        return rootPrefix.concat("config:kpi:itemtimelimit:").concat(categoryId);
+    }
 }

esua-epdc/epdc-module/epdc-events/epdc-events-client/src/main/java/com/elink/esua/epdc/constant/KpiItemConstant.java

@@ -0,0 +1,15 @@
+package com.elink.esua.epdc.constant;
+
+/**
+ * 绩效考核项目相关常量
+ *
+ * @author work@yujt.net.cn
+ * @date 2019/12/17 10:35
+ */
+public interface KpiItemConstant {
+
+    String RESPOND_ITEM_TIME_LIMIT = "validCloseTime";
+
+    String CLOSE_ITEM_TIME_LIMIT = "validRespondTime";
+    
+}

esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/redis/KpiTimeLimitItemRedis.java

@@ -17,10 +17,16 @@
 
 package com.elink.esua.epdc.redis;
 
+import com.elink.esua.epdc.commons.tools.redis.RedisKeys;
 import com.elink.esua.epdc.commons.tools.redis.RedisUtils;
+import com.elink.esua.epdc.constant.KpiItemConstant;
+import com.elink.esua.epdc.entity.KpiTimeLimitItemEntity;
+import com.google.common.collect.Maps;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
+import java.util.Map;
+
 /**
  * 项目响应时限
  *
@@ -29,19 +35,27 @@ import org.springframework.stereotype.Component;
  */
 @Component
 public class KpiTimeLimitItemRedis {
+
     @Autowired
     private RedisUtils redisUtils;
 
-    public void delete(Object[] ids) {
-
-    }
+    /**
+     * 将项目类别时限设置存入缓存
+     *
+     * @param timelimitItem
+     * @return void
+     * @author work@yujt.net.cn
+     * @date 2019/12/17 10:27
+     */
+    public void setTimelimitItem(KpiTimeLimitItemEntity timelimitItem) {
 
-    public void set(){
+        Map<String, Integer> map = Maps.newHashMap();
+        map.put(KpiItemConstant.CLOSE_ITEM_TIME_LIMIT, timelimitItem.getValidCloseTime());
+        map.put(KpiItemConstant.RESPOND_ITEM_TIME_LIMIT, timelimitItem.getValidRespondTime());
 
+        String key = RedisKeys.getKpiItemTimeLimitKey(String.valueOf(timelimitItem.getCategoryId()));
+        redisUtils.set(key, map);
     }
 
-    public String get(String id){
-        return null;
-    }
 
 }

esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/service/impl/KpiTimeLimitIssueServiceImpl.java

@@ -26,10 +26,8 @@ import com.elink.esua.epdc.commons.tools.constant.FieldConstant;
 import com.elink.esua.epdc.dao.KpiTimeLimitIssueDao;
 import com.elink.esua.epdc.dto.KpiTimeLimitIssueDTO;
 import com.elink.esua.epdc.entity.KpiTimeLimitIssueEntity;
-import com.elink.esua.epdc.redis.KpiTimeLimitIssueRedis;
 import com.elink.esua.epdc.service.KpiTimeLimitIssueService;
 import org.apache.commons.lang3.StringUtils;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -46,9 +44,6 @@ import java.util.Map;
 @Service
 public class KpiTimeLimitIssueServiceImpl extends BaseServiceImpl<KpiTimeLimitIssueDao, KpiTimeLimitIssueEntity> implements KpiTimeLimitIssueService {
 
-    @Autowired
-    private KpiTimeLimitIssueRedis kpiTimeLimitIssueRedis;
-
     @Override
     public PageData<KpiTimeLimitIssueDTO> page(Map<String, Object> params) {
         IPage<KpiTimeLimitIssueEntity> page = baseDao.selectPage(

esua-epdc/epdc-module/epdc-kpi/epdc-kpi-server/src/main/java/com/elink/esua/epdc/service/impl/KpiTimeLimitItemServiceImpl.java

@@ -43,7 +43,6 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
-import java.io.File;
 import java.util.Arrays;
 import java.util.List;
 import java.util.Map;
@@ -62,6 +61,9 @@ public class KpiTimeLimitItemServiceImpl extends BaseServiceImpl<KpiTimeLimitIte
     @Autowired
     private EventFeignClient eventFeignClient;
 
+    @Autowired
+    private KpiTimeLimitItemRedis kpiTimeLimitItemRedis;
+
     @Override
     public PageData<KpiTimeLimitItemDTO> page(Map<String, Object> params) {
         String categoryId = params.containsKey("categoryId") ? params.get("categoryId").toString() : null;
@@ -141,6 +143,8 @@ public class KpiTimeLimitItemServiceImpl extends BaseServiceImpl<KpiTimeLimitIte
             timeLimit.setParentCategoryIds(categoryInfo.getPids());
             timeLimit.setParentCategoryNames(categoryInfo.getParentNames());
             entityList.add(timeLimit);
+
+            kpiTimeLimitItemRedis.setTimelimitItem(timeLimit);
         }
 
         baseDao.deleteBatchByCategoryIds(distinctCategoryIds);