| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735 | 
							
- // IntervalToSendDlg.cpp : 实现文件
 
- //
 
- #include "stdafx.h"
 
- #include "IntervalToSend.h"
 
- #include "IntervalToSendDlg.h"
 
- #include "afxdialogex.h"
 
- #include "define.h"
 
- #include <fstream>
 
- #include <iostream>
 
- #include <yyjson/yyjson.h>
 
- #include <map>
 
- #include <string>
 
- #ifdef _DEBUG
 
- #define new DEBUG_NEW
 
- #endif
 
- // 用于应用程序“关于”菜单项的 CAboutDlg 对话框
 
- class CAboutDlg : public CDialogEx
 
- {
 
- public:
 
- 	CAboutDlg();
 
- // 对话框数据
 
- 	enum { IDD = IDD_ABOUTBOX };
 
- 	protected:
 
- 	virtual void DoDataExchange(CDataExchange* pDX);    // DDX/DDV 支持
 
- // 实现
 
- protected:
 
- 	DECLARE_MESSAGE_MAP()
 
- };
 
- CAboutDlg::CAboutDlg() : CDialogEx(CAboutDlg::IDD)
 
- {
 
- }
 
- void CAboutDlg::DoDataExchange(CDataExchange* pDX)
 
- {
 
- 	CDialogEx::DoDataExchange(pDX);
 
- }
 
- BEGIN_MESSAGE_MAP(CAboutDlg, CDialogEx)
 
- END_MESSAGE_MAP()
 
- // CIntervalToSendDlg 对话框
 
- CIntervalToSendDlg::CIntervalToSendDlg(CWnd* pParent /*=NULL*/)
 
- 	: CDialogEx(CIntervalToSendDlg::IDD, pParent)
 
- {
 
- 	m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);
 
- }
 
- void CIntervalToSendDlg::DoDataExchange(CDataExchange* pDX)
 
- {
 
- 	CDialogEx::DoDataExchange(pDX);
 
- 	DDX_Text(pDX, IDC_EDT_DATA, m_data);
 
- 	DDX_Text(pDX, IDC_NET_ADDR, m_ip);
 
- 	DDX_Text(pDX, IDC_EDT_PORT, m_port);
 
- 	DDX_Control(pDX, IDC_CMB_TYPE, m_cmbType);
 
- 	DDX_Check(pDX, IDC_CHK_CYCLE, m_bCycle);
 
- 	DDX_Check(pDX, IDC_CHK_MODIFY, m_bModify);
 
- 	DDX_Check(pDX, IDC_CHK_HEX, m_bHex);
 
- }
 
- BEGIN_MESSAGE_MAP(CIntervalToSendDlg, CDialogEx)
 
- 	ON_WM_SYSCOMMAND()
 
- 	ON_WM_PAINT()
 
- 	ON_WM_QUERYDRAGICON()
 
- 	ON_BN_CLICKED(IDC_BTN_START, &CIntervalToSendDlg::OnBnClickedBtnStart)
 
- 	ON_BN_CLICKED(IDC_BTN_CLEAR, &CIntervalToSendDlg::OnBnClickedBtnClear)
 
- 	ON_BN_CLICKED(IDC_BTN_IMPORT, &CIntervalToSendDlg::OnBnClickedBtnImport)
 
- 	ON_MESSAGE(WM_THREAD_STOP, &CIntervalToSendDlg::OnThreadStop)
 
- 	ON_MESSAGE(WM_THREAD_UPDATE_DATA, &CIntervalToSendDlg::OnUpdateData)
 
- END_MESSAGE_MAP()
 
- // CIntervalToSendDlg 消息处理程序
 
- BOOL CIntervalToSendDlg::OnInitDialog()
 
- {
 
- 	CDialogEx::OnInitDialog();
 
- 	// 将“关于...”菜单项添加到系统菜单中。
 
- 	// IDM_ABOUTBOX 必须在系统命令范围内。
 
- 	ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX);
 
- 	ASSERT(IDM_ABOUTBOX < 0xF000);
 
- 	CMenu* pSysMenu = GetSystemMenu(FALSE);
 
- 	if (pSysMenu != NULL)
 
- 	{
 
- 		BOOL bNameValid;
 
- 		CString strAboutMenu;
 
- 		bNameValid = strAboutMenu.LoadString(IDS_ABOUTBOX);
 
- 		ASSERT(bNameValid);
 
- 		if (!strAboutMenu.IsEmpty())
 
- 		{
 
- 			pSysMenu->AppendMenu(MF_SEPARATOR);
 
- 			pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);
 
- 		}
 
- 	}
 
- 	// 设置此对话框的图标。  当应用程序主窗口不是对话框时,框架将自动
 
- 	//  执行此操作
 
- 	SetIcon(m_hIcon, TRUE);			// 设置大图标
 
- 	SetIcon(m_hIcon, FALSE);		// 设置小图标
 
- 	UpdateData(FALSE);
 
- 	m_cmbType.InsertString((int)eSendType::ST_ONE_SECOND, "每秒发送一次");
 
- 	m_cmbType.InsertString((int)eSendType::ST_TEN_SECOND, "每十秒发送一次");
 
- 	m_cmbType.InsertString((int)eSendType::ST_ONE_MINITUE, "每分钟发送一次");
 
- 	m_cmbType.InsertString((int)eSendType::ST_ONE_HOUR, "每小时发送一次");
 
- 	m_cmbType.InsertString((int)eSendType::ST_ONE_100MILLI, "每100毫秒发送一次");
 
- 	m_cmbType.InsertString((int)eSendType::ST_ACTUAL, "模拟实际发送");
 
- 	m_cmbType.InsertString((int)eSendType::ST_ONE_10MILLI, "每10毫秒发送一次");
 
- 	auto nPos = GetPrivateProfileInt("INFO", "sendtype",(int)eSendType::ST_ONE_SECOND, "IntervalToSend.ini");
 
- 	m_cmbType.SetCurSel(nPos);
 
- 	return TRUE;  // 除非将焦点设置到控件,否则返回 TRUE
 
- }
 
- void CIntervalToSendDlg::OnSysCommand(UINT nID, LPARAM lParam)
 
- {
 
- 	if ((nID & 0xFFF0) == IDM_ABOUTBOX)
 
- 	{
 
- 		CAboutDlg dlgAbout;
 
- 		dlgAbout.DoModal();
 
- 	}
 
- 	else
 
- 	{
 
- 		CDialogEx::OnSysCommand(nID, lParam);
 
- 	}
 
- }
 
- // 如果向对话框添加最小化按钮,则需要下面的代码
 
- //  来绘制该图标。  对于使用文档/视图模型的 MFC 应用程序,
 
- //  这将由框架自动完成。
 
- void CIntervalToSendDlg::OnPaint()
 
- {
 
- 	if (IsIconic())
 
- 	{
 
- 		CPaintDC dc(this); // 用于绘制的设备上下文
 
- 		SendMessage(WM_ICONERASEBKGND, reinterpret_cast<WPARAM>(dc.GetSafeHdc()), 0);
 
- 		// 使图标在工作区矩形中居中
 
- 		int cxIcon = GetSystemMetrics(SM_CXICON);
 
- 		int cyIcon = GetSystemMetrics(SM_CYICON);
 
- 		CRect rect;
 
- 		GetClientRect(&rect);
 
- 		int x = (rect.Width() - cxIcon + 1) / 2;
 
- 		int y = (rect.Height() - cyIcon + 1) / 2;
 
- 		// 绘制图标
 
- 		dc.DrawIcon(x, y, m_hIcon);
 
- 	}
 
- 	else
 
- 	{
 
- 		CDialogEx::OnPaint();
 
- 	}
 
- }
 
- //当用户拖动最小化窗口时系统调用此函数取得光标
 
- //显示。
 
- HCURSOR CIntervalToSendDlg::OnQueryDragIcon()
 
- {
 
- 	return static_cast<HCURSOR>(m_hIcon);
 
- }
 
- void CIntervalToSendDlg::OnBnClickedBtnStart()
 
- {
 
- 	UpdateData(TRUE);
 
- 	if (m_data.IsEmpty())
 
- 	{
 
- 		MessageBox("数据不能为空", "提示", MB_ICONWARNING);
 
- 		return;
 
- 	}
 
- 	if (m_thread)
 
- 	{
 
- 		m_bwork = false;
 
- 		m_thread->join();
 
- 		delete m_thread;
 
- 		m_thread = nullptr;
 
- 		GetDlgItem(IDC_BTN_START)->SetWindowText("开始");
 
- 		GetDlgItem(IDC_BTN_IMPORT)->EnableWindow(TRUE);
 
- 		GetDlgItem(IDC_BTN_CLEAR)->EnableWindow(TRUE);
 
- 		GetDlgItem(IDC_EDT_DATA)->EnableWindow(TRUE);
 
- 	}
 
- 	else
 
- 	{
 
- 		AfxMessageBox("解析需要一点时间, 请多一点点耐心等待结束...");
 
- 		auto lst = new list<SEND_DATA>;
 
- 		if (m_bHex)
 
- 		{
 
- 			if (checkData() == false) return;
 
- 			BYTE* pData = new BYTE[m_data.GetLength() / 2];
 
- 			int nPos = 0;
 
- 			int nLen = m_data.GetLength();
 
- 			char* p = m_data.GetBuffer();
 
- 			for (int i = 0; i < nLen - 1; i += 2)
 
- 			{
 
- 				char a[3] = { m_data.GetAt(i), m_data.GetAt(i + 1), 0 };
 
- 				pData[nPos++] = strtol(a, NULL, 16);
 
- 			}
 
- 			CLNBuffer buffer;
 
- 			buffer.AddData(pData, nPos);
 
- 			while (true)
 
- 			{
 
- 				int nPackLen = buffer.HasPack();
 
- 				if (nPackLen == 0)
 
- 					break;
 
- 				SEND_DATA data;
 
- 				data.pData = new uint8_t[nPackLen];
 
- 				memcpy(data.pData, buffer.GetBuffer(), nPackLen);
 
- 				buffer.Remove(nPackLen);
 
- 				data.nLen = nPackLen;
 
- 				lst->push_back(data);
 
- 			}
 
- 			buffer.Empty();
 
- 			delete[] pData;
 
- 			pData = NULL;
 
- 		}
 
- 		else
 
- 		{
 
- 			CLNBuffer buffer;
 
- 			buffer.AddData((LPBYTE)(LPCSTR)m_data, m_data.GetLength());
 
- 			while (true)
 
- 			{
 
- 				int nPackLen = buffer.HasPack();
 
- 				if (nPackLen == 0)
 
- 					break;
 
- 				SEND_DATA data;
 
- 				data.pData = new uint8_t[nPackLen];
 
- 				memcpy(data.pData, buffer.GetBuffer(), nPackLen);
 
- 				buffer.Remove(nPackLen);
 
- 				data.nLen = nPackLen;
 
- 				lst->push_back(data);
 
- 			}
 
- 		}
 
- 		if (lst->size() == 0)
 
- 		{
 
- 			MessageBox("未解析到数据包", "提示", MB_ICONWARNING);
 
- 			delete lst;
 
- 			return;
 
- 		}
 
- 		CString strLog;
 
- 		strLog.Format("解析完毕,一共解析 %d 道下载命令.开始发送.", lst->size());
 
- 		AfxMessageBox(strLog);
 
- 		m_bwork = true;
 
- 		m_thread = new std::thread(ThreadProc, (DWORD_PTR)this, (DWORD_PTR)lst, (DWORD_PTR)0);
 
- 		GetDlgItem(IDC_BTN_START)->SetWindowText("停止");
 
- 		GetDlgItem(IDC_BTN_IMPORT)->EnableWindow(FALSE);
 
- 		GetDlgItem(IDC_BTN_CLEAR)->EnableWindow(FALSE);
 
- 		GetDlgItem(IDC_EDT_DATA)->EnableWindow(FALSE);
 
- 	}
 
- }
 
- void CIntervalToSendDlg::OnBnClickedBtnClear()
 
- {
 
- 	m_data.Empty();
 
- 	UpdateData(FALSE);
 
- }
 
- void CIntervalToSendDlg::OnBnClickedBtnImport()
 
- {
 
- 	CString strFilter = _T("文件(*.txt)|*.txt||");
 
- 	CFileDialog dlg(TRUE, _T(".txt"), NULL, NULL, strFilter);
 
- 	if (dlg.DoModal() == IDOK)
 
- 	{
 
- 		CString strOpenFile = dlg.GetPathName();
 
- 		AfxMessageBox("解析需要一点时间, 请多一点点耐心等待结束...");
 
- 		auto lst = new list<SEND_DATA>;
 
- 		auto mapData = new map<time_t, list<SEND_DATA>>;
 
- 		CFile file;
 
- 		if (file.Open(strOpenFile, CFile::modeRead) == FALSE) return ;
 
- 		int len = file.GetLength();
 
- 		auto file_data = new uint8_t[len];
 
- 		int l = file.Read(file_data, len);
 
- 		file.Close();
 
- 		CLNBuffer buffer;
 
- 		buffer.AddData(file_data, len);
 
- 		while (true)
 
- 		{
 
- 			int nPackLen = buffer.HasPack();
 
- 			if (nPackLen == 0)
 
- 				break;
 
- 			SEND_DATA data;
 
- 			data.pData = new uint8_t[nPackLen];
 
- 			memcpy(data.pData, buffer.GetBuffer(), nPackLen);
 
- 			buffer.Remove(nPackLen);
 
- 			data.nLen = nPackLen;
 
- 			auto doc = yyjson_read((char*)data.pData, data.nLen, 0);
 
- 			if (doc)
 
- 			{
 
- 				auto root = yyjson_doc_get_root(doc);
 
- 				if (yyjson_is_obj(root) && yyjson_obj_get(root, "IMEI"))
 
- 				{
 
- 					lst->emplace_back(data);
 
- 					auto t = yyjson_get_str(yyjson_obj_get(root, "time"));
 
- 					if (t)
 
- 					{
 
- 						int year, month, day, hour, minute, second;
 
- 						TRACE("%s\r\n", t);
 
- 						auto n = sscanf_s(t, "%d-%d-%d %d:%d:%d", &year, &month, &day, &hour, &minute, &second);
 
- 						if (n == 6)
 
- 						{
 
- 							(*mapData)[hour * 3600 + minute * 60 + second].emplace_back(data);
 
- 						}
 
- 						else
 
- 						{
 
- 							int ii = 0;
 
- 						}
 
- 					}
 
- 				}
 
- 				else
 
- 				{
 
- 					delete[] data.pData;
 
- 				}
 
- 				yyjson_doc_free(doc);
 
- 			}
 
- 			else
 
- 			{
 
- 				delete[] data.pData;
 
- 			}
 
- 		}
 
- 		if (lst->size() == 0)
 
- 		{
 
- 			MessageBox("未解析到数据包", "提示", MB_ICONWARNING);
 
- 			delete lst;
 
- 			return;
 
- 		}
 
- 		CString strLog;
 
- 		strLog.Format("解析完毕,一共解析 %d 道下载命令.开始发送.", lst->size());
 
- 		AfxMessageBox(strLog);
 
- 		delete[] file_data;
 
- 		file_data = nullptr;
 
- 		UpdateData(TRUE);
 
- 		//m_cmbType.SetCurSel((int)eSendType::ST_ONE_100MILLI);
 
- 		WritePrivateProfileString("INFO", "sendtype", std::to_string(m_cmbType.GetCurSel()).c_str(), "IntervalToSend.ini");
 
- 		m_bwork = true;
 
- 		m_thread = new std::thread(ThreadProc, (DWORD_PTR)this, (DWORD_PTR)lst, (DWORD_PTR)mapData);
 
- 		GetDlgItem(IDC_BTN_START)->SetWindowText("停止");
 
- 		GetDlgItem(IDC_BTN_IMPORT)->EnableWindow(FALSE);
 
- 		GetDlgItem(IDC_BTN_CLEAR)->EnableWindow(FALSE);
 
- 		GetDlgItem(IDC_EDT_DATA)->EnableWindow(FALSE);
 
- 	}
 
- }
 
- HRESULT CIntervalToSendDlg::OnThreadStop(WPARAM w, LPARAM l)
 
- {
 
- 	if (m_thread)
 
- 	{
 
- 		m_thread->join();
 
- 		delete m_thread;
 
- 	}
 
- 	m_thread = nullptr;
 
- 	m_bwork = false;
 
- 	GetDlgItem(IDC_BTN_START)->SetWindowText("开始");
 
- 	GetDlgItem(IDC_BTN_IMPORT)->EnableWindow(TRUE);
 
- 	GetDlgItem(IDC_BTN_CLEAR)->EnableWindow(TRUE);
 
- 	GetDlgItem(IDC_EDT_DATA)->EnableWindow(TRUE);
 
- 	MessageBox("发送结束", "提示", MB_ICONINFORMATION);
 
- 	return 0;
 
- }
 
- HRESULT CIntervalToSendDlg::OnUpdateData(WPARAM w, LPARAM l)
 
- {
 
- 	time_t tmNow = (time_t)w;
 
- 	if (w < m_tmLast) return 0;
 
- 	UpdateData(FALSE);
 
- 	return 0;
 
- }
 
- void CIntervalToSendDlg::ThreadProc(DWORD_PTR pThis, DWORD_PTR data, DWORD_PTR m)
 
- {
 
- 	CIntervalToSendDlg* pDlg = (CIntervalToSendDlg*)pThis;
 
- 	auto lst = (list<SEND_DATA>*)data;
 
- 	auto mapData = (map<time_t, list<SEND_DATA>>*)m;
 
- 	time_t lastSend = 0;
 
- 	eSendType type = (eSendType)pDlg->m_cmbType.GetCurSel();
 
- 	auto it = lst->cbegin();
 
- 	g_udpSocket.SendTo(pDlg->m_strInfo, pDlg->m_strInfo.GetLength(), pDlg->m_port, pDlg->m_ip);
 
- 	int nSleepTime = 100;
 
- 	do
 
- 	{
 
- 		Sleep(nSleepTime);
 
- 		time_t tmNow;
 
- 		time(&tmNow);
 
- 		pDlg->PostMessage(WM_THREAD_UPDATE_DATA, (DWORD_PTR)tmNow, 0);
 
- 		if (type == eSendType::ST_ONE_100MILLI)
 
- 		{
 
- 			if (nSleepTime != 100)  nSleepTime = 100;
 
- 			if (it == lst->cend()) break;
 
- 			auto doc = yyjson_read((char*)it->pData, it->nLen, 0);
 
- 			do
 
- 			{
 
- 				auto d_doc = yyjson_doc_mut_copy(doc, 0);
 
- 				auto root = yyjson_mut_doc_get_root(d_doc);
 
- 				if (yyjson_mut_is_obj(root))
 
- 				{
 
- 					//yyjson_mut_obj_remove_str(root, "time");
 
- 					//yyjson_mut_obj_add_strcpy(d_doc, root, "time", dt.Format("%Y-%m-%d %H:%M:%S"));
 
- 					yyjson_mut_obj_add_int(d_doc, root, "make_up", 1); //补传标记
 
- 				}
 
- 				size_t len = 0;
 
- 				auto json = yyjson_mut_write(d_doc, 0, &len);
 
- 				if (json)
 
- 				{
 
- 					g_udpSocket.SendTo(json, len, pDlg->m_port, pDlg->m_ip);
 
- 					lastSend = tmNow;
 
- 					++it;
 
- 					free((void*)json);
 
- 				}
 
- 				yyjson_mut_doc_free(d_doc);
 
- 			} while (false);
 
- 			yyjson_doc_free(doc);
 
- 		}
 
- 		else if (type == eSendType::ST_ONE_10MILLI)
 
- 		{
 
- 			if (nSleepTime != 10)  nSleepTime = 10;
 
- 			if (it == lst->cend()) break;
 
- 			auto doc = yyjson_read((char*)it->pData, it->nLen, 0);
 
- 			do
 
- 			{
 
- 				auto d_doc = yyjson_doc_mut_copy(doc, 0);
 
- 				auto root = yyjson_mut_doc_get_root(d_doc);
 
- 				if (yyjson_mut_is_obj(root))
 
- 				{
 
- 					//yyjson_mut_obj_remove_str(root, "time");
 
- 					//yyjson_mut_obj_add_strcpy(d_doc, root, "time", dt.Format("%Y-%m-%d %H:%M:%S"));
 
- 					yyjson_mut_obj_add_int(d_doc, root, "make_up", 1); //补传标记
 
- 				}
 
- 				size_t len = 0;
 
- 				auto json = yyjson_mut_write(d_doc, 0, &len);
 
- 				if (json)
 
- 				{
 
- 					g_udpSocket.SendTo(json, len, pDlg->m_port, pDlg->m_ip);
 
- 					lastSend = tmNow;
 
- 					++it;
 
- 					free((void*)json);
 
- 				}
 
- 				yyjson_mut_doc_free(d_doc);
 
- 			} while (false);
 
- 		}
 
- 		else if (type == eSendType::ST_ONE_SECOND)
 
- 		{
 
- 			if (nSleepTime != 100)  nSleepTime = 100;
 
- 			if (tmNow > lastSend)
 
- 			{
 
- 				if (pDlg->m_bCycle) //循环发送
 
- 				{
 
- 					if (it == lst->cend()) it = lst->cbegin();
 
- 				}
 
- 				else
 
- 				{
 
- 					if (it == lst->cend()) break;
 
- 				}
 
- 				if (pDlg->m_bModify) //修正时间
 
- 				{
 
- 					auto doc = yyjson_read((char*)it->pData, it->nLen, 0);
 
- 					do 
 
- 					{
 
- 						COleDateTime dt(tmNow);
 
- 						auto d_doc = yyjson_doc_mut_copy(doc, 0);
 
- 						auto root = yyjson_mut_doc_get_root(d_doc);
 
- 						if (yyjson_mut_is_obj(root))
 
- 						{
 
- 							yyjson_mut_obj_remove_str(root, "time");
 
- 							yyjson_mut_obj_add_strcpy(d_doc, root, "time", dt.Format("%Y-%m-%d %H:%M:%S"));
 
- 						}
 
- 						size_t len = 0;
 
- 						auto json = yyjson_mut_write(d_doc, 0, &len);
 
- 						if (json)
 
- 						{
 
- 							g_udpSocket.SendTo(json, len, pDlg->m_port, pDlg->m_ip);
 
- 							lastSend = tmNow;
 
- 							++it;
 
- 							free((void*)json);
 
- 						}
 
- 						yyjson_mut_doc_free(d_doc);
 
- 					} while (false);
 
- 					yyjson_doc_free(doc);
 
- 				}
 
- 				else
 
- 				{
 
- 					g_udpSocket.SendTo(it->pData, it->nLen, pDlg->m_port, pDlg->m_ip);
 
- 					lastSend = tmNow;
 
- 					++it;
 
- 				}
 
- 			}
 
- 		}
 
- 		else if (type == eSendType::ST_TEN_SECOND)
 
- 		{
 
- 			if (nSleepTime != 100)  nSleepTime = 100;
 
- 			if (tmNow > lastSend && (tmNow - lastSend) % 10 == 0)
 
- 			{
 
- 				if (pDlg->m_bCycle) //循环发送
 
- 				{
 
- 					if (it == lst->cend()) it = lst->cbegin();
 
- 				}
 
- 				else
 
- 				{
 
- 					if (it == lst->cend()) break;
 
- 				}
 
- 				if (pDlg->m_bModify) //修正时间
 
- 				{
 
- 					auto doc = yyjson_read((char*)it->pData, it->nLen, 0);
 
- 					do
 
- 					{
 
- 						COleDateTime dt(tmNow);
 
- 						auto d_doc = yyjson_doc_mut_copy(doc, 0);
 
- 						auto root = yyjson_mut_doc_get_root(d_doc);
 
- 						if (yyjson_mut_is_obj(root))
 
- 						{
 
- 							yyjson_mut_obj_remove_str(root, "time");
 
- 							yyjson_mut_obj_add_strcpy(d_doc, root, "time", dt.Format("%Y-%m-%d %H:%M:%S"));
 
- 						}
 
- 						size_t len = 0;
 
- 						auto json = yyjson_mut_write(d_doc, 0, &len);
 
- 						if (json)
 
- 						{
 
- 							g_udpSocket.SendTo(json, len, pDlg->m_port, pDlg->m_ip);
 
- 							lastSend = tmNow;
 
- 							++it;
 
- 							free((void*)json);
 
- 						}
 
- 						yyjson_mut_doc_free(d_doc);
 
- 					} while (false);
 
- 					yyjson_doc_free(doc);
 
- 				}
 
- 				else
 
- 				{
 
- 					g_udpSocket.SendTo(it->pData, it->nLen, pDlg->m_port, pDlg->m_ip);
 
- 					lastSend = tmNow;
 
- 					++it;
 
- 				}
 
- 			}
 
- 		}
 
- 		else if (type == eSendType::ST_ONE_MINITUE)
 
- 		{
 
- 			if (nSleepTime != 100)  nSleepTime = 100;
 
- 			if (tmNow != lastSend && (tmNow - lastSend) % 60 == 0)
 
- 			{
 
- 				if (pDlg->m_bCycle) //循环发送
 
- 				{
 
- 					if (it == lst->cend()) it = lst->cbegin();
 
- 				}
 
- 				else
 
- 				{
 
- 					if (it == lst->cend()) break;
 
- 				}
 
- 				if (pDlg->m_bModify) //修正时间
 
- 				{
 
- 					auto doc = yyjson_read((char*)it->pData, it->nLen, 0);
 
- 					do
 
- 					{
 
- 						COleDateTime dt(tmNow);
 
- 						auto d_doc = yyjson_doc_mut_copy(doc, 0);
 
- 						auto root = yyjson_mut_doc_get_root(d_doc);
 
- 						if (yyjson_mut_is_obj(root))
 
- 						{
 
- 							yyjson_mut_obj_remove_str(root, "time");
 
- 							yyjson_mut_obj_add_strcpy(d_doc, root, "time", dt.Format("%Y-%m-%d %H:%M:%S"));
 
- 						}
 
- 						size_t len = 0;
 
- 						auto json = yyjson_mut_write(d_doc, 0, &len);
 
- 						if (json)
 
- 						{
 
- 							g_udpSocket.SendTo(json, len, pDlg->m_port, pDlg->m_ip);
 
- 							lastSend = tmNow;
 
- 							++it;
 
- 							free((void*)json);
 
- 						}
 
- 						yyjson_mut_doc_free(d_doc);
 
- 					} while (false);
 
- 					yyjson_doc_free(doc);
 
- 				}
 
- 				else
 
- 				{
 
- 					g_udpSocket.SendTo(it->pData, it->nLen, pDlg->m_port, pDlg->m_ip);
 
- 					lastSend = tmNow;
 
- 					++it;
 
- 				}
 
- 			}
 
- 		}
 
- 		else if (type == eSendType::ST_ACTUAL)
 
- 		{
 
- 			if (nSleepTime != 100)  nSleepTime = 100;
 
- 			if (mapData == nullptr) break;
 
- 			if (tmNow > lastSend)
 
- 			{
 
- 				COleDateTime dt(tmNow);
 
- 				auto tt = dt.GetHour() * 3600 + dt.GetMinute() * 60 + dt.GetSecond();
 
- 				TRACE("%d:%d:%d %d\t\r", dt.GetHour(), dt.GetMinute(), dt.GetSecond(), tt);
 
- 				auto ik = mapData->find(tt);
 
- 				if (ik == mapData->end())
 
- 				{
 
- 					lastSend = tmNow;
 
- 					continue;
 
- 				}
 
- 				for (auto& im : ik->second)
 
- 				{
 
- 					auto doc = yyjson_read((char*)im.pData, im.nLen, 0);
 
- 					do
 
- 					{
 
- 						auto d_doc = yyjson_doc_mut_copy(doc, 0);
 
- 						auto root = yyjson_mut_doc_get_root(d_doc);
 
- 						if (yyjson_mut_is_obj(root))
 
- 						{
 
- 							yyjson_mut_obj_remove_str(root, "time");
 
- 							yyjson_mut_obj_add_strcpy(d_doc, root, "time", dt.Format("%Y-%m-%d %H:%M:%S"));
 
- 						}
 
- 						size_t len = 0;
 
- 						auto json = yyjson_mut_write(d_doc, 0, &len);
 
- 						if (json)
 
- 						{
 
- 							g_udpSocket.SendTo(json, len, pDlg->m_port, pDlg->m_ip);
 
- 							TRACE("%s %d:%d:%d", pDlg->m_ip, dt.GetHour(), dt.GetMinute(), dt.GetSecond());
 
- 							free((void*)json);
 
- 						}
 
- 						yyjson_mut_doc_free(d_doc);
 
- 					} while (false);
 
- 					yyjson_doc_free(doc);
 
- 				}
 
- 				lastSend = tmNow;
 
- 			}
 
- 			else if (lastSend > tmNow)
 
- 				lastSend = tmNow - 1; //系统修改了时间
 
- 		}
 
- 	} while (pDlg->m_bwork);
 
- 	for (auto it = lst->begin(); it != lst->end(); it++)
 
- 	{
 
- 		delete it->pData;
 
- 	}
 
- 	lst->clear();
 
- 	pDlg->PostMessage(WM_THREAD_STOP, 0, 0);
 
- }
 
- bool CIntervalToSendDlg::checkData()
 
- {
 
- 	UpdateData(TRUE);
 
- 	if (m_data.GetLength() > 50000)
 
- 	{
 
- 		MessageBox("长度请勿超过5W");
 
- 		m_data = CString();
 
- 		UpdateData(FALSE);
 
- 		return false;
 
- 	}
 
- 	static BYTE data[50000] = { 0 };
 
- 	int nLen = 0;
 
- 	int nDataLen = m_data.GetLength();
 
- 	for (int i = 0; i < nDataLen; i++)
 
- 	{
 
- 		char c = ((LPCSTR)m_data)[i];
 
- 		if (c == ' ')
 
- 		{
 
- 		}
 
- 		else if (c == 0x0d)
 
- 		{
 
- 		}
 
- 		else if (c == 0x0a)
 
- 		{
 
- 		}
 
- 		else if (!(((c >= '0') && (c <= '9')) || ((c >= 'a') && (c <= 'f')) || ((c >= 'A') && (c <= 'F'))))
 
- 		{
 
- 			MessageBox("请输入HEX数据");
 
- 			m_data = CString();
 
- 			UpdateData(FALSE);
 
- 			return false;
 
- 		}
 
- 		else
 
- 		{
 
- 			data[nLen++] = c;
 
- 		}
 
- 	}
 
- 	ASSERT(nLen % 2 == 0);
 
- 	if (nLen % 2 == 1)
 
- 		nLen--;
 
- 	m_data = CString((char*)data, nLen);
 
- 	UpdateData(FALSE);
 
- 	return true;
 
- }
 
 
  |