require(["jquery", "ipu-stomp"], function($, IpuStomp) {
  //	var baseUrl = "ws://localhost:7100/stomp";
    var baseUrl = "ws://47.105.160.21:7100/stomp";
    var login = "empty_account1";
    var passcode = "123456";
    var host = "";
  
    var client;
    //为发送者input绑定onchange事件
    $("#userId").on("change", function(e) {
      $("#userId").val(e.target.value);
    })
    
    var callbacks = {};
    callbacks.onConnected = function(msg){
      console.log("连接成功：" + msg);
      alert("连接成功：" + msg);
      $("#connBtn").val("断开连接");
      $("#connBtn").attr("id", "disconnBtn");
      $("#userId").attr("disabled", "disabled");
    }
      callbacks.onFailure = function(msg){
      console.log("连接失败：" + msg);
      alert("连接失败：" + msg);
    }
  
    $("#connBtn").on("click", function(e) {
      if (typeof (WebSocket) == "undefined") {
        console.log("您的浏览器不支持WebSocket");
      } else {
        console.log("您的浏览器支持WebSocket");
        //实例化WebSocket对象，指定要连接的服务器地址与端口  建立连接
        //等同于socket = new WebSocket("ws://localhost:8888/xxxx/im/25");
        if (!client || !client.connected()) {
          //检查用户ID
          if (!$("#userId").val()) {
            alert("请填写用户名")
            return;
          }
          client = IpuStomp.connect({url:baseUrl,name:login,passcode:passcode,host:host}, callbacks);
          client.setTopicPath("topic");
          
        } else {
          client.disconnect();
          subscription && subscription.unsubscribe();
          $("#disconnBtn").val("连接服务器");
          $("#disconnBtn").attr("id", "connBtn");
          $("#userId").removeAttr("disabled");
        }
      }
    });
    var subscription;
    var path = [
    ];
    $("#receBtn").on(
			"click",
			function(e) {
				console.log(subscription)
				if (subscription) {
					//如果已经订阅
					$("#receBtn").val("订阅");
					$("#receTopic").removeAttr("disabled");
					subscription.unsubscribe();
					subscription = null;
				} else {

					//校验连接状态
					if (!client || !client.connected()) {
						alert("服务未连接")
						return;
					}

					//校验订阅频道
					if (!$("#receTopic").val()) {
						alert("请填写订阅频道")
						return;
					}
					//订阅一个目的地
					//STOMP消息的body必须为字符串
					subscription = client.subscribe($("#receTopic").val(), function(msg) {
            //发现消息进入，开始处理前端触发逻辑
            console.log(msg.body)
						console.log(JSON.parse(msg.body))
						var msgObj = JSON.parse(msg.body)
						var newMsg = new Date().toLocaleString() + "\n"
								+ msgObj.userId + " : " + msgObj.contentText
            var oldMsg = $("#contentText").val()
            console.log(msgObj.contentText)
            path.push([msgObj.contentText.R,msgObj.contentText.Q])
            var map = new AMap.Map("container", {
                resizeEnable: true,
                center: [116.397428, 39.90923],
                zoom: 13
            });
            var marker = new AMap.Marker({
                position: map.getCenter(),
                icon: 'img/mark_bs.png',
                offset: new AMap.Pixel(-13, -30),
                // // 设置是否可以拖拽
                // draggable: true,
                // cursor: 'move',
                // // 设置拖拽效果
                // raiseOnDrag: true
            });
            var polyline = new AMap.Polyline({
              path: path,
              isOutline: true,
              outlineColor: '#ffeeff',
              borderWeight: 3,
              strokeColor: "#3366FF", 
              strokeOpacity: 1,
              strokeWeight: 6,
              // 折线样式还支持 'dashed'
              strokeStyle: "solid",
              // strokeStyle是dashed时有效
              strokeDasharray: [10, 5],
              lineJoin: 'round',
              lineCap: 'round',
              zIndex: 50,
          })
          marker.setPosition([msgObj.contentText.R,msgObj.contentText.Q]);
          marker.setMap(map);
          polyline.setMap(map)
          // 缩放地图到合适的视野级别
          // map.setFitView([ polyline ])
					});
					$("#receBtn").val("取消订阅");
					$("#receTopic").attr("disabled", "disabled");
				}
			})
  
   
  });