From 157c26f5188c7ed62a4547f7e3b5a5a3e3ed7729 Mon Sep 17 00:00:00 2001
From: ‘liusuyi’ <1951119284@qq.com>
Date: 星期日, 08 十月 2023 09:40:47 +0800
Subject: [PATCH] 优化mqtt生产者取消消费者订阅

---
 src/main/java/com/ard/alarm/apponekey/service/impl/ArdAlarmApponekeyServiceImpl.java |   65 +-------------------------------
 1 files changed, 2 insertions(+), 63 deletions(-)

diff --git a/src/main/java/com/ard/alarm/apponekey/service/impl/ArdAlarmApponekeyServiceImpl.java b/src/main/java/com/ard/alarm/apponekey/service/impl/ArdAlarmApponekeyServiceImpl.java
index c958173..dba5f71 100644
--- a/src/main/java/com/ard/alarm/apponekey/service/impl/ArdAlarmApponekeyServiceImpl.java
+++ b/src/main/java/com/ard/alarm/apponekey/service/impl/ArdAlarmApponekeyServiceImpl.java
@@ -1,20 +1,15 @@
 package com.ard.alarm.apponekey.service.impl;
 
 import java.util.Date;
-import java.util.List;
 
 import com.alibaba.fastjson2.JSON;
-import com.ard.utils.mqtt.MqttConsumer;
+import com.ard.utils.mqtt.MqttProducer;
 import com.ard.utils.uuid.IdUtils;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
-import com.ard.alarm.apponekey.mapper.ArdAlarmApponekeyMapper;
 import com.ard.alarm.apponekey.domain.ArdAlarmApponekey;
 import com.ard.alarm.apponekey.service.IArdAlarmApponekeyService;
 
-import javax.annotation.Resource;
-
-import static jdk.nashorn.internal.runtime.regexp.joni.Config.log;
 
 /**
  * app涓�閿姤璀ervice涓氬姟灞傚鐞�
@@ -25,30 +20,6 @@
 @Service
 @Slf4j(topic = "apponekey")
 public class ArdAlarmApponekeyServiceImpl implements IArdAlarmApponekeyService {
-    @Resource
-    private ArdAlarmApponekeyMapper ardAlarmApponekeyMapper;
-
-    /**
-     * 鏌ヨapp涓�閿姤璀�
-     *
-     * @param id app涓�閿姤璀︿富閿�
-     * @return app涓�閿姤璀�
-     */
-    @Override
-    public ArdAlarmApponekey selectArdAlarmApponekeyById(String id) {
-        return ardAlarmApponekeyMapper.selectArdAlarmApponekeyById(id);
-    }
-
-    /**
-     * 鏌ヨapp涓�閿姤璀﹀垪琛�
-     *
-     * @param ardAlarmApponekey app涓�閿姤璀�
-     * @return app涓�閿姤璀�
-     */
-    @Override
-    public List<ArdAlarmApponekey> selectArdAlarmApponekeyList(ArdAlarmApponekey ardAlarmApponekey) {
-        return ardAlarmApponekeyMapper.selectArdAlarmApponekeyList(ardAlarmApponekey);
-    }
 
     /**
      * 鏂板app涓�閿姤璀�
@@ -62,7 +33,7 @@
             ardAlarmApponekey.setId(IdUtils.fastSimpleUUID());
             ardAlarmApponekey.setCreateTime(new Date());
             printLog(ardAlarmApponekey);
-            MqttConsumer.publish(2, false, "apponekey", JSON.toJSONString(ardAlarmApponekey));
+            MqttProducer.publish(2, false, "apponekey", JSON.toJSONString(ardAlarmApponekey));
             return 1;
         } catch (Exception ex) {
             log.error("涓�閿姤璀﹀鐞嗗紓甯�:" + ex.getMessage());
@@ -76,36 +47,4 @@
                 + "銆愰珮灞傘��" + ardAlarmApponekey.getAltitude() + "銆愬垱寤烘椂闂淬��" + ardAlarmApponekey.getCreateTime());
     }
 
-    /**
-     * 淇敼app涓�閿姤璀�
-     *
-     * @param ardAlarmApponekey app涓�閿姤璀�
-     * @return 缁撴灉
-     */
-    @Override
-    public int updateArdAlarmApponekey(ArdAlarmApponekey ardAlarmApponekey) {
-        return ardAlarmApponekeyMapper.updateArdAlarmApponekey(ardAlarmApponekey);
-    }
-
-    /**
-     * 鎵归噺鍒犻櫎app涓�閿姤璀�
-     *
-     * @param ids 闇�瑕佸垹闄ょ殑app涓�閿姤璀︿富閿�
-     * @return 缁撴灉
-     */
-    @Override
-    public int deleteArdAlarmApponekeyByIds(String[] ids) {
-        return ardAlarmApponekeyMapper.deleteArdAlarmApponekeyByIds(ids);
-    }
-
-    /**
-     * 鍒犻櫎app涓�閿姤璀︿俊鎭�
-     *
-     * @param id app涓�閿姤璀︿富閿�
-     * @return 缁撴灉
-     */
-    @Override
-    public int deleteArdAlarmApponekeyById(String id) {
-        return ardAlarmApponekeyMapper.deleteArdAlarmApponekeyById(id);
-    }
 }

--
Gitblit v1.9.3