From cae9dbb98d3e08d1fc03f48fb78700a902aacb08 Mon Sep 17 00:00:00 2001
From: 1098226878 <1098226878@qq.com>
Date: 星期三, 01 九月 2021 14:21:09 +0800
Subject: [PATCH] 增加修改楼栋推送
---
service-job/src/main/java/com/java110/job/adapt/hcGov/asyn/impl/BaseHcGovSendAsynImpl.java | 8 ++++----
1 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/service-job/src/main/java/com/java110/job/adapt/hcGov/asyn/impl/BaseHcGovSendAsynImpl.java b/service-job/src/main/java/com/java110/job/adapt/hcGov/asyn/impl/BaseHcGovSendAsynImpl.java
index 2ba59e7..13d6e41 100644
--- a/service-job/src/main/java/com/java110/job/adapt/hcGov/asyn/impl/BaseHcGovSendAsynImpl.java
+++ b/service-job/src/main/java/com/java110/job/adapt/hcGov/asyn/impl/BaseHcGovSendAsynImpl.java
@@ -38,7 +38,7 @@
}
- protected void saveHcGovLog(JSONObject paramIn,String communityId,String topic,String objId) {
+ protected void saveHcGovLog(JSONObject paramIn,String communityId,String topic,String objId,String secure) {
Assert.hasKeyAndValue(paramIn, "header", "璇锋眰鎶ユ枃涓湭鍖呭惈header");
Assert.hasKeyAndValue(paramIn, "body", "璇锋眰鎶ユ枃涓湭鍖呭惈body");
JSONObject heard = paramIn.getJSONObject("header");
@@ -49,7 +49,7 @@
hcGovTranslatePo.setTranId(heard.getString("tranId"));
hcGovTranslatePo.setCommunityId(communityId);
hcGovTranslatePo.setGovTopic(topic);
- hcGovTranslatePo.setCode(HcGovConstant.COMMUNITY_SECURE);
+ hcGovTranslatePo.setCode(secure);
hcGovTranslatePo.setSendCount("1");
hcGovTranslatePo.setExtCommunityId(heard.getString("extCommunityId"));
hcGovTranslatePo.setObjId(objId);
@@ -74,10 +74,10 @@
}
}
- public void sendKafka(String topic,JSONObject massage,String communityId,String objId) {
+ public void sendKafka(String topic,JSONObject massage,String communityId,String objId,String secure) {
try {
KafkaFactory.sendKafkaMessage(topic,massage.toJSONString());
- saveHcGovLog(massage,communityId,topic,objId);
+ saveHcGovLog(massage,communityId,topic,objId,secure);
} catch (Exception e) {
e.printStackTrace();
}
--
Gitblit v1.8.0