converter.js 25 KB

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