291 lines
7.5 KiB
C++
291 lines
7.5 KiB
C++
#include "base/HGDef.h"
|
|
#include "base/HGInc.h"
|
|
#include "base/HGCrash.h"
|
|
#include "base/HGThread.h"
|
|
#include "base/HGUtility.h"
|
|
#include "base/HGIni.h"
|
|
#include "base/HGMsgPump.h"
|
|
#include "ManagerV1.h"
|
|
#include "ManagerV2.h"
|
|
#include "HttpServer.h"
|
|
#include "SockIoServer.h"
|
|
#include "WSServer.h"
|
|
#include "MsgPumpCallback.h"
|
|
#include "curl/curl.h"
|
|
#include "log/log.h"
|
|
|
|
HLOG g_hLog = nullptr;
|
|
//HGMsgPump msgPumpV1 = NULL;
|
|
HGMsgPump msgPumpV2 = NULL;
|
|
|
|
#if defined(OEM_HANWANG)
|
|
const char* oem = "HanvonScan";
|
|
#elif defined(OEM_LISICHENG)
|
|
const char* oem = "LanxumScan";
|
|
#elif defined(OEM_CANGTIAN)
|
|
const char* oem = "CumtennScan";
|
|
#elif defined(OEM_ZHONGJING)
|
|
const char* oem = "MicrotekScan";
|
|
#elif defined(OEM_ZIGUANG)
|
|
const char* oem = "UniScan";
|
|
#elif defined(OEM_NEUTRAL)
|
|
const char* oem = "NeuScan";
|
|
#elif defined(OEM_DELI)
|
|
const char* oem = "DeliScan";
|
|
#elif defined(OEM_MEISONGDA)
|
|
const char *oem = "MaxsoundScan";
|
|
#elif defined(OEM_GUANGDIANTONG)
|
|
const char *oem = "ToecScan";
|
|
#else
|
|
const char* oem = "HuaGoScan";
|
|
#endif
|
|
|
|
static void HGAPI CrashFunc(HGPointer crashAddr, HGPointer param)
|
|
{
|
|
HGChar logPath[256];
|
|
HGBase_GetConfigPath(logPath, 256);
|
|
strcat(logPath, "crash.dmp");
|
|
HGBase_MakeCrashFile(logPath);
|
|
}
|
|
|
|
static void HGAPI ThreadFuncV1(HGThread thread, HGPointer param)
|
|
{
|
|
(void)thread;
|
|
HGMsgPump msgPump = (HGMsgPump)param;
|
|
|
|
HGChar cfgPath[256];
|
|
HGBase_GetConfigPath(cfgPath, 256);
|
|
HGChar cfgName[256];
|
|
sprintf(cfgName, "%s%s", cfgPath, "config.ini");
|
|
|
|
ver_1::ManagerV1 manager(msgPump);
|
|
ver_1::HttpServer httpServer(msgPump, &manager);
|
|
ver_1::SockIoServer sockIoServer(msgPump, &manager);
|
|
|
|
if (httpServer.Open(18999))
|
|
{
|
|
if (sockIoServer.Open(28999))
|
|
{
|
|
HGBase_RunMsgPump(msgPump, ver_1::HGMsgPumpCallback, NULL);
|
|
sockIoServer.Close();
|
|
}
|
|
|
|
httpServer.Close();
|
|
}
|
|
}
|
|
|
|
static void HGAPI ThreadFuncV2(HGThread thread, HGPointer param)
|
|
{
|
|
(void)thread;
|
|
HGMsgPump msgPump = (HGMsgPump)param;
|
|
|
|
HGChar cfgPath[256];
|
|
HGBase_GetConfigPath(cfgPath, 256);
|
|
HGChar cfgName[256];
|
|
sprintf(cfgName, "%s%s", cfgPath, "config2.ini");
|
|
|
|
ver_2::ManagerV2 manager(msgPump);
|
|
ver_2::WSServer wsServer(msgPump, &manager);
|
|
|
|
HGInt port = 38999;
|
|
HGBase_GetProfileInt(cfgName, "connect", "port", 38999, &port);
|
|
if (wsServer.Open(port))
|
|
{
|
|
HGBase_RunMsgPump(msgPump, ver_2::HGMsgPumpCallback, NULL);
|
|
wsServer.Close();
|
|
}
|
|
}
|
|
|
|
|
|
#if defined(HG_CMP_MSC)
|
|
|
|
#ifndef _DEBUG
|
|
|
|
#if defined(OEM_HANWANG)
|
|
#define SERVICE_NAME TEXT("HWWebService")
|
|
#elif defined(OEM_LISICHENG)
|
|
#define SERVICE_NAME TEXT("LSCWebService")
|
|
#elif defined(OEM_CANGTIAN)
|
|
#define SERVICE_NAME TEXT("CTSWebService")
|
|
#elif defined(OEM_ZHONGJING)
|
|
#define SERVICE_NAME TEXT("ZJWebService")
|
|
#elif defined(OEM_ZIGUANG)
|
|
#define SERVICE_NAME TEXT("ZGWebService")
|
|
#elif defined(OEM_NEUTRAL)
|
|
#define SERVICE_NAME TEXT("NEUWebService")
|
|
#elif defined(OEM_DELI)
|
|
#define SERVICE_NAME TEXT("DLWebService")
|
|
#elif defined(OEM_MEISONGDA)
|
|
#define SERVICE_NAME TEXT("MSDWebService")
|
|
#elif defined(OEM_GUANGDIANTONG)
|
|
#define SERVICE_NAME TEXT("GDTWebService")
|
|
#else
|
|
#define SERVICE_NAME TEXT("HGWebService")
|
|
#endif
|
|
|
|
SERVICE_STATUS_HANDLE ServiceStatusHandle = NULL;
|
|
SERVICE_STATUS ServiceStatus = {0};
|
|
|
|
void WINAPI ServiceCtrlHandler(DWORD dwControl)
|
|
{
|
|
switch (dwControl)
|
|
{
|
|
case SERVICE_CONTROL_STOP: // 暂停控制
|
|
ServiceStatus.dwCurrentState = SERVICE_STOPPED;// 状态设置为停止
|
|
//HGBase_ExitMsgPump(msgPumpV1);
|
|
HGBase_ExitMsgPump(msgPumpV2);
|
|
break;
|
|
case SERVICE_CONTROL_SHUTDOWN:// 关机控制
|
|
ServiceStatus.dwCurrentState = SERVICE_STOPPED;// 状态设置为停止
|
|
//HGBase_ExitMsgPump(msgPumpV1);
|
|
HGBase_ExitMsgPump(msgPumpV2);
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
|
|
// 设置服务状态
|
|
SetServiceStatus(ServiceStatusHandle, &ServiceStatus);
|
|
}
|
|
|
|
void WINAPI ServiceMain(DWORD dwNumServicesArgs, LPTSTR* lpServiceArgVectors)
|
|
{
|
|
ServiceStatusHandle = RegisterServiceCtrlHandler(SERVICE_NAME, ServiceCtrlHandler);
|
|
if (NULL == ServiceStatusHandle)
|
|
{
|
|
return;
|
|
}
|
|
|
|
ServiceStatus.dwServiceType = SERVICE_WIN32;
|
|
ServiceStatus.dwCurrentState = SERVICE_START_PENDING; // 服务正在启动
|
|
ServiceStatus.dwControlsAccepted = SERVICE_ACCEPT_SHUTDOWN | SERVICE_ACCEPT_STOP; // 接受关机与暂停两种控制
|
|
ServiceStatus.dwWin32ExitCode = 0; // 下面四个默认都为0
|
|
ServiceStatus.dwServiceSpecificExitCode = 0;
|
|
ServiceStatus.dwCheckPoint = 0;
|
|
ServiceStatus.dwWaitHint = 0;
|
|
|
|
WSADATA ws = { 0 };
|
|
int ret = WSAStartup(MAKEWORD(2, 2), &ws);
|
|
assert(0 == ret);
|
|
curl_global_init(CURL_GLOBAL_ALL);
|
|
|
|
//HGBase_CreateMsgPump(&msgPumpV1);
|
|
//HGThread threadV1 = NULL;
|
|
//HGBase_OpenThread(ThreadFuncV1, msgPumpV1, &threadV1);
|
|
|
|
HGBase_CreateMsgPump(&msgPumpV2);
|
|
HGThread threadV2 = NULL;
|
|
HGBase_OpenThread(ThreadFuncV2, msgPumpV2, &threadV2);
|
|
|
|
ServiceStatus.dwCurrentState = SERVICE_RUNNING; // 成功运行则把状态设置为运行状态
|
|
SetServiceStatus(ServiceStatusHandle, &ServiceStatus);
|
|
|
|
HGBase_CloseThread(threadV2);
|
|
threadV2 = NULL;
|
|
HGBase_DestroyMsgPump(msgPumpV2);
|
|
msgPumpV2 = NULL;
|
|
//HGBase_CloseThread(threadV1);
|
|
//threadV1 = NULL;
|
|
//HGBase_DestroyMsgPump(msgPumpV1);
|
|
//msgPumpV1 = NULL;
|
|
|
|
curl_global_cleanup();
|
|
WSACleanup();
|
|
}
|
|
|
|
int main()
|
|
{
|
|
HGBase_RegisterCrashFunc(CrashFunc, NULL);
|
|
g_hLog = EnableLog(nullptr, oem, "app");
|
|
|
|
TCHAR serviceName[128];
|
|
lstrcpy(serviceName, SERVICE_NAME);
|
|
|
|
SERVICE_TABLE_ENTRY tableEntry[2];
|
|
tableEntry[0].lpServiceName = serviceName; // 服务程序名称
|
|
tableEntry[0].lpServiceProc = ServiceMain; // 服务程序入口
|
|
tableEntry[1].lpServiceName = NULL;
|
|
tableEntry[1].lpServiceProc = NULL;
|
|
|
|
StartServiceCtrlDispatcher(tableEntry);
|
|
|
|
DisableLog(g_hLog);
|
|
g_hLog = nullptr;
|
|
return 0;
|
|
}
|
|
|
|
#else
|
|
|
|
int main()
|
|
{
|
|
WSADATA ws = { 0 };
|
|
int ret = WSAStartup(MAKEWORD(2, 2), &ws);
|
|
assert(0 == ret);
|
|
curl_global_init(CURL_GLOBAL_ALL);
|
|
|
|
g_hLog = EnableLog(nullptr, oem, "app");
|
|
|
|
//HGBase_CreateMsgPump(&msgPumpV1);
|
|
//HGThread threadV1 = NULL;
|
|
//HGBase_OpenThread(ThreadFuncV1, msgPumpV1, &threadV1);
|
|
|
|
HGBase_CreateMsgPump(&msgPumpV2);
|
|
HGThread threadV2 = NULL;
|
|
HGBase_OpenThread(ThreadFuncV2, msgPumpV2, &threadV2);
|
|
|
|
HGBase_CloseThread(threadV2);
|
|
threadV2 = NULL;
|
|
HGBase_DestroyMsgPump(msgPumpV2);
|
|
msgPumpV2 = NULL;
|
|
//HGBase_CloseThread(threadV1);
|
|
//threadV1 = NULL;
|
|
//HGBase_DestroyMsgPump(msgPumpV1);
|
|
//msgPumpV1 = NULL;
|
|
|
|
curl_global_cleanup();
|
|
WSACleanup();
|
|
|
|
DisableLog(g_hLog);
|
|
g_hLog = nullptr;
|
|
|
|
return 0;
|
|
}
|
|
|
|
#endif
|
|
|
|
#else
|
|
|
|
int main()
|
|
{
|
|
HGBase_RegisterCrashFunc(CrashFunc, NULL);
|
|
curl_global_init(CURL_GLOBAL_ALL);
|
|
|
|
g_hLog = EnableLog(nullptr, oem, "app");
|
|
|
|
//HGBase_CreateMsgPump(&msgPumpV1);
|
|
//HGThread threadV1 = NULL;
|
|
//HGBase_OpenThread(ThreadFuncV1, msgPumpV1, &threadV1);
|
|
|
|
HGBase_CreateMsgPump(&msgPumpV2);
|
|
HGThread threadV2 = NULL;
|
|
HGBase_OpenThread(ThreadFuncV2, msgPumpV2, &threadV2);
|
|
|
|
HGBase_CloseThread(threadV2);
|
|
threadV2 = NULL;
|
|
HGBase_DestroyMsgPump(msgPumpV2);
|
|
msgPumpV2 = NULL;
|
|
//HGBase_CloseThread(threadV1);
|
|
//threadV1 = NULL;
|
|
//HGBase_DestroyMsgPump(msgPumpV1);
|
|
//msgPumpV1 = NULL;
|
|
|
|
curl_global_cleanup();
|
|
|
|
DisableLog(g_hLog);
|
|
g_hLog = nullptr;
|
|
|
|
return 0;
|
|
}
|
|
|
|
#endif
|