lua quik

Добрый день. Вопрос для программистов на lua. Я начал разбираться с написанием робота. Сам робот на простой ma10. Вход при пробитии закрытия свечи ma(закрытием снизу вверх — лонг, сверху в них — шорт). Выход по стопам, при этом после стопа входить в противоположную сторону по открытию следующего часа. И выход по пробитию закрытия свечи и ma.
1)Не могу понять в какую часть когда записать следующее условие: нужно что бы робот выходил при пробитии закрытия свечи ma и делал переворот.
2)Как прописать условие переворота, по открытию следующего часа, переворота при выбивании стопа.
3)Как прописать перенос сделок через ноч.

Account          = ""; -- счет клиента
  ClientCode       = ""; -- код клиента
  FirmCode         = ""; -- код фирмы
  SecCode          = ""; -- код инструмента
  ClassCode        = ""; -- класс инструмента
  Tag              = SecCode .. "_PRICE"; -- индикатор графика цены
  EMA1             = SecCode .. "_EMA1"
  EMA2             = SecCode .. "_EMA2"
  Run              = true; -- отвечает за работу скрипта
  LastOpenBarIndex = 0; 
  FlagOrder        = false; -- флаг наличия активной заявки
  FlagStopOrder    = false;
  OrderNumber      = 0; -- номер заявки
  trans_id         = os.time(); -- уникальный id транзакции
  trans_number     = 0; -- номер транзакции
  trans_status     = 0; -- статус транзакции
  ClosePosition    = true;
  Count            = 0;
  Cycles           = 60;
  Rest             = 1; -- остаток в заявке 
  Start            = 65955; -- начало работы скрипта
  Stop             = 233000; -- конец работы скрипта
  StopLossl         = 350; -- размер стоп-лосса
  StopLosss         = 405; -- размер стоп-лосса
  TakeProfit		= 3.8/100
  Step             = 1; -- шаг цены
  Slip             = 0; -- проскальзывание цены
  Unit             = 10; -- количество лотов в заявке
  
   -- Главная функция скрипта --  
   function main()
       -- Основной цикл скрипта --
	   while Run do
	       if IsWindowClosed(t_id) then -- при закрытие окна торгового робота скрипт останавливается!!!
		     Run = false;
		     message("Stop trading robot!!!");
	       end;
		   
		   if not_trade() then
		   
		       file = io.open(getScriptPath() .. "/LastOpenBarIndex.txt", "r");
			   if file ~= nil then
		         LastOpenBarIndex = tonumber(file:read("*n"));
			     file:close();
			   end;
			 
			   if LastOpenBarIndex == nil then LastOpenBarIndex = 0 end;
			 
		       if FlagOrder then
			   
			     done_order()
				 
			   elseif FlagStopOrder then
			   
			     stop_order()
				 
			   elseif LastOpenBarIndex < getNumCandles(Tag) then
			   
			     Predict = predict() -- получаем прогноз
				 Position = position() -- узнаем позицию по инструменту
	           
			       if Predict > 0 and Position <= 0 then
				       if Position < 0 then
				         QtyBuy = math.abs(Position) + Unit;
					   elseif Position == 0 then
					    QtyBuy = Unit;
					   end;
				     buy(QtyBuy) -- покупаем
				   elseif Predict < 0 and Position >= 0 then
				       if Position > 0 then
				         QtySell = Position + Unit;
					   elseif Position == 0 then
					     QtySell = Unit;
					   end;
				     sell(QtySell) -- продаем
				   end;
				   
				 LastOpenBarIndex = getNumCandles(Tag);
				 
				 file = io.open(getScriptPath() .. "/LastOpenBarIndex.txt", "w");
				   if file ~= nil then
	                 file:write(tostring(LastOpenBarIndex));	 
                     file:close();
				   end;
			   
			   end;
			     
			 -- вывод параметров скрипта в таблицу --  
			 SetCell(t_id, 1, 1, tostring(getInfoParam("SERVERTIME")));
		     SetCell(t_id, 1, 2, SecCode);
		     SetCell(t_id, 1, 3, tostring(position()));
		     SetCell(t_id, 1, 4, tostring(round(tonumber(predict()), 10)));
		     SetCell(t_id, 1, 5, tostring(round(tonumber(getPortfolioInfo(FirmCode, ClientCode).total_limit_open_pos), 2)));
		     SetCell(t_id, 1, 6, tostring(round(tonumber(getPortfolioInfo(FirmCode, ClientCode).varmargin), 2)));
			 
			 sleep(1000);
			   
		   else
	         sleep(1000);
		   end;
	   end;
   end;
   
   function not_trade()
     local Error = true;
       if isConnected() == 1 then
	     local Time = 0;
		 
	     SERVER_TIME = getInfoParam("SERVERTIME"); 
		 
		   if string.len(SERVER_TIME) == 8 then
		     Time = tonumber(SERVER_TIME:sub (1,2) .. SERVER_TIME:sub (4,5) .. SERVER_TIME:sub (7,8));
		   else
		     Time = tonumber(SERVER_TIME:sub (1,1) .. SERVER_TIME:sub (3,4) .. SERVER_TIME:sub (6,7));
		   end; 	
		   
		   if Time == nil then Time = 0 end;
		   
		   if Time < Start then
			 Error = false;
			 SetCell(t_id, 1, 1, "ErrorTime");
			   for i = 2,6 do
		         SetCell(t_id, 1, i, "0");
		       end;
		   elseif Time > 135900 and Time < 140600 then
		     Error = false;
			 SetCell(t_id, 1, 1, "Clearing");
			   for i = 2,6 do
		         SetCell(t_id, 1, i, "0");
		       end;
		   elseif Time > 184400 and Time < 190600 then
		     Error = false;
			 SetCell(t_id, 1, 1, "Clearing");
			   for i = 2,6 do
		         SetCell(t_id, 1, i, "0");
		       end;
		   elseif Time > Stop then
		     Error = false;
			 SetCell(t_id, 1, 1, "ErrorTime");
			   for i = 2,6 do
		         SetCell(t_id, 1, i, "0");
		       end;
			   
			 -- закрытие позиции и снятие стоп-заявки в конце торговой сессии --
			 --[[local Position = position();
		       if Position ~= 0 then
			       if ClosePosition then
				       if Position > 0 then
					     Slip = 0;
			             sell(Position);
			           elseif Position < 0 then
					     Slip = 0;
			             buy(math.abs(Position));
				       end;
					 FlagOrder = false;
				     ClosePosition = false;
				   end;
			   elseif Position == 0 then
			     stop_order()
				 ClosePosition = true;
			   end;]]
		   end;
	   else
	     Error = false;
		 SetCell(t_id, 1, 1, "ErrorConnection");
		   for i = 2,6 do
		     SetCell(t_id, 1, i, "0");
		   end;
	   end;
	 return Error;  
   end;
   
   -- Функция покупки --
   function buy(QtyBuy)
     local PriceBuy = 0; -- цена по которой покупаем
	
       while PriceBuy <= 0 do
	     PriceBuy = tonumber(getParamEx(ClassCode, SecCode, "offer").param_value) - Step * Slip -- получаем лучшую цену предложения
	   end;
	  
	 message("Order to buy at the price: " .. PriceBuy .. ", qty: " .. QtyBuy);
	   
	 trans_id = trans_id + 1;
	 local trans_params = {
	     ['TRANS_ID']    = tostring(trans_id),
         ['ACTION']      = "NEW_ORDER",
         ['CLASSCODE']   = ClassCode,
         ['SECCODE']     = SecCode,
         ['OPERATION']   = "B", 
         ['TYPE']        = "M", 
         ['QUANTITY']    = tostring (math.floor(QtyBuy)), 
         ['ACCOUNT']     = Account,
         ['PRICE']       = tostring(math.floor(PriceBuy)),
		 ['CLIENT_CODE'] = ClientCode 
	                      }
						  
	 trans_status = 0;
     trans_number = 0;
	 
	 sendTransaction(trans_params)
	   
	   while trans_status ~= 3 do
		 sleep(20);
	   end;
	   
	 OrderNumber = trans_number;
	 FlagOrder = true; 
   end;

   -- Функция продажи --
   function sell(QtySell)
     local PriceSell = 0; -- цена по которой продаем
	 
       while PriceSell <= 0 do
	     PriceSell = tonumber(getParamEx(ClassCode, SecCode, "bid").param_value) - Step * Slip -- получаем лучшую цену спроса
	   end;
	   
	 message("Order to sell at the price: " .. PriceSell .. ", in the quantity: " .. QtySell);
	   
	 trans_id = trans_id + 1;
	 local trans_params = {
	     ['TRANS_ID']    = tostring(trans_id),
         ['ACTION']      = "NEW_ORDER",
         ['CLASSCODE']   = ClassCode,
         ['SECCODE']     = SecCode,
         ['OPERATION']   = "S", 
         ['TYPE']        = "M", 
         ['QUANTITY']    = tostring (math.floor(QtySell)), 
         ['ACCOUNT']     = Account,
         ['PRICE']       = tostring(math.floor(PriceSell)),
		 ['CLIENT_CODE'] = ClientCode	 
	                      }
						  
	 trans_status = 0;
     trans_number = 0;
	 
	 sendTransaction(trans_params) 
	 
	   while trans_status ~= 3 do
		 sleep(20);
	   end;
	   
	 OrderNumber = trans_number;
	 FlagOrder = true; 
   end;

   -- Функция контроля исполнения активной заявки --
   function done_order()
     local QtyOrder = 0;
     local PriceOrder = 0;
			 
	   for i = 0, getNumberOf("orders") - 1 do
	       if getItem("orders", i).order_num == OrderNumber then
		     Rest = getItem("orders", i).balance;
		       while PriceOrder <= 0 do
			     PriceOrder = getItem("orders", i).price;
				 QtyOrder = getItem("orders", i).qty;
				 sleep(20);
			   end;
		   end;
	   end;
	  
	   -- если заявка полностью исполнилась --
	   if Rest == 0 then
	     message(getInfoParam("SERVERTIME") .. " Order №" .. OrderNumber .. " fully executed, at the price without slipping: " .. PriceOrder .. " in quantity: " .. QtyOrder, 1)
	     FlagOrder = false;
		 FlagStopOrder = true;
		 Count = 0;
		 
	   -- если заявка не исполнилась, снимаем отстаток --	 
	   elseif Count > Cycles then
	     kill_order(OrderNumber);
	     message(getInfoParam("SERVERTIME") .. " Order №" .. OrderNumber .. " canceled, rest: " .. Rest, 1)
		 Count = 0;
		 FlagOrder = false;
		 
		   if position() ~= 0 then
			 FlagStopOrder = true;
	       end;
		  
		 file = io.open(getScriptPath() .. "/LastOpenBarIndex.txt", "w");
	     file:write("");
         file:close();
		  
	   -- если заявка еще не исполнилась, но время на исполнение еще осталось --
	   elseif Rest > 0 then
	     Count = Count + 1;
	   end;
     sleep(1000);
   end;   
 
  -- Функция выставления stop_loss --
   function stop_order()
       
       local PriceStopOrder = 0;
	   local Position = position();
	   
	   -- снимаем старую стоп-заявку --
	   for i = 0, getNumberOf("stop_orders") - 1 do
           if bit.test(getItem("stop_orders", i).flags, 0) == true then
			 kill_stop_order(getItem("stop_orders", i).order_num);
           end;			   
	   end;
	   
	    -- определяем цену по которой заключена сделка --
	   if Position ~= 0 then
           for i = 0, getNumberOf("trades") - 1 do
	           if getItem("trades", i).order_num == OrderNumber then
		           while PriceStopOrder <= 0 do
			         PriceStopOrder = getItem("trades", i).price;
				     sleep(20);
			       end;
		       end;
	       end;
	   end;
	
	   if PriceStopOrder > 0 and Position ~= 0 then
	   
	       if Position > 0 then
		     StopPrice = PriceStopOrder - StopLossl;
			 PriceX = PriceStopOrder - Step * 200;
			 QtyStopOrder = Position;
			 Operation = "S";
		   elseif Position < 0 then
		     StopPrice = PriceStopOrder + Step * StopLosss;
			 PriceX = PriceStopOrder + Step * 200;
			 QtyStopOrder = math.abs(Position);
			 Operation = "B";
		   end;
		   
           trans_id = trans_id + 1; 
           local trans_params = {
           ['TRANS_ID']        = tostring(trans_id),
           ['ACTION']          = "NEW_STOP_ORDER",
		   ['STOP_ORDER_KIND'] = "SIMPLE_STOP_ORDER",
		   ['EXPIRY_DATE']     = "TODAY",
		   ['STOPPRICE']       = tostring(math.floor(StopPrice)),
           ['CLASSCODE']       = ClassCode,
           ['SECCODE']         = SecCode,
           ['PRICE']           = tostring(math.floor(PriceX)),
           ['OPERATION']       = Operation, 
           ['TYPE']            = "L", 
           ['QUANTITY']        = tostring(math.floor(QtyStopOrder)), 
           ['ACCOUNT']         = Account,
		   ['CLIENT_CODE']     = ClientCode
                              }
						
	       trans_status = 0; -- сбрасываем прошлый статус транзакции
	 
           sendTransaction(trans_params); -- отправляем транзакцию
	 
	       while trans_status ~= 3 do
	         sleep(20);
	       end; 
		   if Position > 0 then
		     StopPrice = PriceStopOrder - StopLossl;
			 PriceX = PriceStopOrder - Step * 200;
			 QtyStopOrder = Position;
			 Operation = "S";
		   elseif Position < 0 then
		     StopPrice = PriceStopOrder + Step * StopLosss;
			 PriceX = PriceStopOrder + Step * 200;
			 QtyStopOrder = math.abs(Position);
			 Operation = "B";
		   end;
		   
           trans_id = trans_id + 1; 
           local trans_params = {
           ['TRANS_ID']        = tostring(trans_id),
           ['ACTION']          = "NEW_STOP_ORDER",
		   ['STOP_ORDER_KIND'] = "SIMPLE_STOP_ORDER",
		   ['EXPIRY_DATE']     = "TODAY",
		   ['STOPPRICE']       = tostring(math.floor(StopPrice)),
           ['CLASSCODE']       = ClassCode,
           ['SECCODE']         = SecCode,
           ['PRICE']           = tostring(math.floor(PriceX)),
           ['OPERATION']       = Operation, 
           ['TYPE']            = "L", 
           ['QUANTITY']        = tostring(math.floor(QtyStopOrder)), 
           ['ACCOUNT']         = Account,
		   ['CLIENT_CODE']     = ClientCode
                              }
						
	       trans_status = 0; -- сбрасываем прошлый статус транзакции
	 
           sendTransaction(trans_params); -- отправляем транзакцию
	 
	       while trans_status ~= 3 do
	         sleep(20);
	       end; 
		   --[[]]
		   if Position > 0 then
		     StopPrice = PriceStopOrder *(TakeProfit+1) ;
			 PriceX = PriceStopOrder - Step * 200;
			 QtyStopOrder = Position;
			 Operation = "S";
		   elseif Position < 0 then
		     StopPrice = PriceStopOrder *(1-TakeProfit);
			 PriceX = PriceStopOrder + Step * 200;
			 QtyStopOrder = math.abs(Position);
			 Operation = "B";
		   end;
		   
           trans_id = trans_id + 1; 
           local trans_params = {
           ['TRANS_ID']        = tostring(trans_id),
           ['ACTION']          = "NEW_STOP_ORDER",
		   ['STOP_ORDER_KIND'] = "SIMPLE_STOP_ORDER",
		   ['EXPIRY_DATE']     = "TODAY",
		   ['STOPPRICE']       = tostring(math.floor(StopPrice)),
           ['CLASSCODE']       = ClassCode,
           ['SECCODE']         = SecCode,
           ['PRICE']           = tostring(math.floor(PriceX)),
           ['OPERATION']       = Operation, 
           ['TYPE']            = "L", 
           ['QUANTITY']        = tostring(math.floor(QtyStopOrder)), 
           ['ACCOUNT']         = Account,
		   ['CLIENT_CODE']     = ClientCode
                              }
						
	       trans_status = 0; -- сбрасываем прошлый статус транзакции
	 
           sendTransaction(trans_params); -- отправляем транзакцию
	 
	       while trans_status ~= 3 do
	         sleep(20);
	       end; 
		   
		   FlagStopOrder = false;
 	   end;
   end;
   
   -- Функция снятия заявки --
   function kill_order(Number)
     trans_id = trans_id + 1;
     local trans_params = {
         ['TRANS_ID']   = tostring(trans_id),
         ['ACTION']     = "KILL_ORDER",
         ['CLASSCODE']  = ClassCode,
         ['SECCODE']    = SecCode,
         ['ACCOUNT']    = Account,
	     ['ORDER_KEY']  = tostring(Number)
                          }
     sendTransaction(trans_params);
   end;
   
   -- Функция снятия стоп-заявки --
   function kill_stop_order(Number)
     trans_id = trans_id + 1;
     local trans_params = {
         ['TRANS_ID']   = tostring(trans_id),
         ['ACTION']     = "KILL_STOP_ORDER",
         ['CLASSCODE']  = ClassCode,
         ['SECCODE']    = SecCode,
         ['ACCOUNT']    = Account,
	     ['STOP_ORDER_KEY']  = tostring(Number)
                          }
     sendTransaction(trans_params);
   end;
   
   -- Функция прогнозирования движения цены инструмента --
   function predict()
     local t, n, l = nil,nil,nil
	   while t == nil do
		 x1 = getNumCandles('Tag')
		 t, n, l = getCandlesByIndex('Tag', 0, 0, x1)
		 ma_1 = t[0].close
		 for i=1, x1-1 do
		 local C = t[i].close
		 local C1 = t[i-1].close
		 local C2 = t[i-2].close
		 local C3 = t[i-3].close
		 local C4 = t[i-4].close
		 local C5 = t[i-5].close
		 local C6 = t[i-6].close
		 local C7 = t[i-7].close
 		 local C8 = t[i-8].close
 		 local C9 = t[i-9].close
 		 ma_2 = (C1+C2+C3+C4+C5+C6+C7+C8+C9+C)/10 

		 ma_1 = ma_2
		 end
	     --
		 sleep(10)
       end;
	   local ema2 = ma_1;
	   
	   local ema1 = t[x1].close
	  
	 local result
	   if ema1 > ema2 then
	      result = 1;
	   elseif ema1 < ema2 then
	      result = -1
	   end;
	 return result;
   end;
   
   -- Функция определния позиции по инструменту --   
   function position()
     local res = 0;
	   for i = 0, getNumberOf("futures_client_holding") - 1 do
		   if getItem("futures_client_holding", i).sec_code == SecCode then
	         res = tonumber(getItem("futures_client_holding", i).totalnet);
	       end;
	   end;
	 return res;
   end;
 
   -- Функция обратного вызова запускается первой и создает таблицу торгового робота --
   function OnInit()
     message("Start trading robot!");
     t_id = AllocTable(); -- создаем таблицу
	 AddColumn (t_id,1,"Time", true, QTABLE_TIME_TYPE, 15);
	 AddColumn (t_id,2,"Sec_Code", true, QTABLE_STRING_TYPE, 10);
	 AddColumn (t_id,3,"Position", true, QTABLE_STRING_TYPE, 10);
	 AddColumn (t_id,4,"Predict", true, QTABLE_STRING_TYPE, 15);
	 AddColumn (t_id,5,"Balance", true, QTABLE_STRING_TYPE, 10);
	 AddColumn (t_id,6,"Margin", true, QTABLE_STRING_TYPE, 10);
	 CreateWindow(t_id); -- создаем окно таблицы
	 SetWindowCaption(t_id, "Trading robot");
	 InsertRow(t_id, 1);
   end;
   
   -- Функция обратного вызова для получения результата отправки транзакции --   
   function OnTransReply(trans_reply)
       if trans_reply.trans_id == trans_id then
         trans_status = trans_reply.status;
		 trans_number = trans_reply.order_num;
	   end;
   end;
   
   -- Функция обратного вызова остановки скрипта --   
   function OnStop()
     Run = false;
	 DestroyTable(t_id);
   end;
   
   -- Функция округления чисел --   
   function round(x, n)
     n = math.pow(10, n or 0)
     x = x * n
     if x >= 0 then x = math.floor(x + 0.5) else x = math.ceil(x - 0.5) end;
     return x / n
   end;
   
   

Буду благодарен за помощь.

---

Данная публикация является личным мнением автора. Мнение владельца сайта может не совпадать с мнением автора.