fix

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

@@ -690,7 +690,7 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
 
         preDealService.insert(dealLogList);
         HashSet<String> hashSet = (HashSet<String>) dealLogList.stream().map(TabHaobanPreDealLog::getDataId).collect(Collectors.toSet());
-        dealDepartmentToMq(taskId, hashSet, SyncTaskStatusEnum.friend_clerk_sync);
+        dealFriendToMq(taskId, hashSet, SyncTaskStatusEnum.friend_clerk_sync);
 	}
 
 	@Override
@@ -798,4 +798,45 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
         HashSet<String> hashSet = (HashSet<String>) dealLogList.stream().map(TabHaobanPreDealLog::getDataId).collect(Collectors.toSet());
         dealDepartmentToMq(taskId, hashSet, SyncTaskStatusEnum.friend_clerk_sync);
 	}
+	
+	 /**
+     * 放入mq处理部门数据
+     *
+     * @param taskId
+     * @param dealList
+     */
+    private void dealFriendToMq(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();
+//            }
+//        });
+
+        List<String> listRet = dealList.stream().map(relationId -> {
+            DealParamMqDTO dealParamMqDTO = new DealParamMqDTO();
+            dealParamMqDTO.setTaskId(taskId);
+            dealParamMqDTO.setData(relationId);
+            dealParamMqDTO.setType(syncTaskStatusEnum.getVal());
+            return JSONObject.toJSONString(dealParamMqDTO);
+        }).collect(Collectors.toList());
+
+        GicMQClient clientInstance = GICMQClientUtil.getClientInstance();
+        try {
+            clientInstance.sendBatchMessages("friendSyncDealMq", listRet);
+        } catch (Exception e) {
+            logger.info("发送失败:{},{}", taskId, JSONObject.toJSONString(listRet));
+            e.printStackTrace();
+        }
+    }
 }