component.js 6.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191
  1. !function(n){"use strict";function d(n,t){var r=(65535&n)+(65535&t);return(n>>16)+(t>>16)+(r>>16)<<16|65535&r}function f(n,t,r,e,o,u){return d((u=d(d(t,n),d(e,u)))<<o|u>>>32-o,r)}function l(n,t,r,e,o,u,c){return f(t&r|~t&e,n,t,o,u,c)}function g(n,t,r,e,o,u,c){return f(t&e|r&~e,n,t,o,u,c)}function v(n,t,r,e,o,u,c){return f(t^r^e,n,t,o,u,c)}function m(n,t,r,e,o,u,c){return f(r^(t|~e),n,t,o,u,c)}function c(n,t){var r,e,o,u;n[t>>5]|=128<<t%32,n[14+(t+64>>>9<<4)]=t;for(var c=1732584193,f=-271733879,i=-1732584194,a=271733878,h=0;h<n.length;h+=16)c=l(r=c,e=f,o=i,u=a,n[h],7,-680876936),a=l(a,c,f,i,n[h+1],12,-389564586),i=l(i,a,c,f,n[h+2],17,606105819),f=l(f,i,a,c,n[h+3],22,-1044525330),c=l(c,f,i,a,n[h+4],7,-176418897),a=l(a,c,f,i,n[h+5],12,1200080426),i=l(i,a,c,f,n[h+6],17,-1473231341),f=l(f,i,a,c,n[h+7],22,-45705983),c=l(c,f,i,a,n[h+8],7,1770035416),a=l(a,c,f,i,n[h+9],12,-1958414417),i=l(i,a,c,f,n[h+10],17,-42063),f=l(f,i,a,c,n[h+11],22,-1990404162),c=l(c,f,i,a,n[h+12],7,1804603682),a=l(a,c,f,i,n[h+13],12,-40341101),i=l(i,a,c,f,n[h+14],17,-1502002290),c=g(c,f=l(f,i,a,c,n[h+15],22,1236535329),i,a,n[h+1],5,-165796510),a=g(a,c,f,i,n[h+6],9,-1069501632),i=g(i,a,c,f,n[h+11],14,643717713),f=g(f,i,a,c,n[h],20,-373897302),c=g(c,f,i,a,n[h+5],5,-701558691),a=g(a,c,f,i,n[h+10],9,38016083),i=g(i,a,c,f,n[h+15],14,-660478335),f=g(f,i,a,c,n[h+4],20,-405537848),c=g(c,f,i,a,n[h+9],5,568446438),a=g(a,c,f,i,n[h+14],9,-1019803690),i=g(i,a,c,f,n[h+3],14,-187363961),f=g(f,i,a,c,n[h+8],20,1163531501),c=g(c,f,i,a,n[h+13],5,-1444681467),a=g(a,c,f,i,n[h+2],9,-51403784),i=g(i,a,c,f,n[h+7],14,1735328473),c=v(c,f=g(f,i,a,c,n[h+12],20,-1926607734),i,a,n[h+5],4,-378558),a=v(a,c,f,i,n[h+8],11,-2022574463),i=v(i,a,c,f,n[h+11],16,1839030562),f=v(f,i,a,c,n[h+14],23,-35309556),c=v(c,f,i,a,n[h+1],4,-1530992060),a=v(a,c,f,i,n[h+4],11,1272893353),i=v(i,a,c,f,n[h+7],16,-155497632),f=v(f,i,a,c,n[h+10],23,-1094730640),c=v(c,f,i,a,n[h+13],4,681279174),a=v(a,c,f,i,n[h],11,-358537222),i=v(i,a,c,f,n[h+3],16,-722521979),f=v(f,i,a,c,n[h+6],23,76029189),c=v(c,f,i,a,n[h+9],4,-640364487),a=v(a,c,f,i,n[h+12],11,-421815835),i=v(i,a,c,f,n[h+15],16,530742520),c=m(c,f=v(f,i,a,c,n[h+2],23,-995338651),i,a,n[h],6,-198630844),a=m(a,c,f,i,n[h+7],10,1126891415),i=m(i,a,c,f,n[h+14],15,-1416354905),f=m(f,i,a,c,n[h+5],21,-57434055),c=m(c,f,i,a,n[h+12],6,1700485571),a=m(a,c,f,i,n[h+3],10,-1894986606),i=m(i,a,c,f,n[h+10],15,-1051523),f=m(f,i,a,c,n[h+1],21,-2054922799),c=m(c,f,i,a,n[h+8],6,1873313359),a=m(a,c,f,i,n[h+15],10,-30611744),i=m(i,a,c,f,n[h+6],15,-1560198380),f=m(f,i,a,c,n[h+13],21,1309151649),c=m(c,f,i,a,n[h+4],6,-145523070),a=m(a,c,f,i,n[h+11],10,-1120210379),i=m(i,a,c,f,n[h+2],15,718787259),f=m(f,i,a,c,n[h+9],21,-343485551),c=d(c,r),f=d(f,e),i=d(i,o),a=d(a,u);return[c,f,i,a]}function i(n){for(var t="",r=32*n.length,e=0;e<r;e+=8)t+=String.fromCharCode(n[e>>5]>>>e%32&255);return t}function a(n){var t=[];for(t[(n.length>>2)-1]=void 0,e=0;e<t.length;e+=1)t[e]=0;for(var r=8*n.length,e=0;e<r;e+=8)t[e>>5]|=(255&n.charCodeAt(e/8))<<e%32;return t}function e(n){for(var t,r="0123456789abcdef",e="",o=0;o<n.length;o+=1)t=n.charCodeAt(o),e+=r.charAt(t>>>4&15)+r.charAt(15&t);return e}function r(n){return unescape(encodeURIComponent(n))}function o(n){return i(c(a(n=r(n)),8*n.length))}function u(n,t){return function(n,t){var r,e=a(n),o=[],u=[];for(o[15]=u[15]=void 0,16<e.length&&(e=c(e,8*n.length)),r=0;r<16;r+=1)o[r]=909522486^e[r],u[r]=1549556828^e[r];return t=c(o.concat(a(t)),512+8*t.length),i(c(u.concat(t),640))}(r(n),r(t))}function t(n,t,r){return t?r?u(t,n):e(u(t,n)):r?o(n):e(o(n))}"function"==typeof define&&define.amd?define(function(){return t}):"object"==typeof module&&module.exports?module.exports=t:n.md5=t}(this);
  2. var md5=this.md5;
  3. /**
  4. 网关上线
  5. 订阅:/sys/hbtgIA0SuVw9lxjB/AA:BB:CC:DD:10/c/#
  6. 子设备注册:
  7. /sys/hbtgIA0SuVw9lxjB/AA:BB:CC:DD:10/s/register
  8. {
  9. "id": "6",
  10. "params":{
  11. "productKey":"Rf4QSjbm65X45753",
  12. "deviceName":"ABC12400001",
  13. "model":"S1"
  14. }
  15. }
  16. 子设备上线
  17. 订阅:/sys/Rf4QSjbm65X45753/ABC12400001/c/#
  18. 数据上报:
  19. /sys/Rf4QSjbm65X45753/ABC12400001/s/event/property/post
  20. {
  21. "id": "6",
  22. "params":{
  23. "powerstate": 1
  24. }
  25. }
  26. */
  27. var registered={};
  28. function getPkDn(clientId){
  29. var arr=clientId.split("_");
  30. return {
  31. pk:arr[0],
  32. dn:arr[1]
  33. };
  34. }
  35. function register(payload){
  36. var auth= JSON.parse(payload);
  37. var arr= auth.clientid.split("_");
  38. if(arr.length<3){
  39. throw new Error("incorrect clientid");
  40. }
  41. var pk=arr[0];
  42. var dn=arr[1];
  43. var model=arr[2];
  44. var pwd=md5("xdkKUymrEGSCYWswqCvSPyRSFvH5j7CU"+auth.clientid);
  45. if(pwd!=auth.password){
  46. throw new Error("incorrect password");
  47. }
  48. return {
  49. type:"register",
  50. data:{
  51. productKey:pk,
  52. deviceName:dn,
  53. model:model
  54. }
  55. };
  56. }
  57. function subRegister(topic,parent,payload){
  58. var params= payload.params;
  59. var reply=
  60. {
  61. productKey:parent.productKey,
  62. deviceName:parent.deviceName,
  63. mid:"0",
  64. content:{
  65. topic:topic.replace("/s/","/c/")+"_reply",
  66. payload:JSON.stringify({
  67. id:payload.id,
  68. code:0,
  69. data:{
  70. "productKey":params.productKey,
  71. "deviceName":params.deviceName
  72. }
  73. })
  74. }
  75. };
  76. return {
  77. type:"register",
  78. data:{
  79. productKey:parent.productKey,
  80. deviceName:parent.deviceName,
  81. subDevices:[{
  82. productKey:params.productKey,
  83. deviceName:params.deviceName,
  84. model:params.model
  85. }]
  86. },
  87. action:{
  88. type:"ack",
  89. content:JSON.stringify(reply)
  90. }
  91. };
  92. }
  93. function deviceStateChange(head,clientId,state){
  94. var topic=head.topic;
  95. var device=getPkDn(clientId);
  96. var arr= topic.split('/');
  97. if(arr.length<6){
  98. throw new Error("incorrect topic")
  99. }
  100. var pk=arr[2];
  101. var dn=arr[3];
  102. return {
  103. type:"state",
  104. data:{
  105. productKey:pk,
  106. deviceName:dn,
  107. state:state,
  108. parent:{
  109. productKey:device.pk,
  110. deviceName:device.dn,
  111. }
  112. }
  113. }
  114. }
  115. function disconnect(clientId){
  116. var device=getPkDn(clientId);
  117. return {
  118. type:"state",
  119. data:{
  120. productKey:device.pk,
  121. deviceName:device.dn,
  122. state:"offline"
  123. }
  124. }
  125. }
  126. //必须提供onReceive方法
  127. this.onReceive=function(head,type,payload){
  128. if(type=='auth'){
  129. return register(payload);
  130. }
  131. if(type=='subscribe'){
  132. return deviceStateChange(head,payload,'online');
  133. }
  134. if(type=='unsubscribe'){
  135. return deviceStateChange(head,payload,'offline');
  136. }
  137. if(type=='disconnect'){
  138. return disconnect(payload);
  139. }
  140. var topic=head['topic'];
  141. if(!topic){
  142. throw new Error("topic is blank")
  143. }
  144. var arr= topic.split('/');
  145. if(arr.length<6){
  146. throw new Error("incorrect topic")
  147. }
  148. var pk=arr[2];
  149. var dn=arr[3];
  150. payload=JSON.parse(payload);
  151. //子设备注册
  152. if(topic.endsWith('/register')){
  153. return subRegister(topic,{productKey:pk,deviceName:dn},payload);
  154. }
  155. //数据上报
  156. return {
  157. type:"report",
  158. data:{
  159. productKey:pk,
  160. deviceName:dn,
  161. mid:payload.id,
  162. content:{
  163. topic:topic,
  164. payload:payload
  165. }
  166. }
  167. }
  168. }
  169. this.onRegistered=function(regInfo,result){
  170. }