Concurrent idempotent anti shake

Submit data , Click many times at a very fast speed , Same data , In the case of concurrency , If no processing is done, multiple operations or records will be generated , Or the primary key repeatedly reports an error .

To solve this problem , First, the front-end anti shake is made , But the front end is not safe , Can bypass or say the network is bad ,

The back end also needs to be anti shake ：

1、 Cut around 、 locked 、 Idempotent function

@Slf4j
@Aspect
@Component
public class NoRepeatSubmitAop {
 

    @Autowired
    private RedisService redisService;

//                         com.hieasy.icrm.project.weixin.controller.wxma.miniapp
    @Synchronized
    @Around("execution(* com.hieasy.icrm.project.weixin.controller.*.*.*Ctrl.*(..)) && @annotation(nrs)")
    public Object arround(ProceedingJoinPoint pjp, NoRepeatSubmit nrs) throws Throwable {
            ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
            HttpServletRequest request = attributes.getRequest();
            String token=request.getHeader("token");
            if(MyStrUtils.isEmpty(token)) return pjp.proceed();
            String key = token+ "-" + request.getServletPath();
//            log.info(" To request ：{}",key);
            if ( !redisService.haskey(key) ) {//  If there is this in the cache url It is deemed to be a duplicate submission 
                Object o = pjp.proceed();
                redisService.setCacheObject(key, 0, 10, TimeUnit.SECONDS);
//                log.info(" Normal to submit ：{},{}",key, MyDateUtil.getNowDateTime());
                return o;
            } else {
                redisService.setCacheObject(key, 0, 10, TimeUnit.SECONDS);// Ordered the same URL Continue restriction , until 2 The interval between clicks exceeds the limit 
                //return R.error(-889," Do not submit repeatedly or operate too frequently ！");
//                log.info(" Limit submission ：{},{}",key, MyDateUtil.getNowDateTime());
                throw new BusinessException(" Do not submit repeatedly or operate too frequently ！( interval 10 second , Recalculate each click )");
            }
    }
 
}

2、 Annotations use

    @Target(ElementType.METHOD) //  It works on the method 
    @Retention(RetentionPolicy.RUNTIME) //  Run time effective 
    public @interface NoRepeatSubmit {
        String name() default "name:";
    }


    @NoRepeatSubmit
    @PostMapping("/goods/save")
    @ApiOperation(value = " Mall goods - preservation ", notes = " This feature adds 、 It can be modified , Single processing , Multiple processes are OK ")
    @ApiOperationSupport(includeParameters = {})
    public JsonResult save(@RequestBody List<CrmWxMallGoods> list) throws Exception {
        Long tenantId=getPresentTenantId();
        int rows=0;
        QueryWrapper wrapper;
        CrmWxMallGoods item;
        for(CrmWxMallGoods goods:list){
            goods.setTenantId(tenantId);
            wrapper=new QueryWrapper();
            wrapper.eq("tenant_id", tenantId);
            wrapper.eq("item_code", goods.getItemCode());
            item= crmWxMallGoodsService.getOne(wrapper);
            if(null!=item){
                goods.setId(item.getId());
                rows+=crmWxMallGoodsService.updateById(goods)?1:0;
            }else{
                rows+=crmWxMallGoodsService.save(goods)?1:0;
            }
        }
        return toJRAjax(rows);
    }