iHotel_student_houtai/src/main/java/com/template/model/mqtt/PushCallback.java

package com.template.model.mqtt;

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.ObjectUtils;
import com.template.common.utils.MessageDecryptUtil;
import com.template.model.pojo.AlarmMessage;
import com.template.model.pojo.HouseLock;
import com.template.model.pojo.HouseNumber;
import com.template.model.pojo.UnlockingRecord;
import com.template.services.impl.AlarmMessageServiceImpl;
import com.template.services.impl.HouseLockServiceImpl;
import com.template.services.impl.HouseNumberServiceImpl;
import com.template.services.impl.UnlockingRecordServiceImpl;
import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.springframework.stereotype.Component;

import java.text.SimpleDateFormat;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.List;

@Slf4j
@Component
public class PushCallback implements MqttCallback {
 
 
    private MqttPushClient client;
    private MqttConfiguration mqttConfiguration;
 
 
    public PushCallback(MqttPushClient client ,MqttConfiguration mqttConfiguration) {
        this.client = client;
        this.mqttConfiguration = mqttConfiguration;
    }
 
    @Override
    public void connectionLost(Throwable cause) {
        /** 连接丢失后，一般在这里面进行重连 **/
        if(client != null) {
            while (true) {
                try {
                    log.info("==============》》》[MQTT] 连接断开，30S之后尝试重连...");
                    Thread.sleep(30000);
//                    MqttPushClient mqttPushClient = new MqttPushClient();
//                    mqttPushClient.connect(mqttConfiguration);
                    if(MqttPushClient.getClient().isConnected()){
                        log.info("=============>>重连成功");
                        break;
                    }
//                    break;
                    //重连
                    client.reconnect();
//                    订阅
//                    client.subscribe();
                } catch (Exception e) {
                    log.error("=============>>>[MQTT] 连接断开，重连失败！<<=============");
                    continue;
                }
            }
        }
//        log.info(cause.getMessage());
//        System.out.println("cause = " + cause);
    }
    @Override

    public void deliveryComplete(IMqttDeliveryToken token) {
        //publish后会执行到这里
        log.info("publish后会执行到这里");
        log.info("pushComplete==============>>>" + token.isComplete());
    }
 
 
    /**
     * 监听对应的主题消息
     * @param topic
     * @param message
     * @throws Exception
     */
    @Override
    public void messageArrived(String topic, MqttMessage message) throws Exception {
        // subscribe后得到的消息会执行到这里面
        String Payload = new String(message.getPayload());
 
        log.info("============》》接收消息主题 : " + topic);
        log.info("============》》接收消息Qos : " + message.getQos());
        log.info("============》》接收消息内容 : " + Payload);
        log.info("============》》接收ID : " + message.getId());
        log.info("接收数据结束 下面可以执行数据处理操作");

        try {

            //实例化入库方法 这里就用到SpringUtil类 来手动的注入
            HouseLockServiceImpl houseLockService = SpringUtil.getBean(HouseLockServiceImpl.class);
            HouseNumberServiceImpl houseNumberService = SpringUtil.getBean(HouseNumberServiceImpl.class);
            UnlockingRecordServiceImpl unlockingRecordService = SpringUtil.getBean(UnlockingRecordServiceImpl.class);
            AlarmMessageServiceImpl alarmMessageService = SpringUtil.getBean(AlarmMessageServiceImpl.class);

            System.out.println("topic:" + topic);
            System.out.println("Qos:" + message.getQos());
            System.out.println("message content:" + new String(message.getPayload()));
            JSONObject s = MessageDecryptUtil.decryptMessage(message.toString(), "6edfcc178c0f415d8e6628238761976f", "2d00b258183146c0a2b19f55250c4596");
            String protocol = s.getString("protocol");

//					设备消息上报
            if ("2".equals(protocol)) {
                UnlockingRecord unlockingRecord = new UnlockingRecord();
                unlockingRecord.setType("消息类型");
                String data = s.getString("data");
                System.out.println("data = " + data);
                JSONObject jsonObject = JSONObject.parseObject(data);
                System.out.println("jsonObject = " + jsonObject);
//						结果
                String result = jsonObject.getString("result");
//						时间
                String messageTime = jsonObject.getString("messageTime");
//						房间luid
                String luid = jsonObject.getString("luid");
//						找到房间号
                LambdaQueryWrapper<HouseLock> WrapperHL = new LambdaQueryWrapper<>();
                WrapperHL.eq(HouseLock::getEquipmentType, luid);
                List<HouseLock> list = houseLockService.list(WrapperHL);
                if (ObjectUtils.isNotEmpty(list) && list.size() > 0) {
                    HouseLock houseLock = list.get(0);
                    Integer houseNumberId = houseLock.getHouseNumberId();
                    HouseNumber byId = houseNumberService.getById(houseNumberId);
                    if (ObjectUtils.isNotEmpty(byId)) {
                        String roomNumber = byId.getRoomNumber();
                        unlockingRecord.setRoomNumber(roomNumber);
                        unlockingRecord.setHouseNumberId(houseNumberId);
                    }
                }

//						消息类型
                String messageType = jsonObject.getString("messageType");

                SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                String format = sdf.format(Long.valueOf(messageTime));
                unlockingRecord.setDateTime(format);


                if ("1".equals(messageType)) {
//密码开锁
                    unlockingRecord.setUnlockType("密码开锁");

                } else if ("2".equals(messageType)) {
//							远程开锁

                    unlockingRecord.setUnlockType("远程开锁");

                } else if ("3".equals(messageType)) {
//无网络密码开锁
                    unlockingRecord.setUnlockType("无网络密码开锁");
                } else if ("5".equals(messageType)) {
//人脸开锁
                    unlockingRecord.setUnlockType("人脸开锁");
                } else if ("10".equals(messageType)) {
//							电池电量更新
                    unlockingRecord.setUnlockType("电池电量更新");
                }
                DateTimeFormatter dateTimeFormatter1 = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
                unlockingRecord.setCreateTime(LocalDateTime.now().format(dateTimeFormatter1));
                unlockingRecord.setUpdateTime(LocalDateTime.now().format(dateTimeFormatter1));
                unlockingRecord.setCreateUser("1");
                unlockingRecord.setUpdateUser("1");

                unlockingRecordService.getSave(unlockingRecord);

            } else if ("3".equals(protocol)) {
                AlarmMessage alarmMessage = new AlarmMessage();
                String data = s.getString("data");
                JSONObject jsonObject = JSONObject.parseObject(data);

                //						消息类型
                String messageType = jsonObject.getString("messageType");

                //						时间
                String messageTime = jsonObject.getString("messageTime");
                SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                String format = sdf.format(Long.valueOf(messageTime));
                alarmMessage.setMessageTime(format);

//						房间luid
                String luid = jsonObject.getString("luid");
//						找到房间号
                LambdaQueryWrapper<HouseLock> WrapperHL = new LambdaQueryWrapper<>();
                WrapperHL.eq(HouseLock::getEquipmentType, luid);
                List<HouseLock> list = houseLockService.list(WrapperHL);
                if (ObjectUtils.isNotEmpty(list) && list.size() > 0) {
                    HouseLock houseLock = list.get(0);
                    Integer houseNumberId = houseLock.getHouseNumberId();
                    HouseNumber byId = houseNumberService.getById(houseNumberId);
                    if (ObjectUtils.isNotEmpty(byId)) {
                        String roomNumber = byId.getRoomNumber();
                        alarmMessage.setRoomNumber(roomNumber);
                    }
                }


                if ("5".equals(messageType)) {
//							低电量
                    alarmMessage.setMessageType("低电量");

                } else if ("1".equals(messageType)) {
                    alarmMessage.setMessageType("密码错误（连续失败五次）");
                } else if ("4".equals(messageType)) {
                    alarmMessage.setMessageType("防拆告警");
                }

                DateTimeFormatter dateTimeFormatter1 = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");
                alarmMessage.setCreateTime(LocalDateTime.now().format(dateTimeFormatter1));
                alarmMessage.setUpdateTime(LocalDateTime.now().format(dateTimeFormatter1));
                alarmMessage.setCreateUser("1");
                alarmMessage.setUpdateUser("1");

                alarmMessageService.getSave(alarmMessage);


        }
        }catch (Exception e){
            e.printStackTrace();
        }




    }
}