From fde2f18ff52dfd54fc95867e3f77baa592664af8 Mon Sep 17 00:00:00 2001 From: zc Date: Wed, 11 Mar 2026 10:55:59 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B5=B7=E5=BA=B7=E5=B7=A5=E4=B8=9A=E7=9B=B8?= =?UTF-8?q?=E6=9C=BA=E5=AF=B9=E6=8E=A5=E9=BB=91=E7=99=BD=E7=94=BB=E9=9D=A2?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- wms-webapi/pom.xml | 9 + .../wms/admin/config/webSocket/webSocket.java | 8 + .../admin/controller/hkMVS/CameraService.java | 377 +++++++++++++++++ .../hkMVS/CameraWebSocketHandler.java | 64 +++ .../controller/hkMVS/ConvertPixelType.java | 386 ++++++++++++++++++ 5 files changed, 844 insertions(+) create mode 100644 wms-webapi/src/main/java/top/wms/admin/controller/hkMVS/CameraService.java create mode 100644 wms-webapi/src/main/java/top/wms/admin/controller/hkMVS/CameraWebSocketHandler.java create mode 100644 wms-webapi/src/main/java/top/wms/admin/controller/hkMVS/ConvertPixelType.java diff --git a/wms-webapi/pom.xml b/wms-webapi/pom.xml index 5fcb322..ae5d3b9 100644 --- a/wms-webapi/pom.xml +++ b/wms-webapi/pom.xml @@ -80,6 +80,15 @@ jakarta.websocket-api 2.1.0 + + + + com.hikvision + MvCameraControlWrapper + 1.0 + system + ${project.basedir}/Library/MvCameraControlWrapper.jar + diff --git a/wms-webapi/src/main/java/top/wms/admin/config/webSocket/webSocket.java b/wms-webapi/src/main/java/top/wms/admin/config/webSocket/webSocket.java index 4466b67..a541351 100644 --- a/wms-webapi/src/main/java/top/wms/admin/config/webSocket/webSocket.java +++ b/wms-webapi/src/main/java/top/wms/admin/config/webSocket/webSocket.java @@ -1,17 +1,25 @@ package top.wms.admin.config.webSocket; +import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.Configuration; import org.springframework.web.socket.config.annotation.EnableWebSocket; import org.springframework.web.socket.config.annotation.WebSocketConfigurer; import org.springframework.web.socket.config.annotation.WebSocketHandlerRegistry; +import top.wms.admin.controller.hkMVS.CameraWebSocketHandler; import top.wms.admin.controller.weighManage.ah.ScaleWebSocketHandler; @Configuration @EnableWebSocket public class webSocket implements WebSocketConfigurer { + + @Autowired + private CameraWebSocketHandler cameraWebSocketHandler; + @Override public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) { // 注册WebSocket端点，允许所有跨域请求 registry.addHandler(new ScaleWebSocketHandler(), "/ws/scale").setAllowedOrigins("*"); + // 注册海康相机WebSocket端点 + registry.addHandler(cameraWebSocketHandler, "/ws/camera").setAllowedOrigins("*"); } } \ No newline at end of file diff --git a/wms-webapi/src/main/java/top/wms/admin/controller/hkMVS/CameraService.java b/wms-webapi/src/main/java/top/wms/admin/controller/hkMVS/CameraService.java new file mode 100644 index 0000000..a5736a5 --- /dev/null +++ b/wms-webapi/src/main/java/top/wms/admin/controller/hkMVS/CameraService.java @@ -0,0 +1,377 @@ +package top.wms.admin.controller.hkMVS; + +import MvCameraControlWrapper.*; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Service; +import org.springframework.web.socket.BinaryMessage; +import org.springframework.web.socket.WebSocketSession; + +import java.util.ArrayList; +import java.util.Map; +import java.util.concurrent.ConcurrentHashMap; + +import static MvCameraControlWrapper.MvCameraControlDefines.*; + +@Slf4j +@Service +public class CameraService { + + // 相机句柄 + private Handle hCamera = null; + // 设备信息列表 + private ArrayList stDeviceList = null; + // WebSocket会话映射，用于存储活跃的WebSocket连接 + private final Map webSocketSessions = new ConcurrentHashMap<>(); + // 相机是否正在运行 + private boolean isRunning = false; + + /** + * 初始化相机 + * @return 初始化结果 + */ + public synchronized boolean initializeCamera() { + if (hCamera != null) { + log.info("Camera already initialized"); + return true; + } + + int nRet = MV_OK; + + try { + // 初始化SDK + log.info("Initializing SDK..."); + nRet = MvCameraControl.MV_CC_Initialize(); + if (MV_OK != nRet) { + log.error("Initialize SDK fail! nRet [0x{0}]", Integer.toHexString(nRet)); + return false; + } + + // 枚举设备 + log.info("Enumerating devices..."); + try { + stDeviceList = MvCameraControl.MV_CC_EnumDevices(MV_GIGE_DEVICE | MV_USB_DEVICE | MV_GENTL_GIGE_DEVICE | MV_GENTL_CAMERALINK_DEVICE | MV_GENTL_CXP_DEVICE | MV_GENTL_XOF_DEVICE); + } catch (CameraControlException e) { + log.error("Enumerate devices failed!", e); + MvCameraControl.MV_CC_Finalize(); + return false; + } + + if (stDeviceList == null || stDeviceList.size() <= 0) { + log.error("No devices found!"); + MvCameraControl.MV_CC_Finalize(); + return false; + } + + // 打印设备信息 + log.info("Found {} device(s):", stDeviceList.size()); + int i = 0; + for (MV_CC_DEVICE_INFO stDeviceInfo : stDeviceList) { + if (null == stDeviceInfo) { + continue; + } + log.info("[camera {}}", i++); + printDeviceInfo(stDeviceInfo); + } + + // 默认选择第一个设备 + log.info("Selecting first device..."); + try { + hCamera = MvCameraControl.MV_CC_CreateHandle(stDeviceList.get(0)); + } catch (CameraControlException e) { + log.error("Create handle failed!", e); + MvCameraControl.MV_CC_Finalize(); + return false; + } + + // 打开设备 + log.info("Opening device..."); + nRet = MvCameraControl.MV_CC_OpenDevice(hCamera); + if (MV_OK != nRet) { + log.error("Connect to camera failed, errcode: [0x{0}]", Integer.toHexString(nRet)); + MvCameraControl.MV_CC_DestroyHandle(hCamera); + hCamera = null; + MvCameraControl.MV_CC_Finalize(); + return false; + } + + // 关闭触发模式 + log.info("Turning off trigger mode..."); + nRet = MvCameraControl.MV_CC_SetEnumValueByString(hCamera, "TriggerMode", "Off"); + if (MV_OK != nRet) { + log.error("SetTriggerMode failed, errcode: [0x{0}]", Integer.toHexString(nRet)); + closeCamera(); + return false; + } + + log.info("Camera initialized successfully"); + return true; + } catch (Exception e) { + log.error("Initialize camera failed", e); + closeCamera(); + return false; + } + } + + /** + * 开始视频流 + * @return 开始结果 + */ + public synchronized boolean startStream() { + if (hCamera == null) { + log.error("Camera not initialized"); + return false; + } + + if (isRunning) { + log.info("Stream already running"); + return true; + } + + try { + // 注册图像回调 + log.info("Registering image callback..."); + int nRet = MvCameraControl.MV_CC_RegisterImageCallBack(hCamera, new CameraImageCallBack() { + @Override + public int OnImageCallBack(byte[] bytes, MV_FRAME_OUT_INFO mv_frame_out_info) { + printFrameInfo(mv_frame_out_info); + processImage(bytes, mv_frame_out_info); + return 0; + } + }); + if (MV_OK != nRet) { + log.error("Register image callback failed, errcode: [0x{0}]", Integer.toHexString(nRet)); + return false; + } + + // 开始采集 + log.info("Starting grabbing..."); + nRet = MvCameraControl.MV_CC_StartGrabbing(hCamera); + if (MV_OK != nRet) { + log.error("StartGrabbing failed, errcode: [0x{0}]", Integer.toHexString(nRet)); + return false; + } + + isRunning = true; + log.info("Stream started successfully"); + return true; + } catch (Exception e) { + log.error("Start stream failed", e); + return false; + } + } + + /** + * 停止视频流 + */ + public synchronized void stopStream() { + if (hCamera == null || !isRunning) { + return; + } + + try { + // 停止采集 + log.info("Stopping grabbing..."); + int nRet = MvCameraControl.MV_CC_StopGrabbing(hCamera); + if (MV_OK != nRet) { + log.error("StopGrabbing failed, errcode: [0x{0}]", Integer.toHexString(nRet)); + } + + isRunning = false; + log.info("Stream stopped"); + } catch (Exception e) { + log.error("Stop stream failed", e); + } + } + + /** + * 关闭相机 + */ + public synchronized void closeCamera() { + if (hCamera != null) { + try { + // 停止采集 + log.info("Stopping grabbing..."); + MvCameraControl.MV_CC_StopGrabbing(hCamera); + // 关闭设备 + log.info("Closing device..."); + MvCameraControl.MV_CC_CloseDevice(hCamera); + // 销毁句柄 + log.info("Destroying handle..."); + MvCameraControl.MV_CC_DestroyHandle(hCamera); + } catch (Exception e) { + log.error("Close camera failed", e); + } finally { + hCamera = null; + } + } + + // 释放SDK + try { + log.info("Finalizing SDK..."); + MvCameraControl.MV_CC_Finalize(); + } catch (Exception e) { + log.error("Finalize SDK failed", e); + } + + isRunning = false; + log.info("Camera closed"); + } + + /** + * 处理图像数据 + * @param bytes 原始图像数据 + * @param frameInfo 帧信息 + */ + private void processImage(byte[] bytes, MV_FRAME_OUT_INFO frameInfo) { + if (bytes == null || frameInfo == null || webSocketSessions.isEmpty()) { + return; + } + + try { + // 打印帧信息，以便调试 + printFrameInfo(frameInfo); + + // 对于黑白相机（MV-CE050-30GM），数据是单通道灰度格式 + // 创建包含图像尺寸信息和原始数据的消息 + // 消息格式: [width(4 bytes)][height(4 bytes)][image data] + byte[] message = new byte[8 + bytes.length]; + + // 写入宽度和高度（使用小端序） + message[0] = (byte) (frameInfo.width & 0xFF); + message[1] = (byte) ((frameInfo.width >> 8) & 0xFF); + message[2] = (byte) ((frameInfo.width >> 16) & 0xFF); + message[3] = (byte) ((frameInfo.width >> 24) & 0xFF); + + message[4] = (byte) (frameInfo.height & 0xFF); + message[5] = (byte) ((frameInfo.height >> 8) & 0xFF); + message[6] = (byte) ((frameInfo.height >> 16) & 0xFF); + message[7] = (byte) ((frameInfo.height >> 24) & 0xFF); + + // 写入原始图像数据 + System.arraycopy(bytes, 0, message, 8, bytes.length); + + // 发送图像数据到所有连接的WebSocket客户端 + for (WebSocketSession session : webSocketSessions.values()) { + if (session.isOpen()) { + try { + session.sendMessage(new BinaryMessage(message)); + } catch (Exception e) { + log.error("Send message to WebSocket failed", e); + } + } + } + } catch (Exception e) { + log.error("Process image failed", e); + } + } + + /** + * 添加WebSocket会话 + * @param session WebSocket会话 + */ + public void addWebSocketSession(WebSocketSession session) { + if (session != null) { + webSocketSessions.put(session.getId(), session); + log.info("WebSocket session added: {}", session.getId()); + + // 如果相机未初始化，初始化相机 + if (!initializeCamera()) { + log.error("Failed to initialize camera for new WebSocket session"); + return; + } + + // 如果视频流未开始，开始视频流 + if (!isRunning) { + startStream(); + } + } + } + + /** + * 移除WebSocket会话 + * @param session WebSocket会话 + */ + public void removeWebSocketSession(WebSocketSession session) { + if (session != null) { + webSocketSessions.remove(session.getId()); + log.info("WebSocket session removed: {}", session.getId()); + + // 如果没有活跃的WebSocket会话，停止视频流 + if (webSocketSessions.isEmpty()) { + stopStream(); + } + } + } + + /** + * 获取当前连接的WebSocket会话数量 + * @return 会话数量 + */ + public int getWebSocketSessionCount() { + return webSocketSessions.size(); + } + + /** + * 检查相机是否正在运行 + * @return 是否正在运行 + */ + public boolean isRunning() { + return isRunning; + } + + /** + * 打印设备信息 + * @param stDeviceInfo 设备信息 + */ + private void printDeviceInfo(MV_CC_DEVICE_INFO stDeviceInfo) { + if (null == stDeviceInfo) { + log.error("stDeviceInfo is null"); + return; + } + + if ((stDeviceInfo.transportLayerType == MV_GIGE_DEVICE) || (stDeviceInfo.transportLayerType == MV_GENTL_GIGE_DEVICE)) { + log.info("\tCurrentIp: {}", stDeviceInfo.gigEInfo.currentIp); + log.info("\tModel: {}", stDeviceInfo.gigEInfo.modelName); + log.info("\tUserDefinedName: {}", stDeviceInfo.gigEInfo.userDefinedName); + } else if (stDeviceInfo.transportLayerType == MV_USB_DEVICE) { + log.info("\tUserDefinedName: {}", stDeviceInfo.usb3VInfo.userDefinedName); + log.info("\tSerial Number: {}", stDeviceInfo.usb3VInfo.serialNumber); + log.info("\tDevice Number: {}", stDeviceInfo.usb3VInfo.deviceNumber); + } else if (stDeviceInfo.transportLayerType == MV_GENTL_CAMERALINK_DEVICE) { + log.info("\tUserDefinedName: {}", stDeviceInfo.cmlInfo.userDefinedName); + log.info("\tSerial Number: {}", stDeviceInfo.cmlInfo.serialNumber); + log.info("\tDevice Number: {}", stDeviceInfo.cmlInfo.DeviceID); + } else if (stDeviceInfo.transportLayerType == MV_GENTL_CXP_DEVICE) { + log.info("\tUserDefinedName: {}", stDeviceInfo.cxpInfo.userDefinedName); + log.info("\tSerial Number: {}", stDeviceInfo.cxpInfo.serialNumber); + log.info("\tDevice Number: {}", stDeviceInfo.cxpInfo.DeviceID); + } else if (stDeviceInfo.transportLayerType == MV_GENTL_XOF_DEVICE) { + log.info("\tUserDefinedName: {}", stDeviceInfo.xofInfo.userDefinedName); + log.info("\tSerial Number: {}", stDeviceInfo.xofInfo.serialNumber); + log.info("\tDevice Number: {}", stDeviceInfo.xofInfo.DeviceID); + } else { + log.error("Device is not supported! "); + } + + log.info("\tAccessible: {}", MvCameraControl.MV_CC_IsDeviceAccessible(stDeviceInfo, MV_ACCESS_Exclusive)); + } + + /** + * 打印帧信息 + * @param stFrameInfo 帧信息 + */ + private void printFrameInfo(MV_FRAME_OUT_INFO stFrameInfo) { + if (null == stFrameInfo) { + log.error("stFrameInfo is null"); + return; + } + + StringBuilder frameInfo = new StringBuilder(""); + frameInfo.append(("\tFrameNum[" + stFrameInfo.frameNum + "]")); + frameInfo.append("\tWidth[" + stFrameInfo.width + "]"); + frameInfo.append("\tHeight[" + stFrameInfo.height + "]"); + frameInfo.append(String.format("\tPixelType[%#x]", stFrameInfo.pixelType.getnValue())); + + log.debug(frameInfo.toString()); + } +} \ No newline at end of file diff --git a/wms-webapi/src/main/java/top/wms/admin/controller/hkMVS/CameraWebSocketHandler.java b/wms-webapi/src/main/java/top/wms/admin/controller/hkMVS/CameraWebSocketHandler.java new file mode 100644 index 0000000..48fb729 --- /dev/null +++ b/wms-webapi/src/main/java/top/wms/admin/controller/hkMVS/CameraWebSocketHandler.java @@ -0,0 +1,64 @@ +package top.wms.admin.controller.hkMVS; + +import jakarta.annotation.Resource; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; +import org.springframework.web.socket.CloseStatus; +import org.springframework.web.socket.WebSocketSession; +import org.springframework.web.socket.handler.BinaryWebSocketHandler; + +@Slf4j +@Component +public class CameraWebSocketHandler extends BinaryWebSocketHandler { + + @Resource + private CameraService cameraService; + + /** + * 连接建立时触发 + */ + @Override + public void afterConnectionEstablished(WebSocketSession session) throws Exception { + log.info("WebSocket connection established: {}", session.getId()); + // 添加WebSocket会话到CameraService + cameraService.addWebSocketSession(session); + } + + /** + * 连接关闭时触发 + */ + @Override + public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception { + log.info("WebSocket connection closed: {}, status: {}", session.getId(), status); + // 从CameraService移除WebSocket会话 + cameraService.removeWebSocketSession(session); + } + + /** + * 处理二进制消息 + */ + @Override + protected void handleBinaryMessage(WebSocketSession session, org.springframework.web.socket.BinaryMessage message) throws Exception { + // 可以在这里处理前端发送的二进制消息（如果需要） + log.debug("Received binary message from WebSocket session: {}", session.getId()); + } + + /** + * 处理文本消息 + */ + @Override + protected void handleTextMessage(WebSocketSession session, org.springframework.web.socket.TextMessage message) { + // 可以在这里处理前端发送的文本消息（如果需要） + log.debug("Received text message from WebSocket session: {}, message: {}", session.getId(), message.getPayload()); + } + + /** + * 处理传输错误 + */ + @Override + public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception { + log.error("WebSocket transport error: {}", exception.getMessage(), exception); + // 从CameraService移除WebSocket会话 + cameraService.removeWebSocketSession(session); + } +} \ No newline at end of file diff --git a/wms-webapi/src/main/java/top/wms/admin/controller/hkMVS/ConvertPixelType.java b/wms-webapi/src/main/java/top/wms/admin/controller/hkMVS/ConvertPixelType.java new file mode 100644 index 0000000..1c07680 --- /dev/null +++ b/wms-webapi/src/main/java/top/wms/admin/controller/hkMVS/ConvertPixelType.java @@ -0,0 +1,386 @@ +package top.wms.admin.controller.hkMVS; /*************************************************************************************************** + * @file ConvertPixelType.java + * @breif Use functions provided in MvCameraControlWrapper.jar to convert pixel type。 + * @author zhanglei72 + * @date 2020/02/10 + * + * @warning + * @version V1.0.0 2020/02/10 create this file. + * @since 2020/02/10 + **************************************************************************************************/ + +import MvCameraControlWrapper.CameraControlException; +import MvCameraControlWrapper.MvCameraControl; + +import java.io.File; +import java.io.FileOutputStream; +import java.io.IOException; +import java.io.OutputStream; +import java.util.ArrayList; +import java.util.Scanner; + +import static MvCameraControlWrapper.MvCameraControlDefines.*; + +public class ConvertPixelType +{ + public static Scanner scanner; + private static void printDeviceInfo(MV_CC_DEVICE_INFO stDeviceInfo) + { + if (null == stDeviceInfo) { + System.out.println("stDeviceInfo is null"); + return; + } + + if ((stDeviceInfo.transportLayerType == MV_GIGE_DEVICE) ||( stDeviceInfo.transportLayerType == MV_GENTL_GIGE_DEVICE)) + { + System.out.println("\tCurrentIp: " + stDeviceInfo.gigEInfo.currentIp); + System.out.println("\tModel: " + stDeviceInfo.gigEInfo.modelName); + System.out.println("\tUserDefinedName: " + stDeviceInfo.gigEInfo.userDefinedName); + } else if (stDeviceInfo.transportLayerType == MV_USB_DEVICE) { + System.out.println("\tUserDefinedName: " + stDeviceInfo.usb3VInfo.userDefinedName); + System.out.println("\tSerial Number: " + stDeviceInfo.usb3VInfo.serialNumber); + System.out.println("\tDevice Number: " + stDeviceInfo.usb3VInfo.deviceNumber); + } else if (stDeviceInfo.transportLayerType == MV_GENTL_CAMERALINK_DEVICE) + { + System.out.println("\tUserDefinedName: " + stDeviceInfo.cmlInfo.userDefinedName); + System.out.println("\tSerial Number: " + stDeviceInfo.cmlInfo.serialNumber); + System.out.println("\tDevice Number: " + stDeviceInfo.cmlInfo.DeviceID); + } + else if (stDeviceInfo.transportLayerType == MV_GENTL_CXP_DEVICE) + { + System.out.println("\tUserDefinedName: " + stDeviceInfo.cxpInfo.userDefinedName); + System.out.println("\tSerial Number: " + stDeviceInfo.cxpInfo.serialNumber); + System.out.println("\tDevice Number: " + stDeviceInfo.cxpInfo.DeviceID); + } + else if (stDeviceInfo.transportLayerType == MV_GENTL_XOF_DEVICE) + { + System.out.println("\tUserDefinedName: " + stDeviceInfo.xofInfo.userDefinedName); + System.out.println("\tSerial Number: " + stDeviceInfo.xofInfo.serialNumber); + System.out.println("\tDevice Number: " + stDeviceInfo.xofInfo.DeviceID); + }else { + System.err.print("Device is not supported! \n"); + } + + System.out.println("\tAccessible: " + + MvCameraControl.MV_CC_IsDeviceAccessible(stDeviceInfo, MV_ACCESS_Exclusive)); + System.out.println(""); + } + + private static void printFrameInfo(MV_FRAME_OUT_INFO stFrameInfo) + { + if (null == stFrameInfo) + { + System.err.println("stFrameInfo is null"); + return; + } + + StringBuilder frameInfo = new StringBuilder(""); + frameInfo.append(("\tFrameNum[" + stFrameInfo.frameNum + "]")); + frameInfo.append("\tWidth[" + stFrameInfo.width + "]"); + frameInfo.append("\tHeight[" + stFrameInfo.height + "]"); + frameInfo.append(String.format("\tPixelType[%#x]", stFrameInfo.pixelType.getnValue())); + + System.out.println(frameInfo.toString()); + } + + public static void saveDataToFile(byte[] dataToSave, int dataSize, String fileName) + { + OutputStream os = null; + + try + { + if((null == dataToSave)||(dataSize <= 0)) + { + System.out.println("saveDataToFile param error."); + return; + } + // create diractory + File tempFile = new File("dat"); + if (!tempFile.exists()) + { + tempFile.mkdirs(); + } + + os = new FileOutputStream(tempFile.getPath() + File.separator + fileName); + if(null != os) + { + os.write(dataToSave, 0, dataSize); + System.out.println("ConvertPixelType succeed."); + } + + } + catch (IOException e) + { + e.printStackTrace(); + } + finally + { + // close file stream + try + { + if(os != null) + { + os.close(); + } + + } catch (IOException e) + { + e.printStackTrace(); + } + } + } + + public static int chooseCamera(ArrayList stDeviceList) + { + if (null == stDeviceList) + { + return -1; + } + + // Choose a device to operate + int camIndex = -1; + + while (true) + { + System.out.print("Please input camera index:"); + if (scanner.hasNextInt()) + { + try + { + camIndex = scanner.nextInt(); + if ((camIndex >= 0 && camIndex < stDeviceList.size()) || -1 == camIndex) + { + break; + } + else + { + System.out.println("Input error: " + camIndex + " Over Range:( 0 - " + (stDeviceList.size()-1) + " )"); + } + } + catch (Exception e) + { + System.out.println("Input not number."); + camIndex = -1; + break; + } + } + else + { + camIndex = -1; + break; + } + + } + if (-1 == camIndex) { + System.out.println("Input error.exit"); + return camIndex; + } + + if (0 <= camIndex && stDeviceList.size() > camIndex) + { + if ((MV_GIGE_DEVICE == stDeviceList.get(camIndex).transportLayerType)||(MV_GENTL_GIGE_DEVICE == stDeviceList.get(camIndex).transportLayerType)) + { + System.out.println("Connect to camera[" + camIndex + "]: " + stDeviceList.get(camIndex).gigEInfo.userDefinedName); + } + else if (MV_USB_DEVICE == stDeviceList.get(camIndex).transportLayerType) + { + System.out.println("Connect to camera[" + camIndex + "]: " + stDeviceList.get(camIndex).usb3VInfo.userDefinedName); + } + else if (MV_GENTL_CAMERALINK_DEVICE == stDeviceList.get(camIndex).transportLayerType) + { + System.out.println("Connect to camera[" + camIndex + "]: " + stDeviceList.get(camIndex).cmlInfo.DeviceID); + } + else if (MV_GENTL_CXP_DEVICE == stDeviceList.get(camIndex).transportLayerType) + { + System.out.println("Connect to camera[" + camIndex + "]: " + stDeviceList.get(camIndex).cxpInfo.DeviceID); + } + else if (MV_GENTL_XOF_DEVICE == stDeviceList.get(camIndex).transportLayerType) + { + System.out.println("Connect to camera[" + camIndex + "]: " + stDeviceList.get(camIndex).xofInfo.DeviceID); + } + else + { + System.out.println("Device is not supported."); + } + } + else + { + System.out.println("Invalid index " + camIndex); + camIndex = -1; + } + + return camIndex; + } + + public static void main(String[] args) + { + int nRet = MV_OK; + int camIndex = -1; + Handle hCamera = null; + scanner = new Scanner(System.in); + ArrayList stDeviceList = null; + + do + { + System.out.println("SDK Version " + MvCameraControl.MV_CC_GetSDKVersion()); + + // Initialize SDK + nRet = MvCameraControl.MV_CC_Initialize(); + if (MV_OK != nRet) + { + System.err.printf("Initialize SDK fail! nRet [0x%x]\n\n",nRet); + break; + } + + // Enumerate GigE and USB devices + try + { + stDeviceList = MvCameraControl.MV_CC_EnumDevices(MV_GIGE_DEVICE | MV_USB_DEVICE | MV_GENTL_GIGE_DEVICE | MV_GENTL_CAMERALINK_DEVICE | MV_GENTL_CXP_DEVICE | MV_GENTL_XOF_DEVICE); + if (0 >= stDeviceList.size()) + { + System.out.println("No devices found!"); + break; + } + int i = 0; + for (MV_CC_DEVICE_INFO stDeviceInfo : stDeviceList) + { + System.out.println("[camera " + (i++) + "]"); + printDeviceInfo(stDeviceInfo); + } + } + catch (CameraControlException e) + { + System.err.println("Enumrate devices failed!" + e.toString()); + e.printStackTrace(); + break; + } + + // choose camera + camIndex = chooseCamera(stDeviceList); + if (camIndex == -1) + { + break; + } + + // Create device handle + try + { + hCamera = MvCameraControl.MV_CC_CreateHandle(stDeviceList.get(camIndex)); + } + catch (CameraControlException e) + { + System.err.println("Create handle failed!" + e.toString()); + e.printStackTrace(); + hCamera = null; + break; + } + + // Open selected device + nRet = MvCameraControl.MV_CC_OpenDevice(hCamera); + if (MV_OK != nRet) + { + System.err.printf("Connect to camera failed, errcode: [%#x]\n", nRet); + break; + } + + // make sure that Trigger mode is off + nRet = MvCameraControl.MV_CC_SetEnumValueByString(hCamera, "TriggerMode", "Off"); + if (MV_OK != nRet) + { + System.err.printf("SetTriggerMode failed, errcode: [%#x]\n", nRet); + break; + } + + // Get payload size + MVCC_INTVALUE stParam = new MVCC_INTVALUE(); + nRet = MvCameraControl.MV_CC_GetIntValue(hCamera, "PayloadSize", stParam); + if (MV_OK != nRet) + { + System.err.printf("Get PayloadSize fail, errcode: [%#x]\n", nRet); + break; + } + + // Start grabbing images + nRet = MvCameraControl.MV_CC_StartGrabbing(hCamera); + if (MV_OK != nRet) + { + System.err.printf("Start Grabbing fail, errcode: [%#x]\n", nRet); + break; + } + + // Get one frame + MV_FRAME_OUT_INFO stImageInfo = new MV_FRAME_OUT_INFO(); + byte[] pData = new byte[(int)stParam.curValue]; + nRet = MvCameraControl.MV_CC_GetOneFrameTimeout(hCamera, pData, stImageInfo, 1000); + if (MV_OK != nRet) + { + System.err.printf("GetOneFrameTimeout fail, errcode:[%#x]\n", nRet); + break; + } + + System.out.println("GetOneFrame: "); + printFrameInfo(stImageInfo); + + // set interpolation algorithm type, 0-Fast 1-Equilibrium 2-Optimal 3-Optimal plus + nRet = MvCameraControl.MV_CC_SetBayerCvtQuality(hCamera, 1); + if (MV_OK != nRet) + { + System.err.printf("set Bayer convert quality fail! nRet [0x%x]\n", nRet); + break; + } + + int dataSizeForRGB = stImageInfo.width * stImageInfo.height * 3; // every RGB pixel takes 3 bytes + byte[] pDataForRGB = new byte[dataSizeForRGB]; + + // Convert pixel type to RGB8_Packed + MV_CC_PIXEL_CONVERT_PARAM_EX stConvertParam = new MV_CC_PIXEL_CONVERT_PARAM_EX(); + stConvertParam.width = stImageInfo.ExtendWidth; // image width + stConvertParam.height = stImageInfo.ExtendHeight; // image height + stConvertParam.srcData = pData; // input buffer + stConvertParam.srcDataLen = stImageInfo.frameLen; // input buffer size + stConvertParam.srcPixelType = stImageInfo.pixelType; // input pixel format + stConvertParam.dstPixelType = MvGvspPixelType.PixelType_Gvsp_RGB8_Packed; // output pixel format + stConvertParam.dstBuffer = pDataForRGB; // output buffer + stConvertParam.dstBufferSize = dataSizeForRGB; // output buffer size + + nRet = MvCameraControl.MV_CC_ConvertPixelTypeEx(hCamera, stConvertParam); + if (MV_OK != nRet) + { + System.err.printf("Convert PixelType fail, errcode: [%#x]\n", nRet); + break; + } + + // Save buffer content to file + saveDataToFile(pDataForRGB, dataSizeForRGB, "AfterConvert_RGB.raw"); + + // Stop grabbing + nRet = MvCameraControl.MV_CC_StopGrabbing(hCamera); + if (MV_OK != nRet) + { + System.err.printf("StopGrabbing failed, errcode: [%#x]\n", nRet); + break; + } + + // close device + nRet = MvCameraControl.MV_CC_CloseDevice(hCamera); + if (MV_OK != nRet) + { + System.err.printf("CloseDevice failed, errcode: [%#x]\n", nRet); + break; + } + + + } while (false); + + if (null != hCamera) + { + // Destroy handle + nRet = MvCameraControl.MV_CC_DestroyHandle(hCamera); + if (MV_OK != nRet) { + System.err.printf("DestroyHandle failed, errcode: [%#x]\n", nRet); + } + } + MvCameraControl.MV_CC_Finalize(); + scanner.close(); + } +}