用户申请退款增加锁 防止重复请求

liquidnet-bus-api/liquidnet-service-kylin-api/src/main/java/com/liquidnet/service/kylin/constant/KylinRedisConst.java

 package com.liquidnet.service.kylin.constant;
 
+import rx.Completable;
+
 public class KylinRedisConst {
     public static final String FIELDS = "kylin:fields:id";
     public static final String PERFORMANCES = "kylin:performances:id:";
@@ -37,6 +39,7 @@ public class KylinRedisConst {
     // 手续费
     public static final String ORDER_REFUND_POUNDAGE = "kylin:order:poundage";
     public static final String ORDER_REFUND_POUNDAGE_EXPLAIN = "kylin:order:poundageExplain";
+    public static final String REDIS_KEY_KYLIN_REFUND_LOCK = "kylin:order:refund:lock:entitiesId:";
 
     public static final String USERID_BUY_INFO = "kylin:buy:userId:";
     public static final String IDCARD_BUY_INFO = "kylin:buy:idCard:";

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/service/impl/KylinOrderTicketsRefundServiceImpl.java

@@ -144,6 +144,11 @@ public class KylinOrderTicketsRefundServiceImpl {
     }
 
     public ResponseDto sendOrderRefund(String orderId, String orderTicketEntitiesId, String reason, String picList, String ticketNum, Integer sendExpressType, String expressNumber, String expressContacts, String expressPhone, String sendExpressAddress, String appointmentTime) {
+        boolean isLock = dataUtils.setRefundLock(orderTicketEntitiesId);
+        if (!isLock) {
+            return ResponseDto.failure("正在处理，请勿重复操作～");
+        }
+
         KylinOrderTicketEntitiesVo orderTicketEntitiesVo = null;
         try {
             String uid = CurrentUtil.getCurrentUid();
@@ -234,6 +239,9 @@ public class KylinOrderTicketsRefundServiceImpl {
         } catch (Exception e) {
             log.error("sendOrderRefundException e:[{}]", e);
             return ResponseDto.failure("申请失败");
+        } finally {
+            // 执行完毕。释放锁
+            dataUtils.delRefundLock(orderTicketEntitiesId);
         }
     }
 

liquidnet-bus-service/liquidnet-service-kylin/liquidnet-service-kylin-impl/src/main/java/com/liquidnet/service/kylin/utils/DataUtils.java

@@ -814,4 +814,17 @@ public class DataUtils {
         }
         return priceExpress;
     }
+
+    public boolean setRefundLock(String orderTicketEntitiesId) {
+        String redisKey = KylinRedisConst.REDIS_KEY_KYLIN_REFUND_LOCK
+                .concat(orderTicketEntitiesId);
+        return redisUtil.lock(redisKey, 1, 60);
+    }
+
+    public void delRefundLock(String orderTicketEntitiesId) {
+        String redisKey = KylinRedisConst.REDIS_KEY_KYLIN_REFUND_LOCK
+                .concat(orderTicketEntitiesId);
+        redisUtil.uLock(redisKey);
+    }
+
 }