converter.js 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601
  1. var mid = 1;
  2. function getMid() {
  3. mid++;
  4. if (mid > 10000) {
  5. mid = 1;
  6. }
  7. return mid + "";
  8. }
  9. //上行数据
  10. this.decode = function (msg) {
  11. var content = msg.content;
  12. var topic = content.topic;
  13. var bytes = CRC.strToByte(content.payload);
  14. if (topic.endsWith("/thing/model/up_raw")) {
  15. var byteData = ab2hex(bytes)
  16. var data = arrayGroup(byteData, 2);
  17. var params = {};
  18. var uint8Array = new Uint8Array(bytes.length);
  19. for (var i = 0; i < bytes.length; i++) {
  20. uint8Array[i] = bytes[i] & 0xff;
  21. }
  22. if (data[1] == '03') {
  23. if (byteData.length == 22 ) {
  24. params['Switch'] = Number(parseInt(data[3] + data[4], 16))
  25. params['HandMode'] = Number(parseInt(data[5] + data[6], 16))+1
  26. params['TempGear'] = Number(data[7].slice(1,2))+1
  27. params['RatioGear'] = Number(data[7].slice(0,1))+1
  28. params['PressureGear'] = data[8].slice(0,1) != 'f' ? Number(data[8].slice(0,1))+1 : 0
  29. params['SpeedGear'] = data[8].slice(1,2) != 'f' ? Number(data[8].slice(1,2))+1 : 0
  30. } else if (byteData.length == 126) {
  31. params['Pressure'] = Number((parseInt(data[3] + data[4], 16) / 100).toFixed(1))
  32. params['EmtyRunPressure'] = Number((parseInt(data[5] + data[6], 16) / 100).toFixed(1))
  33. params['StartPressure'] = Number((parseInt(data[7] + data[8], 16) / 100).toFixed(1))
  34. params['WorkMode'] = Number((parseInt(data[9] + data[10], 16)).toFixed(0))
  35. params['ClearIceEn'] = Number((parseInt(data[11] + data[12], 16)).toFixed(0))
  36. params['WaterT'] = Number((parseInt(data[13] + data[14], 16)).toFixed(0))
  37. params['WaterTReset'] = Number((parseInt(data[15] + data[16], 16)).toFixed(0))
  38. params['SensorMode'] = Number((parseInt(data[17] + data[18], 16)).toFixed(0))
  39. params['SensorGroup'] = Number((parseInt(data[19] + data[20], 16)).toFixed(0))
  40. params['ElectronicTMax'] = Number(parseInt(data[59], 16))
  41. params['ElectronicTMaxReset'] = Number(parseInt(data[60], 16))
  42. } else if (byteData.length == 26) {
  43. params['ActiveTime'] = String(parseInt(data[3], 16))+'-'+String(parseInt(data[4], 16))+'-'+String(parseInt(data[5], 16))
  44. } else if (byteData.length == 190) {
  45. params['Pressure'] = Number((parseInt(data[3] + data[4], 16) / 100).toFixed(1))
  46. params['EmtyRunPressure'] = Number((parseInt(data[5] + data[6], 16) / 100).toFixed(1))
  47. params['StartPressure'] = Number((parseInt(data[7] + data[8], 16) / 100).toFixed(1))
  48. params['WorkMode'] = Number((parseInt(data[9] + data[10], 16)).toFixed(0))
  49. params['ClearIceEn'] = Number((parseInt(data[11] + data[12], 16)).toFixed(0))
  50. params['WaterT'] = Number((parseInt(data[13] + data[14], 16)).toFixed(0))
  51. params['WaterTReset'] = Number((parseInt(data[15] + data[16], 16)).toFixed(0))
  52. params['SensorMode'] = Number((parseInt(data[17] + data[18], 16)).toFixed(0))
  53. params['SensorGroup'] = Number((parseInt(data[19] + data[20], 16)).toFixed(0))
  54. params['ElectronicTMax'] = Number(parseInt(data[59], 16))
  55. params['ElectronicTMaxReset'] = Number(parseInt(data[60], 16))
  56. params['SceneMode'] = Number((parseInt(data[63] + data[64], 16)).toFixed(0))
  57. params['EnergyModeTime'] = Number((parseInt(data[65] + data[66], 16)).toFixed(0))
  58. params['WaterTime'] = String(Number((parseInt(data[68].substring(0, 1), 16)).toFixed(0))) + ',' + String(Number((parseInt(data[68].substring(1), 16)).toFixed(0)))
  59. params['HotWaterTime'] = Number((parseInt(data[69] + data[70], 16)).toFixed(0))
  60. params['TempSet'] = String(Number((parseInt(data[71], 16)).toFixed(0)))+','+ String(Number((parseInt(data[72], 16)).toFixed(0)))
  61. params['TimeModeSet'] = parseInt(data[73] + data[74], 16)+'-'+parseInt(data[75] + data[76], 16)+','+ parseInt(data[77] + data[78], 16)+'-'+parseInt(data[79] + data[80], 16)+','+ parseInt(data[81] + data[82], 16)+'-'+parseInt(data[83] + data[84], 16)+','+ parseInt(data[85] + data[86], 16)+'-'+parseInt(data[87] + data[88], 16)+','+ parseInt(data[89] + data[90], 16)+'-'+parseInt(data[91] + data[92], 16)
  62. } else if (byteData.length == 94) {
  63. let timeStamp = parseInt(String(data[41])+String(data[42])+String(data[43])+String(data[44]),16)
  64. let time = timestampToTime(timeStamp)
  65. params['ActiveTime'] = String(parseInt(data[3], 16))+'-'+String(parseInt(data[4], 16))+'-'+String(parseInt(data[5], 16))
  66. params['Time'] = time + '-'+ timeStamp
  67. }
  68. } else if (data[1] == '04') {
  69. if (byteData.length == 54) {
  70. params['ErrorMsg'] = Number(parseInt(data[3]+data[4], 16))
  71. params['Voltage'] = Number(parseInt(data[5]+data[6], 16))
  72. params['Electric'] = Number(parseInt(data[7]+data[8], 16))/10
  73. params['Power'] = Number(parseInt(data[9]+data[10], 16))
  74. params['Speed'] = Number(parseInt(data[11]+data[12], 16))
  75. params['CurrentPressure1'] = data[13] != 'ff' ? Number((parseInt(data[13]+data[14], 16)/100).toFixed(1)) : 0
  76. params['CurrentPressure2'] = data[15] != 'ff' ? Number((parseInt(data[15]+data[16], 16)/100).toFixed(1)) : 0
  77. params['IpmTemperature'] = Number(parseInt(data[17]+data[18], 16))-55
  78. params['MotorTemperature'] = Number(parseInt(data[19]+data[20], 16))-55
  79. params['WaterTemperature'] = Number(parseInt(data[21]+data[22], 16))-55
  80. let warnArray = reverseStr(hex2bin(data[23] + data[24]))
  81. let warnInfo = ""
  82. for (let i = 0; i < warnArray.length; i++) {
  83. if (warnArray[i] === "1") {
  84. if (warnInfo === "") {
  85. warnInfo = DEVICE_ERROR[i]
  86. } else {
  87. warnInfo += `、${DEVICE_ERROR[i]}`
  88. }
  89. }
  90. }
  91. params['WarnInfo'] = warnInfo
  92. } else if (byteData.length == 18) {
  93. if (String(byteData) == '130404000800004847') {
  94. params['query'] = String(byteData)
  95. } else if (String(byteData).slice(9,10) == 3) {
  96. params['query'] = String(byteData)
  97. } else if (String(byteData).slice(9,10) == 4) {
  98. params['query'] = String(byteData)
  99. }
  100. } else if (byteData.length == 30) {
  101. params['McuVersion'] = String(Number(parseInt(data[3].slice(1,2), 16)))+'.'+String(Number(parseInt(data[4].slice(0,1), 16)))+'.'+String(Number(parseInt(data[4].slice(1,2), 16)))
  102. params['McuStatus'] = Number(parseInt(data[3].slice(0,1), 16))
  103. params['Scene'] = Number(parseInt(data[9]+data[10], 16))
  104. params['Model'] = String(Number(parseInt(data[11]+data[12], 16)))+'W'
  105. } else if (byteData.length == 66) {
  106. params['ErrorMsg'] = Number(parseInt(data[3]+data[4], 16))
  107. params['Voltage'] = Number(parseInt(data[5]+data[6], 16))
  108. params['Electric'] = Number(parseInt(data[7]+data[8], 16))/10
  109. params['Power'] = Number(parseInt(data[9]+data[10], 16))
  110. params['Speed'] = Number(parseInt(data[11]+data[12], 16))
  111. params['CurrentPressure1'] = data[13] != 'ff' ? Number((parseInt(data[13]+data[14], 16)/100).toFixed(1)) : 0
  112. params['CurrentPressure2'] = data[15] != 'ff' ? Number((parseInt(data[15]+data[16], 16)/100).toFixed(1)) : 0
  113. params['IpmTemperature'] = Number(parseInt(data[17]+data[18], 16))-55
  114. params['MotorTemperature'] = Number(parseInt(data[19]+data[20], 16))-55
  115. params['WaterTemperature'] = Number(parseInt(data[21]+data[22], 16))-55
  116. let warnArray = reverseStr(hex2bin(data[23] + data[24]))
  117. let warnInfo = ""
  118. for (let i = 0; i < warnArray.length; i++) {
  119. if (warnArray[i] === "1") {
  120. if (warnInfo === "") {
  121. warnInfo = DEVICE_ERROR[i]
  122. } else {
  123. warnInfo += `、${DEVICE_ERROR[i]}`
  124. }
  125. }
  126. }
  127. params['CountDown'] = Number(parseInt(data[25]+data[26], 16))
  128. params['WarnInfo'] = warnInfo
  129. params['Enabled'] = Number(parseInt(data[29]+data[30], 16))
  130. }
  131. }
  132. params['History'] = byteData
  133. //属性上报
  134. return {
  135. mid: msg.mid,
  136. productKey: msg.productKey,
  137. deviceName: msg.deviceName,
  138. type: "property",
  139. identifier: "report", //属性上报
  140. occur: new Date().getTime(), //时间戳,设备上的事件或数据产生的本地时间
  141. time: new Date().getTime(), //时间戳,消息上报时间
  142. data: params,
  143. };
  144. } else if (topic.indexOf("/event/") > 0) {
  145. //事件上报
  146. } else if (topic.endsWith("/service/property/set_reply")) {
  147. //属性设置回复
  148. } else if (topic.endsWith("/config/set_reply")) {
  149. //设备配置设置回复
  150. } else if (topic.endsWith("/config/get")) {
  151. //设备配置获取
  152. } else if (topic.endsWith("_reply")) {
  153. //服务回复
  154. }
  155. return null;
  156. };
  157. //下行数据
  158. this.encode = function (service, device) {
  159. var deviceMid = getMid();
  160. var method = "thing.service.";
  161. var topic = "/sys/" + service.productKey + "/" + service.deviceName + "/thing/model/down_raw";
  162. var params = {};
  163. var type = service.type;
  164. var identifier = service.identifier;
  165. if (type == "property" && identifier == "get") {
  166. var listParams = []
  167. for (var p in service.params) {
  168. listParams.push(service.params[p]);
  169. }
  170. return {
  171. productKey: service.productKey,
  172. deviceName: service.deviceName,
  173. mid: deviceMid,
  174. content: {
  175. topic: topic,
  176. payload: JSON.stringify({
  177. id: deviceMid,
  178. method: method += "property." + identifier,
  179. params: listParams
  180. })
  181. }
  182. }
  183. } else if (type == "property" && identifier == "set") {
  184. for (var p in service.params) {
  185. params[p] = service.params[p];
  186. }
  187. //站地址
  188. if (paramsArr.includes('query')) {
  189. let queryHexData = arrayGroup(params['query'],2)
  190. let queryData = []
  191. queryHexData.map(function(value) {
  192. queryData.push(parseInt(value,16))
  193. })
  194. payloadArray = queryData
  195. } else {
  196. const stationAddress = "49";
  197. totalArray.push(stationAddress)
  198. //功能码
  199. var functionCode = "";
  200. // 寄存器数量
  201. var register = ''
  202. var baseVal = ''
  203. //起始地址
  204. var startAddressCode = '';
  205. if (paramsArr.length == 1) {
  206. functionCode = '06'
  207. totalArray.push(functionCode)
  208. } else {
  209. functionCode = '10'
  210. paramsArr = ['Pressure', 'EmtyRunPressure', 'StartPressure', 'WorkMode', 'ClearIceEn', 'WaterT', 'WaterTReset']
  211. totalArray.push(parseInt(Number(functionCode),16))
  212. }
  213. if (paramsArr.includes('Switch')) {
  214. startAddressCode = 300
  215. totalArray.push('01','44')
  216. } else if (paramsArr.includes('Pressure')) {
  217. startAddressCode = 400
  218. totalArray.push('01','144')
  219. register = '00' + add0(String(paramsArr.length),2) + add0(String((paramsArr.length*2).toString(16)),2)
  220. totalArray.push('00', add0(paramsArr.length,2), add0(String((paramsArr.length)*2),2))
  221. }
  222. if (functionCode == 6) {
  223. paramsArr.forEach(function(value){
  224. totalArray.push('00',params[value])
  225. itemArray = pad(params[value].toString(16),4)
  226. deviceArray.push(itemArray[0],itemArray[1])
  227. })
  228. } else if (functionCode == 10) {
  229. paramsArr.forEach(function(value, index){
  230. if (index < 3) {
  231. // if (params[value]*100 < 256) {
  232. // totalItemArray = ['00', String((params[value]*100).toFixed(0))]
  233. // itemArray = pad(String((params[value]*100).toString(16)),4)
  234. // totalItemArray = pad(String((params[value]*100).toFixed(0)),4)
  235. // } else {
  236. // outFFIndex = ((Number(params[value]*100))/256).toFixed(0)
  237. // totalItemArray = [outFFIndex, params[value]*100-outFFIndex*256]
  238. // }
  239. itemArray = pad(Number((params[value]*100).toFixed(0)).toString(16),4)
  240. totalItemArray = pad(String((params[value]*100).toFixed(0)),4)
  241. } else {
  242. itemArray = pad(String(params[value].toString(16)),4)
  243. totalItemArray = pad(String(params[value]),4)
  244. }
  245. // totalArray.push(params[value])
  246. // totalArray.push(totalItemArray[0],totalItemArray[1])
  247. totalArray.push(parseInt(itemArray[0],16),parseInt(itemArray[1],16))
  248. // deviceArray.push(parseInt(itemArray[0],16),parseInt(itemArray[1],16))
  249. deviceArray.push(itemArray[0],itemArray[1])
  250. })
  251. }
  252. var startAddressHex = pad(startAddressCode.toString(16), 4);
  253. baseVal = String(stationAddress) + String(functionCode) + String(startAddressHex[0]) + String(startAddressHex[1])
  254. if (functionCode != 6) {
  255. baseVal += register
  256. }
  257. deviceArray.forEach(function(item) {
  258. baseVal += item
  259. })
  260. // baseVal += '00070e0064000a00640001000100370037'
  261. var Crc = CRC.ToModbusCRC16(baseVal)
  262. var crcArray = arrayGroup(Crc,2)
  263. totalArray.push(parseInt(crcArray[0],16),parseInt(crcArray[1],16))
  264. payloadArray = totalArray;
  265. }
  266. // var params = json['params'];
  267. // var prop_float = params['prop_float'];
  268. // var prop_int16 = params['prop_int16'];
  269. // var prop_bool = params['prop_bool'];
  270. // //按照自定义协议格式拼接 rawData。
  271. // payloadArray = payloadArray.concat(buffer_uint8(COMMAND_SET)); //command字段。
  272. // payloadArray = payloadArray.concat(buffer_int32(parseInt(id))); //ALink JSON格式 'id'。
  273. // payloadArray = payloadArray.concat(buffer_int16(prop_int16)); //属性'prop_int16'的值。
  274. // payloadArray = payloadArray.concat(buffer_uint8(prop_bool)); //属性'prop_bool'的值。
  275. // payloadArray = payloadArray.concat(buffer_float32(prop_float)); //属性'prop_float'的值。
  276. }else if (method == 'thing.event.property.post') { //设备上报数据返回结果,如果不需要回复,可以去除该内容
  277. var code = json['code'];
  278. payloadArray = payloadArray.concat(buffer_uint8(COMMAND_REPORT_REPLY)); //command字段
  279. payloadArray = payloadArray.concat(buffer_int32(parseInt(id))); // ALink JSON格式 'id'
  280. payloadArray = payloadArray.concat(buffer_uint8(code));
  281. } else { //未知命令,对于有些命令不做处理
  282. var code = json['code'];
  283. payloadArray = payloadArray.concat(buffer_uint8(COMMAD_UNKOWN)); //command字段
  284. payloadArray = payloadArray.concat(buffer_int32(parseInt(id))); // ALink JSON格式 'id'
  285. payloadArray = payloadArray.concat(buffer_uint8(code));
  286. }
  287. return {
  288. productKey: service.productKey,
  289. deviceName: service.deviceName,
  290. mid: deviceMid,
  291. content: {
  292. topic: topic,
  293. payload: JSON.stringify({
  294. id: deviceMid,
  295. method: method += "property." + identifier,
  296. params: payloadArray
  297. })
  298. }
  299. }
  300. };
  301. const DEVICE_ERROR = [
  302. "压力传感器故障", //0
  303. "高温限功率", //1
  304. "渗漏", // 2
  305. "电机温度传感器故障", //3
  306. "水温传感器故障", //4
  307. "保留", //5
  308. "保留", //6
  309. "保留", //7
  310. "保留", //8
  311. "保留", //9
  312. "保留", //10
  313. "保留", //11
  314. "保留", //12
  315. "保留", //13
  316. "保留", //14
  317. "保留", // 15
  318. "保留", //16
  319. ]
  320. function buffer_uint8(value) {
  321. var uint8Array = new Uint8Array(1);
  322. var dv = new DataView(uint8Array.buffer, 0);
  323. dv.setUint8(0, value);
  324. return [].slice.call(uint8Array);
  325. }
  326. function buffer_int16(value) {
  327. var uint8Array = new Uint8Array(2);
  328. var dv = new DataView(uint8Array.buffer, 0);
  329. dv.setInt16(0, value);
  330. return [].slice.call(uint8Array);
  331. }
  332. function buffer_int32(value) {
  333. var uint8Array = new Uint8Array(4);
  334. var dv = new DataView(uint8Array.buffer, 0);
  335. dv.setInt32(0, value);
  336. return [].slice.call(uint8Array);
  337. }
  338. function buffer_float32(value) {
  339. var uint8Array = new Uint8Array(4);
  340. var dv = new DataView(uint8Array.buffer, 0);
  341. dv.setFloat32(0, value);
  342. return [].slice.call(uint8Array);
  343. }
  344. function ab2hex(buffer) {
  345. var hexArr = Array.prototype.map.call(
  346. new Uint8Array(buffer),
  347. function (bit) {
  348. return ('00' + bit.toString(16)).slice(-2)
  349. }
  350. )
  351. return hexArr.join('');
  352. }
  353. function arrayGroup(ss, step) {
  354. var r = [];
  355. function doGroup(s) {
  356. if (!s) return;
  357. r.push(s.substr(0, step));
  358. s = s.substr(step);
  359. doGroup(s);
  360. }
  361. doGroup(ss);
  362. return r;
  363. }
  364. var CRC = {};
  365. CRC._auchCRCHi = [
  366. 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0,
  367. 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
  368. 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
  369. 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
  370. 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1,
  371. 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
  372. 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1,
  373. 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
  374. 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0,
  375. 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40,
  376. 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1,
  377. 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
  378. 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0,
  379. 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40,
  380. 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
  381. 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
  382. 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0,
  383. 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
  384. 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
  385. 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
  386. 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
  387. 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40,
  388. 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1,
  389. 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
  390. 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0,
  391. 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40
  392. ];
  393. CRC._auchCRCLo = [
  394. 0x00, 0xC0, 0xC1, 0x01, 0xC3, 0x03, 0x02, 0xC2, 0xC6, 0x06,
  395. 0x07, 0xC7, 0x05, 0xC5, 0xC4, 0x04, 0xCC, 0x0C, 0x0D, 0xCD,
  396. 0x0F, 0xCF, 0xCE, 0x0E, 0x0A, 0xCA, 0xCB, 0x0B, 0xC9, 0x09,
  397. 0x08, 0xC8, 0xD8, 0x18, 0x19, 0xD9, 0x1B, 0xDB, 0xDA, 0x1A,
  398. 0x1E, 0xDE, 0xDF, 0x1F, 0xDD, 0x1D, 0x1C, 0xDC, 0x14, 0xD4,
  399. 0xD5, 0x15, 0xD7, 0x17, 0x16, 0xD6, 0xD2, 0x12, 0x13, 0xD3,
  400. 0x11, 0xD1, 0xD0, 0x10, 0xF0, 0x30, 0x31, 0xF1, 0x33, 0xF3,
  401. 0xF2, 0x32, 0x36, 0xF6, 0xF7, 0x37, 0xF5, 0x35, 0x34, 0xF4,
  402. 0x3C, 0xFC, 0xFD, 0x3D, 0xFF, 0x3F, 0x3E, 0xFE, 0xFA, 0x3A,
  403. 0x3B, 0xFB, 0x39, 0xF9, 0xF8, 0x38, 0x28, 0xE8, 0xE9, 0x29,
  404. 0xEB, 0x2B, 0x2A, 0xEA, 0xEE, 0x2E, 0x2F, 0xEF, 0x2D, 0xED,
  405. 0xEC, 0x2C, 0xE4, 0x24, 0x25, 0xE5, 0x27, 0xE7, 0xE6, 0x26,
  406. 0x22, 0xE2, 0xE3, 0x23, 0xE1, 0x21, 0x20, 0xE0, 0xA0, 0x60,
  407. 0x61, 0xA1, 0x63, 0xA3, 0xA2, 0x62, 0x66, 0xA6, 0xA7, 0x67,
  408. 0xA5, 0x65, 0x64, 0xA4, 0x6C, 0xAC, 0xAD, 0x6D, 0xAF, 0x6F,
  409. 0x6E, 0xAE, 0xAA, 0x6A, 0x6B, 0xAB, 0x69, 0xA9, 0xA8, 0x68,
  410. 0x78, 0xB8, 0xB9, 0x79, 0xBB, 0x7B, 0x7A, 0xBA, 0xBE, 0x7E,
  411. 0x7F, 0xBF, 0x7D, 0xBD, 0xBC, 0x7C, 0xB4, 0x74, 0x75, 0xB5,
  412. 0x77, 0xB7, 0xB6, 0x76, 0x72, 0xB2, 0xB3, 0x73, 0xB1, 0x71,
  413. 0x70, 0xB0, 0x50, 0x90, 0x91, 0x51, 0x93, 0x53, 0x52, 0x92,
  414. 0x96, 0x56, 0x57, 0x97, 0x55, 0x95, 0x94, 0x54, 0x9C, 0x5C,
  415. 0x5D, 0x9D, 0x5F, 0x9F, 0x9E, 0x5E, 0x5A, 0x9A, 0x9B, 0x5B,
  416. 0x99, 0x59, 0x58, 0x98, 0x88, 0x48, 0x49, 0x89, 0x4B, 0x8B,
  417. 0x8A, 0x4A, 0x4E, 0x8E, 0x8F, 0x4F, 0x8D, 0x4D, 0x4C, 0x8C,
  418. 0x44, 0x84, 0x85, 0x45, 0x87, 0x47, 0x46, 0x86, 0x82, 0x42,
  419. 0x43, 0x83, 0x41, 0x81, 0x80, 0x40
  420. ];
  421. CRC.CRC16 = function (buffer) {
  422. var hi = 0xff;
  423. var lo = 0xff;
  424. for (var i = 0; i < buffer.length; i++) {
  425. var idx = hi ^ buffer[i];
  426. hi = (lo ^ CRC._auchCRCHi[idx]);
  427. lo = CRC._auchCRCLo[idx];
  428. }
  429. return CRC.padLeft((hi << 8 | lo).toString(16).toUpperCase(), 4, '0');
  430. };
  431. CRC.isArray = function (arr) {
  432. return Object.prototype.toString.call(arr) === '[object Array]';
  433. };
  434. CRC.ToCRC16 = function (str) {
  435. return CRC.CRC16(CRC.isArray(str) ? str : CRC.strToByte(str));
  436. };
  437. CRC.ToModbusCRC16 = function (str) {
  438. return CRC.CRC16(CRC.isArray(str) ? str : CRC.strToHex(str));
  439. };
  440. CRC.strToByte = function (str) {
  441. var tmp = str.split(''),
  442. arr = [];
  443. for (var i = 0, c = tmp.length; i < c; i++) {
  444. var j = encodeURI(tmp[i]);
  445. if (j.length == 1) {
  446. arr.push(j.charCodeAt());
  447. } else {
  448. var b = j.split('%');
  449. for (var m = 1; m < b.length; m++) {
  450. arr.push(parseInt('0x' + b[m]));
  451. }
  452. }
  453. }
  454. return arr;
  455. };
  456. CRC.convertChinese = function (str) {
  457. var tmp = str.split(''),
  458. arr = [];
  459. for (var i = 0, c = tmp.length; i < c; i++) {
  460. var s = tmp[i].charCodeAt();
  461. if (s <= 0 || s >= 127) {
  462. arr.push(s.toString(16));
  463. } else {
  464. arr.push(tmp[i]);
  465. }
  466. }
  467. return arr;
  468. };
  469. CRC.filterChinese = function (str) {
  470. var tmp = str.split(''),
  471. arr = [];
  472. for (var i = 0, c = tmp.length; i < c; i++) {
  473. var s = tmp[i].charCodeAt();
  474. if (s > 0 && s < 127) {
  475. arr.push(tmp[i]);
  476. }
  477. }
  478. return arr;
  479. };
  480. CRC.strToHex = function (hex, isFilterChinese) {
  481. hex = isFilterChinese ? CRC.filterChinese(hex).join('') : CRC.convertChinese(hex).join('');
  482. //清除所有空格
  483. hex = hex.replace(/\s/g, "");
  484. //若字符个数为奇数,补一个空格
  485. hex += hex.length % 2 != 0 ? " " : "";
  486. var c = hex.length / 2,
  487. arr = [];
  488. for (var i = 0; i < c; i++) {
  489. arr.push(parseInt(hex.substr(i * 2, 2), 16));
  490. }
  491. return arr;
  492. };
  493. CRC.padLeft = function (s, w, pc) {
  494. if (pc == undefined) {
  495. pc = '0';
  496. }
  497. for (var i = 0, c = w - s.length; i < c; i++) {
  498. s = pc + s;
  499. }
  500. return s;
  501. };
  502. function str2ab(str) {
  503. var buffer = new ArrayBuffer(str.length / 2); // 2 bytes for each char
  504. var dataView = new DataView(buffer);
  505. var str = str.split("")
  506. var n = 0;
  507. for (var i = 0; i < str.length; i = i + 2) {
  508. dataView.setUint8(n, `0x${str[i]}${str[i+1]}`)
  509. n++;
  510. }
  511. return buffer;
  512. }
  513. function pad(num, n, flag = false) {
  514. var len = num.toString().length;
  515. while (len < n) {
  516. num = "0" + num;
  517. len++;
  518. }
  519. const arr = arrayGroup(num, 2)
  520. //高低位互换
  521. if (arr[1] == '00') {
  522. flag = true
  523. }
  524. return flag ? [arr[1], arr[0]] : [arr[0], arr[1]];
  525. }
  526. function add0(num,n) {
  527. let len = num.length
  528. while(len < n){
  529. num = '0'+num
  530. len++
  531. }
  532. if (len > n) {
  533. num = String(num).slice(1)
  534. }
  535. //console.log(num)
  536. return num
  537. }
  538. function hex2bin(hex, len) {
  539. var bin = parseInt(hex, 16).toString(2);
  540. var l = bin.length;
  541. for (var i = 0; i < len - l; i++) {
  542. bin = "0" + bin;
  543. }
  544. return bin;
  545. }
  546. //翻转字符串并切割成数组
  547. function reverseStr(str) {
  548. var arr = str.split("");
  549. arr.reverse();
  550. return arr;
  551. }
  552. function timestampToTime(timestamp) {
  553. var date = new Date(timestamp * 1000);//时间戳为10位需*1000,时间戳为13位的话不需乘1000
  554. var Y = date.getFullYear() + '-';
  555. var M = (date.getMonth()+1 < 10 ? '0'+(date.getMonth()+1) : date.getMonth()+1) + '-';
  556. var D = date.getDate() + ' ';
  557. var h = date.getHours() + ':';
  558. var m = date.getMinutes() + ':';
  559. var s = date.getSeconds();
  560. return Y+M+D+h+m+s;
  561. }