处理同步到队列

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

@@ -348,6 +348,7 @@ 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);
@@ -361,6 +362,22 @@ public class DealSyncOperationApiServiceImpl implements DealSyncOperationApiServ
                 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("departmentSyncDealMq", listRet);
+        } catch (Exception e) {
+            logger.info("发送失败:{},{}", taskId, JSONObject.toJSONString(listRet));
+            e.printStackTrace();
+        }
     }
 
 

haoban-manage3-service/src/test/java/ServiceTest.java

@@ -166,7 +166,7 @@ public void sendMessage() {
     @Test
     public void extensionList() {
 
-        String s = qywxUserApiService.listSelfExternalUserid("ww9ede832a84b7ae5f", "01YQ-pcdYzF3K0So8uCFfkB5i8D5EBW7KcVB4qA8Ktk", "qiuwenmin");
+        String s = qywxUserApiService.listSelfExternalUserid("ww9ede832a84b7ae5f", "01YQ-pcdYzF3K0So8uCFfkB5i8D5EBW7KcVB4qA8Ktk", "de2c33f2e8924ff884e0073ca2f2f711");
         System.out.println(JSONObject.toJSONString(s));
     }