Emmanuele Sassi
491da764ff
- verifica sulla stima fatta per sezione - aggiunta funziona CreateProduction ed abbozzo CalcProduction - anticipato subscribe a risposta verifica via Redis - aggiunta lettura dati del profilo
621 lines
22 KiB
Lua
621 lines
22 KiB
Lua
--
|
|
-- EEEEEEEEEE GGGGGG TTTTTTTTTTTTTT
|
|
-- EEEEEEEEEE GGGGGGGGGG TTTTTTTTTTTTTT
|
|
-- EEEE GGGG GGGG TTTT
|
|
-- EEEE GGGG TTTT
|
|
-- EEEEEEE GGGG GGGGGGG TTTT
|
|
-- EEEEEEE GGGG GGGGGGG TTTT
|
|
-- EEEE GGGG GGGG TTTT
|
|
-- EEEE GGGG GGGG TTTT
|
|
-- EEEEEEEEEE GGGGGGGGGG TTTT
|
|
-- EEEEEEEEEE GGGGGG TTTT
|
|
--
|
|
-- by Egalware s.r.l.
|
|
-- Door manager by Egalware s.r.l. 2023/05/09
|
|
|
|
require( 'EgtBase')
|
|
_ENV = EgtProtectGlobal()
|
|
EgtEnableDebug( false)
|
|
|
|
-- modalita' di chiamata
|
|
QUESTION_MODES = {
|
|
NULL = 0,
|
|
PREVIEW = 1,
|
|
BOM = 2,
|
|
HARDWARE = 3,
|
|
CONFIG = 4,
|
|
ORDER = 5,
|
|
}
|
|
|
|
QUESTION_CONFIG_SUBMODES = {
|
|
NULL = 0,
|
|
PROFILELIST = 1,
|
|
THRESHOLDLIST = 2,
|
|
}
|
|
|
|
QUESTION_HARDWARE_SUBMODES = {
|
|
NULL = 0,
|
|
LIST = 1,
|
|
CALCHARDWARE = 2,
|
|
HARDWAREOPTION = 3,
|
|
SASHSHAPE = 4,
|
|
PROFILEDATAFROMAREA = 5,
|
|
}
|
|
|
|
-- produttore
|
|
MANUFACTURERS = {
|
|
NULL = 0,
|
|
AGB = 1,
|
|
MAICO = 2,
|
|
ROTO = 3,
|
|
}
|
|
|
|
_G.package.loaded.JSON = nil
|
|
local JSON = require( 'JSON')
|
|
|
|
local sIniFilePath = EgtGetIniFile()
|
|
local sBaseDir = EgtGetStringFromIni( 'Window', 'BaseDir', '', sIniFilePath)
|
|
EgtAddToPackagePath( sBaseDir .. '\\Designing\\?.lua')
|
|
--EgtAddToPackagePath( sBaseDir .. '\\Machining\\?.lua')
|
|
|
|
_G.package.loaded.WinProject = nil
|
|
local WinProject = require( 'WinProject')
|
|
|
|
-- Connessiona a Redis
|
|
local bRedisConnect, nRedisConnectionId = EgtRedisAsyncConnect( ENG.Param2)
|
|
if bRedisConnect then
|
|
EgtOutLog('Connessione con il server Redis dal Lua effettuata con successo con Id=' .. nRedisConnectionId .. '!')
|
|
else
|
|
nRedisConnectionId = 0
|
|
EgtOutLog('Errore! Impossibile connettersi con il server Redis dal Lua!')
|
|
end
|
|
|
|
local function Calc_Preview( QuestionArgs)
|
|
-- leggo argomenti passati
|
|
local sJwd = QuestionArgs["SerializedData"]
|
|
if sJwd and #sJwd > 0 then
|
|
-- imposto cartella profili
|
|
local sProfileDir = ''
|
|
sProfileDir = EgtGetStringFromIni( 'Window', 'ProfileDir', '', sIniFilePath)
|
|
if sProfileDir and #sProfileDir > 0 then
|
|
WDG.PROFILEPATH = sProfileDir
|
|
SetProfilePath()
|
|
else
|
|
local sErrorMsg = 'Errore! Cartella dei profili non trovata!'
|
|
EgtOutLog(sErrorMsg)
|
|
return 0, { Error = sErrorMsg}
|
|
end
|
|
-- carico jwd
|
|
WDG.JWD = sJwd
|
|
WinManage_LoadJwd()
|
|
local AreaId = WDG.AREAID
|
|
-- imposto opzioni visualizzazione
|
|
WDG.VALUE = false
|
|
_G.WinCalculate_SetCalcSolid()
|
|
WDG.VALUE = false
|
|
WinCalculate_SetSimplifiedSolid()
|
|
WDG.VALUE = true
|
|
WinCalculate_SetCalcPreview()
|
|
-- creazione pezzi
|
|
WDG.FRAMEID = AreaId
|
|
WinCalculate_CreatePartFromArea()
|
|
-- calcolo hardware
|
|
--WDG.FRAMEID = AreaId
|
|
--WDG.CALC_HARDWARELIST=false
|
|
--WDG.CALC_POSITIONLIST=false
|
|
--WDG.CALC_MACHININGLIST=false
|
|
--WDG.CALC_OPTIONLIST=false
|
|
--WinCalculate_AddHardware()
|
|
|
|
-- creo file svg
|
|
WDG.GROUPID = EgtGetFirstNameInGroup( GDB_ID.ROOT, WIN_PREVIEW)
|
|
WDG.FILE = 'C:\\Temp\\TestSvgManager.svg'
|
|
WinGetSvg()
|
|
-- leggo il file
|
|
local SouFh = io.open( WDG.FILE, "rb")
|
|
local content
|
|
if SouFh then
|
|
content = SouFh:read( "*all")
|
|
--EgtOutBox( 'Error opening ' .. sFilePath, 'ReadFromFile', 'ERROR')
|
|
SouFh:close()
|
|
--return false
|
|
end
|
|
-- do risultato
|
|
return 1, { Svg = content}
|
|
else
|
|
local sErrorMsg = 'Errore! Jwd non trovato!'
|
|
EgtOutLog(sErrorMsg)
|
|
return 0, { Error = sErrorMsg}
|
|
end
|
|
end
|
|
|
|
local function Calc_BOM( QuestionArgs)
|
|
-- leggo argomenti passati
|
|
local sJwd = QuestionArgs["SerializedData"]
|
|
if sJwd and #sJwd > 0 then
|
|
-- imposto cartella profili
|
|
local sProfileDir = ''
|
|
sProfileDir = EgtGetStringFromIni( 'Window', 'ProfileDir', '', sIniFilePath)
|
|
if sProfileDir and #sProfileDir > 0 then
|
|
WDG.PROFILEPATH = sProfileDir
|
|
SetProfilePath()
|
|
else
|
|
local sErrorMsg = 'Errore! Cartella dei profili non trovata!'
|
|
EgtOutLog(sErrorMsg)
|
|
return 0, { Error = sErrorMsg}
|
|
end
|
|
-- carico jwd
|
|
WDG.JWD = sJwd
|
|
WinManage_LoadJwd()
|
|
local AreaId = WDG.AREAID
|
|
-- imposto opzioni visualizzazione
|
|
WDG.VALUE = false
|
|
_G.WinCalculate_SetCalcSolid()
|
|
WDG.VALUE = false
|
|
WinCalculate_SetSimplifiedSolid()
|
|
WDG.VALUE = false
|
|
WinCalculate_SetCalcPreview()
|
|
-- creazione pezzi
|
|
WDG.FRAMEID = AreaId
|
|
WinCalculate_CreatePartFromArea()
|
|
-- calcolo hardware
|
|
WDG.FRAMEID = AreaId
|
|
WDG.CALC_MACHINING=false
|
|
WDG.CALC_HARDWARELIST=true
|
|
WDG.CALC_POSITIONLIST=false
|
|
WDG.CALC_OPTIONLIST=false
|
|
WinCalculate_AddHardware()
|
|
|
|
WinGetSectionsTotalLenghts()
|
|
WinGetGlassesList()
|
|
-- do risultato
|
|
local BOM = {}
|
|
for Index = 1, #WDG.SECTIONS_LENGTHS do
|
|
table.insert( BOM, { ClassCode = 'WindowTrunk',
|
|
ItemCode = 'Pine-' .. WDG.SECTIONS_LENGTHS[Index].W .. 'x' .. WDG.SECTIONS_LENGTHS[Index].H,
|
|
ItemQty = #WDG.SECTIONS_LENGTHS[Index].L,
|
|
DescriptionCode = '',
|
|
Qty = WDG.SECTIONS_LENGTHS[Index].TotL / 1000})
|
|
end
|
|
for Index = 1, #WDG.GLASSES_LIST do
|
|
table.insert( BOM, { ClassCode = 'WindowGlass',
|
|
ItemCode = '6/14argon/6-' .. EgtIf( WDG.GLASSES_LIST[Index].Rect, 'Rect-', 'Special-') .. WDG.GLASSES_LIST[Index].T,
|
|
ItemQty = 1,
|
|
DescriptionCode = WDG.GLASSES_LIST[Index].W .. 'x' .. WDG.GLASSES_LIST[Index].L,
|
|
Qty = WDG.GLASSES_LIST[Index].W * WDG.GLASSES_LIST[Index].L / 1000000})
|
|
end
|
|
if WDG.HARDWAREKIT_LIST then
|
|
for SashIndex = 1, #WDG.HARDWAREKIT_LIST do
|
|
for HardwareIndex = 1, #WDG.HARDWAREKIT_LIST[SashIndex] do
|
|
local Hardware = WDG.HARDWAREKIT_LIST[SashIndex][HardwareIndex]
|
|
table.insert( BOM, { ClassCode = 'WindowHardware',
|
|
ItemCode = '' .. Hardware['ArtCode'] .. '-' .. Hardware['Description'],
|
|
ItemQty = 1,
|
|
DescriptionCode = '',
|
|
Price = Hardware['Price'],
|
|
Qty = Hardware['Qty']})
|
|
end
|
|
end
|
|
end
|
|
|
|
local JsonBOM = JSON:encode( BOM)
|
|
return 1, { BOM = JsonBOM}
|
|
else
|
|
local sErrorMsg = 'Errore! Jwd non trovato!'
|
|
EgtOutLog(sErrorMsg)
|
|
return 0, { Error = sErrorMsg}
|
|
end
|
|
end
|
|
|
|
local function Calc_HardwareList( QuestionArgs, sReadLine)
|
|
local nManufacturer = tonumber( QuestionArgs["Manufacturer"])
|
|
if nManufacturer == MANUFACTURERS.AGB then
|
|
-- Canali
|
|
local QuestionChannel = "EgwHardwareQuestion"
|
|
local AnswerChannel = "EgwHardwareAnswer" .. os.time()
|
|
|
|
local Question = JSON:decode( sReadLine)
|
|
Question['Args'].OutputChannel = AnswerChannel
|
|
|
|
local JsonQuestion = JSON:encode( Question)
|
|
|
|
local bOk = EgtRedisAsyncPublish( nRedisConnectionId, QuestionChannel, JsonQuestion)
|
|
local AnswerArgs
|
|
if bOk then
|
|
EgtOutLog('Messaggio Redis pubblicato:' .. QuestionChannel .. ' ' .. JsonQuestion)
|
|
local bOk, Answer = EgtRedisAsyncSubscribeOneMessage( nRedisConnectionId, AnswerChannel, 10000)
|
|
if bOk then
|
|
EgtOutLog('Risposta Redis ricevuta:' .. Answer)
|
|
local JsonAnswer = JSON:decode( Answer)
|
|
AnswerArgs = JsonAnswer['Args']
|
|
AnswerArgs.OutputChannel = nil
|
|
else
|
|
local sErrorMsg = 'Errore! Risposta dal canale calcolo hardware Agb non arrivata!'
|
|
EgtOutLog(sErrorMsg)
|
|
return 0, { Error = sErrorMsg}
|
|
end
|
|
else
|
|
local sErrorMsg = 'Errore! Pubblicazione sul canale calcolo hardware Agb fallita!'
|
|
EgtOutLog(sErrorMsg)
|
|
return 0, { Error = sErrorMsg}
|
|
end
|
|
return 1, AnswerArgs
|
|
|
|
end
|
|
end
|
|
|
|
local function Calc_HardwareOptions( QuestionArgs)
|
|
-- leggo argomenti passati
|
|
local sJwd = QuestionArgs["SerializedData"]
|
|
local JsonGroupId = QuestionArgs["GroupId"]
|
|
if sJwd and JsonGroupId and #sJwd > 0 and #JsonGroupId > 0 then
|
|
-- imposto cartella profili
|
|
local sProfileDir = ''
|
|
sProfileDir = EgtGetStringFromIni( 'Window', 'ProfileDir', '', sIniFilePath)
|
|
if sProfileDir and #sProfileDir > 0 then
|
|
WDG.PROFILEPATH = sProfileDir
|
|
SetProfilePath()
|
|
else
|
|
local sErrorMsg = 'Errore! Cartella dei profili non trovata!'
|
|
EgtOutLog(sErrorMsg)
|
|
return 0, { Error = sErrorMsg}
|
|
end
|
|
local GroupId = JSON:decode( JsonGroupId)
|
|
-- carico jwd
|
|
WDG.JWD = sJwd
|
|
WinManage_LoadJwd()
|
|
local AreaId = WDG.AREAID
|
|
-- imposto opzioni visualizzazione
|
|
WDG.VALUE = false
|
|
_G.WinCalculate_SetCalcSolid()
|
|
WDG.VALUE = false
|
|
WinCalculate_SetSimplifiedSolid()
|
|
WDG.VALUE = false
|
|
WinCalculate_SetCalcPreview()
|
|
-- creazione pezzi
|
|
WDG.FRAMEID = AreaId
|
|
WinCalculate_CreatePartFromArea()
|
|
-- calcolo hardware
|
|
for i = 1, #GroupId do
|
|
WDG['AREANBR' .. tostring(i)] = GroupId[i]
|
|
end
|
|
WDG.FRAMEID = AreaId
|
|
WDG.CALC_MACHINING=false
|
|
WDG.CALC_HARDWARELIST=false
|
|
WDG.CALC_POSITIONLIST=false
|
|
WDG.CALC_OPTIONLIST=true
|
|
WinCalculate_AddHardwareByGroupId()
|
|
|
|
local nCalcHardwareOption = 0
|
|
local AnswerGroupId = {}
|
|
for i = 1, #GroupId do
|
|
local HardwareOptionList = WDG['HARDWAREOPTION_LIST' .. tostring(i)]
|
|
if HardwareOptionList then
|
|
nCalcHardwareOption = nCalcHardwareOption + 1
|
|
AnswerGroupId[ tostring( GroupId[i])] = HardwareOptionList[1]
|
|
else
|
|
AnswerGroupId[ tostring( GroupId[i])] = ''
|
|
end
|
|
end
|
|
if nCalcHardwareOption == #GroupId then
|
|
local JsonAnswerGroupId = JSON:encode( AnswerGroupId)
|
|
return 1, { HardwareOptions = JsonAnswerGroupId, GroupId = JsonGroupId}
|
|
elseif nCalcHardwareOption == 0 then
|
|
return 0, { Error = "Errore! Lista opzioni hardware non trovata!", GroupId = JsonGroupId}
|
|
end
|
|
|
|
|
|
|
|
|
|
|
|
--if WDG.HARDWAREOPTION_LIST and #WDG.HARDWAREOPTION_LIST > 0 then
|
|
-- return 1, { HardwareOptions = WDG.HARDWAREOPTION_LIST[1]}
|
|
--else
|
|
-- return 0, { Error = "Errore! Opzioni hardware non trovate!"}
|
|
--end
|
|
else
|
|
local sErrorMsg = 'Errore! Jwd non trovato!'
|
|
EgtOutLog(sErrorMsg)
|
|
return 0, { Error = sErrorMsg}
|
|
end
|
|
end
|
|
|
|
local function Calc_SashShape( QuestionArgs)
|
|
-- leggo argomenti passati
|
|
local sJwd = QuestionArgs["SerializedData"]
|
|
local JsonGroupId = QuestionArgs["GroupId"]
|
|
if sJwd and JsonGroupId and #sJwd > 0 and #JsonGroupId > 0 then
|
|
-- imposto cartella profili
|
|
local sProfileDir = ''
|
|
sProfileDir = EgtGetStringFromIni( 'Window', 'ProfileDir', '', sIniFilePath)
|
|
if sProfileDir and #sProfileDir > 0 then
|
|
WDG.PROFILEPATH = sProfileDir
|
|
SetProfilePath()
|
|
else
|
|
local sErrorMsg = 'Errore! Cartella dei profili non trovata!'
|
|
EgtOutLog(sErrorMsg)
|
|
return 0, { Error = sErrorMsg}
|
|
end
|
|
local GroupId = JSON:decode( JsonGroupId)
|
|
-- carico jwd
|
|
WDG.JWD = sJwd
|
|
WinManage_LoadJwd()
|
|
local AreaId = WDG.AREAID
|
|
-- imposto opzioni visualizzazione
|
|
WDG.VALUE = false
|
|
_G.WinCalculate_SetCalcSolid()
|
|
WDG.VALUE = false
|
|
WinCalculate_SetSimplifiedSolid()
|
|
WDG.VALUE = false
|
|
WinCalculate_SetCalcPreview()
|
|
-- creazione pezzi
|
|
WDG.FRAMEID = AreaId
|
|
WinCalculate_CreatePartFromArea()
|
|
for i = 1, #GroupId do
|
|
WDG['AREANBR' .. tostring(i)] = GroupId[i]
|
|
end
|
|
WinGetSashShape()
|
|
local nCalcShape = 0
|
|
local AnswerGroupId = {}
|
|
for i = 1, #GroupId do
|
|
local SashShape = WDG['SASHSHAPE' .. tostring(i)]
|
|
if SashShape then
|
|
nCalcShape = nCalcShape + 1
|
|
AnswerGroupId[ tostring( GroupId[i])] = SashShape
|
|
else
|
|
AnswerGroupId[ tostring( GroupId[i])] = ''
|
|
end
|
|
end
|
|
if nCalcShape == #GroupId then
|
|
local JsonAnswerGroupId = JSON:encode( AnswerGroupId)
|
|
return 1, { SashShape = JsonAnswerGroupId, GroupId = JsonGroupId}
|
|
else
|
|
return 0, { Error = "Errore! Forma serramento non trovata!", GroupId = JsonGroupId}
|
|
end
|
|
else
|
|
local sErrorMsg = 'Errore! Jwd o GroupId non trovato!'
|
|
EgtOutLog(sErrorMsg)
|
|
return 0, { Error = sErrorMsg, GroupId = JsonGroupId}
|
|
end
|
|
end
|
|
|
|
local function Calc_AreaProfiles( QuestionArgs)
|
|
-- leggo argomenti passati
|
|
local sJwd = QuestionArgs["SerializedData"]
|
|
local JsonGroupId = QuestionArgs["GroupId"]
|
|
if sJwd and JsonGroupId and #sJwd > 0 and #JsonGroupId > 0 then
|
|
-- imposto cartella profili
|
|
local sProfileDir = ''
|
|
sProfileDir = EgtGetStringFromIni( 'Window', 'ProfileDir', '', sIniFilePath)
|
|
if sProfileDir and #sProfileDir > 0 then
|
|
WDG.PROFILEPATH = sProfileDir
|
|
SetProfilePath()
|
|
else
|
|
local sErrorMsg = 'Errore! Cartella dei profili non trovata!'
|
|
EgtOutLog(sErrorMsg)
|
|
return 0, { Error = sErrorMsg}
|
|
end
|
|
local GroupId = JSON:decode( JsonGroupId)
|
|
-- carico jwd
|
|
WDG.JWD = sJwd
|
|
WinManage_LoadJwd()
|
|
local AreaId = WDG.AREAID
|
|
-- imposto opzioni visualizzazione
|
|
WDG.VALUE = false
|
|
_G.WinCalculate_SetCalcSolid()
|
|
WDG.VALUE = false
|
|
WinCalculate_SetSimplifiedSolid()
|
|
WDG.VALUE = false
|
|
WinCalculate_SetCalcPreview()
|
|
-- creazione pezzi
|
|
WDG.FRAMEID = AreaId
|
|
WinCalculate_CreatePartFromArea()
|
|
for i = 1, #GroupId do
|
|
WDG['AREANBR' .. tostring(i)] = GroupId[i]
|
|
end
|
|
WinGetAreaProfiles()
|
|
local nCalcShape = 0
|
|
local AnswerGroupId = {}
|
|
if WDG.AREAPROFILES and #WDG.AREAPROFILES > 0 then
|
|
local JsonAnswerGroupId = JSON:encode( WDG.AREAPROFILES)
|
|
return 1, { AreaProfiles = JsonAnswerGroupId}
|
|
else
|
|
return 0, { Error = "Errore! Dati profilo per l'area non trovati!", GroupId = JsonGroupId}
|
|
end
|
|
else
|
|
local sErrorMsg = 'Errore! Jwd o GroupId non trovato!'
|
|
EgtOutLog(sErrorMsg)
|
|
return 0, { Error = sErrorMsg, GroupId = JsonGroupId}
|
|
end
|
|
end
|
|
|
|
local function Calc_ProfileList()
|
|
-- leggo cartella profili
|
|
local sProfileDir = ''
|
|
sProfileDir = EgtGetStringFromIni( 'Window', 'ProfileDir', '', sIniFilePath)
|
|
if sProfileDir and #sProfileDir > 0 then
|
|
local Profiles = EgtFindAllFiles( sProfileDir .. '\\*.nge')
|
|
for i = 1, #Profiles do
|
|
_, Profiles[i], _ = EgtSplitPath( Profiles[i])
|
|
end
|
|
local ProfilesBOM = JSON:encode( Profiles)
|
|
return 1, { ProfileList = ProfilesBOM}
|
|
else
|
|
local sErrorMsg = 'Errore! Cartella dei profili non trovata!'
|
|
EgtOutLog(sErrorMsg)
|
|
return 0, { Error = sErrorMsg}
|
|
end
|
|
end
|
|
|
|
local function Calc_ThresholdList( QuestionArgs)
|
|
-- leggo argomenti passati
|
|
local sProfileName = QuestionArgs["ProfileName"]
|
|
if sProfileName and #sProfileName > 0 then
|
|
-- imposto cartella profili
|
|
local sProfileDir = ''
|
|
sProfileDir = EgtGetStringFromIni( 'Window', 'ProfileDir', '', sIniFilePath)
|
|
if sProfileDir and #sProfileDir > 0 then
|
|
WDG.PROFILEPATH = sProfileDir
|
|
SetProfilePath()
|
|
else
|
|
local sErrorMsg = 'Errore! Cartella dei profili non trovata!'
|
|
EgtOutLog(sErrorMsg)
|
|
return 0, { Error = sErrorMsg}
|
|
end
|
|
WDG.PROFILE = sProfileName
|
|
GetProfileThresholdsList()
|
|
WinGetProfileData()
|
|
if not WDG.THRESHOLDSLIST then
|
|
local sErrorMsg = 'Errore! Soglie non trovate!'
|
|
EgtOutLog(sErrorMsg)
|
|
return 0, { Error = sErrorMsg}
|
|
end
|
|
if not WDG.PROFILEDATA then
|
|
local sErrorMsg = 'Errore! Dati profilo non trovati!'
|
|
EgtOutLog(sErrorMsg)
|
|
return 0, { Error = sErrorMsg}
|
|
end
|
|
local ThresholdList = { }
|
|
for ThresholdIndex = 1, #WDG.THRESHOLDSLIST do
|
|
table.insert( ThresholdList, { Type = WDG.THRESHOLDSLIST[ThresholdIndex].nType, Name = WDG.THRESHOLDSLIST[ThresholdIndex].sName})
|
|
end
|
|
local JsonThresholdList = JSON:encode( ThresholdList)
|
|
--return 1, { ThresholdList = JsonThresholdList}
|
|
--local ProfileDataDictionary = { }
|
|
--for ThresholdIndex = 1, #WDG.THRESHOLDSLIST do
|
|
-- table.insert( ProfileDataDictionary.ThresholdList, { Type = WDG.THRESHOLDSLIST[ThresholdIndex].nType, Name = WDG.THRESHOLDSLIST[ThresholdIndex].sName})
|
|
--end
|
|
--for k, v in pairs(WDG.PROFILEDATA) do
|
|
-- ProfileDataDictionary[k] = v
|
|
--end
|
|
local JsonProfileDataDictionary = JSON:encode( WDG.PROFILEDATA)
|
|
return 1, { ThresholdList = JsonThresholdList, ProfileData = JsonProfileDataDictionary}
|
|
else
|
|
local sErrorMsg = 'Errore! Profilo non trovato!'
|
|
EgtOutLog(sErrorMsg)
|
|
return 0, { Error = sErrorMsg}
|
|
end
|
|
end
|
|
|
|
local nNilCount = 0
|
|
local bRun = true
|
|
|
|
local size = 2^13 -- good buffer size (8K)
|
|
while bRun do
|
|
local sReadLine = io.stdin:read( 'l')
|
|
EgtOutLog( 'Letta riga da stdin')
|
|
if sReadLine then
|
|
if sReadLine == 'quit' then
|
|
EgtOutLog( 'Chiusura processo')
|
|
break
|
|
end
|
|
if sReadLine ~= '' and sReadLine:find( '^#8477271#') and sReadLine:find( '#8477271#$') then
|
|
EgtOutLog( 'Lettura istruzione valida')
|
|
sReadLine = string.sub( sReadLine, 10, #sReadLine - 9)
|
|
local Question = JSON:decode( sReadLine)
|
|
local nThreadIndex = -1
|
|
local nId = -1
|
|
local ExecEnvironment = -1
|
|
local nResult = 0
|
|
local AnswerArgs = {}
|
|
if Question and Question.nThreadIndex and Question.nId and Question.Args then
|
|
nThreadIndex = tonumber( Question["nThreadIndex"])
|
|
nId = tonumber( Question["nId"])
|
|
ExecEnvironment = tonumber( Question["ExecEnvironment"])
|
|
local QuestionArgs = Question["Args"]
|
|
if QuestionArgs and QuestionArgs.Mode and QuestionArgs.UID then
|
|
local sUid = QuestionArgs["UID"]
|
|
local sRUID = QuestionArgs["RUID"]
|
|
local nMode = tonumber( QuestionArgs["Mode"])
|
|
_G.WDG = {}
|
|
WDG.REDISID = nRedisConnectionId
|
|
-- esecuzione della corretta modalita'
|
|
EgtOutLog('Ricevuta richiesta calcolo: nThreadIndex=' .. nThreadIndex .. ', nId=' .. nId .. ', UID=' .. sUid .. ', nMode=' .. nMode)
|
|
local Result = {}
|
|
if nMode == QUESTION_MODES.PREVIEW then
|
|
nResult, AnswerArgs = Calc_Preview( QuestionArgs)
|
|
elseif nMode == QUESTION_MODES.BOM then
|
|
nResult, AnswerArgs = Calc_BOM( QuestionArgs)
|
|
elseif nMode == QUESTION_MODES.HARDWARE then
|
|
if QuestionArgs.SubMode then
|
|
local nSubMode = tonumber( QuestionArgs["SubMode"])
|
|
EgtOutLog('SubMode=' .. nSubMode)
|
|
if nSubMode == QUESTION_HARDWARE_SUBMODES.LIST then
|
|
nResult, AnswerArgs = Calc_HardwareList( QuestionArgs, sReadLine)
|
|
elseif nSubMode == QUESTION_HARDWARE_SUBMODES.HARDWAREOPTION then
|
|
nResult, AnswerArgs = Calc_HardwareOptions( QuestionArgs)
|
|
elseif nSubMode == QUESTION_HARDWARE_SUBMODES.SASHSHAPE then
|
|
nResult, AnswerArgs = Calc_SashShape( QuestionArgs)
|
|
elseif nSubMode == QUESTION_HARDWARE_SUBMODES.PROFILEDATAFROMAREA then
|
|
nResult, AnswerArgs = Calc_AreaProfiles( QuestionArgs)
|
|
else
|
|
nResult = 0
|
|
local sErrorMsg = 'Errore! Valore di SubMode errato!'
|
|
AnswerArgs = { Error = sErrorMsg}
|
|
EgtOutLog( sErrorMsg)
|
|
end
|
|
else
|
|
nResult = 0
|
|
local sErrorMsg = 'Errore! Domanda senza SubMode che é obbligatorio!'
|
|
AnswerArgs = { Error = sErrorMsg}
|
|
EgtOutLog( sErrorMsg)
|
|
end
|
|
elseif nMode == QUESTION_MODES.CONFIG then
|
|
if QuestionArgs.SubMode then
|
|
local nSubMode = tonumber( QuestionArgs["SubMode"])
|
|
if nSubMode == QUESTION_CONFIG_SUBMODES.PROFILELIST then
|
|
nResult, AnswerArgs = Calc_ProfileList()
|
|
elseif nSubMode == QUESTION_CONFIG_SUBMODES.THRESHOLDLIST then
|
|
nResult, AnswerArgs = Calc_ThresholdList( QuestionArgs)
|
|
else
|
|
nResult = 0
|
|
local sErrorMsg = 'Errore! Valore di SubMode errato!'
|
|
AnswerArgs = { Error = sErrorMsg}
|
|
EgtOutLog( sErrorMsg)
|
|
end
|
|
else
|
|
nResult = 0
|
|
local sErrorMsg = 'Errore! Domanda senza SubMode che é obbligatorio!'
|
|
AnswerArgs = { Error = sErrorMsg}
|
|
EgtOutLog( sErrorMsg)
|
|
end
|
|
end
|
|
AnswerArgs.UID = sUid
|
|
AnswerArgs.RUID = sRUID or 0
|
|
else
|
|
nResult = 0
|
|
local sErrorMsg = 'Errore! Domanda senza argomenti o senza UID o Mode che sono obbligatori!'
|
|
AnswerArgs = { Error = sErrorMsg}
|
|
EgtOutLog( sErrorMsg)
|
|
end
|
|
else
|
|
nResult = 0
|
|
local sErrorMsg = 'Errore! Formato domanda non riconosciuto o senza nThreadIndex, nId o Args!'
|
|
AnswerArgs = { Error = sErrorMsg}
|
|
EgtOutLog( sErrorMsg)
|
|
end
|
|
-- do risultato
|
|
local Result = { nThreadIndex = nThreadIndex,
|
|
nId = nId,
|
|
ExecEnvironment = ExecEnvironment,
|
|
nResult = nResult,
|
|
Args = AnswerArgs}
|
|
-- invio risposta
|
|
EgtOutLog('Invio risposta: nThreadIndex=' .. nThreadIndex .. ', nId=' .. nId .. ', nResult=' .. nResult)
|
|
local JsonResult = JSON:encode( Result)
|
|
io.stdout:write( "#8376261#" .. JsonResult .. "#8376261#" .. '\n')
|
|
io.stdout:flush()
|
|
EgtOutLog( 'Risposta inviata')
|
|
EgtNewFile()
|
|
end
|
|
else
|
|
if nNilCount >= 20 then
|
|
bRun = false
|
|
EgtOutLog( 'Errore! Lettura da stdin fallita!')
|
|
end
|
|
nNilCount = nNilCount + 1
|
|
EgtPause( 100, true)
|
|
end
|
|
end
|
|
|
|
EgtRedisAsyncDisconnect( nRedisConnectionId) |