业务代码中先处置惩罚业务末了存储数据

背景说明：
在处置惩罚复杂业务的时候，特别是研发自测期间，经常会产生很多不必要的垃圾数据。
技能原理：
先将要存入数据库的数据放在缓存中，等所有业务代码实行完后，再同一生存；
代码如下：

1. @Slf4j
2. public class BaseService<M extends BaseMapper<T>, T> extends ServiceImpl<M, T> implements IService<T> {
4.     /**
5.      * 构建查询
6.      * @param e
7.      * @return
8.      */
9.     @SneakyThrows
10.     public <E extends Object> EntityWrapper<E> wrapperTable(E e, String tableName, Boolean like) {
11.         EntityWrapper<E> wrapper = new EntityWrapper<>();
12.         for (String field: JSON.parseObject(JSON.toJSONString(e)).keySet()) {
13.             Field ld = findField(e.getClass(), field);
14.             if(ld == null || !checkField(ld)) continue;
15.             String _s = columnName(ld);
16.             String m =null;
17.             if(_s.contains("_")){
18.                  m = StrUtil.toCamelCase("get_"+_s);
19.             }else {m=StrUtil.genGetter(_s);}
21.             Object o = e.getClass().getMethod(m).invoke(e);
22.             if(ObjectUtils.isEmpty(o)) continue;
23.             if(!ObjectUtils.isEmpty(tableName)) {
24.                 _s = tableName+"."+_s;
25.             }
26.             if(like) wrapper.like(_s,o.toString());
27.             else wrapper.eq(_s , o);
28.         }
29.         return wrapper;
30.     }
31.     /**
32.      * 构建查询
33.      * @param e
34.      * @return
35.      */
36.     @SneakyThrows
37.     public <E extends Object> EntityWrapper<E> wrapper(E e, Boolean like) {
38.         return wrapperTable(e,null,like);
39.     }
40.     /**
41.      * 构建查询
42.      * @param e
43.      * @return
44.      */
45.     @SneakyThrows
46.     public <E extends Object> EntityWrapper<E> wrapper(E e) {
47.         return wrapperTable(e,null,false);
48.     }
49.     private boolean checkField(Field field) {
50.         if(!field.isAnnotationPresent(TableId.class) && !field.isAnnotationPresent(TableField.class)) return false;
51.         if(field.isAnnotationPresent(TableField.class) && !field.getAnnotation(TableField.class).exist()) return false;
52.         return true;
53.     }
54.     private Field findField(Class c,String field) {
55.         if(c == Object.class) return null;
56.         try {
57.             return c.getDeclaredField(field);
58.         } catch (NoSuchFieldException e) {
59.             return findField(c.getSuperclass(),field);
60.         }
61.     }
63.     private String columnName(Field field) {
64.         if(field.isAnnotationPresent(TableId.class) && ObjectUtils.isNotEmpty(field.getAnnotation(TableId.class).value())) return field.getAnnotation(TableId.class).value();
65.         if(field.isAnnotationPresent(TableField.class) && field.getAnnotation(TableField.class).exist() && ObjectUtils.isNotEmpty(field.getAnnotation(TableField.class).value())) return field.getAnnotation(TableField.class).value();
66.         return StrUtil.toUnderlineCase(field.getName());
67.     }
69.     @Transactional(rollbackFor = Exception.class)
70.     @Override
71.     public boolean insertOrUpdate(T entity){
72.         if(entity instanceof TransacationalEntity) {
73.             //截流所有 TransacationalEntity 下的新增
74.             if(((TransacationalEntity) entity).getSqlStatus().equalsIgnoreCase("begin")) {
75.                 return TransactionalUtils.add(this,((TransacationalEntity) entity));
76.             } else if(((TransacationalEntity) entity).getSqlStatus().equalsIgnoreCase("commit")) {
77.                 return TransactionalUtils.commit(((TransacationalEntity) entity).getSqlVersion());
78.             } else {
79.                 return super.insertOrUpdate(entity);
80.             }
81.         } else {
82.             return super.insertOrUpdate(entity);
83.         }
84.     }
86.     @SneakyThrows
87.     @Transactional(rollbackFor = Exception.class)
88.     @Override
89.     public boolean insertOrUpdateBatch(List<T> entityList) {
90.         try {
91.             this.baseMapper.getClass().getMethod("insertOrUpdateBatch", List.class).invoke(this.baseMapper,entityList);
92.         } catch (NoSuchMethodException e) {
93.             log.warn("mapper类{}，不存在方法{}，替换为service执行",this.baseMapper.getClass(),"insertOrUpdateBatch");
94.             super.insertOrUpdateBatch(entityList);
95.         }
96.         return true;
97.     }
100. }

复制代码

业务父类其他方法可以忽略，都是懒得写xml但是版本又不允许升级，偷懒写的sql条件辅助工具。
主要要关注以下两个方法：
第一个，用于截流原来的生存方法，将要生存的数据存入缓存中。

1. @Transactional(rollbackFor = Exception.class)
2.     @Override
3.     public boolean insertOrUpdate(T entity){
4.         if(entity instanceof TransacationalEntity) {
5.             //截流所有 TransacationalEntity 下的新增
6.             if(((TransacationalEntity) entity).getSqlStatus().equalsIgnoreCase("begin")) {
7.                 return TransactionalUtils.add(this,((TransacationalEntity) entity));
8.             } else if(((TransacationalEntity) entity).getSqlStatus().equalsIgnoreCase("commit")) {
9.                 return TransactionalUtils.commit(((TransacationalEntity) entity).getSqlVersion());
10.             } else {
11.                 return super.insertOrUpdate(entity);
12.             }
13.         } else {
14.             return super.insertOrUpdate(entity);
15.         }
16.     }

复制代码

第二个，用于末了同一处置惩罚生存，我这里偷懒了，使用了代码生成器，所以xml中已经有了 insertOrupdataBatch.

1. @SneakyThrows
2.     @Transactional(rollbackFor = Exception.class)
3.     @Override
4.     public boolean insertOrUpdateBatch(List<T> entityList) {
5.         try {
6.             this.baseMapper.getClass().getMethod("insertOrUpdateBatch", List.class).invoke(this.baseMapper,entityList);
7.         } catch (NoSuchMethodException e) {
8.             log.warn("mapper类{}，不存在方法{}，替换为service执行",this.baseMapper.getClass(),"insertOrUpdateBatch");
9.             super.insertOrUpdateBatch(entityList);
10.         }
11.         return true;

复制代码

1. @Data
2. @AllArgsConstructor
3. @NoArgsConstructor
4. public class TransacationalEntity {
6.     /**
7.      * begin null commit
8.      */
9.     @TableField(exist = false)
10.     @ApiModelProperty(hidden = true)
11.     private String sqlStatus;
13.     /**
14.      * begin null commit
15.      */
16.     @TableField(exist = false)
17.     @ApiModelProperty(hidden = true)
18.     private String sqlVersion;
19. }

复制代码

Pojo父类

1. public class TransactionalUtils {
2.     static volatile ConcurrentHashMap<String, ConcurrentHashMap<BaseService, CopyOnWriteArrayList<Object>>> cMap = new ConcurrentHashMap<>();
3.     static volatile ConcurrentHashMap<String,Long> tMap = new ConcurrentHashMap<>();
4.      public static <E extends TransacationalEntity> boolean add(BaseService service, E e) {
5.          long millis = System.currentTimeMillis();
6.          synchronized(service.getClass()) {
7.             ConcurrentHashMap<BaseService, CopyOnWriteArrayList<Object>> map = cMap
8.                     .getOrDefault(e.getSqlVersion(), new ConcurrentHashMap<>());
9.             CopyOnWriteArrayList<Object> list = map.getOrDefault(service, new CopyOnWriteArrayList<>());
10.             list.add(e);
11.             map.put(service, list);
12.             cMap.put(e.getSqlVersion(), map);
13.             tMap.put(e.getSqlVersion(),tMap.getOrDefault(e.getSqlVersion(), 0L)+System.currentTimeMillis()-millis) ;
14.         }
15.          return true;
16.     }
18.     @SneakyThrows
19.     public static boolean commit(String key) {
20.         long millis = System.currentTimeMillis();
21.         int size = 0;
22.         for (Map.Entry<BaseService, CopyOnWriteArrayList<Object>> entry : cMap.remove(key).entrySet()) {
23.             entry.getKey().insertOrUpdateBatch(entry.getValue());
24.             size+=entry.getValue().size();
25.         }
26.         System.out.println("批量业务入队总量" + size);
27.         System.out.println("批量业务入队耗时" + tMap.remove(key));
28.         System.out.println("批量业务提交耗时" + (System.currentTimeMillis()-millis));
29.         return true;
30.     }
32. }

复制代码

核心工具类以下是调用示例：

1. String tranId = IdUtil.simpleUUID();
2.         Map<String, Object> userMap = new HashMap();
3.         userMap.put("sqlStatus","begin");
4.         userMap.put("sqlVersion", tranId);
5.         propretyDye(beans,userMap);
6.         insertOrUpdate(Arrays.asList(beans));
7.         TransactionalUtils.commit(tranId);

复制代码

先给要截流的数据加上版本号和标识，其实只要一个版本号就可以了，sqlStatus这个字段懒得删除了。
版本号主要用来在缓存中分组，隔离其他业务提交。
附带一个参数处置惩罚的小工具，有时候要重复的一层层赋值，太懒了，所以写个工具，让机器本身给我处置惩罚所有数据的值，用法如上面的示例，没仔细检查，偶然会发生栈溢出，但是不影响，应该是项目的全局配置不够造成的：

1. /**
2.      * 属性染色
3.      * 如果对象 o 包含 propreties 的key,则设置key对应的值
4.      * 处理对象和对象中所有的子对象
5.      * @param o
6.      * @param propreties
7.      * @return
8.      */
9.     @SneakyThrows
10.     public static Object propretyDye(Object o, Map<String,Object> propreties) {
11.         if(o instanceof Collection) for (Object object : (Collection<?>) o) {
12.             propretyDye(object,propreties);
13.         }
14.         Class<?> aClass = o.getClass();
15.         while (aClass instanceof Object) {
16.             for (Field field : aClass.getDeclaredFields()) {
17.                 field.setAccessible(true);
18.                 if(propreties.containsKey(field.getName())) field.set(o,propreties.get(field.getName()));
19.                 if(field.get(o) instanceof Collection) for (Object object : (Collection<?>) field.get(o)) {
20.                     propretyDye(object,propreties);
21.                 }
22.                 if(field.get(o) instanceof Object && BeanUtil.isBean(field.get(o).getClass())) propretyDye(field.get(o),propreties);
23.             }
24.             aClass = aClass.getSuperclass();
25.         }
26.         return o;
27.     }

复制代码

 

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。