package com.billion.framework.websocket;

import com.billion.common.core.domain.AjaxResult;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.websocket.Session;
import javax.websocket.server.PathParam;
import java.util.Map;

@RestController("/socketController")
public class PostController {

    @GetMapping("/postWebsocket")
    public AjaxResult list(@PathParam("locationCode") String locationCode)
    {
        Map<String, Session> map = WebSocketUsers.getUsers();
        //1、监听kepserver地址 比如：OP.OP1010.START 、OP.OP1020.START 、OP.OP1030.START
        //2、当其中一个点位发生变化时，判断该点位是哪一个工位
        //
        WebSocketUsers.sendMessageToUserByText(map.get(locationCode), "1");

        return AjaxResult.success();
    }


}