converter.js 25 KB

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