优化mqtt生产者取消消费者订阅

‘liusuyi’

2023-10-08 157c26f5188c7ed62a4547f7e3b5a5a3e3ed7729

 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一键报警Service业务层处理
@@ -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());
@@ -71,41 +42,9 @@
    }

    private void printLog(ArdAlarmApponekey ardAlarmApponekey) {
        log.info("收到数据:" + "【ID】" + ardAlarmApponekey.getId() + "【userId】" + ardAlarmApponekey.getUserId()
        log.debug("收到数据:" + "【ID】" + ardAlarmApponekey.getId() + "【userId】" + ardAlarmApponekey.getUserId()
                + "【经度】" + ardAlarmApponekey.getLongitude() + "【纬度】" + ardAlarmApponekey.getLatitude()
                + "【高层】" + 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);
    }
}