package com.ruoyi.utils.qymqtt.newM;

import java.math.BigDecimal;
import java.nio.charset.StandardCharsets;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;
import java.util.Map;

import com.ruoyi.common.utils.spring.SpringUtils;
import com.ruoyi.sy.domain.ArdSyCarLock;
import com.ruoyi.sy.domain.ArdSyCarRtu;
import com.ruoyi.sy.service.ArdSyCarLockService;
import com.ruoyi.sy.service.ArdSyCarRtuService;
import lombok.extern.slf4j.Slf4j;
import org.eclipse.paho.client.mqttv3.IMqttClient;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttMessage;

import com.alibaba.fastjson.JSON;

@Slf4j(topic = "mqttCar")
public class MessageCallback implements MqttCallback  {

	private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

	//注入电子锁Bean
	ArdSyCarRtuService carRtuService = SpringUtils.getBean(ArdSyCarRtuService.class);
	ArdSyCarLockService carLockService = SpringUtils.getBean(ArdSyCarLockService.class);


	@Override//丢失了对服务端的连接后触发的回调
	public void connectionLost(Throwable arg0) {
		// 资源的清理  重连
		System.out.println(arg0.getMessage());
		arg0.printStackTrace();
		System.out.println("丢失了对服务端的连接");
	}

	@Override //消息发布者消息发布完成产生的回调
	public void deliveryComplete(IMqttDeliveryToken token) {
		log.debug("deliveryComplete---------" + token.isComplete());
		int messageId = token.getMessageId();
		String[] topics = token.getTopics();
		String clientId = token.getClient().getClientId();
//        byte[] msg = token.getMessage().getPayload();
		String topicStr = "";
		for(String topic : topics){
			topicStr = topicStr + topic + ",";
		}
		topicStr = topicStr.substring(0, topicStr.length() - 1);
		log.debug("消息发布完成,messageId="+messageId+",topics="+topicStr+",clientId="+clientId);
	}

	@Override//消息订阅者收到消息后触发的回调
	public void messageArrived(String topic, MqttMessage message) throws Exception {
		try {
			log.debug("【车辆锁主题】："+topic+"【车辆锁信息】："+new String(message.getPayload(), StandardCharsets.UTF_8));
			//出来回调数据
			List<ArdSyCarLock> ardSyCarLocks = carLockService.data(new String(message.getPayload(), StandardCharsets.UTF_8));
			//根据topic查询RTUID
			ArdSyCarRtu ardSyCarRtu = carRtuService.subscribeByCarId(topic);
			String RTU = ardSyCarRtu.getId();
			//根据RTUID查询锁
			List<ArdSyCarLock> ardSyCarLockList = carLockService.carLock(RTU);
			for (int i = 0; i < ardSyCarLocks.size(); i++) {
				ArdSyCarLock ardSyCarLockData = ardSyCarLocks.get(i);
				String relay = ardSyCarLockData.getRelay();
				Integer relayInfo = ardSyCarLockData.getRelayInfo();
				String current = ardSyCarLockData.getCurrents();
				Double currentInfo = ardSyCarLockData.getCurrentInfo();
				for (int j = 0; j < ardSyCarLockList.size(); j++) {
					ArdSyCarLock lock = ardSyCarLockList.get(j);
					String relay1 = lock.getRelay();
					String current1 = lock.getCurrents();
					Integer relayInfo1 = lock.getRelayInfo();
					Double currentInfo1 = lock.getCurrentInfo();
					Boolean upd = false;
					if(relay.equals(relay1)){
						if(!relayInfo.equals(relayInfo1)){
							lock.setRelayInfo(relayInfo);
							upd = true;
						}
					}
					if(current.equals(current1)){
						if(!currentInfo.equals(currentInfo1)){
							lock.setCurrentInfo(currentInfo);
							upd = true;
						}
					}
					if(upd){
						int num = carLockService.updLock(lock);
//                        log.debug("修改"+num+"数据");
					}
				}
			}
		} catch (Exception e) {
			log.debug("车辆电磁锁处理mqtt消息异常:" + e);
		}

	}

}