企业微信同步mq拆分

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

@@ -23,6 +23,14 @@ public interface DealSyncOperationApiService {
      * @param params
      */
     void departmentDealMq(String params);
+    /**
+     * mq拆分
+     * 部门同步处理
+     * "routerName": "departmentSyncDealMq2"
+     *
+     * @param params
+     */
+    void departmentDealMq2(String params);
 
     /**
      * 处理前端数据

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

@@ -133,6 +133,45 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
         }
     }
 
+    @Override
+    public void departmentDealMq2(String params) {
+        DealParamMqDTO dealParamMqDTO = JSONObject.parseObject(params, DealParamMqDTO.class);
+        TabHaobanPreDealLog dataPre = preDealService.getByDataId(dealParamMqDTO.getTaskId(), dealParamMqDTO.getData(), dealParamMqDTO.getType() - 1, PreDealStatusEnum.all.getVal());
+        logger.info("好办同步处理mq处理开始:{}，dataPre={}", params,JSON.toJSONString(dataPre));
+        if (dataPre == null) {
+            return;
+        }
+        Integer dataType = dataPre.getDataType();
+        logger.info("同步类型,dataType:{}",dataType);
+        if (dataType.equals(PreDealTypeEnum.dept.getVal())) {
+            logger.info("0 部门处理：{}", params);
+            operationMap.get("qywxDeptSyncOperation").dealSingleByMq(dealParamMqDTO, dataPre);
+        } else if (dataType.equals(PreDealTypeEnum.clerk.getVal())) {
+            logger.info("2 成员处理：{}", params);
+            operationMap.get("qywxStaffSyncOperation").dealSingleByMq(dealParamMqDTO, dataPre);
+        } else if (dataType.equals(PreDealTypeEnum.friend_clerk.getVal())) {
+            logger.info("6 好友导购处理：{}", params);
+            operationMap.get("friendClerkSyncNewOperation").dealSingleByMq(dealParamMqDTO, dataPre);
+        } else if (dataType.equals(PreDealTypeEnum.friend.getVal())) {
+            logger.info("8 第三方好友处理：{}", params);
+            operationMap.get("friendSyncNewOperation").dealSingleByMq(dealParamMqDTO, dataPre);
+        } else if (dataType.equals(PreDealTypeEnum.self_friend.getVal())) {
+            logger.info("7 自建好友处理：{}", params);
+            operationMap.get("selfFriendSyncNewOperation").dealSingleByMq(dealParamMqDTO, dataPre);
+        } else if (dataType.equals(PreDealTypeEnum.tag.getVal())) {
+            logger.info("10 会员标签处理：{}", params);
+            operationMap.get("friendTagSyncOperation").dealSingleByMq(dealParamMqDTO, dataPre);
+        } else if (dataType.equals(PreDealTypeEnum.tag_member.getVal())) {
+            logger.info("11 会员标签处理标签项：{}", params);
+            operationMap.get("friendMemberTagSyncOperation").dealSingleByMq(dealParamMqDTO, dataPre);
+        } else if(dataType.equals(PreDealTypeEnum.modify_hm.getVal())) {
+            logger.info("20 活码批量修改");
+            operationMap.get("qwHmOperation").dealSingleByMq(dealParamMqDTO, dataPre);
+        }else {
+            logger.info("不是正常数据类型:{}", params);
+        }
+    }
+
 
     @Override
     public void dealDepartment(String taskId, String wxEnterpriseId

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/task/QywxDeptSyncOperation.java

@@ -260,7 +260,7 @@ public class QywxDeptSyncOperation implements BaseSyncOperation {
             dealParamMqDTO.setType(syncTaskStatusEnum.getVal());
             GicMQClient clientInstance = GICMQClientUtil.getClientInstance();
             try {
-                clientInstance.sendMessage("departmentSyncDealMq", JSONObject.toJSONString(dealParamMqDTO));
+                clientInstance.sendMessage("departmentSyncDealMq2", JSONObject.toJSONString(dealParamMqDTO));
             } catch (Exception e) {
                 logger.info("发送失败:{},{}", taskId, relationId);
                 e.printStackTrace();

haoban-manage3-service/src/main/java/com/gic/haoban/manage/service/task/friend/SelfFriendSyncNewOperation.java

@@ -213,7 +213,7 @@ public class SelfFriendSyncNewOperation implements BaseSyncOperation {
         GicMQClient clientInstance = GICMQClientUtil.getClientInstance();
         try {
             Log.info("发送队列SelfFriendSyncNewOperation={}",JSON.toJSONString(ret));
-            clientInstance.sendBatchMessages("departmentSyncDealMq", ret);
+            clientInstance.sendBatchMessages("departmentSyncDealMq2", ret);
         } catch (Exception e) {
             logger.info("发送失败:{},{}", taskId);
             e.printStackTrace();