package com.mes.job;

import cn.hutool.json.JSONObject;
import com.mes.downworkstation.entity.DownWorkstation;
import com.mes.downworkstation.service.DownWorkstationService;
import com.mes.tools.WebSocketServer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

@Slf4j
@Component
public class Downpush {


    @Autowired
    private DownWorkstationService downWorkstationService;
    @Scheduled(fixedDelay = 1000)
    public void Downpush() {


        JSONObject jsonObject = new JSONObject();
        JSONObject jsonObject2 = new JSONObject();
        JSONObject jsonObject3 = new JSONObject();

        List<DownWorkstation> data = downWorkstationService.getoneDownWorkstations(1,6);
        List<Map<String, Object>> glassinfodata = downWorkstationService.getTotalGlassDimensionsByWorkstation(1,3);
        List<Map<String, Object>> glassinfodata2 = downWorkstationService.getTotalGlassDimensionsByWorkstation(4,6);
        jsonObject.append("params",data);
        jsonObject2.append("glassinfo",glassinfodata);
        jsonObject3.append("glassinfo2",glassinfodata2);
        log.info(jsonObject.toString());
        ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("unloadglass");
        ArrayList<WebSocketServer> sendwServer2 = WebSocketServer.sessionMap.get("unloadglass2");
        ArrayList<WebSocketServer> sendwServer3 = WebSocketServer.sessionMap.get("unloadglass3");
        //  log.info(sendwServer.toString());
        if (sendwServer != null) {
            for (WebSocketServer webserver : sendwServer) {

                if (webserver != null&&webserver.session.isOpen()) {
                    webserver.sendMessage(jsonObject.toString());
                }
            }
        }
        if (sendwServer2 != null) {
            for (WebSocketServer webserver : sendwServer2) {

                if (webserver != null&&webserver.session.isOpen()) {
                    webserver.sendMessage(jsonObject2.toString());
                }
            }
        }
        if (sendwServer3 != null) {
            for (WebSocketServer webserver : sendwServer3) {

                if (webserver != null&&webserver.session.isOpen()) {
                    webserver.sendMessage(jsonObject3.toString());
                }
            }
        }

    }
}