SystemDev
/
FCC


			
							123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131
							@*@page
    @model Applications.UniversalApi_WebConsole_App.Views.TankDetails.TestModel
    @{
    }*@

@{
   // Layout = null;
}

<script src="~/js/mqtt.min.js"></script>
<script src="~/js/Chart.bundle.js"></script>
<script src="~/js/jquery-3.4.1.min.js"></script>
<body style="width:1250px;height:780px;background-color:aqua">
    <div id="test_div" style=""> </div>
</body>
<script>

    //$(document).ready(function () {
    var hostname = 'localhost', //'192.168.1.2',
        port = 8384,
        clientId = 'mqttjs_' + (Math.random() * 1000000).toString(),
        timeout = 5000,
        keepAlive = 100,
        cleanSession = false,
        mqttVersion = 3,
        ssl = false;

    var options = {
        //mqtt客户端的id，这里面应该还可以加上其他参数，具体看官方文档
        clientId: 'mqttjs_' + (Math.random() * 1000000).toString(),
        timeout: timeout,
        useSSL: false
    }
    //浏览器采用websocket协议，host主机地址为192.168.0.200，端口为9001，路径为/mqtt
    //var client = mqtt.connect("ws://localhost:8384/mqtt", options); // you add a ws:// url here
    var client = mqtt.connect("ws://localhost:8384/mqtt", options);
    ////建立连接
    client.on('connect',
        function () {
            var a = document.getElementById("testmqqt");
            if (a != null) a.innerHTML = "connected";
            //订阅主题 presence
            client.subscribe('/sys/VeederRoot_ATG_Console_Tcp/VeederRoot_ATG_Console.Handler/thing/service/GetTankInventoryAsync_reply',
                function (err) {
                    if (!err) {

                        console.log("Subscribe TankReadig success");
                        //client.publish('/sys/VeederRoot_ATG_Console_Tcp/VeederRoot_ATG_Console.Handler/thing/service/GetTankReadingsAsync');
                    } else {
                        //打印错误
                        if (a != null) a.innerHTML = err;
                    }
                });
            client.subscribe('/sys/VeederRoot_ATG_Console_Tcp/VeederRoot_ATG_Console.Handler/thing/service/GetTanksAsync_reply',
                function (err) {
                    if (!err) {
                        console.log("Subscribe getTAnk success");
                        client.publish('/sys/VeederRoot_ATG_Console_Tcp/VeederRoot_ATG_Console.Handler/thing/service/GetTanksAsync',"[]");
                        //client.publish('/sys/VeederRoot_ATG_Console_Tcp/VeederRoot_ATG_Console.Handler/thing/service/GetTankReadingsAsync');
                    } else {
                        //打印错误
                        if (a != null) a.innerHTML = err;
                    }
                });
        });
    
    //如果连接错误，打印错误
    //如果连接错误，打印错误
    client.on('error',
        function (err) {
            var a = document.getElementById("test_div");
            if (a != null) a.innerHTML = err;
            client.end();
        });

    //如果client订阅主题成功，那么这里就是当接收到自己订阅主题的处理逻辑
    client.on('message',
        function (topic, message) {
            var a = document.getElementById("testmqqt");
            //if (a != null) a.innerHTML = message.toString();
            if (topic == "/sys/VeederRoot_ATG_Console_Tcp/VeederRoot_ATG_Console.Handler/thing/service/GetTankInventoryAsync_reply") {
                //TableRowADD(JSON.parse(message.toString()));
                //GenerateHeadView();
                //GenerateFootView();
                //GenerateTanksView(JSON.parse(message.toString()), totaltanksnumber);
                //TankDataGet(JSON.parse(message.toString()));
            }
            if (topic == "/sys/VeederRoot_ATG_Console_Tcp/VeederRoot_ATG_Console.Handler/thing/service/GetTanksAsync_reply") {
                //TankIDGet(JSON.parse(message.toString()));
                //GenerateFootView();
                //var s = message.toString();
                //GenerateTankView(JSON.parse(message.toString()));
            }
        });

    //function TankDataGet(datas) {
    //    datas.forEach(function(d){
    //        FuelAmount.innerHTML = "实时油量：" + FormatFloat(d.FuelVolume, 0) + "升";
    //        FuelAmount.style = "font-size:16px; color:black;font-weight:bold;height:30px;width:180px;margin-top:16px;margin-left:0px";
    //        FuelVolume.innerHTML = "实时油位：" + FormatFloat(d.FuelHeight, 0) + "mm";
    //        FuelVolume.style = "font-size:16px; color:black;font-weight:bold;height:30px;width:180px;margin-top:6px;margin-left:0px";
    //        RemainingSpace.innerHTML = "剩余空间：" + FormatFloat(d.FuelTCVolume, 0) + "升";
    //        RemainingSpace.style = "font-size:16px; color:black;font-weight:bold;height:30px;width:180px;margin-top:6px;margin-left:0px";
    //        Temperature.innerHTML = "实时油温：" + FormatFloat(d.Temperture, 0) + "℃";
    //        Temperature.style = "font-size:16px; color:black;font-weight:bold;height:30px;width:180px;margin-top:6px;margin-left:0px";
    //        WaterLevel.innerHTML = "实时水位：" + FormatFloat(d.WaterHeight, 0) + "mm";
    //        WaterLevel.style = "font-size:16px; color:black;font-weight:bold;height:30px;width:180px;margin-top:6px;margin-left:0px";
    //    })
    //}
    //})

    //function TankIDGet(message) {
    //    if (message == null) {
    //        console.log("Invalid message got in tanks view");
    //        return;
    //    }

    //    var d = message;
    //    totaltanksnumber = message.length;
    //    for (i = 0; i < totaltanksnumber; ++i) {
    //        currentFuelID = d[i].Product.ProductLabel;
    //        currentFuelKind = d[i].Label;
    //        currentTankID = d[i].TankNumber;

    //        tanknumber["Parameters:"].tanknumber = i;
    //        client.publish('/sys/VeederRoot_ATG_Console_Tcp/VeederRoot_ATG_Console.Handler/thing/service/GetTankInventoryAsync', JSON.stringify(tanknumber));
    //    }
    //}


</script>