4744 lines
176 KiB
C++
4744 lines
176 KiB
C++
#include "iec104.h"
|
||
|
||
CIEC104ProcessItem::CIEC104ProcessItem()
|
||
{
|
||
apdu_addr = 0;
|
||
apdu_setup = FALSE;
|
||
apdu_setup_sent = FALSE;
|
||
end_of_initialisation = FALSE;
|
||
apdu_ns = 0;
|
||
apdu_nr = 0;
|
||
apdu_ack = 0;
|
||
|
||
apdu_t0_begin = 0;
|
||
apdu_t1_begin = 0;
|
||
apdu_t2_begin = 0;
|
||
apdu_t3_begin = 0;
|
||
apdu_t4_begin = 0;
|
||
apdu_t5_begin = 0;
|
||
|
||
background_scan_begin = 0;
|
||
|
||
apdu_wait_test = FALSE;
|
||
apdu_i_buffer = NULL;
|
||
apdu_unack = NULL;
|
||
apdu_k_max = 12;
|
||
apdu_k = 0;
|
||
apdu_w_max = 8;
|
||
apdu_w = 0;
|
||
|
||
interrogation_type = 0;
|
||
interrogation_start = FALSE; //总召启动
|
||
interrogation_yx_fin = FALSE; //遥信发送完毕
|
||
interrogation_yc_fin = FALSE; //遥测发送完毕
|
||
|
||
pulse_type = 0;
|
||
pulse_start = FALSE;
|
||
pulse_fin = FALSE;
|
||
|
||
clock_synchronized_start = FALSE;
|
||
clock_synchronized_finish = FALSE;
|
||
interrogation_start = FALSE;
|
||
interrogation_finish = FALSE;
|
||
|
||
memset(&ycbws, 0, sizeof(ycbws));
|
||
memset(&yxbws, 0, sizeof(yxbws));
|
||
memset(&events, 0, sizeof(events));
|
||
}
|
||
|
||
CIEC104ProcessItem::~CIEC104ProcessItem()
|
||
{
|
||
apdu_addr = 0;
|
||
apdu_setup = FALSE;
|
||
apdu_setup_sent = FALSE;
|
||
end_of_initialisation = FALSE;
|
||
apdu_ns = 0;
|
||
apdu_nr = 0;
|
||
apdu_ack = 0;
|
||
|
||
apdu_t0_begin = 0;
|
||
apdu_t1_begin = 0;
|
||
apdu_t2_begin = 0;
|
||
apdu_t3_begin = system32.timers;
|
||
apdu_t4_begin = 0;
|
||
apdu_t5_begin = 0;
|
||
|
||
apdu_wait_test = FALSE;
|
||
apdu_k = 0;
|
||
if (apdu_i_buffer)
|
||
{
|
||
delete[] apdu_i_buffer;
|
||
apdu_i_buffer = NULL;
|
||
}
|
||
if (apdu_unack)
|
||
{
|
||
delete[] apdu_unack;
|
||
apdu_unack = NULL;
|
||
}
|
||
apdu_w = 0;
|
||
|
||
interrogation_type = 0;
|
||
interrogation_start = FALSE; //总召启动
|
||
interrogation_yx_fin = FALSE; //遥信发送完毕
|
||
interrogation_yc_fin = FALSE; //遥测发送完毕
|
||
|
||
pulse_type = 0;
|
||
pulse_start = FALSE;
|
||
pulse_fin = FALSE;
|
||
|
||
clock_synchronized_start = FALSE;
|
||
clock_synchronized_finish = FALSE;
|
||
interrogation_start = FALSE;
|
||
interrogation_finish = FALSE;
|
||
|
||
memset(&ycbws, 0, sizeof(ycbws));
|
||
memset(&yxbws, 0, sizeof(yxbws));
|
||
memset(&events, 0, sizeof(events));
|
||
}
|
||
|
||
void CIEC104ProcessItem::Attach(int uid, int sock, DWORD peer_addr, WORD peer_port)
|
||
{
|
||
int i;
|
||
|
||
CNetProcessItem::Attach(uid, sock, peer_addr, peer_port);
|
||
|
||
apdu_setup = FALSE;
|
||
apdu_setup_sent = FALSE;
|
||
apdu_ns = 0;
|
||
apdu_nr = 0;
|
||
apdu_ack = 0;
|
||
|
||
apdu_t1_begin = 0;
|
||
apdu_t2_begin = 0;
|
||
apdu_t3_begin = system32.timers;
|
||
apdu_t4_begin = 0;
|
||
apdu_t5_begin = 0;
|
||
|
||
apdu_wait_test = FALSE;
|
||
|
||
apdu_k = 0;
|
||
if (apdu_i_buffer)
|
||
{
|
||
delete[] apdu_i_buffer;
|
||
apdu_i_buffer = NULL;
|
||
}
|
||
apdu_i_buffer = new APDUBuffer[apdu_k_max];
|
||
memset(apdu_i_buffer, 0, sizeof(APDUBuffer)*apdu_k_max);
|
||
if (apdu_unack)
|
||
{
|
||
delete[] apdu_unack;
|
||
apdu_unack = NULL;
|
||
}
|
||
apdu_unack = new int[apdu_k_max];
|
||
for (i = 0; i < apdu_k_max; i++)
|
||
{
|
||
apdu_unack[i] = i;
|
||
}
|
||
apdu_w = 0;
|
||
|
||
interrogation_type = 0;
|
||
interrogation_start = FALSE; //总召启动
|
||
interrogation_yx_fin = FALSE; //遥信发送完毕
|
||
interrogation_yc_fin = FALSE; //遥测发送完毕
|
||
|
||
pulse_type = 0;
|
||
pulse_start = FALSE;
|
||
pulse_fin = FALSE;
|
||
|
||
clock_synchronized_start = FALSE;
|
||
clock_synchronized_finish = FALSE;
|
||
interrogation_start = FALSE;
|
||
interrogation_finish = FALSE;
|
||
}
|
||
|
||
void CIEC104ProcessItem::Release(void)
|
||
{
|
||
apdu_setup = FALSE;
|
||
apdu_setup_sent = FALSE;
|
||
apdu_ns = 0;
|
||
apdu_nr = 0;
|
||
apdu_ack = 0;
|
||
|
||
apdu_t1_begin = 0;
|
||
apdu_t2_begin = 0;
|
||
apdu_t3_begin = system32.timers;
|
||
apdu_t4_begin = 0;
|
||
apdu_t5_begin = 0;
|
||
|
||
apdu_wait_test = FALSE;
|
||
|
||
apdu_k = 0;
|
||
if (apdu_i_buffer)
|
||
{
|
||
delete[] apdu_i_buffer;
|
||
apdu_i_buffer = NULL;
|
||
}
|
||
if (apdu_unack)
|
||
{
|
||
delete[] apdu_unack;
|
||
apdu_unack = NULL;
|
||
}
|
||
|
||
apdu_w = 0;
|
||
|
||
interrogation_type = 0;
|
||
interrogation_start = FALSE; //总召启动
|
||
interrogation_yx_fin = FALSE; //遥信发送完毕
|
||
interrogation_yc_fin = FALSE; //遥测发送完毕
|
||
|
||
pulse_type = 0;
|
||
pulse_start = FALSE;
|
||
pulse_fin = FALSE;
|
||
|
||
clock_synchronized_start = FALSE;
|
||
clock_synchronized_finish = FALSE;
|
||
interrogation_start = FALSE;
|
||
interrogation_finish = FALSE;
|
||
|
||
CNetProcessItem::Release();
|
||
}
|
||
|
||
CIEC104Process::CIEC104Process()
|
||
{
|
||
asdu_addr_length = 2;
|
||
cot_length = 2;
|
||
info_addr_length = 3;
|
||
|
||
max_frame = 254;
|
||
|
||
apdu_t0_max = 30; //t0的最大值(设定)
|
||
apdu_t1_max = 15; //t1的最大值(设定)
|
||
apdu_t2_max = 10; //t2的最大值(设定)
|
||
apdu_t3_max = 20; //t3的最大值(设定)
|
||
apdu_t4_max = 300; //t4的最大值(设定)
|
||
apdu_t5_max = 900; //t5的最大值(设定)
|
||
background_scan_cycle = 600; //背景扫描时间
|
||
use_cycle_interrogation_command = FALSE; //使用循环总召唤
|
||
|
||
send_start_dt = FALSE; //发送启动帧
|
||
use_send_test = FALSE; //使用发送测试帧
|
||
send_test_type = 0; //发送测试帧类型
|
||
use_send_end_of_initialisation = FALSE;
|
||
use_ns_nr_check = FALSE;
|
||
|
||
last_sec = 0;
|
||
m_yx_start_address = IEC_101_104_YX_START_ADDR;
|
||
m_yc_start_address = IEC_101_104_YC_START_ADDR;
|
||
m_ym_start_address = IEC_101_104_YM_START_ADDR;
|
||
}
|
||
|
||
CIEC104Process::~CIEC104Process()
|
||
{
|
||
}
|
||
|
||
CNetProcessItem *CIEC104Process::CreateItem(int ord)
|
||
{
|
||
return dynamic_cast<CNetProcessItem *>(new CIEC104ProcessItem);
|
||
}
|
||
|
||
void CIEC104Process::DestroyItem(int ord, BOOLEAN bDeleted)
|
||
{
|
||
CIEC104ProcessItem *pItem = (CIEC104ProcessItem *)GetItem(ord);
|
||
if (pItem != NULL && !bDeleted)
|
||
{
|
||
delete pItem;
|
||
return CNetProcess::DestroyItem(ord, TRUE);
|
||
}
|
||
return CNetProcess::DestroyItem(ord, bDeleted);
|
||
}
|
||
|
||
|
||
BOOLEAN CIEC104Process::OnPreCreate(int id)
|
||
{
|
||
if (!CNetProcess::OnPreCreate(id)) return FALSE;
|
||
|
||
if (!GetOption(&m_nOption, sizeof(m_nOption)))
|
||
{
|
||
return FALSE;
|
||
}
|
||
asdu_addr_length = m_nOption.asdu_addr_size;
|
||
cot_length = m_nOption.cot_size;
|
||
info_addr_length = m_nOption.info_addr_size;
|
||
max_frame = 254;
|
||
|
||
apdu_t0_max = m_nOption.t0; //t0的最大值(设定)
|
||
apdu_t1_max = m_nOption.t1; //t1的最大值(设定)
|
||
apdu_t2_max = m_nOption.t2; //t2的最大值(设定)
|
||
apdu_t3_max = m_nOption.t3; //t3的最大值(设定)
|
||
apdu_t4_max = m_nOption.t4; //t4的最大值(设定)
|
||
apdu_t5_max = m_nOption.t5; //t5的最大值(设定)
|
||
background_scan_cycle = m_nOption.background_scan_cycle; //背景扫描时间
|
||
use_cycle_interrogation_command = m_nOption.use_cycle_interrogation_command; //使用循环总召唤
|
||
|
||
send_start_dt = m_nOption.send_start_dt; //发送启动帧
|
||
use_send_test = m_nOption.use_send_test; //使用发送测试帧
|
||
send_test_type = m_nOption.send_test_type; //发送测试帧类型
|
||
use_send_end_of_initialisation = m_nOption.use_send_end_of_initialisation;
|
||
use_ns_nr_check = m_nOption.use_ns_nr_check;
|
||
return TRUE;
|
||
}
|
||
|
||
void CIEC104Process::GetItemYXBWs(CIEC104ProcessItem* pItem)
|
||
{
|
||
int i, uid, count;
|
||
int yxbw_point;
|
||
BOOLEAN yxbw_value;
|
||
BYTE yxbw_qds;
|
||
|
||
if (NULL == pItem) return;
|
||
uid = pItem->GetUnitID();
|
||
if (uid < 0 || uid >= UNIT_NUM) return;
|
||
//if (NULL == pItem->yxbws.data) return;
|
||
count = pItem->yxbws.count;
|
||
if (count < 0 || count >= DATABASE_YXBW_NUM) count = 0;
|
||
int max_count = DATABASE_YXBW_NUM - count;
|
||
for (i = 0; i < max_count; i++)
|
||
{
|
||
yxbw_point = GetUnitYXBW(uid, yxbw_value, yxbw_qds);
|
||
if (yxbw_point < 0) break;
|
||
if (count >= DATABASE_YXBW_NUM) break;
|
||
pItem->yxbws.data[count].order = yxbw_point;
|
||
pItem->yxbws.data[count].value = yxbw_value;
|
||
pItem->yxbws.data[count].qds = yxbw_qds;
|
||
count++;
|
||
}
|
||
pItem->yxbws.count = count;
|
||
}
|
||
|
||
void CIEC104Process::GetItemEvents(CIEC104ProcessItem* pItem)
|
||
{
|
||
int i, uid, count;
|
||
int soe_point;
|
||
BOOLEAN soe_value;
|
||
BYTE soe_qds;
|
||
unionCP56Time soe_time;
|
||
|
||
if (NULL == pItem) return;
|
||
uid = pItem->GetUnitID();
|
||
if (uid < 0 || uid >= UNIT_NUM) return;
|
||
//if (NULL == pItem->events.data) return;
|
||
count = pItem->events.count;
|
||
if (count < 0 || count >= DATABASE_SOE_NUM) count = 0;
|
||
int max_count = DATABASE_SOE_NUM - count;
|
||
for (i = 0; i < max_count; i++)
|
||
{
|
||
soe_point = GetUnitSOE(uid, soe_value, soe_qds, soe_time);
|
||
if (soe_point < 0) break;
|
||
pItem->events.data[count].order = soe_point;
|
||
pItem->events.data[count].value = soe_value;
|
||
pItem->events.data[count].qds = soe_qds;
|
||
memcpy(&pItem->events.data[count].ct, &soe_time, sizeof(soe_time));
|
||
count++;
|
||
}
|
||
pItem->events.count = count;
|
||
}
|
||
|
||
void CIEC104Process::GetItemYCBWs(CIEC104ProcessItem* pItem)
|
||
{
|
||
int i, uid, count;
|
||
|
||
if (NULL == pItem) return;
|
||
uid = pItem->GetUnitID();
|
||
if (uid < 0 || uid >= UNIT_NUM) return;
|
||
//if (NULL == pItem->ycbws.data) return;
|
||
count = pItem->ycbws.count;
|
||
if (count < 0 || count >= pItem->total_yc) count = 0;
|
||
for (i = 0; i < pItem->total_yc; i++)
|
||
{
|
||
if (TRUE == IsUnitYCBW(uid, i))
|
||
{ //有变位产生
|
||
pItem->ycbws.data[count].order = i;
|
||
pItem->ycbws.data[count].value = GetUnitYC(uid, i);
|
||
pItem->ycbws.data[count].flVal = GetUnitYCReal(uid, i);
|
||
pItem->ycbws.data[count].qds = GetUnitYCQDS(uid, i);
|
||
ClearUnitYCBW(uid, i);
|
||
count++;
|
||
}
|
||
}
|
||
pItem->ycbws.count = count;
|
||
}
|
||
|
||
int CIEC104Process::OnPackageReceived(BYTE* pBuf, int count, int ord)
|
||
{
|
||
int uid;
|
||
int len;
|
||
CIEC104ProcessItem* pItem;
|
||
pItem = (CIEC104ProcessItem *)GetItem(ord);
|
||
if (NULL == pItem) return -1;
|
||
uid = pItem->GetUnitID();
|
||
if (uid < 0 || uid >= UNIT_NUM) return -1;
|
||
if (count < 6) return 0;
|
||
if (pBuf[0] != 0x68)
|
||
{ //无效链路报文
|
||
DisplayRxData(pBuf, count, FALSE, uid);
|
||
vLog(LOG_ERROR, "Invalid STX character of 0x%02x.\n", (int)pBuf[0]);
|
||
return -1;
|
||
}
|
||
len = pBuf[1];
|
||
if (count < (len + 2))
|
||
{ //数据长度不足
|
||
return 0;
|
||
}
|
||
//处理接收到的报文
|
||
DisplayRxData(pBuf, (len + 2), TRUE, uid);
|
||
if ((pBuf[2] & 0x01) == 0x00)
|
||
{ //I frame
|
||
WORD ns = (((pBuf[3] << 8) | pBuf[2]) >> 1) & 0x7fff;
|
||
WORD nr = (((pBuf[5] << 8) | pBuf[4]) >> 1) & 0x7fff;
|
||
if (!OnIFrameReceived(ns, nr, &pBuf[6], len-4, ord))
|
||
{
|
||
return -1;
|
||
}
|
||
}
|
||
else if ((pBuf[2] & 0x03) == 0x01)
|
||
{ //S frame
|
||
WORD nr = (((pBuf[5] << 8) | pBuf[4]) >> 1) & 0x7fff;
|
||
if (!OnSFrameReceived(nr, ord))
|
||
{
|
||
return -1;
|
||
}
|
||
}
|
||
else
|
||
{ //U frame
|
||
BOOLEAN STARTDT_ACT = (pBuf[2] & 0x04) == 0x04 ? TRUE : FALSE;
|
||
BOOLEAN STARTDT_CON = (pBuf[2] & 0x08) == 0x08 ? TRUE : FALSE;
|
||
BOOLEAN STOPDT_ACT = (pBuf[2] & 0x10) == 0x10 ? TRUE : FALSE;
|
||
BOOLEAN STOPDT_CON = (pBuf[2] & 0x20) == 0x20 ? TRUE : FALSE;
|
||
BOOLEAN TESTFR_ACT = (pBuf[2] & 0x40) == 0x40 ? TRUE : FALSE;
|
||
BOOLEAN TESTFR_CON = (pBuf[2] & 0x80) == 0x80 ? TRUE : FALSE;
|
||
if (!OnUFrameReceived(STARTDT_ACT, STARTDT_CON, STOPDT_ACT, STOPDT_CON, TESTFR_ACT, TESTFR_CON, ord))
|
||
{
|
||
return -1;
|
||
}
|
||
}
|
||
if (pItem->apdu_setup)
|
||
{ //startdt 后开始喂单元狗
|
||
UnitFeedDog(uid);
|
||
}
|
||
|
||
return (len + 2);
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnDealWithPeerNR(CIEC104ProcessItem* pItem, WORD nr)
|
||
{
|
||
///////此处需要调试一下!!!!
|
||
int i;
|
||
int uid;
|
||
int pos;
|
||
int buffer[256];
|
||
APDUBuffer *pAPDU;
|
||
if (NULL == pItem) return FALSE;
|
||
uid = pItem->GetUnitID();
|
||
if (uid < 0 || uid >= UNIT_NUM) return FALSE;
|
||
|
||
if (!use_ns_nr_check)
|
||
{
|
||
//确认全部的缓冲报文
|
||
pItem->apdu_k = 0;
|
||
pItem->apdu_ack = nr;
|
||
//停止t1计时
|
||
pItem->apdu_t1_begin = 0;
|
||
|
||
return TRUE;
|
||
}
|
||
|
||
if (nr == pItem->apdu_ns)
|
||
{ ///pass
|
||
//确认全部的缓冲报文
|
||
pItem->apdu_k = 0;
|
||
pItem->apdu_ack = nr;
|
||
//停止t1计时
|
||
pItem->apdu_t1_begin = 0;
|
||
}
|
||
else if (pItem->apdu_ack == pItem->apdu_ns)
|
||
{ ///pass
|
||
vLog(LOG_ERROR, "Unit(%d) invalid I frame order(nr=%d,ack=%d,ns=%d).\n", uid, nr, pItem->apdu_ack, pItem->apdu_ns);
|
||
return FALSE;
|
||
}
|
||
else if (pItem->apdu_ack < pItem->apdu_ns)
|
||
{
|
||
if (nr < pItem->apdu_ack || nr > pItem->apdu_ns)
|
||
{ //I帧序列错误,主动断开链路
|
||
vLog(LOG_ERROR, "Unit(%d) invalid I frame order(nr=%d,ack=%d,ns=%d).\n", uid, nr, pItem->apdu_ack, pItem->apdu_ns);
|
||
return FALSE;
|
||
}
|
||
if (nr == pItem->apdu_ack)
|
||
{ //无报文需要确认
|
||
vLog(LOG_DEBUG, "Unit(%d) not ack order(nr=%d,ack=%d,ns=%d).\n", uid, nr, pItem->apdu_ack, pItem->apdu_ns);
|
||
return TRUE;
|
||
}
|
||
//确认ACK至NR之间的缓冲报文(******)
|
||
for (i = 0; i < pItem->apdu_k; i++)
|
||
{
|
||
pos = pItem->apdu_unack[i];
|
||
pAPDU = &pItem->apdu_i_buffer[pos];
|
||
if (pAPDU->NS < pItem->apdu_ack || pAPDU->NS > nr)
|
||
{ //错误的I帧缓冲数据,主动断开链路
|
||
vLog(LOG_ERROR, "Unit(%d) invalid I frame buffer.\n", uid);
|
||
return FALSE;
|
||
}
|
||
if (pAPDU->NS == nr) break;
|
||
}
|
||
if (i >= pItem->apdu_k)
|
||
{ //超出了可能的缓冲数量,缓冲区错误,主动断开链路
|
||
vLog(LOG_ERROR, "Unit(%d) I frame buffer overflow.\n", uid);
|
||
return FALSE;
|
||
}
|
||
//移动缓冲区内的数据
|
||
memcpy(buffer, pItem->apdu_unack, sizeof(int)*pItem->apdu_k_max);
|
||
memcpy(pItem->apdu_unack, &buffer[i], sizeof(int) * (pItem->apdu_k_max - i));
|
||
memcpy(&pItem->apdu_unack[pItem->apdu_k_max - i], buffer, sizeof(int) * i);
|
||
pItem->apdu_k -= i;
|
||
if (pItem->apdu_k != 0)
|
||
{ //更新t1计时
|
||
pAPDU = &pItem->apdu_i_buffer[pItem->apdu_unack[0]];
|
||
pItem->apdu_t1_begin = (DWORD)pAPDU->timer;
|
||
vLog(LOG_DEBUG, "Unit(%d) ack < NS, renew t1 timer to %lu.\n", uid, pAPDU->timer);
|
||
}
|
||
pItem->apdu_ack = nr;
|
||
}
|
||
else if (pItem->apdu_ack > pItem->apdu_ns)
|
||
{ //序列号出现环回的情况
|
||
if (nr > pItem->apdu_ns && nr < pItem->apdu_ack)
|
||
{ //I帧序列错误,主动断开链路
|
||
vLog(LOG_ERROR, "Unit(%d) invalid I frame order(nr=%d,ack=%d,ns=%d).\n", uid, nr, pItem->apdu_ack, pItem->apdu_ns);
|
||
return FALSE;
|
||
}
|
||
if (nr == pItem->apdu_ack)
|
||
{ //无报文需要确认
|
||
vLog(LOG_DEBUG, "Unit(%d) not ack order(nr=%d,ack=%d,ns=%d).\n", uid, nr, pItem->apdu_ack, pItem->apdu_ns);
|
||
return TRUE;
|
||
}
|
||
//确认ACK至NR之间的缓冲报文
|
||
for (i = 0; i < pItem->apdu_k; i++)
|
||
{
|
||
pos = pItem->apdu_unack[i];
|
||
pAPDU = &pItem->apdu_i_buffer[pos];
|
||
if (pAPDU->NS > pItem->apdu_ns && pAPDU->NS < pItem->apdu_ack)
|
||
{ //错误的I帧缓冲数据,主动断开链路
|
||
vLog(LOG_ERROR, "Unit(%d) invalid I frame buffer.\n", uid);
|
||
return FALSE;
|
||
}
|
||
if (pAPDU->NS == nr) break;
|
||
}
|
||
if (i >= pItem->apdu_k)
|
||
{ //超出了可能的缓冲数量,缓冲区错误,主动断开链路
|
||
vLog(LOG_ERROR, "Unit(%d) I frame buffer overflow.\n", uid);
|
||
return FALSE;
|
||
}
|
||
//移动缓冲区内的数据
|
||
memcpy(buffer, pItem->apdu_unack, sizeof(int)*pItem->apdu_k_max);
|
||
memcpy(pItem->apdu_unack, &buffer[i], sizeof(int) * (pItem->apdu_k_max - i));
|
||
memcpy(&pItem->apdu_unack[pItem->apdu_k_max - i], buffer, sizeof(int) * i);
|
||
pItem->apdu_k -= i;
|
||
if (pItem->apdu_k != 0)
|
||
{ //更新t1计时
|
||
pAPDU = &pItem->apdu_i_buffer[pItem->apdu_unack[0]];
|
||
pItem->apdu_t1_begin = (DWORD)pAPDU->timer;
|
||
vLog(LOG_DEBUG, "Unit(%d) ack > NS, renew t1 timer to %lu.\n", uid, pAPDU->timer);
|
||
}
|
||
pItem->apdu_ack = nr;
|
||
}
|
||
return TRUE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnDealWithPeerNS(CIEC104ProcessItem* pItem, WORD ns)
|
||
{
|
||
int uid;
|
||
if (NULL == pItem) return FALSE;
|
||
uid = pItem->GetUnitID();
|
||
if (uid < 0 || uid >= UNIT_NUM) return FALSE;
|
||
|
||
if (!use_ns_nr_check)
|
||
{
|
||
pItem->apdu_nr++;
|
||
pItem->apdu_nr &= 0x7fff;
|
||
return TRUE;
|
||
}
|
||
if (ns != pItem->apdu_nr)
|
||
{ //I帧数据产生丢失,主动断开链路
|
||
vLog(LOG_ERROR, "Unit(%d) I frame lost (%d of %d).\n", uid, pItem->apdu_nr, ns);
|
||
return FALSE;
|
||
}
|
||
pItem->apdu_nr++;
|
||
pItem->apdu_nr &= 0x7fff;
|
||
return TRUE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnSFrameReceived(WORD nr, int ord)
|
||
{
|
||
int uid;
|
||
CIEC104ProcessItem *pItem = (CIEC104ProcessItem *)GetItem(ord);
|
||
if (NULL == pItem) return FALSE;
|
||
uid = pItem->GetUnitID();
|
||
if (uid < 0 || uid >= UNIT_NUM) return FALSE;
|
||
//重置t3计时
|
||
pItem->apdu_t3_begin = system32.timers;
|
||
|
||
//assouan
|
||
vLog(LOG_DEBUG, "Unit(%d) On S Frame Received nr = %d\n", uid, (int)nr);
|
||
return OnDealWithPeerNR(pItem, nr);
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnIFrameReceived(WORD ns, WORD nr, BYTE* pBuf, int count, int ord)
|
||
{
|
||
return TRUE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnUFrameReceived(BOOLEAN STARTDT_ACT, BOOLEAN STARTDT_CON, BOOLEAN STOPDT_ACT, BOOLEAN STOPDT_CON, BOOLEAN TESTFR_ACT, BOOLEAN TESTFR_CON, int ord)
|
||
{
|
||
return TRUE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::SendUFrame(BOOLEAN STARTDT_ACT, BOOLEAN STARTDT_CON, BOOLEAN STOPDT_ACT, BOOLEAN STOPDT_CON, BOOLEAN TESTFR_ACT, BOOLEAN TESTFR_CON, int ord)
|
||
{
|
||
int uid;
|
||
BYTE buffer[6];
|
||
CIEC104ProcessItem* pItem = (CIEC104ProcessItem *)GetItem(ord);
|
||
if (NULL == pItem) return FALSE;
|
||
uid = (int)pItem->GetUnitID();
|
||
if (uid < 0 || uid >= UNIT_NUM) return FALSE;
|
||
memset(buffer, 0, sizeof(buffer));
|
||
buffer[0] = 0x68;
|
||
buffer[1] = 0x04;
|
||
buffer[2] = 0x03 | (STARTDT_ACT ? 0x04 : 0x00) | (STARTDT_CON ? 0x08 : 0x00) |
|
||
(STOPDT_ACT ? 0x10 : 0x00) | (STOPDT_CON ? 0x20 : 0x00) |
|
||
(TESTFR_ACT ? 0x40 : 0x00) | (TESTFR_CON ? 0x80 : 0x00);
|
||
if (!WriteData(buffer, 6, ord))
|
||
{
|
||
vLog(LOG_ERROR, "Unit(%d) Send U Frame Write Data Error.\n", uid);
|
||
return FALSE;
|
||
}
|
||
DisplayTxData(buffer, 6, TRUE, uid);
|
||
return TRUE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::SendIFrame(BYTE *pBuf, int len, int ord)
|
||
{
|
||
int uid;
|
||
int pos;
|
||
APDUBuffer *pAPDU;
|
||
CIEC104ProcessItem* pItem = (CIEC104ProcessItem *)GetItem(ord);
|
||
if (NULL == pItem) return FALSE;
|
||
uid = (int)pItem->GetUnitID();
|
||
//是否达到k值(若达到k值则不应再发送)
|
||
if (pItem->apdu_k >= pItem->apdu_k_max)
|
||
{
|
||
vLog(LOG_WARN, "Unit(%d) reached k value of %d, blocked!\n", uid, pItem->apdu_k);
|
||
return FALSE;
|
||
}
|
||
//取得当前缓冲区位置
|
||
pos = pItem->apdu_unack[pItem->apdu_k];
|
||
pAPDU = &pItem->apdu_i_buffer[pos];
|
||
pItem->apdu_k++;
|
||
//组装I帧报文
|
||
pAPDU->NS = pItem->apdu_ns;
|
||
memset(pAPDU->data, 0, sizeof(pAPDU->data));
|
||
pAPDU->data[0] = 0x68;
|
||
pAPDU->data[1] = (len + 4);
|
||
pAPDU->data[2] = (BYTE)((pItem->apdu_ns << 1) & 0x00ff);
|
||
pAPDU->data[3] = (BYTE)(((pItem->apdu_ns << 1) >> 8) & 0x00ff);
|
||
pAPDU->data[4] = (BYTE)((pItem->apdu_nr << 1) & 0x00ff);
|
||
pAPDU->data[5] = (BYTE)(((pItem->apdu_nr << 1) >> 8) & 0x00ff);
|
||
memcpy(&pAPDU->data[6], pBuf, len);
|
||
pAPDU->length = len+6;
|
||
|
||
int sent = WriteData(pAPDU->data, len+6, ord);
|
||
if (sent <= 0)
|
||
{
|
||
vLog(LOG_ERROR, "Unit(%d) Send I Frame Write Data Error.\n", uid);
|
||
return FALSE;
|
||
}
|
||
DisplayTxData(pAPDU->data, len+6, TRUE, uid);
|
||
|
||
pAPDU->timer = system32.timers;
|
||
//清除t2计时
|
||
pItem->apdu_t2_begin = 0;
|
||
pItem->apdu_w = 0;
|
||
//启动t1计时
|
||
if (pItem->apdu_t1_begin == 0)
|
||
{
|
||
pItem->apdu_t1_begin = (DWORD)pAPDU->timer;
|
||
}
|
||
pItem->apdu_ns++; pItem->apdu_ns &= 0x7fff;
|
||
return TRUE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::SendSFrame(int ord)
|
||
{
|
||
int uid;
|
||
BYTE buffer[6];
|
||
CIEC104ProcessItem* pItem = (CIEC104ProcessItem *)GetItem(ord);
|
||
if (NULL == pItem) return FALSE;
|
||
uid = (int)pItem->GetUnitID();
|
||
memset(buffer, 0, sizeof(buffer));
|
||
buffer[0] = 0x68;
|
||
buffer[1] = 0x04;
|
||
buffer[2] = 0x01;
|
||
buffer[3] = 0x00;
|
||
buffer[4] = (BYTE)((pItem->apdu_nr << 1) & 0x00ff);
|
||
buffer[5] = (BYTE)(((pItem->apdu_nr << 1) >> 8) & 0x00ff);
|
||
if (!WriteData(buffer, 6, ord))
|
||
{
|
||
vLog(LOG_ERROR, "Unit(%d) Send S Frame Write Data Error.\n", uid);
|
||
return FALSE;
|
||
}
|
||
DisplayTxData(buffer, 6, TRUE, uid);
|
||
//清除t2计时
|
||
pItem->apdu_t2_begin = 0;
|
||
pItem->apdu_w = 0;
|
||
return TRUE;
|
||
}
|
||
|
||
//host begin
|
||
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveSingle_point_information(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //单点遥信
|
||
{
|
||
BYTE* pData = pBuf;
|
||
int point;
|
||
|
||
if (IEC_101_104_COT_BACK == (cot & 0x3f) || IEC_101_104_COT_SPONT == (cot & 0x3f) ||
|
||
IEC_101_104_COT_REQ == (cot & 0x3f) || IEC_101_104_COT_RETREM == (cot & 0x3f) ||
|
||
IEC_101_104_COT_RETLOC == (cot & 0x3f) || IEC_101_104_COT_INTERROGATION == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO1 == (cot & 0x3f) || IEC_101_104_COT_INRO2 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO3 == (cot & 0x3f) || IEC_101_104_COT_INRO4 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO5 == (cot & 0x3f) || IEC_101_104_COT_INRO6 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO7 == (cot & 0x3f) || IEC_101_104_COT_INRO8 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO9 == (cot & 0x3f) || IEC_101_104_COT_INRO10 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO11 == (cot & 0x3f) || IEC_101_104_COT_INRO12 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO13 == (cot & 0x3f) || IEC_101_104_COT_INRO14 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO15 == (cot & 0x3f) || IEC_101_104_COT_INRO16 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_PER_CYC == (cot & 0x3f))
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
|
||
DWORD i;
|
||
DWORD information_address;
|
||
BOOLEAN value;
|
||
BYTE qds;
|
||
BYTE ioa[4];
|
||
if (sq) //顺序寻址
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
for (i = 0; i < num; i++, information_address++)
|
||
{
|
||
value = (*pData & 0x01) == 0x01 ? TRUE : FALSE;
|
||
qds = (*pData & 0xf0); pData++;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
|
||
point = GetUnitYXPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYX(uid, point, value, FALSE, qds);
|
||
}
|
||
}
|
||
}
|
||
else //单一寻址自动生成YXBW信号
|
||
{
|
||
for (i = 0; i < num; i++)
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
value = (*pData & 0x01) == 0x01 ? TRUE : FALSE;
|
||
qds = (*pData & 0xf0); pData++;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
|
||
point = GetUnitYXPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYX(uid, point, value, TRUE, qds);
|
||
}
|
||
}
|
||
}
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveSingle_point_information_with_time_tag(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //带时标的单点遥信
|
||
{
|
||
BYTE* pData = pBuf;
|
||
int point;
|
||
|
||
if (IEC_101_104_COT_SPONT == (cot & 0x3f) || IEC_101_104_COT_REQ == (cot & 0x3f) ||
|
||
IEC_101_104_COT_RETREM == (cot & 0x3f) || IEC_101_104_COT_RETLOC == (cot & 0x3f))
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
if (sq) return FALSE; //顺序寻址
|
||
|
||
DWORD i;
|
||
DWORD information_address;
|
||
BOOLEAN value;
|
||
BYTE qds;
|
||
BYTE ioa[4];
|
||
unionCP56Time st;
|
||
|
||
memcpy(&st, &system32.now, sizeof(st));
|
||
for (i = 0; i < num; i++)
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
value = (*pData & 0x01) == 0x01 ? TRUE : FALSE;
|
||
qds = (*pData & 0xf0); pData++;
|
||
st.millisecond = *pData; pData++;
|
||
st.millisecond |= (*pData << 8); pData++;
|
||
st.minute = *pData & 0x3f;
|
||
st.IV = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYXPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYX(uid, point, value, TRUE, qds);
|
||
SetUnitSOE(uid, point, value, st);
|
||
}
|
||
}
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveDouble_point_information(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //双点遥信
|
||
{
|
||
BYTE* pData = pBuf;
|
||
int point;
|
||
|
||
if (IEC_101_104_COT_BACK == (cot & 0x3f) || IEC_101_104_COT_SPONT == (cot & 0x3f) ||
|
||
IEC_101_104_COT_REQ == (cot & 0x3f) || IEC_101_104_COT_RETREM == (cot & 0x3f) ||
|
||
IEC_101_104_COT_RETLOC == (cot & 0x3f) || IEC_101_104_COT_INTERROGATION == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO1 == (cot & 0x3f) || IEC_101_104_COT_INRO2 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO3 == (cot & 0x3f) || IEC_101_104_COT_INRO4 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO5 == (cot & 0x3f) || IEC_101_104_COT_INRO6 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO7 == (cot & 0x3f) || IEC_101_104_COT_INRO8 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO9 == (cot & 0x3f) || IEC_101_104_COT_INRO10 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO11 == (cot & 0x3f) || IEC_101_104_COT_INRO12 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO13 == (cot & 0x3f) || IEC_101_104_COT_INRO14 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO15 == (cot & 0x3f) || IEC_101_104_COT_INRO16 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_PER_CYC == (cot & 0x3f) )
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
|
||
DWORD i;
|
||
DWORD information_address;
|
||
BOOLEAN value;
|
||
BYTE qds;
|
||
BYTE ioa[4];
|
||
if (sq) //顺序寻址
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
for (i = 0; i < num; i++, information_address++)
|
||
{
|
||
value = (*pData & 0x03) == 0x02 ? TRUE : FALSE;
|
||
qds = (*pData & 0xf0);
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYXPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYX(uid, point, value, FALSE, qds);
|
||
}
|
||
}
|
||
}
|
||
else //单一寻址自动生成YXBW信号
|
||
{
|
||
for (i = 0; i < num; i++)
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
value = (*pData & 0x03) == 0x02 ? TRUE : FALSE;
|
||
qds = (*pData & 0xf0);
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYXPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYX(uid, point, value, TRUE, qds);
|
||
}
|
||
}
|
||
}
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveDouble_point_information_with_time_tag(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //带时标的双点遥信
|
||
{
|
||
BYTE* pData = pBuf;
|
||
int point;
|
||
|
||
if (IEC_101_104_COT_SPONT == (cot & 0x3f) || IEC_101_104_COT_REQ == (cot & 0x3f) ||
|
||
IEC_101_104_COT_RETREM == (cot & 0x3f) || IEC_101_104_COT_RETLOC == (cot & 0x3f))
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
if (sq) return FALSE; //顺序寻址
|
||
|
||
DWORD i;
|
||
DWORD information_address;
|
||
BOOLEAN value;
|
||
BYTE qds;
|
||
BYTE ioa[4];
|
||
unionCP56Time st;
|
||
|
||
memcpy(&st, &system32.now, sizeof(st));
|
||
for (i = 0; i < num; i++)
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
value = (*pData & 0x03) == 0x02 ? TRUE : FALSE;
|
||
qds = (*pData & 0xf0); pData++;
|
||
st.millisecond = *pData; pData++;
|
||
st.millisecond |= (*pData << 8); pData++;
|
||
st.minute = *pData & 0x3f;
|
||
st.IV = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYXPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYX(uid, point, value, TRUE, qds);
|
||
SetUnitSOE(uid, point, value, st);
|
||
}
|
||
}
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveMeasured_value_normalised(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //测量值，归一化值
|
||
{
|
||
BYTE* pData = pBuf;
|
||
int point;
|
||
|
||
if (IEC_101_104_COT_PER_CYC == (cot & 0x3f) || IEC_101_104_COT_BACK == (cot & 0x3f) ||
|
||
IEC_101_104_COT_SPONT == (cot & 0x3f) || IEC_101_104_COT_REQ == (cot & 0x3f) ||
|
||
IEC_101_104_COT_RETREM == (cot & 0x3f) || IEC_101_104_COT_RETLOC == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INTERROGATION == (cot & 0x3f) || IEC_101_104_COT_INRO1 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO2 == (cot & 0x3f) || IEC_101_104_COT_INRO3 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO4 == (cot & 0x3f) || IEC_101_104_COT_INRO5 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO6 == (cot & 0x3f) || IEC_101_104_COT_INRO7 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO8 == (cot & 0x3f) || IEC_101_104_COT_INRO9 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO10 == (cot & 0x3f) || IEC_101_104_COT_INRO11 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO12 == (cot & 0x3f) || IEC_101_104_COT_INRO13 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO14 == (cot & 0x3f) || IEC_101_104_COT_INRO15 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO16 == (cot & 0x3f))
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
|
||
DWORD i;
|
||
DWORD information_address;
|
||
short value;
|
||
BYTE qds;
|
||
BYTE ioa[4];
|
||
|
||
if (sq) //顺序寻址
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
for (i = 0; i < num; i++, information_address++)
|
||
{
|
||
value = *pData; pData++;
|
||
value |= (*pData << 8); pData++;
|
||
qds = (*pData & 0xf1); pData++;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYCPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYC(uid, point, (LONG)value, qds);
|
||
}
|
||
}
|
||
}
|
||
else //单一寻址
|
||
{
|
||
for (i = 0; i < num; i++)
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
value = *pData; pData++;
|
||
value |= (*pData << 8); pData++;
|
||
qds = (*pData & 0xf1); pData++;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYCPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYC(uid, point, (LONG)value, qds);
|
||
}
|
||
}
|
||
}
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveMeasured_value_normalised_with_time_tag(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //带时标的遥测量，归一化值
|
||
{
|
||
BYTE* pData = pBuf;
|
||
int point;
|
||
|
||
if (IEC_101_104_COT_SPONT == (cot & 0x3f) || IEC_101_104_COT_REQ == (cot & 0x3f))
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
if (sq) return FALSE; //顺序寻址
|
||
|
||
DWORD i;
|
||
DWORD information_address;
|
||
short value;
|
||
BYTE qds;
|
||
BYTE ioa[4];
|
||
unionCP56Time st;
|
||
|
||
memcpy(&st, &system32.now, sizeof(st));
|
||
for (i = 0; i < num; i++)
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
value = *pData; pData++;
|
||
value |= (*pData << 8); pData++;
|
||
qds = (*pData & 0xf1); pData++;
|
||
st.millisecond = *pData; pData++;
|
||
st.millisecond |= (*pData << 8); pData++;
|
||
st.minute = *pData & 0x3f;
|
||
st.IV = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYCPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYC(uid, point, (LONG)value, qds);
|
||
}
|
||
}
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveMeasured_value_scaled(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //测量值，标度化值
|
||
{
|
||
BYTE* pData = pBuf;
|
||
int point;
|
||
|
||
if (IEC_101_104_COT_PER_CYC == (cot & 0x3f) || IEC_101_104_COT_BACK == (cot & 0x3f) ||
|
||
IEC_101_104_COT_SPONT == (cot & 0x3f) || IEC_101_104_COT_REQ == (cot & 0x3f) ||
|
||
IEC_101_104_COT_RETREM == (cot & 0x3f) || IEC_101_104_COT_RETLOC == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INTERROGATION == (cot & 0x3f) || IEC_101_104_COT_INRO1 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO2 == (cot & 0x3f) || IEC_101_104_COT_INRO3 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO4 == (cot & 0x3f) || IEC_101_104_COT_INRO5 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO6 == (cot & 0x3f) || IEC_101_104_COT_INRO7 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO8 == (cot & 0x3f) || IEC_101_104_COT_INRO9 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO10 == (cot & 0x3f) || IEC_101_104_COT_INRO11 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO12 == (cot & 0x3f) || IEC_101_104_COT_INRO13 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO14 == (cot & 0x3f) || IEC_101_104_COT_INRO15 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO16 == (cot & 0x3f))
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
|
||
DWORD i;
|
||
DWORD information_address;
|
||
short value;
|
||
BYTE qds;
|
||
BYTE ioa[4];
|
||
|
||
if (sq) //顺序寻址
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
for (i = 0; i < num; i++, information_address++)
|
||
{
|
||
value = *pData; pData++;
|
||
value |= (*pData << 8); pData++;
|
||
qds = (*pData & 0xf1); pData++;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYCPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYC(uid, point, (LONG)value, qds);
|
||
}
|
||
}
|
||
}
|
||
else //单一寻址
|
||
{
|
||
for (i = 0; i < num; i++)
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
value = *pData; pData++;
|
||
value |= (*pData << 8); pData++;
|
||
qds = (*pData & 0xf1); pData++;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYCPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYC(uid, point, (LONG)value, qds);
|
||
}
|
||
}
|
||
}
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveMeasured_value_scaled_with_time_tag(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //带时标的遥测量，标度化值
|
||
{
|
||
BYTE* pData = pBuf;
|
||
int point;
|
||
|
||
if (IEC_101_104_COT_SPONT == (cot & 0x3f) || IEC_101_104_COT_REQ == (cot & 0x3f))
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
if (sq) return FALSE; //顺序寻址
|
||
|
||
DWORD i;
|
||
DWORD information_address;
|
||
short value;
|
||
BYTE qds;
|
||
BYTE ioa[4];
|
||
unionCP56Time st;
|
||
|
||
memcpy(&st, &system32.now, sizeof(st));
|
||
for (i = 0; i < num; i++)
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
value = *pData; pData++;
|
||
value |= (*pData << 8); pData++;
|
||
qds = (*pData & 0xf1); pData++;
|
||
st.millisecond = *pData; pData++;
|
||
st.millisecond |= (*pData << 8); pData++;
|
||
st.minute = *pData & 0x3f;
|
||
st.IV = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYCPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYC(uid, point, (LONG)value, qds);
|
||
}
|
||
}
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveMeasured_value_short_floating_point(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //测量值，短浮点数
|
||
{
|
||
BYTE* pData = pBuf;
|
||
int point;
|
||
|
||
if (IEC_101_104_COT_PER_CYC == (cot & 0x3f) || IEC_101_104_COT_BACK == (cot & 0x3f) ||
|
||
IEC_101_104_COT_SPONT == (cot & 0x3f) || IEC_101_104_COT_REQ == (cot & 0x3f) ||
|
||
IEC_101_104_COT_RETREM == (cot & 0x3f) || IEC_101_104_COT_RETLOC == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INTERROGATION == (cot & 0x3f) || IEC_101_104_COT_INRO1 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO2 == (cot & 0x3f) || IEC_101_104_COT_INRO3 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO4 == (cot & 0x3f) || IEC_101_104_COT_INRO5 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO6 == (cot & 0x3f) || IEC_101_104_COT_INRO7 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO8 == (cot & 0x3f) || IEC_101_104_COT_INRO9 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO10 == (cot & 0x3f) || IEC_101_104_COT_INRO11 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO12 == (cot & 0x3f) || IEC_101_104_COT_INRO13 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO14 == (cot & 0x3f) || IEC_101_104_COT_INRO15 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO16 == (cot & 0x3f))
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
|
||
DWORD i;
|
||
DWORD information_address;
|
||
DWORD dwValue;
|
||
float fValue;
|
||
BYTE qds;
|
||
BYTE ioa[4];
|
||
|
||
if (sq) //顺序寻址
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
for (i = 0; i < num; i++, information_address++)
|
||
{
|
||
dwValue = (DWORD)((pData[3] << 24) | (pData[2] << 16) | (pData[1] << 8) | pData[0]);
|
||
pData += 4;
|
||
memcpy(&fValue, &dwValue, sizeof(DWORD));
|
||
qds = (*pData & 0xf1); pData++;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYCPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYC(uid, point, fValue, qds);
|
||
}
|
||
}
|
||
}
|
||
else //单一寻址
|
||
{
|
||
for (i = 0; i < num; i++)
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
dwValue = (DWORD)((pData[3] << 24) | (pData[2] << 16) | (pData[1] << 8) | pData[0]);
|
||
pData += 4;
|
||
memcpy(&fValue, &dwValue, sizeof(DWORD));
|
||
qds = (*pData & 0xf1); pData++;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYCPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYC(uid, point, fValue, qds);
|
||
}
|
||
}
|
||
}
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveMeasured_value_short_floating_point_with_time_tag(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //带时标的遥测量值，短浮点数
|
||
{
|
||
BYTE* pData = pBuf;
|
||
int point;
|
||
|
||
if (IEC_101_104_COT_SPONT == (cot & 0x3f) || IEC_101_104_COT_REQ == (cot & 0x3f))
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
if (sq) return FALSE; //顺序寻址
|
||
|
||
DWORD i;
|
||
DWORD information_address;
|
||
DWORD dwValue;
|
||
float fValue;
|
||
BYTE qds;
|
||
BYTE ioa[4];
|
||
unionCP56Time st;
|
||
|
||
memcpy(&st, &system32.now, sizeof(st));
|
||
for (i = 0; i < num; i++)
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
dwValue = (DWORD)((pData[3] << 24) | (pData[2] << 16) | (pData[1] << 8) | pData[0]);
|
||
pData += 4;
|
||
memcpy(&fValue, &dwValue, sizeof(DWORD));
|
||
qds = (*pData & 0xf1); pData++;
|
||
st.millisecond = *pData; pData++;
|
||
st.millisecond |= (*pData << 8); pData++;
|
||
st.minute = *pData & 0x3f;
|
||
st.IV = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYCPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYC(uid, point, fValue, qds);
|
||
}
|
||
}
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveMeasured_value_normalised_without_quality(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //测量值，不带品质描述的归一化测量值
|
||
{
|
||
BYTE* pData = pBuf;
|
||
int point;
|
||
|
||
if (IEC_101_104_COT_PER_CYC == (cot & 0x3f) || IEC_101_104_COT_BACK == (cot & 0x3f) ||
|
||
IEC_101_104_COT_SPONT == (cot & 0x3f) || IEC_101_104_COT_REQ == (cot & 0x3f) ||
|
||
IEC_101_104_COT_RETREM == (cot & 0x3f) || IEC_101_104_COT_RETLOC == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INTERROGATION == (cot & 0x3f) || IEC_101_104_COT_INRO1 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO2 == (cot & 0x3f) || IEC_101_104_COT_INRO3 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO4 == (cot & 0x3f) || IEC_101_104_COT_INRO5 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO6 == (cot & 0x3f) || IEC_101_104_COT_INRO7 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO8 == (cot & 0x3f) || IEC_101_104_COT_INRO9 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO10 == (cot & 0x3f) || IEC_101_104_COT_INRO11 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO12 == (cot & 0x3f) || IEC_101_104_COT_INRO13 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO14 == (cot & 0x3f) || IEC_101_104_COT_INRO15 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_INRO16 == (cot & 0x3f))
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
|
||
DWORD i;
|
||
DWORD information_address;
|
||
short value;
|
||
BYTE qds;
|
||
BYTE ioa[4];
|
||
|
||
if (sq) //顺序寻址
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
for (i = 0; i < num; i++, information_address++)
|
||
{
|
||
value = *pData; pData++;
|
||
value |= (*pData << 8); pData++;
|
||
qds = 0x00;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYCPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYC(uid, point, (LONG)value, qds);
|
||
}
|
||
}
|
||
}
|
||
else //单一寻址
|
||
{
|
||
for (i = 0; i < num; i++)
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
value = *pData; pData++;
|
||
value |= (*pData << 8); pData++;
|
||
qds = 0x00;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYCPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYC(uid, point, (LONG)value, qds);
|
||
}
|
||
}
|
||
}
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveSingle_point_information_with_time_tag_cp56time2a(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //带CP56Time2a时标的单点信息
|
||
{
|
||
BYTE* pData = pBuf;
|
||
int point;
|
||
|
||
if (IEC_101_104_COT_SPONT == (cot & 0x3f) || IEC_101_104_COT_REQ == (cot & 0x3f) ||
|
||
IEC_101_104_COT_RETREM == (cot & 0x3f) || IEC_101_104_COT_RETLOC == (cot & 0x3f))
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
if (sq) return FALSE; //顺序寻址
|
||
|
||
DWORD i;
|
||
DWORD information_address;
|
||
BOOLEAN value;
|
||
BYTE qds;
|
||
BYTE ioa[4];
|
||
unionCP56Time st;
|
||
|
||
memcpy(&st, &system32.now, sizeof(st));
|
||
for (i = 0; i < num; i++)
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
value = (*pData & 0x01) == 0x01 ? TRUE : FALSE;
|
||
qds = (*pData & 0xf0); pData++;
|
||
st.millisecond = *pData; pData++;
|
||
st.millisecond |= (*pData << 8); pData++;
|
||
st.minute = *pData & 0x3f;
|
||
st.IV = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
st.hour = *pData & 0x1f;
|
||
st.SU = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
st.dayofmonth = *pData & 0x1f;
|
||
st.dayofweek = ((*pData & 0xe0) >> 5); pData++;
|
||
st.month = *pData & 0x0f; pData++;
|
||
st.year = *pData & 0x7f; pData++;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYXPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYX(uid, point, value, TRUE, qds);
|
||
SetUnitSOE(uid, point, value, st);
|
||
}
|
||
}
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveDouble_point_information_with_time_tag_cp56time2a(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //带CP56Time2a时标的双点信息
|
||
{
|
||
BYTE* pData = pBuf;
|
||
int point;
|
||
|
||
if (IEC_101_104_COT_SPONT == (cot & 0x3f) || IEC_101_104_COT_REQ == (cot & 0x3f) ||
|
||
IEC_101_104_COT_RETREM == (cot & 0x3f) || IEC_101_104_COT_RETLOC == (cot & 0x3f))
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
if (sq) return FALSE; //顺序寻址
|
||
|
||
DWORD i;
|
||
DWORD information_address;
|
||
BOOLEAN value;
|
||
BYTE qds;
|
||
BYTE ioa[4];
|
||
unionCP56Time st;
|
||
|
||
memcpy(&st, &system32.now, sizeof(st));
|
||
for (i = 0; i < num; i++)
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
value = (*pData & 0x03) == 0x02 ? TRUE : FALSE;
|
||
qds = (*pData & 0xf0); pData++;
|
||
st.millisecond = *pData; pData++;
|
||
st.millisecond |= (*pData << 8); pData++;
|
||
st.minute = *pData & 0x3f;
|
||
st.IV = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
st.hour = *pData & 0x1f;
|
||
st.SU = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
st.dayofmonth = *pData & 0x1f;
|
||
st.dayofweek = ((*pData & 0xe0) >> 5); pData++;
|
||
st.month = *pData & 0x0f; pData++;
|
||
st.year = *pData & 0x7f; pData++;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYXPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYX(uid, point, value, TRUE, qds);
|
||
SetUnitSOE(uid, point, value, st);
|
||
}
|
||
}
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveMeasured_value_normalised_with_time_tag_cp56time2a(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //带CP56Time2a时标的遥测量值，归一化值
|
||
{
|
||
BYTE* pData = pBuf;
|
||
int point;
|
||
|
||
if (IEC_101_104_COT_SPONT == (cot & 0x3f) || IEC_101_104_COT_REQ == (cot & 0x3f))
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
if (sq) return FALSE; //顺序寻址
|
||
|
||
DWORD i;
|
||
DWORD information_address;
|
||
short value;
|
||
BYTE qds;
|
||
BYTE ioa[4];
|
||
unionCP56Time st;
|
||
|
||
memcpy(&st, &system32.now, sizeof(st));
|
||
for (i = 0; i < num; i++)
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
value = *pData; pData++;
|
||
value |= (*pData << 8); pData++;
|
||
qds = (*pData & 0xf1); pData++;
|
||
st.millisecond = *pData; pData++;
|
||
st.millisecond |= (*pData << 8); pData++;
|
||
st.minute = *pData & 0x3f;
|
||
st.IV = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
st.hour = *pData & 0x1f;
|
||
st.SU = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
st.dayofmonth = *pData & 0x1f;
|
||
st.dayofweek = ((*pData & 0xe0) >> 5); pData++;
|
||
st.month = *pData & 0x0f; pData++;
|
||
st.year = *pData & 0x7f; pData++;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYCPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYC(uid, point, (LONG)value, qds);
|
||
}
|
||
}
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveMeasured_value_scaled_with_time_tag_cp56time2a(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //带CP56Time2a时标的遥测量值，标度化值
|
||
{
|
||
BYTE* pData = pBuf;
|
||
int point;
|
||
|
||
if (IEC_101_104_COT_SPONT == (cot & 0x3f) || IEC_101_104_COT_REQ == (cot & 0x3f))
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
if (sq) return FALSE; //顺序寻址
|
||
|
||
DWORD i;
|
||
DWORD information_address;
|
||
short value;
|
||
BYTE qds;
|
||
BYTE ioa[4];
|
||
unionCP56Time st;
|
||
|
||
memcpy(&st, &system32.now, sizeof(st));
|
||
for (i = 0; i < num; i++)
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
value = *pData; pData++;
|
||
value |= (*pData << 8); pData++;
|
||
qds = (*pData & 0xf1); pData++;
|
||
st.millisecond = *pData; pData++;
|
||
st.millisecond |= (*pData << 8); pData++;
|
||
st.minute = *pData & 0x3f;
|
||
st.IV = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
st.hour = *pData & 0x1f;
|
||
st.SU = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
st.dayofmonth = *pData & 0x1f;
|
||
st.dayofweek = ((*pData & 0xe0) >> 5); pData++;
|
||
st.month = *pData & 0x0f; pData++;
|
||
st.year = *pData & 0x7f; pData++;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYCPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYC(uid, point, (LONG)value, qds);
|
||
}
|
||
|
||
}
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveMeasured_value_short_floating_point_with_time_tag_cp56time2a(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //带CP56Time2a时标的遥测量值，短浮点数
|
||
{
|
||
BYTE* pData = pBuf;
|
||
int point;
|
||
|
||
if (IEC_101_104_COT_SPONT == (cot & 0x3f) || IEC_101_104_COT_REQ == (cot & 0x3f))
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
if (sq) return FALSE; //顺序寻址
|
||
|
||
DWORD i;
|
||
DWORD information_address;
|
||
DWORD dwValue;
|
||
float fValue;
|
||
BYTE qds;
|
||
BYTE ioa[4];
|
||
unionCP56Time st;
|
||
memcpy(&st, &system32.now, sizeof(st));
|
||
for (i = 0; i < num; i++)
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
dwValue = (DWORD)((pData[3] << 24) | (pData[2] << 16) | (pData[1] << 8) | pData[0]);
|
||
pData += 4;
|
||
memcpy(&fValue, &dwValue, sizeof(DWORD));
|
||
qds = (*pData & 0xf1); pData++;
|
||
st.millisecond = *pData; pData++;
|
||
st.millisecond |= (*pData << 8); pData++;
|
||
st.minute = *pData & 0x3f;
|
||
st.IV = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
st.hour = *pData & 0x1f;
|
||
st.SU = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
st.dayofmonth = *pData & 0x1f;
|
||
st.dayofweek = ((*pData & 0xe0) >> 5); pData++;
|
||
st.month = *pData & 0x0f; pData++;
|
||
st.year = *pData & 0x7f; pData++;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYCPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYC(uid, point, fValue, qds);
|
||
}
|
||
}
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveIntegrated_totals(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //累积量
|
||
{
|
||
BYTE* pData = pBuf;
|
||
int point;
|
||
|
||
if (IEC_101_104_COT_SPONT == (cot & 0x3f) || IEC_101_104_COT_REQCOGEN == (cot & 0x3f) ||
|
||
IEC_101_104_COT_REQCO1 == (cot & 0x3f) || IEC_101_104_COT_REQCO2 == (cot & 0x3f) ||
|
||
IEC_101_104_COT_REQCO3 == (cot & 0x3f) || IEC_101_104_COT_REQCO4 == (cot & 0x3f))
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
|
||
int i;
|
||
DWORD information_address;
|
||
DWORD value;
|
||
// BYTE sn;
|
||
BYTE ioa[4];
|
||
if (sq) //顺序寻址
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
for (i = 0; i < num; i++, information_address++)
|
||
{
|
||
value = *pData; pData++;
|
||
value |= (*pData << 8); pData++;
|
||
value |= (*pData << 16); pData++;
|
||
value |= (*pData << 24); pData++;
|
||
//sn = *pData;
|
||
pData++;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYMPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYM(uid, point, value);
|
||
}
|
||
}
|
||
}
|
||
else //单一寻址
|
||
{
|
||
for (i = 0; i < num; i++)
|
||
{
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
value = *pData; pData++;
|
||
value |= (*pData << 8); pData++;
|
||
value |= (*pData << 16); pData++;
|
||
value |= (*pData << 24); pData++;
|
||
//sn = *pData;
|
||
pData++;
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYMPointByParam(uid, ioa, 4);
|
||
if (point >= 0)
|
||
{
|
||
SetUnitYM(uid, point, value);
|
||
}
|
||
}
|
||
}
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveInterrogation_command(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //总召唤
|
||
{
|
||
BYTE* pData = pBuf;
|
||
DWORD information_address;
|
||
BYTE QOI;
|
||
if (IEC_101_104_COT_ACTCON == (cot & 0x3f) || IEC_101_104_COT_DEACTCON == (cot & 0x3f) ||
|
||
IEC_101_104_COT_ACTTREM == (cot & 0x3f) || IEC_101_104_COT_UNKNOWN_TI == (cot & 0x3f) ||
|
||
IEC_101_104_COT_UNKNOWN_COT == (cot & 0x3f) || IEC_101_104_COT_UNKNOWN_ASDU == (cot & 0x3f) ||
|
||
IEC_101_104_COT_UNKNOWN_INFO == (cot & 0x3f))
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
if (sq) return FALSE; //顺序寻址
|
||
if (num != 1) return FALSE;
|
||
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
if (information_address != 0) return FALSE;
|
||
|
||
QOI = *pData; pData++;
|
||
if (QOI < 20 || QOI > 36)
|
||
{
|
||
return FALSE;
|
||
}
|
||
if (IEC_101_104_COT_ACT == (cot & 0x3f))
|
||
{
|
||
return FALSE;
|
||
}
|
||
if (IEC_101_104_COT_ACTCON == (cot & 0x3f))
|
||
{
|
||
return TRUE;
|
||
}
|
||
if (IEC_101_104_COT_ACTTREM == (cot & 0x3f))
|
||
{ //激活终止
|
||
//总召唤结束
|
||
pItem->interrogation_finish = TRUE;
|
||
return TRUE;
|
||
}
|
||
if (IEC_101_104_COT_DEACT == (cot & 0x3f))
|
||
{
|
||
return FALSE;
|
||
}
|
||
if (IEC_101_104_COT_DEACTCON == (cot & 0x3f))
|
||
{
|
||
return TRUE;
|
||
}
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveClock_synchronisation_command(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //时钟同步
|
||
{
|
||
BYTE* pData = pBuf;
|
||
DWORD information_address;
|
||
unionCP56Time st;
|
||
if (IEC_101_104_COT_ACTCON == (cot & 0x3f) || IEC_101_104_COT_ACTTREM == (cot & 0x3f) ||
|
||
IEC_101_104_COT_UNKNOWN_TI == (cot & 0x3f) || IEC_101_104_COT_UNKNOWN_COT == (cot & 0x3f) ||
|
||
IEC_101_104_COT_UNKNOWN_ASDU == (cot & 0x3f) || IEC_101_104_COT_UNKNOWN_INFO == (cot & 0x3f))
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
if (sq) return FALSE; //顺序寻址
|
||
if (num != 1) return FALSE;
|
||
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
if (information_address != 0) return FALSE;
|
||
|
||
st.millisecond = *pData; pData++;
|
||
st.millisecond |= (*pData << 8); pData++;
|
||
st.minute = *pData & 0x3f;
|
||
st.IV = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
st.hour = *pData & 0x1f;
|
||
st.SU = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
st.dayofmonth = *pData & 0x1f;
|
||
st.dayofweek = ((*pData & 0xe0) >> 5); pData++;
|
||
st.month = *pData & 0x0f; pData++;
|
||
st.year = *pData & 0x7f; pData++;
|
||
if ((cot & 0x3f) == IEC_101_104_COT_ACTCON)
|
||
{
|
||
pItem->clock_synchronized_finish = TRUE;
|
||
return TRUE;
|
||
}
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveCounter_Interrogation_command(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //召唤电度量
|
||
{
|
||
BYTE* pData = pBuf;
|
||
DWORD information_address;
|
||
BYTE QCC;
|
||
if (IEC_101_104_COT_ACTCON == (cot & 0x3f) || IEC_101_104_COT_DEACTCON == (cot & 0x3f) ||
|
||
IEC_101_104_COT_ACTTREM == (cot & 0x3f) || IEC_101_104_COT_UNKNOWN_TI == (cot & 0x3f) ||
|
||
IEC_101_104_COT_UNKNOWN_COT == (cot & 0x3f) || IEC_101_104_COT_UNKNOWN_ASDU == (cot & 0x3f) ||
|
||
IEC_101_104_COT_UNKNOWN_INFO == (cot & 0x3f))
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
if (sq) return FALSE; //顺序寻址 never happend;
|
||
if (num != 1) return FALSE;
|
||
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
if (information_address != 0) return FALSE;
|
||
QCC = *pData; pData++;
|
||
if ((QCC & 0x3f) < 1 || (QCC & 0x3f) > 5) return FALSE;
|
||
if (IEC_101_104_COT_ACT == (cot & 0x3f)) return FALSE;
|
||
if (IEC_101_104_COT_ACTCON == (cot & 0x3f)) return TRUE;
|
||
//激活终止
|
||
//召唤电度结束
|
||
if (IEC_101_104_COT_ACTTREM == (cot & 0x3f)) return TRUE;
|
||
if (IEC_101_104_COT_DEACT == (cot & 0x3f)) return FALSE;
|
||
if (IEC_101_104_COT_DEACTCON == (cot & 0x3f)) return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveSingle_command(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //单点遥控
|
||
{
|
||
BYTE* pData = pBuf;
|
||
BYTE SE, value;
|
||
int point;
|
||
DWORD information_address;
|
||
BYTE ioa[4];
|
||
|
||
if( IEC_101_104_COT_ACTCON == (cot & 0x3f) || IEC_101_104_COT_DEACTCON == (cot & 0x3f) ||
|
||
IEC_101_104_COT_ACTTREM == (cot & 0x3f) || IEC_101_104_COT_UNKNOWN_TI == (cot & 0x3f) ||
|
||
IEC_101_104_COT_UNKNOWN_COT == (cot & 0x3f) || IEC_101_104_COT_UNKNOWN_ASDU == (cot & 0x3f) ||
|
||
IEC_101_104_COT_UNKNOWN_INFO == (cot & 0x3f) )
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
if (sq) return FALSE; //顺序寻址
|
||
if (num != 1) return FALSE;
|
||
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYKPointByParam(uid, ioa, 4);
|
||
if (point < 0)
|
||
{
|
||
vLog(LOG_WARN, "Unit(%d) information address error.\n", uid);
|
||
return FALSE;
|
||
}
|
||
SE = (*pData & 0x80) == 0x80 ? TRUE : FALSE;
|
||
value = (*pData & 0x01) == 0x01 ? TRUE : FALSE;
|
||
|
||
BYTE* pYKParam = GetUnitYKParamByPoint(uid, point);
|
||
if (pYKParam == NULL) return FALSE;
|
||
switch (pYKParam[5])
|
||
{
|
||
case 1: //单触点合圈
|
||
if (value != TRUE) return FALSE;
|
||
break;
|
||
case 2: //单触点分圈
|
||
if (value != FALSE) return FALSE;
|
||
break;
|
||
}
|
||
|
||
value = pItem->yk_value;
|
||
if (SE)
|
||
{ //遥控选择
|
||
if (IEC_101_104_COT_ACTCON == (cot & 0x3f))
|
||
{ //激活确认
|
||
SetUnitYK(uid, point, value, YKS_SELED, YKR_SUCC);
|
||
vLog(LOG_WARN, "Unit(%d) yk(%d) %s state is YKS_SELED result is YKR_SUCC.\n", uid, point, (value ? "CLOSE" : "TRIP"));
|
||
return TRUE;
|
||
}
|
||
else if (IEC_101_104_COT_DEACTCON == (cot & 0x3f))
|
||
{ //停止激活确认
|
||
SetUnitYK(uid, point, value, YKS_ABRED, YKR_SUCC);
|
||
vLog(LOG_WARN, "Unit(%d) yk(%d) %s state is YKS_ABRED result is YKR_SUCC.\n", uid, point, (value ? "CLOSE" : "TRIP" ));
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
else
|
||
{ //遥控执行
|
||
if (IEC_101_104_COT_ACTTREM == (cot & 0x3f))
|
||
{ //激活终止
|
||
SetUnitYK(uid, point, value, YKS_EXEED, YKR_SUCC);
|
||
vLog(LOG_WARN, "Unit(%d) yk(%d) %s state is YKS_EXEED result is YKR_SUCC.\n", uid, point, (value ? "CLOSE" : "TRIP"));
|
||
return TRUE;
|
||
}
|
||
else if (IEC_101_104_COT_DEACTCON == (cot & 0x3f))
|
||
{ //停止激活确认
|
||
SetUnitYK(uid, point, value, YKS_ABRED, YKR_SUCC);
|
||
vLog(LOG_WARN, "Unit(%d) yk(%d) %s state is YKS_ABRED result is YKR_SUCC.\n", uid, point, (value ? "CLOSE" : "TRIP"));
|
||
return TRUE;
|
||
}
|
||
else if (IEC_101_104_COT_ACTCON == (cot & 0x3f))
|
||
{ //激活确认
|
||
vLog(LOG_WARN, "Unit(%d) yk(%d) %s ACTCON.\n", uid, point, (value ? "CLOSE" : "TRIP"));
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveDouble_command(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //双点遥控
|
||
{
|
||
BYTE* pData = pBuf;
|
||
BYTE SE, value;
|
||
int point;
|
||
DWORD information_address;
|
||
BYTE ioa[4];
|
||
|
||
if( IEC_101_104_COT_ACTCON == (cot & 0x3f) || IEC_101_104_COT_DEACTCON == (cot & 0x3f) ||
|
||
IEC_101_104_COT_ACTTREM == (cot & 0x3f) || IEC_101_104_COT_UNKNOWN_TI == (cot & 0x3f) ||
|
||
IEC_101_104_COT_UNKNOWN_COT == (cot & 0x3f) || IEC_101_104_COT_UNKNOWN_ASDU == (cot & 0x3f) ||
|
||
IEC_101_104_COT_UNKNOWN_INFO == (cot & 0x3f) )
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
if (sq) return FALSE; //顺序寻址
|
||
if (num != 1) return FALSE;
|
||
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYKPointByParam(uid, ioa, 4);
|
||
if (point < 0)
|
||
{
|
||
vLog(LOG_WARN, "Unit(%d) information address error.\n", uid);
|
||
return FALSE;
|
||
}
|
||
SE = (*pData & 0x80) == 0x80 ? TRUE : FALSE;
|
||
value = (*pData & 0x03) == 0x02 ? TRUE : FALSE;
|
||
BYTE* pYKParam = GetUnitYKParamByPoint(uid, point);
|
||
if (pYKParam == NULL) return FALSE;
|
||
switch (pYKParam[5])
|
||
{
|
||
case 1: //单触点合圈
|
||
if (value != TRUE) return FALSE;
|
||
break;
|
||
case 2: //单触点分圈
|
||
if (value != FALSE) return FALSE;
|
||
break;
|
||
}
|
||
|
||
value = pItem->yk_value;
|
||
if (SE)
|
||
{ //遥控选择
|
||
if (IEC_101_104_COT_ACTCON == (cot & 0x3f))
|
||
{ //激活确认
|
||
SetUnitYK(uid, point, value, YKS_SELED, YKR_SUCC);
|
||
vLog(LOG_WARN, "Unit(%d) yk(%d) %s state is YKS_SELED result is YKR_SUCC.\n", uid, point, (value ? "CLOSE" : "TRIP"));
|
||
return TRUE;
|
||
}
|
||
else if (IEC_101_104_COT_DEACTCON == (cot & 0x3f))
|
||
{ //停止激活确认
|
||
SetUnitYK(uid, point, value, YKS_ABRED, YKR_SUCC);
|
||
vLog(LOG_WARN, "Unit(%d) yk(%d) %s state is YKS_ABRED result is YKR_SUCC.\n", uid, point, (value ? "CLOSE" : "TRIP" ));
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
else
|
||
{ //遥控执行
|
||
if (IEC_101_104_COT_ACTTREM == (cot & 0x3f))
|
||
{ //激活终止
|
||
SetUnitYK(uid, point, value, YKS_EXEED, YKR_SUCC);
|
||
vLog(LOG_WARN, "Unit(%d) yk(%d) %s state is YKS_EXEED result is YKR_SUCC.\n", uid, point, (value ? "CLOSE" : "TRIP"));
|
||
return TRUE;
|
||
}
|
||
else if (IEC_101_104_COT_DEACTCON == (cot & 0x3f))
|
||
{ //停止激活确认
|
||
SetUnitYK(uid, point, value, YKS_ABRED, YKR_SUCC);
|
||
vLog(LOG_WARN, "Unit(%d) yk(%d) %s state is YKS_ABRED result is YKR_SUCC.\n", uid, point, (value ? "CLOSE" : "TRIP"));
|
||
return TRUE;
|
||
}
|
||
else if (IEC_101_104_COT_ACTCON == (cot & 0x3f))
|
||
{ //激活确认
|
||
vLog(LOG_WARN, "Unit(%d) yk(%d) %s ACTCON.\n", uid, point, (value ? "CLOSE" : "TRIP"));
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveSet_point_command_normalized(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //设定归一化值命令
|
||
{
|
||
BYTE* pData = pBuf;
|
||
BYTE SE;
|
||
WORD value;
|
||
int point;
|
||
DWORD information_address;
|
||
BYTE ioa[4];
|
||
|
||
if( IEC_101_104_COT_ACTCON == (cot & 0x3f) || IEC_101_104_COT_DEACTCON == (cot & 0x3f) ||
|
||
IEC_101_104_COT_ACTTREM == (cot & 0x3f) || IEC_101_104_COT_UNKNOWN_TI == (cot & 0x3f) ||
|
||
IEC_101_104_COT_UNKNOWN_COT == (cot & 0x3f) || IEC_101_104_COT_UNKNOWN_ASDU == (cot & 0x3f) ||
|
||
IEC_101_104_COT_UNKNOWN_INFO == (cot & 0x3f) )
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
if (sq) return FALSE; //顺序寻址
|
||
if (num != 1) return FALSE;
|
||
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYTPointByParam(uid, ioa, 4);
|
||
if (point < 0)
|
||
{
|
||
vLog(LOG_WARN, "Unit(%d) information address error.\n", uid);
|
||
return FALSE;
|
||
}
|
||
value = *pData; pData++;
|
||
value |= (*pData << 8); pData++;
|
||
SE = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
if (SE)
|
||
{ //遥控选择
|
||
if (IEC_101_104_COT_ACTCON == (cot & 0x3f))
|
||
{ //激活确认
|
||
SetUnitYT(uid, point, value, YTS_SELED, YTR_SUCC);
|
||
vLog(LOG_WARN, "Unit(%d) set point(%d) %d state is YTS_SELED result is YTR_SUCC.\n", uid, point, value);
|
||
return TRUE;
|
||
}
|
||
else if (IEC_101_104_COT_DEACTCON == (cot & 0x3f))
|
||
{ //停止激活确认
|
||
SetUnitYT(uid, point, value, YTS_ABRED, YTR_SUCC);
|
||
vLog(LOG_WARN, "Unit(%d) set point(%d) %d state is YTS_ABRED result is YTR_SUCC.\n", uid, point, value);
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
else
|
||
{ //遥控执行
|
||
if (IEC_101_104_COT_ACTTREM == (cot & 0x3f))
|
||
{ //激活终止
|
||
SetUnitYT(uid, point, value, YTS_EXEED, YTR_SUCC);
|
||
vLog(LOG_WARN, "Unit(%d) set point(%d) %d state is YTS_EXEED result is YTR_SUCC.\n", uid, point, value);
|
||
return TRUE;
|
||
}
|
||
else if (IEC_101_104_COT_DEACTCON == (cot & 0x3f))
|
||
{ //停止激活确认
|
||
SetUnitYT(uid, point, value, YTS_ABRED, YTR_SUCC);
|
||
vLog(LOG_WARN, "Unit(%d) set point(%d) %d state is YTS_ABRED result is YTR_SUCC.\n", uid, point, value);
|
||
return TRUE;
|
||
}
|
||
else if (IEC_101_104_COT_ACTCON == (cot & 0x3f))
|
||
{ //激活确认
|
||
vLog(LOG_WARN, "Unit(%d) set point(%d) %d ACTCON.\n", uid, point, value);
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveSet_point_command_scaled(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //设定标度化值命令
|
||
{
|
||
BYTE* pData = pBuf;
|
||
BYTE SE;
|
||
WORD value;
|
||
int point;
|
||
DWORD information_address;
|
||
BYTE ioa[4];
|
||
|
||
if( IEC_101_104_COT_ACTCON == (cot & 0x3f) || IEC_101_104_COT_DEACTCON == (cot & 0x3f) ||
|
||
IEC_101_104_COT_ACTTREM == (cot & 0x3f) || IEC_101_104_COT_UNKNOWN_TI == (cot & 0x3f) ||
|
||
IEC_101_104_COT_UNKNOWN_COT == (cot & 0x3f) || IEC_101_104_COT_UNKNOWN_ASDU == (cot & 0x3f) ||
|
||
IEC_101_104_COT_UNKNOWN_INFO == (cot & 0x3f) )
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
if (sq) return FALSE; //顺序寻址
|
||
if (num != 1) return FALSE;
|
||
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYTPointByParam(uid, ioa, 4);
|
||
if (point < 0)
|
||
{
|
||
vLog(LOG_WARN, "Unit(%d) information address error.\n", uid);
|
||
return FALSE;
|
||
}
|
||
value = *pData; pData++;
|
||
value |= (*pData << 8); pData++;
|
||
SE = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
if (SE)
|
||
{ //遥控选择
|
||
if (IEC_101_104_COT_ACTCON == (cot & 0x3f))
|
||
{ //激活确认
|
||
SetUnitYT(uid, point, value, YTS_SELED, YTR_SUCC);
|
||
vLog(LOG_WARN, "Unit(%d) set point(%d) %d state is YTS_SELED result is YTR_SUCC.\n", uid, point, value);
|
||
return TRUE;
|
||
}
|
||
else if (IEC_101_104_COT_DEACTCON == (cot & 0x3f))
|
||
{ //停止激活确认
|
||
SetUnitYT(uid, point, value, YTS_ABRED, YTR_SUCC);
|
||
vLog(LOG_WARN, "Unit(%d) set point(%d) %d state is YTS_ABRED result is YTR_SUCC.\n", uid, point, value);
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
else
|
||
{ //遥控执行
|
||
if (IEC_101_104_COT_ACTTREM == (cot & 0x3f))
|
||
{ //激活终止
|
||
SetUnitYT(uid, point, value, YTS_EXEED, YTR_SUCC);
|
||
vLog(LOG_WARN, "Unit(%d) set point(%d) %d state is YTS_EXEED result is YTR_SUCC.\n", uid, point, value);
|
||
return TRUE;
|
||
}
|
||
else if (IEC_101_104_COT_DEACTCON == (cot & 0x3f))
|
||
{ //停止激活确认
|
||
SetUnitYT(uid, point, value, YTS_ABRED, YTR_SUCC);
|
||
vLog(LOG_WARN, "Unit(%d) set point(%d) %d state is YTS_ABRED result is YTR_SUCC.\n", uid, point, value);
|
||
return TRUE;
|
||
}
|
||
else if (IEC_101_104_COT_ACTCON == (cot & 0x3f))
|
||
{ //激活确认
|
||
vLog(LOG_WARN, "Unit(%d) set point(%d) %d ACTCON.\n", uid, point, value);
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::OnReceiveSet_point_command_short_floating(CIEC104ProcessItem* pItem, int uid, BYTE* pBuf, BOOLEAN sq, BOOLEAN pn, BOOLEAN test, BYTE num, WORD cot) //设定短浮点值命令
|
||
{
|
||
BYTE* pData = pBuf;
|
||
BYTE SE;
|
||
DWORD value;
|
||
int point;
|
||
DWORD information_address;
|
||
BYTE ioa[4];
|
||
|
||
if( IEC_101_104_COT_ACTCON == (cot & 0x3f) || IEC_101_104_COT_DEACTCON == (cot & 0x3f) ||
|
||
IEC_101_104_COT_ACTTREM == (cot & 0x3f) || IEC_101_104_COT_UNKNOWN_TI == (cot & 0x3f) ||
|
||
IEC_101_104_COT_UNKNOWN_COT == (cot & 0x3f) || IEC_101_104_COT_UNKNOWN_ASDU == (cot & 0x3f) ||
|
||
IEC_101_104_COT_UNKNOWN_INFO == (cot & 0x3f) )
|
||
{
|
||
if (pn) return FALSE; //否定
|
||
if (test) return FALSE; //试验
|
||
if (sq) return FALSE; //顺序寻址
|
||
if (num != 1) return FALSE;
|
||
|
||
information_address = 0;
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address = *pData; pData++;
|
||
information_address |= (*pData << 8); pData++;
|
||
information_address |= (*pData << 16); pData++;
|
||
}
|
||
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYTPointByParam(uid, ioa, 4);
|
||
if (point < 0)
|
||
{
|
||
vLog(LOG_WARN, "Unit(%d) information address error.\n", uid);
|
||
return FALSE;
|
||
}
|
||
value = *pData; pData++;
|
||
value |= (*pData << 8); pData++;
|
||
value |= (*pData << 16); pData++;
|
||
value |= (*pData << 24); pData++;
|
||
SE = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
if (SE)
|
||
{ //遥控选择
|
||
if (IEC_101_104_COT_ACTCON == (cot & 0x3f))
|
||
{ //激活确认
|
||
SetUnitYT(uid, point, value, YTS_SELED, YTR_SUCC);
|
||
vLog(LOG_WARN, "Unit(%d) set point(%d) %d state is YTS_SELED result is YTR_SUCC.\n", uid, point, value);
|
||
return TRUE;
|
||
}
|
||
else if (IEC_101_104_COT_DEACTCON == (cot & 0x3f))
|
||
{ //停止激活确认
|
||
SetUnitYT(uid, point, value, YTS_ABRED, YTR_SUCC);
|
||
vLog(LOG_WARN, "Unit(%d) set point(%d) %d state is YTS_ABRED result is YTR_SUCC.\n", uid, point, value);
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
else
|
||
{ //遥控执行
|
||
if (IEC_101_104_COT_ACTTREM == (cot & 0x3f))
|
||
{ //激活终止
|
||
SetUnitYT(uid, point, value, YTS_EXEED, YTR_SUCC);
|
||
vLog(LOG_WARN, "Unit(%d) set point(%d) %d state is YTS_EXEED result is YTR_SUCC.\n", uid, point, value);
|
||
return TRUE;
|
||
}
|
||
else if (IEC_101_104_COT_DEACTCON == (cot & 0x3f))
|
||
{ //停止激活确认
|
||
SetUnitYT(uid, point, value, YTS_ABRED, YTR_SUCC);
|
||
vLog(LOG_WARN, "Unit(%d) set point(%d) %d state is YTS_ABRED result is YTR_SUCC.\n", uid, point, value);
|
||
return TRUE;
|
||
}
|
||
else if (IEC_101_104_COT_ACTCON == (cot & 0x3f))
|
||
{ //激活确认
|
||
vLog(LOG_WARN, "Unit(%d) set point(%d) %d ACTCON.\n", uid, point, value);
|
||
return TRUE;
|
||
}
|
||
return FALSE;
|
||
}
|
||
}
|
||
return FALSE;
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::SendInterrogation_command(CIEC104ProcessItem* pItem, int ord) //总召唤
|
||
{
|
||
DWORD len;
|
||
BYTE buffer[64];
|
||
|
||
len = 0;
|
||
memset(buffer, 0, sizeof(buffer));
|
||
buffer[len++] = C_IC_NA_1;
|
||
buffer[len++] = 0x01;
|
||
//传输原因
|
||
if (1 == m_nOption.cot_size)
|
||
{
|
||
buffer[len++] = (BYTE)(IEC_101_104_COT_ACT & 0xff);
|
||
}
|
||
else if (2 == m_nOption.cot_size)
|
||
{
|
||
buffer[len++] = (BYTE)(IEC_101_104_COT_ACT & 0x00ff);
|
||
buffer[len++] = (BYTE)((IEC_101_104_COT_ACT >> 8) & 0x00ff);
|
||
}
|
||
//应用地址
|
||
if (1 == m_nOption.asdu_addr_size)
|
||
{
|
||
buffer[len++] = (BYTE)(pItem->apdu_addr & 0xff);
|
||
}
|
||
else if (2 == m_nOption.asdu_addr_size)
|
||
{
|
||
buffer[len++] = (BYTE)(pItem->apdu_addr & 0x00ff);
|
||
buffer[len++] = (BYTE)((pItem->apdu_addr >> 8) & 0x00ff);
|
||
}
|
||
//信息体地址
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
buffer[len++] = 0;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
buffer[len++] = 0;
|
||
buffer[len++] = 0;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
buffer[len++] = 0;
|
||
buffer[len++] = 0;
|
||
buffer[len++] = 0;
|
||
}
|
||
buffer[len++] = 0x14; //QOI总召唤
|
||
return SendIFrame(buffer, len, ord);
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::SendClock_synchronisation_command(CIEC104ProcessItem* pItem, int ord) //时钟同步
|
||
{
|
||
DWORD len;
|
||
BYTE buffer[64];
|
||
|
||
len = 0;
|
||
memset(buffer, 0, sizeof(buffer));
|
||
buffer[len++] = C_CS_NA_1;
|
||
buffer[len++] = 0x01;
|
||
//传输原因
|
||
if (1 == m_nOption.cot_size)
|
||
{
|
||
buffer[len++] = (BYTE)(IEC_101_104_COT_ACT & 0xff);
|
||
}
|
||
else if (2 == m_nOption.cot_size)
|
||
{
|
||
buffer[len++] = (BYTE)(IEC_101_104_COT_ACT & 0x00ff);
|
||
buffer[len++] = (BYTE)((IEC_101_104_COT_ACT >> 8) & 0x00ff);
|
||
}
|
||
//应用地址
|
||
if (1 == m_nOption.asdu_addr_size)
|
||
{
|
||
buffer[len++] = (BYTE)(pItem->apdu_addr & 0xff);
|
||
}
|
||
else if (2 == m_nOption.asdu_addr_size)
|
||
{
|
||
buffer[len++] = (BYTE)(pItem->apdu_addr & 0x00ff);
|
||
buffer[len++] = (BYTE)((pItem->apdu_addr >> 8) & 0x00ff);
|
||
}
|
||
//信息体地址
|
||
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
buffer[len++] = 0;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
buffer[len++] = 0;
|
||
buffer[len++] = 0;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
buffer[len++] = 0;
|
||
buffer[len++] = 0;
|
||
buffer[len++] = 0;
|
||
}
|
||
unionCP56Time st;
|
||
if (!get_system_time(&st))
|
||
{
|
||
vLog(LOG_ERROR, "Get system time error.\n");
|
||
return FALSE;
|
||
}
|
||
if ((st.millisecond % 1000) > 900)
|
||
{
|
||
return FALSE;
|
||
}
|
||
st.IV = FALSE;
|
||
st.SU = FALSE;
|
||
buffer[len++] = (BYTE)(st.millisecond & 0x00ff);
|
||
buffer[len++] = (BYTE)((st.millisecond >> 8)& 0x00ff);
|
||
buffer[len++] = (BYTE)(st.minute | (st.IV << 7));
|
||
buffer[len++] = (BYTE)(st.hour | (st.SU << 7));
|
||
buffer[len++] = (BYTE)(st.dayofmonth | (st.dayofweek << 5));
|
||
buffer[len++] = (BYTE)st.month;
|
||
buffer[len++] = (BYTE)st.year;
|
||
return SendIFrame(buffer, len, ord);
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::SendCounter_Interrogation_command(CIEC104ProcessItem* pItem, int ord) //召唤电度量
|
||
{
|
||
DWORD len;
|
||
BYTE buffer[64];
|
||
|
||
len = 0;
|
||
memset(buffer, 0, sizeof(buffer));
|
||
buffer[len++] = C_CI_NA_1;
|
||
buffer[len++] = 0x01;
|
||
//传输原因
|
||
if (1 == m_nOption.cot_size)
|
||
{
|
||
buffer[len++] = (BYTE)(IEC_101_104_COT_ACT & 0xff);
|
||
}
|
||
else if (2 == m_nOption.cot_size)
|
||
{
|
||
buffer[len++] = (BYTE)(IEC_101_104_COT_ACT & 0x00ff);
|
||
buffer[len++] = (BYTE)((IEC_101_104_COT_ACT >> 8) & 0x00ff);
|
||
}
|
||
//应用地址
|
||
if (1 == m_nOption.asdu_addr_size)
|
||
{
|
||
buffer[len++] = (BYTE)(pItem->apdu_addr & 0xff);
|
||
}
|
||
else if (2 == m_nOption.asdu_addr_size)
|
||
{
|
||
buffer[len++] = (BYTE)(pItem->apdu_addr & 0x00ff);
|
||
buffer[len++] = (BYTE)((pItem->apdu_addr >> 8) & 0x00ff);
|
||
}
|
||
//信息体地址
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
buffer[len++] = 0;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
buffer[len++] = 0;
|
||
buffer[len++] = 0;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
buffer[len++] = 0;
|
||
buffer[len++] = 0;
|
||
buffer[len++] = 0;
|
||
}
|
||
buffer[len++] = 5; //QCC总召唤
|
||
return SendIFrame(buffer, len, ord);
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::GetYKFrame(CIEC104ProcessItem* pItem, int ord)
|
||
{
|
||
int uid, order, len;
|
||
DWORD information_address;
|
||
BYTE value, state, result, command, yk_type, relay_type, QU;
|
||
WORD cause_of_transmission = 0;
|
||
BYTE buffer[64];
|
||
|
||
|
||
if (NULL == pItem) return FALSE;
|
||
command = 0;
|
||
len = 0;
|
||
memset(buffer, 0, sizeof(buffer));
|
||
uid = pItem->GetUnitID();
|
||
if (uid < 0 || uid >= UNIT_NUM) return FALSE;
|
||
if (!GetUnitYK(uid, order, value, state, result)) return FALSE;
|
||
|
||
vLog(LOG_WARN, "Unit(%d) yk(%d) %s state is %s result is %s.\n", uid, order, (value ? "CLOSE" : "TRIP"), val_to_str( state, yk_state, "STATE= %d" ), val_to_str( result, yk_result, "RESULT= %d"));
|
||
|
||
//获取遥控信息体地址
|
||
BYTE* pParam = GetUnitYKParamByPoint(uid, order);
|
||
if (NULL == pParam) return FALSE;
|
||
|
||
pItem->yk_value = value;
|
||
|
||
information_address = MAKEDWORD(MAKEWORD(pParam[0], pParam[1]), MAKEWORD(pParam[2], pParam[3]));
|
||
yk_type = pParam[4];
|
||
relay_type = pParam[5];
|
||
QU = pParam[6];
|
||
QU <<= 2; QU &= 0x7c;
|
||
|
||
if (yk_type == USE_YK_DC || yk_type == USE_YK_DEF)
|
||
{ //双点遥控
|
||
command = (value == TRUE) ? DCO_ON: DCO_OFF;
|
||
buffer[len++] = C_DC_NA_1;
|
||
}
|
||
else if (yk_type == USE_YK_SC)
|
||
{
|
||
switch (relay_type)
|
||
{
|
||
case 1: //单触点合圈
|
||
command = TRUE;
|
||
break;
|
||
case 2: //单触点分圈
|
||
command = FALSE;
|
||
break;
|
||
default: //双触点线圈
|
||
command = value;
|
||
break;
|
||
}
|
||
buffer[len++] = C_SC_NA_1;
|
||
}
|
||
if (YKS_SELREQ == state)
|
||
{
|
||
cause_of_transmission = IEC_101_104_COT_ACT;
|
||
command |= 0x80;
|
||
}
|
||
else if (YKS_EXEREQ == state)
|
||
{
|
||
cause_of_transmission = IEC_101_104_COT_ACT;
|
||
}
|
||
else if ((YKS_ABRREQ == state) || ((YKS_SELING == state || YKS_SELED == state) && YKR_OVER == result))
|
||
{
|
||
cause_of_transmission = IEC_101_104_COT_DEACT;
|
||
command |= 0x80;
|
||
}
|
||
|
||
buffer[len++] = 0x01;
|
||
//传输原因
|
||
if (1 == m_nOption.cot_size)
|
||
{
|
||
buffer[len++] = (BYTE)(cause_of_transmission & 0xff);
|
||
}
|
||
else if (2 == m_nOption.cot_size)
|
||
{
|
||
buffer[len++] = (BYTE)(cause_of_transmission & 0x00ff);
|
||
buffer[len++] = (BYTE)((cause_of_transmission >> 8) & 0x00ff);
|
||
}
|
||
//应用地址
|
||
if (1 == m_nOption.asdu_addr_size)
|
||
{
|
||
buffer[len++] = (BYTE)(pItem->apdu_addr & 0xff);
|
||
}
|
||
else if (2 == m_nOption.asdu_addr_size)
|
||
{
|
||
buffer[len++] = (BYTE)(pItem->apdu_addr & 0x00ff);
|
||
buffer[len++] = (BYTE)((pItem->apdu_addr >> 8) & 0x00ff);
|
||
}
|
||
//信息体地址
|
||
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
buffer[len++] = (BYTE)(information_address & 0xff);
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
buffer[len++] = (BYTE)(information_address & 0xff);
|
||
buffer[len++] = (BYTE)((information_address >> 8) & 0xff);
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
buffer[len++] = (BYTE)(information_address & 0xff);
|
||
buffer[len++] = (BYTE)((information_address >> 8) & 0xff);
|
||
buffer[len++] = (BYTE)((information_address >> 16) & 0xff);
|
||
}
|
||
buffer[len++] = (command | QU);
|
||
|
||
return SendIFrame(buffer, len, ord);
|
||
}
|
||
|
||
BOOLEAN CIEC104Process::GetYTFrame(CIEC104ProcessItem* pItem, int ord)
|
||
{
|
||
int uid, order, len, data_length;
|
||
DWORD information_address, value;
|
||
BYTE state, result, yt_type;
|
||
BYTE command = 0;
|
||
WORD cause_of_transmission = 0;
|
||
BYTE buffer[64];
|
||
|
||
|
||
if (NULL == pItem) return FALSE;
|
||
data_length = 2;
|
||
len = 0;
|
||
memset(buffer, 0, sizeof(buffer));
|
||
uid = pItem->GetUnitID();
|
||
if (uid < 0 || uid >= UNIT_NUM) return FALSE;
|
||
if (!GetUnitYT(uid, order, value, state, result)) return FALSE;
|
||
|
||
vLog(LOG_WARN, "Unit(%d) set point(%d) %d state is %s result is %s.\n", uid, order, value, val_to_str( state, yt_state, "STATE= %d" ), val_to_str( result, yt_result, "RESULT= %d"));
|
||
|
||
//获取遥调信息体地址
|
||
BYTE* pParam = GetUnitYTParamByPoint(uid, order);
|
||
if (NULL == pParam) return FALSE;
|
||
|
||
information_address = MAKEDWORD(MAKEWORD(pParam[0], pParam[1]), MAKEWORD(pParam[2], pParam[3]));
|
||
yt_type = pParam[4];
|
||
|
||
if (yt_type == USE_YT_NA)
|
||
{
|
||
data_length = 2;
|
||
buffer[len++] = C_SE_NA_1;
|
||
}
|
||
else if (yt_type == USE_YT_NB)
|
||
{
|
||
data_length = 2;
|
||
buffer[len++] = C_SE_NB_1;
|
||
}
|
||
else if (yt_type == USE_YT_NC)
|
||
{
|
||
data_length = 4;
|
||
buffer[len++] = C_SE_NC_1;
|
||
}
|
||
else
|
||
{
|
||
vLog(LOG_WARN, "Unit(%d) set point(%d) type(%d) error.\n", uid, order, yt_type);
|
||
return FALSE;
|
||
}
|
||
if (YTS_SELREQ == state)
|
||
{
|
||
cause_of_transmission = IEC_101_104_COT_ACT;
|
||
command |= IEC_101_104_SE;
|
||
}
|
||
else if (YTS_EXEREQ == state)
|
||
{
|
||
cause_of_transmission = IEC_101_104_COT_ACT;
|
||
command = 0;
|
||
}
|
||
else if ((YTS_ABRREQ == state) || ((YTS_SELING == state || YTS_SELED == state) && YTR_OVER == result))
|
||
{
|
||
cause_of_transmission = IEC_101_104_COT_DEACT;
|
||
command = 0;
|
||
}
|
||
|
||
buffer[len++] = 0x01;
|
||
//传输原因
|
||
if (1 == m_nOption.cot_size)
|
||
{
|
||
buffer[len++] = (BYTE)(cause_of_transmission & 0xff);
|
||
}
|
||
else if (2 == m_nOption.cot_size)
|
||
{
|
||
buffer[len++] = (BYTE)(cause_of_transmission & 0x00ff);
|
||
buffer[len++] = (BYTE)((cause_of_transmission >> 8) & 0x00ff);
|
||
}
|
||
//应用地址
|
||
if (1 == m_nOption.asdu_addr_size)
|
||
{
|
||
buffer[len++] = (BYTE)(pItem->apdu_addr & 0xff);
|
||
}
|
||
else if (2 == m_nOption.asdu_addr_size)
|
||
{
|
||
buffer[len++] = (BYTE)(pItem->apdu_addr & 0x00ff);
|
||
buffer[len++] = (BYTE)((pItem->apdu_addr >> 8) & 0x00ff);
|
||
}
|
||
//信息体地址
|
||
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
buffer[len++] = (BYTE)(information_address & 0xff);
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
buffer[len++] = (BYTE)(information_address & 0xff);
|
||
buffer[len++] = (BYTE)((information_address >> 8) & 0xff);
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
buffer[len++] = (BYTE)(information_address & 0xff);
|
||
buffer[len++] = (BYTE)((information_address >> 8) & 0xff);
|
||
buffer[len++] = (BYTE)((information_address >> 16) & 0xff);
|
||
}
|
||
if (data_length == 2)
|
||
{
|
||
buffer[len++] = value & 0xff;
|
||
buffer[len++] = (value >> 8) & 0xff;
|
||
}
|
||
else if (data_length == 4)
|
||
{
|
||
buffer[len++] = value & 0xff;
|
||
buffer[len++] = (value >> 8) & 0xff;
|
||
buffer[len++] = (value >> 16) & 0xff;
|
||
buffer[len++] = (value >> 24) & 0xff;
|
||
}
|
||
buffer[len++] = command;
|
||
|
||
return SendIFrame(buffer, len, ord);
|
||
}
|
||
//host end
|
||
//sub begin
|
||
|
||
int CIEC104Process::MakeYKFrame(CIEC104ProcessItem* pItem, int ord)
|
||
{
|
||
BYTE buffer[32];
|
||
if (NULL == pItem) return -1;
|
||
|
||
int order;
|
||
BYTE value, action, result;
|
||
|
||
if (!GetUnitYK(pItem->GetUnitID(), order, value, action, result))
|
||
{
|
||
return 0;
|
||
}
|
||
vLog(LOG_WARN, "Unit(%d) yk(%d) %s state is %s result is %s\n", pItem->GetUnitID(), order, (value ? "CLOSE" : "TRIP"), val_to_str(action, yk_state, "STATE=%d"), val_to_str(result, yk_result, "RESULT=%d"));
|
||
memset(buffer, 0, sizeof(buffer));
|
||
if (YKS_SELED == action && YKR_FAIL == result)
|
||
{
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length] |= IEC_101_104_SE;
|
||
action = YKS_ABRED;
|
||
}
|
||
else if (YKS_SELREQ == action && YKR_OVER == result)
|
||
{
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length] |= IEC_101_104_SE;
|
||
action = YKS_ABRED;
|
||
}
|
||
else if (YKS_SELING == action && YKR_OVER == result)
|
||
{
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length] |= IEC_101_104_SE;
|
||
action = YKS_ABRED;
|
||
}
|
||
BYTE* param;
|
||
BOOLEAN yk_type;
|
||
//BYTE relay_type;
|
||
DWORD ioa;
|
||
param = GetUnitYKParamByPoint(pItem->GetUnitID(), order);
|
||
ioa = MAKEDWORD(MAKEWORD(param[0], param[1]), MAKEWORD(param[2], param[3]));
|
||
yk_type = param[4];
|
||
//relay_type = param[5];
|
||
if (yk_type == USE_YK_DC || yk_type == USE_YK_DEF)
|
||
{ //双点遥控
|
||
buffer[0] = C_DC_NA_1;
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length] |= value ? DCO_ON : DCO_OFF;
|
||
}
|
||
else
|
||
{
|
||
buffer[0] = C_SC_NA_1;
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length] |= value ? SCO_ON : SCO_OFF;
|
||
}
|
||
buffer[1] = 1;
|
||
if (YKS_SELED == action)
|
||
{
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length] |= IEC_101_104_SE;
|
||
SetCOT(&buffer[2], IEC_101_104_COT_ACTCON);
|
||
}
|
||
else if (YKS_ABRED == action)
|
||
{
|
||
SetCOT(&buffer[2], IEC_101_104_COT_DEACTCON);
|
||
}
|
||
else if (YKS_EXEED == action)
|
||
{
|
||
SetCOT(&buffer[2], IEC_101_104_COT_ACTTREM);
|
||
}
|
||
else
|
||
{
|
||
return 0;
|
||
}
|
||
SetAsduAddr(&buffer[2 + cot_length], pItem->apdu_addr);
|
||
SetInformationAddr(&buffer[2 + cot_length + asdu_addr_length], ioa);
|
||
if (!SendIFrame(buffer, (3 + cot_length + asdu_addr_length + info_addr_length), ord)) return -1;
|
||
|
||
return 1;
|
||
}
|
||
|
||
|
||
int CIEC104Process::MakeYTFrame(CIEC104ProcessItem* pItem, int ord)
|
||
{
|
||
BYTE buffer[32];
|
||
if (NULL == pItem) return -1;
|
||
|
||
int order;
|
||
BYTE action, result;
|
||
DWORD value;
|
||
|
||
if (!GetUnitYT(pItem->GetUnitID(), order, value, action, result))
|
||
{
|
||
return 0;
|
||
}
|
||
vLog(LOG_DEBUG, "Unit(%d) set point(%d) %d state is %s result is %s\n", pItem->GetUnitID(), order, value, val_to_str(action, yt_state, "STATE=%d"), val_to_str(result, yt_result, "RESULT=%d"));
|
||
memset(buffer, 0, sizeof(buffer));
|
||
BYTE* param;
|
||
BOOLEAN yt_type;
|
||
DWORD ioa;
|
||
int data_length = 2;
|
||
param = GetUnitYTParamByPoint(pItem->GetUnitID(), order);
|
||
ioa = MAKEDWORD(MAKEWORD(param[0], param[1]), MAKEWORD(param[2], param[3]));
|
||
yt_type = param[4];
|
||
if (yt_type == USE_YT_NA)
|
||
{ //双点遥控
|
||
data_length = 2;
|
||
buffer[0] = C_SE_NA_1;
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length] = value & 0xff;
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length + 1] = (value >> 8) & 0xff;
|
||
}
|
||
else if (yt_type == USE_YT_NB)
|
||
{
|
||
data_length = 2;
|
||
buffer[0] = C_SE_NB_1;
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length] = value & 0xff;
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length + 1] = (value >> 8) & 0xff;
|
||
}
|
||
else
|
||
{
|
||
data_length = 4;
|
||
buffer[0] = C_SE_NC_1;
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length] = value & 0xff;
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length + 1] = (value >> 8) & 0xff;
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length + 2] = (value >> 16) & 0xff;
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length + 3] = (value >> 24) & 0xff;
|
||
}
|
||
buffer[1] = 1;
|
||
if (YTS_SELED == action && YTR_FAIL == result)
|
||
{
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length + data_length] |= IEC_101_104_SE;
|
||
action = YTS_ABRED;
|
||
}
|
||
else if (YTS_SELREQ == action && YTR_OVER == result)
|
||
{
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length + data_length] |= IEC_101_104_SE;
|
||
action = YTS_ABRED;
|
||
}
|
||
else if (YTS_SELING == action && YTR_OVER == result)
|
||
{
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length + data_length] |= IEC_101_104_SE;
|
||
action = YTS_ABRED;
|
||
}
|
||
|
||
if (YTS_SELED == action)
|
||
{
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length + data_length] |= IEC_101_104_SE;
|
||
SetCOT(&buffer[2], IEC_101_104_COT_ACTCON);
|
||
}
|
||
else if (YTS_ABRED == action)
|
||
{
|
||
SetCOT(&buffer[2], IEC_101_104_COT_DEACTCON);
|
||
}
|
||
else if (YTS_EXEED == action)
|
||
{
|
||
SetCOT(&buffer[2], IEC_101_104_COT_ACTTREM);
|
||
}
|
||
else
|
||
{
|
||
return FALSE;
|
||
}
|
||
SetAsduAddr(&buffer[2 + cot_length], pItem->apdu_addr);
|
||
SetInformationAddr(&buffer[2 + cot_length + asdu_addr_length], ioa);
|
||
if (!SendIFrame(buffer, (3 + cot_length + asdu_addr_length + info_addr_length + data_length), ord)) return -1;
|
||
|
||
return 1;
|
||
}
|
||
|
||
int CIEC104Process::Receive_Interrogation_command(CIEC104ProcessItem* pItem, const BYTE* pBuf, BYTE cause_of_transmission, BYTE* pTarget, int& count) //总召唤
|
||
{
|
||
BYTE QOI;
|
||
BYTE* pData = (BYTE*)pBuf;
|
||
|
||
if (NULL == pItem) return ERROR_UNKNOWN;
|
||
|
||
pData += info_addr_length;
|
||
QOI = *pData;
|
||
|
||
pTarget[0] = C_IC_NA_1;
|
||
pTarget[1] = 1;
|
||
SetAsduAddr(&pTarget[2 + cot_length], pItem->apdu_addr);
|
||
SetInformationAddr(&pTarget[2 + cot_length + asdu_addr_length], (DWORD)0);
|
||
pTarget[2 + cot_length + asdu_addr_length + info_addr_length] = QOI;
|
||
count = 3 + cot_length + asdu_addr_length + info_addr_length;
|
||
|
||
if (IEC_101_104_COT_ACT == cause_of_transmission)
|
||
{
|
||
if (QOI < 20 || QOI > 36)
|
||
{
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_ACTCON | IEC_101_104_COT_PN);
|
||
return ERROR_PARAM;
|
||
}
|
||
else
|
||
{ //总召唤，分组召唤
|
||
pItem->interrogation_type = QOI;
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_ACTCON);
|
||
}
|
||
return NO_ERROR;
|
||
}
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_UNKNOWN_COT);
|
||
return ERROR_CAUSE_OF_TRANSMISSION; //传输原因错误
|
||
}
|
||
|
||
int CIEC104Process::Receive_Clock_synchronisation_command(CIEC104ProcessItem* pItem, const BYTE* pBuf, BYTE cause_of_transmission, BYTE* pTarget, int& count) //时钟同步
|
||
{
|
||
BYTE* pData = (BYTE*)pBuf;
|
||
if (NULL == pItem) return ERROR_UNKNOWN;
|
||
|
||
unionCP56Time st;
|
||
pData += info_addr_length;
|
||
st.millisecond = *pData; pData++;
|
||
st.millisecond |= (*pData << 8); pData++;
|
||
st.minute = *pData & 0x3f;
|
||
st.IV = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
st.hour = *pData & 0x1f;
|
||
st.SU = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
st.dayofmonth = *pData & 0x1f;
|
||
st.dayofweek = ((*pData & 0xe0) >> 5); pData++;
|
||
st.month = *pData & 0x0f; pData++;
|
||
st.year = *pData & 0x7f; pData++;
|
||
|
||
pTarget[0] = C_CS_NA_1;
|
||
pTarget[1] = 1;
|
||
SetAsduAddr(&pTarget[2 + cot_length], pItem->apdu_addr);
|
||
SetInformationAddr(&pTarget[2 + cot_length + asdu_addr_length], (DWORD)0);
|
||
pTarget[2 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)(st.millisecond & 0x00ff);
|
||
pTarget[3 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)((st.millisecond >> 8)& 0x00ff);
|
||
pTarget[4 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)(st.minute | (st.IV << 7));
|
||
pTarget[5 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)(st.hour | (st.SU << 7));
|
||
pTarget[6 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)(st.dayofmonth | (st.dayofweek << 5));
|
||
pTarget[7 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)st.month;
|
||
pTarget[8 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)st.year;
|
||
count = 9 + cot_length + asdu_addr_length + info_addr_length;
|
||
|
||
if (IEC_101_104_COT_ACT == cause_of_transmission)
|
||
{
|
||
if (st.IV)
|
||
{
|
||
vLog(LOG_WARN, "Remote Control system time is invalid.\n");
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_ACTCON | IEC_101_104_COT_PN);
|
||
return ERROR_PARAM;
|
||
}
|
||
/*if (!IsAcceptTime())
|
||
{
|
||
vLog(LOG_WARN, "Local clock sync is not supported or not configured.\n");
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_ACTCON | IEC_101_104_COT_PN);
|
||
return NO_ERROR;
|
||
}*/
|
||
set_system_time(&st);
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_ACTCON);
|
||
return NO_ERROR;
|
||
}
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_UNKNOWN_COT);
|
||
return ERROR_CAUSE_OF_TRANSMISSION; //传输原因错误
|
||
}
|
||
|
||
int CIEC104Process::Receive_Counter_interrogation_command(CIEC104ProcessItem* pItem, const BYTE* pBuf, BYTE cause_of_transmission, BYTE* pTarget, int& count) //累积量
|
||
{
|
||
BYTE QCC;
|
||
BYTE* pData = (BYTE*)pBuf;
|
||
|
||
if (NULL == pItem) return ERROR_UNKNOWN;
|
||
|
||
pData += info_addr_length;
|
||
QCC = *pData;
|
||
|
||
pTarget[0] = C_CI_NA_1;
|
||
pTarget[1] = 1;
|
||
SetAsduAddr(&pTarget[2 + cot_length], pItem->apdu_addr);
|
||
SetInformationAddr(&pTarget[2 + cot_length + asdu_addr_length], (DWORD)0);
|
||
pTarget[2 + cot_length + asdu_addr_length + info_addr_length] = QCC;
|
||
count = 3 + cot_length + asdu_addr_length + info_addr_length;
|
||
|
||
//累计量召唤命令限定词出错
|
||
/*
|
||
if ((QCC & 0x3f) < 1 || (QCC & 0x3f) > 5)
|
||
{
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_ACTCON | IEC_101_104_COT_PN);
|
||
return ERROR_PARAM;
|
||
}
|
||
*/
|
||
if (IEC_101_104_COT_ACT == cause_of_transmission)
|
||
{
|
||
pItem->pulse_type = QCC;
|
||
pItem->ym_pos = 0;
|
||
pItem->pulse_start = TRUE;
|
||
pItem->pulse_fin = FALSE;
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_ACTCON);
|
||
return NO_ERROR;
|
||
}
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_UNKNOWN_COT);
|
||
return ERROR_CAUSE_OF_TRANSMISSION; //传输原因错误
|
||
}
|
||
|
||
int CIEC104Process::Receive_Reset_process_command(CIEC104ProcessItem* pItem, const BYTE* pBuf, BYTE cause_of_transmission, BYTE* pTarget, int& count) //复位进程
|
||
{
|
||
if (IEC_101_104_COT_ACT == cause_of_transmission)
|
||
{
|
||
return NO_ERROR;
|
||
}
|
||
return ERROR_CAUSE_OF_TRANSMISSION;
|
||
}
|
||
|
||
int CIEC104Process::Receive_Single_command(CIEC104ProcessItem* pItem, const BYTE* pBuf, BYTE cause_of_transmission, BYTE* pTarget, int& count) //单点令
|
||
{
|
||
BYTE* pData = (BYTE*)pBuf;
|
||
BYTE command;
|
||
int uid, point;
|
||
DWORD information_address;
|
||
BOOLEAN value;
|
||
BYTE SE;
|
||
|
||
if (NULL == pItem) return ERROR_UNKNOWN;
|
||
|
||
information_address = GetInformationAddr(pData); pData += info_addr_length;
|
||
command = *pData;
|
||
|
||
pTarget[0] = C_SC_NA_1;
|
||
pTarget[1] = 1;
|
||
SetAsduAddr(&pTarget[2 + cot_length], pItem->apdu_addr);
|
||
SetInformationAddr(&pTarget[2 + cot_length + asdu_addr_length], information_address);
|
||
pTarget[2 + cot_length + asdu_addr_length + info_addr_length] = command;
|
||
count = 3 + cot_length + asdu_addr_length + info_addr_length;
|
||
if (IEC_101_104_COT_ACT == cause_of_transmission || IEC_101_104_COT_DEACT == cause_of_transmission)
|
||
{
|
||
uid = pItem->GetUnitID();
|
||
BYTE ioa[4];
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
|
||
point = GetUnitYKPointByParam(uid, ioa, 4);
|
||
if (point < 0)
|
||
{ //信息体地址错误
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_UNKNOWN_INFO);
|
||
return ERROR_INFORMATION_ADDRESS;
|
||
}
|
||
SE = GET_SE(command);
|
||
value = GET_SCO(command); pData++;
|
||
//判断该点是否为单点遥控及参数状态
|
||
BYTE* param;
|
||
BYTE yk_type;
|
||
BYTE relay_type;
|
||
param = GetUnitYKParamByPoint(uid, point);
|
||
yk_type = param[4];
|
||
relay_type = param[5];
|
||
if (yk_type != USE_YK_SC)
|
||
{ //遥控类型错误，返回否定确认
|
||
SetCOT(&pTarget[2], ((cause_of_transmission + 1) | IEC_101_104_COT_PN));
|
||
return ERROR_PARAM;
|
||
}
|
||
if (relay_type)
|
||
{
|
||
if (relay_type == 1)
|
||
{ //Only on
|
||
if (!value)
|
||
{
|
||
vLog(LOG_ERROR, "Only on,Cann't off!\n");
|
||
SetCOT(&pTarget[2], ((cause_of_transmission + 1) | IEC_101_104_COT_PN));
|
||
return ERROR_PARAM;
|
||
}
|
||
}
|
||
else
|
||
{ //Only off
|
||
if (value)
|
||
{
|
||
vLog(LOG_ERROR, "Only off,Cann't on!\n");
|
||
SetCOT(&pTarget[2], ((cause_of_transmission + 1) | IEC_101_104_COT_PN));
|
||
return ERROR_PARAM;
|
||
}
|
||
}
|
||
}
|
||
if (IEC_101_104_COT_ACT == cause_of_transmission)
|
||
{ //激活
|
||
if (SE)
|
||
{ //选择
|
||
count = 0;
|
||
SetUnitYK(uid, point, value, YKS_SELREQ, YKR_IDLE);
|
||
vLog(LOG_WARN, "Unit(%d) yk(%d) %s state is YKS_SELREQ result is YKR_IDLE.\n", uid, point, (value ? "CLOSE" : "TRIP"));
|
||
return NO_ERROR;
|
||
}
|
||
else
|
||
{ //执行
|
||
SetUnitYK(uid, point, value, YKS_EXEREQ, YKR_IDLE);
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_ACTCON);
|
||
vLog(LOG_WARN, "Unit(%d) yk(%d) %s state is YKS_EXEREQ result is YKR_IDLE.\n", uid, point, (value ? "CLOSE" : "TRIP"));
|
||
return NO_ERROR;
|
||
}
|
||
}
|
||
else if (IEC_101_104_COT_DEACT == cause_of_transmission)
|
||
{ //激活终止
|
||
SetUnitYK(uid, point, value, YKS_ABRREQ, YKR_IDLE);
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_DEACTCON);
|
||
vLog(LOG_WARN, "Unit(%d) yk(%d) %s state is YKS_ABRREQ result is YKR_IDLE.\n", uid, point, (value ? "CLOSE" : "TRIP"));
|
||
return NO_ERROR;
|
||
}
|
||
}
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_UNKNOWN_COT);
|
||
return ERROR_CAUSE_OF_TRANSMISSION;
|
||
}
|
||
|
||
int CIEC104Process::Receive_Double_command(CIEC104ProcessItem* pItem, const BYTE* pBuf, BYTE cause_of_transmission, BYTE* pTarget, int& count) //单点令
|
||
{
|
||
BYTE* pData = (BYTE*)pBuf;
|
||
BYTE command;
|
||
int uid, point;
|
||
DWORD information_address;
|
||
BOOLEAN value;
|
||
BYTE SE;
|
||
if (NULL == pItem) return ERROR_UNKNOWN;
|
||
information_address = GetInformationAddr(pData); pData += info_addr_length;
|
||
command = *pData;
|
||
|
||
pTarget[0] = C_DC_NA_1;
|
||
pTarget[1] = 1;
|
||
SetAsduAddr(&pTarget[2 + cot_length], pItem->apdu_addr);
|
||
SetInformationAddr(&pTarget[2 + cot_length + asdu_addr_length], information_address);
|
||
pTarget[2 + cot_length + asdu_addr_length + info_addr_length] = command;
|
||
count = 3 + cot_length + asdu_addr_length + info_addr_length;
|
||
if (IEC_101_104_COT_ACT == cause_of_transmission || IEC_101_104_COT_DEACT == cause_of_transmission)
|
||
{
|
||
uid = pItem->GetUnitID();
|
||
BYTE ioa[4];
|
||
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
|
||
point = GetUnitYKPointByParam(uid, ioa, 4);
|
||
if (point < 0)
|
||
{
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_UNKNOWN_INFO);
|
||
count = 3 + cot_length + asdu_addr_length + info_addr_length;
|
||
return ERROR_INFORMATION_ADDRESS;
|
||
}
|
||
SE = GET_SE(command);
|
||
value = GET_DCO(command); pData++;
|
||
//判断该点是否为单点遥控及参数状态
|
||
BYTE* param;
|
||
BYTE yk_type;
|
||
//BYTE relay_type;
|
||
param = GetUnitYKParamByPoint(uid, point);
|
||
yk_type = param[4];
|
||
//relay_type = param[5];
|
||
if (yk_type == USE_YK_SC)
|
||
{ //遥控类型错误，返回否定确认
|
||
SetCOT(&pTarget[2], ((cause_of_transmission + 1) | IEC_101_104_COT_PN));
|
||
return ERROR_PARAM;
|
||
}
|
||
if (IEC_101_104_COT_ACT == cause_of_transmission)
|
||
{ //激活
|
||
if (SE)
|
||
{ //选择
|
||
count = 0;
|
||
SetUnitYK(uid, point, value, YKS_SELREQ, YKR_IDLE);
|
||
vLog(LOG_WARN, "Unit(%d) yk(%d) %s state is YKS_SELREQ result is YKR_IDLE.\n", uid, point, (value ? "CLOSE" : "TRIP"));
|
||
return NO_ERROR;
|
||
}
|
||
else
|
||
{ //执行
|
||
SetUnitYK(uid, point, value, YKS_EXEREQ, YKR_IDLE);
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_ACTCON);
|
||
vLog(LOG_WARN, "Unit(%d) yk(%d) %s state is YKS_EXEREQ result is YKR_IDLE.\n", uid, point, (value ? "CLOSE" : "TRIP"));
|
||
return NO_ERROR;
|
||
}
|
||
}
|
||
else if (IEC_101_104_COT_DEACT == cause_of_transmission)
|
||
{ //激活终止
|
||
SetUnitYK(uid, point, value, YKS_ABRREQ, YKR_IDLE);
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_DEACTCON);
|
||
vLog(LOG_WARN, "Unit(%d) yk(%d) %s state is YKS_ABRREQ result is YKR_IDLE.\n", uid, point, (value ? "CLOSE" : "TRIP"));
|
||
return NO_ERROR;
|
||
}
|
||
}
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_UNKNOWN_COT);
|
||
return ERROR_CAUSE_OF_TRANSMISSION;
|
||
}
|
||
|
||
|
||
int CIEC104Process::Receive_Set_point_command_normalized(CIEC104ProcessItem* pItem, const BYTE* pBuf, BYTE cause_of_transmission, BYTE* pTarget, int& count) //设定规一化值命令
|
||
{
|
||
BYTE* pData = (BYTE*)pBuf;
|
||
BYTE command;
|
||
int uid, point;
|
||
int information_address;
|
||
WORD value = 0;
|
||
BYTE SE;
|
||
|
||
if (NULL == pItem) return ERROR_UNKNOWN;
|
||
information_address = GetInformationAddr(pData);
|
||
pData += info_addr_length;
|
||
value = (WORD)(pData[0] | pData[1] << 8);
|
||
pData += 2;
|
||
command = *pData;
|
||
|
||
pTarget[0] = C_SE_NA_1;
|
||
pTarget[1] = 1;
|
||
SetAsduAddr(&pTarget[2 + cot_length], pItem->apdu_addr);
|
||
SetInformationAddr(&pTarget[2 + cot_length + asdu_addr_length], information_address);
|
||
pTarget[2 + cot_length + asdu_addr_length + info_addr_length] = value & 0xff;
|
||
pTarget[2 + cot_length + asdu_addr_length + info_addr_length + 1] = (value >> 8) & 0xff;
|
||
pTarget[2 + cot_length + asdu_addr_length + info_addr_length + 2] = command;
|
||
count = 3 + cot_length + asdu_addr_length + info_addr_length + 2;
|
||
if (IEC_101_104_COT_ACT == cause_of_transmission || IEC_101_104_COT_DEACT == cause_of_transmission)
|
||
{
|
||
uid = pItem->GetUnitID();
|
||
BYTE ioa[4];
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYTPointByParam(uid, ioa, 4);
|
||
if (point < 0)
|
||
{
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_UNKNOWN_INFO);
|
||
count = 3 + cot_length + asdu_addr_length + info_addr_length + 2;
|
||
return ERROR_INFORMATION_ADDRESS;
|
||
}
|
||
SE = GET_SE(command);
|
||
//判断该点是否为单点遥控及参数状态
|
||
BYTE* param;
|
||
BYTE yt_type;
|
||
param = GetUnitYTParamByPoint(pItem->GetUnitID(), point);
|
||
yt_type = param[4];
|
||
if (yt_type != USE_YT_NA)
|
||
{ //遥控类型错误，返回否定确认
|
||
SetCOT(&pTarget[2], ((cause_of_transmission + 1) | IEC_101_104_COT_PN));
|
||
return ERROR_PARAM;
|
||
}
|
||
if (IEC_101_104_COT_ACT == cause_of_transmission)
|
||
{ //激活
|
||
if (SE)
|
||
{ //选择
|
||
count = 0;
|
||
SetUnitYT(uid, point, value, YTS_SELREQ, YTR_IDLE);
|
||
vLog(LOG_DEBUG, "Unit(%d) set point(%d) %d state is YTS_SELREQ result is YTR_IDLE.\n", uid, point, value);
|
||
return NO_ERROR;
|
||
}
|
||
else
|
||
{ //执行
|
||
SetUnitYT(uid, point, value, YTS_EXEREQ, YTR_IDLE);
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_ACTCON);
|
||
vLog(LOG_DEBUG, "Unit(%d) set point(%d) %d state is YTS_EXEREQ result is YTR_IDLE.\n", uid, point, value);
|
||
return NO_ERROR;
|
||
}
|
||
}
|
||
else if (IEC_101_104_COT_DEACT == cause_of_transmission)
|
||
{ //激活终止
|
||
SetUnitYT(uid, point, value, YTS_ABRREQ, YTR_IDLE);
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_DEACTCON);
|
||
vLog(LOG_DEBUG, "Unit(%d) set point(%d) %d state is YTS_ABRREQ result is YTR_IDLE.\n", uid, point, value);
|
||
return NO_ERROR;
|
||
}
|
||
}
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_UNKNOWN_COT);
|
||
return ERROR_CAUSE_OF_TRANSMISSION;
|
||
}
|
||
|
||
int CIEC104Process::Receive_Set_point_command_scaled(CIEC104ProcessItem* pItem, const BYTE* pBuf, BYTE cause_of_transmission, BYTE* pTarget, int& count) //设定标度化值命令
|
||
{
|
||
BYTE* pData = (BYTE*)pBuf;
|
||
BYTE command;
|
||
int uid, point;
|
||
int information_address;
|
||
WORD value = 0;
|
||
BYTE SE;
|
||
|
||
if (NULL == pItem) return ERROR_UNKNOWN;
|
||
information_address = GetInformationAddr(pData);
|
||
pData += info_addr_length;
|
||
value = (WORD)(pData[0] | pData[1] << 8);
|
||
pData += 2;
|
||
command = *pData;
|
||
|
||
pTarget[0] = C_SE_NB_1;
|
||
pTarget[1] = 1;
|
||
SetAsduAddr(&pTarget[2 + cot_length], pItem->apdu_addr);
|
||
SetInformationAddr(&pTarget[2 + cot_length + asdu_addr_length], information_address);
|
||
pTarget[2 + cot_length + asdu_addr_length + info_addr_length] = value & 0xff;
|
||
pTarget[2 + cot_length + asdu_addr_length + info_addr_length + 1] = (value >> 8) & 0xff;
|
||
pTarget[2 + cot_length + asdu_addr_length + info_addr_length + 2] = command;
|
||
count = 3 + cot_length + asdu_addr_length + info_addr_length + 2;
|
||
if (IEC_101_104_COT_ACT == cause_of_transmission || IEC_101_104_COT_DEACT == cause_of_transmission)
|
||
{
|
||
uid = pItem->GetUnitID();
|
||
BYTE ioa[4];
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYTPointByParam(uid, ioa, 4);
|
||
if (point < 0)
|
||
{
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_UNKNOWN_INFO);
|
||
count = 3 + cot_length + asdu_addr_length + info_addr_length + 2;
|
||
return ERROR_INFORMATION_ADDRESS;
|
||
}
|
||
SE = GET_SE(command);
|
||
//判断该点是否为单点遥控及参数状态
|
||
BYTE* param;
|
||
BYTE yt_type;
|
||
param = GetUnitYTParamByPoint(pItem->GetUnitID(), point);
|
||
yt_type = param[4];
|
||
if (yt_type != USE_YT_NB)
|
||
{ //遥控类型错误，返回否定确认
|
||
SetCOT(&pTarget[2], ((cause_of_transmission + 1) | IEC_101_104_COT_PN));
|
||
return ERROR_PARAM;
|
||
}
|
||
if (IEC_101_104_COT_ACT == cause_of_transmission)
|
||
{ //激活
|
||
if (SE)
|
||
{ //选择
|
||
count = 0;
|
||
SetUnitYT(uid, point, value, YTS_SELREQ, YTR_IDLE);
|
||
vLog(LOG_DEBUG, "Unit(%d) set point(%d) %d state is YTS_SELREQ result is YTR_IDLE.\n", uid, point, value);
|
||
return NO_ERROR;
|
||
}
|
||
else
|
||
{ //执行
|
||
SetUnitYT(uid, point, value, YTS_EXEREQ, YTR_IDLE);
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_ACTCON);
|
||
vLog(LOG_DEBUG, "Unit(%d) set point(%d) %d state is YTS_EXEREQ result is YTR_IDLE.\n", uid, point, value);
|
||
return NO_ERROR;
|
||
}
|
||
}
|
||
else if (IEC_101_104_COT_DEACT == cause_of_transmission)
|
||
{ //激活终止
|
||
SetUnitYT(uid, point, value, YTS_ABRREQ, YTR_IDLE);
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_DEACTCON);
|
||
vLog(LOG_DEBUG, "Unit(%d) set point(%d) %d state is YTS_ABRREQ result is YTR_IDLE.\n", uid, point, value);
|
||
return NO_ERROR;
|
||
}
|
||
}
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_UNKNOWN_COT);
|
||
return ERROR_CAUSE_OF_TRANSMISSION;
|
||
}
|
||
|
||
int CIEC104Process::Receive_Set_point_command_short_floating(CIEC104ProcessItem* pItem, const BYTE* pBuf, BYTE cause_of_transmission, BYTE* pTarget, int& count) //设定短浮点值命令
|
||
{
|
||
BYTE* pData = (BYTE*)pBuf;
|
||
BYTE command;
|
||
int uid, point;
|
||
int information_address;
|
||
DWORD value;
|
||
BYTE SE;
|
||
|
||
if (NULL == pItem) return ERROR_UNKNOWN;
|
||
information_address = GetInformationAddr(pData);
|
||
pData += info_addr_length;
|
||
value = (DWORD)(pData[0] | (pData[1] << 8) | (pData[2] << 16) | (pData[3] << 24));
|
||
pData += 4;
|
||
|
||
command = *pData;
|
||
|
||
pTarget[0] = C_SE_NC_1;
|
||
pTarget[1] = 1;
|
||
SetAsduAddr(&pTarget[2 + cot_length], pItem->apdu_addr);
|
||
SetInformationAddr(&pTarget[2 + cot_length + asdu_addr_length], information_address);
|
||
pTarget[2 + cot_length + asdu_addr_length + info_addr_length] = value & 0xff;
|
||
pTarget[2 + cot_length + asdu_addr_length + info_addr_length + 1] = (value >> 8) & 0xff;
|
||
pTarget[2 + cot_length + asdu_addr_length + info_addr_length + 2] = (value >> 16) & 0xff;
|
||
pTarget[2 + cot_length + asdu_addr_length + info_addr_length + 3] = (value >> 24) & 0xff;
|
||
pTarget[2 + cot_length + asdu_addr_length + info_addr_length + 4] = command;
|
||
count = 3 + cot_length + asdu_addr_length + info_addr_length + 4;
|
||
if (IEC_101_104_COT_ACT == cause_of_transmission || IEC_101_104_COT_DEACT == cause_of_transmission)
|
||
{
|
||
uid = pItem->GetUnitID();
|
||
BYTE ioa[4];
|
||
ioa[0] = information_address & 0xff;
|
||
ioa[1] = (information_address >> 8) & 0xff;
|
||
ioa[2] = (information_address >> 16) & 0xff;
|
||
ioa[3] = (information_address >> 24) & 0xff;
|
||
point = GetUnitYTPointByParam(uid, ioa, 4);
|
||
if (point < 0)
|
||
{
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_UNKNOWN_INFO);
|
||
count = 3 + cot_length + asdu_addr_length + info_addr_length + 4;
|
||
return ERROR_INFORMATION_ADDRESS;
|
||
}
|
||
SE = GET_SE(command);
|
||
//判断该点是否为单点遥控及参数状态
|
||
BYTE* param;
|
||
BYTE yt_type;
|
||
param = GetUnitYTParamByPoint(pItem->GetUnitID(), point);
|
||
yt_type = param[4];
|
||
if (yt_type != USE_YT_NC)
|
||
{ //遥控类型错误，返回否定确认
|
||
SetCOT(&pTarget[2], ((cause_of_transmission + 1) | IEC_101_104_COT_PN));
|
||
return ERROR_PARAM;
|
||
}
|
||
if (IEC_101_104_COT_ACT == cause_of_transmission)
|
||
{ //激活
|
||
if (SE)
|
||
{ //选择
|
||
count = 0;
|
||
SetUnitYT(uid, point, value, YTS_SELREQ, YTR_IDLE);
|
||
vLog(LOG_DEBUG, "Unit(%d) set point(%d) %d state is YTS_SELREQ result is YTR_IDLE.\n", uid, point, value);
|
||
return NO_ERROR;
|
||
}
|
||
else
|
||
{ //执行
|
||
SetUnitYT(uid, point, value, YTS_EXEREQ, YTR_IDLE);
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_ACTCON);
|
||
vLog(LOG_DEBUG, "Unit(%d) set point(%d) %d state is YTS_EXEREQ result is YTR_IDLE.\n", uid, point, value);
|
||
return NO_ERROR;
|
||
}
|
||
}
|
||
else if (IEC_101_104_COT_DEACT == cause_of_transmission)
|
||
{ //激活终止
|
||
SetUnitYT(uid, point, value, YTS_ABRREQ, YTR_IDLE);
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_DEACTCON);
|
||
vLog(LOG_DEBUG, "Unit(%d) set point(%d) %d state is YTS_ABRREQ result is YTR_IDLE.\n", uid, point, value);
|
||
return NO_ERROR;
|
||
}
|
||
}
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_UNKNOWN_COT);
|
||
return ERROR_CAUSE_OF_TRANSMISSION;
|
||
}
|
||
|
||
int CIEC104Process::Send_End_of_initialisation(CIEC104ProcessItem* pItem, int ord)
|
||
{
|
||
BYTE buffer[32];
|
||
memset(buffer, 0, sizeof(buffer));
|
||
if (pItem == NULL) return -1;
|
||
buffer[0] = M_EI_NA_1; //初始化结束
|
||
buffer[1] = 1;
|
||
SetCOT(&buffer[2], IEC_101_104_COT_INIT);
|
||
SetAsduAddr(&buffer[2 + cot_length], pItem->apdu_addr);
|
||
SetInformationAddr(&buffer[2 + cot_length + asdu_addr_length], (DWORD)0);
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length] = 0;
|
||
if (!SendIFrame(buffer, (3 + cot_length + asdu_addr_length + info_addr_length), ord)) return -1;
|
||
return 1;
|
||
}
|
||
|
||
int CIEC104Process::Send_Single_point_information(CIEC104ProcessItem* pItem, int ord, BYTE cause_of_transimission /* = IEC_101_104_COT_SPONT */)
|
||
{
|
||
int uid;
|
||
int i, count;
|
||
BYTE buffer[256], *pData;
|
||
memset(buffer, 0, sizeof(buffer));
|
||
if (NULL == pItem) return -1;
|
||
pData = &buffer[2 + cot_length + asdu_addr_length];
|
||
buffer[0] = M_SP_NA_1;
|
||
SetCOT(&buffer[2], cause_of_transimission);
|
||
SetAsduAddr(&buffer[2 + cot_length], pItem->apdu_addr);
|
||
if (IEC_101_104_COT_SPONT == cause_of_transimission)
|
||
{ //遥信变位
|
||
count = ((max_frame - 8 - cot_length - asdu_addr_length) / (info_addr_length + 1));
|
||
count = pItem->yxbws.count > count ? count : pItem->yxbws.count;
|
||
if (count <= 0) return 0;
|
||
buffer[1] = (count & 0x7f);
|
||
for (i = 0; i < count; i++)
|
||
{
|
||
SetInformationAddr(pData, pItem->yxbws.data[i].order + m_yx_start_address);
|
||
pData += info_addr_length;
|
||
*pData = pItem->yxbws.data[i].value; pData++;
|
||
}
|
||
pItem->yxbws.count -= count;
|
||
if (pItem->yxbws.count <= 0 || pItem->yxbws.count >= DATABASE_YXBW_NUM)
|
||
{ //遥信变位发送结束
|
||
pItem->yxbws.count = 0;
|
||
}
|
||
else
|
||
{
|
||
memcpy(pItem->yxbws.data, &pItem->yxbws.data[count], sizeof(struYXData) * pItem->yxbws.count);
|
||
}
|
||
if (!SendIFrame(buffer, (2 + cot_length + asdu_addr_length + (info_addr_length + 1) * count), ord)) return -1;
|
||
return 1;
|
||
}
|
||
else
|
||
{ //召唤
|
||
count = (max_frame - 8 - cot_length - asdu_addr_length - info_addr_length);
|
||
count = count > 127 ? 127 : count; //遥信最大为127个信息
|
||
count = (pItem->total_yx - pItem->yx_pos) > count ? count : (pItem->total_yx - pItem->yx_pos);
|
||
if (count <= 0)
|
||
{
|
||
pItem->yx_pos = 0;
|
||
if (IEC_101_104_COT_INTERROGATION == cause_of_transimission && pItem->interrogation_start)
|
||
{
|
||
pItem->interrogation_yx_fin = TRUE; //遥信发送完毕
|
||
}
|
||
return 0;
|
||
}
|
||
buffer[1] = 0x80 | count;
|
||
SetInformationAddr(pData, pItem->yx_pos + m_yx_start_address);
|
||
pData += info_addr_length;
|
||
|
||
uid = pItem->GetUnitID();
|
||
for (i = 0; i < count; i++)
|
||
{
|
||
*pData = GetUnitYX(uid, pItem->yx_pos + i) | GetUnitYXQDS(uid, pItem->yx_pos + i);
|
||
pData++;
|
||
}
|
||
pItem->yx_pos += count;
|
||
if (pItem->yx_pos < 0 || pItem->yx_pos >= pItem->total_yx)
|
||
{
|
||
pItem->yx_pos = 0;
|
||
if (IEC_101_104_COT_INTERROGATION == cause_of_transimission && pItem->interrogation_start)
|
||
{
|
||
pItem->interrogation_yx_fin = TRUE; //遥信发送完毕
|
||
}
|
||
}
|
||
if (!SendIFrame(buffer, 2 + cot_length + asdu_addr_length + info_addr_length + count, ord)) return -1;
|
||
return 1;
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
int CIEC104Process::Send_Single_point_information_with_time_tag(CIEC104ProcessItem* pItem, int ord, BYTE cause_of_transimission /* = IEC_101_104_COT_SPONT */)
|
||
{
|
||
int i, count;
|
||
BYTE buffer[256], *pData;
|
||
memset(buffer, 0, sizeof(buffer));
|
||
if (NULL == pItem) return -1;
|
||
pData = &buffer[2 + cot_length + asdu_addr_length];
|
||
buffer[0] = M_SP_TA_1;
|
||
buffer[1] = 9;
|
||
SetCOT(&buffer[2], cause_of_transimission);
|
||
SetAsduAddr(&buffer[2 + cot_length], pItem->apdu_addr);
|
||
if (IEC_101_104_COT_SPONT == cause_of_transimission)
|
||
{ //短时标事件记录
|
||
count = ((max_frame - 8 - cot_length - asdu_addr_length) / (info_addr_length + 4));
|
||
count = pItem->events.count > count ? count : pItem->events.count;
|
||
if (count <= 0) return 0;
|
||
buffer[1] = (count & 0x7f);
|
||
for (i = 0; i < count; i++)
|
||
{
|
||
SetInformationAddr(pData, pItem->events.data[i].order + m_yx_start_address);
|
||
pData += info_addr_length;
|
||
*pData = pItem->events.data[i].value; pData++;
|
||
*pData = (BYTE)(pItem->events.data[i].ct.millisecond & 0x00ff); pData++;
|
||
*pData = (BYTE)((pItem->events.data[i].ct.millisecond >> 8)& 0x00ff); pData++;
|
||
*pData = (BYTE)(pItem->events.data[i].ct.minute | (pItem->events.data[i].ct.IV << 7)); pData++;
|
||
}
|
||
pItem->events.count -= count;
|
||
if (pItem->events.count <= 0 || pItem->events.count >= DATABASE_SOE_NUM)
|
||
{ //事件记录发送结束
|
||
pItem->events.count = 0;
|
||
}
|
||
else
|
||
{
|
||
memcpy(pItem->events.data, &pItem->events.data[count], sizeof(struEventsData) * pItem->events.count);
|
||
}
|
||
if (!SendIFrame(buffer, 2 + cot_length + asdu_addr_length + (info_addr_length + 4) * count, ord)) return -1;
|
||
return 1;
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
int CIEC104Process::Send_Single_point_information_with_time_tag_cp56time2a(CIEC104ProcessItem* pItem, int ord, BYTE cause_of_transimission /* = IEC_101_104_COT_SPONT */)
|
||
{
|
||
int i, count;
|
||
BYTE buffer[256], *pData;
|
||
memset(buffer, 0, sizeof(buffer));
|
||
if (NULL == pItem) return -1;
|
||
pData = &buffer[2 + cot_length + asdu_addr_length];
|
||
buffer[0] = M_SP_TB_1;
|
||
buffer[1] = 9;
|
||
SetCOT(&buffer[2], cause_of_transimission);
|
||
SetAsduAddr(&buffer[2 + cot_length], pItem->apdu_addr);
|
||
if (IEC_101_104_COT_SPONT == cause_of_transimission)
|
||
{ //长时标事件记录
|
||
count = ((max_frame - 8 - cot_length - asdu_addr_length) / (info_addr_length + 8));
|
||
count = pItem->events.count > count ? count : pItem->events.count;
|
||
if (count <= 0) return 0;
|
||
buffer[1] = (count & 0x7f);
|
||
for (i = 0; i < count; i++)
|
||
{
|
||
SetInformationAddr(pData, pItem->events.data[i].order + m_yx_start_address);
|
||
pData += info_addr_length;
|
||
*pData = pItem->events.data[i].value; pData++;
|
||
*pData = (BYTE)(pItem->events.data[i].ct.millisecond & 0x00ff); pData++;
|
||
*pData = (BYTE)((pItem->events.data[i].ct.millisecond >> 8)& 0x00ff); pData++;
|
||
*pData = (BYTE)(pItem->events.data[i].ct.minute | (pItem->events.data[i].ct.IV << 7)); pData++;
|
||
*pData = (BYTE)(pItem->events.data[i].ct.hour | (pItem->events.data[i].ct.SU << 7)); pData++;
|
||
*pData = (BYTE)(pItem->events.data[i].ct.dayofmonth | (pItem->events.data[i].ct.dayofweek << 5)); pData++;
|
||
*pData = (BYTE)pItem->events.data[i].ct.month; pData++;
|
||
*pData = (BYTE)pItem->events.data[i].ct.year; pData++;
|
||
}
|
||
pItem->events.count -= count;
|
||
if (pItem->events.count <= 0 || pItem->events.count >= DATABASE_SOE_NUM)
|
||
{ //事件记录发送结束
|
||
pItem->events.count = 0;
|
||
}
|
||
else
|
||
{
|
||
memcpy(pItem->events.data, &pItem->events.data[count], sizeof(struEventsData) * pItem->events.count);
|
||
}
|
||
if (!SendIFrame(buffer, 2 + cot_length + asdu_addr_length + (info_addr_length + 8) * count, ord)) return -1;
|
||
return 1;
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
int CIEC104Process::Send_Double_point_information(CIEC104ProcessItem* pItem, int ord, BYTE cause_of_transimission /* = IEC_101_104_COT_SPONT */)
|
||
{
|
||
int uid;
|
||
int i, count;
|
||
BYTE buffer[256], *pData;
|
||
memset(buffer, 0, sizeof(buffer));
|
||
if (NULL == pItem) return -1;
|
||
pData = &buffer[2 + cot_length + asdu_addr_length];
|
||
buffer[0] = M_DP_NA_1;
|
||
SetCOT(&buffer[2], cause_of_transimission);
|
||
SetAsduAddr(&buffer[2 + cot_length], pItem->apdu_addr);
|
||
if (IEC_101_104_COT_SPONT == cause_of_transimission)
|
||
{ //遥信变位
|
||
count = ((max_frame - 8 - cot_length - asdu_addr_length) / (info_addr_length + 1));
|
||
count = pItem->yxbws.count > count ? count : pItem->yxbws.count;
|
||
if (count <= 0) return 0;
|
||
buffer[1] = (count & 0x7f);
|
||
for (i = 0; i < count; i++)
|
||
{
|
||
SetInformationAddr(pData, pItem->yxbws.data[i].order + m_yx_start_address);
|
||
pData += info_addr_length;
|
||
*pData = pItem->yxbws.data[i].value ? DPI_ON : DPI_OFF; pData++;
|
||
}
|
||
pItem->yxbws.count -= count;
|
||
if (pItem->yxbws.count <= 0 || pItem->yxbws.count >= DATABASE_YXBW_NUM)
|
||
{ //遥信变位发送结束
|
||
pItem->yxbws.count = 0;
|
||
}
|
||
else
|
||
{
|
||
memcpy(pItem->yxbws.data, &pItem->yxbws.data[count], sizeof(struYXData) * pItem->yxbws.count);
|
||
}
|
||
if (!SendIFrame(buffer, 2 + cot_length + asdu_addr_length + (info_addr_length + 1) * count, ord)) return -1;
|
||
return 1;
|
||
}
|
||
else
|
||
{ //召唤
|
||
count = (max_frame - 8 - cot_length - asdu_addr_length - info_addr_length);
|
||
count = count > 127 ? 127 : count; //遥信最大为127个信息
|
||
count = (pItem->total_yx - pItem->yx_pos) > count ? count : (pItem->total_yx - pItem->yx_pos);
|
||
if (count <= 0)
|
||
{
|
||
pItem->yx_pos = 0;
|
||
if (IEC_101_104_COT_INTERROGATION == cause_of_transimission && pItem->interrogation_start)
|
||
{
|
||
pItem->interrogation_yx_fin = TRUE; //遥信发送完毕
|
||
}
|
||
return 0;
|
||
}
|
||
buffer[1] = 0x80 | count;
|
||
SetInformationAddr(pData, pItem->yx_pos + m_yx_start_address);
|
||
pData += info_addr_length;
|
||
BOOLEAN value;
|
||
uid = pItem->GetUnitID();
|
||
for (i = 0; i < count; i++)
|
||
{
|
||
value = GetUnitYX(uid, pItem->yx_pos + i) ? DPI_ON : DPI_OFF;
|
||
*pData = value | GetUnitYXQDS(uid, pItem->yx_pos + i);
|
||
pData++;
|
||
}
|
||
pItem->yx_pos += count;
|
||
if (pItem->yx_pos < 0 || pItem->yx_pos >= pItem->total_yx)
|
||
{
|
||
pItem->yx_pos = 0;
|
||
if (IEC_101_104_COT_INTERROGATION == cause_of_transimission && pItem->interrogation_start)
|
||
{
|
||
pItem->interrogation_yx_fin = TRUE; //遥信发送完毕
|
||
}
|
||
}
|
||
if (!SendIFrame(buffer, 2 + cot_length + asdu_addr_length + info_addr_length + count, ord)) return -1;
|
||
return 1;
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
int CIEC104Process::Send_Double_point_information_with_time_tag(CIEC104ProcessItem* pItem, int ord, BYTE cause_of_transimission /* = IEC_101_104_COT_SPONT */)
|
||
{
|
||
int i, count;
|
||
BYTE buffer[256], *pData;
|
||
memset(buffer, 0, sizeof(buffer));
|
||
if (NULL == pItem) return -1;
|
||
pData = &buffer[2 + cot_length + asdu_addr_length];
|
||
buffer[0] = M_DP_TA_1;
|
||
buffer[1] = 9;
|
||
SetCOT(&buffer[2], cause_of_transimission);
|
||
SetAsduAddr(&buffer[2 + cot_length], pItem->apdu_addr);
|
||
if (IEC_101_104_COT_SPONT == cause_of_transimission)
|
||
{ //短时标事件记录
|
||
count = ((max_frame - 8 - cot_length - asdu_addr_length) / (info_addr_length + 4));
|
||
count = pItem->events.count > count ? count : pItem->events.count;
|
||
if (count <= 0) return 0;
|
||
buffer[1] = (count & 0x7f);
|
||
for (i = 0; i < count; i++)
|
||
{
|
||
SetInformationAddr(pData, pItem->events.data[i].order + m_yx_start_address);
|
||
pData += info_addr_length;
|
||
*pData = pItem->events.data[i].value ? DPI_ON : DPI_OFF; pData++;
|
||
*pData = (BYTE)(pItem->events.data[i].ct.millisecond & 0x00ff); pData++;
|
||
*pData = (BYTE)((pItem->events.data[i].ct.millisecond >> 8)& 0x00ff); pData++;
|
||
*pData = (BYTE)(pItem->events.data[i].ct.minute | (pItem->events.data[i].ct.IV << 7)); pData++;
|
||
}
|
||
pItem->events.count -= count;
|
||
if (pItem->events.count <= 0 || pItem->events.count >= DATABASE_SOE_NUM)
|
||
{ //事件记录发送结束
|
||
pItem->events.count = 0;
|
||
}
|
||
else
|
||
{
|
||
memcpy(pItem->events.data, &pItem->events.data[count], sizeof(struEventsData) * pItem->events.count);
|
||
}
|
||
if (!SendIFrame(buffer, 2 + cot_length + asdu_addr_length + (info_addr_length + 4) * count, ord)) return -1;
|
||
return 1;
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
int CIEC104Process::Send_Double_point_information_with_time_tag_cp56time2a(CIEC104ProcessItem* pItem, int ord, BYTE cause_of_transimission /* = IEC_101_104_COT_SPONT */)
|
||
{
|
||
int i, count;
|
||
BYTE buffer[256], *pData;
|
||
memset(buffer, 0, sizeof(buffer));
|
||
if (NULL == pItem) return -1;
|
||
pData = &buffer[2 + cot_length + asdu_addr_length];
|
||
buffer[0] = M_DP_TB_1;
|
||
buffer[1] = 9;
|
||
SetCOT(&buffer[2], cause_of_transimission);
|
||
SetAsduAddr(&buffer[2 + cot_length], pItem->apdu_addr);
|
||
if (IEC_101_104_COT_SPONT == cause_of_transimission)
|
||
{ //短时标事件记录
|
||
count = ((max_frame - 8 - cot_length - asdu_addr_length) / (info_addr_length + 8));
|
||
count = pItem->events.count > count ? count : pItem->events.count;
|
||
if (count <= 0) return 0;
|
||
buffer[1] = (count & 0x7f);
|
||
for (i = 0; i < count; i++)
|
||
{
|
||
SetInformationAddr(pData, pItem->events.data[i].order + m_yx_start_address);
|
||
pData += info_addr_length;
|
||
*pData = pItem->events.data[i].value ? DPI_ON : DPI_OFF; pData++;
|
||
*pData = (BYTE)(pItem->events.data[i].ct.millisecond & 0x00ff); pData++;
|
||
*pData = (BYTE)((pItem->events.data[i].ct.millisecond >> 8)& 0x00ff); pData++;
|
||
*pData = (BYTE)(pItem->events.data[i].ct.minute | (pItem->events.data[i].ct.IV << 7)); pData++;
|
||
*pData = (BYTE)(pItem->events.data[i].ct.hour | (pItem->events.data[i].ct.SU << 7)); pData++;
|
||
*pData = (BYTE)(pItem->events.data[i].ct.dayofmonth | (pItem->events.data[i].ct.dayofweek << 5)); pData++;
|
||
*pData = (BYTE)pItem->events.data[i].ct.month; pData++;
|
||
*pData = (BYTE)pItem->events.data[i].ct.year; pData++;
|
||
}
|
||
pItem->events.count -= count;
|
||
if (pItem->events.count <= 0 || pItem->events.count >= DATABASE_SOE_NUM)
|
||
{ //事件记录发送结束
|
||
pItem->events.count = 0;
|
||
}
|
||
else
|
||
{
|
||
memcpy(pItem->events.data, &pItem->events.data[count], sizeof(struEventsData) * pItem->events.count);
|
||
}
|
||
if (!SendIFrame(buffer, 2 + cot_length + asdu_addr_length + (info_addr_length + 8) * count, ord)) return -1;
|
||
return 1;
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
int CIEC104Process::Send_Measured_value_normalised(CIEC104ProcessItem* pItem, int ord, BYTE cause_of_transimission /* = IEC_101_104_COT_SPONT */)
|
||
{
|
||
int uid;
|
||
int i, count;
|
||
BYTE buffer[256], *pData;
|
||
memset(buffer, 0, sizeof(buffer));
|
||
if (NULL == pItem) return -1;
|
||
pData = &buffer[2 + cot_length + asdu_addr_length];
|
||
buffer[0] = M_ME_NA_1;
|
||
SetCOT(&buffer[2], cause_of_transimission);
|
||
SetAsduAddr(&buffer[2 + cot_length], pItem->apdu_addr);
|
||
if (IEC_101_104_COT_SPONT == cause_of_transimission)
|
||
{ //遥测变位
|
||
count = ((max_frame - 8 - cot_length - asdu_addr_length) / (info_addr_length + 3));
|
||
count = pItem->ycbws.count > count ? count : pItem->ycbws.count;
|
||
if (count <= 0) return 0;
|
||
buffer[1] = (count & 0x7f);
|
||
for (i = 0; i < count; i++)
|
||
{
|
||
SetInformationAddr(pData, pItem->ycbws.data[i].order + m_yc_start_address);
|
||
pData += info_addr_length;
|
||
*pData = pItem->ycbws.data[i].value & 0xff; pData++;
|
||
*pData = (pItem->ycbws.data[i].value >> 8) & 0xff; pData++;
|
||
*pData = 0; pData++;
|
||
}
|
||
pItem->ycbws.count -= count;
|
||
if (pItem->ycbws.count <= 0 || pItem->ycbws.count >= UNIT_YC_MAX)
|
||
{ //遥测变位发送结束
|
||
pItem->ycbws.count = 0;
|
||
}
|
||
else
|
||
{
|
||
memcpy(pItem->ycbws.data, &pItem->ycbws.data[count], sizeof(struYCBW) * pItem->ycbws.count);
|
||
}
|
||
if (!SendIFrame(buffer, 2 + cot_length + asdu_addr_length + (info_addr_length + 3) * count, ord)) return -1;
|
||
return 1;
|
||
}
|
||
else
|
||
{ //召唤
|
||
count = (max_frame - 8 - cot_length - asdu_addr_length - info_addr_length) / 3;
|
||
count = (pItem->total_yc - pItem->yc_pos) > count ? count : (pItem->total_yc - pItem->yc_pos);
|
||
if (count <= 0)
|
||
{
|
||
pItem->yc_pos = 0;
|
||
if (IEC_101_104_COT_INTERROGATION == cause_of_transimission && pItem->interrogation_start)
|
||
{
|
||
pItem->interrogation_yc_fin = TRUE; //遥测发送完毕
|
||
}
|
||
return 0;
|
||
}
|
||
buffer[1] = 0x80 | count;
|
||
SetInformationAddr(pData, pItem->yc_pos + m_yc_start_address);
|
||
pData += info_addr_length;
|
||
short value;
|
||
uid = pItem->GetUnitID();
|
||
for (i = 0; i < count; i++)
|
||
{
|
||
value = (short)GetUnitYC(uid, pItem->yc_pos + i);
|
||
*pData = value & 0xff; pData++;
|
||
*pData = (value >> 8) & 0xff; pData++;
|
||
*pData = GetUnitYCQDS(uid, pItem->yc_pos + i); pData++;
|
||
}
|
||
pItem->yc_pos += count;
|
||
if (pItem->yc_pos < 0 || pItem->yc_pos >= pItem->total_yc)
|
||
{
|
||
pItem->yc_pos = 0;
|
||
if (IEC_101_104_COT_INTERROGATION == cause_of_transimission && pItem->interrogation_start)
|
||
{
|
||
pItem->interrogation_yc_fin = TRUE; //遥测发送完毕
|
||
}
|
||
}
|
||
if (!SendIFrame(buffer, 2 + cot_length + asdu_addr_length + info_addr_length + count * 3, ord)) return -1;
|
||
return 1;
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
int CIEC104Process::Send_Measured_value_scaled(CIEC104ProcessItem* pItem, int ord, BYTE cause_of_transimission /* = IEC_101_104_COT_SPONT */)
|
||
{
|
||
int uid;
|
||
int i, count;
|
||
BYTE buffer[256], *pData;
|
||
memset(buffer, 0, sizeof(buffer));
|
||
if (NULL == pItem) return -1;
|
||
pData = &buffer[2 + cot_length + asdu_addr_length];
|
||
buffer[0] = M_ME_NB_1;
|
||
SetCOT(&buffer[2], cause_of_transimission);
|
||
SetAsduAddr(&buffer[2 + cot_length], pItem->apdu_addr);
|
||
if (IEC_101_104_COT_SPONT == cause_of_transimission)
|
||
{ //遥测变位
|
||
count = ((max_frame - 8 - cot_length - asdu_addr_length) / (info_addr_length + 3));
|
||
count = pItem->ycbws.count > count ? count : pItem->ycbws.count;
|
||
if (count <= 0) return 0;
|
||
buffer[1] = (count & 0x7f);
|
||
for (i = 0; i < count; i++)
|
||
{
|
||
SetInformationAddr(pData, pItem->ycbws.data[i].order + m_yc_start_address);
|
||
pData += info_addr_length;
|
||
*pData = pItem->ycbws.data[i].value & 0xff; pData++;
|
||
*pData = (pItem->ycbws.data[i].value >> 8) & 0xff; pData++;
|
||
*pData = 0; pData++;
|
||
}
|
||
pItem->ycbws.count -= count;
|
||
if (pItem->ycbws.count <= 0 || pItem->ycbws.count >= UNIT_YC_MAX)
|
||
{ //遥测变位发送结束
|
||
pItem->ycbws.count = 0;
|
||
}
|
||
else
|
||
{
|
||
memcpy(pItem->ycbws.data, &pItem->ycbws.data[count], sizeof(struYCBW) * pItem->ycbws.count);
|
||
}
|
||
if (!SendIFrame(buffer, 2 + cot_length + asdu_addr_length + (info_addr_length + 3) * count, ord)) return -1;
|
||
return 1;
|
||
}
|
||
else
|
||
{ //召唤
|
||
count = (max_frame - 8 - cot_length - asdu_addr_length - info_addr_length) / 3;
|
||
count = (pItem->total_yc - pItem->yc_pos) > count ? count : (pItem->total_yc - pItem->yc_pos);
|
||
if (count <= 0)
|
||
{
|
||
pItem->yc_pos = 0;
|
||
if (IEC_101_104_COT_INTERROGATION == cause_of_transimission && pItem->interrogation_start)
|
||
{
|
||
pItem->interrogation_yc_fin = TRUE; //遥测发送完毕
|
||
}
|
||
return 0;
|
||
}
|
||
buffer[1] = 0x80 | count;
|
||
SetInformationAddr(pData, pItem->yc_pos + m_yc_start_address);
|
||
pData += info_addr_length;
|
||
short value;
|
||
uid = pItem->GetUnitID();
|
||
for (i = 0; i < count; i++)
|
||
{
|
||
value = (short)GetUnitYC(uid, pItem->yc_pos + i);
|
||
*pData = value & 0xff; pData++;
|
||
*pData = (value >> 8) & 0xff; pData++;
|
||
*pData = GetUnitYCQDS(uid, pItem->yc_pos + i); pData++;
|
||
}
|
||
pItem->yc_pos += count;
|
||
if (pItem->yc_pos < 0 || pItem->yc_pos >= pItem->total_yc)
|
||
{
|
||
pItem->yc_pos = 0;
|
||
if (IEC_101_104_COT_INTERROGATION == cause_of_transimission && pItem->interrogation_start)
|
||
{
|
||
pItem->interrogation_yc_fin = TRUE; //遥测发送完毕
|
||
}
|
||
}
|
||
if (!SendIFrame(buffer, 2 + cot_length + asdu_addr_length + info_addr_length + count * 3, ord)) return -1;
|
||
return 1;
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
int CIEC104Process::Send_Measured_value_short_floating_point(CIEC104ProcessItem* pItem, int ord, BYTE cause_of_transimission /* = IEC_101_104_COT_SPONT */)
|
||
{
|
||
int uid;
|
||
int i, count;
|
||
float fvalue;
|
||
DWORD dwValue;
|
||
BYTE buffer[256], *pData;
|
||
memset(buffer, 0, sizeof(buffer));
|
||
if (NULL == pItem) return -1;
|
||
pData = &buffer[2 + cot_length + asdu_addr_length];
|
||
buffer[0] = M_ME_NC_1;
|
||
SetCOT(&buffer[2], cause_of_transimission);
|
||
SetAsduAddr(&buffer[2 + cot_length], pItem->apdu_addr);
|
||
if (IEC_101_104_COT_SPONT == cause_of_transimission)
|
||
{ //遥测变位
|
||
count = ((max_frame - 8 - cot_length - asdu_addr_length) / (info_addr_length + 5));
|
||
count = pItem->ycbws.count > count ? count : pItem->ycbws.count;
|
||
if (count <= 0) return 0;
|
||
buffer[1] = (count & 0x7f);
|
||
uid = pItem->GetUnitID();
|
||
for (i = 0; i < count; i++)
|
||
{
|
||
SetInformationAddr(pData, pItem->ycbws.data[i].order + m_yc_start_address);
|
||
pData += info_addr_length;
|
||
//fvalue = GetUnitYCRealFromValue(uid, pItem->ycbws.data[i].order, pItem->ycbws.data[i].value);
|
||
fvalue = pItem->ycbws.data[i].flVal;//GetUnitYCRealFromValue(uid, pItem->ycbws.data[i].order, pItem->ycbws.data[i].value);
|
||
dwValue = 0;
|
||
memcpy(&dwValue, &fvalue, sizeof(DWORD));
|
||
*pData = dwValue & 0xff; pData++;
|
||
*pData = (dwValue >> 8) & 0xff; pData++;
|
||
*pData = (dwValue >> 16) & 0xff; pData++;
|
||
*pData = (dwValue >> 24) & 0xff; pData++;
|
||
*pData = 0; pData++;
|
||
}
|
||
pItem->ycbws.count -= count;
|
||
if (pItem->ycbws.count <= 0 || pItem->ycbws.count >= UNIT_YC_MAX)
|
||
{ //遥测变位发送结束
|
||
pItem->ycbws.count = 0;
|
||
}
|
||
else
|
||
{
|
||
memcpy(pItem->ycbws.data, &pItem->ycbws.data[count], sizeof(struYCBW) * pItem->ycbws.count);
|
||
}
|
||
if (!SendIFrame(buffer, 2 + cot_length + asdu_addr_length + (info_addr_length + 5) * count, ord)) return -1;
|
||
return 1;
|
||
}
|
||
else
|
||
{ //召唤
|
||
count = (max_frame - 8 - cot_length - asdu_addr_length - info_addr_length) / 5;
|
||
count = (pItem->total_yc - pItem->yc_pos) > count ? count : (pItem->total_yc - pItem->yc_pos);
|
||
if (count <= 0)
|
||
{
|
||
pItem->yc_pos = 0;
|
||
if (IEC_101_104_COT_INTERROGATION == cause_of_transimission && pItem->interrogation_start)
|
||
{
|
||
pItem->interrogation_yc_fin = TRUE; //遥测发送完毕
|
||
}
|
||
return 0;
|
||
}
|
||
buffer[1] = 0x80 | count;
|
||
SetInformationAddr(pData, pItem->yc_pos + m_yc_start_address);
|
||
pData += info_addr_length;
|
||
uid = pItem->GetUnitID();
|
||
for (i = 0; i < count; i++)
|
||
{
|
||
fvalue = GetUnitYCReal(uid, pItem->yc_pos + i);
|
||
dwValue = 0;
|
||
memcpy(&dwValue, &fvalue, sizeof(DWORD));
|
||
*pData = dwValue & 0xff; pData++;
|
||
*pData = (dwValue >> 8) & 0xff; pData++;
|
||
*pData = (dwValue >> 16) & 0xff; pData++;
|
||
*pData = (dwValue >> 24) & 0xff; pData++;
|
||
*pData = GetUnitYCQDS(uid, pItem->yc_pos + i); pData++;
|
||
}
|
||
pItem->yc_pos += count;
|
||
if (pItem->yc_pos < 0 || pItem->yc_pos >= pItem->total_yc)
|
||
{
|
||
pItem->yc_pos = 0;
|
||
if (IEC_101_104_COT_INTERROGATION == cause_of_transimission && pItem->interrogation_start)
|
||
{
|
||
pItem->interrogation_yc_fin = TRUE; //遥测发送完毕
|
||
}
|
||
}
|
||
if (!SendIFrame(buffer, 2 + cot_length + asdu_addr_length + info_addr_length + count * 5, ord)) return -1;
|
||
return 1;
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
int CIEC104Process::Send_Measured_value_normalised_without_quality(CIEC104ProcessItem* pItem, int ord, BYTE cause_of_transimission /* = IEC_101_104_COT_SPONT */)
|
||
{
|
||
int uid;
|
||
int i, count;
|
||
BYTE buffer[256], *pData;
|
||
memset(buffer, 0, sizeof(buffer));
|
||
if (NULL == pItem) return -1;
|
||
pData = &buffer[2 + cot_length + asdu_addr_length];
|
||
buffer[0] = M_ME_ND_1;
|
||
SetCOT(&buffer[2], cause_of_transimission);
|
||
SetAsduAddr(&buffer[2 + cot_length], pItem->apdu_addr);
|
||
if (IEC_101_104_COT_SPONT == cause_of_transimission)
|
||
{ //遥测变位
|
||
count = ((max_frame - 8 - cot_length - asdu_addr_length) / (info_addr_length + 2));
|
||
count = pItem->ycbws.count > count ? count : pItem->ycbws.count;
|
||
if (count <= 0) return 0;
|
||
buffer[1] = (count & 0x7f);
|
||
for (i = 0; i < count; i++)
|
||
{
|
||
SetInformationAddr(pData, pItem->ycbws.data[i].order + m_yc_start_address);
|
||
pData += info_addr_length;
|
||
*pData = pItem->ycbws.data[i].value & 0xff; pData++;
|
||
*pData = (pItem->ycbws.data[i].value >> 8) & 0xff; pData++;
|
||
}
|
||
pItem->ycbws.count -= count;
|
||
if (pItem->ycbws.count <= 0 || pItem->ycbws.count >= UNIT_YC_MAX)
|
||
{ //遥测变位发送结束
|
||
pItem->ycbws.count = 0;
|
||
}
|
||
else
|
||
{
|
||
memcpy(pItem->ycbws.data, &pItem->ycbws.data[count], sizeof(struYCBW) * pItem->ycbws.count);
|
||
}
|
||
if (!SendIFrame(buffer, 2 + cot_length + asdu_addr_length + (info_addr_length + 2) * count, ord)) return -1;
|
||
return 1;
|
||
}
|
||
else
|
||
{ //召唤
|
||
count = (max_frame - 8 - cot_length - asdu_addr_length - info_addr_length) / 2;
|
||
count = (pItem->total_yc - pItem->yc_pos) > count ? count : (pItem->total_yc - pItem->yc_pos);
|
||
if (count <= 0)
|
||
{
|
||
pItem->yc_pos = 0;
|
||
if (IEC_101_104_COT_INTERROGATION == cause_of_transimission && pItem->interrogation_start)
|
||
{
|
||
pItem->interrogation_yc_fin = TRUE; //遥测发送完毕
|
||
}
|
||
return 0;
|
||
}
|
||
buffer[1] = 0x80 | count;
|
||
SetInformationAddr(pData, pItem->yc_pos + m_yc_start_address);
|
||
pData += info_addr_length;
|
||
short value;
|
||
uid = pItem->GetUnitID();
|
||
for (i = 0; i < count; i++)
|
||
{
|
||
value = (short)GetUnitYC(uid, pItem->yc_pos + i);
|
||
*pData = value & 0xff; pData++;
|
||
*pData = (value >> 8) & 0xff; pData++;
|
||
}
|
||
pItem->yc_pos += count;
|
||
if (pItem->yc_pos < 0 || pItem->yc_pos >= pItem->total_yc)
|
||
{
|
||
pItem->yc_pos = 0;
|
||
if (IEC_101_104_COT_INTERROGATION == cause_of_transimission && pItem->interrogation_start)
|
||
{
|
||
pItem->interrogation_yc_fin = TRUE; //遥测发送完毕
|
||
}
|
||
}
|
||
if (!SendIFrame(buffer, 2 + cot_length + asdu_addr_length + info_addr_length + count * 2, ord)) return -1;
|
||
return 1;
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
|
||
int CIEC104Process::Send_Integrated_totals(CIEC104ProcessItem* pItem, int ord, BYTE cause_of_transimission)
|
||
{
|
||
int uid;
|
||
int i, count;
|
||
DWORD value;
|
||
BYTE buffer[256], *pData;
|
||
memset(buffer, 0, sizeof(buffer));
|
||
if (NULL == pItem) return -1;
|
||
|
||
uid = pItem->GetUnitID();
|
||
pData = &buffer[2 + cot_length + asdu_addr_length];
|
||
buffer[0] = M_IT_NA_1;
|
||
SetCOT(&buffer[2], cause_of_transimission);
|
||
SetAsduAddr(&buffer[2 + cot_length], pItem->apdu_addr);
|
||
if (IEC_101_104_COT_SPONT == cause_of_transimission)
|
||
{ //遥脉变位
|
||
count = ((max_frame - 8 - cot_length - asdu_addr_length) / (info_addr_length + 5));
|
||
count = (pItem->total_ym - pItem->ym_pos) > count ? count : (pItem->total_ym - pItem->ym_pos);
|
||
if (count <= 0) return 0;
|
||
buffer[1] = (count & 0x7f);
|
||
for (i = 0; i < count; i++)
|
||
{
|
||
SetInformationAddr(pData, i + m_ym_start_address + pItem->ym_pos);
|
||
pData += info_addr_length;
|
||
value = GetUnitYM(uid, pItem->ym_pos + i);
|
||
*pData = value & 0xff; pData++;
|
||
*pData = (value >> 8) & 0xff; pData++;
|
||
*pData = (value >> 16) & 0xff; pData++;
|
||
*pData = (value >> 24) & 0xff; pData++;
|
||
*pData = (pItem->ym_pos + i ) % 32; pData++;
|
||
}
|
||
pItem->ym_pos += count;
|
||
if (pItem->ym_pos < 0 || pItem->ym_pos >= pItem->total_ym)
|
||
{
|
||
pItem->ym_pos = 0;
|
||
if ((IEC_101_104_COT_REQCOGEN == cause_of_transimission || IEC_101_104_COT_INTERROGATION == cause_of_transimission) && pItem->pulse_start)
|
||
{
|
||
pItem->pulse_fin = TRUE; //遥脉发送完毕
|
||
}
|
||
}
|
||
if (!SendIFrame(buffer, 2 + cot_length + asdu_addr_length + (info_addr_length + 5) * count, ord)) return -1;
|
||
return 1;
|
||
}
|
||
else
|
||
{ //召唤
|
||
count = (max_frame - 8 - cot_length - asdu_addr_length - info_addr_length) / 5;
|
||
count = (pItem->total_ym - pItem->ym_pos) > count ? count : (pItem->total_ym - pItem->ym_pos);
|
||
if (count <= 0)
|
||
{
|
||
pItem->ym_pos = 0;
|
||
if ((IEC_101_104_COT_REQCOGEN == cause_of_transimission || IEC_101_104_COT_INTERROGATION == cause_of_transimission) && pItem->pulse_start)
|
||
{
|
||
pItem->pulse_fin = TRUE; //遥脉发送完毕
|
||
}
|
||
return 0;
|
||
}
|
||
buffer[1] = 0x80 | count;
|
||
SetInformationAddr(pData, pItem->ym_pos + m_ym_start_address);
|
||
pData += info_addr_length;
|
||
for (i = 0; i < count; i++)
|
||
{
|
||
value = GetUnitYM(uid, pItem->ym_pos + i);
|
||
*pData = value & 0xff; pData++;
|
||
*pData = (value >> 8) & 0xff; pData++;
|
||
*pData = (value >> 16) & 0xff; pData++;
|
||
*pData = (value >> 24) & 0xff; pData++;
|
||
*pData = (pItem->ym_pos + i ) % 32; pData++;
|
||
}
|
||
pItem->ym_pos += count;
|
||
if (pItem->ym_pos < 0 || pItem->ym_pos >= pItem->total_ym)
|
||
{
|
||
pItem->ym_pos = 0;
|
||
if ((IEC_101_104_COT_REQCOGEN == cause_of_transimission || IEC_101_104_COT_INTERROGATION == cause_of_transimission) && pItem->pulse_start)
|
||
{
|
||
pItem->pulse_fin = TRUE; //遥脉发送完毕
|
||
}
|
||
}
|
||
if (!SendIFrame(buffer, 2 + cot_length + asdu_addr_length + info_addr_length + count * 5, ord)) return -1;
|
||
return 1;
|
||
}
|
||
return -1;
|
||
}
|
||
|
||
int CIEC104Process::Send_FrameInterrogation(CIEC104ProcessItem* pItem, int ord, BYTE cause_of_transimission)
|
||
{
|
||
BYTE buffer[10];
|
||
int count;
|
||
buffer[0] = C_IC_NA_1;
|
||
buffer[1] = 0x01;
|
||
SetCOT(&buffer[2], cause_of_transimission);
|
||
SetAsduAddr(&buffer[2 + cot_length], pItem->apdu_addr);
|
||
SetInformationAddr(&buffer[2 + cot_length + asdu_addr_length], (DWORD)0);
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length] = pItem->interrogation_type;
|
||
count = 3 + cot_length + asdu_addr_length + info_addr_length;
|
||
if (!SendIFrame(buffer, count, ord)) return -1;
|
||
return 1;
|
||
}
|
||
|
||
int CIEC104Process::Send_FrameCounterInterrogation(CIEC104ProcessItem* pItem, int ord, BYTE cause_of_transimission)
|
||
{
|
||
BYTE buffer[10];
|
||
int count;
|
||
buffer[0] = C_CI_NA_1;
|
||
buffer[1] = 0x01;
|
||
SetCOT(&buffer[2], cause_of_transimission);
|
||
SetAsduAddr(&buffer[2 + cot_length], pItem->apdu_addr);
|
||
SetInformationAddr(&buffer[2 + cot_length + asdu_addr_length], (DWORD)0);
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length] = pItem->pulse_type;
|
||
count = 3 + cot_length + asdu_addr_length + info_addr_length;
|
||
if (!SendIFrame(buffer, count, ord)) return -1;
|
||
return 1;
|
||
}
|
||
|
||
|
||
int CIEC104Process::Send_Test_command(CIEC104ProcessItem* pItem, int ord, BYTE cause_of_transimission)
|
||
{
|
||
BYTE buffer[32];
|
||
int count;
|
||
buffer[0] = C_TS_NA_1;
|
||
buffer[1] = 0x01;
|
||
SetCOT(&buffer[2], cause_of_transimission);
|
||
SetAsduAddr(&buffer[2 + cot_length], pItem->apdu_addr);
|
||
SetInformationAddr(&buffer[2 + cot_length + asdu_addr_length], (DWORD)0);
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length] = 0xAA;
|
||
buffer[3 + cot_length + asdu_addr_length + info_addr_length] = 0x55;
|
||
|
||
count = 4 + cot_length + asdu_addr_length + info_addr_length;
|
||
if (!SendIFrame(buffer, count, ord)) return -1;
|
||
return 1;
|
||
}
|
||
|
||
int CIEC104Process::Send_Test_command_with_time_tag_cp56time2a(CIEC104ProcessItem* pItem, int ord, BYTE cause_of_transimission)
|
||
{
|
||
BYTE buffer[32];
|
||
int count;
|
||
buffer[0] = C_TS_TA_1;
|
||
buffer[1] = 0x01;
|
||
SetCOT(&buffer[2], cause_of_transimission);
|
||
SetAsduAddr(&buffer[2 + cot_length], pItem->apdu_addr);
|
||
SetInformationAddr(&buffer[2 + cot_length + asdu_addr_length], (DWORD)0);
|
||
buffer[2 + cot_length + asdu_addr_length + info_addr_length] = 0xAA;
|
||
buffer[3 + cot_length + asdu_addr_length + info_addr_length] = 0x55;
|
||
unionCP56Time st;
|
||
if (!get_system_time(&st))
|
||
{
|
||
vLog(LOG_ERROR, "Get system time error.\n");
|
||
return 0;
|
||
}
|
||
st.IV = FALSE;
|
||
st.SU = FALSE;
|
||
buffer[4 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)(st.millisecond & 0x00ff);
|
||
buffer[5 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)((st.millisecond >> 8)& 0x00ff);
|
||
buffer[6 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)(st.minute | (st.IV << 7));
|
||
buffer[7 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)(st.hour | (st.SU << 7));
|
||
buffer[8 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)(st.dayofmonth | (st.dayofweek << 5));
|
||
buffer[9 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)st.month;
|
||
buffer[10 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)st.year;
|
||
count = 11 + cot_length + asdu_addr_length + info_addr_length;
|
||
if (!SendIFrame(buffer, count, ord)) return -1;
|
||
return 1;
|
||
}
|
||
|
||
|
||
|
||
//start his data
|
||
int CIEC104Process::Receive_HisDataRequest_command(CIEC104ProcessItem* pItem, const BYTE* pBuf, BYTE cause_of_transmission, BYTE* pTarget, int& count) //补录数据
|
||
{
|
||
BYTE* pData = (BYTE*)pBuf;
|
||
struct tm* p;
|
||
time_t st, et;
|
||
int st_year, st_mon, st_mday, st_hour, st_min, st_sec;
|
||
int et_year, et_mon, et_mday, et_hour, et_min, et_sec;
|
||
if (NULL == pItem) return ERROR_UNKNOWN;
|
||
|
||
time_t temp = (time_t)system32.timers;
|
||
p = localtime(&temp);
|
||
|
||
pData += info_addr_length;
|
||
|
||
st_year = (pData[1] << 8 | pData[0]); pData += 2;
|
||
st_mon = *pData; pData++;
|
||
st_mday = *pData; pData++;
|
||
st_hour = *pData; pData++;
|
||
st_min = *pData; pData++;
|
||
st_sec = *pData; pData++;
|
||
|
||
p->tm_year = st_year - 1900;
|
||
p->tm_mon = st_mon - 1;
|
||
p->tm_mday = st_mday;
|
||
p->tm_hour = st_hour;
|
||
p->tm_min = st_min;
|
||
p->tm_sec = st_sec;
|
||
st = mktime(p);
|
||
vLog(LOG_DEBUG, "st is: %04d/%02d/%02d %02d:%02d:%02d and ", st_year, st_mon, st_mday, st_hour, st_min, st_sec);
|
||
|
||
et_year = (pData[1] << 8 | pData[0]); pData += 2;
|
||
et_mon = *pData; pData++;
|
||
et_mday = *pData; pData++;
|
||
et_hour = *pData; pData++;
|
||
et_min = *pData; pData++;
|
||
et_sec = *pData; pData++;
|
||
vLog(LOG_DEBUG, "et is: %04d/%02d/%02d %02d:%02d:%02d \n", et_year, et_mon, et_mday, et_hour, et_min, et_sec);
|
||
|
||
p->tm_year = et_year - 1900;
|
||
p->tm_mon = et_mon - 1;
|
||
p->tm_mday = et_mday;
|
||
p->tm_hour = et_hour;
|
||
p->tm_min = et_min;
|
||
p->tm_sec = et_sec;
|
||
et = mktime(p);
|
||
|
||
pTarget[0] = C_HD_NB_1;
|
||
pTarget[1] = 1;
|
||
SetAsduAddr(&pTarget[2 + cot_length], pItem->apdu_addr);
|
||
SetInformationAddr(&pTarget[2 + cot_length + asdu_addr_length], (DWORD)0x8100);
|
||
|
||
pTarget[2 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)st_year;
|
||
pTarget[3 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)((st_year >> 8)& 0x00ff);
|
||
pTarget[4 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)st_mon;
|
||
pTarget[5 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)st_mday;
|
||
pTarget[6 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)st_hour;
|
||
pTarget[7 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)st_min;
|
||
pTarget[8 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)st_sec;
|
||
count = 9 + cot_length + asdu_addr_length + info_addr_length;
|
||
//后期需要添加对时间的判断
|
||
|
||
if (IEC_101_104_COT_REQ == cause_of_transmission)
|
||
{
|
||
if (st > et)
|
||
{
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_DEACTCON | IEC_101_104_COT_PN);
|
||
return ERROR_PARAM;
|
||
}
|
||
// pItem->call_time = st;
|
||
// pItem->call_time_start = st;
|
||
// pItem->call_time_finish = et;
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_ACT);
|
||
return NO_ERROR;
|
||
}
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_UNKNOWN_COT);
|
||
return ERROR_CAUSE_OF_TRANSMISSION; //传输原因错误
|
||
}
|
||
|
||
int CIEC104Process::Receive_His_Interrogation_command(CIEC104ProcessItem* pItem, const BYTE* pBuf, BYTE cause_of_transmission, BYTE VSQ, BYTE* pTarget, int& count) //补录数据
|
||
{
|
||
BYTE* pData = (BYTE*)pBuf;
|
||
if (NULL == pItem) return ERROR_UNKNOWN;
|
||
|
||
//BYTE interval;
|
||
unionCP56Time st;
|
||
unionCP56Time et;
|
||
int info_count;
|
||
DWORD information_address[80];
|
||
|
||
info_count = VSQ & 0x7f;
|
||
if (info_count >= 80 || info_count <= 0) return ERROR_PARAM;
|
||
//interval = *pData;
|
||
pData++; //补采的时间间隔单位
|
||
|
||
//开始时间（包括开始时间）
|
||
st.millisecond = *pData; pData++;
|
||
st.millisecond |= (*pData << 8); pData++;
|
||
st.minute = *pData & 0x3f;
|
||
st.IV = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
st.hour = *pData & 0x1f;
|
||
st.SU = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
st.dayofmonth = *pData & 0x1f;
|
||
st.dayofweek = ((*pData & 0xe0) >> 5); pData++;
|
||
st.month = *pData & 0x0f; pData++;
|
||
st.year = *pData & 0x7f; pData++;
|
||
|
||
//结束时间（不包括结束时间）
|
||
et.millisecond = *pData; pData++;
|
||
et.millisecond |= (*pData << 8); pData++;
|
||
et.minute = *pData & 0x3f;
|
||
et.IV = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
et.hour = *pData & 0x1f;
|
||
et.SU = (*pData & 0x80) == 0x80 ? TRUE : FALSE; pData++;
|
||
et.dayofmonth = *pData & 0x1f;
|
||
et.dayofweek = ((*pData & 0xe0) >> 5); pData++;
|
||
et.month = *pData & 0x0f; pData++;
|
||
et.year = *pData & 0x7f; pData++;
|
||
|
||
for (int i = 0; i < info_count; i++)
|
||
{
|
||
if (1 == m_nOption.info_addr_size)
|
||
{
|
||
information_address[i] = *pData; pData++;
|
||
}
|
||
else if (2 == m_nOption.info_addr_size)
|
||
{
|
||
information_address[i] = *pData; pData++;
|
||
information_address[i] |= (*pData << 8); pData++;
|
||
}
|
||
else if (3 == m_nOption.info_addr_size)
|
||
{
|
||
information_address[i] = *pData; pData++;
|
||
information_address[i] |= (*pData << 8); pData++;
|
||
information_address[i] |= (*pData << 16); pData++;
|
||
}
|
||
}
|
||
|
||
if (IEC_101_104_COT_REQ == cause_of_transmission)
|
||
{
|
||
pTarget[0] = C_HD_NC_1;
|
||
pTarget[1] = 1;
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_ACT);
|
||
SetAsduAddr(&pTarget[2 + cot_length], pItem->apdu_addr);
|
||
SetInformationAddr(&pTarget[2 + cot_length + asdu_addr_length], (DWORD)0);
|
||
pTarget[2 + cot_length + asdu_addr_length + info_addr_length] = (BYTE)0x14;
|
||
count = 9 + cot_length + asdu_addr_length + info_addr_length;
|
||
return NO_ERROR;
|
||
}
|
||
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_UNKNOWN_COT);
|
||
return ERROR_CAUSE_OF_TRANSMISSION; //传输原因错误
|
||
}
|
||
|
||
int CIEC104Process::Receive_His_Counter_Interrogation_command(CIEC104ProcessItem* pItem, const BYTE* pBuf, BYTE cause_of_transmission, BYTE VSQ, BYTE* pTarget, int& count) //补录数据
|
||
{
|
||
SetCOT(&pTarget[2], IEC_101_104_COT_UNKNOWN_COT);
|
||
return ERROR_CAUSE_OF_TRANSMISSION; //传输原因错误
|
||
}
|
||
//sub end
|