simple advisor v1_3_save_file_normal.lua

function OnInit()

	tikers = {
	"AFKS" , "AFLT" , "AGRO" , "ALRS" , "CBOM" , "CHMF" , "ENPG" , "FEES" , "FIVE" , "FIXP" , "GAZP" , "GLTR" , "GMKN" , "HYDR" , "IRAO" , "LKOH" , "MAGN" , "MGNT" , "MOEX" , "MTSS" , "NLMK" , "NVTK" , "OZON" , "PHOR" , "PIKK" , "PLZL" , "POLY" , "ROSN" , "RTKM" , "RUAL" , "SBER" , "SBERP" , "SGZH" , "SNGS" , "SNGSP" , "TATN" , "TATNP" , "TCSG" , "TRNFP" , "VKCO" , "VTBR" , "YNDX"
	}
	
	progname = "simple advisor v.1.3 : "
	timeout = 10000
	timeout2 = 25000 -- пауза 25 секунд для проверки старта скрипта
	startind = 0 -- индекс старта скрипта (первой итерации)
	
	-- цветовые константы
	mBlack 	= RGB(0, 0, 0)
	mWhite 	= RGB(255, 255, 255)
	mRed 	= RGB(255, 204, 250)
	mGreen 	= RGB(199, 254, 236)
	mGray 	= RGB(226, 226, 226)
	mBlue 	= RGB(166, 220, 243)   
	
	starttime 		= 100100
	nomorningtime 		= 103000
	nonewsignalstime 	= 180000
	finishtime 		= 184000
	
	discreport = 0
	
	-- наименование файла: название скрипта дата и время
	filename = string.sub(progname, 1, 14).." "..os.date('%d%m%Y_%H%M%S') 
	
end


function OnStop()
	DestroyTable(m_t)
	do_it = false

	message(progname.." Финиш.")
end


function open_file()
	--создаем/открываем файл для записи
	DirectionSaveFile=tostring("C:\\files\\"..filename..".csv")
	my_csv=io.open(DirectionSaveFile,"a+")
end


function print_file(text)
	my_csv:write(text..";\n")
end


function close_file()
 	-- закрытие файла
	my_csv:flush() 
	my_csv:close()
end


function mprint(numb)
	return string.format("%.2f", numb)
end


function hhmmss(date_time)
	
	local Hour = date_time.hour
	if Hour<10 then Hour = "0"..Hour end
	
	local Min = date_time.min
	if Min<10 then Min = "0"..Min end
	
	local Sec=date_time.sec
	if Sec<10 then Sec="0"..Sec end
		
	return tonumber(Hour..Min..Sec)

end


function table_print(table_text, table_result_ind)

	if table_result_ind <=15 then 
		SetCell(table_result, table_result_ind, 1, table_text)
	else
		InsertRow(table_result,-1)
		SetCell(table_result, table_result_ind, 1, table_text)
	end
	
end

 
function main() 
	
	open_file()

	message(progname.." Старт.")
	message(progname.." starttime = "..starttime)
	print_file(progname.." starttime = "..starttime)
	message(progname.." nomorningtime = "..nomorningtime)
	print_file(progname.." nomorningtime = "..nomorningtime)
	message(progname.." nonewsignalstime = "..nonewsignalstime)
	print_file(progname.." nonewsignalstime = "..nonewsignalstime)
	message(progname.." finishtime = "..finishtime)
	print_file(progname.." finishtime = "..finishtime)
	
	
	-- обработка starttime
	while hhmmss(os.sysdate()) < starttime do
		local time1 = hhmmss(os.sysdate())
		message('Ожидаем время старта скрипта : '..starttime..", текущее время: "..time1) 
		print_file('Ожидаем время старта скрипта : '..starttime..", текущее время: "..time1)
		sleep(timeout2)
	end
	
	close_file()
	
	do_it = true
	
	size_table = 15 -- количество строк таблицы
	table_result_ind = 1 -- индекс строки
	if table_result==nil then  
		table_result = AllocTable() 
		AddColumn(table_result, 1, "Сигналы и результаты:", true, QTABLE_STRING_TYPE, 85) 
		CreateWindow(table_result) 
		SetWindowPos(table_result,0,440,600,320) 
		SetWindowCaption(table_result, progname.." сообщения скрипта")
		for u = 1, size_table do 
			InsertRow(table_result,-1)	
		end
	end
	
	if m_t==nil then     
		m_t = AllocTable() 
			AddColumn(m_t, 1, "Тикер", true, QTABLE_STRING_TYPE, 10) 
			AddColumn(m_t, 2, "Бумага", true, QTABLE_STRING_TYPE, 20)
			AddColumn(m_t, 3, "Тек.Цена", true, QTABLE_DOUBLE_TYPE, 10)
			AddColumn(m_t, 4, "Закрытие", true, QTABLE_DOUBLE_TYPE, 10)
			AddColumn(m_t, 5, "Продажи", true, QTABLE_INT64_TYPE, 10)
			AddColumn(m_t, 6, "Покупки", true, QTABLE_INT64_TYPE, 10)
			AddColumn(m_t, 7, "Сигнал", true, QTABLE_STRING_TYPE, 33)
		CreateWindow(m_t)  
		SetWindowPos(m_t,700,0,690,780) 
		SetWindowCaption(m_t, progname.." создание советника") -- показать таблицу, пишем заголовок
		
		-- добавляем строки циклом
		for u = 1, #tikers do 
			InsertRow(m_t,-1)	
		end
		
	end

	closeprice = {} -- создаем массив цен закрытия
	signal = {}
	lots = {} -- лоты по инструменту
	buypos = {} -- покупки
	sellpos = {} -- продажи
	
	for x = 1, #tikers do 
		closeprice[x] = getParamEx("TQBR", tikers[x], "PREVLEGALCLOSEPR") -- цена закрытия предыдущего дня
		signal[x] = 0 -- статус сигнала по инструменту
		
		lots[x] = getParamEx("TQBR", tikers[x], "LOTSIZE")
		buypos[x] = 0 -- добавляем нулевые значения в массив цен покупок
		sellpos[x] = 0 -- и в массив цен продаж
		
	end


	while do_it do

		-- заполнение таблицы
		for i = 1, #tikers do
			
			local tLast = getParamEx("TQBR", tikers[i], "LAST") 
			local tOffer = getParamEx("TQBR", tikers[i], "OFFERDEPTHT")  
			local tBid = getParamEx("TQBR", tikers[i], "BIDDEPTHT") 

			
			if startind == 0 then -- вывод неизменямой части таблицы
										
				local tName = getParamEx("TQBR", tikers[i], "SHORTNAME") 
				
				SetCell(m_t, i, 1, tikers[i]) 
				SetCell(m_t, i, 2, tName.param_image)
				SetCell(m_t, i, 4, closeprice[i].param_image)
			end

			SetCell(m_t, i, 3, tLast.param_image)
			SetCell(m_t, i, 5, tOffer.param_image)
			SetCell(m_t, i, 6, tBid.param_image)
			
			
			time3 = hhmmss(os.sysdate())	
			
			connect = isConnected()
			
			if connect == 1 then 
						
				if discreport == 1 then
					
					open_file()
					
					discreport = 0
					
					textdisc = " связь с сервером восстановлена"
				
					message(progname..textdisc)
					table_print(time3..textdisc, table_result_ind)
					table_result_ind = table_result_ind + 1
					
					print_file(time3..textdisc)
					close_file()
					
					startind = 0 -- доп.условие на пропуск при обновлении связи
					nomorningtime = time3 - 1
								
				end
			
				
				if tonumber(tOffer.param_value) > 2 * tonumber(tBid.param_value) then
				
					SetColor(m_t, i, 5, mRed, mBlack, mRed, mBlack)
					SetColor(m_t, i, 6, mWhite, mBlack, mWhite, mBlack)
					
					-- отработка сигналов
					if tonumber(tLast.param_value) < tonumber(closeprice[i].param_value) and signal[i] == 0 then 
						
						if startind == 0 and time3 > nomorningtime then
		
								SetCell(m_t, i, 7, "noSHORT (start pass)")
								table_text = "Пропуск на старте SHORT сигнала "..tikers[i].." по цене "..tLast.param_image
								signal[i] = -3 	
						
						else
		
							if time3 < nonewsignalstime then
							
								SetCell(m_t, i, 7, "SHORT")
								table_text = "сигнал SHORT по "..tikers[i].." по цене "..tLast.param_image
								signal[i] = -1 
								
								sellpos[i] = tonumber(tLast.param_value)
								
							else
							
								SetCell(m_t, i, 7, "noSHORT (time out pass)")
								table_text ="пропускаем сигнал на SHORT по таймеру "..nonewsignalstime.." по "..tikers[i].." по цене "..tLast.param_image
								signal[i] = -2 
								
							end	
						
						end
					
						message(progname..table_text)
						table_print(time3.." "..table_text, table_result_ind)
						table_result_ind = table_result_ind + 1
						
						open_file()
						print_file(time3.." "..table_text)
						close_file()
						
					end
					
				elseif 2 * tonumber(tOffer.param_value) < tonumber(tBid.param_value) then

					SetColor(m_t, i, 5, mWhite, mBlack, mWhite, mBlack)
					SetColor(m_t, i, 6, mGreen, mBlack, mGreen, mBlack)	

					if tonumber(tLast.param_value) > tonumber(closeprice[i].param_value) and signal[i] == 0 then 
						
						if startind == 0 and time3 > nomorningtime then
								
								SetCell(m_t, i, 7, "noLONG (start pass)")
								table_text = "Пропуск на старте LONG сигнала по "..tikers[i].." по цене "..tLast.param_image
								signal[i] = 3 
								
						else
						
							if time3 < nonewsignalstime then
							
								SetCell(m_t, i, 7, "LONG")
								table_text = "сигнал LONG по "..tikers[i].." по цене "..tLast.param_image
								signal[i] = 1 
								
								buypos[i] = tonumber(tLast.param_value)
								
							else	
							
								SetCell(m_t, i, 7, "noLONG (time out pass)")
								table_text = "пропускаем сигнал LONG по таймеру "..nonewsignalstime.." по "..tikers[i].." по цене "..tLast.param_image
								signal[i] = 2 
								
							end
						end
						

						
						message(progname..table_text)
						table_print(time3.." "..table_text, table_result_ind)
						table_result_ind = table_result_ind + 1
						
						
						open_file()
						print_file(time3.." "..table_text)
						close_file()
						
					end
					
				else
		
					SetColor(m_t, i, 5, mWhite, mBlack, mWhite, mBlack)
					SetColor(m_t, i, 6, mWhite, mBlack, mWhite, mBlack)
					
					--отработка выхода из сигналов
					if signal[i] ~= 0 then 
					
						if math.abs(signal[i]) == 3 then
						
							if signal[i] > 0 then
								table_text = "Пропуск закрытия позиции LONG (nomorningtime) по "..tikers[i].." по цене "..tLast.param_image
							else
								table_text = "Пропуск закрытия позиции SHORT (nomorningtime) по "..tikers[i].." по цене "..tLast.param_image
							end
							
							textfinres = "Ближайший сигнал по "..tikers[i].." будет отработан на вход"
						
						end
					
					
						if signal[i] == 1 then
							table_text = "закрытие позиции LONG по "..tikers[i].." по цене "..tLast.param_image
							
							sellpos[i] = tonumber(tLast.param_value)
							finres = (sellpos[i] - buypos[i]) * lots[i].param_value
							
							textfinres = tikers[i]..".LONG: покупка по: "..buypos[i].." продажа по: "..sellpos[i].." мин.лот = "..lots[i].param_image.." результат = "..mprint(finres).." руб." 
							
						end
						
						if signal[i] == -1 then
							table_text = "закрытие позиции SHORT по "..tikers[i].." по цене "..tLast.param_image
							
							buypos[i] = tonumber(tLast.param_value)
							finres = (sellpos[i] - buypos[i]) * lots[i].param_value
							
							textfinres = tikers[i]..".SHORT: продажа по: "..sellpos[i].." покупка по: "..buypos[i].." мин.лот = "..lots[i].param_image.." результат = "..mprint(finres).." руб." 
							
						end
						
						open_file()
						
						message(progname..table_text)
						table_print(time3.." "..table_text, table_result_ind)
						table_result_ind = table_result_ind + 1
						
						print_file(time3.." "..table_text)
						
						if math.abs(signal[i]) ~= 2 then
							message(progname..textfinres)
							table_print(textfinres, table_result_ind)
							table_result_ind = table_result_ind + 1
							
							print_file(textfinres)
							
						end
						
						close_file()
						
						signal[i] = 0
						
					end
					
					SetCell(m_t, i, 7, " ")
				
				end			
			
			Highlight(m_t, i, QTABLE_NO_INDEX, mGray, mBlack, 500) -- выделение цветом вносимых изменений
			
			else
			
				if discreport == 0 then
					
					textdisc = " разрыв связи с сервером"
					
					open_file()
					
					message(progname..textdisc)
					table_print(time3..textdisc, table_result_ind)
					table_result_ind = table_result_ind + 1
					
					print_file(time3..textdisc)
					
					discreport = 1
					
					close_file()
					sleep(100)
					
				end
			
			end
												
			if startind == 0 and i == #tikers then startind = 1 end -- убираем индекс первой итерации
			
			sleep(100)
			 
		end
 
 
		--остановка по таймеру
		local time2 = hhmmss(os.sysdate())
			
		if time2>= finishtime then
			
			open_file()
			table_text = "скрипт остановлен по таймеру: "..time2
			message(progname..table_text)
			print_file(table_text)
			SetCell(table_result, table_result_ind, 1, table_text)
			close_file()
			OnStop()
			
		end
		
 
		if IsWindowClosed(m_t) then OnStop() end
		
		sleep(timeout)
		
	end

end