383 lines
9.8 KiB
C
383 lines
9.8 KiB
C
|
|
#include "main.h"
|
|
|
|
#include "os-app.h"
|
|
|
|
#include <stdio.h>
|
|
#include <rtthread.h>
|
|
#include <net-app.h>
|
|
#include <easyflash.h>
|
|
#include <string.h>
|
|
#include "usart-board.h"
|
|
|
|
#include "mqtt-board.h"
|
|
#include "network.h"
|
|
#include "netdrv.h"
|
|
#include "proto.h"
|
|
#include "util.h"
|
|
#include "data.h"
|
|
#include "disdefine.h"
|
|
#include "jsonpacket.h"
|
|
#include "jsonunpack.h"
|
|
#include <stdlib.h>
|
|
#include "user_config.h"
|
|
|
|
|
|
#if !defined(LOG_TAG)
|
|
#define LOG_TAG "network"
|
|
#endif
|
|
#include <elog.h>
|
|
|
|
ALIGN (RT_ALIGN_SIZE)
|
|
static char thread_stack[4096];
|
|
static struct rt_thread netapp_thread;
|
|
|
|
|
|
|
|
extern MqttDrv_t gMqttDrv;
|
|
|
|
|
|
|
|
static rt_timer_t timer;
|
|
|
|
|
|
static uint32_t g_net_5min_timer[SUBTOPIC_COUNT] = {0};
|
|
static uint32_t g_net_1min_timer[SUBTOPIC_COUNT] = {0};
|
|
|
|
|
|
static void timerouter (void * parameter)
|
|
{
|
|
TypeIndexMail_t mail;
|
|
for (int i = 0; i < SUBTOPIC_COUNT; i++)
|
|
{
|
|
if (g_net_1min_timer[i] == 1)
|
|
{
|
|
g_net_1min_timer[i] = 60;
|
|
mail.Type = MAIL_COMM_HEART;
|
|
mail.index = i + 1;
|
|
rt_mb_send (gTCommMail, * ( (uint32_t *) &mail));
|
|
}
|
|
if (g_net_5min_timer[i] == 1)
|
|
{
|
|
g_net_5min_timer[i] = 60 * 5;
|
|
mail.Type = MAIL_COMM_STAND;
|
|
mail.index = i + 1;
|
|
rt_mb_send (gTCommMail, * ( (uint32_t *) &mail));
|
|
}
|
|
if (g_net_1min_timer[i] > 1)
|
|
g_net_1min_timer[i]--;
|
|
if (g_net_5min_timer[i] > 1)
|
|
g_net_5min_timer[i]--;
|
|
}
|
|
|
|
}
|
|
|
|
|
|
const static char upinfo[][10] = {"heart", "regist", "stand", "sluice", "upack", "slack","readcfg"} ;
|
|
|
|
static void thread_entry (void * argument)
|
|
{
|
|
log_i ("network was start!");
|
|
TypeIndexMail_t mail;
|
|
timer = rt_timer_create ("timer", timerouter, RT_NULL, 1000, RT_TIMER_FLAG_PERIODIC);
|
|
// 读取网络驱动类型
|
|
netdrv_init();
|
|
MQTTThreadStart();
|
|
char data[100] = {0};
|
|
int tx_size = 0;
|
|
#ifndef USER_JSON_PACKET
|
|
char rxdata_decode[256];
|
|
int rxdata_decode_size = 0;
|
|
uint32_t datak;
|
|
#endif
|
|
|
|
// 判断站点类型
|
|
//site_type
|
|
char * p = ef_get_env ("site_type") ;
|
|
int site_type = cSiteType2Index(p);
|
|
log_i ("site_type:%d", site_type);
|
|
|
|
//CommTMail_t mail;
|
|
// 注册网络驱动
|
|
// 注册网络驱动
|
|
while (1)
|
|
{
|
|
INIT:
|
|
if (RT_EOK == rt_event_recv (gTrigEvents, EVENT_TRIG_COMM_RST, RT_EVENT_FLAG_AND | RT_EVENT_FLAG_CLEAR, RT_WAITING_NO, RT_NULL))
|
|
{
|
|
log_i ("net work lost");
|
|
mail.Type = MAIL_VIEW_NET_STE;
|
|
mail.index = DIS_STE_ERROR;
|
|
rt_mb_send (gViewMail, * ( (uint32_t*) &mail));
|
|
rt_timer_stop (timer);
|
|
// 发送消息给
|
|
}
|
|
if (MQTT_Subscribed() != 1) // 网络链接不成功
|
|
{
|
|
rt_thread_mdelay (1000);
|
|
goto INIT;
|
|
}
|
|
// 订阅成功
|
|
if (RT_EOK == rt_event_recv (gTrigEvents, EVENT_TRIG_MQTT_SUB, RT_EVENT_FLAG_AND | RT_EVENT_FLAG_CLEAR, RT_WAITING_NO, RT_NULL))
|
|
{
|
|
log_i ("sub Success");
|
|
// // 发送注册报
|
|
// mail.Type = MAIL_COMM_REGIST;
|
|
// mail.index = 1;
|
|
// rt_mb_send (gTCommMail, * ( (uint32_t *) &mail));
|
|
for (int i = 0; i < SUBTOPIC_COUNT; i++)
|
|
{
|
|
rt_timer_start (timer);
|
|
g_net_1min_timer[i] = i * 10 + 5;
|
|
g_net_5min_timer[i] = i * 10 + 10;
|
|
mail.Type = MAIL_VIEW_NET_STE;
|
|
mail.index = DIS_STE_SUCCSEE;
|
|
rt_mb_send (gViewMail, * ( (uint32_t*) &mail));
|
|
}
|
|
}
|
|
if (rt_mb_recv (gTCommMail, (rt_ubase_t *) &mail, RT_WAITING_NO) == RT_EOK)
|
|
{
|
|
log_i ("send packet: type:%s,index:%d", upinfo[mail.Type], mail.index);
|
|
if (g_ifupdate != 1)
|
|
{
|
|
switch (mail.Type)
|
|
{
|
|
case MAIL_COMM_HEART:
|
|
#ifdef USER_JSON_PACKET
|
|
gMqttDrv.tx_size = JsonHeartDatapacket ( (uint8_t *) gMqttDrv.txbuff);
|
|
gMqttDrv.tx_index = mail.index;
|
|
#else
|
|
// 心跳数据
|
|
gMqttDrv.tx_size = PacketHeader (0x2F, data, 4, gMqttDrv.txbuff);
|
|
gMqttDrv.tx_index = mail.index;
|
|
|
|
#endif
|
|
MQTT_SendData () ;
|
|
break;
|
|
case MAIL_COMM_REGIST: // 注册报
|
|
|
|
#ifdef USER_JSON_PACKET // 使用Json格式数据包
|
|
// gMqttDrv.tx_size = JsonRegistDataPacket ((uint8_t *) gMqttDrv.txbuff);
|
|
// gMqttDrv.tx_index = mail.index; // 通道号
|
|
#else
|
|
// 心跳数据
|
|
tx_size = PacketUpRegist (data);
|
|
gMqttDrv.tx_size = PacketHeader (0xE4, data, tx_size, gMqttDrv.txbuff);
|
|
gMqttDrv.tx_index = mail.index;
|
|
#endif
|
|
MQTT_SendData () ;
|
|
break;
|
|
case MAIL_COMM_SLUICE: // 闸门状态自报
|
|
#ifndef USER_JSON_PACKET // 使用Json格式数据包
|
|
tx_size = PacketSluiceUp (mail.index - 1, data);
|
|
gMqttDrv.tx_size = PacketHeader (0x4E, data, tx_size, gMqttDrv.txbuff);
|
|
gMqttDrv.tx_index = mail.index;
|
|
MQTT_SendData () ;
|
|
break;
|
|
#endif
|
|
case MAIL_COMM_STAND: // 5分钟标准包上报
|
|
|
|
#ifdef USER_JSON_PACKET // 使用Json格式数据包
|
|
// 判断站点类型
|
|
switch (site_type)
|
|
{
|
|
case SiteSluice: // 闸门站
|
|
gMqttDrv.tx_size = Json5MinSluiceDataPacket ( (uint8_t *) gMqttDrv.txbuff);
|
|
break;
|
|
case SiteFlow:
|
|
case SiteSee:
|
|
case SiteLevel:
|
|
case SiteSkew:
|
|
gMqttDrv.tx_size = Json5MinFlowDataPacket ( (uint8_t *) gMqttDrv.txbuff);
|
|
break;
|
|
case SiteColl:
|
|
case SiteServer:
|
|
break;
|
|
}
|
|
|
|
gMqttDrv.tx_index = mail.index;
|
|
#else
|
|
// 心跳数据
|
|
tx_size = PakcetTimerUp (mail.index - 1, data);
|
|
gMqttDrv.tx_size = PacketHeader (0x31, data, tx_size, gMqttDrv.txbuff);
|
|
gMqttDrv.tx_index = mail.index;
|
|
#endif
|
|
|
|
MQTT_SendData () ;
|
|
break;
|
|
// case MAIL_COMM_SLACK: // 提闸的应答
|
|
// tx_size = PacketSluiceAck (data);
|
|
// gMqttDrv.tx_size = PacketHeader (0x4E, data, tx_size, gMqttDrv.txbuff);
|
|
// gMqttDrv.tx_index = mail.index;
|
|
// MQTT_SendData();
|
|
// break;
|
|
|
|
|
|
|
|
// MQTT_SendData();
|
|
// break;
|
|
case MAIL_COMM_READPARA:
|
|
#ifdef USER_JSON_PACKET // 使用Json格式数据包
|
|
gMqttDrv.tx_size = JsonConfigReadDataPacket ((uint8_t *) gMqttDrv.txbuff);
|
|
gMqttDrv.tx_index = mail.index;
|
|
#else
|
|
// 心跳数据
|
|
tx_size = PacketUpRegist (data);
|
|
gMqttDrv.tx_size = PacketHeader (0xE4, data, tx_size, gMqttDrv.txbuff);
|
|
gMqttDrv.tx_index = mail.index;
|
|
#endif
|
|
MQTT_SendData();
|
|
break;
|
|
case MAIL_COMM_UPACK: // 升级的应答
|
|
|
|
#ifdef USER_JSON_PACKET // 使用Json格式数据包
|
|
gMqttDrv.tx_size = JsonAckDownload ((uint8_t *) gMqttDrv.txbuff,DownUpdate);
|
|
gMqttDrv.tx_index = mail.index;
|
|
#else
|
|
// 心跳数据
|
|
tx_size = PacketAnsAck (data);
|
|
gMqttDrv.tx_size = PacketHeader (0xE0, data, tx_size, gMqttDrv.txbuff);
|
|
gMqttDrv.tx_index = mail.index;
|
|
#endif
|
|
break;
|
|
case MAIL_COMM_SLACK: // 升级的应答
|
|
|
|
#ifdef USER_JSON_PACKET // 使用Json格式数据包
|
|
gMqttDrv.tx_size = JsonAckDownload ((uint8_t *) gMqttDrv.txbuff,DownRun);
|
|
gMqttDrv.tx_index = mail.index;
|
|
#else
|
|
// 心跳数据
|
|
tx_size = PacketAnsAck (data);
|
|
gMqttDrv.tx_size = PacketHeader (0xE0, data, tx_size, gMqttDrv.txbuff);
|
|
gMqttDrv.tx_index = mail.index;
|
|
#endif
|
|
break;
|
|
case MAIL_COMM_WRACK: // 升级的应答
|
|
|
|
#ifdef USER_JSON_PACKET // 使用Json格式数据包
|
|
gMqttDrv.tx_size = JsonAckDownload ((uint8_t *) gMqttDrv.txbuff,DownConfig);
|
|
gMqttDrv.tx_index = mail.index;
|
|
#else
|
|
// 心跳数据
|
|
tx_size = PacketAnsAck (data);
|
|
gMqttDrv.tx_size = PacketHeader (0xE0, data, tx_size, gMqttDrv.txbuff);
|
|
gMqttDrv.tx_index = mail.index;
|
|
#endif
|
|
break;
|
|
case MAIL_COMM_FACACK: // 升级的应答
|
|
|
|
#ifdef USER_JSON_PACKET // 使用Json格式数据包
|
|
gMqttDrv.tx_size = JsonAckDownload ((uint8_t *) gMqttDrv.txbuff,DownFact);
|
|
gMqttDrv.tx_index = mail.index;
|
|
#else
|
|
// 心跳数据
|
|
tx_size = PacketAnsAck (data);
|
|
gMqttDrv.tx_size = PacketHeader (0xE0, data, tx_size, gMqttDrv.txbuff);
|
|
gMqttDrv.tx_index = mail.index;
|
|
#endif
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
|
|
}
|
|
// 接受数据
|
|
if (RT_EOK == rt_event_recv (gTrigEvents, EVENT_TRIG_COMM_RX, RT_EVENT_FLAG_AND | RT_EVENT_FLAG_CLEAR, RT_WAITING_NO, RT_NULL))
|
|
{
|
|
|
|
#ifdef USER_JSON_PACKET // 使用Json格式数据包
|
|
// 这里-1的作用是将通道0 作为升级通道
|
|
JsonUnPacket(gMqttDrv.rx_index - 1,gMqttDrv.rxbuff); // 第n个通道过来的数据
|
|
// 解析数据
|
|
#else
|
|
rxdata_decode_size = hexstr_to_hexbyte (gMqttDrv.rxbuff, rxdata_decode, gMqttDrv.rx_size);
|
|
elog_hexdump("recv",16,rxdata_decode,rxdata_decode_size);
|
|
switch ( (int) rxdata_decode[10])
|
|
{
|
|
case 0x4E: // 控制闸门操作
|
|
{
|
|
// 远程提闸
|
|
datak = rxdata_decode[18];
|
|
datak = (datak << 8) + rxdata_decode[19];
|
|
log_i ("chann: %d,open:%u mm\r\n",gMqttDrv.rx_index, datak/10);
|
|
|
|
//SluiceData[gMqttDrv.rx_index].opt = 1; // 执行操作闸门
|
|
SluiceData[0].sopen = datak / 10;
|
|
mail.Type = MAIL_SLUICE_OPT;
|
|
mail.index = gMqttDrv.rx_index-1; // 获取是从哪个通道来的数据
|
|
rt_mb_send (gSluiceMail, * ( (uint32_t*) &mail));
|
|
log_i ("index:%u\r\n", mail.index);
|
|
// 回复应答
|
|
mail.Type = MAIL_COMM_SLACK;
|
|
mail.index = gMqttDrv.rx_index;
|
|
rt_mb_send (gTCommMail, * ( (uint32_t*) &mail));
|
|
break;
|
|
}
|
|
case 0xE0:// 远程升级
|
|
{
|
|
int filenamesize = 0;
|
|
rt_memset (SysData.fileName, 0, 32);
|
|
filenamesize = rxdata_decode[12] - 2;
|
|
rt_memcpy (SysData.fileName, &rxdata_decode[16], filenamesize);
|
|
// 启动升级线程
|
|
rt_kprintf ("filename:[%s]\r\n", SysData.fileName);
|
|
// 回复应答
|
|
mail.Type = MAIL_COMM_UPACK;
|
|
mail.index = gMqttDrv.rx_index;
|
|
rt_mb_send (gTCommMail, * ( (uint32_t*) &mail));
|
|
rt_thread_mdelay (2000);
|
|
|
|
UpgradeThreadStart();
|
|
//
|
|
// 应答ACK
|
|
break;
|
|
}
|
|
case 0xE1: // 远程停止闸门
|
|
{
|
|
mail.Type = MAIL_SLUICE_STP; // 停止提
|
|
mail.index = gMqttDrv.rx_index - 1;
|
|
rt_mb_send (gSluiceMail, * ( (uint32_t*) &mail));
|
|
break;
|
|
}
|
|
case 0xE2: // 读取远程参数
|
|
{
|
|
|
|
break;
|
|
}
|
|
default:
|
|
break;
|
|
}
|
|
#endif
|
|
}
|
|
// 网络连接丢失
|
|
rt_thread_mdelay (10);
|
|
}
|
|
//NETWORKEXIT:
|
|
|
|
}
|
|
|
|
void NET_APPThreadStart (void)
|
|
{
|
|
/* 创建线程1，名称是thread1，入口是thread1_entry*/
|
|
rt_thread_init (&netapp_thread, "netapp_thread",
|
|
thread_entry, RT_NULL,
|
|
&thread_stack[0],
|
|
sizeof (thread_stack),
|
|
NET_APP_THREAD_PRIORITY, NET_APP_THREAD_TIMESLICE);
|
|
rt_thread_startup (&netapp_thread);
|
|
return ;
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|