/**
|
* UART485服务模块
|
* 处理UART485通信相关的业务逻辑，包括条码数据接收、设备配置管理等功能
|
*/
|
import bus from "../../dxmodules/dxEventBus.js"
|
import common from "../../dxmodules/dxCommon.js"
|
import log from "../../dxmodules/dxLogger.js"
|
import std from '../../dxmodules/dxStd.js'
|
import driver from '../driver.js'
|
import utils from '../common/utils/utils.js'
|
import dxMap from '../../dxmodules/dxMap.js'
|
import config from '../../dxmodules/dxConfig.js'
|
const uart485Service = {}
|
|
/**
|
* 将十进制数转换为小端序十六进制字符串
|
* @param {number} decimalNumber - 十进制数字
|
* @param {number} byteSize - 字节大小
|
* @returns {string} 小端序十六进制字符串
|
*/
|
function decimalToLittleEndianHex (decimalNumber, byteSize) {
|
const littleEndianBytes = [];
|
for (let i = 0; i < byteSize; i++) {
|
littleEndianBytes.push(decimalNumber & 0xFF);
|
decimalNumber >>= 8; // 相当于除以256
|
}
|
const littleEndianHex = littleEndianBytes
|
.map((byte) => byte.toString(16).padStart(2, '0'))
|
.join('');
|
return littleEndianHex;
|
}
|
|
/**
|
* 将数据包转换为字符串格式
|
* @param {object} pack - 数据包对象
|
* @param {string} pack.cmd - 命令码
|
* @param {string} pack.result - 结果码
|
* @param {string} [pack.data] - 数据
|
* @returns {string} 转换后的字符串
|
*/
|
function pack2str (pack) {
|
pack.data = (!pack.data) ? [] : pack.data.match(/.{2}/g)
|
let len = decimalToLittleEndianHex(pack.data.length, 2)
|
let str = "55aa" + pack.cmd + pack.result + len + pack.data.join('')
|
let crc = common.calculateBcc([0x55, 0xaa, parseInt(pack.cmd, 16), parseInt(pack.result, 16), pack.data.length % 256, pack.data.length / 256].concat(pack.data.map(v => parseInt(v, 16))))
|
return str + crc.toString(16).padStart(2, '0')
|
}
|
|
/**
|
* 接收UART485数据并处理
|
* @param {object} data - 接收到的数据
|
* @param {string} type - 数据类型，'code'表示条码数据，'instruction'表示指令
|
*/
|
uart485Service.receive = function (data, type) {
|
log.info("code:",JSON.stringify(data))
|
if (type == 'code') {
|
if(data.cmd == "30") {
|
if(data.length > 0) {
|
let code = common.hexToString(data.data)
|
const now = new Date().getTime()
|
let map = dxMap.get("CODETIME")
|
let time = map.get("time") || 0
|
let interval = Math.max(1000, config.get("sys.interval"))
|
if(now - time > interval) {
|
bus.fire("getCode", code)
|
map.put("time", new Date().getTime())
|
}
|
}
|
}
|
}
|
if (type == 'instruction') {
|
if (data.cmd == "0a") {
|
// 获取设备SN
|
if (data.length > 0) {
|
console.log('---0A写入--');
|
|
let newSn = common.hexToString(data.data)
|
//修改 sn 号改成传入参数
|
try {
|
let wgetApp = common.systemWithRes(`test -e "/etc/.sn" && echo "OK" || echo "NO"`, 2)
|
if (!wgetApp.includes('OK')) {
|
//没有创建一下
|
common.systemBrief("touch /etc/.sn")
|
}
|
std.saveFile('/etc/.sn', newSn)
|
common.systemWithRes(`rm -rf /app/data/config/config.json`, 2)
|
} catch (error) {
|
log.info('0A写入 sn 失败原因:', error.stack)
|
let pack1 = { "cmd": '0A', "result": '90', 'data': '' }
|
driver.uart485.sendVg(pack2str(pack1))
|
return
|
}
|
//返回串口
|
let pack1 = { "cmd": '0A', "result": '00', 'data': common.stringToHex(newSn) }
|
driver.uart485.sendVg(pack2str(pack1))
|
common.asyncReboot(2)
|
} else {
|
log.info('-----0A查询-----', common.getSn());
|
let pack1 = { "cmd": '0A', "result": '00', "data": common.stringToHex(common.getSn()) }
|
// log.info(pack2str(pack1));
|
driver.uart485.sendVg(pack2str(pack1))
|
}
|
} else if (data.cmd == "b0") {
|
log.info("----b0---")
|
// 查询/修改设备配置
|
let str = data.data
|
if (!str) {
|
return
|
}
|
//数据域第一个字节表示修改还是查询 00 查询 01 修改
|
if (parseInt(str.substring(0, 2)) == 0) {
|
//查询配置
|
let pack1 = { "cmd": 'B0', "result": '00', "data": common.stringToHex(common.getSn()) }
|
driver.uart485.sendVg(pack2str(pack1))
|
} else {
|
//修改配置
|
if (data.dlen <= 1) {
|
return
|
}
|
// ___VBAR_CONFIG_V1.1.0___{ble_name="11127S"}--lLqHBRnE2bU8D2HJ5RTioQ==
|
let toString = common.hexToString(str.substring(2))
|
let content = parseString(toString)
|
if (content.sn) {
|
//修改 sn 号改成传入参数
|
try {
|
let wgetApp = common.systemWithRes(`test -e "/etc/.sn" && echo "OK" || echo "NO"`, 2)
|
if (!wgetApp.includes('OK')) {
|
//没有创建一下
|
common.systemBrief("touch /etc/.sn")
|
}
|
std.saveFile('/etc/.sn', content.sn)
|
common.systemWithRes(`rm -rf /app/data/config/config.json`, 2)
|
} catch (error) {
|
log.info('写入/etc/.sn文件失败,原因:', error.stack)
|
let pack1 = { "cmd": 'B0', "result": '90', "data": common.stringToHex(common.getSn()) }
|
driver.uart485.sendVg(pack2str(pack1))
|
return
|
}
|
//返回串口
|
let pack1 = { "cmd": 'B0', "result": '00', "data": common.stringToHex(content.sn) }
|
driver.uart485.sendVg(pack2str(pack1))
|
common.asyncReboot(2)
|
}
|
|
}
|
} else if (data.cmd == "0c") {
|
log.info("----0c--")
|
// 获取主控chipID
|
let pack = { "cmd": '0C', "result": '00', "data": common.stringToHex(common.getUuid()) }
|
driver.uart485.sendVg(pack2str(pack))
|
}
|
}
|
}
|
|
/**
|
* 解析字符串为JSON对象，注意value内不能有"号
|
* @param {string} inputString - 输入字符串
|
* @returns {object} 解析后的JSON对象
|
*/
|
utils.parseString = function (inputString) {
|
// 获取{}及其之间的内容
|
inputString = inputString.slice(inputString.indexOf("{"), inputString.lastIndexOf("}") + 1)
|
// key=value正则，key是\w+（字母数字下划线，区别大小写），=两边可有空格，value是\w+或相邻两个"之间的内容（包含"）
|
const keyValueRegex = /(\w+)\s*=\s*("[^"]*"|\w+)/g;
|
let jsonObject = {};
|
let match;
|
while ((match = keyValueRegex.exec(inputString)) !== null) {
|
let key = match[1];
|
let value = match[2]
|
|
if (/^\d+$/.test(value)) {
|
// 数字
|
value = parseInt(value)
|
} else if (/^\d+\.\d+$/.test(value)) {
|
// 小数
|
value = parseFloat(value)
|
} else if (value == 'true') {
|
value = true
|
} else if (value == 'false') {
|
value = false
|
} else {
|
// 字符串
|
value = value.replace(/"/g, '').trim()
|
}
|
jsonObject[key] = value;
|
}
|
return jsonObject;
|
}
|
|
export default uart485Service
|
