优化巡检路线查询sql

mrzcc

2020-02-19 b09e1a8b036553d1e161d127aa738a504593490a

 CommunityService/src/main/java/com/java110/community/kafka/CommunityServiceKafka.java

@@ -1,17 +1,19 @@
package com.java110.community.kafka;

import com.alibaba.fastjson.JSONObject;
import com.java110.common.constant.KafkaConstant;
import com.java110.common.constant.ResponseConstant;
import com.java110.common.constant.StatusConstant;
import com.java110.common.exception.InitConfigDataException;
import com.java110.common.exception.InitDataFlowContextException;
import com.java110.common.kafka.KafkaFactory;
import com.java110.utils.constant.KafkaConstant;
import com.java110.utils.constant.ResponseConstant;
import com.java110.utils.constant.StatusConstant;
import com.java110.utils.exception.InitConfigDataException;
import com.java110.utils.exception.InitDataFlowContextException;
import com.java110.utils.kafka.KafkaFactory;
import com.java110.core.base.controller.BaseController;
import com.java110.core.context.BusinessServiceDataFlow;
import com.java110.core.factory.DataTransactionFactory;
import com.java110.community.smo.ICommunityServiceSMO;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.annotation.KafkaListener;

@@ -24,6 +26,9 @@
 */
public class CommunityServiceKafka extends BaseController {

    private final static Logger logger = LoggerFactory.getLogger(CommunityServiceKafka.class);


    @Autowired
    private ICommunityServiceSMO communityServiceSMOImpl;