1244 lines
45 KiB
ObjectPascal
1244 lines
45 KiB
ObjectPascal
unit uMain;
|
|
|
|
interface
|
|
|
|
uses
|
|
Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
|
|
Dialogs, uMQTTComps, StdCtrls, Grids, BaseGrid, AdvGrid, uMQTT ,
|
|
ExtCtrls, DateUtils, ComCtrls, Menus, ScktComp, inifiles,
|
|
Buttons, ZConnection, MQTT,
|
|
ZAbstractDataset, ZDataset, DB, ZAbstractRODataset, ZAbstractConnection,
|
|
System.JSON, FireDAC.Stan.Intf, FireDAC.Stan.Option, FireDAC.Stan.Error,
|
|
FireDAC.UI.Intf, FireDAC.Phys.Intf, FireDAC.Stan.Def, FireDAC.Stan.Pool,
|
|
FireDAC.Stan.Async, FireDAC.Phys, FireDAC.Stan.Param, FireDAC.DatS,
|
|
FireDAC.DApt.Intf, FireDAC.DApt, FireDAC.Phys.PGDef, FireDAC.VCLUI.Wait,
|
|
FireDAC.Comp.UI, FireDAC.Phys.PG, FireDAC.Comp.DataSet, FireDAC.Comp.Client,
|
|
System.Generics.Collections, System.StrUtils, cxGraphics, cxControls,
|
|
cxLookAndFeels, cxLookAndFeelPainters, cxStyles, cxCustomData, cxFilter,
|
|
cxData, cxDataStorage, cxEdit, cxNavigator, dxDateRanges,
|
|
dxScrollbarAnnotations, cxGridLevel, cxGridCustomTableView, cxGridTableView,
|
|
cxClasses, cxGridCustomView, cxGrid;
|
|
|
|
|
|
|
|
type
|
|
TfrmMain = class(TForm)
|
|
MQTTClient1: TMQTTClient;
|
|
initTimer: TTimer;
|
|
StatusBar1: TStatusBar;
|
|
MainMenu1: TMainMenu;
|
|
File1: TMenuItem;
|
|
Config1: TMenuItem;
|
|
N2: TMenuItem;
|
|
Connect1: TMenuItem;
|
|
Disconnect1: TMenuItem;
|
|
insertTimer: TTimer;
|
|
File2: TMenuItem;
|
|
DebugMode1: TMenuItem;
|
|
N8: TMenuItem;
|
|
ProgramExit1: TMenuItem;
|
|
ZConnection1: TZConnection;
|
|
ZReadOnlyQuery1: TZReadOnlyQuery;
|
|
ZQuery1: TZQuery;
|
|
NILM1: TMenuItem;
|
|
Edit1: TMenuItem;
|
|
N1: TMenuItem;
|
|
Panel2: TPanel;
|
|
Label5: TLabel;
|
|
Label6: TLabel;
|
|
Timer_DateTime: TTimer;
|
|
TrayIcon1: TTrayIcon;
|
|
tmrExit: TTimer;
|
|
FDConnection1: TFDConnection;
|
|
FDQuery1: TFDQuery;
|
|
FDPhysPgDriverLink1: TFDPhysPgDriverLink;
|
|
FDGUIxWaitCursor1: TFDGUIxWaitCursor;
|
|
MQTTClient1_old: TMQTTClient;
|
|
PageControl1: TPageControl;
|
|
TabSheet1: TTabSheet;
|
|
TabSheet2: TTabSheet;
|
|
ListBox1: TListBox;
|
|
Panel1: TPanel;
|
|
Label2: TLabel;
|
|
Label3: TLabel;
|
|
Label4: TLabel;
|
|
cxGrid_NILM: TcxGrid;
|
|
cxGrid_NILM_Tv: TcxGridTableView;
|
|
cxGrid_NILM_Lv: TcxGridLevel;
|
|
cxGrid_NILM_TvColumn1: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn2: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn3: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn4: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn5: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn6: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn7: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn8: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn9: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn10: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn11: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn12: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn13: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn14: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn15: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn16: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn17: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn18: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn19: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn20: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn21: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn22: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn23: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn24: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn25: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn26: TcxGridColumn;
|
|
cxGrid_NILM_TvColumn0: TcxGridColumn;
|
|
|
|
procedure initTimerTimer(Sender: TObject);
|
|
procedure FormClose(Sender: TObject; var Action: TCloseAction);
|
|
procedure Connect1Click(Sender: TObject);
|
|
procedure Disconnect1Click(Sender: TObject);
|
|
procedure FormCreate(Sender: TObject);
|
|
procedure insertTimerTimer(Sender: TObject);
|
|
procedure ListBox1DblClick(Sender: TObject);
|
|
procedure ProgramExit1Click(Sender: TObject);
|
|
procedure DebugMode1Click(Sender: TObject);
|
|
procedure Config1Click(Sender: TObject);
|
|
procedure Edit1Click(Sender: TObject);
|
|
procedure N1Click(Sender: TObject);
|
|
|
|
procedure MQTTClient1ClientID(Sender: TObject; var aClientID: UTF8String);
|
|
procedure MQTTClient1EnableChange(Sender: TObject);
|
|
procedure MQTTClient1Failure(Sender: TObject; aReason: Integer;
|
|
var CloseClient: Boolean);
|
|
procedure MQTTClient1Mon(Sender: TObject; aStr: string);
|
|
procedure MQTTClient1Msg(Sender: TObject; aTopic: UTF8String;
|
|
aMessage: AnsiString; aQos: TMQTTQOSType; aRetained: Boolean);
|
|
procedure MQTTClient1Offline(Sender: TObject; Graceful: Boolean);
|
|
procedure MQTTClient1Online(Sender: TObject);
|
|
procedure Timer_DateTimeTimer(Sender: TObject);
|
|
procedure FormCloseQuery(Sender: TObject; var CanClose: Boolean);
|
|
procedure AppEvtMinimize(Sender: TObject);
|
|
procedure tmrExitTimer(Sender: TObject);
|
|
procedure TrayIcon1DblClick(Sender: TObject);
|
|
private
|
|
{ Private declarations }
|
|
debug_mode : Boolean;
|
|
msg_flaw_stop : boolean;
|
|
dumyTopic : string;
|
|
debug_mode_count, hubPort : integer;
|
|
ExitOk : boolean;
|
|
procedure InsertData(topic : string; msg : AnsiString);
|
|
procedure NILM_Grid_CLear;
|
|
public
|
|
//read_gwid : integer;
|
|
fIOTGW : array [1..max_gw] of TIOTGW;
|
|
fNILM : array [1..max_gw] of TNILM;
|
|
appPath : string;
|
|
dbIP, dbPW, dbUser, dbSchema : string;
|
|
dbIP_PG, dbUser_PG, dbPW_PG, dbSchema_PG : string;
|
|
dbPort, dbPort_PG, brokerPort : integer;
|
|
mqtt_topic, brokerIP, ClientID, mqtt_user, mqtt_pw : string;
|
|
aRetain: Boolean;
|
|
old_NilmID : integer;
|
|
aQos: TMQTTQOSType;
|
|
NILM_ID_List : TList<Integer>;
|
|
|
|
// NILM_Map: TDictionary<Integer, Integer>;
|
|
// NILM_Key, NILM_Value: Integer;
|
|
|
|
function DB_Connect:Boolean;
|
|
function DB_Close:Boolean;
|
|
function xAddSqlMark(velStr: String): String;
|
|
function xAddSqlDoubleMark(velStr: String): string;
|
|
|
|
procedure PrintLog(msg, msgType : String);
|
|
procedure MQTTParsing(data : AnsiString; aTopic : String);
|
|
procedure ClearIOTGW();
|
|
procedure SendMQTT_CtrlCommand(sTopic, sMsg : string);
|
|
procedure insertSQL(sql : string);
|
|
end;
|
|
|
|
var
|
|
frmMain: TfrmMain;
|
|
|
|
implementation
|
|
|
|
{$R *.dfm}
|
|
|
|
uses System.Math, global, uConfigMQTT, uConfigNILM, uDevConfig;
|
|
|
|
procedure TfrmMain.ClearIOTGW();
|
|
var
|
|
p, i : integer;
|
|
begin
|
|
for p:=1 to max_gw do
|
|
begin
|
|
fIOTGW[p]._TOPIC := '';
|
|
for i:=0 to 15 do fIOTGW[p]._DI[i] := false;
|
|
for i:=0 to 7 do fIOTGW[p]._DO[i] := false;
|
|
for i:=0 to 3 do fIOTGW[p]._AI[i] := 0;
|
|
for i:=0 to 9 do fIOTGW[p]._TEMP[i] := 0.0;
|
|
for i:=0 to 9 do fIOTGW[p]._HUMID[i] := 0.0;
|
|
|
|
fIOTGW[p].run_dd := 0;
|
|
fIOTGW[p].run_hh := 0;
|
|
fIOTGW[p].run_mm := 0;
|
|
fIOTGW[p].run_ss := 0;
|
|
|
|
fNILM[p].idxNo := 0;
|
|
fNILM[p]._TOPIC := '';
|
|
fNILM[p]._NAME := '';
|
|
for i:=1 to 3 do
|
|
begin
|
|
fNILM[p]._VALUE.PF[i] := 0.0;
|
|
fNILM[p]._VALUE.Vrms[i] := 0.0;
|
|
fNILM[p]._VALUE.Irms[i] := 0.0;
|
|
fNILM[p]._VALUE._Var[i] := 0.0;
|
|
fNILM[p]._VALUE.Va[i] := 0.0;
|
|
fNILM[p]._VALUE.Pwr[i] := 0.0;
|
|
fNILM[p]._VALUE.Gyro[i] := 0.0;
|
|
fNILM[p]._VALUE.Accel[i] := 0.0;
|
|
end;
|
|
fNILM[p]._VALUE.Total_P := 0.0;
|
|
fNILM[p]._VALUE.Total_Q := 0.0;
|
|
fNILM[p]._VALUE.Total_S := 0.0;
|
|
fNILM[p]._VALUE.Total_PF := 0.0;
|
|
fNILM[p]._VALUE.wh := 0;
|
|
fNILM[p]._VALUE.freq := 0.0;
|
|
fNILM[p]._VALUE.rssi := 0;
|
|
fNILM[p]._VALUE.seq := 0;
|
|
fNILM[p]._VALUE.COMM := 0;
|
|
fNILM[p]._VALUE.wire := '';
|
|
fNILM[p]._VALUE.TempC := 0;
|
|
fNILM[p]._VALUE.TempExt := 0.0;
|
|
fNILM[p]._VALUE.Vibration := 0.0;
|
|
fNILM[p]._VALUE.TiltAngle := 0.0;
|
|
fNILM[p].rcvCount := 0;
|
|
fNILM[p].oldRcvCount := 0;
|
|
end;
|
|
end;
|
|
|
|
procedure TfrmMain.InsertData(topic : string; msg : AnsiString);
|
|
begin
|
|
end;
|
|
|
|
//MQTT 데이터 파싱
|
|
procedure TfrmMain.MQTTClient1ClientID(Sender: TObject;
|
|
var aClientID: UTF8String);
|
|
begin
|
|
PrintLog('ClientID :: ' + aClientID, 'SYS');
|
|
end;
|
|
|
|
procedure TfrmMain.MQTTClient1EnableChange(Sender: TObject);
|
|
begin
|
|
if TMQTTClient(Sender).Enabled then
|
|
printlog('Client is enabled.', 'SYS')
|
|
else
|
|
printlog('Client is disabled.', 'SYS');
|
|
end;
|
|
|
|
procedure TfrmMain.MQTTClient1Failure(Sender: TObject; aReason: Integer;
|
|
var CloseClient: Boolean);
|
|
begin
|
|
printlog('---- Failure Reported ' + FailureNames(aReason), 'SYS');
|
|
end;
|
|
|
|
procedure TfrmMain.MQTTClient1Mon(Sender: TObject; aStr: string);
|
|
begin
|
|
printlog(aStr, 'SYS');
|
|
end;
|
|
|
|
procedure TfrmMain.MQTTClient1Msg(Sender: TObject; aTopic: UTF8String;
|
|
aMessage: AnsiString; aQos: TMQTTQOSType; aRetained: Boolean);
|
|
begin
|
|
try
|
|
if (LeftStr(aMessage,1)='{') and (RightStr(aMessage,1)='}') then
|
|
begin
|
|
PrintLog('Topic : '+Utf8ToAnsi(aTopic)+', Msg='+aMessage, 'DEBUG');
|
|
MQTTParsing(aMessage,Utf8ToAnsi(aTopic));
|
|
end else
|
|
begin
|
|
PrintLog('[Not Entry]Topic : '+Utf8ToAnsi(aTopic), 'DEBUG');
|
|
end;
|
|
except
|
|
on e : exception do
|
|
begin
|
|
printlog('MQTTClient1Msg Error :: '+e.Message, 'SYS');
|
|
end;
|
|
end;
|
|
end;
|
|
|
|
procedure TfrmMain.MQTTClient1Offline(Sender: TObject; Graceful: Boolean);
|
|
begin
|
|
if Graceful then
|
|
begin
|
|
printlog('Client Gracefully Disconnected.', 'SYS');
|
|
end
|
|
else
|
|
begin
|
|
printlog('Client Terminated Unexpectedly.', 'SYS');
|
|
end;
|
|
end;
|
|
|
|
procedure TfrmMain.MQTTClient1Online(Sender: TObject);
|
|
var
|
|
s: TStringList;
|
|
begin
|
|
printlog('Client is online.', 'SYS');
|
|
s := TStringList.Create;
|
|
s.AddObject(mqtt_topic, TObject(aQos));
|
|
MQTTClient1.Subscribe(s);
|
|
s.Free;
|
|
end;
|
|
|
|
procedure TfrmMain.MQTTParsing(data : AnsiString; aTopic : String);
|
|
var
|
|
tempTopic_list : TStringList;
|
|
pf, Vrms, Irms, Var_, Va, Pwr: Single;
|
|
nilmID, ch, k, pIdx : integer;
|
|
grid_rowck : integer;
|
|
devStr, numStr: string;
|
|
ch_c : char;
|
|
|
|
JSONObject, ChObj, TotObj, SlaveObj : TJSONObject;
|
|
ChArr, SlaveArr : TJSONArray;
|
|
jvCh, jvTot: TJSONValue;
|
|
|
|
hasRealVoltage, hasRealPower, hasCurrent : Boolean;
|
|
sumP, sumQ, sumS, maxI, nomV, assPF : Double;
|
|
|
|
function GetValNum(const AObj: TJSONObject; const AKey: string; ADefault: Double = 0.0): Double;
|
|
var LVal: TJSONValue;
|
|
begin
|
|
Result := ADefault;
|
|
if AObj = nil then Exit;
|
|
LVal := AObj.GetValue(AKey);
|
|
if Assigned(LVal) and (not (LVal is TJSONNull)) then
|
|
Result := StrToFloatDef(LVal.Value, ADefault);
|
|
end;
|
|
|
|
function GetValInt(const AObj: TJSONObject; const AKey: string; ADefault: Integer = 0): Integer;
|
|
var LVal: TJSONValue;
|
|
begin
|
|
Result := ADefault;
|
|
if AObj = nil then Exit;
|
|
LVal := AObj.GetValue(AKey);
|
|
if Assigned(LVal) and (not (LVal is TJSONNull)) then
|
|
Result := StrToIntDef(LVal.Value, ADefault);
|
|
end;
|
|
|
|
function GetValInt64(const AObj: TJSONObject; const AKey: string; ADefault: Int64 = 0): Int64;
|
|
var LVal: TJSONValue;
|
|
begin
|
|
Result := ADefault;
|
|
if AObj = nil then Exit;
|
|
LVal := AObj.GetValue(AKey);
|
|
if Assigned(LVal) and (not (LVal is TJSONNull)) then
|
|
Result := StrToInt64Def(LVal.Value, ADefault);
|
|
end;
|
|
|
|
function GetValStr(const AObj: TJSONObject; const AKey, ADefault: string): string;
|
|
var LVal: TJSONValue;
|
|
begin
|
|
Result := ADefault;
|
|
if AObj = nil then Exit;
|
|
LVal := AObj.GetValue(AKey);
|
|
if Assigned(LVal) and (not (LVal is TJSONNull)) then
|
|
Result := LVal.Value;
|
|
end;
|
|
|
|
begin
|
|
try
|
|
if Trim(data) = '' then Exit;
|
|
|
|
InsertData(aTopic, data);
|
|
|
|
JSONObject := TJSONObject.ParseJSONValue(data) as TJSONObject;
|
|
if JSONObject = nil then Exit;
|
|
|
|
tempTopic_list := TStringList.Create;
|
|
try
|
|
nilmID := 0;
|
|
|
|
// 1순위: JSON의 dev 필드 확인 (예: "NILM_001", "NILM_032")
|
|
devStr := GetValStr(JSONObject, 'dev', '');
|
|
if devStr <> '' then
|
|
begin
|
|
numStr := '';
|
|
for ch_c in devStr do
|
|
if ch_c in ['0'..'9'] then numStr := numStr + ch_c;
|
|
nilmID := StrToIntDef(numStr, 0);
|
|
end;
|
|
|
|
// 2순위: 토픽 경로에서 추출
|
|
if nilmID <= 0 then
|
|
begin
|
|
Strsplit('/', aTopic, tempTopic_list);
|
|
if tempTopic_list.Count > 0 then
|
|
begin
|
|
if (tempTopic_list.Strings[tempTopic_list.Count - 1] = 'status') or
|
|
(tempTopic_list.Strings[tempTopic_list.Count - 1] = 'event') then
|
|
begin
|
|
if tempTopic_list.Count > 1 then
|
|
nilmID := StrToIntDef(tempTopic_list.Strings[tempTopic_list.Count - 2], 0);
|
|
end
|
|
else
|
|
begin
|
|
nilmID := StrToIntDef(tempTopic_list.Strings[tempTopic_list.Count - 1], 0);
|
|
end;
|
|
end;
|
|
end;
|
|
|
|
// 특수 토픽 (status, gateway, event) 처리
|
|
if aTopic.EndsWith('/status') then
|
|
begin
|
|
printlog(Format('[노드상태] 장비 %d: online=%s, loss_rate=%s',
|
|
[nilmID, GetValStr(JSONObject, 'online', ''), GetValStr(JSONObject, 'loss_rate', '0')]), 'SYS');
|
|
Exit;
|
|
end
|
|
else if aTopic.EndsWith('/gateway') then
|
|
begin
|
|
printlog(Format('[게이트웨이] %s: online=%s, nodes=%d/%d',
|
|
[GetValStr(JSONObject, 'gw', ''), GetValStr(JSONObject, 'online', ''),
|
|
GetValInt(JSONObject, 'nodes_online', 0), GetValInt(JSONObject, 'nodes_total', 0)]), 'SYS');
|
|
Exit;
|
|
end
|
|
else if aTopic.EndsWith('/event') then
|
|
begin
|
|
printlog(Format('[ALARM] 장비 %d: %s (코드:%d, 값:%.2f)',
|
|
[nilmID, GetValStr(JSONObject, 'name', ''), GetValInt(JSONObject, 'code', 0), GetValNum(JSONObject, 'value', 0.0)]), 'SYS');
|
|
Exit;
|
|
end;
|
|
|
|
if (nilmID <= 0) or (nilmID > max_gw) or (fNILM[nilmID].idxNo <= 0) then Exit;
|
|
|
|
grid_rowck := NILM_ID_List.IndexOf(nilmID);
|
|
|
|
// =========================================================================
|
|
// CASE 1: 최신 표준 단일 규격 (ch 배열 및 total 객체)
|
|
// =========================================================================
|
|
jvCh := JSONObject.GetValue('ch');
|
|
if (jvCh <> nil) and (jvCh is TJSONArray) then
|
|
begin
|
|
ChArr := jvCh as TJSONArray;
|
|
|
|
fNILM[nilmID]._VALUE.seq := GetValInt(JSONObject, 'seq', 0);
|
|
fNILM[nilmID]._VALUE.COMM := GetValInt(JSONObject, 'COMM', 0);
|
|
fNILM[nilmID]._VALUE.rssi := GetValInt(JSONObject, 'rssi', 0);
|
|
fNILM[nilmID]._VALUE.wire := GetValStr(JSONObject, 'wire', '3P4W');
|
|
fNILM[nilmID]._VALUE.freq := GetValNum(JSONObject, 'freq', 60.0);
|
|
fNILM[nilmID]._VALUE.wh := GetValInt64(JSONObject, 'wh', 0);
|
|
|
|
for k := 0 to Min(2, ChArr.Count - 1) do
|
|
begin
|
|
if (ChArr.Items[k] <> nil) and (ChArr.Items[k] is TJSONObject) then
|
|
begin
|
|
ChObj := ChArr.Items[k] as TJSONObject;
|
|
pIdx := k + 1; // 1..3
|
|
fNILM[nilmID]._VALUE.Vrms[pIdx] := GetValNum(ChObj, 'v', 0.0);
|
|
fNILM[nilmID]._VALUE.Irms[pIdx] := GetValNum(ChObj, 'i', 0.0);
|
|
fNILM[nilmID]._VALUE.Pwr[pIdx] := GetValNum(ChObj, 'p', 0.0);
|
|
fNILM[nilmID]._VALUE._Var[pIdx] := GetValNum(ChObj, 'q', 0.0);
|
|
fNILM[nilmID]._VALUE.Va[pIdx] := GetValNum(ChObj, 's', 0.0);
|
|
fNILM[nilmID]._VALUE.PF[pIdx] := GetValNum(ChObj, 'pf', 0.0);
|
|
end;
|
|
end;
|
|
|
|
jvTot := JSONObject.GetValue('total');
|
|
if (jvTot <> nil) and (jvTot is TJSONObject) then
|
|
begin
|
|
TotObj := jvTot as TJSONObject;
|
|
fNILM[nilmID]._VALUE.Total_P := GetValNum(TotObj, 'p', 0.0);
|
|
fNILM[nilmID]._VALUE.Total_Q := GetValNum(TotObj, 'q', 0.0);
|
|
fNILM[nilmID]._VALUE.Total_S := GetValNum(TotObj, 's', 0.0);
|
|
fNILM[nilmID]._VALUE.Total_PF := GetValNum(TotObj, 'pf', 0.0);
|
|
end;
|
|
|
|
// 환경/센서 데이터
|
|
fNILM[nilmID]._VALUE.TempC := GetValNum(JSONObject, 'temperature', GetValNum(JSONObject, 'TempC', fNILM[nilmID]._VALUE.TempC));
|
|
fNILM[nilmID]._VALUE.TempExt := GetValNum(JSONObject, 'tempExt', 0.0);
|
|
fNILM[nilmID]._VALUE.Accel[1] := GetValNum(JSONObject, 'accX', GetValNum(JSONObject, 'aX', fNILM[nilmID]._VALUE.Accel[1]));
|
|
fNILM[nilmID]._VALUE.Accel[2] := GetValNum(JSONObject, 'accY', GetValNum(JSONObject, 'aY', fNILM[nilmID]._VALUE.Accel[2]));
|
|
fNILM[nilmID]._VALUE.Accel[3] := GetValNum(JSONObject, 'accZ', GetValNum(JSONObject, 'aZ', fNILM[nilmID]._VALUE.Accel[3]));
|
|
fNILM[nilmID]._VALUE.Vibration := GetValNum(JSONObject, 'vibration', 0.0);
|
|
fNILM[nilmID]._VALUE.Gyro[1] := GetValNum(JSONObject, 'gyroX', GetValNum(JSONObject, 'gX', fNILM[nilmID]._VALUE.Gyro[1]));
|
|
fNILM[nilmID]._VALUE.Gyro[2] := GetValNum(JSONObject, 'gyroY', GetValNum(JSONObject, 'gY', fNILM[nilmID]._VALUE.Gyro[2]));
|
|
fNILM[nilmID]._VALUE.Gyro[3] := GetValNum(JSONObject, 'gyroZ', GetValNum(JSONObject, 'gZ', fNILM[nilmID]._VALUE.Gyro[3]));
|
|
fNILM[nilmID]._VALUE.TiltAngle := GetValNum(JSONObject, 'tiltAngle', 0.0);
|
|
end
|
|
// =========================================================================
|
|
// CASE 2: 하위 호환 slave_data 구조
|
|
// =========================================================================
|
|
else if JSONObject.GetValue('slave_data') <> nil then
|
|
begin
|
|
SlaveArr := JSONObject.GetValue<TJSONArray>('slave_data');
|
|
if (SlaveArr <> nil) and (SlaveArr.Count > 0) and (SlaveArr.Items[0] is TJSONObject) then
|
|
begin
|
|
SlaveObj := SlaveArr.Items[0] as TJSONObject;
|
|
fNILM[nilmID]._VALUE.seq := GetValInt(SlaveObj, 'seq', 0);
|
|
fNILM[nilmID]._VALUE.COMM := GetValInt(SlaveObj, 'COMM', 0);
|
|
fNILM[nilmID]._VALUE.rssi := GetValInt(SlaveObj, 'rssi', 0);
|
|
fNILM[nilmID]._VALUE.wire := GetValStr(SlaveObj, 'wire', '3P4W');
|
|
fNILM[nilmID]._VALUE.freq := GetValNum(SlaveObj, 'frequency', 60.0);
|
|
fNILM[nilmID]._VALUE.wh := GetValInt64(SlaveObj, 'wh', 0);
|
|
|
|
// A상 (CH 1)
|
|
fNILM[nilmID]._VALUE.PF[1] := GetValNum(SlaveObj, 'power_factor_a', GetValNum(SlaveObj, 'pfA', 0.0));
|
|
fNILM[nilmID]._VALUE.Vrms[1] := GetValNum(SlaveObj, 'vrms_a', GetValNum(SlaveObj, 'voltageA', 0.0));
|
|
fNILM[nilmID]._VALUE.Irms[1] := GetValNum(SlaveObj, 'irms_a', GetValNum(SlaveObj, 'currentA', 0.0));
|
|
fNILM[nilmID]._VALUE.Pwr[1] := GetValNum(SlaveObj, 'active_power_a', GetValNum(SlaveObj, 'wA', 0.0));
|
|
fNILM[nilmID]._VALUE._Var[1] := GetValNum(SlaveObj, 'reactive_power_a', GetValNum(SlaveObj, 'Var_A', 0.0));
|
|
fNILM[nilmID]._VALUE.Va[1] := GetValNum(SlaveObj, 'apparent_power_a', GetValNum(SlaveObj, 'Va_A', 0.0));
|
|
|
|
// B상 (CH 2)
|
|
if fNILM[nilmID]._VALUE.wire <> '3P3W' then
|
|
begin
|
|
fNILM[nilmID]._VALUE.PF[2] := GetValNum(SlaveObj, 'power_factor_b', GetValNum(SlaveObj, 'pfB', 0.0));
|
|
fNILM[nilmID]._VALUE.Vrms[2] := GetValNum(SlaveObj, 'vrms_b', GetValNum(SlaveObj, 'voltageB', 0.0));
|
|
fNILM[nilmID]._VALUE.Irms[2] := GetValNum(SlaveObj, 'irms_b', GetValNum(SlaveObj, 'currentB', 0.0));
|
|
fNILM[nilmID]._VALUE.Pwr[2] := GetValNum(SlaveObj, 'active_power_b', GetValNum(SlaveObj, 'wB', 0.0));
|
|
fNILM[nilmID]._VALUE._Var[2] := GetValNum(SlaveObj, 'reactive_power_b', GetValNum(SlaveObj, 'Var_B', 0.0));
|
|
fNILM[nilmID]._VALUE.Va[2] := GetValNum(SlaveObj, 'apparent_power_b', GetValNum(SlaveObj, 'Va_B', 0.0));
|
|
end;
|
|
|
|
// C상 (CH 3)
|
|
fNILM[nilmID]._VALUE.PF[3] := GetValNum(SlaveObj, 'power_factor_c', GetValNum(SlaveObj, 'pfC', 0.0));
|
|
fNILM[nilmID]._VALUE.Vrms[3] := GetValNum(SlaveObj, 'vrms_c', GetValNum(SlaveObj, 'voltageC', 0.0));
|
|
fNILM[nilmID]._VALUE.Irms[3] := GetValNum(SlaveObj, 'irms_c', GetValNum(SlaveObj, 'currentC', 0.0));
|
|
fNILM[nilmID]._VALUE.Pwr[3] := GetValNum(SlaveObj, 'active_power_c', GetValNum(SlaveObj, 'wC', 0.0));
|
|
fNILM[nilmID]._VALUE._Var[3] := GetValNum(SlaveObj, 'reactive_power_c', GetValNum(SlaveObj, 'Var_C', 0.0));
|
|
fNILM[nilmID]._VALUE.Va[3] := GetValNum(SlaveObj, 'apparent_power_c', GetValNum(SlaveObj, 'Va_C', 0.0));
|
|
|
|
// Total
|
|
fNILM[nilmID]._VALUE.Total_P := GetValNum(SlaveObj, 'total_p', 0.0);
|
|
fNILM[nilmID]._VALUE.Total_Q := GetValNum(SlaveObj, 'total_q', 0.0);
|
|
fNILM[nilmID]._VALUE.Total_S := GetValNum(SlaveObj, 'total_s', 0.0);
|
|
fNILM[nilmID]._VALUE.Total_PF := GetValNum(SlaveObj, 'total_pf', 0.0);
|
|
|
|
// 환경/센서
|
|
fNILM[nilmID]._VALUE.TempC := GetValNum(SlaveObj, 'temperature', GetValNum(SlaveObj, 'TempC', fNILM[nilmID]._VALUE.TempC));
|
|
fNILM[nilmID]._VALUE.Accel[1] := GetValNum(SlaveObj, 'accX', GetValNum(SlaveObj, 'aX', fNILM[nilmID]._VALUE.Accel[1]));
|
|
fNILM[nilmID]._VALUE.Accel[2] := GetValNum(SlaveObj, 'accY', GetValNum(SlaveObj, 'aY', fNILM[nilmID]._VALUE.Accel[2]));
|
|
fNILM[nilmID]._VALUE.Accel[3] := GetValNum(SlaveObj, 'accZ', GetValNum(SlaveObj, 'aZ', fNILM[nilmID]._VALUE.Accel[3]));
|
|
fNILM[nilmID]._VALUE.Gyro[1] := GetValNum(SlaveObj, 'gyroX', GetValNum(SlaveObj, 'gX', fNILM[nilmID]._VALUE.Gyro[1]));
|
|
fNILM[nilmID]._VALUE.Gyro[2] := GetValNum(SlaveObj, 'gyroY', GetValNum(SlaveObj, 'gY', fNILM[nilmID]._VALUE.Gyro[2]));
|
|
fNILM[nilmID]._VALUE.Gyro[3] := GetValNum(SlaveObj, 'gyroZ', GetValNum(SlaveObj, 'gZ', fNILM[nilmID]._VALUE.Gyro[3]));
|
|
end;
|
|
end
|
|
// =========================================================================
|
|
// CASE 3: 구형 CH 분할 포맷 ("CH": "01", "02", "03")
|
|
// =========================================================================
|
|
else if JSONObject.GetValue('CH') <> nil then
|
|
begin
|
|
ch := StrToIntDef(JSONObject.GetValue('CH').Value, 0);
|
|
case ch of
|
|
1, 2, 3:
|
|
begin
|
|
pf := GetValNum(JSONObject, 'PF', 0.0);
|
|
Vrms := GetValNum(JSONObject, 'Vrms', 0.0);
|
|
Irms := GetValNum(JSONObject, 'Irms', 0.0);
|
|
Var_ := GetValNum(JSONObject, 'Var_', 0.0);
|
|
Va := GetValNum(JSONObject, 'Va', 0.0);
|
|
Pwr := GetValNum(JSONObject, 'Pwr', 0.0);
|
|
|
|
fNILM[nilmID]._VALUE.PF[ch] := pf;
|
|
fNILM[nilmID]._VALUE.Vrms[ch] := Vrms;
|
|
fNILM[nilmID]._VALUE.Irms[ch] := Irms;
|
|
fNILM[nilmID]._VALUE._Var[ch] := Var_;
|
|
fNILM[nilmID]._VALUE.Va[ch] := Va;
|
|
fNILM[nilmID]._VALUE.Pwr[ch] := Pwr;
|
|
end;
|
|
4: // MPU 센서 또는 03 채널
|
|
begin
|
|
fNILM[nilmID]._VALUE.Gyro[1] := GetValNum(JSONObject, 'gX', fNILM[nilmID]._VALUE.Gyro[1]);
|
|
fNILM[nilmID]._VALUE.Gyro[2] := GetValNum(JSONObject, 'gY', fNILM[nilmID]._VALUE.Gyro[2]);
|
|
fNILM[nilmID]._VALUE.Gyro[3] := GetValNum(JSONObject, 'gZ', fNILM[nilmID]._VALUE.Gyro[3]);
|
|
fNILM[nilmID]._VALUE.Accel[1] := GetValNum(JSONObject, 'aX', fNILM[nilmID]._VALUE.Accel[1]);
|
|
fNILM[nilmID]._VALUE.Accel[2] := GetValNum(JSONObject, 'aY', fNILM[nilmID]._VALUE.Accel[2]);
|
|
fNILM[nilmID]._VALUE.Accel[3] := GetValNum(JSONObject, 'aZ', fNILM[nilmID]._VALUE.Accel[3]);
|
|
fNILM[nilmID]._VALUE.TempC := GetValNum(JSONObject, 'TempC', fNILM[nilmID]._VALUE.TempC);
|
|
end;
|
|
end;
|
|
end;
|
|
|
|
// =========================================================================
|
|
// 가상 전력 추정 계산 (1-CT 전류 전용 환경 대응)
|
|
// =========================================================================
|
|
hasRealVoltage := (fNILM[nilmID]._VALUE.Vrms[1] > 0) or (fNILM[nilmID]._VALUE.Vrms[2] > 0) or (fNILM[nilmID]._VALUE.Vrms[3] > 0);
|
|
hasRealPower := (fNILM[nilmID]._VALUE.Pwr[1] > 0) or (fNILM[nilmID]._VALUE.Pwr[2] > 0) or (fNILM[nilmID]._VALUE.Pwr[3] > 0) or (fNILM[nilmID]._VALUE.Total_P > 0);
|
|
hasCurrent := (fNILM[nilmID]._VALUE.Irms[1] > 0) or (fNILM[nilmID]._VALUE.Irms[2] > 0) or (fNILM[nilmID]._VALUE.Irms[3] > 0);
|
|
|
|
if hasCurrent and (not hasRealVoltage) and (not hasRealPower) then
|
|
begin
|
|
nomV := 220.0;
|
|
assPF := 0.90;
|
|
sumP := 0.0; sumQ := 0.0; sumS := 0.0; maxI := 0.0;
|
|
for k := 1 to 3 do
|
|
begin
|
|
if fNILM[nilmID]._VALUE.Irms[k] > 0 then
|
|
begin
|
|
fNILM[nilmID]._VALUE.Vrms[k] := nomV;
|
|
fNILM[nilmID]._VALUE.PF[k] := assPF;
|
|
fNILM[nilmID]._VALUE.Va[k] := nomV * fNILM[nilmID]._VALUE.Irms[k];
|
|
fNILM[nilmID]._VALUE.Pwr[k] := fNILM[nilmID]._VALUE.Va[k] * assPF;
|
|
fNILM[nilmID]._VALUE._Var[k] := Sqrt(Max(Sqr(fNILM[nilmID]._VALUE.Va[k]) - Sqr(fNILM[nilmID]._VALUE.Pwr[k]), 0.0));
|
|
sumP := sumP + fNILM[nilmID]._VALUE.Pwr[k];
|
|
sumQ := sumQ + fNILM[nilmID]._VALUE._Var[k];
|
|
sumS := sumS + fNILM[nilmID]._VALUE.Va[k];
|
|
if fNILM[nilmID]._VALUE.Irms[k] > maxI then maxI := fNILM[nilmID]._VALUE.Irms[k];
|
|
end;
|
|
end;
|
|
fNILM[nilmID]._VALUE.Total_P := sumP;
|
|
fNILM[nilmID]._VALUE.Total_Q := sumQ;
|
|
fNILM[nilmID]._VALUE.Total_S := sumS;
|
|
fNILM[nilmID]._VALUE.Total_PF := assPF;
|
|
end;
|
|
|
|
// =========================================================================
|
|
// 3P3W / 3P4W Total 전력 자동 합산 보정
|
|
// =========================================================================
|
|
if (fNILM[nilmID]._VALUE.Total_P = 0) and (fNILM[nilmID]._VALUE.Pwr[1] > 0) then
|
|
begin
|
|
if SameText(fNILM[nilmID]._VALUE.wire, '3P3W') then
|
|
begin
|
|
fNILM[nilmID]._VALUE.Total_P := fNILM[nilmID]._VALUE.Pwr[1] + fNILM[nilmID]._VALUE.Pwr[3];
|
|
fNILM[nilmID]._VALUE.Total_Q := fNILM[nilmID]._VALUE._Var[1] + fNILM[nilmID]._VALUE._Var[3];
|
|
end
|
|
else
|
|
begin
|
|
fNILM[nilmID]._VALUE.Total_P := fNILM[nilmID]._VALUE.Pwr[1] + fNILM[nilmID]._VALUE.Pwr[2] + fNILM[nilmID]._VALUE.Pwr[3];
|
|
fNILM[nilmID]._VALUE.Total_Q := fNILM[nilmID]._VALUE._Var[1] + fNILM[nilmID]._VALUE._Var[2] + fNILM[nilmID]._VALUE._Var[3];
|
|
end;
|
|
fNILM[nilmID]._VALUE.Total_S := Sqrt(Sqr(fNILM[nilmID]._VALUE.Total_P) + Sqr(fNILM[nilmID]._VALUE.Total_Q));
|
|
if fNILM[nilmID]._VALUE.Total_S > 0 then
|
|
fNILM[nilmID]._VALUE.Total_PF := fNILM[nilmID]._VALUE.Total_P / fNILM[nilmID]._VALUE.Total_S;
|
|
end;
|
|
|
|
// 수신 카운트 증가
|
|
fNILM[nilmID].rcvCount := fNILM[nilmID].rcvCount + 1;
|
|
if fNILM[nilmID].rcvCount > 65535 then fNILM[nilmID].rcvCount := 1;
|
|
|
|
// 라벨 캡션 갱신
|
|
Label2.Caption := Format('[ID : %d / CH : 01] PF : %.3f, Vrms : %.3f, Irms : %.3f, Var : %.3f, Va : %.3f, Pwr : %.3f',
|
|
[nilmID, fNILM[nilmID]._VALUE.PF[1], fNILM[nilmID]._VALUE.Vrms[1], fNILM[nilmID]._VALUE.Irms[1],
|
|
fNILM[nilmID]._VALUE._Var[1], fNILM[nilmID]._VALUE.Va[1], fNILM[nilmID]._VALUE.Pwr[1]]);
|
|
Label3.Caption := Format('[ID : %d / CH : 02] PF : %.3f, Vrms : %.3f, Irms : %.3f, Var : %.3f, Va : %.3f, Pwr : %.3f',
|
|
[nilmID, fNILM[nilmID]._VALUE.PF[2], fNILM[nilmID]._VALUE.Vrms[2], fNILM[nilmID]._VALUE.Irms[2],
|
|
fNILM[nilmID]._VALUE._Var[2], fNILM[nilmID]._VALUE.Va[2], fNILM[nilmID]._VALUE.Pwr[2]]);
|
|
Label4.Caption := Format('[ID : %d / MPU] gX : %.3f, gY : %.3f, gZ : %.3f, aX : %.3f, aY : %.3f, aZ : %.3f, Temp : %.2f',
|
|
[nilmID, fNILM[nilmID]._VALUE.Gyro[1], fNILM[nilmID]._VALUE.Gyro[2], fNILM[nilmID]._VALUE.Gyro[3],
|
|
fNILM[nilmID]._VALUE.Accel[1], fNILM[nilmID]._VALUE.Accel[2], fNILM[nilmID]._VALUE.Accel[3], fNILM[nilmID]._VALUE.TempC]);
|
|
|
|
// cxGrid 실시간 반영
|
|
if (PageControl1.TabIndex = 0) and (grid_rowck >= 0) then
|
|
with cxGrid_NILM_Tv.DataController do
|
|
begin
|
|
try
|
|
BeginUpdate;
|
|
// CH 1
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn1.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.PF[1]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn2.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.Vrms[1]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn3.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.Irms[1]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn4.Index] := Format('%.3f', [fNILM[nilmID]._VALUE._Var[1]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn5.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.Va[1]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn6.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.Pwr[1]]);
|
|
|
|
// CH 2
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn7.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.PF[2]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn8.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.Vrms[2]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn9.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.Irms[2]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn10.Index] := Format('%.3f', [fNILM[nilmID]._VALUE._Var[2]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn11.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.Va[2]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn12.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.Pwr[2]]);
|
|
|
|
// CH 3
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn13.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.PF[3]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn14.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.Vrms[3]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn15.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.Irms[3]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn16.Index] := Format('%.3f', [fNILM[nilmID]._VALUE._Var[3]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn17.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.Va[3]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn18.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.Pwr[3]]);
|
|
|
|
// MPU 및 센서
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn19.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.Gyro[1]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn20.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.Gyro[2]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn21.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.Gyro[3]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn22.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.Accel[1]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn23.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.Accel[2]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn24.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.Accel[3]]);
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn25.Index] := Format('%.3f', [fNILM[nilmID]._VALUE.TempC]);
|
|
|
|
// 시각
|
|
Values[grid_rowck, cxGrid_NILM_TvColumn26.Index] := FormatDateTime('yymmdd hhnnss', Now);
|
|
finally
|
|
EndUpdate;
|
|
end;
|
|
end;
|
|
|
|
finally
|
|
tempTopic_list.Free;
|
|
JSONObject.Free;
|
|
end;
|
|
except
|
|
on e: Exception do
|
|
begin
|
|
printlog('MQTTParsing Error :: ' + e.Message, 'SYS');
|
|
end;
|
|
end;
|
|
end;
|
|
|
|
procedure TfrmMain.PrintLog(msg, msgType : string);
|
|
var
|
|
f : TextFile;
|
|
log: TStringList;
|
|
i : integer;
|
|
logfile, buf : string;
|
|
begin
|
|
if ListBox1.Items.Count >= 300 then ListBox1.Items.Clear;
|
|
if msgType = 'DEBUG' then
|
|
begin
|
|
if debug_mode then
|
|
begin
|
|
if not msg_flaw_stop then ListBox1.Items.Insert(0, FormatDateTime('hh:nn:ss :: ',now)+msg);
|
|
end;
|
|
end else if msgType = 'SYS' then
|
|
begin
|
|
ListBox1.Items.Insert(0, FormatDateTime('hh:nn:ss :: ',now)+msg);
|
|
|
|
logfile := '';
|
|
logfile := appPath+'log\'+formatdatetime('yyyymmddhh',now())+'.log';
|
|
|
|
|
|
if FileExists(logfile) then
|
|
begin
|
|
log := TStringList.Create;
|
|
AssignFile(f, logfile);
|
|
reset(f);
|
|
while not eof(f) do
|
|
begin
|
|
ReadLn(f, buf);
|
|
log.Add(buf);
|
|
end;
|
|
log.add(FormatDateTime('hh:nn:ss :: ',now)+msg);
|
|
CloseFile(F);
|
|
|
|
AssignFile(f, logfile);
|
|
rewrite(f);
|
|
for i := 0 to log.Count - 1 do
|
|
begin
|
|
WriteLn(f, log.strings[i]);
|
|
end;
|
|
CloseFile(F);
|
|
log.Free;
|
|
end else
|
|
begin
|
|
log := TStringList.Create;
|
|
log.add(FormatDateTime('hh:nn:ss :: ',now)+msg);
|
|
AssignFile(f, logfile);
|
|
rewrite(f);
|
|
for i := 0 to log.Count - 1 do
|
|
begin
|
|
WriteLn(f, log.strings[i]);
|
|
end;
|
|
CloseFile(F);
|
|
log.Free;
|
|
end;
|
|
|
|
|
|
end;
|
|
end;
|
|
|
|
procedure TfrmMain.initTimerTimer(Sender: TObject);
|
|
var
|
|
ini : TInifile;
|
|
pwd : string;
|
|
begin
|
|
old_NilmID := 0;
|
|
debug_mode := false;
|
|
debug_mode_count := 0;
|
|
msg_flaw_stop := false;
|
|
ListBox1.Clear;
|
|
mqtt_topic := '';
|
|
mqtt_topic := 'QST/NILM/LVDT/#';
|
|
|
|
|
|
pwd := '';
|
|
pwd := appPath+'NILM_Manager.ini';
|
|
if FileExists(pwd) then
|
|
begin
|
|
ini := TInifile.Create(pwd);
|
|
with ini do
|
|
begin
|
|
mqtt_topic := ReadString('MQTT','TOPIC',mqtt_topic);
|
|
brokerIP := ReadString('MQTT','BrokerIP','183.111.125.203');
|
|
brokerPort := ReadInteger('MQTT','BrokerPort',1883);
|
|
ClientID := ReadString('MQTT','ClientID','NILM_1st');
|
|
|
|
mqtt_user := ReadString('MQTT','User','qsentech');
|
|
mqtt_pw := ReadString('MQTT','Password','qsentech!1233');
|
|
|
|
|
|
dbIP := ReadString('DATABASE','IP','192.168.200.199');
|
|
dbUser := ReadString('DATABASE','User','root');
|
|
dbPW := ReadString('DATABASE','PW','1233');
|
|
dbSchema := ReadString('DATABASE','Schema','nilm');
|
|
dbPort := ReadInteger('DATABASE','Port',3306);
|
|
|
|
dbIP_PG := ReadString('DATABASE_PG','IP','192.168.200.199');
|
|
dbUser_PG := ReadString('DATABASE_PG','User','root');
|
|
dbPW_PG := ReadString('DATABASE_PG','PW','54323');
|
|
dbSchema_PG := ReadString('DATABASE_PG','Schema','neol');
|
|
dbPort_PG := ReadInteger('DATABASE_PG','Port',3306);
|
|
|
|
hubPort := ReadInteger('MQTT_HUB','Port',6969);
|
|
end;
|
|
ini.Free;
|
|
end;
|
|
|
|
|
|
Statusbar1.Panels.Items[2].Text := format('%d',[MQTTClient1.Port]);
|
|
Statusbar1.Panels.Items[3].Text := mqtt_topic;
|
|
|
|
MQTTClient1.Activate(false);
|
|
Sleep(300);
|
|
|
|
randomize();
|
|
|
|
MQTTClient1.ClientID := ClientID+'_'+inttostr(random(999999));
|
|
MQTTClient1.Host := brokerIP;
|
|
MQTTClient1.Port := brokerPort;
|
|
MQTTClient1.Username := mqtt_user;
|
|
MQTTClient1.Password := mqtt_pw;
|
|
|
|
MQTTClient1.Activate(true);
|
|
|
|
|
|
// QSENTECH_NILM 서버
|
|
if ZConnection1.Connected then ZConnection1.disConnect();
|
|
Sleep(300);
|
|
ZConnection1.HostName := dbIP;
|
|
ZConnection1.Port := dbPort;
|
|
ZConnection1.User := dbUser;
|
|
ZConnection1.Password := dbPW;
|
|
ZConnection1.Database := dbSchema;
|
|
|
|
try
|
|
if not ZConnection1.Connected then ZConnection1.Connect();
|
|
except
|
|
on e : exception do
|
|
begin
|
|
printlog('Database Connect Error :: '+e.Message, 'DB');
|
|
end;
|
|
end;
|
|
|
|
{
|
|
// NEOL_NILM 서버
|
|
if not DB_Connect then begin
|
|
printlog('Database Connect Error :: PG', 'DB');
|
|
end;
|
|
}
|
|
|
|
frmNILM.ShowNILM();
|
|
|
|
if NILM_ID_List.Count > 0 then begin
|
|
NILM_Grid_CLear;
|
|
end;
|
|
|
|
frmDevConfig.ShowDev();
|
|
insertTimer.Enabled := True;
|
|
|
|
initTimer.Enabled := false;
|
|
|
|
AppEvtMinimize(self);
|
|
end;
|
|
|
|
procedure TfrmMain.NILM_Grid_CLear;
|
|
var
|
|
row_ck, i : Integer;
|
|
begin
|
|
with cxGrid_NILM_Tv.DataController do begin
|
|
try
|
|
BeginUpdate;
|
|
RecordCount := 0;
|
|
finally
|
|
EndUpdate;
|
|
end;
|
|
|
|
try
|
|
BeginUpdate;
|
|
for I := 0 to NILM_ID_List.Count-1 do begin
|
|
row_ck := AppendRecord;
|
|
Values[row_ck,cxGrid_NILM_TvColumn0.Index] := NILM_ID_List[i];
|
|
end;
|
|
finally
|
|
EndUpdate;
|
|
end;
|
|
end;
|
|
end;
|
|
|
|
procedure TfrmMain.FormClose(Sender: TObject; var Action: TCloseAction);
|
|
begin
|
|
if insertTimer.Enabled then insertTimer.Enabled := False;
|
|
if Timer_DateTime.Enabled then Timer_DateTime.Enabled := False;
|
|
|
|
MQTTClient1.Activate(false);
|
|
|
|
if ZConnection1.Connected then ZConnection1.disConnect();
|
|
|
|
NILM_ID_List.Free;
|
|
// NILM_Map.Free;
|
|
end;
|
|
|
|
procedure TfrmMain.FormCloseQuery(Sender: TObject; var CanClose: Boolean);
|
|
begin
|
|
if ExitOk then begin
|
|
CanClose := true;
|
|
end else begin
|
|
CanClose := false;
|
|
case MessageBox(handle, '"예(Y)"를 클릭하면, MQTT Client가 트레이로 최소화 됩니다.'+#$0D#$0A#$0D#$0A+'"아니오(N)"를 클릭하면 프로그램이 종료됩니다. ', 'MQTT Client :: 트레이로 최소화 할까요?', MB_YESNOCANCEL) of
|
|
ID_YES : begin
|
|
TrayIcon1.BalloonTitle := 'MQTT Client 화면을 다시 보려면...';
|
|
TrayIcon1.BalloonHint := '트레이 아이콘을 더블클릭하세요.';
|
|
//TrayIcon1.BalloonFlags := bfInfo;
|
|
AppEvtMinimize(self);
|
|
end;
|
|
ID_NO : begin
|
|
//종료 타이머 시작하고 끝나면 ExitOk~
|
|
tmrExit.Tag := 0;
|
|
tmrExit.Enabled := true;
|
|
end;
|
|
end;//case..
|
|
end;//if~
|
|
end;
|
|
|
|
procedure TfrmMain.AppEvtMinimize(Sender: TObject);
|
|
begin
|
|
Hide;
|
|
WindowState := wsMinimized;
|
|
|
|
TrayIcon1.Visible := True;
|
|
TrayIcon1.Animate := True;
|
|
TrayIcon1.ShowBalloonHint;
|
|
end;
|
|
|
|
procedure TfrmMain.Connect1Click(Sender: TObject);
|
|
begin
|
|
|
|
MQTTClient1.Activate(false);
|
|
|
|
sleep(300);
|
|
|
|
MQTTClient1.Activate(true);
|
|
|
|
end;
|
|
|
|
procedure TfrmMain.Disconnect1Click(Sender: TObject);
|
|
begin
|
|
MQTTClient1.Activate(false);
|
|
|
|
end;
|
|
|
|
procedure TfrmMain.FormCreate(Sender: TObject);
|
|
begin
|
|
NILM_ID_List := TList<Integer>.Create;
|
|
// NILM_Map := TDictionary<Integer, Integer>.Create;
|
|
|
|
Label2.Caption := '';
|
|
Label3.Caption := '';
|
|
Label4.Caption := '';
|
|
|
|
PageControl1.TabIndex := 1;
|
|
|
|
appPath := '';
|
|
appPath := ExtractFilePath(Application.ExeName);
|
|
|
|
if not DirectoryExists(appPath + 'log') then
|
|
if not CreateDir(appPath + 'log') then
|
|
raise Exception.Create('Cannot create ' + appPath + 'log');
|
|
|
|
ClearIOTGW();
|
|
|
|
Label6.Caption := format('시작 시간 : %s', [FormatDateTime('YYYY-MM-DD HH:mm:ss', now)]);
|
|
|
|
end;
|
|
|
|
procedure TfrmMain.SendMQTT_CtrlCommand(sTopic, sMsg : string);
|
|
var
|
|
pTopic : UTF8String;
|
|
begin
|
|
pTopic := '';
|
|
pTopic := sTopic;
|
|
|
|
MQTTClient1.Publish(pTopic, sMsg, aQos, false);
|
|
end;
|
|
|
|
procedure TfrmMain.Timer_DateTimeTimer(Sender: TObject);
|
|
begin
|
|
Label5.Caption := FormatDateTime('YYYY-MM-DD HH:mm:ss', now);
|
|
end;
|
|
|
|
procedure TfrmMain.tmrExitTimer(Sender: TObject);
|
|
begin
|
|
case tmrExit.Tag of
|
|
0 : begin
|
|
tmrExit.Tag := tmrExit.Tag+1;
|
|
end;
|
|
1..4 : tmrExit.Tag := tmrExit.Tag+1;
|
|
5 : begin
|
|
tmrExit.Tag := tmrExit.Tag+1;
|
|
tmrExit.Enabled := false;
|
|
ExitOk := true;
|
|
Close;
|
|
end;
|
|
end;//case..
|
|
end;
|
|
|
|
procedure TfrmMain.TrayIcon1DblClick(Sender: TObject);
|
|
begin
|
|
TrayIcon1.Visible := False;
|
|
Show;
|
|
WindowState := wsNormal;
|
|
Application.BringToFront;
|
|
end;
|
|
|
|
procedure TfrmMain.insertSQL(sql : string);
|
|
begin
|
|
try
|
|
{ 인서트마다 재접속 제거 20250717
|
|
try
|
|
if not ZConnection1.Connected then ZConnection1.Connect();
|
|
if ZConnection1.Connected then
|
|
begin
|
|
ZQuery1.Active := false;
|
|
ZQuery1.SQL.Clear;
|
|
ZQuery1.SQL.Add(sql);
|
|
ZQuery1.ExecSQL;
|
|
end;
|
|
finally
|
|
if ZConnection1.Connected then ZConnection1.Disconnect;
|
|
end;
|
|
}
|
|
|
|
if not ZConnection1.Connected then ZConnection1.Connect();
|
|
if ZConnection1.Connected then
|
|
begin
|
|
ZQuery1.Active := false;
|
|
ZQuery1.SQL.Clear;
|
|
ZQuery1.SQL.Add(sql);
|
|
ZQuery1.ExecSQL;
|
|
end;
|
|
|
|
except
|
|
on e : exception do
|
|
begin
|
|
printlog('[insertSQL()]Database Connect Error :: '+e.Message, 'DB');
|
|
end;
|
|
end;
|
|
end;
|
|
|
|
procedure TfrmMain.insertTimerTimer(Sender: TObject);
|
|
var
|
|
pMsg, S, sql : string;
|
|
pTopic : UTF8String;
|
|
i, p : integer;
|
|
begin
|
|
if debug_mode then
|
|
begin
|
|
Statusbar1.Panels.Items[0].Text := 'DEBUG';
|
|
Inc(debug_mode_count, 1);
|
|
if debug_mode_count > 1800 then // Debug Mode는 30분만 동작한다. CPU 점유률 때문에, 24시간 돌리지 않는다.
|
|
begin
|
|
debug_mode_count := 0;
|
|
debug_mode := false;
|
|
DebugMode1.Checked := debug_mode;
|
|
end;
|
|
end else
|
|
begin
|
|
Statusbar1.Panels.Items[0].Text := 'RUN';
|
|
end;
|
|
|
|
if (MQTTClient1.Online) then
|
|
begin
|
|
Statusbar1.Panels.Items[1].Text := 'CONN';
|
|
// dumyTopic := '';
|
|
// dumyTopic := 'SMART-FARM/QST/MQTT_HUB/PUB/0000';
|
|
// pTopic := '';
|
|
// pTopic := dumyTopic;
|
|
// pMsg := '';
|
|
// S := '';
|
|
// S := formatdatetime('yyyymmddhhnnss',now());
|
|
// pMsg := format('{DATE_TIME=%s}', [S]);;
|
|
// MQTTClient1.Publish(pTopic, pMsg, aQos, false);
|
|
end else
|
|
begin
|
|
Statusbar1.Panels.Items[1].Text := 'DisCON';
|
|
end;
|
|
|
|
// for p:=1 to max_gw do NILM_ID_List
|
|
for i:=0 to NILM_ID_List.Count-1 do
|
|
begin
|
|
p := NILM_ID_List[i];
|
|
if (fNILM[p].rcvCount>0) and (fNILM[p].rcvCount <> fNILM[p].oldRcvCount) then
|
|
begin
|
|
fNILM[p].oldRcvCount := fNILM[p].RcvCount;
|
|
sql := '';
|
|
sql := 'UPDATE nilm_value SET '+
|
|
'pf_1='+floattostr(fNILM[p]._VALUE.PF[1] )+', '+
|
|
'pf_2='+floattostr(fNILM[p]._VALUE.PF[2] )+', '+
|
|
'pf_3='+floattostr(fNILM[p]._VALUE.PF[3] )+', '+
|
|
'Vrms_1='+floattostr(fNILM[p]._VALUE.Vrms[1] )+', '+
|
|
'Vrms_2='+floattostr(fNILM[p]._VALUE.Vrms[2] )+', '+
|
|
'Vrms_3='+floattostr(fNILM[p]._VALUE.Vrms[3] )+', '+
|
|
'Irms_1='+floattostr(fNILM[p]._VALUE.Irms[1] )+', '+
|
|
'Irms_2='+floattostr(fNILM[p]._VALUE.Irms[2] )+', '+
|
|
'Irms_3='+floattostr(fNILM[p]._VALUE.Irms[3] )+', '+
|
|
'Var_1='+floattostr(fNILM[p]._VALUE._Var[1] )+', '+
|
|
'Var_2='+floattostr(fNILM[p]._VALUE._Var[2] )+', '+
|
|
'Var_3='+floattostr(fNILM[p]._VALUE._Var[3] )+', '+
|
|
'Va_1='+floattostr(fNILM[p]._VALUE.Va[1] )+', '+
|
|
'Va_2='+floattostr(fNILM[p]._VALUE.Va[2] )+', '+
|
|
'Va_3='+floattostr(fNILM[p]._VALUE.Va[3] )+', '+
|
|
'Pwr_1='+floattostr(fNILM[p]._VALUE.Pwr[1] )+', '+
|
|
'Pwr_2='+floattostr(fNILM[p]._VALUE.Pwr[2] )+', '+
|
|
'Pwr_3='+floattostr(fNILM[p]._VALUE.Pwr[3] )+', '+
|
|
|
|
'gX='+floattostr(fNILM[p]._VALUE.Gyro[1])+', '+
|
|
'gY='+floattostr(fNILM[p]._VALUE.Gyro[2])+', '+
|
|
'gZ='+floattostr(fNILM[p]._VALUE.Gyro[3])+', '+
|
|
'aX='+floattostr(fNILM[p]._VALUE.Accel[1])+', '+
|
|
'aY='+floattostr(fNILM[p]._VALUE.Accel[2])+', '+
|
|
'aZ='+floattostr(fNILM[p]._VALUE.Accel[3])+', '+
|
|
'TempC='+floattostr(fNILM[p]._VALUE.TempC)+', '+
|
|
'lastUpdate=now()'+
|
|
' WHERE NilmID='+inttostr(p);
|
|
if fNILM[p].idxNo > 0 then insertSQL(sql);
|
|
|
|
sql := '';
|
|
sql := 'INSERT INTO '+format('nilm_%.5d',[fNILM[p].idxNo])+' VALUES(null, '+
|
|
''+inttostr(p)+', '+ // Nilm ID
|
|
''+floattostr(fNILM[p]._VALUE.PF[1] )+', 0, '+
|
|
''+floattostr(fNILM[p]._VALUE.Vrms[1] )+', '+
|
|
''+floattostr(fNILM[p]._VALUE.Irms[1] )+', '+
|
|
''+floattostr(fNILM[p]._VALUE._Var[1] )+', '+
|
|
''+floattostr(fNILM[p]._VALUE.Va[1] )+', '+
|
|
''+floattostr(fNILM[p]._VALUE.Pwr[1] )+', '+
|
|
|
|
''+floattostr(fNILM[p]._VALUE.PF[2] )+', 0, '+
|
|
''+floattostr(fNILM[p]._VALUE.Vrms[2] )+', '+
|
|
''+floattostr(fNILM[p]._VALUE.Irms[2] )+', '+
|
|
''+floattostr(fNILM[p]._VALUE._Var[2] )+', '+
|
|
''+floattostr(fNILM[p]._VALUE.Va[2] )+', '+
|
|
''+floattostr(fNILM[p]._VALUE.Pwr[2] )+', '+
|
|
|
|
''+floattostr(fNILM[p]._VALUE.PF[3] )+', 0, '+
|
|
''+floattostr(fNILM[p]._VALUE.Vrms[3] )+', '+
|
|
''+floattostr(fNILM[p]._VALUE.Irms[3] )+', '+
|
|
''+floattostr(fNILM[p]._VALUE._Var[3] )+', '+
|
|
''+floattostr(fNILM[p]._VALUE.Va[3] )+', '+
|
|
''+floattostr(fNILM[p]._VALUE.Pwr[3] )+', '+
|
|
|
|
''+floattostr(fNILM[p]._VALUE.Gyro[1])+', '+
|
|
''+floattostr(fNILM[p]._VALUE.Gyro[2])+', '+
|
|
''+floattostr(fNILM[p]._VALUE.Gyro[3])+', '+
|
|
''+floattostr(fNILM[p]._VALUE.Accel[1])+', '+
|
|
''+floattostr(fNILM[p]._VALUE.Accel[2])+', '+
|
|
''+floattostr(fNILM[p]._VALUE.Accel[3])+', '+
|
|
''+floattostr(fNILM[p]._VALUE.TempC)+', '+
|
|
'now())';
|
|
if fNILM[p].idxNo > 0 then insertSQL(sql);
|
|
|
|
// PrintLog(IntToStr(i)+' / '+inttostr(p),'SYS');
|
|
|
|
end;
|
|
end;
|
|
end;
|
|
|
|
procedure TfrmMain.ListBox1DblClick(Sender: TObject);
|
|
begin
|
|
msg_flaw_stop := not msg_flaw_stop;
|
|
|
|
end;
|
|
|
|
procedure TfrmMain.ProgramExit1Click(Sender: TObject);
|
|
begin
|
|
frmMain.Close;
|
|
|
|
end;
|
|
|
|
procedure TfrmMain.DebugMode1Click(Sender: TObject);
|
|
begin
|
|
DebugMode1.Checked := not DebugMode1.Checked;
|
|
|
|
debug_mode := DebugMode1.Checked;
|
|
debug_mode_count := 0;
|
|
end;
|
|
|
|
procedure TfrmMain.Config1Click(Sender: TObject);
|
|
begin
|
|
frmConfigMQTT.Show;
|
|
end;
|
|
|
|
procedure TfrmMain.Edit1Click(Sender: TObject);
|
|
begin
|
|
frmNILM.Show;
|
|
end;
|
|
|
|
procedure TfrmMain.N1Click(Sender: TObject);
|
|
begin
|
|
frmDevConfig.Show;
|
|
end;
|
|
|
|
function TfrmMain.DB_Connect:Boolean;
|
|
begin
|
|
FDPhysPgDriverLink1.VendorLib := '.\libpq-10.dll';
|
|
|
|
FDConnection1.Connected := False;
|
|
|
|
FDConnection1.Params.Clear;
|
|
FDConnection1.Params.DriverID := 'PG';
|
|
FDConnection1.Params.Database := Trim(dbSchema_PG);
|
|
FDConnection1.Params.UserName := Trim(dbUser_PG);
|
|
FDConnection1.Params.Password := Trim(dbPW_PG);
|
|
FDConnection1.Params.Add('Server=' + Trim(dbIP_PG));
|
|
FDConnection1.Params.Add('Port=' + Trim(IntToStr(dbPort_PG)));
|
|
FDConnection1.Params.Add('CharacterSet=UTF8');
|
|
|
|
try
|
|
FDConnection1.Connected := True;
|
|
|
|
Result := True;
|
|
// Memo1.Lines.Add('연결 성공');
|
|
// Memo1.Lines.Add('"Q1" 버튼을 누른 후 "쿼리" 버튼을 누르세요!!');
|
|
|
|
except
|
|
on E: Exception do begin
|
|
Result := False;
|
|
// Memo1.Lines.Add('연결 실패: ' + E.Message);
|
|
end;
|
|
end;
|
|
end;
|
|
|
|
function TfrmMain.DB_Close:Boolean;
|
|
begin
|
|
try
|
|
if FDConnection1.Connected then FDConnection1.Connected := False;
|
|
Result := True;
|
|
except
|
|
Result := False;
|
|
end;
|
|
end;
|
|
|
|
function TfrmMain.xAddSqlDoubleMark(velStr: String): string;
|
|
begin
|
|
Result := '';
|
|
Result := '"' + velStr + '"';
|
|
end;
|
|
|
|
function TfrmMain.xAddSqlMark(velStr: String): String;
|
|
begin
|
|
Result := '';
|
|
Result := '''' + velStr + '''';
|
|
end;
|
|
|
|
end.
|