好办表并发控制

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/dao/mapper/TabHaobanExternalClerkRelatedMapper.java

@@ -18,7 +18,7 @@ public interface TabHaobanExternalClerkRelatedMapper {
 
     int updateByPrimaryKeySelective(TabHaobanExternalClerkRelated record);
 
-    TabHaobanExternalClerkRelated selectByClerkIdAndExternalUserId(@Param("clerkId") String clerkId,
+    int selectByClerkIdAndExternalUserId(@Param("clerkId") String clerkId,
                                                                    @Param("externalUserId") String externalUserId);
 
     int delByUserIdAndExternalUserId(@Param("externalUserId") String externalUserId , @Param("staffId") String staffId);

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

@@ -89,15 +89,24 @@ public class ExternalClerkRelatedServiceImpl implements ExternalClerkRelatedServ
     public void insert(TabHaobanExternalClerkRelated related) {
         String clerkId = related.getClerkId();
         String externalUserId = related.getExternalUserId();
-        TabHaobanExternalClerkRelated tab = mapper.selectByClerkIdAndExternalUserId(clerkId, externalUserId);
-        if (tab == null) {
+        String lockKey = "addExternalUser:"+externalUserId ;
+        int num1 = mapper.selectByClerkIdAndExternalUserId(clerkId, externalUserId);
+        if(num1 > 0) {
+            return ;
+        }
+        RedisUtil.lock(lockKey,1L);
+        int num2 = mapper.selectByClerkIdAndExternalUserId(clerkId, externalUserId);
+        logger.info("好友数={},{},{}",num1,num2,externalUserId);
+        if (num2 == 0) {
             String uuId = StringUtil.randomUUID();
+            Date now = new Date() ;
             related.setStatusFlag(related.getStatusFlag() != null ? related.getStatusFlag() : 1);
             related.setExternalClerkRelatedId(uuId);
-            related.setCreateTime(new Date());
-            related.setUpdateTime(new Date());
+            related.setCreateTime(now);
+            related.setUpdateTime(now);
             mapper.insertSelective(related);
         }
+        RedisUtil.unlock(lockKey);
     }
 
     @Override

haoban-manage3-service/src/main/resources/mapper/TabHaobanExternalClerkRelatedMapper.xml

@@ -226,9 +226,9 @@
         where external_clerk_related_id = #{externalClerkRelatedId,jdbcType=VARCHAR}
     </update>
 
-    <select id="selectByClerkIdAndExternalUserId" resultMap="BaseResultMap" parameterType="java.lang.String">
+    <select id="selectByClerkIdAndExternalUserId" resultType="int" parameterType="java.lang.String">
         select
-        <include refid="Base_Column_List"/>
+         count(*)
         from tab_haoban_external_clerk_related
         where clerk_id = #{clerkId,jdbcType=VARCHAR}
         and external_user_id = #{externalUserId}