blame | history | patch | commit | commitdiff | ignore whitespace
cjl
2023-10-10 495fad8166b5952c013aea275243cb9ee6e7fa2a 
 screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java


@@ -1,7 +1,10 @@


/*


package com.moral.api.kafka.consumer;




import com.alibaba.fastjson.JSONObject;


import com.alibaba.fastjson.JSON;


import com.moral.api.service.*;


import com.moral.constant.KafkaConstants;


import com.moral.constant.RedisConstants;


import lombok.extern.slf4j.Slf4j;


import org.apache.kafka.clients.consumer.ConsumerRecord;


import org.springframework.beans.factory.annotation.Autowired;


@@ -11,16 +14,9 @@


import org.springframework.stereotype.Component;


import org.springframework.util.ObjectUtils;




import java.text.DecimalFormat;


import java.text.SimpleDateFormat;


import java.util.Date;


import java.util.HashMap;


import java.util.Iterator;


import java.util.Map;




import com.alibaba.fastjson.JSON;


import com.moral.constant.KafkaConstants;


import com.moral.constant.RedisConstants;








@@ -107,6 +103,7 @@


            String id = map.get("id").toString();


            if (id.equals("71")){


                log.warn(id, msg);


                ack.acknowledge();


                return;


            }


//            SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");


@@ -222,3 +219,4 @@


        }


    }


}


*/