// CBuyDlg.cpp: 实现文件
|
//
|
|
#include "common/pch.h"
|
#include "FloatTrade.h"
|
#include "DealQueueDlg.h"
|
#include "afxdialogex.h"
|
#include "../common/StringUtil.h"
|
#include "../common/NetworkApi.h"
|
#include "../common/JsonUtil.h"
|
#include <regex>
|
#include <thread>
|
#include <afxwin.h>
|
#include <windows.h>
|
using namespace std;
|
|
|
// CBuyDlg 对话框
|
|
IMPLEMENT_DYNAMIC(DealQueueDlg, CDialogEx)
|
|
void DealQueueDlg::AddRoundRect(Gdiplus::GraphicsPath& path, Gdiplus::REAL x, Gdiplus::REAL y, Gdiplus::REAL width, Gdiplus::REAL height, Gdiplus::REAL radius)
|
{
|
path.AddArc(x + width - 2 * radius, y, 2 * radius, 2 * radius, 270, 90);
|
path.AddArc(x + width - 2 * radius, y + height - 2 * radius, 2 * radius, 2 * radius, 0, 90);
|
path.AddArc(x, y + height - 2 * radius, 2 * radius, 2 * radius, 90, 90);
|
path.AddArc(x, y, 2 * radius, 2 * radius, 180, 90);
|
path.AddLine(x + radius, y, x + width - radius, y);
|
//path.AddArc(x + radius, y + radius, 2 * radius, 2 * radius, 90, -180);
|
//path.AddArc(x + width - radius, y + radius, 2 * radius, 2 * radius, 90, 180);
|
//path.AddLine(x + radius, y, x + width - radius, y);
|
//path.AddLine(x + radius, y+2*radius, x + width - radius, y + 2 * radius);
|
|
|
}
|
|
DealQueueDlg::DealQueueDlg(CWnd* pParent /*=nullptr*/)
|
: CDialogEx(IDD_DIALOG_DEAL_QUEUE, pParent), m_Pen(Color::MakeARGB(255, 200, 200, 200), 1.0f)
|
{
|
Gdiplus::GdiplusStartupInput startupInput;
|
ULONG_PTR token;
|
Gdiplus::GdiplusStartup(&token, &startupInput, NULL);
|
m_pGraphics = nullptr;
|
m_CornerRadius = -1; // 调整圆角半径
|
}
|
|
DealQueueDlg::~DealQueueDlg()
|
{
|
}
|
|
void DealQueueDlg::setTargetCode(string code)
|
{
|
this->code = code;
|
SetWindowTextW(CString(code.c_str()));
|
if (!code.empty()) {
|
auto t1 = std::thread(requestDealQueue, this);
|
t1.detach();
|
}
|
}
|
|
void DealQueueDlg::startRequestDealQueueTask(DealQueueDlg* context)
|
{
|
|
|
while (TRUE) {
|
try {
|
string code = context->code;
|
if (!code.empty()) {
|
if (context->windowClosed) {
|
break;
|
}
|
requestDealQueue(context);
|
}
|
}
|
|
catch (...) {
|
}
|
Sleep(1000);
|
}
|
}
|
|
void DealQueueDlg::requestDealQueue(DealQueueDlg* context)
|
{
|
std::lock_guard<std::mutex> lock(context->mtx);
|
string result = NetworkApi::get_code_deal_queue(context->code, context->minMoney);
|
auto doc = JsonUtil::parseUTF8(result);
|
list<DealQueueInfo> mLsit;
|
if (doc.IsObject()) {
|
if (doc["code"] == 0) {
|
auto data = doc["data"].GetObjectW();
|
auto deal_list = data["deal_list"].GetArray();
|
for (int i = 0; i < deal_list.Size(); i++) {
|
auto array = deal_list[i].GetArray();
|
DealQueueInfo info;
|
info.type = array[0].GetInt();
|
info.orderNo = array[1].GetInt();
|
info.time_str = array[2].GetString();
|
info.volume = array[3].GetInt();
|
info.money = array[4].GetInt();
|
info.price = array[5].GetString();
|
info.percent = array[6].GetInt();
|
mLsit.push_back(info);
|
}
|
if (data.HasMember("dealing")) {
|
auto dealing = data["dealing"].GetArray();
|
DealQueueInfo info;
|
info.type = dealing[0].GetInt();
|
info.orderNo = dealing[1].GetInt();
|
info.time_str = dealing[2].GetString();
|
info.volume = dealing[3].GetInt();
|
info.money = dealing[4].GetInt();
|
info.price = StringUtil::to_string(dealing[5].GetFloat());
|
info.percent = dealing[6].GetInt();
|
mLsit.push_back(info);
|
}
|
}
|
}
|
if (context->windowClosed) {
|
return;
|
}
|
|
context->listCtrl.SetRedraw(false);
|
bool needReAdd = false;
|
if (mLsit.size() != context->dealQueueList.size() || mLsit.size() == 0) {
|
needReAdd = true;
|
}
|
else if (context->dealQueueList.size() > 0 && mLsit.size() > 0 && context->dealQueueList.back().orderNo != mLsit.back().orderNo) {
|
needReAdd = true;
|
}
|
|
//填充List
|
if (needReAdd) {
|
// 删除原来的数据，然后新增
|
context->listCtrl.DeleteAllItems();
|
int index = 0;
|
for (list<DealQueueInfo>::iterator it = mLsit.begin(); it != mLsit.end(); ++it) {
|
DealQueueInfo info = *it;
|
context->listCtrl.InsertItem(index, L"");
|
context->listCtrl.SetItemText(index, 0, CString(info.time_str.c_str()));
|
context->listCtrl.SetItemText(index, 1, CString(info.price.c_str()));
|
CString money = CString(StringUtil::to_string(info.money / 10000.0f).c_str());
|
money.Append(L"万");
|
context->listCtrl.SetItemText(index, 2, money);
|
CString percent = to_wstring(info.percent).c_str();
|
percent.Append(L"%");
|
context->listCtrl.SetItemText(index, 3, percent);
|
context->listCtrl.SetItemText(index, 4, info.type == 0 ? L"买" : L"卖");
|
index++;
|
}
|
}
|
else {
|
//修改最后一行的数据
|
int index = mLsit.size() - 1;
|
DealQueueInfo oldInfo = context->dealQueueList.back();
|
DealQueueInfo info = mLsit.back();
|
if (oldInfo.percent != info.percent) {
|
context->listCtrl.SetItemText(index, 0, CString(info.time_str.c_str()));
|
context->listCtrl.SetItemText(index, 1, CString(info.price.c_str()));
|
CString money = CString(StringUtil::to_string(info.money / 10000.0f).c_str());
|
money.Append(L"万");
|
context->listCtrl.SetItemText(index, 2, money);
|
CString percent = to_wstring(info.percent).c_str();
|
percent.Append(L"%");
|
context->listCtrl.SetItemText(index, 3, percent);
|
context->listCtrl.SetItemText(index, 4, info.type == 0 ? L"买" : L"卖");
|
}
|
}
|
context->listCtrl.SetRedraw(true);
|
context->dealQueueList = mLsit;
|
}
|
|
void DealQueueDlg::DoDataExchange(CDataExchange* pDX)
|
{
|
|
CDialogEx::DoDataExchange(pDX);
|
DDX_Control(pDX, IDC_LIST_DEAL_QUEUE, listCtrl);
|
DDX_Control(pDX, IDC_EDIT_MIN_MONEY, editMinMoney);
|
}
|
|
BOOL DealQueueDlg::OnInitDialog()
|
{
|
CDialogEx::OnInitDialog();
|
InitializeGDIPlus();
|
minMoney = 50;
|
editMinMoney.SetWindowTextW(to_wstring(minMoney).c_str());
|
listCtrl.InsertColumn(0, _T("时间"), LVCFMT_LEFT, 65, 0);
|
listCtrl.InsertColumn(1, _T("价格"), LVCFMT_LEFT, 50, 1);
|
listCtrl.InsertColumn(2, _T("金额"), LVCFMT_LEFT, 65, 2);
|
listCtrl.InsertColumn(3, _T("手数"), LVCFMT_LEFT, 65, 3);
|
listCtrl.InsertColumn(4, _T("类型"), LVCFMT_LEFT, 40, 4);
|
windowClosed = false;
|
setTargetCode("");
|
auto t1 = std::thread(startRequestDealQueueTask, this);
|
t1.detach();
|
return TRUE;
|
}
|
|
|
BEGIN_MESSAGE_MAP(DealQueueDlg, CDialogEx)
|
|
ON_NOTIFY(LVN_ITEMCHANGED, IDC_LIST_DEAL_QUEUE, &DealQueueDlg::OnItemchangedListDealQueue)
|
ON_WM_CLOSE()
|
ON_NOTIFY(NM_CUSTOMDRAW, IDC_LIST_DEAL_QUEUE, &DealQueueDlg::OnCustomdrawListDealQueue)
|
ON_EN_CHANGE(IDC_EDIT_MIN_MONEY, &DealQueueDlg::OnChangeEditMinMoney)
|
END_MESSAGE_MAP()
|
|
|
// 设置滚动条始终在底部
|
void DealQueueDlg::OnItemchangedListDealQueue(NMHDR* pNMHDR, LRESULT* pResult)
|
{
|
LPNMLISTVIEW pNMLV = reinterpret_cast<LPNMLISTVIEW>(pNMHDR);
|
// 检查是否有新的项被添加
|
//if (pNMLV->uNewState != 0 && (pNMLV->uNewState & LVIS_FOCUSED) == 0)
|
{
|
// 获取当前列表的项数
|
int nItemCount = listCtrl.GetItemCount();
|
|
// 滚动到最后一项
|
if (nItemCount > 0)
|
{
|
listCtrl.EnsureVisible(nItemCount - 1, FALSE);
|
}
|
}
|
*pResult = 0;
|
}
|
|
|
void DealQueueDlg::OnClose()
|
{
|
windowClosed = TRUE;
|
CDialogEx::OnClose();
|
}
|
|
|
void DealQueueDlg::OnCustomdrawListDealQueue(NMHDR* pNMHDR, LRESULT* pResult)
|
{
|
LPNMLVCUSTOMDRAW pNMCD = reinterpret_cast<LPNMLVCUSTOMDRAW>(pNMHDR);
|
|
switch (pNMCD->nmcd.dwDrawStage)
|
{
|
case CDDS_PREPAINT:
|
*pResult = CDRF_NOTIFYITEMDRAW;
|
return;
|
|
case CDDS_ITEMPREPAINT:
|
*pResult = CDRF_NOTIFYSUBITEMDRAW;
|
return;
|
|
case CDDS_SUBITEM | CDDS_ITEMPREPAINT:
|
if (pNMCD->iSubItem == 3) // 假设进度条在第2列（索引为1）
|
{
|
CDC* pDC = CDC::FromHandle(pNMCD->nmcd.hdc);
|
CRect rect;
|
listCtrl.GetSubItemRect(pNMCD->nmcd.dwItemSpec, pNMCD->iSubItem, LVIR_BOUNDS, rect);
|
|
int padding = 1;
|
int height = rect.Height() - padding * 2;
|
if (height % 2 != 0) {
|
height -= 1;
|
}
|
|
if (m_CornerRadius < 0) {
|
m_CornerRadius = height / 2;
|
}
|
|
|
int index = pNMCD->nmcd.dwItemSpec;
|
list<DealQueueInfo>::iterator e = dealQueueList.begin();
|
advance(e, index);
|
// 获取进度值
|
int nProgress = (*e).percent;
|
|
// 计算进度条的宽度
|
int nWidth = rect.Width();
|
int nProgressWidth = nWidth * nProgress / 100;
|
|
Graphics* pGraphics = Gdiplus::Graphics::FromHDC(pDC->GetSafeHdc());
|
pGraphics->SetSmoothingMode(SmoothingModeAntiAlias);
|
pGraphics->SetTextRenderingHint(TextRenderingHintAntiAlias);
|
|
m_Pen.SetColor(0xFF2A1D);
|
// 绘制背景
|
GraphicsPath path;
|
AddRoundRect(path,
|
(Gdiplus::REAL)rect.left,
|
(Gdiplus::REAL)rect.top + padding,
|
(Gdiplus::REAL)rect.Width(),
|
(Gdiplus::REAL)height,
|
m_CornerRadius
|
);
|
pGraphics->FillPath(m_BackBrush, &path);
|
pGraphics->DrawPath(&m_Pen, &path);
|
|
GraphicsPath progressPath;
|
AddRoundRect(progressPath,
|
(Gdiplus::REAL)rect.left,
|
(Gdiplus::REAL)rect.top + padding,
|
(Gdiplus::REAL)nProgressWidth,
|
(Gdiplus::REAL)height,
|
m_CornerRadius
|
);
|
pGraphics->FillPath(m_ProgressBrush, &progressPath);
|
pGraphics->DrawPath(&m_Pen, &progressPath);
|
CString st = L"";
|
st.Append(to_wstring(nProgress).c_str());
|
st.Append(L"%");
|
|
PointF point(rect.left + 5, rect.top + padding); // 调整文本位置
|
Gdiplus::Font font(L"Arial", 10);
|
SolidBrush textBrush(Color::White);
|
pGraphics->DrawString(st, -1, &font, point, &textBrush);
|
*pResult = CDRF_SKIPDEFAULT;
|
}
|
else
|
{
|
*pResult = CDRF_DODEFAULT;
|
}
|
return;
|
}
|
|
|
*pResult = CDRF_DODEFAULT;
|
}
|
|
void DealQueueDlg::InitializeGDIPlus()
|
{
|
m_pGraphics = Gdiplus::Graphics::FromHDC(nullptr);
|
m_Pen.SetColor(0xFF00FF00);
|
m_BackBrush = new Gdiplus::LinearGradientBrush(
|
PointF(0, 0),
|
PointF(0, 20),
|
0xFF000000,
|
0xFF000000
|
);
|
m_ProgressBrush = new Gdiplus::LinearGradientBrush(
|
PointF(0, 0),
|
PointF(0, 20),
|
0xFFFF2A1D,
|
0xFFFF2A1D
|
);
|
|
|
}
|
|
void DealQueueDlg::CleanupGDIPlus()
|
{
|
delete m_pGraphics;
|
}
|
|
|
BOOL DealQueueDlg::PreTranslateMessage(MSG* pMsg)
|
{
|
// 检测是否是键盘消息
|
if (pMsg->message == WM_KEYDOWN && pMsg->wParam == VK_RETURN)
|
{
|
// 处理回车键事件
|
if (CWnd::GetFocus() == GetDlgItem(IDC_EDIT_MIN_MONEY)) {
|
CString money;
|
editMinMoney.GetWindowTextW(money);
|
if (money.IsEmpty()) {
|
minMoney = 0;
|
}
|
else {
|
minMoney = stoi(StringUtil::cstring2String(money));
|
}
|
auto t1 = std::thread(requestDealQueue, this);
|
t1.detach();
|
return TRUE; // 返回 TRUE 表示已经处理了这个消息，不再传递给基类
|
}
|
}
|
|
return CDialogEx::PreTranslateMessage(pMsg);
|
}
|
|
|
void DealQueueDlg::OnChangeEditMinMoney()
|
{
|
// TODO: 如果该控件是 RICHEDIT 控件，它将不
|
// 发送此通知，除非重写 CDialogEx::OnInitDialog()
|
// 函数并调用 CRichEditCtrl().SetEventMask()，
|
// 同时将 ENM_CHANGE 标志“或”运算到掩码中。
|
|
// TODO: 在此添加控件通知处理程序代码
|
}
|
