From 92ac4f9f94141b2b0f86604104cbd82f73bb87f3 Mon Sep 17 00:00:00 2001 From: cjl <276999030@qq.com> Date: Thu, 03 Aug 2023 15:12:43 +0800 Subject: [PATCH] test:测试提交 --- screen-api/src/main/java/com/moral/api/exception/consumer/CruiserDataConsumer.java | 18 +++++++++--------- 1 files changed, 9 insertions(+), 9 deletions(-) diff --git a/screen-api/src/main/java/com/moral/api/exception/consumer/CruiserDataConsumer.java b/screen-api/src/main/java/com/moral/api/exception/consumer/CruiserDataConsumer.java index ebdfc28..2fb4d1e 100644 --- a/screen-api/src/main/java/com/moral/api/exception/consumer/CruiserDataConsumer.java +++ b/screen-api/src/main/java/com/moral/api/exception/consumer/CruiserDataConsumer.java @@ -1,4 +1,4 @@ -/* + package com.moral.api.exception.consumer; import com.moral.api.utils.AdjustDataUtils; @@ -26,14 +26,14 @@ import com.moral.api.websocket.CruiserWebSocketServer; import com.moral.constant.KafkaConstants; -*/ + /* * ������������������������ - * *//* + * */ -@Component +//@Component @Slf4j -public class CruiserDataConsumer implements ConsumerSeekAware { +public class CruiserDataConsumer implements ConsumerSeekAware { @KafkaListener(topics = KafkaConstants.CRUISER_TOPIC_SECOND, containerFactory = "cruiserDataListenerFactory") public void listenSecondSpecial(ConsumerRecord<String, String> record) throws Exception { @@ -67,9 +67,9 @@ continue; } Double sourceDataD = Double.valueOf(String.valueOf(data.get(code))); - */ -/*BigDecimal bg = new BigDecimal(sourceDataD); - bg = bg.setScale(2, BigDecimal.ROUND_FLOOR);*//* + + BigDecimal bg = new BigDecimal(sourceDataD); + bg = bg.setScale(2, BigDecimal.ROUND_FLOOR); String sourceData = String.valueOf(sourceDataD); //������������ @@ -117,4 +117,4 @@ } } -*/ + -- Gitblit v1.8.0