Nozzles.cshtml 52 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904
  1. @model Edge.WebHost.Models.SmartFuel.SmartFuelViewInfo
  2. @*
  3. For more information on enabling MVC for empty projects, visit http://go.microsoft.com/fwlink/?LinkID=397860
  4. *@
  5. @{
  6. var screenWidth = 1280.00;
  7. var mainviewHeight = 501.00;
  8. int maxNozzleNumberInOnePage = 12;
  9. //int maxNozzlewidth = 176;
  10. var maxNozzlewidth = 183.00;
  11. int minNozzlewidth = 129;
  12. //including the right margin at the end of a row,current display 6 nozzles in one row
  13. var marginleft = (screenWidth - maxNozzlewidth * 6) / 7;
  14. int textlableHeight = 34;//人民币未付款图标高度/宽度
  15. //int nozzleImagHeight = 123;
  16. int nozzleImagHeight = 125;
  17. int nozzleHeight = nozzleImagHeight + textlableHeight * 3;//259;
  18. var margintop = (mainviewHeight - nozzleHeight * 2) / 3;
  19. //int margintop
  20. int lableFontSize = 22;
  21. int imgPaidHeight = 25;
  22. int imgPaidWidth = 20;
  23. int alImgWidth = 44;
  24. int alImgHeight = 43;
  25. int headRightHeight = 44;
  26. int alLogoWidth = 61;
  27. int smartFuelLogoWidth = 43;
  28. //int alLogoTop = headRightHeight + 10;
  29. }
  30. <script>
  31. var currentPage = 1;
  32. var oldPage = currentPage;
  33. var totalPage = 1;
  34. var currentView = "AL";
  35. var alLogoVisibility = currentView === "AL" ? "hidden" : "visible";
  36. var smartFuelLogoVisibility = currentView === "SmartFuel" ? "hidden" : "visible";
  37. var amountDecimalDigits = 2;
  38. var volumeDecimalDigits = 2;
  39. var intervalId;
  40. var warningNozzles = new Array();
  41. var alarmNozzles = new Array();
  42. function UpdateFooterPage() {
  43. if (document.getElementById("PumpsPage_Bottom_pages") != null) {
  44. for (var p = 1; p < 6; p++) {
  45. var imgCurrentPageIdStr = "PumpsPage_Bottom_pages_img_"+p;
  46. var imgCurrentPageNotShowedIdStr = "PumpsPage_Bottom_pages_notshowed_img_"+p;
  47. if (p > totalPage) {
  48. if (document.getElementById(imgCurrentPageIdStr) != null)
  49. document.getElementById(imgCurrentPageIdStr).style.visibility = "hidden";
  50. if (document.getElementById(imgCurrentPageNotShowedIdStr) != null)
  51. document.getElementById(imgCurrentPageNotShowedIdStr).style.visibility = "hidden";
  52. } else if (p === currentPage || (p === 5 && currentPage > p)) {
  53. if (document.getElementById(imgCurrentPageIdStr) != null)
  54. document.getElementById(imgCurrentPageIdStr).style.visibility = "visible";
  55. if (document.getElementById(imgCurrentPageNotShowedIdStr) != null)
  56. document.getElementById(imgCurrentPageNotShowedIdStr).style.visibility = "hidden";
  57. }else {
  58. if (document.getElementById(imgCurrentPageIdStr) != null)
  59. document.getElementById(imgCurrentPageIdStr).style.visibility = "hidden";
  60. if (document.getElementById(imgCurrentPageNotShowedIdStr) != null)
  61. document.getElementById(imgCurrentPageNotShowedIdStr).style.visibility = "visible";
  62. }
  63. }
  64. //update next page img position
  65. var nextPageImg = document.getElementById("PumpsPage_Bottom_pages_img_next_page");
  66. var previousPageImg = document.getElementById("PumpsPage_Bottom_pages_img_previous_page");
  67. if (previousPageImg != null) {
  68. //previousPageImg.style.visibility = (totalPage===1||currentPage===1)?"hidden":"visible";
  69. previousPageImg.style.visibility = "visible";
  70. }
  71. if (nextPageImg != null) {
  72. //if (totalPage < 5)
  73. nextPageImg.style.left = (16.5 * totalPage + 5).toString() + "%";
  74. //else {
  75. // nextPageImg.style.left = (16.5 * totalPage + 6).toString() + "%";
  76. //}
  77. //nextPageImg.style.visibility = (totalPage===1||currentPage===totalPage)?"hidden":"visible";
  78. nextPageImg.style.visibility = "visible";
  79. }
  80. }
  81. }
  82. function ClearOldItems() {
  83. var nozzlesDiv = document.getElementById("nozzles");
  84. if (nozzlesDiv != null) {
  85. @*for (var cl = 1; cl < @(maxNozzleNumberInOnePage+1); cl++) {
  86. var ocn = document.getElementById("nozzle_" + (cl+@(maxNozzleNumberInOnePage)*(currentPage-1)));
  87. if (ocn != null) nozzlesDiv.removeChild(ocn);
  88. }*@
  89. var nl = nozzlesDiv.childNodes.length;
  90. for (var cn = 0; cn < nl; cn++) {
  91. var c = nozzlesDiv.childNodes[0];
  92. nozzlesDiv.removeChild(c);
  93. }
  94. }
  95. }
  96. //Generate nozzle view for smart fuel
  97. function GenerateSmartFuelNozzleView(message) {
  98. var nozzlesDiv = document.getElementById("nozzles");
  99. @*for (var cl = 0; cl < @maxNozzleNumberInOnePage; cl++) {
  100. var ocn = document.getElementById("nozzle_" + (cl+@(maxNozzleNumberInOnePage)*(oldPage-1)+1));
  101. if (ocn != null) nozzlesDiv.removeChild(ocn);
  102. }*@
  103. if (nozzlesDiv == null) {
  104. console.log("nozzles div is null");
  105. return;
  106. }
  107. if (!Array.isArray(message))
  108. console.log("message is not a array:"+message);
  109. if (message == null || !Array.isArray(message)|| !(message.length > 0) ){
  110. console.log("Invalid message received for GenerateNozzleView");
  111. return;
  112. }
  113. //cast the pump array to an nozzle array
  114. var nozzlesArray = new Array();
  115. message.forEach(function(p) {
  116. if (p.Nozzles != null && p.Nozzles.length>0) {
  117. p.Nozzles.forEach(function (n) {
  118. n.PumpId = p.PumpId;
  119. nozzlesArray.push(n);
  120. });
  121. }
  122. });
  123. amountDecimalDigits = message[0].AmountDecimalDigits;
  124. volumeDecimalDigits = message[0].VolumeDecimalDigits;
  125. totalPage = Math.ceil(nozzlesArray.length / @(maxNozzleNumberInOnePage));//message.data.length / @(maxNozzleNumberInOnePage)+(message.data.length % (@maxNozzleNumberInOnePage) === 0 ? 0 : 1);
  126. if (currentPage > totalPage) {
  127. currentPage = totalPage;
  128. console.log("configuration changed???");
  129. }
  130. var dataLength =
  131. (nozzlesArray.length - @maxNozzleNumberInOnePage * (currentPage - 1)) > @maxNozzleNumberInOnePage
  132. ? @maxNozzleNumberInOnePage
  133. : (nozzlesArray.length - @maxNozzleNumberInOnePage * (currentPage - 1));
  134. var temp = nozzlesArray.sort(sortBySiteLevelNozzleId).slice(@maxNozzleNumberInOnePage * (currentPage - 1), @maxNozzleNumberInOnePage * (currentPage - 1) + dataLength);
  135. temp.forEach(function (d) {
  136. var nozzleId = d.LogicalId;
  137. var nozzleDiv = document.createElement("div");
  138. nozzleDiv.id = "pump"+d.PumpId+"_nozzle" + nozzleId;
  139. nozzleDiv.style =
  140. "position:relative; float: left;margin-left:"+@(marginleft*100/screenWidth)+"%; margin-top:" +@(margintop*100/screenWidth)+"%; width:" +@(maxNozzlewidth*100/screenWidth)+"%; height:"+@(nozzleHeight*100/mainviewHeight)+"%;";
  141. var nozzleIdDiv = document.createElement("div");
  142. nozzleIdDiv.id = "pump"+d.PumpId+"_nozzleId" + nozzleId;
  143. nozzleIdDiv.style =
  144. "position: absolute; left:0px; top:0px;width: 100%; height:" +@(textlableHeight*100/ nozzleHeight)+"%; text-align: left; font-size: 1.375rem;font-weight: bold;";
  145. nozzleIdDiv.innerHTML = d.SiteLevelNozzleId;
  146. var nozzleImgDiv = document.createElement("div");
  147. nozzleImgDiv.id = "pump"+d.PumpId+"_nozzleImg" + nozzleId;
  148. //nozzleImgDiv.style = "position: relative; float: left;width: 100%; height:" +@(nozzleImagHeight)+"px; text-align: center;border: 1px solid#00bfff;";
  149. nozzleImgDiv.style = "position: relative; float: left;width: 100%; height:" +@(nozzleImagHeight*100/nozzleHeight)+"%;";
  150. nozzleImgDiv.draggable = false;
  151. //油枪状态图
  152. //var fuelingStatusIdleVisible = (d.LogicalState === "IDLE") ? "hidden" : "visible";
  153. //var fuelingStatusFuellingVisible = (d.LogicalState === "FUELING") ? "visible" : "hidden";
  154. var fuelingStatusIdleVisible = "hidden";
  155. var fuelingStatusIdleStaticVisible = "visible";
  156. var fuelingStatusFuellingVisible = "hidden";
  157. var fuelingStatusCallingVisible = "hidden";
  158. var fuelingStatusAuthrizedVisible = "hidden";
  159. var fuelingStatusDisconnectVisible = "hidden";
  160. var fuelingStatusClosedVisible = "hidden";
  161. //IDLE,CALLING,AUTHORIZED,FUELLING,DISCONNECT,油枪未连接
  162. //var imgIdle = document.createElement("img");
  163. var imgIdle = document.createElement("img");
  164. imgIdle.id = "pump"+d.PumpId+"_nozzleImage_Idle_" + nozzleId;
  165. imgIdle.style = "visibility:" + fuelingStatusIdleVisible + ";width: 100%; height:100%;";
  166. imgIdle.draggable = false;
  167. //imgIdle.src = "/images/smartFuel/idle.gif?a=" + Math.random();
  168. imgIdle.src = "WebConsole/images/smartFuel/Idle.gif?a=" + d.PumpId+nozzleId;
  169. var imgIdleStatic = document.createElement("img");
  170. imgIdleStatic.id = "pump"+d.PumpId+"_nozzleImage_IdleStatic_" + nozzleId;
  171. imgIdleStatic.style = "position: absolute; top: 0px; left:0px;visibility:" + fuelingStatusIdleStaticVisible + ";width: 100%; height:100%;";
  172. imgIdleStatic.draggable = false;
  173. imgIdleStatic.src = "WebConsole/images/smartFuel/idleStatic.png";
  174. var imgCalling = document.createElement("img");
  175. imgCalling.id = "pump"+d.PumpId+"_nozzleImage_Calling_" + nozzleId;
  176. //imgCalling.style = "position: absolute; top: 0px; left:" +@((maxNozzlewidth-minNozzlewidth)/2)+"px;visibility:" + fuelingStatusCallingVisible + ";";
  177. imgCalling.style = "position: absolute; top: 0px; left:0px;visibility:" + fuelingStatusCallingVisible + ";width: 100%; height:100%;";
  178. imgCalling.draggable = false;
  179. imgCalling.src = "WebConsole/images/smartFuel/calling.png";
  180. var imgAuthorized= document.createElement("img");
  181. imgAuthorized.id = "pump"+d.PumpId+"_nozzleImage_Authorized_" + nozzleId;
  182. //imgAuthorized.style = "position: absolute; top: 0px; left:"+@((maxNozzlewidth-minNozzlewidth)/2)+"px;visibility:" + fuelingStatusAuthrizedVisible+";";
  183. imgAuthorized.style = "position: absolute; top: 0px; left:0px;visibility:" + fuelingStatusAuthrizedVisible +";width: 100%; height:100%;";
  184. imgAuthorized.draggable = false;
  185. imgAuthorized.src = "WebConsole/images/smartFuel/authorize.png";
  186. var imgFuelling = document.createElement("img");
  187. imgFuelling.id = "pump" + d.PumpId + "_nozzleImage_Fuelling_" + nozzleId;
  188. imgFuelling.draggable = false;
  189. //imgFuelling.style = "position: absolute; left: 0px;top: 0px;visibility:" + fuelingStatusFuellingVisible + ";width: 100%; height:100%;";
  190. imgFuelling.style = "position: absolute; left: 0px;top: 0px;visibility:" + fuelingStatusFuellingVisible + ";width: 100%; height:100%;";
  191. //imgFuelling.src = "/images/smartFuel/fuelling.gif?a=" + Math.random();
  192. imgFuelling.src = "WebConsole/images/smartFuel/fuelling.gif?a=" + d.PumpId+nozzleId;
  193. var imgDisconnect= document.createElement("img");
  194. imgDisconnect.id = "pump"+d.PumpId+"_nozzleImage_Disconnect_" + nozzleId;
  195. //imgDisconnect.style = "position: absolute; top: 0px; left:"+@((maxNozzlewidth-minNozzlewidth)/2)+"px;visibility:" + fuelingStatusDisconnectVisible+";";
  196. imgDisconnect.style = "position: absolute; top: 0px; left:0px;visibility:" + fuelingStatusDisconnectVisible +";width: 100%; height:100%;";
  197. imgDisconnect.draggable = false;
  198. imgDisconnect.src = "WebConsole/images/smartFuel/disconnect.png";
  199. var imgClosed= document.createElement("img");
  200. imgClosed.id = "pump"+d.PumpId+"_nozzleImage_Closed_" + nozzleId;
  201. //imgClosed.style = "position: absolute; top: 0px; left:"+@((maxNozzlewidth-minNozzlewidth)/2)+"px;visibility:" + fuelingStatusClosedVisible+";";
  202. imgClosed.style = "position: absolute; top: 0px; left:0px;visibility:" + fuelingStatusClosedVisible +";width: 100%; height:100%;";
  203. imgClosed.draggable = false;
  204. imgClosed.src = "WebConsole/images/smartFuel/closed.png";
  205. nozzleImgDiv.appendChild(imgIdle);
  206. nozzleImgDiv.appendChild(imgIdleStatic);
  207. nozzleImgDiv.appendChild(imgCalling);
  208. nozzleImgDiv.appendChild(imgAuthorized);
  209. nozzleImgDiv.appendChild(imgFuelling);
  210. nozzleImgDiv.appendChild(imgDisconnect);
  211. nozzleImgDiv.appendChild(imgClosed);
  212. var imgNotPaidVisible = "hidden";
  213. var imgPaidVisible = "visible";
  214. var nozzleAmountDiv = document.createElement("div");
  215. nozzleAmountDiv.id = "pump"+d.PumpId+"_nozzleAmount_" + nozzleId;
  216. nozzleAmountDiv.style = "position: relative; float: left;width: 100%; height:" +@(textlableHeight*100/nozzleHeight)+"%;";
  217. var nozzleAmountImgDiv = document.createElement("div");
  218. nozzleAmountImgDiv.id = "pump"+d.PumpId+"_nozzleAmount_img_"+nozzleId;
  219. nozzleAmountImgDiv.style = "position: relative;float: left;width:" +@(textlableHeight*100/ maxNozzlewidth)+"%; height:100%;";
  220. var nozzleAmountUnpaidImg = document.createElement("img");
  221. nozzleAmountUnpaidImg.id = "pump"+d.PumpId+"_nozzleAmount_img_Unpaid_" + nozzleId;
  222. nozzleAmountUnpaidImg.style = "width:100%; height:100%;"+"visibility:" + imgNotPaidVisible;
  223. nozzleAmountUnpaidImg.draggable = false;
  224. nozzleAmountUnpaidImg.src = "WebConsole/images/smartFuel/payable.png";
  225. var nozzleAmountPaidImg = document.createElement("img");
  226. nozzleAmountPaidImg.id = "pump"+d.PumpId+"_nozzleAmount_img_Paid_" + nozzleId;
  227. nozzleAmountPaidImg.style = "position: absolute; width:" +@(imgPaidWidth*100/textlableHeight)+"%;height:"+@(imgPaidHeight*100/textlableHeight) +"%;top:"+@((textlableHeight-imgPaidHeight)*100/2/ textlableHeight)+"%; left:"+@((textlableHeight-imgPaidWidth)*100/2/ textlableHeight)+"%;visibility:"+imgPaidVisible+";";
  228. nozzleAmountPaidImg.draggable = false;
  229. nozzleAmountPaidImg.src = "WebConsole/images/smartFuel/paid.png";
  230. nozzleAmountImgDiv.appendChild(nozzleAmountUnpaidImg);
  231. nozzleAmountImgDiv.appendChild(nozzleAmountPaidImg);
  232. var nozzleAmountColonDiv = document.createElement("div");
  233. nozzleAmountColonDiv.id = "pump" + d.PumpId + "_nozzleAmount_colon_" + nozzleId;
  234. nozzleAmountColonDiv.style = "position: relative;float: left;width:"+@(8*100/ maxNozzlewidth)+"%; height:100%;font-size:1.375rem; font-weight: bold;text-align: center;";
  235. nozzleAmountColonDiv.innerHTML = " :";
  236. var nozzleAmountValueDiv = document.createElement("div");
  237. nozzleAmountValueDiv.id = "pump"+d.PumpId+"_nozzleAmount_value_" + nozzleId;
  238. nozzleAmountValueDiv.style = "position: relative;float: left;width:" +@((maxNozzlewidth-textlableHeight-8)*100/maxNozzlewidth)+"%; height:100%;font-size:1.375rem; font-weight: bold;text-align: left;";
  239. nozzleAmountValueDiv.innerHTML = "0.00"; //(d.Amount!=null)?(d.Amount/Math.pow(10,amountDecimalDigits)).toFixed(2): "0.00";
  240. nozzleAmountDiv.appendChild(nozzleAmountImgDiv);
  241. nozzleAmountDiv.appendChild(nozzleAmountColonDiv);
  242. nozzleAmountDiv.appendChild(nozzleAmountValueDiv);
  243. var nozzleAccumulatorTextDiv = document.createElement("div");
  244. nozzleAccumulatorTextDiv.id = "pump"+d.PumpId+"_nozzleAccumulatorText_" + nozzleId;
  245. nozzleAccumulatorTextDiv.style = "position: relative; float: left;width: 100%; height:" +@(textlableHeight*100/nozzleHeight)+"%; font-size:1.375rem; font-weight: bold;";
  246. nozzleAccumulatorTextDiv.innerHTML = "累计数:";
  247. var nozzleAccumulatorValueDiv = document.createElement("div");
  248. nozzleAccumulatorValueDiv.id = "pump"+d.PumpId+"_nozzleAccumulatorValue_" + nozzleId;
  249. nozzleAccumulatorValueDiv.style = "position: relative; float: left;width: 100%; height:" +@(textlableHeight*100/nozzleHeight)+"%; font-size:1.375rem; font-weight: bold;";
  250. nozzleAccumulatorValueDiv.innerHTML = "0.00"; //(d.VolumeTotalizer!==null)?(d.VolumeTotalizer/Math.pow(10,volumeDecimalDigits)).toFixed(2):"0.00";
  251. nozzleDiv.appendChild(nozzleImgDiv);
  252. nozzleDiv.appendChild(nozzleIdDiv);
  253. nozzleDiv.appendChild(nozzleAmountDiv);
  254. nozzleDiv.appendChild(nozzleAccumulatorTextDiv);
  255. nozzleDiv.appendChild(nozzleAccumulatorValueDiv);
  256. nozzlesDiv.appendChild(nozzleDiv);
  257. });
  258. UpdateFooterPage();
  259. setTimeout(GetDeviceState,2,-1,-1);
  260. }
  261. //In ascending order of site level nozzle Id
  262. function sortBySiteLevelNozzleId(n1, n2) {
  263. if (n1.SiteLevelNozzleId < n2.SiteLevelNozzleId)
  264. return -1;
  265. else
  266. return 1;
  267. }
  268. function GetAvailableTransactions(pumpId, nozzleId) {
  269. var temp = {
  270. "Parameters": [
  271. {"Name": "PumpId", "Value": pumpId.toString() },
  272. {"Name": "NozzleId", "Value": nozzleId.toString()}
  273. ]
  274. };
  275. var message = JSON.stringify(temp);
  276. mqttclient.publish(apis.has("GetLastAvailableTransaction") ? apis.get("GetLastAvailableTransaction") :'/Applications.FDC.FdcServerHostApp/fdcServerApp/thing/service/GetLastAvailableTransaction/', message);
  277. //mqttclient.publish(apis.has("GetAvailableTransactions") ? apis.get("GetAvailableTransactions"):'/Applications.FDC.FdcServerHostApp/fdcServerApp/thing/service/GetAvailableTransactions/', message);
  278. }
  279. function GetDeviceState(pumpId, nozzleId) {
  280. var temp = {
  281. "Parameters": [
  282. {"Name": "PumpId", "Value": pumpId.toString() },
  283. {"Name": "NozzleId", "Value": nozzleId.toString()}
  284. ]
  285. };
  286. var message = JSON.stringify(temp);
  287. //console.log(message + " " + apis.get("GetDeviceState"));
  288. var path = apis.has("GetDeviceState") ? apis.get("GetDeviceState") : '/Applications.FDC.FdcServerHostApp/fdcServerApp/thing/service/GetDeviceState/';
  289. console.log(message + " " + path);
  290. mqttclient.publish(path, message);
  291. }
  292. function UpdatePayableStatus(message) {
  293. if (message == null || !(message.length > 0)) {
  294. console.log("invalid/null message received for GetAvailableTransactions");
  295. return;
  296. }
  297. message.forEach(function(data) {
  298. var unpaidImg = document.getElementById("pump" + data.PumpId + "_nozzleAmount_img_Unpaid_" + data.LogicalNozzleId);
  299. var paidImg = document.getElementById("pump" + data.PumpId + "_nozzleAmount_img_Paid_" + data.LogicalNozzleId);
  300. if (unpaidImg == null || paidImg == null) {
  301. console.log("paid/unpaid image is not exist on UI");
  302. return;
  303. }
  304. unpaidImg.style.visibility = (data.hasPayableTransactions === true) ? "visible" : "hidden";
  305. paidImg.style.visibility = (data.hasPayableTransactions === false) ? "visible" : "hidden";
  306. });
  307. }
  308. function ProcessTransactionStateChange(message) {
  309. if (message == null || message.Transaction==null) {
  310. console.log("invalid/null message received for GetAvailableTransactions");
  311. return;
  312. }
  313. if (message.State === "Paid" || message.State==="Payable") {
  314. setTimeout(GetAvailableTransactions,1,message.Transaction.PumpId,message.Transaction.LogicalNozzleId);
  315. }
  316. }
  317. function ProcessCurrentFuellingStateChange(message) {
  318. if (message == null || message.Transaction == null || message.Transaction.Nozzle == null) {
  319. console.log("invalid/null message received for GetAvailableTransactions");
  320. return;
  321. }
  322. //update the nozzleState
  323. if (message.Transaction.Finished === false) {
  324. var commonId = "pump" + message.Transaction.Nozzle.PumpId + "_nozzleImage_";
  325. var commonFuellingId = commonId + "Fuelling_";
  326. var fuellingImg = document.getElementById(commonFuellingId + message.Transaction.Nozzle.LogicalId);
  327. if (fuellingImg != null && fuellingImg.style.visibility === "hidden") {
  328. var commonIdleId = commonId + "Idle_";
  329. var commonIdleStaticId = commonId + "IdleStatic_";
  330. var commonCallingId = commonId + "Calling_";
  331. var commonAuthId = commonId + "Authorized_";
  332. var commonDisconnectId = commonId + "Disconnect_";
  333. var commonClosedId = commonId + "Closed_";
  334. var authImg = document.getElementById(commonAuthId + message.Transaction.Nozzle.LogicalId);
  335. var idleImg = document.getElementById(commonIdleId + message.Transaction.Nozzle.LogicalId);
  336. var idleSaticImg = document.getElementById(commonIdleStaticId + message.Transaction.Nozzle.LogicalId);
  337. var callingImg = document.getElementById(commonCallingId + message.Transaction.Nozzle.LogicalId);
  338. var disconnectImg = document.getElementById(commonDisconnectId + message.Transaction.Nozzle.LogicalId);
  339. var closedImg = document.getElementById(commonClosedId + message.Transaction.Nozzle.LogicalId);
  340. var idleImgVisible = "hidden";
  341. var idleImgStaticVisible = "hidden";
  342. var callingImgVisible = "hidden";
  343. var authorizedImgVisible = "hidden";
  344. var fuellingImgVisible = "visible";
  345. var disconnectImgVisible = "hidden";
  346. if (idleImg != null) {idleImg.style.visibility = idleImgVisible;
  347. }
  348. if (idleSaticImg != null) idleSaticImg.style.visibility=idleImgStaticVisible;
  349. if (callingImg != null) callingImg.style.visibility = callingImgVisible;
  350. if (authImg != null) authImg.style.visibility = authorizedImgVisible;
  351. if (fuellingImg != null) {fuellingImg.style.visibility = fuellingImgVisible;
  352. fuellingImg.src = fuellingImg.src; //"/images/smartFuel/fuelling.gif?a=" + Math.random();
  353. }
  354. if (disconnectImg != null) disconnectImg.style.visibility = disconnectImgVisible;
  355. if (closedImg != null) closedImg.style.visibility = "hidden";
  356. }
  357. }
  358. var nozzleAmtDiv = document.getElementById("pump" + message.Transaction.Nozzle.PumpId + "_nozzleAmount_value_" + message.Transaction.Nozzle.LogicalId);
  359. if (nozzleAmtDiv == null) return;
  360. nozzleAmtDiv.innerHTML = message.Transaction.Amount!=null?(message.Transaction.Amount /Math.pow(10, amountDecimalDigits)).toFixed(amountDecimalDigits):"0.00";
  361. if (message.Transaction.Finished === true) {
  362. var nozzleAccumulatorValueDiv = document.getElementById("pump" + message.Transaction.Nozzle.PumpId + "_nozzleAccumulatorValue_" + message.Transaction.Nozzle.LogicalId);
  363. if (nozzleAccumulatorValueDiv == null) return;
  364. nozzleAccumulatorValueDiv.innerHTML = message.Transaction.VolumeTotalizer!=null?(message.Transaction.VolumeTotalizer /Math.pow(10, volumeDecimalDigits)).toFixed(volumeDecimalDigits):"0.00";
  365. //setTimeout(GetAvailableTransactions,1,message.Transaction.Nozzle.PumpId,message.Transaction.Nozzle.LogicalId);
  366. }
  367. }
  368. function ProcessFdcControllerStatusChange(message) {
  369. if (message == null || message.PumpId == null || message.PumpId === ""||message.logicalState ==="") {
  370. console.log("Invalid FDC Controller Status change");
  371. return;
  372. }
  373. //ignore the locked state
  374. if (message.logicalState === "FDC_LOCKED") {
  375. return;
  376. }
  377. var commonId = "pump" + message.PumpId + "_nozzleImage_";
  378. var commonAuthId = commonId + "Authorized_";
  379. var commonIdleId = commonId + "Idle_";
  380. var commonIdleStaticId = commonId + "IdleStatic_";
  381. var commonCallingId = commonId + "Calling_";
  382. var commonFuellingId = commonId + "Fuelling_";
  383. var commonDisconnectId = commonId + "Disconnect_";
  384. var commonclosedId = commonId + "Closed_";
  385. console.log("logicalState:" + message.logicalState);
  386. var idleImgVisible = message.logicalState === "FDC_READY" ? "visible" : "hidden";
  387. var idleImgStaticVisible = message.logicalState === "FDC_READY" ? "visible" : "hidden";
  388. var callingImgVisible = message.logicalState === "FDC_CALLING" ? "visible" : "hidden";
  389. var authorizedImgVisible = message.logicalState === "FDC_AUTHORISED" || message.logicalState === "FDC_STARTED"? "visible" : "hidden";
  390. var fuellingImgVisible = message.logicalState === "FDC_FUELLING" ? "visible" : "hidden";
  391. var disconnectImgVisible = message.logicalState === "FDC_OFFLINE"? "visible" : "hidden";
  392. var closedImgVisible = message.logicalState === "FDC_CLOSED" || message.logicalState === "FDC_ERRORSTATE" || message.logicalState ==="FDC_UNDEFINED"? "visible" : "hidden";
  393. if (message.logicalId === "") {
  394. var idleImgs = $("img[id^=" + commonIdleId);
  395. if (idleImgs != null) {
  396. idleImgs.each(function (index, element) {
  397. var tempIdleVisible = idleImgVisible;
  398. var tempFuellingImg = document.getElementById(commonFuellingId + element.id.substr(commonIdleId.length));
  399. if (tempFuellingImg != null && tempFuellingImg.style.visibility !== "visible") {
  400. tempIdleVisible = "hidden";
  401. }
  402. if (element.style.visibility !== tempIdleVisible) {
  403. element.style.visibility = tempIdleVisible;
  404. if (tempIdleVisible === "visible") {
  405. element.src = element.src;//"/images/smartFuel/idle.gif?a=" + Math.random();
  406. }
  407. }
  408. });
  409. }
  410. var idleStaticImgs = $("img[id^=" + commonIdleStaticId);
  411. if (idleStaticImgs != null) {
  412. idleStaticImgs.each(function (index, element) {
  413. var tempIdleStaticVisible = idleImgStaticVisible;
  414. var tempFuellingImg = document.getElementById(commonFuellingId + element.id.substr(commonIdleStaticId.length));
  415. if (tempFuellingImg != null && tempFuellingImg.style.visibility === "visible") {
  416. tempIdleStaticVisible = "hidden";
  417. }
  418. if (element.style.visibility !== tempIdleStaticVisible) {
  419. element.style.visibility = tempIdleStaticVisible;
  420. }
  421. });
  422. }
  423. var callingImgs = $("img[id^=" + commonCallingId);
  424. if (callingImgs != null) {
  425. callingImgs.each(function (index, element) {
  426. if (element.style.visibility !== callingImgVisible)
  427. element.style.visibility = callingImgVisible;
  428. });
  429. }
  430. var authorizedImgs = $("img[id^=" + commonAuthId);
  431. if (authorizedImgs != null) {
  432. authorizedImgs.each(function (index, element) {
  433. if (element.style.visibility !== authorizedImgVisible)
  434. element.style.visibility = authorizedImgVisible;
  435. });
  436. }
  437. var fuellingImgs = $("img[id^=" + commonFuellingId);
  438. if (fuellingImgs != null) {
  439. fuellingImgs.each(function (index, element) {
  440. if (element.style.visibility !== fuellingImgVisible) {
  441. element.style.visibility = fuellingImgVisible;
  442. if (fuellingImgVisible === "visible") {
  443. element.src = element.src; //"/images/smartFuel/fuelling.gif?a=" + Math.random();
  444. }
  445. }
  446. });
  447. }
  448. var offlineImgs = $("img[id^=" + commonDisconnectId);
  449. if (offlineImgs != null) {
  450. offlineImgs.each(function (index, element) {
  451. if (element.style.visibility !== disconnectImgVisible)
  452. element.style.visibility = disconnectImgVisible;
  453. });
  454. }
  455. var closedImgs = $("img[id^=" + commonclosedId);
  456. if (closedImgs != null) {
  457. closedImgs.each(function (index, element) {
  458. if (element.style.visibility !== closedImgVisible)
  459. element.style.visibility = closedImgVisible;
  460. });
  461. }
  462. } else {
  463. var idleImg = document.getElementById(commonIdleId + message.logicalId);
  464. var idleSaticImg = document.getElementById(commonIdleStaticId + message.logicalId);
  465. var callingImg = document.getElementById(commonCallingId + message.logicalId);
  466. var authImg = document.getElementById(commonAuthId + message.logicalId);
  467. var fuellingImg = document.getElementById(commonFuellingId + message.logicalId);
  468. var disconnectImg = document.getElementById(commonDisconnectId + message.logicalId);
  469. var closedImg = document.getElementById(commonclosedId + message.logicalId);
  470. if (fuellingImg != null && fuellingImg.style.visibility !== "visible" && (message.logicalState === "FDC_READY")) {
  471. idleImgVisible = "hidden";
  472. idleImgStaticVisible = "visible";
  473. } else if (fuellingImg != null && fuellingImg.style.visibility === "visible" && (message.logicalState === "FDC_READY")) {
  474. idleImgVisible = "visible";
  475. idleImgStaticVisible = "hidden";
  476. }
  477. if (idleImg != null && idleImg.style.visibility !== idleImgVisible) {
  478. idleImg.style.visibility = idleImgVisible;
  479. if (idleImgVisible === "visible") {
  480. idleImg.src = idleImg.src; //"/images/smartFuel/idle.gif?a=" + Math.random();
  481. }
  482. }
  483. if (idleSaticImg != null && idleSaticImg.style.visibility !== idleImgStaticVisible) {
  484. idleSaticImg.style.visibility = idleImgStaticVisible;
  485. }
  486. if (callingImg != null && callingImg.style.visibility !== callingImgVisible) callingImg.style.visibility = callingImgVisible;
  487. if (authImg != null && authImg.style.visibility!== authorizedImgVisible) authImg.style.visibility = authorizedImgVisible;
  488. if (fuellingImg != null && fuellingImg.style.visibility !== fuellingImgVisible) {
  489. fuellingImg.style.visibility = fuellingImgVisible;
  490. if (fuellingImgVisible === "visible") {
  491. fuellingImg.src = fuellingImg.src; //"/images/smartFuel/fuelling.gif?a=" + Math.random();
  492. }}
  493. if (disconnectImg != null && disconnectImg.style.visibility !== disconnectImgVisible) disconnectImg.style.visibility = disconnectImgVisible;
  494. if (closedImg != null && closedImg.style.visibility !== closedImgVisible) closedImg.style.visibility = closedImgVisible;
  495. if (message.logicalState === "FDC_FUELLING") {
  496. var authorizedImgs = $("img[id^=" + commonAuthId);
  497. if (authorizedImgs != null) {
  498. authorizedImgs.each(function(index,element) {
  499. if (element.id !== commonAuthId + message.logicalId && element.style.visibility === "visible") {
  500. element.style.visibility = "hidden";
  501. var tempNozzleId = element.id.toString().substr(commonAuthId.length);
  502. var tempIdleImg = document.getElementById(commonIdleStaticId + tempNozzleId);
  503. if (tempIdleImg != null) tempIdleImg.style.visibility = "visible";
  504. }
  505. });
  506. }
  507. }
  508. }
  509. //var r = document.getElementById("pump"+message.PumpId+"_nozzleImg"+"^");
  510. }
  511. function ProcessDeviceState(message) {
  512. if (message == null || !Array.isArray(message)|| !(message.length>0)) {
  513. console.log("Invalid device state");
  514. return;
  515. }
  516. console.log(message);
  517. message.forEach(function (device) {
  518. var commonId = "pump" + device.PumpId + "_nozzleImage_";
  519. var commonAuthId = commonId + "Authorized_";
  520. var commonIdleId = commonId + "Idle_";
  521. var commonIdleStaticId = commonId + "IdleStatic_";
  522. var commonCallingId = commonId + "Calling_";
  523. var commonFuellingId = commonId + "Fuelling_";
  524. var commonDisconnectId = commonId + "Disconnect_";
  525. var commonClosedId = commonId + "Closed_";
  526. if (device.Nozzles != null && device.Nozzles.length > 0) {
  527. device.Nozzles.forEach(function(n) {
  528. var idleImgStaticVisible = device.DeviceState === "FDC_READY" ? "visible" : "hidden";
  529. var idleImgVisible = "hidden";
  530. var callingImgVisible = device.DeviceState === "FDC_CALLING" ? "visible" : "hidden";
  531. var authorizedImgVisible = device.DeviceState === "FDC_AUTHORISED" || device.GetDeviceState ==="FDC_STARTED"? "visible" : "hidden";
  532. var fuellingImgVisible = device.DeviceState === "FDC_FUELLING" ? "visible" : "hidden";
  533. var disconnectImgVisible = device.DeviceState === "FDC_OFFLINE"? "visible" : "hidden";
  534. var closedImgVisible = device.DeviceState === "FDC_CLOSED" || device.DeviceState === "FDC_ERRORSTATE" || device.DeviceState === "FDC_UNDEFINED"? "visible" : "hidden";
  535. if (n.LogicalState == null &&
  536. (device.DeviceState === "FDC_CALLING" || device.DeviceState === "FDC_FUELLING")) {
  537. console.log(
  538. "Currently, don't update the view since don't know which one is in calling/fuelling state");
  539. } else {
  540. var idleImg = document.getElementById(commonIdleId + n.LogicalId);
  541. var idleStaticImg = document.getElementById(commonIdleStaticId + n.LogicalId);
  542. var callingImg = document.getElementById(commonCallingId + n.LogicalId);
  543. var authImg = document.getElementById(commonAuthId + n.LogicalId);
  544. var fuellingImg = document.getElementById(commonFuellingId + n.LogicalId);
  545. var disconnectImg = document.getElementById(commonDisconnectId + n.LogicalId);
  546. var closedImg = document.getElementById(commonClosedId + n.LogicalId);
  547. if (idleImg != null) idleImg.style.visibility = idleImgVisible;
  548. if (idleStaticImg != null) idleStaticImg.style.visibility = idleImgStaticVisible;
  549. if (callingImg != null) callingImg.style.visibility = callingImgVisible;
  550. if (authImg != null) authImg.style.visibility = authorizedImgVisible;
  551. if (fuellingImg != null) fuellingImg.style.visibility = fuellingImgVisible;
  552. if (disconnectImg != null) disconnectImg.style.visibility = disconnectImgVisible;
  553. if (closedImg != null) closedImg.style.visibility = closedImgVisible;
  554. }
  555. });
  556. }
  557. if (device.Nozzles != null && device.Nozzles.length > 0) {
  558. device.Nozzles.forEach(function (n) {
  559. var nozzleAccumulatorValueDiv = document.getElementById("pump" + device.PumpId + "_nozzleAccumulatorValue_" + n.LogicalId);
  560. if (nozzleAccumulatorValueDiv != null)
  561. nozzleAccumulatorValueDiv.innerHTML = n.VolumeTotalizer!= null?(n.VolumeTotalizer / Math.pow(10, volumeDecimalDigits)).toFixed(volumeDecimalDigits):"0.00";
  562. var nozzleAmtDiv = document.getElementById("pump" + device.PumpId + "_nozzleAmount_value_" + n.LogicalId);
  563. if (nozzleAmtDiv == null) return;
  564. nozzleAmtDiv.innerHTML =n.Amount!=null?(n.Amount /Math.pow(10, amountDecimalDigits)).toFixed(amountDecimalDigits):"0.00";
  565. });
  566. }
  567. });
  568. setTimeout(GetAvailableTransactions,2,-1,-1);
  569. }
  570. function UpdateNozzleState(pumpId,nozzleId,state) {
  571. }
  572. //Update the message on header
  573. function UpdateHeadMessage() {
  574. var pumpsHead = document.getElementById("PumpsPage_Head");
  575. var normalHead = document.getElementById("PumpsPage_Head_Status_normal");
  576. var warningHead = document.getElementById("PumpsPage_Head_Status_warning");
  577. var alarmHead = document.getElementById("PumpsPage_Head_Status_alarm");
  578. var textSpan = document.getElementById("head_left_text");
  579. if (pumpsHead == null || normalHead == null || warningHead == null || alarmHead == null || textSpan ==null) {
  580. return;
  581. }
  582. var message = "";
  583. }
  584. //切换至气液比油枪界面
  585. function ToggleOnlineMonitor() {
  586. RenderDiv("/OnlineMonitor/ALNozzles", contentDiv,null,null);
  587. }
  588. </script>
  589. <div id="nozzlesPage" style="position: relative; width:100%; height:100%;">
  590. <div id="nozzles" style="position: absolute;top:2.4%; width:100%; height:88.516%;">
  591. </div>
  592. <div class="tank_filter_div" id="toggleOnlineMonitor" style="top:0%;bottom:90%;left:95%;background-image: url(/WebConsole/images/onlineMonitor/nozzleView/AL.png);visibility:hidden;" onclick="ToggleOnlineMonitor()">
  593. </div>
  594. @*<div id="nozzles_1" style="position: relative; float: left;margin-left:@(marginleft)px; width:@(maxNozzlewidth)px; height:@(nozzleHeight)px; border: 1px solid #00bfff">
  595. </div>
  596. <div id="nozzles_2" style="position: relative; float: left;margin-left:@(marginleft)px; width:@(maxNozzlewidth)px; height:@(nozzleHeight)px; border: 1px solid #00bfff">
  597. </div>*@
  598. @* <input type="button" onclick="GenerateView(12)" value="GenerateView" />*@
  599. @*@for (int i = 0; i < 12; i++)
  600. {
  601. <div id="nozzles_@i" style="position:relative; float: left;margin-left:@(marginleft)px; margin-top: @(margintop)px; width: @(maxNozzlewidth)px; height: @(nozzleHeight)px;border: 1px solid #00bfff">
  602. <div id="nozzleId_@i" style="position: relative; float:left;width: 100%; height: @(textlableHeight)px; text-align: left; font-size: 22px;font-weight: bold">@i</div>
  603. <div id="nozzleImg_@i" style="position: relative; float: left;width: 100%; height: @(nozzleImagHeight)px; text-align: center">
  604. <img id="nozzleImage_Idle_@i" src="/image/online/油枪IDEL.png" style="visibility: visible" />
  605. <img id="nozzleImage_Calling_@i" src="/image/online/油枪CALLING.png" style="position: absolute; top: 0px; left:@((maxNozzlewidth-minNozzlewidth)/2)px;visibility: visible" />
  606. <img id="nozzleImage_Authorized_@i" src="/image/online/油枪授权.png" style="position: absolute; top: 0px; left:@((maxNozzlewidth-minNozzlewidth)/2)px;visibility: visible" />
  607. <img id="nozzleImage_Fuelling_@i" src="/image/online/油枪加油中.png" style="position: absolute; left: 0px;visibility: visible" />
  608. <img id="nozzleImage_Closed_@i" src="/image/online/油枪未连接.png" style="position: absolute; top: 0px; left:@((maxNozzlewidth-minNozzlewidth)/2)px;visibility: visible" />
  609. <img id="nozzleImage_Disconnect_@i" src="/image/online/油枪断开.png" style="position: absolute; top: 0px; left:@((maxNozzlewidth-minNozzlewidth)/2)px;visibility: visible" />
  610. <img id="nozzleALImage_Normal_@i" src="/image/online/normal.png" style="position: absolute; top:@(nozzleImagHeight-alImgWidth)px; left:@(maxNozzlewidth-alImgWidth)px;visibility: visible" />
  611. <img id="nozzleALImage_Warning_@i" src="/image/online/warning.png" style="position: absolute; top:@(nozzleImagHeight-alImgWidth)px; left:@(maxNozzlewidth-alImgWidth)px;visibility: visible" />
  612. <img id="nozzleALImage_Alarm_@i" src="/image/online/alarm.png" style="position: absolute; top:@(nozzleImagHeight-alImgWidth)px; left:@(maxNozzlewidth-alImgWidth)px;visibility: visible" />
  613. </div>
  614. <div id="nozzleAmount_@i" style="position: relative; float: left;width: 100%; height:@(textlableHeight)px; border: 1px solid#00bfff;">
  615. <div id="nozzleAmount_img_@i" style="position: relative;float: left;width:@(textlableHeight+5)px; height:100%;border: 1px solid#00bfff;">
  616. <img id="nozzleAmount_img_notPaid_@i" src="/image/online/人民币标志NotPaid.png" />
  617. <img id="nozzleAmount_img_Paid_@i" src="/image/online/人民币标志已付款.png" style="position: absolute; top:@((textlableHeight-imgPaidHeight)/2)px; left:@((textlableHeight-imgPaidWidth)/2)px;" />
  618. <span style="position: absolute; left: @(textlableHeight)px; text-align: center;line-height: @(textlableHeight)px; font-size: @(lableFontSize)px; font-weight:bold;">:</span>
  619. </div>
  620. <div>
  621. </div>
  622. </div>
  623. <div id="nozzleLiter_@i" style="position: relative; float: left; width: 100%; height:@(textlableHeight)px;font-size: @(lableFontSize)px; font-weight: bold;border: 1px solid#00bfff;">
  624. <div id="nozzleLiter_img_@i" style="position: relative;float:left;width:@(textlableHeight)px; height:100%;">
  625. 升:
  626. </div>
  627. <div id="nozzleLiter_text_@i" style="position: relative; float: left;">
  628. 1234.00
  629. </div>
  630. </div>
  631. <div id="nozzleAL_@i" style="position: relative; float: left;width: 100%; height: @(textlableHeight)px; font-size: @(lableFontSize)px; font-weight: bold;border: 1px solid#00bfff;">
  632. 汽液比 1.3
  633. </div>
  634. </div>
  635. }*@
  636. </div>
  637. <script src="~/WebConsole/js/mqtt.min.js"></script>
  638. <script src="~/WebConsole/js/jquery-3.4.1.min.js"></script>
  639. <script type="text/javascript">
  640. //will set ApiName as key,Path as value
  641. //var apis = new Map();
  642. var nozzlesIntervalId = -1;
  643. var currenthref = window.location.href;
  644. var currentPath = window.location.pathname;
  645. var currentHP = currenthref.slice(0, currenthref.indexOf(currentPath) + 1);
  646. //"ws://localhost:8384/mqtt"
  647. var ipUsedForMqtt = "ws:" + currentHP.slice(currentHP.indexOf("//")) + "mqtt";
  648. $(document).ready(function () {
  649. if (apis.has("GetVRBoardNozzles") && document.getElementById("toggleOnlineMonitor") !== null) {
  650. document.getElementById("toggleOnlineMonitor").style.visibility = "visible";
  651. } else if (document.getElementById("toggleOnlineMonitor") !== null) {
  652. document.getElementById("toggleOnlineMonitor").style.visibility = "hidden";
  653. }
  654. nozzlesIntervalId = setInterval(function () {
  655. console.log("time interval");
  656. if (vm.Nozzles.length === 0) {
  657. ALNozzlesSubscribeEvents();
  658. }
  659. }, 5000);
  660. if (apis.size > 0 && apis.has("GetPumpsLayout")) {
  661. NozzlesSubscribeEvents();
  662. return;
  663. }
  664. var requestData = ["localMqtt", ["IfsfFdcServer"]];
  665. ShowMeAPIS(requestData, function () {
  666. NozzlesSubscribeEvents();
  667. });
  668. //var serviceUrl = currentHP+"u/?apitype=service&an=ShowMeApi&pn=ProcessorsDispatcher&en=Edge.Core.Processor.Dispatcher.DefaultDispatcher";
  669. //$.ajax({
  670. // url: serviceUrl,
  671. // datatype: "application/json",
  672. // type: 'post',
  673. // contentType: "application/json;charset=utf-8;",
  674. // data: JSON.stringify(requestData),
  675. // beforeSend: function () {
  676. // },
  677. // success: function (data) {
  678. // console.log(data);
  679. // data.forEach(function (d) {
  680. // if (apis.has(d.ApiName)) {
  681. // apis.delete(d.ApiName);
  682. // }
  683. // apis.set(d.ApiName, d.Path.slice(d.Path.length - 1) === "+" ? d.Path.slice(0, d.Path.length-1) : d.Path);
  684. // });
  685. // NozzlesSubscribeEvents();
  686. // },
  687. // error: function (err) {
  688. // console.log(err);
  689. // }
  690. //});
  691. });
  692. var options = {
  693. //mqtt客户端的id,这里面应该还可以加上其他参数,具体看官方文档
  694. clientId: 'mqttjs_' + (Math.random() * 1000000).toString(),
  695. timeout: 5000,
  696. useSSL: false
  697. }
  698. //浏览器采用websocket协议,host主机地址为192.168.0.200,端口为9001,路径为/mqtt
  699. //var client = mqtt.connect(ipUsedForMqtt, options); // you add a ws:// url here
  700. function NozzlesSubscribeEvents()
  701. {
  702. if (!mqttclient.connected || apis.size === 0) {
  703. console.log("subscribeEvents:client is not connected or haven't got APIS");
  704. return;
  705. }
  706. mqttclient.subscribe(apis.has("GetPumpsLayout_Reply") ? apis.get("GetPumpsLayout_Reply"):'/Applications.FDC.FdcServerHostApp/fdcServerApp/thing/service/GetPumpsLayout_reply/',
  707. function (err) {
  708. if (!err) {
  709. var temp = {
  710. "parameters": [
  711. { "name": "pumpId", "value": "-1" }
  712. ]
  713. };
  714. var message = JSON.stringify(temp);
  715. mqttclient.publish(apis.has("GetPumpsLayout") ? apis.get("GetPumpsLayout") : '/Applications.FDC.FdcServerHostApp/fdcServerApp/thing/service/GetPumpsLayout/', message);
  716. //client.publish('/sys/fdcServerApp/Applications.FDC.FdcServerHostApp/thing/service/GetPumpsLayout', message);
  717. };
  718. });
  719. mqttclient.subscribe(apis.has("OnFdcControllerStateChange")?apis.get("OnFdcControllerStateChange"): '/Applications.FDC.FdcServerHostApp/fdcServerApp/thing/event/OnFdcControllerStateChange/post',
  720. function (err) {
  721. if (!err) {
  722. console.log("subscribe fdc controller state change event successfully");
  723. } else {
  724. console.log("subscribe fdc controller state change event failed" + err);
  725. }
  726. });
  727. mqttclient.subscribe(apis.has("OnCurrentFuellingStatusChange") ? apis.get("OnCurrentFuellingStatusChange") : '/Applications.FDC.FdcServerHostApp/fdcServerApp/thing/event/OnCurrentFuellingStatusChange/post',
  728. function (err) {
  729. if (!err) {
  730. console.log("subscribe current fuel status change event successfully");
  731. } else {
  732. console.log("subscribe current fuel status change event failed" + err);
  733. }
  734. });
  735. mqttclient.subscribe(apis.has("OnFdcFuelSaleTransactinStateChange") ? apis.get("OnFdcFuelSaleTransactinStateChange"):'/Applications.FDC.FdcServerHostApp/fdcServerApp/thing/event/OnFdcFuelSaleTransactinStateChange/post',
  736. function (err) {
  737. if (!err) {
  738. console.log("subscribe current fuel status change event successfully");
  739. } else {
  740. console.log("subscribe current fuel status change event failed" + err);
  741. }
  742. });
  743. mqttclient.subscribe(apis.has("GetLastAvailableTransaction_Reply") ? apis.get("GetLastAvailableTransaction_Reply") : '/Applications.FDC.FdcServerHostApp/fdcServerApp/thing/service/GetLastAvailableTransaction_Reply/',
  744. function (err) {
  745. if (!err) {
  746. console.log("subscribe GetLastAvailableTransaction_Reply successfully");
  747. };
  748. });
  749. mqttclient.subscribe(apis.has("GetDeviceState_Reply") ? apis.get("GetDeviceState_Reply"):'/Applications.FDC.FdcServerHostApp/fdcServerApp/thing/service/GetDeviceState_reply/',
  750. function (err) {
  751. if (!err) {
  752. console.log("subscribe GetDeviceState_reply successfully" + apis.get("GetDeviceState_Reply"));
  753. };
  754. });
  755. }
  756. ////建立连接
  757. mqttclient.on('connect',
  758. function () {
  759. console.log("connected");
  760. NozzlesSubscribeEvents();
  761. });
  762. //如果连接错误,打印错误
  763. mqttclient.on('error',
  764. function (err) {
  765. console.log("error happens, will close the client");
  766. mqttclient.end();
  767. });
  768. //如果client订阅主题成功,那么这里就是当接收到自己订阅主题的处理逻辑
  769. function OnReply(apis, topic, jsonObj) {
  770. var temp = apis.has("GetPumpsLayout_Reply") ? apis.get("GetPumpsLayout_Reply") : "/Applications.FDC.FdcServerHostApp/fdcServerApp/thing/service/GetPumpsLayout_reply/";
  771. if (topic === temp) {
  772. if (nozzlesIntervalId !== -1) {
  773. console.log("Nozzles Page:stop the interval " + nozzlesIntervalId);
  774. clearInterval(nozzlesIntervalId);
  775. }
  776. ClearOldItems();
  777. GenerateSmartFuelNozzleView(jsonObj);
  778. //get available transactions for all pumps, so there's no need to add parameter for this publish
  779. //client.publish("/sys/fdcServerApp/Applications.FDC.FdcServerHostApp/thing/service/GetAvailableTransactions");
  780. return;
  781. }
  782. temp = apis.has("OnCurrentFuellingStatusChange") ? apis.get("OnCurrentFuellingStatusChange") : "/Applications.FDC.FdcServerHostApp/fdcServerApp/thing/event/OnCurrentFuellingStatusChange/post";
  783. if (topic === temp) {
  784. ProcessCurrentFuellingStateChange(jsonObj);
  785. return;
  786. }
  787. temp = apis.has("OnFdcFuelSaleTransactinStateChange") ? apis.get("OnFdcFuelSaleTransactinStateChange") : '/Applications.FDC.FdcServerHostApp/fdcServerApp/thing/event/OnFdcFuelSaleTransactinStateChange/post';
  788. if (topic === temp) {
  789. ProcessTransactionStateChange(jsonObj);
  790. return;
  791. }
  792. temp = apis.has("OnFdcControllerStateChange") ? apis.get("OnFdcControllerStateChange") : '/Applications.FDC.FdcServerHostApp/fdcServerApp/thing/event/OnFdcControllerStateChange/post';
  793. if (topic === temp) {
  794. ProcessFdcControllerStatusChange(jsonObj);
  795. return;
  796. }
  797. temp = apis.has("GetLastAvailableTransaction_Reply") ? apis.get("GetLastAvailableTransaction_Reply") : '/Applications.FDC.FdcServerHostApp/fdcServerApp/thing/service/GetLastAvailableTransaction_Reply/';
  798. if (topic === temp) {
  799. UpdatePayableStatus(jsonObj);
  800. return;
  801. }
  802. temp = apis.has("GetDeviceState_Reply") ? apis.get("GetDeviceState_Reply") : '/Applications.FDC.FdcServerHostApp/fdcServerApp/thing/service/GetDeviceState_reply/';
  803. if (topic === temp) {
  804. ProcessDeviceState(jsonObj);
  805. return;
  806. }
  807. }
  808. //显示前一页
  809. function ShowPreviousPage() {
  810. if (currentPage === 1) {
  811. //alert("已经是第一页!");
  812. dialogBox("提示信息", "已經是第一頁",null,null);
  813. return;
  814. }
  815. ClearOldItems();
  816. oldPage = currentPage;
  817. currentPage--;
  818. var temp = {
  819. "parameters": [
  820. { "name": "pumpId", "value": "-1" }
  821. ]
  822. };
  823. //如果当前油气回收页面则重新获取NozzlesData
  824. if (mqttclient != null) {
  825. mqttclient.publish(apis.has("GetPumpsLayout") ? apis.get("GetPumpsLayout"):'/Applications.FDC.FdcServerHostApp/fdcServerApp/thing/service/GetPumpsLayout/', JSON.stringify(temp));
  826. }
  827. }
  828. //显示下一页
  829. function ShowNextPage() {
  830. if (currentPage === totalPage) {
  831. //alert("已经是最后一页!");
  832. dialogBox("提示信息", "已經是最後一頁",null,null);
  833. return;
  834. }
  835. ClearOldItems();
  836. oldPage = currentPage;
  837. currentPage++;
  838. var temp = {
  839. "parameters": [
  840. { "name": "pumpId", "value": "-1" }
  841. ]
  842. };
  843. //如果当前油气回收页面则重新获取NozzlesData
  844. if (mqttclient != null) {
  845. mqttclient.publish(apis.has("GetPumpsLayout") ? apis.get("GetPumpsLayout") :'/Applications.FDC.FdcServerHostApp/fdcServerApp/thing/service/GetPumpsLayout/', JSON.stringify(temp));
  846. }
  847. }
  848. </script>