关联导购加锁防止并发问题

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/service/out/impl/StaffClerkRelationApiServiceImpl.java

@@ -170,12 +170,19 @@ public class StaffClerkRelationApiServiceImpl implements StaffClerkRelationApiSe
 
     @Override
     public ServiceResponse bindStaffClerk(StaffClerkRelationDTO staffClerkRelationDTO, String optStaffId, int channelCode) {
+        //加锁防止并发问题
+        String clerkId = staffClerkRelationDTO.getClerkId();
+        String storeId = staffClerkRelationDTO.getStoreId();
+        String key = "haoban_bind_staff:" + clerkId+":"+storeId;
+        RedisUtil.lock(key, 6L);
         ServiceResponse resp = this.bindCheck(staffClerkRelationDTO, optStaffId, channelCode);
         if (resp != null && !resp.isSuccess()) {
             logger.error("不允许绑定：{}", resp.getMessage());
+            RedisUtil.unlock(key);
             return resp;
         }
         String relationId = staffClerkRelationService.bind(staffClerkRelationDTO, optStaffId, channelCode);
+        RedisUtil.unlock(key);
         return ServiceResponse.success(relationId);
     }