大漠插件C++调用

example(多线程模板).rar

#include "stdafx.h"#include "script.h"#include "thread_control.h"#include "log.h"void DoWork(long index);unsigned WINAPI SubThread(PVOID pParam);void CheckException(long index);// 我们做暂停和恢复操作,就主要靠这个延时函数,要求脚本所有用到延时的地方，全部用这个，这样我们可以有很多机会去暂停线程void ScriptDelay(long index,long time){// 判断是否有暂停和结束标记if (g_info[index].is_stop){// 直接退出当前线程,退出前一定要在本线程内解绑,因为绑定模式0和2在线程外解绑的话会失败,导致解绑失败.if (g_info[index].dm){g_info[index].dm->UnBindWindow();}_endthreadex(0);}if (g_info[index].is_pause){g_info[index].thread_state = State_Pause;ThreadNotifyUI_Post(NOTIFY_UPDATE,index);// 如果你想要在暂停时让用户可以操作,那么可以调用EnableBind,但是不要去调用LockInput,LockInput不是用来解除后台的,具体参考LockInput的说明if (g_info[index].dm){g_info[index].dm->EnableBind(5);}// 我们暂停的方法是死循环,然后延时,而不是调用系统的接口// 这样开销最小,并且效率也还不错while (1){if (!g_info[index].is_pause){g_info[index].thread_state = State_Runing;ThreadNotifyUI_Post(NOTIFY_UPDATE,index);// 开启后台if (g_info[index].dm){g_info[index].dm->EnableBind(1);}break;}if (g_info[index].is_stop){// 直接退出当前线程,退出前一定要在本线程内解绑,因为绑定模式0和2在线程外解绑的话会失败,导致解绑失败.if (g_info[index].dm){g_info[index].dm->UnBindWindow();}_endthreadex(0);}Sleep(1);}}// 可能暂停,恢复时会让状态错乱,这里再判断一次if (g_info[index].thread_state != State_Runing){g_info[index].thread_state = State_Runing;ThreadNotifyUI_Post(NOTIFY_UPDATE,index);// 开启后台if (g_info[index].dm){g_info[index].dm->EnableBind(1);}}Sleep(time);}void SetTaskState(long index,const TCHAR * state){_tcscpy(g_info[index].task_state,state);ThreadNotifyUI_Post(NOTIFY_UPDATE,index);}// 脚本主线程,脚本的主要逻辑在这里处理unsigned WINAPI MainThread(PVOID pParam){long index = (long)(DWORD_PTR)pParam;dmsoft * dm;// 初始化当前线程com组件为MTA模式CoInitializeEx (NULL,0);g_info[index].thread_state = State_Runing;ThreadNotifyUI_Post(NOTIFY_UPDATE,index);// 创建对象g_info[index].dm = new dmsoft;dm = g_info[index].dm;// 检测对象是否创建成功,虽然这个一般不会失败,但为了程序健壮性考虑还是加上,如果内存吃紧，还是可能会失败if (dm == NULL || dm->Ver().GetLength() == 0){Log(_T("对象创建失败"));ThreadNotifyUI_Post(NOTIFY_STOP,index);return 0;}// 开启全局共享字库dm->EnableShareDict(1);// 其他设置,比如路径等等dm->SetPath(_T("c:\test_game"));// 开始绑定,主绑定一定要第一个绑定,并且主绑定所在的线程绝对不能结束,否则会造成绑定失效long dm_ret = dm->BindWindowEx(g_info[index].hwnd,_T("normal"),_T("normal"),_T("dx"),_T("dx.public.anti.api"),0);if (dm_ret != 1){Log(_T("主:绑定失败，错误码:%d"),dm->GetLastError());// 通知主线程进行结束操作(释放资源)ThreadNotifyUI_Post(NOTIFY_STOP,index);return 0;}// 禁止输入dm->LockInput(4);// 我们可以创建副线程了// 更新副线程信息g_info[index MAX_HWND].thread_state = State_Starting;// 通知UI,副线程开始创建了ThreadNotifyUI_Post(NOTIFY_UPDATE,index MAX_HWND);// 创建副线程g_info[index MAX_HWND].handle = (HANDLE)_beginthreadex(0, 0, SubThread, (PVOID)(DWORD_PTR)(index MAX_HWND), 0, 0);if (g_info[index MAX_HWND].handle == NULL){// 这里必须要解绑,因为模式0和2不在当前线程解绑的话,会导致无法解绑dm->UnBindWindow();Log(_T("创建副线程失败"));// 通知主线程进行结束操作(释放资源)ThreadNotifyUI_Post(NOTIFY_STOP,index);return 0;}while (1){SetTaskState(index,_T("开始做任务"));DoWork(index);SetTaskState(index,_T("任务完成"));ScriptDelay(index,1000);}}void DoWork(long index){dmsoft * dm = g_info[index].dm;dm->KeyPressChar(_T("m"));ScriptDelay(index,500);}void SetExcepState(long index,const TCHAR * state){_tcscpy(g_info[index].excep_state,state);ThreadNotifyUI_Post(NOTIFY_STOP,index);}// 脚本副线程,用于检测异常等unsigned WINAPI SubThread(PVOID pParam){long index = (long)(DWORD_PTR)pParam;dmsoft * dm;// 初始化当前线程com组件为MTA模式CoInitializeEx (NULL,0);g_info[index].thread_state = State_Runing;ThreadNotifyUI_Post(NOTIFY_UPDATE,index);// 创建对象g_info[index].dm = new dmsoft;dm = g_info[index].dm;// 检测对象是否创建成功,虽然这个一般不会失败,但为了程序健壮性考虑还是加上,如果内存吃紧，还是可能会失败if (dm == NULL || dm->Ver().GetLength() == 0){Log(_T("对象创建失败"));SetExcepState(index,_T("对象创建失败"));return 0;}// 开启全局共享字库dm->EnableShareDict(1);// 其他设置,比如路径等等dm->SetPath(_T("c:\test_game"));long dm_ret = dm->BindWindowEx(g_info[index].hwnd,_T("normal"),_T("normal"),_T("dx"),_T("dx.public.anti.api"),0);if (dm_ret != 1){Log(_T("副:绑定失败，错误码:%d"),dm->GetLastError());// 通知主线程进行结束操作(释放资源)SetExcepState(index,_T("副:绑定失败"));return 0;}while (1){// 检测一些异常,比如突然弹出的对话框，目标窗口被关闭或者掉线等突发情况// 比如检测到掉线，可考虑通知UI,然后重新运行CheckException(index);ScriptDelay(index,3000);}}void CheckException(long index){dmsoft * dm = g_info[index].dm;// 检测窗口是否存在if (dm->GetWindowState(g_info[index].hwnd,0) == 0){SetExcepState(index,_T("窗口不见了"));}// 检测窗口是否卡死// 检测是否掉线// 检测是否有弹出窗口// 其他检测dm->KeyPressChar(_T("s"));}