: | : | :期货量化学习 | :期货量化 |
返回列表 发帖

鼎元C++量化程式码主模块之【.cpp文件】

Rank: 9Rank: 9Rank: 9

UID
2 
积分
2874604 
威望
1387331 布 
龙e币
1487273 刀 
在线时间
13155 小时 
注册时间
2009-12-3 
最后登录
2024-11-24 

Medal No.1
1# 跳转到 » 倒序看帖
打印
tT
龙听发表于 2024-11-2 14:32 | 只看该作者

鼎元C++量化程式码主模块之【.cpp文件】

第一部分范例：http://www.qhlt.cn/thread-159320-1-1.html；

第二部分，模块讲解：

1、公共部分，不用改动。
  1. #include "pch.h"#include "test.h"
  2. #include <vector>
  3. #include <windows.h>
  4. #include <fstream>
  5. #include <stdio.h>
  6. #include <mmsystem.h>
  7. #include <thread>
  8. #pragma comment(lib,"winmm.lib")
  9. using namespace std;
  10. extern "C" __declspec(dllexport)Interface * create(HWND hw, string sName, string sPeriod, string sInst)
  11. {
  12.         return new test(hw, sName, sPeriod, sInst);
  13. }
  14. extern "C" __declspec(dllexport)void destory(Interface * p)
  15. {
  16.         delete p;
  17. }

  19. vector<std::string> split(std::string str, std::string pattern)
  20. {
  21.         std::string::size_type pos;
  22.         std::vector<std::string> result;
  23.         str += pattern;
  24.         int size = str.size();
  25.         for (int i = 0; i < size; i++)
  26.         {
  27.                 pos = str.find(pattern, i);
  28.                 if (pos < size)
  29.                 {
  30.                         std::string s = str.substr(i, pos - i);
  31.                         result.push_back(s);
  32.                         i = pos + pattern.size() - 1;
  33.                 }
  34.         }
  35.         return result;
  36. }
  37. test::test(HWND hw, string sn, string sp, string si)
  38. {
  39.         hwnd = hw;
  40.         sName = sn;
  41.         sPeriod = sp;
  42.         sInst = si;
  43.         //  SetTimer(NULL, 0, 1000, (TIMERPROC)TimerProc);
  44. }

  46. test::~test()
  47. {
  48. }

  50. void test::OnState(string s)
  51. {
  52.         state = s;
  53.         TDLLDATA* t = new TDLLDATA();
  54.         t->sName = sName;
  55.         t->sType = "state";
  56.         t->sData = s;
  57.         if (hwnd)SendMessage(hwnd, WM_DLLDATA, (WPARAM)t, 10);
  58.         
  59. }
  60. void test::UpdateParm(string s)
  61. {
  62.         vector<std::string> v = split(s, "@");
  63.         for (int i = 0; i < v.size(); i++)
  64.         {
  65.                 string ss = v.at(i);
  66.                 vector<std::string> vv = split(ss, "_");
  67.                 if (vv.size() >= 3)
  68.                 {
  69.                         TDLLPARM t;
  70.                         t.Name = vv.at(0); t.Value = vv.at(1); t.Explain = vv.at(2); tend(t);
  71.                         parm[t.Name] = t;
  72.                 }
  73.         }
  74. }

  76. void test::UpdateSub(string sub, double ratio)
  77. {
  78.         mapSub[sub] = ratio;
  79. }

  81. void test::end()
  82. {
  83.         string s;
  84.         list<string>::iterator it;
  85.         for (it = lst.begin(); it != lst.end(); ++it)
  86.         {
  87.                 string key = *it;
  88.                 TDLLPARM t = parm[key];
  89.                 string ss = t.Name + "_" + t.Value + "_" + t.Explain;
  90.                 s = s + ss + "@";
  91.         }
  92.         TDLLDATA* t = new TDLLDATA();
  93.         t->sName = sName;
  94.         t->sType = "InitParm";
  95.         t->sData = s;
  96.         if (hwnd)SendMessage(hwnd, WM_DLLDATA, (WPARAM)t, 10);
  97. }
  98. void test::tend(TDLLPARM t)
  99. {
  100.         lst.push_back(t.Name);
  101.         parm[t.Name] = t;
  102. }

  104. void test::SubscribeMarketData(string s)
  105. {
  106.         TDLLDATA* t = new TDLLDATA();
  107.         t->sName = sName;
  108.         t->sType = "SubMd";
  109.         t->sData = s;
  110.         if (hwnd)SendMessage(hwnd, WM_SUBMD, (WPARAM)t, 11);
  111. }

  113. bool test::IsbeigenOrdrSysID(string orderid)
  114. {
  115.         list<string>::iterator it;
  116.         for (it = lstbeigenOrdrSysID.begin(); it != lstbeigenOrdrSysID.end(); it++)
  117.         {
  118.                 string temp = *it;
  119.                 if (temp == orderid)return true;
  120.         }
  121.         return false;
  122. }

  124. bool test::IsActionOrdrSysID(string orderid)
  125. {
  126.         list<string>::iterator it;
  127.         for (it = lstActionOrdrSysID.begin(); it != lstActionOrdrSysID.end(); it++)
  128.         {
  129.                 string temp = *it;
  130.                 if (temp == orderid)return true;
  131.         }
  132.         return false;
  133. }

  135. void test::OrderInsert(string acc, string inst, char bs, char  oc, int vol, double price, string forfok, string ref2)
  136. {
  137.         TORDERINSERT* t = new TORDERINSERT();
  138.         t->sName = sName;
  139.         t->InvestorID = acc;
  140.         t->InstrumentID = inst;
  141.         t->BuySell = bs;
  142.         t->OpenClose = oc;
  143.         t->Volume = vol;
  144.         t->LimitPrice = price;
  145.         t->FakFok = forfok;
  146.         t->Ref1 = sName;
  147.         t->Ref2 = ref2;
  148.         if (hwnd)SendMessage(hwnd, WM_INSERT, (WPARAM)t, 12);
  149. }

  151. void test::OrderAction(CThostFtdcOrderField t)
  152. {
  153.         TACTION* ta = new TACTION();
  154.         ta->Name = sName;
  155.         ta->InvestorID = t.InvestorID;
  156.         ta->OrderSysID = t.OrderSysID;
  157.         ta->BrokerID = t.BrokerID;
  158.         ta->ExchangeID = t.ExchangeID;
  159.         if (hwnd)SendMessage(hwnd, WM_ACTION, (WPARAM)ta, 13);
  160. }

  162. void test::RsqBar(string period, string inst)
  163. {
  164.         TRSQBAR* t = new TRSQBAR();
  165.         t->Name = sName;
  166.         t->Type = "RsqBar";
  167.         t->Period = period;
  168.         t->Inst = inst;
  169.         if (hwnd)SendMessage(hwnd, WM_RSQBAR, (WPARAM)t, (LPARAM)36);
  170. }

  172. void test::InsertLog(string msg)
  173. {
  174.         TMSG* t = new TMSG();
  175.         t->Name = sName;
  176.         t->Msg = msg;
  177.         if (hwnd)SendMessage(hwnd, WM_MSG, (WPARAM)t, 14);
  178. }

  180. void test::RsqInstrument(string inst)
  181. {
  182.         TRSQ* t = new TRSQ();
  183.         t->Name = sName;
  184.         t->Type = "RsqInstrument";
  185.         t->Inst = inst;
  186.         if (hwnd)SendMessage(hwnd, WM_RSQ, (WPARAM)t, (LPARAM)33);
  187. }

  189. void test::RsqRspQryOrder()
  190. {
  191.         TRSQ* t = new TRSQ();
  192.         t->Name = sName;
  193.         t->Type = "RspQryOrder";
  194.         if (hwnd)SendMessage(hwnd, WM_RSQ, (WPARAM)t, (LPARAM)33);
  195. }

  197. void test::RsqRspQryTrade()
  198. {
  199.         TRSQ* t = new TRSQ();
  200.         t->Name = sName;
  201.         t->Type = "RspQryTrade";
  202.         if (hwnd)SendMessage(hwnd, WM_RSQ, (WPARAM)t, (LPARAM)33);
  203. }

  205. void test::RsqPosition()
  206. {
  207.         TRSQ* t = new TRSQ();
  208.         t->Name = sName;
  209.         t->Type = "RsqPosition";
  210.         if (hwnd)SendMessage(hwnd, WM_RSQ, (WPARAM)t, (LPARAM)33);
  211. }

  213. void test::RsqPositionDetail(string acc)
  214. {
  215.         TRSQ* t = new TRSQ();
  216.         t->Name = sName;
  217.         t->Type = "RsqPositionDetail";
  218.         t->Account = acc;
  219.         if (hwnd)SendMessage(hwnd, WM_RSQ, (WPARAM)t, (LPARAM)33);
  220. }

  222. void test::RsqCommissionRate()
  223. {
  224.         TRSQ* t = new TRSQ();
  225.         t->Name = sName;
  226.         t->Type = "RsqCommissionRate";
  227.         if (hwnd)SendMessage(hwnd, WM_RSQ, (WPARAM)t, (LPARAM)33);
  228. }

  230. void test::RsqAccount()
  231. {
  232.         TRSQ* t = new TRSQ();
  233.         t->Name = sName;
  234.         t->Type = "RsqAccount";
  235.         if (hwnd)SendMessage(hwnd, WM_RSQ, (WPARAM)t, (LPARAM)33);
  236. }

  238. void test::sound(string s)
  239. {
  240.         size_t size = s.length();
  241.         wchar_t* buffer = new wchar_t[size + 1];
  242.         MultiByteToWideChar(CP_ACP, 0, s.c_str(), size, buffer, size * sizeof(wchar_t));
  243.         buffer[size] = 0;
  244.         PlaySound(buffer, NULL, SND_FILENAME | SND_ASYNC);
  245.         delete buffer;
  246.         buffer = NULL;
  247. }
复制代码

收藏 分享
论坛官方微信、群（期货热点、量化探讨、开户与绑定实盘）
 
期货论坛 - 版权/免责声明   1.本站发布源码(包括函数、指标、策略等)均属开放源码，用意在于让使用者学习程序化语法撰写，使用者可以任意修改语法內容并调整参数。仅限用于个人学习使用，请勿转载、滥用，严禁私自连接实盘账户交易。
  2.本站发布资讯(包括文章、视频、历史记录、教材、评论、资讯、交易方案等)均系转载自网络主流媒体，内容仅为作者当日个人观点，本网转载此文出于传递更多信息之目的，并不意味着赞同其观点或证实其描述。本网不对该类信息或数据做任何保证。不对您构成任何投资建议，不能依靠信息而取代自身独立判断，不对因使用本篇文章所诉信息或观点等导致的损失承担任何责任。
  3.本站发布资源(包括书籍、杂志、文档、软件等)均从互联网搜索而来，仅供个人免费交流学习，不可用作商业用途，本站不对显示的内容承担任何责任。请在下载后24小时内删除。如果喜欢，请购买正版，谢谢合作！
  4.龙听期货论坛原创文章属本网版权作品，转载须注明来源“龙听期货论坛”，违者本网将保留追究其相关法律责任的权力。本论坛除发布原创文章外，亦致力于优秀财经文章的交流分享，部分文章推送时若未能及时与原作者取得联系并涉及版权问题时，请及时联系删除。联系方式：http://www.qhlt.cn/thread-262-1-1.html
如何访问权限为100/255贴子：/thread-37840-1-1.html；注册后仍无法回复：/thread-23-1-1.html；微信/QQ群：/thread-262-1-1.html；网盘链接失效解决办法：/thread-93307-1-1.html

Rank: 9Rank: 9Rank: 9

UID
2 
积分
2874604 
威望
1387331 布 
龙e币
1487273 刀 
在线时间
13155 小时 
注册时间
2009-12-3 
最后登录
2024-11-24 

Medal No.1
2#
龙听发表于 2024-11-2 14:33 | 只看该作者
2、指标与函数部分：
  1. /******************************************************************公式(function)部分(开始)*******************************************************************/
  2. double test::avg(string period, string inst, int num)
  3. {
  4.         double d = 0;
  5.         int n = 0;
  6.         map<string, TKVALUE>::reverse_iterator it;
  7.         //  InsertLog(to_string(mapK[period][inst].size()));
  8.         for (it = mapK[period][inst].rbegin(); it != mapK[period][inst].rend(); ++it)
  9.         {
  10.                 d += it->second.dClose;
  11.                 n++;
  12.                 if (n >= num)break;
  13.         }
  14.         return d / n;
  15. }

  17. double test::highest(string period, string inst, int num)
  18. {
  19.         double d = 0;
  20.         int n = 0;
  21.         map<string, TKVALUE>::reverse_iterator it;
  22.         for (it = mapK[period][inst].rbegin(); it != mapK[period][inst].rend(); ++it)
  23.         {
  24.                 if (d < it->second.dHigh)d = it->second.dHigh;
  25.                 n++;
  26.                 if (n >= num)break;
  27.         }
  28.         return d;
  29. }

  31. double test::lowerest(string period, string inst, int num)
  32. {
  33.         double d = 0;
  34.         int n = 0;
  35.         map<string, TKVALUE>::reverse_iterator it;
  36.         for (it = mapK[period][inst].rbegin(); it != mapK[period][inst].rend(); ++it)
  37.         {
  38.                 if (d == 0)d = it->second.dLow;
  39.                 if (d > it->second.dLow)d = it->second.dLow;
  40.                 n++;
  41.                 if (n >= num)break;
  42.         }
  43.         return d;
  44. }

  46. double test::avg1(string period, string inst, int num, int ref)
  47. {
  48.         double d = 0;
  49.         int n = 0;
  50.         int r = 0;
  51.         map<string, TKVALUE>::reverse_iterator it;
  52.         //  InsertLog(to_string(mapK[period][inst].size()));
  53.         for (it = mapK[period][inst].rbegin(); it != mapK[period][inst].rend(); ++it)
  54.         {
  55.                 r++;
  56.                 if (r <= ref)continue;
  57.                 d += it->second.dClose;
  58.                 n++;
  59.                 if (n >= num)break;
  60.         }
  61.         return d / n;
  62. }

  64. double test::highest1(string period, string inst, int num, int ref)
  65. {
  66.         double d = 0;
  67.         int n = 0;
  68.         int r = 0;
  69.         map<string, TKVALUE>::reverse_iterator it;
  70.         for (it = mapK[period][inst].rbegin(); it != mapK[period][inst].rend(); ++it)
  71.         {
  72.                 r++;
  73.                 if (r <= ref)continue;
  74.                 if (d < it->second.dHigh)d = it->second.dHigh;
  75.                 n++;
  76.                 if (n >= num)break;
  77.         }
  78.         return d;
  79. }

  81. double test::lowerest1(string period, string inst, int num, int ref)
  82. {
  83.         double d = 0;
  84.         int n = 0;
  85.         int r = 0;
  86.         map<string, TKVALUE>::reverse_iterator it;
  87.         for (it = mapK[period][inst].rbegin(); it != mapK[period][inst].rend(); ++it)
  88.         {
  89.                 r++;
  90.                 if (r <= ref)continue;
  91.                 if (d == 0)d = it->second.dLow;
  92.                 if (d > it->second.dLow)d = it->second.dLow;
  93.                 n++;
  94.                 if (n >= num)break;
  95.         }
  96.         return d;
  97. }
  98. /******************************************************************公式(function)部分(结束)*******************************************************************/
复制代码
如何访问权限为100/255贴子：/thread-37840-1-1.html；注册后仍无法回复：/thread-23-1-1.html；微信/QQ群：/thread-262-1-1.html；网盘链接失效解决办法：/thread-93307-1-1.html

TOP

Rank: 9Rank: 9Rank: 9

UID
2 
积分
2874604 
威望
1387331 布 
龙e币
1487273 刀 
在线时间
13155 小时 
注册时间
2009-12-3 
最后登录
2024-11-24 

Medal No.1
3#
龙听发表于 2024-11-2 14:35 | 只看该作者
3、时间设定模块：
  1. /// <summary>
  2. /// 以下开始
  3. /// </summary>
  4. string timeStart = "08:50:00";
  5. string timePause = "15:32:00";
  6. string timeResume = "20:50:00";
  7. string timeStop = "02:32:00";
  8. string state = "stop";
复制代码
如何访问权限为100/255贴子：/thread-37840-1-1.html；注册后仍无法回复：/thread-23-1-1.html；微信/QQ群：/thread-262-1-1.html；网盘链接失效解决办法：/thread-93307-1-1.html

TOP

Rank: 9Rank: 9Rank: 9

UID
2 
积分
2874604 
威望
1387331 布 
龙e币
1487273 刀 
在线时间
13155 小时 
注册时间
2009-12-3 
最后登录
2024-11-24 

Medal No.1
4#
龙听发表于 2024-11-2 14:36 | 只看该作者
4、在程序化软件参数设定页面编辑模块：
  1. void test::InitParm()
  2. {
  3.         TDLLPARM t;
  4.         //Name 参数名, Value 默认值, Explain 参数说明, tend 表示一个参数结束
  5.         t.Name = "均线周期"; t.Value = "20"; t.Explain = "均线周期参数，默认20"; tend(t);
  6.         t.Name = "单笔风险"; t.Value = "1"; t.Explain = "交易手数，默认1手"; tend(t);
  7.         t.Name = "滑点值"; t.Value = "1"; t.Explain = "每次交易滑点值"; tend(t);
  8.         t.Name = "优先平仓"; t.Value = "0"; t.Explain = "优先平仓，1优先平今，0优先平昨"; tend(t);
  9.         t.Name = "撤单时间"; t.Value = "5"; t.Explain = "委托后多少秒检查一下是否有未成交，小于0 不撤单"; tend(t);
  10.         t.Name = "策略说明"; t.Value = "0"; t.Explain = "价格超越均线入场开多，跌破均线入场做空，收盘价反向穿越均线出场，"; tend(t);
  11.         end();
  12. }
复制代码
如何访问权限为100/255贴子：/thread-37840-1-1.html；注册后仍无法回复：/thread-23-1-1.html；微信/QQ群：/thread-262-1-1.html；网盘链接失效解决办法：/thread-93307-1-1.html

TOP

Rank: 9Rank: 9Rank: 9

UID
2 
积分
2874604 
威望
1387331 布 
龙e币
1487273 刀 
在线时间
13155 小时 
注册时间
2009-12-3 
最后登录
2024-11-24 

Medal No.1
5#
龙听发表于 2024-11-2 14:37 | 只看该作者
5、计时模块：
  1. void test::OnTimer(string ts)
  2. {
  3.         if (state != "run")return;
  4.         SYSTEMTIME m_time;
  5.         GetLocalTime(&m_time);
  6.         t1 = to_string(m_time.wHour);
  7.         t2 = to_string(m_time.wMinute);
  8.         t3 = to_string(m_time.wSecond);
  9.         t4 = to_string(m_time.wMilliseconds);
  10.         if (t3 != t0 && jg > 0)
  11.         {
  12.                 if ((tm == jg || tm == jg + 1))  chedan();
  13.                 tm++;
  14.         }
  15.         t0 = t3;
  16. }
复制代码
如何访问权限为100/255贴子：/thread-37840-1-1.html；注册后仍无法回复：/thread-23-1-1.html；微信/QQ群：/thread-262-1-1.html；网盘链接失效解决办法：/thread-93307-1-1.html

TOP

Rank: 9Rank: 9Rank: 9

UID
2 
积分
2874604 
威望
1387331 布 
龙e币
1487273 刀 
在线时间
13155 小时 
注册时间
2009-12-3 
最后登录
2024-11-24 

Medal No.1
6#
龙听发表于 2024-11-2 14:38 | 只看该作者
6、点击“运行”动作模块
  1. void test::OnRun()
  2. {
  3.         OnState("run");
  4.         if (state != "run")return;
  5.         mapPosDeta.clear();
  6.         mapPos.clear();
  7.         mapOrder.clear();
  8.         mapTrade.clear();
  9.         sound("sound\\run.wav");
  10.         RsqInstrument(sInst);
  11.         RsqRspQryOrder();
  12.         RsqPosition();
  13.         //        RsqRspQryTrade();
  14.                 //RsqPositionDetail();
  15.                 //RsqAccount();
  16.         SubscribeMarketData(sInst);

  18.         num = 0;
  19.         jxzq = atoi(parm["均线周期"].Value.c_str());
  20.         dbfx = atof(parm["单笔风险"].Value.c_str());
  21.         hd = atoi(parm["滑点值"].Value.c_str());
  22.         yxpc = atoi(parm["优先平仓"].Value.c_str());
  23.         jg = atoi(parm["撤单时间"].Value.c_str());

  25.         RsqBar(sPeriod, sInst);
  26.         ma = avg(sPeriod, sInst, jxzq);

  28.         string s2 = "   均线  " + to_string(ma);
  29.         InsertLog(s2);

  31.         string wj[2];
  32.         string s = "c:/" + sName + sInst + "单均线出场交易系统.txt";
  33.         fstream ofs;
  34.         ofs.open(s, ios::in);
  35.         if (!ofs.is_open())
  36.         {
  37.                 fx = 0;
  38.                 ss = 0;
  39.         }
  40.         else
  41.         {
  42.                 for (int i = 0; i < 2; i++)
  43.                 {
  44.                         getline(ofs, wj[i]);
  45.                         //        InsertLog(wj[i]);
  46.                 }
  47.         }
  48.         ofs.close();
  49.         fx = atoi(wj[0].c_str());
  50.         ss = atoi(wj[1].c_str());
  51.         string s1 = "    均线出场策略启动，均线周期    " + to_string(jxzq) +  "   单笔风险   "
  52.                         + to_string(dbfx) + "   滑点   " + to_string(hd) + "  优先开平    " + to_string(yxpc) + "   撤单时间   "
  53.                         + to_string(jg) + "   持仓方向   " + to_string(fx) + "   数量   " + to_string(ss);
  54.         InsertLog(s1);

  56. }

  58. void test::OnStop()
  59. {
  60.         OnState("stop");
  61.         sound("sound\\stop.wav");
  62.         xieruzhuangtai();
  63.         InsertLog("    单均线交易系统停止运行，持仓方向    " + to_string(fx) + "   手数  " + to_string(ss));

  65. }
复制代码
如何访问权限为100/255贴子：/thread-37840-1-1.html；注册后仍无法回复：/thread-23-1-1.html；微信/QQ群：/thread-262-1-1.html；网盘链接失效解决办法：/thread-93307-1-1.html

TOP

Rank: 9Rank: 9Rank: 9

UID
2 
积分
2874604 
威望
1387331 布 
龙e币
1487273 刀 
在线时间
13155 小时 
注册时间
2009-12-3 
最后登录
2024-11-24 

Medal No.1
7#
龙听发表于 2024-11-2 14:40 | 只看该作者
7、tick接收与运行模块：
  1. void test::OnMarketData(CThostFtdcDepthMarketDataField* t)
  2. {
  3.         if (state != "run")return;
  4.         if (t->InstrumentID != sInst)return;
  5.         mapMd[t->InstrumentID] = *t;

  7.         if (t->LastPrice > ma && fx == 0)
  8.         {
  9.                 fx = 1;
  10.                 ss = dbfx;
  11.                 map<string, double>::iterator it;
  12.                 for (it = mapSub.begin(); it != mapSub.end(); it++)
  13.                 {
  14.                         int sl = (int)(ss * it->second);
  15.                         OrderInsert(it->first, sInst, '0', '0', sl, t->AskPrice1 + hd * mapInstrument[sInst].PriceTick, "", "");//买入开仓语句
  16.                         //输出至交易界面的log里面
  17.                         string s = it->first + " 突破入场价格多单达到入场条件买入开仓 " + to_string(sl) + " 手，价格 " + to_string(t->AskPrice1 + hd * mapInstrument[sInst].PriceTick) + " 基础手数 " + to_string(ss) + " 均线 " + to_string(ma);
  18.                         maps[num] = s;
  19.                         num++;
  20.                 }
  21.                 if (num != 0)shuchurizhi();
  22.                 tm = 0;
  23.                 xieruzhuangtai();
  24.         }
  25.         if (t->LastPrice < ma && fx == 0)
  26.         {
  27.                 fx = -1;
  28.                 ss = dbfx;
  29.                 map<string, double>::iterator it;
  30.                 for (it = mapSub.begin(); it != mapSub.end(); it++)
  31.                 {
  32.                         int sl = (int)(ss * it->second);
  33.                         OrderInsert(it->first, sInst, '1', '0', sl, t->BidPrice1 - hd * mapInstrument[sInst].PriceTick, "", "");
  34.                         string s = it->first + " 突破入场价格空单达到入场条件卖出开仓 " + to_string(sl) + " 手，价格 " + to_string(t->BidPrice1 - hd * mapInstrument[sInst].PriceTick) + " 基础手数 " + to_string(ss) + " 均线 " + to_string(ma);
  35.                         maps[num] = s;
  36.                         num++;

  38.                 }
  39.                 if (num != 0)shuchurizhi();
  40.                 tm = 0;
  41.                 xieruzhuangtai();
  42.         }
  43. }

  45. /*
  46. ***********************************************************************单均线交易系统入场模块(tick模式结束)*******************************************************************
  47. */
复制代码
如何访问权限为100/255贴子：/thread-37840-1-1.html；注册后仍无法回复：/thread-23-1-1.html；微信/QQ群：/thread-262-1-1.html；网盘链接失效解决办法：/thread-93307-1-1.html

TOP

Rank: 9Rank: 9Rank: 9

UID
2 
积分
2874604 
威望
1387331 布 
龙e币
1487273 刀 
在线时间
13155 小时 
注册时间
2009-12-3 
最后登录
2024-11-24 

Medal No.1
8#
龙听发表于 2024-11-2 14:41 | 只看该作者
8、新bar产生动作模块
  1. /*
  2. ***********************************************************************单均线交易系统出场模块(BAR模式开始)*******************************************************************
  3. */
  4. void test::OnBarOpen(TKVALUE t)
  5. {
  6.         if (state != "run")return;
  7.         if (t.InstrumentID != sInst)return;
  8.         mapK[sPeriod][sInst][t.sDate + t.sDayNight + t.sTime] = t;
  9.         ma = avg(sPeriod, sInst, jxzq);
  10.         string s2 = "    合约    " + sInst + "    均线  " + to_string(ma);
  11.         InsertLog(s2);
  12.         //出场策略模块1

  14.         //（1）最新价小于均线价格，持有多单进行平仓模块
  15.         if (mapMd[sInst].LastPrice < ma && fx == 1)
  16.         {
  17.                 fx = 0;
  18.                 map<string, double>::iterator it;
  19.                 for (it = mapSub.begin(); it != mapSub.end(); it++)
  20.                 {
  21.                         int sl = (int)(ss * it->second);
  22.                         if (yxpc == 0)
  23.                         {
  24.                                 closesell1(it->first, sInst, sl, mapMd[sInst].BidPrice1 - hd * mapInstrument[sInst].PriceTick);
  25.                         }
  26.                         else if (yxpc == 1)
  27.                         {
  28.                                 closesell2(it->first, sInst, sl, mapMd[sInst].BidPrice1 - hd * mapInstrument[sInst].PriceTick);
  29.                         }
  30.                         string s = it->first + "    多单跌破均线达到出场条件卖出平仓    " + to_string(sl) + "    手，价格    " + to_string(mapMd[sInst].BidPrice1 - hd * mapInstrument[sInst].PriceTick) + "  基础手数  " + to_string(ss) + "  均线 " + to_string(ma);
  31.                         maps[num] = s;
  32.                         num++;
  33.                 }
  34.                 if (num != 0)shuchurizhi();
  35.                 tm = 0;
  36.                 xieruzhuangtai();
  37.         }
  38.         //（2）最新价大于均线价格，持有空单进行平仓模块
  39.         if (mapMd[sInst].LastPrice > ma && fx == -1)
  40.         {
  41.                 fx = 0;
  42.                 map<string, double>::iterator it;
  43.                 for (it = mapSub.begin(); it != mapSub.end(); it++)
  44.                 {
  45.                         int sl = (int)(ss * it->second);
  46.                         if (yxpc == 0)
  47.                         {
  48.                                 closebuy1(it->first, sInst, sl, mapMd[sInst].AskPrice1 + hd * mapInstrument[sInst].PriceTick);
  49.                         }
  50.                         else if (yxpc == 1)
  51.                         {
  52.                                 closebuy2(it->first, sInst, sl, mapMd[sInst].AskPrice1 + hd * mapInstrument[sInst].PriceTick);
  53.                         }
  54.                         string s = it->first + "    空单涨破均线达到出场条件买入平仓    " + to_string(ss) + "    手，价格    " + to_string(mapMd[sInst].AskPrice1 + hd * mapInstrument[sInst].PriceTick) + "  基础手数  " + to_string(ss) + "  均线 " + to_string(ma);
  55.                         maps[num] = s;
  56.                         num++;
  57.                 }
  58.                 if (num != 0)shuchurizhi();
  59.                 tm = 0;
  60.                 xieruzhuangtai();

  62.         }
  63. }
  64. /*
  65. ***********************************************************************单均线交易系统入出场模块(BAR模式结束)*******************************************************************
  66. */
复制代码
如何访问权限为100/255贴子：/thread-37840-1-1.html；注册后仍无法回复：/thread-23-1-1.html；微信/QQ群：/thread-262-1-1.html；网盘链接失效解决办法：/thread-93307-1-1.html

TOP

Rank: 9Rank: 9Rank: 9

UID
2 
积分
2874604 
威望
1387331 布 
龙e币
1487273 刀 
在线时间
13155 小时 
注册时间
2009-12-3 
最后登录
2024-11-24 

Medal No.1
9#
龙听发表于 2024-11-2 14:42 | 只看该作者
9、委托与成交模块：
  1. void test::OnRtnOrder(CThostFtdcOrderField t)
  2. {
  3.         mapOrder[t.OrderLocalID] = t;
  4.         if (!mapMd.count(t.InstrumentID))SubscribeMarketData(t.InstrumentID);
  5.         if (state != "run")return;
  6.         if (t.OrderStatus == '5' && t.MacAddress == sName  &&IsActionOrdrSysID(t.OrderLocalID)) chongfa(t);

  8.         string s = t.CombOffsetFlag;
  9.        // if (t.OrderStatus == '0' && s != "0" && t.MacAddress == sName) OnStop();
  10. }

  12. void test::OnRtnTrade(CThostFtdcTradeField t)
  13. {
  14.         mapTrade[t.OrderSysID] = t;
  15.         if (state != "run")return;

  17.         RsqPosition();
  18.         RsqPositionDetail(t.InvestorID);
  19. }
复制代码
如何访问权限为100/255贴子：/thread-37840-1-1.html；注册后仍无法回复：/thread-23-1-1.html；微信/QQ群：/thread-262-1-1.html；网盘链接失效解决办法：/thread-93307-1-1.html

TOP

Rank: 9Rank: 9Rank: 9

UID
2 
积分
2874604 
威望
1387331 布 
龙e币
1487273 刀 
在线时间
13155 小时 
注册时间
2009-12-3 
最后登录
2024-11-24 

Medal No.1
10#
龙听发表于 2024-11-2 14:43 | 只看该作者
10、订单成交、撤单、重发委托等跟交易与委托相关模块：
  1. void test::OnRsqBar(string sPeriod, string sInst, map<string, TKVALUE> mp)
  2. {
  3.         if (state != "run")return;
  4.         mapK[sPeriod][sInst] = mp;
  5.         int n = mp.size();
  6.         if (n < jxzq)InsertLog(sInst + "  bar 数量不够 ");
  7. }

  9. /*
  10. ***********************************************************************委托与交易模块(开始)**********************************************************************************
  11. */

  13. void test::OnInstrument(CThostFtdcInstrumentField t)
  14. {
  15.         mapInstrument[t.InstrumentID] = t;
  16. }


  19. void test::OnRspQryOrder(map<string, CThostFtdcOrderField>* m)
  20. {
  21.         mapOrder = *m;
  22. }

  24. void test::OnRspQryTrade(map<string, CThostFtdcTradeField>* m)
  25. {
  26.         mapTrade = *m;
  27. }

  29. void test::OnPosition(map<string, map<string, TPOSITION>>* m)
  30. {
  31.         mapPos = *m;
  32. }

  34. void test::OnPositionDetail(map<string, TDETAIL>* m)
  35. {
  36.         mapPosDeta = *m;
  37.         /*map<string, TDETAIL>::iterator it;
  38.         for (it = mapPosDeta.begin(); it != mapPosDeta.end(); it++)
  39.         {
  40.                 string s1 = "  编号  " + it->first + "  账户  " + it->second.sAcc + "   合约   " + it->second.sInst + "  方向  " + it->second.sBuySell + "  数量  " + to_string(it->second.nVol) + "    平仓数量    " + to_string(it->second.nCloseVol) + "  价格  " + to_string(it->second.dOpenPrice) + "  时间  " + it->second.sOpenDate;
  41.                 if (it->second.nVol - it->second.nCloseVol != 0)InsertLog(s1);
  42.         }*/
  43. }

  45. void test::OnCommissionRate(map<string, map<string, TCOMMISSION>>* m)
  46. {
  47.         mapCom = *m;
  48. }

  50. void test::OnAccount(map<string, CThostFtdcTradingAccountField>* m)
  51. {
  52.         mapAcc = *m;
  53. }

  55. void test::OnInstrumentStatus(CThostFtdcInstrumentStatusField* t)
  56. {

  58. }

  60. void test::OnInstrumentAll(map<string, CThostFtdcInstrumentField>* m)
  61. {
  62.         mapInstrument = *m;
  63. }

  65. void test::chedan()
  66. {
  67.         map<string, CThostFtdcOrderField>::iterator it;
  68.         for (it = mapOrder.begin(); it != mapOrder.end(); it++)
  69.         {
  70.                 if (it->second.MacAddress == sName)
  71.                 {
  72.                         if (it->second.OrderStatus == '3' || it->second.OrderStatus == '1')
  73.                         {
  74.                                 string bs;
  75.                                 string soc;
  76.                                 if (it->second.Direction == '0')bs = "买入";
  77.                                 if (it->second.Direction == '1')bs = "卖出";
  78.                                 if (it->second.CombOffsetFlag == "0")soc = "开仓";
  79.                                 if (it->second.CombOffsetFlag == "1")soc = "平仓";
  80.                                 if (it->second.CombOffsetFlag == "3")soc = "平今仓";
  81.                                 if (it->second.CombOffsetFlag == "4")soc = "平昨仓";
  82.                                 OrderAction(it->second);
  83.                                 string s1 = t1 + ":" + t2 + ":" + t3 + ":" + t4 + "    " + it->second.InvestorID + "   有未成交委托，委托买卖方向   " + bs + soc + "    未成交数量委托数量    " + to_string((it->second.VolumeTotal - it->second.VolumeTraded)) + "    委托价格    " + to_string(it->second.LimitPrice) + "    " + it->second.InstrumentID;
  84.                                 maps[num] = s1;
  85.                                 num++;
  86.                                 lstActionOrdrSysID.push_back(it->second.OrderSysID);
  87.                         }
  88.                 }
  89.         }
  90.         if (num != 0)shuchurizhi();
  91. }

  93. void test::shuchurizhi()
  94. {
  95.         map<int, string>::iterator it;
  96.         for (it = maps.begin(); it != maps.end(); it++)
  97.         {
  98.                 InsertLog(it->second);
  99.         }
  100.         maps.clear();
  101.         num = 0;
  102. }

  104. void test::xieruzhuangtai()
  105. {
  106.         string s = "c:/" + sName + sInst + "均线出场.txt";
  107.         fstream ofs;
  108.         ofs.open(s, ios::out, ios::_Noreplace);
  109.         if (ofs.is_open())
  110.         {
  111.                 ofs << to_string(fx) << endl;
  112.                 ofs << to_string(ss) << endl;
  113.         }
  114.         ofs.close();
  115. }

  117. void test::chongfa(CThostFtdcOrderField t)
  118. {
  119.         string bs;
  120.         string soc;
  121.         if (t.Direction == '0')bs = "买入";
  122.         if (t.Direction == '1')bs = "卖出";
  123.         if (t.CombOffsetFlag == "0")soc = "开仓";
  124.         if (t.CombOffsetFlag == "1")soc = "平仓";
  125.         if (t.CombOffsetFlag == "3")soc = "平今仓";
  126.         if (t.CombOffsetFlag == "4")soc = "平昨仓";
  127.         char oc = t.CombOffsetFlag[0];
  128.         double dsj;
  129.         if (t.Direction == '0')
  130.         {
  131.                 dsj = mapMd[t.InstrumentID].AskPrice1;
  132.         }
  133.         else if (t.Direction == '1')
  134.         {
  135.                 dsj = mapMd[t.InstrumentID].BidPrice1;
  136.         }
  137.         OrderInsert(t.InvestorID, t.InstrumentID, t.Direction, oc, (t.VolumeTotal - t.VolumeTraded), dsj, "", "");
  138.         string s = t.InvestorID;
  139.         string s1 = t1 + ":" + t2 + ":" + t3 + ":" + t4 + "    " + s + "   有撤单成功重发，重发委托买卖方向   " + bs + soc + "    未成交数量委托数量    " + to_string((t.VolumeTotal - t.VolumeTraded)) + "    重发价格    " + to_string(dsj) + "    " + t.InstrumentID;
  140.         InsertLog(s1);
  141. }

  143. //   卖出平仓  优先平昨仓
  144. void test::closesell1(string sInvestorID, string sName, int sl, double jg)
  145. {
  146.         //if (mapInstrument[sName].ExchangeID != "SHFE")
  147.         //{
  148.         //        OrderInsert(sInvestorID, sName, '1', '1', sl, jg, "", "");
  149.         //}
  150.         //else
  151.         //{
  152.         if (mapPos[sInvestorID][sName].nLongPosYd >= sl)
  153.         {
  154.                 OrderInsert(sInvestorID, sName, '1', '4', sl, jg, "", "");
  155.                 string s1 = t1 + ":" + t2 + ":" + t3 + ":" + t4 + "    " + "  账户  " + sInvestorID + " 合约   " + sName + "  卖出平昨  " + to_string(sl) + "  手，账户持仓有多单今仓数量  " + to_string(mapPos[sInvestorID][sName].nLongPosTd) + "   手持有昨仓多单数量 " + to_string(mapPos[sInvestorID][sName].nLongPosYd);
  156.                 InsertLog(s1);
  157.         }
  158.         else if (mapPos[sInvestorID][sName].nLongPosYd > 0)
  159.         {
  160.                 OrderInsert(sInvestorID, sName, '1', '4', mapPos[sInvestorID][sName].nLongPosYd, jg, "", "");
  161.                 int jys2 = min(mapPos[sInvestorID][sName].nLongPosTd, sl - mapPos[sInvestorID][sName].nLongPosYd);
  162.                 if (mapPos[sInvestorID][sName].nLongPosTd > 0)
  163.                 {

  165.                         OrderInsert(sInvestorID, sName, '1', '3', jys2, jg, "", "");
  166.                 }
  167.                 string s1 = t1 + ":" + t2 + ":" + t3 + ":" + t4 + "    " + "  账户  " + sInvestorID + " 合约   " + sName + "  卖出平昨  " + to_string(mapPos[sInvestorID][sName].nLongPosYd) + "  卖出平今仓  " + to_string(jys2) + "  手，账户持仓有多单今仓数量  " + to_string(mapPos[sInvestorID][sName].nLongPosTd) + "   手持有昨仓多单数量 " + to_string(mapPos[sInvestorID][sName].nLongPosYd);
  168.                 InsertLog(s1);
  169.         }
  170.         else if (mapPos[sInvestorID][sName].nLongPosTd > 0)
  171.         {
  172.                 int jys3 = min(sl, mapPos[sInvestorID][sName].nLongPosTd);
  173.                 OrderInsert(sInvestorID, sName, '1', '3', jys3, jg, "", "");
  174.                 string s1 = t1 + ":" + t2 + ":" + t3 + ":" + t4 + "    " + "  账户  " + sInvestorID + " 合约   " + sName + "  卖出平今仓  " + to_string(jys3) + "  手，账户持仓有多单今仓数量  " + to_string(mapPos[sInvestorID][sName].nLongPosTd) + "   手持有昨仓多单数量 " + to_string(mapPos[sInvestorID][sName].nLongPosYd);
  175.                 InsertLog(s1);
  176.         }
  177.         else
  178.         {
  179.                 string s1 = t1 + ":" + t2 + ":" + t3 + ":" + t4 + "    " + "  账户  " + sInvestorID + " 合约   " + sName + "  账户持仓有多单今仓数量  " + to_string(mapPos[sInvestorID][sName].nLongPosTd) + "   手持有昨仓多单数量 " + to_string(mapPos[sInvestorID][sName].nLongPosYd) + "  账户持仓有空单今仓数量  " + to_string(mapPos[sInvestorID][sName].nShortPosTd) + "   手持有昨仓空单数量 " + to_string(mapPos[sInvestorID][sName].nShortPosYd);;
  180.                 InsertLog(s1);
  181.         }
  182.         //        }
  183. }

  185. //  买入平仓 优先平昨仓
  186. void test::closebuy1(string sInvestorID, string sName, int sl, double jg)
  187. {
  188.         //if (mapInstrument[sName].ExchangeID != "SHFE")
  189.         //{
  190.         //        OrderInsert(sInvestorID, sName, '0', '1', sl, jg, "", "");
  191.         //}
  192.         //else
  193.         //{
  194.         if (mapPos[sInvestorID][sName].nShortPosYd >= sl)
  195.         {
  196.                 OrderInsert(sInvestorID, sName, '0', '4', sl, jg, "", "");
  197.                 string s1 = t1 + ":" + t2 + ":" + t3 + ":" + t4 + "    " + "  账户  " + sInvestorID + " 合约   " + sName + "  买入平昨  " + to_string(sl) + "  手，账户持仓有空单今仓数量  " + to_string(mapPos[sInvestorID][sName].nShortPosTd) + "   手持有昨仓空单数量 " + to_string(mapPos[sInvestorID][sName].nShortPosYd);
  198.                 InsertLog(s1);
  199.         }
  200.         else if (mapPos[sInvestorID][sName].nShortPosYd > 0)
  201.         {
  202.                 OrderInsert(sInvestorID, sName, '0', '4', mapPos[sInvestorID][sName].nShortPosYd, jg, "", "");
  203.                 int jys2 = min(mapPos[sInvestorID][sName].nShortPosTd, sl - mapPos[sInvestorID][sName].nShortPosYd);
  204.                 if (mapPos[sInvestorID][sName].nShortPosTd > 0)
  205.                 {

  207.                         OrderInsert(sInvestorID, sName, '0', '3', jys2, jg, "", "");
  208.                 }
  209.                 string s1 = t1 + ":" + t2 + ":" + t3 + ":" + t4 + "    " + "  账户  " + sInvestorID + " 合约   " + sName + "  买入平昨  " + to_string(mapPos[sInvestorID][sName].nShortPosYd) + "  买入平今仓  " + to_string(jys2) + "  手，账户持仓有空单今仓数量  " + to_string(mapPos[sInvestorID][sName].nShortPosTd) + "   手持有昨仓空单数量 " + to_string(mapPos[sInvestorID][sName].nShortPosYd);
  210.                 InsertLog(s1);
  211.         }
  212.         else if (mapPos[sInvestorID][sName].nShortPosTd > 0)
  213.         {
  214.                 int jys3 = min(mapPos[sInvestorID][sName].nShortPosTd, sl);
  215.                 OrderInsert(sInvestorID, sName, '0', '3', jys3, jg, "", "");
  216.                 string s1 = t1 + ":" + t2 + ":" + t3 + ":" + t4 + "    " + "  账户  " + sInvestorID + " 合约   " + sName + "  买入平昨仓  " + to_string(jys3) + "  手，账户持仓有空单今仓数量  " + to_string(mapPos[sInvestorID][sName].nShortPosTd) + "   手持有昨仓空单数量 " + to_string(mapPos[sInvestorID][sName].nShortPosYd);
  217.                 InsertLog(s1);
  218.         }
  219.         else
  220.         {
  221.                 string s1 = t1 + ":" + t2 + ":" + t3 + ":" + t4 + "    " + "  账户  " + sInvestorID + " 合约   " + sName + "  账户持仓有多单今仓数量  " + to_string(mapPos[sInvestorID][sName].nLongPosTd) + "   手持有昨仓多单数量 " + to_string(mapPos[sInvestorID][sName].nLongPosYd) + "  账户持仓有空单今仓数量  " + to_string(mapPos[sInvestorID][sName].nShortPosTd) + "   手持有昨仓空单数量 " + to_string(mapPos[sInvestorID][sName].nShortPosYd);;
  222.                 InsertLog(s1);
  223.         }
  224.         //        }
  225. }

  227. //   卖出平仓  优先平今仓
  228. void test::closesell2(string sInvestorID, string sName, int sl, double jg)
  229. {
  230.         //if (mapInstrument[sName].ExchangeID != "SHFE")
  231.         //{
  232.         //        OrderInsert(sInvestorID, sName, '1', '1', sl, jg, "", "");
  233.         //}
  234.         //else
  235.         //{
  236.         if (mapPos[sInvestorID][sName].nLongPosTd >= sl)
  237.         {
  238.                 OrderInsert(sInvestorID, sName, '1', '3', sl, jg, "", "");
  239.                 string s1 = t1 + ":" + t2 + ":" + t3 + ":" + t4 + "    " + "  账户  " + sInvestorID + " 合约   " + sName + "  卖出平今  " + to_string(sl) + "  手，账户持仓有多单今仓数量  " + to_string(mapPos[sInvestorID][sName].nLongPosTd) + "   手持有昨仓多单数量 " + to_string(mapPos[sInvestorID][sName].nLongPosYd);
  240.                 InsertLog(s1);
  241.         }
  242.         else if (mapPos[sInvestorID][sName].nLongPosTd > 0)
  243.         {
  244.                 OrderInsert(sInvestorID, sName, '1', '3', mapPos[sInvestorID][sName].nLongPosTd, jg, "", "");
  245.                 int jys2 = min(mapPos[sInvestorID][sName].nLongPosYd, sl - mapPos[sInvestorID][sName].nLongPosTd);
  246.                 if (mapPos[sInvestorID][sName].nLongPosYd > 0)
  247.                 {
  248.                         OrderInsert(sInvestorID, sName, '1', '4', jys2, jg, "", "");
  249.                 }
  250.                 string s1 = t1 + ":" + t2 + ":" + t3 + ":" + t4 + "    " + "  账户  " + sInvestorID + " 合约   " + sName + "  卖出平今  " + to_string(mapPos[sInvestorID][sName].nLongPosTd) + "  卖出平昨仓  " + to_string(jys2) + "  手，账户持仓有多单今仓数量  " + to_string(mapPos[sInvestorID][sName].nLongPosTd) + "   手持有昨仓多单数量 " + to_string(mapPos[sInvestorID][sName].nLongPosYd);
  251.                 InsertLog(s1);
  252.         }
  253.         else if (mapPos[sInvestorID][sName].nLongPosYd > 0)
  254.         {
  255.                 int jys3 = min(mapPos[sInvestorID][sName].nLongPosYd, sl);
  256.                 OrderInsert(sInvestorID, sName, '1', '4', jys3, jg, "", "");
  257.                 string s1 = t1 + ":" + t2 + ":" + t3 + ":" + t4 + "    " + "  账户  " + sInvestorID + " 合约   " + sName + "  卖出平昨仓  " + to_string(jys3) + "  手，账户持仓有多单今仓数量  " + to_string(mapPos[sInvestorID][sName].nLongPosTd) + "   手持有昨仓多单数量 " + to_string(mapPos[sInvestorID][sName].nLongPosYd);
  258.                 InsertLog(s1);
  259.         }
  260.         else
  261.         {
  262.                 string s1 = t1 + ":" + t2 + ":" + t3 + ":" + t4 + "    " + "  账户  " + sInvestorID + " 合约   " + sName + "  账户持仓有多单今仓数量  " + to_string(mapPos[sInvestorID][sName].nLongPosTd) + "   手持有昨仓多单数量 " + to_string(mapPos[sInvestorID][sName].nLongPosYd) + "  账户持仓有空单今仓数量  " + to_string(mapPos[sInvestorID][sName].nShortPosTd) + "   手持有昨仓空单数量 " + to_string(mapPos[sInvestorID][sName].nShortPosYd);;
  263.                 InsertLog(s1);
  264.         }
  265. }
  266. //
  267. //}
  268. //  买入平仓 优先平今仓
  269. void test::closebuy2(string sInvestorID, string sName, int sl, double jg)
  270. {
  271.         //if (mapInstrument[sName].ExchangeID != "SHFE")
  272.         //{
  273.         //        OrderInsert(sInvestorID, sName, '0', '1', sl, jg, "", "");
  274.         //}
  275.         //else
  276.         //{
  277.         if (mapPos[sInvestorID][sName].nShortPosTd >= sl)
  278.         {
  279.                 OrderInsert(sInvestorID, sName, '0', '3', sl, jg, "", "");
  280.                 string s1 = t1 + ":" + t2 + ":" + t3 + ":" + t4 + "    " + "  账户  " + sInvestorID + " 合约   " + sName + "  买入平今  " + to_string(sl) + "  手，账户持仓有空单今仓数量  " + to_string(mapPos[sInvestorID][sName].nShortPosTd) + "   手持有昨仓空单数量 " + to_string(mapPos[sInvestorID][sName].nShortPosYd);
  281.                 InsertLog(s1);
  282.         }
  283.         else if (mapPos[sInvestorID][sName].nShortPosTd > 0)
  284.         {
  285.                 OrderInsert(sInvestorID, sName, '0', '3', mapPos[sInvestorID][sName].nShortPosTd, jg, "", "");
  286.                 int jys2 = min(mapPos[sInvestorID][sName].nShortPosYd, sl - mapPos[sInvestorID][sName].nShortPosTd);
  287.                 if (mapPos[sInvestorID][sName].nShortPosYd > 0)
  288.                 {
  289.                         OrderInsert(sInvestorID, sName, '0', '4', jys2, jg, "", "");
  290.                 }
  291.                 string s1 = t1 + ":" + t2 + ":" + t3 + ":" + t4 + "    " + "  账户  " + sInvestorID + " 合约   " + sName + "  买入平今  " + to_string(mapPos[sInvestorID][sName].nShortPosTd) + "  买入平昨仓  " + to_string(jys2) + "  手，账户持仓有空单今仓数量  " + to_string(mapPos[sInvestorID][sName].nShortPosTd) + "   手持有昨仓空单数量 " + to_string(mapPos[sInvestorID][sName].nShortPosYd);
  292.                 InsertLog(s1);
  293.         }
  294.         else if (mapPos[sInvestorID][sName].nShortPosYd > 0)
  295.         {
  296.                 int jys2 = min(mapPos[sInvestorID][sName].nShortPosYd, sl);
  297.                 OrderInsert(sInvestorID, sName, '0', '4', jys2, jg, "", "");
  298.                 string s1 = t1 + ":" + t2 + ":" + t3 + ":" + t4 + "    " + "  账户  " + sInvestorID + " 合约   " + sName + "  买入平昨仓  " + to_string(jys2) + "  手，账户持仓有空单今仓数量  " + to_string(mapPos[sInvestorID][sName].nShortPosTd) + "   手持有昨仓空单数量 " + to_string(mapPos[sInvestorID][sName].nShortPosYd);
  299.                 InsertLog(s1);
  300.         }
  301.         else
  302.         {
  303.                 string s1 = t1 + ":" + t2 + ":" + t3 + ":" + t4 + "    " + "  账户  " + sInvestorID + " 合约   " + sName + "  账户持仓有多单今仓数量  " + to_string(mapPos[sInvestorID][sName].nLongPosTd) + "   手持有昨仓多单数量 " + to_string(mapPos[sInvestorID][sName].nLongPosYd) + "  账户持仓有空单今仓数量  " + to_string(mapPos[sInvestorID][sName].nShortPosTd) + "   手持有昨仓空单数量 " + to_string(mapPos[sInvestorID][sName].nShortPosYd);;
  304.                 InsertLog(s1);
  305.         }
  306. }
  307. /*
  308. ***********************************************************************委托与交易模块(结束)**********************************************************************************
  309. */
复制代码
如何访问权限为100/255贴子：/thread-37840-1-1.html；注册后仍无法回复：/thread-23-1-1.html；微信/QQ群：/thread-262-1-1.html；网盘链接失效解决办法：/thread-93307-1-1.html

TOP

返回列表