DeXun/klp-oa
9
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

扫码枪展示优化

Browse Source
This commit is contained in:
砂糖
2025-08-15 11:42:31 +08:00
parent f9e1aad096
commit 9e8b8c5ed7
4 changed files with 323 additions and 171 deletions
Download Patch File Download Diff File Expand all files Collapse all files

216
klp-ui/src/views/wms/print/scaner.vue
View File

@@ -3,11 +3,20 @@
<el-col :span="4" class="device-panel">
<div class="panel-header">
<h3>设备列表</h3>
<el-button size="mini" type="primary" @click="refreshDevices">刷新</el-button>
</div>
<div class="device-stats">
<span>总设备: {{ deviceStats.totalCount || 0 }}</span>
<span>活跃设备: {{ deviceStats.activeCount || 0 }}</span>
</div>
<ul class="device-list">
<li v-for="item in deviceList" :key="item.id" class="device-item">
<span class="device-id">{{ item.id }}</span>
<span class="device-name">{{ item.name }}</span>
<li v-for="item in deviceList" :key="item.id" class="device-item" :class="{ active: item.isActive }">
<div class="device-status" :class="{ online: item.isActive }"></div>
<div class="device-info">
<span class="device-name">{{ item.name }}</span>
<span class="device-id">{{ item.id }}</span>
<span class="device-ip">{{ item.ip }}</span>
</div>
</li>
</ul>
</el-col>
@@ -123,6 +132,10 @@ export default {
data() {
return {
deviceList: [],
deviceStats: {
totalCount: 0,
activeCount: 0
},
messageList: [],
socket: null,
defaultForm: {
@@ -141,42 +154,88 @@ export default {
this.initSocket();
this.fetchMaster();
},
beforeDestroy() {
// 组件销毁时关闭WebSocket连接
if (this.socket) {
this.socket.close();
}
},
methods: {
initSocket() {
// 处理WebSocket连接
this.socket = new WebSocket("ws://localhost:9000/ws");
this.socket.onopen = () => {
console.log("Socket 连接已建立");
};
this.socket.onmessage = (event) => {
const data = JSON.parse(event.data);
if (data.type === "deviceList") {
console.log(data, '获取设备列表');
this.deviceList = data.devices;
} else if (data.type === "scanMessage") {
console.log(data, '获取消息');
this.messageList.push({
time: new Date().toLocaleString(),
itemId: data.itemId,
itemType: data.itemType,
stockIoId: this.defaultForm.stockIoId,
quantity: this.defaultForm.quantity,
ioType: this.defaultForm.ioType,
warehouseId: this.defaultForm.warehouseId,
batchNo: this.defaultForm.batchNo,
unit: '个'
});
try {
const data = JSON.parse(event.data);
// 处理设备列表数据
if (data.type === "allDevices") {
console.log("获取设备列表", data);
this.deviceList = data.devices || [];
this.deviceStats = {
totalCount: data.totalCount || 0,
activeCount: data.activeCount || 0
};
}
// 处理扫描消息
else if (data.type === "scanMessage") {
console.log("获取扫描消息", data);
this.messageList.push({
time: new Date().toLocaleString(),
itemId: data.itemId,
itemType: data.itemType,
stockIoId: this.defaultForm.stockIoId,
quantity: this.defaultForm.quantity,
ioType: this.defaultForm.ioType,
warehouseId: this.defaultForm.warehouseId,
batchNo: this.defaultForm.batchNo,
unit: '个'
});
}
} catch (error) {
console.error("解析WebSocket消息失败", error);
}
};
this.socket.onclose = () => {
console.log("Socket 连接已关闭");
// 连接关闭后尝试重连
setTimeout(() => {
this.initSocket();
}, 5000);
};
this.socket.onerror = (error) => {
console.error("Socket 错误", error);
};
},
// 刷新设备列表
refreshDevices() {
if (this.socket && this.socket.readyState === WebSocket.OPEN) {
this.socket.send(JSON.stringify({ type: "refreshDevices" }));
} else {
this.$message.warning("WebSocket连接未建立，无法刷新设备列表");
// 尝试重新连接
this.initSocket();
}
},
fetchMaster() {
listStockIo({ pageSize: 9999, pageNum: 1 }).then(res => {
console.log(res, '获取挂载单据');
this.masterList = res.rows;
console.log("获取挂载单据", res);
this.masterList = res.rows || [];
}).catch(error => {
console.error("获取挂载单据失败", error);
this.$message.error("获取挂载单据失败");
});
},
handleDeviceChange(item) {
this.socket.send(
JSON.stringify({
@@ -185,35 +244,67 @@ export default {
})
);
},
handleBatchConfirm() {
// 汇总会导致的库存变更，需要确认
console.log(this.selectedList, '批量确认');
this.selectedList.forEach(item => {
console.log(item, 'item');
});
console.log("批量确认", this.selectedList);
if (this.selectedList.length === 0) {
this.$message.warning("请选择需要确认的记录");
return;
}
// 批量处理逻辑
Promise.all(this.selectedList.map(item => this.processRecord(item)))
.then(() => {
this.$message.success("批量确认成功");
// 从列表中移除已确认的项
this.messageList = this.messageList.filter(
item => !this.selectedList.some(selected => selected.time === item.time)
);
this.selectedList = [];
})
.catch(error => {
console.error("批量确认失败", error);
this.$message.error("批量确认失败");
});
},
handleSelectionChange(selection) {
this.selectedList = selection;
},
handleDelete(row) {
this.messageList = this.messageList.filter(item => item.time !== row.time);
},
async handleConfirm(row) {
// 同时做两件事，插入记录，修改库存
// recordType为1表明记录来源扫码枪
await this.insertRecord({...row, recordType: 1})
await this.updateStock(row)
this.handleDelete(row);
this.$message.success('确认成功');
try {
await this.processRecord(row);
this.handleDelete(row);
this.$message.success('确认成功');
} catch (error) {
console.error("确认失败", error);
this.$message.error('确认失败');
}
},
// 处理单条记录的确认逻辑
async processRecord(row) {
// 插入记录
await this.insertRecord({...row, recordType: 1});
// 更新库存
await this.updateStock(row);
},
insertRecord(row) {
return addStockIoDetail(row)
return addStockIoDetail(row);
},
updateStock(row) {
if (row.ioType === 'in') {
return scanInStock(row)
return scanInStock(row);
} else {
return scanOutStock(row)
return scanOutStock(row);
}
}
},
@@ -249,6 +340,9 @@ export default {
border-bottom: 1px solid #ebeef5;
background-color: #f8fafc;
border-radius: 8px 8px 0 0;
display: flex;
justify-content: space-between;
align-items: center;
}
.panel-header h3 {
@@ -258,6 +352,16 @@ export default {
font-weight: 500;
}
/* 设备统计信息 */
.device-stats {
padding: 10px 20px;
border-bottom: 1px solid #ebeef5;
display: flex;
justify-content: space-between;
font-size: 13px;
color: #606266;
}
.device-list {
flex: 1;
overflow-y: auto;
@@ -267,25 +371,57 @@ export default {
.device-item {
display: flex;
justify-content: space-between;
align-items: center;
padding: 12px 20px;
border-bottom: 1px solid #ebeef5;
transition: background-color 0.3s;
cursor: pointer;
}
.device-item:hover {
background-color: #f5f7fa;
}
.device-id {
font-weight: 500;
color: #606266;
/* 设备状态指示器 */
.device-status {
width: 10px;
height: 10px;
border-radius: 50%;
background-color: #ccc;
margin-right: 12px;
}
.device-status.online {
background-color: #42b983; /* 绿色表示在线 */
}
.device-info {
flex: 1;
}
.device-name {
display: block;
font-weight: 500;
color: #303133;
margin-bottom: 4px;
}
.device-id {
display: block;
font-size: 12px;
color: #606266;
margin-bottom: 2px;
}
.device-ip {
display: block;
font-size: 12px;
color: #909399;
font-size: 13px;
}
/* 活跃设备高亮 */
.device-item.active {
background-color: #f0f9eb;
}
.form-panel {

9
klp-ui/src/views/wms/work/schedulePlan/components/MergeSourceSelector.vue
View File

@@ -35,9 +35,14 @@
<el-option
v-for="task in availableTasks"
:key="task.taskId"
:label="`[产品: ${task.productName || task.productId}] [工艺: ${task.processName || task.processId}] 数量: ${task.taskQuantity}`"
:value="task.taskId"
></el-option>
>
<div class="task-info">
<ProductInfo :productId="task.productId" />
<CraftInfo :craftId="task.processId" />
<span class="task-quantity">数量: {{ task.taskQuantity }}</span>
</div>
</el-option>
</el-select>
</div>
</div>

235
scaner/src/main/java/org/example/Main.java
View File

@@ -6,7 +6,6 @@ import java.io.IOException;
import java.io.OutputStream;
import java.util.ArrayList;
// Main.java 顶部增加
import org.glassfish.tyrus.server.Server;
import MvCodeReaderCtrlWrapper.*;
@@ -19,56 +18,83 @@ import java.io.*;
public class Main {
static Handle hHandle = null;
// 保存设备列表
private static ArrayList<MV_CODEREADER_DEVICE_INFO> stCamListCache = new ArrayList<>();
// 保存所有读取到的设备列表
private static ArrayList<MV_CODEREADER_DEVICE_INFO> allDevices = new ArrayList<>();
// 获取设备列表JSON（推送给前端）
public static String getDeviceListJson() {
// 保存正在监听的设备列表
private static ArrayList<MV_CODEREADER_DEVICE_INFO> activeDevices = new ArrayList<>();
// 获取所有读取到的设备列表JSON（推送给前端）
public static String getAllDevicesJson() {
org.json.JSONObject obj = new org.json.JSONObject();
obj.put("type", "deviceList");
obj.put("type", "allDevices");
org.json.JSONArray arr = new org.json.JSONArray();
for (int i = 0; i < stCamListCache.size(); i++) {
MV_CODEREADER_DEVICE_INFO camInfo = stCamListCache.get(i);
// System.out.println(camInfo.toString() + "设备相信信息");
System.out.println(camInfo.stGigEInfo.chModelName + camInfo.stGigEInfo.chUserDefinedName + camInfo.stGigEInfo.nCurrentIp + camInfo.stGigEInfo.chSerialNumber + camInfo.stGigEInfo.chDeviceVersion
+ camInfo.stGigEInfo.chManufacturerName + camInfo.stGigEInfo.chManufacturerSpecificInfo + camInfo.stGigEInfo.nIpCfgCurrent);
for (MV_CODEREADER_DEVICE_INFO camInfo : allDevices) {
org.json.JSONObject dev = new org.json.JSONObject();
dev.put("id", camInfo.stGigEInfo.chSerialNumber); // 序列号
dev.put("name", camInfo.stGigEInfo.chUserDefinedName != null ? camInfo.stGigEInfo.chUserDefinedName : camInfo.stGigEInfo.chModelName);
dev.put("type", "scanner");
dev.put("on", true); // 默认开
dev.put("name", camInfo.stGigEInfo.chUserDefinedName != null ?
camInfo.stGigEInfo.chUserDefinedName : camInfo.stGigEInfo.chModelName);
dev.put("model", camInfo.stGigEInfo.chModelName); // 型号
dev.put("manufacturer", camInfo.stGigEInfo.chManufacturerName); // 制造商
dev.put("ip", getIpAddress(camInfo.stGigEInfo.nCurrentIp)); // IP地址
dev.put("version", camInfo.stGigEInfo.chDeviceVersion); // 设备版本
dev.put("isActive", isDeviceActive(camInfo)); // 是否正在监听
arr.put(dev);
}
obj.put("devices", arr);
obj.put("totalCount", allDevices.size()); // 设备总数
obj.put("activeCount", activeDevices.size()); // 活跃设备数
return obj.toString();
}
// 检查设备是否正在监听
private static boolean isDeviceActive(MV_CODEREADER_DEVICE_INFO device) {
for (MV_CODEREADER_DEVICE_INFO active : activeDevices) {
if (active.stGigEInfo.chSerialNumber.equals(device.stGigEInfo.chSerialNumber)) {
return true;
}
}
return false;
}
// 将IP整数转换为字符串格式
private static String getIpAddress(int ipInt) {
return ((ipInt & 0xff000000) >> 24) + "." +
((ipInt & 0x00ff0000) >> 16) + "." +
((ipInt & 0x0000ff00) >> 8) + "." +
(ipInt & 0x000000ff);
}
public static void saveDataToFile(byte[] dataToSave, int dataSize, String fileName) {
OutputStream os = null;
try {
// Create saveImg directory
// 创建保存目录
File tempFile = new File("saveImg");
if (!tempFile.exists()) {
tempFile.mkdirs();
}
stCamListCache = MvCodeReaderCtrl.MV_CODEREADER_EnumDevices();
os = new FileOutputStream("saveImg/" + fileName);
os.write(dataToSave, 0, dataSize);
System.out.println("SaveImage succeed.");
System.out.println("图像保存成功: " + fileName);
} catch (IOException e) {
e.printStackTrace();
} finally {
// Close file stream
// 关闭文件流
try {
os.close();
if (os != null) {
os.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
// CallBack function
// 回调函数
private static void printImgCBInfo(byte[] pdata, MV_CODEREADER_IMAGE_OUT_INFO_EX2 stOutInfo) {
if (null == stOutInfo) {
System.out.println("stOutInfo is null");
@@ -77,131 +103,95 @@ public class Main {
System.out.print("/**CBpstOutInfo***************************************/\n");
System.out.print(String.format("获取一帧: nEventID[%d], nChannelID[%d], nWidth[%d], nHeight[%d], nFrameNum[%d], nTriggerIndex[%d], nFrameLen[%d], "
+ " nCodeNumber[%d] \r\n",
stOutInfo.nEventID, stOutInfo.nChannelID, stOutInfo.nWidth, stOutInfo.nHeight, stOutInfo.nFrameNum,
stOutInfo.nTriggerIndex, stOutInfo.nFrameLen, stOutInfo.pstCodeListEx.nCodeNum));
// 示例：扫码时调用POST接口，解析扫码内容并发送JSON
try {
// 假设扫码内容为第一个条码内容
// String scanStr = null;
// if (stOutInfo != null && stOutInfo.pstCodeListEx != null && stOutInfo.pstCodeListEx.nCodeNum > 0) {
// scanStr = stOutInfo.pstCodeListEx.stBcrInfoEx.get(0).chCode;
// }
// if (scanStr != null && !scanStr.isEmpty()) {
// String json = ScanDataUtil.buildRequestJson(
// scanStr,
// "raw_material", // 物品类型
// "扫码入库", // 备注
// null, // 源库位ID
// 1 // 记录类型
// );
// System.out.println("json: " + json);
// // 发送两次请求：修改库存并且插入一条记录
// // 插入记录
// String postUrl1 = "http://localhost:8080/wms/stockIoDetail"; // TODO: 替换为实际接口
// String postResponse = HttpRequestUtil.postJson(postUrl1, json);
// System.out.println("POST接口响应: " + postResponse);
// // 修改库存
// String postUrl2 = "http://localhost:8080/wms/stockIo/scanInStock";
// String postResponse2 = HttpRequestUtil.postJson(postUrl2, json);
// System.out.println("修改库存POST接口响应: " + postResponse2);
// } else {
// System.out.println("未获取到扫码内容，未发送POST请求");
// }
} catch (Exception e) {
System.err.println("POST请求失败: " + e.getMessage());
}
System.out.print("解码状态: bIsGetCode[" + stOutInfo.bIsGetCode + "]\r\n");
// save buffer to file follow Image Type to Save
// saveDataToFile(pdata, stOutInfo.nFrameLen, "Image.jpg");
// saveDataToFile(pdata, stOutInfo.nFrameLen, "Image.raw");
System.out.print("像素类型: MvCodeReaderGvspPixelType[" + stOutInfo.enPixelType + "]\r\n");
System.out.print(String.format("Get One Frame: nEventID[%d], nChannelID[%d], nWidth[%d], nHeight[%d], nFrameNum[%d], nTriggerIndex[%d], nFrameLen[%d], "
+ " nCodeNumber[%d] \r\n",
stOutInfo.nEventID, stOutInfo.nChannelID, stOutInfo.nWidth, stOutInfo.nHeight, stOutInfo.nFrameNum,
stOutInfo.nTriggerIndex, stOutInfo.nFrameLen, stOutInfo.pstCodeListEx.nCodeNum));
System.out.print("Get One Code: bIsGetCode[" + stOutInfo.bIsGetCode + "]success\r\n");
System.out.print("Get GvspPixelType: MvCodeReaderGvspPixelType[" + stOutInfo.enPixelType + "]success\r\n");
// print code info
// 打印解码信息
for (int a = 0; a < stOutInfo.pstCodeListEx.nCodeNum; a++) {
org.json.JSONObject obj = new org.json.JSONObject();
obj.put("type", "scanMessage");
// 解析码中的数据，用下划线分割，第一个为物料类型，第二个为物料id
String code = stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).chCode;
String[] parts = code.split("__");
String itemType = parts[0];
String itemId = parts[1];
obj.put("itemType", itemType);
obj.put("itemId", itemId);
if (parts.length >= 2) {
String itemType = parts[0];
String itemId = parts[1];
obj.put("itemType", itemType);
obj.put("itemId", itemId);
} else {
obj.put("rawCode", code);
obj.put("error", "格式不正确");
}
WsServer.broadcast(obj.toString());
System.out.print(String.format("CodeInfo: TheCodeID[%d], CodeString[%s], nCodeLen[%d], nAngle[%d], nBarType[%d],"
+ "sAlgoCost[%d], nIDRScore[%d], n1DIsGetQuality[%d]\r\n",
a, stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).chCode, stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).nLen,
stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).nAngle, stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).nBarType,
stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).sAlgoCost, stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).nIDRScore,
stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).n1DIsGetQuality));
System.out.print(String.format("CodePointInfo: stCornerLeftTop.X[%d], stCornerLeftTop.Y[%d], stCornerRightTop.X[%d], stCornerRightTop.Y[%d],"
+ "stCornerRightBottom.X[%d], stCornerRightBottom.Y[%d], stCornerLeftBottom.X[%d], stCornerLeftBottom.Y[%d]\r\n",
stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).stCornerLeftTop.nX, stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).stCornerLeftTop.nY,
stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).stCornerRightTop.nX, stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).stCornerRightTop.nY,
stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).stCornerRightBottom.nX, stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).stCornerRightBottom.nY,
stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).stCornerLeftBottom.nX, stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).stCornerLeftBottom.nY));
System.out.print("Get CodeQuality: bIsGetQuality[" + stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).bIsGetQuality + "]success\r\n");
System.out.print(String.format("解码信息: TheCodeID[%d], CodeString[%s], nCodeLen[%d], nAngle[%d], nBarType[%d],"
+ "sAlgoCost[%d], nIDRScore[%d], n1DIsGetQuality[%d]\r\n",
a, stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).chCode, stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).nLen,
stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).nAngle, stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).nBarType,
stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).sAlgoCost, stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).nIDRScore,
stOutInfo.pstCodeListEx.stBcrInfoEx.get(a).n1DIsGetQuality));
}
}
private static void PrintDeviceInfo(MV_CODEREADER_DEVICE_INFO stCamInfo) {
if (stCamInfo.nTLayerType == MvCodeReaderCtrlDefine.MV_CODEREADER_GIGE_DEVICE) {
int nIp1 = ((stCamInfo.stGigEInfo.nCurrentIp & 0xff000000) >> 24) & 0xff;
int nIp2 = ((stCamInfo.stGigEInfo.nCurrentIp & 0x00ff0000) >> 16);
int nIp3 = ((stCamInfo.stGigEInfo.nCurrentIp & 0x0000ff00) >> 8);
int nIp4 = (stCamInfo.stGigEInfo.nCurrentIp & 0x000000ff);
System.out.print("CurrentIp: " + nIp1 + "." + nIp2 + "." + nIp3 + "." + nIp4 + "\r\n");
System.out.print(String.format("GiGEInfo: UserDefinedName:[%s], chSerialNumber:[%s] \r\n\r\n",
stCamInfo.stGigEInfo.chUserDefinedName, stCamInfo.stGigEInfo.chSerialNumber));
System.out.print("IP地址: " + getIpAddress(stCamInfo.stGigEInfo.nCurrentIp) + "\r\n");
System.out.print(String.format("设备信息: 自定义名称:[%s], 序列号:[%s], 型号:[%s] \r\n\r\n",
stCamInfo.stGigEInfo.chUserDefinedName,
stCamInfo.stGigEInfo.chSerialNumber,
stCamInfo.stGigEInfo.chModelName));
}
}
public static void main(String[] args) throws InterruptedException {
System.out.print(" ***************Begin****************** \r\n");
System.out.print(" ***************程序开始****************** \r\n");
String strVersion = MvCodeReaderCtrl.MV_CODEREADER_GetSDKVersion();
System.out.print("Get version " + strVersion + "\r\n");
System.out.print("SDK版本: " + strVersion + "\r\n");
ArrayList<MV_CODEREADER_DEVICE_INFO> stCamList = MvCodeReaderCtrl.MV_CODEREADER_EnumDevices();
Main.stCamListCache = stCamList;
if (stCamList == null || stCamList.isEmpty()) {
System.out.print("Find No Device!\r\n");
return;
// 枚举所有设备
allDevices = MvCodeReaderCtrl.MV_CODEREADER_EnumDevices();
if (allDevices == null || allDevices.isEmpty()) {
System.out.print("未发现任何设备!\r\n");
} else {
System.out.print("发现" + allDevices.size() + "个设备:\r\n");
for (MV_CODEREADER_DEVICE_INFO device : allDevices) {
PrintDeviceInfo(device);
}
}
ArrayList<Handle> handleList = new ArrayList<>();
for (int i = 0; i < stCamList.size(); i++) {
MV_CODEREADER_DEVICE_INFO camInfo = stCamList.get(i);
PrintDeviceInfo(camInfo);
// 尝试打开并启动所有发现的设备
for (int i = 0; i < allDevices.size(); i++) {
MV_CODEREADER_DEVICE_INFO camInfo = allDevices.get(i);
System.out.print("处理设备 " + i + ": " + camInfo.stGigEInfo.chSerialNumber + "\r\n");
Handle handle = null;
try {
handle = MvCodeReaderCtrl.MV_CODEREADER_CreateHandle(camInfo);
} catch (ParameterException e) {
throw new RuntimeException(e);
}
if (handle == null) {
System.out.print("Create handle failed for device " + i + "!\r\n");
System.out.print("创建句柄失败: " + e.getMessage() + "\r\n");
continue;
}
if (handle == null) {
System.out.print("创建句柄失败 for device " + i + "!\r\n");
continue;
}
int nRet = MvCodeReaderCtrl.MV_CODEREADER_OpenDevice(handle);
if (nRet != 0) {
System.out.print("Open Device fail for device " + i + "! nRet[" + String.format("0x%x", nRet) + "]\r\n");
System.out.print("打开设备失败 for device " + i + "! 错误码[" + String.format("0x%x", nRet) + "]\r\n");
continue;
}
nRet = MvCodeReaderCtrl.MV_CODEREADER_RegisterImageCallBackEx2(handle, new ImageCallBack() {
@Override
public int OnImageCallBack(byte[] pdata, MV_CODEREADER_IMAGE_OUT_INFO_EX2 stOutInfo) {
@@ -209,32 +199,47 @@ public class Main {
return 0;
}
});
if (nRet != 0) {
System.out.print("RegisterImageCallBackEx2 Failed for device " + i + "! nRet[" + String.format("0x%x", nRet) + "]\r\n");
System.out.print("注册回调失败 for device " + i + "! 错误码[" + String.format("0x%x", nRet) + "]\r\n");
MvCodeReaderCtrl.MV_CODEREADER_CloseDevice(handle);
continue;
}
nRet = MvCodeReaderCtrl.MV_CODEREADER_StartGrabbing(handle);
if (nRet != 0) {
System.out.print("StartGrabbing Failed for device " + i + "! nRet[" + String.format("0x%x", nRet) + "]\r\n");
System.out.print("启动抓取失败 for device " + i + "! 错误码[" + String.format("0x%x", nRet) + "]\r\n");
MvCodeReaderCtrl.MV_CODEREADER_CloseDevice(handle);
continue;
}
// 如果所有步骤都成功，添加到活跃设备列表
handleList.add(handle);
System.out.print("Device " + i + " startGrabbing success!\r\n");
activeDevices.add(camInfo);
System.out.print("设备 " + i + " 启动成功，开始监听!\r\n");
}
// 阻塞主线程直到退出
System.out.println("所有扫码枪已开始监听");
System.out.println("所有设备处理完毕。活跃设备数量: " + activeDevices.size() + "\r\n");
// 启动 Socket 服务器
Server server = new Server("localhost", 9000, "/", null, WsServer.class);
// 启动WebSocket服务器，用于向前端推送设备列表和扫描结果
Server server = new Server("localhost", 9000, "/", null, WsServer.class);
try {
server.start();
System.out.println("WebSocket服务器已启动，端口9000");
System.out.println("按Enter键退出程序...");
System.in.read(); // 阻塞主线程直到回车
} catch (Exception e) {
throw new RuntimeException(e);
System.out.println("WebSocket服务器错误: " + e.getMessage());
e.printStackTrace();
} finally {
// 停止所有设备
System.out.println("停止所有设备...");
for (Handle handle : handleList) {
MvCodeReaderCtrl.MV_CODEREADER_StopGrabbing(handle);
MvCodeReaderCtrl.MV_CODEREADER_CloseDevice(handle);
}
server.stop();
System.out.println("程序已退出");
}
}
}

34
scaner/src/main/java/org/example/WsServer.java
View File

@@ -9,38 +9,44 @@ import java.io.IOException;
import java.util.Set;
import java.util.concurrent.CopyOnWriteArraySet;
@javax.websocket.server.ServerEndpoint("/ws")
@ServerEndpoint("/ws")
public class WsServer {
private static final Set<javax.websocket.Session> sessions = new CopyOnWriteArraySet<>();
private static final Set<Session> sessions = new CopyOnWriteArraySet<>();
@javax.websocket.OnOpen
public void onOpen(javax.websocket.Session session) {
@OnOpen
public void onOpen(Session session) {
sessions.add(session);
System.out.println("WebSocket连接已建立: " + session.getId());
// 推送扫码枪列表给前端
String deviceListJson = org.example.Main.getDeviceListJson();
// 推送所有扫码枪列表给前端（使用修改后的方法名）
String deviceListJson = Main.getAllDevicesJson();
try {
System.out.println("发送消息到前端");
System.out.println("发送设备列表到前端: " + deviceListJson);
session.getBasicRemote().sendText(deviceListJson);
} catch (IOException e) {
e.printStackTrace();
}
}
@javax.websocket.OnMessage
public void onMessage(String message, javax.websocket.Session session) throws IOException {
@OnMessage
public void onMessage(String message, Session session) throws IOException {
System.out.println("收到消息: " + message);
session.getBasicRemote().sendText("服务器已收到: " + message);
// 可以根据前端需求，在这里处理命令（比如刷新设备列表）
if ("refreshDevices".equals(message)) {
String deviceListJson = Main.getAllDevicesJson();
session.getBasicRemote().sendText(deviceListJson);
} else {
session.getBasicRemote().sendText("服务器已收到: " + message);
}
}
@javax.websocket.OnClose
public void onClose(javax.websocket.Session session) {
@OnClose
public void onClose(Session session) {
sessions.remove(session);
System.out.println("WebSocket连接已关闭: " + session.getId());
}
public static void broadcast(String message) {
for (javax.websocket.Session session : sessions) {
for (Session session : sessions) {
if (session.isOpen()) {
try {
session.getBasicRemote().sendText(message);
@@ -50,4 +56,4 @@ public class WsServer {
}
}
}
}
}