ShipCentralControl/Anjiehui7_DTU/User/modbus_slave.c

#include "includes.h"

// Modbus(RS485<38>ӿڣ<D3BF><DAA3><EFBFBD><EFBFBD><EFBFBD>ģʽ<C4A3><CABD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ͣ<EFBFBD><CDA3><EFBFBD><EFBFBD><EFBFBD>λ<EFBFBD><CEBB><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>, ÿ30<33><30><EFBFBD><EFBFBD><EFBFBD><EFBFBD>λ<EFBFBD><CEBB><EFBFBD><EFBFBD><EFBFBD><EFBFBD>һ<EFBFBD><D2BB><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>

// modbusͨѶ<CDA8><D1B6><EFBFBD><EFBFBD>
#pragma pack(push, 1)

// RF<52><46><EFBFBD>ڷ<EFBFBD><DAB7><EFBFBD>֡<EFBFBD><D6A1>ѭ<EFBFBD><D1AD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
#define MODBUS_SENDM_DATA_COUNT 512
loopbuff_t Modbus_SendM;
uint8_t Modbus_SendM_Data[sizeof(ext_data_t) * (MODBUS_SENDM_DATA_COUNT + 1)] = {0};
// RF<52><46><EFBFBD>ڽ<EFBFBD><DABD>յ<EFBFBD><D5B5><EFBFBD>Ϣ֪ͨ
SemaphoreHandle_t	   Modbus_SendQ = NULL;    // <20><>ֵ<EFBFBD>ź<EFBFBD><C5BA><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>

#pragma pack(pop)

// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ļ<EFBFBD><C4BB><EFBFBD>
#define HEART_SENDBUFF_SIZE 64
uint8_t Heart_sendBuff[HEART_SENDBUFF_SIZE];

// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ݱ<EFBFBD><DDB1>Ļ<EFBFBD><C4BB><EFBFBD>
uint8_t Modbus_sendBuff[TASK_SENDBUFF_SIZE];

static void RS485_SendDataByte(uint8_t *pu8TxBuf, uint32_t u32WriteBytes)
{
    /* Send data */
    UART_Transmit(&huart4, pu8TxBuf, u32WriteBytes);
}

void Modbus_Open()
{
	// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD>Ϣ<EFBFBD><CFA2><EFBFBD><EFBFBD>
	LoopBuff_Create(&Modbus_SendM, sizeof(ext_data_t), MODBUS_SENDM_DATA_COUNT, 0, (uint32_t) Modbus_SendM_Data);

	// <20><><EFBFBD><EFBFBD><EFBFBD>ź<EFBFBD><C5BA><EFBFBD>
	Modbus_SendQ = xSemaphoreCreateBinary();
}

uint8_t pack_heart_send_data()
{
	uint8_t i;
	uint16_t crc;
	
	// <20><><EFBFBD><EFBFBD><EFBFBD>ϱ<EFBFBD><CFB1><EFBFBD><EFBFBD>ݣ<EFBFBD><DDA3><EFBFBD>modbus<75>ӻ<EFBFBD><D3BB><EFBFBD>Ӧ<EFBFBD>ĸ<EFBFBD>ʽ<EFBFBD><CABD>
	memset(Heart_sendBuff, 0, HEART_SENDBUFF_SIZE);
	i = 0;
	
	// PSN
	memmove(Heart_sendBuff + i, dcBuff.configBottle.PSN, 6);
	i += 6;
	
	Heart_sendBuff[i++] = 0x02;	// <20><><EFBFBD><EFBFBD><EFBFBD>룺<EFBFBD><EBA3BA><EFBFBD><EFBFBD>

	// <20><><EFBFBD>ݳ<EFBFBD><DDB3>ȣ<EFBFBD><C8A3><EFBFBD>Ԥ<EFBFBD><D4A4>Ϊ0<CEAA><30><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>޸ģ<DEB8>λ<EFBFBD><CEBB>ΪHeart_sendBuff[7]
	Heart_sendBuff[i++] = 0;
	
	// Ӳ<><D3B2><EFBFBD>汾
	Heart_sendBuff[i++] = dcBuff.powerInfo.hardVer.minor;
	// <20><><EFBFBD><EFBFBD><EFBFBD>汾
	Heart_sendBuff[i++] = dcBuff.powerInfo.softVer.minor;
	// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
	Heart_sendBuff[i++] = dcBuff.powerInfo.softDate.year;
	Heart_sendBuff[i++] = dcBuff.powerInfo.softDate.month;
	Heart_sendBuff[i++] = dcBuff.powerInfo.softDate.day;

	// <20><>Ƶ<EFBFBD>Լ<EFBFBD>״̬
	Heart_sendBuff[i++] = RF_initStatus;
	// <20><><EFBFBD><EFBFBD><EFBFBD>Լ<EFBFBD>״̬
	Heart_sendBuff[i++] = Ethernet_initStatus;
	// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>״̬
	Heart_sendBuff[i++] = Ethernet_IsConnected();
	// GPRS<52><53><EFBFBD><EFBFBD>״̬
	Heart_sendBuff[i++] = dcBuff.dtuData.networked;
	// GPRS<52>ź<EFBFBD>ǿ<EFBFBD><C7BF>
	Heart_sendBuff[i++] = dcBuff.dtuData.rssi;
	// GPRS<52><53><EFBFBD><EFBFBD>״̬
	Heart_sendBuff[i++] = dcBuff.dtuData.connected;
	
	// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
	i += 41;
	
	// <20>޸<EFBFBD><DEB8><EFBFBD><EFBFBD>ݳ<EFBFBD><DDB3><EFBFBD>
	Heart_sendBuff[7] = i - 8;
	
	// У<><D0A3><EFBFBD><EFBFBD>
	crc = MODBUS_RTU_CRC16((uint8_t *) Heart_sendBuff, i);
	*(uint16_t *)(Heart_sendBuff + i) = htons(crc);
	i += 2;
	// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
	Heart_sendBuff[i++] = 0x0d;
	Heart_sendBuff[i++] = 0x0a;
	
	return i;
}

// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>
void Modbus_Task(void *p_arg)
{
	uint8_t i;
	uint32_t heartTick = 0;
	ext_data_t Gprs;

	while(TRUE)
	{
		// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ȡ<EFBFBD><C8A1><EFBFBD>Ͷ<EFBFBD><CDB6>еļ<D0B5>¼
		// <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>л<EFBFBD><D0BB><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>л<EFBFBD><D0BB><EFBFBD><EFBFBD>õ<EFBFBD>ִ<EFBFBD>У<EFBFBD>
		xSemaphoreTake(Modbus_SendQ, 1000);

		if(IsTickOut(heartTick))
		{
			heartTick = GetDelayTick(30000); // 30<33><30><EFBFBD>Ժ<EFBFBD><D4BA>ٷ<EFBFBD>
			
			// TODO: <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>λ<EFBFBD><CEBB><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ȴ<EFBFBD><C8B4><EFBFBD><EFBFBD><EFBFBD>
//			i = pack_heart_send_data();
//			RS485_SendDataByte(Heart_sendBuff, i);
		}
		
		if(LoopBuff_GetCount(&Modbus_SendM))
		{
			// ȡ<><C8A1><EFBFBD><EFBFBD>
			memmove(&Gprs, LoopBuff_GetDataPtr(&Modbus_SendM, Modbus_SendM.info.rdPtr), sizeof(ext_data_t));
			LoopBuff_RemoveItems(&Modbus_SendM, 1);
			i = pack_modbus_tran_data(&Gprs);

			// TODO: <20><><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ݵ<EFBFBD><DDB5><EFBFBD>λ<EFBFBD><CEBB><EFBFBD><EFBFBD><EFBFBD><EFBFBD><EFBFBD>ȴ<EFBFBD><C8B4><EFBFBD><EFBFBD><EFBFBD>
			RS485_SendDataByte(Modbus_sendBuff, i);
		}
	}
}