From 858581a3d96851222754f7e25da3590628e12cd5 Mon Sep 17 00:00:00 2001
From: 1098226878 <1098226878@qq.com>
Date: 星期六, 11 九月 2021 14:27:45 +0800
Subject: [PATCH] 完善协议
---
service-job/src/main/java/com/java110/job/adapt/hcGov/staff/AddStaffToHcGovAdapt.java | 6 +++---
1 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/service-job/src/main/java/com/java110/job/adapt/hcGov/staff/AddStaffToHcGovAdapt.java b/service-job/src/main/java/com/java110/job/adapt/hcGov/staff/AddStaffToHcGovAdapt.java
index 02fa8e3..467fffc 100644
--- a/service-job/src/main/java/com/java110/job/adapt/hcGov/staff/AddStaffToHcGovAdapt.java
+++ b/service-job/src/main/java/com/java110/job/adapt/hcGov/staff/AddStaffToHcGovAdapt.java
@@ -111,7 +111,7 @@
communityMemberDto.setMemberId(SoreId);
List<CommunityMemberDto> communityMemberDtos = communityInnerServiceSMOImpl.getCommunityMembers(communityMemberDto);
JSONArray extCommunityId = new JSONArray();
- //
+ //鑾峰彇鍟嗘埛瀵瑰簲鎵�鏈夊皬鍖虹殑澶栭儴缂栫爜
getCommunityExtId(communityMemberDtos, extCommunityId);
if (extCommunityId == null || extCommunityId.size() < 1) {
@@ -133,8 +133,8 @@
body.put("staffInfo", getCarateStaffInfo(userPo));
- JSONObject kafkaData = baseHcGovSendAsynImpl.createHeadersOrBody(body, extCommunityId.getString(0), ACTION_TYPE, HcGovConstant.COMMUNITY_SECURE);
- baseHcGovSendAsynImpl.sendKafka(HcGovConstant.GOV_TOPIC, kafkaData, extCommunityId.getString(0), SoreId, HcGovConstant.COMMUNITY_SECURE);
+ JSONObject kafkaData = baseHcGovSendAsynImpl.createHeadersOrBody(body, "622021090866160001", ACTION_TYPE, HcGovConstant.COMMUNITY_SECURE);
+ baseHcGovSendAsynImpl.sendKafka(HcGovConstant.GOV_TOPIC, kafkaData, "622021090866160001", SoreId, HcGovConstant.COMMUNITY_SECURE);
}
public void getCommunityExtId(List<CommunityMemberDto> communityMemberDtos, JSONArray extCommunityId) {
--
Gitblit v1.8.0