Blame view

java110-utils/src/main/java/com/java110/utils/cache/BusinessTableHisCache.java 2.79 KB
88e030b7   王彪总   init project
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
  package com.java110.utils.cache;
  
  import com.java110.dto.system.BusinessTableHisDto;
  import com.java110.utils.util.SerializeUtil;
  
  import java.util.ArrayList;
  import java.util.List;
  
  /**
   * 映射缓存工具类
   * Created by wuxw on 2018/4/14.
   */
  public class BusinessTableHisCache extends BaseCache {
  
      //后缀 用来刷缓存时删除 所有以这个为后缀的数据
      public final static String DEFAULT_BUSINESS_TABLE_HIS = "JAVA110_BUSINESS_TABLE_HIS";
  
  
      /**
       * 获取  databus
       *
       * @return
       */
      public static List<BusinessTableHisDto> getBusinessTableHiss() {
          Jedis redis = null;
          try {
              redis = getJedis();
              return SerializeUtil.unserializeList(redis.get((DEFAULT_BUSINESS_TABLE_HIS).getBytes()), BusinessTableHisDto.class);
          } finally {
              if (redis != null) {
                  redis.close();
              }
          }
      }
  
      /**
       * 获取  databus
       *
       * @return
       */
      public static List<BusinessTableHisDto> getBusinessTableHisDtos(String action, String actionObj) {
          List<BusinessTableHisDto> businessTableHisDtoDtoDtos = getBusinessTableHiss();
  
          List<BusinessTableHisDto> tmpBusinessTableHisDtos = new ArrayList<>();
  
          for (BusinessTableHisDto businessTableHisDtoDto : businessTableHisDtoDtoDtos) {
              if (action.equals(businessTableHisDtoDto.getAction()) && actionObj.equals(businessTableHisDtoDto.getActionObj())) {
                  tmpBusinessTableHisDtos.add(businessTableHisDtoDto);
              }
          }
          return tmpBusinessTableHisDtos;
      }
  
      /**
       * 获取  databus
       *
       * @return
       */
      public static BusinessTableHisDto getBusinessTableHisDto(String action, String actionObj) {
          List<BusinessTableHisDto> businessTableHisDtoDtoDtos = getBusinessTableHiss();
          if(businessTableHisDtoDtoDtos == null){
              return null;
          }
  
          for (BusinessTableHisDto businessTableHisDtoDto : businessTableHisDtoDtoDtos) {
              if (action.equals(businessTableHisDtoDto.getAction()) && actionObj.equals(businessTableHisDtoDto.getActionObj())) {
                  return businessTableHisDtoDto;
              }
          }
          return null;
      }
  
      /**
       * 保存list 数据
       *
       * @param businessTableHisDtoDtoDtos
       */
      public static void setValue(List<BusinessTableHisDto> businessTableHisDtoDtoDtos) {
          if (businessTableHisDtoDtoDtos == null || businessTableHisDtoDtoDtos.size() < 1) {
              return;
          }
          Jedis redis = null;
          try {
              redis = getJedis();
              redis.set((DEFAULT_BUSINESS_TABLE_HIS).getBytes(), SerializeUtil.serializeList(businessTableHisDtoDtoDtos));
          } finally {
              if (redis != null) {
                  redis.close();
              }
          }
      }
  
  
  }