package cn.mb.cloud.gateway.controller;


import cn.mb.cloud.gateway.auth.ResultUtil;
import cn.mb.cloud.gateway.util.applets.NettyWebSocketController;
import cn.mb.cloud.gateway.util.echo.NettyChannelMap;
import cn.mb.cloud.gateway.util.echo.NettyServerController;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import io.netty.channel.ChannelHandlerContext;
import org.springframework.web.bind.annotation.*;

import java.util.HashMap;
import java.util.Map;

@RestController
@RequestMapping("/netty")
public class NettyController {


    /**   3.4.5.6
     * 向客户端推送消息
     * @param id
     * @param msg
     */
    @ResponseBody
    @GetMapping("/sendMsgToClient")
    public String sendMsgToClient(String id, Integer type, String msg){
        System.out.println(id+"|"+type+"|"+msg+"!!!!!!!!");
        if(true){//用户端
            String[] split = id.split("_");
            ChannelHandlerContext channel = NettyChannelMap.getData("USER" + split[0]);
            if(null != channel){
                JSONObject jsonObject = new JSONObject();
                jsonObject.put("code", 200);
                jsonObject.put("msg", "SUCCESS");
                jsonObject.put("method", "CLASS");
                Map<String, Object> map = new HashMap<>();
                jsonObject.put("data", map);
                NettyServerController.sendMsgToClient(channel, jsonObject.toJSONString());
                return JSON.toJSONString(ResultUtil.success());
            }
            return JSON.toJSONString(ResultUtil.error("推送失败-----用户id=" + id));

        }
        return JSON.toJSONString(ResultUtil.error("推送失败"));
    }
}