jfmartel/ZT
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Première version fonctionnelle. --- non testée ---

Browse Source
This commit is contained in:
zonetest
2017-07-11 14:01:28 -04:00
parent d08fe76884
commit 630aab922a
11 changed files with 134 additions and 52 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sources/Modbus/ModbusMaster.cpp
+6
View File
@@ -67,11 +67,15 @@ void CModbusMaster::SocketDisconnected()
int CModbusMaster::ReadModbusRegisters()
{
//return SendReadHoldingRegistersRequest(ZT_DATA_BASE_REGISTER_ADDRESS,4); //Read all 3 registers from ZT (2000 - 2003)
return RET_OK;
}
void CModbusMaster::RegistersDatabaseUpdated(quint16 StartAddress, quint16 Length)
{
Q_UNUSED(StartAddress)
Q_UNUSED(Length)
emit ModbusMasterRepositoryUpdated();
qDebug("Database updated with ZT data...");
}
@@ -85,10 +89,12 @@ int CModbusMaster::SendAN1ToZT()
{
//return SendWriteHoldingRegistersRequest(CC_AN1_REGISTER_ADDRESS,1);
//return SendWriteSingleRegisterRequest(CC_AN1_REGISTER_ADDRESS);
return RET_OK;
}
int CModbusMaster::SendAN2ToZT()
{
//return SendWriteHoldingRegistersRequest(CC_AN2_REGISTER_ADDRESS,1);
//return SendWriteSingleRegisterRequest(CC_AN2_REGISTER_ADDRESS);
return RET_OK;
}
sources/Modbus/ModbusTKTransport.cpp
+85 -34
View File
@@ -11,6 +11,7 @@ CModbusTKTransport::CModbusTKTransport(CModbusRepository *Repo)
mMaintenanceMode = mForceZT1Clear = mForceZT2Clear = false;
mZT1TKDataList.clear();
mZT2TKDataList.clear();
mZT1Clear = mZT2Clear = false;
mModbusTKZT1SMState = MODBUS_ZT1_TK_STANDBY_STATE;
mModbusTKZT2SMState = MODBUS_ZT2_TK_STANDBY_STATE;
@@ -24,6 +25,8 @@ CModbusTKTransport::CModbusTKTransport(CModbusRepository *Repo)
mZT2TKStateMachineTimer->setSingleShot(false);
mZT2TKStateMachineTimer->setInterval(0);
connect(mZT2TKStateMachineTimer,SIGNAL(timeout()),this,SLOT(ExecZT2SM()));
ResetAlarmCount(ZTGLOBAL_TYPE_ID);
}
CModbusTKTransport::~CModbusTKTransport()
@@ -53,9 +56,9 @@ int CModbusTKTransport::ClearTK(int ZT)
return RET_ERROR;
}
PannesReg ^= ZT1_V00_ALARM_FLAG_MASK;
PannesReg ^= ZT1_PEQ1_ALARM_FLAG_MASK;
PannesReg ^= ZT1_ALARM_ITI_FLAG_MASK;
PannesReg &= ~ZT1_V00_ALARM_FLAG_MASK;
PannesReg &= ~ZT1_PEQ1_ALARM_FLAG_MASK;
PannesReg &= ~ZT1_ALARM_ITI_FLAG_MASK;
//Clear repo now...
mModbusRepo->WriteMultipleRegs(MODBUS_ZT1_ALARM_DATA_BASE_REG_ADD,Data);
@@ -81,8 +84,8 @@ int CModbusTKTransport::ClearTK(int ZT)
return RET_ERROR;
}
PannesReg ^= ZT2_V02_ALARM_FLAG_MASK;
PannesReg ^= ZT2_PEQ2_ALARM_FLAG_MASK;
PannesReg &= ~ZT2_V02_ALARM_FLAG_MASK;
PannesReg &= ~ZT2_PEQ2_ALARM_FLAG_MASK;
//Clear repo now...
mModbusRepo->WriteMultipleRegs(MODBUS_ZT2_ALARM_DATA_BASE_REG_ADD,Data);
@@ -223,17 +226,17 @@ int CModbusTKTransport::SendTKToCC(int ZT)
}
else if(PPExtIndex == 1)
{
FlagsReg |= ZT1_PP_EXT_FLAG_MASK_1;
FlagsReg |= ZT1_PP_EXT_FLAG_MASK_2;
DataBuf[RegOffset(MODBUS_ZT1_RANK_PP_EXT_2_REG_ADD)] = (qint16)TKData.mRank;
}
else if(PPExtIndex == 2)
{
FlagsReg |= ZT1_PP_EXT_FLAG_MASK_1;
FlagsReg |= ZT1_PP_EXT_FLAG_MASK_3;
DataBuf[RegOffset(MODBUS_ZT1_RANK_PP_EXT_3_REG_ADD)] = (qint16)TKData.mRank;
}
else if(PPExtIndex == 3)
{
FlagsReg |= ZT1_PP_EXT_FLAG_MASK_1;
FlagsReg |= ZT1_PP_EXT_FLAG_MASK_4;
DataBuf[RegOffset(MODBUS_ZT1_RANK_PP_EXT_4_REG_ADD)] = (qint16)TKData.mRank;
}
else
@@ -275,9 +278,9 @@ int CModbusTKTransport::SendTKToCC(int ZT)
PannesReg = DataBuf.at(RegOffset(MODBUS_MISC_DATA_BASE_REG_ADD));
for(int i = 0; i < mZT1TKDataList.size(); i++)
for(int i = 0; i < mZT2TKDataList.size(); i++)
{
CZTDetectionData TKData = mZT1TKDataList.at(i);
CZTDetectionData TKData = mZT2TKDataList.at(i);
switch(TKData.mDetectionID)
{
@@ -330,17 +333,17 @@ int CModbusTKTransport::SendTKToCC(int ZT)
}
else if(PPExtIndex == 1)
{
FlagsReg |= ZT2_PP_EXT_FLAG_MASK_1;
FlagsReg |= ZT2_PP_EXT_FLAG_MASK_2;
DataBuf[RegOffset(MODBUS_ZT2_RANK_PP_EXT_2_REG_ADD)] = (qint16)TKData.mRank;
}
else if(PPExtIndex == 2)
{
FlagsReg |= ZT2_PP_EXT_FLAG_MASK_1;
FlagsReg |= ZT2_PP_EXT_FLAG_MASK_3;
DataBuf[RegOffset(MODBUS_ZT2_RANK_PP_EXT_3_REG_ADD)] = (qint16)TKData.mRank;
}
else if(PPExtIndex == 3)
{
FlagsReg |= ZT2_PP_EXT_FLAG_MASK_1;
FlagsReg |= ZT2_PP_EXT_FLAG_MASK_4;
DataBuf[RegOffset(MODBUS_ZT2_RANK_PP_EXT_4_REG_ADD)] = (qint16)TKData.mRank;
}
else
@@ -354,7 +357,7 @@ int CModbusTKTransport::SendTKToCC(int ZT)
}
//Update the modbus repo to send the alarms...
DataBuf[RegOffset(MODBUS_ZT2_ALARM_RANKS_BASE_ADD)] = FlagsReg;
DataBuf[RegOffset(MODBUS_ZT2_ALARM_DATA_BASE_REG_ADD)] = FlagsReg;
DataBuf[RegOffset(MODBUS_MISC_DATA_BASE_REG_ADD)] = PannesReg;
mModbusRepo->WriteMultipleRegs(MODBUS_ZT_DATA_BASE_REG,DataBuf);
@@ -420,6 +423,11 @@ unsigned int CModbusTKTransport::BeginTKEmission()
mModbusTKZT1SMState = MODBUS_ZT1_TK_SHOW_STATE;
mZT1TKStateMachineTimer->start(0);
}
else if(mMaintenanceMode == true && mModbusTKZT1SMState == MODBUS_ZT1_TK_WAIT_FOR_CLEAR_STATE)
{
//When we are in maintenance mode and we are already sending the alarms, just add the new alarm to the modbus buffer.
SendTKToCC(ZT1_TYPE_ID);
}
}
@@ -434,6 +442,11 @@ unsigned int CModbusTKTransport::BeginTKEmission()
mModbusTKZT2SMState = MODBUS_ZT2_TK_SHOW_STATE;
mZT2TKStateMachineTimer->start(0);
}
else if(mMaintenanceMode == true && mModbusTKZT2SMState == MODBUS_ZT2_TK_WAIT_FOR_CLEAR_STATE)
{
//In maintenance mode, just add the new alarm to the modbus buffer.
SendTKToCC(ZT2_TYPE_ID);
}
}
@@ -451,12 +464,48 @@ unsigned int CModbusTKTransport::SetInputStates(bool AN1State, bool ZT1CDVState,
unsigned int CModbusTKTransport::CancelAllTK()
{
ClearTK(ZT1_TYPE_ID);
ClearTK(ZT2_TYPE_ID);
mModbusTKZT1SMState = MODBUS_ZT1_TK_STANDBY_STATE;
mModbusTKZT2SMState = MODBUS_ZT2_TK_STANDBY_STATE;
mZT1TKDataList.clear();
mZT2TKDataList.clear();
//exec the SM once
mZT1TKStateMachineTimer->start();
mZT2TKStateMachineTimer->start();
ResetAlarmCount(ZTGLOBAL_TYPE_ID);
return RET_OK;
}
unsigned int CModbusTKTransport::CancelMaintenanceCurrentTK()
{
return RET_OK;
int ret = RET_ERROR;
if(mMaintenanceMode == false)
{
return ret;
}
if(mModbusTKZT1SMState == MODBUS_ZT1_TK_WAIT_FOR_CLEAR_STATE)
{
mForceZT1Clear = true;
ret = RET_OK;
}
if(mModbusTKZT2SMState == MODBUS_ZT2_TK_WAIT_FOR_CLEAR_STATE)
{
mForceZT2Clear = true;
ret = RET_OK;
}
return ret;
}
unsigned int CModbusTKTransport::ExitMaintenance()
@@ -550,16 +599,17 @@ void CModbusTKTransport::ExecZT1SM()
{
mZT1TKDataList.clear();
mZT1TKStateMachineTimer->stop();
ResetAlarmCount(ZT1_TYPE_ID);
//In maintenance mode, it is possible to have ZT2 events at the same time
//than ZT1. So if any ZT2 events are waiting in the qeue, send them...
if(mMaintenanceMode)
{
if(mZT2TKDataList.size() > 0)
{
BeginTKEmission();
}
}
// //In maintenance mode, it is possible to have ZT2 events at the same time
// //than ZT1. So if any ZT2 events are waiting in the qeue, send them...
// if(mMaintenanceMode)
// {
// if(mZT2TKDataList.size() > 0)
// {
// BeginTKEmission();
// }
// }
break;
}
@@ -575,7 +625,7 @@ void CModbusTKTransport::ExecZT2SM()
SendTKToCC(ZT2_TYPE_ID); //Mise à jour de la table Modbus avec les données des alarmes actives.
mModbusTKZT1SMState = MODBUS_ZT2_TK_WAIT_FOR_CLEAR_STATE;
mModbusTKZT2SMState = MODBUS_ZT2_TK_WAIT_FOR_CLEAR_STATE;
CZTLog::instance()->AddLogString("Émission des alarmes PCC",true);
for(int i = 0; i < mZT2TKDataList.size(); i++)
@@ -631,16 +681,17 @@ void CModbusTKTransport::ExecZT2SM()
{
mZT2TKDataList.clear();
mZT2TKStateMachineTimer->stop();
ResetAlarmCount(ZT2_TYPE_ID);
//In maintenance mode, it is possible to have ZT1 events at the same time
//than ZT2. So if any ZT1 events are waiting in the qeue, send them...
if(mMaintenanceMode)
{
if(mZT1TKDataList.size() > 0)
{
BeginTKEmission();
}
}
// //In maintenance mode, it is possible to have ZT1 events at the same time
// //than ZT2. So if any ZT1 events are waiting in the qeue, send them...
// if(mMaintenanceMode)
// {
// if(mZT1TKDataList.size() > 0)
// {
// BeginTKEmission();
// }
// }
break;
}
sources/Modbus/ModbusTKTransport.h
+3 -1
View File
@@ -9,6 +9,7 @@
class CModbusTKTransport : public CTKTransportInterface
{
Q_OBJECT
public:
enum eModbusTKSMStates
{
@@ -29,6 +30,7 @@ public:
int SendTKToCC(int ZT);
int ClearTK(int ZT);
unsigned int CancelAllTK();
virtual bool IsZT2TKProcessing();
virtual bool IsZT1TKProcessing();
@@ -38,7 +40,7 @@ public:
virtual unsigned int BeginTKEmission();
virtual unsigned int SetInputStates(bool AN1State, bool ZT1CDVState, bool AN2State, bool ZT2CDVState);
virtual unsigned int CancelAllTK();
virtual unsigned int CancelMaintenanceCurrentTK();
virtual unsigned int ExitMaintenance();
virtual unsigned int EnterMaintenance();