视频监控系统视频上云解决方案EasyCVR集成海康EHome私有协议系列——报警模块说明

#include <stdio.h>
#include <Windows.h>
#include "HCISUPCMS.h"
#include "HCISUPAlarm.h"
 
LONG lLoginID = -1;
LONG lListenHandle = -1;
 
//
//注册回调函数
BOOL CALLBACK RegisterCallBack(LONG lUserID, DWORD dwDataType, void *pOutBuffer, DWORD dwOutLen, void *pInBuffer, DWORD dwInLen, void *pUser)
{
    if (ENUM_DEV_ON == dwDataType)
    {
        NET_EHOME_DEV_REG_INFO *pDevInfo = (NET_EHOME_DEV_REG_INFO *)pOutBuffer;
 
        if (pDevInfo != NULL)
        {
          lLoginID = lUserID;
          printf("On-line, lUserID: %d, Device ID: %s\n", lLoginID, pDevInfo->byDeviceID);
        }
        //输入参数
        NET_EHOME_SERVER_INFO *pServerInfo = (NET_EHOME_SERVER_INFO *)pInBuffer;
        pServerInfo->dwTimeOutCount = 6; //心跳超时次数
        pServerInfo->dwKeepAliveSec = 15; //心跳间隔
        memcpy(pServerInfo->struUDPAlarmSever.szIP, "10.16.2.123", sizeof("10.16.2.123")); //报警服务器IP地址（TCP协议） 
        pServerInfo->struUDPAlarmSever.wPort = 7200; //报警服务器端口（UDP协议），需要和报警服务器启动监听的端口一致
        pServerInfo->dwAlarmServerType = 0;  //报警服务器类型：0- 只支持UDP协议上报，1- 支持UDP、TCP两种协议上报
    }
    else if (ENUM_DEV_OFF == dwDataType)
    {
        printf("Off-line, lUserID: %d\n", lUserID);
        NET_ECMS_ForceLogout(lUserID);       
    }
    else
    {
    }
 
    return TRUE;
}
 
//
//AMS报警回调函数
BOOL CALLBACK AlarmMSGCallBack(LONG lHandle, NET_EHOME_ALARM_MSG *pAlarmMsg, void *pUserData)
{
    lListenHandle = lHandle;
 
    DWORD dwType = pAlarmMsg->dwAlarmType;  //不同的报警类型(dwAlarmType)，pAlarmInfo对应不同的报警信息类型
    printf("Callback of alarm listening, dwAlarmType[%d]\n", dwType);
 
    switch(dwType)
    {
    case EHOME_ALARM_UNKNOWN://未知报警信息
        printf("Unknown Alarm Type!\n");
        break;
    case EHOME_ALARM://基本报警信息：移动侦测、视频遮盖、视频丢失、PIR报警、人脸侦测、区域入侵等
        NET_EHOME_ALARM_INFO struAlarmInfo;
        memcpy(&struAlarmInfo, pAlarmMsg->pAlarmInfo, sizeof(NET_EHOME_ALARM_INFO));
        printf("Basic Alarm: Device ID[%s], szAlarmTime[%s], Alarm Type[%d], Action[%d], VideoChannel[%d]!\n", struAlarmInfo.szDeviceID, \
            struAlarmInfo.szAlarmTime, struAlarmInfo.dwAlarmType, struAlarmInfo.dwAlarmAction, struAlarmInfo.dwVideoChannel);
        break;
    case EHOME_ALARM_HEATMAP_REPORT://热度图报告上传
        NET_EHOME_HEATMAP_REPORT struHeatmapInfo;
        memcpy(&struHeatmapInfo, pAlarmMsg->pAlarmInfo, sizeof(NET_EHOME_HEATMAP_REPORT));
        printf("Heatmap report: Device ID[%s], StartTime[%s], StopTime[%s], dwVideoChannel[%d]!\n", struHeatmapInfo.byDeviceID, \
            struHeatmapInfo.byStartTime, struHeatmapInfo.byStopTime, struHeatmapInfo.dwVideoChannel);
        break;
    case EHOME_ALARM_FACESNAP_REPORT://人脸抓拍报告上传
        NET_EHOME_FACESNAP_REPORT struFaceSnap;
        memcpy(&struFaceSnap, pAlarmMsg->pAlarmInfo, sizeof(NET_EHOME_FACESNAP_REPORT));
        printf("Face snap: Device ID[%s], AlarmTime[%s], dwFaceScore[%d], dwVideoChannel[%d]!\n", struFaceSnap.byDeviceID, \
            struFaceSnap.byAlarmTime, struFaceSnap.dwFaceScore, struFaceSnap.dwVideoChannel);
        break;
    case EHOME_ALARM_GPS://GPS信息上传
        NET_EHOME_GPS_INFO struGpsInfo;
        memcpy(&struGpsInfo, pAlarmMsg->pAlarmInfo, sizeof(NET_EHOME_GPS_INFO));
        printf("GPS info: Device ID[%s], SampleTime[%s], Longitude[%d], Latitude[%d]!\n", struGpsInfo.byDeviceID, \
            struGpsInfo.bySampleTime, struGpsInfo.dwLongitude, struGpsInfo.dwLatitude );
        break;
    case EHOME_ALARM_CID_REPORT://报警主机CID报警信息
        NET_EHOME_CID_INFO struCIDInfo;
        memcpy(&struCIDInfo, pAlarmMsg->pAlarmInfo, sizeof(NET_EHOME_CID_INFO));
        printf("CID info: Device ID[%s], AlarmTime[%s], CID Code[%d], CID Type[%d], CID Describe[%s]!\n", struCIDInfo.byDeviceID, \
        struCIDInfo.byTriggerTime, struCIDInfo.dwCIDCode, struCIDInfo.dwCIDType, struCIDInfo.byCIDDescribe );
        break;
    default:
        break;
    }
 
    return TRUE;
}
 
void main(){
 
    
    //开启AMS报警监听
 
    //AMS初始化
    NET_EALARM_Init();
 
    //报警监听参数
    NET_EHOME_ALARM_LISTEN_PARAM struListen = {0};
    memcpy(struListen.struAddress.szIP, "10.16.2.123", sizeof("10.16.2.123"));
    struListen.struAddress.wPort = 7200; //报警服务的监听端口
    struListen.fnMsgCb = AlarmMSGCallBack; //报警回调函数
    struListen.pUserData = NULL;
    struListen.byProtocolType = 1; //0- TCP方式(保留，暂不支持)，1- UDP方式
 
    //启动报警监听
    LONG lHandle = NET_EALARM_StartListen(&struListen);
    if(lHandle < -1)
    {
        printf("NET_EALARM_StartListen failed, error code: %d\n", NET_EALARM_GetLastError());
        NET_EALARM_Fini();
        return;
    }
    printf("NET_EALARM_StartListen!\n");
    //
 
    
    //CMS注册模块初始化
    NET_ECMS_Init();
 
    //注册监听参数
    NET_EHOME_CMS_LISTEN_PARAM struCMSListenPara = {0};
    memcpy(struCMSListenPara.struAddress.szIP, "0.0.0.0", sizeof("0.0.0.0"));
    struCMSListenPara.struAddress.wPort = 7660;
    struCMSListenPara.fnCB = RegisterCallBack;
 
    //启动监听，接收设备注册信息，注册回调函数里面需要发送报警主机IP和端口给设备
    LONG lListen = NET_ECMS_StartListen(&struCMSListenPara);
    if(lListen < -1)
    {
        printf("NET_ECMS_StartListen failed, error code: %d\n", NET_ECMS_GetLastError());
        NET_ECMS_Fini();
        return;
    }
    printf("NET_ECMS_StartListen!\n");
 
    while(1)
    {
        Sleep(1000);  //注册成功之后再做后续操作
        if(lLoginID >= 0)
        {
            break;
        }
    }
 
    Sleep(300000); //等待5分钟，接收报警信息
 
    
    //退出
 
    //CMS停止监听
    if(!NET_ECMS_StopListen(lListen))
    {
        printf("NET_ECMS_StopListen failed, error code: %d\n", NET_ECMS_GetLastError());
    }
 
    //CMS反初始化，释放资源
    NET_ECMS_Fini();
 
    //AMS停止报警监听
    if(lListenHandle >= 0)
    {
        if (!NET_EALARM_StopListen(lListenHandle))
        {
            printf("NET_EALARM_StopListen failed, error code: %d\n", NET_ECMS_GetLastError());
        }
    }
    //AMS反初始化，释放资源
    NET_EALARM_Fini();
 
    printf("Exit!");
}