package com.thhy.screen.config;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.thhy.general.common.BasicResult;
import com.thhy.general.common.enums.ProListenType;
import com.thhy.screen.modules.biz.agv.entity.AgvStateHistory;
import com.thhy.screen.modules.biz.agv.mapper.AgvStateHistoryMapper;
import com.thhy.screen.modules.biz.bigscreen.controller.ProListenSocketServer;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttMessage;
import org.redisson.api.RedissonClient;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.websocket.Session;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CopyOnWriteArraySet;

@Component
public class OnMqttCallBack implements MqttCallback {

    private Logger logger = LoggerFactory.getLogger("Mqtt-jianting");

    @Autowired
    private RedissonClient redissonClient;

    @Autowired
    private AgvStateHistoryMapper historyMapper;

    @Override
    public void connectionLost(Throwable throwable) {
        System.out.println("丢失连接");
    }

    @Override
    public void messageArrived(String s, MqttMessage mqttMessage) throws Exception {
        System.out.println(s+"================="+mqttMessage.toString());
        System.out.println(s+"================="+mqttMessage.toString());
        logger.info("接收到数据"+mqttMessage.toString());
        /*if("agvmqtt".equals(s)){
            CopyOnWriteArraySet<Session> SESSIONS = ProListenSocketServer.SESSIONS;
            SESSIONS.forEach(session ->{
                try {
                    List<JSONObject> jsonObjectList = new ArrayList<>();
                    JSONObject jsonObject = JSON.parseObject(mqttMessage.toString());
                    AgvStateHistory agvStateHistory = JSON.parseObject(mqttMessage.toString(),AgvStateHistory.class);
                    historyMapper.insert(agvStateHistory);
                    logger.info("保存成功"+mqttMessage.toString());
                    jsonObject.put("mod", ProListenType.AGVINFO);
                    jsonObjectList.add(jsonObject);
                    if (session.isOpen()) {
                        session.getBasicRemote().sendText(JSON.toJSONString(BasicResult.success(jsonObjectList)));
                        logger.info("成功推送AGV消息到生产监控大屏"+session.getId()+"___"+session.getRequestURI().getHost());
                    }
                } catch (IOException e) {
                    throw new RuntimeException(e);
                }
            });
        }*/
    }

    @Override
    public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {
        System.out.println("sssss");
    }
}