converter.js 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595
  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. var hexstr = ab2hex(payloadArray);
  286. console.log("hexstr:" + hexstr);
  287. return {
  288. productKey: service.productKey,
  289. deviceName: service.deviceName,
  290. mid: deviceMid,
  291. content: {
  292. topic: topic,
  293. payload: hexstr
  294. }
  295. }
  296. };
  297. const DEVICE_ERROR = [
  298. "压力传感器故障", //0
  299. "高温限功率", //1
  300. "渗漏", // 2
  301. "电机温度传感器故障", //3
  302. "水温传感器故障", //4
  303. "保留", //5
  304. "保留", //6
  305. "保留", //7
  306. "保留", //8
  307. "保留", //9
  308. "保留", //10
  309. "保留", //11
  310. "保留", //12
  311. "保留", //13
  312. "保留", //14
  313. "保留", // 15
  314. "保留", //16
  315. ]
  316. function buffer_uint8(value) {
  317. var uint8Array = new Uint8Array(1);
  318. var dv = new DataView(uint8Array.buffer, 0);
  319. dv.setUint8(0, value);
  320. return [].slice.call(uint8Array);
  321. }
  322. function buffer_int16(value) {
  323. var uint8Array = new Uint8Array(2);
  324. var dv = new DataView(uint8Array.buffer, 0);
  325. dv.setInt16(0, value);
  326. return [].slice.call(uint8Array);
  327. }
  328. function buffer_int32(value) {
  329. var uint8Array = new Uint8Array(4);
  330. var dv = new DataView(uint8Array.buffer, 0);
  331. dv.setInt32(0, value);
  332. return [].slice.call(uint8Array);
  333. }
  334. function buffer_float32(value) {
  335. var uint8Array = new Uint8Array(4);
  336. var dv = new DataView(uint8Array.buffer, 0);
  337. dv.setFloat32(0, value);
  338. return [].slice.call(uint8Array);
  339. }
  340. function ab2hex(buffer) {
  341. var hexArr = Array.prototype.map.call(
  342. new Uint8Array(buffer),
  343. function (bit) {
  344. return ('00' + bit.toString(16)).slice(-2)
  345. }
  346. )
  347. return hexArr.join('');
  348. }
  349. function arrayGroup(ss, step) {
  350. var r = [];
  351. function doGroup(s) {
  352. if (!s) return;
  353. r.push(s.substr(0, step));
  354. s = s.substr(step);
  355. doGroup(s);
  356. }
  357. doGroup(ss);
  358. return r;
  359. }
  360. var CRC = {};
  361. CRC._auchCRCHi = [
  362. 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0,
  363. 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
  364. 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
  365. 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
  366. 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1,
  367. 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
  368. 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1,
  369. 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
  370. 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0,
  371. 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40,
  372. 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1,
  373. 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
  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, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
  377. 0x80, 0x41, 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, 0x01, 0xC0, 0x80, 0x41,
  380. 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
  381. 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
  382. 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
  383. 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40,
  384. 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1,
  385. 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
  386. 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0,
  387. 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40
  388. ];
  389. CRC._auchCRCLo = [
  390. 0x00, 0xC0, 0xC1, 0x01, 0xC3, 0x03, 0x02, 0xC2, 0xC6, 0x06,
  391. 0x07, 0xC7, 0x05, 0xC5, 0xC4, 0x04, 0xCC, 0x0C, 0x0D, 0xCD,
  392. 0x0F, 0xCF, 0xCE, 0x0E, 0x0A, 0xCA, 0xCB, 0x0B, 0xC9, 0x09,
  393. 0x08, 0xC8, 0xD8, 0x18, 0x19, 0xD9, 0x1B, 0xDB, 0xDA, 0x1A,
  394. 0x1E, 0xDE, 0xDF, 0x1F, 0xDD, 0x1D, 0x1C, 0xDC, 0x14, 0xD4,
  395. 0xD5, 0x15, 0xD7, 0x17, 0x16, 0xD6, 0xD2, 0x12, 0x13, 0xD3,
  396. 0x11, 0xD1, 0xD0, 0x10, 0xF0, 0x30, 0x31, 0xF1, 0x33, 0xF3,
  397. 0xF2, 0x32, 0x36, 0xF6, 0xF7, 0x37, 0xF5, 0x35, 0x34, 0xF4,
  398. 0x3C, 0xFC, 0xFD, 0x3D, 0xFF, 0x3F, 0x3E, 0xFE, 0xFA, 0x3A,
  399. 0x3B, 0xFB, 0x39, 0xF9, 0xF8, 0x38, 0x28, 0xE8, 0xE9, 0x29,
  400. 0xEB, 0x2B, 0x2A, 0xEA, 0xEE, 0x2E, 0x2F, 0xEF, 0x2D, 0xED,
  401. 0xEC, 0x2C, 0xE4, 0x24, 0x25, 0xE5, 0x27, 0xE7, 0xE6, 0x26,
  402. 0x22, 0xE2, 0xE3, 0x23, 0xE1, 0x21, 0x20, 0xE0, 0xA0, 0x60,
  403. 0x61, 0xA1, 0x63, 0xA3, 0xA2, 0x62, 0x66, 0xA6, 0xA7, 0x67,
  404. 0xA5, 0x65, 0x64, 0xA4, 0x6C, 0xAC, 0xAD, 0x6D, 0xAF, 0x6F,
  405. 0x6E, 0xAE, 0xAA, 0x6A, 0x6B, 0xAB, 0x69, 0xA9, 0xA8, 0x68,
  406. 0x78, 0xB8, 0xB9, 0x79, 0xBB, 0x7B, 0x7A, 0xBA, 0xBE, 0x7E,
  407. 0x7F, 0xBF, 0x7D, 0xBD, 0xBC, 0x7C, 0xB4, 0x74, 0x75, 0xB5,
  408. 0x77, 0xB7, 0xB6, 0x76, 0x72, 0xB2, 0xB3, 0x73, 0xB1, 0x71,
  409. 0x70, 0xB0, 0x50, 0x90, 0x91, 0x51, 0x93, 0x53, 0x52, 0x92,
  410. 0x96, 0x56, 0x57, 0x97, 0x55, 0x95, 0x94, 0x54, 0x9C, 0x5C,
  411. 0x5D, 0x9D, 0x5F, 0x9F, 0x9E, 0x5E, 0x5A, 0x9A, 0x9B, 0x5B,
  412. 0x99, 0x59, 0x58, 0x98, 0x88, 0x48, 0x49, 0x89, 0x4B, 0x8B,
  413. 0x8A, 0x4A, 0x4E, 0x8E, 0x8F, 0x4F, 0x8D, 0x4D, 0x4C, 0x8C,
  414. 0x44, 0x84, 0x85, 0x45, 0x87, 0x47, 0x46, 0x86, 0x82, 0x42,
  415. 0x43, 0x83, 0x41, 0x81, 0x80, 0x40
  416. ];
  417. CRC.CRC16 = function (buffer) {
  418. var hi = 0xff;
  419. var lo = 0xff;
  420. for (var i = 0; i < buffer.length; i++) {
  421. var idx = hi ^ buffer[i];
  422. hi = (lo ^ CRC._auchCRCHi[idx]);
  423. lo = CRC._auchCRCLo[idx];
  424. }
  425. return CRC.padLeft((hi << 8 | lo).toString(16).toUpperCase(), 4, '0');
  426. };
  427. CRC.isArray = function (arr) {
  428. return Object.prototype.toString.call(arr) === '[object Array]';
  429. };
  430. CRC.ToCRC16 = function (str) {
  431. return CRC.CRC16(CRC.isArray(str) ? str : CRC.strToByte(str));
  432. };
  433. CRC.ToModbusCRC16 = function (str) {
  434. return CRC.CRC16(CRC.isArray(str) ? str : CRC.strToHex(str));
  435. };
  436. CRC.strToByte = function (str) {
  437. var tmp = str.split(""),
  438. arr = [];
  439. for (var i = 0, c = tmp.length; i < c; i++) {
  440. var j = encodeURI(tmp[i]);
  441. if (j.length == 1) {
  442. arr.push(j.charCodeAt());
  443. } else {
  444. var b = j.split("%");
  445. for (var m = 1; m < b.length; m++) {
  446. arr.push(parseInt('0x' + b[m]));
  447. }
  448. }
  449. }
  450. return arr;
  451. };
  452. CRC.convertChinese = function (str) {
  453. var tmp = str.split(""),
  454. arr = [];
  455. for (var i = 0, c = tmp.length; i < c; i++) {
  456. var s = tmp[i].charCodeAt();
  457. if (s <= 0 || s >= 127) {
  458. arr.push(s.toString(16));
  459. } else {
  460. arr.push(tmp[i]);
  461. }
  462. }
  463. return arr;
  464. };
  465. CRC.filterChinese = function (str) {
  466. var tmp = str.split(""),
  467. arr = [];
  468. for (var i = 0, c = tmp.length; i < c; i++) {
  469. var s = tmp[i].charCodeAt();
  470. if (s > 0 && s < 127) {
  471. arr.push(tmp[i]);
  472. }
  473. }
  474. return arr;
  475. };
  476. CRC.strToHex = function (hex, isFilterChinese) {
  477. hex = isFilterChinese ? CRC.filterChinese(hex).join('') : CRC.convertChinese(hex).join('');
  478. //清除所有空格
  479. hex = hex.replace(/\s/g, "");
  480. //若字符个数为奇数,补一个空格
  481. hex += hex.length % 2 != 0 ? " " : "";
  482. var c = hex.length / 2,
  483. arr = [];
  484. for (var i = 0; i < c; i++) {
  485. arr.push(parseInt(hex.substr(i * 2, 2), 16));
  486. }
  487. return arr;
  488. };
  489. CRC.padLeft = function (s, w, pc) {
  490. if (pc == undefined) {
  491. pc = '0';
  492. }
  493. for (var i = 0, c = w - s.length; i < c; i++) {
  494. s = pc + s;
  495. }
  496. return s;
  497. };
  498. function str2ab(str) {
  499. var buffer = new ArrayBuffer(str.length / 2); // 2 bytes for each char
  500. var dataView = new DataView(buffer);
  501. var str = str.split("")
  502. var n = 0;
  503. for (var i = 0; i < str.length; i = i + 2) {
  504. dataView.setUint8(n, `0x${str[i]}${str[i+1]}`)
  505. n++;
  506. }
  507. return buffer;
  508. }
  509. function pad(num, n, flag = false) {
  510. var len = num.toString().length;
  511. while (len < n) {
  512. num = "0" + num;
  513. len++;
  514. }
  515. const arr = arrayGroup(num, 2)
  516. //高低位互换
  517. if (arr[1] == '00') {
  518. flag = true
  519. }
  520. return flag ? [arr[1], arr[0]] : [arr[0], arr[1]];
  521. }
  522. function add0(num,n) {
  523. let len = num.length
  524. while(len < n){
  525. num = '0'+num
  526. len++
  527. }
  528. if (len > n) {
  529. num = String(num).slice(1)
  530. }
  531. //console.log(num)
  532. return num
  533. }
  534. function hex2bin(hex, len) {
  535. var bin = parseInt(hex, 16).toString(2);
  536. var l = bin.length;
  537. for (var i = 0; i < len - l; i++) {
  538. bin = "0" + bin;
  539. }
  540. return bin;
  541. }
  542. //翻转字符串并切割成数组
  543. function reverseStr(str) {
  544. var arr = str.split("");
  545. arr.reverse();
  546. return arr;
  547. }
  548. function timestampToTime(timestamp) {
  549. var date = new Date(timestamp * 1000);//时间戳为10位需*1000,时间戳为13位的话不需乘1000
  550. var Y = date.getFullYear() + '-';
  551. var M = (date.getMonth()+1 < 10 ? '0'+(date.getMonth()+1) : date.getMonth()+1) + '-';
  552. var D = date.getDate() + ' ';
  553. var h = date.getHours() + ':';
  554. var m = date.getMinutes() + ':';
  555. var s = date.getSeconds();
  556. return Y+M+D+h+m+s;
  557. }