From bd8b398d7bb4b5691a0c52e2641f710eca90bf25 Mon Sep 17 00:00:00 2001
From: zrj <646384940@qq.com>
Date: Tue, 30 Jul 2024 15:48:22 +0800
Subject: [PATCH] 新增南科院预警接口，新增南科院实时测点输入及回调，新增定时任务实时测点输入
---
skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/rabbitmq/MyRabbitReceiver.java | 72 ++++++++++++++++++------------------
1 files changed, 36 insertions(+), 36 deletions(-)
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/rabbitmq/MyRabbitReceiver.java b/skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/rabbitmq/MyRabbitReceiver.java
index 996f16d..6b6d6d9 100644
--- a/skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/rabbitmq/MyRabbitReceiver.java
+++ b/skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/rabbitmq/MyRabbitReceiver.java
@@ -1,36 +1,36 @@
-package cn.gistack.nky.rabbitmq;
-
-import cn.gistack.nky.entity.AlarmGet;
-import cn.gistack.nky.service.IAlarmGetService;
-import com.alibaba.fastjson.JSONObject;
-import lombok.AllArgsConstructor;
-import org.springblade.core.tool.utils.DateUtil;
-import org.springframework.amqp.core.Message;
-import org.springframework.amqp.rabbit.annotation.RabbitListener;
-import org.springframework.stereotype.Component;
-
-import java.text.SimpleDateFormat;
-
-/**
- * @PROJECT_NAME: skjcmanager
- * @DESCRIPTION: 接收南科院消息队列
- * @USER: aix
- * @DATE: 2023/8/3 15:54
- */
-@Component
-@AllArgsConstructor
-public class MyRabbitReceiver {
- private final IAlarmGetService alarmGetService;
-
- @RabbitListener(queues = "alarm")
- public void processMessage(Message message) {
- System.out.println("收到消息"+new String(message.getBody()));
- AlarmGet alarmGet = JSONObject.parseObject(new String(message.getBody()), AlarmGet.class);
-
- SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
- String format = sdf.format(DateUtil.now());
- alarmGet.setCreateTime(format);
- alarmGetService.save(alarmGet);
- }
-
-}
+//package cn.gistack.nky.rabbitmq;
+//
+//import cn.gistack.nky.entity.AlarmGet;
+//import cn.gistack.nky.service.IAlarmGetService;
+//import com.alibaba.fastjson.JSONObject;
+//import lombok.AllArgsConstructor;
+//import org.springblade.core.tool.utils.DateUtil;
+//import org.springframework.amqp.core.Message;
+//import org.springframework.amqp.rabbit.annotation.RabbitListener;
+//import org.springframework.stereotype.Component;
+//
+//import java.text.SimpleDateFormat;
+//
+///**
+// * @PROJECT_NAME: skjcmanager
+// * @DESCRIPTION: 接收南科院消息队列
+// * @USER: aix
+// * @DATE: 2023/8/3 15:54
+// */
+//@Component
+//@AllArgsConstructor
+//public class MyRabbitReceiver {
+// private final IAlarmGetService alarmGetService;
+//
+// @RabbitListener(queues = "alarm")
+// public void processMessage(Message message) {
+// System.out.println("收到消息"+new String(message.getBody()));
+// AlarmGet alarmGet = JSONObject.parseObject(new String(message.getBody()), AlarmGet.class);
+//
+// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+// String format = sdf.format(DateUtil.now());
+// alarmGet.setCreateTime(format);
+// alarmGetService.save(alarmGet);
+// }
+//
+//}
--
Gitblit v1.9.3