增加修改楼栋推送

1098226878

2021-09-01 cae9dbb98d3e08d1fc03f48fb78700a902aacb08

 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);
            saveHcGovLog(massage,communityId,topic,objId);
            KafkaFactory.sendKafkaMessage(topic,massage.toJSONString());
            saveHcGovLog(massage,communityId,topic,objId,secure);
        } catch (Exception e) {
            e.printStackTrace();
        }