会员标签同步

haoban-manage3-api/pom.xml

@@ -45,6 +45,12 @@
             <artifactId>gic-commons</artifactId>
             <version>${gic-commons}</version>
         </dependency>
+        <dependency>
+            <groupId>com.gic</groupId>
+            <artifactId>haoban-app-customer-api</artifactId>
+            <version>3.0-SNAPSHOT</version>
+            <scope>compile</scope>
+        </dependency>
     </dependencies>
 
     <build>

haoban-manage3-api/src/main/java/com/gic/haoban/manage/api/service/ExternalClerkRelatedApiService.java

 package com.gic.haoban.manage.api.service;
 
 import com.gic.api.base.commons.Page;
+import com.gic.haoban.app.customer.dto.QywxTagSyncInfoDTO;
 import com.gic.haoban.base.api.common.BasePageInfo;
 import com.gic.haoban.base.api.common.ServiceResponse;
-import com.gic.haoban.manage.api.dto.ClerkStaffWxUserDTO;
-import com.gic.haoban.manage.api.dto.ExternalClerkRelatedDTO;
-import com.gic.haoban.manage.api.dto.ExternalClerkRelatedShortInfoDTO;
-import com.gic.haoban.manage.api.dto.FriendMemberStatusDTO;
+import com.gic.haoban.manage.api.dto.*;
 
 import java.util.Date;
 import java.util.List;
@@ -323,4 +321,6 @@ public interface ExternalClerkRelatedApiService {
      * @return
      */
     com.gic.api.base.commons.ServiceResponse<String> getMemberIdByExternalId(String wxEnterpriseId,String externalUserId);
+
+    void listMemberIdByEnterpriseId(QywxTagSyncInfoDTO dto);
 }

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

@@ -178,6 +178,12 @@ public interface TabHaobanExternalClerkRelatedMapper {
     List<String> listMemberIdByEnterpriseId(@Param("wxEnterpriseId") String wxEnterpriseId,
                                             @Param("enterpriseId") String enterpriseId);
 
+    Integer countByEnterpriseIdAndWxEnterpriseId(@Param("wxEnterpriseId") String wxEnterpriseId,
+                                                 @Param("enterpriseId") String enterpriseId);
+    List<String> getMemberIdList(@Param("wxEnterpriseId") String wxEnterpriseId,
+                                 @Param("enterpriseId") String enterpriseId,
+                                 @Param("num")Integer num,
+                                 @Param("size")Integer size);
 
     /**
      * 查询会员在企业下的好友关系memberIds 根据会员ids

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

@@ -11,8 +11,10 @@ import com.gic.commons.util.GICMQClientUtil;
 import com.gic.dubbo.entity.ProviderLocalTag;
 import com.gic.enterprise.api.dto.StoreDTO;
 import com.gic.enterprise.api.service.StoreService;
+import com.gic.haoban.app.customer.dto.QywxTagSyncInfoDTO;
 import com.gic.haoban.app.customer.enums.GicQywxSyncTypeEnum;
 import com.gic.haoban.app.customer.enums.QywxSyncTaskTypeEnum;
+import com.gic.haoban.app.customer.service.api.service.QywxTagSyncApiService;
 import com.gic.haoban.base.api.common.BasePageInfo;
 import com.gic.haoban.base.api.common.ServiceResponse;
 import com.gic.haoban.base.api.common.errCode.HaoBanErrCodeCommon;
@@ -25,7 +27,10 @@ import com.gic.haoban.manage.api.service.DealSyncOperationApiService;
 import com.gic.haoban.manage.api.service.ExternalClerkRelatedApiService;
 import com.gic.haoban.manage.api.service.WxEnterpriseApiService;
 import com.gic.haoban.manage.service.config.Config;
-import com.gic.haoban.manage.service.dao.mapper.*;
+import com.gic.haoban.manage.service.dao.mapper.ExternalUseridLogMapper;
+import com.gic.haoban.manage.service.dao.mapper.TabHaobanExternalClerkRelatedMapper;
+import com.gic.haoban.manage.service.dao.mapper.TabHaobanStaffClerkRelationMapper;
+import com.gic.haoban.manage.service.dao.mapper.WxEnterpriseMapper;
 import com.gic.haoban.manage.service.entity.TabHaobanExternalClerkRelated;
 import com.gic.haoban.manage.service.entity.TabHaobanWxEnterprise;
 import com.gic.haoban.manage.service.entity.ext.MemberStaffRelExtDO;
@@ -54,7 +59,11 @@ import org.redisson.api.RateType;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
+
 import java.util.*;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
 import java.util.stream.Collectors;
 
@@ -62,6 +71,7 @@ import java.util.stream.Collectors;
 public class ExternalClerkRelatedApiServiceImpl implements ExternalClerkRelatedApiService {
 
     private static final Logger log = LogManager.getLogger(ExternalClerkRelatedApiServiceImpl.class);
+    private static final int availableProcessor = Runtime.getRuntime().availableProcessors();
 
     @Autowired
     private TabHaobanExternalClerkRelatedMapper tabHaobanExternalClerkRelatedMapper;
@@ -97,6 +107,8 @@ public class ExternalClerkRelatedApiServiceImpl implements ExternalClerkRelatedA
     private MemberService memberService;
     @Autowired
     private ExternalClerkRelatedService externalClerkRelatedService;
+    @Autowired
+    private QywxTagSyncApiService qywxTagSyncApiService;
 
     /**
      * 查询会员在企业下的好友关系
@@ -782,4 +794,50 @@ public class ExternalClerkRelatedApiServiceImpl implements ExternalClerkRelatedA
     public com.gic.api.base.commons.ServiceResponse<String> getMemberIdByExternalId(String wxEnterpriseId, String externalUserId) {
         return com.gic.api.base.commons.ServiceResponse.success(externalClerkRelatedService.getMemberIdByExternalId(wxEnterpriseId,externalUserId));
     }
+
+    @Override
+    public void listMemberIdByEnterpriseId(QywxTagSyncInfoDTO dto) {
+        if(null == dto){
+            log.info("参数不能为空");
+            return;
+        }
+        log.info("标签同步会员参数：{}",JSON.toJSONString(dto));
+        Integer size = 5000;
+        String wxEnterpriseId = dto.getWxEnterpriseId();
+        String enterpriseId = dto.getEnterpriseId();
+        Integer totalCount = tabHaobanExternalClerkRelatedMapper.countByEnterpriseIdAndWxEnterpriseId(wxEnterpriseId, enterpriseId);
+        Integer round = size / totalCount + 1;
+        List<String> result = new LinkedList<>();
+        // 程序计数器
+        final CountDownLatch count = new CountDownLatch(round);
+        // 创建线程
+        ExecutorService executor = Executors.newFixedThreadPool(availableProcessor);
+        // 分配数据
+        for (int i = 0; i < round; i++) {
+            //该线程的查询开始值
+            int startLen = i * size;
+            executor.execute(new Runnable() {
+                @Override
+                public void run() {
+                    List<String> memberIdList = tabHaobanExternalClerkRelatedMapper.getMemberIdList(wxEnterpriseId, enterpriseId, startLen, size);
+                    result.addAll(memberIdList);
+                    // 计数器 -1(唤醒阻塞线程)
+                    count.countDown();
+                }
+            });
+        }
+        try {
+            // 阻塞线程(主线程等待所有子线程 一起执行业务)
+            count.await();
+        } catch (Exception e) {
+            e.printStackTrace();
+        } finally {
+            // 终止线程池
+            // 启动一次顺序关闭，执行以前提交的任务，但不接受新任务。若已经关闭，则调用没有其他作用。
+            executor.shutdown();
+        }
+        dto.setMemberIds(result);
+        qywxTagSyncApiService.tagSync(dto);
+
+    }
 }

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

@@ -515,8 +515,23 @@
         from tab_haoban_external_clerk_related
         where wx_enterprise_id = #{wxEnterpriseId}
           and enterprise_id = #{enterpriseId}
-          and status_flag in (1, 3, 4)
-        order by create_time
+          and status_flag = 1
+    </select>
+    <select id="countByEnterpriseIdAndWxEnterpriseId" resultType="int">
+        select count(*)
+        from tab_haoban_external_clerk_related
+        where wx_enterprise_id = #{wxEnterpriseId}
+          and enterprise_id = #{enterpriseId}
+          and status_flag = 1
+    </select>
+
+    <select id="getMemberIdList" resultType="String">
+        select member_id
+        from tab_haoban_external_clerk_related
+        where wx_enterprise_id = #{wxEnterpriseId}
+          and enterprise_id = #{enterpriseId}
+          and status_flag = 1
+        limit ${num},${size}
     </select>
 
     <select id="listMemberIdsByMemberIds" resultType="String">