fix：离职继承改为消息队列

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

@@ -20,11 +20,22 @@ public interface HandoverOperationApiService {
      */
     public void batchQywxHandoverTimeTask(String params);
 
+
+    /**
+     * 处理企微离职继承
+     *
+     * @param wxEnterpriseId wx企业标识
+     * @author mozhu
+     * @date 2022-04-26 17:29:30
+     */
+    public void dealQywxEnterpriseHandoverMq(String wxEnterpriseId);
+
     /**
      * 定时处理企业微信 离职基础的结果（废弃）
      *
      * @param params
      */
+    @Deprecated
     public void BatchQywxHandoverResultTimeTask(String params);
 
     /**

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

@@ -9,7 +9,6 @@ import com.gic.haoban.manage.api.dto.HandoverExternalDTO;
 import com.gic.haoban.manage.api.dto.HandoverStaffFriendCountDTO;
 import com.gic.haoban.manage.api.dto.SecretSettingDTO;
 import com.gic.haoban.manage.api.enums.SecretTypeEnum;
-import com.gic.haoban.manage.api.service.StaffClerkRelationApiService;
 import com.gic.haoban.manage.service.config.Config;
 import com.gic.haoban.manage.service.dao.mapper.*;
 import com.gic.haoban.manage.service.entity.*;
@@ -124,7 +123,6 @@ public class HandoverServiceImpl implements HandoverService {
                 });
                 handoverExternalMapper.insertBatch(needAdd);
             }
-
         });
         //删除不需要的staff数据
         List<TabHandoverStaff> handoverStaffList = handoverStaffMapper.listByWxEnterpriseId(wxEnterpriseId);

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

@@ -3,6 +3,7 @@ package com.gic.haoban.manage.service.service.out.impl;
 import com.alibaba.fastjson.JSONObject;
 import com.gic.api.base.commons.Page;
 import com.gic.commons.util.EntityUtil;
+import com.gic.commons.util.GICMQClientUtil;
 import com.gic.haoban.base.api.common.BasePageInfo;
 import com.gic.haoban.common.utils.PageUtil;
 import com.gic.haoban.manage.api.dto.*;
@@ -16,6 +17,7 @@ import com.gic.haoban.manage.service.entity.TabHaobanStaff;
 import com.gic.haoban.manage.service.service.HandoverService;
 import com.gic.haoban.manage.service.service.StaffService;
 import com.gic.haoban.manage.service.service.WxEnterpriseService;
+import com.gic.mq.sdk.GicMQClient;
 import com.gic.wechat.api.dto.qywx.QywxTransferCustomerInfoDTO;
 import com.gic.wechat.api.dto.qywx.QywxUnassignedInfoDTO;
 import com.gic.wechat.api.dto.qywx.response.QywxGetUnassignedListDTO;
@@ -60,17 +62,25 @@ public class HandoverOperationApiServiceImpl implements HandoverOperationApiServ
 
     @Override
     public void batchQywxHandoverTimeTask(String params) {
-        logger.info("定时拉取离职基础的人员：{}", params);
+        logger.info("定时拉取离职基础的人员start：{}", params);
         List<YwWxEnterpriseDTO> dtoList = wxEnterpriseApiService.listAll();
         for (YwWxEnterpriseDTO enterpriseDTO : dtoList) {
+            GicMQClient instance = GICMQClientUtil.getClientInstance();
             try {
-                dealQywxEnterpriseHandover(enterpriseDTO.getWxEnterpriseId());
-                dealQywxEnterpriseHandoverResult(enterpriseDTO.getWxEnterpriseId());
+                instance.sendMessage("dealQywxEnterpriseHandoverMq", enterpriseDTO.getWxEnterpriseId());
             } catch (Exception e) {
-                e.printStackTrace();
-                logger.info("商户处理异常：{},{}", JSONObject.toJSONString(enterpriseDTO), e);
+                logger.info("发送消息队列异常：{},{}", JSONObject.toJSONString(enterpriseDTO), e);
             }
         }
+        logger.info("定时拉取离职基础的人员end：{}", params);
+    }
+
+    @Override
+    public void dealQywxEnterpriseHandoverMq(String wxEnterpriseId) {
+        logger.info("离职继承start...{}",wxEnterpriseId);
+        dealQywxEnterpriseHandover(wxEnterpriseId);
+        dealQywxEnterpriseHandoverResult(wxEnterpriseId);
+        logger.info("离职继承end...{}",wxEnterpriseId);
     }
 
     @Override
@@ -96,11 +106,17 @@ public class HandoverOperationApiServiceImpl implements HandoverOperationApiServ
         handoverService.saveHandover(wxEnterpriseId, allQywxUnassigned);
     }
 
+    /**
+     * 获取离职成员客户列表
+     * @param wxEnterpriseDTO
+     * @return
+     */
     private List<QywxUnassignedInfoDTO> getAllQywxUnassigned(WxEnterpriseDTO wxEnterpriseDTO) {
         List<QywxUnassignedInfoDTO> ret = new ArrayList<>();
         QywxGetUnassignedListDTO unassignedListDTO = null;
         String cursor = null;
         do {
+            //离职成员客户列表
             unassignedListDTO = qywxUserApiService.getUnassignedList(wxEnterpriseDTO.getCorpid(), config.getWxSuiteid(), cursor);
             cursor = unassignedListDTO.getNextCursor();
             if (CollectionUtils.isNotEmpty(unassignedListDTO.getInfo())) {
@@ -140,7 +156,6 @@ public class HandoverOperationApiServiceImpl implements HandoverOperationApiServ
                 }
                 List<QywxTransferCustomerInfoDTO> customerResults = customerDTO.getCustomer();
                 handoverService.dealResult(wxEnterpriseId, dto.getHandoverTransferId(), customerResults);
-
             } catch (Exception e) {
                 e.printStackTrace();
                 logger.info("处理异常：{},{}", JSONObject.toJSONString(dto), e);