会员标签同步

haoban-manage3-api/pom.xml

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

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

@@ -323,5 +323,5 @@ public interface ExternalClerkRelatedApiService {
      */
     com.gic.api.base.commons.ServiceResponse<String> getMemberIdByExternalId(String wxEnterpriseId,String externalUserId);
 
-    void listMemberIdByEnterpriseId(QywxTagSyncInfoDTO dto) throws SQLException;
+    void listMemberIdByEnterpriseId(String json);
 }

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

@@ -802,22 +802,24 @@ public class ExternalClerkRelatedApiServiceImpl implements ExternalClerkRelatedA
     }
 
     @Override
-    public void listMemberIdByEnterpriseId(QywxTagSyncInfoDTO dto) throws SQLException {
-        if(null == dto){
+    public void listMemberIdByEnterpriseId(String json){
+        if(null == json){
             log.info("参数不能为空");
             return;
         }
-        log.info("标签同步会员参数：{}",JSON.toJSONString(dto));
-        Integer size = 5000;
+        log.info("标签同步会员参数：{}",json);
+        QywxTagSyncInfoDTO dto = JSONObject.parseObject(json, QywxTagSyncInfoDTO.class);
+        Integer size = 1000;
         String wxEnterpriseId = dto.getWxEnterpriseId();
         String enterpriseId = dto.getEnterpriseId();
-        Integer totalCount = tabHaobanExternalClerkRelatedMapper.countByEnterpriseIdAndWxEnterpriseId(wxEnterpriseId, enterpriseId);
+        Integer totalCount = 0;
+        /*Integer totalCount = tabHaobanExternalClerkRelatedMapper.countByEnterpriseIdAndWxEnterpriseId(wxEnterpriseId, enterpriseId);
         if(0 == totalCount){
             dto.setTotalCount(0);
             qywxTagSyncApiService.tagSync(dto);
             return;
         }
-        dto.setTotalCount(totalCount);
+        dto.setTotalCount(totalCount);*/
         Connection conn = null;
         ResultSet rs = null;
         PreparedStatement pstat = null;
@@ -846,15 +848,22 @@ public class ExternalClerkRelatedApiServiceImpl implements ExternalClerkRelatedA
                 String memberId = rs.getString("memberId");
                 result.add(memberId);
                 if (result.size() == size){
+                    totalCount = totalCount + size;
                     dto.setMemberIds(result);
                     qywxTagSyncApiService.tagSync(dto);
                     result.clear();
                 }
             }
             if (CollUtil.isNotEmpty(result)){
+                totalCount = totalCount + result.size();
                 dto.setMemberIds(result);
+                dto.setTotalCount(totalCount);
                 qywxTagSyncApiService.tagSync(dto);
                 result.clear();
+            }else {
+                dto.setMemberIds(result);
+                dto.setTotalCount(totalCount);
+                qywxTagSyncApiService.tagSync(dto);
             }
         }catch (Exception e){
             log.warn("异常",e);