完善修改楼栋接口

1098226878

2021-09-01 4414e39a60a6f3d24e4217dfd2e2ab048621c66a

 service-job/src/main/java/com/java110/job/adapt/hcGov/asyn/impl/BaseHcGovSendAsynImpl.java

@@ -9,6 +9,7 @@
import com.java110.job.adapt.hcGov.asyn.BaseHcGovSendAsyn;
import com.java110.po.hcGovTranslate.HcGovTranslatePo;
import com.java110.po.hcGovTranslateDetail.HcGovTranslateDetailPo;
import com.java110.utils.cache.MappingCache;
import com.java110.utils.kafka.KafkaFactory;
import com.java110.utils.util.Assert;
import com.java110.utils.util.DateUtil;
@@ -16,6 +17,7 @@
import org.springframework.stereotype.Service;

import java.util.UUID;

@Service
public class BaseHcGovSendAsynImpl implements BaseHcGovSendAsyn {

@@ -104,8 +106,10 @@

    public void sendKafka(String topic,JSONObject massage,String communityId,String objId,String secure) {
        try {
            if ("TRUE".equals(MappingCache.getValue(HcGovConstant.GOV_DOMAIN, HcGovConstant.GOV_SWITCH))) {
            KafkaFactory.sendKafkaMessage(topic,massage.toJSONString());
            saveHcGovLog(massage,communityId,topic,objId,secure);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }