fix

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

@@ -348,20 +348,20 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
     private void dealDepartmentToMq(String taskId, Set<String> dealList, SyncTaskStatusEnum syncTaskStatusEnum) {
         //预处理分组任务
         syncTaskService.updateTaskStatus(taskId, syncTaskStatusEnum.getVal());
-
-        dealList.forEach(relationId -> {
-            DealParamMqDTO dealParamMqDTO = new DealParamMqDTO();
-            dealParamMqDTO.setTaskId(taskId);
-            dealParamMqDTO.setData(relationId);
-            dealParamMqDTO.setType(syncTaskStatusEnum.getVal());
-            GicMQClient clientInstance = GICMQClientUtil.getClientInstance();
-            try {
-                clientInstance.sendMessage("departmentSyncDealMq", JSONObject.toJSONString(dealParamMqDTO));
-            } catch (Exception e) {
-                logger.info("发送失败:{},{}", taskId, relationId);
-                e.printStackTrace();
-            }
-        });
+//
+//        dealList.forEach(relationId -> {
+//            DealParamMqDTO dealParamMqDTO = new DealParamMqDTO();
+//            dealParamMqDTO.setTaskId(taskId);
+//            dealParamMqDTO.setData(relationId);
+//            dealParamMqDTO.setType(syncTaskStatusEnum.getVal());
+//            GicMQClient clientInstance = GICMQClientUtil.getClientInstance();
+//            try {
+//                clientInstance.sendMessage("departmentSyncDealMq", JSONObject.toJSONString(dealParamMqDTO));
+//            } catch (Exception e) {
+//                logger.info("发送失败:{},{}", taskId, relationId);
+//                e.printStackTrace();
+//            }
+//        });
 
         List<String> listRet = dealList.stream().map(relationId -> {
             DealParamMqDTO dealParamMqDTO = new DealParamMqDTO();